From b922fe4d80f7e278b1ff958c4c95626b27cf8266 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期五, 12 四月 2024 15:42:14 +0800
Subject: [PATCH] Merge branch 'phyzasrs' of http://47.97.1.152:5880/r/zy-asrs into phyzasrs
---
src/main/java/com/zy/asrs/service/impl/AgvWrkMastServiceImp.java | 56 ++++++++++++++++++++++----------------------------------
1 files changed, 22 insertions(+), 34 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/AgvWrkMastServiceImp.java b/src/main/java/com/zy/asrs/service/impl/AgvWrkMastServiceImp.java
index dc74a33..5a25ca3 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWrkMastServiceImp.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWrkMastServiceImp.java
@@ -10,7 +10,6 @@
import com.zy.asrs.entity.AgvWrkMast;
import com.zy.asrs.entity.param.AgvTaskCreateParam;
import com.zy.asrs.entity.param.AgvTaskParam;
-import com.zy.asrs.entity.param.AgvTaskkDescribeParam;
import com.zy.asrs.mapper.AgvWrkMastMapper;
import com.zy.asrs.service.*;
import com.zy.common.utils.HttpHandler;
@@ -20,11 +19,7 @@
import org.springframework.stereotype.Service;
import java.io.IOException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
+import java.util.*;
@Service
@Slf4j
@@ -44,9 +39,6 @@
@Value("${agv.containerArrivedPath}")
private String containerArrivedPath;
-
- @Value("${agvBasDev.maxWorkNum}")
- private int maxWrokNum;
@Autowired
AgvWrkMastMapper agvWrkMastMapper;
@@ -75,12 +67,12 @@
return true;
}
- public int startWrk(List<AgvWrkMast> agvWrkMastList, String taskType) throws IOException {
+ public int startWrk(AgvWrkMast agvWrkMast) throws IOException {
AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
- agvTaskCreateParam.setTaskType(taskType);
+ //agvTaskCreateParam.setTaskType(taskType);
- getRequestParam(agvTaskCreateParam,agvWrkMastList);
+ getRequestParam(agvTaskCreateParam,agvWrkMast);
return doHttpRequest(agvTaskCreateParam,"鎼繍浠诲姟涓嬪彂",url, taskCreatePath,null,"127.0.0.1");
@@ -164,30 +156,26 @@
}
}
- private void getRequestParam(AgvTaskCreateParam agvTaskCreateParam,List<AgvWrkMast> agvWrkMastList){
- List<AgvTaskParam> agvTaskParamList = agvWrkMastList.stream().map(agvWrkMast -> {
- AgvTaskParam agvTaskParam = new AgvTaskParam();
- AgvTaskkDescribeParam agvTaskkDescribeParam = new AgvTaskkDescribeParam();
- agvTaskParam.setTaskDescribe(agvTaskkDescribeParam);
- //AgvTaskParam
- if(agvWrkMast.getIoType() == 53 || agvWrkMast.getIoType() == 57){
- agvTaskParam.setTaskCode(-agvWrkMast.getWrkNo() + "");
- }else{
- agvTaskParam.setTaskCode(agvWrkMast.getWrkNo() + "");
- }
+ private void getRequestParam(AgvTaskCreateParam agvTaskCreateParam,AgvWrkMast agvWrkMast){
- agvTaskParam.setTaskPriority(agvWrkMast.getIoPri().intValue());
+ List<AgvTaskParam> agvTaskParamList = Arrays.asList(
+ //璧峰浣�
+ new AgvTaskParam(agvWrkMast.getSourceLocNo()),
+ //鐩爣浣�
+ new AgvTaskParam(agvWrkMast.getLocNo()));
- //AgvTaskkDescribeParam
- if(agvWrkMast.getSourceLocNo().contains("CS") || agvWrkMast.getSourceLocNo().contains("SK")){
- agvTaskkDescribeParam.setFromLocationCode(agvWrkMast.getSourceLocNo());
- }
- agvTaskkDescribeParam.setToLocationCode(agvWrkMast.getLocNo());
- agvTaskkDescribeParam.setContainerCode(agvWrkMast.getBarcode());
- return agvTaskParam;
- }).collect(Collectors.toList());
+// //璧峰浣�
+// agvTaskParamList.add(new AgvTaskParam(agvWrkMast.getSourceLocNo()));
+// //鐩爣浣�
+// agvTaskParamList.add(new AgvTaskParam(agvWrkMast.getLocNo()));
- agvTaskCreateParam.setTasks(agvTaskParamList);
+ if(agvWrkMast.getIoType() == 53 || agvWrkMast.getIoType() == 57 ){
+ agvWrkMast.setWrkNo(-agvWrkMast.getWrkNo());
+ }
+ agvTaskCreateParam.setTaskCode(agvWrkMast.getWrkNo().toString());
+ agvTaskCreateParam.setTaskTyp("F01");
+ agvTaskCreateParam.setPositionCodePath(agvTaskParamList);
+
}
private int doHttpRequest(Object requestParam, String namespace, String url, String path, String appkey, String ip){
@@ -203,7 +191,7 @@
.doPost();
JSONObject jsonObject = JSON.parseObject(response);
- int code = (int) jsonObject.get("code");
+ int code = Integer.parseInt(jsonObject.get("code").toString());
if(code != 0){
throw new CoolException("璋冪敤AGV鍝嶅簲閿欒");
}
--
Gitblit v1.9.1