海政通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2025-10-15 49dd9ee3dea22203cd1a0cc53745cffb6607122c 
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpProcurementServiceImpl.java


@@ -8,8 +8,13 @@


import com.ruoyi.common.core.domain.entity.SysUser;


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.system.dto.AddProcurementDto;


import com.ruoyi.system.export.PlatformLedgerReportExport;


import com.ruoyi.system.export.ProcurementReportClinicExport;


import com.ruoyi.system.export.ProcurementReportPlatformExport;


import com.ruoyi.system.export.ProcurementReportSupplierExport;


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 +37,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;


@@ -44,10 +50,13 @@


import java.math.RoundingMode;


import java.security.PrivateKey;


import java.security.cert.X509Certificate;


import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.util.ArrayList;


import java.util.Collections;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.stream.Collectors;




/**


@@ -103,6 +112,7 @@


    @Resource


    private TCrmWarehouseMapper crmWarehouseMapper;






    @Override


    public PageInfo<TErpProcurementVo> pageList(TErpProcurementQuery query, SysUser user) {




@@ -139,25 +149,25 @@


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


        List<TErpProcurementGoods> tErpProcurementGoods = erpProcurementGoodsMapper.selectList


                (new LambdaQueryWrapper<TErpProcurementGoods>().in(TErpProcurementGoods::getProcurementId, ids));


        List<TSysCommission> tSysCommissions = new ArrayList<>();


        if (!tErpProcurementGoods.isEmpty()) {


            List<String> collect = tErpProcurementGoods.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


            tSysCommissions = sysCommissionMapper.selectList(new LambdaQueryWrapper<TSysCommission>().in(TSysCommission::getTErpProcurementGoodsId, collect));


        }


////        List<TSysCommission> tSysCommissions = new ArrayList<>();


//        if (!tErpProcurementGoods.isEmpty()) {


////            List<String> collect = tErpProcurementGoods.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


////            tSysCommissions = sysCommissionMapper.selectList(new LambdaQueryWrapper<TSysCommission>().in(TSysCommission::getTErpProcurementGoodsId, collect));


//        }


        for (TErpProcurementVo tErpProcurementVo : list) {


            List<TErpProcurementGoods> collect = tErpProcurementGoods.stream().filter(e -> e.getProcurementId().equals(tErpProcurementVo.getId())).collect(Collectors.toList());


            int size = collect.stream().map(TErpProcurementGoods::getGoodsId).collect(Collectors.toSet()).size();


            tErpProcurementVo.setTypeNum(size);


            BigDecimal reduce = collect.stream().map(TErpProcurementGoods::getTotalPrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            tErpProcurementVo.setTotalPrice(reduce);


            if (!collect.isEmpty()) {


                List<String> collect1 = collect.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


                List<TSysCommission> collect2 = tSysCommissions.stream().filter(e -> collect1.contains(e.getTErpProcurementGoodsId())).collect(Collectors.toList());


                BigDecimal reduce1 = collect2.stream().filter(e -> e.getType() == 1).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                BigDecimal reduce2 = collect2.stream().filter(e -> e.getType() == 2).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                tErpProcurementVo.setPlatformMoney(reduce1);


                tErpProcurementVo.setSupplierMoney(reduce2);


            }


//            if (!collect.isEmpty()) {


////                List<String> collect1 = collect.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


////                List<TSysCommission> collect2 = tSysCommissions.stream().filter(e -> collect1.contains(e.getTErpProcurementGoodsId())).collect(Collectors.toList());


////                BigDecimal reduce1 = collect2.stream().filter(e -> e.getType() == 1).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


////                BigDecimal reduce2 = collect2.stream().filter(e -> e.getType() == 2).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


////                tErpProcurementVo.setPlatformMoney(reduce1);


////                tErpProcurementVo.setSupplierMoney(reduce2);


//            }




        }




@@ -187,7 +197,11 @@


                sTime = split[0] + " 00:00:00";


                eTime = split[1] + " 23:59:59";


            }




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


            if(CollectionUtils.isEmpty(supplierClinicId)){


                return pageInfo;


            }


            List<TErpProcurementVo> list = this.baseMapper.pageListWarehouse(query, pageInfo, user, sTime, eTime, supplierClinicId);


//            if (list.isEmpty()) {


//                return pageInfo;


@@ -443,6 +457,13 @@


    public DetailProcurementVO detailProcurement(String clinicSupplierId, SysUser user, String id) {


        DetailProcurementVO detailProcurementVO = new DetailProcurementVO();


        TErpProcurement tErpProcurement = this.getById(id);


        if (tErpProcurement.getWarehousingUserId()!=null && !tErpProcurement.getWarehousingUserId().isEmpty()) {


            SysUser sysUser = sysUserMapper.selectUserById(Long.valueOf(tErpProcurement.getWarehousingUserId()));


            detailProcurementVO.setWarehousingUserName(sysUser.getUserName());


        }


        detailProcurementVO.setWarehousingTime(tErpProcurement.getWarehousingTime());






        detailProcurementVO.setStatus(tErpProcurement.getStatus());


        detailProcurementVO.setCreateTime(tErpProcurement.getCreateTime());


        detailProcurementVO.setSendTime(tErpProcurement.getSendTime());


@@ -638,4 +659,104 @@


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


    }




    @Override


    public List<TErpProcurementGoods> branchAdminStatisticsThree(List<String> clinicIds) {


        return this.baseMapper.branchAdminStatisticsThree(clinicIds);


    }




    @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;


    }




    @Override


    public List<ProcurementReportClinicExport> exportProcurementReportClinic(ClinicProcurementReportQuery query) {


        List<ProcurementReportClinicExport> list = this.baseMapper.exportProcurementReportClinic(query);


        if(CollectionUtils.isEmpty(list)){


            return new ArrayList<>();


        }


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


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


        for (ProcurementReportClinicExport procurementReportClinicExport : list) {


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


            if(!CollectionUtils.isEmpty(procurementGoods)){


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


                procurementReportClinicExport.setProcurementGoodsNum(sum);


            }


            if(Objects.nonNull(procurementReportClinicExport.getPayTime())){


                String payTimeStr = new SimpleDateFormat("yyyy-MM-dd").format(procurementReportClinicExport.getPayTime());


                procurementReportClinicExport.setPayTimeStr(payTimeStr);


            }


        }


        return list;


    }




    @Override


    public List<ProcurementReportSupplierExport> exportProcurementReportSupplier(ClinicProcurementReportQuery query) {


        List<ProcurementReportSupplierExport> list = this.baseMapper.exportProcurementReportSupplier(query);


        if(CollectionUtils.isEmpty(list)){


            return new ArrayList<>();


        }


        for (ProcurementReportSupplierExport procurementReportSupplierExport : list) {


            if(Objects.nonNull(procurementReportSupplierExport.getPayTime())){


                String payTimeStr = new SimpleDateFormat("yyyy-MM-dd").format(procurementReportSupplierExport.getPayTime());


                procurementReportSupplierExport.setPayTimeStr(payTimeStr);


            }


        }


        return list;


    }




    @Override


    public List<ProcurementReportPlatformExport> exportProcurementReportPlatform(ClinicProcurementReportQuery query) {


        List<ProcurementReportPlatformExport> list = this.baseMapper.exportProcurementReportPlatform(query);


        if(CollectionUtils.isEmpty(list)){


            return new ArrayList<>();


        }


        for (ProcurementReportPlatformExport procurementReportPlatformExport : list) {


            if(Objects.nonNull(procurementReportPlatformExport.getPayTime())){


                String payTimeStr = new SimpleDateFormat("yyyy-MM-dd").format(procurementReportPlatformExport.getPayTime());


                procurementReportPlatformExport.setPayTimeStr(payTimeStr);


            }


        }


        return list;


    }




    @Override


    public PageInfo<ClinicProcurementReportVO> platformLedgerReport(ClinicProcurementReportQuery query) {


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


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


        pageInfo.setRecords(list);


        return pageInfo;


    }




    @Override


    public List<PlatformLedgerReportExport> exportPlatformLedgerReport(ClinicProcurementReportQuery query) {


        List<PlatformLedgerReportExport> list = this.baseMapper.exportPlatformLedgerReport(query);


        if(CollectionUtils.isEmpty(list)){


            return new ArrayList<>();


        }


        for (PlatformLedgerReportExport platformLedgerReportExport : list) {


            if(Objects.nonNull(platformLedgerReportExport.getPayTime())){


                String payTimeStr = new SimpleDateFormat("yyyy-MM-dd").format(platformLedgerReportExport.getPayTime());


                platformLedgerReportExport.setPayTimeStr(payTimeStr);


            }


        }


        return list;


    }




}