From 87b052cbd5bb44bf90ac4e9c4aeaf1cdcf5acf63 Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期日, 22 六月 2025 15:30:44 +0800
Subject: [PATCH] #改造
---
src/main/java/com/zy/core/ServerBootstrap.java | 62 ++++++++++++++++++++++++-------
1 files changed, 48 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index 71d10d5..28352cb 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -5,7 +5,9 @@
import com.zy.core.enums.SlaveType;
import com.zy.core.model.*;
import com.zy.core.properties.SlaveProperties;
+import com.zy.core.properties.SystemProperties;
import com.zy.core.thread.*;
+import com.zy.system.entity.license.LicenseVerify;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
@@ -49,14 +51,14 @@
}
private void initMq(){
-// // 鍒濆鍖朢GVmq
-// for (Slave rgv : slaveProperties.getRgv()) {
-// MessageQueue.init(SlaveType.Rgv, rgv);
-// }
- // 鍒濆鍖栬緭閫佺嚎mq
- for (Slave devp : slaveProperties.getDevp()) {
- MessageQueue.init(SlaveType.Devp, devp);
+ // 鍒濆鍖朢GVmq
+ for (Slave rgv : slaveProperties.getRgv()) {
+ MessageQueue.init(SlaveType.Rgv, rgv);
}
+// // 鍒濆鍖栬緭閫佺嚎mq
+// for (Slave devp : slaveProperties.getDevp()) {
+// MessageQueue.init(SlaveType.Devp, devp);
+// }
// // 鍒濆鍖栨潯鐮佹壂鎻忎华mq
// for (Slave barcode : slaveProperties.getBarcode()) {
// MessageQueue.init(SlaveType.Barcode, barcode);
@@ -80,13 +82,13 @@
}
private void initThread(){
-// // 鍒濆鍖栫┛姊溅绾跨▼
-// log.info("鍒濆鍖朢GV绾跨▼...................................................");
-// for (RgvSlave rgv : slaveProperties.getRgv()) {
-// RgvThread rgvThread = new RgvThread(rgv);
-// new Thread((Runnable) rgvThread).start();
-// SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
-// }
+ // 鍒濆鍖栫┛姊溅绾跨▼
+ log.info("鍒濆鍖朢GV绾跨▼...................................................");
+ for (RgvSlave rgv : slaveProperties.getRgv()) {
+ RgvThread rgvThread = new RgvThread(rgv);
+ new Thread((Runnable) rgvThread).start();
+ SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
+ }
// // 鍒濆鍖栬緭閫佺嚎绾跨▼
// log.info("鍒濆鍖栬緭閫佺嚎绾跨▼...................................................");
// for (DevpSlave devp : slaveProperties.getDevp()) {
@@ -130,4 +132,36 @@
public void destroy() {
}
+ @Component
+ class licenseVerifyThread {
+
+ @Scheduled(cron = "0 0 4 * * ?")
+ public void licenseVerify() {
+ int licenseVerifySignCount = 0;
+ boolean licenseVerifySign = false;
+ boolean systemSign = SystemProperties.WCS_RUNNING_STATUS.get();
+ if (!new LicenseVerify().verify()){
+ for (licenseVerifySignCount = 0;!licenseVerifySign && licenseVerifySignCount<10; licenseVerifySignCount++){
+ try{
+ Thread.sleep(1000);
+ }catch (Exception e){
+
+ }
+ if (!new LicenseVerify().verify()){
+ log.info("++++++++ 楠岃瘉璁稿彲璇佸け璐� ++++++++");
+ } else {
+ log.info("++++++++ 楠岃瘉璁稿彲璇佹垚鍔� ++++++++");
+ licenseVerifySign = true;
+ }
+ }
+ if (licenseVerifySignCount>10 && !licenseVerifySign){
+ SystemProperties.WCS_RUNNING_STATUS.set(Boolean.FALSE);
+ } else {
+ if (systemSign){
+ SystemProperties.WCS_RUNNING_STATUS.set(Boolean.TRUE);
+ }
+ }
+ }
+ }
+ }
}
--
Gitblit v1.9.1