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