From d0e95ce34ec339b89cbcb4a3e5457b91544ae084 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期三, 17 十二月 2025 09:26:16 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 172 ++++++++++++++++++++++++++++++++++++++++++++------------
1 files changed, 134 insertions(+), 38 deletions(-)
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 7fddf25..a7559d7 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -7,6 +7,7 @@
import com.core.common.Cools;
import com.core.common.DateUtils;
import com.core.exception.CoolException;
+import com.zy.asrs.domain.enums.WorkNoType;
import com.zy.asrs.entity.*;
import com.zy.asrs.mapper.BasCrnErrorMapper;
import com.zy.asrs.mapper.TestMastMapper;
@@ -158,7 +159,7 @@
// 閫�鍥�
- if (back ||(!Cools.isEmpty(barcode) && barcode.equals("00000000"))) {
+ if (back || (!Cools.isEmpty(barcode) && barcode.equals("00000000"))) {
staProtocol.setWorkNo((short) 9999);
staProtocol.setStaNo(inSta.getBackSta().shortValue());
devpThread.setPakMk(staProtocol.getSiteId(), false);
@@ -209,7 +210,7 @@
} else if (jsonObject.getInteger("code").equals(700) && (!barcodeThread.getBarcode().equals("NG"))) {
StartupDto dto = jsonObject.getObject("data", StartupDto.class);
barcodeThread.setBarcode("");
- staProtocol.setWorkNo((short) 9991);
+ staProtocol.setWorkNo((short) 9999);
staProtocol.setStaNo(inSta.getBackSta().shortValue());
devpThread.setPakMk(staProtocol.getSiteId(), true);
boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -217,7 +218,7 @@
} else {
StartupDto dto = jsonObject.getObject("data", StartupDto.class);
barcodeThread.setBarcode("");
- staProtocol.setWorkNo((short) 9991);
+ staProtocol.setWorkNo((short) 9999);
staProtocol.setStaNo(inSta.getBackSta().shortValue());
devpThread.setPakMk(staProtocol.getSiteId(), true);
boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -1014,7 +1015,7 @@
WrkMast wrkMast = null;
if (Cools.isEmpty(wrkMasts)) {
return;
- }else {
+ } else {
wrkMast = wrkMasts.get(0);
}
// //鍚庢煡绛夊緟搴撲綅杞祴璇曞簱浣�
@@ -1285,15 +1286,36 @@
// 绔欑偣鏉′欢鍒ゆ柇
if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()
- && staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() == 9999 || staProtocol.getWorkNo() == 9990 || staProtocol.getWorkNo() == 9997) && staProtocol.isPakMk()) {
-
+ && staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 9996 && staProtocol.isPakMk()) {
try {
+ // 鑾峰彇鏉＄爜鎵弿浠俊鎭�
+ BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, emptyInSta.getBarcode());
+ String barcode = barcodeThread.getBarcode();
+
+ if ((!Cools.isEmpty(barcode) && barcode.equals("00000000"))) {
+ staProtocol.setWorkNo((short) 9999);
+ staProtocol.setStaNo(emptyInSta.getBackSta().shortValue());
+ devpThread.setPakMk(staProtocol.getSiteId(), false);
+ boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+
+ // led 寮傚父鏄剧ず
+ LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, emptyInSta.getLed());
+ if (ledThread != null) {
+ MessageQueue.offer(SlaveType.Led, emptyInSta.getLed(), new Task(3, "娌℃湁鎵埌鎵樼洏鐮侊紒锛侊紒锛�"));
+ }
+ continue;
+ }
+ WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", barcode).eq("io_type",101));
+ if (!Cools.isEmpty(wrkMast)) {
+ wrkMast.setWrkSts(15L);//鍑哄簱瀹屾垚杞巻鍙叉。
+ }
LocTypeDto locTypeDto = new LocTypeDto(staProtocol);
SearchLocParam param = new SearchLocParam();
param.setIoType(10);
param.setSourceStaNo(emptyInSta.getStaNo());
param.setLocType1(locTypeDto.getLocType1());
+ param.setBarcode(barcode);
String response = new HttpHandler.Builder()
.setUri(wmsUrl)
.setPath("/rpc/pakin/loc/v1")
@@ -1408,7 +1430,7 @@
if (null == wrkMast) {
continue;
}
- log.info(""+mark+" - 0"+" - 寮�濮嬫墽琛�:鍑哄簱 ===>> 宸ヤ綔妗ｄ俊鎭啓鍏ed鏄剧ず鍣�");
+ log.info("" + mark + " - 0" + " - 寮�濮嬫墽琛�:鍑哄簱 ===>> 宸ヤ綔妗ｄ俊鎭啓鍏ed鏄剧ず鍣�");
wrkMasts.add(wrkMast);
// 缁勮鍛戒护
LedCommand ledCommand = new LedCommand();
@@ -1439,7 +1461,7 @@
ledCommand.setEmptyMk(true);
break;
default:
- News.error(""+mark+" - 1"+" - 浠诲姟鍏ュ嚭搴撶被鍨嬮敊璇紒锛侊紒[宸ヤ綔鍙凤細{}] [鍏ュ嚭搴撶被鍨嬶細{}]", wrkMast.getWrkNo(), wrkMast.getIoType());
+ News.error("" + mark + " - 1" + " - 浠诲姟鍏ュ嚭搴撶被鍨嬮敊璇紒锛侊紒[宸ヤ綔鍙凤細{}] [鍏ュ嚭搴撶被鍨嬶細{}]", wrkMast.getWrkNo(), wrkMast.getIoType());
break;
}
ledCommand.setSourceLocNo(wrkMast.getSourceLocNo());
@@ -1448,7 +1470,7 @@
// ledCommand.setSourceStaNo(wrkMast.getSourceStaNo());
if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo());
- wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getSpecs())));
+ wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(), wrkDetl.getSpecs())));
}
commands.add(ledCommand);
}
@@ -1483,7 +1505,7 @@
if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) {
News.error("{}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
continue;
- }else {
+ } else {
ledThread.setLedMk(false);
}
}
@@ -1494,7 +1516,7 @@
wrkMast.setOveMk("Y");
wrkMast.setModiTime(new Date());
if (wrkMastMapper.updateById(wrkMast) == 0) {
- log.error(""+mark+" - 4"+" - 鏇存柊宸ヤ綔妗ｅけ璐�");
+ log.error("" + mark + " - 4" + " - 鏇存柊宸ヤ綔妗ｅけ璐�");
throw new CoolException("鏇存柊宸ヤ綔妗ｅけ璐�");
}
}
@@ -1508,7 +1530,7 @@
}
}
- log.info(""+mark+" - 0"+" - 鍑哄簱 ===>> 宸ヤ綔妗ｄ俊鎭啓鍏ed鏄剧ず鍣ㄦ墽琛屽畬鎴�");
+ log.info("" + mark + " - 0" + " - 鍑哄簱 ===>> 宸ヤ綔妗ｄ俊鎭啓鍏ed鏄剧ず鍣ㄦ墽琛屽畬鎴�");
}
/**
@@ -1697,7 +1719,8 @@
if (null == loc) {
log.error("鍙屾繁搴撲綅 --- 娴呭簱浣嶉樆濉炲紓甯革紒 寰呯Щ杞祬搴撲綅锛�" + shallowLoc.getLocNo());
- throw new CoolException("鍙屾繁搴撲綅 --- 娴呭簱浣嶉樆濉炲紓甯革紒 寰呯Щ杞祬搴撲綅锛�" + shallowLoc.getLocNo());
+ return;
+// throw new CoolException("鍙屾繁搴撲綅 --- 娴呭簱浣嶉樆濉炲紓甯革紒 寰呯Щ杞祬搴撲綅锛�" + shallowLoc.getLocNo());
}
// 鑾峰彇宸ヤ綔鍙�
@@ -2030,7 +2053,7 @@
// 鏍规嵁杈撻�佺嚎plc閬嶅巻
for (DevpSlave devp : slaveProperties.getDevp()) {
SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
- if(null != devpThread){
+ if (null != devpThread) {
//devpThread.startSignal[i][0]
//0:绌洪棽,1:寰呮祴,2:娴嬭瘯涓�;3.娴嬭瘯瀹屾垚;4.娴嬭瘯澶辫触;
@@ -2039,48 +2062,48 @@
//testMast.setStatus
//"鐘舵�� 0: 鏃犺揣 1: 绛夊緟娴嬭瘯 2:娴嬭瘯涓� 3.娴嬭瘯瀹屾垚;4.娴嬭瘯澶辫触; "
- for (int i = 0; i < 24; i++){
+ for (int i = 0; i < 24; i++) {
//鏌ヨ鍦ㄥ簱鍜岄绾﹀嚭搴�
- LocMast locMast=locMastService.selectOne(new EntityWrapper<LocMast>().eq("channel",i+1));
- if(!Cools.isEmpty(locMast)){
- if (locMast.getLocSts().equals("F")){
- TestMast testMast=testMastService.selectOne(new EntityWrapper<TestMast>()
- .eq("loc_no",locMast.getLocNo())
- .eq("user_id",locMast.getBarcode()));
- if(Cools.isEmpty(testMast)){
+ LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("channel", i + 1));
+ if (!Cools.isEmpty(locMast)) {
+ if (locMast.getLocSts().equals("F")) {
+ TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
+ .eq("loc_no", locMast.getLocNo())
+ .eq("user_id", locMast.getBarcode()));
+ if (Cools.isEmpty(testMast)) {
// log.info("2377琛岀▼搴忓紑濮嬭繍琛岋紝娴嬭瘯妗ｄ负绌猴紝璺宠繃");
continue;
}
- HashMap<String,Short> hashMap=new HashMap<>();
- if(devpThread.startSignal[i][0]!=locMast.getPackStatus()){
- hashMap.put("locSts",locMast.getPackStatus().shortValue());
- hashMap.put("channel",(short)(i*2));
- MessageQueue.offer(SlaveType.Devp, 1, new Task(6,hashMap));
+ HashMap<String, Short> hashMap = new HashMap<>();
+ if (devpThread.startSignal[i][0] != locMast.getPackStatus()) {
+ hashMap.put("locSts", locMast.getPackStatus().shortValue());
+ hashMap.put("channel", (short) (i * 2));
+ MessageQueue.offer(SlaveType.Devp, 1, new Task(6, hashMap));
}
//鍚屾璁惧鐘舵��
- if(locMast.getPackStatus()!=testMast.getStatus()){
+ if (locMast.getPackStatus() != testMast.getStatus()) {
testMast.setStatus(locMast.getPackStatus());
testMastService.updateById(testMast);
}
- if(devpThread.startSignal[i][1]!=locMast.getCtnKind()){
+ if (devpThread.startSignal[i][1] != locMast.getCtnKind()) {
locMast.setCtnKind(devpThread.startSignal[i][1]);
locMastService.updateById(locMast);
}
- }else if(locMast.getLocSts().equals("O")){
+ } else if (locMast.getLocSts().equals("O")) {
//褰撳厖鏀剧數搴撲綅涓篛绌哄簱浣嶆椂
//搴撲綅鐘舵�佹敼涓�0绌洪棽
- locMast=locMastService.selectztgx("O",i);
- if(!Cools.isEmpty(locMast)){
- HashMap<String,Short> hashMap=new HashMap<>();
- if(devpThread.startSignal[i][0]!=locMast.getPackStatus()){
- hashMap.put("locSts",(short)0);
- hashMap.put("channel",(short)(i*2));
- MessageQueue.offer(SlaveType.Devp, 1, new Task(6,hashMap));
+ locMast = locMastService.selectztgx("O", i);
+ if (!Cools.isEmpty(locMast)) {
+ HashMap<String, Short> hashMap = new HashMap<>();
+ if (devpThread.startSignal[i][0] != locMast.getPackStatus()) {
+ hashMap.put("locSts", (short) 0);
+ hashMap.put("channel", (short) (i * 2));
+ MessageQueue.offer(SlaveType.Devp, 1, new Task(6, hashMap));
locMast.setPackStatus(0);
locMastService.updateById(locMast);
}
- if(devpThread.startSignal[i][1]!=locMast.getChannel()){
+ if (devpThread.startSignal[i][1] != locMast.getChannel()) {
locMast.setCtnKind(devpThread.startSignal[i][1]);
locMastService.updateById(locMast);
}
@@ -2096,4 +2119,77 @@
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
}
+
+ /**
+ * 鍑哄簱绔欑偣鏃犺揣鏃惰嚜鍔ㄨˉ绌烘澘鍒板嚭搴撳彛
+ */
+ public void automaticEmptyBoardOutbound() {
+ // 鑾峰彇鍏ュ簱绔欎俊鎭�
+ DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
+ StaProtocol staProtocol = devpThread.getStation().get(101);
+ if (staProtocol == null) {
+ return;
+ } else {
+ staProtocol = staProtocol.clone();
+ }
+ if (staProtocol.isAutoing() && !staProtocol.isLoading()
+ && staProtocol.isOutEnable() && staProtocol.getWorkNo() == 0
+ ) {
+ WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("io_type", 110));
+ if (!Cools.isEmpty(wrkMast1)) {
+ return;
+ }
+ LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "D").orderBy("row1"));
+ if (Cools.isEmpty(locMast)) {
+ return;
+ }
+ //鐢熸垚绌烘澘鍑哄簱浠诲姟
+ // 鑾峰彇宸ヤ綔鍙�
+ int workNo = commonService.getWorkNo(WorkNoType.PAKOUT.type);
+ // 鑾峰彇婧愮珯
+ Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
+ .eq("type_no", 110)
+ .eq("stn_no", 101)
+ .eq("crn_no", locMast.getCrnNo());
+ StaDesc staDesc = staDescService.selectOne(wrapper);
+ Integer sourceStaNo = staDesc.getCrnStn();
+ if (Cools.isEmpty(sourceStaNo)) {
+ throw new CoolException("妫�绱㈡簮绔欏け璐�");
+ }
+ Date now = new Date();
+ // 淇濆瓨宸ヤ綔妗�
+ WrkMast wrkMast = new WrkMast();
+ wrkMast.setWrkNo(workNo);
+ wrkMast.setIoTime(now);
+ wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+ wrkMast.setIoType(110); // 鍏ュ嚭搴撶姸鎬侊細 110.绌烘澘鍑哄簱
+ wrkMast.setIoPri(10D);
+ wrkMast.setSourceStaNo(sourceStaNo); // 婧愮珯
+ wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
+ wrkMast.setCrnNo(locMast.getCrnNo());
+ wrkMast.setSourceLocNo(locMast.getLocNo()); // 婧愬簱浣�
+ wrkMast.setFullPlt("N"); // 婊℃澘锛歒
+ wrkMast.setPicking("N"); // 鎷ｆ枡
+ wrkMast.setExitMk("N"); // 閫�鍑�
+ wrkMast.setEmptyMk("Y"); // 绌烘澘
+ wrkMast.setLinkMis("N");
+ wrkMast.setAppeUser(9995L);
+ wrkMast.setAppeTime(now);
+ wrkMast.setModiUser(9995L);
+ wrkMast.setModiTime(now);
+ boolean res = wrkMastService.insert(wrkMast);
+ if (!res) {
+ throw new CoolException("淇濆瓨宸ヤ綔妗ｅけ璐�");
+ }
+ // 鏇存柊搴撲綅鐘舵�� D.绌烘澘 -> R.鍑哄簱棰勭害
+ if (locMast.getLocSts().equals("D")){
+ locMast.setLocSts("R");
+ locMast.setModiUser(9995L);
+ locMast.setModiTime(now);
+ if (!locMastService.updateById(locMast)) {
+ throw new CoolException("鏇存柊搴撲綅鐘舵�佸け璐�");
+ }
+ }
+ }
+ }
}
--
Gitblit v1.9.1