AsianDishJob.cs 70 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666
  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.ZCLotteryAsianDish
  17. {
  18. class AsianDishJob : CommonJob, IJob, IDisposable
  19. {
  20. public AsianDishJob()
  21. {
  22. logName = "AsianDishJob";
  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. private List<F_AsianDish> listDetailId = new List<F_AsianDish>();
  36. public void Click(List<F_Games> Gamelistq)
  37. {
  38. try
  39. {
  40. string Season = DateTime.Now.ToString("yyyy");
  41. teamlist = services.Query<F_Team>().ToList();
  42. int number = Gamelistq.Count;
  43. int page = number % 1000 == 0 ? number / 1000 : number / 1000 + 1;
  44. //要删除的
  45. //插入之前 获取要删除的旧数据的所有PK
  46. for (int i = 0; i < Gamelistq.Count; i++)
  47. {
  48. listGameId.Add(Gamelistq[i].Id);
  49. }
  50. if (Gamelistq.Count > 0)
  51. {
  52. var query1 = new List<F_AsianDish>();
  53. foreach (var item in Gamelistq)
  54. {
  55. try
  56. {
  57. query1.AddRange(services.Query<F_AsianDish>(" and (GameId = ('" +item.Id+ "')) ").Where(a=>a.ChangeDateTime> Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"))).ToList());
  58. }
  59. catch (Exception)
  60. {
  61. }
  62. try
  63. {
  64. query1.AddRange(services.Query<F_AsianDish>(" and (GameId = ('" + item.Id + "') and AsianDishStatus =('903f7b12da6ae811ab3100ac6a4a134f') )").ToList());
  65. }
  66. catch (Exception)
  67. {
  68. }
  69. try
  70. {
  71. query1.AddRange(services.Query<F_AsianDish>(" and (GameId = ('" + item.Id + "') and AsianDishStatus =('913f7b12da6ae811ab3100ac6a4a134f') )").ToList());
  72. }
  73. catch (Exception)
  74. {
  75. }
  76. }
  77. for (int i = 0; i < query1.Count; i++)
  78. {
  79. listDetailint.Add(query1[i].PK);
  80. }
  81. if (listDetailint.Count > 0)
  82. {
  83. var query2 = services.Query<F_AsianDishCuring>(" and GameId in ('" + string.Join("','", listGameId) + "')") == null ? new List<F_AsianDishCuring>() : services.Query<F_AsianDishCuring>(" and GameId in ('" + string.Join("','", listGameId) + "')").ToList();
  84. for (int i = 0; i < query2.Count; i++)
  85. {
  86. listCuringint.Add(query2[i].PK);
  87. }
  88. var query3 = services.Query<F_CuringAnalysis>(" and GameId in ('" + string.Join("','", listGameId) + "') and CuringType='c02e910a438ee811af5a2c4d54d3f5a9'") == null ? new List<F_CuringAnalysis>() : services.Query<F_CuringAnalysis>(" and GameId in ('" + string.Join("','", listGameId) + "') and CuringType='c02e910a438ee811af5a2c4d54d3f5a9'").ToList();
  89. for (int i = 0; i < query3.Count; i++)
  90. {
  91. listAnalysisint.Add(query3[i].PK);
  92. }
  93. }
  94. }
  95. for (int j = 0; j < page; j++)
  96. {
  97. Trace.WriteLine("第几个J 开始 AsianDishJob :" + (j + 1));
  98. threadCount = Gamelistq.Count;
  99. finishcount = 0;
  100. Gamelistq.ForEach(async p =>
  101. {
  102. await Task.Run(() =>
  103. {
  104. Getbjop_new(p.Remark, p);
  105. });
  106. lock (locker)
  107. {
  108. finishcount++;
  109. Monitor.Pulse(locker); //完成,通知等待队列,告知已完,执行下一个。
  110. }
  111. });
  112. lock (locker)
  113. {
  114. while (finishcount != threadCount)
  115. {
  116. Thread.Sleep(5000);
  117. Monitor.Wait(locker);//等待
  118. }
  119. }
  120. Companylist = Companylist.Distinct().ToList();
  121. InsertBankerCompany(Companylist);
  122. InsertBankerCompany1();
  123. {
  124. List<F_SeasonAnalysis> teamSeasonAnalysislist = new List<F_SeasonAnalysis>();
  125. try
  126. {
  127. teamSeasonAnalysislist = services.Query<F_SeasonAnalysis>().ToList();
  128. }
  129. catch (Exception e)
  130. {
  131. }
  132. salist = salist.Distinct().ToList();
  133. salist = salist.Where((x, i) => salist.FindIndex(z => z.TeamId == x.TeamId) == i).ToList();//Lambda表达式去重
  134. List<F_SeasonAnalysis> salist2 = new List<F_SeasonAnalysis>();
  135. foreach (var item in salist)
  136. {
  137. if (teamSeasonAnalysislist.Where(a => a.TeamId == item.TeamId).ToList().Count == 0)
  138. salist2.Add(item);
  139. }
  140. Trace.WriteLine("插入赛季分析数据 开始:" + salist2.Count);
  141. if (salist2.Count != 0)
  142. services.SqlBulkCopyAdd(salist2);
  143. }
  144. var listbk = services.Query<BankerCompany>().ToList();
  145. Thread.Sleep(1000);
  146. oclist = oclist.Where(a => a != null).ToList();
  147. foreach (var item in oclist)
  148. {
  149. F_AsianDishCuring oc_new = new F_AsianDishCuring();
  150. if (item != null)
  151. {
  152. oc_new = item;
  153. var listbkdetail = listbk.Where(a => a.Name == item.BankerCompanyId).FirstOrDefault();
  154. oc_new.BankerCompanyId = listbkdetail==null ? "" : listbkdetail.Id;
  155. lock (oclist_new)
  156. {
  157. oclist_new.Add(oc_new);
  158. }
  159. }
  160. }
  161. Thread.Sleep(1000);
  162. csalist = csalist.Where(a => a != null).ToList();
  163. foreach (var item in csalist)
  164. {
  165. F_AsianDish cp = new F_AsianDish();
  166. cp = item;
  167. lock (listbk)
  168. {
  169. var listbkdetail = listbk.Where(a => a.Name == item.BankerCompanyId).FirstOrDefault();
  170. cp.BankerCompanyId = listbkdetail == null ? "" : listbkdetail.Id;
  171. }
  172. lock (oclist_new)
  173. {
  174. csalist_new.Add(cp);
  175. }
  176. }
  177. }
  178. {
  179. calist = calist.Where((x, i) => calist.FindIndex(z => z.GameId == x.GameId && z.CuringAnalysisType == x.CuringAnalysisType) == i).ToList();//Lambda表达式去重
  180. Trace.WriteLine("插入亚盘固化数据 开始:" + oclist_new.Count);
  181. if (oclist_new.Count > 0)
  182. services.SqlBulkCopyAdd(oclist_new);
  183. Trace.WriteLine("插入固化分析数据 开始:" + calist.Count);
  184. if (calist.Count > 0)
  185. services.SqlBulkCopyAdd(calist);
  186. var list_com = new List<F_AsianDish>();
  187. foreach (var item in Gamelistq)
  188. {
  189. var count = listDetailId.Where(a => a.GameId == item.Id).ToList().Count;
  190. var count_new = csalist_new.Where(a => a.GameId == item.Id).ToList().Count;
  191. if (count_new == 0 && count == 0)
  192. continue;
  193. if (count < count_new)
  194. {
  195. list_com.AddRange(csalist_new.Where(a => a.GameId == item.Id).ToList());
  196. }
  197. else
  198. {
  199. List<F_AsianDish> intlist = new List<F_AsianDish>();
  200. foreach (var item3 in listDetailId.Where(a => a.GameId == item.Id).ToList())
  201. {
  202. var items = item3;
  203. items.PK = 0;
  204. intlist.Add(items);
  205. }
  206. list_com.AddRange(intlist);
  207. }
  208. }
  209. Trace.WriteLine("插入亚盘详情数据 开始:" + list_com.Count);
  210. if (csalist_new.Count > 0)
  211. services.SqlBulkCopyAdd(list_com);
  212. urllist = new List<string>();
  213. urllist1 = new List<string>();
  214. Companylist = new List<string>();//所有公司
  215. bclist = new List<BankerCompany>();
  216. bcrlist = new List<BankerCompanyRelation>();
  217. calist = new List<F_CuringAnalysis>();
  218. salist = new List<F_SeasonAnalysis>();
  219. oclist = new List<F_AsianDishCuring>();
  220. oclist_new = new List<F_AsianDishCuring>();
  221. csalist = new List<F_AsianDish>();
  222. csalist_new = new List<F_AsianDish>();
  223. }
  224. Trace.WriteLine("删除数据 F_CuringAnalysis 开始:" + listAnalysisint.Count);
  225. if (listAnalysisint.Count > 0)
  226. services.Delete<F_CuringAnalysis>(" and PK in (" + string.Join(",", listAnalysisint) + ")");
  227. Trace.WriteLine("删除数据 F_CuringAnalysis 结束:" + listAnalysisint.Count);
  228. Trace.WriteLine("删除数据 F_AsianDish 初始数据 开始:" + listDetailint.Count);
  229. if (listDetailint.Count > 0)
  230. {
  231. if (listDetailint.Count > 1000)
  232. {
  233. int pages = listDetailint.Count % 1000 == 0 ? listDetailint.Count / 1000 : listDetailint.Count / 1000 + 1;
  234. for (int i = 0; i < pages; i++)
  235. {
  236. var listDetailint1 = listDetailint.Skip(i * 1000).Take(1000).ToList();
  237. services.Delete<F_AsianDish>(" and PK in (" + string.Join(",", listDetailint1) + ")");
  238. Trace.WriteLine("删除数据 F_AsianDish 结束中:" + listDetailint1.Count);
  239. }
  240. }
  241. else
  242. {
  243. services.Delete<F_AsianDish>(" and PK in (" + string.Join(",", listDetailint) + ")");
  244. }
  245. }
  246. Trace.WriteLine("删除数据 F_AsianDish 初始数据 结束:" + listDetailint.Count);
  247. Trace.WriteLine("删除数据 F_AsianDishCuring 开始:" + listCuringint.Count);
  248. if (listCuringint.Count > 0)
  249. services.Delete<F_AsianDishCuring>(" and PK in (" + string.Join(",", listCuringint) + ")");
  250. Trace.WriteLine("删除数据 F_AsianDishCuring 结束:" + listCuringint.Count);
  251. Gamelistq = new List<F_Games>();
  252. teamlist = new List<F_Team>();
  253. }
  254. catch (Exception e)
  255. {
  256. CommonHelper.LogBD(e.Message, logName);
  257. CommonHelper.LogBD(e.Source, logName);
  258. CommonHelper.LogBD(e.StackTrace, logName);
  259. Thread.Sleep(1000 * 60 * 5);
  260. urllist = new List<string>();
  261. urllist1 = new List<string>();
  262. Companylist = new List<string>();//所有公司
  263. bclist = new List<BankerCompany>();
  264. bcrlist = new List<BankerCompanyRelation>();
  265. calist = new List<F_CuringAnalysis>();
  266. salist = new List<F_SeasonAnalysis>();
  267. oclist = new List<F_AsianDishCuring>();
  268. oclist_new = new List<F_AsianDishCuring>();
  269. csalist = new List<F_AsianDish>();
  270. csalist_new = new List<F_AsianDish>();
  271. Click(Gamelistq);
  272. }
  273. }
  274. public void DoMainUrl()
  275. {
  276. List<F_Games> Gamelistq = new List<F_Games>();
  277. teamlist = services.Query<F_Team>().ToList();
  278. Gamelistq = services.Query<F_Games>().ToList();
  279. int number = Gamelistq.Count;
  280. int page = number % 100 == 0 ? number / 100 : number / 100 + 1;
  281. ThreadPool.SetMinThreads(1, 1);
  282. ThreadPool.SetMaxThreads(300, 300);
  283. for (int j = 788; j < page; j++)
  284. {
  285. Trace.WriteLine("第几个J 开始:" + (j + 1));
  286. Gamelistq = Gamelistq.Skip(j * 100).Take(100).ToList();
  287. Gamelistq.ForEach(p =>
  288. {
  289. Task.Run(() =>
  290. {
  291. Trace.WriteLine("亚盘分析 开始:" + Gamelistq.IndexOf(p));
  292. Getbjop(p.Remark, p);
  293. });
  294. });
  295. while (true)
  296. {
  297. if (CommonHelper.ThreadsFinsh())
  298. break;
  299. }
  300. Companylist = Companylist.Distinct().ToList();
  301. InsertBankerCompany(Companylist);
  302. InsertBankerCompany1();
  303. {
  304. List<F_SeasonAnalysis> teamlist = new List<F_SeasonAnalysis>();
  305. try
  306. {
  307. teamlist = services.Query<F_SeasonAnalysis>().ToList();
  308. }
  309. catch (Exception e)
  310. {
  311. }
  312. salist = salist.Distinct().ToList();
  313. List<F_SeasonAnalysis> salist1 = salist.Where((x, i) => salist.FindIndex(z => z.TeamId == x.TeamId) == i).ToList();//Lambda表达式去重
  314. List<F_SeasonAnalysis> salist2 = new List<F_SeasonAnalysis>();
  315. foreach (var item in salist1)
  316. {
  317. if (teamlist.Where(a => a.TeamId == item.TeamId).ToList().Count == 0)
  318. salist2.Add(item);
  319. }
  320. Trace.WriteLine("插入赛季分析数据 开始:" + salist2.Count);
  321. if (salist2.Count != 0)
  322. services.SqlBulkCopyAdd(salist2);
  323. }
  324. var listbk = services.Query<BankerCompany>().ToList();
  325. try
  326. {
  327. //oclist.ForEach(p =>
  328. //{
  329. // Task.Run(() =>
  330. // {
  331. // try
  332. // {
  333. // Trace.WriteLine("更换公司Id:");
  334. // F_AsianDishCuring oc_new = new F_AsianDishCuring();
  335. // if (p != null)
  336. // {
  337. // oc_new = p;
  338. // oc_new.BankerCompanyId = listbk.Where(a => a.Name == p.BankerCompanyId).FirstOrDefault().Id;
  339. // // Getbjop(p.Remark, p);
  340. // oclist_new.Add(oc_new);
  341. // }
  342. // }
  343. // catch (Exception e)
  344. // {
  345. // }
  346. // });
  347. //});
  348. Task[] processors = new Task[oclist.Count];
  349. for (int i = 0; i < oclist.Count; i++)
  350. {
  351. int processId = i;
  352. processors[i] = Task.Run(
  353. () => {
  354. try
  355. {
  356. Trace.WriteLine("更换公司Id:");
  357. F_AsianDishCuring oc_new = new F_AsianDishCuring();
  358. if (oclist[processId] != null)
  359. {
  360. oc_new = oclist[processId];
  361. oc_new.BankerCompanyId = listbk.Where(a => a.Name == oclist[processId].BankerCompanyId).FirstOrDefault().Id;
  362. // Getbjop(p.Remark, p);
  363. oclist_new.Add(oc_new);
  364. }
  365. }
  366. catch (Exception e)
  367. {
  368. }
  369. }
  370. );
  371. }
  372. }
  373. catch (Exception r)
  374. {
  375. }
  376. while (true)
  377. {
  378. if (CommonHelper.ThreadsFinsh())
  379. break;
  380. }
  381. csalist.ForEach(p =>
  382. {
  383. Task.Run(() =>
  384. {
  385. if (p != null)
  386. {
  387. lock (csalist)
  388. {
  389. Trace.WriteLine("更换公司Id:" + csalist.IndexOf(p));
  390. F_AsianDish cp = new F_AsianDish();
  391. cp = p;
  392. cp.BankerCompanyId = listbk.Where(a => a.Name == p.BankerCompanyId).FirstOrDefault().Id;
  393. // Getbjop(p.Remark, p);
  394. csalist_new.Add(cp);
  395. }
  396. }
  397. });
  398. });
  399. while (true)
  400. {
  401. if (CommonHelper.ThreadsFinsh())
  402. break;
  403. }
  404. List<F_CuringAnalysis> calist1 = calist.Where((x, i) => calist.FindIndex(z => z.GameId == x.GameId && z.CuringAnalysisType == x.CuringAnalysisType) == i).ToList();//Lambda表达式去重
  405. Trace.WriteLine("插入亚盘固化数据 开始:" + oclist_new.Count);
  406. if (oclist_new.Count > 0)
  407. services.SqlBulkCopyAdd(oclist_new);
  408. Trace.WriteLine("插入亚盘详情数据 开始:" + csalist_new.Count);
  409. if (csalist_new.Count > 0)
  410. services.SqlBulkCopyAdd(csalist_new);
  411. Trace.WriteLine("插入固化分析数据 开始:" + calist1.Count);
  412. if (calist1.Count > 0)
  413. services.SqlBulkCopyAdd(calist1);
  414. urllist = new List<string>();
  415. urllist1 = new List<string>();
  416. Companylist = new List<string>();//所有公司
  417. bclist = new List<BankerCompany>();
  418. bcrlist = new List<BankerCompanyRelation>();
  419. calist = new List<F_CuringAnalysis>();
  420. salist = new List<F_SeasonAnalysis>();
  421. oclist = new List<F_AsianDishCuring>();
  422. oclist_new = new List<F_AsianDishCuring>();
  423. csalist = new List<F_AsianDish>();
  424. csalist_new = new List<F_AsianDish>();
  425. }
  426. }
  427. public List<string> urllist = new List<string>();
  428. public List<string> urllist1 = new List<string>();
  429. public List<string> Companylist = new List<string>();//所有公司
  430. public List<BankerCompany> bclist = new List<BankerCompany>();
  431. public List<BankerCompanyRelation> bcrlist = new List<BankerCompanyRelation>();
  432. public static List<F_CuringAnalysis> calist = new List<F_CuringAnalysis>();
  433. public List<F_Team> teamlist = new List<F_Team>();
  434. //public static List<F_Games> Gamelist = new List<F_Games>();
  435. public static List<F_SeasonAnalysis> salist = new List<F_SeasonAnalysis>();
  436. public static List<F_AsianDishCuring> oclist = new List<F_AsianDishCuring>();
  437. public List<F_AsianDishCuring> oclist_new = new List<F_AsianDishCuring>();
  438. public static List<F_AsianDish> csalist = new List<F_AsianDish>();
  439. //public static List<F_Games> Gamelistq = new List<F_Games>();
  440. public List<F_AsianDish> csalist_new = new List<F_AsianDish>();
  441. public void Getbjop(string url, F_Games game)
  442. {
  443. url = url.Replace(":80", "").Replace("ypdb", "ypdb");
  444. //class="bf-tab-02"
  445. // Trace.WriteLine("亚盘分析 开始:" + url);
  446. string yurl = url;
  447. ;
  448. var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8"));
  449. HtmlDocument doc = new HtmlDocument();
  450. if (htmlResource == null)
  451. return;
  452. if (htmlResource.Contains("lg123456"))
  453. {
  454. urllist.Add(url + "|" + game.Id);
  455. return;
  456. }
  457. if (htmlResource.Contains("403 Forbidden"))
  458. {
  459. urllist.Add(url + "|" + game.Id);
  460. return;
  461. }
  462. doc.LoadHtml(htmlResource);
  463. //赔率集合
  464. HtmlNodeCollection bjopHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-02']/tr");
  465. if (bjopHtml == null)
  466. return;
  467. HtmlNodeCollection homenameHtml = doc.DocumentNode.SelectNodes("//*[@class='host-name']/a");
  468. var q1 = teamlist.Where(a => a.Name == homenameHtml[0].InnerText.Trim()).FirstOrDefault();
  469. string HomeTeamName = "";
  470. string data = "";
  471. if (q1 != null)
  472. {
  473. HomeTeamName = q1.Name;
  474. HtmlNodeCollection homepmHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-zd']");
  475. if (homepmHtml[0].InnerText.Trim().Contains("上赛季排名"))
  476. {
  477. data = "" + string.Join("|", homepmHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  478. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  479. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  480. }
  481. else {
  482. data = "" + homepmHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  483. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  484. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分","");
  485. }
  486. InsertSeasonAnalysis(data, q1.Id, url, game.Season);
  487. }
  488. HtmlNodeCollection visitingnameHtml = doc.DocumentNode.SelectNodes("//*[@class='visit-name']/a");
  489. var q2 = teamlist.Where(a => a.Name == visitingnameHtml[0].InnerText.Trim()).FirstOrDefault();
  490. string VisitingTeamName = "";
  491. if (q2 != null)
  492. {
  493. VisitingTeamName = q2.Name;
  494. HtmlNodeCollection homepmkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-kd']");
  495. if (homepmkHtml[0].InnerText.Trim().Contains("上赛季排名"))
  496. {
  497. data = "" + string.Join("|", homepmkHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  498. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  499. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("客队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  500. }
  501. else {
  502. data = "" + homepmkHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  503. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  504. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分", "");
  505. }
  506. InsertSeasonAnalysis(data, q2.Id, url, game.Season);
  507. }
  508. List<string> listdetail = new List<string>();
  509. foreach (var item in bjopHtml)
  510. {
  511. HtmlDocument doc1 = new HtmlDocument();
  512. doc1.LoadHtml(item.InnerHtml);
  513. HtmlNodeCollection bjoptdHtml = doc1.DocumentNode.SelectNodes("//td");
  514. int i = 1;
  515. string shuju = "", nurl = "";
  516. foreach (var item1 in bjoptdHtml)
  517. {
  518. if (i == 2)
  519. {
  520. // shuju += item1.InnerText.Trim()+"|";
  521. Companylist.Add(item1.InnerText.Trim() + "|" + item1.Attributes["data"].Value);
  522. // Companylist = Companylist.Distinct().ToList();
  523. // InsertBankerCompany();
  524. }
  525. if (i == 6)
  526. {
  527. shuju += item1.InnerText.Trim() + "|";
  528. nurl = item1.SelectNodes("//a")[0].Attributes["href"].Value.Trim();
  529. }
  530. else if (i == 9)
  531. {
  532. HtmlDocument doc2 = new HtmlDocument();
  533. doc2.LoadHtml(item1.InnerHtml);
  534. HtmlNodeCollection timehtml = doc2.DocumentNode.SelectNodes("//em");
  535. shuju += item.Attributes["firsttime"].Value + "|";
  536. }
  537. else
  538. {
  539. shuju += item1.InnerText.Trim() + "|";
  540. }
  541. i++;
  542. }
  543. listdetail.Add(shuju + "@" + nurl);
  544. }
  545. listdetail.ForEach(p =>
  546. {
  547. Task.Run(() =>
  548. {
  549. try
  550. {
  551. var lis = p.Split('@')[0];
  552. //Trace.WriteLine("亚盘分析多线程 开始:" + listdetail.IndexOf(p));
  553. InsertOddsCuring(p.Split('@')[0], game.Id, p.Split('@')[1], game.StartDateTime.TryToDateTime(), game.HomeTeamId, game.VisitingTeamId, HomeTeamName, VisitingTeamName);
  554. }
  555. catch (Exception e)
  556. {
  557. Trace.WriteLine("亚盘分析多线程 报错:" + listdetail.IndexOf(p));
  558. }
  559. });
  560. });
  561. //class="bf-tab-03"
  562. HtmlNodeCollection bjopfxHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-03']/tr");
  563. foreach (var item in bjopfxHtml)
  564. {
  565. HtmlDocument doc1 = new HtmlDocument();
  566. doc1.LoadHtml(item.InnerHtml);
  567. HtmlNodeCollection bjopfxtdHtml = doc1.DocumentNode.SelectNodes("//td");
  568. if (bjopfxtdHtml.Count == 15)
  569. {
  570. string shuju = "";
  571. foreach (var item1 in bjopfxtdHtml)
  572. {
  573. shuju += item1.InnerText.Trim() + "|";
  574. }
  575. InsertCuringAnalysis(shuju, game.Id, url);
  576. }
  577. }
  578. }
  579. public void Getbjopdetail(string url, F_AsianDishCuring oc,string date)
  580. {
  581. try
  582. {
  583. //插入初始
  584. InsertCompensate_start(oc,date);
  585. //Trace.WriteLine("亚盘所有分析获取 开始:" + "http://fenxi.zgzcw.com" + url);
  586. string yurl = url;
  587. if (!url.Contains("http://fenxi.zgzcw.com"))
  588. url = "http://fenxi.zgzcw.com" + url.Replace(":80", "");
  589. var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8"));
  590. HtmlDocument doc = new HtmlDocument();
  591. if (htmlResource == null)
  592. return;
  593. if (htmlResource.Contains("lg123456"))
  594. {
  595. urllist1.Add(url + "|" + oc.Id);
  596. return;
  597. }
  598. if (htmlResource.Contains("403 Forbidden"))
  599. {
  600. urllist1.Add(url + "|" + oc.Id);
  601. return;
  602. }
  603. doc.LoadHtml(htmlResource);
  604. HtmlNodeCollection detailHtml = doc.DocumentNode.SelectNodes("//*[@class='dxzkt-tab']/tr");
  605. if (detailHtml == null)
  606. return;
  607. int i = 0;
  608. foreach (var item in detailHtml)
  609. {
  610. if (i > 10)
  611. return;
  612. HtmlDocument doc1 = new HtmlDocument();
  613. doc1.LoadHtml(item.InnerHtml);
  614. HtmlNodeCollection bjopfxtdHtml = doc1.DocumentNode.SelectNodes("//td");
  615. if (bjopfxtdHtml != null)
  616. {
  617. if (bjopfxtdHtml.Count == 11)
  618. {
  619. string shuju = "";
  620. foreach (var item1 in bjopfxtdHtml)
  621. {
  622. shuju += item1.InnerText.Trim() + "|";
  623. }
  624. InsertCompensate(shuju, oc, url);
  625. }
  626. }
  627. i++;
  628. }
  629. }
  630. catch (Exception e)
  631. {
  632. Trace.WriteLine("报错开始 开始:" + "http://fenxi.zgzcw.com" + url);
  633. //Getbjopdetail(url, oc);
  634. }
  635. }
  636. /// <summary>
  637. /// 插入数据公司
  638. /// </summary>
  639. /// <param name="data"></param>
  640. /// <param name="Id"></param>
  641. /// <param name="Season"></param>
  642. public void InsertBankerCompany(List<string> Companylist)
  643. {
  644. List<BankerCompany> listbk = new List<BankerCompany>();
  645. try
  646. {
  647. listbk = services.Query<BankerCompany>().ToList();
  648. }
  649. catch (Exception e)
  650. {
  651. }
  652. foreach (var item in Companylist)
  653. {
  654. var query = item.Split('|');
  655. if (listbk.Where(a => a.Name == query[0]).ToList().Count > 0)
  656. continue;
  657. BankerCompany bc = new BankerCompany();
  658. bc.CreateDateTime = DateTime.Now;
  659. bc.Id = CommonHelper.GetGuid().ToString();
  660. bc.Name = query[0];
  661. bclist.Add(bc);
  662. }
  663. List<BankerCompany> bclist1 = bclist.Where((x, i) => bclist.FindIndex(z => z.Name == x.Name) == i).ToList();//Lambda表达式去重
  664. Trace.WriteLine("插入公司数据 开始:" + bclist1.Count);
  665. if (bclist1.Count != 0)
  666. services.SqlBulkCopyAdd(bclist1);
  667. }
  668. public void InsertBankerCompany1()
  669. {
  670. List<BankerCompany> listbk = new List<BankerCompany>();
  671. List<BankerCompanyRelation> listbkrs = new List<BankerCompanyRelation>();
  672. try
  673. {
  674. listbk = services.Query<BankerCompany>().ToList();
  675. listbkrs = services.Query<BankerCompanyRelation>().ToList();
  676. }
  677. catch (Exception e)
  678. {
  679. }
  680. foreach (var item in Companylist)
  681. {
  682. if (item.IsEmpty())
  683. continue;
  684. var query = item.Split('|');
  685. // bclist1
  686. if (listbk.Where(a => a.Name == query[0]).ToList().Count > 0)
  687. {
  688. var query2 = query[1].Split(',');
  689. foreach (var item1 in query2)
  690. {
  691. if (item.IsEmpty())
  692. continue;
  693. // if (!item1.Trim().IsEmpty())
  694. {
  695. BankerCompanyRelation bcr = new BankerCompanyRelation();
  696. bcr.BankerCompanyId = listbk.Where(a => a.Name == query[0]).FirstOrDefault().Id;
  697. bcr.BankerCompanyType = a4;
  698. bcr.Remark = "";
  699. bcr.Id = CommonHelper.GetGuid().ToString();
  700. bcr.CreateDateTime = DateTime.Now;
  701. if (listbkrs.Where(a => a.BankerCompanyType == bcr.BankerCompanyType && a.BankerCompanyId == bcr.BankerCompanyId).ToList().Count == 0)
  702. {
  703. bcrlist.Add(bcr);
  704. }
  705. }
  706. }
  707. }
  708. }
  709. Trace.WriteLine("插入公司分类数据 开始:" + bcrlist.Count);
  710. if (bcrlist.Count != 0)
  711. services.SqlBulkCopyAdd(bcrlist);
  712. }
  713. public static string a1 = "c06f47ca4f8ee811af5a2c4d54d3f5a9", a2 = "00ae03d14f8ee811af5a2c4d54d3f5a9", a3 = "30d122dc4f8ee811af5a2c4d54d3f5a9", a4 = "f08de6e64f8ee811af5a2c4d54d3f5a9", a5 = "904f40ef4f8ee811af5a2c4d54d3f5a9";
  714. //百家亚盘 c06f47ca4f8ee811af5a2c4d54d3f5a9
  715. //主流公司 00ae03d14f8ee811af5a2c4d54d3f5a9 0
  716. //交易公司 30d122dc4f8ee811af5a2c4d54d3f5a9 1
  717. //亚洲公司 f08de6e64f8ee811af5a2c4d54d3f5a9 2
  718. //普通公司 904f40ef4f8ee811af5a2c4d54d3f5a9 5
  719. /// <summary>
  720. /// 插入数据亚盘数据
  721. /// </summary>
  722. /// <param name="data"></param>
  723. /// <param name="Id"></param>
  724. /// <param name="Season"></param>
  725. public void InsertCompensate(string data, F_AsianDishCuring oc, string url)
  726. {
  727. try
  728. {
  729. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  730. F_AsianDish ca = new F_AsianDish();
  731. ca.BankerCompanyId = oc.BankerCompanyId;
  732. ca.ChangeDateTime = Convert.ToDateTime(query[1]);
  733. ca.AsianDishStatus = "913f7b12da6ae811ab3100ac6a4a134f";//及时盘口赔率 913f7b12da6ae811ab3100ac6a4a134f
  734. ca.CreateDateTime = DateTime.Now;
  735. ca.SOdd = Convert.ToDouble(query[3]);
  736. ca.POdd = -1;
  737. ca.Disc = Convert.ToString(query[4]) == null ? "" : Convert.ToString(query[4]);
  738. ca.FOdd = Convert.ToDouble(query[5]);
  739. ca.Remark = url;
  740. ca.Id = CommonHelper.GetGuid().ToString();
  741. ca.GameId = oc.GameId;
  742. csalist.Add(ca);
  743. }
  744. catch (Exception e)
  745. {
  746. }
  747. }
  748. /// <summary>
  749. /// 插入数据亚盘数据-初始
  750. /// </summary>
  751. /// <param name="data"></param>
  752. /// <param name="Id"></param>
  753. /// <param name="Season"></param>
  754. public void InsertCompensate_start(F_AsianDishCuring oc,string date)
  755. {
  756. try
  757. {
  758. F_AsianDish ca = new F_AsianDish();
  759. ca.BankerCompanyId = oc.BankerCompanyId;
  760. try
  761. {
  762. ca.ChangeDateTime = Convert.ToDateTime(date);
  763. }
  764. catch (Exception e)
  765. {
  766. ca.ChangeDateTime = Convert.ToDateTime("1999-01-01 00:01");
  767. }
  768. ca.AsianDishStatus = "903f7b12da6ae811ab3100ac6a4a134f";//初始盘口赔率 903f7b12da6ae811ab3100ac6a4a134f
  769. ca.CreateDateTime = DateTime.Now;
  770. ca.SOdd = Convert.ToDouble(oc.Init_SOdd);
  771. ca.POdd = -1;
  772. ca.Disc = oc.Init_DiscName;
  773. ca.FOdd = Convert.ToDouble(oc.Init_FOdd);
  774. ca.Remark = "";
  775. ca.Id = CommonHelper.GetGuid().ToString();
  776. ca.GameId = oc.GameId;
  777. csalist.Add(ca);
  778. }
  779. catch (Exception e)
  780. {
  781. }
  782. }
  783. /// <summary>
  784. /// 插入数据亚盘固化数据
  785. /// </summary>
  786. /// <param name="data"></param>
  787. /// <param name="Id"></param>
  788. /// <param name="Season"></param>
  789. public void InsertOddsCuring(string data, string Id, string url, DateTime date, string HomeTeamId, string VisitingTeamId, string HomeTeamName, string VisitingTeamName)
  790. {
  791. try
  792. {
  793. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  794. F_AsianDishCuring oc = new F_AsianDishCuring();
  795. oc.Init_SOdd = Convert.ToDouble(query[2]);
  796. oc.Init_DiscName = query[3];
  797. oc.Init_FOdd = Convert.ToDouble(query[4]);
  798. oc.Newest_SOdd = Convert.ToDouble(query[5]);
  799. oc.Newest_DiscName = query[6];
  800. oc.Newest_FOdd = Convert.ToDouble(query[7]);
  801. oc.Probability_SOdd = Convert.ToDouble(query[9]);
  802. oc.Probability_FOdd = Convert.ToDouble(query[10]);
  803. oc.Kelly_SOdd = Convert.ToDouble(query[11]);
  804. oc.Kelly_FOdd = Convert.ToDouble(query[12]);
  805. oc.Loss_Odd = Convert.ToDouble(query[13]);
  806. oc.BankerCompanyName = query[1];
  807. oc.BankerCompanyId = query[1];
  808. oc.Remark = url;
  809. oc.Id = CommonHelper.GetGuid().ToString();
  810. oc.CreateDateTime = DateTime.Now;
  811. oc.GameId = Id;
  812. try
  813. {
  814. oc.ChangeDateTime = Convert.ToDateTime(query[8]);
  815. }
  816. catch (Exception e)
  817. {
  818. oc.ChangeDateTime = DateTime.Now;
  819. }
  820. oc.HomeTeamId = HomeTeamId;
  821. oc.HomeTeamName = HomeTeamName;
  822. oc.VisitingTeamId = VisitingTeamId;
  823. oc.VisitingTeamName = VisitingTeamName;
  824. oclist.Add(oc);
  825. Getbjopdetail(url, oc,query[8]);
  826. }
  827. catch (Exception s)
  828. {
  829. }
  830. }
  831. public DateTime GetDate(string time, DateTime date)
  832. {
  833. time = time.Replace("更新时间:赛前", "").Replace("时", "|").Replace("分", "").Trim();
  834. var query = time.Split('|');
  835. if (query.Length == 1)
  836. date.AddMinutes(Convert.ToInt32(query[0]));
  837. if (query.Length == 2)
  838. date.AddMinutes(Convert.ToInt32(query[1])).AddHours(Convert.ToInt32(query[0]));
  839. return date;
  840. }
  841. /// <summary>
  842. /// 插入数据亚盘固化分析数据
  843. /// </summary>
  844. /// <param name="data"></param>
  845. /// <param name="Id"></param>
  846. /// <param name="Season"></param>
  847. public void InsertCuringAnalysis(string data, string Id, string url)
  848. {
  849. try
  850. {
  851. var query = data.Split('|');
  852. F_CuringAnalysis ca = new F_CuringAnalysis();
  853. ca.Remark = url;
  854. ca.Id = CommonHelper.GetGuid().ToString();
  855. ca.CreateDateTime = DateTime.Now;
  856. ca.CuringType = "c02e910a438ee811af5a2c4d54d3f5a9";
  857. if (query[1] == "平均值")
  858. ca.CuringAnalysisType = b1;
  859. if (query[1] == "最大值")
  860. ca.CuringAnalysisType = b2;
  861. if (query[1] == "最小值")
  862. ca.CuringAnalysisType = b3;
  863. ca.GameId = Id;
  864. ca.Init_SOdd = Convert.ToDouble(query[2]);
  865. ca.Init_POdd = -1;
  866. ca.Init_FOdd = Convert.ToDouble(query[4]);
  867. ca.Newest_SOdd = Convert.ToDouble(query[5]);
  868. ca.Newest_POdd = -1;
  869. ca.Newest_FOdd = Convert.ToDouble(query[7]);
  870. ca.Probability_SOdd = Convert.ToDouble(query[9]);
  871. ca.Probability_POdd = -1;
  872. ca.Probability_FOdd = Convert.ToDouble(query[10]);
  873. ca.Kelly_SOdd = Convert.ToDouble(query[11]);
  874. ca.Kelly_POdd = -1;
  875. ca.Kelly_FOdd = Convert.ToDouble(query[12]);
  876. ca.Loss_Odd = -1;
  877. calist.Add(ca);
  878. }
  879. catch (Exception e)
  880. {
  881. }
  882. }
  883. /// <summary>
  884. /// 插入数据亚盘固化分析数据
  885. /// </summary>
  886. /// <param name="data"></param>
  887. /// <param name="Id"></param>
  888. /// <param name="Season"></param>
  889. public F_CuringAnalysis InsertCuringAnalysis2(string data, string Id, string url)
  890. {
  891. try
  892. {
  893. var query = data.Split('|');
  894. F_CuringAnalysis ca = new F_CuringAnalysis();
  895. ca.Remark = url;
  896. ca.Id = CommonHelper.GetGuid().ToString();
  897. ca.CreateDateTime = DateTime.Now;
  898. ca.CuringType = "c02e910a438ee811af5a2c4d54d3f5a9";
  899. if (query[1] == "平均值")
  900. ca.CuringAnalysisType = b1;
  901. if (query[1] == "最大值")
  902. ca.CuringAnalysisType = b2;
  903. if (query[1] == "最小值")
  904. ca.CuringAnalysisType = b3;
  905. ca.GameId = Id;
  906. ca.Init_SOdd = Convert.ToDouble(query[2]);
  907. ca.Init_POdd = -1;
  908. ca.Init_FOdd = Convert.ToDouble(query[4]);
  909. ca.Newest_SOdd = Convert.ToDouble(query[5]);
  910. ca.Newest_POdd = -1;
  911. ca.Newest_FOdd = Convert.ToDouble(query[7]);
  912. ca.Probability_SOdd = Convert.ToDouble(query[9]);
  913. ca.Probability_POdd = -1;
  914. ca.Probability_FOdd = Convert.ToDouble(query[10]);
  915. ca.Kelly_SOdd = Convert.ToDouble(query[11]);
  916. ca.Kelly_POdd = -1;
  917. ca.Kelly_FOdd = Convert.ToDouble(query[12]);
  918. ca.Loss_Odd = -1;
  919. //calist.Add(ca);
  920. return ca;
  921. }
  922. catch (Exception e)
  923. {
  924. return new F_CuringAnalysis();
  925. }
  926. }
  927. //public static string b1 = "c06f47ca4f8ee811af5a2c4d54d3f5a9", b2 = "00ae03d14f8ee811af5a2c4d54d3f5a9", b3 = "30d122dc4f8ee811af5a2c4d54d3f5a9";
  928. public static string b1 = "b1b112fa278ee811a04200ac6a4a134f", b2 = "b2b112fa278ee811a04200ac6a4a134f", b3 = "b1bf8c08288ee811a04200ac6a4a134f";
  929. //平均值 b1b112fa278ee811a04200ac6a4a134f
  930. //最小值 b2b112fa278ee811a04200ac6a4a134f
  931. //最大值 b1bf8c08288ee811a04200ac6a4a134f
  932. /// <summary>
  933. /// 插入数据赛季分析表
  934. /// </summary>
  935. /// <param name="data"></param>
  936. /// <param name="Id"></param>
  937. /// <param name="Season"></param>
  938. public void InsertSeasonAnalysis(string data, string Id, string url, string Season)
  939. {
  940. // List<F_SeasonAnalysis> salist1 = salist;
  941. //if (salist1.Where(a => a.Id == Id).ToList().Count > 0)
  942. //return;
  943. var query = data.Split('|');
  944. try
  945. {
  946. F_SeasonAnalysis sa = new F_SeasonAnalysis();
  947. sa.Remark = url;
  948. sa.Id = CommonHelper.GetGuid().ToString();
  949. sa.CreateDateTime = DateTime.Now;
  950. sa.Season = Season;
  951. sa.TeamId = Id;
  952. sa.OldRanking = query[0].TryToInt32();
  953. sa.NowOldRanking = query[1].TryToInt32();
  954. sa.Win = query[2].TryToInt32();
  955. sa.Draw = query[3].TryToInt32();
  956. sa.Lose = query[4].TryToInt32();
  957. sa.Number = query[5].TryToInt32();
  958. salist.Add(sa);
  959. }
  960. catch (Exception e)
  961. {
  962. F_SeasonAnalysis sa = new F_SeasonAnalysis();
  963. sa.Remark = url;
  964. sa.Id = CommonHelper.GetGuid().ToString();
  965. sa.CreateDateTime = DateTime.Now;
  966. sa.Season = Season;
  967. sa.TeamId = Id;
  968. sa.OldRanking = query[0].TryToInt32();
  969. sa.NowOldRanking = query[0].TryToInt32();
  970. sa.Win = 0;
  971. sa.Draw = 0;
  972. sa.Lose = 0;
  973. sa.Number = query[1].TryToInt32();
  974. salist.Add(sa);
  975. }
  976. }
  977. /// <summary>
  978. /// 插入数据赛季分析表
  979. /// </summary>
  980. /// <param name="data"></param>
  981. /// <param name="Id"></param>
  982. /// <param name="Season"></param>
  983. public F_SeasonAnalysis InsertSeasonAnalysis_new(string data, string Id, string url, string Season)
  984. {
  985. // List<F_SeasonAnalysis> salist1 = salist;
  986. //if (salist1.Where(a => a.Id == Id).ToList().Count > 0)
  987. //return;
  988. var query = data.Split('|');
  989. try
  990. {
  991. F_SeasonAnalysis sa = new F_SeasonAnalysis();
  992. sa.Remark = url;
  993. sa.Id = CommonHelper.GetGuid().ToString();
  994. sa.CreateDateTime = DateTime.Now;
  995. sa.Season = Season;
  996. sa.TeamId = Id;
  997. sa.OldRanking = query[0].TryToInt32();
  998. sa.NowOldRanking = query[1].TryToInt32();
  999. sa.Win = query[2].TryToInt32();
  1000. sa.Draw = query[3].TryToInt32();
  1001. sa.Lose = query[4].TryToInt32();
  1002. sa.Number = query[5].TryToInt32();
  1003. //salist.Add(sa);
  1004. return sa;
  1005. }
  1006. catch (Exception e)
  1007. {
  1008. return new F_SeasonAnalysis();
  1009. }
  1010. }
  1011. #region 更新
  1012. public void Getbjop_new(string url, F_Games game)
  1013. {
  1014. using (AsianDishJob c = new AsianDishJob())
  1015. {
  1016. c.UseLimitedResource(url, game);
  1017. }
  1018. }
  1019. public void Getbjopdetail_new(string url, F_AsianDishCuring oc, string date)
  1020. {
  1021. try
  1022. {
  1023. //插入初始
  1024. InsertCompensate_start(oc, date);
  1025. //Trace.WriteLine("亚盘所有分析获取 开始:" + "http://fenxi.zgzcw.com" + url);
  1026. string yurl = url;
  1027. if (!url.Contains("http://fenxi.zgzcw.com"))
  1028. url = "http://fenxi.zgzcw.com" + url.Replace(":80", "");
  1029. var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8"));
  1030. HtmlDocument doc = new HtmlDocument();
  1031. if (htmlResource == null)
  1032. return;
  1033. if (htmlResource.Contains("lg123456"))
  1034. {
  1035. urllist1.Add(url + "|" + oc.Id);
  1036. return;
  1037. }
  1038. if (htmlResource.Contains("403 Forbidden"))
  1039. {
  1040. urllist1.Add(url + "|" + oc.Id);
  1041. return;
  1042. }
  1043. doc.LoadHtml(htmlResource);
  1044. HtmlNodeCollection detailHtml = doc.DocumentNode.SelectNodes("//*[@class='dxzkt-tab']/tr");
  1045. if (detailHtml == null)
  1046. return;
  1047. DateTime date1 = Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"));
  1048. DateTime jdate = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd"));
  1049. foreach (var item in detailHtml)
  1050. {
  1051. HtmlDocument doc1 = new HtmlDocument();
  1052. doc1.LoadHtml(item.InnerHtml);
  1053. HtmlNodeCollection bjopfxtdHtml = doc1.DocumentNode.SelectNodes("//td");
  1054. if (bjopfxtdHtml != null)
  1055. {
  1056. if (bjopfxtdHtml.Count == 11)
  1057. {
  1058. string shuju = "";
  1059. DateTime newdate=DateTime.Now;
  1060. int i = 0;
  1061. foreach (var item1 in bjopfxtdHtml)
  1062. {
  1063. shuju += item1.InnerText.Trim() + "|";
  1064. if (i == 1)
  1065. {
  1066. try
  1067. {
  1068. newdate = Convert.ToDateTime(item1.InnerText.Trim());
  1069. }
  1070. catch (Exception e)
  1071. {
  1072. }
  1073. }
  1074. i++;
  1075. }
  1076. if (newdate > date1 && newdate < jdate)
  1077. {
  1078. InsertCompensate(shuju, oc, url);
  1079. }
  1080. //InsertCompensate(shuju, oc, url);
  1081. }
  1082. }
  1083. }
  1084. }
  1085. catch (Exception e)
  1086. {
  1087. Trace.WriteLine("报错开始 开始:" + "http://fenxi.zgzcw.com" + url);
  1088. //Getbjopdetail(url, oc);
  1089. }
  1090. }
  1091. /// <summary>
  1092. /// 插入数据亚盘固化数据
  1093. /// </summary>
  1094. /// <param name="data"></param>
  1095. /// <param name="Id"></param>
  1096. /// <param name="Season"></param>
  1097. public void InsertOddsCuring_new(string data, string Id, string url, DateTime date, string HomeTeamId, string VisitingTeamId, string HomeTeamName, string VisitingTeamName,string jsonall,DateTime lastdate)
  1098. {
  1099. try
  1100. {
  1101. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  1102. F_AsianDishCuring oc = new F_AsianDishCuring();
  1103. oc.Init_SOdd = Convert.ToDouble(query[2]);
  1104. oc.Init_DiscName = query[3];
  1105. oc.Init_FOdd = Convert.ToDouble(query[4]);
  1106. oc.Newest_SOdd = Convert.ToDouble(query[5]);
  1107. oc.Newest_DiscName = query[6];
  1108. oc.Newest_FOdd = Convert.ToDouble(query[7]);
  1109. oc.Probability_SOdd = Convert.ToDouble(query[9]);
  1110. oc.Probability_FOdd = Convert.ToDouble(query[10]);
  1111. oc.Kelly_SOdd = Convert.ToDouble(query[11]);
  1112. oc.Kelly_FOdd = Convert.ToDouble(query[12]);
  1113. oc.Loss_Odd = Convert.ToDouble(query[13]);
  1114. oc.BankerCompanyName = query[1];
  1115. oc.BankerCompanyId = query[1];
  1116. oc.Remark = url;
  1117. oc.Id = CommonHelper.GetGuid().ToString();
  1118. oc.CreateDateTime = DateTime.Now;
  1119. oc.GameId = Id;
  1120. try
  1121. {
  1122. oc.ChangeDateTime = Convert.ToDateTime(query[8]);
  1123. }
  1124. catch (Exception e)
  1125. {
  1126. oc.ChangeDateTime = DateTime.Now;
  1127. }
  1128. oc.HomeTeamId = HomeTeamId;
  1129. oc.HomeTeamName = HomeTeamName;
  1130. oc.VisitingTeamId = VisitingTeamId;
  1131. oc.VisitingTeamName = VisitingTeamName;
  1132. lock (oclist)
  1133. {
  1134. oclist.Add(oc);
  1135. }
  1136. F_AsianDish ca = new F_AsianDish();
  1137. ca.BankerCompanyId = oc.BankerCompanyId;
  1138. ca.ChangeDateTime = lastdate;
  1139. ca.AsianDishStatus = "913f7b12da6ae811ab3100ac6a4a134f";//及时盘口赔率 913f7b12da6ae811ab3100ac6a4a134f
  1140. ca.CreateDateTime = DateTime.Now;
  1141. ca.SOdd = Convert.ToDouble(query[5]);
  1142. ca.POdd = -1;
  1143. ca.Disc = query[6];
  1144. ca.FOdd = Convert.ToDouble(query[7]);
  1145. ca.Remark = url;
  1146. ca.Id = CommonHelper.GetGuid().ToString();
  1147. ca.GameId = oc.GameId;
  1148. //csalist.Add(ca);
  1149. lock (oclist)
  1150. {
  1151. csalist.Add(ca);
  1152. }
  1153. // Getbjopdetail_new(url, oc, query[8]);
  1154. Getbjopdetail_new_json(jsonall, query[1], lastdate, oc);
  1155. }
  1156. catch (Exception s)
  1157. {
  1158. }
  1159. }
  1160. /// <summary>
  1161. /// 插入数据亚盘固化数据
  1162. /// </summary>
  1163. /// <param name="data"></param>
  1164. /// <param name="Id"></param>
  1165. /// <param name="Season"></param>
  1166. public op InsertOddsCuring_new2(string data, string Id, string url, DateTime date, string HomeTeamId, string VisitingTeamId, string HomeTeamName, string VisitingTeamName, string jsonall, DateTime lastdate)
  1167. {
  1168. try
  1169. {
  1170. op op = new op();
  1171. var query = data.Replace("↓", "").Replace("↑", "").Split('|');
  1172. F_AsianDishCuring oc = new F_AsianDishCuring();
  1173. oc.Init_SOdd = Convert.ToDouble(query[2]);
  1174. oc.Init_DiscName = query[3];
  1175. oc.Init_FOdd = Convert.ToDouble(query[4]);
  1176. oc.Newest_SOdd = Convert.ToDouble(query[5]);
  1177. oc.Newest_DiscName = query[6];
  1178. oc.Newest_FOdd = Convert.ToDouble(query[7]);
  1179. oc.Probability_SOdd = Convert.ToDouble(query[9]);
  1180. oc.Probability_FOdd = Convert.ToDouble(query[10]);
  1181. oc.Kelly_SOdd = Convert.ToDouble(query[11]);
  1182. oc.Kelly_FOdd = Convert.ToDouble(query[12]);
  1183. oc.Loss_Odd = Convert.ToDouble(query[13]);
  1184. oc.BankerCompanyName = query[1];
  1185. oc.BankerCompanyId = query[1];
  1186. oc.Remark = url;
  1187. oc.Id = CommonHelper.GetGuid().ToString();
  1188. oc.CreateDateTime = DateTime.Now;
  1189. oc.GameId = Id;
  1190. try
  1191. {
  1192. oc.ChangeDateTime = Convert.ToDateTime(query[8]);
  1193. }
  1194. catch (Exception e)
  1195. {
  1196. oc.ChangeDateTime = DateTime.Now;
  1197. }
  1198. oc.HomeTeamId = HomeTeamId;
  1199. oc.HomeTeamName = HomeTeamName;
  1200. oc.VisitingTeamId = VisitingTeamId;
  1201. oc.VisitingTeamName = VisitingTeamName;
  1202. op.Asian = oc;
  1203. F_AsianDish ca = new F_AsianDish();
  1204. ca.BankerCompanyId = oc.BankerCompanyId;
  1205. ca.ChangeDateTime = lastdate;
  1206. ca.AsianDishStatus = "913f7b12da6ae811ab3100ac6a4a134f";//及时盘口赔率 913f7b12da6ae811ab3100ac6a4a134f
  1207. ca.CreateDateTime = DateTime.Now;
  1208. ca.SOdd = Convert.ToDouble(query[5]);
  1209. ca.POdd = -1;
  1210. ca.Disc = query[6];
  1211. ca.FOdd = Convert.ToDouble(query[7]);
  1212. ca.Remark = url;
  1213. ca.Id = CommonHelper.GetGuid().ToString();
  1214. ca.GameId = oc.GameId;
  1215. //csalist.Add(ca);
  1216. op.Asiandetail.Add(ca);
  1217. // Getbjopdetail_new(url, oc, query[8]);
  1218. var a_new= Getbjopdetail_new_json2(jsonall, query[1], lastdate, oc);
  1219. op.Asiandetail.AddRange(a_new);
  1220. return op;
  1221. }
  1222. catch (Exception s)
  1223. {
  1224. return new op();
  1225. }
  1226. }
  1227. public void Getbjopdetail_new_json(string jsonurl,string BankerCompanyName,DateTime lastdate, F_AsianDishCuring oc)
  1228. {
  1229. var obj = JsonConvert.DeserializeObject<JObject>(jsonurl);
  1230. var list = obj["company5List"];
  1231. var objw = JsonConvert.DeserializeObject<List<company5List>>(list.ToString());
  1232. var objw1 = objw.Where(a => a.attribute.name == BankerCompanyName).FirstOrDefault();
  1233. if (objw1 == null)
  1234. return;
  1235. foreach (var item in objw1.c)
  1236. {
  1237. if (lastdate == item.attribute.wdate.TryToDateTime())
  1238. continue;
  1239. if (item.attribute.wdate.TryToDateTime() > Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")) )
  1240. {
  1241. F_AsianDish ca = new F_AsianDish();
  1242. ca.BankerCompanyId = oc.BankerCompanyId;
  1243. ca.ChangeDateTime = item.attribute.wdate.TryToDateTime();
  1244. ca.AsianDishStatus = "913f7b12da6ae811ab3100ac6a4a134f";//及时盘口赔率 913f7b12da6ae811ab3100ac6a4a134f
  1245. ca.CreateDateTime = DateTime.Now;
  1246. ca.SOdd = Convert.ToDouble(item.attribute.win);
  1247. ca.POdd = -1;
  1248. ca.Disc = item.attribute.same_handicap;
  1249. ca.FOdd = Convert.ToDouble(item.attribute.lost);
  1250. ca.Remark = "";
  1251. ca.Id = CommonHelper.GetGuid().ToString();
  1252. ca.GameId = oc.GameId;
  1253. lock (csalist)
  1254. {
  1255. csalist.Add(ca);
  1256. }
  1257. }else
  1258. {
  1259. var s1 = item.attribute.wdate.TryToDateTime();
  1260. var s2 = Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"));
  1261. }
  1262. }
  1263. }
  1264. public List<F_AsianDish> Getbjopdetail_new_json2(string jsonurl, string BankerCompanyName, DateTime lastdate, F_AsianDishCuring oc)
  1265. {
  1266. List<F_AsianDish> a_new = new List<F_AsianDish>();
  1267. var obj = JsonConvert.DeserializeObject<JObject>(jsonurl);
  1268. var list = obj["company5List"];
  1269. var objw = JsonConvert.DeserializeObject<List<company5List>>(list.ToString());
  1270. var objw1 = objw.Where(a => a.attribute.name == BankerCompanyName).FirstOrDefault();
  1271. if (objw1 == null)
  1272. return new List<F_AsianDish>(); ;
  1273. foreach (var item in objw1.c)
  1274. {
  1275. if (lastdate == item.attribute.wdate.TryToDateTime())
  1276. continue;
  1277. if (item.attribute.wdate.TryToDateTime() > Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")))
  1278. {
  1279. F_AsianDish ca = new F_AsianDish();
  1280. ca.BankerCompanyId = oc.BankerCompanyId;
  1281. ca.ChangeDateTime = item.attribute.wdate.TryToDateTime();
  1282. ca.AsianDishStatus = "913f7b12da6ae811ab3100ac6a4a134f";//及时盘口赔率 913f7b12da6ae811ab3100ac6a4a134f
  1283. ca.CreateDateTime = DateTime.Now;
  1284. ca.SOdd = Convert.ToDouble(item.attribute.win);
  1285. ca.POdd = -1;
  1286. ca.Disc = item.attribute.same_handicap;
  1287. ca.FOdd = Convert.ToDouble(item.attribute.lost);
  1288. ca.Remark = "";
  1289. ca.Id = CommonHelper.GetGuid().ToString();
  1290. ca.GameId = oc.GameId;
  1291. a_new.Add(ca);
  1292. }
  1293. else
  1294. {
  1295. var s1 = item.attribute.wdate.TryToDateTime();
  1296. var s2 = Convert.ToDateTime(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd"));
  1297. }
  1298. }
  1299. return a_new;
  1300. }
  1301. public class company5List
  1302. {
  1303. public company5List()
  1304. {
  1305. c = new List<sk>();
  1306. }
  1307. public Attribute attribute { get; set; }
  1308. public List<sk> c { get; set; }
  1309. }
  1310. public class Attribute
  1311. {
  1312. public string name { get; set; }
  1313. public string cid { get; set; }
  1314. }
  1315. public class sk
  1316. {
  1317. public sk2 attribute { get; set; }
  1318. public string value { get; set; }
  1319. }
  1320. public class sk2
  1321. {
  1322. public string lost { get; set; }
  1323. public string lostch { get; set; }
  1324. public string arq { get; set; }
  1325. public string wdate { get; set; }
  1326. public string win { get; set; }
  1327. public string wdate1 { get; set; }
  1328. public string same { get; set; }
  1329. public string cid { get; set; }
  1330. public string samech { get; set; }
  1331. public string alost { get; set; }
  1332. public string awin { get; set; }
  1333. public string winch { get; set; }
  1334. public string returnPer { get; set; }
  1335. public string arq_num { get; set; }
  1336. public string same_handicap { get; set; }
  1337. }
  1338. #endregion
  1339. public void UseLimitedResource(string url, F_Games game)
  1340. {
  1341. try
  1342. {
  1343. List<F_SeasonAnalysis> sa_new = new List<F_SeasonAnalysis>();
  1344. url = url.Replace(":80", "");
  1345. string jsonall = CommonHelper.GetHtmlString(url.Replace("fenxi.zgzcw.com", "fenxi.zgzcw.com/json"), "", 5 * 1000);
  1346. var htmlResource = CommonHelper.GetHtmlString(url, "", 5 * 1000);
  1347. HtmlDocument doc = new HtmlDocument();
  1348. if (htmlResource == null)
  1349. return;
  1350. if (htmlResource == ConfigurationManager.AppSettings["HttpException"].ToString())
  1351. return;
  1352. doc.LoadHtml(htmlResource);
  1353. //赔率集合
  1354. HtmlNodeCollection bjopHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-02']/tr");
  1355. if (bjopHtml == null)
  1356. return;
  1357. string HomeTeamName = "";
  1358. HtmlNodeCollection homenameHtml = doc.DocumentNode.SelectNodes("//*[@class='host-name']/a");
  1359. if (homenameHtml != null)
  1360. {
  1361. var q1 = teamlist.Where(a => a.Name == homenameHtml[0].InnerText.Trim()).FirstOrDefault();
  1362. string data = "";
  1363. if (q1 != null)
  1364. {
  1365. HomeTeamName = q1.Name;
  1366. HtmlNodeCollection homepmHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-zd']");
  1367. if (homepmHtml[0].InnerText.Trim().Contains("上赛季排名"))
  1368. {
  1369. data = "" + string.Join("|", homepmHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  1370. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  1371. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  1372. }
  1373. else
  1374. {
  1375. data = "" + homepmHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  1376. HtmlNodeCollection homedfHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-h']");
  1377. data += "|" + homedfHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分", "");
  1378. }
  1379. var sa_sea = InsertSeasonAnalysis_new(data, q1.Id, url, game.Season);
  1380. if (sa_sea != null)
  1381. sa_new.Add(sa_sea);
  1382. }
  1383. }
  1384. string VisitingTeamName = "";
  1385. HtmlNodeCollection visitingnameHtml = doc.DocumentNode.SelectNodes("//*[@class='visit-name']/a");
  1386. if (visitingnameHtml != null)
  1387. {
  1388. string data = "";
  1389. var q2 = teamlist.Where(a => a.Name == visitingnameHtml[0].InnerText.Trim()).FirstOrDefault();
  1390. if (q2 != null)
  1391. {
  1392. VisitingTeamName = q2.Name;
  1393. HtmlNodeCollection homepmkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-add-info-kd']");
  1394. if (homepmkHtml[0].InnerText.Trim().Contains("上赛季排名"))
  1395. {
  1396. data = "" + string.Join("|", homepmkHtml[0].InnerText.Trim().Replace("上赛季排名:", "").Replace("本赛季排名", "").Split(':'));
  1397. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  1398. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("客队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "");
  1399. }
  1400. else
  1401. {
  1402. data = "" + homepmkHtml[0].InnerText.Trim().Replace("FIFA排名:", "");
  1403. HtmlNodeCollection homedfkHtml = doc.DocumentNode.SelectNodes("//*[@class='team-info-v']");
  1404. data += "|" + homedfkHtml[0].InnerText.Trim().Replace("主队:", "").Replace("胜", "|").Replace("平", "|").Replace("负", "|").Replace("分", "").Replace("积分", "");
  1405. }
  1406. var sa_sea = InsertSeasonAnalysis_new(data, q2.Id, url, game.Season);
  1407. if (sa_sea != null)
  1408. sa_new.Add(sa_sea);
  1409. }
  1410. }
  1411. salist.AddRange(sa_new);
  1412. DateTime lastdate = DateTime.Now;
  1413. foreach (var item in bjopHtml)
  1414. {
  1415. HtmlDocument doc1 = new HtmlDocument();
  1416. doc1.LoadHtml(item.InnerHtml);
  1417. HtmlNodeCollection bjoptdHtml = doc1.DocumentNode.SelectNodes("//td");
  1418. int i = 1;
  1419. string shuju = "", nurl = "";
  1420. DateTime lasttime = DateTime.Now;
  1421. foreach (var item1 in bjoptdHtml)
  1422. {
  1423. if (i == 2)
  1424. {
  1425. Companylist.Add(item1.InnerText.Trim() + "|" + item1.Attributes["data"].Value);
  1426. }
  1427. if (i == 6)
  1428. {
  1429. shuju += item1.InnerText.Trim() + "|";
  1430. nurl = item1.SelectNodes("//a")[0].Attributes["href"].Value.Trim();
  1431. }
  1432. else if (i == 9)
  1433. {
  1434. HtmlDocument doc2 = new HtmlDocument();
  1435. doc2.LoadHtml(item1.InnerHtml);
  1436. HtmlNodeCollection timehtml = doc2.DocumentNode.SelectNodes("//em");
  1437. shuju += item.Attributes["firsttime"].Value + "|";
  1438. string datestring = timehtml[0].InnerText.Trim().Replace("更新时间:赛前", "").Replace("时", "|").Replace("分", "");
  1439. string Hours = "0";
  1440. string Minute = "0";
  1441. if (datestring.Split('|').Length == 2)
  1442. {
  1443. Hours = datestring.Split('|')[0];
  1444. Minute = datestring.Split('|')[1];
  1445. }
  1446. else if (datestring.Split('|').Length == 1)
  1447. {
  1448. Hours = "0";
  1449. Minute = datestring.Split('|')[0];
  1450. }
  1451. int Minutes = Minute.TryToInt32() + Hours.TryToInt32() * 60;
  1452. lasttime = Convert.ToDateTime(game.StartDateTime).AddMinutes(-Minutes);
  1453. }
  1454. else
  1455. {
  1456. shuju += item1.InnerText.Trim() + "|";
  1457. }
  1458. i++;
  1459. }
  1460. lastdate = lasttime;
  1461. var op = InsertOddsCuring_new2(shuju, game.Id, nurl, game.StartDateTime.TryToDateTime(), game.HomeTeamId, game.VisitingTeamId, HomeTeamName, VisitingTeamName, jsonall, Convert.ToDateTime(lasttime));
  1462. oclist.Add(op.Asian);
  1463. csalist.AddRange(op.Asiandetail);
  1464. }
  1465. //class="bf-tab-03"
  1466. HtmlNodeCollection bjopfxHtml = doc.DocumentNode.SelectNodes("//*[@class='bf-tab-03']/tr");
  1467. if (bjopfxHtml == null)
  1468. return;
  1469. foreach (var item in bjopfxHtml)
  1470. {
  1471. HtmlDocument doc1 = new HtmlDocument();
  1472. doc1.LoadHtml(item.InnerHtml);
  1473. HtmlNodeCollection bjopfxtdHtml = doc1.DocumentNode.SelectNodes("//td");
  1474. if (bjopfxtdHtml.Count == 15)
  1475. {
  1476. string shuju = "";
  1477. foreach (var item1 in bjopfxtdHtml)
  1478. {
  1479. shuju += item1.InnerText.Trim() + "|";
  1480. }
  1481. var ca_n = InsertCuringAnalysis2(shuju, game.Id, url);
  1482. calist.Add(ca_n);
  1483. }
  1484. }
  1485. }
  1486. catch (Exception e)
  1487. {
  1488. //throw;
  1489. }
  1490. }
  1491. void IDisposable.Dispose()
  1492. {
  1493. //Console.WriteLine("我在释放");
  1494. }
  1495. }
  1496. public class op
  1497. {
  1498. public op()
  1499. {
  1500. Asiandetail = new List<F_AsianDish>();
  1501. }
  1502. public F_AsianDishCuring Asian { get; set; }
  1503. public List<F_AsianDish> Asiandetail { get; set; }
  1504. }
  1505. }