Browse Source

广电卡绑定队列打开,监听事件为60天

lcl 2 năm trước cách đây
mục cha
commit
6369735fcb
2 tập tin đã thay đổi với 6 bổ sung6 xóa
  1. 1 1
      AppStart/Helper/SycnSpServer/SycnSpBindService.cs
  2. 5 5
      Startup.cs

+ 1 - 1
AppStart/Helper/SycnSpServer/SycnSpBindService.cs

@@ -178,7 +178,7 @@ namespace MySystem
                 {
                     WebCMSEntities spdb = new WebCMSEntities();
                     PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
-                    DateTime start = DateTime.Now.AddDays(-5);
+                    DateTime start = DateTime.Now.AddDays(-60);
                     int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/BindRecordId.txt")));
                     var Binds = spdb.BindRecord.Select(m => new { m.Id, m.CreateTime, m.Status, m.MerNo, m.MerSnNo, m.ProductType, m.Remark, m.Field1, m.Field2, m.Field3, m.Field5, m.SeoTitle, m.SeoKeyword }).Where(m => m.Id >= StartId && m.CreateTime >= start && m.ProductType == "14" && m.Status == 1).OrderByDescending(m => m.Id).ToList();
                     foreach (var Bind in Binds)

+ 5 - 5
Startup.cs

@@ -167,7 +167,7 @@ namespace MySystem
             if(Library.ConfigurationManager.EnvironmentFlag == 2)
             {
                 SycnSpBindService.Instance.Start(); //同步SP绑定数据
-                // SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
+                SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
                 SycnSpMerchantService.Instance.Start(); //同步SP商户数据
                 SycnSpActiveService.Instance.Start(); //同步SP激活数据
                 SycnSpTradeService.Instance.Start(); //同步SP交易数据
@@ -272,10 +272,10 @@ namespace MySystem
         {
             string conn = Configuration["Setting:SqlConnStr"];
             string dbName = "KxsMainServer";
-            // if(Library.ConfigurationManager.EnvironmentFlag == 2)
-            // {
-            //     dbName = "KxsProfitServer";
-            // }
+            if(Library.ConfigurationManager.EnvironmentFlag == 2)
+            {
+                dbName = "KxsProfitServer";
+            }
             Dictionary<string, Dictionary<string, string>> tables = new Dictionary<string, Dictionary<string, string>>();
             System.Data.DataTable tablecollection = Library.CustomerSqlConn.dtable("select DISTINCT TABLE_NAME from information_schema.columns where table_schema = '" + dbName + "'", conn);
             foreach (System.Data.DataRow subtable in tablecollection.Rows)