浏览代码

增加每月重置小分仓额度(监听)队列

lcl 2 年之前
父节点
当前提交
e00baabb3f
共有 2 个文件被更改,包括 21 次插入1 次删除
  1. 19 0
      AppStart/Timer/ResetSmallStoreHelper.cs
  2. 2 1
      Startup.cs

+ 19 - 0
AppStart/Timer/ResetSmallStoreHelper.cs

@@ -15,6 +15,25 @@ public class ResetSmallStoreHelper
     {
     }
 
+    public void Listen()
+    {
+        Thread th = new Thread(ListenDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void ListenDo()
+    {
+        while (true)
+        {
+            if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 1 && DateTime.Now.Hour < 3)
+            {
+                RedisDbconn.Instance.AddList("ResetSmallStoreQueue", "1");
+            }
+            Thread.Sleep(600000);
+        }
+    }
+
     public void Start()
     {
         Thread th = new Thread(DoWorks);

+ 2 - 1
Startup.cs

@@ -211,7 +211,8 @@ namespace MySystem
             SetDepositPostService.Instance.Start(); //提交支付公司设置费率接口
             SetDepositPostService.Instance.StartKdb(); //监控开店宝费率设置结果
             SetFeeFlagService.Instance.Start(); //118天提前通知创客费率调升消息
-            ResetSmallStoreHelper.Instance.Start(); //每月重置小分仓额度
+            ResetSmallStoreHelper.Instance.Start(); //每月重置小分仓额度(执行)
+            ResetSmallStoreHelper.Instance.Listen(); //每月重置小分仓额度(监听)
             OperateService.Instance.Start(); //运营中心每天统计一次发货量、库存
             OperateAmountService.Instance.Start(); //运营中心额度变更
             OperateStockService.Instance.Start(); //运营中心库存实时更新