RFIDInParkDataBuffer.java 997 Bytes
package com.bsth.data.signal;

import com.bsth.data.signal.dto.RfidInOutDto;
import com.bsth.data.msg_queue.SignalAndAttConsumeQueue;
import com.bsth.entity.ac.CarInOutEntity;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.LinkedList;

/**
 * 场内 RFID 数据缓存
 * Created by panzhao on 2017/9/5.
 */
public class RFIDInParkDataBuffer {

    static Logger logger = LoggerFactory.getLogger(RFIDInParkDataBuffer.class);

    private static LinkedList<RfidInOutDto> list;

    static{
        list = new LinkedList<>();
    }

    public static void put(RfidInOutDto rfidInOut){
        if(null == rfidInOut)
            return;
        if(StringUtils.isEmpty(rfidInOut.getCarCard()))
            return;

        if(null == rfidInOut.getReportTime())
            return;

        list.add(rfidInOut);
        CarInOutEntity cio = CarInOutEntity.getInstance(rfidInOut);
        SignalAndAttConsumeQueue.put(cio);
    }
}