<?php

require_once(APPDIR."/Api/v1/Modules/Operationaldata/Snopp.php");
require_once(APPDIR."/Api/v1/Modules/Operationaldata/SnoppCitycom.php");


use application\Api\v1\Modules;

class OperationaldataApicontroller extends mfBaseApicontroller
{
    //private $filter_gemeinde_ids = [];
    //private $campaign;

    private $campaign;
    private $campaigns = [];
    private $filter_salescluster_ids = [];
    private $campaigns_by_scluster = [];

    private $allowed_preordertypes = [];
    private $district_is_city = false;
    private $hausnummer_add_zusatz = false;
    private $exist_is_error = false;

    protected function init()
    {
        $db = $this->db(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
    }

    protected function registerRoutes()
    {

        /*
         * TODO: Load Api Modules automatically in mfBaseApiController
         */
        $modules = [];
        foreach (["Snopp", "SnoppCitycom"] as $moduleName) {
            $classname = "application\\Api\\v1\\Modules\\Operationaldata\\" . $moduleName;
            $modules[$moduleName] = new $classname([
                "get" => $this->get,
                "post" => $this->post,
                "db" => $this->db(),
                "me" => $this->me
            ]);
        }

        $this->addRoute("/operationaldata/networks", "getNetworks", "GET");
        $this->addRoute("/operationaldata/preordercampaigns", "getPreorderCampaigns", "GET");
        $this->addRoute("/operationaldata/buildings", "getBuildingsByCampaign", "GET");

        $this->addRoute("/operationaldata/home/:id/connected", [$modules["Snopp"], "setPreorderConnected"], "POST");
        $this->addRoute("/operationaldata/home/:id/active", [$modules["Snopp"], "setPreorderActive"], "POST");

        $this->addRoute("/operationaldata/preorder/:id/orderService", [$modules["SnoppCitycom"], "orderService"], "POST");
        $this->addRoute("/operationaldata/preorder/:id/ontStatus", [$modules["SnoppCitycom"], "getOntStatus"], "GET");
        $this->addRoute("/operationaldata/preorder/:id/ontTelemetry", [$modules["SnoppCitycom"], "getOntTelemetry"], "GET");

    }

    /*
     * is called after User is authenticated by API Key
     */
    protected function authenticated()
    {
        $this->registerRoutes();

        if ($this->me->is("preorderaddressreporting")) {
            return mfResponse::Forbidden();
        }

        $campaignApiusers = PreordercampaignApiuserModel::search(["worker_id" => $this->me->id]);

        foreach ($campaignApiusers as $campaignApiuser) {
            $campaign = new Preordercampaign($campaignApiuser->preordercampaign_id);
            if ($campaign->id) {
                foreach (PreordercampaignSalesclusterModel::search(['preordercampaign_id' => $campaign->id]) as $campain_scluster) {
                    if (!in_array($campain_scluster->salescluster_id, $this->filter_salescluster_ids)) {
                        $this->filter_salescluster_ids[] = $campain_scluster->salescluster_id;
                    }

                    $this->campaigns_by_scluster[$campain_scluster->salescluster_id] = $campaign->id;

                }
                $this->campaigns[$campaign->id] = $campaign;

                // get allowed preordertypes
                if (is_array($campaign->types) && count($campaign->types)) {
                    foreach ($campaign->types as $type) {
                        $this->allowed_preordertypes[] = $type->type;
                    }
                }

                if ($campaign->district_is_city == 1) {
                    $this->district_is_city = true;
                }
                if ($campaign->hausnummer_add_zusatz == 1) {
                    $this->hausnummer_add_zusatz = true;
                }
                if ($campaign->exist_is_error == 1) {
                    $this->exist_is_error = true;
                }
                if ($campaign->require_connectiontype == 1) {
                    $this->require_connectiontype = true;
                }
                if ($campaign->allow_unit_update == 1) {
                    $this->allow_unit_update = true;
                }
            } else {
                $this->log->debug(__METHOD__ . ": campaign not found (PreordercampaignApiuser::preordercampaign_id " . $campaignApiuser->preordercampaign_id . ")");
                $this->log->debug(print_r($campaignApiuser, true));
            }


            foreach (PreordercampaignOriginhostnameModel::search(['preordercampaign_id' => $campaign->id]) as $origin) {
                $this->addAllowedOrigin($origin->hostname);
            }
        }

        $this->allowed_preordertypes = array_unique($this->allowed_preordertypes);
    }

    protected function getNetworks() {
        $return = [];

        $my_network_ids = [];
        $networks = [];


        $fixed_networks = false;
        if(array_key_exists("preorder_networks", $this->me->flags) && $this->me->flags["preorder_networks"]) {
            $pnetworks = json_decode($this->me->flags["preorder_networks"]);
            if(is_array($pnetworks) && count($pnetworks)) {
                $fixed_networks = $pnetworks;
            }

        }

        if($fixed_networks) {
            foreach($fixed_networks as $network_id) {
                $fnetwork = new Network($network_id);
                if($fnetwork->id && $fnetwork->opsystem == "snopp") {
                    $my_network_ids[] = $fnetwork->id;
                    $networks[] = $fnetwork;
                }
            }
        } else {
            foreach($this->me->my_networks as $network) {
                if($network->id && !in_array($network->id, $my_network_ids)) {
                    $my_network_ids[] = $network->id;
                }
            }

            $networks = NetworkModel::search(["opsystem" => "snopp"]);
        }

        foreach($networks as $network) {
            if(!in_array($network->id, $my_network_ids)) continue;

            $name = $network->name;

            if($network->adb_netzgebiet_id) {
                if($network->adb_netzgebiet->source == "citycom-oan-api") {
                    $name = "OC ".$network->adb_netzgebiet->name;
                } else {
                    $cityname = preg_replace('/^Liezen\s+-\s+/', '', $network->adb_netzgebiet->name);
                    $name = "ROC_" . $network->adb_netzgebiet->extref . "_" . $cityname;
                }
            }

            $net = [];
            $net["id"] = $network->id;
            $net["name"] = $name;
            $net["created"]  = $network->create;
            $net["updated"]  = $network->edit;
            $return[] = $net;
        }

        return mfResponse::Ok(["networks" => $return]);
    }

    protected function getPreorderCampaigns() {
        $return = [];

        foreach($this->campaigns as $campaign) {
            if($campaign->from > date('U') || $campaign->to < date('U')) {
                continue;
            }
            $c = [];
            $c["id"] = $campaign->id;
            $c["name"] = $campaign->name;
            $c["created"] = $campaign->create;
            $c["updated"] = $campaign->edit;
            $return[] = $c;
        }

        return mfResponse::Ok(["preordercampaigns" => $return]);
    }

    protected function getBuildingsByCampaign() {
        $buildings = [];

        if(!array_key_exists("campaign_id", $this->get) || !$this->get["campaign_id"]) {
            return mfResponse::BadRequest(["message" => "mandatory parameter campaign_id is missing."]);
        }

        $campaign_id = $this->get["campaign_id"];

        if(!is_numeric($campaign_id) || $campaign_id < 1) {
            return mfResponse::BadRequest(["message" => "Invalid value for campaign_id"]);
        }

        $campaign = new Preordercampaign($campaign_id);
        if(!$campaign) {
            return mfResponse::NotFound(["message" => "Network not found"]);
        }

        if($campaign->from > date('U') || $campaign->to < date('U')) {
            return mfResponse::Ok(["buildings" => []]);
        }

        $adb_netzgebiet_id = $campaign->adb_netzgebiet->id;

        if(!$adb_netzgebiet_id) {
            return mfResponse::NotFound(["message" => "Network not found"]);
        }

        // nur Bestellungen von Aktivnetzbetreiber und seine ISPs
        if(!count($campaign->active_operators)) {
            return mfResponse::Ok(["buildings" => []]);
        }

        $isp_ids = [];

        foreach($campaign->active_operators as $aop) {
            foreach($aop->isps as $op_isp) {
                if(!in_array($op_isp->id, $isp_ids)) {
                    $isp_ids[] = $op_isp->isp_id;
                }
            }
        }

        //var_dump($isp_ids);exit;

        $b = [];

        $woStateNameToId = [];

        $woStateNameToId["Clarify"] = 5;
        $woStateNameToId["Review"] = 7;
        $woStateNameToId["Accepted"] = 8;
        $woStateNameToId["Plan Released"] = 10;
        $woStateNameToId["Assigned"] = 20;
        $woStateNameToId["Executed"] = 30;
        $woStateNameToId["Documented"] = 40;
        $woStateNameToId["Cancelled"] = 99;


        $preorder_search = ["preordercampaign_id" => $campaign_id];
        if(count($isp_ids)) {
            $preorder_search["partner_id"] = $isp_ids;
        }


        foreach(PreorderModel::searchActive($preorder_search) as $preorder) {
            $hausnummer_id = $preorder->adb_hausnummer_id;
            $wohneinheit_id = $preorder->adb_wohneinheit_id;

            if(!$hausnummer_id || !$wohneinheit_id) continue;

            $hausnummer = $preorder->adb_hausnummer;
            $wohneinheit = $preorder->adb_wohneinheit;

            if(!array_key_exists($hausnummer_id, $b)) {
                $b[$hausnummer_id] = [
                    'id' => $preorder->adb_hausnummer_id,
                    'status' => [
                        'code' => $preorder->status->code,
                        'text' => $preorder->status->name
                    ],
                    'oaid' => $hausnummer->oaid,
                    'salescluster_id' => $preorder->preordercampaign_id,
                    'network_id' => $preorder->campaign->network_id,
                    'zip' => $hausnummer->plz->plz,
                    'city' => $hausnummer->strasse->gemeinde->name,
                    "municipality" => "",
                    'district' => $hausnummer->ortschaft->name,
                    'street' => $hausnummer->strasse->name,
                    'housenumber' => $hausnummer->hausnummer,
                    'gps_lat' => ($hausnummer->gps_lat) ? (float)$hausnummer->gps_lat : null,
                    'gps_long' => ($hausnummer->gps_long) ? (float)$hausnummer->gps_long : null,

                    "homes" => []
                ];
                if($this->district_is_city) {
                    $b[$hausnummer_id]['city'] = $hausnummer->ortschaft->name;
                    $b[$hausnummer_id]['municipality'] = $hausnummer->strasse->gemeinde->name;
                } else {
                    unset($b[$hausnummer_id]['municipality']);
                }
            }

            if(!array_key_exists($wohneinheit_id, $b[$hausnummer_id]["homes"])) {
                $home_data = [
                    'id' => $wohneinheit_id,
                    'oaid' => $wohneinheit->oaid,
                    'num' => (int)$wohneinheit->num,
                    'block' => $wohneinheit->block,
                    'stiege' => $wohneinheit->stiege,
                    'stock' => $wohneinheit->stock,
                    'tuer' => $wohneinheit->tuer,
                    'zusatz' => $wohneinheit->zusatz,
                    'patch_cluster' => $wohneinheit->patch_cluster,
                    'patch_shelf' => $wohneinheit->patch_shelf,
                    'patch_module' => $wohneinheit->patch_module,
                    'patch_port' => $wohneinheit->patch_port,
                    'workorder_id' => ($wohneinheit->rimo_workorder) ? $wohneinheit->rimo_workorder->id : null,
                    'workorder_name' => ($wohneinheit->rimo_workorder) ? $wohneinheit->rimo_workorder->rimo_name : null,
                    'workorder_state_id' => ($wohneinheit->rimo_workorder) ? $woStateNameToId[$wohneinheit->rimo_workorder->rimo_status] : null,
                    'workorder_state_label' => ($wohneinheit->rimo_workorder) ? $wohneinheit->rimo_workorder->rimo_status : null,
                ];

                //var_dump($campaign->adb_netzgebiet);

                // add CPE data if Citycom OAN
                if($campaign->adb_netzgebiet->source == "citycom-oan-api") {
                    $home_data["ont_sn"] = "";
                    $home_data["ont_gpid"] = "";
                    $home_data["ont_mac"] = "";
                    $cc_data = PreorderCitycomOan::getFirst(["preorder_id" => $preorder->id]);
                    if($cc_data) {
                        if($cc_data->ont_sn) $home_data["ont_sn"] = $cc_data->ont_sn;
                        if($cc_data->ont_gpid) $home_data["ont_gpid"] = $cc_data->ont_gpid;
                        if($cc_data->ont_mac) $home_data["ont_mac"] = $cc_data->ont_mac;
                    }
                }

                $b[$hausnummer_id]["homes"][] = $home_data;
            }
        }

        $buildings = array_values($b);
        return mfResponse::Ok(["buildings" => $buildings]);

        /*
        $db = $this->db(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);

        $sql = AddressDB::$wohneinheit_query;
        $sql .= " WHERE Hausnummer.netzgebiet_id=$adb_netzgebiet_id AND Hausnummer.visibility = 'public'";

        $res = $db->query($sql);
        if(!$db->num_rows($res)) {
            return mfResponse::Ok(["buildings" => []]);
        }

        $b = [];

        while($data = $db->fetch_object($res)) {
            if(!array_key_exists($data->hausnummer_id, $b)) {
                $housenumber = $data->hausnummer;
                if($this->hausnummer_add_zusatz) {
                    if($data->zusatz) {
                        $housenumber .= " (".$data->zusatz.")";
                    }
                }

                $b[$data->hausnummer_id] = [
                    'id' => $data->hausnummer_id,
                    'oaid' => $data->hausnummer_oaid,
                    'cluster_id' => $data->netzgebiet_extref,
                    'zip' => $data->plz,
                    'city' => $data->gemeinde,
                    "municipality" => "",
                    'district' => $data->ortschaft,
                    'street' => $data->strasse,
                    'housenumber' => $housenumber,
                    'gps_lat' => ($data->gps_lat) ? (float)$data->gps_lat : null,
                    'gps_long' => ($data->gps_long) ? (float)$data->gps_long : null,

                    "homes" => []
                ];

                if($this->district_is_city) {
                    $b[$data->hausnummer_id]['city'] = $data->ortschaft;
                    $b[$data->hausnummer_id]['municipality'] = $data->gemeinde;
                } else {
                    unset($b[$data->hausnummer_id]['municipality']);
                }
            }

            $b[$data->hausnummer_id]["homes"][] = [
                'id' => $data->wohneinheit_id,
                'oaid' => $data->wohneinheit_oaid,
                'num' => (int)$data->num,
                'block' => $data->block,
                'stiege' => $data->stiege,
                'stock' => $data->stock,
                'tuer' => $data->tuer,
                'zusatz' => $data->zusatz,
            ];
            
            
        }

        /*
        foreach($b as $tmp_b) {
            $homes = array_values($tmp_b["homes"]);
            return mfResponse::Ok(["Homes" => $homes]);
            unset($tmp_b["homes"]);
            $tmp_b["homes"] = array_values($homes);
            $buildings[] = $tmp_b;

        }

        $buildings = array_values($b);
        */


    }
}