deliverroutersupport.java

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

package com.sms.platform.switchcenter.support;

import org.apache.log4j.Logger;

import com.pub.dataframe.FileStack;
import com.sms.platform.switchcenter.entity.DeliverRouter;
import com.sms.platform.switchcenter.parameter.ReceiverParameter;
import com.sms.platform.switchcenter.parameter.SwitchParameter;
import com.sms.protocol.standard12.Standard_Deliver;
import com.sms.protocol.standard12.Standard_Inner_Deliver;

public class DeliverRouterSupport extends Support {

	public static Logger log = Logger.getLogger(DeliverRouterSupport.class);

	public DeliverRouterSupport() {
	}

	protected boolean resolve() {

		SwitchParameter global = SwitchParameter.getInstance();
		Standard_Inner_Deliver sid = (Standard_Inner_Deliver) super.inner;
		int orderID = 0;
		if (sid.getDesClientID() == 0) {// 获得目的方编号

			// 获得应该发送的合作伙伴
			if ((orderID = DeliverRouter.searchOrder(global.getDeliverRouter(),
					sid)) < 0) {
				// 没有找到合作伙伴，写到重发队列中
				log.debug(" no search : " + sid);

				ReceiverParameter rp = ReceiverParameter.getInstance();
				FileStack fs = FileStack.getInstance(rp.getFilename().get(0)
						.getFilename());
				try {
					while (true) {
						if (fs.push(inner)) {
							log.debug("DeliverQueue put : true");
							break;
						}
					}
				} catch (Exception ex) {
		            ObjectLog.log.error(sid.toDataString());
		            ObjectLogError.log.error(sid.toDataString());
					log.error("",ex);
				}
				return false;
			}

			if ((sid.getMessageType() == Standard_Deliver.MessageType_CancelAll
					|| sid.getMessageType() == Standard_Deliver.MessageType_CancelOne 
					|| sid.getMessageType() == Standard_Deliver.MessageType_Order)
					&& orderID > 0) {
				if (log.isDebugEnabled())
					log.debug("search  DesClientID order : "
							+ sid.getDesClientID() + "  ServiceCode : "
							+ sid.getServiceCode() + "  MessageType : "
							+ sid.getMessageType() + "  SourceMobile : "
							+ sid.getSrcMobile() + "  orderID : " + orderID
							+ "  SeqID : " + sid.getSequenceId());
			} else {
				if (log.isDebugEnabled())
					log.debug("search  DesClientID : " + sid.getDesClientID()
							+ "  ServiceCode : " + sid.getServiceCode()
							+ "  MessageType : " + sid.getMessageType()
							+ "  SourceMobile : " + sid.getSrcMobile()
							+ "  SeqID : " + sid.getSequenceId());
			}

		}

		return true;
	}

	protected void fail() {

	}
}