暂存

Util/HaoDa/AddNewMerchantSetUtil.cs

@@ -59,14 +59,14 @@ namespace MySystem
             List<ImageItem> imageList = new List<ImageItem>();
             ImageItem imageItem = new ImageItem();
             //开户许可证
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.OpenAccountLicenses))
             {
                 imageItem.name = "openAccountLicenses";
                 imageItem.value = AddInfo.OpenAccountLicenses;
                 imageList.Add(imageItem);
             }
             //租赁协议
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.RentAgreement))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "rentAgreement";
@@ -74,7 +74,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //盒伙人商户合影
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.OperatorMcht))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "operatorMcht";
@@ -82,7 +82,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //营业执照
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.LicenseCopy))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "license";
@@ -90,7 +90,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //委托结算协议
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.AgentProtocol))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "agentProtocol";
@@ -98,7 +98,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //商户签名图片
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.SignaturePicture))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "signaturePicture";
@@ -106,7 +106,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //辅助照片
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.Support))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "support";
@@ -122,7 +122,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //收银台
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.CheckstandImg))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "checkstandImg";
@@ -130,7 +130,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //店铺全景
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.IndoorPic))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "shopInnerImg";
@@ -138,7 +138,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //商品照片
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.ProductImg))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "productImg";
@@ -146,7 +146,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //合同签名
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.Agreement))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "agreement";
@@ -154,7 +154,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //税务登记证
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.TaxImage))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "taxImage";
@@ -162,7 +162,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //组织机构证照片
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.OrganizationCopy))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "orgImage";
@@ -170,7 +170,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //行业许可证
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.IndustryLicense1))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "industryLicense1";
@@ -178,7 +178,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //正面人像图片
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.FaceRecognition))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "faceRecognition";
@@ -186,7 +186,7 @@ namespace MySystem
                 imageList.Add(imageItem);
             }
             //补充资料
