App_Controller_LoginController.proxy.php 4.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  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. use \Hyperf\Di\Aop\ProxyTrait;
  17. use \Hyperf\Di\Aop\PropertyHandlerTrait;
  18. function __construct(\Hyperf\Logger\LoggerFactory $loggerFactory)
  19. {
  20. if (method_exists(parent::class, '__construct')) {
  21. parent::__construct(...func_get_args());
  22. }
  23. $this->__handlePropertyHandler(__CLASS__);
  24. }
  25. #[Inject]
  26. protected ValidatorFactoryInterface $validationFactory;
  27. /**
  28. * @var UserServiceInterface
  29. */
  30. #[Inject]
  31. private $userServiceClient;
  32. public function login(Jwt $jwt)
  33. {
  34. $this->logger->info("验证之前");
  35. $reqData = $this->request->all();
  36. $validator = $this->validationFactory->make($reqData, ['username' => 'required', 'password' => 'required', 'type' => 'required'], ['username.required' => '用户名不能为空', 'password.required' => '密码不能为空', 'type.required' => '登录方式必填']);
  37. if ($validator->fails()) {
  38. $errorMessage = $validator->errors()->first();
  39. return Result::error($errorMessage);
  40. }
  41. $comm = new CommonService();
  42. $ip = $comm->userIp();
  43. $redis = $this->container->get(\Hyperf\Redis\Redis::class);
  44. $code = $redis->get('code' . $ip);
  45. if (empty($code)) {
  46. return Result::error("验证码已过期");
  47. }
  48. var_dump("验证码:", $code);
  49. if (strtolower($code) != $reqData['captcha']) {
  50. return Result::error("验证码错误");
  51. }
  52. //$reqData
  53. $where = [];
  54. if ($reqData['type'] == 1) {
  55. //密码登录
  56. $where = ['user_name' => $reqData['username']];
  57. }
  58. $this->logger->info("验证之前");
  59. $userInfos = $this->userServiceClient->verifyUserInfo($where);
  60. $this->logger->info("验证用户返回值:", $userInfos);
  61. if (md5(md5($reqData['password']) . $userInfos['data']['salt']) != $userInfos['data']['password']) {
  62. return Result::error("用户名或密码错误");
  63. }
  64. $userData = [
  65. 'uid' => $userInfos['data']['id'],
  66. // 如果使用单点登录,必须存在配置文件中的sso_key的值,一般设置为用户的id
  67. 'user_name' => $userInfos['data']['user_name'],
  68. 'role_id' => $userInfos['data']['role_id'],
  69. 'mobile' => $userInfos['data']['mobile'],
  70. 'email' => $userInfos['data']['email'],
  71. 'rong_token' => $userInfos['data']['rong_token'],
  72. 'level_id' => $userInfos['data']['level_id'],
  73. ];
  74. // 使用默认场景登录
  75. $token = $jwt->getToken('default', $userData);
  76. $data = ['token' => $token->toString(), 'exp' => $jwt->getTTL($token->toString())];
  77. return Result::success($data);
  78. }
  79. # http头部必须携带token才能访问的路由
  80. public function getData(Jwt $jwt)
  81. {
  82. // var_dump($this->UserId);
  83. $h = $this->request->getHeaders();
  84. // var_dump($this->request->getHeaders());
  85. // $a= 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJwaHBlcjY2Ni9qd3QiLCJ1aWQiOjMyLCJ1c2VyX25hbWUiOiIxIiwicm9sZV9pZCI6MSwibW9iaWxlIjoiMTU4MDEyNDU3NTUiLCJlbWFpbCI6IjVAcXEuY29tIiwicm9uZ190b2tlbiI6IiIsImxldmVsX2lkIjo4LCJqd3Rfc2NlbmUiOiJkZWZhdWx0IiwianRpIjoiZGVmYXVsdF82Njc1MjJkZDQ3YWYxMi41MTE5MjI5MiIsImlhdCI6MTcxODk1MjY2OSwibmJmIjoxNzE4OTUyNjY5LCJleHAiOjE3MjE1NDQ2Njl9.e0JW8fgNrwBdFgmQ8GNtES2ME1SbcbIih5MsQWzT6sk';
  86. $arr = $jwt->getClaimsByToken($h['token'][0]);
  87. var_dump($h['token'][0], "+++++++++++", $arr, "===####");
  88. return $this->response->json(['code' => 0, 'msg' => 'success', 'data' => ['a' => 1]]);
  89. }
  90. }