From 1b410cd3e265568909aaba902923d166c2a73fe9 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期三, 31 一月 2024 09:52:20 +0800
Subject: [PATCH] # 入库流程参数修改
---
src/main/java/com/zy/asrs/controller/OpenController.java | 134 +++++++++++++++++++--------------
src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 43 +++++-----
src/main/java/com/zy/asrs/entity/param/TaskCreateParam.java | 6
src/main/java/com/zy/asrs/entity/ToWmsDTO.java | 12 +-
pom.xml | 2
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 7 -
src/main/java/com/zy/asrs/service/OpenService.java | 5
7 files changed, 116 insertions(+), 93 deletions(-)
diff --git a/pom.xml b/pom.xml
index 5b3e5d3..afc0f15 100644
--- a/pom.xml
+++ b/pom.xml
@@ -200,7 +200,7 @@
</dependencies>
<build>
- <finalName>wxwcs</finalName>
+ <finalName>ryzhwcs</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index eb2cd6c..6e3ff59 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -1,7 +1,6 @@
package com.zy.asrs.controller;
import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.annotations.AppAuth;
import com.core.common.BaseRes;
@@ -11,9 +10,8 @@
import com.zy.asrs.entity.*;
import com.zy.asrs.entity.param.TaskOverParam;
import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
-import com.zy.asrs.entity.param.taskCreateParam;
+import com.zy.asrs.entity.param.TaskCreateParam;
import com.zy.asrs.service.*;
-import com.zy.common.utils.HttpHandler;
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +21,6 @@
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
-import java.sql.ResultSetMetaData;
import java.util.*;
@Slf4j
@@ -47,6 +44,8 @@
private BasCrnpService basCrnpService;
@Autowired
private StaDescService staDescService;
+ @Autowired
+ private LocMastService locMastService;
@Value("${wms.url}")
private String wmsUrl;
@@ -79,7 +78,7 @@
//鍒涘缓浠诲姟
@PostMapping("/taskCreate")
public R taskCreate(@RequestHeader String appkey,
- @RequestBody taskCreateParam param,
+ @RequestBody TaskCreateParam param,
HttpServletRequest request) {
auth(appkey, param, request);
if (Cools.isEmpty(param)) {
@@ -241,63 +240,86 @@
List<WMSAndAGVInterfaceParam> params1 =new ArrayList<>();
for (WMSAndAGVInterfaceParam param:params){
- if (Cools.isEmpty(param)){
- return R.error("鍙傛暟涓虹┖锛�");
- } else if (Cools.isEmpty(param.getTaskNo())){
- return R.error("浠诲姟鍙蜂负绌猴紒");
- } else if (Cools.isEmpty(param.getTaskType())){
- return R.error("浠诲姟绫诲瀷涓虹┖锛�");
- } else if (Cools.isEmpty(param.getWarehouseId())){
- return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
- }
- if (Cools.isEmpty(param.getTaskPriority())){
- param.setTaskPriority(1);
- }
- if (Cools.isEmpty(param.getContainerCode())){
- return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
- }
- if (Cools.isEmpty(param.getEmptyContainer())){
- return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
- }
- if (!param.getTaskType().equals("YK")){
- if (Cools.isEmpty(param.getTargetWharf())){
- return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
- }
- }
+ if (Cools.isEmpty(param)){
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getTaskNo())){
+ return R.error("浠诲姟鍙蜂负绌猴紒");
+ } else if (Cools.isEmpty(param.getTaskType())){
+ return R.error("浠诲姟绫诲瀷涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getWarehouseId())){
+ return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
+ }
+ if (Cools.isEmpty(param.getTaskPriority())){
+ param.setTaskPriority(1);
+ }
+ if (Cools.isEmpty(param.getSourceLocationCode()) || Cools.isEmpty(param.getTargetLocationCode())){
+ return R.error("鍒濆鐩爣鎴栬�呯洰鏍囦綅涓虹┖");
+ }
+// if (Cools.isEmpty(param.getContainerCode())){
+// return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
+// }
+// if (Cools.isEmpty(param.getEmptyContainer())){
+// return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
+// }
+// if (!param.getTaskType().equals("YK")){
+// if (Cools.isEmpty(param.getTargetWharf())){
+// return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+// }
+// }
- StaDesc staDesc = new StaDesc();
- if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("J")){
- staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
- .eq("crn_no",param.getTaskTunnel())
- .eq("type_no",2)
- .lt("stn_no",200));
- }else if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("H")){
- staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
- .eq("crn_no",param.getTaskTunnel())
- .eq("type_no",2)
- .lt("stn_no",400)
- .gt("stn_no",200));
- }else {
- staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
- .eq("crn_no",param.getTaskTunnel())
- .eq("type_no",2)
- .lt("stn_no",500)
- .ge("stn_no",400));
+ LocMast locMast = locMastService.selectByLocNo(param.getSourceLocationCode());
+ if(Cools.isEmpty(locMast)){
+ return R.error("鍒濆搴撲綅鏃犳硶鎵惧埌");
+ }
+
+ Integer ioType = TaskCreateParam.convertParamIoType(param.getTaskType());
+ if(ioType == 2){
+ //鍑哄簱浠诲姟鍒涘缓
+ StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+ .eq("type_no",2)
+ .eq("crn_no",locMast.getCrnNo())
+ .eq("stn_no",param.getTargetLocationCode()));
+ if(Cools.isEmpty(staDesc)){
+ return R.error("鍑哄簱璺姴涓嶅瓨鍦�");
}
param.setTargetLocationCode(staDesc.getStnNo().toString());
+ R r = openService.taskCreate(new TaskCreateParam(param));
+ }else if (ioType == 3){
+ //绉诲簱浠诲姟鍒涘缓
+
+ }
+
+// if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("J")){
+// staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+// .eq("crn_no",param.getTaskTunnel())
+// .eq("type_no",2)
+// .lt("stn_no",200));
+// }else if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("H")){
+// staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+// .eq("crn_no",param.getTaskTunnel())
+// .eq("type_no",2)
+// .lt("stn_no",400)
+// .gt("stn_no",200));
+// }else {
+// staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+// .eq("crn_no",param.getTaskTunnel())
+// .eq("type_no",2)
+// .lt("stn_no",500)
+// .ge("stn_no",400));
+// }
+ //param.setTargetLocationCode(staDesc.getStnNo().toString());
- R r = openService.taskCreate(new taskCreateParam(param));
+ R r = openService.taskCreate(new TaskCreateParam(param));
- apiLogService.save("Wms浠诲姟涓嬪彂鎺ュ彛"
- ,request.getRemoteAddr()+request.getRequestURI()
- ,appkey
- ,request.getRemoteAddr()
- ,JSON.toJSONString(param)
- ,r.toString()
- ,true
- );
-
+ apiLogService.save("Wms浠诲姟涓嬪彂鎺ュ彛"
+ ,request.getRemoteAddr()+request.getRequestURI()
+ ,appkey
+ ,request.getRemoteAddr()
+ ,JSON.toJSONString(param)
+ ,r.toString()
+ ,true
+ );
}
diff --git a/src/main/java/com/zy/asrs/entity/ToWmsDTO.java b/src/main/java/com/zy/asrs/entity/ToWmsDTO.java
index db1c4f5..0a3fe8b 100644
--- a/src/main/java/com/zy/asrs/entity/ToWmsDTO.java
+++ b/src/main/java/com/zy/asrs/entity/ToWmsDTO.java
@@ -8,7 +8,7 @@
@Data
public class ToWmsDTO {
private String warehouseId;
- //private String containerCode;
+ private String containerCode;
private String applyType;
private String wharfSource;
@@ -16,16 +16,16 @@
private List<Integer> canInboundTunnels;
// 瀹瑰櫒缂栫爜
- private String containerCode;
+ private String barcode;
//瀹瑰櫒绫诲瀷
- private String containerTypeCode;
+ private String ioType;
//鍏ュ簱绔欑紪鍙�
private Integer stationCode;
//搴撲綅绫诲瀷
- private String locationTypes;
+ private String locType;
- public ToWmsDTO(String containerCode, Integer stationCode){
- this.containerCode = containerCode;
+ public ToWmsDTO(String barcode, Integer stationCode){
+ this.barcode = barcode;
this.stationCode = stationCode;
}
diff --git a/src/main/java/com/zy/asrs/entity/param/taskCreateParam.java b/src/main/java/com/zy/asrs/entity/param/TaskCreateParam.java
similarity index 91%
rename from src/main/java/com/zy/asrs/entity/param/taskCreateParam.java
rename to src/main/java/com/zy/asrs/entity/param/TaskCreateParam.java
index a0467ce..fd7803e 100644
--- a/src/main/java/com/zy/asrs/entity/param/taskCreateParam.java
+++ b/src/main/java/com/zy/asrs/entity/param/TaskCreateParam.java
@@ -3,7 +3,7 @@
import lombok.Data;
@Data
-public class taskCreateParam {
+public class TaskCreateParam {
//浠诲姟鍙�
private String taskNo;
@@ -31,9 +31,9 @@
//鍫嗗灈鏈�
private Integer crn;
- public taskCreateParam(){};
+ public TaskCreateParam(){};
- public taskCreateParam(WMSAndAGVInterfaceParam param){
+ public TaskCreateParam(WMSAndAGVInterfaceParam param){
this.taskNo = param.getTaskNo();
this.ioType = convertParamIoType(param.getTaskType());
this.barcode = param.getContainerCode();
diff --git a/src/main/java/com/zy/asrs/service/OpenService.java b/src/main/java/com/zy/asrs/service/OpenService.java
index 3a24243..7798985 100644
--- a/src/main/java/com/zy/asrs/service/OpenService.java
+++ b/src/main/java/com/zy/asrs/service/OpenService.java
@@ -3,15 +3,14 @@
import com.core.common.R;
import com.zy.asrs.entity.param.TaskOverParam;
import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
-import com.zy.asrs.entity.param.taskCreateParam;
+import com.zy.asrs.entity.param.TaskCreateParam;
-import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
public interface OpenService {
//鍒涘缓浠诲姟
- R taskCreate(taskCreateParam param);
+ R taskCreate(TaskCreateParam param);
R AgvToWCSToWms(WMSAndAGVInterfaceParam param) throws IOException;
diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index ccfc32e..ecf5d4d 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -4,21 +4,14 @@
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
-import com.core.common.R;
-import com.core.common.SpringUtils;
import com.core.exception.CoolException;
-import com.fasterxml.jackson.databind.ObjectMapper;
import com.zy.asrs.domain.enums.TaskStatusType;
import com.zy.asrs.entity.*;
import com.zy.asrs.entity.param.TaskOverToWms;
-import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
-import com.zy.asrs.entity.param.taskCreateParam;
import com.zy.asrs.mapper.*;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.CommandUtils;
-import com.zy.asrs.utils.PostMesDataUtils;
import com.zy.asrs.utils.Utils;
-import com.zy.common.service.CommonService;
import com.zy.common.utils.HttpHandler;
import com.zy.core.CrnThread;
import com.zy.core.DevpThread;
@@ -34,7 +27,6 @@
import com.zy.core.model.protocol.StaProtocol;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.BarcodeThread;
-import com.zy.core.thread.LedThread;
import com.zy.core.thread.SiemensDevpThread;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
@@ -43,6 +35,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
import java.io.IOException;
import java.util.*;
@@ -100,6 +93,9 @@
public void generateStoreWrkFile() throws IOException, InterruptedException {
+ try {
+
+
// 鏍规嵁杈撻�佺嚎plc閬嶅巻
for (DevpSlave devp : slaveProperties.getDevp()) {
// 閬嶅巻鍏ュ簱鍙�
@@ -186,20 +182,23 @@
// 璇锋眰wms鎺ュ彛锛岃幏鍙栧伐浣滃彿鍜岀洰鏍囧簱浣�
ToWmsDTO toWmsDTO = new ToWmsDTO(barcode,staProtocol.getSiteId());
String response;
- try {
- response = new HttpHandler.Builder()
- .setHeaders(null)
- .setUri(wmsUrl)
- .setPath(inboundTaskApplyPath)
- .setJson(JSON.toJSONString(toWmsDTO))
- .build()
- .doPost();
- }catch (Exception e){
- log.error("wms閫氳澶辫触,"+e.getMessage());
- continue;
- }
+ response = new HttpHandler.Builder()
+ .setHeaders(null)
+ .setUri(wmsUrl)
+ .setPath(inboundTaskApplyPath)
+ .setJson(JSON.toJSONString(toWmsDTO))
+ .build()
+ .doPost();
JSONObject jsonObject = JSON.parseObject(response);
+ apiLogService.save("wms璇锋眰鍏ュ簱璐т綅鎺ュ彛"
+ ,wmsUrl+inboundTaskApplyPath
+ ,null
+ ,"127.0.0.1"
+ ,JSON.toJSONString(toWmsDTO)
+ ,response
+ ,true
+ );
if (jsonObject.getInteger("code").equals(200) && !Cools.isEmpty(jsonObject.get("data").toString())) {
GetWmsDto getWmsDto = JSON.parseObject(jsonObject.get("data").toString(), GetWmsDto.class);
// 鍒涙柊涓�涓叆搴撳伐浣滄。
@@ -301,6 +300,10 @@
}
}
+ } catch (Exception e) {
+ log.error("generateStoreWrkFile e", e);
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+ }
}
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 8aae7d5..45ef6a5 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -12,7 +12,7 @@
import com.zy.asrs.entity.ToWmsDTO;
import com.zy.asrs.entity.param.TaskOverParam;
import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
-import com.zy.asrs.entity.param.taskCreateParam;
+import com.zy.asrs.entity.param.TaskCreateParam;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.StaDescService;
@@ -31,7 +31,6 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
-import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.*;
@@ -60,7 +59,7 @@
@Override
- public R taskCreate(taskCreateParam param) {
+ public R taskCreate(TaskCreateParam param) {
TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
if (taskWrk != null) {
throw new CoolException(param.getTaskNo() + "浠诲姟宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
@@ -162,7 +161,7 @@
WMSAndAGVInterfaceParam data = JSONObject.parseObject(jsonObject.get("data").toString(), WMSAndAGVInterfaceParam.class);
String msg = null;
try {
- taskCreate(new taskCreateParam(data));
+ taskCreate(new TaskCreateParam(data));
}catch (Exception e){
msg = e.getMessage();
}
--
Gitblit v1.9.1