优化平台帐号余额服务

Bailun.DC.DailyPlatformAccountBalance/Services.cs

@@ -34,7 +34,7 @@ namespace Bailun.DC.DailyPlatformAccountBalance
                 {
                     Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                     var end = DateTime.Now;
-                    var start = end.AddDays(-1);
+                    var start = DateTime.Parse("2020-06-20");
 
                     Init(start,end);
                     
@@ -45,8 +45,6 @@ namespace Bailun.DC.DailyPlatformAccountBalance
                     SaveDaily();
                     Console.WriteLine("结束每日记录保存 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
 
-
-
                 }
                 
 
@@ -68,7 +66,7 @@ namespace Bailun.DC.DailyPlatformAccountBalance
             if (json.code == 0 && json.count>0)
             {
                 Save(json.data);
-
+                Console.WriteLine("获取到了"+json.count+"条记录。");
             }
 
         }
@@ -115,6 +113,8 @@ namespace Bailun.DC.DailyPlatformAccountBalance
         private void UpdateBalanceSheet(DateTime day)
         {
             //platformBalanceUpdate
+
+
         }
 
         /// <summary>
@@ -123,7 +123,7 @@ namespace Bailun.DC.DailyPlatformAccountBalance
         private void SaveDaily()
         {
             var sql = $@"insert into dc_daily_platform_account_balance (day,account,platform_name,currency,currencyrate,availableamount,availableamount_rmb,frozenmoney,frozenmoney_rmb,totalamount,totalamount_rmb,dc_createtime) 
-                        select date_add(now(), interval -1 day),account,platform_name,currency,currencyrate,availableamount,availableamount_rmb,frozenmoney,frozenmoney_rmb,totalamount,totalamount_rmb,now() from dc_base_platform_account_balance t1";
+                        select DATE_SUB(curdate(),INTERVAL 1 DAY),account,platform_name,currency,currencyrate,availableamount,availableamount_rmb,frozenmoney,frozenmoney_rmb,totalamount,totalamount_rmb,now() from dc_base_platform_account_balance t1";
 
             using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
             {
@@ -132,7 +132,8 @@ namespace Bailun.DC.DailyPlatformAccountBalance
                     cn.Open();
                 }
 
-                cn.Execute("delete from dc_daily_platform_account_balance where day=date_add(now(), interval -1 day)");
+                cn.Execute("delete from dc_daily_platform_account_balance where day=DATE_SUB(curdate(),INTERVAL 1 DAY);");
+
                 cn.Execute(sql);
             }