-            if(!string.IsNullOrEmpty(AddInfo.StoreEntrancePic))
+            if(!string.IsNullOrEmpty(AddInfo.Extra1))
             {
                 imageItem = new ImageItem();
                 imageItem.name = "extra1";

Util/HaoDa/HaoDaHelper.cs

@@ -111,6 +111,7 @@ namespace MySystem
             reqdic.Add("confirmCode", confirmCode); //支付确认码，由4位纯数字组成，每次请求时随机生成	
             reqdic.Add("subAppId", subAppId); //公众号或者小程序appId	
             reqdic.Add("subAppIdType", subAppIdType); //subAppId 对应的类型，默认为公众号， SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序
+            reqdic.Add("ledgerModel", ledgerModel); //分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段
 
             string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
             function.WriteLog(req, "好哒微信公众号和小程序支付");
@@ -132,10 +133,11 @@ namespace MySystem
         /// <param name="storeNo">盒子的门店编码</param>
         /// <param name="outOrderNo">商户订单号</param>
         /// <param name="transAmount">交易金额，单位：分</param>
+        /// <param name="callbackUrl">交易完成之后，商户接收交易结果通知的地址</param>
         /// <param name="subOpenId">支付宝用户标识</param>
         /// <param name="confirmCode">支付确认码，由4位纯数字组成，每次请求时随机生成</param>
         /// <returns></returns>
-        public string Alipay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string subOpenId, string confirmCode)
+        public string Alipay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode)
         {
             function.WriteLog(DateTime.Now.ToString(), "好哒支付宝服务窗支付");
             Dictionary<string, object> reqdic = new Dictionary<string, object>();
@@ -143,6 +145,7 @@ namespace MySystem
             reqdic.Add("storeNo", storeNo); //盒子的门店编码	
             reqdic.Add("outOrderNo", outOrderNo); //商户订单号
             reqdic.Add("transAmount", transAmount); //交易金额，单位：分	
+            reqdic.Add("callbackUrl", callbackUrl); //交易完成之后，商户接收交易结果通知的地址
             reqdic.Add("subOpenId", subOpenId); //支付宝用户标识	
             reqdic.Add("confirmCode", confirmCode); //支付确认码，由4位纯数字组成，每次请求时随机生成
 

Util/HaoDa/ProfitHelper.cs

@@ -1,2022 +1,229 @@
-// using System;
-// using System.Collections.Generic;
-// using System.Linq;
-// using System.Data;
-// using MySystem.Models.Main;
-// using Library;
-// using System.Threading;
-// using Microsoft.Extensions.Hosting;
-// using System.Threading.Tasks;
-
-// namespace MySystem
-// {
-//     public class ProfitHelper
-//     {
-//         public readonly static ProfitHelper Instance = new ProfitHelper();
-//         private ProfitHelper()
-//         {
-//         }
-        
-//         #region 激活队列
-//         public void StartActive()
-//         { 
-//             Thread th = new Thread(StartListenActive);
-//             th.IsBackground = true;
-//             th.Start();
-//         }
-//         public void StartListenActive()
-//         {
-//             while (true)
-//             {
-//                 string content = RedisDbconn.Instance.RPop<string>("ActProfitQueue");
-//                 if (!string.IsNullOrEmpty(content))
-//                 {
-//                     StartListenActiveDo(content);
-//                 }
-//                 else
-//                 {
-//                     Thread.Sleep(60000);
-//                 }
-//             }
-//         }
-//         public void StartListenActiveDo(string content)
-//         { 
-//             try
-//             {
-//                 int MerchantId = int.Parse(content);
-//                 KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
-//                 WebCMSEntities db = new WebCMSEntities();
-//                 bool check = db.ActiveReward.Any(m => m.MerchantId == MerchantId);
-//                 if (!check)
-//                 {
-//                     decimal ActPrize = 50;
-//                     MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId) ?? new MerchantInfo();
-//                     PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == MerchantId) ?? new PosMachinesTwo();
-//                     db.ActiveReward.Add(new ActiveReward()
-//                     {
-//                         CreateDate = DateTime.Now,
-//                         UpdateDate = DateTime.Now,
-//                         UserId = merchant.UserId, //创客
-//                         MerchantId = merchant.Id, //商户
-//                         StandardDate = DateTime.Now, //达标日期
-//                         RewardAmount = ActPrize, //奖励金额
-//                         DirectBuddyNo = merchant.UserId, //商户直属创客
-//                         KqSnNo = pos.PosSn, //渠道SN号
-//                         SnType = pos.PosSnType, //机具类型
-//                         SnApplyUserId = pos.BuyUserId, //机具申请创客
-//                         SnStoreId = pos.StoreId, //SN仓库
-//                         RewardTips = "达标奖励", //奖励描述
-//                         Remark = "达标奖励", //备注
-//                         ActDate = pos.ActivationTime, //激活时间
-//                     });
-//                     db.SaveChanges();
-//                     int GetUserId = merchant.UserId;
-//                     KxsMainModels.UserAccount account = kxsdb.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
-//                     if (account == null)
-//                     {
-//                         account = kxsdb.UserAccount.Add(new KxsMainModels.UserAccount()
-//                         {
-//                             Id = GetUserId,
-//                             UserId = GetUserId,
-//                         }).Entity;
-//                         kxsdb.SaveChanges();
-//                     }
-//                     decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-//                     decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-//                     decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-//                     account.BalanceAmount += ActPrize;
-//                     account.TotalAmount += ActPrize;
-//                     decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-//                     decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-//                     decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-//                     KxsMainModels.UserAccountRecord userAccountRecord = kxsdb.UserAccountRecord.Add(new KxsMainModels.UserAccountRecord()
-//                     {
-//                         CreateDate = DateTime.Now,
-//                         UpdateDate = DateTime.Now,
-//                         UserId = GetUserId, //创客
-//                         ChangeType = 131, //变动类型
-//                         ChangeAmount = ActPrize, //变更金额
-//                         BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
-//                         AfterTotalAmount = AfterTotalAmount, //变更后总金额
-//                         BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
-//                         AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
-//                         BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
-//                         AfterBalanceAmount = AfterBalanceAmount, //变更后余额
-//                     }).Entity;
-//                     kxsdb.SaveChanges();
-//                 }
-//                 kxsdb.Dispose();
-//                 db.Dispose();
-//             }
-//             catch (Exception ex)
-//             {
-//                 function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "激活奖励服务异常");
-//             }
-//         }
-//         #endregion
-
-//         #region 消费队列(执行消费退款金额的统计)
-//         public void StartListenTrade()
-//         {
-//             Thread th = new Thread(StartListenTradeDo);
-//             th.IsBackground = true;
-//             th.Start();
-//         }
-//         public void StartListenTradeDo()
-//         {
-//             while (true)
-//             {
-//                 string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrders:Divi:1:List");
-//                 if (!string.IsNullOrEmpty(orderidstring))
-//                 {
-//                     ReturnStat(orderidstring, 1);
-//                 }
-//                 else
-//                 {
-//                     Thread.Sleep(60000);
-//                 }
-//             }
-//         }
-
-//         public void StartListenWxTrade()
-//         {
-//             Thread th = new Thread(StartListenWxTradeDo);
-//             th.IsBackground = true;
-//             th.Start();
-//         }
-//         public void StartListenWxTradeDo()
-//         {
-//             while (true)
-//             {
-//                 string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrders:Divi:2:List");
-//                 if (!string.IsNullOrEmpty(orderidstring))
-//                 {
-//                     ReturnStat(orderidstring, 2);
-//                 }
-//                 else
-//                 {
-//                     Thread.Sleep(10000);
-//                 }
-//             }
-//         }
-
-//         public void ReturnStat(string orderidstring, int PayMode)
-//         { 
-//             int OrderId = int.Parse(function.CheckInt(orderidstring));
-//             WebCMSEntities db = new WebCMSEntities();
-//             using (var tran = db.Database.BeginTransaction())
-//             {
-//                 try
-//                 {
-//                     ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == OrderId);
-//                     if (order != null)
-//                     {
-//                         decimal PayMoney = order.PayMoney;
-//                         int MerchantId = order.MerchantId;
-//                         MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
-//                         if (merchant != null)
-//                         {
-//                             int UserId = merchant.UserId;
-//                             List<CustomTagSet> customTagSets = db.CustomTagSet.ToList(); //获取公用配置参数集和
-//                             //获取参数
-//                             CustomTagSet profitPercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerProfitPercent") ?? new CustomTagSet();
-//                             decimal profitPercent = decimal.Parse(function.CheckNum(profitPercentSet.Contents)); //基于收款金额的总分润比例;
-//                             CustomTagSet cusumerFeePercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerFeePercent") ?? new CustomTagSet();
-//                             decimal cusumerFeePercent = decimal.Parse(function.CheckNum(cusumerFeePercentSet.Contents)); //费率;
-//                             CustomTagSet minProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "MinProfit") ?? new CustomTagSet();
-//                             decimal minProfit = decimal.Parse(function.CheckNum(minProfitSet.Contents)); //最小分润值;
-
-//                             MerchantParamSet set = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
-//                             int DiviPersons = set.DiviPersons; //单笔订单分红人数
-//                             decimal DiviPercent = set.DiviPercent; //单人最大分红比例
-//                             int ProfitDays = set.ProfitDays; //分红期限（天）
-//                             decimal GetPercent = set.GetPercent / 100; //商家实收比例
-//                             decimal MinPayMoney = set.MinPayMoney; //订单参与门槛
-//                             int IsAll = set.IsAll; //是否收全额
-//                             // decimal TotalActual = 0;
-//                             if (IsAll == 0 && PayMoney >= MinPayMoney && GetPercent < 1)
-//                             {
-//                                 decimal DiviMoney = PayMoney * (1 - GetPercent - cusumerFeePercent - profitPercent);
-//                                 if (DiviMoney > 0)
-//                                 {
-//                                     RedisDbconn.Instance.AddRightList("ConsumerOrders:Divi:" + PayMode + ":" + order.MerchantId, order);
-//                                     DiviMoney = DiviMoney / DiviPersons;
-//                                     List<int> deletes = new List<int>();
-//                                     long CurDiviPersons = DiviPersons;
-//                                     long QueueCount = RedisDbconn.Instance.Count("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
-//                                     long CurQueueCount = QueueCount;
-//                                     // int CheckNum = 0; //判断活动人数是否大于当前队列订单数来确认while循环的数量，如果是就少循环一次，判处自己的订单名额
-//                                     if (CurDiviPersons >= CurQueueCount)
-//                                     {
-//                                         CurDiviPersons = CurQueueCount;
-//                                     }
-//                                     if (DiviPersons < QueueCount)
-//                                     {
-//                                         QueueCount = DiviPersons;
-//                                     }
-//                                     decimal OtherMoney = 0; // 退款金额>最大退款金额-当前退款金额，次金额应归还给商户
-
-//                                     // List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
-//                                     // foreach(ConsumerOrders sub in orders)
-//                                     // {
-//                                     //     function.WriteLog(sub.Id.ToString(), "返现队列");
-//                                     // }
-//                                     // function.WriteLog("\n\n", "返现队列");
-
-//                                     // 减去自己付的订单
-//                                     // CurDiviPersons = CurDiviPersons - 1;
-//                                     int OutCount = 0; // 出局人数
-//                                     while (CurDiviPersons > 0)
-//                                     {
-//                                         ConsumerOrders suborder = RedisDbconn.Instance.RPop<ConsumerOrders>("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
-//                                         if (suborder != null)
-//                                         {
-//                                             MerchantParamSet subset = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
-//                                             int subProfitDays = subset.ProfitDays; //分红期限（天）
-//                                             bool IsOut = suborder.UpdateDate.Value.AddDays(subProfitDays) < DateTime.Now ? true : false;
-//                                             if (suborder.CurDivi < suborder.MaxDivi && !IsOut)
-//                                             {
-//                                                 //如果没过期并且当前退款金额没超过最大退款金额，就执行
-//                                                 decimal GetMoney = suborder.MaxDivi - suborder.CurDivi;
-//                                                 decimal DiffMoney = 0;
-//                                                 if (GetMoney >= DiviMoney)
-//                                                 {
-//                                                     GetMoney = DiviMoney;
-//                                                 }
-//                                                 else
-//                                                 {
-//                                                     DiffMoney = DiviMoney - GetMoney;
-//                                                 }
-//                                                 if (GetMoney > minProfit)
-//                                                 {
-//                                                     suborder.CurDivi += GetMoney;
-//                                                     if (DiffMoney > 0)
-//                                                     {
-//                                                         OtherMoney += DiffMoney;
-//                                                     }
-//                                                     ConsumerProfit cprofit = db.ConsumerProfit.Add(new ConsumerProfit()
-//                                                     {
-//                                                         CreateDate = DateTime.Now,
-//                                                         ConsumerId = suborder.ConsumerId,
-//                                                         MerchantId = suborder.MerchantId,
-//                                                         OrderId = suborder.Id,
-//                                                         GetMoney = GetMoney,
-//                                                         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();
-//                                                     if(order.PayMode == 1)
-//                                                     {
-//                                                         AlipayFunction.Instance.Refund(suborder.SeoTitle, GetMoney.ToString("f2"), "门店分红", merchantAdd.AlipayAuthToken);
-//                                                     }
-//                                                     else
-//                                                     {
-//                                                         Dictionary<string, string> dic = WeChatFunction.Instance.Refund(merchantAdd.SubMchid, GetMoney, suborder.PayMoney, suborder.OrderNo, DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8), "门店分红");
-//                                                     }
-//                                                     if (suborder.CurDivi < suborder.MaxDivi)
-//                                                     {
-//                                                         RedisDbconn.Instance.AddList("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId, suborder);
-//                                                     }
-//                                                     else
-//                                                     {
-//                                                         OutCount += 1;
-//                                                     }
-//                                                 }
-//                                             }
-//                                             else
-//                                             { 
-//                                                 //否者计算人数不计入退款名额
-//                                                 CurDiviPersons += 1;
-//                                             }
-//                                         }
-//                                         CurDiviPersons -= 1;
-//                                         QueueCount = RedisDbconn.Instance.Count("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
-//                                         if (QueueCount == 0)
-//                                         {
-//                                             CurDiviPersons = 0;
-//                                         }
-//                                     }
-//                                     // long DoCount = DiviPersons > (QueueCount + OutCount) ? DiviPersons - QueueCount : 0;
-//                                     // decimal MerchantGetMoney = PayMoney * GetPercent;
-//                                     // decimal DoMoney = DoCount * DiviMoney;
-//                                     // TotalActual = PayMoney * GetPercent + DoCount * DiviMoney + OtherMoney;
-//                                     // function.WriteLog("返现金额：" + DiviMoney + ";返现人数：" + DiviPersons + ";返现商户：" + TotalActual + ";返现溢出：" + OtherMoney + ";商户应得金额：" + MerchantGetMoney + ";返现差额：" + DoMoney + ";", "消费者返现日志");
-
-
-//                                     //代理商分润
-//                                     // AgentProfit(db, order);
-//                                 }
-//                             }
-//                         }
-//                     }
-//                     tran.Commit();
-//                 }
-//                 catch (Exception ex)
-//                 {
-//                     function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
-//                     tran.Rollback();
-//                 }
-//             }
-//             db.Dispose();
-//         }
-
-//         public void StartListenProfit()
-//         {
-//             Thread th = new Thread(StartListenProfitDo);
-//             th.IsBackground = true;
-//             th.Start();
-//         }
-
-//         public void StartListenProfitDo()
-//         {
-//             while(true)
-//             {
-//                 if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 0)
-//                 {
-//                     DoProfit();
-//                     Thread.Sleep(600000);
-//                 }
-//                 else
-//                 {
-//                     Thread.Sleep(3600000);
-//                 }
-//             }
-//         }
-
-//         //分润算法
-//         public void DoProfit()
-//         {
-//             string TradeMonth = DateTime.Now.ToString("yyyyMM");
-//             WebCMSEntities dbnew = new WebCMSEntities();
-//             DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", MysqlConn.SqlConnStr);
-//             foreach(DataRow dr in dt.Rows)
-//             {
-//                 int UserId = int.Parse(dr["UserId"].ToString());
-//                 bool IsActive = dr["IsAct"].ToString() == "1";
-//                 decimal TotalAmount = decimal.Parse(dr[2].ToString());
-//                 List<ProfitUsers> users = new List<ProfitUsers>();
-//                 int TopUserId = 0; //顶级创客Id
-//                 Users us = dbnew.Users.FirstOrDefault(a => a.Id == UserId);
-//                 if (us != null)
-//                 {
-//                     string uidstring = us.Id.ToString();
-//                     if (!string.IsNullOrEmpty(us.ParentNav))
-//                     {
-//                         uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
-//                         TopUserId = int.Parse(function.CheckInt(us.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]));
-//                     }
-//                     string[] uidlist = uidstring.Split(',');
-//                     Array.Reverse(uidlist);
-//                     foreach (string uidstr in uidlist)
-//                     {
-//                         int puid = int.Parse(function.CheckInt(uidstr));
-//                         Users pus = dbnew.Users.FirstOrDefault(a => a.Id == puid);
-//                         if (pus != null)
-//                         {
-//                             users.Add(new ProfitUsers()
-//                             {
-//                                 UserId = pus.Id,
-//                                 UserNav = pus.ParentNav,
-//                                 UserLevel = pus.UserLevel,
-//                                 CreateDate = pus.CreateDate.Value,
-//                             });
-//                         }
-//                     }
-//                 }
-//                 List<ProfitResult> list = new List<ProfitResult>();
-//                 list = StartProft(dbnew, TotalAmount, 1, users, IsActive);
-//                 using (var tran = dbnew.Database.BeginTransaction())
-//                 {
-//                     try
-//                     {
-//                         foreach (ProfitResult sub in list)
-//                         {
-//                             if (sub.Message == "分红奖励")
-//                             { 
-//                                 UserAccountRecord accountRecord = dbnew.UserAccountRecord.Add(new UserAccountRecord()
-//                                 {
-//                                     CreateDate = DateTime.Now,
-//                                     UpdateDate = DateTime.Now,
-//                                     UserId = sub.UserId, //创客
-//                                     ChangeType = 11, //变动类型
-//                                     ProductType = 1, //产品类型
-//                                     ChangeAmount = sub.Money, //变更金额
-//                                     Status = -1,
-//                                 }).Entity;
-//                                 dbnew.SaveChanges();
-//                             }
-//                             else
-//                             {
-//                                 int ProfitType = sub.UserId == UserId ? 0 : 1;
-//                                 ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.BrandId == 1 && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
-//                                 if (editprofitrecord == null)
-//                                 {
-//                                     editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
-//                                     {
-//                                         CreateDate = DateTime.Now,
-//                                         UserId = sub.UserId, //创客
-//                                         BrandId = 1, //品牌
-//                                         ProfitType = ProfitType, //创客分润类型
-//                                         TradeMonth = TradeMonth, //交易月
-//                                         TopUserId = TopUserId, //顶级创客
-//                                     }).Entity;
-//                                     dbnew.SaveChanges();
-//                                     string RecordNo = "KPM";
-//                                     int RecordId = editprofitrecord.Id;
-//                                     string RecordIdString = RecordId.ToString();
-//                                     for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
-//                                     {
-//                                         RecordIdString = "0" + RecordIdString;
-//                                     }
-//                                     RecordNo += RecordIdString;
-//                                     editprofitrecord.RecordNo = RecordNo;
-//                                     dbnew.SaveChanges();
-//                                 }
-//                                 editprofitrecord.TradeAmt += TotalAmount; //商户交易总额                            
-//                                 editprofitrecord.DebitCapTradeNum += 1; //商户借记卡封顶交易总笔数
-//                                 decimal ProfitMoney = sub.Money;
-//                                 dbnew.SaveChanges();
-//                             }
-//                         }
-//                         dbnew.SaveChanges();
-//                         tran.Commit();
-//                     }
-//                     catch (Exception ex)
-//                     { 
-//                         tran.Rollback();
-//                         function.WriteLog(ex.ToString(), "分润异常");
-//                     }
-//                 }
-//             }
-//             dbnew.Dispose();
-//         }
-
-//         public void DoActives(WebCMSEntities dbnew, TradeRecord trade_record)
-//         {
-//             if (RedisDbconn.Instance.CheckKey("pobjact" + trade_record.Sort))
-//             {
-//                 List<ProfitObjectsActives> objactives = RedisDbconn.Instance.GetList<ProfitObjectsActives>("pobjact" + trade_record.Sort);
-//                 if (objactives.Count > 0)
-//                 {
-//                     string OtherCondition = " and Type=1";
-//                     if (trade_record.Sort == 1) OtherCondition = " and Type<>1";
-//                     else if (trade_record.Sort == 2) OtherCondition = " and Type<>1";
-//                     else if (trade_record.Sort == 4) OtherCondition = " and Type=2";
-//                     else if (trade_record.Sort == 11) OtherCondition = " and Type=2";
-//                     else if (trade_record.Sort == 14) OtherCondition = " and (Type=1 or Type=3)";
-//                     else if (trade_record.Sort == 6 || trade_record.Sort == 7 || trade_record.Sort == 18) OtherCondition = "";
-//                     else if (trade_record.Sort == 29) OtherCondition = " and Type=2";
-//                     PosMachinesTwo machine = dbnew.PosMachinesTwo.FirstOrDefault(m => m.PosSn == trade_record.SnNo) ?? new PosMachinesTwo();
-//                     if (machine.ActivationState == 0)
-//                     {
-//                         return;
-//                     }
-//                     if (machine.BrandId == 0)
-//                     {
-//                         return;
-//                     }
-//                     Users user = dbnew.Users.FirstOrDefault(m => m.Id == machine.UserId) ?? new Users();
-//                     Users buyuser = dbnew.Users.FirstOrDefault(m => m.Id == machine.BuyUserId) ?? new Users();
-//                     Dictionary<string, ProfitUsers> Users = new Dictionary<string, ProfitUsers>();
-//                     Users.Add("UserId", new ProfitUsers()
-//                     {
-//                         UserId = user.Id,
-//                         UserNav = user.ParentNav,
-//                         UserLevel = user.UserLevel,
-//                     });
-//                     Users.Add("BuyUserId", new ProfitUsers()
-//                     {
-//                         UserId = buyuser.Id,
-//                         UserNav = buyuser.ParentNav,
-//                         UserLevel = buyuser.UserLevel,
-//                     });
-//                     List<ProfitResult> list = StartActiveProft(dbnew, machine, trade_record.SnNo, trade_record.Sort, Users, new ActiveCheckData()
-//                     {
-//                         TableName = "TransactionRecord",
-//                         StatField = "Money",
-//                         CheckField = "pos_sn",
-//                         OtherCondition = OtherCondition,
-//                     });
-//                     foreach (ProfitResult sub in list)
-//                     {
-//                         // dbnew.MybillTable.Add(new MybillTable()
-//                         // {
-//                         //     Content = sub.Message,
-//                         //     Money = sub.Money,
-//                         //     Type = 1,
-//                         //     UserId = sub.UserId,
-//                         //     UserNav = sub.UserNav,
-//                         //     Kind = 2,
-//                         //     CreateDate = DateTime.Now,
-//                         //     SeoTitle = trade_record.SeoTitle,
-//                         //     SeoKeyword = trade_record.SnNo,
-//                         //     Sort = trade_record.Sort,
-//                         //     Status = -3,
-//                         // });
-//                     }
-//                     dbnew.SaveChanges();
-//                 }
-//             }
-//         }
-
-//         //代理商分润算法
-//         public void AgentProfit(WebCMSEntities db, ConsumerOrders order)
-//         {
-//             int MerchantId = order.MerchantId;
-//             decimal PayMoney = order.PayMoney;
-//             MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
-//             if (merchant != null)
-//             {
-//                 List<CustomTagSet> customTagSets = RedisDbconn.Instance.GetList<CustomTagSet>("CustomTagSet", 1, 1000); //获取公用配置参数集和 // TODO: 后台配置
-//                 //获取代理商参数
-//                 CustomTagSet profitPercentSet = customTagSets.FirstOrDefault(m => m.Tags == "AgentProfitPercent") ?? new CustomTagSet();
-//                 decimal profitPercent = decimal.Parse(function.CheckNum(profitPercentSet.Contents)); //基于收款金额的总分润比例;
-//                 CustomTagSet makerProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "AgentMakerProfit") ?? new CustomTagSet();
-//                 decimal makerProfit = decimal.Parse(function.CheckNum(makerProfitSet.Contents)); //创客分润比例;
-//                 CustomTagSet directProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "AgentDirectProfit") ?? new CustomTagSet();
-//                 decimal directProfit = decimal.Parse(function.CheckNum(directProfitSet.Contents)); //直推分润比例;
-//                 CustomTagSet minProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "MinProfit") ?? new CustomTagSet();
-//                 decimal minProfit = decimal.Parse(function.CheckNum(minProfitSet.Contents)); //最小分润值;
-
-//                 string MerAreas = merchant.Areas;
-//                 MerchantParamSet set = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
-//                 decimal ProfitMoney = PayMoney * (1 - set.DiviPercent) * profitPercent;
-//                 Users user = db.Users.FirstOrDefault(m => m.Id == merchant.UserId);
-//                 if (user != null)
-//                 {
-//                     decimal ProfitAmount = ProfitMoney * makerProfit;
-//                     if (ProfitAmount >= minProfit)
-//                     {
-//                         db.ProfitRecord.Add(new ProfitRecord()
-//                         {
-//                             CreateDate = DateTime.Now,
-//                             UpdateDate = DateTime.Now,
-//                             Remark = "分润奖励",
-//                             UserId = user.Id, //创客
-//                             MerchantId = MerchantId, //商户
-//                             SnNo = order.SnNo, //SN号
-//                             TradeDate = order.CreateDate, //交易日期
-//                             ProfitAmount = ProfitAmount, //分润金额
-//                             BrandId = 1, //品牌
-//                             ParentNav = user.ParentNav, //上级创客集
-//                             TradeId = order.Id, //交易记录Id
-//                         });
-//                         db.SaveChanges();
-//                     }
-//                 }
-//                 Users puser = db.Users.FirstOrDefault(m => m.Id == user.ParentUserId);
-//                 if (puser != null)
-//                 {
-//                     decimal ProfitAmount = ProfitMoney * directProfit;
-//                     if (ProfitAmount >= minProfit)
-//                     {
-//                         db.ProfitRecord.Add(new ProfitRecord()
-//                         {
-//                             CreateDate = DateTime.Now,
-//                             UpdateDate = DateTime.Now,
-//                             Remark = "分润奖励",
-//                             UserId = puser.Id, //创客
-//                             MerchantId = MerchantId, //商户
-//                             SnNo = order.SnNo, //SN号
-//                             TradeDate = order.CreateDate, //交易日期
-//                             ProfitAmount = ProfitAmount, //分润金额
-//                             BrandId = 1, //品牌
-//                             ParentNav = puser.ParentNav, //上级创客集
-//                             TradeId = order.Id, //交易记录Id
-//                         });
-//                         db.SaveChanges();
-//                     }
-//                 }
-//                 string[] areaList = MerAreas.Split(',');
-//                 decimal GetMoneyFlag = 0;
-//                 for (int i = 0; i < areaList.Length; i++)
-//                 {
-//                     string CurAreas = "";
-//                     for (int j = 0; j < areaList.Length - i; j++)
-//                     {
-//                         CurAreas += areaList[j] + ",";
-//                     }
-//                     CurAreas = CurAreas.TrimEnd(',');
-//                     int AgentLevel = CurAreas.Split(',').Length;
-//                     Users areaUser = db.Users.FirstOrDefault(m => m.AgentAreas == CurAreas && m.AgentLevel > AgentLevel);
-//                     if (areaUser != null)
-//                     {
-//                         AgentLevelSet agentset = db.AgentLevelSet.FirstOrDefault(m => m.Id == AgentLevel) ?? new AgentLevelSet();
-//                         decimal ProfitAmount = ProfitMoney * agentset.ProfitPercent;
-//                         if (agentset.LevelDiff == 1)
-//                         {
-//                             ProfitAmount -= GetMoneyFlag;
-//                         }
-//                         if (ProfitAmount >= minProfit)
-//                         {
-//                             db.ProfitRecord.Add(new ProfitRecord()
-//                             {
-//                                 CreateDate = DateTime.Now,
-//                                 UpdateDate = DateTime.Now,
-//                                 Remark = "分润奖励",
-//                                 UserId = puser.Id, //创客
-//                                 MerchantId = MerchantId, //商户
-//                                 SnNo = order.SnNo, //SN号
-//                                 TradeDate = order.CreateDate, //交易日期
-//                                 ProfitAmount = ProfitAmount, //分润金额
-//                                 BrandId = 1, //品牌
-//                                 ParentNav = puser.ParentNav, //上级创客集
-//                                 TradeId = order.Id, //交易记录Id
-//                             });
-//                             db.SaveChanges();
-//                             GetMoneyFlag = ProfitAmount;
-//                         }
-//                         ProfitAmount = ProfitMoney * agentset.AreasProfitPercent;
-//                         if (ProfitAmount >= minProfit)
-//                         {
-//                             db.ProfitRecord.Add(new ProfitRecord()
-//                             {
-//                                 CreateDate = DateTime.Now,
-//                                 UpdateDate = DateTime.Now,
-//                                 Remark = "分润奖励",
-//                                 UserId = puser.Id, //创客
-//                                 MerchantId = MerchantId, //商户
-//                                 SnNo = order.SnNo, //SN号
-//                                 TradeDate = order.CreateDate, //交易日期
-//                                 ProfitAmount = ProfitAmount, //分润金额
-//                                 BrandId = 1, //品牌
-//                                 ParentNav = puser.ParentNav, //上级创客集
-//                                 TradeId = order.Id, //交易记录Id
-//                             });
-//                             db.SaveChanges();
-//                         }
-//                     }
-//                 }
-//             }
-//         }
-
-//         // 收款金额：100
-//         // 单笔退款金额 = (收款金额*返现比例 - 已返现金额) > (收款金额 - 收款金额*商家实收比例 - 收款金额*(1 - 商家实收比例)*10% - 手续费（收款金额*0.38%） ) / 返现人数 ? (收款金额 - 收款金额*商家实收比例 - 收款金额*(1 - 商家实收比例)*10% - 手续费（收款金额*0.38%）) / 返现人数 : (收款金额*返现比例 - 已返现金额)
-//         // 分账金额: 收款金额*(1 - 商家实收比例)*10%
-//         // 代理分润金额：   省：75%    市：65%    区县：55%   创客：30%    直推创客：5%
-//         // 区域保护分润金额：省：5%     市：5%     区县：5%
-//         // QE:
-//         /*
-//         条件1(跨区域开发商家)：
-//             A为四川省成都市金牛区代理，B为金牛区创客，C为B推荐的金牛区创客，D为四川省成都市代理，E为四川省代理，F为广东省深圳市南山区代理，G为广东省深圳市代理，H为广东省代理。
-//             C推荐一个广东省深圳市南山区商家，交易金额1000元。
-//         则：
-//             C可得分润 = 分账金额 * 30%
-//             B可得直推分润 = 分账金额 * 5%
-//             A可得分润 = 分账金额 * (55% - 30%)
-//             G可得分润 = 分账金额 * (65% - 55%)
-//             H可得分润 = 分账金额 * (75% - 65%) 
-//             F、G、H可再得区域保护分润 = 分账金额 * 5%
-
-            
-//         条件2(同区域)：
-//             A为四川省成都市金牛区代理，B为金牛区创客，C为B推荐的金牛区创客，D为四川省成都市代理，E为四川省代理
-//             C推荐一个四川省成都市金牛区商家，交易金额1000元。
-//         则：
-//             C可得分润 = 分账金额 * 30%
-//             B可得直推分润 = 分账金额 * 5%
-//             A可得分润 = 分账金额 * (55% - 30%)
-//             D可得分润 = 分账金额 * (65% - 55%)
-//             E可得分润 = 分账金额 * (75% - 65%) 
-//             A、D、E可再得区域保护分润 = 分账金额 * 5%
-
-
-//         条件3(代理断级)：
-//             B为金牛区创客，C为B推荐的金牛区创客，D为四川省成都市代理，E为四川省代理，F为广东省深圳市南山区代理，G为广东省深圳市代理，H为广东省代理。
-//             C推荐一个广东省深圳市南山区商家，交易金额1000元。
-//         则：
-//             C可得分润 = 分账金额 * 30%
-//             B可得直推分润 = 分账金额 * 5%
-//             D可得分润 = 分账金额 * (65% - 30%)
-//             H可得分润 = 分账金额 * (75% - 65%) 
-//             F、G、H可再得区域保护分润 = 分账金额 * 5%
-
-//         */
-
-//         #endregion
-
-//         #region 商户队列
-
-//         public void StartListenMerchantDo(Dictionary<string, string> data, bool bind = false)
-//         {
-            
-//         }
-
-//         #endregion
-
-//         #region 绑定队列
-
-//         public void StartListenBindDo(Dictionary<string, string> data)
-//         {
-//         }
-
-//         #endregion      
-
-
-
-
-//         #region 分润算法
-//         public List<ProfitResult> StartProft(WebCMSEntities dbnew, decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
-//         {
-//             int BrandId = 1;
-//             List<UserLevelSet> levels = RedisDbconn.Instance.GetList<UserLevelSet>("pobjlevel");
-//             List<ProfitResult> result = new List<ProfitResult>();
-//             ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
-//             if (obj.Status == 1) //判断分润是否开启
-//             {
-//                 int maxLevel = obj.MaxLevel; //最大等级
-//                 int maxFloor = obj.MaxFloor; //最大层级
-//                 int maxContinueFloor = RedisDbconn.Instance.Get<int>("pobjconc" + BrandId); //最大继续分润层级
-//                 decimal diffLevelProfit = 0;  //等级级差
-//                 // decimal diffDiviProfit = 0; //分红级差
-//                 int curLevel = 0; //当前层级的会员等级
-//                 for (int curFloor = 1; curFloor <= users.Count; curFloor++)
-//                 {
-//                     ProfitUsers user = new ProfitUsers();
-//                     if (curFloor <= users.Count)
-//                     {
-//                         user = users[curFloor - 1];
-//                     }
-//                     int UserLevel = 1; //user.UserLevel; //当前会员等级
-//                     decimal utrade = RedisDbconn.Instance.Get<decimal>("TeamTradeStat:" + user.UserId + ":" + BrandId + ":" + DateTime.Now.ToString("yyMM"));
-//                     UserLevelSet checklevel = levels.Where(m => m.UpLevelIntegral < utrade).OrderBy(m => m.Id).FirstOrDefault();
-//                     if (checklevel != null)
-//                     {
-//                         UserLevel = checklevel.Id + 1;
-//                     }
-//                     //判断当前创客是否有直推的激活机具，并且在活动时间内
-//                     if (UserLevel == maxLevel && UserLevel == curLevel)
-//                     {
-//                         break;
-//                     }
-//                     if (UserLevel <= maxLevel && UserLevel > curLevel)
-//                     {
-//                         ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
-//                         if (objlevel != null)
-//                         {
-//                             decimal getLevelProfit = 0;  //等级分润
-//                             UserProfitSet profitSet = new UserProfitSet();
-//                             decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
-//                             if (profitPercent > 0)
-//                             {
-//                                 getLevelProfit += TotalAmount * profitPercent;
-//                             }
-//                             decimal money = getLevelProfit;
-//                             getLevelProfit -= diffLevelProfit;
-//                             if (objlevel.LevelDiff == 1)  //判断是否有级差
-//                             {
-//                                 diffLevelProfit = money;
-//                             }
-//                             if (getLevelProfit >= obj.MinProfitVal)
-//                             {
-//                                 result.Add(new ProfitResult()
-//                                 {
-//                                     UserId = user.UserId,
-//                                     UserNav = user.UserNav,
-//                                     Money = getLevelProfit,
-//                                     ProfitRate = profitSet.ProfitRate,
-//                                     ProfitPercent = profitSet.ProfitPercent,
-//                                     AddOrSubRate = profitSet.AddOrSubRate,
-//                                     ProfitRateBase = profitSet.ProfitRateBase,
-//                                 });
-//                             }
-//                         }
-//                     }
-//                     curLevel = UserLevel;
-//                 }
-//             }
-//             return result;
-//         }
-//         #endregion
-
-//         #region 活动奖励算法
-//         public List<ProfitResult> StartActiveProft(WebCMSEntities dbnew, PosMachinesTwo machine, string CheckObject, int ObjectId, Dictionary<string, ProfitUsers> Users, ActiveCheckData StatParam)
-//         {
-//             DateTime Start = machine.ActivationTime.Value;
-//             List<ProfitResult> result = new List<ProfitResult>();
-//             ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + ObjectId);
-//             if (obj.Status == 1) //判断分润是否开启
-//             {
-//                 List<ProfitObjectsActives> objactives = RedisDbconn.Instance.GetList<ProfitObjectsActives>("pobjact" + ObjectId);
-//                 foreach (ProfitObjectsActives objactive in objactives)
-//                 {
-//                     if (objactive.StartDate <= DateTime.Now && objactive.EndDate >= DateTime.Now)
-//                     {
-//                         string UserKey = "UserId";
-//                         decimal ProfitMoney = objactive.ProfitNumber;  //获得数
-//                         decimal FinishNumber = objactive.FinishNumber; //完成数
-//                         string CheckKey = CheckObject + "-" + objactive.Id;
-//                         ProfitObjectsActiveCheck check = dbnew.ProfitObjectsActiveCheck.FirstOrDefault(m => m.CheckData == CheckKey);
-//                         if (ProfitMoney > 0 && check == null)
-//                         {
-//                             int LimitDateKind = objactive.LimitDateKind; //时间限制类型 日月年/自定义
-//                             if (LimitDateKind == 4)
-//                             {
-//                                 DateTime LimitCustomerDate = objactive.LimitCustomerDate.Value; //过期时间
-//                                 if (LimitCustomerDate >= DateTime.Now)
-//                                 {
-//                                     decimal totalTradeMoney = 0;
-//                                     OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
-//                                     string sqlstr = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + LimitCustomerDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
-//                                     DataTable dt = OtherMySqlConn.dtable(sqlstr);
-//                                     if (dt.Rows.Count > 0)
-//                                     {
-//                                         totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
-//                                     }
-//                                     // OtherMySqlConn.connstr = ;
-//                                     if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal)  //达到完成数，发放奖励
-//                                     {
-//                                         result.Add(new ProfitResult()
-//                                         {
-//                                             UserId = Users[UserKey].UserId,
-//                                             UserNav = Users[UserKey].UserNav,
-//                                             Money = ProfitMoney,
-//                                         });
-//                                         dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
-//                                         {
-//                                             CheckData = CheckKey
-//                                         });
-//                                         dbnew.SaveChanges();
-//                                     }
-//                                 }
-//                             }
-//                             else
-//                             {
-//                                 int LimitDateVal = objactive.LimitDateVal; //时间限制值 日月年
-//                                 DateTime checkDate = Start;
-//                                 if (LimitDateKind == 1)
-//                                 {
-//                                     checkDate = checkDate.AddDays(LimitDateVal);
-//                                 }
-//                                 else if (LimitDateKind == 2)
-//                                 {
-//                                     checkDate = checkDate.AddMonths(LimitDateVal);
-//                                 }
-//                                 else if (LimitDateKind == 3)
-//                                 {
-//                                     checkDate = checkDate.AddYears(LimitDateVal);
-//                                 }
-//                                 if (checkDate >= DateTime.Now)
-//                                 {
-//                                     decimal totalTradeMoney = 0;
-//                                     OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
-//                                     string sql = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + checkDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
-//                                     DataTable dt = OtherMySqlConn.dtable(sql);
-//                                     if (dt.Rows.Count > 0)
-//                                     {
-//                                         totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
-//                                     }
-//                                     // OtherMySqlConn.connstr = ;
-//                                     if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal)  //达到完成数，发放奖励
-//                                     {
-//                                         result.Add(new ProfitResult()
-//                                         {
-//                                             UserId = Users[UserKey].UserId,
-//                                             UserNav = Users[UserKey].UserNav,
-//                                             Money = ProfitMoney,
-//                                         });
-//                                         dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
-//                                         {
-//                                             CheckData = CheckKey
-//                                         });
-//                                         dbnew.SaveChanges();
-//                                     }
-//                                 }
-//                             }
-//                         }
-//                     }
-//                 }
-//             }
-//             return result;
-//         }
-//         #endregion
-
-//         #region 激活奖励算法
-//         public ProfitResult ActivationProft(PosMachinesTwo machine, ProfitUsers User)
-//         {
-//             int BrandId = machine.BrandId;
-//             DateTime Start = machine.ActivationTime.Value;
-//             ProfitResult result = new ProfitResult();
-//             if (machine.PosSnType == 1 && machine.UserId != machine.BuyUserId) //循环机具，划拨给其他人，没有激活返现没有循环
-//             { 
-//                 return result;
-//             }
-//             ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
-//             if (obj.Status == 1) //判断分润是否开启
-//             {
-//                 ProfitObjectActivations objact = RedisDbconn.Instance.Get<ProfitObjectActivations>("pobjacti" + BrandId);
-//                 if (objact.StartDate <= DateTime.Now && objact.EndDate >= DateTime.Now)
-//                 {
-//                     int LimitDateKind = objact.LimitDateKind; //时间限制类型 日月年/自定义
-//                     int LimitDateVal = objact.LimitDateVal; //时间限制值 日月年
-//                     decimal ProfitMoney = objact.ProfitNumber;
-//                     int MachineCount = objact.MachineCount;
-//                     DateTime checkDate = Start;
-//                     if (LimitDateKind == 1)
-//                     {
-//                         checkDate = checkDate.AddDays(LimitDateVal);
-//                     }
-//                     else if (LimitDateKind == 2)
-//                     {
-//                         checkDate = checkDate.AddMonths(LimitDateVal);
-//                     }
-//                     else if (LimitDateKind == 3)
-//                     {
-//                         checkDate = checkDate.AddYears(LimitDateVal);
-//                     }
-//                     else if (LimitDateKind == 4)
-//                     {
-//                         checkDate = objact.LimitCustomerDate.Value;
-//                     }
-//                     // if (DateTime.Now > checkDate && ProfitMoney > objact.ExpiredNumber)
-//                     // {
-//                     //     ProfitMoney = objact.ExpiredNumber;
-//                     // }
-//                     if (ProfitMoney >= obj.MinProfitVal)
-//                     {
-//                         result = new ProfitResult()
-//                         {
-//                             UserId = User.UserId,
-//                             UserNav = User.UserNav,
-//                             Money = ProfitMoney,
-//                             MachineCount = MachineCount,
-//                         };
-//                     }
-//                 }
-//             }
-//             return result;
-//         }
-//         #endregion
-
-//         #region 获取分润规则Id
-
-//         private int GetLevelKindId(int BrandId, int Help, int BankCardType)
-//         {
-//             return RedisDbconn.Instance.Get<int>("pobjlv:kid:" + BrandId + ":" + Help + ":" + BankCardType);
-//         }
-
-//         #endregion
-
-
-
-
-
-
-
-
-//         #region POS统计交易额
-//         public void StartListenTradeDo(int tradeId, bool profit = true)
-//         {
-//             try
-//             {
-//                 WebCMSEntities dbnew = new WebCMSEntities();
-//                 TradeRecord trade_record = dbnew.TradeRecord.FirstOrDefault(m => m.Id == tradeId);
-//                 if (trade_record != null)
-//                 {
-//                     int BrandId = trade_record.BrandId;
-//                     decimal TradeAmt = trade_record.TradeAmount;
-//                     int BankCardTypeNum = trade_record.BankCardType; //1-贷记卡，0-借记卡，2-准贷记卡
-
-//                     DateTime TradeDateTime = trade_record.CreateDate.Value;
-//                     string monthString = TradeDateTime.ToString("yyyyMM");
-//                     string dayString = TradeDateTime.ToString("yyyyMMdd");
-//                     string NaturalMonthString = RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:NaturalMonth");
-//                     int NaturalMonth = int.Parse(NaturalMonthString); //自然月
-
-//                     MachineForSnNo machinefor = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == trade_record.SnNo) ?? new MachineForSnNo();
-//                     PosMachinesTwo machine = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == machinefor.SnId) ?? new PosMachinesTwo();
-//                     Users user = dbnew.Users.FirstOrDefault(m => m.Id == machine.UserId) ?? new Users();
-//                     int TopUserId = 0;
-//                     if (!string.IsNullOrEmpty(user.ParentNav))
-//                     {
-//                         string[] navList = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
-//                         if (navList.Length > 1)
-//                         {
-//                             TopUserId = int.Parse(navList[1]);
-//                         }
-//                         else
-//                         { 
-//                             TopUserId = int.Parse(navList[0]);
-//                         }
-//                     }
-//                     PosMerchantInfo merchant = dbnew.PosMerchantInfo.FirstOrDefault(m => m.Id == machine.BindMerchantId) ?? new PosMerchantInfo();
-//                     List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
-
-//                     using (var tran = dbnew.Database.BeginTransaction())
-//                     {
-//                         try
-//                         {
-//                             ulong DirectFlag = merchant.UserId == machine.UserId ? 1u : 0u; //是否直营
-//                             ulong MerHelpFlag = 1; //扶持期、稳定期
-//                             if (merchant.CreateDate.Value < DateTime.Now.AddMonths(-NaturalMonth))
-//                             {
-//                                 MerHelpFlag = 0;
-//                             }
-//                             int HelpMonthCount = DateTime.Now.Month - merchant.CreateDate.Value.Month; //扶持期第几月
-//                             if (HelpMonthCount < 0)
-//                             {
-//                                 HelpMonthCount = 12 + DateTime.Now.Month - merchant.CreateDate.Value.Month;
-//                             }
-//                             int QrPayFlag = trade_record.QrPayFlag;
-//                             decimal CreditTradeAmt = 0;
-//                             decimal DebitNotCapTradeAmt = 0;
-//                             decimal DebitCapTradeAmt = 0;
-//                             int DebitCapTradeNum = 0;
-//                             if (BankCardTypeNum == 1)
-//                             {
-//                                 CreditTradeAmt = TradeAmt;
-//                             }
-//                             else if (BankCardTypeNum == 0)
-//                             {
-//                                 //累计借记卡封顶或非封顶交易 // TODO:需优化，判断不太科学
-//                                 // decimal profitrate = 0;
-//                                 // if (user.CreateDate.Value.AddMonths(NaturalMonth) >= DateTime.Now)
-//                                 // {
-//                                 //     UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 1) ?? new UserProfitSet(); //获取创客分润规则-扶持期
-//                                 //     profitrate = profitSet.ProfitRate;
-//                                 // }
-//                                 // else
-//                                 // {
-//                                 //     UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 0) ?? new UserProfitSet(); //获取创客分润规则-非扶持期
-//                                 //     profitrate = profitSet.ProfitRate;
-//                                 // }
-//                                 // profitrate = profitrate / 100;
-//                                 // int UserLevel = user.UserLevel; //当前会员等级
-//                                 // decimal utrade = RedisDbconn.Instance.Get<decimal>("TeamTradeStat:" + user.Id + ":" + BrandId + ":" + DateTime.Now.ToString("yyMM"));
-//                                 // UserLevelSet checklevel = levels.Where(m => m.UpLevelIntegral < utrade).OrderBy(m => m.Id).FirstOrDefault();
-//                                 // if (checklevel != null)
-//                                 // {
-//                                 //     UserLevel = checklevel.Id + 1;
-//                                 // }
-//                                 // ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + GetLevelKindId(BrandId) + ":" + UserLevel); //获取当前等级参数
-//                                 // decimal getLevelProfit = TradeAmt * objlevel.Percents * profitrate;
-//                                 // if (getLevelProfit < 1)
-//                                 // {
-//                                 //     DebitNotCapTradeAmt = TradeAmt;
-//                                 // }
-//                                 // else
-//                                 // {
-//                                 //     DebitCapTradeAmt = TradeAmt;
-//                                 //     DebitCapTradeNum = 1;
-//                                 //     trade_record.CapFlag = 1;
-//                                 //     dbnew.SaveChanges();
-//                                 // }
-//                                 DebitNotCapTradeAmt = TradeAmt;
-//                             }
-//                             UserTradeMonthSummary editsummary = dbnew.UserTradeMonthSummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeMonth == monthString && m.BrandId == BrandId && m.StatType == 0);
-//                             if (editsummary == null)
-//                             {
-//                                 dbnew.UserTradeMonthSummary.Add(new UserTradeMonthSummary()
-//                                 {
-//                                     CreateDate = DateTime.Now,
-//                                     UserId = user.Id, //创客
-//                                     TradeMonth = monthString, //交易月
-//                                     BrandId = BrandId, //品牌
-//                                     StatType = 0, //交易统计类型
-//                                     TradeAmt = TradeAmt, //商户交易总额
-//                                     CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
-//                                     DebitNotCapTradeAmt = DebitNotCapTradeAmt, //商户非封顶借记卡交易总金额
-//                                     DebitCapTradeAmt = DebitCapTradeAmt, //商户借记卡封顶交易总额
-//                                     DebitCapTradeNum = DebitCapTradeNum, //商户借记卡封顶交易总笔数
-//                                     MallPosOrderStatus = machine.PosSnType == 1 ? 0 : 1, //商城兑换机具状态
-//                                     ActiveBuddyMerStatus = user.RealName == merchant.MerchantName ? 0 : 1, //激活创客同名商户
-//                                 });
-//                             }
-//                             else
-//                             {
-//                                 editsummary.TradeAmt += TradeAmt;
-//                                 editsummary.CreditTradeAmt += CreditTradeAmt;
-//                                 editsummary.DebitNotCapTradeAmt += DebitNotCapTradeAmt;
-//                                 editsummary.DebitCapTradeAmt += DebitCapTradeAmt;
-//                                 editsummary.DebitCapTradeNum += DebitCapTradeNum;
-//                             }
-//                             TradeDaySummary editdaysum = dbnew.TradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
-//                             if (editdaysum == null)
-//                             {
-//                                 editdaysum = dbnew.TradeDaySummary.Add(new TradeDaySummary()
-//                                 {
-//                                     CreateDate = DateTime.Now,
-//                                     UserId = user.Id, //创客
-//                                     TradeDate = dayString, //交易日
-//                                     TradeMonth = monthString, //交易月
-//                                     BrandId = BrandId, //品牌
-//                                     TopUserId = TopUserId, //顶级创客
-//                                 }).Entity;
-//                                 dbnew.SaveChanges();
-//                             }
-//                             //分类统计交易额
-//                             if (MerHelpFlag == 0)
-//                             {
-//                                 if (DirectFlag == 1)
-//                                 {
-//                                     editdaysum.NotHelpDirectTradeAmt = TradeAmt; //直营商户交易总额(非扶持期)
-//                                     if (BankCardTypeNum == 1)
-//                                     {
-//                                         editdaysum.NotHelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(非扶持期)
-//                                         if (QrPayFlag == 1)
-//                                         {
-//                                             editdaysum.NotHelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(非扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             editdaysum.NotHelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(非扶持期)
-//                                         }
-//                                     }
-//                                     else
-//                                     {
-//                                         editdaysum.NotHelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(非扶持期)
-//                                         if (DebitCapTradeNum > 0)
-//                                         {
-//                                             editdaysum.NotHelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(非扶持期)
-//                                             editdaysum.NotHelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(非扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             if (QrPayFlag == 1)
-//                                             {
-//                                                 editdaysum.NotHelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(非扶持期)
-//                                             }
-//                                             else
-//                                             {
-//                                                 editdaysum.NotHelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(非扶持期)
-//                                             }
-//                                         }
-//                                     }
-//                                 }
-//                                 else
-//                                 {
-//                                     editdaysum.NotHelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(非扶持期)
-//                                     if (BankCardTypeNum == 1)
-//                                     {
-//                                         editdaysum.NotHelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(非扶持期)
-//                                         if (QrPayFlag == 1)
-//                                         {
-//                                             editdaysum.NotHelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(非扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             editdaysum.NotHelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(非扶持期)
-//                                         }
-//                                     }
-//                                     else
-//                                     {
-//                                         editdaysum.NotHelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(非扶持期)
-//                                         if (DebitCapTradeNum > 0)
-//                                         {
-//                                             editdaysum.NotHelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(非扶持期)
-//                                             editdaysum.NotHelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(非扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             if (QrPayFlag == 1)
-//                                             {
-//                                                 editdaysum.NotHelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(非扶持期)
-//                                             }
-//                                             else
-//                                             {
-//                                                 editdaysum.NotHelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(非扶持期)
-//                                             }
-//                                         }
-//                                     }
-//                                 }
-//                             }
-//                             else
-//                             {
-//                                 if (DirectFlag == 1)
-//                                 {
-//                                     editdaysum.HelpDirectTradeAmt += TradeAmt; //直营商户交易总额(扶持期)
-//                                     if (BankCardTypeNum == 1)
-//                                     {
-//                                         editdaysum.HelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(扶持期)
-//                                         if (QrPayFlag == 1)
-//                                         {
-//                                             editdaysum.HelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             editdaysum.HelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(扶持期)
-//                                         }
-//                                     }
-//                                     else
-//                                     {
-//                                         editdaysum.HelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(扶持期)
-//                                         if (DebitCapTradeNum > 0)
-//                                         {
-//                                             editdaysum.HelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(扶持期)
-//                                             editdaysum.HelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             if (QrPayFlag == 1)
-//                                             {
-//                                                 editdaysum.HelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(扶持期)
-//                                             }
-//                                             else
-//                                             {
-//                                                 editdaysum.HelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(扶持期)
-//                                             }
-//                                         }
-//                                     }
-//                                 }
-//                                 else
-//                                 {
-//                                     editdaysum.HelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(扶持期)
-//                                     if (BankCardTypeNum == 1)
-//                                     {
-//                                         editdaysum.HelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(扶持期)
-//                                         if (QrPayFlag == 1)
-//                                         {
-//                                             editdaysum.HelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             editdaysum.HelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(扶持期)
-//                                         }
-//                                     }
-//                                     else
-//                                     {
-//                                         editdaysum.HelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(扶持期)
-//                                         if (DebitCapTradeNum > 0)
-//                                         {
-//                                             editdaysum.HelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(扶持期)
-//                                             editdaysum.HelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(扶持期)
-//                                         }
-//                                         else
-//                                         {
-//                                             if (QrPayFlag == 1)
-//                                             {
-//                                                 editdaysum.HelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(扶持期)
-//                                             }
-//                                             else
-//                                             {
-//                                                 editdaysum.HelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(扶持期)
-//                                             }
-//                                         }
-//                                     }
-//                                 }
-//                             }
-//                             UserTradeDaySummary userdaysum = dbnew.UserTradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
-//                             if (userdaysum == null)
-//                             {
-//                                 userdaysum = dbnew.UserTradeDaySummary.Add(new UserTradeDaySummary()
-//                                 {
-//                                     CreateDate = DateTime.Now,
-//                                     UserId = user.Id, //创客
-//                                     TradeDate = dayString, //交易日
-//                                     TradeMonth = monthString, //交易月
-//                                     BrandId = BrandId, //品牌
-//                                 }).Entity;
-//                                 dbnew.SaveChanges();
-//                             }
-//                             if (DirectFlag == 1)
-//                             {
-//                                 userdaysum.DirectTradeAmt += TradeAmt; //直营商户交易总额
-//                                 if (BankCardTypeNum == 0)
-//                                 {
-//                                     userdaysum.DirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额
-//                                 }
-//                             }
-//                             else
-//                             {
-//                                 userdaysum.NonDirectTradeAmt += TradeAmt; //非直营商户交易总额
-//                                 if (BankCardTypeNum == 0)
-//                                 {
-//                                     userdaysum.NonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额
-//                                 }
-//                             }
-//                             dbnew.SaveChanges();
-//                             if (profit)
-//                             {
-//                                 DoProfitForPos(dbnew, trade_record);
-//                             }
-//                             tran.Commit();
-//                         }
-//                         catch (Exception ex)
-//                         {
-//                             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
-//                             tran.Rollback();
-//                         }
-//                     }
-//                 }
-//                 dbnew.Dispose();
-//             }
-//             catch (Exception ex)
-//             {
-//                 function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
-//             }
-//         }
-
-//         public void DoProfitForPos(WebCMSEntities dbnew, TradeRecord trade_record)
-//         { 
-//             List<ProfitUsers> users = new List<ProfitUsers>();
-//             int TopUserId = 0; //顶级创客Id
-//             Users us = dbnew.Users.FirstOrDefault(a => a.Id == trade_record.UserId);
-//             if (us != null)
-//             {
-//                 string uidstring = us.Id.ToString();
-//                 string[] uidlist = { };
-//                 if (!string.IsNullOrEmpty(us.ParentNav))
-//                 {
-//                     uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
-//                     uidlist = uidstring.Split(',');
-//                     if (uidlist.Length > 1)
-//                     {
-//                         TopUserId = int.Parse(function.CheckInt(uidlist[1]));
-//                     }
-//                     else
-//                     { 
-//                         TopUserId = int.Parse(function.CheckInt(uidlist[0]));
-//                     }
-//                 }
-//                 Array.Reverse(uidlist);
-//                 foreach (string uidstr in uidlist)
-//                 {
-//                     int puid = int.Parse(function.CheckInt(uidstr));
-//                     Users pus = dbnew.Users.FirstOrDefault(a => a.Id == puid);
-//                     if (pus != null)
-//                     {
-//                         users.Add(new ProfitUsers()
-//                         {
-//                             UserId = pus.Id,
-//                             UserNav = pus.ParentNav,
-//                             UserLevel = pus.UserLevel,
-//                             CreateDate = pus.CreateDate.Value,
-//                         });
-//                     }
-//                 }
-//             }
-//             string TradeMonth = trade_record.TradeDate.Value.ToString("yyyyMM");
-//             List<ProfitResult> list = new List<ProfitResult>();
-//             list = StartProftForPos(dbnew, trade_record, users);
-//             using (var tran = dbnew.Database.BeginTransaction())
-//             {
-//                 try
-//                 {
-//                     foreach (ProfitResult sub in list)
-//                     {
-//                         if (sub.Message == "分红奖励")
-//                         { 
-//                             UserAccountRecord accountRecord = dbnew.UserAccountRecord.Add(new UserAccountRecord()
-//                             {
-//                                 CreateDate = DateTime.Now,
-//                                 UpdateDate = DateTime.Now,
-//                                 UserId = sub.UserId, //创客
-//                                 ChangeType = 11, //变动类型
-//                                 ProductType = trade_record.BrandId, //产品类型
-//                                 ChangeAmount = sub.Money, //变更金额
-//                                 Status = -1,
-//                             }).Entity;
-//                             dbnew.SaveChanges();
-//                         }
-//                         else
-//                         {
-//                             int ProfitType = sub.UserId == trade_record.UserId ? 0 : 1;
-//                             ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.MerchantId == trade_record.MerchantId && m.BrandId == trade_record.BrandId && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
-//                             if (editprofitrecord == null)
-//                             {
-//                                 editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
-//                                 {
-//                                     CreateDate = DateTime.Now,
-//                                     UserId = sub.UserId, //创客
-//                                     MerchantId = trade_record.MerchantId, //商户
-//                                     BrandId = trade_record.BrandId, //品牌
-//                                     ProfitType = ProfitType, //创客分润类型
-//                                     TradeMonth = TradeMonth, //交易月
-//                                     TopUserId = TopUserId, //顶级创客
-//                                 }).Entity;
-//                                 dbnew.SaveChanges();
-//                                 string RecordNo = "KPM";
-//                                 int RecordId = editprofitrecord.Id;
-//                                 string RecordIdString = RecordId.ToString();
-//                                 for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
-//                                 {
-//                                     RecordIdString = "0" + RecordIdString;
-//                                 }
-//                                 RecordNo += RecordIdString;
-//                                 editprofitrecord.RecordNo = RecordNo;
-//                                 dbnew.SaveChanges();
-//                             }
-//                             // editprofitrecord.OtherTradeAmt = 0; //其他产品交易总金额
-//                             // editprofitrecord.OtherCreditTradeAmt = 0; //其他产品贷记卡交易总金额
-//                             // editprofitrecord.OtherDebitNotCapTradeAmt = 0; //其他产品借记卡非封顶交易总金额
-//                             decimal TradeAmount = trade_record.TradeAmount;
-//                             editprofitrecord.TradeAmt += TradeAmount; //商户交易总额
-//                             if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeAmt += TradeAmount; //贷记卡交易总金额
-//                             if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeAmt += TradeAmount; //(云闪付)贷记卡交易总金额
-//                             if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeAmt += TradeAmount; //(非云闪付)贷记卡交易总金额
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeAmt += TradeAmount; //(非扶持期)(非云闪付)贷记卡交易总金额
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeAmt += TradeAmount; //(扶持期)(非云闪付)贷记卡交易总金额
-//                             if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonCapTradeAmt += TradeAmount; //商户非封顶借记卡交易总额
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNotCapTradeAmt += TradeAmount; //(云闪付)商户非封顶借记卡交易总额
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNotCapTradeAmt += TradeAmount; //(非云闪付)商户非封顶借记卡交易总额
-//                             if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonCapTradeAmt += TradeAmount; //(非扶持期)(非云闪付)借记卡非封顶交易总金额
-//                             if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonCapTradeAmt += TradeAmount; //(扶持期)(非云闪付)借记卡非封顶交易总金额
-//                             if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapTradeAmt = TradeAmount; //商户借记卡封顶交易总额
-//                             editprofitrecord.DebitCapTradeNum += 1; //商户借记卡封顶交易总笔数
-
-//                             decimal ProfitMoney = sub.Money;
-//                             ulong DirectFlag = trade_record.DirectFlag;
-//                             editprofitrecord.TradeProfit += ProfitMoney; //交易分润
-//                             if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeProfit += ProfitMoney; //贷记卡分润总金额
-//                             if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeProfit += ProfitMoney; //(云闪付)贷记卡交易分润
-//                             if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeProfit += ProfitMoney; //(非云闪付)贷记卡交易分润
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeProfit += ProfitMoney; //(非扶持期)(非云闪付)贷记卡分润总金额
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeProfit += ProfitMoney; //(扶持期)(非云闪付)贷记卡分润总金额
-//                             if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonTradeCapProfit += ProfitMoney; //借记卡非封顶交易分润总金额
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNonTradeCapProfit += ProfitMoney; //(云闪付)借记卡非封顶交易分润总金额
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNonTradeCapProfit += ProfitMoney; //(非云闪付)借记卡非封顶交易分润总金额
-//                             if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonTradeCapProfit += ProfitMoney; //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
-//                             if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonTradeCapProfit += ProfitMoney; //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
-//                             if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitTradeCapProfit += ProfitMoney; //借记卡封顶交易分润总金额
-//                             if (sub.Money < 1 && DirectFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapSingleReward += ProfitMoney; //借记卡合伙人直营封顶交易奖励金额
-
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)贷记卡标准分润比例
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)贷记卡成本或增或减比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)贷记卡-标准分润比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)贷记卡成本或增或减比例
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)借记卡标准分润比例
-//                             if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)借记卡成本或增或减比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)借记卡商户交易对应分润比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)借记卡-标准分润比例
-//                             if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)借记卡成本或增或减比例
-//                             if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitRate = sub.ProfitRate; //(云闪付)贷记卡交易分润比例
-//                             if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitStandardRate = sub.ProfitRateBase; //(云闪付)贷记卡分润基准
-//                             editprofitrecord.QrCreditAddOrSubRate = sub.AddOrSubRate; //(云闪付)贷记卡分润比例或增或减
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitRate = sub.ProfitRate; //(云闪付)借记卡非封顶交易分润比例
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitStandardRate = sub.ProfitRateBase; //(云闪付)借记卡非封顶交易分润基准
-//                             if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitAddOrSubRate = sub.AddOrSubRate; //(云闪付)借记卡非封顶交易分润比例或增或减
-//                             dbnew.SaveChanges();
-
-//                             dbnew.ProfitRecord.Add(new ProfitRecord()
-//                             {
-//                                 CreateDate = DateTime.Now,
-//                                 UpdateDate = DateTime.Now,
-//                                 UserId = sub.UserId, //创客
-//                                 MerchantId = trade_record.MerchantId, //商户
-//                                 MerNo = trade_record.MerNo, //渠道商户编号
-//                                 MerHelpFlag = trade_record.MerHelpFlag, //是否属于扶持周期内商户
-//                                 HelpMonthCount = trade_record.HelpMonthCount, //扶持第几个月
-//                                 MerBuddyType = trade_record.MerBuddyType, //商户创客类型
-//                                 SnNo = trade_record.SnNo, //SN号
-//                                 TradeDate = trade_record.TradeDate, //交易日期
-//                                 ProfitAmount = sub.Money, //分润金额
-//                                 QrPayFlag = trade_record.QrPayFlag, //云闪付标识
-//                                 CapFlag = trade_record.CapFlag, //借记卡封顶交易标志
-//                                 DirectFlag = trade_record.DirectFlag, //是否直营
-//                                 BrandId = trade_record.BrandId, //品牌
-//                                 ParentNav = us.ParentNav, //上级创客集
-//                                 TradeId = trade_record.Id, //交易记录Id
-//                             });
-//                             dbnew.SaveChanges();
-
-//                             // Users user = dbnew.Users.FirstOrDefault(m => m.Id == sub.UserId);
-//                             // if (user != null)
-//                             // {
-//                                 // if (!string.IsNullOrEmpty(user.CloudPushDeviceId))
-//                                 // {
-//                                 //     new AliyunPushOld().Push("鑫创客通知", "您有一笔分润收益：" + sub.Money.ToString("f2"), "30", "NOTICE", user.DeviceType, user.CloudPushDeviceId, "1");
-//                                 // }
-//                                 // TODO:发送阿里云推送消息
-//                             // }
-//                         }
-//                     }
-//                     dbnew.SaveChanges();
-//                     tran.Commit();
-//                 }
-//                 catch (Exception ex)
-//                 { 
-//                     tran.Rollback();
-//                     function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "POS分润异常");
-//                 }
-//             }
-//         }
-
-//         #endregion
-        
-//         #region POS分润算法
-//         public List<ProfitResult> StartProftForPos(WebCMSEntities dbnew, TradeRecord trade, List<ProfitUsers> users)
-//         {
-//             // 级差
-//             /*   
-                
-//                 K1 - K5：无大小市场要求，无押机分润比例为有押金机的70%，如K1的有押金机分润比例为万6，则无押机的分润比例为万4.2
-//                                       机具激活大于90天，分润比例为原比例的70%
-
-//                         if(is0y){
-//                             分润比例为原比例的70%
-//                         }
-//                         if(ActivityDate > now - 90){
-//                             分润比例为原比例的70%
-//                         }
-//                 K6 - K9：
-//                     K6：至少有1个直推大于3000万，且总交易额减去3000万大于1200万，则获得分红奖（月月红）直接级差
-//                     K7：总交易额减去最大交易额的直推，大于4000万，则获得分红奖（月月红）直接级差
-//                     K8：总交易额减去最大交易额的直推，大于12000万，则获得分红奖（月月红）直接级差
-//                     K9：总交易额减去最大交易额的直推，大于32000万，则获得分红奖（月月红）直接级差
-
-//                 补贴：
-//                     0押金无补贴
-//                     机具激活90天内，机具所属创客获得万10置顶
-//                     若创客为商户型创客，则机具UserId的创客获得万4分润
-
-//             */
-
-
-//             List<ProfitResult> result = new List<ProfitResult>();
-//             int BrandId = trade.BrandId;
-//             ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
-//             if (obj.Status == 1) //判断分润是否开启
-//             {
-//                 decimal TradeMoney = trade.TradeAmount;
-//                 int BankCardType = trade.BankCardType; //银行卡类型：贷记卡-1，借记卡-0
-//                 int MerHelpFlag = (int)trade.MerHelpFlag; //扶持期-1，稳定期=0
-//                 List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
-//                 int IncludeCurrentMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:IncludeCurrentMonth")); //是否包含当前月
-//                 int NaturalMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:NaturalMonth")); //自然月
-//                 if(IncludeCurrentMonth == 1) NaturalMonth -= 1;
-//                 if (BankCardType == 0)
-//                 {
-//                     Users user = dbnew.Users.FirstOrDefault(m => m.Id == trade.UserId) ?? new Users();
-//                     // UserProfitSet profitSet = profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
-//                     // profitrate = profitSet.ProfitRate;
-//                     // profitrate = profitrate / 100;
-//                     int UserLevel = user.UserLevel; //当前会员等级
-//                     int HelpTime = 0;
-//                     if (user.CreateDate.Value.AddMonths(NaturalMonth) > DateTime.Now)
-//                     {
-//                         HelpTime = 1;
-//                     }
-//                     int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
-//                     ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
-//                     decimal getLevelProfit = TradeMoney * objlevel.Percents;
-//                     if(getLevelProfit > 1) getLevelProfit = 1;
-//                     result.Add(new ProfitResult()
-//                     {
-//                         UserId = user.Id,
-//                         UserNav = user.ParentNav,
-//                         Money = getLevelProfit,
-//                         ProfitRate = objlevel.Percents,
-//                         // ProfitPercent = profitSet.ProfitPercent,
-//                         // AddOrSubRate = profitSet.AddOrSubRate,
-//                         // ProfitRateBase = profitSet.ProfitRateBase,
-//                     });
-//                     return result;
-//                 }
-//                 int maxLevel = obj.MaxLevel; //最大等级
-//                 int maxFloor = obj.MaxFloor; //最大层级
-//                 int maxContinueFloor = RedisDbconn.Instance.Get<int>("pobjconc" + BrandId); //最大继续分润层级
-//                 decimal diffLevelProfit = 0;  //等级级差
-//                 decimal diffDiviProfit = 0; //分红级差
-//                 // decimal diffFloorProfit = 0;  //层级级差
-//                 // int continueFloor = 0; //继续分润层级
-//                 int curLevel = 0; //当前层级的会员等级
-//                 for (int curFloor = 1; curFloor <= users.Count; curFloor++)
-//                 {
-//                     ProfitUsers user = new ProfitUsers();
-//                     if (curFloor <= users.Count)
-//                     {
-//                         user = users[curFloor - 1];
-//                     }
-//                     int UserLevel = user.UserLevel; //当前会员等级
-//                     //判断当前创客是否有直推的激活机具，并且在活动时间内
-//                     if (UserLevel == maxLevel && UserLevel == curLevel)
-//                     {
-//                         break;
-//                     }
-//                     if (UserLevel <= maxLevel && UserLevel > curLevel)
-//                     {
-//                         int HelpTime = 0;
-//                         if (user.CreateDate.AddMonths(NaturalMonth) > DateTime.Now)
-//                         {
-//                             HelpTime = 1;
-//                         }
-//                         int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
-//                         ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
-//                         if (objlevel != null)
-//                         {
-//                             decimal getLevelProfit = 0;  //等级分润
-//                             // UserProfitSet profitSet = new UserProfitSet();
-//                             if (objlevel.Percents > 0)
-//                             {
-//                                 //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
-//                                 decimal profitrate = objlevel.Percents;
-//                                 // profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.UserId && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
-//                                 // profitrate = profitSet.ProfitRate;
-//                                 // profitrate = profitrate / 100;
-//                                 getLevelProfit += TradeMoney * objlevel.Percents * profitrate;
-//                             }
-//                             if (objlevel.AddProfitVal > 0)
-//                             {
-//                                 //分红奖励:一个3000万，3000万以下市场总和大于1200万
-//                                 bool bigMarket = false;
-//                                 decimal smallMarket = 0;
-//                                 List<Users> directs = dbnew.Users.Where(m => m.ParentUserId == user.UserId).ToList();
-//                                 decimal BigMarketTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:BigMarketTradeAmt")); //大市场交易额
-//                                 decimal PassTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:PassTradeAmt")); //小市场交易超越额
-//                                 decimal UnitPrize = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:UnitPrize")); //单位奖励基数
-//                                 foreach (Users direct in directs)
-//                                 {
-//                                     UserData userData = dbnew.UserData.FirstOrDefault(m => m.UserId == direct.Id) ?? new UserData();
-//                                     if (userData.TotalOrderMoney >= BigMarketTradeAmt)
-//                                     {
-//                                         bigMarket = true;
-//                                     }
-//                                     else
-//                                     {
-//                                         smallMarket += userData.TotalOrderMoney;
-//                                     }
-//                                 }
-//                                 if (bigMarket && smallMarket >= PassTradeAmt)
-//                                 { 
-//                                     decimal DiviPrize = objlevel.AddProfitVal * TradeMoney / UnitPrize;
-//                                     decimal checkmoney = DiviPrize;
-//                                     DiviPrize -= diffDiviProfit;
-//                                     if (objlevel.LevelDiff == 1)  //判断是否有级差
-//                                     {
-//                                         diffDiviProfit = checkmoney;
-//                                     }
-//                                     if (DiviPrize >= obj.MinProfitVal)
-//                                     {
-//                                         result.Add(new ProfitResult()
-//                                         {
-//                                             UserId = user.UserId,
-//                                             UserNav = user.UserNav,
-//                                             Money = DiviPrize,
-//                                             Message = "分红奖励",
-//                                         });
-//                                     }
-//                                 }
-//                             }
-//                             decimal money = getLevelProfit;
-//                             getLevelProfit -= diffLevelProfit;
-//                             if (objlevel.LevelDiff == 1)  //判断是否有级差
-//                             {
-//                                 diffLevelProfit = money;
-//                             }
-//                             if (getLevelProfit >= obj.MinProfitVal)
-//                             {
-//                                 result.Add(new ProfitResult()
-//                                 {
-//                                     UserId = user.UserId,
-//                                     UserNav = user.UserNav,
-//                                     Money = getLevelProfit,
-//                                     ProfitRate = objlevel.Percents,
-//                                     // ProfitPercent = profitSet.ProfitPercent,
-//                                     // AddOrSubRate = profitSet.AddOrSubRate,
-//                                     // ProfitRateBase = profitSet.ProfitRateBase,
-//                                 });
-//                             }
-//                         }
-//                     }
-//                     curLevel = UserLevel;
-//                 }
-//             }
-//             return result;
-//         }
-//         public void StatProfit()
-//         {
-//             Thread th = new Thread(StatProfitDo);
-//             th.IsBackground = true;
-//             th.Start();
-//         }
-//         public void StatProfitDo()
-//         {
-//             string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
-//             string check = function.ReadInstance("/ProfitStat/" + Month + ".txt");
-//             if (!string.IsNullOrEmpty(check))
-//             {
-//                 return;
-//             }
-//             function.WritePage("/ProfitStat/", Month + ".txt", DateTime.Now.ToString());
-//             WebCMSEntities db = new WebCMSEntities();
-//             for (int i = 1; i <= 9; i++) //品牌
-//             {
-//                 for (int j = 0; j <= 1; j++) //卡类型
-//                 {
-//                     int PageNum = 1;
-//                     bool op = true;
-//                     while(op)
-//                     {
-//                         List<ProfitResult> result = StartProftForPosByMonth(i, j, Month, PageNum);
-//                         if(result.Count > 0)
-//                         {
-//                             foreach (ProfitResult sub in result)
-//                             {
-//                                 int TopUserId = 0;
-//                                 if (!string.IsNullOrEmpty(sub.UserNav))
-//                                 {
-//                                     string[] UserNavList = sub.UserNav.Trim(',').Replace(",,", ",").Split(',');
-//                                     if (UserNavList.Length > 1)
-//                                     {
-//                                         TopUserId = int.Parse(UserNavList[1]);
-//                                     }
-//                                     else
-//                                     {
-//                                         TopUserId = int.Parse(UserNavList[0]);
-//                                     }
-//                                 }
-//                                 string RecordNo = "P" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
-//                                 decimal ProfitAmt = sub.Money;
-//                                 decimal TradeAmt = sub.TradeAmount;
-//                                 decimal ProfitRate = sub.ProfitRate;
-//                                 if (sub.IsSubsidy == 1 && j == 1)
-//                                 {
-//                                     decimal CreditTradeAmt = TradeAmt; //商户贷记卡交易总金额
-//                                     decimal QrCreditTradeAmt = 0; //商户(云闪付)贷记卡交易总金额
-//                                     decimal NonQrCreditTradeAmt = 0; //商户(非云闪付)贷记卡交易总金额
-//                                     decimal CreditProfitRate = 0; //(非云闪付)贷记卡交易分润比例
-//                                     decimal SubsidyProfit = 0; //商户(非云闪付)贷记卡交易分润补贴金额
-//                                     if (sub.QrPayFlag == 1)
-//                                     {
-//                                         QrCreditTradeAmt = TradeAmt; //商户(云闪付)贷记卡交易总金额
-//                                     }
-//                                     else
-//                                     { 
-//                                         NonQrCreditTradeAmt = TradeAmt; //商户(非云闪付)贷记卡交易总金额
-//                                         CreditProfitRate = ProfitRate; //(非云闪付)贷记卡交易分润比例
-//                                         SubsidyProfit = ProfitAmt; //商户(非云闪付)贷记卡交易分润补贴金额
-//                                     }
-//                                     MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == sub.PosSn) ?? new MachineForSnNo();
-//                                     PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo(); 
-//                                     PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.MerchantId) ?? new PosMerchantInfo();
-//                                     db.ProfitSubsidyDetail.Add(new ProfitSubsidyDetail()
-//                                     {
-//                                         CreateDate = DateTime.Now,
-//                                         UpdateDate = DateTime.Now,
-//                                         RecordNo = RecordNo, //流水号
-//                                         BrandId = sub.BrandId, //品牌
-//                                         ProductName = RelationClass.GetKqProductBrandInfo(sub.BrandId), //产品名称
-//                                         TradeMonth = Month, //交易月份
-//                                         MerchantId = sub.MerchantId, //商户
-//                                         MerNo = merchant.KqMerNo, //渠道商户编号
-//                                         SnNo = sub.PosSn, //渠道SN号
-//                                         MerRegTime = pos.BindingTime, //渠道注册时间
-//                                         MerStandardDate = merchant.MerStandardDate, //商户激活时间
-//                                         BelongUserId = merchant.UserId, //商户归属人
-//                                         MerHelpFlag = sub.HelpFlag == 1 ? 1u : 0u, //是否属于扶持周期内商户
-//                                         SubsidyUserId = sub.UserId, //补贴人
-//                                         SubsidyType = sub.DirectFlag, //分润补贴类型
-//                                         SubsidyProfitRate = sub.Money, //创客活动期内直营商户分润万分之十
-//                                         CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
-//                                         QrCreditTradeAmt = QrCreditTradeAmt, //商户(云闪付)贷记卡交易总金额
-//                                         NonQrCreditTradeAmt = NonQrCreditTradeAmt, //商户(非云闪付)贷记卡交易总金额
-//                                         CreditProfitRate = CreditProfitRate, //(非云闪付)贷记卡交易分润比例
-//                                         SubsidyProfit = SubsidyProfit, //商户(非云闪付)贷记卡交易分润补贴金额
-//                                     });
-//                                 }
-//                             }
-//                             db.SaveChanges();
-//                             PageNum += 1;
-//                         }
-//                         else
-//                         {
-//                             op = false;
-//                         }
-//                     }
-//                 }
-//             }
-//             db.Dispose();
-
-//             HelpProfitHelper.Instance.StatProfitEveryDay(DateTime.Now.AddMonths(-1).ToString("yyyyMM")); //助利宝分润
-//             ProfitCheckHelper.Instance.Start();
-//         }
-//         public List<ProfitResult> StartProftForPosByMonth(int BrandId, int BankCardType, string Month, int PageNum = 1)
-//         {
-//             // 级差
-//             /*   
-                
-//                 K1 - K5：无大小市场要求，无押机分润比例为有押金机的70%，如K1的有押金机分润比例为万6，则无押机的分润比例为万4.2
-//                                       机具激活大于90天，分润比例为原比例的70%
-
-//                         if(is0y){
-//                             分润比例为原比例的70%
-//                         }
-//                         if(ActivityDate > now - 90){
-//                             分润比例为原比例的70%
-//                         }
-//                 K6 - K9：
-//                     K6：至少有1个直推大于3000万，且总交易额减去3000万大于1200万，则获得分红奖（月月红）直接级差
-//                     K7：总交易额减去最大交易额的直推，大于4000万，则获得分红奖（月月红）直接级差
-//                     K8：总交易额减去最大交易额的直推，大于12000万，则获得分红奖（月月红）直接级差
-//                     K9：总交易额减去最大交易额的直推，大于32000万，则获得分红奖（月月红）直接级差
-
-//                 补贴：
-//                     0押金无补贴
-//                     机具激活90天内，机具所属创客获得万10置顶
-//                     若创客为商户型创客，则机具UserId的创客获得万4分润
-
-//                     //查分润
-//                     select u.MakerCode,u.RealName,u.UserLevel,r.Rank,pos.SeoKeyword,p.KqSnNo,(case when ProfitType=1 then '直营' else '团队' end) as DirectFlag,
-//                     k.Name,CreditTradeAmt,CreditTradeProfit,DebitTradeAmt,DebitTradeProfit,QrCreditTradeAmt,QrCreditTradeProfit from (
-//                     select UserId,ProfitType,BrandId,MerchantId,
-//                     sum(CreditTradeAmt) as CreditTradeAmt,
-//                     sum(CreditTradeProfit) as CreditTradeProfit,
-//                     sum(DebitNonCapTradeAmt+DebitCapTradeAmt) as DebitTradeAmt,
-//                     sum(DebitNonTradeCapProfit+DebitTradeCapProfit) as DebitTradeProfit,
-//                     sum(QrCreditTradeAmt) as QrCreditTradeAmt,
-//                     sum(QrCreditTradeProfit) as QrCreditTradeProfit
-//                     from ProfitRewardRecord where MerchantId>0
-//                     GROUP BY UserId,ProfitType,BrandId,MerchantId
-//                     ) tb 
-//                     left join Users u on tb.UserId=u.Id 
-//                     LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
-//                     left join PosMerchantInfo p on tb.MerchantId=p.Id 
-//                     left join MachineForSnNo fp on fp.SnNo=p.KqSnNo 
-//                     left join PosMachinesTwo pos on pos.Id=fp.SnId 
-//                     left join UserRankWhite r on u.Id=r.Id 
-//                     ORDER BY p.KqSnNo,u.MakerCode
-
-//                     //查补贴
-//                     select u.MakerCode,u.RealName,u.UserLevel,r.Rank,m.KqSnNo,m.MerchantName,(case when SubsidyType=1 then '直营' else '团队' end) as DirectFlag,
-//                     k.Name,CreditTradeAmt,SubsidyProfit from (
-//                     select SubsidyUserId,MerchantId,BrandId,SubsidyType,
-//                     sum(CreditTradeAmt) as CreditTradeAmt,
-//                     sum(SubsidyProfitRate) as SubsidyProfit
-//                     from ProfitSubsidyDetail where TradeMonth='202208' 
-//                     GROUP BY SubsidyUserId,MerchantId,BrandId,SubsidyType
-//                     ) tb 
-//                     left join Users u on tb.SubsidyUserId=u.Id 
-//                     LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
-//                     left join PosMerchantInfo m on tb.MerchantId=m.Id 
-//                     left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00'
-
-//                     // TODO:做到后台查询，换绑机器遗漏交易额补差
-//                     select UserId,sum(TradeAmount) from TradeRecord where SnNo in (
-//                     select PosSn from PosMachinesTwo where UserId=0 and BuyUserId=0 and CreditTrade>0
-//                     ) and CreateDate>='2022-04-01 00:00:00' and CreateDate<'2022-05-01 00:00:00' and UserId>0 group by UserId
-
-//             */
-
-//             int PageSize = 200;
-//             int SkipNum = (PageNum - 1) * PageSize;
-//             string LimitString = " limit " + PageSize;
-//             if(PageNum > 1)
-//             {
-//                 LimitString = " limit " + SkipNum + "," + PageSize;
-//             }
-//             function.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
-//             function.WriteLog(BankCardType.ToString(), "老规则分润日志");
-//             function.WriteLog(BrandId.ToString(), "老规则分润日志");
-//             List<ProfitResult> result = new List<ProfitResult>();
-//             ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
-//             if (obj.Status == 1) //判断分润是否开启
-//             {
-//                 string start = Month.Substring(0, 4) + "-" + Month.Substring(4, 2) + "-01 00:00:00";
-//                 string end = DateTime.Parse(start).AddMonths(1).ToString("yyyy-MM-dd HH:mm:ss");
-//                 DataTable dt = new DataTable();
-//                 if (BankCardType == 1)
-//                 {
-//                     dt = ProfitHelperV2.Instance.GetDataTable("select SnNo,UserId,QrPayFlag,MerHelpFlag,TradeAmount,Version from TradeRecord" + Month + " where MerHelpFlag=1 and Version=0 and BrandId=" + BrandId + LimitString);
-//                 }
-//                 function.WriteLog("记录页数：" + PageNum.ToString(), "老规则分润日志");
-//                 function.WriteLog("记录条数：" + dt.Rows.Count.ToString(), "老规则分润日志");
-//                 foreach (DataRow dr in dt.Rows)
-//                 {
-//                     WebCMSEntities dbnew = new WebCMSEntities();
-//                     try
-//                     {
-//                         string SnNo = dr["SnNo"].ToString();
-//                         int UserId = int.Parse(dr["UserId"].ToString());
-//                         int HelpTime = int.Parse(dr["Version"].ToString()) == 1 ? 2 : int.Parse(dr["MerHelpFlag"].ToString());
-//                         function.WriteLog("SnNo:" + SnNo, "老规则分润日志");
-//                         function.WriteLog("UserId:" + UserId, "老规则分润日志");
-//                         function.WriteLog("HelpTime:" + HelpTime, "老规则分润日志");
-//                         MachineForSnNo forSnNo = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == SnNo) ?? new MachineForSnNo();
-//                         PosMachinesTwo pos = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
-//                         decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
-//                         if (pos.BindingState == 1)
-//                         {
-//                             function.WriteLog("BindingState:" + pos.BindingState, "老规则分润日志");
-//                             int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString());
-//                             decimal TradeAmt = decimal.Parse(dr[4].ToString());
-//                             List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
-//                             SubUser selfUser = ProfitHelperV2.Instance.GetUser(UserId, Month) ?? new SubUser();
-//                             int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
-//                             if (BankCardType == 0)
-//                             {
-//                             }
-//                             else
-//                             {
-//                                 int maxLevel = obj.MaxLevel; //最大等级
-//                                 decimal diffLevelProfit = 0;  //等级级差
-//                                 int curLevel = 0; //当前层级的会员等级
-//                                 string ParentNav = selfUser.ParentNav;
-//                                 if (string.IsNullOrEmpty(ParentNav) && pos.BuyUserId == 1 && pos.UserId == 1)
-//                                 {
-//                                     ParentNav = ",0,";
-//                                 }
-//                                 if (!string.IsNullOrEmpty(ParentNav))
-//                                 {
-//                                     ParentNav += "," + UserId + ",";
-//                                     string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-//                                     Array.Reverse(ParentNavList); //反转顺序
-//                                     int level = 0;
-//                                     DateTime now = DateTime.Now;
-//                                     DateTime ThisMonth = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
-//                                     foreach (string UserIdString in ParentNavList)
-//                                     {
-//                                         level += 1;
-//                                         int uid = int.Parse(UserIdString);
-//                                         SubUser user = ProfitHelperV2.Instance.GetUser(uid, Month) ?? new SubUser();
-//                                         int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
-//                                         if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
-//                                         {
-//                                             break;
-//                                         }
-//                                         if (UserLevel <= maxLevel && UserLevel > curLevel)
-//                                         {
-//                                             function.WriteLog("UserLevel:" + UserLevel, "老规则分润日志");
-//                                             function.WriteLog("curLevel:" + curLevel, "老规则分润日志");
-//                                             int LevelKindId = GetLevelKindId(BrandId, HelpTime, 1);
-//                                             ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
-//                                             if (objlevel != null)
-//                                             {
-//                                                 decimal getLevelProfit = 0;  //等级分润
-//                                                 if (objlevel.Percents > 0)
-//                                                 {
-//                                                     //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
-//                                                     getLevelProfit += TradeAmt * objlevel.Percents;
-//                                                 }
-//                                                 if (objlevel.AddProfitVal > 0)
-//                                                 {
-//                                                     getLevelProfit += objlevel.AddProfitVal;
-//                                                 }
-//                                                 decimal money = getLevelProfit;
-//                                                 getLevelProfit -= diffLevelProfit;
-//                                                 if (objlevel.LevelDiff == 1)  //判断是否有级差
-//                                                 {
-//                                                     diffLevelProfit = money;
-//                                                 }
-
-//                                                 // 分润补贴
-//                                                 if (HelpTime == 1 && level == 1)
-//                                                 {
-//                                                     function.WriteLog("ok", "老规则分润日志");
-//                                                     int SubsidyUserId = pos.BuyUserId;
-//                                                     SubUser subuser = ProfitHelperV2.Instance.GetUser(SubsidyUserId, Month) ?? new SubUser();
-//                                                     int subUserLevel = subuser.PreUserLevel > subuser.UserLevel ? subuser.PreUserLevel : subuser.UserLevel;
-//                                                     function.WriteLog("subUserLevel:" + subUserLevel, "老规则分润日志");
-//                                                     if(subUserLevel < 5)
-//                                                     {
-//                                                         function.WriteLog("sub:ok:", "老规则分润日志");
-//                                                         ProfitObjectLevels sublevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + subUserLevel); //获取当前等级参数
-//                                                         if (sublevel != null)
-//                                                         {
-//                                                             decimal otherPercent = 0.001M - sublevel.Percents;
-//                                                             decimal otherMoney = TradeAmt * otherPercent;
-//                                                             function.WriteLog("otherPercent:" + otherPercent, "老规则分润日志");
-//                                                             function.WriteLog("otherMoney:" + otherMoney, "老规则分润日志");
-//                                                             if (otherMoney >= obj.MinProfitVal)
-//                                                             {
-//                                                                 function.WriteLog("finish:" + SnNo, "老规则分润日志");
-//                                                                 result.Add(new ProfitResult()
-//                                                                 {
-//                                                                     UserId = subuser.Id,
-//                                                                     UserNav = subuser.ParentNav,
-//                                                                     Money = PublicFunction.NumberFormat(otherMoney),
-//                                                                     ProfitRate = otherPercent,
-//                                                                     Message = "分润补贴",
-//                                                                     BankCardType = BankCardType,
-//                                                                     QrPayFlag = QrPayFlag,
-//                                                                     DirectFlag = 1,
-//                                                                     BrandId = pos.BrandId,
-//                                                                     IsSubsidy = 1,
-//                                                                     MerchantId = pos.BindMerchantId,
-//                                                                     TradeAmount = TradeAmt,
-//                                                                     HelpFlag = HelpTime,
-//                                                                     PosSn = pos.PosSn,
-//                                                                 });
-//                                                             }
-//                                                         }
-//                                                     }
-//                                                 }
-//                                             }
-//                                         }
-//                                         curLevel = UserLevel;
-//                                     }
-//                                 }
-//                             }
-//                         }
-//                         function.WriteLog("\n\n", "老规则分润日志");
-//                     }
-//                     catch (Exception ex)
-//                     {
-//                         function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
-//                     }
-//                     dbnew.Dispose();
-//                 }
-//             }
-//             function.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
-//             function.WriteLog("\r\n\r\n", "老规则分润日志");
-//             return result;
-//         }
-//         #endregion
-
-//     }
-// }
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Data;
+using MySystem.Models.Main;
+using Library;
+using System.Threading;
+using Microsoft.Extensions.Hosting;
+using System.Threading.Tasks;
+
+namespace MySystem
+{
+    public class ProfitHelper
+    {
+        public readonly static ProfitHelper Instance = new ProfitHelper();
+        private ProfitHelper()
+        {
+        }
+
+        #region 消费队列(执行消费退款金额的统计)
+        public void StartListenTrade()
+        {
+            Thread th = new Thread(StartListenTradeDo);
+            th.IsBackground = true;
+            th.Start();
+        }
+        public void StartListenTradeDo()
+        {
+            while (true)
+            {
+                string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrders:Divi:1:List");
+                if (!string.IsNullOrEmpty(orderidstring))
+                {
+                    ReturnStat(orderidstring, 1);
+                }
+                else
+                {
+                    Thread.Sleep(60000);
+                }
+            }
+        }
+
+        public void StartListenWxTrade()
+        {
+            Thread th = new Thread(StartListenWxTradeDo);
+            th.IsBackground = true;
+            th.Start();
+        }
+        public void StartListenWxTradeDo()
+        {
+            while (true)
+            {
+                string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrders:Divi:2:List");
+                if (!string.IsNullOrEmpty(orderidstring))
+                {
+                    ReturnStat(orderidstring, 2);
+                }
+                else
+                {
+                    Thread.Sleep(10000);
+                }
+            }
+        }
+
+        public void ReturnStat(string orderidstring, int PayMode)
+        { 
+            int OrderId = int.Parse(function.CheckInt(orderidstring));
+            WebCMSEntities db = new WebCMSEntities();
+            using (var tran = db.Database.BeginTransaction())
+            {
+                try
+                {
+                    ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == OrderId);
+                    if (order != null)
+                    {
+                        decimal PayMoney = order.PayMoney;
+                        int MerchantId = order.MerchantId;
+                        MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
+                        if (merchant != null)
+                        {
+                            int UserId = merchant.UserId;
+                            List<CustomTagSet> customTagSets = db.CustomTagSet.ToList(); //获取公用配置参数集和
+                            //获取参数
+                            CustomTagSet profitPercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerProfitPercent") ?? new CustomTagSet();
+                            decimal profitPercent = decimal.Parse(function.CheckNum(profitPercentSet.Contents)); //基于收款金额的总分润比例;
+                            CustomTagSet cusumerFeePercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerFeePercent") ?? new CustomTagSet();
+                            decimal cusumerFeePercent = decimal.Parse(function.CheckNum(cusumerFeePercentSet.Contents)); //费率;
+                            CustomTagSet minProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "MinProfit") ?? new CustomTagSet();
+                            decimal minProfit = decimal.Parse(function.CheckNum(minProfitSet.Contents)); //最小分润值;
+
+                            MerchantParamSet set = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
+                            int DiviPersons = set.DiviPersons; //单笔订单分红人数
+                            decimal DiviPercent = set.DiviPercent; //单人最大分红比例
+                            int ProfitDays = set.ProfitDays; //分红期限（天）
+                            decimal GetPercent = set.GetPercent / 100; //商家实收比例
+                            decimal MinPayMoney = set.MinPayMoney; //订单参与门槛
+                            int IsAll = set.IsAll; //是否收全额
+                            // decimal TotalActual = 0;
+                            if (IsAll == 0 && PayMoney >= MinPayMoney && GetPercent < 1)
+                            {
+                                decimal DiviMoney = PayMoney * (1 - GetPercent - cusumerFeePercent - profitPercent);
+                                if (DiviMoney > 0)
+                                {
+                                    RedisDbconn.Instance.AddRightList("ConsumerOrders:Divi:" + PayMode + ":" + order.MerchantId, order);
+                                    DiviMoney = DiviMoney / DiviPersons;
+                                    List<int> deletes = new List<int>();
+                                    long CurDiviPersons = DiviPersons;
+                                    long QueueCount = RedisDbconn.Instance.Count("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
+                                    long CurQueueCount = QueueCount;
+                                    // int CheckNum = 0; //判断活动人数是否大于当前队列订单数来确认while循环的数量，如果是就少循环一次，判处自己的订单名额
+                                    if (CurDiviPersons >= CurQueueCount)
+                                    {
+                                        CurDiviPersons = CurQueueCount;
+                                    }
+                                    if (DiviPersons < QueueCount)
+                                    {
+                                        QueueCount = DiviPersons;
+                                    }
+                                    decimal OtherMoney = 0; // 退款金额>最大退款金额-当前退款金额，次金额应归还给商户
+
+                                    // List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
+                                    // foreach(ConsumerOrders sub in orders)
+                                    // {
+                                    //     function.WriteLog(sub.Id.ToString(), "返现队列");
+                                    // }
+                                    // function.WriteLog("\n\n", "返现队列");
+
+                                    // 减去自己付的订单
+                                    // CurDiviPersons = CurDiviPersons - 1;
+                                    int OutCount = 0; // 出局人数
+                                    while (CurDiviPersons > 0)
+                                    {
+                                        ConsumerOrders suborder = RedisDbconn.Instance.RPop<ConsumerOrders>("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
+                                        if (suborder != null)
+                                        {
+                                            MerchantParamSet subset = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
+                                            int subProfitDays = subset.ProfitDays; //分红期限（天）
+                                            bool IsOut = suborder.UpdateDate.Value.AddDays(subProfitDays) < DateTime.Now ? true : false;
+                                            if (suborder.CurDivi < suborder.MaxDivi && !IsOut)
+                                            {
+                                                //如果没过期并且当前退款金额没超过最大退款金额，就执行
+                                                decimal GetMoney = suborder.MaxDivi - suborder.CurDivi;
+                                                decimal DiffMoney = 0;
+                                                if (GetMoney >= DiviMoney)
+                                                {
+                                                    GetMoney = DiviMoney;
+                                                }
+                                                else
+                                                {
+                                                    DiffMoney = DiviMoney - GetMoney;
+                                                }
+                                                if (GetMoney > minProfit)
+                                                {
+                                                    suborder.CurDivi += GetMoney;
+                                                    if (DiffMoney > 0)
+                                                    {
+                                                        OtherMoney += DiffMoney;
+                                                    }
+                                                    ConsumerProfit cprofit = db.ConsumerProfit.Add(new ConsumerProfit()
+                                                    {
+                                                        CreateDate = DateTime.Now,
+                                                        ConsumerId = suborder.ConsumerId,
+                                                        MerchantId = suborder.MerchantId,
+                                                        OrderId = suborder.Id,
+                                                        GetMoney = GetMoney,
+                                                        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();
+                                                    // if(order.PayMode == 1)
+                                                    // {
+                                                    //     AlipayFunction.Instance.Refund(suborder.SeoTitle, GetMoney.ToString("f2"), "门店分红", merchantAdd.AlipayAuthToken);
+                                                    // }
+                                                    // else
+                                                    // {
+                                                    //     Dictionary<string, string> dic = WeChatFunction.Instance.Refund(merchantAdd.SubMchid, GetMoney, suborder.PayMoney, suborder.OrderNo, DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8), "门店分红");
+                                                    // }
+                                                    if (suborder.CurDivi < suborder.MaxDivi)
+                                                    {
+                                                        RedisDbconn.Instance.AddList("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId, suborder);
+                                                    }
+                                                    else
+                                                    {
+                                                        OutCount += 1;
+                                                    }
+                                                }
+                                            }
+                                            else
+                                            { 
+                                                //否者计算人数不计入退款名额
+                                                CurDiviPersons += 1;
+                                            }
+                                        }
+                                        CurDiviPersons -= 1;
+                                        QueueCount = RedisDbconn.Instance.Count("ConsumerOrders:Divi:" + PayMode + ":" + MerchantId);
+                                        if (QueueCount == 0)
+                                        {
+                                            CurDiviPersons = 0;
+                                        }
+                                    }
+                                    // long DoCount = DiviPersons > (QueueCount + OutCount) ? DiviPersons - QueueCount : 0;
+                                    // decimal MerchantGetMoney = PayMoney * GetPercent;
+                                    // decimal DoMoney = DoCount * DiviMoney;
+                                    // TotalActual = PayMoney * GetPercent + DoCount * DiviMoney + OtherMoney;
+                                    // function.WriteLog("返现金额：" + DiviMoney + ";返现人数：" + DiviPersons + ";返现商户：" + TotalActual + ";返现溢出：" + OtherMoney + ";商户应得金额：" + MerchantGetMoney + ";返现差额：" + DoMoney + ";", "消费者返现日志");
+
+
+                                    //代理商分润
+                                    // AgentProfit(db, order);
+                                }
+                            }
+                        }
+                    }
+                    tran.Commit();
+                }
+                catch (Exception ex)
+                {
+                    function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
+                    tran.Rollback();
+                }
+            }
+            db.Dispose();
+        }
+        #endregion
+    }
+}

Util/HaoDa/WeChatPayBackService.cs

@@ -111,13 +111,6 @@ namespace MySystem
         //     return Encoding.UTF8.GetString(plaintext);
         // }
 
-
-
-
-
-
-
-
         //分账队列
         public void StartProfitShare()
         {

Util/RedisDbconn.cs

@@ -93,6 +93,11 @@ namespace MySystem
             return RedisHelper.LPush(key, value);
             // return 0;
         }
+        public long AddRightList(string key, object value)
+        {
+            return RedisHelper.RPush(key, value);
+            // return 0;
+        }
         public T RPop<T>(string key)
         {
             return RedisHelper.RPop<T>(key);