From ad28331c1e3ed456b72765874b41b83b49dc279f Mon Sep 17 00:00:00 2001 From: 严智鑫 <test> Date: 星期四, 18 四月 2024 14:44:11 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java | 123 ++++++++++++++++++++-------------------- 1 files changed, 61 insertions(+), 62 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 index 32903a6..9a4a882 100644 --- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java +++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/common/Plchome.java @@ -1,62 +1,61 @@ -package com.mes.common; - -import cn.hutool.json.JSONObject; -import com.mes.downworkstation.service.DownGlassLogic; -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); - DownGlassLogic plcService = plcServiceSupplier.get(); - // plcService.performPlcActions(); - //plcService.unloadpush(); - - //褰撲笅鐗囦换鍔¤〃鐘舵�佷负1鏃跺�欏皢鏁版嵁鎻掑叆鍒颁笅鐗囩幓鐠冧俊鎭〃 - plcService.insertdownglassinfo(); - - - - //褰撴満姊版墜浠诲姟琛ㄤ腑鐘舵�佷负1 鏇存柊宸茬粡钀芥灦鏁伴噺锛屽苟涓旀妸涓嬬墖浠诲姟琛ㄧ殑閭f潯璁板綍鍒犳帀 宸ヤ綅琛ㄦ祦绋嬪崱缁戝畾浜嗘灦瀛� - plcService.downWorkstation(); - - - } 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()); - }} - - } - } -} +package com.mes.common; + +import cn.hutool.json.JSONObject; +import com.mes.downworkstation.service.DownGlassLogic; +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); + DownGlassLogic plcService = plcServiceSupplier.get(); + // plcService.performPlcActions(); + //plcService.unloadpush(); + + //褰撲笅鐗囦换鍔¤〃鐘舵�佷负1鏃跺�欏皢鏁版嵁鎻掑叆鍒颁笅鐗囩幓鐠冧俊鎭〃 + plcService.insertdownglassinfo(); + + + //褰撴満姊版墜浠诲姟琛ㄤ腑鐘舵�佷负1 鏇存柊宸茬粡钀芥灦鏁伴噺锛屽苟涓旀妸涓嬬墖浠诲姟琛ㄧ殑閭f潯璁板綍鍒犳帀 宸ヤ綅琛ㄦ祦绋嬪崱缁戝畾浜嗘灦瀛� + plcService.downWorkstation(); + + + } 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