AuthService.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390
  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 && $password == '') {
  65. //20251020增加验证登录直接注册功能
  66. $data = [
  67. 'mobile' => $account,
  68. 'password' => Hash::make($this->getRandomName()),
  69. 'utype' => 1,
  70. 'reg_type' => 1,
  71. 'reg_source' => 2,
  72. 'member_status' => 1,
  73. 'reg_source_cn' => '接码自动注册',
  74. 'mobile_audit' => 1,
  75. 'username' => $this->getRandomName(),
  76. 'reg_time' => time(),
  77. 'last_login_time' => time(),
  78. 'reg_ip' => ip2long(request()->ip()),
  79. ];
  80. $member = $this->memberRepository->create($data);
  81. $user = $this->checkUser($account, $password, 2);
  82. }else{
  83. return false;
  84. }
  85. // if(!$this->checkPwdLog($user)){
  86. // return false;
  87. // }
  88. $this->login($user, $isAutoLogin);
  89. //绑定微信和中奖
  90. $open_id = Session::get('open_id');
  91. if (!empty($open_id)) {
  92. $union_id = Session::get('union_id', '');
  93. $data = [
  94. 'uid' => $user->id,
  95. 'utype' => 2,
  96. 'type' => 3,
  97. 'openid' => $open_id,
  98. 'unionid' => $union_id,
  99. ];
  100. Thirdlogin::create($data);
  101. $prize_id = Session::get('prize_id',0);
  102. if (!empty($prize_id)) {
  103. $win = new LotteryWin();
  104. $win->member_id = $user->id;
  105. $win->prize_id = $prize_id;
  106. $win->created_at = date('Y-m-d H:i:s');
  107. $win->save();
  108. }
  109. Session::forget('open_id');
  110. Session::forget('union_id');
  111. Session::forget('prize_id');
  112. Session::save();
  113. }
  114. return $user;
  115. }
  116. public function loginByCompany($account, $password, $isAutoLogin = 0)
  117. {
  118. $user = $this->checkUser($account, $password, 1);
  119. if (!$user) {
  120. return false;
  121. }
  122. if(!$this->checkPwdLog($user)){
  123. return false;
  124. }
  125. $this->login($user, $isAutoLogin);
  126. return $user;
  127. }
  128. public function loginByOrganization($account, $password, $isAutoLogin = 0)
  129. {
  130. $user = $this->checkUser($account, $password, 3);
  131. if (!$user) {
  132. return false;
  133. }
  134. $this->login($user, $isAutoLogin);
  135. return $user;
  136. }
  137. /**
  138. * @return string
  139. */
  140. public function resetPasswordToken($data)
  141. {
  142. $token = str_random(32);
  143. Cache::put($token, $data, 24 * 60);
  144. return $token;
  145. }
  146. public function checkResetPasswordToken($token)
  147. {
  148. return Cache::get($token, false);
  149. }
  150. public function resetPassword($token, $password)
  151. {
  152. $data = Cache::pull($token);
  153. if ($data['utype'] == 1) {
  154. $user = $this->companyRepository->resetPassword($data['type'], $data[$data['type']], $password);
  155. } elseif ($data['utype'] == 2) {
  156. $user = $this->memberRepository->resetPassword($data['type'], $data[$data['type']], $password);
  157. }
  158. $this->memberLogRepository->createLog($user, 2045, []);
  159. return $data['utype'];
  160. }
  161. public function sendEmailHook($email, $token)
  162. {
  163. Cache::put('reset_password' . $email, $token, 24 * 60);
  164. }
  165. public function getTokenByEmail($email)
  166. {
  167. return Cache::pull('reset_password' . $email);
  168. }
  169. /**
  170. * 检查微信账号是否已绑定账号和登录网站
  171. * @param array $wechatUser
  172. * @param int $type 2微信开放平台,3微信公众号,4微信小程序
  173. * @return bool
  174. */
  175. public function wechatCheck(array $wechatUser, $type = 2)
  176. {
  177. $user = $this->thirdloginRepository->checkWechat($wechatUser['openid'], isset($wechatUser['unionid']) ? $wechatUser['unionid'] : "", $type);
  178. if (!$user) {
  179. return false;
  180. }
  181. return $user;
  182. }
  183. /**
  184. * 检查qq账号是否已绑定账号和登录网站
  185. * @param array $qqUser
  186. * @param int $type
  187. * @return bool
  188. */
  189. public function qqCheck(array $qqUser, $type = 1)
  190. {
  191. $user = $this->thirdloginRepository->checkQQ($qqUser['openid']);
  192. if (!$user) {
  193. return false;
  194. }
  195. return $user;
  196. }
  197. /**
  198. * @param array $wechatUser
  199. * @param Model|Authenticatable $user
  200. * @param bool $update_message 是否更新用户信息
  201. * @param int $type 2微信开放平台,3微信公众号,4微信小程序
  202. * @throws \Prettus\Validator\Exceptions\ValidatorException
  203. */
  204. public function wechatRegister(array $wechatUser, $user, $update_message = false, $type = 2)
  205. {
  206. $data['uid'] = $user->id;
  207. $data['utype'] = ($user instanceof Member) ? 2 : 1;
  208. $data['type'] = $type;
  209. $data['subsite_id'] = $user->subsite_id;
  210. $data['openid'] = $wechatUser['openid'];
  211. $data['unionid'] = isset($wechatUser['unionid']) ? $wechatUser['unionid'] : "";
  212. $this->thirdloginRepository->create($data);
  213. // if ($update_message) {//暂时不更新信息
  214. // if ($user instanceof Member) {
  215. // $image_path="person/images/".uniqid().'.jpg';
  216. // download($wechatUser['headimgurl'], $image_path);
  217. // $this->memberInfoRepository->updateInfo(['images'=>$image_path], $user->id);
  218. // } else {
  219. // $image_path="company/logo/".uniqid().'.jpg';
  220. // download($wechatUser['headimgurl'], $image_path);
  221. // $this->companyRepository->save(['logo'=>$image_path], $user->id);
  222. // }
  223. // }
  224. }
  225. /**
  226. * @param array $qqUser
  227. * @param Model|Authenticatable $user
  228. * @param bool $update_message 是否更新用户信息
  229. * @param int $type 1 QQ
  230. * @throws \Prettus\Validator\Exceptions\ValidatorException
  231. */
  232. public function qqRegister(array $qqUser, $user, $update_message = false, $type = 1)
  233. {
  234. $data['uid'] = $user->id;
  235. $data['utype'] = ($user instanceof Member) ? 2 : 1;
  236. $data['type'] = $type;
  237. $data['subsite_id'] = $user->subsite_id;
  238. $data['openid'] = $qqUser['openid'];
  239. $data['unionid'] = "";
  240. $this->thirdloginRepository->create($data);
  241. // if ($update_message) {//暂时不更新信息
  242. // if ($user instanceof Member) {
  243. // $image_path="person/images/".uniqid().'.jpg';
  244. // download($wechatUser['headimgurl'], $image_path);
  245. // $this->memberInfoRepository->updateInfo(['images'=>$image_path], $user->id);
  246. // } else {
  247. // $image_path="company/logo/".uniqid().'.jpg';
  248. // download($wechatUser['headimgurl'], $image_path);
  249. // $this->companyRepository->save(['logo'=>$image_path], $user->id);
  250. // }
  251. // }
  252. }
  253. /**
  254. * 检查用户是否存在
  255. * @param $username
  256. * @param $password
  257. * @param $utype 1企业,2用户
  258. * @return bool|\Illuminate\Database\Eloquent\Model|null
  259. */
  260. public function checkUser($username, $password, $utype)
  261. {
  262. if ($utype == 2) {
  263. $user = $this->memberRepository->getMemberByAccount($username);
  264. } elseif ($utype == 3) {
  265. $user = $this->organizationRepository->getOrganizationByAccount($username);
  266. } else {
  267. $user = $this->companyRepository->getCompanyByAccount($username);
  268. }
  269. if (!$user) {
  270. return false;
  271. }
  272. if ($password && !Hash::check($password, $user->password)) {
  273. // if (!empty($user->old_password)) {
  274. // //旧系统数据密码转移
  275. // $oldmembers = \App\Transfer\Member::select('pwd_hash')->where('uid', $user->id)->first();
  276. // if (md5(md5($password) . $oldmembers->pwd_hash . 'pNxOnSBtDzW7-7Pi') == $user->old_password) {
  277. // $user->old_password = "";
  278. // $user->password = Hash::make($password);
  279. // $user->save();
  280. // return $user;
  281. // }
  282. // }
  283. return false;
  284. }
  285. return $user;
  286. }
  287. public function checkPwdLog($user)
  288. {
  289. $reglog = $this->memberLogRepository->getMemberLog(
  290. $user->id,
  291. $user->utype,
  292. 1000
  293. );
  294. $regdata = $reglog->toArray()['data'];
  295. if(count($regdata) >= 1){
  296. $log = array_shift($regdata);
  297. $reg_time = strtotime($log['created_at']);
  298. }else{
  299. $reg_time = 0;
  300. }
  301. if((time()-$reg_time)<7776000){
  302. return true;
  303. }
  304. $pwdLog = $this->memberLogRepository->getMemberLog(
  305. $user->id,
  306. $user->utype,
  307. 2045
  308. );
  309. $data = $pwdLog->toArray()['data'];
  310. if(count($data) >= 1){
  311. $log = array_shift($data);
  312. $time = strtotime($log['created_at']);
  313. }else{
  314. $time = 0;
  315. }
  316. if($time > 0 && (time()-$time)>7776000){
  317. return false;
  318. }else{
  319. return true;
  320. }
  321. }
  322. public function login($user, $isAutoLogin = 0)
  323. {
  324. $isAutoLogin = $isAutoLogin ? true : false;
  325. if ($user instanceof Company) {
  326. Auth::guard('web-company')->login($user, $isAutoLogin);
  327. $this->companyRepository->updateLoginStatus($user);
  328. $this->memberLogRepository->createLog($user, 1001, []);
  329. } elseif ($user instanceof Organization) {
  330. Auth::guard('web-organization')->login($user, $isAutoLogin);
  331. $this->organizationRepository->updateLoginStatus($user);
  332. $this->memberLogRepository->createLog($user, 1001, []);
  333. } else {
  334. Auth::guard('web-member')->login($user, $isAutoLogin);
  335. $this->memberRepository->updateLoginStatus($user);
  336. $this->memberLogRepository->createLog($user, 1001, []);
  337. }
  338. }
  339. public function logout()
  340. {
  341. Auth::guard('web-company')->logout();
  342. Auth::guard('web-member')->logout();
  343. Auth::guard('web-organization')->logout();
  344. }
  345. private function getRandomName()
  346. {
  347. //str_replace(substr($data['mobile'], 3, 4), "****", $data['mobile']);
  348. return uniqid();
  349. }
  350. }