@@ -19,6 +19,13 @@ services:

             - "@database_connection"

             - "@logger"

+    vonrotenberg.cron.wa_slot_notifications:

+        class: vonRotenberg\WeinanlieferungBundle\Cron\SendSlotChangeNotificationJob

+        public: true

+        arguments:

+            - "@database_connection"

+            - "@logger"

+

     vonrotenberg.wa.slot_checker:

         class: vonRotenberg\WeinanlieferungBundle\SlotChecker

         public: true

@@ -109,3 +109,66 @@ $GLOBALS['NOTIFICATION_CENTER']['NOTIFICATION_TYPE']['weinanlieferung']['wa_book

         'booking_lage',

     )

 );

+

+$GLOBALS['NOTIFICATION_CENTER']['NOTIFICATION_TYPE']['weinanlieferung']['wa_slot_change'] = array

+(

+    'recipients'    => array

+    (

+        'member_email', // The email address of the recipient

+        'admin_email' // The email address of the recipient

+    ),

+    'email_sender_address'    => array

+    (

+        'member_email', // The email address of the recipient

+        'admin_email' // The email address of the recipient

+    ),

+    'email_sender_name'    => array

+    (

+        'member_email', // The email address of the recipient

+        'admin_email' // The email address of the recipient

+    ),

+    'email_subject'        => array

+    (

+        'domain',

+        'member_email',

+        'admin_email',

+        'slot_date',

+        'slot_time',

+        'slot_standort',

+        'slot_ncsent',

+        'slot_behaelter',

+        'slot_behaelterBuchbar',

+    ),

+    'email_text'    => array

+    (

+        'member_firstname', // The firstname of the recipient

+        'member_lastname', // The lastname of the recipient

+        'member_memberno', // The member account number of the recipient

+        'slot_date',

+        'slot_time',

+        'slot_standort',

+        'slot_behaelter',

+        'slot_behaelterBuchbar',

+        'slot_sorten',

+        'slot_ernteart',

+        'slot_lage',

+        'slot_anmerkungen',

+        'slot_ncsent',

+    ),

+    'email_html'    => array

+    (

+        'member_firstname', // The firstname of the recipient

+        'member_lastname', // The lastname of the recipient

+        'member_memberno', // The member account number of the recipient

+        'slot_date',

+        'slot_time',

+        'slot_standort',

+        'slot_behaelter',

+        'slot_behaelterBuchbar',

+        'slot_sorten',

+        'slot_ernteart',

+        'slot_lage',

+        'slot_anmerkungen',

+        'slot_ncsent',

+    )

+);

@@ -119,6 +119,11 @@ $GLOBALS['TL_DCA']['tl_vr_wa_slot'] = array

         (

             'sql' => "int(10) unsigned NOT NULL default '0'"

         ),

+        'nc_sent'      => array

+        (

+            'sql' => "int(10) unsigned NOT NULL default '0'"

+        ),

+

         'date'        => array

         (

             'exclude'   => true,

@@ -116,7 +116,7 @@ $GLOBALS['TL_DCA']['tl_vr_wa_standort'] = array

     // Subpalettes

     'subpalettes' => array

     (

-        'nc_enable' => 'nc_notification'

+        'nc_enable' => 'nc_notification,nc_notification_slots,nc_notification_groups'

     ),

     // Fields

@@ -174,6 +174,22 @@ $GLOBALS['TL_DCA']['tl_vr_wa_standort'] = array

             'inputType'                 => 'select',

             'eval'                      => array('mandatory'=>true,'includeBlankOption'=>true, 'chosen'=>true, 'tl_class'=>'w50'),

             'sql'                       => "int(10) unsigned NOT NULL default '0'"

+        ),

+        'nc_notification_slots' => array

+        (

+            'exclude'                   => true,

+            'inputType'                 => 'select',

+            'eval'                      => array('mandatory'=>true,'includeBlankOption'=>true, 'chosen'=>true, 'tl_class'=>'w50'),

+            'sql'                       => "int(10) unsigned NOT NULL default '0'"

+        ),

+        'nc_notification_groups' => array

+        (

+            'exclude'                 => true,

+            'inputType'               => 'checkbox',

+            'foreignKey'              => 'tl_member_group.name',

+            'eval'                    => array('mandatory'=>true, 'multiple'=>true,'tl_class'=>'clr'),

+            'sql'                     => "blob NULL",

+            'relation'                => array('type'=>'hasMany', 'load'=>'lazy')

         )

     )

 );

@@ -11,3 +11,5 @@

 $GLOBALS['TL_LANG']['tl_nc_notification']['type']['weinanlieferung'] = 'Weinanlieferung';

 $GLOBALS['TL_LANG']['tl_nc_notification']['type']['wa_booking_change'][0] = 'Neue Buchung / Buchungsupdate';

 $GLOBALS['TL_LANG']['tl_nc_notification']['type']['wa_booking_change'][1] = 'Wenn eine neue Buchung eingeht, oder eine vorhandene Buchung geändert wird.';

+$GLOBALS['TL_LANG']['tl_nc_notification']['type']['wa_slot_change'][0] = 'Neuer buchbarer Slot / Slot-Aktualisierung';

+$GLOBALS['TL_LANG']['tl_nc_notification']['type']['wa_slot_change'][1] = 'Wenn eine neuer buchbarer Slot zur Verfügung steht, oder ein vorhandener Slot geändert wird.';

new file mode 100644

@@ -0,0 +1,50 @@

+<?php

+

+declare(strict_types=1);

+

+/*

+ * This file is part of eSales Media SinglereisenBundle

+ *

+ * (c) Benjamin Roth

+ *

+ * @license proprietary

+ */

+

+namespace vonRotenberg\WeinanlieferungBundle\Command;

+

+use Contao\CoreBundle\Framework\ContaoFramework;

+use Contao\System;

+use Symfony\Component\Console\Command\Command;

+use Symfony\Component\Console\Input\InputInterface;

+use Symfony\Component\Console\Output\OutputInterface;

+use vonRotenberg\WeinanlieferungBundle\Cron\SendSlotChangeNotificationJob;

+

+class SendSlotChangeNotificationCommand extends Command

+{

+    public function __construct(ContaoFramework $framework)

+    {

+        $this->framework = $framework;

+

+        parent::__construct();

+    }

+

+    protected function configure(): void

+    {

+        $this

+            ->setName('luumicore:sendSlotNotifications')

+            ->setDescription('Sends notifications about newly added or modified slots once they\'re bookable.')

+        ;

+    }

+

+    protected function execute(InputInterface $input, OutputInterface $output): int

+    {

+        $this->framework->initialize();

+

+        /** @var SendSlotChangeNotificationJob $wa_service */

+        $wa_service = System::getContainer()->get("vonrotenberg.cron.wa_slot_notifications");

+

+        $wa_service('cli');

+

+        return 0;

+    }

+}

new file mode 100644

@@ -0,0 +1,161 @@

+<?php

+

+declare(strict_types=1);

+

+/*

+* This file is part of newsmailer bundle for Contao.

+*

+* (c) Benjamin Roth

+*

+* @license LGPL-3.0-or-later

+*/

+

+namespace vonRotenberg\WeinanlieferungBundle\Cron;

+

+use Contao\Config;

+use Contao\CoreBundle\Monolog\ContaoContext;

+use Contao\CoreBundle\ServiceAnnotation\CronJob;

+use Contao\Date;

+use Contao\MemberModel;

+use Contao\StringUtil;

+use Contao\System;

+use Doctrine\DBAL\Connection;

+use NotificationCenter\Model\Notification;

+use Psr\Log\LoggerInterface;

+use Psr\Log\LogLevel;

+use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungLageModel;

+use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungLeseartModel;

+use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungRebsorteModel;

+use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungSlotsModel;

+use vonRotenberg\WeinanlieferungBundle\Model\WeinanlieferungStandortModel;

+

+/**

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

+ */

+class SendSlotChangeNotificationJob

