java/haizhentong.git

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

			}
			}