添加推送押金奖励

AppStart/GetHaoDaFTPInfoService.cs

@@ -113,6 +113,7 @@ namespace MySystem
                 if (!string.IsNullOrEmpty(fileContents))
                 {
                     WebCMSEntities db = new WebCMSEntities();
+                    MpMainModels2.WebCMSEntities mpdb2 = new MpMainModels2.WebCMSEntities();
                     var DataInfo = fileContents.TrimEnd('\n').Split('\n', 2);
                     if(DataInfo.Length > 1)
                     {
@@ -194,9 +195,23 @@ namespace MySystem
                                 Status = 1,
                             });
                             db.SaveChanges();
+
+                            //推送MQ给创业帮
+                            var merchantAddInfo = mpdb2.MerchantAddInfo.FirstOrDefault(m => m.MchtNo == MerNo) ?? new MpMainModels2.MerchantAddInfo();
+                            if (merchantAddInfo.BrandId == 1)
+                            {
+                                SortedList<string, string> obj = new SortedList<string, string>();
+                                obj.Add("create_time", ActDateString);
+                                obj.Add("sn", SnNo);
+                                obj.Add("deposit", Deposit);
+                                obj.Add("merch_no", merchantAddInfo.MchtNo);
+                                obj.Add("maker_code", merchantAddInfo.CybMakerCode);
+                                PushHelper.Instance.Do(obj, "cashNotify");
+                            }
                         }
                     }
                     db.Dispose();
+                    mpdb2.Dispose();
                 }
 
                 // 关闭响应

Util/PushHelper.cs

@@ -16,11 +16,11 @@ namespace MySystem
         {
         }
 
-        string NoticeUrl = "http://cybsp.888cyb.com/v1/cybsp/transNotify/hd";
+        string NoticeUrl = "http://cybsp.888cyb.com/v1/cybsp/{path}/hd";
         string AesSecret = "kvS4TIRh7Yulg4nr";
 
         //要执行的方法
-        public void Do(SortedList<string, string> obj)
+        public void Do(SortedList<string, string> obj, string path = "transNotify")
         {
             string PushData = "";
             string PushDataEncrypt = "";
@@ -36,8 +36,8 @@ namespace MySystem
             string requestJson = Newtonsoft.Json.JsonConvert.SerializeObject(obj);
             PushDataEncrypt = requestJson;
             LogHelper.Instance.WriteLog("请求参数：" + PushDataEncrypt, "好哒推送数据日志");
-            LogHelper.Instance.WriteLog("请求地址：" + NoticeUrl, "好哒推送数据日志");
-            string result = function.PostWebRequest(NoticeUrl, requestJson, "application/json");
+            LogHelper.Instance.WriteLog("请求地址：" + NoticeUrl.Replace("{path}", path), "好哒推送数据日志");
+            string result = function.PostWebRequest(NoticeUrl.Replace("{path}", path), requestJson, "application/json");
             LogHelper.Instance.WriteLog("返回报文：" + result + "\n\n", "好哒推送数据日志");
         }        
     }