CZY/MES-ETL
1
0
Fork 0
Code Pull Requests Releases Activity

fix cache error

Browse Source
This commit is contained in:
陈梓阳 2024-02-10 17:45:13 +08:00
parent 571805250b
commit f6af04bfcd
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
MesETL.App/Program.cs
View File

@ -120,13 +120,13 @@ async Task RunProgram()
switch (table) switch (table)
{ {
case TableNames.OrderBlockPlan: case TableNames.OrderBlockPlan:
MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.Order)); MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.Order + '-'));
break; break;
case TableNames.OrderItem: case TableNames.OrderItem:
MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.OrderBlockPlan)); MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.OrderBlockPlan + '-'));
break; break;
case TableNames.OrderProcessSchedule: case TableNames.OrderProcessSchedule:
MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.OrderProcess)); MemoryCache.Instance?.Delete(s => s.StartsWith(TableNames.OrderProcess + '-'));
break; break;
} }
}; };
@ -270,7 +270,7 @@ async Task RunProgram()
return false; return false;
break; break;
} }
// case TableNames.OrderBlockPlanResult: // case TableNames.OrderBlockPlanResult: // 用SaveTime过滤
// { // {
// if (DateTime.Parse(record["SaveTime"].Trim('"', '\'')) < oldestTime) // if (DateTime.Parse(record["SaveTime"].Trim('"', '\'')) < oldestTime)
// return false; // return false;
@ -629,8 +629,8 @@ async Task RunProgram()
host.Services.AddSingleton<ITransformService, TransformService>(); host.Services.AddSingleton<ITransformService, TransformService>();
host.Services.AddSingleton<IOutputService, OutputService>(); host.Services.AddSingleton<IOutputService, OutputService>();
host.Services.AddSingleton<TaskMonitorService>(); host.Services.AddSingleton<TaskMonitorService>();
host.Services.AddRedisCache(redisOptions); // host.Services.AddRedisCache(redisOptions);
// host.Services.AddSingleton<ICacher, MemoryCache>(); host.Services.AddSingleton<ICacher, MemoryCache>();
var app = host.Build(); var app = host.Build();
await app.RunAsync(); await app.RunAsync();
} }

2
MesETL.App/appsettings.json
View File

@ -9,7 +9,7 @@
"InputDir": "D:\\Dump\\MyDumper-ZST 2024-02-05", // Csv数据输入目录 "InputDir": "D:\\Dump\\MyDumper-ZST 2024-02-05", // Csv数据输入目录
"UseMock": false, // 使用模拟数据进行测试 "UseMock": false, // 使用模拟数据进行测试
"MockCountMultiplier": 1, // 模拟数据量级的乘数 "MockCountMultiplier": 1, // 模拟数据量级的乘数
"TableOrder": ["order_block_plan", "order_block_plan_result"], // 按顺序输入的表 "TableOrder": [], // 按顺序输入的表
"TableIgnoreList": [] // 忽略输入的表 "TableIgnoreList": [] // 忽略输入的表
}, },
"Transform":{ "Transform":{