#

1

2 天以前 09358392b9c559ebbc9503f1cecea3b7ab3e6c2c

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

@@ -10,6 +10,8 @@
import com.core.common.SpringUtils;
import com.core.exception.CoolException;
import com.zy.asrs.entity.*;
import com.zy.asrs.mapper.BasRgvMapMapper;
import com.zy.asrs.mapper.BasRgvMapper;
import com.zy.asrs.service.*;
import com.zy.common.utils.News;
import com.zy.core.DevpThread;
@@ -24,7 +26,9 @@
import com.zy.core.model.protocol.StaProtocol;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;

import java.io.Console;
import java.nio.charset.StandardCharsets;
import java.text.MessageFormat;
import java.util.*;
@@ -37,7 +41,8 @@
@Data
@Slf4j
public class SiemensDevpThread implements Runnable, DevpThread {

    private BasRgvMapMapper basRgvMapMapper;
    private BasRgvMapper basRgvMapper;
    private DevpSlave slave;
    private SiemensS7Net siemensS7Net;
    private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
@@ -47,6 +52,7 @@
//
//    }};
    public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{
        add(1);add(2);//小车站点
        add(1001);add(1002);add(1004);
        add(1005);add(1007);
        add(1008);add(1010);
@@ -67,6 +73,7 @@
    }};

    public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
        add(3);add(4);
        add(2001);add(2003);
        add(2004);add(2006);
        add(2007);add(2009);
@@ -81,8 +88,8 @@
        add(2034);add(2035);add(2037);
//        add(2041);add(2042);add(2043);add(2044);
//        add(2045);add(2046);add(2047);add(2048);
//        add(2101);add(2102);add(2103);add(2104);add(2105);add(2106);add(2107);add(2108);add(2109);add(2110);
//        add(2111);add(2112);add(2113);add(2114);add(2115);add(2116);add(2117);add(2118);add(2119);add(2120);
        add(2101);add(2102);add(2103);add(2104);add(2105);add(2106);add(2107);add(2108);add(2109);add(2110);
        add(2111);add(2112);add(2113);add(2114);add(2115);add(2116);add(2117);add(2118);add(2119);add(2120);
        add(4001);add(4003);add(4004);add(4006);
    }};

@@ -114,6 +121,12 @@
        put(2026, 2516);put(2027, 2608);put(2028, 2792);put(2029, 2700);put(2030, 2908);
        put(2031, 464);put(2032, 348);put(2033, 556);put(2034, 92);put(2035, 0);
        put(2037, 256);

        put(2101, 0);put(2102, 92);put(2103, 184);put(2104, 276);put(2105, 368);
        put(2106, 460);put(2107, 552);put(2108, 644);put(2109, 736);put(2110, 828);
        put(2111, 920);put(2112, 1012);put(2113, 1104);put(2114, 1196);put(2115, 1288);
        put(2116, 1380);put(2117, 1472);put(2118, 1564);put(2119, 1656);put(2120, 1748);
        put(2121, 1840);put(2122, 1932);

        put(4001, 0);put(4002, 116);put(4003, 508);put(4004, 392);put(4005, 300);
        put(4006, 208);
