messageblacklistserviceimpl.java

野蔷薇论坛源码 java 自己看看吧。 学习用

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

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

import org.apache.log4j.Logger;

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.exception.DAOException;
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{
	
	private static final Logger logger = Logger.getLogger(MessageBlacklistServiceImpl.class);
	
	public Cache cache = CacheFactory.creator(CacheRegion.MESSAGE_BLACKLIST);
	
	public static void main(String args[]){
		com.yeqiangwei.club.dao.hibernate.ConnectionManager.init();

		com.yeqiangwei.club.dao.hibernate.ConnectionManager.closeSession();
	}
	

	public void createOrUpdate(MessageBlacklistModel model) {

	}

	public void 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);
			try {
				this.getMessageBlacklistDAO().create(item);
			} catch (DAOException e) {
				throw new ClubException(e.getMessage());
			}
			model.setMessageBlacklistId(item.getMessageBlacklistId());
		}
	}

	public void update(MessageBlacklistModel model) {

	}

	public int delete(int id) throws ClubException {
		if(id>0){
			MessageBlacklist item = new MessageBlacklist();
			item.setMessageBlacklistId(id);
			try {
				return this.getMessageBlacklistDAO().delete(item);
			} catch (DAOException e) {
				throw new ClubException(e.getMessage());
			}
		}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));
			}
			try {
				return this.getMessageBlacklistDAO().delete(list);
			} catch (DAOException e) {
				logger.error(e.toString());
			}
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
		return 0;
	}

	public int delete(List<Integer> 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);
			}
			try {
				return this.getMessageBlacklistDAO().delete(list);
			} catch (DAOException e) {
				logger.error(e.toString());
			}
		}else{
			throw new ClubException(MessageUtils.getMessage("error_parameter"));
		}
		return 0;
	}
	
	public int deleteAllByMyUserId(int myUserId) throws ClubException {
		if(myUserId>0){
			try {
				return this.getMessageBlacklistDAO().deleteAllByMyUserId(myUserId);
			} catch (DAOException e) {
				throw new ClubException(e.getMessage());
			}
		}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);
	}
}