package cn.iocoder.yudao.module.mes.service.wm.salesnotice;
|
|
import cn.hutool.core.util.ObjUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.salesnotice.vo.line.MesWmSalesNoticeLinePageReqVO;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.salesnotice.vo.line.MesWmSalesNoticeLineSaveReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.batch.MesWmBatchDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.materialstock.MesWmMaterialStockDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.salesnotice.MesWmSalesNoticeDO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.salesnotice.MesWmSalesNoticeLineDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.wm.salesnotice.MesWmSalesNoticeLineMapper;
|
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
|
import cn.iocoder.yudao.module.mes.service.wm.batch.MesWmBatchService;
|
import cn.iocoder.yudao.module.mes.service.wm.materialstock.MesWmMaterialStockService;
|
import jakarta.annotation.Resource;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
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.module.mes.enums.ErrorCodeConstants.*;
|
import static cn.iocoder.yudao.module.mes.enums.wm.MesWmSalesNoticeStatusEnum.PREPARE;
|
|
/**
|
* MES 发货通知单行 Service 实现类
|
*/
|
@Service
|
@Validated
|
public class MesWmSalesNoticeLineServiceImpl implements MesWmSalesNoticeLineService {
|
|
@Resource
|
private MesWmSalesNoticeLineMapper salesNoticeLineMapper;
|
|
@Resource
|
@Lazy
|
private MesWmSalesNoticeService salesNoticeService;
|
@Resource
|
private MesWmBatchService batchService;
|
@Resource
|
private MesWmMaterialStockService materialStockService;
|
@Resource
|
private MesMdmItemService mdmItemService;
|
|
@Override
|
public Long createSalesNoticeLine(MesWmSalesNoticeLineSaveReqVO createReqVO) {
|
// 校验数据
|
validateLineSaveData(createReqVO);
|
|
// 插入
|
MesWmSalesNoticeLineDO line = BeanUtils.toBean(createReqVO, MesWmSalesNoticeLineDO.class);
|
fillBatchId(line);
|
salesNoticeLineMapper.insert(line);
|
return line.getId();
|
}
|
|
@Override
|
public void updateSalesNoticeLine(MesWmSalesNoticeLineSaveReqVO updateReqVO) {
|
// 校验存在
|
MesWmSalesNoticeLineDO line = validateSalesNoticeLineExists(updateReqVO.getId());
|
// 校验数据
|
updateReqVO.setNoticeId(line.getNoticeId());
|
validateLineSaveData(updateReqVO);
|
|
// 更新
|
MesWmSalesNoticeLineDO updateObj = BeanUtils.toBean(updateReqVO, MesWmSalesNoticeLineDO.class);
|
fillBatchId(updateObj);
|
salesNoticeLineMapper.updateById(updateObj);
|
}
|
|
@Override
|
public void deleteSalesNoticeLine(Long id) {
|
// 校验存在
|
MesWmSalesNoticeLineDO line = validateSalesNoticeLineExists(id);
|
// 校验父单据存在且为草稿状态
|
validateNoticeStatusDraft(line.getNoticeId());
|
|
// 删除
|
salesNoticeLineMapper.deleteById(id);
|
}
|
|
@Override
|
public MesWmSalesNoticeLineDO getSalesNoticeLine(Long id) {
|
return salesNoticeLineMapper.selectById(id);
|
}
|
|
@Override
|
public PageResult<MesWmSalesNoticeLineDO> getSalesNoticeLinePage(MesWmSalesNoticeLinePageReqVO pageReqVO) {
|
return salesNoticeLineMapper.selectPage(pageReqVO);
|
}
|
|
@Override
|
public List<MesWmSalesNoticeLineDO> getSalesNoticeLineListByNoticeId(Long noticeId) {
|
return salesNoticeLineMapper.selectListByNoticeId(noticeId);
|
}
|
|
@Override
|
public void deleteSalesNoticeLineByNoticeId(Long noticeId) {
|
salesNoticeLineMapper.deleteByNoticeId(noticeId);
|
}
|
|
@Override
|
public MesWmSalesNoticeLineDO validateSalesNoticeLineExists(Long id) {
|
MesWmSalesNoticeLineDO line = salesNoticeLineMapper.selectById(id);
|
if (line == null) {
|
throw exception(WM_SALES_NOTICE_LINE_NOT_EXISTS);
|
}
|
return line;
|
}
|
|
@Override
|
public MesWmSalesNoticeLineDO validateSalesNoticeLineExists(Long lineId, Long noticeId) {
|
MesWmSalesNoticeLineDO line = validateSalesNoticeLineExists(lineId);
|
// 进一步校验行的 noticeId 与传入的 noticeId 是否匹配
|
if (noticeId != null && ObjUtil.notEqual(line.getNoticeId(), noticeId)) {
|
throw exception(WM_SALES_NOTICE_LINE_NOT_MATCH);
|
}
|
return line;
|
}
|
|
private void validateLineSaveData(MesWmSalesNoticeLineSaveReqVO reqVO) {
|
validateNoticeStatusDraft(reqVO.getNoticeId());
|
mdmItemService.validateItemExistsAndEnable(reqVO.getItemId());
|
|
MesWmBatchDO batch = resolveBatch(reqVO);
|
if (batch == null) {
|
throw exception(WM_MATERIAL_STOCK_NOT_EXISTS);
|
}
|
if (ObjUtil.notEqual(batch.getItemId(), reqVO.getItemId())) {
|
throw exception(WM_MATERIAL_STOCK_NOT_EXISTS);
|
}
|
BigDecimal qualifiedQuantity = materialStockService
|
.getQualifiedMaterialStockListByItemAndBatch(reqVO.getItemId(), batch.getId()).stream()
|
.map(MesWmMaterialStockDO::getQuantity)
|
.filter(quantity -> quantity != null)
|
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
if (qualifiedQuantity.compareTo(reqVO.getQuantity()) < 0) {
|
throw exception(WM_MATERIAL_STOCK_INSUFFICIENT);
|
}
|
reqVO.setBatchId(batch.getId());
|
reqVO.setBatchCode(batch.getCode());
|
}
|
|
private MesWmBatchDO resolveBatch(MesWmSalesNoticeLineSaveReqVO reqVO) {
|
if (reqVO.getBatchId() != null) {
|
return batchService.getBatch(reqVO.getBatchId());
|
}
|
if (StrUtil.isNotBlank(reqVO.getBatchCode())) {
|
return batchService.getBatchByCode(reqVO.getBatchCode());
|
}
|
return null;
|
}
|
|
/**
|
* 校验父发货通知单存在且为草稿状态
|
*/
|
private void validateNoticeStatusDraft(Long noticeId) {
|
MesWmSalesNoticeDO notice = salesNoticeService.getSalesNotice(noticeId);
|
if (notice == null) {
|
throw exception(WM_SALES_NOTICE_NOT_EXISTS);
|
}
|
if (ObjUtil.notEqual(PREPARE.getStatus(), notice.getStatus())) {
|
throw exception(WM_SALES_NOTICE_STATUS_NOT_ALLOW_UPDATE);
|
}
|
}
|
|
/**
|
* 根据 batchCode 回填 batchId
|
*/
|
private void fillBatchId(MesWmSalesNoticeLineDO line) {
|
if (StrUtil.isEmpty(line.getBatchCode())) {
|
return;
|
}
|
MesWmBatchDO batch = batchService.getBatchByCode(line.getBatchCode());
|
if (batch != null) {
|
line.setBatchId(batch.getId());
|
}
|
}
|
|
@Override
|
public void createSalesNoticeLine(MesWmSalesNoticeLineDO line) {
|
salesNoticeLineMapper.insert(line);
|
}
|
|
}
|
