package cn.iocoder.yudao.module.mes.service.wm.productsales;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesPageReqVO;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesSaveReqVO;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesShippingReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.salesnotice.MesWmSalesNoticeDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDetailDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesLineDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesMapper;
|
import cn.iocoder.yudao.module.mes.enums.MesBizTypeConstants;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmProductSalesStatusEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmQualityStatusEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmSalesNoticeStatusEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmStockReserveBizTypeEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmTransactionTypeEnum;
|
import cn.iocoder.yudao.module.mes.service.md.client.MesMdClientService;
|
import cn.iocoder.yudao.module.mes.service.wm.materialstock.MesWmMaterialStockService;
|
import cn.iocoder.yudao.module.mes.service.wm.salesnotice.MesWmSalesNoticeService;
|
import cn.iocoder.yudao.module.mes.service.wm.stockreserve.MesWmStockReserveService;
|
import cn.iocoder.yudao.module.mes.service.wm.transaction.MesWmTransactionService;
|
import cn.iocoder.yudao.module.mes.service.wm.transaction.dto.MesWmTransactionSaveReqDTO;
|
import cn.iocoder.yudao.module.erp.api.sale.ErpSaleOrderApi;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.math.BigDecimal;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
|
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
|
|
/**
|
* MES 销售出库单 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
public class MesWmProductSalesServiceImpl implements MesWmProductSalesService {
|
|
@Resource
|
private MesWmProductSalesMapper productSalesMapper;
|
|
@Resource
|
private MesWmProductSalesLineService productSalesLineService;
|
@Resource
|
private MesWmProductSalesDetailService productSalesDetailService;
|
@Resource
|
private MesMdClientService clientService;
|
@Resource
|
private MesWmSalesNoticeService salesNoticeService;
|
@Resource
|
private MesWmTransactionService wmTransactionService;
|
@Resource
|
private MesWmMaterialStockService materialStockService;
|
@Resource
|
private MesWmStockReserveService stockReserveService;
|
|
@Resource
|
private ErpSaleOrderApi saleOrderApi;
|
|
@Override
|
public Long createProductSales(MesWmProductSalesSaveReqVO createReqVO) {
|
// 校验数据
|
validateProductSalesSaveData(null, createReqVO);
|
|
// 插入
|
MesWmProductSalesDO sales = BeanUtils.toBean(createReqVO, MesWmProductSalesDO.class);
|
sales.setStatus(MesWmProductSalesStatusEnum.PREPARE.getStatus());
|
productSalesMapper.insert(sales);
|
return sales.getId();
|
}
|
|
@Override
|
public void updateProductSales(MesWmProductSalesSaveReqVO updateReqVO) {
|
// 校验存在 + 草稿状态
|
validateProductSalesExistsAndDraft(updateReqVO.getId());
|
// 校验数据
|
validateProductSalesSaveData(updateReqVO.getId(), updateReqVO);
|
|
// 更新
|
MesWmProductSalesDO updateObj = BeanUtils.toBean(updateReqVO, MesWmProductSalesDO.class);
|
productSalesMapper.updateById(updateObj);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void deleteProductSales(Long id) {
|
// 校验存在 + 草稿状态
|
validateProductSalesExistsAndDraft(id);
|
|
// 级联删除明细和行
|
productSalesDetailService.deleteProductSalesDetailBySalesId(id);
|
productSalesLineService.deleteProductSalesLineBySalesId(id);
|
// 删除
|
productSalesMapper.deleteById(id);
|
}
|
|
@Override
|
public MesWmProductSalesDO getProductSales(Long id) {
|
return productSalesMapper.selectById(id);
|
}
|
|
@Override
|
public PageResult<MesWmProductSalesDO> getProductSalesPage(MesWmProductSalesPageReqVO pageReqVO) {
|
return productSalesMapper.selectPage(pageReqVO);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void submitProductSales(Long id) {
|
// 校验存在 + 草稿状态
|
validateProductSalesExistsAndDraft(id);
|
// 校验至少有一条行
|
List<MesWmProductSalesLineDO> lines = productSalesLineService.getProductSalesLineListBySalesId(id);
|
if (CollUtil.isEmpty(lines)) {
|
throw exception(WM_PRODUCT_SALES_LINES_EMPTY);
|
}
|
// 校验每行出库数量 > 0
|
for (MesWmProductSalesLineDO line : lines) {
|
if (line.getQuantity() == null || BigDecimal.ZERO.compareTo(line.getQuantity()) >= 0) {
|
throw exception(WM_PRODUCT_SALES_LINE_QUANTITY_INVALID);
|
}
|
}
|
|
// 检查所有行的 oqcCheckFlag：如果有需要 OQC 检验的行，进入待检测状态
|
boolean needOqc = CollectionUtils.anyMatch(lines,
|
line -> Boolean.TRUE.equals(line.getOqcCheckFlag()));
|
if (needOqc) {
|
// 批量初始化 OQC 行的质量状态为"待检验"
|
List<Long> oqcLineIds = convertList(
|
CollectionUtils.filterList(lines, line -> Boolean.TRUE.equals(line.getOqcCheckFlag())),
|
MesWmProductSalesLineDO::getId);
|
productSalesLineService.updateProductSalesLineQualityStatus(oqcLineIds, MesWmQualityStatusEnum.PENDING.getStatus());
|
// 需要检验，进入待检测
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.CONFIRMED.getStatus()));
|
return;
|
}
|
// 不需要检验，直接进入待拣货
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.APPROVING.getStatus()));
|
}
|
|
@Override
|
public boolean checkProductSalesQuantity(Long id) {
|
// 校验每行明细数量之和是否等于行出库数量
|
List<MesWmProductSalesLineDO> lines = productSalesLineService.getProductSalesLineListBySalesId(id);
|
for (MesWmProductSalesLineDO line : lines) {
|
List<MesWmProductSalesDetailDO> details = productSalesDetailService.getProductSalesDetailListByLineId(line.getId());
|
if (CollUtil.isEmpty(details)) {
|
return false;
|
}
|
BigDecimal totalDetailQty = CollectionUtils.getSumValue(details,
|
MesWmProductSalesDetailDO::getQuantity, BigDecimal::add, BigDecimal.ZERO);
|
if (line.getQuantity() != null && totalDetailQty.compareTo(line.getQuantity()) != 0) {
|
return false;
|
}
|
}
|
return true;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void stockProductSales(Long id) {
|
// 校验存在
|
MesWmProductSalesDO sales = validateProductSalesExists(id);
|
if (ObjUtil.notEqual(MesWmProductSalesStatusEnum.APPROVING.getStatus(), sales.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_CANNOT_PICK);
|
}
|
// 校验每行至少有拣货明细，并校验库存充足
|
List<MesWmProductSalesLineDO> lines = productSalesLineService.getProductSalesLineListBySalesId(id);
|
for (MesWmProductSalesLineDO line : lines) {
|
List<MesWmProductSalesDetailDO> details = productSalesDetailService.getProductSalesDetailListByLineId(line.getId());
|
if (CollUtil.isEmpty(details)) {
|
throw exception(WM_PRODUCT_SALES_DETAILS_EMPTY);
|
}
|
// 校验库存充足并创建占用
|
for (MesWmProductSalesDetailDO detail : details) {
|
materialStockService.validateSelectedStock(
|
detail.getMaterialStockId(),
|
detail.getItemId(),
|
detail.getBatchId(),
|
detail.getBatchCode(),
|
detail.getWarehouseId(),
|
detail.getLocationId(),
|
detail.getAreaId(),
|
detail.getQuantity()
|
);
|
// 创建库存占用
|
stockReserveService.createReserve(
|
detail.getMaterialStockId(),
|
MesWmStockReserveBizTypeEnum.PRODUCT_SALES.getType(),
|
id,
|
sales.getCode(),
|
detail.getId(),
|
detail.getItemId(),
|
detail.getQuantity()
|
);
|
}
|
}
|
|
// 执行拣货（待拣货 → 待填写运单）
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.SHIPPING.getStatus()));
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void shippingProductSales(MesWmProductSalesShippingReqVO reqVO) {
|
// 校验存在
|
MesWmProductSalesDO sales = validateProductSalesExists(reqVO.getId());
|
if (ObjUtil.notEqual(MesWmProductSalesStatusEnum.SHIPPING.getStatus(), sales.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_CANNOT_SHIPPING);
|
}
|
|
// 填写运单（待填写运单 → 待执行出库）
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(reqVO.getId())
|
.setCarrier(reqVO.getCarrier())
|
.setShippingNumber(reqVO.getShippingNumber())
|
.setStatus(MesWmProductSalesStatusEnum.APPROVED.getStatus()));
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void finishProductSales(Long id) {
|
// 1. 校验存在
|
MesWmProductSalesDO sales = validateProductSalesExists(id);
|
if (ObjUtil.notEqual(MesWmProductSalesStatusEnum.APPROVED.getStatus(), sales.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_CANNOT_FINISH);
|
}
|
|
// 2. 确认占用转出库（释放占用量）
|
stockReserveService.confirmReserveToOutbound(MesWmStockReserveBizTypeEnum.PRODUCT_SALES.getType(), id);
|
|
// 3. 遍历所有明细，创建库存事务（扣减库存 + 记录流水）
|
createTransactionList(sales);
|
|
// 4. 更新出库单状态
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.FINISHED.getStatus()));
|
|
// 5. 更新关联的发货通知单出库数量和状态
|
if (sales.getNoticeId() != null) {
|
updateSalesNoticeOutCount(sales);
|
}
|
|
// 6. 回写 ERP 销售订单的出库数量和状态
|
updateErpSaleOrderOutCount(sales);
|
}
|
|
/**
|
* 更新发货通知单的出库数量和状态
|
*/
|
private void updateSalesNoticeOutCount(MesWmProductSalesDO sales) {
|
// 获取出库单行
|
List<MesWmProductSalesLineDO> lines = productSalesLineService.getProductSalesLineListBySalesId(sales.getId());
|
if (CollUtil.isEmpty(lines)) {
|
return;
|
}
|
// 遍历行，按 noticeLineId 更新出库数量
|
for (MesWmProductSalesLineDO line : lines) {
|
if (line.getNoticeLineId() != null && line.getQuantity() != null) {
|
salesNoticeService.updateSalesNoticeLineOutCount(line.getNoticeLineId(), line.getQuantity());
|
}
|
}
|
}
|
|
/**
|
* 回写 ERP 销售订单的出库数量和状态
|
*/
|
private void updateErpSaleOrderOutCount(MesWmProductSalesDO sales) {
|
// 获取出库单行
|
List<MesWmProductSalesLineDO> lines = productSalesLineService.getProductSalesLineListBySalesId(sales.getId());
|
if (CollUtil.isEmpty(lines)) {
|
return;
|
}
|
// 用于存储销售订单 ID，避免重复更新
|
Long saleOrderId = null;
|
// 遍历行，按 saleOrderItemId 更新出库数量
|
for (MesWmProductSalesLineDO line : lines) {
|
if (line.getSaleOrderItemId() != null && line.getQuantity() != null) {
|
saleOrderApi.updateOrderItemOutCount(line.getSaleOrderItemId(), line.getQuantity());
|
// 获取销售订单 ID（从第一个有效的明细项获取）
|
if (saleOrderId == null) {
|
cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderItemRespDTO itemDTO =
|
saleOrderApi.getSaleOrderItem(line.getSaleOrderItemId()).getCheckedData();
|
if (itemDTO != null && itemDTO.getOrderId() != null) {
|
saleOrderId = itemDTO.getOrderId();
|
}
|
}
|
}
|
}
|
// 更新销售订单的出库状态
|
if (saleOrderId != null) {
|
saleOrderApi.updateOrderOutStatus(saleOrderId);
|
}
|
}
|
|
private void createTransactionList(MesWmProductSalesDO sales) {
|
List<MesWmProductSalesDetailDO> details = productSalesDetailService.getProductSalesDetailListBySalesId(sales.getId());
|
wmTransactionService.createTransactionList(convertList(details, detail -> new MesWmTransactionSaveReqDTO()
|
.setType(MesWmTransactionTypeEnum.OUT.getType()).setItemId(detail.getItemId())
|
.setQuantity(detail.getQuantity().negate()) // 出库数量为负数
|
.setBatchId(detail.getBatchId()).setBatchCode(detail.getBatchCode())
|
.setWarehouseId(detail.getWarehouseId()).setLocationId(detail.getLocationId()).setAreaId(detail.getAreaId())
|
.setBizType(MesBizTypeConstants.WM_PRODUCT_SALES).setBizId(sales.getId())
|
.setBizCode(sales.getCode()).setBizLineId(detail.getLineId())));
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void cancelProductSales(Long id) {
|
// 校验存在
|
MesWmProductSalesDO sales = validateProductSalesExists(id);
|
// 已完成和已取消不允许取消
|
if (ObjectUtils.equalsAny(sales.getStatus(),
|
MesWmProductSalesStatusEnum.FINISHED.getStatus(),
|
MesWmProductSalesStatusEnum.CANCELED.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_CANNOT_CANCEL);
|
}
|
// 释放库存占用
|
stockReserveService.releaseReserve(MesWmStockReserveBizTypeEnum.PRODUCT_SALES.getType(), id);
|
// 取消
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.CANCELED.getStatus()));
|
}
|
|
@Override
|
public void confirmProductSales(Long id) {
|
// 校验存在 + 待检测状态
|
MesWmProductSalesDO sales = validateProductSalesExists(id);
|
if (ObjUtil.notEqual(MesWmProductSalesStatusEnum.CONFIRMED.getStatus(), sales.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_CANNOT_CONFIRM);
|
}
|
// OQC 检验完成，流转到待拣货
|
productSalesMapper.updateById(new MesWmProductSalesDO()
|
.setId(id).setStatus(MesWmProductSalesStatusEnum.APPROVING.getStatus()));
|
}
|
|
@Override
|
public List<MesWmProductSalesDO> getProductSalesListByClientId(Long clientId) {
|
return productSalesMapper.selectListByClientId(clientId);
|
}
|
|
private void validateProductSalesSaveData(Long id, MesWmProductSalesSaveReqVO reqVO) {
|
// 校验编码唯一
|
validateCodeUnique(id, reqVO.getCode());
|
// 校验客户存在
|
clientService.validateClientExistsAndEnable(reqVO.getClientId());
|
// 校验发货通知单
|
if (reqVO.getNoticeId() != null) {
|
MesWmSalesNoticeDO notice = salesNoticeService.validateSalesNoticeExists(reqVO.getNoticeId());
|
if (ObjUtil.notEqual(notice.getStatus(), MesWmSalesNoticeStatusEnum.APPROVED.getStatus())) {
|
throw exception(WM_SALES_NOTICE_STATUS_NOT_APPROVED);
|
}
|
if (ObjUtil.notEqual(notice.getClientId(), reqVO.getClientId())) {
|
throw exception(WM_SALES_NOTICE_CLIENT_MISMATCH);
|
}
|
}
|
}
|
|
private MesWmProductSalesDO validateProductSalesExists(Long id) {
|
MesWmProductSalesDO sales = productSalesMapper.selectById(id);
|
if (sales == null) {
|
throw exception(WM_PRODUCT_SALES_NOT_EXISTS);
|
}
|
return sales;
|
}
|
|
/**
|
* 校验销售出库单存在且为草稿状态
|
*/
|
@Override
|
public MesWmProductSalesDO validateProductSalesExistsAndDraft(Long id) {
|
MesWmProductSalesDO sales = validateProductSalesExists(id);
|
if (ObjUtil.notEqual(MesWmProductSalesStatusEnum.PREPARE.getStatus(), sales.getStatus())) {
|
throw exception(WM_PRODUCT_SALES_NOT_PREPARE);
|
}
|
return sales;
|
}
|
|
private void validateCodeUnique(Long id, String code) {
|
MesWmProductSalesDO sales = productSalesMapper.selectByCode(code);
|
if (sales == null) {
|
return;
|
}
|
if (ObjUtil.notEqual(id, sales.getId())) {
|
throw exception(WM_PRODUCT_SALES_CODE_DUPLICATE);
|
}
|
}
|
|
@Override
|
public void updateStatus(Long id, Integer status) {
|
productSalesMapper.updateById(new MesWmProductSalesDO().setId(id).setStatus(status));
|
}
|
|
}
|
