chore: change code for ik http transaction & timeout

v2.0.0
ricky rx 2 years ago
parent d947df81d3
commit 158106c758

@ -31,6 +31,31 @@ class Indokargo {
throw new \Exception("Indokargo status is not valid (ik status = $status)" ); throw new \Exception("Indokargo status is not valid (ik status = $status)" );
} }
} }
private static function _HttpTransaction(StsLog $stsLog, $callback) {
try {
return $callback();
} catch(ConnectionException $e) {
// if error cause by connection error, try again later
$stsLog->error_info = [
'message' => $e->getMessage(),
'errors' => $e->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->is_retry = true;
$stsLog->save();
return JSONResponse::Success(['is_warning' => true,
'message' => "Failed to sync data with indokargo data, don't worry, we will sync data later"]);
} catch(\Throwable $th) {
DB::rollBack();
$stsLog->error_info = [
'message' => $th->getMessage(),
'errors' => $th->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->save();
throw $th;
}
}
//-- END UTILITIES //-- END UTILITIES
//------------------------------------------------------------------------ //------------------------------------------------------------------------
@ -53,7 +78,7 @@ class Indokargo {
$stsLog->request_data = $request->all(); $stsLog->request_data = $request->all();
$stsLog->request_time = Carbon::now(); $stsLog->request_time = Carbon::now();
try { return self::_HttpTransaction($stsLog, function() use($tvFk, $request, $stsLog) {
$request->validate(['code' => 'required|string']); $request->validate(['code' => 'required|string']);
$result = Http::indokargo()->post('tv/address/create', $request->all()); $result = Http::indokargo()->post('tv/address/create', $request->all());
@ -85,27 +110,7 @@ class Indokargo {
$stsLog->save(); $stsLog->save();
DB::commit(); DB::commit();
return JSONResponse::Success(['is_warning' => false, 'message' => 'Success To Save Data']); return JSONResponse::Success(['is_warning' => false, 'message' => 'Success To Save Data']);
} catch(ConnectionException $e) { });
// if error cause by connection error, try again later
$stsLog->error_info = [
'message' => $e->getMessage(),
'errors' => $e->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->is_retry = true;
$stsLog->save();
return JSONResponse::Success(['is_warning' => true,
'message' => "Failed to sync data with indokargo data, don't worry, we will sync data later"]);
} catch(\Throwable $th) {
DB::rollBack();
$stsLog->error_info = [
'message' => $th->getMessage(),
'errors' => $th->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->save();
throw $th;
}
} }
public static function updateTVAddress(Request $request, int $tvFk, String $ikAddressId, int $lastSeq = 0) { public static function updateTVAddress(Request $request, int $tvFk, String $ikAddressId, int $lastSeq = 0) {
@ -123,7 +128,7 @@ class Indokargo {
$stsLog->request_data = $request->all(); $stsLog->request_data = $request->all();
$stsLog->request_time = Carbon::now(); $stsLog->request_time = Carbon::now();
try { return self::_HttpTransaction($stsLog, function() use($stsLog, $request) {
$request->validate(['code' => 'required|string', 'ik_address_id' => 'required|string']); $request->validate(['code' => 'required|string', 'ik_address_id' => 'required|string']);
$result = Http::indokargo()->post('tv/address/update-tv', $request->all()); $result = Http::indokargo()->post('tv/address/update-tv', $request->all());
$res = $result->throw()->json(); $res = $result->throw()->json();
@ -135,29 +140,8 @@ class Indokargo {
$stsLog->result = StsLog::STATUS_SUCCESS; $stsLog->result = StsLog::STATUS_SUCCESS;
$stsLog->save(); $stsLog->save();
DB::commit(); DB::commit();
return JSONResponse::Success(['message' => "Success to save data"]);
return JSONResponse::Success(['is_warning' => false, 'message' => 'Success To Save Data']); });
} catch(ConnectionException $e) {
// if error cause by connection error, try again later
$stsLog->error_info = [
'message' => $e->getMessage(),
'errors' => $e->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->is_retry = true;
$stsLog->save();
return JSONResponse::Success(['is_warning' => true,
'message' => "Failed to sync data with indokargo data, don't worry, we will sync data later"]);
} catch(\Throwable $th) {
DB::rollBack();
$stsLog->error_info = [
'message' => $th->getMessage(),
'errors' => $th->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->save();
throw $th;
}
} }
public static function changeStatusAddress(Request $request, int $tvFk, String $ikAddressId, int $lastSeq = 0) { public static function changeStatusAddress(Request $request, int $tvFk, String $ikAddressId, int $lastSeq = 0) {
@ -175,7 +159,7 @@ class Indokargo {
$stsLog->request_data = $request->all(); $stsLog->request_data = $request->all();
$stsLog->request_time = Carbon::now(); $stsLog->request_time = Carbon::now();
try { return self::_HttpTransaction($stsLog, function() use($stsLog, $request) {
$request->validate(['ik_address_id' => 'required|string', 'is_active'=> 'required|boolean']); $request->validate(['ik_address_id' => 'required|string', 'is_active'=> 'required|boolean']);
$result = Http::indokargo()->post('tv/address/change-status', $request->all()); $result = Http::indokargo()->post('tv/address/change-status', $request->all());
$res = $result->throw()->json(); $res = $result->throw()->json();
@ -189,27 +173,7 @@ class Indokargo {
DB::commit(); DB::commit();
return JSONResponse::Success(['is_warning' => false, 'message' => 'Success To Change Status']); return JSONResponse::Success(['is_warning' => false, 'message' => 'Success To Change Status']);
} catch(ConnectionException $e) { });
// if error cause by connection error, try again later
$stsLog->error_info = [
'message' => $e->getMessage(),
'errors' => $e->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->is_retry = true;
$stsLog->save();
return JSONResponse::Success(['is_warning' => true,
'message' => "Failed to sync data with indokargo data, don't worry, we will sync data later"]);
} catch(\Throwable $th) {
DB::rollBack();
$stsLog->error_info = [
'message' => $th->getMessage(),
'errors' => $th->getTrace()
];
$stsLog->result = StsLog::STATUS_FAILED;
$stsLog->save();
throw $th;
}
} }
} }

@ -25,7 +25,7 @@ class AppServiceProvider extends ServiceProvider
'session' => env('INDOKARGO_API_SESSION_ID', '') 'session' => env('INDOKARGO_API_SESSION_ID', '')
]; ];
return Http::withHeaders($headers) return Http::withHeaders($headers)->timeout(120)
->baseUrl(env('INDOKARGO_API_URL', '').'/v1/'); ->baseUrl(env('INDOKARGO_API_URL', '').'/v1/');
}); });
} }

Loading…
Cancel
Save