|
|
@@ -36,16 +36,16 @@ namespace MySystem
|
|
|
}
|
|
|
public void StartResetMerchantDo()
|
|
|
{
|
|
|
- // while (true)
|
|
|
- // {
|
|
|
- // string content = RedisDbconn.Instance.RPop<string>("ResetMerchantStatDataQueue2");
|
|
|
- // if (!string.IsNullOrEmpty(content))
|
|
|
- // {
|
|
|
- // StatResetMerchantAmount(content);
|
|
|
- // }
|
|
|
- // Thread.Sleep(10000);
|
|
|
- // }
|
|
|
- StatResetMerchantAmount("{\"MerchantId\":\"" + 1702 + "\",\"StartDate\":\"" + 20231201 + "\",\"EndDate\":\"" + 20231212 + "\"}");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+ string content = RedisDbconn.Instance.RPop<string>("ResetMerchantStatDataQueue2");
|
|
|
+ if (!string.IsNullOrEmpty(content))
|
|
|
+ {
|
|
|
+ StatResetMerchantAmount(content);
|
|
|
+ }
|
|
|
+ Thread.Sleep(10000);
|
|
|
+ }
|
|
|
+ // StatResetMerchantAmount("{\"MerchantId\":\"" + 1702 + "\",\"StartDate\":\"" + 20231201 + "\",\"EndDate\":\"" + 20231212 + "\"}");
|
|
|
}
|
|
|
public void StatResetMerchantAmount(string content)
|
|
|
{
|
|
|
@@ -82,7 +82,7 @@ namespace MySystem
|
|
|
CustomerSqlConn.op("INSERT INTO UserAmountSummary (SeoTitle,PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct) select 'team' SeoTitle,PayMode,SUM(PayMoney) TotalAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate, " + UserId + " UserId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2);
|
|
|
}
|
|
|
|
|
|
- CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + " and TradeMonth='" + date.Replace("-", "").Substring(0, 6) + "'", AppConfig.Base.StatSqlConn2);
|
|
|
+ CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + "", AppConfig.Base.StatSqlConn2);
|
|
|
CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " (MerchantId,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount,TradeMonth) select MerchantId,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + smonth + "-01" + " 00:00:00' and CreateDate<'" + emonth + "-01" + " 00:00:00' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2);
|
|
|
|
|
|
CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummaryList" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + " and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.StatSqlConn2);
|