ham-ref/cloudlog
1
0
Fork 0
mirror of https://github.com/magicbug/Cloudlog synced 2026-08-13 17:49:35 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions
cloudlog/application/models/Eqslmethods_model.php
Peter Goodhall 4b063e7fe0 Small eqsl changes
2026-07-18 22:31:33 +01:00

410 lines
20 KiB
PHP
Raw Permalink Blame History

<?php
class Eqslmethods_model extends CI_Model {
private $eqsl_mappings_table = 'eqsl_mappings';
function mark_all_as_sent() {
$data = array(
'COL_EQSL_QSL_SENT' => 'Y',
'COL_EQSL_QSLSDATE' => date('Y-m-d')." 00:00:00",
);
$this->db->group_start();
$this->db->where('COL_EQSL_QSL_SENT', 'N');
$this->db->or_where('COL_EQSL_QSL_SENT', 'R');
$this->db->or_where('COL_EQSL_QSL_SENT', 'Q');
$this->db->or_where('COL_EQSL_QSL_SENT', null);
$this->db->group_end();
$this->db->update($this->config->item('table_name'), $data);
}
function get_eqsl_users() {
$this->db->select('user_eqsl_name, user_eqsl_password, user_id');
$this->db->where('coalesce(user_eqsl_name, "") != ""');
$this->db->where('coalesce(user_eqsl_password, "") != ""');
$query = $this->db->get($this->config->item('auth_table'));
return $query->result();
}
function eqsl_mappings_table_exists() {
return $this->db->table_exists($this->eqsl_mappings_table);
}
function get_eqsl_mappings_for_sync() {
if (!$this->eqsl_mappings_table_exists()) {
return array();
}
$this->db->select('eqsl_mappings.mapping_id, eqsl_mappings.user_id, eqsl_mappings.station_id, eqsl_mappings.eqsl_username, eqsl_mappings.eqsl_password, eqsl_mappings.eqsl_qth_nickname, station_profile.station_callsign');
$this->db->from($this->eqsl_mappings_table);
$this->db->join('station_profile', 'station_profile.station_id = eqsl_mappings.station_id', 'inner');
$this->db->where('eqsl_mappings.enabled', 1);
$this->db->where('coalesce(eqsl_mappings.eqsl_username, "") != ""');
$this->db->where('coalesce(eqsl_mappings.eqsl_password, "") != ""');
$this->db->where('coalesce(eqsl_mappings.eqsl_qth_nickname, "") != ""');
return $this->db->get()->result_array();
}
/*
* Gets all station location for user, for use in cron where we don't have any login
*/
function get_all_user_locations($userid) {
$this->db->select('station_profile.*, dxcc_entities.name as station_country, dxcc_entities.end as dxcc_end');
$this->db->where('user_id', $userid);
$this->db->join('dxcc_entities','station_profile.station_dxcc = dxcc_entities.adif','left outer');
return $this->db->get('station_profile');
}
// Show all QSOs we need to send to eQSL
function eqsl_not_yet_sent($userid = null) {
$CI =& get_instance();
if ($userid == null) {
$CI->load->model('logbooks_model');
$logbooks_locations_array = $CI->logbooks_model->list_logbook_relationships($this->session->userdata('active_station_logbook'));
} else {
$stations = $this->get_all_user_locations($userid);
$logbooks_locations_array = array();
foreach ($stations->result() as $row) {
array_push($logbooks_locations_array, $row->station_id);
}
array_push($logbooks_locations_array, -9999);
}
$this->db->select('station_profile.*, '.$this->config->item('table_name').'.COL_PRIMARY_KEY, '.$this->config->item('table_name').'.COL_TIME_ON, '.$this->config->item('table_name').'.COL_CALL, '.$this->config->item('table_name').'.COL_MODE, '.$this->config->item('table_name').'.COL_SUBMODE, '.$this->config->item('table_name').'.COL_BAND, '.$this->config->item('table_name').'.COL_COMMENT, '.$this->config->item('table_name').'.COL_RST_SENT, '.$this->config->item('table_name').'.COL_PROP_MODE, '.$this->config->item('table_name').'.COL_SAT_NAME, '.$this->config->item('table_name').'.COL_SAT_MODE, '.$this->config->item('table_name').'.COL_QSLMSG');
$this->db->from('station_profile');
$this->db->join($this->config->item('table_name'),'station_profile.station_id = '.$this->config->item('table_name').'.station_id');
$this->db->where("coalesce(station_profile.eqslqthnickname, '') <> ''");
$this->db->where($this->config->item('table_name').'.COL_CALL !=', '');
$this->db->group_start();
$this->db->where($this->config->item('table_name').'.COL_EQSL_QSL_SENT is null');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', '');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'R');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'Q');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'N');
$this->db->group_end();
if (!empty($logbooks_locations_array)) {
$this->db->where_in('station_profile.station_id', $logbooks_locations_array);
} else {
// Option 1: Skip the query altogether (return no results)
return [];
}
return $this->db->get();
}
// Show all QSOs for a specific station location that we need to send to eQSL
function eqsl_not_yet_sent_for_station($station_id, $qth_nickname = null) {
$station_id = (int) $station_id;
if ($station_id <= 0) {
return array();
}
$this->db->select('station_profile.*, '.$this->config->item('table_name').'.COL_PRIMARY_KEY, '.$this->config->item('table_name').'.COL_TIME_ON, '.$this->config->item('table_name').'.COL_CALL, '.$this->config->item('table_name').'.COL_MODE, '.$this->config->item('table_name').'.COL_SUBMODE, '.$this->config->item('table_name').'.COL_BAND, '.$this->config->item('table_name').'.COL_COMMENT, '.$this->config->item('table_name').'.COL_RST_SENT, '.$this->config->item('table_name').'.COL_PROP_MODE, '.$this->config->item('table_name').'.COL_SAT_NAME, '.$this->config->item('table_name').'.COL_SAT_MODE, '.$this->config->item('table_name').'.COL_QSLMSG');
$this->db->from('station_profile');
$this->db->join($this->config->item('table_name'),'station_profile.station_id = '.$this->config->item('table_name').'.station_id');
$this->db->where('station_profile.station_id', $station_id);
// Mapping mode resolves QTH nickname from eqsl_mappings, not station_profile.
// Do not filter by station_profile.eqslqthnickname here.
$this->db->where($this->config->item('table_name').'.COL_CALL !=', '');
$this->db->group_start();
$this->db->where($this->config->item('table_name').'.COL_EQSL_QSL_SENT is null');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', '');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'R');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'Q');
$this->db->or_where($this->config->item('table_name').'.COL_EQSL_QSL_SENT', 'N');
$this->db->group_end();
return $this->db->get();
}
// Show all QSOs whose eQSL card images we did not download yet
function eqsl_not_yet_downloaded($userid = null) {
$CI =& get_instance();
if ($userid == null) {
$CI->load->model('logbooks_model');
$logbooks_locations_array = $CI->logbooks_model->list_logbook_relationships($this->session->userdata('active_station_logbook'));
} else {
$stations = $this->get_all_user_locations($userid);
$logbooks_locations_array = array();
foreach ($stations->result() as $row) {
array_push($logbooks_locations_array, $row->station_id);
}
array_push($logbooks_locations_array, -9999);
}
$this->db->select('station_profile.station_id, '.$this->config->item('table_name').'.COL_PRIMARY_KEY, '.$this->config->item('table_name').'.COL_TIME_ON, '.$this->config->item('table_name').'.COL_CALL, '.$this->config->item('table_name').'.COL_MODE, '.$this->config->item('table_name').'.COL_SUBMODE, '.$this->config->item('table_name').'.COL_BAND, '.$this->config->item('table_name').'.COL_PROP_MODE, '.$this->config->item('table_name').'.COL_SAT_NAME, '.$this->config->item('table_name').'.COL_SAT_MODE, '.$this->config->item('table_name').'.COL_QSLMSG, eQSL_images.qso_id');
$this->db->from('station_profile');
$this->db->join($this->config->item('table_name'),'station_profile.station_id = '.$this->config->item('table_name').'.station_id');
$this->db->join('eQSL_images','eQSL_images.qso_id = '.$this->config->item('table_name').'.COL_PRIMARY_KEY','left outer');
//$this->db->where("coalesce(station_profile.eqslqthnickname, '') <> ''");
$this->db->where($this->config->item('table_name').'.COL_CALL !=', '');
$this->db->where($this->config->item('table_name').'.COL_EQSL_QSL_RCVD', 'Y');
$this->db->where('qso_id', NULL);
if (!empty($logbooks_locations_array)) {
$this->db->where_in('station_profile.station_id', $logbooks_locations_array);
} else {
// Option 1: Skip the query altogether (return no results)
return [];
}
$this->db->order_by("COL_TIME_ON", "desc");
return $this->db->get();
}
// Show all QSOs with received eQSL for mapped stations whose card images are not downloaded yet
function eqsl_not_yet_downloaded_for_station_ids($station_ids) {
if (!is_array($station_ids) || empty($station_ids)) {
return array();
}
$station_ids = array_map('intval', $station_ids);
$station_ids = array_values(array_unique(array_filter($station_ids, function($id) {
return $id > 0;
})));
if (empty($station_ids)) {
return array();
}
$this->db->select('station_profile.station_id, '.$this->config->item('table_name').'.COL_PRIMARY_KEY, '.$this->config->item('table_name').'.COL_TIME_ON, '.$this->config->item('table_name').'.COL_CALL, '.$this->config->item('table_name').'.COL_MODE, '.$this->config->item('table_name').'.COL_SUBMODE, '.$this->config->item('table_name').'.COL_BAND, '.$this->config->item('table_name').'.COL_PROP_MODE, '.$this->config->item('table_name').'.COL_SAT_NAME, '.$this->config->item('table_name').'.COL_SAT_MODE, '.$this->config->item('table_name').'.COL_QSLMSG, eQSL_images.qso_id');
$this->db->from('station_profile');
$this->db->join($this->config->item('table_name'),'station_profile.station_id = '.$this->config->item('table_name').'.station_id');
$this->db->join('eQSL_images','eQSL_images.qso_id = '.$this->config->item('table_name').'.COL_PRIMARY_KEY','left outer');
$this->db->where_in('station_profile.station_id', $station_ids);
$this->db->where($this->config->item('table_name').'.COL_CALL !=', '');
$this->db->where($this->config->item('table_name').'.COL_EQSL_QSL_RCVD', 'Y');
$this->db->where('qso_id', NULL);
$this->db->order_by("COL_TIME_ON", "desc");
return $this->db->get();
}
// Mark the QSO as sent to eQSL
function eqsl_mark_sent($primarykey) {
$data = array(
'COL_EQSL_QSLSDATE' => date('Y-m-d H:i:s'), // eQSL doesn't give us a date, so let's use current
'COL_EQSL_QSL_SENT' => 'Y',
);
$this->db->where('COL_PRIMARY_KEY', $primarykey);
$this->db->update($this->config->item('table_name'), $data);
return "eQSL Sent";
}
// Returns all the distinct callsign, eqsl nick pair for the current user/supplied user
function all_of_user_with_eqsl_nick_defined($userid = null) {
if ($userid == null) {
$this->db->where('user_id', $this->session->userdata('user_id'));
} else {
$this->db->where('user_id', $userid);
}
$this->db->where('eqslqthnickname IS NOT NULL');
$this->db->where('eqslqthnickname !=', '');
$this->db->from('station_profile');
$this->db->select('station_callsign, eqslqthnickname, station_id');
$this->db->distinct(TRUE);
return $this->db->get();
}
// Get the last date we received an eQSL
function eqsl_last_qsl_rcvd_date($callsign, $nickname) {
$qso_table_name = $this->config->item('table_name');
$this->db->from($qso_table_name);
$this->db->join('station_profile',
'station_profile.station_id = '.$qso_table_name.'.station_id AND station_profile.eqslqthnickname != ""');
$this->db->where('station_profile.station_callsign', $callsign);
$this->db->where('station_profile.eqslqthnickname', $nickname);
$this->db->select("DATE_FORMAT(COL_EQSL_QSLRDATE,'%Y%m%d') AS COL_EQSL_QSLRDATE", FALSE);
$this->db->where('COL_EQSL_QSLRDATE IS NOT NULL');
$this->db->order_by("COL_EQSL_QSLRDATE", "desc");
$this->db->limit(1);
$query = $this->db->get();
$row = $query->row();
if (isset($row->COL_EQSL_QSLRDATE)){
return $row->COL_EQSL_QSLRDATE;
} else {
// No previous date (first time import has run?), so choose UNIX EPOCH!
// Note: date is yyyy/mm/dd format
return '19700101';
}
}
// Update a QSO with eQSL QSL info
// We could also probably use this:
// https://eqsl.cc/qslcard/VerifyQSO.txt
// https://www.eqsl.cc/qslcard/ImportADIF.txt
function eqsl_update($datetime, $callsign, $band, $mode, $qsl_status, $station_callsign, $station_id) {
$data = array(
'COL_EQSL_QSLRDATE' => date('Y-m-d H:i:s'), // eQSL doesn't give us a date, so let's use current
'COL_EQSL_QSL_RCVD' => $qsl_status
);
$this->db->where('COL_TIME_ON >= DATE_ADD(DATE_FORMAT("'.$datetime.'", \'%Y-%m-%d %H:%i\' ), INTERVAL -15 MINUTE )');
$this->db->where('COL_TIME_ON <= DATE_ADD(DATE_FORMAT("'.$datetime.'", \'%Y-%m-%d %H:%i\' ), INTERVAL 15 MINUTE )');
$this->db->where('COL_CALL', $callsign);
$this->db->where('COL_STATION_CALLSIGN', $station_callsign);
$this->db->where('COL_BAND', $band);
$this->db->where('COL_MODE', $mode);
$this->db->where('station_id', $station_id);
$this->db->update($this->config->item('table_name'), $data);
return "Updated";
}
// Determine if we've already received an eQSL for this QSO
function eqsl_dupe_check($datetime, $callsign, $band, $mode, $qsl_status, $station_callsign, $station_id) {
$this->db->select('COL_EQSL_QSLRDATE');
$this->db->where('COL_TIME_ON >= DATE_ADD(DATE_FORMAT("'.$datetime.'", \'%Y-%m-%d %H:%i\' ), INTERVAL -15 MINUTE )');
$this->db->where('COL_TIME_ON <= DATE_ADD(DATE_FORMAT("'.$datetime.'", \'%Y-%m-%d %H:%i\' ), INTERVAL 15 MINUTE )');
$this->db->where('COL_CALL', $callsign);
$this->db->where('COL_BAND', $band);
$this->db->where('COL_MODE', $mode);
$this->db->where('COL_STATION_CALLSIGN', $station_callsign);
$this->db->where('COL_EQSL_QSL_RCVD', $qsl_status);
$this->db->where('station_id', $station_id);
$this->db->limit(1);
$query = $this->db->get($this->config->item('table_name'));
$row = $query->row();
if ($row != null) {
return true;
}
return false;
}
/*
* Batch update multiple QSOs from eQSL confirmation imports
* Replaces N individual eqsl_update() calls with batch operations
* Provides massive performance improvement for large eQSL imports
*
* @param array $records Array of eQSL confirmation records with keys:
* datetime, callsign, band, mode, qsl_status, station_callsign, station_id
* @return array Statistics array with 'updated', 'duplicates', 'errors' counts
*/
function eqsl_update_batch($records)
{
if (empty($records) || !is_array($records)) {
log_message('debug', 'eQSL batch update: No records provided');
return array('updated' => 0, 'duplicates' => 0, 'errors' => 0, 'updated_ids' => array(), 'duplicate_ids' => array());
}
$record_count = count($records);
log_message('info', "eQSL batch update: Processing {$record_count} confirmation records");
$table_name = $this->config->item('table_name');
// Fetch current eQSL status for all QSOs by primary key
// (primary keys were already resolved by import_check, avoiding a re-query with un-normalized mode)
$qso_ids = array_column($records, 'qso_id');
$this->db->select('COL_PRIMARY_KEY, COL_EQSL_QSL_RCVD, COL_EQSL_QSLRDATE');
$this->db->where_in('COL_PRIMARY_KEY', $qso_ids);
$query = $this->db->get($table_name);
$current_status = array();
foreach ($query->result() as $row) {
$current_status[$row->COL_PRIMARY_KEY] = $row;
}
$batch_updates = array();
$duplicates = 0;
$duplicate_ids = array();
foreach ($records as $record) {
$qso_id = $record['qso_id'];
$qsl_status = $record['qsl_status'];
if (isset($current_status[$qso_id])) {
$current = $current_status[$qso_id];
// Skip if already confirmed with the same status (duplicate)
if ($current->COL_EQSL_QSL_RCVD == $qsl_status && !empty($current->COL_EQSL_QSLRDATE)) {
$duplicates++;
$duplicate_ids[] = $qso_id;
continue;
}
}
$batch_updates[] = array(
'COL_PRIMARY_KEY' => $qso_id,
'COL_EQSL_QSLRDATE' => date('Y-m-d H:i:s'),
'COL_EQSL_QSL_RCVD' => $qsl_status,
);
}
$updated_ids = array();
if (!empty($batch_updates)) {
$this->db->update_batch($table_name, $batch_updates, 'COL_PRIMARY_KEY');
// Use count of prepared records rather than affected_rows() which is unreliable
// after update_batch() (returns only last batch count in CI3)
$updated_ids = array_column($batch_updates, 'COL_PRIMARY_KEY');
log_message('info', 'eQSL batch update: Updated ' . count($updated_ids) . ' QSO records, ' . $duplicates . ' duplicates skipped');
}
return array(
'updated' => count($updated_ids),
'duplicates' => $duplicates,
'errors' => 0,
'updated_ids' => $updated_ids,
'duplicate_ids' => $duplicate_ids,
);
}
/*
* Batch mark multiple QSOs as sent to eQSL
* Replaces N individual eqsl_mark_sent() calls with single batch operation
*
* @param array $qso_ids Array of QSO primary keys to mark as sent
* @return int Number of rows affected
*/
function eqsl_mark_sent_batch($qso_ids)
{
// Return early if no QSOs to update
if (empty($qso_ids) || !is_array($qso_ids)) {
log_message('debug', 'eQSL batch mark sent: No QSO IDs provided');
return 0;
}
// Sanitize the QSO IDs to prevent SQL injection
$qso_ids = array_map('intval', $qso_ids);
$qso_ids = array_filter($qso_ids, function($id) { return $id > 0; });
if (empty($qso_ids)) {
log_message('warning', 'eQSL batch mark sent: All QSO IDs were invalid');
return 0;
}
$qso_count = count($qso_ids);
log_message('info', "eQSL batch mark sent: Processing {$qso_count} QSOs");
// Use CodeIgniter's query builder for safe batch update
$this->db->set('COL_EQSL_QSLSDATE', date('Y-m-d H:i:s'));
$this->db->set('COL_EQSL_QSL_SENT', 'Y');
$this->db->where_in('COL_PRIMARY_KEY', $qso_ids);
$this->db->update($this->config->item('table_name'));
$affected_rows = $this->db->affected_rows();
if ($affected_rows != $qso_count) {
log_message('warning', "eQSL batch mark sent: Expected to update {$qso_count} QSOs but affected {$affected_rows}");
} else {
log_message('info', "eQSL batch mark sent: Successfully marked {$affected_rows} QSOs as sent");
}
return $affected_rows;
}
}
?>
Reference in a new issue View git blame Copy permalink