删除redis的clear操作

AppStart/Helper/CheckAlipaySignService.cs

@@ -1,127 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using MySystem.PxcModels;
-using Library;
-using LitJson;
-using System.Text.RegularExpressions;
-
-namespace MySystem
-{
-    public class CheckAlipaySignService
-    {
-        public readonly static CheckAlipaySignService Instance = new CheckAlipaySignService();
-        private CheckAlipaySignService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            try
-            {
-                PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
-                List<MerchantSign> deletes = new List<MerchantSign>();
-                List<MerchantSign> signs = RedisDbconn.Instance.GetList<MerchantSign>("AlipaySignList", 1, 10000000); // TODO: 换成mysql存储遍历
-                foreach (MerchantSign sign in signs)
-                {
-                    string content = new AlipayFunction().QuerySignStatus(sign.BusinessCode);
-                    JsonData dic = JsonMapper.ToObject(content);
-                    if (dic["alipay_open_agent_order_query_response"]["code"].ToString() == "10000")
-                    {
-                        if (dic["alipay_open_agent_order_query_response"]["order_status"].ToString() == "MERCHANT_CONFIRM")
-                        {
-                            string sign_url = dic["alipay_open_agent_order_query_response"]["confirm_url"].ToString();
-                            PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId && m.QueryCount == 0);
-                            if (merchantadd != null)
-                            {
-                                merchantadd.QueryCount = 1;
-                                string confirm_url = "/static/alipay_confirm_url/";
-                                string fileName = function.MD5_16(Guid.NewGuid().ToString());
-                                function.CreateQRCode2(sign_url, fileName, "/bsserver_com" + confirm_url);
-                                string SignUrlList = function.CheckNull(merchantadd.SeoKeyword);
-                                if (string.IsNullOrEmpty(SignUrlList))
-                                {
-                                    SignUrlList = "Alipay:" + confirm_url + ";";
-                                }
-                                else
-                                {
-                                    SignUrlList = "Alipay:" + confirm_url+ ";" + SignUrlList;
-                                }
-                                merchantadd.SeoKeyword = SignUrlList;
-                                merchantadd.SeoTitle = dic["alipay_open_agent_order_query_response"]["merchant_pid"].ToString();
-                                db.SaveChanges();
-                                RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                            }
-                        }
-                        else if (dic["alipay_open_agent_order_query_response"]["order_status"].ToString() == "MERCHANT_CONFIRM_SUCCESS")
-                        {
-                            PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId && m.QueryCount < 2);
-                            if (merchantadd != null)
-                            {
-                                merchantadd.QueryCount = 2;
-                                db.SaveChanges();
-                                RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                                if (merchantadd.Status == 2 && merchantadd.QueryCount == 2)
-                                {
-                                    PxcModels.MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                                    List<PxcModels.MerchantInfo> merchants = RedisDbconn.Instance.GetList<PxcModels.MerchantInfo>("TmpMerchantInfo:" + merchant.UserId, 1, 1000000);
-                                    PxcModels.MerchantInfo check = merchants.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                                    if (check != null)
-                                    {
-                                        merchants.Remove(check);
-                                        RedisDbconn.Instance.Clear("TmpMerchantInfo:" + merchant.UserId);
-                                        RedisDbconn.Instance.AddList("TmpMerchantInfo:" + merchant.UserId, merchants.ToArray());
-                                    }
-                                }
-                                deletes.Add(sign);
-                            }
-                        }
-                        else if (dic["alipay_open_agent_order_query_response"]["order_status"].ToString() == "MERCHANT_APPLY_ORDER_CANCELED")
-                        { 
-                            PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                            if (merchantadd != null)
-                            {
-                                string Season = function.CheckNull(merchantadd.SeoDescription);
-                                if (string.IsNullOrEmpty(Season))
-                                {
-                                    Season = "Alipay:" + dic["alipay_open_agent_order_query_response"]["reject_reason"].ToString() + ";";
-                                }
-                                else
-                                {
-                                    Season = Regex.Replace(Season, "Alipay:.*?;", "");
-                                    Season += "Alipay:" + dic["alipay_open_agent_order_query_response"]["reject_reason"].ToString() + ";";
-                                }
-                                merchantadd.SeoDescription = Season;
-                                merchantadd.QueryCount = -1;
-                                db.SaveChanges();
-                                RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                                PxcModels.MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                                if (merchant != null)
-                                {
-                                    merchant.Status = -1;
-                                    RedisDbconn.Instance.Set("MerchantInfo:" + sign.MerchantAddInfoId, merchant);
-                                }
-                                deletes.Add(sign);
-                            }
-                        }
-                    }
-                }
-                if (deletes.Count > 0)
-                {
-                    foreach (MerchantSign delete in deletes)
-                    {
-                        signs.Remove(delete);
-                    }
-                    RedisDbconn.Instance.Clear("AliaySignList");
-                    RedisDbconn.Instance.AddList("AliaySignList", signs.ToArray());
-                }
-                // jobInfo.Status = 1;
-                // jobInfo.Msg = "执行完成";
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
-            }
-            catch (Exception ex)
-            {
-                function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public:merchant:signerr");
-            }
-        }
-    }
-}

AppStart/Helper/CheckWeChatSignService.cs

