From 71981a2a80474cd52c19ec618d534bbdf4b0a100 Mon Sep 17 00:00:00 2001
From: HB9HIL <fabian.berg@hb9hil.org>
Date: Fri, 8 Mar 2024 15:15:28 +0100
Subject: [PATCH] basic delete migration of dupe files

---
 application/migrations/186_rm_eqsl_dbl.php | 99 ++++++++++++++++++----
 1 file changed, 81 insertions(+), 18 deletions(-)

diff --git a/application/migrations/186_rm_eqsl_dbl.php b/application/migrations/186_rm_eqsl_dbl.php
index 20413a1fc..9353616ec 100644
--- a/application/migrations/186_rm_eqsl_dbl.php
+++ b/application/migrations/186_rm_eqsl_dbl.php
@@ -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;
+	  } 
+}