推送机具数据

AppStart/StartHelper.cs

@@ -16,6 +16,8 @@
                 PushHelper.Instance.Start(); //推送队列
                 RePushHelper.Instance.Start(); //重新推送队列
                 AliyunPushHelper.Instance.Start(); //阿里云消息推送
+                PosPushHelper.Instance.Start(); //推送机具数据
+                PosRePushHelper.Instance.Start(); //重推送机具数据
 
                 // DefaultHelper.Instance.Start(); //队列程序
                 // ......其他队列程序

Util/Queue/PosPushHelper.cs

@@ -55,21 +55,23 @@ namespace MySystem
             string url = "";
             JsonData jsonObj = JsonMapper.ToObject(content);
             string dataType = jsonObj["data_type"].ToString();
+            string dataContent = jsonObj["data_content"].ToString();
             if(dataType == "bind") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/binding";
             if(dataType == "un_bind") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/unbind";
             if(dataType == "trade") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/trade";
             if(dataType == "deposit") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/cash";
-            string encryptContent = AesEncrypt(content);
+            if(dataType == "active") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/extActData";
+            string encryptContent = AesEncrypt(dataContent);
             string res = PostWebRequest(url, encryptContent, new Dictionary<string, string>());
             if(!res.Contains("\"status\""))
             {
-                SaveToDb(content, encryptContent, dataType);
+                SaveToDb(dataContent, encryptContent, dataType);
                 return;
             }
             JsonData backObj = JsonMapper.ToObject(res);
             if(backObj["status"].ToString() != "1")
             {
-                SaveToDb(content, encryptContent, dataType);
+                SaveToDb(dataContent, encryptContent, dataType);
                 return;
             }
         }

Util/Queue/PosRePushHelper.cs

@@ -56,6 +56,7 @@ namespace MySystem
                 if(dataType == "un_bind") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/unbind";
                 if(dataType == "trade") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/trade";
                 if(dataType == "deposit") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/cash";
+                if(dataType == "active") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/extActData";
                 string res = PostWebRequest(url, sub.EncryptContent, new Dictionary<string, string>());
                 if(res.Contains("\"status\""))
                 {

appsettings.Development.json

@@ -12,7 +12,7 @@
     "OssHost": "",
     "SourceHost": "",
     "Database": "KxsPushServer",
-    "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsPushServer;password=DaMSJxexJMW7i0Jb;database=KxsPushServer;charset=utf8;",
+    "SqlConnStr": "server=47.108.62.166;port=3306;user=KxsPushServer;password=0j3sEGdlvOsgGbat;database=KxsPushServer;charset=utf8;",
     "SourceSqlConnStr": "server=47.108.62.166;port=3306;user=root;password=HDlNs1ZpG5iR9D9I;database=KxsMainServer;charset=utf8;",
     "RmSourceSqlConnStr": "server=47.108.62.166;port=3306;user=root;password=HDlNs1ZpG5iR9D9I;database=KxsMainServer;charset=utf8;",
     "RedisConnStr": "47.108.62.166:6379,password=klm@redis,DefaultDatabase=1,poolsize=500,preheat=50,asyncPipeline=true",