输送线扫码时更细站点信息

zyx

2024-04-11 bf28baa00838879c15a22decf314b6e76eb6e89b

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

@@ -3,12 +3,14 @@
import com.alibaba.fastjson.JSONObject;
import com.core.common.Cools;
import com.core.common.DateUtils;
import com.zy.asrs.service.AgvBasDevpService;
import com.zy.core.News;
import com.zy.core.Slave;
import com.zy.core.ThreadHandler;
import com.zy.core.cache.OutputQueue;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;

import java.io.DataInputStream;
import java.io.DataOutputStream;
@@ -34,6 +36,9 @@
    private DataInputStream dataInputStream;
    public Integer connCount = 0;

    @Autowired
    private AgvBasDevpService agvBasDevpService;

    public BarcodeThread(Slave slave) {
        this.slave = slave;
    }
@@ -47,13 +52,20 @@
        this.barcode.append(barcode);
        if(!Cools.isEmpty(barcode)) {
            News.info("{}号条码器，检索数据：{}", slave.getId(), this.barcode);

            JSONObject jsonObject = new JSONObject();
            jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F));
            jsonObject.put("barcode", barcode);
            jsonObject.put("id", slave.getId());
            if (OutputQueue.BARCODE.size() >= 32) {
                OutputQueue.BARCODE.poll();
            }
            OutputQueue.BARCODE.offer(jsonObject);

            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)){
                agvBasDevpService.updateBarcode(devNo,barcode);
            }
        }
    }

@@ -99,7 +111,7 @@
        connect();
        while (true) {
            try {
                byte[] read = read(14, 5000);
                byte[] read = read(14, 15000);
                if (null != read) {
                    String s = new String(read);
                    if (!Cools.isEmpty(s)) {
@@ -107,12 +119,13 @@
                    }
                }
                Thread.sleep(50);
            } catch (SocketTimeoutException ignore) {
                connCount++;
            } catch (Exception e) {
            }catch (Exception e) {
                setBarcode("");
                e.printStackTrace();
                log.error("run" + e);
//                e.printStackTrace();
                connect();
            }

        }
    }