0aea981cf1
- Implemented interfaces for UnitOfMeasure, UnitOfMeasureListResponse, CreateUnitOfMeasureData, and UpdateUnitOfMeasureData. - Added API methods for listing, retrieving, creating, updating, and deleting units of measure. - Included pagination support for the list method.
409 lines
15 KiB
Python
409 lines
15 KiB
Python
"""seed_initial_data
|
|
|
|
Revision ID: 7937209f9718
|
|
Revises: 531bf8cdae06
|
|
Create Date: 2025-10-19 18:23:55.258800
|
|
|
|
"""
|
|
|
|
# pylint: disable=no-member
|
|
|
|
from typing import Sequence, Union
|
|
|
|
from alembic import op
|
|
from api.v1.modules.public.reference_data.code_pedimento_regimens.seed import (
|
|
seed as code_pedimento_regimens_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.containers.seed import (
|
|
seed as container_types_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.countries.seed import seed as countries_seed
|
|
from api.v1.modules.public.reference_data.currency_types.seed import (
|
|
seed as currency_types_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.customs_sections.seed import (
|
|
seed as customs_sections_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.customs_warehouses.seed import (
|
|
seed as customs_warehouses_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.incoterms.seed import seed as incoterms_seed
|
|
from api.v1.modules.public.reference_data.invoice_types.seed import (
|
|
seed as invoice_types_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.material_types.seed import (
|
|
seed as material_types_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.payment_methods.seed import (
|
|
seed as payment_methods_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.pedimento_codes.seed import (
|
|
seed as pedimento_codes_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.pedimento_regimens.seed import (
|
|
seed as pedimento_regimens_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.sectors.seed import seed as sectors_seed
|
|
from api.v1.modules.public.reference_data.transport_modes.seed import (
|
|
seed as transport_modes_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.transport_types.seed import (
|
|
seed as transport_types_seed,
|
|
)
|
|
from api.v1.modules.public.reference_data.valuation_methods.seed import (
|
|
seed as valuation_methods_seed,
|
|
)
|
|
from api.v1.modules.a76.general_catalogs.units_of_measure.seed_med import seed as units_of_measure_seed
|
|
from api.v1.modules.a76.general_catalogs.units_of_measure.seed_ace import seed as ace_seed
|
|
from api.v1.modules.a76.general_catalogs.units_of_measure.seed_oma import seed as oma_seed
|
|
from api.v1.modules.a76.general_catalogs.units_of_measure.seed_ame import seed as ame_seed
|
|
from api.v1.modules.a76.general_catalogs.units_of_measure.seed_adua import seed as adua_seed
|
|
|
|
# revision identifiers, used by Alembic.
|
|
revision: str = "7937209f9718"
|
|
down_revision: Union[str, Sequence[str], None] = "531bf8cdae06"
|
|
branch_labels: Union[str, Sequence[str], None] = None
|
|
depends_on: Union[str, Sequence[str], None] = None
|
|
|
|
|
|
def upgrade() -> None:
|
|
"""Upgrade schema."""
|
|
|
|
# --- AMPLIAR COLUMNAS ANTES DE INSERTAR DATOS ---
|
|
op.execute("ALTER TABLE a76.unit_of_measure_ace ALTER COLUMN code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.unit_of_measure_oma ALTER COLUMN code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.unit_of_measure_american ALTER COLUMN code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.unit_of_measure_customs ALTER COLUMN code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.units_of_measure ALTER COLUMN code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.units_of_measure ALTER COLUMN customs_code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.units_of_measure ALTER COLUMN american_code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.units_of_measure ALTER COLUMN ace_code TYPE VARCHAR(20);")
|
|
op.execute("ALTER TABLE a76.units_of_measure ALTER COLUMN oma_code TYPE VARCHAR(20);")
|
|
|
|
# --- UTILIDAD DE FORMATEO ---
|
|
def format_value(val):
|
|
if val is None or str(val).strip() == '' or str(val).upper() == 'NONE':
|
|
return 'NULL'
|
|
return f"'{str(val).replace(chr(39), chr(39)*2)}'"
|
|
|
|
# --- SEEDS PUBLIC (Tablas base) ---
|
|
# Seeds
|
|
values_pc = ", ".join(
|
|
[
|
|
f"('{code}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for code, desc in pedimento_codes_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO pedimento_codes (code, description) VALUES
|
|
{values_pc}
|
|
ON CONFLICT (code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_pr = ", ".join(
|
|
[
|
|
f"('{code}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for code, desc in pedimento_regimens_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.pedimento_regimens (code, description) VALUES
|
|
{values_pr}
|
|
ON CONFLICT (code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_cpr = ", ".join(
|
|
[
|
|
f"('{ped_code}', '{reg_code}', '{type_code}')"
|
|
for ped_code, reg_code, type_code in code_pedimento_regimens_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.code_pedimento_regimens (pedimento_code, regimen_code, type_code) VALUES
|
|
{values_cpr}
|
|
"""
|
|
)
|
|
|
|
values_c = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for key, desc in container_types_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.containers (key, description) VALUES
|
|
{values_c}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_country = ", ".join(
|
|
[
|
|
f"('{m3_key}', '{mex_key}', '{ame_key}', '{desc_es.replace(chr(39), chr(39)*2)}', '{desc_en.replace(chr(39), chr(39)*2)}')"
|
|
for m3_key, mex_key, ame_key, desc_es, desc_en in countries_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.countries (m3_key, mex_key, ame_key, description_es, description_en) VALUES
|
|
{values_country}
|
|
ON CONFLICT (m3_key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_ct = ", ".join(
|
|
[
|
|
f"('{code}', '{currency_name.replace(chr(39), chr(39)*2)}', '{country_desc.replace(chr(39), chr(39)*2)}')"
|
|
for code, currency_name, country_desc in currency_types_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.currency_types (code, currency_name, country_description) VALUES
|
|
{values_ct}
|
|
ON CONFLICT (code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_cs = ", ".join(
|
|
[
|
|
f"('{code}', '{name.replace(chr(39), chr(39)*2)}')"
|
|
for code, name in customs_sections_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.customs_sections (customs_code, section_name) VALUES
|
|
{values_cs}
|
|
ON CONFLICT (customs_code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_cw = ", ".join(
|
|
[
|
|
f"('{key}', '{customs.replace(chr(39), chr(39)*2)}', '{fiscalized_warehouse.replace(chr(39), chr(39)*2)}')"
|
|
for key, customs, fiscalized_warehouse in customs_warehouses_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.customs_warehouses (key, customs, fiscalized_warehouse)
|
|
VALUES
|
|
{values_cw}
|
|
ON CONFLICT (key, customs) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_incoterms = ", ".join(
|
|
[
|
|
f"('{code}', '{desc_es.replace(chr(39), chr(39)*2)}', '{desc_en.replace(chr(39), chr(39)*2)}')"
|
|
for code, desc_es, desc_en in incoterms_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.incoterms (code, description_es, description_en) VALUES
|
|
{values_incoterms}
|
|
ON CONFLICT (code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_it = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}', '{note.replace(chr(39), chr(39)*2)}', '{type.replace(chr(39), chr(39)*2)}', '{operation.replace(chr(39), chr(39)*2)}')"
|
|
for key, desc, note, type, operation in invoice_types_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.invoice_types (key, description, note, type, operation) VALUES
|
|
{values_it}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_mt = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}', '{category.replace(chr(39), chr(39)*2)}')"
|
|
for key, desc, category in material_types_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.material_types (key, description, type) VALUES
|
|
{values_mt}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_pm = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for key, desc in payment_methods_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.payment_methods (key, description) VALUES
|
|
{values_pm}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_sectors = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}', '{authorized}')"
|
|
for key, desc, authorized in sectors_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.sectors (key, description, authorized) VALUES
|
|
{values_sectors}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_tm = ", ".join(
|
|
[
|
|
f"('{key}', '{name.replace(chr(39), chr(39)*2)}')"
|
|
for key, name in transport_modes_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.transport_modes (key, name) VALUES
|
|
{values_tm}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_tt = ", ".join(
|
|
[
|
|
f"('{code}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for code, desc in transport_types_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.transport_types (transport_code, description) VALUES
|
|
{values_tt}
|
|
ON CONFLICT (transport_code) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
values_vm = ", ".join(
|
|
[
|
|
f"('{key}', '{desc.replace(chr(39), chr(39)*2)}')"
|
|
for key, desc in valuation_methods_seed
|
|
]
|
|
)
|
|
op.execute(
|
|
f"""
|
|
INSERT INTO public.valuation_methods (key, description) VALUES
|
|
{values_vm}
|
|
ON CONFLICT (key) DO NOTHING;
|
|
"""
|
|
)
|
|
|
|
# --- SEEDS A76 (Unidades de Medida) ---
|
|
|
|
# ACE
|
|
val_ace = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in ace_seed])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_ace (code, description) VALUES {val_ace} ON CONFLICT ON CONSTRAINT uq_uom_ace_code DO NOTHING;")
|
|
|
|
# OMA
|
|
val_oma = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in oma_seed])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_oma (code, description) VALUES {val_oma} ON CONFLICT ON CONSTRAINT uq_uom_oma_code DO NOTHING;")
|
|
|
|
# AME
|
|
val_ame = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in ame_seed])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_american (code, description) VALUES {val_ame} ON CONFLICT ON CONSTRAINT uq_uom_american_code DO NOTHING;")
|
|
|
|
# ADUA (Customs)
|
|
val_adua = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in adua_seed])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_customs (code, description) VALUES {val_adua} ON CONFLICT ON CONSTRAINT uq_uom_customs_code DO NOTHING;")
|
|
|
|
# Recolectar códigos adicionales que faltan en los catálogos
|
|
additional_customs = set()
|
|
additional_american = set()
|
|
additional_ace = set()
|
|
additional_oma = set()
|
|
|
|
existing_customs = {c for c, d in adua_seed}
|
|
existing_american = {c for c, d in ame_seed}
|
|
existing_ace = {c for c, d in ace_seed}
|
|
existing_oma = {c for c, d in oma_seed}
|
|
|
|
for code, desc, desc_en, customs, american, ace, oma in units_of_measure_seed:
|
|
if customs and customs.strip() and customs not in existing_customs:
|
|
additional_customs.add((customs, f'Auto-generated from {code}'))
|
|
if american and american.strip() and american not in existing_american:
|
|
additional_american.add((american, f'Auto-generated from {code}'))
|
|
if ace and ace.strip() and ace not in existing_ace:
|
|
additional_ace.add((ace, f'Auto-generated from {code}'))
|
|
if oma and oma.strip() and oma not in existing_oma:
|
|
additional_oma.add((oma, f'Auto-generated from {code}'))
|
|
|
|
# Insertar códigos adicionales
|
|
if additional_customs:
|
|
val_add_customs = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in additional_customs])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_customs (code, description) VALUES {val_add_customs} ON CONFLICT ON CONSTRAINT uq_uom_customs_code DO NOTHING;")
|
|
|
|
if additional_american:
|
|
val_add_american = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in additional_american])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_american (code, description) VALUES {val_add_american} ON CONFLICT ON CONSTRAINT uq_uom_american_code DO NOTHING;")
|
|
|
|
if additional_ace:
|
|
val_add_ace = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in additional_ace])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_ace (code, description) VALUES {val_add_ace} ON CONFLICT ON CONSTRAINT uq_uom_ace_code DO NOTHING;")
|
|
|
|
if additional_oma:
|
|
val_add_oma = ", ".join([f"({format_value(c)}, {format_value(d)})" for c, d in additional_oma])
|
|
op.execute(f"INSERT INTO a76.unit_of_measure_oma (code, description) VALUES {val_add_oma} ON CONFLICT ON CONSTRAINT uq_uom_oma_code DO NOTHING;")
|
|
|
|
# TABLA MAESTRA UOM
|
|
val_uom = ", ".join([
|
|
f"({format_value(code)}, {format_value(desc)}, {format_value(desc_en)}, "
|
|
f"{format_value(customs)}, {format_value(american)}, {format_value(ace)}, {format_value(oma)}, 1, 1)"
|
|
for code, desc, desc_en, customs, american, ace, oma in units_of_measure_seed
|
|
])
|
|
op.execute(f"""
|
|
INSERT INTO a76.units_of_measure
|
|
(code, description, description_en, customs_code, american_code, ace_code, oma_code, tenant_id, company_id)
|
|
VALUES {val_uom}
|
|
ON CONFLICT (code, tenant_id, company_id) DO NOTHING;
|
|
""")
|
|
|
|
|
|
def downgrade() -> None:
|
|
"""Downgrade schema."""
|
|
|
|
op.execute("DELETE FROM a76.units_of_measure;")
|
|
op.execute("DELETE FROM a76.unit_of_measure_customs;")
|
|
op.execute("DELETE FROM a76.unit_of_measure_american;")
|
|
op.execute("DELETE FROM a76.unit_of_measure_oma;")
|
|
op.execute("DELETE FROM a76.unit_of_measure_ace;")
|
|
op.execute("DELETE FROM public.valuation_methods;")
|
|
op.execute("DELETE FROM public.transport_types;")
|
|
op.execute("DELETE FROM public.transport_modes;")
|
|
op.execute("DELETE FROM public.sectors;")
|
|
op.execute("DELETE FROM public.payment_methods;")
|
|
op.execute("DELETE FROM public.material_types;")
|
|
op.execute("DELETE FROM public.invoice_types;")
|
|
op.execute("DELETE FROM public.incoterms;")
|
|
op.execute("DELETE FROM public.customs_warehouses;")
|
|
op.execute("DELETE FROM public.customs_sections;")
|
|
op.execute("DELETE FROM public.currency_types;")
|
|
op.execute("DELETE FROM public.countries;")
|
|
op.execute("DELETE FROM public.containers;")
|
|
op.execute("DELETE FROM public.code_pedimento_regimens;")
|
|
op.execute("DELETE FROM public.pedimento_regimens;")
|
|
op.execute("DELETE FROM public.pedimento_codes;")
|