From 20f84e1b1e20dca7b52d5c2213fd0fe1198b7b28 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期一, 05 六月 2023 12:05:49 +0800
Subject: [PATCH] 巡检记录增加wellName字段

---
 ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java |   69 +++++++++++++++++++---------------
 1 files changed, 39 insertions(+), 30 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java b/ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java
index f482870..11c9de2 100644
--- a/ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/inspect/service/impl/ArdVideoInspectTaskServiceImpl.java
@@ -2,6 +2,7 @@
 
 import java.text.SimpleDateFormat;
 import java.util.*;
+
 import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
 import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
 import com.ruoyi.common.utils.DateUtils;
@@ -60,7 +61,7 @@
             }
             ardVideoInspectTask.setCurrentStepId("");
             ardVideoInspectTask.setCurrentStepStartTime("");
-            ardVideoInspectTaskMapper.updateArdVideoInspectTask(ardVideoInspectTask);
+            ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(ardVideoInspectTask);
         }
     }
 
@@ -115,7 +116,7 @@
         ardVideoInspectTask.setUpdateBy(SecurityUtils.getUsername());
         ardVideoInspectTask.setUpdateTime(DateUtils.getNowDate());
         //  ardVideoInspectTaskMapper.deleteArdVideoInspectTaskStepByTaskId(ardVideoInspectTask.getId());
-       // insertArdVideoInspectTaskStep(ardVideoInspectTask);
+        insertArdVideoInspectTaskStep(ardVideoInspectTask);
         return ardVideoInspectTaskMapper.updateArdVideoInspectTask(ardVideoInspectTask);
     }
 
