From a72412ea76015aa84883da72e643c63096c71a24 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期三, 24 四月 2024 09:00:44 +0800 Subject: [PATCH] 认证权限 --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 52 insertions(+), 0 deletions(-) diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java new file mode 100644 index 0000000..feb80b2 --- /dev/null +++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java @@ -0,0 +1,52 @@ +package com.mes.common; + +import cn.hutool.json.JSONObject; + +import com.mes.tools.WebSocketServer; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; +import org.springframework.stereotype.Component; + +import java.util.ArrayList; +import java.util.function.Supplier; + +@Component +public class Plchome extends Thread { + private int i = 1; + private static final Logger log = LogManager.getLogger(Plchome.class); + + // private final Supplier<DownGlassLogic> plcServiceSupplier; + +// public Plchome() { +// this.plcServiceSupplier = () -> WebSocketServer.applicationContext.getBean(DownGlassLogic.class); +// } + + + @Override + public void run() { + while (!Thread.currentThread().isInterrupted()) { + try { + i++; + Thread.sleep(100); + + + + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + e.printStackTrace(); + } + + JSONObject jsonObject = new JSONObject(); + // System.out.println(arraylist6); + jsonObject.append("data", 1); + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unloadglass"); + if (sendwServer != null) { + for (WebSocketServer webserver : sendwServer) { + webserver.sendMessage(jsonObject.toString()); + log.info("鍑嗗鍚� WebSocket 鏈嶅姟鍣ㄥ彂閫佹秷鎭�: {}", jsonObject.toString()); + } + } + + } + } +} -- Gitblit v1.8.0