wforgroledaoagent.java

公司自己开发的工作流引擎

package cn.com.iaspec.workflow.organize.business;

import org.apache.log4j.Logger;
import java.io.InputStream;
import java.util.Properties;
import java.io.IOException;
import cn.com.iaspec.workflow.vo.db.WfOrganization;
import cn.com.iaspec.workflow.vo.db.WfUser;
import cn.com.iaspec.workflow.vo.db.WfRole;
import cn.com.iaspec.workflow.privilege.dao.LoginDAO;
import cn.com.iaspec.workflow.organize.dao.WfRoleDAO;
import cn.com.iaspec.workflow.organize.dao.SelectActorDAO;
import cn.com.iaspec.workflow.organize.dao.WfUserDAO;
import java.util.List;
import java.util.ArrayList;
import cn.com.iaspec.workflow.vo.workflow.UserInfo;
import cn.com.iaspec.workflow.privilege.business.PrivilegeControl;
import cn.com.iaspec.workflow.organize.dao.WfOrganizationDAO;
import cn.com.iaspec.workflow.helper.SystemConfigurations;
import cn.com.iaspec.workflow.organize.interf.WfOrgInterface;
import cn.com.iaspec.workflow.sysmanage.interf.WfCheckExistsInterface;
import cn.com.iaspec.workflow.vo.workflow.WfCheckExistsResult;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: IASPEC Technologies</p>
 *
 * @author leigm
 * @version 1.0
 */

public class WfOrgRoleDAOAgent implements WfOrgInterface,WfCheckExistsInterface {

  private  transient Logger logger = null;
  private  WfOrgRoleDAOAgent instance = null;
  private  WfOrgInterface orgDaoImpl = null;
  private  WfCheckExistsInterface checkExistImpl = null;

  public WfOrgRoleDAOAgent(){
     logger = Logger.getLogger(WfOrgRoleDAOAgent.class);
     orgDaoImpl = SystemConfigurations.getInstance().getWfOrgInterface();
     checkExistImpl = SystemConfigurations.getInstance().getCheckExistsInterface();
  }
  public UserInfo login(String loginId,String password)throws Exception{
    if(orgDaoImpl != null){
        System.out.println("-----1----");
      return orgDaoImpl.login(loginId,password);
    }else{
        System.out.println("-----2----");
      new LoginDAO().login(loginId,password);
      System.out.println("---WfOrgRoleDAOAgent--success----");
      return null;
    }
  }

  /**
   * 根据登录名取得用户信息
   * @param loginId String
   * @return UserInfo
   */
  public UserInfo getUserInfoByLoginName(String loginId)throws Exception{
    if(orgDaoImpl != null){
      return orgDaoImpl.getUserInfoByLoginName(loginId);
    }else{
      return new LoginDAO().getUserInfoByLoginName(loginId);
    }
  }

  /**
   * 根据用户id取得用户信息
   * @param userId String
   * @return WfUser
   */
  public WfUser getUserInfo(String userId)throws Exception{
    if(orgDaoImpl != null){
      return orgDaoImpl.getUserInfo(userId);
    }else{
      return new WfUserDAO().getUserInfo(userId);
    }
  }

  /**
   * 取得指定组织信息
   * @param orgId String
   * @return WfOrganization
   */
  public WfOrganization getOrgInfo(String orgId)throws Exception{
    WfOrganization org = null;

    if(orgDaoImpl != null){
      org = orgDaoImpl.getOrgInfo(orgId);
    }else{
      org = new WfOrganizationDAO().getOrgInfo(orgId);
    }

    return org;
  }

