<?php

namespace app\admin\controller;

use app\model\Message;
use app\model\Notice;
use app\model\Attachment;
use think\Db;
use think\facade\Request;
use think\facade\Log;

class MessageRemind extends Base
{
    private $type =array(1=>'询价待处理',2=>"订单进度",3=>"调价待处理",4=>"查勘待派单",5=>"查勘待跟进",6=>"报告待制作",7=>"报告待审核",8=>"工作流待处理",9=>"工作流进度");
    private $message_type =array(1=>'询价待处理',2=>"订单进度",3=>"调价待处理",4=>"查勘待派单",5=>"查勘待跟进",6=>"报告待制作",
        7=>"报告待审核",8=>"工作流待处理",9=>"工作流进度",10=>'询价待处理',11=>"订单进度",12=>"调价待处理",13=>"查勘待派单",
        14=>"查勘待跟进",15=>"报告待制作",16=>"报告待审核",17=>"工作流待处理",18=>"工作流进度",18=>"查勘待跟进",19=>"报告待制作",
        20=>"报告待审核",21=>"工作流待处理",22=>"工作流进度",23=>"查勘待跟进",24=>"报告待制作",25=>"报告待审核");
    /**
     * 获取信息列表
     * @author   cavan
    */
	public function MessageRemindList()
	{
	    if(empty($this->userInfo)){
	        return $this->buildFailed("登录已失效");
        }
	    $Mdb = new Message();

        $resultData=$Mdb->where(["status"=>1,"user_id"=>$this->userInfo['user_id']])
            ->order("create_time asc")
            ->field('*')
            ->select()
            ->toArray();
        $data = array();
        if(!empty($resultData)){
            $inquiryPending = array();$OrderProgress = array();$ModifyPricePending = array();$SurveyWaitingList = array();$SurveyfollowUp = array();
            $ReportProduced = array();$ReportReviewed = array();$WorkflowPending = array();$WorkflowProgress = array();
            $inquiryPendingCount = $OrderProgressCount = $ModifyPricePendingCount = $SurveyWaitingListCount = $SurveyfollowUpCount = $ReportProducedCount = $ReportReviewedCount = $WorkflowPendingCount = $WorkflowProgressCount = 0;
            $type_arr = array_unique(array_column($resultData,"type"));
            if(!empty($type_arr)){
                foreach ($type_arr as $k => $v){
                    foreach ($resultData as $kd => $vd){
                        $vd['create_time'] = date("Y-m-d H:i",strtotime($vd['create_time']));
                        if($v == $vd['type']){
                            if($v == 1){
                                $inquiryPending[] = $vd;
                                if($vd['issee'] == 2){
                                    $inquiryPendingCount++;
                                }
                            }else if($v == 2){
                                if($vd['message_type'] == 11 || $vd['message_type'] == 31){         //报告已完成  报告完成时间不是当天的不显示
                                    $completion_time = Db::name("report")
                                        ->where("quot_id",$vd['quot_id'])
                                        ->value("completion_time");
                                    if($completion_time && date("Y-m-d",$completion_time) == date("Y-m-d",time())){
                                        $OrderProgress[] = $vd;
                                        if($vd['issee'] == 2){
                                            $OrderProgressCount++;
                                        }
                                    }
                                }else{
                                    $OrderProgress[] = $vd;
                                    if($vd['issee'] == 2){
                                        $OrderProgressCount++;
                                    }
                                }
                            }else if($v == 3){
                                $ModifyPricePending[] = $vd;
                                if($vd['issee'] == 2){
                                    $ModifyPricePendingCount++;
                                }
                            }else if($v == 4){
                                $SurveyWaitingList[] = $vd;
                                if($vd['issee'] == 2){
                                    $SurveyWaitingListCount++;
                                }
                            }else if($v == 5){
                                $SurveyfollowUp[] = $vd;
                                if($vd['issee'] == 2){
                                    $SurveyfollowUpCount++;
                                }
                            }else if($v == 6){
                                $ReportProduced[] = $vd;
                                if($vd['issee'] == 2){
                                    $ReportProducedCount++;
                                }
                            }else if($v == 7){
                                $ReportReviewed[] = $vd;
                                if($vd['issee'] == 2){
                                    $ReportReviewedCount++;
                                }
                            }else if($v == 8){
                                $WorkflowPending[] = $vd;
                                if($vd['issee'] == 2){
                                    $WorkflowPendingCount++;
                                }
                            }else if($v == 9){
                                $WorkflowProgress[] = $vd;
                                if($vd['issee'] == 2){
                                    $WorkflowProgressCount++;
                                }
                            }
                        }
                    }
                }
            }
            $data['inquiryPending'] = $inquiryPending;
            $data['OrderProgress'] = array_merge($this->arraySort(array_merge($OrderProgress),"create_time","desc"));
            $data['ModifyPricePending'] = $ModifyPricePending;
            $data['SurveyWaitingList'] = $SurveyWaitingList;
            $data['SurveyfollowUp'] = $SurveyfollowUp;
            $data['ReportProduced'] = $ReportProduced;
            $data['ReportReviewed'] = $ReportReviewed;
            $data['WorkflowPending'] = $WorkflowPending;
            $data['WorkflowProgress'] = $WorkflowProgress;
            $data['inquiryPendingCount'] = $inquiryPendingCount;
            $data['OrderProgressCount'] = $OrderProgressCount;
            $data['ModifyPricePendingCount'] = $ModifyPricePendingCount;
            $data['SurveyWaitingListCount'] = $SurveyWaitingListCount;
            $data['SurveyfollowUpCount'] = $SurveyfollowUpCount;
            $data['ReportProducedCount'] = $ReportProducedCount;
            $data['ReportReviewedCount'] = $ReportReviewedCount;
            $data['WorkflowPendingCount'] = $WorkflowPendingCount;
            $data['WorkflowProgressCount'] = $WorkflowProgressCount;
        }

        return $this->buildSuccess($data);
	}

