From 84e8c13e1885892631e52f71508150c0ff1ee55f Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期四, 25 九月 2025 18:52:01 +0800
Subject: [PATCH] 诊所erp

---
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpClinicWarehousingServiceImpl.java |  140 +++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 130 insertions(+), 10 deletions(-)

diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpClinicWarehousingServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpClinicWarehousingServiceImpl.java
index 122815a..aafd7f6 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpClinicWarehousingServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpClinicWarehousingServiceImpl.java
@@ -2,19 +2,19 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ruoyi.common.basic.PageInfo;
 import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.system.dto.ClinicOutboundGoodsDto;
+import com.ruoyi.system.dto.OutboundGoodsNextDto;
+import com.ruoyi.system.dto.clinicWarehouseGoodsDto;
 import com.ruoyi.system.mapper.*;
 import com.ruoyi.system.model.*;
-import com.ruoyi.system.query.TErpGoodsQuery;
-import com.ruoyi.system.query.TErpInventoryQuery;
-import com.ruoyi.system.query.ValidityPeriodWarningQuery;
+import com.ruoyi.system.query.*;
 import com.ruoyi.system.service.TErpClinicWarehousingService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.system.vo.InventoryDetailVo;
-import com.ruoyi.system.vo.PageInventoryListVo;
-import com.ruoyi.system.vo.TErpGoodsVO;
-import com.ruoyi.system.vo.ValidityPeriodWarningVo;
+import com.ruoyi.system.vo.*;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -23,6 +23,7 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -112,7 +113,7 @@
                         TErpClinicWarehousing tErpSupplierWarehousing = erpClinicWarehousingMapper.selectById(tErpSupplierInventoryGoods1.getWarehousingId());
 //                        List<TErpSupplierWarehousingBatch> tErpSupplierWarehousingBatches = erpSupplierWarehousingBatchMapper.selectList(new LambdaQueryWrapper<TErpSupplierWarehousingBatch>().eq(TErpSupplierWarehousingBatch::getWarehousingId, tErpSupplierWarehousing.getId()));
 //                        int sum = tErpSupplierWarehousingBatches.stream().mapToInt(TErpSupplierWarehousingBatch::getWarehousingNumber).sum();
-                        String goodsId = tErpSupplierWarehousing.getGoodsId();
+                        String goodsId = tErpSupplierInventoryGoods1.getGoodsId();
                         TErpGoods goods = erpGoodsMapper.selectById(goodsId);
                         int count = tErpSupplierInventoryGoods1.getInventoryCount() - tErpSupplierInventoryGoods1.getDamagedCount();
                         BigDecimal multiply = goods.getSalesAmount().multiply(new BigDecimal(count));
