220 lines
7.8 KiB
Java
220 lines
7.8 KiB
Java
package com.klp.service.impl;
|
||
|
||
import cn.hutool.core.bean.BeanUtil;
|
||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||
import com.klp.common.core.page.TableDataInfo;
|
||
import com.klp.common.core.domain.PageQuery;
|
||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||
import com.klp.common.utils.StringUtils;
|
||
import com.klp.domain.bo.WmsPurchasePlanDetailBo;
|
||
import com.klp.domain.vo.WmsPurchasePlanDetailVo;
|
||
import com.klp.domain.vo.WmsRawMaterialVo;
|
||
import com.klp.service.IWmsPurchasePlanDetailService;
|
||
import lombok.RequiredArgsConstructor;
|
||
import org.springframework.stereotype.Service;
|
||
import com.klp.domain.bo.WmsStockBo;
|
||
import com.klp.domain.vo.WmsStockVo;
|
||
import com.klp.domain.WmsStock;
|
||
import com.klp.domain.WmsWarehouse;
|
||
import com.klp.mapper.WmsStockMapper;
|
||
import com.klp.mapper.WmsWarehouseMapper;
|
||
import com.klp.service.IWmsStockService;
|
||
|
||
import java.math.BigDecimal;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
import java.util.Collection;
|
||
import java.util.ArrayList;
|
||
|
||
/**
|
||
* 库存：原材料/产品与库区/库位的存放关系Service业务层处理
|
||
*
|
||
* @author Joshi
|
||
* @date 2025-07-18
|
||
*/
|
||
@RequiredArgsConstructor
|
||
@Service
|
||
public class WmsStockServiceImpl implements IWmsStockService {
|
||
|
||
private final WmsStockMapper baseMapper;
|
||
private final WmsWarehouseMapper warehouseMapper;
|
||
private final IWmsPurchasePlanDetailService purchasePlanDetailService;
|
||
|
||
|
||
/**
|
||
* 查询库存：原材料/产品与库区/库位的存放关系
|
||
*/
|
||
@Override
|
||
public WmsStockVo queryById(Long stockId){
|
||
return baseMapper.selectVoById(stockId);
|
||
}
|
||
|
||
/**
|
||
* 查询库存：原材料/产品与库区/库位的存放关系列表
|
||
*/
|
||
@Override
|
||
public TableDataInfo<WmsStockVo> queryPageList(WmsStockBo bo, PageQuery pageQuery) {
|
||
QueryWrapper<WmsStock> lqw = buildQueryWrapperPlus(bo);
|
||
Page<WmsStockVo> result = baseMapper.selectVoPagePlus(pageQuery.build(), lqw);
|
||
fillDemandInfo(result.getRecords());
|
||
return TableDataInfo.build(result);
|
||
}
|
||
|
||
/**
|
||
* 填充原材料在途信息
|
||
*/
|
||
private void fillDemandInfo(List<WmsStockVo> rawMaterialList) {
|
||
if (rawMaterialList == null || rawMaterialList.isEmpty()) {
|
||
return;
|
||
}
|
||
// 为每个原材料填充信息
|
||
for (WmsStockVo vo : rawMaterialList) {
|
||
Long rawMaterialId = vo.getItemId();
|
||
// 查询在途量（采购计划明细）
|
||
BigDecimal onTheWay = getOnTheWayQuantity(rawMaterialId);
|
||
vo.setOnTheWay(onTheWay);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取在途量
|
||
*/
|
||
private BigDecimal getOnTheWayQuantity(Long rawMaterialId) {
|
||
WmsPurchasePlanDetailBo bo = new WmsPurchasePlanDetailBo();
|
||
bo.setRawMaterialId(rawMaterialId);
|
||
List<WmsPurchasePlanDetailVo> list = purchasePlanDetailService.queryList(bo);
|
||
return list.stream()
|
||
.filter(item -> item.getStatus() != null && item.getStatus() == 1) // 在途状态
|
||
.map(WmsPurchasePlanDetailVo::getQuantity)
|
||
.filter(qty -> qty != null)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
}
|
||
|
||
/**
|
||
* 查询库存：原材料/产品与库区/库位的存放关系列表
|
||
*/
|
||
@Override
|
||
public List<WmsStockVo> queryList(WmsStockBo bo) {
|
||
LambdaQueryWrapper<WmsStock> lqw = buildQueryWrapper(bo);
|
||
return baseMapper.selectVoList(lqw);
|
||
}
|
||
private LambdaQueryWrapper<WmsStock> buildQueryWrapper(WmsStockBo bo) {
|
||
Map<String, Object> params = bo.getParams();
|
||
LambdaQueryWrapper<WmsStock> lqw = new LambdaQueryWrapper<>();
|
||
lqw.eq(StringUtils.isNotBlank(bo.getItemType()), WmsStock::getItemType, bo.getItemType());
|
||
lqw.eq(bo.getItemId() != null, WmsStock::getItemId, bo.getItemId());
|
||
lqw.eq(bo.getQuantity() != null, WmsStock::getQuantity, bo.getQuantity());
|
||
lqw.eq(StringUtils.isNotBlank(bo.getUnit()), WmsStock::getUnit, bo.getUnit());
|
||
lqw.eq(StringUtils.isNotBlank(bo.getBatchNo()), WmsStock::getBatchNo, bo.getBatchNo());
|
||
return lqw;
|
||
}
|
||
|
||
private QueryWrapper<WmsStock> buildQueryWrapperPlus(WmsStockBo bo) { // 注意：这里改用 QueryWrapper 而非 LambdaQueryWrapper
|
||
Map<String, Object> params = bo.getParams();
|
||
QueryWrapper<WmsStock> qw = Wrappers.query(); // 使用普通 QueryWrapper
|
||
qw.eq("s.del_flag", 0); // 手动添加逻辑删除条件
|
||
|
||
// 处理仓库ID查询，支持递归查询子节点
|
||
if (bo.getWarehouseId() != null) {
|
||
List<Long> warehouseIds = getWarehouseIdsWithChildren(bo.getWarehouseId());
|
||
if (warehouseIds.size() == 1) {
|
||
qw.eq("s.warehouse_id", warehouseIds.get(0));
|
||
} else {
|
||
qw.in("s.warehouse_id", warehouseIds);
|
||
}
|
||
}
|
||
|
||
qw.eq(StringUtils.isNotBlank(bo.getItemType()), "s.item_type", bo.getItemType());
|
||
qw.eq(bo.getItemId() != null, "s.item_id", bo.getItemId());
|
||
qw.eq(bo.getQuantity() != null, "s.quantity", bo.getQuantity());
|
||
qw.eq(StringUtils.isNotBlank(bo.getUnit()), "s.unit", bo.getUnit());
|
||
qw.eq(StringUtils.isNotBlank(bo.getBatchNo()), "s.batch_no", bo.getBatchNo());
|
||
|
||
return qw;
|
||
}
|
||
|
||
/**
|
||
* 新增库存：原材料/产品与库区/库位的存放关系
|
||
*/
|
||
@Override
|
||
public Boolean insertByBo(WmsStockBo bo) {
|
||
WmsStock add = BeanUtil.toBean(bo, WmsStock.class);
|
||
validEntityBeforeSave(add);
|
||
boolean flag = baseMapper.insert(add) > 0;
|
||
if (flag) {
|
||
bo.setStockId(add.getStockId());
|
||
}
|
||
return flag;
|
||
}
|
||
|
||
/**
|
||
* 修改库存：原材料/产品与库区/库位的存放关系
|
||
*/
|
||
@Override
|
||
public Boolean updateByBo(WmsStockBo bo) {
|
||
WmsStock update = BeanUtil.toBean(bo, WmsStock.class);
|
||
validEntityBeforeSave(update);
|
||
return baseMapper.updateById(update) > 0;
|
||
}
|
||
|
||
/**
|
||
* 保存前的数据校验
|
||
*/
|
||
private void validEntityBeforeSave(WmsStock entity){
|
||
//TODO 做一些数据校验,如唯一约束
|
||
}
|
||
|
||
/**
|
||
* 批量删除库存：原材料/产品与库区/库位的存放关系
|
||
*/
|
||
@Override
|
||
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
||
if(isValid){
|
||
//TODO 做一些业务上的校验,判断是否需要校验
|
||
}
|
||
return baseMapper.deleteBatchIds(ids) > 0;
|
||
}
|
||
|
||
@Override
|
||
public BigDecimal getStockByItemId(Long rawMaterialId) {
|
||
return baseMapper.getStockByItemId(rawMaterialId);
|
||
}
|
||
|
||
/**
|
||
* 获取指定仓库ID及其所有子仓库ID
|
||
* @param warehouseId 仓库ID
|
||
* @return 包含当前仓库ID和所有子仓库ID的列表
|
||
*/
|
||
private List<Long> getWarehouseIdsWithChildren(Long warehouseId) {
|
||
List<Long> warehouseIds = new ArrayList<>();
|
||
warehouseIds.add(warehouseId); // 添加当前仓库ID
|
||
|
||
// 递归获取所有子仓库ID
|
||
getChildWarehouseIds(warehouseId, warehouseIds);
|
||
|
||
return warehouseIds;
|
||
}
|
||
|
||
/**
|
||
* 递归获取子仓库ID
|
||
* @param parentId 父仓库ID
|
||
* @param warehouseIds 仓库ID列表（用于收集结果）
|
||
*/
|
||
private void getChildWarehouseIds(Long parentId, List<Long> warehouseIds) {
|
||
// 查询直接子仓库
|
||
List<WmsWarehouse> children = warehouseMapper.selectList(
|
||
Wrappers.<WmsWarehouse>lambdaQuery()
|
||
.eq(WmsWarehouse::getParentId, parentId)
|
||
.eq(WmsWarehouse::getDelFlag, 0)
|
||
);
|
||
|
||
// 递归处理每个子仓库
|
||
for (WmsWarehouse child : children) {
|
||
warehouseIds.add(child.getWarehouseId());
|
||
getChildWarehouseIds(child.getWarehouseId(), warehouseIds);
|
||
}
|
||
}
|
||
}
|