uploadrepository.java

jive论坛使得不时地好的不好的jive论坛使得不时地好的不好的

package com.jdon.jivejdon.repository;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;

import org.apache.log4j.Logger;

import com.jdon.controller.model.PageIterator;
import com.jdon.jivejdon.Constants;
import com.jdon.jivejdon.dao.SequenceDao;
import com.jdon.jivejdon.dao.UploadFileDao;
import com.jdon.jivejdon.model.ForumMessage;
import com.jdon.jivejdon.model.UploadFile;

public class UploadRepository {
	private final static Logger logger = Logger.getLogger(UploadRepository.class);
	private SequenceDao sequenceDao;

	private UploadFileDao uploadFileDao;
	
	public UploadRepository(SequenceDao sequenceDao, UploadFileDao uploadFileDao) {
		this.sequenceDao = sequenceDao;
		this.uploadFileDao = uploadFileDao;
	}
	
	public Collection getUploadFiles(String parentId, boolean lazy) {
		Collection uploads = new ArrayList();
		Collection ids = uploadFileDao.getAdjunctIDs(parentId);
		Iterator iter = ids.iterator();
		while (iter.hasNext()) {
			String id = (String)iter.next();
			UploadFile uf = getUploadFile(id, lazy);
			uploads.add(uf);
		}
		return uploads;
	}
		
	
	public PageIterator getUploadFiles(int start,int count){
		return uploadFileDao.getUploadFiles(start, count);
	}
	

	public UploadFile getUploadFile(String objectId, boolean lazy) {
		return uploadFileDao.getUploadFile(objectId,lazy);
	}

	public void saveAllUploadFiles(String parentId, Collection uploads) throws Exception {
		logger.debug(" prepareForSaveAllUploadFiles parentId=" + parentId);
		if (uploads == null)
			return;
		logger.debug(" uploads size=" + uploads.size());
		Iterator iter = uploads.iterator();
		while (iter.hasNext()) {
			UploadFile uploadFile = (UploadFile) iter.next();
			uploadFile.setParentId(parentId);
			saveUpload(uploadFile);
		}
	}
	
	private void saveUpload(UploadFile uploadFile) throws Exception{
		Long mIDInt = sequenceDao.getNextId(Constants.OTHERS);
		uploadFile.setId(mIDInt.toString());
		uploadFileDao.createUploadFile(uploadFile);
	}
	
	public void updateAllUploadFiles(String parentId, Collection uploads) throws Exception {
		if (uploads == null)
			return;
		logger.debug(" mergeAllUploadFiles parentId=" + parentId);
		deleteAllUploadFiles(parentId);
		saveAllUploadFiles(parentId, uploads);

	}
	
	public void deleteAllUploadFiles(String parentId) {
		Collection ids = uploadFileDao.getAdjunctIDs(parentId);
		Iterator iter = ids.iterator();
		while (iter.hasNext()) {
			String id = (String)iter.next();
			deleteUploadFile(id);
		}
	}
	
	public  void deleteUploadFile(String objectId){
		uploadFileDao.deleteUploadFile(objectId);
	}
}