fileuploadserviceimpl.java

这是一款最新的野蔷薇论坛源码,有需要的朋友可以尽情下载

/* 
 * Created on 2007-4-17
 * Last modified on 2007-4-17
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.fileUpload;

import java.util.List;

import org.apache.log4j.Logger;

import com.yeqiangwei.club.dao.DAOLocator;
import com.yeqiangwei.club.dao.DAOWrapper;
import com.yeqiangwei.club.fileUpload.dao.FileUpload;
import com.yeqiangwei.club.fileUpload.dao.FileUploadDAO;
import com.yeqiangwei.club.util.BeanLocator;
import com.yeqiangwei.club.util.BeanUtils;
import com.yeqiangwei.club.util.MessageUtils;
import com.yeqiangwei.util.TypeChange;
import com.yeqiangwei.util.Validator;

public class FileUploadServiceImpl extends MessageUtils implements FileUploadService {
	
	private static final Logger logger = Logger.getLogger(FileUploadServiceImpl.class);
	
	private FileUploadDAO fileUploadDAO;

	public FileUploadModel findById(int id) {
		if(id>0){
			FileUpload item = this.getFileUploadDAO().findById(id);
			if(!Validator.isEmpty(item)){
				FileUploadModel model = new FileUploadModel();
				BeanUtils.copyProperties(model,item);
				return model;
			}
		}
		return null;
	}

	public FileUploadModel createOrUpdate(FileUploadModel model) {
		return null;
	}
	
	private boolean validator(FileUploadModel model){
		boolean bea = false;
		if(!Validator.isEmpty(model)
				&&!Validator.isEmpty(model.getFileName()))
		{
			bea = true;
		}else{
			model = null;
			this.setMessage(MessageUtils.getMessage("error_system"));
			logger.error("数据写入失败，文件名为空！");
		}
		return bea;
	}
	
	public static void main(String args[]){
		com.yeqiangwei.club.dao.hibernate.ConnectionManager.init();
		FileUpload item = new FileUpload();
		FileUploadServiceImpl f = new FileUploadServiceImpl();
		f.getFileUploadDAO().create(item);
	}
	
	public FileUploadModel create(FileUploadModel model) {
		if(this.validator(model))
		{
			FileUpload item = new FileUpload();
			logger.debug("model.getFileUploadId()"+model.getFileUploadId());
			BeanUtils.copyProperties(item, model);
			logger.debug("FilePath:" + item.getFilePath());
			item = this.getFileUploadDAO().create(item);
			if(!Validator.isEmpty(item)){
				model.setFileUploadId(item.getFileUploadId());
				logger.debug("item.getFileUploadId()"+item.getFileUploadId());
				logger.debug("model.getFileUploadId()"+model.getFileUploadId());
			}else{
				model = null;
				this.setMessage(MessageUtils.getMessage("error_system"));
				logger.error("数据写入失败，文件地址为："+model.getFilePath()+model.getFileName());
			}
		}
		return model;
	}

	public FileUploadModel update(FileUploadModel model) {
		
		return null;
	}

	public int delete(FileUploadModel model) {
		int id = model.getFileUploadId();
		int c = 0;
		if(id>0){
			FileUpload item = new FileUpload();
			item.setFileUploadId(id);
			c = this.getFileUploadDAO().delete(item);
			if(c>0){
				this.setMessage(MessageUtils.getMessage("success"));
			}else{
				this.setMessage(MessageUtils.getMessage("error_system"));
			}
		}else{
			this.setMessage(MessageUtils.getMessage("error"));
		}
		return c;
	}

	public int delete(String[] ids) {
		int s = 0;
		int e = 0;
		for(int i=0; i<ids.length; i++){
			int id = TypeChange.stringToInt(ids[0]);
			FileUploadModel model = new FileUploadModel();
			model.setFileUploadId(id);
			if(this.delete(model)>0){
				s++;
			}else{
				e++;
			}
		}
		this.setMessage(MessageUtils.getMessage(s,e));
		return s;
	}

	public List<FileUploadModel> findByParameter(FileUploadParameter param) {
		List<FileUpload> list = this.getFileUploadDAO().findByParameter(param);
		List<FileUploadModel> mlist = BeanUtils.copyList(list,BeanLocator.FILEUPLOADMODEL);
		return mlist;
	}

	public long countByParameter(FileUploadParameter param) {
		return this.getFileUploadDAO().countByParameter(param);
	}

	public FileUploadDAO getFileUploadDAO() {
		if(Validator.isEmpty(fileUploadDAO)){
			fileUploadDAO = DAOWrapper.<FileUploadDAO>getDAO(DAOLocator.FILEUPLOAD);
		}
		return fileUploadDAO;
	}
	
}