배치 선/후처리

    public boolean checkIfRunnableBatch(String jobName, BasicBatchControlParameters basicBatchControlParameters, BatchType batchType) throws Exception;

    public boolean checkIfRunnableBatchGroup(String jobName, DataSource dataSource, BatchType batchType) throws Exception;

    public void preProcess(String jobName, DataSource dataSource, WrappedJobParameters wrapJobParameters
            , BatchType batchType, BasicBatchControlParameters basicBatchControlParameters, ContextHeader cHeader) throws Exception;

    public void initModuleTest(String jobId, DataSource dataSource, WrappedJobParameters wrapedJobParameters, BatchType batchType
            , BasicBatchControlParameters basicBatchControlParameters, ContextHeader cHeader) throws Exception;

    package bxm.batch.dft.context;

    ......

    public class DefaultBatchPreProcessor implements BatchPreProcessor {

        @Override
        public boolean checkIfRunnableBatch(String jobId, BasicBatchControlParameters basicBatchControlParameters, BatchType batchType) throws BatchNotFoundException
        {
            boolean isCheck = false;

            // 일반배치 및 온디맨드 배치
            if(BatchType.GENERAL == batchType || BatchType.ONDEMAND == batchType)
            {
                isCheck = checkIfRunnableBatch(jobId, (BatchControlParameters)basicBatchControlParameters, batchType);
            }
            // 데몬 배치
            else if(BatchType.DAEMON == batchType)
            {
                isCheck = checkIfRunnableDaemon(jobId, (DaemonControlParameters)basicBatchControlParameters, batchType);
            }

            return isCheck;
        }

        /**
         * 일반, 온디맨드배치의  실행 가능여부 판단
         *
         * @param jobId 배치 Job ID
         * @param basicBatchControlParameters 배치 Job 정보 Load Instance
         * @param batchType 배치 유형
         * @return boolean 실행 가능여부
         * @throws BatchNotFoundException
         */
        private boolean checkIfRunnableBatch(String jobId, BatchControlParameters batchControlParameters, BatchType batchType) throws BatchNotFoundException
        {
            boolean isCheck = true;

            if(batchControlParameters != null)
            {
                // 배치 상태 구분 체크
                if(!batchControlParameters.isUseYn())
                {
                    isCheck = false;
                    logger.error("Batch USE_YN Column value : not use.......");
                    throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_BATCH_USE_YN, "Batch USE_YN Column value : not use.......");
                }

                if(!batchType.isEquals(batchControlParameters.getJobTypeCd()))
                {
                    isCheck = false;
                    logger.error("Batch job type check error. Job type : {}", batchControlParameters.getJobTypeCd());
                    throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_INVALID_JOB_TYPE, "Batch job type check error. Job type : " + batchControlParameters.getJobTypeCd());
                }

                if(batchType != BatchType.ONDEMAND)
                {
                    String applicationName = ApplicationContextTrace.getCurrentApplication().getApplicationName();
                    if(!applicationName.equals(batchControlParameters.getBxmAppId()))
                    {
                        isCheck = false;
                        logger.error("Parameter application ID [{}] and current application id [{}] are different. "
                                , new Object[]{batchControlParameters.getBxmAppId(), applicationName});
                        throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_INVALID_APP_ID, "Invalid applicaton name. Parameter application id : " + batchControlParameters.getBxmAppId());
                    }
                }

                // 일자 체크
                String currentDate = DateUtils.getCurrentDate(DateUtils.EMPTY_DATE_TYPE);
                if(StringUtils.hasText(batchControlParameters.getJobUseStartDt()))
                {
                    if(currentDate.compareTo(batchControlParameters.getJobUseStartDt()) < 0)
                    {
                        isCheck = false;
                        logger.error("Start date check error. Current Date : [{}], Start Date : [{}]"
                                , new Object[]{currentDate, batchControlParameters.getJobUseStartDt()});
                        throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_INVALID_START_DATE, "Invalid start date : " + batchControlParameters.getJobUseStartDt());
                    }
                }

                if(StringUtils.hasText(batchControlParameters.getJobUseEndDt()))
                {
                    if(currentDate.compareTo(batchControlParameters.getJobUseEndDt()) > 0)
                    {
                        isCheck = false;
                        logger.error("End date check error. Current Date : [{}], End Date : [{}]"
                                , new Object[]{currentDate, batchControlParameters.getJobUseEndDt()});
                        throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_INVALID_END_DATE, "Invalid end date : " + batchControlParameters.getJobUseEndDt());
                    }
                }

                // 프로세스 중복 실행 확인
                if(!batchControlParameters.isProcessDupExecUseYn())
                {
                    checkProcessDuplication(ApplicationContainerUtils.getApplicationContainer().getDataSoruce(), jobId);
                }
            }
            else
            {
                logger.error("Batch job control parameter is null.");
                throw new BatchJobNotFoundException(BatchApplicationContext.getDomainId(), jobId);
            }

            return isCheck;
        }

        /**
         * 데몬 배치의  실행 가능여부 판단
         *
         * @param jobId 배치 Job ID
         * @param basicBatchControlParameters 배치 Job 정보 Load Instance
         * @param batchType 배치 유형
         * @return boolean 실행 가능여부
         * @throws BatchNotFoundException
         */
        private boolean checkIfRunnableDaemon(String jobId, DaemonControlParameters daemonControlParameters, BatchType batchType) throws BatchNotFoundException
        {
            boolean isCheck = true;

            if(daemonControlParameters != null)
            {
                // 배치 상태 구분 체크
                if(!daemonControlParameters.isUseYn())
                {
                    isCheck = false;
                    logger.error("Batch USE_YN Column value : not use.......");
                    throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_BATCH_USE_YN, "Batch USE_YN Column value : not use.......");
                }

                String applicationName = ApplicationContextTrace.getCurrentApplication().getApplicationName();
                if(!applicationName.equals(daemonControlParameters.getBxmAppId()))
                {
                    isCheck = false;
                    logger.error("Parameter application ID [{}] and current application id [{}] are different. "
                            , new Object[]{daemonControlParameters.getBxmAppId(), applicationName});
                    throw new RestrictedBatchExecutionException(jobId, BxmBatchErrorCode.RESTRICTED_INVALID_APP_ID, "Invalid applicaton name. Parameter application id : " + daemonControlParameters.getBxmAppId());
                }
            }
            else
            {
                logger.error("Daemon Batch job control parameter is null.");
                throw new BatchJobNotFoundException(BatchApplicationContext.getDomainId(), jobId);
            }

            return isCheck;
        }


        @Override
        public boolean checkIfRunnableBatchGroup(String jobName, DataSource dataSource, BatchType batchType) throws Exception
        {
            // 일반 배치인 경우에만 배치 그룹정보를 체크한다.
            if(BatchType.GENERAL == batchType)
            {
                BatchGroupCheckProcessor batchGroupCheckProcessor = BatchApplicationContainer.getBatchGroupCheckProcessor();
                Map<String, BatchJobGroupInfo> batchGroupInfos = batchGroupCheckProcessor.loadBatchGroupInfo(jobName, dataSource);
                if(batchGroupInfos == null || batchGroupInfos.isEmpty())
                {
                    return true;
                }

                for(String jobGrpId : batchGroupInfos.keySet())
                {
                    if(!batchGroupCheckProcessor.batchGroupCheck(jobName, dataSource, jobGrpId, batchGroupInfos.get(jobGrpId)))
                    {
                        logger.error("Current batch job group count check is false. Job Group Id : [{}]", jobGrpId);
                        throw new RestrictedBatchExecutionException(jobName, BxmBatchErrorCode.RESTRICTED_GROUP_CONTROL
                                , "Current batch job group count check is false. Job Group Id : " + jobGrpId);
                    }
                }
            }

            return true;
        }

        @Override
        public void preProcess(String jobId, DataSource dataSource, WrapedJobParameters wrapedJobParameters, BatchType batchType
                , BasicBatchControlParameters basicBatchControlParameters)
        {
            // 기준일자 설정
            setStdDate(dataSource, cHeader, basicBatchControlParameters, wrappedJobParameters, batchType);

            // 일반배치일 경우
            if(BatchType.GENERAL == batchType)
            {
                // 시작로그 설정
                BatchLogUtils.startJobLog(jobId, true);
                /** 메모리 측정 스레드 수행 */
                /*Thread t = new Thread(new MonitorBatchMemory());
                  t.start();*/
            }
        }
    }

        public void contextPreProcess(String jobId, DataSource dataSource, WrapedJobParameters wrapJobParameters, BatchType batchType, BasicBatchControlParameters basicBatchControlParameters, JobExecution jobExecution) throws Exception;

    package bxm.batch.dft.context;

    ......

    public class DefaultBatchContextPreProcessor implements BatchContextPreProcessor{

        private static final Logger logger = LoggerFactory.getLogger(DefaultBatchContextPreProcessor.class);

        @Override
        public void contextPreProcess(String jobId, DataSource dataSource,
                WrappedJobParameters wrapJobParameters, BatchType batchType,
                BasicBatchControlParameters basicBatchControlParameters, JobExecution jobExecution)
                throws Exception
        {
            logger.debug("batch context preProcess..........");

            BatchLogUtils.startJobExecLog(jobExecution.getJobId(), jobExecution.getId(), true);

            // 기동 실패한 JOB은 Context가 정상적으로 복구하여 처리하지 못했기 때문에.. 재시작 시 오류의 위험성이 있다.
            // 그래서 기동 실패한 경우에는 LOAD_FAIL 파라미터로 추가하여 해당 파라미터로 입력 하였을 경우.. 재실행 할 수 없도록 처리한다.
            if(wrapJobParameters.getJobParameters().getParameters().containsKey("LOAD_FAIL"))
            {
                throw new BxmBatchRuntimeException("Job failed to start cannot restart.");
            }

            // 기본 헤더 생성
            ServiceTraceContextImpl traceContext = (ServiceTraceContextImpl) ContextTrace.getCurrentContext();
            DefaultSystemHeader defaultSystemHeader = (DefaultSystemHeader) traceContext.getContextHeader();

            //String guid = DefaultGuidGenerator.generateInitialGuid();
            String guid = SystemUtils.generateGUID();
            defaultSystemHeader.setGuid(guid);  // Global Id
            defaultSystemHeader.setChlType("Z1");                                 // 채널유형
            defaultSystemHeader.setMsgReqDttm(ThreadSafeSimpleDateFormat.simpleFormatCurrentTime(Format.yyyyMMddHHmmssTT));
            defaultSystemHeader.setSysCd(DefaultBatchPropsConstants.PROPERTY_BAT_SYS_ID);   // 송신시스템구분
            defaultSystemHeader.setSystemId(DefaultBatchPropsConstants.PROPERTY_BAT_SYS_ID);
            defaultSystemHeader.setUserId(jobId);
            defaultSystemHeader.setLangCd(Locale.getDefault().getLanguage());

            if(BatchType.GENERAL == batchType || BatchType.ONDEMAND == batchType)
            {
                if(!(basicBatchControlParameters instanceof DefaultBatchControlParameter))
                {
                    logger.error("Invaild batch control parameter....");
                    throw new IllegalStateException("Invaild batch control parameter....");
                }

                DefaultBatchControlParameter defaultBatchControlParameter = (DefaultBatchControlParameter) basicBatchControlParameters;

                if(BatchType.ONDEMAND == batchType)
                {
                    logger.debug("system loglevel : {}", defaultBatchControlParameter.getSysLogLevel());
                    if(defaultBatchControlParameter.getSysLogLevel() != null)
                    {
                        // 온디맨드 배치 인 경우 로그레벨 설정
                        ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setSysLoggingLevel(defaultBatchControlParameter.getSysLogLevel());
                    }

                    logger.debug("business loglevel : {}", defaultBatchControlParameter.getBizLogLevel());
                    if(defaultBatchControlParameter.getBizLogLevel() != null)
                    {
                        // 온디맨드 배치 인 경우 로그레벨 설정
                        ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setBizLoggingLevel(defaultBatchControlParameter.getBizLogLevel());
                    }

                    logger.debug("database loglevel : {}", defaultBatchControlParameter.getDBLogLevel());
                    if(defaultBatchControlParameter.getDBLogLevel() != null)
                    {
                        // 온디맨드 배치 인 경우 로그레벨 설정
                        ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setDBLoggingLevel(defaultBatchControlParameter.getDBLogLevel());
                    }
                }
            }

            // Set Step Commit Interval.
            if(!StringUtils.isEmpty(basicBatchControlParameters.getCommitCfgList()))
            {
                Map<String, Integer> stepCommitCounts = BxmDefaultStepListener.setCommitIntervalUtil(basicBatchControlParameters.getCommitCfgList());

                // 온디맨드 배치 선처리에서는 Context가 생성되어 있지 않기 때문에 설정값은 파라미터로 넘겨 Launcher 에서 설정 하도록 한다.
                if(LApplicationContext.getDataContainer() != null)
                {
                    LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_COMMIT_INTERVAL, stepCommitCounts);
                }
            }
            else
            {
                logger.info("commit interval value is null or empty");
            }

            // Default Commit Interval 설정
            if(LApplicationContext.getDataContainer() != null)
            {
                LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_JOB_DFT_COMMIT_INTERVAL, basicBatchControlParameters.getDefaultCommitInterval());
            }

            // Count, AMT Map CMDC에 설정
            // Count와 AMT가 복구 되었으면 존재, 복구 되지 않았으면.. 없음.
            if(LApplicationContext.getDataContainer().get(BatchContextConstans.CMDC_BATCH_COUNT_LOG) == null)
            {
                Map<Integer, Long> countMap = new ConcurrentHashMap<Integer, Long>();
                LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_BATCH_COUNT_LOG, countMap);
                Map<Integer, Long> lastCountMap = new ConcurrentHashMap<Integer, Long>();
                LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_BATCH_LAST_COUNT_LOG, lastCountMap);
            }
            if(LApplicationContext.getDataContainer().get(BatchContextConstans.CMDC_BATCH_AMT_LOG) == null)
            {
                Map<Integer, BigDecimal> amtMap = new ConcurrentHashMap<Integer, BigDecimal>();
                LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_BATCH_AMT_LOG, amtMap);
                Map<Integer, BigDecimal> lastAmtMap = new ConcurrentHashMap<Integer, BigDecimal>();
                LApplicationContext.getDataContainer().put(BatchContextConstans.CMDC_BATCH_LAST_AMT_LOG, lastAmtMap);
            }

            // 배치 데이타소스 허용 리스트 설정
            BatchDataSourceUtils.putDataSourceAllowList(basicBatchControlParameters.getDataSourceAllowList());
        }
    }

        public void postProcess(String jobId, DataSource dataSource, JobParameters jobParameters, JobExecution jobExecution, BatchType batchType, BasicBatchControlParameters basicBatchControlParameters) throws Exception;

    public class DefaultBatchPostProcessor implements BatchPostProcessor {

        @Override
        public void postProcess(String jobId, DataSource dataSource,
                JobParameters jobParameters, JobExecution jobExecution,
                BatchType batchType, BasicBatchControlParameters basicBatchControlParameters)
        {
            logger.debug("batch postProcess..........");

            // Exception 정보 확인
            checkException(jobName, jobExecution);

            if(BatchType.GENERAL == batchType)
            {
                BatchLogUtils.endJobLog(jobExecution, true);

                if(jobExecution != null && jobExecution.getId() != null)
                {
                    // CPU 사용량 Update. 에러가 발생하더라도 계속 진행.
                    updateCpuUse(jobExecution.getId());

                    // 건수, 금액 Update
                    updateCountAmt(dataSource, jobExecution.getId());

                    // 배치 메모리 update
                    //updateBatchMemory(jobExecution.getId());
                }
            }

            // Job ExitStatus 처리
            applyJobExitStatus(jobExecution);

            BatchDataSourceUtils.removeDataSourceUseList();
            BatchDataSourceUtils.removeAllowDataSourceList();

            try {BxmLoadRemoteExecutor.destroyExecutors();} catch (Exception e) {}
        }
    }