@@ -161,6 +174,10 @@
        put(1036, 512);put(1103, 476);put(1047, 452);put(2037, 270);put(4001,294);

    }};
    public static final Map<Integer, Integer> siteAgvOffsetMap = new HashMap<Integer, Integer>() {{
        put(1037, 0);put(1039, 2);put(1041, 4);put(2033, 0);put(2034,2);put(4003,4);put(4006,6);

    }};

    // 特殊站点集合
    private static final Set<Integer> specialSites = new HashSet<>(
@@ -173,6 +190,8 @@
    private static final Set<Integer> specialSites3 = new HashSet<>(//机械臂站点
            Arrays.asList(1098,1093,1087,1082,1074,1071,1061,1058));

    private static final Set<Integer> specialAgvSites = new HashSet<>(//agv取放货站点
            Arrays.asList(1037,1039,1041,2033,2034,4003,4006));

    public static final ArrayList<Integer> BarcodeList = new ArrayList<Integer>() {{
        add(0); add(1); add(2);
@@ -277,6 +296,7 @@
                read();

            } catch (Exception e) {
                e.printStackTrace();
                log.error("Dev数据读取线程异常！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
                initSite();
            }
@@ -322,6 +342,9 @@
                        write((StaProtocol)task.getData());
                        log.error("输送线下发命令："+((StaProtocol) task.getData()).getWorkNo()+","+((StaProtocol) task.getData()).getStaNo());
                        break;
//                    case 3:
//                        writeAgv((StaProtocol)task.getData());
//                        break;
                    default:
                        break;
                }
@@ -441,20 +464,34 @@
        OperateResultExOne<byte[]> result3 = null;//1042-1053
        OperateResultExOne<byte[]> result4 = null;//1054-1079
        OperateResultExOne<byte[]> result5 = null;//1080-1110
        OperateResultExOne<byte[]> result6 = null;//2101-2122

        OperateResultExOne<byte[]> resultErr = null;
        if(staNoSize == 100){
        OperateResultExOne<byte[]> resultPlc = null;
        OperateResultExOne<byte[]> resultAgv = null;

        OperateResultExOne<byte[]> resultArm5 = null;//2110
        OperateResultExOne<byte[]> resultArm6 = null;//2120

        if(staNoSize == 102){
            result1 = siemensS7Net.Read("DB100.0", (short) (2768));//1001-1028
            result2 = siemensS7Net.Read("DB101.0", (short) (1268));//1029-1037
            result3 = siemensS7Net.Read("DB104.0", (short) (1268));//1042-1053
            result4 = siemensS7Net.Read("DB103.0", (short) (2824));//1054-1079
            result5 = siemensS7Net.Read("DB102.0", (short) (3428));//1080-1110
            resultErr = siemensS7Net.Read("DB3.0", (short) (536));
//            resultAgv = siemensS7Net.Read("DB901.0", (short) (5)); //agv取放货请求
//            resultPlc = siemensS7Net.Read("DB902.0", (short) (5)); //输送线确认
        }else{
            result1 = siemensS7Net.Read("DB200.0", (short) (3000));//2001-2030
            result2 = siemensS7Net.Read("DB201.0", (short) (720));//2031-2037
            result3 = siemensS7Net.Read("DB400.0", (short) (600));//4001-4006
            result6 = siemensS7Net.Read("DB202.0", (short) (7400));//2101-2122
            resultErr = siemensS7Net.Read("DB3.0", (short) (354));

//            resultAgv = siemensS7Net.Read("DB901.0", (short) (7)); //agv取放货请求
//            resultPlc = siemensS7Net.Read("DB902.0", (short) (7)); //输送线确认
            resultArm5 = siemensS7Net.Read("DB202.4328", (short) (254));//2110
            resultArm6 = siemensS7Net.Read("DB202.6888", (short) (254));//2120
        }


@@ -470,7 +507,7 @@
                    station.put(siteId, staProtocol);
                }
                staProtocol.setSiteId(siteId);
                if (staNoSize == 100) {
                if (staNoSize == 102) {
                    if (siteId < 1029) {
                        result = result1;
                    } else if (siteId < 1042) {
@@ -485,158 +522,247 @@
                }else{
                    if (siteId < 2031) {
                        result = result1;
                    } else if (siteId < 4001) {
                    } else if (siteId < 2040) {
                        result = result2;
                    } else {
                    } else if(siteId<4000){
                        if (siteId == 2110) {
                            if (resultArm5.IsSuccess) {
                                // 转换为字符串
                                String resultString = siemensS7Net.getByteTransform().TransString(resultArm5.Content, 2, 252,"UTF-8");
                                // 去除可能的空字符
//                                resultString = resultString.TrimEnd('\0');
//                                System.out.println("2110Barcode:"+resultString);
                                staProtocol.setBarcode(resultString);
                            } else {
                                staProtocol.setBarcode("");
                            }
                        } else if (siteId == 2120){
                            if (resultArm6.IsSuccess) {
                                // 转换为字符串
                                String resultString = siemensS7Net.getByteTransform().TransString(resultArm6.Content, 2, 252,"UTF-8");
                                // 去除可能的空字符
//                                resultString = resultString.TrimEnd('\0');
//                                System.out.println("2120Barcode:"+resultString);
                                staProtocol.setBarcode(resultString);
                            } else {
                                staProtocol.setBarcode("");
                            }
                        }
                        result = result6;
                    }
                    else {
                        result = result3;
                    }
                }
                // 获取该站点对应的偏移量
                Integer offset = siteOffsetMap.get(siteId);
                if (offset == null) {
                    continue; // 如果没定义偏移量，跳过
                }
                Integer offset2 = getOffsetBySiteId(siteId);//特殊偏移量计算
                Integer offset3 = getOffsetBySiteId2(siteId);
                Integer offsetSign = siteOffsetMapSign.get(siteId);
                if(siteId == 1040){
                    boolean[] full = siemensS7Net.getByteTransform().TransBool(result.Content, offset, 2);
                    staProtocol.setFull(full[0]);
                }
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2));     // 工作号
                staProtocol.setStaNo((short)siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 12));   // 目标站
                staProtocol.setBarcode(String.valueOf(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 16)));  //条码

                if(specialSites2.contains(siteId)){
                    staProtocol.setStaNo((short)siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 48));   // 目标站
                    staProtocol.setBarcode(String.valueOf(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 52)));  //条码
                }
                if(staNosErrList.contains(siteId)){
                    Integer offsetErr = siteErrOffsetMap.get(siteId);
                    boolean[] statusErr = siemensS7Net.getByteTransform().TransBool(resultErr.Content, offsetErr, 2);
                    staProtocol.setFrontErr(statusErr[2]);
                    staProtocol.setBackErr(statusErr[3]);
                    staProtocol.setHighErr(statusErr[5]);
                    staProtocol.setLeftErr(statusErr[11]);
                    staProtocol.setRightErr(statusErr[12]);
//                if(siteId < 5){
//                    int rgvNo = 2;
//                    if(siteId<3){
//                        rgvNo = 1;
//                    }
////                    BasRgv basRgv = basRgvMapper.selectByRgvNo(rgvNo);
//                    BasRgvMap basRgvMap = basRgvMapMapper.selectByRgvNo(rgvNo);
//                    if(siteId%2 != 0){
////                        staProtocol.setWorkNo(basRgv.getWrkNo1());
//                    }else{
////                        staProtocol.setWorkNo(basRgv.getWrkNo2());
//                    }
//
//                }else{
                    // 获取该站点对应的偏移量
                    Integer offset = siteOffsetMap.get(siteId);
                    if (offset == null) {
                        continue; // 如果没定义偏移量，跳过
                    }
                    Integer offset2 = getOffsetBySiteId(siteId);//特殊偏移量计算
                    Integer offset3 = getOffsetBySiteId2(siteId);
                    Integer offsetSign = siteOffsetMapSign.get(siteId);
                    if(siteId == 1040){
                        boolean[] full = siemensS7Net.getByteTransform().TransBool(result.Content, offset, 2);
                        staProtocol.setFull(full[0]);
                    }
                    staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2));     // 工作号
                    staProtocol.setStaNo((short)siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 12));   // 目标站
                    if (staProtocol.getSiteId()!=2110 && staProtocol.getSiteId()!=2120 ){
                        staProtocol.setBarcode(String.valueOf(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 16)));  //条码
                    }
                    if(specialSites2.contains(siteId)){
                        staProtocol.setStaNo((short)siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 48));   // 目标站
                        if (staProtocol.getSiteId()!=2110 && staProtocol.getSiteId()!=2120 ){
                            staProtocol.setBarcode(String.valueOf(siemensS7Net.getByteTransform().TransInt32(result.Content, offset + offset2 + 52)));  //条码
                        }
                    }
                    if(staNosErrList.contains(siteId)){
                        Integer offsetErr = siteErrOffsetMap.get(siteId);
                        boolean[] statusErr = siemensS7Net.getByteTransform().TransBool(resultErr.Content, offsetErr, 2);
                        staProtocol.setFrontErr(statusErr[2]);
                        staProtocol.setBackErr(statusErr[3]);
                        staProtocol.setHighErr(statusErr[5]);
                        staProtocol.setLeftErr(statusErr[11]);
                        staProtocol.setRightErr(statusErr[12]);
// 取出454~458位置的5个字节
                    byte[] bytes = Arrays.copyOfRange(resultErr.Content, (offsetErr + 14), (offsetErr + 19));
                        byte[] bytes = Arrays.copyOfRange(resultErr.Content, (offsetErr + 14), (offsetErr + 19));
// 转换成字符串（S7里CHAR是单字节编码，直接ASCII即可）
                    String plcStr = new String(bytes, StandardCharsets.US_ASCII).trim();
                        String plcStr = new String(bytes, StandardCharsets.US_ASCII).trim();
// 判断是否等于 "error"
                    staProtocol.setBarcodeErr("error".equalsIgnoreCase(plcStr));
                }
                        staProtocol.setBarcodeErr("error".equalsIgnoreCase(plcStr));
                    }

                boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3, 1);
                staProtocol.setAutoing(!status[0]);  // 自动
                boolean[] status1 = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3 - 4, 3);
                boolean[] statusErr = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3 - 8, 3);
                boolean[] statusSign = siemensS7Net.getByteTransform().TransBool(resultErr.Content, offsetSign, 3);
                boolean loading = false;
                if(!status1[0])
                {
                    loading = true;
                }
                staProtocol.setLoading(loading);  // 有物
                    boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3, 1);
                    staProtocol.setAutoing(!status[0]);  // 自动
                    boolean[] status1 = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3 - 4, 3);
                    boolean[] statusErr = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3 - 8, 3);
