鞍钢鲅鱼圈能源管控系统后端代码
liriming
9 天以前 3eddf4ddac0d6851500b85c77c0b4488a8a6d2c1
同步syncLog表
已修改5个文件
68 ■■■■■ 文件已修改
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncEmsTask.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/dao/SyncLogDao.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/entity/SyncLogEntity.java 19 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/service/SyncLogService.java 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/sync/service/impl/SyncLogServiceImpl.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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);
    }
}