'Job Retrieving PackingLists', 'message' => 'You have successfully submit a job to retrieve a list of PackingLists' ]; } /** @var CreatesJobResult */ private $createsJobResult; /** * ListPackingListsJobLogic constructor. * @param CreatesJobResult $createsJobResult */ public function __construct(CreatesJobResult $createsJobResult) { $this->createsJobResult = $createsJobResult; } /** * @param Request $request * @return JsonResponse */ public function logic(Request $request) : JsonResponse { $jobId = uniqid(); $user = Auth::user(); $userInfo = (object) [ // 'email' => $user->email, 'type' => $user->type, ]; $userInfoJson = json_encode($userInfo); $requestSignature = md5($userInfoJson . $request->fullUrl()); $listGenericJobObject = new ListGenericJobObject( $request->fullUrl(), $request->all(), $requestSignature, null, $jobId, $userInfo ); // $filters = Helper::deserializeFilters($request->input('filters')); // if(isset($filters['priority'])){ // if($filters['priority'] == '1'){ // ListPackingListsJob::dispatch($listGenericJobObject)->onQueue('hellokitty1'); //cief todo: testing sqs // } // else{ // ListPackingListsJob::dispatch($listGenericJobObject)->onQueue('hellokitty2'); //cief todo: testing sqs // } // } ListPackingListsJob::dispatch($listGenericJobObject); $result = []; $result['job_id'] = $jobId; $this->createsJobResult->execute($listGenericJobObject); return $this->response(['data' => $result]); } }