//                    boolean[] statusSign = siemensS7Net.getByteTransform().TransBool(resultErr.Content, offsetSign, 3);

                staProtocol.setInEnable(status1[2]); // 可入
                staProtocol.setOutEnable(status1[2]);// 可出
                staProtocol.setErr(status1[6]);
                    boolean loading = false;
                    if(!status1[0])
                    {
                        loading = true;
                    }
                    staProtocol.setLoading(loading);  // 有物

                //报警
                staProtocol.setPassTimeOut(statusErr[0]);
                staProtocol.setObjectNoIdError(statusErr[1]);
                staProtocol.setIdNoObjectError(statusErr[2]);
                staProtocol.setLmfrError(statusErr[3]);
                staProtocol.setLiftError(statusErr[4]);
                staProtocol.setDlfrError(statusErr[5]);
                staProtocol.setDmfrError(statusErr[6]);
                staProtocol.setVfdError(statusErr[7]);
                staProtocol.setSrvError(statusErr[8]);
                staProtocol.setRes1(statusErr[9]);
                staProtocol.setRes2(statusErr[10]);
                staProtocol.setRes3(statusErr[11]);
                staProtocol.setCommunicationTimeOut(statusErr[12]);
                staProtocol.setParameterIncompleteError(statusErr[13]);
                staProtocol.setDataNotClear(statusErr[14]);
                staProtocol.setSetParameterError(statusErr[15]);
                staProtocol.setRes4(statusErr[16]);
                staProtocol.setRes5(statusErr[17]);
                staProtocol.setDataError(statusErr[18]);
                    staProtocol.setInEnable(status1[2]); // 可入
                    staProtocol.setOutEnable(status1[2]);// 可出
                    staProtocol.setErr(status1[6]);

                //信号
                staProtocol.setSensorGArrive(statusSign[0]);
                staProtocol.setSensorGDec(statusSign[1]);
                staProtocol.setSensorGArrive2(statusSign[2]);
                staProtocol.setSensorLimit(statusSign[3]);
                staProtocol.setEmergency(statusSign[4]);
                staProtocol.setSensorGLeave(statusSign[5]);
                staProtocol.setSensorGLeave2(statusSign[6]);
                staProtocol.setSensorCUp(statusSign[7]);
                staProtocol.setSensorCDown(statusSign[8]);
                staProtocol.setLiftMotorFr(statusSign[9]);
                staProtocol.setLineMotorFr(statusSign[10]);
                staProtocol.setTranMotorFr(statusSign[11]);
                staProtocol.setRst1(statusSign[12]);
                staProtocol.setRst2(statusSign[13]);
                staProtocol.setRst3(statusSign[14]);
                staProtocol.setRst4(statusSign[15]);
                staProtocol.setSensorArriveD(statusSign[16]);
                staProtocol.setSensorDecD(statusSign[17]);
                staProtocol.setSensorArriveL(statusSign[18]);
                staProtocol.setSensorDecL(statusSign[19]);
                staProtocol.setSensorArriveR(statusSign[20]);
                staProtocol.setSensorDecR(statusSign[21]);
