smsfwloadsvc.java

短信

package com.asiainfo.batchsend.sms.sms.db;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;

import org.apache.log4j.Logger;

import com.asiainfo.batchsend.sms.boss.DBCon;
import com.asiainfo.batchsend.sms.sms.MessageInfo;
import com.asiainfo.databusi.util.DataBusiDbUtils;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Company: Asiainfo Technologies(China),Inc </p>
 * <p>Date: Dec 7, 2007 4:15:02 PM </p>
 * <p>Email to: [e-mail] </p>
 * @author jiangyl
 * @version 1.0
 */
public class SmsFwLoadSvc {
	private static final Logger log = Logger.getLogger(SmsFwLoadSvc.class);
	private String channelId;
	private static String strDBType = DataBusiDbUtils.BACKTYPE;

	public SmsFwLoadSvc(String channelId){
		this.channelId = channelId;
	}
	
	public List loadData() {
		List list = new LinkedList();
		Connection con = null;
		String sql = " select id,TARGET_PHONE_NUMBER,SRC_MSISDN,SEND_MSG from sms_fw_push" +
				" where status = 0 and camp_channel_id ='" +  channelId + "'"; 
		if (strDBType.equalsIgnoreCase("oracle")) {
			sql += " and rownum <  101";
		}else if(strDBType.equalsIgnoreCase("db2")) {
			sql += " fetch first 100 rows only ";
		}
		
		String update = "update sms_fw_push set status = 1, send_count = send_count+1 where id=?";
		try {
			con = DBCon.getShenYunDataSource().getConnection();
			con.setAutoCommit(false);
			ResultSet rs = con.createStatement().executeQuery(sql);
			PreparedStatement ps = con.prepareStatement(update);
			while(rs.next()){
				MessageInfo mbi = new MessageInfo();
				mbi.setMessageid(rs.getString("id"));
				mbi.setPhonenumber(rs.getString("SRC_MSISDN"));
				mbi.setSrcPhoneNumber(rs.getString("SRC_MSISDN"));
				mbi.setMessage(rs.getString("SEND_MSG"));
				list.add(mbi);
				
				ps.setInt(1, Integer.parseInt(mbi.getMessageid()));
				ps.addBatch();
			}
			ps.executeBatch();
			con.commit();
			con.close();
			con = null;
		} catch (Exception e) {
			try{
				con.rollback();
			}catch(Exception ee){
			}
			log.error("",e);
		} finally {
			if ( con != null ){
				try {
					con.close();
				} catch (SQLException e) {
				}
			}
		}
		return list;

	}
	
	public static void failDone(List list, int sendLimit){
		Connection con = null;
		String sql = " update sms_fw_push set status = (case when send_count >= " + sendLimit + " then 2 " +
		  			 " when send_count < " + sendLimit  + " then 0 end ) where id = ? ";
		try{
			con = DBCon.getShenYunDataSource().getConnection();
			con.setAutoCommit(false);
			PreparedStatement ps = con.prepareStatement(sql);
			for ( int i = 0; i < list.size(); i++ ){
				MessageInfo msg = (MessageInfo)list.get(i);
				ps.setInt(1, Integer.parseInt(msg.getMessageid()));
				ps.addBatch();
			}
			con.commit();
			con.close();
			con = null;
		} catch (Exception e) {
			try{
				con.rollback();
			}catch(Exception ee){
			}
			log.error("",e);
		} finally {
			if ( con != null ){
				try {
					con.close();
				} catch (SQLException e) {
				}
			}
		}
	}
}