lcl hace 5 meses
padre
commit
50a0d2ef21
Se han modificado 1 ficheros con 4 adiciones y 0 borrados
  1. 4 0
      Util/Queue/PosPushHelper.cs

+ 4 - 0
Util/Queue/PosPushHelper.cs

@@ -53,6 +53,7 @@ namespace MySystem
         public void DoSomeThing(string content)
         public void DoSomeThing(string content)
         {
         {
             string url = "";
             string url = "";
+            function.WriteLog(DateTime.Now.ToString() + "\n" + content, "统一推送日志");
             JsonData jsonObj = JsonMapper.ToObject(content);
             JsonData jsonObj = JsonMapper.ToObject(content);
             string dataType = jsonObj["data_type"].ToString();
             string dataType = jsonObj["data_type"].ToString();
             string dataContent = jsonObj["data_content"].ToJson();
             string dataContent = jsonObj["data_content"].ToJson();
@@ -61,9 +62,12 @@ namespace MySystem
             if(dataType == "trade") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/trade";
             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 == "deposit") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/cash";
             if(dataType == "active") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/extActData";
             if(dataType == "active") url = "http://gateway.kexiaoshuang.com/v1/kxs/statServer/sp/extActData";
+            function.WriteLog("url:" + url, "统一推送日志");
             string encryptContent = AesEncrypt(dataContent);
             string encryptContent = AesEncrypt(dataContent);
             encryptContent = Convert.ToBase64String(Encoding.UTF8.GetBytes(encryptContent));
             encryptContent = Convert.ToBase64String(Encoding.UTF8.GetBytes(encryptContent));
+            function.WriteLog("encryptContent:" + encryptContent, "统一推送日志");
             string res = PostWebRequest(url, encryptContent, new Dictionary<string, string>());
             string res = PostWebRequest(url, encryptContent, new Dictionary<string, string>());
+            function.WriteLog("res:" + res + "\n\n\n", "统一推送日志");
             if(!res.Contains("\"status\""))
             if(!res.Contains("\"status\""))
             {
             {
                 SaveToDb(dataContent, encryptContent, dataType);
                 SaveToDb(dataContent, encryptContent, dataType);