From 1c1daebcb9f89138a84e9a7643d1909bb1a5a342 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 14 七月 2026 10:27:31 +0800
Subject: [PATCH] 1.仓储物流-自定义出入库分别新增接口
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java | 201 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 201 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java
index 30a2777..c2b964c 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/salesnotice/MesWmSalesNoticeServiceImpl.java
@@ -6,16 +6,28 @@
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.wm.salesnotice.vo.MesWmSalesNoticePageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.salesnotice.vo.MesWmSalesNoticeSaveReqVO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesLineDO;
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.productsales.MesWmProductSalesMapper;
+import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesLineMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.salesnotice.MesWmSalesNoticeMapper;
+import cn.iocoder.yudao.module.mes.dal.mysql.wm.salesnotice.MesWmSalesNoticeLineMapper;
+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.erp.api.sale.ErpSaleOrderApi;
+import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderItemRespDTO;
+import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderRespDTO;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
+import java.math.BigDecimal;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
@@ -39,6 +51,18 @@
private MesWmSalesNoticeLineService salesNoticeLineService;
@Resource
private MesMdClientService clientService;
+
+ @Resource
+ private ErpSaleOrderApi saleOrderApi;
+ @Resource
+ private MesMdAutoCodeRecordService autoCodeRecordService;
+
+ @Resource
+ private MesWmProductSalesMapper productSalesMapper;
+ @Resource
+ private MesWmProductSalesLineMapper productSalesLineMapper;
+ @Resource
+ private MesWmSalesNoticeLineMapper salesNoticeLineMapper;
@Override
public Long createSalesNotice(MesWmSalesNoticeSaveReqVO createReqVO) {
@@ -149,4 +173,181 @@
}
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Long generateSalesNoticeFromSaleOrder(Long saleOrderId) {
+ // 1. 鑾峰彇閿�鍞鍗曚俊鎭�
+ ErpSaleOrderRespDTO saleOrder = saleOrderApi.getSaleOrder(saleOrderId).getCheckedData();
+ if (saleOrder == null) {
+ throw exception(WM_SALES_NOTICE_SALE_ORDER_NOT_EXISTS);
+ }
+
+ // 2. 鑾峰彇閿�鍞鍗曟槑缁�
+ List<ErpSaleOrderItemRespDTO> saleOrderItems = saleOrderApi.getSaleOrderItemList(saleOrderId).getCheckedData();
+ if (CollUtil.isEmpty(saleOrderItems)) {
+ throw exception(WM_SALES_NOTICE_SALE_ORDER_ITEM_EMPTY);
+ }
+
+ // 3. 鐢熸垚鍙戣揣閫氱煡鍗曠紪鐮�
+ String code = autoCodeRecordService.generateAutoCode("SALESNOTICE_CODE", null);
+
+ // 4. 鍒涘缓鍙戣揣閫氱煡鍗曚富琛�
+ MesWmSalesNoticeDO notice = new MesWmSalesNoticeDO();
+ notice.setCode(code);
+ notice.setName("閿�鍞鍗昜" + saleOrder.getNo() + "]鍙戣揣閫氱煡");
+ notice.setClientId(saleOrder.getCustomerId());
+ notice.setSaleOrderId(saleOrderId);
+ notice.setSaleOrderCode(saleOrder.getNo());
+ notice.setSalesDate(java.time.LocalDateTime.now());
+ notice.setStatus(PREPARE.getStatus());
+ salesNoticeMapper.insert(notice);
+
+ // 5. 閬嶅巻鏄庣粏鍒涘缓鍙戣揣閫氱煡鍗曡
+ for (ErpSaleOrderItemRespDTO saleOrderItem : saleOrderItems) {
+ MesWmSalesNoticeLineDO line = new MesWmSalesNoticeLineDO();
+ line.setNoticeId(notice.getId());
+ line.setSaleOrderItemId(saleOrderItem.getId());
+ line.setItemId(saleOrderItem.getProductId());
+ line.setQuantity(saleOrderItem.getCount());
+ salesNoticeLineService.createSalesNoticeLine(line);
+ }
+
+ return notice.getId();
+ }
+
+ @Override
+ public void finishSalesNotice(Long id) {
+ // 宸插簾寮冿紝淇濈暀鍏煎鎬�
+ updateSalesNoticeOutStatus(id);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void updateSalesNoticeLineOutCount(Long noticeLineId, BigDecimal outCount) {
+ if (noticeLineId == null || outCount == null) {
+ return;
+ }
+ // 1. 鑾峰彇鍙戣揣閫氱煡鍗曡
+ MesWmSalesNoticeLineDO line = salesNoticeLineMapper.selectById(noticeLineId);
+ if (line == null) {
+ return;
+ }
+ // 2. 绱姞鍑哄簱鏁伴噺
+ BigDecimal newOutCount = (line.getOutCount() != null ? line.getOutCount() : BigDecimal.ZERO).add(outCount);
+ // 3. 鏇存柊琛�
+ salesNoticeLineMapper.updateById(new MesWmSalesNoticeLineDO()
+ .setId(noticeLineId)
+ .setOutCount(newOutCount));
+ // 4. 鏇存柊涓诲崟鍑哄簱鐘舵��
+ updateSalesNoticeOutStatus(line.getNoticeId());
+ }
+
+ @Override
+ public void updateSalesNoticeOutStatus(Long noticeId) {
+ if (noticeId == null) {
+ return;
+ }
+ // 1. 鑾峰彇鍙戣揣閫氱煡鍗�
+ MesWmSalesNoticeDO notice = salesNoticeMapper.selectById(noticeId);
+ if (notice == null) {
+ return;
+ }
+ // 2. 鑾峰彇鍙戣揣閫氱煡鍗曡
+ List<MesWmSalesNoticeLineDO> lines = salesNoticeLineMapper.selectListByNoticeId(noticeId);
+ if (CollUtil.isEmpty(lines)) {
+ return;
+ }
+ // 3. 璁＄畻鍑哄簱鐘舵��
+ int outStatus = calculateOutStatus(lines);
+ // 4. 鏇存柊鍑哄簱鐘舵��
+ salesNoticeMapper.updateById(new MesWmSalesNoticeDO()
+ .setId(noticeId)
+ .setOutStatus(outStatus));
+ // 5. 濡傛灉鍏ㄩ儴鍑哄簱锛屾洿鏂板崟鎹姸鎬佷负宸插畬鎴�
+ if (outStatus == MesWmOutStatusEnum.ALL_OUT.getStatus()) {
+ salesNoticeMapper.updateById(new MesWmSalesNoticeDO()
+ .setId(noticeId)
+ .setStatus(FINISHED.getStatus()));
+ }
+ }
+
+ /**
+ * 璁＄畻鍑哄簱鐘舵��
+ */
+ private int calculateOutStatus(List<MesWmSalesNoticeLineDO> lines) {
+ boolean allOut = true;
+ boolean anyOut = false;
+
+ for (MesWmSalesNoticeLineDO line : lines) {
+ BigDecimal quantity = line.getQuantity() != null ? line.getQuantity() : BigDecimal.ZERO;
+ BigDecimal outCount = line.getOutCount() != null ? line.getOutCount() : BigDecimal.ZERO;
+
+ if (outCount.compareTo(BigDecimal.ZERO) > 0) {
+ anyOut = true;
+ }
+ if (outCount.compareTo(quantity) < 0) {
+ allOut = false;
+ }
+ }
+
+ if (allOut) {
+ return MesWmOutStatusEnum.ALL_OUT.getStatus();
+ } else if (anyOut) {
+ return MesWmOutStatusEnum.PART_OUT.getStatus();
+ } else {
+ return MesWmOutStatusEnum.NOT_OUT.getStatus();
+ }
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Long generateProductSalesFromNotice(Long noticeId) {
+ // 1. 鏍￠獙鍙戣揣閫氱煡鍗曞瓨鍦ㄤ笖涓哄緟鍑哄簱鐘舵��
+ MesWmSalesNoticeDO notice = validateSalesNoticeExists(noticeId);
+ if (ObjUtil.notEqual(APPROVED.getStatus(), notice.getStatus())) {
+ throw exception(WM_SALES_NOTICE_STATUS_NOT_APPROVED);
+ }
+
+ // 2. 鑾峰彇鍙戣揣閫氱煡鍗曡
+ List<MesWmSalesNoticeLineDO> noticeLines = salesNoticeLineService.getSalesNoticeLineListByNoticeId(noticeId);
+ if (CollUtil.isEmpty(noticeLines)) {
+ throw exception(WM_SALES_NOTICE_LINE_EMPTY);
+ }
+
+ // 3. 鐢熸垚閿�鍞嚭搴撳崟缂栫爜
+ String code = autoCodeRecordService.generateAutoCode("WM_PRODUCT_SALES_CODE", null);
+
+ // 4. 鍒涘缓閿�鍞嚭搴撳崟涓昏〃
+ MesWmProductSalesDO productSales = new MesWmProductSalesDO();
+ productSales.setCode(code);
+ productSales.setName("鍙戣揣閫氱煡鍗昜" + notice.getCode() + "]鍑哄簱");
+ productSales.setClientId(notice.getClientId());
+ productSales.setSaleOrderId(notice.getSaleOrderId());
+ productSales.setSalesOrderCode(notice.getSaleOrderCode());
+ productSales.setNoticeId(noticeId);
+ productSales.setSalesDate(notice.getSalesDate());
+ // 鏀惰揣淇℃伅浠庡彂璐ч�氱煡鍗曞甫鍏�
+ productSales.setContactName(notice.getRecipientName());
+ productSales.setContactTelephone(notice.getRecipientTelephone());
+ productSales.setContactAddress(notice.getRecipientAddress());
+ productSales.setStatus(MesWmProductSalesStatusEnum.PREPARE.getStatus());
+ productSalesMapper.insert(productSales);
+
+ // 5. 閬嶅巻鍙戣揣閫氱煡鍗曡鍒涘缓閿�鍞嚭搴撳崟琛�
+ for (MesWmSalesNoticeLineDO noticeLine : noticeLines) {
+ MesWmProductSalesLineDO salesLine = new MesWmProductSalesLineDO();
+ salesLine.setSalesId(productSales.getId());
+ salesLine.setSaleOrderItemId(noticeLine.getSaleOrderItemId());
+ salesLine.setNoticeLineId(noticeLine.getId());
+ salesLine.setItemId(noticeLine.getItemId());
+ salesLine.setQuantity(noticeLine.getQuantity());
+ salesLine.setBatchId(noticeLine.getBatchId());
+ salesLine.setBatchCode(noticeLine.getBatchCode());
+ salesLine.setOqcCheckFlag(noticeLine.getOqcCheckFlag());
+ productSalesLineMapper.insert(salesLine);
+ }
+
+ return productSales.getId();
+ }
+
}
--
Gitblit v1.9.3