smsqueue.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.tssx.ebiz.smscenter;

import java.sql.*;

public class SMSQueue
{

    private String destinationAddr;
    private long queueID;
    private String sourceAddr;
    private short priorityFlag;
    private Date scheduleTime;
    private short sendStat;
    private String content;
    private long userID;
    private short submitMulti;
    private short fileNum;
    private short sendCount;
    private Date validatyPeriod;
    private String spNumber;
    private String corpID;
    private String serviceType;
    private int feeType;
    private int morelatetoMTFlag;
    private String feeValue;
    private String givenValue;
    private int reportFlag;

    public SMSQueue()
    {
    }

    public void insert(Connection con, long queueID, String sourceAddr, String destinationAddr, String content, short submitMulti,
            int fileNum, String spNumber, String corpID, String serviceType, int feeType, String feeValue, String givenValue,
            int morelatetoMTFlag, int reportFlag)
        throws SQLException
    {
        String sql = "";
        PreparedStatement stmt = null;
        try
        {
            sql = "insert into tsmsqueu(queueID,scheduleTime,sourceAddr,destinationAddr,content,submitMulti,fileNum,validatyPeriod,spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag) values (?,sysdate,?,?,?,?,?,sysdate,?,?,?,?,?,?,?,?)";
            stmt = con.prepareStatement(sql);
            stmt.setLong(1, queueID);
            stmt.setString(2, sourceAddr);
            stmt.setString(3, destinationAddr);
            stmt.setString(4, content);
            stmt.setShort(5, submitMulti);
            stmt.setInt(6, fileNum);
            stmt.setString(7, spNumber);
            stmt.setString(8, corpID);
            stmt.setString(9, serviceType);
            stmt.setInt(10, feeType);
            stmt.setString(11, feeValue);
            stmt.setString(12, givenValue);
            stmt.setInt(13, morelatetoMTFlag);
            stmt.setInt(14, reportFlag);
            stmt.executeUpdate();
            stmt.close();
        }
        finally
        {
            if(stmt != null)
                stmt = null;
        }
    }

    public void insert(Connection con, long queueID, String sourceAddr, String destinationAddr, String content, short submitMulti,
            int fileNum, long userID, String spNumber, String corpID, String serviceType, int feeType,
            String feeValue, String givenValue, int morelatetoMTFlag, int reportFlag)
        throws SQLException
    {
        String sql = "";
        PreparedStatement stmt = null;
        try
        {
            sql = "insert into tsmsqueu(queueID,scheduleTime,sourceAddr,destinationAddr,content,submitMulti,fileNum,userID,validatyPeriod,spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag) values (?,sysdate,?,?,?,?,?,?,sysdate,?,?,?,?,?,?,?,?)";
            stmt = con.prepareStatement(sql);
            stmt.setLong(1, queueID);
            stmt.setString(2, sourceAddr);
            stmt.setString(3, destinationAddr);
            stmt.setString(4, content);
            stmt.setShort(5, submitMulti);
            stmt.setInt(6, fileNum);
            stmt.setLong(7, userID);
            stmt.setString(8, spNumber);
            stmt.setString(9, corpID);
            stmt.setString(10, serviceType);
            stmt.setInt(11, feeType);
            stmt.setString(12, feeValue);
            stmt.setString(13, givenValue);
            stmt.setInt(14, morelatetoMTFlag);
            stmt.setInt(15, reportFlag);
            stmt.executeUpdate();
            stmt.close();
        }
        finally
        {
            if(stmt != null)
                stmt = null;
        }
    }
    public void insertByDate(Connection con, long queueID, String sourceAddr, String destinationAddr, String content, short submitMulti,
            int fileNum, String spNumber, String corpID, String serviceType, int feeType, String feeValue, String givenValue,
            int morelatetoMTFlag, int reportFlag,String dateSql)
            throws SQLException{
          String sql = "";
           PreparedStatement stmt = null;
           try
           {
               sql = "insert into tsmsqueu(queueID,scheduleTime,sourceAddr,destinationAddr,content,submitMulti,fileNum,validatyPeriod,spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag) values (?,"+dateSql+",?,?,?,?,?,"+dateSql+",?,?,?,?,?,?,?,?)";
               System.out.println(sql);
               stmt = con.prepareStatement(sql);
               stmt.setLong(1, queueID);
               stmt.setString(2, sourceAddr);
               stmt.setString(3, destinationAddr);
               stmt.setString(4, content);
               stmt.setShort(5, submitMulti);
               stmt.setInt(6, fileNum);
               stmt.setString(7, spNumber);
               stmt.setString(8, corpID);
               stmt.setString(9, serviceType);
               stmt.setInt(10, feeType);
               stmt.setString(11, feeValue);
               stmt.setString(12, givenValue);
               stmt.setInt(13, morelatetoMTFlag);
               stmt.setInt(14, reportFlag);
               stmt.executeUpdate();
               stmt.close();
           }
           finally
           {
               if(stmt != null)
                   stmt = null;
           }

    }

