清多余的返现记录

退款成功才加记录

Controllers/HomeController.cs

@@ -37,36 +37,55 @@ namespace MySystem.Controllers
             // TianYuVoiceHelper.Instance.doSomething(DateTime.Now.ToString("yyyyMMddHHmmssfff"),"2023100701","100");
             // MqLinksHelper.Instance.doSomething("LKB01230600250000585","100");
 
-            WebCMSEntities db = new WebCMSEntities();
-            Dictionary<string, decimal> ids = new Dictionary<string, decimal>();
-            ids.Add("2023110210011368216017215", 262.47M);
-            ids.Add("2023110209582965570227565", 251.64M);
-            ids.Add("2023110209574326337435601", 251.64M);
-            ids.Add("2023110209560893881718314", 251.65M);
-            ids.Add("2023110209543045040095492", 262.47M);
-            ids.Add("2023110120300992564524492", 229.98M);
-            ids.Add("2023110117085160175731898", 197.50M);
-            ids.Add("2023110211572884957467004", 284.14M);
-            ids.Add("2023110120413202804978303", 229.95M);
-            ids.Add("2023110420031422808138102", 216.61M);
-            ids.Add("2023110209551553040540156", 251.64M);
-            ids.Add("2023110113114323483481218", 175.83M);
-            ids.Add("2023110119412078375206313", 208.34M);
-            ids.Add("2023110119333924371118894", 208.32M);
-            ids.Add("2023110100013510004332936", 165.01M);
-            ids.Add("2023110100001381586035192", 175.85M);
-            ids.Add("2023110316204063871545838", 54.15M);
-            ids.Add("2023110117044613033713627", 197.49M);
-            ids.Add("2023103116455918116251045", 132.51M);
-            ids.Add("2023110115043281646491586", 186.68M);
-            foreach(string orderno in ids.Keys)
-            {
-                decimal cur = ids[orderno];
-                ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == orderno) ?? new ConsumerOrders();
-                order.CurDivi = cur;
-                RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
-            }
-            db.Dispose();            
+            // WebCMSEntities db = new WebCMSEntities();
+            // Dictionary<string, decimal> ids = new Dictionary<string, decimal>();
+            // ids.Add("2023110210011368216017215", 262.47M);
+            // foreach(string orderno in ids.Keys)
+            // {
+            //     decimal cur = ids[orderno];
+            //     ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == orderno) ?? new ConsumerOrders();
+            //     order.CurDivi = cur;
+            //     RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
+            // }
+
+            // List<int> ids = new List<int>();
+            // ids.Add(4058);
+            // List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:2:1271");
+            // foreach(int oid in ids)
+            // {
+            //     function.WriteLog("oid:" + oid, "返现id");
+            //     decimal curDivi = 0;
+            //     ConsumerOrders order = orders.FirstOrDefault(m => m.Id == oid);
+            //     if(order == null)
+            //     {
+            //         order = db.ConsumerOrders.FirstOrDefault(m => m.Id == oid);
+            //         curDivi = order.MaxDivi;
+            //         function.WriteLog("出局", "返现id");
+            //     }
+            //     else
+            //     {
+            //         function.WriteLog("未出局", "返现id");
+            //         curDivi = order.CurDivi;
+            //     }
+            //     if(order != null)
+            //     {
+            //         List<ConsumerProfit> profits = db.ConsumerProfit.Where(m => m.OrderId == oid).ToList();
+            //         foreach(ConsumerProfit profit in profits)
+            //         {
+            //             if(curDivi >= profit.GetMoney)
+            //             {
+            //                 curDivi -= profit.GetMoney; 
+            //             }
+            //             else
+            //             {
+            //                 function.WriteLog(profit.Id.ToString(), "返现id");
+            //             }
+            //         }
+            //     }
+            //     function.WriteLog("\n\n", "返现id");
+            // }
+
+            // db.Dispose();            
 
             return "ok";
         }

Util/HaoDa/ProfitHelper.cs

@@ -147,19 +147,6 @@ namespace MySystem
                                                 if (GetMoney > minProfit)
                                                 {
                                                     suborder.CurDivi += GetMoney;
-                                                    ConsumerProfit cprofit = db.ConsumerProfit.Add(new ConsumerProfit()
-                                                    {
-                                                        CreateDate = DateTime.Now,
-                                                        ConsumerId = suborder.ConsumerId,
-                                                        MerchantId = suborder.MerchantId,
-                                                        OrderId = suborder.Id,
-                                                        GetMoney = Math.Round(GetMoney, 2),
-                                                        QueryCount = PayMode,
-                                                        Sort = OrderId,
-                                                        SeoTitle = suborder.OrderNo,
-                                                        SeoKeyword = suborder.PayMoney.ToString(),
-                                                    }).Entity;
-                                                    db.SaveChanges();
                                                     MerchantAddInfo merchantAdd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == suborder.MerchantId) ?? new MerchantAddInfo();
                                                     
                                                     //聚合支付退款
@@ -169,6 +156,22 @@ namespace MySystem
                                                     {
                                                         function.WriteLog("请求退款接口", "返现逻辑日志");
                                                         var info = HaoDaHelper.Instance.AggregatedPayRefund(merchantAdd.OutMchtNo, merchantAdd.StoreNo, "HDTK" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8), suborder.OrderNo, RefundAmount.ToString("f0"));
+                                                        if(info.Contains("\"resultCode\":\"1\""))
+                                                        {
+                                                            db.ConsumerProfit.Add(new ConsumerProfit()
+                                                            {
+                                                                CreateDate = DateTime.Now,
+                                                                ConsumerId = suborder.ConsumerId,
+                                                                MerchantId = suborder.MerchantId,
+                                                                OrderId = suborder.Id,
+                                                                GetMoney = Math.Round(GetMoney, 2),
+                                                                QueryCount = PayMode,
+                                                                Sort = OrderId,
+                                                                SeoTitle = suborder.OrderNo,
+                                                                SeoKeyword = suborder.PayMoney.ToString(),
+                                                            });
+                                                            db.SaveChanges();
+                                                        }
                                                         function.WriteLog("接口返回:" + info, "返现逻辑日志");
                                                         orderids.Add(suborder.Id);
                                                     }