MemberController.php 51 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323
  1. <?php
  2. namespace app\admin\controller\member;
  3. use app\admin\service\member\MemberService;
  4. use app\admin\service\notify\RechargeService;
  5. use app\admin\service\order\OrderService;
  6. use app\admin\validate\member\MemberValidate;
  7. use app\model\Coupon;
  8. use app\model\CouponDetail;
  9. use app\model\Family;
  10. use app\model\FamilyMember;
  11. use app\model\Member;
  12. use app\model\MemberAccount;
  13. use app\model\MemberBenefit;
  14. use app\model\MemberQuota;
  15. use app\model\MemberRole;
  16. use app\model\Order;
  17. use app\model\OrderReturn;
  18. use app\model\OrderSheet;
  19. use app\model\PayDetail;
  20. use support\Db;
  21. use support\exception\BusinessException;
  22. use support\Log;
  23. use support\Request;
  24. use Tinywan\Jwt\JwtToken;
  25. use function _PHPStan_cc8d35ffb\RingCentral\Psr7\str;
  26. class MemberController
  27. {
  28. public function selectList(Request $request)
  29. {
  30. $keywords = $request->get('keywords');
  31. $isOwner = $request->get('member_is_owner', 'N');
  32. if (!$keywords) {
  33. return json_fail("查询错误");
  34. }
  35. $res = Db::table('member')
  36. ->leftjoin('member_cert', 'member.member_id', '=', 'member_cert.join_cert_member_id')
  37. ->leftjoin('member_info', 'member.member_id', '=', 'member_info.join_info_member_id')
  38. ->select('member.member_id', 'member.member_mobile', 'member_cert.member_cert_name', 'member_info.member_info_nickname')
  39. ->where('member.member_is_owner', $isOwner)
  40. ->where('member_status', 'ACTIVED')
  41. // ->where('member_mobile','<>','0000')
  42. ->where(function ($query) use ($keywords) {
  43. $query->where('member.member_mobile', 'like', '%' . $keywords . '%')
  44. ->orWhere("member.member_id", 'like', '%' . $keywords . '%')
  45. ->orWhere("member_cert.member_cert_name", 'like', '%' . $keywords . '%')
  46. ->orWhere("member_info.member_info_nickname", 'like', '%' . $keywords . '%');
  47. })->get();
  48. $data = [];
  49. foreach ($res as $item) {
  50. // $item->member_mobile = substr($item->member_mobile,0,3).'****'.substr($item->member_mobile,7);
  51. $name = '';
  52. if (!empty($item->member_cert_name)) {
  53. $name = $item->member_cert_name;
  54. } else if (!empty($item->member_info_nickname)) {
  55. $name = $item->member_info_nickname;
  56. }
  57. $value = !empty($name) ? $name . '-' : '';
  58. if ($item->member_mobile != '0000') {
  59. $value .= $item->member_mobile;
  60. }
  61. if (empty($value)) {
  62. $value = $item->member_mobile;
  63. }
  64. $value = rtrim($value, '-');
  65. $data[] = [
  66. 'key' => $item->member_id,
  67. 'value' => $value,
  68. ];
  69. }
  70. return json_success('', $data);
  71. }
  72. public function exportMember(Request $request)
  73. {
  74. return MemberService::exportMember($request);
  75. }
  76. public function selectWriteOffMember()
  77. {
  78. $members = Member::with([
  79. 'cert' => function ($query) {
  80. $query->select('join_cert_member_id', 'member_cert_name');
  81. }
  82. ])->whereRaw("JSON_EXTRACT(`member_json`, '$.user') IS NOT NULL")
  83. ->select('member_id', 'member_mobile', 'member_json')
  84. ->get()
  85. ->toArray();
  86. foreach ($members as &$member) {
  87. // $member['member_mobile'] = substr($member['member_mobile'],0,3).'****'.substr($member['member_mobile'],7);
  88. $member['member_json'] = json_decode($member['member_json'], true);
  89. $member['username'] = $member['member_mobile'];
  90. $member['user_id'] = $member['member_json']['user'] ? $member['member_json']['user']['user_id'] : '';
  91. if (isset($member['cert']['member_cert_name'])) {
  92. $member['username'] = $member['cert']['member_cert_name'] . '-' . $member['username'];
  93. }
  94. }
  95. return json_success('', $members);
  96. }
  97. public function selectFamilyMemberList(Request $request)
  98. {
  99. $keywords = $request->get('keywords');
  100. if (!$keywords) {
  101. return json_fail("查询错误");
  102. }
  103. // 创建的家庭
  104. $family = Family::where('join_family_creator_member_id', $request->get('memberId'))->get()->toArray();
  105. if (!$family) {
  106. return json_success('暂无数据');
  107. }
  108. $familyIds = array_column($family, 'family_id');
  109. $res = FamilyMember::whereIn('join_family_id', $familyIds)
  110. ->where("family_member_name", 'like', '%' . $keywords . '%')
  111. ->get()
  112. ->toArray();
  113. $data = [];
  114. foreach ($res as $item) {
  115. $data[] = [
  116. 'key' => $item['join_family_member_id'],
  117. 'value' => $item['family_member_name']
  118. ];
  119. }
  120. return json_success('', $data);
  121. }
  122. public function selectMemberAllQuota(Request $request)
  123. {
  124. $memberId = $request->get('member_id', '');
  125. $orderId = $request->get('order_id', '');
  126. $goodsId = $request->get('goods_id', '');
  127. $person = $request->get('person', '');
  128. $selectType = $request->get('select_type', 'ALL');
  129. if (!$memberId) {
  130. return json_fail('参数异常');
  131. }
  132. $data = [];
  133. $benefit = MemberBenefit::where('join_benefit_member_id', $memberId)
  134. ->whereColumn('member_benefit_limit_count', '>', 'member_benefit_used_count')
  135. ->select('member_benefit_id as id', 'member_benefit_name as name', 'member_benefit_limit_count as total', 'member_benefit_used_count as used')
  136. ->when($orderId != '', function ($query) use ($orderId) {
  137. $query->where('join_benefit_order_id', $orderId);
  138. })->when($goodsId != '', function ($query) use ($goodsId) {
  139. $query->where('join_benefit_goods_id', $goodsId);
  140. })
  141. ->get()
  142. ->toArray();
  143. foreach ($benefit as $item) {
  144. if ($item['total'] - $item['used'] < $person) {
  145. $item['disabled'] = true;
  146. }
  147. $item['cut'] = $item['total'] - $item['used'];
  148. $data[] = $item;
  149. }
  150. if ($selectType == 'BENEFIT') {
  151. return json_success('', $data);
  152. }
  153. $quotas = MemberQuota::where('join_quota_member_id', $memberId)
  154. ->when($goodsId != '', function ($query) use ($goodsId) {
  155. $query->whereJsonContains('member_quota_json', ['goods_id' => $goodsId]);
  156. })
  157. ->selectRaw('join_quota_member_id,join_member_rule_added_component_id,COUNT(*) as total')
  158. ->groupBy('join_quota_member_id', 'join_member_rule_added_component_id')
  159. ->get()
  160. ->toArray();
  161. foreach ($quotas as $quota) {
  162. $usedNum = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  163. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  164. ->where('member_quota_status', 'USED')
  165. ->count('*');
  166. if ($quota['total'] <= $usedNum) {
  167. continue;
  168. }
  169. $memberQuota = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  170. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  171. ->select('member_quota_id as id', 'member_quota_name as name')
  172. ->first()
  173. ->toArray();
  174. $memberQuota['total'] = $quota['total'];
  175. $memberQuota['used'] = $usedNum;
  176. if ($memberQuota['total'] - $memberQuota['used'] < $person) {
  177. $memberQuota['disabled'] = true;
  178. }
  179. $memberQuota['cut'] = $memberQuota['total'] - $memberQuota['used'];
  180. $data[] = $memberQuota;
  181. }
  182. if ($selectType == 'QUOTA') {
  183. return json_success('', $data);
  184. }
  185. return json_success('', $data);
  186. }
  187. /**
  188. * 预约核销用
  189. */
  190. public function selectMemberAllQuotaByAppointment(Request $request)
  191. {
  192. $memberId = $request->get('member_id', '');
  193. $orderId = $request->get('order_id', '');
  194. $goodsId = $request->get('goods_id', '');
  195. $person = $request->get('person', '');
  196. $selectType = $request->get('select_type', 'ALL');
  197. if (!$memberId) {
  198. return json_fail('参数异常');
  199. }
  200. $data = [];
  201. $benefit = MemberBenefit::where('join_benefit_member_id', $memberId)
  202. ->whereColumn('member_benefit_limit_count', '>', 'member_benefit_used_count')
  203. ->select('member_benefit_id as id', 'member_benefit_name as name', 'member_benefit_limit_count as total', 'member_benefit_used_count as used')
  204. ->when($orderId != '', function ($query) use ($orderId) {
  205. $query->where('join_benefit_order_id', $orderId);
  206. })->when($goodsId != '', function ($query) use ($goodsId) {
  207. $query->where('join_benefit_goods_id', $goodsId);
  208. })
  209. ->get()
  210. ->toArray();
  211. $data['benefit'] = [];
  212. foreach ($benefit as $item) {
  213. $item['benefit']['cut'] = $item['total'] - $item['used'];
  214. $data['benefit']['name'] = $item['name'];
  215. $data['benefit']['cut'] += $item['cut'];
  216. $data['benefit']['id'][] = $item['id'];
  217. }
  218. if ($selectType == 'BENEFIT') {
  219. return json_success('', $data);
  220. }
  221. $quotas = MemberQuota::where('join_quota_member_id', $memberId)
  222. ->when($goodsId != '', function ($query) use ($goodsId) {
  223. $query->whereJsonContains('member_quota_json', ['goods_id' => $goodsId]);
  224. })
  225. ->selectRaw('join_quota_member_id,join_member_rule_added_component_id,COUNT(*) as total')
  226. ->groupBy('join_quota_member_id', 'join_member_rule_added_component_id')
  227. ->get()
  228. ->toArray();
  229. $data['quota'] = [];
  230. foreach ($quotas as $quota) {
  231. $usedNum = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  232. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  233. ->where('member_quota_status', 'USED')
  234. ->count('*');
  235. if ($quota['total'] <= $usedNum) {
  236. continue;
  237. }
  238. $memberQuota = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  239. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  240. ->select('member_quota_id as id', 'member_quota_name as name')
  241. ->first()
  242. ->toArray();
  243. $memberQuota['total'] = $quota['total'];
  244. $memberQuota['used'] = $usedNum;
  245. if ($memberQuota['total'] - $memberQuota['used'] < $person) {
  246. $memberQuota['disabled'] = true;
  247. }
  248. $memberQuota['cut'] = $memberQuota['total'] - $memberQuota['used'];
  249. $data['quota']['name'] = $memberQuota['name'];
  250. $data['quota']['cut'] += $memberQuota['cut'];
  251. $data['quota']['id'][] = $memberQuota['id'];
  252. // $data[] = $memberQuota;
  253. }
  254. if ($selectType == 'QUOTA') {
  255. return json_success('', $data);
  256. }
  257. return json_success('', $data);
  258. }
  259. public function selectMemberAllQuotaByGoods(Request $request)
  260. {
  261. $memberId = $request->get('member_id', '');
  262. $orderId = $request->get('order_id', '');
  263. $person = $request->get('person', '');
  264. $selectType = $request->get('select_type', 'ALL');
  265. if (!$memberId) {
  266. return json_fail('参数异常');
  267. }
  268. $data = [];
  269. $benefit = MemberBenefit::where('join_benefit_member_id', $memberId)
  270. // ->whereColumn('member_benefit_limit_count','>','member_benefit_used_count')
  271. ->select('member_benefit_id as id', 'member_benefit_name as name', 'member_benefit_limit_count as total', 'member_benefit_used_count as used')
  272. ->when($orderId != '', function ($query) use ($orderId) {
  273. $query->where('join_benefit_order_id', $orderId);
  274. })
  275. ->get()
  276. ->toArray();
  277. foreach ($benefit as $item) {
  278. if ($item['total'] - $item['used'] < $person) {
  279. $item['disabled'] = true;
  280. }
  281. $item['cut'] = $item['total'] - $item['used'];
  282. $data[] = $item;
  283. }
  284. if ($selectType == 'BENEFIT') {
  285. return json_success('', $data);
  286. }
  287. $quotas = MemberQuota::where('join_quota_member_id', $memberId)
  288. ->selectRaw('join_quota_member_id,join_member_rule_added_component_id,COUNT(*) as total')
  289. ->groupBy('join_quota_member_id', 'join_member_rule_added_component_id')
  290. ->get()
  291. ->toArray();
  292. foreach ($quotas as $quota) {
  293. $usedNum = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  294. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  295. ->where('member_quota_status', 'USED')
  296. ->count('*');
  297. if ($quota['total'] <= $usedNum) {
  298. continue;
  299. }
  300. $memberQuota = MemberQuota::where('join_quota_member_id', $quota['join_quota_member_id'])
  301. ->where('join_member_rule_added_component_id', $quota['join_member_rule_added_component_id'])
  302. ->select('member_quota_id as id', 'member_quota_name as name')
  303. ->first()
  304. ->toArray();
  305. $memberQuota['total'] = $quota['total'];
  306. $memberQuota['used'] = $usedNum;
  307. if ($memberQuota['total'] - $memberQuota['used'] < $person) {
  308. $memberQuota['disabled'] = true;
  309. }
  310. $memberQuota['cut'] = $memberQuota['total'] - $memberQuota['used'];
  311. $data[] = $memberQuota;
  312. }
  313. if ($selectType == 'QUOTA') {
  314. return json_success('', $data);
  315. }
  316. return json_success('', $data);
  317. }
  318. public function list(Request $request)
  319. {
  320. return MemberService::list($request);
  321. }
  322. public function info(Request $request)
  323. {
  324. $memberId = $request->get('member_id', '');
  325. if (!$memberId) {
  326. return json_fail("参数错误");
  327. }
  328. return MemberService::info($memberId);
  329. }
  330. public function vipInfo(Request $request)
  331. {
  332. $memberId = $request->get('member_id', '');
  333. if (!$memberId) {
  334. return json_fail("参数错误");
  335. }
  336. return MemberService::vipInfo($request);
  337. }
  338. public function welfareInfo(Request $request)
  339. {
  340. $memberId = $request->get('member_id');
  341. if (!$memberId) {
  342. return json_fail("参数错误");
  343. }
  344. return MemberService::welfareInfo($request);
  345. }
  346. public function commissionList(Request $request)
  347. {
  348. $memberId = $request->get('member_id');
  349. if (!$memberId) {
  350. return json_fail("参数错误");
  351. }
  352. return MemberService::commissionList($request);
  353. }
  354. /**
  355. * @Desc 我的粉丝列表
  356. * @Author Gorden
  357. * @Date 2024/9/20 10:22
  358. *
  359. * @param Request $request
  360. * @return \support\Response
  361. */
  362. public function fansList(Request $request)
  363. {
  364. $memberId = $request->get('member_id');
  365. if (!$memberId) {
  366. return json_fail("参数错误");
  367. }
  368. return MemberService::fansList($request);
  369. }
  370. public function clearWelfare(Request $request)
  371. {
  372. $memberId = $request->post('member_id', '');
  373. if (!$memberId) {
  374. return json_fail("参数错误");
  375. }
  376. return MemberService::clearWelfare($request);
  377. }
  378. public function balanceInfo(Request $request)
  379. {
  380. $memberId = $request->get('member_id', '');
  381. if (!$memberId) {
  382. return json_fail("参数错误");
  383. }
  384. return MemberService::balanceInfo($request);
  385. }
  386. public function pointInfo(Request $request)
  387. {
  388. $memberId = $request->get('member_id', '');
  389. if (!$memberId) {
  390. return json_fail("参数错误");
  391. }
  392. return MemberService::pointInfo($memberId);
  393. }
  394. /**
  395. * @Desc 添加会员
  396. * @Author Gorden
  397. * @Date 2024/3/25 13:40
  398. *
  399. * @param Request $request
  400. * @return \support\Response
  401. */
  402. public function add(Request $request)
  403. {
  404. $validate = new MemberValidate();
  405. if (!$validate->scene('add')->check($request->post())) {
  406. return json_fail($validate->getError());
  407. }
  408. _syslog("添加用户", "用户【" . $request->post('member_cert_name') . '】');
  409. return MemberService::add($request->post());
  410. }
  411. public function update(Request $request)
  412. {
  413. $validate = new MemberValidate();
  414. if (!$validate->scene('update')->check($request->post())) {
  415. return json_fail($validate->getError());
  416. }
  417. _syslog("编辑用户", "用户【" . $request->post('member_cert_name') ?? $request->post('member_id') . '】');
  418. return MemberService::update($request->post());
  419. }
  420. /**
  421. * @Desc 绑定的设备
  422. * @Author Gorden
  423. * @Date 2024/4/7 10:20
  424. *
  425. * @param $id
  426. * @return \support\Response
  427. */
  428. public function device($id)
  429. {
  430. return MemberService::deviceList($id);
  431. }
  432. public function addDevice(Request $request)
  433. {
  434. return MemberService::addDevice($request);
  435. }
  436. public function updateDevice(Request $request)
  437. {
  438. return MemberService::updateDevice($request);
  439. }
  440. public function deleteDevice(Request $request)
  441. {
  442. return MemberService::deleteDevice($request);
  443. }
  444. /**
  445. * @Desc 卡券数量
  446. * @Author Gorden
  447. * @Date 2024/8/22 18:51
  448. *
  449. * @param Request $request
  450. * @return \support\Response
  451. */
  452. public function couponCount(Request $request)
  453. {
  454. $memberId = $request->get('member_id', '');
  455. $coupons = CouponDetail::leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
  456. ->where('join_coupon_detail_member_id', $memberId)
  457. ->select('coupon.coupon_name', 'coupon.coupon_classify', 'coupon.coupon_value')
  458. ->get()
  459. ->toArray();
  460. $data = ['manjian' => 0, 'diyong' => 0, 'zhekou' => 0, 'lijian' => 0, 'zengpin' => 0, 'fuli' => 0, 'nianka' => 0, 'jika' => 0, 'yueka' => 0];
  461. foreach ($coupons as $item) {
  462. if ($item['coupon_classify'] == '满减券') {
  463. $data['manjian'] += 1;
  464. } elseif ($item['coupon_classify'] == '抵用券') {
  465. $data['diyong'] += 1;
  466. } elseif ($item['coupon_classify'] == '折扣券') {
  467. $data['zhekou'] += 1;
  468. } elseif ($item['coupon_classify'] == '立减券') {
  469. $data['lijian'] += 1;
  470. } elseif ($item['coupon_classify'] == '赠品券') {
  471. $data['zengpin'] += 1;
  472. } elseif ($item['coupon_classify'] == '福利券') {
  473. $data['fuli'] += 1;
  474. } elseif ($item['coupon_classify'] == '年卡') {
  475. $data['nianka'] += 1;
  476. } elseif ($item['coupon_classify'] == '季卡') {
  477. $data['jika'] += 1;
  478. } elseif ($item['coupon_classify'] == '月卡') {
  479. $data['yueka'] += 1;
  480. }
  481. }
  482. $data['total'] = $data['manjian'] + $data['diyong'] + $data['zhekou'] + $data['lijian'] + $data['zengpin'] + $data['fuli'] + $data['nianka'] + $data['jika'] + $data['yueka'];
  483. return json_success('', $data);
  484. }
  485. /**
  486. * @Desc 我的卡券
  487. * @Author Gorden
  488. * @Date 2024/8/22 18:45
  489. *
  490. * @param Request $request
  491. * @return \support\Response
  492. */
  493. public function coupon(Request $request)
  494. {
  495. $memberId = $request->get('member_id', '');
  496. $classify = $request->get('classify', '');
  497. $page = $request->get('page', 1);
  498. $pageSize = $request->get('pageSize', 20);
  499. $coupons = CouponDetail::with([
  500. 'member' => function ($query) {
  501. $query->select('member_id', 'member_mobile');
  502. },
  503. 'cert' => function ($query) {
  504. $query->select('join_cert_member_id', 'member_cert_name');
  505. },
  506. 'info' => function ($query) {
  507. $query->select('join_info_member_id', 'member_info_nickname');
  508. }
  509. ])
  510. ->leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
  511. ->where('join_coupon_detail_member_id', $memberId)
  512. ->where('coupon.coupon_classify', $classify)
  513. ->groupBy('join_coupon_detail_member_id', 'join_detail_coupon_id');
  514. // $total = $coupons->count();
  515. $totalModel = Db::select("select count(a.join_detail_coupon_id) as total from (select join_detail_coupon_id from app_coupon_detail as d left join app_coupon as c ON d.join_detail_coupon_id = c.coupon_id where d.join_coupon_detail_member_id='" . $memberId . "' and c.coupon_classify='" . $classify . "' group by d.join_coupon_detail_member_id,d.join_detail_coupon_id) as a");
  516. $total = 0;
  517. if (!empty($totalModel) && !empty($totalModel[0])) {
  518. $total = $totalModel[0]->total;
  519. }
  520. $rows = $coupons->select('coupon_detail.join_coupon_detail_member_id', 'coupon_detail.join_detail_coupon_id'
  521. , 'coupon.coupon_name', 'coupon.coupon_classify', 'coupon.coupon_value')
  522. ->selectRaw('COUNT(1) as total,
  523. COUNT(IF(app_coupon_detail.coupon_detail_status="USED",1,NULL)) as used_total,
  524. COUNT(IF(app_coupon_detail.coupon_detail_status="ACTIVED" or app_coupon_detail.coupon_detail_status="WAITING",1,NULL)) as unused_total,
  525. MAX(app_coupon_detail.coupon_detail_deadline_datetime) as deadline_datetime')
  526. ->orderBy('deadline_datetime', 'DESC')
  527. ->forPage($page, $pageSize)
  528. ->get()
  529. ->toArray();
  530. foreach ($rows as &$item) {
  531. $mobile = $certName = $nickname = '';
  532. if (!empty($item['member']) && !empty($item['member']['member_mobile'])) {
  533. $mobile = $item['member']['member_mobile'];
  534. }
  535. if (!empty($item['cert']) && !empty($item['cert']['member_cert_name'])) {
  536. $certName = $item['cert']['member_cert_name'];
  537. }
  538. if (!empty($item['info']) && !empty($item['info']['member_info_nickname'])) {
  539. $nickname = $item['info']['member_info_nickname'];
  540. }
  541. $item['member_name'] = MemberService::getMemberName($mobile, $certName, $nickname);
  542. unset($item['member'], $item['cert'], $item['info']);
  543. $item['invalid_total'] = $item['total'] - $item['used_total'] - $item['unused_total'];
  544. // 优惠券分类
  545. $coupon = Coupon::with('category')->where('coupon_id', $item['join_detail_coupon_id'])
  546. ->select('coupon_id', 'join_coupon_category_id')
  547. ->first();
  548. if (!empty($coupon) && !empty($coupon->category)) {
  549. $item['category_name'] = $coupon->category->category_name;
  550. }
  551. }
  552. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  553. }
  554. /**
  555. * @Desc 我的卡券
  556. * @Author Gorden
  557. * @Date 2024/8/22 18:45
  558. *
  559. * @param Request $request
  560. * @return \support\Response
  561. */
  562. public function allCoupon(Request $request)
  563. {
  564. $memberId = $request->get('member_id', '');
  565. $page = $request->get('page', 1);
  566. $pageSize = $request->get('pageSize', 20);
  567. $coupons = CouponDetail::with([
  568. 'member' => function ($query) {
  569. $query->select('member_id', 'member_mobile');
  570. },
  571. 'cert' => function ($query) {
  572. $query->select('join_cert_member_id', 'member_cert_name');
  573. },
  574. 'info' => function ($query) {
  575. $query->select('join_info_member_id', 'member_info_nickname');
  576. }
  577. ])
  578. ->leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
  579. ->where('join_coupon_detail_member_id', $memberId)
  580. ->groupBy('join_coupon_detail_member_id', 'join_detail_coupon_id');
  581. // $total = $coupons->count();
  582. $totalModel = Db::select("select count(a.join_detail_coupon_id) as total from (select join_detail_coupon_id from app_coupon_detail as d left join app_coupon as c ON d.join_detail_coupon_id = c.coupon_id where d.join_coupon_detail_member_id='" . $memberId . "' group by d.join_coupon_detail_member_id,d.join_detail_coupon_id) as a");
  583. $total = 0;
  584. if (!empty($totalModel) && !empty($totalModel[0])) {
  585. $total = $totalModel[0]->total;
  586. }
  587. $rows = $coupons->select('coupon_detail.join_coupon_detail_member_id', 'coupon_detail.join_detail_coupon_id'
  588. , 'coupon.coupon_name', 'coupon.coupon_classify', 'coupon.coupon_value')
  589. ->selectRaw('COUNT(1) as total,
  590. COUNT(IF(app_coupon_detail.coupon_detail_status="USED",1,NULL)) as used_total,
  591. COUNT(IF(app_coupon_detail.coupon_detail_status="ACTIVED" or app_coupon_detail.coupon_detail_status="WAITING",1,NULL)) as unused_total,
  592. MAX(app_coupon_detail.coupon_detail_deadline_datetime) as deadline_datetime')
  593. ->orderBy('deadline_datetime', 'DESC')
  594. ->forPage($page, $pageSize)
  595. ->get()
  596. ->toArray();
  597. foreach ($rows as &$item) {
  598. $mobile = $certName = $nickname = '';
  599. if (!empty($item['member']) && !empty($item['member']['member_mobile'])) {
  600. $mobile = $item['member']['member_mobile'];
  601. }
  602. if (!empty($item['cert']) && !empty($item['cert']['member_cert_name'])) {
  603. $certName = $item['cert']['member_cert_name'];
  604. }
  605. if (!empty($item['info']) && !empty($item['info']['member_info_nickname'])) {
  606. $nickname = $item['info']['member_info_nickname'];
  607. }
  608. $item['member_name'] = MemberService::getMemberName($mobile, $certName, $nickname);
  609. unset($item['member'], $item['cert'], $item['info']);
  610. $item['invalid_total'] = $item['total'] - $item['used_total'] - $item['unused_total'];
  611. // 优惠券分类
  612. $coupon = Coupon::with('category')->where('coupon_id', $item['join_detail_coupon_id'])
  613. ->select('coupon_id', 'join_coupon_category_id')
  614. ->first();
  615. if (!empty($coupon) && !empty($coupon->category)) {
  616. $item['category_name'] = $coupon->category->category_name;
  617. }
  618. }
  619. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  620. }
  621. /**
  622. * @Desc 我的卡券 领取记录
  623. * @Author Gorden
  624. * @Date 2024/8/22 18:45
  625. *
  626. * @param Request $request
  627. * @return \support\Response
  628. */
  629. public function couponDetail(Request $request)
  630. {
  631. $memberId = $request->get('member_id', '');
  632. $couponId = $request->get('coupon_id', '');
  633. $page = $request->get('page', 1);
  634. $pageSize = $request->get('pageSize', 20);
  635. $coupons = CouponDetail::with([
  636. 'member' => function ($query) {
  637. $query->select('member_id', 'member_mobile');
  638. },
  639. 'cert' => function ($query) {
  640. $query->select('join_cert_member_id', 'member_cert_name');
  641. },
  642. 'info' => function ($query) {
  643. $query->select('join_info_member_id', 'member_info_nickname');
  644. }
  645. ])
  646. ->leftJoin('coupon', 'coupon.coupon_id', '=', 'coupon_detail.join_detail_coupon_id')
  647. ->where('join_coupon_detail_member_id', $memberId)
  648. ->where('coupon.coupon_id', $couponId);
  649. $total = $coupons->count();
  650. $rows = $coupons->select('coupon_detail.*', 'coupon.coupon_name', 'coupon.coupon_classify', 'coupon.coupon_value')
  651. ->orderBy('coupon_detail_deadline_datetime', 'desc')
  652. ->forPage($page, $pageSize)
  653. ->get()
  654. ->toArray();
  655. foreach ($rows as &$item) {
  656. $mobile = $certName = $nickname = '';
  657. if (!empty($item['member']) && !empty($item['member']['member_mobile'])) {
  658. $mobile = $item['member']['member_mobile'];
  659. }
  660. if (!empty($item['cert']) && !empty($item['cert']['member_cert_name'])) {
  661. $certName = $item['cert']['member_cert_name'];
  662. }
  663. if (!empty($item['info']) && !empty($item['info']['member_info_nickname'])) {
  664. $nickname = $item['info']['member_info_nickname'];
  665. }
  666. $item['member_name'] = MemberService::getMemberName($mobile, $certName, $nickname);
  667. unset($item['member'], $item['cert'], $item['info']);
  668. if (!empty($coupon) && !empty($coupon->category)) {
  669. $item['category_name'] = $coupon->category->category_name;
  670. }
  671. }
  672. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  673. }
  674. /**
  675. * @Desc 新会员充值备份记录
  676. * @Author Gorden
  677. * @Date 2024/10/15 10:27
  678. *
  679. * @param Request $request
  680. * @return \support\Response
  681. */
  682. public function rechargeBackupsList(Request $request)
  683. {
  684. $page = $request->get('page', 1);
  685. $pageSize = $request->get('pageSize', 20);
  686. $memberId = $request->get('member_id');
  687. if (!$memberId) {
  688. return json_fail("参数异常");
  689. }
  690. $member = Member::where('member_id', $memberId)
  691. ->select('member_id', 'member_extend_json')
  692. ->first();
  693. $data = [];
  694. if (!empty($member->member_extend_json)) {
  695. $extendJson = json_decode($member->member_extend_json, true);
  696. if (isset($extendJson['snap'])) {
  697. foreach ($extendJson['snap'] as $key => $item) {
  698. $data[] = [
  699. 'recharge_times' => $key,
  700. 'member_account_surplus' => $item['member_account_surplus'],
  701. 'member_account_added' => $item['member_account_added'],
  702. 'pay_amount' => $item['pay_amount'],
  703. 'added_rate' => floatval($item['added_rate']) * 100,
  704. 'added_amount' => $item['added_amount']
  705. ];
  706. }
  707. }
  708. }
  709. $total = count($data);
  710. $start = ($page - 1) * $pageSize;
  711. $rows = array_slice($data, $start, $pageSize);
  712. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  713. }
  714. /**
  715. * @Desc 会员权益使用记录
  716. * @Author Gorden
  717. * @Date 2024/10/15 11:13
  718. *
  719. * @param Request $request
  720. * @return \support\Response
  721. */
  722. public function roleBenefitUsedList(Request $request)
  723. {
  724. $page = $request->get('page', 1);
  725. $pageSize = $request->get('pageSize', 20);
  726. $memberId = $request->get('member_id');
  727. if (!$memberId) {
  728. return json_fail('参数异常');
  729. }
  730. $data = $this->getRoleBenefitUsedList($memberId);
  731. $total = count($data);
  732. $start = ($page - 1) * $pageSize;
  733. $rows = array_slice($data, $start, $pageSize);
  734. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  735. }
  736. public function consumptionList(Request $request)
  737. {
  738. $page = $request->get('page', 1);
  739. $pageSize = $request->get('pageSize', 20);
  740. $memberId = $request->get('member_id');
  741. if (!$memberId) {
  742. return json_fail('参数异常');
  743. }
  744. $member = Member::where('member_id', $memberId)->first();
  745. $firstRechargeTime = 0;
  746. if (!empty($member->member_extend_json)) {
  747. $memberExtendJson = json_decode($member->member_extend_json, true);
  748. if (isset($memberExtendJson['snap'])) {
  749. foreach ($memberExtendJson['snap'] as $key => $value) {
  750. $firstRechargeTime = strtotime($key);
  751. break;
  752. }
  753. }
  754. }
  755. $payDetailIds = PayDetail::where('pay_addtimes', '>', $firstRechargeTime)
  756. ->where('pay_prepayid', $memberId . '-CASH')
  757. ->where('pay_status', 'SUCCESS')
  758. ->pluck('join_pay_order_id')
  759. ->toArray();
  760. $orders = Order::with([
  761. 'payDetail' => function ($query) {
  762. $query->where('pay_prepayid', 'like', '%CASH%');
  763. }
  764. ])->whereIn('order_groupby', $payDetailIds)
  765. ->where('order_addtimes', '>', $firstRechargeTime)
  766. ->whereIn('order_classify',['GOODS','SERVICE','CHNMED','CHNNCD','PACKAGE','DISHES']);
  767. $total = $orders->count();
  768. $rows = $orders->orderBy('order_addtimes', 'DESC')
  769. ->forPage($page, $pageSize)
  770. ->get()
  771. ->toArray();
  772. $data = [];
  773. foreach ($rows as $row) {
  774. $sheets = OrderSheet::with([
  775. 'goods' => function ($query) {
  776. $query->select('goods_id', 'goods_name');
  777. }
  778. ])->where('join_sheet_order_id', $row['order_id'])
  779. ->get()
  780. ->toArray();
  781. $deng = "";
  782. if (count($sheets) > 1) {
  783. $deng = '等';
  784. }
  785. foreach ($row['pay_detail'] as $item) {
  786. if (!empty($item['join_pay_object_json'])) {
  787. $payObjectJson = json_decode($item['join_pay_object_json'], true);
  788. if ($payObjectJson['order_id'] != $row['order_id']) {
  789. continue;
  790. }
  791. }
  792. $data[] = [
  793. 'order_classify' => $row['order_classify'],
  794. 'order_id' => $row['order_id'],
  795. 'goods_name' => !empty($sheets[0]) && !empty($sheets[0]['goods']) ? ($sheets[0]['goods']['goods_name'] . $deng) : '',
  796. 'order_amount_total' => $row['order_amount_total'],
  797. 'order_amount_pay' => $row['order_amount_pay'],
  798. 'pay_paytimes' => $item['pay_paytimes'] ?? "",
  799. 'order_addtimes' => $row['order_addtimes'],
  800. 'pay_amount' => $item['pay_amount']
  801. ];
  802. }
  803. }
  804. $rows = $data;
  805. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  806. }
  807. /**
  808. * @Desc 消费导出
  809. * @Author Gorden
  810. * @Date 2024/10/15 17:36
  811. *
  812. * @param Request $request
  813. * @return \support\Response
  814. */
  815. public function exportConsumptionList(Request $request)
  816. {
  817. $memberId = $request->post('member_id');
  818. $orderIds = $request->post('order_id', []);
  819. if (!$memberId) {
  820. return json_fail('参数异常');
  821. }
  822. $member = Member::where('member_id', $memberId)->first();
  823. $firstRechargeTime = 0;
  824. if (!empty($member->member_extend_json)) {
  825. $memberExtendJson = json_decode($member->member_extend_json, true);
  826. if (isset($memberExtendJson['snap'])) {
  827. foreach ($memberExtendJson['snap'] as $key => $value) {
  828. $firstRechargeTime = strtotime($key);
  829. break;
  830. }
  831. }
  832. }
  833. if (empty($orderIds)) {
  834. $payDetailIds = PayDetail::where('pay_addtimes', '>', $firstRechargeTime)
  835. ->where('pay_prepayid', $memberId . '-CASH')
  836. ->where('pay_status', 'SUCCESS')
  837. ->pluck('join_pay_order_id')
  838. ->toArray();
  839. } else {
  840. $payDetailIds = Order::whereIn('order_id', $orderIds)->pluck('order_groupby')->toArray();
  841. }
  842. $rows = Order::with([
  843. 'payDetail' => function ($query) {
  844. $query->where('pay_prepayid', 'like', '%CASH%');
  845. }
  846. ])->whereIn('order_groupby', $payDetailIds)
  847. ->where('order_addtimes', '>', $firstRechargeTime)
  848. ->whereIn('order_classify',['GOODS','SERVICE','CHNMED','CHNNCD','PACKAGE','DISHES'])
  849. ->orderBy('order_addtimes', 'DESC')
  850. ->get()
  851. ->toArray();
  852. $data = [];
  853. $payAmount = 0;
  854. foreach ($rows as $row) {
  855. $sheets = OrderSheet::with([
  856. 'goods' => function ($query) {
  857. $query->select('goods_id', 'goods_name');
  858. }
  859. ])->where('join_sheet_order_id', $row['order_id'])
  860. ->get()
  861. ->toArray();
  862. $deng = "";
  863. if (count($sheets) > 1) {
  864. $deng = '等';
  865. }
  866. foreach ($row['pay_detail'] as $item) {
  867. if (!empty($item['join_pay_object_json'])) {
  868. $payObjectJson = json_decode($item['join_pay_object_json'], true);
  869. if ($payObjectJson['order_id'] != $row['order_id']) {
  870. continue;
  871. }
  872. }
  873. $payAmount += $item['pay_amount'];
  874. $data[] = [
  875. 'order_classify' => OrderService::$orderClassify[$row['order_classify']],
  876. 'order_id' => $row['order_id'],
  877. 'goods_name' => !empty($sheets[0]) && !empty($sheets[0]['goods']) ? ($sheets[0]['goods']['goods_name'] . $deng) : '',
  878. 'order_amount_total' => $row['order_amount_total'],
  879. 'order_amount_pay' => $row['order_amount_pay'],
  880. 'pay_paytimes' => $item['pay_paytimes'] ?? "",
  881. 'order_addtimes' => $row['order_addtimes'],
  882. 'pay_amount' => $item['pay_amount']
  883. ];
  884. }
  885. }
  886. $data[] = ['pay_amount' => "总计:" . sprintf('%.2f', $payAmount)];
  887. return json_success('success', $data);
  888. }
  889. /**
  890. * @Desc 获取权益使用记录
  891. * @Author Gorden
  892. * @Date 2024/10/15 11:35
  893. *
  894. * @param $memberId
  895. * @param $orderIds
  896. * @return array
  897. */
  898. public function getRoleBenefitUsedList($memberId, $orderIds = [])
  899. {
  900. $couponDetails = CouponDetail::where('join_coupon_detail_member_id', $memberId)
  901. ->where('coupon_detail_status', 'USED')
  902. ->whereJsonContains('coupon_detail_extend_json->gettype', 'ROLE')
  903. ->get()
  904. ->toArray();
  905. $data = [];
  906. foreach ($couponDetails as $couponDetail) {
  907. $orders = Order::where('order_discount_json', 'like', '%' . $couponDetail['coupon_detail_id'] . '%')
  908. ->whereIn('order_is_complete', ['Y', 'N'])
  909. ->where('order_status_payment', 'SUCCESS')
  910. ->when(!empty($orderIds), function ($query) use ($orderIds) {
  911. $query->whereIn('order_id', $orderIds);
  912. })->get()
  913. ->toArray();
  914. foreach ($orders as $order) {
  915. $sheets = OrderSheet::with([
  916. 'goods' => function ($query) {
  917. $query->select('goods_id', 'goods_name');
  918. }
  919. ])->where('join_sheet_order_id', $order['order_id'])
  920. ->get()
  921. ->toArray();
  922. $deng = "";
  923. if (count($sheets) > 1) {
  924. $deng = '等';
  925. }
  926. $discountJson = json_decode($order['order_discount_json'], true);
  927. $couponName = '';
  928. $discountAmount = 0;
  929. foreach ($discountJson as $item) {
  930. $discountAmount = $item['coupon_value'];
  931. $couponName = Coupon::where('coupon_id', $item['coupon_id'])->value('coupon_name');
  932. }
  933. $payDetailTimes = PayDetail::whereJsonContains('join_pay_object_json->order_id', $order['order_id'])->value('pay_paytimes');
  934. $data[] = [
  935. 'order_id' => $order['order_id'],
  936. 'goods_name' => !empty($sheets[0]) && !empty($sheets[0]['goods']) ? ($sheets[0]['goods']['goods_name'] . $deng) : '',
  937. 'order_classify' => $order['order_classify'],
  938. 'order_amount_total' => $order['order_amount_total'],
  939. 'order_amount_pay' => $order['order_amount_pay'],
  940. 'coupon_name' => $couponName,
  941. 'discountAmount' => $discountAmount,
  942. 'order_status_system' => $order['order_status_system'],
  943. 'order_addtimes' => $order['order_addtimes'],
  944. 'pay_paytimes' => $payDetailTimes
  945. ];
  946. }
  947. }
  948. return $data;
  949. }
  950. public function roleBenefitExport(Request $request)
  951. {
  952. $orderIds = $request->post('order_id', []);
  953. $memberId = $request->post('member_id');
  954. $applyUsername = $request->post('apply_username', '');
  955. $applyMobile = $request->post('apply_mobile', '');
  956. $applyAmount = $request->post('apply_amount', '');
  957. if (!$memberId) {
  958. return json_fail("参数异常");
  959. }
  960. $data = $this->getRoleBenefitUsedList($memberId, $orderIds);
  961. $dicountAmount = 0;
  962. foreach ($data as $key => $item) {
  963. $data[$key]['order_classify'] = OrderService::$orderClassify[$item['order_classify']];
  964. $dicountAmount += $item['discountAmount'];
  965. }
  966. $returnApplayData['data'] = $data;
  967. $returnApplayData['amount'] = $applyAmount;
  968. $returnApplayData['apply_username'] = $applyUsername;
  969. $returnApplayData['apply_mobile'] = $applyMobile;
  970. $returnApplayData['reason'] = "会员权益退款";
  971. $data[] = [
  972. 'discountAmount' => '优惠合计:¥' . sprintf('%.2f', $dicountAmount)
  973. ];
  974. // $data[] = [
  975. // 'order_classify' => '申请人:' . $applyUsername,
  976. // ];
  977. // $data[] = [
  978. // 'order_classify' => '电话:' . $applyMobile,
  979. // ];
  980. // $data[] = [
  981. // 'order_classify' => '退款金额:' . $applyAmount,
  982. // ];
  983. // 产生退款记录
  984. // $this->refundOrder($memberId, $returnApplayData);
  985. return json_success('success', $data);
  986. }
  987. public function refundOrder(Request $request)
  988. {
  989. $params = $request->post();
  990. Db::beginTransaction();
  991. try {
  992. // 查出所有的充值订单
  993. $orders = Order::where('join_order_member_id', $params['member_id'])
  994. ->where('order_classify', 'RECHARGE')
  995. ->where('order_is_complete', 'Y')
  996. ->get()
  997. ->toArray();
  998. $orderIds = array_column($orders, 'order_id');
  999. if (empty($orderIds)) {
  1000. throw new BusinessException("未查询到充值订单");
  1001. }
  1002. // 订单改为退款订单
  1003. Order::whereIn('order_id', $orderIds)->update([
  1004. 'order_is_complete' => 'R'
  1005. ]);
  1006. OrderReturn::where('join_return_member_id', $params['member_id'])
  1007. ->where('order_return_status', '<>', 'DONE')
  1008. ->where('order_return_category', '会员退款')
  1009. ->delete();
  1010. $returnApplyJson = [
  1011. 'reason' => '会员退款',
  1012. 'order_id' => $orderIds,
  1013. 'classify' => 'ROLE_REFUND',
  1014. 'username' => $params['username'],
  1015. 'mobile' => $params['mobile'],
  1016. 'surplus' => $params['surplus'],
  1017. 'added' => $params['added'],
  1018. 'bank_name' => $params['bank_name'],
  1019. 'bank_acount' => $params['bank_acount'],
  1020. 'bank_cardno' => $params['bank_cardno']
  1021. ];
  1022. // 退款记录
  1023. OrderReturn::insert([
  1024. 'join_order_return_user_id' => JwtToken::getCurrentId(),
  1025. 'join_return_member_id' => $params['member_id'],
  1026. 'join_return_order_id' => $orderIds[0],
  1027. 'order_return_status' => 'PENDING',
  1028. 'order_return_category' => '会员退款',
  1029. 'order_return_apply_datetime' => date('Y-m-d H:i:s'),
  1030. 'order_return_apply_json' => json_encode($returnApplyJson),
  1031. 'order_return_remark' => $params['remark'] ?? '',
  1032. 'order_return_addtimes' => time()
  1033. ]);
  1034. Db::commit();
  1035. return json_success("success");
  1036. } catch (BusinessException $e) {
  1037. Db::rollBack();
  1038. Log::error("创建退款记录失败:" . $e->getMessage());
  1039. return json_fail($e->getMessage());
  1040. } catch (\Exception $e) {
  1041. Db::rollBack();
  1042. Log::error("创建退款记录失败:" . $e->getMessage());
  1043. return json_fail("创建退款记录失败");
  1044. }
  1045. }
  1046. public function roleBenefitRefund(Request $request)
  1047. {
  1048. $memberId = $request->post('member_id');
  1049. if (!$memberId) {
  1050. return json_fail('参数异常');
  1051. }
  1052. $returnOrder = OrderReturn::where('join_return_member_id', $memberId)
  1053. ->where('order_return_status', 'DOING')
  1054. ->where('order_return_category', '会员权益退款')
  1055. ->first();
  1056. if (!$returnOrder) {
  1057. return json_fail("退款数据异常");
  1058. }
  1059. $memberAccount = MemberAccount::where('join_account_member_id', $memberId)
  1060. ->where('member_account_classify', 'CASH')
  1061. ->where('member_account_status', 'ACTIVED')
  1062. ->first();
  1063. if (!$memberAccount) {
  1064. return json_fail('会员账户异常');
  1065. }
  1066. try {
  1067. Db::beginTransaction();
  1068. $refundApplyJson = json_decode($returnOrder->order_return_apply_json, true);
  1069. $amount = $refundApplyJson['amount'];
  1070. $refundApplyJson['user_id'] = JwtToken::getCurrentId();
  1071. $refundApplyJson['datetime'] = date('Y-m-d H:i:s');
  1072. $returnOrder->order_return_refund_json = json_encode($refundApplyJson);
  1073. $returnOrder->order_return_status = 'DONE';
  1074. $returnOrder->save();
  1075. // 账户剩余
  1076. if ($memberAccount->member_account_surplus + $memberAccount->member_account_added < $amount) {
  1077. throw new BusinessException("账户余额不足");
  1078. }
  1079. // 本金
  1080. if ($memberAccount->member_account_surplus >= $amount) {
  1081. $memberAccount->member_account_surplus = $memberAccount->member_account_surplus - $amount;
  1082. } else {
  1083. $memberAccount->member_account_added = $memberAccount->member_account_added - ($amount - $memberAccount->member_account_surplus);
  1084. $memberAccount->member_account_surplus = 0;
  1085. }
  1086. $memberAccount->save();
  1087. // 删除会员身份
  1088. Member::where('member_id', $memberId)
  1089. ->update([
  1090. 'join_member_role_id' => '',
  1091. 'member_role_begintime' => '',
  1092. 'member_role_config_json' => '[]'
  1093. ]);
  1094. // 没用的优惠券失效
  1095. CouponDetail::where('join_coupon_detail_member_id', $memberId)
  1096. ->where('coupon_detail_status', '<>', 'USED')
  1097. ->whereJsonContains('coupon_detail_extend_json->gettype', 'ROLE')
  1098. ->update([
  1099. 'coupon_detail_status' => 'DISABLED'
  1100. ]);
  1101. // 产生一条退款记录 (pay_detail)
  1102. PayDetail::insert([
  1103. 'join_pay_member_id' => $memberId,
  1104. 'join_pay_order_id' => 'ROLE_REFUND',
  1105. 'join_pay_object_json' => '[]',
  1106. 'pay_status' => 'SUCCESS',
  1107. 'pay_category' => 'ROLE_REFUND',
  1108. 'pay_amount' => $amount,
  1109. 'pay_paytimes' => date('Y-m-d H:i:s'),
  1110. 'pay_prepayid' => $memberId . '-CASH',
  1111. 'pay_addtimes' => time()
  1112. ]);
  1113. Db::commit();
  1114. return json_success('success');
  1115. } catch (BusinessException $e) {
  1116. Db::rollBack();
  1117. return json_fail($e->getMessage());
  1118. } catch (\Exception $e) {
  1119. Db::rollBack();
  1120. return json_fail('退款失败');
  1121. }
  1122. }
  1123. public function crownContinue(Request $request)
  1124. {
  1125. $memberId = $request->post('member_id');
  1126. $dataTime = $request->post('datetime', date('Y-m-d'));
  1127. $sendAll = $request->post('send_all', false);
  1128. $orderId = $request->post('order_id');
  1129. if (!$memberId || !$orderId) {
  1130. return json_fail('参数异常');
  1131. }
  1132. $member = Member::where('member_id', $memberId)->first();
  1133. try {
  1134. Db::beginTransaction();
  1135. $roleConfigJson = [];
  1136. if (!empty($member->member_role_config_json)) {
  1137. $roleConfigJson = json_decode($member->member_role_config_json, true);
  1138. if (!empty($roleConfigJson['next'])) {
  1139. unset($roleConfigJson['next']);
  1140. }
  1141. }
  1142. $roleConfigJson['deadline_datetime'] = date('Y-m-d 23:59:59', strtotime($dataTime . ' + 364 days'));
  1143. $member->member_role_config_json = json_encode($roleConfigJson);
  1144. $member->member_role_begintime = date('Y-m-d 00:00:00', strtotime($dataTime));
  1145. $memberRoleId = MemberRole::where('member_role_category', 'COMBINE')
  1146. ->where('member_role_status', 'ACTIVED')
  1147. ->where('member_role_name', 'like', '%皇冠%')
  1148. ->value('member_role_id');
  1149. $member->join_member_role_id = $memberRoleId;
  1150. $member->save();
  1151. if ($sendAll === true) {
  1152. $payDetail = PayDetail::whereJsonContains('join_pay_object_json->order_id', $orderId)
  1153. ->first();
  1154. if (!empty($payDetail->pay_extend_json)) {
  1155. $payExtendJson = json_decode($payDetail->pay_extend_json, true);
  1156. $account = MemberAccount::where('join_account_member_id', $memberId)
  1157. ->where('member_account_classify', 'CASH')
  1158. ->first();
  1159. $account->member_account_added = $account->member_account_added + $payExtendJson['added_amount'];
  1160. $account->save();
  1161. }
  1162. // 产生一条支付记录
  1163. PayDetail::insert([
  1164. 'join_pay_member_id' => $memberId,
  1165. 'join_pay_order_id' => 'CROWN_CONTINUE',
  1166. 'join_pay_object_json' => '[]',
  1167. 'pay_status' => 'SUCCESS',
  1168. 'pay_category' => 'CROWN_CONTINUE',
  1169. 'pay_amount' => 0,
  1170. 'pay_paytimes' => date('Y-m-d H:i:s'),
  1171. 'pay_prepayid' => $memberId . '-CASH',
  1172. 'pay_extend_json' => $payDetail->pay_extend_json,
  1173. 'pay_addtimes' => time()
  1174. ]);
  1175. $goodsAttributeJson = RechargeService::getGoodsAttributeJson($orderId);
  1176. // 发券
  1177. $couponParams['order_id'] = $orderId;
  1178. RechargeService::disposeRoleCoupon($goodsAttributeJson, $couponParams, $memberId);
  1179. }
  1180. Db::commit();
  1181. return json_success('success');
  1182. } catch (\Exception $e) {
  1183. dump($e->getTrace());
  1184. Db::rollBack();
  1185. Log::error("续期失败:" . $e->getMessage());
  1186. return json_fail("续期失败");
  1187. }
  1188. }
  1189. }