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

@@ -43,8 +43,18 @@
        logger.info("runCokingMainTask，参数为：{}", processTypes);
        try {

            String[] split = processTypes.split(",");
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.MILLISECOND, 0);
            calendar.set(Calendar.SECOND, 0);
            calendar.set(Calendar.MINUTE, 0);
            calendar.set(Calendar.HOUR_OF_DAY, 0);
            calendar.add(Calendar.DAY_OF_YEAR, -1);
            String clock = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);

            // 清理旧数据
            cokingProcessMainService.deleteByClock(clock);

            String[] split = processTypes.split(",");
            for (String processType : split) {
                CokingProcessConfEntity queryParams = new CokingProcessConfEntity();
                queryParams.setIndType(processType);
@@ -54,24 +64,11 @@
                    continue;
                }

                Calendar calendar = Calendar.getInstance();
                calendar.set(Calendar.MILLISECOND, 0);
                calendar.set(Calendar.SECOND, 0);
                calendar.set(Calendar.MINUTE, 0);
                calendar.set(Calendar.HOUR_OF_DAY, 0);
                calendar.add(Calendar.DAY_OF_YEAR, -1);
                String clock = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);

                // 清理旧数据
                cokingProcessMainService.deleteByClock(clock);

                // 主工序指标 筛选info_type = 0
                List<CokingProcessConfEntity> indList = list.stream().filter(e -> e.getInfoType().equals("0")).collect(Collectors.toList());
                if (CollectionUtils.isEmpty(indList)) {
                if (CollectionUtils.isEmpty(list)) {
                    continue;
                }
                List<CokingProcessMainEntity> processMainEntities = new ArrayList<>(indList.size());
                for (CokingProcessConfEntity conf : indList) {
                List<CokingProcessMainEntity> processMainEntities = new ArrayList<>(list.size());
                for (CokingProcessConfEntity conf : list) {
                    if (StringUtils.isBlank(conf.getDataType())) {
                        logger.info("DataType is Empty");
                        continue;