Merge pull request #3985 from bcgov/release

Release v1.2.7

Author: AlexZorkin

backend/lcfs/db/migrations/versions/2026-02-26-12-02_e3b7a9d4c2f1.py

@@ -0,0 +1,24 @@
+"""Add Gigajoules to quantity units enum.
+
+Revision ID: e3b7a9d4c2f1
+Revises: 3d7b65a9d2ef
+Create Date: 2026-02-19 10:00:00.000000
+"""
+
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "e3b7a9d4c2f1"
+down_revision = "3d7b65a9d2ef"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    with op.get_context().autocommit_block():
+        op.execute("ALTER TYPE quantityunitsenum ADD VALUE IF NOT EXISTS 'Gigajoules'")
+
+
+def downgrade() -> None:
+    # PostgreSQL does not support removing enum values in-place.
+    pass

backend/lcfs/db/migrations/versions/2026-03-01-12-00_b1234567890c.py

@@ -0,0 +1,40 @@
+"""Add active flag to compliance report charging equipment
+
+Revision ID: b1234567890c
+Revises: e3b7a9d4c2f1
+Create Date: 2026-03-01 12:00:00.000000
+"""
+
+from alembic import op
+import sqlalchemy as sa
+
+# revision identifiers, used by Alembic.
+revision = "b1234567890c"
+down_revision = "e3b7a9d4c2f1"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.add_column(
+        "compliance_report_charging_equipment",
+        sa.Column(
+            "is_active",
+            sa.Boolean(),
+            nullable=False,
+            server_default=sa.true(),
+            comment="Indicates whether the reporting row is active for compliance",
+        ),
+    )
+
+    op.execute(
+        """
+        UPDATE compliance_report_charging_equipment
+        SET is_active = TRUE
+        WHERE is_active IS NULL
+        """
+    )
+
+
+def downgrade() -> None:
+    op.drop_column("compliance_report_charging_equipment", "is_active")

backend/lcfs/db/migrations/versions/2026-03-01-12-01_8e9f1a2b3c4d.py

