outsmsdao.java

来自「短信系统SMS：支持普通短信、长短信和wap push短信的发送。」· Java 代码 · 共 99 行

package com.ekun.biz.dao;

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

/**
 * <p>Title: </p>
 * 待发表DAO,对应OPERATIONLINE_WAIT
 * <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);
  static String sqlSelect = "select MSGID,FEETYPE,FEECODE,CONTENT,SENDER_PORT,ACCEMOBI,SERVICETYPE,REPORTFLAG from OPERATIONLINE_WAIT ";
  /**
   * 为防止用户重启导致尚未更新状态的待发数据再重复发送，系统启动时先调用此函数更新一下状态！
   */
  public void updateSendFlag()
  {
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    try
    {
      conn = DBManager.getDBConn();
      //调用分区查询函数
      preparedStatement = conn.prepareStatement("{call PROC_UPDATE_SMSSTATE}");
      preparedStatement.execute();
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
      logger.error("OutsmsDAO.updateSendFlag出错!", ex);
    }
  }
  /**
   * 取得符合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 = sqlSelect + sFilter;
      preparedStatement = conn.prepareStatement(sql);
      rs = preparedStatement.executeQuery();
      ArrayList al = new ArrayList();
      while (rs.next())
      {
        OutsmsVO outsmsInfo = new OutsmsVO();
        outsmsInfo.setACCEMOBI(rs.getString("ACCEMOBI"));
        outsmsInfo.setCONTENT(rs.getString("CONTENT"));
        outsmsInfo.setFEECODE(rs.getInt("FEECODE"));
        outsmsInfo.setFEETYPE(rs.getInt("FEETYPE"));
        outsmsInfo.setMSGID(rs.getString("MSGID"));
        outsmsInfo.setREPORTFLAG(rs.getInt("REPORTFLAG"));
        outsmsInfo.setSENDER_PORT(rs.getString("REPORTFLAG"));
        outsmsInfo.setSERVICETYPE(rs.getString("SERVICETYPE"));
        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("OutsmsDAO.filterByWhere查询出错!", ex);
    }
    return new OutsmsVO[0];
  }

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