|
|
@@ -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\":\"" + 1153 + "\",\"StartDate\":\"" + 20231028 + "\",\"EndDate\":\"" + 20231028 + "\"}");
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+ string content = RedisDbconn.Instance.RPop<string>("ResetMerchantStatDataQueue2");
|
|
|
+ if (!string.IsNullOrEmpty(content))
|
|
|
+ {
|
|
|
+ StatResetMerchantAmount(content);
|
|
|
+ }
|
|
|
+ Thread.Sleep(10000);
|
|
|
+ }
|
|
|
+ // StatResetMerchantAmount("{\"MerchantId\":\"" + 1153 + "\",\"StartDate\":\"" + 20231001 + "\",\"EndDate\":\"" + 20231029 + "\"}");
|
|
|
}
|
|
|
public void StatResetMerchantAmount(string content)
|
|
|
{
|