xiaoyi
2 天以前 14c80fbd16a51a355138345ecf69df9ca37746bf
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/returnsales/MesWmReturnSalesServiceImpl.java
@@ -19,12 +19,14 @@
import cn.iocoder.yudao.module.mes.enums.wm.MesWmReturnSalesStatusEnum;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmTransactionTypeEnum;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.aftersales.api.AfterSaleTicketApi;
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
import cn.iocoder.yudao.module.mes.service.wm.transaction.MesWmTransactionService;
import cn.iocoder.yudao.module.mes.service.wm.transaction.dto.MesWmTransactionSaveReqDTO;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.validation.annotation.Validated;
import java.math.BigDecimal;
@@ -33,6 +35,7 @@
import java.util.Map;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.invalidParamException;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
@@ -58,6 +61,8 @@
    private MesMdmItemService mdmItemService;
    @Resource
    private MesWmTransactionService wmTransactionService;
    @Resource
    private ObjectProvider<AfterSaleTicketApi> afterSaleTicketApiProvider;
    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -183,6 +188,13 @@
        // 3. 更新退货单状态
        returnSalesMapper.updateById(new MesWmReturnSalesDO()
                .setId(id).setStatus(MesWmReturnSalesStatusEnum.FINISHED.getStatus()));
        if (returnSales.getAfterSaleReturnId() != null) {
            AfterSaleTicketApi api = afterSaleTicketApiProvider.getIfAvailable();
            if (api == null) throw invalidParamException("售后服务不可用,无法同步退货入库状态");
            var response = api.onReturnInboundFinished(returnSales.getAfterSaleReturnId());
            if (response == null || !Boolean.TRUE.equals(response.getCheckedData()))
                throw invalidParamException("售后退货入库状态同步失败");
        }
    }
    private void createTransactionList(MesWmReturnSalesDO returnSales) {