outsmsdao.java

短信系统SMS：支持普通短信、长短信和wap push短信的发送。

package com.casin.biz;

import java.sql.*;
import java.util.*;
import com.ekun.common.log.*;
import com.ekun.common.db.*;
import com.ekun.biz.vo.OutsmsVO;
import com.ekun.common.util.StringUtils;

/**
 * <p>Title: </p>
 * 待发表DAO,对应OPERATIONLINE
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author ekun
 * @version 1.0
 */
public class OutsmsDAO
{
  static Logger logger = LoggerFactory.getLogger(OutsmsDAO.class);

  /**
   * 取得符合Where条件的记录数组
   * @param sFilter String：过滤条件，即：包含where的语句
   * @return OutsmsVO[]
   */
  public OutsmsVO[] filterByWhere(String sFilter)
  {
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    ResultSet rs = null;
    try
    {
      conn = DBManager.getDBConn();
      //调用分区查询函数
      String sql ="select id,mobilenumber,url,filename,hint,push from alarm_sms " + sFilter;
      preparedStatement = conn.prepareStatement(sql);
      rs = preparedStatement.executeQuery();
      ArrayList al = new ArrayList();
      while (rs.next())
      {
        OutsmsVO outsmsInfo = new OutsmsVO();
        outsmsInfo.setACCEMOBI(rs.getString("mobilenumber"));

        int type = rs.getInt("push");
        if(type == 2){
          String strUrl = rs.getString("url");
          if (StringUtils.strTrimIsEmpty(strUrl)) //WAP短信需要的路径
            continue;
          strUrl += rs.getString("filename");
          outsmsInfo.setCONTENT(strUrl);
        }else if(type == 8){
          outsmsInfo.setCONTENT(rs.getString("hint"));
        }

        outsmsInfo.setFEECODE(0);
        outsmsInfo.setFEETYPE(0);
        outsmsInfo.setMSGID(rs.getString("id"));
        outsmsInfo.setREPORTFLAG(0);
        //发送者号码目前配置在cmpp.ini中sendPort;
        //outsmsInfo.setSENDER_PORT("059495500");
        outsmsInfo.setSERVICETYPE("HELP");
        al.add(outsmsInfo);
      }
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);

      return (OutsmsVO[])al.toArray(new OutsmsVO[0]);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);
      logger.error("数据库查询出错!", ex);
    }
    return new OutsmsVO[0];
  }

  public static void main(String[] args)
  {
    OutsmsDAO dao = new OutsmsDAO();
    dao.filterByWhere("");
  }
}