배치 작업 제어

    public interface BasicBatchControlParameters {
        public void loadBatchControlParameters(String jobId, DataSource datasource);
        public ApplicationLogLevel getSysLogLevel();
        public ApplicationLogLevel getBizLogLevel();
        public ApplicationLogLevel getDBLogLevel();
        public boolean isParamDupExecUseYn();
        public String getCommitCfgList();
        public String getStdDtDscd();
        public String getDtBefAftDscd();
        public int getDtBefAftDayCnt();
    }

    public interface BatchControlParameters extends BasicBatchControlParameters {
        public BatchControlParameters getBatchControlParameters();
        public String getDomainId();
        public String getJobId();
        public String getJobNm();
        public BatchJobControlType getJobTypeCd();
        public String getBxmAppId();
        public boolean isUseYn();
        public ApplicationLogLevel getSysLogLevel();
        public ApplicationLogLevel getBizLogLevel();
        public ApplicationLogLevel getDBLogLevel();
        public String getCommitCfgList();
        public String getJobUseStartDt();
        public String getJobUseEndDt();
        public boolean isStdDtParamUseYn();
        boolean isProcessDupExecUseYn();
        boolean isParamDupExecUseYn();
    }

public class DefaultBatchControlParameter implements BatchControlParameters{

    private BatchControlParameters batchControlParameters;

    private BatchControlParameterDto batchParamInfo;

    private boolean useYn;
    private BatchJobControlType batchJobControlType;
    private ApplicationLogLevel sysLogLevel;
    private ApplicationLogLevel bizLogLevel;
    private ApplicationLogLevel dbLogLevel;
    private boolean processDupExecUseYn;
    private boolean paramDupExecUseYn;
    private boolean stdDtParamUseYn;

    ...

    /**
     * 배치 Job 정보를 조회한다.
     * @param jobId 배치 JOB ID
     * @param dataSource DataSource
     * @throws BatchJobNotFoundException
     */
    public void loadBatchControlParameters(String jobId) throws BatchJobNotFoundException
    {
        try
        {
            BatchControlMapper batchControlMapper = JdbcOperatorUtils.getMapper(BatchControlMapper.class);
            BatchControlParameterDto paramInfo =
                    batchControlMapper.selectBxmBatchJobInfo(BatchApplicationContext.getDomainId(), jobId);

            if(paramInfo != null)
            {
                this.batchJobControlType = BatchJobControlType.ALL.getValue(paramInfo.getJobTypeCd());
                this.useYn = BatchCommYN.valueOf(paramInfo.getUseYn()).getBoolean();
                this.sysLogLevel = getLogLevel(jobId, paramInfo.getSysLogLvNm(), Layer.SYS);
                this.bizLogLevel = getLogLevel(jobId, paramInfo.getBizLogLvNm(), Layer.BIZ);
                this.dbLogLevel = getLogLevel(jobId, paramInfo.getDbLogLvNm(), Layer.DB);
                if(StringUtils.isEmpty(paramInfo.getProcessDupExecYn())){
                    paramInfo.setProcessDupExecYn("Y");
                }
                this.processDupExecUseYn = BatchCommYN.valueOf(paramInfo.getProcessDupExecYn()).getBoolean();
                if(StringUtils.isEmpty(paramInfo.getParamDupExecYn())){
                    paramInfo.setParamDupExecYn("Y");
                }
                this.paramDupExecUseYn = BatchCommYN.valueOf(paramInfo.getParamDupExecYn()).getBoolean();
                if(StringUtils.isEmpty(paramInfo.getStdDtParamUseYn())){
                    paramInfo.setStdDtParamUseYn("Y");
                }
                this.stdDtParamUseYn = BatchCommYN.valueOf(paramInfo.getStdDtParamUseYn()).getBoolean();


                if(StringUtils.hasText(paramInfo.getDsAllwList()))
                {
                    String[] dslist = paramInfo.getDsAllwList().split("\\,");;
                    this.dataSourceAllowList = Arrays.asList(dslist);
                }

                batchControlParameters = this;

                paramInfo.setDomainId(BatchApplicationContext.getDomainId());
                paramInfo.setJobId(jobId);

                this.batchParamInfo = paramInfo;
            }
            else
            {
                if(!BatchApplicationContext.isModuleTest())
                {
                    throw new BatchJobNotFoundException(BatchApplicationContext.getDomainId(), jobId);
                }
                else
                {
                    initModuleTest();
                }
            }
        }
        catch (BatchJobNotFoundException e)
        {
            logger.warn("load batch control parameters for [{}]is failed.", new Object[]{ jobId}, e);
            throw e;
        }
        catch (Throwable th)
        {
            logger.warn("load batch control parameters for [{}]is failed.", new Object[]{ jobId}, th);
            throw new IllegalStateException(th);
        }
    }

