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

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

Java书籍

开发平台：

Java

ForumMSGAdmin.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 ForumMSGAdmin
  16. { int forumID,rootID,announceID;
  17. String userName,sql,url,action;
  18. User theUser;
  19. public ForumMSGAdmin(){
  20. }
  21. public ForumMSGAdmin(HttpServletRequest request,HttpServletResponse response) throws Exception{
  22. userName=GCookie.getCookieValue(request,"UJBBUName","");
  24. theUser=SkinUtil.checkUser(request,response,4);
  25. checkAdmin(request,response);
  26. adminMSG(request,response);
  27. }
  29. public void checkAdmin(HttpServletRequest request,HttpServletResponse response) throws Exception{
  31. action=ParamUtil.getString(request,"action");
  32. if(action==null||"".equals(action))
  33. throw new Exception("错误请求！");
  35. forumID=ParamUtil.getInt(request,"forumID");
  36. if(!action.equals("delall")){
  37. rootID=ParamUtil.getInt(request,"rootID");
  38. announceID=ParamUtil.getInt(request,"announceID");
  39. }
  40. if(forumID==0)
  41. throw new Exception("请指定论坛版面");
  42. Forum theForum=new Forum(forumID);
  43. if(theForum==null||(theForum.getForumMaster().indexOf(userName)<0&&theUser.getUserClass()<20))
  44. throw new Exception("您不是该版面斑竹或者系统管理员。");
  45. }
  46. public void adminMSG(HttpServletRequest request,HttpServletResponse response) throws Exception{
  48. if (action.equals("lock"))
  49.  lockMSG();
  50. else if (action.equals("unlock"))
  51.  unlockMSG();
  52. else if (action.equals("deltopic"))
  53.  delTopic();
  54. else if (action.equals("move")){
  55. String tempString=ParamUtil.getString(request,"checked");
  56. if(tempString!=null&&"yes".equals(tempString))
  57. moveTopic(request);
  58. else
  59. return;
  60. }
  61. else if (action.equals("delall")){
  62. String tempString=ParamUtil.getString(request,"checked");
  63. if(tempString!=null&&"yes".equals(tempString))
  64. delAll(request);
  65. else
  66. return;
  67. }
  68. else if (action.equals("copy")){
  69. String tempString=ParamUtil.getString(request,"checked");
  70. if(tempString!=null&&"yes".equals(tempString))
  71. copyTopic(request);
  72. }
  74. else if (action.equals("top"))
  75.  topMSG();
  76. else if (action.equals("untop"))
  77.  untopMSG();
  78. else if (action.equals("delmsg" ))
  79.  delMSG();
  80. else if (action.equals("isbest"))
  81.  bestMSG();
  82. else if (action.equals("nobest" ))
  83.  unbestMSG();
  84. else
  85. throw new Exception ("请选择相应操作。");
  86. }
  87. public void  delAll(HttpServletRequest request) throws Exception{
  88. String username=ParamUtil.getString(request,"username");
  89. if(username==null||"".equals(username))
  90. throw new Exception("请输入被帖子删除用户名。");
  91. DBConnect dbc=new DBConnect();
  92. sql="Select Count(announceID) from bbs.bbs1 where boardID="+forumID+" and username=?";
  93. dbc.prepareStatement(sql);
  94. dbc.setBytes(1,(new String(username.getBytes("ISO-8859-1"),"GBK")).getBytes());
  96. ResultSet rs=dbc.executeQuery();
  97. rs.next();
  98. int titlenum=rs.getInt(1);
  99.      rs.close();
  101. if(titlenum!=0){
  102. int wealthDel=Integer.parseInt(ForumPropertiesManager.getString("wealthDel"));
  104. int epDel=Integer.parseInt(ForumPropertiesManager.getString("epDel"));
  106. int cpDel=Integer.parseInt(ForumPropertiesManager.getString("cpDel"));
  108. sql="update bbs.bbs1 set locktopic=2 where boardID="+forumID+" and  username=?";
  109. dbc.prepareStatement(sql);
  110. dbc.setBytes(1,(new String(username.getBytes("ISO-8859-1"),"GBK")).getBytes());
  111. dbc.executeUpdate();
  112. sql="update bbs.myuser set article=article-"+titlenum+",userWealth=userWealth-"+(titlenum*wealthDel)+",userEP=userEP-"+(titlenum*epDel)+",userCP=userCP-"+(titlenum*cpDel)+" where username=?";
  113. dbc.prepareStatement(sql);
  114. dbc.setBytes(1,(new String(username.getBytes("ISO-8859-1"),"GBK")).getBytes());
  115. dbc.executeUpdate();
  118. sql="select count(announceid) from bbs.bbs1 where boardID="+forumID;
  119. rs=dbc.executeQuery(sql);
  120. rs.next();
  121. int NewAnnounceNum=rs.getInt(1);
  122. rs.close();
  124. sql="select count(announceid) from bbs.bbs1 where ParentID=0 and boardID="+forumID;
  125. rs=dbc.executeQuery(sql);
  126. rs.next();
  127. int NewTopicNum=rs.getInt(1);
  128. rs.close();
  130. sql="update bbs.board set lastbbsnum="+NewAnnounceNum+",lasttopicnum="+NewTopicNum+" where boardID="+forumID;
  131. dbc.executeUpdate();
  132. }
  133. dbc.close();
  134. }
  135. public void copyTopic(HttpServletRequest request) throws Exception{
  136. int newForumID=ParamUtil.getInt(request,"newForumID");
  137. DBConnect dbc=new DBConnect();
  138. ResultSet rs;
  139. if (forumID==newForumID){
  140. dbc.close();
  141. throw new Exception("不能在相同版面内进行转移操作。");
  142. }
  143. else{
  145. sql="select boardID,announceid,Parentid from bbs.bbs1 where announceid="+announceID+" and boardID="+forumID;
  146. dbc.prepareStatement(sql);
  147. rs=dbc.executeQuery();
  149. if(!rs.next()){
  150. dbc.close();
  151. throw new Exception ("您选择的贴子并不存在。");
  152. }
  153. else {
  154. //rs.next();
  155. if(rs.getInt(3)!=0){
  156. dbc.close();
  157. throw new Exception("您必须选择一个主题，而不是贴子。");
  158. }
  159. }
  160. }
  164. String  newtopic,username,body,dateandtime,ip,Expression;
  165. int msgLength, announceid;
  166. sql="select topic,username,body,dateAndTime,length,ip,Expression from bbs.bbs1 where announceid="+announceID;
  167. rs=dbc.executeQuery(sql);
  168. if(!rs.next()){
  169. dbc.close();
  170. throw new Exception("没有此贴!");
  171. }
  172. //rs.next();
  173. newtopic=rs.getString(1) + "-->" + userName + "添加";
  174. username=rs.getString(2);
  175. body=rs.getString(3);
  176. dateandtime=rs.getString(4);
  177. msgLength=rs.getInt(5);
  178. ip=rs.getString(6);
  179. Expression=rs.getString(7);
  180. rs.close();
  183. sql="insert into bbs.bbs1(boardID,parentID,child,userName,topic,n body,dateandtime,hits,length,rootID,layer,orders,ip,Expression,locktopic,signflag,emailflag,times,isvote,istop,isbest) n values("+newForumID+",0,0,?,?,?,'"+dateandtime+"', 0,"+msgLength+",0,1,0,'"+ip+"','"+Expression+"',n 0,0,0,0,0,0,0)";
  184. dbc.prepareStatement(sql);
  185. dbc.setBytes(1,(new String(username.getBytes("ISO-8859-1"),"GBK")).getBytes());
  186. dbc.setBytes(2,(new String(newtopic.getBytes("ISO-8859-1"),"GBK")).getBytes());
  187. dbc.setBytes(3,(new String(body.getBytes("ISO-8859-1"),"GBK")).getBytes());
  188. dbc.executeUpdate();
  191. sql="select announceID from bbs.bbs1 order by announceID desc";
  192. rs=dbc.executeQuery(sql);
  193. rs.next();
  194. announceid=rs.getInt(1);
  195. rs.close();
  197. sql="update bbs.bbs1 set rootID="+announceid+",times="+announceid+" where announceID="+announceid;
  198. dbc.executeUpdate(sql);
  201. int postNum,todayNum;
  203. sql="select count(*) from bbs.bbs1 where rootID="+rootID;
  204. dbc.prepareStatement(sql);
  205. rs=dbc.executeQuery();
  206. rs.next();
  207. postNum=rs.getInt(1);
  208. rs.close();
  210. sql="select count(*) from bbs.bbs1 where rootID="+rootID+" and day(dateandtime)=day(getdate())";
  211. rs=dbc.executeQuery(sql);
  212. rs.next();
  213. todayNum=rs.getInt(1);
  214. rs.close();
  216. //'更新论坛贴子数据
  217. //LastCount(forumID)
  218. //LastCount(newForumID)
  219. //call BoardNumAdd(newForumID,1,postNum,todayNum)
  220. //call AllboardNumAdd(todayNum,postNum,1)
  222. lastCount(forumID);
  223. lastCount(newForumID);
  224. forumNumAdd(newForumID,0,1,todayNum,dbc);
  226. allForumNumAdd(todayNum,1,0,dbc);
  229. url="dispbbs.jsp?forumID="+newForumID+"&rootID="+announceid+"&announceID="+announceid;
  231. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  232. dbc.prepareStatement(sql);
  233. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  234. dbc.setBytes(2,(new String("拷贝帖子".getBytes("ISO-8859-1"),"GBK")).getBytes());
  235. dbc.executeUpdate();
  236. dbc.close();
  237. ForumPropertiesManager.resetManager();
  239. }
  240. public void moveTopic(HttpServletRequest request) throws Exception{
  241. int newForumID=ParamUtil.getInt(request,"newForumID");
  242. DBConnect dbc=new DBConnect();
  243. ResultSet rs;
  244. if (forumID==newForumID){
  245. dbc.close();
  246. throw new Exception("不能在相同版面内进行转移操作。");
  247. }
  248. else{
  250. sql="select boardID,announceid,Parentid from bbs.bbs1 where announceid="+announceID+" and boardID="+forumID;
  251. dbc.prepareStatement(sql);
  252. rs=dbc.executeQuery();
  254. if(!rs.next()){
  255. dbc.close();
  256. throw new Exception ("您选择的贴子并不存在。");
  257. }
  258. else {
  259. //rs.next();
  260. if(rs.getInt(3)!=0){
  261. dbc.close();
  262. throw new Exception("您必须选择一个主题，而不是贴子。");
  263. }
  264. }
  265. }
  267. String leavemessage=ParamUtil.getString(request,"leavemessage");
  268. if(leavemessage==null||leavemessage.equals("")){
  269. dbc.close();
  270. throw new Exception("请选择相应的操作！");
  271. }
  275. if (leavemessage.equals("yes")) {
  276. //'ON ERROR RESUME NEXT
  277. }
  279. else if (leavemessage.equals("no")) {
  280. String newtopic;
  282. sql="select topic from bbs.bbs1 where announceid="+rootID;
  283. dbc.prepareStatement(sql);
  284. rs=dbc.executeQuery();
  285. rs.next();
  286. newtopic=rs.getString(1)+ "-->" + userName + "转移";
  287. rs.close();
  289. sql="update bbs.bbs1 set topic=? where announceid="+rootID;
  290. dbc.prepareStatement(sql);
  291. dbc.setBytes(1,(new String(newtopic.getBytes("ISO-8859-1"),"GBK")).getBytes());
  292. dbc.executeUpdate();
  294. sql="update bbs.bbs1 set boardID="+newForumID+" where rootID="+rootID;
  295. dbc.prepareStatement(sql);
  296. dbc.executeUpdate();
  298. int postNum,todayNum;
  300. sql="select count(*) from bbs.bbs1 where rootID="+rootID;
  301. dbc.prepareStatement(sql);
  302. rs=dbc.executeQuery();
  303. rs.next();
  304. postNum=rs.getInt(1);
  305. rs.close();
  307. sql="select count(*) from bbs.bbs1 where rootID="+rootID+" and day(dateandtime)=day(getdate())";
  308. rs=dbc.executeQuery(sql);
  309. rs.next();
  310. todayNum=rs.getInt(1);
  311. rs.close();
  313. //'更新论坛贴子数据
  314. lastCount(forumID);
  315. forumNumSub(forumID,0,1,todayNum,dbc);
  316. lastCount(newForumID);
  317. forumNumAdd(newForumID,0,1,todayNum,dbc);
  318. //allForumNumSub(todayNum,1,0,dbc);
  322. //'更新论坛数据结束
  324. url="dispbbs.jsp?forumID="+newForumID+"&rootID="+rootID+"&announceID="+rootID;
  325. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  326. dbc.prepareStatement(sql);
  327. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  328. dbc.setBytes(2,(new String("转移主题".getBytes("ISO-8859-1"),"GBK")).getBytes());
  329. dbc.executeUpdate();
  330. dbc.close();
  331. ForumPropertiesManager.resetManager();
  332. }
  333. else{
  334. dbc.close();
  335. throw new Exception("请选择相应操作。");
  336. }
  337. }
  338. //public void copyMSG() throws Exception{}
  340. public void lockMSG() throws Exception{
  341. sql="update bbs.bbs1 set locktopic=1 where boardID="+forumID+" and rootID="+rootID;
  342. DBConnect dbc=new DBConnect();
  343. dbc.executeUpdate(sql);
  344. url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
  345. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  346. dbc.prepareStatement(sql);
  347. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  348. dbc.setBytes(2,(new String("锁定帖子".getBytes("ISO-8859-1"),"GBK")).getBytes());
  349. dbc.executeUpdate();
  350. dbc.close();
  351. }
  353. public void unlockMSG() throws Exception{
  354. DBConnect dbc=new DBConnect();
  355. sql="update bbs.bbs1 set locktopic=0 where boardID="+forumID+" and rootID="+rootID;
  356. dbc.executeUpdate(sql);
  357. url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
  358. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  359. dbc.prepareStatement(sql);
  360. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  361. dbc.setBytes(2,(new String("解除锁定".getBytes("ISO-8859-1"),"GBK")).getBytes());
  362. dbc.executeUpdate();
  363. dbc.close();
  364. }
  365. public void topMSG() throws Exception{
  366. DBConnect dbc=new DBConnect();
  367. sql="update bbs.bbs1 set istop=1 where boardID="+forumID+" and rootID="+rootID;
  368. dbc.executeUpdate(sql);
  369. url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
  370. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  371. dbc.prepareStatement(sql);
  372. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  373. dbc.setBytes(2,(new String("固顶帖子".getBytes("ISO-8859-1"),"GBK")).getBytes());
  374. dbc.executeUpdate();
  375. dbc.close();
  376. }
  377. public void untopMSG() throws Exception{
  378. DBConnect dbc=new DBConnect();
  379. sql="update bbs.bbs1 set istop=0 where boardID="+forumID+" and rootID="+rootID;
  380. dbc.executeUpdate(sql);
  381. url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
  382. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  383. dbc.prepareStatement(sql);
  384. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  385. dbc.setBytes(2,(new String("解除固顶".getBytes("ISO-8859-1"),"GBK")).getBytes());
  386. dbc.executeUpdate();
  387. dbc.close();
  388. }
  389. public void bestMSG() throws Exception{
  390. DBConnect dbc=new DBConnect();
  391. sql="update bbs.bbs1 set isbest=1 where boardID="+forumID+" and announceid="+announceID;
  392. dbc.executeUpdate(sql);
  393. url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
  394. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  395. dbc.prepareStatement(sql);
  396. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  397. dbc.setBytes(2,(new String("加入精华".getBytes("ISO-8859-1"),"GBK")).getBytes());
  398. dbc.executeUpdate();
  399. dbc.close();
  400. }
  401. public void unbestMSG() throws Exception{
  402. DBConnect dbc=new DBConnect();
  403. sql="update bbs.bbs1 set isbest=0 where boardID="+forumID+" and announceid="+announceID;
  404. dbc.executeUpdate(sql);
  405. url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
  406. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  407. dbc.prepareStatement(sql);
  408. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  409. dbc.setBytes(2,(new String("解除精华".getBytes("ISO-8859-1"),"GBK")).getBytes());
  410. dbc.executeUpdate();
  411. dbc.close();
  412. }
  413. public void delMSG() throws Exception{
  414. DBConnect dbc=new DBConnect();
  415. sql="update bbs.bbs1 set locktopic=2 where boardID="+forumID+" and ParentID!=0 and announceid="+announceID;
  416. dbc.executeUpdate(sql);
  417. sql="select Max(announceid) from bbs1 where  locktopic!=2 and rootID="+rootID+" and boardID="+forumID;
  418. ResultSet rs=dbc.executeQuery(sql);
  419. rs.next();
  420. int lastPostime=rs.getInt(1);
  421. rs.close();
  423. int todayNum;
  424. sql="select count(*) from bbs.bbs1 where announceid="+announceID+" and day(dateandtime)=day(getdate())";
  425. rs=dbc.executeQuery(sql);
  426. rs.next();
  427. todayNum=rs.getInt(1);
  428. rs.close();
  430. lastCount(forumID);
  431. forumNumSub(forumID,0,1,todayNum,dbc);
  433. allForumNumSub(todayNum,1,0,dbc);
  435. int wealthDel=Integer.parseInt(ForumPropertiesManager.getString("wealthDel"));
  437. int epDel=Integer.parseInt(ForumPropertiesManager.getString("epDel"));
  439. int cpDel=Integer.parseInt(ForumPropertiesManager.getString("cpDel"));
  441. sql="update bbs.bbs1 set times="+lastPostime+" where rootID="+rootID+" and boardID="+forumID;
  442. dbc.executeUpdate(sql);
  443. sql="update bbs.bbs1 set child=child-1 where announceid="+rootID+" and boardID="+forumID;
  444. dbc.executeUpdate(sql);
  446. sql="update bbs.myuser set article=article-1,userWealth=userWealth-"+wealthDel+",userEP=userEP-"+epDel+",userCP=userCP-"+cpDel+"  where username=?";
  447. dbc.prepareStatement(sql);
  448. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  450. dbc.executeUpdate();
  451. url="showannounce.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID;
  452. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  453. dbc.prepareStatement(sql);
  454. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  455. dbc.setBytes(2,(new String("删除帖子".getBytes("ISO-8859-1"),"GBK")).getBytes());
  456. dbc.executeUpdate();
  457. dbc.close();
  458. ForumPropertiesManager.resetManager();
  459. }
  461. public void delTopic() throws Exception{
  462. DBConnect dbc=new DBConnect();
  463. int todayNum,postNum;
  464. sql="select count(*) from bbs.bbs1 where rootID="+rootID;
  465. ResultSet  rs=dbc.executeQuery(sql);
  466. rs.next();
  467. postNum=rs.getInt(1);
  468. sql="select count(*) from bbs.bbs1 where rootID="+rootID+" and     day(dateandtime)=day(getdate())";
  469. rs=dbc.executeQuery(sql);
  470. rs.next();
  471. todayNum=rs.getInt(1);
  472. rs.close();
  473. int wealthDel=Integer.parseInt(ForumPropertiesManager.getString("wealthDel"));
  475. int epDel=Integer.parseInt(ForumPropertiesManager.getString("epDel"));
  477. int cpDel=Integer.parseInt(ForumPropertiesManager.getString("cpDel"));
  478. sql="select username from bbs.bbs1 where rootID="+rootID;
  480. rs=dbc.executeQuery(sql);
  484. while(rs.next()){
  485. String tempName=rs.getString(1);
  486. if(tempName!=null&&!"".equals(tempName)){
  487. sql="update bbs.myuser set article=article-1,userWealth=userWealth-"+wealthDel+",userEP=userEP-"+epDel+" where username=?";
  488. dbc.prepareStatement(sql);
  489. dbc.setBytes(1,(new String(tempName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  490. dbc.executeUpdate();
  491. }
  492. }
  494. rs.close();
  495. sql="update bbs.bbs1 set locktopic=2 where rootID="+rootID;
  496. dbc.executeUpdate(sql);
  498. lastCount(forumID);
  499. forumNumSub(forumID,1,postNum,todayNum,dbc);
  500. allForumNumSub(todayNum,postNum,1,dbc);
  502. url="dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+rootID;
  503. sql="insert into bbs.log (l_username,l_content,l_url) values (?,?,'"+url+"')";
  504. dbc.prepareStatement(sql);
  505. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  506. dbc.setBytes(2,(new String("删除主题".getBytes("ISO-8859-1"),"GBK")).getBytes());
  507. dbc.executeUpdate();
  508. dbc.close();
  509. ForumPropertiesManager.resetManager();
  510. }
  516. public void lastCount(int forumID) throws Exception{
  517. DBConnect dbc=new DBConnect();
  518. ResultSet rs=dbc.executeQuery("select topic,body,rootID,dateandtime,username from bbs.bbs1 where locktopic!=2 and boardID="+forumID+" order by announceid desc");
  519. String lastTopic,body,lastPost,lastPostUser;
  520. int lastRootID;
  521. if (rs.next()) {
  522. lastTopic=rs.getString(1);
  523. body=rs.getString(2);
  524. if(lastTopic==null||"".equals(lastTopic)){
  525. if(body.length()>14)
  526. lastTopic=body.substring(0,14);
  527. else lastTopic=body;
  528. }
  530. lastRootID=rs.getInt(3);
  531. lastPost=rs.getString(4);
  532. lastPostUser=rs.getString(5);
  533. }
  534. else{
  535. lastTopic="无";
  536. lastRootID=0;
  537. lastPost=Format.getDateTime();
  538. lastPostUser="无";
  539. }
  540. rs.close();
  542. sql="update bbs.board set lastTopic=?,lastRootID='"+lastRootID+"',lastPosttime='"+lastPost+"',lastPostuser=? where boardID="+forumID;
  543. dbc.prepareStatement(sql);
  544. dbc.setBytes(1,(new String(lastTopic.getBytes("ISO-8859-1"),"GBK")).getBytes());
  545. dbc.setBytes(2,(new String(lastPostUser.getBytes("ISO-8859-1"),"GBK")).getBytes());
  546. dbc.executeUpdate();
  547. dbc.close();
  548. }
  551. public void  forumNumAdd(int forumID,int topicNum,int postNum,int todayNum,DBConnect dbc) throws Exception {
  552. sql="update bbs.board set lastbbsnum=lastbbsnum+"+postNum+",lastTopicNum=lastTopicNum+"+topicNum+",todayNum=todayNum+"+todayNum+" where boardID="+forumID;
  553. dbc.executeUpdate(sql);
  554. }
  556. //'版面发帖数减少
  557. public  void forumNumSub(int forumID,int topicNum,int postNum,int todayNum,DBConnect dbc) throws Exception {
  558. sql="update bbs.board set lastbbsnum=lastbbsnum-"+postNum+",lastTopicNum=lastTopicNum-"+topicNum+",todayNum=todayNum-"+todayNum+" where boardID="+forumID;
  559. //'response.write sql
  560. //'response.end
  561. dbc.executeUpdate(sql);
  562. }
  565. //'所有论坛发帖数增加
  566. public void  allForumNumAdd(int todayNum,int postNum,int topicNum,DBConnect dbc) throws Exception {
  567. sql="update bbs.config set TodayNum=todayNum+"+todayNum+",BbsNum=bbsNum+"+postNum+",TopicNum=topicNum+"+topicNum;
  568. dbc.executeUpdate(sql);
  569. }
  571. //'所有论坛发帖数减少
  572. public void allForumNumSub(int todayNum,int postNum,int topicNum,DBConnect dbc) throws Exception{
  573. sql="update bbs.config set TodayNum=todayNum-"+todayNum+",BbsNum=bbsNum-"+postNum+",TopicNum=topicNum-"+topicNum;
  574. dbc.executeUpdate(sql);
  575. }
  578. }