|
@@ -40,7 +40,7 @@ namespace MySystem
|
|
|
}
|
|
}
|
|
|
public void StatTradeAmount()
|
|
public void StatTradeAmount()
|
|
|
{
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
|
using (var tran = db.Database.BeginTransaction())
|
|
using (var tran = db.Database.BeginTransaction())
|
|
@@ -48,10 +48,10 @@ namespace MySystem
|
|
|
try
|
|
try
|
|
|
{
|
|
{
|
|
|
string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
|
|
string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
|
|
|
- function.WriteLog("开始时间:" + start, "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("开始时间:" + start, "统计商户和创客交易额日志2");
|
|
|
DataTable idsDt = CustomerSqlConn.dtable("select Id,UserId from ConsumerOrders where Id>=916515 and CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 100", AppConfig.Base.SqlConn2);
|
|
DataTable idsDt = CustomerSqlConn.dtable("select Id,UserId from ConsumerOrders where Id>=916515 and CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 100", AppConfig.Base.SqlConn2);
|
|
|
- function.WriteLog("查询条数:" + idsDt.Rows.Count, "统计商户和创客交易额日志2");
|
|
|
|
|
- function.WriteLog("1--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("查询条数:" + idsDt.Rows.Count, "统计商户和创客交易额日志2");
|
|
|
|
|
+ Utils.WriteLog("1--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
if(idsDt.Rows.Count > 0)
|
|
if(idsDt.Rows.Count > 0)
|
|
|
{
|
|
{
|
|
|
string ids = "";
|
|
string ids = "";
|
|
@@ -62,13 +62,13 @@ namespace MySystem
|
|
|
idlist.Add(int.Parse(function.CheckInt(idsDr["UserId"].ToString())));
|
|
idlist.Add(int.Parse(function.CheckInt(idsDr["UserId"].ToString())));
|
|
|
}
|
|
}
|
|
|
List<KxsMainModels.Users> users = maindb.Users.Where(m => idlist.Contains(m.Id)).ToList();
|
|
List<KxsMainModels.Users> users = maindb.Users.Where(m => idlist.Contains(m.Id)).ToList();
|
|
|
- function.WriteLog("ids:" + ids, "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("ids:" + ids, "统计商户和创客交易额日志2");
|
|
|
DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount),Sort from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),Sort", AppConfig.Base.SqlConn2);
|
|
DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount),Sort from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),Sort", AppConfig.Base.SqlConn2);
|
|
|
- function.WriteLog("统计人数:" + selfDt.Rows.Count, "统计商户和创客交易额日志2");
|
|
|
|
|
- function.WriteLog("2--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("统计人数:" + selfDt.Rows.Count, "统计商户和创客交易额日志2");
|
|
|
|
|
+ Utils.WriteLog("2--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
if (selfDt.Rows.Count > 0)
|
|
if (selfDt.Rows.Count > 0)
|
|
|
{
|
|
{
|
|
|
- function.WriteLog("开始循环", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("开始循环", "统计商户和创客交易额日志2");
|
|
|
foreach (DataRow selfDr in selfDt.Rows)
|
|
foreach (DataRow selfDr in selfDt.Rows)
|
|
|
{
|
|
{
|
|
|
int UserId = int.Parse(selfDr["UserId"].ToString());
|
|
int UserId = int.Parse(selfDr["UserId"].ToString());
|
|
@@ -86,9 +86,9 @@ namespace MySystem
|
|
|
string TradeMonth = TradeDate.Substring(0, 6);
|
|
string TradeMonth = TradeDate.Substring(0, 6);
|
|
|
int Sort = int.Parse(selfDr["Sort"].ToString());
|
|
int Sort = int.Parse(selfDr["Sort"].ToString());
|
|
|
|
|
|
|
|
- function.WriteLog("21--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("21--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
|
- function.WriteLog("创客交易额", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("创客交易额", "统计商户和创客交易额日志2");
|
|
|
//创客交易额
|
|
//创客交易额
|
|
|
// UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.Id > 1190107 && m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self" && m.Sort == Sort);
|
|
// UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.Id > 1190107 && m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self" && m.Sort == Sort);
|
|
|
// if (selfStat == null)
|
|
// if (selfStat == null)
|
|
@@ -135,10 +135,10 @@ namespace MySystem
|
|
|
// }
|
|
// }
|
|
|
// db.SaveChanges();
|
|
// db.SaveChanges();
|
|
|
|
|
|
|
|
- function.WriteLog("22--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("22--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
|
- function.WriteLog("商户交易额", "统计商户和创客交易额日志2");
|
|
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + MerchantId + ":" + IsAct + ":" + TradeMonth + ":" + TradeDate + ":" + PayMode + "----" + TradeAmount + ":" + TradeCount + ":" + ActualAmount, "统计商户交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("商户交易额", "统计商户和创客交易额日志2");
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + MerchantId + ":" + IsAct + ":" + TradeMonth + ":" + TradeDate + ":" + PayMode + "----" + TradeAmount + ":" + TradeCount + ":" + ActualAmount, "统计商户交易额日志2");
|
|
|
//商户交易额
|
|
//商户交易额
|
|
|
// MerchantAmountSummay merchantStat = db.MerchantAmountSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
|
|
// MerchantAmountSummay merchantStat = db.MerchantAmountSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
|
|
|
// if (merchantStat == null)
|
|
// if (merchantStat == null)
|
|
@@ -158,7 +158,7 @@ namespace MySystem
|
|
|
// merchantStat.TotalActual += ActualAmount;
|
|
// merchantStat.TotalActual += ActualAmount;
|
|
|
// db.SaveChanges();
|
|
// db.SaveChanges();
|
|
|
|
|
|
|
|
- // function.WriteLog("23--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ // Utils.WriteLog("23--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
|
MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
|
|
MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
|
|
|
if(merchant != null)
|
|
if(merchant != null)
|
|
@@ -180,9 +180,9 @@ namespace MySystem
|
|
|
}
|
|
}
|
|
|
db.SaveChanges();
|
|
db.SaveChanges();
|
|
|
|
|
|
|
|
- // function.WriteLog("24--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ // Utils.WriteLog("24--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
|
- // function.WriteLog(str: "码牌交易额", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ // Utils.WriteLog(str: "码牌交易额", "统计商户和创客交易额日志2");
|
|
|
// //码牌交易额
|
|
// //码牌交易额
|
|
|
// QrCodeAmountSummay qrcode = db.QrCodeAmountSummay.FirstOrDefault(m => m.SnNo == SnNo && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
|
|
// QrCodeAmountSummay qrcode = db.QrCodeAmountSummay.FirstOrDefault(m => m.SnNo == SnNo && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
|
|
|
// if (qrcode == null)
|
|
// if (qrcode == null)
|
|
@@ -202,27 +202,27 @@ namespace MySystem
|
|
|
// qrcode.TotalActual += ActualAmount;
|
|
// qrcode.TotalActual += ActualAmount;
|
|
|
// db.SaveChanges();
|
|
// db.SaveChanges();
|
|
|
|
|
|
|
|
- function.WriteLog("25--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog("25--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
|
// string jsonString = "{\"TradeDate\":\"" + TradeDate + "\",\"PayMoney\":\"" + TradeAmount + "\",\"TradeCount\":\"" + TradeCount + "\",\"MerchantActualAmount\":\"" + ActualAmount + "\",\"MerchantId\":\"" + MerchantId + "\",\"PayMode\":\"" + PayMode + "\",\"IsAct\":\"" + IsAct + "\"}";
|
|
// string jsonString = "{\"TradeDate\":\"" + TradeDate + "\",\"PayMoney\":\"" + TradeAmount + "\",\"TradeCount\":\"" + TradeCount + "\",\"MerchantActualAmount\":\"" + ActualAmount + "\",\"MerchantId\":\"" + MerchantId + "\",\"PayMode\":\"" + PayMode + "\",\"IsAct\":\"" + IsAct + "\"}";
|
|
|
// RedisDbconn.Instance.AddList("StatMerchantTradeSummaryQueue2", jsonString);
|
|
// RedisDbconn.Instance.AddList("StatMerchantTradeSummaryQueue2", jsonString);
|
|
|
- function.WriteLog(str: "----", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog(str: "----", "统计商户和创客交易额日志2");
|
|
|
}
|
|
}
|
|
|
CustomerSqlConn.op("update ConsumerOrders set Version=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SqlConn2);
|
|
CustomerSqlConn.op("update ConsumerOrders set Version=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SqlConn2);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
tran.Commit();
|
|
tran.Commit();
|
|
|
- function.WriteLog(str: "提交", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog(str: "提交", "统计商户和创客交易额日志2");
|
|
|
}
|
|
}
|
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
|
{
|
|
{
|
|
|
tran.Rollback();
|
|
tran.Rollback();
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户和创客交易额异常");
|
|
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户和创客交易额异常");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
db.Dispose();
|
|
db.Dispose();
|
|
|
maindb.Dispose();
|
|
maindb.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志2");
|
|
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志2");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 统计创客激活数
|
|
// 统计创客激活数
|
|
@@ -245,7 +245,7 @@ namespace MySystem
|
|
|
}
|
|
}
|
|
|
public void StartPosActNumEverTime()
|
|
public void StartPosActNumEverTime()
|
|
|
{
|
|
{
|
|
|
- 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();
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
|
try
|
|
try
|
|
@@ -261,7 +261,7 @@ namespace MySystem
|
|
|
DataTable userDt = CustomerSqlConn.dtable("select UserId,DATE_FORMAT(UpdateDate,'%Y%m%d'),count(Id) from MerchantInfo where Id in (" + ids.TrimEnd(',') + ") group by UserId,DATE_FORMAT(UpdateDate,'%Y%m%d')", AppConfig.Base.SqlConn2);
|
|
DataTable userDt = CustomerSqlConn.dtable("select UserId,DATE_FORMAT(UpdateDate,'%Y%m%d'),count(Id) from MerchantInfo where Id in (" + ids.TrimEnd(',') + ") group by UserId,DATE_FORMAT(UpdateDate,'%Y%m%d')", AppConfig.Base.SqlConn2);
|
|
|
if (userDt.Rows.Count > 0)
|
|
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)
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
{
|
|
|
int UserId = int.Parse(userDr["UserId"].ToString());
|
|
int UserId = int.Parse(userDr["UserId"].ToString());
|
|
@@ -316,17 +316,17 @@ namespace MySystem
|
|
|
}
|
|
}
|
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
|
{
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
}
|
|
}
|
|
|
db.Dispose();
|
|
db.Dispose();
|
|
|
maindb.Dispose();
|
|
maindb.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 test()
|
|
public void test()
|
|
|
{
|
|
{
|
|
|
- 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();
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
|
|
|
try
|
|
try
|
|
@@ -342,7 +342,7 @@ namespace MySystem
|
|
|
DataTable userDt = CustomerSqlConn.dtable("select UserId,DATE_FORMAT(SignDate,'%Y%m%d'),count(Id) from MerchantInfo where Id in (" + ids.TrimEnd(',') + ") group by UserId,DATE_FORMAT(SignDate,'%Y%m%d')", AppConfig.Base.SqlConn2);
|
|
DataTable userDt = CustomerSqlConn.dtable("select UserId,DATE_FORMAT(SignDate,'%Y%m%d'),count(Id) from MerchantInfo where Id in (" + ids.TrimEnd(',') + ") group by UserId,DATE_FORMAT(SignDate,'%Y%m%d')", AppConfig.Base.SqlConn2);
|
|
|
if (userDt.Rows.Count > 0)
|
|
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)
|
|
foreach (DataRow userDr in userDt.Rows)
|
|
|
{
|
|
{
|
|
|
int UserId = int.Parse(userDr["UserId"].ToString());
|
|
int UserId = int.Parse(userDr["UserId"].ToString());
|
|
@@ -397,11 +397,11 @@ namespace MySystem
|
|
|
}
|
|
}
|
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
|
{
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
|
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
|
|
|
}
|
|
}
|
|
|
db.Dispose();
|
|
db.Dispose();
|
|
|
maindb.Dispose();
|
|
maindb.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", "实时执行创客激活数日志");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|