@@ -1,143 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using MySystem.PxcModels;
-using Library;
-using LitJson;
-using System.Text.RegularExpressions;
-
-namespace MySystem
-{
-    public class CheckWeChatSignService
-    {
-        public readonly static CheckWeChatSignService Instance = new CheckWeChatSignService();
-        private CheckWeChatSignService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            try
-            {
-                PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
-                List<MerchantSign> deletes = new List<MerchantSign>();
-                List<MerchantSign> signs = RedisDbconn.Instance.GetList<MerchantSign>("WeChatSignList", 1, 10000000); // TODO: 换成mysql存储遍历
-                foreach (MerchantSign sign in signs)
-                {
-                    Dictionary<string, object> dic = new WeChatFunction().QueryMerchant(sign.BusinessCode);
-                    if (dic["applyment_state"].ToString() == "APPLYMENT_STATE_TO_BE_SIGNED")
-                    {
-                        string sign_url = dic["sign_url"].ToString();
-                        PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId && m.Status == 0);
-                        if (merchantadd != null)
-                        {
-                            merchantadd.Status = 1;
-                            string SignUrlList = function.CheckNull(merchantadd.SeoKeyword);
-                            if (string.IsNullOrEmpty(SignUrlList))
-                            {
-                                SignUrlList = "WeChat:" + sign_url + ";";
-                            }
-                            else
-                            {
-                                SignUrlList += "WeChat:" + sign_url+ ";";
-                            }
-                            merchantadd.SeoKeyword = SignUrlList;
-                            PxcModels.MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                            if (merchantadd.Status > 0 && merchantadd.QueryCount > 0)
-                            {
-                                merchant.Status = 1;
-                            }
-                            db.SaveChanges();
-                            RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                        }
-                    }
-                    else if (dic["applyment_state"].ToString() == "APPLYMENT_STATE_FINISHED")
-                    { 
-                        PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId && m.Status == 1);
-                        if (merchantadd != null)
-                        {
-                            merchantadd.Status = 2;
-                            RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                            PxcModels.MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                            if (merchantadd.Status == 2 && merchantadd.QueryCount == 2)
-                            {
-                                merchant.Status = 2;
-                            }
-                            db.SaveChanges();
-                            if (merchantadd.Status == 2 && merchantadd.QueryCount == 2)
-                            {
-                                List<MerchantInfo> merchants = RedisDbconn.Instance.GetList<MerchantInfo>("TmpMerchantInfo:" + merchant.UserId, 1, 1000000);
-                                MerchantInfo check = merchants.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                                if (check != null)
-                                {
-                                    merchants.Remove(check);
-                                    RedisDbconn.Instance.Clear("TmpMerchantInfo:" + merchant.UserId);
-                                    RedisDbconn.Instance.AddList("TmpMerchantInfo:" + merchant.UserId, merchants.ToArray());
-                                }
-                            }
-                            deletes.Add(sign);
-                        }
-                    }
-                    else if (dic["applyment_state"].ToString() == "APPLYMENT_STATE_REJECTED")
-                    {
-                        PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                        if (merchantadd != null)
-                        {
-                            string Season = function.CheckNull(merchantadd.SeoDescription);
-                            if (string.IsNullOrEmpty(Season))
-                            {
-                                Season = "WeChat:" + dic["reject_reason"].ToString() + ";";
-                            }
-                            else
-                            {
-                                Season = Regex.Replace(Season, "WeChat:.*?;", "");
-                                Season += "WeChat:" + dic["reject_reason"].ToString() + ";";
-                            }
-                            merchantadd.SeoDescription = Season;
-                            merchantadd.Status = -1;
-                            db.SaveChanges();
-                            RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                            PxcModels.MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                            if (merchant != null)
-                            {
-                                merchant.Status = -1;
-                                RedisDbconn.Instance.Set("MerchantInfo:" + sign.MerchantAddInfoId, merchant);
-                            }
-                            deletes.Add(sign);
-                        }
-                    }
-                    else
-                    {
-                        string sub_mchid = "";
-                        if (dic.ContainsKey("sub_mchid"))
-                        {
-                            sub_mchid = dic["sub_mchid"].ToString();
-                            PxcModels.MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
-                            if (merchantadd != null)
-                            {
-                                merchantadd.SubMchid = sub_mchid;
-                                db.SaveChanges();
-                                RedisDbconn.Instance.Set("MerchantAddInfo:" + sign.MerchantAddInfoId, merchantadd);
-                            }
-                        }
-                    }
-                }
-                if (deletes.Count > 0)
-                {
-                    foreach (MerchantSign delete in deletes)
-                    {
-                        signs.Remove(delete);
-                    }
-                    RedisDbconn.Instance.Clear("WeChatSignList");
-                    RedisDbconn.Instance.AddList("WeChatSignList", signs.ToArray());
-                }
-                // jobInfo.Status = 1;
-                // jobInfo.Msg = "执行完成";
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
-            }
-            catch (Exception ex)
-            {
-                function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public:merchant:signerr");
-            }
-        }
-    }
-}

AppStart/Helper/Profit/DiviService.cs

