Nhances/nhance
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CHANGE_TEMP_QUEUE_ENABLED

Browse Source
This commit is contained in:
velz 2024-03-30 15:17:04 +05:30
parent 2386c6c227
commit 2f70084e83
2 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/Controllers/EmployeeServiceController.php
View File

@ -17,6 +17,7 @@ use App\Models\FileModel;
use App\Models\EmpEndorsementModel; use App\Models\EmpEndorsementModel;
use App\Controllers\Jobs ; use App\Controllers\Jobs ;
use App\Controllers\JobWorker ;
use PhpOffice\PhpSpreadsheet\Spreadsheet; use PhpOffice\PhpSpreadsheet\Spreadsheet;
use Kint\Kint; use Kint\Kint;
@ -266,8 +267,9 @@ class EmployeeServiceController extends AdminController
{ {
//proceed next data level validation in JOB queue //proceed next data level validation in JOB queue
$job_details = new Jobs(); $job_details = new Jobs();
$r = Jobs::addJob(['job_name' => 'excelFileDataValidation','payload' => ['file_id' => $file_id]]); $r = Jobs::addJob(['job_name' => 'excelFileDataValidation','payload' => ['file_id' => $file_id]]);
$jobWorker = new JobWorker();
JobWorker::processJob($r);
} }
return $result; return $result;
@ -438,6 +440,8 @@ class EmployeeServiceController extends AdminController
$job_details = new Jobs(); $job_details = new Jobs();
$r = Jobs::addJob(['job_name' => 'employeesOnboardPreprocess','payload' => ['file_id' => $file_id]]); $r = Jobs::addJob(['job_name' => 'employeesOnboardPreprocess','payload' => ['file_id' => $file_id]]);
$jobWorker = new JobWorker();
JobWorker::processJob($r);
} }
return $result; return $result;

23
app/Controllers/JobWorker.php
View File

@ -27,6 +27,14 @@ class JobWorker extends AdminController
// } // }
} }
public static function streamOutput($data)
{
ob_implicit_flush(true);
// try { ob_end_flush(); } catch(Exception $e) { echo $e->getMessage(); }
echo $data;
flush();
}
public static function processJobs(array $jobdata = []) public static function processJobs(array $jobdata = [])
{ {
// echo 'listen';//die(); // echo 'listen';//die();
@ -49,6 +57,7 @@ class JobWorker extends AdminController
//sleep(1); //sleep(1);
SELF::processjob(['id' => $job->id,'uuid' => $job->uuid]); SELF::processjob(['id' => $job->id,'uuid' => $job->uuid]);
usleep( 500000 );
} }
} }
} }
@ -86,8 +95,15 @@ class JobWorker extends AdminController
{ {
$job = $job[0]; $job = $job[0];
echo "\nProcessing job id - " . $job->id . "\n";
echo "Job name - " . $job->name . "\n";
// echo "\nProcessing job id - " . $job->id . "\n";
SELF::streamOutput("\nProcessing job id - " . $job->id . "\n");
// sleep(5);
// echo "Job name - " . $job->name . "\n";
SELF::streamOutput("Job name - " . $job->name . "\n");
// sleep(5);
// print_r(SELF::$event_class_mapping); // print_r(SELF::$event_class_mapping);
// echo array_key_exists($job->name,SELF::$event_class_mapping) ? 'mapped' : 'notmapped'; // echo array_key_exists($job->name,SELF::$event_class_mapping) ? 'mapped' : 'notmapped';
// die(); // die();
@ -173,7 +189,8 @@ class JobWorker extends AdminController
]); ]);
// echo "Job $job->id $job_status. Response - $response \n"; // echo "Job $job->id $job_status. Response - $response \n";
echo "Job $job->id $job_status \n"; // echo "Job $job->id $job_status \n";
SELF::streamOutput("Job $job->id $job_status \n");
return true; return true;
} }
else else