/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEWC0161B010TPDA * ソースファイル名：JSYejbEWC0161B010TPDA.java * 作成者：EK909290 * 日付：2012年01月31日 *＜機能概要＞ * 視聴制御オーダ対象デジタルティアグループ一覧照会テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * ｖ32.00.00 2017/05/26 FJ)河邊【OM-2017-0000488】オープンカーソルエラー * ********************************************************************************/ package eo.ejb.cbs.sqlf; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANSQLFacility; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import eo.common.constant.JPCModelConstant; import eo.ejb.cbs.cbsmsg.EWC0161B010CBSMsg; import eo.ejb.cbs.cbsmsg.EWC0161B010CBSMsg1List; import eo.ejb.cbm.entity.WC0161ETMsg; /** * * テンプレートDBアクセス部品　EWC0161B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEWC0161B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEWC0161B010TPDA() { } /** * EWC0161B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /** * パラメータセット用 */ int iIndex = 1; /** * 最大検索件数、表示件数、表示ページ番号が未設定の場合 */ if (inMsg.isNull(EWC0161B010CBSMsg.MAX_SEARCH_NUM) || inMsg.isNull(EWC0161B010CBSMsg.DISPLAY_NUM) || inMsg.isNull(EWC0161B010CBSMsg.DISPLAY_PAGE_NUM)) { throw new IllegalArgumentException("サービスインターフェイス共通部の最大検索件数、表示件数、表示ページ番号は必須項目です。"); } /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(WC0161ETMsg.getTableName()); // 総件数取得 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" COUNT(*) AS CNT ") .append(" FROM ") .append(" WC_T_WC_ODR_TG_DGTIA WC0161, ") .append(" WC_M_TIA_GRP_TG_TIA WC0091 "); // SQL文_個別部1 sql_Buff.append(" WHERE WC0161.DGTIA_GRP_CD = WC0091.DGTIA_GRP_CD ") .append(" AND WC0091.MK_FLG = '0' ") .append(" AND WC0091.DGTIA_SBT_CD = '00' ") .append(" AND WC0161.WCTRL_ORDER_NO = ? ") .append(" AND WC0161.MK_FLG = '0' "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EWC0161B010CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(ＫＥＹ＿視聴制御オーダ番号を指定) CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(EWC0161B010CBSMsg.KEY_WCTRL_ORDER_NO)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EWC0161B010CBSMsgの明細にセットする項目 String[] msgKeyListCnt = { EWC0161B010CBSMsg.TOTAL_SEARCH_NUM }; // 結果取得 rsltQuery.next(); mapMessage(rsltQuery, msgKeyListCnt, inMsg); // 総ページ数、エラーフラグ設定 // 総ページ数設定 int iTotal = Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.TOTAL_SEARCH_NUM)); int iDispNum = Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.DISPLAY_NUM)); int iSearchDivDisp = iTotal / iDispNum; int iRest = iTotal % iDispNum; // 割り切れない場合は総ページ数を増やす if (0 != iRest) { iSearchDivDisp ++; } inMsg.set(EWC0161B010CBSMsg.TOTAL_PAGE_NUM, Integer.toString(iSearchDivDisp)); // 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了 if (0 == (Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EWC0161B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了 if (Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.MAX_SEARCH_NUM)) < (Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EWC0161B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } // 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了 int iDispPageNum = Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.DISPLAY_PAGE_NUM)); int iStartNum = iDispNum * (iDispPageNum - 1) + 1; int iEndNum = iDispNum * iDispPageNum; if (Integer.parseInt(inMsg.getString(EWC0161B010CBSMsg.MAX_SEARCH_NUM)) < iStartNum) { inMsg.set(EWC0161B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA); return; } // SQL文_基本部1 StringBuffer sql_Buff1 = new StringBuffer(); sql_Buff1.append(" SELECT ") .append(" WC0161.WCTRL_ORDER_NO, ") .append(" WC0161.DGTIA_GRP_CD, ") .append(" WC0091.DGTIA_CD, ") .append(" WC0161.ADD_DTM, ") .append(" WC0161.ADD_OPEACNT, ") .append(" WC0161.UPD_DTM, ") .append(" WC0161.UPD_OPEACNT, ") .append(" WC0161.MK_FLG ") .append(" FROM ") .append(" WC_T_WC_ODR_TG_DGTIA WC0161, ") .append(" WC_M_TIA_GRP_TG_TIA WC0091 "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EWC0161B010CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff1.append(" WHERE WC0161.DGTIA_GRP_CD = WC0091.DGTIA_GRP_CD ") .append(" AND WC0091.MK_FLG = '0' ") .append(" AND WC0091.DGTIA_SBT_CD = '00' ") .append(" AND WC0161.WCTRL_ORDER_NO = ? ") .append(" AND WC0161.MK_FLG = '0' ") .append(" ORDER BY WC0091.DGTIA_CD "); } // OM-2017-0000488 2017/05/26 ADD START if(pstmt != null){ pstmt.close(); } // OM-2017-0000488 2017/05/26 ADD END //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff1.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff1); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EWC0161B010CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(ＫＥＹ＿視聴制御オーダ番号を指定) CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(EWC0161B010CBSMsg.KEY_WCTRL_ORDER_NO)); } //○TAI-2013-0000025 if(null != rsltQuery) { rsltQuery.close(); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EWC0161B010CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EWC0161B010CBSMsg1List.WCTRL_ORDER_NO , EWC0161B010CBSMsg1List.DGTIA_GRP_CD , EWC0161B010CBSMsg1List.DGTIA_CD , EWC0161B010CBSMsg1List.ADD_DTM , EWC0161B010CBSMsg1List.ADD_OPEACNT , EWC0161B010CBSMsg1List.UPD_DTM , EWC0161B010CBSMsg1List.UPD_OPEACNT , EWC0161B010CBSMsg1List.MK_FLG }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EWC0161B010CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EWC0161B010CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EWC0161B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(EWC0161B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }