UserService.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609
  1. <?php
  2. namespace App\Services\Client;
  3. use App\Enums\TechnicianAuthStatus;
  4. use App\Models\CoachInfoRecord;
  5. use App\Models\MemberUser;
  6. use Illuminate\Support\Facades\Auth;
  7. use Illuminate\Support\Facades\DB;
  8. use Illuminate\Support\Facades\Log;
  9. use Illuminate\Support\Facades\Redis;
  10. use SimpleSoftwareIO\QrCode\Facades\QrCode;
  11. /**
  12. * 用户服务类
  13. *
  14. * 处理用户相关的业务逻辑,包括:
  15. * - 用户信息的获取和更新
  16. * - 用户注册
  17. * - 用户反馈
  18. * - 技师申请
  19. * - 邀请码生成
  20. */
  21. class UserService
  22. {
  23. protected $marketDistTeamService;
  24. public function __construct(MarketDistTeamService $marketDistTeamService)
  25. {
  26. $this->marketDistTeamService = $marketDistTeamService;
  27. }
  28. /**
  29. * 获取当前用户信息
  30. *
  31. * 业务逻辑:
  32. * 1. 通过 Auth 门面获取当前登录用户信息
  33. * 2. 返回用户基本信息
  34. *
  35. * @return \Illuminate\Http\JsonResponse 返回用户信息
  36. *
  37. * @throws \Exception 获取用户信息失败时抛出异常
  38. */
  39. public function getUserInfo(): MemberUser
  40. {
  41. try {
  42. /** @var MemberUser $user */
  43. // 通过 Auth 门面获取当前登录用户信息
  44. $user = Auth::user();
  45. return $user;
  46. } catch (\Exception $e) {
  47. // 记录错误日志
  48. Log::error('获取用户信息失败', ['error' => $e->getMessage()]);
  49. throw $e;
  50. }
  51. }
  52. /**
  53. * 用户注册
  54. *
  55. * 业务逻辑:
  56. * 1. 验证手机号是否已被注册
  57. * 2. 验证短信验证码
  58. * 3. 创建新用户记录
  59. * 4. 处理邀请关系(如果有)
  60. *
  61. * @param string $mobile 手机号
  62. * @param string $code 验证码
  63. * @param string|null $invite_code 邀请码(选填)
  64. * @param int|null $invite_id 邀请人ID(选填)
  65. * @param string|null $invite_role 邀请人角色(选填)
  66. * @return \Illuminate\Http\JsonResponse 返回注册结果
  67. *
  68. * @throws \Exception 注册过程中出现错误时抛出异常
  69. */
  70. public function register(string $mobile, string $code, ?string $invite_code = null, ?int $invite_id = null, ?string $invite_role = null): array
  71. {
  72. try {
  73. DB::beginTransaction();
  74. // 检查手机号是否已注册
  75. abort_if(MemberUser::where('mobile', $mobile)->exists(), 422, '该手机号已注册');
  76. // 验证短信验证码
  77. abort_if(! $this->verifySmsCode($mobile, $code), 422, '验证码错误或已过期');
  78. // 创建用户
  79. $user = MemberUser::create([
  80. 'mobile' => $mobile,
  81. 'password' => bcrypt(substr($mobile, -6)), // 默认密码为手机号后6位
  82. 'nickname' => substr_replace($mobile, '****', 3, 4), // 默认昵称为手机号(中间4位隐藏)
  83. ]);
  84. // 处理邀请关系
  85. if ($invite_code && $invite_role && $invite_id) {
  86. $this->marketDistTeamService->createInviteRelation($user, $invite_code, $invite_id, $invite_role);
  87. }
  88. DB::commit();
  89. return [
  90. 'user_id' => $user->id,
  91. 'mobile' => $mobile,
  92. 'invite_code' => $user->invite_code,
  93. ];
  94. } catch (\Exception $e) {
  95. DB::rollBack();
  96. Log::error('用户注册失败', ['error' => $e->getMessage(), 'mobile' => $mobile]);
  97. throw $e;
  98. }
  99. }
  100. /**
  101. * 验证短信验证码
  102. *
  103. * 业务逻辑:
  104. * 1. 从 Redis 获取存储的验证码
  105. * 2. 比对验证码是否匹配
  106. * 3. 验证成功后删除缓存的验证码
  107. *
  108. * @param string $mobile 手机号
  109. * @param string $code 待验证的验证码
  110. * @return bool 返回验证结果
  111. */
  112. private function verifySmsCode(string $mobile, string $code): bool
  113. {
  114. try {
  115. $cacheKey = "sms_code:{$mobile}";
  116. $cacheCode = Redis::get($cacheKey);
  117. if (! $cacheCode || $cacheCode !== $code) {
  118. return false;
  119. }
  120. Redis::del($cacheKey); // 验证成功后删除验证码
  121. return true;
  122. } catch (\Exception $e) {
  123. Log::error('验证码验证失败', ['error' => $e->getMessage(), 'mobile' => $mobile]);
  124. return false;
  125. }
  126. }
  127. /**
  128. * 更新当前用户信息
  129. *
  130. * 业务逻辑:
  131. * 1. 获取当前登录用户
  132. * 2. 更新用户基本信息
  133. *
  134. * @param array $data 待更新的用户数据
  135. * @return \Illuminate\Http\JsonResponse 返回更新结果
  136. *
  137. * @throws \Exception 更新失败时抛出异常
  138. */
  139. public function updateUserInfo(array $data): MemberUser
  140. {
  141. try {
  142. DB::beginTransaction();
  143. // 更新用户信息
  144. $user = Auth::user();
  145. $user->update($data);
  146. DB::commit();
  147. return $user->fresh();
  148. } catch (\Exception $e) {
  149. DB::rollBack();
  150. Log::error('更新用户信息失败', ['error' => $e->getMessage(), 'data' => $data]);
  151. throw $e;
  152. }
  153. }
  154. /**
  155. * 提交用户反馈
  156. *
  157. * 业务逻辑:
  158. * 1. 创建用户反馈记录
  159. * 2. 保存反馈内容和图片
  160. * 3. 记录用户联系方式(如果提供)
  161. *
  162. * @param string $content 反馈内容
  163. * @param array $images 反馈图片数组
  164. * @param string|null $contact 联系方式
  165. * @return \Illuminate\Http\JsonResponse 返回提交结果
  166. *
  167. * @throws \Exception 提交反馈失败时抛出异常
  168. */
  169. public function feedback(string $content, array $images = [], ?string $contact = null): void //Feedback
  170. {
  171. try {
  172. DB::beginTransaction();
  173. // 创建反馈记录
  174. // $feedback = Feedback::create([
  175. // 'user_id' => Auth::user()->id,
  176. // 'content' => $content,
  177. // 'images' => $images,
  178. // 'contact' => $contact,
  179. // ]);
  180. DB::commit();
  181. // return $feedback;
  182. } catch (\Exception $e) {
  183. DB::rollBack();
  184. Log::error('提交反馈失败', ['error' => $e->getMessage(), 'content' => $content]);
  185. throw $e;
  186. }
  187. }
  188. /**
  189. * 申请成为技师
  190. *
  191. * 业务逻辑:
  192. * 1. 检查用户申请资格
  193. * - 验证用户是否已有技师身份
  194. * - 检查是否存在未完成的申请
  195. * 2. 创建或更新技师基础信息
  196. * - 首次申请:创建技师记录
  197. * - 重新申请:更新技师信息
  198. * 3. 创建申请记录
  199. * - 记录申请信息
  200. * - 保存形象照片
  201. * - 设置申请状态
  202. *
  203. * @param string $mobile 联系电话
  204. * @param int $gender 性别(1:男/2:女)
  205. * @param string $work_years 工作年限
  206. * @param string $intention_city 意向城市
  207. * @param array $portrait_images 形象照片数组
  208. * @param string|null $description 个人介绍
  209. * @return \App\Models\CoachInfoRecord 返回申请记录
  210. *
  211. * @throws \Exception 申请失败时抛出异常
  212. */
  213. public function applyCoach(
  214. string $mobile,
  215. int $gender,
  216. string $work_years,
  217. string $intention_city,
  218. array $portrait_images,
  219. ?string $description = null
  220. ): CoachInfoRecord {
  221. try {
  222. DB::beginTransaction();
  223. // 1. 获取并验证用户信息
  224. $user = $this->getAndValidateUser();
  225. // 2. 获取或创建技师基础信息
  226. $coach = $this->getOrCreateCoach($user, $mobile, $gender);
  227. // 3. 创建申请记录
  228. $application = $this->createCoachApplication(
  229. $coach,
  230. $mobile,
  231. $gender,
  232. $work_years,
  233. $intention_city,
  234. $portrait_images,
  235. $description
  236. );
  237. DB::commit();
  238. // 记录成功日志
  239. $this->logApplicationSuccess($user, $coach, $application);
  240. return $application;
  241. } catch (\Exception $e) {
  242. DB::rollBack();
  243. $this->logApplicationError($e, $mobile);
  244. throw $e;
  245. }
  246. }
  247. /**
  248. * 获取并验证用户信息
  249. *
  250. * 业务逻辑:
  251. * 1. 获取当前登录用户
  252. * 2. 验证用户是否存在
  253. * 3. 返回用户模型
  254. *
  255. * @return \App\Models\MemberUser 返回用户模型
  256. *
  257. * @throws \Illuminate\Http\Exceptions\HttpResponseException 用户未登录时抛出异常
  258. */
  259. private function getAndValidateUser(): MemberUser
  260. {
  261. /** @var MemberUser $user */
  262. $user = Auth::user();
  263. // 确保用户存在
  264. abort_if(! $user, 401, '用户未登录');
  265. return $user;
  266. }
  267. /**
  268. * 获取或创建技师基础信息
  269. *
  270. * 业务逻辑:
  271. * 1. 获取用户关联的技师信息
  272. * 2. 如果存在技师信息:
  273. * - 验证现有申请状态
  274. * - 更新基础信息
  275. * 3. 如果不存在技师信息:
  276. * - 创建新的技师记录
  277. *
  278. * @param \App\Models\MemberUser $user 用户模型
  279. * @param string $mobile 手机号
  280. * @param int $gender 性别(1:男/2:女)
  281. * @return \App\Models\Coach 返回技师模型
  282. *
  283. * @throws \Illuminate\Http\Exceptions\HttpResponseException 验证失败时抛出异常
  284. */
  285. private function getOrCreateCoach(MemberUser $user, string $mobile, int $gender)
  286. {
  287. $coach = $user->coach;
  288. if ($coach) {
  289. // 检查现有申请状态
  290. $this->validateExistingApplication($coach);
  291. // 更新基础信息
  292. $coach->update([
  293. 'mobile' => $mobile,
  294. 'gender' => $gender,
  295. ]);
  296. return $coach->fresh();
  297. }
  298. // 创建新的技师记录
  299. return $user->coach()->create([
  300. 'mobile' => $mobile,
  301. 'gender' => $gender,
  302. ]);
  303. }
  304. /**
  305. * 验证现有申请状态
  306. *
  307. * 业务逻辑:
  308. * 1. 查询技师的申请记录
  309. * 2. 检查是否存在审核中或已通过的申请
  310. * 3. 根据状态返回相应的错误信息
  311. *
  312. * @param \App\Models\Coach $coach 技师模型
  313. *
  314. * @throws \Illuminate\Http\Exceptions\HttpResponseException 存在未完成申请时抛出异常
  315. */
  316. private function validateExistingApplication($coach): void
  317. {
  318. $existingApplication = CoachInfoRecord::where('coach_id', $coach->id)
  319. ->whereIn('state', [TechnicianAuthStatus::AUDITING, TechnicianAuthStatus::PASSED])
  320. ->first();
  321. if ($existingApplication) {
  322. $message = $existingApplication->state === TechnicianAuthStatus::PASSED
  323. ? '您已是技师,无需重复申请'
  324. : '您有正在审核的申请,请耐心等待';
  325. abort(422, $message);
  326. }
  327. }
  328. /**
  329. * 创建技师申请记录
  330. *
  331. * 业务逻辑:
  332. * 1. 准备申请记录数据
  333. * 2. 处理形象照片数据
  334. * 3. 创建申请记录
  335. *
  336. * @param \App\Models\Coach $coach 技师模型
  337. * @param string $mobile 联系电话
  338. * @param int $gender 性别(1:男/2:女)
  339. * @param string $work_years 工作年限
  340. * @param string $intention_city 意向城市
  341. * @param array $portrait_images 形象照片数组
  342. * @param string|null $description 个人介绍
  343. * @return \App\Models\CoachInfoRecord 返回申请记录
  344. */
  345. private function createCoachApplication(
  346. $coach,
  347. string $mobile,
  348. int $gender,
  349. string $work_years,
  350. string $intention_city,
  351. array $portrait_images,
  352. ?string $description
  353. ): CoachInfoRecord {
  354. return CoachInfoRecord::create([
  355. 'coach_id' => $coach->id,
  356. 'mobile' => $mobile,
  357. 'gender' => $gender,
  358. 'work_years' => $work_years,
  359. 'intention_city' => $intention_city,
  360. 'portrait_images' => json_encode($portrait_images, JSON_UNESCAPED_UNICODE),
  361. 'description' => $description,
  362. 'state' => TechnicianAuthStatus::AUDITING,
  363. ]);
  364. }
  365. /**
  366. * 记录申请成功日志
  367. *
  368. * 业务逻辑:
  369. * 1. 记录用户ID和技师ID
  370. * 2. 记录申请记录ID和状态
  371. * 3. 记录联系方式
  372. *
  373. * @param \App\Models\MemberUser $user 用户模型
  374. * @param \App\Models\Coach $coach 技师模型
  375. * @param \App\Models\CoachInfoRecord $application 申请记录
  376. */
  377. private function logApplicationSuccess(MemberUser $user, $coach, CoachInfoRecord $application): void
  378. {
  379. Log::info('技师申请提交成功', [
  380. 'user_id' => $user->id,
  381. 'coach_id' => $coach->id,
  382. 'application_id' => $application->id,
  383. 'mobile' => $application->mobile,
  384. 'state' => $application->state,
  385. ]);
  386. }
  387. /**
  388. * 记录申请错误日志
  389. *
  390. * 业务逻辑:
  391. * 1. 记录错误信息和堆栈跟踪
  392. * 2. 记录用户ID和联系方式
  393. * 3. 记录错误发生的文件和行号
  394. *
  395. * @param \Exception $e 异常对象
  396. * @param string $mobile 联系电话
  397. */
  398. private function logApplicationError(\Exception $e, string $mobile): void
  399. {
  400. Log::error('申请成为技师失败', [
  401. 'error' => $e->getMessage(),
  402. 'user_id' => Auth::id(),
  403. 'mobile' => $mobile,
  404. 'trace' => $e->getTraceAsString(),
  405. 'file' => $e->getFile(),
  406. 'line' => $e->getLine(),
  407. ]);
  408. }
  409. /**
  410. * 生成用户邀请码
  411. *
  412. * 业务逻辑:
  413. * 1. 获取当前用户信息
  414. * 2. 根据用户类型生成邀请码
  415. * 3. 生成包含邀请参数的链接
  416. * 4. 生成邀请二维码
  417. * 5. 记录邀请码生成日志
  418. *
  419. * @param string $type 邀请码类型(user/coach)
  420. * @return array 返回邀请码和二维码信息
  421. *
  422. * @throws \Exception 生成邀请码失败时抛出异常
  423. */
  424. public function generateInviteCode(string $type = 'user'): array
  425. {
  426. try {
  427. /** @var MemberUser $user */
  428. // 1. 获取当前用户
  429. $user = Auth::user();
  430. // 2. 根据类型获取邀请人ID和角色
  431. $inviteInfo = $this->getInviteInfo($user, $type);
  432. if (! $inviteInfo) {
  433. throw new \Exception('无法生成邀请码,用户类型不匹配');
  434. }
  435. // 3. 生成邀请码
  436. $inviteCode = $this->generateInviteCodeByType(
  437. $type,
  438. $inviteInfo['id']
  439. );
  440. // 4. 生成邀请链接和二维码
  441. $inviteUrl = $this->generateInviteUrl($inviteCode);
  442. $qrCode = $this->generateQrCode($inviteUrl);
  443. // 5. 记录日志
  444. Log::info('生成邀请码', [
  445. 'user_id' => $user->id,
  446. 'type' => $type,
  447. 'invite_id' => $inviteInfo['id'],
  448. 'invite_code' => $inviteCode,
  449. 'invite_url' => $inviteUrl,
  450. ]);
  451. return [
  452. 'invite_code' => $inviteCode,
  453. 'invite_url' => $inviteUrl,
  454. 'qr_code' => $qrCode,
  455. ];
  456. } catch (\Exception $e) {
  457. Log::error('生成邀请码失败', [
  458. 'error' => $e->getMessage(),
  459. 'user_id' => Auth::id(),
  460. 'type' => $type,
  461. ]);
  462. throw $e;
  463. }
  464. }
  465. /**
  466. * 获取邀请人信息
  467. *
  468. * 业务逻辑:
  469. * 1. 根据类型判断邀请人身份
  470. * 2. 用户类型:直接返回用户信息
  471. * 3. 技师类型:
  472. * - 验证技师状态
  473. * - 返回技师信息
  474. *
  475. * @param \App\Models\MemberUser $user 当前用户
  476. * @param string $type 邀请类型(user/coach)
  477. * @return array|null 返回邀请人信息,无效类型返回null
  478. */
  479. private function getInviteInfo(MemberUser $user, string $type): ?array
  480. {
  481. switch ($type) {
  482. case 'user':
  483. return [
  484. 'id' => $user->id,
  485. 'role' => 'user',
  486. ];
  487. case 'coach':
  488. $coach = $user->coach;
  489. if ($coach && $coach->state === TechnicianAuthStatus::PASSED) {
  490. return [
  491. 'id' => $coach->id,
  492. 'role' => 'coach',
  493. ];
  494. }
  495. return null;
  496. default:
  497. return null;
  498. }
  499. }
  500. /**
  501. * 根据类型生成邀请码
  502. *
  503. * 业务逻辑:
  504. * 1. 组合类型和ID
  505. * 2. 生成格式化的邀请码
  506. *
  507. * @param string $type 邀请类型(user/coach)
  508. * @param int $id 邀请人ID
  509. * @return string 返回格式为 "type_id" 的邀请码
  510. */
  511. private function generateInviteCodeByType(string $type, int $id): string
  512. {
  513. return sprintf('%s_%d', $type, $id);
  514. }
  515. /**
  516. * 生成邀请链接
  517. *
  518. * 业务逻辑:
  519. * 1. 获取应用URL
  520. * 2. 添加邀请码参数
  521. * 3. 生成完整的邀请链接
  522. *
  523. * @param string $inviteCode 邀请码
  524. * @return string 返回完整的邀请链接
  525. */
  526. private function generateInviteUrl(string $inviteCode): string
  527. {
  528. // return config('app.url').'/invite?'.http_build_query(['invite_code' => $inviteCode]);
  529. return $inviteCode;
  530. }
  531. /**
  532. * 生成二维码
  533. *
  534. * 业务逻辑:
  535. * 1. 使用 QrCode 库生成 SVG 格式二维码
  536. * 2. 设置二维码大小和边距
  537. * 3. 转换为 base64 编码
  538. *
  539. * @param string $content 二维码内容
  540. * @return string 返回 base64 编码的二维码图片
  541. */
  542. private function generateQrCode(string $content): string
  543. {
  544. $qrImage = QrCode::format('svg')
  545. ->size(200)
  546. ->margin(2)
  547. ->encoding('UTF-8')
  548. ->generate($content);
  549. return 'data:image/svg+xml;base64,'.base64_encode($qrImage);
  550. }
  551. }