TCDLTManage.cs 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data;
  4. using System.Data.Common;
  5. using System.Data.SqlClient;
  6. using System.Text;
  7. using CB.Common;
  8. using CB.Data;
  9. using CB.Entity;
  10. using CB.Interface.Infrastructure;
  11. namespace CB.Data.SqlServer
  12. {
  13. public class TCDLTManage : Repository<TCDLTInfo>, ITCDLTService
  14. {
  15. public TCDLTManage(string interfaceId)
  16. : base(interfaceId)
  17. {
  18. }
  19. public override bool Save(TCDLTInfo entity)
  20. {
  21. DbParameter[] pars ={
  22. DbHelper.MakeInParam(InterfaceId,"@Term",(DbType)SqlDbType.Int,4,entity.Term),
  23. DbHelper.MakeInParam(InterfaceId,"@OpenCode1",(DbType)SqlDbType.Int,4,entity.OpenCode1),
  24. DbHelper.MakeInParam(InterfaceId,"@OpenCode2",(DbType)SqlDbType.Int,4,entity.OpenCode2),
  25. DbHelper.MakeInParam(InterfaceId,"@OpenCode3",(DbType)SqlDbType.Int,4,entity.OpenCode3),
  26. DbHelper.MakeInParam(InterfaceId,"@OpenCode4",(DbType)SqlDbType.Int,4,entity.OpenCode4),
  27. DbHelper.MakeInParam(InterfaceId,"@OpenCode5",(DbType)SqlDbType.Int,4,entity.OpenCode5),
  28. DbHelper.MakeInParam(InterfaceId,"@OpenCode6",(DbType)SqlDbType.Int,4,entity.OpenCode6),
  29. DbHelper.MakeInParam(InterfaceId,"@OpenCode7",(DbType)SqlDbType.Int,4,entity.OpenCode7),
  30. DbHelper.MakeInParam(InterfaceId,"@OpenTime",(DbType)SqlDbType.DateTime,0,entity.OpenTime),
  31. DbHelper.MakeInParam(InterfaceId,"@ShiJiHao",(DbType)SqlDbType.NVarChar,0,entity.ShiJiHao),
  32. DbHelper.MakeInParam(InterfaceId,"@KaiJiHao",(DbType)SqlDbType.NVarChar,0,entity.KaiJiHao),
  33. DbHelper.MakeInParam(InterfaceId,"@Detail",(DbType)SqlDbType.NVarChar,500,entity.Detail)
  34. };
  35. return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId,CommandType.StoredProcedure, "usp_TCDLT_save", pars)) > 0;
  36. }
  37. public override bool Update(TCDLTInfo entity)
  38. {
  39. DbParameter[] pars ={
  40. DbHelper.MakeInParam(InterfaceId,"@Term",(DbType)SqlDbType.Int,4,entity.Term),
  41. DbHelper.MakeInParam(InterfaceId,"@OpenCode1",(DbType)SqlDbType.Int,4,entity.OpenCode1),
  42. DbHelper.MakeInParam(InterfaceId,"@OpenCode2",(DbType)SqlDbType.Int,4,entity.OpenCode2),
  43. DbHelper.MakeInParam(InterfaceId,"@OpenCode3",(DbType)SqlDbType.Int,4,entity.OpenCode3),
  44. DbHelper.MakeInParam(InterfaceId,"@OpenCode4",(DbType)SqlDbType.Int,4,entity.OpenCode4),
  45. DbHelper.MakeInParam(InterfaceId,"@OpenCode5",(DbType)SqlDbType.Int,4,entity.OpenCode5),
  46. DbHelper.MakeInParam(InterfaceId,"@OpenCode6",(DbType)SqlDbType.Int,4,entity.OpenCode6),
  47. DbHelper.MakeInParam(InterfaceId,"@OpenCode7",(DbType)SqlDbType.Int,4,entity.OpenCode7),
  48. DbHelper.MakeInParam(InterfaceId,"@OpenTime",(DbType)SqlDbType.DateTime,0,entity.OpenTime),
  49. DbHelper.MakeInParam(InterfaceId,"@ShiJiHao",(DbType)SqlDbType.NVarChar,0,entity.ShiJiHao),
  50. DbHelper.MakeInParam(InterfaceId,"@KaiJiHao",(DbType)SqlDbType.NVarChar,0,entity.KaiJiHao),
  51. DbHelper.MakeInParam(InterfaceId,"@Detail",(DbType)SqlDbType.NVarChar,500,entity.Detail)
  52. };
  53. return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId, CommandType.StoredProcedure, "usp_TCDLT_save", pars)) > 0;
  54. }
  55. public override bool Delete(int id)
  56. {
  57. DbParameter[] pars ={
  58. DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,id)
  59. };
  60. return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId,CommandType.StoredProcedure, "usp_TCDLT_Delete", pars)) > 0;
  61. }
  62. public override TCDLTInfo Get<TKey>(TKey key)
  63. {
  64. TCDLTInfo Entity = null;
  65. DbParameter[] para =
  66. {
  67. DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,key)
  68. };
  69. using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.Text,
  70. @"SELECT TOP 1 [Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],
  71. [OpenCode6],[OpenCode7],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime] FROM [DT_TCDLT] WHERE [Id]= @Id",
  72. para))
  73. {
  74. if (reader.Read())
  75. {
  76. Entity = LoadEntity(reader);
  77. }
  78. reader.Dispose();
  79. }
  80. return Entity;
  81. }
  82. public override IList<TCDLTInfo> ToList()
  83. {
  84. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  85. using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, @"SELECT [Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],
  86. [OpenCode6],[OpenCode7],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime] FROM [DT_TCDLT] ORDER BY [Term] ASC"))
  87. {
  88. if (null != dt && 0 < dt.Rows.Count)
  89. {
  90. foreach (DataRow dr in dt.Rows)
  91. {
  92. list.Add(LoadEntity(dr));
  93. }
  94. }
  95. dt.Dispose();
  96. }
  97. return list;
  98. }
  99. public override IList<TCDLTInfo> ToList(TCDLTInfo entity)
  100. {
  101. throw new NotImplementedException();
  102. }
  103. public override IList<TCDLTInfo> ToPaging(TCDLTInfo entity, int pageSize, int pageIndex, out int recordCount)
  104. {
  105. string where = "1=1 ";
  106. if (null != entity)
  107. {
  108. if (entity.Term > 0)
  109. where += " AND [Term]=" + entity.Term;
  110. }
  111. recordCount = 0;
  112. string field = "[Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenCode6],[OpenCode7],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime]"
  113. , orderField = "[Term] DESC"
  114. , tableName = "DT_TCDLT";
  115. DbParameter[] para =
  116. {
  117. DbHelper.MakeInParam(InterfaceId,"@pageSize",(DbType)SqlDbType.Int,4,pageSize),
  118. DbHelper.MakeInParam(InterfaceId,"@page",(DbType)SqlDbType.Int,4,pageIndex),
  119. DbHelper.MakeInParam(InterfaceId,"@tableName",(DbType)SqlDbType.NVarChar,500,tableName),
  120. DbHelper.MakeInParam(InterfaceId,"@field",(DbType)SqlDbType.NVarChar,1000,field),
  121. DbHelper.MakeInParam(InterfaceId,"@orderField",(DbType)SqlDbType.NVarChar,50,orderField),
  122. DbHelper.MakeInParam(InterfaceId,"@where",(DbType)SqlDbType.NVarChar,2000,where)
  123. };
  124. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  125. using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "usp_st_page", para))
  126. {
  127. while (reader.Read())
  128. {
  129. list.Add(LoadEntity(reader));
  130. }
  131. if (reader.NextResult() && reader.Read())
  132. {
  133. recordCount = reader.GetInt32(0);
  134. }
  135. reader.Dispose();
  136. }
  137. return list;
  138. }
  139. protected override TCDLTInfo LoadEntity(DataRow dr)
  140. {
  141. TCDLTInfo entity = new TCDLTInfo
  142. {
  143. Id = TypeConverter.ObjectToInt(dr["Id"]),
  144. Term = TypeConverter.ObjectToInt(dr["Term"]),
  145. OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
  146. OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
  147. OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
  148. OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
  149. OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
  150. OpenCode6 = TypeConverter.ObjectToInt(dr["OpenCode6"]),
  151. OpenCode7 = TypeConverter.ObjectToInt(dr["OpenCode7"]),
  152. OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
  153. ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
  154. KaiJiHao = dr["KaiJiHao"].ToString().Trim(),
  155. Detail = dr["Detail"].ToString(),
  156. Addtime = TypeConverter.ObjectToDateTime(dr["Addtime"], DateTime.MinValue)
  157. };
  158. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  159. return entity;
  160. }
  161. protected override TCDLTInfo LoadEntity(IDataReader reader)
  162. {
  163. TCDLTInfo entity = new TCDLTInfo
  164. {
  165. Id = TypeConverter.ObjectToInt(reader["Id"]),
  166. Term = TypeConverter.ObjectToInt(reader["Term"]),
  167. OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
  168. OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
  169. OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
  170. OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
  171. OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
  172. OpenCode6 = TypeConverter.ObjectToInt(reader["OpenCode6"]),
  173. OpenCode7 = TypeConverter.ObjectToInt(reader["OpenCode7"]),
  174. OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
  175. ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
  176. KaiJiHao = reader["KaiJiHao"].ToString().Trim(),
  177. Detail = reader["Detail"].ToString(),
  178. Addtime = TypeConverter.ObjectToDateTime(reader["Addtime"], DateTime.MinValue)
  179. };
  180. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  181. return entity;
  182. }
  183. public IList<TCDLTInfo> ToListForTrend(long term, LotterySearchField fields)
  184. {
  185. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  186. int week = null == fields ? 0 : fields.Week;
  187. DbParameter[] para;
  188. if (0 < week)
  189. {
  190. para = new DbParameter[]
  191. {
  192. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT TOP 2 OpenTime, ShiJiHao, KaiJiHao, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]<=@qi And datepart(dw,OpenTime)=@week ORDER BY [Term] DESC"),
  193. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,0,"@qi int ,@week int"),
  194. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term),
  195. DbHelper.MakeInParam(InterfaceId,"@week",(DbType)SqlDbType.Int,4,week)
  196. };
  197. }
  198. else
  199. {
  200. para = new DbParameter[]
  201. {
  202. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT TOP 2 OpenTime, ShiJiHao, KaiJiHao, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]<=@qi ORDER BY [Term] DESC"),
  203. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
  204. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
  205. };
  206. }
  207. using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
  208. {
  209. while (reader.Read())
  210. {
  211. var entity = new TCDLTInfo
  212. {
  213. Term = TypeConverter.ObjectToInt(reader["Term"]),
  214. OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
  215. OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
  216. OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
  217. OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
  218. OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
  219. OpenCode6 = TypeConverter.ObjectToInt(reader["OpenCode6"]),
  220. OpenCode7 = TypeConverter.ObjectToInt(reader["OpenCode7"]),
  221. OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
  222. ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
  223. KaiJiHao = reader["KaiJiHao"].ToString().Trim()
  224. };
  225. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  226. list.Add(entity);
  227. }
  228. reader.Close();
  229. }
  230. return list;
  231. }
  232. public IList<TCDLTInfo> ToListForNextTrend(long term, LotterySearchField fields)
  233. {
  234. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  235. int week = null == fields ? 0 : fields.Week;
  236. DbParameter[] para;
  237. if (0 < week)
  238. {
  239. para = new DbParameter[]
  240. {
  241. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT TOP 2 OpenTime, ShiJiHao, KaiJiHao, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi And datepart(dw,OpenTime)=@week ORDER BY [Term] ASC"),
  242. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,0,"@qi int ,@week int"),
  243. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term),
  244. DbHelper.MakeInParam(InterfaceId,"@week",(DbType)SqlDbType.Int,4,week)
  245. };
  246. }
  247. else
  248. {
  249. para = new DbParameter[]
  250. {
  251. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT TOP 2 OpenTime, ShiJiHao, KaiJiHao, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi ORDER BY [Term] ASC"),
  252. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
  253. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
  254. };
  255. }
  256. using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
  257. {
  258. while (reader.Read())
  259. {
  260. var entity = new TCDLTInfo
  261. {
  262. Term = TypeConverter.ObjectToInt(reader["Term"]),
  263. OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
  264. OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
  265. OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
  266. OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
  267. OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
  268. OpenCode6 = TypeConverter.ObjectToInt(reader["OpenCode6"]),
  269. OpenCode7 = TypeConverter.ObjectToInt(reader["OpenCode7"]),
  270. OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
  271. ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
  272. KaiJiHao = reader["KaiJiHao"].ToString().Trim()
  273. };
  274. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  275. list.Add(entity);
  276. }
  277. reader.Dispose();
  278. }
  279. return list;
  280. }
  281. public IList<TCDLTInfo> GetListToEnd(long term, TrendChartSearchField fields)
  282. {
  283. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  284. int week = null == fields ? 0 : fields.Week;
  285. string query = "";
  286. int topSize = 0;
  287. if (null != fields)
  288. {
  289. if (fields.Year > 0)
  290. {
  291. query += " and Term between " + (fields.Year * 1000).ToString() + " and " + ((fields.Year + 1) * 1000).ToString() + " ";
  292. fields.Record = 1500;
  293. }
  294. else if (fields.StartTerm > 0 && fields.EndTerm > 0)
  295. { query += " and Term between " + fields.StartTerm.ToString() + " and " + fields.EndTerm.ToString() + " "; fields.Record = 1500; }
  296. else if (fields.Record == 0)
  297. { fields.Record = 30; }
  298. topSize = fields.Record;
  299. }
  300. string topSql = "";
  301. if (topSize > 0) topSql = " top (" + topSize.ToString() + ")";
  302. DbParameter[] para;
  303. if (0 < week)
  304. {
  305. para = new DbParameter[]
  306. {
  307. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT "+topSql+" Id, OpenTime, ShiJiHao, KaiJiHao, Detail, Addtime, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi AND datepart(dw,OpenTime)=@week "+ query+" ORDER BY [Term] DESC"),
  308. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,0,"@qi int ,@week int"),
  309. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term),
  310. DbHelper.MakeInParam(InterfaceId,"@week",(DbType)SqlDbType.Int,4,week)
  311. };
  312. }
  313. else
  314. {
  315. para = new DbParameter[]
  316. {
  317. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,2000," SELECT "+topSql+" Id, OpenTime, ShiJiHao, KaiJiHao, Detail, Addtime, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi "+ query+" ORDER BY [Term] DESC"),
  318. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
  319. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
  320. };
  321. }
  322. using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
  323. {
  324. if (null != dt && 0 < dt.Rows.Count)
  325. {
  326. foreach (DataRow dr in dt.Rows)
  327. {
  328. var entity = new TCDLTInfo
  329. {
  330. Term = TypeConverter.ObjectToInt(dr["Term"]),
  331. OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
  332. OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
  333. OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
  334. OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
  335. OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
  336. OpenCode6 = TypeConverter.ObjectToInt(dr["OpenCode6"]),
  337. OpenCode7 = TypeConverter.ObjectToInt(dr["OpenCode7"]),
  338. OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
  339. ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
  340. KaiJiHao = dr["KaiJiHao"].ToString().Trim()
  341. };
  342. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  343. list.Add(entity);
  344. }
  345. }
  346. dt.Dispose();
  347. }
  348. return list;
  349. }
  350. public IList<TCDLTInfo> GetListToEnd(long term, LotterySearchField fields)
  351. {
  352. IList<TCDLTInfo> list = new List<TCDLTInfo>();
  353. int week = null == fields ? 0 : fields.Week;
  354. DbParameter[] para;
  355. if (0 < week)
  356. {
  357. para = new DbParameter[]
  358. {
  359. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,0,"SELECT Id, OpenTime, ShiJiHao, KaiJiHao, Detail, Addtime, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi AND datepart(dw,OpenTime)=@week ORDER BY [Term] ASC"),
  360. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,0,"@qi int ,@week int"),
  361. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term),
  362. DbHelper.MakeInParam(InterfaceId,"@week",(DbType)SqlDbType.Int,4,week)
  363. };
  364. }
  365. else
  366. {
  367. para = new DbParameter[]
  368. {
  369. DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,200,"SELECT Id, OpenTime, ShiJiHao, KaiJiHao, Detail, Addtime, Term, OpenCode1, OpenCode2, OpenCode3, OpenCode4, OpenCode5, OpenCode6, OpenCode7 FROM DT_TCDLT WHERE [Term]>=@qi ORDER BY [Term] ASC"),
  370. DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
  371. DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
  372. };
  373. }
  374. using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.StoredProcedure, "dbo.sp_executesql", para))
  375. {
  376. if (null != dt && 0 < dt.Rows.Count)
  377. {
  378. foreach (DataRow dr in dt.Rows)
  379. {
  380. var entity = new TCDLTInfo
  381. {
  382. Term = TypeConverter.ObjectToInt(dr["Term"]),
  383. OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
  384. OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
  385. OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
  386. OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
  387. OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
  388. OpenCode6 = TypeConverter.ObjectToInt(dr["OpenCode6"]),
  389. OpenCode7 = TypeConverter.ObjectToInt(dr["OpenCode7"]),
  390. OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
  391. ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
  392. KaiJiHao = dr["KaiJiHao"].ToString().Trim()
  393. };
  394. entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5, entity.OpenCode6, entity.OpenCode7 };
  395. list.Add(entity);
  396. }
  397. }
  398. dt.Dispose();
  399. }
  400. return list;
  401. }
  402. }
  403. }