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

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

Java书籍

开发平台：

Java

Forum.java：源码内容
  1. package net.acai.forum;
  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.database.*;
  11. import java.sql.*;
  12. import net.acai.filter.*;
  13. import net.acai.util.*;
  14. import net.acai.forum.*;
  15. import net.acai.util.Format;
  16. import java.util.Vector;
  17. import javax.servlet.http.*;
  18. //import net.acai.forum.util.*;
  19. import java.util.regex.*;
  21. public class Forum{
  23. int forumID,forumClass,lockForum,forumSkin,lastBbsNum;
  24. int lastTopicNum,strAllowForumCode,strAllowHTML,strIMGInPosts;
  25. int strIcons,strFlash,lastRootID,todayNum;
  26. int voteID;
  27. String forumType,readMe,forumMaster;
  28. String tableBack,tableTitle,tableBody,aTableBody,tableFont,tableContent;
  29. String alertFont,lastPostUser,lastPostTime,forumLogo,indexIMG,lastTopic,forumUser;
  30. Vector forumOLUsers;
  31. int forumTopicNum;
  32. int forumOLGuestUsersNum=0,forumOLMemberUsersNum=0,forumsOLUsersNum=0;
  33. int forumMSGsNum=0;
  34. ForumTopic forumMSGTopic;
  35. public Forum(){
  36. }
  37. public Forum(HttpServletRequest request,HttpServletResponse response,int forumID) throws ForumNotFoundException{
  38. init(forumID);
  39. SkinUtil.checkUserStats(request,response,this.forumType);
  40. this.getOnline();
  41. }
  43. public Forum(int forumID) throws ForumNotFoundException{
  44. init(forumID);
  46. this.getOnline();
  47. }
  49. public void init(int forumID) throws ForumNotFoundException{
  50. try{
  51. DBConnect dbc=new DBConnect("select * from bbs.board where boardid=?");
  52. dbc.setInt(1,forumID);
  53. ResultSet rs=dbc.executeQuery();
  54. rs.next();
  55. this.forumID=rs.getInt(1);
  56. forumType=rs.getString(2);
  57. forumClass=rs.getInt(3);
  58. readMe=rs.getString(4);
  59. forumMaster=rs.getString(5);
  60. lockForum=rs.getInt(6);
  61. forumSkin=rs.getInt(7);
  62. tableBack=rs.getString(8);
  63. tableTitle=rs.getString(9);
  64. tableBody=rs.getString(10);
  65. aTableBody=rs.getString(11);
  66. tableFont=rs.getString(12);
  67. tableContent=rs.getString(13);
  68. alertFont=rs.getString(14);
  69. lastPostUser=rs.getString(15);
  70. lastPostTime=rs.getString(16);
  71. lastBbsNum=rs.getInt(17);
  72. lastTopicNum=rs.getInt(18);
  73. strAllowForumCode=rs.getInt(19);
  74. strAllowHTML=rs.getInt(20);
  75. strIMGInPosts=rs.getInt(21);
  76. strIcons=rs.getInt(22);
  77. strFlash=rs.getInt(23);
  78. forumLogo=rs.getString(24);
  79. indexIMG=rs.getString(25);
  80. lastRootID=rs.getInt(26);
  81. lastTopic=rs.getString(27);
  82. todayNum=rs.getInt(28);
  83. forumUser=rs.getString(29);
  84. dbc.clearParameters();
  85. dbc.close();
  86. }
  87. catch(Exception e){
  88. e.printStackTrace();
  89. throw new ForumNotFoundException();
  90. }
  91. }
  93. public Vector getOnline() throws ForumNotFoundException{
  94. try{
  95. DBConnect dbc=new DBConnect();
  96. dbc.prepareStatement("select * from bbs.online order by id");
  97. ResultSet rs=dbc.executeQuery();
  98. forumsOLUsersNum=rs.getRow();
  99. forumOLUsers=new Vector();
  100. dbc.prepareStatement("select * from bbs.online where stats like ? order by id");
  101. String tempForumType="%"+forumType+"%";
  102. dbc.setBytes(1,(new String(tempForumType.getBytes("ISO-8859-1"),"GBK")).getBytes());
  103. rs=dbc.executeQuery();
  105. while(rs.next()){//&&this.forumType.equals(rs.getString(4).trim())){
  107. OLUser tempOLUser=new OLUser();
  108. tempOLUser.setUserID(rs.getInt(1));
  109. if("guest".equals(rs.getString(2)))
  110. forumOLGuestUsersNum++;
  111. else
  112. forumOLMemberUsersNum++;
  113. tempOLUser.setUserName(rs.getString(2));
  114. tempOLUser.setUserClass(rs.getString(3));
  115. tempOLUser.setStats(rs.getString(4));
  116. tempOLUser.setUserIP(rs.getString(5));
  117. tempOLUser.setStartTime(rs.getString(6));
  118. tempOLUser.setLastTimeBK(rs.getString(7));
  119. tempOLUser.setLastTime(rs.getString(8));
  120. tempOLUser.setBrowser(rs.getString(9));
  121. tempOLUser.setActForIP(rs.getString(10));
  122. tempOLUser.setComeFrom(rs.getString(11));
  123. tempOLUser.setActCome(rs.getString(12));
  124. forumOLUsers.add(tempOLUser);
  126. }
  128. dbc.close();
  129. return forumOLUsers;
  130. }
  131. catch(Exception e){
  132. e.printStackTrace();
  133. throw new ForumNotFoundException();
  134. }
  135. }
  137. public Vector getForumTopics  (int forumID,int start ,int Page) throws ForumTopicNotFoundException{
  138. try
  139. {
  140. //DBConnect dbc=new DBConnect(2,0);
  141. DBConnect dbc=new DBConnect();
  142. ResultSet rs=dbc.executeQuery("select count(announceid) from bbs.bbs1 where boardID="+forumID+" and parentID=0  and  locktopic!=2");
  143. rs.next();
  144. forumTopicNum=rs.getInt(1);
  146. String sql="select count(Announceid) from bbs.bbs1 where istop=1 and layer=1 and boardid="+forumID;
  147. rs=dbc.executeQuery(sql);
  148. rs.next();
  149. int topNum=rs.getInt(1);
  150. rs.close();
  151. int maxAnnouncePerPage=Integer.parseInt(ForumPropertiesManager.getString("MaxAnnouncePerPage"));
  153. /*if(Page>1)
  154. sql="select * from bbs1 where boardID="+forumID+" and parentID=0n and times < (select all (times) from bbs1 where boardID="+forumID+" and istop=0 and parentID=0 order by times desc limit 0,"+((Page-1)*maxAnnouncePerPage-topNum)+")  andn  locktopic!=2 ORDER BY istop desc,times desc,announceid desc limitn 0,"+maxAnnouncePerPage;
  155. else*/
  156. sql="select * from bbs.bbs1 where boardID="+forumID+" and parentID=0  and  locktopic!=2n ORDER BY istop desc,times desc,announceid descn";
  158. dbc.prepareStatement(sql);
  159. rs=dbc.executeQuery();
  160. int num1 = ((Page-1)*maxAnnouncePerPage) ;
  161. int num2 = (((Page-1)*maxAnnouncePerPage)+maxAnnouncePerPage) ;
  162. int i = 0 ;
  163. int n = 0 ;
  164. Vector forumTopics=new Vector();
  165. while(rs.next()){
  167. i++;
  168. if(i<num1)continue;
  170. n++;
  171. if(n>num2)break;
  173. ForumTopic theTopic=new ForumTopic(rs.getInt(12));
  174. theTopic.setAnnounceID(rs.getInt(1));
  175. theTopic.setParentID(rs.getInt(2));
  176. theTopic.setChildNum(rs.getInt(3));
  177. theTopic.setForumID(rs.getInt(4));
  178. theTopic.setUserName(rs.getString(5));
  179. theTopic.setUserEmail(rs.getString(6));
  180. theTopic.setTopic(rs.getString(7));
  181. theTopic.setBody(rs.getString(8));
  182. theTopic.setDateAndTime(rs.getString(9));
  183. theTopic.setHits(rs.getInt(10));
  184. theTopic.setLength(rs.getInt(11));
  185. theTopic.setRootID(rs.getInt(12));
  186. theTopic.setLayer(rs.getInt(13));
  187. theTopic.setOrders(rs.getInt(14));
  188. theTopic.setIsBest(rs.getInt(15));
  189. theTopic.setUserIP(rs.getString(16));
  190. theTopic.setExpression(rs.getString(17));
  191. theTopic.setTimes(rs.getInt(18));
  192. theTopic.setLockTopic(rs.getInt(19));
  193. theTopic.setSignFlag(rs.getInt(20));
  194. theTopic.setEmailFlag(rs.getInt(21));
  195. theTopic.setIsTop(rs.getInt(22));
  196. theTopic.setIsVote(rs.getInt(23));
  197. forumTopics.add(theTopic);
  199. }
  201. dbc.close();
  202. return forumTopics;
  203. }
  204. catch ( ForumTopicNotFoundException  oe )
  205. {
  206. oe.printStackTrace();
  207. return null;
  208. }
  209. catch ( SQLException s3 )
  210. {
  211. s3.printStackTrace();
  212. return null;
  213. }
  214. catch(Exception e)
  215. {
  216. e.printStackTrace();
  217. throw new ForumTopicNotFoundException();
  218. }
  219. }
  220. public Vector getForumBestTopics  (int forumID,int start ,int perPage) throws ForumTopicNotFoundException{
  221. try{
  222. //DBConnect dbc=new DBConnect(2,0);
  223. DBConnect dbc=new DBConnect();
  224. dbc.prepareStatement("select * from bbs.bbs1 where boardID=? and isBest=1 and locktopic!=2  ORDER BY bbs1.times desc,bbs1.announceid desc");
  225. dbc.setInt(1,forumID);
  226. ResultSet rs=dbc.executeQuery();
  227. if(rs.last())
  228. forumTopicNum=rs.getRow();
  229. rs.absolute(start);
  230. int i=0;
  231. Vector forumTopics=new Vector();
  232. do
  233. {
  235. ForumTopic theTopic=new ForumTopic(rs.getInt(12));
  236. theTopic.setAnnounceID(rs.getInt(1));
  237. theTopic.setParentID(rs.getInt(2));
  238. theTopic.setChildNum(rs.getInt(3));
  239. theTopic.setForumID(rs.getInt(4));
  240. theTopic.setUserName(rs.getString(5));
  241. theTopic.setUserEmail(rs.getString(6));
  242. theTopic.setTopic(rs.getString(7));
  243. theTopic.setBody(rs.getString(8));
  244. theTopic.setDateAndTime(rs.getString(9));
  245. theTopic.setHits(rs.getInt(10));
  246. theTopic.setLength(rs.getInt(11));
  247. theTopic.setRootID(rs.getInt(12));
  248. theTopic.setLayer(rs.getInt(13));
  249. theTopic.setOrders(rs.getInt(14));
  250. theTopic.setIsBest(rs.getInt(15));
  251. theTopic.setUserIP(rs.getString(16));
  252. theTopic.setExpression(rs.getString(17));
  253. theTopic.setTimes(rs.getInt(18));
  254. theTopic.setLockTopic(rs.getInt(19));
  255. theTopic.setSignFlag(rs.getInt(20));
  256. theTopic.setEmailFlag(rs.getInt(21));
  257. theTopic.setIsTop(rs.getInt(22));
  258. theTopic.setIsVote(rs.getInt(23));
  259. forumTopics.add(theTopic);
  260. i++;
  261. if(i==perPage)
  262. break;
  263. }
  264. while(rs.next());
  265. dbc.close();
  266. return forumTopics;
  267. }
  268. catch(Exception e)
  269. {
  270. e.printStackTrace();
  271. throw new ForumTopicNotFoundException();
  272. }
  273. }
  275. public static Vector getFollowTopics (int forumID,int rootID){
  276. Vector followTopics=new Vector();
  277. try{
  278. String sql="select announceID,layer,bbs.bbs1.boardID,rootID,topic,body,userName,child,hits from bbs.bbs1,bbs.board where bbs.bbs1.boardid="+forumID+" and bbs.bbs1.rootid="+rootID+" and bbs.bbs1.announceid<>"+rootID+" and bbs.bbs1.boardid=bbs.board.boardid and  bbs.bbs1.locktopic!=2 order by bbs.bbs1.rootid desc,bbs.bbs1.orders";
  279. //DBConnect dbc=new DBConnect(2,0);
  280. DBConnect dbc=new DBConnect();
  281. ResultSet rs=dbc.executeQuery(sql);
  283. while(rs.next()){
  284. ForumTopic theMSG=new ForumTopic();
  285. theMSG.setAnnounceID(rs.getInt("announceID"));
  286. theMSG.setLayer(rs.getInt("layer"));
  287. theMSG.setForumID(rs.getInt("boardID"));
  288. theMSG.setRootID(rs.getInt("rootID"));
  289. theMSG.setAnnounceID(rs.getInt("announceID"));
  291. /*
  292. if(rs.getString("topic")==null||rs.getString("topic").trim().equals("")){
  293. String m=rs.getString("body");
  294. if(rs.getString("body").length()>22)
  295. theMSG.setTopic(m.substring(0,22).replaceAll("\n|\r"," ").replaceAll(">", "&gt;").replaceAll("<", "&lt;"));
  296. else{
  298. theMSG.setTopic(m.replaceAll("\r|\n"," ").replaceAll(">", "&gt;").replaceAll("<", "&lt;"));
  299. }
  300. }
  301. else*/
  302. theMSG.setTopic(rs.getString("topic"));
  303. theMSG.setBody(rs.getString("body"));
  304. theMSG.setUserName(rs.getString("userName"));
  305. theMSG.setChildNum(rs.getInt("child"));
  306. theMSG.setHits(rs.getInt("hits"));
  308. followTopics.add(theMSG);
  309. }
  310. dbc.close();
  312. }
  313. catch(Exception e){
  314. e.printStackTrace();
  315. }
  317. return followTopics;
  319. }
  320. public ForumMSG getForumMSGTopic(){
  321. return this.forumMSGTopic;
  322. }
  323. public Vector getForumMSGs  (int forumID,int rootID,int announceID,int start ,int perPage) throws ForumMSGNotFoundException{
  324. try{
  325. DBConnect dbc=new DBConnect();
  326. ResultSet rs=dbc.executeQuery("select topic,istop,isbest,username,hits,times from bbs.bbs1 where announceID="+rootID);
  327. rs.next();
  328. forumMSGTopic=new ForumTopic();
  329. forumMSGTopic.setTopic(rs.getString(1));
  330. forumMSGTopic.setIsTop(rs.getInt(2));
  331. forumMSGTopic.setIsBest(rs.getInt(3));
  332. forumMSGTopic.setUserName(rs.getString(4));
  333. forumMSGTopic.setHits(rs.getInt(5));
  334. forumMSGTopic.setTimes(rs.getInt(6));
  335. forumMSGTopic.setAnnounceID(rootID);
  336. rs.close();
  339. String sql="Select B.AnnounceID,B.boardID,B.UserName,B.Topic,B.dateandtime,B.body,"+
  340. "B.Expression,B.ip,B.rootid,B.signflag,B.isbest,B.isvote,"+
  341. "U.username,U.useremail,U.homepage,U.oicq,U.sign,U.userclass,"+
  342. "U.title,U.width,U.height,U.article,U.face,U.addDate,"+
  343. "U.userWealth,U.userEP,U.userCP,B.hits,B.isTop,B.lockTopic"+
  344. " from bbs.bbs1 B inner join bbs.myuser U on U.username=B.username "+
  345. "where B.boardid="+forumID+" and B.rootid="+rootID+" and B.lockTopic!=2 order by announceid";
  347. rs=dbc.executeQuery(sql);
  349. //if(rs.last()) forumMSGsNum=rs.getRow();
  350. forumMSGsNum = 0 ;
  351. while(rs.next())
  352. {
  353. forumMSGsNum  ++ ;
  354. }
  356. rs=dbc.executeQuery(sql);
  357. int t = 1 ;
  358. if(t<start)
  359. {
  360. while(rs.next())
  361. {
  362. if(t==start)break;
  363. t++;
  364. }
  365. }
  367. //rs.absolute(start);
  369. int i=0;
  370. Vector forumMSGs=new Vector();
  371. while(rs.next())
  372. {
  374. ForumMSG theMSG=new ForumMSG();
  375. theMSG.setAnnounceID(rs.getInt(1));
  376. theMSG.setForumID(rs.getInt(2));
  377. theMSG.setUserName(rs.getString(3));
  378. theMSG.setTopic(rs.getString(4));
  379. theMSG.setDateAndTime(rs.getString(5));
  380. theMSG.setBody(rs.getString(6));
  381. theMSG.setExpression(rs.getString(7));
  382. theMSG.setUserIP(rs.getString(8));
  383. theMSG.setRootID(rs.getInt(9));
  384. theMSG.setSignFlag(rs.getInt(10));
  385. theMSG.setIsBest(rs.getInt(11));
  386. theMSG.setIsVote(rs.getInt(12));
  387. theMSG.setIsTop(rs.getInt(29));
  388. theMSG.setLockTopic(rs.getInt(30));
  389. theMSG.setHits(rs.getInt(28)+1);
  390. User msgUser=new User();
  391. msgUser.setUserName(rs.getString(13));
  392. msgUser.setUserEmail(rs.getString(14));
  393. msgUser.setHomePage(rs.getString(15));
  394. msgUser.setOicq(rs.getString(16));
  395. msgUser.setSign(rs.getString(17));
  396. msgUser.setUserClass(rs.getInt(18));
  397. msgUser.setTitle(rs.getString(19));
  398. msgUser.setWidth(rs.getInt(20));
  399. msgUser.setHeight(rs.getInt(21));
  400. msgUser.setArticle(rs.getInt(22));
  401. msgUser.setFace(rs.getString(23));
  402. msgUser.setAddDate(rs.getString(24));
  403. msgUser.setUserWealth(rs.getInt(25));
  404. msgUser.setUserEP(rs.getInt(26));
  405. msgUser.setUserCP(rs.getInt(27));
  406. theMSG.setUser(msgUser);
  407. forumMSGs.add(theMSG);
  408. i++;
  409. if(i==perPage)
  410. break;
  411. }
  412. sql="update bbs.bbs1 set hits=hits+1 where announceID="+announceID;
  413. dbc.executeUpdate(sql);
  414. dbc.close();
  415. return forumMSGs;
  416. }
  417. catch(SQLException se)
  418. {
  419. se.printStackTrace();
  420. throw new ForumMSGNotFoundException();
  421. }
  422. catch(Exception e)
  423. {
  424. e.printStackTrace();
  425. throw new ForumMSGNotFoundException();
  426. }
  427. }
  428. public static Vector getForumTextMSGs  (HttpServletRequest request) throws ForumMSGNotFoundException{
  429. try{
  430. int forumID,rootID;
  431. try{
  432. forumID=ParamUtil.getInt(request,"forumID");
  433. rootID=ParamUtil.getInt(request,"rootID");
  435. }
  436. catch(Exception e){
  437. throw new Exception("对不起，没有发现帖子！");
  438. }
  441. //DBConnect dbc=new DBConnect(2,0);
  442. DBConnect dbc=new DBConnect();
  443. String sql="Select UserName,Topic,dateandtime,body from bbs.bbs1 where boardid="+forumID+" and rootid="+rootID+" order by announceid";
  445. ResultSet rs=dbc.executeQuery(sql);
  447. /*if(!rs.next())
  448. throw new Exception("对不起没有发现帖子!");*/
  450. Vector forumMSGs=new Vector();
  451. while(rs.next())
  452. {
  454. ForumMSG theMSG=new ForumMSG();
  455. //theMSG.setAnnounceID(rs.getInt(1));
  456. //theMSG.setForumID(rs.getInt(2));
  457. theMSG.setUserName(rs.getString(1));
  458. theMSG.setTopic(rs.getString(2));
  459. theMSG.setDateAndTime(rs.getString(3));
  460. theMSG.setBody(rs.getString(4));
  461. /*theMSG.setExpression(rs.getString(7));
  462. theMSG.setUserIP(rs.getString(8));
  463. theMSG.setRootID(rs.getInt(9));
  464. theMSG.setSignFlag(rs.getInt(10));
  465. theMSG.setIsBest(rs.getInt(11));
  466. theMSG.setIsVote(rs.getInt(12));
  467. theMSG.setIsTop(rs.getInt(29));
  468. theMSG.setLockTopic(rs.getInt(30));
  469. theMSG.setHits(rs.getInt(28)+1);
  470. User msgUser=new User();
  471. msgUser.setUserName(rs.getString(13));
  472. msgUser.setUserEmail(rs.getString(14));
  473. msgUser.setHomePage(rs.getString(15));
  474. msgUser.setOicq(rs.getString(16));
  475. msgUser.setSign(rs.getString(17));
  476. msgUser.setUserClass(rs.getInt(18));
  477. msgUser.setTitle(rs.getString(19));
  478. msgUser.setWidth(rs.getInt(20));
  479. msgUser.setHeight(rs.getInt(21));
  480. msgUser.setArticle(rs.getInt(22));
  481. msgUser.setFace(rs.getString(23));
  482. msgUser.setAddDate(rs.getString(24));
  483. msgUser.setUserWealth(rs.getInt(25));
  484. msgUser.setUserEP(rs.getInt(26));
  485. msgUser.setUserCP(rs.getInt(27));
  486. theMSG.setUser(msgUser);*/
  487. forumMSGs.add(theMSG);
  489. }
  491. dbc.close();
  492. return forumMSGs;
  493. }
  494. catch(Exception e)
  495. {
  496. e.printStackTrace();
  497. throw new ForumMSGNotFoundException(e.getMessage());
  498. }
  499. }
  500. public int getForumMSGsNum(){
  501. return this.forumMSGsNum;
  502. }
  503. public int getForumTopicNum(){
  504. return forumTopicNum;
  505. }
  507. public int getForumID(){
  508. return forumID;
  509. }
  510. public String getForumType(){
  511. return forumType;
  512. }
  513. public int getForumClass(){
  514. return forumClass;
  515. }
  516. public String getReadMe(){
  517. return readMe;
  518. }
  519. public String getForumMaster(){
  520. return forumMaster;
  521. }
  522. public int getLockForum(){
  523. return lockForum;
  524. }
  525. public int getForumSkin(){
  526. return forumSkin;
  527. }
  528. public String getTableBack(){
  529. return tableBack;
  530. }
  531. public String getTableTitle(){
  532. return tableTitle;
  533. }
  534. public String getTableBody(){
  535. return tableBody;
  536. }
  537. public String getATableBody(){
  538. return aTableBody;
  539. }
  540. public String getTableFont(){
  541. return tableFont;
  542. }
  543. public String getTableContent(){
  544. return tableContent;
  545. }
  546. public String getAlertFont(){
  547. return alertFont;
  548. }
  549. public String getLastPostUser(){
  550. return lastPostUser;
  551. }
  552. public String getLastPostTime(){
  553. return lastPostTime;
  554. }
  555. public int getLastBbsNum(){
  556. return lastBbsNum;
  557. }
  558. public int getLastTopicNum(){
  559. return lastTopicNum;
  560. }
  561. public boolean getStrAllowForumCode(){
  562. if(strAllowForumCode==1)
  563. return true;
  564. else
  565. return false;
  566. }
  567. public boolean getStrAllowHTML(){
  568. if(strAllowHTML==1)
  569. return true;
  570. else
  571. return false;
  572. }
  573. public boolean getStrIMGInPosts(){
  574. if(strIMGInPosts==1)
  575. return true;
  576. else
  577. return false;
  578. }
  579. public boolean getStrIcons(){
  580. if(strIcons==1)
  581. return true;
  582. else
  583. return false;
  584. }
  585. public boolean getStrFlash(){
  586. if(strFlash==1)
  587. return true;
  588. else
  589. return false;
  590. }
  591. public String getForumLogo(){
  592. return forumLogo;
  593. }
  594. public String getIndexIMG(){
  595. return indexIMG;
  596. }
  597. public int getLastRootID(){
  598. return lastRootID;
  599. }
  600. public String getLastTopic(){
  601. return StringUtils.escapeHTMLTags(this.lastTopic);
  602. }
  603. public int getTodayNum(){
  604. return todayNum;
  605. }
  606. public String getForumUser(){
  607. return forumUser;
  608. }
  609. public Vector getForumOLUsers(){
  610. return forumOLUsers;
  611. }
  612. public int getForumOLGuestUsersNum(){
  613. return this.forumOLGuestUsersNum;
  614. }
  615. public int getForumOLMemberUsersNum(){
  616. return this.forumOLMemberUsersNum;
  617. }
  619. public int getForumsOLUsersNum(){
  620. return this.forumsOLUsersNum;
  621. }
  623. public String getForumIMG(String lastlogin){
  624. String strIMG="";
  625. switch(this.getForumSkin())
  626. {
  627. case 1:
  628. if(Format.compareTo(lastlogin,this.lastPostTime))
  629. strIMG="<img src=pic/foldernew.gif width=13 height=16 alt=常规论坛，有新帖子>";
  630. else
  631. strIMG="<img src=pic/ifolder.gif width=13 height=16 alt=常规论坛，无新帖子>";
  632. break;
  633. case 2:
  634. if(Format.compareTo(lastlogin,this.lastPostTime))
  635. strIMG="<img src=pic/folderallnew.gif width=13 height=16 alt=开放论坛，有新帖子>";
  636. else
  637. strIMG="<img src=pic/folderall.gif width=13 height=16 alt=开放论坛，无新帖子>";
  638. break;
  639. case 3:
  640. if(Format.compareTo(lastlogin,this.lastPostTime))
  641. strIMG="<img src=pic/follownew.gif width=13 height=16 alt=评论论坛，有新帖子>";
  642. else
  643. strIMG="<img src=pic/follow.gif width=13 height=16 alt=评论论坛，无新帖子>";
  644. break;
  645. case 4:
  646. if(Format.compareTo(lastlogin,this.lastPostTime))
  647. strIMG="<img src=pic/jinghua.gif width=13 height=16 alt=精华区，有新帖子>";
  648. else
  649. strIMG="<img src=pic/jinghua.gif width=13 height=16 alt=精华区，无新帖子>";
  650. break;
  651. case 5:
  652. if(Format.compareTo(lastlogin,this.lastPostTime))
  653. strIMG="<img src=pic/lock_l.gif width=13 height=16 alt=认证论坛，有新帖子>";
  654. else
  655. strIMG="<img src=pic/lock_b.gif width=13 height=16 alt=认证论坛，无新帖子>";
  656. break;
  657. case 6:
  658. if(Format.compareTo(lastlogin,this.lastPostTime))
  659. strIMG="<img src=pic/foldernew.gif width=13 height=16 alt=正规论坛，有新帖子>";
  660. else
  661. strIMG="<img src=pic/ifolder.gif width=13 height=16 alt=正规论坛，无新帖子>";
  662. break;
  663. default:
  664. }
  666. return strIMG;
  667. }
  669. public String authorSaveMSG(HttpServletRequest request,HttpServletResponse response) throws Exception{
  671. String userName=ParamUtil.getString(request,"userName","");
  672. String userPassword=ParamUtil.getString(request,"userPassword","");
  673. String sql="";
  674. String char_changed = "[align=right][此贴子已经被作者于"+Format.getDateTime()+"编辑过][/align]";
  675.          try{
  677.          User tempUser=new User(userName,userPassword,4);
  678. DBConnect dbc=new DBConnect();
  679. ResultSet rs;
  680.          int forumID=ParamUtil.getInt(request,"forumID");
  681. int announceID=ParamUtil.getInt(request,"announceID");
  682. int rootID=ParamUtil.getInt(request,"rootID");
  683. dbc.prepareStatement("select * from bbs.bbs1 where announceID=? and rootID=? and userName=?");
  684. dbc.setInt(1,announceID);
  685. dbc.setInt(2,rootID);
  686. dbc.setBytes(3,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  687. rs=dbc.executeQuery();
  688. if(!rs.next())
  689. throw new Exception("<li>对不起，您没有权利编辑此帖子！</li>");
  690.          String subject=ParamUtil.getString(request,"subject","");
  691.          String content=ParamUtil.getString(request,"content","")+"nnnn"+char_changed;
  692.          String expression=ParamUtil.getString(request,"expression","");
  693.          int signFlag=ParamUtil.getInt(request,"signFlag",1);
  694.          int emailFlag=ParamUtil.getInt(request,"emailFlag",0);
  695.          if(subject.equals("")) throw new Exception("没有主体文字");
  697. sql="update bbs.bbs1 set Topic=?,Body=?,DateAndTime=getdate(),length=?,ip=?,expression=?,signflag=?,emailflag=? where announceID=?";
  698. dbc.prepareStatement(sql);
  699. dbc.setBytes(1,(new String(subject.getBytes("ISO-8859-1"),"GBK")).getBytes());
  700. dbc.setBytes(2,(new String(content.getBytes("ISO-8859-1"),"GBK")).getBytes());
  701. dbc.setInt(3,content.length());
  702. dbc.setString(4,request.getRemoteAddr());
  703. dbc.setString(5,expression);
  704. dbc.setInt(6,signFlag);
  705. dbc.setInt(7,emailFlag);
  706. dbc.setInt(8,announceID);
  709. dbc.executeUpdate();
  710. dbc.close();
  711. return "dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID+"#"+announceID;
  712.    }
  713.    catch(UserNotFoundException e){
  714.    throw new Exception("没有发现用户");
  715.    }
  716.    catch(Exception e){
  717.    e.printStackTrace();
  718.    throw new Exception("<Br>"+"<li>"+e.getMessage());
  719. }
  720. }
  721. public String masterSaveMSG(HttpServletRequest request,HttpServletResponse response) throws Exception{
  723. String userName=GCookie.getCookieValue(request,"UJBBUName","");
  725. //String userPassword=ParamUtil.getString(request,"userPassword","");
  726. String sql="";
  727. String char_changed = "[align=right][此贴子已经被"+userName+"于"+Format.getDateTime()+"编辑过][/align]";
  728.          try{
  730.          User tempUser=SkinUtil.checkUser(request,response,4);
  731. DBConnect dbc=new DBConnect();
  732. ResultSet rs;
  733.          int forumID=ParamUtil.getInt(request,"forumID");
  734. int announceID=ParamUtil.getInt(request,"announceID");
  735. int rootID=ParamUtil.getInt(request,"rootID");
  737.          String subject=ParamUtil.getString(request,"subject","");
  738.          String content=ParamUtil.getString(request,"content","")+"nnnn"+char_changed;
  739.          String expression=ParamUtil.getString(request,"expression","");
  740.          int signFlag=ParamUtil.getInt(request,"signFlag",1);
  741.          int emailFlag=ParamUtil.getInt(request,"emailFlag",0);
  742.          if(subject.equals("")) throw new Exception("没有主体文字");
  744. sql="update bbs.bbs1 set Topic=?,Body=?,DateAndTime=getdate(),length=?,ip=?,expression=?,signflag=?,emailflag=? where announceID=?";
  745. dbc.prepareStatement(sql);
  746. dbc.setBytes(1,(new String(subject.getBytes("ISO-8859-1"),"GBK")).getBytes());
  747. dbc.setBytes(2,(new String(content.getBytes("ISO-8859-1"),"GBK")).getBytes());
  748. dbc.setInt(3,content.length());
  749. dbc.setString(4,request.getRemoteAddr());
  750. dbc.setString(5,expression);
  751. dbc.setInt(6,signFlag);
  752. dbc.setInt(7,emailFlag);
  753. dbc.setInt(8,announceID);
  756. dbc.executeUpdate();
  757. dbc.close();
  758. return "dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID+"#"+announceID;
  759.    }
  760.    catch(UserNotFoundException e){
  761.    throw new Exception("没有发现用户");
  762.    }
  763.    catch(Exception e){
  764.    e.printStackTrace();
  765.    throw new Exception("<Br>"+"<li>"+e.getMessage());
  766. }
  767. }
  768. public String addTopic(HttpServletRequest request,HttpServletResponse response) throws Exception{
  770. String userName=ParamUtil.getString(request,"userName","");
  771. String userPassword=ParamUtil.getString(request,"userPassword","");
  772. String sql="";
  774.          try{
  776.          //SkinUtil.userLogin(request,response,2);
  777.          User tempUser=new User(userName,userPassword,2);
  778. DBConnect dbc=new DBConnect();
  779.          int forumID=ParamUtil.getInt(request,"forumID",1);
  780.          String subject=ParamUtil.getString(request,"subject","");
  781.          String content=ParamUtil.getString(request,"content","");
  782.          String expression=ParamUtil.getString(request,"expression","");
  783. int isVote=ParamUtil.getInt(request,"isVote",0);
  784.          int signFlag=ParamUtil.getInt(request,"signFlag",1);
  785.          int emailFlag=ParamUtil.getInt(request,"emailFlag",0);
  786.          if(subject.equals("")) throw new Exception("没有主体文字");
  788. sql="insert into bbs.bbs1(Boardid,ParentID,Child,username,topic,body,DateAndTime,hits,length,rootid,layer,orders,ip,Expression,locktopic,signflag,emailflag,istop,isbest,isvote,times) values "+
  789. "("+
  790. forumID+",0,0,?,?,?,'"+
  791. Format.getDateTime()+"',0,"+
  792. content.length()+",0,1,0,'"+request.getRemoteAddr()+"','"+
  793. expression+".gif',0,"+signFlag+","+emailFlag+",0,0,"+isVote+",0)";
  795. dbc.prepareStatement(sql);
  796. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  797. dbc.setBytes(2,(new String(subject.getBytes("ISO-8859-1"),"GBK")).getBytes());
  798. dbc.setBytes(3,(new String(content.getBytes("ISO-8859-1"),"GBK")).getBytes());
  799. dbc.executeUpdate();
  800. ResultSet rs=dbc.executeQuery("select announceid from bbs.bbs1 order by announceid desc");
  801.          rs.next();
  802.          int announceID=rs.getInt(1);
  803. voteID=announceID;
  804. sql="update bbs.bbs1 set rootid="+announceID+",times="+announceID+" where announceid="+announceID;
  805. dbc.executeUpdate(sql);
  806. String shortTopic="";
  807. if ("".equals(subject))
  808. if(content.length()>21)
  809. shortTopic=content.substring(0,20);
  810. else
  811. shortTopic=content;
  812. else
  813. if(subject.length()>21)
  814. shortTopic=subject.substring(0,20);
  815. else
  816. shortTopic=subject;
  817. ResultSet tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where day(dateandtime)-day(getdate())=0 and boardid="+forumID);
  818.      tmprs.next();
  819.      int forumToday=tmprs.getInt(1);
  820.      tmprs=null;
  821. sql="update bbs.board set lastpostuser=?,lastposttime='"+Format.getDateTime()+"',lastbbsnum=lastbbsnum+1,lasttopicnum=lasttopicnum+1,todaynum="+forumToday+",lastrootid="+announceID+",lasttopic=? where  boardid="+forumID;
  822. dbc.clearParameters();
  823. dbc.prepareStatement(sql);
  824. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  825. dbc.setBytes(2,(new String(shortTopic.getBytes("ISO-8859-1"),"GBK")).getBytes());
  826. dbc.executeUpdate();
  827. tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where day(dateandtime)-day(getdate())=0");
  828.      tmprs.next();
  829.      int allTodays=tmprs.getInt(1);
  830. dbc.executeUpdate("update bbs.config set topicnum=topicnum+1,bbsnum=bbsnum+1,todayNum="+allTodays);
  831. dbc.close();
  832. ForumPropertiesManager.resetManager();
  833. return "dispbbs.jsp?forumID="+forumID+"&rootID="+announceID+"&announceID="+announceID;
  834.    }
  835.    catch(UserNotFoundException e){
  836.    throw new Exception("没有发现用户");
  837.    }
  838.    catch(Exception e){
  839.    e.printStackTrace();
  840.    throw new Exception("<Br>"+"<li>数据库操作失败，请以后再试");
  841. }
  842. }
  843. public String addMSG(HttpServletRequest request,HttpServletResponse response)throws UserNotFoundException ,Exception{
  844. //try{
  845. String userName=ParamUtil.getString(request,"userName","");
  846. String userPassword=ParamUtil.getString(request,"userPassword","");
  847. //SkinUtil.userLogin(request,response,3);
  848. User tempUser=new User(userName,userPassword,3);
  849.          DBConnect dbc=new DBConnect();
  850.          int forumID=this.forumID;
  851.          String subject=ParamUtil.getString(request,"subject","");
  852.          String content=ParamUtil.getString(request,"content","");
  853.          String expression=ParamUtil.getString(request,"expression","face7.gif");
  854. String sql="";
  855. int rootID=ParamUtil.getInt(request,"rootID");
  856. ResultSet rs;
  857. dbc.prepareStatement("select locktopic from bbs.bbs1 where announceid="+rootID);
  858. rs=dbc.executeQuery();
  859. if(!rs.next()){
  860. dbc.close();
  861. throw new Exception("<li>对不起，没有发现此主题！</li>");
  862. }
  863. else{
  864. //rs.next();
  865. if(rs.getInt(1)==1||rs.getInt(1)==2){
  866. dbc.close();
  867. throw new Exception("对不起，此帖子已经锁定，您不能回复！");
  868. }
  869. }
  871. int iLayer,iOrders;
  872.          int signFlag=ParamUtil.getInt(request,"signFlag",1);
  873.          int emailFlag=ParamUtil.getInt(request,"emailFlag",0);
  875. int parentID=ParamUtil.getInt(request,"parentID",rootID);
  876. sql="select layer,orders from bbs.bbs1 where announceid="+parentID;
  877. rs=dbc.executeQuery(sql);
  878. if(rs.next()){
  879. if(rs.getString(1)!=null)
  880. iLayer=0;
  881. else
  882. iLayer=rs.getInt(1);
  883. if(rs.getString(2)!=null)
  884. iOrders=0;
  885. else
  886. iOrders=rs.getInt(2);
  887. }
  888. else{
  889. iLayer=0;
  890. iOrders=0;
  891. }
  892. rs.close();
  893. if (rootID!=0){
  894. iLayer=iLayer+1;
  895. dbc.executeUpdate("update bbs.bbs1 set orders=orders+1 where rootid="+rootID+" and orders>"+iOrders);
  896. iOrders=iOrders+1;
  897.       }
  898.          sql="insert into bbs.bbs1(Boardid,ParentID,Child,username,topic,body,DateAndTime,hits,length,rootid,layer,orders,ip,Expression,locktopic,signflag,emailflag,istop,isbest,isvote,times) values "+
  899. "("+
  900. forumID+","+parentID+",0,"+
  901. "?,?,?,'"+
  902. Format.getDateTime()+"',0,"+
  903. content.length()+","+rootID+","+iLayer+","+iOrders+",'"+request.getRemoteAddr()+"','"+
  904. expression+"',0,"+signFlag+","+emailFlag+",0,0,0,0)";
  905. dbc.prepareStatement(sql);
  906. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  907. dbc.setBytes(2,(new String(subject.getBytes("ISO-8859-1"),"GBK")).getBytes());
  908. dbc.setBytes(3,(new String(content.getBytes("ISO-8859-1"),"GBK")).getBytes());
  909. dbc.executeUpdate();
  910. rs=dbc.executeQuery("select announceid from bbs.bbs1 order by announceid desc");
  911.          rs.next();
  912.          int announceID=rs.getInt(1);
  913. sql="update bbs.bbs1 set child=child+1,times="+announceID+" where rootID="+rootID;
  914.            dbc.executeUpdate(sql);
  915.            String shortTopic="";
  917.            if ("".equals(subject))
  918. if(content.length()>21)
  919. shortTopic=content.substring(0,20);
  920. else
  921. shortTopic=content;
  922. else
  923. if(subject.length()>21)
  924. shortTopic=subject.substring(0,20);
  925. else
  926. shortTopic=subject;
  927. ResultSet tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where day(dateandtime)-day(getdate())=0 and boardid="+forumID);
  928.      tmprs.next();
  929.      int forumToday=tmprs.getInt(1);
  930.      tmprs=null;
  932. sql="update bbs.board set lastpostuser=?,lastposttime='"+Format.getDateTime()+"',lastbbsnum=lastbbsnum+1,todaynum="+forumToday+",lastrootid="+rootID+",lasttopic=? where  boardid="+forumID;
  933. dbc.clearParameters();
  934. dbc.prepareStatement(sql);
  935. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  936. dbc.setBytes(2,(new String(shortTopic.getBytes("ISO-8859-1"),"GBK")).getBytes());
  937. dbc.executeUpdate();
  938. tmprs=dbc.executeQuery("Select count(announceid) from bbs.bbs1 Where day(dateandtime)-day(getdate())=0");
  939.      tmprs.next();
  940.      int allTodays=tmprs.getInt(1);
  941. dbc.executeUpdate("update bbs.config set bbsnum=bbsnum+1,todayNum="+allTodays);
  942. dbc.close();
  943. ForumPropertiesManager.resetManager();
  944. return "dispbbs.jsp?forumID="+forumID+"&rootID="+rootID+"&announceID="+announceID+"#"+announceID;
  947. }
  948. public String addVote(HttpServletRequest request,HttpServletResponse response) throws Exception{
  949. try{
  951. String vote=ParamUtil.getString(request,"vote");
  952. String userName=ParamUtil.getString(request,"userName","");
  953. if(vote==null) throw new Exception("<li>请您输入选举内容</li>");
  954. String voteNum="";
  956. String reg="(r|n)";
  957. String [] tempString=vote.split(reg);
  960. for(int i=0;i<tempString.length;i++)
  962. if(!tempString[i].trim().equals(""))
  963. if(i==tempString.length-1)
  964. voteNum+="0";
  965. else
  966. voteNum+="0|";
  975. int voteType=ParamUtil.getInt(request,"voteType",0);
  977. String url=this.addTopic(request,response);
  978. DBConnect dbc=new DBConnect("insert into bbs.vote(announceID,vote,voteNum,voteType,voteUser) values(?,?,?,?,?)");
  979. dbc.setInt(1,voteID);
  980. dbc.setBytes(2,(new String(vote.getBytes("ISO-8859-1"),"GBK")).getBytes());
  981. dbc.setString(3,voteNum);
  982. dbc.setInt(4,voteType);
  983. dbc.setBytes(5,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  984. dbc.executeUpdate();
  985. dbc.close();
  986. return url;
  987. }
  988. catch(Exception e){
  989. e.printStackTrace();
  990. throw new Exception(e.getMessage());
  991. }
  993. }
  994. public ForumVote getForumVote(int announceID) throws Exception{
  995. DBConnect dbc=new DBConnect("select * from bbs.vote where announceID=?");
  996. dbc.setInt(1,announceID);
  997. ResultSet rs=dbc.executeQuery();
  998. if(rs.next()){
  999. ForumVote forumVote=new ForumVote();
  1000. forumVote.setVoteID(rs.getInt(1));
  1001. forumVote.setAnnounceID(rs.getInt(2));
  1002. forumVote.setVote(rs.getString(3));
  1003. forumVote.setVoteNum(rs.getString(4));
  1004. forumVote.setVoteUser(rs.getString(5));
  1005. forumVote.setVoteType(rs.getInt(6));
  1006. return forumVote;
  1007. }
  1008. else
  1009. throw new Exception("<li>错误，对不起，没有发现投票！</li>");
  1010. }
  1011. public String addVoteNum(HttpServletRequest request,HttpServletResponse response) throws Exception {
  1012. String userName=GCookie.getCookieValue(request,"UJBBUName","");
  1013. String userPassword=GCookie.getCookieValue(request,"UJBBUPSW","");
  1014. User tempUser=new User(userName,userPassword,1);
  1015. int announceID=ParamUtil.getInt(request,"announceID");
  1016. int forumID=ParamUtil.getInt(request,"forumID");
  1017. ForumVote theVote=this.getForumVote(announceID);
  1018. String voteNum="";
  1019. int [] voteNumS=theVote.getVoteNumS();
  1020. if(theVote.getUserSign(userName))
  1021. throw new Exception("<li>对不起，您已经投票了！</li>");
  1022. else{
  1023. if(theVote.getVoteType()==0){
  1024. int postID=ParamUtil.getInt(request,"postVote");
  1025. voteNumS[postID]++;
  1026. }
  1027. else{
  1028. for(int i=0;i<voteNumS.length;i++){
  1029. if(ParamUtil.getString(request,"postVote_"+(i))!=null)
  1030. voteNumS[i]++;
  1031. }
  1032. }
  1034. for(int i=0;i<voteNumS.length;i++)
  1035. if(i==voteNumS.length-1)
  1036. voteNum+=Integer.toString(voteNumS[i]);
  1037. else
  1038. voteNum+=Integer.toString(voteNumS[i])+"|";
  1040. }
  1041. DBConnect dbc=new DBConnect("select * from bbs.vote where announceID="+announceID);
  1042. ResultSet rs=dbc.executeQuery();
  1043. rs.next();
  1044. String voteUser=rs.getString(5);
  1045. voteUser+="|"+userName;
  1046. dbc.prepareStatement("update bbs.vote set voteNum='"+voteNum+"',voteUser=? where announceID="+announceID);
  1047. dbc.setBytes(1,(new String(voteUser.getBytes("ISO-8859-1"),"GBK")).getBytes());
  1048. dbc.executeUpdate();
  1050. return "dispbbs.jsp?forumID="+forumID+"&rootID="+announceID+"&announceID="+announceID;
  1054. }
  1055. }