激活推送mq

AppStart/Helper/ActiveRewardService.cs

@@ -53,6 +53,7 @@ namespace MySystem
                 {
                     edit.Status = 2;
                     db.SaveChanges();
+                    Utils.Instance.SendActData(db.MerchantInfo.FirstOrDefault(m => m.Id == edit.MerchantId) ?? new MerchantInfo(), 4);
                 }
             }
             db.Dispose();

AppStart/Helper/CheckAlipaySignService.cs

@@ -107,6 +107,7 @@ namespace MySystem
                                         if(merchant.Status < 2 && merchant.QueryCount < 2)
                                         {
                                             RedisDbconn.Instance.AddList("MpMerchantActQueue", "{\"userId\":\"" + merchant.UserId + "\",\"statDate\":\"" + DateTime.Now.ToString("yyyyMMdd") + "\",\"statMonth\":\"" + DateTime.Now.ToString("yyyyMM") + "\"}");
+                                            Utils.Instance.SendActData(merchant);
                                         }
                                         merchant.QueryCount = 2;
                                         if (merchant.SignDate == null)
@@ -130,6 +131,7 @@ namespace MySystem
                                     if(merchant.Status < 2 && merchant.QueryCount < 2)
                                     {
                                         RedisDbconn.Instance.AddList("MpMerchantActQueue", "{\"userId\":\"" + merchant.UserId + "\",\"statDate\":\"" + DateTime.Now.ToString("yyyyMMdd") + "\",\"statMonth\":\"" + DateTime.Now.ToString("yyyyMM") + "\"}");
+                                        Utils.Instance.SendActData(merchant);
                                     }
                                     merchant.QueryCount = 2;
                                     if (merchant.SignDate == null)

AppStart/Helper/CheckWeChatSignService.cs

@@ -98,6 +98,7 @@ namespace MySystem
                             if(merchant.Status < 2 && merchant.QueryCount < 2)
                             {
                                 RedisDbconn.Instance.AddList("MpMerchantActQueue", "{\"userId\":\"" + merchant.UserId + "\",\"statDate\":\"" + DateTime.Now.ToString("yyyyMMdd") + "\",\"statMonth\":\"" + DateTime.Now.ToString("yyyyMM") + "\"}");
+                                Utils.Instance.SendActData(merchant);
                             }
                             merchant.Status = 2;
                             if(merchant.SignDate == null)

Utils/Utils.cs

@@ -0,0 +1,37 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Library;
+using MySystem.Models;
+
+namespace MySystem
+{
+    public class Utils
+    {
+        public readonly static Utils Instance = new Utils();
+        private Utils()
+        { }
+
+        #region 推送激活数据信息
+
+        public void SendActData(MerchantInfo pos, int actType = 3)
+        {
+            string data = "{";
+            data += "\"userId\":\"" + pos.UserId + "\",";
+            data += "\"brandId\":\"2\",";
+            data += "\"actTime\":\"" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\",";
+            data += "\"bindTime\":\"" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\",";
+            data += "\"sn\":\"\",";
+            data += "\"actType\":\"" + actType + "\"";
+            data += "}";
+            function.WriteLog(DateTime.Now.ToString() + "\n" + data, "订单推送MQ日志");
+            RedisDbconn.Instance.AddList("KxsOrderQueue", data);
+        }
+
+        #endregion 
+    
+    
+    
+    
+    }
+}