//package com.zy.core.thread.impl;
|
//
|
//import HslCommunication.Core.Types.OperateResult;
|
//import HslCommunication.Core.Types.OperateResultExOne;
|
//import HslCommunication.Profinet.Siemens.SiemensPLCS;
|
//import HslCommunication.Profinet.Siemens.SiemensS7Net;
|
//import com.core.common.DateUtils;
|
//import com.zy.common.utils.RedisUtil;
|
//import com.zy.core.News;
|
//import com.zy.core.ThreadHandler;
|
//import com.zy.core.cache.OutputQueue;
|
//import com.zy.core.model.ForkLiftSlave;
|
//import com.zy.core.model.protocol.ForkLiftProtocol;
|
//import lombok.extern.slf4j.Slf4j;
|
//
|
//import java.text.MessageFormat;
|
//import java.util.ArrayList;
|
//import java.util.Date;
|
//import java.util.HashMap;
|
//import java.util.List;
|
//
|
//@Slf4j
|
//@SuppressWarnings("all")
|
//public class LfdZyForkLiftMasterThread implements ThreadHandler {
|
//
|
// private ForkLiftSlave slave;
|
// private ForkLiftProtocol forkLiftProtocol;
|
// private RedisUtil redisUtil;
|
// private SiemensS7Net siemensS7Net;
|
// private List<HashMap<String,Object>> slaveAddressList = null;
|
// private boolean connect = false;
|
//
|
// public LfdZyForkLiftMasterThread(ForkLiftSlave slave, RedisUtil redisUtil) {
|
// this.slave = slave;
|
// this.redisUtil = redisUtil;
|
// ArrayList<HashMap<String, Object>> addressList = new ArrayList<>();
|
//
|
// HashMap<String, Object> lift1 = new HashMap<>();
|
// lift1.put("status", new DbData("DB101.0", (short) 18));//提升机数据
|
// lift1.put("staStatusTray", new DbData("DB102.0", (short) 14));//站点数据
|
// lift1.put("staStatusCar", new DbData("DB102.50", (short) 14));//站点数据
|
// lift1.put("write", new DbData("DB103.0", null));//写入数据
|
// lift1.put("writeConfirm", new DbData("DB103.8", null));//写入确认数据
|
// lift1.put("confirm", new DbData("DB103.10", null));//确认命令
|
// lift1.put("switchIOMode", new DbData("DB103.12", null));//出入库模式
|
//
|
// HashMap<String, Object> lift2 = new HashMap<>();
|
// lift2.put("status", new DbData("DB104.0", (short) 18));//提升机数据
|
// lift2.put("staStatusTray", new DbData("DB105.0", (short) 14));//站点数据
|
// lift2.put("staStatusCar", new DbData("DB105.50", (short) 14));//站点数据
|
// lift2.put("write", new DbData("DB106.0", null));//写入数据
|
// lift2.put("writeConfirm", new DbData("DB106.8", null));//写入确认数据
|
// lift2.put("confirm", new DbData("DB106.10", null));//确认命令
|
// lift2.put("switchIOMode", new DbData("DB106.12", null));//出入库模式
|
//
|
// addressList.add(lift1);
|
// addressList.add(lift2);
|
// this.slaveAddressList = addressList;
|
// }
|
//
|
// @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.FORKLIFT.offer(MessageFormat.format( "【{0}】货叉提升机连接成功 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
|
// News.info("货叉提升机连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
// } else {
|
// OutputQueue.FORKLIFT.offer(MessageFormat.format( "【{0}】货叉提升机连接失败！！！ ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
|
// News.error("货叉提升机连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
// }
|
// // siemensS7Net.ConnectClose();
|
// this.connect = result;
|
// return result;
|
// }
|
//
|
// @Override
|
// public void close() {
|
//
|
// }
|
//
|
// @Override
|
// public void run() {
|
// News.info("{}号货叉提升机Master线程启动", slave.getId());
|
// this.connect();
|
// while (true) {
|
// try {
|
// if (!this.connect) {
|
// this.connect();
|
// }
|
//
|
// Thread.sleep(500);
|
// }catch (Exception e){
|
// e.printStackTrace();
|
// }
|
// }
|
// }
|
//
|
// public SiemensS7Net getSiemensS7Net() {
|
// return siemensS7Net;
|
// }
|
//
|
// public synchronized OperateResultExOne<byte[]> read(Integer slaveId, String dbTag) {
|
// try {
|
// HashMap<String, Object> map = this.slaveAddressList.get(slaveId - 1);
|
// DbData dbData = (DbData) map.get(dbTag);
|
// OperateResultExOne<byte[]> result = siemensS7Net.Read(dbData.dbAddress, dbData.dbAddressLength);
|
// return result;
|
// } catch (Exception e) {
|
// OutputQueue.FORKLIFT.offer(MessageFormat.format("【{0}】读取提升机状态信息失败 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
|
// }
|
// return null;
|
// }
|
//
|
// public synchronized OperateResult write(Integer slaveId, String dbTag, short[] array) {
|
// try {
|
// HashMap<String, Object> map = this.slaveAddressList.get(slaveId - 1);
|
// DbData dbData = (DbData) map.get(dbTag);
|
// OperateResult result = siemensS7Net.Write(dbData.dbAddress, array);
|
// return result;
|
// } catch (Exception e) {
|
// OutputQueue.FORKLIFT.offer(MessageFormat.format("【{0}】写入提升机状态信息失败 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
|
// }
|
// return null;
|
// }
|
//
|
// public synchronized OperateResult write(Integer slaveId, String dbTag, short val) {
|
// try {
|
// HashMap<String, Object> map = this.slaveAddressList.get(slaveId - 1);
|
// DbData dbData = (DbData) map.get(dbTag);
|
// OperateResult result = siemensS7Net.Write(dbData.dbAddress, val);
|
// return result;
|
// } catch (Exception e) {
|
// OutputQueue.FORKLIFT.offer(MessageFormat.format("【{0}】写入提升机状态信息失败 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
|
// }
|
// return null;
|
// }
|
//
|
// private class DbData {
|
// private String dbAddress;
|
// private Short dbAddressLength;
|
//
|
// public DbData(String dbAddress, Short dbAddressLength) {
|
// this.dbAddress = dbAddress;
|
// this.dbAddressLength = dbAddressLength;
|
// }
|
//
|
// }
|
//}
|
