Auth.php 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  1. <?php
  2. namespace app\controller\api;
  3. use app\extra\basic\Base;
  4. use app\extra\dyLife\Crypt;
  5. use app\extra\tools\CodeExtend;
  6. use app\middleware\AuthMiddleware;
  7. use app\model\saas\SaasUserOpen;
  8. use DI\Attribute\Inject;
  9. use LinFly\Annotation\Attributes\Route\Controller;
  10. use LinFly\Annotation\Attributes\Route\GetMapping;
  11. use LinFly\Annotation\Attributes\Route\Middleware;
  12. use LinFly\Annotation\Attributes\Route\PostMapping;
  13. use support\Request;
  14. use Shopwwi\WebmanAuth\Facade\Auth as AuthFacade;
  15. use support\Response;
  16. #[Controller("/dy/auth"),Middleware(AuthMiddleware::class)]
  17. class Auth extends Base
  18. {
  19. protected array $noNeedLogin = ["log2mobile","log2nickname","loginMobileAuth",'loginNicknameAuth'];
  20. #[Inject]
  21. protected SaasUserOpen $model;
  22. /**
  23. * 授权获取手机号-非登录
  24. * @param Request $request
  25. * @return Response
  26. */
  27. #[PostMapping("mobile/auth")]
  28. public function loginMobileAuth(Request $request): Response
  29. {
  30. try {
  31. $param = $this->_valid([
  32. "login.require" => '获取登录参数失败',
  33. "code.default" => '',
  34. "encryptedData.default" => '',
  35. "iv.default" => '',
  36. ],$request->method());
  37. if (!is_array($param)) return error($param);
  38. echo getDateFull()."登录手机号信息\n";
  39. echo json_encode($param)."\n";
  40. $sessionKey = (new Crypt)->config($this->getDyConfig())->getSessionKey($param['login']);
  41. if (empty($sessionKey)) return error("授权登录失败-m");
  42. if (!empty($param['code'])) {
  43. $mobileStr = (new Crypt)->config($this->getDyConfig())->token()->getMobile($param['code']);
  44. } else {
  45. $data = $this->decrypt($param['encryptedData'],$sessionKey['session_key'],$param['iv']);
  46. $mobileStr = $data['purePhoneNumber'];
  47. }
  48. if (empty($mobileStr)) return error("授权信息获取失败");
  49. return $this->encode("success",['mobile' => $mobileStr,'openid' => $sessionKey['openid']]);
  50. } catch (\Throwable $throwable) {
  51. return error($throwable->getMessage());
  52. }
  53. }
  54. /**
  55. * 授权昵称等信息-实际登录
  56. * @param Request $request
  57. * @return Response
  58. */
  59. #[PostMapping("nickname/auth")]
  60. public function loginNicknameAuth(Request $request): Response
  61. {
  62. try {
  63. $param = $this->_valid([
  64. "avatar.require" => trans("empty.require"),
  65. "nickname.require" => trans("empty.require"),
  66. "mobile.require" => trans("empty.require"),
  67. ],$request->method());
  68. if (!is_array($param)) return error($param);
  69. echo getDateFull()."登录昵称信息\n";
  70. echo json_encode($param)."\n";
  71. $mobileData = json_decode($param['mobile'],true);
  72. $mobile = [];
  73. if (!empty($param['mobile'])) {
  74. if (!isset($mobileData['openid'])) return error("授权失败");
  75. if (isValidMobile($mobileData['mobile'])) {
  76. $mobile = ["purePhoneNumber" => $mobileData['mobile']];
  77. } else {
  78. $mobile = $this->decrypt2code(sConf('wechat.min_private_key'), $mobileData['mobile']);
  79. }
  80. }
  81. if (empty($mobile)) return error("授权登录失败-u");
  82. $userInfo = [
  83. "openid" => $mobileData['openid'],
  84. "nickname" => $param['nickname']?removeEmoji2($param['nickname']):'',
  85. "avatar" => $param['avatar']
  86. ];
  87. $map = ["openid" => $mobileData['openid']];
  88. if (!empty($mobile['purePhoneNumber'])) {
  89. $userInfo['mobile'] = $mobile['purePhoneNumber'];
  90. }
  91. $user = $this->model->where($map)->findOrEmpty();
  92. if ($user->isEmpty()) {
  93. $userInfo["create_ip"] = $request->getRealIp();
  94. $user->insertGetId($userInfo);
  95. }
  96. $userAuth = get_object_vars(AuthFacade::guard("user")->login(['openid' => $mobileData['openid']]));
  97. return success("ok",$userAuth);
  98. } catch (\Throwable $throwable) {
  99. return error($throwable->getMessage());
  100. }
  101. }
  102. #[PostMapping("nickname")]
  103. public function log2nickname(Request $request): Response
  104. {
  105. try {
  106. $param = $request->post();
  107. $sessionKey = (new Crypt)->config($this->getDyConfig())->getSessionKey($param['login']);
  108. if (empty($sessionKey)) return error("授权登录失败");
  109. $userInfo = [
  110. "openid" => $sessionKey['openid'],
  111. "nickname" => $param['nickname']?removeEmoji2($param['nickname']):'',
  112. "avatar" => $param['avatar']??'',
  113. "create_ip" => $request->getRealIp()
  114. ];
  115. $map = ["openid" => $sessionKey['openid']];
  116. $user = $this->model->where($map)->findOrEmpty();
  117. if ($user->isEmpty()) {
  118. $user->insertGetId($userInfo);
  119. } else {
  120. $user->nickname = $param['nickname']?removeEmoji2($param['nickname']):'';
  121. $user->avatar = $param['avatar']??'';
  122. $user->save();
  123. }
  124. $userAuth = get_object_vars(AuthFacade::guard("user")->login(['openid' => $sessionKey['openid']]));
  125. return success("ok",$userAuth);
  126. } catch (\Throwable $th) {
  127. return error($th->getMessage());
  128. }
  129. }
  130. #[PostMapping("mobile")]
  131. public function log2mobile(Request $request): Response
  132. {
  133. try {
  134. $param = $request->post();
  135. $sessionKey = (new Crypt)->config($this->getDyConfig())->getSessionKey($param['login']);
  136. if (empty($sessionKey)) return error("授权登录失败");
  137. $mobile = [];
  138. if (!empty($param['code'])) {
  139. $mobileStr = (new Crypt)->config($this->getDyConfig())->token()->getMobile($param['code']);
  140. if (!empty($mobileStr)) {
  141. $mobile = $this->decrypt2code(sConf('wechat.min_private_key'), $mobileStr);
  142. }
  143. }
  144. $userInfo = [
  145. "openid" => $sessionKey['openid'],
  146. "create_ip" => $request->getRealIp()
  147. ];
  148. $map = ["openid" => $sessionKey['openid']];
  149. if (!empty($mobile['purePhoneNumber'])) {
  150. $userInfo['mobile'] = $mobile['purePhoneNumber'];
  151. }
  152. $user = $this->model->where($map)->findOrEmpty();
  153. if ($user->isEmpty()) {
  154. $user->insertGetId($userInfo);
  155. }
  156. $userAuth = get_object_vars(AuthFacade::guard("user")->login(['openid' => $sessionKey['openid']]));
  157. return success("ok",$userAuth);
  158. } catch (\Throwable $th) {
  159. return error($th->getMessage());
  160. }
  161. }
  162. protected function decrypt2code($private_key, $ciphertext_str) {
  163. // 解码 base64 密文
  164. $ciphertext = base64_decode($ciphertext_str);
  165. // 使用私钥解密
  166. openssl_private_decrypt($ciphertext, $plaintext, $private_key, OPENSSL_PKCS1_PADDING);
  167. if ($plaintext === false) {
  168. return [];
  169. }
  170. return json_decode($plaintext,true);
  171. }
  172. protected function decrypt($encrypted_data, $session_key, $iv) {
  173. $data = base64_decode($encrypted_data);
  174. $key = base64_decode($session_key);
  175. $iv_decoded = base64_decode($iv);
  176. // 使用 AES-256-CBC 模式解密
  177. $decrypted = openssl_decrypt($data, 'AES-128-CBC', $key, OPENSSL_RAW_DATA, $iv_decoded);
  178. return json_decode($decrypted,true);
  179. }
  180. }