MemberService.php 62 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276
  1. <?php
  2. namespace app\admin\service\member;
  3. use app\model\ClientPoints;
  4. use app\model\CouponDetail;
  5. use app\model\Device;
  6. use app\model\Family;
  7. use app\model\FamilyMember;
  8. use app\model\Goods;
  9. use app\model\Member;
  10. use app\model\MemberAccount;
  11. use app\model\MemberCert;
  12. use app\model\MemberDevice;
  13. use app\model\MemberInfo;
  14. use app\model\Order;
  15. use app\model\OrderSheet;
  16. use app\model\PayDetail;
  17. use app\model\SysCategory;
  18. use app\model\SysDept;
  19. use app\model\SysSerial;
  20. use app\model\SysUser;
  21. use support\Db;
  22. use support\exception\BusinessException;
  23. use support\Request;
  24. class MemberService
  25. {
  26. public static function list(Request $request)
  27. {
  28. $page = $request->get('page', 1);
  29. $pageSize = $request->get('pageSize', 10);
  30. $name = $request->get('name', '');
  31. $mobile = $request->get('mobile', '');
  32. $level = $request->get('level', '');
  33. $isAuth = $request->get('is_auth', '');
  34. $addtime = $request->get('member_addtimes', []);
  35. $type = $request->get('type', '');
  36. $rows = Member::with([
  37. 'account' => function ($query) {
  38. $query->where('member_account_status', 'ACTIVED');
  39. }
  40. ])
  41. ->where('member_is_owner', 'N')
  42. ->where('member_mobile', '<>', '0000')
  43. ->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
  44. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
  45. // ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
  46. ->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
  47. // ->where('member_account.member_account_classify', 'CASH')
  48. ->when($name != '', function ($query) use ($name) {
  49. $query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
  50. })->when($mobile != '', function ($query) use ($mobile) {
  51. $query->where('member.member_mobile', 'like', '%' . $mobile . '%');
  52. })->when($level != '', function ($query) use ($level) {
  53. if ($level == 'other') {
  54. $query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
  55. } else if ($level == 'VIP') {
  56. $query->where('member.member_is_vip', 'Y');
  57. } else {
  58. $query->where('member_role.member_role_id', $level);
  59. }
  60. })->when($isAuth != '', function ($query) use ($isAuth) {
  61. if ($isAuth == 'Y') {
  62. $query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
  63. } else {
  64. $query->where('member_cert.member_cert_name', NULL)->orWhere('member_cert.member_cert_nbr', NULL)->orWhere('member_cert.member_cert_name', '')->orWhere('member_cert.member_cert_nbr', '');
  65. }
  66. })->when(!empty($addtime), function ($query) use ($addtime) {
  67. $addtime[0] = strtotime($addtime[0]);
  68. $addtime[1] = strtotime($addtime[1]);
  69. $query->whereBetween('member.member_addtimes', $addtime);
  70. })->when(!empty($type), function ($query) use ($type) {
  71. if ($type == 'todayAdd') {
  72. $addtime[0] = strtotime(date('Y-m-d') . ' 00:00:00');
  73. $addtime[1] = strtotime(date('Y-m-d') . ' 23:59:59');
  74. } else if ($type == 'monthAdd') {
  75. $addtime[0] = strtotime(date('Y-m-01') . ' 00:00:00');
  76. $addtime[1] = strtotime(date('Y-m-t') . ' 23:59:59');
  77. }
  78. $query->whereBetween('member.member_addtimes', $addtime);
  79. })
  80. ->select('member_id', 'member_is_vip', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
  81. 'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service',
  82. 'member_role.member_role_id', 'member_role.member_role_name',
  83. 'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation',
  84. // 'member_account.member_account_surplus'
  85. );
  86. // 总条数
  87. $total = $rows->count('member_id');
  88. $rows = $rows->orderBy('member_addtimes', 'DESC')
  89. ->forPage($page, $pageSize)
  90. ->get()
  91. ->toArray();
  92. foreach ($rows as &$row) {
  93. $row['coupon_count'] = CouponDetail::where('join_coupon_detail_member_id', $row['member_id'])->count();
  94. $row['member_mobile'] = substr($row['member_mobile'], 0, 3) . '****' . substr($row['member_mobile'], 7);
  95. $row['info'] = [
  96. 'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '用户',
  97. 'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
  98. 'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
  99. 'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
  100. 'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : ''
  101. ];
  102. $row['cert'] = [
  103. 'member_cert_birth' => $row['member_cert_birth'],
  104. 'member_cert_gender' => $row['member_cert_gender'],
  105. 'member_cert_name' => $row['member_cert_name'],
  106. 'member_cert_nbr' => $row['member_cert_nbr'],
  107. 'member_cert_province' => !empty($row['member_cert_province']) && is_json($row['member_cert_province']) ? json_decode($row['member_cert_province']) : '',
  108. 'member_cert_addr' => $row['member_cert_addr'],
  109. 'member_cert_face' => !empty($row['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_face'] : '',
  110. 'member_cert_photo' => !empty($row['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_photo'] : '',
  111. 'member_cert_nation' => $row['member_cert_nation'],
  112. ];
  113. $account = [];
  114. if (!empty($row['account'])) {
  115. foreach ($row['account'] as $item) {
  116. if ($item['member_account_classify'] == 'WELFARE') {
  117. $account['welfare'] = [
  118. 'member_account_name' => $item['member_account_name'],
  119. 'member_account_income' => $item['member_account_income'],
  120. 'member_account_expend' => $item['member_account_expend'],
  121. 'member_account_surplus' => $item['member_account_surplus'],
  122. 'member_account_added' => $item['member_account_added'],
  123. ];
  124. } else if ($item['member_account_classify'] == 'POINTS') {
  125. $account['points'] = [
  126. 'member_account_name' => $item['member_account_name'],
  127. 'member_account_income' => $item['member_account_income'],
  128. 'member_account_expend' => $item['member_account_expend'],
  129. 'member_account_surplus' => $item['member_account_surplus'],
  130. 'member_account_added' => $item['member_account_added'],
  131. ];
  132. } else if ($item['member_account_classify'] == 'CASH') {
  133. $account['cash'] = [
  134. 'member_account_name' => $item['member_account_name'],
  135. 'member_account_income' => $item['member_account_income'],
  136. 'member_account_expend' => $item['member_account_expend'],
  137. 'member_account_surplus' => $item['member_account_surplus'],
  138. 'member_account_added' => $item['member_account_added'],
  139. ];
  140. } else if ($item['member_account_classify'] == 'CARD') {
  141. $account['card'] = [
  142. 'member_account_name' => $item['member_account_name'],
  143. 'member_account_income' => $item['member_account_income'],
  144. 'member_account_expend' => $item['member_account_expend'],
  145. 'member_account_surplus' => $item['member_account_surplus'],
  146. 'member_account_added' => $item['member_account_added'],
  147. ];
  148. } else if ($item['member_account_classify'] == 'VIP') {
  149. $account['vip'] = [
  150. 'member_account_name' => $item['member_account_name'],
  151. 'member_account_income' => $item['member_account_income'],
  152. 'member_account_expend' => $item['member_account_expend'],
  153. 'member_account_surplus' => $item['member_account_surplus'],
  154. 'member_account_added' => $item['member_account_added'],
  155. ];
  156. }
  157. }
  158. }
  159. $row['account'] = $account;
  160. $row['is_auth'] = "未认证";
  161. if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
  162. $row['is_auth'] = "已认证";
  163. }
  164. $row['source'] = "APP";
  165. $row['belong'] = [];
  166. $row['referee'] = [];
  167. if (!empty($row['member_extend_json'])) {
  168. $extendJson = json_decode($row['member_extend_json'], true);
  169. if (isset($extendJson['come_from'])) {
  170. $row['source'] = $extendJson['come_from'] ?? '';
  171. }
  172. if (isset($extendJson['belong'])) {
  173. $user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
  174. if ($user) {
  175. $row['belong']['user_id'] = $extendJson['belong']['user_id'];
  176. $row['belong']['username'] = $user->user_name;
  177. $row['belong']['user_mobile'] = $user->user_mobile;
  178. }
  179. $row['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
  180. }
  181. if (isset($extendJson['referee'])) {
  182. foreach ($extendJson['referee'] as $key => $referee) {
  183. $row['referee'][] = [
  184. 'name' => $referee,
  185. 'time' => $key
  186. ];
  187. }
  188. }
  189. }
  190. }
  191. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  192. }
  193. public static function exportMember(Request $request)
  194. {
  195. $memberIds = $request->get('member_id', '');
  196. $name = $request->get('name', '');
  197. $mobile = $request->get('mobile', '');
  198. $level = $request->get('level', '');
  199. $isAuth = $request->get('is_auth', '');
  200. $addtime = $request->get('member_addtimes', []);
  201. $rows = Member::with('account')
  202. ->where('member_is_owner', 'N')
  203. ->where('member_mobile', '<>', '0000')
  204. ->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
  205. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
  206. // ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
  207. ->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
  208. // ->where('member_account.member_account_classify', 'CASH')
  209. ->when($memberIds != '', function ($query) use ($memberIds) {
  210. $query->whereIn('member.member_id', $memberIds);
  211. })->when($name != '', function ($query) use ($name) {
  212. $query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
  213. })->when($mobile != '', function ($query) use ($mobile) {
  214. $query->where('member.member_mobile', 'like', '%' . $mobile . '%');
  215. })->when($level != '', function ($query) use ($level) {
  216. if ($level == 'other') {
  217. $query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
  218. } else {
  219. $query->where('member_role.member_role_id', $level);
  220. }
  221. })->when($isAuth != '', function ($query) use ($isAuth) {
  222. if ($isAuth == 'Y') {
  223. $query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
  224. } else {
  225. $query->where('member_cert.member_cert_name', NULL)->where('member_cert.member_cert_nbr', NULL)->where('member_cert.member_cert_name', '')->where('member_cert.member_cert_nbr', '');
  226. }
  227. })->when(!empty($addtime), function ($query) use ($addtime) {
  228. $addtime[0] = strtotime($addtime[0]);
  229. $addtime[1] = strtotime($addtime[1]);
  230. $query->whereBetween('member.member_addtimes', $addtime);
  231. })->select('member_id', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
  232. 'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service',
  233. 'member_role.member_role_id', 'member_role.member_role_name',
  234. 'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation',
  235. // 'member_account.member_account_surplus'
  236. )->orderBy('member_addtimes', 'DESC')
  237. ->get()
  238. ->toArray();
  239. $exportData = [];
  240. foreach ($rows as $row) {
  241. $row['info'] = [
  242. 'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '用户',
  243. 'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
  244. 'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
  245. 'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
  246. 'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : ''
  247. ];
  248. $row['cert'] = [
  249. 'member_cert_name' => $row['member_cert_name'],
  250. ];
  251. $account = [];
  252. if (!empty($row['account'])) {
  253. foreach ($row['account'] as $item) {
  254. if ($item['member_account_classify'] == 'POINTS') {
  255. $account['points'] = [
  256. 'member_account_surplus' => $item['member_account_surplus'],
  257. 'member_account_added' => $item['member_account_added'],
  258. ];
  259. } else if ($item['member_account_classify'] == 'CASH') {
  260. $account['cash'] = [
  261. 'member_account_surplus' => $item['member_account_surplus'],
  262. 'member_account_added' => $item['member_account_added'],
  263. ];
  264. } else if ($item['member_account_classify'] == 'CARD') {
  265. $account['card'] = [
  266. 'member_account_surplus' => $item['member_account_surplus'],
  267. 'member_account_added' => $item['member_account_added'],
  268. ];
  269. }
  270. }
  271. }
  272. // $row['account'] = $account;
  273. $row['is_auth'] = "未认证";
  274. if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
  275. $row['is_auth'] = "已认证";
  276. }
  277. $row['source'] = "APP";
  278. if (!empty($row['member_extend_json'])) {
  279. $extendJson = json_decode($row['member_extend_json'], true);
  280. if (isset($extendJson['come_from'])) {
  281. $row['source'] = $extendJson['come_from'] ?? '';
  282. }
  283. }
  284. $sourceStr = ['APP' => "APP", 'CUSTOMER' => "客户管理", 'SYSTEM' => "后台"];
  285. $exportData[] = [
  286. 'member_id' => $row['member_id'],
  287. 'member_info_nickname' => $row['info']['member_info_nickname'] ?? '',
  288. 'member_mobile' => $row['member_mobile'] ?? '',
  289. 'member_cert_name' => $row['cert']['member_cert_name'] ?? '',
  290. 'source' => in_array($row['source'], $sourceStr) ? $sourceStr[$row['source']] : 'APP',
  291. 'cash' => isset($account['cash']) ? $account['cash']['member_account_surplus'] + $account['cash']['member_account_added'] : 0,
  292. 'points' => isset($account['points']) ? $account['points']['member_account_surplus'] + $account['points']['member_account_added'] : 0,
  293. 'is_auth' => $row['is_auth'],
  294. 'level' => $row['member_role_name'] ?? '普通用户',
  295. 'member_addtimes' => $row['member_addtimes'],
  296. 'member_info_referee' => $row['info']['member_info_referee'] ?? '',
  297. 'member_info_business' => $row['info']['member_info_business'] ?? '',
  298. 'member_info_service' => $row['info']['member_info_service'] ?? '',
  299. ];
  300. }
  301. return json_success('', $exportData);
  302. }
  303. public static function info($memberId)
  304. {
  305. $member = Member::with('cert', 'info')
  306. ->where('member_id', $memberId)
  307. ->first();
  308. if (!$member) {
  309. return json_fail('查询错误');
  310. }
  311. $member = $member->toArray();
  312. $member['info'] = [
  313. 'member_info_nickname' => !empty($member['info']) && !empty($member['info']['member_info_nickname']) ? $member['info']['member_info_nickname'] : substr($member['member_mobile'], -4, 4) . '用户',
  314. 'member_info_headimg' => !empty($member['info']) && !empty($member['info']['member_info_headimg']) ? $member['info']['member_info_headimg'] : '',
  315. 'member_info_referee' => !empty($member['info']) && !empty($member['info']['member_info_referee']) ? $member['info']['member_info_referee'] : '',
  316. 'member_info_business' => !empty($member['info']) && !empty($member['info']['member_info_business']) ? $member['info']['member_info_business'] : '',
  317. 'member_info_service' => !empty($member['info']) && !empty($member['info']['member_info_service']) ? $member['info']['member_info_service'] : '',
  318. ];
  319. $member['cert'] = [
  320. 'member_cert_birth' => $member['cert']['member_cert_birth'] ?? '',
  321. 'member_cert_gender' => $member['cert']['member_cert_gender'] ?? '',
  322. 'member_cert_name' => $member['cert']['member_cert_name'] ?? '',
  323. 'member_cert_nbr' => $member['cert']['member_cert_nbr'] ?? '',
  324. 'member_cert_province' => !empty($member['cert']) && !empty($member['cert']['member_cert_province']) && is_json($member['cert']['member_cert_province']) ? json_decode($member['cert']['member_cert_province']) : '',
  325. 'member_cert_addr' => $member['cert']['member_cert_addr'] ?? '',
  326. 'member_cert_face' => !empty($member['cert']) && !empty($member['cert']['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_face'] : '',
  327. 'member_cert_photo' => !empty($member['cert']) && !empty($member['cert']['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_photo'] : '',
  328. 'member_cert_nation' => $member['cert']['member_cert_nation'] ?? '',
  329. ];
  330. if (!empty($member['join_invite_member_id'])){
  331. $inviteMember = Member::with([
  332. 'info'=>function($query){
  333. $query->select('join_info_member_id','member_info_nickname');
  334. },
  335. 'cert'=>function($query){
  336. $query->select('join_cert_member_id','member_cert_name');
  337. }
  338. ])->where('member_id',$member['join_invite_member_id'])
  339. ->first();
  340. $inviteMemberName = '';
  341. if (!empty($inviteMember->cert) && !empty($inviteMember->cert->member_cert_name)){
  342. $inviteMemberName = $inviteMember->cert->member_cert_name;
  343. }elseif (!empty($inviteMemberName->info) && !empty($inviteMemberName->info->member_info_nickname)){
  344. $inviteMemberName = $inviteMemberName->info->member_info_nickname;
  345. }
  346. $member['invite_member'] = $inviteMemberName.(!empty($inviteMember->member_invite_code) ? '('.$inviteMember->member_invite_code.')' : '');
  347. }
  348. $member['is_auth'] = "未认证";
  349. if (!empty($member['cert']['member_cert_nbr']) && !empty($member['cert']['member_cert_name'])) {
  350. $member['is_auth'] = "已认证";
  351. }
  352. $member['source'] = "APP";
  353. $member['belong'] = [];
  354. $member['referee'] = [];
  355. if (!empty($member['member_extend_json'])) {
  356. $extendJson = json_decode($member['member_extend_json'], true);
  357. if (isset($extendJson['come_from'])) {
  358. $member['source'] = $extendJson['come_from'] ?? '';
  359. }
  360. if (isset($extendJson['belong'])) {
  361. $user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
  362. if ($user) {
  363. $member['belong']['user_id'] = $extendJson['belong']['user_id'];
  364. $member['belong']['username'] = $user->user_name;
  365. $member['belong']['user_mobile'] = $user->user_mobile;
  366. }
  367. $member['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
  368. }
  369. if (isset($extendJson['referee'])) {
  370. foreach ($extendJson['referee'] as $key => $referee) {
  371. $member['referee'][] = [
  372. 'name' => $referee,
  373. 'time' => $key
  374. ];
  375. }
  376. }
  377. }
  378. return json_success('', $member);
  379. }
  380. /**
  381. * VIP账户明细
  382. */
  383. public static function vipInfo(Request $request)
  384. {
  385. $memberId = $request->get('member_id', '');
  386. $page = $request->get('page', 1);
  387. $pageSize = $request->get('pageSize', 20);
  388. $account = MemberAccount::where('join_account_member_id', $memberId)
  389. ->where('member_account_classify', 'VIP')
  390. ->first();
  391. $balance = $account->member_account_surplus + $account->member_account_added;
  392. $info = PayDetail::where(function ($query) use ($memberId) {
  393. $query->where('join_pay_member_id', $memberId)
  394. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  395. ->where('pay_category', 'VIP')
  396. ->where('pay_status', 'SUCCESS');
  397. })->orWhere(function ($query) use ($memberId) {
  398. $query->where('join_pay_member_id', $memberId)
  399. ->where('pay_prepayid', 'like', '%VIP%')
  400. ->where('pay_status', 'SUCCESS');
  401. })->orderByDesc('pay_addtimes')
  402. ->get()
  403. ->toArray();
  404. $data = [];
  405. foreach ($info as $key => $item) {
  406. $categoryIds = [];
  407. if (!empty($item['join_pay_order_id'])) {
  408. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  409. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  410. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  411. }
  412. $categoryName = [];
  413. foreach ($categoryIds as $id) {
  414. $category = SysCategory::where('category_id', $id)->first();
  415. if (!empty($category->category_super_path)) {
  416. $path = explode('#', $category->category_super_path);
  417. $ids = array_filter($path);
  418. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  419. } else {
  420. $categoryName[] = $category->category_name;
  421. }
  422. }
  423. $item['goods_category'] = implode(',', array_unique($categoryName));
  424. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  425. $item['goods_category'] = '自定义金额充值';
  426. }
  427. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  428. $item['balance_type'] = 'add';
  429. } else {
  430. $item['balance_type'] = 'cut';
  431. }
  432. if ($key == 0 && in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  433. if (!empty($item['pay_extend_json'])) {
  434. $extendJson = json_decode($item['pay_extend_json'], true);
  435. if (!isset($extendJson['added_amount'])) {
  436. $extendJson['added_amount'] = 0;
  437. }
  438. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  439. $data[] = [
  440. 'join_pay_member_id' => $item['join_pay_member_id'],
  441. 'pay_addtimes' => $item['pay_addtimes'],
  442. 'pay_amount' => $extendJson['added_amount'],
  443. 'pay_category' => 'ADDED',
  444. 'balance' => number_format($balance, 2, '.', ''),
  445. 'balance_type' => 'add',
  446. ];
  447. }
  448. $balance = $balance - $extendJson['added_amount'];
  449. }
  450. $item['balance'] = number_format($balance, 2, '.', '');
  451. $balance = $balance - $item['pay_amount'];
  452. $data[] = $item;
  453. continue;
  454. }
  455. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  456. if (!empty($item['pay_extend_json'])) {
  457. $extendJson = json_decode($item['pay_extend_json'], true);
  458. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  459. $data[] = [
  460. 'join_pay_member_id' => $item['join_pay_member_id'],
  461. 'pay_addtimes' => $item['pay_addtimes'],
  462. 'pay_amount' => $extendJson['added_amount'],
  463. 'pay_category' => 'ADDED',
  464. 'balance' => number_format($balance, 2, '.', ''),
  465. 'balance_type' => 'add',
  466. ];
  467. $balance = $balance - $extendJson['added_amount'];
  468. }
  469. }
  470. $item['balance'] = number_format($balance, 2, '.', '');
  471. $balance = $balance - $item['pay_amount'];
  472. } else {
  473. $item['balance'] = number_format($balance, 2, '.', '');
  474. $balance = $balance + $item['pay_amount'];
  475. }
  476. $data[] = $item;
  477. }
  478. $total = count($data);
  479. $start = ($page - 1) * $pageSize;
  480. $rows = array_slice($data, $start, $pageSize);
  481. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  482. }
  483. public static function welfareInfo(Request $request)
  484. {
  485. $memberId = $request->get('member_id', '');
  486. $page = $request->get('page', 1);
  487. $pageSize = $request->get('pageSize', 20);
  488. $account = MemberAccount::where('join_account_member_id', $memberId)
  489. ->where('member_account_classify', 'WELFARE')
  490. ->first();
  491. $balance = $account->member_account_surplus + $account->member_account_added;
  492. $info = PayDetail::where(function ($query) use ($memberId) {
  493. $query->where('join_pay_member_id', $memberId)
  494. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  495. ->where('pay_category', 'RECHARGE')
  496. ->where('pay_prepayid', 'WELFARE')
  497. ->where('pay_status', 'SUCCESS');
  498. })->orWhere(function ($query) use ($memberId) {
  499. $query->where('join_pay_member_id', $memberId)
  500. ->where('pay_prepayid', 'like', '%WELFARE%')
  501. ->where('pay_status', 'SUCCESS');
  502. })->orderByDesc('pay_addtimes')
  503. ->get()
  504. ->toArray();
  505. $data = [];
  506. foreach ($info as $key => $item) {
  507. $categoryIds = [];
  508. if (!empty($item['join_pay_order_id'])) {
  509. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  510. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  511. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  512. }
  513. $categoryName = [];
  514. foreach ($categoryIds as $id) {
  515. $category = SysCategory::where('category_id', $id)->first();
  516. if (!empty($category->category_super_path)) {
  517. $path = explode('#', $category->category_super_path);
  518. $ids = array_filter($path);
  519. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  520. } else {
  521. $categoryName[] = $category->category_name;
  522. }
  523. }
  524. $item['goods_category'] = implode(',', array_unique($categoryName));
  525. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  526. $item['goods_category'] = '自定义金额充值';
  527. }
  528. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  529. $item['balance_type'] = 'add';
  530. } else {
  531. $item['balance_type'] = 'cut';
  532. }
  533. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  534. if (!empty($item['pay_extend_json'])) {
  535. $extendJson = json_decode($item['pay_extend_json'], true);
  536. if (!isset($extendJson['added_amount'])) {
  537. $extendJson['added_amount'] = 0;
  538. }
  539. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  540. $data[] = [
  541. 'join_pay_member_id' => $item['join_pay_member_id'],
  542. 'pay_addtimes' => $item['pay_addtimes'],
  543. 'pay_amount' => $extendJson['added_amount'],
  544. 'pay_category' => 'ADDED',
  545. 'balance' => number_format($balance, 2, '.', ''),
  546. 'balance_type' => 'add',
  547. ];
  548. }
  549. $balance = $balance - $extendJson['added_amount'];
  550. }
  551. $item['balance'] = number_format($balance, 2, '.', '');
  552. $balance = $balance - $item['pay_amount'];
  553. $data[] = $item;
  554. continue;
  555. }
  556. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  557. if (!empty($item['pay_extend_json'])) {
  558. $extendJson = json_decode($item['pay_extend_json'], true);
  559. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  560. $data[] = [
  561. 'join_pay_member_id' => $item['join_pay_member_id'],
  562. 'pay_addtimes' => $item['pay_addtimes'],
  563. 'pay_amount' => $extendJson['added_amount'],
  564. 'pay_category' => 'ADDED',
  565. 'balance' => number_format($balance, 2, '.', ''),
  566. 'balance_type' => 'add',
  567. ];
  568. $balance = $balance - $extendJson['added_amount'];
  569. }
  570. }
  571. $item['balance'] = number_format($balance, 2, '.', '');
  572. $balance = $balance - $item['pay_amount'];
  573. } else {
  574. $item['balance'] = number_format($balance, 2, '.', '');
  575. $balance = $balance + $item['pay_amount'];
  576. }
  577. $data[] = $item;
  578. }
  579. $total = count($data);
  580. $start = ($page - 1) * $pageSize;
  581. $rows = array_slice($data, $start, $pageSize);
  582. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  583. }
  584. public static function balanceInfo(Request $request)
  585. {
  586. $memberId = $request->get('member_id', '');
  587. $page = $request->get('page', 1);
  588. $pageSize = $request->get('pageSize', 20);
  589. $account = MemberAccount::where('join_account_member_id', $memberId)
  590. ->where('member_account_classify', 'CASH')
  591. ->first();
  592. $balance = $account->member_account_surplus + $account->member_account_added;
  593. $info = PayDetail::where(function ($query) use ($memberId) {
  594. $query->where('join_pay_member_id', $memberId)
  595. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  596. ->where('pay_category', 'RECHARGE')
  597. ->where('pay_prepayid', '<>', $memberId . '-WELFARE')
  598. ->where('pay_status', 'SUCCESS');
  599. })->orWhere(function ($query) use ($memberId) {
  600. $query->where('join_pay_member_id', $memberId)
  601. ->where('pay_prepayid', 'like', '%CASH%')
  602. ->where('pay_status', 'SUCCESS');
  603. })->orderByDesc('pay_addtimes')
  604. ->get()
  605. ->toArray();
  606. $data = [];
  607. foreach ($info as $key => $item) {
  608. $categoryIds = [];
  609. if (!empty($item['join_pay_order_id'])) {
  610. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  611. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  612. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  613. }
  614. $categoryName = [];
  615. foreach ($categoryIds as $id) {
  616. $category = SysCategory::where('category_id', $id)->first();
  617. if (!empty($category->category_super_path)) {
  618. $path = explode('#', $category->category_super_path);
  619. $ids = array_filter($path);
  620. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  621. } else {
  622. $categoryName[] = $category->category_name;
  623. }
  624. }
  625. $item['goods_category'] = implode(',', array_unique($categoryName));
  626. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  627. $item['goods_category'] = '自定义金额充值';
  628. }
  629. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  630. $item['balance_type'] = 'add';
  631. } else {
  632. $item['balance_type'] = 'cut';
  633. }
  634. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  635. if (!empty($item['pay_extend_json'])) {
  636. $extendJson = json_decode($item['pay_extend_json'], true);
  637. if (!isset($extendJson['added_amount'])) {
  638. $extendJson['added_amount'] = 0;
  639. }
  640. // 计划任务还没跑
  641. if ($item['pay_category'] == 'RECHARGE' && (!isset($extendJson['notify']) || $extendJson['notify'] != 'success')) {
  642. continue;
  643. }
  644. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  645. $data[] = [
  646. 'join_pay_member_id' => $item['join_pay_member_id'],
  647. 'pay_addtimes' => $item['pay_addtimes'],
  648. 'pay_amount' => $extendJson['added_amount'],
  649. 'pay_category' => 'ADDED',
  650. 'balance' => number_format($balance, 2, '.', ''),
  651. 'balance_type' => 'add',
  652. ];
  653. }
  654. $balance = $balance - $extendJson['added_amount'];
  655. }
  656. $item['balance'] = number_format($balance, 2, '.', '');
  657. $balance = $balance - $item['pay_amount'];
  658. $data[] = $item;
  659. continue;
  660. }
  661. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  662. if (!empty($item['pay_extend_json'])) {
  663. $extendJson = json_decode($item['pay_extend_json'], true);
  664. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  665. $data[] = [
  666. 'join_pay_member_id' => $item['join_pay_member_id'],
  667. 'pay_addtimes' => $item['pay_addtimes'],
  668. 'pay_amount' => $extendJson['added_amount'],
  669. 'pay_category' => 'ADDED',
  670. 'balance' => number_format($balance, 2, '.', ''),
  671. 'balance_type' => 'add',
  672. ];
  673. $balance = $balance - $extendJson['added_amount'];
  674. }
  675. }
  676. $item['balance'] = number_format($balance, 2, '.', '');
  677. $balance = $balance - $item['pay_amount'];
  678. } else {
  679. $item['balance'] = number_format($balance, 2, '.', '');
  680. $balance = $balance + $item['pay_amount'];
  681. }
  682. $data[] = $item;
  683. }
  684. $total = count($data);
  685. $start = ($page - 1) * $pageSize;
  686. $rows = array_slice($data, $start, $pageSize);
  687. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  688. }
  689. public static function pointInfo($memberId)
  690. {
  691. $account = MemberAccount::where('join_account_member_id', $memberId)
  692. ->where('member_account_classify', 'POINTS')
  693. ->first();
  694. $balance = $account->member_account_surplus + $account->member_account_added;
  695. $points = ClientPoints::where('join_client_points_member_id', $memberId)->get()->toArray();
  696. $nowPoint = 0;
  697. foreach ($points as $key => &$point) {
  698. $point['goods_category'] = '其他';
  699. if (!empty($point['join_client_points_goods_id'])) {
  700. $categoryId = Goods::where('goods_id', $point['join_client_points_goods_id'])->pluck('join_goods_category_id');
  701. $category = SysCategory::where('category_id', $categoryId)->first();
  702. if (!empty($category->category_super_path)) {
  703. $path = explode('#', $category->category_super_path);
  704. $ids = array_filter($path);
  705. $point['goods_category'] = SysCategory::where('category_id', current($ids))->value('category_name');
  706. } else {
  707. $point['goods_category'] = $category->category_name;
  708. }
  709. }
  710. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  711. $point['balance_type'] = 'add';
  712. } else {
  713. $point['balance_type'] = 'cut';
  714. }
  715. if ($key == 0) {
  716. $point['balance'] = number_format($balance, 2, '.', '');
  717. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  718. $balance = $balance - $point['client_points_nbr'];
  719. } else {
  720. $balance = $balance + $point['client_points_nbr'];
  721. }
  722. continue;
  723. }
  724. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  725. $point['balance'] = number_format($balance, 2, '.', '');
  726. $balance = $balance - $point['client_points_nbr'];
  727. // $point['balance'] = $balance = $nowPoint = number_format($balance - $point['client_points_nbr'], 2, '.', '');
  728. } else {
  729. $point['balance'] = number_format($balance, 2, '.', '');
  730. $balance = $balance + $point['client_points_nbr'];
  731. // $point['balance'] = $balance = $nowPoint = number_format($balance + $point['client_points_nbr'], 2, '.', '');
  732. }
  733. }
  734. return json_success('', $points);
  735. }
  736. /**
  737. * @Desc 添加会员
  738. * @Author Gorden
  739. * @Date 2024/3/25 13:40
  740. *
  741. * @param $params
  742. * @return \support\Response
  743. */
  744. public static function add($params)
  745. {
  746. Db::beginTransaction();
  747. try {
  748. $memberId = self::generateMemberId();
  749. // 先写主表,要ID
  750. $memberData = [
  751. 'member_id' => $memberId,
  752. 'member_is_owner' => $params['is_owner'] ?? 'N',
  753. 'member_classify' => $params['classify'] ?? '',
  754. 'member_status' => $params['status'] ?? 'PENDING',
  755. 'member_mobile' => $params['mobile'] ?? '',
  756. 'member_category' => $params['member_category'] ?? '后台添加',
  757. 'member_invite_code' => self::generateInviteCode(),
  758. // 'member_from' => $params['source'],
  759. // 'member_extend_json' => json_encode(['come_from' => $params['source']]),
  760. 'member_addtimes' => time(),
  761. ];
  762. $extendJson['come_from'] = $params['source'];
  763. if (!empty($params['user_id'])) {
  764. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  765. if (!$deptId) {
  766. throw new BusinessException('请先关联业务员和门店');
  767. }
  768. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  769. }
  770. $memberData['member_extend_json'] = json_encode($extendJson);
  771. Member::insert($memberData);
  772. // 账户表
  773. $accountData = [
  774. 'join_account_member_id' => $memberId,
  775. 'member_account_classify' => 'POINTS',
  776. 'member_account_status' => 'ACTIVED',
  777. 'member_account_category' => 'NORMAL',
  778. 'member_account_nbr' => $memberId . '-POINTS',
  779. 'member_account_name' => '积分账户',
  780. 'member_account_addtimes' => time()
  781. ];
  782. // 积分账户
  783. MemberAccount::insert($accountData);
  784. $accountData['member_account_classify'] = 'CASH';
  785. $accountData['member_account_nbr'] = $memberId . '-CASH';
  786. $accountData['member_account_name'] = '余额账户';
  787. // 现金/余额账户
  788. MemberAccount::insert($accountData);
  789. // 福利账户
  790. // if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY'){
  791. // $welfareData = [
  792. // 'join_account_member_id'=>$memberId,
  793. // 'member_account_classify'=>'WELFARE',
  794. // 'member_account_status'=>'ACTIVED',
  795. // 'member_account_category'=>'NORMAL',
  796. // 'member_account_nbr'=>$memberId.'-WELFARE',
  797. // 'member_account_name'=>'福利账户',
  798. // 'member_account_addtimes'=>time()
  799. // ];
  800. // MemberAccount::insert($welfareData);
  801. // }
  802. // member cert
  803. $certData = [
  804. 'join_cert_member_id' => $memberId,
  805. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  806. 'member_cert_name' => $params['cert_name'] ?? '',
  807. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  808. 'member_cert_birth' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
  809. 'member_cert_gender' => $params['gender'] ?? '',
  810. 'member_cert_province' => !empty($params['province']) ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  811. 'member_cert_city' => $params['city'] ?? '',
  812. 'member_cert_addr' => $params['addr'] ?? '',
  813. // 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  814. // 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  815. ];
  816. MemberCert::insert($certData);
  817. // member info
  818. $infoData = [
  819. 'join_info_member_id' => $memberId,
  820. 'member_info_nickname' => $params['account_name'] ?? '',
  821. 'member_info_headimg' => !empty($params['avatar']) ? getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']) : '',
  822. 'member_info_referee' => $params['member_info_referee'] ?? '',
  823. 'member_info_business' => $params['member_info_business'] ?? '',
  824. 'member_info_service' => $params['member_info_service'] ?? '',
  825. ];
  826. MemberInfo::insert($infoData);
  827. Db::commit();
  828. } catch (BusinessException $e) {
  829. Db::rollBack();
  830. return json_fail($e->getMessage());
  831. } catch (\Exception $e) {
  832. Db::rollBack();
  833. dump($e->getMessage() . ';line:' . $e->getLine());
  834. return json_fail("数据添加失败");
  835. }
  836. return json_success('数据添加成功', ['member_id' => $memberId]);
  837. }
  838. /**
  839. * @Desc 编辑会员/ 业主
  840. * @Author Gorden
  841. * @Date 2024/4/20 15:18
  842. *
  843. * @param $params
  844. * @return \support\Response
  845. */
  846. public static function update($params)
  847. {
  848. Db::beginTransaction();
  849. try {
  850. $memberId = $params['member_id'];
  851. $member = Member::where('member_id', $params['member_id'])->first();
  852. if (!$member) {
  853. return json_fail("暂无数据");
  854. }
  855. $extendJson = [];
  856. if (!empty($member->member_extend_json)) {
  857. $extendJson = json_decode($member->member_extend_json, true);
  858. }
  859. $extendJson['come_from'] = $params['source'];
  860. // 门店、业务员
  861. if (!empty($params['user_id'])) {
  862. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  863. if (!$deptId) {
  864. throw new BusinessException('请先关联业务员和门店');
  865. }
  866. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  867. }
  868. // 先写主表,要ID
  869. $memberData = [
  870. 'member_id' => $memberId,
  871. 'member_is_owner' => $params['is_owner'],
  872. 'member_classify' => $params['member_classify'],
  873. 'member_status' => $params['status'],
  874. // 'member_mobile' => $params['mobile'],
  875. // 'member_from' => $params['source'],
  876. 'member_extend_json' => json_encode($extendJson)
  877. ];
  878. Member::where('member_id', $params['member_id'])->update($memberData);
  879. // member cert
  880. $certData = [
  881. 'join_cert_member_id' => $memberId,
  882. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  883. 'member_cert_name' => $params['cert_name'] ?? '',
  884. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  885. 'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  886. 'member_cert_gender' => $params['gender'] ?? '',
  887. 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  888. 'member_cert_city' => $params['city'] ?? '',
  889. 'member_cert_addr' => $params['addr'] ?? '',
  890. 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  891. 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  892. ];
  893. if (!MemberCert::where('join_cert_member_id', $memberId)->exists()) {
  894. MemberCert::insert($certData);
  895. } else {
  896. MemberCert::where('join_cert_member_id', $params['member_id'])->update($certData);
  897. }
  898. // member info
  899. $avatar = '';
  900. if ($params['avatar'] && (strpos($params['avatar'], getenv('APP_IMAGE_DOMAIN')) !== false || strpos($params['avatar'], getenv('SYSTEM_AVATAR_DOMAIN')) !== false)) {
  901. $avatar = $params['avatar'];
  902. } else if ($params['avatar']) {
  903. $avatar = getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']);
  904. }
  905. $infoData = [
  906. 'join_info_member_id' => $memberId,
  907. 'member_info_nickname' => $params['account_name'],
  908. 'member_info_headimg' => $avatar,
  909. 'member_info_referee' => $params['member_info_referee'] ?? '',
  910. 'member_info_business' => $params['member_info_business'] ?? '',
  911. 'member_info_service' => $params['member_info_service'] ?? '',
  912. ];
  913. if (!MemberInfo::where('join_info_member_id', $params['member_id'])->exists()) {
  914. MemberInfo::insert($infoData);
  915. } else {
  916. MemberInfo::where('join_info_member_id', $params['member_id'])->update($infoData);
  917. }
  918. // 福利账户
  919. // if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY' && !MemberAccount::where('member_account_nbr',$memberId.'-WELFARE')->exists()){
  920. // $welfareData = [
  921. // 'join_account_member_id'=>$memberId,
  922. // 'member_account_classify'=>'WELFARE',
  923. // 'member_account_status'=>'ACTIVED',
  924. // 'member_account_category'=>'NORMAL',
  925. // 'member_account_nbr'=>$memberId.'-WELFARE',
  926. // 'member_account_name'=>'福利账户',
  927. // 'member_account_addtimes'=>time()
  928. // ];
  929. // MemberAccount::insert($welfareData);
  930. // }
  931. Db::commit();
  932. } catch (\Exception $e) {
  933. Db::rollBack();
  934. dump($e->getMessage() . ';line:' . $e->getLine());
  935. return json_fail("数据更新失败");
  936. }
  937. return json_success('数据更新成功');
  938. }
  939. /**
  940. * @Desc 会员关联设备列表
  941. * @Author Gorden
  942. * @Date 2024/4/7 9:52
  943. *
  944. * @param $id
  945. * @return \support\Response
  946. */
  947. public static function deviceList($id)
  948. {
  949. $family = Family::where('join_family_creator_member_id', $id)->get()->toArray();
  950. $familyMemberIds = '';
  951. if ($family) {
  952. $familyIds = array_column($family, 'family_id');
  953. $familyMember = FamilyMember::whereIn('join_family_id', $familyIds)->get()->toArray();
  954. $familyMemberIds = array_column($familyMember, 'join_family_member_id');
  955. }
  956. $rows = MemberDevice::leftJoin('device', 'device.device_id', '=', 'member_device.join_member_device_id')
  957. ->leftJoin('member', 'member.member_id', '=', 'member_device.join_device_member_id')
  958. ->leftJoin('family_member', 'family_member.join_family_member_id', '=', 'member_device.join_device_member_id')
  959. ->select('device.device_category', 'device.device_name', 'device.device_type', 'member.member_mobile', 'member_device.*', 'family_member.family_member_name')
  960. ->when(!empty($familyMemberIds), function ($query) use ($familyMemberIds) {
  961. $query->whereIn('member_device.join_device_master_member_id', $familyMemberIds);
  962. })
  963. ->when(empty($familyMemberIds), function ($query) use ($id) {
  964. $query->where('member_device.join_device_master_member_id', $id);
  965. })->orderBy('member_device_addtimes', 'desc')
  966. ->get()
  967. ->toArray();
  968. return json_success('', ['rows' => $rows]);
  969. }
  970. /**
  971. * @Desc 绑定设备
  972. * @Author Gorden
  973. * @Date 2024/4/7 10:27
  974. *
  975. * @param Request $request
  976. * @return \support\Response
  977. */
  978. public static function addDevice(Request $request)
  979. {
  980. $params = $request->post();
  981. Db::beginTransaction();
  982. try {
  983. $data = [
  984. 'join_device_member_id' => $params['join_device_member_id'] ?? '',
  985. 'join_device_master_member_id' => $params['join_device_master_member_id'],
  986. 'join_member_device_id' => $params['join_member_device_id'],
  987. 'member_device_status' => $params['member_device_status'],
  988. 'member_device_key' => $params['member_device_key'] ?? '',
  989. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  990. 'member_device_remark' => $params['member_device_remark'] ?? null,
  991. 'member_device_addtimes' => time(),
  992. ];
  993. MemberDevice::insert($data);
  994. $device = Device::where('device_id', $params['join_member_device_id'])->whereIn('device_status', ['PROCESSING', 'PENDING'])->first();
  995. // 激活设备
  996. if (!$device) {
  997. Db::rollBack();
  998. return json_fail('当前设备不是可激活状态');
  999. }
  1000. $device->device_status = 'ACTIVED';
  1001. $device->save();
  1002. Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => 'ACTIVED']);
  1003. _syslog("绑定设备", "用户【" . ($params['join_device_member_id'] ?? $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  1004. Db::commit();
  1005. } catch (\Exception $e) {
  1006. Db::rollBack();
  1007. dump($e->getMessage());
  1008. return json_fail('绑定失败');
  1009. }
  1010. return json_success('绑定成功');
  1011. }
  1012. public static function updateDevice(Request $request)
  1013. {
  1014. $params = $request->post();
  1015. Db::beginTransaction();
  1016. try {
  1017. $data = [
  1018. 'member_device_status' => $params['member_device_status'],
  1019. 'member_device_key' => $params['member_device_key'],
  1020. 'join_device_member_id' => $params['join_device_member_id'],
  1021. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  1022. 'member_device_remark' => $params['member_device_remark'] ?? null,
  1023. ];
  1024. MemberDevice::where('member_device_id', $request->post('member_device_id'))->update($data);
  1025. $device = Device::where('device_id', $params['join_member_device_id'])->first();
  1026. if ($device->device_status != $params['member_device_status']) {
  1027. $device->device_status = $params['member_device_status'];
  1028. $device->save();
  1029. }
  1030. // Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => $params['member_device_status']]);
  1031. Db::commit();
  1032. _syslog("更新绑定设备", "用户【" . ($params['join_device_member_id'] == "" ? $params['join_device_member_id'] : $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  1033. } catch (\Exception $e) {
  1034. Db::rollBack();
  1035. dump($e->getMessage());
  1036. return json_fail('绑定更新失败');
  1037. }
  1038. return json_success('绑定更新成功');
  1039. }
  1040. public static function deleteDevice(Request $request)
  1041. {
  1042. try {
  1043. Db::beginTransaction();
  1044. $memberDevice = MemberDevice::where('member_device_id', $request->post('member_device_id'))->first();
  1045. if (!$memberDevice) {
  1046. return json_fail('数据不存在');
  1047. }
  1048. $device = Device::where('device_id', $memberDevice->join_member_device_id)->first();
  1049. $device->device_status = "DISABLED";
  1050. $device->save();
  1051. // Device::where('device_id', $memberDevice->join_member_device_id)->update(['device_status' => 'DISABLED']);
  1052. $memberDevice->delete();
  1053. Db::commit();
  1054. _syslog("解除绑定设备", "用户【" . ($memberDevice->join_device_member_id == "" ? $memberDevice->join_device_member_id : $memberDevice->join_device_master_member_id) . '】,解除绑定设备【' . $device->device_name . '】');
  1055. return json_success('解除绑定成功');
  1056. } catch (\Exception $e) {
  1057. Db::rollBack();
  1058. return json_fail('绑定失败');
  1059. }
  1060. }
  1061. /**
  1062. * 手动创建会员
  1063. */
  1064. public static function createMember($params)
  1065. {
  1066. $memberId = $params['member_id'] ?? '';
  1067. if (!$memberId) {
  1068. throw new BusinessException("参数异常");
  1069. }
  1070. // 主表
  1071. $memberData = [
  1072. 'member_id' => $memberId,
  1073. 'member_is_owner' => 'N',
  1074. 'member_classify' => 'MEMBER',
  1075. 'member_status' => 'ACTIVED',
  1076. 'member_mobile' => $params['mobile'],
  1077. 'member_invite_code' => self::generateInviteCode(),
  1078. 'member_extend_json' => json_encode(['come_from' => 'SYSTEM']),
  1079. 'member_addtimes' => time()
  1080. ];
  1081. Member::insert($memberData);
  1082. // 账户表
  1083. $accountData = [
  1084. 'join_account_member_id' => $memberId,
  1085. 'member_account_classify' => 'POINTS',
  1086. 'member_account_status' => 'ACTIVED',
  1087. 'member_account_category' => 'NORMAL',
  1088. 'member_account_nbr' => $memberId . '-POINTS',
  1089. 'member_account_name' => '积分账户',
  1090. 'member_account_addtimes' => time()
  1091. ];
  1092. // 积分账户
  1093. MemberAccount::insert($accountData);
  1094. $accountData['member_account_classify'] = 'CASH';
  1095. $accountData['member_account_nbr'] = $memberId . '-CASH';
  1096. $accountData['member_account_name'] = '余额账户';
  1097. // 现金/余额账户
  1098. MemberAccount::insert($accountData);
  1099. // info
  1100. $infoData = [
  1101. 'join_info_member_id' => $memberId,
  1102. 'member_info_nickname' => $params['username']
  1103. ];
  1104. MemberInfo::insert($infoData);
  1105. }
  1106. private static function generateMemberId()
  1107. {
  1108. $id = SysSerial::getSerial();
  1109. return "MR" . str_pad($id, 16, "0", STR_PAD_LEFT) . random_string(6, 'up');
  1110. }
  1111. public static function getMemberName($mobile, $certName, $nickname)
  1112. {
  1113. $name = '';
  1114. if (!empty($certName)) {
  1115. $name = $certName;
  1116. } elseif (!empty($nickname)) {
  1117. $name = $nickname;
  1118. }
  1119. if (!empty($name) && !empty($mobile)) {
  1120. $name .= '-' . $mobile;
  1121. } elseif (!empty($mobile)) {
  1122. $name = $mobile;
  1123. }
  1124. return $name;
  1125. }
  1126. public static function getMemberNameByMemberId($memberId)
  1127. {
  1128. $member = Member::with([
  1129. 'cert' => function ($query) {
  1130. $query->select('join_cert_member_id', 'member_cert_name');
  1131. },
  1132. 'info' => function ($query) {
  1133. $query->select('join_info_member_id', 'member_info_nickname');
  1134. },
  1135. ]
  1136. )->where('member_id', $memberId)
  1137. ->first();
  1138. if (empty($member)) {
  1139. return;
  1140. }
  1141. $member = $member->toArray();
  1142. $mobile = $certName = $nickname = '';
  1143. if (!empty($member['member_mobile'])) {
  1144. $mobile = $member['member_mobile'];
  1145. }
  1146. if (!empty($member['cert']) && !empty($member['cert']['member_cert_name'])) {
  1147. $certName = $member['cert']['member_cert_name'];
  1148. }
  1149. if (!empty($member['info']) && !empty($member['info']['member_info_nickname'])) {
  1150. $nickname = $member['info']['member_info_nickname'];
  1151. }
  1152. return self::getMemberName($mobile, $certName, $nickname);
  1153. }
  1154. /**
  1155. * @Desc 生成推荐码
  1156. * @Author Gorden
  1157. * @Date 2024/9/6 9:05
  1158. *
  1159. * @return string
  1160. */
  1161. public static function generateInviteCode()
  1162. {
  1163. $code = random_string(8, 'number');
  1164. if (Member::where('member_invite_code', $code)->exists()) {
  1165. return self::generateInviteCode();
  1166. } else {
  1167. return $code;
  1168. }
  1169. }
  1170. }