处理分账结算异常问题

Startup.cs

@@ -89,6 +89,7 @@ namespace MySystem
             });
 
             MySystemLib.SystemPublicFuction.appcheck = "success";
+            RedisDbconn.csredis = new CSRedis.CSRedisClient(Configuration["Setting:RedisConnStr"]);
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
@@ -146,8 +147,8 @@ namespace MySystem
                 MerchantConfirmService.Instance.Start(); //提交商户进件
                 CheckWeChatSignService.Instance.Start(); //查询商户审核状态
                 CheckWeChatBindService.Instance.Start(); //执行好哒微信绑定appid
-                ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
-                ProfitShareService.Instance.StartCheck(); //复核头一天的分账
+                // ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
+                // ProfitShareService.Instance.StartCheck(); //复核头一天的分账
                 HaoDaExtHelper.Instance.StartWeChat();
                 HaoDaExtHelper.Instance.StartAlipay();
                 HaoDaExtQueryHelper.Instance.StartWeChat();

Util/HaoDa/ProfitShareService.cs

@@ -61,7 +61,6 @@ namespace MySystem
             string mchtNo = jsonData["mchtNo"].ToString();
             string status = jsonData["status"].ToString();
             string payTime = jsonData["payTime"].ToString();
-            string desc = jsonData["desc"].ToString();
             WebCMSEntities db = new WebCMSEntities();
             ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.TradePayNo == applyNo);
             if(order != null)
@@ -74,8 +73,9 @@ namespace MySystem
                 else
                 {
                     order.DivideFlag = -1;
+                    string desc = jsonData["desc"].ToString();
+                    order.DivideLog = desc;
                 }
-                order.DivideLog = desc;
                 db.SaveChanges();
                 RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":List", order.Id.ToString());
             }

Util/RedisDbconn.cs

