src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -150,7 +150,7 @@
                    errMsg = "右超限";
                    back = true;
                }
                if (!back && staProtocol.isWeightErr()) {
                if (!back && staProtocol.getWeight() > 1000) {
                    errMsg = "超重";
                    back = true;
                }

 src/main/java/com/zy/common/model/SearchLocParam.java

@@ -18,7 +18,7 @@
    // 库位规格（ 0:未知, 1:低库位, 2:中库位, 3:高库位 ）
    private Short locType1;

    private Double weight;
    private Integer weight;

    public static void main(String[] args) {
        SearchLocParam searchLocParam = new SearchLocParam();

 src/main/java/com/zy/core/model/protocol/StaProtocol.java

@@ -50,7 +50,7 @@
    private boolean pakMk = true;

    //托盘重量
    private Double weight = 0.0;
    private Integer weight = 0;

    // 入库暂存数
    private Short inQty;
@@ -121,7 +121,7 @@
        basDevp.setLocType2((short) 0);  // 宽窄类型{0:未知,1:窄库位,2:宽库位}
        basDevp.setLocType3((short) 0);  // 轻重类型{0:未知,1:轻库位,2:重库位}
        basDevp.setLocType1(high != low && low ? (short) 1 : (short) 2);
        basDevp.setInQty(inQty !=null ?(int)inQty : 0);
        basDevp.setInQty(weight !=null ?(int)weight : 0);
        return basDevp;
    }


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

@@ -86,6 +86,16 @@
        add(222);add(224);add(227);add(230);
    }};

    public static final ArrayList<Integer> staNoWeight1 = new ArrayList<Integer>() {{
        add(123);
        add(223);add(225);add(228);add(231);
    }};

    public static final ArrayList<Integer> staNoWeight2 = new ArrayList<Integer>() {{
        add(102);add(105);add(107);add(109);
        add(203);add(205);add(208);add(211);
    }};

    private Integer count=0;

    /**
@@ -116,6 +126,17 @@
                return staNosErrList1;
            case 2:
                return staNosErrList2;
            default:
                throw new CoolException("服务器异常");
        }
    }

    private ArrayList<Integer> getStaNoWeight() {
        switch (slave.getId()) {
            case 1:
                return staNoWeight1;
            case 2:
                return staNoWeight2;
            default:
                throw new CoolException("服务器异常");
        }
@@ -246,12 +267,16 @@
    private void read() throws InterruptedException {
//        // 更新入出库模式
//        updateIoMode();

//        if (slave.getId()==1) return;
        ArrayList<Integer> staNos = getStaNo();
        ArrayList<Integer> staNosErrList = getStaNoErr();
        ArrayList<Integer> staNoWeight = getStaNoWeight();
        int staNoSize = staNos.size();
        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB101.0", (short) (500 * 8));

        if (result.IsSuccess) {
        OperateResultExOne<byte[]> resultWeight = siemensS7Net.Read("DB102.0", (short)  (8 * 4));
        if (result.IsSuccess && resultWeight.IsSuccess) {
            int j = 0;
            for(int i = 0 ; i<staNoSize;i++){
                Integer siteId = staNos.get(i); // 站点编号
                StaProtocol staProtocol = station.get(siteId);
@@ -264,9 +289,11 @@
                int offset = getOffsetFromSiteId(siteId);//取余获得对应db块数据

                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt32(result.Content, offset));     // 工作号

                if (staNoWeight.contains(siteId)) {
                    staProtocol.setWeight(siemensS7Net.getByteTransform().TransInt32(resultWeight.Content, j));
                    j = j + 4;
                }
                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, offset+ 4));   // 目标站

                status = siemensS7Net.getByteTransform().TransBool(result.Content, offset+ 6, 2);

                staProtocol.setAutoing(status[0]);  // 自动