From f91db6022539e797c958c1fac16dc5e53db4f892 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期五, 17 十一月 2023 16:02:00 +0800
Subject: [PATCH] Merge remote-tracking branch 'orgin/igds-api-gateway' into igds-api-gateway
---
src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java | 2 +-
src/main/java/com/fzzy/protocol/ProtocolRunner.java | 22 ++++++++++++++++++++++
src/main/java/com/fzzy/gateway/GatewayRunner.java | 2 ++
3 files changed, 25 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/GatewayRunner.java b/src/main/java/com/fzzy/gateway/GatewayRunner.java
index 1f05550..92c537b 100644
--- a/src/main/java/com/fzzy/gateway/GatewayRunner.java
+++ b/src/main/java/com/fzzy/gateway/GatewayRunner.java
@@ -26,6 +26,8 @@
@Autowired
private GatewayTimerScheduled scheduled;
+
+
@Override
public void run(String... args) throws Exception {
mqttPublishService.init();
diff --git a/src/main/java/com/fzzy/protocol/ProtocolRunner.java b/src/main/java/com/fzzy/protocol/ProtocolRunner.java
new file mode 100644
index 0000000..c64169f
--- /dev/null
+++ b/src/main/java/com/fzzy/protocol/ProtocolRunner.java
@@ -0,0 +1,22 @@
+package com.fzzy.protocol;
+
+import com.fzzy.protocol.weightyh.YhScaleServerEngine;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Service;
+
+/**
+ * 閰嶇疆闅忕郴缁熷惎鍔ㄩ粯璁ら厤缃�
+ */
+@Service
+@Slf4j
+@Order(value = 3)
+public class ProtocolRunner implements CommandLineRunner {
+ @Override
+ public void run(String... args) throws Exception {
+
+ YhScaleServerEngine.start();
+ }
+
+}
diff --git a/src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java b/src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java
index 42a0373..5b54ce9 100644
--- a/src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java
+++ b/src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java
@@ -35,7 +35,7 @@
log.info("* ========================");
log.info("* ");
- log.info("* 鍦扮-鑰�鍗庡搧鐗屾湇鍔″惎鍔紝绔彛鍙�={}", YhScaleServerEngine.port);
+ log.info("* WEIGHT-SERVER-START锛孭ORT={}", YhScaleServerEngine.port);
log.info("* ");
log.info("* ========================");
}
--
Gitblit v1.9.3