diff --git a/Layout/default/AddressDB/export.csv.php b/Layout/default/AddressDB/export.csv.php index a7aca833e..a5a8668f1 100644 --- a/Layout/default/AddressDB/export.csv.php +++ b/Layout/default/AddressDB/export.csv.php @@ -1,9 +1,17 @@ -AddressDB_ID;Extref;Adrcd;OAID;Status Code; Status Name;Netzgebiet_Extref;Netzgebiet;GKZ;Gemeinde;OKZ;Ortschaft;PLZ;SKZ;Strasse;Hausnummer;Grundstueck;GPS Breite; GPS Laenge;Rollout;Rollout_Info;Freigabe;Nutzungseinheiten;GDA-Eigenschaft;Meridian;RW;HW +AddressDB_ID;Extref;Adrcd;OAID;Status Code; Status Name;Netzgebiet_Extref;Netzgebiet;Rimo Building External ID;GKZ;Gemeinde;OKZ;Ortschaft;PLZ;SKZ;Strasse;Hausnummer;Grundstueck;GPS Breite; GPS Laenge;Rollout;Rollout_Info;Freigabe;Nutzungseinheiten;GDA-Eigenschaft;Meridian;RW;HW;Sichtbarkeit unit_count; ?> -id?>;"extref?>";adrcd?>;"oaid?>";"code?>";"name?>";"extref?>";"name?>";kennziffer?>;"name?>";kennziffer?>;"name?>";"plz?>";kennziffer?>;"name?>";"hausnummer?>";"grund_nr?>";gps_lat?>;gps_long?>;rollout?>;"rollout_info?>";"";;"gdaeigenschaft?>";"meridian?>";rw?>;hw?> +id?>;"extref?>";adrcd?>;"oaid?>";"code?>";"name?>";"extref?>";"name?>";"rimo_id?>";kennziffer?>;"name?>";kennziffer?>;"name?>";"plz?>";kennziffer?>;"name?>";"hausnummer?>";"grund_nr?>";gps_lat?>;gps_long?>;rollout?>;"rollout_info?>";"";;"gdaeigenschaft?>";"meridian?>";rw?>;hw?>;visibility?> -Kampagne;Netzgebiet ID;Netzgebiet;Extref;Bestellcode;OAID;Bestelldatum;Bestelltyp;Status Code; Status Name;Anschlusstyp;GWR Adresscode;Meridian;RW;HW;Anschluss Strasse;Anschluss Hausnummer;Anschluss PLZ;Anschluss Ort;Anschluss Wohneinheit;GPS Breite;GPS Länge;Anzahl Anschlüsse;Kunde Firma;Kunde UID;Kunde Vorname;Kunde Nachname;Kunde Strasse;Kunde PLZ;Kunde Ort;Kunde Telefon;Kunde Email;Partner;CIF Token;Cif Url; Cif Cable Url;Addon Lehrverrohrung Grundstück;Addon Hausverkabelung;BEP festgelegt;Starterpaket erhalten;Erstellt;Letzte Bearbeitung +Kampagne;Netzgebiet ID;Netzgebiet;Extref;Bestellcode;Gutscheincodes;OAID;Bestelldatum;Bestelltyp;Status Code; Status Name;Anschlusstyp;GWR Adresscode;Meridian;RW;HW;Anschluss Strasse;Anschluss Hausnummer;Anschluss PLZ;Anschluss Ort;Anschluss Wohneinheit;GPS Breite;GPS Länge;Anzahl Anschlüsse;Kunde Firma;Kunde UID;Kunde Vorname;Kunde Nachname;Kunde Strasse;Kunde PLZ;Kunde Ort;Kunde Telefon;Kunde Email;Partner;CIF Token;Cif Url; Cif Cable Url;Addon Lehrverrohrung Grundstück;Addon Hausverkabelung;BEP festgelegt;Starterpaket erhalten;Erstellt;Letzte Bearbeitung ortschaft_id); $plz = Layout::getMfValuecacheObject("ADBPlz", $hausnummer->plz_id); $partner = Layout::getMfValuecacheObject("Address", $data->partner_id); - + $preorder = Layout::getMfValuecacheObject("Preorder", $data->id); + + $discounts = []; + if(is_array($preorder->discounts) && count($preorder->discounts)) { + foreach($preorder->discounts as $discount) { + $discounts[] = $discount->code; + } + } + + $adrcd = $hausnummer->adrcd; + if($hausnummer->subcd) { + $adrcd .= "-".$hausnummer->subcd; + } + $unit_data = ""; if($wohneinheit->block) $unit_data .= "Block ".$wohneinheit->block; if($wohneinheit->stiege) $unit_data .= "Stiege ".$wohneinheit->stiege; @@ -59,7 +76,7 @@ while($data = mysqli_fetch_object($res)): if($data->uid == "string") $data->uid = ""; ?> -"name?>";"extref?>";"name?>";"extref?>";"ucode?>";"oaid?>";"order_date) ? date("d.m.Y",$data->order_date) : ""?>";"type,"preorder")?>";"code?>";"name?>";"connection_type,"preorder")?>";"adrcd?>";"meridian?>";"rw?>";"hw?>";"name?>";"hausnummer?>";"plz?>";"name?>";"";"gps_lat?>";"gps_long?>";connection_count?>;"company?>";"uid?>";"firstname?>";"lastname?>";"street?>";"zip?>";"city?>";"phone?>";"email?>";"getCompanyOrName()?>";"ciftoken?>";"cifurl?>";"cifcableurl?>";;;;;"create)?>";"edit)?>" +"name?>";"extref?>";"name?>";"extref?>";"ucode?>";"";"oaid?>";"order_date) ? date("d.m.Y",$data->order_date) : ""?>";"type,"preorder")?>";"code?>";"name?>";"connection_type,"preorder")?>";"";"meridian?>";"rw?>";"hw?>";"name?>";"hausnummer?>";"plz?>";"name?>";"";"gps_lat?>";"gps_long?>";connection_count?>;"company?>";"uid?>";"firstname?>";"lastname?>";"street?>";"zip?>";"city?>";"phone?>";"email?>";"getCompanyOrName()?>";"ciftoken?>";"cifurl?>";"cifcableurl?>";;;;;"create)?>";"edit)?>" db(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME); - - $this->addRoute("/addressdb/getClusters", "getClusters", "GET"); - $this->addRoute("/addressdb/findAddress", "find", "GET"); - $this->addRoute("/addressdb/findAddress", "find", "POST"); - $this->addRoute("/addressdb/searchAddress", "search", "GET"); - $this->addRoute("/addressdb/searchAddress", "search", "POST"); - $this->addRoute("/addressdb/findStreet", "findStreet", "GET"); - $this->addRoute("/addressdb/findStreet", "findStreet", "POST"); - $this->addRoute("/addressdb/findZip", "findZip", "GET"); - $this->addRoute("/addressdb/findZip", "findZip", "POST"); - $this->addRoute("/addressdb/findCity", "findCity", "GET"); - $this->addRoute("/addressdb/findCity", "findCity", "POST"); - $this->addRoute("/addressdb/findDistrict", "findDistrict", "GET"); - $this->addRoute("/addressdb/findDistrict", "findDistrict", "POST"); - - $this->allowMissingOrigin = true; - } - - protected function authenticated() { - - if($this->me->is("preorderaddressreporting")) { - $preorder_networks = json_decode($this->me->getFlag("preorder_networks")); - - if(!is_array($preorder_networks) || !count($preorder_networks)) { - return mfResponse::Forbidden(); - } - //$this->filter_salescluster_ids = $preorder_networks; - - foreach($preorder_networks as $network_id) { - $network = new Network($network_id); - $adb_netzgebiet_id = $network->adb_netzgebiet_id; - foreach(PreordercampaignSalesclusterModel::search(["salescluster_id" => $adb_netzgebiet_id]) as $campaign_scluster) { - if(!in_array($campaign_scluster->salescluster_id, $this->filter_salescluster_ids)) { - $this->filter_salescluster_ids[] = $campaign_scluster->salescluster_id; - } - $campaign = new Preordercampaign($campaign_scluster->preordercampaign_id); - if(!$campaign->id) continue; - $this->campaigns_by_scluster[$adb_netzgebiet_id] = $campaign_scluster->preordercampaign_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; + private $campaigns = []; + private $filter_salescluster_ids = []; + private $campaigns_by_scluster = []; + private $allowed_preordertypes = []; + private $district_is_city = false; + private $hausnummer_add_zusatz = false; + + protected function init() { + $db = $this->db(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME); + + $this->addRoute("/addressdb/getClusters", "getClusters", "GET"); + $this->addRoute("/addressdb/findAddress", "find", "GET"); + $this->addRoute("/addressdb/findAddress", "find", "POST"); + $this->addRoute("/addressdb/searchAddress", "search", "GET"); + $this->addRoute("/addressdb/searchAddress", "search", "POST"); + $this->addRoute("/addressdb/findStreet", "findStreet", "GET"); + $this->addRoute("/addressdb/findStreet", "findStreet", "POST"); + $this->addRoute("/addressdb/findZip", "findZip", "GET"); + $this->addRoute("/addressdb/findZip", "findZip", "POST"); + $this->addRoute("/addressdb/findCity", "findCity", "GET"); + $this->addRoute("/addressdb/findCity", "findCity", "POST"); + $this->addRoute("/addressdb/findDistrict", "findDistrict", "GET"); + $this->addRoute("/addressdb/findDistrict", "findDistrict", "POST"); + $this->addRoute("/addressdb/fullexport", "exportAddresses", "GET"); + + $this->allowMissingOrigin = true; + } + + protected function authenticated() { + + if($this->me->is("preorderaddressreporting")) { + $preorder_networks = json_decode($this->me->getFlag("preorder_networks")); + + if(!is_array($preorder_networks) || !count($preorder_networks)) { + return mfResponse::Forbidden(); } - } - - if($campaign->district_is_city == 1) { - $this->district_is_city = true; - } - - if($campaign->hausnummer_add_zusatz == 1) { - $this->hausnummer_add_zusatz = true; - } - - foreach(PreordercampaignOriginhostnameModel::search(['preordercampaign_id' => $campaign->id]) as $origin) { - $this->addAllowedOrigin($origin->hostname); - } - - } - } - - } else { - - $campaignApiusers = PreordercampaignApiuserModel::search(["worker_id" => $this->me->id]); + //$this->filter_salescluster_ids = $preorder_networks; - if(!$campaignApiusers) { - $cau = new PreordercampaignApiuser(); - $cau->preordercampaign_id = 1; - $campaignApiusers = [$cau]; - } + foreach($preorder_networks as $network_id) { + $network = new Network($network_id); + $adb_netzgebiet_id = $network->adb_netzgebiet_id; + foreach(PreordercampaignSalesclusterModel::search(["salescluster_id" => $adb_netzgebiet_id]) as $campaign_scluster) { + if(!in_array($campaign_scluster->salescluster_id, $this->filter_salescluster_ids)) { + $this->filter_salescluster_ids[] = $campaign_scluster->salescluster_id; + } + $campaign = new Preordercampaign($campaign_scluster->preordercampaign_id); + if(!$campaign->id) continue; + $this->campaigns_by_scluster[$adb_netzgebiet_id] = $campaign_scluster->preordercampaign_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; + } + } - foreach($campaignApiusers as $campaignApiuser) { - $campaign = new Preordercampaign($campaignApiuser->preordercampaign_id); - if($campaign) { - foreach(PreordercampaignSalesclusterModel::search(['preordercampaign_id' => $campaign->id]) as $campaign_scluster) { - if(!in_array($campaign_scluster->salescluster_id, $this->filter_salescluster_ids)) { - $this->filter_salescluster_ids[] = $campaign_scluster->salescluster_id; - } + if($campaign->district_is_city == 1) { + $this->district_is_city = true; + } - $this->campaigns_by_scluster[$campaign_scluster->salescluster_id] = $campaign->id; + if($campaign->hausnummer_add_zusatz == 1) { + $this->hausnummer_add_zusatz = true; + } - } - $this->campaigns[$campaign->id] = $campaign; + foreach(PreordercampaignOriginhostnameModel::search(['preordercampaign_id' => $campaign->id]) as $origin) { + $this->addAllowedOrigin($origin->hostname); + } - // 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; - } - } - - foreach(PreordercampaignOriginhostnameModel::search(['preordercampaign_id' => $campaign->id]) as $origin) { - $this->addAllowedOrigin($origin->hostname); - } - } - - //var_dump($this->allowed_preordertypes);exit; - //var_dump($this->filter_salescluster_ids, $this->campaigns_by_scluster);exit; - //var_dump($this->campaigns, $this->allowed_origins);exit; - } - - $this->allowed_preordertypes = array_unique($this->allowed_preordertypes); - - } - - protected function getClusters() { - $cluster_search = []; - if(count($this->filter_salescluster_ids)) { - $cluster_search['netzgebiet_id'] = $this->filter_salescluster_ids; - } - $clusters = []; - foreach(ADBNetzgebietModel::search($cluster_search) as $cluster) { - $c = []; - $c['id'] = $cluster->extref; - $c['name'] = $cluster->name; - $clusters[] = $c; - } - - return mfResponse::Ok(["clusters" => $clusters]); - - } - - protected function findCity() { - // unofficially supporting GET and POST in v1 - $get = array_merge($this->post, $this->get); - - // search parameter is unofficially deprecated but still supported - $search = trim($get['search']); - $city = trim($get['city']); - $district = trim($get['district']); - $zip = trim($get['zip']); - $search_cluster_id = trim($get['cluster_id']); - - if(!$city) { - $city = $search; - } - - if(!$city && !$zip && !$search_cluster_id) { - return mfResponse::BadRequest(['message' => "No search parameters"]); - } - - $city_search = ['name%' => $city]; - if($zip) { - $city_search['plz%'] = $zip; - } - if($district) { - $district_search['ortschaft%'] = $zip; - } - - if(count($this->filter_salescluster_ids)) { - $city_search['netzgebiet_id'] = $this->filter_salescluster_ids; - } - - if($search_cluster_id) { - $city_search['netzgebiet_extref'] = $search_cluster_id; - } - - if($this->district_is_city) { - $results = ADBOrtschaftModel::search($city_search); - } else { - $results = ADBGemeindeModel::search($city_search); - } - - - $cities = []; - foreach($results as $result) { - $cities[] = $result->name; - } - - $cities = array_unique($cities); - return mfResponse::Ok(['cities' => array_values($cities)]); - } - - protected function findDistrict() { - // unofficially supporting GET and POST in v1 - $get = array_merge($this->post, $this->get); - - // search parameter is unofficially deprecated but still supported - $search = $this->db()->escape(trim($get['search'])); - $city = $this->db()->escape(trim($get['city'])); - $district = $this->db()->escape(trim($get['district'])); - $zip = $this->db()->escape(trim($get['zip'])); - $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); - - if(!$district) { - $district = $search; - } - /* - if(!$city && !$zip && !$district) { - return mfResponse::BadRequest(['message' => "No search parameters"]); - }*/ - - $where = "1=1"; - - if($district && $district != "%") { - $where .= " AND ortschaft like '$district%'"; - } - if($city && $city != "%") { - $where .= " AND gemeinde like '$city%'"; - } - if($zip && $zip != "%") { - $where .= " AND plz like '$zip%'"; - } - - if(count($this->filter_salescluster_ids)) { - $where .= " AND netzgebiet_id IN (".join(", ", $this->filter_salescluster_ids).")"; - } - - if($search_cluster_id) { - $where .= " AND netzgebiet_extref='$search_cluster_id'"; - } - - $cities = []; - - $sql = "SELECT gemeinde, ortschaft FROM view_hausnummer WHERE $where GROUP BY gemeinde,ortschaft_id ORDER BY gemeinde, ortschaft"; - //echo $sql;exit; - $res = $this->db()->query($sql); - if($this->db()->num_rows($res)) { - while($data = $this->db()->fetch_object($res)) { - if(!array_key_exists($data->gemeinde, $cities)) { - $cities[$data->gemeinde] = []; - } - $cities[$data->gemeinde][] = $data->ortschaft; - } - } - - return mfResponse::Ok(['cities' => $cities]); - } - - protected function findZip() { - // unofficially supporting GET and POST in v1 - $get = array_merge($this->post, $this->get); - - // search parameter is unofficially deprecated but still supported - $search = trim($get['search']); - $zip = trim($get['zip']); - $search_cluster_id = trim($get['cluster_id']); - - if(!$search && !$zip && !$search_cluster_id) { - return mfResponse::BadRequest(['message' => "Searchstring cannot be empty!"]); - } - - if(!$zip) { - $zip = $search; - } - - $zip_search = ['plzstring%' => $zip]; - //var_dump($this->filter_salescluster_ids);exit; - if(count($this->filter_salescluster_ids)) { - $zip_search['netzgebiet_id'] = $this->filter_salescluster_ids; - } - - if($search_cluster_id) { - $zip_search['netzgebiet_extref'] = $search_cluster_id; - } - - //var_dump($zip_search);exit; - $results = ADBPlzModel::search($zip_search); - - - $zips = []; - foreach($results as $result) { - $zips[] = $result->plz; - } - - $zips = array_unique($zips); - return mfResponse::Ok(['zips' => array_values($zips)]); - } - - protected function findStreet() { - // unofficially supporting GET and POST in v1 - $get = array_merge($this->post, $this->get); - - // search parameter is unofficially deprecated but still supported - $search = $this->db()->escape(trim($get['search'])); - $street = $this->db()->escape(trim($get['street'])); - $city = $this->db()->escape(trim($get['city'])); - $zip = $this->db()->escape(trim($get['zip'])); - $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); - - if(!$search && !$street && !$city && !$zip && !$search_cluster_id) { - return mfResponse::BadRequest(['message' => "No search parameters"]); - } - - if(!$street) { - $street = $search; - } - - $where = "1=1"; - $where .= " AND strasse like '$street%'"; - if($city) { - if($this->district_is_city) { - $where .= " AND ortschaft like '$city%'"; - } else { - $where .= " AND gemeinde like '$city%'"; - } - } - if($zip) { - $where .= " AND plz like '$zip%'"; - } - - if(count($this->filter_salescluster_ids)) { - $where .= " AND netzgebiet_id IN (".join(", ", $this->filter_salescluster_ids).")"; - } - - if($search_cluster_id) { - $where .= " AND netzgebiet_extref='$search_cluster_id'"; - } - - $streets = []; - - $sql = "SELECT strasse FROM view_hausnummer WHERE $where GROUP BY strasse ORDER BY strasse"; - //echo "$sql";exit; - $res = $this->db()->query($sql); - if($this->db()->num_rows($res)) { - while($data = $this->db()->fetch_object($res)) { - $streets[] = $data->strasse; - } - - } - - $streets = array_unique($streets); - sort($streets); - return mfResponse::Ok(['streets' => array_values($streets)]); - } - - protected function search() { - $get = array_merge($this->post, $this->get); - - $search = $this->db()->escape(trim($get['search'])); - - $format = "flat"; - if($get['format'] == "tree") { - $format = "tree"; - } - - if(!$search) { - return mfResponse::BadRequest(['message' => "Search string cannot be empty"]); - } - if($search == "%") { - return mfResponse::BadRequest(['message' => "Search string cannot be empty"]); - } - - /* - * do normal search - */ - $search_parts = []; - $search = str_replace(",", "", $search); - $tmp_search_parts = explode(" ", $search); - $ort_search = $strasse_search = $plz_search = $hausnummer_search = []; - - foreach($tmp_search_parts as $p) { - $p = $this->db()->escape(trim($p)); - if(!$p) continue; - if(in_array($p,$search_parts)) continue; - $search_parts[] = $p; - $gem_search[] = "Gemeinde.name like '$p%'"; - $ort_search[] = "Ortschaft.name like '$p%'"; - $strasse_search[] = "Strasse.name like '$p%'"; - $plz_search[] = "Plz.plz like '$p%'"; - $hausnummer_search[] = "Hausnummer.hausnummer like '$p%'"; - } - - $where = "1=1"; - if(count($this->filter_salescluster_ids)) { - $where .= " AND netzgebiet_id IN (".implode(",", $this->filter_salescluster_ids).")"; - } - $where .= " AND Hausnummer.visibility='public'"; - - $sql = AddressDB::$wohneinheit_query; - $sql .= "\n WHERE $where AND ((".implode(" OR ", $ort_search).") OR (".implode(" OR ", $strasse_search).") OR (".implode(" OR ", $plz_search).") OR (".implode(" OR ", $hausnummer_search).")) ORDER BY strasse, LENGTH(hausnummer), hausnummer, LENGTH(`Wohneinheit`.tuer),`Wohneinheit`.tuer, zusatz, LENGTH(num), num"; - - //$sql = "SELECT * FROM view_wohneinheit WHERE $where AND ((".implode(" OR ", $ort_search).") OR (".implode(" OR ", $strasse_search).") OR (".implode(" OR ", $plz_search).") OR (".implode(" OR ", $hausnummer_search).")) ORDER BY strasse, LENGTH(hausnummer), hausnummer, LENGTH(tuer),tuer, zusatz, LENGTH(num), num"; - $this->log->debug($sql); - - $res = $this->db()->query($sql); - - - - if($this->db()->num_rows($res)) { - $tmp_addresses = []; - while($data = $this->db()->fetch_object($res)) { - $address_key = $data->hausnummer_id; - if($this->hausnummer_add_zusatz) { - $address_key = $data->hausnummer_id."-".$data->zusatz; - } - //$sort_key = $data->plz." ".$data->gemeinde." ".$data->ortschaft." ".$data->strasse." ".$data->hausnummer." ".$data->zusatz; - $sort_key = $data->plz." ".$data->gemeinde." ".$data->ortschaft." ".$data->strasse." ".$data->hausnummer." ".$data->zusatz; - if(!array_key_exists($address_key, $tmp_addresses)) { - - // get allowed preorderTypes - $ptypes = []; - if($data->freigabe) { - $freigaben = json_decode($data->freigabe); - if(is_array($freigaben) && count($freigaben)) { - foreach($freigaben as $freigabe) { - if(in_array($freigabe, $this->allowed_preordertypes)) { - $ptypes[] = $freigabe; - } } - } - - // if FCP is on blacklist, don't allow any order types - $campaign = $this->campaigns[$this->campaigns_by_scluster[$data->netzgebiet_id]]; - if(!$campaign) { - $this->log->error("Campaign not found for netzgebiet_id ".$data->netzgebiet_id); - } else { - if($data->rimo_fcp_name && is_array($campaign->banned_fcps) && count($campaign->banned_fcps) && in_array($data->rimo_fcp_name, $campaign->banned_fcps)) { - $ptypes = []; - } - } } - $housenumber = $data->hausnummer; - if($this->hausnummer_add_zusatz) { - if($data->zusatz) { - $housenumber .= " (".$data->zusatz.")"; - } - } - - $tmp_addresses[$address_key] = [ - 'sort_key' => $sort_key, - 'oaid' => $data->hausnummer_oaid, - 'cluster_id' => $data->netzgebiet_extref, - 'zip' => $data->plz, - 'city' => $data->gemeinde, - "municipality" => "", - 'district' => $data->ortschaft, - 'street' => $data->strasse, - 'housenumber' => $housenumber, - 'stiege' => $data->hausnummer_stiege, - 'lot_number' => $data->grund_nr, - 'meridian' => $data->meridian, - 'rw' => $data->rw, - 'hw' => $data->hw, - 'building_unit_count' => 0, - 'gps_lat' => ($data->gps_lat) ? (float)$data->gps_lat : null, - 'gps_long' => ($data->gps_long) ? (float)$data->gps_long : null, - 'rollout_year' => ($data->rollout) ? (int)$data->rollout : null, - 'rollout_info' => $data->rollout_info, - 'preorderTypes' => $ptypes, - 'units' => [] - ]; - if($this->district_is_city) { - $tmp_addresses[$address_key]['city'] = $data->ortschaft; - $tmp_addresses[$address_key]['municipality'] = $data->gemeinde; - } else { - unset($tmp_addresses[$address_key]['municipality']); - } - } - - $unit_data = [ - 'oaid' => $data->wohneinheit_oaid, - 'num' => (int)$data->num, - 'block' => $data->block, - 'stock' => $data->stock, - 'tuer' => $data->tuer, - 'zusatz' => $data->zusatz, - ]; - - if($this->me->is("preorderaddressreporting")) { - if($data->partner_company) { - $unit_data["ordered"] = true; - $unit_data["orderType"] = $data->order_type; - $unit_data["ispName"] = $data->partner_company; - } else { - $unit_data["ordered"] = false; - $unit_data["orderType"] = null; - $unit_data["ispName"] = null; - } - } - - $tmp_addresses[$address_key]['units'][] = $unit_data; - $tmp_addresses[$address_key]['building_unit_count']++; - //if($data->hausnummer_oaid == "AT-8940-30400d5c") var_dump($data); - } - //exit; - //var_dump($tmp_addresses);exit; - // sort found addresses by count of found keywords - // if there is an int we don't want to show more than one street - $sorted_addresses = []; - foreach($tmp_addresses as $temp_add) { - $includes_int = false; - $count = 0; - $count_parts = 0; - $uniq_parts_count = 0; - $uniq_parts_found = []; - /*if($temp_add['oaid'] == "AT-8940-30400d5c") { - var_dump($temp_add); - }*/ - foreach($search_parts as $p) { - $p = $this->db->escape(trim($p)); - if(strlen($p) === 0) continue; - $uniq_parts_count++; - if(is_numeric(($p))) { - $includes_int = true; - $count_parts++; - if(substr_count(strtolower($temp_add['sort_key']), strtolower($p))) { - $count++; - } - if(!in_array($p, $uniq_parts_found)) { - $uniq_parts_found[] = $p; - } - } else { - $p_count = substr_count(strtolower($temp_add['sort_key']), strtolower($p)); - if($p_count) { - $count += $p_count; - $count_parts++; - if(!in_array($p, $uniq_parts_found)) { - $uniq_parts_found[] = $p; - } - } - } - } - - unset($temp_add['sort_key']); - if($includes_int && (($count + 1) - count($search_parts) ) < 1) { - continue; - } - - //var_dump(count($search_parts), $count, $count_parts, $temp_add); - - /*if($temp_add['oaid'] == "AT-8954-d6c41665") { - echo $temp_add['sort_key'].": AT-8954-d6c41665: count $count; uniq_parts_count $uniq_parts_count; count_parts $count_parts; search_parts ".count($search_parts)."

\n"; - //var_dump(); - //exit; - }*/ - - if($count_parts == count($search_parts)) { - $count += 50; - } - - if($uniq_parts_count <= count($uniq_parts_found)) { - if(!array_key_exists($count, $sorted_addresses)) { - $sorted_addresses[$count] = []; - } - $sorted_addresses[$count][] = $temp_add; - } - } - //exit; - - - ksort($sorted_addresses, SORT_NUMERIC); - $sorted_addresses = array_reverse($sorted_addresses, true); - //var_dump($sorted_addresses);exit; - - // sort / format - if($format == "tree") { - foreach($sorted_addresses as $counted_addresses) { - foreach($counted_addresses as $cadd) { - $addresses[] = $cadd; - } - } - //var_dump($addresses);exit; - //$addresses = array_values($sorted_addresses); - - if(!$addresses) $addresses = []; } else { - foreach($sorted_addresses as $counted_addresses) { - foreach($counted_addresses as $ta) { - foreach($ta['units'] as $u) { - $new_address = []; + + $campaignApiusers = PreordercampaignApiuserModel::search(["worker_id" => $this->me->id]); + + if(!$campaignApiusers) { + $cau = new PreordercampaignApiuser(); + $cau->preordercampaign_id = 1; + $campaignApiusers = [$cau]; + } + + + foreach($campaignApiusers as $campaignApiuser) { + $campaign = new Preordercampaign($campaignApiuser->preordercampaign_id); + if($campaign) { + foreach(PreordercampaignSalesclusterModel::search(['preordercampaign_id' => $campaign->id]) as $campaign_scluster) { + if(!in_array($campaign_scluster->salescluster_id, $this->filter_salescluster_ids)) { + $this->filter_salescluster_ids[] = $campaign_scluster->salescluster_id; + } + + $this->campaigns_by_scluster[$campaign_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; + } + } + + foreach(PreordercampaignOriginhostnameModel::search(['preordercampaign_id' => $campaign->id]) as $origin) { + $this->addAllowedOrigin($origin->hostname); + } + } + + //var_dump($this->allowed_preordertypes);exit; + //var_dump($this->filter_salescluster_ids, $this->campaigns_by_scluster);exit; + //var_dump($this->campaigns, $this->allowed_origins);exit; + } + + $this->allowed_preordertypes = array_unique($this->allowed_preordertypes); + + } + + protected function getClusters() { + $cluster_search = []; + if(count($this->filter_salescluster_ids)) { + $cluster_search['netzgebiet_id'] = $this->filter_salescluster_ids; + } + $clusters = []; + foreach(ADBNetzgebietModel::search($cluster_search) as $cluster) { + $c = []; + $c['id'] = $cluster->extref; + $c['name'] = $cluster->name; + $clusters[] = $c; + } + + return mfResponse::Ok(["clusters" => $clusters]); + + } + + protected function findCity() { + // unofficially supporting GET and POST in v1 + $get = array_merge($this->post, $this->get); + + // search parameter is unofficially deprecated but still supported + $search = trim($get['search']); + $city = trim($get['city']); + $district = trim($get['district']); + $zip = trim($get['zip']); + $search_cluster_id = trim($get['cluster_id']); + + if(!$city) { + $city = $search; + } + + if(!$city && !$zip && !$search_cluster_id) { + return mfResponse::BadRequest(['message' => "No search parameters"]); + } + + $city_search = ['name%' => $city]; + if($zip) { + $city_search['plz%'] = $zip; + } + if($district) { + $district_search['ortschaft%'] = $zip; + } + + if(count($this->filter_salescluster_ids)) { + $city_search['netzgebiet_id'] = $this->filter_salescluster_ids; + } + + if($search_cluster_id) { + $city_search['netzgebiet_extref'] = $search_cluster_id; + } + + if($this->district_is_city) { + $results = ADBOrtschaftModel::search($city_search); + } else { + $results = ADBGemeindeModel::search($city_search); + } + + + $cities = []; + foreach($results as $result) { + $cities[] = $result->name; + } + + $cities = array_unique($cities); + return mfResponse::Ok(['cities' => array_values($cities)]); + } + + protected function findDistrict() { + // unofficially supporting GET and POST in v1 + $get = array_merge($this->post, $this->get); + + // search parameter is unofficially deprecated but still supported + $search = $this->db()->escape(trim($get['search'])); + $city = $this->db()->escape(trim($get['city'])); + $district = $this->db()->escape(trim($get['district'])); + $zip = $this->db()->escape(trim($get['zip'])); + $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); + + if(!$district) { + $district = $search; + } + /* + if(!$city && !$zip && !$district) { + return mfResponse::BadRequest(['message' => "No search parameters"]); + }*/ + + $where = "1=1"; + + if($district && $district != "%") { + $where .= " AND ortschaft like '$district%'"; + } + if($city && $city != "%") { + $where .= " AND gemeinde like '$city%'"; + } + if($zip && $zip != "%") { + $where .= " AND plz like '$zip%'"; + } + + if(count($this->filter_salescluster_ids)) { + $where .= " AND netzgebiet_id IN (" . join(", ", $this->filter_salescluster_ids) . ")"; + } + + if($search_cluster_id) { + $where .= " AND netzgebiet_extref='$search_cluster_id'"; + } + + $cities = []; + + $sql = "SELECT gemeinde, ortschaft FROM view_hausnummer WHERE $where GROUP BY gemeinde,ortschaft_id ORDER BY gemeinde, ortschaft"; + //echo $sql;exit; + $res = $this->db()->query($sql); + if($this->db()->num_rows($res)) { + while($data = $this->db()->fetch_object($res)) { + if(!array_key_exists($data->gemeinde, $cities)) { + $cities[$data->gemeinde] = []; + } + $cities[$data->gemeinde][] = $data->ortschaft; + } + } + + return mfResponse::Ok(['cities' => $cities]); + } + + protected function findZip() { + // unofficially supporting GET and POST in v1 + $get = array_merge($this->post, $this->get); + + // search parameter is unofficially deprecated but still supported + $search = trim($get['search']); + $zip = trim($get['zip']); + $search_cluster_id = trim($get['cluster_id']); + + if(!$search && !$zip && !$search_cluster_id) { + return mfResponse::BadRequest(['message' => "Searchstring cannot be empty!"]); + } + + if(!$zip) { + $zip = $search; + } + + $zip_search = ['plzstring%' => $zip]; + //var_dump($this->filter_salescluster_ids);exit; + if(count($this->filter_salescluster_ids)) { + $zip_search['netzgebiet_id'] = $this->filter_salescluster_ids; + } + + if($search_cluster_id) { + $zip_search['netzgebiet_extref'] = $search_cluster_id; + } + + //var_dump($zip_search);exit; + $results = ADBPlzModel::search($zip_search); + + + $zips = []; + foreach($results as $result) { + $zips[] = $result->plz; + } + + $zips = array_unique($zips); + return mfResponse::Ok(['zips' => array_values($zips)]); + } + + protected function findStreet() { + // unofficially supporting GET and POST in v1 + $get = array_merge($this->post, $this->get); + + // search parameter is unofficially deprecated but still supported + $search = $this->db()->escape(trim($get['search'])); + $street = $this->db()->escape(trim($get['street'])); + $city = $this->db()->escape(trim($get['city'])); + $zip = $this->db()->escape(trim($get['zip'])); + $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); + + if(!$search && !$street && !$city && !$zip && !$search_cluster_id) { + return mfResponse::BadRequest(['message' => "No search parameters"]); + } + + if(!$street) { + $street = $search; + } + + $where = "1=1"; + $where .= " AND strasse like '$street%'"; + if($city) { + if($this->district_is_city) { + $where .= " AND ortschaft like '$city%'"; + } else { + $where .= " AND gemeinde like '$city%'"; + } + } + if($zip) { + $where .= " AND plz like '$zip%'"; + } + + if(count($this->filter_salescluster_ids)) { + $where .= " AND netzgebiet_id IN (" . join(", ", $this->filter_salescluster_ids) . ")"; + } + + if($search_cluster_id) { + $where .= " AND netzgebiet_extref='$search_cluster_id'"; + } + + $streets = []; + + $sql = "SELECT strasse FROM view_hausnummer WHERE $where GROUP BY strasse ORDER BY strasse"; + //echo "$sql";exit; + $res = $this->db()->query($sql); + if($this->db()->num_rows($res)) { + while($data = $this->db()->fetch_object($res)) { + $streets[] = $data->strasse; + } + + } + + $streets = array_unique($streets); + sort($streets); + return mfResponse::Ok(['streets' => array_values($streets)]); + } + + protected function search() { + $get = array_merge($this->post, $this->get); + + $search = $this->db()->escape(trim($get['search'])); + + $format = "flat"; + if($get['format'] == "tree") { + $format = "tree"; + } + + if(!$search) { + return mfResponse::BadRequest(['message' => "Search string cannot be empty"]); + } + if($search == "%") { + return mfResponse::BadRequest(['message' => "Search string cannot be empty"]); + } + + /* + * do normal search + */ + $search_parts = []; + $search = str_replace(",", "", $search); + $tmp_search_parts = explode(" ", $search); + $ort_search = $strasse_search = $plz_search = $hausnummer_search = []; + + foreach($tmp_search_parts as $p) { + $p = $this->db()->escape(trim($p)); + if(!$p) continue; + if(in_array($p, $search_parts)) continue; + $search_parts[] = $p; + $gem_search[] = "Gemeinde.name like '$p%'"; + $ort_search[] = "Ortschaft.name like '$p%'"; + $strasse_search[] = "Strasse.name like '$p%'"; + $plz_search[] = "Plz.plz like '$p%'"; + $hausnummer_search[] = "Hausnummer.hausnummer like '$p%'"; + } + + $where = "1=1"; + if(count($this->filter_salescluster_ids)) { + $where .= " AND netzgebiet_id IN (" . implode(",", $this->filter_salescluster_ids) . ")"; + } + $where .= " AND Hausnummer.visibility='public'"; + + $sql = AddressDB::$wohneinheit_query; + $sql .= "\n WHERE $where AND ((" . implode(" OR ", $ort_search) . ") OR (" . implode(" OR ", $strasse_search) . ") OR (" . implode(" OR ", $plz_search) . ") OR (" . implode(" OR ", $hausnummer_search) . ")) ORDER BY strasse, LENGTH(hausnummer), hausnummer, LENGTH(`Wohneinheit`.tuer),`Wohneinheit`.tuer, zusatz, LENGTH(num), num"; + + //$sql = "SELECT * FROM view_wohneinheit WHERE $where AND ((".implode(" OR ", $ort_search).") OR (".implode(" OR ", $strasse_search).") OR (".implode(" OR ", $plz_search).") OR (".implode(" OR ", $hausnummer_search).")) ORDER BY strasse, LENGTH(hausnummer), hausnummer, LENGTH(tuer),tuer, zusatz, LENGTH(num), num"; + $this->log->debug($sql); + + $res = $this->db()->query($sql); + + + if($this->db()->num_rows($res)) { + $tmp_addresses = []; + while($data = $this->db()->fetch_object($res)) { + $address_key = $data->hausnummer_id; + if($this->hausnummer_add_zusatz) { + $address_key = $data->hausnummer_id . "-" . $data->zusatz; + } + //$sort_key = $data->plz." ".$data->gemeinde." ".$data->ortschaft." ".$data->strasse." ".$data->hausnummer." ".$data->zusatz; + $sort_key = $data->plz . " " . $data->gemeinde . " " . $data->ortschaft . " " . $data->strasse . " " . $data->hausnummer . " " . $data->zusatz; + if(!array_key_exists($address_key, $tmp_addresses)) { + + // get allowed preorderTypes + $ptypes = []; + if($data->freigabe) { + $freigaben = json_decode($data->freigabe); + if(is_array($freigaben) && count($freigaben)) { + foreach($freigaben as $freigabe) { + if(in_array($freigabe, $this->allowed_preordertypes)) { + $ptypes[] = $freigabe; + } + } + } + + // if FCP is on blacklist, don't allow any order types + $campaign = $this->campaigns[$this->campaigns_by_scluster[$data->netzgebiet_id]]; + if(!$campaign) { + $this->log->error("Campaign not found for netzgebiet_id " . $data->netzgebiet_id); + } else { + if($data->rimo_fcp_name && is_array($campaign->banned_fcps) && count($campaign->banned_fcps) && in_array($data->rimo_fcp_name, $campaign->banned_fcps)) { + $ptypes = []; + } + } + } + + $housenumber = $data->hausnummer; + if($this->hausnummer_add_zusatz) { + if($data->zusatz) { + $housenumber .= " (" . $data->zusatz . ")"; + } + } + + $tmp_addresses[$address_key] = [ + 'sort_key' => $sort_key, + 'oaid' => $data->hausnummer_oaid, + 'cluster_id' => $data->netzgebiet_extref, + 'zip' => $data->plz, + 'city' => $data->gemeinde, + "municipality" => "", + 'district' => $data->ortschaft, + 'street' => $data->strasse, + 'housenumber' => $housenumber, + 'stiege' => $data->hausnummer_stiege, + 'lot_number' => $data->grund_nr, + 'meridian' => $data->meridian, + 'rw' => $data->rw, + 'hw' => $data->hw, + 'building_unit_count' => 0, + 'gps_lat' => ($data->gps_lat) ? (float)$data->gps_lat : null, + 'gps_long' => ($data->gps_long) ? (float)$data->gps_long : null, + 'rollout_year' => ($data->rollout) ? (int)$data->rollout : null, + 'rollout_info' => $data->rollout_info, + 'preorderTypes' => $ptypes, + 'units' => [] + ]; + if($this->district_is_city) { + $tmp_addresses[$address_key]['city'] = $data->ortschaft; + $tmp_addresses[$address_key]['municipality'] = $data->gemeinde; + } else { + unset($tmp_addresses[$address_key]['municipality']); + } + } + + $unit_data = [ + 'oaid' => $data->wohneinheit_oaid, + 'num' => (int)$data->num, + 'block' => $data->block, + 'stock' => $data->stock, + 'tuer' => $data->tuer, + 'zusatz' => $data->zusatz, + ]; + if($this->me->is("preorderaddressreporting")) { - $new_address['ordered'] = $u['ordered']; - $new_address['orderType'] = $u['orderType']; - $new_address['ispName'] = $u['ispName']; + if($data->partner_company) { + $unit_data["ordered"] = true; + $unit_data["orderType"] = $data->order_type; + $unit_data["ispName"] = $data->partner_company; + } else { + $unit_data["ordered"] = false; + $unit_data["orderType"] = null; + $unit_data["ispName"] = null; + } } - $new_address['oaid'] = $u['oaid']; - $new_address['building_oaid'] = $ta['oaid']; - $new_address['cluster_id'] = $ta['cluster_id']; - $new_address['street'] = $ta['street']; - $new_address['housenumber'] = $ta['housenumber']; - $new_address['stiege'] = $ta['stiege']; - $new_address['zip'] = $ta['zip']; - $new_address['city'] = $ta['city']; - if(array_key_exists("municipality", $ta)) { - $new_address['municipality'] = $ta['municipality']; - } - $new_address['district'] = $ta['district']; - $new_address['lot_number'] = $ta['lot_number']; - $new_address['meridian'] = $ta['meridian']; - $new_address['rw'] = $ta['rw']; - $new_address['hw'] = $ta['hw']; - $new_address['building_unit_count'] = $ta['building_unit_count']; - $new_address['num'] = $u['num']; - $new_address['block'] = $u['block']; - $new_address['stock'] = $u['stock']; - $new_address['tuer'] = $u['tuer']; - $new_address['zusatz'] = $u['zusatz']; - $new_address['gps_lat'] = $ta['gps_lat']; - $new_address['gps_long'] = $ta['gps_long']; - $new_address['rollout_year'] = $ta['rollout_year']; - $new_address['rollout_info'] = $ta['rollout_info']; - $new_address['preorderTypes'] = $ta['preorderTypes']; - $addresses[] = $new_address; - } + $tmp_addresses[$address_key]['units'][] = $unit_data; + $tmp_addresses[$address_key]['building_unit_count']++; + //if($data->hausnummer_oaid == "AT-8940-30400d5c") var_dump($data); } - } + //exit; + //var_dump($tmp_addresses);exit; + // sort found addresses by count of found keywords + // if there is an int we don't want to show more than one street + $sorted_addresses = []; + foreach($tmp_addresses as $temp_add) { + $includes_int = false; + $count = 0; + $count_parts = 0; + $uniq_parts_count = 0; + $uniq_parts_found = []; + /*if($temp_add['oaid'] == "AT-8940-30400d5c") { + var_dump($temp_add); + }*/ + foreach($search_parts as $p) { + $p = $this->db->escape(trim($p)); + if(strlen($p) === 0) continue; + $uniq_parts_count++; + if(is_numeric(($p))) { + $includes_int = true; + $count_parts++; + if(substr_count(strtolower($temp_add['sort_key']), strtolower($p))) { + $count++; + } + if(!in_array($p, $uniq_parts_found)) { + $uniq_parts_found[] = $p; + } + } else { + $p_count = substr_count(strtolower($temp_add['sort_key']), strtolower($p)); + if($p_count) { + $count += $p_count; + $count_parts++; + if(!in_array($p, $uniq_parts_found)) { + $uniq_parts_found[] = $p; + } + } + } + } + + unset($temp_add['sort_key']); + if($includes_int && (($count + 1) - count($search_parts)) < 1) { + continue; + } + + //var_dump(count($search_parts), $count, $count_parts, $temp_add); + + /*if($temp_add['oaid'] == "AT-8954-d6c41665") { + echo $temp_add['sort_key'].": AT-8954-d6c41665: count $count; uniq_parts_count $uniq_parts_count; count_parts $count_parts; search_parts ".count($search_parts)."

\n"; + //var_dump(); + //exit; + }*/ + + if($count_parts == count($search_parts)) { + $count += 50; + } + + if($uniq_parts_count <= count($uniq_parts_found)) { + if(!array_key_exists($count, $sorted_addresses)) { + $sorted_addresses[$count] = []; + } + $sorted_addresses[$count][] = $temp_add; + } + } + //exit; + + + ksort($sorted_addresses, SORT_NUMERIC); + $sorted_addresses = array_reverse($sorted_addresses, true); + //var_dump($sorted_addresses);exit; + + // sort / format + if($format == "tree") { + foreach($sorted_addresses as $counted_addresses) { + foreach($counted_addresses as $cadd) { + $addresses[] = $cadd; + } + } + //var_dump($addresses);exit; + //$addresses = array_values($sorted_addresses); + + if(!$addresses) $addresses = []; + } else { + foreach($sorted_addresses as $counted_addresses) { + foreach($counted_addresses as $ta) { + foreach($ta['units'] as $u) { + $new_address = []; + if($this->me->is("preorderaddressreporting")) { + $new_address['ordered'] = $u['ordered']; + $new_address['orderType'] = $u['orderType']; + $new_address['ispName'] = $u['ispName']; + } + $new_address['oaid'] = $u['oaid']; + $new_address['building_oaid'] = $ta['oaid']; + $new_address['cluster_id'] = $ta['cluster_id']; + $new_address['street'] = $ta['street']; + $new_address['housenumber'] = $ta['housenumber']; + $new_address['stiege'] = $ta['stiege']; + $new_address['zip'] = $ta['zip']; + $new_address['city'] = $ta['city']; + if(array_key_exists("municipality", $ta)) { + $new_address['municipality'] = $ta['municipality']; + } + $new_address['district'] = $ta['district']; + $new_address['lot_number'] = $ta['lot_number']; + $new_address['meridian'] = $ta['meridian']; + $new_address['rw'] = $ta['rw']; + $new_address['hw'] = $ta['hw']; + $new_address['building_unit_count'] = $ta['building_unit_count']; + $new_address['num'] = $u['num']; + $new_address['block'] = $u['block']; + $new_address['stock'] = $u['stock']; + $new_address['tuer'] = $u['tuer']; + $new_address['zusatz'] = $u['zusatz']; + $new_address['gps_lat'] = $ta['gps_lat']; + $new_address['gps_long'] = $ta['gps_long']; + $new_address['rollout_year'] = $ta['rollout_year']; + $new_address['rollout_info'] = $ta['rollout_info']; + $new_address['preorderTypes'] = $ta['preorderTypes']; + + $addresses[] = $new_address; + } + } + } + } + } - } - - return mfResponse::Ok(['addresses' => $addresses]); - } - - protected function find() { - // unofficially supporting GET and POST in v1 - $get = array_merge($this->post, $this->get); - - $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); - $search_street = $this->db()->escape(trim($get['street'])); - $search_zip = $this->db()->escape(trim($get['zip'])); - $search_district = $this->db()->escape(trim($get['district'])); - $search_city = $this->db()->escape(trim($get['city'])); - $search_housenumber = $this->db()->escape(trim($get['housenumber'])); - $search_stiege = $this->db()->escape(trim($get['stiege'])); - - $format = "flat"; - if($get['format'] == "tree") { - $format = "tree"; - } - - if(!$search_street && !$search_cluster_id) { - return mfResponse::BadRequest(['message' => "Searchstring cannot be empty!"]); - } - - $addresses = []; - - $where = "1=1"; - - if($search_zip && $search_zip != "%") { - $where .= " AND Plz.plz like '$search_zip%'"; - } - if($search_district && $search_district != "%") { - $where .= " AND Ortschaft.name like '$search_district%'"; - } - if($search_city && $search_city != "%") { - if($this->district_is_city) { - $where .= " AND Ortschaft.name like '$search_city%'"; - } else { - $where .= " AND Gemeinde.name like '$search_city%'"; - } - } - if($search_street && $search_street != "%") { - $where .= " AND Strasse.name like '$search_street%'"; - } - if($search_housenumber && $search_housenumber != "%") { - $where .= " AND Hausnummer.hausnummer like '$search_housenumber%'"; - } - if($search_stiege && $search_stiege != "%") { - $where .= " AND Hausnummer.stiege like '$search_stiege%'"; + return mfResponse::Ok(['addresses' => $addresses]); } - if(count($this->filter_salescluster_ids)) { - $where .= " AND Hausnummer.netzgebiet_id IN (".implode(",", $this->filter_salescluster_ids).")"; - } - if($search_cluster_id) { - $where .= " AND Netzgebiet.extref='$search_cluster_id'"; - } - $where .= " AND Hausnummer.visibility='public'"; - //echo $where; - //var_dump($this->filter_salescluster_ids);exit; - - $sql = AddressDB::$wohneinheit_query; - $sql .= "\n WHERE $where ORDER BY plz, gemeinde, ortschaft, strasse, LENGTH(hausnummer), hausnummer, LENGTH(hausnummer_stiege), hausnummer_stiege, `Wohneinheit`.block, `Wohneinheit`.stock, LENGTH(num), num, LENGTH(`Wohneinheit`.tuer), `Wohneinheit`.tuer"; - - //$sql = "SELECT * FROM view_wohneinheit WHERE $where ORDER BY plz, gemeinde, ortschaft, strasse, LENGTH(hausnummer), hausnummer, block, stiege, stock, LENGTH(num), num, LENGTH(tuer), tuer"; - $this->log->debug($sql); - $res = $this->db()->query($sql); - - if($this->db()->num_rows($res)) { - $tmp_addresses = []; - while($data = $this->db()->fetch_object($res)) { - $address_key = $data->hausnummer_id; - if($this->hausnummer_add_zusatz) { - $address_key = $data->hausnummer_id."-".$data->zusatz; - } - if(!array_key_exists($address_key, $tmp_addresses)) { - - // get allowed preorderTypes - $ptypes = []; - if($data->freigabe) { - $freigaben = json_decode($data->freigabe); - if(is_array($freigaben) && count($freigaben)) { - foreach($freigaben as $freigabe) { - if(in_array($freigabe, $this->allowed_preordertypes)) { - $ptypes[] = $freigabe; - } - } - } - - // if FCP is on blacklist, don't allow any order types - $campaign = $this->campaigns[$this->campaigns_by_scluster[$data->netzgebiet_id]]; - if(!$campaign) { - $this->log->error("Campaign not found for netzgebiet_id ".$data->netzgebiet_id); - } else { - if($data->rimo_fcp_name && is_array($campaign->banned_fcps) && count($campaign->banned_fcps) && in_array($data->rimo_fcp_name, $campaign->banned_fcps)) { - $ptypes = []; - } - } - } + protected function find() { + // unofficially supporting GET and POST in v1 + $get = array_merge($this->post, $this->get); - $housenumber = $data->hausnummer; - if($this->hausnummer_add_zusatz) { - if($data->zusatz) { - $housenumber .= " (".$data->zusatz.")"; - } - } - - $tmp_addresses[$address_key] = [ - 'oaid' => $data->hausnummer_oaid, - 'cluster_id' => $data->netzgebiet_extref, - 'zip' => $data->plz, - 'city' => $data->gemeinde, - "municipality" => "", - 'district' => $data->ortschaft, - 'street' => $data->strasse, - 'housenumber' => $housenumber, - 'stiege' => $data->hausnummer_stiege, - 'lot_number' => $data->grund_nr, - 'meridian' => $data->meridian, - 'rw' => $data->rw, - 'hw' => $data->hw, - 'building_unit_count' => 0, - 'gps_lat' => ($data->gps_lat) ? (float)$data->gps_lat : null, - 'gps_long' => ($data->gps_long) ? (float)$data->gps_long : null, - 'rollout_year' => ($data->rollout) ? (int)$data->rollout : null, - 'rollout_info' => $data->rollout_info, - 'preorderTypes' => $ptypes, - 'units' => [] - ]; + $search_cluster_id = $this->db()->escape(trim($get['cluster_id'])); + $search_street = $this->db()->escape(trim($get['street'])); + $search_zip = $this->db()->escape(trim($get['zip'])); + $search_district = $this->db()->escape(trim($get['district'])); + $search_city = $this->db()->escape(trim($get['city'])); + $search_housenumber = $this->db()->escape(trim($get['housenumber'])); + $search_stiege = $this->db()->escape(trim($get['stiege'])); + + $format = "flat"; + if($get['format'] == "tree") { + $format = "tree"; + } + + if(!$search_street && !$search_cluster_id) { + return mfResponse::BadRequest(['message' => "Searchstring cannot be empty!"]); + } + + $addresses = []; + + $where = "1=1"; + + if($search_zip && $search_zip != "%") { + $where .= " AND Plz.plz like '$search_zip%'"; + } + if($search_district && $search_district != "%") { + $where .= " AND Ortschaft.name like '$search_district%'"; + } + if($search_city && $search_city != "%") { if($this->district_is_city) { - $tmp_addresses[$address_key]['city'] = $data->ortschaft; - $tmp_addresses[$address_key]['municipality'] = $data->gemeinde; + $where .= " AND Ortschaft.name like '$search_city%'"; } else { - unset($tmp_addresses[$address_key]['municipality']); + $where .= " AND Gemeinde.name like '$search_city%'"; } - - } - - $unit_data = [ - 'oaid' => $data->wohneinheit_oaid, - 'num' => (int)$data->num, - 'block' => $data->block, - 'stock' => $data->stock, - 'tuer' => $data->tuer, - 'zusatz' => $data->zusatz, - ]; - if($this->me->is("preorderaddressreporting")) { - if($data->partner_company) { - $unit_data["ordered"] = true; - $unit_data["orderType"] = $data->order_type; - $unit_data["ispName"] = $data->partner_company; - } else { - $unit_data["ordered"] = false; - $unit_data["orderType"] = null; - $unit_data["ispName"] = null; - } - } - $tmp_addresses[$address_key]['units'][] = $unit_data; - $tmp_addresses[$address_key]['building_unit_count']++; - - } - if($format == "tree") { - /*foreach($tmp_addresses as $ta) { - $addresses[] = $ta; - }*/ - $addresses = array_values($tmp_addresses); - } else { - foreach($tmp_addresses as $ta) { - foreach($ta['units'] as $u) { - $new_address = []; - if($this->me->is("preorderaddressreporting")) { - $new_address['ordered'] = $u['ordered']; - $new_address['orderType'] = $u['orderType']; - $new_address['ispName'] = $u['ispName']; - } - $new_address['oaid'] = $u['oaid']; - $new_address['building_oaid'] = $ta['oaid']; - $new_address['cluster_id'] = $ta['cluster_id']; - $new_address['street'] = $ta['street']; - $new_address['housenumber'] = $ta['housenumber']; - $new_address['stiege'] = $ta['stiege']; - $new_address['zip'] = $ta['zip']; - $new_address['city'] = $ta['city']; - if(array_key_exists("municipality", $ta)) { - $new_address['municipality'] = $ta['municipality']; - } - $new_address['district'] = $ta['district']; - $new_address['lot_number'] = $ta['lot_number']; - $new_address['meridian'] = $ta['meridian']; - $new_address['rw'] = $ta['rw']; - $new_address['hw'] = $ta['hw']; - $new_address['building_unit_count'] = $ta['building_unit_count']; - $new_address['num'] = $u['num']; - $new_address['block'] = $u['block']; - $new_address['stock'] = $u['stock']; - $new_address['tuer'] = $u['tuer']; - $new_address['zusatz'] = $u['zusatz']; - $new_address['gps_lat'] = $ta['gps_lat']; - $new_address['gps_long'] = $ta['gps_long']; - $new_address['rollout_year'] = $ta['rollout_year']; - $new_address['rollout_info'] = $ta['rollout_info']; - $new_address['preorderTypes'] = $ta['preorderTypes']; - - $addresses[] = $new_address; - } - } + if($search_street && $search_street != "%") { + $where .= " AND Strasse.name like '$search_street%'"; + } + if($search_housenumber && $search_housenumber != "%") { + $where .= " AND Hausnummer.hausnummer like '$search_housenumber%'"; + } + if($search_stiege && $search_stiege != "%") { + $where .= " AND Hausnummer.stiege like '$search_stiege%'"; } + if(count($this->filter_salescluster_ids)) { + $where .= " AND Hausnummer.netzgebiet_id IN (" . implode(",", $this->filter_salescluster_ids) . ")"; + } + if($search_cluster_id) { + $where .= " AND Netzgebiet.extref='$search_cluster_id'"; + } + $where .= " AND Hausnummer.visibility='public'"; + //echo $where; + //var_dump($this->filter_salescluster_ids);exit; + + $sql = AddressDB::$wohneinheit_query; + $sql .= "\n WHERE $where ORDER BY plz, gemeinde, ortschaft, strasse, LENGTH(hausnummer), hausnummer, LENGTH(hausnummer_stiege), hausnummer_stiege, `Wohneinheit`.block, `Wohneinheit`.stock, LENGTH(num), num, LENGTH(`Wohneinheit`.tuer), `Wohneinheit`.tuer"; + + //$sql = "SELECT * FROM view_wohneinheit WHERE $where ORDER BY plz, gemeinde, ortschaft, strasse, LENGTH(hausnummer), hausnummer, block, stiege, stock, LENGTH(num), num, LENGTH(tuer), tuer"; + $this->log->debug($sql); + $res = $this->db()->query($sql); + + if($this->db()->num_rows($res)) { + $tmp_addresses = []; + while($data = $this->db()->fetch_object($res)) { + $address_key = $data->hausnummer_id; + if($this->hausnummer_add_zusatz) { + $address_key = $data->hausnummer_id . "-" . $data->zusatz; + } + if(!array_key_exists($address_key, $tmp_addresses)) { + + // get allowed preorderTypes + $ptypes = []; + if($data->freigabe) { + $freigaben = json_decode($data->freigabe); + if(is_array($freigaben) && count($freigaben)) { + foreach($freigaben as $freigabe) { + if(in_array($freigabe, $this->allowed_preordertypes)) { + $ptypes[] = $freigabe; + } + } + } + + // if FCP is on blacklist, don't allow any order types + $campaign = $this->campaigns[$this->campaigns_by_scluster[$data->netzgebiet_id]]; + if(!$campaign) { + $this->log->error("Campaign not found for netzgebiet_id " . $data->netzgebiet_id); + } else { + if($data->rimo_fcp_name && is_array($campaign->banned_fcps) && count($campaign->banned_fcps) && in_array($data->rimo_fcp_name, $campaign->banned_fcps)) { + $ptypes = []; + } + } + } + + $housenumber = $data->hausnummer; + if($this->hausnummer_add_zusatz) { + if($data->zusatz) { + $housenumber .= " (" . $data->zusatz . ")"; + } + } + + $tmp_addresses[$address_key] = [ + 'oaid' => $data->hausnummer_oaid, + 'cluster_id' => $data->netzgebiet_extref, + 'zip' => $data->plz, + 'city' => $data->gemeinde, + "municipality" => "", + 'district' => $data->ortschaft, + 'street' => $data->strasse, + 'housenumber' => $housenumber, + 'stiege' => $data->hausnummer_stiege, + 'lot_number' => $data->grund_nr, + 'meridian' => $data->meridian, + 'rw' => $data->rw, + 'hw' => $data->hw, + 'building_unit_count' => 0, + 'gps_lat' => ($data->gps_lat) ? (float)$data->gps_lat : null, + 'gps_long' => ($data->gps_long) ? (float)$data->gps_long : null, + 'rollout_year' => ($data->rollout) ? (int)$data->rollout : null, + 'rollout_info' => $data->rollout_info, + 'preorderTypes' => $ptypes, + 'units' => [] + ]; + if($this->district_is_city) { + $tmp_addresses[$address_key]['city'] = $data->ortschaft; + $tmp_addresses[$address_key]['municipality'] = $data->gemeinde; + } else { + unset($tmp_addresses[$address_key]['municipality']); + } + + } + + $unit_data = [ + 'oaid' => $data->wohneinheit_oaid, + 'num' => (int)$data->num, + 'block' => $data->block, + 'stock' => $data->stock, + 'tuer' => $data->tuer, + 'zusatz' => $data->zusatz, + ]; + if($this->me->is("preorderaddressreporting")) { + if($data->partner_company) { + $unit_data["ordered"] = true; + $unit_data["orderType"] = $data->order_type; + $unit_data["ispName"] = $data->partner_company; + } else { + $unit_data["ordered"] = false; + $unit_data["orderType"] = null; + $unit_data["ispName"] = null; + } + } + $tmp_addresses[$address_key]['units'][] = $unit_data; + $tmp_addresses[$address_key]['building_unit_count']++; + + + } + if($format == "tree") { + /*foreach($tmp_addresses as $ta) { + $addresses[] = $ta; + }*/ + $addresses = array_values($tmp_addresses); + } else { + foreach($tmp_addresses as $ta) { + foreach($ta['units'] as $u) { + $new_address = []; + if($this->me->is("preorderaddressreporting")) { + $new_address['ordered'] = $u['ordered']; + $new_address['orderType'] = $u['orderType']; + $new_address['ispName'] = $u['ispName']; + } + $new_address['oaid'] = $u['oaid']; + $new_address['building_oaid'] = $ta['oaid']; + $new_address['cluster_id'] = $ta['cluster_id']; + $new_address['street'] = $ta['street']; + $new_address['housenumber'] = $ta['housenumber']; + $new_address['stiege'] = $ta['stiege']; + $new_address['zip'] = $ta['zip']; + $new_address['city'] = $ta['city']; + if(array_key_exists("municipality", $ta)) { + $new_address['municipality'] = $ta['municipality']; + } + $new_address['district'] = $ta['district']; + $new_address['lot_number'] = $ta['lot_number']; + $new_address['meridian'] = $ta['meridian']; + $new_address['rw'] = $ta['rw']; + $new_address['hw'] = $ta['hw']; + $new_address['building_unit_count'] = $ta['building_unit_count']; + $new_address['num'] = $u['num']; + $new_address['block'] = $u['block']; + $new_address['stock'] = $u['stock']; + $new_address['tuer'] = $u['tuer']; + $new_address['zusatz'] = $u['zusatz']; + $new_address['gps_lat'] = $ta['gps_lat']; + $new_address['gps_long'] = $ta['gps_long']; + $new_address['rollout_year'] = $ta['rollout_year']; + $new_address['rollout_info'] = $ta['rollout_info']; + $new_address['preorderTypes'] = $ta['preorderTypes']; + + $addresses[] = $new_address; + } + } + } + + } + + return mfResponse::Ok(['addresses' => $addresses]); + } + + protected function exportAddresses() { + /*if($this->me->username != 'r.eschner@rmlinfrastruktur.at') { + return mfResponse::Forbidden(); + }*/ + + $netzgebiet_ids = []; + if(count($this->filter_salescluster_ids)) { + $netzgebiet_ids = $this->filter_salescluster_ids; + } + + //var_dump($netzgebiet_ids);exit; + $sql = "SELECT * FROM Hausnummer WHERE netzgebiet_id IN (".implode(",", $netzgebiet_ids).")"; + //echo "$sql\n";exit; + $res = $this->db()->query($sql); + + $tpl = new Layout(); + $tpl->setTemplate("AddressDB/export.csv"); + $tpl->set("res", $res); + $tpl->set("no_filename", true); + $tpl->display(); + //$csv = $tpl->render(); + //echo $csv; + exit; + } - - return mfResponse::Ok(['addresses' => $addresses]); - } - } \ No newline at end of file