From 471faf9943b3c2f29ccf2dc8e27ac09b8b97423c Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 17 四月 2026 09:52:41 +0800
Subject: [PATCH] 1

---
 zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java |   11 ++++++-----
 1 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
index 8393115..85cfb33 100644
--- a/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
+++ b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
@@ -1,5 +1,6 @@
 package com.zy.acs.conveyor.core.operation;
 
+import com.zy.acs.common.utils.News;
 import com.zy.acs.conveyor.core.enums.ConveyorStateType;
 import com.zy.acs.conveyor.core.properties.CtuOperationConfig;
 import lombok.extern.slf4j.Slf4j;
@@ -21,14 +22,14 @@
         // 鑷姩娉ㄥ唽鎵�鏈夋搷浣滃鐞嗗櫒
         for (OperationHandler handler : handlers) {
             handlerMap.put(handler.getType(), handler);
-            log.info("娉ㄥ唽杈撻�佺嚎鎿嶄綔澶勭悊鍣�: {}", handler.getType());
+            News.info("娉ㄥ唽杈撻�佺嚎鎿嶄綔澶勭悊鍣�: {}", handler.getType());
         }
     }
 
     public void execute(CtuOperationConfig config) {
         OperationHandler handler = handlerMap.get(config.getType());
         if (handler == null) {
-            log.warn("鏈壘鍒版搷浣滃鐞嗗櫒: {}", config.getType());
+            News.warn("鏈壘鍒版搷浣滃鐞嗗櫒: {}", config.getType());
             return;
         }
 
@@ -40,15 +41,15 @@
             } catch (Exception e) {
                 retryCount++;
                 if (retryCount >= config.getMaxRetries()) {
-                    log.error("鎿嶄綔鎵ц澶辫触锛屽凡杈惧埌鏈�澶ч噸璇曟鏁�: {}", config.getType(), e);
+                    News.error("鎿嶄綔鎵ц澶辫触锛屽凡杈惧埌鏈�澶ч噸璇曟鏁�: {}", config.getType(), e);
                 } else {
-                    log.warn("鎿嶄綔鎵ц澶辫触锛屾鍦ㄩ噸璇�({}/{})",
+                    News.warn("鎿嶄綔鎵ц澶辫触锛屾鍦ㄩ噸璇�({}/{})",
                             retryCount, config.getMaxRetries(), e);
                     try {
                         Thread.sleep(config.getRetryDelay());
                     } catch (InterruptedException ie) {
                         Thread.currentThread().interrupt();
-                        log.error("閲嶈瘯浼戠湢琚腑鏂�", ie);
+                        News.error("閲嶈瘯浼戠湢琚腑鏂�", ie);
                         return;
                     }
                 }

--
Gitblit v1.9.1