From e90544b3ab05170775b132e5c567bb33eb436ab4 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期一, 15 七月 2024 08:55:57 +0800
Subject: [PATCH] 深浅库位冲突
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 107 ++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 93 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 3f59baa..17ccc10 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -9,7 +9,6 @@
import com.core.common.DateUtils;
import com.core.common.SpringUtils;
import com.core.exception.CoolException;
-import com.zy.asrs.domain.enums.TaskStatusType;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.CommandInfo;
import com.zy.asrs.entity.CommandInfoLog;
@@ -29,10 +28,7 @@
import lombok.extern.slf4j.Slf4j;
import java.text.MessageFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
/**
@@ -71,6 +67,12 @@
add(400);add(401);add(402);add(403);
add(404);add(405);add(406);add(407);
}};
+ public static final ArrayList<Integer> hoist1 = new ArrayList<Integer>() {{
+ add(302);add(303);
+ }};
+ public static final ArrayList<Integer> hoist2 = new ArrayList<Integer>() {{
+ add(402);add(403);
+ }};
/**
* 鏉＄爜鏁伴噺
@@ -97,6 +99,17 @@
return staNos3;
case 4:
return staNos4;
+ default:
+ throw new CoolException("鏈嶅姟鍣ㄥ紓甯�");
+ }
+ }
+
+ private ArrayList<Integer> getHoist() {
+ switch (slave.getId()) {
+ case 3:
+ return hoist1;
+ case 4:
+ return hoist2;
default:
throw new CoolException("鏈嶅姟鍣ㄥ紓甯�");
}
@@ -131,6 +144,9 @@
write2((StaProtocol)task.getData());
read();
break;
+ case 4:
+ write3((StaProtocol)task.getData());
+ break;
default:
break;
}
@@ -141,6 +157,38 @@
e.printStackTrace();
}
+ }
+ }
+
+ // 鍐欑粍鎷撲俊鍙�(娌℃湁鏌ヨ鍒拌鎵樼洏鐮佷换鍔�)
+ private void write3(StaProtocol staProtocol) {
+ // 涓�涓猻hort=涓や釜瀛楄妭=2*byte 1byte = 8浣�
+ // 鍏堣涓�娆�
+ OperateResultExOne<byte[]> read = siemensS7Net.Read("DB100.200", (short) 1);
+ if(read.IsSuccess){
+ byte[] content = read.Content;
+ boolean[] array = siemensS7Net.getByteTransform().TransBool(content, 0,1);
+ // 濡傛灉宸茬粡涓簍rue锛屽垯涓嶉噸澶嶅啓
+ boolean flag = false;
+ switch (staProtocol.getSiteId()) {
+ case 103: if(array[0]) {
+ } else array[0] = true; flag = true; break;
+ case 107: if(array[1]) {
+ } else array[1] = true; flag = true; break;
+ case 111: if(array[2]) {
+ } else array[2] = true; flag = true; break;
+ case 115: if(array[3]) {
+ } else array[3] = true; flag = true; break;
+ case 119: if(array[4]) {
+ } else array[4] = true; flag = true; break;
+ case 123: if(array[5]) {
+ } else array[5] = true; flag = true; break;
+ default:
+ }
+ if (flag) {
+ siemensS7Net.Write("DB100.200", array);
+ log.info("鍐欏叆缁勬墭淇″彿锛歿}", Arrays.toString(array));
+ }
}
}
@@ -178,8 +226,9 @@
station.put(i, staProtocol);
}
staProtocol.setWorkNo((short) 0);
- staProtocol.setNearbySta((short) 3);
+ staProtocol.setNearbySta((short) 1);
staProtocol.setLoading(false);
+ staProtocol.setAutoing(false);
}
}
}
@@ -258,20 +307,50 @@
OperateResultExOne<byte[]> resultRgvLocation = siemensS7Net.Read("DB43.0", (short) 8);
OperateResultExOne<byte[]> resultRgvload = siemensS7Net.Read("DB192.0", (short) 8);
if (resultRgvWrkNo.IsSuccess && resultRgvLocation.IsSuccess && resultRgvload.IsSuccess){
- for (int i = 1;i<5;i++){
+ for (int i = 0;i<4;i++){
short wrkNo = siemensS7Net.getByteTransform().TransInt16(resultRgvWrkNo.Content, i * 32);
short location = siemensS7Net.getByteTransform().TransInt16(resultRgvLocation.Content, i * 2);
boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRgvload.Content, i*2, 1);
- StaProtocol staProtocol = station.get(i);
+ StaProtocol staProtocol = station.get((i+1));
if (null == staProtocol) {
staProtocol = new StaProtocol();
- staProtocol.setSiteId(i);
- station.put(i, staProtocol);
+ staProtocol.setSiteId((i+1));
+ station.put((i+1), staProtocol);
}
staProtocol.setWorkNo(wrkNo);
+ staProtocol.setAutoing(true);
staProtocol.setNearbySta(location);
staProtocol.setLoading(status[0]);
}
+ }
+ }
+ if (slave.getId() == 3 || slave.getId() == 4){
+ ArrayList<Integer> hoist = getHoist();
+ int hoistSize = hoist.size();
+ OperateResultExOne<byte[]> resultHoist = siemensS7Net.Read("DB15.0", (short) 33);
+ if (resultHoist.IsSuccess) {
+ Integer siteId = hoist.get(0); // 绔欑偣缂栧彿
+ StaProtocol staProtocol = station.get(siteId);
+ if (null == staProtocol) {
+ staProtocol = new StaProtocol();
+ staProtocol.setSiteId(siteId);
+ station.put(siteId, staProtocol);
+ }
+ boolean[] status = siemensS7Net.getByteTransform().TransBool(resultHoist.Content, 32, 1);
+ staProtocol.setPlace1(status[0]);
+ staProtocol.setPlace2(status[1]);
+
+ Integer siteId2 = hoist.get(1); // 绔欑偣缂栧彿
+ staProtocol = station.get(siteId2);
+ if (null == staProtocol) {
+ staProtocol = new StaProtocol();
+ staProtocol.setSiteId(siteId);
+ station.put(siteId, staProtocol);
+ }
+ boolean[] status2 = siemensS7Net.getByteTransform().TransBool(resultHoist.Content, 32, 1);
+ staProtocol.setPlace1(status2[2]);
+ staProtocol.setPlace2(status2[3]);
+
}
}
@@ -432,14 +511,14 @@
Integer siteId = staNos.get(i); // 绔欑偣缂栧彿
boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i*4, 1);
StaProtocol staProtocol = station.get(siteId);
- staProtocol.setBreakerErr(status[0]);
- staProtocol.setInfraredErr(status[1]);
+ staProtocol.setBreakerErr(status[0]); //鎻愬崌鏈� 涓婂崌鏋侀檺
+ staProtocol.setInfraredErr(status[1]); //鎻愬崌鏈� 涓嬮檷鏋侀檺
staProtocol.setOutTimeErr(status[2]);
staProtocol.setSeizeSeatErr(status[3]);
staProtocol.setWrkYgoodsN(status[4]);
staProtocol.setInverterErr(status[5]);
- staProtocol.setContactErr(status[6]);
- staProtocol.setUpcontactErr(status[7]);
+ staProtocol.setContactErr(status[6]); //鎻愬崌鏈� 宸﹁秴闄�
+ staProtocol.setUpcontactErr(status[7]); //鎻愬崌鏈� 鍙宠秴闄�
}
}
--
Gitblit v1.9.1