From ed4cb573a3a7648f169445b648cb5450605f8d2a Mon Sep 17 00:00:00 2001
From: 18516761980 <tqsxp@163.com>
Date: 星期三, 12 十月 2022 16:00:24 +0800
Subject: [PATCH] #lsh
---
src/main/java/com/zy/asrs/controller/OpenController.java | 2
src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | 126 ++++++++++++++++++++++++++++++++++++++++-
src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java | 15 +++--
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 2
src/main/resources/application.yml | 13 ++++
5 files changed, 144 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 103054e..8c88539 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -287,7 +287,7 @@
if (Cools.isEmpty(param)) {
return R.parse(BaseRes.PARAM);
}
- if (param.getTestResult().equals("ok")){
+ if (param.getTestResult().equals("OK")){
map.put("isComplete",openService.testFinish(param));
}else {
map.put("isComplete",false);
diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index d6d7569..024a4bb 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -86,8 +86,18 @@
@Value("${mes.url}")
private String mesUrl;
- @Value("${ren.url}")
- private String renUrl;
+ @Value("${ren.url1}")
+ private String renUrl1;
+ @Value("${ren.url2}")
+ private String renUrl2;
+ @Value("${ren.url3}")
+ private String renUrl3;
+ @Value("${ren.url4}")
+ private String renUrl4;
+ @Value("${ren.url5}")
+ private String renUrl5;
+ @Value("${ren.url6}")
+ private String renUrl6;
@Value("${ren.startUpTestPACK}")
private String startUpTestPACK;
@@ -643,9 +653,28 @@
throw new CoolException("娴嬭瘯鐢宠澶辫触");
}
- if (!testMastService.insert(testMast)){
- throw new CoolException("娣诲姞testMast澶辫触");
+ TestMast testMast1 = testMastService.selectOne(new EntityWrapper<TestMast>()
+ .eq("loc_no", testMast.getLocNo())
+ .eq("barcode", testMast.getBarcode())
+ .eq("user_id",testMast.getUserId())
+ .eq("channel",locMast.getChannel().toString())
+ .lt("status",4)
+ );
+ if (Cools.isEmpty(testMast1)){
+ if (!testMastService.insert(testMast)){
+ throw new CoolException("娣诲姞testMast澶辫触");
+ }
+ }else {
+ if (!testMastService.update(testMast,new EntityWrapper<TestMast>()
+ .eq("loc_no", testMast.getLocNo())
+ .eq("barcode", testMast.getBarcode())
+ .eq("user_id",testMast.getUserId())
+ .eq("channel",locMast.getChannel().toString())
+ .lt("status",4))){
+ throw new CoolException("鏇存柊testMast澶辫触");
+ }
}
+
locMast.setPackStatus(1);
locMast.setModiTime(now);
@@ -670,6 +699,7 @@
}
@Transactional
public ReturnT<String> startUpTestPACK1(TestMast testMast){
+ String renUrl="";
try {
Review review=new Review();
review.setLocNo(testMast.getLocNo());
@@ -677,6 +707,19 @@
review.setBarcode(testMast.getBarcode());
review.setChannel(testMast.getChannel().toString());
review.setRequestTime(DateUtils.convert(new Date()));
+ if (testMast.getChannel()>=1 && testMast.getChannel()<=8){
+ renUrl=renUrl1;
+ }else if (testMast.getChannel()>=9 && testMast.getChannel()<=16){
+ renUrl=renUrl2;
+ }else if (testMast.getChannel()>=17 && testMast.getChannel()<=24){
+ renUrl=renUrl3;
+ }else if (testMast.getChannel()>=25 && testMast.getChannel()<=36){
+ renUrl=renUrl4;
+ }else if (testMast.getChannel()>=37 && testMast.getChannel()<=40){
+ renUrl=renUrl5;
+ }else if (testMast.getChannel()>=41 && testMast.getChannel()<=48){
+ renUrl=renUrl6;
+ }
return postMesData(renUrl,startUpTestPACK,review);
}catch (Exception e) {
log.error("fail", e);
@@ -687,11 +730,74 @@
}
@Transactional
public ReturnT<String> suspendTestPACK1(String channel){
+ String renUrl="";
try {
Review review=new Review();
review.setPause("true");
review.setChannel(channel);
review.setRequestTime(DateUtils.convert(new Date()));
+ switch (channel){
+ case "1":
+ case "2":
+ case "3":
+ case "4":
+ case "5":
+ case "6":
+ case "7":
+ case "8":
+ renUrl=renUrl1;
+ break;
+ case "9":
+ case "10":
+ case "11":
+ case "12":
+ case "13":
+ case "14":
+ case "15":
+ case "16":
+ renUrl=renUrl2;
+ break;
+ case "17":
+ case "18":
+ case "19":
+ case "20":
+ case "21":
+ case "22":
+ case "23":
+ case "24":
+ renUrl=renUrl3;
+ break;
+ case "25":
+ case "26":
+ case "27":
+ case "28":
+ case "29":
+ case "30":
+ case "31":
+ case "32":
+ renUrl=renUrl4;
+ break;
+ case "33":
+ case "34":
+ case "35":
+ case "36":
+ case "37":
+ case "38":
+ case "39":
+ case "40":
+ renUrl=renUrl5;
+ break;
+ case "41":
+ case "42":
+ case "43":
+ case "44":
+ case "45":
+ case "46":
+ case "47":
+ case "48":
+ renUrl=renUrl6;
+ break;
+ }
return postMesData(renUrl,suspendTestPACK,review);
}catch (Exception e) {
log.error("fail", e);
@@ -705,7 +811,17 @@
String name="";
if (URL.equals(mesUrl)){
name="mes绯荤粺";
- }else if (URL.equals(renUrl)){
+ }else if (URL.equals(renUrl1)){
+ name="娴嬭瘯绯荤粺";
+ }else if (URL.equals(renUrl2)){
+ name="娴嬭瘯绯荤粺";
+ }else if (URL.equals(renUrl3)){
+ name="娴嬭瘯绯荤粺";
+ }else if (URL.equals(renUrl4)){
+ name="娴嬭瘯绯荤粺";
+ }else if (URL.equals(renUrl5)){
+ name="娴嬭瘯绯荤粺";
+ }else if (URL.equals(renUrl6)){
name="娴嬭瘯绯荤粺";
}
if(combParam != null){
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 1fa5aa5..4ffa4ce 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -816,7 +816,7 @@
combParam.setLocNo(locMast.getLocNo());
combParam.setPackSts(3);
combParam.setRequestTime(DateUtils.convert(new Date()));
- postMesData(inpath,combParam);
+// postMesData(inpath,combParam);
if (!locMastService.update(locMast, new EntityWrapper<LocMast>().eq("loc_no", review.getLocNo()))){
throw new CoolException("鏇存敼浜у搧鐘舵�佸け璐�");
}
diff --git a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
index e71ced7..be19e16 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
@@ -71,12 +71,15 @@
combParam.setRequestTime(DateUtils.convert(new Date()));
result = postMesData(inpath,combParam);
// 淇濆瓨鍏ュ簱閫氱煡妗e巻鍙叉。
- if (!waitPakinLogService.save(wrkMast.getBarcode())) {
- exceptionHandle("淇濆瓨鍏ュ簱閫氱煡妗e巻鍙叉。[workNo={0}]澶辫触", wrkMast.getWrkNo());
- }
- // 鍒犻櫎鍏ュ簱閫氱煡妗�
- if (!waitPakinService.delete(new EntityWrapper<WaitPakin>().eq("zpallet", wrkMast.getBarcode()))) {
- exceptionHandle("鍒犻櫎鍏ュ簱閫氱煡妗workNo={0}]澶辫触", wrkMast.getWrkNo());
+ WaitPakin pakin = waitPakinService.selectOne(new EntityWrapper<WaitPakin>().eq("zpallet", wrkMast.getBarcode()));
+ if (pakin!=null){
+ if (!waitPakinLogService.save(wrkMast.getBarcode())) {
+ exceptionHandle("淇濆瓨鍏ュ簱閫氱煡妗e巻鍙叉。[workNo={0}]澶辫触", wrkMast.getWrkNo());
+ }
+ // 鍒犻櫎鍏ュ簱閫氱煡妗�
+ if (!waitPakinService.delete(new EntityWrapper<WaitPakin>().eq("zpallet", wrkMast.getBarcode()))) {
+ exceptionHandle("鍒犻櫎鍏ュ簱閫氱煡妗workNo={0}]澶辫触", wrkMast.getWrkNo());
+ }
}
}
} else if (wrkMast.getWrkSts() == 15 && wrkMast.getIoType() == 101){
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index ce97532..2c357d1 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -60,7 +60,18 @@
outPath: mes-pm/in/stock/condition/exWarehouse
ren:
- url: 172.28.15.196:12784
+ # 1~8閫氶亾
+ url1: 172.28.15.196:12784
+ # 9~16閫氶亾
+ url2: 172.28.15.197:12784
+ # 17~24閫氶亾
+ url3: 172.28.15.198:12784
+ # 25~32閫氶亾
+ url4: 172.28.15.199:12784
+ # 33~40閫氶亾
+ url5: 172.28.15.200:12784
+ # 41~48閫氶亾
+ url6: 172.28.15.201:12784
# 鍚姩娴嬭瘯璇锋眰
startUpTestPACK: TestStart
#鏆傚仠娴嬭瘯
--
Gitblit v1.9.1