|
|
@@ -33,14 +33,6 @@ namespace MySystem
|
|
|
if(string.IsNullOrEmpty(check))
|
|
|
{
|
|
|
function.WritePage("/LeaderComp/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString());
|
|
|
- // if(DateTime.Now.Day == 1)
|
|
|
- // {
|
|
|
- // Ready(DateTime.Now.AddMonths(-1).ToString("yyyyMM"));
|
|
|
- // Thread.Sleep(2000);
|
|
|
- // CustomerSqlConn.op("insert into LeaderCompPrizeBak select * from LeaderCompPrize;insert into LeaderCompAddTradeBak select * from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
|
|
|
- // CustomerSqlConn.op("delete from LeaderCompTmpBak;insert into LeaderCompTmpBak (Id,EveryMonthData,ParentNav,ParentUserId) select Id,EveryMonthData,ParentNav,ParentUserId from LeaderCompTmp;", MysqlConn.SqlConnStr);
|
|
|
- // CustomerSqlConn.op("insert into LeaderCompTradeStatBak (`CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth`) select `CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth` from LeaderCompTradeStat;", MysqlConn.SqlConnStr);
|
|
|
- // }
|
|
|
Ready(DateTime.Now.ToString("yyyyMM"));
|
|
|
}
|
|
|
}
|
|
|
@@ -73,11 +65,8 @@ namespace MySystem
|
|
|
try
|
|
|
{
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
- ReadModels.WebCMSEntities readdb = new ReadModels.WebCMSEntities();
|
|
|
- OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
|
|
|
- MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
|
|
|
- MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
|
|
|
string MonthString = month;
|
|
|
+ string PreMonthString = DateTime.Parse(month.Substring(0, 4) + "-" + month.Substring(4, 2) + "-01 00:00:00").AddMonths(-1).ToString("yyyyMM");
|
|
|
|
|
|
//统计交易增量
|
|
|
function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
|
|
|
@@ -86,7 +75,7 @@ namespace MySystem
|
|
|
string sql = "";
|
|
|
int rownum = 0;
|
|
|
int num = 0;
|
|
|
- DataTable dt = CustomerSqlConn.dtable("select user_id,pid,pid_path,leader_type,(case when amt is null then 0 else amt end) amt from (select tb1.user_id,pid,pid_path,leader_type,trade_amt+act_trade_amt+unact_trade_amt+act_num-logout_num amt from (select user_id,sum(help_direct_trade_amt+pro_direct_trade_amt+pro_a_direct_trade_amt+pro_b_direct_trade_amt) trade_amt from kxs_user_trade_#{now,yyyyMM}# where total_type=1 and brand_id not in (18,19,20,21,29,101,100) group by user_id) tb1 LEFT JOIN (select user_id,sum(help_direct_trade_amt)*4 act_trade_amt,sum(pro_direct_trade_amt) unact_trade_amt from kxs_user_trade_#{now,yyyyMM}# where total_type=1 and brand_id in (101,100,18,19,20,21,29) group by user_id) tb2 on tb1.user_id=tb2.user_id LEFT JOIN (select user_id,sum(act_num)*10000 act_num from kxs_user_act_trade where total_type=1 and brand_id in (14,23,24,25,26,32) and trade_month<'#{now,yyyyMM}#' group by user_id) tb3 on tb1.user_id=tb3.user_id LEFT JOIN (select user_id,logout_num*10000 logout_num from kxs_user_logout_trade where total_type=1 and trade_month='#{now,-1,MONTH,yyyyMM}#') tb4 on tb1.user_id=tb4.user_id LEFT JOIN kxs_user.kxs_user u on tb1.user_id=u.id LEFT JOIN kxs_user.kxs_leader l on tb1.user_id=l.id and l.expired_date>now()) tball where amt>0", MysqlConn.JavaStatSqlConnStr);
|
|
|
+ DataTable dt = CustomerSqlConn.dtable("select user_id,pid,pid_path,leader_type,(case when amt is null then 0 else amt end) amt from (select tb1.user_id,pid,pid_path,leader_type,trade_amt+act_trade_amt+unact_trade_amt+act_num-logout_num amt from (select user_id,sum(help_direct_trade_amt+pro_direct_trade_amt+pro_a_direct_trade_amt+pro_b_direct_trade_amt) trade_amt from kxs_user_trade_" + month + " where total_type=1 and brand_id not in (18,19,20,21,29,101,100) group by user_id) tb1 LEFT JOIN (select user_id,sum(help_direct_trade_amt)*4 act_trade_amt,sum(pro_direct_trade_amt) unact_trade_amt from kxs_user_trade_" + month + " where total_type=1 and brand_id in (101,100,18,19,20,21,29) group by user_id) tb2 on tb1.user_id=tb2.user_id LEFT JOIN (select user_id,sum(act_num)*10000 act_num from kxs_user_act_trade where total_type=1 and brand_id in (14,23,24,25,26,32) and trade_month<'" + month + "' group by user_id) tb3 on tb1.user_id=tb3.user_id LEFT JOIN (select user_id,logout_num*10000 logout_num from kxs_user_logout_trade where total_type=1 and trade_month='" + PreMonthString + "') tb4 on tb1.user_id=tb4.user_id LEFT JOIN kxs_user.kxs_user u on tb1.user_id=u.id LEFT JOIN kxs_user.kxs_leader l on tb1.user_id=l.id and l.expired_date>now()) tball where amt>0", MysqlConn.JavaStatSqlConnStr);
|
|
|
function.WriteLog("交易数:" + dt.Rows.Count.ToString(), "领导人达标奖励日志");
|
|
|
foreach(DataRow dr in dt.Rows)
|
|
|
{
|
|
|
@@ -122,7 +111,7 @@ namespace MySystem
|
|
|
// List<LeaderCompTradeStat> stats = db.LeaderCompTradeStat.Where(m => m.StatMonth == MonthString).ToList();
|
|
|
DataTable stats = CustomerSqlConn.dtable("select UserId,ParentUserId,ParentNav,TradeAmount,LeaderType,(select sum(TradeAmount) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigTradeAmount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount<30000000) SmallCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType=2) LeaderCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType>2) OperaterCount from LeaderCompTradeStat p where StatMonth='" + MonthString + "' and UserId>1", MysqlConn.SqlConnStr);
|
|
|
function.WriteLog(stats.Rows.Count.ToString(), "领导人达标奖励日志");
|
|
|
- string sql = "";
|
|
|
+ string sqlString = "";
|
|
|
foreach(DataRow stat in stats.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(function.CheckInt(stat["UserId"].ToString()));
|
|
|
@@ -188,17 +177,13 @@ namespace MySystem
|
|
|
operaterOnePrize = 6000;
|
|
|
}
|
|
|
decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
|
|
|
- sql += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (0," + totalAmount + "," + tradePrize + ",now(),'" + MonthString + "'," + ParentUserId + ");";
|
|
|
+ sqlString += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (0," + totalAmount + "," + tradePrize + ",now(),'" + MonthString + "'," + ParentUserId + ");";
|
|
|
}
|
|
|
}
|
|
|
db.SaveChanges();
|
|
|
- readdb.SaveChanges();
|
|
|
- opdb.Dispose();
|
|
|
- mpmaindb.Dispose();
|
|
|
- mpmaindb2.Dispose();
|
|
|
function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
|
|
|
|
|
|
- CustomerSqlConn.op(sql, MysqlConn.JavaUserSqlConnStr);
|
|
|
+ CustomerSqlConn.op(sqlString, MysqlConn.JavaUserSqlConnStr);
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
