sendthread.java~74~

短信网关发送接受平台。

package smscenter;
import cmpp12.*;
import com.newpalm.smsgwapi.*;
import com.newpalm.log.BatchLog;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */
import java.io.*;
import smscenter.pack.*;
public class SendThread extends Engine{
    public SpConnector12 Connector = null;

    public String updateSql = "update sms_submit set result = ";
    public String setSql = " , resend = resend-1";
    public String whereSql = " where msg_id = ";

    public DBConnection db = null;
    public SendThread() {
        super("SendThread");
        setDaemon(true);
    }
    public SendThread(SpConnector12 spConnector){
        super("SendThread");
        setDaemon(true);
        this.Connector = spConnector;
        db = new DBConnection(Config.db_name ,Config.db_host );
    }
    public void run(){
        while(isRunning()){
            /*
                提取sms包
            */
            System.out.println("发送队列中有 ("+Config.sendPool.getSize()+") 个SUBMIT包");
            SubmitPack submitPack = new SubmitPack();
            if(Config.sendPool.getSize()>0 ){
                submitPack = (SubmitPack)Config.sendPool.pop();

            /*
                发送submit包
            */
                CMPPSubmitMessage oneMsg = new CMPPSubmitMessage();
                oneMsg.setMsgId(submitPack.msg_id);
//            if(Config.msg_id>4) break; //if sended 2 msg, then jump out of while
                oneMsg.setPkTotal(submitPack.pkTotal);
                oneMsg.setPkNumber(submitPack.pkNumber );
                oneMsg.setRegisteredDelivery(submitPack.registered_deliery );
                oneMsg.setMsgLevel(submitPack.msg_level );
                oneMsg.setServiceId(submitPack.serviced_id );
                oneMsg.setFeeUserType(submitPack.fee_user_type);
                oneMsg.setFeeTerminalId(submitPack.fee_terminal_id );
                oneMsg.setTpPid(submitPack.tp_pid );
                oneMsg.setTpUdhi(submitPack.tp_udhi);
                oneMsg.setMsgFmt(submitPack.msg_fmt );
                oneMsg.setMsgSrc(submitPack.msg_src );
                oneMsg.setFeeType(submitPack.fee_type);
                oneMsg.setFeeCode(submitPack.fee_code);
                oneMsg.setValidTime(submitPack.valid_time );
                oneMsg.setAtTime(submitPack.at_time );
                oneMsg.setSrcTerminalId(submitPack.src_terminal_id );
                oneMsg.setDestUsrTl(submitPack.dest_user_t1 );
                oneMsg.setDestTerminalId(submitPack.dest_terminal_id );
                oneMsg.setMsgContent(submitPack.msg_content );
                oneMsg.setReserve(submitPack.reserve );
                //send the message
                try {
                    Connector.sendMsg(oneMsg);
                    String sql = updateSql + "2" + setSql + whereSql + String.valueOf(oneMsg.getMsgId());
                    System.out.println("正在发送！");
                    db.executeUpdate(sql);
                    System.out.println("Send one submit message: " +
                                       " SequenceID:'" + oneMsg.getSequenceID() + "'" +
                                       " Msg_id:'" + oneMsg.getMsgId() + "'" +
                                       " Pk_total:'" + oneMsg.getPkTotal() + "'" +
                                       " Pk_number:'" + oneMsg.getPkNumber() + "'" +
                                       " Msg_level:'" + oneMsg.getMsgLevel() + "'" +
                                       " Service_id:'" + oneMsg.getServiceId() + "'" +
                                       " fee_usertype:'" + oneMsg.getFeeUserType() + "'" +
                                       " fee_termianl_id:'" + oneMsg.getFeeTerminalId() + "'" +
                                       " tp_pid:'" + oneMsg.getTpPid() + "'" +
                                       " tp_udhi:'" + oneMsg.getTpUdhi() + "'" +
                                       " Msg_Fmt:'" + oneMsg.getMsgFmt() + "'" +
                                       " Msg_src:'" + oneMsg.getMsgSrc() + "'" +
                                       " FeeType:'" + oneMsg.getFeeType() + "'" +
                                       " FeeCode:'" + oneMsg.getFeeCode() + "'" +
                                       " Valid_Time:'" + oneMsg.getValidTime() + "'" +
                                       " At_Time:'" + oneMsg.getAtTime() + "'" +
                                       " Src_terminal_id:'" + oneMsg.getSrcTerminalId() + "'" +
                                       " DestUsr_tl:'" + oneMsg.getDestUsrTl() + "'" +
                                       " Dest_terminal_id:'" + oneMsg.getDestTerminalId().trim() +"'" +
                                       " Msg_Content:'" + oneMsg.getMsgContent() + "'" +
                                       " Registered_delivery:'" + oneMsg.getRegisteredDelivery() + "'" +
                                       " Reserve:'" + oneMsg.getReserve() + "'\n"
                                       );
                    Config.log.log("Send one submit message: " +
                                       " SequenceID:'" + oneMsg.getSequenceID() + "'" +
                                       " Msg_id:'" + oneMsg.getMsgId() + "'");
                }
                catch (Exception ex) {Config.log.log("Exception in SendThread : \r\n\t"+ex.toString() );}
            }
            try{
                sleep(TimeConfig.TIME_ONE_SECOND);
            }catch(Exception e){
                System.out.println("Exception In SendThread : "+e.toString() );
            }
        }
    }

    public static void main(String[] args) {
        SendThread sendThread1 = new SendThread();
    }
}