# -*- coding: utf-8 -*-
from collections import OrderedDict
import pykintone
import numpy as np
import pandas as pd
from karura.core.dataframe_extension import DataFrameExtension, FType
from karura.env import get_kintone_env


class Field():

    def __init__(self, code, f_type, label, is_unique):
        self.code = code
        self.f_type = f_type
        self.label = label
        self.is_unique = is_unique
    
    @classmethod
    def create(cls, f_code, f_dict):
        f_type = f_dict["type"]
        f_label = f_dict["label"]
        is_unique = False
        if "unique" in f_dict:
            is_unique = f_dict["unique"]

        f = Field(f_code, f_type, f_label, is_unique)
        if f.get_feature_type() is not None:
            return f
        else:
            return None        

    def get_feature_type(self):
        ftype = None
        if self.f_type in ["CREATED_TIME", "CREATOR", "MODIFIER", "UPDATED_TIME", "RECORD_NUMBER", "作成日時", "作成者", "更新者", "更新日時", "レコード番号"]:
            pass
        elif self.f_type in ["FILE", "LINK", "RICH_TEXT", "STATUS_ASSIGNEE", "SUBTABLE"]:
            pass
        elif self.is_unique:
            ftype = FType.unique
        elif self.f_type in ["RADIO_BUTTON", "DROP_DOWN", "CHECK_BOX", "MULTI_SELECT", "CATEGORY", "STATUS", "カテゴリー", "ステータス", "USER_SELECT"]:
            # todo: think about multiselect
            ftype = FType.categorical
        elif self.f_type in ["DATE", "DATETIME"]:
            ftype = FType.datetime
        elif self.f_type in ["NUMBER", "CALC"]:
            ftype = FType.numerical
        elif self.f_type in ["MULTI_LINE_TEXT", "SINGLE_LINE_TEXT"]:
            # optional inferring
            if self.code.endswith("_type") or self.code.endswith("_category"):
                ftype = FType.categorical
            elif not self.is_unique and (self.code.endswith("_id") or self.code.endswith("_cd")):
                ftype = FType.categorical
            elif self.code.endswith("_value"):
                ftype = FType.numerical
            else:
                ftype = FType.text

        return ftype
    
    def __repr__(self):
        repr = "<{}:{}->{} {}>".format(self.__class__, self.f_type, self.get_feature_type(), self.label)
        return repr


class Application():

    def __init__(self, env=None):
        self.env = env if env is not None else get_kintone_env()
        self.max_count = 10000
        self._kintone_limit = 500
    
    def get_app_id(self, app_name):
        kintone = pykintone.login(self.env.domain, self.env.login_id, self.env.password)
        result = kintone.administration().select_app_info()
        if result.ok:
            matched = [a for a in result.infos if a.name == app_name]
            if len(matched) > 0:
                return matched[0].app_id
            else:
                return ""
        else:
            raise Exception("Error occurred when getting the app_id")


    def load(self, app_id, query="", fields=(), target=""):
        app = pykintone.login(self.env.domain, self.env.login_id, self.env.password).app(app_id)
        fields_d = self.get_fields(app_id)
        if len(fields) > 0:
            d = OrderedDict()
            for f in fields:
                if f in fields_d:
                    d[f] = fields_d[f]
            fields_d = d
        
        q = query + " " if query else ""

        records = []
        _fields = list(fields_d.keys())
        selected = app.select(query=q + "limit {}".format(self._kintone_limit), fields=_fields)
        records = selected.records
        if selected.total_count > self._kintone_limit:
            repeat = np.floor(min(self.max_count, selected.total_count) / self._kintone_limit)
            for i in range(int(repeat)):
                selected = app.select(query=q + "limit {} offset {}".format(self._kintone_limit, (i + 1) * self._kintone_limit), fields=_fields)
                if len(selected.records) > 0:
                    records += selected.records

        data = []
        columns = []
        for i, r in enumerate(records):
            row = []

            if i == 0:
                columns = [f for f in _fields if f in r]

            for f in columns:
                v = r[f]["value"]
                row.append(v)
            
            if len(row) > 0:
                data.append(row)
        
        fs = [fields_d[c] for c in columns]
        df = pd.DataFrame(np.array(data), columns=[f.label for f in fs])
        categoricals = [f.label for f in fs if f.get_feature_type() == FType.categorical]
        numericals = [f.label for f in fs if f.get_feature_type() == FType.numerical]
        datetimes = [f.label for f in fs if f.get_feature_type() == FType.datetime]
        texts = [f.label for f in fs if f.get_feature_type() == FType.text]
        uniques = [f.label for f in fs if f.get_feature_type() == FType.unique]

        dfe = DataFrameExtension(df, categoricals, numericals, datetimes, texts, uniques)
        if target:
            dfe.target = fields_d[target].label
        return dfe

    def get_fields(self, app_id):
        # todo: if app_id exists on karura app, get field definition from it.

        app = pykintone.login(self.env.domain, self.env.login_id, self.env.password).app(app_id)
        fields = app.administration().form().get()

        if not fields.ok:
            raise Exception("Error occurred when getting the form information from kintone.")
        
        fs = fields.raw
        d = OrderedDict()

        for f_code in fs:
            f = Field.create(f_code, fs[f_code])
            if f:
                d[f_code] = f
        
        return d

