clientlogic.java

这是一个上传下载的原代码

package com.model.logic;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Map;

import org.apache.struts.upload.FormFile;

import com.model.dao.Imp.INewsClient;
import com.model.entity.NewsInfo;
import com.model.form.QueryNewsForm;
import com.model.form.ServiceForm;
import com.project.util.DateTimeUtil;
/**
 *  创建人：杨森
 *  创建时间：2007-9-7
 *  描述：前台新闻展现逻辑层
 *  最后修改时间：
 *  最后修改人：
 */
public class ClientLogic {
	public INewsClient DBClient;
	public INewsClient getDBClient() {
		return DBClient;
	}
	public void setDBClient(INewsClient client) {
		DBClient = client;
	}
	/**
	 * @author YangSen
	 * @描述 实现综合信息5个模块展现 并加以分页 (综合信息模块)
	 */
	public Map queryNewsColligate(int index,int max,String role,String flag){
		return this.getDBClient().selectNewsColligateInfo(index,max,role,flag);
	}
	/**
	 * @author YangSen
	 * @描述 实现综合信息5个模块展现 并加以分页 (经济运行工作模块)
	 */
	public Map queryNewsEconomy(int index,int max,String role,String flag){
		return this.getDBClient().selectNewsEconomyInfo(index,max,role,flag);
	}
	/**
	 * @author YangSen
	 * @描述 实现综合信息5个模块展现 并加以分页 (省市模块)
	 */
	public Map queryNewsCityCrics(int index,int max,String role,String flag){
		return this.getDBClient().selectNewsCityCircsInfo(index,max,role,flag);
	}
	/**
	 * @author YangSen
	 * @描述 实现全部信息 index页面展现前3条记录
	 */
	public Map allNews(String role){
		return this.getDBClient().selectAllNews(role);
	}
	/**
	 * @author YangSen
	 * @描述 查询要寻找的对象
	 */
	public Map queryNewsContent(String newsId){
		return this.getDBClient().selectNewsContent(newsId);
	}
	/**
	 * @author YangSen
	 * @描述 根据页面获取的条件进行查询 并返回结果集
	 */
	public Map queryNewsInfo(QueryNewsForm form,int pageNum,int pageSize,String role){
		return this.getDBClient().selectQueryNews(form,pageNum,pageSize,role);
	}
	/**
	 * @author YangSen
	 * @描述 浏览公告更多信息
	 */
	public Map afficheMoreInfo(int pageNum,int pageSize,String role){
		return this.getDBClient().selectAffiche(pageNum,pageSize,role);
	}
	/**
	 * @author YangSen
	 * @throws IOException 
	 * @throws FileNotFoundException 
	 * @描述 后台信息上传
	 */
	public String uploadFile(ServiceForm service,String path) throws FileNotFoundException, IOException{
		FormFile file = service.getFile();
		NewsInfo newsInfo = new NewsInfo();
		String fileName = file.getFileName();
		String changFileName = DateTimeUtil.getDateFlag(fileName);
		
		newsInfo.setTitle(service.getTitle());
		newsInfo.setKind("信息服务");
		newsInfo.setNewsKey(fileName);
		newsInfo.setCreateDate(DateTimeUtil.getNowDate());
		newsInfo.setSort(changFileName);
		if(file == null){
			return "no";
		}else{
			InputStream streamIn = file.getInputStream();
			OutputStream streamOut = new FileOutputStream(path + "/" + changFileName); 
			int bytesRead = 0;
			byte[] buffer = new byte[8192];
			while((bytesRead = streamIn.read(buffer,0,8192))!= -1){
				streamOut.write(buffer,0,bytesRead);
			}
			streamOut.close();
			streamIn.close();
			file.destroy();
			boolean temp = this.getDBClient().upload(newsInfo);
			return (temp == true)?"ok":"no";
		}
	}
	/**
	 * @author YangSen
	 * @throws IOException 
	 * @throws FileNotFoundException 
	 * @描述 编辑信息上传
	 */
	public String editUploadFile(ServiceForm service,String path) throws FileNotFoundException, IOException{
		FormFile file = service.getFile();
		NewsInfo newsInfo = new NewsInfo();
		String fileName = file.getFileName();
		String changFileName = DateTimeUtil.getDateFlag(fileName);
		
		newsInfo.setTitle(service.getTitle());
		newsInfo.setKind("信息服务");
		newsInfo.setNewsKey(fileName);
		newsInfo.setCreateDate(DateTimeUtil.getNowDate());
		newsInfo.setSort(changFileName);
		newsInfo.setNewsId(service.getNewsId());
		if(file == null){
			return "no";
		}else{
			InputStream streamIn = file.getInputStream();
			OutputStream streamOut = new FileOutputStream(path + "/" + changFileName); 
			int bytesRead = 0;
			byte[] buffer = new byte[8192];
			while((bytesRead = streamIn.read(buffer,0,8192))!= -1){
				streamOut.write(buffer,0,bytesRead);
			}
			streamOut.close();
			streamIn.close();
			file.destroy();
			boolean temp = this.getDBClient().editServiceInfoSubmit(newsInfo);
			return (temp == true)?"ok":"no";
		}
	}
	/**
	 * @author YangSen
	 * @param newsId 查找文件的ID
	 * @描述 返回文件记录
	 */
	public NewsInfo downLoad(String newsId){
		return (NewsInfo)this.getDBClient().downLoad(newsId).get(0);
	}
	/**
	 * @author YangSen
	 * @param newsId 查找文件的ID
	 * @描述 返回文件记录和相关下载文件
	 */
	public NewsInfo downLoadAcc(String newsId){
		return (NewsInfo)this.getDBClient().downLoad(newsId).get(0);
	}
	/**
	 * @author YangSen
	 * @描述 信息服务列表
	 */
	public Map queryServiceInfo(int pageNum,int pageSize){
		return this.getDBClient().selectServiceInfo(pageNum, pageSize);
	}
	/**
	 * @author YangSen
	 * @描述 删除信息服务
	 */
	public void dlelteServiceInfo(String newsId){
		NewsInfo newsInfo = new NewsInfo();
		newsInfo.setNewsId(newsId);
		this.getDBClient().deleteServiceInfo(newsInfo);
	}
	/**
	 * @author YangSen
	 * @描述 编辑信息服务
	 */
	public NewsInfo editServiceInfo(String newsId){
		return (NewsInfo)this.getDBClient().editServiceInfo(newsId).get(0);
	}
}