同步日报

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

对比新文件
@@ -0,0 +1,94 @@
package com.iailab.module.ansteel.job.task;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.framework.common.util.http.HttpUtils;
import com.iailab.module.ansteel.report.entity.DutyReportEntity;
import com.iailab.module.ansteel.report.service.DutyReportService;
import com.iailab.module.data.api.point.DataPointApi;
import com.iailab.module.data.api.point.dto.ApiPointValueWriteDTO;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.math.BigDecimal;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月13日
 */
@Component("syncDutyReportTask")
public class SyncDutyReportTask implements ITask {
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private DutyReportService dutyReportService;

    @Autowired
    private DataPointApi dataPointApi;

    private final static String URL = "http://10.50.37.1:8806/batch/xxb/getDutyReportData";

    @Override
    public void run(String params) {
        logger.info("SyncDutyReportTask定时任务正在执行，参数为：{}", params);
        try {
            String date = params;
            if (StringUtils.isBlank(date)) {
                Calendar calendar = Calendar.getInstance();
                calendar.set(Calendar.MILLISECOND, 0);
                calendar.set(Calendar.MINUTE, 0);
                calendar.add(Calendar.DAY_OF_YEAR, -1);
                date = DateUtils.format(calendar.getTime(), "yyyy-MM-dd");
            }
            Map<String, Object> queryMap = new HashMap<String, Object>();
            queryMap.put("date", date);
            String responseStr = HttpUtils.sendPost(URL, JSONObject.toJSONString(queryMap));
            if (StringUtils.isBlank(responseStr)) {
                logger.info("responseStr is null");
                return;
            }
            Map<String, BigDecimal> dataMap1 = new HashMap<>();
            Map<String, BigDecimal> dataMap2 = new HashMap<>();
            JSONArray jsonArray = JSONArray.parseArray(responseStr);
            for (int i = 0; i < jsonArray.size(); i++) {
                JSONObject jsonObject = jsonArray.getJSONObject(i);
                dataMap1.put(jsonObject.getString("cdeIndex"), new BigDecimal(jsonObject.get("valAct").toString()));
                dataMap2.put(jsonObject.getString("cdeIndex"), new BigDecimal(jsonObject.get("monthAvgValue").toString()));
            }

            List<DutyReportEntity> list = dutyReportService.list();
            if (CollectionUtils.isEmpty(list)) {
                logger.info("DutyReportEntity list is empty");
                return;
            }
            for (DutyReportEntity dutyReportEntity : list) {
                if (dataMap1.get(dutyReportEntity.getCdeIndex()) != null) {
                    ApiPointValueWriteDTO writeDTO = new ApiPointValueWriteDTO();
                    writeDTO.setPointNo(dutyReportEntity.getPointNo1());
                    writeDTO.setValue(dataMap1.get(dutyReportEntity.getCdeIndex()));
                    dataPointApi.writePointRealValue(writeDTO);
                }
                if (dataMap2.get(dutyReportEntity.getCdeIndex()) != null) {
                    ApiPointValueWriteDTO writeDTO = new ApiPointValueWriteDTO();
                    writeDTO.setPointNo(dutyReportEntity.getPointNo2());
                    writeDTO.setValue(dataMap2.get(dutyReportEntity.getCdeIndex()));
                    dataPointApi.writePointRealValue(writeDTO);
                }
            }
        } catch (Exception ex) {
            logger.error("SyncDutyReportTask运行异常");
            ex.printStackTrace();
        }
        logger.info("SyncDutyReportTask运行完成");
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/report/dao/DutyReportDao.java

对比新文件
@@ -0,0 +1,14 @@
package com.iailab.module.ansteel.report.dao;

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.module.ansteel.report.entity.DutyReportEntity;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月13日
 */
@Mapper
public interface DutyReportDao extends BaseDao<DutyReportEntity> {
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/report/entity/DutyReportEntity.java

对比新文件
@@ -0,0 +1,36 @@
package com.iailab.module.ansteel.report.entity;

import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.io.Serializable;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月13日
 */
@Data
@TableName("t_xxb_duty_report")
public class DutyReportEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * id
     */
    @TableId
    private String id;

    private String cdeIndex;

    private String nameIndex;

    private String pointNo1;

    private String pointNo2;

    private String pointNo3;

    private Integer sort;
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/report/package-info.java

对比新文件
@@ -0,0 +1 @@
package com.iailab.module.ansteel.report;

 ansteel-biz/src/main/java/com/iailab/module/ansteel/report/service/DutyReportService.java

对比新文件
@@ -0,0 +1,15 @@
package com.iailab.module.ansteel.report.service;

import com.iailab.module.ansteel.report.entity.DutyReportEntity;

import java.util.List;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月13日
 */
public interface DutyReportService {

    List<DutyReportEntity> list();
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/report/service/impl/DutyReportServiceImpl.java

对比新文件
@@ -0,0 +1,31 @@
package com.iailab.module.ansteel.report.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.module.ansteel.report.dao.DutyReportDao;
import com.iailab.module.ansteel.report.entity.DutyReportEntity;
import com.iailab.module.ansteel.report.service.DutyReportService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月13日
 */
@Slf4j
@Service
public class DutyReportServiceImpl implements DutyReportService {

    @Autowired
    private DutyReportDao dutyReportDao;

    @Override
    public List<DutyReportEntity> list() {
        QueryWrapper<DutyReportEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.orderByAsc("sort");
        return dutyReportDao.selectList(queryWrapper);
    }
}