海政通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
9 天以前 781dc4e9816753672dfe2c2af75e499f1f9bb576 
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpProcurementServiceImpl.java


@@ -10,6 +10,7 @@


import com.ruoyi.system.dto.AddProcurementDto;


import com.ruoyi.system.mapper.*;


import com.ruoyi.system.model.*;


import com.ruoyi.system.query.ClinicProcurementReportQuery;


import com.ruoyi.system.query.TErpGoodsQuery;


import com.ruoyi.system.query.TErpProcurementQuery;


import com.ruoyi.system.service.TErpGoodsService;


@@ -32,6 +33,7 @@


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Propagation;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import javax.annotation.Resource;


import javax.net.ssl.SSLContext;


@@ -638,4 +640,24 @@


        return this.baseMapper.supplierSalesStatisticsGoodsCountMonth(supplierId,startTime, endTime,goodsName);


    }




    @Override


    public PageInfo<ClinicProcurementReportVO> clinicProcurementReport(ClinicProcurementReportQuery query) {


        PageInfo<ClinicProcurementReportVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());


        List<ClinicProcurementReportVO> list = this.baseMapper.clinicProcurementReport(query, pageInfo);


        if(CollectionUtils.isEmpty(list)){


            return pageInfo;


        }


        List<String> procurementIds = list.stream().map(TErpProcurement::getId).collect(Collectors.toList());


        List<TErpProcurementGoods> erpProcurementGoods = erpProcurementGoodsMapper.selectList(new QueryWrapper<TErpProcurementGoods>().lambda().in(TErpProcurementGoods::getProcurementId, procurementIds));


        for (ClinicProcurementReportVO clinicProcurementReportVO : list) {


            List<TErpProcurementGoods> procurementGoods = erpProcurementGoods.stream().filter(tErpProcurementGoods -> tErpProcurementGoods.getProcurementId().equals(clinicProcurementReportVO.getId())).collect(Collectors.toList());


            if(!CollectionUtils.isEmpty(procurementGoods)){


                int sum = procurementGoods.stream().mapToInt(TErpProcurementGoods::getPurchaseCount).sum();


                clinicProcurementReportVO.setProcurementGoodsNum(sum);


            }


        }


        pageInfo.setRecords(list);


        return pageInfo;


    }




}