package com.huiton.cerp.sam;

import java.util.Vector;
import java.sql.*;

import com.huiton.pub.dbx.*;
import com.huiton.pub.lan_tools.LanTools;
import com.huiton.mainframe.util.tracer.Debug;


/**
 * Title: 系統(tǒng)管理庫信息
 * Description:  本類提供了讀取sam庫的信息接口。非sam模塊的程序應(yīng)從本類獲取sam庫的數(shù)據(jù)
 * Copyright:    Copyright (c) 2001
 * Company: 利瑪信息技術(shù)有限公司
 * @author 王濤
 * @version 1.0
 */

public class SamDbInfo {

  JdbOp dbObj;
  String errMsg="";

  public SamDbInfo() {
  try {
//System.out.println("workdir:" + System.getProperty("user.dir"));
  dbObj = new JdbOp("","sam");

  }catch (Exception e)  {
    errMsg = this.getClass().getName() + ".SamDbInfo(): " + e;
  }

  }

  /**
   * Tile: 獲取系統(tǒng)執(zhí)行的錯(cuò)誤信息
   */
  public String getErrMsg() {
    return errMsg;
  }

  /**
   * Title: 獲取用戶的名稱
   * @param userUniCode: 用戶代號(hào)
   * @return 成功時(shí)返回用戶名稱，否則返回null
   */
  public String getUserName(String userUniCode) {
    errMsg = "";
  try {
    ResultSet rst;
    String mySql = "select user_name from sam_employee where user_unique_no = " + LanTools.toSqlString(userUniCode);
    rst = dbObj.getData(mySql);
    if (rst == null)
      throw new Exception(dbObj.getErrMsg());
    if (rst.next())
      return rst.getString("user_name");
    return "無名者";
  }catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getUserName(): " + e;
    return null;
  }
  }

  /**
   * Title: 獲取程序文件名
   * @param progCode: 程序文件代號(hào)
   * @return 成功時(shí)返回程序文件名(可能為空)，否則返回null
   */
  public String getProgFileName(String progCode)  {
    errMsg = "";
  try {
    ResultSet rst;
    String mySql = "select prog_value from scg_program where prog_code = " + LanTools.toSqlString(progCode);
    rst = dbObj.getData(mySql);
    if (rst == null)
      throw new Exception(dbObj.getErrMsg());
    if (rst.next())
      return rst.getString("prog_value");
    return "";
  }catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getProgFileName(): " + e;
    return null;
  }
  }

  /**
   * 獲取父菜單索引
   * @param menuList: 菜單向量
   * @param pCode: 父菜單號(hào)
   * @param curItem: 當(dāng)前項(xiàng)的索引號(hào)
   * @return 成功時(shí)返回索引，否則返回-1
   */
  int getParentIndex(Vector menuList, String pCode,int curItem) {
    for (int i=0; i<curItem; i++) {
      MenuDef md = (MenuDef)menuList.elementAt(i);
      if (md.menuCode.equalsIgnoreCase(pCode))	{
        md.hasSubMenu = true;
        return i;
      }
    }
    return -1;
  }

  /**
   * 形成菜單。本方法循環(huán)遞歸調(diào)用以完成菜單樹的構(gòu)造
   * @param userId: 用戶代號(hào)
   * @param companyCode: 公司號(hào)
   * @return 成功時(shí)返回獲得的菜單對象向量，否則返回null
   */
  public Vector getMenu(String userId,String companyCode) {
    errMsg = "";
  try {
    int count=0;    //才單項(xiàng)的計(jì)數(shù)
    Vector menuList = new Vector();
    ResultSet rst;
    String mySql;

    //按寬度優(yōu)先取結(jié)果集
    mySql ="select * from sam_personal_menu where company_code = "+LanTools.toSqlString(companyCode);
    mySql += " and user_unique_no = " + LanTools.toSqlString(userId);
    mySql += " order by menu_level,menu_index";
    rst = dbObj.getData(mySql);
    while (rst.next())  {
      MenuDef md = new MenuDef();
      md.menuCode = rst.getString("menu_code");
      md.menuName_zh = rst.getString("menu_name_cn");
      md.menuName_en = rst.getString("menu_name_en");
      md.menuName_tw = rst.getString("menu_name_tw");
      md.level = rst.getInt("menu_level");
      int index = rst.getInt("menu_index");
      md.parentCode = rst.getString("menu_code_father");
      md.progCode = rst.getString("prog_code");
      menuList.add(md);
    }

    //處理有子標(biāo)志
    for (int i=1; i<menuList.size(); i++ )  {
      MenuDef md = (MenuDef)menuList.elementAt(i);
      getParentIndex(menuList,md.parentCode,i);    //獲取父菜單索引
    }
   return menuList;
}catch (Exception e) {
  errMsg = this.getClass().getName() + ".getMenu(): " + e;
  return null;
}
  }

  /**
   * 獲取用戶的收藏夾數(shù)據(jù)
   * @param uerId：用戶代號(hào)
   * @param companyCode: 收藏夾所屬的公司代號(hào)
   * @return 成功時(shí)返回包含收藏夾定義的向量，向量的每一個(gè)元素都是一個(gè)FavorDef類。失敗時(shí)返回null。
   * @see FavorDef
   */
  public Vector getFavor(String userId, String companyCode)  {
    errMsg = "";
  try {
    String mySql = "",progId;
    Vector vRst = new Vector();
    ResultSet pRst;

    mySql = "select * from sam_personal_favor where user_unique_no = " + LanTools.toSqlString(userId);
    mySql += " and company_code = " + LanTools.toSqlString(companyCode);
    mySql += " order by favor_level,favor_index";
    ResultSet rst = dbObj.getData(mySql);
    if (rst == null)
      return vRst;
    while (rst.next()) {
      //添加收藏項(xiàng)
      FavorDef  fd = new FavorDef();
      fd.companyCode = companyCode;
      fd.userId = userId;
      fd.sysCode = rst.getString("sys_code");
      progId = rst.getString("prog_code");
      fd.name = rst.getString("favor_name");
      fd.index = rst.getString("favor_index");
      fd.level = rst.getString("favor_level");

      mySql = "select prog_value from scg_program where prog_code=" + LanTools.toSqlString(progId);
      mySql += " and sys_code=" + LanTools.toSqlString(fd.sysCode);
      pRst = dbObj.getData(mySql);
      if (pRst.next())
        fd.progUrl = pRst.getString("prog_value");
      vRst.addElement(fd);
    }
    return vRst;

  }catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getFavor(): " + e;
    return null;
  }
  }

  /**
   * Title: 獲取部門定義信息。
   * Description: 本方法獲取指定公司的部門定義信息。
   * @param companyCode: 公司代號(hào)
   * @return 調(diào)用成功時(shí)返回一個(gè)向量，向量的每一項(xiàng)均為一個(gè)DeptDef實(shí)例
   * @see DeptDef
   */
  public Vector getDept(String companyCode) {

    errMsg = "";
//System.out.println("enter samdbinfo");
  try {
    Vector vRst = new Vector();
//System.out.println("select * from sam_dept where company_code =" + LanTools.toSqlString(companyCode));
    ResultSet rst = dbObj.getData("select * from sam_dept where company_code =" + LanTools.toSqlString(companyCode));
    while (rst.next())  {
      DeptDef dd = new DeptDef();
      dd.companyCode = companyCode;
      dd.Code = rst.getString("dept_code");
      dd.Name = rst.getString("dept_name");
      dd.parentCode = rst.getString("dept_code_father");
      dd.masterPosCode = rst.getString("master_position_code");
      vRst.add(dd);
//System.out.println(dd.companyCode);
    }

    return vRst;
}catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getDept(): " + e;
    return null;
}
  }

  /**
   * 獲取會(huì)話定義
   * @param sessionId: 要獲取的會(huì)話代號(hào)
   * @return 成功時(shí)返回SessionDef對象，否則返回null
   */
  public SessionDef getSession(String sessionId)  {
    SessionDef sd = new SessionDef();

    errMsg = "";
try {
    ResultSet rst = dbObj.getData("select * from sam_session where session_code = " + LanTools.toSqlString(sessionId));
    if (rst.next()) {

      sd.companyCode = rst.getString("company_code");
      sd.sessionId = sessionId;
      sd.year = rst.getString("year");
      sd.userId = rst.getString("user_unique_no");
      sd.loginDateTime = rst.getString("login_dateTime");

    }
    else
      errMsg = "沒有" + sessionId + "的登錄信息。";
    return sd;
}catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getSession(): " + e;
    return null;
}
  }

  /**
   * 獲取公司屬性
   * @param companyCode: 要提取屬性的公司代號(hào)
   * @return 成功時(shí)返回ComDef對象，否則返回null
   */
  public ComDef getComAtt(String companyCode) {
    errMsg = "";
try {
    ResultSet rst = dbObj.getData("select * from sam_company where company_code=" + LanTools.toSqlString(companyCode));
    if (!rst.next())
      throw new Exception("無效的公司代號(hào): " + companyCode);
    ComDef cd = new ComDef();
    cd.comCode = companyCode;
    cd.comName = rst.getString("company_name");
    cd.comParCode = rst.getString("company_code_father");
    cd.comNameEn = rst.getString("company_name_en");
    return cd;
}catch (Exception e)  {
    errMsg = this.getClass().getName() + ".getComAtt(): " + e;
    return null;
}
  }

    /**
     * 根據(jù)部門代號(hào)獲取部門名稱
     * @param deptCode: 要查詢的部門代號(hào)
     * @return 成功返回該部門的名稱，否則返回null。
     * @侯曦洋
     * @2001年12月25日
     */
    public String getDeptName(String deptCode, String companyCode)
    {
         try
         {
              errMsg = "";
              String mySql = "select dept_name from sam_dept where company_code = '" + companyCode.trim() +
                             "' and dept_code = '" + deptCode.trim() + "'" ;

              Debug.println("samDbInfo: " + mySql);
              ResultSet rst = dbObj.getData(mySql);
              if (rst == null || !rst.next())
              {
                   errMsg = "未找到部門代號(hào): " + deptCode;
                   Debug.println("samDbInfo: " + errMsg);
                   return null;
              }

              return rst.getString("dept_name");
         }
         catch (Exception e)
         {
              errMsg = this.getClass().getName()+ ".getDeptName(): " + e;
              return null;
         }
    }

    /**
     * 根據(jù)人員代號(hào)獲取部門名稱
     * @param userUniqueNo: 要查詢的人員代號(hào)
     * @return 成功返回該部門的名稱，否則返回null。
     * @侯曦洋
     * @2001年12月25日
     */
    public String getDeptNameOfUserUniqueNo(String userUniqueNo, String companyCode)
    {
         try
         {
              errMsg = "";
              String mySql = " select a.dept_name from sam_dept a, epd_address_book b where " +
                             " a.company_code = '" + companyCode.trim() + "'" +
                             " and b.user_unique_no = '" + userUniqueNo.trim() + "'"  +
                             " and a.company_code = b.company_code " +
                             " and a.dept_code = b.dept_code";

              Debug.println("samDbInfo: " + mySql);
              ResultSet rst = dbObj.getData(mySql);
              if (rst == null || !rst.next())
              {
                   errMsg = "未找到人員代號(hào): " + userUniqueNo;
                   Debug.println("samDbInfo: " + errMsg);
                   return null;
              }

              return rst.getString("dept_name");
         }
         catch (Exception e)
         {
              errMsg = this.getClass().getName()+ ".getDeptNameOfUserUniqueNo(): " + e;
              return null;
         }
    }

  /**
   * 獲取職位名稱
   * @param companyCode: 公司代號(hào)
   * @param positionCode: 職位代碼
   * @return 成功識(shí)返回與positionCode相對應(yīng)的職位名稱，否則返回null
   */
  public String getPositionName(String companyCode,String positionCode)  {
    errMsg = "";
  try {
    ResultSet rst;
    String mySql = "select  position_name from sam_position where company_code='" + companyCode + "'";
    mySql += " and position_code='" + positionCode + "'";
    rst = dbObj.getData(mySql);
    if (rst.next())
      return rst.getString("position_name");
    else  {
      errMsg = "公司" + companyCode + "不存在的職位代號(hào): " + positionCode;
      throw new Exception(errMsg);
    }
  }catch (Exception e)  {
    e.printStackTrace();
    errMsg = "SamDbInfo.getPositionName: " + e;
    return null;
  }
  }

  /**
   * 返回指定部門的定義
   * @param companyCode 部門所屬的公司代號(hào)
   * @param deptCode  部門代號(hào)
   * @return  成功時(shí)返回部門定義對象，否則返回null
   */
  public DeptDef getDeptDef(String companyCode, String deptCode)  {
    errMsg = "";
    Debug.println("獲取部門定義...");
  try {
    String mySql = "select * from sam_dept where company_code='" + companyCode + "'";
    mySql += " and dept_code='" + deptCode + "'";
    Debug.println("SamDbInfo: " + mySql);
    ResultSet rst = dbObj.getData(mySql);
    if (rst.next())  {
      DeptDef dd = new DeptDef();
      dd.companyCode = companyCode;
      dd.Code = rst.getString("dept_code");
      dd.Name = rst.getString("dept_name");
      dd.parentCode = rst.getString("dept_code_father");
      dd.masterPosCode = rst.getString("master_position_code");

      return dd;
//System.out.println(dd.companyCode);
    }
    errMsg = "SamDbInfo.getDept: 未能找到部門代號(hào)--" + deptCode;
    System.out.println("errMsg");
    return null;
  }catch (Exception e)  {
    e.printStackTrace();
    errMsg = "" + e;
    return null;
  }
  }

  /**
   * 獲得幣種名稱
   * @param currencyCode    幣種定義代碼
   * @param companyCode     公司代碼
   * @return  成功時(shí)返回名稱，否則返回null
   */
  public String getCurrency(String currencyCode,String companyCode)
  {
    String sql="";
    sql="select currency_name from sam_currency where company_code='"+companyCode+"'";
    sql+=" and currency_code='"+currencyCode+"'";
    String currency="";
    try{
      ResultSet rs=dbObj.getData(sql);
      if(rs.next())
      {
        currency=rs.getString(1);
      }
      return currency;
    }
    catch(Exception e)
    {
      System.out.println("類com.huiton.cerp.sam.samDbInfo的getCurrency方法出錯(cuò)"+e);
      return null;
    }
  }

}