OddsJob.cs 44 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Configuration;
  4. using System.Diagnostics;
  5. using System.Linq;
  6. using System.Text;
  7. using System.Threading;
  8. using System.Threading.Tasks;
  9. using FCS.Common;
  10. using FCS.Interface;
  11. using FCS.Models;
  12. using HtmlAgilityPack;
  13. using Newtonsoft.Json;
  14. using Newtonsoft.Json.Linq;
  15. using Quartz;
  16. namespace FCS.Crawler.ZCLotteryGames
  17. {
  18. class OddsJob : CommonJob, IJob,IDisposable
  19. {
  20. public OddsJob()
  21. {
  22. logName = "OddsJob";
  23. log = new LogHelper();
  24. services = IOC.Resolve<IDTOpenCode>();
  25. }
  26. public void Execute(IJobExecutionContext context)
  27. {
  28. //Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
  29. // Click();
  30. }
  31. private List<int> listCuringint = new List<int>();
  32. private List<int> listDetailint = new List<int>();
  33. private List<int> listAnalysisint = new List<int>();
  34. private List<string> listGameId = new List<string>();
  35. public List<string> urllist = new List<string>();
  36. public List<string> urllist1 = new List<string>();
  37. public List<string> Companylist = new List<string>();//所有公司
  38. public List<BankerCompany> bclist = new List<BankerCompany>();
  39. public List<BankerCompanyRelation> bcrlist = new List<BankerCompanyRelation>();
  40. public static List<F_CuringAnalysis> calist = new List<F_CuringAnalysis>();
  41. public List<F_Team> teamlist = new List<F_Team>();
  42. public static List<F_SeasonAnalysis> salist = new List<F_SeasonAnalysis>();
  43. public static List<F_OddsCuring> oclist = new List<F_OddsCuring>();
  44. public List<F_OddsCuring> oclist_new = new List<F_OddsCuring>();
  45. public static List<F_Compensate> csalist = new List<F_Compensate>();
  46. public List<F_Compensate> csalist_new = new List<F_Compensate>();
  47. private List<F_Compensate> listDetailId = new List<F_Compensate>();
  48. //公司类型
  49. public static string a1 = "c06f47ca4f8ee811af5a2c4d54d3f5a9", a2 = "00ae03d14f8ee811af5a2c4d54d3f5a9", a3 = "30d122dc4f8ee811af5a2c4d54d3f5a9", a4 = "f08de6e64f8ee811af5a2c4d54d3f5a9", a5 = "904f40ef4f8ee811af5a2c4d54d3f5a9";
  50. //百家欧赔 c06f47ca4f8ee811af5a2c4d54d3f5a9
  51. //主流公司 00ae03d14f8ee811af5a2c4d54d3f5a9 0
  52. //交易公司 30d122dc4f8ee811af5a2c4d54d3f5a9 1
  53. //亚洲公司 f08de6e64f8ee811af5a2c4d54d3f5a9 2
  54. //普通公司 904f40ef4f8ee811af5a2c4d54d3f5a9 5
  55. //欧赔固化分析大小值类型
  56. public static string b1 = "b1b112fa278ee811a04200ac6a4a134f", b2 = "b2b112fa278ee811a04200ac6a4a134f", b3 = "b1bf8c08288ee811a04200ac6a4a134f";
  57. //平均值 b1b112fa278ee811a04200ac6a4a134f
  58. //最小值 b2b112fa278ee811a04200ac6a4a134f
  59. //最大值 b1bf8c08288ee811a04200ac6a4a134f
  60. public void Click(List<F_Games> Gamelistq)
  61. {
  62. try
  63. {
  64. string Season = DateTime.Now.ToString("yyyy");
  65. //Gamelistq = glist;
  66. teamlist = services.Query<F_Team>().ToList();
  67. int number = Gamelistq.Count;
  68. int page = number % 1000 == 0 ? number / 1000 : number / 1000 + 1;
  69. //要删除的
  70. //插入之前 获取要删除的旧数据的所有PK
  71. for (int i = 0; i < Gamelistq.Count; i++)
  72. {
  73. listGameId.Add(Gamelistq[i].Id);
  74. }
  75. if (Gamelistq.Count > 0)
  76. {
  77. var query1 = new List<F_Compensate>();
  78. foreach (var item in Gamelistq)
  79. {
  80. try
  81. {
  82. query1.AddRange(services.Query<F_Compensate>(" and (GameId = ('" + item.Id + "')) ").Where(a=>a.ChangeDateTime> Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"))).ToList());
  83. }
  84. catch (Exception)
  85. {
  86. }
  87. try
  88. {
  89. query1.AddRange(services.Query<F_Compensate>(" and (GameId = ('" + item.Id + "') and CompensateType =('a1bfa33cd96ae811ab3100ac6a4a134f') )").ToList());
  90. }
  91. catch (Exception)
  92. {
  93. }
  94. try
  95. {
  96. query1.AddRange(services.Query<F_Compensate>(" and (GameId = ('" + item.Id + "') and CompensateType =('21f77e31d96ae811ab3100ac6a4a134f') )").ToList());
  97. }
  98. catch (Exception)
  99. {
  100. }
  101. try
  102. {
  103. query1.AddRange(services.Query<F_Compensate>(" and (GameId = ('" + item.Id + "') and CompensateType =('20f77e31d96ae811ab3100ac6a4a134f') )").ToList());
  104. }
  105. catch (Exception)
  106. {
  107. }
  108. }
  109. listDetailId = query1;
  110. for (int i = 0; i < query1.Count; i++)
  111. {
  112. listDetailint.Add(query1[i].PK);
  113. }
  114. var query2 = services.Query<F_OddsCuring>(" and GameId in ('" + string.Join("','", listGameId) + "')") == null ? new List<F_OddsCuring>() : services.Query<F_OddsCuring>(" and GameId in ('" + string.Join("','", listGameId) + "')").ToList();
  115. for (int i = 0; i < query2.Count; i++)
  116. {
  117. listCuringint.Add(query2[i].PK);
  118. }
  119. var query3 = services.Query<F_CuringAnalysis>(" and GameId in ('" + string.Join("','", listGameId) + "') and CuringType='0046feff428ee811af5a2c4d54d3f5a9'") == null ? new List<F_CuringAnalysis>() : services.Query<F_CuringAnalysis>(" and GameId in ('" + string.Join("','", listGameId) + "') and CuringType='0046feff428ee811af5a2c4d54d3f5a9'").ToList();
  120. for (int i = 0; i < query3.Count; i++)
  121. {
  122. listAnalysisint.Add(query3[i].PK);
  123. }
  124. }
  125. for (int j = 0; j < page; j++)
  126. {
  127. Trace.WriteLine("第几个J 开始 OddsJob :" + (j + 1));
  128. threadCount = Gamelistq.Count;
  129. finishcount = 0;
  130. Gamelistq.ForEach(async p =>
  131. {
  132. await Task.Run(() =>
  133. {
  134. Getbjop_new(p.Remark, p);
  135. });
  136. lock (locker)
  137. {
  138. finishcount++;
  139. Monitor.Pulse(locker); //完成,通知等待队列,告知已完,执行下一个。
  140. }
  141. });
  142. lock (locker)
  143. {
  144. while (finishcount != threadCount)
  145. {
  146. Thread.Sleep(5000);
  147. Monitor.Wait(locker);//等待
  148. }
  149. }
  150. Companylist = Companylist.Distinct().ToList();
  151. InsertBankerCompany(Companylist);
  152. InsertBankerCompany1();
  153. {
  154. List<F_SeasonAnalysis> teamSeasonAnalysislist = new List<F_SeasonAnalysis>();
  155. try
  156. {
  157. teamSeasonAnalysislist = services.Query<F_SeasonAnalysis>().ToList();
  158. }
  159. catch (Exception e)
  160. {
  161. }
  162. salist = salist.Distinct().ToList();
  163. salist = salist.Where((x, i) => salist.FindIndex(z => z.TeamId == x.TeamId) == i).ToList();//Lambda表达式去重
  164. List<F_SeasonAnalysis> salist2 = new List<F_SeasonAnalysis>();
  165. foreach (var item in salist)
  166. {
  167. if (teamSeasonAnalysislist.Where(a => a.TeamId == item.TeamId).ToList().Count == 0)
  168. salist2.Add(item);
  169. }
  170. Trace.WriteLine("插入赛季分析数据 开始:" + salist2.Count);
  171. if (salist2.Count != 0)
  172. services.SqlBulkCopyAdd(salist2);
  173. }
  174. List<BankerCompany> listbk = new List<BankerCompany>();
  175. try
  176. {
  177. listbk = services.Query<BankerCompany>().ToList();
  178. }
  179. catch (Exception e)
  180. {
  181. }
  182. Thread.Sleep(5000);
  183. oclist = oclist.Where(a => a != null).ToList();
  184. foreach (var item in oclist)
  185. {
  186. F_OddsCuring oc_new = new F_OddsCuring();
  187. oc_new = item;
  188. lock (listbk)
  189. {
  190. var listbkdetail = listbk.Where(a => a.Name == item.BankerCompanyId).FirstOrDefault();
  191. oc_new.BankerCompanyId = listbkdetail == null ? "" : listbkdetail.Id;
  192. }
  193. lock (oclist_new)
  194. {
  195. oclist_new.Add(oc_new);
  196. }
  197. }
  198. csalist = csalist.Where(a => a != null).ToList();
  199. foreach (var item in csalist)
  200. {
  201. if (item != null)
  202. {
  203. F_Compensate cp = new F_Compensate();
  204. cp = item;
  205. lock (listbk)
  206. {
  207. var listbkdetail = listbk.Where(a => a.Name == item.BankerCompanyId).FirstOrDefault();
  208. cp.BankerCompanyId = listbkdetail == null ? "" : listbkdetail.Id;
  209. }
  210. lock (oclist_new)
  211. {
  212. csalist_new.Add(cp);
  213. }
  214. }
  215. }
  216. }
  217. {
  218. Trace.WriteLine("插入欧赔固化数据 开始:" + oclist_new.Count);
  219. if (oclist_new.Count != 0)
  220. services.SqlBulkCopyAdd(oclist_new);
  221. Trace.WriteLine("插入固化分析数据 开始:" + calist.Count);
  222. if (calist.Count != 0)
  223. services.SqlBulkCopyAdd(calist);
  224. var list_com = new List<F_Compensate>();
  225. foreach (var item in Gamelistq)
  226. {
  227. var count = listDetailId.Where(a => a.GameId == item.Id).ToList().Count;
  228. var count_new = csalist_new.Where(a => a.GameId == item.Id).ToList().Count;
  229. if (count_new == 0 && count == 0)
  230. continue;
  231. if (count < count_new)
  232. {
  233. list_com.AddRange(csalist_new.Where(a => a.GameId == item.Id).ToList());
  234. }
  235. else
  236. {
  237. List<F_Compensate> intlist = new List<F_Compensate>();
  238. foreach (var item3 in listDetailId.Where(a => a.GameId == item.Id).ToList())
  239. {
  240. var items = item3;
  241. items.PK = 0;
  242. intlist.Add(items);
  243. }
  244. list_com.AddRange(intlist);
  245. }
  246. }
  247. Trace.WriteLine("插入欧赔详情数据 开始:" + list_com.Count);
  248. if (list_com.Count != 0)
  249. {
  250. int page1 = list_com.Count % 1000 == 0 ? list_com.Count / 1000 : list_com.Count / 1000 + 1;
  251. for (int i = 0; i < page1; i++)
  252. {
  253. var querylist = list_com.Skip(i * 1000).Take(1000).ToList();
  254. Trace.WriteLine("插入欧赔详情数据 开始:" + querylist.Count);
  255. services.SqlBulkCopyAdd(querylist);
  256. }
  257. }
  258. urllist = new List<string>();
  259. urllist1 = new List<string>();
  260. Companylist = new List<string>();//所有公司
  261. bclist = new List<BankerCompany>();
  262. bcrlist = new List<BankerCompanyRelation>();
  263. calist = new List<F_CuringAnalysis>();
  264. salist = new List<F_SeasonAnalysis>();
  265. oclist = new List<F_OddsCuring>();
  266. oclist_new = new List<F_OddsCuring>();
  267. csalist = new List<F_Compensate>();
  268. csalist_new = new List<F_Compensate>();
  269. }
  270. Trace.WriteLine("删除数据 F_CuringAnalysis 开始:" + listAnalysisint.Count);
  271. if (listAnalysisint.Count > 0)
  272. services.Delete<F_CuringAnalysis>(" and PK in (" + string.Join(",", listAnalysisint) + ")");
  273. Trace.WriteLine("删除数据 F_CuringAnalysis 结束:" + listAnalysisint.Count);
  274. listAnalysisint = new List<int>();
  275. Trace.WriteLine("删除数据 F_Compensate 开始:" + listDetailint.Count);
  276. if (listDetailint.Count > 0)
  277. {
  278. if (listDetailint.Count > 1000)
  279. {
  280. int pages = listDetailint.Count % 1000 == 0 ? listDetailint.Count / 1000 : listDetailint.Count / 1000 + 1;
  281. for (int i = 0; i < pages; i++)
  282. {
  283. var listDetailint1 = listDetailint.Skip(i * 1000).Take(1000).ToList();
  284. services.Delete<F_Compensate>(" and PK in (" + string.Join(",", listDetailint1) + ")");
  285. Trace.WriteLine("删除数据 F_OddsCuring 结束中:" + listDetailint1.Count);
  286. }
  287. }
  288. else
  289. {
  290. services.Delete<F_Compensate>(" and PK in (" + string.Join(",", listDetailint) + ")");
  291. }
  292. }
  293. Trace.WriteLine("删除数据 F_Compensate 结束:" + listDetailint.Count);
  294. listDetailint = new List<int>();
  295. Trace.WriteLine("删除数据 F_OddsCuring 开始:" + listCuringint.Count);
  296. if (listCuringint.Count > 0)
  297. {
  298. if (listCuringint.Count > 1000)
  299. {
  300. int pages = listCuringint.Count % 1000 == 0 ? listCuringint.Count / 1000 : listCuringint.Count / 1000 + 1;
  301. for (int i = 0; i < pages; i++)
  302. {
  303. var listCuringint1 = listCuringint.Skip(i * 1000).Take(1000).ToList();
  304. services.Delete<F_OddsCuring>(" and PK in (" + string.Join(",", listCuringint1) + ")");
  305. Trace.WriteLine("删除数据 F_OddsCuring 结束中:" + listCuringint1.Count);
  306. }
  307. }
  308. else
  309. {
  310. services.Delete<F_OddsCuring>(" and PK in (" + string.Join(",", listCuringint) + ")");
  311. }
  312. }
  313. Trace.WriteLine("删除数据 F_OddsCuring 结束:" + listCuringint.Count);
  314. listCuringint = new List<int>();
  315. Gamelistq = new List<F_Games>();
  316. teamlist = new List<F_Team>();
  317. }
  318. catch (Exception e)
  319. {
  320. CommonHelper.LogBD(e.Message, logName);
  321. CommonHelper.LogBD(e.Source, logName);
  322. CommonHelper.LogBD(e.StackTrace, logName);
  323. EmailHelper.Send("赔率报错", e.Message);
  324. Thread.Sleep(1000*60*5);
  325. urllist = new List<string>();
  326. urllist1 = new List<string>();
  327. Companylist = new List<string>();//所有公司
  328. bclist = new List<BankerCompany>();
  329. bcrlist = new List<BankerCompanyRelation>();
  330. calist = new List<F_CuringAnalysis>();
  331. salist = new List<F_SeasonAnalysis>();
  332. oclist = new List<F_OddsCuring>();
  333. oclist_new = new List<F_OddsCuring>();
  334. csalist = new List<F_Compensate>();
  335. csalist_new = new List<F_Compensate>();
  336. Click(Gamelistq);
  337. }
  338. }
  339. /// <summary>
  340. /// 插入数据公司
  341. /// </summary>
  342. /// <param name="data"></param>
  343. /// <param name="Id"></param>
  344. /// <param name="Season"></param>
  345. public void InsertBankerCompany(List<string> Companylist)
  346. {
  347. List<BankerCompany> listbk = new List<BankerCompany>();
  348. try
  349. {
  350. listbk = services.Query<BankerCompany>().ToList();
  351. }
  352. catch (Exception e)
  353. {
  354. }
  355. foreach (var item in Companylist)
  356. {
  357. if (item.IsEmpty())
  358. continue;
  359. var query = item.Split('|');
  360. if (listbk.Where(a => a.Name == query[0]).ToList().Count > 0)
  361. continue;
  362. BankerCompany bc = new BankerCompany();
  363. bc.CreateDateTime = DateTime.Now;
  364. bc.Id = CommonHelper.GetGuid().ToString();
  365. bc.Name = query[0];
  366. bclist.Add(bc);
  367. }
  368. List<BankerCompany> bclist1 = bclist.Where((x, i) => bclist.FindIndex(z => z.Name == x.Name) == i).ToList();//Lambda表达式去重
  369. Trace.WriteLine("插入公司数据 开始:" + bclist1.Count);
  370. if(bclist1.Count!=0)
  371. services.SqlBulkCopyAdd(bclist1);
  372. }
  373. public void InsertBankerCompany1()
  374. {
  375. List<BankerCompany> listbk = new List<BankerCompany>();
  376. List<BankerCompanyRelation> listbkrs = new List<BankerCompanyRelation>();
  377. try
  378. {
  379. listbk = services.Query<BankerCompany>().ToList();
  380. listbkrs = services.Query<BankerCompanyRelation>().ToList();
  381. }
  382. catch (Exception e)
  383. {
  384. }
  385. foreach (var item in Companylist)
  386. {
  387. if (item.IsEmpty())
  388. continue;
  389. var query = item.Split('|');
  390. // bclist1
  391. if (listbk.Where(a => a.Name == query[0]).ToList().Count > 0)
  392. {
  393. var query2 = query[1].Split(',');
  394. foreach (var item1 in query2)
  395. {
  396. //if (!item1.Trim().IsEmpty())
  397. {
  398. BankerCompanyRelation bcr = new BankerCompanyRelation();
  399. bcr.BankerCompanyId = listbk.Where(a => a.Name == query[0]).FirstOrDefault().Id;
  400. if (item1 == "0")
  401. bcr.BankerCompanyType = a2;
  402. if (item1 == "1")
  403. bcr.BankerCompanyType = a3;
  404. if (item1 == "2")
  405. bcr.BankerCompanyType = a4;
  406. if (item1 == "5")
  407. bcr.BankerCompanyType = a5;
  408. if (item1 == "")
  409. bcr.BankerCompanyType = a1;
  410. if (item1 == "X")
  411. bcr.BankerCompanyType = a1;
  412. bcr.Remark = "";
  413. bcr.Id = CommonHelper.GetGuid().ToString();
  414. bcr.CreateDateTime = DateTime.Now;
  415. if (listbkrs.Where(a => a.BankerCompanyType == bcr.BankerCompanyType && a.BankerCompanyId == bcr.BankerCompanyId).ToList().Count == 0)
  416. {
  417. bcrlist.Add(bcr);
  418. }
  419. }
  420. }
  421. }
  422. }
  423. Trace.WriteLine("插入公司分类数据 开始:" + bcrlist.Count);
  424. if (bcrlist.Count!=0)
  425. services.SqlBulkCopyAdd(bcrlist);
  426. }
  427. /// <summary>
  428. /// 插入数据欧赔数据
  429. /// </summary>
  430. /// <param name="data"></param>
  431. /// <param name="Id"></param>
  432. /// <param name="Season"></param>
  433. public void InsertCompensate(string data, F_OddsCuring oc, string url)
  434. {
  435. try
  436. {
  437. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  438. F_Compensate ca = new F_Compensate();
  439. ca.BankerCompanyId = oc.BankerCompanyId;
  440. ca.ChangeDateTime = Convert.ToDateTime(query[1]);
  441. ca.CompensateType = "a0bfa33cd96ae811ab3100ac6a4a134f";//即时赔率 a0bfa33cd96ae811ab3100ac6a4a134f
  442. ca.CreateDateTime = DateTime.Now;
  443. ca.SOdd = Convert.ToDouble(query[3]);
  444. ca.POdd = Convert.ToDouble(query[4]);
  445. ca.FOdd = Convert.ToDouble(query[5]);
  446. ca.Remark = url;
  447. ca.Id = CommonHelper.GetGuid().ToString();
  448. ca.GameId = oc.GameId;
  449. csalist.Add(ca);
  450. ca = new F_Compensate();
  451. ca.BankerCompanyId = oc.BankerCompanyId;
  452. ca.ChangeDateTime = Convert.ToDateTime(query[1]);
  453. ca.CompensateType = "20f77e31d96ae811ab3100ac6a4a134f";//概率 20f77e31d96ae811ab3100ac6a4a134f
  454. ca.CreateDateTime = DateTime.Now;
  455. ca.SOdd = Convert.ToDouble(query[6]);
  456. ca.POdd = -1;
  457. ca.FOdd = Convert.ToDouble(query[7]);
  458. ca.Remark = url;
  459. ca.Id = CommonHelper.GetGuid().ToString();
  460. ca.GameId = oc.GameId;
  461. csalist.Add(ca);
  462. ca = new F_Compensate();
  463. ca.BankerCompanyId = oc.BankerCompanyId;
  464. ca.ChangeDateTime = Convert.ToDateTime(query[1]);
  465. ca.CompensateType = "21f77e31d96ae811ab3100ac6a4a134f";//凯利指数 21f77e31d96ae811ab3100ac6a4a134f
  466. ca.CreateDateTime = DateTime.Now;
  467. ca.SOdd = Convert.ToDouble(query[8]);
  468. ca.POdd = -1;
  469. ca.FOdd = Convert.ToDouble(query[9]);
  470. ca.Remark = url;
  471. ca.Id = CommonHelper.GetGuid().ToString();
  472. ca.GameId = oc.GameId;
  473. csalist.Add(ca);
  474. ca = new F_Compensate();
  475. ca.BankerCompanyId = oc.BankerCompanyId;
  476. ca.ChangeDateTime = Convert.ToDateTime(query[1]);
  477. ca.CompensateType = "a1bfa33cd96ae811ab3100ac6a4a134f";//赔付率 a1bfa33cd96ae811ab3100ac6a4a134f
  478. ca.CreateDateTime = DateTime.Now;
  479. ca.SOdd = Convert.ToDouble(query[10]);
  480. ca.POdd = -1;
  481. ca.FOdd = -1;
  482. ca.Remark = url;
  483. ca.Id = CommonHelper.GetGuid().ToString();
  484. ca.GameId = oc.GameId;
  485. csalist.Add(ca);
  486. }
  487. catch (Exception e)
  488. {
  489. }
  490. }
  491. /// <summary>
  492. /// 插入数据欧赔固化分析数据
  493. /// </summary>
  494. /// <param name="data"></param>
  495. /// <param name="Id"></param>
  496. /// <param name="Season"></param>
  497. public F_CuringAnalysis InsertCuringAnalysis_new(string data, string Id, string url)
  498. {
  499. var query = data.Split('|');
  500. F_CuringAnalysis ca = new F_CuringAnalysis();
  501. ca.Remark = url;
  502. ca.Id = CommonHelper.GetGuid().ToString();
  503. ca.CreateDateTime = DateTime.Now;
  504. ca.CuringType = "0046feff428ee811af5a2c4d54d3f5a9";
  505. if (query[1] == "平均值")
  506. ca.CuringAnalysisType = b1;
  507. if (query[1] == "最大值")
  508. ca.CuringAnalysisType = b2;
  509. if (query[1] == "最小值")
  510. ca.CuringAnalysisType = b3;
  511. ca.GameId = Id;
  512. ca.Init_SOdd = Convert.ToDouble(query[2]);
  513. ca.Init_POdd = Convert.ToDouble(query[3]);
  514. ca.Init_FOdd = Convert.ToDouble(query[4]);
  515. ca.Newest_SOdd = Convert.ToDouble(query[5]);
  516. ca.Newest_POdd = Convert.ToDouble(query[6]);
  517. ca.Newest_FOdd = Convert.ToDouble(query[7]);
  518. ca.Probability_SOdd = Convert.ToDouble(query[9]);
  519. ca.Probability_POdd = Convert.ToDouble(query[10]);
  520. ca.Probability_FOdd = Convert.ToDouble(query[11]);
  521. ca.Kelly_SOdd = Convert.ToDouble(query[12]);
  522. ca.Kelly_POdd = Convert.ToDouble(query[13]);
  523. ca.Kelly_FOdd = Convert.ToDouble(query[14]);
  524. ca.Loss_Odd = Convert.ToDouble(query[15]);
  525. return ca;
  526. }
  527. /// <summary>
  528. /// 插入数据赛季分析表
  529. /// </summary>
  530. /// <param name="data"></param>
  531. /// <param name="Id"></param>
  532. /// <param name="Season"></param>
  533. public F_SeasonAnalysis InsertSeasonAnalysis_new(string data, string Id, string url, string Season)
  534. {
  535. // List<F_SeasonAnalysis> salist1 = salist;
  536. //if (salist1.Where(a => a.Id == Id).ToList().Count > 0)
  537. //return;
  538. var query = data.Split('|');
  539. try
  540. {
  541. F_SeasonAnalysis sa = new F_SeasonAnalysis();
  542. sa.Remark = url;
  543. sa.Id = CommonHelper.GetGuid().ToString();
  544. sa.CreateDateTime = DateTime.Now;
  545. sa.Season = Season;
  546. sa.TeamId = Id;
  547. sa.OldRanking = query[0].TryToInt32();
  548. sa.NowOldRanking = query[1].TryToInt32();
  549. sa.Win = query[2].TryToInt32();
  550. sa.Draw = query[3].TryToInt32();
  551. sa.Lose = query[4].TryToInt32();
  552. sa.Number = query[5].TryToInt32();
  553. //salist.Add(sa);
  554. return sa;
  555. }
  556. catch (Exception e)
  557. {
  558. return new F_SeasonAnalysis();
  559. }
  560. }
  561. #region 更新
  562. public void Getbjop_new(string url, F_Games game)
  563. {
  564. using (OddsJob c = new OddsJob())
  565. {
  566. c.UseLimitedResource(url, game);
  567. }
  568. }
  569. /// <summary>
  570. /// 插入数据欧赔固化数据
  571. /// </summary>
  572. /// <param name="data"></param>
  573. /// <param name="Id"></param>
  574. /// <param name="Season"></param>
  575. public op InsertOddsCuring_new2(string data, string Id, string url, DateTime date, string HomeTeamId, string VisitingTeamId, string HomeTeamName, string VisitingTeamName, string jsonall, DateTime lastdate)
  576. {
  577. try
  578. {
  579. op op = new op();
  580. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  581. F_OddsCuring oc = new F_OddsCuring();
  582. oc.Init_SOdd = Convert.ToDouble(query[2]);
  583. oc.Init_POdd = Convert.ToDouble(query[3]);
  584. oc.Init_FOdd = Convert.ToDouble(query[4]);
  585. oc.Newest_SOdd = Convert.ToDouble(query[5]);
  586. oc.Newest_POdd = Convert.ToDouble(query[6]);
  587. oc.Newest_FOdd = Convert.ToDouble(query[7]);
  588. oc.Probability_SOdd = Convert.ToDouble(query[9]);
  589. oc.Probability_POdd = Convert.ToDouble(query[10]);
  590. oc.Probability_FOdd = Convert.ToDouble(query[11]);
  591. oc.Kelly_SOdd = Convert.ToDouble(query[12]);
  592. oc.Kelly_POdd = Convert.ToDouble(query[13]);
  593. oc.Kelly_FOdd = Convert.ToDouble(query[14]);
  594. oc.Loss_Odd = Convert.ToDouble(query[15]);
  595. oc.BankerCompanyName = query[1];
  596. oc.BankerCompanyId = query[1];
  597. oc.Remark = url;
  598. oc.Id = CommonHelper.GetGuid().ToString();
  599. oc.CreateDateTime = DateTime.Now;
  600. oc.GameId = Id;
  601. oc.ChangeDateTime = Convert.ToDateTime(query[8]);
  602. oc.HomeTeamId = HomeTeamId;
  603. oc.HomeTeamName = HomeTeamName;
  604. oc.VisitingTeamId = VisitingTeamId;
  605. oc.VisitingTeamName = VisitingTeamName;
  606. op.odds = oc;
  607. F_Compensate ca = new F_Compensate();
  608. ca.BankerCompanyId = oc.BankerCompanyId;
  609. ca.ChangeDateTime = lastdate;
  610. ca.CompensateType = "20f77e31d96ae811ab3100ac6a4a134f";//概率 20f77e31d96ae811ab3100ac6a4a134f
  611. ca.CreateDateTime = DateTime.Now;
  612. ca.SOdd = Convert.ToDouble(query[9]);
  613. ca.POdd = Convert.ToDouble(query[10]);
  614. ca.FOdd = Convert.ToDouble(query[11]);
  615. ca.Remark = url;
  616. ca.Id = CommonHelper.GetGuid().ToString();
  617. ca.GameId = oc.GameId;
  618. op.oddsdetail.Add(ca);
  619. ca = new F_Compensate();
  620. ca.BankerCompanyId = oc.BankerCompanyId;
  621. ca.ChangeDateTime = lastdate;
  622. ca.CompensateType = "21f77e31d96ae811ab3100ac6a4a134f";//凯利指数 21f77e31d96ae811ab3100ac6a4a134f
  623. ca.CreateDateTime = DateTime.Now;
  624. ca.SOdd = Convert.ToDouble(query[12]);
  625. ca.POdd = Convert.ToDouble(query[13]);
  626. ca.FOdd = Convert.ToDouble(query[14]);
  627. ca.Remark = url;
  628. ca.Id = CommonHelper.GetGuid().ToString();
  629. ca.GameId = oc.GameId;
  630. op.oddsdetail.Add(ca);
  631. ca = new F_Compensate();
  632. ca.BankerCompanyId = oc.BankerCompanyId;
  633. ca.ChangeDateTime = lastdate;
  634. ca.CompensateType = "a1bfa33cd96ae811ab3100ac6a4a134f";//赔付率 a1bfa33cd96ae811ab3100ac6a4a134f
  635. ca.CreateDateTime = DateTime.Now;
  636. ca.SOdd = Convert.ToDouble(query[15]);
  637. ca.POdd = -1;
  638. ca.FOdd = -1;
  639. ca.Remark = url;
  640. ca.Id = CommonHelper.GetGuid().ToString();
  641. ca.GameId = oc.GameId;
  642. op.oddsdetail.Add(ca);
  643. ca = new F_Compensate();
  644. ca.BankerCompanyId = oc.BankerCompanyId;
  645. ca.ChangeDateTime = lastdate;
  646. ca.CompensateType = "a0bfa33cd96ae811ab3100ac6a4a134f";//即时赔率 a0bfa33cd96ae811ab3100ac6a4a134f
  647. ca.CreateDateTime = DateTime.Now;
  648. ca.SOdd = Convert.ToDouble(query[2]); ;
  649. ca.POdd = Convert.ToDouble(query[3]); ;
  650. ca.FOdd = Convert.ToDouble(query[4]); ;
  651. ca.Remark = "";
  652. ca.Id = CommonHelper.GetGuid().ToString();
  653. ca.GameId = oc.GameId;
  654. op.oddsdetail.Add(ca);
  655. var c_list=Getbjopdetail_new_json2(jsonall, oc.BankerCompanyName, lastdate, oc);
  656. op.oddsdetail.AddRange(c_list);
  657. return op;
  658. }
  659. catch (Exception e)
  660. {
  661. return new op();
  662. }
  663. }
  664. //欧赔详情
  665. public List<F_Compensate> Getbjopdetail_new_json2(string jsonurl, string BankerCompanyName, DateTime lastdate, F_OddsCuring oc)
  666. {
  667. List<F_Compensate> c_list = new List<F_Compensate>();
  668. var obj = JsonConvert.DeserializeObject<JObject>(jsonurl);
  669. var list = obj["company5List"];
  670. var objw = JsonConvert.DeserializeObject<List<company5List>>(list.ToString());
  671. var objw1 = objw.Where(a => a.attribute.name == BankerCompanyName).FirstOrDefault();
  672. if (objw1 == null)
  673. return new List<F_Compensate>();
  674. foreach (var item in objw1.c)
  675. {
  676. if (lastdate == item.attribute.wdate.TryToDateTime())
  677. continue;
  678. if (item.attribute.wdate.TryToDateTime() > Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")))
  679. {
  680. F_Compensate ca = new F_Compensate();
  681. ca.BankerCompanyId = oc.BankerCompanyId;
  682. ca.ChangeDateTime = Convert.ToDateTime(item.attribute.wdate.TryToDateTime());
  683. ca.CompensateType = "a0bfa33cd96ae811ab3100ac6a4a134f";//即时赔率 a0bfa33cd96ae811ab3100ac6a4a134f
  684. ca.CreateDateTime = DateTime.Now;
  685. ca.SOdd = Convert.ToDouble(item.attribute.win);
  686. ca.POdd = Convert.ToDouble(item.attribute.same);
  687. ca.FOdd = Convert.ToDouble(item.attribute.lost);
  688. ca.Remark = "";
  689. ca.Id = CommonHelper.GetGuid().ToString();
  690. ca.GameId = oc.GameId;
  691. c_list.Add(ca);
  692. }
  693. else
  694. {
  695. var s1 = item.attribute.wdate.TryToDateTime();
  696. var s2 = Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"));
  697. }
  698. }
  699. return c_list;
  700. }
  701. public class company5List
  702. {
  703. public company5List()
  704. {
  705. c = new List<sk>();
  706. }
  707. public Attribute attribute { get; set; }
  708. public List<sk> c { get; set; }
  709. }
  710. public class Attribute
  711. {
  712. public string name { get; set; }
  713. public string cid { get; set; }
  714. }
  715. public class sk
  716. {
  717. public sk2 attribute { get; set; }
  718. public string value { get; set; }
  719. }
  720. public class op
  721. {
  722. public op()
  723. {
  724. oddsdetail = new List<F_Compensate>();
  725. }
  726. public F_OddsCuring odds { get; set; }
  727. public List<F_Compensate> oddsdetail { get; set; }
  728. }
  729. public class sk2
  730. {
  731. public string lost { get; set; }
  732. public string lostch { get; set; }
  733. public string arq { get; set; }
  734. public string wdate { get; set; }
  735. public string win { get; set; }
  736. public string wdate1 { get; set; }
  737. public string same { get; set; }
  738. public string cid { get; set; }
  739. public string samech { get; set; }
  740. public string alost { get; set; }
  741. public string awin { get; set; }
  742. public string winch { get; set; }
  743. public string returnPer { get; set; }
  744. public string arq_num { get; set; }
  745. public string same_handicap { get; set; }
  746. }
  747. public void UseLimitedResource(string url, F_Games game)
  748. {
  749. try
  750. {
  751. List<F_SeasonAnalysis> sa_new = new List<F_SeasonAnalysis>();
  752. url = url.Replace(":80", "").Replace("ypdb", "bjop");
  753. string yurl = url;
  754. string jsonall = CommonHelper.GetHtmlString(url.Replace("fenxi.zgzcw.com", "fenxi.zgzcw.com/json"), "", 5 * 1000);
  755. var htmlResource = CommonHelper.GetHtmlString(url, "", 5 * 1000);
  756. HtmlDocument doc = new HtmlDocument();
  757. if (htmlResource == null)
  758. return;
  759. if (htmlResource == ConfigurationManager.AppSettings["HttpException"].ToString())
  760. return;
  761. doc.LoadHtml(htmlResource);
  762. //赔率集合
  763. HtmlNodeCollection bjopHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-02']/tr");
  764. if (bjopHtml == null)
  765. return;
  766. string HomeTeamName = "";
  767. HtmlNodeCollection homenameHtml = doc.DocumentNode.SelectNodes("//*[@class='host-name']/a");
  768. if (homenameHtml != null)
  769. {
  770. var q1 = teamlist.Where(a => a.Name == homenameHtml[0].InnerText.Trim()).FirstOrDefault();
  771. string data = "";
  772. if (q1 != null)
  773. {
  774. HomeTeamName = q1.Name;
  775. HtmlNodeCollection homepmHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-zd']");
  776. if (homepmHtml[0].InnerText.Trim().Contains("上赛季排名"))
  777. {
  778. data = "" + string.Join("|", homepmHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  779. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  780. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  781. }
  782. else
  783. {
  784. data = "" + homepmHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  785. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  786. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分", "");
  787. }
  788. var sa_sea=InsertSeasonAnalysis_new(data, q1.Id, url, game.Season);
  789. if (sa_sea != null)
  790. sa_new.Add(sa_sea);
  791. }
  792. }
  793. string VisitingTeamName = "";
  794. HtmlNodeCollection visitingnameHtml = doc.DocumentNode.SelectNodes("//*[@class='visit-name']/a");
  795. if (visitingnameHtml != null)
  796. {
  797. string data = "";
  798. var q2 = teamlist.Where(a => a.Name == visitingnameHtml[0].InnerText.Trim()).FirstOrDefault();
  799. if (q2 != null)
  800. {
  801. VisitingTeamName = q2.Name;
  802. HtmlNodeCollection homepmkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-kd']");
  803. if (homepmkHtml[0].InnerText.Trim().Contains("上赛季排名"))
  804. {
  805. data = "" + string.Join("|", homepmkHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  806. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  807. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("客队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  808. }
  809. else
  810. {
  811. data = "" + homepmkHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  812. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  813. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分", "");
  814. }
  815. var sa_sea = InsertSeasonAnalysis_new(data, q2.Id, url, game.Season);
  816. if (sa_sea != null)
  817. sa_new.Add(sa_sea);
  818. }
  819. }
  820. salist.AddRange(sa_new);
  821. List<string> listdetail = new List<string>();
  822. foreach (var item in bjopHtml)
  823. {
  824. HtmlDocument doc1 = new HtmlDocument();
  825. doc1.LoadHtml(item.InnerHtml);
  826. HtmlNodeCollection bjoptdHtml = doc1.DocumentNode.SelectNodes("//td");
  827. int i = 1;
  828. string shuju = "", nurl = "", lasttime = "";
  829. foreach (var item1 in bjoptdHtml)
  830. {
  831. if (i == 2)
  832. {
  833. // shuju += item1.InnerText.Trim()+"|";
  834. try
  835. {
  836. String SD = item1.InnerText.Trim() + "|" + item1.Attributes["data"].Value;
  837. Companylist.Add(SD);
  838. }
  839. catch (Exception e)
  840. {
  841. string aa = item1.InnerText.Trim(), ss = item1.Attributes["data"].Value;
  842. }
  843. }
  844. if (i == 6)
  845. {
  846. shuju += item1.InnerText.Trim() + "|";
  847. nurl = item1.SelectNodes("//a")[0].Attributes["href"].Value.Trim();
  848. }
  849. else if (i == 9)
  850. {
  851. shuju += item.Attributes["firsttime"].Value + "|";
  852. lasttime = item.Attributes["lasttime"].Value;
  853. }
  854. else
  855. {
  856. shuju += item1.InnerText.Trim() + "|";
  857. }
  858. i++;
  859. }
  860. DateTime lastdate = CommonHelper.ConvertIntToDateTime(lasttime);
  861. var op=InsertOddsCuring_new2(shuju, game.Id, nurl, game.StartDateTime.TryToDateTime(), game.HomeTeamId, game.VisitingTeamId, HomeTeamName, VisitingTeamName, jsonall, Convert.ToDateTime(lastdate));
  862. oclist.Add(op.odds);
  863. csalist.AddRange(op.oddsdetail);
  864. }
  865. //class="bf-tab-03"
  866. HtmlNodeCollection bjopfxHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-03']/tr");
  867. if (bjopfxHtml == null)
  868. return;
  869. foreach (var item in bjopfxHtml)
  870. {
  871. HtmlDocument doc1 = new HtmlDocument();
  872. doc1.LoadHtml(item.InnerHtml);
  873. HtmlNodeCollection bjopfxtdHtml = doc1.DocumentNode.SelectNodes("//td");
  874. if (bjopfxtdHtml.Count == 17)
  875. {
  876. string shuju = "";
  877. foreach (var item1 in bjopfxtdHtml)
  878. {
  879. shuju += item1.InnerText.Trim() + "|";
  880. }
  881. var ca_n=InsertCuringAnalysis_new(shuju, game.Id, url);
  882. calist.Add(ca_n);
  883. }
  884. }
  885. }
  886. catch (Exception e)
  887. {
  888. Trace.WriteLine("报错开始 开始:" + url);
  889. }
  890. }
  891. void IDisposable.Dispose()
  892. {
  893. // Console.WriteLine("我在释放");
  894. }
  895. #endregion
  896. }
  897. }