UserService.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608
  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. * 2. 创建或更新技师基础信息
  194. * 3. 创建申请记录
  195. *
  196. * @param int $age 年龄
  197. * @param string $mobile 联系电话
  198. * @param int $gender 性别(1:男/2:女)
  199. * @param string $work_years 工作年限
  200. * @param string $intention_city 意向城市
  201. * @param array $portrait_images 形象照片数组
  202. * @param string|null $description 个人介绍
  203. * @return \App\Models\CoachInfoRecord 返回申请记录
  204. *
  205. * @throws \Exception 申请失败时抛出异常
  206. */
  207. public function applyCoach(
  208. int $age,
  209. string $mobile,
  210. int $gender,
  211. string $work_years,
  212. string $intention_city,
  213. array $portrait_images,
  214. ?string $description = null
  215. ): CoachInfoRecord {
  216. try {
  217. DB::beginTransaction();
  218. // 1. 获取并验证用户信息
  219. $user = $this->getAndValidateUser();
  220. // 2. 获取或创建技师基础信息
  221. $coach = $this->getOrCreateCoach($user, $mobile, $gender);
  222. // 3. 创建申请记录
  223. $application = $this->createCoachApplication(
  224. $coach,
  225. $age,
  226. $mobile,
  227. $gender,
  228. $work_years,
  229. $intention_city,
  230. $portrait_images,
  231. $description
  232. );
  233. DB::commit();
  234. // 记录成功日志
  235. $this->logApplicationSuccess($user, $coach, $application);
  236. return $application;
  237. } catch (\Exception $e) {
  238. DB::rollBack();
  239. $this->logApplicationError($e, $mobile);
  240. throw $e;
  241. }
  242. }
  243. /**
  244. * 获取并验证用户信息
  245. *
  246. * 业务逻辑:
  247. * 1. 获取当前登录用户
  248. * 2. 验证用户是否存在
  249. * 3. 返回用户模型
  250. *
  251. * @return \App\Models\MemberUser 返回用户模型
  252. *
  253. * @throws \Illuminate\Http\Exceptions\HttpResponseException 用户未登录时抛出异常
  254. */
  255. private function getAndValidateUser(): MemberUser
  256. {
  257. /** @var MemberUser $user */
  258. $user = Auth::user();
  259. // 确保用户存在
  260. abort_if(! $user, 401, '用户未登录');
  261. return $user;
  262. }
  263. /**
  264. * 获取或创建技师基础信息
  265. *
  266. * 业务逻辑:
  267. * 1. 获取用户关联的技师信息
  268. * 2. 如果存在技师信息:
  269. * - 验证现有申请状态
  270. * - 更新基础信息
  271. * 3. 如果不存在技师信息:
  272. * - 创建新的技师记录
  273. *
  274. * @param \App\Models\MemberUser $user 用户模型
  275. * @param string $mobile 手机号
  276. * @param int $gender 性别(1:男/2:女)
  277. * @return \App\Models\Coach 返回技师模型
  278. *
  279. * @throws \Illuminate\Http\Exceptions\HttpResponseException 验证失败时抛出异常
  280. */
  281. private function getOrCreateCoach(MemberUser $user, string $mobile, int $gender)
  282. {
  283. $coach = $user->coach;
  284. if ($coach) {
  285. // 检查现有申请状态
  286. $this->validateExistingApplication($coach);
  287. // 更新基础信息
  288. $coach->update([
  289. 'mobile' => $mobile,
  290. 'gender' => $gender,
  291. ]);
  292. return $coach->fresh();
  293. }
  294. // 创建新的技师记录
  295. return $user->coach()->create([
  296. 'mobile' => $mobile,
  297. 'gender' => $gender,
  298. ]);
  299. }
  300. /**
  301. * 验证现有申请状态
  302. *
  303. * 业务逻辑:
  304. * 1. 查询技师的申请记录
  305. * 2. 检查是否存在审核中或已通过的申请
  306. * 3. 根据状态返回相应的错误信息
  307. *
  308. * @param \App\Models\Coach $coach 技师模型
  309. *
  310. * @throws \Illuminate\Http\Exceptions\HttpResponseException 存在未完成申请时抛出异常
  311. */
  312. private function validateExistingApplication($coach): void
  313. {
  314. $existingApplication = CoachInfoRecord::where('coach_id', $coach->id)
  315. ->whereIn('state', [TechnicianAuthStatus::AUDITING, TechnicianAuthStatus::PASSED])
  316. ->first();
  317. if ($existingApplication) {
  318. $message = $existingApplication->state === TechnicianAuthStatus::PASSED
  319. ? '您已是技师,无需重复申请'
  320. : '您有正在审核的申请,请耐心等待';
  321. abort(422, $message);
  322. }
  323. }
  324. /**
  325. * 创建技师申请记录
  326. *
  327. * 业务逻辑:
  328. * 1. 准备申请记录数据
  329. * 2. 处理形象照片数据
  330. * 3. 创建申请记录
  331. *
  332. * @param \App\Models\Coach $coach 技师模型
  333. * @param int $age 年龄
  334. * @param string $mobile 联系电话
  335. * @param int $gender 性别(1:男/2:女)
  336. * @param string $work_years 工作年限
  337. * @param string $intention_city 意向城市
  338. * @param array $portrait_images 形象照片数组
  339. * @param string|null $description 个人介绍
  340. * @return \App\Models\CoachInfoRecord 返回申请记录
  341. */
  342. private function createCoachApplication(
  343. $coach,
  344. int $age,
  345. string $mobile,
  346. int $gender,
  347. string $work_years,
  348. string $intention_city,
  349. array $portrait_images,
  350. ?string $description
  351. ): CoachInfoRecord {
  352. return CoachInfoRecord::create([
  353. 'coach_id' => $coach->id,
  354. 'age' => $age,
  355. 'mobile' => $mobile,
  356. 'gender' => $gender,
  357. 'work_years' => $work_years,
  358. 'intention_city' => $intention_city,
  359. 'portrait_images' => json_encode($portrait_images, JSON_UNESCAPED_UNICODE),
  360. 'description' => $description,
  361. 'state' => TechnicianAuthStatus::AUDITING,
  362. ]);
  363. }
  364. /**
  365. * 记录申请成功日志
  366. *
  367. * 业务逻辑:
  368. * 1. 记录用户ID和技师ID
  369. * 2. 记录申请记录ID和状态
  370. * 3. 记录联系方式
  371. *
  372. * @param \App\Models\MemberUser $user 用户模型
  373. * @param \App\Models\Coach $coach 技师模型
  374. * @param \App\Models\CoachInfoRecord $application 申请记录
  375. */
  376. private function logApplicationSuccess(MemberUser $user, $coach, CoachInfoRecord $application): void
  377. {
  378. Log::info('技师申请提交成功', [
  379. 'user_id' => $user->id,
  380. 'coach_id' => $coach->id,
  381. 'application_id' => $application->id,
  382. 'mobile' => $application->mobile,
  383. 'state' => $application->state,
  384. ]);
  385. }
  386. /**
  387. * 记录申请错误日志
  388. *
  389. * 业务逻辑:
  390. * 1. 记录错误信息和堆栈跟踪
  391. * 2. 记录用户ID和联系方式
  392. * 3. 记录错误发生的文件和行号
  393. *
  394. * @param \Exception $e 异常对象
  395. * @param string $mobile 联系电话
  396. */
  397. private function logApplicationError(\Exception $e, string $mobile): void
  398. {
  399. Log::error('申请成为技师失败', [
  400. 'error' => $e->getMessage(),
  401. 'user_id' => Auth::id(),
  402. 'mobile' => $mobile,
  403. 'trace' => $e->getTraceAsString(),
  404. 'file' => $e->getFile(),
  405. 'line' => $e->getLine(),
  406. ]);
  407. }
  408. /**
  409. * 生成用户邀请码
  410. *
  411. * 业务逻辑:
  412. * 1. 获取当前用户信息
  413. * 2. 根据用户类型生成邀请码
  414. * 3. 生成包含邀请参数的链接
  415. * 4. 生成邀请二维码
  416. * 5. 记录邀请码生成日志
  417. *
  418. * @param string $type 邀请码类型(user/coach)
  419. * @return array 返回邀请码和二维码信息
  420. *
  421. * @throws \Exception 生成邀请码失败时抛出异常
  422. */
  423. public function generateInviteCode(string $type = 'user'): array
  424. {
  425. try {
  426. /** @var MemberUser $user */
  427. // 1. 获取当前用户
  428. $user = Auth::user();
  429. // 2. 根据类型获取邀请人ID和角色
  430. $inviteInfo = $this->getInviteInfo($user, $type);
  431. if (! $inviteInfo) {
  432. throw new \Exception('无法生成邀请码,用户类型不匹配');
  433. }
  434. // 3. 生成邀请码
  435. $inviteCode = $this->generateInviteCodeByType(
  436. $type,
  437. $inviteInfo['id']
  438. );
  439. // 4. 生成邀请链接和二维码
  440. $inviteUrl = $this->generateInviteUrl($inviteCode);
  441. $qrCode = $this->generateQrCode($inviteUrl);
  442. // 5. 记录日志
  443. Log::info('生成邀请码', [
  444. 'user_id' => $user->id,
  445. 'type' => $type,
  446. 'invite_id' => $inviteInfo['id'],
  447. 'invite_code' => $inviteCode,
  448. 'invite_url' => $inviteUrl,
  449. ]);
  450. return [
  451. 'invite_code' => $inviteCode,
  452. 'invite_url' => $inviteUrl,
  453. 'qr_code' => $qrCode,
  454. ];
  455. } catch (\Exception $e) {
  456. Log::error('生成邀请码失败', [
  457. 'error' => $e->getMessage(),
  458. 'user_id' => Auth::id(),
  459. 'type' => $type,
  460. ]);
  461. throw $e;
  462. }
  463. }
  464. /**
  465. * 获取邀请人信息
  466. *
  467. * 业务逻辑:
  468. * 1. 根据类型判断邀请人身份
  469. * 2. 用户类型:直接返回用���信息
  470. * 3. 技师类型:
  471. * - 验证技师状态
  472. * - 返回技师信息
  473. *
  474. * @param \App\Models\MemberUser $user 当前用户
  475. * @param string $type 邀请类型(user/coach)
  476. * @return array|null 返回邀请人信息,无效类型返回null
  477. */
  478. private function getInviteInfo(MemberUser $user, string $type): ?array
  479. {
  480. switch ($type) {
  481. case 'user':
  482. return [
  483. 'id' => $user->id,
  484. 'role' => 'user',
  485. ];
  486. case 'coach':
  487. $coach = $user->coach;
  488. if ($coach && $coach->state === TechnicianAuthStatus::PASSED) {
  489. return [
  490. 'id' => $coach->id,
  491. 'role' => 'coach',
  492. ];
  493. }
  494. return null;
  495. default:
  496. return null;
  497. }
  498. }
  499. /**
  500. * 根据类型生成邀请码
  501. *
  502. * 业务逻辑:
  503. * 1. 组合类型和ID
  504. * 2. 生成格式化的邀请码
  505. *
  506. * @param string $type 邀请类型(user/coach)
  507. * @param int $id 邀请人ID
  508. * @return string 返回格式为 "type_id" 的邀请码
  509. */
  510. private function generateInviteCodeByType(string $type, int $id): string
  511. {
  512. return sprintf('%s_%d', $type, $id);
  513. }
  514. /**
  515. * 生成邀请链接
  516. *
  517. * 业务逻辑:
  518. * 1. 获取应用URL
  519. * 2. 添加邀请码参数
  520. * 3. 生成完整的邀请链接
  521. *
  522. * @param string $inviteCode 邀请码
  523. * @return string 返回完整的邀请链接
  524. */
  525. private function generateInviteUrl(string $inviteCode): string
  526. {
  527. // return config('app.url').'/invite?'.http_build_query(['invite_code' => $inviteCode]);
  528. return $inviteCode;
  529. }
  530. /**
  531. * 生成二维码
  532. *
  533. * 业务逻辑:
  534. * 1. 使用 QrCode 库生成 SVG 格式二维码
  535. * 2. 设置二维码大小和边距
  536. * 3. 转换为 base64 编码
  537. *
  538. * @param string $content 二维码内容
  539. * @return string 返回 base64 编码的二维码图片
  540. */
  541. private function generateQrCode(string $content): string
  542. {
  543. $qrImage = QrCode::format('svg')
  544. ->size(200)
  545. ->margin(2)
  546. ->encoding('UTF-8')
  547. ->generate($content);
  548. return 'data:image/svg+xml;base64,'.base64_encode($qrImage);
  549. }
  550. }