放开返现队列

Startup.cs

@@ -147,7 +147,7 @@ namespace MySystem
                 MerchantConfirmService.Instance.Start(); //提交商户进件
                 CheckWeChatSignService.Instance.Start(); //查询商户审核状态
                 CheckWeChatBindService.Instance.Start(); //执行好哒微信绑定appid
-                // ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
+                ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
                 // ProfitShareService.Instance.StartCheck(); //复核头一天的分账
                 HaoDaExtHelper.Instance.StartWeChat();
                 HaoDaExtHelper.Instance.StartAlipay();

Util/HaoDa/ProfitShareService.cs

@@ -26,31 +26,31 @@ namespace MySystem
         {
             while (true)
             {
-                // WebCMSEntities db = new WebCMSEntities();
-                // DateTime checkDate = DateTime.Now.AddMinutes(-2);
-                // var list = db.ConsumerOrders.Select(m => new { m.Id, m.DivideDate, m.DivideFlag, m.IsAct, m.PayMode }).Where(m => m.DivideFlag == 1 && m.IsAct == 1 && m.DivideDate < checkDate).OrderBy(m => m.Id).Take(100).ToList();
-                // foreach (var sub in list)
-                // {
-                //     RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + sub.PayMode + ":List", sub.Id.ToString());
-                //     ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == sub.Id);
-                //     if (order != null)
-                //     {
-                //         order.DivideFlag = 2;
-                //         db.SaveChanges();
-                //     }
-                // }
-                // db.Dispose();
-                // Thread.Sleep(5000);
-
-                string content = RedisDbconn.Instance.RPop<string>("PartOrderStatusQueue");
-                if(!string.IsNullOrEmpty(content))
+                WebCMSEntities db = new WebCMSEntities();
+                DateTime checkDate = DateTime.Now.AddMinutes(-2);
+                var list = db.ConsumerOrders.Select(m => new { m.Id, m.DivideDate, m.DivideFlag, m.IsAct, m.PayMode }).Where(m => m.DivideFlag == 1 && m.IsAct == 1 && m.DivideDate < checkDate).OrderBy(m => m.Id).Take(100).ToList();
+                foreach (var sub in list)
                 {
-                    StartExcute(content);
-                }
-                else
-                {
-                    Thread.Sleep(60000);
+                    RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + sub.PayMode + ":List", sub.Id.ToString());
+                    ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == sub.Id);
+                    if (order != null)
+                    {
+                        order.DivideFlag = 2;
+                        db.SaveChanges();
+                    }
                 }
+                db.Dispose();
+                Thread.Sleep(5000);
+
+                // string content = RedisDbconn.Instance.RPop<string>("PartOrderStatusQueue");
+                // if(!string.IsNullOrEmpty(content))
+                // {
+                //     StartExcute(content);
+                // }
+                // else
+                // {
+                //     Thread.Sleep(60000);
+                // }
             }
         }