Нет описания

T_Call_OutTask.cs 16KB

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