스케줄러 서비스 개발

/*
 * Copyright (c) 2016 by TmaxSoft co., Ltd.
 * All rights reserved.
 *
 * This software is the confidential and proprietary information
 * of TmaxSoft co., Ltd("Confidential Information").  You
 * shall not disclose such Confidential Information and shall use
 * it only in accordance with the terms of the license agreement
 * you entered into with TmaxSoft co., Ltd.
 */

package com.tmax.proobject.schedule.handler;

import com.tmax.proobject.model.dataobject.DataObject;
import com.tmax.proobject.schedule.model.ScheduleModelSet;

/**
 * 스케줄이 트리거에의해 기동했을때 선후처리 혹은 에러 처리를 위한 핸들러 인터페이스이다.</br>
 * 스케줄 플로우 기능 사용시, 스케줄 플로우가 시작되고 종료될 때의 선후처리 혹은 에러 처리를 한다.</br>
 * 구현후 구현체는 system/lib에 위치시켜야하며 proobject.xml의 schedule-config에 관련 설정을 추가해야 한다.
 *
 * @author unseok.kim
 * @since  2019. 12. 4.
 */
public interface IScheduleTriggerHandler {

    /**
     * 스케줄이 트리거되어 실행되기 직전 처리해야하는 로직이 있다면, 이 메소드를 통해 구현한다.</br>
     * 반환값이 true인 경우, 스케줄을 통한 SO,JOB,SHELL을 실행시키지 않고 다음 주기를 스케줄링한다.
     *
     * @since 2019. 12. 4.
     * @param sid 트리거된 스케줄의 아이디
     * @param exId 트리거된 스케줄의 실행 번호 혹은 플로우 기능 사용시 트리거된 스케줄 플로우의 실행번호
     * @param set 트리거된 스케줄의 정보가 담겨있는 모델 객체
     * @return 현재 트리거된 스케줄을 skip할지 여부를 결정한다.
     */
    public boolean preProcess(String sid, String exId, ScheduleModelSet set);


    /**
     * 스케줄이 트리거되어 실행된후, 스케줄을 통해 실행된 SO, JOB, SHELL의 동작이 종료된후 실행할 로직
     *
     * @since 2019. 12. 4.
     * @param sid 트리거된 스케줄의 아이디
     * @param exId 트리거된 스케줄의 실행 번호 혹은 플로우 기능 사용시 트리거된 스케줄 플로우의 실행번호
     * @param set 트리거된 스케줄의 정보가 담겨있는 모델 객체
     * @param outputDataObject 트리건된 스케줄이 호출한 ServiceObject의 반환값.</br>
     * Job 혹은 스탠드얼론으로 호출된 서비스의 경우 반환값이 존재하지 않기 때문에 데이터가 전달되지 않음을 유의.
     */
    public void postProcess(String sid, String exId, ScheduleModelSet set, DataObject outputDataObject);

    /**
     * 스케줄이 트리거되어 실행된후, 스케줄을 통해 실행된 SO, JOB, SHELL이 에러를 발생시키며 종료된경우 실행할 로직
     *
     * @since 7 Fix #1
     * @param sid 트리거된 스케줄의 아이디
     * @param exId 트리거된 스케줄의 실행 번호 혹은 플로우 기능 사용시 트리거된 스케줄 플로우의 실행번호
     * @param set 트리거된 스케줄의 정보가 담겨있는 모델 객체
     * @param t 스케줄을 통해 실행된 SO, JOB, SHELL에서 발생시킨 Exception
     */
    public void postProcessOnError(String sid, String exId, ScheduleModelSet set, Throwable t);

}

package com.tmax.proobject.schedule.handler;

import com.tmax.proobject.model.dataobject.DataObject;
import com.tmax.proobject.schedule.event.ScheduleTriggerEvent.ScheduleTriggerEventPhase;
import com.tmax.proobject.schedule.model.ScheduleModelSet;

/**
 * 스케줄 플로우를 통해 실행되는 각각의 작업들에 대한 후처리 및 에러 처리를 위한 핸들러 인터페이스이다.</br>
 * 구현 후 구현체는 system/lib에 위치시켜야하며, proobject.xml의 schedule-config에 관련 설정을 추가해야
 * 한다.
 *
 * @author YimSinHyuk
 * @since 2021. 2. 25.
 */
public interface IScheduleFlowSequenceHandler {

    /**
     * 스케줄러가 서비스 혹은 배치 잡을 호출하여, PO_SCHEDULE_STATUS에 이력을 남길때 호출되는 인터페이스
     *
     * @since 7 Fix #1
     * @param sid       현재 실행하려는 스케줄의 아이디
     * @param exId      현재 실행하려는 스케줄의 실행 번호
     * @param flowExId  현재 실행하려는 스케줄이 속한 플로우의 실행 번호
     * @param phase     현재 실행하려는 스케줄의 단계(PRE, MAIN, POST)
     * @param seq       현재 실행하려는 스케줄의 순서
     * @param repeatCnt 현재 실행하려는 스케줄의 반복횟수
     * @param set       현재 실행하려는 스케줄의 정보가 담겨있는 모델 객체
     */
    public void preProcess(String sid, String exId, String flowId, String flowExId, ScheduleTriggerEventPhase phase, int seq, int repeatCnt,
            ScheduleModelSet set);

    /**
     * 스케줄러가 호출한 서비스 혹은 배치 잡에 대한 응답이 돌아와서, PO_SCHEDULE_STATUS의 이력을 지우고, </br>
     * PO_SCHEDULE_HISTORY로 이력을 옮기려고 할 때 호출되는 인터페이스
     *
     * @since 7 Fix #1
     * @param sid              실행한 스케줄의 아이디
     * @param exId             실행한 스케줄의 실행 번호
     * @param flowExId         실행한 스케줄이 속한 플로우의 실행 번호
     * @param phase            실행한 스케줄의 단계(PRE, MAIN, POST)
     * @param seq              실행한 스케줄의 순서
     * @param repeatCnt        실행한 스케줄의 반복횟수
     * @param set              실행한 스케줄의 정보가 담겨있는 모델 객체
     * @param outputDataObject 스케줄이 호출한 ServiceObject의 응답 결과.</br>
     * Job 혹은 스탠드얼론으로 실행시킨 서비스의 경우, DataObject로 결과가 반환되지 않기 때문에 데이터가 전달되지 않음을 유의.
     */
    public void postProcess(String sid, String exId, String flowId, String flowExId, ScheduleTriggerEventPhase phase, int seq, int repeatCnt,
            ScheduleModelSet set, DataObject outputDataObject);

    /**
     * 스케줄러가 호출한 서비스 혹은 배치 잡이 실패하여 응답값에 에러가 포함된 경우, PO_SCHEDULE_STATUS의 이력을 지우고,
     * </br>
     * PO_SCHEDULE_HISTORY로 이력을 옮기려고 할 때 호출되는 인터페이스
     *
     * @since 7 Fix #1
     * @param sid               실행한 스케줄의 아이디
     * @param exId              실행한 스케줄의 실행 번호
     * @param flowExId          실행한 스케줄이 속한 플로우의 실행 번호
     * @param phase             실행한 스케줄의 단계(PRE, MAIN, POST)
     * @param seq               실행한 스케줄의 순서
     * @param repeatCnt         실행한 스케줄의 반복횟수
     * @param set               실행한 스케줄의 정보가 담겨있는 모델 객체
     * @param responseException 호출한 서비스나 배치 잡에 대한 에러
     */
    public void postProcessOnError(String sid, String exId, String flowId, String flowExId, ScheduleTriggerEventPhase phase, int seq, int repeatCnt,
            ScheduleModelSet set, Throwable responseException);
}

-- PO_Schedule_Calendar Table Create SQL
CREATE TABLE PO_SCHEDULE_CALENDAR
(
    CALID            VARCHAR2(64)    NOT NULL,
    CALNAME          VARCHAR2(64)    NULL,
    CALENDARTYPE     VARCHAR2(20)    NULL,
    PATTERN          VARCHAR2(4000)  NULL,
    PARENTCALID      VARCHAR2(64)    NULL,
    EXCLUSIVEFLAG    VARCHAR2(5)     NULL,
    DESCRIPTION      VARCHAR2(4000)  NULL,
    CONSTRAINT PO_SCHEDULE_CALENDAR_PK PRIMARY KEY (CALID)
);
COMMENT ON TABLE PO_SCHEDULE_CALENDAR IS '스케줄 캘린더';
COMMENT ON COLUMN PO_SCHEDULE_CALENDAR.CALID IS '캘린더 ID';
COMMENT ON COLUMN PO_SCHEDULE_CALENDAR.CALNAME IS '캘린더 명';
COMMENT ON COLUMN PO_SCHEDULE_CALENDAR.CALENDARTYPE IS '캘린더타입(일,주,월,AD)';
COMMENT ON COLUMN PO_SCHEDULE_CALENDAR.PATTERN IS '캘린더 패턴';
COMMENT ON COLUMN PO_SCHEDULE_CALENDAR.DESCRIPTION IS '캘린더에 대한설명';

