import json

from django.contrib.contenttypes.fields import GenericRelation
from django.db import models, connection


class TtZone(models.Model):
    code = models.CharField(max_length=150)
    name = models.CharField(max_length=255)
    desc = models.TextField(null=True)
    department = models.ForeignKey("api.TtDepartment", on_delete=models.SET_NULL, null=True)
    zone = models.ForeignKey("api.TtZone", on_delete=models.SET_NULL, null=True,related_name="sub_zone") # related name is used for get sub zone
    extra_data_1 = models.TextField(null=True)
    extra_data_2 = models.TextField(null=True)
    extra_data_3 = models.TextField(null=True)
    extra_data_4 = models.TextField(null=True)
    extra_data_5 = models.TextField(null=True)
    extra_data_6 = models.TextField(null=True)
    extra_data_7 = models.TextField(null=True)
    extra_data_8 = models.TextField(null=True)
    extra_data_9 = models.TextField(null=True)
    extra_data_10 = models.TextField(null=True)
    status = models.SmallIntegerField()
    created_by = models.BigIntegerField(null=True)
    created_at = models.DateTimeField(auto_now_add=True)
    updated_by = models.BigIntegerField(null=True)
    updated_at = models.DateTimeField(auto_now=True)

    # wont add column, just want create relation between self and tt_tag_relation table
    tag = GenericRelation(
        "api.TtTagRelation",
        content_type_field="refer_table",
        object_id_field="refer_id",
    )

    STATUS_TO_CODE = {
        "active": 1,
        "inactive": 2,
    }

    IMPORT_RULES = {
        "code": ["required", "string", "unique"],
        "name": ["required", "string"],
        "desc": ["nullable", "string"],
        "department_id": ["nullable", "exist"], # department code
        "zone_id": ["nullable", "exist"], # zone code
        **{
            f"extra_data_{i}": ["nullable", "string"]
            for i in range(1, 11)
        },
    }

    class Meta:
        db_table = "tt_zone"

    def __str__(self):
        return self.name

    @staticmethod
    def get_all_level_sub_zone_ids(zone_id, level=None, include_self=False):
        with connection.cursor() as cursor:
            sql = """
                    WITH RECURSIVE dept_tree AS (
                        SELECT id, zone_id, 0 as level
                        FROM tt_zone
                        WHERE id = %s
                        UNION ALL
                        SELECT z.id, z.zone_id, dt.level + 1
                        FROM tt_zone z
                        INNER JOIN dept_tree dt ON z.zone_id = dt.id
                        {level_limit}
                    )
                    SELECT id FROM dept_tree WHERE id != %s;
                """
            level_limit = ""
            params = [zone_id, zone_id]
            if level is not None:
                level_limit = "WHERE dt.level < %s"
                params = [zone_id, level, zone_id]

            cursor.execute(sql.format(level_limit=level_limit), params)
            ids = [row[0] for row in cursor.fetchall()]

            if include_self:
                ids = ids + [zone_id]

        return ids