初始化

.gitignore

+bin/
+obj/

Agent/AgentService.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Agent
+{
+    public class AgentService
+    {
+    }
+}

Data/FlightFlow.cs

+using Newtonsoft.Json.Linq;
+using OpenQA.Selenium;
+using OpenQA.Selenium.Chrome;
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Model;
+using TicketSpider.Spiders.EasterLineRule;
+using TicketSpider.Uitls;
+
+namespace TicketSpider.Data
+{
+    public class FlightFlow
+    {
+
+        private JArray TARGET_FLIGHT = new JArray();
+
+        public async void StartAsync()
+        {
+            
+            Console.WriteLine("进入东航刷票模块，开始计算需求.......");
+            
+            Console.WriteLine("开始模拟登录信息.......");
+            string loginCookies = AccountManagerHelper.GetInstance();
+            if (!string.IsNullOrEmpty(loginCookies) && !TaskHelper.cancelTokenSource.IsCancellationRequested)
+            {
+                Console.WriteLine("获取登录信息成功, 开始操作乘客信息");
+               
+                await Task.Run(() => new PassengerHelper().RegistPassengerHandler());
+                Thread.Sleep(2000);
+                Console.WriteLine("乘客信息处理完毕，开始执行寻票...");
+                if (CmdHelper.FLIGHTS.Count == 1) 
+                {
+                    if (CmdHelper.FLIGHTS.FirstOrDefault().DepartDateMode == 1)
+                    {
+                        Task.Factory.StartNew(() => QueryTicketHandler(CmdHelper.FLIGHTS.FirstOrDefault().DepartDate), TaskHelper.cancelTokenSource.Token);
+                    }
+                    else if (CmdHelper.FLIGHTS.FirstOrDefault().DepartDateMode == 2)
+                    {
+                        var dates=CmdHelper.FLIGHTS.FirstOrDefault().DepartDate.Split("~");
+                        var dt1 = DateTime.Parse(dates[0]);
+                        var dt2 = DateTime.Parse(dates[1]);
+                        while (true)
+                        {
+                            Task.Factory.StartNew(() => QueryTicketHandler(dt1.ToString("yyyy-MM-dd")), TaskHelper.cancelTokenSource.Token);
+                            dt1.AddDays(1);
+                            if (dt1 > dt2) break;
+                        }
+                    }
+                    else if (CmdHelper.FLIGHTS.FirstOrDefault().DepartDateMode == 3)
+                    {
+                        var dates = CmdHelper.FLIGHTS.FirstOrDefault().DepartDate;
+                        var dt1 = DateTime.Parse($"{dates}-01");
+                        while (true)
+                        {
+                            Task.Factory.StartNew(() => QueryTicketHandler(dt1.ToString("yyyy-MM-dd")), TaskHelper.cancelTokenSource.Token);
+                            dt1.AddDays(1);
+                            if (dt1.ToString("yyyy/MM") != dates) break;
+                        }
+                    }
+                }
+            }
+            else 
+            {
+                Console.WriteLine("获取登录信息失败，程序退出...");
+                Environment.Exit(0);
+            }
+            
+        }
+
+        public async void QueryTicketHandler(string date)
+        {
+            //Setup 2:获取航班数据
+            var flight = new QueryFlightHelper(0.1M).RunAsync(date).Result;
+            if (!TaskHelper.cancelTokenSource.IsCancellationRequested) return;
+            Console.WriteLine("获取机票信息完毕");
+            Thread.Sleep(1000);
+            //Setup 4 创建订单
+            Console.WriteLine("开始创建订单...");
+            var orderSubmit = await new TicketOrderHelper().RunAsync(flight);
+            if (!TaskHelper.cancelTokenSource.IsCancellationRequested) return;
+            if (orderSubmit.result)
+            {
+                //Setup 5 弹出付款链接
+                Console.WriteLine("订单创建成功，正在准备付款页面");
+                OpenOrderPayPageHandler(orderSubmit.order);
+            }
+            else
+            {
+                Console.WriteLine("订单提交失败....程序退出");
+                TaskHelper.GetInstance().UnLockOrderStatus(); //释放锁定
+            }
+        }
+
+        public void OpenOrderPayPageHandler(JObject order)
+        {
+            var flag = false;
+            ReadOnlyCollection<IWebElement> inputEle = null;
+            var option = new ChromeOptions();
+            //option.AddArgument("--incognito");
+            //option.AddArgument("headless");
+            option.AddArgument("disable-infobars");
+            //option.AddArgument("window-size=1920,1080");
+            //option.AddArgument("user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/95.0.4638.69 Safari/537.36");
+            ChromeDriverService service = ChromeDriverService.CreateDefaultService(Environment.CurrentDirectory);
+            service.HideCommandPromptWindow = true;
+            option.PageLoadStrategy = PageLoadStrategy.Eager;
+            IWebDriver driver = new ChromeDriver(service, option);
+            var cookies = AccountManagerHelper.GetInstance().Split(";");
+            driver.Navigate().GoToUrl("https://www.ceair.com/");
+            Thread.Sleep(2000);
+            driver.Manage().Cookies.DeleteAllCookies();
+            foreach (var item in cookies)
+            {
+                driver.Manage().Cookies.AddCookie(new Cookie(item.Split("=")[0], item.Split("=")[1]));
+            }
+            var param= $"{{\"tdOrderNo\":\"{order["tdOrderNo"].ToString()}\",\"t\":{DateTime.Now.Ticks}}}";
+            param = Convert.ToBase64String(Encoding.UTF8.GetBytes(param));
+            param = System.Web.HttpUtility.UrlEncode(param);
+            
+            driver.Navigate().GoToUrl($"https://www.ceair.com/payment?searchKey={param}ENCODEKEY");
+            //通知流程结束
+            TaskHelper.cancelTokenSource.Cancel();
+            AccountManagerHelper.StopHeartLine();
+        }
+
+    }
+}