--  Table Create SQL
CREATE TABLE PO_SCHEDULE_TRIGGER
(
    STRIGERID          VARCHAR2(64)      NOT NULL,
    SCHEDULETYPE       VARCHAR2(20)      NULL,
    CRONEXPRESSION     VARCHAR2(30)      NULL,
    BIZ_CALID          VARCHAR2(64)      NULL,
    HOLY_CALID         VARCHAR2(64)      NULL,
    EXCEPTIONTYPE      VARCHAR2(20)      NULL,
    EXCEPTIONDATE      VARCHAR2(20)      NULL,
    REPEATMAXCNT       NUMBER(18, 0)     NULL,
    REPEATINTERVAL     NUMBER(18, 0)     NULL,
    DUPLEEXEYN         VARCHAR2(1)       NULL,
    INVOKEDELAYTIME    NUMBER(18, 0)     NULL,
    DESCRIPTION        VARCHAR2(4000)    NULL,
    CONSTRAINT PO_SCHEDULE_TRIGGER_PK PRIMARY KEY (STRIGERID)
);
COMMENT ON TABLE PO_SCHEDULE_TRIGGER IS '스케줄 실행 조건';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.STRIGERID IS '스케줄 트리거 ID';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.SCHEDULETYPE IS 'CRON(캘린더 만들지 않고), CALENDAR';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.CRONEXPRESSION IS 'SCHEDULETYPE가 CRON일 경우 EXPRESSION';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.REPEATMAXCNT IS '최대 반복 횟수';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.REPEATINTERVAL IS '반복 주기(MS)';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.DUPLEEXEYN IS '중복실행가능여부';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.INVOKEDELAYTIME IS 'INVOKE 조건 만족 후, 호출 딜레이';
COMMENT ON COLUMN PO_SCHEDULE_TRIGGER.DESCRIPTION IS '스케줄 주기에 대한설명';

-- PO_SCHEDULE_MAIN TABLE CREATE SQL
CREATE TABLE PO_SCHEDULE_MAIN
(
    SID           VARCHAR2(64)    NOT NULL,
    SNAME         VARCHAR2(64)    NULL,
    USERYN        VARCHAR2(1)    NULL,
    STARTTIME     VARCHAR2(14)    NULL,
    ENDTIME       VARCHAR2(14)    NULL,
    STRIGERID     VARCHAR2(64)    NULL,
    TARGETID      VARCHAR2(64)    NULL,
    MODIFYTIME    VARCHAR2(14)    NULL,
    INVOKECNT     NUMBER(5, 0)    DEFAULT -1,
    NODEID        VARCHAR2(128)   NULL,
    FLOWID        VARCHAR2(64)    NULL,
    BIZCODE       VARCHAR2(64)    NULL,
    DESCRIPTION   VARCHAR2(4000)  NULL,
    CONSTRAINT PO_SCHEDULE_MAIN_PK PRIMARY KEY (SID)
);
COMMENT ON TABLE PO_SCHEDULE_MAIN IS '스케줄 메인';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.SID IS '스케줄 ID';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.SNAME IS '스케줄명';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.USERYN IS '스케줄 사용여부';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.STARTTIME IS '스케줄 실행 가능시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.ENDTIME IS '스케줄 유효 만료 시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.STRIGERID IS '스케줄 트리거 ID';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.TARGETID IS '실행 JOB ID';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.MODIFYTIME IS '최근 수정시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.FLOWID IS '스케줄이 속한 FLOW의 ID';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.BIZCODE IS '업무코드';
COMMENT ON COLUMN PO_SCHEDULE_MAIN.DESCRIPTION IS '스케줄에 대한 설명';

-- PO_SCHEDULE_MAIN TABLE CREATE SQL
CREATE TABLE PO_SCHEDULE_STATUS
(
    SID               VARCHAR2(64)    NOT NULL,
    SEXNUM            VARCHAR2(64)    NULL,
    STARTTIME         VARCHAR2(14)    NULL,
    MODIFYTIME        VARCHAR2(14)    NULL,
    STATUS            VARCHAR2(20)    NULL,
    TYPE              VARCHAR2(20)    NULL,
    SEQ               NUMBER(18),
    REPEATCNT         NUMBER(18, 0)   NULL,
    NODEID            VARCHAR2(128)   NULL,
    FLOWID            VARCHAR2(64)    NULL,
    FLOWEXNUM         VARCHAR2(64)    NULL,
    RUN_IMMEDIATELY   NUMBER(1)       NULL,
    CONSTRAINT PO_SCHEDULE_STATUS_PK PRIMARY KEY (SID, SEXNUM)
);
COMMENT ON TABLE PO_SCHEDULE_STATUS IS '스캐쥴 진행중에만 해당 테이블 사용하며 종료시 PO_SCHEDULE_HISTORY 로 데이터 전달';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.SID IS '스케줄 ID';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.SEXNUM IS '스케줄 실행번호';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.MODIFYTIME IS '최근 수정시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.STATUS IS '상태(PREPARE, RUNNING, TERMINATING)';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.TYPE IS '스케줄링 대상이 JOB인 경우, 선행 배치인지 본배치인지 후행 배치인지 여부';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.SEQ IS '스케줄링 대상이 JOB이면서 선/후행 배치인 경우, 실행 순서';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.REPEATCNT IS '현재 반복 회차';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.NODEID IS '실행되고 있는 노드 아이디';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.FLOWID IS '스케줄이 속한 FLOW의 ID';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.FLOWEXNUM IS '스케줄 flow 실행번호';
COMMENT ON COLUMN PO_SCHEDULE_STATUS.RUN_IMMEDIATELY IS '즉시 실행 여부'


-- PO_SCHEDULE_HISTORY TABLE CREATE SQL
CREATE TABLE PO_SCHEDULE_HISTORY
(
    SID              VARCHAR2(64)    NOT NULL,
    SEXNUM           VARCHAR2(64)    NULL,
    STATUS           VARCHAR2(20)    NULL,
    TYPE             VARCHAR2(20)    NULL,
    SEQ              NUMBER(18),
    REPEATCNT        NUMBER(18, 0)   NULL,
    STARTTIME        VARCHAR2(14)    NULL,
    ENDTIME          VARCHAR2(14)    NULL,
    NODEID           VARCHAR2(128)   NULL,
    ERRMSG           CLOB            NULL,
    FLOWID           VARCHAR2(64)    NULL,
    FLOWEXNUM        VARCHAR2(64)    NULL,
    RUN_IMMEDIATELY  NUMBER(1)       NULL,
    CONSTRAINT PO_SCHEDULE_HISTORY_PK PRIMARY KEY (SID,SEXNUM)
);
COMMENT ON TABLE PO_SCHEDULE_HISTORY IS '스케줄 히스토리';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.SID IS '스케줄 ID';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.SEXNUM IS '스케줄 실행번호';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.TYPE IS '스케줄링 대상이 JOB인 경우, 선행 배치인지 본배치인지 후행 배치인지 여부';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.SEQ IS '스케줄링 대상이 JOB이면서 선/후행 배치인 경우, 실행 순서';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.REPEATCNT IS '현재 반복 회차';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.STATUS IS '상태(TERMINATED,  COMPLETED, FAILED, REVISED)';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.STARTTIME IS '시작시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.ENDTIME IS '종료시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.FLOWID IS '스케줄이 속한 FLOW의 ID';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.FLOWEXNUM IS '스케줄 flow 실행번호';
COMMENT ON COLUMN PO_SCHEDULE_HISTORY.RUN_IMMEDIATELY IS '즉시 실행 여부'

-- PO_SCHEDULE_TARGET TABLE CREATE SQL
CREATE TABLE PO_SCHEDULE_TARGET
(
    TARGETID       VARCHAR2(64)     NOT NULL,
    EXJOBTYPE      VARCHAR2(20)     NULL,
    EXINPUTDATA    VARCHAR2(4000)   NULL,
    EXHEADERDATA   VARCHAR2(4000)   NULL,
    EXNODEID       VARCHAR2(128)    NULL,
    EXNAME1        VARCHAR2(64)     NULL,
    EXNAME2        VARCHAR2(64)     NULL,
    EXNAME3        VARCHAR2(64)     NULL,
    DESCRIPTION    VARCHAR2(4000)   NULL,
    CONSTRAINT PO_SCHEDULE_TARGET_PK PRIMARY KEY (TARGETID)
);
COMMENT ON TABLE PO_SCHEDULE_TARGET IS '스케줄 실행 대상 정보';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.TARGETID IS '실행 JOB ID';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXJOBTYPE IS '실행 JOB 종류(JO,SO,SHELL)';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXINPUTDATA IS 'JO, SO : INPUTMSGTEXT, SHELL : SHELL PARAMETER';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXNODEID IS '스케줄이 실행되는 노드';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXNAME1 IS 'JO, SO : APPLICATIONNAME, SHELL : SHELL파일명';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXNAME2 IS 'JO, SO : SERVICEGROUP, SHELL : 파일 경로';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.EXNAME3 IS 'JO, SO : SERVICE, SHELL : 사용하지 않음';
COMMENT ON COLUMN PO_SCHEDULE_TARGET.DESCRIPTION IS '타겟에 대한설명';

CREATE TABLE PO_SCHEDULE_MAIN_FLOW(
    FLOWID              VARCHAR2(64)    NOT NULL,
    PRECONDITION        NUMBER(1),
    POSTCONDITION       NUMBER(1),
    INNERPRECONDITION   NUMBER(1),
    INNERPOSTCONDITION  NUMBER(1),
    DAILYEXECNT         NUMBER(18),
    CURRENTEXECNT       NUMBER(18) DEFAULT 0,
    LATESTEXEDATE       DATE,
    DESCRIPTION         VARCHAR2(4000)
);
ALTER TABLE PO_SCHEDULE_MAIN_FLOW ADD CONSTRAINT PO_SCHEDULE_MAIN_FLOW_PK PRIMARY KEY (FLOWID);

COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.FLOWID IS '스케줄 flow를 구분지을 아이디';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.PRECONDITION IS '선행배치가 존재할 경우, 본배치를 실행시키기 위한 조건. -1: always, 0: fail, 1: success';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.POSTCONDITION IS '후행배치가 존재할 경우, 후행배치를 실행시키기 위한 조건. -1: always, 0: fail, 1: success';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.INNERPRECONDITION IS '선행배치 내부에서 다음 선행 배치를 실행시키기 위한 조건. -1: always, 0: fail, 1: success';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.INNERPOSTCONDITION IS '후행배치 내부에서 다음 후행 배치를 실행시키기 위한 조건. -1: always, 0: fail, 1: success';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.DAILYEXECNT IS '본배치가 스케줄링됬을때 제한할 일별 실행횟수 제한';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.CURRENTEXECNT IS '본배치가 스케줄링됬을때 제한할 일별 실행횟수 제한에 해당하는 실행횟수';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.LATESTEXEDATE IS '스케줄이 실행된 가장 최신 일자';
COMMENT ON COLUMN PO_SCHEDULE_MAIN_FLOW.DESCRIPTION IS '스케줄 flow에 대한설명';


CREATE TABLE PO_SCHEDULE_SUB_FLOW(
    FLOWID           VARCHAR2(64)     NOT NULL,
    SEQ              NUMBER(18)       NOT NULL,
    TYPE             VARCHAR2(20)     NOT NULL,
    TARGETID         VARCHAR2(64)     NOT NULL,
    REPEATMAXCNT     NUMBER(18, 0)    NULL,
    REPEATINTERVAL   NUMBER(18, 0)    NULL,
    DESCRIPTION      VARCHAR2(4000)   NULL
);
ALTER TABLE PO_SCHEDULE_SUB_FLOW ADD CONSTRAINT PO_SCHEDULE_SUB_FLOW_PK PRIMARY KEY (FLOWID, SEQ, TYPE);
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.FLOWID IS '선/후행 배치가 속한 flow의 아이디';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.SEQ IS '선/후행 배치의 실행 순서';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.TYPE IS '"PRE" : 선행 배치, "POST": 후행배치';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.TARGETID IS '선/후행 배치가 실행시켜야 하는 JOB의 TARGETID';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.REPEATMAXCNT IS '최대 반복 횟수';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.REPEATINTERVAL IS '반복 주기(MS)';
COMMENT ON COLUMN PO_SCHEDULE_SUB_FLOW.DESCRIPTION IS '스케줄 선후행 flow에 대한설명';

CREATE TABLE PO_SCHEDULE_FLOW_STATUS(
    FLOWID        VARCHAR2(64)    NOT NULL,
    FLOWEXNUM     VARCHAR2(64)    NULL,
    STATUS        VARCHAR2(20)    NULL,
    STARTTIME     VARCHAR2(14)    NULL,
    ENDTIME       VARCHAR2(14)    NULL,
    NODEID        VARCHAR2(128)   NULL,
    RUN_IMMEDIATELY  NUMBER(1)    NULL,
    ERRMSG        CLOB            NULL
);
ALTER TABLE PO_SCHEDULE_FLOW_STATUS ADD CONSTRAINT PO_SCHEDULE_FLOW_STATUS_PK PRIMARY KEY (FLOWID, FLOWEXNUM);
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.FLOWID IS '선/후행 배치가 속한 flow의 아이디';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.FLOWEXNUM IS '스케줄 flow 실행번호';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.STATUS IS '상태(RUNNING)';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.STARTTIME IS '시작시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.ENDTIME IS '종료시간(YYYYMMDDHHMMSS)';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.RUN_IMMEDIATELY IS '즉시 실행 여부';
COMMENT ON COLUMN PO_SCHEDULE_FLOW_STATUS.ERRMSG IS '플로우 실행에 관한 에러 메세지';

