fast_response/superadmin/application/admin/controller/Firm.php

<?php

namespace app\admin\controller;

use app\common\controller\Backend;
use think\Db;

/**
 * 合作企业
 *
 * @icon fa fa-circle-o
 */
class Firm extends Backend
{
    protected $noNeedRight = ['index','getAiService'];

    /**
     * Firm模型对象
     * @var \app\admin\model\Firm
     */
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\Firm;

    }



    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */



    //查询企业的AI客服
    function getAiService(){
        //查询当前企业已经配置的AI客服
        $aicustomerservice_ids = Db::table('fa_firm')
            ->where('id',session_admin_firm_id())
            ->value('aicustomerservice_ids');
        $info = Db::table('fa_aicustomerservice')
            ->whereIn('id',explode(',',$aicustomerservice_ids))
            ->select();
        return json(['list'=>$info,'total'=>$info]);
    }

    public function add()
    {
        if (false === $this->request->isPost()) {
            return $this->view->fetch();
        }
        $params = $this->request->post('row/a');
        if (empty($params)) {
            $this->error(__('Parameter %s can not be empty', ''));
        }
        $params = $this->preExcludeFields($params);

        if ($this->dataLimit && $this->dataLimitFieldAutoFill) {
            $params[$this->dataLimitField] = $this->auth->id;
        }
        Db::startTrans();
        try {
            //是否采用模型验证
            if ($this->modelValidate) {
                $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
                $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate;
                $this->model->validateFailException()->validate($validate);
            }
            $result = $this->model->allowField(true)->insertGetId($params);
            $addaicustomerswrvicelistResult = $this->addaicustomerswrvicelist($params,$result);
            if (!$addaicustomerswrvicelistResult['res']){
                $this->error($addaicustomerswrvicelistResult['text']);
                Db::rollback();
            }
            Db::table('fa_aicustomerservicefirmstorelist')->insertAll($addaicustomerswrvicelistResult['data']);
            Db::commit();
        } catch (ValidateException|PDOException|Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if ($result === false) {
            $this->error(__('No rows were inserted'));
        }
        $this->success();
    }

    /**
     * 添加机器人管理回复时间
     * @param $params
     * @param $firm_id
     * @return void
     */
    public function addaicustomerswrvicelist($params,$firm_id){
        $aicustomerservice_ids = explode(',',$params['aicustomerservice_ids']);
        if (!$firm_id){
            return ['res'=>false,'text'=>'企业添加失败，请重新操作'];
        }
        if(count($aicustomerservice_ids) < 1 ){
            return ['res'=>false,'text'=>'请添加机器人'];
        }
        $data = [];
        foreach ($aicustomerservice_ids as $key=>$val){
            $data[$key]['firm_id'] = $firm_id;
            $data[$key]['aicustomerservice_id'] = $val;
            $data[$key]['status'] = 'yes';
            $data[$key]['create_time'] = $params['create_time'];
            $data[$key]['update_time'] = $params['create_time'];
        }
        return ['res'=>true,'data'=>$data];
    }

    /** 导入基础管理（企业为1的导入其中）
     * @param
     * @return void
     */
    public function importBasic($ids = null)
    {
        $firmstoreData = Db::table('fa_firmstore')->where('firm_id',$ids)->select();
        if (count($firmstoreData) == 0){
            return json(['code'=>201,'msg'=>'请先添加门店']);
        }
        $firmbigcategoryData = Db::table('fa_firmbigcategory')->where('firm_id',1)->select();
        foreach ($firmbigcategoryData as $key=>&$val){
            unset($val['id']);
            $val['firm_id'] = $ids;
        }
        $firmcustomeroriginData = Db::table('fa_firmcustomerorigin')->where('firm_id',1)->select();
        foreach ($firmcustomeroriginData as $key=>&$val){
            unset($val['id']);
            $val['firm_id'] = $ids;
        }
        $firmdutyData = Db::table('fa_firmduty')->where('firm_id',1)->select();
        $firmdutyMore = [];
        foreach ($firmdutyData as $key=>&$val){
            $data = [];
            $data['firm_id'] = $ids;
            $data['name'] = $val['name'];
            foreach ($firmstoreData as &$v){
                $data['firmstore_id'] = $v['id'];
                $firmdutyMore[] = $data;
            }
        }
        $firmbigcategoryResult = false;
        $firmcustomerorigiResult = false;
        $firmdutyResult = false;
        Db::startTrans();
        try {
            $firmbigcategoryResult = Db::table('fa_firmbigcategory')->insertAll($firmbigcategoryData);
            $firmcustomerorigiResult = Db::table('fa_firmcustomerorigin')->insertAll($firmcustomeroriginData);
            $firmdutyResult = Db::table('fa_firmduty')->insertAll($firmdutyMore);
            Db::commit();
        }catch(ValidateException|PDOException|Exception $e){
            return json(['code'=>201,'msg'=>$e->getMessage()]);
        }
        if (!$firmbigcategoryResult || !$firmcustomerorigiResult || !$firmdutyResult){
            return json(['code'=>201,'msg'=>'导入失败']);
        }
        return json(['code'=>200,'msg'=>'导入成功']);
    }
}