From 3682d2980a7f340f131bc7b48434370fc2728411 Mon Sep 17 00:00:00 2001 From: guoshengxiong <1923636941@qq.com> Date: Mon, 17 Nov 2025 10:42:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E6=8E=89=E6=B5=B7=E5=BA=B7=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=E5=AE=9A=E6=97=B6=E9=87=8D=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zhgd/xmgl/task/HikvisionTask.java | 100 +++++++++--------- 1 file changed, 50 insertions(+), 50 deletions(-) diff --git a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java index e93ccf96d..91a9b3db6 100644 --- a/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java +++ b/src/main/java/com/zhgd/xmgl/task/HikvisionTask.java @@ -171,60 +171,60 @@ public class HikvisionTask { /** * 定时重试失败的记录，十分钟一次 */ - @SchedulerLock(name = "retrySyncHikvisionTenMin", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) - @Scheduled(cron = "0 */10 * * * ?") - @RequestMapping("retrySyncHikvisionTenMin") - public void retrySyncHikvisionTenMin() { - try { - HashMap newListMap = new HashMap<>(16); - newListMap.put("isSuccess", 0); - 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); - retryMap.put("id", xzHikvisionSync.getId()); - try { - xzHikvisionSyncService.retry(retryMap); - } catch (Exception e) { - log.error("海康同步的定时重试失败的记录:error:", e); - } - } - } catch (Exception e) { - log.error("定时重试失败的记录，十分钟一次，出现错误" + e); - } - } +// @SchedulerLock(name = "retrySyncHikvisionTenMin", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) +// @Scheduled(cron = "0 */10 * * * ?") +// @RequestMapping("retrySyncHikvisionTenMin") +// public void retrySyncHikvisionTenMin() { +// try { +// HashMap newListMap = new HashMap<>(16); +// newListMap.put("isSuccess", 0); +// 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); +// retryMap.put("id", xzHikvisionSync.getId()); +// try { +// xzHikvisionSyncService.retry(retryMap); +// } catch (Exception e) { +// log.error("海康同步的定时重试失败的记录:error:", e); +// } +// } +// } catch (Exception e) { +// log.error("定时重试失败的记录，十分钟一次，出现错误" + e); +// } +// } /** * 定时重试失败的记录，一小时一次 */ - @SchedulerLock(name = "retrySyncHikvisionHourly", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) - @Scheduled(cron = "0 0 0/1 * * ?") - @RequestMapping("retrySyncHikvisionHourly") - public void retrySyncHikvisionHourly() { - try { - HashMap newListMap = new HashMap<>(16); - newListMap.put("isSuccess", 0); - 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); - retryMap.put("id", xzHikvisionSync.getId()); - try { - xzHikvisionSyncService.retry(retryMap); - } catch (Exception e) { - log.error("海康同步的定时重试失败的记录:error:", e); - } - } - } catch (Exception e) { - log.error("定时重试失败的记录，一小时一次" + e); - } - } +// @SchedulerLock(name = "retrySyncHikvisionHourly", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) +// @Scheduled(cron = "0 0 0/1 * * ?") +// @RequestMapping("retrySyncHikvisionHourly") +// public void retrySyncHikvisionHourly() { +// try { +// HashMap newListMap = new HashMap<>(16); +// newListMap.put("isSuccess", 0); +// 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); +// retryMap.put("id", xzHikvisionSync.getId()); +// try { +// xzHikvisionSyncService.retry(retryMap); +// } catch (Exception e) { +// log.error("海康同步的定时重试失败的记录:error:", e); +// } +// } +// } catch (Exception e) { +// log.error("定时重试失败的记录，一小时一次" + e); +// } +// } /**