From ab00d30e72fea3b9cb33dc065861e92e5d0eeb14 Mon Sep 17 00:00:00 2001 From: aijinhui <aijinhui> Date: 星期六, 21 十月 2023 14:09:09 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java | 13 +++++++------ 1 files changed, 7 insertions(+), 6 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java index b4b12e0..dfce1a1 100644 --- a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java +++ b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueTaskExecutor.java @@ -15,7 +15,7 @@ import com.ruoyi.alarm.tube.service.IArdAlarmTubeService; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.device.camera.domain.CameraCmd; -import com.ruoyi.device.hiksdk.service.IHikClientService; +import com.ruoyi.device.camera.service.ICameraSdkService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; @@ -39,7 +39,7 @@ @Resource IArdAlarmRadarPumpService ardAlarmRadarPumpService; @Resource - IHikClientService hikClientService; + ICameraSdkService cameraSdkService; @Resource IArdAlarmTubeService ardAlarmTubeService; @@ -47,6 +47,7 @@ IArdAlarmExternalService ardAlarmExternalService; @Resource IArdAlarmAccessService ardAlarmAccessService; + public void processTask(GuideTask guideTask) { try { CameraCmd cmd = new CameraCmd(); @@ -58,17 +59,17 @@ cmd.setRecordBucketName("record"); cmd.setRecordObjectName("alarm_" + guideTask.getAlarmId()); log.debug("寮�濮嬪紩瀵�"); - boolean guideRes = hikClientService.guideTargetPosition(cmd); + boolean guideRes = cameraSdkService.guideTargetPosition(cmd); if (guideRes) { log.debug("寮曞鎴愬姛"); - hikClientService.controlLock(cmd);//涓婇攣 - hikClientService.recordStart(cmd);//寮�濮嬪綍鍍� + cameraSdkService.controlLock(cmd);//涓婇攣 + cameraSdkService.recordStart(cmd);//寮�濮嬪綍鍍� try { Thread.sleep(30000); } catch (InterruptedException e) { log.info("褰撳墠浠诲姟ID" + guideTask.getAlarmId() + "绾跨▼琚粓姝�"); } - String url = hikClientService.recordStopToMinio(cmd);//鍋滄褰曞儚杩斿洖url + String url = cameraSdkService.recordStopToMinio(cmd);//鍋滄褰曞儚杩斿洖url if (StringUtils.isNotEmpty(url)) { switch (guideTask.getAlarmType()) { case "sys_tube_leak": -- Gitblit v1.9.3