syncEmsTask修改

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

@@ -57,12 +57,10 @@

            // 执行查询并处理结果
            ResultSet rs = pstmt.executeQuery();
            boolean colCount = rs.next();
            if(!colCount){
            if(!rs.isBeforeFirst()){
                pstmt.setString(1, lastMonth);
                rs = pstmt.executeQuery();
                colCount =  rs.next();
                if(!colCount){
                if(!rs.isBeforeFirst()){
                    pstmt.setString(1, upMonth);
                    rs = pstmt.executeQuery();
                    remark = "上月数据为空，同步上上月数据成功";
@@ -71,7 +69,7 @@
                }
            }
            byqlzAdsService.delete(yearMonth);
            while (colCount) {
            while (rs.next()) {
                ByqlzAdsEntity entity = new ByqlzAdsEntity();

                // 映射基础字段
@@ -131,11 +129,17 @@
            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);
    }
}