LoginController.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. <?php
  2. declare(strict_types=1);
  3. namespace App\Controller;
  4. use \Phper666\JWTAuth\JWT;
  5. use Hyperf\Di\Annotation\Inject;
  6. use Hyperf\HttpServer\Annotation\AutoController;
  7. use Hyperf\Validation\Contract\ValidatorFactoryInterface;
  8. use App\Tools\Result;
  9. use App\JsonRpc\UserServiceInterface;
  10. use App\Tools\CommonService;
  11. /**
  12. * @AutoController()
  13. */
  14. class LoginController extends AbstractController
  15. {
  16. #[Inject]
  17. protected ValidatorFactoryInterface $validationFactory;
  18. /**
  19. * @var UserServiceInterface
  20. */
  21. #[Inject]
  22. private $userServiceClient;
  23. public function login(Jwt $jwt)
  24. {
  25. $this->logger->info("验证之前");
  26. $reqData = $this->request->all();
  27. $validator = $this->validationFactory->make(
  28. $reqData,
  29. [
  30. 'username' => 'required',
  31. 'password' => 'required',
  32. 'type' =>'required'
  33. ],
  34. [
  35. 'username.required' => '用户名不能为空',
  36. 'password.required' => '密码不能为空',
  37. 'type.required' => '登录方式必填'
  38. ]
  39. );
  40. if ($validator->fails()){
  41. $errorMessage = $validator->errors()->first();
  42. return Result::error($errorMessage);
  43. }
  44. $comm = new CommonService();
  45. $ip = $comm->userIp();
  46. $redis = $this->container->get(\Hyperf\Redis\Redis::class);
  47. $code = $redis->get('code'.$ip);
  48. if(empty($code)){
  49. return Result::error("验证码已过期");
  50. }
  51. var_dump("验证码:",$code);
  52. if(strtolower($code)!=$reqData['captcha']){
  53. return Result::error("验证码错误");
  54. }
  55. //$reqData
  56. $where = [];
  57. if($reqData['type'] ==1){//密码登录
  58. $where = [
  59. 'user_name'=>$reqData['username'],
  60. ];
  61. }
  62. $this->logger->info("验证之前");
  63. $userInfos = $this->userServiceClient->verifyUserInfo($where);
  64. $this->logger->info("验证用户返回值:", $userInfos);
  65. if(md5(md5($reqData['password']).$userInfos['data']['salt']) != $userInfos['data']['password']){
  66. return Result::error("用户名或密码错误");
  67. }
  68. $userData = [
  69. 'uid' => $userInfos['data']['id'], // 如果使用单点登录,必须存在配置文件中的sso_key的值,一般设置为用户的id
  70. 'user_name' => $userInfos['data']['user_name'],
  71. 'role_id' => $userInfos['data']['role_id'],
  72. 'mobile' => $userInfos['data']['mobile'],
  73. 'email' => $userInfos['data']['email'],
  74. 'rong_token' => $userInfos['data']['rong_token'],
  75. 'level_id' => $userInfos['data']['level_id']
  76. ];
  77. var_dump($userData);
  78. // 使用默认场景登录
  79. $token = $jwt->getToken('default', $userData);
  80. $data = [
  81. 'token' => $token->toString(),
  82. 'exp' => $jwt->getTTL($token->toString()),
  83. ];
  84. return Result::success($data);
  85. }
  86. /**
  87. * 注册或登陆
  88. * @return void
  89. */
  90. public function registerOrLogin()
  91. {
  92. }
  93. # http头部必须携带token才能访问的路由
  94. public function getData(Jwt $jwt)
  95. {
  96. // var_dump($this->UserId);
  97. $h = $this->request->getHeaders();
  98. // var_dump($this->request->getHeaders());
  99. // $a= 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJwaHBlcjY2Ni9qd3QiLCJ1aWQiOjMyLCJ1c2VyX25hbWUiOiIxIiwicm9sZV9pZCI6MSwibW9iaWxlIjoiMTU4MDEyNDU3NTUiLCJlbWFpbCI6IjVAcXEuY29tIiwicm9uZ190b2tlbiI6IiIsImxldmVsX2lkIjo4LCJqd3Rfc2NlbmUiOiJkZWZhdWx0IiwianRpIjoiZGVmYXVsdF82Njc1MjJkZDQ3YWYxMi41MTE5MjI5MiIsImlhdCI6MTcxODk1MjY2OSwibmJmIjoxNzE4OTUyNjY5LCJleHAiOjE3MjE1NDQ2Njl9.e0JW8fgNrwBdFgmQ8GNtES2ME1SbcbIih5MsQWzT6sk';
  100. $arr = $jwt->getClaimsByToken($h['token'][0]);
  101. var_dump($h['token'][0],"+++++++++++",$arr,"===####");
  102. return $this->response->json(['code' => 0, 'msg' => 'success', 'data' => ['a' => 1]]);
  103. }
  104. }