|
|
@ -40,7 +40,7 @@ public class SndngSendBulksTasklet implements Tasklet {
|
|
|
|
@JobScope
|
|
|
|
@JobScope
|
|
|
|
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
|
|
|
|
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
|
|
|
|
final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled");
|
|
|
|
final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled");
|
|
|
|
boolean isSuccess = false;
|
|
|
|
boolean isSuccess = true;
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
MDC.put("request_trace_batch_id", UUID.randomUUID().toString().replace("-", ""));
|
|
|
|
MDC.put("request_trace_batch_id", UUID.randomUUID().toString().replace("-", ""));
|
|
|
@ -62,8 +62,9 @@ public class SndngSendBulksTasklet implements Tasklet {
|
|
|
|
dto.setSndngProcessSttus(contribution.getStepExecution().getJobParameters()
|
|
|
|
dto.setSndngProcessSttus(contribution.getStepExecution().getJobParameters()
|
|
|
|
.getString("sndngProcessSttus"));
|
|
|
|
.getString("sndngProcessSttus"));
|
|
|
|
service.sendBulks(dto);
|
|
|
|
service.sendBulks(dto);
|
|
|
|
isSuccess = true;
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
isSuccess = false;
|
|
|
|
String errMsg = ErrorParse.extractError(e).getMessage();
|
|
|
|
String errMsg = ErrorParse.extractError(e).getMessage();
|
|
|
|
log.error("SndngSendBulksTasklet error :: {}", e.getMessage());
|
|
|
|
log.error("SndngSendBulksTasklet error :: {}", e.getMessage());
|
|
|
|
MDC.put("service_error_msg", errMsg);
|
|
|
|
MDC.put("service_error_msg", errMsg);
|
|
|
|