From d4a7b1faad635b4817891185a4f471595db2eece Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期一, 15 九月 2025 19:33:49 +0800
Subject: [PATCH] art: 生产订单SAP同步

---
 src/main/java/org/jeecg/modules/mes/service/impl/MesProductionOrderServiceImpl.java |   57 +++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 53 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/jeecg/modules/mes/service/impl/MesProductionOrderServiceImpl.java b/src/main/java/org/jeecg/modules/mes/service/impl/MesProductionOrderServiceImpl.java
index 19c42ec..495ac47 100644
--- a/src/main/java/org/jeecg/modules/mes/service/impl/MesProductionOrderServiceImpl.java
+++ b/src/main/java/org/jeecg/modules/mes/service/impl/MesProductionOrderServiceImpl.java
@@ -4,15 +4,21 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.jeecg.common.constant.CommonConstant;
-import org.jeecg.modules.mdc.util.DateUtils;
+import org.jeecg.common.exception.JeecgBootException;
 import org.jeecg.modules.mes.entity.MesProductionOrder;
 import org.jeecg.modules.mes.mapper.MesProductionOrderMapper;
 import org.jeecg.modules.mes.service.IMesProductionOrderService;
 import org.jeecg.modules.sap.dto.ProductionOrderDTO;
+import org.jeecg.modules.sap.request.ProductionOrderSyncRequest;
+import org.jeecg.modules.sap.service.ProductionOrderSync;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @Description: SAP鐢熶骇璁㈠崟
@@ -22,6 +28,12 @@
  */
 @Service
 public class MesProductionOrderServiceImpl extends ServiceImpl<MesProductionOrderMapper, MesProductionOrder> implements IMesProductionOrderService {
+    //宸ュ巶缂栫爜(鏂扮伀鐐� 2301)
+    @Value("${xhj.factoryCode:2301}")
+    private String FACTORY_CODE;
+
+    @Autowired
+    private ProductionOrderSync productionOrderSync;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -57,7 +69,7 @@
     @Override
     public String getLastSyncCreateDate() {
         String lastSyncDate = this.getBaseMapper().getLastSyncCreateDate();
-        if(lastSyncDate == null){
+        if (lastSyncDate == null) {
             return null;
         }
         return lastSyncDate.replaceAll("-", "");
@@ -66,9 +78,46 @@
     @Override
     public String getLastSyncUpdateDate() {
         String lastSyncDate = this.getBaseMapper().getLastSyncUpdateDate();
-        if(lastSyncDate == null){
+        if (lastSyncDate == null) {
             return null;
         }
         return lastSyncDate.replaceAll("-", "");
     }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean syncSapProductionOrder(String id) {
+        MesProductionOrder entity = super.getById(id);
+        if (entity == null) {
+            throw new JeecgBootException("鐢熶骇璁㈠崟涓嶅瓨鍦紝璇峰埛鏂伴噸缃紒");
+        }
+        ProductionOrderSyncRequest request = new ProductionOrderSyncRequest();
+        request.setOrderCode(entity.getOrderCode());
+        request.setFactoryCode(FACTORY_CODE);
+        try {
+            Map<String, Object> resultMap = productionOrderSync.syncProductionOrder(request);
+            if (resultMap == null) {
+                throw new JeecgBootException("鍝嶅簲缁撴灉涓虹┖锛�");
+            }
+            if (!CommonConstant.SAP_SUCCESS_CODE.equals(resultMap.get("ztype"))) {
+                throw new JeecgBootException(resultMap.get("zmess").toString());
+            }
+            //璋冪敤鎴愬姛锛岃幏鍙栬繑鍥炴暟鎹�
+            Object result = resultMap.get("result");
+            boolean b = result instanceof List;
+            if (!b) {
+                throw new JeecgBootException("杩斿洖缁撴灉鏍煎紡閿欒锛�");
+            }
+            List<ProductionOrderDTO> productionOrderDTOList = (List<ProductionOrderDTO>) result;
+            if (CollectionUtil.isEmpty(productionOrderDTOList)) {
+                throw new JeecgBootException("SAP鏈煡璇㈠埌鐢熸垚璁㈠崟锛�");
+            }
+            ProductionOrderDTO dto = productionOrderDTOList.get(0);
+            entity.updateEntity(dto);
+            super.updateById(entity);
+        } catch (Exception e) {
+            throw new JeecgBootException("璇锋眰SAP澶辫触锛�" + e.getMessage());
+        }
+        return true;
+    }
 }

--
Gitblit v1.9.3