调整获取物流基础信息

Bailun.DC.SyncLogisticInfo/Services.cs

@@ -28,7 +28,7 @@ namespace Bailun.DC.SyncLogisticInfo
             {
                 var now = DateTime.Now;
 
-                if (now.Minute%5==0 && !isRuning)  //每5分钟同步一次
+                if (now.Minute%30==0 && !isRuning)  //每5分钟同步一次
                 {
                     Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                     Init();
@@ -54,81 +54,83 @@ namespace Bailun.DC.SyncLogisticInfo
                 var endtime = starttime.AddDays(1);
                 var currenttime = DateTime.Now;
 
-                
+
                 //starttime = DateTime.Parse("2020-09-05");
                 //endtime = starttime.AddDays(1);
                 
-                while(currenttime>endtime)
-                {
-                    var page = 1;
-                    var pagesize = 1000;
-                    var total = -1;
+                var page = 1;
+                var pagesize = 1000;
+                var total = -1;
 
-                    using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
+                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
+                {
+                    if (cn.State == System.Data.ConnectionState.Closed)
                     {
-                        if (cn.State == System.Data.ConnectionState.Closed)
-                        {
-                            cn.Open();
-                        }
-
-                        var m = cn.QueryFirstOrDefault<DateTime?>("select end_time from job_point_log where job_name='dc-base-logisticinfo'");
-                        if (m != null && m.HasValue)
-                        {
-                            starttime = m.Value.AddMinutes(-2);
-                            endtime = starttime.AddHours(8);
-                        }
-
+                        cn.Open();
                     }
 
-                    if (starttime >= DateTime.Now)
+                    var m = cn.QueryFirstOrDefault<DateTime?>("select end_time from job_point_log where job_name='dc-base-logisticinfo'");
+                    if (m != null && m.HasValue)
                     {
-                        starttime = DateTime.Now.AddMinutes(-2);
+                        starttime = m.Value.AddMinutes(-2);
+                        endtime = starttime.AddHours(2);
                     }
 
+                }
+
+                if (starttime >= DateTime.Now)
+                {
+                    starttime = DateTime.Now.AddMinutes(-2);
+                }
+
+                if(endtime>DateTime.Now)
+                {
+                    endtime = DateTime.Now;
+                }
+
 
-                    while (total == -1 || total > ((page - 1) * pagesize))
+                while (total == -1 || total > ((page - 1) * pagesize))
+                {
+                    var j = new
                     {
-                        var j = new
-                        {
-                            StartModificationTime = starttime,
-                            EndModificationTime = endtime,
-                            pageIndex = page,
-                            pageCount = pagesize,
-                        };
+                        StartModificationTime = starttime,
+                        EndModificationTime = endtime,
+                        pageIndex = page,
+                        pageCount = pagesize,
+                    };
 
-                        Console.WriteLine("Page:" + page + "；starttime:" + starttime.ToString("yyyy-MM-dd HH:mm:ss") + "；endtime:" + endtime.ToString("yyyy-MM-dd HH:mm:ss"));
+                    Console.WriteLine("Page:" + page + "；starttime:" + starttime.ToString("yyyy-MM-dd HH:mm:ss") + "；endtime:" + endtime.ToString("yyyy-MM-dd HH:mm:ss"));
 
-                        var str = Common.HttpHelper.NetHelper.HttpPostJson(url, JsonConvert.SerializeObject(j));
-                        var json = Newtonsoft.Json.JsonConvert.DeserializeObject<mResult>(str);
+                    var str = Common.HttpHelper.NetHelper.HttpPostJson(url, JsonConvert.SerializeObject(j));
+                    var json = Newtonsoft.Json.JsonConvert.DeserializeObject<mResult>(str);
 
-                        if (json != null && json.success && json.result.result.Count > 0)
-                        {
-                            Save(json.result.result);
-                            Console.WriteLine("总记录数：" + json.result.total + ",当前页记录数：" + json.result.result.Count + "条记录。" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                            total = json.result.total;
-                            page++;
-                        }
-                        else
-                        {
-                            page = 1;
-                            total = 0;
+                    if (json != null && json.success && json.result.result.Count > 0)
+                    {
+                        Save(json.result.result);
+                        Console.WriteLine("总记录数：" + json.result.total + ",当前页记录数：" + json.result.result.Count + "条记录。" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+                        total = json.result.total;
+                        page++;
+                    }
+                    else
+                    {
+                        page = 1;
+                        total = 0;
 
-                        }
                     }
+                }
 
-                    using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+                using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+                {
+                    if (cn.State == System.Data.ConnectionState.Closed)
                     {
-                        if (cn.State == System.Data.ConnectionState.Closed)
-                        {
-                            cn.Open();
-                        }
+                        cn.Open();
+                    }
 
-                        cn.Execute("update job_point_log set start_time='" + starttime.ToString("yyyy-MM-dd HH:mm:ss") + "',end_time='" + endtime.ToString("yyyy-MM-dd HH:mm:ss") + "' where job_name='dc-base-logisticinfo'");
+                    cn.Execute("update job_point_log set start_time='" + starttime.ToString("yyyy-MM-dd HH:mm:ss") + "',end_time='" + endtime.ToString("yyyy-MM-dd HH:mm:ss") + "' where job_name='dc-base-logisticinfo'");
 
-                    }
                 }
 
-                
+
 
                 isRuning = false;
             }