海政通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2025-10-15 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;


@@ -171,19 +173,15 @@






        Integer roleType = user.getRoleType();


        String supplierClinicId = null;


        List<String> supplierClinicId = null;


        if (roleType == 6) {




            TCrmWarehouse warehouse = crmWarehouseMapper.selectOne(Wrappers.lambdaQuery(TCrmWarehouse.class)


                    .eq(TCrmWarehouse::getUserId, user.getUserId())


                    .last("LIMIT 1"));


            // 供应商


            TCrmSupplier crmSupplier = crmSupplierMapper.selectOne(Wrappers.lambdaQuery(TCrmSupplier.class)


                    .eq(TCrmSupplier::getWarehouseId, warehouse.getId())


                    .last("LIMIT 1"));


            supplierClinicId = crmSupplier.getId();






            supplierClinicId = crmSupplierMapper.selectList(Wrappers.lambdaQuery(TCrmSupplier.class)


                    .eq(TCrmSupplier::getWarehouseId, warehouse.getId())).stream().map(TCrmSupplier::getId).collect(Collectors.toList());


            String sTime = null;


            String eTime = null;


            if (query.getTime() != null && !query.getTime().isEmpty()) {


@@ -496,11 +494,11 @@




    @Override


    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)


    public void detailProcurementSend(String clinicSupplierId, SysUser user, String id,String logisticsNumber) {


    public void detailProcurementSend(List<String> clinicSupplierId, SysUser user, String id,String logisticsNumber) {


        // 查出这个采购的下级商品


        List<TErpProcurementGoods> list = erpProcurementGoodsService.list(new QueryWrapper<TErpProcurementGoods>().eq("procurement_id", id));


        List<TErpSupplierWarehousing> tErpSupplierWarehousings = erpSupplierWarehousingMapper.selectList(new LambdaQueryWrapper<TErpSupplierWarehousing>()


                .eq(TErpSupplierWarehousing::getSupplierId, clinicSupplierId).in(TErpSupplierWarehousing::getGoodsId, list.stream().map(TErpProcurementGoods::getGoodsId).collect(Collectors.toList()))


                .in(TErpSupplierWarehousing::getSupplierId, clinicSupplierId).in(TErpSupplierWarehousing::getGoodsId, list.stream().map(TErpProcurementGoods::getGoodsId).collect(Collectors.toList()))


                .orderByAsc(BaseModel::getCreateTime));




        if(tErpSupplierWarehousings.isEmpty()){


@@ -544,7 +542,7 @@


                    if(count>=purchaseCount){


                        // 添加出库记录


                        TErpSupplierOutbound tErpSupplierOutbound= new TErpSupplierOutbound();


                        tErpSupplierOutbound.setSupplierId(clinicSupplierId);


                        tErpSupplierOutbound.setSupplierId(tErpSupplierWarehousing.getSupplierId());


                        tErpSupplierOutbound.setWarehouseId(tErpSupplierWarehousing.getWarehouseId());


                        tErpSupplierOutbound.setOutboundType(7);


                        //TODO 确定这个是采购价还是销售价格


@@ -567,7 +565,7 @@


                        purchaseCount = purchaseCount - count;


                        // 添加出库记录


                        TErpSupplierOutbound tErpSupplierOutbound= new TErpSupplierOutbound();


                        tErpSupplierOutbound.setSupplierId(clinicSupplierId);


                        tErpSupplierOutbound.setSupplierId(tErpSupplierWarehousing.getSupplierId());


                        tErpSupplierOutbound.setWarehouseId(tErpSupplierWarehousing.getWarehouseId());


                        tErpSupplierOutbound.setOutboundType(7);


                        //TODO 确定这个是采购价还是销售价格


@@ -602,4 +600,64 @@




    }




    @Override


    public List<SupplierThirtyProcurementStatisticsVO> supplierThirtyProcurementStatistics(String supplierAndClinicId, String startTime, String endTime,Integer roleType) {


        return this.baseMapper.supplierThirtyProcurementStatistics(supplierAndClinicId, startTime, endTime, roleType);


    }




    @Override


    public List<SupplierThirtyMoneyProcurementStatisticsVO> supplierThirtyMoneyProcurementStatistics(String supplierAndClinicId, String startTime, String endTime,Integer roleType) {


        return this.baseMapper.supplierThirtyMoneyProcurementStatistics(supplierAndClinicId, startTime, endTime, roleType);


    }




    @Override


    public Integer supplierSalesStatisticsTypeCount(String supplierId) {


        return this.baseMapper.supplierSalesStatisticsTypeCount(supplierId);


    }




    @Override


    public Integer supplierSalesStatisticsCount(String supplierId) {


        return this.baseMapper.supplierSalesStatisticsCount(supplierId);


    }




    @Override


    public BigDecimal supplierSalesStatisticsMoney(String supplierId, String startTime, String endTime) {


        return this.baseMapper.supplierSalesStatisticsMoney(supplierId,startTime, endTime);


    }




    @Override


    public List<SupplierSalesStatisticsGoodsTypeVO> supplierSalesStatisticsGoodsType(String supplierId, String startTime, String endTime) {


        return this.baseMapper.supplierSalesStatisticsGoodsType(supplierId,startTime, endTime);


    }




    @Override


    public List<SupplierSalesStatisticsGoodsCountVO> supplierSalesStatisticsGoodsCount(String supplierId, String startTime, String endTime, String goodsName) {


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


    }




    @Override


    public List<SupplierSalesStatisticsGoodsCountVO> supplierSalesStatisticsGoodsCountMonth(String supplierId, String startTime, String endTime, String goodsName) {


        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;


    }




}