후행 처리 커스터마이징

private static final String SELECT_APTABLE_SQL =
    " SELECT MAX(%s) " +
    " FROM %s " +
    " WHERE %s > ? AND %s <= COALESCE(CAST(? as int), 0) + ? " +
    " %s "
    ;

@Override
public IDeferredExecInfo getApTableProcInfo(final IDeferredMainInfo deferredMainInfo, long maxSeq)
{
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;

    IDeferredExecInfo deferredExecInfo = null;

    try
    {
        conn = BxmDeferredUtils.getConnection();

        // Table명 설정
        String tableName = null;
        if(deferredMainInfo.isDayTableYn())
        {
            tableName = new StringBuilder().append(deferredMainInfo.getTargetTableNm())
                                           .append(DeferredConstants.TABLE_WORD_SEPARATE_VAL)
                                           .append(BxmDeferredUtils.getDay(deferredMainInfo.getBizDt()))
                                           .toString();
        }
        else
        {
            tableName = deferredMainInfo.getTargetTableNm();
        }

        String sql = null;

        // 노드병 실행 여부에 따른 조회 쿼리 정의
        if(deferredMainInfo.isNodeExecYn())
        {
            sql = String.format(SELECT_APTABLE_SQL
                    , deferredMainInfo.getTargetColumnNm()
                    , tableName
                    , deferredMainInfo.getTargetColumnNm()
                    , deferredMainInfo.getTargetColumnNm()
                    , DeferredConstants.WHERE_NODE_NO_SQL
                    );
        }
        else
        {
            sql = String.format(SELECT_APTABLE_SQL
                    , deferredMainInfo.getTargetColumnNm()
                    , tableName
                    , deferredMainInfo.getTargetColumnNm()
                    , deferredMainInfo.getTargetColumnNm()
                    , ""
                    );
        }

        pstmt = conn.prepareStatement(sql);

        int ix = 0;

        pstmt.setLong(++ix, maxSeq);
        pstmt.setLong(++ix, maxSeq);
        pstmt.setInt(++ix, deferredMainInfo.getFetchCnt());
        if(deferredMainInfo.isNodeExecYn())
        {
            pstmt.setInt(++ix, BxmDeferredUtils.getNodeNo());
        }

        rs = pstmt.executeQuery();
        if(rs.next())
        {
            // 실행정보 설정
            long startSeq = maxSeq + 1;
            long endSeq =  rs.getLong(1);

            if(startSeq != 0 && startSeq <= endSeq)
            {
                deferredExecInfo = new DeferredExecInfo();

                deferredExecInfo.setStartSeq(startSeq);
                deferredExecInfo.setEndSeq(endSeq);
                deferredExecInfo.setDeferredId(deferredMainInfo.getDeferredId());
                deferredExecInfo.setNodeNo(BxmDeferredUtils.getNodeNo());
                deferredExecInfo.setBizDt(deferredMainInfo.getBizDt());
                deferredExecInfo.setDeferredStatusCd(DeferredConstants.EXEC_STATUS_PROCEEDING);
                deferredExecInfo.setStartDttm(BxmDeferredUtils.getCurrentSystemTime());
                deferredExecInfo.setErrCd("");
                deferredExecInfo.setErrMsgCtt("");
            }
        }
    }
    catch (Exception e)
    {
        logger.error(e.getMessage(), e);
        throw new IllegalStateException(e);
    }
    finally
    {
        BxmDeferredUtils.closeDbConn(conn, pstmt, rs);
    }
    return deferredExecInfo;
}

@Override
public DeferredExecIO deferredPreProcessor(final ContextHeader cHeader, final Application application,
        final ServiceTraceContextImpl serviceTraceContextImpl, final IDeferredMainInfo deferredMainInfo
        , final IDeferredExecInfo deferredExecInfo, final Long procSeq)
{
    // Header 설정
    cHeader.setRemoteAddr("localhost");
    cHeader.setUuid(SystemUtils.generateGUID());
    ((IOmmObject)cHeader).set("userId", "deferredExecutor");

    // 후행 처리 Service 입력 데이터 생성
    DeferredExecIO deferredExecIO = new DeferredExecIO();
    deferredExecIO.setDeferredId(deferredExecInfo.getDeferredId());
    deferredExecIO.setBizDt(deferredExecInfo.getBizDt());

    // 일련번호 하나씩.. 서비스 호출
    if(DeferredConstants.SVC_PROC_ONE.equals(deferredMainInfo.getSvcProcCd()))
    {
        // Error 가 발생한 일련번호 설정
        deferredExecIO.setProcSeq(procSeq);
    }
    // 대상전체.. 서비스 호출
    else if(DeferredConstants.SVC_PROC_ALL.equals(deferredMainInfo.getSvcProcCd()))
    {
        deferredExecIO.setStartSeq(deferredExecInfo.getStartSeq());
        deferredExecIO.setEndSeq(deferredExecInfo.getEndSeq());
    }
    deferredExecIO.setTargetTableNm(deferredMainInfo.getTargetTableNm());
    deferredExecIO.setTargetColumnNm(deferredMainInfo.getTargetColumnNm());
    deferredExecIO.setNodeNo(deferredExecInfo.getNodeNo());

    return deferredExecIO;
}

@Override
public void executeDeferredService(final ContextHeader cHeader,
        final ServiceTraceContextImpl serviceTraceContextImpl, final IDeferredMainInfo deferredMainInfo, final IOmmObject iOmmObject)
                throws NestedRuntimeException, NestedCheckedException
{
    // Deferred Service 호출
    ServiceExecutor.execute(deferredMainInfo.getBxmAppId(), deferredMainInfo.getSvcNm()
            , deferredMainInfo.getOpNm(), iOmmObject);
}

@Override
public void deferredPostProcessor(final ContextHeader cHeader, final IDeferredMainInfo deferredMainInfo, final IDeferredExecInfo deferredExecInfo)
{

}

@Override
public void deferredErrorPostProcessor(final ContextHeader cHeader
        , final IDeferredMainInfo deferredMainInfo, final IDeferredExecInfo deferredExecInfo, Exception exception, int procNum)
{

}

@Override
public String loadBizDt()
{
    return DateUtils.getCurrentDate(DateUtils.EMPTY_DATE_TYPE);
}

@Override
public void decideApEndYn(IDeferredMainInfo deferredMainInfo, IDeferredWorkInfo deferredWorkInfo)
{
    if ( !isApEndYn(deferredMainInfo))
    {
        return ;
    }

    if (isExistingRunningDeferredService(deferredMainInfo))
    {
        logger.info("Deferred[{}] is running. Can not be closed.", deferredMainInfo.getDeferredId());
    }
    else
    {
        if (isEndDeferredProcessor(deferredMainInfo))
        {
            workEnd(deferredMainInfo, deferredWorkInfo);
        }
    }
}

private boolean isExistingRunningDeferredService(IDeferredMainInfo deferredMainInfo)
{
    return (DeferredContainer.getDeferredDBProcessor().getDeferredExecInfoCount(deferredMainInfo) > 0);
}

private void workEnd(IDeferredMainInfo deferredMainInfo, IDeferredWorkInfo deferredWorkInfo)
{
    deferredWorkInfo.setEndYn(true);
    int result = DeferredContainer.getDeferredDBProcessor().modifyDeferredWorkEnd(deferredWorkInfo);
    if(result != 0)
    {
        logger.info("Deferred[{}] to NodeNo[{}]/BizDate[{}] is now complete."
                , new Object[]{deferredMainInfo.getDeferredId()
                            , deferredWorkInfo.getNodeNo()
                            , deferredMainInfo.getBizDt()});
    }
}