From 67a0042c5f29e4bb0e0b82f6190f2bc51480b45c Mon Sep 17 00:00:00 2001
From: username@email.com <yzy2002yzy@163.com>
Date: 星期二, 28 二月 2023 13:25:09 +0800
Subject: [PATCH] 工资绩效改版

---
 zhengcaioa/Crawler/Program.cs |   38 ++++++++++++++++++++++++++++++++++++--
 1 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/zhengcaioa/Crawler/Program.cs b/zhengcaioa/Crawler/Program.cs
index 9889a6a..2d4b5d6 100644
--- a/zhengcaioa/Crawler/Program.cs
+++ b/zhengcaioa/Crawler/Program.cs
@@ -19,7 +19,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 api_domain = "http://192.168.0.15: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 api_domain = "http://172.26.97.184:9200";
         static void Main(string[] args)
         {
 
@@ -142,6 +147,10 @@
             Thread thread1 = new Thread(new ThreadStart(obj.Method2));
             thread1.Start();
 
+
+            Thread thread2 = new Thread(new ThreadStart(obj.Method3));
+            thread2.Start();
+
             Console.WriteLine("Hello World!");
         }
 
@@ -152,8 +161,12 @@
                 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);
+
                 //鑾峰彇鍥涘窛鐨勬斂閲囨暟鎹�
-                sichuanoperation.operations(cccontext);
+                sichuanoperation.operations(cccontext, cccontext1);
                 //Console.WriteLine("杩欎釜鏆傚仠");
                 Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
             }
@@ -166,13 +179,34 @@
                 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);
+                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);
+
+                //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
+                //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
+
+                //鑾峰彇涓浗鏀块噰缃戠殑鍥涘窛鏀块噰鏁版嵁
+                CcgpSichuanoperation.operations(cccontext);
+                Thread.CurrentThread.Join(1000 * 60 * 10);//闃绘璁惧畾鏃堕棿
+            }
+        }
+
 
 
 

--
Gitblit v1.9.1