From 8db5b45c853fe5e49f2bca9047ea63e739cb8d79 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期六, 25 五月 2024 08:21:24 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownCacheGlassTask.java | 47 ++++++++++++++++++++++++++++++++--------------- 1 files changed, 32 insertions(+), 15 deletions(-) diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownCacheGlassTask.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownCacheGlassTask.java index 69b61b3..d8361e1 100644 --- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownCacheGlassTask.java +++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownCacheGlassTask.java @@ -2,6 +2,7 @@ import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; +import cn.hutool.json.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.mes.common.S7object; import com.mes.common.config.Const; @@ -21,6 +22,7 @@ import com.mes.glassinfo.service.GlassInfoService; import com.mes.downglassinfo.entity.DownGlassTask; import com.mes.downglassinfo.service.DownGlassTaskService; +import com.mes.tools.WebSocketServer; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -28,6 +30,7 @@ import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -63,7 +66,7 @@ // @Value("${mes.threshold}") private int threshold; - //@Scheduled(fixedDelay = 1000) + // @Scheduled(fixedDelay = 1000) public void plcdownGlassTask() { // PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; // String taskRequestTypeValue = plcParameterObject.getPlcParameter("A06_request_word").getValue(); @@ -74,14 +77,14 @@ // String G06RobotTaskRequestWord = plcParameterObject.getPlcParameter("G06RobotTaskRequestWord").getAddress(); - String taskRequestTypeValue ="3"; + String taskRequestTypeValue ="0"; String glassIdeValue ="NG24041101C002-2-6-1-6"; String confirmationWrodValue ="1"; String outGlassstate="1"; String confirmationWrodAddress="1"; - String G11RobotTaskRequestWord ="1"; - String G06RobotTaskRequestWord ="1"; - String G13RobotTaskRequestWord ="1"; + String G11RobotTaskRequestWord ="0"; + String G06RobotTaskRequestWord ="0"; + String G13RobotTaskRequestWord ="0"; log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佷负锛歿}", taskRequestTypeValue, glassIdeValue, confirmationWrodValue, outGlassstate); @@ -127,6 +130,8 @@ + + } /** @@ -144,9 +149,19 @@ } log.info("2銆佽幏鍙栧埌鐨勭幓鐠冧俊鎭负{}", glassInfo); -// if(glassInfo.getFlowCardId()=){ -// -// } + if (glassInfo.getGlassId().equals(downStorageCageDetailsService.DirectConnection()) ) { + //鐩撮�� + log.info("3銆佸鏋滃綋鍓嶇幓鐠冨睘浜庣増鍥緄d鍜岀墖搴忕殑椤哄簭鍒欑洿閫氾紝鎵ц涓嬬墖浠诲姟"); + DownWorkstation downWorkstation = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>().eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); + int WorkstationId=downWorkstation.getWorkstationId(); + DownGlassTask downGlassTask = downStorageCageService.createDownGlassTask(glassInfo, "0", String.valueOf(WorkstationId), "3"); + downGlassTaskService.insertCacheTask(downGlassTask); + + }else{ + + log.info("4銆佸鏋滀笉灞炰簬鐗堝浘id鍜岀墖搴忕殑椤哄簭鎵ц杩涚墖浠诲姟"); + + //娣诲姞杩涚墖浠诲姟 鏌ユ壘绌烘牸 List<DownStorageCageDetails> list = downStorageCageService.selectCacheEmpty(); if(list.size()>0){ @@ -154,8 +169,8 @@ - log.info("3銆佹煡璇㈠崸寮忕悊鐗囩閲岄潰鐨勭┖鏍�:{}", list); - log.info("4銆佸皢鐜荤拑淇℃伅鎻掑叆鍗у紡鐞嗙墖绗�,褰撳墠鐜荤拑淇℃伅:{}", glassInfo); + log.info("5銆佹煡璇㈠崸寮忕悊鐗囩閲岄潰鐨勭┖鏍�:{}", list); + log.info("6銆佸皢鐜荤拑淇℃伅鎻掑叆鍗у紡鐞嗙墖绗�,褰撳墠鐜荤拑淇℃伅:{}", glassInfo); DownStorageCageDetails details = new DownStorageCageDetails(); BeanUtils.copyProperties(glassInfo, details); details.setState(1); @@ -163,17 +178,19 @@ details.setSlot(item.getSlot()); details.setDeviceId(item.getDeviceId()); downStorageCageDetailsService.save(details); - log.info("5銆佺幓鐠冧俊鎭凡瀛樺叆鐞嗙墖绗艰鎯呰〃锛岀幓鐠冧俊鎭负{}", details); + log.info("7銆佺幓鐠冧俊鎭凡瀛樺叆鐞嗙墖绗艰鎯呰〃锛岀幓鐠冧俊鎭负{}", details); DownGlassTask downGlassTask = downStorageCageService.createDownGlassTask(glassInfo, "0", item.getSlot() + "", "1"); //娣诲姞杩涚墖浠诲姟 - log.info("6銆佺敓鎴愯繘鐗囦换鍔′俊鎭瓨鍏ヤ换鍔¤〃{}", downGlassTask); + log.info("8銆佺敓鎴愯繘鐗囦换鍔′俊鎭瓨鍏ヤ换鍔¤〃{}", downGlassTask); downGlassTaskService.insertCacheTask(downGlassTask); } + + + + } + log.info("9銆佸彂閫佺‘璁ゅ瓧瀹屾垚"); //S7object.getinstance().plccontrol.WriteWord(confirmationWrodAddress, (short) 1); - log.info("7銆佸彂閫佺‘璁ゅ瓧瀹屾垚"); - - } /** -- Gitblit v1.8.0