+{

+    /** @var LoggerInterface  */

+    private $logger;

+

+    /** @var Connection */

+    private $db;

+

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

+    {

+        $this->logger = $logger;

+        $this->db = $db;

+    }

+

+    public function __invoke(string $scope)

+    {

+        System::loadLanguageFile('default','de');

+        list($admin_name,$admin_email) = StringUtil::splitFriendlyEmail(Config::get('adminEmail'));

+        $intNotificationsCount = 0;

+

+        // Get locations

+        $Locations = WeinanlieferungStandortModel::findBy('nc_enable','1');

+

+        if ($Locations !== null)

+        {

+            while ($Locations->next())

+            {

+                $Location = $Locations->current();

+                $time = Date::floorToMinute();

+

+                // Get members

+                $memberGroupIds = StringUtil::deserialize($Location->nc_notification_groups,true);

+                $memberGroupSqlFragment = [];

+                if (!count($memberGroupIds))

+                {

+                    continue;

+                }

+                foreach ($memberGroupIds as $memberGroupId)

+                {

+                    $memberGroupSqlFragment[] = "`groups` LIKE '%\"$memberGroupId\"%'";

+                }

+                $Members = MemberModel::findBy(array("(".implode(' OR ',$memberGroupSqlFragment).")","(start='' OR start<='$time') AND (stop='' OR stop>'" . ($time + 60) . "') AND disable=''"),null);

+

+                // Do we have updateable items

+                $Slots = $this->db->executeQuery("SELECT s.id, s.date, s.time, s.duration, s.behaelter, s.sorten, s.ernteart, s.lage, s.anmerkungen, s.nc_sent FROM tl_vr_wa_slot s WHERE s.pid = ? AND s.nc_sent < s.tstamp AND s.published='1' AND (buchbar_ab='' OR buchbar_ab<='$time') AND (buchbar_bis='' OR buchbar_bis>'" . ($time + 60) . "')",[$Location->id]);

+

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

+                if ($Members !== null && $Slots->rowCount() && ($Notification = Notification::findByPk($Location->nc_notification_slots)) !== null)

+                {

+                    foreach ($Slots->iterateAssociative() as $Slot)

+                    {

+                        $arrSortenAvailable = [];

+                        $arrErnteartAvailable = [];

+                        $arrLageAvailable = [];

+                        $arrSortenBooked = [];

+                        $arrErnteartBooked = [];

+                        $arrLageBooked = [];

+

+                        $SlotModel = WeinanlieferungSlotsModel::findByPk($Slot['id']);

+

+                        if (isset($Slot['slot_sorten']))

+                        {

+                            $SortenLeseart = StringUtil::deserialize($Slot['sorten'],true);

+                            foreach($SortenLeseart as $sorteLeseart)

+                            {

+                                $objSorte = WeinanlieferungRebsorteModel::findByPk($sorteLeseart['sorte']);

+                                $objLeseart = WeinanlieferungLeseartModel::findByPk($sorteLeseart['leseart']);

+                                $arrSortenAvailable[$objSorte->id.','.$objLeseart->id] = ($objSorte !== null  ? $objSorte->title : '') . ' ' . ($objLeseart !== null  ? $objLeseart->title : '');

+                            }

+                        }

+                        if (isset($Slot['ernteart']))

+                        {

+                            foreach (explode(',', $Slot['ernteart']) as $ernteart)

+                            {

+                                $arrErnteartAvailable[$ernteart] = $GLOBALS['TL_LANG']['REF']['wa_ernteart'][$ernteart] ?? $ernteart;

+                            }

+                        }

+                        if (isset($Slot['lage']))

+                        {

+                            foreach (explode(',', $Slot['lage']) as $lage)

+                            {

+                                if (($Lage = WeinanlieferungLageModel::findByPk($lage)) !== null)

+                                {

+                                    $arrLageAvailable[$Lage->id] = $Lage->title;

+                                }

+                            }

+                        }

+

+                        // Send notification to member

+                        foreach ($Members as $Member)

+                        {

+                            $Notification->send(array

+                            (

+                                'member_email'          => $Member->email . ($Member->nc_news_additionalEmail ? ',' . $Member->nc_news_additionalEmail : ''),

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

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

+                                'member_memberno'       => $Member->memberno,

+                                'slot_date'             => Date::parse(Date::getNumericDateFormat(),$Slot['date']),

+                                'slot_time'             => Date::parse(Date::getNumericTimeFormat(),$Slot['time']),

+                                'slot_standort'         => $Location->title,

+                                'slot_behaelter'        => $Slot['behaelter'],

+                                'slot_behaelterBuchbar' => $SlotModel !== null ? $SlotModel->getAvailableBehaelter() : '',

+                                'slot_sorten'           => implode(', ',$arrSortenAvailable),

+                                'slot_ernteart'         => implode(', ',$arrErnteartAvailable),

+                                'slot_lage'             => implode(', ',$arrLageAvailable),

+                                'slot_anmerkungen'      => $Slot['anmerkungen'],

+                                'slot_ncsent'           => $Slot['nc_sent'],

+                                'admin_email'           => $admin_email,

+                            ),

+                                $GLOBALS['TL_LANGUAGE']);

+

+                            $intNotificationsCount++;

+                        }

+

+                        $this->db->executeStatement("UPDATE tl_vr_wa_slot SET nc_sent = ? WHERE id = ?",[$time,$Slot['id']]);

+                    }

+                }

+            }

+

+            // Flag news as sent

+            if ($intNotificationsCount)

+            {

+                $this->logger->log(LogLevel::INFO, sprintf('WA notifications(%s) has been sent',$intNotificationsCount), array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+            }

+        }

+    }

+}

@@ -46,4 +46,25 @@ class WeinanlieferungStandortContainerListener

         return $arrOptions;

     }

+

+    /**

+     * @Callback(table="tl_vr_wa_standort", target="fields.nc_notification_slots.options")

+     */

+    public function onNcNotificationSlotsOptionsCallback(DataContainer $dc)

+    {

+        $arrOptions = [];

+        $objNotifications = $this->db->executeQuery("SELECT id,title FROM tl_nc_notification WHERE type='wa_slot_change' ORDER BY title");

+

+        if (!$objNotifications->rowCount())

+        {

+            return $arrOptions;

+        }

+

+        foreach ($objNotifications->fetchAllAssociative() as $notification)

+        {

+            $arrOptions[$notification['id']] = $notification['title'];

+        }

+

+        return $arrOptions;

+    }

 }