Compare commits
1 Commits
adadbef249
...
378515d29b
Author | SHA1 | Date | |
---|---|---|---|
378515d29b |
@ -62,9 +62,9 @@ class Area extends Base
|
|||||||
if ($nea=$this->mo->fftn->echoareas->where('name',$area)->pop()) {
|
if ($nea=$this->mo->fftn->echoareas->where('name',$area)->pop()) {
|
||||||
// requesting to subscribe "You already are since..., arguments ignored
|
// requesting to subscribe "You already are since..., arguments ignored
|
||||||
if ($sub) {
|
if ($sub) {
|
||||||
Log::debug(sprintf('%s:- FTN [%s] ALREADY subscribed to [%s] since [%s]',self::LOGKEY,$this->mo->fftn->ftn,$area,$nea->pivot->subscribed));
|
Log::debug(sprintf('%s:- FTN [%s] ALREADY subscribed to [%s] since [%s]',self::LOGKEY,$this->mo->fftn->ftn,$area,$nea->pivot->subscribed->format('Y-m-d H:i')));
|
||||||
|
|
||||||
return sprintf('%-25s <-- ALREADY subscribed since %s',$command,$nea->pivot->subscribed);
|
return sprintf('%-25s <-- ALREADY subscribed since %s',$command,$nea->pivot->subscribed->format('Y-m-d H:i'));
|
||||||
|
|
||||||
// requesting to unsubscribe
|
// requesting to unsubscribe
|
||||||
} else {
|
} else {
|
||||||
|
@ -63,9 +63,9 @@ class Area extends Base
|
|||||||
if ($nea=$this->mo->fftn->fileareas->where('name',$area)->pop()) {
|
if ($nea=$this->mo->fftn->fileareas->where('name',$area)->pop()) {
|
||||||
// requesting to subscribe "You already are since..., arguments ignored
|
// requesting to subscribe "You already are since..., arguments ignored
|
||||||
if ($sub) {
|
if ($sub) {
|
||||||
Log::debug(sprintf('%s:- FTN [%s] ALREADY subscribed to [%s] since [%s]',self::LOGKEY,$this->mo->fftn->ftn,$area,$nea->pivot->subscribed));
|
Log::debug(sprintf('%s:- FTN [%s] ALREADY subscribed to [%s] since [%s]',self::LOGKEY,$this->mo->fftn->ftn,$area,$nea->pivot->subscribed->format('Y-m-d H:i')));
|
||||||
|
|
||||||
return sprintf('%-25s <-- ALREADY subscribed since %s',$command,$nea->pivot->subscribed);
|
return sprintf('%-25s <-- ALREADY subscribed since %s',$command,$nea->pivot->subscribed->format('Y-m-d H:i'));
|
||||||
|
|
||||||
// requesting to unsubscribe
|
// requesting to unsubscribe
|
||||||
} else {
|
} else {
|
||||||
|
@ -1,79 +0,0 @@
|
|||||||
<?php
|
|
||||||
|
|
||||||
namespace App\Classes\FTN\Process\Netmail\Robot\Filefix;
|
|
||||||
|
|
||||||
use Carbon\Carbon;
|
|
||||||
use Illuminate\Support\Facades\Log;
|
|
||||||
|
|
||||||
use App\Classes\FTN\Process\Netmail\Robot\Areafix\Base;
|
|
||||||
|
|
||||||
// Resend a file
|
|
||||||
class Resend extends Base
|
|
||||||
{
|
|
||||||
private const LOGKEY = 'FFA';
|
|
||||||
|
|
||||||
private const command = '%RESEND';
|
|
||||||
|
|
||||||
public static function help(): array
|
|
||||||
{
|
|
||||||
return [
|
|
||||||
self::command.' <FILEAREA> <FILENAME>',
|
|
||||||
' Resend a file from a file area',
|
|
||||||
' Arguments:',
|
|
||||||
' - FILEAREA (required) name of area to subscribe or unsubscribe',
|
|
||||||
' - FILENAME (required) number of file to resend',
|
|
||||||
' Notes:',
|
|
||||||
' * You can obtain a list of files in an area with %FILELIST <FILEAREA>',
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
public function process(): string
|
|
||||||
{
|
|
||||||
$command = self::command.' '.join(' ',$this->arguments);
|
|
||||||
|
|
||||||
if (count($this->arguments) < 2)
|
|
||||||
return sprintf('%-25s <-- INVALID, NOT ENOUGH ARGUMENTS',$command);
|
|
||||||
elseif (count($this->arguments) > 2)
|
|
||||||
return sprintf('%-25s <-- INVALID, TOO MANU ARGUMENTS',$command);
|
|
||||||
|
|
||||||
Log::debug(sprintf('%s:- Resending [%s] from [%s] to [%s]',self::LOGKEY,$this->arguments[1],$this->arguments[0],$this->mo->fftn->ftn));
|
|
||||||
|
|
||||||
// Area exists
|
|
||||||
if ($fa=$this->mo->fftn->domain->fileareas->where('name',$this->arguments[0])->pop()) {
|
|
||||||
// If already subscribed
|
|
||||||
if ($nea=$this->mo->fftn->fileareas->where('name',$fa->name)->pop()) {
|
|
||||||
// Check the file is in the area
|
|
||||||
if ($fo=$nea->files()->where('name','ilike',$this->arguments[1])->single()) {
|
|
||||||
// File hasnt been exported before
|
|
||||||
if (! $fo->seenby->where('id',$this->mo->fftn_id)->count()) {
|
|
||||||
Log::info(sprintf('Exported [%d] FILE (%s) dated (%s) to [%s]',$fo->id,$fo->name,$fo->datetime->format('Y-m-d H:i:s'),$this->mo->fftn->ftn3d));
|
|
||||||
$fo->seenby()->attach($this->mo->fftn_id,['export_at'=>Carbon::now()]);
|
|
||||||
|
|
||||||
} else {
|
|
||||||
Log::debug(sprintf('Re-exported [%d] FILE (%s) dated (%s) to [%s]',$fo->id,$fo->name,$fo->datetime,$this->mo->fftn->ftn3d));
|
|
||||||
$fo->seenby()->updateExistingPivot($this->mo->fftn_id,['export_at'=>Carbon::now(),'sent_at'=>NULL]);
|
|
||||||
}
|
|
||||||
|
|
||||||
return sprintf('%-25s <-- FILE QUEUED TO RESEND',$command);
|
|
||||||
|
|
||||||
// No file in area
|
|
||||||
} else {
|
|
||||||
Log::debug(sprintf('%s:- FTN [%s] doesnt have a file [%s], NO ACTION taken',self::LOGKEY,$this->mo->fftn->ftn,$this->arguments[1]));
|
|
||||||
|
|
||||||
return sprintf('%-25s <-- FILE NOT FOUND, NO ACTION taken',$command);
|
|
||||||
}
|
|
||||||
|
|
||||||
// If not subscribed
|
|
||||||
} else {
|
|
||||||
Log::debug(sprintf('%s:- FTN [%s] is NOT subscribed to [%s], NO ACTION taken',self::LOGKEY,$this->mo->fftn->ftn,$this->arguments[0]));
|
|
||||||
|
|
||||||
return sprintf('%-25s <-- NOT subscribed, NO ACTION taken',$command);
|
|
||||||
}
|
|
||||||
|
|
||||||
} else {
|
|
||||||
Log::debug(sprintf('%s:- FILE [%s] area UNKNOWN [%s], NO ACTION taken',self::LOGKEY,$this->mo->fftn->ftn,$this->arguments[0]));
|
|
||||||
|
|
||||||
return sprintf('%-25s <-- AREA UNKNOWN, NO ACTION TAKEN',$command);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -95,7 +95,7 @@ class FilefixRescan implements ShouldQueue
|
|||||||
->cursor() as $fo)
|
->cursor() as $fo)
|
||||||
{
|
{
|
||||||
// File hasnt been exported before
|
// File hasnt been exported before
|
||||||
if (! $fo->seenby->where('address_id',$this->ao->id)->count()) {
|
if (! $fo->seenby->count()) {
|
||||||
$fo->seenby()->attach($this->ao->id,['export_at'=>Carbon::now()]);
|
$fo->seenby()->attach($this->ao->id,['export_at'=>Carbon::now()]);
|
||||||
$c++;
|
$c++;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user