#读取地图文件优化

Junjie

2024-11-22 d13a01d1769f29b336e5b9f8612c6d41aaabbbb1

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

@@ -56,7 +56,10 @@
            String devNo = slave.getId() == 13 ? "310-1" : slave.getId() == 15 ? "312-2" : slave.getId() == 17 ? "314-1" : slave.getId() == 19 ? "316-1" : null;
            if(!Cools.isEmpty(devNo)){
                barcode = barcode.substring(3,barcode.length());
                agvBasDevpService.updateBarcode(devNo,barcode);
                int updateBarcode = agvBasDevpService.updateBarcode(devNo, barcode);
                if (updateBarcode <= 0) {
                    News.info("{}号条码器，检索数据：{}，更新站点条码失败", slave.getId(), this.barcode);
                }
            }
            News.info("{}号条码器，更新成功", slave.getId());
            JSONObject jsonObject = new JSONObject();
@@ -77,7 +80,7 @@
            close();  //1.主动释放连接 //2.某些服务器对指定ip有链路数限制
            socket = new Socket();
            SocketAddress socketAddress = new InetSocketAddress(slave.getIp(), slave.getPort());
            socket.connect(socketAddress, 1000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
            socket.connect(socketAddress, 10000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
            dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataInputStream = new DataInputStream(socket.getInputStream());
//            log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
@@ -113,15 +116,17 @@
        connect();
        while (true) {
            try {
                byte[] read = read(14, 15000);
                byte[] read = read(14, 3 * 60 * 1000);
                if (null != read) {
                    String s = new String(read);
                    log.warn("ip:{},id:{},读取到条码：{}",slave.getIp(),slave.getId(),s);
                    if (!Cools.isEmpty(s)) {
                        setBarcode(new String(read));
                    }
                }
                Thread.sleep(50);
            }catch (Exception e) {
                log.warn("ip:{},id:{},读取条码异常：{}",slave.getIp(),slave.getId(),e);
                setBarcode("");
                log.error("run" + e);
//                e.printStackTrace();