GZ/nwyj/.svn/pristine/0e/0e1ae69006d28c6a294a34b866e9ee18c1554f8c.svn-base

package com.sinosoft.am.systemFile.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

import net.sf.json.JSONArray;

import org.apache.log4j.Logger;

import com.formaction.Parameter;
import com.formaction.vo.Msg;
import com.persistence.DbConnection;
import com.persistence.service.PersistenceFactory;
import com.persistence.service.exception.PersistenceException;
import com.sinosoft.am.systemFile.vo.SystemFile;
import com.sysmodel.datamodel.xmlmodel.ModelFactory;

public class SystemFileDao{
	private Logger	log	= Logger.getLogger(this.getClass());
	
	/**
	 * 上报文件  上级单位可看
	 * @throws ClassNotFoundException 
	 */
	public Msg appear(String comp_id,String fd_id) throws ClassNotFoundException{
		Msg m=new Msg();
		String []arr=fd_id.split(",");
		String sql="UPDATE ECM_AM_FILE_MANAGEMENT SET FILE_STATUS='1',REPORT_COMP_ID=? where fd_objectid=?";
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
			for(int i=0;i<arr.length;i++){
				st.setString(1, comp_id);
				st.setString(2, arr[i]);
				st.executeUpdate();
				num++;
			}
			if(num==arr.length){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.DELETE_SUCSESS);
				 conn.commit();
				 return m;
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.DELETE_FAILURE);
				conn.rollback();
				return m;
			}
		}catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
	}
	
	/**
	 * 发布文件 使所有级别都可以看到
	 * @throws ClassNotFoundException 
	 */
	public Msg issue(String comp_id,String fd_id) throws ClassNotFoundException{
		Msg m=new Msg();
		String []arr=fd_id.split(",");
		String sql="UPDATE ECM_AM_FILE_MANAGEMENT SET FILE_STATUS='2',PUBLISH_COMP_ID=? where fd_objectid=?";
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
			for(int i=0;i<arr.length;i++){
				st.setString(1, comp_id);
				st.setString(2, arr[i]);
				st.executeUpdate();
				num++;
			}
			if(num==arr.length){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.DELETE_SUCSESS);
				 conn.commit();
				 return m;
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.DELETE_FAILURE);
				conn.rollback();
				return m;
			}
		}catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
	}
	
	/**
	 * 撤回文件 更改文件状态，上级无法查看，只能本人查看
	 * @throws ClassNotFoundException 
	 */
	public Msg callBack(String fd_id) throws ClassNotFoundException{
		Msg m=new Msg();
		String []arr=fd_id.split(",");
		String sql="UPDATE ECM_AM_FILE_MANAGEMENT SET FILE_STATUS='0' where fd_objectid=?";
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
			for(int i=0;i<arr.length;i++){
				st.setString(1, arr[i]);
				st.executeUpdate();
				num++;
			}
			if(num==arr.length){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.DELETE_SUCSESS);
				 conn.commit();
				 return m;
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.DELETE_FAILURE);
				conn.rollback();
				return m;
			}
		}catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
	}
	
	/**
	 * 上传文件
	 */
	public void importFile(String fileName){
		
	}
	
	//查询上报的文件
	//上报公司为查询用户的子公司且状态为上报状态‘1’
	public List<Map<String, String>> queryAppearFileList(String userId,String conditon) throws ClassNotFoundException{
		String sql="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE REPORT_COMP_ID in(select id from sys_department_0827 where parent_id='"+userId+"') and FILE_STATUS='1' ";
		if(!"".equals(conditon)){
			sql+=conditon;
		}
		log.info("queryAppearFileList.sql==="+sql);
		List<Map<String, String>> list = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		log.info("获取已接收消息条数===="+list.size());
//		String result = "{\"rows\":" + JSONArray.fromObject(list).toString() + "}";
		return list;
	}
	
	//查询发布的文件
	//状态为2 且发布部门为当前用户部门
	public List<Map<String, String>> queryIssueFileList(String userId,String conditon) throws ClassNotFoundException{
		String sql="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE FILE_STATUS='2' AND PUBLISH_COMP_ID='"+userId+"' ";
		if(!"".equals(conditon)){
			sql+=conditon;
		}
		log.info("queryIssueFileList.sql==="+sql);
		List<Map<String, String>> list = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		log.info("获取已接收消息条数===="+list.size());
//		String result = "{\"rows\":" + JSONArray.fromObject(list).toString() + "}";
		return list;
	}
	
	//查询上传的文件
	//上传用户为登录用户且文件状态为上传状态‘0’
	public List<Map<String, String>> queryUploadFileList(String userId,String conditon) throws ClassNotFoundException{
		String sql="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE FILE_STATUS in('0','1')   AND PIGEONHOLE_MAN_ID='"+userId+"' ";
		if(!"".equals(conditon)){
			sql+=conditon;
		}
		log.info("queryUploadFileList.sql==="+sql);
		List<Map<String, String>> list = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		log.info("获取已接收消息条数===="+list.size());
//		String result = "{\"rows\":" + JSONArray.fromObject(list).toString() + "}";
		return list;
	}
	
	/**
	 * 初始化和查询文件
	 * @throws ClassNotFoundException 
	 */
	public String queryFileList(String userId,String comp_id,String condition,int pageNo,int pageSize) throws ClassNotFoundException{
		if(!"".equals(condition)){
			condition+=" ";
		}
		/*String sql1="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE REPORT_COMP_ID in(select id from sys_department_0827 where parent_id='"+userId+"') and FILE_STATUS='1' ";
		String sql2="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE FILE_STATUS='2' AND PUBLISH_COMP_ID='"+userId+"' ";
		String sql3="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT WHERE FILE_STATUS in('0','1')   AND PIGEONHOLE_MAN_ID='"+userId+"' ";*/
		String sql="";
		String sqlR="";
		
		if(!"".equals(condition)){
			sql+="select FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT "
					+ "WHERE (REPORT_COMP_ID in(select id from sys_department_0827 where parent_id='"+userId+"') and FILE_STATUS='1' "+condition+")or (FILE_STATUS='2' AND PUBLISH_COMP_ID='"+userId+"' "+condition+") or(FILE_STATUS in('0','1')   AND PIGEONHOLE_MAN_ID='"+userId+"' "+condition+") ";
			sqlR+="select top "+(pageNo-1)*pageSize+","+pageSize+" FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID from ECM_AM_FILE_MANAGEMENT "
					+ "WHERE (REPORT_COMP_ID in(select id from sys_department_0827 where parent_id='"+userId+"') and FILE_STATUS='1' "+condition+")or (FILE_STATUS='2' AND PUBLISH_COMP_ID='"+userId+"' "+condition+") or(FILE_STATUS in('0','1')   AND PIGEONHOLE_MAN_ID='"+userId+"' "+condition+") ";
			/*sql+=condition;
			sqlR+=condition;*/
		}
		List<Map<String, String>> list = null;
		List<Map<String, String>> listR = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
			listR = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sqlR);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		log.info("sqlR===="+sqlR);
		log.info("sql===="+sql);
		log.info("获取已接收消息条数===="+list.size());
		
		/*List<Map<String, String>>list1=queryAppearFileList(comp_id,condition);
		List<Map<String, String>>list2=queryIssueFileList(comp_id,condition);
		List<Map<String, String>>list3=queryUploadFileList(userId,condition);*/
		/*for(int i=0;i<list1.size();i++){
			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
//			list.add(list1.get(i));
		}*/
		/*for(int i=0;i<list2.size();i++){
			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
//			list.add(list2.get(i));
			
		}*/
		/*for(int i=0;i<list3.size();i++){
			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
//			list.add(list3.get(i));
			
		}*/
		
		log.info("获取已接收消息条数===="+list.size());
		String result = "{\"pager.pageNo\":"+pageNo+",\"pager.totalRows\":"+list.size()+",\"rows\":" + JSONArray.fromObject(listR).toString() + "}";
		log.info("result==="+result);
		return result;
	}
	
	
	/**
	 * 查看文件明细和修改文件查看
	 */
	public String getFileInfo(String fd_id){
		String sql="select * from ECM_AM_FILE_MANAGEMENT where fd_objectid='"+fd_id+"'";
		List list = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		String result = "{\"rows\":" + JSONArray.fromObject(list).toString() + "}";
		log.info("获取制度文件信息==="+result);
		return result;
	}
	
	/**
	 * 修改文件--纯修改文件基本信息
	 * @throws ClassNotFoundException 
	 */
	public Msg updateFile(SystemFile sf) throws ClassNotFoundException{
		Msg m=new Msg();
		String sql="update ECM_AM_FILE_MANAGEMENT SET FILE_TITLE=?,FILE_CLASSIFY=?,FILE_CONTENT=?,CHANGE_DETAIL=?,CHANGE_TYPE=?,UPDATEDATE=?,FILE_ADD_DATE=?  WHERE FD_OBJECTID=?";
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
				st.setString(1, sf.getFILE_TITLE());
				st.setString(2, sf.getFILE_CLASSIFY());
				st.setString(3, sf.getFILE_CONTENT());
				st.setString(4, sf.getCHANGE_DETAIL());
				st.setString(5, sf.getCHANGE_TYPE());
				st.setString(6,formatDate(new Date()));
				st.setString(7, sf.getFILE_ADD_DATE());
				st.setString(8, sf.getFD_OBJECTID());
				st.executeUpdate();
				num++;
			if(num==1){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.UPDATE_SUCSESS);
				 conn.commit();
				 return m;
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.UPDATE_FAILURE);
				conn.rollback();
				return m;
			}
		}catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
	}
	
	/**
	 * 归档--修改时如果附件栏有变动，则视为归档
	 * @throws ClassNotFoundException 
	 */
	public Msg placeFile(SystemFile sf) throws ClassNotFoundException{
		Msg m=new Msg();
//		String version_id=getVersionId(sf.getFD_OBJECTID());
		sf.setVERSION_ID(sf.getVERSION_ID());
		
		m=createFile(sf);
		
		m=deleteFile(sf.getFD_OBJECTID());
		return m;
	}
	
//	public String getVersionId(String id) throws ClassNotFoundException{
//		String sql="SELECT version_id FROM  WHERE fd_objectid='"+id+"'";
//		String fd_id="";
//		Connection conn = null;
//		Statement stat = null;
//		ResultSet rs = null;
//		DbConnection db = new DbConnection();
//		try {
//			conn = db.getConnection();
//			stat = conn.createStatement();
//			rs = stat.executeQuery(sql);
//			List<String> list = new ArrayList<String>();
//			while (rs.next()) {
//				list.add(rs.getString("FD_OBJECTID"));
//			}
//			if(list.size()==1){
//				fd_id=list.get(0);
//			}
//		} catch (SQLException e) {
//			this.log.error(e.getMessage(), e);
//			throw new ClassNotFoundException("DAO　Layou: 获得数据库消息ID集合"
//					+ sql, e);
//		} finally {
//			db.close(rs);
//			db.close(stat);
//			db.close(conn);
//		}
//		return fd_id;
//	}
	
	//查看历史版本，表格显示   版次-变更说明-状态
	public String showHis(String version_id){
		String sql="SELECT * FROM  ECM_AM_FILE_MANAGEMENT WHERE version_id='"+version_id+"'";
		List list = null;
		try {
			list = PersistenceFactory.getInstance( ModelFactory.getSysmodel()).getSearchResultToMap(99, sql);
		} catch (PersistenceException e) {
			log.error(e.getMessage());
		}
		log.info("获取已接收消息条数===="+list.size());
		String result =  JSONArray.fromObject(list).toString();
		return result;
	}
	
	/**
	 * 删除文件
	 * @throws ClassNotFoundException 
	 */
	public Msg deleteFile(String fd_id) throws ClassNotFoundException{
		Msg m=new Msg();
		String []arr=fd_id.split(";");
		String sql="UPDATE ECM_AM_FILE_MANAGEMENT SET IS_DEL='1' WHERE FD_OBJECTID=?" ;
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
			for(int i=0;i<arr.length;i++){
				st.setString(1, arr[i]);
				st.executeUpdate();
				num++;
			}
			if(num==arr.length){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.DELETE_SUCSESS);
				 conn.commit();
				 return m;
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.DELETE_FAILURE);
				conn.rollback();
				return m;
			}
		}catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
	}
	
	/**
	 * 增加文件
	 * @throws ClassNotFoundException 
	 */
	public Msg createFile(SystemFile sf) throws ClassNotFoundException{
		Msg m=new Msg();
//		String fileName=sf.getELECTRONIC_FILE();
//		String newFileName=uploadFile(fileName);
		String sql="INSERT INTO ECM_AM_FILE_MANAGEMENT(FD_OBJECTID,FILE_TITLE,FILE_CLASSIFY,FILE_CONTENT,FILE_ADD_DATE,PIGEONHOLE_MAN_ID,PIGEONHOLE_DATE,CHANGE_DETAIL,CHANGE_TYPE,PUBLISH_COMP_ID,REPORT_COMP_ID,FILE_STATUS,IS_DEL,ELECTRONIC_FILE,UPDATEDATE,VERSION_ID) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
		Connection conn = null;
		PreparedStatement st = null;
		int num=0;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			conn.setAutoCommit(false);
			st = conn.prepareStatement(sql);
			String fd_id=createMsgId(getMsgId());
				st.setString(1,fd_id );
				st.setString(2, sf.getFILE_TITLE());
				st.setString(3, sf.getFILE_CLASSIFY());
				st.setString(4, sf.getFILE_CONTENT());
				st.setString(5, sf.getFILE_ADD_DATE());
				st.setString(6, sf.getPIGEONHOLE_MAN_ID());
				st.setString(7, formatDate(new Date()));
				st.setString(8, sf.getCHANGE_DETAIL());
				st.setString(9, "新增");
				st.setString(10,"");//发布单位
				st.setString(11, "");//上报单位
				st.setString(12, "0");//发布、上传、上报状态
				st.setString(13,"0");
				st.setString(14, sf.getELECTRONIC_FILE());
				st.setString(15, formatDate(new Date()));
				st.setString(16, fd_id);
				st.executeUpdate();
				num++;
			if(num==1){
				log.info("删除----num===="+num);
				m.setSucsess(new Boolean(true).toString());
				 m.setInfo(Parameter.DELETE_SUCSESS);
				 conn.commit();
			}else{
				m.setSucsess(new Boolean(false).toString());
				m.setInfo(Parameter.DELETE_FAILURE);
				conn.rollback();
			}
		}catch (SQLException e) {
			m.setSucsess(new Boolean(false).toString());
			m.setInfo(Parameter.DELETE_FAILURE);
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 删除消息"
					+ sql, e);
		} finally {
			db.close(st);
			db.close(conn);
		}
		return m;
	}
	
	public String formatDate(Date d) {
		SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		String date = sd.format(d);
		return date;
	}
	
	public List<String> getMsgId() throws ClassNotFoundException {
		String sql = "SELECT FD_OBJECTID FROM ECM_AM_FILE_MANAGEMENT";
		Connection conn = null;
		Statement stat = null;
		ResultSet rs = null;
		DbConnection db = new DbConnection();
		try {
			conn = db.getConnection();
			stat = conn.createStatement();
			rs = stat.executeQuery(sql);
			List<String> list = new ArrayList();
			while (rs.next()) {
				list.add(rs.getString("FD_OBJECTID"));
			}
			return list;
		} catch (SQLException e) {
			this.log.error(e.getMessage(), e);
			throw new ClassNotFoundException("DAO　Layou: 获得数据库消息ID集合"
					+ sql, e);
		} finally {
			db.close(rs);
			db.close(stat);
			db.close(conn);
		}
	}
	
	public String createMsgId(List<String> list) throws ClassNotFoundException{
		long l=(long) ((Math.random()+1)*1000000000);
		String msgId=l+"";
		if(list.contains(msgId)){
			return createMsgId(list);
		}
		else{
			log.info("FD_OBJECTID==="+msgId);
		return msgId;
		}
	}
	
	//上传文件，参数为本地文件路径+文件名 
	//返回文件上传后在服务器中的地址加文件名
	public String uploadFile(String fileName){
		return null;
	}
	
	public void downLoadFile(String fd_id){
		
	}
}