|
|
@@ -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,13 +87,13 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励");
|
|
|
activePrizeWithoutDeposit();
|
|
|
- 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);
|
|
|
}
|
|
|
@@ -112,13 +112,13 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励");
|
|
|
activePrizeWithoutDeposit12();
|
|
|
- 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);
|
|
|
}
|
|
|
@@ -137,13 +137,13 @@ namespace MySystem
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理来客吧0押激活奖励");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":start", "实时处理来客吧0押激活奖励");
|
|
|
activePrizeWithoutDeposit15();
|
|
|
- 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);
|
|
|
}
|
|
|
@@ -165,13 +165,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);
|
|
|
}
|
|
|
@@ -737,7 +737,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()
|
|
|
{
|
|
|
@@ -1197,29 +1197,29 @@ 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, "开机奖励发放日志");
|
|
|
bool IsGet = db.OpenRewardDetail.Any(m => m.SnNo == pos.PosSn);
|
|
|
if (pos.BindingTime > DateTime.Now.AddDays(-30) && !IsGet)
|
|
|
{
|
|
|
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))
|
|
|
{
|
|
|
@@ -1236,8 +1236,8 @@ namespace MySystem
|
|
|
UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(db, UserId);
|
|
|
if (puser.Id > 0 && Prize > 0)
|
|
|
{
|
|
|
- function.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
|
|
|
- function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
|
|
|
if(puser.LeaderLevel > 0 || puser.UserType > 0)
|
|
|
{
|
|
|
bool leaderOp = true;
|
|
|
@@ -1245,11 +1245,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))
|
|
|
{
|
|
|
@@ -1382,7 +1382,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
|
|
|
@@ -1584,7 +1584,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);
|
|
|
@@ -1747,16 +1747,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")));
|
|
|
@@ -1819,11 +1819,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();
|
|
|
}
|
|
|
@@ -1893,7 +1893,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
|
|
|
{
|
|
|
@@ -1908,21 +1908,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());
|
|
|
@@ -1963,9 +1963,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());
|
|
|
@@ -2014,10 +2014,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);
|
|
|
}
|
|
|
@@ -2033,7 +2033,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
|
|
|
{
|
|
|
@@ -2069,10 +2069,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", "执行商户交易额日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2108,7 +2108,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");
|
|
|
@@ -2118,7 +2118,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)
|
|
|
@@ -2196,7 +2196,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);
|
|
|
@@ -2232,7 +2232,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);
|
|
|
@@ -2265,18 +2265,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();
|
|
|
@@ -2292,7 +2292,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");
|
|
|
@@ -2302,7 +2302,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)
|
|
|
@@ -2392,7 +2392,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);
|
|
|
@@ -2442,7 +2442,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);
|
|
|
@@ -2484,7 +2484,7 @@ namespace MySystem
|
|
|
}
|
|
|
startid = subuser.Id;
|
|
|
}
|
|
|
- function.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
@@ -2536,11 +2536,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();
|
|
|
@@ -2578,7 +2578,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
|
|
|
{
|
|
|
@@ -2588,14 +2588,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());
|
|
|
@@ -2628,9 +2628,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());
|
|
|
@@ -2661,16 +2661,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
|
|
|
{
|
|
|
@@ -2685,7 +2685,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());
|
|
|
@@ -2746,10 +2746,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", "实时执行创客激活数日志");
|
|
|
}
|
|
|
|
|
|
// 统计新增创客数
|
|
|
@@ -2781,7 +2781,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
|
|
|
{
|
|
|
@@ -2791,14 +2791,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());
|
|
|
@@ -2827,9 +2827,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());
|
|
|
@@ -2856,16 +2856,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
|
|
|
{
|
|
|
@@ -2880,7 +2880,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();
|
|
|
@@ -2935,10 +2935,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", "实时执行新增创客数日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2973,7 +2973,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
|
|
|
{
|
|
|
@@ -2988,16 +2988,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());
|
|
|
@@ -3030,9 +3030,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());
|
|
|
@@ -3062,16 +3062,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
|
|
|
{
|
|
|
@@ -3092,7 +3092,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());
|
|
|
@@ -3154,10 +3154,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", "实时统计收益日志");
|
|
|
}
|
|
|
|
|
|
|