msgcontentfilter.java

自动导入文件到数据库,用于无法实时入库,需要在特定时间大批量入库的程序

package com.onet.autobill.bill.convert;



import com.onet.autobill.bill.common.ResourceCollect;
import com.onet.autobill.util.ConvertString;
import com.onet.pojomsg.onetmsg3.SM_Base_Msg;
import com.onet.pojomsg.onetmsg3.SM_Constant;
import com.onet.pojomsg.onetmsg3.SM_Deliver_Msg;
import com.onet.pojomsg.onetmsg3.SM_Submit_Msg;

/**
 * 消息内容转换
 * @author mengwei
 *
 */
public class MsgContentFilter implements ConvertFilter {

	@Override
	public void convert(SM_Base_Msg baseMsg) throws Exception{
		if(baseMsg.getCommandID()==SM_Constant.TYPE_SM_DELIVER){
			SM_Deliver_Msg deliver = (SM_Deliver_Msg)baseMsg;
			deliver.putAppendageField("MsgContent",ConvertString.formatMsgContent(Integer.parseInt((String)deliver.getAppendageField("MsgFormat")), ConvertString.getStringFromGbkHex((String)deliver.getAppendageField("MsgContent"))));
			
		}
		if(baseMsg.getCommandID()==SM_Constant.TYPE_SM_SUBMIT){
			SM_Submit_Msg submit = (SM_Submit_Msg)baseMsg;
			submit.putAppendageField("MsgContent",(ConvertString.formatMsgContent(Integer.parseInt((String)submit.getAppendageField("MsgFormat")), ConvertString.getStringFromGbkHex((String)submit.getAppendageField("MsgContent")))));
			
		}

	}

	@Override
	public void initResource(ResourceCollect resourceCollect) {
		return;
		
	}

}