Cloudlog/application/models/Dxcc.php

<?php

class DXCC extends CI_Model
{

	public $bandslots = array("160m" => 0,
		"80m" => 0,
		"60m" => 0,
		"40m" => 0,
		"30m" => 0,
		"20m" => 0,
		"17m" => 0,
		"15m" => 0,
		"12m" => 0,
		"10m" => 0,
		"6m" => 0,
		"4m" => 0,
		"2m" => 0,
		"70cm" => 0,
		"23cm" => 0,
		"13cm" => 0,
		"9cm" => 0,
		"6cm" => 0,
		"3cm" => 0,
		"1.25cm" => 0,
		"SAT" => 0,
	);

	function __construct()
	{
		// Call the Model constructor
		parent::__construct();

	}

	function get_worked_bands()
	{
		$CI =& get_instance();
		$CI->load->model('Stations');
		$station_id = $CI->Stations->find_active();

		// get all worked slots from database
		$data = $this->db->query(
			"SELECT distinct LOWER(`COL_BAND`) as `COL_BAND` FROM `" . $this->config->item('table_name') . "` WHERE station_id = " . $station_id . " AND COL_PROP_MODE != \"SAT\""
		);
		$worked_slots = array();
		foreach ($data->result() as $row) {
			array_push($worked_slots, $row->COL_BAND);
		}

		$SAT_data = $this->db->query(
			"SELECT distinct LOWER(`COL_PROP_MODE`) as `COL_PROP_MODE` FROM `" . $this->config->item('table_name') . "` WHERE station_id = " . $station_id . " AND COL_PROP_MODE = \"SAT\""
		);

		foreach ($SAT_data->result() as $row) {
			array_push($worked_slots, strtoupper($row->COL_PROP_MODE));
		}


		// bring worked-slots in order of defined $bandslots
		$results = array();
		foreach (array_keys($this->bandslots) as $slot) {
			if (in_array($slot, $worked_slots)) {
				array_push($results, $slot);
			}
		}

		return $results;
	}

	function show_stats()
	{
		$CI =& get_instance();
		$CI->load->model('Stations');
		$station_id = $CI->Stations->find_active();

		$data = $this->db->query(
			"select COL_COUNTRY, COL_MODE, lcase(COL_BAND) as COL_BAND, count(COL_COUNTRY) as cnt
            from " . $this->config->item('table_name') . "
            where station_id = " . $station_id . " AND COL_PROP_MODE != \"SAT\"
            group by COL_COUNTRY, COL_MODE, COL_BAND"
		);

		$results = array();
		$last_country = "";
		foreach ($data->result() as $row) {
			if ($last_country != $row->COL_COUNTRY) {
				// new row
				$results[$row->COL_COUNTRY] = $this->bandslots;
				$last_country = $row->COL_COUNTRY;
			}

			// update stats
			if (!isset($results[$row->COL_COUNTRY]))
				$results[$row->COL_COUNTRY] = [];

			if (!isset($results[$row->COL_COUNTRY][$row->COL_BAND]))
				$results[$row->COL_COUNTRY][$row->COL_BAND] = 0;

			$results[$row->COL_COUNTRY][$row->COL_BAND] += $row->cnt;
		}

		// Satellite DXCC

		$satellite_data = $this->db->query(
			"select COL_COUNTRY, COL_PROP_MODE as COL_PROP_MODE, count(COL_COUNTRY) as cnt
				from " . $this->config->item('table_name') . "
				where station_id = " . $station_id . " AND COL_PROP_MODE = \"SAT\"
				group by COL_COUNTRY"
		);

		foreach ($satellite_data->result() as $row) {
			if ($last_country != $row->COL_COUNTRY) {
				// new row
				$results[$row->COL_COUNTRY] = $this->bandslots;
				$last_country = $row->COL_COUNTRY;
			}

			// update stats
			if (!isset($results[$row->COL_COUNTRY]))
				$results[$row->COL_COUNTRY] = [];

			if (!isset($results[$row->COL_COUNTRY][$row->COL_PROP_MODE]))
				$results[$row->COL_COUNTRY][$row->COL_PROP_MODE] = 0;

			$results[$row->COL_COUNTRY][$row->COL_PROP_MODE] += $row->cnt;
		}

		// print_r($results);
		// return;

		return $results;
	}

