调整助利宝商机生成条件

AppStart/Helper/Profit/HelpProfitPreMerchantHelper.cs

@@ -51,7 +51,7 @@ namespace MySystem
             string BrandId = function.ReadInstance("/PublicParam/HelpProfitMerBrandId.txt");
             if(string.IsNullOrEmpty(GetCount))
             {
-                GetCount = "500";
+                GetCount = "200";
                 function.WritePage("/PublicParam/", "HelpProfitMerCount.txt", GetCount);
             }
             if(string.IsNullOrEmpty(BrandId))
@@ -60,7 +60,7 @@ namespace MySystem
                 function.WritePage("/PublicParam/", "HelpProfitMerBrandId.txt", BrandId);
             }
             RedisDbconn.Instance.Clear("HelpProfitMerchantIds");
-            DataTable dt = OtherMySqlConn.dtable("SELECT MerchantId,sum FROM( SELECT MerchantId,SUM(TradeAmount) sum FROM PosMerchantTradeSummay WHERE MerchantId not in (select MerchantId from HelpProfitMerIds) AND BrandId in (" + BrandId + ") AND TradeMonth in ('" + Month1 + "','" + Month2 + "','" + Month3 + "') GROUP BY MerchantId)a WHERE a.sum/3 >= 35000 and a.sum/3 <= 50000 limit " + GetCount);
+            DataTable dt = OtherMySqlConn.dtable("SELECT MerchantId,sum FROM( SELECT MerchantId,SUM(TradeAmount) sum FROM PosMerchantTradeSummay WHERE MerchantId not in (select MerchantId from HelpProfitMerIds) AND BrandId in (" + BrandId + ") AND TradeMonth in ('" + Month1 + "','" + Month2 + "','" + Month3 + "') GROUP BY MerchantId)a WHERE a.sum/3 >= 35000 and a.sum/3 <= 60000 limit " + GetCount);
             foreach(DataRow dr in dt.Rows)
             {
                 RedisDbconn.Instance.AddList("HelpProfitMerchantIds", int.Parse(function.CheckInt(dr["MerchantId"].ToString())));

AppStart/Helper/TestService.cs

@@ -443,28 +443,23 @@ namespace MySystem
             html += "</tr>";
             WebCMSEntities db = new WebCMSEntities();
             OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            DataTable dt = OtherMySqlConn.dtable("select DISTINCT UserId from TradeDaySummary where TradeMonth='" + month + "' and SeoTitle='team' and UserId>0");
+            DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where Id>=2194025 and TradeMonth='" + month + "' and SeoTitle='team' group by UserId having sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt)>=3000000 and sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt)<10000000");
             function.WriteLog("总数:" + dt.Rows.Count, "每月交易额统计");
             foreach(DataRow dr in dt.Rows)
             {
                 int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
-                decimal TradeAmt = 0;
+                decimal TradeAmt = decimal.Parse(function.CheckNum(dr[1].ToString()));
                 decimal MaxTradeAmt = 0;
-                DataTable userdt = OtherMySqlConn.dtable("select sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where TradeMonth='" + month + "' and SeoTitle='team' and UserId=" + UserId);
-                if(userdt.Rows.Count > 0)
-                {
-                    TradeAmt = decimal.Parse(function.CheckInt(userdt.Rows[0][0].ToString()));
-                }
                 List<decimal> subTradeAmtList = new List<decimal>();
                 DataTable subdt = OtherMySqlConn.dtable("select Id from Users where ParentUserId=" + UserId + " and AuthFlag=1");
                 foreach(DataRow subdr in subdt.Rows)
                 {
                     int SubUserId = int.Parse(function.CheckInt(subdr["Id"].ToString()));
                     decimal subTradeAmt = 0;
-                    DataTable subuserdt = OtherMySqlConn.dtable("select sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where TradeMonth='" + month + "' and SeoTitle='team' and UserId=" + SubUserId);
+                    DataTable subuserdt = OtherMySqlConn.dtable("select sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where Id>=2194025 and TradeMonth='" + month + "' and SeoTitle='team' and UserId=" + SubUserId);
                     if(subuserdt.Rows.Count > 0)
                     {
-                        subTradeAmt = decimal.Parse(function.CheckInt(subuserdt.Rows[0][0].ToString()));
+                        subTradeAmt = decimal.Parse(function.CheckNum(subuserdt.Rows[0][0].ToString()));
                     }
                     subTradeAmtList.Add(subTradeAmt);
                 }

Startup.cs

@@ -226,7 +226,7 @@ namespace MySystem
             // StatService.Instance.ListenFluxRecord();
             // StatService.Instance.StartEverDay2();
             // TestHelper.Instance.Start();
-            TestService.Instance.Start();
+            // TestService.Instance.Start();
             // StatService.Instance.StartEverDay();
             // RabbitMQClient.Instance.StartReceive("MerchantConfirmList");
             // RabbitMQClient.Instance.StartReceive("CheckWeChatSign");