MemberService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604
  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\SysSerial;
  18. use support\Db;
  19. use support\Request;
  20. class MemberService
  21. {
  22. public static function list(Request $request)
  23. {
  24. $page = $request->get('page', 1);
  25. $pageSize = $request->get('pageSize', 10);
  26. $name = $request->get('name', '');
  27. $mobile = $request->get('mobile', '');
  28. $rows = Member::with('account')
  29. ->where('member_is_owner', 'N')
  30. ->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
  31. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
  32. // ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
  33. ->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
  34. // ->where('member_account.member_account_classify', 'CASH')
  35. ->when($name != '', function ($query) use ($name) {
  36. $query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
  37. })->when($mobile != '', function ($query) use ($mobile) {
  38. $query->where('member.member_mobile', 'like', '%' . $mobile . '%');
  39. })->select('member_id', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
  40. 'member_info.member_info_nickname', 'member_info.member_info_headimg',
  41. 'member_role.member_role_id', 'member_role.member_role_name',
  42. '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',
  43. // 'member_account.member_account_surplus'
  44. );
  45. // 总条数
  46. $total = $rows->count('member_id');
  47. $rows = $rows->orderBy('member_addtimes', 'DESC')
  48. ->forPage($page, $pageSize)
  49. ->get()
  50. ->toArray();
  51. foreach ($rows as &$row) {
  52. $row['info'] = [
  53. 'member_info_nickname' => $row['member_info_nickname'] ?? '',
  54. 'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : ''
  55. ];
  56. $row['cert'] = [
  57. 'member_cert_birth' => $row['member_cert_birth'],
  58. 'member_cert_gender' => $row['member_cert_gender'],
  59. 'member_cert_name' => $row['member_cert_name'],
  60. 'member_cert_nbr' => $row['member_cert_nbr'],
  61. 'member_cert_province' => !empty($row['member_cert_province']) && is_json($row['member_cert_province']) ? json_decode($row['member_cert_province']) : '',
  62. 'member_cert_addr' => $row['member_cert_addr'],
  63. 'member_cert_face' => !empty($row['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_face'] : '',
  64. 'member_cert_photo' => !empty($row['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_photo'] : '',
  65. 'member_cert_nation' => $row['member_cert_nation'],
  66. ];
  67. $account = [];
  68. if (!empty($row['account'])) {
  69. foreach ($row['account'] as $item) {
  70. if ($item['member_account_classify'] == 'POINTS') {
  71. $account['points'] = [
  72. 'member_account_name' => $item['member_account_name'],
  73. 'member_account_income' => $item['member_account_income'],
  74. 'member_account_expend' => $item['member_account_expend'],
  75. 'member_account_surplus' => $item['member_account_surplus'],
  76. 'member_account_added' => $item['member_account_added'],
  77. ];
  78. } else if ($item['member_account_classify'] == 'CASH') {
  79. $account['cash'] = [
  80. 'member_account_name' => $item['member_account_name'],
  81. 'member_account_income' => $item['member_account_income'],
  82. 'member_account_expend' => $item['member_account_expend'],
  83. 'member_account_surplus' => $item['member_account_surplus'],
  84. 'member_account_added' => $item['member_account_added'],
  85. ];
  86. } else if ($item['member_account_classify'] == 'CARD') {
  87. $account['card'] = [
  88. 'member_account_name' => $item['member_account_name'],
  89. 'member_account_income' => $item['member_account_income'],
  90. 'member_account_expend' => $item['member_account_expend'],
  91. 'member_account_surplus' => $item['member_account_surplus'],
  92. 'member_account_added' => $item['member_account_added'],
  93. ];
  94. }
  95. }
  96. }
  97. $row['account'] = $account;
  98. $row['is_auth'] = "未认证";
  99. if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
  100. $row['is_auth'] = "已认证";
  101. }
  102. $row['source'] = "APP";
  103. if (!empty($row['member_extend_json'])) {
  104. $extendJson = json_decode($row['member_extend_json'], true);
  105. if (isset($extendJson['come_from'])) {
  106. $row['source'] = $extendJson['come_from'] ?? '';
  107. }
  108. }
  109. }
  110. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  111. }
  112. public static function info($memberId)
  113. {
  114. $member = Member::with('cert')
  115. ->where('member_id', $memberId)
  116. ->first();
  117. return json_success('', $member);
  118. }
  119. public static function balanceInfo(Request $request)
  120. {
  121. $memberId = $request->get('member_id', '');
  122. $page = $request->get('page', 1);
  123. $pageSize = $request->get('pageSize', 20);
  124. $account = MemberAccount::where('join_account_member_id', $memberId)
  125. ->where('member_account_classify', 'CASH')
  126. ->first();
  127. $balance = $account->member_account_surplus + $account->member_account_added;
  128. $info = PayDetail::where(function ($query) use ($memberId) {
  129. $query->where('join_pay_member_id', $memberId)
  130. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  131. ->where('pay_category', 'RECHARGE')
  132. ->where('pay_status', 'SUCCESS');
  133. })->orWhere(function ($query) use ($memberId) {
  134. $query->where('join_pay_member_id', $memberId)
  135. ->whereNotIn('pay_prepayid', ['W06', 'A01'])
  136. ->where('pay_category', '<>', 'RECHARGE')
  137. ->where('pay_status', 'SUCCESS');
  138. })->orderByDesc('pay_addtimes')
  139. ->get()
  140. ->toArray();
  141. $data = [];
  142. foreach ($info as $key => $item) {
  143. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  144. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  145. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  146. $categoryName = [];
  147. foreach ($categoryIds as $id) {
  148. $category = SysCategory::where('category_id', $id)->first();
  149. if (!empty($category->category_super_path)) {
  150. $path = explode('#', $category->category_super_path);
  151. $ids = array_filter($path);
  152. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  153. } else {
  154. $categoryName[] = $category->category_name;
  155. }
  156. }
  157. $item['goods_category'] = implode(',', $categoryName);
  158. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  159. $item['balance_type'] = 'add';
  160. } else {
  161. $item['balance_type'] = 'cut';
  162. }
  163. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  164. if (!empty($item['pay_extend_json'])) {
  165. $extendJson = json_decode($item['pay_extend_json'], true);
  166. if (!isset($extendJson['added_amount'])) {
  167. $extendJson['added_amount'] = 0;
  168. }
  169. // 计划任务还没跑
  170. if ($item['pay_category'] == 'RECHARGE' && (!isset($extendJson['notify']) || $extendJson['notify'] != 'success')) {
  171. continue;
  172. }
  173. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  174. $data[] = [
  175. 'join_pay_member_id' => $item['join_pay_member_id'],
  176. 'pay_addtimes' => $item['pay_addtimes'],
  177. 'pay_amount' => $extendJson['added_amount'],
  178. 'pay_category' => 'ADDED',
  179. 'balance' => number_format($balance, 2, '.', ''),
  180. 'balance_type' => 'add',
  181. ];
  182. }
  183. $balance = $balance - $extendJson['added_amount'];
  184. }
  185. $item['balance'] = number_format($balance, 2, '.', '');
  186. $balance = $balance - $item['pay_amount'];
  187. $data[] = $item;
  188. continue;
  189. }
  190. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  191. if (!empty($item['pay_extend_json'])) {
  192. $extendJson = json_decode($item['pay_extend_json'], true);
  193. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  194. $data[] = [
  195. 'join_pay_member_id' => $item['join_pay_member_id'],
  196. 'pay_addtimes' => $item['pay_addtimes'],
  197. 'pay_amount' => $extendJson['added_amount'],
  198. 'pay_category' => 'ADDED',
  199. 'balance' => number_format($balance, 2, '.', ''),
  200. 'balance_type' => 'add',
  201. ];
  202. $balance = $balance - $extendJson['added_amount'];
  203. }
  204. }
  205. $item['balance'] = number_format($balance, 2, '.', '');
  206. $balance = $balance - $item['pay_amount'];
  207. } else {
  208. $item['balance'] = number_format($balance, 2, '.', '');
  209. $balance = $balance + $item['pay_amount'];
  210. }
  211. $data[] = $item;
  212. }
  213. $total = count($data);
  214. $start = ($page-1)*$pageSize;
  215. $rows = array_slice($data,$start,$pageSize);
  216. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  217. }
  218. public static function pointInfo($memberId)
  219. {
  220. $account = MemberAccount::where('join_account_member_id', $memberId)
  221. ->where('member_account_classify', 'POINTS')
  222. ->first();
  223. $balance = $account->member_account_surplus + $account->member_account_added;
  224. $points = ClientPoints::where('join_client_points_member_id', $memberId)->get()->toArray();
  225. $nowPoint = 0;
  226. foreach ($points as $key => &$point) {
  227. $point['goods_category'] = '其他';
  228. if (!empty($point['join_client_points_goods_id'])) {
  229. $categoryId = Goods::where('goods_id', $point['join_client_points_goods_id'])->pluck('join_goods_category_id');
  230. $category = SysCategory::where('category_id', $categoryId)->first();
  231. if (!empty($category->category_super_path)) {
  232. $path = explode('#', $category->category_super_path);
  233. $ids = array_filter($path);
  234. $point['goods_category'] = SysCategory::where('category_id', current($ids))->value('category_name');
  235. } else {
  236. $point['goods_category'] = $category->category_name;
  237. }
  238. }
  239. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送"])) {
  240. $point['balance_type'] = 'add';
  241. } else {
  242. $point['balance_type'] = 'cut';
  243. }
  244. if ($key == 0) {
  245. $point['balance'] = number_format($balance, 2, '.', '');
  246. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送"])) {
  247. $balance = $balance - $point['client_points_nbr'];
  248. } else {
  249. $balance = $balance + $point['client_points_nbr'];
  250. }
  251. continue;
  252. }
  253. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送"])) {
  254. $point['balance'] = number_format($balance, 2, '.', '');
  255. $balance = $balance - $point['client_points_nbr'];
  256. // $point['balance'] = $balance = $nowPoint = number_format($balance - $point['client_points_nbr'], 2, '.', '');
  257. } else {
  258. $point['balance'] = number_format($balance, 2, '.', '');
  259. $balance = $balance + $point['client_points_nbr'];
  260. // $point['balance'] = $balance = $nowPoint = number_format($balance + $point['client_points_nbr'], 2, '.', '');
  261. }
  262. }
  263. return json_success('', $points);
  264. }
  265. /**
  266. * @Desc 添加会员
  267. * @Author Gorden
  268. * @Date 2024/3/25 13:40
  269. *
  270. * @param $params
  271. * @return \support\Response
  272. */
  273. public static function add($params)
  274. {
  275. Db::beginTransaction();
  276. try {
  277. $memberId = self::generateMemberId();
  278. // 先写主表,要ID
  279. $memberData = [
  280. 'member_id' => $memberId,
  281. 'member_is_owner' => $params['is_owner'],
  282. 'member_classify' => $params['classify'],
  283. 'member_status' => $params['status'],
  284. 'member_mobile' => $params['mobile'],
  285. // 'member_from' => $params['source'],
  286. 'member_extend_json' => json_encode(['come_from' => $params['source']]),
  287. 'member_addtimes' => time(),
  288. ];
  289. Member::insert($memberData);
  290. // 账户表
  291. $accountData = [
  292. 'join_account_member_id' => $memberId,
  293. 'member_account_classify' => 'POINTS',
  294. 'member_account_status' => 'ACTIVED',
  295. 'member_account_category' => 'NORMAL',
  296. 'member_account_nbr' => $memberId . '-POINTS',
  297. 'member_account_name' => '积分账户',
  298. 'member_account_addtimes' => time()
  299. ];
  300. // 积分账户
  301. MemberAccount::insert($accountData);
  302. $accountData['member_account_classify'] = 'CASH';
  303. $accountData['member_account_nbr'] = $memberId . '-CASH';
  304. $accountData['member_account_name'] = '余额账户';
  305. // 现金/余额账户
  306. MemberAccount::insert($accountData);
  307. // member cert
  308. $certData = [
  309. 'join_cert_member_id' => $memberId,
  310. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  311. 'member_cert_name' => $params['cert_name'] ?? '',
  312. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  313. 'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  314. 'member_cert_gender' => $params['gender'] ?? '',
  315. 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  316. 'member_cert_city' => $params['city'] ?? '',
  317. 'member_cert_addr' => $params['addr'] ?? '',
  318. // 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  319. // 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  320. ];
  321. MemberCert::insert($certData);
  322. // member info
  323. $infoData = [
  324. 'join_info_member_id' => $memberId,
  325. 'member_info_nickname' => $params['account_name'],
  326. 'member_info_headimg' => getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar'])
  327. ];
  328. MemberInfo::insert($infoData);
  329. Db::commit();
  330. } catch (\Exception $e) {
  331. Db::rollBack();
  332. dump($e->getMessage() . ';line:' . $e->getLine());
  333. return json_fail("数据添加失败");
  334. }
  335. return json_success('数据添加成功');
  336. }
  337. /**
  338. * @Desc 编辑会员/ 业主
  339. * @Author Gorden
  340. * @Date 2024/4/20 15:18
  341. *
  342. * @param $params
  343. * @return \support\Response
  344. */
  345. public static function update($params)
  346. {
  347. Db::beginTransaction();
  348. try {
  349. $memberId = $params['member_id'];
  350. $member = Member::where('member_id', $params['member_id'])->first();
  351. if (!$member) {
  352. return json_fail("暂无数据");
  353. }
  354. $extendJson = [];
  355. if (!empty($member->member_extend_json)) {
  356. $extendJson = json_decode($member->member_extend_json, true);
  357. }
  358. $extendJson['come_from'] = $params['source'];
  359. // 先写主表,要ID
  360. $memberData = [
  361. 'member_id' => $memberId,
  362. 'member_is_owner' => $params['is_owner'],
  363. 'member_classify' => $params['classify'],
  364. 'member_status' => $params['status'],
  365. 'member_mobile' => $params['mobile'],
  366. // 'member_from' => $params['source'],
  367. 'member_extend_json' => json_encode($extendJson)
  368. ];
  369. Member::where('member_id', $params['member_id'])->update($memberData);
  370. // member cert
  371. $certData = [
  372. 'join_cert_member_id' => $memberId,
  373. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  374. 'member_cert_name' => $params['cert_name'] ?? '',
  375. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  376. 'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  377. 'member_cert_gender' => $params['gender'] ?? '',
  378. 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  379. 'member_cert_city' => $params['city'] ?? '',
  380. 'member_cert_addr' => $params['addr'] ?? '',
  381. 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  382. 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  383. ];
  384. if (!MemberCert::where('join_cert_member_id', $memberId)->exists()) {
  385. MemberCert::insert($certData);
  386. } else {
  387. MemberCert::where('join_cert_member_id', $params['member_id'])->update($certData);
  388. }
  389. // member info
  390. if (strpos($params['avatar'], getenv('APP_IMAGE_DOMAIN')) !== false || strpos($params['avatar'], getenv('SYSTEM_AVATAR_DOMAIN')) !== false) {
  391. $avatar = $params['avatar'];
  392. } else {
  393. $avatar = getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']);
  394. }
  395. $infoData = [
  396. 'join_info_member_id' => $memberId,
  397. 'member_info_nickname' => $params['account_name'],
  398. 'member_info_headimg' => $avatar
  399. ];
  400. if (!MemberInfo::where('join_info_member_id', $params['member_id'])->exists()) {
  401. MemberInfo::insert($infoData);
  402. } else {
  403. MemberInfo::where('join_info_member_id', $params['member_id'])->update($infoData);
  404. }
  405. Db::commit();
  406. } catch (\Exception $e) {
  407. Db::rollBack();
  408. dump($e->getMessage() . ';line:' . $e->getLine());
  409. return json_fail("数据更新失败");
  410. }
  411. return json_success('数据更新成功');
  412. }
  413. /**
  414. * @Desc 会员关联设备列表
  415. * @Author Gorden
  416. * @Date 2024/4/7 9:52
  417. *
  418. * @param $id
  419. * @return \support\Response
  420. */
  421. public static function deviceList($id)
  422. {
  423. $family = Family::where('join_family_creator_member_id', $id)->get()->toArray();
  424. $familyMemberIds = '';
  425. if ($family) {
  426. $familyIds = array_column($family, 'family_id');
  427. $familyMember = FamilyMember::whereIn('join_family_id', $familyIds)->get()->toArray();
  428. $familyMemberIds = array_column($familyMember, 'join_family_member_id');
  429. }
  430. $rows = MemberDevice::leftJoin('device', 'device.device_id', '=', 'member_device.join_member_device_id')
  431. ->leftJoin('member', 'member.member_id', '=', 'member_device.join_device_member_id')
  432. ->leftJoin('family_member', 'family_member.join_family_member_id', '=', 'member_device.join_device_member_id')
  433. ->select('device.device_category', 'device.device_name', 'device.device_type', 'member.member_mobile', 'member_device.*', 'family_member.family_member_name')
  434. ->when(!empty($familyMemberIds), function ($query) use ($familyMemberIds) {
  435. $query->whereIn('member_device.join_device_master_member_id', $familyMemberIds);
  436. })
  437. ->when(empty($familyMemberIds), function ($query) use ($id) {
  438. $query->where('member_device.join_device_master_member_id', $id);
  439. })->orderBy('member_device_addtimes', 'desc')
  440. ->get()
  441. ->toArray();
  442. return json_success('', ['rows' => $rows]);
  443. }
  444. /**
  445. * @Desc 绑定设备
  446. * @Author Gorden
  447. * @Date 2024/4/7 10:27
  448. *
  449. * @param Request $request
  450. * @return \support\Response
  451. */
  452. public static function addDevice(Request $request)
  453. {
  454. $params = $request->post();
  455. Db::beginTransaction();
  456. try {
  457. $data = [
  458. 'join_device_member_id' => $params['join_device_member_id'] ?? '',
  459. 'join_device_master_member_id' => $params['join_device_master_member_id'],
  460. 'join_member_device_id' => $params['join_member_device_id'],
  461. 'member_device_status' => $params['member_device_status'],
  462. 'member_device_key' => $params['member_device_key'] ?? '',
  463. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  464. 'member_device_remark' => $params['member_device_remark'] ?? null,
  465. 'member_device_addtimes' => time(),
  466. ];
  467. MemberDevice::insert($data);
  468. $device = Device::where('device_id', $params['join_member_device_id'])->whereIn('device_status', ['PROCESSING', 'PENDING'])->first();
  469. // 激活设备
  470. if (!$device) {
  471. Db::rollBack();
  472. return json_fail('当前设备不是可激活状态');
  473. }
  474. $device->device_status = 'ACTIVED';
  475. $device->save();
  476. Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => 'ACTIVED']);
  477. _syslog("绑定设备", "用户【" . ($params['join_device_member_id'] ?? $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  478. Db::commit();
  479. } catch (\Exception $e) {
  480. Db::rollBack();
  481. dump($e->getMessage());
  482. return json_fail('绑定失败');
  483. }
  484. return json_success('绑定成功');
  485. }
  486. public static function updateDevice(Request $request)
  487. {
  488. $params = $request->post();
  489. Db::beginTransaction();
  490. try {
  491. $data = [
  492. 'member_device_status' => $params['member_device_status'],
  493. 'member_device_key' => $params['member_device_key'],
  494. 'join_device_member_id' => $params['join_device_member_id'],
  495. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  496. 'member_device_remark' => $params['member_device_remark'] ?? null,
  497. ];
  498. MemberDevice::where('member_device_id', $request->post('member_device_id'))->update($data);
  499. $device = Device::where('device_id', $params['join_member_device_id'])->first();
  500. if ($device->device_status != $params['member_device_status']) {
  501. $device->device_status = $params['member_device_status'];
  502. $device->save();
  503. }
  504. // Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => $params['member_device_status']]);
  505. Db::commit();
  506. _syslog("更新绑定设备", "用户【" . ($params['join_device_member_id'] == "" ? $params['join_device_member_id'] : $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  507. } catch (\Exception $e) {
  508. Db::rollBack();
  509. dump($e->getMessage());
  510. return json_fail('绑定更新失败');
  511. }
  512. return json_success('绑定更新成功');
  513. }
  514. public static function deleteDevice(Request $request)
  515. {
  516. try {
  517. Db::beginTransaction();
  518. $memberDevice = MemberDevice::where('member_device_id', $request->post('member_device_id'))->first();
  519. if (!$memberDevice) {
  520. return json_fail('数据不存在');
  521. }
  522. $device = Device::where('device_id', $memberDevice->join_member_device_id)->first();
  523. $device->device_status = "DISABLED";
  524. $device->save();
  525. // Device::where('device_id', $memberDevice->join_member_device_id)->update(['device_status' => 'DISABLED']);
  526. $memberDevice->delete();
  527. Db::commit();
  528. _syslog("解除绑定设备", "用户【" . ($memberDevice->join_device_member_id == "" ? $memberDevice->join_device_member_id : $memberDevice->join_device_master_member_id) . '】,解除绑定设备【' . $device->device_name . '】');
  529. return json_success('解除绑定成功');
  530. } catch (\Exception $e) {
  531. Db::rollBack();
  532. return json_fail('绑定失败');
  533. }
  534. }
  535. private static function generateMemberId()
  536. {
  537. $id = SysSerial::getSerial();
  538. return "ME" . str_pad($id, 16, "0", STR_PAD_LEFT) . random_string(6, 'up');
  539. }
  540. }