| | |
|---|
| | | @Override |
|---|
| | | public IPage<ProcurementPageDto> listPageByProductProduction(Page page, ProcurementPageDto procurementDto) { |
|---|
| | | IPage<ProcurementPageDto> procurementPageDtoIPage = procurementRecordMapper.listPageByProductProduction(page, procurementDto); |
|---|
| | | |
|---|
| | | |
|---|
| | | List<ProcurementPageDto> procurementPageDtos = procurementPageDtoIPage.getRecords(); |
|---|
| | | // 计算待入库数量 |
|---|
| | | // 查询采购记录已入库数量 |
|---|
| | | List<Integer> collect = procurementPageDtos.stream().map(ProcurementPageDto::getId).collect(Collectors.toList()); |
|---|
| | | if(CollectionUtils.isEmpty( collect)){ |
|---|
| | | return procurementPageDtoIPage; |
|---|
| | | } |
|---|
| | | LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect) |
|---|
| | | .eq(ProcurementRecordOut::getType, 4); |
|---|
| | | List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper); |
|---|
| | | if(CollectionUtils.isEmpty( procurementRecords)){ |
|---|
| | | return procurementPageDtoIPage; |
|---|
| | | } |
|---|
| | | for (ProcurementPageDto dto : procurementPageDtos) { |
|---|
| | | // 根据采购台账ID筛选对应的出库记录 |
|---|
| | | List<ProcurementRecordOut> collect1 = procurementRecords.stream() |
|---|
| | | .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId())) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | // 如果没有相关的出库记录，跳过该条数据 |
|---|
| | | if(CollectionUtils.isEmpty(collect1)){ |
|---|
| | | dto.setInboundNum0(dto.getInboundNum()); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 计算已出库数量总和，并设置待出库数量 |
|---|
| | | BigDecimal totalInboundNum = collect1.stream() |
|---|
| | | .map(ProcurementRecordOut::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | |
|---|
| | | // 待出库数量 = 总数量 - 已出库数量 |
|---|
| | | dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum)); |
|---|
| | | } |
|---|
| | | return procurementPageDtoIPage; |
|---|
| | | } |
|---|
| | | |
|---|
