/*
 * Aipo is a groupware program developed by Aimluck,Inc.
 * Copyright (C) 2004-2008 Aimluck,Inc.
 * http://aipostyle.com/
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
package com.aimluck.eip.common;

import java.util.Collections;
import java.util.Comparator;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import org.apache.cayenne.access.DataContext;
import org.apache.cayenne.exp.Expression;
import org.apache.cayenne.exp.ExpressionFactory;
import org.apache.cayenne.query.SelectQuery;
import org.apache.jetspeed.services.logging.JetspeedLogFactoryService;
import org.apache.jetspeed.services.logging.JetspeedLogger;
import org.apache.jetspeed.services.rundata.JetspeedRunData;
import org.apache.jetspeed.services.rundata.JetspeedRunDataService;
import org.apache.turbine.services.TurbineServices;
import org.apache.turbine.services.rundata.RunDataService;

import com.aimluck.eip.cayenne.om.account.EipMCompany;
import com.aimluck.eip.cayenne.om.account.EipMPosition;
import com.aimluck.eip.cayenne.om.account.EipMPost;
import com.aimluck.eip.cayenne.om.account.auto._EipMPost;
import com.aimluck.eip.cayenne.om.security.TurbineUser;
import com.aimluck.eip.orm.DatabaseOrmService;

/**
 * 会社情報、部署情報、役職情報をメモリ上に保持するクラスです。 <br />
 *
 */
public class ALEipManager {

  /** logger */
  private static final JetspeedLogger logger = JetspeedLogFactoryService
      .getLogger(ALEipManager.class.getName());

  /** Singleton */
  private static ALEipManager manager = new ALEipManager();

  /** The JetspeedRunData Service. */
  private JetspeedRunDataService runDataService = null;

  /** 会社リスト */
  private Map companysMap = new LinkedHashMap();

  /** 部署リスト */
  private Map postsMap = new LinkedHashMap();

  /** 役職リスト */
  private Map positionsMap = new LinkedHashMap();

  /**
   *
   *
   */
  private ALEipManager() {
    this.runDataService = (JetspeedRunDataService) TurbineServices
        .getInstance().getService(RunDataService.SERVICE_NAME);
    initCompany();
    initPost();
    initPosition();
  }

  /**
   *
   * @return
   */
  public static ALEipManager getInstance() {
    return manager;
  }

