From 1cad14bca191807e18705c3a5526eda8151be439 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期一, 14 四月 2025 23:10:22 +0800
Subject: [PATCH] 批量审核和图片保存bug
---
ycl-platform/src/main/java/com/ycl/task/SynchronizeDHAlarm.java | 49 ++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 48 insertions(+), 1 deletions(-)
diff --git a/ycl-platform/src/main/java/com/ycl/task/SynchronizeDHAlarm.java b/ycl-platform/src/main/java/com/ycl/task/SynchronizeDHAlarm.java
index 7ad52dd..9f42306 100644
--- a/ycl-platform/src/main/java/com/ycl/task/SynchronizeDHAlarm.java
+++ b/ycl-platform/src/main/java/com/ycl/task/SynchronizeDHAlarm.java
@@ -1,12 +1,16 @@
package com.ycl.task;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ycl.common.constant.GlobalQueue;
import com.ycl.entity.video.VideoAlarmReport;
import com.ycl.entity.video.VideoPoint;
+import com.ycl.service.caseHandler.IBaseCaseService;
import com.ycl.service.caseHandler.IViolationsService;
import com.ycl.service.oss.OssService;
+import com.ycl.service.resources.IImageResourcesService;
import com.ycl.service.video.IVideoAlarmReportService;
import com.ycl.service.video.impl.IVideoPointService;
+import com.ycl.vo.casePool.BaseCaseVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -14,6 +18,9 @@
import java.io.ByteArrayInputStream;
import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
@@ -31,6 +38,12 @@
@Autowired
private IViolationsService violationsService;
+
+ @Autowired
+ private IBaseCaseService baseCaseService;
+
+ @Autowired
+ private IImageResourcesService imageService;
@Scheduled(cron = "0 */1 * * * ?")
@Transactional(rollbackFor = Exception.class)
@@ -51,7 +64,7 @@
if (videoAlarmReport.getPicByte() != null) {
String extension = "jpg";
InputStream inputStream = new ByteArrayInputStream(videoAlarmReport.getPicByte());
- String picData = ossService.uploadImages(inputStream, extension);
+ String picData = ossService.uploadImages(inputStream, extension, 0);
videoAlarmReport.setPicData(picData);
}
@@ -68,4 +81,38 @@
}
}
}
+
+
+ @Scheduled(cron = "0 0 0 * * ?")
+// @Transactional(rollbackFor = Exception.class)
+ public void deleteAlarmTask() {
+ System.out.println("----------------鎵ц娓呴櫎鏁版嵁浠诲姟:");
+ int i = 1;
+ while (true) {
+ String beginTime = "2020-01-01 00:00:00";
+ String endTime = LocalDateTime.now().plusDays(-3).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+ Page<BaseCaseVO> page = baseCaseService.selectVideoInspection(i, 10, null, null, beginTime, endTime, null);
+
+ System.out.println("----------------娓呴櫎鏁版嵁浠诲姟鎬绘潯鏁�:" + page.getTotal());
+ if (page.getRecords().size() > 0) {
+ page.getRecords().forEach(baseCaseVO -> {
+ String picData = baseCaseVO.getPicData();
+ String[] urls = picData.split(",");
+ for (String url : urls) {
+ ossService.deleteImages(url);
+ }
+
+ baseCaseService.removeById(baseCaseVO.getBaseId());
+ violationsService.removeById(baseCaseVO.getBaseId());
+
+ imageService.removeById(baseCaseVO.getImageId());
+
+ System.out.println("----------------娓呴櫎鏁版嵁鏁版嵁鎴愬姛锛宨d:" + baseCaseVO.getBaseId());
+ });
+ } else {
+ break;
+ }
+ i++;
+ }
+ }
}
--
Gitblit v1.8.0