    @Override
    public BatchControlParameters getBatchControlParameters()
    {
        return this.batchControlParameters;
    }

    /**
     * 로그레벨 설정
     * @param jobId 배치 JOB ID
     * @param logLevel 로그레빌(String)
     */
    private ApplicationLogLevel getLogLevel(String jobId, String logLevel, LoggerLayer.Layer layer)
    {
        ApplicationLogLevel appLogLevel = null;
        try
        {
            // 로그레벨 설정
            if(StringUtils.hasText(logLevel))
            {
                // 온디맨드 배치에서는 context가 생성되기 전이기 때문에 파라미터로 넘겨 JobLauncer에서 생성하여 처리하도록 한다.
                if(BxmBatchConstants.BATCH_DEFAULT_LOG_LEVEL.equals(logLevel.toUpperCase()))
                {
                    if(ContextTrace.getCurrentContext() != null)
                    {
                        DefaultLogLevel defaultLogLevel = (DefaultLogLevel) BatchApplicationContext.getDataContainer().get(BatchContextConstans.CMDC_DEFAULT_LOGLEVEL);
                        if(defaultLogLevel != null)
                        {
                            switch (layer) {
                                case SYS:
                                    appLogLevel = defaultLogLevel.getSysLogLevel();
                                    break;
                                case BIZ:
                                    appLogLevel = defaultLogLevel.getBizLogLevel();
                                    break;
                                case DB:
                                    appLogLevel = defaultLogLevel.getDBLogLevel();
                                    break;
                                default:
                                break;
                            }
                        }
                    }
                    else
                    {
                        appLogLevel = null;
                    }
                }
                else
                {
                    appLogLevel = Enum.valueOf(ApplicationLogLevel.class, logLevel.toUpperCase());
                    if(ContextTrace.getCurrentContext() != null)
                    {
                        switch (layer) {
                            case SYS:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setSysLoggingLevel(appLogLevel);
                                break;
                            case BIZ:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setBizLoggingLevel(appLogLevel);
                                break;
                            case DB:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setDBLoggingLevel(appLogLevel);
                                break;
                            default:
                                break;
                        }
                    }
                }
            }
        }
        catch(IllegalArgumentException ie)
        {
            logger.warn("Can not apply registered batch [{}] loglevel. Invalid value [{}]. set default loglevel"
                    , new Object[]{jobId, logLevel}, ie);
        }
        return appLogLevel;
    }

    ...
}

public interface BasicBatchControlParameters {
    public void loadBatchControlParameters(String jobId, DataSource datasource);
    public ApplicationLogLevel getSysLogLevel();
    public ApplicationLogLevel getBizLogLevel();
    public ApplicationLogLevel getDBLogLevel();
    public boolean isParamDupExecUseYn();
    public String getCommitCfgList();
    public String getStdDtDscd();
    public String getDtBefAftDscd();
    public int getDtBefAftDayCnt();
}

public interface DaemonControlParameters extends BasicBatchControlParameters {
    public DaemonControlParameters getDaemonControlParameters();

    public String getDomainId();
    public String getJobId();
    public String getJobNm();
    public String getBxmAppId();
    public boolean isUseYn();
    public ApplicationLogLevel getSysLogLevel();
    public ApplicationLogLevel getBizLogLevel();
    public ApplicationLogLevel getDBLogLevel();
    public String getCommitCfgList();
    public String getExecArgs();
    public int getExecIntervalSec();
    public String getCronExecCfgVal();
    public boolean isParllExecYn();
    public boolean isErrStopYn();
    public String getExecStartTime();
    public String getExecEndTime();
}

public class DefaultDaemonControlParameter implements DaemonControlParameters{

    private DaemonControlParameters daemonControlParameters;

    private DaemonBatchControlParameterDto daemonBatchParamInfo;

    private boolean useYn;
    private ApplicationLogLevel sysLogLevel;
    private ApplicationLogLevel bizLogLevel;
    private ApplicationLogLevel dbLogLevel;
    private boolean parllExecYn;
    private boolean errStopYn;
    private List<String> dataSourceAllowList;
    private Integer defaultCommitInterval;

    ......

    @Override
    public void loadBatchControlParameters(String jobId) {

        try
        {
            BatchControlMapper batchControlMapper = JdbcOperatorUtils.getMapper(BatchControlMapper.class);
            DaemonBatchControlParameterDto paramInfo =
                    batchControlMapper.selectBxmDaemonBatchJobInfo(BatchApplicationContext.getDomainId(), jobId);

            if(paramInfo != null)
            {
                // 사용여부
                if(StringUtils.hasText(paramInfo.getUseYn()))
                {
                    this.useYn = BatchCommYN.valueOf(paramInfo.getUseYn()).getBoolean();
                }

                // system loglevel
                this.sysLogLevel = getLogLevel(jobId, paramInfo.getSysLogLvNm(), Layer.SYS);

                // biz loglevel
                this.bizLogLevel = getLogLevel(jobId, paramInfo.getBizLogLvNm(), Layer.BIZ);

                // db loglevel
                this.dbLogLevel = getLogLevel(jobId, paramInfo.getDbLogLvNm(), Layer.DB);

                if(StringUtils.hasText(paramInfo.getParllExecYn()))
                {
                    this.parllExecYn = BatchCommYN.valueOf(paramInfo.getParllExecYn()).getBoolean();
                }

                // 실행 노드 정보
                if(StringUtils.hasText(paramInfo.getErrStopYn()))
                {
                    this.errStopYn = BatchCommYN.valueOf(paramInfo.getErrStopYn()).getBoolean();
                }

                // 데이타소스허용목록
                if(StringUtils.hasText(paramInfo.getDsAllwList()))
                {
                    String[] dslist = paramInfo.getDsAllwList().split("\\,");;
                    this.dataSourceAllowList = Arrays.asList(dslist);
                }

                if(StringUtils.hasText(paramInfo.getDefaultCommitIntvl()))
                {
                    this.defaultCommitInterval = Integer.parseInt(paramInfo.getDefaultCommitIntvl());
                }

                daemonControlParameters = this;

                paramInfo.setDomainId(BatchApplicationContext.getDomainId());
                paramInfo.setJobId(jobId);

                this.daemonBatchParamInfo = paramInfo;
            }
            else
            {
                throw new BatchJobNotFoundException(BatchApplicationContext.getDomainId(), jobId);
            }
        }
        catch(Throwable th)
        {
            logger.warn("load batch control parameters for [{}]is failed.", new Object[]{jobId, th});
            throw new IllegalArgumentException(th.getMessage(), th);
        }
    }

    @Override
    public DaemonControlParameters getDaemonControlParameters()
    {
        return daemonControlParameters;
    }

    /**
     * 로그레벨 설정
     * @param jobId 배치 JOB ID
     * @param logLevel 로그레빌(String)
     */
    private ApplicationLogLevel getLogLevel(String jobId, String logLevel, LoggerLayer.Layer layer)
    {
        ApplicationLogLevel appLogLevel = null;
        try
        {
            // 로그레벨 설정
            if(StringUtils.hasText(logLevel))
            {
                // 온디맨드 배치에서는 context가 생성되기 전이기 때문에 파라미터로 넘겨 JobLauncer에서 생성하여 처리하도록 한다.
                if(BxmBatchConstants.BATCH_DEFAULT_LOG_LEVEL.equals(logLevel.toUpperCase()))
                {
                    if(ContextTrace.getCurrentContext() != null)
                    {
                        DefaultLogLevel defaultLogLevel = (DefaultLogLevel) BatchApplicationContext.getDataContainer().get(BatchContextConstans.CMDC_DEFAULT_LOGLEVEL);
                        if(defaultLogLevel != null)
                        {
                            switch (layer) {
                                case SYS:
                                    appLogLevel = defaultLogLevel.getSysLogLevel();
                                    break;
                                case BIZ:
                                    appLogLevel = defaultLogLevel.getBizLogLevel();
                                    break;
                                case DB:
                                    appLogLevel = defaultLogLevel.getDBLogLevel();
                                    break;
                                default:
                                break;
                            }
                        }
                    }
                    else
                    {
                        appLogLevel = null;
                    }
                }
                else
                {
                    appLogLevel = Enum.valueOf(ApplicationLogLevel.class, logLevel.toUpperCase());
                    if(ContextTrace.getCurrentContext() != null)
                    {
                        switch (layer) {
                            case SYS:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setSysLoggingLevel(appLogLevel);
                                break;
                            case BIZ:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setBizLoggingLevel(appLogLevel);
                                break;
                            case DB:
                                ((ServiceTraceContextImpl)ContextTrace.getCurrentContext()).setDBLoggingLevel(appLogLevel);
                                break;
                            default:
                                break;
                        }
                    }
                }
            }
        }
        catch(IllegalArgumentException ie)
        {
            logger.warn("Can not apply registered batch [{}] loglevel. Invalid value [{}]. set default loglevel"
                    , new Object[]{jobId, logLevel}, ie);
        }

        return appLogLevel;
    }
}