@@ -1,130 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using MySystem.PxcModels;
-using Library;
-using LitJson;
-
-namespace MySystem
-{
-    public class DiviService
-    {
-        public readonly static DiviService Instance = new DiviService();
-        private DiviService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            string content = "";
-            try
-            {
-                string Msg = CheckData();
-                // jobInfo.Status = Msg == "success" ? 1: 0;
-                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "DiviBack");
-            }
-            catch (Exception ex)
-            {
-                if (!string.IsNullOrEmpty(content))
-                {
-                    Dictionary<string, string> data = new Dictionary<string, string>();
-                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    data.Add("ErrMsg", ex.ToString());
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "diviback_err");
-                }
-                else
-                {
-                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "diviback_service");
-                }
-            }
-        }
-
-        //检查机具扣费情况
-        private string CheckData()
-        {
-            DateTime StatDate = DateTime.Now.AddMonths(-1);
-            DateTime StartDate = DateTime.Parse(StatDate.ToString("yyyy-MM") + "-01 00:00:00");
-            DateTime EndDate = StartDate.AddMonths(1);
-            string TradeMonth = StatDate.ToString("yyyyMM");
-            WebCMSEntities db = new WebCMSEntities();
-            using (var tran = db.Database.BeginTransaction())
-            {
-                try
-                {
-                    List<UserAccountRecord> list = db.UserAccountRecord.Where(m => m.CreateDate >= StartDate && m.CreateDate < EndDate && m.Status == -1).ToList();
-                    foreach (UserAccountRecord sub in list)
-                    {
-                        UserAccount account = db.UserAccount.FirstOrDefault(m => m.UserId == sub.UserId);
-                        if (account == null)
-                        {
-                            account = db.UserAccount.Add(new UserAccount()
-                            {
-                                Id = sub.UserId,
-                                CreateDate = DateTime.Now,
-                                UserId = sub.UserId,
-                                UserProperty = 0,
-                                UserType = 2,
-                            }).Entity;
-                            db.SaveChanges();
-                        }
-                        decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-                        decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-                        decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-                        account.BalanceAmount += sub.ChangeAmount;
-                        account.TotalAmount += sub.ChangeAmount;
-                        decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-                        decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-                        decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-                        UserAccountRecord edit = db.UserAccountRecord.FirstOrDefault(m => m.Id == sub.Id);
-                        if (edit != null)
-                        {
-                            edit.Status = 0;
-                            edit.BeforeTotalAmount += BeforeTotalAmount; //变更前总金额
-                            edit.AfterTotalAmount += AfterTotalAmount; //变更后总金额
-                            edit.BeforeFreezeAmount += BeforeFreezeAmount; //变更前冻结金额
-                            edit.AfterFreezeAmount += AfterFreezeAmount; //变更后冻结金额
-                            edit.BeforeBalanceAmount += BeforeBalanceAmount; //变更前余额
-                            edit.AfterBalanceAmount += AfterBalanceAmount; //变更后余额
-                        }
-                        db.SaveChanges();
-
-                        //首页-快联盟产品-收益查看-分红奖励
-                        List<TradeProfitItem> DiviList = RedisDbconn.Instance.GetList<TradeProfitItem>("TradeProfit:Divi:" + sub.UserId + ":" + sub.ProductType, 1, 1000000);
-                        TradeProfitItem Check = DiviList.FirstOrDefault(m => m.TradeMonthValue == TradeMonth);
-                        if (Check == null)
-                        {
-                            DiviList.Add(new TradeProfitItem()
-                            {
-                                TradeProfit = sub.ChangeAmount,
-                                TradeMonth = sub.CreateDate.Value.ToString("yyyy年MM月"),
-                                TradeMonthValue = sub.CreateDate.Value.ToString("yyyyMM"),
-                                CreateDate = DateTime.Now,
-                            });
-                        }
-                        else
-                        {
-                            Check.TradeProfit += sub.ChangeAmount;
-                        }
-                        RedisDbconn.Instance.Clear("TradeProfit:Divi:" + sub.UserId + ":" + sub.ProductType);
-                        RedisDbconn.Instance.AddList("TradeProfit:Divi:" + sub.UserId + ":" + sub.ProductType, DiviList.ToArray());
-
-                    }
-                    
-                    tran.Commit();
-                }
-                catch (Exception ex)
-                {
-                    tran.Rollback();
-                    ErrorMsg msg = new ErrorMsg()
-                    {
-                        Time = DateTime.Now,
-                        ErrorContent = ex.ToString(),
-                    };
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(msg), "DiviServiceError");
-                }
-            }
-            db.Dispose();
-            return "success";
-        }
-    }
-}

AppStart/Helper/Profit/FluxService.cs

