| | |
| | | package com.iailab.module.ansteel.job.task; |
| | | |
| | | import com.iailab.framework.common.util.date.DateUtils; |
| | | import com.iailab.module.ansteel.coking.entity.CokingAnalyIndEntity; |
| | | import com.iailab.module.ansteel.coking.entity.CokingProcessConfEntity; |
| | | import com.iailab.module.ansteel.coking.entity.CokingProdDayEntity; |
| | | import com.iailab.module.ansteel.coking.entity.CokingTraceIndEntity; |
| | | import com.iailab.module.ansteel.coking.service.CokingProcessConfService; |
| | | import com.iailab.module.ansteel.coking.service.CokingProdDayService; |
| | | import com.iailab.module.ansteel.coking.service.CokingTraceIndService; |
| | | 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; |
| | |
| | | private CokingProdDayService cokingProdDayService; |
| | | |
| | | @Resource |
| | | private CokingTraceIndService cokingTraceIndService; |
| | | |
| | | @Resource |
| | | private DataPointApi dataPointApi; |
| | | |
| | | @Resource |
| | |
| | | calendar.set(Calendar.SECOND, 0); |
| | | calendar.add(Calendar.DAY_OF_YEAR, -1); |
| | | String clock = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY); |
| | | String clock2 = ""; |
| | | int hour = calendar.get(Calendar.HOUR_OF_DAY); |
| | | if (hour == 0) { |
| | | clock2 = clock.concat("-").concat("A"); |
| | | } else if (hour == 8) { |
| | | clock2 = clock.concat("-").concat("B"); |
| | | } else if (hour == 16) { |
| | | clock2 = clock.concat("-").concat("C"); |
| | | } |
| | | logger.info("清理旧数据"); |
| | | cokingProdDayService.deleteByClock(clock); |
| | | for (CokingProcessConfEntity conf : list) { |
| | |
| | | value = indValues.get(indValues.size() - 1).getDataValue().toString(); |
| | | } |
| | | break; |
| | | case MODEL: |
| | | value = "100"; |
| | | break; |
| | | default: |
| | | break; |
| | | |
| | | } |
| | | this.saveProdDay(conf, value, clock); |
| | | saveProdDay(conf, value, clock); |
| | | saveTraceInd(conf, value, clock2); |
| | | } |
| | | } catch (Exception ex) { |
| | | logger.error("RunCokingProdDayTask运行异常"); |
| | |
| | | |
| | | } |
| | | |
| | | private void saveTraceInd(CokingProcessConfEntity conf, String value, String clock) { |
| | | CokingTraceIndEntity cokingTraceIndEntity = new CokingTraceIndEntity(); |
| | | cokingTraceIndEntity.setTitle(conf.getIndType()); |
| | | cokingTraceIndEntity.setClock(clock); |
| | | cokingTraceIndEntity.setIndName(conf.getIndName()); |
| | | cokingTraceIndEntity.setIndValue(value); |
| | | cokingTraceIndEntity.setIndUnit(conf.getIndUnit()); |
| | | cokingTraceIndService.save(cokingTraceIndEntity); |
| | | } |
| | | |
| | | private void saveProdDay(CokingProcessConfEntity conf, String value, String clock) { |
| | | CokingProdDayEntity cokingProdDayEntity = new CokingProdDayEntity(); |
| | | cokingProdDayEntity.setInfoType(conf.getInfoType()); |