qimall/addons/LuckyGroup/common/logic/order/OpenRewardLogic.php

<?php

namespace addons\LuckyGroup\common\logic\order;

use addons\LuckyGroup\common\models\LuckyGroupActivity;
use addons\LuckyGroup\common\models\LuckyGroupOrder;
use common\enums\StatusEnum;
use yii\db\Exception;

class OpenRewardLogic
{

    //开团
    public static function handleSync($data)
    {
        try {
            \Yii::$app->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);
    }
}