//                    boolean[] statusAlarm = siemensS7Net.getByteTransform().TransBool(resultAlarm.Content, 2*i, 1);
//                    //报警
//                    staProtocol.setPassTimeOut(statusAlarm[0]);
//                    staProtocol.setObjectNoIdError(statusAlarm[1]);
//                    staProtocol.setIdNoObjectError(statusAlarm[2]);
//                    staProtocol.setLmfrError(statusAlarm[3]);
//                    staProtocol.setLiftError(statusAlarm[4]);
//                    staProtocol.setDlfrError(statusAlarm[5]);
//                    staProtocol.setDmfrError(statusAlarm[6]);
//                    staProtocol.setVfdError(statusAlarm[7]);
//                    staProtocol.setSrvError(statusAlarm[8]);
//                    staProtocol.setRes1(statusAlarm[9]);
//                    staProtocol.setRes2(statusAlarm[10]);
//                    staProtocol.setRes3(statusAlarm[11]);
//                    staProtocol.setCommunicationTimeOut(statusAlarm[12]);
//                    staProtocol.setParameterIncompleteError(statusAlarm[13]);
//                    staProtocol.setDataNotClear(statusAlarm[14]);
//                    staProtocol.setSetParameterError(statusAlarm[15]);

                    //报警
                    staProtocol.setPassTimeOut(statusErr[0]);
                    staProtocol.setObjectNoIdError(statusErr[1]);
                    staProtocol.setIdNoObjectError(statusErr[2]);
                    staProtocol.setLmfrError(statusErr[3]);
                    staProtocol.setLiftError(statusErr[4]);
                    staProtocol.setDlfrError(statusErr[5]);
                    staProtocol.setDmfrError(statusErr[6]);
                    staProtocol.setVfdError(statusErr[7]);
                    staProtocol.setSrvError(statusErr[8]);
                    staProtocol.setRes1(statusErr[9]);
                    staProtocol.setRes2(statusErr[10]);
                    staProtocol.setRes3(statusErr[11]);
                    staProtocol.setCommunicationTimeOut(statusErr[12]);
                    staProtocol.setParameterIncompleteError(statusErr[13]);
                    staProtocol.setDataNotClear(statusErr[14]);
                    staProtocol.setSetParameterError(statusErr[15]);
                    staProtocol.setRes4(statusErr[16]);
                    staProtocol.setRes5(statusErr[17]);
                    staProtocol.setDataError(statusErr[18]);

                    //信号
