diff --git a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java index c3cb89c8b..23d89a536 100644 --- a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java +++ b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java @@ -138,6 +138,7 @@ public class HikvisionTask { newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetHour(new Date(), -1))); newListMap.put("geBeforeTenMin", 1); List newestList = xzHikvisionSyncService.getNewestList(newListMap); + newestList = newestList.stream().filter(xzHikvisionSync -> Objects.equals(xzHikvisionSync.getIsSuccess(), 0)).collect(Collectors.toList()); for (XzHikvisionSync xzHikvisionSync : newestList) { log.info("海康同步的定时重试失败的记录,id:{}", xzHikvisionSync.getId()); HashMap retryMap = new HashMap<>(16); @@ -166,6 +167,7 @@ public class HikvisionTask { newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetDay(new Date(), -1))); newListMap.put("geBeforeHour", 1); List newestList = xzHikvisionSyncService.getNewestList(newListMap); + newestList = newestList.stream().filter(xzHikvisionSync -> Objects.equals(xzHikvisionSync.getIsSuccess(), 0)).collect(Collectors.toList()); for (XzHikvisionSync xzHikvisionSync : newestList) { log.info("海康同步的定时重试失败的记录,id:{}", xzHikvisionSync.getId()); HashMap retryMap = new HashMap<>(16);