@@ -207,7 +207,10 @@ class SecureDownloadsJob

                 // Continue if no member found

                 if ($objMember === null) {

-                    $this->logger->log(LogLevel::WARNING, sprintf('Could not find member for file "%s". (%s) [%s]', $objFile->name, implode(' AND ',$arrColumns),implode(', ',$arrValues)), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                    if (System::getContainer()->getParameter('kernel.debug'))

+                    {

+                        $this->logger->log(LogLevel::WARNING, sprintf('Could not find member for file "%s". (%s) [%s]', $objFile->name, implode(' AND ',$arrColumns),implode(', ',$arrValues)), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                    }

                     continue;

                 }

@@ -95,7 +95,7 @@ class SecureDownloadsJob

                                     'member_firstname' => $Member->firstname,

                                     'member_lastname' => $Member->lastname,

                                     'downloads' => implode("\n",$arrDownloads),

-                                    'downloads_html' => "<ul>\n<li>".implode("</li>\n<li>",$arrDownloads)."</li>\n</ul>"

+                                    'downloads_html' => "<ul class='vault_list'>\n<li>".implode("</li>\n<li>",$arrDownloads)."</li>\n</ul>"

                                 ),$GLOBALS['TL_LANGUAGE']);

                             }

@@ -32,14 +32,13 @@ use Psr\Log\LoggerInterface;

 use Psr\Log\LogLevel;

 use vonRotenberg\MemberfilesBundle\Model\MemberfilesConfigModel;

+/**

+ * Cron job for importing member files and sending notifications

+ */

 class SecureDownloadsJob

 {

-

-    /** @var LoggerInterface */

-    private $logger;

-

-    /** @var Connection */

-    protected $db;

+    private LoggerInterface $logger;

+    private Connection $db;

     public function __construct(Connection $db, LoggerInterface $logger)

     {

@@ -48,33 +47,39 @@ class SecureDownloadsJob

     }

     /**

+     * Send email notifications about new files to members

+     * Runs every 10 minutes

+     *

      * @CronJob("*\/10 * * * *")

      */

-    public function sendFileNotifications(string $scope)

+    public function sendFileNotifications(string $scope): void

     {

-        // Get archives with notifications enabled

+        // Get configurations with notifications enabled

         $Configurations = MemberfilesConfigModel::findBy(["hasNotification = ?", "enabled = ?"], ['1','1']);

         if ($Configurations !== null)

         {

             while ($Configurations->next())

             {

-                // Do we have new items

+                // Check for members with unsent file notifications

                 $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid");

-                // Load groups and notification models if we have news to share

+                // Send notifications if there are new files and notification is configured

                 if ($Members->rowCount() && ($Notification = Notification::findByPk($Configurations->notification)) !== null)

                 {

                     foreach ($Members->iterateAssociative() as $member)

                     {

+                        // Only process active members with valid email addresses

                         if (($Member = MemberModel::findOneBy(array("disable != '1'","login = '1'","email LIKE '%@%'","id = ?"),array($member['pid']))) !== null)

                         {

+                            // Get all unsent files for this member

                             $Files = $this->db->executeQuery("SELECT s.id, f.uuid, s.ctime FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.pid = ? AND s.nc_sent != '1' ORDER BY s.ctime DESC, f.name",[$Member->id]);

                             $arrFileIds = [];

                             if ($Files->rowCount())

                             {

                                 $arrDownloads = array();

+                                // Build list of files for notification email

                                 foreach ($Files->iterateAssociative() as $file)

                                 {

                                     if (($File = FilesModel::findByUuid($file['uuid'])) !== null)

@@ -94,8 +99,14 @@ class SecureDownloadsJob

                                 ),$GLOBALS['TL_LANGUAGE']);

                             }

-                            // Flag news as sent

-                            $this->db->executeStatement("UPDATE tl_member_secureDownloads SET nc_sent = '1' WHERE id IN (" . implode(',', $arrFileIds) . ")");

+                            // Flag notifications as sent

+                            if (!empty($arrFileIds)) {

+                                $placeholders = implode(',', array_fill(0, count($arrFileIds), '?'));

+                                $this->db->executeStatement(

+                                    "UPDATE tl_member_secureDownloads SET nc_sent = '1' WHERE id IN ($placeholders)",

+                                    $arrFileIds

+                                );

+                            }

                         }

                     }

                     $this->logger->log(LogLevel::INFO, 'Secure downloads notifications has been sent (' . $Members->rowCount() . ')', array('contao' => new ContaoContext(__METHOD__, 'CRON')));

@@ -105,22 +116,25 @@ class SecureDownloadsJob

     }

     /**

+     * Import files from source folders and assign them to members

+     * Runs every minute

+     *

      * @CronJob("* * * * *")

      */

-    public function importFiles(string $scope)

+    public function importFiles(string $scope): void

     {

         $projectDir = System::getContainer()->getParameter('kernel.project_dir');

         $Configurations = MemberfilesConfigModel::findAll();

         $intFileCount = 0;

-        // No root pages available

+        // Exit if no configurations available

         if ($Configurations === null)

         {

             return;

         }

-        // Iterate page roots

+        // Process each configuration

         while ($Configurations->next())

         {

             if (System::getContainer()->getParameter('kernel.debug'))

@@ -138,14 +152,14 @@ class SecureDownloadsJob

             $Source = FilesModel::findByUuid($Configurations->source);

             $Target = FilesModel::findByUuid($Configurations->target);

-            // Continue if folder doesn't exist

+            // Continue if source or target folder doesn't exist

             if ($Source === null || !file_exists($projectDir . "/".$Source->path) || $Target === null || !file_exists($projectDir . "/".$Target->path))

             {

-                $this->logger->log(LogLevel::WARNING, sprintf('Source or target folder is missing for page root %s. %s %s', $Configurations->title,$Source->path,$Target->path), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                $this->logger->log(LogLevel::WARNING, sprintf('Source or target folder is missing for configuration %s. %s %s', $Configurations->title,$Source->path,$Target->path), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

                 continue;

             }

-            // Read files inside folder

+            // Read files from source folder

             $Files = FilesModel::findByPid($Source->uuid);

             // Continue if folder is empty

@@ -174,14 +188,14 @@ class SecureDownloadsJob

                 $objFile = new File($Files->path);

-                // Check for fragments

+                // Extract member identifier from filename using regex

                 if (!preg_match('/'.$Configurations->regexp.'/U',$objFile->filename,$fragments))

                 {

                     $this->logger->log(LogLevel::WARNING, sprintf('File "%s" is missing a member fragment or has the wrong syntax.', $objFile->name), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

                     continue;

                 }

-                // Find member

+                // Find member based on extracted fragments

                 $arrColumns = array();

                 $arrValues = array();

                 foreach (StringUtil::deserialize($Configurations->fields, true) as $i => $field)

@@ -197,11 +211,11 @@ class SecureDownloadsJob

                     continue;

                 }

-                // Remove fragments from file name

+                // Remove member identifier fragments from filename

                 $baseFilename = preg_replace('/'.$Configurations->regexp.'/U','',$objFile->filename);

                 $sanitizedFilename = $baseFilename.'.'.$objFile->extension;

-                // Check or create folder structure

+                // Create organized folder structure (groups of 100 members per folder)

                 $strSubFolder = sprintf("%03d",ceil(($objMember->id+1)/100)-1).'/'.$objMember->id;

                 $strTargetFolder = $Target->path.'/'.$strSubFolder;

@@ -233,17 +247,16 @@ class SecureDownloadsJob

                 $File = Dbafs::addResource($strTargetFolder.'/'.$sanitizedFilename,false);

-                // Add file to DB and delete source

+                // Register file in database for member

                 $arrData = array(

                     'pid'     => $objMember->id,

                     'uuid'    => ($File !== null ? $File->uuid : ''),

                     'tstamp'  => time(),

                     'ctime'   => time(),

-//          'name'    => $sanitizedFilename,

-//          'path'    => $strTargetFolder.'/'.$sanitizedFilename

                 );

                 $this->db->insert('tl_member_secureDownloads',$arrData);

+                // Delete source file after successful import

                 if (!$objFile->delete()) {

                     $this->logger->log(LogLevel::WARNING, sprintf('Could not delete source file "%s" for member ID "%s".', $objFile->name, $objMember->id), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

                 }

@@ -63,7 +63,7 @@ class SecureDownloadsJob

                 $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid");

                 // Load groups and notification models if we have news to share

-                if ($Members->rowCount() && ($Notification = Notification::findByPk($Configurations->sd_nc_notification)) !== null)

+                if ($Members->rowCount() && ($Notification = Notification::findByPk($Configurations->notification)) !== null)

                 {

                     foreach ($Members->iterateAssociative() as $member)

                     {

@@ -53,7 +53,7 @@ class SecureDownloadsJob

     public function sendFileNotifications(string $scope)

     {

         // Get archives with notifications enabled

-        $Configurations = MemberfilesConfigModel::findBy(["hasNotifications = ?", "enabled = ?"], ['1','1']);

+        $Configurations = MemberfilesConfigModel::findBy(["hasNotification = ?", "enabled = ?"], ['1','1']);

         if ($Configurations !== null)

         {

@@ -30,6 +30,7 @@ use Doctrine\DBAL\Connection;

 use NotificationCenter\Model\Notification;

 use Psr\Log\LoggerInterface;

 use Psr\Log\LogLevel;

+use vonRotenberg\MemberfilesBundle\Model\MemberfilesConfigModel;

 class SecureDownloadsJob

 {

@@ -52,17 +53,17 @@ class SecureDownloadsJob

     public function sendFileNotifications(string $scope)

     {

         // Get archives with notifications enabled

-        $Root = PageModel::findBy(array("sd_nc_enable = ?","type = 'root'"),'1');

+        $Configurations = MemberfilesConfigModel::findBy(["hasNotifications = ?", "enabled = ?"], ['1','1']);

-        if ($Root !== null)

+        if ($Configurations !== null)

         {

-            while ($Root->next())

+            while ($Configurations->next())

             {

                 // Do we have new items

                 $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid");

                 // Load groups and notification models if we have news to share

-                if ($Members->rowCount() && ($Notification = Notification::findByPk($Root->sd_nc_notification)) !== null)

+                if ($Members->rowCount() && ($Notification = Notification::findByPk($Configurations->sd_nc_notification)) !== null)

                 {

                     foreach ($Members->iterateAssociative() as $member)

                     {

@@ -108,72 +109,73 @@ class SecureDownloadsJob

      */

     public function importFiles(string $scope)

     {

-        $objRoots = PageModel::findPublishedRootPages();

+        $projectDir = System::getContainer()->getParameter('kernel.project_dir');

+        $Configurations = MemberfilesConfigModel::findAll();

         $intFileCount = 0;

         // No root pages available

-        if ($objRoots === null)

+        if ($Configurations === null)

         {

             return;

         }

         // Iterate page roots

-        while ($objRoots->next())

+        while ($Configurations->next())

         {

             if (System::getContainer()->getParameter('kernel.debug'))

             {

-                $this->logger->log(LogLevel::DEBUG, sprintf('Starting secure downloads import for %s', $objRoots->title), array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+                $this->logger->log(LogLevel::DEBUG, sprintf('Starting secure downloads import for %s', $Configurations->title), array('contao' => new ContaoContext(__METHOD__, 'CRON')));

             }

             // Continue if secure downloads is disabled

-            if (!$objRoots->secureDownloadsEnabled)

+            if (!$Configurations->enabled)

             {

                 continue;

             }

             // Get folder models

-            $objFolder = FilesModel::findByUuid($objRoots->secureDownloadsSRC);

-            $objTarget = FilesModel::findByUuid($objRoots->secureDownloadsTarget);

+            $Source = FilesModel::findByUuid($Configurations->source);

+            $Target = FilesModel::findByUuid($Configurations->target);

             // Continue if folder doesn't exist

-            if ($objFolder === null || !file_exists(TL_ROOT . "/".$objFolder->path) || $objTarget === null || !file_exists(TL_ROOT . "/".$objTarget->path))

+            if ($Source === null || !file_exists($projectDir . "/".$Source->path) || $Target === null || !file_exists($projectDir . "/".$Target->path))

             {

-                $this->logger->log(LogLevel::WARNING, sprintf('Source or target folder is missing for page root %s. %s %s', $objRoots->title,$objFolder->path,$objTarget->path), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                $this->logger->log(LogLevel::WARNING, sprintf('Source or target folder is missing for page root %s. %s %s', $Configurations->title,$Source->path,$Target->path), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

                 continue;

             }

             // Read files inside folder

-            $objFiles = FilesModel::findByPid($objFolder->uuid);

+            $Files = FilesModel::findByPid($Source->uuid);

             // Continue if folder is empty

-            if ($objFiles === null)

+            if ($Files === null)

             {

                 continue;

             }

             // Escape single quotes in fragment regexp

-            $objRoots->secureDownloadsRegExp = addcslashes($objRoots->secureDownloadsRegExp,'\'');

+            $Configurations->regexp = addcslashes($Configurations->regexp,'\'');

             // Iterate files

-            while ($objFiles->next())

+            while ($Files->next())

             {

                 // Skip subfolders and special files

-                if ($objFiles->type == 'folder' || strpos($objFiles->name,'.') === 0)

+                if ($Files->type == 'folder' || strpos($Files->name,'.') === 0)

                 {

                     continue;

                 }

                 // Continue if file doesn't exist

-                if (!file_exists(TL_ROOT . "/".$objFiles->path))

+                if (!file_exists($projectDir . "/".$Files->path))

                 {

                     continue;

                 }

-                $objFile = new File($objFiles->path);

+                $objFile = new File($Files->path);

                 // Check for fragments

-                if (!preg_match('/'.$objRoots->secureDownloadsRegExp.'/U',$objFile->filename,$fragments))

+                if (!preg_match('/'.$Configurations->regexp.'/U',$objFile->filename,$fragments))

                 {

                     $this->logger->log(LogLevel::WARNING, sprintf('File "%s" is missing a member fragment or has the wrong syntax.', $objFile->name), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

                     continue;

@@ -182,7 +184,7 @@ class SecureDownloadsJob

                 // Find member

                 $arrColumns = array();

                 $arrValues = array();

-                foreach (StringUtil::deserialize($objRoots->secureDownloadsFields, true) as $i => $field)

+                foreach (StringUtil::deserialize($Configurations->fields, true) as $i => $field)

                 {

                     $arrColumns[] = "$field = ?";

                     $arrValues[] = $fragments[$i+1];

@@ -196,19 +198,19 @@ class SecureDownloadsJob

                 }

                 // Remove fragments from file name

-                $baseFilename = preg_replace('/'.$objRoots->secureDownloadsRegExp.'/U','',$objFile->filename);

+                $baseFilename = preg_replace('/'.$Configurations->regexp.'/U','',$objFile->filename);

                 $sanitizedFilename = $baseFilename.'.'.$objFile->extension;

                 // Check or create folder structure

                 $strSubFolder = sprintf("%03d",ceil(($objMember->id+1)/100)-1).'/'.$objMember->id;

-                $strTargetFolder = $objTarget->path.'/'.$strSubFolder;

+                $strTargetFolder = $Target->path.'/'.$strSubFolder;

                 $arrFolders = explode('/',$strTargetFolder);

                 $strStartPath = '';

                 foreach ($arrFolders as $folder)

                 {

-                    if (!is_dir(TL_ROOT . '/' . $strStartPath . $folder))

+                    if (!is_dir($projectDir . '/' . $strStartPath . $folder))

                     {

                         Files::getInstance()->mkdir($strStartPath . $folder);

                     }

@@ -217,7 +219,7 @@ class SecureDownloadsJob

                 // Do not overwrite existing files

                 $copyId = 1;

-                while(file_exists(TL_ROOT . "/".$strTargetFolder.'/'.$sanitizedFilename))

+                while(file_exists($projectDir . "/".$strTargetFolder.'/'.$sanitizedFilename))

                 {

                     $sanitizedFilename = $baseFilename.'_'.$copyId++.'.'.$objFile->extension;

                 }

@@ -196,7 +196,8 @@ class SecureDownloadsJob

                 }

                 // Remove fragments from file name

-                $sanitizedFilename = preg_replace('/'.$objRoots->secureDownloadsRegExp.'/U','',$objFile->filename).'.'.$objFile->extension;

+                $baseFilename = preg_replace('/'.$objRoots->secureDownloadsRegExp.'/U','',$objFile->filename);

+                $sanitizedFilename = $baseFilename.'.'.$objFile->extension;

                 // Check or create folder structure

                 $strSubFolder = sprintf("%03d",ceil(($objMember->id+1)/100)-1).'/'.$objMember->id;

@@ -216,10 +217,9 @@ class SecureDownloadsJob

                 // Do not overwrite existing files

                 $copyId = 1;

-                $baseFilename = $sanitizedFilename;

                 while(file_exists(TL_ROOT . "/".$strTargetFolder.'/'.$sanitizedFilename))

                 {

-                    $sanitizedFilename = $baseFilename.'_'.$copyId++;

+                    $sanitizedFilename = $baseFilename.'_'.$copyId++.'.'.$objFile->extension;

                 }

                 // Try to copy file

@@ -214,6 +214,14 @@ class SecureDownloadsJob

                     $strStartPath .= $folder . '/';

                 }

+                // Do not overwrite existing files

+                $copyId = 1;

+                $baseFilename = $sanitizedFilename;

+                while(file_exists(TL_ROOT . "/".$strTargetFolder.'/'.$sanitizedFilename))

+                {

+                    $sanitizedFilename = $baseFilename.'_'.$copyId++;

+                }

+

                 // Try to copy file

                 if (!Files::getInstance()->copy($objFile->path,$strTargetFolder.'/'.$sanitizedFilename))

                 {

@@ -68,14 +68,19 @@ class SecureDownloadsJob

                     {

                         if (($Member = MemberModel::findOneBy(array("disable != '1'","login = '1'","email LIKE '%@%'","id = ?"),array($member['pid']))) !== null)

                         {

-                            $Files = $this->db->executeQuery("SELECT s.id, f.name, s.ctime FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.pid = ? AND s.nc_sent != '1' ORDER BY s.ctime DESC, f.name",[$Member->id]);

+                            $Files = $this->db->executeQuery("SELECT s.id, f.uuid, s.ctime FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.pid = ? AND s.nc_sent != '1' ORDER BY s.ctime DESC, f.name",[$Member->id]);

+                            $arrFileIds = [];

                             if ($Files->rowCount())

                             {

                                 $arrDownloads = array();

-                                foreach ($Files as $file)

+                                foreach ($Files->iterateAssociative() as $file)

                                 {

-                                    $arrDownloads[] = date('d.m.Y', $file['ctime']) . " - " . $file['name'];

+                                    if (($File = FilesModel::findByUuid($file['uuid'])) !== null)

+                                    {

+                                        $arrDownloads[] = date('d.m.Y', $file['ctime']) . " - " . $File->name;

+                                        $arrFileIds[] = $file['id'];

+                                    }

                                 }

                                 $Notification->send(array

@@ -89,7 +94,6 @@ class SecureDownloadsJob

                             }

                             // Flag news as sent

-                            $arrFileIds = $Files->fetchFirstColumn();

                             $this->db->executeStatement("UPDATE tl_member_secureDownloads SET nc_sent = '1' WHERE id IN (" . implode(',', $arrFileIds) . ")");

                         }

                     }

@@ -59,12 +59,12 @@ class SecureDownloadsJob

             while ($Root->next())

             {

                 // Do we have new items

-                $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid ORDER BY s.ctime DESC, f.name");

+                $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid");

                 // Load groups and notification models if we have news to share

                 if ($Members->rowCount() && ($Notification = Notification::findByPk($Root->sd_nc_notification)) !== null)

                 {

-                    foreach ($Members as $member)

+                    foreach ($Members->iterateAssociative() as $member)

                     {

                         if (($Member = MemberModel::findOneBy(array("disable != '1'","login = '1'","email LIKE '%@%'","id = ?"),array($member['pid']))) !== null)

                         {

@@ -14,11 +14,22 @@ namespace vonRotenberg\MemberfilesBundle\Cron;

 use Contao\BackendUser;

 use Contao\Controller;

+use Contao\CoreBundle\Monolog\ContaoContext;

 use Contao\CoreBundle\ServiceAnnotation\Callback;

+use Contao\CoreBundle\ServiceAnnotation\CronJob;

 use Contao\DataContainer;

+use Contao\Dbafs;

+use Contao\File;

+use Contao\Files;

+use Contao\FilesModel;

+use Contao\MemberModel;

+use Contao\PageModel;

+use Contao\StringUtil;

 use Contao\System;

 use Doctrine\DBAL\Connection;

+use NotificationCenter\Model\Notification;

 use Psr\Log\LoggerInterface;

+use Psr\Log\LogLevel;

 class SecureDownloadsJob

 {

@@ -36,10 +47,200 @@ class SecureDownloadsJob

     }

     /**

-     * @CronJob("* * * * *")

+     * @CronJob("*\/10 * * * *")

      */

     public function sendFileNotifications(string $scope)

     {

+        // Get archives with notifications enabled

+        $Root = PageModel::findBy(array("sd_nc_enable = ?","type = 'root'"),'1');

+

+        if ($Root !== null)

+        {

+            while ($Root->next())

+            {

+                // Do we have new items

+                $Members = $this->db->executeQuery("SELECT s.pid FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.nc_sent != '1' GROUP BY s.pid ORDER BY s.ctime DESC, f.name");

+

+                // Load groups and notification models if we have news to share

+                if ($Members->rowCount() && ($Notification = Notification::findByPk($Root->sd_nc_notification)) !== null)

+                {

+                    foreach ($Members as $member)

+                    {

+                        if (($Member = MemberModel::findOneBy(array("disable != '1'","login = '1'","email LIKE '%@%'","id = ?"),array($member['pid']))) !== null)

+                        {

+                            $Files = $this->db->executeQuery("SELECT s.id, f.name, s.ctime FROM tl_member_secureDownloads s INNER JOIN tl_files f ON f.uuid = s.uuid WHERE s.pid = ? AND s.nc_sent != '1' ORDER BY s.ctime DESC, f.name",[$Member->id]);

+

+                            if ($Files->rowCount())

+                            {

+                                $arrDownloads = array();

+                                foreach ($Files as $file)

+                                {

+                                    $arrDownloads[] = date('d.m.Y', $file['ctime']) . " - " . $file['name'];

+                                }

+

+                                $Notification->send(array

+                                (

+                                    'member_email' => $Member->email,

+                                    'member_firstname' => $Member->firstname,

+                                    'member_lastname' => $Member->lastname,

+                                    'downloads' => implode("\n",$arrDownloads),

+                                    'downloads_html' => "<ul>\n<li>".implode("</li>\n<li>",$arrDownloads)."</li>\n</ul>"

+                                ),$GLOBALS['TL_LANGUAGE']);

+                            }

+

+                            // Flag news as sent

+                            $arrFileIds = $Files->fetchFirstColumn();

+                            $this->db->executeStatement("UPDATE tl_member_secureDownloads SET nc_sent = '1' WHERE id IN (" . implode(',', $arrFileIds) . ")");

+                        }

+                    }

+                    $this->logger->log(LogLevel::INFO, 'Secure downloads notifications has been sent (' . $Members->rowCount() . ')', array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+                }

+            }

+        }

+    }

+

+    /**

+     * @CronJob("* * * * *")

+     */

+    public function importFiles(string $scope)

+    {

+        $objRoots = PageModel::findPublishedRootPages();

+

+        $intFileCount = 0;

+

+        // No root pages available

+        if ($objRoots === null)

+        {

+            return;

+        }

+

+        // Iterate page roots

+        while ($objRoots->next())

+        {

+            if (System::getContainer()->getParameter('kernel.debug'))

+            {

+                $this->logger->log(LogLevel::DEBUG, sprintf('Starting secure downloads import for %s', $objRoots->title), array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+            }

+

+            // Continue if secure downloads is disabled

+            if (!$objRoots->secureDownloadsEnabled)

+            {

+                continue;

+            }

+

+            // Get folder models

+            $objFolder = FilesModel::findByUuid($objRoots->secureDownloadsSRC);

+            $objTarget = FilesModel::findByUuid($objRoots->secureDownloadsTarget);

+

+            // Continue if folder doesn't exist

+            if ($objFolder === null || !file_exists(TL_ROOT . "/".$objFolder->path) || $objTarget === null || !file_exists(TL_ROOT . "/".$objTarget->path))

+            {

+                $this->logger->log(LogLevel::WARNING, sprintf('Source or target folder is missing for page root %s. %s %s', $objRoots->title,$objFolder->path,$objTarget->path), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                continue;

+            }

+

+            // Read files inside folder

+            $objFiles = FilesModel::findByPid($objFolder->uuid);

+

+            // Continue if folder is empty

+            if ($objFiles === null)

+            {

+                continue;

+            }

+

+            // Escape single quotes in fragment regexp

+            $objRoots->secureDownloadsRegExp = addcslashes($objRoots->secureDownloadsRegExp,'\'');

+

+            // Iterate files

+            while ($objFiles->next())

+            {

+                // Skip subfolders and special files

+                if ($objFiles->type == 'folder' || strpos($objFiles->name,'.') === 0)

+                {

+                    continue;

+                }

+

+                // Continue if file doesn't exist

+                if (!file_exists(TL_ROOT . "/".$objFiles->path))

+                {

+                    continue;

+                }

+

+                $objFile = new File($objFiles->path);

+

+                // Check for fragments

+                if (!preg_match('/'.$objRoots->secureDownloadsRegExp.'/U',$objFile->filename,$fragments))

+                {

+                    $this->logger->log(LogLevel::WARNING, sprintf('File "%s" is missing a member fragment or has the wrong syntax.', $objFile->name), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                    continue;

+                }

+

+                // Find member

+                $arrColumns = array();

+                $arrValues = array();

+                foreach (StringUtil::deserialize($objRoots->secureDownloadsFields, true) as $i => $field)

+                {

+                    $arrColumns[] = "$field = ?";

+                    $arrValues[] = $fragments[$i+1];

+                }

+                $objMember = MemberModel::findOneBy($arrColumns,$arrValues);

+

+                // Continue if no member found

+                if ($objMember === null) {

+                    $this->logger->log(LogLevel::WARNING, sprintf('Could not find member for file "%s". (%s) [%s]', $objFile->name, implode(' AND ',$arrColumns),implode(', ',$arrValues)), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                    continue;

+                }

+

+                // Remove fragments from file name

+                $sanitizedFilename = preg_replace('/'.$objRoots->secureDownloadsRegExp.'/U','',$objFile->filename).'.'.$objFile->extension;

+

+                // Check or create folder structure

+                $strSubFolder = sprintf("%03d",ceil(($objMember->id+1)/100)-1).'/'.$objMember->id;

+                $strTargetFolder = $objTarget->path.'/'.$strSubFolder;

+

+                $arrFolders = explode('/',$strTargetFolder);

+                $strStartPath = '';

+

+                foreach ($arrFolders as $folder)

+                {

+                    if (!is_dir(TL_ROOT . '/' . $strStartPath . $folder))

+                    {

+                        Files::getInstance()->mkdir($strStartPath . $folder);

+                    }

+                    $strStartPath .= $folder . '/';

+                }

+

+                // Try to copy file

+                if (!Files::getInstance()->copy($objFile->path,$strTargetFolder.'/'.$sanitizedFilename))

+                {

+                    $this->logger->log(LogLevel::WARNING, sprintf('Could not import file "%s" for member ID "%s".', $objFile->name, $objMember->id), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                    continue;

+                }

+

+                $File = Dbafs::addResource($strTargetFolder.'/'.$sanitizedFilename,false);

+

+                // Add file to DB and delete source

+                $arrData = array(

+                    'pid'     => $objMember->id,

+                    'uuid'    => ($File !== null ? $File->uuid : ''),

+                    'tstamp'  => time(),

+                    'ctime'   => time(),

+//          'name'    => $sanitizedFilename,

+//          'path'    => $strTargetFolder.'/'.$sanitizedFilename

+                );

+                $this->db->insert('tl_member_secureDownloads',$arrData);

+

+                if (!$objFile->delete()) {

+                    $this->logger->log(LogLevel::WARNING, sprintf('Could not delete source file "%s" for member ID "%s".', $objFile->name, $objMember->id), array('contao' => new ContaoContext(__METHOD__, 'ERROR')));

+                }

+

+                $intFileCount++;

+            }

+        }

+        if ($intFileCount)

+        {

+            $this->logger->log(LogLevel::INFO, sprintf("Imported %s files for secure member downloads",$intFileCount), array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+        }

     }

 }

new file mode 100644

@@ -0,0 +1,45 @@

+<?php

+

+declare(strict_types=1);

+

+/*

+ * This file is part of memberfiles bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license commercial

+ */

+

+namespace vonRotenberg\MemberfilesBundle\Cron;

+

+use Contao\BackendUser;

+use Contao\Controller;

+use Contao\CoreBundle\ServiceAnnotation\Callback;

+use Contao\DataContainer;

+use Contao\System;

+use Doctrine\DBAL\Connection;

+use Psr\Log\LoggerInterface;

+

+class SecureDownloadsJob

+{

+

+    /** @var LoggerInterface */

+    private $logger;

+

+    /** @var Connection */

+    protected $db;

+

+    public function __construct(Connection $db, LoggerInterface $logger)

+    {

+        $this->logger = $logger;

+        $this->db = $db;

+    }

+

+    /**

+     * @CronJob("* * * * *")

+     */

+    public function sendFileNotifications(string $scope)

+    {

+

+    }

+}