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

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

Browse Source
This commit is contained in:
guoshengxiong 2024-07-24 19:39:30 +08:00
parent dbdb7145c3
commit eabbe172b7
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -138,6 +138,7 @@ public class HikvisionTask {
newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetHour(new Date(), -1))); newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetHour(new Date(), -1)));
newListMap.put("geBeforeTenMin", 1); newListMap.put("geBeforeTenMin", 1);
List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap); List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap);
newestList = newestList.stream().filter(xzHikvisionSync -> Objects.equals(xzHikvisionSync.getIsSuccess(), 0)).collect(Collectors.toList());
for (XzHikvisionSync xzHikvisionSync : newestList) { for (XzHikvisionSync xzHikvisionSync : newestList) {
log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId()); log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId());
HashMap<String, Object> retryMap = new HashMap<>(16); HashMap<String, Object> retryMap = new HashMap<>(16);
@ -166,6 +167,7 @@ public class HikvisionTask {
newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetDay(new Date(), -1))); newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetDay(new Date(), -1)));
newListMap.put("geBeforeHour", 1); newListMap.put("geBeforeHour", 1);
List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap); List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap);
newestList = newestList.stream().filter(xzHikvisionSync -> Objects.equals(xzHikvisionSync.getIsSuccess(), 0)).collect(Collectors.toList());
for (XzHikvisionSync xzHikvisionSync : newestList) { for (XzHikvisionSync xzHikvisionSync : newestList) {
log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId()); log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId());
HashMap<String, Object> retryMap = new HashMap<>(16); HashMap<String, Object> retryMap = new HashMap<>(16);