From 84ea4ef19e5a4945f336dfdd788081510477dfc1 Mon Sep 17 00:00:00 2001 From: 严智鑫 <test> Date: 星期六, 12 十月 2024 14:21:10 +0800 Subject: [PATCH] 1.卧式缓存前的扫码-增加重复ID验证,2.增加钢化版图查询工程功能 --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java | 47 +++++++++++++++++++++++++++++++++++++---------- 1 files changed, 37 insertions(+), 10 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java index 946882a..22ac553 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java @@ -94,7 +94,7 @@ public static String engineerId = ""; - @Scheduled(fixedDelay = 1000) + //@Scheduled(fixedDelay = 1000) public void plcHomeEdgTask() { Date startDate = new Date(); log.info("鏈浠诲姟寮�濮嬫墽琛屾椂闂达細{}", startDate); @@ -124,8 +124,9 @@ log.info("2銆佽幏鍙栧埌鐨勮姹傚瓧涓嶄负0锛屽皢纭瀛椾笉涓�0锛岀洿鎺ョ粨鏉�"); return; } - if ("1".equals(taskRequestTypeValue)) { - log.info("2銆佽繘鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�"); + boolean result = edgStorageCageDetailsService.inToVerify(glassIdeValue); + if ("1".equals(taskRequestTypeValue)&&result) { + log.info("2銆佽繘鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�,鎵爜閲嶅ID楠岃瘉銆愭湁閲嶅=false,鏃犻噸澶�=true銆戯細{}",result); inTo(glassIdeValue, confirmationWrodAddress, currentSlot); } else if ("2".equals(taskRequestTypeValue)) { //09绌洪棽 锛�1 10绌洪棽 锛�2 閮界┖闂诧細3 鍏朵粬0 @@ -137,8 +138,8 @@ //鍔犵瀛愰噷闈㈡槸鍚︽湁鐜荤拑锛屾湁鍏堝嚭锛屾棤鐜荤拑鍏堣繘 boolean outFlase = outTo(Integer.parseInt(out08Glassstate), Integer.parseInt(out10Glassstate), confirmationWrodAddress, glassIdeValue, Integer.parseInt(currentSlot)); - log.info("鍑虹墖浠诲姟鏄惁瀹屾垚锛歿},涓旂幓鐠僫d:{}涓嶄负绌哄垯鎵ц杩涚墖浠诲姟", outFlase, glassIdeValue); - if (!outFlase && StringUtils.isNotBlank(glassIdeValue)) { + log.info("鍑虹墖浠诲姟鏄惁瀹屾垚锛歿},涓旂幓鐠僫d:{}涓嶄负绌哄垯鎵ц杩涚墖浠诲姟,鎵爜閲嶅ID楠岃瘉銆愭湁閲嶅=false,鏃犻噸澶�=true銆戯細{}", outFlase, glassIdeValue,result); + if (!outFlase && StringUtils.isNotBlank(glassIdeValue)&&result) { inTo(glassIdeValue, confirmationWrodAddress, currentSlot); } } @@ -210,7 +211,6 @@ S7object.getinstance().plccontrol.writeWord(confirmationWrodAddress, 1); log.info("7銆佸彂閫佺‘璁ゅ瓧瀹屾垚"); - } @@ -654,6 +654,13 @@ log.info("7銆佹坊鍔犲嚭鐗囩幓鐠冨昂瀵镐俊鎭埌纾ㄨ竟鍓嶇幓鐠冭〃鏄惁瀹屾垚锛歿}", glassSizeStatus); S7object.getinstance().plccontrol.writeWord(confirmationWrodAddress, 1); log.info("8銆佸彂閫佺‘璁ゅ瓧宸插畬鎴�"); + Damage damage=new Damage(); + damage.setGlassId(glassInfo.getGlassId()); + damage.setWorkingProcedure("鍒囧壊"); + damage.setLine(1001); + damage.setType(1); + damage.setRemark("杩囧崸寮忕悊鐗�"); + damageService.insertDamage(damage); return Boolean.TRUE; } return Boolean.FALSE; @@ -728,10 +735,6 @@ List<Map<String, Object>> currentCutTerritorys = edgStorageCageDetailsService.selectCutTerritory(); jsonObject.append("currentCutTerritory", currentCutTerritorys); //log.info("鏈璇嗗埆鐗堝浘{},++++{}",engineerId,currentCutTerritorys); - //纾ㄨ竟淇℃伅 - List<EdgGlassTaskInfo> edgTasks = edgGlassTaskInfoService.selectEdgInfo(); - jsonObject.append("edgTasks", edgTasks); - //鍗у缂撳瓨绗煎唴淇℃伅 List<Map<String, Object>> EdgStorageCageinfos = edgStorageCageService.selectEdgStorageCages(); jsonObject.append("EdgStorageCageinfos", EdgStorageCageinfos); @@ -771,4 +774,28 @@ } } + @Scheduled(fixedDelay = 1000) + public void CacheGlassTaskss() { + JSONObject jsonObject = new JSONObject(); + //log.info("鏈璇嗗埆鐗堝浘{},++++{}",engineerId,currentCutTerritorys); + //纾ㄨ竟淇℃伅 + List<EdgGlassTaskInfo> edgTasks = edgGlassTaskInfoService.selectEdgInfo(); + jsonObject.append("edgTasks", edgTasks); + + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("edgTasks"); + if (sendwServer != null) { + for (WebSocketServer webserver : sendwServer) { + if (webserver != null) { + webserver.sendMessage(jsonObject.toString()); + List<String> messages = webserver.getMessages(); + if (!messages.isEmpty()) { + // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛� + webserver.clearMessages(); + } + } else { + log.info("edgTasks is closed"); + } + } + } + } } -- Gitblit v1.8.0