MemberService.php 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239
  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. $member['is_auth'] = "未认证";
  331. if (!empty($member['cert']['member_cert_nbr']) && !empty($member['cert']['member_cert_name'])) {
  332. $member['is_auth'] = "已认证";
  333. }
  334. $member['source'] = "APP";
  335. $member['belong'] = [];
  336. $member['referee'] = [];
  337. if (!empty($member['member_extend_json'])) {
  338. $extendJson = json_decode($member['member_extend_json'], true);
  339. if (isset($extendJson['come_from'])) {
  340. $member['source'] = $extendJson['come_from'] ?? '';
  341. }
  342. if (isset($extendJson['belong'])) {
  343. $user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
  344. if ($user) {
  345. $member['belong']['user_id'] = $extendJson['belong']['user_id'];
  346. $member['belong']['username'] = $user->user_name;
  347. $member['belong']['user_mobile'] = $user->user_mobile;
  348. }
  349. $member['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
  350. }
  351. if (isset($extendJson['referee'])){
  352. foreach ($extendJson['referee'] as $key => $referee){
  353. $member['referee'][] = [
  354. 'name'=>$referee,
  355. 'time'=>$key
  356. ];
  357. }
  358. }
  359. }
  360. return json_success('', $member);
  361. }
  362. /**
  363. * VIP账户明细
  364. */
  365. public static function vipInfo(Request $request)
  366. {
  367. $memberId = $request->get('member_id', '');
  368. $page = $request->get('page', 1);
  369. $pageSize = $request->get('pageSize', 20);
  370. $account = MemberAccount::where('join_account_member_id', $memberId)
  371. ->where('member_account_classify', 'VIP')
  372. ->first();
  373. $balance = $account->member_account_surplus + $account->member_account_added;
  374. $info = PayDetail::where(function ($query) use ($memberId) {
  375. $query->where('join_pay_member_id', $memberId)
  376. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  377. ->where('pay_category', 'VIP')
  378. ->where('pay_status', 'SUCCESS');
  379. })->orWhere(function ($query) use ($memberId) {
  380. $query->where('join_pay_member_id', $memberId)
  381. ->where('pay_prepayid', 'like', '%VIP%')
  382. ->where('pay_status', 'SUCCESS');
  383. })->orderByDesc('pay_addtimes')
  384. ->get()
  385. ->toArray();
  386. $data = [];
  387. foreach ($info as $key => $item) {
  388. $categoryIds = [];
  389. if (!empty($item['join_pay_order_id'])) {
  390. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  391. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  392. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  393. }
  394. $categoryName = [];
  395. foreach ($categoryIds as $id) {
  396. $category = SysCategory::where('category_id', $id)->first();
  397. if (!empty($category->category_super_path)) {
  398. $path = explode('#', $category->category_super_path);
  399. $ids = array_filter($path);
  400. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  401. } else {
  402. $categoryName[] = $category->category_name;
  403. }
  404. }
  405. $item['goods_category'] = implode(',', array_unique($categoryName));
  406. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  407. $item['goods_category'] = '自定义金额充值';
  408. }
  409. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  410. $item['balance_type'] = 'add';
  411. } else {
  412. $item['balance_type'] = 'cut';
  413. }
  414. if ($key == 0 && in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  415. if (!empty($item['pay_extend_json'])) {
  416. $extendJson = json_decode($item['pay_extend_json'], true);
  417. if (!isset($extendJson['added_amount'])) {
  418. $extendJson['added_amount'] = 0;
  419. }
  420. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  421. $data[] = [
  422. 'join_pay_member_id' => $item['join_pay_member_id'],
  423. 'pay_addtimes' => $item['pay_addtimes'],
  424. 'pay_amount' => $extendJson['added_amount'],
  425. 'pay_category' => 'ADDED',
  426. 'balance' => number_format($balance, 2, '.', ''),
  427. 'balance_type' => 'add',
  428. ];
  429. }
  430. $balance = $balance - $extendJson['added_amount'];
  431. }
  432. $item['balance'] = number_format($balance, 2, '.', '');
  433. $balance = $balance - $item['pay_amount'];
  434. $data[] = $item;
  435. continue;
  436. }
  437. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  438. if (!empty($item['pay_extend_json'])) {
  439. $extendJson = json_decode($item['pay_extend_json'], true);
  440. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  441. $data[] = [
  442. 'join_pay_member_id' => $item['join_pay_member_id'],
  443. 'pay_addtimes' => $item['pay_addtimes'],
  444. 'pay_amount' => $extendJson['added_amount'],
  445. 'pay_category' => 'ADDED',
  446. 'balance' => number_format($balance, 2, '.', ''),
  447. 'balance_type' => 'add',
  448. ];
  449. $balance = $balance - $extendJson['added_amount'];
  450. }
  451. }
  452. $item['balance'] = number_format($balance, 2, '.', '');
  453. $balance = $balance - $item['pay_amount'];
  454. } else {
  455. $item['balance'] = number_format($balance, 2, '.', '');
  456. $balance = $balance + $item['pay_amount'];
  457. }
  458. $data[] = $item;
  459. }
  460. $total = count($data);
  461. $start = ($page - 1) * $pageSize;
  462. $rows = array_slice($data, $start, $pageSize);
  463. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  464. }
  465. public static function welfareInfo(Request $request)
  466. {
  467. $memberId = $request->get('member_id', '');
  468. $page = $request->get('page', 1);
  469. $pageSize = $request->get('pageSize', 20);
  470. $account = MemberAccount::where('join_account_member_id', $memberId)
  471. ->where('member_account_classify', 'WELFARE')
  472. ->first();
  473. $balance = $account->member_account_surplus + $account->member_account_added;
  474. $info = PayDetail::where(function ($query) use ($memberId) {
  475. $query->where('join_pay_member_id', $memberId)
  476. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  477. ->where('pay_category', 'RECHARGE')
  478. ->where('pay_prepayid', 'WELFARE')
  479. ->where('pay_status', 'SUCCESS');
  480. })->orWhere(function ($query) use ($memberId) {
  481. $query->where('join_pay_member_id', $memberId)
  482. ->where('pay_prepayid', 'like', '%WELFARE%')
  483. ->where('pay_status', 'SUCCESS');
  484. })->orderByDesc('pay_addtimes')
  485. ->get()
  486. ->toArray();
  487. $data = [];
  488. foreach ($info as $key => $item) {
  489. $categoryIds = [];
  490. if (!empty($item['join_pay_order_id'])) {
  491. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  492. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  493. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  494. }
  495. $categoryName = [];
  496. foreach ($categoryIds as $id) {
  497. $category = SysCategory::where('category_id', $id)->first();
  498. if (!empty($category->category_super_path)) {
  499. $path = explode('#', $category->category_super_path);
  500. $ids = array_filter($path);
  501. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  502. } else {
  503. $categoryName[] = $category->category_name;
  504. }
  505. }
  506. $item['goods_category'] = implode(',', array_unique($categoryName));
  507. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  508. $item['goods_category'] = '自定义金额充值';
  509. }
  510. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  511. $item['balance_type'] = 'add';
  512. } else {
  513. $item['balance_type'] = 'cut';
  514. }
  515. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  516. if (!empty($item['pay_extend_json'])) {
  517. $extendJson = json_decode($item['pay_extend_json'], true);
  518. if (!isset($extendJson['added_amount'])) {
  519. $extendJson['added_amount'] = 0;
  520. }
  521. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  522. $data[] = [
  523. 'join_pay_member_id' => $item['join_pay_member_id'],
  524. 'pay_addtimes' => $item['pay_addtimes'],
  525. 'pay_amount' => $extendJson['added_amount'],
  526. 'pay_category' => 'ADDED',
  527. 'balance' => number_format($balance, 2, '.', ''),
  528. 'balance_type' => 'add',
  529. ];
  530. }
  531. $balance = $balance - $extendJson['added_amount'];
  532. }
  533. $item['balance'] = number_format($balance, 2, '.', '');
  534. $balance = $balance - $item['pay_amount'];
  535. $data[] = $item;
  536. continue;
  537. }
  538. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  539. if (!empty($item['pay_extend_json'])) {
  540. $extendJson = json_decode($item['pay_extend_json'], true);
  541. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  542. $data[] = [
  543. 'join_pay_member_id' => $item['join_pay_member_id'],
  544. 'pay_addtimes' => $item['pay_addtimes'],
  545. 'pay_amount' => $extendJson['added_amount'],
  546. 'pay_category' => 'ADDED',
  547. 'balance' => number_format($balance, 2, '.', ''),
  548. 'balance_type' => 'add',
  549. ];
  550. $balance = $balance - $extendJson['added_amount'];
  551. }
  552. }
  553. $item['balance'] = number_format($balance, 2, '.', '');
  554. $balance = $balance - $item['pay_amount'];
  555. } else {
  556. $item['balance'] = number_format($balance, 2, '.', '');
  557. $balance = $balance + $item['pay_amount'];
  558. }
  559. $data[] = $item;
  560. }
  561. $total = count($data);
  562. $start = ($page - 1) * $pageSize;
  563. $rows = array_slice($data, $start, $pageSize);
  564. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  565. }
  566. public static function balanceInfo(Request $request)
  567. {
  568. $memberId = $request->get('member_id', '');
  569. $page = $request->get('page', 1);
  570. $pageSize = $request->get('pageSize', 20);
  571. $account = MemberAccount::where('join_account_member_id', $memberId)
  572. ->where('member_account_classify', 'CASH')
  573. ->first();
  574. $balance = $account->member_account_surplus + $account->member_account_added;
  575. $info = PayDetail::where(function ($query) use ($memberId) {
  576. $query->where('join_pay_member_id', $memberId)
  577. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  578. ->where('pay_category', 'RECHARGE')
  579. ->where('pay_prepayid', '<>', $memberId . '-WELFARE')
  580. ->where('pay_status', 'SUCCESS');
  581. })->orWhere(function ($query) use ($memberId) {
  582. $query->where('join_pay_member_id', $memberId)
  583. ->where('pay_prepayid', 'like', '%CASH%')
  584. ->where('pay_status', 'SUCCESS');
  585. })->orderByDesc('pay_addtimes')
  586. ->get()
  587. ->toArray();
  588. $data = [];
  589. foreach ($info as $key => $item) {
  590. $categoryIds = [];
  591. if (!empty($item['join_pay_order_id'])) {
  592. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  593. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  594. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  595. }
  596. $categoryName = [];
  597. foreach ($categoryIds as $id) {
  598. $category = SysCategory::where('category_id', $id)->first();
  599. if (!empty($category->category_super_path)) {
  600. $path = explode('#', $category->category_super_path);
  601. $ids = array_filter($path);
  602. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  603. } else {
  604. $categoryName[] = $category->category_name;
  605. }
  606. }
  607. $item['goods_category'] = implode(',', array_unique($categoryName));
  608. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  609. $item['goods_category'] = '自定义金额充值';
  610. }
  611. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  612. $item['balance_type'] = 'add';
  613. } else {
  614. $item['balance_type'] = 'cut';
  615. }
  616. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  617. if (!empty($item['pay_extend_json'])) {
  618. $extendJson = json_decode($item['pay_extend_json'], true);
  619. if (!isset($extendJson['added_amount'])) {
  620. $extendJson['added_amount'] = 0;
  621. }
  622. // 计划任务还没跑
  623. if ($item['pay_category'] == 'RECHARGE' && (!isset($extendJson['notify']) || $extendJson['notify'] != 'success')) {
  624. continue;
  625. }
  626. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  627. $data[] = [
  628. 'join_pay_member_id' => $item['join_pay_member_id'],
  629. 'pay_addtimes' => $item['pay_addtimes'],
  630. 'pay_amount' => $extendJson['added_amount'],
  631. 'pay_category' => 'ADDED',
  632. 'balance' => number_format($balance, 2, '.', ''),
  633. 'balance_type' => 'add',
  634. ];
  635. }
  636. $balance = $balance - $extendJson['added_amount'];
  637. }
  638. $item['balance'] = number_format($balance, 2, '.', '');
  639. $balance = $balance - $item['pay_amount'];
  640. $data[] = $item;
  641. continue;
  642. }
  643. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  644. if (!empty($item['pay_extend_json'])) {
  645. $extendJson = json_decode($item['pay_extend_json'], true);
  646. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  647. $data[] = [
  648. 'join_pay_member_id' => $item['join_pay_member_id'],
  649. 'pay_addtimes' => $item['pay_addtimes'],
  650. 'pay_amount' => $extendJson['added_amount'],
  651. 'pay_category' => 'ADDED',
  652. 'balance' => number_format($balance, 2, '.', ''),
  653. 'balance_type' => 'add',
  654. ];
  655. $balance = $balance - $extendJson['added_amount'];
  656. }
  657. }
  658. $item['balance'] = number_format($balance, 2, '.', '');
  659. $balance = $balance - $item['pay_amount'];
  660. } else {
  661. $item['balance'] = number_format($balance, 2, '.', '');
  662. $balance = $balance + $item['pay_amount'];
  663. }
  664. $data[] = $item;
  665. }
  666. $total = count($data);
  667. $start = ($page - 1) * $pageSize;
  668. $rows = array_slice($data, $start, $pageSize);
  669. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  670. }
  671. public static function pointInfo($memberId)
  672. {
  673. $account = MemberAccount::where('join_account_member_id', $memberId)
  674. ->where('member_account_classify', 'POINTS')
  675. ->first();
  676. $balance = $account->member_account_surplus + $account->member_account_added;
  677. $points = ClientPoints::where('join_client_points_member_id', $memberId)->get()->toArray();
  678. $nowPoint = 0;
  679. foreach ($points as $key => &$point) {
  680. $point['goods_category'] = '其他';
  681. if (!empty($point['join_client_points_goods_id'])) {
  682. $categoryId = Goods::where('goods_id', $point['join_client_points_goods_id'])->pluck('join_goods_category_id');
  683. $category = SysCategory::where('category_id', $categoryId)->first();
  684. if (!empty($category->category_super_path)) {
  685. $path = explode('#', $category->category_super_path);
  686. $ids = array_filter($path);
  687. $point['goods_category'] = SysCategory::where('category_id', current($ids))->value('category_name');
  688. } else {
  689. $point['goods_category'] = $category->category_name;
  690. }
  691. }
  692. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送",'登录活动积分'])) {
  693. $point['balance_type'] = 'add';
  694. } else {
  695. $point['balance_type'] = 'cut';
  696. }
  697. if ($key == 0) {
  698. $point['balance'] = number_format($balance, 2, '.', '');
  699. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送",'登录活动积分'])) {
  700. $balance = $balance - $point['client_points_nbr'];
  701. } else {
  702. $balance = $balance + $point['client_points_nbr'];
  703. }
  704. continue;
  705. }
  706. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送",'登录活动积分'])) {
  707. $point['balance'] = number_format($balance, 2, '.', '');
  708. $balance = $balance - $point['client_points_nbr'];
  709. // $point['balance'] = $balance = $nowPoint = number_format($balance - $point['client_points_nbr'], 2, '.', '');
  710. } else {
  711. $point['balance'] = number_format($balance, 2, '.', '');
  712. $balance = $balance + $point['client_points_nbr'];
  713. // $point['balance'] = $balance = $nowPoint = number_format($balance + $point['client_points_nbr'], 2, '.', '');
  714. }
  715. }
  716. return json_success('', $points);
  717. }
  718. /**
  719. * @Desc 添加会员
  720. * @Author Gorden
  721. * @Date 2024/3/25 13:40
  722. *
  723. * @param $params
  724. * @return \support\Response
  725. */
  726. public static function add($params)
  727. {
  728. Db::beginTransaction();
  729. try {
  730. $memberId = self::generateMemberId();
  731. // 先写主表,要ID
  732. $memberData = [
  733. 'member_id' => $memberId,
  734. 'member_is_owner' => $params['is_owner'] ?? 'N',
  735. 'member_classify' => $params['classify'] ?? '',
  736. 'member_status' => $params['status'] ?? 'PENDING',
  737. 'member_mobile' => $params['mobile'] ?? '',
  738. 'member_category' => $params['member_category'] ?? '后台添加',
  739. // 'member_from' => $params['source'],
  740. // 'member_extend_json' => json_encode(['come_from' => $params['source']]),
  741. 'member_addtimes' => time(),
  742. ];
  743. $extendJson['come_from'] = $params['source'];
  744. if (!empty($params['user_id'])) {
  745. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  746. if (!$deptId) {
  747. throw new BusinessException('请先关联业务员和门店');
  748. }
  749. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  750. }
  751. $memberData['member_extend_json'] = json_encode($extendJson);
  752. Member::insert($memberData);
  753. // 账户表
  754. $accountData = [
  755. 'join_account_member_id' => $memberId,
  756. 'member_account_classify' => 'POINTS',
  757. 'member_account_status' => 'ACTIVED',
  758. 'member_account_category' => 'NORMAL',
  759. 'member_account_nbr' => $memberId . '-POINTS',
  760. 'member_account_name' => '积分账户',
  761. 'member_account_addtimes' => time()
  762. ];
  763. // 积分账户
  764. MemberAccount::insert($accountData);
  765. $accountData['member_account_classify'] = 'CASH';
  766. $accountData['member_account_nbr'] = $memberId . '-CASH';
  767. $accountData['member_account_name'] = '余额账户';
  768. // 现金/余额账户
  769. MemberAccount::insert($accountData);
  770. // 福利账户
  771. // if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY'){
  772. // $welfareData = [
  773. // 'join_account_member_id'=>$memberId,
  774. // 'member_account_classify'=>'WELFARE',
  775. // 'member_account_status'=>'ACTIVED',
  776. // 'member_account_category'=>'NORMAL',
  777. // 'member_account_nbr'=>$memberId.'-WELFARE',
  778. // 'member_account_name'=>'福利账户',
  779. // 'member_account_addtimes'=>time()
  780. // ];
  781. // MemberAccount::insert($welfareData);
  782. // }
  783. // member cert
  784. $certData = [
  785. 'join_cert_member_id' => $memberId,
  786. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  787. 'member_cert_name' => $params['cert_name'] ?? '',
  788. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  789. 'member_cert_birth' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
  790. 'member_cert_gender' => $params['gender'] ?? '',
  791. 'member_cert_province' => !empty($params['province']) ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  792. 'member_cert_city' => $params['city'] ?? '',
  793. 'member_cert_addr' => $params['addr'] ?? '',
  794. // 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  795. // 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  796. ];
  797. MemberCert::insert($certData);
  798. // member info
  799. $infoData = [
  800. 'join_info_member_id' => $memberId,
  801. 'member_info_nickname' => $params['account_name'] ?? '',
  802. 'member_info_headimg' => !empty($params['avatar']) ? getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']) : '',
  803. 'member_info_referee' => $params['member_info_referee'] ?? '',
  804. 'member_info_business' => $params['member_info_business'] ?? '',
  805. 'member_info_service' => $params['member_info_service'] ?? '',
  806. ];
  807. MemberInfo::insert($infoData);
  808. Db::commit();
  809. } catch (BusinessException $e) {
  810. Db::rollBack();
  811. return json_fail($e->getMessage());
  812. } catch (\Exception $e) {
  813. Db::rollBack();
  814. dump($e->getMessage() . ';line:' . $e->getLine());
  815. return json_fail("数据添加失败");
  816. }
  817. return json_success('数据添加成功', ['member_id' => $memberId]);
  818. }
  819. /**
  820. * @Desc 编辑会员/ 业主
  821. * @Author Gorden
  822. * @Date 2024/4/20 15:18
  823. *
  824. * @param $params
  825. * @return \support\Response
  826. */
  827. public static function update($params)
  828. {
  829. Db::beginTransaction();
  830. try {
  831. $memberId = $params['member_id'];
  832. $member = Member::where('member_id', $params['member_id'])->first();
  833. if (!$member) {
  834. return json_fail("暂无数据");
  835. }
  836. $extendJson = [];
  837. if (!empty($member->member_extend_json)) {
  838. $extendJson = json_decode($member->member_extend_json, true);
  839. }
  840. $extendJson['come_from'] = $params['source'];
  841. // 门店、业务员
  842. if (!empty($params['user_id'])) {
  843. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  844. if (!$deptId) {
  845. throw new BusinessException('请先关联业务员和门店');
  846. }
  847. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  848. }
  849. // 先写主表,要ID
  850. $memberData = [
  851. 'member_id' => $memberId,
  852. 'member_is_owner' => $params['is_owner'],
  853. 'member_classify' => $params['member_classify'],
  854. 'member_status' => $params['status'],
  855. // 'member_mobile' => $params['mobile'],
  856. // 'member_from' => $params['source'],
  857. 'member_extend_json' => json_encode($extendJson)
  858. ];
  859. Member::where('member_id', $params['member_id'])->update($memberData);
  860. // member cert
  861. $certData = [
  862. 'join_cert_member_id' => $memberId,
  863. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  864. 'member_cert_name' => $params['cert_name'] ?? '',
  865. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  866. 'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  867. 'member_cert_gender' => $params['gender'] ?? '',
  868. 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  869. 'member_cert_city' => $params['city'] ?? '',
  870. 'member_cert_addr' => $params['addr'] ?? '',
  871. 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  872. 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  873. ];
  874. if (!MemberCert::where('join_cert_member_id', $memberId)->exists()) {
  875. MemberCert::insert($certData);
  876. } else {
  877. MemberCert::where('join_cert_member_id', $params['member_id'])->update($certData);
  878. }
  879. // member info
  880. $avatar = '';
  881. if ($params['avatar'] && (strpos($params['avatar'], getenv('APP_IMAGE_DOMAIN')) !== false || strpos($params['avatar'], getenv('SYSTEM_AVATAR_DOMAIN')) !== false)) {
  882. $avatar = $params['avatar'];
  883. } else if ($params['avatar']) {
  884. $avatar = getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']);
  885. }
  886. $infoData = [
  887. 'join_info_member_id' => $memberId,
  888. 'member_info_nickname' => $params['account_name'],
  889. 'member_info_headimg' => $avatar,
  890. 'member_info_referee' => $params['member_info_referee'] ?? '',
  891. 'member_info_business' => $params['member_info_business'] ?? '',
  892. 'member_info_service' => $params['member_info_service'] ?? '',
  893. ];
  894. if (!MemberInfo::where('join_info_member_id', $params['member_id'])->exists()) {
  895. MemberInfo::insert($infoData);
  896. } else {
  897. MemberInfo::where('join_info_member_id', $params['member_id'])->update($infoData);
  898. }
  899. // 福利账户
  900. // if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY' && !MemberAccount::where('member_account_nbr',$memberId.'-WELFARE')->exists()){
  901. // $welfareData = [
  902. // 'join_account_member_id'=>$memberId,
  903. // 'member_account_classify'=>'WELFARE',
  904. // 'member_account_status'=>'ACTIVED',
  905. // 'member_account_category'=>'NORMAL',
  906. // 'member_account_nbr'=>$memberId.'-WELFARE',
  907. // 'member_account_name'=>'福利账户',
  908. // 'member_account_addtimes'=>time()
  909. // ];
  910. // MemberAccount::insert($welfareData);
  911. // }
  912. Db::commit();
  913. } catch (\Exception $e) {
  914. Db::rollBack();
  915. dump($e->getMessage() . ';line:' . $e->getLine());
  916. return json_fail("数据更新失败");
  917. }
  918. return json_success('数据更新成功');
  919. }
  920. /**
  921. * @Desc 会员关联设备列表
  922. * @Author Gorden
  923. * @Date 2024/4/7 9:52
  924. *
  925. * @param $id
  926. * @return \support\Response
  927. */
  928. public static function deviceList($id)
  929. {
  930. $family = Family::where('join_family_creator_member_id', $id)->get()->toArray();
  931. $familyMemberIds = '';
  932. if ($family) {
  933. $familyIds = array_column($family, 'family_id');
  934. $familyMember = FamilyMember::whereIn('join_family_id', $familyIds)->get()->toArray();
  935. $familyMemberIds = array_column($familyMember, 'join_family_member_id');
  936. }
  937. $rows = MemberDevice::leftJoin('device', 'device.device_id', '=', 'member_device.join_member_device_id')
  938. ->leftJoin('member', 'member.member_id', '=', 'member_device.join_device_member_id')
  939. ->leftJoin('family_member', 'family_member.join_family_member_id', '=', 'member_device.join_device_member_id')
  940. ->select('device.device_category', 'device.device_name', 'device.device_type', 'member.member_mobile', 'member_device.*', 'family_member.family_member_name')
  941. ->when(!empty($familyMemberIds), function ($query) use ($familyMemberIds) {
  942. $query->whereIn('member_device.join_device_master_member_id', $familyMemberIds);
  943. })
  944. ->when(empty($familyMemberIds), function ($query) use ($id) {
  945. $query->where('member_device.join_device_master_member_id', $id);
  946. })->orderBy('member_device_addtimes', 'desc')
  947. ->get()
  948. ->toArray();
  949. return json_success('', ['rows' => $rows]);
  950. }
  951. /**
  952. * @Desc 绑定设备
  953. * @Author Gorden
  954. * @Date 2024/4/7 10:27
  955. *
  956. * @param Request $request
  957. * @return \support\Response
  958. */
  959. public static function addDevice(Request $request)
  960. {
  961. $params = $request->post();
  962. Db::beginTransaction();
  963. try {
  964. $data = [
  965. 'join_device_member_id' => $params['join_device_member_id'] ?? '',
  966. 'join_device_master_member_id' => $params['join_device_master_member_id'],
  967. 'join_member_device_id' => $params['join_member_device_id'],
  968. 'member_device_status' => $params['member_device_status'],
  969. 'member_device_key' => $params['member_device_key'] ?? '',
  970. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  971. 'member_device_remark' => $params['member_device_remark'] ?? null,
  972. 'member_device_addtimes' => time(),
  973. ];
  974. MemberDevice::insert($data);
  975. $device = Device::where('device_id', $params['join_member_device_id'])->whereIn('device_status', ['PROCESSING', 'PENDING'])->first();
  976. // 激活设备
  977. if (!$device) {
  978. Db::rollBack();
  979. return json_fail('当前设备不是可激活状态');
  980. }
  981. $device->device_status = 'ACTIVED';
  982. $device->save();
  983. Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => 'ACTIVED']);
  984. _syslog("绑定设备", "用户【" . ($params['join_device_member_id'] ?? $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  985. Db::commit();
  986. } catch (\Exception $e) {
  987. Db::rollBack();
  988. dump($e->getMessage());
  989. return json_fail('绑定失败');
  990. }
  991. return json_success('绑定成功');
  992. }
  993. public static function updateDevice(Request $request)
  994. {
  995. $params = $request->post();
  996. Db::beginTransaction();
  997. try {
  998. $data = [
  999. 'member_device_status' => $params['member_device_status'],
  1000. 'member_device_key' => $params['member_device_key'],
  1001. 'join_device_member_id' => $params['join_device_member_id'],
  1002. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  1003. 'member_device_remark' => $params['member_device_remark'] ?? null,
  1004. ];
  1005. MemberDevice::where('member_device_id', $request->post('member_device_id'))->update($data);
  1006. $device = Device::where('device_id', $params['join_member_device_id'])->first();
  1007. if ($device->device_status != $params['member_device_status']) {
  1008. $device->device_status = $params['member_device_status'];
  1009. $device->save();
  1010. }
  1011. // Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => $params['member_device_status']]);
  1012. Db::commit();
  1013. _syslog("更新绑定设备", "用户【" . ($params['join_device_member_id'] == "" ? $params['join_device_member_id'] : $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  1014. } catch (\Exception $e) {
  1015. Db::rollBack();
  1016. dump($e->getMessage());
  1017. return json_fail('绑定更新失败');
  1018. }
  1019. return json_success('绑定更新成功');
  1020. }
  1021. public static function deleteDevice(Request $request)
  1022. {
  1023. try {
  1024. Db::beginTransaction();
  1025. $memberDevice = MemberDevice::where('member_device_id', $request->post('member_device_id'))->first();
  1026. if (!$memberDevice) {
  1027. return json_fail('数据不存在');
  1028. }
  1029. $device = Device::where('device_id', $memberDevice->join_member_device_id)->first();
  1030. $device->device_status = "DISABLED";
  1031. $device->save();
  1032. // Device::where('device_id', $memberDevice->join_member_device_id)->update(['device_status' => 'DISABLED']);
  1033. $memberDevice->delete();
  1034. Db::commit();
  1035. _syslog("解除绑定设备", "用户【" . ($memberDevice->join_device_member_id == "" ? $memberDevice->join_device_member_id : $memberDevice->join_device_master_member_id) . '】,解除绑定设备【' . $device->device_name . '】');
  1036. return json_success('解除绑定成功');
  1037. } catch (\Exception $e) {
  1038. Db::rollBack();
  1039. return json_fail('绑定失败');
  1040. }
  1041. }
  1042. /**
  1043. * 手动创建会员
  1044. */
  1045. public static function createMember($params)
  1046. {
  1047. $memberId = $params['member_id'] ?? '';
  1048. if (!$memberId) {
  1049. throw new BusinessException("参数异常");
  1050. }
  1051. // 主表
  1052. $memberData = [
  1053. 'member_id' => $memberId,
  1054. 'member_is_owner' => 'N',
  1055. 'member_classify' => 'MEMBER',
  1056. 'member_status' => 'ACTIVED',
  1057. 'member_mobile' => $params['mobile'],
  1058. 'member_extend_json' => json_encode(['come_from' => 'SYSTEM']),
  1059. 'member_addtimes' => time()
  1060. ];
  1061. Member::insert($memberData);
  1062. // 账户表
  1063. $accountData = [
  1064. 'join_account_member_id' => $memberId,
  1065. 'member_account_classify' => 'POINTS',
  1066. 'member_account_status' => 'ACTIVED',
  1067. 'member_account_category' => 'NORMAL',
  1068. 'member_account_nbr' => $memberId . '-POINTS',
  1069. 'member_account_name' => '积分账户',
  1070. 'member_account_addtimes' => time()
  1071. ];
  1072. // 积分账户
  1073. MemberAccount::insert($accountData);
  1074. $accountData['member_account_classify'] = 'CASH';
  1075. $accountData['member_account_nbr'] = $memberId . '-CASH';
  1076. $accountData['member_account_name'] = '余额账户';
  1077. // 现金/余额账户
  1078. MemberAccount::insert($accountData);
  1079. // info
  1080. $infoData = [
  1081. 'join_info_member_id' => $memberId,
  1082. 'member_info_nickname' => $params['username']
  1083. ];
  1084. MemberInfo::insert($infoData);
  1085. }
  1086. private static function generateMemberId()
  1087. {
  1088. $id = SysSerial::getSerial();
  1089. return "MR" . str_pad($id, 16, "0", STR_PAD_LEFT) . random_string(6, 'up');
  1090. }
  1091. public static function getMemberName($mobile, $certName, $nickname)
  1092. {
  1093. $name = '';
  1094. if (!empty($certName)) {
  1095. $name = $certName;
  1096. } elseif (!empty($nickname)) {
  1097. $name = $nickname;
  1098. }
  1099. if (!empty($name) && !empty($mobile)) {
  1100. $name .= '-' . $mobile;
  1101. } elseif (!empty($mobile)) {
  1102. $name = $mobile;
  1103. }
  1104. return $name;
  1105. }
  1106. public static function getMemberNameByMemberId($memberId)
  1107. {
  1108. $member = Member::with([
  1109. 'cert' => function ($query) {
  1110. $query->select('join_cert_member_id', 'member_cert_name');
  1111. },
  1112. 'info' => function ($query) {
  1113. $query->select('join_info_member_id', 'member_info_nickname');
  1114. },
  1115. ]
  1116. )->where('member_id', $memberId)
  1117. ->first();
  1118. if (empty($member)) {
  1119. return;
  1120. }
  1121. $member = $member->toArray();
  1122. $mobile = $certName = $nickname = '';
  1123. if (!empty($member['member_mobile'])) {
  1124. $mobile = $member['member_mobile'];
  1125. }
  1126. if (!empty($member['cert']) && !empty($member['cert']['member_cert_name'])) {
  1127. $certName = $member['cert']['member_cert_name'];
  1128. }
  1129. if (!empty($member['info']) && !empty($member['info']['member_info_nickname'])) {
  1130. $nickname = $member['info']['member_info_nickname'];
  1131. }
  1132. return self::getMemberName($mobile, $certName, $nickname);
  1133. }
  1134. }