@@ -193,8 +194,7 @@
     public void manualTaskRun(String TaskId) {
         try {
             ArdVideoInspectTask videoInspectTask = ardVideoInspectTaskMapper.selectArdVideoInspectTaskById(TaskId);
-            if(!videoInspectTask.getMenualSwitch().equals("寮�"))
-            {
+            if (!videoInspectTask.getMenualSwitch().equals("寮�")) {
                 return;
             }
             if (videoInspectTask.getArdVideoInspectTaskStepList().size() == 0) {
@@ -308,6 +308,7 @@
                         continue;
                     }
                     videoInspectTask.setArdVideoInspectTaskStepList(ardVideoInspectTaskStepList);
+
                     String currentStepId = videoInspectTask.getCurrentStepId();
                     String currentStepStartTime = videoInspectTask.getCurrentStepStartTime();
                     if (StringUtils.isNull(currentStepId) || StringUtils.isEmpty(currentStepId)) {
@@ -333,29 +334,30 @@
                         }
                     }
                 } else {
-                    if(Global.task_record.contains(videoInspectTask.getId()))
-                    {
-                        /*鍋滄褰曞儚*/
-                        CameraCmd cmd = new CameraCmd();
-                        cmd.setCameraId(videoInspectTask.getCameraId());
-                        cmd.setChannelNum(videoInspectTask.getChannel());
-                        cmd.setOperator("sys_patrol_inspect");
-                        cmd.setEnable(false);//鍋滄褰曞儚
-                        String uuid = UUID.randomUUID().toString().replace("-", "");
-                        String time = new SimpleDateFormat("yyyyMMdd").format(new Date());
-                        String recordName = videoInspectTask.getCameraId() + "/" + time + "/" + uuid + ".mp4";
-                        cmd.setRecordBucketName("record");
-                        cmd.setRecordObjectName(recordName);
-                        cmd.setUploadMinio(true);
-                        hikClientService.recordToMinio(cmd);
+//                    if(Global.task_record.contains(videoInspectTask.getId()))
+//                    {
+//                        /*鍋滄褰曞儚*/
+//                        CameraCmd cmd = new CameraCmd();
+//                        cmd.setCameraId(videoInspectTask.getCameraId());
+//                        cmd.setChannelNum(videoInspectTask.getChannel());
+//                        cmd.setOperator("sys_patrol_inspect");
+//                        cmd.setEnable(false);//鍋滄褰曞儚
+//                        String uuid = UUID.randomUUID().toString().replace("-", "");
+//                        String time = new SimpleDateFormat("yyyyMMdd").format(new Date());
+//                        String recordName = videoInspectTask.getCameraId() + "/" + time + "/" + uuid + ".mp4";
+//                        cmd.setRecordBucketName("record");
+//                        cmd.setRecordObjectName(recordName);
+//                        cmd.setUploadMinio(true);
+//                        hikClientService.recordToMinio(cmd);
+//                    }
+                    if (StringUtils.isNotEmpty(videoInspectTask.getCurrentStepId())) {
+                        videoInspectTask.setCurrentStepId("");
+                        ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(videoInspectTask);
                     }
-                    if (StringUtils.isEmpty(videoInspectTask.getCurrentStepId()) || StringUtils.isEmpty(videoInspectTask.getCurrentStepStartTime())) {
-                        continue;
+                    if (StringUtils.isNotEmpty(videoInspectTask.getCurrentStepStartTime())) {
+                        videoInspectTask.setCurrentStepId("");
+                        ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(videoInspectTask);
                     }
-                    /*杩囨湡鐨勪换鍔℃竻绌哄綋鍓嶆楠や俊鎭�*/
-                    videoInspectTask.setCurrentStepId("");
-                    videoInspectTask.setCurrentStepStartTime("");
-                    ardVideoInspectTaskMapper.updateArdVideoInspectTask(videoInspectTask);
                 }
             }
         } catch (Exception ex) {
@@ -432,7 +434,7 @@
                 /*鏇存柊浠诲姟褰撳墠姝ラid鍜屾楠ゅ惎鍔ㄦ椂闂�*/
                 ardVideoInspectTask.setCurrentStepId(step.getId());
                 ardVideoInspectTask.setCurrentStepStartTime(DateUtils.getTime());
-                ardVideoInspectTaskMapper.updateArdVideoInspectTask(ardVideoInspectTask);
+                ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(ardVideoInspectTask);
                 String wellId = step.getWellId();
                 if (!StringUtils.isNull(wellId)) {
                     /*鑾峰彇浜曞潗鏍�*/
@@ -457,8 +459,7 @@
                     cmd.setExpired(step.getRecordingTime());
                     boolean setTargetPosition = hikClientService.setTargetPosition(cmd);
                     if (setTargetPosition) {
-                        if(!Global.task_record.contains(ardVideoInspectTask.getId()))
-                        {
+                        if (!Global.task_record.contains(ardVideoInspectTask.getId())) {
                             /*鎺у埗鐩告満宸℃鎴愬姛锛屽紑濮嬪綍鍍�*/
                             cmd.setEnable(true);//鍚姩褰曞儚
                             hikClientService.recordToMinio(cmd);
@@ -470,7 +471,7 @@
                         hikClientService.recordToMinio(cmd);
                         /*鎺у埗澶辫触,褰撳墠姝ラ鍚姩鏃堕棿缃畁ull*/
                         ardVideoInspectTask.setCurrentStepStartTime("");
-                        ardVideoInspectTaskMapper.updateArdVideoInspectTask(ardVideoInspectTask);
+                        ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(ardVideoInspectTask);
                     }
                 }
             }
@@ -478,6 +479,7 @@
             log.error("宸℃寮�濮嬪紓甯革細" + ex.getMessage());
         }
     }
+
     //姝ラ鍋滄
     private void stopRunStep(ArdVideoInspectTask ardVideoInspectTask) {
         try {
@@ -512,6 +514,11 @@
                 /*鎻掑叆宸℃璁板綍*/
                 ArdVideoInspectRecord ardVideoInspectRecord = new ArdVideoInspectRecord();
                 ardVideoInspectRecord.setStepId(step.getId());
+                ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellById(step.getWellId());
+                if(StringUtils.isNotNull(ardAlarmpointsWell))
+                {
+                    ardVideoInspectRecord.setWellName(ardAlarmpointsWell.getWellId());
+                }
                 Date currentStepStartDate = DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStartTime);
                 Date currentStepStopDate = DateUtils.addMinutes(currentStepStartDate, step.getRecordingTime());
                 ardVideoInspectRecord.setStartTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, currentStepStartDate));
@@ -524,6 +531,7 @@
             log.error("宸℃鍋滄寮傚父:" + ex.getMessage());
         }
     }
+
     //姝ラ鍒ゆ柇鏄惁杩囨湡
     private boolean isExpirdStep(ArdVideoInspectTask ardVideoInspectTask) {
         try {
@@ -554,6 +562,7 @@
             return false;
         }
     }
+
     //姝ラ鍒囨崲
     private String changeNextStep(ArdVideoInspectTask ardVideoInspectTask) {
         try {
@@ -582,7 +591,7 @@
                         .findFirst()
                         .orElse(null);
                 avit.setCurrentStepId(nextStepId);
-                ardVideoInspectTaskMapper.updateArdVideoInspectTask(avit);
+                ardVideoInspectTaskMapper.updateArdVideoInspectTaskWithCurrentSetpInfo(avit);
                 log.info("姝ラ锛�" + currentStepId + "鍒囨崲涓�" + nextStepId);
                 return nextStepId;
             }

--
Gitblit v1.9.3