Нет описания

T_CTI_Task.cs 27KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Data.SqlClient;
  6. using System.Data;
  7. using CallCenterApi.DB;
  8. namespace CallCenterApi.DAL
  9. {
  10. /// <summary>
  11. /// 数据访问类:T_CTI_Task
  12. /// </summary>
  13. public partial class T_CTI_Task
  14. {
  15. public T_CTI_Task()
  16. { }
  17. #region Method
  18. /// <summary>
  19. /// 是否存在该记录
  20. /// </summary>
  21. public bool Exists(long TaskID)
  22. {
  23. StringBuilder strSql = new StringBuilder();
  24. strSql.Append("select count(1) from T_CTI_Task");
  25. strSql.Append(" where TaskID=@TaskID");
  26. SqlParameter[] parameters = {
  27. new SqlParameter("@TaskID", SqlDbType.BigInt)
  28. };
  29. parameters[0].Value = TaskID;
  30. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  31. }
  32. /// <summary>
  33. /// 增加一条数据
  34. /// </summary>
  35. public long Add(Model.T_CTI_Task model)
  36. {
  37. StringBuilder strSql = new StringBuilder();
  38. strSql.Append("insert into T_CTI_Task(");
  39. strSql.Append("TaskName,TrunkGroupID,CallerNum,CallType,ExInfo,MaxTrunkCount,IntensityCoefficient,ItemTableName,State,AddTime,y_PSort,y_TkModelId,y_SXH,y_FPCount,y_YJCount,y_HCCount,y_HSCount,y_HTCount,y_HMCount,y_OkCount,y_RFCount,y_ConsCount,y_InvlCount,y_NoAnswerCount,y_ShutDownCount,TaskType,Pre,Concurrency,ConcurrencyType)");
  40. strSql.Append(" values (");
  41. strSql.Append("@TaskName,@TrunkGroupID,@CallerNum,@CallType,@ExInfo,@MaxTrunkCount,@IntensityCoefficient,@ItemTableName,@State,@AddTime,@y_PSort,@y_TkModelId,@y_SXH,@y_FPCount,@y_YJCount,@y_HCCount,@y_HSCount,@y_HTCount,@y_HMCount,@y_OkCount,@y_RFCount,@y_ConsCount,@y_InvlCount,@y_NoAnswerCount,@y_ShutDownCount,@TaskType,@Pre,@Concurrency,@ConcurrencyType)");
  42. strSql.Append(";select @@IDENTITY");
  43. SqlParameter[] parameters = {
  44. new SqlParameter("@TaskName", SqlDbType.VarChar,200),
  45. new SqlParameter("@TrunkGroupID", SqlDbType.Int,4),
  46. new SqlParameter("@CallerNum", SqlDbType.VarChar,11),
  47. new SqlParameter("@CallType", SqlDbType.Int,4),
  48. new SqlParameter("@ExInfo", SqlDbType.VarChar,200),
  49. new SqlParameter("@MaxTrunkCount", SqlDbType.Int,4),
  50. new SqlParameter("@IntensityCoefficient", SqlDbType.Float,8),
  51. new SqlParameter("@ItemTableName", SqlDbType.VarChar,100),
  52. new SqlParameter("@State", SqlDbType.Int,4),
  53. new SqlParameter("@AddTime", SqlDbType.DateTime),
  54. new SqlParameter("@y_PSort", SqlDbType.Int,4),
  55. new SqlParameter("@y_TkModelId", SqlDbType.BigInt,8),
  56. new SqlParameter("@y_SXH", SqlDbType.Int,4),
  57. new SqlParameter("@y_FPCount", SqlDbType.Int,4),
  58. new SqlParameter("@y_YJCount", SqlDbType.Int,4),
  59. new SqlParameter("@y_HCCount", SqlDbType.Int,4),
  60. new SqlParameter("@y_HSCount", SqlDbType.Int,4),
  61. new SqlParameter("@y_HTCount", SqlDbType.Int,4),
  62. new SqlParameter("@y_HMCount", SqlDbType.Int,4),
  63. new SqlParameter("@y_OkCount", SqlDbType.Int,4),
  64. new SqlParameter("@y_RFCount", SqlDbType.Int,4),
  65. new SqlParameter("@y_ConsCount", SqlDbType.Int,4),
  66. new SqlParameter("@y_InvlCount", SqlDbType.Int,4),
  67. new SqlParameter("@y_NoAnswerCount", SqlDbType.Int,4),
  68. new SqlParameter("@y_ShutDownCount", SqlDbType.Int,4),
  69. new SqlParameter("@TaskType", SqlDbType.Int,4),
  70. new SqlParameter("@Pre", SqlDbType.VarChar,300),
  71. new SqlParameter("@Concurrency", SqlDbType.Int),
  72. new SqlParameter("@ConcurrencyType", SqlDbType.Int)
  73. };
  74. parameters[0].Value = model.TaskName;
  75. parameters[1].Value = model.TrunkGroupID;
  76. parameters[2].Value = model.CallerNum;
  77. parameters[3].Value = model.CallType;
  78. parameters[4].Value = model.ExInfo;
  79. parameters[5].Value = model.MaxTrunkCount;
  80. parameters[6].Value = model.IntensityCoefficient;
  81. parameters[7].Value = model.ItemTableName;
  82. parameters[8].Value = model.State;
  83. parameters[9].Value = model.AddTime;
  84. parameters[10].Value = model.y_PSort;
  85. parameters[11].Value = model.y_TkModelId;
  86. parameters[12].Value = model.y_SXH;
  87. parameters[13].Value = model.y_FPCount;
  88. parameters[14].Value = model.y_YJCount;
  89. parameters[15].Value = model.y_HCCount;
  90. parameters[16].Value = model.y_HSCount;
  91. parameters[17].Value = model.y_HTCount;
  92. parameters[18].Value = model.y_HMCount;
  93. parameters[19].Value = model.y_OkCount;
  94. parameters[20].Value = model.y_RFCount;
  95. parameters[21].Value = model.y_ConsCount;
  96. parameters[22].Value = model.y_InvlCount;
  97. parameters[23].Value = model.y_NoAnswerCount;
  98. parameters[24].Value = model.y_ShutDownCount;
  99. parameters[25].Value = model.TaskType;
  100. parameters[26].Value = model.Pre;
  101. parameters[27].Value = model.Concurrency;
  102. parameters[28].Value = model.ConcurrencyType;
  103. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  104. if (obj == null)
  105. {
  106. return 0;
  107. }
  108. else
  109. {
  110. return Convert.ToInt64(obj);
  111. }
  112. }
  113. /// <summary>
  114. /// 更新一条数据
  115. /// </summary>
  116. public bool Update(CallCenterApi.Model.T_CTI_Task model)
  117. {
  118. StringBuilder strSql = new StringBuilder();
  119. strSql.Append("update T_CTI_Task set ");
  120. strSql.Append("TaskName=@TaskName,");
  121. strSql.Append("TrunkGroupID=@TrunkGroupID,");
  122. strSql.Append("CallerNum=@CallerNum,");
  123. strSql.Append("CallType=@CallType,");
  124. strSql.Append("ExInfo=@ExInfo,");
  125. strSql.Append("MaxTrunkCount=@MaxTrunkCount,");
  126. strSql.Append("IntensityCoefficient=@IntensityCoefficient,");
  127. strSql.Append("ItemTableName=@ItemTableName,");
  128. strSql.Append("AddTime=@AddTime,");
  129. strSql.Append("State=@State,");
  130. strSql.Append("y_PSort=@y_PSort,");
  131. strSql.Append("y_TkModelId=@y_TkModelId,");
  132. strSql.Append("y_SXH=@y_SXH,");
  133. strSql.Append("y_FPCount=@y_FPCount,");
  134. strSql.Append("y_YJCount=@y_YJCount,");
  135. strSql.Append("y_HCCount=@y_HCCount,");
  136. strSql.Append("y_HSCount=@y_HSCount,");
  137. strSql.Append("y_HTCount=@y_HTCount,");
  138. strSql.Append("y_HMCount=@y_HMCount,");
  139. strSql.Append("y_OkCount=@y_OkCount,");
  140. strSql.Append("y_RFCount=@y_RFCount,");
  141. strSql.Append("y_ConsCount=@y_ConsCount,");
  142. strSql.Append("y_InvlCount=@y_InvlCount,");
  143. strSql.Append("y_NoAnswerCount=@y_NoAnswerCount,");
  144. strSql.Append("y_ShutDownCount=@y_ShutDownCount,");
  145. strSql.Append("TaskType=@TaskType, ");
  146. strSql.Append("Pre=@Pre, ");
  147. strSql.Append("Concurrency=@Concurrency, ");
  148. strSql.Append("ConcurrencyType=@ConcurrencyType ");
  149. strSql.Append(" where TaskID=@TaskID");
  150. SqlParameter[] parameters = {
  151. new SqlParameter("@TaskName", SqlDbType.VarChar,200),
  152. new SqlParameter("@TrunkGroupID", SqlDbType.Int,4),
  153. new SqlParameter("@CallerNum", SqlDbType.VarChar,11),
  154. new SqlParameter("@CallType", SqlDbType.Int,4),
  155. new SqlParameter("@ExInfo", SqlDbType.VarChar,200),
  156. new SqlParameter("@MaxTrunkCount", SqlDbType.Int,4),
  157. new SqlParameter("@IntensityCoefficient", SqlDbType.Float,8),
  158. new SqlParameter("@ItemTableName", SqlDbType.VarChar,100),
  159. new SqlParameter("@State", SqlDbType.Int,4),
  160. new SqlParameter("@AddTime", SqlDbType.DateTime),
  161. new SqlParameter("@y_PSort", SqlDbType.Int,4),
  162. new SqlParameter("@y_TkModelId", SqlDbType.BigInt,8),
  163. new SqlParameter("@y_SXH", SqlDbType.Int,4),
  164. new SqlParameter("@y_FPCount", SqlDbType.Int,4),
  165. new SqlParameter("@y_YJCount", SqlDbType.Int,4),
  166. new SqlParameter("@y_HCCount", SqlDbType.Int,4),
  167. new SqlParameter("@y_HSCount", SqlDbType.Int,4),
  168. new SqlParameter("@y_HTCount", SqlDbType.Int,4),
  169. new SqlParameter("@y_HMCount", SqlDbType.Int,4),
  170. new SqlParameter("@y_OkCount", SqlDbType.Int,4),
  171. new SqlParameter("@y_RFCount", SqlDbType.Int,4),
  172. new SqlParameter("@y_ConsCount", SqlDbType.Int,4),
  173. new SqlParameter("@y_InvlCount", SqlDbType.Int,4),
  174. new SqlParameter("@y_NoAnswerCount", SqlDbType.Int,4),
  175. new SqlParameter("@y_ShutDownCount", SqlDbType.Int,4),
  176. new SqlParameter("@TaskType", SqlDbType.Int,4),
  177. new SqlParameter("@TaskID",SqlDbType.BigInt),
  178. new SqlParameter("@Pre",SqlDbType.VarChar,300),
  179. new SqlParameter("@Concurrency", SqlDbType.Int),
  180. new SqlParameter("@ConcurrencyType", SqlDbType.Int)
  181. };
  182. parameters[0].Value = model.TaskName;
  183. parameters[1].Value = model.TrunkGroupID;
  184. parameters[2].Value = model.CallerNum;
  185. parameters[3].Value = model.CallType;
  186. parameters[4].Value = model.ExInfo;
  187. parameters[5].Value = model.MaxTrunkCount;
  188. parameters[6].Value = model.IntensityCoefficient;
  189. parameters[7].Value = model.ItemTableName;
  190. parameters[8].Value = model.State;
  191. parameters[9].Value = model.AddTime;
  192. parameters[10].Value = model.y_PSort;
  193. parameters[11].Value = model.y_TkModelId;
  194. parameters[12].Value = model.y_SXH;
  195. parameters[13].Value = model.y_FPCount;
  196. parameters[14].Value = model.y_YJCount;
  197. parameters[15].Value = model.y_HCCount;
  198. parameters[16].Value = model.y_HSCount;
  199. parameters[17].Value = model.y_HTCount;
  200. parameters[18].Value = model.y_HMCount;
  201. parameters[19].Value = model.y_OkCount;
  202. parameters[20].Value = model.y_RFCount;
  203. parameters[21].Value = model.y_ConsCount;
  204. parameters[22].Value = model.y_InvlCount;
  205. parameters[23].Value = model.y_NoAnswerCount;
  206. parameters[24].Value = model.y_ShutDownCount;
  207. parameters[25].Value = model.TaskType;
  208. parameters[26].Value = model.TaskID;
  209. parameters[27].Value = model.Pre;
  210. parameters[28].Value = model.Concurrency;
  211. parameters[29].Value = model.ConcurrencyType;
  212. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  213. if (rows > 0)
  214. {
  215. return true;
  216. }
  217. else
  218. {
  219. return false;
  220. }
  221. }
  222. /// <summary>
  223. /// 更新一条数据
  224. /// </summary>
  225. public bool UpdateState(int id, int state)
  226. {
  227. StringBuilder strSql = new StringBuilder();
  228. strSql.Append("update T_CTI_Task set ");
  229. strSql.Append("State=@State");
  230. strSql.Append(" where TaskID=@TaskID");
  231. SqlParameter[] parameters = {
  232. new SqlParameter("@State", SqlDbType.Int,4),
  233. new SqlParameter("@TaskID", SqlDbType.BigInt,8)};
  234. parameters[0].Value = state;
  235. parameters[1].Value = id;
  236. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  237. if (rows > 0)
  238. {
  239. return true;
  240. }
  241. else
  242. {
  243. return false;
  244. }
  245. }
  246. /// <summary>
  247. /// 更新多条数据
  248. /// </summary>
  249. public bool UpdateStateBatch(string where, int state)
  250. {
  251. StringBuilder strSql = new StringBuilder();
  252. strSql.Append("update T_CTI_Task set ");
  253. strSql.Append("State=@State");
  254. if (!string.IsNullOrWhiteSpace(where))
  255. {
  256. strSql.Append(" where ");
  257. strSql.Append(where);
  258. }
  259. SqlParameter[] parameters = {
  260. new SqlParameter("@State", SqlDbType.Int,4) };
  261. parameters[0].Value = state;
  262. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  263. if (rows > 0)
  264. {
  265. return true;
  266. }
  267. else
  268. {
  269. return false;
  270. }
  271. }
  272. /// <summary>
  273. /// 删除一条数据
  274. /// </summary>
  275. public bool Delete(long TaskID)
  276. {
  277. StringBuilder strSql = new StringBuilder();
  278. strSql.Append("delete from T_CTI_Task ");
  279. strSql.Append(" where TaskID=@TaskID");
  280. SqlParameter[] parameters = {
  281. new SqlParameter("@TaskID", SqlDbType.BigInt)
  282. };
  283. parameters[0].Value = TaskID;
  284. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  285. if (rows > 0)
  286. {
  287. return true;
  288. }
  289. else
  290. {
  291. return false;
  292. }
  293. }
  294. /// <summary>
  295. /// 批量删除数据
  296. /// </summary>
  297. public bool DeleteList(string TaskIDlist)
  298. {
  299. StringBuilder strSql = new StringBuilder();
  300. strSql.Append("delete from T_CTI_Task ");
  301. strSql.Append(" where TaskID in (" + TaskIDlist + ") ");
  302. int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
  303. if (rows > 0)
  304. {
  305. return true;
  306. }
  307. else
  308. {
  309. return false;
  310. }
  311. }
  312. /// <summary>
  313. /// 得到一个对象实体
  314. /// </summary>
  315. public CallCenterApi.Model.T_CTI_Task GetModel(long TaskID)
  316. {
  317. StringBuilder strSql = new StringBuilder();
  318. strSql.Append("select top 1 TaskID,TaskName,TrunkGroupID,CallerNum,CallType,ExInfo,MaxTrunkCount,IntensityCoefficient,ItemTableName,State,AddTime,y_PSort,y_TkModelId,y_SXH,y_FPCount,y_YJCount,y_HCCount,y_HSCount,y_HTCount,y_HMCount,y_OkCount,y_RFCount,y_ConsCount,y_InvlCount,y_NoAnswerCount,y_ShutDownCount,TaskType,Pre,Concurrency,ConcurrencyType from T_CTI_Task ");
  319. strSql.Append(" where State>=0 and TaskID=@TaskID ");
  320. SqlParameter[] parameters = {
  321. new SqlParameter("@TaskID", SqlDbType.BigInt)
  322. };
  323. parameters[0].Value = TaskID;
  324. CallCenterApi.Model.T_CTI_Task model = new CallCenterApi.Model.T_CTI_Task();
  325. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  326. if (ds.Tables[0].Rows.Count > 0)
  327. {
  328. if (ds.Tables[0].Rows[0]["TaskID"] != null && ds.Tables[0].Rows[0]["TaskID"].ToString() != "")
  329. {
  330. model.TaskID = long.Parse(ds.Tables[0].Rows[0]["TaskID"].ToString());
  331. }
  332. if (ds.Tables[0].Rows[0]["TaskName"] != null && ds.Tables[0].Rows[0]["TaskName"].ToString() != "")
  333. {
  334. model.TaskName = ds.Tables[0].Rows[0]["TaskName"].ToString();
  335. }
  336. if (ds.Tables[0].Rows[0]["TrunkGroupID"] != null && ds.Tables[0].Rows[0]["TrunkGroupID"].ToString() != "")
  337. {
  338. model.TrunkGroupID = int.Parse(ds.Tables[0].Rows[0]["TrunkGroupID"].ToString());
  339. }
  340. if (ds.Tables[0].Rows[0]["CallerNum"] != null && ds.Tables[0].Rows[0]["CallerNum"].ToString() != "")
  341. {
  342. model.CallerNum = ds.Tables[0].Rows[0]["CallerNum"].ToString();
  343. }
  344. if (ds.Tables[0].Rows[0]["CallType"] != null && ds.Tables[0].Rows[0]["CallType"].ToString() != "")
  345. {
  346. model.CallType = int.Parse(ds.Tables[0].Rows[0]["CallType"].ToString());
  347. }
  348. if (ds.Tables[0].Rows[0]["ExInfo"] != null && ds.Tables[0].Rows[0]["ExInfo"].ToString() != "")
  349. {
  350. model.ExInfo = ds.Tables[0].Rows[0]["ExInfo"].ToString();
  351. }
  352. if (ds.Tables[0].Rows[0]["MaxTrunkCount"] != null && ds.Tables[0].Rows[0]["MaxTrunkCount"].ToString() != "")
  353. {
  354. model.MaxTrunkCount = int.Parse(ds.Tables[0].Rows[0]["MaxTrunkCount"].ToString());
  355. }
  356. if (ds.Tables[0].Rows[0]["IntensityCoefficient"] != null && ds.Tables[0].Rows[0]["IntensityCoefficient"].ToString() != "")
  357. {
  358. model.IntensityCoefficient = decimal.Parse(ds.Tables[0].Rows[0]["IntensityCoefficient"].ToString());
  359. }
  360. if (ds.Tables[0].Rows[0]["ItemTableName"] != null && ds.Tables[0].Rows[0]["ItemTableName"].ToString() != "")
  361. {
  362. model.ItemTableName = ds.Tables[0].Rows[0]["ItemTableName"].ToString();
  363. }
  364. if (ds.Tables[0].Rows[0]["State"] != null && ds.Tables[0].Rows[0]["State"].ToString() != "")
  365. {
  366. model.State = int.Parse(ds.Tables[0].Rows[0]["State"].ToString());
  367. }
  368. if (ds.Tables[0].Rows[0]["AddTime"] != null && ds.Tables[0].Rows[0]["AddTime"].ToString() != "")
  369. {
  370. model.AddTime = DateTime.Parse(ds.Tables[0].Rows[0]["AddTime"].ToString());
  371. }
  372. if (ds.Tables[0].Rows[0]["y_PSort"] != null && ds.Tables[0].Rows[0]["y_PSort"].ToString() != "")
  373. {
  374. model.y_PSort = int.Parse(ds.Tables[0].Rows[0]["y_PSort"].ToString());
  375. }
  376. if (ds.Tables[0].Rows[0]["y_TkModelId"] != null && ds.Tables[0].Rows[0]["y_TkModelId"].ToString() != "")
  377. {
  378. model.y_TkModelId = long.Parse(ds.Tables[0].Rows[0]["y_TkModelId"].ToString());
  379. }
  380. if (ds.Tables[0].Rows[0]["y_SXH"] != null && ds.Tables[0].Rows[0]["y_SXH"].ToString() != "")
  381. {
  382. model.y_SXH = int.Parse(ds.Tables[0].Rows[0]["y_SXH"].ToString());
  383. }
  384. if (ds.Tables[0].Rows[0]["y_FPCount"] != null && ds.Tables[0].Rows[0]["y_FPCount"].ToString() != "")
  385. {
  386. model.y_FPCount = int.Parse(ds.Tables[0].Rows[0]["y_FPCount"].ToString());
  387. }
  388. if (ds.Tables[0].Rows[0]["y_YJCount"] != null && ds.Tables[0].Rows[0]["y_YJCount"].ToString() != "")
  389. {
  390. model.y_YJCount = int.Parse(ds.Tables[0].Rows[0]["y_YJCount"].ToString());
  391. }
  392. if (ds.Tables[0].Rows[0]["y_HCCount"] != null && ds.Tables[0].Rows[0]["y_HCCount"].ToString() != "")
  393. {
  394. model.y_HCCount = int.Parse(ds.Tables[0].Rows[0]["y_HCCount"].ToString());
  395. }
  396. if (ds.Tables[0].Rows[0]["y_HSCount"] != null && ds.Tables[0].Rows[0]["y_HSCount"].ToString() != "")
  397. {
  398. model.y_HSCount = int.Parse(ds.Tables[0].Rows[0]["y_HSCount"].ToString());
  399. }
  400. if (ds.Tables[0].Rows[0]["y_HTCount"] != null && ds.Tables[0].Rows[0]["y_HTCount"].ToString() != "")
  401. {
  402. model.y_HTCount = int.Parse(ds.Tables[0].Rows[0]["y_HTCount"].ToString());
  403. }
  404. if (ds.Tables[0].Rows[0]["y_HMCount"] != null && ds.Tables[0].Rows[0]["y_HMCount"].ToString() != "")
  405. {
  406. model.y_HMCount = int.Parse(ds.Tables[0].Rows[0]["y_HMCount"].ToString());
  407. }
  408. if (ds.Tables[0].Rows[0]["y_OkCount"] != null && ds.Tables[0].Rows[0]["y_OkCount"].ToString() != "")
  409. {
  410. model.y_OkCount = int.Parse(ds.Tables[0].Rows[0]["y_OkCount"].ToString());
  411. }
  412. if (ds.Tables[0].Rows[0]["y_RFCount"] != null && ds.Tables[0].Rows[0]["y_RFCount"].ToString() != "")
  413. {
  414. model.y_RFCount = int.Parse(ds.Tables[0].Rows[0]["y_RFCount"].ToString());
  415. }
  416. if (ds.Tables[0].Rows[0]["y_ConsCount"] != null && ds.Tables[0].Rows[0]["y_ConsCount"].ToString() != "")
  417. {
  418. model.y_ConsCount = int.Parse(ds.Tables[0].Rows[0]["y_ConsCount"].ToString());
  419. }
  420. if (ds.Tables[0].Rows[0]["y_InvlCount"] != null && ds.Tables[0].Rows[0]["y_InvlCount"].ToString() != "")
  421. {
  422. model.y_InvlCount = int.Parse(ds.Tables[0].Rows[0]["y_InvlCount"].ToString());
  423. }
  424. if (ds.Tables[0].Rows[0]["y_NoAnswerCount"] != null && ds.Tables[0].Rows[0]["y_NoAnswerCount"].ToString() != "")
  425. {
  426. model.y_NoAnswerCount = int.Parse(ds.Tables[0].Rows[0]["y_NoAnswerCount"].ToString());
  427. }
  428. if (ds.Tables[0].Rows[0]["y_ShutDownCount"] != null && ds.Tables[0].Rows[0]["y_ShutDownCount"].ToString() != "")
  429. {
  430. model.y_ShutDownCount = int.Parse(ds.Tables[0].Rows[0]["y_ShutDownCount"].ToString());
  431. }
  432. if (ds.Tables[0].Rows[0]["TaskType"] != null && ds.Tables[0].Rows[0]["TaskType"].ToString() != "")
  433. {
  434. model.TaskType = int.Parse(ds.Tables[0].Rows[0]["TaskType"].ToString());
  435. }
  436. if (ds.Tables[0].Rows[0]["Pre"] != null && ds.Tables[0].Rows[0]["Pre"].ToString() != "")
  437. {
  438. model.Pre = ds.Tables[0].Rows[0]["Pre"].ToString();
  439. }
  440. if (ds.Tables[0].Rows[0]["Concurrency"] != null && ds.Tables[0].Rows[0]["Concurrency"].ToString() != "")
  441. {
  442. model.Concurrency = float.Parse(ds.Tables[0].Rows[0]["Concurrency"].ToString());
  443. }
  444. if (ds.Tables[0].Rows[0]["ConcurrencyType"] != null && ds.Tables[0].Rows[0]["ConcurrencyType"].ToString() != "")
  445. {
  446. model.ConcurrencyType = int.Parse(ds.Tables[0].Rows[0]["ConcurrencyType"].ToString());
  447. }
  448. return model;
  449. }
  450. else
  451. {
  452. return null;
  453. }
  454. }
  455. public DataSet GetTask(int groupId)
  456. {
  457. StringBuilder strSql = new StringBuilder();
  458. strSql.Append("select * FROM ");
  459. strSql.Append(" FROM vw_CTI_TaskPager ");
  460. return DbHelperSQL.Query(strSql.ToString());
  461. }
  462. /// <summary>
  463. /// 获得数据列表
  464. /// </summary>
  465. public DataSet GetList(string strWhere)
  466. {
  467. StringBuilder strSql = new StringBuilder();
  468. strSql.Append("select * ");
  469. strSql.Append(" FROM vw_CTI_TaskPager ");
  470. if (strWhere.Trim() != "")
  471. {
  472. strSql.Append(" where " + strWhere);
  473. }
  474. return DbHelperSQL.Query(strSql.ToString());
  475. }
  476. /// <summary>
  477. /// 获得前几行数据
  478. /// </summary>
  479. public DataSet GetList(int Top, string strWhere, string filedOrder)
  480. {
  481. StringBuilder strSql = new StringBuilder();
  482. strSql.Append("select ");
  483. if (Top > 0)
  484. {
  485. strSql.Append(" top " + Top.ToString());
  486. }
  487. strSql.Append(" TaskID,TaskName,TrunkGroupID,CallerNum,CallType,ExInfo,MaxTrunkCount,IntensityCoefficient,ItemTableName,State,AddTime,y_PSort,y_TkModelId,y_SXH,y_FPCount,y_YJCount,y_HCCount,y_HSCount,y_HTCount,y_HMCount,y_OkCount,y_RFCount,y_ConsCount,y_InvlCount,y_NoAnswerCount,y_ShutDownCount,TaskType,Pre,Speed ");
  488. strSql.Append(" FROM T_CTI_Task ");
  489. if (strWhere.Trim() != "")
  490. {
  491. strSql.Append(" where " + strWhere);
  492. }
  493. strSql.Append(" order by " + filedOrder);
  494. return DbHelperSQL.Query(strSql.ToString());
  495. }
  496. /// <summary>
  497. /// 获取记录总数
  498. /// </summary>
  499. public int GetRecordCount(string strWhere)
  500. {
  501. StringBuilder strSql = new StringBuilder();
  502. strSql.Append("select count(1) FROM T_CTI_Task ");
  503. if (strWhere.Trim() != "")
  504. {
  505. strSql.Append(" where " + strWhere);
  506. }
  507. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  508. if (obj == null)
  509. {
  510. return 0;
  511. }
  512. else
  513. {
  514. return Convert.ToInt32(obj);
  515. }
  516. }
  517. /// <summary>
  518. /// 分页获取数据列表
  519. /// </summary>
  520. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  521. {
  522. StringBuilder strSql = new StringBuilder();
  523. strSql.Append("SELECT * FROM ( ");
  524. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  525. if (!string.IsNullOrEmpty(orderby.Trim()))
  526. {
  527. strSql.Append("order by T." + orderby);
  528. }
  529. else
  530. {
  531. strSql.Append("order by T.TaskID desc");
  532. }
  533. strSql.Append(")AS Row, T.* from T_CTI_Task T ");
  534. if (!string.IsNullOrEmpty(strWhere.Trim()))
  535. {
  536. strSql.Append(" WHERE " + strWhere);
  537. }
  538. strSql.Append(" ) TT");
  539. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  540. return DbHelperSQL.Query(strSql.ToString());
  541. }
  542. /*
  543. /// <summary>
  544. /// 分页获取数据列表
  545. /// </summary>
  546. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  547. {
  548. SqlParameter[] parameters = {
  549. new SqlParameter("@tblName", SqlDbType.VarChar, 255),
  550. new SqlParameter("@fldName", SqlDbType.VarChar, 255),
  551. new SqlParameter("@PageSize", SqlDbType.Int),
  552. new SqlParameter("@PageIndex", SqlDbType.Int),
  553. new SqlParameter("@IsReCount", SqlDbType.Bit),
  554. new SqlParameter("@OrderType", SqlDbType.Bit),
  555. new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
  556. };
  557. parameters[0].Value = "T_CTI_Task";
  558. parameters[1].Value = "TaskID";
  559. parameters[2].Value = PageSize;
  560. parameters[3].Value = PageIndex;
  561. parameters[4].Value = 0;
  562. parameters[5].Value = 0;
  563. parameters[6].Value = strWhere;
  564. return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  565. }*/
  566. #endregion Method
  567. }
  568. }