出库配送明细增删改;

This commit is contained in:
王奎兴
2026-05-28 17:42:23 +08:00
parent c5adb68fc9
commit 6586b1cd73
2 changed files with 22 additions and 3 deletions
@@ -109,11 +109,16 @@ public class ReservationStockOutOrderDomainService {
if (stockOutOrderDO.getCheckTaskDistribution() == null) { if (stockOutOrderDO.getCheckTaskDistribution() == null) {
stockOutOrderDO.setCheckTaskDistribution(2); stockOutOrderDO.setCheckTaskDistribution(2);
} }
stockOutOrderService.insert(stockOutOrderDO);
List<ReservationDeliveryDetailsLink> reservationDeliveryDetailsLinkList = stockOutOrderDO.getReservationDeliveryDetailsLinkList(); List<ReservationDeliveryDetailsLink> reservationDeliveryDetailsLinkList = stockOutOrderDO.getReservationDeliveryDetailsLinkList();
reservationDeliveryDetailsLinkList.forEach(reservationDeliveryDetailsLink -> {
reservationDeliveryDetailsLink.setOrderNumber(stockOutOrderDO.getOutOrderNumber());
reservationDeliveryDetailsLink.setOrderId(stockOutOrderDO.getOutOrderId());
});
if (!CollectionUtils.isEmpty(reservationDeliveryDetailsLinkList)) { if (!CollectionUtils.isEmpty(reservationDeliveryDetailsLinkList)) {
reservationDeliveryDetailsLinkService.saveBatch(reservationDeliveryDetailsLinkList); reservationDeliveryDetailsLinkService.saveBatch(reservationDeliveryDetailsLinkList);
} }
stockOutOrderService.insert(stockOutOrderDO);
return outMaterialDetailService.batchInsert(stockOutOrderDO.getOutOrderNumber(), stockOutOrderDO.getMaterialDetailList()); return outMaterialDetailService.batchInsert(stockOutOrderDO.getOutOrderNumber(), stockOutOrderDO.getMaterialDetailList());
} }
@@ -82,6 +82,7 @@ import com.mhd.wms.domain.taskShelfMaterialDetail.repository.facade.ITaskShelfMa
import com.mhd.wms.domain.taskShelfMaterialDetail.repository.todo.TaskShelfMaterialDetailDO; import com.mhd.wms.domain.taskShelfMaterialDetail.repository.todo.TaskShelfMaterialDetailDO;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@@ -1269,7 +1270,8 @@ public class StockShelfOrderDomainService {
materialInventoryOmsParamDO.setKctzType("入库"); materialInventoryOmsParamDO.setKctzType("入库");
materialInventoryOmsParamDO.setLoginUser(loginUser); materialInventoryOmsParamDO.setLoginUser(loginUser);
materialInventoryOmsParamDO.setMaterialInventoryId(null); materialInventoryOmsParamDO.setMaterialInventoryId(null);
omsServiceFeign.omsEdit(materialInventoryOmsParamDO); //omsServiceFeign.omsEdit(materialInventoryOmsParamDO);
asyncOmsEdit(materialInventoryOmsParamDO);
//抄码商品对照数据插入 //抄码商品对照数据插入
copyCodeProductComparison(materialBaseInfo,shelfMaterialDetail,inventoryParamDO); copyCodeProductComparison(materialBaseInfo,shelfMaterialDetail,inventoryParamDO);
} else if (materialInventoryPOS.size() == 1) { } else if (materialInventoryPOS.size() == 1) {
@@ -1338,13 +1340,25 @@ public class StockShelfOrderDomainService {
materialInventoryOmsParamDO.setTopOrganizationId(shelfMaterialDetail.getTopOrganizationId()); materialInventoryOmsParamDO.setTopOrganizationId(shelfMaterialDetail.getTopOrganizationId());
materialInventoryOmsParamDO.setOrganizationId(shelfMaterialDetail.getOrganizationId()); materialInventoryOmsParamDO.setOrganizationId(shelfMaterialDetail.getOrganizationId());
materialInventoryOmsParamDO.setOrganizationName(shelfMaterialDetail.getOrganizationName()); materialInventoryOmsParamDO.setOrganizationName(shelfMaterialDetail.getOrganizationName());
omsServiceFeign.omsEdit(materialInventoryOmsParamDO); //omsServiceFeign.omsEdit(materialInventoryOmsParamDO);
asyncOmsEdit(materialInventoryOmsParamDO);
//抄码商品对照数据插入 //抄码商品对照数据插入
copyCodeProductComparison(materialBaseInfo,shelfMaterialDetail,inventoryParamDO); copyCodeProductComparison(materialBaseInfo,shelfMaterialDetail,inventoryParamDO);
} }
} }
} }
// 核心注解:表示这是一个异步方法
@Async
public void asyncOmsEdit(MaterialInventoryOmsParamDO materialInventoryOmsParamDO) {
try {
omsServiceFeign.omsEdit(materialInventoryOmsParamDO); // 异步执行,不阻塞主线程
} catch (Exception e) {
// 异步调用失败可以打日志、发告警、落库,不影响主流程
log.error("异步调用omsEdit失败:{}", e.getMessage());
}
}
/** /**
* 上架完成、库存入账后写入抄码对照表。数据来自上架明细 {@link ShelfMaterialDetail#getCopyDetails()} * 上架完成、库存入账后写入抄码对照表。数据来自上架明细 {@link ShelfMaterialDetail#getCopyDetails()}
* 与收货明细/PDA 提交的 JSON 一致:key 为序号(字符串),value 为单件净重(千克,支持小数如 1.343)。 * 与收货明细/PDA 提交的 JSON 一致:key 为序号(字符串),value 为单件净重(千克,支持小数如 1.343)。