|
|
@@ -36,15 +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);
|
|
|
- }
|
|
|
+ // while (true)
|
|
|
+ // {
|
|
|
+ // string content = RedisDbconn.Instance.RPop<string>("ResetMerchantStatDataQueue2");
|
|
|
+ // if (!string.IsNullOrEmpty(content))
|
|
|
+ // {
|
|
|
+ // StatResetMerchantAmount(content);
|
|
|
+ // }
|
|
|
+ // Thread.Sleep(10000);
|
|
|
+ // }
|
|
|
+ StatResetMerchantAmount("{\"MerchantId\":\"" + 1415 + "\",\"StartDate\":\"" + 20231127 + "\",\"EndDate\":\"" + 20231127 + "\"}");
|
|
|
}
|
|
|
public void StatResetMerchantAmount(string content)
|
|
|
{
|
|
|
@@ -115,7 +116,7 @@ namespace MySystem
|
|
|
if (selfDt.Rows.Count == 1)
|
|
|
{
|
|
|
CustomerSqlConn.op("UPDATE MerchantTradeSummary" + LastDate + " SET NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + "", conn);
|
|
|
- CustomerSqlConn.op("UPDATE MerchantTradeSummaryList" + TradeMonth + " NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + " AND TradeDate='" + LastDate + "'", conn);
|
|
|
+ CustomerSqlConn.op("UPDATE MerchantTradeSummaryList" + TradeMonth + " SET NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + " AND TradeDate='" + LastDate + "'", conn);
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
@@ -126,7 +127,7 @@ namespace MySystem
|
|
|
if (check)
|
|
|
{
|
|
|
CustomerSqlConn.op("UPDATE MerchantTradeSummary" + LastDate + " SET NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + "", conn);
|
|
|
- CustomerSqlConn.op("UPDATE MerchantTradeSummaryList" + TradeMonth + " NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + " AND TradeDate='" + LastDate + "'", conn);
|
|
|
+ CustomerSqlConn.op("UPDATE MerchantTradeSummaryList" + TradeMonth + " SET NonActAmount=" + NonActAmounts + ",ActAmount=" + ActAmounts + ",AliPayInFactAmount=" + AliPayInFactAmounts + ",WeChatInfactAmount=" + WeChatInfactAmounts + ",OderCount=" + OderCounts + ",InFactAmount=" + InFactAmounts + ",TradeAmount=" + TradeAmounts + " WHERE MerchantId=" + MerchantId + " AND TradeDate='" + LastDate + "'", conn);
|
|
|
check = false;
|
|
|
}
|
|
|
}
|