package com.zy.core.thread; import HslCommunication.Core.Types.OperateResult; import HslCommunication.Core.Types.OperateResultExOne; import HslCommunication.Profinet.Siemens.SiemensPLCS; import HslCommunication.Profinet.Siemens.SiemensS7Net; import com.alibaba.fastjson.JSON; import com.core.common.DateUtils; import com.zy.core.ThreadHandler; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.OutputQueue; import com.zy.core.enums.SlaveType; import com.zy.core.model.DevpSlave; import com.zy.core.model.Task; 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.Map; import java.util.concurrent.ConcurrentHashMap; /** * 输送线线程 * Created by vincent on 2020/8/4 */ @Data @Slf4j public class DevpThread implements Runnable, ThreadHandler { private DevpSlave slave; private SiemensS7Net siemensS7Net; private Map station = new ConcurrentHashMap<>(); private short heartBeatVal = 1; public DevpThread(DevpSlave slave) { this.slave = slave; } @Override @SuppressWarnings("InfiniteLoopStatement") public void run() { connect(); while (true) { try { int step = 1; Task task = MessageQueue.poll(SlaveType.Devp, slave.getId()); if (task != null) { step = task.getStep(); } switch (step) { // 读数据 case 1: read(); break; // 写数据 case 2: write((StaProtocol)task.getData()); break; default: break; } // 心跳 heartbeat(); Thread.sleep(400); } catch (Exception e) { e.printStackTrace(); } } } @Override public boolean connect() { boolean result = false; siemensS7Net = new SiemensS7Net(SiemensPLCS.S1200, slave.getIp()); siemensS7Net.setRack(slave.getRack().byteValue()); siemensS7Net.setSlot(slave.getSlot().byteValue()); OperateResult connect = siemensS7Net.ConnectServer(); if(connect.IsSuccess){ result = true; OutputQueue.DEVP.offer(MessageFormat.format( "【{0}】输送线plc连接成功 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot())); log.info("输送线plc连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); } else { OutputQueue.DEVP.offer(MessageFormat.format( "【{0}】输送线plc连接失败！！！ ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot())); log.error("输送线plc连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); } siemensS7Net.ConnectClose(); return result; } /** * 读取状态 ====> 整块plc */ private void read(){ OperateResultExOne result = siemensS7Net.Read("DB100.0", (short) 40); if (result.IsSuccess) { for (int i = 1; i <= 8; i++) { StaProtocol staProtocol = station.get(i); if (null == staProtocol) { staProtocol = new StaProtocol(); staProtocol.setSiteId(i); station.put(i, staProtocol); } staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, (i-1)*2)); // 工作号 staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, (i-1)*2+20)); // 目标站 } } OperateResultExOne result1 = siemensS7Net.Read("DB100.40", (short) 8); if (result1.IsSuccess) { for (int i = 1; i <= 8; i++) { boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i-1, 1); StaProtocol staProtocol = station.get(i); staProtocol.setAutoing(status[0]); // 自动 staProtocol.setLoading(status[1]); // 有物 staProtocol.setInEnable(status[2]); // 可入 staProtocol.setOutEnable(status[3]);// 可出 staProtocol.setEmptyMk(status[4]); // 空板信号 } } if (result.IsSuccess && result1.IsSuccess) { OutputQueue.DEVP.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId())); } else { OutputQueue.DEVP.offer(MessageFormat.format("【{0}】读取输送线plc状态信息失败 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot())); log.error("读取堆垛机plc状态信息失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()); } } /** * 写入 =====> 单站点写入 */ private void write(StaProtocol staProtocol){ if (null == staProtocol) { return; } OperateResult write = siemensS7Net.Write("DB100." + (staProtocol.getSiteId() - 1) * 2, staProtocol.getWorkNo()); // 工作号 OperateResult write1 = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) * 2 + 20), staProtocol.getStaNo()); // 目标站 boolean[] status = new boolean[8]; status[0] = staProtocol.isAutoing(); status[1] = staProtocol.isLoading(); status[2] = staProtocol.isInEnable(); status[3] = staProtocol.isOutEnable(); status[4] = staProtocol.isEmptyMk(); OperateResult write2 = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) + 40), status); // 状态 if (!write.IsSuccess || !write1.IsSuccess || !write2.IsSuccess) { OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线站点数据失败。输送线plc编号={1}，站点数据={2}", slave.getId(), JSON.toJSON(staProtocol))); log.error("写入输送线站点数据失败。输送线plc编号={}，站点数据={}", slave.getId(), JSON.toJSON(staProtocol)); } else { OutputQueue.DEVP.offer(MessageFormat.format("【{0}】[id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(staProtocol))); } } /** * 心跳 */ private void heartbeat(){ if (heartBeatVal == 1) { heartBeatVal = 2; } else { heartBeatVal = 1; } OperateResult write = siemensS7Net.Write("DB100.50", heartBeatVal); if (!write.IsSuccess) { log.error("输送线plc编号={} 心跳失败", slave.getId()); } } @Override public void close() { siemensS7Net.ConnectClose(); } public static void main(String[] args) { DevpSlave slave = new DevpSlave(); slave.setIp("192.168.2.125"); DevpThread devpThread = new DevpThread(slave); devpThread.connect(); devpThread.read(); // 写 StaProtocol staProtocol = devpThread.getStation().get(1); staProtocol.setWorkNo((short) 232); staProtocol.setStaNo((short) 6); staProtocol.setAutoing(true); staProtocol.setEmptyMk(true); staProtocol.setInEnable(true); devpThread.write(staProtocol); System.out.println("----------------------------------------"); // 读 devpThread.read(); System.out.println(JSON.toJSONString(devpThread.station)); } }