firefly-iii/app/Jobs/WarnAboutBills.php

<?php

namespace FireflyIII\Jobs;

use Carbon\Carbon;
use FireflyIII\Events\RequestedReportOnJournals;
use FireflyIII\Events\WarnUserAboutBill;
use FireflyIII\Models\Bill;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Log;

/**
 * Class WarnAboutBills
 */
class WarnAboutBills implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    private Carbon $date;
    private bool   $force;


    /**
     * Create a new job instance.
     *
     * @codeCoverageIgnore
     *
     * @param Carbon|null $date
     */
    public function __construct(?Carbon $date)
    {
        if (null !== $date) {
            $newDate = clone $date;
            $newDate->startOfDay();
            $this->date = $newDate;
        }
        if (null === $date) {
            $newDate = new Carbon;
            $newDate->startOfDay();
            $this->date = $newDate;
        }
        $this->force = false;

        Log::debug(sprintf('Created new WarnAboutBills("%s")', $this->date->format('Y-m-d')));
    }

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        Log::debug(sprintf('Now at start of WarnAboutBills() job for %s.', $this->date->format('D d M Y')));
        $bills = Bill::all();
        /** @var Bill $bill */
        foreach ($bills as $bill) {
            Log::debug(sprintf('Now checking bill #%d ("%s")', $bill->id, $bill->name));
            if ($this->hasDateFields($bill)) {
                if ($this->needsWarning($bill, 'end_date')) {
                    $this->sendWarning($bill, 'end_date');
                }
                if ($this->needsWarning($bill, 'extension_date')) {
                    $this->sendWarning($bill, 'extension_date');
                }
            }
        }
        Log::debug('Done with handle()');

        // clear cache:
        app('preferences')->mark();
    }

    /**
     * @param Bill $bill
     * @return bool
     */
    private function hasDateFields(Bill $bill): bool
    {
        if (false === $bill->active) {
            Log::debug('Bill is not active.');
            return false;
        }
        if (null === $bill->end_date && null === $bill->extension_date) {
            Log::debug('Bill has no date fields.');
            return false;
        }
        return true;
    }

    /**
     * @param Bill   $bill
     * @param string $field
     * @return bool
     */
    private function needsWarning(Bill $bill, string $field): bool
    {
        if (null === $bill->$field) {
            return false;
        }
        $diff = $this->getDiff($bill, $field);
        $list = config('firefly.bill_reminder_periods');
        Log::debug(sprintf('Difference in days for field "%s" ("%s") is %d day(s)', $field, $bill->$field->format('Y-m-d'), $diff));
        if (in_array($diff, $list, true)) {
            return true;
        }
        return false;
    }

    /**
     * @param Bill   $bill
     * @param string $field
     * @return int
     */
    private function getDiff(Bill $bill, string $field): int
    {
        $today  = clone $this->date;
        $carbon = clone $bill->$field;
        return $today->diffInDays($carbon, false);
    }

    /**
     * @param Bill   $bill
     * @param string $field
     * @return void
     */
    private function sendWarning(Bill $bill, string $field): void
    {
        $diff = $this->getDiff($bill, $field);
        Log::debug('Will now send warning!');
        event(new WarnUserAboutBill($bill, $field, $diff));
    }

    /**
     * @param Carbon $date
     */
    public function setDate(Carbon $date): void
    {
        $newDate = clone $date;
        $newDate->startOfDay();
        $this->date = $newDate;
    }

    /**
     * @param bool $force
     */
    public function setForce(bool $force): void
    {
        $this->force = $force;
    }
}