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

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

.net编程

开发平台：

Others

ScheduleDA.cs：源码内容
  1. using System;
  2. using System.Data;
  3. using System.Data.SqlClient;
  4. using qminoa.Common.Data;
  6. namespace qminoa.DA.Schedule
  7. {
  8. public class ScheduleDA
  9. {
  10. private String conn=System.Configuration.ConfigurationSettings.AppSettings.Get("ConnectionString");
  12. public ScheduleDA()
  13. {
  15. }
  17. public SqlCommand cpOtherManRead(int schid)
  18. {
  19. SqlConnection objconnection = new SqlConnection(conn);
  20. SqlCommand objcommand=new SqlCommand();
  21. objcommand.Connection =objconnection;  
  22. objcommand.CommandText = "cpOtherManRead";
  23. objcommand.CommandType = CommandType.StoredProcedure;
  24. objcommand.Parameters.Add(new SqlParameter("@schid", SqlDbType.Int));
  25. objcommand.Parameters["@schid"].Value=schid;
  26. return objcommand;
  27. }
  29. public SqlCommand SchRead(int EmpID,DateTime FDate)
  30. {
  31. SqlConnection objconnection = new SqlConnection(conn);
  32. SqlCommand objcommand=new SqlCommand(); 
  33. objcommand.Connection =objconnection;
  34. objcommand.CommandText = "cpMyAllSch";
  35. objcommand.CommandType = CommandType.StoredProcedure; 
  36. objcommand.Parameters.Add(new SqlParameter("@EmpID", SqlDbType.Int));
  37. objcommand.Parameters["@EmpID"].Value=EmpID;
  38. objcommand.Parameters.Add(new SqlParameter("@FDate", SqlDbType.DateTime));
  39. objcommand.Parameters["@FDate"].Value=FDate;
  40. return objcommand;
  41. }
  43. public int IsMySchedule(int EmpID,int id)
  44. {
  45. int opt = -1;
  46. SqlCommand objcommand = new SqlCommand();
  47. SqlDataReader cpread;
  48. SqlConnection objconnection = new SqlConnection(conn);
  49. objcommand.Connection =objconnection;
  50. objcommand.CommandText = "cpIsMySchedule";
  51. objcommand.CommandType = CommandType.StoredProcedure;
  52. objcommand.Parameters.Add(new SqlParameter("@SchID", SqlDbType.Int));
  53. objcommand.Parameters["@SchID"].Value=id;
  54. objcommand.Connection.Open();
  55. cpread = objcommand.ExecuteReader();
  56. cpread.Read();
  57. if(EmpID == Int16.Parse(cpread.GetValue(0).ToString()))
  58. {
  59. opt = 0;
  60. }
  61. cpread.Close();
  62. objcommand.Connection.Close();
  63. return opt;
  64. }
  66. public DataSet cpMySch(int SchID)
  67. {
  68. SqlCommand command = new SqlCommand();
  69. command.CommandText = "cpMySchByID";
  70. command.CommandType = CommandType.StoredProcedure;
  71. command.Connection = new SqlConnection(conn);
  72. SqlParameter param = new SqlParameter(paramChg(ScheduleData.SCHID_FIELD),SqlDbType.Int);
  73. param.Value = SchID;
  74. command.Parameters.Add(param);
  75. SqlDataAdapter commandAdp = new SqlDataAdapter();
  76. commandAdp.SelectCommand = command;
  77. DataSet data = new DataSet();
  78. try
  79. {
  80. commandAdp.Fill(data);
  81. }
  82. catch(Exception ex)
  83. {
  84. throw new ApplicationException(ex.ToString());
  85. }
  86. return data;
  87. }
  89. public DataSet cpScheduleTip(int empID)
  90. {
  91. SqlCommand command = new SqlCommand();
  92. command.CommandText = "cpScheduleTip";
  93. command.CommandType = CommandType.StoredProcedure;
  94. command.Connection = new SqlConnection(conn);
  95. SqlParameter param = new SqlParameter("@EmpID",SqlDbType.Int);
  96. param.Value = empID;
  97. command.Parameters.Add(param);
  98. SqlDataAdapter commandAdp = new SqlDataAdapter();
  99. commandAdp.SelectCommand = command;
  100. DataSet data = new DataSet();
  101. try
  102. {
  103. commandAdp.Fill(data);
  104. }
  105. catch(Exception ex)
  106. {
  107. throw new ApplicationException(ex.ToString());
  108. }
  109. return data;
  110. }
  112. public void cpSchDel(int schid)
  113. {
  114. SqlConnection objconnection = new SqlConnection(conn);
  115. SqlCommand objcommand=new SqlCommand(); 
  116. objcommand.Connection =objconnection;  
  117. objcommand.CommandText = "cpSchDel";
  118. objcommand.CommandType = CommandType.StoredProcedure;
  119.   objcommand.Parameters.Add(new SqlParameter("@schid", SqlDbType.Int));
  120. objcommand.Parameters["@schid"].Value=schid;
  121. objcommand.Connection.Open();
  122. objcommand.ExecuteNonQuery();
  123. objcommand.Connection.Close();
  124. }
  126. public void cpDelOtherMan(int schid)
  127. {
  128. SqlConnection objconnection = new SqlConnection(conn);
  129. SqlCommand objcommand=new SqlCommand(); 
  130. objcommand.Connection =objconnection;  
  131. objcommand.CommandText = "cpDelOtherMan";
  132. objcommand.CommandType = CommandType.StoredProcedure; 
  133. objcommand.Parameters.Add(new SqlParameter("@schid", SqlDbType.Int));
  134. objcommand.Parameters["@schid"].Value=schid;
  135. objcommand.Connection.Open();
  136. objcommand.ExecuteNonQuery();
  137. objcommand.Connection.Close();
  138. }
  140. public void cpOtherManAddUp(int schid,string otherman)
  141. {
  142. SqlConnection objconnection = new SqlConnection(conn);
  143. SqlCommand objcommand=new SqlCommand(); 
  144. objcommand.Connection =objconnection;  
  145. objcommand.CommandText = "cpOtherManAddUp";
  146. objcommand.CommandType = CommandType.StoredProcedure; 
  147. objcommand.Parameters.Add(new SqlParameter("@schid", SqlDbType.Int));
  148. objcommand.Parameters["@schid"].Value=schid;
  149. objcommand.Parameters.Add(new SqlParameter("@otherman", SqlDbType.VarChar));
  150. objcommand.Parameters["@otherman"].Value=otherman;
  151. objcommand.Connection.Open();
  152. objcommand.ExecuteNonQuery();
  153. objcommand.Connection.Close();
  154. }
  156. public int ScheduleAdd(ScheduleData schdata)
  157. {
  158. SqlCommand command = new SqlCommand();
  159. command.CommandType = CommandType.StoredProcedure;
  160. command.Connection = new SqlConnection(conn);
  161. command.CommandText = "cpScheduleAdd";
  162. SqlParameter paramTmp = new SqlParameter("@Identify",SqlDbType.Int);
  163. paramTmp.Direction = ParameterDirection.ReturnValue;
  164. command.Parameters.Add(paramTmp);
  165. command.Parameters.Add(paramChg(ScheduleData.EMPID_FIELD),SqlDbType.Int);
  166. command.Parameters.Add(paramChg(ScheduleData.SUBJECT_FIELD),SqlDbType.VarChar);
  167. command.Parameters.Add(paramChg(ScheduleData.SCHTYPE_FIELD),SqlDbType.VarChar);
  168. command.Parameters.Add(paramChg(ScheduleData.PLACE_FIELD),SqlDbType.VarChar);
  169. command.Parameters.Add(paramChg(ScheduleData.CONTENT_FIELD),SqlDbType.Text);
  170. command.Parameters.Add(paramChg(ScheduleData.PRIVFLAG_FIELD),SqlDbType.Bit);
  171. command.Parameters.Add(paramChg(ScheduleData.REPEATFLAG_FIELD),SqlDbType.Bit);
  172. command.Parameters.Add(paramChg(ScheduleData.REQUENCATE_FIELD),SqlDbType.Char);
  173. command.Parameters.Add(paramChg(ScheduleData.UPTODATE_FIELD),SqlDbType.DateTime);
  174. command.Parameters.Add(paramChg(ScheduleData.REMINDFLAG_FIELD),SqlDbType.Bit);
  175. command.Parameters.Add(paramChg(ScheduleData.REMINDDAY_FIELD),SqlDbType.SmallInt);
  176. command.Parameters.Add(paramChg(ScheduleData.FDATE_FIELD),SqlDbType.DateTime);
  177. command.Parameters.Add(paramChg(ScheduleData.TDATE_FIELD),SqlDbType.DateTime);
  178. command.Parameters[paramChg(ScheduleData.EMPID_FIELD)].SourceColumn = ScheduleData.EMPID_FIELD;
  179. command.Parameters[paramChg(ScheduleData.SUBJECT_FIELD)].SourceColumn = ScheduleData.SUBJECT_FIELD;
  180. command.Parameters[paramChg(ScheduleData.SCHTYPE_FIELD)].SourceColumn = ScheduleData.SCHTYPE_FIELD;
  181. command.Parameters[paramChg(ScheduleData.PLACE_FIELD)].SourceColumn = ScheduleData.PLACE_FIELD;
  182. command.Parameters[paramChg(ScheduleData.CONTENT_FIELD)].SourceColumn = ScheduleData.CONTENT_FIELD;
  183. command.Parameters[paramChg(ScheduleData.PRIVFLAG_FIELD)].SourceColumn = ScheduleData.PRIVFLAG_FIELD;
  184. command.Parameters[paramChg(ScheduleData.REPEATFLAG_FIELD)].SourceColumn = ScheduleData.REPEATFLAG_FIELD;
  185. command.Parameters[paramChg(ScheduleData.REQUENCATE_FIELD)].SourceColumn = ScheduleData.REQUENCATE_FIELD;
  186. command.Parameters[paramChg(ScheduleData.UPTODATE_FIELD)].SourceColumn = ScheduleData.UPTODATE_FIELD;
  187. command.Parameters[paramChg(ScheduleData.REMINDFLAG_FIELD)].SourceColumn = ScheduleData.REMINDFLAG_FIELD;
  188. command.Parameters[paramChg(ScheduleData.REMINDDAY_FIELD)].SourceColumn = ScheduleData.REMINDDAY_FIELD;
  189. command.Parameters[paramChg(ScheduleData.FDATE_FIELD)].SourceColumn = ScheduleData.FDATE_FIELD;
  190. command.Parameters[paramChg(ScheduleData.TDATE_FIELD)].SourceColumn = ScheduleData.TDATE_FIELD;
  191. SqlDataAdapter commandAdp = new SqlDataAdapter();
  192. commandAdp.UpdateCommand = command;
  193. int result = commandAdp.Update(schdata,ScheduleData.SCHEDULE_TABLE);
  194. if(result>0)
  195. return (int)commandAdp.UpdateCommand.Parameters["@Identify"].Value;
  196. else
  197. return 0;
  198. }
  200. public bool ScheduleUpdate(ScheduleData schdata)
  201. {
  202. SqlCommand command = new SqlCommand();
  203. command.CommandType = CommandType.StoredProcedure;
  204. command.Connection = new SqlConnection(conn);
  205. command.CommandText = "cpScheduleUpdate";
  206. command.Parameters.Add(paramChg(ScheduleData.SCHID_FIELD),SqlDbType.Int);
  207. command.Parameters.Add(paramChg(ScheduleData.EMPID_FIELD),SqlDbType.Int);
  208. command.Parameters.Add(paramChg(ScheduleData.SUBJECT_FIELD),SqlDbType.VarChar);
  209. command.Parameters.Add(paramChg(ScheduleData.SCHTYPE_FIELD),SqlDbType.VarChar);
  210. command.Parameters.Add(paramChg(ScheduleData.PLACE_FIELD),SqlDbType.VarChar);
  211. command.Parameters.Add(paramChg(ScheduleData.CONTENT_FIELD),SqlDbType.Text);
  212. command.Parameters.Add(paramChg(ScheduleData.PRIVFLAG_FIELD),SqlDbType.Bit);
  213. command.Parameters.Add(paramChg(ScheduleData.REPEATFLAG_FIELD),SqlDbType.Bit);
  214. command.Parameters.Add(paramChg(ScheduleData.REQUENCATE_FIELD),SqlDbType.Char);
  215. command.Parameters.Add(paramChg(ScheduleData.UPTODATE_FIELD),SqlDbType.DateTime);
  216. command.Parameters.Add(paramChg(ScheduleData.REMINDFLAG_FIELD),SqlDbType.Bit);
  217. command.Parameters.Add(paramChg(ScheduleData.REMINDDAY_FIELD),SqlDbType.SmallInt);
  218. command.Parameters.Add(paramChg(ScheduleData.FDATE_FIELD),SqlDbType.DateTime);
  219. command.Parameters.Add(paramChg(ScheduleData.TDATE_FIELD),SqlDbType.DateTime);
  220. command.Parameters[paramChg(ScheduleData.SCHID_FIELD)].SourceColumn = ScheduleData.SCHID_FIELD;
  221. command.Parameters[paramChg(ScheduleData.EMPID_FIELD)].SourceColumn = ScheduleData.EMPID_FIELD;
  222. command.Parameters[paramChg(ScheduleData.SUBJECT_FIELD)].SourceColumn = ScheduleData.SUBJECT_FIELD;
  223. command.Parameters[paramChg(ScheduleData.SCHTYPE_FIELD)].SourceColumn = ScheduleData.SCHTYPE_FIELD;
  224. command.Parameters[paramChg(ScheduleData.PLACE_FIELD)].SourceColumn = ScheduleData.PLACE_FIELD;
  225. command.Parameters[paramChg(ScheduleData.CONTENT_FIELD)].SourceColumn = ScheduleData.CONTENT_FIELD;
  226. command.Parameters[paramChg(ScheduleData.PRIVFLAG_FIELD)].SourceColumn = ScheduleData.PRIVFLAG_FIELD;
  227. command.Parameters[paramChg(ScheduleData.REPEATFLAG_FIELD)].SourceColumn = ScheduleData.REPEATFLAG_FIELD;
  228. command.Parameters[paramChg(ScheduleData.REQUENCATE_FIELD)].SourceColumn = ScheduleData.REQUENCATE_FIELD;
  229. command.Parameters[paramChg(ScheduleData.UPTODATE_FIELD)].SourceColumn = ScheduleData.UPTODATE_FIELD;
  230. command.Parameters[paramChg(ScheduleData.REMINDFLAG_FIELD)].SourceColumn = ScheduleData.REMINDFLAG_FIELD;
  231. command.Parameters[paramChg(ScheduleData.REMINDDAY_FIELD)].SourceColumn = ScheduleData.REMINDDAY_FIELD;
  232. command.Parameters[paramChg(ScheduleData.FDATE_FIELD)].SourceColumn = ScheduleData.FDATE_FIELD;
  233. command.Parameters[paramChg(ScheduleData.TDATE_FIELD)].SourceColumn = ScheduleData.TDATE_FIELD;
  235. SqlDataAdapter commandAdp = new SqlDataAdapter();
  236. commandAdp.UpdateCommand = command;
  237. commandAdp.Update(schdata,ScheduleData.SCHEDULE_TABLE);
  238. if(schdata.HasErrors)
  239. {
  240. schdata.Tables[ScheduleData.SCHEDULE_TABLE].GetErrors()[0].ClearErrors();
  241. return false;
  242. }
  243. else
  244. {
  245. schdata.AcceptChanges();
  246. return true;
  247. }
  248. }
  250. private string paramChg(string str)
  251. {
  252. str = "@"+str;
  253. return str;
  254. }
  255. public DataSet dropPlacebind()
  256. {
  257. DataSet objdataset=new DataSet ();
  258. SqlDataAdapter objadapter=new SqlDataAdapter("cpDropPlaceBind",conn);
  259. objadapter.Fill(objdataset, "tablename");
  260. return objdataset;
  261. }
  263. public DataSet dropTypebind()
  264. {
  265. DataSet objdataset=new DataSet ();
  266. SqlDataAdapter objadapter=new SqlDataAdapter("cpDropTypeBind",conn);
  267. objadapter.Fill(objdataset, "tablename");
  268. return objdataset;
  269. }
  271. public DataTable cpdepempread(string Branch,string Dep,string EmpName)
  272. {
  273. SqlDataAdapter objadapter = new SqlDataAdapter();
  274. SqlCommand objcommand;
  275. DataTable objdataset = new DataTable();
  276. objadapter.SelectCommand = new SqlCommand(); 
  277. objadapter.SelectCommand.Connection = new SqlConnection(conn);
  278. objcommand = objadapter.SelectCommand;
  279. objcommand.CommandText = "cpDepEmpRead";
  280. objcommand.CommandType = CommandType.StoredProcedure;
  281. objcommand.Parameters.Add(new SqlParameter("@Branch", SqlDbType.VarChar));
  282. objcommand.Parameters["@Branch"].Value=Branch;
  283. objcommand.Parameters.Add(new SqlParameter("@Dep", SqlDbType.VarChar));
  284. objcommand.Parameters["@Dep"].Value=Dep;
  285. objcommand.Parameters.Add(new SqlParameter("@EmpName", SqlDbType.VarChar));
  286. objcommand.Parameters["@EmpName"].Value=EmpName;
  287. objadapter.Fill(objdataset);
  288. return objdataset;
  289. }
  291. public DataTable cpdepschread(DateTime fdate,int empid)
  292. {
  293. SqlDataAdapter objadapter = new SqlDataAdapter();
  294. SqlCommand objcommand;
  295. DataTable objdataset = new DataTable();
  296. objadapter.SelectCommand = new SqlCommand(); 
  297. objadapter.SelectCommand.Connection = new SqlConnection(conn);
  298. objcommand = objadapter.SelectCommand;
  299. objcommand.CommandText = "cpDepSchRead";
  300. objcommand.CommandType = CommandType.StoredProcedure;
  301. objcommand.Parameters.Add(new SqlParameter("@Fdate", SqlDbType.DateTime));
  302. objcommand.Parameters["@Fdate"].Value=fdate;
  303. objcommand.Parameters.Add(new SqlParameter("@EmpID", SqlDbType.Int));
  304. objcommand.Parameters["@EmpID"].Value=empid;
  305. objadapter.Fill(objdataset);
  306. return objdataset;
  307. }
  308. }
  309. }