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

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

Java书籍

开发平台：

Java

UserManager.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.*;
  12. import java.sql.*;
  13. import java.util.Vector;
  14. import javax.servlet.http.*;
  15. import net.acai.util.*;
  16. public class UserManager{
  17. public static void createUser(String username,String password)
  18. throws UserAlreadyExistException,Exception{
  19. DBConnect dbc=new DBConnect("select * from bbs.myuser where UserName=?");
  20. dbc.setBytes(1,(new String(username.getBytes("ISO-8859-1"),"GBK")).getBytes());
  21. java.sql.ResultSet rs=dbc.executeQuery();
  22. if(rs.next())
  23. throw new UserAlreadyExistException();
  24. else{
  25. dbc.clearParameters();
  26. dbc.prepareStatement("insert into bbs.myuser (UserName,UserPassword) values(?,?)");
  27. dbc.setString(1,username);
  28. dbc.setString(2,password);
  29. dbc.executeUpdate();
  30. }
  31. dbc.close();
  32. }
  33. public static User findUser(String userName) throws UserNotFoundException,Exception{
  34. try{
  35. DBConnect dbc=new DBConnect("select * from bbs.myuser where UserName like ?");
  36. dbc.setBytes(1,(new String(userName.trim().getBytes("ISO-8859-1"),"GBK")).getBytes());
  37. ResultSet rs=dbc.executeQuery();
  38. if(rs.next()){
  39. //此处对USER的各种属性进行定义了
  40. User tempUser=new User();
  41. tempUser.setUserID(rs.getInt(1));
  42. tempUser.setUserName(rs.getString(2));
  43. tempUser.setUserEmail(rs.getString(3));
  44. tempUser.setArticle(rs.getInt(4));
  45. tempUser.setUserPassword(rs.getString(5));
  46. tempUser.setSign(rs.getString(6));
  47. tempUser.setSex(rs.getString(7));
  48. tempUser.setHomePage(rs.getString(8));
  49. tempUser.setAddDate(rs.getString(9));
  50. tempUser.setLogins(rs.getInt(10));
  51. tempUser.setFace(rs.getString(11));
  52. tempUser.setWidth(rs.getInt(12));
  53. tempUser.setHeight(rs.getInt(13));
  54. tempUser.setOicq(rs.getString(14));
  55. tempUser.setLastLogin(rs.getString(15));
  56. tempUser.setBbsType(rs.getInt(16));
  57. tempUser.setUserClass(rs.getInt(18));
  58. tempUser.setUserGroup(rs.getString(19));
  59. tempUser.setUserWealth(rs.getInt(20));
  60. tempUser.setUserEP(rs.getInt(21));
  61. tempUser.setUserCP(rs.getInt(22));
  62. tempUser.setTitle(rs.getString(23));
  63. tempUser.setReann(rs.getString(25));
  64. dbc.close();
  65. return tempUser;
  66. }
  67. else{
  68. dbc.close();
  69. throw new UserNotFoundException("<li>对不起，没有发现此用户"+userName+"</li>");
  70. }
  72. }
  73. catch(Exception e){
  74. e.printStackTrace();
  75. throw new UserNotFoundException(e.getMessage());
  76. }
  78. }
  79. public static Vector findUsers(String userName) throws UserNotFoundException,Exception{
  80. try{
  81. DBConnect dbc=new DBConnect("select * from bbs.myuser where UserName like ?");
  82. dbc.setBytes(1,(new String(("%"+userName.trim()+"%").getBytes("ISO-8859-1"),"GBK")).getBytes());
  83. ResultSet rs=dbc.executeQuery();
  84. if(!rs.next()){
  85. dbc.close();
  86. throw new Exception();
  87. }
  88. Vector userVector=new Vector();
  89. do{
  90. //此处对USER的各种属性进行定义了
  91. User tempUser=new User();
  92. tempUser.setUserID(rs.getInt(1));
  93. tempUser.setUserName(rs.getString(2));
  94. tempUser.setUserEmail(rs.getString(3));
  95. tempUser.setArticle(rs.getInt(4));
  96. tempUser.setUserPassword(rs.getString(5));
  97. tempUser.setSign(rs.getString(6));
  98. tempUser.setSex(rs.getString(7));
  99. tempUser.setHomePage(rs.getString(8));
  100. tempUser.setAddDate(rs.getString(9));
  101. tempUser.setLogins(rs.getInt(10));
  102. tempUser.setFace(rs.getString(11));
  103. tempUser.setWidth(rs.getInt(12));
  104. tempUser.setHeight(rs.getInt(13));
  105. tempUser.setOicq(rs.getString(14));
  106. tempUser.setLastLogin(rs.getString(15));
  107. tempUser.setBbsType(rs.getInt(16));
  108. tempUser.setUserClass(rs.getInt(18));
  109. tempUser.setUserGroup(rs.getString(19));
  110. tempUser.setUserWealth(rs.getInt(20));
  111. tempUser.setUserEP(rs.getInt(21));
  112. tempUser.setUserCP(rs.getInt(22));
  113. tempUser.setTitle(rs.getString(23));
  114. tempUser.setReann(rs.getString(25));
  115. userVector.add(tempUser);
  117. }
  118. while(rs.next());
  119. dbc.close();
  120. return userVector;
  122. }
  123. catch(Exception e){
  124. e.printStackTrace();
  125. throw new UserNotFoundException(e.getMessage());
  126. }
  128. }
  129. public static void updateUser(HttpServletRequest request) throws Exception{
  130. String userName=ParamUtil.getString(request,"userName","");
  131. String userPassword=ParamUtil.getString(request,"userPassword","");
  132. String userEmail=ParamUtil.getString(request,"userEmail","");
  133. String face=ParamUtil.getString(request,"face","");
  134. int width=ParamUtil.getInt(request,"width",0);
  135. int height=ParamUtil.getInt(request,"height",0);
  136. String oicq=ParamUtil.getString(request,"oicq");
  137. String sign=ParamUtil.getString(request,"sign","");
  138. String myFace=ParamUtil.getString(request,"myface","");
  139. boolean foundErr=false;
  140. String errMSG="";
  141. int sex=0;
  142. int showRe=0;
  143. if("".equals(userName)||userName.length()>20)
  144. {
  145. errMSG=errMSG+"<br>"+"<li>请输入您的用户名(长度不能大于20)。";
  146. foundErr=true;
  147. }
  148. 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){
  149. errMSG=errMSG+"<br>"+"<li>用户名中含有非法字符。";
  150. foundErr=true;
  151. }
  152. try{
  153. sex=ParamUtil.getInt(request,"sex");
  154. }
  155. catch(NumberFormatException e)
  156. {
  157. errMSG=errMSG+"<br>"+"<li>请选择您的性别。";
  158. foundErr=true;
  159. }
  163. if (userEmail.indexOf('@')<0||userEmail.indexOf('.')<0){
  164. errMSG=errMSG+"<br>"+"<li>您的Email有错误。";
  165.     foundErr=true;
  166.     }
  167.     if (!"".equals(myFace)){
  168.     if (width==0 || height==0){
  169. errMSG=errMSG+"<br>"+"<li>请输入图片的宽度和高度。";
  170. foundErr=true;
  171. }
  172. else if (width<20|| width>80){
  173. errMSG=errMSG+"<br>"+"<li>您输入的图片宽度不符合标准。";
  174. foundErr=true;
  175. }
  176. else if (height<20 || height>80){
  177. errMSG=errMSG+"<br>"+"<li>您输入的图片高度不符合标准。";
  178. foundErr=true;
  179. }
  180. else face=myFace;
  182. }
  183. else
  184. if ("".equals(face)){
  185. errMSG=errMSG+"<br>"+"<li>请选择您的个性头像。";
  186. foundErr=true;
  187. }
  188. else if (face.endsWith(".gif")){
  189. width=32;
  190. height=32;
  191. }
  192. else{
  194. errMSG=errMSG+"<br>"+"<li>您选择了错误的头像。";
  195. foundErr=true;
  196. }
  197. if(oicq==null)
  198. oicq="";
  199. else
  200. try{
  201. Integer.parseInt(oicq);
  202. }
  203. catch(NumberFormatException e)
  204. {
  206. errMSG=errMSG+"<br>"+"<li>Oicq号码只能是4-10位数字，您可以选择不输入。";
  207. foundErr=true;
  208. }
  210. if(!foundErr)
  211. {
  212. try{
  213. DBConnect dbc=new DBConnect("select * from bbs.myuser where username=? ");
  214. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  217. ResultSet rs=dbc.executeQuery();
  218. if(rs.next()){
  219. MD5 md5=new MD5();
  220. dbc.clearParameters();
  221. dbc.prepareStatement("update bbs.myuser set userPassword=?,userEmail=?,sign=?,oicq=?,sex=?,face=?,width=?,height=? where userName=?");
  222. dbc.setBytes(1,(new String(md5.getMD5ofStr(userPassword).getBytes("ISO-8859-1"),"GBK")).getBytes());
  223. dbc.setBytes(2,(new String(userEmail.getBytes("ISO-8859-1"),"GBK")).getBytes());
  224. dbc.setBytes(3,(new String(sign.getBytes("ISO-8859-1"),"GBK")).getBytes());
  225. dbc.setBytes(4,(new String(oicq.getBytes("ISO-8859-1"),"GBK")).getBytes());
  226. dbc.setInt(5,sex);
  227. dbc.setBytes(6,(new String(face.getBytes("ISO-8859-1"),"GBK")).getBytes());
  228. dbc.setInt(7,width);
  229. dbc.setInt(8,height);
  230. dbc.setBytes(9,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  231. dbc.executeUpdate();
  234. }
  236. else
  237. throw new UserNotFoundException();
  240. //ForumPropertiesManager.resetManager();
  241. dbc.close();
  242. }
  243. catch(UserNotFoundException e){
  244. errMSG=errMSG+"<br>"+"<li>对不起，您输入的用户名已经被注册，请重新输入。";
  245. throw new Exception(errMSG);
  246. }
  247. catch(Exception e){
  248. e.printStackTrace();
  249. throw e;
  250. }
  252. }
  253. if(foundErr)
  254. throw new Exception(errMSG);
  255. }
  256. public static void delUser(HttpServletRequest request) throws Exception{
  257. String [] userID=request.getParameterValues("userID");
  258. DBConnect dbc=new DBConnect();
  259. String sql;
  260. for(int i=0;i<userID.length;i++){
  261. sql="delete from bbs.myuser where userID="+userID[i];
  262. dbc.executeUpdate(sql);
  263. }
  264. dbc.close();
  267. }
  268. public static void addAdmin(HttpServletRequest request,int wealthReg,int epReg,int cpReg) throws Exception{
  269. String userName=ParamUtil.getString(request,"userName","");
  271. String psw=ParamUtil.getString(request,"psw","");
  272. String userPassword="";
  273. String pswc=ParamUtil.getString(request,"pswc","");
  274. String userEmail=ParamUtil.getString(request,"userEmail","");
  275. String face=ParamUtil.getString(request,"face","");
  276. int width=ParamUtil.getInt(request,"width",0);
  277. int height=ParamUtil.getInt(request,"height",0);
  278. String oicq=ParamUtil.getString(request,"oicq");
  279. String sign=ParamUtil.getString(request,"sign","");
  280. String myFace=ParamUtil.getString(request,"myface","");
  281. boolean foundErr=false;
  282. String errMSG="";
  283. int sex=0;
  284. int showRe=0;
  285. if("".equals(userName)||userName.length()>20)
  286. {
  287. errMSG=errMSG+"<br>"+"<li>请输入您的用户名(长度不能大于20)。";
  288. foundErr=true;
  289. }
  290. 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){
  291. errMSG=errMSG+"<br>"+"<li>用户名中含有非法字符。";
  292. foundErr=true;
  293. }
  294. try{
  295. sex=ParamUtil.getInt(request,"sex");
  296. }
  297. catch(NumberFormatException e)
  298. {
  299. errMSG=errMSG+"<br>"+"<li>请选择您的性别。";
  300. foundErr=true;
  301. }
  302. try{
  303. showRe=ParamUtil.getInt(request,"showRe");
  304. }
  305. catch(NumberFormatException e){
  306. errMSG=errMSG+"<br>"+"<li>请选择您的帖子有回复时是否要提示您。";
  307. foundErr=true;
  308. }
  309. if("".equals(psw) || psw.length()>10){
  310. errMSG=errMSG+"<br>"+"<li>请输入您的密码(长度不能大于10)。";
  311. foundErr=true;
  312. }
  313. if (!pswc.equals(psw)){
  314. errMSG=errMSG+"<br>"+"<li>您输入的密码和确认密码不一致。";
  315. foundErr=true;
  316. }
  317. else
  318. userPassword=psw;
  320. if (userEmail.indexOf('@')<0||userEmail.indexOf('.')<0){
  321. errMSG=errMSG+"<br>"+"<li>您的Email有错误。";
  322.     foundErr=true;
  323.     }
  324.     if (!"".equals(myFace)){
  325.     if (width==0 || height==0){
  326. errMSG=errMSG+"<br>"+"<li>请输入图片的宽度和高度。";
  327. foundErr=true;
  328. }
  329. else if (width<20|| width>80){
  330. errMSG=errMSG+"<br>"+"<li>您输入的图片宽度不符合标准。";
  331. foundErr=true;
  332. }
  333. else if (height<20 || height>80){
  334. errMSG=errMSG+"<br>"+"<li>您输入的图片高度不符合标准。";
  335. foundErr=true;
  336. }
  337. else face=myFace;
  339. }
  340. else
  341. if ("".equals(face)){
  342. errMSG=errMSG+"<br>"+"<li>请选择您的个性头像。";
  343. foundErr=true;
  344. }
  345. else if (face.endsWith(".gif")){
  346. width=32;
  347. height=32;
  348. }
  349. else{
  351. errMSG=errMSG+"<br>"+"<li>您选择了错误的头像。";
  352. foundErr=true;
  353. }
  354. if(oicq==null)
  355. oicq="";
  356. else
  357. try{
  358. Integer.parseInt(oicq);
  359. }
  360. catch(NumberFormatException e)
  361. {
  363. errMSG=errMSG+"<br>"+"<li>Oicq号码只能是4-10位数字，您可以选择不输入。";
  364. foundErr=true;
  365. }
  367. if(!foundErr)
  368. {
  369. try{
  370. DBConnect dbc=new DBConnect("select * from bbs.myuser where username=?");
  371. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  373. ResultSet rs=dbc.executeQuery();
  374. if(rs.next()){
  375. dbc.close();
  376. throw new UserAlreadyExistException();
  377. }
  378. MD5 md5=new MD5();
  379. dbc.clearParameters();
  380. 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( ?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
  381. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  382. dbc.setBytes(2,(new String(md5.getMD5ofStr(userPassword).getBytes("ISO-8859-1"),"GBK")).getBytes());
  383. dbc.setBytes(3,(new String(userEmail.getBytes("ISO-8859-1"),"GBK")).getBytes());
  384. dbc.setInt(4,20);
  385. dbc.setBytes(5,(new String(sign.getBytes("ISO-8859-1"),"GBK")).getBytes());
  386. dbc.setBytes(6,(new String(oicq.getBytes("ISO-8859-1"),"GBK")).getBytes());
  387. dbc.setInt(7,0);
  388. dbc.setInt(8,0);
  389. dbc.setInt(9,sex);
  390. dbc.setInt(10,showRe);
  391. dbc.setString(11,Format.getDateTime());
  392. dbc.setBytes(12,(new String(face.getBytes("ISO-8859-1"),"GBK")).getBytes());
  393. dbc.setInt(13,width);
  394. dbc.setInt(14,height);
  395. dbc.setInt(15,1);
  396. dbc.setString(16,Format.getDateTime());
  397. dbc.setInt(17,wealthReg);
  398. dbc.setInt(18,epReg);
  399. dbc.setInt(19,cpReg);
  400. dbc.executeUpdate();
  402. dbc.clearParameters();
  403. dbc.prepareStatement("update bbs.config set usernum=usernum+1,lastUser=?");
  404. dbc.setBytes(1,userName.getBytes());
  405. dbc.executeUpdate();
  407. String forumName=ForumPropertiesManager.getString("ForumName");
  408. String sender=forumName;
  409. String title=forumName+"欢迎您的到来";
  410. String body=forumName+"全体管理人员欢迎您的到来n如有任何疑问请及时联系系统管理员。n如有任何使用上的问题请查看论坛帮助。n感谢您注册本系统，让我们一起来建设这个网上家园！";
  411. String sql="insert into bbs.message(incept,sender,title,content,sendtime,flag,issend) values(?,?,?,?,getdate(),0,1)";
  412. dbc.prepareStatement(sql);
  413. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  414. dbc.setBytes(2,(new String(sender.getBytes("ISO-8859-1"),"GBK")).getBytes());
  415. dbc.setBytes(3,(new String(title.getBytes("ISO-8859-1"),"GBK")).getBytes());
  416. dbc.setBytes(4,(new String(body.getBytes("ISO-8859-1"),"GBK")).getBytes());
  417. dbc.executeUpdate();
  418. dbc.close();
  419. ForumPropertiesManager.resetManager();
  420. }
  421. catch(UserAlreadyExistException e){
  422. errMSG=errMSG+"<br>"+"<li>对不起，您输入的用户名已经被注册，请重新输入。";
  423. throw new Exception(errMSG);
  424. }
  425. catch(Exception e){
  426. e.printStackTrace();
  427. throw e;
  428. }
  430. }
  431. if(foundErr)
  432. throw new Exception(errMSG);
  433. }
  436. }