领导人达标奖增加广电卡存量交易

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -27,7 +27,7 @@ namespace MySystem
         {
             while(true)
             {
-                if(DateTime.Now.Hour >= 0 && DateTime.Now.Hour < 3 && DateTime.Now.Minute > 5)
+                if(DateTime.Now.Hour >= 0 && DateTime.Now.Hour < 12)
                 {
                     string check = function.ReadInstance("/LeaderComp/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
                     if(string.IsNullOrEmpty(check))
@@ -112,11 +112,13 @@ namespace MySystem
                     check = db.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14);
                     if (check)
                     {
-                        TradeAmount += db.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
+                        int ActCount = db.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus);
+                        ActCount += UserDataDbconn.Instance.GetSimActTradeAmt(UserId, month, "Team");
                         if(db.UserSimActSummary.Any(m => m.UserId == UserId && m.Kind == 1))
                         {
-                            TradeAmount -= db.UserSimActSummary.Where(m => m.UserId == UserId && m.Kind == 1).Sum(m => m.ActCount) * 10000;
+                            ActCount -= db.UserSimActSummary.Where(m => m.UserId == UserId && m.Kind == 1).Sum(m => m.ActCount);
                         }
+                        TradeAmount += ActCount * 10000;
                     }
                     sql += "insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount) values (now(), " + UserId + ", '" + month + "-" + checkMonth + "', " + TradeAmount + ");\n";
                     num += 1;

AppStart/UserDataDbconn.cs

@@ -0,0 +1,32 @@
+using System;
+using System.Collections.Generic;
+using Library;
+using System.Linq;
+using System.Data;
+using MySystem.ReadModels;
+
+namespace MySystem
+{
+    public class UserDataDbconn
+    {
+        public readonly static UserDataDbconn Instance = new UserDataDbconn();
+
+
+        #region 广电卡存量查询
+
+        public int GetSimActTradeAmt(int UserId, string Month, string Kind = "Self")
+        {
+            int ActCount = 0;
+            string PreMonth = DateTime.Parse(Month.Substring(0, 4) + "-" + Month.Substring(4, 2) + "-01 00:00:00").AddMonths(-1).ToString("yyyyMM");
+            DataTable dt = CustomerSqlConn.dtable("select SimValidAct" + Kind + "Count from KxsStatServer.SimValidAct" + PreMonth + " where UserId=" + UserId, MysqlConn.ReadSqlConnStr);
+            if(dt.Rows.Count > 0)
+            {
+                ActCount = int.Parse(function.CheckInt(dt.Rows[0]["SimValidAct" + Kind + "Count"].ToString()));
+            }
+            return ActCount;
+        }
+
+        #endregion
+
+    }
+}