From f7371a4a3413ec37931b26a95b7b0290a46219f2 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 10 四月 2026 15:18:56 +0800
Subject: [PATCH] Merge branch 'rcs_master' into jdxaj
---
zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/thread/S7DevpThread.java | 179 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 179 insertions(+), 0 deletions(-)
diff --git a/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/thread/S7DevpThread.java b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/thread/S7DevpThread.java
new file mode 100644
index 0000000..3aed2d0
--- /dev/null
+++ b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/thread/S7DevpThread.java
@@ -0,0 +1,179 @@
+//package com.zy.acs.conveyor.core.thread;
+//
+//import com.alibaba.fastjson.JSON;
+//import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
+//import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
+//import com.zy.acs.common.utils.ByteUtils;
+//import com.zy.acs.common.utils.News;
+//import com.zy.acs.conveyor.core.DevpThread;
+//import com.zy.acs.conveyor.core.cache.SlaveConnection;
+//import com.zy.acs.conveyor.core.constant.DeviceField;
+//import com.zy.acs.conveyor.core.constant.PlcConstant;
+//import com.zy.acs.conveyor.core.constant.StationStatusField;
+//import com.zy.acs.conveyor.core.constant.TaskField;
+//import com.zy.acs.conveyor.core.enums.SlaveType;
+//import com.zy.acs.conveyor.core.model.StaProtocol;
+//import com.zy.acs.conveyor.core.properties.DevpSlave;
+//import com.zy.acs.conveyor.entity.Devp;
+//import com.zy.acs.conveyor.service.DevpService;
+//import com.zy.acs.conveyor.utils.SpringContextUtil;
+//import com.zy.acs.framework.common.Cools;
+//import com.zy.acs.framework.common.DateUtils;
+//import lombok.Data;
+//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.concurrent.ConcurrentHashMap;
+//
+/// **
+// * 杈撻�佺嚎绾跨▼
+// * Created by vincent on 2020/8/4
+// */
+//@Data
+//@Slf4j
+//public class S7DevpThread implements Runnable, DevpThread {
+//
+// private DevpSlave slave;
+//
+// private S7PLC s7PLC;
+//
+// private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
+//
+//
+// @Override
+// @SuppressWarnings("InfiniteLoopStatement")
+// public void run() {
+// connect();
+// while (true) {
+// try {
+// TaskType step = TaskType.READ;
+// Task task = MessageQueue.poll(SlaveType.Devp, slave.getId());
+// if (task != null) {
+// step = task.getStep();
+// }
+// switch (step) {
+// // 璇绘暟鎹�
+// case READ:
+// read();
+// break;
+// // 鍐欐暟鎹� ID+鐩爣绔�
+// case WRITE:
+// write((StaProtocol) task.getData());
+// break;
+// default:
+// break;
+// }
+// Thread.sleep(100);
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+//
+// }
+// }
+//
+//
+// @Override
+// public boolean connect() {
+// s7PLC = new S7PLC(EPlcType.S1200, slave.getIp());
+// s7PLC.connect();
+// return true;
+// }
+//
+// /**
+// * 璇诲彇鐘舵�� ====> 鏁村潡plc
+// */
+// private void read() throws InterruptedException {
+// List<Integer> staNos = slave.getStaNos();
+// int staNoSize = staNos.size();
+// byte[] stationStatus = s7PLC.readByte(StationStatusField.TASK_NUMBER.getAddressPattern() + PlcConstant.ADDRESS_CONCATENATION + StationStatusField.TASK_NUMBER.getOffset(), StationStatusField.TASK_NUMBER.getOffset() + staNoSize * StationStatusField.ALL.getByteLength());
+// for (int i = 0; i < staNoSize; i++) {
+// // 绔欑偣缂栧彿
+// Integer siteId = staNos.get(i);
+// StaProtocol staProtocol = station.get(siteId);
+// if (null == staProtocol) {
+// staProtocol = new StaProtocol();
+// staProtocol.setSiteId(siteId);
+// station.put(siteId, staProtocol);
+// }
+// staProtocol.setWorkNo((int) ByteUtils.getLong(stationStatus, StationStatusField.TASK_NUMBER.getOffset() + i * StationStatusField.ALL.getByteLength()));
+// staProtocol.setStaNo((int) ByteUtils.getShort(stationStatus, StationStatusField.FINAL_TARGET.getOffset() + i * StationStatusField.ALL.getByteLength()));
+// boolean[] status = ByteUtils.getBooleans(stationStatus, StationStatusField.STATUS_WORD.getOffset() + i * StationStatusField.ALL.getByteLength(), StationStatusField.STATUS_WORD.getByteLength());
+// staProtocol.setAutoing(status[0]); // 鑷姩
+// staProtocol.setLoading(status[1]); // 鏈夌墿
+// staProtocol.setInEnable(status[2]); // 鍙叆
+// staProtocol.setOutEnable(status[3]);// 鍙嚭
+// staProtocol.setEmptyMk(status[4]); // 绌烘澘淇″彿
+// staProtocol.setFullPlt(status[5]); // 婊℃墭鐩�
+// staProtocol.setHigh(status[6]); // 楂樺簱浣�
+// staProtocol.setLow(status[7]); // 浣庡簱浣�
+// if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
+// staProtocol.setPakMk(true);
+// }
+// }
+// List<Integer> barcodeNumber = slave.getBarcodeArr();
+// byte[] deviceField = s7PLC.readByte(DeviceField.BARCODE.getAddressPattern() + PlcConstant.ADDRESS_CONCATENATION + DeviceField.BARCODE.getOffset(), DeviceField.BARCODE.getOffset() + DeviceField.BARCODE.getByteLength() * barcodeNumber.size());
+// for (int i = 0; i < barcodeNumber.size(); i++) {
+// String barcode = ByteUtils.getString(deviceField, i * DeviceField.BARCODE.getByteLength(), DeviceField.BARCODE.getByteLength());
+// BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeNumber.get(i));
+// if (Cools.isEmpty(barcode)) {
+// barcodeThread.clearBarcode();
+// } else {
+// if (!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
+// barcodeThread.setBarcode(barcode);
+// log.info("鏂欑鐮侊細{}", barcode);
+// }
+// }
+// }
+//
+//
+// // 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
+// try {
+// List<Devp> devps = new ArrayList<>();
+// for (Integer siteId : staNos) {
+// StaProtocol staProtocol = station.get(siteId);
+// devps.add(staProtocol.toSqlModel());
+// }
+// DevpService devpService = SpringContextUtil.getBean(DevpService.class);
+// if (null != devpService) {
+// devpService.updateBatchByDevpNo(devps);
+// } else {
+// throw new Exception("鏇存柊鏁版嵁搴撴暟鎹け璐�");
+// }
+// } catch (Exception e) {
+// e.printStackTrace();
+// News.error("SiemensDevp" + " - 3" + " - 鏇存柊鏁版嵁搴撴暟鎹け璐� ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
+// }
+//
+//
+// }
+//
+// /**
+// * 鍐欏叆 ID+鐩爣绔� =====> 鍗曠珯鐐瑰啓鍏�
+// */
+// private void write(StaProtocol staProtocol) throws InterruptedException {
+// if (null == staProtocol) {
+// return;
+// }
+// List<Integer> staNos = slave.getStaNos();
+// int index = staNos.indexOf(staProtocol.getSiteId());
+//
+// s7PLC.writeInt32(TaskField.TASK_NUMBER.getAddressPattern() + PlcConstant.ADDRESS_CONCATENATION + (TaskField.DEST_STATION.getOffset() + index * TaskField.ALL.getByteLength()), staProtocol.getWorkNo()); // 宸ヤ綔鍙�
+// Thread.sleep(100);
+// s7PLC.writeInt16(TaskField.DEST_STATION.getAddressPattern() + PlcConstant.ADDRESS_CONCATENATION + (index * TaskField.ALL.getByteLength() + TaskField.DEST_STATION.getOffset() + TaskField.DEST_STATION.getAddressPattern()), staProtocol.getStaNo().shortValue()); // 鐩爣绔�
+//
+// OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(staProtocol)));
+// News.error("SiemensDevp" + " - 4" + " - 鍐欏叆杈撻�佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(staProtocol));
+// }
+//
+//
+// @Override
+// public void close() {
+// s7PLC.close();
+// }
+//
+//
+//}
--
Gitblit v1.9.1