<?php

/**
 * @Author: fm453
 * @Date:   2018-11-22 03:40:46
 * @Last Modified by:   fm453
 * @Last Modified time: 2021-09-11 10:10:32
 * @Email: fm453@lukegzs.com
 */
namespace backend\controllers;

use Yii;
use yii\data\Pagination;
use yii\helpers\Url;
use addons\models\AcCar;
use addons\models\AcCarOwner;
use addons\models\AcStore;
use addons\models\AcEmployee;
use addons\models\AcFansExt;

use common\models\Fans;

use common\models\CSms;
use common\models\CVcode;

use vendor\aliyun\dysms\Sms;

class CarownerController extends \yii\web\Controller
{
    //替代常规的_construct 析构函数；其他方法调用前执行
    public function init()
    {
        parent::init();
        $session = Yii::$app->session;
        if(isset($_GET['pid']) && (int)$_GET['pid']>0){
            $session->set('pid',(int)$_GET['pid']);
        }
        $pid = $session->get('pid');
        if(!$pid){
            return Yii::$app->response->redirect(['index/index']);
        }
    }

    //主界面
    public function actionIndex()
    {
        global $_HI,$_FM;
        return $this->render('../layouts/dev',[]);

    }

    //车主用户列表
    public function actionList()
    {
        global $_HI,$_FM;
        $pid = Yii::$app->session->get('pid');
        $model = new AcCarOwner();
        $where = $where2 = [];
        $where2[]='and';
        $where['pid'] = $pid;
        $post = Yii::$app->request->post();
        $search = [];
        $search['title'] = isset($post['title']) ? trim(htmlspecialchars_decode($post['title'])) : '';
        if(!empty($search['title'])){
            $where2[] = ['LIKE','name',$search['title']];
        }
        $where['deleted'] = 0;
        $data = $model->find()->where($where);
        if($search['title']){
            // $data = $data->andwhere($where2);
        }
        $pages = new Pagination(['totalCount' =>$data->count(), 'pageSize' => '20']);
        $res = $data->offset($pages->offset)->limit($pages->limit)->indexBy('mid')->all();

        $status = Yii::$app->params['CommonStatus'];
        $gender = Yii::$app->params['gender'];

        $model = new AcStore();
        $where = [];
        $where['pid'] = $pid;
        $_stores = $model->find()->where($where)->all();
        $stores = [];
        foreach($_stores as $s){
            $stores[$s->id] = $s->toArray();
        }

        $eids = $mids = [];
        foreach($res as $r){
            $eids[$r['employee_id']] = $r['employee_id'];
            $mids[$r['mid']] = $r['mid'];
        }

        $model = new AcEmployee();
        $employees = [];
        $_employees = $model->find()->where(['in','id',$eids])->indexBy('id')->all();
        foreach($_employees as $s){
            $employees[$s->id] = $s->toArray();
        }

        $model = new Fans();
        $users = [];
        $_users = $model->find()->where(['in','id',$mids])->all();
        foreach($_users as $s){
            $s = $s->toArray();
            $users[$s['id']] = $s;
        }
        $model = new AcFansExt();
        $exts = [];
        $_exts = $model->find()->where(['in','mid',$mids])->andwhere(['pid'=>$pid,'deleted'=>0])->indexBy('id')->all();
        foreach($_exts as $ext){
            $ext = $ext->toArray();
            if(isset($users[$s['id']])){
                if($ext['mobile']==$users[$s['id']]['mobile']){
                    $exts[$ext['mid']][$ext['key']] = $ext['value'];
                }
            }
        }

        $owners = [];
        foreach($res as $s){
            $s = $s->toArray();
            $owners[$s['id']] = $s;
        }

        return $this->render('list',[
            'owners' => $owners,
            'pager' => $pages,
            'employees'=>$employees,
            'stores'=>$stores,
            'users'=>$users,
            'exts'=>$exts,
            'status'=>$status,
            'gender'=>$gender,
            'search'=>$search
        ]);
    }

