FileCheckJob: added dms check

application/controllers/jobs/FileCheckJob.php

@@ -0,0 +1,122 @@
+<?php
+
+if (! defined('BASEPATH'))
+	exit('No direct script access allowed');
+
+class FileCheckJob extends CLI_Controller
+{
+	/**
+	 * Initialize FileCheckJob
+	 *
+	 * @return	void
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+	}
+
+	/**
+	 */
+	public function run()
+	{
+		$this->load->model('content/Dms_model', 'DmsModel');
+		$this->_checkFiles();
+		$this->_checkDms();
+	}
+
+	private function _checkDms($dmsIdCounter = 0, $totalFileCounter = 0, $nonExistentFiles = [])
+	{
+		$limit = 100;
+
+		// get dms entries
+		$qry = "
+			SELECT 
+				DISTINCT ON (dms_id) dms_id, vers.filename, vers.version
+			FROM
+				campus.tbl_dms
+				LEFT JOIN campus.tbl_dms_version vers USING (dms_id)
+			WHERE
+				dms_id > $dmsIdCounter
+				AND dms_id IN (395281, 395280)
+			ORDER BY
+				dms_id, vers.version DESC
+			LIMIT $limit";
+
+		$result = $this->DmsModel->execReadOnlyQuery($qry);
+
+		if (isError($result))
+		{
+			echo getError($result);
+			return;
+		}
+
+		if (!hasData($result))
+		{
+			echo "\nDMS check finished!";
+			echo "\n----------------------------------";
+			echo "\n$totalFileCounter files checked, ".count($nonExistentFiles)." file(s) exist in DMS, but not in file system:\n";
+			echo implode("\n", $nonExistentFiles)."\n";
+			return;
+		}
+
+		$data = getData($result);
+
+		$dir = DMS_PATH;
+		$dms_id = 0;
+
+		foreach ($data as $dms)
+		{
+			$dms_id = $dms->dms_id;
+			$totalFileCounter++;
+			$fullPath = $dir.$dms->filename;
+			//echo "Checking dms entry with id $dms_id...\n";
+			if (!file_exists($fullPath))
+			{
+				$nonExistentFiles[] = $fullPath;
+			}
+		}
+
+		$this->_checkDms($dms_id, $totalFileCounter, $nonExistentFiles);
+	}
+
+	/**
+	 * 
+	 * @param
+	 * @return object success or error
+	 */
+	private function _checkFiles()
+	{
+		$missingDms = [];
+		$count = 0;
+
+		$dir = DMS_PATH;
+
+		$it = new RecursiveDirectoryIterator($dir);
+
+		foreach (new RecursiveIteratorIterator($it) as $file) {
+			if($file->isDir()) continue;
+			$filename = $file->getFilename();
+			//echo "Checking $filename...\n";
+			$this->DmsModel->addSelect('dms_id');
+			$this->DmsModel->addJoin('campus.tbl_dms_version', 'dms_id');
+			$result = $this->DmsModel->loadWhere(['filename' => $filename]);
+
+			if (isError($result))
+			{
+				echo getError($result);
+				continue;
+			}
+
+			if (!hasData($result))
+			{
+				$missingDms[] = $filename;
+			}
+			$count++;
+		}
+
+		echo "\nFile system check finished!";
+		echo "\n----------------------------------";
+		echo "\n$count files checked, ".count($missingDms)." file(s) exist in file system, but not in database:\n";
+		echo $dir.implode("\n$dir", $missingDms)."\n";
+	}
+}