forummsgadmin.java

阿菜论坛beta-1版java代码

			dbc.setBytes(1,newtopic.getBytes("GBK"));
			dbc.executeUpdate();
			
			sql="update bbs1 set boardID="+newForumID+" where rootID="+rootID;
			dbc.prepareStatement(sql);
			dbc.executeUpdate();
			
			int postNum,todayNum;
			
			sql="select count(*) from bbs1 where rootID="+rootID;
			dbc.prepareStatement(sql);
			rs=dbc.executeQuery();
			rs.next();
			postNum=rs.getInt(1);
			rs.close();
			
			sql="select count(*) from bbs1 where rootID="+rootID+" and TO_DAYS(dateandtime)=TO_DAYS(now())";
			rs=dbc.executeQuery(sql);
			rs.next();
			todayNum=rs.getInt(1);
			rs.close();
			
//'更新论坛贴子数据
			lastCount(forumID);
			forumNumSub(forumID,0,1,todayNum,dbc);
			lastCount(newForumID);
			forumNumAdd(newForumID,0,1,todayNum,dbc);
			//allForumNumSub(todayNum,1,0,dbc);



//'更新论坛数据结束

			url="dispbbs.jsp?forumID="+newForumID+"&rootID="+rootID+"&announceID="+rootID;
			sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
			dbc.prepareStatement(sql);
			dbc.setBytes(1,userName.getBytes("GBK"));
			dbc.setBytes(2,"转移主题".getBytes("GBK"));
			dbc.executeUpdate();
			dbc.close();
			ForumPropertiesManager.resetManager();
		}
		else{
			dbc.close();
			throw new Exception("请选择相应操作。");
		}
}
	//public void copyMSG() throws Exception{}
	
	public void lockMSG() throws Exception{
		sql="update bbs1 set locktopic=1 where boardID="+forumID+" and rootID="+rootID;
		DBConnect dbc=new DBConnect();
		dbc.executeUpdate(sql);
		url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"锁定帖子".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
		
	public void unlockMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set locktopic=0 where boardID="+forumID+" and rootID="+rootID;
		dbc.executeUpdate(sql);
		url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"解除锁定".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	public void topMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set istop=1 where boardID="+forumID+" and rootID="+rootID;
		dbc.executeUpdate(sql);
		url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"固顶帖子".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	public void untopMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set istop=0 where boardID="+forumID+" and rootID="+rootID;
		dbc.executeUpdate(sql);
		url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"解除固顶".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	public void bestMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set isbest=1 where boardID="+forumID+" and announceid="+announceID;
		dbc.executeUpdate(sql);
		url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"加入精华".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	public void unbestMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set isbest=0 where boardID="+forumID+" and announceid="+announceID;
		dbc.executeUpdate(sql);
		url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"解除精华".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	public void delMSG() throws Exception{
		DBConnect dbc=new DBConnect();
		sql="update bbs1 set locktopic=2 where boardID="+forumID+" and ParentID!=0 and announceid="+announceID;
		dbc.executeUpdate(sql);
		sql="select Max(announceid) from bbs1 where  locktopic!=2 and rootID="+rootID+" and boardID="+forumID;
		ResultSet rs=dbc.executeQuery(sql);
		rs.next();
		int lastPostime=rs.getInt(1);
		rs.close();
	
		int todayNum;
		sql="select count(*) from bbs1 where announceid="+announceID+" and TO_DAYS(dateandtime)=TO_DAYS(now())";
		rs=dbc.executeQuery(sql);
		rs.next();
		todayNum=rs.getInt(1);
		rs.close();
		
		lastCount(forumID);
		forumNumSub(forumID,0,1,todayNum,dbc);

		allForumNumSub(todayNum,1,0,dbc);
		
		int wealthDel=Integer.parseInt(ForumPropertiesManager.getString("wealthDel"));
		
		int epDel=Integer.parseInt(ForumPropertiesManager.getString("epDel"));
		
		int cpDel=Integer.parseInt(ForumPropertiesManager.getString("cpDel"));
				
		sql="update bbs1 set times="+lastPostime+" where rootID="+rootID+" and boardID="+forumID;
		dbc.executeUpdate(sql);
		sql="update bbs1 set child=child-1 where announceid="+rootID+" and boardID="+forumID;
		dbc.executeUpdate(sql);
	
		sql="update user set article=article-1,userWealth=userWealth-"+wealthDel+",userEP=userEP-"+epDel+",userCP=userCP-"+cpDel+"  where username=?";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		
		dbc.executeUpdate();
		url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"删除帖子".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
		ForumPropertiesManager.resetManager();
	}

	public void delTopic() throws Exception{
		DBConnect dbc=new DBConnect();
		int todayNum,postNum;
		sql="select count(*) from bbs1 where rootID="+rootID;
		ResultSet  rs=dbc.executeQuery(sql);
		rs.next();
		postNum=rs.getInt(1);
		sql="select count(*) from bbs1 where rootID="+rootID+" and     TO_DAYS(dateandtime)=TO_DAYS(now())";
		rs=dbc.executeQuery(sql);
		rs.next();
		todayNum=rs.getInt(1);
		rs.close();
		int wealthDel=Integer.parseInt(ForumPropertiesManager.getString("wealthDel"));
		
		int epDel=Integer.parseInt(ForumPropertiesManager.getString("epDel"));
		
		int cpDel=Integer.parseInt(ForumPropertiesManager.getString("cpDel"));
		sql="select username from bbs1 where rootID="+rootID;
		
		rs=dbc.executeQuery(sql);
		
		
		
		while(rs.next()){
			String tempName=rs.getString(1);
			if(tempName!=null&&!"".equals(tempName)){
			sql="update user set article=article-1,userWealth=userWealth-"+wealthDel+",userEP=userEP-"+epDel+" where username=?";
			dbc.prepareStatement(sql);
			dbc.setBytes(1,tempName.getBytes("GBK"));
			dbc.executeUpdate();
			}
		}
		
		rs.close();
		sql="update bbs1 set locktopic=2 where rootID="+rootID;
		dbc.executeUpdate(sql);
		
		lastCount(forumID);
		forumNumSub(forumID,1,postNum,todayNum,dbc);
		allForumNumSub(todayNum,postNum,1,dbc);
		
		url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
		sql="insert into log (l_username,l_content,l_url) values (?,?,'"+url+"')";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,userName.getBytes("GBK"));
		dbc.setBytes(2,"删除主题".getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
		ForumPropertiesManager.resetManager();
	}





	public void lastCount(int forumID) throws Exception{
		DBConnect dbc=new DBConnect();
		ResultSet rs=dbc.executeQuery("select topic,body,rootID,dateandtime,username from bbs1 where locktopic!=2 and boardID="+forumID+" order by announceid desc limit 0,1");
		String lastTopic,body,lastPost,lastPostUser;
		int lastRootID;
		if (rs.next()) {
			lastTopic=rs.getString(1);
			body=rs.getString(2);
			if(lastTopic==null||"".equals(lastTopic)){
				if(body.length()>14)
					lastTopic=body.substring(0,14);
				else lastTopic=body;
			}

			lastRootID=rs.getInt(3);
			lastPost=rs.getString(4);
			lastPostUser=rs.getString(5);
		}
		else{
			lastTopic="无";
			lastRootID=0;
			lastPost=Format.getDateTime();
			lastPostUser="无";
		}
		rs.close();
	
		sql="update board set lastTopic=?,lastRootID='"+lastRootID+"',lastPosttime='"+lastPost+"',lastPostuser=? where boardID="+forumID;
		dbc.prepareStatement(sql);
		dbc.setBytes(1,lastTopic.getBytes("GBK"));
		dbc.setBytes(2,lastPostUser.getBytes("GBK"));
		dbc.executeUpdate();
		dbc.close();
	}
	
	
	public void  forumNumAdd(int forumID,int topicNum,int postNum,int todayNum,DBConnect dbc) throws Exception {
		sql="update board set lastbbsnum=lastbbsnum+"+postNum+",lastTopicNum=lastTopicNum+"+topicNum+",todayNum=todayNum+"+todayNum+" where boardID="+forumID;
		dbc.executeUpdate(sql);
	}
	
	//'版面发帖数减少
	public  void forumNumSub(int forumID,int topicNum,int postNum,int todayNum,DBConnect dbc) throws Exception {
		sql="update board set lastbbsnum=lastbbsnum-"+postNum+",lastTopicNum=lastTopicNum-"+topicNum+",todayNum=todayNum-"+todayNum+" where boardID="+forumID;
		//'response.write sql
		//'response.end
		dbc.executeUpdate(sql);
	}
	
	
	//'所有论坛发帖数增加
	public void  allForumNumAdd(int todayNum,int postNum,int topicNum,DBConnect dbc) throws Exception {
		sql="update config set TodayNum=todayNum+"+todayNum+",BbsNum=bbsNum+"+postNum+",TopicNum=topicNum+"+topicNum;
		dbc.executeUpdate(sql);
	}

	//'所有论坛发帖数减少
	public void allForumNumSub(int todayNum,int postNum,int topicNum,DBConnect dbc) throws Exception{
		sql="update config set TodayNum=todayNum-"+todayNum+",BbsNum=bbsNum-"+postNum+",TopicNum=topicNum-"+topicNum;
		dbc.executeUpdate(sql);
	}


}