写入原始表需要写入链接

AppStart/StartHelper.cs

@@ -12,9 +12,9 @@
             int Environment = Library.ConfigurationManager.EnvironmentFlag; //运行环境（1-开发环境，2-生产环境）
             if(Environment == 2)
             {
-                // SourceHelper.Instance.Start(); //获取原始数据队列
+                SourceHelper.Instance.Start(); //获取原始数据队列
                 // PushHelper.Instance.Start(); //推送队列
-                RePushHelper.Instance.Start(); //重新推送队列
+                // RePushHelper.Instance.Start(); //重新推送队列
 
                 // DefaultHelper.Instance.Start(); //队列程序
                 // ......其他队列程序

Config/Base.cs

@@ -8,6 +8,7 @@ namespace AppConfig
         public static string ApiKey = "G6H7@J8%";
         public static string SqlConnStr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
         public static string SourceSqlConnStr = ConfigurationManager.AppSettings["SourceSqlConnStr"].ToString();
+        public static string RmSourceSqlConnStr = ConfigurationManager.AppSettings["RmSourceSqlConnStr"].ToString();
         public static string Host = Library.ConfigurationManager.AppSettings["Host"].ToString();
         public static string SourceHost = Library.ConfigurationManager.AppSettings["SourceHost"].ToString();
         public static string Database = Library.ConfigurationManager.AppSettings["Database"].ToString();

Util/Queue/SourceHelper.cs

@@ -175,7 +175,7 @@ namespace MySystem
                     }
                     insertSql += "insert into u_" + TableName + " (" + TargetQueryField.TrimEnd(',') + ") values (" + values.TrimEnd(',') + ");";
                     StartId = int.Parse(dr["Id"].ToString());
-                    CustomerSqlConn.op("update " + TableName + " set " + FlagField + "=1 where Id=" + StartId, AppConfig.Base.SourceSqlConnStr);
+                    CustomerSqlConn.op("update " + TableName + " set " + FlagField + "=1 where Id=" + StartId, AppConfig.Base.RmSourceSqlConnStr);
                 }
                 var edit = db.SourceData.FirstOrDefault(m => m.Id == source.Id);
                 if(edit != null)

appsettings.Development.json

@@ -14,6 +14,7 @@
     "Database": "KxsPushServer",
     "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsPushServer;password=DaMSJxexJMW7i0Jb;database=KxsPushServer;charset=utf8;",
     "SourceSqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer;charset=utf8;",
+    "RmSourceSqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer;charset=utf8;",
     "RedisConnStr": "47.109.31.237:6379,password=klm@redis,DefaultDatabase=1,poolsize=500,preheat=50,asyncPipeline=true",
     "IOSAppVersion": "1.0.0",
     "AndroidAppVersion": "1.0.0",