UserController.php 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192
  1. <?php
  2. namespace mall\controllers;
  3. use bizHd\custom\classes\CustomClass;
  4. use bizHd\wx\classes\WxOpenClass;
  5. use bizMall\message\services\SmsService;
  6. use bizMall\user\classes\UserClass;
  7. use bizMall\user\services\UserAssetService;
  8. use bizMall\user\services\UserService;
  9. use common\components\jwt;
  10. use common\components\stringUtil;
  11. use Yii;
  12. use common\components\util;
  13. use yii\helpers\Json;
  14. class UserController extends BaseController
  15. {
  16. //创建用户和客户 ssh 20220607
  17. public function actionCreate()
  18. {
  19. $post = Yii::$app->request->post();
  20. $user = UserClass::replaceUser($post);
  21. if (isset($this->shop) && !empty($this->shop)) {
  22. //增加商家的客户
  23. CustomClass::replaceCustom($this->shop, $user);
  24. //增加用户的门店
  25. UserClass::addRecentShop($this->shop->id, $user);
  26. }
  27. $userId = $user->id ?? 0;
  28. $token = !empty($userId) ? jwt::getNewToken($userId) : '';
  29. $fullUser = UserClass::getById($userId, true);
  30. util::success(['user' => $fullUser, 'token' => $token]);
  31. }
  32. //最近店铺 ssh 2021.2.27
  33. public function actionRecentShop()
  34. {
  35. $list = [];
  36. //显示国兰的信息 0不是 1是
  37. $showGlInfo = getenv('SHOW_GL_INFO');
  38. $info = $showGlInfo === false ? 1 : $showGlInfo;
  39. util::success(['list' => $list, 'showGlInfo' => $info]);
  40. }
  41. //获取登陆客户的资产 ssh 2019.11.22
  42. public function actionAsset()
  43. {
  44. $asset = UserAssetService::getByUserId($this->userId);
  45. util::success($asset);
  46. }
  47. //获取登陆客户的优惠情况 ssh 2019.12.3
  48. public function actionDiscount()
  49. {
  50. $discount = UserAssetService::getDiscount($this->userId);
  51. util::success($discount);
  52. }
  53. //小程序用户完整信息 ssh 2019.12.12
  54. public function actionMiniFullInfo()
  55. {
  56. $post = Yii::$app->request->post();
  57. $iv = isset($post['iv']) ? $post['iv'] : '';
  58. $encryptedData = isset($post['encryptedData']) ? $post['encryptedData'] : '';
  59. $merchant = WxOpenClass::getMallWxMiniBase();
  60. $appId = $merchant['miniAppId'];
  61. $miniOpenId = $post['miniOpenId'];
  62. if (empty($miniOpenId)) {
  63. util::success(['hasNoOpenId' => 1], '登录失败');
  64. }
  65. $cacheKey = 'MALL_MINI_SESSION_KEY_' . $miniOpenId;
  66. $sessionKey = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
  67. $wxMiniSecret = Yii::getAlias("@vendor/weixinMiniSecret");
  68. require_once($wxMiniSecret . '/wxBizDataCrypt.php');
  69. $pc = new \WXBizDataCrypt($appId, $sessionKey);
  70. $errCode = $pc->decryptData($encryptedData, $iv, $result);
  71. if ($errCode != 0) {
  72. Yii::info($result . ' ' . $errCode);
  73. util::fail('获取用户信息失败');
  74. }
  75. Yii::info('小程序获取用户信息:' . $result);
  76. $originalInfo = Json::decode($result);
  77. util::success($originalInfo);
  78. }
  79. //小程序用户手机号
  80. public function actionMiniMobile()
  81. {
  82. $post = Yii::$app->request->post();
  83. $iv = $post['iv'];
  84. $encryptedData = $post['encryptedData'];
  85. $merchant = WxOpenClass::getMallWxMiniBase();
  86. $appId = $merchant['miniAppId'];
  87. $miniOpenId = $post['miniOpenId'];
  88. if (empty($miniOpenId)) {
  89. util::success(['hasNoOpenId' => 1], '登录失败');
  90. }
  91. $cacheKey = 'MALL_MINI_SESSION_KEY_' . $miniOpenId;
  92. $sessionKey = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
  93. if (empty($sessionKey)) {
  94. util::fail('系统错误,session empty');
  95. }
  96. $wxMiniSecret = Yii::getAlias("@vendor/weixinMiniSecret");
  97. require_once($wxMiniSecret . '/wxBizDataCrypt.php');
  98. $pc = new \WXBizDataCrypt($appId, $sessionKey);
  99. $errCode = $pc->decryptData($encryptedData, $iv, $result);
  100. if ($errCode != 0) {
  101. util::fail('解密失败');
  102. }
  103. $arr = Json::decode($result);
  104. $mobile = isset($arr['purePhoneNumber']) ? $arr['purePhoneNumber'] : '';
  105. if (empty($mobile)) {
  106. util::fail('没有取到手机号,请重试');
  107. }
  108. util::success(['mobile' => $mobile]);
  109. }
  110. //密码修改
  111. public function actionPassword()
  112. {
  113. $post = Yii::$app->request->post();
  114. $old = isset($post['old']) ? $post['old'] : '';
  115. $new = isset($post['new']) ? $post['new'] : '';
  116. $confirm = isset($post['confirm']) ? $post['confirm'] : '';
  117. if (empty($new)) {
  118. util::fail('请输入新密码');
  119. }
  120. if ($new != $confirm) {
  121. util::fail('二次密码不一致');
  122. }
  123. $userId = $this->userId;
  124. $user = UserService::getUserInfo($userId);
  125. if (isset($user['hasPayPwd']) && $user['hasPayPwd'] == 1) {
  126. if (empty($old)) {
  127. util::fail('请填写旧密码');
  128. }
  129. if (password_verify($old, $user['payPassword']) == false) {
  130. util::fail('旧密码错误');
  131. }
  132. }
  133. UserService::updateById($userId, ['payPassword' => password_hash($new, PASSWORD_BCRYPT), 'hasPayPwd' => 1]);
  134. util::complete('修改成功');
  135. }
  136. //申请会员 ssh 2019.12.18
  137. public function actionApplyMember()
  138. {
  139. $post = Yii::$app->request->post();
  140. $mobile = isset($post['mobile']) ? $post['mobile'] : 0;
  141. if (stringUtil::isMobile($mobile) == false) {
  142. util::fail('请输入手机号');
  143. }
  144. $userId = $this->userId;
  145. $asset = UserAssetService::getByUserId($userId);
  146. if (isset($asset['member']) && $asset['member'] != -1) {
  147. util::fail('已经是会员了');
  148. }
  149. $code = isset($post['code']) ? $post['code'] : '';
  150. $cacheCode = SmsService::getApplyMemberCode($userId, $mobile);
  151. if (empty($cacheCode) || $cacheCode != $code) {
  152. util::fail('验证码错误');
  153. }
  154. $update = [];
  155. if (isset($post['realName']) && !empty($post['realName'])) {
  156. $update['realName'] = $post['realName'];
  157. }
  158. if (isset($post['birthday']) && !empty($post['birthday'])) {
  159. $update['birthday'] = $post['birthday'];
  160. }
  161. $user = UserService::getByCondition(['sjId' => $this->sjId, 'mobile' => $mobile]);
  162. if ($userId == $user['id']) {
  163. util::fail('手机号已验证');
  164. }
  165. if (!empty($user)) {
  166. util::fail('手机号已经注册过了');
  167. }
  168. $update['mobile'] = $mobile;
  169. $userInfo = isset($this->user->attributes) ? $this->user->attributes : [];
  170. UserService::becomeMember($userInfo, $this->sj->attributes, $update);
  171. util::complete('注册成功');
  172. }
  173. //登陆客户的信息 ssh 2020.3.12
  174. public function actionLoginDetail()
  175. {
  176. $user = isset($this->user->attributes) ? $this->user->attributes : [];
  177. util::success($user);
  178. }
  179. }