From d85a066201e3ea9bafcff1028f4b9af7823eb6b1 Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期四, 19 六月 2025 13:40:02 +0800
Subject: [PATCH] syncEmsTask修改
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java | 13 ++-----------
1 files changed, 2 insertions(+), 11 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 e0a8623..623c76e 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,11 +57,9 @@
// 执行查询并处理结果
ResultSet rs = pstmt.executeQuery();
- ResultSetMetaData meta = rs.getMetaData();
boolean colCount = rs.next();
if(!colCount){
pstmt.setString(1, lastMonth);
- meta = rs.getMetaData();
rs = pstmt.executeQuery();
colCount = rs.next();
if(!colCount){
@@ -73,8 +71,7 @@
}
}
byqlzAdsService.delete(yearMonth);
-
- while (rs.next()) {
+ while (colCount) {
ByqlzAdsEntity entity = new ByqlzAdsEntity();
// 映射基础字段
@@ -125,7 +122,7 @@
}
}
- entity.setLoadTime(currentDate);
+ entity.setLoadTime(rs.getString("LOAD_TIME"));
resultList.add(entity);
}
@@ -140,11 +137,5 @@
e.printStackTrace();
}
logger.info("SyncEmsTask运行完成");
- }
-
- public static void main(String[] args) {
- SyncEmsTask task = new SyncEmsTask();
- String params = "";
- task.run(params);
}
}
--
Gitblit v1.9.3