2025-11-20

优化接口

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;
     }
 

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;
 

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}")