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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > C#编程 > 查看源码
BBS.cs
资源名称：UDS1.1_51aspx.rar　[点击查看]
上传用户：cha0314
上传日期：2014-03-02
资源大小：12522k
文件大小：32k
源码类别：

C#编程

开发平台：

C#

BBS.cs：源码内容
  1. using System;
  2. using System.Data;
  3. using System.Data.SqlClient;
  4. using System.IO;
  5. using System.Collections ;
  6. using System.Configuration;
  7. using System.Web;
  11. namespace UDS.Components
  12. {
  13. /// <summary>
  14. /// BBS 的摘要说明。
  15. /// </summary>
  16. public class BBSClass
  17. {
  18. #region 判断是否有BBS管理权限
  19. /// <summary>
  20. /// 判断是否有管理权限
  21. /// </summary>
  22. /// <param name="username">用户名</param>
  23. /// <returns>bool</returns>
  24. public bool AdminBBS(string username,int classid)
  25. {
  26. if(classid!=0)
  27. {
  28. int actid = 8;
  29. Database db = new Database();
  30. SqlParameter[] prams = {
  31.    db.MakeInParam("@Class_ID",SqlDbType.Int,4,classid),
  32.    db.MakeInParam("@Username",SqlDbType.VarChar,100,username),
  33.    db.MakeInParam("@Act_ID",SqlDbType.Int,4,actid),
  34.    db.MakeOutParam("@ReturnValue",SqlDbType.Int,4)
  35.    };
  36. try
  37. {
  38. db.RunProc("sp_GetAccessPermission",prams);
  39. // 仅做测试用
  40. // return(true);
  41. return((Int32.Parse(prams[3].Value.ToString())==1)?true:false);
  43. }
  44. catch(Exception ex)
  45. {
  46. Error.Log(ex.Message);
  47. throw new Exception("BBS权限判断错误!",ex);
  48. }
  49. }
  50. else
  51. return(false);
  53. }
  55. #endregion
  57. #region 判断是否有发布系统公告权限
  58. /// <summary>
  59. /// 判断是否有发布系统公告权限
  60. /// </summary>
  61. /// <param name="username">用户名</param>
  62. /// <returns>bool</returns>
  63. public bool AdminSysBulletin(string username,int classid)
  64. {
  65. if(classid!=0)
  66. {
  67. int actid = 9;
  68. Database db = new Database();
  69. SqlParameter[] prams = {
  70.    db.MakeInParam("@Class_ID",SqlDbType.Int,4,classid),
  71.    db.MakeInParam("@Username",SqlDbType.VarChar,100,username),
  72.    db.MakeInParam("@Act_ID",SqlDbType.Int,4,actid),
  73.    db.MakeOutParam("@ReturnValue",SqlDbType.Int,4)
  74.    };
  75. try
  76. {
  77. db.RunProc("sp_GetAccessPermission",prams);
  78. // 仅做测试用
  79. // return(true);
  80. return((Int32.Parse(prams[3].Value.ToString())==1)?true:false);
  82. }
  83. catch(Exception ex)
  84. {
  85. Error.Log(ex.Message);
  86. throw new Exception("BBS权限判断错误!",ex);
  87. }
  88. }
  89. else
  90. return(false);
  92. }
  94. #endregion
  96. #region 判断是否是板块斑竹
  97. /// <summary>
  98. /// 判断是否是板块斑竹
  99. /// </summary>
  100. /// <param name="boardid">板块ID</param>
  101. /// <param name="username">用户名</param>
  102. /// <returns></returns>
  103. public bool IsBoardMaster(int boardid,string username)
  104. {
  105. Database db = new Database();
  106. SqlParameter[] prams = {
  107.    db.MakeInParam("@board_id",SqlDbType.Int,4,boardid),
  108.    db.MakeInParam("@staff_name",SqlDbType.VarChar,100,username)
  109.    };
  110. try
  111. {
  112. if(db.RunProc("sp_BBSISBoardMaster",prams)==1)
  113. return(true);
  114. else
  115. return(false);
  116. }
  117. catch(Exception ex)
  118. {
  119. Error.Log(ex.Message);
  120. throw new Exception("BBS斑竹权限判断错误!",ex);
  121. }
  123. }
  124. #endregion
  126.         #region 新增分栏信息
  127. //给uds_bbs_catalog表,新增记录
  128. public bool AddBBSCatalog (BBSCatalog BBSCatalog)  //string CatalogName,string CatalogDescription
  129. {
  130. //参数 CatalogName 表示BBS中的title , 参数 CatalogDescription 表示BBS中的content
  131. //给存储过程传递参数
  132. Database data = new Database();
  133. SqlParameter[] prams = {
  134.    data.MakeInParam("@title",  SqlDbType.VarChar, 300, BBSCatalog.CatalogName),
  135.    data.MakeInParam("@content", SqlDbType.NText, 16, BBSCatalog.CatalogDescription),
  136. };
  137. data.RunProc ("sp_BBS_AddCatalog",prams);
  138. return true;
  140. }
  141. #endregion 
  143. #region 查询BBS贴子
  144. public SqlDataReader Find(string key,BBSSearchOption option,DataTable boards)
  145. {
  146. string boardids = "";
  147. string sql = "select * from UDS_Bbs_ForumItem";
  148. SqlDataReader dr = null;
  151. if(option.searchtype==BBSSearchType.author)
  152. {
  153. sql += " where sender like '%"+key+"%'";
  154. }
  155. else if(option.searchtype==BBSSearchType.title)
  156. {
  157. sql += " where title like '%"+key+"%'";
  158. }
  160. if(option.BoardID!=0)
  161. {
  162. sql += " and board_id="+option.BoardID;
  163. }
  164. else
  165. {
  166. foreach(DataRow row in boards.Rows)
  167. {
  168. boardids += row["board_id"].ToString() + ",";
  169. }
  171. if(boardids!="")
  172. boardids = boardids.Substring(0,boardids.Length-1);
  176. sql += " and board_id in ("+boardids+")";
  177. }
  178. if(option.TimeBound!=TimeSpan.MaxValue)
  179. {
  180. //计算时间段
  181. sql += " and datediff(d,send_time,getdate())< "+option.TimeBound.Days.ToString();
  182. }
  185. UDS.Components.Database db = new UDS.Components.Database();
  186. SqlParameter[] prams = {
  187.    db.MakeInParam("@SQL",  SqlDbType.NText, 5000, sql),
  188. };
  190. db.RunProc("sp_RunSQL",prams,out dr);
  191. return dr;
  192. }
  193. #endregion
  195. #region 修改分栏信息时根据CatalogID显示数据
  196. public SqlDataReader GetModifyBBSCatalog (int m_CatalogID)
  197. {
  198. //参数CatalogID表示存储过程中的@catalog_id int 分栏ID
  199. SqlDataReader dataReader = null;
  200. Database data = new Database();
  201. SqlParameter[] prams = {
  202.    data.MakeInParam("@catalog_id",  SqlDbType.Int, 4, m_CatalogID),
  203. };
  204. try
  205. {
  206. data.RunProc ("sp_BBS_GetCatalogInfo",prams,out dataReader);
  207. return dataReader;
  208. }
  209. catch (Exception ex)
  210. {
  211. Error.Log(ex.ToString());
  212. // throw new Exception("BBS类别增加错误!",ex);
  213. return null;
  214. }
  215. }
  216. #endregion
  218. #region 修改（编缉分栏信息）
  219. //更新分类栏信息
  220. public bool EditBBSCatalog (BBSCatalog BBSCatalog)
  221. {
  222. // @catalog_id int, : 分栏ID
  223. // @catalog_name varchar(300), : 分栏名称
  224. // @catalog_description varchar(300) : 分栏介绍
  225. // 给存储过程传递参数
  226. Database data = new Database();
  227. SqlParameter[] prams = {
  228.    data.MakeInParam("@catalog_id",  SqlDbType.Int, 4, BBSCatalog.CatalogID),
  229.    data.MakeInParam("@catalog_name", SqlDbType.VarChar, 300, BBSCatalog.CatalogName),
  230.    data.MakeInParam("@catalog_description", SqlDbType.VarChar ,300, BBSCatalog.CatalogDescription),
  231. };
  232. try
  233. {
  234. data.RunProc ("sp_BBS_UpdateCatalogInfo",prams);
  235. return true;
  236. }
  237. catch (Exception ex)
  238. {
  239. Error.Log(ex.ToString());
  240. throw new Exception("BBS类别编缉错误!",ex);
  242. }
  243. }
  244. #endregion
  246. #region 删除分栏（分栏信息）
  248. public int DelBBSCatalog(int catalog_id)
  249. {
  250. Database db = new Database();
  251. SqlParameter[] prams = {
  252.    db.MakeInParam("@catalog_id ",SqlDbType.Int,4,catalog_id)
  253.    };
  254. return(db.RunProc("sp_BBS_DeleteCatalog",prams));
  255. }
  257.     #endregion
  259.         #region 在分类中新增一个板块（添加板块）
  260. //在BBS大类中 添加板块
  261. public bool BBSAddBoard(BBSBoard BBSBoard)
  262. {
  263. //需向存储过程传递的参数如下
  264. //@catalog_id (int) 分类ID号, @title (varchar(300)) 抬头的名称, @content ntext 板块内容, @boardtype bit 板块类型
  266. Database data = new Database();
  267. SqlParameter[] prams = { 
  268.    data.MakeInParam ("@catalog_id", SqlDbType.Int, 4, BBSBoard.CatalogID ),
  269.    data.MakeInParam ("@title", SqlDbType.VarChar, 300, BBSBoard.BoardName ),
  270.    data.MakeInParam ("@content", SqlDbType.NText, 16, BBSBoard.BoardDescription ),
  271.    data.MakeInParam ("@boardtype", SqlDbType.Bit, 1, BBSBoard.BoardType ),
  272. };
  274. data.RunProc ("sp_BBS_AddBoard",prams);
  275. return true;
  277. }
  279.         #endregion 
  281. #region 修改板块时根据BoardID显示数据
  283. public SqlDataReader GetModifyBBSBoard (int m_BoardID)
  284. {
  285. //参数m_BoardID表示存储过程中的@board_id int : 板块ID
  286. SqlDataReader dataReader = null;
  287. Database data = new Database();
  288. SqlParameter[] prams = {
  289.    data.MakeInParam("@board_id",  SqlDbType.Int, 4, m_BoardID),
  290. };
  291. try
  292. {
  293. data.RunProc ("sp_BBS_GetBoardInfo",prams,out dataReader);
  294. return dataReader;
  295. }
  296. catch (Exception ex)
  297. {
  298. Error.Log(ex.ToString());
  299. // throw new Exception("BBS类别增加错误!",ex);
  300. return null;
  301. }
  302. }
  304. #endregion
  306. #region 修改（编缉板块）
  307. //更新板块信息
  308. public bool EditBBSBoard (BBSBoard BBSBoard)
  309. {
  310. //@board_id int, : 被更新的板块ID
  311. //@board_name varchar(300) : 板块名称
  312. //@board_description varchar(300), : 板块介绍
  313. //@board_type bit : 板块类型(公共型，私有型)
  314. // 给存储过程传递参数
  315. Database data = new Database();
  316. SqlParameter[] prams = {
  317.    data.MakeInParam("@board_id",  SqlDbType.Int, 4, BBSBoard.BoardID),
  318.    data.MakeInParam("@board_name", SqlDbType.VarChar, 300, BBSBoard.BoardName),
  319.    data.MakeInParam("@board_description", SqlDbType.VarChar ,300, BBSBoard.BoardDescription),
  320.    data.MakeInParam("@board_type", SqlDbType.Bit, 1 ,BBSBoard.BoardType),
  321. };
  322. //try
  323. {
  324. data.RunProc ("sp_BBS_UpdateBoardInfo",prams);
  325. return true;
  326. }
  327. //catch (Exception ex)
  328. {
  329. // Error.Log(ex.ToString());
  330. // throw new Exception("BBS板块编缉错误!",ex);
  332. }
  333. }    
  334. #endregion
  336. #region 删除（删除板块）
  338. public int DelBBSBoard(int board_id)
  339. {
  340. //@board_id  : 板块ID
  341. Database db = new Database();
  342. SqlParameter[] prams = {
  343.    db.MakeInParam("@board_id ",SqlDbType.Int,4,board_id)
  344.    };
  345. return(db.RunProc("sp_BBS_DeleteBoard",prams));
  346. }
  348. #endregion
  350. #region 斑竹操作
  351. //得到版块版主
  352. public SqlDataReader GetBoardMaster ()
  353. {
  354. SqlDataReader dataReader = null;
  355. Database data = new Database();
  356. //SqlParameter[] prams = {
  357. //    data.MakeInParam("@board_id",  SqlDbType.Int, 4, master.BoardID),
  358. //};
  359. try
  360. {
  361. data.RunProc ("sp_BBS_GetAllBoardMaster",out dataReader);
  362. return dataReader;
  363. }
  364. catch (Exception ex)
  365. {
  366. Error.Log(ex.ToString());
  367. return null;
  368. }
  369. }
  372. //删除版主
  373. public int DeleteBoardMaster (BBSBoardmaster master)
  374. {
  375. //参数:
  376. //      @BoardID  : 版块ID
  377. //    @StaffID  : 员工ID
  378. Database data = new Database();
  379. SqlParameter[] prams = {
  380.    data.MakeInParam("@BoardID", SqlDbType.Int, 4, master.BoardID),
  381.    data.MakeInParam("@StaffID", SqlDbType.Int, 4, master.StaffID), 
  382. };
  383. return(data.RunProc ("sp_BBS_DeleteBoardMaster",prams));
  384. }
  387. //设置版主
  388. public bool SetupBoardMaster (BBSBoardmaster master)
  389. {
  390. //参数:
  391. //       @BoardID int : 板块ID
  392. //      @StaffID int : 员工ID
  393. Database data = new Database();
  394. SqlParameter[] prams = {
  395.    data.MakeInParam("@BoardID", SqlDbType.Int, 4, master.BoardID),
  396.    data.MakeInParam("@StaffID", SqlDbType.Int, 4, master.StaffID), 
  397. };
  398. try
  399. {
  400. data.RunProc ("sp_BBS_SetupBoardMaster",prams);
  401. return true;
  402. }
  403. catch (Exception ex)
  404. {
  405. Error.Log(ex.ToString());
  406. return false;
  407. }
  408. }
  411. //取所有在职的用户名称
  412. public SqlDataReader GetAllStaff()
  413. {
  414. //参数  无   默认取在职的所有人员名称
  415. SqlDataReader dataReader = null;
  416. Database data = new Database();
  417. try
  418. {
  419. data.RunProc ("sp_getallstaff",out dataReader);
  420. return dataReader;
  421. }
  422. catch (Exception ex)
  423. {
  424. Error.Log(ex.ToString());
  425. return null;
  426. }
  427. }
  429. #endregion
  431. #region 私有板块成员操作
  432. //得到版块成员
  433. public SqlDataReader GetBoardMember ()
  434. {
  435. SqlDataReader dataReader = null;
  436. Database data = new Database();
  437. try
  438. {
  439. data.RunProc ("sp_BBS_GetAllBoardMember",out dataReader);
  440. return dataReader;
  441. }
  442. catch (Exception ex)
  443. {
  444. Error.Log(ex.ToString());
  445. return null;
  446. }
  447. }
  450. //删除成员
  451. public int DeleteBoardMember (BBSBoardmember member)
  452. {
  453. //参数:
  454. //      @BoardID  : 版块ID
  455. //    @StaffID  : 员工ID
  456. Database data = new Database();
  457. SqlParameter[] prams = {
  458.    data.MakeInParam("@StaffID", SqlDbType.Int, 4, member.StaffID)
  459. };
  460. return(data.RunProc ("sp_BBS_DeleteBoardMember",prams));
  461. }
  464. //设置成员
  465. public bool SetupBoardMember (int boardid,int staffid)
  466. {
  467. //参数:
  468. //       @BoardID int : 板块ID
  469. //      @StaffID int : 员工ID
  470. Database data = new Database();
  471. SqlParameter[] prams = {
  472.    data.MakeInParam("@BoardID", SqlDbType.Int, 4, boardid),
  473.    data.MakeInParam("@StaffID", SqlDbType.Int, 4, staffid), 
  474. };
  475. try
  476. {
  477. data.RunProc ("sp_BBS_SetupBoardMember",prams);
  478. return true;
  479. }
  480. catch (Exception ex)
  481. {
  482. Error.Log(ex.ToString());
  483. return false;
  484. }
  485. }
  487. #endregion
  489. #region 显示所有分栏信息
  490. public SqlDataReader GetBBSCatalog()
  491. {
  492. //参数: 无
  493. SqlDataReader dataReader = null;
  494. Database data = new Database();
  496. try
  497. {
  498. data.RunProc ("sp_GetBBSCatalog",out dataReader);
  499. return dataReader;
  500. }
  501. catch (Exception ex)
  502. {
  503. Error.Log(ex.ToString());
  504. return null;
  505. }
  506. }
  507. #endregion
  509. #region 显示个人的分类栏的版块
  510. public SqlDataReader GetBBSBoard(string m_StaffName)  
  511. {
  512. //参数:  m_StaffName        :   员工姓名
  513. //@catalog_id int : 分类栏ID
  514. // @staff_name varchar(50)='' : 员工姓名
  515. SqlDataReader dataReader = null;
  516. Database data = new Database ();
  517. SqlParameter[] prams = {
  518.    data.MakeInParam("@staff_name",  SqlDbType.VarChar, 50, m_StaffName)
  519. };
  520. try 
  521. {
  522. data.RunProc ("sp_BBS_GetAllBoardByStaff",prams,out dataReader);
  523. return dataReader;
  524. }
  525. catch (Exception ex)
  526. {
  527. Error.Log(ex.ToString());
  528. return null;
  529. }
  530. }
  531.         #endregion
  533. #region 显示所有板块
  534. public SqlDataReader GetAllBBSBoard()  
  535. {
  536. SqlDataReader dataReader = null;
  537. Database data = new Database ();
  538. try 
  539. {
  540. data.RunProc ("sp_BBS_GetAllBoard",out dataReader);
  541. return dataReader;
  542. }
  543. catch (Exception ex)
  544. {
  545. Error.Log(ex.ToString());
  546. return null;
  547. }
  548. }
  549. #endregion
  551. #region 显示该版块的所有帖子
  552. public SqlDataReader GetBBSForumItem(BBSForumItem item)
  553. {
  554. //参数: @board_id int : 该版块ID
  555. SqlDataReader dataReader = null;
  556. Database data = new Database ();
  557. SqlParameter[] prams = {
  558.    data.MakeInParam("@board_id",  SqlDbType.Int, 4, item.BoardID),
  559. };
  560. try
  561. {
  562. data.RunProc ("sp_GetBBSForumItem",prams,out dataReader);
  563. return dataReader;
  564. }
  565. catch (Exception ex)
  566. {
  567. Error.Log(ex.ToString());
  568. return null;
  569. }
  570. }
  571.         #endregion
  573. #region 得到所有系统公告
  574. /// <summary>
  575. /// 得到所有系统公告
  576. /// </summary>
  577. /// <returns></returns>
  578. public SqlDataReader GetSysBulletin()
  579. {
  580. SqlDataReader dataReader = null;
  581. Database data = new Database ();
  582. try
  583. {
  584. SqlParameter[] prams = {
  585.    data.MakeInParam("@type",  SqlDbType.Int, 4, -1),
  586. };
  587. data.RunProc ("sp_BBS_GetBulletin",prams,out dataReader);
  588. return dataReader;
  589. }
  590. catch (Exception ex)
  591. {
  592. Error.Log(ex.ToString());
  593. return null;
  594. }
  596. }
  597. #endregion
  599. #region 得到所有桌面公告
  600. /// <summary>
  601. /// 得到所有桌面公告
  602. /// </summary>
  603. /// <returns></returns>
  604. public SqlDataReader GetDeskTopBulletin()
  605. {
  606. SqlDataReader dataReader = null;
  607. Database data = new Database ();
  608. try
  609. {
  610. SqlParameter[] prams = {
  611.    data.MakeInParam("@type",  SqlDbType.Int, 4, -2),
  612. };
  613. data.RunProc ("sp_BBS_GetBulletin",prams,out dataReader);
  614. return dataReader;
  615. }
  616. catch (Exception ex)
  617. {
  618. Error.Log(ex.ToString());
  619. return null;
  620. }
  622. }
  623. #endregion
  625. #region 得到板块公告
  626. /// <summary>
  627. /// 得到板块公告
  628. /// </summary>
  629. /// <param name="boardid">板块id,=0则取出所有板块的公告</param>
  630. /// <returns></returns>
  631. public SqlDataReader GetBulletin(int boardid)
  632. {
  633. SqlDataReader dataReader = null;
  634. Database data = new Database ();
  635. try
  636. {
  637. SqlParameter[] prams = {
  638.    data.MakeInParam("@type",  SqlDbType.Int, 4, boardid),
  639. };
  640. data.RunProc ("sp_BBS_GetBulletin",prams,out dataReader);
  641. return dataReader;
  642. }
  643. catch (Exception ex)
  644. {
  645. Error.Log(ex.ToString());
  646. return null;
  647. }
  649. }
  650. #endregion
  652. #region 读取论坛帖子
  653. public SqlDataReader ReadBBSForumItem(BBSForumItem item)
  654. {
  655. //参数: @item_id int : 帖子ID
  656. SqlDataReader dataReader = null;
  657. Database data = new Database ();
  658. SqlParameter[] prams = {
  659.    data.MakeInParam("@item_id",  SqlDbType.Int, 4, item.ItemID),
  660. };
  661. try 
  662. {
  663. data.RunProc ("sp_ReadBBSForumItem",prams,out dataReader);
  664. return dataReader;
  665. }
  666. catch (Exception ex)
  667. {
  668. Error.Log(ex.ToString());
  669. return null;
  670. }
  671. }
  673. public void ReadBBSForumItemStruct(BBSForumItem item)
  674. {
  675. //参数: @item_id int : 帖子ID
  676. SqlDataReader dataReader = null;
  677. Database data = new Database ();
  678. SqlParameter[] prams = {
  679.    data.MakeInParam("@item_id",  SqlDbType.Int, 4, item.ItemID),
  680. };
  681. try 
  682. {
  683. data.RunProc ("sp_ReadBBSForumItem",prams,out dataReader);
  684. while(dataReader.Read())
  685. {
  686. item.BoardID = Int32.Parse(dataReader["board_id"].ToString());
  687. item.Title = dataReader["title"].ToString();
  688. item.Content = dataReader["content"].ToString();
  689. item.Sender = dataReader["sender"].ToString();
  690. item.SendTime = DateTime.Parse(dataReader["send_time"].ToString());
  691. item.HitTimes = Int32.Parse(dataReader["hit_times"].ToString());
  692. item.ReplayTimes = Int32.Parse(dataReader["replay_times"].ToString());
  693. item.LastReplayer = dataReader["last_replayer"].ToString();
  694. item.LastReplayTime = dataReader["last_replay_time"].ToString();
  695. item.IP = dataReader["ip"].ToString();
  696. item.Bulletin = Convert.ToBoolean(dataReader["bulletin"]);
  697. item.SysBulletin = Convert.ToBoolean(dataReader["sysbulletin"]);
  698. item.DeskTop = Convert.ToBoolean(dataReader["desktop"]);
  699. }
  701. }
  702. catch (Exception ex)
  703. {
  704. Error.Log(ex.ToString());
  706. }
  707. }
  708. #endregion
  710. #region 修改论坛帖子
  711. public void ModBBSForumItem(BBSForumItem item)
  712. {
  713. //参数: @item_id int : 帖子ID
  714. Database data = new Database ();
  715. SqlParameter[] prams = {
  716.     data.MakeInParam("@item_id",  SqlDbType.Int, 4, item.ItemID),
  717. data.MakeInParam("@board_id",  SqlDbType.Int, 4, item.BoardID),
  718. data.MakeInParam("@title",  SqlDbType.VarChar, 300, item.Title),
  719. data.MakeInParam("@content",  SqlDbType.NText, 5000, item.Content),
  720. data.MakeInParam("@sender",  SqlDbType.VarChar, 50, item.Sender),
  721. data.MakeInParam("@send_time",  SqlDbType.DateTime, 8, item.SendTime),
  722. data.MakeInParam("@hit_times",  SqlDbType.Int, 4, item.HitTimes),
  723. data.MakeInParam("@replay_times",  SqlDbType.Int, 4, item.ReplayTimes),
  724. data.MakeInParam("@last_replayer",  SqlDbType.VarChar, 50, item.LastReplayer),
  725. data.MakeInParam("@last_replay_time",  SqlDbType.DateTime, 8, item.LastReplayTime==""?Convert.DBNull:item.LastReplayTime),
  726. data.MakeInParam("@ip",  SqlDbType.VarChar, 50, item.IP),
  727. data.MakeInParam("@bulletin",  SqlDbType.Bit, 4, item.Bulletin),
  728. data.MakeInParam("@sysbulletin",  SqlDbType.Bit, 4, item.SysBulletin),
  729. data.MakeInParam("@desktop",  SqlDbType.Bit, 4, item.DeskTop),
  730. };
  731. try 
  732. {
  733. data.RunProc ("sp_BBS_UpdateItemInfo",prams);
  735. }
  736. catch (Exception ex)
  737. {
  738. Error.Log(ex.ToString());
  740. }
  741. }
  742. #endregion
  744. #region 读取帖子回复
  745. public SqlDataReader ReadBBSForumItemReplay(BBSForumItem item)
  746. {
  747. //参数: @item_id int : 帖子ID
  748. SqlDataReader dataReader = null;
  749. Database data = new Database ();
  750. SqlParameter[] prams = {
  751.    data.MakeInParam("@item_id",  SqlDbType.Int, 4, item.ItemID),
  752. };
  753. try
  754. {
  755. data.RunProc ("sp_ReadBBSForumItemReplay",prams,out dataReader);
  756. return dataReader;
  757. }
  758. catch (Exception ex)
  759. {
  760. Error.Log(ex.ToString ());
  761. return null;
  762. }
  763. }
  764.         #endregion
  766. #region 删除回复
  767. public void DelReplay(BBSReplay replay)
  768. {
  769. Database data = new Database ();
  770. SqlParameter[] prams = {
  771.     data.MakeInParam("@replayid",  SqlDbType.Int, 4,replay.ReplayId),
  772. data.MakeInParam("@itemid",SqlDbType.Int,4,replay.ItemID)
  773. };
  774. data.RunProc ("sp_BBS_DeleteReplay",prams);
  775. }
  776. #endregion
  778. #region 回复贴子
  779. public int ReplayItem(BBSReplay replay)
  780. {
  781. Database data = new Database ();
  782. SqlParameter[] prams = {
  783.     data.MakeInParam("@item_id",  SqlDbType.Int, 4, replay.ItemID),
  784. data.MakeInParam("@content",  SqlDbType.NText,5000, replay.Content),
  785. data.MakeInParam("@replayer",  SqlDbType.VarChar,300, replay.Replayer),
  786. data.MakeInParam("@replay_ip",  SqlDbType.VarChar,50, replay.ReplayId)
  787. };
  788. try
  789. {
  790. return(data.RunProc ("sp_BBSReplay",prams));
  791. }
  792. catch (Exception ex)
  793. {
  794. Error.Log(ex.ToString ());
  795. throw new Exception("回复出错！");
  796. }
  798. }
  799. #endregion
  801. #region 发布贴子
  802. public int SendItem(BBSForumItem item)
  803. {
  804. Database data = new Database ();
  805. SqlParameter[] prams = {
  806.    data.MakeInParam("@board_id",  SqlDbType.Int, 4,item.BoardID),
  807.    data.MakeInParam("@title",  SqlDbType.VarChar,300,item.Title),
  808.    data.MakeInParam("@content",  SqlDbType.NText,5000,item.Content),
  809.    data.MakeInParam("@sender",  SqlDbType.VarChar,100,item.Sender),
  810.    data.MakeInParam("@ip",  SqlDbType.VarChar,50,item.IP ),
  811.    data.MakeInParam("@bulletin",SqlDbType.Bit,1,item.Bulletin),
  812.    data.MakeInParam("@sysbulletin",SqlDbType.Bit,1,item.SysBulletin),
  813.    data.MakeInParam("@desktop",SqlDbType.Bit,1,item.DeskTop)
  814.    };
  815. try
  816. {
  817. return(data.RunProc ("sp_BBSAddItem",prams));
  818. }
  819. catch (Exception ex)
  820. {
  821. Error.Log(ex.ToString ());
  822. throw new Exception("发布出错！");
  823. }
  824. }
  825. #endregion
  827. #region 增加板主
  828. public void AddBoardMaster(int boardid,int staffid)
  829. {
  830. Database data = new Database ();
  831. SqlParameter[] prams = {
  832.    data.MakeInParam("@BoardID",  SqlDbType.Int, 4,boardid),
  833.    data.MakeInParam("@StaffID",  SqlDbType.Int, 4,staffid)
  834.    };
  835. data.RunProc ("sp_BBS_SetupBoardMaster",prams);
  837. }
  838. #endregion
  840. #region 删除板主
  841. public void DelBoardMaster(int boardid,int staffid)
  842. {
  843. Database data = new Database ();
  844. SqlParameter[] prams = {
  845.    data.MakeInParam("@BoardID",  SqlDbType.Int, 4,boardid),
  846.    data.MakeInParam("@StaffID",  SqlDbType.Int, 4,staffid)
  847.    };
  848. data.RunProc ("sp_BBS_DeleteBoardMaster",prams);
  849. }
  851. #endregion
  853. #region 移动论坛贴子
  854. public void MoveBoardItem(BBSForumItem olditem,BBSForumItem newitem)
  855. {
  856. Database data = new Database ();
  857. SqlParameter[] prams = {
  858.    data.MakeInParam("@item_id",  SqlDbType.Int, 4,olditem.ItemID),
  859.    data.MakeInParam("@to_board_id",  SqlDbType.Int, 4,newitem.BoardID)
  860.    };
  861. data.RunProc ("sp_BBSMoveItem",prams);
  862. }
  863. #endregion
  865. #region 删除论坛贴子
  866. public void DelItem(BBSForumItem item)
  867. {
  868. Database data = new Database ();
  869. SqlParameter[] prams = {
  870.    data.MakeInParam("@item_id",  SqlDbType.Int, 4,item.ItemID)
  871.   
  872.    };
  873. data.RunProc ("sp_BBSDeleteItem",prams);
  874. }
  875. #endregion
  877. #region 得到所有论坛
  878. public SqlDataReader GetAllBoard()
  879. {
  880. Database data = new Database ();
  881. SqlDataReader dr = null;
  882. data.RunProc ("sp_BBSGetMoveToBoard",out dr);
  883. return(dr);
  884. }
  885. #endregion
  887. #region 上传一个文件得到id号
  888. public int InsertFile(string name,string extension)
  889. {
  890. Database data = new Database();
  891. SqlParameter[] prams = {
  892.    data.MakeInParam("@name",SqlDbType.VarChar,200,name),
  893.    data.MakeInParam("@extension",SqlDbType.VarChar,100,extension)
  894.    };
  896. return(data.RunProc ("sp_BBS_AddFile",prams));
  897. }
  899. #endregion
  901. #region 根据id得到上传附件信息
  902. public SqlDataReader GetAttachmentByID(int id)
  903. {
  904. Database data = new Database();
  905. SqlDataReader dr = null;
  906. SqlParameter[] prams = {
  907.    data.MakeInParam("@id",SqlDbType.Int,4,id)
  908.    };
  909. data.RunProc ("sp_BBS_GetAttachmentByID",prams,out dr);
  910. return(dr);
  911. }
  912. #endregion
  914. }
  915. }
  917. public class BBSBoard
  918. {
  919. private int m_BoardID;
  920. private int m_CatalogID;
  921. private string m_BoardName;
  922. private string m_BoardDescription;
  923. private int m_BoardType;
  925. public int BoardID
  926. {
  927. //
  928. get { return m_BoardID; }
  929. set { m_BoardID = value; }
  930. }
  931.  
  932. public int CatalogID
  933. {
  934. //
  935. get { return m_CatalogID; }
  936. set { m_CatalogID = value; }
  937. }
  939. public string BoardName
  940. {
  941. //
  942. get { return m_BoardName; }
  943. set { m_BoardName = value; }
  944. }
  946. public string BoardDescription
  947. {
  948. //
  949. get { return m_BoardDescription; }
  950. set { m_BoardDescription = value; }
  951. }
  953. public int BoardType
  954. {
  955. //
  956. get { return m_BoardType; }
  957. set { m_BoardType = value; }
  958. } 
  959. }
  961. public class BBSBoardmaster
  962. {
  963. // 板主信息
  964. private int m_BoardID;
  965. private int m_StaffID;
  967. public int BoardID 
  968. {
  969. //
  970. get { return m_BoardID; }
  971. set { m_BoardID = value; }
  972. }
  974. public int StaffID
  975. {
  976. //
  977. get { return m_StaffID; }
  978. set { m_StaffID = value; } 
  979. }   
  981. }
  983. public class BBSBoardmember
  984. {
  985. //BBS里的会员
  986. private int m_StaffID;
  987. private int m_BoardID;
  989. public int StaffID 
  990. {
  991. //
  992. get { return m_StaffID; } 
  993. set { m_StaffID = value; }
  994. }
  996. public int BoardID
  997. {
  998. //
  999. get { return m_BoardID; }
  1000. set { m_BoardID = value; }
  1001. }
  1003. }
  1005. public class BBSCatalog 
  1006. {
  1007. //BBS 类别
  1008. private int m_CatalogID;
  1009. private string m_CatalogName; 
  1010. private string m_CatalogDescription;
  1012. public int CatalogID
  1013. {
  1014. //类别ID号
  1015. get { return m_CatalogID; }
  1016. set { m_CatalogID = value; }
  1017. }
  1019. public string CatalogName
  1020. {
  1021. // 类别名称
  1022. get { return m_CatalogName; } 
  1023. set { m_CatalogName = value; }
  1024. }
  1026. public string CatalogDescription
  1027. {
  1028. // 类别备注
  1029. get { return m_CatalogDescription; }
  1030. set { m_CatalogDescription = value; } 
  1031. }
  1033. }
  1035. public class BBSForumItem
  1036. {
  1037. //
  1038. private int m_ItemID;
  1039. private int m_BoardID;
  1040. private string m_Title;
  1041. private string m_Content;
  1042. private string m_Sender;
  1043. private DateTime m_SendTime;
  1044. private int m_HitTimes;
  1045. private int m_ReplayTimes;
  1046. private string m_LastReplayer;
  1047. private string m_LastReplayTime;
  1048. private string m_IP;
  1049. private bool m_Bulletin;
  1050. private bool m_SysBulletin;
  1051. private bool m_DeskTop;
  1053. public int ItemID
  1054. {
  1055. //
  1056. get { return m_ItemID;}
  1057. set {m_ItemID = value;}
  1058. }
  1060. public int BoardID
  1061. {
  1062. //
  1063. get { return m_BoardID; }
  1064. set { m_BoardID = value; }
  1065. }
  1067. public string Title
  1068. {
  1069. //
  1070. get { return m_Title; }
  1071. set { m_Title = value; }
  1072. }
  1074. public string Content
  1075. {
  1076. //
  1077. get { return m_Content; }
  1078. set { m_Content = value; }
  1079. }
  1081. public string Sender 
  1082. {
  1083. //
  1084. get { return m_Sender; }
  1085. set { m_Sender = value; }
  1086. }
  1088. public DateTime SendTime
  1089. {
  1090. //发送时间
  1091. get { return m_SendTime; }
  1092. set { m_SendTime = value; }
  1093. }
  1095. public int HitTimes
  1096. {
  1097. //
  1098. get { return m_HitTimes; }
  1099. set { m_HitTimes = value; }
  1100. }
  1102. public int ReplayTimes
  1103. {
  1104. //回复次数
  1105. get { return m_ReplayTimes; }
  1106. set { m_ReplayTimes = value; }
  1107. }
  1109. public string LastReplayer
  1110. {
  1111. //
  1112. get { return m_LastReplayer; }
  1113. set { m_LastReplayer = value; }
  1114. }
  1116. public string LastReplayTime
  1117. {
  1118. //
  1119. get { return m_LastReplayTime; }
  1120. set { m_LastReplayTime = value; }
  1121. }
  1123. public string IP 
  1124. {
  1125. //
  1126. get { return m_IP; }
  1127. set { m_IP = value; }
  1128. }
  1129. /// <summary>
  1130. /// 版面公告
  1131. /// </summary>
  1132. public bool Bulletin
  1133. {
  1134. get{return m_Bulletin;}
  1135. set{m_Bulletin = value;}
  1136. }
  1137. /// <summary>
  1138. /// 系统公告
  1139. /// </summary>
  1140. public bool SysBulletin
  1141. {
  1142. get{return m_SysBulletin;}
  1143. set{m_SysBulletin = value;}
  1144. }
  1146. /// <summary>
  1147. /// 公告桌面显示
  1148. /// </summary>
  1149. public bool DeskTop
  1150. {
  1151. get{return m_DeskTop;}
  1152. set{m_DeskTop = value;}
  1153. }
  1155. /// <summary>
  1156. /// 将贴子附件与自身绑定
  1157. /// </summary>
  1158. /// <param name="filenames">文件名（多个文件名用 , 分开）</param>
  1159. public void Attach(string filenames)
  1160. {
  1161. UDS.Components.Database data = new UDS.Components.Database ();
  1162. string[] arrfilename = filenames.Split(',');
  1163. for(int i=0;i<arrfilename.Length;i++)
  1164. {
  1165. if(arrfilename[i].Trim()!="")
  1166. {
  1167. SqlParameter[] prams = {
  1168.    data.MakeInParam("@itemid",  SqlDbType.Int, 4,this.ItemID),
  1169.    data.MakeInParam("@filename",  SqlDbType.VarChar, 500,arrfilename[i])
  1170.    };
  1171. data.RunProc ("sp_BBS_AttachmentToItem",prams);
  1172. }
  1174. }
  1176. }
  1178. /// <summary>
  1179. /// 删除附件
  1180. /// </summary>
  1181. public void DelAttachment(string attachmentmd)
  1182. {
  1183. UDS.Components.Database data = new UDS.Components.Database ();
  1184. //删除所有回复附件
  1185. //得到所有回复
  1186. UDS.Components.BBSClass bbs = new UDS.Components.BBSClass();
  1187. SqlDataReader dr1 = null;
  1188. dr1 = bbs.ReadBBSForumItemReplay(this);
  1189. while(dr1.Read())
  1190. {
  1191. BBSReplay replay = new BBSReplay();
  1192. replay.ReplayId = Int32.Parse(dr1["replay_id"].ToString());
  1193. replay.DelAttachment(attachmentmd);
  1194. }
  1195. //删除贴子本身附件
  1196. SqlParameter[] prams = {
  1197.    data.MakeInParam("@itemid",  SqlDbType.Int, 4,this.ItemID),
  1198. };
  1199. SqlDataReader dr = null;
  1200. data.RunProc ("sp_BBS_GetItemAttachment",prams,out dr);
  1201. while(dr.Read())
  1202. {
  1203. System.IO.File.Delete(attachmentmd+"\"+dr["filename"].ToString());
  1204. }
  1205. data.Close();
  1206. SqlParameter[] prams1 = {
  1207. data.MakeInParam("@itemid",  SqlDbType.Int, 4,this.ItemID),
  1208. };
  1209. data.RunProc("sp_BBS_DelAttachmentToItem",prams1);
  1210. }
  1211.         
  1212. }
  1213. public class BBSReplay
  1214. {
  1215. private int m_ReplayId;
  1216. private int m_ItemId;
  1217. private string m_Content;
  1218. private string m_Replayer;
  1219. private string m_ReplayTime;
  1220. private string m_ReplayIP;
  1221.         
  1222. public int ReplayId
  1223. {
  1224. //
  1225. get { return m_ReplayId; }
  1226. set { m_ReplayId = value; }
  1227. }
  1229. public int ItemID
  1230. {
  1231. //
  1232. get { return m_ItemId; }
  1233. set { m_ItemId = value; }
  1234. }
  1236. public string Content
  1237. {
  1238. //
  1239. get { return m_Content; }
  1240. set { m_Content = value;}
  1241. }
  1243. public string Replayer
  1244. {
  1245. //
  1246. get { return m_Replayer; }
  1247. set { m_Replayer = value; }
  1248. }
  1250. public string ReplayTime
  1251. {
  1252. //
  1253. get { return m_ReplayTime; }
  1254. set { m_ReplayTime = value; }
  1255. }
  1257. public string ReplayIP
  1258. {
  1259. //
  1260. get { return m_ReplayIP; }
  1261. set { m_ReplayIP = value; }
  1262. }
  1264. /// <summary>
  1265. /// 将附件和回复绑定
  1266. /// </summary>
  1267. /// <param name="filenames">文件名,多个文件名用 , 分开</param>
  1268. public void Attach(string filenames)
  1269. {
  1270. UDS.Components.Database data = new UDS.Components.Database ();
  1271. string[] arrfilename = filenames.Split(',');
  1272. for(int i=0;i<arrfilename.Length;i++)
  1273. {
  1274. if(arrfilename[i].Trim()!="")
  1275. {
  1276. SqlParameter[] prams = {
  1277.    data.MakeInParam("@replayid",  SqlDbType.Int, 4,this.ReplayId),
  1278.    data.MakeInParam("@filename",  SqlDbType.VarChar, 500,arrfilename[i])
  1279.    };
  1280. data.RunProc ("sp_BBS_AttachmentToReplay",prams);
  1281. }
  1283. }
  1284. }
  1286. /// <summary>
  1287. /// 删除附件
  1288. /// </summary>
  1289. public void DelAttachment(string attachmentmd)
  1290. {
  1291. UDS.Components.Database data = new UDS.Components.Database ();
  1292. SqlParameter[] prams = {
  1293.    data.MakeInParam("@replayid",  SqlDbType.Int, 4,this.ReplayId),
  1294.    };
  1295. SqlDataReader dr = null;
  1296. data.RunProc ("sp_BBS_GetReplayAttachment",prams,out dr);
  1297. while(dr.Read())
  1298. {
  1299. System.IO.File.Delete(attachmentmd+"\"+dr["filename"].ToString());
  1300. }
  1301. data.Close();
  1302. SqlParameter[] prams1 = {
  1303.    data.MakeInParam("@replayid",  SqlDbType.Int, 4,this.ReplayId),
  1304. };
  1305. data.RunProc("sp_BBS_DelAttachmentToReplay",prams1);
  1306. }
  1307. }
  1310. public class BBSSearchOption
  1311. {
  1312. private int _boardid;
  1313. private TimeSpan _time;
  1314. private BBSSearchType _searchtype;
  1316. public int BoardID
  1317. {
  1318. get
  1319. {
  1320. return _boardid;
  1321. }
  1322. set
  1323. {
  1324. _boardid = value;
  1325. }
  1326. }
  1328. public TimeSpan TimeBound
  1329. {
  1330. get
  1331. {
  1332. return _time;
  1333. }
  1334. set
  1335. {
  1336. _time = value;
  1337. }
  1338. }
  1340. public BBSSearchType searchtype
  1341. {
  1342. get
  1343. {
  1344. return _searchtype;
  1345. }
  1346. set
  1347. {
  1348. _searchtype = value;
  1349. }
  1350. }
  1352. }
  1354. public enum BBSSearchType{author,title}