/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEKK0191B020TPDA * ソースファイル名：JSYejbEKK0191B020TPDA.java * 作成者：EK908590 * 日付：2011年11月09日 *＜機能概要＞ * サービス契約内訳＜eo光電話＞内訳番号取得テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * v3.00.00 2012/03/17 FJ)楠神新規作成 * ********************************************************************************/ 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.common.constant.JTUStrConst; import eo.ejb.cbs.cbsmsg.EKK0191B020CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0191B020CBSMsg1List; import eo.ejb.cbm.entity.KK0191ETMsg; import eo.ejb.common.JTUModelCommon; /** * * テンプレートDBアクセス部品　EKK0191B020_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
* @author FJ */ public class JSYejbEKK0191B020TPDA extends CAANSQLFacility implements TemplateDBAccessHandler { /** * コンストラクタ */ public JSYejbEKK0191B020TPDA() { } /** * EKK0191B020_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext * @return void */ public void invoke(CAANMsg inMsg, AgentDispatchContext inContext) { // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; //パラメータセット用 int iIndex = 1; // 検索処理パターン String searchType = inMsg.getString(EKK0191B020CBSMsg.SEARCH_TYPE); //共通部必須チェック if(JPCModelConstant.SAERCH_TYPE_IKT.equals(searchType)) { /** * 最大検索件数が未設定の場合 */ if (inMsg.isNull(EKK0191B020CBSMsg.MAX_SEARCH_NUM)) { throw new IllegalArgumentException(JTUStrConst.ICRN_ERR_MSG_IKT); } } else { throw new IllegalArgumentException(JTUStrConst.ICRN_ERR_MSG_FUSEI_PTN); } /******************** * SQL文の作成 ********************/ try { //コネクション取得 con1 = JSYejbConnection.getConnection(KK0191ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); StringBuffer sql_Select = new StringBuffer(); StringBuffer sql_From = new StringBuffer(); StringBuffer sql_Where = new StringBuffer(); StringBuffer sql_Order = new StringBuffer(); sql_Select.append(" SELECT ") .append(" TEL.SVC_KEI_UCWK_NO "); sql_From.append(" FROM ") .append(" KK_T_SVKEIUW_EOH_TEL TEL ") .append(" INNER JOIN ") .append(" KK_T_SVC_KEI_UCWK UCWK ") .append(" ON ") .append(" TEL.SVC_KEI_UCWK_NO = UCWK.SVC_KEI_UCWK_NO ") .append(" AND ") .append(" TEL.GENE_ADD_DTM = UCWK.GENE_ADD_DTM ") .append(" AND ") .append(" UCWK.SVC_KEI_NO = ? ") .append(" AND ") .append(" UCWK.RSV_APLY_YMD || UCWK.GENE_ADD_DTM = ") .append(" (SELECT MAX(KK0161_GENE.RSV_APLY_YMD || KK0161_GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_SVC_KEI_UCWK KK0161_GENE ") .append(" WHERE KK0161_GENE.SVC_KEI_UCWK_NO = UCWK.SVC_KEI_UCWK_NO ") .append(" AND KK0161_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0161_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0161_GENE.MK_FLG = '0') "); // SQL文_個別部1 if ("1".equals(inMsg.getObject(EKK0191B020CBSMsg.FUNC_CODE).toString())) { sql_Where.append(" WHERE ") .append(" TEL.TELNO = ? ") .append(" AND ") .append(" TEL.MK_FLG= '0' "); } //件数取得SQL StringBuffer sql_cnt = new StringBuffer(); sql_cnt.append(" SELECT ") .append(" COUNT(*) AS CNT ") .append(sql_From) .append(sql_Where); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_cnt.toString()); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if("1".equals(inMsg.getString(EKK0191B020CBSMsg.FUNC_CODE))) { //パラメータ設定用Index 初期化 iIndex = 1; // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(EKK0191B020CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, JTUModelCommon.getOpeDate(inMsg, null)); // パラメータの設定(ＫＥＹ＿電話番号を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(EKK0191B020CBSMsg.KEY_TELNO)); } //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_cnt); /** * SQL文実行 */ // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0191B020CBSMsgの明細にセットする項目 String[] msgKeyListCnt = { EKK0191B020CBSMsg.TOTAL_SEARCH_NUM }; /** * 結果取得 */ rsltQuery.next(); mapMessage(rsltQuery, msgKeyListCnt, inMsg); // 資源の解放 if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } // 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了 if (0 == (Integer.parseInt(inMsg.getString(EKK0191B020CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EKK0191B020CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了 if (Integer.parseInt(inMsg.getString(EKK0191B020CBSMsg.MAX_SEARCH_NUM)) < (Integer.parseInt(inMsg.getString(EKK0191B020CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EKK0191B020CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } /*********************************************************************************************** * データ取得 */ sql_Buff.append(" SELECT ") .append(" * ") .append(" FROM ") .append(" ( ") .append(sql_Select) .append(sql_From) .append(sql_Where) .append(sql_Order) .append(" ) TBL "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if("1".equals(inMsg.getString(EKK0191B020CBSMsg.FUNC_CODE))) { //パラメータ設定用Index 初期化 iIndex = 1; // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(EKK0191B020CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, JTUModelCommon.getOpeDate(inMsg, null)); // パラメータの設定(ＫＥＹ＿電話番号を指定) CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(EKK0191B020CBSMsg.KEY_TELNO)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0191B020CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0191B020CBSMsg1List.SVC_KEI_UCWK_NO }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery, msgKeyList1, "eo.ejb.cbs.cbsmsg.EKK0191B020CBSMsg1List", 0); // 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了 if (0 == outMsg1.length) { inMsg.set(EKK0191B020CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了 if (Integer.parseInt(inMsg.getString(EKK0191B020CBSMsg.MAX_SEARCH_NUM)) < (outMsg1.length)) { inMsg.set(EKK0191B020CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } //総検索件数を再設定 inMsg.set(EKK0191B020CBSMsg.TOTAL_SEARCH_NUM, Integer.toString(outMsg1.length)); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0191B020CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0191B020CBSMsg.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(EKK0191B020CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }