admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

定时重试失败的记录时间修改

Browse Source
This commit is contained in:
guoshengxiong 2024-07-25 16:34:38 +08:00
parent b2513eb68e
commit da9ca5f7e2
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/zhgd/xmgl/task/HikvisionTask.java
View File

@ -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<Project> projects = projectMapper.selectList(new LambdaQueryWrapper<Project>()
.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 {
}
}
}
/**