178天提前通知创客费率调升消息

监控机具互斥日志

AppStart/Helper/SetFeeFlagService.cs

@@ -0,0 +1,60 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Threading;
+using MySystem.Models;
+using Library;
+
+namespace MySystem
+{
+    /// <summary>
+    /// 设置机具费率标记并推送消息
+    /// </summary>
+    public class SetFeeFlagService
+    {
+        public readonly static SetFeeFlagService Instance = new SetFeeFlagService();
+        private SetFeeFlagService()
+        { }
+
+        public void Start()
+        {
+            Thread th = new Thread(doSomething);
+            th.IsBackground = true;
+            th.Start();
+        }
+
+        public void doSomething()
+        {
+            while (true)
+            {
+                if (DateTime.Now.Hour > 0 && DateTime.Now.Hour < 3)
+                {
+                    try
+                    {
+                        string check = function.ReadInstance("/Fee/check" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt");
+                        if (string.IsNullOrEmpty(check))
+                        {
+                            function.WritePage("/Fee/", "check" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString("HH:mm:ss"));
+                            WebCMSEntities db = new WebCMSEntities();
+                            var date = DateTime.Now.AddDays(-178);
+                            var posList = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BindingTime <= date && m.BindingState == 1 && m.UpFeeFlag == 0).ToList();
+                            //循环修改机具费率调升标记
+                            //统计需要推送消息的用户Id
+                            foreach (var item in posList)
+                            {
+                                string info = "{\"RecordId\":\"\",\"PosId\":\"" + item.Id + "\",\"Fee\": \"" + 0.63 + "\",\"Kind\": \"" + 1 + "\",\"OpMan\": \""+"系统"+"\"}";
+                                RedisDbconn.Instance.AddList("SetDepositQueue", info);
+                            }
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "机具费率标记设置异常");
+                    }
+                }
+                Thread.Sleep(1200000);
+            }
+        }
+    }
+}

AppStart/Helper/SycnSpServer/SycnSpMerchantService.cs

@@ -84,6 +84,7 @@ namespace MySystem
                                         Name = Name.Replace("个体商户", "");
                                         Name = Name.Replace("企业户", "");
                                         Name = Name.Replace("企业商户", "");
+                                        function.WriteLog(DateTime.Now.ToString() + "-----startNo:" + startNo + ",endNo:" + endNo + ",Name:" + Name, "监控机具是否互斥");
                                         bool check = db.PosMerchantInfo.Any(m => m.MerIdcardNo.StartsWith(startNo) && m.MerIdcardNo.EndsWith(endNo) && m.MerchantName.Contains(Name));
                                         if(check)
                                         {
@@ -98,6 +99,7 @@ namespace MySystem
                                         MerchantNo = Mer.MerNo,
                                     }).Entity;
                                     db.SaveChanges();
+                                    function.WriteLog("MerNo:" + Mer.MerNo + ",PosSn:" + pos.PosSn + ",IsFirst:" + IsFirst + "\n\n", "监控机具是否互斥");
                                 }
                                 // else
                                 // {

AppStart/Timer/StoreApplyHelper.cs

@@ -408,7 +408,6 @@ public class StoreApplyHelper
         ids.Add(3596);
         ids.Add(32630);
         ids.Add(11211);
-        ids.Add(59190);
         return ids;
     }
 

Startup.cs

@@ -216,6 +216,7 @@ namespace MySystem
             HelpProfitPreMerchantHelper.Instance.Start();
             SetDepositService.Instance.Start(); //调整费率（通知、标记）
             SetDepositPostService.Instance.Start(); //提交支付公司设置费率接口
+            SetFeeFlagService.Instance.Start(); //178天提前通知创客费率调升消息
 
             // StatService.Instance.StartPosActNum(); //实时统计激活数
             // StatService.Instance.StartNewUserNum(); //实时统计新增创客数