--5초 마다 스케줄, 반복 없음, 중복실행 없음
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeid)
VALUES ('sId1', 'sName1', 'y', '20170101010101', '20200101010101', 'sId1_TR', 'sId1_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId1_TR', 'cron', '0/5 * * * * ?', 0,0, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId1_TA', 'SO', '', '', 'test', 'example', 'JobServiceCCTargetSample');

--1분 마다 스케줄, 반복 없음, 중복실행 없음
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeid)
VALUES ('sId2', 'sName2', 'y', '20170101010101', '20200101010101', 'sId2_TR', 'sId2_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId2_TR', 'cron', '0 0/1 * 1/1 * ? *', 0,0, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId2_TA', 'SO', '', '', 'test', 'example', 'JobServiceCCTargetSample');

--1분 마다 스케줄, 무한반복 2초간격, 중복실행 없음
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeid)
VALUES ('sId3', 'sName3', 'y', '20170101010101', '20200101010101', 'sId3_TR', 'sId3_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId3_TR', 'cron', '0 0/1 * 1/1 * ? *',-1,2000, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId3_TA', 'SO', '', '', 'test', 'example', 'JobServiceCCTargetSample');

--4초 마다 스케줄, 반복 없음, 중복실행 없음, input값 있음
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeid)
VALUES ('sId4', 'sName4', 'y', '20170101010101', '20200101010101', 'sId4_TR', 'sId4_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId4_TR', 'cron', '0/4 * * * * ?',0,0, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId4_TA', 'SO', '{"cc_id":"SAMPLE1","cc_exe_id":"testEx1","retry_yn":"n"}', '', 'test', 'example', 'JobServiceCCTargetSample');

--5초 마다 스케줄, 반복 없음, 중복실행 없음, 배치 실행
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeid)
VALUES ('sId5', 'sName5', 'y', '20170101010101', '20200101010101', 'sId5_TR', 'sId5_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId5_TR', 'cron', '0/5 * * * * ?',0,0, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId5_TA', 'JO', '', '', 'test', 'svcGrpTest', 'JobServiceNormalSample');

--5초 마다 스케줄, 반복 없음, 중복실행 없음, 프로배치 실행
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime, nodeId)
VALUES ('sId10', 'sName10', 'y', '20170101010101', '20200101010101', 'sId10_TR', 'sId10_TA', '20170101010101', 'ProObject7');

INSERT INTO PO_Schedule_Trigger (sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval, dupleExeYn, invokeDelayTime)
VALUES ('sId10_TR', 'cron', '0/5 * * * * ?',0,0, 'n', 1);

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('sId10_TA', 'PROBATCH', '', 'ProBatch_1', '', '', 'JobServiceNormalSample');

truncate table PO_Schedule_Main;
truncate table PO_Schedule_TARGET;
truncate table PO_Schedule_Trigger;

--INSERT INTO PO_Schedule_Calendar (calId, calName, calendarType, pattern, inCalId, exCalId, exceptionType, exceptionDate)
VALUES ('calId1', '', '', '', '', '', '', '');
--INSERT INTO PO_Schedule_Calendar (calId, calName, calendarType, pattern, inCalId, exCalId, exceptionType, exceptionDate)
VALUES ('calId2', '', '', '', '', '', '', '');
--truncate table PO_Schedule_Calendar;

--정상 등록되었는지 확인하는 쿼리
SELECT *
FROM PO_Schedule_Main main, PO_Schedule_Trigger tri, PO_Schedule_TARGET tar
WHERE main.sTrigerId=tri.sTrigerId AND main.targetId=tar.targetId;

---calenar data
insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('cron_daily', 'cron_daily', 'CRON', '15 0 * * * ?', '', 'false');

