from __future__ import annotations
import datetime, hashlib, logging, os, pytz, redis, secrets

from typing import Dict, List, Optional, Set, Union
from pydantic import BaseModel, EmailStr, Field, Json, PrivateAttr, ValidationError, validator

from app.db_sql import redis_lookup_id_random, get_id_random
from app.lib_general import log, logging

from .common_field_schema import base_fields, default_num_bytes


class Order_Line_Base(BaseModel):
    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    id_random: Optional[str] = Field(
        **base_fields['order_line_id_random'],
        alias = 'order_line_id_random',
        default_factory = lambda:secrets.token_urlsafe(default_num_bytes),
    )
    id: Optional[int] = Field(
        alias = 'order_line_id'
    )

    order_id_random: Optional[str]
    order_id: Optional[int]

    product_id_random: str
    product_id: Optional[int]

    product_for_type: Optional[str] # Copied from product record
    product_for_id_random: Optional[str] # Copied from product record NOPE
    product_for_id: Optional[int] # Copied from product record

    product_type_id: Optional[int] # Copied from product record
    product_type: Optional[str] # WARNING: Copied from product record; dup from look up? probably not use?
    product_type_code: Optional[str] # Copied from product record; from look up
    product_type_name: Optional[str] # Copied from product record; from look up

    product_name: Optional[str] # Copied from product record
    product_description: Optional[str] # Copied from product record
    product_unit_price: Optional[int] # Copied from product record
    product_recurring: Optional[bool] # Copied from product record

    curr_product_id_random: str # Should be the same as product_id_random above
    curr_product_id: Optional[int] # Should be the same as product_id above

     # NOTE: This is reversed with for_id_random
    curr_product_for_type: Optional[str] # Dynamic from v_order_line
    curr_product_for_id: Optional[int] # Dynamic from v_order_line
    curr_product_for_id_random: Optional[str] # Dynamic from v_order_line NOPE

    curr_product_type_id: Optional[int] # Dynamic from v_order_line
    curr_product_type: Optional[str] # Dynamic from v_order_line
    curr_product_type_code: Optional[str] # Dynamic from v_order_line
    curr_product_type_name: Optional[str] # Dynamic from v_order_line

    curr_product_name: Optional[str] # Dynamic from v_order_line
    curr_product_description: Optional[str] # Dynamic from v_order_line
    curr_product_unit_price: Optional[int] # Dynamic from v_order_line
    curr_product_max_quantity: Optional[int] # Dynamic from v_order_line
    curr_product_recurring: Optional[bool] # Dynamic from v_order_line

    for_person_id: Optional[int]
    for_person_id_random: Optional[str]
    for_person_given_name: Optional[str] # Dynamic from v_order_line
    for_person_full_name: Optional[str] # Dynamic from v_order_line

    name: Optional[str] # Should be the same as product_name above
    quantity: int = Field(0, ge=0, lt=150)
    amount: int = Field(0, ge=0, lt=1500000)
    recurring: Optional[bool] = False
    message: Optional[str]

    notes: Optional[str]

    created_on: Optional[datetime.datetime] = None
    updated_on: Optional[datetime.datetime] = None

    # Including other related objects
    # product: Optional[Union[Product_Base, None]] # Future use?
    # for_person: Optional[Union[Person_Base, None]] # Future use?

    _processed_at: datetime.datetime = PrivateAttr(default_factory=datetime.datetime.now)

    #@validator('order_line_id_random', always=True)
    def order_line_id_random_copy(cls, v, values, **kwargs):
        log.setLevel(logging.WARNING)
        log.debug(locals())

        if values['id_random']:
            return values['id_random']
        return None

    @validator('id', always=True)
    def order_line_id_lookup(cls, v, values, **kwargs):
        log.setLevel(logging.WARNING)
        log.debug(locals())

        if values['id_random']:
            log.debug(values['id_random'])
            return redis_lookup_id_random(record_id_random=values['id_random'], table_name='order_line')
        return None

    @validator('order_id', always=True)
    def order_id_lookup(cls, v, values, **kwargs):
        log.setLevel(logging.WARNING)
        log.debug(locals())

        if values['order_id_random']:
            return redis_lookup_id_random(record_id_random=values['order_id_random'], table_name='order')
        return None

    @validator('product_id', always=True)
    def product_id_lookup(cls, v, values, **kwargs):
        log.setLevel(logging.WARNING)
        log.debug(locals())

        if values.get('product_id_random', None):
            return redis_lookup_id_random(record_id_random=values['product_id_random'], table_name='product')
        return None

    @validator('product_for_id', always=True)
    def product_for_id_lookup(cls, v, values, **kwargs):
        log.setLevel(logging.WARNING)
        log.debug(locals())

        if values['product_for_id_random'] and values['product_for_type']:
            return redis_lookup_id_random(record_id_random=values['product_for_id_random'], table_name=values['product_for_type'])
        return None

    # @validator('curr_product_for_id_random', always=True)
    # def curr_product_for_id_random_lookup(cls, v, values, **kwargs):
    #     log.setLevel(logging.DEBUG)
    #     log.debug(locals())

    #     if values['curr_product_for_id'] and values['curr_product_for_type']:
    #         return redis_lookup_id(record_id=values['curr_product_for_id'], table_name=values['curr_product_for_type'])
    #     return None

    @validator('curr_product_for_id_random', always=True)
    def curr_product_for_id_random_lookup(cls, v, values, **kwargs):
        log.setLevel(logging.DEBUG)
        log.debug(locals())

        if values['curr_product_for_id'] and values['curr_product_for_type']:
            return get_id_random(record_id=values['curr_product_for_id'], table_name=values['curr_product_for_type'])
        return None

    # @validator('curr_product_for_id', always=True)
    # def curr_product_for_id_lookup(cls, v, values, **kwargs):
    #     log.setLevel(logging.WARNING)
    #     log.debug(locals())

    #     if values['curr_product_for_id_random'] and values['curr_product_for_type']:
    #         return redis_lookup_id_random(record_id_random=values['curr_product_for_id_random'], table_name=values['curr_product_for_type'])
    #     return None

    class Config:
        underscore_attrs_are_private = True
        allow_population_by_field_name = True
        fields = base_fields


class Order_Line_DB_Base(BaseModel):
    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    id_random: Optional[str] = Field(
        alias = 'order_line_id_random',
    )
    id: Optional[int] = Field(
        alias = 'order_line_id'
    )

    order_id_random: Optional[str]
    order_id: Optional[int]

    product_id_random: str
    product_id: Optional[int]

    product_for_type: Optional[str] # Copied from product record
    product_for_id_random: Optional[str] # Copied from product record NOPE
    product_for_id: Optional[int] # Copied from product record

    product_type_id: Optional[int] # Copied from product record

    product_name: Optional[str] # Copied from product record
    product_unit_price: Optional[int] # Copied from product record
    product_recurring: Optional[bool] # Copied from product record

    for_person_id: Optional[int]
    for_person_id_random: Optional[str]

    name: Optional[str] # Should be the same as product_name above
    quantity: int = Field(0, ge=0, lt=150)
    amount: int = Field(0, ge=0, lt=1500000)
    recurring: Optional[bool] = False
    recurring_period: Optional[int]

    message: Optional[str]

    notes: Optional[str]

    _processed_at: datetime.datetime = PrivateAttr(default_factory=datetime.datetime.now)

    class Config:
        underscore_attrs_are_private = True
        allow_population_by_field_name = True

Order_Line_Base.update_forward_refs()