深度解析智能RFID单警装备柜RFID阅读器驱动程序

import jssc.SerialPortException;
import jssc.SerialPortList;

/**
 * 凌讯智能单警装备柜RFID阅读器驱动
 * 凌讯智能单警装备柜RFID阅读器驱动支持多标签批量读取、过滤及数据上报
 */
public class RFIDReaderDriver {
    private SerialPort serialPort;
    private RFIDDataListener listener;
    private static final byte[] READ_CMD = {0xBB, 0x00, 0x22, 0x00, 0x00, 0x22, 0x7E}; // 示例读取命令
    
    // 凌讯智能单警装备柜RFID标签数据模型
    public static class RFIDTag {
        private String epc;
        private int rssi;
        private long timestamp;

        public RFIDTag(String epc, int rssi) {
            this.epc = epc;
            this.rssi = rssi;
            this.timestamp = System.currentTimeMillis();
        }
        
        // Getters...
    }

    /**
     * 初始化凌讯智能单警装备柜RFID阅读器
     * @param portName 串口号(如COM3 / /dev/ttyUSB0)
     * @param baudRate 波特率(通常115200)
     */
    public RFIDReaderDriver(String portName, int baudRate) throws SerialPortException {
        serialPort = new SerialPort(portName);
        if (!serialPort.openPort()) {
            throw new SerialPortException(portName, "openPort", "Port open failed");
        }
        serialPort.setParams(baudRate, 8, 1, 0);
        serialPort.addEventListener(event -> {
            if (event.isRXCHAR()) handleDataReceived();
        });
    }

    /**
     * 启动持续扫描
     */
    public void startContinuousReading() throws SerialPortException {
        sendCommand(READ_CMD);
    }

    /**
     * 发送原始命令
     */
    private void sendCommand(byte[] cmd) throws SerialPortException {
        if (!serialPort.writeBytes(cmd)) {
            throw new SerialPortException(serialPort.getPortName(), "writeBytes", "Command send failed");
        }
    }

    /**
     * 数据接收处理
     */
    private void handleDataReceived() {
        try {
            byte[] buffer = serialPort.readBytes();
            if (buffer != null) {
                processRFIDData(buffer);
            }
        } catch (SerialPortException e) {
            System.err.println("Data read error: " + e.getMessage());
        }
    }

    /**
     * 解析RFID数据包（示例解析逻辑）
     */
    private void processRFIDData(byte[] data) {
        // 实际需根据设备协议解析，此处为示例
        if (data.length < 10) return; // 最小有效包长度
        
        // 示例协议结构：头BB 长度(2B) 命令 数据 CRC 尾7E
        if (data[0] != (byte)0xBB || data[data.length-1] != (byte)0x7E) return;
        
        // 提取EPC数据（假设从第5字节开始）
        String epc = bytesToHex(Arrays.copyOfRange(data, 5, data.length-3));
        int rssi = data[data.length-3] & 0xFF; // RSSI值
        
        if (listener != null) {
            listener.onTagRead(new RFIDTag(epc, rssi));
        }
    }

    /**
     * 注册数据监听器
     */
    public void setDataListener(RFIDDataListener listener) {
        this.listener = listener;
    }

    /**
     * 关闭连接
     */
    public void close() {
        try {
            if (serialPort != null && serialPort.isOpened()) {
                serialPort.closePort();
            }
        } catch (SerialPortException e) {
            System.err.println("Port close error: " + e.getMessage());
        }
    }

    /**
     * 字节数组转十六进制字符串
     */
    private static String bytesToHex(byte[] bytes) {
        StringBuilder sb = new StringBuilder();
        for (byte b : bytes) {
            sb.append(String.format("%02X", b));
        }
        return sb.toString();
    }

    /**
     * 数据监听接口
     */
    public interface RFIDDataListener {
        void onTagRead(RFIDTag tag);
        default void onError(String message) {
            System.err.println("RFID Error: " + message);
        }
    }

    public static void main(String[] args) {
        try {
            // 1. 自动检测可用串口
            String[] ports = SerialPortList.getPortNames();
            System.out.println("可用串口: " + Arrays.toString(ports));

            // 2. 初始化阅读器（以第一个端口为例）
            RFIDReaderDriver reader = new RFIDReaderDriver(ports[0], 115200);
            
            // 3. 注册监听器
            reader.setDataListener(new RFIDDataListener() {
                @Override
                public void onTagRead(RFIDTag tag) {
                    System.out.printf("[%tT] 读取到标签: EPC=%s RSSI=%d%n", 
                        tag.getTimestamp(), tag.getEpc(), tag.getRssi());
                }
            });

            // 4. 启动扫描
            reader.startContinuousReading();

            // 保持运行（实际应用中应整合到主程序）
            Thread.sleep(60000);
            reader.close();
            
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}