| | |
| | | import com.qianwen.smartman.common.utils.LocalDateTimeUtils; |
| | | import com.qianwen.smartman.common.utils.LocalDateUtil; |
| | | import com.qianwen.smartman.common.utils.MessageUtils; |
| | | import com.qianwen.smartman.modules.cps.dto.ShiftInfoDTO; |
| | | import com.qianwen.smartman.modules.cps.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.cps.service.IShiftDetailService; |
| | | import com.qianwen.smartman.modules.cps.vo.WorkstationVO; |
| | | import com.qianwen.smartman.modules.smis.dto.ShiftInfoDTO; |
| | | import com.qianwen.smartman.modules.smis.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.smis.service.IShiftDetailService; |
| | | import com.qianwen.smartman.modules.smis.vo.WorkstationVO; |
| | | import com.qianwen.smartman.modules.mdc.convert.AlarmConvert; |
| | | import com.qianwen.smartman.modules.mdc.entity.SuperAggregate; |
| | | import com.qianwen.smartman.modules.mdc.entity.SuperAlarm; |
| | |
| | | return new Page<>(); |
| | | } |
| | | LocalDate queryTime = vo.getQueryTime(); |
| | | List<SuperAlarm> list = this.alarmMapper.selectListAlarm(vo, DateUtil.format(queryTime, "yyyyMMdd")); |
| | | List<SuperAlarm> list = this.alarmMapper.selectListAlarm(vo,Integer.parseInt(DateUtil.format(queryTime, "yyyyMMdd"))); |
| | | Map<String, List<SuperAlarm>> map = FilterOffUtils.filterOffDay(list, OpenTypeEnums.ALARM_ANALYSIS).stream().collect(Collectors.groupingBy(c -> { |
| | | return c.getCode() + c.getMessage(); |
| | | })); |
| | |
| | | if (map.size() == 0) { |
| | | return page; |
| | | } |
| | | List<SuperAlarm> alarms = this.alarmMapper.selectListAlarm(vo, DateUtil.format(queryTime, "yyyyMMdd")); |
| | | List<SuperAlarm> alarms = this.alarmMapper.selectListAlarm(vo, Integer.parseInt(DateUtil.format(queryTime, "yyyyMMdd"))); |
| | | List<AlarmDataSheetVO> res = AlarmConvert.INSTANCE.convert(FilterOffUtils.filterOffDay(alarms, OpenTypeEnums.ALARM_ANALYSIS)); |
| | | List<AlarmDataSheetVO> alarmDataSheetVOS = new ArrayList<>(); |
| | | Map<String, List<AlarmDataSheetVO>> resMap = res.stream().collect(Collectors.groupingBy(c2 -> { |
| | | return c2.getAlarmCode() + c2.getAlarmMsg(); |
| | | })); |
| | | resMap.values().forEach(alarmDataSheetVOList -> { |
| | | ((AlarmDataSheetVO) alarmDataSheetVOList.get(0)).setCount(Integer.valueOf(alarmDataSheetVOList.size())); |
| | | ((AlarmDataSheetVO) alarmDataSheetVOList.get(0)).setCount(alarmDataSheetVOList.size()); |
| | | alarmDataSheetVOS.add(alarmDataSheetVOList.get(0)); |
| | | }); |
| | | if (query.getSize().intValue() == -1) { |
| | |
| | | public BladeFile exportAlarm(AlarmShiftSearchExcelVO vo) { |
| | | BladeFile bladeFile; |
| | | |
| | | List<SuperAlarm> superAlarms = this.alarmMapper.selectListAlarmByShift(LocalDateTimeUtils.formatTimeLocalDate(vo.getStartTime(), "yyyyMMdd"), LocalDateTimeUtils.formatTimeLocalDate(vo.getEndTime(), "yyyyMMdd"), vo.getWorkstationId()); |
| | | List<SuperAlarm> superAlarms = this.alarmMapper.selectListAlarmByShift(Integer.parseInt(LocalDateTimeUtils.formatTimeLocalDate(vo.getStartTime(), "yyyyMMdd")) , Integer.parseInt(LocalDateTimeUtils.formatTimeLocalDate(vo.getEndTime(), "yyyyMMdd")), vo.getWorkstationId()); |
| | | superAlarms = FilterOffUtils.filterOffDay(superAlarms, OpenTypeEnums.ALARM_ANALYSIS); |
| | | superAlarms.sort(Comparator.comparing(SuperAggregate::getFactoryDate)); |
| | | Collections.reverse(superAlarms); |
| | |
| | | if (Func.isNull(vo.getWorkstationId())) { |
| | | return new AlarmSummaryGraphVO(); |
| | | } |
| | | List<SuperAlarm> alarms = this.alarmMapper.queryAlarm(null, vo, DateUtil.format(vo.getQueryTime(), "yyyyMMdd")); |
| | | List<SuperAlarm> alarms = this.alarmMapper.queryAlarm(null, vo,Integer.parseInt(DateUtil.format(vo.getQueryTime(), "yyyyMMdd")) ); |
| | | alarms.forEach(a -> { |
| | | if(a.getCode() == null) { |
| | | a.setCode("0");//默认给0,避免错误 |
| | | } |
| | | }); |
| | | Map<String, Integer> map = FilterOffUtils.filterOffDay(alarms, OpenTypeEnums.ALARM_ANALYSIS).stream().collect(Collectors.groupingBy((v0) -> { |
| | | return v0.getCode(); |
| | | }, Collectors.reducing(0, e -> { |