From b47f7ee10276f79015a21b36bf53c96c3dfc8203 Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期四, 19 六月 2025 11:20:29 +0800
Subject: [PATCH] syncEmsTask修改
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java | 14 ++++++++++----
1 files changed, 10 insertions(+), 4 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 f76e3a8..e0a8623 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
@@ -58,13 +58,13 @@
// 执行查询并处理结果
ResultSet rs = pstmt.executeQuery();
ResultSetMetaData meta = rs.getMetaData();
- int colCount = meta.getColumnCount();
- if(colCount == 0){
+ boolean colCount = rs.next();
+ if(!colCount){
pstmt.setString(1, lastMonth);
meta = rs.getMetaData();
rs = pstmt.executeQuery();
- colCount = meta.getColumnCount();
- if(colCount == 0){
+ colCount = rs.next();
+ if(!colCount){
pstmt.setString(1, upMonth);
rs = pstmt.executeQuery();
remark = "上月数据为空，同步上上月数据成功";
@@ -141,4 +141,10 @@
}
logger.info("SyncEmsTask运行完成");
}
+
+ public static void main(String[] args) {
+ SyncEmsTask task = new SyncEmsTask();
+ String params = "";
+ task.run(params);
+ }
}
--
Gitblit v1.9.3