Open4CodeServices.cs 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Data;
  6. using System.Data.SqlClient;
  7. using Interface;
  8. using Models;
  9. using Common;
  10. using Models.Entity.LotteryNumDB;
  11. namespace Services
  12. {
  13. /// <summary>
  14. /// 开奖4个球号的彩种数据服务
  15. /// </summary>
  16. public class Open4CodeServices : BaseServices, IOpen4Code
  17. {
  18. /// <summary>
  19. /// 获取最新一条记录
  20. /// </summary>
  21. /// <param name="lottery">彩种名称</param>
  22. /// <returns></returns>
  23. public OpenCode4Model GetLastItem(SCCLottery lottery)
  24. {
  25. var TableName = EnumHelper.GetSCCLotteryTableName(lottery);
  26. var sqlString = string.Format(LastItemSql, TableName);
  27. var ds = SqlHelper.ExecuteDataset(CommandType.Text, sqlString);
  28. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  29. {
  30. var result = LoadData<OpenCode4Model>(ds.Tables[0].Rows[0]);
  31. return result;
  32. }
  33. return null;
  34. }
  35. /// <summary>
  36. /// 获取开奖列表
  37. ///
  38. /// </summary>
  39. /// <param name="lottery">彩种名称</param>
  40. /// <returns></returns>
  41. public List<OpenCode4Model> GetListIn(SCCLottery lottery, bool IsToday)
  42. {
  43. List<string> result = new List<string>();
  44. var TableName = EnumHelper.GetSCCLotteryTableName(lottery);
  45. var sqlString = string.Format(QueryListSQL, TableName, IsToday ? CommonHelper.SCCSysDateTime.ToString("yyyyMMdd") : CommonHelper.SCCSysDateTime.AddDays(-1).ToString("yyyyMMdd"));
  46. var ds = SqlHelper.ExecuteDataset(CommandType.Text, sqlString);
  47. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  48. {
  49. var data = LoadDataList<OpenCode4Model>(ds.Tables[0]);
  50. return data;
  51. }
  52. else
  53. {
  54. return null;
  55. }
  56. }
  57. /// <summary>
  58. /// 获取前一天开奖列表
  59. ///
  60. /// </summary>
  61. /// <param name="lottery">彩种名称</param>
  62. /// <returns></returns>
  63. public List<OpenCode4Model> GetYesterdayList(SCCLottery lottery)
  64. {
  65. List<string> result = new List<string>();
  66. var TableName = EnumHelper.GetSCCLotteryTableName(lottery);
  67. var sqlString = string.Format(YesterdayListSql, TableName, CommonHelper.SCCSysDateTime.AddDays(-1).ToString("yyyyMMdd"));
  68. var ds = SqlHelper.ExecuteDataset(CommandType.Text, sqlString);
  69. long tempQiHao = 0;
  70. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  71. {
  72. var data = LoadDataList<OpenCode4Model>(ds.Tables[0]);
  73. return data;
  74. }
  75. else
  76. {
  77. return null;
  78. }
  79. }
  80. /// <summary>
  81. /// 获取前一天失败列表
  82. /// 期号格式形如YYMMDDQQ
  83. /// </summary>
  84. /// <param name="lottery">彩种名称</param>
  85. /// <param name="TotalQNum">当前彩种每天总期数</param>
  86. /// <returns></returns>
  87. public List<string> GetYesterdayFailQQList(SCCLottery lottery, int TotalQNum)
  88. {
  89. List<string> result = new List<string>();
  90. var TableName = EnumHelper.GetSCCLotteryTableName(lottery);
  91. var sqlString = string.Format(YesterdayListSql, TableName, CommonHelper.SCCSysDateTime.AddDays(-1).ToString("yyyyMMdd"));
  92. var ds = SqlHelper.ExecuteDataset(CommandType.Text, sqlString);
  93. long tempQiHao = 0;
  94. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  95. {
  96. var data = LoadDataList<OpenCode4Model>(ds.Tables[0]);
  97. OpenCode4Model item = null;
  98. for (var i = 1; i <= TotalQNum; i++)
  99. {
  100. tempQiHao = Convert.ToInt64(CommonHelper.GenerateYesterdayQiHaoYYMMDDQQ(i));
  101. item = data.Where(R => R.Term == tempQiHao).FirstOrDefault();
  102. if (item == null)
  103. result.Add(tempQiHao.ToString());
  104. }
  105. }
  106. else
  107. {
  108. for (var i = 1; i <= TotalQNum; i++)
  109. {
  110. tempQiHao = Convert.ToInt64(CommonHelper.GenerateYesterdayQiHaoYYMMDDQQ(i));
  111. result.Add(tempQiHao.ToString());
  112. }
  113. }
  114. return result;
  115. }
  116. /// <summary>
  117. /// 新增彩种开奖数据
  118. /// </summary>
  119. /// <param name="lottery">彩种名称</param>
  120. /// <param name="model">开奖数据模型</param>
  121. /// <returns></returns>
  122. public bool AddOpen4Code(SCCLottery lottery, OpenCode4Model model)
  123. {
  124. var TableName = EnumHelper.GetSCCLotteryTableName(lottery);
  125. var sqlString = string.Format(AddItemSql, TableName);
  126. var param = new SqlParameter[]{
  127. new SqlParameter("@Term",model.Term),
  128. new SqlParameter("@OpenCode1",model.OpenCode1),
  129. new SqlParameter("@OpenCode2",model.OpenCode2),
  130. new SqlParameter("@OpenCode3",model.OpenCode3),
  131. new SqlParameter("@OpenCode4",model.OpenCode4),
  132. new SqlParameter("@OpenTime",model.OpenTime),
  133. new SqlParameter("@ID",Guid.NewGuid().ToString().Replace("-", ""))
  134. };
  135. var result = SqlHelper.ExecuteNonQuery(CommandType.Text, sqlString, param);
  136. return result > 0;
  137. }
  138. #region Sql语句
  139. /// <summary>
  140. /// 获取最新一条记录的Sql语句
  141. /// </summary>
  142. private static string LastItemSql = @"SELECT TOP 1 * FROM {0} ORDER BY Term DESC";
  143. /// <summary>
  144. /// 获取前一天列表的Sql语句
  145. /// </summary>
  146. private static string YesterdayListSql = @"SELECT * FROM {0}
  147. WHERE CONVERT(varchar(10),OpenTime,112)={1}
  148. ORDER BY OpenTime DESC";
  149. /// <summary>
  150. /// 新增开奖数据的Sql语句
  151. /// </summary>
  152. private static string AddItemSql = @"IF NOT EXISTS(SELECT TOP 1 1 FROM {0} WHERE Term = @Term)
  153. BEGIN
  154. INSERT INTO {0}(Term,OpenCode1,OpenCode2,OpenCode3,OpenCode4,OpenTime,Addtime,ID)
  155. SELECT @Term,@OpenCode1,@OpenCode2,@OpenCode3,@OpenCode4,@OpenTime,GETDATE(),@ID
  156. END";
  157. private static string QueryListSQL = @"SELECT * FROM {0}
  158. WHERE CONVERT(varchar(10),OpenTime,112)='{1}'
  159. ORDER BY OpenTime DESC";
  160. #endregion
  161. }
  162. }