init

liusuyi

2024-10-10 38f29e38fcc668171dc05c53d40a36b895c86102

 ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java

@@ -2,6 +2,7 @@


import java.util.*;



import com.ruoyi.alarm.global.domain.GuidePoint;

import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;

import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;

import com.ruoyi.common.utils.DateUtils;

@@ -13,6 +14,7 @@
import com.ruoyi.inspect.domain.ArdVideoInspectRecord;

import com.ruoyi.inspect.mapper.ArdVideoInspectRecordMapper;

import com.ruoyi.inspect.mapper.ArdVideoInspectTaskStepMapper;

import com.ruoyi.utils.websocket.util.WebSocketUtils;

import lombok.extern.slf4j.Slf4j;

import org.springframework.stereotype.Service;

import com.ruoyi.common.utils.StringUtils;

@@ -115,7 +117,7 @@
    public int updateArdVideoInspectTask(ArdVideoInspectTask ardVideoInspectTask) {

        ardVideoInspectTask.setUpdateBy(SecurityUtils.getUsername());

        ardVideoInspectTask.setUpdateTime(DateUtils.getNowDate());

        //  ardVideoInspectTaskMapper.deleteArdVideoInspectTaskStepByTaskId(ardVideoInspectTask.getId());

        ardVideoInspectTaskMapper.deleteArdVideoInspectTaskStepByTaskId(ardVideoInspectTask.getId());

        insertArdVideoInspectTaskStep(ardVideoInspectTask);

        return ardVideoInspectTaskMapper.updateArdVideoInspectTask(ardVideoInspectTask);

    }

@@ -183,14 +185,9 @@
        }

        if (StringUtils.isNotNull(ardVideoInspectTaskStepList)) {

            for (ArdVideoInspectTaskStep ardVideoInspectTaskStep : ardVideoInspectTaskStepList) {

                if (ardVideoInspectTaskStep.getId() == null) {

                    //新的步骤,添加

                    ardVideoInspectTaskStep.setId(IdUtils.simpleUUID());

                    ardVideoInspectTaskStepMapper.insertArdVideoInspectTaskStep(ardVideoInspectTaskStep);

                } else {

                    //已有步骤,更新

                    ardVideoInspectTaskStepMapper.updateArdVideoInspectTaskStep(ardVideoInspectTaskStep);

                }

            }

        }

    }

@@ -436,32 +433,40 @@
                if (!StringUtils.isNull(wellId)) {

                    /*获取井坐标*/

                    ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellById(wellId);

                    double[] targetPositon = new double[3];

                    targetPositon[0] = well.getLongitude();

                    targetPositon[1] = well.getLatitude();

                    targetPositon[2] = well.getAltitude();

                    if (StringUtils.isNull(well)) {

                        log.debug("找不到井:" + well.getWellId());

                        return;

                    }

                    log.debug("找到井:" + well.getWellId());

                    GuidePoint guidePoint = new GuidePoint().setLongitude(well.getLongitude()).setLatitude(well.getLatitude());

                    log.debug("找到井坐标:" + well.getLongitude() + "-" + well.getLatitude() + "-" + well.getAltitude());

                    /*获取相机坐标*/

                    ArdCameras cameras = ardCamerasMapper.selectArdCamerasById(cameraId);

                    if (StringUtils.isNull(cameras)) {

                        log.debug("找不到相机:" + cameraId);

                        return;

                    }

                    double[] cameraPositon = new double[3];

                    cameraPositon[0] = cameras.getLongitude();

                    cameraPositon[1] = cameras.getLatitude();

                    cameraPositon[2] = cameras.getAltitude();

                    log.debug("找到相机:" + cameraId);

                    /*控制相机巡检*/

                    CameraCmd cmd = new CameraCmd();

                    cmd.setCameraId(cameraId);

                    cmd.setChanNo(channel);

                    cmd.setTargetPosition(targetPositon);

                    cmd.setTargetPosition(new double[]{guidePoint.getLongitude(), guidePoint.getLatitude()});

                    cmd.setOperator("sys_patrol_inspect");

                    cmd.setExpired(step.getRecordingTime() * 60);



                    boolean setTargetPosition = cameraSdkService.guideTargetPosition(cmd);

                    cmd.setExpired(step.getRecordingTime());//秒为单位

                    boolean setTargetPosition = cameraSdkService.guideTargetPosition(cmd).get("code").equals(200);

                    if (setTargetPosition) {

                        /*控制相机巡检成功，开始录像*/

                        cameraSdkService.recordStart(cmd);

                        //region 通知前端

                        Map<String, Object> message = new HashMap<>();

                        Map<String, String> data = new HashMap<>();

                        data.put("cameraId", cmd.getCameraId());

                        data.put("wellId", well.getWellId());

                        data.put("type", ardVideoInspectTask.getInspectMode()+"巡检");

                        message.put("70000", data);

                        WebSocketUtils.sendMessageAll(message);

                        //endregion

                    } else {

                        /*控制失败,当前步骤启动时间置null*/

                        ardVideoInspectTask.setCurrentStepStartTime("");

@@ -494,34 +499,43 @@
                if (!StringUtils.isNull(wellId)) {

                    /*获取井坐标*/

                    ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellById(wellId);

                    double[] targetPositon = new double[3];

                    targetPositon[0] = well.getLongitude();

                    targetPositon[1] = well.getLatitude();

                    targetPositon[2] = well.getAltitude();

                    if(StringUtils.isNull(well))

                    {

                        log.debug("找不到井:" + well.getWellId());

                        return;

                    }

                    log.debug("找到井:" + well.getWellId());

                    GuidePoint guidePoint = new GuidePoint().setLongitude(well.getLongitude()).setLatitude(well.getLatitude());

                    /*获取相机坐标*/

                    ArdCameras cameras = ardCamerasMapper.selectArdCamerasById(cameraId);

                    if (StringUtils.isNull(cameras)) {

                        log.debug("找不到相机:" + cameraId);

                        return;

                    }

                    double[] cameraPositon = new double[3];

                    cameraPositon[0] = cameras.getLongitude();

                    cameraPositon[1] = cameras.getLatitude();

                    cameraPositon[2] = cameras.getAltitude();

                    log.debug("找到相机:" + cameraId);

                    /*控制相机巡检*/

                    CameraCmd cmd = new CameraCmd();

                    cmd.setCameraId(cameraId);

                    cmd.setChanNo(channel);

                    cmd.setTargetPosition(targetPositon);

                    cmd.setTargetPosition(new double[]{guidePoint.getLongitude(), guidePoint.getLatitude()});

                    cmd.setOperator("sys_patrol_inspect");

                    cmd.setExpired(step.getRecordingTime() * 60);

                    boolean setTargetPosition = cameraSdkService.guideTargetPosition(cmd);

                    cmd.setExpired(step.getRecordingTime());//秒为单位

                    boolean setTargetPosition = cameraSdkService.guideTargetPosition(cmd).get("code").equals(200);

                    if (!setTargetPosition) {

                        /*控制失败,当前步骤启动时间置null*/

                        ardVideoInspectTask.setCurrentStepStartTime("");

                        ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(ardVideoInspectTask);

                    } else {

                        log.debug("引导成功!");

                        //region 通知前端

                        Map<String, Object> message = new HashMap<>();

                        Map<String, String> data = new HashMap<>();

                        data.put("cameraId", cmd.getCameraId());

                        data.put("wellId", well.getWellId());

                        data.put("type", ardVideoInspectTask.getInspectMode()+"巡检");

                        message.put("70000", data);

                        WebSocketUtils.sendMessageAll(message);

                        //endregion

                    }

                }

            }

@@ -553,7 +567,7 @@
                cmd.setChanNo(channel);

                cmd.setOperator("sys_patrol_inspect");

                cmd.setRecordBucketName("record");

                cmd.setRecordObjectName("inspectGuide/" + DateUtils.getDateYYYYMMDD()+"/"+ IdUtils.fastSimpleUUID());

                cmd.setRecordObjectName("inspectGuide/" + DateUtils.getDateYYYYMMDD() + "/" + IdUtils.fastSimpleUUID());

                String url = cameraSdkService.recordStopToMinio(cmd);

                /*插入巡检记录*/

                ArdVideoInspectRecord ardVideoInspectRecord = new ArdVideoInspectRecord();

@@ -564,7 +578,7 @@
                    ardVideoInspectRecord.setWellName(ardAlarmpointsWell.getWellId());

                }

                Date currentStepStartDate = DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStartTime);

                Date currentStepStopDate = DateUtils.addMinutes(currentStepStartDate, step.getRecordingTime());

                Date currentStepStopDate = DateUtils.addSeconds(currentStepStartDate, step.getRecordingTime());

                ardVideoInspectRecord.setStartTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStartDate));

                ardVideoInspectRecord.setEndTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStopDate));

                ardVideoInspectRecord.setRecordFilePath(url);

