dealer.java

一个直销用的管理软件

        ResultSet rs = oper.getRs("SELECT * FROM [file] WHERE (FileName = '" + dealerID + "')");
        try{
            while(rs.next()){
                returnValue[0] = String.valueOf(rs.getInt("Fileid"));
            	returnValue[1] = String.valueOf(rs.getString("FileFolderID"));
            	returnValue[2] = rs.getString("FileDescription");
            	returnValue[3] = rs.getString("FileFalseName");
            	break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到文件表中(file)某一经销商的父文件夹编号编号时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到文件夹中(folder)某一经销商的的文件夹编号
     * @param dealerID 经销商的编号
     * @return 父文件夹的编号和名字以及文件编号
     */
    public String[] getFolderIDByFolder(String dealerID){
        String[] returnValue = new String[3];
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT * FROM [folder] WHERE (FolderName = '" + dealerID + "')");
        try{
            while(rs.next()){
                returnValue[0] = String.valueOf(rs.getInt("FolderName"));
            	returnValue[1] = String.valueOf(rs.getString("Folderid"));
            	returnValue[2] = rs.getString("FolderDescription");
            	break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到文件表中(file)某一经销商的父文件夹编号编号时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 经销商注册方法,包含一个事务,此方法独立出来
     * @param operStr 传入的语句
     * 返回执行的条数
     */
    public int dealerRegister(String[] operStr,String upuserid,String dealerid,String name){
        DBConnectionManager newoper = new DBConnectionManager();
        Connection newconn = newoper.getConn();
        int returnValue = 0;
        try{
            Statement newstmt = newconn.createStatement();
            newconn.setAutoCommit(false);
            for(int i=0;i<operStr.length;i++){
                returnValue = returnValue + newstmt.executeUpdate(operStr[i]);
            }
            
            //得到上级经销商在folder表中的编号,此句放在此处执行,是因为要得到父级编号,这样程序的重用性会大大降低,此处属于将来程序优化的重点部分
            int folderId = getFolderID(upuserid);
    		String dealerOper = "insert into [file](FileName,FileFolderID,FileDescription) values('" + dealerid + "'," + folderId + ",'" + name + "')";
    		returnValue = returnValue + newstmt.executeUpdate(dealerOper);
    		
    		newconn.commit();
    		newstmt.close();
    		newconn.close();
        } catch(SQLException e){
            log.error("进行数据库操作的时候出错(含事务处理,位于经销商处理类):" + e);
        }
        return returnValue;
    }
    
    /**
     * 检查文件表或文件夹表中是否有指定经销商编号
     * @param dealerid 经销商
     * @return 返回true,和false
     */
    public boolean checkFileTable(String dealerid,String tableName,String fieldName){
    	boolean returnValue = false;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT * FROM [" + tableName + "] WHERE (" + fieldName + " = '" + dealerid + "')");
        try{
            while(rs.next()){
                returnValue = true;
            	break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("检查文件表或文件夹表中是否有指定经销商编号时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 根据区域得到区域的颜色
     * @param area 区域名
     * @return 颜色值
     */
    public String getAreaColor(String areaid){
    	String returnValue = "";
    	if(areaid.equals("A")){
    		returnValue = "#FF0000";
		} else if(areaid.equals("B")){
			returnValue = "#0000FF";
		} else if(areaid.equals("C")){
			returnValue = "#FFFF00";
		} else if(areaid.equals("D")){
			returnValue = "#FF00FF";
		} else {
			returnValue = "#666699";
		}
    	return returnValue;
    }
    
    /**
     * 得到树的第二起始ID
     * @param dealerID
     * @return 返回编号
     */
    public int[] getTreeID(String dealerID){
    	int returnValue[] = {0,1};
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("select * from folder WHERE FolderName = '" + dealerID + "'");
        try{
            while(rs.next()){
            	returnValue[0] = rs.getInt("FolderParentID");
            	returnValue[1] = rs.getInt("div");
            	break;
            }
            rs.close();
            
            rs = oper.getRs("select * from [file] WHERE FileName = '" + dealerID + "'");
            while(rs.next()){
            	returnValue[0] = rs.getInt("FileFolderID");
            	returnValue[1] = rs.getInt("div");
            	break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到树的第二起始ID时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到经销商的上级经销商编号
     * @param dealerID 经销商编号
     * @return 上级经销商编号
     */
    public String getUpDealerID(String dealerID){
    	String returnValue = "";
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT upuserid FROM v_user where userid='" + dealerID + "'");
        try{
            while(rs.next()){
                returnValue = rs.getString("upuserid");
                break;
            }
            rs.close();
        } catch (SQLException e){
            log.error("得到经销商的上级经销商编号时出错:" + e);
        }
        oper.closeConn();
        return returnValue;
    }
    
    /**
     * 得到所有经销商列表
     * @return 返回经销商列表
     */
    public List getDealerList(){
        List list = new ArrayList();
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("select userid from t_usersign");
        try{
            while(rs.next()){
                list.add(rs.getString("userid"));
            }
        } catch (SQLException e){
            log.error("得到经销商编号列表时出错:" + e);
        }
        return list;
    }
    
    /**
     * 根据经销商编号得到经销商的信息
     * @param dealerid
     * @return
     */
    public List getDealerInfo(String dealerid){
        List list = new ArrayList();
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("SELECT * FROM v_user where userid='" + dealerid + "'"); 
        try{
            while(rs.next()){
                list.add(rs.getString("name"));
            	list.add(rs.getString("bank"));
            	String bankcard = rs.getString("bankcard");
            	String opencard = rs.getString("opencard");
            	int sort = rs.getInt("sort");
            	//两者之间肯定有一个不为空
            	if(bankcard.equals("")){
            	    list.add(opencard);
            	} else {
            	    list.add(bankcard);
            	}
            	if(sort==1){
            		list.add("经销商");
            	} else {
            		list.add("准经销商");
            	}
            }
            rs.close();
        } catch (SQLException e){
            log.error("根据经销商编号得到经销商信息时出错:" + e);
        }
        return list;
    }
    
    /**
     * 根据年份，月份，经销商的编号来判断重复消费表中是否已经有记录了
     * @param dealerid  经销商编号
     * @param years 年份
     * @param months　月份
     * @return 返回一个布尔类型的值，如果是true,则说明此经销商已经重复消费了，无法再次重复消费，如果是false，则说明此经销商没有重复消费，可以
     * 添加记录
     */
    public boolean checkRepeatConsume(String dealerid,int years,int months){
        boolean returnValue = false;
        DBConnectionManager oper = new DBConnectionManager();
        ResultSet rs = oper.getRs("select * from t_UserRepeatConsume where ConsumeUserid='" + dealerid + "' and years=" + years + " and months=" + months);
        try{
            while(rs.next()){
                returnValue = true;
            }
        } catch (SQLException e){
            log.error("判断重复消费表中是否已经有记录:" + e);
        }
        return returnValue;
    }
    
    /**
     * 检查日期是否已经超过限定日期
     * @param exceedDate 要检查的日期
     * @param type 检查类型,分为查天和查月,即是否超过一天,是否超过一月
     * @return 如果超过为true,否则为false
     */
    public boolean checkDateExceed(String exceedDate,String type){
    	boolean returnValue = false;
    	//得到月,日
    	String newDate = Unit.getTrimDateNoTimer(exceedDate);
    	String[] temp = newDate.split("-");
    	int month = Integer.parseInt(temp[1]);
    	int day = Integer.parseInt(temp[2]);
    	
    	//得到当前时间
    	String currentDate = Unit.getCurrentTimer();
    	String[] currentTemp = newDate.split("-");
    	int currentMonth = Integer.parseInt(currentTemp[1]);
    	int currentDay = Integer.parseInt(currentTemp[2]);
    	if(type.equals("day")){
    		if(currentDay-day>=1){
    			returnValue = true;
    		}
    	} else if(type.equals("month")){
    		if(currentMonth - month>=1){
    			returnValue = true;
    		}
    	}
    	return returnValue;
    }
    
    public static void main(String[] args) {
        Dealer dealer = new Dealer();
        //System.out.println(dealer.getDealerDiv("001001","001000"));
        int[] test = dealer.getTreeID("00000081");
        System.out.println(test[1]);
    }
}