#

luxiaotao1123

2021-05-27 b166570c1d12527cdc2a03358e2392f94a15520f

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

@@ -5,7 +5,6 @@
import HslCommunication.Profinet.Siemens.SiemensPLCS;
import HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.alibaba.fastjson.JSON;
import com.core.common.Arith;
import com.core.common.DateUtils;
import com.core.common.SpringUtils;
import com.zy.asrs.entity.BasDevp;
@@ -43,6 +42,7 @@
        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);
    }};

    public SiemensDevpThread(DevpSlave slave) {
@@ -107,7 +107,7 @@
    private void read() throws InterruptedException {
        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 140);
        if (result.IsSuccess) {
            for (int i = 0; i < staNos.size(); i++) {
            for (int i = 0; i < 35; i++) {
                Integer siteId = staNos.get(i); // 站点编号
                StaProtocol staProtocol = station.get(siteId);
                if (null == staProtocol) {
@@ -115,21 +115,30 @@
                    staProtocol.setSiteId(siteId);
                    station.put(siteId, staProtocol);
                }
//                int divides = (int) Arith.divides(0, siteId, 100);
//                int remainder = (int) Arith.remainder(siteId, 100);
//                int index = ((divides - 1) * 50) + remainder;
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2));     // 工作号
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2 + 70));   // 目标站
            }
        }
        Thread.sleep(100);
        Thread.sleep(50);
        OperateResultExOne<byte[]> result0 = siemensS7Net.Read("DB100.180", (short) 36);
        if (result0.IsSuccess) {
            for (int i = 0; i < 9; i++) {
                Integer siteId = staNos.get(i + 35); // 站点编号
                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));   // 目标站
            }
        }
        Thread.sleep(50);
        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.140", (short) 35);
        if (result1.IsSuccess) {
            for (int i = 0; i < staNos.size(); i++) {
            for (int i = 0; i < 35; i++) {
                Integer siteId = staNos.get(i); // 站点编号
//                int divides = (int) Arith.divides(0, siteId, 100);
//                int remainder = (int) Arith.remainder(siteId, 100);
//                int index = ((divides - 1) * 100) + remainder;
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i, 1);
                StaProtocol staProtocol = station.get(siteId);
                staProtocol.setAutoing(status[0]);  // 自动
@@ -146,8 +155,29 @@
                }
            }
        }
        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 (result.IsSuccess && result1.IsSuccess) {
                if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
                    staProtocol.setPakMk(true);
                }
            }
        }

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

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

@@ -180,14 +210,21 @@
        if (null == staProtocol) {
            return;
        }
//        int divides = (int) Arith.divides(0, staProtocol.getSiteId(), 100);
//        int remainder = (int) Arith.remainder(staProtocol.getSiteId(), 100);
//        int index = ((divides - 1) * 50) + remainder;
        int index = staNos.indexOf(staProtocol.getSiteId());
        OperateResult write;
        OperateResult write1;
        // 一期
        if (staProtocol.getSiteId() < 300) {
            write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo());    // 工作号
            Thread.sleep(100);
            write1 = siemensS7Net.Write("DB100." + (index*2 + 70), staProtocol.getStaNo());    // 目标站
        // 二期
        } else {
            write = siemensS7Net.Write("DB100." + (index-35)*2 + 180, staProtocol.getWorkNo());    // 工作号
            Thread.sleep(100);
            write1 = siemensS7Net.Write("DB100." + (index-35)*2 + 198, staProtocol.getStaNo());    // 目标站
        }

        OperateResult write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo());    // 工作号
        Thread.sleep(200);
        OperateResult write1 = siemensS7Net.Write("DB100." + (index*2 + 70), staProtocol.getStaNo());    // 目标站
        if (!write.IsSuccess || !write1.IsSuccess) {
            staProtocol = station.get(staProtocol.getSiteId());
            if (staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0) {
@@ -233,6 +270,7 @@
    }

    public static void main(String[] args) {
        System.out.println(staNos.size());
        for (int i = 0; i<staNos.size(); i++) {
//            System.out.println(i*2);
//            System.out.println(i*2 + 200);