[BizManager] Schedule Execution of Java Class 기능 설명

GXS Korea 문의 결과 해당 기능과 관련한 공식 가이드/메뉴얼 문서는 없는 상황.

BizManager Library 디컴파일 해보면 참고가 될만한 샘플을 볼수가 있어서 해당 내용을 기반으로 첨부와 같이 가이드 문서를 작성

1. 기능 설명

- Parties -> Processing Rule -> Action 에 해당 하는 기능임

- Provides the capability to configure the system to invoke a Java class.

2. 설정 세부 항목 설명

   1) Name 

       -  실행될 Processing Rule Action 명칭 정의

   2) Java Class 

       - 실행할 Java Class에 대한 Class Qualified Name

       - Class 생성과 관련한 현재까지 공개된 내용(현재 BizManager측의 해당 Class 생성관련한 공식 가이드 없음)

       (1) 주요 Interface or Class            - com.ipnetsolutions.msgsrv.script.ScrBean 

              => 생성할 Class에서는 이 Interface를 Implement 해야만 함

            - com.ipnetsolutions.msgsrv.script.ScrResults

              => 생성한 Class내에서의 처리결과를 저장하는데 사용되는 클래스

            - com.ipnetsolutions.msgsrv.script.ScrBean.Context

              => 생성하는 Class내에서 BizManager 프로세싱 단계에 저장된 각 Object에 접근할수 있는 통로

       (2) 생성 Class의 적용위치

            - BizManager의 ClassPath상에 위치하면 될것으로 추정됨

            - 현재 C:\BizConnect\Application\app3.3.0\lib\common 경로에 생성한 클래스를 위치히야 정상동작

              하는것으로 확인됨

            - 생성 Class 적용시 서버 재기동 과정이 필요함

       (3) 샘플 소스

            - 첨부의 샘플소스 확인

package kr.co.inspien.bizmanager;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import com.ipnetsolutions.config.itf.Configurator;
import com.ipnetsolutions.logger.Logger;
import com.ipnetsolutions.msgsrv.script.ScrBean;
import com.ipnetsolutions.msgsrv.script.ScrResults;

public class SampleJavaAction implements ScrBean{

	@Override
	public ScrResults run(Context context) throws Exception {
		// TODO Auto-generated method stub
		
		Logger oLog = context.getLog();
				
		//Action Script 실행 결과 객체 생성
		ScrResults oResult = new ScrResults(oLog);
		
		//Context 객체에서 Parameter String 추출
		String sParam = context.getParam();
		
		//Context 객체에서 현재 처리중인 데이터 파일명 추출하기 
		Input oInput = context.getInput();
		String outFnm = oInput.logicalFilename;
		
		//Context 객체에서 현재 처리중인 데이터 추출하기
		InputStream is = oInput.getInputStream();
		String sProcData = convertStreamToString(is);
		
		
		//Context 객체에서 Output 출력하기
		String sOutFile = "TRANS_JAVA_OUTPUT";
		FileWriter wtr = new FileWriter(sOutFile);
		StringBuffer sb = new StringBuffer();
		sb.append("");
		sb.append("");	
		sb.append("");
		sb.append("YUMI_DUNS");
		sb.append("lswDUNS");
		sb.append("YUMI_XML_DOC");
		sb.append("123123");
		sb.append("");
		sb.append("");
		sb.append("");
		sb.append("444");
		sb.append("10");
		sb.append("Test");
		sb.append("");
		sb.append("");
		sb.append("");
		
        wtr.write(sb.toString());
        wtr.close();
        
      //Context 객체에서 Output 출력하기
        oResult.addOutput(sOutFile);
	
		//Configuration 정보
		Configurator cf = context.getConfigurator();
		String sCF = null;
		if(cf != null){
			sCF = cf.getDatabaseConnectionName();
		}

		//==> Test Output File 
		FileWriter fstream = new FileWriter("C:/temp/BizManagerTestOutput_0724.txt");
		BufferedWriter out = new BufferedWriter(fstream);
		out.write("Logger Level="+oLog.getLevel()+"\r\n");
		out.write("Logger Name="+oLog.getName()+"\r\n");
		out.write("Parameter String = "+sParam+"\r\n");
		out.write("logicalFileName = "+outFnm+"\r\n");
		out.write("Configuration DB Connection Name="+sCF+"\r\n");
		out.write("============================== Contents Start =============================\r\n");
		out.write(sProcData);
		out.write("============================== Contents End =============================\r\n");
		out.close();
		
		if(sParam.equals("ERROR")){
			oResult.addError("Custom Error Message");    //처리결과 에러상태로 지정
		}else if(sParam.equals("WARNING")){
			oResult.addWarning("Custom Warning Message");
                        //처리결과는 Success이나 지정한 메시지가  Operation 모니터링내에 Error Message 항목에 출력됨
		}
		
		
		return oResult;
	}
	
	public String convertStreamToString(InputStream is) throws IOException {
		
		if (is != null) {
            StringBuilder sb = new StringBuilder();
            String line;

            try {
                BufferedReader reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
                while ((line = reader.readLine()) != null) {
                    sb.append(line).append("\n");
                }
            } finally {
                is.close();
            }
            return sb.toString();
        } else {      
            return "";
        }
	}
	

}

    3) System ID

       - 서버 이중화 구성의 경우 해당 Class가 실행될 특정 서버를 지정할 수 있음

   4) Parameter String

       - 생성한 Java Class 내부로 전달할 Parmeter String 지정

       - //Context 객체에서 Parameter String 추출 String sParam = context.getParam();

   5) Stop Default Transmission

       - Java Class 호출후 수신자(Receipt)의 Default Trandport를 실행할지 여부임 

       - 하나의 Processing Rule에 등록된 Acition 모두 동일하게 셋팅해야 적용된다         

          예) 모두 해당 옵션을 선택해제해야 각 Action의 처리상태와 상관없이 수신지 Default Transport 수행함 

   6) Cascade Multiple Actions

       - 현재 등록하는 Action의 처리상태에 따라 후속 Action을 실행여부 결정 

       - 해당 옵션선택시 현재 단계의 Action이 실패할경우 후속 Action이 실행되지 않음 

   7) Schedule

       - immediately : 즉시 실행

       - 그외 스케쥴 지정시 지정된 시간만큼의 Delay를 가진후 실행되는 모습을 취함

         ※ 특정시간 실행 지정가능

3. 해당 기능 활용 방안

    - 각 Processing Rule에서 지정한 Document 처리시 BizManager에서 제공하지 않는 기능들에 대해서

      Custom Java 소스를 활용하여 극복이 가능 할것으로 보임

    - Java Class의 처리상태가 Error인경우 Operation 메뉴에서 Retry 처리도 가능함

    - Java Class에서 문서의 변환 및 외부 작업 수행후 후속 프로세스로의 연계도 가능함     

      예) 아래와 같이  ACT_JAVACALL2 단계에서 문서를 변환하고 이후 후속 프로세스가 진행됨

Schedule 지정시 Operation 옵션에서 아래와 같이 Delay 처리되는 상황을 확인할수 있다.