From eabbe172b74f5717cad0d1484ee2ec59b8914aa7 Mon Sep 17 00:00:00 2001 From: guoshengxiong <1923636941@qq.com> Date: Wed, 24 Jul 2024 19:39:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E9=87=8D=E8=AF=95=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=E7=9A=84=E8=AE=B0=E5=BD=95=E6=97=B6=E9=97=B4=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/zhgd/xmgl/task/HikvisionTask.java | 2 ++ 1 file changed, 2 insertions(+) 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);