Bladeren bron

补订单数据

lcl 1 jaar geleden
bovenliggende
commit
e445df4ac1
2 gewijzigde bestanden met toevoegingen van 33 en 26 verwijderingen
  1. 21 26
      Controllers/HomeController.cs
  2. 12 0
      Util/HaoDa/WeChatPayBackService.cs

+ 21 - 26
Controllers/HomeController.cs

@@ -38,31 +38,26 @@ 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("2023123120272680842405573", 30.08M);
-            // ids.Add("2023110823050361106411696", 162.39M);
-            // ids.Add("2023103111150680882895028", 129.97M);
-            // ids.Add("2023110115111893112798296", 186.66M);
-            // ids.Add("2023110119350047351848839", 219.15M);
-            // ids.Add("2023103121092345128864326", 132.51M);
-            // ids.Add("2023110119465569176817757", 219.16M);
-            // ids.Add("2023110119570851706448968", 219.16M);
-            // ids.Add("2023110119282078572281345", 208.32M);
-            // ids.Add("2023103111025117492478602", 151.62M);
-            // ids.Add("2023103111023104266492281", 129.96M);
-            // ids.Add("2023103111020866149098706", 140.79M);
-            // ids.Add("2023103111014803279616494", 162.45M);
-            // ids.Add("2023103111011872712858973", 173.28M);
-            foreach(string orderno in ids.Keys)
-            {
-                decimal cur = ids[orderno];
-                ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == orderno) ?? new ConsumerOrders();
-                order.CurDivi = cur;
-                order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"UpdateDate\":\".*?\"", "\"UpdateDate\":\"" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + "\"");
-                order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"ProfitDays\":.*?,", "\"ProfitDays\":90,");
-                RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
-            }
+            // WebCMSEntities db = new WebCMSEntities();
+            // Dictionary<string, decimal> ids = new Dictionary<string, decimal>();
+            // ids.Add("2023123120272680842405573", 30.08M);
+            // foreach(string orderno in ids.Keys)
+            // {
+            //     decimal cur = ids[orderno];
+            //     ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == orderno) ?? new ConsumerOrders();
+            //     order.CurDivi = cur;
+            //     order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"UpdateDate\":\".*?\"", "\"UpdateDate\":\"" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + "\"");
+            //     order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"ProfitDays\":.*?,", "\"ProfitDays\":90,");
+            //     RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
+            // }
+
+            // string content = function.ReadInstance("/222.log");
+            // string[] contents = content.Split('\n');
+            // foreach(string sub in contents)
+            // {
+            //     // RedisDbconn.Instance.AddList("WeChatPayBackHd", sub);
+            //     RedisDbconn.Instance.AddList("PartOrderQueue", sub);
+            // }
 
             // List<int> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:2:1272").Select(m => m.Id).ToList();
             // DataTable dt = CustomerSqlConn.dtable("select OrderId,sum(GetMoney) money from ConsumerProfit where MerchantId=1272 group by OrderId order by OrderId", AppConfig.Base.SqlConnStr);
@@ -150,7 +145,7 @@ namespace MySystem.Controllers
             //     function.WriteLog("\n\n", "返现id");
             // }
 
-            db.Dispose();
+            // db.Dispose();
 
             // decimal settleAmount = b / 100M;
             // decimal divideAmt = (1 - 0.0038M) * a;

+ 12 - 0
Util/HaoDa/WeChatPayBackService.cs

@@ -51,9 +51,11 @@ namespace MySystem
 
         public void dosomething(string content)
         {
+            LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + content, "微信支付回调监控");
             JsonData jsonObj = JsonMapper.ToObject(content);
             if (jsonObj.Count > 0)
             {
+                LogHelper.Instance.WriteLog("json通过", "微信支付回调监控");
                 string OrderNo = jsonObj["outOrderNo"].ToString();
                 string HdOrderNo = jsonObj["orderNo"].ToString();
                 string TradeNo = "";
@@ -61,16 +63,21 @@ namespace MySystem
                 {
                     TradeNo = jsonObj["payChannelOrderNo"].ToString();
                 }
+                LogHelper.Instance.WriteLog("OrderNo:" + OrderNo, "微信支付回调监控");
+                LogHelper.Instance.WriteLog("HdOrderNo:" + HdOrderNo, "微信支付回调监控");
+                LogHelper.Instance.WriteLog("TradeNo:" + TradeNo, "微信支付回调监控");
                 WebCMSEntities db = new WebCMSEntities();
                 ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == OrderNo && m.Status == 0);
                 if (order != null)
                 {
+                    LogHelper.Instance.WriteLog("找到订单", "微信支付回调监控");
                     order.Status = 1;
                     order.UpdateDate = DateTime.Now;
                     order.PayMoney = order.PayMoney;
                     order.MaxDivi = order.MaxDivi;
                     order.SeoTitle = HdOrderNo;
                     order.SeoKeyword = TradeNo;
+                    LogHelper.Instance.WriteLog("赋值", "微信支付回调监控");
                     MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantInfo();
                     MerchantAddInfo addinfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantAddInfo();
                     if(addinfo.Status == 1 && order.PayMode == 2)
@@ -86,6 +93,7 @@ namespace MySystem
                         addinfo.AlipayRemark = "";
                     }
                     order.UserId = merchant.UserId;
+                    LogHelper.Instance.WriteLog("创客:" + merchant.UserId, "微信支付回调监控");
                     ConsumerOrders check = db.ConsumerOrders.FirstOrDefault(m => m.Id < order.Id && m.Status > 0 && m.PayMode == order.PayMode && m.MerchantId == order.MerchantId);
                     if (check != null)
                     {
@@ -96,6 +104,7 @@ namespace MySystem
                         order.QueryCount = 1;
                     }
                     db.SaveChanges();
+                    LogHelper.Instance.WriteLog("检测商户订单数:" + order.QueryCount, "微信支付回调监控");
 
                     Models.Main1.WebCMSEntities db1 = new Models.Main1.WebCMSEntities();
                     var machines = db1.PosMachines.Select(m => new { m.SeoDescription, m.DeviceKind, m.BrandId, m.Detail, m.BindMerchantId }).Where(m => m.DeviceKind == "2" && m.BindMerchantId == order.MerchantId);
@@ -115,9 +124,12 @@ namespace MySystem
                         }
                     }
                     db1.Dispose();
+                    LogHelper.Instance.WriteLog("执行完毕", "微信支付回调监控");
                 }
                 db.Dispose();
+                LogHelper.Instance.WriteLog("结束", "微信支付回调监控");
             }
+            LogHelper.Instance.WriteLog("\n\n", "微信支付回调监控");
         }
 
         //分账队列