ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java

@@ -70,6 +70,7 @@
            }
            byqlzAdsService.delete(yearMonth);
            while (rs.next()) {
                logger.error("进入循环");
                ByqlzAdsEntity entity = new ByqlzAdsEntity();

                // 映射基础字段
@@ -123,23 +124,15 @@
                entity.setLoadTime(rs.getString("LOAD_TIME"));
                resultList.add(entity);
            }
            resultList.forEach(System.out::println);

            byqlzAdsService.save(resultList);

            syncLogService.save(remark);
            // 输出结果
            resultList.forEach(System.out::println);
            resultList.clear();
        } catch (SQLException e) {
            logger.error("SyncEmsTask运行异常");
            e.printStackTrace();
        }
        logger.info("SyncEmsTask运行完成");
    }

    public static void main(String[] args) {
        SyncEmsTask syncEmsTask = new SyncEmsTask();
        String params = "";
        syncEmsTask.run(params);
    }
}