dealer.java

一个直销用的管理软件

package com.susssoft.richjl.operation;

import com.susssoft.richjl.dboperation.DBConnectionManager;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.susssoft.richjl.common.Unit;

import org.apache.log4j.Logger;
/**
 * 经销商操作的类,包含注册,修改信息的业务方法,所有测试方法在本类进行,不使用JUnit
 * @author 付祖远
 */
public class Dealer {
    private static final Logger log = Logger.getLogger(Dealer.class);
    /**
     * 得到经销商所在层次,此层次是在注册的时候确定的,根据上经经销商和推荐人来确定的,分为几种情况,
     * 1.上级经销商和推荐人编号都为-1,说明为顶级经销商,处于第一级,那么相关的下线都为第二级,所在层次2
     * 2.推荐人编号为-1,说明没有推荐人,要查询推荐人的层次,然后将查询的层次加1,从而得到注册经销商的层次
     * 3.推荐人和上级经销商编号都不为-1,这种情况和第二种情况是一样的
     * @param putuserid
     * @param upuserid
     */
    public int getDealerDiv(String putuserid,String upuserid){
        int div = 0;
        if("-1".equals(putuserid) && "-1".equals(upuserid)){
            div = 1;
        } else {
            div = getDealerDivByID(upuserid) + 1;
        }
        return div;
    }
    
    /**
     * 得到批定经销商所在的层次
     * @param dealerID
     * @return 返回层次
     */
    public int getDealerDivByID(String dealerID){
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("select div from t_userrelation where userid='" + dealerID + "'");
        int div = 0;
        try{
            while(rs.next()){
                div = rs.getInt("div");
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到指定经销商所在层次时出错:" + e);
        }
        oper.closeConn();
        return div;
    }
    
    /**
     * 判断指定的经销商下面有几个下级经销商
     * @param dealerID
     * @return 返回下级经销商的个数
     */
    public int checkDealer(String dealerID){
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT COUNT(*) AS totalCount FROM t_userrelation WHERE (upUserid = '" + dealerID + "')");
        int count = 0 ;
        try{
            while(rs.next()){
                count = rs.getInt("totalCount");
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到指定经销商下级经销商个数时出错:" + e);
        }
        oper.closeConn();
        return count;
    }
    
    /**
     * 判断指定的经销商下面的区域是否已经有经销商存在
     * @param dealerID
     * @return 返回下级经销商的个数
     */
    public boolean checkDealerArea(String dealerID,String area){
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT areaid FROM t_userrelation WHERE (upUserid = '" + dealerID + "')");
        boolean returnValue = false ;
        try{
            while(rs.next()){
            	if(area.equals(rs.getString("areaid"))){
            		returnValue = true;
            		break;
            	}
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到指定经销商下级经销商区域是否重复时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到数据库编号最大的经销商
     * @return 经销商编号
     */
    public String getDealer(){
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT Userid FROM t_usersign ORDER BY Userid DESC");
        String userID = "" ;
        try{
            while(rs.next()){
                userID = rs.getString("Userid");
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到指定经销商下级经销商个数时出错:" + e);
        }
        oper.closeConn();
        if("".equals(userID)){
            userID = Dictionary.TOPDEALERID;
        } else {
            userID = Unit.getSequenceID(userID);
        }
        return userID;
    }
    
    /**
     * 判断指定编号的经销商是否存在
     * @param dealerID 经销商编号
     * @return 如果存在返回true,否则返回false
     */
    public boolean checkDealerExists(String dealerID){
        boolean returnValue = false;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT count(*) as totalCount FROM t_usersign where Userid='" + dealerID + "'");
        try{
            while(rs.next()){
                if(rs.getInt("totalCount")!=0){
                    returnValue = true;
                }
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("判断数据库中是否有指定的经销商时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 检查经销商是否是合法的登录用户
     * @param userid 经销商编号
     * @param pwd 经销商密码
     * @return 如果有此用户则返回true,否则返回false
     */
    public boolean checkLogin(String userid,String pwd){
        boolean returnValue = false;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("select * from t_usersign where userid='" + userid + "' and pwd='" + pwd + "'");
        try{
            while(rs.next()){
                returnValue = true;
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("检查用户时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到经销商权限
     * @param dealerID 经销商编号
     * @return 经销商权限
     */
    public int getDealerPurviewByID(String dealerID){
    	 int returnValue = 0;
         DBConnectionManager oper = new DBConnectionManager();
         ResultSet rs = oper.getRs("SELECT purview FROM t_userrelation WHERE (Userid = '" + dealerID + "')");
         try{
             while(rs.next()){
             	returnValue = rs.getInt("purview");
             }
             rs.close();
         } catch (SQLException e){
             log.error("得到用户权限时出错:" + e);
         }
         oper.closeConn();
         return returnValue;
    }
    
    /**
     * 检查公司销售额表中是否有此年,此周的信息
     * @param yearNum 年
     * @param weekNum 周
     * @return 返回一个数组,一个是判断是否存在(1存在,0不存在),另一个是得到经销商总金额,最后一个是准经销商总金额
     */
    public int[] checkWeek(int yearNum,int weekNum){
        int[] returnValue = {0,0,0};
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT * FROM t_company_sale where years=" + yearNum + " and weeks=" + weekNum);
        try{
            while(rs.next()){
            	returnValue[0] = 1;
            	returnValue[1] = rs.getInt("usermoney");
            	returnValue[2] = rs.getInt("gusermoney");
            }
            rs.close();
        } catch (SQLException e){
            log.error("检查公司销售额表中是否有此年,此周的信息时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 判断经销商类型是否改变,改变只能从准经销商变为经销商
     * @param dealerID 经销商编号
     * @param dealer 经销商类别
     * @return 当返回0时,表示未改变类型,当返回1时表示由准经销商变为经销商,当返回2时表示经销商转准经销商(不合法)
     */
    public int checkDealerType(String dealerID,int dealer){
        int returnValue = 0;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT sort FROM t_usersign WHERE (Userid = '" + dealerID + "')");
        try{
            while(rs.next()){
            	if(dealer==rs.getInt("sort")){
            	    returnValue = 0;
            	} else if(dealer!=rs.getInt("sort") && rs.getInt("sort")==2){
            	    returnValue = 1;
            	} else if(dealer!=rs.getInt("sort") && rs.getInt("sort")==1){
            	    returnValue = 2;
            	} 
            }
            rs.close();
        } catch (SQLException e){
            log.error("进行经销商类型判断时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到上级经销商在folder表中的编号(自动编号产生)
     * @param updealerID 上级经销商的编号
     * @return 返回上级经销商的自动编号
     */
    public int getFolderID(String updealerID){
        int returnValue = 0;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT Folderid FROM folder WHERE (FolderName = '" + updealerID + "')");
        try{
            while(rs.next()){
            	returnValue = rs.getInt("Folderid");
            	break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到上级经销商在folder表中的编号时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到文件表中(file)某一经销商的父文件夹编号
     * @param dealerID 经销商的编号
     * @return 父文件夹的编号和名字以及文件编号
     */
    public String[] getFolderIDByFile(String dealerID){
        String[] returnValue = new String[4];
        DBConnectionManager oper = new DBConnectionManager();