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:14:06 +08:00
parent 7846943f93
commit dbdb7145c3
1 changed files with 37 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -131,21 +131,25 @@ public class HikvisionTask {
@SchedulerLock(name = "retrySyncHikvisionTenMin", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) @SchedulerLock(name = "retrySyncHikvisionTenMin", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30)
@Scheduled(cron = "0 */10 * * * ?") @Scheduled(cron = "0 */10 * * * ?")
@RequestMapping("retrySyncHikvisionTenMin") @RequestMapping("retrySyncHikvisionTenMin")
public void retrySyncHikvisionTenMin() throws Exception { public void retrySyncHikvisionTenMin() {
HashMap<String, Object> newListMap = new HashMap<>(16); try {
newListMap.put("isSuccess", 0); HashMap<String, Object> newListMap = new HashMap<>(16);
newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetHour(new Date(), -1))); newListMap.put("isSuccess", 0);
newListMap.put("geBeforeTenMin", 1); newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetHour(new Date(), -1)));
List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap); newListMap.put("geBeforeTenMin", 1);
for (XzHikvisionSync xzHikvisionSync : newestList) { List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap);
log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId()); for (XzHikvisionSync xzHikvisionSync : newestList) {
HashMap<String, Object> retryMap = new HashMap<>(16); log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId());
retryMap.put("id", xzHikvisionSync.getId()); HashMap<String, Object> retryMap = new HashMap<>(16);
try { retryMap.put("id", xzHikvisionSync.getId());
xzHikvisionSyncService.retry(retryMap); try {
} catch (Exception e) { xzHikvisionSyncService.retry(retryMap);
log.error("海康同步的定时重试失败的记录:error:", e); } catch (Exception e) {
log.error("海康同步的定时重试失败的记录:error:", e);
}
} }
} catch (Exception e) {
log.error("定时重试失败的记录，十分钟一次，出现错误" + e);
} }
} }
@ -153,23 +157,27 @@ public class HikvisionTask {
* 定时重试失败的记录，一小时一次 * 定时重试失败的记录，一小时一次
*/ */
@SchedulerLock(name = "retrySyncHikvisionHourly", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30) @SchedulerLock(name = "retrySyncHikvisionHourly", lockAtMostFor = 1000 * 30, lockAtLeastFor = 1000 * 30)
@Scheduled(cron = "0 */10 * * * ?") @Scheduled(cron = "0 0 0/1 * * ?")
@RequestMapping("retrySyncHikvisionHourly") @RequestMapping("retrySyncHikvisionHourly")
public void retrySyncHikvisionHourly() throws Exception { public void retrySyncHikvisionHourly() {
HashMap<String, Object> newListMap = new HashMap<>(16); try {
newListMap.put("isSuccess", 0); HashMap<String, Object> newListMap = new HashMap<>(16);
newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetDay(new Date(), -1))); newListMap.put("isSuccess", 0);
newListMap.put("geBeforeHour", 1); newListMap.put("createDateBegin", DateUtil.formatDateTime(DateUtil.offsetDay(new Date(), -1)));
List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap); newListMap.put("geBeforeHour", 1);
for (XzHikvisionSync xzHikvisionSync : newestList) { List<XzHikvisionSync> newestList = xzHikvisionSyncService.getNewestList(newListMap);
log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId()); for (XzHikvisionSync xzHikvisionSync : newestList) {
HashMap<String, Object> retryMap = new HashMap<>(16); log.info("海康同步的定时重试失败的记录，id:{}", xzHikvisionSync.getId());
retryMap.put("id", xzHikvisionSync.getId()); HashMap<String, Object> retryMap = new HashMap<>(16);
try { retryMap.put("id", xzHikvisionSync.getId());
xzHikvisionSyncService.retry(retryMap); try {
} catch (Exception e) { xzHikvisionSyncService.retry(retryMap);
log.error("海康同步的定时重试失败的记录:error:", e); } catch (Exception e) {
log.error("海康同步的定时重试失败的记录:error:", e);
}
} }
} catch (Exception e) {
log.error("定时重试失败的记录，一小时一次" + e);
} }
} }