Model/City.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Model
+{
+    public class City
+    {
+        public string cityCode { get; set; }
+        public string cityName { get; set; }
+        public string firstLetterCn { get; set; }
+        public string firstLetterEn { get; set; }
+        public string group { get; set; }
+        public int isHotArr { get; set; }
+        public int isHotDep { get; set; }
+        public string label { get; set; }
+        public string match { get; set; }
+        public string nc { get; set; }
+        public int orderArr { get; set; }
+        public int orderDep { get; set; }
+        public string value { get; set; }
+    }
+}

Model/FavorPaxIdDtoList.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Model
+{
+
+    [Serializable]
+    public class FavorPaxIdDtoList
+    {
+        public string id { get; set; }
+        public string favorPaxId { get; set; }
+        public string idIssueNation { get; set; }
+        public string idNo { get; set; }
+        public string idType { get; set; }
+        public string idValidDt { get; set; }
+
+        public string paxIDType { get; set; }
+
+        public string paxYouxiaoqi { get; set; }
+    }
+}

Model/Flight.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Model
+{
+    [Serializable]
+    public class Flight
+    {
+        public string? DepartCity { get; set; }
+
+        public string? ArriveCity { get; set; }
+
+        public int? DepartDateMode { get; set; }
+
+        public string? DepartDate { get; set; }
+
+        public string? AirlineCode { get; set; }
+
+        public string? SeatCode { get; set; }
+
+        public string arrCityCode { get; set; }
+        public string arrCode { get; set; }
+        public string depCityCode { get; set; }
+        public string depCode { get; set; }
+    }
+}

Model/Passenger.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Model
+{
+    [Serializable]
+    public class Passenger
+    {
+        public string id { get; set; }
+        public string paxName { get; set; }
+        public string paxNameFirst { get; set; }
+        public string paxNameLast { get; set; }
+        public string gender { get; set; }
+        public string birthday { get; set; }
+        public string nationality { get; set; }
+        public string telephoneCode { get; set; }
+        public string mobile { get; set; }
+        public string email { get; set; }
+        public List<FavorPaxIdDtoList> favorPaxIdDtoList { get; set; }
+        public string ffpAirline { get; set; }
+        public string ffpNo { get; set; }
+        public string paxType { get; set; }
+
+       
+
+    }
+}

Spiders/CityService.cs

+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Model;
+
+namespace TicketSpider.Spiders
+{
+    public class CityService
+    {
+        public static List<City> CITIES = new List<City>();
+
+        public static bool Load()
+        {
+            string cityJsonFile = Environment.CurrentDirectory + "\\zh_CN.json";
+            if (File.Exists(cityJsonFile)) 
+            {
+                using (StreamReader file = File.OpenText(cityJsonFile))
+                {
+                    using (JsonTextReader reader = new JsonTextReader(file))
+                    {
+                        try
+                        {
+                            var o = (JArray)JToken.ReadFrom(reader);
+                            CITIES = JsonConvert.DeserializeObject<List<City>>(JsonConvert.SerializeObject(o));
+                            return true;
+                        }
+                        catch (Exception){ }
+
+                    }
+                }
+            }
+
+            return false;
+        }
+
+        public static City? GetCityHandler(string city)
+        {
+            return CITIES.Where(x => x.cityName == city).FirstOrDefault();
+        }
+
+        public static bool Container(string city)
+        {
+            return CITIES.Where(x => x.cityName == city).Count() > 0;
+        }
+    }
+}

Spiders/EasterLineRule/CookiesHelper.cs