    /**
     * 消息已读调用方法
     *
     * @author           cavan
     *
     * @param       ids                 //信息表id字符串
     */
    public function MessageRead(){
        $ids = $this->request->post('ids', '', 'trim');                           //信息表id
        $relsut = array();
        if(!$ids){
            $Mdb = new Message();
            $resultData=$Mdb->where(["status"=>1,"issee"=>2,"user_id"=>$this->userInfo['user_id']])
                ->field('id')
                ->select()
                ->toArray();
            if(!empty($resultData)){
                foreach ($resultData as $k => $v){
                    $relsut = MessageRead($v['id']);
                }
            }else{
                return $this->buildSuccess();
            }
        }else{
            $relsut = MessageRead($ids);
        }
        if($relsut && $relsut['code'] == 1){
            return $this->buildSuccess();
        }else {
            return $this->buildFailed("操作成功");
        }
    }

	/**
     * app消息写入方法
     *
     * @author           cavan
     *
     * @param       quot_id                 //询价主表id
     * @param       type                       //消息归属
     * @param       message_type               //消息类型
     * @param       property_cert_info_id          //物业表id
	*/
	public function publicMessage(){
        $quot_id = $this->request->post('quot_id', '', 'trim');                           //询价主表id
        $type = $this->request->post('type', '', 'trim');                                       //消息归属
        $message_type = $this->request->post('message_type', '', 'trim');                       //消息类型
        $property_cert_info_id = $this->request->post('property_cert_info_id', '', 'trim');             //物业表id

        $relsut = PublicMessage($quot_id,$type,$message_type,$property_cert_info_id);
        if($relsut['code'] == 1){
            return $this->buildSuccess();
        }else {
            return $this->buildFailed($relsut['msg']);
        }
    }

    /**
     * 公告 / 传阅
     *
     * @author           cavan
     *
     */
    public function Notice(){
        if(empty($this->userInfo)){
            return $this->buildFailed("登录已失效");
        }
        $Ndb = new Notice();
        $Attachment = new Attachment();             //获取图片信息

        $resultData1=$Ndb->where(["type"=>1])
            ->where("status",1)
            ->order(['update_time'=>'desc','create_time'=>'desc'])
            ->field('*')
            ->limit(5)
            ->select()
            ->toArray();

        if(!empty($resultData1)){
            foreach ($resultData1 as $k => $v){
                //图片列表
                $resultData1[$k]['fileslist'] = !empty($v['files'])?$Attachment->getUrls($v['files']):array();
            }
        }

        $user_id = $this->userInfo['user_id'];
        $resultData2=$Ndb->where(["type"=>2])
            ->where('FIND_IN_SET(:uid,relevant_personnel_ids)',['uid' => $user_id])
            ->where("status",1)
            ->order(['update_time'=>'desc','create_time'=>'desc'])
            ->field('*')
            ->limit(5)
            ->select()
            ->toArray();

        if(!empty($resultData2)){
            foreach ($resultData2 as $k => $v){
                //图片列表
                $resultData2[$k]['fileslist'] = !empty($v['files'])?$Attachment->getUrls($v['files']):array();
                $resultData2[$k]['propertyDetails'] = Db::name("notice_reply")->where("notice_id",$v['id'])->field("*")->select();
            }
        }

        $data['Notice'] = $resultData1;
        $data['Circulation'] = $resultData2;

       return $this->buildSuccess($data);

    }


