Kaynağa Gözat

修复返现队列重复返现问题

lcl 1 yıl önce
ebeveyn
işleme
8a86d40e96

+ 5 - 1
Util/HaoDa/ProfitHelper.cs

@@ -131,7 +131,7 @@ namespace MySystem
                                     function.WriteLog("人数:" + CurDiviPersons, "返现逻辑日志");
                                     while (CurDiviPersons > 0)
                                     {
-                                        ConsumerOrders suborder = RedisDbconn.Instance.RPop<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
+                                        ConsumerOrders suborder = RedisDbconn.Instance.RPopLPush<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, "ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
                                         if (suborder != null)
                                         {
                                             decimal TmpCurDivi = suborder.CurDivi;
@@ -244,6 +244,10 @@ namespace MySystem
                             }
                         }
                     }
+                    else
+                    {
+                        function.WriteLog("没找到订单:" + orderidstring, "返现逻辑日志");
+                    }
                     tran.Commit();
                 }
                 catch (Exception ex)

+ 6 - 0
Util/HaoDa/WeChatPayBackService.cs

@@ -126,6 +126,12 @@ namespace MySystem
                     db1.Dispose();
                     LogHelper.Instance.WriteLog("执行完毕", "微信支付回调监控");
                 }
+                else
+                {
+                    LogHelper.Instance.WriteLog("没找到订单", "微信支付回调监控");
+                    Thread.Sleep(2000);
+                    RedisDbconn.Instance.AddList("WeChatPayBackHd", content);
+                }
                 db.Dispose();
                 LogHelper.Instance.WriteLog("结束", "微信支付回调监控");
             }