#

luxiaotao1123

2022-01-14 c41d362fa2e9bedcdd0a68c2e9ef12ed616512bc

#

 src/main/java/com/zy/core/thread/SiemensDevpThread.java

@@ -39,11 +39,15 @@
    private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
    private short heartBeatVal = 1;
    public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{
        add(100);add(101);add(102);add(103);add(104);add(105);add(106);add(107);add(108);add(109);add(110);add(111);add(112);add(113);add(114);
        add(115);add(116);add(117);add(118);add(119);add(120);add(121);add(122);add(123);add(124);add(125);add(126);add(127);add(128);
        add(200);add(201);add(202);add(203);add(204);add(205);
        add(300);add(301);add(302);add(303);add(304);add(305);add(306);add(307);add(308);
        add(129);
        add(100);add(101);add(102);add(103);add(104);add(105);add(106);add(107);add(108);add(109);
        add(110);add(111);add(112);add(113);add(114);add(115);add(116);add(117);add(118);add(119);
        add(120);add(121);add(122);add(123);add(124);add(125);add(126);add(127);add(128);add(129);
        add(130);add(131);add(132);add(133);add(134);add(135);add(136);add(137);add(138);add(139);
        add(140);add(141);add(142);add(143);add(144);add(145);add(146);add(147);add(148);add(149);
        add(150);add(151);add(152);add(153);add(154);add(155);add(156);add(157);add(158);add(159);
        add(160);add(161);add(162);add(163);add(164);add(165);add(166);add(167);add(168);add(169);
        add(170);add(171);add(172);add(173);add(174);add(175);add(176);add(177);add(178);add(179);
        add(180);add(181);add(182);
    }};

    public SiemensDevpThread(DevpSlave slave) {
@@ -106,9 +110,9 @@
     * 读取状态 ====> 整块plc
     */
    private void read() throws InterruptedException {
        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 140);
        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 166);
        if (result.IsSuccess) {
            for (int i = 0; i < 35; i++) {
            for (int i = 0; i < 83; i++) {
                Integer siteId = staNos.get(i); // 站点编号
                StaProtocol staProtocol = station.get(siteId);
                if (null == staProtocol) {
@@ -117,43 +121,26 @@
                    station.put(siteId, staProtocol);
                }
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2));     // 工作号
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2 + 70));   // 目标站
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result0 = siemensS7Net.Read("DB100.180", (short) 36);
        OperateResultExOne<byte[]> result0 = siemensS7Net.Read("DB101.0", (short) 166);
        if (result0.IsSuccess) {
            for (int i = 0; i < 9; i++) {
                Integer siteId = staNos.get(i + 35); // 站点编号
            for (int i = 0; i < 83; 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(siemensS7Net.getByteTransform().TransInt16(result0.Content, i*2));     // 工作号
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result0.Content, i*2 + 18));   // 目标站
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2));   // 目标站
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result3 = siemensS7Net.Read("DB100.226", (short) 4);
        if (result3.IsSuccess) {
            for (int i = 0; i < 1; i++) {
                Integer siteId = staNos.get(i + 44); // 站点编号
                StaProtocol staProtocol = station.get(siteId);
                if (null == staProtocol) {
                    staProtocol = new StaProtocol();
                    staProtocol.setSiteId(siteId);
                    station.put(siteId, staProtocol);
                }
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result3.Content, i*2));     // 工作号
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result3.Content, i*2 + 2));   // 目标站
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.140", (short) 35);
        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB102.0", (short) 83);
        if (result1.IsSuccess) {
            for (int i = 0; i < 35; i++) {
            for (int i = 0; i < 83; i++) {
                Integer siteId = staNos.get(i); // 站点编号
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i, 1);
                StaProtocol staProtocol = station.get(siteId);
@@ -171,50 +158,8 @@
                }
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB100.216", (short) 9);
        if (result2.IsSuccess) {
            for (int i = 0; i < 9; i++) {
                Integer siteId = staNos.get(i + 35); // 站点编号
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result2.Content, i, 1);
                StaProtocol staProtocol = station.get(siteId);
                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);
                }
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result4 = siemensS7Net.Read("DB100.230", (short) 1);
        if (result4.IsSuccess) {
            for (int i = 0; i < 1; i++) {
                Integer siteId = staNos.get(i + 44); // 站点编号
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result4.Content, i, 1);
                StaProtocol staProtocol = station.get(siteId);
                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);
                }
            }
        }

        if (result.IsSuccess && result0.IsSuccess && result1.IsSuccess && result2.IsSuccess && result3.IsSuccess && result4.IsSuccess) {
        if (result.IsSuccess && result0.IsSuccess && result1.IsSuccess) {

            OutputQueue.DEVP.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId()));

@@ -248,24 +193,9 @@
            return;
        }
        int index = staNos.indexOf(staProtocol.getSiteId());
        OperateResult write;
        OperateResult write1;
        // 一期
        if (staProtocol.getSiteId() < 300 && staProtocol.getSiteId() != 129) {
            write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo());    // 工作号
        OperateResult write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo());    // 工作号
            Thread.sleep(100);
            write1 = siemensS7Net.Write("DB100." + (index*2 + 70), staProtocol.getStaNo());    // 目标站
        // 二期
        } else if (staProtocol.getSiteId() >= 300 && staProtocol.getSiteId() != 129){
            write = siemensS7Net.Write("DB100." + ((index-35)*2 + 180), staProtocol.getWorkNo());    // 工作号
            Thread.sleep(100);
            write1 = siemensS7Net.Write("DB100." + ((index-35)*2 + 198), staProtocol.getStaNo());    // 目标站
        // 三期  129
        } else {
            write = siemensS7Net.Write("DB100." + ((index-44)*2 + 226), staProtocol.getWorkNo());    // 工作号
            Thread.sleep(100);
            write1 = siemensS7Net.Write("DB100." + ((index-44)*2 + 228), staProtocol.getStaNo());    // 目标站
        }
        OperateResult write1 = siemensS7Net.Write("DB101." + index*2, staProtocol.getStaNo());    // 目标站

        if (!write.IsSuccess || !write1.IsSuccess) {
            staProtocol = station.get(staProtocol.getSiteId());