//                    staProtocol.setSensorGArrive(statusSign[0]);
//                    staProtocol.setSensorGDec(statusSign[1]);
//                    staProtocol.setSensorGArrive2(statusSign[2]);
//                    staProtocol.setSensorLimit(statusSign[3]);
//                    staProtocol.setEmergency(statusSign[4]);
//                    staProtocol.setSensorGLeave(statusSign[5]);
//                    staProtocol.setSensorGLeave2(statusSign[6]);
//                    staProtocol.setSensorCUp(statusSign[7]);
//                    staProtocol.setSensorCDown(statusSign[8]);
//                    staProtocol.setLiftMotorFr(statusSign[9]);
//                    staProtocol.setLineMotorFr(statusSign[10]);
//                    staProtocol.setTranMotorFr(statusSign[11]);
//                    staProtocol.setRst1(statusSign[12]);
//                    staProtocol.setRst2(statusSign[13]);
//                    staProtocol.setRst3(statusSign[14]);
//                    staProtocol.setRst4(statusSign[15]);
//                    staProtocol.setSensorArriveD(statusSign[16]);
//                    staProtocol.setSensorDecD(statusSign[17]);
//                    staProtocol.setSensorArriveL(statusSign[18]);
//                    staProtocol.setSensorDecL(statusSign[19]);
//                    staProtocol.setSensorArriveR(statusSign[20]);
//                    staProtocol.setSensorDecR(statusSign[21]);

