周口郸城医院 DanChengCallCenter_API

T_Call_OutTask.cs 17KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428
  1. using CallCenterApi.DB;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Data.SqlClient;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Threading.Tasks;
  9. namespace CallCenterApi.DAL
  10. {
  11. /// <summary>
  12. /// 数据访问类:T_Call_OutTask
  13. /// </summary>
  14. public partial class T_Call_OutTask
  15. {
  16. public T_Call_OutTask()
  17. { }
  18. #region BasicMethod
  19. /// <summary>
  20. /// 增加一条数据
  21. /// </summary>
  22. public int Add(CallCenterApi.Model.T_Call_OutTask model)
  23. {
  24. StringBuilder strSql = new StringBuilder();
  25. strSql.Append("insert into T_Call_OutTask(");
  26. strSql.Append("F_TaskName,F_TaskRemark,F_PagerID,F_IsStart,F_StartTime,F_EndTime,F_IsAllot,F_AllotUserCode,F_AllotTime,F_CreateUserCode,F_CreateTime,F_DeleteFlag,F_IsZDWH)");
  27. strSql.Append(" values (");
  28. strSql.Append("@F_TaskName,@F_TaskRemark,@F_PagerID,@F_IsStart,@F_StartTime,@F_EndTime,@F_IsAllot,@F_AllotUserCode,@F_AllotTime,@F_CreateUserCode,@F_CreateTime,@F_DeleteFlag,@F_IsZDWH)");
  29. strSql.Append(";select @@IDENTITY");
  30. SqlParameter[] parameters = {
  31. new SqlParameter("@F_TaskName", SqlDbType.NVarChar,50),
  32. new SqlParameter("@F_TaskRemark", SqlDbType.NText),
  33. new SqlParameter("@F_PagerID", SqlDbType.Int,4),
  34. new SqlParameter("@F_IsStart", SqlDbType.Int,4),
  35. new SqlParameter("@F_StartTime", SqlDbType.DateTime),
  36. new SqlParameter("@F_EndTime", SqlDbType.DateTime),
  37. new SqlParameter("@F_IsAllot", SqlDbType.Int,4),
  38. new SqlParameter("@F_AllotUserCode", SqlDbType.NVarChar,50),
  39. new SqlParameter("@F_AllotTime", SqlDbType.DateTime),
  40. new SqlParameter("@F_CreateUserCode", SqlDbType.NVarChar,50),
  41. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  42. new SqlParameter("@F_DeleteFlag", SqlDbType.Int,4),
  43. new SqlParameter("@F_IsZDWH", SqlDbType.Int,4)
  44. };
  45. parameters[0].Value = model.F_TaskName;
  46. parameters[1].Value = model.F_TaskRemark;
  47. parameters[2].Value = model.F_PagerID;
  48. parameters[3].Value = model.F_IsStart;
  49. parameters[4].Value = model.F_StartTime;
  50. parameters[5].Value = model.F_EndTime;
  51. parameters[6].Value = model.F_IsAllot;
  52. parameters[7].Value = model.F_AllotUserCode;
  53. parameters[8].Value = model.F_AllotTime;
  54. parameters[9].Value = model.F_CreateUserCode;
  55. parameters[10].Value = model.F_CreateTime;
  56. parameters[11].Value = model.F_DeleteFlag;
  57. parameters[12].Value = model.F_IsZDWH;
  58. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  59. if (obj == null)
  60. {
  61. return 0;
  62. }
  63. else
  64. {
  65. return Convert.ToInt32(obj);
  66. }
  67. }
  68. /// <summary>
  69. /// 更新一条数据
  70. /// </summary>
  71. public bool Update(CallCenterApi.Model.T_Call_OutTask model)
  72. {
  73. StringBuilder strSql = new StringBuilder();
  74. strSql.Append("update T_Call_OutTask set ");
  75. strSql.Append("F_TaskName=@F_TaskName,");
  76. strSql.Append("F_TaskRemark=@F_TaskRemark,");
  77. strSql.Append("F_PagerID=@F_PagerID,");
  78. strSql.Append("F_IsStart=@F_IsStart,");
  79. strSql.Append("F_StartTime=@F_StartTime,");
  80. strSql.Append("F_EndTime=@F_EndTime,");
  81. strSql.Append("F_IsAllot=@F_IsAllot,");
  82. strSql.Append("F_AllotUserCode=@F_AllotUserCode,");
  83. strSql.Append("F_AllotTime=@F_AllotTime,");
  84. strSql.Append("F_CreateUserCode=@F_CreateUserCode,");
  85. strSql.Append("F_CreateTime=@F_CreateTime,");
  86. strSql.Append("F_DeleteFlag=@F_DeleteFlag,");
  87. strSql.Append("F_IsZDWH=@F_IsZDWH ");
  88. strSql.Append(" where F_TaskID=@F_TaskID");
  89. SqlParameter[] parameters = {
  90. new SqlParameter("@F_TaskName", SqlDbType.NVarChar,50),
  91. new SqlParameter("@F_TaskRemark", SqlDbType.NText),
  92. new SqlParameter("@F_PagerID", SqlDbType.Int,4),
  93. new SqlParameter("@F_IsStart", SqlDbType.Int,4),
  94. new SqlParameter("@F_StartTime", SqlDbType.DateTime),
  95. new SqlParameter("@F_EndTime", SqlDbType.DateTime),
  96. new SqlParameter("@F_IsAllot", SqlDbType.Int,4),
  97. new SqlParameter("@F_AllotUserCode", SqlDbType.NVarChar,50),
  98. new SqlParameter("@F_AllotTime", SqlDbType.DateTime),
  99. new SqlParameter("@F_CreateUserCode", SqlDbType.NVarChar,50),
  100. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  101. new SqlParameter("@F_DeleteFlag", SqlDbType.Int,4),
  102. new SqlParameter("@F_IsZDWH", SqlDbType.Int,4),
  103. new SqlParameter("@F_TaskID", SqlDbType.Int,4)};
  104. parameters[0].Value = model.F_TaskName;
  105. parameters[1].Value = model.F_TaskRemark;
  106. parameters[2].Value = model.F_PagerID;
  107. parameters[3].Value = model.F_IsStart;
  108. parameters[4].Value = model.F_StartTime;
  109. parameters[5].Value = model.F_EndTime;
  110. parameters[6].Value = model.F_IsAllot;
  111. parameters[7].Value = model.F_AllotUserCode;
  112. parameters[8].Value = model.F_AllotTime;
  113. parameters[9].Value = model.F_CreateUserCode;
  114. parameters[10].Value = model.F_CreateTime;
  115. parameters[11].Value = model.F_DeleteFlag;
  116. parameters[12].Value = model.F_IsZDWH;
  117. parameters[13].Value = model.F_TaskID;
  118. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  119. if (rows > 0)
  120. {
  121. return true;
  122. }
  123. else
  124. {
  125. return false;
  126. }
  127. }
  128. /// <summary>
  129. /// 删除一条数据
  130. /// </summary>
  131. public bool Delete(int F_TaskID)
  132. {
  133. StringBuilder strSql = new StringBuilder();
  134. //strSql.Append("delete from T_Call_OutTask ");
  135. strSql.Append("update T_Call_OutTask set F_DeleteFlag=1 ");
  136. strSql.Append(" where F_TaskID=@F_TaskID");
  137. SqlParameter[] parameters = {
  138. new SqlParameter("@F_TaskID", SqlDbType.Int,4)
  139. };
  140. parameters[0].Value = F_TaskID;
  141. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  142. if (rows > 0)
  143. {
  144. return true;
  145. }
  146. else
  147. {
  148. return false;
  149. }
  150. }
  151. /// <summary>
  152. /// 批量删除数据
  153. /// </summary>
  154. public bool DeleteList(string F_TaskIDlist)
  155. {
  156. StringBuilder strSql = new StringBuilder();
  157. //strSql.Append("delete from T_Call_OutTask ");
  158. strSql.Append("update T_Call_OutTask set F_DeleteFlag=1 ");
  159. strSql.Append(" where F_TaskID in (" + F_TaskIDlist + ") ");
  160. int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
  161. if (rows > 0)
  162. {
  163. return true;
  164. }
  165. else
  166. {
  167. return false;
  168. }
  169. }
  170. /// <summary>
  171. /// 得到一个对象实体
  172. /// </summary>
  173. public CallCenterApi.Model.T_Call_OutTask GetModel(int F_TaskID)
  174. {
  175. StringBuilder strSql = new StringBuilder();
  176. strSql.Append("select top 1 * from T_Call_OutTask ");
  177. strSql.Append(" where F_TaskID=@F_TaskID");
  178. SqlParameter[] parameters = {
  179. new SqlParameter("@F_TaskID", SqlDbType.Int,4)
  180. };
  181. parameters[0].Value = F_TaskID;
  182. CallCenterApi.Model.T_Call_OutTask model = new CallCenterApi.Model.T_Call_OutTask();
  183. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  184. if (ds.Tables[0].Rows.Count > 0)
  185. {
  186. return DataRowToModel(ds.Tables[0].Rows[0]);
  187. }
  188. else
  189. {
  190. return null;
  191. }
  192. }
  193. /// <summary>
  194. /// 得到一个对象实体
  195. /// </summary>
  196. public CallCenterApi.Model.T_Call_OutTask DataRowToModel(DataRow row)
  197. {
  198. CallCenterApi.Model.T_Call_OutTask model = new CallCenterApi.Model.T_Call_OutTask();
  199. if (row != null)
  200. {
  201. if (row["F_TaskID"] != null && row["F_TaskID"].ToString() != "")
  202. {
  203. model.F_TaskID = int.Parse(row["F_TaskID"].ToString());
  204. }
  205. if (row["F_TaskName"] != null)
  206. {
  207. model.F_TaskName = row["F_TaskName"].ToString();
  208. }
  209. if (row["F_TaskRemark"] != null)
  210. {
  211. model.F_TaskRemark = row["F_TaskRemark"].ToString();
  212. }
  213. if (row["F_PagerID"] != null && row["F_PagerID"].ToString() != "")
  214. {
  215. model.F_PagerID = int.Parse(row["F_PagerID"].ToString());
  216. }
  217. if (row["F_IsStart"] != null && row["F_IsStart"].ToString() != "")
  218. {
  219. model.F_IsStart = int.Parse(row["F_IsStart"].ToString());
  220. }
  221. if (row["F_StartTime"] != null && row["F_StartTime"].ToString() != "")
  222. {
  223. model.F_StartTime = DateTime.Parse(row["F_StartTime"].ToString());
  224. }
  225. if (row["F_EndTime"] != null && row["F_EndTime"].ToString() != "")
  226. {
  227. model.F_EndTime = DateTime.Parse(row["F_EndTime"].ToString());
  228. }
  229. if (row["F_IsAllot"] != null && row["F_IsAllot"].ToString() != "")
  230. {
  231. model.F_IsAllot = int.Parse(row["F_IsAllot"].ToString());
  232. }
  233. if (row["F_AllotUserCode"] != null)
  234. {
  235. model.F_AllotUserCode = row["F_AllotUserCode"].ToString();
  236. }
  237. if (row["F_AllotTime"] != null && row["F_AllotTime"].ToString() != "")
  238. {
  239. model.F_AllotTime = DateTime.Parse(row["F_AllotTime"].ToString());
  240. }
  241. if (row["F_CreateUserCode"] != null)
  242. {
  243. model.F_CreateUserCode = row["F_CreateUserCode"].ToString();
  244. }
  245. if (row["F_CreateTime"] != null && row["F_CreateTime"].ToString() != "")
  246. {
  247. model.F_CreateTime = DateTime.Parse(row["F_CreateTime"].ToString());
  248. }
  249. if (row["F_DeleteFlag"] != null && row["F_DeleteFlag"].ToString() != "")
  250. {
  251. model.F_DeleteFlag = int.Parse(row["F_DeleteFlag"].ToString());
  252. }
  253. if (row["F_IsZDWH"] != null && row["F_IsZDWH"].ToString() != "")
  254. {
  255. model.F_IsZDWH = int.Parse(row["F_IsZDWH"].ToString());
  256. }
  257. }
  258. return model;
  259. }
  260. /// <summary>
  261. /// 获得数据列表
  262. /// </summary>
  263. public DataSet GetList(string strWhere)
  264. {
  265. StringBuilder strSql = new StringBuilder();
  266. strSql.Append("select * ");
  267. strSql.Append(" FROM T_Call_OutTask ");
  268. if (strWhere.Trim() != "")
  269. {
  270. strSql.Append(" where " + strWhere);
  271. }
  272. return DbHelperSQL.Query(strSql.ToString());
  273. }
  274. /// <summary>
  275. /// 获得前几行数据
  276. /// </summary>
  277. public DataSet GetList(int Top, string strWhere, string filedOrder)
  278. {
  279. StringBuilder strSql = new StringBuilder();
  280. strSql.Append("select ");
  281. if (Top > 0)
  282. {
  283. strSql.Append(" top " + Top.ToString());
  284. }
  285. strSql.Append(" * ");
  286. strSql.Append(" FROM T_Call_OutTask ");
  287. if (strWhere.Trim() != "")
  288. {
  289. strSql.Append(" where " + strWhere);
  290. }
  291. strSql.Append(" order by " + filedOrder);
  292. return DbHelperSQL.Query(strSql.ToString());
  293. }
  294. /// <summary>
  295. /// 获取记录总数
  296. /// </summary>
  297. public int GetRecordCount(string strWhere)
  298. {
  299. StringBuilder strSql = new StringBuilder();
  300. strSql.Append("select count(1) FROM T_Call_OutTask ");
  301. if (strWhere.Trim() != "")
  302. {
  303. strSql.Append(" where " + strWhere);
  304. }
  305. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  306. if (obj == null)
  307. {
  308. return 0;
  309. }
  310. else
  311. {
  312. return Convert.ToInt32(obj);
  313. }
  314. }
  315. /// <summary>
  316. /// 分页获取数据列表
  317. /// </summary>
  318. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  319. {
  320. StringBuilder strSql = new StringBuilder();
  321. strSql.Append("SELECT * FROM ( ");
  322. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  323. if (!string.IsNullOrEmpty(orderby.Trim()))
  324. {
  325. strSql.Append("order by T." + orderby);
  326. }
  327. else
  328. {
  329. strSql.Append("order by T.F_TaskID desc");
  330. }
  331. strSql.Append(")AS Row, T.* from T_Call_OutTask T ");
  332. if (!string.IsNullOrEmpty(strWhere.Trim()))
  333. {
  334. strSql.Append(" WHERE " + strWhere);
  335. }
  336. strSql.Append(" ) TT");
  337. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  338. return DbHelperSQL.Query(strSql.ToString());
  339. }
  340. #endregion BasicMethod
  341. #region ExtensionMethod
  342. /// <summary>
  343. /// 更新分配状态
  344. /// </summary>
  345. public bool UpdateAllot(int taskid,int isallot,string alUCode,DateTime altime)
  346. {
  347. StringBuilder strSql = new StringBuilder();
  348. strSql.Append("update T_Call_OutTask set ");
  349. strSql.Append("F_IsAllot=@F_IsAllot,");
  350. strSql.Append("F_AllotUserCode=@F_AllotUserCode,");
  351. strSql.Append("F_AllotTime=@F_AllotTime");
  352. strSql.Append(" where F_TaskID=@F_TaskID");
  353. SqlParameter[] parameters = {
  354. new SqlParameter("@F_IsAllot", SqlDbType.Int,4),
  355. new SqlParameter("@F_AllotUserCode", SqlDbType.NVarChar,50),
  356. new SqlParameter("@F_AllotTime", SqlDbType.DateTime),
  357. new SqlParameter("@F_TaskID", SqlDbType.Int,4)};
  358. parameters[0].Value = isallot;
  359. parameters[1].Value = alUCode;
  360. parameters[2].Value = altime;
  361. parameters[3].Value = taskid;
  362. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  363. if (rows > 0)
  364. {
  365. return true;
  366. }
  367. else
  368. {
  369. return false;
  370. }
  371. }
  372. /// <summary>
  373. /// 更新启动状态
  374. /// </summary>
  375. public bool UpdateStart(int taskid,int isstart,DateTime stime,DateTime etime)
  376. {
  377. StringBuilder strSql = new StringBuilder();
  378. strSql.Append("update T_Call_OutTask set ");
  379. strSql.Append("F_IsStart=@F_IsStart,");
  380. strSql.Append("F_StartTime=@F_StartTime,");
  381. strSql.Append("F_EndTime=@F_EndTime");
  382. strSql.Append(" where F_TaskID=@F_TaskID");
  383. SqlParameter[] parameters = {
  384. new SqlParameter("@F_IsStart", SqlDbType.Int,4),
  385. new SqlParameter("@F_StartTime", SqlDbType.DateTime),
  386. new SqlParameter("@F_EndTime", SqlDbType.DateTime),
  387. new SqlParameter("@F_TaskID", SqlDbType.Int,4)};
  388. parameters[0].Value = isstart;
  389. parameters[1].Value = stime;
  390. parameters[2].Value = etime;
  391. parameters[3].Value = taskid;
  392. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  393. if (rows > 0)
  394. {
  395. return true;
  396. }
  397. else
  398. {
  399. return false;
  400. }
  401. }
  402. #endregion ExtensionMethod
  403. }
  404. }