@@ -1,164 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using MySystem.PxcModels;
-using Library;
-using LitJson;
-
-namespace MySystem
-{
-    public class FluxService
-    {
-        public readonly static FluxService Instance = new FluxService();
-        private FluxService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            string content = "";
-            try
-            {
-                string Msg = CheckFlux();
-                // jobInfo.Status = Msg == "success" ? 1: 0;
-                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "FluxBack");
-            }
-            catch (Exception ex)
-            {
-                if (!string.IsNullOrEmpty(content))
-                {
-                    Dictionary<string, string> data = new Dictionary<string, string>();
-                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    data.Add("ErrMsg", ex.ToString());
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "fluxback_err");
-                }
-                else
-                {
-                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "fluxback_service");
-                }
-            }
-        }
-
-        //检查机具扣费情况
-        private string CheckFlux()
-        {
-            DateTime StatDate = DateTime.Now.AddMonths(-1);
-            DateTime StartDate = DateTime.Parse(StatDate.ToString("yyyy-MM") + "-01 00:00:00");
-            DateTime EndDate = StartDate.AddMonths(1);
-            string TradeMonth = StatDate.ToString("yyyyMM");
-            WebCMSEntities db = new WebCMSEntities();
-            using (var tran = db.Database.BeginTransaction())
-            {
-                try
-                {
-                    List<FluxProfitSummary> list = db.FluxProfitSummary.Where(m => m.TradeMonth == TradeMonth && m.CheckStatus == 0).ToList();
-                    foreach (FluxProfitSummary sub in list)
-                    {
-                        int UserId = sub.UserId; //创客
-                        decimal FluxProfitAmt = sub.FluxProfitAmt; //交易分润
-                        decimal ActualProfit = 0;
-                        //核对
-                        bool check = db.FluxProfitDetail.Any(m => m.UserId == sub.UserId && m.TradeDate == sub.TradeMonth);
-                        if (check)
-                        {
-                            ActualProfit = db.FluxProfitDetail.Where(m => m.UserId == sub.UserId && m.TradeDate == sub.TradeMonth).Sum(m => m.FluxProfitAmt);
-                        }
-                        if (ActualProfit == FluxProfitAmt)
-                        {
-                            //核对成功
-                            FluxProfitSummary edit = db.FluxProfitSummary.FirstOrDefault(m => m.Id == sub.Id);
-                            if (edit != null)
-                            {
-                                edit.CheckStatus = 1;
-                                db.SaveChanges();
-                            }
-                            UserAccount account = db.UserAccount.FirstOrDefault(m => m.UserId == sub.UserId);
-                            if (account == null)
-                            {
-                                account = db.UserAccount.Add(new UserAccount()
-                                {
-                                    Id = sub.UserId,
-                                    CreateDate = DateTime.Now,
-                                    UserId = sub.UserId,
-                                    UserProperty = 0,
-                                    UserType = 2,
-                                }).Entity;
-                                db.SaveChanges();
-                            }
-                            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-                            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-                            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-                            account.BalanceAmount += FluxProfitAmt;
-                            account.TotalAmount += FluxProfitAmt;
-                            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-                            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-                            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-                            db.SaveChanges();
-                            UserAccountRecord accountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
-                            {
-                                CreateDate = DateTime.Now,
-                                UpdateDate = DateTime.Now,
-                                UserId = sub.UserId, //创客
-                                ChangeType = 60, //变动类型
-                                ProductType = sub.BrandId, //产品类型
-                                ChangeAmount = FluxProfitAmt, //变更金额
-                                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
-                                AfterTotalAmount = AfterTotalAmount, //变更后总金额
-                                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
-                                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
-                                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
-                                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
-                            }).Entity;
-                            db.SaveChanges();
-
-                            RedisDbconn.Instance.HAddNumber("TmpFluxProfit", sub.UserId + "_" + sub.BrandId + "_" + StatDate.ToString("yyyy年MM月") + "_" + StatDate.ToString("yyyyMM"), FluxProfitAmt);
-                        }
-                        else
-                        {
-                            ErrorMsg msg = new ErrorMsg()
-                            {
-                                Time = DateTime.Now,
-                                ErrorContent = "同步流量卡分佣失败，数据不一致",
-                                Obj = Newtonsoft.Json.JsonConvert.SerializeObject(sub),
-                            };
-                            RedisDbconn.Instance.AddList("FluxServiceWarning", msg);
-                        }
-                    }
-
-                    //首页-快联盟产品-收益查看-流量卡分佣
-                    Dictionary<string, decimal> datalist = RedisDbconn.Instance.HGetAll<decimal>("TmpFluxProfit");
-                    foreach (string key in datalist.Keys)
-                    {
-                        string[] fields = key.Split('_');
-                        string UserId = fields[0];
-                        string BrandId = fields[1];
-                        string TradeM = fields[2];
-                        string TradeMValue = fields[3];
-                        RedisDbconn.Instance.AddList("FluxProfitSummary:" + UserId + ":" + BrandId, new TradeProfitItem()
-                        {
-                            TradeProfit = datalist[key],
-                            TradeMonth = TradeM,
-                            TradeMonthValue = TradeMValue,
-                            CreateDate = DateTime.Now,
-                        });
-                    }
-                    RedisDbconn.Instance.Clear("TmpFluxProfit");
-                    
-                    tran.Commit();
-                }
-                catch (Exception ex)
-                {
-                    tran.Rollback();
-                    ErrorMsg msg = new ErrorMsg()
-                    {
-                        Time = DateTime.Now,
-                        ErrorContent = ex.ToString(),
-                    };
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(msg), "ProfitServiceError");
-                }
-            }
-            db.Dispose();
-            return "success";
-        }
-    }
-}

AppStart/Helper/Profit/ProfitService.cs

