Fcln35x7.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500
  1. using CP.Common;
  2. using MC.ORM;
  3. using MySql.Data.MySqlClient;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Threading.Tasks;
  9. namespace CP.Model
  10. {
  11. #region 辽宁福彩35选7
  12. [TableName("fcln35x7"), PrimaryKey("id")]
  13. public class Fcln35x7Info
  14. {
  15. #region
  16. /// <summary>
  17. /// 期数
  18. /// </summary>
  19. public int qi { get; set; }
  20. /// <summary>
  21. /// 第一个号码
  22. /// </summary>
  23. public int n1 { get; set; }
  24. /// <summary>
  25. /// 第二个号码
  26. /// </summary>
  27. public int n2 { get; set; }
  28. /// <summary>
  29. /// 第三个号码
  30. /// </summary>
  31. public int n3 { get; set; }
  32. /// <summary>
  33. /// 第四个号码
  34. /// </summary>
  35. public int n4 { get; set; }
  36. /// <summary>
  37. /// 第五个号码
  38. /// </summary>
  39. public int n5 { get; set; }
  40. /// <summary>
  41. /// 第六个号码
  42. /// </summary>
  43. public int n6 { get; set; }
  44. /// <summary>
  45. /// 第七个号码
  46. /// </summary>
  47. public int n7 { get; set; }
  48. /// <summary>
  49. /// 第八个号码
  50. /// </summary>
  51. public int n8 { get; set; }
  52. /// <summary>
  53. /// 和值
  54. /// </summary>
  55. public int hz { get; set; }
  56. /// <summary>
  57. /// 跨度
  58. /// </summary>
  59. public int kd { get; set; }
  60. /// <summary>
  61. /// AC值
  62. /// </summary>
  63. public int ac { get; set; }
  64. /// <summary>
  65. /// 星期几
  66. /// </summary>
  67. public int week { get; set; }
  68. /// <summary>
  69. /// 开奖日期
  70. /// </summary>
  71. public DateTime date { get; set; }
  72. /// <summary>
  73. /// 在列表中的排名..
  74. /// 用于遗漏计算.
  75. /// </summary>
  76. [Ignore]
  77. public int rank { get; set; }
  78. #endregion
  79. }
  80. #endregion
  81. #region 35选7完整模型
  82. /// <summary>
  83. /// 辽宁35选7完整模型
  84. /// </summary>
  85. [TableName("fcln35x7"), PrimaryKey("id")]
  86. public class Fcln35x7LongInfo : Fcln35x7Info
  87. {
  88. #region
  89. /// <summary>
  90. /// 自动编号
  91. /// </summary>
  92. public int id { get; set; }
  93. /// <summary>
  94. /// 一等奖注数
  95. /// </summary>
  96. public string zj1 { get; set; }
  97. /// <summary>
  98. /// 一等奖金额
  99. /// </summary>
  100. public string jo1 { get; set; }
  101. /// <summary>
  102. /// 二等奖注数
  103. /// </summary>
  104. public string zj2 { get; set; }
  105. /// <summary>
  106. /// 二等奖金额
  107. /// </summary>
  108. public string jo2 { get; set; }
  109. /// <summary>
  110. /// 三等奖注数
  111. /// </summary>
  112. public string zj3 { get; set; }
  113. /// <summary>
  114. /// 三等奖金额
  115. /// </summary>
  116. public string jo3 { get; set; }
  117. /// <summary>
  118. /// 四等奖注数
  119. /// </summary>
  120. public string zj4 { get; set; }
  121. /// <summary>
  122. /// 四等奖金额
  123. /// </summary>
  124. public string jo4 { get; set; }
  125. /// <summary>
  126. /// 五等奖注数
  127. /// </summary>
  128. public string zj5 { get; set; }
  129. /// <summary>
  130. /// 五等奖金额
  131. /// </summary>
  132. public string jo5 { get; set; }
  133. /// <summary>
  134. /// 六等奖注数
  135. /// </summary>
  136. public string zj6 { get; set; }
  137. /// <summary>
  138. /// 六等奖金额
  139. /// </summary>
  140. public string jo6 { get; set; }
  141. /// <summary>
  142. /// 幸运奖注数
  143. /// </summary>
  144. public string zj7 { get; set; }
  145. /// <summary>
  146. /// 幸运奖金额
  147. /// </summary>
  148. public string jo7 { get; set; }
  149. /// <summary>
  150. /// 开奖详情json
  151. /// </summary>
  152. public string winbonus { set; get; }
  153. /// <summary>
  154. /// 添加时间
  155. /// </summary>
  156. public DateTime addtime { get; set; }
  157. /// <summary>
  158. /// 下期奖池
  159. /// </summary>
  160. public string nextmoney { get; set; }
  161. /// <summary>
  162. /// 当期投注金额
  163. /// </summary>
  164. public string tzmoney { get; set; }
  165. /// <summary>
  166. /// 是否复查开奖号
  167. /// </summary>
  168. public int ischeck { get; set; }
  169. /// <summary>
  170. /// 号码
  171. /// </summary>
  172. public string opencode { get; set; }
  173. /// <summary>
  174. /// 第1步(开奖号)状态 -1:未添加 2:完成 3:复查完成
  175. /// </summary>
  176. public int step1state { set; get; }
  177. /// <summary>
  178. /// 第2步(开奖详情)状态 -1:未添加 1:完成一半 2:完成 3:复查完成
  179. /// </summary>
  180. public int step2state { set; get; }
  181. [Ignore]
  182. public string isComplete
  183. {
  184. get
  185. {
  186. if (step2state == 3)
  187. return "<span style='color:green;'>是</span>";
  188. return "<span style='color:red;'>否</span>";
  189. }
  190. }
  191. #endregion
  192. }
  193. #endregion
  194. #region 35x7遗漏模型
  195. /// <summary>
  196. /// 35选7出号走势图上的遗漏模型
  197. /// </summary>
  198. public class Fcln35x7MissInfo
  199. {
  200. /// <summary>
  201. /// 名称
  202. /// </summary>
  203. public string name { get; set; }
  204. /// <summary>
  205. /// 号码遗漏
  206. /// </summary>
  207. public int[] ch { get; set; }
  208. }
  209. /// <summary>
  210. /// 和值遗漏模型
  211. /// </summary>
  212. public class Fcln35x7HzMissInfo
  213. {
  214. /// <summary>
  215. /// 名称
  216. /// </summary>
  217. public string name { get; set; }
  218. /// <summary>
  219. /// 和值
  220. /// </summary>
  221. public int[] hz { get; set; }
  222. /// <summary>
  223. /// 和值奇偶
  224. /// </summary>
  225. public int[] jo { get; set; }
  226. /// <summary>
  227. /// 和尾
  228. /// </summary>
  229. public int[] hw { get; set; }
  230. }
  231. /// <summary>
  232. /// 跨度值遗漏模型
  233. /// </summary>
  234. public class Fcln35x7KdMissInfo
  235. {
  236. /// <summary>
  237. /// 名称
  238. /// </summary>
  239. public string name { get; set; }
  240. /// <summary>
  241. /// 跨度
  242. /// </summary>
  243. public int[] kd { get; set; }
  244. /// <summary>
  245. ///跨度奇偶
  246. /// </summary>
  247. public int[] jo { get; set; }
  248. /// <summary>
  249. /// 跨度大小
  250. /// </summary>
  251. public int[] dx { get; set; }
  252. /// <summary>
  253. /// 跨度质合
  254. /// </summary>
  255. public int[] zh { get; set; }
  256. }
  257. #endregion
  258. /// <summary>
  259. /// 辽宁35选7的数据库操作.
  260. /// </summary>
  261. public class Fcln35x7Data : DataConnect
  262. {
  263. /// <summary>
  264. /// 数据库中取出所有 新疆35选7数据
  265. /// </summary>
  266. /// <returns></returns>
  267. public static List<Fcln35x7Info> GetFcln35x7List()
  268. {
  269. List<Fcln35x7Info> list = new List<Fcln35x7Info>();
  270. string sql = string.Format("order by qi asc");
  271. DataConnect dc = new DataConnect();
  272. list = dc.db.Fetch<Fcln35x7Info>(sql);
  273. if (list != null && list.Count > 0)
  274. {
  275. for (int i = 0; i < list.Count; i++)
  276. {
  277. list[i].rank = i + 1;
  278. }
  279. }
  280. return list;
  281. }
  282. #region 开奖公告相关方法
  283. /// <summary>
  284. /// 获取开奖列表
  285. /// </summary>
  286. /// <param name="n">条数</param>
  287. /// <param name="type">默认0只有开奖号数据 1 带有开机号 2 带有试机号</param>
  288. /// <returns></returns>
  289. public static List<Fcln35x7LongInfo> GetList(int n = 30, bool isall = false)
  290. {
  291. string sql = $"where n1 > -1 order by qi desc limit {n}";
  292. if (isall)
  293. {
  294. sql = $"where n1 > -1 order by qi desc";
  295. }
  296. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  297. {
  298. return db.Fetch<Fcln35x7LongInfo>(sql);
  299. }
  300. }
  301. /// <summary>
  302. /// 获取最新30条开奖信息
  303. /// </summary>
  304. /// <returns></returns>
  305. public static Fcln35x7LongInfo GetFcln35X7NewInfo()
  306. {
  307. string sql = string.Format("where n1>-1 order by qi desc limit 1 ");
  308. DataConnect dc = new DataConnect();
  309. return dc.db.SingleOrDefault<Fcln35x7LongInfo>(sql);
  310. }
  311. /// <summary>
  312. /// 获取最新30条开奖信息
  313. /// </summary>
  314. /// <returns></returns>
  315. public static List<Fcln35x7LongInfo> GetFcln35x7Top30(int n = 30)
  316. {
  317. string sql = string.Format($"order by qi desc limit {n}");
  318. DataConnect dc = new DataConnect();
  319. return dc.db.Fetch<Fcln35x7LongInfo>(sql);
  320. }
  321. #region 根据期数获取某期开奖信息
  322. public static Fcln35x7LongInfo GetFcln35x7InfoByQi(int qi)
  323. {
  324. string sql = string.Empty;
  325. if (qi == 0)
  326. sql = string.Format("order by qi desc limit 1");
  327. else
  328. sql = string.Format("where qi={0} limit 1", qi);
  329. DataConnect dc = new DataConnect();
  330. Fcln35x7LongInfo info = dc.db.SingleOrDefault<Fcln35x7LongInfo>(sql);
  331. return info;
  332. }
  333. #endregion
  334. #region 根据年份取出当年所有期数
  335. /// <summary>
  336. /// 根据年份取出当年所有期数
  337. /// </summary>
  338. /// <param name="year"></param>
  339. /// <returns></returns>
  340. public static List<int> GetFcln35x7QiListByYear(int year)
  341. {
  342. List<int> rlist = new List<int>();
  343. string sql = string.Format("where qi like '{0}%' order by qi desc", year);
  344. DataConnect dc = new DataConnect();
  345. var list = dc.db.Fetch<Fcln35x7Info>(sql);
  346. if (list != null && list.Count > 0)
  347. {
  348. for (int i = 0; i < list.Count; i++)
  349. {
  350. rlist.Add(list[i].qi);
  351. }
  352. }
  353. return rlist;
  354. }
  355. #endregion
  356. #endregion
  357. #region 开奖号抓取相关数据层方法
  358. private static readonly object _lock = new object();
  359. public static void Add(Fcln35x7LongInfo info)
  360. {
  361. if (info == null)
  362. return;
  363. if (info.qi <= 0)
  364. return;
  365. info.opencode = $"{info.n1:00},{info.n2:00},{info.n3:00},{info.n4:00},{info.n5:00},{info.n6:00},{info.n7:00}+{info.n8:00}";
  366. //和值
  367. info.hz = info.n1 + info.n2 + info.n3 + info.n4 + info.n5 + info.n6 + info.n7;
  368. //星期
  369. info.week = Utils.GetIntWeek(info.date.DayOfWeek.ToString());
  370. List<int> kjh = new List<int> { info.n1, info.n2, info.n3, info.n4, info.n5, info.n6, info.n7 };
  371. kjh.Sort();
  372. info.n1 = kjh[0];
  373. info.n2 = kjh[1];
  374. info.n3 = kjh[2];
  375. info.n4 = kjh[3];
  376. info.n5 = kjh[4];
  377. info.n6 = kjh[5];
  378. info.n7 = kjh[6];
  379. //AC值
  380. string[] kjhstr = { info.n1.ToString(), info.n2.ToString(), info.n3.ToString(), info.n4.ToString(), info.n5.ToString(), info.n6.ToString(), info.n7.ToString() };
  381. //检查开奖号是否有重复值
  382. int[] array = { info.n1, info.n2, info.n3, info.n4, info.n5, info.n6, info.n7 };
  383. info.ac = ToolUtils.GetAC(kjhstr);
  384. info.kd = info.n7 - info.n1;
  385. lock (_lock)
  386. {
  387. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  388. {
  389. if (db.Exists<Fcln35x7LongInfo>($"where qi={info.qi}"))
  390. return;
  391. db.Insert(info);
  392. try
  393. {
  394. //更新api
  395. DoHttpHelp.UpdateWebApi(DFEnum.fcln35x7.ToString());
  396. }
  397. catch (Exception) { }
  398. }
  399. }
  400. }
  401. public static void Update(Fcln35x7LongInfo model)
  402. {
  403. if (model == null)
  404. return;
  405. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  406. {
  407. var entity = db.SingleOrDefault<Fcln35x7LongInfo>(model.id);
  408. db.Update(entity);
  409. }
  410. }
  411. public static Fcln35x7LongInfo GetLastOne()
  412. {
  413. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  414. {
  415. var entity = db.SingleOrDefault<Fcln35x7LongInfo>($"order by qi desc limit 1");
  416. return entity ?? new Fcln35x7LongInfo();
  417. }
  418. }
  419. #endregion
  420. }
  421. }