diff --git a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java index 6c830c737..80bc37018 100644 --- a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java +++ b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java @@ -106,6 +106,15 @@ public class HikvisionTask { @Scheduled(cron = "0 0/30 * * * ?") @RequestMapping("deleteLongTask") public void deleteLongTask() throws Exception { + doDeleteLongTask(false); + } + + @RequestMapping("deleteAllTask") + public void deleteAllTask() throws Exception { + doDeleteLongTask(true); + } + + private void doDeleteLongTask(boolean deleteAll) { List projects = projectMapper.selectList(new LambdaQueryWrapper() .eq(Project::getSyncHikvision, 1)); for (Project project : projects) { @@ -115,7 +124,7 @@ public class HikvisionTask { JSONArray listJa = dataJo.getJSONArray("list"); for (int i = 0; i < listJa.size(); i++) { JSONObject jo = listJa.getJSONObject(i); - if (DateUtil.compare(DateUtil.parse(jo.getString("createTime")), DateUtil.offsetMinute(new Date(), -30)) < 0) { + if (deleteAll || DateUtil.compare(DateUtil.parse(jo.getString("createTime")), DateUtil.offsetMinute(new Date(), -30)) < 0) { if (jo.getInteger("taskStatus").equals(1)) { HikvisionUtil.stopTask(project, new JoBuilder().put("taskId", jo.getString("authTaskId")).build()); } else { @@ -128,7 +137,6 @@ public class HikvisionTask { } } - } /**