@@ -1,178 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using MySystem.PxcModels;
-using Library;
-using LitJson;
-
-namespace MySystem
-{
-    public class ProfitService
-    {
-        public readonly static ProfitService Instance = new ProfitService();
-        private ProfitService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            string content = "";
-            try
-            {
-                string Msg = Profit();
-                // jobInfo.Status = Msg == "success" ? 1: 0;
-                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "ProfitBack");
-            }
-            catch (Exception ex)
-            {
-                if (!string.IsNullOrEmpty(content))
-                {
-                    Dictionary<string, string> data = new Dictionary<string, string>();
-                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    data.Add("ErrMsg", ex.ToString());
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "profitback_err");
-                }
-                else
-                {
-                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "profitback_service");
-                }
-            }
-        }
-
-        //验证并同步到账户
-        private string Profit()
-        {
-            DateTime StatDate = DateTime.Now.AddMonths(-1);
-            DateTime StartDate = DateTime.Parse(StatDate.ToString("yyyy-MM") + "-01 00:00:00");
-            DateTime EndDate = StartDate.AddMonths(1);
-            string TradeMonth = StatDate.ToString("yyyyMM");
-            WebCMSEntities db = new WebCMSEntities();
-            using (var tran = db.Database.BeginTransaction())
-            {
-                try
-                {
-                    List<ProfitRewardRecord> list = db.ProfitRewardRecord.Where(m => m.TradeMonth == TradeMonth && m.CheckStatus == 0).ToList();
-                    foreach (ProfitRewardRecord sub in list)
-                    {
-                        int UserId = sub.UserId; //创客
-                        int MerchantId = sub.MerchantId; //商户
-                        int BrandId = sub.BrandId; //品牌
-                        int ProfitType = sub.ProfitType; //创客分润类型 直营-0，团队-1
-                        decimal ProfitMoney = sub.TradeProfit; //交易分润
-                        decimal ActualProfit = 0;
-                        if (ProfitType == 0)
-                        {
-                            bool check = db.ProfitRecord.Any(m => m.UserId == sub.UserId && m.MerchantId == sub.MerchantId && m.BrandId == sub.BrandId && m.TradeDate >= StartDate && m.TradeDate <= EndDate);
-                            if (check)
-                            {
-                                ActualProfit = db.ProfitRecord.Where(m => m.UserId == sub.UserId && m.MerchantId == sub.MerchantId && m.BrandId == sub.BrandId && m.TradeDate >= StartDate && m.TradeDate <= EndDate).Sum(m => m.ProfitAmount);
-                            }
-                        }
-                        else if (ProfitType == 1)
-                        {
-                            string UserIdString = "," + sub.UserId + ",";
-                            bool check = db.ProfitRecord.Any(m => m.ParentNav.Contains(UserIdString) && m.MerchantId == sub.MerchantId && m.BrandId == sub.BrandId && m.TradeDate >= StartDate && m.TradeDate <= EndDate);
-                            if (check)
-                            {
-                                ActualProfit = db.ProfitRecord.Where(m => m.ParentNav.Contains(UserIdString) && m.MerchantId == sub.MerchantId && m.BrandId == sub.BrandId && m.TradeDate >= StartDate && m.TradeDate <= EndDate).Sum(m => m.ProfitAmount);
-                            }
-                        }
-                        if (ActualProfit == ProfitMoney)
-                        {
-                            ProfitRewardRecord edit = db.ProfitRewardRecord.FirstOrDefault(m => m.Id == sub.Id);
-                            if (edit != null)
-                            {
-                                edit.CheckStatus = 1;
-                                db.SaveChanges();
-                            }
-                            UserAccount account = db.UserAccount.FirstOrDefault(m => m.UserId == sub.UserId);
-                            if (account == null)
-                            {
-                                account = db.UserAccount.Add(new UserAccount()
-                                {
-                                    Id = sub.UserId,
-                                    CreateDate = DateTime.Now,
-                                    UserId = sub.UserId,
-                                    UserProperty = 0,
-                                    UserType = 2,
-                                }).Entity;
-                                db.SaveChanges();
-                            }
-                            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-                            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-                            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-                            account.BalanceAmount += ProfitMoney;
-                            account.TotalAmount += ProfitMoney;
-                            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-                            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-                            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-                            db.SaveChanges();
-                            UserAccountRecord accountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
-                            {
-                                CreateDate = DateTime.Now,
-                                UpdateDate = DateTime.Now,
-                                UserId = sub.UserId, //创客
-                                ChangeType = 1, //变动类型
-                                ProductType = sub.BrandId, //产品类型
-                                ChangeAmount = ProfitMoney, //变更金额
-                                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
-                                AfterTotalAmount = AfterTotalAmount, //变更后总金额
-                                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
-                                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
-                                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
-                                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
-                                TransRecordNo = sub.RecordNo, //交易流水编号
-                                Remark = "",
-                            }).Entity;
-                            db.SaveChanges();
-
-                            RedisDbconn.Instance.HAddNumber("TmpTradeProfit", sub.UserId + "_" + BrandId + "_" + StatDate.ToString("yyyy年MM月") + "分润_" + StatDate.ToString("yyyyMM"), ProfitMoney);
-                        }
-                        else
-                        {
-                            ErrorMsg msg = new ErrorMsg()
-                            {
-                                Time = DateTime.Now,
-                                ErrorContent = "同步交易分润失败，数据不一致",
-                                Obj = Newtonsoft.Json.JsonConvert.SerializeObject(sub),
-                            };
-                            RedisDbconn.Instance.AddList("ProfitServiceWarning", msg);
-                        }
-                    }
-
-                    //首页-快联盟产品-收益查看-交易分润
-                    Dictionary<string, decimal> datalist = RedisDbconn.Instance.HGetAll<decimal>("TmpTradeProfit");
-                    foreach (string key in datalist.Keys)
-                    {
-                        string[] fields = key.Split('_');
-                        string UserId = fields[0];
-                        string BrandId = fields[1];
-                        string TradeM = fields[2];
-                        string TradeMValue = fields[3];
-                        RedisDbconn.Instance.AddList("TradeProfit:" + UserId + ":" + BrandId, new TradeProfitItem()
-                        {
-                            TradeProfit = datalist[key],
-                            TradeMonth = TradeM,
-                            TradeMonthValue = TradeMValue,
-                            CreateDate = DateTime.Now,
-                        });
-                    }
-                    RedisDbconn.Instance.Clear("TmpTradeProfit");
-                    tran.Commit();
-                }
-                catch (Exception ex)
-                {
-                    tran.Rollback();
-                    ErrorMsg msg = new ErrorMsg()
-                    {
-                        Time = DateTime.Now,
-                        ErrorContent = ex.ToString(),
-                    };
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(msg), "ProfitServiceError");
-                }
-            }
-            db.Dispose();
-            return "success";
-        }
-    }
-}

AppStart/Helper/Profit/TeamTopService.cs