    //车主用户选择
    public function actionSelect()
    {
        global $_HI,$_FM;
        $pid = Yii::$app->session->get('pid');
        $model = new AcCarOwner();
        $where = $where2 = [];
        $where2[]='and';
        $where['pid'] = $pid;
        $post = Yii::$app->request->post();
        $search = [];
        $search['title'] = isset($post['title']) ? trim(htmlspecialchars_decode($post['title'])) : '';
        if(!empty($search['title'])){
            $where2[] = ['LIKE','name',$search['title']];
        }
        $where['deleted'] = 0;
        $data = $model->find()->where($where);
        if($search['title']){
            // $data = $data->andwhere($where2);
        }
        $pages = new Pagination(['totalCount' =>$data->count(), 'pageSize' => '20']);
        $res = $data->offset($pages->offset)->limit($pages->limit)->indexBy('mid')->all();
        $status = Yii::$app->params['CommonStatus'];
        $gender = Yii::$app->params['gender'];

        $model = new AcStore();
        $where = [];
        $where['pid'] = $pid;
        $_stores = $model->find()->where($where)->all();
        $stores = [];
        foreach($_stores as $s){
            $stores[$s->id] = $s->toArray();
        }

        $eids = $mids = [];
        foreach($res as $r){
            $eids[$r['employee_id']] = $r['employee_id'];
            $mids[$r['mid']] = $r['mid'];
        }

        $model = new AcEmployee();
        $employees = [];
        $_employees = $model->find()->where(['in','id',$eids])->indexBy('id')->all();
        foreach($_employees as $s){
            $employees[$s->id] = $s->toArray();
        }

        $model = new Fans();
        $users = [];
        $_users = $model->find()->where(['in','id',$mids])->all();
        foreach($_users as $s){
            $s = $s->toArray();
            $users[$s['id']] = $s;
        }
        $model = new AcFansExt();
        $exts = [];
        $_exts = $model->find()->where(['in','mid',$mids])->andwhere(['pid'=>$pid,'deleted'=>0])->indexBy('id')->all();
        foreach($_exts as $ext){
            $ext = $ext->toArray();
            if(isset($users[$s['id']])){
                if($ext['mobile']==$users[$s['id']]['mobile']){
                    $exts[$ext['mid']][$ext['key']] = $ext['value'];
                }
            }
        }

        $owners = [];
        foreach($res as $s){
            $s = $s->toArray();
            if(isset($exts[$s['mid']])){
                foreach($exts[$s['mid']] as $col=>$val){
                    $s[$col] = $val;
                }
            }
            $owners[$s['id']] = $s;
        }

        $callback = !empty(Yii::$app->request->get('callback')) ? Yii::$app->request->get('callback') : 'carowner';
        return $this->render('select',[
            'owners' => $owners,
            'pager' => $pages,
            'employees'=>$employees,
            'stores'=>$stores,
            'users'=>$users,
            'exts'=>$exts,
            'status'=>$status,
            'gender'=>$gender,
            'search'=>$search,
            'callback'=>$callback
        ]);
    }

    //新增车主
    public function actionNew()
    {
        global $_HI,$_FM;
        $levels = Yii::$app->params['customerLevels'];
        return $this->render('modify',['levels'=>$levels]);
    }

    //更新车主
    public function actionEdit()
    {
        global $_HI,$_FM;
        $levels = Yii::$app->params['customerLevels'];
        $model = new AcCarOwner();
        $id = Yii::$app->request->get('id');
        $pid = Yii::$app->session->get('pid');
        $res = $model->find()->where(['id' => $id])->one();
        if($res){
            $res = $res->toArray();
            $res['last_send'] = $res['last_send'] ? date('Y-m-d',$res['last_send']) : '';
            $res['last_contact'] = $res['last_contact'] ? date('Y-m-d',$res['last_contact']) : '';
        }else{
            $res = [];
        }

        //查询对应的系统用户
        $user = Fans::findIdentity($res['mid']);
        $res['mobile'] = '';
        if($user){
            $res['mobile'] = $user->mobile;
        }
        $exts = AcFansExt::find()->where(['mid' => $res['mid'],'mobile' => $res['mobile'],'pid'=>$pid,'deleted'=>0])->all();
        if($exts){
            foreach($exts as $ext){
                $res[$ext['key']] = $ext['value'];
            }
        }

        $store = AcStore::find()->where(['id' => $res['store_id']])->one();
        if($store){
            $res['store_title'] = $store->title;
        }

        $employee = AcEmployee::find()->where(['id' => $res['employee_id']])->one();
        if($employee){
            $res['employee_title'] = $employee->name;
        }

        // memory_get_usage();//查看当前内存,字节

        return $this->render('modify',[
            'detail'=>$res,
            'levels'=>$levels,
            'id'=>$id,
        ]);
    }

