jili2/application/common/model/Orders.php

<?php

namespace app\common\model;
use app\common\util\AppMsg;
use app\hander\HelpHander;
use think\Db;
use think\Exception;

class Orders extends Base {
    public $priority = [
        1 => '可延缓的',
        2 => '常规',
        3 => '紧急',
        4 => '预约',
    ];
    public $source_type = [
        1 => '一键呼叫',
        2 => '隐患',
        3 => '投诉',
    ];
    public $table = 'orders';
    protected $validateName = 'Orders';
    public function addSave($data, $type = 0) {//type 是否是调度发单1是
        $scene = 'dispatchAdd';
        if ($type == 0) {
            $scene = 'addShow';
        }
        $data['userType'] = isset($data['userType']) ? $data['userType'] : 0;
        $data['isSpontaneous'] = isset($data['isSpontaneous']) ? $data['isSpontaneous'] : 0;
        $data['quality_type'] = isset($data['quality_type']) ? $data['quality_type'] : 0;
        if(isset($data['source_type']) && $data['source_type']==4 && $data['isSpontaneous']==0){//一键呼叫派发

            if(!isset($data['work_type_mode']) || $data['work_type_mode'] <0){
                $this->error = '请选择转单类型';
                return false;
            }
            $config = Db::name('config')
                ->where('name','web_order_transfer_type')
                ->value('value');
            if(empty($config)){
                $workType = [];
            }else{
                $workType = explode('|',$config);

            }
            if(!in_array($data['work_type_mode'],$workType)){
                $this->error = '当前类型不能进行转单';
                return false;
            }
            if($type==1){
                if($data['userType']==0){
                    $data['to_user_id'] = !isset($data['to_user_id'])?$data['to_user_id'.$data['work_type_mode']]:$data['to_user_id'];
                }else{
                    $data['to_roles_id'] =!isset($data['to_roles_id'])? $data['to_roles_id'.$data['work_type_mode']]:$data['to_roles_id'];
                }
            }

        }
        $result = validate($this->validateName)->check($data, [], $scene);
        if (true !== $result) {
            $this->error = validate($this->validateName)->getError();
            return false;
        }
        if($data['work_type_mode']!=3){
            if(empty($data['content'])){
                $images = isset($data['images']) ? $data['images'] : '';
                $videos = isset($data['videos']) ? $data['videos'] : '';
                $voices = isset($data['voices']) ? $data['voices'] : '';
                if(empty($images) && empty($videos) && empty($voices)){
                    $this->error = '内容不能为空';
                    return false;
                }
            }
        }
        if ($data['work_type_mode'] == 3) {
            $result = validate('OrdersConvey')->check($data, []);
            if (true !== $result) {
                $this->error = validate('OrdersConvey')->getError();
                return false;
            }
        }
        if($type == 1 && $data['work_type_mode'] == 15) { // 品质整改
            if(!isset($data['informer_user']) || empty($data['informer_user'])){
                $this->error = '知会人不能为空';
                return false;
            }
        }
        $sData = array(
            'dep_id' => isset($data['dep_id']) && !empty($data['dep_id']) ? $data['dep_id'] : 0,
            'org_id' => $data['org_id'],
            'user_id' => $data['user_id'],
            'order_mode' => $type == 0 ? 1 : 4,
            'create_time' => getTime(),
            'create_yyyy' => date('Y'),
            'create_yyyymm' => date('Ym'),
            'create_yyyymmdd' => date('Ymd'),
            'sn' => get_unique_sn(get_config('sn_prefix')),
            'content' => $data['content'],
            'images' => isset($data['images']) ? $data['images'] : '',
            'videos' => isset($data['videos']) ? $data['videos'] : '',
            'voices' => isset($data['voices']) ? $data['voices'] : '',
            'work_type_mode' => $data['work_type_mode'],
            'quality_type' => isset($data['quality_type'])?$data['quality_type']:0,
            'quality_cate' => isset($data['quality_cate'])?$data['quality_cate']:0,
            'informer_user' => isset($data['informer_user'])?$data['informer_user']:0,
            'source_type' => $type == 0 ? 1 : 2,
            'name' => isset($data['name']) ? $data['name'] : '',
            'phone' => isset($data['phone']) ? $data['phone'] : '',
        );
        if(isset($data['source_type']) && !empty($data['source_type'])){
            $sData['source_type'] = $data['source_type'];
        }
        //普通订单自发
        if (isset($data['source_type']) && $data['source_type'] == 3) {
            $sData['source_type'] = 3;
            $sData['order_mode'] = 4;
            $sData['send_time'] = getTime();
            if ($data['work_type_mode'] == 1) {
                if (!isset($data['type_id']) || empty($data['type_id'])) {
                    $this->error = '请选择报修事项';
                    return false;
                }

            }
        }

        //一键呼叫订单自发
        if (isset($data['source_type']) && $data['source_type'] == 4 && $data['isSpontaneous']==1) {
            $sData['source_type'] = 3;
            $sData['order_mode'] = 4;
            $sData['send_time'] = getTime();


        }
        if ($type == 1) {
            if ($data['userType'] == 0) {

                if (!isset($data['to_user_id']) || empty($data['to_user_id'])) {
//                    $this->error = '请选择执行人';
//                    return false;
                    $sData['order_mode'] = 1;
                    $data['to_user_id'] = "";
                }else{
                    $sData['send_time'] = getTime();
                    $sData['order_mode'] = 4;
                }
                if ($data['work_type_mode'] == 1) {
                    if (!isset($data['type_id']) || empty($data['type_id'])) {
                        $this->error = '请选择报修事项';
                        return false;
                    }
                }
            }
            else {
                if(two_dispatch_off($data['org_id'])!=1){
                    $this->error = '二级调度开关未开启';
                    return false;
                }
                $sData['order_mode'] = 1;
                $sData['is_deal'] = 1;
                if (!isset($data['to_roles_id']) || empty($data['to_roles_id'])) {
//                    $this->error = '请选择二级调度';
//                    return false;
                    $sData['is_deal'] = 0;
                }
            }
        }

        if(isset($data['sxType'] ) && !empty($data['sxType']) && $data['sxType'] == 1){
            $sData['name']=isset($data['name'])?$data['name']:'';
            $sData['phone']=isset($data['phone'])?$data['phone']:'';
        }

//        if($type == 0){
//            $sData['from'] = 1;
//        }

        $this->startTrans();
        try {
            $pusharr = []; // 需要推送给工人
            $pushdis = []; // 需要推送给二级调度
            $orderId = $this->insertGetId($sData);
            if (!$orderId) {
                \exception('保存订单失败');
            }

            if(isset($data['id']) && $data['id'] > 0){ // 电话保单
                Db::name('phone_monitor_record')->where('id',$data['id'])->update([
                    'order_id' => $orderId,
                    'update_time' => date('Y-m-d H:i:s')
                ]);
            }

            if ($data['work_type_mode'] == 1) {//报修订单
                $rData = [];
                if (isset($data['type_id']) && !empty($data['type_id'])) {
                    $rData['type_id'] = $data['type_id'];
                }
                if (isset($data['address_id']) && !empty($data['address_id'])) {
                    $rData['address_id'] = $data['address_id'];
                }
                if (isset($data['repair_priority']) && !empty($data['repair_priority'])) {
                    $rData['repair_priority'] = $data['repair_priority'];
                }
                if (!empty($rData)) {
                    $rData['order_id'] = $orderId;
                    $res = Db::name('order_repair')
                        ->insert($rData);
                    if (!$res) {
                        \exception('保存维修扩展失败');
                    }
                }
            }
            if ($data['work_type_mode'] == 3) {
                if (!$data['start'] || !$data['end']) {
                    $this->error = '取件与送达地点不能为空';
                    return false;
                }
                if ($data['start'] == $data['end']) {
                    $this->error = '取件与送达地点不能是同一地点';
                    return false;
                }

                if (!$data['type']) {
                    $this->error = '运送类型不能为空';
                    return false;
                }
                $conveyCate = Db::name('convey_cate')
                    ->where('id', $data['type'])
                    ->find();
                if($conveyCate){ // 需求时间和应完成时间，都由前端传
                    if(!$data['xq_time'] || !$data['ywc_time']){
                        $data['xq_time'] = date('Y-m-d H:i:s');
                        $time = Db::name('time')
                            ->where('id',$conveyCate['time_id'])
                            ->find();
                        $data['ywc_time'] = date('Y-m-d H:i',strtotime($data['xq_time']) + 60*$time['bz_time']);
                    }else{
                        if ($data['xq_time'] >= $data['ywc_time']) {
                            $this->error = '应完成时间应大于需求时间';
                            return false;
                        }
                        if (strtotime($data['xq_time']) < time() - 10 * 60) {
                            $this->error = '需求时间已过时';
                            return false;
                        }
                    }
                }

                /*if($conveyCate['cate']==4){
                    if (!$data['xq_time'] || !$data['ywc_time']) {
                        $this->error = '应完成时间应和需求时间不能为空';
                        return false;
                    }
                    if ($data['xq_time'] >= $data['ywc_time']) {
                        $this->error = '应完成时间应大于需求时间';
                        return false;
                    }
                    if (strtotime($data['xq_time']) < time() - 10 * 60) {
                        $this->error = '需求时间已过时';
                        return false;
                    }
                }else{
                    $data['xq_time'] = date('Y-m-d H:i:s');
                    $time = Db::name('time')
                        ->where('id',$conveyCate['time_id'])
                        ->find();
                    $data['ywc_time'] = date('Y-m-d H:i',strtotime($data['xq_time']) + 60*$time['bz_time']);
                }*/


                $ysData = array(
                    'order_id' => $orderId,
                    'type' => $data['type'],
                    'start' => $data['start'],
                    'end' => $data['end'],
                    'xq_time' => isset($data['xq_time'])?$data['xq_time']:"",
                    'ywc_time' => isset($data['ywc_time'])?$data['ywc_time']:"",
                    'name' => isset($data['name'])?$data['name']:"",
                    'phone' => isset($data['phone'])?$data['phone']:"",
                    'device_id' => isset($data['device_id']) ? (int)$data['device_id'] : 0,
                    'priority' => empty($data['priority']) ? 0 : $data['priority'],
                    'score'=>$conveyCate['score']
                );
                if(empty($ysData['xq_time'])){
                    unset($ysData['xq_time']);
                }
                if(empty($ysData['ywc_time'])){
                    unset($ysData['ywc_time']);
                }
                $oCid = Db::name('order_convey')
                    ->insertGetId($ysData);
                if (!$oCid) {
                    exception('运送信息保存失败');
                }

                if(isset($data['way_addr']) && !empty($data['way_addr'])){
                    $wayAddr = explode(',',$data['way_addr']);
                    foreach ($wayAddr as $k=>$v){
                        if($v){
                            $cdata = [
                                'order_id'=>$orderId,
                                'addr'=>$v,
                                'create_time'=>date('Y-m-d H:i:s'),
                                'order_convey_id'=>$oCid,
                            ];
                            $oce =  Db::name('order_convey_end')->insert($cdata);
                            if(!$oce){
                                exception('途径地点信息保存失败');
                            }
                        }
                    }

                }

                model('UserConveyCate')->updateCate($data['user_id'],$data['type']);
                if ($conveyCate['cate'] == 1) {
                    $patient = [
                        'order_id' => $orderId,
                        'bed_number' => isset($data['bed_number']) ? $data['bed_number'] : '',
                        'name' => isset($data['p_name']) ? $data['p_name'] : '',
                        'ba_number' => isset($data['ba_number']) ? $data['ba_number'] : '',
                        'gender' => isset($data['gender']) && !empty($data['gender']) ? $data['gender'] : 0,
                        'back' => isset($data['back']) && !empty($data['back']) ? $data['back'] : 0,
                    ];
                    $ocPid = Db::name('order_convey_patient')
                        ->insertGetId($patient);
                    if (!$ocPid) {
                        exception('保存运送病人扩展失败');
                    }
                }
            }
            if ($type == 1 || $sData['source_type']==3 || ($sData['source_type']==4 && $data['isSpontaneous']==1)) {
                if ($data['userType'] == 0) {
                    if($sData['source_type']==3 || ($sData['source_type']==4 && $data['isSpontaneous']==1)){
                        $data['to_user_id'] = $data['user_id'];
                    }
                    $send_user_num = $this->sendUserNum($data['work_type_mode'],$data['org_id']);
                    $users = empty($data['to_user_id'])?[]:explode(',', $data['to_user_id']);
                    if($send_user_num==1 && count($users) >1){
                        exception('执行人只能选择单人');
                    }
                    $to_user_id =  array_unique($users);
                    $todoData = [
                        'order_id' => $orderId,
                        'todo_content' => isset($data['todo_content'])?$data['todo_content']:"",
                        'create_user_id' => $data['user_id'],
                        'org_id' => $data['org_id'],
                        'create_time' => getTime(),
                        'todo_mode' => $sData['source_type']==3?2:1,
                        'work_type_mode' => $data['work_type_mode'],
                        'create_yyyy' => date('Y'),
                        'create_yyyymm' => date('Ym'),
                        'create_yyyymmdd' => date('Ymd'),
                        'quality_type' => $data['quality_type'],
                    ];
                    if($sData['source_type']==3){
                        $todoData['confirm_time'] = getTime();
                    }

                    $taskData = [
                        'org_id' => $data['org_id'],
                        'type' => 1,
                        'start_time' => getTime(),
                        'create_time' => getTime(),
                    ];
                    if($data['work_type_mode']==1){
                        if (isset($data['repair_priority']) && $data['repair_priority']==3) {
                            $taskData['priority'] = 1;
                        }
                    }elseif ($data['work_type_mode']==3){
                        if (isset($data['priority']) && $data['priority']==3) {
                            $taskData['priority'] = 2;
                        }
                    }
                    $sns = [];
                    foreach ($to_user_id as $k => $v) {
                        if(empty($v)){
                            continue;
                        }
                        $todoData['to_user_id'] = $v;
                        $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                        while (true){
                            if(in_array($todoData['sn'],$sns)){
                                $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                            }else{
                                $sns[] = $todoData['sn'];
                                break;
                            }
                        }

                        if($type == 1 && $data['work_type_mode'] == 15){ // 品质整改
                            $todoData['todo_mode'] = 2;
                            $todoData['confirm_time'] = getTime();
                        }
                        $res = Db::name('todo')
                            ->insertGetId($todoData);
                        if (!$res) {
                            \exception('执行人:' . $v . '派单失败');
                        }
                        if($sData['source_type']!=3){
                            $pusharr[] = [
                                'user_id' => $v,
                                'todo_id' => $res
                            ];
                        }
                        $taskData['user_id'] = $v;
                        $taskData['bus_id'] = $res;
                        $res = Db::name('task')
                            ->insert($taskData);
                        if (!$res) {
                            \exception('执行人:' . $v . '任务保存失败');
                        }
                    }
                    if(check_two_dispatch($data['user_id'])==1){
                        $dLog = [
                            'user_id'=>$data['user_id'],
                            'to_user_id'=>$data['user_id'],
                            'create_time' => getTime(),
                            'content' => isset($data['todo_content']) ? $data['todo_content'] : '',
                            'order_id' => $orderId,
                            'roles_id' => 0

                        ];
                        $r = Db::name('orders')
                            ->where('id',$orderId)
                            ->update(['is_deal'=>1]);
                        if(!$r){
                            \exception('订单更新失败');

                        }
                        $res = Db::name('dispatch_log')
                            ->insert($dLog);
                        if (!$res) {
                            \exception('二级调度记录保存失败');
                        }
                    }
                }
                else {
                    $pRolesId = explode(',',$data['to_roles_id']);
                    $pp = [];
                    foreach ($pRolesId as $k=>$v){
                        $logData = [
                            'user_id' => $data['user_id'],
                            'to_user_id' =>0,
                            'create_time' => getTime(),
                            'content' => isset($data['todo_content']) ? $data['todo_content'] : '',
                            'order_id' => $orderId,
                            'roles_id' => $v
                        ];
                        $pp[] = $logData;
                    }
                    $pushdis = Db::name('user_roles')
                        ->where('roles_id','in',$pRolesId)
                        ->column('user_id');
                    $res = Db::name('dispatch_log')
                        ->insertAll($pp);
                    if (!$res) {
                        \exception('派发失败');
                    }
                }
            }
            if($type == 1 && $data['work_type_mode'] == 15){ // 品质整改
                if($data['quality_type']==0){
                    Db::name('daily_record')->where('id',$data['daily_record_id'])->update(['order_id' => $orderId]);
                }elseif ($data['quality_type']==1){
                    Db::name('device_record')->where('id',$data['daily_record_id'])->update(['order_id' => $orderId]);
                }
                elseif (in_array($data['quality_type'],[2,3,4,5])){
                    Db::name('patrol_record')->where('id',$data['daily_record_id'])->update(['order_id' => $orderId]);
                }
            }
            $this->commit();

            if($pusharr){
                foreach ($pusharr as $k=>$v){
                    // 极光推送
                    send_jpush([$v['user_id']],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$v['todo_id']]);
                }
            }
            if(empty($sData['informer_user']) && $type == 1 && $data['work_type_mode'] == 15){
                send_jpush([$sData['informer_user']],AppMsg::PUSH_INFORMER_USER,'您有一个品控订单,请知晓',['id'=>$orderId]);

            }
            if($pushdis){
                foreach ($pushdis as $k=>$v){
                    // 极光推送
                    send_jpush([$v],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$orderId]);
                }
            }

