clubmessage.java

GamVan Club v1.1 源代码

                cmSendUser = rs.getString(2);
                cmTakeUser = rs.getString(3);
                cmTopic = rs.getString(4);
                cmTopic = es.htmlEncoder(cmTopic);
                cmContent = rs.getString(5);
                cmContent = es.htmlEncoder(cmContent);
                cmContent = es.ubbEncoder(cmContent);
                cmAddTime = rs.getString(7);
                cmAddTime = cmAddTime.replace(".0","");
                cmIsTake = rs.getInt(8);
                cmOrder = rs.getInt(9);
                cmReID = rs.getInt(10);
                cmSendID = rs.getInt(11);
                cmTakeID = rs.getInt(12);
                bea = true;
            }
            rs.close();
            pps.close();
        }catch(Exception e){
            con.close();
            message = e.toString();
        }finally{
            con.close();
        }
        return bea;
    }
    public boolean clubMessage(String uNames) throws Exception{
        uNames = clubgb.gb(uNames);
        cmTopic = clubgb.gb(cmTopic);
        cmContent = clubgb.gb(cmContent);
        boolean bea = false;
        int count = 0;
        ClubUsers cu = new ClubUsers();
        StringTokenizer st = new StringTokenizer(uNames,",");
        String[] uName = new String[st.countTokens()];
        if(uNames.equals("")||cmTopic.equals("")){
            message = "用户名、标题不能为空。";
            return false;
        }
        try{
            for(int i=0;st.hasMoreTokens();i++){ //提取用户名
                uName[i] = st.nextToken().trim();
                if(cu.userSelect(uName[i])){ //判断短消息接收ID是否为注册用户
                    cmTakeID = cu.getUserID();
                    switch(isPost){
                        case 0:     //直接发送
                            cmAddTake(uName[i]); 
                            break;
                        case 1:     //发件箱保留副本
                             cmAddSend(uName[i]); 
                             cmAddTake(uName[i]);
                             break;
                        case 2:     //草稿箱不发送
                             cmIsSend = 0;
                             cmAddSend(uName[i]);
                             break;
                    } 
                    count ++;
                }else{
                    message+= uName[i] + " 不是注册用户发送失败！<br>";
                }
            }
             message += String.valueOf(count) + " 条短消息发送成功！<br>";
        }catch(Exception e){
            message = e.toString();
        }
        return bea;        
    }
    public boolean cmAddSend(String uName) throws Exception{
        boolean bea = false;
        Connection con = bridge.getConnection();
        StringBuffer sqlCommand = new StringBuffer("");
        try{
            sqlCommand.append("Insert Into GVclubMessageSend(cmSendUser, cmTakeUser");
            sqlCommand.append(", cmTopic, cmContent, cmUserIp, cmAddTime, cmIsSend, cmOrder,cmReID, cmSendID, cmTakeID)");
            sqlCommand.append(" Values(?,?,?,?,?,?,?,?,?,?,?)");
            PreparedStatement pps = con.prepareStatement(sqlCommand.toString());
            pps.setString(1, cmSendUser);
            pps.setString(2, uName);
            pps.setString(3, cmTopic);
            pps.setString(4, cmContent);
            pps.setString(5, cmUserIp);
            pps.setString(6, now);
            pps.setInt(7 ,cmIsSend);
            pps.setInt(8, cmOrder); 
            pps.setInt(9, cmReID); 
            pps.setInt(10, cmSendID);
            pps.setInt(11, cmTakeID);
            pps.executeUpdate();
            bea = true;
        }catch(Exception e){
            message = "发件箱数据存储失败！";
            con.close();
        }finally{
            con.close();
        }
        return bea;
    }
    public boolean cmAddTake(String uName) throws Exception{
        boolean bea = false;
        Connection con = bridge.getConnection();
        StringBuffer sqlCommand = new StringBuffer("");
        try{
            sqlCommand.append("Insert Into GVclubMessageTake(cmTakeUser, cmSendUser");
            sqlCommand.append(", cmTopic, cmContent, cmUserIp, cmAddTime, cmIsTake, cmOrder, cmReID, cmSendID, cmTakeID)");
            sqlCommand.append(" Values(?,?,?,?,?,?,?,?,?,?,?)");
            PreparedStatement pps = con.prepareStatement(sqlCommand.toString());
            pps.setString(1, uName);
            pps.setString(2, cmSendUser);
            pps.setString(3, cmTopic);
            pps.setString(4, cmContent);
            pps.setString(5, cmUserIp);
            pps.setString(6, now);
            pps.setInt(7, 0); //直接更新为未接收。
            pps.setInt(8, cmOrder);
            pps.setInt(9, cmReID); 
            pps.setInt(10, cmSendID);
            pps.setInt(11, cmTakeID);
            pps.executeUpdate();
            bea = true;
        }catch(Exception e){
            message = "收件箱数据存储失败！";
            con.close();
        }finally{
            con.close();
        }
        return bea;
    }
    public void setTakeUser(String cmTakeUser){
        this.cmTakeUser = cmTakeUser;
    }
    public String getTakeUser(){
        return this.cmTakeUser;
    }
    public void setSendUser(String cmSendUser){
        this.cmSendUser = cmSendUser;
    }
    public String getSendUser(){
        return this.cmSendUser;
    }
    public void setTopic(String cmTopic){
        if(cmTopic==null){
            this.cmTopic="";
        }else{
           this.cmTopic = cmTopic; 
        }        
    }
    
    public void setSendID(int cmSendID){
        this.cmSendID = cmSendID;
    }
    public void setTakeID(int cmTakeID){
        this.cmTakeID = cmTakeID;
    }
    public int getSendID(){
        return this.cmSendID;
    }
    public int getTakeID(){
        return this.cmTakeID;
    }
    
    public String getTopic(){
        this.cmTopic = es.htmlEncoder(cmTopic);    
        return this.cmTopic;
    }
    public void setContent(String cmContent){
        if(cmContent==null){
            this.cmContent = "";
        }else{
            this.cmContent = cmContent;
        }
    }
    public String getContent(){
        this.cmContent = es.htmlEncoder(cmContent);
        this.cmContent = es.ubbEncoder(cmContent);
        return this.cmContent;
    }
    public void setUserIp(String cmUserIp){
        this.cmUserIp = cmUserIp;
    }
    public String getUserIp(){
        return this.cmUserIp;
    }
    public String getAddTime(){
        return this.cmAddTime;
    }
    public void setIsTake(int cmIsTake){
       this.cmIsTake = cmIsTake;
    }
    public int getIsTake(){
        return this.cmIsTake;
    }
    public void setIsSend(int cmIsSend){
        this.cmIsSend = (cmIsSend);
    }
    public int getIsSend(){
        return this.cmIsSend;
    }
    public void setOrder(int cmOrder){
        this.cmOrder = (cmOrder);
    }
    public String getMessage(){
        return this.message;
    }
    public void setIsPost(String isPost){
        if(isPost!=null){
            this.isPost = Integer.parseInt(isPost);
        }else{
            this.isPost = 0;
        }
    }
    public void setReID(int reID){
        this.cmReID = reID;
    }
    public int getCmID(){
        return this.cmID;
    }
    public int getCmReID(){
        return this.cmReID;
    }
}