|
@@ -2406,7 +2406,7 @@ namespace MySystem
|
|
{
|
|
{
|
|
StatMyUserThisTradeListen();
|
|
StatMyUserThisTradeListen();
|
|
}
|
|
}
|
|
- int timespan = 1000 * 3600;
|
|
|
|
|
|
+ int timespan = 1000 * 3600 * 3;
|
|
Thread.Sleep(timespan);
|
|
Thread.Sleep(timespan);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -2419,11 +2419,16 @@ namespace MySystem
|
|
// TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
// TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
// }
|
|
// }
|
|
DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
|
|
DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
|
|
|
|
+ string sql = "";
|
|
foreach (DataRow dr in list.Rows)
|
|
foreach (DataRow dr in list.Rows)
|
|
{
|
|
{
|
|
string UserId = dr["UserId"].ToString();
|
|
string UserId = dr["UserId"].ToString();
|
|
string ThisMonthTrade = dr[1].ToString();
|
|
string ThisMonthTrade = dr[1].ToString();
|
|
- OtherMySqlConn.op("update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId);
|
|
|
|
|
|
+ sql += "update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId + ";";
|
|
|
|
+ }
|
|
|
|
+ if(!string.IsNullOrEmpty(sql))
|
|
|
|
+ {
|
|
|
|
+ OtherMySqlConn.op(sql);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|