From 4747e5dcb4066161b42a7a54cab542949ad5826c Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期一, 29 九月 2025 13:36:00 +0800
Subject: [PATCH] #和得服务器
---
src/main/java/com/zy/core/thread/RgvThread.java | 250 ++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 240 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index c15ac26..3bbc231 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -5,10 +5,16 @@
import HslCommunication.Profinet.Siemens.SiemensPLCS;
import HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.alibaba.fastjson.JSON;
+import com.core.common.Cools;
import com.core.common.DateUtils;
import com.core.common.SpringUtils;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.BasRgv;
+import com.zy.asrs.entity.BasRgvMap;
import com.zy.asrs.entity.BasRgvOpt;
+import com.zy.asrs.service.BasDevpService;
+import com.zy.asrs.service.BasRgvMapService;
import com.zy.asrs.service.BasRgvOptService;
import com.zy.asrs.service.BasRgvService;
import com.zy.common.utils.News;
@@ -25,11 +31,13 @@
import com.zy.core.model.command.CrnCommand;
import com.zy.core.model.command.RgvCommand;
import com.zy.core.model.protocol.RgvProtocol;
+import com.zy.core.model.protocol.StaProtocol;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import java.text.MessageFormat;
-import java.util.Date;
+import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
/**
* RGV绾跨▼
@@ -42,6 +50,8 @@
private SiemensS7Net siemensNet;
private RgvSlave slave;
private RgvProtocol rgvProtocol;
+ private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
+
/**
* 宸ヤ綅1澶嶄綅淇″彿
*/
@@ -97,7 +107,8 @@
command.setTaskStatus(RgvTaskStatusType.NONE); // 浠诲姟妯″紡
command.setTargetPosition(0); // 婧愮珯
command.setWrkTaskPri(0); // 鐩爣绔�
- write(command);
+ command.setCommand(false);
+ write2(command);
break;
default:
break;
@@ -108,6 +119,45 @@
}
}
+ }
+ private static final Set<Integer> specialSites = new HashSet<>(
+ Arrays.asList(1004,1014,1018,1028,1035));
+ public static final Map<Integer, Integer> StaPosition = new HashMap<Integer, Integer>() {{
+ put(1004, 1001);put(1014, 1011);put(1018, 1015);put(1028, 1025);put(1035, 1032);
+
+ }};
+ public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{
+ add(1);add(2);
+
+ }};
+
+ public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
+ add(3);add(4);
+
+ }};
+ /**
+ * 鍒濆鍖栫珯鐐圭姸鎬�
+ */
+ private void initSite() {
+ ArrayList<Integer> staNos = getStaNo();
+
+ // 绔欑偣缂栧彿
+ for (Integer siteId : staNos) {
+ StaProtocol staProtocol = station.get(siteId);
+ if (null == staProtocol) {
+ staProtocol = new StaProtocol();
+ staProtocol.setSiteId(siteId);
+ station.put(siteId, staProtocol);
+ }
+ staProtocol.setWorkNo(0); // ID
+ staProtocol.setAutoing(false); // 鑷姩
+ staProtocol.setLoading(false); // 鏈夌墿
+ staProtocol.setInEnable(false); // 鍙叆
+ staProtocol.setOutEnable(false); // 鍙嚭
+ staProtocol.setEmptyMk(false); // 绌烘澘淇″彿
+ staProtocol.setStaNo((short) 0); // 鐩爣绔�
+
+ }
}
/**
@@ -145,7 +195,16 @@
// rgvProtocol.setxDistance((short) 0);
// rgvProtocol.setxDuration((short) 0);
}
-
+ private ArrayList<Integer> getStaNo() {
+ switch (slave.getId()) {
+ case 1:
+ return staNos1;
+ case 2:
+ return staNos2;
+ default:
+ throw new CoolException("鏈嶅姟鍣ㄥ紓甯�");
+ }
+ }
@Override
public boolean connect() {
boolean result = false;
@@ -179,7 +238,9 @@
*/
private void readStatus(){
try {
- OperateResultExOne<byte[]> result = siemensNet.Read("DB101.0", (short) 27);
+ ArrayList<Integer> staNos = getStaNo();
+
+ OperateResultExOne<byte[]> result = siemensNet.Read("DB101.0", (short) 38);
if (result.IsSuccess) {
if (null == rgvProtocol) {
rgvProtocol = new RgvProtocol();
@@ -192,10 +253,12 @@
rgvProtocol.setStatus1(siemensNet.getByteTransform().TransInt16(result.Content, 12));
rgvProtocol.setTaskNo1(siemensNet.getByteTransform().TransInt32(result.Content, 16));
rgvProtocol.setTaskNo2(siemensNet.getByteTransform().TransInt32(result.Content, 20));
- boolean[] status1 = siemensNet.getByteTransform().TransBool(result.Content, 24, 2);
+ rgvProtocol.setStaNo1(siemensNet.getByteTransform().TransInt32(result.Content, 28));
+ rgvProtocol.setStaNo2(siemensNet.getByteTransform().TransInt32(result.Content, 32));
+ boolean[] status1 = siemensNet.getByteTransform().TransBool(result.Content, 24, 1);
rgvProtocol.setLoaded1(status1[0]);
rgvProtocol.setLoaded2(status1[1]);
- boolean[] status2 = siemensNet.getByteTransform().TransBool(result.Content, 26, 1);
+ boolean[] status2 = siemensNet.getByteTransform().TransBool(result.Content, 36,1);
rgvProtocol.setErr1(status2[0]);
rgvProtocol.setErr2(status2[1]);
rgvProtocol.setErr3(status2[2]);
@@ -203,8 +266,16 @@
rgvProtocol.setErr5(status2[4]);
rgvProtocol.setErr6(status2[5]);
rgvProtocol.setErr7(status2[6]);
- OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛", DateUtils.convert(new Date()), slave.getId()));
+ rgvProtocol.setErr8(status2[7]);
+ boolean[] status3 = siemensNet.getByteTransform().TransBool(result.Content, 37, 1);
+ rgvProtocol.setErr9(status3[0]);
+ rgvProtocol.setErr10(status3[1]);
+ rgvProtocol.setErr11(status3[2]);
+ rgvProtocol.setErr12(status3[3]);
+ BasRgvMapService basRgvMapService = SpringUtils.getBean(BasRgvMapService.class);
+
+ OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛", DateUtils.convert(new Date()), slave.getId()));
try {
// 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
BasRgvService basRgvService = SpringUtils.getBean(BasRgvService.class);
@@ -249,6 +320,9 @@
}
byte[] writeBytes = new byte[14];
command.setRgvNo(slave.getId());
+ if(specialSites.contains(command.getTargetPosition())){
+ command.setTargetPosition(StaPosition.get(command.getTargetPosition()));
+ }
writeInt32(writeBytes, 0, command.getWrkTaskPri());
writeInt32(writeBytes, 4, command.getTargetPosition());
writeInt16(writeBytes, 8, (short)command.getTaskStatus());
@@ -307,15 +381,145 @@
int writeCount2 = 0;
do {
writeCount2++;
- boolean commandFinish = true;
+ Short commandFinish = 1;
result = siemensNet.Write("DB100.34.0", commandFinish);
if(result.IsSuccess){
//RGV浠诲姟鍐欏叆鍚庯紝鍥炶涓�娆★紝鐪嬫槸鍚︽垚鍔�
Thread.sleep(200);
OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.34", (short) 2);
if (resultRead.IsSuccess) {
- commandFinish=siemensNet.getByteTransform().TransBool(resultRead.Content, 0);
- if (!commandFinish){
+ commandFinish=siemensNet.getByteTransform().TransInt16(resultRead.Content, 0);
+ if (commandFinish !=1){
+ News.error("RGV浠诲姟纭浣�"+commandFinish+"鍐欏叆鏁版嵁涓庡洖璇绘暟鎹笉涓�鑷达紒"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+ }else{
+ //浠诲姟鍛戒护鍐欏叆鎴愬姛
+ News.info("RGV浠诲姟纭浣�"+commandFinish+"鍥炶鎴愬姛锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+ break;
+ }
+ }else {
+ News.error("RGV浠诲姟纭浣�"+commandFinish+"鍥炶澶辫触锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+ }
+ } else {
+ News.error("RGV浠诲姟纭浣�"+commandFinish+"鍐欏叆澶辫触锛�"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
+ }
+ }while (writeCount2<5);
+ }
+ try {
+ // 鏃ュ織璁板綍
+ BasRgvOptService bean = SpringUtils.getBean(BasRgvOptService.class);
+ BasRgvOpt basRgvOpt = new BasRgvOpt(
+ command.getTaskNo(),
+ command.getRgvNo(),
+ new Date(),
+ command.getTaskStatus().toString(),
+ command.getTargetPosition(),
+ command.getWrkTaskPri(),
+ new Date()
+ );
+ bean.insert(basRgvOpt);
+ } catch (Exception ignore) {
+ log.error(ignore.getMessage());
+ }
+
+ if (result != null && result.IsSuccess) {
+ Thread.sleep(200);
+ this.readStatus();
+ log.info("RGV 宸ヤ綅鍛戒护涓嬪彂[id:{}] >>>>> {}", slave.getId(), JSON.toJSON(command));
+ OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 宸ヤ綅鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
+ return true;
+ } else {
+ OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆戝啓鍏GV plc宸ヤ綅鏁版嵁澶辫触 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
+ log.error("鍐欏叆RGV plc宸ヤ綅鏁版嵁澶辫触 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+ return false;
+ }
+ }
+ private boolean write2(RgvCommand command) throws InterruptedException {
+ if (null == command) {
+ log.error("RGV鍐欏叆鍛戒护涓虹┖");
+ return false;
+ }
+ OperateResultExOne<byte[]> result1 = siemensNet.Read("DB100.0", (short) 39);
+ if (result1.IsSuccess){
+ RgvCommand one = new RgvCommand();
+ one.setWrkTaskPri(siemensNet.getByteTransform().TransInt32(result1.Content, 0));//鎵ц宸ヤ綅
+ one.setTargetPosition(siemensNet.getByteTransform().TransInt32(result1.Content, 4));//琛岃蛋鐩爣绔�
+ one.setTaskStatus(siemensNet.getByteTransform().TransInt16(result1.Content, 8));//灏忚溅鐘舵��
+ one.setTaskNo(siemensNet.getByteTransform().TransInt32(result1.Content, 10));//涓嬪彂宸ヤ綔鍙�
+ News.info("RGV鍛戒护涓嬪彂鍓嶈鍙栫姸鎬乕id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+ }
+ byte[] writeBytes = new byte[36];
+ command.setRgvNo(slave.getId());
+ if(specialSites.contains(command.getTargetPosition())){
+ command.setTargetPosition(StaPosition.get(command.getTargetPosition()));
+ }
+ writeInt32(writeBytes, 0, command.getWrkTaskPri());
+ writeInt32(writeBytes, 4, command.getTargetPosition());
+ writeInt16(writeBytes, 8, (short)command.getTaskStatus());
+ writeInt32(writeBytes, 10, command.getTaskNo());
+ writeBool(writeBytes, 34, 0, command.getCommand());
+ OperateResult result = siemensNet.Write("DB100.0", writeBytes);
+
+ if (!result.IsSuccess){
+ News.error("鍐欏叆RGVplc鏁版嵁澶辫触锛岄噸鏂版坊鍔犱换鍔″埌闃熷垪 ===> [id:{}],{}",slave.getId(),JSON.toJSON(command));
+ MessageQueue.offer(SlaveType.Rgv,slave.getId(),new Task(2,command));
+ Thread.sleep(100);
+ readStatus();
+ return false;
+ }
+
+ //RGV浠诲姟鍐欏叆鍚庯紝鍥炶涓�娆★紝鐪嬫槸鍚︽垚鍔�
+ Thread.sleep(400);
+ try {
+ OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.0", (short) 14);
+ if (resultRead.IsSuccess){
+ RgvCommand one = new RgvCommand();
+ one.setWrkTaskPri(siemensNet.getByteTransform().TransInt32(resultRead.Content, 0));//鎵ц宸ヤ綅
+ one.setTargetPosition(siemensNet.getByteTransform().TransInt32(resultRead.Content, 4));//琛岃蛋鐩爣绔�
+ one.setTaskStatus(siemensNet.getByteTransform().TransInt16(resultRead.Content, 8));//灏忚溅鐘舵��
+ one.setTaskNo(siemensNet.getByteTransform().TransInt32(resultRead.Content, 10));//涓嬪彂宸ヤ綔鍙�
+ if (
+ !command.getTaskNo().equals(one.getTaskNo()) ||
+ !command.getTaskStatus().equals(one.getTaskStatus()) ||
+ !command.getWrkTaskPri().equals(one.getWrkTaskPri()) ||
+ !command.getTargetPosition().equals(one.getTargetPosition())
+ ) {
+ try{
+ News.error("RGV鍛戒护鍦板潃鍐欏叆鍚庡洖璇诲け璐id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+ }catch (Exception e){
+ try{
+ News.error("鏃ュ織鎵撳嵃澶辫触锛�===>>鍙傛暟one鎶ラ敊 [id:{}],{}", slave.getId(), JSON.toJSON(command),JSON.toJSON(resultRead));
+ }catch (Exception e1){
+ News.error("鏃ュ織鎵撳嵃澶辫触锛�===>> [id:{}],{}", slave.getId(), JSON.toJSON(command));
+ }
+ }
+ News.error("Rgv鍛戒护鍥炶澶辫触鍚庯紝閲嶆柊娣诲姞浠诲姟鍒伴槦鍒� ===>> [id:{}],{}", slave.getId(), JSON.toJSON(command));
+ MessageQueue.offer(SlaveType.Rgv, slave.getId(), new Task(2, command));
+ Thread.sleep(100);
+ readStatus();
+ return false;
+ }else {
+ News.info("RGV鍛戒护鍦板潃鍐欏叆鍚庡洖璇绘垚鍔焄id:{}] >>>>> 鍐欏叆[{}],===>>鍥炶[{}]", slave.getId(), JSON.toJSON(command),JSON.toJSON(one));
+ }
+ }
+ }catch (Exception e){
+ News.error("RGV鍛戒护鍦板潃鍐欏叆鍚庡洖璇诲嚭閿�");
+ }
+
+ if (result.IsSuccess) { //浠诲姟涓嬪彂纭
+ Thread.sleep(300);
+ //浠诲姟涓嬪彂娆℃暟
+ int writeCount2 = 0;
+ do {
+ writeCount2++;
+ Short commandFinish = 1;
+ result = siemensNet.Write("DB100.34.0", commandFinish);
+ if(result.IsSuccess){
+ //RGV浠诲姟鍐欏叆鍚庯紝鍥炶涓�娆★紝鐪嬫槸鍚︽垚鍔�
+ Thread.sleep(200);
+ OperateResultExOne<byte[]> resultRead = siemensNet.Read("DB100.34", (short) 2);
+ if (resultRead.IsSuccess) {
+ commandFinish=siemensNet.getByteTransform().TransInt16(resultRead.Content, 0);
+ if (commandFinish !=1){
News.error("RGV浠诲姟纭浣�"+commandFinish+"鍐欏叆鏁版嵁涓庡洖璇绘暟鎹笉涓�鑷达紒"+"寰幆鎵ц娆℃暟:"+writeCount2+"娆�");
}else{
//浠诲姟鍛戒护鍐欏叆鎴愬姛
@@ -380,7 +584,33 @@
}
}
+ public Integer getRgvPosI(Integer pos) {
+ if (pos == null) return 0;
+ // key: 绔欑偣鍙� value: 鍩哄噯鐗╃悊浣嶇疆
+ Map<Integer, Integer> posMap = new HashMap<>();
+ posMap.put(1004, 6534);
+ posMap.put(1007, 33634);
+ posMap.put(1010, 75174);
+ posMap.put(1014, 102124);
+ posMap.put(1018, 138224);
+ posMap.put(1021, 178034);
+ posMap.put(1024, 219684);
+ posMap.put(1028, 246724);
+ posMap.put(1031, 288194);
+ posMap.put(1035, 315204);
+ int tolerance = 50; // 鍏佽璇樊鑼冨洿
+
+ for (Map.Entry<Integer, Integer> entry : posMap.entrySet()) {
+ int site = entry.getKey();
+ int basePos = entry.getValue();
+ if (Math.abs(pos - basePos) <= tolerance) {
+ return site;
+ }
+ }
+
+ return 0; // 娌″尮閰嶅埌绔欑偣
+ }
@Override
public void close() {
--
Gitblit v1.9.1