//                    Integer offsetAgv = siteAgvOffsetMap.get(siteId);
//
//                    boolean[] statusPlc = siemensS7Net.getByteTransform().TransBool(resultPlc.Content, offsetAgv, 1);
//                    boolean[] statusAgv = siemensS7Net.getByteTransform().TransBool(resultAgv.Content, offsetAgv, 1);
//
//                    if(specialAgvSites.contains(siteId)){
//                        // 心跳
//                        staProtocol.setHeartbeatDevp(statusPlc[0]);
//                        staProtocol.setHeartbeatAgv(statusAgv[0]);
//                        // 输送线（PLC）
//                        staProtocol.setConveyorAllowPick(statusPlc[1]);
//                        staProtocol.setConveyorAllowPlace(statusPlc[2]);
//                        staProtocol.setConveyorPickDone(statusPlc[3]);
//                        staProtocol.setConveyorPlaceDone(statusPlc[4]);
//                        staProtocol.setSafetyDoorOpen(statusPlc[5]);
//                        staProtocol.setExternalEmergencyStop(statusPlc[6]);
//                        // AGV
//                        staProtocol.setAgvRequestPlace(statusAgv[1]);
//                        staProtocol.setAgvRequestPick(statusAgv[2]);
//                        staProtocol.setAgvPickDone(statusAgv[3]);
//                        staProtocol.setAgvPlaceDone(statusAgv[4]);
//                        staProtocol.setAgvForbidden(statusAgv[5]);
//                    }


                if( (staProtocol.getPassTimeOut() ||
                    staProtocol.getObjectNoIdError() ||
                        staProtocol.getIdNoObjectError() ||
                        staProtocol.getLmfrError() ||
                        staProtocol.getLiftError() ||
                        staProtocol.getDlfrError() ||
                        staProtocol.getDmfrError() ||
                        staProtocol.getVfdError() ||
                        staProtocol.getSrvError() ||
                        staProtocol.getRes1() ||
                        staProtocol.getRes2() ||
                        staProtocol.getRes3() ||
                        staProtocol.getCommunicationTimeOut() ||
                        staProtocol.getParameterIncompleteError() ||
                        staProtocol.getDataNotClear() ||
                        staProtocol.getSetParameterError() ||
                        staProtocol.getDataError()) && staProtocol.isWriteMk()
                ){
                    staProtocol.setErrorMk(true);//若存在异常触发写入
                }
                    if( (staProtocol.getPassTimeOut() ||
                            staProtocol.getObjectNoIdError() ||
                            staProtocol.getIdNoObjectError() ||
                            staProtocol.getLmfrError() ||
                            staProtocol.getLiftError() ||
                            staProtocol.getDlfrError() ||
                            staProtocol.getDmfrError() ||
                            staProtocol.getVfdError() ||
                            staProtocol.getSrvError() ||
                            staProtocol.getRes1() ||
                            staProtocol.getRes2() ||
                            staProtocol.getRes3() ||
                            staProtocol.getCommunicationTimeOut() ||
                            staProtocol.getParameterIncompleteError() ||
                            staProtocol.getDataNotClear() ||
                            staProtocol.getSetParameterError() ||
                            staProtocol.getDataError()) && staProtocol.isWriteMk()
                    ){
                        staProtocol.setErrorMk(true);//若存在异常触发写入
                    }

                if(     !staProtocol.getPassTimeOut() &&
                        !staProtocol.getObjectNoIdError() &&
                        !staProtocol.getIdNoObjectError() &&
                        !staProtocol.getLmfrError() &&
                        !staProtocol.getLiftError() &&
                        !staProtocol.getDlfrError() &&
                        !staProtocol.getDmfrError() &&
                        !staProtocol.getVfdError() &&
                        !staProtocol.getSrvError() &&
                        !staProtocol.getRes1() &&
                        !staProtocol.getRes2() &&
                        !staProtocol.getRes3() &&
                        !staProtocol.getCommunicationTimeOut() &&
                        !staProtocol.getParameterIncompleteError() &&
                        !staProtocol.getDataNotClear() &&
                        !staProtocol.getSetParameterError() &&
                        !staProtocol.getDataError()
                ){
                    staProtocol.setWriteMk(true);//无异常后才能继续写入
                    staProtocol.setErrorMk(false);//若存在异常触发写入
                    if(     !staProtocol.getPassTimeOut() &&
                            !staProtocol.getObjectNoIdError() &&
                            !staProtocol.getIdNoObjectError() &&
                            !staProtocol.getLmfrError() &&
                            !staProtocol.getLiftError() &&
                            !staProtocol.getDlfrError() &&
                            !staProtocol.getDmfrError() &&
                            !staProtocol.getVfdError() &&
                            !staProtocol.getSrvError() &&
                            !staProtocol.getRes1() &&
                            !staProtocol.getRes2() &&
                            !staProtocol.getRes3() &&
                            !staProtocol.getCommunicationTimeOut() &&
                            !staProtocol.getParameterIncompleteError() &&
                            !staProtocol.getDataNotClear() &&
                            !staProtocol.getSetParameterError() &&
                            !staProtocol.getDataError()
                    ){
                        staProtocol.setWriteMk(true);//无异常后才能继续写入
                        staProtocol.setErrorMk(false);//若存在异常触发写入

                }
                    }


                if (!staProtocol.isPakMk() && (!staProtocol.isLoading() || staProtocol.getWorkNo()==0)) {
                    staProtocol.setPakMk(true);
                }
                    if (!staProtocol.isPakMk() && (!staProtocol.isLoading() || staProtocol.getWorkNo()==0)) {
                        staProtocol.setPakMk(true);
                    }
