Public_Tools/wavelog
2
0
Fork 0
mirror of https://github.com/wavelog/wavelog.git synced 2026-03-22 10:24:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

basic delete migration of dupe files

Browse Source
This commit is contained in:
HB9HIL
2024-03-08 15:15:28 +01:00
parent 873cefc4d7
commit 71981a2a80
1 changed files with 81 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
application/migrations/186_rm_eqsl_dbl.php
View File

@@ -4,41 +4,104 @@ defined('BASEPATH') or exit('No direct script access allowed');
// Remove Dupes from eQSL-Table and add a unique idx
class Migration_rm_eqsl_dbl extends CI_Migration {
class Migration_rm_eqsl_dbl extends CI_Migration
{
public function up()
{
$dbltrbl=1;
$dbltrbl = 1;
// while ($dbltrbl>0) { // Enable this after Development // Need this to make sure we also delete eQSLs with an amount>2. So repeat until we have no more dupes
$sql='select min(id) as id,qso_id from eQSL_images group by qso_id having count(1)>1;';
$query=$this->db->query($sql);
$dbltrbl=$query->num_rows();
if ($dbltrbl > 0) {
$eqsl2del=[];
foreach ($query->result() as $row)
$eqsl2del[]=$row->id;
foreach ($eqsl2del as $oneeqsl) {
$res=$this->db->query("select image_file from eQSL_images where id=?",$oneeqsl)->result()[0]->image_file;
log_message("Error"," Need to remove file ".$res." with PK ".$oneeqsl); // Add moving of files HERE
}
foreach ($eqsl2del as $oneeqsl) {
//$this->db->query('delete from eQSL_images where id=?',$oneeqsl); // Enable this after development
$sql = 'SELECT MIN(id) as id,qso_id FROM eQSL_images GROUP BY qso_id HAVING count(1)>1;';
$query = $this->db->query($sql);
$dbltrbl = $query->num_rows();
if ($dbltrbl > 0) {
$eqsl2del = [];
foreach ($query->result() as $row)
$eqsl2del[] = $row->id;
foreach ($eqsl2del as $oneeqsl) {
$res = $this->db->query("SELECT image_file FROM eQSL_images WHERE id=?", $oneeqsl)->result()[0]->image_file;
if ($this->config->item('userdata')) {
$userdata_dir = $this->config->item('userdata');
$qso_id = $this->get_qsoid_from_eqsl_filename($res) ?? '';
// we need to get the user Id which corresponds to that particular qso
if (!empty($qso_id)) {
$get_user_id = $this->get_user_id_from_qso($qso_id);
// can be an deleted qso
if(!empty($get_user_id)) {
$user_id = $get_user_id;
} else {
$user_id = 'not_assigned';
}
} else {
$user_id = 'not_assigned';
}
// target path
$target_path = $userdata_dir . '/' . $user_id . '/eqsl_card';
// then remove the file
if (!unlink($target_path . '/' . $res)) {
log_message('error', 'Mig 186: Dupe file: "'.$target_path.'/'.$res.'" could not be deleted. There is no file with this filename');
} else {
log_message('debug', 'Mig 186: Dupe file: "'.$target_path.'/'.$res.'" were deleted because it was a dupe.');
}
} else {
// TODO: move files if userdata is disabled
}
}
foreach ($eqsl2del as $oneeqsl) {
//$this->db->query('delete from eQSL_images where id=?',$oneeqsl); // Enable this after development
}
}
// } // Enable this after development
/* Enable this after development
$index = $this->db->query("SHOW INDEX FROM eQSL_images WHERE Key_name = 'qso_id_UNIQUE'")->num_rows();
if ($index == 0) {
$this->db->query("ALTER TABLE `eQSL_images` ADD UNIQUE INDEX `qso_id_UNIQUE` (`qso_id` ASC);");
}
*/
*/
}
public function down() {
public function down()
{
$index = $this->db->query("SHOW INDEX FROM eQSL_images WHERE Key_name = 'qso_id_UNIQUE'")->num_rows();
if ($index > 0) {
$this->db->query("ALTER TABLE `eQSL_images` DROP INDEX `qso_id_UNIQUE`;");
}
}
}
function get_qsoid_from_eqsl_filename($filename)
{
$sql = "SELECT qso_id FROM eQSL_images WHERE image_file = ?";
$result = $this->db->query($sql, $filename);
$row = $result->row();
return $row->qso_id;
}
function get_user_id_from_qso($qso_id) {
$clean_qsoid = $this->security->xss_clean($qso_id);
$sql = 'SELECT station_profile.user_id
FROM '.$this->config->item('table_name').'
INNER JOIN station_profile ON ('.$this->config->item('table_name').'.station_id = station_profile.station_id)
WHERE '.$this->config->item('table_name').'.COL_PRIMARY_KEY = ?';
$result = $this->db->query($sql, $clean_qsoid);
$row = $result->row();
return $row->user_id;
}
}