qimall/addons/IssueCoupons/backend/controllers/DefaultController.php

<?php

namespace addons\IssueCoupons\backend\controllers;

use addons\Coupon\common\models\AddonsCoupon;
use addons\ElectronCoupon\common\models\ElectronCoupon;
use addons\IssueCoupons\common\enums\IssueCouponsEnum;
use addons\IssueCoupons\common\logic\Send;
use addons\IssueCoupons\common\models\IssueCouponsRule;
use common\enums\AddonsEnum;
use common\enums\RabbitMqEnum;
use common\enums\StatusEnum;
use common\models\mall\MallAddons;
use common\models\user\User;
use common\models\user\UserLabel;
use common\models\user\UserLevel;
use Yii;
use common\controllers\AddonsController;
use yii\db\Exception;

/**
 * 默认控制器
 *
 * Class DefaultController
 * @package addons\IssueCoupons\backend\controllers
 */
class DefaultController extends BaseController
{
    public $enableCsrfValidation = false;
    /**
     * 获取配置
     * @Author: ltm
     * @DateTime: 2022/06/28 0015 10:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array|string|\yii\web\Response
     */
    public function actionIndex()
    {
        $retuest = Yii::$app->request;
        if ($retuest->isAjax) {

            if ($retuest->isPost) {
                $params = Yii::$app->request->post();
                // 检查提交的参数
                $res = Yii::$app->services->validate->validate($params,[
                    [['name'], 'string'],
                    [['create_time'],'safe']
                ]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                $where = [];
                $time = time();
                !empty($params['name']) && $where[] = ['like', 'name', $params['name']];
                if($params['create_time']) $where[] = ['between', 'created_at', strtotime($params['create_time'][0]),strtotime($params['create_time'][1])];
                $where[] = ['=', 'mall_id', $this->mall_id];
                $where[] = ['>=', 'status', StatusEnum::DISABLED];
                $order = 'id desc';
                $params = array('where' => $where, 'order'=>$order, 'limit' => $params['limit']);
                $list = IssueCouponsRule::listPage($params, false, true);
                if($list['list']){
                    foreach ($list['list'] as $k => $v){
                        if($v['coupon']){
                            $coupon = json_decode($v['coupon'],true);
                            if($coupon){
                                $coupon_array = array_sum(array_column($coupon,'num'));
                                $list['list'][$k]['coupon_num'] = $coupon_array;
                            }

                        }
                        if($v['e_coupon']){
                            $e_coupon = json_decode($v['e_coupon'],true);
                            if($e_coupon){
                                $e_coupon_array = array_sum(array_column($e_coupon,'num'));
                                $list['list'][$k]['e_coupon_num'] = $e_coupon_array;
                            }

                        }
                    }
                }
                $list['now_time'] = time();
                $this->success('获取成功', $list);
            }
        } else {
            return $this->render($this->action->id);
        }
    }

    /**
     * 获取配置
     * @Author: ltm
     * @DateTime: 2022/06/28 0015 10:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array|string|\yii\web\Response
     */
    public function actionEdit()
    {
        try {
            $request = Yii::$app->request;
            if ($request->isAjax) {
                // 提交等级内容
                if ($request->isPost) {
                    $params = Yii::$app->request->post();
                    $res = Yii::$app->services->validate->validate($params, [
                        [['timing_time','name','grant_object','redpack','redpack_remark','score','score_remark','balance'], 'safe'],
                        [['balance_remark','grant_object_content','coupon','e_coupon','id'], 'safe'],
                    ]);
                    if ($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                    if(!$params['grant_object_content']) $params['grant_object_content'] = 1;
                    $params['mall_id'] = $this->mall_id;
                    $params['timing_time'] = strtotime($params['timing_time']);
                    $params = IssueCouponsRule::exceptNullVal($params);

                    if(isset($params['status']) && !in_array($params['status'],[StatusEnum::DISABLED,StatusEnum::ENABLED,StatusEnum::DELETE])) throw new Exception("参数错误");;
                    //var_dump($params);die;
                    $params['coupon'] = json_encode($params['coupon']);
                    $params['e_coupon'] = json_encode($params['e_coupon']);
                    if($params['grant_object_content']) $params['grant_object_content'] = json_encode($params['grant_object_content']);
                    $res = IssueCouponsRule::setData($params);
                    if ($res === false) throw new Exception(IssueCouponsRule::getStaticError());
                    return $this->success('操作成功');
                }else{
                    $params = Yii::$app->request->get();
                    $res = Yii::$app->services->validate->validate($params, [
                        [['id'], 'integer'],
                    ]);
                    if ($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                    $where[] = ['=', 'mall_id', $this->mall_id];
                    $where[] = ['>=', 'status', StatusEnum::DISABLED];
                    $where[] = ['=', 'id', $params['id']];
                    $data['detail'] = IssueCouponsRule::getOne($where,true);
                    $timing_time = $data['detail']['timing_time'];
                    $data['detail']['timing_time'] = date('Y-m-d H:i:s',$timing_time);
                    $data['detail']['coupon'] = json_decode($data['detail']['coupon']);
                    if(is_array($data['detail']['coupon'])){
                        $coupon_ids = array_column($data['detail']['coupon'],'id');
                        $coupon_ids_data = array_column($data['detail']['coupon'],'num','id');
                        if($coupon_ids){
                            $coupon_where[] = ['in','id',$coupon_ids];
                            $coupon_data = AddonsCoupon::lists(['where'=> $coupon_where,'limit'=>'2000'],true);
                            if($coupon_data){
                                foreach ($coupon_data as $k=>$v){
                                    $coupon_data[$k]['num'] = $coupon_ids_data[$v['id']];
                                    $coupon_data[$k]['relevant_id'] = $v['id'];
                                    $coupon_data[$k]['discount_method'] = $v['type']==1? $v['discount'].'折' : '优惠'.$v['sub_price'].'元';
                                }
                            }
                            $data['coupon_select_list'] = $coupon_data;
                        }

                    }
                    $data['detail']['e_coupon'] = json_decode($data['detail']['e_coupon']);
                    if(is_array($data['detail']['e_coupon'])){
                        $e_coupon_ids = array_column($data['detail']['e_coupon'],'id');
                        $e_coupon_ids_data = array_column($data['detail']['e_coupon'],'num','id');
                        if($e_coupon_ids){
                            $e_coupon_where[] = ['in','id',$e_coupon_ids];
                            $e_coupon_data = ElectronCoupon::lists(['where'=> $e_coupon_where,'limit'=>'2000'],true);
                            //var_dump($where);
                            if($e_coupon_data){
                                foreach ($e_coupon_data as $k=>$v){
                                    $e_coupon_data[$k]['num'] = $e_coupon_ids_data[$v['id']];
                                    $e_coupon_data[$k]['coupon_id'] = $v['id'];
                                }
                            }
                            $data['e_coupon_select_list'] = $e_coupon_data;
                        }
                    }
                    $data['detail']['grant_object_content'] = json_decode($data['detail']['grant_object_content']);

                    //var_dump($data['detail']['goods_ids']);
                    $data['picker_date'] = date('Y-m-d', $timing_time);
                    $data['picker_time'] = date('H:i', $timing_time);
                    $this->success('获取成功', $data);
                }
            }
        } catch (\Exception $e) {
            return $this->error($e->getMessage(), []);
        }

        $has_coupon = MallAddons::isInstall($this->mall_id,AddonsEnum::ADDONS_NAME_COUPON);
        $has_e_coupon = MallAddons::isInstall($this->mall_id,IssueCouponsEnum::ADDONSELETRONCOUPON);
        $has_redpack = MallAddons::isInstall($this->mall_id,IssueCouponsEnum::ADDONSREDPACK);
        return $this->render($this->action->id,['has_coupon' => $has_coupon,
            'has_e_coupon' => $has_e_coupon,
            'has_redpack' => $has_redpack]);
    }

    /**
     * 获取配置
     * @Author: ltm
     * @DateTime: 2022/06/28 0015 10:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array|string|\yii\web\Response
     */
    public function actionGetObject()
    {
        $request = Yii::$app->request;
        if ($request->isGet) {
            $params = Yii::$app->request->get();
            $res = Yii::$app->services->validate->validate($params, [
                [['type','user_ids'], 'integer'],
            ]);
            $list = [];
            switch ($params['type']){
                case 2:
                    $list = UserLevel::getUserLevelArr($this->mall_id);
                    $data = [];
                    if($list){
                        foreach ($list as $k => $v){
                            $array['id'] = $k;
                            $array['name'] = $v;
                            $data[] = $array;
                        }
                    }
                    break;
                case 3:
                    $where[] = ['=', 'status', StatusEnum::ENABLED];
                    $where[] = ['=', 'mall_id', $this->mall_id];
                    $params['where'] = $where;
                    $list = UserLabel::lists($params,true);
                    if($list){
                        foreach ($list as $k => $v){
                            $array['id'] = $v['id'];
                            $array['name'] = $v['name'];
                            $data[] = $array;
                        }
                    }
                    break;
                case 4:
                    if($params['user_ids']){
                        //$user_ids = array_column($params['user_ids'],'id');
                        if(is_array($params['user_ids'])){
                            $user_where[] = ['in','id',$params['user_ids']];
                            $user_data = User::lists(['where'=>$user_where,'select'=>'id,nickname,username,mobile,avatar_url','limit'=>'2000'],true);
                            if($user_data){
                                foreach ($user_data as $k=>$v){
                                    $array = [];
                                    $array['id'] = $v['id'];
                                    $array['name'] = $v['nickname']?$v['nickname']:$v['username'];
                                    $data[] = $array;
                                }
                            }
                        }
                    }
                    break;
            }
            $this->success('获取成功', $data);
        }

    }

    /**
     * 获取商品独立设置的优惠券设置
     * @Author: ltm
     * @DateTime: 2022/7/4  15:53
     * @Copyright: copyright (c) 2021 xuan-e
     * @return mixed|void
     */
    public function actionSelectUser()
    {
        if (Yii::$app->request->isAjax && Yii::$app->request->isPost) {
            $params = Yii::$app->request->post();
            $params['where'][] = ['mall_id' => $this->mall_id];
            $params['where'][] = ['status' => [StatusEnum::ENABLED]];
            if (!empty($params['keyword'])) $params['where'][] = ['like', 'nickname', $params['keyword']];
            if (!empty($params['mobile'])) $params['where'][] = ['=', 'mobile', $params['mobile']];
            if (!empty($params['user_id'])) $params['where'][] = ['=', 'id', $params['user_id']];
            $params['order'] = 'id desc';
            $params['select'] = 'id,nickname,username,mobile,avatar_url';
            $list = User::listPage($params);
            return $this->success('操作成功', $list);
        }

    }

    /**
     * 获取配置
     * @Author: ltm
     * @DateTime: 2022/06/28 0015 10:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array|string|\yii\web\Response
     */
    public function actionHandle()
    {
        $request = Yii::$app->request;
        if ($request->isAjax && $request->isPost) {
            $params = Yii::$app->request->post();
            // 检查提交的参数
            $res = Yii::$app->services->validate->validate($params,[
                [['item_id','id','status'], 'integer']
            ]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
            $params['mall_id'] = $this->mall_id;
            // 修改数据
            $res = IssueCouponsRule::setData($params);
            if($res == false) return $this->error("修改失败" . IssueCouponsRule::getStaticError());

            return $this->success("修改成功");
        }
    }

    /**
     * 进行手动执行发放
     * @Author: ltm
     * @DateTime: 2022/06/28 0015 10:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array|string|\yii\web\Response
     */
    public function actionSend()
    {
        $request = Yii::$app->request;
        if ($request->isAjax && $request->isPost) {
            $params = Yii::$app->request->post();
            // 检查提交的参数
            $res = Yii::$app->services->validate->validate($params,[
                [['id','status'], 'integer']
            ]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
            $params['mall_id'] = $this->mall_id;
            // 修改数据
//            $send_res =new Send();
//            $res = $send_res->handsend($params);
            $data['id'] = $params['id'];
            $data['mall_id'] = $params['mall_id'];
            Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_TASK, RabbitMqEnum::TASK_QUEUE, $data, Send::class, 'handsend');
            if($res == false) return $this->error("修改失败" . IssueCouponsRule::getStaticError());

            return $this->success("操作成功");
        }
    }
    public function actionTest(){
//        $send_res =new Send();
//        $res = $send_res->execute();
       Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_TASK, RabbitMqEnum::TASK_QUEUE, [], Send::class, 'execute');
    }

}