admin/dh-inspeccion-v2
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 3 Wiki Activity

fix: endurecer migración F2.2.1 contra PostgreSQL real

Browse Source
This commit is contained in:
admin
2026-09-06 22:41:03 -03:00
parent e09930d411
commit cf3327a4da
1 changed files with 336 additions and 135 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api-v3/src/database/migrations/1789754400000-phase-f2-2-1-reference-excel-data.ts
+336 -135
View File
@@ -64,6 +64,25 @@ const referenceAliases: Record<string, string> = {
generador: 'generador', generador: 'generador',
}; };
type IdRow = { id: string };
type CountRow = { total: string };
async function assetIdByCode(queryRunner: QueryRunner, code: string): Promise<string | null> {
const rows = (await queryRunner.query(
`SELECT id FROM assets WHERE lower(code)=lower($1::text) LIMIT 1`,
[code],
)) as IdRow[];
return rows[0]?.id ?? null;
}
async function assetTypeIdByCode(queryRunner: QueryRunner, code: string): Promise<string | null> {
const rows = (await queryRunner.query(
`SELECT id FROM asset_types WHERE lower(code)=lower($1::text) LIMIT 1`,
[code],
)) as IdRow[];
return rows[0]?.id ?? null;
}
export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterface { export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterface {
name = 'PhaseF221ReferenceExcelData1789754400000'; name = 'PhaseF221ReferenceExcelData1789754400000';
@@ -75,7 +94,8 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
SELECT 'SPREADSHEET','DH-F221-TERRITORIO','Tablas de yacimiento(1).xlsx','Dirección de Hidrocarburos', SELECT 'SPREADSHEET','DH-F221-TERRITORIO','Tablas de yacimiento(1).xlsx','Dirección de Hidrocarburos',
'Fuente F2.2.1: maestro territorial y operativo. Hoja normalizada cr26e_tabla1.' 'Fuente F2.2.1: maestro territorial y operativo. Hoja normalizada cr26e_tabla1.'
WHERE NOT EXISTS ( WHERE NOT EXISTS (
SELECT 1 FROM source_documents WHERE document_number='DH-F221-TERRITORIO' AND issuer='Dirección de Hidrocarburos' SELECT 1 FROM source_documents
WHERE document_number='DH-F221-TERRITORIO' AND issuer='Dirección de Hidrocarburos'
) )
`); `);
await queryRunner.query(` await queryRunner.query(`
@@ -83,35 +103,45 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
SELECT 'SPREADSHEET','DH-F221-APP','APLICACION APP(1).xlsx','Dirección de Hidrocarburos', SELECT 'SPREADSHEET','DH-F221-APP','APLICACION APP(1).xlsx','Dirección de Hidrocarburos',
'Fuente F2.2.1: matriz de jerarquía, información y catálogo contextual de hallazgos. Hojas Hoja1 y Hoja2.' 'Fuente F2.2.1: matriz de jerarquía, información y catálogo contextual de hallazgos. Hojas Hoja1 y Hoja2.'
WHERE NOT EXISTS ( WHERE NOT EXISTS (
SELECT 1 FROM source_documents WHERE document_number='DH-F221-APP' AND issuer='Dirección de Hidrocarburos' SELECT 1 FROM source_documents
WHERE document_number='DH-F221-APP' AND issuer='Dirección de Hidrocarburos'
) )
`); `);
const territoryDocumentRows = (await queryRunner.query( const territoryDocuments = (await queryRunner.query(
`SELECT id FROM source_documents WHERE document_number='DH-F221-TERRITORIO' AND issuer='Dirección de Hidrocarburos' LIMIT 1`, `SELECT id FROM source_documents
)) as Array<{ id: string }>; WHERE document_number='DH-F221-TERRITORIO' AND issuer='Dirección de Hidrocarburos' LIMIT 1`,
const appDocumentRows = (await queryRunner.query( )) as IdRow[];
`SELECT id FROM source_documents WHERE document_number='DH-F221-APP' AND issuer='Dirección de Hidrocarburos' LIMIT 1`, const appDocuments = (await queryRunner.query(
)) as Array<{ id: string }>; `SELECT id FROM source_documents
const territoryDocumentId = territoryDocumentRows[0]?.id; WHERE document_number='DH-F221-APP' AND issuer='Dirección de Hidrocarburos' LIMIT 1`,
const appDocumentId = appDocumentRows[0]?.id; )) as IdRow[];
if (!territoryDocumentId || !appDocumentId) throw new Error('F2.2.1 source documents could not be resolved'); const territoryDocumentId = territoryDocuments[0]?.id;
const appDocumentId = appDocuments[0]?.id;
if (!territoryDocumentId || !appDocumentId) {
throw new Error('F2.2.1 source documents could not be resolved');
}
await queryRunner.query(`UPDATE asset_types SET can_be_root=true WHERE operational_role IN ('AREA','COMPANY')`); await queryRunner.query(
`UPDATE asset_types SET can_be_root=true WHERE operational_role IN ('AREA','COMPANY')`,
);
await queryRunner.query(` await queryRunner.query(`
INSERT INTO asset_types (code,name,description,can_be_root,is_active,operational_role) INSERT INTO asset_types (code,name,description,can_be_root,is_active,operational_role)
SELECT 'yacimiento','Yacimiento','Yacimiento físico/operativo perteneciente a un Área. Su operadora se determina por contexto histórico.',false,true,'GENERIC' SELECT 'yacimiento','Yacimiento',
'Yacimiento físico/operativo perteneciente a un Área. Su operadora se determina por contexto histórico.',
false,true,'GENERIC'
WHERE NOT EXISTS (SELECT 1 FROM asset_types WHERE lower(code)='yacimiento') WHERE NOT EXISTS (SELECT 1 FROM asset_types WHERE lower(code)='yacimiento')
`); `);
await queryRunner.query(` await queryRunner.query(`
INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id) INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id)
SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent SELECT child.id,parent.id
FROM asset_types child CROSS JOIN asset_types parent
WHERE lower(child.code)='yacimiento' AND parent.operational_role='AREA' WHERE lower(child.code)='yacimiento' AND parent.operational_role='AREA'
ON CONFLICT DO NOTHING ON CONFLICT DO NOTHING
`); `);
await queryRunner.query(` await queryRunner.query(`
INSERT INTO asset_attribute_definitions (asset_type_id,code,name,data_type,is_required,is_active,sort_order) INSERT INTO asset_attribute_definitions
(asset_type_id,code,name,data_type,is_required,is_active,sort_order)
SELECT type.id,definition.code,definition.name,'TEXT',false,true,definition.sort_order SELECT type.id,definition.code,definition.name,'TEXT',false,true,definition.sort_order
FROM asset_types type FROM asset_types type
CROSS JOIN (VALUES CROSS JOIN (VALUES
@@ -122,9 +152,12 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
ON CONFLICT DO NOTHING ON CONFLICT DO NOTHING
`); `);
await queryRunner.query(` await queryRunner.query(`
INSERT INTO asset_attribute_definitions (asset_type_id,code,name,data_type,is_required,is_active,sort_order) INSERT INTO asset_attribute_definitions
SELECT type.id,'tipo_concesion_fuente','Tipo de concesión informado por la fuente','TEXT',false,true,40 (asset_type_id,code,name,data_type,is_required,is_active,sort_order)
FROM asset_types type WHERE type.operational_role='AREA' SELECT type.id,'tipo_concesion_fuente','Tipo de concesión informado por la fuente',
'TEXT',false,true,40
FROM asset_types type
WHERE type.operational_role='AREA'
ON CONFLICT DO NOTHING ON CONFLICT DO NOTHING
`); `);
@@ -134,154 +167,236 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
for (const row of source.territory) { for (const row of source.territory) {
const areaKey = row.area.trim().toLocaleLowerCase('es'); const areaKey = row.area.trim().toLocaleLowerCase('es');
let areaId = areaCache.get(areaKey); let areaId = areaCache.get(areaKey) ?? null;
if (!areaId) { if (!areaId) {
const areaCode = stableCode('AREA', row.area); const areaCode = stableCode('AREA', row.area);
await queryRunner.query( areaId = await assetIdByCode(queryRunner, areaCode);
`INSERT INTO assets ( if (!areaId) {
asset_type_id,parent_id,code,name,description,information_status,operational_status, const inserted = (await queryRunner.query(
data_origin,source_name,source_reference,source_notes,current_version `INSERT INTO assets (
) asset_type_id,parent_id,code,name,description,information_status,operational_status,
SELECT type.id,NULL,$1,$2,$3,'VALIDATED','IN_SERVICE','IMPORT',$4,$5,$6,0 data_origin,source_name,source_reference,source_notes,current_version
FROM asset_types type )
WHERE type.operational_role='AREA' SELECT type.id,NULL,$1::varchar,$2::varchar,$3::text,
AND NOT EXISTS (SELECT 1 FROM assets WHERE lower(code)=lower($1)) 'VALIDATED','IN_SERVICE','IMPORT',$4::varchar,$5::varchar,$6::text,0
LIMIT 1`, FROM asset_types type
[areaCode, row.area, `Área importada desde Tablas de yacimiento. Departamento: ${row.department}.`, 'Tablas de yacimiento(1).xlsx', `cr26e_tabla1|AREA|${row.area}`, `Departamento=${row.department}; TipoConcesion=${row.concessionType}`], WHERE type.operational_role='AREA'
); LIMIT 1
const rows = (await queryRunner.query(`SELECT id FROM assets WHERE lower(code)=lower($1) LIMIT 1`, [areaCode])) as Array<{ id: string }>; RETURNING id`,
areaId = rows[0]?.id; [
areaCode,
row.area,
`Área importada desde Tablas de yacimiento. Departamento: ${row.department}.`,
'Tablas de yacimiento(1).xlsx',
`cr26e_tabla1|AREA|${row.area}`,
`Departamento=${row.department}; TipoConcesion=${row.concessionType}`,
],
)) as IdRow[];
areaId = inserted[0]?.id ?? null;
}
if (!areaId) throw new Error(`Could not resolve area ${row.area}`); if (!areaId) throw new Error(`Could not resolve area ${row.area}`);
areaCache.set(areaKey, areaId); areaCache.set(areaKey, areaId);
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes) `INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes)
VALUES ($1,$2,'SOURCE','Importación F2.2.1 · cr26e_tabla1') ON CONFLICT DO NOTHING`, VALUES ($1::uuid,$2::uuid,'SOURCE','Importación F2.2.1 · cr26e_tabla1')
ON CONFLICT DO NOTHING`,
[areaId, territoryDocumentId], [areaId, territoryDocumentId],
); );
for (const [definitionCode, value] of [['departamento', row.department], ['tipo_concesion_fuente', row.concessionType]] as const) {
await queryRunner.query(
`INSERT INTO asset_attribute_values (asset_id,definition_id,value)
SELECT $1,definition.id,to_jsonb($3::text)
FROM asset_attribute_definitions definition
JOIN asset_types type ON type.id=definition.asset_type_id
WHERE type.operational_role='AREA' AND lower(definition.code)=lower($2)
ON CONFLICT (asset_id,definition_id) DO UPDATE SET value=EXCLUDED.value,updated_at=CURRENT_TIMESTAMP`,
[areaId, definitionCode, value],
);
}
} }
let companyId: string | null = null; for (const [definitionCode, value] of [
['departamento', row.department],
['tipo_concesion_fuente', row.concessionType],
] as const) {
await queryRunner.query(
`INSERT INTO asset_attribute_values (asset_id,definition_id,value)
SELECT $1::uuid,definition.id,to_jsonb($3::text)
FROM asset_attribute_definitions definition
JOIN asset_types type ON type.id=definition.asset_type_id
WHERE type.operational_role='AREA'
AND lower(definition.code)=lower($2::text)
ON CONFLICT (asset_id,definition_id)
DO UPDATE SET value=EXCLUDED.value,updated_at=CURRENT_TIMESTAMP`,
[areaId, definitionCode, value],
);
}
const noOperator = slug(row.operator) === 'sin_empresa_operadora'; const noOperator = slug(row.operator) === 'sin_empresa_operadora';
let companyId: string | null = null;
if (!noOperator) { if (!noOperator) {
const companyKey = row.operator.trim().toLocaleLowerCase('es'); const companyKey = row.operator.trim().toLocaleLowerCase('es');
companyId = companyCache.get(companyKey) ?? null; companyId = companyCache.get(companyKey) ?? null;
if (!companyId) { if (!companyId) {
const companyCode = stableCode('ORG', row.operator); const companyCode = stableCode('ORG', row.operator);
await queryRunner.query( companyId = await assetIdByCode(queryRunner, companyCode);
`INSERT INTO assets ( if (!companyId) {
asset_type_id,parent_id,code,name,description,information_status,operational_status, const inserted = (await queryRunner.query(
data_origin,source_name,source_reference,source_notes,current_version `INSERT INTO assets (
) asset_type_id,parent_id,code,name,description,information_status,operational_status,
SELECT type.id,NULL,$1,$2,'Organización operadora importada desde Tablas de yacimiento.','VALIDATED','IN_SERVICE','IMPORT',$3,$4,'Empresa/Operadora informada por la fuente',0 data_origin,source_name,source_reference,source_notes,current_version
FROM asset_types type )
WHERE type.operational_role='COMPANY' SELECT type.id,NULL,$1::varchar,$2::varchar,
AND NOT EXISTS (SELECT 1 FROM assets WHERE lower(code)=lower($1)) 'Organización operadora importada desde Tablas de yacimiento.',
LIMIT 1`, 'VALIDATED','IN_SERVICE','IMPORT',$3::varchar,$4::varchar,
[companyCode, row.operator, 'Tablas de yacimiento(1).xlsx', `cr26e_tabla1|OPERADORA|${row.operator}`], 'Empresa/Operadora informada por la fuente',0
); FROM asset_types type
const rows = (await queryRunner.query(`SELECT id FROM assets WHERE lower(code)=lower($1) LIMIT 1`, [companyCode])) as Array<{ id: string }>; WHERE type.operational_role='COMPANY'
companyId = rows[0]?.id ?? null; LIMIT 1
RETURNING id`,
[
companyCode,
row.operator,
'Tablas de yacimiento(1).xlsx',
`cr26e_tabla1|OPERADORA|${row.operator}`,
],
)) as IdRow[];
companyId = inserted[0]?.id ?? null;
}
if (!companyId) throw new Error(`Could not resolve operator ${row.operator}`); if (!companyId) throw new Error(`Could not resolve operator ${row.operator}`);
companyCache.set(companyKey, companyId); companyCache.set(companyKey, companyId);
await queryRunner.query( await queryRunner.query(
`INSERT INTO organization_profiles (asset_id,organization_kind,legal_name) `INSERT INTO organization_profiles (asset_id,organization_kind,legal_name)
SELECT $1,CASE WHEN lower($2) LIKE 'ute %' OR lower($2) LIKE 'ute(%' THEN 'UTE'::organization_kind ELSE 'COMPANY'::organization_kind END,$2 SELECT $1::uuid,
WHERE NOT EXISTS (SELECT 1 FROM organization_profiles WHERE asset_id=$1)`, CASE WHEN lower($2::text) LIKE 'ute %' OR lower($2::text) LIKE 'ute(%'
THEN 'UTE'::organization_kind ELSE 'COMPANY'::organization_kind END,
$2::varchar
WHERE NOT EXISTS (SELECT 1 FROM organization_profiles WHERE asset_id=$1::uuid)`,
[companyId, row.operator], [companyId, row.operator],
); );
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes) `INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes)
VALUES ($1,$2,'SOURCE','Importación F2.2.1 · cr26e_tabla1') ON CONFLICT DO NOTHING`, VALUES ($1::uuid,$2::uuid,'SOURCE','Importación F2.2.1 · cr26e_tabla1')
ON CONFLICT DO NOTHING`,
[companyId, territoryDocumentId], [companyId, territoryDocumentId],
); );
} }
await queryRunner.query( await queryRunner.query(
`INSERT INTO area_company_relations (area_id,company_id,relation_role,valid_from,start_reason,source_document_id) `INSERT INTO area_company_relations
SELECT $1,$2,'OPERATOR',CURRENT_TIMESTAMP,'Importado desde Tablas de yacimiento(1).xlsx',$3 (area_id,company_id,relation_role,valid_from,start_reason,source_document_id)
SELECT $1::uuid,$2::uuid,'OPERATOR',CURRENT_TIMESTAMP,
'Importado desde Tablas de yacimiento(1).xlsx',$3::uuid
WHERE NOT EXISTS ( WHERE NOT EXISTS (
SELECT 1 FROM area_company_relations SELECT 1 FROM area_company_relations
WHERE area_id=$1 AND company_id=$2 AND relation_role='OPERATOR' AND valid_until IS NULL WHERE area_id=$1::uuid AND company_id=$2::uuid
AND relation_role='OPERATOR' AND valid_until IS NULL
)`, )`,
[areaId, companyId, territoryDocumentId], [areaId, companyId, territoryDocumentId],
); );
} }
const fieldCode = stableCode('YAC', row.field, row.area); const fieldCode = stableCode('YAC', row.field, row.area);
await queryRunner.query( let fieldId = await assetIdByCode(queryRunner, fieldCode);
`INSERT INTO assets ( if (!fieldId) {
asset_type_id,parent_id,operational_area_id,operator_company_id,code,name,description, // The operational context is intentionally all-or-nothing. A source row
information_status,operational_status,data_origin,source_name,source_reference,source_notes,current_version // that explicitly says "Sin Empresa Operadora" stays physically under
) // its Área but receives no fabricated operator and no half context.
SELECT type.id,$1,$1,$2,$3,$4,$5,'VALIDATED','IN_SERVICE','IMPORT',$6,$7,$8,0 const operationalAreaId = companyId ? areaId : null;
FROM asset_types type const inserted = (await queryRunner.query(
WHERE lower(type.code)='yacimiento' `INSERT INTO assets (
AND NOT EXISTS (SELECT 1 FROM assets WHERE lower(code)=lower($3)) asset_type_id,parent_id,operational_area_id,operator_company_id,code,name,description,
LIMIT 1`, information_status,operational_status,data_origin,source_name,source_reference,
[areaId, companyId, fieldCode, row.field, `Yacimiento del Área ${row.area}.`, 'Tablas de yacimiento(1).xlsx', `cr26e_tabla1|YACIMIENTO|${row.field}|AREA|${row.area}`, `Departamento=${row.department}; TipoConcesion=${row.concessionType}; OperadoraFuente=${row.operator}`], source_notes,current_version
); )
const fieldRows = (await queryRunner.query(`SELECT id FROM assets WHERE lower(code)=lower($1) LIMIT 1`, [fieldCode])) as Array<{ id: string }>; SELECT type.id,$1::uuid,$2::uuid,$3::uuid,$4::varchar,$5::varchar,$6::text,
const fieldId = fieldRows[0]?.id; 'VALIDATED','IN_SERVICE','IMPORT',$7::varchar,$8::varchar,$9::text,0
FROM asset_types type
WHERE lower(type.code)='yacimiento'
LIMIT 1
RETURNING id`,
[
areaId,
operationalAreaId,
companyId,
fieldCode,
row.field,
`Yacimiento del Área ${row.area}.`,
'Tablas de yacimiento(1).xlsx',
`cr26e_tabla1|YACIMIENTO|${row.field}|AREA|${row.area}`,
`Departamento=${row.department}; TipoConcesion=${row.concessionType}; OperadoraFuente=${row.operator}`,
],
)) as IdRow[];
fieldId = inserted[0]?.id ?? null;
}
if (!fieldId) throw new Error(`Could not resolve field ${row.field} / ${row.area}`); if (!fieldId) throw new Error(`Could not resolve field ${row.field} / ${row.area}`);
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes) `INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes)
VALUES ($1,$2,'SOURCE','Importación F2.2.1 · cr26e_tabla1') ON CONFLICT DO NOTHING`, VALUES ($1::uuid,$2::uuid,'SOURCE','Importación F2.2.1 · cr26e_tabla1')
ON CONFLICT DO NOTHING`,
[fieldId, territoryDocumentId], [fieldId, territoryDocumentId],
); );
for (const [definitionCode, value] of [['departamento_fuente', row.department], ['tipo_concesion_fuente', row.concessionType]] as const) { for (const [definitionCode, value] of [
['departamento_fuente', row.department],
['tipo_concesion_fuente', row.concessionType],
] as const) {
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_attribute_values (asset_id,definition_id,value) `INSERT INTO asset_attribute_values (asset_id,definition_id,value)
SELECT $1,definition.id,to_jsonb($3::text) SELECT $1::uuid,definition.id,to_jsonb($3::text)
FROM asset_attribute_definitions definition FROM asset_attribute_definitions definition
JOIN asset_types type ON type.id=definition.asset_type_id JOIN asset_types type ON type.id=definition.asset_type_id
WHERE lower(type.code)='yacimiento' AND lower(definition.code)=lower($2) WHERE lower(type.code)='yacimiento'
ON CONFLICT (asset_id,definition_id) DO UPDATE SET value=EXCLUDED.value,updated_at=CURRENT_TIMESTAMP`, AND lower(definition.code)=lower($2::text)
ON CONFLICT (asset_id,definition_id)
DO UPDATE SET value=EXCLUDED.value,updated_at=CURRENT_TIMESTAMP`,
[fieldId, definitionCode, value], [fieldId, definitionCode, value],
); );
} }
const rightName = `Tipo informado: ${row.concessionType}`;
const rightKey = `${areaId}|${slug(row.concessionType)}`; const rightKey = `${areaId}|${slug(row.concessionType)}`;
if (!seenRights.has(rightKey)) { if (!seenRights.has(rightKey)) {
seenRights.add(rightKey); seenRights.add(rightKey);
await queryRunner.query( const existing = (await queryRunner.query(
`INSERT INTO area_legal_rights (area_id,right_type,name,status,source_document_id,notes) `SELECT id FROM area_legal_rights
SELECT $1,$2::area_legal_right_type,$3,'ACTIVE',$4,$5 WHERE area_id=$1::uuid AND lower(name)=lower($2::text)
WHERE NOT EXISTS ( AND source_document_id=$3::uuid LIMIT 1`,
SELECT 1 FROM area_legal_rights WHERE area_id=$1 AND lower(name)=lower($3) AND source_document_id=$4 [areaId, rightName, territoryDocumentId],
)`, )) as IdRow[];
[areaId, legalRightType(row.concessionType), `Tipo informado: ${row.concessionType}`, territoryDocumentId, `Importado desde cr26e_tabla1. Departamento: ${row.department}.`], if (!existing[0]?.id) {
); await queryRunner.query(
`INSERT INTO area_legal_rights
(area_id,right_type,name,status,source_document_id,notes)
VALUES ($1::uuid,$2::area_legal_right_type,$3::varchar,'ACTIVE',$4::uuid,$5::text)`,
[
areaId,
legalRightType(row.concessionType),
rightName,
territoryDocumentId,
`Importado desde cr26e_tabla1. Departamento: ${row.department}.`,
],
);
}
} }
} }
const topLevelTypes = new Set(source.types.map((entry) => entry.code)); const topLevelTypes = new Set(source.types.map((entry) => entry.code));
for (const pair of source.parentPairs) topLevelTypes.delete(pair.child); for (const pair of source.parentPairs) topLevelTypes.delete(pair.child);
const allTypeDefinitions = new Map(source.types.map((entry) => [entry.code, entry.name])); const allTypeDefinitions = new Map(source.types.map((entry) => [entry.code, entry.name]));
for (const targets of Object.values(groupTargets)) { for (const targets of Object.values(groupTargets)) {
for (const target of targets) if (!allTypeDefinitions.has(target)) allTypeDefinitions.set(target, target.replaceAll('_', ' ')); for (const target of targets) {
if (!allTypeDefinitions.has(target)) {
allTypeDefinitions.set(target, target.replaceAll('_', ' '));
}
}
} }
for (const [typeCode, typeName] of allTypeDefinitions) { for (const [typeCode, typeName] of allTypeDefinitions) {
await queryRunner.query( if (!(await assetTypeIdByCode(queryRunner, typeCode))) {
`INSERT INTO asset_types (code,name,description,can_be_root,is_active,operational_role) await queryRunner.query(
SELECT $1,$2,'Tipo incorporado desde APLICACION APP(1).xlsx · F2.2.1',false,true,'GENERIC' `INSERT INTO asset_types (code,name,description,can_be_root,is_active,operational_role)
WHERE NOT EXISTS (SELECT 1 FROM asset_types WHERE lower(code)=lower($1))`, VALUES ($1::varchar,$2::varchar,
[typeCode, typeName], 'Tipo incorporado desde APLICACION APP(1).xlsx · F2.2.1',false,true,'GENERIC')`,
); [typeCode, typeName],
);
}
await queryRunner.query( await queryRunner.query(
`INSERT INTO finding_catalog_asset_type_profiles (asset_type_id,reason) `INSERT INTO finding_catalog_asset_type_profiles (asset_type_id,reason)
SELECT id,'Aplicabilidad inicial importada desde APLICACION APP(1).xlsx' SELECT id,'Aplicabilidad inicial importada desde APLICACION APP(1).xlsx'
FROM asset_types WHERE lower(code)=lower($1) FROM asset_types WHERE lower(code)=lower($1::text)
ON CONFLICT (asset_type_id) DO NOTHING`, ON CONFLICT (asset_type_id) DO NOTHING`,
[typeCode], [typeCode],
); );
@@ -291,7 +406,7 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id) `INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id)
SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent
WHERE lower(child.code)=lower($1) AND lower(parent.code)='yacimiento' WHERE lower(child.code)=lower($1::text) AND lower(parent.code)='yacimiento'
ON CONFLICT DO NOTHING`, ON CONFLICT DO NOTHING`,
[typeCode], [typeCode],
); );
@@ -301,7 +416,7 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id) `INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id)
SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent
WHERE lower(child.code)=lower($1) AND lower(parent.code)=lower($2) WHERE lower(child.code)=lower($1::text) AND lower(parent.code)=lower($2::text)
ON CONFLICT DO NOTHING`, ON CONFLICT DO NOTHING`,
[pair.child, pair.parent], [pair.child, pair.parent],
); );
@@ -311,7 +426,7 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id) `INSERT INTO asset_type_parent_rules (child_type_id,parent_type_id)
SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent SELECT child.id,parent.id FROM asset_types child CROSS JOIN asset_types parent
WHERE lower(child.code)=lower($1) AND lower(parent.code)='yacimiento' WHERE lower(child.code)=lower($1::text) AND lower(parent.code)='yacimiento'
ON CONFLICT DO NOTHING`, ON CONFLICT DO NOTHING`,
[typeCode], [typeCode],
); );
@@ -322,16 +437,21 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
let sortOrder = 100; let sortOrder = 100;
for (const label of entry.labels) { for (const label of entry.labels) {
const attributeCode = slug(label, 72); const attributeCode = slug(label, 72);
await queryRunner.query( const typeId = await assetTypeIdByCode(queryRunner, entry.type);
`INSERT INTO asset_attribute_definitions (asset_type_id,code,name,data_type,is_required,is_active,sort_order) if (!typeId) continue;
SELECT type.id,$2,$3,'TEXT',false,true,$4 FROM asset_types type const existing = (await queryRunner.query(
WHERE lower(type.code)=lower($1) `SELECT id FROM asset_attribute_definitions
AND NOT EXISTS ( WHERE asset_type_id=$1::uuid AND lower(code)=lower($2::text) LIMIT 1`,
SELECT 1 FROM asset_attribute_definitions existing [typeId, attributeCode],
WHERE existing.asset_type_id=type.id AND lower(existing.code)=lower($2) )) as IdRow[];
)`, if (!existing[0]?.id) {
[entry.type, attributeCode, label, sortOrder], await queryRunner.query(
); `INSERT INTO asset_attribute_definitions
(asset_type_id,code,name,data_type,is_required,is_active,sort_order)
VALUES ($1::uuid,$2::varchar,$3::varchar,'TEXT',false,true,$4::integer)`,
[typeId, attributeCode, label, sortOrder],
);
}
sortOrder += 10; sortOrder += 10;
} }
} }
@@ -341,22 +461,29 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
SELECT 'APP26','Aplicación APP 2026',260,true SELECT 'APP26','Aplicación APP 2026',260,true
WHERE NOT EXISTS (SELECT 1 FROM finding_categories WHERE lower(code)='app26') WHERE NOT EXISTS (SELECT 1 FROM finding_categories WHERE lower(code)='app26')
`); `);
const categoryRows = (await queryRunner.query(`SELECT id FROM finding_categories WHERE lower(code)='app26' LIMIT 1`)) as Array<{ id: string }>; const categoryRows = (await queryRunner.query(
`SELECT id FROM finding_categories WHERE lower(code)='app26' LIMIT 1`,
)) as IdRow[];
const categoryId = categoryRows[0]?.id; const categoryId = categoryRows[0]?.id;
if (!categoryId) throw new Error('Could not resolve APP26 finding category'); if (!categoryId) throw new Error('Could not resolve APP26 finding category');
const titlesByType = new Map<string, Set<string>>(); const titlesByType = new Map<string, Set<string>>();
const addTitle = (typeCode: string, title: string) => { const addTitle = (typeCode: string, title: string): void => {
const cleanTitle = title.trim(); const cleanTitle = title.trim();
if (!cleanTitle || /^idem\b/i.test(cleanTitle)) return; if (!cleanTitle || /^idem\b/i.test(cleanTitle)) return;
const set = titlesByType.get(typeCode) ?? new Set<string>(); const set = titlesByType.get(typeCode) ?? new Set<string>();
set.add(cleanTitle); set.add(cleanTitle);
titlesByType.set(typeCode, set); titlesByType.set(typeCode, set);
}; };
for (const entry of source.directFindings) for (const title of entry.titles) addTitle(entry.type, title);
for (const entry of source.directFindings) {
for (const title of entry.titles) addTitle(entry.type, title);
}
for (const group of source.groups) { for (const group of source.groups) {
const targets = groupTargets[slug(group.name)] ?? [slug(group.name)]; const targets = groupTargets[slug(group.name)] ?? [slug(group.name)];
for (const target of targets) for (const item of group.items) addTitle(target, item.title); for (const target of targets) {
for (const item of group.items) addTitle(target, item.title);
}
} }
for (let pass = 0; pass < 3; pass += 1) { for (let pass = 0; pass < 3; pass += 1) {
for (const entry of source.idemRefs) { for (const entry of source.idemRefs) {
@@ -367,32 +494,64 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
} }
} }
const allTitles = [...new Set([...titlesByType.values()].flatMap((set) => [...set]))].sort((a, b) => a.localeCompare(b, 'es')); const allTitles = [
let sourceNumber = 1; ...new Set([...titlesByType.values()].flatMap((titles) => [...titles])),
].sort((a, b) => a.localeCompare(b, 'es'));
const itemIdByTitle = new Map<string, string>(); const itemIdByTitle = new Map<string, string>();
let sourceNumber = 1;
for (const title of allTitles) { for (const title of allTitles) {
const itemCode = `APP26-${createHash('sha1').update(title).digest('hex').slice(0, 12).toUpperCase()}`; const itemCode = `APP26-${createHash('sha1').update(title).digest('hex').slice(0, 12).toUpperCase()}`;
await queryRunner.query( let itemRows = (await queryRunner.query(
`INSERT INTO finding_catalog_items (category_id,code,source_number,title,import_note,revision,is_active) `SELECT id FROM finding_catalog_items WHERE lower(code)=lower($1::text) LIMIT 1`,
SELECT $1,$2,$3,$4,'Importado desde APLICACION APP(1).xlsx · F2.2.1',1,true [itemCode],
WHERE NOT EXISTS (SELECT 1 FROM finding_catalog_items WHERE lower(code)=lower($2))`, )) as IdRow[];
[categoryId, itemCode, sourceNumber, title], if (!itemRows[0]?.id) {
); itemRows = (await queryRunner.query(
const itemRows = (await queryRunner.query(`SELECT id FROM finding_catalog_items WHERE lower(code)=lower($1) LIMIT 1`, [itemCode])) as Array<{ id: string }>; `INSERT INTO finding_catalog_items
if (itemRows[0]?.id) itemIdByTitle.set(title, itemRows[0].id); (category_id,code,source_number,title,import_note,revision,is_active)
VALUES ($1::uuid,$2::varchar,$3::integer,$4::varchar,
'Importado desde APLICACION APP(1).xlsx · F2.2.1',1,true)
RETURNING id`,
[categoryId, itemCode, sourceNumber, title],
)) as IdRow[];
}
const itemId = itemRows[0]?.id;
if (itemId) {
itemIdByTitle.set(title, itemId);
await queryRunner.query(
`INSERT INTO finding_catalog_item_versions
(item_id,revision,snapshot,actor_username)
SELECT item.id,item.revision,
jsonb_build_object(
'id',item.id,'categoryId',category.id,'categoryCode',category.code,
'categoryName',category.name,'code',item.code,'sourceNumber',item.source_number,
'title',item.title,'legalBasis',item.legal_basis,'glossary',item.glossary,
'importNote',item.import_note,'revision',item.revision,'isActive',item.is_active
),
'migration:F2.2.1'
FROM finding_catalog_items item
JOIN finding_categories category ON category.id=item.category_id
WHERE item.id=$1::uuid
AND NOT EXISTS (
SELECT 1 FROM finding_catalog_item_versions version
WHERE version.item_id=item.id AND version.revision=item.revision
)`,
[itemId],
);
}
sourceNumber += 1; sourceNumber += 1;
} }
for (const [typeCode, titles] of titlesByType) { for (const [typeCode, titles] of titlesByType) {
const typeRows = (await queryRunner.query(`SELECT id FROM asset_types WHERE lower(code)=lower($1) LIMIT 1`, [typeCode])) as Array<{ id: string }>; const assetTypeId = await assetTypeIdByCode(queryRunner, typeCode);
const assetTypeId = typeRows[0]?.id;
if (!assetTypeId) continue; if (!assetTypeId) continue;
for (const title of titles) { for (const title of titles) {
const catalogItemId = itemIdByTitle.get(title); const catalogItemId = itemIdByTitle.get(title);
if (!catalogItemId) continue; if (!catalogItemId) continue;
await queryRunner.query( await queryRunner.query(
`INSERT INTO finding_catalog_item_asset_types (catalog_item_id,asset_type_id) `INSERT INTO finding_catalog_item_asset_types (catalog_item_id,asset_type_id)
VALUES ($1,$2) ON CONFLICT DO NOTHING`, VALUES ($1::uuid,$2::uuid) ON CONFLICT DO NOTHING`,
[catalogItemId, assetTypeId], [catalogItemId, assetTypeId],
); );
} }
@@ -400,15 +559,57 @@ export class PhaseF221ReferenceExcelData1789754400000 implements MigrationInterf
await queryRunner.query( await queryRunner.query(
`INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes) `INSERT INTO asset_source_documents (asset_id,document_id,relation_type,notes)
SELECT asset.id,$1,'MENTIONS','El tipo/hallazgo del elemento se definió con la matriz APLICACION APP(1).xlsx' SELECT asset.id,$1::uuid,'MENTIONS',
FROM assets asset JOIN asset_types type ON type.id=asset.asset_type_id 'El tipo/hallazgo del elemento se definió con la matriz APLICACION APP(1).xlsx'
FROM assets asset
JOIN asset_types type ON type.id=asset.asset_type_id
WHERE lower(type.code)='yacimiento' WHERE lower(type.code)='yacimiento'
ON CONFLICT DO NOTHING`, ON CONFLICT DO NOTHING`,
[appDocumentId], [appDocumentId],
); );
const importedYacimientos = (await queryRunner.query(
`SELECT count(*)::text AS total
FROM assets asset JOIN asset_types type ON type.id=asset.asset_type_id
WHERE asset.data_origin='IMPORT'
AND asset.source_name='Tablas de yacimiento(1).xlsx'
AND lower(type.code)='yacimiento'`,
)) as CountRow[];
if (Number(importedYacimientos[0]?.total ?? 0) !== source.territory.length) {
throw new Error(
`F2.2.1 verification failed: expected ${source.territory.length} imported yacimientos, found ${importedYacimientos[0]?.total ?? '0'}`,
);
}
const importedCatalog = (await queryRunner.query(
`SELECT count(*)::text AS total
FROM finding_catalog_items item
JOIN finding_categories category ON category.id=item.category_id
WHERE lower(category.code)='app26'`,
)) as CountRow[];
if (Number(importedCatalog[0]?.total ?? 0) !== allTitles.length) {
throw new Error(
`F2.2.1 verification failed: expected ${allTitles.length} APP26 findings, found ${importedCatalog[0]?.total ?? '0'}`,
);
}
const halfContexts = (await queryRunner.query(
`SELECT count(*)::text AS total FROM assets
WHERE (operational_area_id IS NULL) <> (operator_company_id IS NULL)`,
)) as CountRow[];
if (Number(halfContexts[0]?.total ?? 0) !== 0) {
throw new Error('F2.2.1 verification failed: an imported asset has an incomplete operational context');
}
// eslint-disable-next-line no-console
console.log(
`[F2.2.1] imported territory=${source.territory.length}; yacimientos=${importedYacimientos[0]?.total}; catalog=${importedCatalog[0]?.total}; halfContexts=0`,
);
} }
public async down(): Promise<void> { public async down(): Promise<void> {
throw new Error('F2.2.1 contiene maestros territoriales y catálogo de referencia; no se revierte destructivamente. Restaurar backup PRE si fuera necesario.'); throw new Error(
'F2.2.1 contiene maestros territoriales y catálogo de referencia; no se revierte destructivamente. Restaurar backup PRE si fuera necesario.',
);
} }
} }