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