/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbEKK0351B507TPDA * ソースファイル名：JSYejbEKK0351B507TPDA.java * 作成者 ：EK909148 * 日付 ：2012年06月25日 *＜機能概要＞ * オプションチャンネル契約一覧照会テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 * v3.00 2012/05/24 FU)南岡 カレント取得SQL修正 * v3.01 2012/06/25 FU)南岡 【TAI-2012-0000054】 SQL見直し * v4.00 2012/08/02 FU)美濃原 【ANK-0324-00-00】 オプションチャンネル申込の早期化について * v4.00 2012/10/11 FJ)美濃原 【IT1-2012-0001273】システム日付をオンライン運用日付に修正 * v4.00 2013/01/10 FU)西川 【ST4-2012-0000274】 SQL見直し * ********************************************************************************/ 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.KK0351ETMsg; import eo.ejb.cbs.cbsmsg.EKK0351B507CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0351B507CBSMsg1List; import eo.ejb.common.JCCModelCommon; /** * * テンプレートDBアクセス部品　EKK0351B507_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK0351B507TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK0351B507TPDA() { } /** * EKK0351B507_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(KK0351ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" KK0351.OP_SVC_KEI_NO, ") .append(" KK0351.OP_SVC_KEI_STAT, ") .append(" KK0351.RSV_APLY_YMD, ") .append(" KK0351.UPD_DTM, ") .append(" KK0351.OP_SVC_CD, ") .append(" KK0821.OP_SVC_NM, ") .append(" KK0821.OP_CHANNEL_SBT_CD, ") .append(" KK0161.SVC_KEI_NO, ") .append(" KK0351.SVC_KEI_UCWK_NO, ") .append(" KK0341_STB.KKTK_SVC_KEI_NO AS KKTK_SVC_KEI_NO_STB, ") .append(" KK0341_STB.KIKI_SEIZO_NO AS KIKI_SEIZO_NO_STB, ") .append(" KK0341_CCAS.KKTK_SVC_KEI_NO AS KKTK_SVC_KEI_NO_CCAS, ") .append(" KK0341_CCAS.KIKI_SEIZO_NO AS KIKI_SEIZO_NO_CCAS ") .append(" FROM ") .append(" ( ") .append(" SELECT ") .append(" KK0341_TMP.KKTK_SVC_KEI_NO, ") .append(" KK0341_TMP.SVC_KEI_UCWK_NO, ") .append(" KK0341_TMP.KIKI_SEIZO_NO, ") .append(" KK0341_TMP.KKTK_SVC_KEI_STAT, ") .append(" KK0341_TMP.KKTK_SVC_CD, ") .append(" KK0341_TMP.RSV_APLY_YMD ") .append(" FROM ") .append(" KK_T_KKTK_SVC_KEI KK0341_TMP ") .append(" WHERE ") .append(" KK0341_TMP.SVC_KEI_NO = ? AND ") // 1 .append(" (KK0341_TMP.KKTK_SVC_KEI_NO, KK0341_TMP.RSV_APLY_YMD || KK0341_TMP.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT KK0341_GENE.KKTK_SVC_KEI_NO, MAX(KK0341_GENE.RSV_APLY_YMD || KK0341_GENE.GENE_ADD_DTM) ") .append(" FROM ") .append(" KK_T_KKTK_SVC_KEI KK0341_GENE ") .append(" WHERE ") .append(" KK0341_GENE.KKTK_SVC_KEI_NO = KK0341_TMP.KKTK_SVC_KEI_NO ") .append(" AND KK0341_GENE.RSV_APLY_YMD <= ? ") // 2 .append(" AND KK0341_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0341_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0341_GENE.KKTK_SVC_KEI_NO ") .append(" ) ") .append(" ) KK0341_STB ") .append(" INNER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK0341_TMP.KKTK_SVC_KEI_NO, ") .append(" KK0341_TMP.SVC_KEI_UCWK_NO, ") .append(" KK0341_TMP.KIKI_SEIZO_NO, ") .append(" KK0341_TMP.KKTK_SVC_KEI_STAT, ") .append(" KK0341_TMP.KKTK_SVC_CD, ") .append(" KK0341_TMP.RSV_APLY_YMD ") .append(" FROM ") .append(" KK_T_KKTK_SVC_KEI KK0341_TMP ") .append(" WHERE ") .append(" KK0341_TMP.SVC_KEI_NO = ? AND ") // 3 .append(" (KK0341_TMP.KKTK_SVC_KEI_NO, KK0341_TMP.RSV_APLY_YMD || KK0341_TMP.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT KK0341_GENE.KKTK_SVC_KEI_NO, MAX(KK0341_GENE.RSV_APLY_YMD || KK0341_GENE.GENE_ADD_DTM) ") .append(" FROM ") .append(" KK_T_KKTK_SVC_KEI KK0341_GENE ") .append(" WHERE ") .append(" KK0341_GENE.KKTK_SVC_KEI_NO = KK0341_TMP.KKTK_SVC_KEI_NO ") .append(" AND KK0341_GENE.RSV_APLY_YMD <= ? ") // 4 .append(" AND KK0341_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0341_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0341_GENE.KKTK_SVC_KEI_NO ") .append(" ) ") .append(" ) KK0341_CCAS ") .append(" ON ") .append(" KK0341_CCAS.SVC_KEI_UCWK_NO = KK0341_STB.SVC_KEI_UCWK_NO ") .append(" INNER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK0351_TMP.OP_SVC_KEI_NO, ") .append(" KK0351_TMP.SVC_KEI_UCWK_NO, ") .append(" KK0351_TMP.OP_SVC_CD, ") .append(" KK0351_TMP.UPD_DTM, ") .append(" KK0351_TMP.OP_SVC_KEI_STAT, ") .append(" KK0351_TMP.RSV_APLY_YMD, ") .append(" DECODE(KK0351_TMP.OP_SVC_KEI_STAT,'100','1', ") .append(" DECODE(KK0351_TMP.OP_SVC_KEI_STAT,'210','1', ") .append(" DECODE(KK0351_TMP.OP_SVC_KEI_STAT,'220','1', ") .append(" DECODE(KK0351_TMP.OP_SVC_KEI_STAT,'030','2')))) AS SORT_KEY ") .append(" FROM ") .append(" KK_T_OP_SVC_KEI KK0351_TMP ") .append(" WHERE ") .append(" (KK0351_TMP.OP_SVC_KEI_NO, KK0351_TMP.RSV_APLY_YMD || KK0351_TMP.GENE_ADD_DTM) = ( ") .append(" SELECT ") .append(" KK0351_GENE.OP_SVC_KEI_NO, MAX(KK0351_GENE.RSV_APLY_YMD || KK0351_GENE.GENE_ADD_DTM) AS MAX ") .append(" FROM ") .append(" KK_T_OP_SVC_KEI KK0351_GENE ") .append(" WHERE ") .append(" KK0351_GENE.OP_SVC_KEI_NO = KK0351_TMP.OP_SVC_KEI_NO AND ") .append(" KK0351_GENE.RSV_APLY_YMD <= ? AND ") // 5 .append(" KK0351_GENE.RSV_APLY_CD = '2' AND ") .append(" KK0351_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0351_GENE.OP_SVC_KEI_NO ") .append(" ) AND ") .append(" KK0351_TMP.OP_SVC_KEI_STAT IN('030','100','210','220') ") .append(" ) KK0351 ") .append(" ON ") .append(" KK0341_STB.SVC_KEI_UCWK_NO = KK0351.SVC_KEI_UCWK_NO AND ") .append(" KK0341_CCAS.SVC_KEI_UCWK_NO = KK0351.SVC_KEI_UCWK_NO ") .append(" INNER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK0161_TMP.SVC_KEI_UCWK_NO, ") .append(" KK0161_TMP.SVC_KEI_NO, ") .append(" KK0161_TMP.PCRS_CD, ") .append(" KK0161_TMP.SVC_KEI_UCWK_STAT, ") .append(" KK0161_TMP.RSV_APLY_YMD ") .append(" FROM ") .append(" KK_T_SVC_KEI_UCWK KK0161_TMP ") .append(" WHERE ") .append(" KK0161_TMP.SVC_KEI_NO = ? ") // 6 .append(" AND (KK0161_TMP.SVC_KEI_UCWK_NO, KK0161_TMP.RSV_APLY_YMD || KK0161_TMP.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 ") .append(" KK0161_GENE.SVC_KEI_UCWK_NO = KK0161_TMP.SVC_KEI_UCWK_NO ") .append(" AND KK0161_GENE.RSV_APLY_YMD <= ? ") // 7 .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(" ) KK0161 ") .append(" ON ") .append(" KK0161.SVC_KEI_UCWK_NO = KK0351.SVC_KEI_UCWK_NO ") .append(" INNER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK0821_TMP.OP_SVC_CD, ") .append(" KK0821_TMP.OP_SVC_NM, ") .append(" KK0821_TMP.OP_CHANNEL_SBT_CD, ") .append(" KK0821_TMP.RSV_APLY_YMD ") .append(" FROM ") .append(" KK_M_OP_SVC KK0821_TMP ") .append(" WHERE ") .append(" (KK0821_TMP.OP_SVC_CD, KK0821_TMP.RSV_APLY_YMD || KK0821_TMP.GENE_ADD_DTM) = ( ") .append(" SELECT KK0821_GENE.OP_SVC_CD, MAX(KK0821_GENE.RSV_APLY_YMD || KK0821_GENE.GENE_ADD_DTM) ") .append(" FROM KK_M_OP_SVC KK0821_GENE ") .append(" WHERE ") .append(" KK0821_GENE.OP_SVC_CD = KK0821_TMP.OP_SVC_CD ") .append(" AND KK0821_GENE.RSV_APLY_YMD <= ? ") // 8 .append(" AND KK0821_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0821_GENE.OP_SVC_CD ") .append(" ) ") .append(" ) KK0821 ") .append(" ON ") .append(" KK0821.OP_SVC_CD = KK0351.OP_SVC_CD ") .append(" INNER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK0791_TMP.OP_SVC_CD ") .append(" FROM ") .append(" KK_M_PCRS KK0791_TMP ") .append(" WHERE ") .append(" KK0791_TMP.PCRS_CHPSB_SCREEN_SKBT_CD in ('1','3') AND ") .append(" (KK0791_TMP.PCRS_CD, KK0791_TMP.RSV_APLY_YMD || KK0791_TMP.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT KK0791_GENE.PCRS_CD, MAX(KK0791_GENE.RSV_APLY_YMD || KK0791_GENE.GENE_ADD_DTM) ") .append(" FROM ") .append(" KK_M_PCRS KK0791_GENE ") .append(" WHERE ") .append(" KK0791_GENE.PCRS_CD = KK0791_TMP.PCRS_CD ") .append(" AND KK0791_GENE.RSV_APLY_YMD <= ? ") // 9' .append(" AND KK0791_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0791_GENE.PCRS_CD ") .append(" ) ") .append(" ) KK0791 ") .append(" ON ") .append(" KK0351.OP_SVC_CD = KK0791.OP_SVC_CD "); if ( "1".equals( inMsg.getObject(EKK0351B507CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE ") .append(" NOT EXISTS ") .append(" ( ") .append(" SELECT ") .append(" TMP_KK1681.OP_SVC_KEI_NO ") .append(" FROM ") .append(" KK_T_IDO_RSV TMP_KK1681 ") .append(" WHERE ") .append(" TMP_KK1681.OP_SVC_KEI_NO = KK0351.OP_SVC_KEI_NO AND ") .append(" TMP_KK1681.MK_FLG = '0' AND ") .append(" TMP_KK1681.IDO_RSV_DTL_CD IN('015','016') AND ") .append(" TMP_KK1681.IDO_RSV_STAT_CD IN('00','03') AND ") .append(" TMP_KK1681.RSV_APLY_YMD >= ? ") // 10' .append(" ) AND ") .append(" KK0161.SVC_KEI_UCWK_STAT IN ('100', '030') AND ") .append(" KK0341_STB.KKTK_SVC_CD = 'C009' AND ") .append(" KK0341_STB.KKTK_SVC_KEI_STAT IN ('100', '030') AND ") .append(" KK0341_CCAS.KKTK_SVC_CD = 'C011' AND ") .append(" KK0341_CCAS.KKTK_SVC_KEI_STAT IN ('100', '030') AND ") .append(" KK0161.SVC_KEI_NO = ? ") // 11' .append(" ORDER BY ") .append(" OP_CHANNEL_SBT_CD, ") .append(" SORT_KEY, ") .append(" OP_SVC_CD "); } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 if ( "1".equals( inMsg.getString(EKK0351B507CBSMsg.FUNC_CODE) ) ) { /* ++++++++++ v4.00 修正開始 ++++++++++ */ // パラメータのカウント int iPCnt = 1; // サービス契約番号取得 String svcKeiNo = (String)inMsg.getObject(EKK0351B507CBSMsg.KEY_SVC_KEI_NO); // 運用日付取得 String opeDate = JCCModelCommon.getOpeDate(inMsg, null); // 1 パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, svcKeiNo); // 2 パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 3 パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, svcKeiNo); // 4 パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 5 パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 6 パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, svcKeiNo); // 7 パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 8 パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 9' パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 10' パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, opeDate); // 11' パラメータの設定(ＫＥＹ＿サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, iPCnt++, svcKeiNo); /* ++++++++++ v4.00 修正終了 ++++++++++ */ } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK0351B507CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0351B507CBSMsg1List.OP_SVC_KEI_NO , EKK0351B507CBSMsg1List.OP_SVC_KEI_STAT , EKK0351B507CBSMsg1List.RSV_APLY_YMD , EKK0351B507CBSMsg1List.UPD_DTM , EKK0351B507CBSMsg1List.OP_SVC_CD , EKK0351B507CBSMsg1List.OP_SVC_CD_NM , EKK0351B507CBSMsg1List.OP_CHANNEL_SBT_CD , EKK0351B507CBSMsg1List.SVC_KEI_NO , EKK0351B507CBSMsg1List.SVC_KEI_UCWK_NO , EKK0351B507CBSMsg1List.KKTK_SVC_KEI_NO_STB , EKK0351B507CBSMsg1List.KIKI_SEIZO_NO_STB , EKK0351B507CBSMsg1List.KKTK_SVC_KEI_NO_CCAS , EKK0351B507CBSMsg1List.KIKI_SEIZO_NO_CCAS }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0351B507CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0351B507CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0351B507CBSMsg.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(EKK0351B507CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }