鞍钢鲅鱼圈能源管控系统后端代码
上一版本: 336ac066 | 补丁 | 提交 | 显示空白
潘志宝
昨天 bd0f24fb70621ea26dc6fd4c41b391620ab583dd 
焦化溯源时间修改
已修改4个文件
189 ■■■■■ 文件已修改
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdMonTask.java 94 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java 30 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java 34 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelHCTask.java 31 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdMonTask.java


@@ -1,13 +1,29 @@


package com.iailab.module.ansteel.job.task;




import com.iailab.framework.common.util.date.DateUtils;


import com.iailab.module.ansteel.coking.entity.CokingProcessConfEntity;


import com.iailab.module.ansteel.coking.entity.CokingProdDayEntity;


import com.iailab.module.ansteel.coking.service.CokingProcessConfService;


import com.iailab.module.ansteel.coking.service.CokingProdDayService;


import com.iailab.module.ansteel.common.enums.ProcessConfDataTypeEnum;


import com.iailab.module.data.api.ind.IndItemApi;


import com.iailab.module.data.api.ind.dto.ApiIndItemValueDTO;


import com.iailab.module.data.api.point.DataPointApi;


import org.apache.commons.lang3.StringUtils;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;




import javax.annotation.Resource;


import java.util.ArrayList;


import java.util.Calendar;


import java.util.List;


import java.util.Map;




