@@ -214,5 +214,22 @@ namespace MySystem.Controllers
return "ok";
}
+
+ public string clearQueue(int OrderId, int MerchantId, int PayMode)
+ {
+ List<ConsumerOrders> list = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId + "", 1, 100000);
+ foreach(ConsumerOrders sub in list)
+ if(sub.Id == OrderId)
+ RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:2:1272", sub);
+ }
+ return "ok";
@@ -148,6 +148,13 @@ namespace MySystem
#endregion
+ #region 移除列表对象
+ public long DelFromList(string key, object value, int count = 1)
+ return RedisHelper.LRem(key, count, value);
+ #endregion
#region 添加排序列表对象
public long AddSort(string key, object value, decimal score)
{