OwnerService.php 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. <?php
  2. namespace app\admin\service\member;
  3. use app\model\Member;
  4. use app\model\MemberCert;
  5. use app\model\MemberInfo;
  6. use app\model\SysSerial;
  7. use support\Db;
  8. use support\Request;
  9. class OwnerService
  10. {
  11. public static function list(Request $request)
  12. {
  13. $page = $request->get('page', 1);
  14. $pageSize = $request->get('pageSize', 10);
  15. $id = $request->get('id', '');
  16. $mobile = $request->get('mobile', '');
  17. $rows = Member::where('member_is_owner', 'Y')
  18. ->when($id != '', function ($query) use ($id) {
  19. $query->where('member_id', 'like', '%' . $id . '%');
  20. })->when($mobile != '', function ($query) use ($mobile) {
  21. $query->where('member_mobile', 'like', '%' . $mobile . '%');
  22. });
  23. // 总条数
  24. $total = $rows->count('member_id');
  25. $rows = $rows->with([
  26. 'info' => function ($query) {
  27. $query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
  28. },
  29. 'cert' => function ($query) {
  30. $query->select('join_cert_member_id', 'member_cert_birth', 'member_cert_gender', 'member_cert_name', 'member_cert_nbr',
  31. 'member_cert_province', 'member_cert_city', 'member_cert_addr', 'member_cert_face', 'member_cert_photo');
  32. }
  33. ])->select('member_id', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes')
  34. ->orderBy('member_addtimes', 'DESC')
  35. ->forPage($page, $pageSize)
  36. ->get()
  37. ->toArray();
  38. foreach ($rows as &$row) {
  39. if (!empty($row['info']['member_info_headimg'])) {
  40. $row['info']['member_info_headimg'] = getenv('STORAGE_DOMAIN') . $row['info']['member_info_headimg'];
  41. }
  42. if (!empty($row['cert']['member_cert_face'])) {
  43. $row['cert']['member_cert_face'] = getenv('STORAGE_DOMAIN') . $row['cert']['member_cert_face'];
  44. $row['cert']['member_cert_photo'] = getenv('STORAGE_DOMAIN') . $row['cert']['member_cert_photo'];
  45. }
  46. }
  47. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  48. }
  49. /**
  50. * @Desc 添加会员
  51. * @Author Gorden
  52. * @Date 2024/3/25 13:40
  53. *
  54. * @param $params
  55. * @return \support\Response
  56. */
  57. public static function add($params)
  58. {
  59. Db::beginTransaction();
  60. try {
  61. $memberId = self::generateMemberId();
  62. // 先写主表,要ID
  63. $memberData = [
  64. 'member_id' => $memberId,
  65. 'member_is_owner' => $params['is_owner'],
  66. 'member_classify' => $params['classify'],
  67. 'member_status' => $params['status'],
  68. 'member_mobile' => $params['mobile'],
  69. 'member_from' => $params['source'],
  70. 'member_addtimes' => time(),
  71. ];
  72. Member::insert($memberData);
  73. // member cert
  74. $certData = [
  75. 'join_cert_member_id' => $memberId,
  76. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  77. 'member_cert_name' => $params['cert_name'] ?? '',
  78. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  79. 'member_cert_birth' => $params['birth'] ?? '',
  80. 'member_cert_gender' => $params['gender'] ?? '',
  81. 'member_cert_province' => $params['province'] ?? '',
  82. 'member_cert_city' => $params['city'] ?? '',
  83. 'member_cert_addr' => $params['addr'] ?? '',
  84. 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  85. 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  86. ];
  87. MemberCert::insert($certData);
  88. // member info
  89. $infoData = [
  90. 'join_info_member_id' => $memberId,
  91. 'member_info_nickname' => $params['account_name'],
  92. 'member_info_headimg' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar'])
  93. ];
  94. MemberInfo::insert($infoData);
  95. Db::commit();
  96. } catch (\Exception $e) {
  97. Db::rollBack();
  98. dump($e->getMessage() . ';line:' . $e->getLine());
  99. return json_fail("数据添加失败");
  100. }
  101. return json_success('数据添加成功');
  102. }
  103. private static function generateMemberId()
  104. {
  105. $id = SysSerial::getSerial();
  106. return "ME" . str_pad($id, 16, "0", STR_PAD_LEFT) . random_string(8);
  107. }
  108. }