MemberService.php 58 KB

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