/**


 * 生成焦化月累计生产信息


 * 0 5 0 * * ?


 *


 *


 * @author PanZhibao


 * @Description


@@ -18,9 +34,85 @@




    private Logger logger = LoggerFactory.getLogger(getClass());




    @Resource


    private CokingProcessConfService cokingProcessConfService;




    @Resource


    private CokingProdDayService cokingProdDayService;




    @Resource


    private DataPointApi dataPointApi;




    @Resource


    private IndItemApi indItemApi;






    @Override


    public void run(String params) {


        logger.info("RunCokingProdMonTask，参数为：{}", params);


        try {


            CokingProcessConfEntity queryParams = new CokingProcessConfEntity();


            queryParams.setIndType("prod_mon");


            List<CokingProcessConfEntity> list = cokingProcessConfService.list(queryParams);


            if (CollectionUtils.isEmpty(list)) {


                logger.info("ConfLis is Empty");


                return;


            }




            Calendar calendar = Calendar.getInstance();


            calendar.set(Calendar.MILLISECOND, 0);


            calendar.set(Calendar.SECOND, 0);


            calendar.add(Calendar.DAY_OF_YEAR, -1);


            String clock = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);


            logger.info("清理旧数据");


            cokingProdDayService.deleteByClock(clock);


            for (CokingProcessConfEntity conf : list) {


                if (StringUtils.isBlank(conf.getDataType())) {


                    logger.info("DataType is Empty");


                    continue;


                }


                if (StringUtils.isBlank(conf.getPointNo())) {


                    logger.info("PointNo is Empty");


                    continue;


                }


                String value = "";


                switch (ProcessConfDataTypeEnum.getEumByCode(conf.getDataType())) {


                    case DATAPOINT:


                        List<String> points = new ArrayList<>();


                        points.add(conf.getPointNo());


                        Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);


                        value = pointsRealValue.get(conf.getPointNo()).toString();


                        break;


                    case IND:


                        List<ApiIndItemValueDTO> indValues = indItemApi.queryIndItemDefaultValue(conf.getPointNo());


                        if (!CollectionUtils.isEmpty(indValues)) {


                            value = indValues.get(indValues.size() - 1).getDataValue().toString();


                        }


                        break;


                    default:


                        break;




                }


                saveProdDay(conf, value, clock, conf.getIndCode());


            }




        } catch (Exception ex) {


            logger.error("RunCokingProdMonTask运行异常");


            ex.printStackTrace();


        }


        logger.info("RunCokingProdMonTask运行完成");




    }




    private void saveProdDay(CokingProcessConfEntity conf, String value, String clock, String indCode) {


        CokingProdDayEntity entity = new CokingProdDayEntity();


        entity.setInfoType(conf.getInfoType());


        entity.setSort(conf.getSort());


        entity.setIndCode(indCode);


        entity.setIndName(conf.getIndName());


        entity.setIndUnit(conf.getIndUnit());


        entity.setIndValue(value);


        entity.setClock(clock);


        cokingProdDayService.save(entity);


    }


}




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


@@ -99,29 +99,39 @@


            calendar.set(Calendar.MILLISECOND, 0);


            calendar.set(Calendar.SECOND, 0);


            calendar.set(Calendar.MINUTE,0);


            calendar.add(Calendar.DAY_OF_YEAR, -1);


            String yesterday = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);


            int hour = calendar.get(Calendar.HOUR_OF_DAY);


            Date startDate = calendar.getTime();


            calendar.add(Calendar.HOUR, 8);


            Date endDate = calendar.getTime();


            String clock = "";


            String analyClass = "";


            if (hour == 0) {


                clock = yesterday.concat("-").concat("A");


            if (hour >= 8 && hour < 16) {


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("A");


                analyClass = "甲班";


            } else if (hour == 8) {


                clock = yesterday.concat("-").concat("B");


            } else if (hour >= 16 && hour < 24) {


                calendar.set(Calendar.HOUR_OF_DAY, 8);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "乙班";


            } else if (hour == 16) {


                clock = yesterday.concat("-").concat("C");


            } else if (hour >= 0 && hour < 8) {


                calendar.add(Calendar.DAY_OF_YEAR, -1);


                calendar.set(Calendar.HOUR_OF_DAY, 16);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "丙班";


            }


            Map<String, Object> tMap = new HashMap<>();


            tMap.put("relId", UUID.randomUUID().toString());


            tMap.put("process", "备煤工序");


            tMap.put("reportName", "备煤工序");


            tMap.put("analyDate", yesterday);


            tMap.put("analyDate", DateUtils.format(startDate));


            tMap.put("analyClass", analyClass);


            tMap.put("clock", clock);


            tMap.put("analyContent", "备煤耗电异常");




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


@@ -18,7 +18,6 @@


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import java.util.*;


@@ -106,25 +105,42 @@


        logger.info("RunCokingTraceModelGXJTask，参数为：{}", params);


        try {


            Calendar calendar = Calendar.getInstance();


            calendar.set(Calendar.MILLISECOND, 0);


            calendar.set(Calendar.SECOND, 0);


            calendar.set(Calendar.MINUTE, 0);


            int hour = calendar.get(Calendar.HOUR_OF_DAY);


            String yesterday = DateUtils.format(DateUtils.addDateDays(new Date(), -1), DateUtils.FORMAT_YEAR_MONTH_DAY);


            Date startDate = calendar.getTime();


            Date endDate = calendar.getTime();


            String clock = "";


            String analyClass = "";


            if (hour == 0) {


                clock = yesterday.concat("-").concat("A");


            if (hour >= 8 && hour < 16) {


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("A");


                analyClass = "甲班";


            } else if (hour == 8) {


                clock = yesterday.concat("-").concat("B");


            } else if (hour >= 16 && hour < 24) {


                calendar.set(Calendar.HOUR_OF_DAY, 8);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "乙班";


            } else if (hour == 16) {


                clock = yesterday.concat("-").concat("C");


            } else if (hour >= 0 && hour < 8) {


                calendar.add(Calendar.DAY_OF_YEAR, -1);


                calendar.set(Calendar.HOUR_OF_DAY, 16);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "丙班";


            }


            Map<String, Object> tMap = new HashMap<>();


            tMap.put("relId", UUID.randomUUID().toString());


            tMap.put("process", "干熄焦工序");


            tMap.put("reportName", "锅炉蒸汽产量");


            tMap.put("analyDate", yesterday);


            tMap.put("analyDate", DateUtils.format(startDate));


            tMap.put("analyClass", analyClass);


            tMap.put("clock", clock);


            tMap.put("analyContent", "干熄焦产蒸汽量异常");




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


@@ -18,7 +18,6 @@


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import java.util.*;


@@ -101,29 +100,39 @@


            calendar.set(Calendar.MILLISECOND, 0);


            calendar.set(Calendar.SECOND, 0);


            calendar.set(Calendar.MINUTE,0);


            calendar.add(Calendar.DAY_OF_YEAR, -1);


            String yesterday = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);


            int hour = calendar.get(Calendar.HOUR_OF_DAY);


            Date startDate = calendar.getTime();


            calendar.add(Calendar.HOUR, 8);


            Date endDate = calendar.getTime();


            String clock = "";


            String analyClass = "";


            if (hour == 0) {


                clock = yesterday.concat("-").concat("A");


            if (hour >= 8 && hour < 16) {


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("A");


                analyClass = "甲班";


            } else if (hour == 8) {


                clock = yesterday.concat("-").concat("B");


            } else if (hour >= 16 && hour < 24) {


                calendar.set(Calendar.HOUR_OF_DAY, 8);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "乙班";


            } else if (hour == 16) {


                clock = yesterday.concat("-").concat("C");


            } else if (hour >= 0 && hour < 8) {


                calendar.add(Calendar.DAY_OF_YEAR, -1);


                calendar.set(Calendar.HOUR_OF_DAY, 16);


                startDate = calendar.getTime();


                calendar.add(Calendar.HOUR_OF_DAY, 8);


                endDate = calendar.getTime();


                clock = DateUtils.format(startDate).concat("-").concat("B");


                analyClass = "丙班";


            }


            Map<String, Object> tMap = new HashMap<>();


            tMap.put("relId", UUID.randomUUID().toString());


            tMap.put("process", "化产工序");


            tMap.put("reportName", "化产工序");


            tMap.put("analyDate", yesterday);


            tMap.put("analyDate", DateUtils.format(startDate));


            tMap.put("analyClass", analyClass);


            tMap.put("clock", clock);


            tMap.put("analyContent", "化产蒸汽消耗量异常");