마이플랫폼 자바쪽 소스(Ifrx17) 프리즘 EX1) 조회1을 실행 트랜잭션 -> AC -> DC 처리(execute,setDataWindow)

Ifrx17FhJava>src>com.tyli.ejis.core>fh>ac>BrofcMm.....EJB.java
Ifrx17FhJava>src>com.tyli.ejis.core>fh>dc>BrofcMM.....EJB.java

fh>ac>BrofcMm...EJB.java

public class BrofcMm....EJB extends GenericEJB {

private static final long serialVersionUID = -1234567L;
private UserLogger logger = null;
@SuppressWarnings("unused")
private final messageManager msgManager = MessageManager.getInstance();

/*처리유형 별 분기를 위한 메소드*/
/*코멘트 생략...*/
@Override
pulbic DataContainer process(UserInfo userinfo, AuthInfo authInfo, DataContainer currentDC, DataContainer originalDC) throws AppException, AppEJBException {
logger = UserLogger.getLogger(userInfo, authInfo);
logger.debug(BrofcMm....EJB.class.getName() + ".process");
DataContainer resultDC = new DataContainer();

//화면에서 전송한 TaskID와 opCode를 가져온다
String opCode = authInfo.getRequestOp();

if("IQY01".equals(opCode)) {
//조회
resultDC = inquiryBroMm...EJB(userInfo, authInfo, currentDC);
} else if ("IQY02".equals(opCode)) {
resultDC = inquiryClo...EJB(userInfo, authInfo, currentDC);
} else {
throw new AppEJBException("HBSE0X3","에러명칭","에러명칭");
}
return resultDC;
}


/*조회 1*/
private DataContainer inquiryBroMm...EJB(UserInfo userInfo, AuthInfo authInfo, DataContainer currentDC) throws AppEJBException, AppException {
DataContainer resultDC = new DataContainer ();

try {
// Domain Component에 전달할 DataContainer를 생성한다
DataContainer outputDC = new DataContainer();
outputDC = BizBrokerUtil.callDCBizBroker("FH_DC_BrofcMm...", "inquiryBrofcMm....", userInfo, authInfo, currentDC);
resultDC.setDataWindow("DS_LISX", outputDC.getDataWindow("DS_LISX"));
} catch (AppEJBException e) {
logger.error( " ", e);
throw e;
} catch (Exception e) {
logger.error(" ", e);
throw new AppEJBException("XXXX", e.toString(), e.toString());
}
return resultDC;
}





fh>dc>BrofcMm...EJB.java

public class BrofcMm...EJB extends GenericEJB {
private static final long serialVersionUID = 123456L;
private UserLogger logger = null;
/*로그인 사원번호*/
@SuppressWarnings("unused")
private String empNo = "";
/*로그인 지점코드*/
@SuppressWarnings("unuserd")
private String brofcCOD = "";
@SuppressWarnings("unused")
private final MessageManager msgManager = MessageManager.getInstance();

/*처리유형 별 분기를 위한 메소드*/
/*코멘트 생략...*/
@Override
public DataContainer process(UserInfo userInfo userInfo, AuthInfo authInfo, DataContainer currentDC, DataContainer originalDC) throws AppException, AppEJBException {

logger = UserLogger.getLogger(userInfo, authInfo);
logger.debug(BrofcMm...EJB.class.getName() + ".process");
empNo = userInfo.getValue(BzConst.EMPNO);
brofcCOD = userInfo.getValue(BzConst.VROFCCOD);
String opCode = authInfo.getRequestOp();
DataCOntainber resultDC = null;

if ( "inquiryBrofcMm...".equals(opCode)) {
try {
resultDC = InquiryBrofcMm....EJB(userinfo, authInfo, currentDC);
} catch (SQLException e) {
e.printStackTrace();
}

return resultDC;
}



/*조회1*/
/*코멘트생략....*/
private DataContainer inquiryBrofcMm...EJB(UserInfo userInfo, AuthInfo authInfo, DataContainer currentDC) throws SQLException {
DataContainer resultDC = new DataContainer();
SQLProcessor sqlProc = null;
sqlProc = new SQLProcessor("ds_xxxx17", userInfo, authInfo);
MiPagingInfo pagingUtil = (MipagingInfo)currentDC.getObject(TyliConstants.MIPLATFORM_PAGING_INFO);
//currentDC 에서 파라미터를 가져온다
String YMD_GBN = currentDC.getParameter("YMD_GBN);
String CLO_ST = currentDC.getParameter("CLO_ST");
sqlProc.setParam("CLO_ST", CLO_ST);

sqlProc.setDsFetchCount(1000);
String strSqlId = "FH_.......IQY01";
sqlProc.execute(strSqlId, pagingUtil.getPageIndex(), flase);

//수행결과를 가져온다
DataWindow dw = sqlProc.getResultDW();
logger.debug("dw ==> " + dw);
//결과 DataWindow를 resultDC에 넣는다.
resultDC.setDataWindow("DS_LIST", dw);

return resultDC;
}