# -*- coding: utf-8 -*-
from collections import OrderedDict
import pykintone
import numpy as np
import pandas as pd
from karura.core.dataframe_extension import DataFrameExtension, FType
from karura.env import get_kintone_env


class Field():

    def __init__(self, code, f_type, label, is_unique):
        self.code = code
        self.f_type = f_type
        self.label = label
        self.is_unique = is_unique
    
    @classmethod
    def create(cls, f_code, f_dict):
        f_type = f_dict["type"]
        f_label = f_dict["label"]
        is_unique = False
        if "unique" in f_dict:
            is_unique = f_dict["unique"]

        f = Field(f_code, f_type, f_label, is_unique)
        if f.get_feature_type() is not None:
            return f
        else:
            return None        

    def get_feature_type(self):
        ftype = None
        if self.f_type in ["CREATED_TIME", "CREATOR", "MODIFIER", "UPDATED_TIME", "RECORD_NUMBER", "作成日時", "作成者", "更新者", "更新日時", "レコード番号"]:
            pass
        elif self.f_type in ["FILE", "LINK", "RICH_TEXT", "STATUS_ASSIGNEE", "SUBTABLE"]:
            pass
        elif self.is_unique:
            ftype = FType.unique
        elif self.f_type in ["RADIO_BUTTON", "DROP_DOWN", "CHECK_BOX", "MULTI_SELECT", "CATEGORY", "STATUS", "カテゴリー", "ステータス", "USER_SELECT"]:
            # todo: think about multiselect
            ftype = FType.categorical
        elif self.f_type in ["DATE", "DATETIME"]:
            ftype = FType.datetime
        elif self.f_type in ["NUMBER", "CALC"]:
            ftype = FType.numerical
        elif self.f_type in ["MULTI_LINE_TEXT", "SINGLE_LINE_TEXT"]:
            # optional inferring
            if self.code.endswith("_type") or self.code.endswith("_category"):
                ftype = FType.categorical
            elif not self.is_unique and (self.code.endswith("_id") or self.code.endswith("_cd")):
                ftype = FType.categorical
            elif self.code.endswith("_value"):
                ftype = FType.numerical
            else:
                ftype = FType.text

        return ftype
    
    def __repr__(self):
        repr = "<{}:{}->{} {}>".format(self.__class__, self.f_type, self.get_feature_type(), self.label)
        return repr


class Application():

    def __init__(self, env=None):
        self.env = env if env is not None else get_kintone_env()
        self.max_count = 10000
        self._kintone_limit = 500
    
    def get_app_id(self, app_name):
        kintone = pykintone.login(self.env.domain, self.env.login_id, self.env.password)
        result = kintone.administration().select_app_info()
        if result.ok:
            matched = [a for a in result.infos if a.name == app_name]
            if len(matched) > 0:
                return matched[0].app_id
            else:
                return ""
        else:
            raise Exception("Error occurred when getting the app_id")


    def load(self, app_id, query="", fields=(), target=""):
        app = pykintone.login(self.env.domain, self.env.login_id, self.env.password).app(app_id)
        fields_d = self.get_fields(app_id)
        if len(fields) > 0:
            d = OrderedDict()
            for f in fields:
                if f in fields_d:
                    d[f] = fields_d[f]
            fields_d = d
        
        q = query + " " if query else ""

        records = []
        _fields = list(fields_d.keys())
        selected = app.select(query=q + "limit {}".format(self._kintone_limit), fields=_fields)
        records = selected.records
        if selected.total_count > self._kintone_limit:
            repeat = np.floor(min(self.max_count, selected.total_count) / self._kintone_limit)
            for i in range(int(repeat)):
                selected = app.select(query=q + "limit {} offset {}".format(self._kintone_limit, (i + 1) * self._kintone_limit), fields=_fields)
                if len(selected.records) > 0:
                    records += selected.records

        data = []
        columns = []
        for i, r in enumerate(records):
            row = []

            if i == 0:
                columns = [f for f in _fields if f in r]

            for f in columns:
                v = r[f]["value"]
                row.append(v)
            
            if len(row) > 0:
                data.append(row)
        
        fs = [fields_d[c] for c in columns]
        df = pd.DataFrame(np.array(data), columns=[f.label for f in fs])
        categoricals = [f.label for f in fs if f.get_feature_type() == FType.categorical]
        numericals = [f.label for f in fs if f.get_feature_type() == FType.numerical]
        datetimes = [f.label for f in fs if f.get_feature_type() == FType.datetime]
        texts = [f.label for f in fs if f.get_feature_type() == FType.text]
        uniques = [f.label for f in fs if f.get_feature_type() == FType.unique]

        dfe = DataFrameExtension(df, categoricals, numericals, datetimes, texts, uniques)
        if target:
            dfe.target = fields_d[target].label
        return dfe

    def get_fields(self, app_id):
        # todo: if app_id exists on karura app, get field definition from it.

        app = pykintone.login(self.env.domain, self.env.login_id, self.env.password).app(app_id)
        fields = app.administration().form().get()

        if not fields.ok:
            raise Exception("Error occurred when getting the form information from kintone.")
        
        fs = fields.raw
        d = OrderedDict()

        for f_code in fs:
            f = Field.create(f_code, fs[f_code])
            if f:
                d[f_code] = f
        
        return d

# -*- coding: utf-8 -*- # todo: think about multiselect # optional inferring # todo: if app_id exists on karura app, get field definition from it.