From 09d9824fbcdb76501e5eb37ee79a073d8fdd9eda Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期二, 01 四月 2025 09:12:02 +0800 Subject: [PATCH] 推送当天时间改为接口调用 --- hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java | 61 +++++++++++------------------- 1 files changed, 22 insertions(+), 39 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 5323dd5..96bbbc5 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 @@ -175,7 +175,12 @@ List<RawGlassStorageDetails> stationTwoList = rawGlassStorageDetailList.stream().filter(item -> item.getDeviceId() == 6).collect(Collectors.toList()); jsonObject.append("stationOne", stationOneList); jsonObject.append("stationTwo", stationTwoList); - + //鏄惁寮�濮嬪伐绋� + Engineering engineering = engineeringService.selectInitiate(1); + jsonObject.append("engineering", engineering); + //宸ヤ綅淇℃伅 + List<UpWorkstation> upWorkstations = upWorkstationService.list(); + jsonObject.append("list", upWorkstations); ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { @@ -193,24 +198,6 @@ } - @Scheduled(fixedDelay = 1000) - public void send() { - ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("mainMes"); - if (sendwServer != null) { - //鎺ㄩ�佹湇鍔″櫒褰撳墠鏃堕棿 - JSONObject jsonObject = new JSONObject(); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - jsonObject.append("globalDate", sdf.format(DateUtil.getEndDate())); - for (WebSocketServer webserver : sendwServer) { - if (webserver != null) { - webserver.sendMessage(jsonObject.toString()); - } else { - log.info("mainMes is closed"); - } - } - } - } - // @Scheduled(fixedDelay = 5000) public void loadGlassStatus() { JSONObject jsonObject = new JSONObject(); @@ -218,6 +205,7 @@ String inkageStatus = plcParameterObject.getPlcParameter("InkageStatus").getValue(); // String inkageStatus ="1"; jsonObject.append("InkageStatus", inkageStatus); + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { @@ -230,26 +218,21 @@ } } - @Scheduled(fixedDelay = 1000) - public void loadGlassIsRun() { - JSONObject jsonObject = new JSONObject(); - //鏄惁寮�濮嬪伐绋� - Engineering engineering = engineeringService.selectInitiate(1); - jsonObject.append("engineering", engineering); - //宸ヤ綅淇℃伅 - List<UpWorkstation> upWorkstations = upWorkstationService.list(); - jsonObject.append("list", upWorkstations); - ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlassIsRun"); - if (sendwServer != null) { - for (WebSocketServer webserver : sendwServer) { - if (webserver != null) { - webserver.sendMessage(jsonObject.toString()); - } else { - log.info("loadGlassIsRun is closed"); - } - } - } - } +// @Scheduled(fixedDelay = 1000) +// public void loadGlassIsRun() { +// JSONObject jsonObject = new JSONObject(); +// +// ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlassIsRun"); +// if (sendwServer != null) { +// for (WebSocketServer webserver : sendwServer) { +// if (webserver != null) { +// webserver.sendMessage(jsonObject.toString()); +// } else { +// log.info("loadGlassIsRun is closed"); +// } +// } +// } +// } public void overTask(String loadStatus, int state) { -- Gitblit v1.8.0