| | |
| | | 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; |
| | | |
| | | /** |
| | |
| | | private short heartBeatVal = 1; |
| | | private StaError1 staError1; |
| | | public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{ |
| | | add(100);add(101);add(102);add(103); |
| | | add(1002);add(1020);add(1035);add(103); |
| | | add(104);add(105);add(106);add(107); |
| | | add(200);add(201);add(202);add(203);add(210); |
| | | add(300);add(301);add(302);add(303);add(304);add(305); |
| | |
| | | // 写数据 ID+目标站 |
| | | case 2: |
| | | write((StaProtocol)task.getData()); |
| | | log.error("输送线下发命令:"+((StaProtocol) task.getData()).getWorkNo()+","+((StaProtocol) task.getData()).getStaNo()); |
| | | // log.error("输送线下发命令:"+((StaProtocol) task.getData()).getWorkNo()+","+((StaProtocol) task.getData()).getStaNo()); |
| | | break; |
| | | // 写开门 |
| | | case 3: |
| | |
| | | booleans[1] = true; // 关门信号 |
| | | booleans[0] = false; |
| | | siemensS7Net.Write("DB100.826",booleans); |
| | | log.info("下发关门信号成功:" + Arrays.toString(booleans)); |
| | | } |
| | | } else if(flag == 1) { |
| | | OperateResultExOne<byte[]> readOpenResult = siemensS7Net.Read("DB100.826", (short) 1); |
| | |
| | | booleans[0] = true; // 开门信号 |
| | | booleans[1] = false; |
| | | siemensS7Net.Write("DB100.826",booleans); |
| | | log.info("下发开门信号成功:" + Arrays.toString(booleans)); |
| | | } |
| | | } |
| | | Thread.sleep(500); |
| | |
| | | staProtocol.setCloseAskDoor(booleans[1]); |
| | | staProtocol.setIfOpenDoor(booleans[2]); |
| | | staProtocol.setIfCloseDoor(booleans[3]); |
| | | log.info("下发开关门后回读:" + Arrays.toString(booleans)); |
| | | } |
| | | } |
| | | |
| | |
| | | OperateResultExOne<byte[]> resultErr = siemensS7Net.Read("DB101.1652", (short) ((staNosErrList.size()+1)*4)); // 不连续,多读中间一个 |
| | | if (resultErr.IsSuccess){ |
| | | for (int i = 0;i<staNosErrList.size();i++){ |
| | | boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i*9+2, 1); |
| | | boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i*8+2, 1); |
| | | StaProtocol staProtocol = station.get(staNosErrList.get(i)); |
| | | staProtocol.setFrontErr(status[0]); |
| | | staProtocol.setBackErr(status[1]); |