syncEmsTask修改

 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);
    }
}