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

@@ -2,6 +2,7 @@

import com.iailab.module.ansteel.ems.entity.ByqlzAdsEntity;
import com.iailab.module.ansteel.ems.service.ByqlzAdsService;
import com.iailab.module.ansteel.sync.service.SyncLogService;
import com.iailab.module.model.api.mdk.MdkApi;
import com.iailab.module.model.api.mdk.dto.MdkScheduleReqDTO;
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
@@ -30,9 +31,13 @@
    @Autowired
    private ByqlzAdsService byqlzAdsService;

    @Autowired
    private SyncLogService syncLogService;

    @Override
    public void run(String params) {
        logger.info("SyncEmsTask定时任务正在执行，参数为：{}", params);
        String remark = "同步成功";
        List<ByqlzAdsEntity> resultList = new ArrayList<>();
        Calendar cal = Calendar.getInstance();
        String currentDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(cal.getTime());//当前日期
@@ -62,6 +67,9 @@
                if(colCount == 0){
                    pstmt.setString(1, upMonth);
                    rs = pstmt.executeQuery();
                    remark = "上月数据为空，同步上上月数据成功";
                }else{
                    remark = "本月数据为空，同步上月数据成功";
                }
            }
            byqlzAdsService.delete(yearMonth);
@@ -122,6 +130,8 @@
            }

            byqlzAdsService.save(resultList);

            syncLogService.save(remark);
            // 输出结果
            resultList.forEach(System.out::println);