#

Junjie

2023-09-26 58365ea8a02e8adee1b56948085998107f9a80b3

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

@@ -41,7 +41,7 @@
    private SiemensS7Net siemensS7Net;
    private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
    private short heartBeatVal = 1;
    private int barcodeSize = 1;
    private int barcodeSize = 9;
    public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{
        add(100);add(101);
        add(102);add(103);
@@ -52,6 +52,9 @@
        add(300);add(301);
        add(340);add(341);
        add(345);add(346);
        add(303);add(317);
        add(325);add(331);
        add(333);add(339);
    }};

    public static final ArrayList<Integer> outInStaNos = new ArrayList<Integer>() {{
@@ -147,11 +150,11 @@
            }
        }
        Thread.sleep(200);
        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB1001.0", (short) (staNos.size()));
        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB1001.0", (short) (staNos.size()*2));
        if (result1.IsSuccess) {
            for (int i = 0; i < staNos.size(); i++) {
                Integer siteId = staNos.get(i); // 站点编号
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i, 1);
                boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i*2, 1);
                StaProtocol staProtocol = station.get(siteId);
                staProtocol.setAutoing(status[0]);  // 自动
                staProtocol.setLoading(status[1]);  // 有物
@@ -170,32 +173,15 @@

        //读条码
        Thread.sleep(100);
        OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB100.200",(short)24);
        OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB1000.200", (short) 72);
        if (result2.IsSuccess) {
            for (int i = 0; i <= barcodeSize; i++) {
//                byte[] bytes = siemensS7Net.getByteTransform().TransByte(result2.Content, i * 8, 8);
//                String barcode = CommonUtils.bytesToBarcode(bytes);
            for (int i = 0; i < barcodeSize; i++) {
                String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8");
                BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, i + 1);
                if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
                    barcodeThread.setBarcode(barcode);
                }
            }
        }

        // 充电信号位1
        Thread.sleep(50);
        OperateResultExOne<byte[]> result32 = siemensS7Net.Read("DB102.109", (short)1);
        if (result32.IsSuccess) {
            boolean[] status = siemensS7Net.getByteTransform().TransBool(result32.Content, 0, 1);
            charge0 = status[0];  //1:可以充电   0：可能离线 可能在充电
        }
        // 充电信号位2
        Thread.sleep(50);
        OperateResultExOne<byte[]> result31 = siemensS7Net.Read("DB100.201", (short)1);
        if (result31.IsSuccess) {
            boolean[] status = siemensS7Net.getByteTransform().TransBool(result31.Content, 0, 1);
            charge1 = status[0];
        }

        // 外形检测 - 102
@@ -417,10 +403,10 @@
        //任务下发成功标识
        boolean writeFlag = false;
        while(writeCount < 5){
            writeResult = siemensS7Net.Write("DB100." + index*4, array);    // 工作号、目标站
            writeResult = siemensS7Net.Write("DB1000." + index*4, array);    // 工作号、目标站
            if(writeResult.IsSuccess){
                Thread.sleep(200);
                OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB100." + index*4, (short)4);
                OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB1000." + index*4, (short)4);
                if(readResult.IsSuccess){
                    short workNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 0);
                    short staNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 2);