From f95afb8ff0588bf12a53b6ff811a192bccd79546 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期五, 14 六月 2024 14:39:17 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java | 75 ++++++++++++++++++++++++------------- 1 files changed, 49 insertions(+), 26 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 c05fbee..8c66de2 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 @@ -5,7 +5,6 @@ import com.mes.device.PlcParameterObject; import com.mes.engineering.entity.Engineering; import com.mes.engineering.service.EngineeringService; -import com.mes.pp.entity.OptimizeProject; import com.mes.pp.service.OptimizeProjectService; import com.mes.tools.WebSocketServer; import com.mes.uppattenusage.entity.UpPattenUsage; @@ -47,31 +46,37 @@ @Scheduled(fixedDelay = 300) public void plcLoadGlassTask() throws InterruptedException { try { + //鑾峰彇鑱旀満鐘舵�� + String inkageStatus =plcParameterObject.getPlcParameter("MesToPlc").getValue(); //鑾峰彇鏄惁鏈変笂鐗囪姹� String loadRequest = plcParameterObject.getPlcParameter("loadRequest").getValue(); + //mes鐘舵�� String mesToPlc = plcParameterObject.getPlcParameter("MesToPlc").getValue(); - //鍒ゆ柇寮�濮嬩笂鐗囩殑宸ョ▼鍙� - Engineering engineering = engineeringService.selectInitiate(1); - if ("1".equals(loadRequest) && engineering != null) { - log.info("寮�濮嬩笂鐗囦换鍔�"); - UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering); - log.info("褰撴湁璇锋眰鏃舵煡璇㈠綋鍓嶄笂鐗囬『搴忕殑鐜荤拑淇℃伅{}", upPattenUsage); - UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage); - log.info("绗﹀悎鐨勫昂瀵哥殑宸ヤ綅鐜荤拑锛歿}", upwork); - if (upwork != null) { - int workId = upwork.getWorkstationId();//宸ヤ綅id - double width = upwork.getPatternWidth();//瀹藉害 - double height = upwork.getPatternHeight();//楂樺害 - S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("WorkId").getAddress(), workId); - S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (long) width); - S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (long) height); - S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 1); - //鏇存敼涓婄墖琛ㄧ姸鎬� - upPattenUsageService.updateUpPattenUsageState(upPattenUsage, workId); + if("1".equals(inkageStatus)&&"1".equals(loadRequest)) { + //鍒ゆ柇寮�濮嬩笂鐗囩殑宸ョ▼鍙� + Engineering engineering = engineeringService.selectInitiate(1); + if (engineering != null) { + log.info("寮�濮嬩笂鐗囦换鍔�"); + UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering); + log.info("褰撴湁璇锋眰鏃舵煡璇㈠綋鍓嶄笂鐗囬『搴忕殑鐜荤拑淇℃伅{}", upPattenUsage); + UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage); + log.info("绗﹀悎鐨勫昂瀵哥殑宸ヤ綅鐜荤拑锛歿}", upwork); + if (upwork != null) { + int workId = upwork.getWorkstationId();//宸ヤ綅id + double width = upwork.getPatternWidth();//瀹藉害 + double height = upwork.getPatternHeight();//楂樺害 + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("WorkId").getAddress(), workId); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (long) width); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (long) height); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 1); + //鏇存敼涓婄墖琛ㄧ姸鎬� + upPattenUsageService.updateUpPattenUsageState(upPattenUsage, workId); + } } + } - if("1".equals(mesToPlc)&& "0".equals(loadRequest)){ + if ("1".equals(mesToPlc) && "0".equals(loadRequest)) { //璇锋眰瀛椾负闆舵椂锛屼换鍔″瓧娓呴浂 S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 0); } @@ -110,7 +115,7 @@ } } - @Scheduled(fixedDelay = 300) + @Scheduled(fixedDelay = 1000) public void loadGlassHome(){ JSONObject jsonObject = new JSONObject(); //姝e湪杩涜鐨勪换鍔� @@ -124,11 +129,29 @@ for (WebSocketServer webserver : sendwServer) { if (webserver != null) { webserver.sendMessage(jsonObject.toString()); - List<String> messages = webserver.getMessages(); - if (!messages.isEmpty()) { - // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛� - webserver.clearMessages(); - } +// List<String> messages = webserver.getMessages(); +// if (!messages.isEmpty()) { +// // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛� +// webserver.clearMessages(); +// } + } else { + log.info("Home is closed"); + } + } + } + } + @Scheduled(fixedDelay = 5000) + public void loadGlassStatus(){ + JSONObject jsonObject = new JSONObject(); + //姝e湪杩涜鐨勪换鍔� + String inkageStatus =plcParameterObject.getPlcParameter("MesToPlc").getValue(); + //String inkageStatus ="1"; + jsonObject.append("InkageStatus", inkageStatus); + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass"); + if (sendwServer != null) { + for (WebSocketServer webserver : sendwServer) { + if (webserver != null) { + webserver.sendMessage(jsonObject.toString()); } else { log.info("Home is closed"); } -- Gitblit v1.8.0