cdsevent.java

自己实现的基于串口通讯发送短消息的低层协议JAVA代码

package com.jzl.sirius.at.event;

import java.nio.ByteBuffer;

import com.jzl.sirius.at.ATConstants;
import com.jzl.sirius.at.util.StringMatch;

/**
 * 收到类型为"+CDS:"短信事件
 * 
 * @author xujian
 * @version 2.0
 * @see com.jzl.sirius.at.event.MutiableEvent
 */
public class CDSEvent extends MutiableEvent {

    private StringMatch startMatch = new StringMatch(ATConstants.CRLF + "+CDS:");
    private StringMatch endMatch   = new StringMatch(ATConstants.CRLF);
    private boolean eventStarted = false;
    
    private StringBuffer sb = new StringBuffer();
    
    private int mode = ATConstants.SMS_FORMAT_TEXT;
    private int crlfCount = 0;
    
    // pdu mode
    private int length = -1;
    private String pdu;
	
    // text mode
	private int fo = -1;
	private int mr = -1;
    private String ra;
    private int tora = -1;
	private String scts;
	private String dt;
	private int st = -1;
	
	

	/**
	 * <pre>
	 * mode=1,Text mode;mode=0,pdu mode.
	 * ? For ds=1 and PDU mode
	 * 		Unsolicited response
	 * 		+CDS: length
	 * 		pdu
	 * 	? For ds=1 and text mode
	 * 		Unsolicited response
	 * 		+CDS: fo,mr,[ra],[tora],scts,dt,st
	 * </pre>
	 * 
	 * @param mode
	 *			mode=1,Text mode;mode=0,pdu mode.
	 */
	public CDSEvent(int mode) {
		this.mode = mode;
	}
    
    public void reset() {
        super.reset();
        eventStarted = false;
        crlfCount = 0;
        pdu = "";
        length   = -1;
        sb = new StringBuffer();
    }
    
    public boolean match(char ch) {
        eventStarted = startMatch.match(ch);
        return eventStarted;
    }

	

    public boolean readResponse(ByteBuffer buffer) {
        while(buffer.hasRemaining()){
            
            char ch = (char)buffer.get();
            if (eventStarted) {
                sb.append(ch);
                if (endMatch.match(ch)) {
                    crlfCount++;
                    
                    if (mode == ATConstants.SMS_FORMAT_TEXT && crlfCount == 1) {
                        // 事件结束，进行结果解析
                        decodeTextResponse();
                        finish();
                    
                        return true;
                    }
                    else if (mode == ATConstants.SMS_FORMAT_PDU && crlfCount == 2) {
                        decodePduResponse();
                        finish();
                    
                        return true;
                    }
                }
            }
            else 
                match(ch);
            
        }
        
        return false;
    }
    
    private void decodeTextResponse(){
        
    }
    
    private void decodePduResponse(){
        int index = sb.indexOf(ATConstants.CRLF);
        if (index == -1) 
            return;
        
        try {
            String str = sb.substring(0, index).trim();
            length = Integer.parseInt(str);
            
            str = sb.substring(index + ATConstants.CRLF.length());
            index = str.indexOf(ATConstants.CRLF);
            
            if (index == -1)
                return;
            
            pdu = str.substring(0, index).trim();
        }
        catch(Exception ex) {
            ex.printStackTrace();
        }
    }


	public int getLength() {
		return length;
	}

	public String getPdu() {
		return pdu;
	}

	public int getFo() {
		return fo;
	}

	public int getMr() {
		return mr;
	}

	public String getScts() {
		return scts;
	}

	public String getDt() {
		return dt;
	}

	public int getSt() {
		return st;
	}

	public int getTora() {
		return tora;
	}

	public String getRa() {
		return ra;
	}
    
    public Object clone() throws CloneNotSupportedException {
        CDSEvent obj = (CDSEvent)super.clone();
        obj.sb.append(sb);
        obj.eventStarted = eventStarted;
        obj.mode = mode;
        obj.pdu = pdu;
        obj.length = length;
        obj.crlfCount = crlfCount;
        
        return obj;
    }

}