Fcah25x5.cs 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640
  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. /// <summary>
  12. /// 安徽25选5
  13. /// </summary>
  14. [TableName("fcah25x5"), PrimaryKey("id")]
  15. public class Fcah25x5
  16. {
  17. /// <summary>
  18. /// 开奖信息自动编号
  19. /// </summary>
  20. public int id { get; set; }
  21. /// <summary>
  22. /// 期数
  23. /// </summary>
  24. public int qi { get; set; }
  25. /// <summary>
  26. /// 开奖号第1位
  27. /// </summary>
  28. public int n1 { get; set; }
  29. /// <summary>
  30. /// 开奖号第2位
  31. /// </summary>
  32. public int n2 { get; set; }
  33. /// <summary>
  34. /// 开奖号第3位
  35. /// </summary>
  36. public int n3 { get; set; }
  37. /// <summary>
  38. /// 开奖号第4位
  39. /// </summary>
  40. public int n4 { get; set; }
  41. /// <summary>
  42. /// 开奖号第5位
  43. /// </summary>
  44. public int n5 { get; set; }
  45. /// <summary>
  46. /// 和值
  47. /// </summary>
  48. public int hz { get; set; }
  49. /// <summary>
  50. /// 跨度
  51. /// </summary>
  52. public int kd { get; set; }
  53. /// <summary>
  54. /// AC值
  55. /// </summary>
  56. public int ac { get; set; }
  57. /// <summary>
  58. /// 星期
  59. /// </summary>
  60. public int week { get; set; }
  61. /// <summary>
  62. /// 开奖日期
  63. /// </summary>
  64. public DateTime date { get; set; }
  65. /// <summary>
  66. /// 在列表中的排名..
  67. /// 用于遗漏计算.
  68. /// </summary>
  69. [Ignore]
  70. public int rank { get; set; }
  71. /// <summary>
  72. /// 一等奖注数
  73. /// </summary>
  74. public string zj1 { get; set; }
  75. /// <summary>
  76. /// 一等奖金额
  77. /// </summary>
  78. public string jo1 { get; set; }
  79. /// <summary>
  80. /// 二等奖注数
  81. /// </summary>
  82. public string zj2 { get; set; }
  83. /// <summary>
  84. /// 二等奖金额
  85. /// </summary>
  86. public string jo2 { get; set; }
  87. /// <summary>
  88. /// 三等奖注数
  89. /// </summary>
  90. public string zj3 { get; set; }
  91. /// <summary>
  92. /// 三等奖金额
  93. /// </summary>
  94. public string jo3 { get; set; }
  95. /// <summary>
  96. /// 开奖详情json
  97. /// </summary>
  98. public string winbonus { set; get; }
  99. /// <summary>
  100. /// 添加开奖日期
  101. /// </summary>
  102. public DateTime addtime { get; set; }
  103. /// <summary>
  104. /// 投注金额
  105. /// </summary>
  106. public string tzmoney { get; set; }
  107. /// <summary>
  108. /// 奖池
  109. /// </summary>
  110. public string nextmoney { get; set; }
  111. /// <summary>
  112. ///是否复查
  113. /// </summary>
  114. public int ischeck { get; set; }
  115. /// <summary>
  116. /// 号码
  117. /// </summary>
  118. public string opencode { get; set; }
  119. }
  120. #region 安徽25选5基本模型
  121. [TableName("fcah25x5"), PrimaryKey("id")]
  122. public class Fcah25x5Info
  123. {
  124. /// <summary>
  125. /// 期数
  126. /// </summary>
  127. public int qi { get; set; }
  128. /// <summary>
  129. /// 开奖号第1位
  130. /// </summary>
  131. public int n1 { get; set; }
  132. /// <summary>
  133. /// 开奖号第2位
  134. /// </summary>
  135. public int n2 { get; set; }
  136. /// <summary>
  137. /// 开奖号第3位
  138. /// </summary>
  139. public int n3 { get; set; }
  140. /// <summary>
  141. /// 开奖号第4位
  142. /// </summary>
  143. public int n4 { get; set; }
  144. /// <summary>
  145. /// 开奖号第5位
  146. /// </summary>
  147. public int n5 { get; set; }
  148. /// <summary>
  149. /// 和值
  150. /// </summary>
  151. public int hz { get; set; }
  152. /// <summary>
  153. /// 跨度
  154. /// </summary>
  155. public int kd { get; set; }
  156. /// <summary>
  157. /// AC值
  158. /// </summary>
  159. public int ac { get; set; }
  160. /// <summary>
  161. /// 星期
  162. /// </summary>
  163. public int week { get; set; }
  164. /// <summary>
  165. /// 开奖日期
  166. /// </summary>
  167. public DateTime date { get; set; }
  168. /// <summary>
  169. /// 在列表中的排名..
  170. /// 用于遗漏计算.
  171. /// </summary>
  172. [Ignore]
  173. public int rank { get; set; }
  174. }
  175. #endregion
  176. #region 安徽25选5开奖信息完整模型
  177. /// <summary>
  178. /// 福彩湖北22选5开奖信息完整模型
  179. /// </summary>
  180. [TableName("fchb22x5"), PrimaryKey("id")]
  181. public class Fcah25x5LongInfo : Fcah25x5Info
  182. {
  183. /// <summary>
  184. /// 开奖信息自动编号
  185. /// </summary>
  186. public int id { get; set; }
  187. /// <summary>
  188. /// 一等奖注数
  189. /// </summary>
  190. public string zj1 { get; set; }
  191. /// <summary>
  192. /// 一等奖金额
  193. /// </summary>
  194. public string jo1 { get; set; }
  195. /// <summary>
  196. /// 二等奖注数
  197. /// </summary>
  198. public string zj2 { get; set; }
  199. /// <summary>
  200. /// 二等奖金额
  201. /// </summary>
  202. public string jo2 { get; set; }
  203. /// <summary>
  204. /// 三等奖注数
  205. /// </summary>
  206. public string zj3 { get; set; }
  207. /// <summary>
  208. /// 三等奖金额
  209. /// </summary>
  210. public string jo3 { get; set; }
  211. /// <summary>
  212. /// 开奖详情json
  213. /// </summary>
  214. public string winbonus { set; get; }
  215. /// <summary>
  216. /// 添加开奖日期
  217. /// </summary>
  218. public DateTime addtime { get; set; }
  219. /// <summary>
  220. /// 投注金额
  221. /// </summary>
  222. public string tzmoney { get; set; }
  223. /// <summary>
  224. /// 奖池
  225. /// </summary>
  226. public string nextmoney { get; set; }
  227. /// <summary>
  228. ///是否复查
  229. /// </summary>
  230. public int ischeck { get; set; }
  231. /// <summary>
  232. /// 号码
  233. /// </summary>
  234. public string opencode { get; set; }
  235. }
  236. #endregion
  237. #region 走势图上的遗漏模型
  238. /// <summary>
  239. /// 22x5出号走势图上的遗漏模型
  240. /// </summary>
  241. public class ah25x5ChzsMissInfo
  242. {
  243. public string name { get; set; }
  244. /// <summary>
  245. /// 出号
  246. /// </summary>
  247. public int[] ch { get; set; }
  248. }
  249. /// <summary>
  250. /// 和值走势图上的遗漏
  251. /// </summary>
  252. public class ah25x5hzMissInfo
  253. {
  254. public string name { get; set; }
  255. public int[] hz { get; set; }
  256. public int[] hzjo { get; set; }
  257. public int[] hw { get; set; }
  258. public int[] hwdx { get; set; }
  259. public int[] hwjo { get; set; }
  260. }
  261. /// <summary>
  262. /// 22x5AC值走势图遗漏模型
  263. /// </summary>
  264. public class ah25x5AcMissInfo
  265. {
  266. public string name { get; set; }
  267. public int[] ac { get; set; }
  268. public int[] dx { get; set; }
  269. public int[] jo { get; set; }
  270. public int[] zh { get; set; }
  271. public int[] _012 { get; set; }
  272. public int[] zf { get; set; }
  273. }
  274. /// <summary>
  275. /// 22x5 跨度走势图遗漏模型
  276. /// </summary>
  277. public class ah25x5KdMissInfo
  278. {
  279. public string name { get; set; }
  280. public int[] kd { get; set; }
  281. public int[] dx { get; set; }
  282. public int[] jo { get; set; }
  283. public int[] zh { get; set; }
  284. public int[] _012 { get; set; }
  285. }
  286. /// <summary>
  287. /// 012路走势图上的遗漏模型
  288. /// </summary>
  289. public class ah25x5012MissInfo
  290. {
  291. /// <summary>
  292. /// 名称
  293. /// </summary>
  294. public string name { get; set; }
  295. /// <summary>
  296. /// 号码1形态
  297. /// </summary>
  298. public int[] w1 { get; set; }
  299. /// <summary>
  300. /// 号码2形态
  301. /// </summary>
  302. public int[] w2 { get; set; }
  303. public int[] w3 { get; set; }
  304. public int[] w4 { get; set; }
  305. public int[] w5 { get; set; }
  306. /// <summary>
  307. /// 大个数走势
  308. /// </summary>
  309. public int[] xt1 { get; set; }
  310. /// <summary>
  311. /// 小个数
  312. /// </summary>
  313. public int[] xt2 { get; set; }
  314. /// <summary>
  315. /// 3个数
  316. /// </summary>
  317. public int[] xt3 { get; set; }
  318. }
  319. /// <summary>
  320. /// 大小走势图上的遗漏模型
  321. /// </summary>
  322. public class ah25x5DxMissInfo
  323. {
  324. /// <summary>
  325. /// 名称
  326. /// </summary>
  327. public string name { get; set; }
  328. /// <summary>
  329. /// 号码1形态
  330. /// </summary>
  331. public int[] w1 { get; set; }
  332. /// <summary>
  333. /// 号码2形态
  334. /// </summary>
  335. public int[] w2 { get; set; }
  336. public int[] w3 { get; set; }
  337. public int[] w4 { get; set; }
  338. public int[] w5 { get; set; }
  339. /// <summary>
  340. /// 比值走势
  341. /// </summary>
  342. public int[] bz { get; set; }
  343. /// <summary>
  344. /// 大个数走势
  345. /// </summary>
  346. public int[] xt1 { get; set; }
  347. /// <summary>
  348. /// 小个数
  349. /// </summary>
  350. public int[] xt2 { get; set; }
  351. }
  352. #endregion
  353. /// <summary>
  354. /// 安徽25选5
  355. /// </summary>
  356. public class Fcah25x5Data : DataConnect
  357. {
  358. /// <summary>
  359. /// 根据期数获取某期开奖信息
  360. /// </summary>
  361. /// <param name="qi"></param>
  362. /// <returns></returns>
  363. public static Fcah25x5 GetQi(int qi)
  364. {
  365. string sql = string.Empty;
  366. if (qi == 0)
  367. sql = string.Format("order by qi desc limit 1");
  368. else
  369. sql = string.Format("where qi={0} limit 1", qi);
  370. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  371. {
  372. Fcah25x5 info = db.SingleOrDefault<Fcah25x5>(sql);
  373. return info;
  374. }
  375. }
  376. /// <summary>
  377. /// 最新30期完整开奖数据
  378. /// </summary>
  379. /// <returns></returns>
  380. public static List<Fcah25x5> GetList(int n = 30, bool isall = false)
  381. {
  382. string sql = $"where n1 > -1 order by qi desc limit {n}";
  383. if (isall)
  384. {
  385. sql = $"where n1 > -1 order by qi desc";
  386. }
  387. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  388. {
  389. return db.Fetch<Fcah25x5>(sql);
  390. }
  391. }
  392. #region 开奖号抓取相关数据层方法
  393. private static readonly object _lock = new object();
  394. public static void Add(Fcah25x5 info)
  395. {
  396. if (info == null)
  397. return;
  398. if (info.qi <= 0)
  399. return;
  400. info.opencode = $"{info.n1:00},{info.n2:00},{info.n3:00},{info.n4:00},{info.n5:00}";
  401. //和值
  402. info.hz = info.n1 + info.n2 + info.n3 + info.n4 + info.n5 ;
  403. //星期
  404. info.week = Utils.GetIntWeek(info.date.DayOfWeek.ToString());
  405. //AC值
  406. string[] kjhstr = { info.n1.ToString(), info.n2.ToString(), info.n3.ToString(), info.n4.ToString(), info.n5.ToString()};
  407. info.ac = ToolUtils.GetAC(kjhstr);
  408. info.kd = info.n5 - info.n1;
  409. lock (_lock)
  410. {
  411. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  412. {
  413. if (db.Exists<Fcah25x5>($"where qi={info.qi}"))
  414. return;
  415. db.Insert(info);
  416. try
  417. {
  418. //更新api
  419. DoHttpHelp.UpdateWebApi(DFEnum.fcah25x5.ToString());
  420. }
  421. catch (Exception) { }
  422. }
  423. }
  424. }
  425. public static void Update(Fcah25x5 model)
  426. {
  427. if (model == null)
  428. return;
  429. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  430. {
  431. var entity = db.SingleOrDefault<Fcah25x5>(model.id);
  432. db.Update(entity);
  433. }
  434. }
  435. public static Fcah25x5 GetLastOne()
  436. {
  437. using (Database db = new Database(mysql, MySqlClientFactory.Instance))
  438. {
  439. var entity = db.SingleOrDefault<Fcah25x5>($"order by qi desc limit 1");
  440. return entity;
  441. }
  442. }
  443. #endregion
  444. /// <summary>
  445. /// 所有的湖北22选5的数据
  446. /// </summary>
  447. /// <returns></returns>
  448. public static List<Fcah25x5Info> GetFcah25x5List()
  449. {
  450. List<Fcah25x5Info> list = new List<Fcah25x5Info>();
  451. string sql = string.Format("order by qi asc");
  452. DataConnect dc = new DataConnect();
  453. list = dc.db.Fetch<Fcah25x5Info>(sql);
  454. if (list != null && list.Count > 0)
  455. {
  456. for (int i = 0; i < list.Count; i++)
  457. {
  458. list[i].rank = i + 1;
  459. }
  460. }
  461. return list;
  462. }
  463. #region 开奖公告相关方法
  464. /// <summary>
  465. /// 获取最新开奖信息
  466. /// </summary>
  467. /// <returns></returns>
  468. public static Fcah25x5LongInfo GetFchb22X5NewInfo()
  469. {
  470. string sql = string.Format("where n1>-1 order by qi desc limit 1 ");
  471. DataConnect dc = new DataConnect();
  472. return dc.db.SingleOrDefault<Fcah25x5LongInfo>(sql);
  473. }
  474. /// <summary>
  475. /// 获取最新30条开奖信息
  476. /// </summary>
  477. /// <returns></returns>
  478. public static List<Fcah25x5LongInfo> GetFcah25x5Top30()
  479. {
  480. string sql = string.Format("order by qi desc limit 30");
  481. DataConnect dc = new DataConnect();
  482. return dc.db.Fetch<Fcah25x5LongInfo>(sql);
  483. }
  484. #region 根据期数获取某期开奖信息
  485. /// <summary>
  486. /// 根据期数获取某期开奖信息
  487. /// </summary>
  488. /// <param name="qi"></param>
  489. /// <returns></returns>
  490. public static Fcah25x5LongInfo GetFcah25x5InfoByQi(int qi)
  491. {
  492. string sql = string.Empty;
  493. if (qi == 0)
  494. sql = string.Format("order by qi desc limit 1");
  495. else
  496. sql = string.Format("where qi={0} limit 1", qi);
  497. DataConnect dc = new DataConnect();
  498. Fcah25x5LongInfo info = dc.db.SingleOrDefault<Fcah25x5LongInfo>(sql);
  499. return info;
  500. }
  501. #endregion
  502. #region 根据年份取出当年所有期数
  503. /// <summary>
  504. /// 根据年份取出当年所有期数
  505. /// </summary>
  506. /// <param name="year"></param>
  507. /// <returns></returns>
  508. public static List<int> GetFcah25x5QiListByYear(int year)
  509. {
  510. List<int> rlist = new List<int>();
  511. string sql = string.Format("where qi like '{0}%' order by qi desc", year);
  512. DataConnect dc = new DataConnect();
  513. var list = dc.db.Fetch<Fcah25x5Info>(sql);
  514. if (list != null && list.Count > 0)
  515. {
  516. for (int i = 0; i < list.Count; i++)
  517. {
  518. rlist.Add(list[i].qi);
  519. }
  520. }
  521. return rlist;
  522. }
  523. #endregion
  524. #endregion
  525. }
  526. }