Skip to content

D
DataCenter_Core2.1_20190520
Commit 6f685944 by guanzhenshan
Options

增加同步物流对账单信息服务

parent 88546d22
Showing with 219 additions and 26 deletions
Bailun.DC.DailyLogisticSupplierTransaction/Program.cs
......@@ -12,28 +12,28 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
/// </summary>
/// <param name="args"></param>
/// <returns></returns>
static async Task Main(string[] args)
{
Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
{
services.AddHostedService<Services>();
});
await builder.RunConsoleAsync();
}
//static void Main(string[] args)
//static async Task Main(string[] args)
//{
// var _services = new Services();
// var start = DateTime.Parse("2020-04-01");
// while (start.AddDays(1) < DateTime.Now)
// Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
// var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
// {
// Console.WriteLine(start);
// _services.Init(start);
// start = start.AddDays(1);
// }
// services.AddHostedService<Services>();
// });
// await builder.RunConsoleAsync();
//}
static void Main(string[] args)
{
var _services = new Services();
var start = DateTime.Parse("2020-04-01");
while (start.AddDays(1) < DateTime.Now)
{
Console.WriteLine(start);
_services.Init(start);
start = start.AddDays(1);
}
}
}
}
Bailun.DC.SyncLogisticInfo/Bailun.DC.SyncLogisticInfo.csproj
......@@ -4,10 +4,12 @@
<OutputType>Exe</OutputType>
<TargetFramework>netcoreapp2.1</TargetFramework>
<LangVersion>latest</LangVersion>
<LangVersion>latest</LangVersion>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Dapper" Version="2.0.35" />
<PackageReference Include="Dapper.SimpleCRUD" Version="2.2.0.1" />
<PackageReference Include="Microsoft.Extensions.Hosting" Version="3.1.5" />
<PackageReference Include="MySql.Data" Version="8.0.20" />
<PackageReference Include="Newtonsoft.Json" Version="10.0.1" />
......
Bailun.DC.SyncLogisticInfo/Dockerfile 0 → 100644
FROM microsoft/dotnet:2.1-runtime AS base
WORKDIR /app
RUN /bin/cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && echo 'Asia/Shanghai' >/etc/timezone
FROM microsoft/dotnet:2.1-sdk AS build
WORKDIR /src
COPY Bailun.DC.SyncLogisticInfo/Bailun.DC.SyncLogisticInfo.csproj Bailun.DC.SyncLogisticInfo/
COPY Bailun.DC.Common/Bailun.DC.Common.csproj Bailun.DC.Common/
RUN dotnet restore Bailun.DC.SyncLogisticInfo/Bailun.DC.SyncLogisticInfo.csproj
COPY . .
WORKDIR /src/Bailun.DC.SyncLogisticInfo
RUN dotnet build Bailun.DC.SyncLogisticInfo.csproj -c Release -o /app
FROM build AS publish
RUN dotnet publish Bailun.DC.SyncLogisticInfo.csproj -c Release -o /app
FROM base AS final
WORKDIR /app
COPY --from=publish /app .
ENTRYPOINT ["dotnet", "Bailun.DC.SyncLogisticInfo.dll"]
Bailun.DC.SyncLogisticInfo/Program.cs
using System;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using System;
using System.Threading.Tasks;
namespace Bailun.DC.SyncLogisticInfo
{
......@@ -8,12 +11,29 @@ namespace Bailun.DC.SyncLogisticInfo
/// 同步物流对账基础数据
/// </summary>
/// <param name="args"></param>
static void Main(string[] args)
static async Task Main(string[] args)
{
Console.WriteLine("Hello World!");
Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
{
services.AddHostedService<Services>();
});
await builder.RunConsoleAsync();
}
//static void Main(string[] args)
//{
// //Console.WriteLine("Hello World!");
// var _service = new Services();
// _service.Init();
//}
}
}
Bailun.DC.SyncLogisticInfo/Services.cs
using System;
using Bailun.DC.SyncLogisticInfo.Models;
using System;
using System.Collections.Generic;
using System.Text;
using Newtonsoft.Json;
using MySql.Data.MySqlClient;
using Dapper;
using Microsoft.Extensions.Hosting;
using System.Threading;
using System.Threading.Tasks;
namespace Bailun.DC.SyncLogisticInfo
{
public class Services
public class Services : BackgroundService
{
private Timer _timer;
protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
return Task.CompletedTask;
}
private void DoWork(object state)
{
try
{
var now = DateTime.Now;
if (now.Minute % 3==0) //每三分钟同步一次
{
Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
Init();
Console.WriteLine("任务运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
string url = "http://wms.bailuntec.com/api/services/app/LogisticsReconciliationService/GetNormalDataQuery";
public void Init()
{
Dapper.SimpleCRUD.SetDialect(SimpleCRUD.Dialect.MySQL);
var starttime = DateTime.Parse("2020-01-01");
var endtime = starttime.AddDays(1);
var page = 1;
var pagesize = 1000;
var total = -1;
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
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)
{
starttime = m.last_modification_time.Value;
endtime = DateTime.Now;
}
}
while (total == -1 || total>((page-1)*pagesize))
{
var j = new
{
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"));
var str = Common.HttpHelper.NetHelper.HttpPostJson(url, JsonConvert.SerializeObject(j));
var json = Newtonsoft.Json.JsonConvert.DeserializeObject<mResult>(str);
if (json.success && json.result.result.Count > 0)
{
Save(json.result.result);
Console.WriteLine("获取到了" + json.result.result.Count + "条记录。");
total = json.result.total;
page++;
}
else
{
page=1;
total = 0;
endtime = endtime.AddDays(1);
}
}
}
private void Save()
private void Save(List<DataInfo> list)
{
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
foreach (var item in list)
{
try
{
cn.Execute("delete from dc_base_logistics where wms_id=" + item.id);
var m = new dc_base_logistics
{
bailun_shipment_cost_cny = item.bailunShipmentCostCNY,
bill_code = item.billCode,
company_code = item.company_Code,
company_name = item.company_Name,
cost_diff_decimal = item.costDiffDecimal,
diff_state_type = item.diffStateType + "",
fee_code = item.feeCode,
fee_product_type = item.feeProductType,
generate_bill_status = item.generateBillStatus,
gmt_create_time = DateTime.Now,
gmt_modify_time = DateTime.Now,
info_id = item.infoId + "",
last_modification_time = item.lastModificationTime,
line_name = item.line_Name,
merchant_output_weight_kg = item.merchantOutputWeightKg,
merchant_output_weight_kg_original = item.merchantOutputWeightKg_Original ?? 0,
merchant_reconciliation_time = item.merchantReconciliationTime,
merchant_shipment_cost_cny = item.merchantShipmentCostCNY,
merchant_shipment_cost_sny_original = item.merchantShipmentCostCNY_Original ?? 0,
output_weight_kg = item.outputWeightKg,
reconciliation_type = item.reconciliationType,
remark = item.remark,
shipment_time = item.shipmentTime,
tracking_no = item.trackingNo,
weight_diff_decimal = item.weightDiffDecimal,
wms_id = item.id
};
cn.Insert<dc_base_logistics>(m);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
throw ex;
}
}
}
}
}
......
docker-compose.yml
......@@ -132,3 +132,10 @@ services:
context: .
dockerfile: Bailun.DC.DailyBorrowFee/Dockerfile
bailun.dc.synclogisticinfo:
image: ${DOCKER_REGISTRY}bailundcsynclogisticinfo
build:
context: .
dockerfile: Bailun.DC.SyncLogisticInfo/Dockerfile
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