package demo.smgpdemo;

import java.util.*;
import java.sql.*;
import java.io.*;
import com.huawei.smproxy.SMGPSMProxy;
import com.huawei.smproxy.comm.smgp.*;
import com.huawei.smproxy.comm.smgp.message.*;
import com.huawei.smproxy.util.*;

/**
 * <p>Web發(fā)送短消息管理操作類，具體負(fù)責(zé)將頁面提交的短消息發(fā)送到infoX</p>
 */

public class SMSender extends SMGPSMProxy
{
    //系統(tǒng)配置信息
    private static Args arg = Env.getConfig().getArgs("SMGPConnect");

    private static SMSender instance;

    public static SMSender getInstance()
    {
        if (instance==null)
        {
            instance = new SMSender();
        }
        return instance;
    }

    protected SMSender()
    {
        super(SMSender.arg);
    }

    /**
     * 當(dāng)與InfoX的連接被中斷時(shí)的處理
     */
    public void OnTerminate()
    {
        System.out.println("Connection have been breaked! ");
    }
    /**
     * 對(duì)SMGW主動(dòng)下發(fā)的消息的處理。此例中只返回一個(gè)成功的響應(yīng)。
     * @param msg 收到的消息。
     * @return 返回的相應(yīng)消息。
     */
    public SMGPMessage onDeliver(final SMGPDeliverMessage msg)
    {
		if (msg.getIsReport() == 1)
		{
			System.out.println("Get a report message. " + msg.toString());
			return new SMGPDeliverRespMessage(msg.getMsgId(), 0);
		}
		else
		{
			System.out.println("Get a deliver message. "+msg.toString());
			return new SMGPDeliverRespMessage(msg.getMsgId(), 0);
		}
    }

    /**
     * 發(fā)送一條消息，完成真正的消息發(fā)送。
     * @param msg 待發(fā)送的消息。
     * @return true：發(fā)送成功。false：發(fā)送失敗。
     */
    public boolean send(SMGPSubmitMessage msg) {
      if ( msg == null ) {
        return false;
      }
      SMGPSubmitRespMessage reportMsg = null;
      PreparedStatement stat = null;
      try {
          reportMsg = (SMGPSubmitRespMessage)super.send(msg);
      }
      catch (IOException ex) {
        ex.printStackTrace();
        return false;
      }
      return true;
    }
}