From 3d8cd234989151a86dfca610b7ebcf1dbe1f0875 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期四, 19 六月 2025 16:58:17 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java | 17 +++++++----------
1 files changed, 7 insertions(+), 10 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java
index 253c87d..5a6b846 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java
@@ -57,12 +57,10 @@
// 执行查询并处理结果
ResultSet rs = pstmt.executeQuery();
- boolean colCount = rs.next();
- if(!colCount){
+ if(!rs.isBeforeFirst()){
pstmt.setString(1, lastMonth);
rs = pstmt.executeQuery();
- colCount = rs.next();
- if(!colCount){
+ if(!rs.isBeforeFirst()){
pstmt.setString(1, upMonth);
rs = pstmt.executeQuery();
remark = "上月数据为空，同步上上月数据成功";
@@ -71,7 +69,8 @@
}
}
byqlzAdsService.delete(yearMonth);
- while (colCount) {
+ while (rs.next()) {
+ logger.error("进入循环");
ByqlzAdsEntity entity = new ByqlzAdsEntity();
// 映射基础字段
@@ -125,13 +124,11 @@
entity.setLoadTime(rs.getString("LOAD_TIME"));
resultList.add(entity);
}
-
- byqlzAdsService.save(resultList);
-
- syncLogService.save(remark);
- // 输出结果
resultList.forEach(System.out::println);
+ byqlzAdsService.save(resultList);
+ syncLogService.save(remark);
+ resultList.clear();
} catch (SQLException e) {
logger.error("SyncEmsTask运行异常");
e.printStackTrace();
--
Gitblit v1.9.3