From 2d72f443bb702ffb4e03e64501d6f797fbfbad20 Mon Sep 17 00:00:00 2001 From: 18516761980 <56479841@qq.com> Date: 星期三, 22 六月 2022 08:28:11 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/SiteController.java | 16 ++++++++++++++-- 1 files changed, 14 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java index 30500f8..e0aba4d 100644 --- a/src/main/java/com/zy/asrs/controller/SiteController.java +++ b/src/main/java/com/zy/asrs/controller/SiteController.java @@ -15,7 +15,7 @@ import com.zy.core.model.Task; import com.zy.core.model.protocol.StaProtocol; import com.zy.core.properties.SlaveProperties; -import com.zy.core.thread.DevpThread; +import com.zy.core.DevpThread; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -63,6 +63,8 @@ vo.setPakMk(staProtocol.isPakMk()?"Y":"N"); // 鍏ュ簱鏍囪 vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N"); // 绌烘澘淇″彿 vo.setStaNo(staProtocol.getStaNo()); // 鐩爣绔� +// vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�"); //楂樹綆搴撲綅 + vo.setLocType1(devp.getDevNo()==102 ? "楂�" : "浣�"); } return R.ok().add(list); } @@ -137,6 +139,7 @@ vo.setPakMk(staProtocol.isPakMk()?"Y":"N"); // 闇�姹�1 vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N"); // 绌烘澘淇″彿 vo.setStaNo(staProtocol.getStaNo()); // 鐩爣绔� + vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�"); //楂樹綆搴撲綅 return R.ok().add(vo); } } @@ -148,19 +151,28 @@ @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁") public R siteDetlUpdate(@RequestParam Integer siteId, @RequestParam Short workNo, - @RequestParam Short staNo){ + @RequestParam Short staNo, + @RequestParam String pakMk){ for (DevpSlave devp : slaveProperties.getDevp()) { DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); Map<Integer, StaProtocol> station = devpThread.getStation(); for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) { if (siteId.equals(entry.getKey())) { StaProtocol staProtocol = entry.getValue(); + if (staProtocol == null) { + continue; + } else { + staProtocol = staProtocol.clone(); + } if (workNo != null) { staProtocol.setWorkNo(workNo); } if (staNo != null) { staProtocol.setStaNo(staNo); } + if (pakMk != null) { + staProtocol.setPakMk(pakMk.equals("Y")); + } boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); if (result) { return R.ok(); -- Gitblit v1.9.1