From 32d38851a6e5cf79e541e3763503e4c9f9f38308 Mon Sep 17 00:00:00 2001
From: fengyuan_yang <1976974459@qq.com>
Date: Thu, 20 Nov 2025 16:50:31 +0800
Subject: [PATCH] =?UTF-8?q?2025-11-20=20=E4=BC=98=E5=8C=96=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/PartInformationServiceImpl.java      |  9 +++++
 .../impl/RoutingManagementServiceImpl.java    |  4 ++
 .../modules/part/task/PartRelatedTask.java    | 39 ++++++++++++++-----
 3 files changed, 43 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
index 99d42a4c..7b533960 100644
--- a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
+++ b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
@@ -959,11 +959,19 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
             if (!"200".equals(deleteInventoryPartPropertyResponse.get("resultCode"))) {
                 throw new RuntimeException("IFS库存件属性删除异常：" + deleteInventoryPartPropertyResponse.get("resultMsg"));
             }
+            log.info("savePartItemInfo2 - ifsProperty size: {} contents: {}", ifsProperty.size(), JSON.toJSONString(ifsProperty));
             if (!ifsProperty.isEmpty()) {
+                log.info("开始同步物料属性到IFS，共 {} 条数据...", ifsProperty.size());
+                long startTime = System.currentTimeMillis();
                 Map<String, String> addInventoryPartPropertyResponse = inventoryServiceBean.syncInventoryPartCharacteristics(srv, ifsProperty);
+                long endTime = System.currentTimeMillis();
+                log.info("物料属性同步完成，耗时: {} ms", (endTime - startTime));
                 if (!"200".equals(addInventoryPartPropertyResponse.get("resultCode"))) {
                     throw new RuntimeException("IFS库存件属性新增异常：" + addInventoryPartPropertyResponse.get("resultMsg"));
                 }
+                log.info("物料属性同步成功");
+            } else {
+                log.info("ifsProperty 为空，跳过物料属性同步");
             }
         }
     }
@@ -1094,6 +1102,7 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
             property.setCharacteristicType("N".equals(itemDate.getValueTypeDb()) ? "Numeric" : "T".equals(itemDate.getValueTypeDb()) ? "Alpha" : "");
             ifsProperty.add(property);
         }
+        log.info("savePartItemInfo2 - ifsProperty size: {} contents: {}", ifsProperty.size(), JSON.toJSONString(ifsProperty));
         return ifsProperty;
     }
 
diff --git a/src/main/java/com/spring/modules/part/service/impl/RoutingManagementServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/RoutingManagementServiceImpl.java
index 06ab435c..a8aa91f6 100644
--- a/src/main/java/com/spring/modules/part/service/impl/RoutingManagementServiceImpl.java
+++ b/src/main/java/com/spring/modules/part/service/impl/RoutingManagementServiceImpl.java
@@ -43,6 +43,8 @@ import io.swagger.models.auth.In;
 import net.sf.json.JSONArray;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.ss.formula.functions.T;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -56,6 +58,8 @@ import java.util.stream.Collectors;
 @Service
 public class RoutingManagementServiceImpl extends ServiceImpl<RoutingManagementMapper, RoutingHeaderEntity> implements RoutingManagementService {
 
+    private static final Logger log = LoggerFactory.getLogger(RoutingManagementServiceImpl.class);
+
     @Autowired
     private RoutingManagementMapper routingManagementMapper;
 
diff --git a/src/main/java/com/spring/modules/part/task/PartRelatedTask.java b/src/main/java/com/spring/modules/part/task/PartRelatedTask.java
index 3fd0728a..454caa37 100644
--- a/src/main/java/com/spring/modules/part/task/PartRelatedTask.java
+++ b/src/main/java/com/spring/modules/part/task/PartRelatedTask.java
@@ -39,18 +39,39 @@ public class PartRelatedTask {
     @Scheduled(cron = "${task.data.syncDataToPLM}")
     public void executeDeviceCollect() {
         String siteCon = convertToSQLString(useSite);
+        
         // 同步人员等级
-        PersonnelLevelVo laborClassVo = new PersonnelLevelVo();
-        laborClassVo.setSiteCon(siteCon);
-        routingManagementService.syncLaborClassToPLM(laborClassVo);
+        try {
+            logger.info("开始同步人员等级...");
+            PersonnelLevelVo laborClassVo = new PersonnelLevelVo();
+            laborClassVo.setSiteCon(siteCon);
+            routingManagementService.syncLaborClassToPLM(laborClassVo);
+            logger.info("同步人员等级完成");
+        } catch (Exception e) {
+            logger.error("同步人员等级失败: " + e.getMessage(), e);
+        }
+        
         // 同步加工中心
-        WorkCenterVo workCenterVo = new WorkCenterVo();
-        workCenterVo.setSiteCon(siteCon);
-        routingManagementService.syncWorkCenterToPLM(workCenterVo);
+        try {
+            logger.info("开始同步加工中心...");
+            WorkCenterVo workCenterVo = new WorkCenterVo();
+            workCenterVo.setSiteCon(siteCon);
+            routingManagementService.syncWorkCenterToPLM(workCenterVo);
+            logger.info("同步加工中心完成");
+        } catch (Exception e) {
+            logger.error("同步加工中心失败: " + e.getMessage(), e);
+        }
+        
         // 同步加工中心成本
-        WorkCenterCostVo workCenterCostVo = new WorkCenterCostVo();
-        workCenterCostVo.setSiteCon(siteCon);
-        routingManagementService.syncWorkCenterCostToPLM(workCenterCostVo);
+        try {
+            logger.info("开始同步加工中心成本...");
+            WorkCenterCostVo workCenterCostVo = new WorkCenterCostVo();
+            workCenterCostVo.setSiteCon(siteCon);
+            routingManagementService.syncWorkCenterCostToPLM(workCenterCostVo);
+            logger.info("同步加工中心成本完成");
+        } catch (Exception e) {
+            logger.error("同步加工中心成本失败: " + e.getMessage(), e);
+        }
     }
 
     @Scheduled(cron = "${task.data.syncLocationToPLM}")