Skip to content

D
DataCenter_Core2.1_20190520
Commit f75329a5 by guanzhenshan
Options

调整wms物流基础数据

parent 30b63a09
Showing with 67 additions and 57 deletions
Bailun.DC.SyncLogisticInfo/Services.cs
...@@ -13,7 +13,7 @@ namespace Bailun.DC.SyncLogisticInfo ...@@ -13,7 +13,7 @@ namespace Bailun.DC.SyncLogisticInfo
{ {
public class Services : BackgroundService public class Services : BackgroundService
{ {
private static bool isRuning = false;
private Timer _timer; private Timer _timer;
protected override Task ExecuteAsync(CancellationToken stoppingToken) protected override Task ExecuteAsync(CancellationToken stoppingToken)
...@@ -28,7 +28,7 @@ namespace Bailun.DC.SyncLogisticInfo ...@@ -28,7 +28,7 @@ namespace Bailun.DC.SyncLogisticInfo
{ {
var now = DateTime.Now; var now = DateTime.Now;
if (now.Minute%30==0) //每30分钟同步一次 if (now.Minute%10==0 && !isRuning) //每30分钟同步一次
{ {
Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
Init(); Init();
...@@ -45,80 +45,90 @@ namespace Bailun.DC.SyncLogisticInfo ...@@ -45,80 +45,90 @@ namespace Bailun.DC.SyncLogisticInfo
public void Init() public void Init()
{ {
Dapper.SimpleCRUD.SetDialect(SimpleCRUD.Dialect.MySQL); try
{
isRuning = true;
Dapper.SimpleCRUD.SetDialect(SimpleCRUD.Dialect.MySQL);
var starttime = DateTime.Parse("2020-01-01"); var starttime = DateTime.Parse("2020-01-01");
var endtime = starttime.AddDays(1); var endtime = starttime.AddDays(1);
var page = 1; var page = 1;
var pagesize = 1000; var pagesize = 1000;
var total = -1; var total = -1;
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString)) using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{ {
cn.Open(); 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(2);
}
} }
var m = cn.QueryFirstOrDefault<DateTime?>("select end_time from job_point_log where job_name='dc-base-logisticinfo'"); //starttime = DateTime.Parse("2020-09-05");
if (m != null && m.HasValue) //endtime = starttime.AddDays(1);
if (endtime > DateTime.Now)
{ {
starttime = m.Value.AddMinutes(-3); endtime = DateTime.Now;
endtime = starttime.AddHours(1);
} }
}
//starttime = DateTime.Parse("2020-09-05"); while (total == -1 || total > ((page - 1) * pagesize))
//endtime = starttime.AddDays(1);
if (endtime > DateTime.Now)
{
endtime = DateTime.Now;
}
while (total == -1 || total>((page-1)*pagesize))
{
var j = new
{ {
StartModificationTime = starttime, var j = new
EndModificationTime = endtime, {
pageIndex = page, StartModificationTime = starttime,
pageCount = pagesize, 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 str = Common.HttpHelper.NetHelper.HttpPostJson(url, JsonConvert.SerializeObject(j));
var json = Newtonsoft.Json.JsonConvert.DeserializeObject<mResult>(str); var json = Newtonsoft.Json.JsonConvert.DeserializeObject<mResult>(str);
if (json!=null && json.success && json.result.result.Count > 0) if (json != null && json.success && json.result.result.Count > 0)
{ {
Save(json.result.result); Save(json.result.result);
Console.WriteLine("总记录数："+ json.result.total + ",当前页记录数：" + json.result.result.Count + "条记录。"+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); Console.WriteLine("总记录数：" + json.result.total + ",当前页记录数：" + json.result.result.Count + "条记录。" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
total = json.result.total; total = json.result.total;
page++; page++;
} }
else else
{ {
page=1; page = 1;
total = 0; total = 0;
endtime = endtime.AddDays(1); endtime = endtime.AddDays(1);
}
} }
}
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString)) using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{ {
cn.Open(); if (cn.State == System.Data.ConnectionState.Closed)
} {
cn.Open();
}
cn.Execute("update job_point_log 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 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;
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
isRuning = false;
}
} }
private void Save(List<DataInfo> list) private void Save(List<DataInfo> list)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment