调整现金流的更新方法

Bailun.DC.LogicWareHouse/Services.cs

@@ -359,22 +359,20 @@ namespace Bailun.DC.LogicWareHouse
                         cn.Open();
                     }
 
-                    cn.Execute("update dc_skuwarehouse_stock_sales set cash_in_30days=0,cash_out_30days=0,cash_net = 0");
+                    
 
-                    var list = cn.Query<mCash>("select t2.bailun_sku,t2.warehouse_code,t2.pay_amount_30,t2.income_amount_30 from dc_base_stock t2 where (t2.pay_amount_30>0 or t2.income_amount_30>0)");
-                    foreach (var item in list)
-                    {
-                        cn.Execute("update dc_skuwarehouse_stock_sales set cash_in_30days=" + item.income_amount_30 + ",cash_out_30days=" + item.pay_amount_30 + ",cash_net=" + (item.income_amount_30 - item.pay_amount_30) + " where bailun_sku='" + item.bailun_sku + "' and warehouse_code='" + item.warehouse_code + "'");
-                        Console.WriteLine(item.bailun_sku + "&" + item.warehouse_code);
-                    }
+                    cn.Execute("update dc_skuwarehouse_stock_sales set cash_in_30days=0,cash_out_30days=0,cash_net = 0");
 
-                    //var sql = @"update dc_skuwarehouse_stock_sales t1
-                    //            join dc_base_stock t2 on (t2.pay_amount_30>0 or t2.income_amount_30>0) and t1.bailun_sku=t2.bailun_sku and t1.warehouse_code=t2.warehouse_code
-                    //            set t1.cash_in_30days=t2.income_amount_30,t1.cash_out_30days=t2.pay_amount_30,t1.cash_net = t2.income_amount_30-t2.pay_amount_30";
+                    cn.Execute("TRUNCATE dc_base_stock_cash;");
 
-                    //var result = cn.Execute(sql);
+                    cn.Execute(@"insert into dc_base_stock_cash(bailun_sku, warehouse_code, pay_amount_30, income_amount_30)
+                    select t2.bailun_sku,t2.warehouse_code,t2.pay_amount_30,t2.income_amount_30 from dc_base_stock t2 where(t2.pay_amount_30 > 0 or t2.income_amount_30 > 0);");
 
-                    Console.WriteLine("更新30天现金流的记录数有：" + list.Count());
+                    var result = cn.Execute(@"update dc_skuwarehouse_stock_sales t1
+                    join dc_base_stock_cash t2 on t1.bailun_sku = t2.bailun_sku and t1.warehouse_code = t2.warehouse_code
+                    set t1.cash_in_30days = t2.income_amount_30,t1.cash_out_30days = t2.pay_amount_30,t1.cash_net = (t2.income_amount_30 - t2.pay_amount_30);");
+                    
+                    Console.WriteLine("更新30天现金流的记录数有：" + result);
                 }
 
                 Console.WriteLine(" 更新现金流方法 已完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));