CouponController.php 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752
  1. <?php
  2. namespace app\admin\controller\coupon;
  3. use app\admin\service\coupon\CouponDetailService;
  4. use app\admin\validate\coupon\CouponValidate;
  5. use app\admin\validate\device\DeviceValidate;
  6. use app\controller\Curd;
  7. use app\model\Coupon;
  8. use app\model\CouponDetail;
  9. use app\model\CouponGoods;
  10. use app\model\Device;
  11. use app\model\Member;
  12. use app\model\SysDept;
  13. use app\model\SysSerial;
  14. use support\Db;
  15. use support\exception\BusinessException;
  16. use support\Request;
  17. use support\Response;
  18. use Tinywan\Jwt\JwtToken;
  19. class CouponController extends Curd
  20. {
  21. public function __construct()
  22. {
  23. $this->model = new Coupon();
  24. $this->validate = true;
  25. $this->validateClass = new CouponValidate();
  26. }
  27. /**
  28. * @Desc 列表
  29. * @Author Gorden
  30. * @Date 2024/3/28 15:01
  31. *
  32. * @param Request $request
  33. * @return Response
  34. * @throws \support\exception\BusinessException
  35. */
  36. public function select(Request $request): Response
  37. {
  38. $joinCouponCategoryId = $request->get('join_coupon_category_id', []);
  39. [$where, $format, $limit, $field, $order] = $this->selectInput($request);
  40. if (!empty($joinCouponCategoryId)) {
  41. $where['join_coupon_category_id'] = ['in', implode(',', $joinCouponCategoryId)];
  42. }
  43. $order = $request->get('order', 'desc');
  44. $field = $field ?? 'coupon_addtimes';
  45. $query = $this->doSelect($where, $field, $order);
  46. return $this->doFormat($query, $format, $limit);
  47. }
  48. protected function doSelect(array $where, string $field = null, string $order = 'desc')
  49. {
  50. $model = $this->model->with([
  51. 'category' => function ($query) {
  52. $query->select('category_id', 'category_name');
  53. },
  54. 'user',
  55. 'detail'
  56. ]);
  57. foreach ($where as $column => $value) {
  58. if (is_array($value)) {
  59. if ($value[0] === 'like' || $value[0] === 'not like') {
  60. $model = $model->where($column, $value[0], "%$value[1]%");
  61. } elseif (in_array($value[0], ['>', '=', '<', '<>'])) {
  62. $model = $model->where($column, $value[0], $value[1]);
  63. } elseif ($value[0] == 'in' && !empty($value[1])) {
  64. $valArr = $value[1];
  65. if (is_string($value[1])) {
  66. $valArr = explode(",", trim($value[1]));
  67. }
  68. $model = $model->whereIn($column, $valArr);
  69. } elseif ($value[0] == 'not in' && !empty($value[1])) {
  70. $valArr = $value[1];
  71. if (is_string($value[1])) {
  72. $valArr = explode(",", trim($value[1]));
  73. }
  74. $model = $model->whereNotIn($column, $valArr);
  75. } elseif ($value[0] == 'null') {
  76. $model = $model->whereNull($column);
  77. } elseif ($value[0] == 'not null') {
  78. $model = $model->whereNotNull($column);
  79. } elseif ($value[0] !== '' || $value[1] !== '') {
  80. $model = $model->whereBetween($column, $value);
  81. }
  82. } else {
  83. $model = $model->where($column, $value);
  84. }
  85. }
  86. if ($field) {
  87. $model = $model->orderBy($field, $order);
  88. }
  89. return $model;
  90. }
  91. protected function afterQuery($items)
  92. {
  93. foreach ($items as &$item) {
  94. if (!empty($item['coupon_json'])) {
  95. $couponJson = json_decode($item['coupon_json'], true);
  96. if (isset($couponJson['member'])) {
  97. if (isset($couponJson['member']['list']) && !empty($couponJson['member']['list'])) {
  98. $item['coupon_use_member'] = 'member';
  99. $item['memberList'] = $couponJson['member']['list'];
  100. } else if (isset($couponJson['member']['where']) && !empty($couponJson['member']['where'])) {
  101. if (trim($couponJson['member']['where']) == '1') {
  102. $item['coupon_use_member'] = 'all';
  103. } else {
  104. $item['coupon_use_member'] = 'condition';
  105. $where = str_replace('`', '', urldecode($couponJson['member']['where']));
  106. $whereArr = explode('=', $where);
  107. // dump($whereArr);
  108. if (isset($whereArr[0]) && trim($whereArr[0]) == 'member_is_vip') {
  109. $item['condition'] = 'is_vip';
  110. } else if (isset($whereArr[0]) && trim($whereArr[0]) == 'member_classify') {
  111. if (isset($whereArr[1]) && str_replace("'", '', trim($whereArr[1])) == 'MEMBER') {
  112. $item['condition'] = 'is_member';
  113. } else if (isset($whereArr[1]) && str_replace("'", '', trim($whereArr[1])) == 'EMPLOY') {
  114. $item['condition'] = 'is_employ';
  115. }
  116. }
  117. }
  118. }
  119. }
  120. if (isset($couponJson['premises'])) {
  121. $item['premises'] = $couponJson['premises'];
  122. } else {
  123. $item['premises_range'] = 'all';
  124. }
  125. }
  126. if (!empty($item['coupon_validdate_begin']) && !empty($item['coupon_validdate_end'])) {
  127. $item['coupon_use_time'] = 'date';
  128. } elseif ($item['coupon_validdate_day']) {
  129. $item['coupon_use_time'] = 'day';
  130. }
  131. $item['member_count'] = 0;
  132. $item['pending_count'] = 0;
  133. $item['used_count'] = 0;
  134. if (!empty($item['detail'])) {
  135. foreach ($item['detail'] as $detail) {
  136. if (!empty($detail['join_coupon_detail_member_id'])) {
  137. $item['member_count'] += 1;
  138. }
  139. if ($detail['coupon_detail_status'] == 'PENDING') {
  140. $item['pending_count'] += 1;
  141. } elseif ($detail['coupon_detail_status'] == 'USED') {
  142. $item['used_count'] += 1;
  143. }
  144. }
  145. }
  146. }
  147. return $items;
  148. }
  149. public function selectList()
  150. {
  151. $coupons = Coupon::where('coupon_status', 'ACTIVED')
  152. ->select('coupon_id', 'coupon_name')
  153. ->orderBy('coupon_addtimes', 'DESC')
  154. ->get()
  155. ->toArray();
  156. return json_success('', $coupons);
  157. }
  158. // public function afterQuery($items)
  159. // {
  160. // foreach ($items as &$item) {
  161. // $item->coupon_begindate = date('Y-m-d H:i:s', $item->coupon_begindate);
  162. // $item->coupon_enddate = date('Y-m-d H:i:s', $item->coupon_enddate);
  163. // }
  164. //
  165. // return $items;
  166. // }
  167. /**
  168. * @Desc 添加优惠券
  169. * @Author Gorden
  170. * @Date 2024/8/14 15:16
  171. *
  172. * @param Request $request
  173. * @return Response
  174. */
  175. public function insert(Request $request): Response
  176. {
  177. if ($this->validate && !$this->validateClass->scene('add')->check($request->post())) {
  178. return json_fail($this->validateClass->getError());
  179. }
  180. $goods = $request->post('goodsContentList', []);
  181. if (empty($goods)) {
  182. return json_fail("请选择关联的产品");
  183. }
  184. Db::beginTransaction();
  185. try {
  186. $data = $this->insertInput($request);
  187. $data['coupon_creator_user_id'] = JwtToken::getCurrentId();
  188. $this->doInsert($data);
  189. // 关联优惠券和商品、规格
  190. $this->insertCouponGoods($goods, $data['coupon_id']);
  191. if ($data['coupon_number'] > 0) {
  192. $this->generateCouponDetail($data['coupon_id'], $data['coupon_status'], $data['coupon_number']);
  193. }
  194. Db::commit();
  195. return json_success('success');
  196. } catch (BusinessException $customException) {
  197. Db::rollBack();
  198. dump($customException->getMessage());
  199. return json_fail($customException->getMessage());
  200. } catch (\Exception $e) {
  201. Db::rollBack();
  202. dump($e->getMessage());
  203. return json_fail('数据写入失败');
  204. }
  205. }
  206. /**
  207. * @Desc 关联优惠券、产品、规格
  208. * @Author Gorden
  209. * @Date 2024/8/14 14:32
  210. *
  211. * @param $goods
  212. * @param $couponId
  213. * @return void
  214. * @throws BusinessException
  215. */
  216. public function insertCouponGoods($goods, $couponId)
  217. {
  218. try {
  219. foreach ($goods as $good) {
  220. CouponGoods::insert([
  221. 'join_goods_coupon_id' => $couponId,
  222. 'join_coupon_goods_id' => $good['goods_id'],
  223. 'join_coupon_goods_sku_id' => $good['sku_id'],
  224. 'coupon_goods_json' => '[]',
  225. 'coupon_goods_extend_json' => '[]',
  226. 'coupon_goods_addtimes' => time()
  227. ]);
  228. }
  229. } catch (\Exception $e) {
  230. throw new BusinessException("关联产品失败");
  231. }
  232. }
  233. protected function insertInput(Request $request): array
  234. {
  235. $params = $request->post();
  236. $data = $this->inputFilter($params);
  237. $data['coupon_id'] = "CU" . str_pad(SysSerial::getSerial(), 6, '0') . random_string(6, 'up');
  238. if (!empty($params['coupon_use_time']) && $params['coupon_use_time'] == 'date') {
  239. $data['coupon_validdate_day'] = 0;
  240. $data['coupon_validdate_begin'] = date("Y-m-d H:i:s", strtotime($data['coupon_validdate_begin']));
  241. $data['coupon_validdate_end'] = date("Y-m-d H:i:s", strtotime($data['coupon_validdate_end']));
  242. } elseif (!empty($params['coupon_use_time']) && $params['coupon_use_time'] == 'day') {
  243. $data['coupon_validdate_begin'] = '';
  244. $data['coupon_validdate_end'] = '';
  245. }
  246. $couponJson = [];
  247. if ($params['coupon_use_member'] == 'member' && isset($params['member_list'])) {
  248. $couponJson['member']['list'] = $params['member_list'];
  249. $couponJson['member']['range'] = '';
  250. $couponJson['member']['where'] = '';
  251. } else if ($params['coupon_use_member'] == 'condition') {
  252. $couponJson['member']['list'] = [];
  253. if (isset($params['condition']) && $params['condition'] == 'is_vip') {
  254. $couponJson['member']['range'] = 'VIP会员';
  255. $couponJson['member']['where'] = urlencode(" `member_is_vip` = 'Y'");
  256. } elseif (isset($params['condition']) && $params['condition'] == 'is_employ') {
  257. $couponJson['member']['range'] = '公司员工';
  258. $couponJson['member']['where'] = urlencode(" `member_classify` = 'EMPLOY'");
  259. } elseif (isset($params['condition']) && $params['condition'] == 'is_member') {
  260. $couponJson['member']['range'] = '会员';
  261. $couponJson['member']['where'] = urlencode(" `member_classify` = 'MEMBER'");
  262. }
  263. } else if ($params['coupon_use_member'] == 'all') {
  264. $couponJson['member']['list'] = [];
  265. $couponJson['member']['range'] = '全部会员';
  266. $couponJson['member']['where'] = '';
  267. }
  268. if (!empty($params['premises_range']) && $params['premises_range'] == 'all') {
  269. $couponJson['premises_range'] = '所有门店可用';
  270. } elseif (!empty($params['premises_range']) && $params['premises_range'] == 'part') {
  271. $couponJson['premises'] = $params['premises'];
  272. $couponJson['premises_range'] = '部分门店可用';
  273. }
  274. $data['coupon_json'] = json_encode($couponJson, JSON_UNESCAPED_UNICODE);
  275. return $data;
  276. }
  277. public function customSend(Request $request)
  278. {
  279. $chooseCoupons = $request->post('chooseCoupons', []);
  280. $couponUseMember = $request->post('coupon_use_member', '');
  281. $memberList = $request->post('member_list', []);
  282. $condition = $request->post('condition', '');
  283. if ($couponUseMember == 'condition') {
  284. if ($condition == 'is_employ') {
  285. $memberList = Member::where('member_classify', 'EMPLOY')->pluck('member_id')->toArray();
  286. } elseif ($condition == 'is_member') {
  287. $memberList = Member::where('member_classify', 'MEMBER')->pluck('member_id')->toArray();
  288. } elseif ($condition == 'is_vip') {
  289. $memberList = Member::where('member_is_vip', 'Y')->pluck('member_id')->toArray();
  290. }
  291. }
  292. Db::beginTransaction();
  293. try {
  294. $couponIds = array_column($chooseCoupons, 'id');
  295. $coupons = Coupon::whereIn('coupon_id', $couponIds)->get()->toArray();
  296. foreach ($coupons as $coupon) {
  297. foreach ($chooseCoupons as $chooseCoupon) {
  298. if ($chooseCoupon['id'] == $coupon['coupon_id']) {
  299. if (empty($chooseCoupon['gain_datetime'])) {
  300. $chooseCoupon['gain_datetime'] = date('Y-m-d H:i:s');
  301. }
  302. $params['coupon_id'] = $coupon['coupon_id'];
  303. $params['coupon_detail_gain_datetime'] = date('Y-m-d H:i:s', strtotime($chooseCoupon['gain_datetime']));
  304. if (($coupon['coupon_validdate_day'] == 0 || $coupon['coupon_validdate_day'] == '') && !empty($coupon['coupon_validdate_end'])) {
  305. $params['coupon_detail_deadline_datetime'] = $coupon['coupon_validdate_end'];
  306. } elseif ($coupon['coupon_validdate_day'] > 0) {
  307. $endUnix = strtotime($chooseCoupon['gain_datetime']);
  308. $params['coupon_detail_deadline_datetime'] = date('Y-m-d H:i:s', $endUnix + ($coupon['coupon_validdate_day'] * 24 * 3600) -1);
  309. }
  310. foreach ($memberList as $item) {
  311. $params['member_id'] = $item;
  312. if ($chooseCoupon['nbr'] > 0) {
  313. for ($i = 0; $i < $chooseCoupon['nbr']; $i++) {
  314. CouponDetailService::customSendCoupon($params);
  315. }
  316. }
  317. }
  318. }
  319. }
  320. }
  321. Db::commit();
  322. return json_success("发放成功");
  323. } catch (BusinessException $e) {
  324. return json_fail($e->getMessage());
  325. } catch (\Exception $e) {
  326. Db::rollBack();
  327. return json_fail('优惠券发放失败');
  328. }
  329. }
  330. /**
  331. * @Desc 修改优惠券
  332. * @Author Gorden
  333. * @Date 2024/8/14 15:48
  334. *
  335. * @param Request $request
  336. * @return Response
  337. */
  338. public function update(Request $request): Response
  339. {
  340. if ($this->validate && !$this->validateClass->scene('update')->check($request->post())) {
  341. return json_fail($this->validateClass->getError());
  342. }
  343. $params = $request->post();
  344. Db::beginTransaction();
  345. try {
  346. [$id, $data] = $this->updateInput($request);
  347. $originCouponNumber = $data['origin_coupon_number'];
  348. $originCouponValiddateDay = $data['origin_coupon_validdate_day'];
  349. $originCouponValiddateEnd = $data['origin_coupon_validdate_end'];
  350. unset($data['origin_coupon_number'], $data['origin_coupon_validdate_day'], $data['origin_coupon_validdate_end']);
  351. $this->updateCouponGoods($request->post('goodsContentList'), $id);
  352. if ($originCouponNumber == 0 && $data['coupon_number'] != 0) {
  353. // 查已领取多少了
  354. $detailCount = CouponDetail::where('join_detail_coupon_id', $id)->count();
  355. if ($detailCount < $data['coupon_number']) {
  356. $this->generateCouponDetail($id, $data['coupon_status'], $data['coupon_number'] - $detailCount);
  357. }
  358. } else if ($originCouponNumber < $data['coupon_number']) {
  359. $this->generateCouponDetail($id, $data['coupon_status'], $data['coupon_number'] - $originCouponNumber);
  360. } else if ($originCouponNumber > $data['coupon_number']) {
  361. CouponDetail::where('join_detail_coupon_id', $id)
  362. ->where('join_coupon_detail_member_id', '')
  363. ->limit($originCouponNumber - $data['coupon_number'])
  364. ->delete();
  365. }
  366. // 修改时间了
  367. if ($params['coupon_use_time'] == 'day' && $originCouponValiddateDay != $data['coupon_validdate_day']) {
  368. $this->updateDetailTimeForDay($id, $data['coupon_validdate_day']);
  369. } elseif ($params['coupon_use_time'] == 'date' && $originCouponValiddateEnd != $data['coupon_validdate_end']) {
  370. $this->updateDetailTimeForDate($id, $data['coupon_validdate_end']);
  371. }
  372. // 激活状态,初始改为待领取
  373. if ($data['coupon_status'] == 'ACTIVED') {
  374. CouponDetail::where('join_detail_coupon_id', $id)->where('coupon_detail_status', 'INIT')->update(['coupon_detail_status' => 'PENDING']);
  375. } elseif ($data['coupon_status'] == 'DISABLED') { // 禁用状态,未领取未使用的都是禁用
  376. CouponDetail::where('join_detail_coupon_id', $id)->where('coupon_detail_status', '<>', 'USED')->update(['coupon_detail_status' => 'DISABLED']);
  377. }
  378. $this->doUpdate($id, $data);
  379. Db::commit();
  380. return json_success('success');
  381. } catch (BusinessException $e) {
  382. Db::rollBack();
  383. return json_fail($e->getMessage());
  384. } catch (\Exception $e) {
  385. Db::rollBack();
  386. dump($e->getMessage());
  387. return json_fail('数据更新失败');
  388. }
  389. }
  390. public function updateDetailTimeForDay($couponId, $day)
  391. {
  392. $details = CouponDetail::where('join_detail_coupon_id', $couponId)
  393. ->where('coupon_detail_status', '<>', 'USED')
  394. ->where('coupon_detail_deadline_datetime', '<>', '')
  395. ->get()
  396. ->toArray();
  397. try {
  398. foreach ($details as $detail) {
  399. $couponDetailGainDatetime = strtotime($detail['coupon_detail_gain_datetime']);
  400. CouponDetail::where('coupon_detail_id', $detail['coupon_detail_id'])
  401. ->update([
  402. 'coupon_detail_deadline_datetime' => date('Y-m-d H:i:s', $couponDetailGainDatetime + ($day * 24 * 3600))
  403. ]);
  404. }
  405. } catch (\Exception $e) {
  406. dump($e->getMessage());
  407. throw new BusinessException("优惠券更新失败");
  408. }
  409. }
  410. public function updateDetailTimeForDate($couponId, $endDate)
  411. {
  412. $details = CouponDetail::where('join_detail_coupon_id', $couponId)
  413. ->where('coupon_detail_status', '<>', 'USED')
  414. ->where('coupon_detail_deadline_datetime', '<>', '')
  415. ->get()
  416. ->toArray();
  417. try {
  418. foreach ($details as $detail) {
  419. CouponDetail::where('coupon_detail_id', $detail['coupon_detail_id'])
  420. ->update([
  421. 'coupon_detail_deadline_datetime' => $endDate
  422. ]);
  423. }
  424. } catch (\Exception $e) {
  425. dump($e->getMessage());
  426. throw new BusinessException("优惠券更新失败");
  427. }
  428. }
  429. public function updateCouponGoods($goods, $couponId)
  430. {
  431. try {
  432. $couponGoodsIds = CouponGoods::where('join_goods_coupon_id', $couponId)->pluck('join_coupon_goods_id')->toArray();
  433. $goodsIds = array_column($goods, 'goods_id');
  434. // 新的差集
  435. $goodsDiff = array_diff($goodsIds, $couponGoodsIds);
  436. // 旧的差集
  437. $couponDiff = array_diff($couponGoodsIds, $goodsIds);
  438. foreach ($goods as $good) {
  439. // 更新两个中都有的
  440. if (in_array($good['goods_id'], $couponGoodsIds)) {
  441. CouponGoods::where('join_goods_coupon_id', $couponId)->where('join_coupon_goods_id', $good['goods_id'])->update(['join_coupon_goods_sku_id' => $good['sku_id']]);
  442. } elseif (in_array($good['goods_id'], $goodsDiff)) { // 新加的
  443. CouponGoods::insert([
  444. 'join_goods_coupon_id' => $couponId,
  445. 'join_coupon_goods_id' => $good['goods_id'],
  446. 'join_coupon_goods_sku_id' => $good['sku_id'],
  447. 'coupon_goods_json' => '[]',
  448. 'coupon_goods_extend_json' => '[]',
  449. 'coupon_goods_addtimes' => time()
  450. ]);
  451. }
  452. }
  453. if (!empty($couponDiff)) { // 去掉的
  454. foreach ($couponDiff as $item) {
  455. CouponGoods::where('join_goods_coupon_id', $couponId)->where('join_coupon_goods_id', $item)->delete();
  456. }
  457. }
  458. } catch (\Exception $e) {
  459. throw new BusinessException('关联产品更新失败');
  460. }
  461. }
  462. protected function updateInput(Request $request): array
  463. {
  464. $params = $request->post();
  465. $primary_key = $this->model->getKeyName();
  466. $id = $request->post($primary_key);
  467. $data = $this->inputFilter($params);
  468. if (!empty($params['coupon_use_time']) && $params['coupon_use_time'] == 'date') {
  469. $data['coupon_validdate_day'] = 0;
  470. $data['coupon_validdate_begin'] = date("Y-m-d H:i:s", strtotime($data['coupon_validdate_begin']));
  471. $data['coupon_validdate_end'] = date("Y-m-d H:i:s", strtotime($data['coupon_validdate_end']));
  472. } elseif (!empty($params['coupon_use_time']) && $params['coupon_use_time'] == 'day') {
  473. $data['coupon_validdate_begin'] = '';
  474. $data['coupon_validdate_end'] = '';
  475. }
  476. $model = $this->model->find($id);
  477. // 原数量
  478. $data['origin_coupon_number'] = $model->coupon_number;
  479. // 原优惠天数
  480. $data['origin_coupon_validdate_day'] = $model->coupon_validdate_day;
  481. // 原结束时间
  482. $data['origin_coupon_validdate_end'] = $model->coupon_validdate_end;
  483. if (!$model) {
  484. throw new BusinessException('记录不存在', 2);
  485. }
  486. $couponJson = [];
  487. if (!empty($model->coupon_json)) {
  488. $couponJson = json_decode($model->coupon_json, true);
  489. }
  490. if ($params['coupon_use_member'] == 'member' && isset($params['member_list'])) {
  491. $couponJson['member']['list'] = $params['member_list'];
  492. // if (isset($couponJson['member']['range'])) {
  493. $couponJson['member']['range'] = '';
  494. // }
  495. // if (isset($couponJson['member']['where'])) {
  496. $couponJson['member']['where'] = '';
  497. // }
  498. } else if ($params['coupon_use_member'] == 'condition') {
  499. if (isset($params['condition']) && $params['condition'] == 'is_vip') {
  500. $couponJson['member']['range'] = 'VIP会员';
  501. $couponJson['member']['where'] = urlencode(" `member_is_vip` = 'Y'");
  502. } elseif (isset($params['condition']) && $params['condition'] == 'is_employ') {
  503. $couponJson['member']['range'] = '公司员工';
  504. $couponJson['member']['where'] = urlencode(" `member_classify` = 'EMPLOY'");
  505. } elseif (isset($params['condition']) && $params['condition'] == 'is_member') {
  506. $couponJson['member']['range'] = '会员';
  507. $couponJson['member']['where'] = urlencode(" `member_classify` = 'MEMBER'");
  508. }
  509. // if (isset($couponJson['member']['list'])) {
  510. $couponJson['member']['list'] = [];
  511. // }
  512. } else if ($params['coupon_use_member'] == 'all') {
  513. $couponJson['member']['list'] = [];
  514. $couponJson['member']['range'] = '全部会员';
  515. $couponJson['member']['where'] = '';
  516. if (isset($couponJson['member']['list'])) {
  517. $couponJson['member']['list'] = [];
  518. }
  519. }
  520. if (!empty($params['premises_range']) && $params['premises_range'] == 'all') {
  521. $couponJson['premises_range'] = '所有门店可用';
  522. unset($couponJson['premises']);
  523. } elseif (!empty($params['premises_range']) && $params['premises_range'] == 'part') {
  524. $couponJson['premises'] = $params['premises'];
  525. $couponJson['premises_range'] = '部分门店可用';
  526. }
  527. if (empty($data['coupon_validdate_day'])) {
  528. $data['coupon_validdate_day'] = 0;
  529. }
  530. $data['coupon_json'] = json_encode($couponJson, JSON_UNESCAPED_UNICODE);
  531. unset($data[$primary_key]);
  532. return [$id, $data];
  533. }
  534. /**
  535. * 优惠券详情
  536. */
  537. public function info(Request $request): Response
  538. {
  539. $couponId = $request->get('coupon_id', '');
  540. if (!$couponId) {
  541. return json_fail('参数异常');
  542. }
  543. $coupon = Coupon::where('coupon_id', $couponId)->first();
  544. if (!$coupon) {
  545. return json_fail('数据异常');
  546. }
  547. // 拼选择的商品
  548. $couponGoods = CouponGoods::with([
  549. 'goods' => function ($query) {
  550. $query->select('goods_id', 'goods_id as id', 'goods_name as name', 'join_goods_category_id as pid', 'goods_classify', 'goods_sales_price', 'goods_cover');
  551. },
  552. 'skus',
  553. 'sku'
  554. ])->where('join_goods_coupon_id', $couponId)
  555. ->get()
  556. ->toArray();
  557. $goodsIds = [];
  558. $goodsContent = [];
  559. foreach ($couponGoods as $couponGood) {
  560. $goodsIds[] = $couponGood['join_coupon_goods_id'];
  561. $content = [
  562. 'goods_id' => $couponGood['join_coupon_goods_id'],
  563. 'sku_id' => $couponGood['join_coupon_goods_sku_id'],
  564. ];
  565. if (isset($couponGood['goods'])) {
  566. $content['goods_name'] = $couponGood['goods']['name'];
  567. $content['goods_classify'] = $couponGood['goods']['goods_classify'];
  568. $content['goods_cover'] = getenv('STORAGE_DOMAIN') . $couponGood['goods']['goods_cover'];
  569. }
  570. if (isset($couponGood['sku']) && isset($couponGood['sku']['goods_sku_specs_json'])) {
  571. // $skuSpecsJson = json_decode($couponGood['sku']['goods_sku_specs_json'], true);
  572. // $skuName = '';
  573. // foreach ($skuSpecsJson as $item) {
  574. // if (is_array($item)) {
  575. // $item = implode('', $item);
  576. // }
  577. // $skuName .= $item . ',';
  578. // }
  579. // $content['sku_name'] = rtrim($skuName, ',');
  580. $content['goods_sales_price'] = $couponGood['sku']['goods_sku_sales_price'];
  581. }
  582. if (isset($couponGood['skus'])) {
  583. foreach ($couponGood['skus'] as $key => $skus) {
  584. if (!empty($skus['goods_sku_specs_json'])) {
  585. $skuSpecsJson = json_decode($skus['goods_sku_specs_json'], true);
  586. $skuName = '';
  587. foreach ($skuSpecsJson as $item) {
  588. if (is_array($item)) {
  589. $item = implode('', $item);
  590. }
  591. $skuName .= $item . ',';
  592. }
  593. $couponGood['skus'][$key]['sku_name'] = rtrim($skuName, ',');
  594. }
  595. }
  596. $content['skus'] = $couponGood['skus'];
  597. }
  598. $goodsContent[] = $content;
  599. }
  600. // 选中的会员
  601. $memberLists = [];
  602. // 可用门店
  603. $premises = [];
  604. if (!empty($coupon->coupon_json)) {
  605. $couponJson = json_decode($coupon->coupon_json, true);
  606. if (isset($couponJson['member']) && isset($couponJson['member']['list']) && !empty($couponJson['member']['list'])) {
  607. $res = Db::table('member')
  608. ->leftjoin('member_cert', 'member.member_id', '=', 'member_cert.join_cert_member_id')
  609. ->leftjoin('member_info', 'member.member_id', '=', 'member_info.join_info_member_id')
  610. ->select('member.member_id', 'member.member_mobile', 'member_cert.member_cert_name', 'member_info.member_info_nickname')
  611. ->where('member_status', 'ACTIVED')
  612. ->whereIn('member_id', $couponJson['member']['list'])
  613. ->get();
  614. $memberLists = [];
  615. foreach ($res as $item) {
  616. $name = '';
  617. if (!empty($item->member_cert_name)) {
  618. $name = $item->member_cert_name;
  619. } else if (!empty($item->member_info_nickname)) {
  620. $name = $item->member_info_nickname;
  621. }
  622. $value = !empty($name) ? $name . '-' : '';
  623. if ($item->member_mobile != '0000') {
  624. $value .= $item->member_mobile;
  625. }
  626. if (empty($value)) {
  627. $value = $item->member_mobile;
  628. }
  629. $value = rtrim($value, '-');
  630. $memberLists[] = [
  631. 'key' => $item->member_id,
  632. 'value' => $value,
  633. ];
  634. }
  635. }
  636. if (isset($couponJson['premises']) && !empty($couponJson['premises'])) {
  637. $premises = SysDept::whereIn('dept_id', $couponJson['premises'])
  638. ->select('dept_id', 'dept_name')
  639. ->get()
  640. ->toArray();
  641. }
  642. }
  643. $data = [
  644. 'goods_ids' => $goodsIds,
  645. 'goods_content' => $goodsContent,
  646. 'member_lists' => $memberLists,
  647. 'premises_list' => $premises
  648. ];
  649. return json_success('', $data);
  650. }
  651. /**
  652. * 删除
  653. * @param Request $request
  654. * @return Response
  655. * @throws BusinessException
  656. */
  657. public function delete(Request $request): Response
  658. {
  659. $ids = $this->deleteInput($request);
  660. Db::beginTransaction();
  661. try {
  662. // 删除优惠券关联的产品
  663. foreach ($ids as $id) {
  664. $couponDetail = CouponDetail::with([
  665. 'coupon' => function ($query) {
  666. $query->select('coupon_id', 'coupon_name');
  667. }
  668. ])->where('join_detail_coupon_id', $id)
  669. ->where('join_coupon_detail_member_id', '<>', '')
  670. ->first();
  671. if (!empty($couponDetail)) {
  672. Db::rollBack();
  673. return json_fail($couponDetail->coupon && $couponDetail->coupon->coupon_name ? $couponDetail->coupon->coupon_name . "已被领取,无法删除,请禁用" : "删除的优惠券中有已被领取的,无法删除,请禁用");
  674. }
  675. CouponGoods::where('join_goods_coupon_id', $id)->delete();
  676. // CouponDetail::where('join_detail_coupon_id', $id)
  677. // ->whereIn('coupon_detail_status',['INIT','PENDING','ACTIVED'])
  678. // ->delete();
  679. // CouponDetail::where('join_detail_coupon_id', $id)
  680. // ->where('coupon_detail_status','WAITING')
  681. // ->update(['coupon_detail_status'=>'DISABLED']);
  682. }
  683. $this->doDelete($ids);
  684. Db::commit();
  685. return json_success('success');
  686. } catch (\Exception $e) {
  687. dump($e->getMessage());
  688. Db::rollBack();
  689. return json_fail('删除失败');
  690. }
  691. }
  692. private function generateCouponDetail($couponId, $couponStatus, $nbr)
  693. {
  694. for ($i = 0; $i < intval($nbr); $i++) {
  695. CouponDetail::insert([
  696. 'coupon_detail_id' => 'CUDT' . str_pad(SysSerial::getSerial(), 6, '0') . random_string(6, 'up'),
  697. 'join_detail_coupon_id' => $couponId,
  698. 'coupon_detail_status' => $couponStatus == 'ACTIVED' ? 'PENDING' : 'INIT',
  699. 'coupon_detail_addtimes' => time()
  700. ]);
  701. }
  702. }
  703. }