From 460eb8108ddba02f4dfde9e22ba33c7d4888b602 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期四, 19 六月 2025 14:12:55 +0800
Subject: [PATCH] Merge branch 'master' of http://dlindusit.com:53929/r/ansteel

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java |   23 +++++++----------------
 1 files changed, 7 insertions(+), 16 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..253c87d 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();
 
                 // 映射基础字段
@@ -100,11 +97,11 @@
                         case 7: entity.setVal7(val); break;
                         case 8: entity.setVal8(val); break;
                         case 9: entity.setVal9(val); break;
-                        case 10: entity.setVal11(val); break;
-                        case 11: entity.setVal12(val); break;
-                        case 12: entity.setVal13(val); break;
-                        case 13: entity.setVal14(val); break;
-                        case 14: entity.setVal2(val); break;
+                        case 10: entity.setVal10(val); break;
+                        case 11: entity.setVal11(val); break;
+                        case 12: entity.setVal12(val); break;
+                        case 13: entity.setVal13(val); break;
+                        case 14: entity.setVal14(val); break;
                         case 15: entity.setVal15(val); break;
                         case 16: entity.setVal16(val); break;
                         case 17: entity.setVal17(val); break;
@@ -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