/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbEKK0501B001TPDA * ソースファイル名：JSYejbEKK0501B001TPDA.java * 作成者 ：EK907066 * 日付 ：2012年04月19日 *＜機能概要＞ * 口座一覧照会（請求契約番号）テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ********************************************************************************/ 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.ejb.cbs.cbsmsg.EKK0501B001CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0501B001CBSMsg1List; import eo.ejb.cbm.entity.KK0501ETMsg; /** * * テンプレートDBアクセス部品　EKK0501B001_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK0501B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK0501B001TPDA() { } /** * EKK0501B001_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(KK0501ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT KK0501.SEIKY_WAY_NO_KOZA ") .append(" , KK0501.GENE_ADD_DTM ") .append(" , KK0501.BANK_CD ") .append(" , KK0501.BANK_SHITEN_CD ") .append(" , KK0501.YOKIN_SHUMOKU_CD ") .append(" , KK0501.KOZA_NO ") .append(" , KK0501.NEW_CD ") .append(" , KK0501.KOZA_MEIGIN_KANA ") .append(" , KK0501.TSUCHO_SYMBOL ") .append(" , KK0501.TSUCHO_NO ") .append(" FROM KK_T_KOZA KK0501 "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EKK0501B001CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE KK0501.KOZA_STAT <> '920' "); // 条件の設定(ＫＥＹ＿金融機関コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_BANK_CD)) { sql_Buff.append(" AND KK0501.BANK_CD = ? "); } // 条件の設定(ＫＥＹ＿金融機関支店コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_BANK_SHITEN_CD)) { sql_Buff.append(" AND KK0501.BANK_SHITEN_CD = ? "); } // 条件の設定(ＫＥＹ＿預金種目コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_YOKIN_SHUMOKU_CD)) { sql_Buff.append(" AND KK0501.YOKIN_SHUMOKU_CD = ? "); } // 条件の設定(ＫＥＹ＿口座番号が設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_KOZA_NO)) { sql_Buff.append(" AND KK0501.KOZA_NO = ? "); } // 条件の設定(ＫＥＹ＿新規コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_NEW_CD)) { sql_Buff.append(" AND KK0501.NEW_CD = ? "); } // 条件の設定(ＫＥＹ＿通帳記号が設定されていた場合) if(!inMsg.isNull(EKK0501B001CBSMsg.KEY_TSUCHO_SYMBOL)) { sql_Buff.append(" AND KK0501.TSUCHO_SYMBOL = ? "); } // 条件の設定(ＫＥＹ＿通帳番号が設定されていた場合) if(!inMsg.isNull(EKK0501B001CBSMsg.KEY_TSUCHO_NO)) { sql_Buff.append(" AND KK0501.TSUCHO_NO = ? "); } sql_Buff.append(" AND KK0501.MK_FLG = '0' ") .append(" AND EXISTS ") .append(" ( SELECT 1 ") .append(" FROM KK_T_SEIKY_KEI KK0491 ") .append(" WHERE KK0491.SEIKY_WAY_NO_KOZA = KK0501.SEIKY_WAY_NO_KOZA ") .append(" AND KK0491.SEIKY_KEI_NO = ? "); // 条件の設定(ＫＥＹ＿予約適用コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_RSV_APLY_CD)) { sql_Buff.append(" AND KK0491.RSV_APLY_CD = ? "); } sql_Buff.append(" AND KK0491.MK_FLG = '0' ") .append(" ) ") .append(" ORDER BY KK0501.SEIKY_WAY_NO_KOZA DESC, ") .append(" KK0501.GENE_ADD_DTM DESC "); } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 if ( "1".equals( inMsg.getString(EKK0501B001CBSMsg.FUNC_CODE) ) ) { int bindIndex = 1; // 条件の設定(ＫＥＹ＿金融機関コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_BANK_CD)) { // パラメータの設定(ＫＥＹ＿金融機関コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_BANK_CD)); } // 条件の設定(ＫＥＹ＿金融機関支店コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_BANK_SHITEN_CD)) { // パラメータの設定(ＫＥＹ＿金融機関支店コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_BANK_SHITEN_CD)); } // 条件の設定(ＫＥＹ＿預金種目コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_YOKIN_SHUMOKU_CD)) { // パラメータの設定(ＫＥＹ＿預金種目コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_YOKIN_SHUMOKU_CD)); } // 条件の設定(ＫＥＹ＿口座番号が設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_KOZA_NO)) { // パラメータの設定(ＫＥＹ＿口座番号を指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_KOZA_NO)); } // 条件の設定(ＫＥＹ＿新規コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_NEW_CD)) { // パラメータの設定(ＫＥＹ＿新規コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_NEW_CD)); } // 条件の設定(ＫＥＹ＿通帳記号が設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_TSUCHO_SYMBOL)) { // パラメータの設定(ＫＥＹ＿新規コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_TSUCHO_SYMBOL)); } // 条件の設定(ＫＥＹ＿通帳番号が設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_TSUCHO_NO)) { // パラメータの設定(ＫＥＹ＿新規コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_TSUCHO_NO)); } // パラメータの設定(ＫＥＹ＿請求契約番号を指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_SEIKY_KEI_NO)); // 条件の設定(ＫＥＹ＿予約適用コードが設定されていた場合) if (!inMsg.isNull(EKK0501B001CBSMsg.KEY_RSV_APLY_CD)) { // パラメータの設定(ＫＥＹ＿予約適用コードを指定) CAANJDBCUtil.setParam(pstmt, bindIndex++, inMsg.getObject(EKK0501B001CBSMsg.KEY_RSV_APLY_CD)); } } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0501B001CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0501B001CBSMsg1List.SEIKY_WAY_NO_KOZA , EKK0501B001CBSMsg1List.GENE_ADD_DTM , EKK0501B001CBSMsg1List.BANK_CD , EKK0501B001CBSMsg1List.BANK_SHITEN_CD , EKK0501B001CBSMsg1List.YOKIN_SHUMOKU_CD , EKK0501B001CBSMsg1List.KOZA_NO , EKK0501B001CBSMsg1List.NEW_CD , EKK0501B001CBSMsg1List.KOZA_MEIGIN_KANA , EKK0501B001CBSMsg1List.TSUCHO_SYMBOL , EKK0501B001CBSMsg1List.TSUCHO_NO }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0501B001CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0501B001CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0501B001CBSMsg.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(EKK0501B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }