|
@@ -128,7 +128,7 @@ namespace MySystem
|
|
|
function.WriteLog("人数:" + CurDiviPersons, "返现逻辑日志");
|
|
|
while (CurDiviPersons > 0)
|
|
|
{
|
|
|
- ConsumerOrders suborder = RedisDbconn.Instance.RPopLPush<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, "ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
|
|
|
+ ConsumerOrders suborder = RedisDbconn.Instance.RPop<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
|
|
|
if (suborder != null)
|
|
|
{
|
|
|
function.WriteLog("返现对象订单:" + suborder.Id, "返现逻辑日志");
|
|
@@ -185,12 +185,12 @@ namespace MySystem
|
|
|
if (suborder.CurDivi < suborder.MaxDivi)
|
|
|
{
|
|
|
function.WriteLog("返现未达最大值继续", "返现逻辑日志");
|
|
|
- // RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
|
|
|
+ RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
function.WriteLog("返现达最大值,出局", "返现逻辑日志");
|
|
|
- RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
|
|
|
+ // RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
|
|
|
OutCount += 1;
|
|
|
}
|
|
|
Thread.Sleep(1000);
|