feat: 补齐排产约束与缺料校验，新增风险监测，优化隐患通知与招投标联动

xiaoyi

8 天以前 bc31cda78817c62aa552be40f39eccaa03262923

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java

@@ -17,7 +17,7 @@
import cn.iocoder.yudao.module.mes.enums.wm.MesWmOutStatusEnum;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmProductSalesStatusEnum;
import cn.iocoder.yudao.module.mes.service.md.autocode.MesMdAutoCodeRecordService;
import cn.iocoder.yudao.module.mes.service.md.client.MesMdClientService;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.erp.api.sale.ErpSaleOrderApi;
import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderItemRespDTO;
import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderRespDTO;
@@ -51,7 +51,7 @@
    @Resource
    private MesWmSalesNoticeLineService salesNoticeLineService;
    @Resource
    private MesMdClientService clientService;
    private CrmCustomerApi customerApi;

    @Resource
    private ErpSaleOrderApi saleOrderApi;
@@ -66,7 +66,9 @@
    private MesWmSalesNoticeLineMapper salesNoticeLineMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long createSalesNotice(MesWmSalesNoticeSaveReqVO createReqVO) {
        lockReferencedSaleOrder(createReqVO, null);
        // 校验数据
        validateSalesNoticeSave(createReqVO);

@@ -78,9 +80,11 @@
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateSalesNotice(MesWmSalesNoticeSaveReqVO updateReqVO) {
        // 校验存在 + 草稿状态
        validateSalesNoticeExistsAndDraft(updateReqVO.getId());
        MesWmSalesNoticeDO existing = validateSalesNoticeExistsAndDraft(updateReqVO.getId());
        lockReferencedSaleOrder(updateReqVO, existing);
        // 校验数据
        validateSalesNoticeSave(updateReqVO);

@@ -108,7 +112,7 @@

    @Override
    public PageResult<MesWmSalesNoticeDO> getSalesNoticePage(MesWmSalesNoticePageReqVO pageReqVO) {
        return salesNoticeMapper.selectPage(pageReqVO);
        return salesNoticeMapper.selectPage(pageReqVO, (List<Long>) null);
    }

    @Override
@@ -166,8 +170,23 @@
        validateNoticeCodeUnique(saveReqVO.getId(), saveReqVO.getCode());
        // 校验客户存在
        if (saveReqVO.getClientId() != null) {
            clientService.validateClientExistsAndEnable(saveReqVO.getClientId());
            customerApi.validateCustomer(saveReqVO.getClientId());
        }
    }

    /** 与订单作废使用同一订单行锁；支持历史请求仅传订单号。 */
    private void lockReferencedSaleOrder(MesWmSalesNoticeSaveReqVO request, MesWmSalesNoticeDO existing) {
        Long orderId = request.getSaleOrderId();
        String orderNo = request.getSaleOrderCode();
        if (orderId == null && (orderNo == null || orderNo.isBlank()) && existing != null) {
            orderId = existing.getSaleOrderId();
            orderNo = existing.getSaleOrderCode();
        }
        if (orderId == null && (orderNo == null || orderNo.isBlank())) return;
        ErpSaleOrderRespDTO order = saleOrderApi.lockSaleOrderForNotice(orderId, orderNo).getCheckedData();
        if (order == null) throw exception(WM_SALES_NOTICE_SALE_ORDER_NOT_EXISTS);
        request.setSaleOrderId(order.getId());
        request.setSaleOrderCode(order.getNo());
    }

    private void validateNoticeCodeUnique(Long id, String code) {
@@ -183,16 +202,13 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long generateSalesNoticeFromSaleOrder(Long saleOrderId) {
        // 先锁定订单，再检查通知；与订单作废串行执行。
        ErpSaleOrderRespDTO saleOrder = saleOrderApi.lockSaleOrderForNotice(saleOrderId, null).getCheckedData();
        if (saleOrder == null) throw exception(WM_SALES_NOTICE_SALE_ORDER_NOT_EXISTS);
        // 1. 校验是否已生成过发货通知单（防止重复生成）
        MesWmSalesNoticeDO existNotice = salesNoticeMapper.selectBySaleOrderId(saleOrderId);
        if (existNotice != null) {
            throw exception(WM_SALES_NOTICE_ALREADY_EXISTS);
        }

        // 2. 获取销售订单信息
        ErpSaleOrderRespDTO saleOrder = saleOrderApi.getSaleOrder(saleOrderId).getCheckedData();
        if (saleOrder == null) {
            throw exception(WM_SALES_NOTICE_SALE_ORDER_NOT_EXISTS);
        }

        // 3. 获取销售订单明细