AuthService.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317
  1. <?php
  2. namespace App\Services\Auth;
  3. use App\Models\Company;
  4. use App\Models\LotteryWin;
  5. use App\Models\Organization;
  6. use App\Models\Member;
  7. use App\Models\Thirdlogin;
  8. use App\Repositories\CompanyRepository;
  9. use App\Repositories\MemberInfoRepository;
  10. use App\Repositories\MemberLogRepository;
  11. use App\Repositories\MemberRepository;
  12. use App\Repositories\ThirdloginRepository;
  13. use Illuminate\Contracts\Auth\Authenticatable;
  14. use Illuminate\Database\Eloquent\Model;
  15. use Illuminate\Support\Facades\Auth;
  16. use Illuminate\Support\Facades\Cache;
  17. use Illuminate\Support\Facades\Hash;
  18. use App\Repositories\OrganizationRepository;
  19. use Illuminate\Support\Facades\Session;
  20. class AuthService
  21. {
  22. /**
  23. * @var MemberRepository
  24. */
  25. protected $memberRepository;
  26. /**
  27. * @var CompanyRepository
  28. */
  29. protected $companyRepository;
  30. /**
  31. * @var MemberLogRepository
  32. */
  33. private $memberLogRepository;
  34. /**
  35. * @var ThirdloginRepository
  36. */
  37. private $thirdloginRepository;
  38. /**
  39. * @var MemberInfoRepository
  40. */
  41. private $memberInfoRepository;
  42. //20200217 zmw 增加机构认证
  43. protected $organizationRepository;
  44. /**
  45. * AuthService constructor.
  46. * @param MemberInfoRepository $memberInfoRepository
  47. * @param MemberRepository $memberRepository
  48. * @param CompanyRepository $companyRepository
  49. * @param MemberLogRepository $memberLogRepository
  50. * @param ThirdloginRepository $thirdloginRepository
  51. */
  52. public function __construct(MemberInfoRepository $memberInfoRepository, MemberRepository $memberRepository, CompanyRepository $companyRepository, OrganizationRepository $organizationRepository, MemberLogRepository $memberLogRepository, ThirdloginRepository $thirdloginRepository)
  53. {
  54. $this->memberRepository = $memberRepository;
  55. $this->companyRepository = $companyRepository;
  56. $this->memberLogRepository = $memberLogRepository;
  57. $this->thirdloginRepository = $thirdloginRepository;
  58. $this->memberInfoRepository = $memberInfoRepository;
  59. $this->organizationRepository = $organizationRepository;
  60. }
  61. public function loginByAccount($account, $password = '', $isAutoLogin = 0)
  62. {
  63. $user = $this->checkUser($account, $password, 2);
  64. if (!$user) {
  65. return false;
  66. }
  67. $this->login($user, $isAutoLogin);
  68. //绑定微信和中奖
  69. $open_id = Session::get('open_id');
  70. if (!empty($open_id)) {
  71. $union_id = Session::get('union_id', '');
  72. $data = [
  73. 'uid' => $user->id,
  74. 'utype' => 2,
  75. 'type' => 3,
  76. 'openid' => $open_id,
  77. 'unionid' => $union_id,
  78. ];
  79. Thirdlogin::create($data);
  80. $prize_id = Session::get('prize_id',0);
  81. if (!empty($prize_id)) {
  82. $win = new LotteryWin();
  83. $win->member_id = $user->id;
  84. $win->prize_id = $prize_id;
  85. $win->created_at = date('Y-m-d H:i:s');
  86. $win->save();
  87. }
  88. Session::forget('open_id');
  89. Session::forget('union_id');
  90. Session::forget('prize_id');
  91. Session::save();
  92. }
  93. return $user;
  94. }
  95. public function loginByCompany($account, $password, $isAutoLogin = 0)
  96. {
  97. $user = $this->checkUser($account, $password, 1);
  98. if (!$user) {
  99. return false;
  100. }
  101. $this->login($user, $isAutoLogin);
  102. return $user;
  103. }
  104. public function loginByOrganization($account, $password, $isAutoLogin = 0)
  105. {
  106. $user = $this->checkUser($account, $password, 3);
  107. if (!$user) {
  108. return false;
  109. }
  110. $this->login($user, $isAutoLogin);
  111. return $user;
  112. }
  113. /**
  114. * @return string
  115. */
  116. public function resetPasswordToken($data)
  117. {
  118. $token = str_random(32);
  119. Cache::put($token, $data, 24 * 60);
  120. return $token;
  121. }
  122. public function checkResetPasswordToken($token)
  123. {
  124. return Cache::get($token, false);
  125. }
  126. public function resetPassword($token, $password)
  127. {
  128. $data = Cache::pull($token);
  129. if ($data['utype'] == 1) {
  130. $this->companyRepository->resetPassword($data['type'], $data[$data['type']], $password);
  131. } elseif ($data['utype'] == 2) {
  132. $this->memberRepository->resetPassword($data['type'], $data[$data['type']], $password);
  133. }
  134. return $data['utype'];
  135. }
  136. public function sendEmailHook($email, $token)
  137. {
  138. Cache::put('reset_password' . $email, $token, 24 * 60);
  139. }
  140. public function getTokenByEmail($email)
  141. {
  142. return Cache::pull('reset_password' . $email);
  143. }
  144. /**
  145. * 检查微信账号是否已绑定账号和登录网站
  146. * @param array $wechatUser
  147. * @param int $type 2微信开放平台,3微信公众号,4微信小程序
  148. * @return bool
  149. */
  150. public function wechatCheck(array $wechatUser, $type = 2)
  151. {
  152. $user = $this->thirdloginRepository->checkWechat($wechatUser['openid'], isset($wechatUser['unionid']) ? $wechatUser['unionid'] : "", $type);
  153. if (!$user) {
  154. return false;
  155. }
  156. return $user;
  157. }
  158. /**
  159. * 检查qq账号是否已绑定账号和登录网站
  160. * @param array $qqUser
  161. * @param int $type
  162. * @return bool
  163. */
  164. public function qqCheck(array $qqUser, $type = 1)
  165. {
  166. $user = $this->thirdloginRepository->checkQQ($qqUser['openid']);
  167. if (!$user) {
  168. return false;
  169. }
  170. return $user;
  171. }
  172. /**
  173. * @param array $wechatUser
  174. * @param Model|Authenticatable $user
  175. * @param bool $update_message 是否更新用户信息
  176. * @param int $type 2微信开放平台,3微信公众号,4微信小程序
  177. * @throws \Prettus\Validator\Exceptions\ValidatorException
  178. */
  179. public function wechatRegister(array $wechatUser, $user, $update_message = false, $type = 2)
  180. {
  181. $data['uid'] = $user->id;
  182. $data['utype'] = ($user instanceof Member) ? 2 : 1;
  183. $data['type'] = $type;
  184. $data['subsite_id'] = $user->subsite_id;
  185. $data['openid'] = $wechatUser['openid'];
  186. $data['unionid'] = isset($wechatUser['unionid']) ? $wechatUser['unionid'] : "";
  187. $this->thirdloginRepository->create($data);
  188. // if ($update_message) {//暂时不更新信息
  189. // if ($user instanceof Member) {
  190. // $image_path="person/images/".uniqid().'.jpg';
  191. // download($wechatUser['headimgurl'], $image_path);
  192. // $this->memberInfoRepository->updateInfo(['images'=>$image_path], $user->id);
  193. // } else {
  194. // $image_path="company/logo/".uniqid().'.jpg';
  195. // download($wechatUser['headimgurl'], $image_path);
  196. // $this->companyRepository->save(['logo'=>$image_path], $user->id);
  197. // }
  198. // }
  199. }
  200. /**
  201. * @param array $qqUser
  202. * @param Model|Authenticatable $user
  203. * @param bool $update_message 是否更新用户信息
  204. * @param int $type 1 QQ
  205. * @throws \Prettus\Validator\Exceptions\ValidatorException
  206. */
  207. public function qqRegister(array $qqUser, $user, $update_message = false, $type = 1)
  208. {
  209. $data['uid'] = $user->id;
  210. $data['utype'] = ($user instanceof Member) ? 2 : 1;
  211. $data['type'] = $type;
  212. $data['subsite_id'] = $user->subsite_id;
  213. $data['openid'] = $qqUser['openid'];
  214. $data['unionid'] = "";
  215. $this->thirdloginRepository->create($data);
  216. // if ($update_message) {//暂时不更新信息
  217. // if ($user instanceof Member) {
  218. // $image_path="person/images/".uniqid().'.jpg';
  219. // download($wechatUser['headimgurl'], $image_path);
  220. // $this->memberInfoRepository->updateInfo(['images'=>$image_path], $user->id);
  221. // } else {
  222. // $image_path="company/logo/".uniqid().'.jpg';
  223. // download($wechatUser['headimgurl'], $image_path);
  224. // $this->companyRepository->save(['logo'=>$image_path], $user->id);
  225. // }
  226. // }
  227. }
  228. /**
  229. * 检查用户是否存在
  230. * @param $username
  231. * @param $password
  232. * @param $utype 1企业,2用户
  233. * @return bool|\Illuminate\Database\Eloquent\Model|null
  234. */
  235. public function checkUser($username, $password, $utype)
  236. {
  237. if ($utype == 2) {
  238. $user = $this->memberRepository->getMemberByAccount($username);
  239. } elseif ($utype == 3) {
  240. $user = $this->organizationRepository->getOrganizationByAccount($username);
  241. } else {
  242. $user = $this->companyRepository->getCompanyByAccount($username);
  243. }
  244. if (!$user) {
  245. return false;
  246. }
  247. if ($password && !Hash::check($password, $user->password)) {
  248. if (!empty($user->old_password)) {
  249. //旧系统数据密码转移
  250. $oldmembers = \App\Transfer\Member::select('pwd_hash')->where('uid', $user->id)->first();
  251. if (md5(md5($password) . $oldmembers->pwd_hash . 'pNxOnSBtDzW7-7Pi') == $user->old_password) {
  252. $user->old_password = "";
  253. $user->password = Hash::make($password);
  254. $user->save();
  255. return $user;
  256. }
  257. }
  258. return false;
  259. }
  260. return $user;
  261. }
  262. public function login($user, $isAutoLogin = 0)
  263. {
  264. $isAutoLogin = $isAutoLogin ? true : false;
  265. if ($user instanceof Company) {
  266. Auth::guard('web-company')->login($user, $isAutoLogin);
  267. $this->companyRepository->updateLoginStatus($user);
  268. $this->memberLogRepository->createLog($user, 1001, []);
  269. } elseif ($user instanceof Organization) {
  270. Auth::guard('web-organization')->login($user, $isAutoLogin);
  271. $this->organizationRepository->updateLoginStatus($user);
  272. $this->memberLogRepository->createLog($user, 1001, []);
  273. } else {
  274. Auth::guard('web-member')->login($user, $isAutoLogin);
  275. $this->memberRepository->updateLoginStatus($user);
  276. $this->memberLogRepository->createLog($user, 1001, []);
  277. }
  278. }
  279. public function logout()
  280. {
  281. Auth::guard('web-company')->logout();
  282. Auth::guard('web-member')->logout();
  283. Auth::guard('web-organization')->logout();
  284. }
  285. }