messageblacklistserviceimpl.java

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

/* 
 * Created on 2007-5-2
 * Last modified on 2007-08-22
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.service.message;

import java.util.ArrayList;
import java.util.List;

import com.yeqiangwei.club.cache.Cache;
import com.yeqiangwei.club.cache.CacheFactory;
import com.yeqiangwei.club.cache.CacheRegion;
import com.yeqiangwei.club.dao.DAOLocator;
import com.yeqiangwei.club.dao.DAOWrapper;
import com.yeqiangwei.club.dao.MessageBlacklistDAO;
import com.yeqiangwei.club.dao.model.MessageBlacklist;
import com.yeqiangwei.club.exception.ClubException;
import com.yeqiangwei.club.param.MessageParameter;
import com.yeqiangwei.club.service.ServiceLocator;
import com.yeqiangwei.club.service.ServiceWrapper;
import com.yeqiangwei.club.service.model.MessageBlacklistModel;
import com.yeqiangwei.club.service.model.UserModel;
import com.yeqiangwei.club.service.user.UserService;
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;

/**
 * 
 * @author yeqiangwei
 */
public class MessageBlacklistServiceImpl implements MessageBlacklistService{
	
	public Cache cache = CacheFactory.creator(CacheRegion.MESSAGE_BLACKLIST);
	
	public static void main(String args[]){
		com.yeqiangwei.club.dao.hibernate.ConnectionManager.init();
		MessageBlacklistServiceImpl s = new MessageBlacklistServiceImpl();
		//com.yeqiangwei.club.dao.tran.TransactionUtils tran = new com.yeqiangwei.club.dao.tran.TransactionUtils();
		MessageParameter param = new MessageParameter();
		param.setMyUserId(95);
		param.setPage(1);
		param.setRows(20);
		List list = s.findByParameter(param);
		System.out.print(list);
		/*
		tran.beginTransaction();
		MessageBlacklistModel model = new MessageBlacklistModel();
		model.setUserName("111");
		model.setMyUserId(1);
		
		s.create(model);
		*/
		//tran.commit();
		//System.out.println(s.getMessage());
		com.yeqiangwei.club.dao.hibernate.ConnectionManager.closeSession();
	}
	

	public MessageBlacklistModel createOrUpdate(MessageBlacklistModel model) {
		return null;
	}

	public MessageBlacklistModel create(MessageBlacklistModel model) throws ClubException {
		int myUserId = model.getMyUserId();
		if(myUserId==0){
			throw new ClubException(MessageUtils.getMessage("error_notlogin"));
		}
		UserModel user = this.getUserService().findByUserName(model.getUserName());
		if(Validator.isEmpty(user)){
			throw new ClubException(MessageUtils.getMessage("error_notfind_user"));
		}
		int userId = user.getUserId();
		model.setUserId(userId);
		MessageBlacklist item = this.getMessageBlacklistDAO().findByMyUserIdAndUserId(myUserId,userId);		
		if(!Validator.isEmpty(item)){
			throw new ClubException(MessageUtils.getMessage("error_userName_duplicate"));
		}else{
			item = new MessageBlacklist();
			BeanUtils.copyProperties(item,model);
			this.getMessageBlacklistDAO().create(item);
			model.setMessageBlacklistId(item.getMessageBlacklistId());
			return model;
		}
	}

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

	public int delete(int id) throws ClubException {
		if(id>0){
			MessageBlacklist item = new MessageBlacklist();
			item.setMessageBlacklistId(id);
			return this.getMessageBlacklistDAO().delete(item);
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
	}

	public int delete(String[] ids) throws ClubException {
		if(!Validator.isEmpty(ids)){
			List<Integer> list = new ArrayList<Integer>();
			for(int i=0; i<ids.length; i++){
				int id = TypeChange.stringToInt(ids[i]);
				list.add(new Integer(id));
			}
			return this.getMessageBlacklistDAO().delete(list);
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
	}

	public int delete(List ids) throws ClubException {
		List<Integer> list = new ArrayList<Integer>();
		if(!Validator.isEmpty(ids)){
			for(int i=0; i<ids.size(); i++){
				int id = TypeChange.objToInt(ids.get(i));
				list.add(id);
			}
			return this.getMessageBlacklistDAO().delete(list);
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
	}
	
	public int deleteAllByMyUserId(int myUserId) throws ClubException {
		if(myUserId>0){
			return this.getMessageBlacklistDAO().deleteAllByMyUserId(myUserId);
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
	}

	public MessageBlacklistModel findByMyUserIdAndUserId(int myUserId, int userId) {
		MessageBlacklistModel model = null;
		MessageBlacklist item = this.getMessageBlacklistDAO().findByMyUserIdAndUserId(myUserId,userId);
		if(!Validator.isEmpty(item)){
			model = new MessageBlacklistModel();
			BeanUtils.copyProperties(model,item);
		}
		return model;
	}

	public List<MessageBlacklistModel> findByParameter(MessageParameter param) {
		List<MessageBlacklist> list = this.getMessageBlacklistDAO().findByParameter(param);
		//System.out.println(list.size());
		List<MessageBlacklistModel> mlist = BeanUtils.copyList(list, BeanLocator.MESSAGEBLACKLISTMODEL);
		//System.out.println(mlist.size());
		return mlist;
	}

	public long countByParameter(MessageParameter param) {
		return this.getMessageBlacklistDAO().countByParameter(param);
	}

	public MessageBlacklistDAO getMessageBlacklistDAO(){
		return DAOWrapper.<MessageBlacklistDAO>getSingletonInstance(DAOLocator.MESSAGEBLACKLIST);
	}

	public MessageBlacklistModel findById(int id) {
		return null;
	}

	public int delete(MessageBlacklistModel model) {
		return 0;
	}
	
	public UserService getUserService(){
		return ServiceWrapper.<UserService>getSingletonInstance(ServiceLocator.USER);
	}
}