UserService.php 18 KB

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