/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEKK0841B003TPDA * ソースファイル名：JSYejbEKK0841B003TPDA.java * 作成者：EK103161 * 日付：2012年03月29日 *＜機能概要＞ * 割引サービス一覧照会（基準年月日）テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * ｖ5.00.00 2013/09/05 FJ)寺園 OM-2013-0001677 * ｖ9.00.00 2014/04/17 FJ)小島 ANK-2056-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.EKK0841B003CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0841B003CBSMsg1List; import eo.ejb.cbm.entity.KK0841ETMsg; import eo.ejb.common.JKKModelCommon; /** * * テンプレートDBアクセス部品　EKK0841B003_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK0841B003TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** 接尾辞(0000) */ private static final String SURFIX_0000 = "0000"; /** 接尾辞(2359) */ private static final String SURFIX_2359 = "2359"; /** * コンストラクタ */ public JSYejbEKK0841B003TPDA() { } /** * EKK0841B003_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; // パラメータのカウント int iPCnt = 0; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(KK0841ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" KK0841.WRIB_SVC_CD ") .append(" , KK0841.WRIB_TYPE_CD ") .append(" , KK0841.WRIB_SVC_NM ") .append(" , KK0841.UPPL_APLY_CNT ") .append(" , KK0841.WRIB_AGING_PRD ") .append(" , KK0841.UPPL_KEI_CNT ") .append(" , KK0841.DSP_JUN ") .append(" , KK0841.YUSEN_JUN_MDL_CD ") .append(" , KK0841.YUSEN_JUN_KIND_CD ") .append(" , KK0841.YUSEN_JUN_TYPE_CD ") .append(" , KK0841.YUSEN_JUN_TYPE_JUN ") .append(" , KK0841.APLY_JOKEN_CD ") .append(" , KK0841.WRIB_ADD_JOKEN_CD ") .append(" FROM ") .append(" KK_M_WRIB_SVC KK0841 "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() ) || "2".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() ) || "3".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() )) { sql_Buff.append(" WHERE "); // ＫＥＹ＿基準年月日がnull以外の場合 if(!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { sql_Buff.append(" ( KK0841.UK_STA_YMDHM IS NULL OR KK0841.UK_STA_YMDHM <= ? ) AND ") .append(" ( KK0841.UK_END_YMDHM IS NULL OR KK0841.UK_END_YMDHM >= ? ) AND "); } //検索条件を追加（KEY_WRIB_TYPE_CD） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_TYPE_CD)) { String[] wkWribTypeCd = inMsg.getString(EKK0841B003CBSMsg.KEY_WRIB_TYPE_CD).split(","); StringBuffer sbWribTypeCd = new StringBuffer(); sql_Buff.append(" KK0841.WRIB_TYPE_CD IN ( "); for (int i = 0; i < wkWribTypeCd.length; i++) { // 入力値をカンマで分割した数分OR条件にて設定した内容を // AND条件にてWHERE句に設定する sbWribTypeCd.append(" , ? "); } // 最初のカンマを取り除いて設定 sql_Buff.append(sbWribTypeCd.toString().substring(2)); sql_Buff.append(" ) AND "); } //検索条件を追加（KEY_WRIB_APLY_OPTNTY_CD） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_APLY_OPTNTY_CD)) { sql_Buff.append(" KK0841.WRIB_APLY_OPTNTY_CD = ? AND "); } //検索条件を追加（KEY_DSP_CAMPAIGN_CD） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_DSP_CAMPAIGN_CD)) { sql_Buff.append(" KK0841.DSP_CAMPAIGN_CD = ? AND "); } //検索条件を追加（KEY_WRIB_SVC_CD） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_CD)) { sql_Buff.append(" KK0841.WRIB_SVC_CD = ? AND "); } //検索条件を追加（KEY_UK_STA_YMD_FROM） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_STA_YMD_FROM)) { sql_Buff.append(" KK0841.UK_STA_YMDHM >= ? AND "); } //検索条件を追加（KEY_UK_STA_YMD_TO） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_STA_YMD_TO)) { sql_Buff.append(" KK0841.UK_STA_YMDHM <= ? AND "); } //検索条件を追加（KEY_UK_END_YMD_FROM） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_END_YMD_FROM)) { sql_Buff.append(" KK0841.UK_END_YMDHM >= ? AND "); } //検索条件を追加（KEY_UK_END_YMD_TO） if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_END_YMD_TO)) { sql_Buff.append(" KK0841.UK_END_YMDHM <= ? AND "); } sql_Buff.append(" (KK0841.WRIB_SVC_CD ,KK0841.RSV_APLY_YMD || KK0841.GENE_ADD_DTM) = ") .append(" ( SELECT KK0841_GENE.WRIB_SVC_CD, MAX(KK0841_GENE.RSV_APLY_YMD || KK0841_GENE.GENE_ADD_DTM) AS KK0841_MAX ") .append(" FROM KK_M_WRIB_SVC KK0841_GENE ") .append(" WHERE KK0841_GENE.WRIB_SVC_CD = KK0841.WRIB_SVC_CD AND ") .append(" KK0841_GENE.RSV_APLY_YMD <= ? AND ") .append(" KK0841_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0841_GENE.WRIB_SVC_CD ") .append(" ) "); // 機能コードが1、3の場合 if("1".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() ) || "3".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() )) { // 検索条件を追加（KEY_MSKM_SBT_CD） if(!inMsg.isNull(EKK0841B003CBSMsg.KEY_MSKM_SBT_CD)) { sql_Buff.append(" AND ") .append(" EXISTS ") .append(" ( SELECT 1 ") .append(" FROM KK_M_WRSV_APLY_JKN KK2311 ") .append(" WHERE KK0841.WRIB_SVC_CD = KK2311.WRIB_SVC_CD AND ") .append(" KK2311.WRSV_APLY_JKN_SBT_CD = '05' AND ") .append(" KK2311.WRSV_APLY_JKN_VALUE_1 = ? AND "); // ＫＥＹ＿基準年月日がnullの場合条件に含めない if(!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { sql_Buff.append(" KK2311.WRSV_APLY_JKN_TSTAYMD <= ? AND ") .append(" KK2311.WRSV_APLY_JKN_TENDYMD >= ? AND "); } sql_Buff.append(" KK2311.MK_FLG = '0' ") .append(" ) "); } // 機能コードが3の場合 if("3".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() )) { sql_Buff.append(" AND KK0841.WRIB_SCREEN_CTRL_CD = '1' "); } } // 機能コードが2の場合 if("2".equals( inMsg.getObject(EKK0841B003CBSMsg.FUNC_CODE).toString() )) { // 検索条件を追加（ＫＥＹ＿データ抽出項目設定条件種別コード、ＫＥＹ＿データ抽出項目設定条件値1） if(!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_JYO_SBT_CD) && !inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_VAL)) { sql_Buff.append(" AND ") .append(" EXISTS ") .append(" ( SELECT 1 ") .append(" FROM KK_M_WRSV_APLY_JKN KK2311 ") .append(" WHERE KK0841.WRIB_SVC_CD = KK2311.WRIB_SVC_CD AND ") .append(" KK2311.WRSV_APLY_JKN_SBT_CD = ? AND ") .append(" KK2311.WRSV_APLY_JKN_VALUE_1 = ? AND "); // ＫＥＹ＿基準年月日がnullの場合条件に含めない if(!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { sql_Buff.append(" KK2311.WRSV_APLY_JKN_TSTAYMD <= ? AND ") .append(" KK2311.WRSV_APLY_JKN_TENDYMD >= ? AND "); } sql_Buff.append(" KK2311.MK_FLG = '0' ") .append(" ) "); } } sql_Buff.append(" ORDER BY ") .append(" KK0841.YUSEN_JUN_MDL_CD ASC, ") .append(" KK0841.YUSEN_JUN_KIND_CD ASC, ") .append(" KK0841.YUSEN_JUN_TYPE_CD ASC, ") .append(" KK0841.YUSEN_JUN_TYPE_JUN ASC "); } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE) ) || "2".equals( inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE) ) || "3".equals( inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE) )) { // パラメータの設定(ＫＥＹ＿基準年月日を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD).toString().concat(SURFIX_2359)); CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD).toString().concat(SURFIX_0000)); } // パラメータの設定(ＫＥＹ＿割引タイプコードを指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_TYPE_CD)) { String[] wkWribTypeCd = inMsg.getString(EKK0841B003CBSMsg.KEY_WRIB_TYPE_CD).split(","); for (int i = 0; i < wkWribTypeCd.length; i++) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, wkWribTypeCd[i]); } } // パラメータの設定(ＫＥＹ＿割引適用契機コードを指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_APLY_OPTNTY_CD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_WRIB_APLY_OPTNTY_CD)); } // パラメータの設定(ＫＥＹ＿表示用キャンペーンコードを指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_DSP_CAMPAIGN_CD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_DSP_CAMPAIGN_CD)); } // パラメータの設定(ＫＥＹ＿割引サービスコードを指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_CD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_WRIB_SVC_CD)); } // パラメータの設定(ＫＥＹ＿受付開始年月日(自)を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_STA_YMD_FROM)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_UK_STA_YMD_FROM) .toString().concat(SURFIX_0000)); } // パラメータの設定(ＫＥＹ＿受付開始年月日(至)を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_STA_YMD_TO)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_UK_STA_YMD_TO) .toString().concat(SURFIX_2359)); } // パラメータの設定(ＫＥＹ＿受付終了年月日(自)を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_END_YMD_FROM)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_UK_END_YMD_FROM) .toString().concat(SURFIX_0000)); } // パラメータの設定(ＫＥＹ＿受付終了年月日(至)を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_UK_END_YMD_TO)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_UK_END_YMD_TO) .toString().concat(SURFIX_2359)); } // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, JKKModelCommon.getOpeDate(inMsg)); if ("1".equals(inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE)) || "3".equals(inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE))) { // パラメータの設定(ＫＥＹ＿申込種別コードを指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_MSKM_SBT_CD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_MSKM_SBT_CD)); // パラメータの設定(ＫＥＹ＿基準年月日を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD)); CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD)); } } } if ("2".equals(inMsg.getString(EKK0841B003CBSMsg.FUNC_CODE))) { // パラメータの設定(ＫＥＹ＿割引サービス適用条件種別コード, ＫＥＹ＿割引サービス適用条件値1を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_JYO_SBT_CD) && !inMsg.isNull(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_VAL)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_JYO_SBT_CD)); CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_WRIB_SVC_TEKI_VAL)); // パラメータの設定(ＫＥＹ＿基準年月日を指定) if (!inMsg.isNull(EKK0841B003CBSMsg.KEY_KJNYMD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD)); CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0841B003CBSMsg.KEY_KJNYMD)); } } } } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0841B003CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0841B003CBSMsg1List.WRIB_SVC_CD , EKK0841B003CBSMsg1List.WRIB_TYPE_CD , EKK0841B003CBSMsg1List.WRIB_SVC_NM , EKK0841B003CBSMsg1List.UPPL_APLY_CNT , EKK0841B003CBSMsg1List.WRIB_AGING_PRD , EKK0841B003CBSMsg1List.UPPL_KEI_CNT , EKK0841B003CBSMsg1List.DSP_JUN , EKK0841B003CBSMsg1List.YUSEN_JUN_MDL_CD , EKK0841B003CBSMsg1List.YUSEN_JUN_KIND_CD , EKK0841B003CBSMsg1List.YUSEN_JUN_TYPE_CD , EKK0841B003CBSMsg1List.YUSEN_JUN_TYPE_JUN , EKK0841B003CBSMsg1List.APLY_JOKEN_CD , EKK0841B003CBSMsg1List.WRIB_ADD_JOKEN_CD }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0841B003CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0841B003CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0841B003CBSMsg.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(EKK0841B003CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }