投诉处理，爬

username@email.com

3 天以前 d4431c7e89865a506af8662244004d0baa7ed609

 zhengcaioa/Crawler/Program.cs

@@ -20,10 +20,12 @@

        //public static string connection = @"server=.;database=WebCrawler;uid=sa;pwd=123456;";
        //public static string connection1 = @"server=.;database=zhengcaioa;uid=sa;pwd=123456;";
        //public static string connection2 = @"server=.;database=FZCZTB;uid=sa;pwd=123456;";
        //public static string api_domain = "http://192.168.0.9:9200";

        public static string connection = @"server=172.26.97.184;database=WebCrawler;uid=sa;pwd=Za20222812;";
        public static string connection1 = @"server=172.26.97.184;database=zhengcaioa;uid=sa;pwd=Za20222812;";
        public static string connection2 = @"server=172.26.97.184;database=FZCZTB;uid=sa;pwd=Za20222812;";
        public static string api_domain = "http://172.26.97.184:9200";
        static void Main(string[] args)
        {
@@ -140,7 +142,7 @@

            Program obj = new Program();
            //方法一：调用线程执行方法，在方法中实现死循环，每个循环Sleep设定时间
            Thread thread = new Thread(new ThreadStart(obj.Method1));
            Thread thread = new Thread(new ThreadStart(obj.Method));
            thread.Start();


@@ -154,58 +156,76 @@
            Console.WriteLine("Hello World!");
        }

        void Method1()
        void Method()
        {
            while (true)
            {
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
                //ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
                var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
                var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
                var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection2).Options);

                var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
                var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
                //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
                //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);

                //获取四川的政采数据
                sichuanoperation.operations(cccontext, cccontext1);
                //获取四川的投诉处理数据
                sichuantousuoperation.operations(cccontext);
                //Console.WriteLine("这个暂停");
                Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//阻止设定时间
            }
        }

        void Method2()
        {
            while (true)
            {
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
                var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
                var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
        //void Method1()
        //{
        //    while (true)
        //    {
        //        ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
        //        var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
        //        var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);

                var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
                var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
        //        var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
        //        var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);

                //获取四川的政采数据
                OldSichuanoperation.operations(cccontext, cccontext1);
                Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//阻止设定时间
            }
        }
        //        //获取四川的政采数据
        //        sichuanoperation.operations(cccontext, cccontext1);
        //        //Console.WriteLine("这个暂停");
        //        Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//阻止设定时间
        //    }
        //}

        //void Method2()
        //{
        //    while (true)
        //    {
        //        ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
        //        var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
        //        var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);

        //        var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
        //        var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);

        //        //获取四川的政采数据
        //        OldSichuanoperation.operations(cccontext, cccontext1);
        //        Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//阻止设定时间
        //    }
        //}


        void Method3()
        {
            while (true)
            {
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
                var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
                var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
        //void Method3()
        //{
        //    while (true)
        //    {
        //        ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
        //        var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
        //        var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);

                //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
                //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
        //        //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
        //        //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);

                //获取中国政采网的四川政采数据
                CcgpSichuanoperation.operations(cccontext);
                Thread.CurrentThread.Join(1000 * 60 * 10);//阻止设定时间
            }
        }
        //        //获取中国政采网的四川政采数据
        //        CcgpSichuanoperation.operations(cccontext);
        //        Thread.CurrentThread.Join(1000 * 60 * 10);//阻止设定时间
        //    }
        //}