|
|
@@ -42,7 +42,7 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天重置交易额异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天重置交易额异常");
|
|
|
}
|
|
|
Thread.Sleep(3600000);
|
|
|
}
|
|
|
@@ -62,13 +62,13 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理激活奖励");
|
|
|
dosomething3();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理激活奖励");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理激活奖励异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理激活奖励异常");
|
|
|
}
|
|
|
Thread.Sleep(30000);
|
|
|
}
|
|
|
@@ -87,14 +87,14 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励");
|
|
|
activePrizeWithoutDeposit();
|
|
|
// activePrizeWithoutDeposit6();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理0押激活奖励");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理0押激活奖励异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理0押激活奖励异常");
|
|
|
}
|
|
|
Thread.Sleep(30000);
|
|
|
}
|
|
|
@@ -113,14 +113,14 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励");
|
|
|
activePrizeWithoutDeposit12();
|
|
|
// activePrizeWithoutDeposit122();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理盒易付0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理盒易付0押激活奖励");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理盒易付0押激活奖励异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理盒易付0押激活奖励异常");
|
|
|
}
|
|
|
Thread.Sleep(30000);
|
|
|
}
|
|
|
@@ -142,13 +142,13 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理广电卡激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理广电卡激活奖励");
|
|
|
StartSimActiveDo();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理广电卡激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理广电卡激活奖励");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理广电卡激活奖励异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理广电卡激活奖励异常");
|
|
|
}
|
|
|
Thread.Sleep(29000);
|
|
|
}
|
|
|
@@ -669,7 +669,7 @@ namespace MySystem
|
|
|
bool check1 = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn && m.RewardAmount == ActPrize);
|
|
|
if (!check && !check1)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + pos.PosSn, "实时处理激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + pos.PosSn, "实时处理激活奖励");
|
|
|
Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
|
|
|
db.ActiveReward.Add(new ActiveReward()
|
|
|
{
|
|
|
@@ -1128,28 +1128,28 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "开机奖励发放日志");
|
|
|
int PosId = int.Parse(content);
|
|
|
Thread.Sleep(1000);
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && ((!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000) || m.BrandId == 14));
|
|
|
if (pos != null)
|
|
|
{
|
|
|
- function.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志");
|
|
|
if (pos.BindingTime > DateTime.Now.AddDays(-30))
|
|
|
{
|
|
|
decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
|
|
|
- function.WriteLog("押金:" + pos.SeoKeyword, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("押金:" + pos.SeoKeyword, "开机奖励发放日志");
|
|
|
if (ActPrize > 0 || pos.BrandId == 14)
|
|
|
{
|
|
|
PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
|
|
|
if (merchant != null)
|
|
|
{
|
|
|
- function.WriteLog("商户:" + merchant.KqMerNo, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("商户:" + merchant.KqMerNo, "开机奖励发放日志");
|
|
|
Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
|
|
|
if (user != null)
|
|
|
{
|
|
|
- function.WriteLog("所属人:" + user.MakerCode, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("所属人:" + user.MakerCode, "开机奖励发放日志");
|
|
|
string ParentNav = function.CheckNull(user.ParentNav) + "," + user.Id + ",";
|
|
|
if (!string.IsNullOrEmpty(ParentNav))
|
|
|
{
|
|
|
@@ -1165,15 +1165,15 @@ namespace MySystem
|
|
|
Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1);
|
|
|
if (puser != null && Prize > 0)
|
|
|
{
|
|
|
- function.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
|
|
|
// int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机
|
|
|
// int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
|
|
|
// int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
|
|
|
// int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
|
|
|
// int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机(不限购买或赠送)
|
|
|
- // function.WriteLog("条件:machineCount:" + machineCount + ",ActiveCount:" + ActiveCount + ",couponCount:" + couponCount + "", "开机奖励发放日志");
|
|
|
+ // Utils.WriteLog("条件:machineCount:" + machineCount + ",ActiveCount:" + ActiveCount + ",couponCount:" + couponCount + "", "开机奖励发放日志");
|
|
|
// if (machineCount + ActiveCount + couponCount >= 3)
|
|
|
- function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
|
|
|
if(puser.LeaderLevel > 0 || puser.UserType == 1)
|
|
|
{
|
|
|
bool leaderOp = true;
|
|
|
@@ -1181,11 +1181,11 @@ namespace MySystem
|
|
|
{
|
|
|
DateTime now = DateTime.Now;
|
|
|
leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
|
|
|
- function.WriteLog("条件:leaderOp:" + leaderOp, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("条件:leaderOp:" + leaderOp, "开机奖励发放日志");
|
|
|
}
|
|
|
if(leaderOp)
|
|
|
{
|
|
|
- function.WriteLog("满足条件", "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("满足条件", "开机奖励发放日志");
|
|
|
int pTopUserId = 0;
|
|
|
if (!string.IsNullOrEmpty(puser.ParentNav))
|
|
|
{
|
|
|
@@ -1318,7 +1318,7 @@ namespace MySystem
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常");
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
@@ -1520,7 +1520,7 @@ namespace MySystem
|
|
|
}
|
|
|
public void doFluxRecord()
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "执行流量费返佣");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "执行流量费返佣");
|
|
|
SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
DateTime start = DateTime.Now.AddDays(-20);
|
|
|
@@ -1681,16 +1681,16 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
|
|
|
}
|
|
|
}
|
|
|
spdb.Dispose();
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣");
|
|
|
}
|
|
|
public void CheckFluxForTrade()
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "扫描交易记录中的流量费");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "扫描交易记录中的流量费");
|
|
|
SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
|
|
|
DateTime start = DateTime.Now.AddDays(-20);
|
|
|
int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
|
|
|
@@ -1753,11 +1753,11 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描交易记录中的流量费异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描交易记录中的流量费异常");
|
|
|
}
|
|
|
}
|
|
|
spdb.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n", "扫描交易记录中的流量费");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n", "扫描交易记录中的流量费");
|
|
|
|
|
|
doFluxRecord();
|
|
|
}
|
|
|
@@ -1793,7 +1793,7 @@ namespace MySystem
|
|
|
public void StatTradeAmountEverDay(object sender)
|
|
|
{
|
|
|
string date = sender.ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -1808,21 +1808,21 @@ namespace MySystem
|
|
|
{
|
|
|
startId = startDt.Rows[0][0].ToString();
|
|
|
}
|
|
|
- function.WriteLog(startId + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(startId + "\n\n", "执行昨天交易额日志");
|
|
|
// DataTable endDt = OtherMySqlConn.dtable("select max(Id) from TradeRecord where CreateDate<'" + end + "'");
|
|
|
// if (endDt.Rows.Count > 0)
|
|
|
// {
|
|
|
// endId = endDt.Rows[0][0].ToString();
|
|
|
// }
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
|
|
|
- function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["Id"].ToString());
|
|
|
string ParentNav = userDr["ParentNav"].ToString();
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
DataTable selfdt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by BrandId,BankCardType,QrPayFlag");
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
foreach (DataRow selfDr in selfdt.Rows)
|
|
|
{
|
|
|
int BrandId = int.Parse(selfDr["BrandId"].ToString());
|
|
|
@@ -1863,9 +1863,9 @@ namespace MySystem
|
|
|
{
|
|
|
uids.Add(NavUserIdString + start);
|
|
|
int NavUserId = int.Parse(NavUserIdString);
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
DataTable teamDt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId,BankCardType,QrPayFlag");
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
foreach (DataRow teamDr in teamDt.Rows)
|
|
|
{
|
|
|
int BrandId = int.Parse(teamDr["BrandId"].ToString());
|
|
|
@@ -1914,10 +1914,10 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
|
|
|
|
|
|
StatMerchantTrade(date);
|
|
|
}
|
|
|
@@ -1933,7 +1933,7 @@ namespace MySystem
|
|
|
//统计商户交易额
|
|
|
private void StatMerchantTrade(string date)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
|
|
|
// WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -1969,10 +1969,10 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
|
|
|
}
|
|
|
// db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2008,7 +2008,7 @@ namespace MySystem
|
|
|
try
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
DateTime end = start.AddDays(1);
|
|
|
string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
|
@@ -2018,7 +2018,7 @@ namespace MySystem
|
|
|
while(op)
|
|
|
{
|
|
|
var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList();
|
|
|
- function.WriteLog(users.Count.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(users.Count.ToString(), "创客升级日志");
|
|
|
if(users.Count > 0)
|
|
|
{
|
|
|
foreach (var subuser in users)
|
|
|
@@ -2096,7 +2096,7 @@ namespace MySystem
|
|
|
}
|
|
|
if (AfterLevel > BeforeLevel && AfterLevel > 1 && upFlag)
|
|
|
{
|
|
|
- function.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
|
|
|
+ Utils.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
|
|
|
user.UserLevel = AfterLevel;
|
|
|
DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
|
|
|
@@ -2132,7 +2132,7 @@ namespace MySystem
|
|
|
}
|
|
|
if (AfterLevel < BeforeLevel && BeforeLevel > 1)
|
|
|
{
|
|
|
- function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
|
|
|
+ Utils.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
|
|
|
user.UserLevel = AfterLevel;
|
|
|
DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
|
|
|
@@ -2165,18 +2165,18 @@ namespace MySystem
|
|
|
}
|
|
|
startid = subuser.Id;
|
|
|
}
|
|
|
- function.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
op = false;
|
|
|
}
|
|
|
}
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(ex.ToString(), "创客升级异常");
|
|
|
+ Utils.WriteLog(ex.ToString(), "创客升级异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
mpmaindb.Dispose();
|
|
|
@@ -2192,7 +2192,7 @@ namespace MySystem
|
|
|
try
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
DateTime end = start.AddDays(1);
|
|
|
string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
|
@@ -2202,7 +2202,7 @@ namespace MySystem
|
|
|
while(op)
|
|
|
{
|
|
|
var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList();
|
|
|
- function.WriteLog(users.Count.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(users.Count.ToString(), "创客升级日志");
|
|
|
if(users.Count > 0)
|
|
|
{
|
|
|
foreach (var subuser in users)
|
|
|
@@ -2292,7 +2292,7 @@ namespace MySystem
|
|
|
}
|
|
|
if (AfterLevel > BeforeLevel && AfterLevel > 0 && upFlag)
|
|
|
{
|
|
|
- function.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
|
|
|
+ Utils.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
|
|
|
user.UserLevel = AfterLevel;
|
|
|
DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
|
|
|
@@ -2342,7 +2342,7 @@ namespace MySystem
|
|
|
}
|
|
|
if (AfterLevel < BeforeLevel && BeforeLevel > 0)
|
|
|
{
|
|
|
- function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
|
|
|
+ Utils.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
|
|
|
user.UserLevel = AfterLevel;
|
|
|
DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
|
|
|
@@ -2384,7 +2384,7 @@ namespace MySystem
|
|
|
}
|
|
|
startid = subuser.Id;
|
|
|
}
|
|
|
- function.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
@@ -2436,11 +2436,11 @@ namespace MySystem
|
|
|
op = false;
|
|
|
}
|
|
|
}
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "创客升级日志");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(ex.ToString(), "创客升级异常");
|
|
|
+ Utils.WriteLog(ex.ToString(), "创客升级异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
mpmaindb.Dispose();
|
|
|
@@ -2478,7 +2478,7 @@ namespace MySystem
|
|
|
public void StartPosActNumDo(object sender)
|
|
|
{
|
|
|
string date = sender.ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2488,14 +2488,14 @@ namespace MySystem
|
|
|
string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
|
|
|
List<string> uids = new List<string>();
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT BuyUserId from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "')");
|
|
|
- function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["Id"].ToString());
|
|
|
string ParentNav = userDr["ParentNav"].ToString();
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
DataTable selfdt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId=" + UserId + " group by BrandId");
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
foreach (DataRow selfDr in selfdt.Rows)
|
|
|
{
|
|
|
int BrandId = int.Parse(selfDr["BrandId"].ToString());
|
|
|
@@ -2528,9 +2528,9 @@ namespace MySystem
|
|
|
{
|
|
|
uids.Add(NavUserIdString + start);
|
|
|
int NavUserId = int.Parse(NavUserIdString);
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
DataTable teamDt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId");
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
foreach (DataRow teamDr in teamDt.Rows)
|
|
|
{
|
|
|
int BrandId = int.Parse(teamDr["BrandId"].ToString());
|
|
|
@@ -2561,16 +2561,16 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
|
|
|
Thread.Sleep(60000);
|
|
|
}
|
|
|
public void StartPosActNumEverTime()
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2585,7 +2585,7 @@ namespace MySystem
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')");
|
|
|
if (userDt.Rows.Count > 0)
|
|
|
{
|
|
|
- function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
|
|
|
+ Utils.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["BuyUserId"].ToString());
|
|
|
@@ -2646,10 +2646,10 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志");
|
|
|
}
|
|
|
|
|
|
// 统计新增创客数
|
|
|
@@ -2681,7 +2681,7 @@ namespace MySystem
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
string date = sender.ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2691,14 +2691,14 @@ namespace MySystem
|
|
|
string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
|
|
|
List<string> uids = new List<string>();
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
|
|
|
- function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["Id"].ToString());
|
|
|
string ParentNav = userDr["ParentNav"].ToString();
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
DataTable selfdt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentUserId=" + UserId + "");
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
foreach (DataRow selfDr in selfdt.Rows)
|
|
|
{
|
|
|
int AddCount = int.Parse(selfDr[0].ToString());
|
|
|
@@ -2727,9 +2727,9 @@ namespace MySystem
|
|
|
{
|
|
|
uids.Add(NavUserIdString + start);
|
|
|
int NavUserId = int.Parse(NavUserIdString);
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
DataTable teamDt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentNav like '%," + NavUserId + ",%'");
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
foreach (DataRow teamDr in teamDt.Rows)
|
|
|
{
|
|
|
int AddCount = int.Parse(teamDr[0].ToString());
|
|
|
@@ -2756,16 +2756,16 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
|
|
|
Thread.Sleep(60000);
|
|
|
}
|
|
|
public void StartNewUserNumEverTime()
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2780,7 +2780,7 @@ namespace MySystem
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d'),count(Id) from Users where Id in (" + ids.TrimEnd(',') + ") group by ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d')");
|
|
|
if(userDt.Rows.Count > 0)
|
|
|
{
|
|
|
- function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志");
|
|
|
+ Utils.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
string StatDate = userDr[1].ToString();
|
|
|
@@ -2835,10 +2835,10 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2873,7 +2873,7 @@ namespace MySystem
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
string date = sender.ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2888,16 +2888,16 @@ namespace MySystem
|
|
|
{
|
|
|
startId = startDt.Rows[0][0].ToString();
|
|
|
}
|
|
|
- function.WriteLog(startId + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(startId + "\n\n", "执行昨天收益日志");
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
|
|
|
- function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["Id"].ToString());
|
|
|
string ParentNav = userDr["ParentNav"].ToString();
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
DataTable selfdt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by ChangeType,ProductType");
|
|
|
- function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
foreach (DataRow selfDr in selfdt.Rows)
|
|
|
{
|
|
|
int ChangeType = int.Parse(selfDr["ChangeType"].ToString());
|
|
|
@@ -2930,9 +2930,9 @@ namespace MySystem
|
|
|
{
|
|
|
uids.Add(NavUserIdString + start);
|
|
|
int NavUserId = int.Parse(NavUserIdString);
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
DataTable teamDt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by ChangeType,ProductType");
|
|
|
- function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
foreach (DataRow teamDr in teamDt.Rows)
|
|
|
{
|
|
|
int ChangeType = int.Parse(teamDr["ChangeType"].ToString());
|
|
|
@@ -2962,16 +2962,16 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
|
|
|
}
|
|
|
|
|
|
public void StatProfitEverDayEverTime()
|
|
|
{
|
|
|
OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
try
|
|
|
{
|
|
|
@@ -2992,7 +2992,7 @@ namespace MySystem
|
|
|
DataTable userDt = OtherMySqlConn.dtable("select UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d'),sum(ChangeAmount) from UserAccountRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d')");
|
|
|
if (userDt.Rows.Count > 0)
|
|
|
{
|
|
|
- function.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志");
|
|
|
+ Utils.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志");
|
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
|
int UserId = int.Parse(userDr["UserId"].ToString());
|
|
|
@@ -3054,10 +3054,10 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志");
|
|
|
}
|
|
|
|
|
|
|