qimall/addons/Rebate/backend/controllers/IndexController.php

<?php
/*
 * @Descripttion:
 * @copyright: Copyright (c) 2021 广东七件事集团
 * @Author: lun
 * @Date: 2021-12-28 21:23:39
 */
/**
 * @copyright: Copyright (c) 2021
 * Created by PhpStorm
 * Author: lun
 * Date: 2021-12-28
 * Time: 15:41
 */


namespace addons\Rebate\backend\controllers;

use addons\Rebate\common\enums\RebateEnum;
use addons\Rebate\common\logic\RewardLogic;
use addons\Rebate\common\models\Rebate;
use addons\Rebate\common\models\RebateBuy;
use addons\Rebate\common\models\RebateRewardLog;
use addons\Rebate\common\models\RebateUserLevel;
use common\enums\AddonsEnum;
use common\enums\StatusEnum;
use common\models\goods\Goods;
use common\models\mall\MallAddons;
use common\models\user\User;
use common\models\user\UserLevel;
use common\models\goods\GoodsCate;
use Yii;
use yii\db\Expression;
use yii\helpers\Json;

class IndexController extends BaseController
{
    public $enableCsrfValidation = false;

    /**
     * 活动列表
     * @Author: lun
     * @DateTime: 2022/1/15 0015 9:59
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return string|\yii\web\Response
     */
    public function actionIndex()
    {
        if (Yii::$app->request->isAjax) {
            if (Yii::$app->request->isGet) {
                // 处理 GET 请求
                $params = Yii::$app->request->get();
            } elseif (Yii::$app->request->isPost) {
                // 处理 POST 请求
                $params = Yii::$app->request->post();
            }
            // 检查提交的参数
            $res = Yii::$app->services->validate->validate($get, [
                [['start_at','end_at','reward_type','status'], 'integer'],
                [['title'], 'string'],
            ]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());

            $time = time();
            $where = [];
            $where[] = ['=', 'mall_id', $this->mall_id];
            $where[] = ['<>', 'status', StatusEnum::DELETE];
            !empty($params['title']) && $where[] = ['like', 'title', $params['title']];
            !empty($params['reward_type']) && $where[] = ['=', 'reward_type', $params['reward_type']];
            // 根据需求虚拟订单只显示进行中的
            if (Yii::$app->request->isPost) {
                $where[] = ['<', 'start_at', $time];
                $where[] = ['>', 'end_at', $time];
                $where[] = ['=', 'status', StatusEnum::ENABLED];
            }
            if(!empty($params['status'])) {// 状态条件筛选
                switch($params['status']) {
                    case 1:// 进行中
                        $where[] = ['<', 'start_at', $time];
                        $where[] = ['>', 'end_at', $time];
                        $where[] = ['=', 'status', StatusEnum::ENABLED];
                    break;
                    case 2:// 已过期
                        $where[] = ['<', 'end_at', $time];
                    break;
                    case 3:// 停用
                        $where[] = ['=', 'status', StatusEnum::DISABLED];
                    break;
                    case 4:// 未开始
                        $where[] = ['>', 'start_at', $time];
                    break;
                }
            }

            $with = ['statistics' => function($query){
                $query->select("r_id,join_num,pay_num,pay_money");
            }];
            $order = 'created_at desc';
            $select = "id,title,start_at,end_at,item_id,reward_type,status,created_at";
            $params = compact('where','order','select','with');
            $list = Rebate::listPage($params, false, true);
            if(!empty($list['list'])){
                foreach ($list['list'] as&$item){
                    $item['start_date'] = date("Y-m-d H:i",$item['start_at']);
                    $item['end_date'] = date("Y-m-d H:i",$item['end_at']);
                }
            }
            return $this->success('获取成功', array_merge($list, ['now_time' => $time]));
        }
        return $this->render($this->action->id);
    }