    //保存车主资料
    public function actionSave()
    {
        $post = Yii::$app->request->post();
        $id = (int)$post['id'];
        $pid = Yii::$app->session->get('pid');
        if(!$post['mobile']){
            \Yii::$app->getSession()->setFlash('warning', '请输入主手机号码！');
            $url = Url::toRoute(['carowner/edit','id'=>$id]);
            return $this->redirect(['modify','id'=>$id]);
        }

        $mobile = $post['mobile'];
        //查询对应的系统用户
        $userModel = new Fans();
        $user = $userModel->findByUsername($mobile);
        if(empty($user)){
            $pwd = isset($post['password']) ? trim($post['password']) : Yii::$app->params['defaultFansPassword'];
            $userModel->mobile = $mobile;
            $userModel->email = $mobile.'@hiluker.com';
            $userModel->setPassword($pwd);
            $userModel->generateAuthKey();
            $userModel->created_at = time();
            $userModel->from = 'ctms';
            $userModel->save();
            $user_id = $userModel->attributes['id']; //获取插入后id
        }else{
            $user_id = $user->id;
        }
        /*保存扩展资料 S*/
        $AcFansExt = new AcFansExt();
        //批量硬删及软删
        $AcFansExt->deleteAll(['deleted'=>2,'pid'=>$pid,'mid'=>$user_id]);    //硬删,变更历史3次的
        $AcFansExt->updateAllCounters(['deleted'=>1],['pid'=>$pid,'mid'=>$user_id]);    //更新已有数据
        //开始写入新传入的数据
        $datas = [];
        $data = [];
        $cols = ['realname'=>'realname','nickname'=>'nickname','title'=>'title','password'=>'password','mobiles'=>'mobiles','thumb'=>'thumb','province'=>'province','idcard'=>'idcard'];
        foreach($cols as $col=>$key){
            $data['pid'] = $pid;
            $data['mid'] = $user_id;
            $data['key'] = $col;
            $data['mobile'] = $mobile;
            $data['value'] = isset($post[$key]) ? trim($post[$key]) : '';
            $datas[] = $data;
        }
        //批量插入
        $model = clone $AcFansExt;
        foreach($datas as $attributes)
        {
            $model->isNewRecord = true;
            $model->setAttributes($attributes,false);
            $model->save() && $model->id=0;
        }
        /*保存扩展资料 E*/

        //格式化数据
        $data = [];
        //目标键=》POST键
        $cols = ['gender'=>'gender','total_fee'=>'total_fee','level'=>'level','score'=>'score','store_id'=>'store','employee_id'=>'employee','status_code'=>'status_code','deleted'=>'deleted'];
        foreach($cols as $col=>$key){
            $data[$col] = isset($post[$key]) ? (int)$post[$key] : 0;
        }
        $cols = ['last_send'=>'last_send','last_contact'=>'last_contact'];
        foreach($cols as $col=>$key){
            $data[$col] = isset($post[$key]) ? strtotime($post[$key]) : 0;
        }
        $cols = ['remark'=>'editor'];
        foreach($cols as $col=>$key){
            $data[$col] = isset($post[$key]) ? htmlspecialchars($post[$key]) : '';
        }
        $data['create_at'] = time();
        $data['update_at'] = $data['create_at'];
        $data['pid'] = $pid;
        $data['mid'] = $user_id;

        //格式化车主资料
        $AcCarOwner = new AcCarOwner();
        foreach($data as $key=>$val){
            $AcCarOwner->$key = $val;
        }

        //查询该车主是否在库
        $carOwner = AcCarOwner::find()->where(['pid'=>$data['pid'],'mid'=>$data['mid']])->one();
        if($carOwner){
            $id = $carOwner->id;
        }

        //车主资料入库
        if($id){
            $AcCarOwner->id = $id;
            unset($data['create_at']);
            $res = $AcCarOwner->updateAll($data,['id'=>$id]);
        }else{
            $res = $AcCarOwner->save();
            $id = $AcCarOwner->attributes['id']; //获取插入后id
        }

        if($res){
            \Yii::$app->getSession()->setFlash('success', '车主资料保存成功！');
            return $this->redirect(['edit','id'=>$id]);
        }else{
            \Yii::$app->getSession()->setFlash('warning', '车主资料保存失败！');
            return $this->goBack();
        }

        // $return = [];
        // if($res){
        //     $return['msg'] = '车主信息保存成功';
        //     $return['errorcode'] = 200;
        //     $return['url'] = Url::toRoute(['carowner/edit','id'=>$id]);
        //     $return['buttons'] = [
        //         ['title'=>'好的，我知道了','class'=>'primary','url'=>$return['url']]
        //     ];
        // }else{
        //     $return['msg'] = '车主信息保存失败';
        //     $return['errorcode'] = 0;
        //     $return['url'] = Url::toRoute(['carowner/new',$post]);
        //     $return['buttons'] = [
        //         ['title'=>'好的，我知道了','class'=>'info','url'=>$return['url']]
        //     ];
        // }

        // $classes = ['0'=>'warning','200'=>'success'];
        // $return['content'] = $return['msg'];
        // $return['class'] = $classes[$return['errorcode']];

        // Yii::$app->request->setBodyParams($return);
        // return Yii::$app->runAction('index/msg');
    }

