bossfwsvcimpl.java

短信

package com.asiainfo.batchsend.sms.boss;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;

import org.apache.log4j.Logger;

import com.asiainfo.batchsend.model.SmsFwPush;
import com.asiainfo.databusi.util.CharUtil;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Company: Asiainfo Technologies(China),Inc </p>
 * <p>Date: Nov 6, 2007 3:55:51 PM </p>
 * <p>Email to: [e-mail] </p>
 * @author jiangyl
 * @version 1.0
 */

public class BossFwSvcImpl implements BossSvc {
	private static final Logger log = Logger.getLogger(BossFwSvcImpl.class);
	private String channelId = "";
	
	public BossFwSvcImpl(String channelId){
		this.channelId = channelId;
	}
	//判断是否有可发送的任务
	String hasLoadData = " select id, target_phone_number, src_msisdn,camp_channel_id, t.send_msg,t.received_time "
		   + " from sms_fw_push t where status = " + TODO + " and target_phone_number != '" + Config12350.NUMBER + "'"
		   + " and target_phone_number != '0' fetch first 2 rows only ";
	
	public boolean hasLoadData() {
		Connection conn = null;
		boolean flag = false;
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			ResultSet rs = conn.createStatement().executeQuery(hasLoadData);
			while(rs.next()){
				flag = true;
				break;
			}
			rs.close();
			conn.close();
		} catch (SQLException e) {
			log.error("深运平台在从sms_fw_push表中检查是否有发送数据时发生严重的错误",e);
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
		return flag;
		
	}
	
	//这里只根据任务提取数据，主要是因为根据调度任务传进来的taskId已经具备发送的条件
	String loadData = " select id, target_phone_number, src_msisdn,camp_channel_id, t.send_msg,t.received_time "
			   + " from sms_fw_push t where status = " + TODO + " and target_phone_number != '" + Config12350.NUMBER + "'"
			   + " and target_phone_number != '0' fetch first 10 rows only ";
	String updateStatus = "update sms_fw_push t set t.status = ? where t.id =?";
	
	public List loadData(){
		threadSleep(Config12350.sleepAfterFwSend);
		List list = new LinkedList();
		Connection conn = null;
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			conn.setAutoCommit(false);
			Statement psLoad = conn.createStatement();
			PreparedStatement psUpdate = conn.prepareStatement(this.updateStatus);
			ResultSet rs = psLoad.executeQuery(loadData);
			while(rs.next()){
				SmsFwPush sms = new SmsFwPush();
				sms.setId( rs.getLong("id"));
				sms.setTargetPhoneNumber(rs.getString("target_phone_number"));
				sms.setCampChannelId( rs.getString("camp_channel_id"));
				sms.setSendMsg( rs.getString("send_msg"));
				sms.setSrcMsisdn(rs.getString("src_msisdn"));  
				sms.setReceivedDate( rs.getDate("received_time"));
				list.add(sms);
	
				psUpdate.setInt(1, DONE);
				psUpdate.setLong(2, sms.getId());
				psUpdate.addBatch();
			}
			psUpdate.executeBatch();
			conn.commit();
			System.out.println("深运平台从sms_fw_push表在装载数据时获取" +  list.size());
		} catch (SQLException e) {
			try {
				conn.rollback();
			} catch (SQLException ee) {
			}
			log.error("控制线程在装载数据发生严重的错误",e);
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
		return list;
	}
	
	
	String send10086 = " insert into sms_receive(DONE_CODE,SRC_ADDR,DST_ADDR,TEXT,RECEIVE_DATE,DONE_DATE,TYPE,STATUS)"
				 + " values(0,?,'10086',?,sysdate,sysdate,1,0)";
	public boolean sendData(List list) {
		boolean flag = true;
		List failList = new ArrayList();
		Connection conn = null;
		PreparedStatement psInsert = null;
		try {
			conn = DBCon.getConnection();
			conn.setAutoCommit(false);
			psInsert = conn.prepareStatement(this.send10086);
			for (  int i = 0; i < list.size(); i++ ){
				SmsFwPush sms = (SmsFwPush)list.get(i);
				String date = "sysdate";
				if (  sms.getReceivedDate() != null ){
					date = "to_date('" + (sms.getReceivedDate()+"").substring(0,10) + "','yyyy-MM-dd')";
				}else{
					date = "sysdate";
				}
				psInsert.setString(1, sms.getSrcMsisdn());
				psInsert.setString(2, CharUtil.convertCharToGBK(sms.getSendMsg()));
				psInsert.addBatch();
			}
			psInsert.executeBatch();
			psInsert.close();
			conn.commit();
			log.debug("深运平台在向BOSS数据库表插入数据,共插入了" + list.size()+ "条记录");
		} catch (SQLException e) {
			flag = false;
			try {
				conn.close();
			} catch (SQLException ee) {
			}
			log.error("深运平台在向BOSS数据库表插入数据时发生严重的错误",e);
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
		return flag;
	}
	
	//发送成功之后如何处理数据
	public boolean successDone(List list) {
		return true;
	}
	
    //发送失败后需要如何处理数据
	public void failDone(List list) {
		Connection conn = null;
		String update = "update sms_receive t set t.status = ? where t.id = ?  ";
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			conn.setAutoCommit(false);
			PreparedStatement ps = conn.prepareStatement(update);
			for (  int i = 0; i < list.size(); i++ ){
				ps.setInt(1, FAIL);
				ps.setLong(2, ((SmsFwPush)list.get(i) ).getId());
				ps.addBatch();
			}
			ps.executeBatch();
			conn.commit();
		} catch (SQLException e) {
			try{
				conn.rollback();
			}catch(SQLException se){
			}
			log.error("深运平台在设置sms_push表发送失败状态的时候发生严重的错误",e);
		} finally {
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
		}
	}
	
	private void threadSleep(long msec) {
		try {
			Thread.sleep(msec);
		} catch (Exception e) {
		}
	}

	public String getChannel() {
		return this.channelId;
	}
	
}