inser12530errorsvc.java

短信

package com.asiainfo.batchsend.sms.boss.boss12503;

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 com.asiainfo.batchsend.model.SmsReceived;
import com.asiainfo.batchsend.sms.boss.DBCon;
import com.asiainfo.databusi.util.CharUtil;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Company: Asiainfo Technologies(China),Inc </p>
 * <p>Date: Nov 13, 2007 5:31:11 PM </p>
 * <p>Email to: [e-mail] </p>
 * @author jiangyl
 * @version 1.0
 */
public class Inser12530ErrorSvc {
	//status = 1 表示插入  2 表示处理过
	static String inser = " insert into sms_fw_12530_error( src_msisdn,send_msg,code,status,received_time) values(?,?,?,?,?)";
	public static void insert(String phone,String msg, String code){
		Connection conn = null;
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			PreparedStatement ins = conn.prepareStatement(inser);
			ins.setString(1, phone);
			ins.setString(2, CharUtil.convertCharToDb(msg));
			ins.setString(3, code);
			ins.setInt(4, 1);
			ins.setTimestamp(5,new java.sql.Timestamp(System.currentTimeMillis()));
			ins.executeUpdate();
			ins.close();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
	}
	
	static String query = " select * from sms_fw_12530_error where to_char(received_time,'yyyy-MM-dd') <= ? and to_char(received_time,'yyyy-MM-dd') >= ?";
	public static List findAll(String beginDate, String endDate){
		Connection conn = null;
		List list = new LinkedList();  
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			PreparedStatement ins = conn.prepareStatement(query);
			ins.setString(1, endDate);
			ins.setString(2, beginDate);
			ResultSet rs  = ins.executeQuery();
			while ( rs.next() ){
				SmsReceived  sms = new SmsReceived();
				sms.setMsisdn(rs.getString("src_msisdn"));
				sms.setCodeName(rs.getString("code"));
				sms.setReceivedMsg(CharUtil.convertCharToGBK(rs.getString("send_msg")));
				sms.setReceivedTime(rs.getTimestamp("received_time"));
				list.add(sms);
			}
			ins.close();
			conn.close();
			conn = null;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
		return list;
	}
}