Method get_joined_db

models/db.php:286–333

* Get Joined DB * @param string requesting * @param array site_ids */

(
        $requesting, $sites = [])

     * @param array site_ids
     */
    public static function get_joined_db(
        $requesting, $sites = []){

            // TODO: Add "WHERE" with site id, so that we only equalify active site alerts.

        // Set conditions based on type.
        if($requesting == 'equalified_alerts'){
            $table1 = 'alerts';
            $table2 = 'queued_alerts';
            $selected_columns = "DISTINCT $table1.id";
        }elseif($requesting == 'new_alerts'){
            $table1 = 'queued_alerts';
            $table2 = 'alerts';
            $selected_columns = "DISTINCT $table1.id, ";
            $selected_columns.= "$table1.url, $table1.message, ";
            $selected_columns.= "$table1.status, $table1.site_id, ";
            $selected_columns.= "$table1.source, $table1.tags, ";
            $selected_columns.= "$table1.more_info, $table1.more_info";
        }
        
        // SQL.
        $sql = "SELECT $selected_columns FROM $table1 ";
        $sql.= "LEFT JOIN $table2 ";
        $sql.= "ON $table1.url=$table2.url ";
        $sql.= "AND $table1.message=$table2.message ";
        $sql.= "AND $table1.site_id=$table2.site_id ";
        $sql.= "AND $table1.source=$table2.source ";
        $sql.= "WHERE $table2.id IS NULL AND $table1.archived = 0 ";
        if(!empty($sites)){
            foreach($sites as $site){
                $sql.= "AND $table1.site_id = $site->id ";
            }
        }
        $params = array();
    
        // Query
        $result = self::query($sql, $params, true);
    
        // Result
        $content = [];
        if($result->num_rows > 0){
            while($row = $result->fetch_object()){
                $content[] = $row;
            }
        }
        return $content;

    }
    
    /**
     * Add DB Column