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

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

Java书籍

开发平台：

Java

SMSManager.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 javax.servlet.http.*;
  13. import java.sql.*;
  14. import net.acai.util.*;
  15. import java.util.Vector;
  16. public class SMSManager{
  17. String userName,sql;
  18. User theUser;
  19. public SMSManager(HttpServletRequest request,HttpServletResponse response) throws Exception{
  20. userName=GCookie.getCookieValue(request,"UJBBUName","");
  21. theUser=SkinUtil.checkUser(request,response,4);
  22. }
  23. public SMSMSG getSMSMSG(HttpServletRequest request) throws Exception {
  24. return this.getSMSMSG(request,"inbox");
  25. }
  26. public static boolean checkSMS(HttpServletRequest request){
  27. String userName=GCookie.getCookieValue(request,"UJBBUName","");
  28. boolean smsSign=false;
  30. try{
  31. DBConnect dbc=new DBConnect();
  32. String sql="Select Count(id) From bbs.Message Where flag=0 and issend=1 and delR=0 And incept=?";
  33. dbc.prepareStatement(sql);
  34. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  35. ResultSet rs=dbc.executeQuery();
  36. if(rs.next())
  37. smsSign=true;
  38. dbc.close();
  39. }
  40. catch(Exception e){
  42. e.printStackTrace();
  43. }
  44. return smsSign;
  46. }
  47. public static SMSMSG getNewSMS(HttpServletRequest request){
  48. String userName=GCookie.getCookieValue(request,"UJBBUName","");
  51. try{
  52. DBConnect dbc=new DBConnect();
  53. String sql="Select  id,sender From bbs.Message Where flag=0 and issend=1 and delR=0 And incept=?";
  54. dbc.prepareStatement(sql);
  55. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  56. ResultSet rs=dbc.executeQuery();
  57. if(!rs.next()){
  58. dbc.close();
  59. return null;
  60. }
  61. SMSMSG sms=new SMSMSG();
  62. sms.setID(rs.getInt(1));
  63. sms.setSender(rs.getString(2));
  64. dbc.close();
  65. return sms;
  66. }
  67. catch(Exception e){
  69. e.printStackTrace();
  70. return null;
  71. }
  73. }
  74. public SMSMSG getSMSMSG(HttpServletRequest request,String sign) throws Exception {
  75. DBConnect dbc=new DBConnect();
  76. int ID=0;
  77. try{
  78. ID=ParamUtil.getInt(request,"id");
  79. }
  80. catch(Exception e){
  81. throw new Exception("请指定相关参数。");
  82. }
  83. if(sign.equals("fw")){
  84. sql="select * from bbs.message where (incept=? or sender=?) and id="+ID;
  85. dbc.prepareStatement(sql);
  86. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  87. dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  88. }
  89. else if(sign.equals("edit")){
  90. sql="select * from bbs.message where sender=? and issend=0 and id="+ID;
  91. dbc.prepareStatement(sql);
  92. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  93. }
  94. else if(sign.equals("read")){
  95. sql="update bbs.message set flag=1 where ID="+ID;
  96. dbc.executeUpdate(sql);
  97. sql="select * from bbs.message where (incept=? or sender=?) and id="+ID;
  98. dbc.prepareStatement(sql);
  99. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  100. dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  101. }
  102. else {
  103. sql="select * from bbs.message where incept=? and id="+ID;
  104. dbc.prepareStatement(sql);
  105. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  107. }
  108. ResultSet rs=dbc.executeQuery();
  109. rs.next();
  110. SMSMSG sms=new SMSMSG();
  111. sms.setID(rs.getInt(1));
  112. sms.setSender(rs.getString(2));
  113. sms.setIncept(rs.getString(3));
  114. sms.setTitle(rs.getString(4));
  115. sms.setContent(rs.getString(5));
  116. sms.setFlag(rs.getInt(6));
  117. sms.setSendtime(rs.getString(7));
  118. sms.setDelR(rs.getInt(8));
  119. sms.setDelS(rs.getInt(9));
  120. sms.setIsSend(rs.getInt(10));
  121. dbc.close();
  122. return sms;
  123. }
  124. public Vector getInBox() throws Exception{
  125. Vector smsVector=new Vector();
  126. DBConnect dbc=new DBConnect();
  127. sql="select * from bbs.message where incept=? and issend=1 and delR=0 order by flag,sendtime desc";
  128. dbc.prepareStatement(sql);
  129. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  130. ResultSet rs=dbc.executeQuery();
  131. while(rs.next()){
  132. SMSMSG sms=new SMSMSG();
  133. sms.setID(rs.getInt(1));
  134. sms.setSender(rs.getString(2));
  135. sms.setIncept(rs.getString(3));
  136. sms.setTitle(rs.getString(4));
  137. sms.setContent(rs.getString(5));
  138. sms.setFlag(rs.getInt(6));
  139. sms.setSendtime(rs.getString(7));
  140. sms.setDelR(rs.getInt(8));
  141. sms.setDelS(rs.getInt(9));
  142. sms.setIsSend(rs.getInt(10));
  143. smsVector.add(sms);
  144. }
  145. dbc.close();
  146. return smsVector;
  148. }
  149. public Vector getOutBox() throws Exception{
  150. Vector smsVector=new Vector();
  151. DBConnect dbc=new DBConnect();
  152. sql="select * from bbs.message where sender=? and issend=0 and delS=0 order by sendtime desc";
  153. dbc.prepareStatement(sql);
  154. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  155. ResultSet rs=dbc.executeQuery();
  156. while(rs.next()){
  157. SMSMSG sms=new SMSMSG();
  158. sms.setID(rs.getInt(1));
  159. sms.setSender(rs.getString(2));
  160. sms.setIncept(rs.getString(3));
  161. sms.setTitle(rs.getString(4));
  162. sms.setContent(rs.getString(5));
  163. sms.setFlag(rs.getInt(6));
  164. sms.setSendtime(rs.getString(7));
  165. sms.setDelR(rs.getInt(8));
  166. sms.setDelS(rs.getInt(9));
  167. sms.setIsSend(rs.getInt(10));
  168. smsVector.add(sms);
  169. }
  170. dbc.close();
  171. return smsVector;
  173. }
  174. public Vector getRecycle() throws Exception{
  175. Vector smsVector=new Vector();
  176. DBConnect dbc=new DBConnect();
  177. sql="select * from bbs.message where ((sender=? and delS=1) or (incept=? and delR=1)) and delS!=2 order by sendtime desc";
  178. dbc.prepareStatement(sql);
  179. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  180. dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  181. ResultSet rs=dbc.executeQuery();
  182. while(rs.next()){
  183. SMSMSG sms=new SMSMSG();
  184. sms.setID(rs.getInt(1));
  185. sms.setSender(rs.getString(2));
  186. sms.setIncept(rs.getString(3));
  187. sms.setTitle(rs.getString(4));
  188. sms.setContent(rs.getString(5));
  189. sms.setFlag(rs.getInt(6));
  190. sms.setSendtime(rs.getString(7));
  191. sms.setDelR(rs.getInt(8));
  192. sms.setDelS(rs.getInt(9));
  193. sms.setIsSend(rs.getInt(10));
  194. smsVector.add(sms);
  195. }
  196. dbc.close();
  197. return smsVector;
  199. }
  200. public Vector getIsSend() throws Exception{
  201. Vector smsVector=new Vector();
  202. DBConnect dbc=new DBConnect();
  203. sql="select * from bbs.message where sender=? and issend=1 and delS=0 order by sendtime desc";
  204. dbc.prepareStatement(sql);
  205. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  206. ResultSet rs=dbc.executeQuery();
  207. while(rs.next()){
  208. SMSMSG sms=new SMSMSG();
  209. sms.setID(rs.getInt(1));
  210. sms.setSender(rs.getString(2));
  211. sms.setIncept(rs.getString(3));
  212. sms.setTitle(rs.getString(4));
  213. sms.setContent(rs.getString(5));
  214. sms.setFlag(rs.getInt(6));
  215. sms.setSendtime(rs.getString(7));
  216. sms.setDelR(rs.getInt(8));
  217. sms.setDelS(rs.getInt(9));
  218. sms.setIsSend(rs.getInt(10));
  219. smsVector.add(sms);
  220. }
  221. dbc.close();
  222. return smsVector;
  224. }
  225. public void  delInBox(HttpServletRequest request) throws Exception{
  226. int ID=0;
  227.         String[] ids = request.getParameterValues("id");
  228. if(ids.length==0)
  229. throw new Exception("请指定相关参数。");
  230.         for(int i=0;i<ids.length;i++)
  231.         {
  232.             ID = Integer.parseInt(ids[i]);
  233.             DBConnect dbc = new DBConnect();
  234.             sql = "update bbs.message set delR=1 where incept=? and id =" + ID;
  235.             dbc.prepareStatement(sql);
  236.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  237.             dbc.executeUpdate();
  238.             dbc.close();
  239.         }
  240. }
  242. public void  allDelInBox() throws Exception{
  243. sql="update bbs.message set delR=1 where incept=? and delR=0";
  244. DBConnect dbc=new DBConnect();
  245. dbc.prepareStatement(sql);
  246. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  247. dbc.executeUpdate();
  248. dbc.close();
  249. }
  250. public void  delOutBox(HttpServletRequest request) throws Exception{
  251. int ID=0;
  252.         String[] ids = request.getParameterValues("id");
  253.         if(ids.length==0)
  254.             throw new Exception("请指定相关参数。");
  255.         for(int i=0;i<ids.length;i++)
  256.         {
  257.             ID = Integer.parseInt(ids[i]);
  259.             DBConnect dbc = new DBConnect();
  260.             sql = "update bbs.message set delS=1 where sender=? and issend=0 and id =" + ID;
  261.             dbc.prepareStatement(sql);
  262.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  263.             dbc.executeUpdate();
  264.             dbc.close();
  265.         }
  266. }
  268. public void  allDelOutBox() throws Exception{
  269. sql="update bbs.message set delS=1 where sender=? and delS=0 and issend=0";
  270. DBConnect dbc=new DBConnect();
  271. dbc.prepareStatement(sql);
  272. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  273. dbc.executeUpdate();
  274. dbc.close();
  275. }
  276. public void  delIsSend(HttpServletRequest request) throws Exception{
  277. int ID=0;
  278.         String[] ids = request.getParameterValues("id");
  279.         if(ids.length==0)
  280.             throw new Exception("请指定相关参数。");
  281.         for(int i=0;i<ids.length;i++)
  282.         {
  283.             ID = Integer.parseInt(ids[i]);
  285.             DBConnect dbc = new DBConnect();
  286.             sql = "update bbs.message set delS=1 where sender=? and issend=1 and id =" + ID;
  287.             dbc.prepareStatement(sql);
  288.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  289.             dbc.executeUpdate();
  290.             dbc.close();
  291.         }
  292. }
  293. public void  allDelIsSend() throws Exception{
  294. sql="update bbs.message set delS=1 where sender=? and delS=0 and issend=1";
  295. DBConnect dbc=new DBConnect();
  296. dbc.prepareStatement(sql);
  297. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  298. dbc.executeUpdate();
  299. dbc.close();
  300. }
  301. public void  delRecycle(HttpServletRequest request) throws Exception{
  302. int ID=0;
  303.         String[] ids = request.getParameterValues("id");
  304.         if(ids.length==0)
  305.             throw new Exception("请指定相关参数。");
  306.         for(int i=0;i<ids.length;i++)
  307.         {
  308.             ID = Integer.parseInt(ids[i]);
  310.             DBConnect dbc = new DBConnect();
  311.             sql = "delete from bbs.message where incept=? and delR=1 and id=" + ID;
  312.             dbc.prepareStatement(sql);
  313.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  314.             dbc.executeUpdate();
  315.             sql = "update bbs.message set delS=2 where sender=? and delS=1 and id =" + ID;
  316.             dbc.prepareStatement(sql);
  317.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  318.             dbc.executeUpdate();
  319.             dbc.close();
  320.         }
  321. }
  322. public void  allDelRecycle() throws Exception{
  323. DBConnect dbc=new DBConnect();
  324. sql="delete from bbs.message where incept=? and delR=1";
  325. dbc.prepareStatement(sql);
  326. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  327. dbc.executeUpdate();
  328. sql="update bbs.message set delS=2 where sender=? and delS=1";
  329. dbc.prepareStatement(sql);
  330. dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  331. dbc.executeUpdate();
  332. dbc.close();
  333. }
  334. public void  delete(HttpServletRequest request) throws Exception{
  335. int ID=0;
  336.         String[] ids = request.getParameterValues("id");
  337.         if(ids.length==0)
  338.             throw new Exception("请指定相关参数。");
  339.         for(int i=0;i<ids.length;i++)
  340.         {
  341.             ID = Integer.parseInt(ids[i]);
  343.             DBConnect dbc = new DBConnect();
  345.             sql = "update bbs.message set delR=1 where incept=? and id=" + ID;
  346.             dbc.prepareStatement(sql);
  347.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  348.             dbc.executeUpdate();
  349.             sql = "update bbs.message set delS=1 where sender=? and id=" + ID;
  350.             dbc.prepareStatement(sql);
  351.             dbc.setBytes(1, (new String(userName.getBytes("ISO-8859-1"), "GBK")).getBytes());
  352.             dbc.executeUpdate();
  353.             dbc.close();
  354.         }
  355. }
  361. ///////////////////////////////////////////////////////////
  362. public void  saveSMS(HttpServletRequest request) throws Exception{
  364. String touser=ParamUtil.getString(request,"touser");
  365. if(touser==null||touser.trim().equals(""))
  366. throw new Exception("您忘记填写发送对象了吧。");
  368. String title=ParamUtil.getString(request,"title");
  369. if(title==null||title.trim().equals(""))
  370. throw new Exception("您还没有填写标题呀。");
  371. String message=ParamUtil.getString(request,"message");
  372. if(message==null||message.trim().equals(""))
  373. throw new Exception("内容是必须要填写的噢。");
  375. String [] users=touser.split(",");
  376. DBConnect dbc=new DBConnect();
  377. ResultSet rs;
  378. for(int i=0;i<users.length;i++){
  379. if (i>4){
  380. dbc.close();
  381. throw new Exception("最多只能发送给5个用户，您的名单5位以后的请重新发送");
  382. }
  384. sql="select username from bbs.myuser where username=?";
  385. dbc.prepareStatement(sql);
  386. dbc.setBytes(1,(new String(users[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
  387. rs=dbc.executeQuery();
  388. if(!rs.next()){
  389. dbc.close();
  390. throw new Exception("论坛没有这个用户，看看你的发送对象写对了嘛？");
  391. }
  393. String submit=new String(ParamUtil.getString(request,"Submit","").getBytes("ISO-8859-1"),"GBK");;
  395. if(submit.equals("发送")){
  396. sql="insert into bbs.message (incept,sender,title,content,sendtime,flag,issend) values (?,?,?,?,getdate(),0,1)";
  397. }
  398. else{
  399. sql="insert into bbs.message (incept,sender,title,content,sendtime,flag,issend) values (?,?,?,?,getdate(),0,0)";
  400. }
  401. dbc.prepareStatement(sql);
  402. dbc.setBytes(1,(new String(users[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
  403. dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  404. dbc.setBytes(3,(new String(title.getBytes("ISO-8859-1"),"GBK")).getBytes());
  405. dbc.setBytes(4,(new String(message.getBytes("ISO-8859-1"),"GBK")).getBytes());
  406. dbc.executeUpdate();
  408. }
  409. dbc.close();
  411. }
  414. public void saveEdit(HttpServletRequest request) throws Exception{
  415. int ID=0;
  416. try{
  417. ID=ParamUtil.getInt(request,"id");
  418. }
  419. catch(Exception e){
  420. throw new Exception("请指定相关参数。");
  421. }
  422. String touser=ParamUtil.getString(request,"touser");
  423. if(touser==null||touser.trim().equals(""))
  424. throw new Exception("您忘记填写发送对象了吧。");
  426. String title=ParamUtil.getString(request,"title");
  427. if(title==null||title.trim().equals(""))
  428. throw new Exception("您还没有填写标题呀。");
  429. String message=ParamUtil.getString(request,"message");
  430. if(message==null||message.trim().equals(""))
  431. throw new Exception("内容是必须要填写的噢。");
  433. String incept=touser;
  435. DBConnect dbc=new DBConnect();
  436. sql="select username from bbs.myuser where username=?";
  437. dbc.prepareStatement(sql);
  438. dbc.setBytes(1,(new String(incept.getBytes("ISO-8859-1"),"GBK")).getBytes());
  440. ResultSet rs=dbc.executeQuery();
  441. if(!rs.next()){
  442. dbc.close();
  443. throw new Exception("论坛没有这个用户，看看你的发送对象写对了嘛？");
  444. }
  445. rs.close();
  446. String submit=new String(ParamUtil.getString(request,"Submit","").getBytes("ISO-8859-1"),"GBK");
  448. if(submit.equals("发送")){
  449. sql="update bbs.message set incept=?,sender=?,title=?,content=?,sendtime=getdate(),flag=0,issend=1 where id="+ID;
  450. }
  451. else{
  452. sql="update bbs.message set incept=?,sender=?,title=?,content=?,sendtime=getdate(),flag=0,issend=0 where id="+ID;
  453. }
  454. dbc.prepareStatement(sql);
  455. dbc.setBytes(1,(new String(incept.getBytes("ISO-8859-1"),"GBK")).getBytes());
  456. dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
  457. dbc.setBytes(3,(new String(title.getBytes("ISO-8859-1"),"GBK")).getBytes());
  458. dbc.setBytes(4,(new String(message.getBytes("ISO-8859-1"),"GBK")).getBytes());
  459. dbc.executeUpdate();
  460. dbc.close();
  461. }
  462. }