清理旧数据 ind

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java

@@ -15,4 +15,6 @@
    List<CokingAnalyIndEntity> list(Map<String, Object> params);

    void save(List<CokingAnalyIndEntity> entityList);

    void delete(String analyType, String analyDate, String analyClass);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceChartService.java

@@ -16,6 +16,7 @@
    List<CokingTraceChartEntity> list(Map<String, Object> params);

    void save(CokingTraceChartEntity cokingTraceChartEntity);

    void insert(List<CokingTraceChartEntity> list);

    void save(String relId, String clock, String indType, Date startDate, Date endDate);

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java

@@ -39,4 +39,15 @@
    public void save(List<CokingAnalyIndEntity> entityList) {
        cokingAnalyIndDao.insert(entityList);
    }

    @Override
    public void delete(String analyType, String analyDate, String analyClass) {
        QueryWrapper<CokingAnalyIndEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("analy_type", analyType)
                .eq("analy_date", analyDate)
                .eq("analy_class", analyClass);
        cokingAnalyIndDao.delete(queryWrapper);


    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceChartServiceImpl.java

@@ -6,6 +6,7 @@
import com.iailab.module.ansteel.coking.entity.CokingTraceConfEntity;
import com.iailab.module.ansteel.coking.service.CokingTraceChartService;
import com.iailab.module.ansteel.coking.service.CokingTraceConfService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
@@ -18,6 +19,7 @@
 * @author lirm ${email}
 * @since 1.0.0 2025-04-16
 */
@Slf4j
@Service
public class CokingTraceChartServiceImpl implements CokingTraceChartService {

@@ -47,7 +49,7 @@

    @Override
    public void save(String relId, String clock, String indType, Date startDate, Date endDate) {
        // 查询需要保存chart的配置
        log.info("查询需要保存chart的配置");
        Map<String, Object> map = new HashMap<>();
        map.put("indType", indType);
        map.put("ext1", "chart");
@@ -55,6 +57,7 @@
        if (CollectionUtils.isEmpty(list)) {
            return;
        }
        log.info("list.size={}", list.size());

        List<CokingTraceChartEntity> entityList = new ArrayList<>();
        list.forEach(value -> {

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

@@ -262,6 +262,8 @@
            analyIndEntity.setSort(i + 1);
            entityList.add(analyIndEntity);
        }
        // 清理旧数据
        cokingAnalyIndService.delete(process, analyDate, analyClass);
        cokingAnalyIndService.save(entityList);
    }
}

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

@@ -266,6 +266,8 @@
            analyIndEntity.setSort(i+1);
            entityList.add(analyIndEntity);
        }
        // 清理旧数据
        cokingAnalyIndService.delete(process, analyDate, analyClass);
        cokingAnalyIndService.save(entityList);
    }
}

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

@@ -258,6 +258,8 @@
            analyIndEntity.setSort(i + 1);
            entityList.add(analyIndEntity);
        }
        // 清理旧数据
        cokingAnalyIndService.delete(process, analyDate, analyClass);
        cokingAnalyIndService.save(entityList);
    }
}

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

@@ -265,6 +265,8 @@
            analyIndEntity.setSort(i + 1);
            entityList.add(analyIndEntity);
        }
        // 清理旧数据
        cokingAnalyIndService.delete(process, analyDate, analyClass);
        cokingAnalyIndService.save(entityList);
    }
}