@@ -590,7 +604,7 @@
                ArdVideoInspectTaskStep currentStep = objectOptional.get();

                /*获取到当前步骤的开始和结束时间*/

                Date currentStepStartDate = DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStartTime);

                Date currentStepStopDate = DateUtils.addMinutes(currentStepStartDate, currentStep.getRecordingTime());

                Date currentStepStopDate = DateUtils.addSeconds(currentStepStartDate, currentStep.getRecordingTime());

                /*判断当前步骤时间是否过期*/

                if (!DateUtils.TimeCompare(currentStepStartDate, currentStepStopDate)) {

                    return true;

@@ -657,32 +671,35 @@
    public List getCameraIdleTimeList(String cameraId) {

        LinkedList<String> timeList = new LinkedList();

        List<Map> usedPeriods = this.getTaskUsedCameraPeriods(cameraId);

        for (Map p :

                usedPeriods) {

            timeList.add((String) p.get("start_time"));

            timeList.add((String) p.get("end_time"));

        }

        //判断第一个起始点

        if (timeList.size() > 0) {

            if ("00:00:00".equals(timeList.getFirst())) {

                timeList.removeFirst();

            } else {

                timeList.addFirst("00:00:00");

        //事件段为空,则全天作为一个时间段

        if (usedPeriods.size() == 0) {

            timeList.add("00:00:00");

            timeList.add("23:59:59");

        }else{

            for (Map p :

                    usedPeriods) {

                timeList.add((String) p.get("start_time"));

                timeList.add((String) p.get("end_time"));

            }

            //判断最后一个结束时间

            if ("23:59:59".equals(timeList.getLast())) {

                timeList.removeLast();

            } else {

                timeList.addLast("23:59:59");

            }

            //事件段为空,则全天作为一个时间段

            if (timeList.size() == 0) {

                timeList.add("00:00:00");

                timeList.add("23:59:59");

            }

            //判断第一个起始点

            if (timeList.size() > 0) {

                if ("00:00:00".equals(timeList.getFirst())) {

                    timeList.removeFirst();

                } else {

                    timeList.addFirst("00:00:00");

                }

                //判断最后一个结束时间

                if ("23:59:59".equals(timeList.getLast())) {

                    timeList.removeLast();

                } else {

                    timeList.addLast("23:59:59");

                }





            }

        }





        return timeList;

    }

}