/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKK0661B001TPDA
* ソースファイル名：JSYejbEKK0661B001TPDA.java
* 作成者 ：EK103161
* 日付 ：2012年02月07日
*＜機能概要＞
* リモートサポート作業項目一覧照会（基準日指定）テンプレート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.common.constant.JPCModelConstant;
import eo.ejb.cbm.entity.KK0661ETMsg;
import eo.ejb.cbs.cbsmsg.EKK0661B001CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0661B001CBSMsg1List;
import eo.ejb.common.JKKejbPagingUtil;
/**
*
* テンプレートDBアクセス部品 EKK0661B001_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKK0661B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler
{
/**
* コンストラクタ
*/
public JSYejbEKK0661B001TPDA()
{
}
/**
* EKK0661B001_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;
// PreparedStatementのパラメータカウント
int iPCnt = 1;
int iPPage = 1;
/********************
* SQL文の作成
********************/
try
{
//コネクション取得
con1 = JSYejbConnection.getConnection(KK0661ETMsg.getTableName());
// SQL文の作成(件数取得用)
// (1)
StringBuffer sql_Buff1 = new StringBuffer();
sql_Buff1.append(" SELECT ")
.append(" COUNT(*) AS CNT ");
// SQL文の作成(ページングヘッダ)
// (2)
StringBuffer sql_Buff2 = new StringBuffer();
sql_Buff2.append(" SELECT * ")
.append(" FROM ( SELECT ALL_SELECT.*, ROWNUM AS LINE ")
.append(" FROM ( ");
// SQL文の作成(ページングフッダ)
// (3)
StringBuffer sql_Buff3 = new StringBuffer();
sql_Buff3.append(" ) ALL_SELECT ")
.append(" ) PAGE_SELECT ")
.append(" WHERE PAGE_SELECT.LINE BETWEEN ? AND ? ")
.append(" ORDER BY PAGE_SELECT.LINE ASC ");
// SQL文の作成(項目取得)
// (4)
StringBuffer sql_Buff4 = new StringBuffer();
sql_Buff4.append(" SELECT ")
.append(" KK0661.RMT_SUPPORT_WORK_KMK_CD, ")
.append(" KK0661.RMT_SUPPORT_PRC_CD, ")
.append(" KK0661.RMT_SUPPORT_WORK_KMK_NM, ")
.append(" KK0661.RMT_SUPPORT_WORK_AMNT ");
// SQL文の作成(FROM句)
// (5)
StringBuffer sql_Buff5 = new StringBuffer();
sql_Buff5.append(" FROM KK_M_RMTSPRT_WRKITEM KK0661 ");
// SQL文の作成(WHERE句)
// (6)
StringBuffer sql_BuffWhere = new StringBuffer();
// SQL文_個別部1
if ("1".equals(inMsg.getObject(EKK0661B001CBSMsg.FUNC_CODE).toString()))
{
sql_BuffWhere.append(" WHERE (KK0661.RMT_SUPPORT_WORK_KMK_CD, KK0661.RSV_APLY_YMD || KK0661.GENE_ADD_DTM) = ")
.append(" ( ")
.append(" SELECT KK0661_GENE.RMT_SUPPORT_WORK_KMK_CD, MAX(KK0661_GENE.RSV_APLY_YMD || KK0661_GENE.GENE_ADD_DTM) AS KK0661_MAX ")
.append(" FROM KK_M_RMTSPRT_WRKITEM KK0661_GENE ")
.append(" WHERE KK0661_GENE.RMT_SUPPORT_WORK_KMK_CD = KK0661.RMT_SUPPORT_WORK_KMK_CD ")
.append(" AND KK0661_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK0661_GENE.MK_FLG = '0' ")
.append(" GROUP BY KK0661_GENE.RMT_SUPPORT_WORK_KMK_CD ")
.append(" ) ")
.append(" AND RMTSPRT_WRKITEM_TSTAYMD <= ? ")
.append(" AND RMTSPRT_WRKITEM_TENDYMD >= ? ");
}
// SQL文の作成(ORDER BY句)
// (7)
StringBuffer sql_BuffSort = new StringBuffer();
sql_BuffSort.append(" ORDER BY RMT_SUPPORT_WORK_KMK_CD ASC ");
// SQL文の組立て(件数取得用) (1) + (5) + (6)
StringBuffer sql_Count = new StringBuffer();
sql_Count.append(sql_Buff1)
.append(sql_Buff5)
.append(sql_BuffWhere);
//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(EKK0661B001CBSMsg.FUNC_CODE)))
{
// パラメータの設定
iPCnt = setPram(inMsg, pstmt_Count, iPCnt);
}
// ResultSetの取得
rsltQuery_Count = pstmt_Count.executeQuery();
// 総検索件数を取得する
Long lDataCnt = 0L;
if (rsltQuery_Count.next())
{
lDataCnt = rsltQuery_Count.getLong("CNT");
}
// 件数とページ数の算出
// 表示件数
Long lDispNum = inMsg.getStringAsLong(EKK0661B001CBSMsg.DISPLAY_NUM);
// 表示ページ数
Long lDispPage = inMsg.getStringAsLong(EKK0661B001CBSMsg.DISPLAY_PAGE_NUM);
// 総ページ数の算出
String strMaxPage = JKKejbPagingUtil.calcTotalPage(lDataCnt, lDispNum);
// 共通部に値を設定する
// 総検索件数
inMsg.set(EKK0661B001CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(lDataCnt));
// 総ページ数
inMsg.set(EKK0661B001CBSMsg.TOTAL_PAGE_NUM, strMaxPage);
// SQL文の組立て(項目取得・ページング用) (2) + (4) + (5) + (6) + (7)
StringBuffer sql_Page = new StringBuffer();
sql_Page.append(sql_Buff2)
.append(sql_Buff4)
.append(sql_Buff5)
.append(sql_BuffWhere)
.append(sql_BuffSort)
.append(sql_Buff3);
//prepareStatementにSQL文をセット
pstmt_Page = con1.prepareStatement(sql_Page.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Page);
// 検索対象を算出する
long[] iPages = JKKejbPagingUtil.calcSearchRows(lDispPage, lDispNum);
long lRowSta = iPages[0];
long lRowEnd = iPages[1];
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ("1".equals(inMsg.getString(EKK0661B001CBSMsg.FUNC_CODE)))
{
// パラメータの設定
iPPage = setPram(inMsg, pstmt_Page, iPPage);
// パラメータの設定(検索開始行を指定)
CAANJDBCUtil.setParam(pstmt_Page, iPPage++, lRowSta);
// パラメータの設定(検索終了行を指定)
CAANJDBCUtil.setParam(pstmt_Page, iPPage++, lRowEnd);
}
// ResultSetの取得
rsltQuery_Page = pstmt_Page.executeQuery();
// EKK0661B001CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKK0661B001CBSMsg1List.RMT_SUPPORT_WORK_KMK_CD
, EKK0661B001CBSMsg1List.RMT_SUPPORT_PRC_CD
, EKK0661B001CBSMsg1List.RMT_SUPPORT_WORK_KMK_NM
, EKK0661B001CBSMsg1List.RMT_SUPPORT_WORK_AMNT
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page, msgKeyList1, "eo.ejb.cbs.cbsmsg.EKK0661B001CBSMsg1List", 0);
// 取得結果が0件の場合は表示ページ該当なしエラー
if (0L == outMsg1.length)
{
inMsg.set(EKK0661B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
// inMsg(CBSMsg)に明細をセット
inMsg.set("EKK0661B001CBSMsg1List", outMsg1);
}
catch (SQLException e)
{
inMsg.set(EKK0661B001CBSMsg.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(EKK0661B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
/**
*
* パラメータの設定を行います。
*
* @param inMsg 入力値の格納されたCBSMsg
* @param pstmt プリペアステートメント
* @param iPCnt パラメータのカウント
* @return iPCnt パラメータのカウント
* @exception SQLException
*/
private int setPram(CAANMsg inMsg, PreparedStatement pstmt, int iPCnt) throws SQLException
{
// バインド変数の数繰り返す
for (int i = 0; i < 3; i++)
{
// パラメータの設定(ＫＥＹ＿基準年月日を指定)
CAANJDBCUtil.setParam(pstmt, iPCnt++, inMsg.getObject(EKK0661B001CBSMsg.KEY_BASE_YMD));
}
return iPCnt;
}
}