改造激活奖励队列

AppStart/Helper/StatService.cs

@@ -48,9 +48,16 @@ namespace MySystem
             }
         }
 
-        public void ActiveReward(JobMqMsg jobInfo)
+
+        public void StartActiveReward()
+        {
+            Thread th = new Thread(ActiveReward);
+            th.IsBackground = true;
+            th.Start();
+        }
+
+        public void ActiveReward()
         {
-            string content = "";
             try
             {
                 dosomething3();
@@ -59,18 +66,9 @@ namespace MySystem
             }
             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");
-                }
+                function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理激活记录异常");
             }
+            Thread.Sleep(30000);
         }
 
 

AppStart/Timer/ActiveRewardTimer.cs

@@ -1,36 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
-using System.Linq;
-using Microsoft.Extensions.Hosting;
-using MySystem;
-
-public class ActiveRewardTimer
-{
-    public readonly static ActiveRewardTimer Instance = new ActiveRewardTimer();
-    private ActiveRewardTimer()
-    {
-    }
-    
-    public void Start()
-    {
-        Thread th = new Thread(DoWorks);
-        th.IsBackground = true;
-        th.Start();
-    }
-
-    private void DoWorks()
-    {
-        while (true)
-        {
-            string MsgContent = RedisDbconn.Instance.RPop<string>("ActiveReward");
-            if (!string.IsNullOrEmpty(MsgContent))
-            {
-                JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                StatService.Instance.ActiveReward(job);
-            }
-            Thread.Sleep(30000);
-        }
-    }
-}

Startup.cs

@@ -187,7 +187,7 @@ namespace MySystem
             SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
             SycnSpMerchantRecordService.Instance.Start(); //同步SP商户记录数据
 
-            ActiveRewardTimer.Instance.Start(); //实时处理激活记录
+            StatService.Instance.StartActiveReward(); //实时处理激活记录
             StatService.Instance.StartOpenReward(); //实时获取开机奖励
             StatService.Instance.ListenFluxRecord(); //实时获取流量费分佣
             LeaderPrizeService.Instance.Start(); //大盟主奖励发奖