@@ -0,0 +1,128 @@
+"""Create credit market audit log table
+
+Revision ID: 8e9f1a2b3c4d
+Revises: b1234567890c
+Create Date: 2026-02-11 10:30:00.000000
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "8e9f1a2b3c4d"
+down_revision = "b1234567890c"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.create_table(
+        "credit_market_audit_log",
+        sa.Column(
+            "credit_market_audit_log_id",
+            sa.Integer(),
+            autoincrement=True,
+            nullable=False,
+            comment="Unique identifier for each credit market audit log entry.",
+        ),
+        sa.Column(
+            "organization_id",
+            sa.Integer(),
+            nullable=False,
+            comment="Organization associated with the credit market listing change.",
+        ),
+        sa.Column(
+            "credits_to_sell",
+            sa.Integer(),
+            nullable=False,
+            server_default=sa.text("0"),
+            comment="Credits to sell at the time of the change.",
+        ),
+        sa.Column(
+            "credit_market_is_seller",
+            sa.Boolean(),
+            nullable=False,
+            server_default=sa.text("false"),
+            comment="Whether the organization was marked as seller.",
+        ),
+        sa.Column(
+            "credit_market_is_buyer",
+            sa.Boolean(),
+            nullable=False,
+            server_default=sa.text("false"),
+            comment="Whether the organization was marked as buyer.",
+        ),
+        sa.Column(
+            "contact_person",
+            sa.String(length=500),
+            nullable=True,
+            comment="Credit market contact person name.",
+        ),
+        sa.Column(
+            "phone",
+            sa.String(length=50),
+            nullable=True,
+            comment="Credit market contact phone.",
+        ),
+        sa.Column(
+            "email",
+            sa.String(length=255),
+            nullable=True,
+            comment="Credit market contact email.",
+        ),
+        sa.Column(
+            "changed_by",
+            sa.String(length=255),
+            nullable=True,
+            comment="BCeID/IDIR username that performed the listing change.",
+        ),
+        sa.Column(
+            "create_date",
+            sa.TIMESTAMP(timezone=True),
+            server_default=sa.text("now()"),
+            nullable=True,
+            comment="Date and time (UTC) when the physical record was created in the database.",
+        ),
+        sa.Column(
+            "update_date",
+            sa.TIMESTAMP(timezone=True),
+            server_default=sa.text("now()"),
+            nullable=True,
+            comment="Date and time (UTC) when the physical record was updated in the database. It will be the same as the create_date until the record is first updated after creation.",
+        ),
+        sa.PrimaryKeyConstraint(
+            "credit_market_audit_log_id", name=op.f("pk_credit_market_audit_log")
+        ),
+        sa.ForeignKeyConstraint(
+            ["organization_id"],
+            ["organization.organization_id"],
+            name=op.f("fk_credit_market_audit_log_organization_id_organization"),
+        ),
+        comment="Captures historical snapshots of credit trading market listings after each change.",
+    )
+
+    op.create_index(
+        "idx_credit_market_audit_log_create_date",
+        "credit_market_audit_log",
+        ["create_date"],
+        unique=False,
+    )
+    op.create_index(
+        "idx_credit_market_audit_log_changed_by",
+        "credit_market_audit_log",
+        ["changed_by"],
+        unique=False,
+    )
+
+
+def downgrade() -> None:
+    op.drop_index(
+        "idx_credit_market_audit_log_changed_by",
+        table_name="credit_market_audit_log",
+    )
+    op.drop_index(
+        "idx_credit_market_audit_log_create_date",
+        table_name="credit_market_audit_log",
+    )
+    op.drop_table("credit_market_audit_log")

backend/lcfs/db/migrations/versions/2026-03-03-11-30_84d7cf6d1940.py

@@ -0,0 +1,87 @@
+"""Alter unique constraints on Charging site
+
+Revision ID: 84d7cf6d1940
+Revises: 8e9f1a2b3c4d
+Create Date: 2026-03-03 11:30:47.227193
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+from alembic_postgresql_enum import TableReference
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = "84d7cf6d1940"
+down_revision = "8e9f1a2b3c4d"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.drop_index(
+        op.f("idx_charging_equipment_charging_site_id"),
+        table_name="charging_equipment",
+        if_exists=True,
+    )
+    op.drop_index(
+        op.f("idx_charging_site_site_code"), table_name="charging_site", if_exists=True
+    )
+    op.drop_constraint(
+        op.f("uq_charging_site_org_name"),
+        "charging_site",
+        type_="unique",
+        if_exists=True,
+    )
+    op.drop_constraint(
+        op.f("uq_charging_site_site_code"),
+        "charging_site",
+        type_="unique",
+        if_exists=True,
+    )
+    op.create_index(
+        op.f("idx_charging_site_site_code"),
+        "charging_site",
+        ["site_code"],
+        unique=False,
+    )
+    op.create_unique_constraint(
+        "uq_charging_site_id_version", "charging_site", ["charging_site_id", "version"]
+    )
+    op.create_unique_constraint(
+        "uq_charging_site_org_name",
+        "charging_site",
+        ["organization_id", "site_name", "site_code", "version"],
+    )
+
+
+def downgrade() -> None:
+    op.drop_constraint(
+        "uq_charging_site_org_name", "charging_site", type_="unique", if_exists=True
+    )
+    op.drop_constraint(
+        "uq_charging_site_id_version", "charging_site", type_="unique", if_exists=True
+    )
+    op.drop_index(
+        op.f("idx_charging_site_site_code"), table_name="charging_site", if_exists=True
+    )
+    op.create_index(
+        op.f("idx_charging_site_site_code"),
+        "charging_site",
+        ["site_code"],
+        unique=False,
+    )
+    op.create_unique_constraint(
+        op.f("uq_charging_site_site_code"), "charging_site", ["site_code"]
+    )
+    op.create_unique_constraint(
+        "uq_charging_site_org_name",
+        "charging_site",
+        ["organization_id", "site_name", "site_code"],
+    )
+    op.create_index(
+        op.f("idx_charging_equipment_charging_site_id"),
+        "charging_equipment",
+        ["charging_site_id"],
+        unique=False,
+    )

backend/lcfs/db/models/compliance/ChargingSite.py

@@ -41,12 +41,18 @@ class ChargingSite(BaseModel, Auditable, Versioning):
 
     __tablename__ = "charging_site"
     __table_args__ = (
-        UniqueConstraint("site_code"),
         UniqueConstraint(
             "organization_id",
             "site_name",
+            "site_code",
+            "version",
             name="uq_charging_site_org_name",
         ),
+        UniqueConstraint(
+            "charging_site_id",
+            "version",
+            name="uq_charging_site_id_version",
+        ),
         {"comment": "Charging sites"},
     )
 

backend/lcfs/db/models/compliance/ComplianceReport.py

@@ -38,6 +38,7 @@ class QuantityUnitsEnum(enum.Enum):
     Litres = "L"
     Kilograms = "kg"
     Kilowatt_hour = "kWh"
+    Gigajoules = "Gj"
     Cubic_metres = "m³"
 
 

backend/lcfs/db/models/compliance/ComplianceReportChargingEquipment.py

@@ -10,6 +10,7 @@
     Double,
     DateTime,
     UniqueConstraint,
+    Boolean,
 )
 from sqlalchemy.orm import relationship
 from datetime import datetime
@@ -116,6 +117,13 @@ class ComplianceReportChargingEquipment(BaseModel, Auditable):
         nullable=True,
         comment="Optional notes about compliance for this association",
     )
+    is_active = Column(
+        Boolean,
+        nullable=False,
+        default=True,
+        server_default="true",
+        comment="Indicates whether the association is active for reporting",
+    )
 
     # Relationships
     charging_equipment = relationship(

backend/lcfs/db/models/fuel/FuelType.py

@@ -12,6 +12,7 @@ class QuantityUnitsEnum(enum.Enum):
     Litres = "L"
     Kilograms = "kg"
     Kilowatt_hour = "kWh"
+    Gigajoules = "Gj"
     Cubic_metres = "m³"