From 1498da813428be4e35423b6cf26fc45a203e73ab Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 13 八月 2025 16:44:06 +0800
Subject: [PATCH] 1
---
src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java | 66 ++++++++++++++++++++++++++++++++-
1 files changed, 64 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
index db82921..c61aa25 100644
--- a/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
@@ -1,6 +1,7 @@
package com.zy.asrs.service.impl;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.mapper.WrkMastMapper;
@@ -20,7 +21,9 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import java.util.ArrayList;
import java.util.Date;
+import java.util.List;
/**
* 绔嬩綋浠撳簱WCS绯荤粺涓绘祦绋嬩笟鍔�
@@ -97,7 +100,7 @@
LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
locMast.setLocSts("S");
locMast.setModiTime(new Date());
- locMastService.selectById(locMast);
+ locMastService.updateById(locMast);
}
}
}
@@ -130,7 +133,7 @@
News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�");
// 鍒ゆ柇閲嶅宸ヤ綔妗�
// 106涔熺畻涓婏紝浠ュ悗106-銆�107鐢ㄤ簬鏇存柊搴撳瓨
- WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("loc_no", "1001").in("wrk_sts", 106,107));
+ WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("loc_no", "1001").in("wrk_sts", 106, 107));
if (wrkMast == null) {
continue;
}
@@ -161,4 +164,63 @@
}
}
+ public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
+
+ add(101);
+ add(102);
+ add(103);
+ add(104);
+ add(105);
+ add(106);
+ add(107);
+ add(108);
+ }};
+
+ public synchronized void in(Integer mark) {
+ // 閬嶅巻鍏ュ簱鍙�
+ for (Integer inSta : staNos2) {
+ // 鑾峰彇鍏ュ簱绔欎俊鎭�
+ SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
+ StaProtocol staProtocol = devpThread.getStation().get(inSta);
+ if (staProtocol == null) {
+ continue;
+ } else {
+ staProtocol = staProtocol.clone();
+ }
+ // 鍒ゆ柇鏄惁婊¤冻鏉′欢
+ if (!staProtocol.isAutoing() && !staProtocol.isLoading()) {
+ continue;
+ }
+ // && staProtocol.isInEnable()
+ if (staProtocol.isInEnable()) {
+ getWrk(staProtocol, "-2");
+ }
+ if (staProtocol.isOutEnable()) {
+ getWrk(staProtocol, "-3");
+ }
+ }
+ }
+
+ private void getWrk(StaProtocol staProtocol, String lev) {
+ List<WrkMast> sourceLocNo = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("source_loc_no", staProtocol.getSiteId() + lev));
+ if (!Cools.isEmpty(sourceLocNo) && !sourceLocNo.isEmpty()) {
+ return;
+ }
+ WrkMast in = new WrkMast();
+ in.setSourceLocNo(staProtocol.getSiteId() + lev);
+ in.setLocNo("");
+ in.setIoType(10);
+ in.setIoTime(new Date());
+ in.setWrkSts(1L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+ in.setIoPri(13D); // 浼樺厛绾э細13
+ in.setFullPlt("Y"); // 婊℃澘锛歒
+ in.setPicking("N"); // 鎷ｆ枡
+ in.setExitMk("N"); // 閫�鍑�
+ in.setEmptyMk("Y"); // 绌烘澘
+ in.setLinkMis("N");
+ in.setAppeTime(new Date());
+ in.setModiTime(new Date());
+ wrkMastService.insert(in);
+ }
+
}
--
Gitblit v1.9.1