//                }

            }
        }
        //条码扫描器
@@ -647,7 +773,7 @@
        OperateResultExOne<byte[]> reasultBarcode3 = siemensS7Net.Read("DB102.2780", (short) 4);//1103
        OperateResultExOne<byte[]> reasultBarcode4 = siemensS7Net.Read("DB201.344", (short) 4);//2037
        OperateResultExOne<byte[]> reasultBarcode5 = siemensS7Net.Read("DB400.112", (short) 4);//4001
        OperateResultExOne<byte[]> reasultBarcode6 = siemensS7Net.Read("DB201.716", (short) 4);//4001
        OperateResultExOne<byte[]> reasultBarcode6 = siemensS7Net.Read("DB201.716", (short) 4);//2033

        if(barcodeList.get(0) == 0){
            if(reasultBarcode1.IsSuccess){
@@ -703,6 +829,8 @@
                }
            }
        }




        if (result1.IsSuccess && result2.IsSuccess) {
@@ -851,8 +979,8 @@
                    staProtocol.isHighErr()? 1L:0L,
                    staProtocol.isLeftErr()? 1L:0L,
                    staProtocol.isRightErr()? 1L:0L,
                    staProtocol.isBarcodeErr()? 1L:0L

                    staProtocol.isBarcodeErr()? 1L:0L,
                    staProtocol.getErrCode()
            );
            bean.insert(basDevpOpt);
        } catch (Exception ignore) {