节点操作放开请求队列

Areas/Api/Controllers/v1/Main1/ConsumerOrdersController.cs

@@ -190,14 +190,14 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
             ConsumerOrders query = new ConsumerOrders();
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
             query = ConsumerOrdersService.Query(id);
-            // if(query.PayMoney == 2)
-            // {
-            //     RedisDbconn.Instance.AddList("AddWeChatDiviQueue", id.ToString());
-            // }
-            // else if(query.PayMoney == 1)
-            // {
-            //     RedisDbconn.Instance.AddList("AddAlipayDiviQueue", id.ToString());
-            // }
+            if(query.PayMoney == 2)
+            {
+                RedisDbconn.Instance.AddList("AddWeChatDiviQueue", id.ToString());
+            }
+            else if(query.PayMoney == 1)
+            {
+                RedisDbconn.Instance.AddList("AddAlipayDiviQueue", id.ToString());
+            }
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion

Areas/Api/Controllers/v1/Main1/MerchantAddInfoController.cs

@@ -344,7 +344,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
             JsonData data = JsonMapper.ToObject(value);
             Dictionary<string, object> Obj = new Dictionary<string, object>();
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
-            // RedisDbconn.Instance.AddList("MerchantConfirmQueue", "{\"MerchantId\":\"" + id + "\",\"Kind\":\"2\"}");
+            RedisDbconn.Instance.AddList("MerchantConfirmQueue", "{\"MerchantId\":\"" + id + "\",\"Kind\":\"2\"}");
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion
@@ -363,7 +363,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
             JsonData data = JsonMapper.ToObject(value);
             Dictionary<string, object> Obj = new Dictionary<string, object>();
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
-            // RedisDbconn.Instance.AddList("MerchantConfirmQueue", "{\"MerchantId\":\"" + id + "\",\"Kind\":\"1\"}");
+            RedisDbconn.Instance.AddList("MerchantConfirmQueue", "{\"MerchantId\":\"" + id + "\",\"Kind\":\"1\"}");
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion
@@ -388,15 +388,15 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
             Obj.Add("WeChatRemark", query.WeChatRemark); //微信备注
             Obj.Add("WeChatMerchantId", query.WeChatMerchantId); //微信商户号
             Obj.Add("Status", query.Status); //微信审核状态
-            // if(query.Status < 1)
-            // {
-            //     RedisDbconn.Instance.AddList("WeChatSignQueue", new MerchantSign()
-            //     {
-            //         BusinessCode = query.BusinessCode,
-            //         MerchantAddInfoId = id,
-            //         Status = ""
-            //     });
-            // }
+            if(query.Status < 1)
+            {
+                RedisDbconn.Instance.AddList("WeChatSignQueue", new MerchantSign()
+                {
+                    BusinessCode = query.BusinessCode,
+                    MerchantAddInfoId = id,
+                    Status = ""
+                });
+            }
 
             return Obj;
         }
@@ -424,15 +424,15 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
             Obj.Add("AlipayRemark", query.AlipayRemark); //支付宝备注
             Obj.Add("Status", query.QueryCount); //支付宝审核状态
 
-            // if(query.Status < 1)
-            // {
-            //     RedisDbconn.Instance.AddList("AlipaySignQueue", new MerchantSign()
-            //     {
-            //         BusinessCode = query.SeoTitle,
-            //         MerchantAddInfoId = id,
-            //         Status = ""
-            //     });
-            // }
+            if(query.Status < 1)
+            {
+                RedisDbconn.Instance.AddList("AlipaySignQueue", new MerchantSign()
+                {
+                    BusinessCode = query.SeoTitle,
+                    MerchantAddInfoId = id,
+                    Status = ""
+                });
+            }
 
             return Obj;
         }

Areas/Api/Controllers/v1/Main2/ConsumerOrdersController.cs

@@ -187,7 +187,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
             JsonData data = JsonMapper.ToObject(value);
             Dictionary<string, object> Obj = new Dictionary<string, object>();
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
-            // RedisDbconn.Instance.AddList("AddHdDiviQueue", id.ToString());
+            RedisDbconn.Instance.AddList("AddHdDiviQueue", id.ToString());
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion

Areas/Api/Controllers/v1/Main2/MerchantAddInfoController.cs

@@ -312,7 +312,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
             JsonData data = JsonMapper.ToObject(value);
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
             Dictionary<string, object> Obj = new Dictionary<string, object>();                        
-            // RedisDbconn.Instance.AddList("WeChatForHaoDaQueue", id.ToString());
+            RedisDbconn.Instance.AddList("WeChatForHaoDaQueue", id.ToString());
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion
@@ -331,7 +331,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
             JsonData data = JsonMapper.ToObject(value);
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
             Dictionary<string, object> Obj = new Dictionary<string, object>();                        
-            // RedisDbconn.Instance.AddList("AlipayForHaoDaQueue", id.ToString());
+            RedisDbconn.Instance.AddList("AlipayForHaoDaQueue", id.ToString());
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion
@@ -350,7 +350,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
             JsonData data = JsonMapper.ToObject(value);
             int id = int.Parse(function.CheckInt(data["id"].ToString()));
             Dictionary<string, object> Obj = new Dictionary<string, object>();                        
-            // RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + id + "\"}");
+            RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + id + "\"}");
             return new AppResultJson() { Status = "1", Info = "", Data = Obj };
         }
         #endregion