orderrecordcreator.java

短信开发用于文件交换处理转发的类模块

package com.pub.backserver.order;

import java.nio.charset.CharacterCodingException;

import org.apache.log4j.Logger;
import org.apache.mina.common.ByteBuffer;

import com.pub.berkeleydb.DefaultRecordCreator;

/**
 * @author [e-mail]
 * @create 2007-7-16
 */

public class OrderRecordCreator extends DefaultRecordCreator {

	
	private static Logger log = Logger.getLogger(OrderRecordCreator.class);

	@Override
    public void toKey(ByteBuffer out, Object r) throws CharacterCodingException {
        OrderEntity oe = (OrderEntity) r;
//        out.putString(oe.getMobile(), 21, Message.charset.newEncoder());
        str2bytebuffer(out, oe.getMobile(), 21);
        out.putInt(oe.getProdId());
        out.putInt(oe.getServiceCodeId());
    }

	@Override
    public void fromKey(ByteBuffer in, Object r) throws CharacterCodingException {
		OrderEntity oe = (OrderEntity) r;
//		oe.setMobile(in.getString(21, Message.charset.newDecoder()));
		oe.setMobile(bytebuffer2str(in, 21));
		oe.setProdId(in.getInt());
		oe.setServiceCodeId(in.getInt());
    }

	@Override
    public void toValue(ByteBuffer out, Object r) throws CharacterCodingException {
		OrderEntity oe = (OrderEntity) r;
        out.putShort(oe.getOperationId());
        out.putShort(oe.getProvinceId());
        out.putInt(oe.getGwId());
        out.putInt(oe.getChannelId());
        
    }

	@Override
    public void fromValue(ByteBuffer in, Object r) throws CharacterCodingException {
		OrderEntity oe = (OrderEntity) r;
		oe.setOperation(in.getShort());
		oe.setProvince(in.getShort());
		oe.setGwId(in.getInt());
		oe.setChannelId(in.getInt());
    }

}