mmspspreceivesvcimpl.java

短信

package com.asiainfo.batchsend.mms.psp;
import java.io.File;
import java.io.LineNumberReader;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.LinkedList;
import java.util.List;

import org.apache.log4j.Logger;

import com.asiainfo.batchsend.sms.boss.DBCon;
import com.asiainfo.batchsend.util.FileUtil;
import com.asiainfo.batchsend.util.FtpUtil;

/**
 * <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 MmsPspReceiveSvcImpl {
	private static final Logger log = Logger.getLogger(MmsPspReceiveSvcImpl.class);	
	
	public static class FileNameFilter implements java.io.FilenameFilter{
		public boolean accept(File dir, String name) {
			if ( name.toLowerCase().endsWith("log"))
				return true;
			return false;
		}
	}
	
	public String[] listFile(){
		return new File(MmsConfig.logPath).list(new FileNameFilter());
	}
	
	public void runReceive() {
		FtpUtil ftp = null;
		try {
			//下载文件
			ftp = new FtpUtil(MmsConfig.user,MmsConfig.password,MmsConfig.server,MmsConfig.dataPath);
			ftp.connect(MmsConfig.ftpLog);
			ftp.logPath = MmsConfig.logPath;
			String logSuff = "log";
			String[] file = ftp.nameList("*log");
			for ( int i = 0; i < file.length; i++ ){
				if ( file[i].indexOf(logSuff) > 0 ){
					ftp.get(file[i]);
					ftp.rename(file[i], file[i]+".bak");
				}
			}
			ftp.close();
			ftp = null;
			
			//解析文件入库
			String[] files = this.listFile();
			for ( int i = 0; i < files.length; i++ ){
				String[] sqls = this.getSqlByFile(files[i]);
				boolean flag = this.save2Db(sqls);
				if (flag){
				   FileUtil.moveMmsLogFile(files[i]);
				   log.info("文件名称" + files[i] + "已经成功入库");
				}
			}
		}catch(Exception e){
			log.error("",e);
		}finally{
			if ( ftp != null ){
				try{
					ftp.close();
				}catch(Exception se){
				}
			}
		}
	}
	
	private String[] getSqlByFile(String file){
		List list = new LinkedList();
		LineNumberReader reader = null;
		String line;
		try{
			reader = new LineNumberReader(new FileReader( MmsConfig.logPath + file));
			while ( (line = reader.readLine()) != null && !line.equals("")){
				list.add(constructSql(line));
			}
			reader.close();
		} catch (Exception e) {
			try{
				reader.close();
			}catch(Exception se){
			}
			log.error("",e);
		}
		return (String[])list.toArray(new String[list.size()]);
	}
	
	
	//发送成功之后如何处理数据
	private String constructSql(String line) {
		String[] val = line.split("[ ]+");
		String taskId = val[1].trim();
		taskId = taskId.substring(taskId.length()-20);
		String sql = "insert into NB_MMS_REPORT_STATUS(PSP_ID, TASK_ID, MSISDN,STATUS) values(" 
			+ val[0]+ ",'" + taskId +  "','" +  val[3]+ "'," + val[5].substring(0,1)+")";
		return sql;
	}
	
	
	
    //发送失败后需要如何处理数据
	public boolean save2Db(String[] sqls) {
		boolean flag = true;
		Connection conn = null;
		if ( sqls == null || sqls.length == 0 )
			return true;
		try {
			conn = DBCon.getShenYunDataSource().getConnection();
			conn.setAutoCommit(false);
			Statement ps = conn.createStatement();
			for (  int i = 0; i < sqls.length; i++ ){
				ps.addBatch(sqls[i]);
			}
			ps.executeBatch();
			conn.commit();
		} catch (SQLException e) {
			flag = false;
			try{
				conn.rollback();
			}catch(SQLException se){
			}
			log.error("深运平台在设置nb_mms_push表发送失败状态的时候发生严重的错误",e);
		} finally {
			try {
				conn.close();
			} catch (SQLException e) {
			}
		}
		return flag;
	}
}