	/**
	 *    Function: mostactive
	 *    Information: Returns the most active band
	 **/
	function info($callsign)
	{
		$exceptions = $this->db->query('
				SELECT *
				FROM `dxccexceptions`
				WHERE `prefix` = \'' . $callsign . '\'
				LIMIT 1
			');

		if ($exceptions->num_rows() > 0) {
			return $exceptions;
		} else {

			$query = $this->db->query('
					SELECT *
					FROM dxcc_entities
					WHERE prefix = SUBSTRING( \'' . $callsign . '\', 1, LENGTH( prefix ) )
					ORDER BY LENGTH( prefix ) DESC
					LIMIT 1
				');

			return $query;
		}
	}

	function search()
	{
		print_r($this->input->get());
		return;
	}

	function empty_table($table)
	{
		$this->db->empty_table($table);
	}

	function list()
	{
		$this->db->order_by('name', 'ASC');
		return $this->db->get('dxcc_entities');
	}

	function get_dxcc_array($dxccArray, $bands, $postdata)
	{
		$CI =& get_instance();
		$CI->load->model('Stations');
		$station_id = $CI->Stations->find_active();

		foreach ($bands as $band) {                // Looping through bands and entities to generate the array needed for display
			foreach ($dxccArray as $dxcc) {
				$dxccMatrix[$dxcc->adif]['name'] = $dxcc->name;
				$dxccMatrix[$dxcc->adif]['Dxccprefix'] = $dxcc->prefix;
				if ($postdata['includedeleted'])
					$dxccMatrix[$dxcc->adif]['Deleted'] = isset($dxcc->Enddate) ? "<div class='alert-danger'>Y</div>" : '';
				$dxccMatrix[$dxcc->adif][$band] = '-';
			}

			// If worked is checked, we add worked entities to the array
			if ($postdata['worked'] != NULL) {
				$workedDXCC = $this->getDxccBandWorked($station_id, $band, $postdata);
				foreach ($workedDXCC as $wdxcc) {
					$dxccMatrix[$wdxcc->dxcc][$band] = '<div class="alert-danger"><a href=\'dxcc_details?Country="' . str_replace("&", "%26", $wdxcc->name) . '"&Band="' . $band . '"\'>W</a></div>';;
				}
			}

			// If confirmed is checked, we add confirmed entities to the array
			if ($postdata['confirmed'] != NULL) {
				$confirmedDXCC = $this->getDxccBandConfirmed($station_id, $band, $postdata);
				foreach ($confirmedDXCC as $cdxcc) {
					$dxccMatrix[$cdxcc->dxcc][$band] = '<div class="alert-success"><a href=\'dxcc_details?Country="' . str_replace("&", "%26", $cdxcc->name) . '"&Band="' . $band . '"\'>C</a></div>';;
				}
			}
		}

		// We want to remove the worked dxcc's in the list, since we do not want to display them
		if ($postdata['worked'] == NULL) {
			$workedDxcc = $this->getDxccWorked($station_id, $postdata);
			foreach ($workedDxcc as $wdxcc) {
				if (array_key_exists($wdxcc->dxcc, $dxccMatrix)) {
					unset($dxccMatrix[$wdxcc->dxcc]);
				}
			}
		}

		// We want to remove the confirmed dxcc's in the list, since we do not want to display them
		if ($postdata['confirmed'] == NULL) {
			$confirmedDxcc = $this->getDxccConfirmed($station_id, $postdata);
			foreach ($confirmedDxcc as $cdxcc) {
				if (array_key_exists($cdxcc->dxcc, $dxccMatrix)) {
					unset($dxccMatrix[$cdxcc->dxcc]);
				}
			}
		}

		if (isset($dxccMatrix)) {
			return $dxccMatrix;
		} else {
			return 0;
		}
	}

	function getDxccBandConfirmed($station_id, $band, $postdata)
	{
		$sql = "select adif as dxcc, name from dxcc_entities
				join (
					select col_dxcc from " . $this->config->item('table_name') . " thcv
					where station_id = " . $station_id .
			" and col_dxcc > 0";

		if ($band == 'SAT') {
			$sql .= " and col_prop_mode ='" . $band . "'";
		} else {
			$sql .= " and col_prop_mode !='SAT'";
			$sql .= " and col_band ='" . $band . "'";
		}

		$sql .= $this->addQslToQuery($postdata);

		$sql .= " group by col_dxcc
				) x on dxcc_entities.adif = x.col_dxcc";

		if ($postdata['includedeleted'] == NULL) {
			$sql .= " and dxcc_entities.end is null";
		}

		$sql .= $this->addContinentsToQuery($postdata);

		$query = $this->db->query($sql);

		return $query->result();
	}

	function getDxccBandWorked($station_id, $band, $postdata)
	{
		$sql = "select adif as dxcc, name from dxcc_entities
				join (
					select col_dxcc from " . $this->config->item('table_name') . " thcv
					where station_id = " . $station_id .
			" and col_dxcc > 0";

		if ($band == 'SAT') {
			$sql .= " and col_prop_mode ='" . $band . "'";
		} else {
			$sql .= " and col_prop_mode !='SAT'";
			$sql .= " and col_band ='" . $band . "'";
		}

		$sql .= " group by col_dxcc
				) x on dxcc_entities.adif = x.col_dxcc";;

		if ($postdata['includedeleted'] == NULL) {
			$sql .= " and dxcc_entities.end is null";
		}

		$sql .= $this->addContinentsToQuery($postdata);

		$query = $this->db->query($sql);

		return $query->result();
	}

	function fetchDxcc($postdata)
	{
		$CI =& get_instance();
		$CI->load->model('Stations');
		$station_id = $CI->Stations->find_active();

		$sql = "select adif, prefix, name, date(end) Enddate, date(start) Startdate 
            from dxcc_entities";

		if ($postdata['notworked'] == NULL) {
			$sql .= " join (select col_dxcc from " . $this->config->item('table_name') . " where station_id = $station_id";

			if ($postdata['band'] != 'All') {
				if ($postdata['band'] == 'SAT') {
					$sql .= " and col_prop_mode ='" . $postdata['band'] . "'";
				} else {
					$sql .= " and col_prop_mode !='SAT'";
					$sql .= " and col_band ='" . $postdata['band'] . "'";
				}
			}

			$sql .= ' group by col_dxcc) x on dxcc_entities.adif = x.col_dxcc';
		}

		$sql .= " where 1 = 1";

		if ($postdata['includedeleted'] == NULL) {
			$sql .= " and end is null";
		}

		$sql .= $this->addContinentsToQuery($postdata);

		$sql .= ' order by prefix';
		$query = $this->db->query($sql);

		return $query->result();
	}

	function getDxccWorked($station_id, $postdata)
	{
		$sql = "SELECT adif as dxcc FROM dxcc_entities
        join (
            select col_dxcc 
            from " . $this->config->item('table_name') . " thcv
            where station_id = " . $station_id .
			" and col_dxcc > 0";

		if ($postdata['band'] != 'All') {
			if ($postdata['band'] == 'SAT') {
				$sql .= " and col_prop_mode ='" . $postdata['band'] . "'";
			} else {
				$sql .= " and col_prop_mode !='SAT'";
				$sql .= " and col_band ='" . $postdata['band'] . "'";
			}
		}

		$sql .= " and not exists (select 1 from " . $this->config->item('table_name') . " where station_id = $station_id and col_dxcc = thcv.col_dxcc";

		if ($postdata['band'] != 'All') {
			if ($postdata['band'] == 'SAT') {
				$sql .= " and col_prop_mode ='" . $postdata['band'] . "'";
			} else {
				$sql .= " and col_prop_mode !='SAT'";
				$sql .= " and col_band ='" . $postdata['band'] . "'";
			}
		}

		$sql .= $this->addQslToQuery($postdata);

		$sql .= ')';

		$sql .= " group by col_dxcc
            ) ll on dxcc_entities.adif = ll.col_dxcc
            where 1=1";

		if ($postdata['includedeleted'] == 'false') {
			$sql .= " and dxcc_entities.end is null";
		}

		$sql .= $this->addContinentsToQuery($postdata);

		$query = $this->db->query($sql);

		return $query->result();
	}

	function getDxccConfirmed($station_id, $postdata)
	{
		$sql = "SELECT adif as dxcc FROM dxcc_entities
            join (
                select col_dxcc 
                from " . $this->config->item('table_name') . " thcv
                where station_id = " . $station_id .
			" and col_dxcc > 0";

		if ($postdata['band'] != 'All') {
			if ($postdata['band'] == 'SAT') {
				$sql .= " and col_prop_mode ='" . $postdata['band'] . "'";
			} else {
				$sql .= " and col_prop_mode !='SAT'";
				$sql .= " and col_band ='" . $postdata['band'] . "'";
			}
		}

		$sql .= $this->addQslToQuery($postdata);

		$sql .= " group by col_dxcc
            ) ll on dxcc_entities.adif = ll.col_dxcc
            where 1=1";

		if ($postdata['includedeleted'] == 'false') {
			$sql .= " and dxcc_entities.end is null";
		}

		$sql .= $this->addContinentsToQuery($postdata);

		$query = $this->db->query($sql);

		return $query->result();
	}

	// Made function instead of repeating this several times
	function addQslToQuery($postdata)
	{
		$sql = '';
		if ($postdata['lotw'] != NULL and $postdata['qsl'] == NULL) {
			$sql .= " and col_lotw_qsl_rcvd = 'Y'";
		}

		if ($postdata['qsl'] != NULL and $postdata['lotw'] == NULL) {
			$sql .= " and col_qsl_rcvd = 'Y'";
		}

		if ($postdata['qsl'] != NULL && $postdata['lotw'] != NULL) {
			$sql .= " and (col_qsl_rcvd = 'Y' or col_lotw_qsl_rcvd = 'Y')";
		}
		return $sql;
	}

	// Made function instead of repeating this several times
	function addContinentsToQuery($postdata)
	{
		$sql = '';
		if ($postdata['Africa'] == NULL) {
			$sql .= " and cont <> 'AF'";
		}

		if ($postdata['Europe'] == NULL) {
			$sql .= " and cont <> 'EU'";
		}

		if ($postdata['Asia'] == NULL) {
			$sql .= " and cont <> 'AS'";
		}

		if ($postdata['SouthAmerica'] == NULL) {
			$sql .= " and cont <> 'SA'";
		}

		if ($postdata['NorthAmerica'] == NULL) {
			$sql .= " and cont <> 'NA'";
		}

		if ($postdata['Oceania'] == NULL) {
			$sql .= " and cont <> 'OC'";
		}

		if ($postdata['Antarctica'] == NULL) {
			$sql .= " and cont <> 'AN'";
		}
		return $sql;
	}

	/*
     * Function gets worked and confirmed summary on each band on the active stationprofile
     */
	function get_dxcc_summary($bands)
	{
		$CI =& get_instance();
		$CI->load->model('Stations');
		$station_id = $CI->Stations->find_active();

		foreach ($bands as $band) {
			$result = $this->getSummaryByBand($band, $station_id);
			$dxccSummary['worked'][$band] = $result[0]->count;
			$dxccSummary['confirmed'][$band] = $result[0]->cfmdxcc;
		}

		return $dxccSummary;
	}

	function getSummaryByBand($band, $station_id)
	{
		$sql = "SELECT thcv.col_band, count(distinct thcv.col_dxcc) as count, coalesce (cfmdxcc.count, 0) as cfmdxcc FROM " . $this->config->item('table_name') . " thcv";

		$sql .= " left outer join (
                    select col_band, count(distinct col_dxcc) as count from " . $this->config->item('table_name') . " thcv";
		$sql .= " where station_id = " . $station_id;

		if ($band == 'SAT') {
			$sql .= " and col_prop_mode ='" . $band . "'";
		} else {
			$sql .= " and col_prop_mode !='SAT'";
			$sql .= " and col_band ='" . $band . "'";
		}

		$sql .= " and (col_qsl_rcvd = 'Y' or col_lotw_qsl_rcvd = 'Y')";

		$sql .= ") cfmdxcc on thcv.col_band = cfmdxcc.col_band ";

		$sql .= " where station_id = " . $station_id;

		if ($band == 'SAT') {
			$sql .= " and thcv.col_prop_mode ='" . $band . "'";
		} else {
			$sql .= " and thcv.col_prop_mode !='SAT'";
			$sql .= " and thcv.col_band ='" . $band . "'";

		}
		$query = $this->db->query($sql);

		return $query->result();
	}
}
?>