    //删除用户
    public function actionDelete($id)
    {
        global $_HI,$_FM;
        $get = Yii::$app->request->get();
        $post = Yii::$app->request->post();
        $id = (int)$get['id'];
        $data = $where = [];
        $where['pid'] = Yii::$app->session->get('pid');
        $where['id'] = $id;
        $data['update_at'] = time();
        $data['deleted'] = 1;

        $model = new AcCarOwner();
        foreach($data as $key=>$val){
            $model->$key = $val;
        }

        $model->id = $id;
        $res = $model->updateAll($data,$where);

        $return = [];
        $return['url'] = Url::toRoute('carowner/list');
        $return['timeout'] = 3; //3秒后自动跳转
        $return['status'] = 0;
        if($res){
            $return['msg'] = '删除成功';
            $return['errorcode'] = 200;
            $return['data'] = $id;
        }else{
            $return['msg'] = '删除失败';
            $return['errorcode'] = 0;
        }
        exit(json_encode($return,JSON_UNESCAPED_UNICODE));
    }

    public function actionAjax()
    {
        $get = Yii::$app->request->get();
        $post = Yii::$app->request->post();
        $id = (int)$get['id'];
        $data = $where = [];
        $where['pid'] = Yii::$app->session->get('pid');
        $where['id'] = $id;
        $data['update_at'] = time();

        $model = new AcCarOwner();
        $res = $model->find()->where(['id' => $id])->one();
        $return = [];
        $return['timeout'] = 1; //3秒后自动跳转
        $return['status_code'] = 0;
        $return['ajax'] = 1;
        if($res){
            $res = $res->toArray();
        }else{
            $return['msg'] = '车主数据不存在';
            $return['errorcode'] = 404;
            exit(json_encode($return,JSON_UNESCAPED_UNICODE));
        }

        switch($get['do'])
        {
            case 'hide':
                $data['status_code'] = 0;
                $model->id = $id;
                $res = $model->updateAll($data,$where);
                if($res){
                    $return['msg'] = '车主隐藏标记成功';
                    $return['errorcode'] = 200;
                    $return['data'] = ['css'=>'info'];
                }else{
                    $return['msg'] = '车主隐藏标记失败';
                    $return['errorcode'] = 0;
                }
            break;
            case 'show':
                $data['status_code'] = 1;
                $model->id = $id;
                $res = $model->updateAll($data,$where);
                if($res){
                    $return['msg'] = '车主显示标记成功';
                    $return['errorcode'] = 200;
                    $return['data'] = ['css'=>'default'];
                }else{
                    $return['msg'] = '车主显示标记失败';
                    $return['errorcode'] = 0;
                }
            break;
            default:
            break;
        }
        exit(json_encode($return,JSON_UNESCAPED_UNICODE));
    }

