/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKK3381B010TPDA
* ソースファイル名：JSYejbEKK3381B010TPDA.java
* 作成者 ：EK941153
* 日付 ：2022年04月11日
*＜機能概要＞
* IVR進捗管理一覧照会テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* ｖ1.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.common.constant.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.EKK3381B010CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK3381B010CBSMsg1List;
import eo.ejb.cbm.entity.KK3381ETMsg;
import eo.ejb.common.JKKejbPagingUtil;
/**
*
* テンプレートDBアクセス部品 EKK3381B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKK3381B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbEKK3381B010TPDA() {
}
/**
* EKK3381B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void
*/
public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt_Count = null;
PreparedStatement pstmt_Page = null;
// リザルトセット
ResultSet rsltQuery_Count = null;
ResultSet rsltQuery_Page = null;
/********************
* SQL文の作成
********************/
try{
//コネクション取得
con1 = JSYejbConnection.getConnection(KK3381ETMsg.getTableName());
// SQL文の作成(ページングヘッダ)
// (1)
StringBuffer sql_Buff1 = new StringBuffer();
sql_Buff1.append(" SELECT * ")
.append(" FROM ( ")
.append(" SELECT ALL_SELECT.*, ROWNUM AS LINE ")
.append(" FROM ( ");
// SQL文の作成(COUNT用)
// (2)
StringBuffer sql_Buff2 = new StringBuffer();
sql_Buff2.append(" SELECT ")
.append(" COUNT(*) AS CNT ");
// SQL文の作成(項目取得)
// (3)
StringBuffer sql_Buff3 = new StringBuffer();
sql_Buff3.append(" SELECT ")
.append(" KK3381.IVR_UK_NO ")
.append(" ,KK3381.IVR_SKBT_ID ")
.append(" ,KK3381.SEIKY_KEI_NO ")
.append(" ,KK3381.SYSID ")
.append(" ,KK3381.CUST_KANA ")
.append(" ,KK3381.IVR_STAT_CD ")
.append(" ,(SELECT ZM0171_01.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171_01 ")
.append(" WHERE ZM0171_01.CD_SBT_CD = 'CD01789' ")
.append(" AND ZM0171_01.CD_DIV = KK3381.IVR_STAT_CD ")
.append(" AND ZM0171_01.MK_FLG = '0' ")
.append(" ) AS IVR_STAT_CD_NM ")
.append(" ,KK3381.IVR_HASINSHA_TELNO ")
.append(" ,KK3381.IVR_INCOMING_DATE ")
.append(" ,KK3381.CARD_ADD_SUCCESS_FLG ")
.append(" ,(SELECT ZM0171_02.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171_02 ")
.append(" WHERE ZM0171_02.CD_SBT_CD = 'CD01790' ")
.append(" AND ZM0171_02.CD_DIV = KK3381.CARD_ADD_SUCCESS_FLG ")
.append(" AND ZM0171_02.MK_FLG = '0' ")
.append(" ) AS CARD_ADD_SUCCESS_FLG_NM ")
.append(" ,KK3381.IVR_TRAN_RUN_DATE ")
.append(" ,KK3381.CRECARD_NO_AZKRI_ID ")
.append(" ,KK3381.IVR_IKT_ADD_ERR_CD ")
.append(" ,KK3381.IVR_IKT_ADD_ERR_RSN ")
.append(" ,KK3381.SEIKY_WAY_NO_CRECARD ")
.append(" ,KK3381.OUTPUT_ZUMI_FLG ");
// SQL文の作成(WHERE句)
// (4)
StringBuffer sql_Buff4 =new StringBuffer();
sql_Buff4.append(" FROM ")
.append(" KK_T_IVR_PRG_KANRI KK3381 ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(EKK3381B010CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff4.append(" WHERE KK3381.SEIKY_KEI_NO = ? ")
.append(" AND KK3381.MK_FLG = '0' ");
}
// SQL文の作成(ORDER BY句)
// (5)
StringBuffer sql_Buff5 = new StringBuffer();
sql_Buff5.append(" ORDER BY KK3381.IVR_UK_NO DESC ");
// SQL文の作成(ページングフッタ)
// (6)
StringBuffer sql_Buff6 = new StringBuffer();
sql_Buff6.append(" ) ALL_SELECT ")
.append(" ) PAGE_SELECT ")
.append(" WHERE PAGE_SELECT.LINE BETWEEN ? AND ? ")
.append(" ORDER BY PAGE_SELECT.LINE ASC ");
// SQL文の組立て(件数取得用) (2) + (4)
StringBuffer sql_Count = new StringBuffer();
sql_Count.append(sql_Buff2)
.append(sql_Buff4);
//prepareStatementにSQL文をセット
pstmt_Count = con1.prepareStatement(sql_Count.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Count);
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKK3381B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿請求契約番号を指定)
CAANJDBCUtil.setParam(pstmt_Count, 1, inMsg.getObject(EKK3381B010CBSMsg.KEY_SEIKY_KEI_NO));
}
// ResultSetの取得
rsltQuery_Count = pstmt_Count.executeQuery();
// 総検索件数を取得する
Long IDataCnt = 0L;
if (rsltQuery_Count.next())
{
IDataCnt = rsltQuery_Count.getLong("CNT");
}
// 表示件数
Long IDispNum = inMsg.getStringAsLong(EKK3381B010CBSMsg.DISPLAY_NUM);
// 表示ページ数
Long IDispPage = inMsg.getStringAsLong(EKK3381B010CBSMsg.DISPLAY_PAGE_NUM);
// 最大取得件数
Long IMaxNum = inMsg.getStringAsLong(EKK3381B010CBSMsg.MAX_SEARCH_NUM);
// 総ページ数
String strMaxPage = JKKejbPagingUtil.calcTotalPage(IDataCnt, IDispNum);
// 共通部に値を設定する
// 総検索件数
inMsg.set(EKK3381B010CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(IDataCnt));
// 総ページ数
inMsg.set(EKK3381B010CBSMsg.TOTAL_PAGE_NUM, strMaxPage);
// データ取得件数が0件の場合エラー
if (0 == IDataCnt)
{
inMsg.set(EKK3381B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
return;
}
// 最大取得件数を超えた場合エラー
if (IDataCnt > IMaxNum)
{
inMsg.set(EKK3381B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX);
return;
}
// SQL文の組立て(項目取得・ページング用)(1) + (3) + (4) + (5) + (6)
StringBuffer sql_Page =new StringBuffer();
sql_Page.append(sql_Buff1)
.append(sql_Buff3)
.append(sql_Buff4)
.append(sql_Buff5)
.append(sql_Buff6);
// prepareStatementにSQL文をセット
pstmt_Page = con1.prepareStatement(sql_Page.toString());
// ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Page);
// 検索対象を算出する
long[] IPages = JKKejbPagingUtil.calcSearchRows(IDispPage, IDispNum);
long IRowSta = IPages[0];
long IRowEnd = IPages[1];
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKK3381B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿請求契約番号を指定)
CAANJDBCUtil.setParam(pstmt_Page, 1, inMsg.getObject(EKK3381B010CBSMsg.KEY_SEIKY_KEI_NO));
// パラメータの設定(検索開始行を指定)
CAANJDBCUtil.setParam(pstmt_Page, 2, IRowSta);
// パラメータの設定(検索終了行を指定)
CAANJDBCUtil.setParam(pstmt_Page, 3, IRowEnd);
}
// ResultSetの取得
rsltQuery_Page = pstmt_Page.executeQuery();
// EKK3381B010CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKK3381B010CBSMsg1List.IVR_UK_NO
, EKK3381B010CBSMsg1List.IVR_SKBT_ID
, EKK3381B010CBSMsg1List.SEIKY_KEI_NO
, EKK3381B010CBSMsg1List.SYSID
, EKK3381B010CBSMsg1List.CUST_KANA
, EKK3381B010CBSMsg1List.IVR_STAT_CD
, EKK3381B010CBSMsg1List.IVR_STAT_CD_NM
, EKK3381B010CBSMsg1List.IVR_HASINSHA_TELNO
, EKK3381B010CBSMsg1List.IVR_INCOMING_DATE
, EKK3381B010CBSMsg1List.CARD_ADD_SUCCESS_FLG
, EKK3381B010CBSMsg1List.CARD_ADD_SUCCESS_FLG_NM
, EKK3381B010CBSMsg1List.IVR_TRAN_RUN_DATE
, EKK3381B010CBSMsg1List.CRECARD_NO_AZKRI_ID
, EKK3381B010CBSMsg1List.IVR_IKT_ADD_ERR_CD
, EKK3381B010CBSMsg1List.IVR_IKT_ADD_ERR_RSN
, EKK3381B010CBSMsg1List.SEIKY_WAY_NO_CRECARD
, EKK3381B010CBSMsg1List.OUTPUT_ZUMI_FLG
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK3381B010CBSMsg1List",0);
// inMsg(CBSMsg)に明細をセット
// 取得結果が0件の場合は表示ページ該当なしエラー
if (0 >= outMsg1.length)
{
inMsg.set(EKK3381B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
inMsg.set("EKK3381B010CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(EKK3381B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
} finally {
// 資源の解放
try{
if(rsltQuery_Count != null){
rsltQuery_Count.close();
}
if(rsltQuery_Page != null){
rsltQuery_Page.close();
}
if(pstmt_Count != null){
pstmt_Count.close();
}
if(pstmt_Page != null){
pstmt_Page.close();
}
if(con1 != null){
closeConnection(con1);
}
}catch(SQLException e){
inMsg.set(EKK3381B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}