  /**
   *
   */
  private void initCompany() {
    companysMap.clear();

    String org_id = null;
    List org_list = DatabaseOrmService.getInstance().getOrgKeys();
    Iterator iter = org_list.iterator();
    while (iter.hasNext()) {
      try {
        /** 会社リスト */
        Map companyMap = new LinkedHashMap();

        org_id = (String) iter.next();
        DataContext dataContext = DataContext.createDataContext(org_id);
        SelectQuery query = new SelectQuery(EipMCompany.class);
        List list = dataContext.performQuery(query);
        int size = list.size();
        for (int i = 0; i < size; i++) {
          EipMCompany record = (EipMCompany) list.get(i);
          ALEipCompany company = new ALEipCompany();
          company.initField();
          company.setCompanyId(record.getCompanyId().intValue());
          company.setCompanyName(record.getCompanyName());
          companyMap.put(record.getCompanyId(), company);
        }
        companysMap.put(org_id, companyMap);
      } catch (Exception e) {
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   *
   */
  private void initPost() {
    postsMap.clear();

    String org_id = null;
    List org_list = DatabaseOrmService.getInstance().getOrgKeys();
    Iterator iter = org_list.iterator();
    while (iter.hasNext()) {
      try {
        /** 部署リスト */
        Map postMap = new LinkedHashMap();

        org_id = (String) iter.next();
        DataContext dataContext = DataContext.createDataContext(org_id);
        SelectQuery query = new SelectQuery(EipMPost.class);
        //Add 2010/07/31 キョク Start---
        Expression exp1 = ExpressionFactory.noMatchExp(
            EipMPost.DISABLED_PROPERTY, ALEipConstants.USER_STAT_DISABLED);
        Expression exp2 = ExpressionFactory.noMatchExp(
            EipMPost.DISABLED_PROPERTY, ALEipConstants.USER_STAT_NUTRAL);
        
        query.setQualifier(exp1);        
        query.andQualifier(exp2);
        
        //Add 2010/07/31 キョク End---
        List list = dataContext.performQuery(query);
        Collections.sort(list, new Comparator<Object>(){
          public int compare(Object l1, Object l2) {
            return ((EipMPost) l1).getPostName().compareTo(((EipMPost) l2).getPostName());
          }
        });
        int size = list.size();
        for (int i = 0; i < size; i++) {
          EipMPost record = (EipMPost) list.get(i);
          ALEipPost post = new ALEipPost();
          post.initField();
          post.setPostId(record.getPostId().intValue());
          post.setPostName(record.getPostName());
          post.setGroupName(record.getGroupName());
          postMap.put(record.getPostId(), post);
        }

        postsMap.put(org_id, postMap);
      } catch (Exception e) {
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   *
   */
  private void initPosition() {
    positionsMap.clear();

    String org_id = null;
    List org_list = DatabaseOrmService.getInstance().getOrgKeys();
    Iterator iter = org_list.iterator();
    while (iter.hasNext()) {
      try {
        /** 役職リスト */
        Map positionMap = new LinkedHashMap();

        org_id = (String) iter.next();
        DataContext dataContext = DataContext.createDataContext(org_id);
        SelectQuery query = new SelectQuery(EipMPosition.class);
        List list = dataContext.performQuery(query);
        int size = list.size();
        for (int i = 0; i < size; i++) {
          EipMPosition record = (EipMPosition) list.get(i);
          ALEipPosition position = new ALEipPosition();
          position.initField();
          position.setPositionId(record.getPositionId().intValue());
          position.setPositionName(record.getPositionName());
          positionMap.put(record.getPositionId(), position);
        }
        positionsMap.put(org_id, positionMap);
      } catch (Exception e) {
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   */
  public void reloadCompany() {
    String org_id = "";
    synchronized (companysMap) {
      try {
        org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
        DataContext dataContext = DatabaseOrmService.getInstance()
            .getDataContext();
        SelectQuery query = new SelectQuery(EipMCompany.class);
        List list = dataContext.performQuery(query);
        int size = list.size();
        Map companyMap = (Map) companysMap.remove(org_id);
        if (companyMap == null) {
          companyMap = new LinkedHashMap();
        } else {
          companyMap.clear();
        }
        for (int i = 0; i < size; i++) {
          EipMCompany record = (EipMCompany) list.get(i);
          ALEipCompany company = new ALEipCompany();
          company.initField();
          company.setCompanyId(record.getCompanyId().intValue());
          company.setCompanyName(record.getCompanyName());
          companyMap.put(record.getCompanyId(), company);
        }

        companysMap.put(org_id, companyMap);
      } catch (Exception e) {
        // TODO: エラー処理
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   *
   */
  public void reloadPost() {
    String org_id = "";
    synchronized (postsMap) {
      try {
        org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
        DataContext dataContext = DatabaseOrmService.getInstance()
            .getDataContext();
        SelectQuery query = new SelectQuery(EipMPost.class);
        List list = dataContext.performQuery(query);
        Collections.sort(list, new Comparator<Object>(){
          public int compare(Object l1, Object l2) {
            return ((EipMPost) l1).getPostName().compareTo(((EipMPost) l2).getPostName());
          }
        });
        int size = list.size();
        Map postMap = (Map) postsMap.remove(org_id);
        if (postMap == null) {
          postMap = new LinkedHashMap();
        } else {
          postMap.clear();
        }
        for (int i = 0; i < size; i++) {
          EipMPost record = (EipMPost) list.get(i);
          ALEipPost post = new ALEipPost();
          post.initField();
          post.setPostId(record.getPostId().intValue());
          post.setPostName(record.getPostName());
          post.setGroupName(record.getGroupName());
          postMap.put(record.getPostId(), post);
        }

        postsMap.put(org_id, postMap);
      } catch (Exception e) {
        // TODO: エラー処理
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   *
   */
  public void reloadPosition() {
    String org_id = "";
    synchronized (positionsMap) {
      try {
        org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
        DataContext dataContext = DatabaseOrmService.getInstance()
            .getDataContext();
        SelectQuery query = new SelectQuery(EipMPosition.class);
        List list = dataContext.performQuery(query);
        int size = list.size();

        Map positionMap = (Map) positionsMap.remove(org_id);
        if (positionMap == null) {
          positionMap = new LinkedHashMap();
        } else {
          positionMap.clear();
        }
        for (int i = 0; i < size; i++) {
          EipMPosition record = (EipMPosition) list.get(i);
          ALEipPosition position = new ALEipPosition();
          position.initField();
          position.setPositionId(record.getPositionId().intValue());
          position.setPositionName(record.getPositionName());
          positionMap.put(record.getPositionId(), position);
        }

        positionsMap.put(org_id, positionMap);
      } catch (Exception e) {
        // TODO: エラー処理
        logger.error("[" + org_id + ":ALEipManager]", e);
      }
    }
  }

  /**
   *
   * @return
   */
  public Map getCompanyMap() {
    synchronized (companysMap) {
      String org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
      if (!companysMap.containsKey(org_id)) {
        reloadCompany();
        if (!companysMap.containsKey(org_id)) {
          return null;
        } else {
          return (Map) companysMap.get(org_id);
        }
      }
      return (Map) companysMap.get(org_id);
    }
  }

  /**
   *
   * @return
   */
  public Map getPostMap() {
    synchronized (postsMap) {
      String org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
      if (!postsMap.containsKey(org_id)) {
        reloadPost();
        if (!postsMap.containsKey(org_id)) {
          return null;
        } else {
          return (Map) postsMap.get(org_id);
        }
      }
      return (Map) postsMap.get(org_id);
    }
  }

  /**
   *
   * @return
   */
  public Map getPositionMap() {
    synchronized (positionsMap) {
      String org_id = DatabaseOrmService.getInstance().getOrgId(getRunData());
      if (!positionsMap.containsKey(org_id)) {
        reloadPosition();
        if (!positionsMap.containsKey(org_id)) {
          return null;
        } else {
          return (Map) positionsMap.get(org_id);
        }
      }
      return (Map) positionsMap.get(org_id);
    }
  }

  protected JetspeedRunData getRunData() {
    JetspeedRunData rundata = null;
    if (this.runDataService != null) {
      rundata = this.runDataService.getCurrentRunData();
    }
    return rundata;
  }
}