    /**
     * @Author: lun
     * Date: 2021-12-29
     * Time: 21:36
     * @Note:编辑
     */
    public function actionEdit()
    {
        if (\Yii::$app->request->isAjax) {
            if (\Yii::$app->request->isPost) {
                $params = Yii::$app->request->post();

                // 判断商品是否已存在,存在则不保存
                /*$check_goods = Rebate::checkGoods($this->mall_id, $params['item_id'], $params['id'] ?? 0);
                if($check_goods == false) return $this->error("该活动的商品已被其他活动使用，请另选商品");*/
                $params['item_type'] = RebateEnum::ITEM_TYPE_GOODS;
                if (!empty($params['cate_info'])) {
                    $params['item_type'] = RebateEnum::ITEM_TYPE_GOODS_CATE;
                    $params['item_info'] = $params['cate_info'];
                }

                // 保存数据
                $res = Rebate::setData($this->mall_id, $params);
                if($res == false) return $this->error(Rebate::getStaticError());

                return $this->success("保存成功");
            } else {
                $params = Yii::$app->request->get();
                // 检查提交的参数
                $res = Yii::$app->services->validate->validate($get,[[['id'], 'integer']]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                

                if(!empty($params['id'])) {
                    $detail = Rebate::getOne([['id' => $params['id']]],true);
                    if($detail) {
                        $detail['consume_level'] = empty($detail['consume_level']) ? [] : Json::decode($detail['consume_level'], true);
                        $detail['initiate_level'] = empty($detail['initiate_level']) ? [] : Json::decode($detail['initiate_level'], true);
                        if ($detail['item_type'] == RebateEnum::ITEM_TYPE_GOODS_CATE) {
                            $detail['cate_info'] = Json::decode($detail['item_info'], true);
                            $detail['item_info'] = [];
                        } else {
                            $detail['item_info'] = Goods::lists(['where' => [['id' => $detail['item_id']]], 'select' => 'id,price,goods_name name,stock,cover_pic']);
                            $detail['cate_info'] = [];
                        }
                        $detail['reward_info'] = Json::decode($detail['reward_info'], true);
                        $data['detail'] = $detail;
                    }
                }

                // 获取会员等级
                $level_arr = [['name' => '默认等级', 'level' => 0]];
                $member_arr = UserLevel::getUserLevelArr($this->mall_id, 2, true);
                $data['level_arr'] = array_merge($level_arr, $member_arr);
                $member_arr =  RebateUserLevel::getRebateUserLevelArr($this->mall_id,2);
                $data['rebate_user_level_arr'] = array_merge($level_arr, $member_arr);
                return $this->success("保存成功", $data);
            }
        }
        //判断是否安装红包拓客插件
        $has_redpack = MallAddons::isInstall($this->mall_id,AddonsEnum::ADDONS_NAME_REDPACK);
        // 判断优惠券插件是否安装
        $has_coupon = MallAddons::isInstall($this->mall_id,AddonsEnum::ADDONS_NAME_COUPON);
        return $this->render($this->action->id,['has_coupon' => $has_coupon, 'has_redpack' => $has_redpack]);
    }


    /**
     * 操作处理
     *
     * @return void
     */
    public function actionHandle()
    {
        $request = Yii::$app->request;
        if ($request->isAjax && $request->isPost) {
            $params = Yii::$app->request->post();
            // 检查提交的参数
            $res = Yii::$app->services->validate->validate($get,[
                [['item_id','id','status'], 'integer']
            ]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());

            // 判断商品是否已存在,存在则不保存
            /*if($params['status'] == 1) {
                $check_goods = Rebate::checkGoods($this->mall_id, $params['item_id'], $params['id'] ?? 0);
                if($check_goods == false) return $this->error("该活动的商品已被其他活动使用，请另选商品");
            }*/

            // 修改数据
            $res = Rebate::setData($this->mall_id, $params);
            if($res == false) return $this->error("修改失败" . Rebate::getStaticError());

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


    /**
     * 活动列表
     * @Author: lun
     * @DateTime: 2022/1/15 0015 10:10
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return mixed|string|void
     */
    public function actionRewardLog()
    {
        if (Yii::$app->request->isAjax) {
            $params = Yii::$app->request->get();
            // 检查提交的参数
            $res = Yii::$app->services->validate->validate($get,[
                [['rid','user_id','mobile'], 'integer'],
                [['btw_time'], 'safe']
            ]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
            $where = [];
            $where[] = ['=', 'mall_id', $this->mall_id];
            $where[] = ['=', 'r_id', $params['rid']];
            !empty($params['user_id']) && $user_id[] = $params['user_id'];
            if(!empty($params['mobile'])) {
                $user_id[] = User::find()->select("id")->where(['mobile' => $params['mobile']])->scalar();
            }
            !empty($user_id) && $where[] = ['in', 'user_id', $user_id];
            !empty($params['btw_time']) && $where[] = ['between', 'created_at', strtotime($params['btw_time'][0]), strtotime($params['btw_time'][1])];
            $where[] = ['=', 'status', 1];
            $with = ['user' => function($query){
                $query->select("id,nickname,mobile,avatar_url");
            }];
            $order = 'created_at desc';
            $select = "id,r_id,user_id,reward_title,content,created_at,is_frozen";
            $params = compact('where','order','select','with');
            $list = RebateRewardLog::listPage($params, false, true);

            foreach ($list['list'] as &$item) {
                $item['is_frozen_text'] = RebateEnum::FROZEN_STATUS_MAP[$item['is_frozen']] ?? '-';
            }

            return $this->success("获取成功", $list);
        }
        return $this->render($this->action->id);
    }

    /**
     * 获取奖励关联的订单
     * @Author：lun
     * @Date：2024-01-17 11:31
     * @Copyright：copyright（c）2023 广东七件事集团
     * @return mixed|string|void|null
     */
    public function actionRewardBuyLogs()
    {
        if (Yii::$app->request->isAjax) {
            if (Yii::$app->request->isGet) {
                $params = Yii::$app->request->get();
                // 检查提交的参数
                $res = Yii::$app->services->validate->validate($params,[
                    [['reward_id','pid'], 'required'],
                    [['reward_id','pid'], 'integer']
                ]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                $where = [];
                $where[] = ['=', 'mall_id', $this->mall_id];
                $where[] = ['=', 'pid', $params['pid']];
                $where[] = ['=', 'reward_id', $params['reward_id']];
                $where[] = ['=', 'status', StatusEnum::ENABLED];

                $with = ['user' => function($query){
                    $query->select("id,nickname,mobile,avatar_url");
                }];
                $order = 'created_at desc';
                $select = "id,user_id,order_no,pay_at,updated_at";
                $params = compact('where','order','select','with');
                $list = RebateBuy::lists($params, true);
                return $this->success("获取成功", $list);
            }
        } else {
            return $this->render($this->action->id);
        }
    }

    /**
     * @return string|void
     */
    public function actionActivityLog()
    {
        if (!Yii::$app->request->isAjax) {
            return $this->render($this->action->id);
        }
        $request = Yii::$app->request->get();
        $rid = $request['rid'] ?? 0;
        if (!is_numeric($rid)) {
            $this->error('参数错误');
            return;
        }

        $select = "pid, COUNT(*) AS order_total," .
            "COUNT(IF(order_settlement_status = 1, 1, NULL)) AS achieved_total," .
            "COUNT(IF(order_settlement_status = 0 AND refund_id = 0, 1, NULL)) AS unachieved_total," .
            "COUNT(IF(order_settlement_status = 0 AND refund_id > 0, 1, NULL)) AS expired_total";

        $where = [];
        $where[] = ['=', 'mall_id', $this->mall_id];
        $where[] = ['=', 'r_id', $rid];
        $where[] = ['=', 'status', StatusEnum::ENABLED];
        !empty($request['user_id']) && $user_id[] = $request['user_id'];
        if(!empty($request['mobile'])) {
            $user_id[] = User::find()->select("id")->where(['mobile' => $request['mobile']])->scalar();
        }
        !empty($user_id) && $where[] = ['in', 'pid', $user_id];
        !empty($request['created_at']) && $where[] = ['between', 'created_at', strtotime($request['created_at'][0]), strtotime($request['created_at'][1])];

        $params = [
            'select' => new Expression($select),
            'group' => 'pid',
            'where' => $where,
            'with' => [
                'pUser' => function ($query) {
                    $query->select('id, nickname, avatar_url, mobile');
                }
            ]
        ];
        $list = RebateBuy::listPage($params);
        $this->success('success', $list);
    }

    /**
     * @return void
     */
    public function actionActivityOrderDetails()
    {
        $rid = $this->request->get('rid', 0);
        $pid = $this->request->get('pid', 0);
        if (!is_numeric($rid) || !is_numeric($pid)) {
            $this->error('参数错误');
            return;
        }

        $select = 'id, reward_id, user_id, order_no, pay_at, order_settlement_status, refund_id, is_reward_trigger, position';
        $params = [
            'select' => $select,
            'where' => [
                [
                    'mall_id' => $this->mall_id,
                    'status' => StatusEnum::ENABLED,
                    'r_id' => $rid,
                    'pid' => $pid
                ]
            ],
            'with' => [
                'user' => function ($query) {
                    $query->select('id, nickname, avatar_url, mobile');
                },
                'rewardLog' => function ($query) {
                    $query->select('id, content');
                }
            ],
            'order' => 'order_settlement_status desc, position asc'
        ];
        $list = RebateBuy::listPage($params);

        if (!empty($list['list'])) {
            foreach ($list['list'] as &$item) {
                $item['pay_at_text'] = $item['pay_at'] ? date('Y-m-d H:i:s', $item['pay_at']) : '-';
                $item['order_settlement_status_text'] = $item['order_settlement_status'] ? '已达标' : ($item['refund_id'] > 0 ? '已失效' : '未达标');
                $item['position'] = !$item['position'] ? '-' : $item['position'];
            }
        }

        $this->success('success', $list);
    }

    public function actionCateList(){
        if (Yii::$app->request->isAjax) {
            $keyword =  Yii::$app->request->get('name','');
            $cate_id =  Yii::$app->request->get('id','');
            $limit =  Yii::$app->request->get('limit','10');
            $where = [['mall_id' => $this->mall['id'],'parent_id' => 0,'mch_id' => $this->admin->mch_id,'status' => [StatusEnum::ENABLED,StatusEnum::DISABLED]]];
            $keyword && $where[] = ['like','name', '%'. $keyword.'%',false];
            $cate_id && $where[] = ['=','id', $cate_id];
            $order = 'sort asc,created_at desc';
            $with = [];
            $select = 'id,name,pic,sort,created_at';
            $params = compact('where', 'select', 'order','with', 'limit');
            $list = GoodsCate::listPage($params);
            if($list === false) return $this->error(GoodsCate::getStaticError());
            return $this->success('ok',compact('list'));
        }
        return $this->render($this->action->id);
    }
}