Activity.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696
  1. <?php
  2. namespace app\admin\controller\lottery;
  3. use app\common\controller\Backend;
  4. use app\common\Enum\LotteryEnum;
  5. use app\common\Enum\ChannelEnum;
  6. use think\Db;
  7. use think\exception\ValidateException;
  8. use think\exception\PDOException;
  9. use Exception;
  10. /**
  11. * 抽奖活动管理
  12. *
  13. * @icon fa fa-gift
  14. */
  15. class Activity extends Backend
  16. {
  17. /**
  18. * Activity模型对象
  19. * @var \app\admin\model\lottery\Activity
  20. */
  21. protected $model = null;
  22. public function _initialize()
  23. {
  24. parent::_initialize();
  25. $this->model = new \app\admin\model\lottery\Activity;
  26. // 获取枚举值列表
  27. $this->view->assign("typeList", LotteryEnum::getLotteryTypeMap());
  28. $this->assignconfig("typeList", json_encode(LotteryEnum::getLotteryTypeMap()));
  29. $this->view->assign("statusList", LotteryEnum::getActivityStatusMap());
  30. $this->assignconfig("statusList", json_encode(LotteryEnum::getActivityStatusMap()));
  31. $this->view->assign("lotteryTypeList", LotteryEnum::getLotteryTypeMap());
  32. $this->assignconfig("lotteryTypeList", json_encode(LotteryEnum::getLotteryTypeMap()));
  33. $this->view->assign("userLimitTypeList", LotteryEnum::getUserLimitTypeMap());
  34. $this->assignconfig("userLimitTypeList", json_encode(LotteryEnum::getUserLimitTypeMap()));
  35. $this->view->assign("guideStyleList", LotteryEnum::getGuideStyleMap());
  36. $this->assignconfig("guideStyleList", json_encode(LotteryEnum::getGuideStyleMap()));
  37. $this->view->assign("conditionTypeList", LotteryEnum::getConditionTypeMap());
  38. $this->assignconfig("conditionTypeList", json_encode(LotteryEnum::getConditionTypeMap()));
  39. // 奖品类型配置
  40. $this->view->assign("prizeTypeList", LotteryEnum::getPrizeTypeMap());
  41. $this->assignconfig("prizeTypeList", json_encode(LotteryEnum::getPrizeTypeMap()));
  42. // 奖品默认图片配置
  43. $this->assignconfig("prizeDefaultImages", json_encode(LotteryEnum::getPrizeDefaultImageMap()));
  44. // 渠道配置
  45. $this->view->assign("channelList", ChannelEnum::getChannelMap());
  46. $this->assignconfig("channelList", json_encode(ChannelEnum::getChannelMap()));
  47. // $this->view->assign("channelGroupList", ChannelEnum::getChannelGroupMap());
  48. // $this->assignconfig("channelGroupList", json_encode(ChannelEnum::getChannelGroupMap()));
  49. // $this->view->assign("channelsByGroup", ChannelEnum::getChannelsByGroup());
  50. // $this->assignconfig("channelsByGroup", json_encode(ChannelEnum::getChannelsByGroup()));
  51. $config = config('site');
  52. $lottery_guide = $config['lottery_guide'] ?? '';
  53. $prize_losing_lottery = $config['prize_losing_lottery'] ?? '';
  54. $this->view->assign("prize_losing_lottery", $prize_losing_lottery);
  55. $this->view->assign("lottery_guide", $lottery_guide);
  56. }
  57. /**
  58. * 查看
  59. */
  60. public function index()
  61. {
  62. //当前是否为关联查询
  63. $this->relationSearch = true;
  64. //设置过滤方法
  65. $this->request->filter(['strip_tags', 'trim']);
  66. if ($this->request->isAjax()) {
  67. //如果发送的来源是Selectpage,则转发到Selectpage
  68. if ($this->request->request('keyField')) {
  69. return $this->selectpage();
  70. }
  71. list($where, $sort, $order, $offset, $limit) = $this->buildparams();
  72. $list = $this->model
  73. ->with(['prize'])
  74. ->where($where)
  75. ->order($sort, $order)
  76. ->paginate($limit);
  77. foreach ($list as $row) {
  78. $row->visible(['id','name','description','cover_image','type','status','start_time','end_time','lottery_type','total_draw_count','total_people_count','total_win_count']);
  79. $row->visible(['prize']);
  80. // 处理奖品关联数据(hasMany关系)
  81. if (isset($row->prize) && $row->prize) {
  82. foreach ($row->prize as $prize) {
  83. if (is_object($prize) && method_exists($prize, 'visible')) {
  84. $prize->visible(['name','type','total_stock','remain_stock']);
  85. }
  86. }
  87. }
  88. }
  89. $result = array("total" => $list->total(), "rows" => $list->items());
  90. return json($result);
  91. }
  92. return $this->view->fetch();
  93. }
  94. /**
  95. * 添加
  96. */
  97. public function add()
  98. {
  99. if ($this->request->isPost()) {
  100. $params = $this->request->post("row/a");
  101. if ($params) {
  102. $params = $this->preExcludeFields($params);
  103. // 获取奖品数据
  104. $prizesJson = $this->request->post("prizes_json", "");
  105. $prizesData = [];
  106. if (!empty($prizesJson)) {
  107. $prizesData = json_decode($prizesJson, true);
  108. if (json_last_error() !== JSON_ERROR_NONE) {
  109. $this->error('奖品数据格式错误');
  110. }
  111. }
  112. // 获取规则数据
  113. $rulesJson = $this->request->post("rules_json", "");
  114. $rulesData = [];
  115. if (!empty($rulesJson)) {
  116. $rulesData = json_decode($rulesJson, true);
  117. if (json_last_error() !== JSON_ERROR_NONE) {
  118. $this->error('规则数据格式错误');
  119. }
  120. }
  121. // 处理活动基础数据
  122. $activityData = $this->processActivityData($params);
  123. // 验证奖品数据
  124. $this->validatePrizesData($prizesData);
  125. // 验证规则数据
  126. $this->validateRulesData($rulesData);
  127. $result = false;
  128. Db::startTrans();
  129. try {
  130. // 保存活动主表数据
  131. //是否采用模型验证
  132. if ($this->modelValidate) {
  133. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  134. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate;
  135. $this->model->validateFailException(true)->validate($validate);
  136. }
  137. $result = $this->model->allowField(true)->save($activityData);
  138. if ($result) {
  139. $activityId = $this->model->id;
  140. // 保存奖品数据
  141. $this->savePrizesData($activityId, $prizesData);
  142. // 保存参与条件数据
  143. $this->saveRulesData($activityId, $rulesData);
  144. }
  145. Db::commit();
  146. } catch (ValidateException $e) {
  147. Db::rollback();
  148. $this->error($e->getMessage());
  149. } catch (PDOException $e) {
  150. Db::rollback();
  151. $this->error($e->getMessage());
  152. } catch (Exception $e) {
  153. Db::rollback();
  154. $this->error($e->getMessage());
  155. }
  156. if ($result !== false) {
  157. $this->success();
  158. } else {
  159. $this->error(__('No rows were inserted'));
  160. }
  161. }
  162. $this->error(__('Parameter %s can not be empty', ''));
  163. }
  164. return $this->view->fetch();
  165. }
  166. /**
  167. * 处理活动基础数据
  168. */
  169. private function processActivityData($params)
  170. {
  171. // 处理时间字段
  172. if (isset($params['start_time']) && $params['start_time']) {
  173. $params['start_time'] = strtotime($params['start_time']);
  174. }
  175. if (isset($params['end_time']) && $params['end_time']) {
  176. $params['end_time'] = strtotime($params['end_time']);
  177. }
  178. if (isset($params['lottery_time']) && $params['lottery_time']) {
  179. $params['lottery_time'] = strtotime($params['lottery_time']);
  180. }
  181. // 处理JSON字段
  182. if (isset($params['user_limit_value']) && $params['user_limit_value']) {
  183. $params['user_limit_value'] = json_encode($params['user_limit_value']);
  184. }
  185. // 处理渠道字段(如果存在的话)
  186. if (isset($params['channels']) && is_array($params['channels'])) {
  187. $params['channels'] = json_encode($params['channels']);
  188. }
  189. // 处理兑奖期限设置
  190. if (isset($params['redeem_expire_type'])) {
  191. $params['redeem_expire_type'] = intval($params['redeem_expire_type']);
  192. if ($params['redeem_expire_type'] == 2) { // 固定时长
  193. $params['redeem_expire_days'] = isset($params['redeem_expire_days']) ? intval($params['redeem_expire_days']) : 7;
  194. } else {
  195. $params['redeem_expire_days'] = null;
  196. }
  197. }
  198. // 字段名映射 - 将前端字段名映射到实际数据表字段名
  199. if (isset($params['title'])) {
  200. $params['name'] = $params['title']; // 活动标题映射到name字段
  201. unset($params['title']);
  202. }
  203. if (isset($params['lottery_people'])) {
  204. $params['lottery_people_num'] = $params['lottery_people']; // 开奖人数字段名映射
  205. unset($params['lottery_people']);
  206. }
  207. if (isset($params['per_person_limit'])) {
  208. $params['person_limit_num'] = $params['per_person_limit']; // 单人限制次数字段名映射
  209. unset($params['per_person_limit']);
  210. }
  211. // 移除不属于活动表的字段
  212. unset($params['task_type']);
  213. // 设置默认值
  214. $params['type'] = 1; // 消费抽奖
  215. // 初始化统计字段
  216. if (!isset($params['total_draw_count'])) {
  217. $params['total_draw_count'] = 0;
  218. }
  219. if (!isset($params['total_people_count'])) {
  220. $params['total_people_count'] = 0;
  221. }
  222. if (!isset($params['total_win_count'])) {
  223. $params['total_win_count'] = 0;
  224. }
  225. return $params;
  226. }
  227. /**
  228. * 验证奖品数据
  229. */
  230. private function validatePrizesData($prizesData)
  231. {
  232. if (empty($prizesData)) {
  233. throw new Exception('请至少添加一个奖品');
  234. }
  235. if (count($prizesData) > 10) {
  236. throw new Exception('奖品数量不能超过10个');
  237. }
  238. $totalRate = 0;
  239. foreach ($prizesData as $prize) {
  240. if (!isset($prize['name']) || !isset($prize['type']) || !isset($prize['rate'])) {
  241. throw new Exception('奖品配置不完整');
  242. }
  243. $totalRate += floatval($prize['rate']);
  244. // 验证特定类型奖品的必需字段
  245. switch (intval($prize['type'])) {
  246. case 5: // 优惠券
  247. if (empty($prize['coupon_id'])) {
  248. throw new Exception('优惠券奖品必须选择优惠券');
  249. }
  250. break;
  251. case 8: // 商城奖品
  252. if (empty($prize['goods_id'])) {
  253. throw new Exception('商城奖品必须选择商品');
  254. }
  255. break;
  256. }
  257. }
  258. if (abs($totalRate - 100) > 0.01) {
  259. throw new Exception('奖品总概率必须等于100%,当前为' . $totalRate . '%');
  260. }
  261. }
  262. /**
  263. * 验证规则数据
  264. */
  265. private function validateRulesData($rulesData)
  266. {
  267. if (empty($rulesData)) {
  268. throw new Exception('请至少设置一种参与条件');
  269. }
  270. foreach ($rulesData as $type => $rule) {
  271. if (!isset($rule['type'])) {
  272. throw new Exception('规则配置不完整');
  273. }
  274. switch (intval($rule['type'])) {
  275. case 1: // 购买指定商品
  276. if (empty($rule['goods_ids'])) {
  277. throw new Exception('购买指定商品规则必须选择商品');
  278. }
  279. $goodsIds = json_decode($rule['goods_ids'], true);
  280. if (!is_array($goodsIds) || empty($goodsIds)) {
  281. throw new Exception('购买指定商品规则的商品数据格式错误');
  282. }
  283. break;
  284. case 2: // 单笔订单消费满额
  285. case 3: // 单次充值满额
  286. case 4: // 活动期间累计消费满额
  287. if (empty($rule['condition_value'])) {
  288. throw new Exception('消费/充值规则必须设置金额');
  289. }
  290. if (floatval($rule['condition_value']) <= 0) {
  291. throw new Exception('消费/充值规则金额必须大于0');
  292. }
  293. break;
  294. }
  295. }
  296. }
  297. /**
  298. * 保存奖品数据
  299. */
  300. private function savePrizesData($activityId, $prizesData)
  301. {
  302. $prizeModel = new \app\admin\model\lottery\LotteryPrize;
  303. foreach ($prizesData as $index => $prize) {
  304. $prizeData = [
  305. 'activity_id' => $activityId,
  306. 'name' => $prize['name'],
  307. 'type' => intval($prize['type']),
  308. 'image' => isset($prize['image']) ? $prize['image'] : '',
  309. 'probability' => floatval($prize['rate']),
  310. 'total_stock' => isset($prize['quantity']) ? intval($prize['quantity']) : 0,
  311. 'remain_stock' => isset($prize['quantity']) ? intval($prize['quantity']) : 0,
  312. 'sort_order' => $index,
  313. 'status' => 1,
  314. 'createtime' => time()
  315. ];
  316. // 根据奖品类型设置特定字段
  317. switch (intval($prize['type'])) {
  318. case LotteryEnum::PRIZE_TYPE_POINTS: // 积分 - 使用amount字段存储积分数量
  319. $prizeData['amount'] = isset($prize['points']) ? intval($prize['points']) : 0;
  320. $prizeData['description'] = '积分奖品';
  321. break;
  322. case LotteryEnum::PRIZE_TYPE_BALANCE: // 余额 - 使用amount字段存储余额金额
  323. $prizeData['amount'] = isset($prize['balance']) ? floatval($prize['balance']) : 0;
  324. $prizeData['description'] = '余额奖品';
  325. break;
  326. case LotteryEnum::PRIZE_TYPE_COUPON: // 优惠券
  327. $prizeData['coupon_id'] = isset($prize['coupon_id']) ? intval($prize['coupon_id']) : 0;
  328. $prizeData['description'] = '优惠券奖品';
  329. break;
  330. case LotteryEnum::PRIZE_TYPE_REDPACK: // 红包 - 使用amount字段存储红包金额
  331. $prizeData['amount'] = isset($prize['redpack_amount']) ? floatval($prize['redpack_amount']) : 0;
  332. $prizeData['description'] = '红包奖品';
  333. break;
  334. case LotteryEnum::PRIZE_TYPE_CODE: // 兑换码
  335. if (isset($prize['manual_codes']) && !empty($prize['manual_codes'])) {
  336. $codes = array_filter(array_map('trim', explode("\n", $prize['manual_codes'])));
  337. $prizeData['exchange_codes'] = json_encode($codes);
  338. $prizeData['used_codes'] = json_encode([]); // 初始化已使用列表
  339. $prizeData['total_stock'] = count($codes);
  340. $prizeData['remain_stock'] = count($codes);
  341. }
  342. $prizeData['description'] = '兑换码奖品';
  343. break;
  344. case LotteryEnum::PRIZE_TYPE_SHOP_GOODS: // 商城奖品
  345. $prizeData['goods_id'] = isset($prize['goods_id']) ? intval($prize['goods_id']) : 0;
  346. $prizeData['goods_sku_id'] = isset($prize['goods_sku_id']) ? intval($prize['goods_sku_id']) : null;
  347. $prizeData['description'] = '商城奖品';
  348. break;
  349. case LotteryEnum::PRIZE_TYPE_GOODS: // 实物奖品
  350. $prizeData['description'] = isset($prize['description']) ? $prize['description'] : '实物奖品';
  351. break;
  352. case LotteryEnum::PRIZE_TYPE_NO_PRIZE: // 未中奖
  353. default:
  354. $prizeData['description'] = '未中奖';
  355. break;
  356. }
  357. $prizeModel->create($prizeData);
  358. }
  359. }
  360. /**
  361. * 保存规则数据
  362. */
  363. private function saveRulesData($activityId, $rulesData)
  364. {
  365. $conditionModel = new \app\admin\model\lottery\Condition;
  366. foreach ($rulesData as $type => $rule) {
  367. $typeInt = intval($type);
  368. $conditionRecord = [
  369. 'activity_id' => $activityId,
  370. 'type' => $typeInt,
  371. 'reward_times' => 1,
  372. 'is_repeatable' => 0,
  373. 'status' => $conditionModel::STATUS_ENABLED,
  374. 'createtime' => time()
  375. ];
  376. switch ($typeInt) {
  377. case LotteryEnum::CONDITION_TYPE_BUY_GOODS: // 购买指定商品
  378. $goodsIds = isset($rule['goods_ids']) ? $rule['goods_ids'] : '[]';
  379. if (is_string($goodsIds)) {
  380. $goodsIds = json_decode($goodsIds, true) ?: [];
  381. }
  382. $conditionRecord['goods_ids'] = json_encode($goodsIds);
  383. $conditionRecord['goods_rule'] = isset($rule['goods_rule']) ? intval($rule['goods_rule']) : $conditionModel::GOODS_RULE_INCLUDE;
  384. break;
  385. case LotteryEnum::CONDITION_TYPE_ORDER_AMOUNT: // 单笔订单消费满额
  386. case LotteryEnum::CONDITION_TYPE_TOTAL_AMOUNT: // 活动期间累计消费满额
  387. $conditionRecord['condition_value'] = isset($rule['condition_value']) ? floatval($rule['condition_value']) : 0;
  388. if ($typeInt == LotteryEnum::CONDITION_TYPE_TOTAL_AMOUNT) {
  389. $conditionRecord['is_repeatable'] = 0; // 累计消费不可重复
  390. } else {
  391. $conditionRecord['is_repeatable'] = 1; // 其他类型可重复
  392. }
  393. break;
  394. }
  395. $conditionModel->create($conditionRecord);
  396. }
  397. }
  398. /**
  399. * 编辑
  400. */
  401. public function edit($ids = null)
  402. {
  403. $row = $this->model->get($ids);
  404. if (!$row) {
  405. $this->error(__('No Results were found'));
  406. }
  407. $adminIds = $this->getDataLimitAdminIds();
  408. if (is_array($adminIds)) {
  409. if (!in_array($row[$this->dataLimitField], $adminIds)) {
  410. $this->error(__('You have no permission'));
  411. }
  412. }
  413. if ($this->request->isPost()) {
  414. $params = $this->request->post("row/a");
  415. if ($params) {
  416. $params = $this->preExcludeFields($params);
  417. // 获取奖品数据
  418. $prizesJson = $this->request->post("prizes_json", "");
  419. $prizesData = [];
  420. if (!empty($prizesJson)) {
  421. $prizesData = json_decode($prizesJson, true);
  422. if (json_last_error() !== JSON_ERROR_NONE) {
  423. $this->error('奖品数据格式错误');
  424. }
  425. }
  426. // 获取规则数据
  427. $rulesJson = $this->request->post("rules_json", "");
  428. $rulesData = [];
  429. if (!empty($rulesJson)) {
  430. $rulesData = json_decode($rulesJson, true);
  431. if (json_last_error() !== JSON_ERROR_NONE) {
  432. $this->error('规则数据格式错误');
  433. }
  434. }
  435. // 处理活动基础数据
  436. $activityData = $this->processActivityData($params);
  437. // 验证奖品数据
  438. $this->validatePrizesData($prizesData);
  439. // 验证规则数据
  440. $this->validateRulesData($rulesData);
  441. $result = false;
  442. Db::startTrans();
  443. try {
  444. // 更新活动主表数据
  445. //是否采用模型验证
  446. if ($this->modelValidate) {
  447. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  448. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
  449. $row->validateFailException(true)->validate($validate);
  450. }
  451. $result = $row->allowField(true)->save($activityData);
  452. if ($result !== false) {
  453. $activityId = $ids;
  454. // 删除原有奖品数据
  455. Db::table('shop_lottery_prize')->where('activity_id', $activityId)->delete();
  456. // 删除原有条件数据
  457. Db::table('shop_lottery_condition')->where('activity_id', $activityId)->delete();
  458. // 保存新的奖品数据
  459. $this->savePrizesData($activityId, $prizesData);
  460. // 保存新的规则数据
  461. $this->saveRulesData($activityId, $rulesData);
  462. }
  463. Db::commit();
  464. } catch (ValidateException $e) {
  465. Db::rollback();
  466. $this->error($e->getMessage());
  467. } catch (PDOException $e) {
  468. Db::rollback();
  469. $this->error($e->getMessage());
  470. } catch (Exception $e) {
  471. Db::rollback();
  472. $this->error($e->getMessage());
  473. }
  474. if ($result !== false) {
  475. $this->success();
  476. } else {
  477. $this->error(__('No rows were updated'));
  478. }
  479. }
  480. $this->error(__('Parameter %s can not be empty', ''));
  481. }
  482. // 处理时间显示
  483. if ($row->start_time) {
  484. $row->start_time = date('Y-m-d H:i:s', $row->start_time);
  485. }
  486. if ($row->end_time) {
  487. $row->end_time = date('Y-m-d H:i:s', $row->end_time);
  488. }
  489. if ($row->lottery_time) {
  490. $row->lottery_time = date('Y-m-d H:i:s', $row->lottery_time);
  491. }
  492. // 处理JSON字段
  493. if ($row->user_limit_value) {
  494. $row->user_limit_value = json_decode($row->user_limit_value, true);
  495. }
  496. // 处理渠道字段
  497. if ($row->channels) {
  498. $row->channels = json_decode($row->channels, true);
  499. }
  500. // 字段名映射 - 将数据表字段名映射回前端字段名
  501. if (isset($row->name)) {
  502. $row->title = $row->name; // 将name映射回title供前端使用
  503. }
  504. if (isset($row->lottery_people_num)) {
  505. $row->lottery_people = $row->lottery_people_num; // 映射回前端字段名
  506. }
  507. if (isset($row->person_limit_num)) {
  508. $row->per_person_limit = $row->person_limit_num; // 映射回前端字段名
  509. }
  510. // 获取奖品数据
  511. $prizes = Db::table('shop_lottery_prize')
  512. ->where('activity_id', $ids)
  513. ->order('sort_order', 'asc')
  514. ->select();
  515. // 处理奖品数据的字段映射,转换为前端需要的格式
  516. $processedPrizes = [];
  517. foreach ($prizes as $prize) {
  518. $prizeData = [
  519. 'id' => $prize['id'],
  520. 'name' => $prize['name'],
  521. 'type' => intval($prize['type']),
  522. 'image' => $prize['image'] ?? '',
  523. 'description' => $prize['description'] ?? '',
  524. 'quantity' => intval($prize['total_stock']), // 前端使用quantity字段
  525. 'rate' => floatval($prize['probability']), // 前端使用rate字段
  526. 'sort_order' => intval($prize['sort_order']),
  527. ];
  528. // 根据奖品类型设置特定字段(保留所有类型的处理逻辑,但只显示启用的类型)
  529. switch (intval($prize['type'])) {
  530. case LotteryEnum::PRIZE_TYPE_NO_PRIZE:
  531. // 未中奖项的特殊处理
  532. $prizeData['quantity'] = 0; // 未中奖项数量固定为0
  533. break;
  534. case LotteryEnum::PRIZE_TYPE_GOODS:
  535. // 实物奖品的特殊处理
  536. break;
  537. case LotteryEnum::PRIZE_TYPE_POINTS:
  538. $prizeData['points'] = intval($prize['amount'] ?? 0);
  539. break;
  540. case LotteryEnum::PRIZE_TYPE_BALANCE:
  541. $prizeData['balance'] = floatval($prize['amount'] ?? 0);
  542. break;
  543. case LotteryEnum::PRIZE_TYPE_COUPON:
  544. $prizeData['coupon_id'] = $prize['coupon_id'] ?? '';
  545. $prizeData['coupon_name'] = $prize['coupon_name'] ?? '';
  546. break;
  547. case LotteryEnum::PRIZE_TYPE_REDPACK:
  548. $prizeData['redpack_amount'] = floatval($prize['amount'] ?? 0);
  549. break;
  550. case LotteryEnum::PRIZE_TYPE_CODE:
  551. $prizeData['code_type'] = $prize['code_type'] ?? 'auto';
  552. if (!empty($prize['exchange_codes'])) {
  553. $codes = json_decode($prize['exchange_codes'], true) ?: [];
  554. $prizeData['manual_codes'] = implode("\n", $codes);
  555. }
  556. break;
  557. case LotteryEnum::PRIZE_TYPE_SHOP_GOODS:
  558. $prizeData['goods_id'] = $prize['goods_id'] ?? '';
  559. $prizeData['goods_name'] = $prize['goods_name'] ?? '';
  560. break;
  561. }
  562. $processedPrizes[] = $prizeData;
  563. }
  564. // 使用处理后的奖品数据
  565. $prizes = $processedPrizes;
  566. // 获取条件数据
  567. $conditions = Db::table('shop_lottery_condition')
  568. ->where('activity_id', $ids)
  569. ->select();
  570. // 处理条件数据的字段映射并构建规则数据
  571. $rulesData = [];
  572. foreach ($conditions as $condition) {
  573. $rule = [
  574. 'type' => $condition['type']
  575. ];
  576. // 根据条件类型设置特定字段
  577. switch (intval($condition['type'])) {
  578. case LotteryEnum::CONDITION_TYPE_BUY_GOODS:
  579. $rule['goods_rule'] = $condition['goods_rule'] ?? 1;
  580. $rule['goods_ids'] = $condition['goods_ids'] ?? '[]';
  581. // 解析商品ID数组用于前端显示
  582. $rule['goods_ids_array'] = json_decode($condition['goods_ids'], true) ?: [];
  583. break;
  584. case LotteryEnum::CONDITION_TYPE_ORDER_AMOUNT:
  585. case LotteryEnum::CONDITION_TYPE_TOTAL_AMOUNT:
  586. $rule['condition_value'] = $condition['condition_value'] ?? 0;
  587. break;
  588. }
  589. $rulesData[$condition['type']] = $rule;
  590. }
  591. // echo "<pre>";
  592. // print_r($prizes);
  593. // echo "</pre>";
  594. // exit;
  595. $this->view->assign("row", $row);
  596. // 使用assignconfig传递数据给JavaScript
  597. $this->assignconfig("existingPrizes", $prizes); // 奖品数据
  598. $this->assignconfig("existingRulesData", $rulesData); // 规则数据
  599. $this->assignconfig("existingConditions", $conditions); // 条件数据
  600. $this->assignconfig("existingTaskTypes", array_keys($rulesData)); // 任务类型
  601. // 保持向后兼容,仍然传递给模板
  602. $this->view->assign("prizes", $prizes);
  603. $this->view->assign("rulesData", $rulesData);
  604. $this->view->assign("conditions", $conditions);
  605. $this->view->assign("taskTypes", array_keys($rulesData));
  606. return $this->view->fetch();
  607. }
  608. }