submitchecksupport.java

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

package com.sms.platform.switchcenter.support;

import org.apache.log4j.Logger;

import com.pub.util.Regexp;
import com.sms.platform.switchcenter.parameter.SenderParameter;
import com.sms.protocol.standard12.Standard_Head;
import com.sms.protocol.standard12.Standard_Inner_Response;
import com.sms.protocol.standard12.Standard_Inner_Submit;
import com.sms.protocol.standard12.Standard_SeqNum;

public class SubmitCheckSupport   extends Support{
	
	public static Logger log = Logger.getLogger(SubmitCheckSupport.class);

	public SubmitCheckSupport(){
	}

	protected boolean resolve() {
		
		SenderParameter sp = SenderParameter.getInstance();
		Standard_Inner_Submit sis = (Standard_Inner_Submit) super.inner;
		try {
			if (!Standard_SeqNum.checkSequence(sis.getSrcClientID(), sis
					.getSequenceId())) {
				ObjectLog.log.debug(sis.toDataString());
				Standard_Inner_Response ssr = new Standard_Inner_Response(sis);
				ssr.setState(Standard_Head.ERR_MESSAGE_STRUCTURE);
//			ObjectQueue.getInstanceResponse().add(ssr);
				return false;
			} else if (sis.getDestMobile() == null
					|| sis.getDestMobile().equals("")
					|| sis.getDestMobileCount() != 1
					|| (!Regexp.isSoftRegexpValidate(sis.getDestMobileOne(),
							Regexp.mobile_regexp))) {
				ObjectLog.log.debug(sis.toDataString());
				Standard_Inner_Response ssr = new Standard_Inner_Response(sis);
				ssr.setState(Standard_Head.ERR_MESSAGE_STRUCTURE);
//			ObjectQueue.getInstanceResponse().add(ssr);
				return false;
			} else if (sis.getMessageContent() == null
					|| ("").equals(sis.getMessageContent())) {
				ObjectLog.log.debug(sis.toDataString());
				Standard_Inner_Response ssr = new Standard_Inner_Response(sis);
				ssr.setState(Standard_Head.ERR_MESSAGE_CONTENT);
//			ObjectQueue.getInstanceResponse().add(ssr);
				return false;
			} else if (sis.getMessageLength() == 0) {
				ObjectLog.log.debug(sis.toDataString());
				Standard_Inner_Response ssr = new Standard_Inner_Response(sis);
				ssr.setState(Standard_Head.ERR_MESSAGE_LENGTH);
//			ObjectQueue.getInstanceResponse().add(ssr);
				return false;
			}
		} catch (Exception e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		return true;
	}
	
	protected void fail(){
		
	}	
}