  /**
   * 取得整个组织树的信息
   * @return WfOrganization[]
   */
  public WfOrganization[] getAllOrgInfo()throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getAllOrgInfo();
    }else{
      List orgList = new SelectActorDAO().getAllOrgInfo(null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定组织的直接子组织
   * @param orgId String   //指定组织id
   * @return WfOrganization[]
   */
  public WfOrganization[] getSubOrg(String orgId)throws Exception{
    if(orgDaoImpl != null){
      return orgDaoImpl.getSubOrg(orgId);
    }else{

    }

    return null;
  }

  /**
   * 取得指定组织的子组织，包括下级的下级组织
   * @param orgId String //指定组织id
   * @return WfOrganization[]
   */
  public WfOrganization[] getAllSubOrg(String orgId)throws Exception{
    if(orgDaoImpl != null){
      return orgDaoImpl.getAllSubOrg(orgId);
    }else{

    }

    return null;
  }

  /**
   * 取得指定用户所在的组织的直接上级组织
   * @param userId String //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserCurrentOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserCurrentOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getCurrOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定用户所在的组织的直接上级组织
   * @param userId String //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserParentOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserParentOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getParentOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得当前用户的所有上级部门，包括上级的上级
   * @param userId String  //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserAllParentOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserAllParentOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getParentOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定用户所在的组织的平级组织，不包括用户所在组织
   * @param userId String //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserParallelOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserParallelOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getParallelOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定用户所在的部门的所有下级组织，包括下级的下级
   * @param userId String  //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserSubOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserSubOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getChildOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定用户所在的部门的所有下级组织，包括下级的下级
   * @param userId String //指定用户id
   * @return WfOrganization[]
   */
  public WfOrganization[] getUserAllSubOrg(String userId)throws Exception{
    WfOrganization[] orgArray = null;

    if(orgDaoImpl != null){
      orgArray = orgDaoImpl.getUserAllSubOrg(userId);
    }else{
      List orgList = new SelectActorDAO().getAllChildOrgInfo(userId,null);
      if(orgList != null && orgList.size()>0){
        orgArray=new WfOrganization[orgList.size()];
        orgList.toArray(orgArray);
      }
    }

    return orgArray;
  }

  /**
   * 取得指定组织中的所有人员
   * @param orgId String  //指定的组织id
   * @return WfUser[]
   */
  public WfUser[] getOrgUser(String orgId)throws Exception{
    WfUser[] userArray = null;

    if(orgDaoImpl != null){
      userArray = orgDaoImpl.getOrgUser(orgId);
    }else{
      List userList = new SelectActorDAO().getUserByOrgId(orgId);
      if(userList != null && userList.size()>0){
        userArray = new WfUser[userList.size()];
        userList.toArray(userArray);
      }
    }

    return userArray;
  }

  /**
   * 取得指定的角色中信息
   * @param roleId String //指定的角色id
   * @return WfRole
   */
  public WfRole getRoleInfo(String roleId)throws Exception{
    WfRole role = null;

    if(orgDaoImpl != null){
      role = orgDaoImpl.getRoleInfo(roleId);
    }else{
      role = new WfRoleDAO().getRoleInfo(roleId);
    }

    return role;
  }

  /**
   * 取得指定角色中的所有人员
   * @param roleId String //指定的角色id
   * @return WfUser[]
   */
  public WfUser[] getRoleUser(String roleId)throws Exception{
    WfUser[] userArray = null;

    if(orgDaoImpl != null){
      userArray = orgDaoImpl.getRoleUser(roleId);
    }else{
      List userList = new SelectActorDAO().getUserByRoleId(roleId);

      if(userList != null && userList.size()>0){
        userArray=new WfUser[userList.size()];
        userList.toArray(userArray);
      }
    }

    return userArray;
  }

  /**
   * 检查在业务系统中是否存在参数中的用户信息
   *
   * @param userInfo WfUser      //待检查用户
   * @return WfCheckExistsResult
   * @throws Exception
   */
  public WfCheckExistsResult checkWfUserExists(WfUser userInfo)throws Exception{
    if(this.checkExistImpl == null){
      WfUserDAO userDao = new WfUserDAO();
      return userDao.checkUserExists(userInfo);
    }else{
      return this.checkExistImpl.checkWfUserExists(userInfo);
    }
  }

  public WfCheckExistsResult checkWfRoleExists(WfRole userInfo)throws Exception{

    return null;
  }

  public WfCheckExistsResult checkWfOrganizationExists(WfOrganization orgInfo)throws Exception{

    return null;
  }


}