/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKK1351B501TPDA
* ソースファイル名：JSYejbEKK1351B501TPDA.java
* 作成者 ：EK908575
* 日付 ：2013年01月12日
*＜機能概要＞
* データ抽出項目一覧照会（表示データ抽出項目ＣＤ）テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* ｖ1.00.00
* ｖ4.00.00 2013/01/11 FJ）三浦【ST2-2013-0000027】複数件のデータ抽出項目情報の取得
* ｖ5.00.00 2013/02/28 FJ）多田【IT1-2013-0000337】割引集約対応
* ｖ5.01.00 2013/03/12 FJ) 多田【IT1-2013-0000428】割引照査済対応
********************************************************************************/
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.EKK1351B501CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK1351B501CBSMsg1List;
import eo.ejb.cbm.entity.KK1351ETMsg;
import eo.ejb.common.JKKModelCommon;
/**
*
* テンプレートDBアクセス部品 EKK1351B501_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKK1351B501TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbEKK1351B501TPDA() {
}
/**
* EKK1351B501_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(KK1351ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT ")
.append(" KK1351.DCHSKM_CD DCHSKM_CD, ")
.append(" KK1351.DCHS_TYPE_CD DCHS_TYPE_CD, ")
.append(" KK1351.DSP_DCHSKM_CD DSP_DCHSKM_CD, ")
.append(" KK1351.DCHSKM_NM DCHSKM_NM, ")
.append(" KK1351.SET_PSB_STA_YMDHM SET_PSB_STA_YMDHM, ")
.append(" KK1351.SET_PSB_END_YMDHM SET_PSB_END_YMDHM, ")
.append(" KK1351.DCHS_APLY_OPTNTY_CD DCHS_APLY_OPTNTY_CD, ")
.append(" KK1351.DCHS_RLS_OPTNTY_CD DCHS_RLS_OPTNTY_CD, ")
.append(" KK1351.DCHS_SBT_CD DCHS_SBT_CD, ")
.append(" KK1351.DCHSKM_STA_CD DCHSKM_STA_CD, ")
.append(" KK1351.STA_ADJ_CD STA_ADJ_CD, ")
.append(" KK1351.STA_ADJ_PRD STA_ADJ_PRD, ")
.append(" KK1351.DCHSKM_END_CD DCHSKM_END_CD, ")
.append(" KK1351.UPPL_APLY_CNT UPPL_APLY_CNT, ")
.append(" KK1351.DCHSKM_AGING_PRD DCHSKM_AGING_PRD, ")
.append(" KK1351.UPPL_KEI_CNT UPPL_KEI_CNT, ")
.append(" KK1351.DSP_JUN DSP_JUN, ")
.append(" KK1351.JOKEN_TSTAYMD JOKEN_TSTAYMD, ")
.append(" KK1351.JOKEN_TENDYMD JOKEN_TENDYMD, ")
.append(" KK1351.APLY_CNT_HAMBET_CD APLY_CNT_HAMBET_CD, ")
.append(" KK1351.APLY_CNT APLY_CNT, ")
.append(" KK1351.APLY_JOKEN_CD APLY_JOKEN_CD, ")
.append(" KK1351.DCHS_ADD_JOKEN_CD DCHS_ADD_JOKEN_CD, ")
.append(" KK1351.RSV_APLY_YMD KK1351_RSV_APLY_YMD, ")
.append(" KK1351.DCHSKM_TSTAYMD DCHSKM_TSTAYMD, ")
.append(" KK1351.DCHSKM_TENDYMD DCHSKM_TENDYMD, ")
.append(" KK1351.UPD_DTM UPD_DTM, ")
.append(" KK1371.DCHSKM_TG_SVC_CD DCHSKM_TG_SVC_CD, ")
.append(" KK1371.APLY_JOKEN_GRP APLY_JOKEN_GRP, ")
.append(" KK1371.SVC_CD SVC_CD, ")
.append(" KK1371.PRC_GRP_CD PRC_GRP_CD, ")
.append(" KK1371.PCRS_CD PCRS_CD, ")
.append(" KK1371.PPLAN_CD PPLAN_CD, ")
.append(" KK1371.OP_SVC_CD OP_SVC_CD, ")
.append(" KK1371.SBOP_SVC_CD SBOP_SVC_CD, ")
.append(" KK1371.KKTK_SVC_CD KKTK_SVC_CD, ")
.append(" KK1371.KKTK_SBT_CD KKTK_SBT_CD, ")
.append(" KK1371.SEIOPSVC_CD SEIOPSVC_CD, ")
.append(" KK1371.SVC_KEI_YEAR_CNT SVC_KEI_YEAR_CNT, ")
.append(" KK1371.TRGT_KEI_SVC_CNT TRGT_KEI_SVC_CNT, ")
.append(" KK1371.TRGT_KEI_SVC_UPPL TRGT_KEI_SVC_UPPL, ")
.append(" KK1371.TRGT_SVC_HAMBET_CD TRGT_SVC_HAMBET_CD, ")
.append(" KK1371.UPPL_AUTO_APLY_KH UPPL_AUTO_APLY_KH, ")
.append(" KK1371.RSV_APLY_YMD KK1371_RSV_APLY_YMD, ")
.append(" KK1371.DCHSKM_TG_SVC_TSTAYMD DCHSKM_TG_SVC_TSTAYMD, ")
.append(" KK1371.DCHSKM_TG_SVC_TENDYMD DCHSKM_TG_SVC_TENDYMD, ")
.append(" KK1371.CHGE_BF_SVC_CD, ")
.append(" KK1371.CHGE_BF_PRC_GRP_CD, ")
.append(" KK1371.CHGE_BF_PCRS_CD, ")
.append(" KK1371.CHGE_BF_PPLAN_CD, ")
.append(" KK1371.CHGE_BF_OP_SVC_CD, ")
.append(" KK1371.CHGE_BF_SBOP_SVC_CD, ")
.append(" KK1371.CHGE_BF_KKTK_SVC_CD, ")
.append(" KK1371.CHGE_BF_KKTK_SBT_CD, ")
.append(" KK1371.CHGE_BF_SEIOPSVC_CD ")
.append(" FROM ")
.append(" (SELECT ")
.append(" KK1351A.DCHSKM_CD, ")
.append(" KK1351A.DCHS_TYPE_CD, ")
.append(" KK1351A.DSP_DCHSKM_CD, ")
.append(" KK1351A.DCHSKM_NM, ")
.append(" KK1351A.SET_PSB_STA_YMDHM, ")
.append(" KK1351A.SET_PSB_END_YMDHM, ")
.append(" KK1351A.DCHS_APLY_OPTNTY_CD, ")
.append(" KK1351A.DCHS_RLS_OPTNTY_CD, ")
.append(" KK1351A.DCHS_SBT_CD, ")
.append(" KK1351A.DCHSKM_STA_CD, ")
.append(" KK1351A.STA_ADJ_CD, ")
.append(" KK1351A.STA_ADJ_PRD, ")
.append(" KK1351A.DCHSKM_END_CD, ")
.append(" KK1351A.UPPL_APLY_CNT, ")
.append(" KK1351A.DCHSKM_AGING_PRD, ")
.append(" KK1351A.UPPL_KEI_CNT, ")
.append(" KK1351A.DSP_JUN, ")
.append(" KK1351A.JOKEN_TSTAYMD, ")
.append(" KK1351A.JOKEN_TENDYMD, ")
.append(" KK1351A.APLY_CNT_HAMBET_CD, ")
.append(" KK1351A.APLY_CNT, ")
.append(" KK1351A.APLY_JOKEN_CD, ")
.append(" KK1351A.DCHS_ADD_JOKEN_CD, ")
.append(" KK1351A.RSV_APLY_YMD, ")
.append(" KK1351A.DCHSKM_TSTAYMD, ")
.append(" KK1351A.DCHSKM_TENDYMD, ")
.append(" KK1351A.UPD_DTM ")
.append(" FROM ")
.append(" KK_M_DCHSKM KK1351A ")
.append(" WHERE ")
.append(" KK1351A.DSP_DCHSKM_CD = ? ")
.append(" AND KK1351A.RSV_APLY_YMD || KK1351A.GENE_ADD_DTM = ")
.append(" (SELECT ")
.append(" MAX(KK1351_GENE.RSV_APLY_YMD || KK1351_GENE.GENE_ADD_DTM) AS KK1351_MAX ")
.append(" FROM ")
.append(" KK_M_DCHSKM KK1351_GENE ")
.append(" WHERE ")
.append(" KK1351_GENE.DCHSKM_CD = KK1351A.DCHSKM_CD ")
.append(" AND KK1351_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK1351_GENE.MK_FLG = '0') ")
.append(" ) KK1351 ")
.append(" INNER JOIN ")
.append(" (SELECT ")
.append(" KK1371A.DCHSKM_CD DCHSKM_CD, ")
.append(" KK1371A.DCHSKM_TG_SVC_CD DCHSKM_TG_SVC_CD, ")
.append(" KK1371A.APLY_JOKEN_GRP APLY_JOKEN_GRP, ")
.append(" KK1371A.SVC_CD SVC_CD, ")
.append(" KK1371A.PRC_GRP_CD PRC_GRP_CD, ")
.append(" KK1371A.PCRS_CD PCRS_CD, ")
.append(" KK1371A.PPLAN_CD PPLAN_CD, ")
.append(" KK1371A.OP_SVC_CD OP_SVC_CD, ")
.append(" KK1371A.SBOP_SVC_CD SBOP_SVC_CD, ")
.append(" KK1371A.KKTK_SVC_CD KKTK_SVC_CD, ")
.append(" KK1371A.KKTK_SBT_CD KKTK_SBT_CD, ")
.append(" KK1371A.SEIOPSVC_CD SEIOPSVC_CD, ")
.append(" KK1371A.SVC_KEI_YEAR_CNT SVC_KEI_YEAR_CNT, ")
.append(" KK1371A.TRGT_KEI_SVC_CNT TRGT_KEI_SVC_CNT, ")
.append(" KK1371A.TRGT_KEI_SVC_UPPL TRGT_KEI_SVC_UPPL, ")
.append(" KK1371A.TRGT_SVC_HAMBET_CD TRGT_SVC_HAMBET_CD, ")
.append(" KK1371A.UPPL_AUTO_APLY_KH UPPL_AUTO_APLY_KH, ")
.append(" KK1371A.RSV_APLY_YMD RSV_APLY_YMD, ")
.append(" KK1371A.DCHSKM_TG_SVC_TSTAYMD DCHSKM_TG_SVC_TSTAYMD, ")
.append(" KK1371A.DCHSKM_TG_SVC_TENDYMD DCHSKM_TG_SVC_TENDYMD, ")
.append(" KK1371A.CHGE_BF_SVC_CD, ")
.append(" KK1371A.CHGE_BF_PRC_GRP_CD, ")
.append(" KK1371A.CHGE_BF_PCRS_CD, ")
.append(" KK1371A.CHGE_BF_PPLAN_CD, ")
.append(" KK1371A.CHGE_BF_OP_SVC_CD, ")
.append(" KK1371A.CHGE_BF_SBOP_SVC_CD, ")
.append(" KK1371A.CHGE_BF_KKTK_SVC_CD, ")
.append(" KK1371A.CHGE_BF_KKTK_SBT_CD, ")
.append(" KK1371A.CHGE_BF_SEIOPSVC_CD ")
.append(" FROM ")
.append(" KK_M_DCHSKM_TG_SVC KK1371A ")
.append(" WHERE ")
.append(" KK1371A.RSV_APLY_YMD || KK1371A.GENE_ADD_DTM = ")
.append(" (SELECT ")
.append(" MAX(KK1371_GENE.RSV_APLY_YMD || KK1371_GENE.GENE_ADD_DTM) AS KK1371_MAX ")
.append(" FROM KK_M_DCHSKM_TG_SVC KK1371_GENE ")
.append(" WHERE ")
.append(" KK1371_GENE.DCHSKM_TG_SVC_CD = KK1371A.DCHSKM_TG_SVC_CD ")
.append(" AND KK1371_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK1371_GENE.MK_FLG = '0') ")
.append(" ) KK1371 ")
.append(" ON KK1351.DCHSKM_CD = KK1371.DCHSKM_CD ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(EKK1351B501CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff.append(" ORDER BY KK1351.DCHSKM_CD, KK1371.DCHSKM_TG_SVC_CD ");
}
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
int iParamCntr = 0;
// パラメータの設定(ＫＥＹ＿表示用データ抽出項目コードを指定)
CAANJDBCUtil.setParam(pstmt, ++iParamCntr, inMsg.getObject(EKK1351B501CBSMsg.KEY_DSP_DCHSKM_CD));
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, ++iParamCntr, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, ++iParamCntr, JKKModelCommon.getOpeDate(inMsg));
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// EKK1351B501CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKK1351B501CBSMsg1List.DCHSKM_CD
, EKK1351B501CBSMsg1List.DCHS_TYPE_CD
, EKK1351B501CBSMsg1List.DSP_DCHSKM_CD
, EKK1351B501CBSMsg1List.DCHSKM_NM
, EKK1351B501CBSMsg1List.SET_PSB_STA_YMDHM
, EKK1351B501CBSMsg1List.SET_PSB_END_YMDHM
, EKK1351B501CBSMsg1List.DCHS_APLY_OPTNTY_CD
, EKK1351B501CBSMsg1List.DCHS_RLS_OPTNTY_CD
, EKK1351B501CBSMsg1List.DCHS_SBT_CD
, EKK1351B501CBSMsg1List.DCHSKM_STA_CD
, EKK1351B501CBSMsg1List.STA_ADJ_CD
, EKK1351B501CBSMsg1List.STA_ADJ_PRD
, EKK1351B501CBSMsg1List.DCHSKM_END_CD
, EKK1351B501CBSMsg1List.UPPL_APLY_CNT
, EKK1351B501CBSMsg1List.DCHSKM_AGING_PRD
, EKK1351B501CBSMsg1List.UPPL_KEI_CNT
, EKK1351B501CBSMsg1List.DSP_JUN
, EKK1351B501CBSMsg1List.JOKEN_TSTAYMD
, EKK1351B501CBSMsg1List.JOKEN_TENDYMD
, EKK1351B501CBSMsg1List.APLY_CNT_HAMBET_CD
, EKK1351B501CBSMsg1List.APLY_CNT
, EKK1351B501CBSMsg1List.APLY_JOKEN_CD
, EKK1351B501CBSMsg1List.DCHS_ADD_JOKEN_CD
, EKK1351B501CBSMsg1List.KK1351_RSV_APLY_YMD
, EKK1351B501CBSMsg1List.DCHSKM_TSTAYMD
, EKK1351B501CBSMsg1List.DCHSKM_TENDYMD
, EKK1351B501CBSMsg1List.UPD_DTM
, EKK1351B501CBSMsg1List.DCHSKM_TG_SVC_CD
, EKK1351B501CBSMsg1List.APLY_JOKEN_GRP
, EKK1351B501CBSMsg1List.SVC_CD
, EKK1351B501CBSMsg1List.PRC_GRP_CD
, EKK1351B501CBSMsg1List.PCRS_CD
, EKK1351B501CBSMsg1List.PPLAN_CD
, EKK1351B501CBSMsg1List.OP_SVC_CD
, EKK1351B501CBSMsg1List.SBOP_SVC_CD
, EKK1351B501CBSMsg1List.KKTK_SVC_CD
, EKK1351B501CBSMsg1List.KKTK_SBT_CD
, EKK1351B501CBSMsg1List.SEIOPSVC_CD
, EKK1351B501CBSMsg1List.SVC_KEI_YEAR_CNT
, EKK1351B501CBSMsg1List.TRGT_KEI_SVC_CNT
, EKK1351B501CBSMsg1List.TRGT_KEI_SVC_UPPL
, EKK1351B501CBSMsg1List.TRGT_SVC_HAMBET_CD
, EKK1351B501CBSMsg1List.UPPL_AUTO_APLY_KH
, EKK1351B501CBSMsg1List.KK1371_RSV_APLY_YMD
, EKK1351B501CBSMsg1List.DCHSKM_TG_SVC_TSTAYMD
, EKK1351B501CBSMsg1List.DCHSKM_TG_SVC_TENDYMD
, EKK1351B501CBSMsg1List.CHGE_BF_SVC_CD
, EKK1351B501CBSMsg1List.CHGE_BF_PRC_GRP_CD
, EKK1351B501CBSMsg1List.CHGE_BF_PCRS_CD
, EKK1351B501CBSMsg1List.CHGE_BF_PPLAN_CD
, EKK1351B501CBSMsg1List.CHGE_BF_OP_SVC_CD
, EKK1351B501CBSMsg1List.CHGE_BF_SBOP_SVC_CD
, EKK1351B501CBSMsg1List.CHGE_BF_KKTK_SVC_CD
, EKK1351B501CBSMsg1List.CHGE_BF_KKTK_SBT_CD
, EKK1351B501CBSMsg1List.CHGE_BF_SEIOPSVC_CD
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK1351B501CBSMsg1List",0);
// inMsg(CBSMsg)に明細をセット
inMsg.set("EKK1351B501CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(EKK1351B501CBSMsg.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(EKK1351B501CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}