开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 电子书籍 > Java书籍 > 查看源码
ForumAdmin.java
资源名称：第4章 BBS论坛系统.rar　[点击查看]
上传用户：yuyunping
上传日期：2013-03-21
资源大小：1844k
文件大小：15k
源码类别：

Java书籍

开发平台：

Java

ForumAdmin.java：源码内容
  1. package net.acai.forum.admin;
  2. /**
  3.  * Title:        清清网络
  4.  * Description:
  5.  * Copyright:    Copyright (c) 2002
  6.  * Company:      www.SuperSpace.com
  7.  * @author:       SuperSpace
  8.  * @version 1.0
  9.  */
  10. import net.acai.forum.*;
  11. import net.acai.database.*;
  12. import javax.servlet.http.*;
  13. import java.sql.*;
  14. import net.acai.util.*;
  15. public class ForumAdmin{
  16. public ForumAdmin(){}
  18. //////////////////////////////////save mod/////////////
  19. public void saveMod(HttpServletRequest request) throws Exception{
  20. int forumID;
  21. try{
  22. forumID=ParamUtil.getInt(request,"forumID");
  23. }
  24. catch(Exception e){
  25. throw new Exception("对不起，请您选定您想要修改的论坛ID");
  26. }
  27. int forumSkin;
  28. try{
  29. forumSkin=ParamUtil.getInt(request,"forumSkin");
  30. }
  31. catch(Exception e){
  32. throw new Exception("对不起，请您选定论坛的类别！");
  33. }
  34. Forum theForum=ForumFactory.getForum(forumID);
  35. if(theForum==null)
  36. throw new  Exception("错误的论坛");
  37. if(theForum.getForumSkin()==forumSkin)
  38. return;
  40. String forumUser_1="";
  41. if(forumSkin==5){
  42. String vipuser=ParamUtil.getString(request,"vipuser");
  43. if(vipuser!=null&&!"".equals(vipuser.trim())){
  44. String [] forumUser=vipuser.split("\n|\r");
  46. for(int i=0;i<forumUser.length;i++){
  47. if(!"".equals(forumUser_1)){
  48. if(i!=forumUser.length-1)
  49. forumUser_1+=forumUser[i]+",";
  50. else
  51. forumUser_1+=forumUser[i];
  52. }
  53. }
  54. }
  55. }
  56. DBConnect dbc=new DBConnect("update bbs.board set boardUser=?,boardskin=? where boardID=?");
  57. dbc.setBytes(1,(new String(forumUser_1.getBytes("ISO-8859-1"),"GBK")).getBytes());
  58. dbc.setInt(2,forumSkin);
  59. dbc.setInt(3,forumID);
  60. dbc.executeUpdate();
  61. dbc.close();
  62. }
  64. public static void saveNew(HttpServletRequest request) throws  Exception{
  65. String forumType=ParamUtil.getString(request,"boardtype");
  66. if(forumType==null||"".equals(forumType.trim()))
  67. throw new Exception("请输入论坛名称。");
  68. int classID;
  69. try{
  70. classID=ParamUtil.getInt(request,"class");
  71. }
  72. catch(Exception e){
  73. throw new Exception("请选择论坛分类。");
  74. }
  75. String forumMaster=ParamUtil.getString(request,"boardmaster","");
  76. /*if(forumMaster==null||"".equals(forumMaster.trim()))
  77. throw new Exception("请输入版主姓名。");
  78. */
  79. String readme=ParamUtil.getString(request,"readme");
  80. if(readme==null||"".equals(readme.trim()))
  81. throw new Exception("请输入论坛说明。");
  82. int lockForum;
  83. try{
  84. lockForum=ParamUtil.getInt(request,"lockboard");
  85. }
  86. catch(Exception e){
  87. throw new Exception("请选择论坛开放状态。");
  88. }
  89. DBConnect dbc=new DBConnect();
  90. String sql="insert into bbs.board(boardtype,class,boardmaster,readme,lockboard,tableback,tabletitle,ntablebody,atablebody,tablefont,tablecontent,alertfont,forumlogo,indeximg,nstrallowforumcode,strallowhtml,strimginposts,stricons,strflash,lastpostuser,nlastposttime,lastbbsnum,lasttopicnum)n values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,getdate(),?,?)";
  91. dbc.prepareStatement(sql);
  92. dbc.setBytes(1,(new String(forumType.getBytes("ISO-8859-1"),"GBK")).getBytes());
  93. dbc.setInt(2,classID);
  94. dbc.setBytes(3,(new String(forumMaster.getBytes("ISO-8859-1"),"GBK")).getBytes());
  95. dbc.setBytes(4,(new String(readme.getBytes("ISO-8859-1"),"GBK")).getBytes());
  96. dbc.setInt(5,lockForum);
  97. dbc.setString(6,ParamUtil.getString(request,"Tableback",""));
  98. dbc.setString(7,ParamUtil.getString(request,"Tabletitle",""));
  99. dbc.setString(8,ParamUtil.getString(request,"Tablebody",""));
  100. dbc.setString(9,ParamUtil.getString(request,"aTablebody",""));
  101. dbc.setString(10,ParamUtil.getString(request,"TableFont",""));
  102. dbc.setString(11,ParamUtil.getString(request,"TableContent",""));
  103. dbc.setString(12,ParamUtil.getString(request,"AlertFont",""));
  104. dbc.setString(13,ParamUtil.getString(request,"Logo",""));
  105. dbc.setString(14,ParamUtil.getString(request,"indeIMG",""));
  106. dbc.setString(15,ParamUtil.getString(request,"strAllowForumCode",""));
  107. dbc.setString(16,ParamUtil.getString(request,"strAllowHTML",""));
  108. dbc.setString(17,ParamUtil.getString(request,"strIMGInPosts",""));
  109. dbc.setString(18,ParamUtil.getString(request,"strIcons",""));
  110. dbc.setString(19,ParamUtil.getString(request,"strflash",""));
  111. dbc.setBytes(20,(new String(("未知").getBytes("ISO-8859-1"),"GBK")).getBytes());
  112. dbc.setInt(21,0);
  113. dbc.setInt(22,0);
  114. dbc.executeUpdate();
  115. if(forumMaster!=null&&!("".equals(forumMaster.trim())))
  116. addMaster(forumMaster,dbc);
  118. dbc.close();
  119. }
  120. public static void saveEdit(HttpServletRequest request) throws Exception{
  121. //System.out.println("asdf");
  122. int editID;
  123. try{
  124. editID=ParamUtil.getInt(request,"editid");
  125. }
  126. catch(Exception e){
  127. throw new Exception("请选择编辑论坛的ID。");
  128. }
  129. int newforumID;
  130. try{
  131. newforumID=ParamUtil.getInt(request,"newforumID");
  132. }
  133. catch(Exception e){
  134. throw new Exception("请填写新论坛的ID。");
  135. }
  136. if (newforumID!=editID) {
  137. Forum tempForum=ForumFactory.getForum(newforumID);
  138. if(tempForum!=null)
  139. throw new Exception("您不能指定和别的论坛一样的序号。");
  140. }
  141. String forumType=ParamUtil.getString(request,"boardtype");
  142. if(forumType==null||"".equals(forumType.trim()))
  143. throw new Exception("请输入论坛名称。");
  144. int classID;
  145. try{
  146. classID=ParamUtil.getInt(request,"class");
  147. }
  148. catch(Exception e){
  149. throw new Exception("请选择论坛分类。");
  150. }
  151. String forumMaster=ParamUtil.getString(request,"boardmaster","");
  152. /*if(forumMaster==null||"".equals(forumMaster.trim()))
  153. throw new Exception("请输入版主姓名。");*/
  155. String readme=ParamUtil.getString(request,"readme");
  156. if(readme==null||"".equals(readme.trim()))
  157. throw new Exception("请输入论坛说明。");
  158. int lockForum;
  159. try{
  160. lockForum=ParamUtil.getInt(request,"lockboard");
  161. }
  162. catch(Exception e){
  163. throw new Exception("请选择论坛开放状态。");
  164. }
  165. String sql="update bbs.board set boardtype=?,class=?,boardmaster=?,readme=?,lockboard=?,tableback=?,n tabletitle=?,tablebody=?,atablebody=?,tableFont=?,tablecontent=?,alertfont=?,n forumlogo=?,indexIMG=?,strAllowForumCode=?,strAllowHTML=?,strIMGInPosts=?,n strIcons=?,strflash=? n where bbs.board.boardid=?";
  166. DBConnect dbc=new DBConnect();
  167. dbc.prepareStatement(sql);
  169. dbc.setBytes(1,(new String(forumType.getBytes("ISO-8859-1"),"GBK")).getBytes());
  170. dbc.setInt(2,classID);
  171. dbc.setBytes(3,(new String(forumMaster.getBytes("ISO-8859-1"),"GBK")).getBytes());
  172. dbc.setBytes(4,(new String(readme.getBytes("ISO-8859-1"),"GBK")).getBytes());
  173. dbc.setInt(5,lockForum);
  174. dbc.setString(6,ParamUtil.getString(request,"Tableback",""));
  175. dbc.setString(7,ParamUtil.getString(request,"Tabletitle",""));
  176. dbc.setString(8,ParamUtil.getString(request,"Tablebody",""));
  177. dbc.setString(9,ParamUtil.getString(request,"aTablebody",""));
  178. dbc.setString(10,ParamUtil.getString(request,"TableFont",""));
  179. dbc.setString(11,ParamUtil.getString(request,"TableContent",""));
  180. dbc.setString(12,ParamUtil.getString(request,"AlertFont",""));
  181. dbc.setString(13,ParamUtil.getString(request,"Logo",""));
  182. dbc.setString(14,ParamUtil.getString(request,"indeIMG",""));
  183. dbc.setString(15,ParamUtil.getString(request,"strAllowForumCode",""));
  184. dbc.setString(16,ParamUtil.getString(request,"strAllowHTML",""));
  185. dbc.setString(17,ParamUtil.getString(request,"strIMGInPosts",""));
  186. dbc.setString(18,ParamUtil.getString(request,"strIcons",""));
  187. dbc.setString(19,ParamUtil.getString(request,"strflash",""));
  188. dbc.setInt(20,editID);
  189. dbc.executeUpdate();
  190. sql="update bbs.bbs1 set boardid="+newforumID+" where boardid="+editID;
  191. dbc.executeUpdate(sql);
  192. if(forumMaster!=null&&!("".equals(forumMaster.trim())))
  193. addMaster(forumMaster,dbc);
  194. dbc.close();
  195. }
  196. public static void del(HttpServletRequest request) throws Exception{
  197. int forumID;
  198. try{
  199. forumID=ParamUtil.getInt(request,"boardid");
  200. }
  201. catch(Exception e){
  202. throw new Exception("请您选择您要修改的论坛ID");
  203. }
  204. String sql="delete from bbs.board where boardid="+forumID;
  205. DBConnect dbc=new DBConnect(sql);
  206. dbc.executeUpdate();
  207. sql="delete from bbs.bbs1 where boardid="+forumID;
  208. dbc.executeUpdate(sql);
  209. dbc.close();
  210. }
  211. public static void dell(HttpServletRequest request) throws Exception{
  212. int ID;
  213. try{
  214. ID=ParamUtil.getInt(request,"id");
  215. }
  216. catch(Exception e){
  217. throw new Exception("请您选择您要删除的分类的ID");
  218. }
  219. DBConnect dbc=new DBConnect();
  220. String sql = "delete from bbs.class where id="+ID;
  221. dbc.executeUpdate(sql);
  222. sql = "delete from bbs.board where class="+ID;
  223. dbc.executeUpdate(sql);
  224. sql="select boardid from bbs.board where class="+ID;
  225. ResultSet rs=dbc.executeQuery(sql);
  226. while(rs.next()){
  227. sql="delete from bbs.bbs1 where boardid="+rs.getInt(1);
  228. dbc.executeUpdate(sql);
  229. }
  230. dbc.close();
  231. }
  232. public static void updateOrders(HttpServletRequest request) throws Exception{
  233. int newID;
  234. try{
  235. newID=ParamUtil.getInt(request,"newid");
  237. }
  238. catch(Exception e){
  239. throw new Exception("请您选择您想要更新的类别!");
  240. }
  241. int ID;
  242. try{
  243. ID=ParamUtil.getInt(request,"id");
  245. }
  246. catch(Exception e){
  247. throw new Exception("请您选择您想要更新的类别!");
  248. }
  250. if(newID==ID)
  251. return;
  252. DBConnect dbc=new DBConnect();
  253. String sql="select * from bbs.class where id="+newID;
  254. ResultSet rs=dbc.executeQuery(sql);
  255. if(rs.next())
  256. throw new Exception("您输入的序号和其他分类序号相同，请重新输入。");
  257. sql="update bbs.class set id="+newID+",class=? where id="+ID;
  258. dbc.prepareStatement(sql);
  259. dbc.setBytes(1,(new String(ParamUtil.getString(request,"classname","").getBytes("ISO-8859-1"),"GBK")).getBytes());
  260. dbc.executeUpdate();
  261. sql="update bbs.board set class="+newID+" where class="+ID;
  262. dbc.executeUpdate(sql);
  263. sql="update bbs.board set class="+newID+" where class="+ID;
  264. dbc.executeUpdate(sql);
  265. dbc.close();
  266. }
  267. public static void saveClass(HttpServletRequest request) throws Exception{
  268. String classname=ParamUtil.getString(request,"classname");
  269. if(classname==null)
  270. throw new Exception("请您输入您想添加分类的名字！");
  271. String sql="insert into bbs.class(class) values(?)";
  272. DBConnect dbc=new DBConnect(sql);
  273. dbc.setBytes(1,(new String(classname.getBytes("ISO-8859-1"),"GBK")).getBytes());
  274. dbc.executeUpdate();
  275. dbc.close();
  276. }
  277. public String update() throws Exception{
  278. String sql="select boardid,boardtype from bbs.board";
  279. DBConnect dbc1=new DBConnect(sql);
  280. ResultSet rs=dbc1.executeQuery();
  281. StringBuffer sb=new StringBuffer();
  282. if(!rs.next()){
  283. dbc1.close();
  284. throw new Exception("论坛还没有版面，请先添加版面。");
  285. }
  286. // temprs;
  287. DBConnect dbc=new DBConnect();
  288. String newuser=newuser(dbc);
  289. do{
  291. sql="Select count(announceid) from bbs.bbs1 where boardid="+rs.getInt(1);
  292. ResultSet temprs=dbc.executeQuery(sql);
  294. temprs.next();
  295. String tempString=temprs.getString(1);
  296. int allArticle=(tempString==null)?0:temprs.getInt(1);
  298. temprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 where boardid="+rs.getInt(1) +" and parentID=0");
  299. temprs.next();
  300. tempString=temprs.getString(1);
  301. int allTopic=(tempString==null)?0:temprs.getInt(1);
  303. ResultSet ers=dbc.executeQuery("select Max(announceid) from bbs.bbs1 where boardid="+rs.getInt(1));
  304. ers.next();
  305. tempString=ers.getString(1);
  307. //int maxID=(tempString==null)?"无":ers.getInt(1);
  308. String userName,dateandtime;
  311. if(tempString==null){
  312. userName="无";
  313. dateandtime=Format.getDateTime();
  314. }
  315. else {
  316. int maxID=ers.getInt(1);
  317. ers=dbc.executeQuery("select username,dateandtime from bbs.bbs1 where announceid="+maxID);
  318. ers.next();
  319. userName=ers.getString(1);
  320. dateandtime=ers.getString(2);
  321. }
  323. sql="update bbs.board set lastpostuser=?,lastposttime='"+dateandtime+"',lastbbsnum="+allArticle+",lasttopicnum="+allTopic+",TodayNum="+todays(rs.getInt(1),dbc)+" where boardid="+rs.getInt(1);
  324. dbc.prepareStatement(sql);
  325. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  326. dbc.executeUpdate();
  327. sb.append("更新论坛数据成功，"+rs.getString(2)+"共有"+allArticle+"篇贴子，"+allTopic+"篇主题，今日有"+todays(rs.getInt(1),dbc)+"篇帖子。<br>");
  328. }
  329. while(rs.next());
  330. sql="update bbs.config set TopicNum="+titlenum(dbc)+",BbsNum="+gettipnum(dbc)+",TodayNum="+alltodays(dbc)+",UserNum="+allusers(dbc)+",lastUser=?";
  331. dbc.prepareStatement(sql);
  332. dbc.setBytes(1,(new String(newuser.getBytes("ISO-8859-1"),"GBK")).getBytes());
  333. dbc.executeUpdate();
  334. dbc.close();
  335. dbc1.close();
  336. ForumPropertiesManager.resetManager();
  337. return sb.toString();
  339. }
  341. public int  todays(int boardid,DBConnect dbc) throws Exception{
  342. ResultSet tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where  day(dateandtime)=day(getdate()) and boardid="+boardid);
  343. tmprs.next();
  344. String tempString=tmprs.getString(1);
  345. int temp=(tempString==null)?0:tmprs.getInt(1);
  346. return temp;
  347. }
  348. public int alltodays(DBConnect dbc) throws Exception{
  349.      ResultSet tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where  day(dateandtime)=day(getdate())");
  350. tmprs.next();
  351. String tempString=tmprs.getString(1);
  352. int temp=(tempString==null)?0:tmprs.getInt(1);
  353. return temp;
  355. }
  356. public int  allusers(DBConnect dbc) throws Exception{
  357.      ResultSet tmprs=dbc.executeQuery("Select count(userid) from bbs.myuser");
  358.      tmprs.next();
  359. String tempString=tmprs.getString(1);
  360. int temp=(tempString==null)?0:tmprs.getInt(1);
  361. return temp;
  362. }
  363. public  String newuser(DBConnect dbc) throws Exception{
  364. ResultSet tmprs=dbc.executeQuery("Select  username from bbs.myuser order by userid desc");
  365. String newuser;
  366. if(!tmprs.next()){
  367. newuser="没有会员";
  368. }
  369. else{
  370. //tmprs.next();
  371. newuser=tmprs.getString(1);
  372. }
  373. return newuser;
  374. }
  375. public int  gettipnum(DBConnect dbc) throws Exception{
  376.      ResultSet tmprs=dbc.executeQuery("Select Count(announceID) from bbs.bbs1");
  377.      tmprs.next();
  378. String tempString=tmprs.getString(1);
  379. int temp=(tempString==null)?0:tmprs.getInt(1);
  380. return temp;
  381. }
  382. public int titlenum(DBConnect dbc) throws Exception{
  383. ResultSet tmprs=dbc.executeQuery("Select Count(announceID) from bbs.bbs1 where parentID=0");
  384.      tmprs.next();
  385. String tempString=tmprs.getString(1);
  386. int temp=(tempString==null)?0:tmprs.getInt(1);
  387. return temp;
  388. }
  391. //////////////////////////////////////
  392. public static void addMaster(String masters,DBConnect dbc) throws Exception{
  394. String [] arr=masters.split("\|");
  395. //DBConnect dbc=
  396. ResultSet rs;
  397. String sql;
  398. for(int i=0;i<arr.length;i++){
  399. sql="select userID from bbs.myuser where userName=?";
  400. dbc.prepareStatement(sql);
  401. dbc.setBytes(1,(new String(arr[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
  402. rs=dbc.executeQuery();
  403. if(!rs.next()){
  404. dbc.close();
  405. throw new Exception("没有发现此用户"+arr[i]);
  406. }
  407. sql="update bbs.myuser set userclass=19 where username=?";
  408. dbc.prepareStatement(sql);
  409. dbc.setBytes(1,(new String(arr[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
  410. dbc.executeUpdate();
  411. }
  412. }
  416. }