    //短信营销
    public function actionMsg()
    {
        global $_HI,$_FM;
        $levels = Yii::$app->params['customerLevels'];
        $model = new AcCarOwner();
        $id = Yii::$app->request->get('id');
        $pid = Yii::$app->session->get('pid');
        $res = $model->find()->where(['id' => $id])->one();
        if($res){
            $res = $res->toArray();
            $res['last_send'] = $res['last_send'] ? date('Y-m-d',$res['last_send']) : '';
            $res['last_contact'] = $res['last_contact'] ? date('Y-m-d',$res['last_contact']) : '';
        }else{
            $res = [];
        }

        //查询对应的系统用户
        $userModel = new Fans();
        $user = Fans::find()->where(['id'=>$res['mid']])->one();
        $res['mobile'] = '';
        if($user){
            $res['mobile'] = $user->mobile;
        }
        $exts = AcFansExt::find()->where(['mid' => $res['mid'],'mobile' => $res['mobile'],'pid'=>$pid,'deleted'=>0])->all();
        if($exts){
            foreach($exts as $ext){
                $res[$ext['key']] = $ext['value'];
            }
        }

        $store = AcStore::find()->where(['id' => $res['store_id']])->one();
        if($store){
            $res['store_title'] = $store->title;
        }

        $employee = AcEmployee::find()->where(['id' => $res['employee_id']])->one();
        if($store){
            $res['employee_title'] = $employee->name;
        }

        $op = Yii::$app->request->get('op');
        $opp = Yii::$app->request->get('opp');
        if(!$op){
            return $this->render('msg',[
                'detail'=>$res,
                'levels'=>$levels,
                'id'=>$id,
            ]);
        }elseif($op=='send'){
            $option = [];
            $config = [];
            $config['accessKeyId'] = Yii::$app->params['aliDySms']['accessKeyId'];
            $config['accessKeySecret'] = Yii::$app->params['aliDySms']['accessKeySecret'];
            $config['sign'] = Yii::$app->params['aliDySms']['sign'];
            $sms = new Sms($option,$config);
            $phone = $res['mobile'];
            $content=[];
            switch($opp){
                case 'vcode':    //发送验证码
                    $code = mt_rand(1000,9999);
                    $content['code'] = $code;
                    $tmpl = Yii::$app->params['aliDySms']['tmpl']['vcode'];
                    //验证码入库
                    $vcodeModel = new CVcode();
                    $vcode = [];
                    $vcode['code'] = $code;
                    $vcode['mobile'] =  $phone;
                    $vcode['create_at'] = time();
                    foreach($vcode as $key=>$val){
                        $vcodeModel->$key = $val;
                    }
                    $vcodeModel->save();
                break;
                case 'birthday':    //发送生日祝福
                    $realname = isset($res['realname'])?$res['realname']:'VIP';
                    $content['name'] = $realname;
                    $content['company'] = Yii::$app->request->post('company');
                    $content['company'] = $content['company'] ? $content['company'] : '安诚托车';
                    $tmpl = Yii::$app->params['aliDySms']['tmpl']['acBirthday'];
                break;
            }
            $result = $sms->send($phone,$tmpl,$content);
            //保存发送记录
            $smsModel = new CSms();
            $smsdata = [];
            $sid = Yii::$app->session->get('sid');
            $smsdata['sid'] = (int)$sid;
            $smsdata['pid'] = $pid;
            $smsdata['uid'] =  Yii::$app->user->identity->id;
            $smsdata['mobile'] =  $phone;
            $smsdata['content'] = json_encode($content,JSON_UNESCAPED_UNICODE);
            $smsdata['create_at'] = time();
            foreach($smsdata as $key=>$val){
                $smsModel->$key = $val;
            }
            $smsModel->save();

            $return = [];
            $msg = '';
            if(!$result){
                $msg .= "【".$phone."】发送失败，接口提示：".$sms->errors."\r\n";
                $return['errorcode'] = 0;
            }elseif(is_array($result) && $result['Code'] !='OK'){
                $msg .= "【".$phone."】发送失败，接口提示：".$result['Message']."\r\n";
                $return['errorcode'] = 0;
            }else{
                $msg .= "【".$phone."】发送成功"."\r\n";
                $return['errorcode'] = 0;
            }
            $return['msg'] = $msg;
            exit(json_encode($return,JSON_UNESCAPED_UNICODE));
        }
    }

    //信息摘要
    public function actionInfo()
    {
        global $_HI,$_FM;
        $levels = Yii::$app->params['customerLevels'];
        $model = new AcCarOwner();
        $id = Yii::$app->request->get('id');
        $pid = Yii::$app->session->get('pid');
        $res = $model->find()->where(['id' => $id])->one();
        if($res){
            $res = $res->toArray();
            $res['last_send'] = $res['last_send'] ? date('Y-m-d',$res['last_send']) : '';
            $res['last_contact'] = $res['last_contact'] ? date('Y-m-d',$res['last_contact']) : '';
        }else{
            $res = [];
        }

        //查询对应的系统用户
        $userModel = new Fans();
        $user = Fans::find()->where(['id'=>$res['mid']])->one();
        $res['mobile'] = '';
        if($user){
            $res['mobile'] = $user->mobile;
        }
        $exts = AcFansExt::find()->where(['mid' => $res['mid'],'mobile' => $res['mobile'],'pid'=>$pid,'deleted'=>0])->all();
        if($exts){
            foreach($exts as $ext){
                $res[$ext['key']] = $ext['value'];
            }
        }

        $store = AcStore::find()->where(['id' => $res['store_id']])->one();
        if($store){
            $res['store_title'] = $store->title;
        }

        $employee = AcEmployee::find()->where(['id' => $res['employee_id']])->one();
        if($store){
            $res['employee_title'] = $employee->name;
        }

        return $this->render('info',[
            'detail'=>$res,
            'levels'=>$levels,
            'id'=>$id,
        ]);
    }

}