uploadrepository.java

非常有影响的 j道 论 坛 源码 国外很有明的专家编写的 ....对java爱好者很有参考价值

package com.jdon.jivejdon.repository;

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

import org.apache.log4j.Logger;

import com.jdon.jivejdon.Constants;
import com.jdon.jivejdon.dao.SequenceDao;
import com.jdon.jivejdon.dao.UploadFileDao;
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(Long messageId, boolean lazy) {
		return uploadFileDao.getAdjunct(messageId, lazy);
	}
	

	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(Long parentId, Collection uploads) throws Exception {
		if (uploads == null)
			return;
		logger.debug(" mergeAllUploadFiles parentId=" + parentId);
		for (Object o : uploads) {
			UploadFile uploadFile = (UploadFile) o;
			if (uploadFile.isDataIsLazyLoad())
				continue;

			uploadFileDao.deleteUploadFile(uploadFile.getId());
			saveUpload(uploadFile);
		}

	}
	
	public void deleteAllUploadFiles(Long parentId) {
		uploadFileDao.deleteAllUploadFile(parentId);
	}
}