增加更新物流供应商期初和期末金额的方法

Bailun.DC.HappenAmount/Program.cs

@@ -7,28 +7,29 @@ namespace Bailun.DC.HappenAmount
 {
     class Program
     {
-        static async Task Main(string[] args)
-        {
-            Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-            var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
-            {
-                services.AddHostedService<Services>();
-            });
+        //static async Task Main(string[] args)
+        //{
+        //    Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+        //    var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
+        //    {
+        //        services.AddHostedService<Services>();
+        //    });
 
-            await builder.RunConsoleAsync();
-        }
+        //    await builder.RunConsoleAsync();
+        //}
 
-        //static void Main(string[] args)
-        //{
-        //    //var start = DateTime.Parse("2019-11-01");
-        //    //while (start.AddDays(1) < DateTime.Now)
-        //    //{
-        //    //    new Services().Init(start, start.AddDays(1));
-        //    //    start = start.AddDays(1);
-        //    //}
+        static void Main(string[] args)
+        {
+            var start = DateTime.Parse("2019-12-01");
+            //while (start.AddDays(3) < DateTime.Now)
+            //{
+            //    //new Services().Init(start, start.AddDays(1));
+            //    new Bailun.DC.Services.FinanceReportServices().AddLogisticsWaitPay(start, 0);
+            //    start = start.AddDays(1);
+            //}
 
-        //    new Bailun.DC.Services.FinanceReportServices().AddLogisticsWaitPay(DateTime.Parse("2020-01-15"), 0);
+            new Bailun.DC.Services.FinanceReportServices().UpdateLogisticsWaitPay(start,0,"admin",null);
 
-        //}
+        }
     }
 }

Bailun.DC.Services/FinanceReportServices.cs

@@ -272,13 +272,77 @@ namespace Bailun.DC.Services
 
                 var result = cn.Update<dc_daily_lg_waitpay>(obj);
 
-                UpdateLogisticsEndAmount(obj.day, obj.amount_end); 
+                UpdateLogisticsEndAmount(obj.day, obj.amount_end);
+
+                //同步更新该日期后面的期初和期末
+                UpdateLogisticsWaitPay(obj.day,userid,username,null);
 
                 return result > 0 ? "" : "保存异常，请重试！";
             }
         }
 
         /// <summary>
+        /// 更新后面数据的期初和期末
+        /// </summary>
+        /// <param name="day">日期</param>
+        /// <param name="userid">用户id</param>
+        /// <param name="username">用户名称</param>
+        /// <param name="cn"></param>
+        public void UpdateLogisticsWaitPay(DateTime day,int userid,string username,MySqlConnection cn)
+        {
+            try
+            {
+                var sql = "select * from dc_daily_lg_waitpay where day='" + day.AddDays(1).ToString("yyyy-MM-dd") + "'";
+
+                if (cn == null)
+                {
+                    cn = new MySqlConnection(Common.GlobalConfig.ConnectionString);
+                    cn.Open();
+                }
+                else
+                {
+                    if (cn.State == ConnectionState.Closed)
+                    {
+                        cn.Open();
+                    }
+                }
+
+                var obj = cn.QueryFirstOrDefault<dc_daily_lg_waitpay>(sql);
+                if (obj == null)
+                {
+                    return;
+                }
+
+                sql = "select * from dc_daily_lg_waitpay where day='" + day.ToString("yyyy-MM-dd") + "'";
+                var objPre = cn.QueryFirstOrDefault<dc_daily_lg_waitpay>(sql);
+                if (objPre == null)
+                {
+                    return;
+                }
+
+                obj.amount_start = objPre.amount_end;
+                obj.amount_end = obj.amount_start + obj.amount_happen + obj.amount_happen_adjust - obj.amount_payed - obj.amount_payed_adjust;
+
+                obj.lastupdatetime = DateTime.Now;
+                obj.lastupdateuserid = userid;
+                obj.lastupdateusername = username;
+
+                cn.Update(obj);
+
+                UpdateLogisticsEndAmount(obj.day, obj.amount_end);
+
+                UpdateLogisticsWaitPay(obj.day,userid,username,cn);
+
+                cn.Close();
+                cn.Dispose();
+            }
+            catch (Exception ex)
+            {
+                
+            }
+        }
+
+        /// <summary>
         /// 增加物流供应商应付账款记录
         /// </summary>
         /// <param name="date">日期</param>