@@ -1,39 +0,0 @@
-using System.Threading;
-using System.Threading.Tasks;
-using System.Linq;
-using Microsoft.Extensions.Hosting;
-using MySystem.PxcModels;
-using MySystem;
-
-public class TeamTopService : BackgroundService
-{
-    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
-    {
-        while (!stoppingToken.IsCancellationRequested)
-        {
-            int timespan = 1000 * 60 * 60;
-            await Task.Delay(timespan).ContinueWith(tsk =>
-            {
-                WebCMSEntities db = new WebCMSEntities();
-
-                //首页-特训营-排行榜-个人
-                var personTops = db.TeamPersonDayTop.Select(m => new { m.Id, m.ActMerNum }).OrderByDescending(m => m.ActMerNum).ToList();
-                RedisDbconn.Instance.Clear("TeamPersonDayTop");
-                foreach (var sub in personTops)
-                {
-                    RedisDbconn.Instance.AddList("TeamPersonDayTop", sub.Id);
-                }
-
-                //首页-特训营-排行榜-团队
-                var teamTops = db.TeamDayTop.Select(m => new { m.Id, m.ActMerNum }).OrderByDescending(m => m.ActMerNum).ToList();
-                RedisDbconn.Instance.Clear("TeamDayTop");
-                foreach (var sub in teamTops)
-                {
-                    RedisDbconn.Instance.AddList("TeamDayTop", sub.Id);
-                }
-
-                db.Dispose();
-            });
-        }
-    }
-}

AppStart/Helper/StatService.cs

@@ -227,30 +227,6 @@ namespace MySystem
 
 
 
-
-
-
-        public void clear()
-        {
-            RedisDbconn.Instance.Clear("TotalAmount*");
-            RedisDbconn.Instance.Clear("TotalCloudPayAmount*");
-            RedisDbconn.Instance.Clear("TotalPosAmount*");
-            RedisDbconn.Instance.Clear("TeamTotalAmount*");
-            RedisDbconn.Instance.Clear("TeamTotalCloudPayAmount*");
-            RedisDbconn.Instance.Clear("TeamTotalPosAmount*");
-
-            // RedisDbconn.Instance.Clear("TotalUser*");
-            // RedisDbconn.Instance.Clear("TeamTotalUser*");
-            // RedisDbconn.Instance.Clear("AddUser*");
-            // RedisDbconn.Instance.Clear("TeamAddUser*");
-
-            // RedisDbconn.Instance.Clear("TotalPosMerchant*");
-            // RedisDbconn.Instance.Clear("TeamTotalPosMerchant*");
-
-            RedisDbconn.Instance.Clear("MerTotalAmount*");
-        }
-
-
         // 1. 前一天的绑定记录和创客信息匹配，设置商户型创客
         public void dosomething1(string date)
         {
@@ -840,8 +816,6 @@ namespace MySystem
                 }
                 RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize);
 
-                //收支明细
-                RedisDbconn.Instance.Clear("UserAccount:Income:" + GetUserId + ":" + monthString);
             }
         }
 
@@ -2039,45 +2013,17 @@ namespace MySystem
         private void StatMerchantTrade(string date)
         {
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
-            // WebCMSEntities db = new WebCMSEntities();
             try
             {
                 string start = date + " 00:00:00";
                 string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                 CustomerSqlConn.op("insert into PosMerchantTradeSummay (MerchantId,BrandId,TradeDate,TradeMonth,TradeAmount,CreateDate)  select *,now() from (select MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d') as TradeDate,DATE_FORMAT(CreateDate,'%Y%m') as TradeMonth,sum(TradeAmount) as TradeAmount from TradeRecord where Id>=13000000 and CreateDate>='" + start + "' and CreateDate<'" + end + "' and ActStatus=1 and BrandId!=14 group by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d'),TradeDate,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d')) tb", MysqlConn.SqlConnStr);
 
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*");
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "").Substring(0, 6)); //商户当月交易
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "")); //商户当日交易
-                // foreach (DataRow selfDr in selfdt.Rows)
-                // {
-                //     int BrandId = int.Parse(selfDr["BrandId"].ToString());
-                //     int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
-                //     string TradeDate = selfDr["TradeDate"].ToString();
-                //     TradeDate = TradeDate.Replace("-", "");
-                //     string TradeMonth = TradeDate.Substring(0, 6);
-                //     decimal TradeAmount = decimal.Parse(selfDr["TradeAmount"].ToString());
-                //     PosMerchantTradeSummay merStat = db.PosMerchantTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId);
-                //     if (merStat == null)
-                //     {
-                //         merStat = db.PosMerchantTradeSummay.Add(new PosMerchantTradeSummay()
-                //         {
-                //             MerchantId = MerchantId,
-                //             TradeMonth = TradeMonth,
-                //             TradeDate = TradeDate,
-                //             BrandId = BrandId,
-                //         }).Entity;
-                //         db.SaveChanges();
-                //     }
-                //     merStat.TradeAmount += TradeAmount;
-                //     db.SaveChanges();                    
-                // }
             }
             catch (Exception ex)
             {
                 function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
             }
-            // db.Dispose();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
         }
 

AppStart/Helper/StatServiceTmp.cs

@@ -172,9 +172,7 @@ namespace MySystem
                 string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                 OtherMySqlConn.op("delete from PosMerchantTradeSummay where TradeDate='" + TradeDate + "' and BrandId=7");
                 OtherMySqlConn.op("insert into PosMerchantTradeSummay (MerchantId,BrandId,TradeDate,TradeMonth,TradeAmount,CreateDate)  select *,now() from (select MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d') as TradeDate,DATE_FORMAT(CreateDate,'%Y%m') as TradeMonth,sum(TradeAmount) as TradeAmount from TradeRecord where CreateDate>='" + start + "' and CreateDate<'" + end + "' and BrandId=7 group by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d'),TradeDate,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d')) tb");
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*");
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "").Substring(0, 6)); //商户当月交易
-                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "")); //商户当日交易
+                
             }
             catch (Exception ex)
             {

AppStart/Helper/StatTimerService.cs

@@ -79,83 +79,5 @@ namespace MySystem
             db.Dispose();
         }
 
