From f17a48a0e3d7531b240a89755e7b7e7e2248ccb2 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期三, 11 十月 2023 15:15:54 +0800
Subject: [PATCH] fix(quartz): 1.增加超时重试机制2.数据条数不统一时删除拉取到的数据
---
src/main/java/com/integrated/zyyt/service/ZyytService.java | 11 +++--------
1 files changed, 3 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/integrated/zyyt/service/ZyytService.java b/src/main/java/com/integrated/zyyt/service/ZyytService.java
index a6286f0..0cd5983 100644
--- a/src/main/java/com/integrated/zyyt/service/ZyytService.java
+++ b/src/main/java/com/integrated/zyyt/service/ZyytService.java
@@ -263,7 +263,7 @@
continue;
}
List<YyztTShkdrb> yyztTShkdrbs = stationInfoList.subList(fromIndex, toIndex);
- try {
+
List<Object[]> insertShkdrbList = new ArrayList<>();
yyztTShkdrbs.forEach(item -> {
insertShkdrbList.add(new Object[]{
@@ -317,17 +317,11 @@
batchNo});
});
jdbcTemplate.batchUpdate(batchInsertSql, insertShkdrbList);
- } catch (Exception e) {
- log.error(e.getMessage());
- //鎵嬪伐鍥炴粴寮傚父
-// TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
- stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
- return;
- }
}
}
} catch (Exception e) {
log.error(e.getMessage());
+ jdbcTemplate.update(delSql);
stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
return;
}
@@ -430,6 +424,7 @@
log.error(e.getMessage());
//鎵嬪伐鍥炴粴寮傚父
// TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
+ jdbcTemplate.update(delSql);
stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
return;
}
--
Gitblit v1.9.1