mingde-bd/application/api/controller/v1/PatrolRecord.php

<?php
namespace app\api\controller\v1;
use app\api\controller\Base;
use app\common\model\Task;
use app\hander\HelpHander;
use think\Db;
use think\Exception;

class PatrolRecord extends Base
{

    public function updateBySn()
    {
        $deviceSn = input('deviceSn');
        $power = input('power');
        $ret = Db::name('address')
            ->where('sn',$deviceSn)->update(['power'=>$power]);
        if($ret){
            HelpHander::success([],'修改成功');
        }else {
            HelpHander::error('修改失败');
        }
    }

    public function add(){

//        $jsonArray = [
//            'userId'=>$this->userId,
//            'orgId'=>$this->orgId,
//            'patrolTaskId'=>input('patrolTaskId'),
//            'patrolAddrFormId'=>input('patrolAddrFormId'),
//            'patrolAddrId'=>input('patrolAddrId'),
//            'images'=>input('images'),
//            'content'=>input('content'),
//            'isNormal'=>input('isNormal'),
//            'patrolMode'=>input('patrolMode'),
//            'checkJson'=>input('checkJson'),
//        ];
//        if(!$jsonArray['checkJson']){
//            HelpHander::error('检查结果不能为空');
//        }
        // checkJson新格式：[{"id":1,"title":"表单名称","forms":[{"remark":"","result":"1","title":"测试","type":"0"}]}]
        $json = input('json');
        if (!$json) {
            HelpHander::error('参数不正确');
        }
        $jsonArray=json_decode($json,true);
        if(!$jsonArray['checkJson']){
            HelpHander::error('检查结果不能为空');
        }
        $patrolTask = Db::name('patrol_task')
            ->where('id',$jsonArray['patrolTaskId'])
            ->where('del',0)
            ->find();
        $task = $patrolTask;
        if(!$patrolTask){
            HelpHander::error('任务不存在');
        }
        if(!in_array($patrolTask['status'],[0,1])){
            HelpHander::error('任务已处理');
        }
        $curTime = time();
        $startTime = strtotime($patrolTask['start_time']);
        $endTime = strtotime($patrolTask['end_time']);
        if($curTime < $startTime || $curTime > $endTime){
            HelpHander::error('不在任务时间范围内，无法提交');
        }
        // 检查该任务是已保存
        $res = Db::name('patrol_record')
            ->where('patrol_task_id',$jsonArray['patrolTaskId'])
            ->where('patrol_addr_form_id',$jsonArray['patrolAddrFormId'])
            ->find();
        if($res){
            HelpHander::error('该地点已上传记录');
        }
        $countrecord = Db::name('patrol_record')
            ->where('patrol_task_id',$jsonArray['patrolTaskId'])
            ->count();

        $time = 0; // 0=正常 1=异常
        $rmax = 0;
        $rmin = 0;
        $wctime = 0;
        if($task['in_order'] == 1){ // 按顺序巡更，检查地点循序
            $fcount = Db::name('patrol_task_addr')
                ->where('id','<',$jsonArray['patrolAddrFormId'])
                ->where('patrol_task_id',$jsonArray['patrolTaskId'])
                ->count();
            if($fcount > 0 && ($countrecord == 0 || ($countrecord > 0 && $countrecord != $fcount))){
                HelpHander::error('请按正确顺序执行计划');
            }
            if($task['lines']){ // 路线时间设置
                $lines = json_decode($task['lines'],true);
                if($countrecord > 0 && $fcount > 0){ // 说明不是第一个点，获取路线开始节点
                    $saddrid = Db::name('patrol_task_addr')
                        ->where('id','<',$jsonArray['patrolAddrFormId'])
                        ->where('patrol_task_id',$jsonArray['patrolTaskId'])
                        ->value('address_id');
                    $eaddrid = $jsonArray['patrolAddrId'];
                    $lastTime = Db::name('patrol_record')
                        ->where('patrol_task_id',$jsonArray['patrolTaskId'])
                        ->order('id desc')
                        ->value('create_time');
                    $ctime = round((time() - strtotime($lastTime))/60);
                    foreach ($lines as $k=>$v){
                        if($v['s'] = $saddrid && $v['e'] == $eaddrid){ // 是同一路线，计算时长
                             $min = round($v['kd'] - $v['fd']);
                             $max = round($v['kd'] + $v['fd']);
                             $min = $min > 0 ?$min:0;
                             $max = $max > 0 ?$max:0;
                             if($ctime < $min || $max < $ctime){
                                 $time = 1;
                             }

                            $rmin = $min;
                            $rmax = $max;
                            $wctime = $ctime;
                             break;
                        }
                    }
                }
            }
        }


        Db::startTrans();
        try {
            $data=[
                'org_id'=>$jsonArray['orgId'],
                'user_id'=>$jsonArray['userId'],
                'patrol_task_id'=>$jsonArray['patrolTaskId'],
                'patrol_addr_id'=>$jsonArray['patrolAddrId'],
                'images'=>$jsonArray['images'],
                'content'=>isset($jsonArray['content'])?$jsonArray['content']:'',
                'check_json'=>$jsonArray['checkJson'],
                'is_normal'=>$jsonArray['isNormal'],
                'create_time'=>date('Y-m-d H:i:s'),
                'create_yyyy'=>date('Y'),
                'create_yyyymm'=>date('Ym'),
                'create_yyyymmdd'=>date('Ymd'),
                'patrol_mode'=>$jsonArray['patrolMode'],
                'patrol_addr_form_id'=>$jsonArray['patrolAddrFormId'],
                'time' => $time,
                'min' => $rmin,
                'max' => $rmax,
                'wc_time' => $wctime
            ];
            $addRecord=Db::name('patrol_record')->insert($data);

            if(!$addRecord){
                exception('保存失败');
            }

            $countaddr = Db::name('patrol_task_addr')
                ->where('patrol_task_id',$jsonArray['patrolTaskId'])->count();

            if($countaddr == $countrecord + 1){
                $status = 2;
            }else{
                $status = 1;
            }

            if($jsonArray['isNormal']==1 && $task['is_exception'] == 0){
                Db::name('patrol_task')->where('id',$jsonArray['patrolTaskId'])->setField('is_exception',1);
            }

            if($task['status'] != $status){
                $a = [
                    'status'=>$status,
                    'update_time'=>getTime(),
                ];
                $save = Db::name('patrol_task')
                    ->where('id',$jsonArray['patrolTaskId'])
                    ->update($a);
                if(!$save){
                    exception('操作失败');
                }

                if(in_array($status,[2,3,5])){
                    Db::name('task')
                        ->where('bus_id', $jsonArray['patrolTaskId'])
                        ->where('type', (new Task())::TASK_TYPE_PATROL)
                        ->delete();
                }

            }

            Db::commit();

        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            HelpHander::error( $e->getMessage());
        }
        HelpHander::success([],'操作成功');
    }

    public function recordByAddr(){
        $id = input('id/d',0);
        $mode = input('mode/d',1);
        $page = input('page/d',1);
        $size = input('size/d',10);
        $lists = Db::name('patrol_record')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->join('patrol_task c','a.patrol_task_id = c.id')
            ->where('a.patrol_addr_id',$id)
            ->where('a.patrol_mode',$mode)
            ->field('a.id,a.patrol_task_id,a.order_id,a.patrol_mode,a.patrol_addr_form_id,a.is_normal,a.create_time,b.real_name,a.time,c.title')
            ->order('a.id desc')
            ->page($page,$size)
            ->select();
        $lists = $lists?$lists:[];
        foreach ($lists as $kk=>$val){
            $status = 0;
            if($val['order_id'] > 0 ){
                $order =  Db::name('orders')->where('id',$val['order_id'])->whereIn('order_mode',[5,6])->where('del',0)->find();
                if($order){
                    $status = 2;
                }else{
                    $status = 1;
                }
            }
            $lists[$kk]['zg_type'] = $status;
        }
        HelpHander::success($lists?$lists:[],'成功');
    }

}