From 006020bc9a87dc40c2e73bc50f244b348b831de1 Mon Sep 17 00:00:00 2001
From: gaoluyang <2820782392@qq.com>
Date: 星期二, 03 十一月 2026 13:41:56 +0800
Subject: [PATCH] 恢复 ERP 采购入库/退货后端，补齐采购统计接口
---
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/purchase/ErpPurchaseInServiceImpl.java | 352 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 352 insertions(+), 0 deletions(-)
diff --git a/yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/purchase/ErpPurchaseInServiceImpl.java b/yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/purchase/ErpPurchaseInServiceImpl.java
new file mode 100644
index 0000000..b1f7bf5
--- /dev/null
+++ b/yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/purchase/ErpPurchaseInServiceImpl.java
@@ -0,0 +1,352 @@
+package cn.iocoder.yudao.module.erp.service.purchase;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.number.MoneyUtils;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.in.ErpPurchaseInPageReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.in.ErpPurchaseInSaveReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.purchase.ErpPurchaseInDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.purchase.ErpPurchaseInItemDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.purchase.ErpPurchaseOrderDO;
+import cn.iocoder.yudao.module.erp.dal.mysql.purchase.ErpPurchaseInItemMapper;
+import cn.iocoder.yudao.module.erp.dal.mysql.purchase.ErpPurchaseInMapper;
+import cn.iocoder.yudao.module.erp.dal.redis.no.ErpNoRedisDAO;
+import cn.iocoder.yudao.module.erp.enums.ErpAuditStatus;
+import cn.iocoder.yudao.module.erp.service.finance.ErpAccountService;
+import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
+import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO;
+import cn.iocoder.yudao.module.mes.api.wms.dto.WmsPurchaseInboundReqDTO;
+import cn.iocoder.yudao.module.mes.api.wms.stock.WmsStockApi;
+import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.annotation.Validated;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.*;
+import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.*;
+
+// TODO 鑺嬭壙锛氳褰曟搷浣滄棩蹇�
+
+/**
+ * ERP 閲囪喘鍏ュ簱 Service 瀹炵幇绫�
+ *
+ * @author 鑺嬮亾婧愮爜
+ */
+@Service
+@Validated
+@Slf4j
+public class ErpPurchaseInServiceImpl implements ErpPurchaseInService {
+
+ @Resource
+ private ErpPurchaseInMapper purchaseInMapper;
+ @Resource
+ private ErpPurchaseInItemMapper purchaseInItemMapper;
+
+ @Resource
+ private ErpNoRedisDAO noRedisDAO;
+
+ @Resource
+ private MdmItemApi mdmItemApi;
+ @Resource
+ @Lazy // 寤惰繜鍔犺浇锛岄伩鍏嶅惊鐜緷璧�
+ private ErpPurchaseOrderService purchaseOrderService;
+ @Resource
+ private ErpAccountService accountService;
+
+ @Resource
+ private WmsStockApi wmsStockApi;
+
+ @Resource
+ private AdminUserApi adminUserApi;
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Long createPurchaseIn(ErpPurchaseInSaveReqVO createReqVO) {
+ // 1.1 鏍￠獙閲囪喘璁㈠崟宸插鏍�
+ ErpPurchaseOrderDO purchaseOrder = purchaseOrderService.validatePurchaseOrder(createReqVO.getOrderId());
+ // 1.2 鏍￠獙鍏ュ簱椤圭殑鏈夋晥鎬�
+ List<ErpPurchaseInItemDO> purchaseInItems = validatePurchaseInItems(createReqVO.getItems());
+ // 1.3 鏍￠獙缁撶畻璐︽埛
+ accountService.validateAccount(createReqVO.getAccountId());
+ // 1.4 鐢熸垚鍏ュ簱鍗曞彿锛屽苟鏍￠獙鍞竴鎬�
+ String no = noRedisDAO.generate(ErpNoRedisDAO.PURCHASE_IN_NO_PREFIX);
+ if (purchaseInMapper.selectByNo(no) != null) {
+ throw exception(PURCHASE_IN_NO_EXISTS);
+ }
+
+ // 2.1 鎻掑叆鍏ュ簱
+ ErpPurchaseInDO purchaseIn = BeanUtils.toBean(createReqVO, ErpPurchaseInDO.class, in -> in
+ .setNo(no).setStatus(ErpAuditStatus.PROCESS.getStatus()))
+ .setOrderNo(purchaseOrder.getNo()).setSupplierId(purchaseOrder.getSupplierId());
+ calculateTotalPrice(purchaseIn, purchaseInItems);
+ purchaseInMapper.insert(purchaseIn);
+ // 2.2 鎻掑叆鍏ュ簱椤�
+ purchaseInItems.forEach(o -> o.setInId(purchaseIn.getId()));
+ purchaseInItemMapper.insertBatch(purchaseInItems);
+
+ // 3. 鏇存柊閲囪喘璁㈠崟鐨勫叆搴撴暟閲�
+ updatePurchaseOrderInCount(createReqVO.getOrderId());
+ return purchaseIn.getId();
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void updatePurchaseIn(ErpPurchaseInSaveReqVO updateReqVO) {
+ // 1.1 鏍￠獙瀛樺湪
+ ErpPurchaseInDO purchaseIn = validatePurchaseInExists(updateReqVO.getId());
+ if (ErpAuditStatus.APPROVE.getStatus().equals(purchaseIn.getStatus())) {
+ throw exception(PURCHASE_IN_UPDATE_FAIL_APPROVE, purchaseIn.getNo());
+ }
+ // 1.2 鏍￠獙閲囪喘璁㈠崟宸插鏍�
+ ErpPurchaseOrderDO purchaseOrder = purchaseOrderService.validatePurchaseOrder(updateReqVO.getOrderId());
+ // 1.3 鏍￠獙缁撶畻璐︽埛
+ accountService.validateAccount(updateReqVO.getAccountId());
+ // 1.4 鏍￠獙璁㈠崟椤圭殑鏈夋晥鎬�
+ List<ErpPurchaseInItemDO> purchaseInItems = validatePurchaseInItems(updateReqVO.getItems());
+
+ // 2.1 鏇存柊鍏ュ簱
+ ErpPurchaseInDO updateObj = BeanUtils.toBean(updateReqVO, ErpPurchaseInDO.class)
+ .setOrderNo(purchaseOrder.getNo()).setSupplierId(purchaseOrder.getSupplierId());
+ calculateTotalPrice(updateObj, purchaseInItems);
+ purchaseInMapper.updateById(updateObj);
+ // 2.2 鏇存柊鍏ュ簱椤�
+ updatePurchaseInItemList(updateReqVO.getId(), purchaseInItems);
+
+ // 3.1 鏇存柊閲囪喘璁㈠崟鐨勫叆搴撴暟閲�
+ updatePurchaseOrderInCount(updateObj.getOrderId());
+ // 3.2 娉ㄦ剰锛氬鏋滈噰璐鍗曠紪鍙峰彉鏇翠簡锛岄渶瑕佹洿鏂扳�滆�佲�濋噰璐鍗曠殑鍏ュ簱鏁伴噺
+ if (ObjectUtil.notEqual(purchaseIn.getOrderId(), updateObj.getOrderId())) {
+ updatePurchaseOrderInCount(purchaseIn.getOrderId());
+ }
+ }
+
+ private void calculateTotalPrice(ErpPurchaseInDO purchaseIn, List<ErpPurchaseInItemDO> purchaseInItems) {
+ purchaseIn.setTotalCount(getSumValue(purchaseInItems, ErpPurchaseInItemDO::getCount, BigDecimal::add));
+ purchaseIn.setTotalProductPrice(getSumValue(purchaseInItems, ErpPurchaseInItemDO::getTotalPrice, BigDecimal::add, BigDecimal.ZERO));
+ purchaseIn.setTotalTaxPrice(getSumValue(purchaseInItems, ErpPurchaseInItemDO::getTaxPrice, BigDecimal::add, BigDecimal.ZERO));
+ purchaseIn.setTotalPrice(purchaseIn.getTotalProductPrice().add(purchaseIn.getTotalTaxPrice()));
+ // 璁＄畻浼樻儬浠锋牸
+ if (purchaseIn.getDiscountPercent() == null) {
+ purchaseIn.setDiscountPercent(BigDecimal.ZERO);
+ }
+ purchaseIn.setDiscountPrice(MoneyUtils.priceMultiplyPercent(purchaseIn.getTotalPrice(), purchaseIn.getDiscountPercent()));
+ purchaseIn.setTotalPrice(purchaseIn.getTotalPrice().subtract(purchaseIn.getDiscountPrice()).add(purchaseIn.getOtherPrice()));
+ }
+
+ private void updatePurchaseOrderInCount(Long orderId) {
+ // 1.1 鏌ヨ閲囪喘璁㈠崟瀵瑰簲鐨勯噰璐叆搴撳崟鍒楄〃
+ List<ErpPurchaseInDO> purchaseIns = purchaseInMapper.selectListByOrderId(orderId);
+ // 1.2 鏌ヨ瀵瑰簲鐨勯噰璐鍗曢」鐨勫叆搴撴暟閲�
+ Map<Long, BigDecimal> returnCountMap = purchaseInItemMapper.selectOrderItemCountSumMapByInIds(
+ convertList(purchaseIns, ErpPurchaseInDO::getId));
+ // 2. 鏇存柊閲囪喘璁㈠崟鐨勫叆搴撴暟閲�
+ purchaseOrderService.updatePurchaseOrderInCount(orderId, returnCountMap);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void updatePurchaseInStatus(Long id, Integer status) {
+ boolean approve = ErpAuditStatus.APPROVE.getStatus().equals(status);
+ // 1.1 鏍￠獙瀛樺湪
+ ErpPurchaseInDO purchaseIn = validatePurchaseInExists(id);
+ // 1.2 鏍￠獙鐘舵��
+ if (purchaseIn.getStatus().equals(status)) {
+ throw exception(approve ? PURCHASE_IN_APPROVE_FAIL : PURCHASE_IN_PROCESS_FAIL);
+ }
+ // 1.3 鏍￠獙宸蹭粯娆�
+ if (!approve && purchaseIn.getPaymentPrice().compareTo(BigDecimal.ZERO) > 0) {
+ throw exception(PURCHASE_IN_PROCESS_FAIL_EXISTS_PAYMENT);
+ }
+
+ // 2. 鏇存柊鐘舵��
+ int updateCount = purchaseInMapper.updateByIdAndStatus(id, purchaseIn.getStatus(),
+ new ErpPurchaseInDO().setStatus(status));
+ if (updateCount == 0) {
+ throw exception(approve ? PURCHASE_IN_APPROVE_FAIL : PURCHASE_IN_PROCESS_FAIL);
+ }
+
+ // 3. 鍚屾 WMS 搴撳瓨锛圡ES 搴撳瓨锛�
+ if (approve) {
+ List<ErpPurchaseInItemDO> purchaseInItems = purchaseInItemMapper.selectListByInId(id);
+ syncToWmsPurchaseInbound(purchaseIn, purchaseInItems);
+ }
+ }
+
+ /**
+ * 鍚屾閲囪喘鍏ュ簱鍒� WMS 搴撳瓨
+ */
+ private void syncToWmsPurchaseInbound(ErpPurchaseInDO purchaseIn, List<ErpPurchaseInItemDO> purchaseInItems) {
+ if (CollUtil.isEmpty(purchaseInItems)) {
+ return;
+ }
+
+ log.info("[syncToWmsPurchaseInbound] 寮�濮嬪悓姝ラ噰璐叆搴撳埌WMS锛宲urchaseInId={}", purchaseIn.getId());
+
+ // 鏋勫缓鍏ュ簱璇锋眰
+ WmsPurchaseInboundReqDTO reqDTO = new WmsPurchaseInboundReqDTO()
+ .setBizId(purchaseIn.getId())
+ .setBizCode(purchaseIn.getNo())
+ .setReceiptTime(LocalDateTime.now());
+
+ // 杞崲鏄庣粏椤癸細ERP 浜у搧缂栧彿鍗� MDM 鐗╂枡缂栧彿锛屼粨搴撶紪鍙峰嵆 MES 浠撳簱缂栧彿
+ List<WmsPurchaseInboundReqDTO.Item> items = convertList(purchaseInItems, item -> new WmsPurchaseInboundReqDTO.Item()
+ .setItemId(item.getProductId())
+ .setWarehouseId(item.getWarehouseId())
+ .setQuantity(item.getCount())
+ .setBizLineId(item.getId()));
+
+ // 杩囨护鎺夋槧灏勫け璐ョ殑椤�
+ items = items.stream().filter(java.util.Objects::nonNull).toList();
+ if (CollUtil.isEmpty(items)) {
+ log.warn("[syncToWmsPurchaseInbound] 鏃犳湁鏁堢殑鍏ュ簱鏄庣粏锛岃烦杩嘩MS鍚屾");
+ return;
+ }
+
+ reqDTO.setItems(items);
+
+ try {
+ Long transactionId = wmsStockApi.purchaseInbound(reqDTO);
+ log.info("[syncToWmsPurchaseInbound] 鍚屾鎴愬姛锛宼ransactionId={}", transactionId);
+ } catch (Exception e) {
+ log.error("[syncToWmsPurchaseInbound] 鍚屾澶辫触", e);
+ // 娉ㄦ剰锛氳繖閲屽彲浠ラ�夋嫨鎶涘嚭寮傚父鍥炴粴锛屾垨浠呰褰曟棩蹇�
+ // throw exception(PURCHASE_IN_SYNC_WMS_FAIL);
+ }
+ }
+
+ @Override
+ public void updatePurchaseInPaymentPrice(Long id, BigDecimal paymentPrice) {
+ ErpPurchaseInDO purchaseIn = purchaseInMapper.selectById(id);
+ if (purchaseIn.getPaymentPrice().equals(paymentPrice)) {
+ return;
+ }
+ if (paymentPrice.compareTo(purchaseIn.getTotalPrice()) > 0) {
+ throw exception(PURCHASE_IN_FAIL_PAYMENT_PRICE_EXCEED, paymentPrice, purchaseIn.getTotalPrice());
+ }
+ purchaseInMapper.updateById(new ErpPurchaseInDO().setId(id).setPaymentPrice(paymentPrice));
+ }
+
+ private List<ErpPurchaseInItemDO> validatePurchaseInItems(List<ErpPurchaseInSaveReqVO.Item> list) {
+ // 1. 鏍￠獙鐗╂枡瀛樺湪锛堢墿鏂欎富鏁版嵁宸茶縼绉诲埌 MDM锛�
+ Set<Long> productIds = convertSet(list, ErpPurchaseInSaveReqVO.Item::getProductId);
+ Map<Long, MdmItemRespDTO> itemMap = productIds.isEmpty() ? Collections.emptyMap() : mdmItemApi.getItemMap(productIds);
+ if (itemMap.size() != productIds.size()) {
+ throw exception(PRODUCT_NOT_EXISTS);
+ }
+ // 2. 杞寲涓� ErpPurchaseInItemDO 鍒楄〃
+ return convertList(list, o -> BeanUtils.toBean(o, ErpPurchaseInItemDO.class, item -> {
+ item.setProductUnitId(itemMap.get(item.getProductId()).getUnitMeasureId());
+ item.setTotalPrice(MoneyUtils.priceMultiply(item.getProductPrice(), item.getCount()));
+ if (item.getTotalPrice() == null) {
+ return;
+ }
+ if (item.getTaxPercent() != null) {
+ item.setTaxPrice(MoneyUtils.priceMultiplyPercent(item.getTotalPrice(), item.getTaxPercent()));
+ }
+ }));
+ }
+
+ private void updatePurchaseInItemList(Long id, List<ErpPurchaseInItemDO> newList) {
+ // 绗竴姝ワ紝瀵规瘮鏂拌�佹暟鎹紝鑾峰緱娣诲姞銆佷慨鏀广�佸垹闄ょ殑鍒楄〃
+ List<ErpPurchaseInItemDO> oldList = purchaseInItemMapper.selectListByInId(id);
+ List<List<ErpPurchaseInItemDO>> diffList = diffList(oldList, newList, // id 涓嶅悓锛屽氨璁や负鏄笉鍚岀殑璁板綍
+ (oldVal, newVal) -> oldVal.getId().equals(newVal.getId()));
+
+ // 绗簩姝ワ紝鎵归噺娣诲姞銆佷慨鏀广�佸垹闄�
+ if (CollUtil.isNotEmpty(diffList.get(0))) {
+ diffList.get(0).forEach(o -> o.setInId(id));
+ purchaseInItemMapper.insertBatch(diffList.get(0));
+ }
+ if (CollUtil.isNotEmpty(diffList.get(1))) {
+ purchaseInItemMapper.updateBatch(diffList.get(1));
+ }
+ if (CollUtil.isNotEmpty(diffList.get(2))) {
+ purchaseInItemMapper.deleteByIds(convertList(diffList.get(2), ErpPurchaseInItemDO::getId));
+ }
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void deletePurchaseIn(List<Long> ids) {
+ // 1. 鏍￠獙涓嶅浜庡凡瀹℃壒
+ List<ErpPurchaseInDO> purchaseIns = purchaseInMapper.selectByIds(ids);
+ if (CollUtil.isEmpty(purchaseIns)) {
+ return;
+ }
+ purchaseIns.forEach(purchaseIn -> {
+ if (ErpAuditStatus.APPROVE.getStatus().equals(purchaseIn.getStatus())) {
+ throw exception(PURCHASE_IN_DELETE_FAIL_APPROVE, purchaseIn.getNo());
+ }
+ });
+
+ // 2. 閬嶅巻鍒犻櫎锛屽苟璁板綍鎿嶄綔鏃ュ織
+ purchaseIns.forEach(purchaseIn -> {
+ // 2.1 鍒犻櫎璁㈠崟
+ purchaseInMapper.deleteById(purchaseIn.getId());
+ // 2.2 鍒犻櫎璁㈠崟椤�
+ purchaseInItemMapper.deleteByInId(purchaseIn.getId());
+
+ // 2.3 鏇存柊閲囪喘璁㈠崟鐨勫叆搴撴暟閲�
+ updatePurchaseOrderInCount(purchaseIn.getOrderId());
+ });
+
+ }
+
+ private ErpPurchaseInDO validatePurchaseInExists(Long id) {
+ ErpPurchaseInDO purchaseIn = purchaseInMapper.selectById(id);
+ if (purchaseIn == null) {
+ throw exception(PURCHASE_IN_NOT_EXISTS);
+ }
+ return purchaseIn;
+ }
+
+ @Override
+ public ErpPurchaseInDO getPurchaseIn(Long id) {
+ return purchaseInMapper.selectById(id);
+ }
+
+ @Override
+ public ErpPurchaseInDO validatePurchaseIn(Long id) {
+ ErpPurchaseInDO purchaseIn = validatePurchaseInExists(id);
+ if (ObjectUtil.notEqual(purchaseIn.getStatus(), ErpAuditStatus.APPROVE.getStatus())) {
+ throw exception(PURCHASE_IN_NOT_APPROVE);
+ }
+ return purchaseIn;
+ }
+
+ @Override
+ public PageResult<ErpPurchaseInDO> getPurchaseInPage(ErpPurchaseInPageReqVO pageReqVO) {
+ return purchaseInMapper.selectPage(pageReqVO);
+ }
+
+ // ==================== 閲囪喘鍏ュ簱椤� ====================
+
+ @Override
+ public List<ErpPurchaseInItemDO> getPurchaseInItemListByInId(Long inId) {
+ return purchaseInItemMapper.selectListByInId(inId);
+ }
+
+ @Override
+ public List<ErpPurchaseInItemDO> getPurchaseInItemListByInIds(Collection<Long> inIds) {
+ if (CollUtil.isEmpty(inIds)) {
+ return Collections.emptyList();
+ }
+ return purchaseInItemMapper.selectListByInIds(inIds);
+ }
+
+}
--
Gitblit v1.9.3