+using OpenQA.Selenium;
+using OpenQA.Selenium.Chrome;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Spiders.EasterLineRule
+{
+    public class CookiesHelper
+    {
+        /// <summary>
+        /// 获取初始化Cookies
+        /// </summary>
+        /// <returns></returns>
+        public Task<string> GetInitCookie()
+        {
+            var cookieStr = string.Empty;
+            var option = new ChromeOptions();
+            option.AddArgument("--incognito");
+            option.AddArgument("headless");
+            option.AddArgument("disable-infobars");
+            option.AddArgument("window-size=1920,1080");
+            option.AddArgument("user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/95.0.4638.69 Safari/537.36");
+            ChromeDriverService service = ChromeDriverService.CreateDefaultService(Environment.CurrentDirectory);
+            service.HideCommandPromptWindow = true;
+            option.PageLoadStrategy = PageLoadStrategy.Eager;
+            IWebDriver driver = new ChromeDriver(service, option);
+            try
+            {
+                
+                var param = "{\"travelType\":\"oneway\",\"passengerNum\":\"1,0,0\",\"depCity\":\"BKK\",\"arrCity\":\"SHA\",\"depValues\":\"BKK\",\"arrValues\":\"PVG, SHA\",\"depCityName\":\"曼谷\",\"arrCityName\":\"上海\",\"date\":\"2022-12-11\",\"cabinClass\":\"ALL\",\"payWay\":\"money\",\"depSelectValue\":\"BKK\",\"arrSelectValue\":\"PVG, SHA\",\"depLabel\":\"\",\"arrLabel\":\"\",\"isArrCity\":true,\"isDepCity\":true,\"arrCn\":\"CN\",\"depCn\":\"TH\",\"t\":" + DateTime.Now.Ticks + "}";
+                param = System.Web.HttpUtility.UrlEncode(param);
+                param = Convert.ToBase64String(Encoding.UTF8.GetBytes(param));
+                driver.Navigate().GoToUrl($"https://www.ceair.com/shopping?searchKey={param}ENCODEKEY");
+
+                foreach (var item in driver.Manage().Cookies.AllCookies)
+                {
+                    cookieStr += item.Name + "=" + item.Value + ";";
+                }
+                cookieStr = cookieStr.Substring(0, cookieStr.Length - 1);
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine($"获取cooki失败，{ex.Message}");
+            }
+            driver.Quit();
+            return Task.FromResult(cookieStr);
+        }
+    }
+}

Spiders/EasterLineRule/PassengerHelper.cs

+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Model;
+using TicketSpider.Uitls;
+
+namespace TicketSpider.Spiders.EasterLineRule
+{
+    public class PassengerHelper
+    {
+        public static List<Passenger> GLOBAL_USERLIST { get; private set; }
+
+        public async void RegistPassengerHandler()
+        {
+            GLOBAL_USERLIST = new List<Passenger>();
+            var registResult = await RegistPassenger(CmdHelper.PASSENGETS);
+            var passengersArray = await IsHavePassenger();
+            if (passengersArray.Any())
+            {
+                var passengers = passengersArray.ToObject<List<Passenger>>();
+                CmdHelper.PASSENGETS.ForEach(user => {
+                    passengers.ToList().ForEach(x => {
+                        x.favorPaxIdDtoList.ForEach(y =>
+                        {
+                            if (y.idType == user.favorPaxIdDtoList.First().idType && y.idNo == user.favorPaxIdDtoList.First().idNo)
+                            {
+                                y.idValidDt=user.favorPaxIdDtoList[0].idValidDt;
+                                GLOBAL_USERLIST.Add(x);
+                                
+                            }
+                        });
+                    });
+                });
+                if (GLOBAL_USERLIST.Any())
+                {
+                    Console.WriteLine("完成乘客信息锁定");
+                }
+                else 
+                {
+                    Console.WriteLine("警告：未能绑定乘客信息");
+                }
+            }
+            else 
+            {
+                Console.WriteLine("警告：未能绑定乘客信息");
+            }
+        }
+
+        private async Task<bool> RegistPassenger(List<Passenger> userList)
+        {
+            JObject passengers = new JObject();
+            passengers.Add("paxs", JArray.FromObject(userList));
+            passengers.Add("singleAlone",false);
+            passengers.Add("deviceId", "");
+
+            var paramster=JsonConvert.SerializeObject(passengers);
+            var request = CreateRequest();
+            var url = "https://www.ceair.com/portal/v3/customer/addPassenger";
+            var content = new StringContent(paramster, System.Text.Encoding.UTF8, "application/json");
+             var response = await request.PostAsync(url, content);
+
+            var result = response.Content.ReadAsStringAsync().Result;
+            if (result.Contains("A200") || result.Contains("U200127"))
+            {
+                return true;
+            }
+
+            return false;
+        }
+
+        private async Task<JArray> IsHavePassenger() 
+        {
+            var request = CreateRequest();
+            var resloveResult = new JArray();
+            var url = "https://www.ceair.com/portal/v3/customer/queryPassengerList";
+            var content = new StringContent("{\"userId\": " + AccountManagerHelper._userId+ ", \"deviceId\": \"\"}", System.Text.Encoding.UTF8, "application/json");
+            var response = await request.PostAsync(url, content);
+            var result = response.Content.ReadAsStringAsync().Result;
+            if (result.Contains("U200"))
+            {
+                
+                try
+                {
+                    resloveResult = JObject.Parse(result)["resultContent"]as JArray;
+                }
+                catch (Exception) { }
+            }
+            //if (resloveResult.Any()) 
+            //{
+            //    Console.WriteLine($"获取乘客信息成功：{JsonConvert.SerializeObject(resloveResult)}");
+            //}
+            return resloveResult;
+        }
+
+        private HttpClient CreateRequest()
+        {
+            var handler = new HttpClientHandler();
+            handler.AllowAutoRedirect = false;
+            handler.UseCookies = true;
+            handler.CookieContainer = CreateCookie(AccountManagerHelper.GetInstance());
+            handler.AutomaticDecompression = DecompressionMethods.GZip;
+            handler.ClientCertificateOptions = ClientCertificateOption.Automatic;
+            var http = new HttpClient(handler);
+            CreateRequestHeaders(ref http);
+
+            return http;
+        }
+
+        private CookieContainer CreateCookie(string cookieStr)
+        {
+            var uri = new Uri("https://www.ceair.com");
+            var cc = new CookieContainer();
+            foreach (var str in cookieStr.Split(';'))
+            {
+                cc.SetCookies(uri, str);
+            }
+            return cc;
+        }
+
+        private void CreateRequestHeaders(ref HttpClient http)
+        {
+            var random = new Random();
+            http.DefaultRequestHeaders.Add("Accept", "application/json, text/plain, */*");
+            http.DefaultRequestHeaders.Add("Accept-Encoding", "gzip, deflate, br");
+            http.DefaultRequestHeaders.Add("Accept-Language", "zh-CN,zh;q=0.9");
+            http.DefaultRequestHeaders.Add("Cache-Control", "no-cache");
+            //http.DefaultRequestHeaders.Add("Connection", "keep-alive");
+            //http.DefaultRequestHeaders.Add("Content-Length", "188");
+            //http.DefaultRequestHeaders.Add("Content-Type", new MediaTypeHeaderValue("application/json"));
+            //http.DefaultRequestHeaders.Add("Host", "m.ceair.com");
+            http.DefaultRequestHeaders.Add("Origin", "https://www.ceair.com");
+            http.DefaultRequestHeaders.Add("Pragma", "no-cache");
+            http.DefaultRequestHeaders.Add("Referer", "https://www.ceair.com/leftNavigation/personCenter/passengers");
+            //http.DefaultRequestHeaders.Add("salesChannel", "NzcwMQ==");
+            http.DefaultRequestHeaders.Add("sec-ch-ua", "\" Not; A Brand\";v=\"99\", \"Google Chrome\";v=\"97\", \"Chromium\";v=\"97\"");
+            http.DefaultRequestHeaders.Add("sec-ch-ua-mobile", "?0");
+            http.DefaultRequestHeaders.Add("sec-ch-ua-platform", "\"Windows\"");
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Dest", "empty");
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Mode", "cors");
+
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Site", "same-origin");
+            http.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.99 Safari/537.36");
+            http.DefaultRequestHeaders.Add("x-tingyun-id", $"DuR5xFLm8eI;r={random.Next(100000000, 999999999)}");
+
+            http.DefaultRequestHeaders.Add("site", "zh_CN");
+            http.DefaultRequestHeaders.Add("shakehand", "535206fb27efbaf75066ff179b975ff6");
+            http.DefaultRequestHeaders.Add("pragma", "no-cache");
+        }
+    }
+}

Spiders/EasterLineRule/QueryFlightHelper.cs

+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Data;
+using TicketSpider.Uitls;
+
+namespace TicketSpider.Spiders.EasterLineRule
+{
+    public class QueryFlightHelper
+    {
+        private static decimal REQUEST_QPS=2;
+
+        private static int INTERVAL_TIMER = 1000;
+
+        //public CookieContainer cookieContainer = new CookieContainer();
+
+        public QueryFlightHelper(decimal qps = 2) 
+        {
+            REQUEST_QPS = qps;
+            INTERVAL_TIMER = (int)(1000 / REQUEST_QPS);
+
+        }
+
+        public async Task<JObject> RunAsync(string date)
+        {
+            var timerCount = 1;
+            var flightResult = new JObject();
+            var cookieContainer = new CookieContainer();
+            CreateCookie(ref cookieContainer);
+            while (!TaskHelper.cancelTokenSource.IsCancellationRequested)
+            {
+                
+                Console.WriteLine($"正在执行第{timerCount}次航班查询请求");
+                var result = await Action(date,cookieContainer);
+                timerCount++;
+                if (result.result.Contains("S200"))
+                {
+                    var resloveResult = new JArray();
+                    try
+                    {
+                        resloveResult= JObject.Parse(result.result)["data"]["flightItems"] as JArray;
+                        var realFlight = resloveResult.ToList().Where(x => (x["cabinInfoDescs"] as JArray).Any());
+                        if (realFlight.Any())
+                        {
+                            resloveResult = JArray.FromObject(realFlight);
+                        }
+                        else 
+                        {
+                            resloveResult.Clear();
+                        }
+                    }
+                    catch (Exception){}
+                    if (resloveResult.Any()) 
+                    {
+                        while (!TaskHelper.GetInstance().UpdateTicketStatus() && !TaskHelper.cancelTokenSource.IsCancellationRequested)
+                        {
+                            Console.WriteLine("已获取到机票信息，排队中，等待其他线程释放");
+                            Thread.Sleep(1000);
+                        }
+                        if (TaskHelper.cancelTokenSource.IsCancellationRequested) break;
+                        flightResult = JObject.Parse(result.result);
+                        flightResult["data"]["flightItems"] = resloveResult;
+                        break;
+                    }
+                }
+                else 
+                {
+                    Console.WriteLine("未找到机票");
+
+                    var newCookies = result.cookies.Split(';',StringSplitOptions.RemoveEmptyEntries);
+                    if (newCookies.Any()) 
+                    {
+                        var uri = new Uri("https://www.ceair.com");
+                        foreach (var cookie in newCookies)
+                        {
+                            var haveCookies = cookieContainer.GetAllCookies().Where(x => x.Name == cookie.Split("=")[0]);
+                            if (haveCookies.Any())
+                            {
+                                haveCookies.First().Value = cookie.Split("=")[1];
+                            }
+                            else
+                            {
+                                cookieContainer.SetCookies(uri, cookie);
+                            }
+                        }
+                    }
+                    
+                    //TODO 切换代理
+                }
+                Thread.Sleep(INTERVAL_TIMER);
+            }
+            //Console.WriteLine($"获取到航班数据");
+            return flightResult;
+        }
+
+        public async Task<(string result,string cookies)> Action(string date,CookieContainer cookieContainer)
+        {
+            var result = string.Empty;
+            var cookies = string.Empty;
+            try
+            {
+                var handler = new HttpClientHandler();
+                handler.AllowAutoRedirect = false;
+                handler.UseCookies = true;
+                handler.CookieContainer = cookieContainer;
+                handler.AutomaticDecompression = DecompressionMethods.GZip;
+                handler.ClientCertificateOptions = ClientCertificateOption.Automatic;
+                var http = new HttpClient(handler);
+                CreateRequestHeaders(ref http);
+                var url = "https://www.ceair.com/portal/v3/shopping/briefInfo";
+                var f = CmdHelper.FLIGHTS.FirstOrDefault();
+                var paramStr = $"{{\"adultCount\":1,\"arrCityCode\":\"{f.arrCityCode}\",\"arrCode\":\"{f.arrCode}\",\"arrDate\":\"\",\"childCount\":0,\"depCityCode\":\"{f.depCityCode}\",\"depCode\":\"{f.depCode}\",\"depDate\":\"{date.Replace("/","-")}\",\"infantCount\":0,\"routeType\":\"OW\",\"onlyPlaneFlag\":false,\"cabinLevel\":\"\",\"deviceId\":\"\"}}";
+                var content = new StringContent(paramStr, System.Text.Encoding.UTF8, "application/json");
+                var response = await http.PostAsync(url, content);
+                //var setCookies = response.Headers.GetValues("Set-Cookie");
+                
+                //foreach (var item in setCookies)
+                //{
+                //    cookies += item + ";";
+                //}
+                result = response.Content.ReadAsStringAsync().Result;
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine($"查询航班发生异常，异常信息如下：{e.Message}");
+            }
+            //FlightDataHelper.TARGET_FLIGHT=resu
+            return (result,cookies);
+        }
+
+        private void CreateCookie(ref CookieContainer cookieContainer)
+        {
+            var cookieStr = new CookiesHelper().GetInitCookie().Result;
+            var uri = new Uri("https://www.ceair.com");
+            var cc = new CookieContainer();
+            foreach (var str in cookieStr.Split(';'))
+            {
+                cc.SetCookies(uri, str);
+            }
+            cookieContainer = cc;
+        }
+
+        private void CreateRequestHeaders(ref HttpClient http)
+        {
+            var random = new Random();
+            http.DefaultRequestHeaders.Add("Accept", "application/json, text/plain, */*");
+            http.DefaultRequestHeaders.Add("Accept-Encoding", "gzip, deflate, br");
+            http.DefaultRequestHeaders.Add("Accept-Language", "zh-CN,zh;q=0.9");
+            http.DefaultRequestHeaders.Add("Cache-Control", "no-cache");
+            //http.DefaultRequestHeaders.Add("Connection", "keep-alive");
+            //http.DefaultRequestHeaders.Add("Content-Length", "188");
+            //http.DefaultRequestHeaders.Add("Content-Type", new MediaTypeHeaderValue("application/json"));
+            //http.DefaultRequestHeaders.Add("Host", "m.ceair.com");
+            http.DefaultRequestHeaders.Add("Origin", "https://www.ceair.com");
+            http.DefaultRequestHeaders.Add("Pragma", "no-cache");
+            http.DefaultRequestHeaders.Add("Referer", "https://www.ceair.com/shopping?searchKey=JTdCJTIydHJhdmVsVHlwZSUyMiUzQSUyMm9uZXdheSUyMiUyQyUyMnBhc3Nlbmdlck51bSUyMiUzQSUyMjElMkMwJTJDMCUyMiUyQyUyMmRlcENpdHklMjIlM0ElMjJCS0slMjIlMkMlMjJhcnJDaXR5JTIyJTNBJTIyU0hBJTIyJTJDJTIyZGVwVmFsdWVzJTIyJTNBJTIyQktLJTIyJTJDJTIyYXJyVmFsdWVzJTIyJTNBJTIyUFZHJTJDU0hBJTIyJTJDJTIyZGVwQ2l0eU5hbWUlMjIlM0ElMjIlRTYlOUIlQkMlRTglQjAlQjclMjIlMkMlMjJhcnJDaXR5TmFtZSUyMiUzQSUyMiVFNCVCOCU4QSVFNiVCNSVCNyUyMiUyQyUyMmRhdGUlMjIlM0ElMjIyMDIyLTEyLTExJTIyJTJDJTIyY2FiaW5DbGFzcyUyMiUzQSUyMkFMTCUyMiUyQyUyMnBheVdheSUyMiUzQSUyMm1vbmV5JTIyJTJDJTIyZGVwU2VsZWN0VmFsdWUlMjIlM0ElMjJCS0slMjIlMkMlMjJhcnJTZWxlY3RWYWx1ZSUyMiUzQSUyMlBWRyUyQ1NIQSUyMiUyQyUyMmRlcExhYmVsJTIyJTNBJTIyJTIyJTJDJTIyYXJyTGFiZWwlMjIlM0ElMjIlMjIlMkMlMjJpc0FyckNpdHklMjIlM0F0cnVlJTJDJTIyaXNEZXBDaXR5JTIyJTNBdHJ1ZSUyQyUyMmFyckNuJTIyJTNBJTIyQ04lMjIlMkMlMjJkZXBDbiUyMiUzQSUyMlRIJTIyJTJDJTIydCUyMiUzQTE2NTA4NzYwOTA5MjAlN0Q%3DENCODEKEY");
+            http.DefaultRequestHeaders.Add("salesChannel", "NzcwMQ==");
+            http.DefaultRequestHeaders.Add("sec-ch-ua", "\" Not; A Brand\";v=\"99\", \"Google Chrome\";v=\"97\", \"Chromium\";v=\"97\"");
+            http.DefaultRequestHeaders.Add("sec-ch-ua-mobile", "?0");
+            http.DefaultRequestHeaders.Add("sec-ch-ua-platform", "\"Windows\"");
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Dest", "empty");
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Mode", "cors");
+
+            http.DefaultRequestHeaders.Add("Sec-Fetch-Site", "same-origin");
+            http.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.99 Safari/537.36");
+            
+
+            http.DefaultRequestHeaders.Add("site", "zh_CN");
+            http.DefaultRequestHeaders.Add("shakehand", "535206fb27efbaf75066ff179b975ff6");
+            http.DefaultRequestHeaders.Add("pragma", "no-cache");
+        }
+    }
+}

TicketSpider.csproj

+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <None Remove="zh_CN.json" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Content Include="zh_CN.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="DotnetSpider" Version="5.0.9" />
+    <PackageReference Include="Selenium.WebDriver" Version="4.1.0" />
+    <PackageReference Include="Selenium.WebDriver.ChromeDriver" Version="100.0.4896.6000" />
+	  <PackageReference Include="Serilog.AspNetCore" Version="3.4.0" />
+	  <PackageReference Include="Serilog.Sinks.Console" Version="3.1.1" />
+	  <PackageReference Include="Serilog.Sinks.RollingFile" Version="3.3.0" />
+	  <PackageReference Include="Serilog.Sinks.PeriodicBatching" Version="2.3.0" />
+	  <PackageReference Include="System.Drawing.Common" Version="6.0.0" />
+  </ItemGroup>
+
+</Project>

TicketSpider.sln

+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.1.32210.238
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TicketSpider", "TicketSpider.csproj", "{53EAE111-750E-4BB3-8E84-3EC67776A4DC}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{53EAE111-750E-4BB3-8E84-3EC67776A4DC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{53EAE111-750E-4BB3-8E84-3EC67776A4DC}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{53EAE111-750E-4BB3-8E84-3EC67776A4DC}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{53EAE111-750E-4BB3-8E84-3EC67776A4DC}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {8F140037-DD2A-4035-B86C-323926118022}
+	EndGlobalSection
+EndGlobal

Uitls/CmdHelper.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Model;
+
+namespace TicketSpider.Uitls
+{
+    public static class CmdHelper
+    {
+        /// <summary>
+        /// 航司
+        /// </summary>
+        public static string[]? AIRLINE = null;
+
+        /// <summary>
+        /// 命令模式
+        /// </summary>
+        public static int CMD_MODEL=0;
+
+        /// <summary>
+        /// 航班信息
+        /// </summary>
+        public static List<Flight> FLIGHTS = new List<Flight>();
+
+        /// <summary>
+        /// 乘客信息
+        /// </summary>
+        public static List<Passenger> PASSENGETS = new List<Passenger>();
+    }
+
+}

Uitls/DemoModelHelper.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using TicketSpider.Model;
+
+namespace TicketSpider.Uitls
+{
+    public static class DemoModelHelper
+    {
+        public static List<Passenger> GetTempPassenger()
+        { 
+            var list=new List<Passenger>();
+            list.Add(new Passenger() { 
+                id="",
+                paxName="罗超",
+                paxNameFirst="LUO",
+                paxNameLast="CHAO",
+                gender="M",
+                birthday="19901226",
+                nationality="CN",
+                telephoneCode="86",
+                mobile="17308037817",
+                email="",
+                ffpAirline="",
+                ffpNo="",
+                favorPaxIdDtoList=new List<FavorPaxIdDtoList>() { 
+                    new FavorPaxIdDtoList() {
+                        id="",
+                        favorPaxId="",
+                        idIssueNation="",
+                        idNo="EH7982905",
+                        idType="PP",
+                        idValidDt="",
+                        paxIDType=""
+                    }
+                },
+                paxType=""
+            });
+
+            list.Add(new Passenger()
+            {
+                id = "",
+                paxName = "康琪",
+                paxNameFirst = "Kang",
+                paxNameLast = "Qi",
+                gender = "F",
+                birthday = "20020316",
+                nationality = "CN",
+                telephoneCode = "86",
+                mobile = "17708004866",
+                email = "",
+                ffpAirline = "",
+                ffpNo = "",
+                favorPaxIdDtoList = new List<FavorPaxIdDtoList>() {
+                    new FavorPaxIdDtoList() {
+                        id="",
+                        favorPaxId="",
+                        idIssueNation="",
+                        idNo="EH7982908",
+                        idType="PP",
+                        idValidDt="",
+                        paxIDType=""
+                    }
+                },
+                paxType = ""
+            });
+
+            return list;
+        }
+    }
+}

Uitls/HttpClientHelper.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Uitls
+{
+    public class HttpClientHelper
+    {
+        private static HttpClientHelper httpClientHelper = null;
+
+        private HttpClient httpClient;
+
+        /// <summary>
+        /// 构造方法私有，用于单例
+        /// </summary>
+        private HttpClientHelper() { }
+
+        /// <summary>
+        /// 获取当前类的实例
+        /// </summary>
+        /// <returns></returns>
+        public static HttpClientHelper GetInstance()
+        {
+            if (httpClientHelper != null)
+            {
+                return httpClientHelper;
+            }
+            else
+            {
+                HttpClientHelper httpClientHelper = new HttpClientHelper();
+
+                //取消使用默认的Cookies
+                HttpClientHandler handler = new HttpClientHandler() { UseCookies = false };
+                httpClientHelper.httpClient = new HttpClient(handler);
+                return httpClientHelper;
+            }
+        }
+
+        /// <summary>
+        /// Get方法请求
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <returns></returns>
+        public HttpResponseMessage Get(string url, List<KeyValuePair<string, string>> headers = null)
+        {
+            HttpRequestMessage request = new HttpRequestMessage()
+            {
+                RequestUri = new Uri(url),
+                Method = HttpMethod.Get,
+            };
+            if (headers != null && headers.Count > 0)
+            {
+                request.Headers.Clear();
+
+                foreach (var header in headers)
+                {
+                    request.Headers.Add(header.Key, header.Value);
+
+                }
+            }
+            HttpResponseMessage response = httpClient.SendAsync(request).Result;
+            return response;
+        }
+
+        /// <summary>
+        /// Get方法请求
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <returns></returns>
+        public async Task<(HttpResponseMessage response, CookieContainer cookies)> GetAsync(string url, List<KeyValuePair<string, string>> headers = null)
+        {
+            var handler = new HttpClientHandler();
+            var cookieContainer = new CookieContainer();
+            handler.CookieContainer = cookieContainer;
+            HttpRequestMessage request = new HttpRequestMessage()
+            {
+                RequestUri = new Uri(url),
+                Method = HttpMethod.Get,
+            };
+            if (headers != null && headers.Count > 0)
+            {
+                request.Headers.Clear();
+                foreach (var header in headers)
+                {
+                    request.Headers.Add(header.Key, header.Value);
+                }
+            }
+            var response = await httpClient.SendAsync(request);
+            return (response,cookieContainer);
+        }
+
+        /// <summary>
+        /// Post方法请求 application/x-www-form-urlencoded格式
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <param name="paramList">参数集合</param>
+        /// <returns></returns>
+        public HttpResponseMessage Post(string url, List<KeyValuePair<String, String>> paramList, List<KeyValuePair<string, string>> headers = null)
+        {
+            FormUrlEncodedContent formUrlEncodedContent = new FormUrlEncodedContent(paramList);
+            if (headers != null && headers.Count > 0)
+            {
+                formUrlEncodedContent.Headers.Clear();
+                foreach (var header in headers)
+                {
+                    formUrlEncodedContent.Headers.Add(header.Key, header.Value);
+                }
+            }
+            HttpResponseMessage response = httpClient.PostAsync(new Uri(url), formUrlEncodedContent).Result;
+            return response;
+        }
+
+        public async Task<HttpResponseMessage> PostAsync(string url, List<KeyValuePair<String, String>> paramList, List<KeyValuePair<string, string>> headers = null)
+        {
+            FormUrlEncodedContent formUrlEncodedContent = new FormUrlEncodedContent(paramList);
+            if (headers != null && headers.Count > 0)
+            {
+                formUrlEncodedContent.Headers.Clear();
+                foreach (var header in headers)
+                {
+                    formUrlEncodedContent.Headers.Add(header.Key, header.Value);
+                }
+            }
+            return await httpClient.PostAsync(new Uri(url), formUrlEncodedContent);
+        }
+
+        /// <summary>
+        /// Post方法请求 raw data
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <param name="content">raw data</param>
+        /// <returns></returns>
+        public HttpResponseMessage Post(string url, string content, List<KeyValuePair<string, string>> headers = null)
+        {
+            StringContent stringContent = new StringContent(content, Encoding.UTF8);
+            if (headers != null && headers.Count > 0)
+            {
+                stringContent.Headers.Clear();
+                foreach (var header in headers)
+                {
+                    stringContent.Headers.Add(header.Key, header.Value);
+                }
+            }
+
+            HttpResponseMessage response = httpClient.PostAsync(new Uri(url), stringContent).Result;
+            return response;
+        }
+
+        /// <summary>
+        /// Post方法请求 raw data
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <param name="content">raw data</param>
+        /// <returns></returns>
+        public async Task<HttpResponseMessage> PostAsync(string url, string content, List<KeyValuePair<string, string>> headers = null)
+        {
+            StringContent stringContent = new StringContent(content, Encoding.UTF8,"");
+            if (headers != null && headers.Count > 0)
+            {
+                stringContent.Headers.Clear();
+                foreach (var header in headers)
+                {
+                    stringContent.Headers.Add(header.Key, header.Value);
+                }
+            }
+            return await httpClient.PostAsync(new Uri(url), stringContent);
+
+        }
+
+        /// <summary>
+        /// 释放httpclient
+        /// </summary>
+        public void Release()
+        {
+            httpClient.Dispose();
+        }
+
+
+
+        /// <summary>
+        /// 设置默认请求头
+        /// </summary>
+        /// <param name="name"></param>
+        /// <param name="value"></param>
+        public void SetDefaultHeaders(string name, string value)
+        {
+            httpClient.DefaultRequestHeaders.Add(name, value);
+        }
+
+        /// <summary>
+        /// 删除默认请求头
+        /// </summary>
+        /// <param name="name"></param>
+        public void RemoveDefaultHeaders(string name)
+        {
+            httpClient.DefaultRequestHeaders.Remove(name);
+        }
+    }
+}

Uitls/TaskHelper.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Uitls
+{
+    public class TaskHelper
+    {
+        public static CancellationTokenSource cancelTokenSource = new CancellationTokenSource();
+
+        private static TaskHelper taskHelper=null;
+
+        private static object taskHelperLock = new object();
+
+        private static object ticketLock = new object();
+
+        //public event Action CancelEvent;
+        private static bool TICKET_EXSITS = false;
+
+        public bool UpdateTicketStatus()
+        {
+            lock (ticketLock)
+            {
+                if (!TICKET_EXSITS)
+                {
+                    TICKET_EXSITS = true;
+                    return true;
+                }
+                else return false;
+            }
+        }
+
+        public void UnLockOrderStatus()
+        {
+            TICKET_EXSITS = false;
+        }
+
+        public static TaskHelper GetInstance()
+        {
+            if (taskHelper == null)
+            {
+                lock (taskHelperLock) 
+                {
+                    if (taskHelper == null) taskHelper = new TaskHelper();
+                }
+            }
+            return taskHelper;
+        }
+
+        public void FinishTask()
+        { 
+            cancelTokenSource.Cancel();
+        }
+
+        public void WatchCancel()
+        {
+            while (!cancelTokenSource.IsCancellationRequested)
+            {
+                Thread.Sleep(1000);
+            }
+            Console.WriteLine("警卫：所有线程立即停止");
+            //CancelEvent?.Invoke();
+        }
+    }
+}

Uitls/WebSiteHtmlLoader.cs

+using OpenQA.Selenium.Remote;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace TicketSpider.Uitls
+{
+    public class WebSiteHtmlLoader : IDisposable
+    {
+        private readonly RemoteWebDriver _remoteWebDriver;
+
+        public WebSiteHtmlLoader(RemoteWebDriver remoteWebDriver)
+        {
+            if (remoteWebDriver == null) throw new ArgumentNullException("remoteWebDriver");
+            _remoteWebDriver = remoteWebDriver;
+        }
+
+        public string GetRenderedHtml(Uri webSiteUri)
+        {
+            if (webSiteUri == null) throw new ArgumentNullException("webSiteUri");
+            _remoteWebDriver.Navigate().GoToUrl(webSiteUri);
+
+            return _remoteWebDriver.PageSource;
+        }
+
+        public void Dispose()
+        {
+            Dispose(true);
+            GC.SuppressFinalize(this);
+        }
+
+        private void Dispose(bool disposing)
+        {
+            if (disposing)
+            {
+                if (_remoteWebDriver != null)
+                {
+                    _remoteWebDriver.Quit();
+                }
+            }
+        }
+    }
+}