调整wms物流基础数据

Bailun.DC.SyncLogisticInfo/Services.cs

@@ -28,7 +28,7 @@ namespace Bailun.DC.SyncLogisticInfo
             {
                 var now = DateTime.Now;
 
-                if (now.Minute % 3==0)  //每三分钟同步一次
+                if (now.Hour % 3==0 && now.Minute==1)  //每3小时同步一次
                 {
                     Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                     Init();
@@ -60,10 +60,10 @@ namespace Bailun.DC.SyncLogisticInfo
                     cn.Open();
                 }
 
-                var m = cn.QueryFirstOrDefault<dc_base_logistics>("select * from dc_base_logistics order by last_modification_time desc limit 1");
-                if (m != null && m.last_modification_time.HasValue)
+                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.last_modification_time.Value;
+                    starttime = m.Value;
                     endtime = starttime.AddDays(1);
                 }
 
@@ -106,6 +106,19 @@ namespace Bailun.DC.SyncLogisticInfo
                     endtime = endtime.AddDays(1);
                 }
             }
+
+            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+            {
+                if (cn.State == System.Data.ConnectionState.Closed)
+                {
+                    cn.Open();
+                }
+
+                cn.Execute("update job_point_log start_time='"+starttime.ToString("yyyy-MM-dd")+"',end_time='"+endtime.ToString("yyyy-MM-dd")+"' where job_name='dc-base-logisticinfo'");
+                
+            }
+
+
         }
 
         private void Save(List<DataInfo> list)