            if($type == 0 && $sData['source_type'] != 3){ // 客户发单，需要检查是否有抢单
                $off = model('Config')->getConfig('org_grab_order'.$sData['work_type_mode'],$sData['org_id']);
                if($off){
                    $workers = model('WorkTypeMode')->getRolesUserApp($sData['work_type_mode'],$sData['org_id']);
                    $uids = [];
                    foreach ($workers as $v){
                        $uids[] = $v['id'];
                    }
                    if($uids){
                        send_jpush($uids,AppMsg::PUSH_ORDER_ROB,'',['id'=>$orderId]);
                    }
                }
            }

            $dispatchOff = model('Config')->getConfig('org_dispatch_off',$sData['org_id']);

            if($dispatchOff==1){
                //提醒调度
                $dUser = model('Roles')->getDispatchOrder($sData['work_type_mode'],$sData['org_id']);
                if(!empty($dUser)){
                    send_jpush($dUser,AppMsg::PUSH_WORKER_ORDER_SEND,'您有一个新的订单需要及时处理',['id'=>$orderId]);

                }
            }

            return true;
        } catch (Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    public function editSave($data){
        $order = Db::name('orders')->where('id',$data['id'])->find();
        if(!$order || $order['del'] == 1){
            $this->error = '订单不存在';
            return false;
        }
        if($order['order_mode'] != 2 && $order['order_mode'] != 3){
            $this->error = '只能修改已取消的订单';
            return false;
        }
        if(empty($data['to_user_id'])){
            $this->error = '请选择执行人';
            return false;
        }
        if($order['work_type_mode'] ==1){
            if(empty($data['type_id'])){
                $this->error = '请选择报修事项';
                return false;
            }
            if(empty($data['repair_priority'])){
                $this->error = '请选择报修紧急程度';
                return false;
            }
        }else if($order['work_type_mode'] == 3){
            if(empty($data['type'])){
                $this->error = '请选择运送类型';
                return false;
            }
            if(empty($data['priority'])){
                $this->error = '请选择优先级';
                return false;
            }
            if(empty($data['start'])){
                $this->error = '请选择开始地点';
                return false;
            }
            if(empty($data['end'])){
                $this->error = '请选择结束地点';
                return false;
            }
            if(empty($data['xq_time'])){
                $this->error = '请选择需求时间';
                return false;
            }
            if(empty($data['ywc_time'])){
                $this->error = '请选择应完成时间';
                return false;
            }
        }

        Db::startTrans();
        try{
            $ret = Db::name('orders')->where('id',$data['id'])->update([
                'content' => $data['content'],
                'order_mode' => 4,
                'images' => $data['images'],
                'dep_id' => $data['dep_id'],
                'send_time' => getTime()
            ]);
            if(!$ret){
                \exception("操作失败");
            }
            $taskData = [
                'org_id' => $order['org_id'],
                'type' => 1,
                'start_time' => getTime(),
                'create_time' => getTime(),
            ];
            if($order['work_type_mode'] == 1){
                if (isset($data['repair_priority']) && $data['repair_priority']==3) {
                    $taskData['priority'] = 1;
                }
                $repair = Db::name('order_repair')->where('order_id',$order['id'])->find();
                if($repair){
                    Db::name("order_repair")->where('id',$repair['id'])->update([
                        'type_id' => $data['type_id'],
                        'address_id' => empty($data['address_id'])?0:$data['address_id'],
                        'repair_priority' => $data['repair_priority'],
                        'update_time' => getTime()
                    ]);
                }else{
                    Db::name("order_repair")->insertGetId([
                        'order_id' => $order['id'],
                        'type_id' => $data['type_id'],
                        'address_id' => empty($data['address_id'])?0:$data['address_id'],
                        'repair_priority' => $data['repair_priority'],
                        'update_time' => getTime()
                    ]);
                }
            }else if($order['work_type_mode'] == 3){
                if (isset($data['priority']) && $data['priority']==3) {
                    $taskData['priority'] = 2;
                }
                $conveyCate = Db::name('convey_cate')->where('id',$data['type'])->find();
                if($conveyCate['cate'] == 1){
                    $ocp = Db::name('order_convey_patient')->where('order_id',$data['id'])->find();
                    if($ocp){
                        Db::name('order_convey_patient')->where('id',$ocp['id'])->update([
                            'order_id' => $data['id'],
                            'bed_number' => $data['bed_number'],
                            'name' => $data['p_name'],
                        ]);
                    }else{
                        Db::name('order_convey_patient')->insertGetId([
                            'order_id' => $data['id'],
                            'bed_number' => $data['bed_number'],
                            'name' => $data['p_name'],
                        ]);
                    }
                }

                $oc = Db::name('order_convey')->where('order_id',$data['id'])->find();
                if($oc){
                    Db::name('order_convey')->where('id',$oc['id'])->update([
                        'order_id' => $data['id'],
                        'type' => $data['type'],
                        'start' => $data['start'],
                        'end' => $data['end'],
                        'xq_time' => $data['xq_time'],
                        'ywc_time' => $data['ywc_time'],
                        'device_id' => $data['device_id'],
                        'priority' => $data['priority'],
                    ]);
                }else{
                    Db::name('order_convey')->insertGetId([
                        'order_id' => $data['id'],
                        'type' => $data['type'],
                        'start' => $data['start'],
                        'end' => $data['end'],
                        'xq_time' => $data['xq_time'],
                        'ywc_time' => $data['ywc_time'],
                        'device_id' => $data['device_id'],
                        'priority' => $data['priority'],
                    ]);
                }

                Db::name('order_convey_end')->where('order_id',$data['id'])->delete();
                $addrs = empty($data['way_addr'])?[]:explode(',',$data['way_addr']);
                foreach ($addrs as $k=>$v){
                    Db::name('order_convey_end')->insertGetId([
                        'order_id' => $data['id'],
                        'addr' => $v,
                        'create_time' => getTime()
                    ]);
                }
            }

            $uids = explode(',',$data['to_user_id']);
            $uids = array_unique($uids);

            $pusharr = [];
            $sns = [];
            foreach ($uids as $k=>$v){
                $todoData = [
                    'order_id' => $order['id'],
                    'org_id' => $order['org_id'],
                    'work_type_mode' => $order['work_type_mode'],
                    'to_user_id' => $v,
                    'todo_content' => $data['todo_content'],
                    'create_user_id' => $data['user_id'],
                    'create_time' => getTime(),
                    'todo_mode' => 1,
                    'create_yyyy' => date("Y"),
                    'create_yyyymm' => date("Ym"),
                    'create_yyyymmdd' => date("Ymd"),
                ];

                $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                while (true){
                    if(in_array($todoData['sn'],$sns)){
                        $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                    }else{
                        $sns[] = $todoData['sn'];
                        break;
                    }
                }
                $res = Db::name('todo')->insertGetId($todoData);
                if (!$res) {
                    \exception('执行人:' . $v . '派单失败');
                }
                $pusharr[] = [
                    'user_id' => $v,
                    'todo_id' => $res
                ];
                $taskData['user_id'] = $v;
                $taskData['bus_id'] = $res;
                $res = Db::name('task')->insert($taskData);
                if (!$res) {
                    \exception('执行人:' . $v . '任务保存失败');
                }
            }

            if($pusharr){
                foreach ($pusharr as $k=>$v){
                    // 极光推送
                    send_jpush([$v['user_id']],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$v['todo_id']]);
                }
            }

            Db::commit();

            return true;
        }catch (\Exception $e){
            Db::rollback();
            $this->error = $e->getMessage();
            return false;
        }



    }

    public function formatOrderConvey($lists, $status = 0, $is_list = 0) {
        $newret  = [];
        $newret1 = [];
        $newret2 = [];
        $newret3 = [];
        $newret4 = [];

        if (empty($lists)) {
            return [$newret, $newret1, $newret2, $newret3, $newret4];
        }

        // 只处理 work_type_mode = 3 的订单
        $orders = [];
        foreach ($lists as $v) {
            if (isset($v['work_type_mode']) && $v['work_type_mode'] == 3) {
                $orders[$v['id']] = $v;
            }
        }
        if (empty($orders)) {
            foreach ($lists as $v) {
                $this->classifyOrder($v, $status, $newret, $newret1, $newret2, $newret3, $newret4);
            }
            return [$newret, $newret1, $newret2, $newret3, $newret4];
        }

        $orderIds = array_keys($orders);
        $now = time();

        // ===== 1. order_convey（一次） =====
        $orderConveys = Db::name('order_convey')->whereIn('order_id', $orderIds)->select();
        $orderConveyMap = [];
        $deviceIds = [];
        $addressIds = [];
        foreach ($orderConveys as $oc) {
            $orderConveyMap[$oc['order_id']] = $oc;
            $deviceIds[]  = $oc['device_id'];
            $addressIds[] = $oc['start'];
            $addressIds[] = $oc['end'];
        }

        // ===== 2. convey_cate + time（一次） =====
        $typeIds = array_column($orders, 'type');
        foreach ($orderConveys as $oc) {
            $typeIds[] = $oc['type'];
        }
        $typeIds = array_unique(array_filter($typeIds));
        $conveyMap = [];
        if ($typeIds) {
            $conveyMap = Db::name('convey_cate')
                ->alias('c')
                ->join('time t', 't.id=c.time_id')
                ->whereIn('c.id', $typeIds)
                ->field('c.id,c.cate,c.title,t.yy_time,t.bz_time,t.jg_time,t.wjjg_time')
                ->column('c.id,c.cate,c.title,t.yy_time,t.bz_time,t.jg_time,t.wjjg_time', 'c.id');
        }

        // ===== 3. address（一次） =====
        $addressIds = array_unique(array_filter($addressIds));
        $addressMap = $addressIds
            ? Db::name('address')->whereIn('id', $addressIds)->column('title', 'id')
            : [];

        // ===== 4. convey_device（一次） =====
        $deviceIds = array_unique(array_filter($deviceIds));
        $deviceMap = $deviceIds
            ? Db::name('convey_device')->whereIn('id', $deviceIds)->column('title', 'id')
            : [];

        // ===== 6. todo + user（一次） =====
        $todos = Db::name('todo')
            ->alias('t')
            ->join('user u', 'u.id=t.to_user_id')
            ->whereIn('t.order_id', $orderIds)
            ->where('t.todo_mode', 'in', [1, 2, 3, 4])
            ->where('t.del', 0)
            ->field('t.id,t.order_id,u.real_name,u.mobile,t.confirm_time')
            ->order('t.id asc')
            ->select();
        $todoGroup = [];
        $todoIds = [];
        foreach ($todos as $t) {
            $todoGroup[$t['order_id']][] = $t;
            $todoIds[] = $t['id'];
        }

        // ===== 7. todo_convey start_time（一次） =====
        $startTimeMap = $todoIds
            ? Db::name('todo_convey')->whereIn('todo_id', $todoIds)->column('start_time', 'todo_id')
            : [];

        // ===== 8. order_delay（一次） =====
//        $orderDelays = Db::name('order_delay')->whereIn('order_id', $orderIds)->select();
//        $delayGroup = [];
//        $delayReasonIds = [];
//        foreach ($orderDelays as $d) {
//            $delayGroup[$d['order_id']][] = $d;
//            if ($d['status'] == 0) {
//                $delayReasonIds[] = $d['delay_reason_id'];
//            }
//        }
//        $delayReasonIds = array_unique(array_filter($delayReasonIds));
//        $delayReasonMap = $delayReasonIds
//            ? Db::name('delay_reason')->whereIn('id', $delayReasonIds)->column('title', 'id')
//            : [];

        // ===== 9. 床号（一次） =====
        $bedMap = Db::name('order_convey_patient')->whereIn('order_id', $orderIds)->column('bed_number', 'order_id');

        // ===== 10. 用户（一次，real_name + mobile） =====
        $userRows = Db::name('user')
            ->whereIn('id', array_unique(array_filter(array_column($lists, 'user_id'))))
            ->field('id,real_name')
            ->select();
        $userMap = array_column($userRows, null, 'id');
        $priority = $this->priority ?? [];


        // ===== 循环内纯内存组装 + 分类 =====
        foreach ($orders as $id => $v) {
            $oc     = $orderConveyMap[$id] ?? [];
            $convey = $conveyMap[$v['type']] ?? ($conveyMap[$oc['type'] ?? 0] ?? []);

            // ---- 基础字段 ----
            $v['type_name']   = $convey['title'] ?? '';
            $v['start_name']  = $addressMap[$oc['start'] ?? 0] ?? '';
            $v['end_name']    = $addressMap[$oc['end'] ?? 0] ?? '';
            $v['device_name'] = $deviceMap[$oc['device_id'] ?? 0] ?? '';
            $v['real_name']   = $userMap[$v['user_id']]['real_name'] ?? '';
            $v['priorityName']  = $priority[$v['priority']] ?? '';


            // ---- last_time ----
            $last = strtotime($v['ywc_time']) - $now;
            $v['last_time'] = $last > 0 ? round($last / 60) : 0;

            // ---- todo 汇总 ----
            $todo = $todoGroup[$id] ?? [];
            $usersArr = [];
            $confirmtime = '';
            foreach ($todo as $t) {
                $usersArr[] = $t['real_name'] . (!empty($t['mobile']) ? '[' . $t['mobile'] . ']' : '');
                if ($t['confirm_time']) {
                    if (!$confirmtime || $t['confirm_time'] < $confirmtime) {
                        $confirmtime = $t['confirm_time'];
                    }
                }
            }
            $v['is_todo']      = $todo ? 1 : 0;
            $v['real_names']   = implode(',', $usersArr);
            $v['confirm_time'] = $confirmtime;

            // ---- start_time（第一个 todo 的 todo_convey.start_time）----
            $firstTodoId = $todo[0]['id'] ?? 0;
            $startTime   = $startTimeMap[$firstTodoId] ?? '';
            $v['start_time'] = $startTime ? date('H:i', strtotime($startTime)) : '';
            // 兼容原 foreach 的字段名
            $v['starttime'] = $v['start_time'];

            // ---- delay ----
            $v['delay'] = 0;
            $v['delay_diff'] = 0;
            $v['delay_reason'] = '';
//            foreach (($delayGroup[$id] ?? []) as $d) {
//                $diff = $now - strtotime($d['start_time']);
//                if ($d['status'] == 0) {
//                    $v['delay'] = 1;
//                    $v['delay_reason'] = $delayReasonMap[$d['delay_reason_id']] ?? '';
//                }
//                $v['delay_diff'] += $diff;
//            }
//            $v['delay_diff'] = round($v['delay_diff'] / 60);

            // ---- status（与原 foreach 完全一致）----
            if ($v['delay'] == 1) {
                $v['status'] = 3;
            } else {
                $v['status'] = ($v['order_mode'] == 1) ? 1 : 2;
            }

            // ---- ss（按原 foreach：基于 xq_time，且 curtime > xqtime 才分段）----
            $xqtime  = strtotime($v['xq_time']);
            $curtime = time();
            if ($curtime > $xqtime) {
                $ct = round(($curtime - $xqtime) / 60);
                if ($ct < ($convey['yy_time'] ?? 0)) {
                    $ss = 0;
                } elseif ($ct < ($convey['bz_time'] ?? 0)) {
                    $ss = 1;
                } elseif ($ct < ($convey['jg_time'] ?? 0)) {
                    $ss = 2;
                } elseif ($ct < ($convey['wjjg_time'] ?? 0)) {
                    $ss = 3;
                } else {
                    $ss = 4;
                }
            } else {
                $ss = 0;
            }
            $v['ss'] = $ss;

            // ---- 时间展示 ----
            $v['xtime'] = date('H:i', strtotime($v['xq_time']));
            $v['stime'] = $v['send_time'] ? date('H:i', strtotime($v['send_time'])) : '';
            $v['ctime'] = $confirmtime ? date('H:i', strtotime($confirmtime)) : '';

            // ---- 床号（cate=1 才取）----
            $v['bed_number'] = (($convey['cate'] ?? 0) == 1) ? ($bedMap[$id] ?? '') : '';

            $orders[$id] = $v;

            // ---- 分类（用入参 $status，与原 foreach 一致）----
            $this->classifyOrder($v, $status, $newret, $newret1, $newret2, $newret3, $newret4);
        }

        // 非 work_type_mode=3 的数据按原字段分类（混合场景兜底）
        foreach ($lists as $v) {
            if (!isset($orders[$v['id']])) {
                $this->classifyOrder($v, $status, $newret, $newret1, $newret2, $newret3, $newret4);
            }
        }

        return [$newret, $newret1, $newret2, $newret3, $newret4];
    }
    private function classifyOrder($v, $status, &$newret, &$newret1, &$newret2, &$newret3, &$newret4) {
        $delay     = $v['delay'] ?? 0;
        $orderMode = $v['order_mode'] ?? 0;

        // 延时任务
        if ($status == 3 && $delay == 1) {
            $newret[]  = $v;
            $newret1[] = $v;
        }
        // 新任务
        if ($status == 1 && $orderMode == 1) {
            $newret[]  = $v;
            $newret2[] = $v;
        }
        // 进行中
        if ($status == 2 && $orderMode == 4) {
            $newret[]  = $v;
            $newret3[] = $v;
        }
        // 其他
        if (!$status || !in_array($status, [1, 2, 3])) {
            $newret[]  = $v;
            $newret4[] = $v;
        }
    }

    //后台格式化订单详情
    public function formatOrder($v, $is_list = 0) {
        $v['order_type'] = '';
        $v['order_type_matter'] = '';
        $v['address_title'] = '';
        $v['repair_priority'] = '';
        $v['task_priority'] = 0;
        $v['cons'] = [];
        if ($v['work_type_mode'] == 1) {
            $typeInfo = (new \app\common\model\OrderType())
                ->getTypeByOrderId($v['id']);
            $v['order_type'] = $typeInfo && isset($typeInfo['title']) ? $typeInfo['title'] : '';
            $v['order_type_matter'] = $typeInfo ? $typeInfo['child_title'] : '';
            $v['address_title'] = $typeInfo ? $typeInfo['address_title'] : '';
            $v['repair_priority'] = $typeInfo ? $typeInfo['repair_priority'] : '';
            $v['task_priority'] = $typeInfo?($typeInfo['repair_priority_index']==3?1:0):0;
            $todo_mate = Db::name('todo_mate')
                ->where('order_id',$v['id'])
                ->select();

            if(!empty($todo_mate)){
                $cons = Db::name('todo_mate_item')
                    ->alias('a')
                    ->join('mate_goods b','b.id = a.items_id')
                    ->where('a.todo_mate_id','in',array_column($todo_mate,'id'))
                    ->field('a.*,b.title')
                    ->select();
                foreach ($cons as $k1=>$v1){
                    $v['cons'][] = [
                        'title' =>$v1['title'],
                        'total' =>$v1['total'],
                        'money' =>$v1['money'],
                        'total_money' =>$v1['total_money'],
                        'realName' =>$this->getTableField('user',['id'=>$v1['user_id']],'real_name'),
                    ];

                }
            }

        }
        $v['type_name'] = '';
        $v['start_name'] = '';
        $v['end_name'] = '';
        $v['device_name'] = '';
        if ($v['work_type_mode'] == 3) {
            $oc = Db::name('order_convey')
                ->where('order_id', $v['id'])
                ->find();
            $v['type_name'] = $this->getTableField('convey_cate', ['id' => $oc['type']], 'title');
            $v['start_name'] = $this->getTableField('address', ['id' => $oc['start']], 'title');
            $v['end_name'] = $this->getTableField('address', ['id' => $oc['end']], 'title');
            $v['device_name'] = $this->getTableField('convey_device', ['id' => $oc['device_id']], 'title');
            $v['task_priority'] = $oc['priority']==3?2:0;
        }
        $v['work_type_mode_text'] = $this->getTableField('work_type_mode', ['id' => $v['work_type_mode']], 'name');
        $v['source_type_text'] =$v['from']>0? isset($this->source_type[$v['from']])?$this->source_type[$v['from']]:'':$this->getTableField('work_type_mode', ['id' => $v['work_type_mode']], 'name');
        $v['dep'] = $this->getTableField('dep', ['id' => $v['dep_id']], 'title');
        $v['order_mode_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'in_content');
        $v['order_mode_out_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'out_content');
        $v['order_mode_color'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'color');
        $v['real_name'] = $this->getTableField('user', ['id' => $v['user_id']], 'real_name');
        $v['informer_user_name'] = $this->getTableField('user', ['id' => $v['informer_user']], 'real_name');
        $v['mobile'] = $this->getTableField('user', ['id' => $v['user_id']], 'mobile');
        $v['schedulContent'] = '';
        $v['to_user_name'] = '';
        $v['quality_cate_name'] = '';
        if($v['work_type_mode']==15){
            $v['quality_cate_name'] = model('QualityCate')->getPTitle($v['quality_cate']);
        }
        $todo = Db::name('todo')
            ->where('order_id', $v['id'])
            ->where('del',0)
            ->select();
        if($todo){
            $toUserInfo = Db::name('user')
                ->where('id','in',array_column($todo,'to_user_id'))
                ->column('real_name');
            $v['to_user_name'] = implode(',',$toUserInfo);
        }
        $dispatchLog = Db::name('dispatch_log')
            ->where('order_id',$v['id'])
            ->find();
        if($dispatchLog && $dispatchLog['content']){
            $v['schedulContent'] = $dispatchLog['content'];
        }
        $pDep = '';
        $depInfo = Db::name('dep')
            ->where('id',$v['dep_id'])
            ->find();
        if($depInfo){
            $pDep = Db::name('dep_cate')
                ->where('id',$depInfo['cate_id'])
                ->value('title');
        }
        $v['dep_cate_name'] = $pDep;
        if ($is_list > 0) {
            $v['todo_list'] = [];
            $todo = Db::name('todo')
                ->where('order_id', $v['id'])
                ->where('del',0)
                ->select();
            if (!empty($todo)) {
                foreach ($todo as $k => $v1) {
                    $todo[$k]['to_real_name'] = $this->getTableField('user', ['id' => $v1['to_user_id']], 'real_name');
                    $todo[$k]['todo_mode_text'] = $this->getTableField('todo_mode', ['id' => $v1['todo_mode']], 'in_content');
                    $tx = $this->getTableField('todo_mode', ['id' => $v1['todo_mode']], 'out_content');
                    $todo[$k]['to_ok_images'] = !empty($v1['images'])?explode(',',$v1['images']):'';
                    $todo[$k]['todo_mode_out_text'] =$tx;
                    $todoConvey = Db::name('todo_convey')->where('todo_id',$v1['id'])->find();
                    $todo[$k]['start_img'] = $todoConvey?$todoConvey['start_img'] :'';
                    $todo[$k]['end_img'] = $todoConvey?$todoConvey['end_img'] :'';
                }


                $v['todo_list'] = $todo;
            }
            $v['comment'] = [];
            if ($v['order_mode'] == 6) {
                $v['comment'] = Db::name('comment')
                    ->where('type', $v['work_type_mode'])
                    ->where('from_id', $v['id'])
                    ->where('org_id', $v['org_id'])
                    ->find();
            }
            $v['oc'] = [];
            $v['ocp'] = [];
            if ($v['work_type_mode'] == 3) {
                $oc = Db::name('order_convey')
                    ->where('order_id', $v['id'])
                    ->find();
                $oc['type_name'] = $this->getTableField('convey_cate', ['id' => $oc['type']], 'title');
                $oc['start_name'] = $this->getTableField('address', ['id' => $oc['start']], 'title');
                $oc['end_name'] = $this->getTableField('address', ['id' => $oc['end']], 'title');
                $oc['device_name'] = $this->getTableField('convey_device', ['id' => $oc['device_id']], 'title');
                $v['oc'] = $oc;
                $cate = $this->getTableField('convey_cate', ['id' => $oc['type']], 'cate');
                if ($cate == 1) {
                    $ocp = Db::name('order_convey_patient')
                        ->where('order_id', $v['id'])
                        ->find();
                    $v['ocp'] = $ocp;
                }
            }
        }
        return $v;
    }
    public function newFormatOrder($v, $is_list = 0) {
        $v['order_type'] = '';
        $v['order_type_matter'] = '';
        $v['address_title'] = '';
        $v['repair_priority'] = '';
        $v['task_priority'] = 0;
        $v['cons'] = [];
        if ($v['work_type_mode'] == 1) {
            $typeInfo = (new \app\common\model\OrderType())
                ->getTypeByOrderId($v['id']);
            $v['order_type'] = $typeInfo && isset($typeInfo['title']) ? $typeInfo['title'] : '';
            $v['order_type_matter'] = $typeInfo ? $typeInfo['child_title'] : '';
            $v['address_title'] = $typeInfo ? $typeInfo['address_title'] : '';
            $v['repair_priority'] = $typeInfo ? $typeInfo['repair_priority'] : '';
            $v['task_priority'] = $typeInfo?($typeInfo['repair_priority_index']==3?1:0):0;

            $todo_mate = Db::name('todo_mate')
                ->where('order_id',$v['id'])
                ->select();

            if(!empty($todo_mate)){
                $cons = Db::name('todo_mate_item')
                    ->alias('a')
                    ->join('mate_goods b','b.id = a.items_id')
                    ->where('a.todo_mate_id','in',array_column($todo_mate,'id'))
                    ->field('a.*,b.title')
                    ->select();
                foreach ($cons as $k1=>$v1){
                    $v['cons'][] = [
                        'title' =>$v1['title'],
                        'total' =>$v1['total'],
                        'money' =>$v1['money'],
                        'total_money' =>$v1['total_money'],
                        'realName' =>$this->getTableField('user',['id'=>$v1['user_id']],'real_name'),
                    ];

                }
            }


        }
        $v['type_name'] = '';
        $v['start_name'] = '';
        $v['end_name'] = '';
        $v['device_name'] = '';
        if ($v['work_type_mode'] == 3) {
            $oc = Db::name('order_convey')
                ->where('order_id', $v['id'])
                ->find();
            $v['type_name'] = $this->getTableField('convey_cate', ['id' => $oc['type']], 'title');
            $v['start_name'] = $this->getTableField('address', ['id' => $oc['start']], 'title');
            $v['end_name'] = $this->getTableField('address', ['id' => $oc['end']], 'title');
            $v['device_name'] = $this->getTableField('convey_device', ['id' => $oc['device_id']], 'title');
            $v['task_priority'] = $oc['priority']==3?2:0;
        }
        $v['work_type_mode_text'] = $this->getTableField('work_type_mode', ['id' => $v['work_type_mode']], 'name');
        $v['source_type_text'] =$v['from']>0? isset($this->source_type[$v['from']])?$this->source_type[$v['from']]:'':$this->getTableField('work_type_mode', ['id' => $v['work_type_mode']], 'name');
        $v['dep'] = $this->getTableField('dep', ['id' => $v['dep_id']], 'title');
        $v['order_mode_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'in_content');
        $v['order_mode_out_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'out_content');
        $v['order_mode_color'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'color');
        $v['real_name'] = $this->getTableField('user', ['id' => $v['user_id']], 'real_name');
        $v['informer_user_name'] = $this->getTableField('user', ['id' => $v['informer_user']], 'real_name');
        $v['mobile'] = $this->getTableField('user', ['id' => $v['user_id']], 'mobile');
        $v['schedulContent'] = '';
        $v['to_user_name'] = '';
        $v['quality_cate_name'] = '';
        if($v['work_type_mode']==15){
            $v['quality_cate_name'] = model('QualityCate')->getPTitle($v['quality_cate']);
        }
        $todo = Db::name('todo')
            ->where('order_id', $v['id'])
            ->where('del',0)
            ->select();
        if($todo){
            $toUserInfo = Db::name('user')
                ->where('id','in',array_column($todo,'to_user_id'))
                ->column('real_name');
            $v['to_user_name'] = implode(',',$toUserInfo);
        }
        $dispatchLog = Db::name('dispatch_log')
            ->where('order_id',$v['id'])
            ->find();
        if($dispatchLog && $dispatchLog['content']){
            $v['schedulContent'] = $dispatchLog['content'];
        }
        $pDep = '';
        $depInfo = Db::name('dep')
            ->where('id',$v['dep_id'])
            ->find();
        if($depInfo){
            $pDep = Db::name('dep_cate')
                ->where('id',$depInfo['cate_id'])
                ->value('title');
        }
        $v['dep_cate_name'] = $pDep;
        return $v;
    }
    //api格式化订单详情
    public function apiFormatOrder($v, $is_list = 0,$todo_id=0) {

        $v['delayStatus'] = 0;
        $v['delayReason'] = '';
        $v['videos'] = $v['videos']?$v['videos']:'';
        $v['voices'] = $v['voices']?$v['voices']:'';
        $v['images'] = $v['images']?$v['images']:'';
        $v['repair'] = null;
        if ($v['work_type_mode'] == 1) {
            $v['repair'] = [];
            $typeInfo = (new \app\common\model\OrderType())
                ->getTypeByOrderId($v['id']);
            $v['repair']['order_type'] = $typeInfo && isset($typeInfo['title']) ? $typeInfo['title'] : '';
            $v['repair']['order_type_matter'] = $typeInfo ? $typeInfo['child_title'] : '';
            $v['repair']['address_title'] = $typeInfo ? $typeInfo['address_title'] : '';
            $v['repair']['type_id'] = $typeInfo ? $typeInfo['type_id'] : 0;
            $v['repair']['address_id'] = $typeInfo ? $typeInfo['address_id'] : 0;
            $v['repair']['repair_priority'] = $typeInfo ? $typeInfo['repair_priority'] : "";
        }
        $v['work_type_mode_text'] = $this->getTableField('work_type_mode', ['id' => $v['work_type_mode']], 'name');
        $v['dep'] = $this->getTableField('dep', ['id' => $v['dep_id']], 'title');
        $v['order_mode_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'in_content');
        $v['order_mode_out_text'] = $this->getTableField('order_mode', ['id' => $v['order_mode']], 'out_content');
        $v['real_name'] = $this->getTableField('user', ['id' => $v['user_id']], 'real_name');
        $v['mobile'] = $this->getTableField('user', ['id' => $v['user_id']], 'mobile');
        $v['schedulContent'] = '';
        $v['send_time'] = $v['send_time']?$v['send_time']:"";
        $v['cancel_time'] = $v['cancel_time']?$v['cancel_time']:"";
        $v['finish_time'] = $v['finish_time']?$v['finish_time']:"";
        $v['quality_cate_name'] = '';
        if($v['work_type_mode']==15){
            $v['quality_cate_name'] = model('QualityCate')->getPTitle($v['quality_cate']);
        }
        $dispatchLog = Db::name('dispatch_log')
            ->where('order_id',$v['id'])
            ->find();
        if($dispatchLog && $dispatchLog['content']){
            $v['schedulContent'] = $dispatchLog['content'];
        }
        if ($is_list > 0) {
            $v['todo_list'] = [];
            $t = [];
            if($todo_id >0){
                $t[] = ['id','=',$todo_id];
            }
            $todo = Db::name('todo')
                ->where('order_id', $v['id'])
                ->where($t)
                ->select();
            if (!empty($todo)) {
                $ysdign = model("Config")->getConfig("order_ys_sign",$v['org_id']);
                foreach ($todo as $k => $v1) {
                    $todo[$k]['yssign'] = $ysdign == 1?1:0;
                    $todo[$k]['to_real_name'] = $this->getTableField('user', ['id' => $v1['to_user_id']], 'real_name');
                    $todo[$k]['todo_mode_text'] = $this->getTableField('todo_mode', ['id' => $v1['todo_mode']], 'in_content');
                    $tx = $this->getTableField('todo_mode', ['id' => $v1['todo_mode']], 'out_content');
                    $todo[$k]['startStatus'] = 0;
                    $todo[$k]['mobile'] = $this->getTableField('user', ['id' => $v1['to_user_id']], 'mobile');;
                    $todo[$k]['images'] = $v1['images']?$v1['images']:"";
                    $todo[$k]['reject_time'] = $v1['reject_time']?$v1['reject_time']:"";
                    $todo[$k]['confirm_time'] = $v1['confirm_time']?$v1['confirm_time']:"";
                    $todo[$k]['done_time'] = $v1['done_time']?$v1['done_time']:"";
                    $todo[$k]['sign'] = $v1['sign']?$v1['sign']:"";
                    $todo[$k]['nodo_reason'] = $v1['nodo_reason']?$v1['nodo_reason']:'';
                    $pause_name = '';
                    $pause_reason = '';
                    $pause_time = '';
                    $pauseList = [];
                    $pause_reason = $v1['pause_reason'];
                    $pause_time = $v1['pause_time'];
                    if($v1['todo_mode']==2 && $v1['pause']==1){
                        $pause_name = '已挂起';
                        $tx = $tx.'(已挂起)';
                    }
                    $pauseList = Db::name('todo_puase')
                        ->where('todo_id',$v1['id'])
                        ->select();
                    $pauseList = $pauseList?$pauseList:[];
                    $todo[$k]['pauseList'] = $pauseList;
                    $todo[$k]['todo_mode_out_text'] = $tx;
                    $todo[$k]['pause_name'] = $pause_name;
                    $todo[$k]['pause_time'] = $pause_time;
                    $todo[$k]['pause_reason'] = $pause_reason;
                    if($v['work_type_mode'] == 3){
                        $todo_convey = Db::name('todo_convey')
                            ->where('todo_id',$v1['id'])
                            ->find();
                        $todo[$k]['startStatus'] = isset($todo_convey['start_time'])&& !empty($todo_convey['start_time'])?1:0;
                        $todo[$k]['start_img'] = isset($todo_convey['start_img'])&& !empty($todo_convey['start_img'])?$todo_convey['start_img']:'';
                        $todo[$k]['end_img'] = isset($todo_convey['end_img'])&& !empty($todo_convey['end_img'])?$todo_convey['end_img']:'';
                    }

                    $todo_mate = Db::name('todo_mate')
                        ->where('todo_id',$v1['id'])
                        ->select();
                    $todo[$k]['cons'] = [];
                    if(!empty($todo_mate)){
                        $cons = Db::name('todo_mate_item')
                            ->alias('a')
                            ->join('mate_goods b','b.id = a.items_id')
                            ->where('a.todo_mate_id','in',array_column($todo_mate,'id'))
                            ->field('a.*,b.title')
                            ->select();
                        foreach ($cons as $k2=>$v2){
                            $todo[$k]['cons'][] = [
                                'title' =>$v2['title'],
                                'total' =>$v2['total'],
                                'money' =>$v2['money'],
                                'total_money' =>$v2['total_money'],
                                'realName' =>$this->getTableField('user',['id'=>$v2['user_id']],'real_name'),
                            ];
                        }
                    }
                }
                $v['todo_list'] = $todo;
            }
            $v['comment'] = null;
            if ($v['order_mode'] == 6) {
                $v['comment'] = [];
                $v['comment'] = Db::name('comment')
                    ->where('type', $v['work_type_mode'])
                    ->where('from_id', $v['id'])
                    ->where('org_id', $v['org_id'])
                    ->find();
            }
            $v['oc'] = null;
            if ($v['work_type_mode'] == 3) {
                $v['oc'] = [];
                $oc = Db::name('order_convey')
                    ->where('order_id', $v['id'])
                    ->find();
                $oc['type_name'] = $this->getTableField('convey_cate', ['id' => $oc['type']], 'title');
                $oc['start_name'] = $this->getTableField('address', ['id' => $oc['start']], 'title');
                $oc['end_name'] = $this->getTableField('address', ['id' => $oc['end']], 'title');
                $oc['device_name'] = $this->getTableField('convey_device', ['id' => $oc['device_id']], 'title');
                $oc['priority'] = isset($this->priority[$oc['priority']]) ? $this->priority[$oc['priority']] : "";
                $sample = Db::name('order_convey_lis')
                    ->where('order_id', $v['id'])
                    ->column('barcode');
                $oc['sample'] = implode(',', $sample);
                $cate = $this->getTableField('convey_cate', ['id' => $oc['type']], 'cate');
                $oc['conveyTypeCate'] = $cate;
                $oc['typeScore'] = $oc['score'];
                $v['oc'] = $oc;
                if ($cate == 1) {
                    $ocp = Db::name('order_convey_patient')
                        ->where('order_id', $v['id'])
                        ->find();
                    $v['oc']['ocp'] = $ocp;
                }
            }

        }

        $v['delayStatus'] = 0;
        $order_delay = Db::name('order_delay')
            ->alias('a')
            ->join('delay_reason b','a.delay_reason_id=b.id')
            ->where('a.order_id',$v['id'])
            ->field('a.*,b.title')
            ->order('a.id desc')
            ->find();
        if($order_delay && $order_delay['status']==0){
            $v['delayReason'] = $order_delay['title'];
            $v['delayStatus'] = 1;
        }

        if($v['name']){
            $v['real_name'] = $v['name'];
        }
        if($v['phone']){
            $v['mobile'] = $v['phone'];
        }
        return $v;
    }
    public function cancel($id, $userId, $type = 1, $reason = '') {//type=1用户取消2调度取消
        $info = $this
            ->where('id', $id)
            ->find();
        if (!in_array($info['order_mode'], [1, 4])) {
            $this->error = '当前订单不可取消';
        }
        $data = [
            'cancel_reason' => $reason,
            'cancel_user_id' => $userId,
            'cancel_time' => getTime(),
            'order_mode' => $type == 1 ? 2 : 3,
        ];
        $this->startTrans();
        try {
            $res = $this->where('id', $id)->update($data);
            if (!$res) {
                \exception('更新订单失败');
            }
            if ($type == 2) {
                $todo = Db::name('todo')
                    ->where('order_id', $id)
                    ->select();
                $tData = [
                    'cancel_reason' => $reason,
                    'todo_mode' => 6,
                ];
                if (!empty($todo)) {
                    $res = Db::name('todo')
                        ->where('order_id', $id)
                        ->update($tData);
                    if (!$res) {
                        \exception('更新工单失败');
                    }
                    Db::name('task')
                        ->where('bus_id', 'in', array_column($todo, 'id'))
                        ->where('type', 1)
                        ->delete();
                }
            }
            $this->commit();
            return true;
        } catch (Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }
    public function del($orderId, $userId) {
        $this->startTrans();
        try {
            $res = $this
                ->where('id', $orderId)->update([
                    'del' => 1,
                    'del_user_id' => $userId,
                    'del_time' => getTime(),
                ]);
            if (!$res) {
                \exception('订单删除失败');
            }
            $todo = Db::name('todo')
                ->where('order_id', $orderId)
                ->select();
            if (!empty($todo)) {
                $res = Db::name('todo')
                    ->where('order_id', $orderId)
                    ->update(['del' => 1]);
                if (!$res) {
                    \exception('工单删除失败');
                }
                Db::name('task')
                    ->where('bus_id', 'in', array_column($todo, 'id'))
                    ->where('type', 1)
                    ->delete();
            }
            $this->commit();
            return true;
        } catch (Exception $e) {
            Db::rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }
    //获取订单派单人数
    public function sendUserNum($mode = 1,$orgId=0) {
        $name = 'org_send_order' . $mode;
        $value = (new \app\common\model\Config())
            ->getConfig($name,$orgId);
        return (!$value || $value == 0) ? 0 : 1;//0多人1单人
    }
    //派单
    public function send($id, $userId, $data) {

        $info = Db::name('orders')->where('id', $id)->find();
        $oldInfo = $info;
        if ($info['order_mode'] != 1) {
            $this->error = '当前订单不可派发';
            return false;
        }
        $data['userType'] = isset($data['userType']) ? $data['userType'] : 0;
        if($info['source_type']==4 && $oldInfo['work_type_mode'] ==0  && $info['is_deal']==0){//一键呼叫派发
            if(!isset($data['work_type_mode']) || $data['work_type_mode'] <0){
                $this->error = '请选择转单类型';
                return false;
            }
            $config = Db::name('config')
                ->where('name','web_order_transfer_type')
                ->value('value');
            if(empty($config)){
                $workType = [];
            }else{
                $workType = explode('|',$config);

            }
            if(!in_array($data['work_type_mode'],$workType)){
                $this->error = '当前类型不能进行转单';
                return false;
            }
            if($data['userType']==0){
                $data['to_user_id'] = !isset($data['to_user_id'])?$data['to_user_id'.$data['work_type_mode']]:$data['to_user_id'];
            }else{
                $data['to_roles_id'] =!isset($data['to_roles_id'])? $data['to_roles_id'.$data['work_type_mode']]:$data['to_roles_id'];
            }
            $info['work_type_mode'] = $data['work_type_mode'];
            if ($data['work_type_mode'] == 3) {
                $result = validate('OrdersConvey')->check($data, []);
                if (true !== $result) {
                    $this->error = validate('OrdersConvey')->getError();
                    return false;
                }
            }
        }
        $pusharr = []; // 需要推送给工人
        $pushdis = []; // 需要推送给二级调度
        if ($data['userType'] == 0) {
            if (!isset($data['to_user_id']) || empty($data['to_user_id'])) {
                $this->error = '请选择执行人';
                return false;
            }
            if ($info['work_type_mode'] == 1) {
                if (!isset($data['type_id']) || empty($data['type_id'])) {
                    $this->error = '请选择报修事项';
                    return false;
                }
            }
        }
        else {
            if(two_dispatch_off($info['org_id'])!=1){
                $this->error = '二级调度开关未开启';
                return false;
            }
            if (!isset($data['to_roles_id']) || empty($data['to_roles_id'])) {
                $this->error = '请选择二级调度';
                return false;
            }
        }
        $this->startTrans();
        try {
            if ($data['userType'] == 0) {
                $send_user_num = $this->sendUserNum($info['work_type_mode'],$data['org_id']);
                $users = explode(',', $data['to_user_id']);
                if($send_user_num==1 && count($users) >1){
                    $this->error = '执行人只能选择单人';
                    return false;
                }
                $to_user_id = array_unique($users);
                $todoData = [
                    'order_id' => $id,
                    'todo_content' => $data['todo_content'],
                    'create_user_id' => $userId,
                    'org_id' => $data['org_id'],
                    'create_time' => getTime(),
                    'todo_mode' => 1,
                    'work_type_mode' => $info['work_type_mode'],
                    'create_yyyy' => date('Y'),
                    'create_yyyymm' => date('Ym'),
                    'create_yyyymmdd' => date('Ymd'),
                ];

                $taskData = [
                    'org_id' => $data['org_id'],
                    'type' => 1,
                    'start_time' => getTime(),
                    'create_time' => getTime(),
                ];
                if($info['work_type_mode']==1){

                    if($info['source_type']==4 && $oldInfo['work_type_mode']==0 && $info['is_deal']==0) {
                        $taskData['priority'] = isset($data['repair_priority']) && $data['repair_priority']==3?1:0;
                    }else{
                        $orderRepair = Db::name('order_repair')
                            ->where('order_id',$id)
                            ->find();
                        $taskData['priority'] = !empty($orderRepair) && $orderRepair['repair_priority']==3?1:0;

                    }
                }else if ($info['work_type_mode']==3){
                    if($info['source_type']==4 && $oldInfo['work_type_mode']==0 && $info['is_deal']==0) {
                        $taskData['priority'] = isset($data['repair_priority']) && $data['repair_priority']==3?2:0;
                    }else{
                        $order_convey = Db::name('order_convey')
                            ->where('order_id',$id)
                            ->find();
                        $taskData['priority'] = !empty($order_convey) && $order_convey['priority']==3?2:0;

                    }
                    }
                $sns = [];
                foreach ($to_user_id as $k => $v) {
                    if(empty($v)){
                        continue;
                    }
                    $todoData['to_user_id'] = $v;
                    $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                    while (true){
                        if(in_array($todoData['sn'],$sns)){
                            $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                        }else{
                            $sns[] = $todoData['sn'];
                            break;
                        }
                    }
                    $res = Db::name('todo')
                        ->insertGetId($todoData);
                    if (!$res) {
                        \exception('执行人:' . $v . '派单失败');
                    }
                    $pusharr[] = [
                        'user_id' => $v,
                        'todo_id' => $res
                    ];
                    $taskData['user_id'] = $v;
                    $taskData['bus_id'] = $res;
                    $res = Db::name('task')
                        ->insert($taskData);
                    if (!$res) {
                        \exception('执行人:' . $v . '任务保存失败');
                    }
                }

                if($info['source_type']==4 && $oldInfo['work_type_mode']==0  && $info['is_deal']==0){
                    $rr = ['order_mode' => 4, 'work_type_mode'=>$data['work_type_mode'],'send_time' => getTime(),'from'=>1];
                }else{
                    $rr = ['order_mode' => 4, 'send_time' => getTime()];
                }
                $res = $this->where('id', $id)
                    ->update($rr);
                if (!$res) {
                    \exception('订单更新失败');
                }
            }
            else {
                $pRolesId = explode(',',$data['to_roles_id']);
                $pp = [];
                foreach ($pRolesId as $k=>$v){
                    $logData = [
                        'user_id' => $userId,
                        'to_user_id' =>0,
                        'create_time' => getTime(),
                        'content' => isset($data['todo_content']) ? $data['todo_content'] : '',
                        'order_id' => $id,
                        'roles_id' => $v
                    ];
                    $pp[] = $logData;
                }
                $pushdis = Db::name('user_roles')
                    ->where('roles_id','in',$pRolesId)
                    ->column('user_id');

                $res = Db::name('dispatch_log')
                    ->insertAll($pp);
                if (!$res) {
                    \exception('派发失败');
                }
                if($info['source_type']==4 && $oldInfo['work_type_mode']==0 && $info['is_deal']==0){
                    $rrs = ['is_deal' => 1, 'work_type_mode'=>$data['work_type_mode']];
                }else{
                    $rrs = ['is_deal' => 1];
                }
                $res = $this->where('id', $id)
                    ->update($rrs);
                if (!$res) {
                    \exception('订单更新失败');
                }
            }
            if ($info['work_type_mode'] == 1) {//报修订单
                $rData = [];
                if (isset($data['type_id']) && !empty($data['type_id'])) {
                    $rData['type_id'] = $data['type_id'];
                }
                if (isset($data['address_id']) && !empty($data['address_id'])) {
                    $rData['address_id'] = $data['address_id'];
                }
                if($info['source_type']==4 && $oldInfo['work_type_mode']==0 && $info['is_deal']==0) {
                    if (isset($data['repair_priority']) && !empty($data['repair_priority'])) {
                        $rData['repair_priority'] = $data['repair_priority'];
                    }
                }
                    if (!empty($rData)) {
                    $old = Db::name('order_repair')
                        ->where('order_id', $id)
                        ->find();
                    if ($old) {
                        $rData['update_time'] = getTime();
                        $res = Db::name('order_repair')
                            ->where('order_id', $id)
                            ->update($rData);
                    }
                    else {
                        $rData['order_id'] = $id;
                        $res = Db::name('order_repair')
                            ->insert($rData);
                    }
                    if (!$res) {
                        \exception('保存维修扩展失败');
                    }
                }
            }else{
                $old = Db::name('order_repair')
                    ->where('order_id', $id)
                    ->find();
                if ($old) {
                    $res = Db::name('order_repair')
                        ->where('order_id', $id)
                        ->delete();
                    if (!$res) {
                        \exception('删除维修扩展失败');
                    }
                }
            }
            if($info['source_type']==4 && $oldInfo['work_type_mode']==0 && $info['is_deal']==0){//一键呼叫 转单运送
                if ($data['work_type_mode'] == 3) {
                    if (!$data['start'] || !$data['end']) {
                        $this->error = '取件与送达地点不能为空';
                        return false;
                    }
                    if ($data['start'] == $data['end']) {
                        $this->error = '取件与送达地点不能是同一地点';
                        return false;
                    }
                    if (!$data['xq_time'] || !$data['ywc_time']) {
                        $this->error = '应完成时间应和需求时间不能为空';
                        return false;
                    }
                    if ($data['xq_time'] >= $data['ywc_time']) {
                        $this->error = '应完成时间应大于需求时间';
                        return false;
                    }
                    if (strtotime($data['xq_time']) < time() - 10 * 60) {
                        $this->error = '需求时间已过时';
                        return false;
                    }
                    if (!$data['type']) {
                        $this->error = '运送类型不能为空';
                        return false;
                    }
//                    if(!$data['name']){
//                        $this->error = '联系人不能为空';
//                        return false;
//                    }
//                    if(!$data['phone']){
//                        $this->error = '联系人电话不能为空';
//                        return false;
//                    }
                    $ysData = array(
                        'order_id' => $id,
                        'type' => $data['type'],
                        'start' => $data['start'],
                        'end' => $data['end'],
                        'xq_time' => $data['xq_time'],
                        'ywc_time' => $data['ywc_time'],
                        'name' => $data['name'],
                        'phone' => $data['phone'],
                        'device_id' => isset($data['device_id']) ? (int)$data['device_id'] : 0,
                        'priority' => empty($data['priority']) ? 0 : $data['priority']
                    );

                    $check =  Db::name('order_convey')
                        ->where('order_id',$id)
                        ->find();
                    if($check){
                        Db::name('order_convey')
                            ->where('order_id',$id)
                            ->update($ysData);
                    }else{
                        $oCid = Db::name('order_convey')
                            ->insertGetId($ysData);
                        if (!$oCid) {
                            exception('运送信息保存失败');
                        }
                    }

                    $conveyCate = Db::name('convey_cate')
                        ->where('id', $data['type'])
                        ->find();
                    if ($conveyCate['cate'] == 1) {
                        $patient = [
                            'order_id' => $id,
                            'bed_number' => isset($data['bed_number']) ? $data['bed_number'] : '',
                            'name' => isset($data['p_name']) ? $data['p_name'] : '',
                            'ba_number' => isset($data['ba_number']) ? $data['ba_number'] : '',
                            'gender' => isset($data['gender']) && !empty($data['gender']) ? $data['gender'] : 0,
                            'back' => isset($data['back']) && !empty($data['back']) ? $data['back'] : 0,
                        ];
                        $cp = Db::name('order_convey_patient')
                            ->where('order_id',$id)
                            ->find();
                        if($cp){
                            Db::name('order_convey_patient')
                                ->where('order_id',$id)
                                ->update($patient);
                        }else{
                            $ocPid = Db::name('order_convey_patient')
                                ->insertGetId($patient);
                            if (!$ocPid) {
                                exception('保存运送病人扩展失败');
                            }
                        }

                    }
                }else{
                    Db::name('order_convey')
                        ->where('order_id',$id)
                        ->delete();
                    Db::name('order_convey_patient')
                        ->where('order_id',$id)
                        ->delete();
                }

            }
            if($info['work_type_mode'] == 3){
                $wlps = Db::connect('db_config_jili')->name('wlps')->where('order_id',$info['id'])->find();
                if($wlps){
                    Db::connect('db_config_jili')->name('wlps')->where('id',$wlps['id'])->update([
                        'send_time' => date('Y-m-d H:i:s')
                    ]);
                }
            }
            $this->commit();
            if($pusharr){
                foreach ($pusharr as $k=>$v){
                    // 极光推送
                    send_jpush([$v['user_id']],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$v['todo_id']]);
                }
            }
            if($pushdis){
                foreach ($pushdis as $k=>$v){
                    // 极光推送
                    send_jpush([$v],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$info['id']]);
                }
            }
            // 极光推送
            send_jpush([$info['user_id']],AppMsg::PUSH_USER_ORDER_SEND,'',['id'=>$info['id']]);
            return true;
        } catch (Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    //转单
    public function zd_send($id, $data) {

        $info = $this->where('id', $id)->find();
        if ($info['order_mode'] != 1) {
            $this->error = '当前订单不可转单';
            return false;
        }
        if(!isset($data['work_type_mode']) || $data['work_type_mode'] <0){
            $this->error = '请选择转单类型';
            return false;
        }
        $config = Db::name('config')
            ->where('name','web_order_transfer_type')
            ->value('value');
        if(empty($config)){
            $workType = [];
        }else{
            $workType = explode('|',$config);

        }
        if(!in_array($data['work_type_mode'],[98,99])){
            if(!in_array($data['work_type_mode'],$workType)){
                $this->error = '当前类型不能进行转单';
                return false;
            }
        }


        $info['work_type_mode'] = $data['work_type_mode'];
        if ($data['work_type_mode'] == 3) {
            $result = validate('OrdersConvey')->check($data, []);
            if (true !== $result) {
                $this->error = validate('OrdersConvey')->getError();
                return false;
            }
        }
        if ($info['work_type_mode'] == 1) {
            if (!isset($data['type_id']) || empty($data['type_id'])) {
                $this->error = '请选择报修事项';
                return false;
            }
        }
        $this->startTrans();
        try {
            $rr['work_type_mode'] = $data['work_type_mode'];
            $rr['update_time'] = getTime();
            if($info['work_type_mode'] == 0 && $info['source_type'] == 4){
                $rr['from'] = 1;
            }

            $res = $this->where('id', $id)
                ->update($rr);
            if (!$res) {
                \exception('订单更新失败');
            }

//            if($info['work_type_mode'] == 3){
//                $score = empty($data['score'])?0:floatval($data['score']);
//                Db::name('order_convey')->where('order_id',$id)->update(['score'=>$score]);
//            }
            if ($info['work_type_mode'] == 1) {//报修订单
                $rData = [];
                if (isset($data['type_id']) && !empty($data['type_id'])) {
                    $rData['type_id'] = $data['type_id'];
                }
                if (isset($data['address_id']) && !empty($data['address_id'])) {
                    $rData['address_id'] = $data['address_id'];
                }
                if (isset($data['repair_priority']) && !empty($data['repair_priority'])) {
                    $rData['repair_priority'] = $data['repair_priority'];
                }
                if (!empty($rData)) {
                    $old = Db::name('order_repair')
                        ->where('order_id', $id)
                        ->find();
                    if ($old) {
                        $rData['update_time'] = getTime();
                        $res = Db::name('order_repair')
                            ->where('order_id', $id)
                            ->update($rData);
                    }
                    else {
                        $rData['order_id'] = $id;
                        $res = Db::name('order_repair')
                            ->insert($rData);
                    }
                    if (!$res) {
                        \exception('保存维修扩展失败');
                    }
                }
            }else{
                $old = Db::name('order_repair')
                    ->where('order_id', $id)
                    ->find();
                if ($old) {
                    $res = Db::name('order_repair')
                        ->where('order_id', $id)
                        ->delete();
                    if (!$res) {
                        \exception('删除维修扩展失败');
                    }
                }
            }
            if ($data['work_type_mode'] == 3) {
                if (!$data['start'] || !$data['end']) {
                    $this->error = '取件与送达地点不能为空';
                    return false;
                }
                if ($data['start'] == $data['end']) {
                    $this->error = '取件与送达地点不能是同一地点';
                    return false;
                }
                if (!$data['xq_time'] || !$data['ywc_time']) {
                    $this->error = '应完成时间应和需求时间不能为空';
                    return false;
                }
                if ($data['xq_time'] >= $data['ywc_time']) {
                    $this->error = '应完成时间应大于需求时间';
                    return false;
                }
                if (strtotime($data['xq_time']) < time() - 10 * 60) {
                    $this->error = '需求时间已过时';
                    return false;
                }
                if (!$data['type']) {
                    $this->error = '运送类型不能为空';
                    return false;
                }
//                if(!$data['name']){
//                    $this->error = '联系人不能为空';
//                    return false;
//                }
//                if(!$data['phone']){
//                    $this->error = '联系人电话不能为空';
//                    return false;
//                }

                $ysData = array(
                    'order_id' => $id,
                    'type' => $data['type'],
                    'start' => $data['start'],
                    'end' => $data['end'],
                    'xq_time' => $data['xq_time'],
                    'ywc_time' => $data['ywc_time'],
                    'name' => $data['name'],
                    'phone' => $data['phone'],
                    'device_id' => isset($data['device_id']) ? (int)$data['device_id'] : 0,
                    'priority' => empty($data['priority']) ? 0 : $data['priority']
                );

                $check =  Db::name('order_convey')
                    ->where('order_id',$id)
                    ->find();
                if($check){
                    Db::name('order_convey')
                        ->where('order_id',$id)
                        ->update($ysData);
                }else{
                    $oCid = Db::name('order_convey')
                        ->insertGetId($ysData);
                    if (!$oCid) {
                        exception('运送信息保存失败');
                    }
                }

                $conveyCate = Db::name('convey_cate')
                    ->where('id', $data['type'])
                    ->find();
                if ($conveyCate['cate'] == 1) {
                    $patient = [
                        'order_id' => $id,
                        'bed_number' => isset($data['bed_number']) ? $data['bed_number'] : '',
                        'name' => isset($data['p_name']) ? $data['p_name'] : '',
                        'ba_number' => isset($data['ba_number']) ? $data['ba_number'] : '',
                        'gender' => isset($data['gender']) && !empty($data['gender']) ? $data['gender'] : 0,
                        'back' => isset($data['back']) && !empty($data['back']) ? $data['back'] : 0,
                    ];
                    $cp = Db::name('order_convey_patient')
                        ->where('order_id',$id)
                        ->find();
                    if($cp){
                        Db::name('order_convey_patient')
                            ->where('order_id',$id)
                            ->update($patient);
                    }else{
                        $ocPid = Db::name('order_convey_patient')
                            ->insertGetId($patient);
                        if (!$ocPid) {
                            exception('保存运送病人扩展失败');
                        }
                    }

                }
            }else{
                Db::name('order_convey')
                    ->where('order_id',$id)
                    ->delete();
                Db::name('order_convey_patient')
                    ->where('order_id',$id)
                    ->delete();
            }
            //转投诉
            if($data['work_type_mode']==98){
                $complain=[
                    'org_id'=>$info['org_id'],
                    'dep_id'=>$info['dep_id'],
                    'create_user_id'=>$info['user_id'],
                    'content'=>$info['content'],
                    'images'=>isset($info['images'])?$info['images']:'',
                    'voices'=>isset($info['voices'])?$info['voices']:'',
                    'videos'=>isset($info['videos'])?$info['videos']:'',
                    'create_time'=>getTime(),
                    'from'=>1,
                    'create_yyyy'=>date('Y'),
                    'create_yyyymm'=>date('Ym'),
                    'create_yyyymmdd'=>date('Ymd'),
                ];
                $ret = Db::name('complain')->insert($complain);
                if (!$ret) {
                    exception('转投诉失败');
                }
            }
            //转隐患
            if($data['work_type_mode']==99){
                $complain=[
                    'org_id'=>$info['org_id'],
                    'dep_id'=>$info['dep_id'],
                    'create_user_id'=>$info['user_id'],
                    'content'=>$info['content'],
                    'images'=>isset($info['images'])?$info['images']:'',
                    'voices'=>isset($info['voices'])?$info['voices']:'',
                    'videos'=>isset($info['videos'])?$info['videos']:'',
                    'create_time'=>getTime(),
                    'from'=>1,
                    'create_yyyy'=>date('Y'),
                    'create_yyyymm'=>date('Ym'),
                    'create_yyyymmdd'=>date('Ymd'),
                ];
                $ret = Db::name('hiddendanger')->insert($complain);
                if (!$ret) {
                    exception('转投诉失败');
                }
            }
            if(in_array($data['work_type_mode'],[98,99])){
                $res = $this
                    ->where('id', $id)->update([
                        'del' => 1,
                        'work_type_mode' => 0,
                        'del_user_id' => $info['user_id'],
                        'del_time' => getTime(),
                    ]);
                if (!$res) {
                    \exception('订单删除失败');
                }
            }
            $this->commit();
            return true;
        } catch (Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }
    //批量派单
    public function batchsend($id, $userId, $data) {
        $ids = explode(',',$id);
        $infos = $this->where('id', 'in',$ids)->select();
        $pusharr = []; // 需要推送给工人
        foreach ($infos as $k=>$info){

            if ($info['order_mode'] != 1) {
                $this->error = '当前选择订单中包含已派发订单,请重新选择';
                return false;
            }
            $data['userType'] = isset($data['userType']) ? $data['userType'] : 0;
            if ($data['userType'] == 0) {
                if (!isset($data['to_user_id']) || empty($data['to_user_id'])) {
                    $this->error = '请选择执行人';
                    return false;
                }
                if ($info['work_type_mode'] == 1) {
                    if (!isset($data['type_id']) || empty($data['type_id'])) {
                        $this->error = '请选择报修事项';
                        return false;
                    }
                }
            }
            else {
                if(two_dispatch_off($info['org_id'])!=1){
                    $this->error = '二级调度开关未开启';
                    return false;
                }
                if (!isset($data['to_roles_id']) || empty($data['to_roles_id'])) {
                    $this->error = '请选择二级调度';
                    return false;
                }
            }
            $this->startTrans();
            try {
                if ($data['userType'] == 0) {
                    $send_user_num = $this->sendUserNum($info['work_type_mode'],$data['org_id']);
                    $users = explode(',', $data['to_user_id']);
                    if($send_user_num==1 && count($users) >1){
                        $this->error = '执行人只能选择单人';
                        return false;
                    }
                    $to_user_id = array_unique($users);
                    $todoData = [
                        'order_id' => $info['id'],
                        'todo_content' => $data['todo_content'],
                        'create_user_id' => $userId,
                        'org_id' => $data['org_id'],
                        'create_time' => getTime(),
                        'todo_mode' => 1,
                        'work_type_mode' => $info['work_type_mode'],
                        'create_yyyy' => date('Y'),
                        'create_yyyymm' => date('Ym'),
                        'create_yyyymmdd' => date('Ymd'),
                        ];
                    $taskData = [
                        'org_id' => $data['org_id'],
                        'type' => 1,
                        'start_time' => getTime(),
                        'create_time' => getTime(),
                    ];
                    $sns = [];
                    foreach ($to_user_id as $k => $v) {
                        if(empty($v)){
                            continue;
                        }
                        $todoData['to_user_id'] = $v;
                        $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                        while (true){
                            if(in_array($todoData['sn'],$sns)){
                                $todoData['sn'] = get_unique_sn(get_config('sn_prefix'));
                            }else{
                                $sns[] = $todoData['sn'];
                                break;
                            }
                        }
                        $res = Db::name('todo')
                            ->insertGetId($todoData);
                        if (!$res) {
                            \exception('执行人:' . $v . '派单失败');
                        }
                        $pusharr[] = [
                            'user_id' => $v,
                            'todo_id' => $res
                        ];
                        $taskData['user_id'] = $v;
                        $taskData['bus_id'] = $res;
                        $res = Db::name('task')
                            ->insert($taskData);
                        if (!$res) {
                            \exception('执行人:' . $v . '任务保存失败');
                        }
                    }
                    $res = $this->where('id', $info['id'])
                        ->update(['order_mode' => 4, 'send_time' => getTime()]);
                    if (!$res) {
                        \exception('订单更新失败');
                    }
                }
                else {
                    $logData = [
                        'user_id' => $userId,
                        'to_user_id' => 0,
                        'create_time' => getTime(),
                        'content' => isset($data['todo_content']) ? $data['todo_content'] : '',
                        'order_id' => $info['id'],
                        'roles_id' => $data['to_roles_id']
                    ];
                    $res = Db::name('dispatch_log')
                        ->insertGetId($logData);
                    if (!$res) {
                        \exception('派发失败');
                    }
                    $res = $this->where('id', $info['id'])
                        ->update(['is_deal' => 1]);
                    if (!$res) {
                        \exception('订单更新失败');
                    }
                }
                if ($info['work_type_mode'] == 1) {//报修订单
                    $rData = [];
                    if (isset($data['type_id']) && !empty($data['type_id'])) {
                        $rData['type_id'] = $data['type_id'];
                    }
                    if (isset($data['address_id']) && !empty($data['address_id'])) {
                        $rData['address_id'] = $data['address_id'];
                    }
                    if (!empty($rData)) {
                        $old = Db::name('order_repair')
                            ->where('order_id', $info['id'])
                            ->find();
                        if ($old) {
                            $rData['update_time'] = getTime();
                            $res = Db::name('order_repair')
                                ->where('order_id', $info['id'])
                                ->update($rData);
                        }
                        else {
                            $rData['order_id'] = $info['id'];
                            $res = Db::name('order_repair')
                                ->insert($rData);
                        }
                        if (!$res) {
                            \exception('保存维修扩展失败');
                        }
                    }
                }
                if($info['work_type_mode'] == 3){
                $wlps = Db::connect('db_config_jili')->name('wlps')->where('order_id',$info['id'])->find();
                    if($wlps){
                    Db::connect('db_config_jili')->name('wlps')->where('id',$wlps['id'])->update([
                        'send_time' => date('Y-m-d H:i:s')
                    ]);
                    }
                }
                $this->commit();
            } catch (Exception $e) {
                $this->rollback();
                $this->error = $e->getMessage();
                return false;
            }

            // 极光推送
            send_jpush([$info['user_id']],AppMsg::PUSH_USER_ORDER_SEND,'',['id'=>$info['id']]);
        }

        if($pusharr){
            foreach ($pusharr as $k=>$v){
                // 极光推送
                send_jpush([$v['user_id']],AppMsg::PUSH_WORKER_ORDER_SEND,'',['id'=>$v['todo_id']]);
            }
        }
        return true;


    }
    //完成订单
    public function finish($id) {
        $info = $this->where('id', $id)->find();
        if ($info['order_mode'] != 4) {
            $this->error = '当前订单不可完成';
            return false;
        }
        $this->startTrans();
        try {
            $res = $this->where('id', $id)
                ->update([
                    'order_mode' => 5,
                    'finish_time' => getTime(),
                ]);
            if (!$res) {
                \exception('订单更新失败');
            }
            $todo = Db::name('todo')
                ->where('order_id', $id)
                ->select();
            if (!empty($todo)) {
                foreach ($todo as $kk=>$vv){
                    $wh = [
                        'todo_mode' => 3,
                        'done_time' => getTime(),
                        'wc_time'=>time() - strtotime($vv['confirm_time'])
                    ];
                    if($vv['todo_mode']==1){
                        $wh['confirm_time'] = $vv['create_time'];
                        $wh['wc_time'] = time() - strtotime($vv['create_time']);
                    }
                    $res = Db::name('todo')
                        ->where('id', $vv['id'])
                        ->update($wh);
                    if (!$res) {
                        \exception('工单更新失败');
                    }
                }

                $res = Db::name('task')
                    ->where('bus_id', 'in', array_column($todo, 'id'))
                    ->where('type', 1)
                    ->delete();
                if (!$res) {
                    \exception('任务删除失败');
                }
            }
            $this->commit();

            // 极光推送
            send_jpush([$info['user_id']],AppMsg::PUSH_USER_ORDER_FINISH,'',['id'=>$info['id']]);

            return true;
        } catch (Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    //批量完成订单
    public function batchfinish($id) {
        $ids = explode(',',$id);
        $infos = $this->where('id', 'in',$ids)->select();
        $pusharr = []; // 需要推送
        foreach ($infos as $k=>$info){
            if ($info['order_mode'] != 4) {
                $this->error = '当前所选订单有不可完成的订单';
                return false;
            }
            $this->startTrans();
            try {
                $res = $this->where('id', $info['id'])
                    ->update([
                        'order_mode' => 5,
                        'finish_time' => getTime(),
                    ]);
                if (!$res) {
                    \exception('订单更新失败');
                }
                $todo = Db::name('todo')
                    ->where('order_id', $info['id'])
                    ->select();
                if (!empty($todo)) {
                    foreach ($todo as $kk=>$vv){
                        $wh = [
                            'todo_mode' => 3,
                            'done_time' => getTime(),
                            'wc_time'=>time() - strtotime($vv['confirm_time'])
                        ];
                        if($vv['todo_mode']==1){
                            $wh['confirm_time'] = $vv['create_time'];
                            $wh['wc_time'] = time() - strtotime($vv['create_time']);
                        }
                        $res = Db::name('todo')
                            ->where('id', $vv['id'])
                            ->update($wh);
                        if (!$res) {
                            \exception('工单更新失败');
                        }
                    }
                    Db::name('task')
                        ->where('bus_id', 'in', array_column($todo, 'id'))
                        ->where('type', 1)
                        ->delete();
                }
                $this->commit();
                $pusharr[] = [
                    'user_id' => $info['user_id'],
                    'id' => $info['id']
                ];
            } catch (Exception $e) {
                $this->rollback();
                $this->error = $e->getMessage();
                return false;
            }
        }

        if($pusharr){
            foreach ($pusharr as $k=>$v){
                // 极光推送
                send_jpush([$v['user_id']],AppMsg::PUSH_USER_ORDER_FINISH,'',['id'=>$v['id']]);
            }
        }
        return true;

    }
    //评价订单
    public function addComment($id, $score, $content, $userId, $org_id) {
        $info = $this->where('id', $id)->find();
        if (!$info) {
            $this->error = '订单不存在';
            return false;
        }
        if ($info['user_id'] != $userId) {
            $this->error = '订单只可由发起人评价';
            return false;
        }
        if ($info['order_mode'] != 5) {
            $this->error = '此状态不能评价';
            return false;
        }
        $jsonArray = [
            'score'=>$score,
            'content'=>isset($content)?$content:'',
            'userId'=>$userId,
            'type'=>$info['work_type_mode'],
            'fromId'=>$id,
            'orgId'=>$org_id,
        ];
        $ret = model('Comment')->addSave($jsonArray);
        if(!$ret){
            $this->error = model('Comment')->getError();
            return false;
        }
        return true;
    }
    //api 调度订单列表
    public function lists($page, $size, $cur_order_mode, $userId, $orgId) {
        $map[] = ['org_id', '=', $orgId];
        $map[] = ['del', '=', 0];

        $map2[] = ['todo_mode', '=', 4];
        $map1 = [];
        $auth = get_dispatch_auth($userId);
        if (empty($auth)) {
            $map[] = ['work_type_mode', '=', -1];
        }
        else {
            $map[] = ['work_type_mode', 'in', $auth];
        }
        $org_two_dispatch = (new Config())->getConfig('org_two_dispatch',$orgId);
        if($org_two_dispatch==0){//二级调度开关关闭
            if ($cur_order_mode == 0) {//待处理
                $map[] = ['order_mode', 'in', [1]];
                $map[] = ['is_deal', '=', 0];
            }
            else {
                if ($cur_order_mode == 1) {//已处理
                    $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                }
            }
        }else{
            if (check_two_dispatch($userId) == 1) {//二级调度角色
                $roles_id = Db::name('user_roles')
                    ->where('user_id',$userId)
                    ->value('roles_id');
                $ids = Db::name('dispatch_log')
                    ->where('roles_id', $roles_id)
                    ->whereOr('to_user_id', $userId)
                    ->column('order_id');
                if ($cur_order_mode == 2) {//驳回
                    if (empty($ids)) {
                        $map2[] = ['order_id', '=', -1];
                    }
                    else {
                        $map2[] = ['order_id', 'in', $ids];
                    }
                }
                else {
                    if (empty($ids)) {
                        $map[] = ['id', '=', -1];
                    }
                    else {
                        $map[] = ['id', 'in', $ids];
                    }
                }
                if ($cur_order_mode == 0) {//待处理
                    $map[] = ['order_mode', 'in', [1]];
                }
                else {
                    if ($cur_order_mode == 1) {//已处理
                        $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                    }
                }
            }
            else {
                if ($cur_order_mode == 0) {//待处理
                    $map[] = ['order_mode', 'in', [1]];
                    $map[] = ['is_deal', '=', 0];
                }
                else {
                    if ($cur_order_mode == 1) {//已处理
                        $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                        $map1[] = ['is_deal', '=', 1];
                    }
                }

            }
        }
        $offset = ($page - 1) * $size;
        if ($cur_order_mode == 2) { //驳回订单
            $list = Db::name('todo_view')
                ->where($map)
                ->where($map2)
                ->limit($offset, $size)
                ->order('id', 'desc')
                ->select();
            $data = [];
            foreach ($list as $k => $v) {
                $order = $this->where('id', $v['order_id'])
                    ->find()->toArray();
                $v1 = $this->formatOrder($order);
                $v1['is_transfer'] = ($order['source_type']==4 && $order['order_mode']==1 && $order['is_deal']==0)?1:0;

                $ll = formatArray(
                    [
                        'id',
                        'order_mode',
                        'create_time',
                        'source_type',
                        'work_type_mode',
                        'send_time',
                        'work_type_mode_text',
                        'dep',
                        'order_mode_text',
                        'order_mode_out_text',
                        'real_name',
                        'is_transfer',
                        'task_priority',
                        'sn'
                    ]
                    , $v1);

                if($order['from'] > 0){
                    $from = '';
                    if($order['from'] == 1){
                        $from = '一键呼叫';
                    }else if($order['from'] == 2){
                        $from = '隐患预警';
                    }else if($order['from'] == 3){
                        $from = '投诉';
                    }
                    $ll['work_type_mode_text'] = $ll['work_type_mode_text'].'('.$from.')';
                }

                $ll['todo_id'] = $v['id'];
                $data[] = $ll;
            }
            return $data;
        }
        $list = $this->where($map)
            ->whereOr($map1)
            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];
        foreach ($list as $k => $v) {
            $v = $this->formatOrder($v);
            $v['is_transfer'] = ($v['source_type']==4 && $v['order_mode']==1 && $v['is_deal']==0)?1:0;

            $ll = formatArray(
                [
                    'id',
                    'order_mode',
                    'create_time',
                    'source_type',
                    'work_type_mode',
                    'send_time',
                    'work_type_mode_text',
                    'dep',
                    'order_mode_text',
                    'order_mode_out_text',
                    'real_name',
                    'is_transfer',
                    'task_priority',
                    'sn'
                ]
                , $v);

            if($v['from'] > 0){
                $from = '';
                if($v['from'] == 1){
                    $from = '一键呼叫';
                }else if($v['from'] == 2){
                    $from = '隐患预警';
                }else if($v['from'] == 3){
                    $from = '投诉';
                }
                $ll['work_type_mode_text'] = $ll['work_type_mode_text'].'('.$from.')';
            }

            $data[] = $ll;
        }
        return $data;
    }
    //api 发起人品控订单列表
    public function userQualityLists($page, $size, $userId, $orgId) {
        $map[] = ['org_id', '=', $orgId];
        $map[] = ['del', '=', 0];
        $map[] = ['user_id', '=', $userId];
        $map[] = ['work_type_mode', '=', 15];
        $offset = ($page - 1) * $size;

        $list = $this->where($map)
            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];
        foreach ($list as $k => $v) {
            $v = $this->formatOrder($v);

            $ll = formatArray(
                [
                    'id',
                    'create_time',
                    'informer_user_name',
                    'order_mode',
                    'order_mode_out_text',
                    'to_user_name',
                    'real_name',
                    'sn'
                ]
                , $v);
            $data[] = $ll;
        }
        return $data;
    }
    //api 知会人品控订单列表
    public function informerQualityLists($page, $size, $userId, $orgId) {
        $map[] = ['org_id', '=', $orgId];
        $map[] = ['del', '=', 0];
        $map[] = ['informer_user', '=', $userId];
        $map[] = ['work_type_mode', '=', 15];
        $offset = ($page - 1) * $size;

        $list = $this->where($map)
            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];
        foreach ($list as $k => $v) {
            $v = $this->formatOrder($v);

            $ll = formatArray(
                [
                    'id',
                    'create_time',
                    'informer_user_name',
                    'order_mode',
                    'order_mode_out_text',
                    'to_user_name',
                    'real_name',
                    'sn'
                ]
                , $v);
            $data[] = $ll;
        }
        return $data;
    }
    //api 订单详情
    public function detail($orderId) {
        $info = $this->where('id', $orderId)
            ->find();
        if (empty($info)) {
            HelpHander::error('订单信息不存在');
        }
        $is_ch = 0;
        if($info['order_mode'] == 4){
            $todoInfo = Db::name('todo')->where('order_id',$info['id'])->where('del',0)->where('todo_mode','>',1)->find();
            if(!$todoInfo){
                $is_ch = 1;
            }
        }
        $info['is_ch'] =  $is_ch;

        $info = $info->toArray();
        $info = $this->apiFormatOrder($info, 1);
        if($info['work_type_mode'] == 3){
            // 地点路径
            $conveyends = Db::name('order_convey_end')
                ->alias('a')
                ->join('address b','b.id = a.addr')
                ->where('a.order_id',$orderId)
                ->order('a.id asc')
                ->field('a.*,b.title')
                ->select();
            $info['ends'] = $conveyends?$conveyends:[];

            $payinfo = [
                'is_pay' => 0,
                'id' => 0,
                'url' => '',
                'money' => 0,
                'remark' => '',
                'type' => 1,
                'pay_time' => '',
            ];

            // 是否需要支付
            $pay = Db::name('order_convey_pay')->where('order_id',$orderId)->find();
            if($pay){
                $payinfo['is_pay'] = $pay['status'] == 0?0:1;
                $payinfo['url'] = url('h5/Index/pay',['id'=>$pay['id']],false,true);
                $payinfo['money'] = round($pay['money'],2);
                $payinfo['remark'] = $pay['remark'];
                $payinfo['pay_time'] = $pay['pay_time']?$pay['pay_time']:'';
                $payinfo['id'] = $pay['id'];
            }
            $info['pay'] = $payinfo;


        }

        return $info;
    }
    //抢单列表
    public function queryGrabOrders($page, $size, $userId, $orgId) {
        $rolesId = Db::name('user_roles')
            ->where('user_id', $userId)
            ->value('roles_id');
        $rolesInfo = Db::name('roles')
            ->where('id', $rolesId)
            ->find();
        if ($rolesInfo['parent_id'] > 0) {
            $rolesId = $rolesInfo['parent_id'];
        }
        $workType = Db::name('work_type_mode')
            ->where('type', 1)
            ->where('roles', 'like', '%' . $rolesId . '%')
            ->column('id');
        if (empty($workType)) {
            return [];
        }
        $n = [];
        foreach ($workType as $k=>$v){
            $orgGrabOrder = (new Config())->getConfig('org_grab_order'.$v,$orgId);
            if($orgGrabOrder && $orgGrabOrder>0){
                $n[] = $v;
            }
        }
        if(empty($n)){
            return [];
        }
        $workType = $n;
        $map[] = ['org_id', '=', $orgId];
        $map[] = ['del', '=', 0];
        $map[] = ['order_mode', 'in', [1]];
        $map[] = ['work_type_mode', 'in', $workType];
        $offset = ($page - 1) * $size;

        $list = $this->where($map)
//            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];

        // 预约类型-取15分钟后之前的订单
        $curtime15 = time()+60*15;

        foreach ($list as $k => $v) {
            $rr = formatArray(
                ['id', 'content', 'create_time', 'work_type_mode']
                , $v);
            $rr['depName'] = $this->getTableField('dep', ['id' => $v['dep_id']], 'title');

            $convey = Db::name('order_convey')->where('order_id',$v['id'])->find();
            $rr['start_address'] = '';
            $rr['end_address'] = '';
            $rr['convey_title'] = '';

            if($v['work_type_mode'] == 3){
                if($convey){
                    $rr['start_address'] = Db::name('address')->where('id',$convey['start'])->value('title');
                    $rr['end_address'] = Db::name('address')->where('id',$convey['end'])->value('title');

                    $cate = Db::name('convey_cate')->where('id',$convey['type'])->find();
                    $rr['convey_title'] = $cate?$cate['title']:'';

                    $conveyCate = Db::name('convey_cate')->where('id',$convey['type'])->find();

                    if($conveyCate && $conveyCate['priority'] != 4 && $convey['xq_time'] < date('Y-m-d H:i:s',$curtime15)){
                        $data[] = $rr;
                    }
                }

            }else{
                $data[] = $rr;
            }

        }

        $newData = array_page_list($data,$page,$size);
        return $newData;
    }
    //抢单
    public function grabOrdersEdit($order, $userId,$orderType,$addressId) {
        $this->startTrans();
        try {
            $data = [
                'order_mode' => 4,
                'send_time' => getTime(),
            ];
            $res = $this->where('id', $order['id'])->update($data);
            if (!$res) {
                \exception('订单修改失败');
            }
            $orders = Db::name('orders')
                ->where('id',$order['id'])
                ->find();
            if($orders['work_type_mode']==1){
                $p = [
                    'type_id'=>$orderType,
                    'address_id'=>$addressId,
                ];
                $repair = Db::name('order_repair')
                    ->where('order_id', $order['id'])
                    ->find();
                if($repair){
                    $r = Db::name('order_repair')
                        ->where('id', $repair['id'])
                        ->update($p);
                }else{
                    $p['order_id'] = $order['id'];
                    $r = Db::name('order_repair')->insert($p);
                }
                if (!$r) {
                    \exception('订单扩展修改失败');
                }
            }
            $todoData = [
                'order_id' => $order['id'],
                'todo_content' => '',
                'to_user_id' => $userId,
                'create_user_id' => $userId,
                'org_id' => $order['org_id'],
                'create_time' => getTime(),
                'xy_time' => time()-strtotime($orders['create_time']),
                'confirm_time' => getTime(),
                'todo_mode' => 2,
                'work_type_mode' => $order['work_type_mode'],
                'create_yyyy' => date('Y'),
                'create_yyyymm' => date('Ym'),
                'create_yyyymmdd' => date('Ymd'),
                'sn' => get_unique_sn(get_config('sn_prefix')),
            ];
            $res = Db::name('todo')
                ->insertGetId($todoData);
            if (!$res) {
                \exception('抢单失败');
            }
            $taskData = [
                'org_id' => $order['org_id'],
                'type' => 1,
                'start_time' => getTime(),
                'create_time' => getTime(),
            ];
            $taskData['user_id'] = $userId;
            $taskData['bus_id'] = $res;

            if($orders['work_type_mode']==1){
                $orderRepair = Db::name('order_repair')
                    ->where('order_id',$orders['id'])
                    ->find();
                $taskData['priority'] = !empty($orderRepair) && $orderRepair['repair_priority']==3?1:0;

            }else if ($orders['work_type_mode']==3){
                $order_convey = Db::name('order_convey')
                    ->where('order_id',$orders['id'])
                    ->find();
                $taskData['priority'] = !empty($order_convey) && $order_convey['priority']==3?2:0;
            }
            $res = Db::name('task')
                ->insert($taskData);
            if (!$res) {
                \exception('任务保存失败');
            }

            $this->commit();
            return true;
        } catch (Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }
    //用户订单列表
    public function userOrdersByMode($page,$size,$userId,$mode,$type,$orgId){
        $map[] = ['del', '=', 0];
        $map[] = ['user_id', '=', $userId];
        if($mode >0){
            $map[] = ['work_type_mode', '=', $mode];
        }
        if($type >0 && in_array($type,[1,5,6])){
            $map[] = ['order_mode', '=', $type];
        }elseif ($type==7){//处理中
            $map[] = ['order_mode', 'in', [1,4]];

        }elseif ($type==8){//已挂起
            $ids = Db::name('todo')
                ->where('org_id',$orgId)
                ->where('del',0)
                ->where('work_type_mode',1)
                ->where('todo_mode',2)
                ->where('pause',1)
                ->column('order_id');
            if(empty($ids)){
                $map[] = ['id', '=', -1];
            }else{
                $map[] = ['id', 'in', $ids];
            }

        }elseif ($type==9){//已取消
            $map[] = ['order_mode', 'in', [2,3,7]];

        }
        $offset = ($page - 1) * $size;
        $list = $this->where($map)
            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];
        foreach ($list as $k => $v) {
            $v = $this->formatOrder($v);
            $order_delay = Db::name('order_delay')
                ->alias('a')
                ->join('delay_reason b','a.delay_reason_id=b.id')
                ->where('a.order_id',$v['id'])
                ->field('a.*,b.title')
                ->find();
            if($order_delay && $order_delay['status']==0){
                $v['order_mode_out_text'] = '延迟中';
                $v['delay_reason'] = $order_delay['title'];
            }
            if($type==8){
                $v['order_mode_out_text'] = $v['order_mode_out_text'].'(已挂起)';
            }
            $ll = formatArray(
                [
                    'id',
                    'order_mode',
                    'create_time',
                    'source_type',
                    'work_type_mode',
                    'send_time',
                    'work_type_mode_text',
                    'dep',
                    'order_mode_text',
                    'order_mode_out_text',
                    'real_name',
                    'sn'
                ]
                , $v);

            $data[] = $ll;
        }
        return $data;
    }
    //所有订单列表
    public function queryAllOrder($orgId,$page,$size,$workTypeMode,$currOrderMode,$beginTime,$endTime,$dept=0){
        if(in_array($workTypeMode,[0,1,2,3,4,15])){
            $map[] = ['work_type_mode','=',$workTypeMode];
        }
        if($currOrderMode && $currOrderMode > 0){
            $map[] = ['order_mode','=',$currOrderMode];
        }
        if($beginTime){
            $map[] = ['create_time','>=',$beginTime.' 00:00:00'];
        }
        if($endTime){
            $map[] = ['create_time','<=',$endTime.' 23:59:59'];
        }
        if($dept > 0){
            $map[] = ['dep_id','=',$dept];
        }
        $map[] = ['del', '=', 0];
        $map[] = ['org_id', '=', $orgId];
        $offset = ($page - 1) * $size;
        $list = $this->where($map)
            ->limit($offset, $size)
            ->order('id', 'desc')
            ->select();
        $list = $list ? $list->toArray() : [];
        $data = [];
        foreach ($list as $k => $v) {
            $v = $this->apiFormatOrder($v);
            $ll = formatArray(
                [
                    'id',
                    'order_mode',
                    'create_time',
                    'source_type',
                    'work_type_mode',
                    'send_time',
                    'work_type_mode_text',
                    'dep',
                    'order_mode_text',
                    'order_mode_out_text',
                    'real_name',
                    'sn'
                ]
                , $v);
            $data[] = $ll;
        }
        return $data;
    }
    //延迟任务
    public function delay_reason($id,$delayReasonId,$type=0){
        $ids = explode(',',$id);

        $this->startTrans();
        try{
            foreach ($ids as $id){
                $info = $this->where('id',$id)->find();

                if (!in_array($info['order_mode'],[1,4])) {
                   \exception('选择的订单状态不能延迟');
                }

                $res = Db::name('order_delay')
                    ->where('order_id',$id)
                    ->where('status',0)
                    ->find();
                if($res){
                   \exception('选择的订单已存在延时任务');
                }

                $curTime = date('Y-m-d H:i:s');

                $res =Db::name('order_delay')
                    ->insert([
                    'order_id' => $id,
                    'delay_reason_id' => $delayReasonId,
                    'start_time' => $curTime,
                    'status' => 0,
                    'type' => $type
                ]);
               if(!$res){
                   \exception('添加失败');
               }
            }

            $this->commit();
            return true;
        }catch (Exception $e){
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    //取消延迟
    public function batchcanceldelay($id){
        $ids = explode(',',$id);

        $this->startTrans();
        try{
            foreach ($ids as $id){

                $info = Db::name('order_delay')
                    ->where('order_id',$id)
                    ->where('status',0)
                    ->find();
                if(!$info){
                    \exception('选择的订单不存在延时任务');
                }

                $curTime = date('Y-m-d H:i:s');

                $res =Db::name('order_delay')
                    ->where('order_id',$id)
                    ->update([
                        'end_time' => $curTime,
                        'diff' => strtotime($curTime) - strtotime($info['start_time']),
                        'status' => 1
                    ]);
                if(!$res){
                    \exception('添加失败');
                }
            }

            $this->commit();
            return true;
        }catch (Exception $e){
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    public function addConveyEnd($orgId,$orderId,$addrId){
        $order = Db::name('orders')
            ->where('org_id',$orgId)
            ->where('id',$orderId)
            ->where('order_mode',4)
            ->where('del',0)
            ->where('work_type_mode',3)
            ->find();
        if(!$order){
            $this->error = '订单不存在';
            return false;
        }

        // 检查订单是不是病人运送
        $convey = Db::name('order_convey')
            ->alias('a')
            ->join('convey_cate b','a.type = b.id')
            ->where('a.order_id',$orderId)
            ->where('b.cate',1)
            ->field('a.*')
            ->find();
        if(!$convey){
            $this->error = '订单不存在';
            return false;
        }

        Db::startTrans();
        try{
            $ret = Db::name('order_convey_end')->insert([
                'order_id' => $orderId,
                'addr' => $convey['end'],
                'order_convey_id' => $convey['id'],
                'create_time' => date('Y-m-d H:i:s')
            ]);
            if(!$ret){
                \exception('操作失败');
            }

            // 更换目的地
            if($addrId != $convey['end']){
                $res = Db::name('order_convey')->where('id', $convey['id'])->update([
                    'end' => $addrId,
                ]);
                if(!$res){
                    \exception('操作失败');
                }
            }

            Db::commit();
        }catch (Exception $e){
            Db::rollback();
            $this->error = '操作失败';
            return false;
        }

        return true;
    }

    // 途经点点扫码
    public function sweepCode($code,$id,$num=0,$img='',$orgId=0,$userId=0){
        $addrs = model('address')->checkAddrCode($code,2,$orgId);
        if(!$addrs){
            HelpHander::error('二维码不正确');
        }

        $info = Db::name('order_convey_end')->where('id',$id)->find();
        if(!$info){
            $this->error = '数据不存在';
            return false;
        }
        if($info['addr'] != $addrs['id']){
            $this->error = '地点不正确';
            return false;
        }
        $totalNum = Db::name('orders')->where('id',$info['order_id'])->value('total_num');

        if($totalNum > 0){
            $totalNum2 = Db::name('order_convey_end')->where('order_id',$info['order_id'])->where('del',0)->where('scan',1)->sum('num');
            $t2 = $totalNum2+$num;
            if(intval($t2) > intval($totalNum) ){
                $this->error = '送达数量不能超过领取总数量';
                return false;
            }
        }
        $res = Db::name('order_convey_end')->where('id',$id)->update([
            'scan' => 1,
            'update_time' => date('Y-m-d H:i:s'),
            'num'=>$num,
            'img'=>$img,
            'user_id'=>$userId
        ]);
        if(!$res){
            $this->error = '操作失败';
            return false;
        }

        return true;

    }

    //api获取调度,待处理,已处理,驳回数量
    public function orderCount($userId, $orgId,$cur_order_mode=0) {
        $map[] = ['org_id', '=', $orgId];
        $map[] = ['del', '=', 0];

        $map2[] = ['todo_mode', '=', 4];
        $map1 = [];
        $auth = get_dispatch_auth($userId);
        if (empty($auth)) {
            $map[] = ['work_type_mode', '=', -1];
        }
        else {
            $map[] = ['work_type_mode', 'in', $auth];
        }
        $org_two_dispatch = (new Config())->getConfig('org_two_dispatch',$orgId);
        if($org_two_dispatch==0){//二级调度开关关闭
            if ($cur_order_mode == 0) {//待处理
                $map[] = ['order_mode', 'in', [1]];
                $map[] = ['is_deal', '=', 0];
            }
            else {
                if ($cur_order_mode == 1) {//已处理
                    $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                }
            }
        }else{
            if (check_two_dispatch($userId) == 1) {//二级调度角色
                $roles_id = Db::name('user_roles')
                    ->where('user_id',$userId)
                    ->value('roles_id');
                $ids = Db::name('dispatch_log')
                    ->where('roles_id', $roles_id)
                    ->whereOr('to_user_id', $userId)
                    ->column('order_id');
                if ($cur_order_mode == 2) {//驳回
                    if (empty($ids)) {
                        $map2[] = ['order_id', '=', -1];
                    }
                    else {
                        $map2[] = ['order_id', 'in', $ids];
                    }
                }
                else {
                    if (empty($ids)) {
                        $map[] = ['id', '=', -1];
                    }
                    else {
                        $map[] = ['id', 'in', $ids];
                    }
                }
                if ($cur_order_mode == 0) {//待处理
                    $map[] = ['order_mode', 'in', [1]];
                }
                else {
                    if ($cur_order_mode == 1) {//已处理
                        $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                    }
                }
            }
            else {
                if ($cur_order_mode == 0) {//待处理
                    $map[] = ['order_mode', 'in', [1]];
                    $map[] = ['is_deal', '=', 0];
                }
                else {
                    if ($cur_order_mode == 1) {//已处理
                        $map[] = ['order_mode', 'in', [2, 3, 4, 5, 6]];
                        $map1[] = ['is_deal', '=', 1];
                    }
                }

            }
        }
        if ($cur_order_mode == 2) { //驳回订单
            $count = Db::name('todo_view')
                ->where($map)
                ->where($map2)
                ->count();
            return $count;
        }
        $count = $this->where($map)
            ->whereOr($map1)
            ->count();
        return $count;
    }

    public function addBxOrders($data){
        if($data['type_id'] < 1){
            $this->error = '报修事项不能为空';
            return false;
        }

        if($data['repair_priority'] < 1){
            $this->error = '请选择紧急程度';
            return false;
        }


        if(empty($data['images']) && empty($data['voices']) && empty($data['content'])){
            $this->error = '内容不能为空';
            return false;
        }
        $odata = [
            'user_id'=>$data['user_id'],
            'org_id'=> $data['org_id'],
            'dep_id'=>$data['dep_id'],
            'images'=>$data['images'],
            'videos'=>$data['videos'],
            'voices'=>$data['voices'],
            'content'=>$data['content'],
            'work_type_mode'=>$data['work_type_mode'],
            'source_type'=>$data['source_type'],
            'sn'=>get_unique_sn(get_config('sn_prefix')),
            'order_mode'=>4,
            'create_time'=>date('Y-m-d H:i:s'),
            'send_time'=>date('Y-m-d H:i:s'),
            'create_yyyy'=>date('Y'),
            'create_yyyymm'=>date('Ym'),
            'create_yyyymmdd'=>date('Ymd'),
            'from'=>1,
        ];

        Db::startTrans();
        try {
            $orderId = Db::name('orders')->insertGetId($odata);
            if(!$orderId){
                \exception('操作失败');
            }
            $orData = [
                'order_id'=>$orderId,
                'type_id'=>$data['type_id'],
                'address_id'=>$data['address_id'],
                'repair_priority'=>$data['repair_priority'],
                'update_time'=>date('Y-m-d H:i:s'),
            ];
            $or = Db::name('order_repair')->insert($orData);
            if(!$or){
                \exception('操作失败');
            }
            $tData = [
                'order_id'=>$orderId,
                'to_user_id'=>$data['user_id'],
                'todo_content'=>$data['content'],
                'org_id'=>$data['org_id'],
                'create_user_id'=>$data['user_id'],
                'create_time'=>date('Y-m-d H:i:s'),
                'todo_mode'=>2,
                'work_type_mode'=>$data['work_type_mode'],
                'create_yyyy'=>date('Y'),
                'create_yyyymm'=>date('Ym'),
                'create_yyyymmdd'=>date('Ymd'),
                'sn'=>get_unique_sn(get_config('sn_prefix')),
            ];

            $todoId = Db::name('todo')->insertGetId($tData);
            if(!$todoId){
                \exception('操作失败');
            }

            $taskData = [
                'org_id' => $data['org_id'],
                'user_id' => $data['user_id'],
                'type' => 1,
                'start_time' => getTime(),
                'create_time' => getTime(),
                'bus_id' => $todoId,
                'priority' => $data['repair_priority']==3 ?1:0,
            ];

            $task = Db::name('task')->insert($taskData);
            if(!$task){
                \exception('任务保存失败');
            }

            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            $this->error = '操作失败';
            return false;
        }

        return  true;

    }


    public function autoSend($id){
        $info = Db::name('orders')
            ->where('id',$id)
            ->find();
//        $org_auto_send = (new \app\common\model\Config())
//            ->getConfig('org_auto_send',$info['org_id']);
//        if(!$org_auto_send){
//           $this->error='自动派单未开启';
//           return false;
//        }
        $repair = Db::name('order_repair')
            ->where('order_id',$id)
            ->find();
        if(empty($repair) || strlen($repair['type_id'])==0){
            $this->error='订单报修事项为空';
            return false;
        }
        $parent_id = Db::name('order_type')
            ->where('id',$repair['type_id'])
            ->value('parent_id');
        if(empty($info)){
            $this->error='订单信息不存在';
            return false;
        }
        if($info['work_type_mode']!=1){
            $this->error='当前订单类型不能自动派单';
            return false;
        }
        if($info['order_mode']!=1){
            $this->error='当前订单已处理';
            return false;
        }
        $depInfo = Db::name('order_auto_send_area')
            ->where('dep_id',$info['dep_id'])
            ->find();
        $workUser = get_sort_user($info['org_id'],1,$parent_id);
        if(empty($workUser)){
            $this->error='人员不存在';
            return false;
        }
        //当前科室未设置负责人
        if(empty($depInfo) || empty($depInfo['user_id'])){
            $lastUser = Db::name('order_auto_send_log')
                ->where('org_id',$info['org_id'])
                ->where('type',0)
                ->where('type_id',$parent_id)
                ->order('id','desc')
                ->value('user_id');
            $newSort = cache("org_user_sort_".$info['org_id']);
            if(empty($newSort)){
                $newSort = get_sort_user($info['org_id'],1,$parent_id);
            }else{
                $newSort = Db::name('user')
                    ->where('id','in',$newSort)
                    ->where('type_id',$parent_id)
                    ->column('id');
            }
            if(cache("auto_send_end_".$info['org_id'])){
                $userId = $newSort[0];
                cache("auto_send_end_".$info['org_id'],false);
            }else{
                $curKey = array_search($lastUser,$newSort);
                if(strlen($curKey) >0){
                    if(isset($newSort[$curKey+1])){
                        $userId = $newSort[$curKey+1];
                        if(!isset($newSort[$curKey+2])){
                            cache("org_user_sort_".$info['org_id'],null);
                            cache("org_user_sort_list_".$info['org_id'],null);
                            cache("auto_send_end_".$info['org_id'],1);
                        }
                    }else{
                        cache("org_user_sort_".$info['org_id'],null);
                        cache("org_user_sort_list_".$info['org_id'],null);
                        $userId = $newSort[0];
                    }

                }else{
                    cache("org_user_sort_".$info['org_id'],null);
                    cache("org_user_sort_list_".$info['org_id'],null);
                    $userId = $newSort[0];
                }
            }
            $type =0;
        }else{//订单科室设置负责人
            $lastUser = Db::name('order_auto_send_log')
                ->where('org_id',$info['org_id'])
                ->where('type',1)
                ->where('dep_id',$info['dep_id'])
                ->where('type_id',$parent_id)
                ->order('id','desc')
                ->value('user_id');
            $idList = explode(',',$depInfo['user_id']);
            $uu = Db::name('user')
                ->where('del',0)
                ->where('enable',1)
                ->where('enable_sorts',1)
                ->where('work',1)
                ->where('type_id',$parent_id)
                ->where('id','in',$idList)
                ->order(['sorts'=>'desc','id'=>'asc'])
                ->column('id');
            if(empty($uu)){
                Db::name('order_auto_send_area')
                    ->where('dep_id',$info['dep_id'])
                    ->delete();
                $this->autoSend($id);
            }else{
                $old = cache("org_user_sort_".$info['org_id']);
                $old_data = $uu;
                $uu = [];
                $not_exits = [];
                if($old){
                    foreach ($old_data as $k=>$v){
                        if(in_array($v,$old)){
                            $kk = array_search($v,$old);
                            $uu[$kk] = $v;
                        }else{
                            $not_exits[] = $v;
                        }
                    }

                }else{
                    $uu = $old_data;
                }
                ksort($uu);
                $aa = [];
                foreach ($uu as $k=>$v){
                    $aa[] = $v;
                }
                foreach ($not_exits as $k=>$v){
                    array_push($aa,$v);
                }
                $uu = $aa;
                if(empty($lastUser) || !in_array($lastUser,$uu)){
                    $userId = $uu[0];
                }else{
                    if($lastUser==$uu[count($uu)-1]){
                        $userId = $uu[0];
                    }else{
                        $cc = array_search($lastUser,$uu);
                        if(strlen($cc) >0){
                            if(isset($uu[$cc+1])){
                                $userId = $uu[$cc+1];
                            }else{
                                $userId = $uu[0];
                            }
                        }
                    }
                }
            }
            $newSort = $uu;
            $type =1;
        }
        $log = [
            'org_id'=>$info['org_id'],
            'order_id'=>$id,
            'user_id'=>$userId,
            'type_id'=>$parent_id,
            'dep_id'=>$type==1?$info['dep_id']:0,
            'type'=>$type,
            'create_time'=>getTime(),
            'user_sort'=>json_encode($newSort)
        ];
        Db::startTrans();
        try{
            $r =Db::name('order_auto_send_log')
                ->insertGetId($log);
//            Db::commit();
//            return true;
            if(!$r){
                \exception('派单失败');
            }
            if($type==1){
                $rr = Db::name('order_auto_send_area')
                    ->where('dep_id',$info['dep_id'])
                    ->update(['last_user'=>$userId,'update_time'=>getTime()]);
                if(!$rr){
                    \exception('更新派单区域管理失败');
                }
            }

            $todoData = [
                'order_id' => $id,
                'todo_content' => $info['content'],
                'create_user_id' => $info['user_id'],
                'org_id' => $info['org_id'],
                'create_time' => getTime(),
                'todo_mode' => 1,
                'work_type_mode' => $info['work_type_mode'],
                'create_yyyy' => date('Y'),
                'create_yyyymm' => date('Ym'),
                'create_yyyymmdd' => date('Ymd'),

            ];

            $taskData = [
                'org_id' => $info['org_id'],
                'type' => 1,
                'start_time' => getTime(),
                'create_time' => getTime(),
            ];
            if($info['work_type_mode']==1){
                $orderRepair = Db::name('order_repair')
                    ->where('order_id',$info['id'])
                    ->find();
                $taskData['priority'] = !empty($orderRepair) && $orderRepair['repair_priority']==3?1:0;

            }else if ($info['work_type_mode']==3){
                $order_convey = Db::name('order_convey')
                    ->where('order_id',$info['id'])
                    ->find();
                $taskData['priority'] = !empty($order_convey) && $order_convey['priority']==3?2:0;
            }
            $sns = [];
            $to_user_id = [$userId];
            $snpre = (new Config())->getConfig('sn_prefix');
            foreach ($to_user_id as $k => $v) {
                if(empty($v)){
                    continue;
                }
                $todoData['to_user_id'] = $v;

                while (true){  //获取唯一工单号
                    $sn = get_unique_sn($snpre);
                    if(!in_array($sn,$sns)){
                        $ret = Db::name('todo')->where('sn',$sn)->find();
                        if(!$ret){
                            $todoData['sn'] = $sn;
                            break;
                        }
                    }
                }
                $todoData['is_auto'] = 1;
                $res = Db::name('todo')
                    ->insertGetId($todoData);
                if (!$res) {
                    \exception('执行人:' . $v . '派单失败');
                }
                $pusharr[] = [
                    'user_id' => $v,
                    'todo_id' => $res
                ];
                $taskData['user_id'] = $v;
                $taskData['bus_id'] = $res;
                $res = Db::name('task')
                    ->insert($taskData);
                if (!$res) {
                    \exception('执行人:' . $v . '任务保存失败');
                }
            }
            $r = Db::name('orders')
                ->where('id',$id)
                ->update(['order_mode'=>4]);
            if(!$r){
                \exception('操作失败');
            }
            if($pusharr) {
                foreach ($pusharr as $k => $v) {
                    // 极光推送
                    send_jpush([$v['user_id']], AppMsg::PUSH_WORKER_ORDER_SEND, '', ['id' => $v['todo_id']]);
                }
            }
            // 极光推送
            send_jpush([$info['user_id']],AppMsg::PUSH_USER_ORDER_SEND,'',['id'=>$info['id']]);
            Db::commit();
            return true;
        }catch (Exception $e){
            Db::rollback();
            $this->error=$e->getMessage();
            return false;
        }


    }

    public function get_cur_day_lists($org,$limit=5)
    {
        $ret = Db::name('orders')
            ->alias('o')
            ->where('o.org_id',$org)
            ->where('o.del',0)
            // ->where('o.order_mode','in',[1,4])
            //->where('o.work_type_mode',3)
            ->where('o.create_yyyymmdd',date('Ymd'))
            ->order('o.id','desc')
            ->limit($limit)->select();
        foreach ($ret as $k=>$v){

            $todo =Db::name('todo')
                ->alias('t')
                ->where('t.order_id',$v['id'])
                ->join('user u','u.id = t.to_user_id')
                // ->where('t.todo_mode','in',[1,2,3])
                ->where('t.del',0)
                ->field('u.real_name,t.create_time,t.confirm_time')
                ->order('t.id','asc')
                ->select();

            $users = [];
            $confirmTime = '';
            foreach ($todo as $kk=>$vv){
                $users[] = $vv['real_name'];
                if(!$confirmTime && $vv['confirm_time']){
                    $confirmTime = $vv['confirm_time'];
                }else if($confirmTime && $vv['confirm_time'] && $vv['confirm_time'] < $confirmTime){
                    $confirmTime = $vv['confirm_time'];
                }
            }

            $ret[$k]['real_names'] = implode(',',$users);
            $ret[$k]['send_time'] = $todo?$todo[0]['create_time']:'';
            $ret[$k]['confirm_time'] = $confirmTime;
            $ret[$k]['order_model_txt'] = Db::name('order_mode')
                ->where('id',$v['order_mode'])
                ->value('out_content');


        }

        return $ret?$ret:[];
    }
    public function get_cur_day_lists_bak($org,$limit=5)
    {
        $ret = Db::name('orders')
            ->alias('o')
            ->join('order_convey oc','oc.order_id = o.id')
            ->field('o.*,oc.type,oc.start,oc.end,oc.xq_time,oc.ywc_time,oc.device_id,oc.name,oc.phone,oc.priority')
            ->where('o.org_id',$org)
            ->where('o.del',0)
            ->where('o.order_mode','in',[1,4])
            ->where('o.work_type_mode',3)
            ->where('o.create_yyyymmdd',date('Ymd'))
            ->order('oc.xq_time','ASC')
            ->limit($limit)->select();
        foreach ($ret as $k=>$v){
            $ret[$k]['start_name'] = $this->getTableField('address',array('id'=>$v['start']),'title');
            $ret[$k]['end_name'] = $this->getTableField('address',array('id'=>$v['end']),'title');
            $ret[$k]['type_name'] = $this->getTableField('convey_cate',array('id'=>$v['type']),'title');
            $ret[$k]['real_name'] = $this->getTableField('user',array('id'=>$v['user_id']),'real_name');

            $todo =Db::name('todo')
                ->alias('t')
                ->where('t.order_id',$v['id'])
                ->join('user u','u.id = t.to_user_id')
                ->where('t.todo_mode','in',[1,2,3])
                ->where('t.del',0)
                ->field('u.real_name,t.create_time,t.confirm_time')
                ->order('t.id','asc')
                ->select();

            $users = [];
            $confirmTime = '';
            foreach ($todo as $kk=>$vv){
                $users[] = $vv['real_name'];
                if(!$confirmTime && $vv['confirm_time']){
                    $confirmTime = $vv['confirm_time'];
                }else if($confirmTime && $vv['confirm_time'] && $vv['confirm_time'] < $confirmTime){
                    $confirmTime = $vv['confirm_time'];
                }
            }

            $ret[$k]['real_names'] = implode(',',$users);
            $ret[$k]['send_time'] = $todo?$todo[0]['create_time']:'';
            $ret[$k]['confirm_time'] = $confirmTime;
            $ret[$k]['device_name'] = '';
            if($v['device_id'] > 0){
                $ret[$k]['device_name'] = $this->getTableField('convey_device',array('id'=>$v['device_id']),'title');
            }

            $last = strtotime($v['ywc_time']) - time();
            $ret[$k]['last_time'] = $last > 0?round($last/60):0;

        }

        return $ret?$ret:[];
    }

    public function delConveyEnd($orderId,$orgId){
        $order = Db::name('orders')
            ->where('org_id',$orgId)
            ->where('id',$orderId)
            ->where('order_mode',4)
            ->where('del',0)
            ->where('work_type_mode',3)
            ->find();
        if(!$order){
            $this->error = '订单不存在';
            return false;
        }

        // 检查订单是不是病人运送
        $convey = Db::name('order_convey')
            ->alias('a')
            ->join('convey_cate b','a.type = b.id')
            ->where('a.order_id',$orderId)
          //  ->where('b.cate',1)
            ->field('a.*')
            ->find();
        if(!$convey){
            $this->error = '订单不存在';
            return false;
        }
        $orderEnd = Db::name('order_convey_end')
            ->where('order_convey_id',$convey['id'])
            ->where('del',0)
            ->order('id','desc')
            ->select();
        if(!$orderEnd){
            $this->error = '没有途径地点不能删除目的地';
            return false;
        }
        Db::startTrans();
        try{
            $ret = Db::name('order_convey_end')
                ->where('id',$orderEnd[0]['id'])->update([
                    'del' => 1,
                    'update_time' => date('Y-m-d H:i:s')
                ]);
            if(!$ret){
                \exception('操作失败');
            }

            // 更换目的地
            $res = Db::name('order_convey')
                ->where('id', $convey['id'])->update([
                    'end' => $orderEnd[0]['addr'],
                ]);
            if(!$res){
                \exception('操作失败');
            }

            Db::commit();
        }catch (Exception $e){
            Db::rollback();
            $this->error = '操作失败';
            return false;
        }

        return true;
    }

}