|
|
@@ -43,7 +43,7 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天同步创客上级关联异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天同步创客上级关联异常");
|
|
|
}
|
|
|
Thread.Sleep(1800000);
|
|
|
}
|
|
|
@@ -63,13 +63,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);
|
|
|
}
|
|
|
@@ -88,13 +88,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);
|
|
|
}
|
|
|
@@ -113,13 +113,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);
|
|
|
}
|
|
|
@@ -138,13 +138,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);
|
|
|
}
|
|
|
@@ -166,13 +166,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);
|
|
|
}
|
|
|
@@ -375,7 +375,7 @@ namespace MySystem
|
|
|
PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
|
|
|
if (merchant != null && pos.ActivationTime.Value <= pos.BindingTime.Value.AddDays(30))
|
|
|
{
|
|
|
- function.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理激活奖励");
|
|
|
+ Utils.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理激活奖励");
|
|
|
string ParentNav = "";
|
|
|
Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
|
|
|
if (user != null)
|
|
|
@@ -415,7 +415,7 @@ namespace MySystem
|
|
|
if (GetUserId > 0)
|
|
|
{
|
|
|
doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize);
|
|
|
- function.WriteLog("ActPrize:" + ActPrize + "", "实时处理激活奖励");
|
|
|
+ Utils.WriteLog("ActPrize:" + ActPrize + "", "实时处理激活奖励");
|
|
|
}
|
|
|
}
|
|
|
else if(ActPrize == 0)
|
|
|
@@ -423,7 +423,7 @@ namespace MySystem
|
|
|
if(pos.BrandId == 6)
|
|
|
{
|
|
|
doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
|
|
|
- function.WriteLog("ActPrize:50", "实时处理激活奖励");
|
|
|
+ Utils.WriteLog("ActPrize:50", "实时处理激活奖励");
|
|
|
}
|
|
|
}
|
|
|
PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
|
|
|
@@ -485,16 +485,16 @@ namespace MySystem
|
|
|
}
|
|
|
foreach (PosMachinesTwo pos in posList.ToList())
|
|
|
{
|
|
|
- function.WriteLog(str: "机具号:" + pos.PosSn, "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("机具号:" + pos.PosSn, "无押金激活奖励日志");
|
|
|
PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
|
|
|
if (merchant != null)
|
|
|
{
|
|
|
- function.WriteLog("商户号:" + merchant.KqMerNo, "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("商户号:" + merchant.KqMerNo, "无押金激活奖励日志");
|
|
|
string ParentNav = "";
|
|
|
Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
|
|
|
if (user != null)
|
|
|
{
|
|
|
- function.WriteLog("机具所属人:" + user.Id, "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("机具所属人:" + user.Id, "无押金激活奖励日志");
|
|
|
int GetUserId = user.Id;
|
|
|
ParentNav = user.ParentNav;
|
|
|
int TopUserId = 0;
|
|
|
@@ -502,25 +502,25 @@ namespace MySystem
|
|
|
{
|
|
|
TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
|
|
|
}
|
|
|
- function.WriteLog("BindingTime:" + pos.BindingTime, "无押金激活奖励日志");
|
|
|
- function.WriteLog("ActivationTime:" + pos.ActivationTime, "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("BindingTime:" + pos.BindingTime, "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("ActivationTime:" + pos.ActivationTime, "无押金激活奖励日志");
|
|
|
if(pos.BindingTime.Value.AddDays(30) >= pos.ActivationTime)
|
|
|
{
|
|
|
- function.WriteLog("满足条件", "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("满足条件", "无押金激活奖励日志");
|
|
|
doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 30);
|
|
|
- function.WriteLog("已发放", "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("已发放", "无押金激活奖励日志");
|
|
|
|
|
|
DateTime now = pos.ActivationTime.Value;
|
|
|
//盟主奖励
|
|
|
if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("大盟主奖发放", "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("大盟主奖发放", "无押金激活奖励日志");
|
|
|
RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
|
|
|
}
|
|
|
//运营中心奖励
|
|
|
if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("运营中心奖发放", "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("运营中心奖发放", "无押金激活奖励日志");
|
|
|
RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
|
|
|
}
|
|
|
}
|
|
|
@@ -532,7 +532,7 @@ namespace MySystem
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- function.WriteLog("\n\n\n", "无押金激活奖励日志");
|
|
|
+ Utils.WriteLog("\n\n\n", "无押金激活奖励日志");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
}
|
|
|
@@ -623,13 +623,13 @@ namespace MySystem
|
|
|
//盟主奖励
|
|
|
if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
|
|
|
+ Utils.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
|
|
|
RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
|
|
|
}
|
|
|
//运营中心奖励
|
|
|
if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
|
|
|
+ Utils.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
|
|
|
RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
|
|
|
}
|
|
|
}
|
|
|
@@ -661,7 +661,7 @@ namespace MySystem
|
|
|
}
|
|
|
foreach (PosMachinesTwo pos in posList.ToList())
|
|
|
{
|
|
|
- function.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理来客吧0押激活奖励");
|
|
|
+ Utils.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理来客吧0押激活奖励");
|
|
|
PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
|
|
|
if (merchant != null)
|
|
|
{
|
|
|
@@ -685,17 +685,17 @@ namespace MySystem
|
|
|
//盟主奖励
|
|
|
if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
|
|
|
+ Utils.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
|
|
|
RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
|
|
|
}
|
|
|
//运营中心奖励
|
|
|
if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
|
|
|
{
|
|
|
- function.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
|
|
|
+ Utils.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
|
|
|
RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
|
|
|
}
|
|
|
}
|
|
|
- function.WriteLog("ActPrize:30", "实时处理来客吧0押激活奖励");
|
|
|
+ Utils.WriteLog("ActPrize:30", "实时处理来客吧0押激活奖励");
|
|
|
PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
|
|
|
if(item != null)
|
|
|
{
|
|
|
@@ -835,7 +835,7 @@ namespace MySystem
|
|
|
|
|
|
public void doActiveRewardFunc(WebCMSEntities db, PosMerchantInfo merchant, PosMachinesTwo pos, int GetUserId, string ParentNav, int TopUserId, decimal ActPrize, int ChangeType = 0, int ActType = 0)
|
|
|
{
|
|
|
- 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()
|
|
|
{
|
|
|
@@ -1270,7 +1270,7 @@ 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);
|
|
|
List<int> BrandIds = new List<int>();
|
|
|
@@ -1290,7 +1290,7 @@ namespace MySystem
|
|
|
PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && ((!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000) || BrandIds.Contains(m.BrandId)));
|
|
|
if (pos != null)
|
|
|
{
|
|
|
- function.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志");
|
|
|
bool IsGet = true;
|
|
|
if(Utils.Instance.IsWifi(pos.BrandId))
|
|
|
{
|
|
|
@@ -1305,15 +1305,15 @@ namespace MySystem
|
|
|
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) ?? new PosMerchantInfo();
|
|
|
- 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))
|
|
|
{
|
|
|
@@ -1370,8 +1370,8 @@ namespace MySystem
|
|
|
UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(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.UserType > 0 || puser.LeaderLevel > 0)
|
|
|
{
|
|
|
bool leaderOp = true;
|
|
|
@@ -1379,13 +1379,13 @@ 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, "开机奖励发放日志");
|
|
|
}
|
|
|
else if(puser.LeaderLevel == 0 && puser.UserType > 0)
|
|
|
{
|
|
|
DateTime now = DateTime.Now;
|
|
|
leaderOp = opdb.SysAdmin.Any(m => m.UserId == puser.Id && m.ExpireDate >= now);
|
|
|
- function.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
+ Utils.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
}
|
|
|
else if(puser.LeaderLevel > 0 && puser.UserType > 0)
|
|
|
{
|
|
|
@@ -1395,7 +1395,7 @@ namespace MySystem
|
|
|
}
|
|
|
if(leaderOp)
|
|
|
{
|
|
|
- function.WriteLog("满足条件", "开机奖励发放日志");
|
|
|
+ Utils.WriteLog("满足条件", "开机奖励发放日志");
|
|
|
int pTopUserId = 0;
|
|
|
if (!string.IsNullOrEmpty(puser.ParentNav))
|
|
|
{
|
|
|
@@ -1419,7 +1419,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
|
|
|
@@ -1444,7 +1444,7 @@ 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();
|
|
|
@@ -1452,22 +1452,22 @@ namespace MySystem
|
|
|
PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && m.CreditTrade >= 10000 && 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 (!IsGet)
|
|
|
{
|
|
|
// decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
|
|
|
- // function.WriteLog("押金:" + pos.SeoKeyword, "盟主开机奖励发放日志");
|
|
|
+ // Utils.WriteLog("押金:" + pos.SeoKeyword, "盟主开机奖励发放日志");
|
|
|
// if (ActPrize > 0)
|
|
|
// {
|
|
|
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))
|
|
|
{
|
|
|
@@ -1480,8 +1480,8 @@ namespace MySystem
|
|
|
UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(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;
|
|
|
@@ -1489,17 +1489,17 @@ namespace MySystem
|
|
|
{
|
|
|
DateTime now = DateTime.Now;
|
|
|
leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
|
|
|
- function.WriteLog("条件:1-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
+ Utils.WriteLog("条件:1-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
}
|
|
|
// else if(puser.LeaderLevel == 0 && puser.UserType > 0)
|
|
|
// {
|
|
|
// DateTime now = DateTime.Now;
|
|
|
// leaderOp = opdb.SysAdmin.Any(m => m.UserId == puser.Id && m.ExpireDate >= now);
|
|
|
- // function.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
+ // Utils.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
|
|
|
// }
|
|
|
if(leaderOp)
|
|
|
{
|
|
|
- function.WriteLog("满足条件", "盟主开机奖励发放日志");
|
|
|
+ Utils.WriteLog("满足条件", "盟主开机奖励发放日志");
|
|
|
int pTopUserId = 0;
|
|
|
if (!string.IsNullOrEmpty(puser.ParentNav))
|
|
|
{
|
|
|
@@ -1524,7 +1524,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
|
|
|
@@ -1726,7 +1726,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);
|
|
|
@@ -1889,16 +1889,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(-120);
|
|
|
int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
|
|
|
@@ -1961,11 +1961,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();
|
|
|
}
|
|
|
@@ -2104,7 +2104,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
|
|
|
{
|
|
|
@@ -2119,21 +2119,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());
|
|
|
@@ -2174,9 +2174,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());
|
|
|
@@ -2225,10 +2225,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);
|
|
|
}
|
|
|
@@ -2242,7 +2242,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"), "执行商户交易额日志");
|
|
|
try
|
|
|
{
|
|
|
string start = date + " 00:00:00";
|
|
|
@@ -2251,7 +2251,7 @@ namespace MySystem
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
|
|
|
}
|
|
|
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
@@ -2293,11 +2293,11 @@ namespace MySystem
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
tran.Rollback();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计WIFI商户的交易额");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计WIFI商户的交易额");
|
|
|
}
|
|
|
tran.Dispose();
|
|
|
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", "执行商户交易额日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2333,7 +2333,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");
|
|
|
@@ -2343,7 +2343,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)
|
|
|
@@ -2421,7 +2421,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);
|
|
|
@@ -2457,7 +2457,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);
|
|
|
@@ -2490,18 +2490,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();
|
|
|
@@ -2517,7 +2517,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");
|
|
|
@@ -2527,7 +2527,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)
|
|
|
@@ -2617,7 +2617,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);
|
|
|
@@ -2667,7 +2667,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);
|
|
|
@@ -2709,7 +2709,7 @@ namespace MySystem
|
|
|
}
|
|
|
startid = subuser.Id;
|
|
|
}
|
|
|
- function.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
+ Utils.WriteLog(startid.ToString(), "创客升级日志");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
@@ -2761,11 +2761,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();
|
|
|
@@ -2803,7 +2803,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
|
|
|
{
|
|
|
@@ -2813,14 +2813,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());
|
|
|
@@ -2853,9 +2853,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());
|
|
|
@@ -2886,16 +2886,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
|
|
|
{
|
|
|
@@ -2910,7 +2910,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());
|
|
|
@@ -2971,10 +2971,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", "实时执行创客激活数日志");
|
|
|
}
|
|
|
|
|
|
// 统计新增创客数
|
|
|
@@ -3006,7 +3006,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
|
|
|
{
|
|
|
@@ -3016,14 +3016,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());
|
|
|
@@ -3052,9 +3052,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());
|
|
|
@@ -3081,16 +3081,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
|
|
|
{
|
|
|
@@ -3105,7 +3105,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();
|
|
|
@@ -3160,10 +3160,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", "实时执行新增创客数日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -3198,7 +3198,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
|
|
|
{
|
|
|
@@ -3213,16 +3213,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());
|
|
|
@@ -3255,9 +3255,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());
|
|
|
@@ -3287,16 +3287,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
|
|
|
{
|
|
|
@@ -3317,7 +3317,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());
|
|
|
@@ -3379,10 +3379,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", "实时统计收益日志");
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -3412,7 +3412,7 @@ namespace MySystem
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\nPosId:" + content + "\n" + ex.ToString(), "押金奖励发放异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\nPosId:" + content + "\n" + ex.ToString(), "押金奖励发放异常");
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
@@ -3431,13 +3431,13 @@ namespace MySystem
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + pos.PosSn, "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + pos.PosSn, "服务费奖励发放日志");
|
|
|
decimal DepositNumber = decimal.Parse(function.CheckNum(Deposit));
|
|
|
- function.WriteLog("DepositNumber:" + DepositNumber, "服务费奖励发放日志");
|
|
|
- function.WriteLog("BuyUserId:" + pos.BuyUserId, "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("DepositNumber:" + DepositNumber, "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("BuyUserId:" + pos.BuyUserId, "服务费奖励发放日志");
|
|
|
if(DepositNumber > 0 && pos.BuyUserId > 0)
|
|
|
{
|
|
|
- function.WriteLog("满足条件", "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("满足条件", "服务费奖励发放日志");
|
|
|
decimal ActPrize = 0;
|
|
|
if(DepositNumber > 1000)
|
|
|
{
|
|
|
@@ -3446,7 +3446,7 @@ namespace MySystem
|
|
|
if(DepositNumber == 199) ActPrize = 100;
|
|
|
if(DepositNumber == 299) ActPrize = 200;
|
|
|
if(DepositNumber == 249) ActPrize = 160;
|
|
|
- function.WriteLog("ActPrize:" + ActPrize, "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("ActPrize:" + ActPrize, "服务费奖励发放日志");
|
|
|
if(ActPrize > 0)
|
|
|
{
|
|
|
Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
|
|
|
@@ -3457,7 +3457,7 @@ namespace MySystem
|
|
|
{
|
|
|
TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
|
|
|
}
|
|
|
- function.WriteLog("发放给:" + GetUserId, "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("发放给:" + GetUserId, "服务费奖励发放日志");
|
|
|
if((pos.BrandId == 12 || pos.BrandId == 13) && string.IsNullOrEmpty(merchant.KqMerNo))
|
|
|
{
|
|
|
if(!db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn && m.ActType == 1))
|
|
|
@@ -3469,10 +3469,10 @@ namespace MySystem
|
|
|
{
|
|
|
doActiveReward(db, merchant, pos, GetUserId, user.ParentNav, TopUserId, ActPrize, 0, 1);
|
|
|
}
|
|
|
- function.WriteLog("已发放", "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("已发放", "服务费奖励发放日志");
|
|
|
}
|
|
|
}
|
|
|
- function.WriteLog("\n\n\n", "服务费奖励发放日志");
|
|
|
+ Utils.WriteLog("\n\n\n", "服务费奖励发放日志");
|
|
|
}
|
|
|
|
|
|
|