From 3eddf4ddac0d6851500b85c77c0b4488a8a6d2c1 Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期四, 19 六月 2025 09:37:44 +0800
Subject: [PATCH] 同步syncLog表
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java | 10 ++++++++++
1 files changed, 10 insertions(+), 0 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java
index 09522e2..f76e3a8 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java
+++ b/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);
--
Gitblit v1.9.3