departmentbean.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.sxit.wap.department;
import java.sql.*;
import java.util.*;
import com.sxit.wap.common.*;
import com.sxit.wap.exception.*;

public class DepartmentBean extends DepartmentDao{
  public static Collection queryDepartmentByParentId(int parentId) throws SysException {
    return queryBySql("SELECT * FROM " + tableName + " WHERE PARENT_ID = " + parentId + " ORDER BY NAME");
  }
  public static Collection queryDepartmentByOrderParentId(int parentId) throws SysException {
    return queryBySql("SELECT * FROM " + tableName + " WHERE PARENT_ID = " + parentId + " ORDER BY ORDER_ID");
  }
  public static Collection getTree(int groupId) throws SysException {
    Collection value = new ArrayList();
    String sql = "SELECT LEVEL, ID, PARENT_ID, NAME FROM WAP_DEPARTMENT START WITH (PARENT_ID = 0 AND GROUP_ID = " + groupId + ") CONNECT BY PARENT_ID = PRIOR ID";
    Collection coll = DepartmentBean.queryBySql(sql);
    Iterator it = coll.iterator();
    int index = 0;
    Hashtable element = null;
    while ( it.hasNext() || element!=null) {
      if (element == null) {
        element = (Hashtable)it.next();
      }
      String level = (String)element.get("level");
      String id = (String)element.get("id");
      String parentId = (String)element.get("parentId");
      String name = (String)element.get("name");
      TreeModel treeModel = new TreeModel();
      treeModel.setIndex(index++);
      treeModel.setId(Integer.parseInt(id));
      treeModel.setPid(Integer.parseInt(parentId));
      treeModel.setName(name);
      treeModel.setLevel(Integer.parseInt(level));
      if (it.hasNext()) {
        element = (Hashtable)it.next();
        if (treeModel.getLevel() >= Integer.parseInt((String)element.get("level"))) {
          treeModel.setHasLeaf(0);
        } else {
          treeModel.setHasLeaf(1);
        }
      } else {
        treeModel.setHasLeaf(0);
        element = null;
      }
      treeModel.setIsOpen(1);
      treeModel.setIsAdmin(1);
      value.add(treeModel);
    }
    return value;
  }
  public static DepartmentModel getRootDepartmentModel(int groupId) throws SysException {
    String sql = "SELECT * FROM " + tableName + " WHERE PARENT_ID = 0 AND GROUP_ID = " + groupId;
    Collection coll = queryBySql(sql);
    Iterator it = coll.iterator();
    return toModel((Hashtable)it.next());
  }
  public static boolean hasSub(int id) throws SysException {
    String sql = "SELECT COUNT(*) FROM " + tableName + " WHERE PARENT_ID = " + id;
    return getRowCountBySql(sql) != 0;
  }
  public static String getDepartmentName(int departmentId) throws SysException {
    try {
      return findByPK(departmentId).getName();
    } catch (FinderException e) {
      throw new SysException(e.getMessage());
    }
  }
  public static boolean isGroupExists(int groupId) throws SysException {
    String sql = "SELECT COUNT(*) FROM WAP_DEPARTMENT WHERE GROUP_ID = " + groupId;
    return getRowCountBySql(sql) > 1;
  }
  public static void deleteByGroups(int[] groups) throws SysException {
    String sql = "";
    sql = "DELETE FROM WAP_DEPARTMENT WHERE 1 = 2";
    for ( int i = 0; i < groups.length; i++ ) {
      sql += " OR GROUP_ID = " + groups[i];
    }
    updateBySql(sql);
  }
}