2024-12-17 14:23:14 +01:00
parent 4b5b1e01f5
commit 8d692db5b1
6 changed files with 314 additions and 31 deletions
@@ -88,4 +88,160 @@ class ConstructionConsentController extends mfBaseController {
        $this->addAction();
    }
    protected function apiAction() {
        if(!$this->me->is(["Admin","netowner"]) && !$this->me->can("Preorder")) {
            $this->redirect("Dashboard");
        }
        $do = $this->request->do;
        $data = [];
        switch($do) {
            case "findStreet":
                $return = $this->findStreetApi();
                break;
            default:
                $this->log->warn(__METHOD__ . ": Called API function '$do' does not exist");
                $return = false;
        }
        if(!is_array($return) || !count($return)) {
            $data = ["status" => "error"];
            $this->returnJson($data);
        }
        $data['status'] = "OK";
        $data['result'] = $return;
        $this->returnJson($data);
    }
    private function findStreetApi() {
        $addresses = [];
        $search = trim($this->request->q);
        $project_id = $this->request->project_id;
        $scluster_ids = [];
        if($project_id) {
            $project = new ConstructionConsentProject($project_id);
            if(!$project->id) {
                header("Content-Type: application/json");
                echo json_encode(["results" => []]);
                exit;
            }
            foreach($project->adb_networks as $network) {
                $scluster_ids[] = $network->id;
            }
        } else {
            // get all salesclusters
            foreach(ADBNetzgebietModel::getAll() as $network) {
                $scluster_ids[] = $network->id;
            }
        }
        $results = [];
        $search_parts = explode(" ", $search);
        $ort_search = $strasse_search = $plz_search = $hausnummer_search = $gst_search = [];
        foreach($search_parts as $p) {
            $p = $this->db->escape(trim($p));
            if(!$p) continue;
            $ort_search[] = "ortschaft like '$p%'";
            $strasse_search[] = "strasse like '$p%'";
            $plz_search[] = "plz like '%$p%'";
            $hausnummer_search[] = "hausnummer like '%$p%'";
            $gst_search[] = "grund_nr like '%$p%'";
        }
        $where = "1=1";
        if(count($scluster_ids)) {
            $where .= " AND netzgebiet_id IN (".implode(', ',$scluster_ids).")";
        }
        /*if($include_gst) {
            $sql = "SELECT * FROM view_hausnummer WHERE $where AND ((".implode(" OR ", $ort_search).") OR (".implode(" OR ", $strasse_search).") OR (".implode(" OR ", $plz_search).") OR (".implode(" OR ", $hausnummer_search).")  OR (".implode(" OR ", $gst_search).") ) ORDER BY strasse, LENGTH(hausnummer), hausnummer";
        } else {
            $sql = "SELECT * FROM view_hausnummer 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";
        }*/
        $sql = "SELECT strasse_id,plz,ortschaft,strasse FROM view_hausnummer
         WHERE $where 
         AND ((".implode(" OR ", $ort_search).") OR (".implode(" OR ", $strasse_search).") OR (".implode(" OR ", $plz_search).") OR (".implode(" OR ", $hausnummer_search)."))
         GROUP BY plz,ortschaft,strasse,strasse_id
         ORDER BY strasse
         ";
        $this->log->debug($sql);
        $adb = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
        $res = $adb->query($sql);
        $this->log->debug("done");
        if(!$adb->num_rows($res)) {
            header("Content-Type: application/json");
            echo json_encode(["results" => []]);
            exit;
        }
        while($data = $adb->fetch_object($res)) {
            //$address_string = $data->plz." ".$data->ortschaft.", ".$data->strasse." ".$data->hausnummer;
            $address_string = $data->plz." ".$data->ortschaft.", ".$data->strasse;
            /*if($include_gst) {
                $address_string .= " | GST: ".$data->grund_nr;
            }*/
            $sort_key = $data->plz." ".$data->ortschaft." ".$data->strasse;
            $address = [];
            $address['id'] = $data->strasse_id;
            $address["text"] = $address_string;
            $address['sort_key'] = $sort_key;
            $addresses[] = $address;
        }
        // sort results by most occurences of search strings
        $sort = [];
        foreach($addresses as $key => $address) {
            $includes_int = false;
            $count = 0;
            foreach($search_parts as $p) {
                $p = $this->db->escape(trim($p));
                if(!$p) continue;
                if(is_numeric(($p))) {
                    $includes_int = true;
                    if(substr_count(strtolower($address['text']), strtolower($p))) {
                        $count++;
                    }
                } else {
                    $count += substr_count(strtolower($address['text']), strtolower($p));
                }
            }
            unset($address['sort_key']);
            //echo $address['text']." $p $count<br />\n";
            if($includes_int && (($count + 1) - count($search_parts) ) < 1) {
                continue;
            }
            if(!array_key_exists($count, $sort)) {
                $sort[$count] = [];
            }
            $sort[$count][] = $address;
        }
        ksort($sort, SORT_NUMERIC);
        $sort = array_reverse($sort, true);
        //var_dump($sort);exit;
        foreach($sort as $res) {
            foreach($res as $a) {
                $results[] = $a;
            }
        }
        header("Content-Type: application/json");
        echo json_encode(["results" => $results]);
        exit;
    }
}