    public void insert(Connection con, long queueID, String destinationAddr)
        throws SQLException
    {
        String sql = "";
        PreparedStatement stmt = null;
        sql = "insert into tsmsmult(queueID,destinationAddr) values (?,?)";
        try
        {
            stmt = con.prepareStatement(sql);
            stmt.setLong(1, queueID);
            stmt.setString(2, destinationAddr);
            stmt.executeUpdate();
            stmt.close();
        }
        finally
        {
            if(stmt != null)
                stmt = null;
        }
    }

    public void setDestinationAddr(String destinationAddr)
    {
        this.destinationAddr = destinationAddr;
    }

    public String getDestinationAddr()
    {
        return destinationAddr;
    }

    public void setQueueID(long queueID)
    {
        this.queueID = queueID;
    }

    public long getQueueID()
    {
        return queueID;
    }

    public void setSourceAddr(String sourceAddr)
    {
        this.sourceAddr = sourceAddr;
    }

    public String getSourceAddr()
    {
        return sourceAddr;
    }

    public void setPriorityFlag(short priorityFlag)
    {
        this.priorityFlag = priorityFlag;
    }

    public short getPriorityFlag()
    {
        return priorityFlag;
    }

    public void setScheduleTime(Date scheduleTime)
    {
        this.scheduleTime = scheduleTime;
    }

    public Date getScheduleTime()
    {
        return scheduleTime;
    }

    public void setSendStat(short sendStat)
    {
        this.sendStat = sendStat;
    }

    public short getSendStat()
    {
        return sendStat;
    }

    public void setContent(String content)
    {
        this.content = content;
    }

    public String getContent()
    {
        return content;
    }

    public void setUserID(long userID)
    {
        this.userID = userID;
    }

    public long getUserID()
    {
        return userID;
    }

    public void setSubmitMulti(short submitMulti)
    {
        this.submitMulti = submitMulti;
    }

    public short getSubmitMulti()
    {
        return submitMulti;
    }

    public void setFileNum(short fileNum)
    {
        this.fileNum = fileNum;
    }

    public short getFileNum()
    {
        return fileNum;
    }

    public void setSendCount(short sendCount)
    {
        this.sendCount = sendCount;
    }

    public short getSendCount()
    {
        return sendCount;
    }

    public void setValidatyPeriod(Date validatyPeriod)
    {
        this.validatyPeriod = validatyPeriod;
    }

    public Date getValidatyPeriod()
    {
        return validatyPeriod;
    }

    public void setSpNumber(String spNumber)
    {
        this.spNumber = spNumber;
    }

    public String getSpNumber()
    {
        return spNumber;
    }

    public void setCorpID(String corpID)
    {
        this.corpID = corpID;
    }

    public String getCorpID()
    {
        return corpID;
    }

    public void setServiceType(String serviceType)
    {
        this.serviceType = serviceType;
    }

    public String getServiceType()
    {
        return serviceType;
    }

    public void setFeeType(int feeType)
    {
        this.feeType = feeType;
    }

    public int getFeeType()
    {
        return feeType;
    }

    public void setFeeValue(String feeValue)
    {
        this.feeValue = feeValue;
    }

    public String getFeeValue()
    {
        return feeValue;
    }

    public void setGivenValue(String givenValue)
    {
        this.givenValue = givenValue;
    }

    public String getGivenValue()
    {
        return givenValue;
    }

    public void setMorelatetoMTFlag(int morelatetoMTFlag)
    {
        this.morelatetoMTFlag = morelatetoMTFlag;
    }

    public int getMorelatetoMTFlag()
    {
        return morelatetoMTFlag;
    }

    public void setReportFlag(int reportFlag)
    {
        this.reportFlag = reportFlag;
    }

    public int getReportFlag()
    {
        return reportFlag;
    }
}