@@ -124,7 +125,7 @@
                         List<TErpClinicOutboundGoods> tErpSupplierOutboundGoods = erpClinicOutboundGoodsMapper.selectList(new LambdaQueryWrapper<TErpClinicOutboundGoods>().eq(TErpClinicOutboundGoods::getOutboundId, tErpSupplierOutbound.getId()));
                         for (TErpClinicOutboundGoods tErpSupplierOutboundGood : tErpSupplierOutboundGoods) {
                             TErpClinicWarehousing tErpSupplierWarehousing = erpClinicWarehousingMapper.selectById(tErpSupplierOutboundGood.getWarehousingId());
-                            String goodsId = tErpSupplierWarehousing.getGoodsId();
+                            String goodsId = tErpSupplierInventoryGoods1.getGoodsId();
                             TErpGoods goods = erpGoodsMapper.selectById(goodsId);
                             int count = tErpSupplierInventoryGoods1.getInventoryCount() - tErpSupplierInventoryGoods1.getDamagedCount();
                             BigDecimal multiply = goods.getSalesAmount().multiply(new BigDecimal(count));
@@ -158,7 +159,7 @@
                 InventoryDetailVo inventoryDetailVo = new InventoryDetailVo();
                 if(tErpSupplierInventoryGood.getInventoryType()==1){
                     TErpClinicWarehousing tErpSupplierWarehousing = erpClinicWarehousingMapper.selectById(tErpSupplierInventoryGood.getWarehousingId());
-                    String goodsId = tErpSupplierWarehousing.getGoodsId();
+                    String goodsId = tErpSupplierInventoryGood.getGoodsId();
                     TErpGoods goods = erpGoodsMapper.selectById(goodsId);
                     inventoryDetailVo.setGoodsName(goods.getGoodsName());
                     TErpGoodsUnit tErpGoodsUnit = erpGoodsUnitMapper.selectById(goods.getPackingUnitId());
@@ -237,5 +238,124 @@
         pageInfo.setRecords(list);
         return pageInfo;
     }
+
+    @Override
+    public PageInfo<TErpClinicWarehousePageListVO> warehousePageList(TClinicWarehouseQuery query, SysUser user, String supplierClinicId) {
+        String time = query.getTime();
+        String sTime =null;
+        String eTime = null;
+        if(time!=null && !time.isEmpty()){
+            String[] split = time.split(" - ");
+            sTime = split[0] + " 00:00:00";
+            eTime = split[1] + " 23:59:59";
+        }
+        PageInfo<TErpClinicWarehousePageListVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
+        List<TErpClinicWarehousePageListVO> list = this.baseMapper.warehousePageList(query,pageInfo,user,supplierClinicId,sTime,eTime);
+        if(list.isEmpty()){
+            return pageInfo;
+        }
+        List<String> collect = list.stream().map(TErpClinicWarehousePageListVO::getId).collect(Collectors.toList());
+        List<TErpClinicWarehousingBatch> tErpClinicWarehousingBatches = erpClinicWarehousingBatchMapper.selectList(new LambdaQueryWrapper<TErpClinicWarehousingBatch>().in(TErpClinicWarehousingBatch::getWarehousingId, collect));
+
+        for (TErpClinicWarehousePageListVO tErpClinicWarehousePageListVO : list) {
+            int size = tErpClinicWarehousingBatches.stream().filter(e -> e.getWarehousingId().equals(tErpClinicWarehousePageListVO.getId())).map(TErpClinicWarehousingBatch::getGoodsId).collect(Collectors.toSet()).size();
+            tErpClinicWarehousePageListVO.setTypeNum(size);
+        }
+        pageInfo.setRecords(list);
+        return pageInfo;
+    }
+
+    @Override
+    public PageInfo<TErpClinicOutboundPageListVO> outboundPageList(TClinicOutboundQuery query, SysUser user, String supplierClinicId) {
+        String time = query.getTime();
+        String sTime =null;
+        String eTime = null;
+        if(time!=null && !time.isEmpty()){
+            String[] split = time.split(" - ");
+            sTime = split[0] + " 00:00:00";
+            eTime = split[1] + " 23:59:59";
+        }
+        PageInfo<TErpClinicOutboundPageListVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
+        List<TErpClinicOutboundPageListVO> list = this.baseMapper.outboundPageList(query,pageInfo,user,supplierClinicId,sTime,eTime);
+        pageInfo.setRecords(list);
+        return pageInfo;
+    }
+
+    @Override
+    public void warehouseGoods(List<clinicWarehouseGoodsDto> dtos, SysUser user, String supplierClinicId) {
+
+        // dtos根据供应商分组
+        Map<String, List<clinicWarehouseGoodsDto>> collect = dtos.stream().collect(Collectors.groupingBy(clinicWarehouseGoodsDto::getSupplierId));
+
+        for (Map.Entry<String, List<clinicWarehouseGoodsDto>> stringListEntry : collect.entrySet()) {
+            String key = stringListEntry.getKey();
+            List<clinicWarehouseGoodsDto> value = stringListEntry.getValue();
+            TErpClinicWarehousing tErpClinicWarehousing = new TErpClinicWarehousing();
+            tErpClinicWarehousing.setClinicId(supplierClinicId);
+            tErpClinicWarehousing.setCreateId(user.getUserId().toString());
+            tErpClinicWarehousing.setWarehouseNo("G"+ DateUtils.dateTimeNow());
+            tErpClinicWarehousing.setCreateTime(LocalDateTime.now());
+            tErpClinicWarehousing.setSupplierId(key);
+            tErpClinicWarehousing.setType(3);
+            this.save(tErpClinicWarehousing);
+
+            BigDecimal totalPrice = new BigDecimal(0);
+            for (clinicWarehouseGoodsDto dto : value) {
+                TErpClinicWarehousingBatch tErpClinicWarehousingBatch = new TErpClinicWarehousingBatch();
+                tErpClinicWarehousingBatch.setWarehousingId(tErpClinicWarehousing.getId());
+                tErpClinicWarehousingBatch.setWarehousingNumber(dto.getPurchaseCount());
+                tErpClinicWarehousingBatch.setBatchNumber(dto.getBatchNumber());
+                tErpClinicWarehousingBatch.setProductionDate(dto.getProductionDate());
+                tErpClinicWarehousingBatch.setExpiryDate(dto.getExpiryDate());
+                tErpClinicWarehousingBatch.setGoodsId(dto.getId());
+                TErpGoods goods = erpGoodsMapper.selectById(dto.getId());
+                tErpClinicWarehousingBatch.setGoodsName(goods.getGoodsName());
+                tErpClinicWarehousingBatch.setQuasiNumber(goods.getQuasiNumber());
+                tErpClinicWarehousingBatch.setUnitAmount(dto.getUnitAmount());
+                tErpClinicWarehousingBatch.setSalesAmount(dto.getSalesAmount());
+                if(dto.getSalesAmount()==null){
+                    tErpClinicWarehousingBatch.setSalesAmount(goods.getClinicPurchasePrice());
+                }
+                tErpClinicWarehousingBatch.setPurchaseCount(dto.getPurchaseCount());
+                erpClinicWarehousingBatchMapper.insert(tErpClinicWarehousingBatch);
+
+                totalPrice = totalPrice.add(dto.getSalesAmount().multiply(new BigDecimal(dto.getPurchaseCount())));
+            }
+            tErpClinicWarehousing.setTotalPrice(totalPrice);
+            this.updateById(tErpClinicWarehousing);
+
+        }
+
+    }
+
+    @Override
+    public void outboundGoods(ClinicOutboundGoodsDto dto, SysUser user, String supplierClinicId) {
+        TErpClinicOutbound tErpClinicOutbound = new TErpClinicOutbound();
+        tErpClinicOutbound.setClinicId(supplierClinicId);
+        tErpClinicOutbound.setCreateId(user.getUserId().toString());
+        tErpClinicOutbound.setOutboundNumber("G"+ DateUtils.dateTimeNow());
+        tErpClinicOutbound.setCreateTime(LocalDateTime.now());
+        tErpClinicOutbound.setOutboundType(dto.getOutboundType());
+        tErpClinicOutbound.setTotalMoney(dto.getTotalPrice());
+        tErpClinicOutbound.setOutboundReason(dto.getOutboundReason());
+        tErpClinicOutbound.setTypeNum(dto.getTypeNum());
+        erpClinicOutboundMapper.insert(tErpClinicOutbound);
+
+        List<TErpClinicOutboundGoods> tErpClinicOutboundGoods = new ArrayList<>();
+        for (OutboundGoodsNextDto outboundGoodsNextDto : dto.getOutboundGoodsNextDtos()) {
+            TErpClinicOutboundGoods tErpClinicOutboundGoods1 = new TErpClinicOutboundGoods();
+            tErpClinicOutboundGoods1.setOutboundId(tErpClinicOutbound.getId());
+            String batchId = outboundGoodsNextDto.getBatchId();
+            TErpClinicWarehousingBatch tErpClinicWarehousingBatch = erpClinicWarehousingBatchMapper.selectById(batchId);
+            tErpClinicOutboundGoods1.setWarehousingId(tErpClinicWarehousingBatch.getWarehousingId());
+            tErpClinicOutboundGoods1.setWarehousingBatchId(batchId);
+            tErpClinicOutboundGoods1.setOutboundCount(outboundGoodsNextDto.getNum());
+            tErpClinicOutboundGoods1.setTotalPrice(tErpClinicWarehousingBatch.getUnitAmount().multiply(BigDecimal.valueOf(outboundGoodsNextDto.getNum())));
+            tErpClinicOutboundGoods1.setGoodsId(tErpClinicWarehousingBatch.getGoodsId());
+            tErpClinicOutboundGoods.add(tErpClinicOutboundGoods1);
+            erpClinicOutboundGoodsMapper.insert(tErpClinicOutboundGoods1);
+        }
+
+    }
 }
 

--
Gitblit v1.7.1