    /**
     * 获取信息列表最新 10条
     * @author   cavan
     */
    public function MessageRemindAll()
    {
        $min_id = $this->request->post('min_id', '', 'trim');                           //分页
        if(empty($this->userInfo)){
            return $this->buildFailed("登录已失效");
        }
        $Mdb = new Message();
        $where = array();
        $where[] = ["status","=",1];
        $where[] = ["user_id","=",$this->userInfo['user_id']];
        if($min_id){
            $where[] = ["id","<",$min_id];
        }
        $resultData=$Mdb->where($where)
            ->order(['issee'=>'desc','id'=>'desc'])
            ->field('*')
            ->limit(10)
            ->select()
            ->toArray();
        $issee_num = $Mdb->where(["status"=>1,'issee'=>2,"user_id"=>$this->userInfo['user_id']])->count();
        if(!empty($resultData)){
            foreach ($resultData as $kd => $vd){
                $resultData[$kd]['create_time'] = date("Y-m-d H:i",strtotime($vd['create_time']));
                if($vd['type'] == 1){
                    $resultData[$kd]['messageType'] = "inquiryPending";
                }else if($vd['type'] == 2){
                    if($vd['message_type'] == 11 || $vd['message_type'] == 31){         //报告已完成  报告完成时间不是当天的不显示
                        $completion_time = Db::name("report")
                            ->where("quot_id",$vd['quot_id'])
                            ->value("completion_time");
                        if(!$completion_time || ($completion_time && date("Y-m-d",$completion_time) != date("Y-m-d",time()))){
                            unset($resultData[$kd]);
                        }else{
                            $resultData[$kd]['messageType'] = "OrderProgress";
                        }
                    }else{
                        $resultData[$kd]['messageType'] = "OrderProgress";
                    }
                }else if($vd['type'] == 3){
                    $resultData[$kd]['messageType'] = "ModifyPricePending";
                }else if($vd['type'] == 4){
                    $resultData[$kd]['messageType'] = "SurveyWaitingList";
                }else if($vd['type'] == 5){
                    $resultData[$kd]['messageType'] = "SurveyfollowUp";
                }else if($vd['type'] == 6){
                    $resultData[$kd]['messageType'] = "ReportProduced";
                }else if($vd['type'] == 7){
                    $resultData[$kd]['messageType'] = "ReportReviewed";
                }else if($vd['type'] == 8){
                    $resultData[$kd]['messageType'] = "WorkflowPending";
                }else if($vd['type'] == 9){
                    $resultData[$kd]['messageType'] = "WorkflowProgress";
                }
            }
        }
        $data = array();
        $data['issee_num'] = $issee_num;
        $data['list'] = array_merge($resultData);

        return $this->buildSuccess($data);
    }

    /**
     * 消息推送
     *
    */
    public function messagePush(){
        ignore_user_abort(TRUE); //如果客户端断开连接，不会引起脚本abort
        set_time_limit(0); //取消脚本执行延时上限

        $request = Request::instance();
        $par = $request->param();
        $par = json_decode(urldecode($par['query']), true);
        if(!empty($par)){
            $res = sendMessage($par['user_id'],$par['message_content']);
            Log::write("参数：".json_encode($par)."--返回：".$res,'workermanmsg');
        }
    }

    //数组排序
    function arraySort($array,$keys,$sort='asc') {
        $newArr = $valArr = array();
        foreach ($array as $key=>$value) {
            $valArr[$key] = $value[$keys];
        }
        ($sort == 'asc') ?  asort($valArr) : arsort($valArr);
        reset($valArr);
        foreach($valArr as $key=>$value) {
            $newArr[$key] = $array[$key];
        }
        return $newArr;
    }
}