/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbETU0021B017TPDA
* ソースファイル名：JSYejbETU0021B017TPDA.java
* 作成者 ：EK911023
* 日付 ：2012年08月22日
*＜機能概要＞
* 同番移転一覧照会（サービス契約内訳番号）2テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* ｖ1.00.00
* ｖ5.00.00 2013/10/29 FJ）寺園 OM-2013-0003575
*
********************************************************************************/
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.ETU0021B017CBSMsg;
import eo.ejb.cbs.cbsmsg.ETU0021B017CBSMsg1List;
import eo.ejb.cbm.entity.TU0021ETMsg;
import eo.ejb.common.JKKModelCommon;
/**
*
* テンプレートDBアクセス部品 ETU0021B017_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbETU0021B017TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbETU0021B017TPDA() {
}
/**
* ETU0021B017_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(TU0021ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT TU0021.DOBANITEN_NO, ")
.append(" TU0021.GENE_ADD_DTM, ")
.append(" TU0021.DOBANITEN_STAT, ")
.append(" TU0021.SVC_KEI_UCWK_NO, ")
.append(" TU0021.HOJIN_SVC_KEI_UK_NO, ")
.append(" TU0021.HJIN_EO_YKAE_SVKEI_NO, ")
.append(" TU0021.HOJIN_KOJIN_CD, ")
.append(" TU0021.DOBANITEN_MSKM_YMD, ")
.append(" TU0021.DOBANITEN_SBT_CD, ")
.append(" TU0021.DOBANITEN_UK_YMD, ")
.append(" TU0021.DOBANITEN_KIBO_YMD, ")
.append(" TU0021.NTT_TELNO, ")
.append(" TU0021.NTT_KEISHA_NM, ")
.append(" TU0021.NTT_KSH_KANA, ")
.append(" TU0021.RRKS_NM, ")
.append(" TU0021.RRKS_TELNO, ")
.append(" TU0021.SETPLACE_AD_CD, ")
.append(" TU0021.SETPLACE_PCD, ")
.append(" TU0021.SETPLACE_STATE_NM, ")
.append(" TU0021.SETPLACE_CITY_NM, ")
.append(" TU0021.SETPLACE_OAZTSU_NM, ")
.append(" TU0021.SETPLACE_AZCHO_NM, ")
.append(" TU0021.SETPLACE_BNCHIGO, ")
.append(" TU0021.SETPLACE_ADRTTM, ")
.append(" TU0021.SETPLACE_ADRRM, ")
.append(" TU0021.SETPLACE_AD_MAN_INPUT_FLG, ")
.append(" TU0021.SETPLACE_AD_CFM_CD, ")
.append(" TU0021.SETPLACE_SBT_CD, ")
.append(" TU0021.SETPLACE_SBT_OTR_HOKI, ")
.append(" TU0021.MSKM_JI_BMP_JIGYOSHA_CD, ")
.append(" TU0021.DOBANITEN_TNT_USER_ID, ")
.append(" TU0021.MSKM_JIGSHO_NO, ")
.append(" TU0021.MSKMJIG_KIJIRAN_1, ")
.append(" TU0021.MSKMJIG_KIJIRAN_2, ")
.append(" TU0021.MSKMJIG_USE_CD, ")
.append(" TU0021.DOBANITEN_CHOSA_REQYMD, ")
.append(" TU0021.SEND_DTM, ")
.append(" TU0021.SEND_CNT, ")
.append(" TU0021.NTT_REQ_SKBT_NO, ")
.append(" TU0021.DOBANITEN_CHOSA_FIN_YMD, ")
.append(" TU0021.DOBANITEN_NTT_UK_NO, ")
.append(" TU0021.DOBANITEN_KH, ")
.append(" TU0021.DOBANITEN_RSLT_CD, ")
.append(" TU0021.DOBANITEN_RSLT_MEMO, ")
.append(" TU0021.UK_COMP_KISAI_BIKO, ")
.append(" TU0021.DOBANITEN_YMD, ")
.append(" TU0021.DOBANITEN_STP_CD, ")
.append(" TU0021.DOBANITEN_STP_YMD, ")
.append(" TU0021.HOJIN_RSLT_OPUT_ZUMI_FLG, ")
.append(" TU0021.RSLT_LIST_OPUT_ZUMI_FLG, ")
.append(" TU0021.TIOKR_RNK_INF_SKSI_ZM_FLG, ")
.append(" TU0021.ADD_DTM, ")
.append(" TU0021.ADD_OPEACNT, ")
.append(" TU0021.UPD_DTM, ")
.append(" TU0021.UPD_OPEACNT, ")
.append(" TU0021.DEL_DTM, ")
.append(" TU0021.DEL_OPEACNT, ")
.append(" TU0021.MK_FLG ")
.append(" FROM ")
.append(" (SELECT TU0021_01.* ")
.append(" ,KK0161_01.SVC_KEI_UCWK_NO AS KEY_SVC_KEI_UCWK_NO ")
.append(" FROM TU_T_DOBANITEN TU0021_01 ")
.append(" INNER JOIN KK_T_SVC_KEI_UCWK KK0161_01 ")
.append(" ON KK0161_01.SVC_KEI_UCWK_NO = TU0021_01.SVC_KEI_UCWK_NO ")
.append(" WHERE TU0021_01.SVC_KEI_UCWK_NO IS NOT NULL ")
.append(" AND (TU0021_01.DOBANITEN_NO, TU0021_01.GENE_ADD_DTM) = ")
.append(" (SELECT TU0021_01_GENE.DOBANITEN_NO, MAX(TU0021_01_GENE.GENE_ADD_DTM) AS TU0021_MIN ")
.append(" FROM TU_T_DOBANITEN TU0021_01_GENE ")
.append(" WHERE TU0021_01_GENE.DOBANITEN_NO = TU0021_01.DOBANITEN_NO ")
.append(" AND TU0021_01_GENE.MK_FLG = '0' ")
.append(" GROUP BY TU0021_01_GENE.DOBANITEN_NO) ")
.append(" AND (KK0161_01.SVC_KEI_UCWK_NO, KK0161_01.RSV_APLY_YMD || KK0161_01.GENE_ADD_DTM) = ")
.append(" (SELECT KK0161_01_GENE.SVC_KEI_UCWK_NO, MAX(KK0161_01_GENE.RSV_APLY_YMD || KK0161_01_GENE.GENE_ADD_DTM) AS KK0161_MAX ")
.append(" FROM KK_T_SVC_KEI_UCWK KK0161_01_GENE ")
.append(" WHERE KK0161_01_GENE.SVC_KEI_UCWK_NO = KK0161_01.SVC_KEI_UCWK_NO ")
.append(" AND KK0161_01_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK0161_01_GENE.RSV_APLY_CD = '2' ")
.append(" AND KK0161_01_GENE.MK_FLG = '0' ")
.append(" GROUP BY KK0161_01_GENE.SVC_KEI_UCWK_NO) ")
.append(" UNION ")
.append(" SELECT TU0021_02.* ")
.append(" ,KK0161_02.SVC_KEI_UCWK_NO AS KEY_SVC_KEI_UCWK_NO ")
.append(" FROM TU_T_DOBANITEN TU0021_02 ")
.append(" INNER JOIN KK_T_SVKEIUW_EOH_TEL KK0191 ")
.append(" ON KK0191.TELNO = TU0021_02.NTT_TELNO ")
.append(" INNER JOIN KK_T_SVC_KEI_UCWK KK0161_02 ")
.append(" ON KK0161_02.SVC_KEI_UCWK_NO = KK0191.SVC_KEI_UCWK_NO ")
.append(" AND KK0161_02.GENE_ADD_DTM = KK0191.GENE_ADD_DTM ")
.append(" INNER JOIN KK_T_SVC_KEI KK0081 ")
.append(" ON KK0081.SVC_KEI_NO = KK0161_02.SVC_KEI_NO ")
.append(" AND KK0081.SYSID = TU0021_02.SYSID ")
.append(" WHERE TU0021_02.SVC_KEI_UCWK_NO IS NULL ")
.append(" AND (TU0021_02.DOBANITEN_NO, TU0021_02.GENE_ADD_DTM) = ")
.append(" (SELECT TU0021_02_GENE.DOBANITEN_NO, MAX(TU0021_02_GENE.GENE_ADD_DTM) AS TU0021_MIN ")
.append(" FROM TU_T_DOBANITEN TU0021_02_GENE ")
.append(" WHERE TU0021_02_GENE.DOBANITEN_NO = TU0021_02.DOBANITEN_NO ")
.append(" AND TU0021_02_GENE.MK_FLG = '0' ")
.append(" GROUP BY TU0021_02_GENE.DOBANITEN_NO) ")
.append(" AND (KK0161_02.SVC_KEI_UCWK_NO, KK0161_02.RSV_APLY_YMD || KK0161_02.GENE_ADD_DTM) = ")
.append(" (SELECT KK0161_02_GENE.SVC_KEI_UCWK_NO, MAX(KK0161_02_GENE.RSV_APLY_YMD || KK0161_02_GENE.GENE_ADD_DTM) AS KK0161_MAX ")
.append(" FROM KK_T_SVC_KEI_UCWK KK0161_02_GENE ")
.append(" WHERE KK0161_02_GENE.SVC_KEI_UCWK_NO = KK0161_02.SVC_KEI_UCWK_NO ")
.append(" AND KK0161_02_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK0161_02_GENE.RSV_APLY_CD = '2' ")
.append(" AND KK0161_02_GENE.MK_FLG = '0' ")
.append(" GROUP BY KK0161_02_GENE.SVC_KEI_UCWK_NO) ")
.append(" AND (KK0081.SVC_KEI_NO, KK0081.RSV_APLY_YMD || KK0081.GENE_ADD_DTM) = ")
.append(" (SELECT KK0081_GENE.SVC_KEI_NO, MAX(KK0081_GENE.RSV_APLY_YMD || KK0081_GENE.GENE_ADD_DTM) AS KK0081_MAX ")
.append(" FROM KK_T_SVC_KEI KK0081_GENE ")
.append(" WHERE KK0081_GENE.SVC_KEI_NO = KK0081.SVC_KEI_NO ")
.append(" AND KK0081_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK0081_GENE.RSV_APLY_CD = '2' ")
.append(" AND KK0081_GENE.MK_FLG = '0' ")
.append(" GROUP BY KK0081_GENE.SVC_KEI_NO) ")
.append(" ) TU0021 ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(ETU0021B017CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff.append(" WHERE TU0021.KEY_SVC_KEI_UCWK_NO = ? ")
.append(" AND TU0021.DOBANITEN_STAT <> '090' ")
.append(" ORDER BY TU0021.UPD_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(ETU0021B017CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(運用日を指定)
CAANJDBCUtil.setParam(pstmt, 1, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日を指定)
CAANJDBCUtil.setParam(pstmt, 2, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日を指定)
CAANJDBCUtil.setParam(pstmt, 3, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(ＫＥＹ＿サービス契約内訳番号を指定)
CAANJDBCUtil.setParam(pstmt, 4, inMsg.getObject(ETU0021B017CBSMsg.KEY_SVC_KEI_UCWK_NO));
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// ETU0021B017CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
ETU0021B017CBSMsg1List.DOBANITEN_NO
, ETU0021B017CBSMsg1List.GENE_ADD_DTM
, ETU0021B017CBSMsg1List.DOBANITEN_STAT
, ETU0021B017CBSMsg1List.SVC_KEI_UCWK_NO
, ETU0021B017CBSMsg1List.HOJIN_SVC_KEI_UK_NO
, ETU0021B017CBSMsg1List.HJIN_EO_YKAE_SVKEI_NO
, ETU0021B017CBSMsg1List.HOJIN_KOJIN_CD
, ETU0021B017CBSMsg1List.DOBANITEN_MSKM_YMD
, ETU0021B017CBSMsg1List.DOBANITEN_SBT_CD
, ETU0021B017CBSMsg1List.DOBANITEN_UK_YMD
, ETU0021B017CBSMsg1List.DOBANITEN_KIBO_YMD
, ETU0021B017CBSMsg1List.NTT_TELNO
, ETU0021B017CBSMsg1List.NTT_KEISHA_NM
, ETU0021B017CBSMsg1List.NTT_KSH_KANA
, ETU0021B017CBSMsg1List.RRKS_NM
, ETU0021B017CBSMsg1List.RRKS_TELNO
, ETU0021B017CBSMsg1List.SETPLACE_AD_CD
, ETU0021B017CBSMsg1List.SETPLACE_PCD
, ETU0021B017CBSMsg1List.SETPLACE_STATE_NM
, ETU0021B017CBSMsg1List.SETPLACE_CITY_NM
, ETU0021B017CBSMsg1List.SETPLACE_OAZTSU_NM
, ETU0021B017CBSMsg1List.SETPLACE_AZCHO_NM
, ETU0021B017CBSMsg1List.SETPLACE_BNCHIGO
, ETU0021B017CBSMsg1List.SETPLACE_ADRTTM
, ETU0021B017CBSMsg1List.SETPLACE_ADRRM
, ETU0021B017CBSMsg1List.SETPLACE_AD_MAN_INPUT_FLG
, ETU0021B017CBSMsg1List.SETPLACE_AD_CFM_CD
, ETU0021B017CBSMsg1List.SETPLACE_SBT_CD
, ETU0021B017CBSMsg1List.SETPLACE_SBT_OTR_HOKI
, ETU0021B017CBSMsg1List.MSKM_JI_BMP_JIGYOSHA_CD
, ETU0021B017CBSMsg1List.DOBANITEN_TNT_USER_ID
, ETU0021B017CBSMsg1List.MSKM_JIGSHO_NO
, ETU0021B017CBSMsg1List.MSKMJIG_KIJIRAN_1
, ETU0021B017CBSMsg1List.MSKMJIG_KIJIRAN_2
, ETU0021B017CBSMsg1List.MSKMJIG_USE_CD
, ETU0021B017CBSMsg1List.DOBANITEN_CHOSA_REQYMD
, ETU0021B017CBSMsg1List.SEND_DTM
, ETU0021B017CBSMsg1List.SEND_CNT
, ETU0021B017CBSMsg1List.NTT_REQ_SKBT_NO
, ETU0021B017CBSMsg1List.DOBANITEN_CHOSA_FIN_YMD
, ETU0021B017CBSMsg1List.DOBANITEN_NTT_UK_NO
, ETU0021B017CBSMsg1List.DOBANITEN_KH
, ETU0021B017CBSMsg1List.DOBANITEN_RSLT_CD
, ETU0021B017CBSMsg1List.DOBANITEN_RSLT_MEMO
, ETU0021B017CBSMsg1List.UK_COMP_KISAI_BIKO
, ETU0021B017CBSMsg1List.DOBANITEN_YMD
, ETU0021B017CBSMsg1List.DOBANITEN_STP_CD
, ETU0021B017CBSMsg1List.DOBANITEN_STP_YMD
, ETU0021B017CBSMsg1List.HOJIN_RSLT_OPUT_ZUMI_FLG
, ETU0021B017CBSMsg1List.RSLT_LIST_OPUT_ZUMI_FLG
, ETU0021B017CBSMsg1List.TIOKR_RNK_INF_SKSI_ZM_FLG
, ETU0021B017CBSMsg1List.ADD_DTM
, ETU0021B017CBSMsg1List.ADD_OPEACNT
, ETU0021B017CBSMsg1List.UPD_DTM
, ETU0021B017CBSMsg1List.UPD_OPEACNT
, ETU0021B017CBSMsg1List.DEL_DTM
, ETU0021B017CBSMsg1List.DEL_OPEACNT
, ETU0021B017CBSMsg1List.MK_FLG
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ETU0021B017CBSMsg1List",0);
// inMsg(CBSMsg)に明細をセット
inMsg.set("ETU0021B017CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(ETU0021B017CBSMsg.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(ETU0021B017CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}