-        public void ResetUserData()
-        {
-            RedisDbconn.Instance.Clear("TotalUser:*");
-            RedisDbconn.Instance.Clear("TeamTotalUser:*");
-            RedisDbconn.Instance.Clear("AddUser:*");
-            RedisDbconn.Instance.Clear("TeamAddUser:*");
-            WebCMSEntities db = new WebCMSEntities();
-            // 统计创客数据
-            DataTable dt = dbconn.dtable("select Id,AuthFlag from Users where AuthFlag=1 order by Id");
-            foreach (DataRow dr in dt.Rows)
-            {
-                int UserId = int.Parse(dr["Id"].ToString()); //创客ID
-                DateTime date = DateTime.Parse(dr["AuthFlag"].ToString());
-                string TradeMonth = date.ToString("yyyyMM");
-                string TradeDate = date.ToString("yyyyMMdd");
-                int Level = 0;
-                while (UserId > 0)
-                {
-                    Level += 1;
-                    Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
-                    if (user != null)
-                    {
-                        if (user.AuthFlag == 1)
-                        {
-                            if (Level == 1)
-                            {
-                                RedisDbconn.Instance.AddInt("TotalUser:" + UserId); //累计总创客                
-                                RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeDate); //新增创客       
-                                RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeMonth); //新增创客
-                            }
-                            RedisDbconn.Instance.AddInt("TeamTotalUser:" + UserId); //累计总创客                
-                            RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeDate); //新增创客
-                            RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeMonth); //新增创客
-                        }
-                        UserId = user.ParentUserId;
-                    }
-                }
-            }
-            db.Dispose();
-        }
-
-        public void SetUserData(int uid)
-        {
-            WebCMSEntities db = new WebCMSEntities();
-            // 统计创客数据
-            DataTable dt = dbconn.dtable("select Id,AuthFlag from Users where Id=" + uid + " and AuthFlag=1 order by Id");
-            if (dt.Rows.Count > 0)
-            {
-                DataRow dr = dt.Rows[0];
-                int UserId = int.Parse(dr["Id"].ToString()); //创客ID
-                DateTime date = DateTime.Parse(dr["AuthFlag"].ToString());
-                string TradeMonth = date.ToString("yyyyMM");
-                string TradeDate = date.ToString("yyyyMMdd");
-                int Level = 0;
-                while (UserId > 0)
-                {
-                    Level += 1;
-                    Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
-                    if (user != null)
-                    {
-                        if (user.AuthFlag == 1)
-                        {
-                            if (Level == 1)
-                            {
-                                RedisDbconn.Instance.AddInt("TotalUser:" + UserId); //累计总创客                
-                                RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeDate); //新增创客       
-                                RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeMonth); //新增创客
-                            }
-                            RedisDbconn.Instance.AddInt("TeamTotalUser:" + UserId); //累计总创客                
-                            RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeDate); //新增创客
-                            RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeMonth); //新增创客
-                        }
-                        UserId = user.ParentUserId;
-                    }
-                }
-            }
-            db.Dispose();
-        }
     }
 }

AppStart/Helper/WeChatPayBackService.cs

