2 Commits

Author SHA1 Message Date
4d336afd44 Merge pull request 'Added import transit scheduling mail in scheduler page' (#576) from ranjith-dev into master
Some checks failed
Scan for leaked secrets using Kingfisher / kingfisher-secrets-scan (push) Has been cancelled
Reviewed-on: #576
2026-05-08 09:13:20 +00:00
dhanabalan
9bb6e05589 Added import transit scheduling mail in scheduler page
Some checks failed
Scan for leaked secrets using Kingfisher / kingfisher-secrets-scan (push) Has been cancelled
Gemini PR Review / Gemini PR Review (pull_request) Has been cancelled
Scan for leaked secrets using Kingfisher / kingfisher-secrets-scan (pull_request) Has been cancelled
Laravel Larastan / larastan (pull_request) Has been cancelled
Laravel Pint / pint (pull_request) Has been cancelled
2026-05-08 14:43:06 +05:30

View File

@@ -40,6 +40,7 @@ class Scheduler extends Command
{
$this->call('approval:trigger-mails');
// $this->call('sftp:process-files');
// --- Production Rules ---
$productionRules = AlertMailRule::where('module', 'ProductionQuantities')
@@ -234,6 +235,55 @@ class Scheduler extends Command
break;
}
}
$ImportTransitRules = AlertMailRule::where('module', 'ImportTransit')
->where('rule_name', 'ImportTransitMail')
->select('plant', 'schedule_type')
->distinct()
->get();
foreach ($ImportTransitRules as $rule) {
switch ($rule->schedule_type) {
case 'Live':
// Run every minute
\Artisan::call('send-import-transit', [
'schedule_type' => $rule->schedule_type,
'plant' => $rule->plant,
]);
break;
case 'Hourly':
if (now()->minute == 0) {
\Artisan::call('send-import-transit', [
'schedule_type' => $rule->schedule_type,
'plant' => $rule->plant,
]);
}
break;
case 'Daily':
if (now()->format('H:i') == '11:10') {
try {
\Artisan::call('send-import-transit', [
'schedule_type' => $rule->schedule_type,
'plant' => $rule->plant,
]);
Log::info('Invoice Transit executed', [
'plant' => $rule->plant,
'type' => $rule->schedule_type,
]);
}
catch (\Throwable $e) {
Log::error('Invoice Transit FAILED', [
'plant' => $rule->plant,
'error' => $e->getMessage(),
'trace' => $e->getTraceAsString(),
]);
}
}
break;
}
}
}
/**