groupdaoimpl.java

oa办公系统

/**
 * FileName:GroupDaoImpl.java,v 1.0 created in 2008-11-7 下午02:59:05
 * Created by jinbao
 * Copyright (c) 2008 ecjtu
 * All Rights Reserved.
 */
package cn.jx.ecjtu.oa.ps.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import com.wanczy.dbutil.IResultSetHandler;
import cn.jx.ecjtu.oa.ps.dao.BaseDao;
import cn.jx.ecjtu.oa.ps.dao.GroupDao;
import cn.jx.ecjtu.oa.ps.pojo.Group;

/**
 * 分组管理dao实现类
 * @author 金宝
 * @version $Revision: 1.37 $
 * @since 1.0
 */
public class GroupDaoImpl extends BaseDao implements GroupDao {
	class ResultSet2Group implements IResultSetHandler {
		public Object handle(ResultSet rs) throws SQLException {
			return new Group(rs.getInt("group_id"), rs.getString("group_name"),
					rs.getInt("user_id"));
		}
	}

	private ResultSet2Group resultSet2Group = new ResultSet2Group();

	/**
	 * 
	 */
	public int saveGroups(Group group) {
		return dbAccess
				.executeUpdate(
						"insert into oa_group (group_name,user_id) values (?,?)",
						new Object[] { group.getGroup_name(),
								group.getUser_id()});
	}

	/**
	 * 删除组,组中成员被放在默认组中
	 * 
	 * @author 何爱民
	 * @version $Revision: 1.37 $
	 * @since 1.0
	 */
	public int removeGroups(int user_id, int group_id) {
		int ret=0;
		ret+=dbAccess.executeUpdate(
				"update oa_postcard set group_id=0 where user_id=? and group_id=?", 
				new Object[] { user_id, group_id });
		ret+=dbAccess.executeUpdate("delete from oa_group where user_id=? and group_id=?",
				new Object[] { user_id, group_id });
		return ret;
	}
	
	/**
	 * 清空组中所有成员
	 * 
	 * @author 何爱民
	 * @version $Revision: 1.37 $
	 * @since 1.0
	 */
	public int clearGroups(int user_id,int group_id){
		int ret=1;
		ret+=dbAccess.executeUpdate(
				"delete from oa_postcard  where user_id=? and group_id=?", 
				new Object[] { user_id, group_id });
		return ret;
	}

	/**
	 * 修改组名
	 * 
	 * @author 吴元昆
	 * @version $Revision: 1.37 $
	 * @since 1.0
	 */
	public int updateGroup(Group group) {
		return dbAccess.executeUpdate(
				"update  oa_group set group_name=? where group_id=? and user_id=?",
				new Object[] { group.getGroup_name(), group.getGroup_id(),group.getUser_id() });
	}

	public int outputGroup(Group group) {
		return 0;

	}
	public int inputGroup(Group group){
		return 0;
	}

	public int groupIdByGroupName(String group_name,int user_id)
	{
		List list= dbAccess.executeQuery(
				"select * from oa_group where group_name=?",
				new Object[] { group_name}
				,resultSet2Group);
		if(list!=null) {
			int m=0;
			for(int k=0;k<list.size();k++){
				Group group=(Group)list.get(k);
				if(group.getUser_id()==user_id) m=group.getGroup_id();
			}
			return m;}
		else{ 
			return 0;}
	}
		
	
	public List<Group> findByOwner(int ownerId) {
		return dbAccess.executeQuery("select * from oa_group where user_id=?",
				new Object[] { ownerId }, resultSet2Group);
	}

}