/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEKK0321B003TPDA * ソースファイル名：JSYejbEKK0321B003TPDA.java * 作成者：EK103127 * 日付：2011年10月27日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANSQLFacility; 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.AgentDispatchContext; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import eo.ejb.cbm.entity.KK0321ETMsg; import eo.ejb.cbs.cbsmsg.EKK0321B003CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0321B003CBSMsg1List; import eo.ejb.common.JKKModelCommon; /** * * テンプレートDBアクセス部品　EKK0321B003_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK0321B003TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK0321B003TPDA() { } /** * EKK0321B003_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; // 運用日の取得 String opeDate = JKKModelCommon.getOpeDate(inMsg); /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(KK0321ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT KK0321.KAKINS_NO ") .append(" ,KK0321.SEIKY_KEI_NO ") .append(" ,KK0321.SVC_KEI_NO ") .append(" ,KK0321.SVC_KEI_UCWK_NO ") .append(" ,KK0321.KKTK_SVC_KEI_NO ") .append(" ,KK0321.OP_SVC_KEI_NO ") .append(" ,KK0321.SEIOPSVC_KEI_NO ") .append(" ,KK0321.SBOP_SVC_KEI_NO ") .append(" ,KK0321.WRIB_SVC_KEI_NO ") .append(" ,KK0321.OWNR_KEI_NO ") .append(" ,KK0321.PRC_KMK_CD ") .append(" ,KK0321.KAKINS_TSTAYMD ") .append(" ,KK0321.KAKINS_TENDYMD ") .append(" ,KK0321.UPD_DTM ") .append(" FROM KK_T_KAKINS KK0321 "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EKK0321B003CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE KK0321.MK_FLG = '0' ") .append(" AND KK0321.SEIKY_KEI_NO = ? ") .append(" AND KK0321.KAKINS_TSTAYMD <= ? ") .append(" AND KK0321.KAKINS_TENDYMD >= ? "); // ＫＥＹ＿課金先適用開始年月日が指定されている場合 if(!inMsg.isNull(EKK0321B003CBSMsg.KEY_KAKINS_TSTAYMD)) { sql_Buff.append(" AND KK0321.KAKINS_TSTAYMD = ? "); } sql_Buff.append(" AND ( ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_SVC_KEI_UCWK KK0161 ") .append(" WHERE KK0161.SVC_KEI_UCWK_NO = KK0321.SVC_KEI_UCWK_NO ") .append(" AND KK0161.SVC_KEI_NO = ? ") .append(" AND (KK0161.SVC_KEI_UCWK_NO, KK0161.RSV_APLY_YMD || KK0161.GENE_ADD_DTM) = ") .append(" (SELECT KK0161_GENE.SVC_KEI_UCWK_NO, 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 = KK0161.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' ") .append(" GROUP BY KK0161_GENE.SVC_KEI_UCWK_NO) ") .append(" ) ") .append(" OR ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_OP_SVC_KEI KK0351 ") .append(" WHERE KK0351.OP_SVC_KEI_NO = KK0321.OP_SVC_KEI_NO ") .append(" AND KK0351.SVC_KEI_NO = ? ") .append(" AND (KK0351.OP_SVC_KEI_NO, KK0351.RSV_APLY_YMD || KK0351.GENE_ADD_DTM) = ") .append(" (SELECT KK0351_GENE.OP_SVC_KEI_NO, MAX(KK0351_GENE.RSV_APLY_YMD || KK0351_GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_OP_SVC_KEI KK0351_GENE ") .append(" WHERE KK0351_GENE.OP_SVC_KEI_NO = KK0351.OP_SVC_KEI_NO ") .append(" AND KK0351_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0351_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0351_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0351_GENE.OP_SVC_KEI_NO) ") .append(" ) ") .append(" OR ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_SEIOPSVC_KEI KK0441 ") .append(" WHERE KK0441.SEIOPSVC_KEI_NO = KK0321.SEIOPSVC_KEI_NO ") .append(" AND KK0441.SVC_KEI_NO = ? ") .append(" AND (KK0441.SEIOPSVC_KEI_NO, KK0441.RSV_APLY_YMD || KK0441.GENE_ADD_DTM) = ") .append(" (SELECT KK0441_GENE.SEIOPSVC_KEI_NO, MAX(KK0441_GENE.RSV_APLY_YMD || KK0441_GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_SEIOPSVC_KEI KK0441_GENE ") .append(" WHERE KK0441_GENE.SEIOPSVC_KEI_NO = KK0441.SEIOPSVC_KEI_NO ") .append(" AND KK0441_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0441_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0441_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0441_GENE.SEIOPSVC_KEI_NO) ") .append(" ) ") .append(" OR ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_WRISVC_TG_KEI KK0481 ") .append(" WHERE KK0481.WRIB_SVC_KEI_NO = KK0321.WRIB_SVC_KEI_NO ") .append(" AND KK0481.SVC_KEI_NO = ? ") .append(" AND (KK0481.WRIB_SVC_KEI_NO, KK0481.WRIB_SVC_TRGT_KEI_NO, KK0481.GENE_ADD_DTM) = ") .append(" (SELECT KK0481_GENE.WRIB_SVC_KEI_NO, KK0481_GENE.WRIB_SVC_TRGT_KEI_NO, MAX(KK0481_GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_WRISVC_TG_KEI KK0481_GENE ") .append(" WHERE KK0481_GENE.WRIB_SVC_KEI_NO = KK0481.WRIB_SVC_KEI_NO ") .append(" AND KK0481_GENE.WRIB_SVC_TRGT_KEI_NO = KK0481.WRIB_SVC_TRGT_KEI_NO ") .append(" AND KK0481_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0481_GENE.WRIB_SVC_KEI_NO, KK0481_GENE.WRIB_SVC_TRGT_KEI_NO) ") .append(" ) ") .append(" OR ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341_01 ") .append(" WHERE KK0341_01.KKTK_SVC_KEI_NO = KK0321.KKTK_SVC_KEI_NO ") .append(" AND KK0341_01.SVC_KEI_NO = ? ") .append(" AND (KK0341_01.KKTK_SVC_KEI_NO, KK0341_01.RSV_APLY_YMD || KK0341_01.GENE_ADD_DTM) = ") .append(" (SELECT KK0341_01GENE.KKTK_SVC_KEI_NO, MAX(KK0341_01GENE.RSV_APLY_YMD || KK0341_01GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341_01GENE ") .append(" WHERE KK0341_01GENE.KKTK_SVC_KEI_NO = KK0341_01.KKTK_SVC_KEI_NO ") .append(" AND KK0341_01GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0341_01GENE.RSV_APLY_CD = '2' ") .append(" AND KK0341_01GENE.MK_FLG = '0' ") .append(" GROUP BY KK0341_01GENE.KKTK_SVC_KEI_NO) ") .append(" ) ") .append(" OR ") .append(" EXISTS (SELECT * ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341_02 ") .append(" INNER JOIN ( ") .append(" SELECT KK0251.SVC_KEI_KAISEN_UCWK_NO ") .append(" FROM KK_T_KAISEN_TG_SVKEI KK0241 ") .append(" INNER JOIN KK_T_SVKEI_KAISEN_UW KK0251 ") .append(" ON KK0241.SVC_KEI_KAISEN_UCWK_NO = KK0251.SVC_KEI_KAISEN_UCWK_NO ") .append(" WHERE KK0241.SVC_KEI_NO = ? ") .append(" AND KK0241.KAISEN_UCWK_USE_STAYMD <= ? ") .append(" AND KK0241.KAISEN_UCWK_USE_ENDYMD >= ? ") .append(" AND KK0241.MK_FLG = '0' ") .append(" AND KK0251.SVC_KEI_KAISEN_UCWK_STAT = '100' ") .append(" AND (KK0251.SVC_KEI_KAISEN_UCWK_NO, KK0251.GENE_ADD_DTM) = ( ") .append(" SELECT KK0251_GENE.SVC_KEI_KAISEN_UCWK_NO, MAX(KK0251_GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_SVKEI_KAISEN_UW KK0251_GENE ") .append(" WHERE KK0251_GENE.SVC_KEI_KAISEN_UCWK_NO = KK0251.SVC_KEI_KAISEN_UCWK_NO ") .append(" AND KK0251_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0251_GENE.SVC_KEI_KAISEN_UCWK_NO) ") .append(" AND KK0251.USE_STAYMD = ( ") .append(" SELECT MAX(KK0251_01.USE_STAYMD) ") .append(" FROM KK_T_KAISEN_TG_SVKEI KK0241_01 ") .append(" INNER JOIN KK_T_SVKEI_KAISEN_UW KK0251_01 ") .append(" ON KK0251_01.SVC_KEI_KAISEN_UCWK_NO = KK0241_01.SVC_KEI_KAISEN_UCWK_NO ") .append(" WHERE KK0241_01.SVC_KEI_NO = KK0241.SVC_KEI_NO ") .append(" AND KK0241_01.KAISEN_UCWK_USE_STAYMD <= ? ") .append(" AND KK0241_01.KAISEN_UCWK_USE_ENDYMD >= ? ") .append(" AND KK0241_01.MK_FLG = '0' ") .append(" AND KK0251_01.SVC_KEI_KAISEN_UCWK_STAT = '100' ") .append(" AND (KK0251_01.SVC_KEI_KAISEN_UCWK_NO, KK0251_01.GENE_ADD_DTM) = ") .append(" (SELECT KK0251_02GENE.SVC_KEI_KAISEN_UCWK_NO, MAX(KK0251_02GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_SVKEI_KAISEN_UW KK0251_02GENE ") .append(" WHERE KK0251_02GENE.SVC_KEI_KAISEN_UCWK_NO = KK0251_01.SVC_KEI_KAISEN_UCWK_NO ") .append(" AND KK0251_02GENE.MK_FLG = '0' ") .append(" GROUP BY KK0251_02GENE.SVC_KEI_KAISEN_UCWK_NO) ") .append(" ) ") .append(" ) KAISEN ON KAISEN.SVC_KEI_KAISEN_UCWK_NO = KK0341_02.SVC_KEI_KAISEN_UCWK_NO ") .append(" WHERE KK0341_02.KKTK_SVC_KEI_NO = KK0321.KKTK_SVC_KEI_NO ") .append(" AND (KK0341_02.KKTK_SVC_KEI_NO, KK0341_02.RSV_APLY_YMD || KK0341_02.GENE_ADD_DTM) = ") .append(" (SELECT KK0341_02GENE.KKTK_SVC_KEI_NO, MAX(KK0341_02GENE.RSV_APLY_YMD || KK0341_02GENE.GENE_ADD_DTM) ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341_02GENE ") .append(" WHERE KK0341_02GENE.KKTK_SVC_KEI_NO = KK0341_02.KKTK_SVC_KEI_NO ") .append(" AND KK0341_02GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0341_02GENE.RSV_APLY_CD = '2' ") .append(" AND KK0341_02GENE.MK_FLG = '0' ") .append(" GROUP BY KK0341_02GENE.KKTK_SVC_KEI_NO) ") .append(" ) ") .append(" ) ") .append(" ORDER BY KK0321.KAKINS_NO 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(EKK0321B003CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(ＫＥＹ＿請求契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SEIKY_KEI_NO)); // パラメータの設定(ＫＥＹ＿基準年月日を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_BASE_YMD)); // パラメータの設定(ＫＥＹ＿基準年月日を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_BASE_YMD)); // パラメータの設定(ＫＥＹ＿課金先適用開始年月日を指定) if(!inMsg.isNull(EKK0321B003CBSMsg.KEY_KAKINS_TSTAYMD)) { CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_KAKINS_TSTAYMD)); } // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0321B003CBSMsg.KEY_SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, ++iPCnt, opeDate); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0321B003CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0321B003CBSMsg1List.KAKINS_NO , EKK0321B003CBSMsg1List.SEIKY_KEI_NO , EKK0321B003CBSMsg1List.SVC_KEI_NO , EKK0321B003CBSMsg1List.SVC_KEI_UCWK_NO , EKK0321B003CBSMsg1List.KKTK_SVC_KEI_NO , EKK0321B003CBSMsg1List.OP_SVC_KEI_NO , EKK0321B003CBSMsg1List.SEIOPSVC_KEI_NO , EKK0321B003CBSMsg1List.SBOP_SVC_KEI_NO , EKK0321B003CBSMsg1List.WRIB_SVC_KEI_NO , EKK0321B003CBSMsg1List.OWNR_KEI_NO , EKK0321B003CBSMsg1List.PRC_KMK_CD , EKK0321B003CBSMsg1List.KAKINS_TSTAYMD , EKK0321B003CBSMsg1List.KAKINS_TENDYMD , EKK0321B003CBSMsg1List.UPD_DTM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0321B003CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0321B003CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0321B003CBSMsg.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(EKK0321B003CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }