| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | List<FlowCardGlassInfoDTO> dtos = new ArrayList<>(); |
|---|
| | | listMap.forEach((e, v) -> { |
|---|
| | | HollowBigStorageCageDetails cageDetails = v.get(0); |
|---|
| | | //按照流程卡获取对应的产品名称 |
|---|
| | | String productName = baseMapper.queryProductNameByFlowCardId(cageDetails.getFlowCardId()); |
|---|
| | | List<FlowCardGlassInfoDTO> flowCardInfoList = hollowBigStorageCageDetailsService.hollowIsAll(e, cageDetails.getTotalLayer(), Boolean.FALSE); |
|---|
| | | for (FlowCardGlassInfoDTO item : flowCardInfoList) { |
|---|
| | | item.setProductName(productName); |
|---|
| | | dtos.add(item); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | Map<String, FlowCardGlassInfoDTO> result = dtos.stream() |
|---|
| | | .collect(Collectors.toMap( |
|---|
| | | FlowCardGlassInfoDTO::getFlowCardId, |
|---|
| | | dto -> { |
|---|
| | | FlowCardGlassInfoDTO newDto = new FlowCardGlassInfoDTO(); |
|---|
| | | newDto.setFlowCardId(dto.getFlowCardId()); |
|---|
| | | newDto.setSumCount(dto.getSumCount()); |
|---|
| | | newDto.setPairCount(dto.getPairCount()); |
|---|
| | | newDto.setRealCount(dto.getRealCount()); |
|---|
| | | newDto.setLayer(dto.getLayer()); |
|---|
| | | return newDto; |
|---|
| | | }, |
|---|
| | | (dto1, dto2) -> { |
|---|
| | | dto1.setRealCount(dto1.getRealCount() + dto2.getRealCount()); // 累加 realCount |
|---|
| | | dto1.setLayer(Math.max(dto1.getLayer(), dto2.getLayer())); // 累加 最大层数 |
|---|
| | | return dto1; // 返回合并后的对象 |
|---|
| | | } |
|---|
| | | )); |
|---|
| | | return dtos.stream().collect(Collectors.groupingBy(e -> e.getFlowCardId() + ":" + e.getProductName())); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<FlowCardGlassInfoDTO> queryHollowAllFlowCardSummary(HollowBigStorageDetailsQueryVO query) { |
|---|
| | | List<HollowBigStorageCageDetails> detailsList = hollowBigStorageCageDetailsService.list(new LambdaQueryWrapper<HollowBigStorageCageDetails>() |
|---|
| | | .eq(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_IN) |
|---|
| | | .like(StringUtils.isNotBlank(query.getFilmsId()), HollowBigStorageCageDetails::getFilmsId, query.getFilmsId()) |
|---|
| | | .like(StringUtils.isNotBlank(query.getFlowCardId()), HollowBigStorageCageDetails::getFlowCardId, query.getFlowCardId()) |
|---|
| | | .eq(query.getThickness() != 0, HollowBigStorageCageDetails::getThickness, query.getThickness()) |
|---|
| | | .orderByAsc(HollowBigStorageCageDetails::getFlowCardId) |
|---|
| | | ); |
|---|
| | | if (CollectionUtil.isEmpty(detailsList)) { |
|---|
| | | log.info("笼内无玻璃"); |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | Map<String, List<HollowBigStorageCageDetails>> listMap = detailsList.stream().collect(Collectors.groupingBy(HollowBigStorageCageDetails::getFlowCardId)); |
|---|
| | | List<FlowCardGlassInfoDTO> dtos = new ArrayList<>(); |
|---|
| | | listMap.forEach((e, v) -> { |
|---|
| | | HollowBigStorageCageDetails cageDetails = v.get(0); |
|---|
| | | dtos.addAll(hollowBigStorageCageDetailsService.hollowIsAll(e, cageDetails.getTotalLayer(), Boolean.FALSE)); |
|---|
| | | }); |
|---|
| | | return dtos.stream().collect(Collectors.groupingBy(FlowCardGlassInfoDTO::getFlowCardId)); |
|---|
| | | Map<String, FlowCardGlassInfoDTO> result = dtos.stream() |
|---|
| | | .collect(Collectors.toMap( |
|---|
| | | FlowCardGlassInfoDTO::getFlowCardId, |
|---|
| | | dto -> { |
|---|
| | | FlowCardGlassInfoDTO newDto = new FlowCardGlassInfoDTO(); |
|---|
| | | newDto.setFlowCardId(dto.getFlowCardId()); |
|---|
| | | newDto.setSumCount(dto.getSumCount()); |
|---|
| | | newDto.setPairCount(dto.getPairCount()); |
|---|
| | | newDto.setRealCount(dto.getRealCount()); |
|---|
| | | newDto.setLayer(dto.getLayer()); |
|---|
| | | newDto.setSlotCount(dto.getSlotCount()); |
|---|
| | | return newDto; |
|---|
| | | }, |
|---|
| | | (dto1, dto2) -> { |
|---|
| | | dto1.setRealCount(dto1.getRealCount() + dto2.getRealCount()); // 累加 realCount |
|---|
| | | dto1.setLayer(Math.max(dto1.getLayer(), dto2.getLayer())); // 累加 最大层数 |
|---|
| | | dto1.setSlotCount(dto1.getSlotCount() + dto2.getSlotCount()); |
|---|
| | | return dto1; // 返回合并后的对象 |
|---|
| | | } |
|---|
| | | )); |
|---|
| | | List<FlowCardGlassInfoDTO> resultList = new ArrayList<>(result.values()); |
|---|
| | | List<FlowCardGlassInfoDTO> sortedList = resultList.stream() |
|---|
| | | .sorted(Comparator.comparing(FlowCardGlassInfoDTO::getRealCount).reversed() // 第一个字段倒序 |
|---|
| | | .thenComparing(FlowCardGlassInfoDTO::getSumCount, Comparator.reverseOrder())) // 第二个字段倒序 |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | return sortedList; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
