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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > .net编程 > 查看源码
MsgObj.cs
资源名称：ASP[1].NET.rar　[点击查看]
上传用户：autodoor
上传日期：2022-08-04
资源大小：9973k
文件大小：16k
源码类别：

.net编程

开发平台：

Others

MsgObj.cs：源码内容
  1. using System;
  2. using qminoa.Common.Data;
  3. using System.Data;
  4. using System.Data.SqlClient;
  5. namespace qminoa.DA
  6. {
  7. public class MsgObj
  8. {
  9. private SqlConnection conn;
  10. public MsgObj()
  11. {
  12. conn  = new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["ConnectionString"]);
  13. }
  15. public void InsertMessage(MsgCont msgobj,string Type,int personid)
  16. {
  17. SqlCommand command  = new SqlCommand();
  18. command.CommandText = "Msg_SendSave";
  19. command.CommandType = CommandType.StoredProcedure;
  20. command.Connection  = conn;
  22. SqlParameter [] paras = {   new SqlParameter("@MessagePersonID",SqlDbType.Int),
  23. new SqlParameter("@SendTo",SqlDbType.NVarChar,200),
  24. new SqlParameter("@SecretTo",SqlDbType.NVarChar,200),
  25. new SqlParameter("@SendToID",SqlDbType.NVarChar,200),
  26. new SqlParameter("@SecretToID",SqlDbType.NVarChar,200),
  27. new SqlParameter("@Title",SqlDbType.NVarChar,50),
  28. new SqlParameter("@Content",SqlDbType.Text),
  29. new SqlParameter("@SendDate",SqlDbType.DateTime),
  30. new SqlParameter("@Accessory",SqlDbType.NVarChar,200),
  31. new SqlParameter("@AccessoryID",SqlDbType.NVarChar,200),
  32. new SqlParameter("@Status",SqlDbType.Int),
  33. new SqlParameter("@Important",SqlDbType.Bit),
  34. new SqlParameter("@RetValue",SqlDbType.Int)
  35. };
  36. paras[0].Value = personid;
  37. paras[1].Value = msgobj.SendTo;
  38. paras[2].Value = msgobj.SecretTo;
  39. paras[3].Value = msgobj.SendToID;
  40. paras[4].Value = msgobj.SecretToID;
  41. paras[5].Value = msgobj.Title;
  42. paras[6].Value = msgobj.Content;
  43. paras[7].Value = msgobj.SendTime;
  44. paras[8].Value = msgobj.Accessory;
  45. paras[9].Value = msgobj.AccessoryID;
  46. if("发送" == Type)
  47. {
  48. paras[10].Value = 0;
  49. }
  50. else if( "保存" == Type)
  51. {
  52. paras[10].Value = 2;
  53. }
  54. paras[11].Value = msgobj.Important;
  55. paras[12].Direction = ParameterDirection.ReturnValue;
  56. foreach(SqlParameter para in paras)
  57. {
  58. command.Parameters.Add(para);
  59. }
  60. conn.Open();
  61. command.ExecuteNonQuery();
  62. int msgkey = Convert.ToInt32(command.Parameters["@RetValue"].Value.ToString(),10);
  63. conn.Close();
  65. if("发送" == Type)
  66. {
  67. AddMsgIndex(msgkey,msgobj.SendToID,msgobj.SecretToID,msgobj.SendTime,msgobj.Important);
  68. }
  69. }
  71. public void AddMsgIndex(int MsgKey,string SendToID,string SecretToID,DateTime senddate,bool Important)
  72. {
  73. char [] separator = new char[1];
  74. char [] separator2 = new Char[1];
  75. separator[0]  = ',';
  76. separator2[0] = '*';
  77. MsgAdd msgindex = new MsgAdd();
  78. DataRow row ;
  79. if( SendToID != "" && SendToID != null)
  80. {
  81. string [] senddepartid = SendToID.Split(separator,50);
  82. for(int i = 0; i < senddepartid.Length; i ++)
  83. {
  84. int pos = senddepartid[i].IndexOf("*");
  85. string [] sendid = senddepartid[i].Split(separator2,2);
  86. if( pos != -1)
  87. {
  88. row = msgindex.Tables["MsgAdd"].NewRow();
  89. row[MsgAdd.MSGID_FIELD] = MsgKey;
  90. row[MsgAdd.MSGPERSONID_FIELD] = Convert.ToInt32(sendid[1],10);
  91. row[MsgAdd.SENDLEVEL_FIELD]   = 0;
  92. row[MsgAdd.TIMES_FIELD]  = 0;
  93. row[MsgAdd.STATUS_FIELD] = 4;
  94. row[MsgAdd.DELETEFLAG_FIELD] = 0;
  95. row[MsgAdd.SENDDATE_FIELD] = senddate;
  96. row[MsgAdd.IMPORTANT_FIELD] = Important;
  97. msgindex.Tables[MsgAdd.MSGADD_TABLE].Rows.Add(row);
  98. }
  99. else
  100. {
  101. int departid = Convert.ToInt32(senddepartid[i],10);
  102. SelectPersonByDepart(departid,msgindex,MsgKey,senddate,0,Important);
  103. }
  104. }
  105. }
  106. if( SecretToID != "" && SecretToID != null)
  107. {
  108. string [] secretdepartid = SecretToID.Split(separator,10);
  109. for(int j = 0; j < secretdepartid.Length; j ++)
  110. {
  111. int pos = secretdepartid[j].IndexOf("*");
  112. string [] secretid = secretdepartid[j].Split(separator2,2);
  113. if(pos != -1)
  114. {
  115. row = msgindex.Tables["MsgAdd"].NewRow();
  116. row[MsgAdd.MSGID_FIELD] = MsgKey;
  117. row[MsgAdd.MSGPERSONID_FIELD] = Convert.ToInt32(secretid[1],10);
  118. row[MsgAdd.SENDLEVEL_FIELD]   = 1;
  119. row[MsgAdd.TIMES_FIELD]  = 0;
  120. row[MsgAdd.STATUS_FIELD] = 4;
  121. row[MsgAdd.DELETEFLAG_FIELD] = 0;
  122. row[MsgAdd.SENDDATE_FIELD] = senddate;
  123. row[MsgAdd.IMPORTANT_FIELD] = Important;
  124. msgindex.Tables[MsgAdd.MSGADD_TABLE].Rows.Add(row);
  125. }
  126. else
  127. {
  128. int depart = Convert.ToInt32(secretdepartid[j],10);
  129. SelectPersonByDepart(depart,msgindex,MsgKey,senddate,1,Important);
  130. }
  131. }
  132. }
  133. SqlDataAdapter cscommand = new SqlDataAdapter();
  134. cscommand.SelectCommand  = new SqlCommand("select * from MsgAdd");
  135. cscommand.SelectCommand.Connection = conn;
  136. SqlCommandBuilder objBuilder = new SqlCommandBuilder(cscommand);
  137. cscommand.Update(msgindex,"MsgAdd");
  138. }
  140. public void SelectPersonByDepart(int DepartID,MsgAdd msgobj,int MsgKey,DateTime senddate,int send_level,bool Important)
  141. {
  142. SqlCommand command  = new SqlCommand();
  143. command.CommandText = "Msg_GetEmpByDep";
  144. SqlParameter para   = new SqlParameter("@DepartID",SqlDbType.Int);
  145. command.CommandType = CommandType.StoredProcedure;
  146. para.Value = DepartID; 
  147. command.Parameters.Add(para);
  148. command.Connection  = conn;
  149. if(conn.State == ConnectionState.Closed)
  150. conn.Open();
  151. SqlDataReader reader;
  152. reader = command.ExecuteReader();
  153. DataRow row;
  154. while(reader.Read())
  155. {
  156. row = msgobj.Tables["MsgAdd"].NewRow();
  157. row[MsgAdd.MSGID_FIELD] = MsgKey;
  158. row[MsgAdd.MSGPERSONID_FIELD] = Convert.ToInt32(reader["EmpID"].ToString(),10);
  159. row[MsgAdd.SENDLEVEL_FIELD]   = send_level;
  160. row[MsgAdd.TIMES_FIELD]  = 0;
  161. row[MsgAdd.STATUS_FIELD] = 4;
  162. row[MsgAdd.DELETEFLAG_FIELD] = 0;
  163. row[MsgAdd.SENDDATE_FIELD] = senddate;
  164. row[MsgAdd.IMPORTANT_FIELD] = Important;
  165. msgobj.Tables[MsgAdd.MSGADD_TABLE].Rows.Add(row);
  166. }
  167. reader.Close();
  168. conn.Close();
  169. }
  171. public DataSet SeeMessage(string type,int PersonID)
  172. {
  173. DataSet msgobj = new DataSet();
  174. SqlDataAdapter csCommand = new SqlDataAdapter();
  175. SqlCommand command = new SqlCommand();
  176. csCommand.SelectCommand = command;
  177. command.CommandText = "Msg_GetMsgById";
  178. command.CommandType = CommandType.StoredProcedure;
  179. SqlParameter [] paras  = {   new SqlParameter("@Type",SqlDbType.Int),
  180.      new SqlParameter("@PersonID",SqlDbType.Int)
  181.   };
  182. if("recnote" == type)
  183. {
  184. paras[0].Value = 0;
  185. }
  186. else if ("sendnote" == type)
  187. {
  188. paras[0].Value = 1;
  189. }
  190. else if ( "caonote" == type)
  191. {
  192. paras[0].Value = 2;
  193. }
  194. else
  195. {
  196. paras[0].Value = 3;
  197. }
  198. paras[1].Value = PersonID;
  199. foreach(SqlParameter para in paras)
  200. {
  201. command.Parameters.Add(para);
  202. }
  203. csCommand.SelectCommand.Connection = conn;
  204. csCommand.Fill(msgobj,"simpleobj");
  205. return msgobj;
  206. }
  208. public MessageData SeeAllMessage(string messageid,string status)
  209. {
  210. MessageData msgobj = new MessageData();
  211. SqlDataAdapter csCommand = new SqlDataAdapter();
  212. SqlCommand command = new SqlCommand();
  213. csCommand.SelectCommand = command;
  214. command.CommandText = "Msg_GetAllMsg";
  215. command.CommandType = CommandType.StoredProcedure;
  216. SqlParameter [] paras  = {  
  217.  new SqlParameter("@MessageID",SqlDbType.Int),
  218.  new SqlParameter("@sendperson",SqlDbType.NVarChar,50),
  219.  new SqlParameter("@Status",SqlDbType.Int)
  220.  };
  221. paras[0].Value = Convert.ToInt32(messageid,10);
  222. paras[1].Direction = ParameterDirection.Output;
  223. paras[2].Value = Convert.ToInt32(status,10);
  224. foreach(SqlParameter para in paras)
  225. {
  226. command.Parameters.Add(para);
  227. }
  228. csCommand.SelectCommand.Connection = conn;
  229. csCommand.Fill(msgobj,MessageData.MESSAGE_TABLE);
  230. int count = msgobj.Tables[MessageData.MESSAGE_TABLE].Rows.Count;
  231. string sendperson = command.Parameters["@sendperson"].Value.ToString();
  232. for(int i = 0; i < count; i ++)
  233. {
  234. msgobj.Tables[MessageData.MESSAGE_TABLE].Rows[i][MessageData.MESSAGEPERSON_FIELD] = sendperson;
  235. }
  236. return msgobj;
  237. }
  239. public void WatchTimesAdd(string reid)
  240. {
  241. SqlCommand command  = new SqlCommand();
  242. command.CommandText = "Mag_AddTimes";
  243. command.CommandType = CommandType.StoredProcedure;
  244. command.Connection  = conn;
  245. SqlParameter para   = new SqlParameter("@reID",SqlDbType.Int);
  246. para.Value = Convert.ToInt32(reid,10);
  247. command.Parameters.Add(para);
  248. conn.Open();
  249. command.ExecuteNonQuery();
  250. conn.Close();
  251. }
  253. public int [] MsgNotice(int personid)
  254. {
  255. SqlCommand command = new SqlCommand();
  256. command.CommandText = "Msg_Notice";
  257. command.CommandType = CommandType.StoredProcedure;
  258. SqlParameter [] paras = {   new SqlParameter("@personid",SqlDbType.Int),
  259. new SqlParameter("@seen",SqlDbType.Int),
  260. new SqlParameter("@unseen",SqlDbType.Int)
  261. };
  262. paras[0].Value = personid;
  263. paras[1].Direction = ParameterDirection.Output;
  264. paras[2].Direction = ParameterDirection.Output;
  266. foreach(SqlParameter para in paras)
  267. {
  268. command.Parameters.Add(para);
  269. }
  270. command.Connection = conn;
  271. conn.Open();
  273. command.ExecuteNonQuery();
  275. int [] see = new int[2];
  276. see[0] = Convert.ToInt32(command.Parameters["@seen"].Value.ToString(),10);
  277. see[1] = Convert.ToInt32(command.Parameters["@unseen"].Value.ToString(),10);
  278. return see;
  279. }
  281. public DataSet SeeDraft(string msgid,string personid)
  282. {
  283. SqlDataAdapter csCommand = new SqlDataAdapter();
  284. SqlCommand command = new SqlCommand();
  285. command.CommandType = CommandType.StoredProcedure;
  286. command.CommandText = "Msg_GetDraft";
  287. SqlParameter [] paras = {   new SqlParameter("@personid",SqlDbType.Int),
  288. new SqlParameter("@msgid",SqlDbType.Int)
  289. };
  290. paras[0].Value = personid;
  291. paras[1].Value = msgid;
  292. foreach(SqlParameter para in paras)
  293. command.Parameters.Add(para);
  294. csCommand.SelectCommand = command;
  295. csCommand.SelectCommand.Connection = conn;
  296. DataSet data = new DataSet();
  297. csCommand.Fill(data,"draftmsg");
  298. return data;
  299. }
  302. public void InsertAgain(string msgid, MsgCont msgobj,int _status)
  303. {
  304. SqlCommand command  = new SqlCommand();
  305. command.CommandText = "Msg_SendAgain";
  306. command.CommandType = CommandType.StoredProcedure;
  307. command.Connection  = conn;
  309. SqlParameter [] paras = {   new SqlParameter("@msgid",SqlDbType.Int),
  310. new SqlParameter("@SendTo",SqlDbType.NVarChar,200),
  311. new SqlParameter("@SecretTo",SqlDbType.NVarChar,200),
  312. new SqlParameter("@SendToID",SqlDbType.NVarChar,200),
  313. new SqlParameter("@SecretToID",SqlDbType.NVarChar,200),
  314. new SqlParameter("@Title",SqlDbType.NVarChar,50),
  315. new SqlParameter("@Content",SqlDbType.Text),
  316. new SqlParameter("@SendDate",SqlDbType.DateTime),
  317. new SqlParameter("@Accessory",SqlDbType.NVarChar,200),
  318. new SqlParameter("@AccessoryID",SqlDbType.NVarChar,200),
  319. new SqlParameter("@Status",SqlDbType.Int),
  320. new SqlParameter("@Important",SqlDbType.Bit)
  321. };
  322. paras[0].Value = Convert.ToInt32(msgid,10);
  323. paras[1].Value = msgobj.SendTo;
  324. paras[2].Value = msgobj.SecretTo;
  325. paras[3].Value = msgobj.SendToID;
  326. paras[4].Value = msgobj.SecretToID;
  327. paras[5].Value = msgobj.Title;
  328. paras[6].Value = msgobj.Content;
  329. paras[7].Value = msgobj.SendTime;
  330. paras[8].Value = msgobj.Accessory;
  331. paras[9].Value = msgobj.AccessoryID;
  332. paras[10].Value = _status; //此参数表示是发送还是再次保存
  333. paras[11].Value = msgobj.Important;
  334. foreach(SqlParameter para in paras)
  335. command.Parameters.Add(para);
  336. conn.Open();
  337. command.ExecuteNonQuery();
  338. conn.Close();
  339. if(_status == 0)
  340. {
  341. int msgkey = Convert.ToInt32(msgid,10);
  342. AddMsgIndex(msgkey,msgobj.SendToID,msgobj.SecretToID,msgobj.SendTime,msgobj.Important);
  343. }
  344. }
  346. public void DeleteMessage(string msgid,string personid,string status)
  347. {
  348. SqlCommand command = new SqlCommand();
  349. command.CommandText = "Msg_DelMsg";
  350. command.CommandType = CommandType.StoredProcedure;
  351. command.Connection  = conn;
  352. SqlParameter [] paras = {   new SqlParameter("@msgid",SqlDbType.Int),
  353. new SqlParameter("@personid", SqlDbType.Int),
  354. new SqlParameter("@status" ,SqlDbType.Int)
  355. };
  356. paras[0].Value = Convert.ToInt32(msgid);
  357. paras[1].Value = Convert.ToInt32(personid);
  358. paras[2].Value = Convert.ToInt32(status);
  359. foreach(SqlParameter para in paras)
  360. {
  361. command.Parameters.Add(para);
  362. }
  363. conn.Open();
  364. command.ExecuteNonQuery();
  365. conn.Close();
  366. }
  369. public void MoveMessage(string msgid,string personid, string status)
  370. {
  371. SqlCommand command = new SqlCommand();
  372. command.CommandText = "Msg_MoveMsg";
  373. command.CommandType = CommandType.StoredProcedure;
  374. command.Connection  = conn;
  375. SqlParameter [] paras = {   new SqlParameter("@msgid",SqlDbType.Int),
  376. new SqlParameter("@personid", SqlDbType.Int),
  377. new SqlParameter("@status" ,SqlDbType.Int)
  378. };
  379. paras[0].Value = Convert.ToInt32(msgid);
  380. paras[1].Value = Convert.ToInt32(personid);
  381. paras[2].Value = Convert.ToInt32(status);
  382. foreach(SqlParameter para in paras)
  383. {
  384. command.Parameters.Add(para);
  385. }
  386. conn.Open();
  387. command.ExecuteNonQuery();
  388. conn.Close();
  389. }
  391. public string [] MsgFolder(string personid)
  392. {
  393. SqlCommand command = new SqlCommand();
  394. command.CommandText = "Msg_Folder";
  395. command.CommandType = CommandType.StoredProcedure;
  396. command.Connection  = conn;
  397. SqlParameter [] paras = {   new SqlParameter("@personid",SqlDbType.Int),
  398. new SqlParameter("@send",SqlDbType.Int),
  399. new SqlParameter("@resive_new",SqlDbType.Int),
  400. new SqlParameter("@resive_old",SqlDbType.Int),
  401. new SqlParameter("@draft",SqlDbType.Int),
  402. new SqlParameter("@rubbish_1",SqlDbType.Int),
  403.                         new SqlParameter("@rubbish_2",SqlDbType.Int)
  404. };
  405. paras[0].Value = Convert.ToInt32(personid,10);
  406. paras[1].Direction = ParameterDirection.Output;
  407. paras[2].Direction = ParameterDirection.Output;
  408. paras[3].Direction = ParameterDirection.Output;
  409. paras[4].Direction = ParameterDirection.Output;
  410. paras[5].Direction = ParameterDirection.Output;
  411. paras[6].Direction = ParameterDirection.Output;
  413. foreach(SqlParameter para in paras)
  414. {
  415. command.Parameters.Add(para);
  416. }
  418. conn.Open();
  419. command.ExecuteNonQuery();
  420. string [] info_list = new string [6];
  421. info_list[0] = command.Parameters["@send"].Value.ToString();
  422. info_list[1] = command.Parameters["@resive_new"].Value.ToString();
  423. info_list[2] = command.Parameters["@resive_old"].Value.ToString();
  424. info_list[3] = command.Parameters["@draft"].Value.ToString();
  425. info_list[4] = command.Parameters["@rubbish_1"].Value.ToString();
  426. info_list[5] = command.Parameters["@rubbish_2"].Value.ToString();
  427. conn.Close();
  428. return info_list;
  429. }
  432. public void RemainMsg(string msgid,string personid,string status)
  433. {
  434. SqlCommand command = new SqlCommand();
  435. command.CommandText = "Msg_RemainMsg";
  436. command.CommandType = CommandType.StoredProcedure;
  437. command.Connection  = conn;
  438. SqlParameter [] paras = {   new SqlParameter("@msgid",SqlDbType.Int),
  439. new SqlParameter("@personid", SqlDbType.Int),
  440. new SqlParameter("@status" ,SqlDbType.Int)
  441. };
  442. paras[0].Value = Convert.ToInt32(msgid);
  443. paras[1].Value = Convert.ToInt32(personid);
  444. paras[2].Value = Convert.ToInt32(status);
  445. foreach(SqlParameter para in paras)
  446. {
  447. command.Parameters.Add(para);
  448. }
  449. conn.Open();
  450. command.ExecuteNonQuery();
  451. conn.Close();
  452. }
  453. }
  454. }