db->close(); echo '开渠道列处理开始,接收订单id:' . implode(',', $data['order_ids']); $mall_id = $data['mall_id']; $activity_id = $data['activity_id']; $goods_id = $data['goods_id']; $order_ids = $data['order_ids']; if (empty($order_ids)) throw new Exception('订单ids 不能为空'); // 拼团中奖处理 //todo 读缓存 $activity = LuckyGroupActivity::findOne(['id' => $activity_id, 'mall_id' => $mall_id, 'status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]]); if (empty($activity)) throw new Exception('未找到幸运拼团活动(' . $activity_id . ')'); //拼团开奖 $win_loss_logic = new WinLossLogic(); $win_loss_logic->openReward($activity, $goods_id, $order_ids); return true; } catch (Exception $e) { echo '开奖队列处理失败' . PHP_EOL . $e->getFile() . '(' . $e->getLine() . ')' . PHP_EOL . "message:" . $e->getMessage(); var_dump('开奖队列处理失败处理失败' . PHP_EOL . $e->getFile() . '(' . $e->getLine() . ')' . PHP_EOL . "message:" . $e->getMessage()); return false; } } //禁用活动 public static function disableActivity($data){ $order_ids = $data['order_ids']; $win_loss_logic = new WinLossLogic(); $win_loss_logic->disableActivity($order_ids); } }