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

<?php

namespace addons\Boss\backend\controllers;

use addons\Boss\common\enums\LevelEnum;
use addons\Boss\common\models\AddonsBoss;
use addons\Boss\common\models\AddonsBossLevel;
use addons\Boss\common\models\BossImportLevelFailLog;
use addons\Boss\common\models\BossImportLevelLog;
use common\enums\StatusEnum;
use common\models\user\User;
use common\components\CsvExport;
use common\helpers\csv\CsvExportHelper;
use common\enums\DownloadEnum;

use Yii;

/**
 * 默认控制器
 *
 * Class DefaultController
 * @package addons\Boss\backend\controllers
 */
class DefaultController extends BaseController
{
    public $enableCsrfValidation = false;

    /**
    * 首页
    *
    * @return string
    */
    public function actionIndex()
    {
        $retuest = Yii::$app->request;
        if ($retuest->isAjax) {
            if ($retuest->isGet) {
                $get = Yii::$app->request->get();

                // 检查提交的参数
                $res = Yii::$app->services->validate->validate($get,[
                    [['id','level','user_id'], 'integer'],
                    [['id','keyword'], 'safe'],
                ]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());

                // 获取股东等级
                $level_list = AddonsBossLevel::getBossLevel([['mall_id' => $this->mall_id]],[],true,'level,name', 'level');

                // 升级类型
                $upgrade_type = LevelEnum::getUpgradeType();

                $where = $parents = $list = [];
                $where[] = ['=', 'status', StatusEnum::ENABLED];
                $where[] = ['=', 'mall_id', $this->mall_id];
                !empty($get['user_id']) && $where[] = ['=', 'user_id', $get['user_id']];
                !empty($get['level']) && $where[] = ['=', 'level', $get['level']];

                // 根据搜索手机号查询用户id
                if (!empty($get['keyword'])) {
                    $user_ids = User::find()->select("id")->where(['mall_id' => $this->mall_id])->andWhere(['like', 'mobile', $get['keyword'] . '%', false])->asArray()->column();
                    if (empty($user_ids)) $this->success('获取成功', compact('list','level_list', 'upgrade_type', 'parents'));
                    $where[] = ['in', 'user_id', $user_ids];
                }

                $with = ['user'];
                $order = 'created_at desc';
                $params = array('where' => $where, 'order'=>$order, 'with' => $with, 'limit' => $get['limit']);

                $list = AddonsBoss::listPage($params, false, true);
                if (isset($list['list'])) {
                    // 获取用户上级推荐人id
                    $parent_ids = [];
                    foreach ($list['list'] as $boss) {
                        $parent_ids[] = $boss['user']['parent_id'];
                    }
                    if ($parent_ids) {
                        // 获取上级用户信息
                        $parents = User::getUserList([['in','id',array_unique($parent_ids)]], 'id,nickname', [], 1);
                        $parents = array_column($parents, 'nickname', 'id');
                    }
                }
                $export_list = AddonsBoss::exportFieldsList();

                $this->success('获取成功', compact('list','level_list', 'upgrade_type', 'parents','export_list'));
            }
        } 
        if (\Yii::$app->request->post('flag') == 'EXPORT') {
            $post = \Yii::$app->request->post();
            $post['mall_id'] = $this->mall_id;
            $filename = '股东列表-' . date('YmdHis') . '_' . rand(10000, 99999);
            $res = CsvExportHelper::exportDownLoadCenter($this->mall_id, $filename, DownloadEnum::TYPE_DISTRIBUTION, AddonsBoss::class, 'exportHandle', $post);
            if ($res === false) return $this->error('加入导出任务失败' . CsvExportHelper::getStaticError());
            return $this->success('添加导出任务成功，任务完成后请在下载中心进行下载！');
        }
        return $this->render('index', []);
    }


    /**
     * 添加股东
     * @Author: lun
     * @DateTime: 2021/10/21 0021 17:56
     * @Copyright: copyright (c) 2021 广东七件事集团
     */
    public function actionAddBoss()
    {
        $retuest = Yii::$app->request;
        if ($retuest->isAjax) {
            if ($retuest->isPost) {
                $params = Yii::$app->request->post();
                $res = Yii::$app->services->validate->validate($params,[[['mobile','level'], 'integer'], [['mobile','level'], 'required']]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());

                // 根据手机号码获取用户id
                $user = User::getOne([['mall_id' => $this->mall_id], ['mobile' => $params['mobile']]],true,[],false,'id');
                if (empty($user)) return $this->error('暂无此用户');
                $params['mall_id'] = $this->mall_id;
                $params['user_id'] = $user['id'];
                $params['admin_id'] = $this->admin->id;

                // 保存数据
                $res = AddonsBoss::setData($params);
                if (!$res) return $this->error(AddonsBoss::getStaticError());
                $this->success('股东添加成功');
            }
        }
    }

