@@ -11,3 +11,10 @@ services:

     vonRotenberg\WeinanlieferungBundle\Migration\RebsortenMigration:

         tags:

             - { name: contao.migration, priority: 0 }

+

+    vonrotenberg.cron.wa_booking_notifications:

+        class: vonRotenberg\WeinanlieferungBundle\Cron\SendBookingChangeNotificationJob

+        public: true

+        arguments:

+            - "@database_connection"

+            - "@logger"

@@ -32,3 +32,66 @@ $GLOBALS['TL_MODELS']['tl_vr_wa_rebsorte'] = WeinanlieferungRebsorteModel::class

 $GLOBALS['TL_MODELS']['tl_vr_wa_leseart'] = WeinanlieferungLeseartModel::class;

 $GLOBALS['TL_MODELS']['tl_vr_wa_lage'] = WeinanlieferungLageModel::class;

 $GLOBALS['TL_MODELS']['tl_vr_wa_reservation'] = WeinanlieferungReservationModel::class;

+

+

+// Notification

+$GLOBALS['NOTIFICATION_CENTER']['NOTIFICATION_TYPE']['weinanlieferung']['wa_booking_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'

+    ),

+    '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_behaelter',

+        'slot_sorten',

+        'slot_ernteart',

+        'slot_lage',

+        'slot_anmerkungen',

+        'booking_behaelter',

+        'booking_sorten',

+        'booking_ernteart',

+        'booking_lage',

+    ),

+    '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_behaelter',

+        'slot_sorten',

+        'slot_ernteart',

+        'slot_lage',

+        'slot_anmerkungen',

+        'booking_behaelter',

+        'booking_sorten',

+        'booking_ernteart',

+        'booking_lage',

+    )

+);

new file mode 100644

@@ -0,0 +1,26 @@

+<?php

+

+/*

+ * This file is part of contao-weinanlieferung-bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license commercial

+ */

+

+use Contao\CoreBundle\DataContainer\PaletteManipulator;

+

+PaletteManipulator::create()

+    ->addField('memberno','personal_legend',PaletteManipulator::POSITION_APPEND)

+    ->applyToPalette('default','tl_member');

+

+

+$GLOBALS['TL_DCA']['tl_member']['fields']['memberno'] = array

+(

+    'label'                 => &$GLOBALS['TL_LANG']['tl_member']['memberno'],

+    'exclude'               => true,

+    'search'                => true,

+    'inputType'             => 'text',

+    'eval'                  => array('maxlength'=>16, 'tl_class'=>'w50'),

+    'sql'                   => "varchar(16) NOT NULL default ''",

+);

@@ -125,6 +125,10 @@ $GLOBALS['TL_DCA']['tl_vr_wa_reservation'] = array

         (

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

         ),

+        'nc_sent'      => array

+        (

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

+        ),

         'uid'         => array

         (

             'exclude'                 => true,

@@ -104,12 +104,14 @@ $GLOBALS['TL_DCA']['tl_vr_wa_standort'] = array

     // Palettes

     'palettes' => array

     (

-        'default' => '{title_legend},title'

+        '__selector__' => ['nc_enable'],

+        'default' => '{title_legend},title;{notification_legend},nc_enable'

     ),

     // Subpalettes

     'subpalettes' => array

     (

+        'nc_enable' => 'nc_notification'

     ),

     // Fields

@@ -135,6 +137,20 @@ $GLOBALS['TL_DCA']['tl_vr_wa_standort'] = array

                 'maxlength' => 255

             ),

             'sql'                     => "varchar(255) NOT NULL default ''"

+        ),

+        'nc_enable' => array

+        (

+            'exclude'                 => true,

+            'inputType'               => 'checkbox',

+            'eval'                    => array('tl_class'=>'w50 m12','submitOnChange'=>true),

+            'sql'                     => "char(1) NOT NULL default ''"

+        ),

+        'nc_notification' => array

+        (

+            'exclude'                   => true,

+            'inputType'                 => 'select',

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

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

         )

     )

 );

new file mode 100644

@@ -0,0 +1,12 @@

+<?php

+

+/**

+ * This file is part of contao-weinanlieferung-bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license commercial

+ */

+

+$GLOBALS['TL_LANG']['tl_member']['memberno'][0] = 'Mitgliedsnummer';

+$GLOBALS['TL_LANG']['tl_member']['memberno'][1] = 'Die Mitgliedsnummer des Winzers.';

new file mode 100644

@@ -0,0 +1,13 @@

+<?php

+

+/**

+ * This file is part of contao-weinanlieferung-bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license commercial

+ */

+

+$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.';

@@ -10,8 +10,13 @@

 $GLOBALS['TL_LANG']['tl_vr_wa_standort']['title'][0] = 'Titel';

 $GLOBALS['TL_LANG']['tl_vr_wa_standort']['title'][1] = 'Der Name des Anlieferungs-Standorts.';

+$GLOBALS['TL_LANG']['tl_vr_wa_standort']['nc_enable'][0] = 'Benachrichtigungen aktivieren';

+$GLOBALS['TL_LANG']['tl_vr_wa_standort']['nc_enable'][1] = 'Ermöglicht das Versenden von Benachrichtigungen beim Veröffentlichen neuer Nachrichten.';

+$GLOBALS['TL_LANG']['tl_vr_wa_standort']['nc_notification'][0] = 'Benachrichtigung';

+$GLOBALS['TL_LANG']['tl_vr_wa_standort']['nc_notification'][1] = 'Die zu versendende Benachrichtigung.';

 $GLOBALS['TL_LANG']['tl_vr_wa_standort']['title_legend'] = 'Standort';

+$GLOBALS['TL_LANG']['tl_vr_wa_standort']['notification_legend'] = 'Benachrichtigung-Einstellungen';

 $GLOBALS['TL_LANG']['tl_vr_wa_standort']['rebsorte'] = 'Rebsorten';

 $GLOBALS['TL_LANG']['tl_vr_wa_standort']['leseart'] = 'Leseart';

new file mode 100644

@@ -0,0 +1,48 @@

+<?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;

+

+class SendBookingChangeNotificationCommand extends Command

+{

+    public function __construct(ContaoFramework $framework)

+    {

+        $this->framework = $framework;

+

+        parent::__construct();

+    }

+

+    protected function configure(): void

+    {

+        $this

+            ->setName('weinanlieferung:sendBookingNotifications')

+            ->setDescription('Sends notifications about newly added or modified bookings.')

+        ;

+    }

+

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

+    {

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

+

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

+

+        $wa_service('cli');

+

+        return 0;

+    }

+}

new file mode 100644

@@ -0,0 +1,159 @@

+<?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\WeinanlieferungStandortModel;

+

+/**

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

+ */

+class SendBookingChangeNotificationJob

+{

+    /** @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)

+    {

+        $this->logger->log(LogLevel::INFO, 'WA notifications debug', array('contao' => new ContaoContext(__METHOD__, 'CRON')));

+        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();

+

+                // Do we have updateable items

+                $Bookings = $this->db->executeQuery("SELECT r.id, r.pid, r.uid, r.behaelter, r.sorten, r.lage, r.ernteart, r.upload, s.date as 'slot_date', s.time as 'slot_time', s.behaelter as 'slot_behaelter', s.sorten as 'slot_sorten', s.ernteart as 'slot_ernteart', s.lage as 'slot_lage', s.anmerkungen as 'slot_anmerkungen' FROM tl_vr_wa_reservation r INNER JOIN tl_vr_wa_slot s ON s.id = r.pid WHERE s.pid = ? AND r.nc_sent < r.tstamp AND s.published='1'",[$Location->id]);

+

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

+                if ($Bookings->rowCount() && ($Notification = Notification::findByPk($Location->nc_notification)) !== null)

+                {

+                    foreach ($Bookings->iterateAssociative() as $Booking)

+                    {

+                        // Get group members

+                        $Member = MemberModel::findOneBy(array("id = ?", "login='1' AND (start='' OR start<='$time') AND (stop='' OR stop>'" . ($time + 60) . "') AND disable=''"), [$Booking['uid']]);

+

+                        // Send notification to member

+                        if ($Member !== null)

+                        {

+                            $arrSortenAvailable = [];

+                            $arrErnteartAvailable = [];

+                            $arrLageAvailable = [];

+                            $arrSortenBooked = [];

+                            $arrErnteartBooked = [];

+                            $arrLageBooked = [];

+

+                            $SortenLeseart = StringUtil::deserialize($Booking['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 : '');

+                            }

+                            $SortenLeseart = explode(';',$Booking['sorten']);

+                            foreach($SortenLeseart as $sorteLeseart)

+                            {

+                                list($sorte,$leseart) = explode(',',$sorteLeseart);

+                                $objSorte = WeinanlieferungRebsorteModel::findByPk($sorte);

+                                $objLeseart = WeinanlieferungLeseartModel::findByPk($leseart);

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

+                            }

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

+                            {

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

+                            }

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

+                            {

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

+                            }

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

+                            {

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

+                                {

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

+                                }

+                            }

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

+                            {

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

+                                {

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

+                                }

+                            }

+

+                            $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(),$Booking['slot_date']),

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

+                                'slot_behaelter'     => $Booking['slot_behaelter'],

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

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

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

+                                'slot_anmerkungen'   => $Booking['slot_anmerkungen'],

+                                'booking_behaelter'  => $Booking['behaelter'],

+                                'booking_sorten'     => implode(', ',$arrSortenBooked),

+                                'booking_ernteart'   => implode(', ',$arrErnteartBooked),

+                                'booking_lage'       => implode(', ',$arrLageBooked),

+                                'admin_email'        => $admin_email,

+                            ),

+                                $GLOBALS['TL_LANGUAGE']);

+

+                            $intNotificationsCount++;

+                            $this->db->executeStatement("UPDATE tl_vr_wa_reservation SET nc_sent = ? WHERE id = ?",[$time,$Booking['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')));

+            }

+        }

+    }

+}

new file mode 100644

@@ -0,0 +1,49 @@

+<?php

+

+declare(strict_types=1);

+

+/*

+ * This file is part of contao-weinanlieferung-bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license commercial

+ */

+

+namespace vonRotenberg\WeinanlieferungBundle\EventListener\DataContainer;

+

+use Contao\CoreBundle\ServiceAnnotation\Callback;

+use Contao\DataContainer;

+use Doctrine\DBAL\Connection;

+

+class WeinanlieferungStandortContainerListener

+{

+    /** @var Connection */

+    protected $db;

+

+    public function __construct(Connection $db)

+    {

+        $this->db = $db;

+    }

+

+    /**

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

+     */

+    public function onNcNotificationOptionsCallback(DataContainer $dc)

+    {

+        $arrOptions = [];

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

+

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

+        {

+            return $arrOptions;

+        }

+

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

+        {

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

+        }

+

+        return $arrOptions;

+    }

+}