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

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

Java书籍

开发平台：

Java

ForumFactory.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.forum.*;
  11. import net.acai.database.DBConnect;
  12. import net.acai.util.*;
  13. import java.util.Vector;
  14. import java.sql.ResultSet;
  15. import javax.servlet.http.*;
  17. public class ForumFactory{
  19. public static Vector getForums(int gateWayID)
  20. throws ForumNotFoundException{
  21. try{
  22. DBConnect dbc=new DBConnect("select * from bbs.board where class=?");
  24. dbc.setInt(1,gateWayID);
  25. Vector forumVector=new Vector();
  26. ResultSet rs=dbc.executeQuery();
  27. while(rs.next()){
  28. int forumID=rs.getInt(1);
  29. Forum theForum=new Forum(forumID);
  30. forumVector.add(theForum);
  31. }
  32. dbc.close();
  33. return forumVector;
  34. }
  35. catch(Exception e){
  36. throw new ForumNotFoundException("字符出错");
  37. }
  38. }
  39. public static Forum getForum(int forumID) throws ForumNotFoundException{
  40. try{
  41. Forum theForum=new Forum(forumID);
  42. return theForum;
  43. }
  44. catch(Exception e){
  45. e.printStackTrace();
  46. throw new ForumNotFoundException();
  47. }
  48. }
  49. public static Forum getForum(HttpServletRequest request,HttpServletResponse response,HttpSession session,int forumID) throws ForumNotFoundException{
  51. Forum theForum=new Forum(request,response,forumID);
  52. return theForum;
  54. }
  57. public static Vector getOLUsers(String sign){
  58. try{
  59. DBConnect dbc=new DBConnect("select * from bbs.online order by id");
  60. Vector forumOLUsers=null;
  61. forumOLUsers=new Vector();
  62. ResultSet rs;
  63. rs=dbc.executeQuery();
  64. while(rs.next()){
  65. if(sign.equals("guest")&&rs.getString(2).equals("guest")){
  66. OLUser tempOLUser=new OLUser();
  67. tempOLUser.setUserID(rs.getInt(1));
  68. tempOLUser.setUserName(rs.getString(2));
  69. tempOLUser.setUserClass(rs.getString(3));
  70. tempOLUser.setStats(rs.getString(4));
  71. tempOLUser.setUserIP(rs.getString(5));
  72. tempOLUser.setStartTime(rs.getString(6));
  73. tempOLUser.setLastTimeBK(rs.getString(7));
  74. tempOLUser.setLastTime(rs.getString(8));
  75. tempOLUser.setBrowser(rs.getString(9));
  76. tempOLUser.setActForIP(rs.getString(10));
  77. tempOLUser.setComeFrom(rs.getString(11));
  78. tempOLUser.setActCome(rs.getString(12));
  79. forumOLUsers.add(tempOLUser);
  80. }
  81. else if(sign.equals("member")&&!rs.getString(2).equals("guest")){
  82. OLUser tempOLUser=new OLUser();
  83. tempOLUser.setUserID(rs.getInt(1));
  84. tempOLUser.setUserName(rs.getString(2));
  85. tempOLUser.setUserClass(rs.getString(3));
  86. tempOLUser.setStats(rs.getString(4));
  87. tempOLUser.setUserIP(rs.getString(5));
  88. tempOLUser.setStartTime(rs.getString(6));
  89. tempOLUser.setLastTimeBK(rs.getString(7));
  90. tempOLUser.setLastTime(rs.getString(8));
  91. tempOLUser.setBrowser(rs.getString(9));
  92. tempOLUser.setActForIP(rs.getString(10));
  93. tempOLUser.setComeFrom(rs.getString(11));
  94. tempOLUser.setActCome(rs.getString(12));
  95. forumOLUsers.add(tempOLUser);
  96. }
  97. else if(sign.equals("total")){
  98. OLUser tempOLUser=new OLUser();
  99. tempOLUser.setUserID(rs.getInt(1));
  100. tempOLUser.setUserName(rs.getString(2));
  101. tempOLUser.setUserClass(rs.getString(3));
  102. tempOLUser.setStats(rs.getString(4));
  103. tempOLUser.setUserIP(rs.getString(5));
  104. tempOLUser.setStartTime(rs.getString(6));
  105. tempOLUser.setLastTimeBK(rs.getString(7));
  106. tempOLUser.setLastTime(rs.getString(8));
  107. tempOLUser.setBrowser(rs.getString(9));
  108. tempOLUser.setActForIP(rs.getString(10));
  109. tempOLUser.setComeFrom(rs.getString(11));
  110. tempOLUser.setActCome(rs.getString(12));
  111. forumOLUsers.add(tempOLUser);
  113. }
  115. }
  117. dbc.close();
  118. return forumOLUsers;
  119. }
  120. catch(Exception e){
  121. e.printStackTrace();
  122. return null;
  123. //throw new ForumNotFoundException("字符出错");
  124. }
  125. }
  127. public static Vector getOLGuestUsers(){
  128. return getOLUsers("guest");
  129. }
  130. public static int getOLGuestUsersNum(){
  131. return getOLGuestUsers().size();
  132. }
  133. public static Vector getOLMemberUsers(){
  134. return getOLUsers("member");
  135. }
  136. public static int getOLMemberUsersNum(){
  137. return getOLMemberUsers().size();
  138. }
  140. public static int getOLUsersNum(){
  141. return getOLUsers("total").size();
  142. }
  143. public static void addUser(HttpServletRequest request,int wealthReg,int epReg,int cpReg) throws Exception{
  144. String userName=ParamUtil.getString(request,"userName","");
  146. String psw=ParamUtil.getString(request,"psw","");
  147. String userPassword="";
  148. String pswc=ParamUtil.getString(request,"pswc","");
  149. String userEmail=ParamUtil.getString(request,"userEmail","");
  150. String face=ParamUtil.getString(request,"face","");
  151. int width=ParamUtil.getInt(request,"width",0);
  152. int height=ParamUtil.getInt(request,"height",0);
  153. String oicq=ParamUtil.getString(request,"oicq");
  154. String sign=ParamUtil.getString(request,"sign","");
  155. String myFace=ParamUtil.getString(request,"myface","");
  156. boolean foundErr=false;
  157. String errMSG="";
  158. int sex=0;
  159. int showRe=0;
  160. if("".equals(userName)||userName.length()>20)
  161. {
  162. errMSG=errMSG+"<br>"+"<li>请输入您的用户名(长度不能大于20)。";
  163. foundErr=true;
  164. }
  165. if (userName.indexOf('=')>-1||userName.indexOf('%')>-1||userName.indexOf('?')>-1||userName.indexOf('&')>-1 || userName.indexOf(';')>-1 ||userName.indexOf(',')>0 || userName.indexOf(''')>-1 || userName.indexOf('+') >-1){
  166. errMSG=errMSG+"<br>"+"<li>用户名中含有非法字符。";
  167. foundErr=true;
  168. }
  169. try{
  170. sex=ParamUtil.getInt(request,"sex");
  171. }
  172. catch(NumberFormatException e)
  173. {
  174. errMSG=errMSG+"<br>"+"<li>请选择您的性别。";
  175. foundErr=true;
  176. }
  177. try{
  178. showRe=ParamUtil.getInt(request,"showRe");
  179. }
  180. catch(NumberFormatException e){
  181. errMSG=errMSG+"<br>"+"<li>请选择您的帖子有回复时是否要提示您。";
  182. foundErr=true;
  183. }
  184. if("".equals(psw) || psw.length()>10){
  185. errMSG=errMSG+"<br>"+"<li>请输入您的密码(长度不能大于10)。";
  186. foundErr=true;
  187. }
  188. if (!pswc.equals(psw)){
  189. errMSG=errMSG+"<br>"+"<li>您输入的密码和确认密码不一致。";
  190. foundErr=true;
  191. }
  192. else
  193. userPassword=psw;
  195. if (userEmail.indexOf('@')<0||userEmail.indexOf('.')<0){
  196. errMSG=errMSG+"<br>"+"<li>您的Email有错误。";
  197.     foundErr=true;
  198.     }
  199.     if (!"".equals(myFace)){
  200.     if (width==0 || height==0){
  201. errMSG=errMSG+"<br>"+"<li>请输入图片的宽度和高度。";
  202. foundErr=true;
  203. }
  204. else if (width<20|| width>80){
  205. errMSG=errMSG+"<br>"+"<li>您输入的图片宽度不符合标准。";
  206. foundErr=true;
  207. }
  208. else if (height<20 || height>80){
  209. errMSG=errMSG+"<br>"+"<li>您输入的图片高度不符合标准。";
  210. foundErr=true;
  211. }
  212. else face=myFace;
  214. }
  215. else
  216. if ("".equals(face)){
  217. errMSG=errMSG+"<br>"+"<li>请选择您的个性头像。";
  218. foundErr=true;
  219. }
  220. else if (face.endsWith(".gif")){
  221. width=32;
  222. height=32;
  223. }
  224. else{
  226. errMSG=errMSG+"<br>"+"<li>您选择了错误的头像。";
  227. foundErr=true;
  228. }
  229. if(oicq==null)
  230. oicq="";
  231. else
  232. try{
  233. Integer.parseInt(oicq);
  234. }
  235. catch(NumberFormatException e)
  236. {
  238. errMSG=errMSG+"<br>"+"<li>Oicq号码只能是4-10位数字，您可以选择不输入。";
  239. foundErr=true;
  240. }
  242. if(!foundErr)
  243. {
  244. try{
  245. DBConnect dbc=new DBConnect("select * from bbs.myuser where username=?");
  246. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  248. ResultSet rs=dbc.executeQuery();
  249. if(rs.next()){
  250. dbc.close();
  251. throw new UserAlreadyExistException();
  252. }
  253. MD5 md5=new MD5();
  254. dbc.clearParameters();
  255. dbc.prepareStatement("insert into bbs.myuser ( userName,userPassword,userEmail,userClass,sign,oicq,article,lockuser,sex,showRe,addDate,face,width,height,logins,lastlogin,userWealth,userEP,userCP) values( ?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
  256. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  257. dbc.setBytes(2,(new String(md5.getMD5ofStr(userPassword).getBytes("ISO-8859-1"),"GBK")).getBytes());
  258. dbc.setBytes(3,(new String(userEmail.getBytes("ISO-8859-1"),"GBK")).getBytes());
  259. dbc.setInt(4,1);
  260. dbc.setBytes(5,(new String(sign.getBytes("ISO-8859-1"),"GBK")).getBytes());
  261. dbc.setBytes(6,(new String(oicq.getBytes("ISO-8859-1"),"GBK")).getBytes());
  262. dbc.setInt(7,0);
  263. dbc.setInt(8,0);
  264. dbc.setInt(9,sex);
  265. dbc.setInt(10,showRe);
  266. dbc.setString(11,Format.getDateTime());
  267. dbc.setBytes(12,(new String(face.getBytes("ISO-8859-1"),"GBK")).getBytes());
  268. dbc.setInt(13,width);
  269. dbc.setInt(14,height);
  270. dbc.setInt(15,1);
  271. dbc.setString(16,Format.getDateTime());
  272. dbc.setInt(17,wealthReg);
  273. dbc.setInt(18,epReg);
  274. dbc.setInt(19,cpReg);
  275. dbc.executeUpdate();
  277. dbc.clearParameters();
  278. dbc.prepareStatement("update bbs.config set usernum=usernum+1,lastUser=?");
  279. dbc.setBytes(1,userName.getBytes());
  280. dbc.executeUpdate();
  282. String forumName=ForumPropertiesManager.getString("ForumName");
  283. String sender=forumName;
  284. String title=forumName+"欢迎您的到来";
  285. String body=forumName+"全体管理人员欢迎您的到来n如有任何疑问请及时联系系统管理员。n如有任何使用上的问题请查看论坛帮助。n感谢您注册本系统，让我们一起来建设这个网上家园！";
  286. String sql="insert into bbs.message(incept,sender,title,content,sendtime,flag,issend) values(?,?,?,?,getdate(),0,1)";
  287. dbc.prepareStatement(sql);
  288. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  289. dbc.setBytes(2,(new String(sender.getBytes("ISO-8859-1"),"GBK")).getBytes());
  290. dbc.setBytes(3,(new String(title.getBytes("ISO-8859-1"),"GBK")).getBytes());
  291. dbc.setBytes(4,(new String(body.getBytes("ISO-8859-1"),"GBK")).getBytes());
  292. dbc.executeUpdate();
  293. dbc.close();
  294. ForumPropertiesManager.resetManager();
  295. }
  296. catch(UserAlreadyExistException e){
  297. errMSG=errMSG+"<br>"+"<li>对不起，您输入的用户名已经被注册，请重新输入。";
  298. throw new Exception(errMSG);
  299. }
  300. catch(Exception e){
  301. e.printStackTrace();
  302. throw e;
  303. }
  305. }
  306. if(foundErr)
  307. throw new Exception(errMSG);
  308. }
  313. }