@@ -1,117 +0,0 @@
-using System;
-using System.Collections.Generic;
-using Library;
-using LitJson;
-using System.Linq;
-using MySystem.PxcModels;
-using Org.BouncyCastle.Crypto.Modes;
-using Org.BouncyCastle.Crypto.Engines;
-using Org.BouncyCastle.Crypto.Parameters;
-using System.Text;
-
-namespace MySystem
-{
-    public class WeChatPayBackService
-    {
-        public readonly static WeChatPayBackService Instance = new WeChatPayBackService();
-        private WeChatPayBackService()
-        { }
-
-        public void Start(JobMqMsg jobInfo)
-        {
-            string content = "";
-            try
-            {
-                dosomething();
-                // string Msg = "success";
-                // jobInfo.Status = Msg == "success" ? 1 : 0;
-                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
-            }
-            catch (Exception ex)
-            {
-                if (!string.IsNullOrEmpty(content))
-                {
-                    Dictionary<string, string> data = new Dictionary<string, string>();
-                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    data.Add("ErrMsg", ex.ToString());
-                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
-                }
-                else
-                {
-                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
-                }
-            }
-        }
-
-        public void dosomething()
-        {
-            bool op = true;
-            while (op)
-            {
-                string content = RedisDbconn.Instance.RPop<string>("WeChatPayBack");
-                if (!string.IsNullOrEmpty(content))
-                {
-                    JsonData jsonObj = JsonMapper.ToObject(content);
-                    if (jsonObj.Count > 0)
-                    {
-                        if (jsonObj["event_type"].ToString() == "TRANSACTION.SUCCESS")
-                        {
-                            JsonData resource = jsonObj["resource"];
-                            //开始解密
-                            string WxPayResourceDecryptModel = AesGcmDecrypt(resource["associated_data"].ToString(), resource["nonce"].ToString(), resource["ciphertext"].ToString());
-                            // {\"sp_mchid\":\"1611167423\",\"sub_mchid\":\"1622024882\",\"sp_appid\":\"wxe2c051b3e46c0f6f\",\"out_trade_no\":\"2022022621562926396898863\",\"transaction_id\":\"4200001412202202267619496496\",\"trade_type\":\"JSAPI\",\"trade_state\":\"SUCCESS\",\"trade_state_desc\":\"支付成功\",\"bank_type\":\"OTHERS\",\"attach\":\"\",\"success_time\":\"2022-02-26T21:56:42+08:00\",\"payer\":{\"sp_openid\":\"omawy5W6jb0pgPfuKUVs6K3bEhzk\",\"sub_openid\":\"\"},\"amount\":{\"total\":1,\"payer_total\":1,\"currency\":\"CNY\",\"payer_currency\":\"CNY\"}}
-                            JsonData orderObj = JsonMapper.ToObject(WxPayResourceDecryptModel);
-                            string OrderNo = orderObj["out_trade_no"].ToString();
-                            WebCMSEntities db = new WebCMSEntities();
-                            ConsumerOrderForNo forNo = db.ConsumerOrderForNo.FirstOrDefault(m => m.OrderNo == OrderNo);
-                            if (forNo != null)
-                            {
-                                ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == forNo.OrderIds && m.Status == 0);
-                                if (order != null)
-                                {
-                                    order.Status = 1;
-                                    order.UpdateDate = DateTime.Now;
-                                    order.PayMoney = order.PayMoney;
-                                    order.MaxDivi = order.MaxDivi;
-                                    db.SaveChanges();
-                                    RedisDbconn.Instance.AddList("ConsumerOrdersStat", order.Id);
-                                    RedisDbconn.Instance.AddList("ConsumerOrders:Divi:List", order.Id.ToString());
-                                    RedisDbconn.Instance.AddRightList("ConsumerOrders:Divi:" + order.MerchantId, order);
-                                    // ConsumerOrdersStatService.Instance.Stat(order);
-                                }
-                            }
-                            db.Dispose();
-                        }
-                    }
-                }
-                else
-                {
-                    op = false;
-                }
-            }
-        }
-
-        private string ALGORITHM = "AES/GCM/NoPadding";
-        private int TAG_LENGTH_BIT = 128;
-        private int NONCE_LENGTH_BYTE = 12;
-        private string AES_KEY = "VyULlqfAW2gBfCNfLdupcL7zlha7d93F";//你的v3秘钥
-
-        public string AesGcmDecrypt(string associatedData, string nonce, string ciphertext)
-        {
-            GcmBlockCipher gcmBlockCipher = new GcmBlockCipher(new AesEngine());
-            AeadParameters aeadParameters = new AeadParameters(
-                new KeyParameter(Encoding.UTF8.GetBytes(AES_KEY)),
-                128,
-                Encoding.UTF8.GetBytes(nonce),
-                Encoding.UTF8.GetBytes(associatedData));
-            gcmBlockCipher.Init(false, aeadParameters);
-
-            byte[] data = Convert.FromBase64String(ciphertext);
-            byte[] plaintext = new byte[gcmBlockCipher.GetOutputSize(data.Length)];
-            int length = gcmBlockCipher.ProcessBytes(data, 0, data.Length, plaintext, 0);
-            gcmBlockCipher.DoFinal(plaintext, length);
-            return Encoding.UTF8.GetString(plaintext);
-        }
-    }
-}

AppStart/RabbitMQClient.cs

@@ -145,108 +145,7 @@ namespace MySystem
             consumer.Received += (a, e) =>
             {
                 string MsgContent = Encoding.Default.GetString(e.Body.ToArray());                
-                if (QueueName == "TimerStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    StatTimerService.Instance.Start(job);
-                }
-                else if (QueueName == "PosTradeStat")
-                {
-                    // JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    // StatService.Instance.Start(job);
-                }
-                else if (QueueName == "SycnSpServer")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    SycnSpService.Instance.Start(job);
-                }
-                else if (QueueName == "CheckWeChatSign")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    CheckWeChatSignService.Instance.Start(job);
-                }
-                else if (QueueName == "CheckAlipaySign")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    CheckAlipaySignService.Instance.Start(job);
-                }
-                else if (QueueName == "WeChatPayBack")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    WeChatPayBackService.Instance.Start(job);
-                }
-                else if (QueueName == "AlipayPayBack")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    AlipayPayBackService.Instance.Start(job);
-                }
-                else if (QueueName == "AlipayPayBack2")
-                {
-                    // JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    // AlipayPayBack2Service.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersDiviList")
-                { 
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ReceiveProfitService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersStatService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersReturnDo")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersReturnDoService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersReturnStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersReturnStatService.Instance.Start(job);
-                }
-                else if (QueueName == "MerchantConfirmList")
-                {
-                    MerchantConfirmService.Instance.Start(MsgContent);
-                }
-                else if (QueueName == "DeleteMySqlData")
-                {
-                    DeleteMySqlDataService.Instance.Start(MsgContent);
-                }
-                // else if (QueueName == "PublicMainServer")
-                // { 
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     ReceiveTaskService.Instance.Start(job);
-                // }
-                // else if (QueueName == "SycnTableData")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     if (job.BrandInfo.DataType == 1)
-                //     {
-                //         //同步激活
-                //         SycnActiveRewardService.Instance.Start(job);
-                //     }
-                //     else if (job.BrandInfo.DataType == 2)
-                //     {
-                //         //同步交易
-                //         SycnTradeRecordService.Instance.Start(job);
-                //     }
-                //     else if (job.BrandInfo.DataType == 8)
-                //     {
-                //         //同步商户
-                //         SycnMerchantInfoService.Instance.Start(job);
-                //     }
-                // }
-                // else if (QueueName == "ProfitForEverMonth")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     ProfitService.Instance.Start(job);
-                // }
-                // else if (QueueName == "FluxPrize")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     FluxService.Instance.Start(job);
-                // }
+                
                 channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
             };
             channel.BasicConsume(QueueName, false, consumer);