@@ -6,17 +6,15 @@ namespace MySystem
     public class RedisDbconn
     {
         public readonly static RedisDbconn Instance = new RedisDbconn();
+        public static CSRedis.CSRedisClient csredis;
         private RedisDbconn()
         {
-            var csredis = new CSRedis.CSRedisClient(ConfigurationManager.AppSettings["RedisConnStr"].ToString());
-            //初始化 RedisHelper
-            RedisHelper.Initialization(csredis);
         }
 
         #region 设置单个字段
         public bool Set(string key, object value)
         {
-            return RedisHelper.Set(key, value);
+            return csredis.Set(key, value);
             // return false;
         }
         #endregion
@@ -24,7 +22,7 @@ namespace MySystem
         #region 整数累加
         public long AddInt(string key, long value = 1)
         {
-            return RedisHelper.IncrBy(key, value);
+            return csredis.IncrBy(key, value);
             // return 0;
         }
         #endregion
@@ -32,7 +30,7 @@ namespace MySystem
         #region 数字累加
         public decimal AddNumber(string key, decimal value = 1)
         {
-            return RedisHelper.IncrByFloat(key, value);
+            return csredis.IncrByFloat(key, value);
             // return 0;
         }
         #endregion
@@ -40,14 +38,14 @@ namespace MySystem
         #region 获取单个字段
         public T Get<T>(string key)
         {
-            return RedisHelper.Get<T>(key);
+            return csredis.Get<T>(key);
         }
         #endregion
 
         #region 设置散列字段
         public bool HSet(string key, string field, object value)
         {
-            return RedisHelper.HSet(key, field, value);
+            return csredis.HSet(key, field, value);
             // return false;
         }
         #endregion
@@ -55,7 +53,7 @@ namespace MySystem
         #region 散列整数累加
         public long HAddInt(string key, string field, long value = 1)
         {
-            return RedisHelper.HIncrBy(key, field, value);
+            return csredis.HIncrBy(key, field, value);
             // return 0;
         }
         #endregion
@@ -63,7 +61,7 @@ namespace MySystem
         #region 散列数字累加
         public decimal HAddNumber(string key, string field, decimal value = 1)
         {
-            return RedisHelper.HIncrByFloat(key, field, value);
+            return csredis.HIncrByFloat(key, field, value);
             // return 0;
         }
         #endregion
@@ -71,48 +69,48 @@ namespace MySystem
         #region 获取散列元素
         public T HGet<T>(string key, string field)
         {
-            return RedisHelper.HGet<T>(key, field);
+            return csredis.HGet<T>(key, field);
         }
         #endregion
 
         #region 获取散列所有元素
         public Dictionary<string, T> HGetAll<T>(string key)
         {
-            return RedisHelper.HGetAll<T>(key);
+            return csredis.HGetAll<T>(key);
         }
         #endregion
 
         #region 添加列表对象
         public long AddList(string key, object value)
         {
-            return RedisHelper.LPush(key, value);
+            return csredis.LPush(key, value);
             // return 0;
         }
         public long AddList(string key, object[] value)
         {
-            return RedisHelper.LPush(key, value);
+            return csredis.LPush(key, value);
             // return 0;
         }
         public long AddRightList(string key, object value)
         {
-            return RedisHelper.RPush(key, value);
+            return csredis.RPush(key, value);
             // return 0;
         }
         public T RPop<T>(string key)
         {
-            return RedisHelper.RPop<T>(key);
+            return csredis.RPop<T>(key);
         }
         #endregion
 
         #region 添加集合对象
         public long SAdd(string key, object value)
         {
-            return RedisHelper.SAdd(key, value);
+            return csredis.SAdd(key, value);
             // return 0;
         }
         public long SAdd(string key, object[] value)
         {
-            return RedisHelper.SAdd(key, value);
+            return csredis.SAdd(key, value);
             // return 0;
         }
         #endregion
@@ -120,14 +118,14 @@ namespace MySystem
         #region 获取集合对象
         public T[] SGetList<T>(string key)
         {
-            return RedisHelper.SMembers<T>(key);
+            return csredis.SMembers<T>(key);
         }
         #endregion
 
         #region 修改列表对象
         public bool SetList(string key, int index, object value)
         {
-            return RedisHelper.LSet(key, index, value);
+            return csredis.LSet(key, index, value);
             // return false;
         }
         #endregion
@@ -137,7 +135,7 @@ namespace MySystem
         {
             int start = (pageNum - 1) * pageSize;
             int end = start + pageSize - 1;
-            string[] list = RedisHelper.LRange(key, start, end);
+            string[] list = csredis.LRange(key, start, end);
             List<T> lists = new List<T>();
             foreach (string record in list)
             { 
@@ -150,21 +148,21 @@ namespace MySystem
         #region 移除列表对象
         public long DelFromList(string key, object value, int count = 1)
         {
-            return RedisHelper.LRem(key, count, value);
+            return csredis.LRem(key, count, value);
         }
         #endregion
 
         #region 移动列表元素位置
         public T RPopLPush<T>(string key, string tokey)
         {
-            return RedisHelper.RPopLPush<T>(key, tokey);
+            return csredis.RPopLPush<T>(key, tokey);
         }
         #endregion
 
         #region 添加排序列表对象
         public long AddSort(string key, object value, decimal score)
         {
-            return RedisHelper.ZAdd(key, (score, value));
+            return csredis.ZAdd(key, (score, value));
             // return 0;
         }
         #endregion
@@ -174,7 +172,7 @@ namespace MySystem
         {
             int start = (pageNum - 1) * pageSize;
             int end = start + pageSize;
-            string[] list = RedisHelper.ZRangeByScore(key, start, end);
+            string[] list = csredis.ZRangeByScore(key, start, end);
             List<T> lists = new List<T>();
             foreach (string record in list)
             { 
@@ -186,7 +184,7 @@ namespace MySystem
         {
             int start = (pageNum - 1) * pageSize;
             int end = start + pageSize;
-            string[] list = RedisHelper.ZRevRangeByScore(key, start, end);
+            string[] list = csredis.ZRevRangeByScore(key, start, end);
             List<T> lists = new List<T>();
             foreach (string record in list)
             { 
@@ -198,7 +196,7 @@ namespace MySystem
 
         public bool Remove(string key, long start, long end)
         {
-            return RedisHelper.LTrim(key, start, end);
+            return csredis.LTrim(key, start, end);
         }
 
         public bool RemoveTop(string key, long count)
@@ -208,24 +206,24 @@ namespace MySystem
 
         public long Count(string key)
         {
-            return RedisHelper.LLen(key);
+            return csredis.LLen(key);
         }
 
         public void Clear(string pattern)
         {
-            string[] keys = RedisHelper.Keys(pattern);
-            RedisHelper.Del(keys);
+            string[] keys = csredis.Keys(pattern);
+            csredis.Del(keys);
         }
 
         public string[] GetKeys(string pattern)
         { 
-            string[] keys = RedisHelper.Keys(pattern);
+            string[] keys = csredis.Keys(pattern);
             return keys;
         }
 
         public void SetExpire(string key, int expire)
         { 
-            RedisHelper.Expire(key, expire); //秒为单位
+            csredis.Expire(key, expire); //秒为单位
         }
     }
 }