insert into PO_Schedule_Calendar(calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('anual_daily', 'anual_daily', 'ANNUAL', '11.28,11.30,12.01,12.03,12.05', '', 'false');

insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('month_daily', 'month_daily', 'MONTHLY',
'true,false,false,false,false,false,false,false,false,false,false,false,false,false,
false,false,false,false,false,false,false,false,false,false,false,false,false,false,
false,false,false', '', 'false');

insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values('calId_weekly', 'calId_weekly', 'WEEKLY', 'false,false,false,false,false,false,false', '', 'false');

insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('calId_daily', 'calId_daily', 'DAILY', '09:00,18:00', '', 'false');

insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('calId_RANGE', 'calId_RANGE', 'RANGE', '2018.11.28 09:00,2018.12.02 19:00', '', 'false');

insert into PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
values ('calId_DAYS', 'calId_DAYS', 'DAYS', '2018.11.28,2018.12.02,2018.12.03', '', 'false');

----5초 마다 스케줄, 반복 없음, 중복실행 없음
INSERT INTO PO_Schedule_Main (sId, sName, userYn, startTime, endTime, sTrigerId, targetId, modifyTime)
VALUES ('exT1', 'sName1', 'y', '20170101010101', '20200101010101', 'exT1_TR', 'exT1_TA', '20170101010101');

INSERT INTO PO_Schedule_Trigger(sTrigerId, scheduleType, cronExpression, repeatMaxCnt, repeatInterval,
dupleExeYn, invokeDelayTime, biz_calId, holy_calId)
VALUES ('exT1_TR', 'cron', '0/5 * * * * ?', 0,0, 'n', 1, 'ExCanual_daily', '');

INSERT INTO PO_Schedule_TARGET (targetId, exJobType, exInputData, exNodeId, exName1, exName2, exName3)
VALUES ('exT1_TA', 'SO', '', '', 'proobject', 'batch', 'JobServiceCCTargetSample');

INSERT INTO PO_Schedule_Calendar (calId, calName, calendarType, pattern, parentCalId, exclusiveFlag)
VALUES ( 'ExCanual_daily', 'ExCanual_daily', 'ANNUAL', '', '', 'false');

////////////스케줄 데이터 생성 시작////////////
ServiceName name = new ServiceName("appName", "svcgrpName", "JobServiceNormalSample");
ScheduleBuilder builder = new ScheduleBuilder();

//appName, svcGrpName, svcName, inputJson
builder.configJob(name.getApplicationName(), name.getServiceGroupName(), name.getServiceName(),
"{\"cc_id\":\"SAMPLE1\",\"cc_exe_id\":\"testEx1\",\"retry_yn\":\"n\"}");

builder.configCron("0/5 * * * * ?");//5초마다
//builder.configValidTime("20110101235000", "20200101235000");
//builder.configRepeat(-1, 1000, false);
ScheduleModelSet set = builder.build("scheduleId1", "ScheduleName1");
////////////스케줄 데이터 생성 끝////////////


//스케줄을 등록하며, 등록한 시점부터 동작한다.
ScheduleRegister.getInstance().regist(set, Storage_Type.MEMORY);//메모리에 스케줄을 등록한다.
//ScheduleRegister.getInstance().regist(set, Storage_Type.DB);//DB에 스케줄을 등록한다.

//스케줄을 삭제한다.
ScheduleRegister.getInstance().unregist("scheduleId1");//메모리에 sid가 있으면 삭제하며, 메모리에 없으면 DB에 delete를 수행한다.
//ScheduleRegister.getInstance().unregist("scheduleId1", Storage_Type.MEMORY);//메모리에 등록된 sid를 삭제한다.
//ScheduleRegister.getInstance().unregist("scheduleId1", Storage_Type.DB);//DB에 등록된 sid를 삭제한다.

String sId = "scheduleId1";
String sName = "ScheduleName1";

ScheduleModelSet set = new ScheduleModelSet();
ScheduleBuilder builder = new ScheduleBuilder();
builder.configCron("0/30 * * 1/1 * ? 2019");
builder.configJob("test", "main","S_Callee","");
builder.configValidTime("20190819110000", "99990819111500");

set=builder.build(sId, sName);
set.getMainModel().setSid("scheduleId1");
set.getMainModel().setDisposableYn(true);
set.getMainModel().setExjobid(null);
set.getMainModel().setInvokeCnt(0);
set.getMainModel().setModifytime("20190823174150");
set.getMainModel().setNodeId("scheduleId1_TA");
set.getMainModel().setSname(sName);
set.getMainModel().setStarttime("30000819110000");
set.getMainModel().setStrigerid("scheduleId1_TR");
set.getMainModel().setUseryn("Y");
set.getTriggerModel().setCronexpression("0/30 * * 1/1 * ? 2019");

ScheduleRegister.getInstance().modify(set, Storage_Type.DB);

ScheduleControlDataObject _scheduleControlDataObject = new ScheduleControlDataObject();
try {
    RequestContext requestContext = ServiceManager.getServiceRequestContext("proobject.schedule.ScheduleControlService");
    ServiceManager.call(requestContext, "proobject.schedule.ScheduleControlService", _scheduleControlDataObject);
   } catch (ServiceCallFailedException e){
}

// 1. ScheduleModelSet 생성을 위한 ScheduleBuilder 객체 생성
ScheduleBuilder builder = new ScheduleBuilder();

// 2. 스케줄후 실행할 작업을 설정한다.
// PO_SCHEDULE_TARGET에 데이터가 저장되며, 스케줄 주기가 도래했을때 실행할 서비스 혹은 배치를 설정한다.
// 스케줄 작업의 종류는 SO, JO, SHELL로 각 종류에 맞는 문자열을 입력한다.
// test.main.service를 실행시키는 예제이다.
builder.configJob("test", "main", "service", "{\"value\":\"call\"}", "SO", "서비스");

// 3. 스케줄 주기를 설정한다.
// PO_SCHEDULE_TRIGGER에 데이터가 저장되며, 스케줄이 실행되는 조건을 설정한다.
// 스케줄 트리거를 입력하는 것이며, 스케줄 주기는 CRON EXPRESSION 문법에 맞게 입력한다.
builder.configCron("0 0/1 * 1/1 * ? *");

// 4. 스케줄이 트리거되었을때 반복실행에 관한 설정을 입력한다.
// PO_SCHEDULE_TRIGGER에 데이터가 저장된다.
// 스케줄 플로우 기능을 사용하는 경우 본배치의 반복 실행에 관한 값을 입력한다.
builder.configRepeat(0, 0, false);

// 5. 스케줄 플로우의 메인 플로우 정보를 입력한다.
// PO_SCHEDULE_MAIN_FLOW에 데이터가 저장된다.
// 메인 플로우가 등록되지 않은 경우, 메인 플로우 정보도 같이 생성하기위해 사용하는 API이다.
// 서브 플로우에 대한 실행 조건, 일별 실행횟수 제한을 설정한다.
// 서브 플로우에 대한 실행 조건은 com.tmax.proobject.schedule.repository.ScheduleBuilder.ExecuteCondition 클래스를 통해 입력한다.
builder.configScheduleMainFlow("flowId1",  ExecuteCondition.SUCCESS, ExecuteCondition.SUCCESS, ExecuteCondition.SUCCESS, ExecuteCondition.SUCCESS, 1);

// 6. 스케줄 플로우의 서브 플로우 정보를 입력한다.
// PO_SCHEDULE_SUB_FLOW에 데이터가 저장되며, 서브 플로우의 실행 순서, 서브 플로우의 타입, 서브 플로우가 실행시킬 대상 아이디를 설정한다.
// 서브플로우의 순서는 항상 '1'부터 시작한다.
builder.configScheduleSubFlow("flowId1", 1, SubFlowType.PRE, "subTarget1", 0, 0);
builder.configScheduleSubFlow("flowId1", 1, SubFlowType.POST, "subTarget2", 0, 0);

// 7. 서브 플로우가 실행시킬 대상 작업의 정보를 입력한다.
// 사전에 반드시 configScheduleSubFlow api를 통해 서브 플로우 설정을 추가한다음 호출해야한다.
// configScheduleSubFlow로 추가한 서브플로우의 타겟이 존재하지않는 경우, 해당 타겟을 추가하기 위한 API이다.
// configScheduleSubFlow에 지정한 seq와 type을 기준으로 타겟 정보가 추가된다.
// 스케줄 작업의 종류는 SO, JO, SHELL로 com.tmax.proobject.schedule.repository.ScheduleBuilder.Schedule_Job_Type을 입력한다.
builder.addFlowJob(1, SubFlowType.PRE, "subTarget1", "test", "main", "service", "{\"value\":\"call2\"}", Schedule_Job_Type.SO, "선행배치1");
builder.addFlowJob(1, SubFlowType.POST, "subTarget2", "test", "main", "service", "{\"value\":\"call2\"}", Schedule_Job_Type.SO, "후행배치1");

// 8. 등록하려는 스케줄이 동작할 수 있는 유효기간을 입력한다.
// 스케줄 주기와 상관없이 등록하려는 스케줄은 설정한 기간 내에서만 동작한다.
builder.configValidTime("20210101000000", "20220101000000");

// 9. 스케줄러가 실행될수있는 횟수를 지정한다.
// 스케줄은 지정된 횟수만큼 실행하고 삭제한다.
// -1을 설정하는 경우 스케줄을 무한대로 실행한다.
builder.configInvokeCount(1);

// 10. 스케줄러를 사용가능한 상태로 등록할지 여부를 설정한다.
// 스케줄을 등록할 때 userYN값을 통해서 스케줄이 런타임으로 로드될지 말지 결정합니다.
builder.configUse(false);

// 11. ScheduleModelSet을 생성한다.
// PO_SCHEDULE_MAIN, TARGET, TRIGGER, MAIN_FLOW의 아이디 값을 입력한다.
// flowId   : ScheduleBuilder를 통해 처음 main flow를 등록하시는 경우 configScheduleMainFlow API에 입력했던 flowId를 그대로 입력합니다. /  이미 메인 플로우가 등록되어있는 경우, 스케줄이 속해야하는 플로우 아이디를 입력합니다.
// sId      : 스케줄을 구분지을수 있는 아이디
// sName    : 스케줄 한글이름
// sTrigerId    : configCron과 configRepeat을 통해 설정한 스케줄 트리거의 아이디. 입력하지 않을시 '스케줄아이디 + _TR'로 설정됩니다.
// sTargetId    : configJob을 통해 설정한 스케줄 타겟의 아이디. 입력하지 않을시 '스케줄아이디 + _TA'로 설정됩니다.
// description  : 스케줄 설명
ScheduleModelSet model = builder.build("flowId1", "schedule1", "예제 스케줄", "trigger1", "target1", "스케줄샘플코드");
ScheduleRegister.getInstance().regist(model, Storage_Type.DB);