<?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);
            if (!$result){
                $this->error(__('No rows were inserted'));
                Db::rollback();
            }
            $firmstoreResult = Db::table('fa_firmstore')->insert(['firm_id'=>$result,'name'=>$params['full_name'].'门店']);
            if (!$firmstoreResult){
                $this->error(__('No rows were inserted firmstore'));
                Db::rollback();
            }
            $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 (empty($firmstoreData)){
            return json(['code'=>201,'msg'=>'请先添加门店']);
        }
        //大类
        $firmbigcategoryData = Db::table('fa_firmbigcategory')->where('firm_id',1)->select();
        if (empty($firmbigcategoryData)){
            return json(['code'=>201,'msg'=>'请先添加大类模版']);
        }
        foreach ($firmbigcategoryData as $key=>&$val){
            unset($val['id']);
            $val['firm_id'] = $ids;
        }
        //客户来源
        $firmcustomeroriginData = Db::table('fa_firmcustomerorigin')->where('firm_id',1)->select();
        if (empty($firmcustomeroriginData)){
            return json(['code'=>201,'msg'=>'请先添加客户来源模版']);
        }
        foreach ($firmcustomeroriginData as $key=>&$val){
            unset($val['id']);
            $val['firm_id'] = $ids;
        }
        //职务
        $firmdutyData = Db::table('fa_firmduty')->where('firm_id',1)->where('firmstore_id',1)->select();
        if (empty($firmdutyData)){
            return json(['code'=>201,'msg'=>'请先添加职务模版']);
        }
        $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;
            }
        }
        //标签
        $firmtagsData = Db::table('fa_firmtags')->where('firm_id',1)->select();
        if (empty($firmtagsData)){
            return json(['code'=>201,'msg'=>'请先添加职务模版']);
        }
        foreach ($firmtagsData as $key=>&$val){
            unset($val['id']);
            $val['firm_id'] = $ids;
        }

        $firmbigcategoryResult = false;
        $firmcustomerorigiResult = false;
        $firmdutyResult = false;
        $firmtagsResult = 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);
            $firmtagsResult = Db::table('fa_firmtags')->insertAll($firmtagsData);
            //店铺项目
            $firmstoreprojectsoneData = Db::table('fa_firmstoreprojectsone')->where('firm_id',1)->where('firmstore_id',1)->select();
            foreach ($firmstoreprojectsoneData as $key=>&$val){
                foreach ($firmstoreData as &$v){
                    $data = [];
                    $data['firm_id'] = $ids;
                    $data['name'] = $val['name'];
                    $data['firmstore_id'] = $v['id'];
                    //添加一级店铺项目
                    $firmstoreprojectsone_id = Db::table('fa_firmstoreprojectsone')->insertGetId($data);
                    //查询二级店铺项目
                    $firmstoreprojectstwoData = Db::table('fa_firmstoreprojectstwo')->where('firm_id',1)
                        ->where('firmstore_id',1)->where('firmstoreprojectsone_id',$val['id'])->select();
                    foreach ($firmstoreprojectstwoData as &$value){
                        $firmstoreprojectstwo_oldid = $value['id'];
                        unset($value['id']);
                        $value['firm_id'] = $ids;
                        $value['firmstore_id'] = $v['id'];
                        $value['firmstoreprojectsone_id'] = $firmstoreprojectsone_id;
                        //添加二级店铺项目
                        $firmstoreprojectstwo_id = Db::table('fa_firmstoreprojectstwo')->insertGetId($value);
                        //查询事例模块
                        $mattertemplatecategorizationData = Db::table('fa_mattertemplatecategorization')->where('firm_id',1)
                            ->where('firmstoreprojectsone_id',$val['id'])->where('firmstoreprojectstwo_id',$firmstoreprojectstwo_oldid)->select();
                        foreach ($mattertemplatecategorizationData as &$mtcv){
                            $mtc_id = $mtcv['id'];
                            unset($mtcv['id']);
                            $mtcv['firm_id'] = $ids;
                            $mtcv['firmstoreprojectsone_id'] = $firmstoreprojectsone_id;
                            $mtcv['firmstoreprojectstwo_id'] = $firmstoreprojectstwo_id;
                            $mtcv['create_time'] = date('Y-m-d H:i:s');
                            $mtcv['update_time'] = date('Y-m-d H:i:s');
                            $mattertemplatecategorization_id = Db::table('fa_mattertemplatecategorization')->insertGetId($mtcv);
                            //事例模块具体内容
                            $fa_mattertemplatecategorizedcontent = Db::table('fa_mattertemplatecategorizedcontent')
                                ->where('mattertemplatecategorization_id',$mtc_id)->select();
                            foreach ($fa_mattertemplatecategorizedcontent as &$values){
                                unset($values['id']);
                                $values['mattertemplatecategorization_id'] = $mattertemplatecategorization_id;
                                $values['create_time'] = date('Y-m-d H:i:s');
                                $values['update_time'] = date('Y-m-d H:i:s');
                            }
                            Db::table('fa_mattertemplatecategorizedcontent')->insertAll($fa_mattertemplatecategorizedcontent);
                        }
                    }
                }
            }
            Db::commit();
        }catch(ValidateException|PDOException|Exception $e){
            return json(['code'=>201,'msg'=>$e->getMessage()]);
        }

        $requiredResults = [
            'firmbigcategoryResult' => $firmbigcategoryResult ?? null,
            'firmcustomerorigiResult' => $firmcustomerorigiResult ?? null,
            'firmdutyResult' => $firmdutyResult ?? null,
            'firmtagsResult' => $firmtagsResult ?? null,
        ];
        foreach ($requiredResults as $key => $value) {
            if (!$value) {
                // 返回更详细的错误信息，指出具体哪个变量导致失败
                return json([
                    'code' => 201,
                    'msg' => "导入失败：{$key} 为空或无效"
                ]);
            }
        }
        return json(['code'=>200,'msg'=>'导入成功']);
    }
}