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); ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/dao/SyncLogDao.java
@@ -1,9 +1,14 @@ package com.iailab.module.ansteel.sync.dao; import com.iailab.framework.common.dao.BaseDao; import com.iailab.module.ansteel.sync.entity.SyncLogEntity; import org.apache.ibatis.annotations.Mapper; /** * @author PanZhibao * @Description * @createTime 2025年06月18日 */ public interface SyncLogDao { @Mapper public interface SyncLogDao extends BaseDao<SyncLogEntity> { } ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/entity/SyncLogEntity.java
@@ -1,9 +1,26 @@ package com.iailab.module.ansteel.sync.entity; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; import java.io.Serializable; import java.util.Date; /** * @author PanZhibao * @Description * @createTime 2025年06月18日 */ public class SyncLogEntity { @Data @TableName("t_sync_log") public class SyncLogEntity implements Serializable { private static final long serialVersionUID = 1L; @TableId(type = IdType.ASSIGN_UUID) private String id; private String tableName; private String remark; private Date createDate; } ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/service/SyncLogService.java
@@ -1,9 +1,11 @@ package com.iailab.module.ansteel.sync.service; /** * @author PanZhibao * @author lirm * @Description * @createTime 2025年06月18日 */ public class SyncLogService { } public interface SyncLogService { void save(String remark); } ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/service/impl/SyncLogServiceImpl.java
@@ -1,9 +1,31 @@ package com.iailab.module.ansteel.sync.service.impl; import com.iailab.module.ansteel.sync.dao.SyncLogDao; import com.iailab.module.ansteel.sync.entity.SyncLogEntity; import com.iailab.module.ansteel.sync.service.SyncLogService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.Date; /** * @author PanZhibao * @Description * @createTime 2025年06月18日 */ public class SyncLogServiceImpl { @Slf4j @Service public class SyncLogServiceImpl implements SyncLogService { @Resource private SyncLogDao syncLogDao; @Override public void save(String remark) { SyncLogEntity syncLogEntity = new SyncLogEntity(); syncLogEntity.setTableName("t_sync_log"); syncLogEntity.setRemark(remark); syncLogEntity.setCreateDate(new Date()); syncLogDao.insert(syncLogEntity); } }