From d1bf846d1ef407da9200fb319d8f8f4ed3984d53 Mon Sep 17 00:00:00 2001 From: wu <731351411@qq.com> Date: 星期五, 02 八月 2024 10:32:02 +0800 Subject: [PATCH] 增加上片状态显示和推送 --- hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java | 34 ++++++++++++++++++++++++++++++++-- 1 files changed, 32 insertions(+), 2 deletions(-) diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java index ff4e20c..17b0050 100644 --- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java +++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java @@ -120,10 +120,20 @@ JSONObject jsonObject = new JSONObject(); //姝e湪杩涜鐨勪换鍔� List<UpPattenUsage> upPattenUsages = upPattenUsageService.prioritylist(); - jsonObject.append("prioritylist", upPattenUsages); + if(upPattenUsages!=null){ + jsonObject.append("prioritylist", upPattenUsages); + } + //宸ヤ綅淇℃伅 List<UpWorkstation> upWorkstations = upWorkstationService.list(); jsonObject.append("list", upWorkstations); + //鏄惁寮�濮嬪伐绋� + Engineering engineering = engineeringService.selectInitiate(1); + if (engineering != null){ + jsonObject.append("engineering", engineering); + }else { + jsonObject.append("engineering", "0"); + } ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { @@ -145,7 +155,7 @@ public void loadGlassStatus() { JSONObject jsonObject = new JSONObject(); //姝e湪杩涜鐨勪换鍔� - String inkageStatus = plcParameterObject.getPlcParameter("MesToPlc").getValue(); + String inkageStatus =plcParameterObject.getPlcParameter("InkageStatus").getValue(); //String inkageStatus ="1"; jsonObject.append("InkageStatus", inkageStatus); ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass"); @@ -159,6 +169,26 @@ } } } + @Scheduled(fixedDelay = 1000) + public void loadGlassIsRun() { + JSONObject jsonObject = new JSONObject(); + Engineering engineering = engineeringService.selectInitiate(1); + if (engineering != null){ + jsonObject.append("engineering", engineering); + }else { + jsonObject.append("engineering", "0"); + } + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("IsRun"); + if (sendwServer != null) { + for (WebSocketServer webserver : sendwServer) { + if (webserver != null) { + webserver.sendMessage(jsonObject.toString()); + } else { + log.info("Home is closed"); + } + } + } + } public void overTask(String loadStatus, int state) { -- Gitblit v1.8.0