    /**
     * 根据用户名搜索用户
     * @Author: lun
     * @DateTime: 2021/10/21 0021 18:36
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return mixed|void
     */
    public function actionSelectUser()
    {
        $retuest = Yii::$app->request;
        if ($retuest->isAjax && $retuest->isPost) {
            $params = Yii::$app->request->post();
            $res = Yii::$app->services->validate->validate($params,[[['keyword'], 'string'], [['keyword'], 'required']]);
            if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
            // 搜索用户列表
            $list = User::getUserList([['mall_id' => $this->mall_id],['like','mobile',$params['keyword']]], 'id,mobile', [], 1);

            $this->success('获取成功', $list);
        }
    }


    /**
     * 股东数据编辑
     * @Author: lun
     * @DateTime: 2021/10/23 0023 9:20
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return mixed|void
     */
    public function actionEdit()
    {
        $retuest = Yii::$app->request;
        if ($retuest->isAjax) {
            if ($retuest->isPost) {
                $params = Yii::$app->request->post();
                $res = Yii::$app->services->validate->validate($params,[
                    [['user_id'], 'required'],
                    [['remark'], 'string'],
                    [['user_id','status','level', 'is_extra_bonus_alone_limit'], 'integer'],
                    [['extra_bonus_limit'], 'number']
                ]);
                if($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
                $params = AddonsBoss::exceptNullVal($params);
                $params['mall_id'] = $this->mall_id;

                // 修改等级操作
                if (!empty($params['level'])) {
                    $params['upgrade_status'] = LevelEnum::UPGRADE_MANUAL;
                    $params['upgrade_level_at'] = time();
                    $params['admin_id'] = $this->admin->id;
                }

                // 保存数据
                $res = AddonsBoss::setData($params);
                if (!$res) return $this->error(AddonsBoss::getStaticError());
                $this->success('修改成功');
            }
        }
    }
     /**
     * 导入日志记录
     * @return mixed|void
     */
    public function actionGetImportLevelLog()
    {
        $params = \Yii::$app->request->get();
        $params['where'] = [
            ['mall_id'=>$this->mall_id]
        ];
        $params['order'] = 'id desc';
        $data = BossImportLevelLog::listPage($params, false, true);
        if (!empty($data['list'])) {
            foreach ($data['list'] as &$v) {
                $v['url'] = '';
                if ($v['fail_counts']) $v['url'] = \Yii::$app->urlManager->createUrl(['boss/default/export-level-fail', 'log_id' => $v['id']]);
            }
        }
        return $this->success('操作成功', $data);
    }

    /**
     * 导出失败日志
     */
    public function actionExportLevelFail()
    {
        BossImportLevelFailLog::exportFailLog(\Yii::$app->request->get());
    }
     /**
     * 会员批量导入模板下载
     */
    public function actionImportLevelModel()
    {
        $csv = new CsvExport();
        $file_name = '批量导入股东等级模板-' . date('YmdHis', time());
        $head_list = array_column(AddonsBoss::$head_list, 'field_name');
        return $csv->export([], $head_list, $file_name);
    }
        /**
     * 批量导入等级
     * @return mixed|string|void
     */
    public function actionImportLevel()
    {
        set_time_limit(0);
        if (\Yii::$app->request->isAjax) {
            $params = \Yii::$app->request->post();
            $res = Yii::$app->services->validate->validate($params, [
                [['current_num'], 'required'],
                [['file'], 'file', 'extensions' => ['csv']],
                [['file_path'], 'string'],
                [['sync'], 'safe'],
            ]);
            if ($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
            $params['mall_id'] = $this->mall_id;
            if(!empty($params['sync'])){
                $res = AddonsBoss::importLevelSync($params);
            }else{
                $res = AddonsBoss::importLevel($params);
            }

            if (empty($res['fail_counts'])) return $this->success('操作成功', $res);
            if (!empty($res['fail_counts'])) return $this->error('导入失败'.$res['fail_counts'].'条');
            return $this->error(AddonsBoss::getStaticError());
        } else {
            return $this->render($this->action->id);
        }
    }


}