delivermessage.java

采用JAVA开发

package com.gctech.sms.sp.cms.msg2;

import com.gctech.sms.sp.cms.util.ProtocolBuffer;

import java.text.SimpleDateFormat;
import java.util.Date;

public class DeliverMessage extends Message {
    public  String messageId = null;
    private int msgFmt = 0;
    private Date recvTime = null;
    public String srcTermId = null;
    public int srcTermType  = 0;
    public String destTermId = null;
    private int msgLength = 0;
    public String content = null;
    public String linkId = null;
    public int isReport = 0;

    static SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");

    public DeliverMessage()
    {
      commandId = Message.DELIVER;
    }

    public static void main(String[] args) {
        DeliverMessage deliverMessage1 = new DeliverMessage();
    }

    public static DeliverMessage createMessage(byte[] bs) {
        ProtocolBuffer pb = ProtocolBuffer.create(bs);
        DeliverMessage m = new DeliverMessage();
        m.commandId = pb.readInt();
        m.commandStatus = pb.readInt();
        m.sequenceId = pb.readInt();
        m.messageId = pb.readString(10);
        m.isReport = pb.readByte();
        m.msgFmt = pb.readByte();
        //note igore beacuse of error
       String date = pb.readString(14);
//        try {
//
//          m.recvTime = sdf.parse(date);
//        } catch (Exception e) {
//            throw new IllegalArgumentException(date + "格式不对");
//        }
        m.srcTermId = pb.readString(32);
        m.srcTermType = pb.readByte();
        m.destTermId = pb.readString(21);
        m.msgLength = pb.readByte();
        m.content = pb.readString(m.msgLength);
        m.linkId = pb.readString(20);
        return m;
    }

    public byte[] toBytes() {
        throw new UnsupportedOperationException("cms不需要提供此方法");
    }
    public String toString()
    {
      return "[src:"+srcTermId+"] [destTermId:"+destTermId+"] content:["+content+"]";
    }



}