焦化概况 旧数据清理

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

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

    void insert(List<CokingOverviewEntity> result);

    void deleteByProcessType(String processType, String clock);
}

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

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

    void insertList(List<CokingTraceDataEntity> list);

    void deleteByExObj(String exObj, String clock);
}

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

@@ -79,4 +79,12 @@
    public void insert(List<CokingOverviewEntity> result) {
        cokingOverviewDao.insert(result);
    }

    @Override
    public void deleteByProcessType(String processType, String clock) {
        QueryWrapper<CokingOverviewEntity> queryWrapperDay = new QueryWrapper<>();
        queryWrapperDay.eq("process_type", processType);
        queryWrapperDay.eq("clock", clock);
        cokingOverviewDao.delete(queryWrapperDay);
    }
}

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

@@ -39,4 +39,12 @@
    public void insertList(List<CokingTraceDataEntity> list) {
        cokingTraceDataDao.insert(list);
    }

    @Override
    public void deleteByExObj(String exObj, String clock) {
        QueryWrapper<CokingTraceDataEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("ex_obj", exObj)
                .eq("clock", clock);
        cokingTraceDataDao.delete(queryWrapper);
    }
}

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

@@ -133,6 +133,10 @@
                    overviewEntity.setSubProcessType(entry.getKey());
                    overviewEntity.setClock(clock);
                    result.add(overviewEntity);

                    // 清理旧数据
                    cokingOverviewService.deleteByProcessType(processType, clock);
                    cokingTraceDataService.deleteByExObj(processType, clock);
                }
                cokingOverviewService.insert(result);