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

新增清理规则

Browse Source
This commit is contained in:
陈梓阳 2024-02-26 09:26:18 +08:00
parent f689e1b659
commit c6d97fdc86
3 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
MesETL.App/Program.cs
View File

@ -260,6 +260,13 @@ async Task RunProgram()
return false; return false;
break; break;
} }
// OrderDataParts删除对应Order.OrderNo不存在的对象
case TableNames.OrderDataParts:
{
if (!await cache.ExistsAsync(CacheKeysFunc.Order_OrderNo_CompanyID(record["OrderNo"])))
return false;
break;
}
// OrderBlockPlan删除CreateTime < 202301的 // OrderBlockPlan删除CreateTime < 202301的
case TableNames.OrderBlockPlan: case TableNames.OrderBlockPlan:
{ {
@ -409,7 +416,14 @@ async Task RunProgram()
record["CompanyID"] = record["CompanyID"] =
// 获取Order.OrderNo -> CompanyID // 获取Order.OrderNo -> CompanyID
ThrowIfNoCached(await cache.GetStringAsync(CacheKeysFunc.Order_OrderNo_CompanyID(record["OrderNo"])), ThrowIfNoCached(await cache.GetStringAsync(CacheKeysFunc.Order_OrderNo_CompanyID(record["OrderNo"])),
TableNames.OrderBoxBlock, TableNames.Order, "OrderNo", "无法获取对应的CompanyID"); TableNames.OrderDataBlock, TableNames.Order, "OrderNo", "无法获取对应的CompanyID");
break;
// 修正OrderDataParts.CompanyID:
case TableNames.OrderDataParts:
record["CompanyID"] =
// 获取Order.OrderNo -> CompanyID
ThrowIfNoCached(await cache.GetStringAsync(CacheKeysFunc.Order_OrderNo_CompanyID(record["OrderNo"])),
TableNames.OrderDataParts, TableNames.Order, "OrderNo", "无法获取对应的CompanyID");
break; break;
// OrderModule添加ShardKey列，移除ViewFileName列 // OrderModule添加ShardKey列，移除ViewFileName列
case TableNames.OrderModule: case TableNames.OrderModule:

4
MesETL.App/appsettings.json
View File

@ -11,7 +11,7 @@
"InputDir": "D:\\Dump\\NewMockData", // Csv数据输入目录 "InputDir": "D:\\Dump\\NewMockData", // Csv数据输入目录
"UseMock": false, // 使用模拟数据进行测试 "UseMock": false, // 使用模拟数据进行测试
"MockCountMultiplier": 1, // 模拟数据量级的乘数 "MockCountMultiplier": 1, // 模拟数据量级的乘数
"TableOrder": ["order", "order_data_block"], // 按顺序输入的表 "TableOrder": ["order", "order_data_parts"], // 按顺序输入的表
"TableIgnoreList": [] // 忽略输入的表 "TableIgnoreList": [] // 忽略输入的表
}, },
"Transform":{ "Transform":{
@ -30,7 +30,7 @@
"NoOutput": ["order"], "NoOutput": ["order"],
"ForUpdate": "ForUpdate":
{ {
"order_data_block": "CompanyID = new.CompanyID" "order_data_parts": "CompanyID = new.CompanyID"
} }
}, },
"RecordQueue":{ "RecordQueue":{

6
MesETL.sln
View File

@ -8,6 +8,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MesETL.Tool", "MesETL.Tool\
EndProject EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MesETL.Shared", "MesETL.Shared\MesETL.Shared.csproj", "{FE134001-0E22-458B-BEF2-29712A29087E}" Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MesETL.Shared", "MesETL.Shared\MesETL.Shared.csproj", "{FE134001-0E22-458B-BEF2-29712A29087E}"
EndProject EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MesETL.Clean", "MesETL.Clean\MesETL.Clean.csproj", "{E1B2BED0-EBA6-4A14-BAD5-8EC4E528D7E0}"
EndProject
Global Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU Debug|Any CPU = Debug|Any CPU
@ -30,5 +32,9 @@ Global
{FE134001-0E22-458B-BEF2-29712A29087E}.Debug|Any CPU.Build.0 = Debug|Any CPU {FE134001-0E22-458B-BEF2-29712A29087E}.Debug|Any CPU.Build.0 = Debug|Any CPU
{FE134001-0E22-458B-BEF2-29712A29087E}.Release|Any CPU.ActiveCfg = Release|Any CPU {FE134001-0E22-458B-BEF2-29712A29087E}.Release|Any CPU.ActiveCfg = Release|Any CPU
{FE134001-0E22-458B-BEF2-29712A29087E}.Release|Any CPU.Build.0 = Release|Any CPU {FE134001-0E22-458B-BEF2-29712A29087E}.Release|Any CPU.Build.0 = Release|Any CPU
{E1B2BED0-EBA6-4A14-BAD5-8EC4E528D7E0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{E1B2BED0-EBA6-4A14-BAD5-8EC4E528D7E0}.Debug|Any CPU.Build.0 = Debug|Any CPU
{E1B2BED0-EBA6-4A14-BAD5-8EC4E528D7E0}.Release|Any CPU.ActiveCfg = Release|Any CPU
{E1B2BED0-EBA6-4A14-BAD5-8EC4E528D7E0}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection EndGlobalSection
EndGlobal EndGlobal