From ebcaed76a00f824e57ccd7e2c38efe725e160374 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期二, 17 十一月 2020 16:02:01 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/CrnController.java | 62 +++++++++++++++++++++++++++++-- 1 files changed, 58 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java index 7829f11..75e0789 100644 --- a/src/main/java/com/zy/asrs/controller/CrnController.java +++ b/src/main/java/com/zy/asrs/controller/CrnController.java @@ -3,9 +3,11 @@ import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.annotations.ManagerAuth; +import com.core.common.Cools; import com.core.common.R; import com.core.exception.CoolException; import com.zy.asrs.domain.enums.CrnStatusType; +import com.zy.asrs.domain.param.CrnDemoParam; import com.zy.asrs.domain.param.CrnOperatorParam; import com.zy.asrs.domain.vo.CommandLogVo; import com.zy.asrs.domain.vo.CrnMsgTableVo; @@ -16,6 +18,8 @@ import com.zy.asrs.mapper.BasCrnErrorMapper; import com.zy.asrs.service.BasCrnpService; import com.zy.asrs.service.WrkMastService; +import com.zy.asrs.service.impl.MainServiceImpl; +import com.zy.core.CrnThread; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.OutputQueue; import com.zy.core.cache.SlaveConnection; @@ -28,7 +32,7 @@ import com.zy.core.model.command.CrnCommand; import com.zy.core.model.protocol.CrnProtocol; import com.zy.core.properties.SlaveProperties; -import com.zy.core.thread.CrnThread; +import com.zy.core.properties.SystemProperties; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; @@ -55,6 +59,8 @@ private BasCrnErrorMapper basCrnErrorMapper; @Autowired private BasCrnpService basCrnpService; + @Autowired + private MainServiceImpl mainService; @ManagerAuth(memo = "杩涜涓殑鍛戒护") @@ -121,8 +127,8 @@ vo.setForkOffset(crnProtocol.getForkPosType().desc); // 璐у弶浣嶇疆 vo.setXLocation(crnProtocol.getWalkPos() == 1?"鏄�":"鍚�"); // 璧拌瀹氫綅 vo.setYLocation(crnProtocol.getLiftPosType().equals(CrnLiftPosType.NONE)?"鍚�":"鏄�"); // 鍗囬檷瀹氫綅 - vo.setStop(crnProtocol.getCrnTemp1().stop?"鏄�":"鍚�"); // 鎬ュ仠 - vo.setWarnCode(String.valueOf(crnProtocol.getAlarm())); // 寮傚父鐮� + vo.setStop(crnProtocol.getCrnError1().controlStop||crnProtocol.getCrnError1().mainStop||crnProtocol.getCrnError1().remoteStop?"鏄�":"鍚�"); // 鎬ュ仠 + vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1())); // 寮傚父鐮� } return R.ok().add(list); } @@ -148,7 +154,7 @@ } vo.setWorkNo(crnProtocol.getTaskNo()); // 浠诲姟鍙� - BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm()); + BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1()); if (null != crnError) { vo.setError(crnError.getErrName()); } @@ -188,6 +194,23 @@ return R.ok().add(str.toString()); } + @PostMapping("/demo/switch") + @ManagerAuth(memo = "鍫嗗灈鏈烘紨绀�") + public R crnDemo(CrnDemoParam param) throws InterruptedException { + if (Cools.isEmpty(param.getCrnId())){ + return R.error(); + } + if (Cools.isEmpty(param.getPassword())){ + return R.error("璇疯緭鍏ュ彛浠�"); + } + if (!param.getPassword().equals(SystemProperties.WCS_PASSWORD)){ + return R.error("鍙d护閿欒"); + } + Thread.sleep(200L); + mainService.crnDemoOfLocMove(param.getCrnId()); + return R.ok(); + } + /****************************************************************/ /************************** 鎵嬪姩鎿嶄綔 ******************************/ @@ -207,6 +230,7 @@ command.setDestinationPosX(param.getRow()); // 鐩爣搴撲綅鎺� command.setDestinationPosY(param.getBay()); // 鐩爣搴撲綅鍒� command.setDestinationPosZ(param.getLev()); // 鐩爣搴撲綅灞� + staNoProcess(param, command); return crnControl(command)?R.ok():R.error(); } @@ -224,6 +248,7 @@ command.setDestinationPosX(param.getRow()); // 鐩爣搴撲綅鎺� command.setDestinationPosY(param.getBay()); // 鐩爣搴撲綅鍒� command.setDestinationPosZ(param.getLev()); // 鐩爣搴撲綅灞� + staNoProcess(param, command); return crnControl(command)?R.ok():R.error(); } @@ -241,6 +266,7 @@ command.setDestinationPosX(param.getRow()); // 鐩爣搴撲綅鎺� command.setDestinationPosY(param.getBay()); // 鐩爣搴撲綅鍒� command.setDestinationPosZ(param.getLev()); // 鐩爣搴撲綅灞� + staNoProcess(param, command); return crnControl(command)?R.ok():R.error(); } @@ -258,6 +284,7 @@ command.setDestinationPosX(param.getStaNo()); // 鐩爣搴撲綅鎺� command.setDestinationPosY((short) 0); // 鐩爣搴撲綅鍒� command.setDestinationPosZ((short) 1); // 鐩爣搴撲綅灞� + staNoProcess(param, command); return crnControl(command)?R.ok():R.error(); } @@ -309,6 +336,7 @@ command.setDestinationPosX(param.getRow()); // 鐩爣搴撲綅鎺� command.setDestinationPosY(param.getBay()); // 鐩爣搴撲綅鍒� command.setDestinationPosZ(param.getLev()); // 鐩爣搴撲綅灞� + staNoProcess(param, command); return crnControl(command)?R.ok():R.error(); } @@ -422,4 +450,30 @@ return false; } + private void staNoProcess(CrnOperatorParam param, CrnCommand command){ + if (param.getSourceStaNo()!=null) { + if (param.getSourceStaNo() == 5) { + command.setSourcePosX((short) 2); // 婧愬簱浣嶆帓 + command.setSourcePosY((short) 0); // 婧愬簱浣嶅垪 + command.setSourcePosZ((short) 1); // 婧愬簱浣嶅眰 + } else if (param.getSourceStaNo() == 6) { + command.setSourcePosX((short) 1); // 婧愬簱浣嶆帓 + command.setSourcePosY((short) 0); // 婧愬簱浣嶅垪 + command.setSourcePosZ((short) 1); // 婧愬簱浣嶅眰 + } + } + if (param.getStaNo()!=null) { + if (param.getStaNo() == 5) { + command.setDestinationPosX((short) 2); // 鐩爣搴撲綅鎺� + command.setDestinationPosY((short) 0); // 鐩爣搴撲綅鍒� + command.setDestinationPosZ((short) 1); // 鐩爣搴撲綅灞� + } else if (param.getStaNo() == 6) { + command.setDestinationPosX((short) 1); // 鐩爣搴撲綅鎺� + command.setDestinationPosY((short) 0); // 鐩爣搴撲綅鍒� + command.setDestinationPosZ((short) 1); // 鐩爣搴撲綅灞� + } + } + } + + } -- Gitblit v1.9.1