修改同步半成品库存服务

Bailun.DC.SyncSemiStock/Program.cs

@@ -17,11 +17,13 @@ namespace Bailun.DC.SyncSemiStock
 
             await builder.RunConsoleAsync();
 
+            //new Services().Init();
+
             //new Services().SyncSupplierPrice();
 
             //new Services().SyncStockLog();
 
-
+            //new Services().SaveDailySemiStock();
 
         }
 

Bailun.DC.SyncSemiStock/Services.cs

@@ -80,54 +80,64 @@ namespace Bailun.DC.SyncSemiStock
                 totalPage = json.data.TotalPages;
                 total = json.data.TotalItems;
 
-
-                //删除历史数据
-                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+                try
                 {
-                    if(cn.State== System.Data.ConnectionState.Closed)
+                    //删除历史数据
+                    using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
                     {
-                        cn.Open();
-                    }
+                        if (cn.State == System.Data.ConnectionState.Closed)
+                        {
+                            cn.Open();
+                        }
 
-                    cn.Execute("TRUNCATE dc_semi_stock_prod_new");
+                        cn.Execute("TRUNCATE dc_semi_stock_prod_new");
 
-                }
+                    }
 
-                //保存第一页数据
-                SaveData(json.data.Items);
+                    //保存第一页数据
+                    SaveData(json.data.Items);
 
-                //请求第二页之后的数据
-                while (page<totalPage)
-                {
-                    page++;
+                    //请求第二页之后的数据
+                    while (page < totalPage)
+                    {
+                        page++;
 
-                    result = DC.Common.HttpHelper.NetHelper.Request(url + "?page="+page+"&rows=" + rows);
-                    json = Newtonsoft.Json.JsonConvert.DeserializeObject<Models.response_StockData>(result);
+                        result = DC.Common.HttpHelper.NetHelper.Request(url + "?page=" + page + "&rows=" + rows);
+                        json = Newtonsoft.Json.JsonConvert.DeserializeObject<Models.response_StockData>(result);
 
-                    if(json.success)
-                    {
-                        page = json.data.CurrentPage;
-                        totalPage = json.data.TotalPages;
-                        total = json.data.TotalItems;
+                        if (json.success)
+                        {
+                            page = json.data.CurrentPage;
+                            totalPage = json.data.TotalPages;
+                            total = json.data.TotalItems;
 
-                        //保存当前页数据
-                        SaveData(json.data.Items);
+                            //保存当前页数据
+                            SaveData(json.data.Items);
+                        }
                     }
-                }
 
-                //保存每日库存
-                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
-                {
-                    if(cn.State== System.Data.ConnectionState.Closed)
+                    //保存每日库存
+                    using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
                     {
-                        cn.Open();
-                    }
+                        if (cn.State == System.Data.ConnectionState.Closed)
+                        {
+                            cn.Open();
+                        }
 
-                    cn.Execute("delete from dc_semi_stock_prod_new_daily where record_time='" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + "'");
+                        cn.Execute("delete from dc_semi_stock_prod_new_daily where record_time='" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + "'");
 
-                    cn.Execute($"insert dc_semi_stock_prod_new_daily (material_id,warehouse_id,jit_prod_stock,plan_prod_stock,warehouse_name,material_code,material_name,material_category,new_price,gmt_create,gmt_modify,record_time) select material_id,warehouse_id,jit_prod_stock,plan_prod_stock,warehouse_name,material_code,material_name,material_category,new_price,gmt_create,gmt_modify,(DATE_SUB(curdate(),INTERVAL 1 DAY)) as 'record_time' from dc_semi_stock_prod_new");
+                        cn.Execute($"insert dc_semi_stock_prod_new_daily (material_id,warehouse_id,jit_prod_stock,plan_prod_stock,warehouse_name,material_code,material_name,material_category,new_price,gmt_create,gmt_modify,record_time) select material_id,warehouse_id,jit_prod_stock,plan_prod_stock,warehouse_name,material_code,material_name,material_category,new_price,gmt_create,gmt_modify,(DATE_SUB(curdate(),INTERVAL 1 DAY)) as 'record_time' from dc_semi_stock_prod_new");
 
+                    }
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine("获取半成品实时库存数据异常："+ex.Message);
+                    System.Threading.Thread.Sleep(5 * 1000);
+                    Init();
                 }
+
+                
             }
 
         }