鞍钢鲅鱼圈能源管控系统后端代码
潘志宝
9 天以前 3d8cd234989151a86dfca610b7ebcf1dbe1f0875
Merge remote-tracking branch 'origin/master'
已修改1个文件
17 ■■■■■ 文件已修改
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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,8 @@
                }
            }
            byqlzAdsService.delete(yearMonth);
            while (colCount) {
            while (rs.next()) {
                logger.error("进入循环");
                ByqlzAdsEntity entity = new ByqlzAdsEntity();
                // 映射基础字段
@@ -125,13 +124,11 @@
                entity.setLoadTime(rs.getString("LOAD_TIME"));
                resultList.add(entity);
            }
            byqlzAdsService.save(resultList);
            syncLogService.save(remark);
            // 输出结果
            resultList.forEach(System.out::println);
            byqlzAdsService.save(resultList);
            syncLogService.save(remark);
            resultList.clear();
        } catch (SQLException e) {
            logger.error("SyncEmsTask运行异常");
            e.printStackTrace();