/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbECK0121B004TPDA
* ソースファイル名：JSYejbECK0121B004TPDA.java
* 作成者 ：EK907441
* 日付 ：2012年05月18日
*＜機能概要＞
* お客様グループ設定一覧照会（お客様情報取得）テンプレート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.ECK0121B004CBSMsg;
import eo.ejb.cbs.cbsmsg.ECK0121B004CBSMsg1List;
import eo.ejb.cbm.entity.CK0121ETMsg;
import eo.ejb.common.JCKModelCommon;
import eo.ejb.common.JKKejbPagingUtil;
import eo.ejb.common.db.JCKejbExclusiveProcCK0011;
/**
*
* テンプレートDBアクセス部品 ECK0121B004_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbECK0121B004TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* ＫＥＹ＿ソート項目No：1:グループ割引適用承認年月日
*/
private static final String SORTITEM_GRP_WRIB_APLY_SHONIN_YMD = "1";
/**
* ＫＥＹ＿ソート項目No：2:お客様グループ設定無効年月日
*/
private static final String SORTITEM_CUST_GRP_SETTE_MK_YMD = "2";
/**
* ＫＥＹ＿ソート項目No：3:SYSID
*/
private static final String SORTITEM_SYSID= "3";
/**
* ＫＥＹ＿ソート項目No：4:eoID
*/
private static final String SORTITEM_EOID = "4";
/**
* ＫＥＹ＿ソート項目No：5:お客様名
*/
private static final String SORTITEM_CUST_NM = "5";
/**
* ＫＥＹ＿ソート項目No：6:契約者住所コード
*/
private static final String SORTITEM_KEISHA_AD_CD = "6";
/**
* ＫＥＹ＿ソート区分：1:昇順
*/
private static final String SORTKBN_ASC = "1";
/**
* ＫＥＹ＿ソート区分：2:降順
*/
private static final String SORTKBN_DESC = "2";
/**
* コンストラクタ
*/
public JSYejbECK0121B004TPDA() {
}
/**
* ECK0121B004_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(CK0121ETMsg.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(" CK0121.CUST_GRP_SETTE_NO ")
.append(" ,CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ,CK0121.CUST_GRP_SETTE_MK_YMD ")
.append(" ,CK0121.SYSID ")
.append(" ,CK0011.EOID ")
.append(" ,CK0011.CUST_NM ")
.append(" ,CK0011.KEISHA_AD_CD ")
.append(" ,CK0011.KEISHA_PCD ")
.append(" ,CK0011.KEISHA_STATE_NM ")
.append(" ,CK0011.KEISHA_CITY_NM ")
.append(" ,CK0011.KEISHA_OAZTSU_NM ")
.append(" ,CK0011.KEISHA_AZCHO_NM ")
.append(" ,CK0011.KEISHA_BNCHIGO ")
.append(" ,CK0011.KEISHA_ADRTTM ")
.append(" ,CK0011.KEISHA_ADRRM ")
.append(" ,NULL AS LAST_UPD_DTM ");
// SQL文の作成(FROM句)
// (5)
StringBuffer sql_Buff5 = new StringBuffer();
sql_Buff5.append(" FROM CK_T_CUST_GRP_SETTE CK0121 ")
.append(" INNER JOIN CK_T_CUST CK0011 ON CK0011.SYSID = CK0121.SYSID ");
// SQL文の作成(WHERE句)
// (6)
StringBuffer sql_BuffWhere = new StringBuffer();
if ( "1".equals( inMsg.getObject(ECK0121B004CBSMsg.FUNC_CODE).toString() ) ) {
sql_BuffWhere.append(" WHERE ");
// カレントレコード取得
sql_BuffWhere.append(" ( ");
sql_BuffWhere.append(" (CK0121.CUST_GRP_SETTE_NO, CK0121.RSV_APLY_YMD || CK0121.GENE_ADD_DTM) = ");
sql_BuffWhere.append(" (SELECT CK0121_GENE.CUST_GRP_SETTE_NO, MAX(CK0121_GENE.RSV_APLY_YMD || CK0121_GENE.GENE_ADD_DTM) AS CK0121_MAX ");
sql_BuffWhere.append(" FROM CK_T_CUST_GRP_SETTE CK0121_GENE ");
sql_BuffWhere.append(" WHERE CK0121_GENE.CUST_GRP_SETTE_NO = CK0121.CUST_GRP_SETTE_NO ");
sql_BuffWhere.append(" AND CK0121_GENE.RSV_APLY_YMD <= ? ");
sql_BuffWhere.append(" AND CK0121_GENE.RSV_APLY_CD = '2' ");
sql_BuffWhere.append(" AND CK0121_GENE.MK_FLG = '0' ");
sql_BuffWhere.append(" GROUP BY CK0121_GENE.CUST_GRP_SETTE_NO) ");
sql_BuffWhere.append(" AND (CK0011.SYSID, CK0011.RSV_APLY_YMD || CK0011.GENE_ADD_DTM) = ");
sql_BuffWhere.append(" (SELECT CK0011_GENE.SYSID, MAX(CK0011_GENE.RSV_APLY_YMD || CK0011_GENE.GENE_ADD_DTM) AS CK0011_MAX ");
sql_BuffWhere.append(" FROM CK_T_CUST CK0011_GENE ");
sql_BuffWhere.append(" WHERE CK0011_GENE.SYSID = CK0121.SYSID ");
sql_BuffWhere.append(" AND CK0011_GENE.RSV_APLY_YMD <= ? ");
sql_BuffWhere.append(" AND CK0011_GENE.RSV_APLY_CD = '2' ");
sql_BuffWhere.append(" AND CK0011_GENE.MK_FLG = '0' ");
sql_BuffWhere.append(" GROUP BY CK0011_GENE.SYSID) ");
if (!inMsg.isNull(ECK0121B004CBSMsg.KEY_GRP_CD)) {
sql_BuffWhere.append(" AND CK0121.GRP_CD = ? ");
}
sql_BuffWhere.append(" ) ");
sql_BuffWhere.append(" OR ");
// 未来の最新レコード取得
sql_BuffWhere.append(" ( ");
sql_BuffWhere.append(" (CK0121.CUST_GRP_SETTE_NO, CK0121.RSV_APLY_YMD || CK0121.GENE_ADD_DTM) = ");
sql_BuffWhere.append(" (SELECT CK0121_GENE.CUST_GRP_SETTE_NO, MAX(CK0121_GENE.RSV_APLY_YMD || CK0121_GENE.GENE_ADD_DTM) AS CK0121_MAX ");
sql_BuffWhere.append(" FROM CK_T_CUST_GRP_SETTE CK0121_GENE ");
sql_BuffWhere.append(" WHERE CK0121_GENE.CUST_GRP_SETTE_NO = CK0121.CUST_GRP_SETTE_NO ");
sql_BuffWhere.append(" AND CK0121_GENE.RSV_APLY_YMD > ? ");
sql_BuffWhere.append(" AND CK0121_GENE.RSV_APLY_CD = '2' ");
sql_BuffWhere.append(" AND CK0121_GENE.MK_FLG = '0' ");
sql_BuffWhere.append(" GROUP BY CK0121_GENE.CUST_GRP_SETTE_NO) ");
sql_BuffWhere.append(" AND (CK0011.SYSID, CK0011.RSV_APLY_YMD || CK0011.GENE_ADD_DTM) = ");
sql_BuffWhere.append(" (SELECT CK0011_GENE.SYSID, MAX(CK0011_GENE.RSV_APLY_YMD || CK0011_GENE.GENE_ADD_DTM) AS CK0011_MAX ");
sql_BuffWhere.append(" FROM CK_T_CUST CK0011_GENE ");
sql_BuffWhere.append(" WHERE CK0011_GENE.SYSID = CK0121.SYSID ");
sql_BuffWhere.append(" AND CK0011_GENE.RSV_APLY_YMD <= ? ");
sql_BuffWhere.append(" AND CK0011_GENE.RSV_APLY_CD = '2' ");
sql_BuffWhere.append(" AND CK0011_GENE.MK_FLG = '0' ");
sql_BuffWhere.append(" GROUP BY CK0011_GENE.SYSID) ");
if (!inMsg.isNull(ECK0121B004CBSMsg.KEY_GRP_CD)) {
sql_BuffWhere.append(" AND CK0121.GRP_CD = ? ");
}
sql_BuffWhere.append(" ) ");
}
// SQL文の作成(ORDER BY句)
// (7)
// 子関数で入力サービスＩＦを元に組み立て
StringBuffer sql_BuffSort = this.strBuffOrderByBuilder(inMsg);
// 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(ECK0121B004CBSMsg.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(ECK0121B004CBSMsg.DISPLAY_NUM);
// 表示ページ数
Long lDispPage = inMsg.getStringAsLong(ECK0121B004CBSMsg.DISPLAY_PAGE_NUM);
// 総ページ数の算出
String strMaxPage = JKKejbPagingUtil.calcTotalPage(lDataCnt, lDispNum);
// 共通部に値を設定する
// 総検索件数
inMsg.set(ECK0121B004CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(lDataCnt));
// 総ページ数
inMsg.set(ECK0121B004CBSMsg.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(ECK0121B004CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定
iPCnt = this.setPram(inMsg, pstmt_Page, iPPage);
// パラメータの設定(検索開始行を指定)
CAANJDBCUtil.setParam(pstmt_Page, iPCnt++, lRowSta);
// パラメータの設定(検索終了行を指定)
CAANJDBCUtil.setParam(pstmt_Page, iPCnt++, lRowEnd);
}
// ResultSetの取得
rsltQuery_Page = pstmt_Page.executeQuery();
// ECK0121B004CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
ECK0121B004CBSMsg1List.CUST_GRP_SETTE_NO
, ECK0121B004CBSMsg1List.GRP_WRIB_APLY_SHONIN_YMD
, ECK0121B004CBSMsg1List.CUST_GRP_SETTE_MK_YMD
, ECK0121B004CBSMsg1List.SYSID
, ECK0121B004CBSMsg1List.EOID
, ECK0121B004CBSMsg1List.CUST_NM
, ECK0121B004CBSMsg1List.KEISHA_AD_CD
, ECK0121B004CBSMsg1List.KEISHA_PCD
, ECK0121B004CBSMsg1List.KEISHA_STATE_NM
, ECK0121B004CBSMsg1List.KEISHA_CITY_NM
, ECK0121B004CBSMsg1List.KEISHA_OAZTSU_NM
, ECK0121B004CBSMsg1List.KEISHA_AZCHO_NM
, ECK0121B004CBSMsg1List.KEISHA_BNCHIGO
, ECK0121B004CBSMsg1List.KEISHA_ADRTTM
, ECK0121B004CBSMsg1List.KEISHA_ADRRM
, ECK0121B004CBSMsg1List.LAST_UPD_DTM
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECK0121B004CBSMsg1List",0);
// 取得結果が0件の場合は表示ページ該当なしエラー
if (0L == outMsg1.length)
{
inMsg.set(ECK0121B004CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
// inMsg(CBSMsg)に明細をセット
inMsg.set("ECK0121B004CBSMsg1List", outMsg1);
if (outMsg1.length > 0)
{
for (int i = 0; i < outMsg1.length; i++) {
String lastUpdDtm = null;
// 検索結果に"SYSID"が設定されていた場合
if (!outMsg1[i].isNull(ECK0121B004CBSMsg1List.SYSID))
{
lastUpdDtm = new JCKejbExclusiveProcCK0011().getLastUpdDtmSysId(inMsg,
outMsg1[i].getString(ECK0121B004CBSMsg1List.SYSID));
}
// 取得した最大最終更新年月日時分秒を設定
outMsg1[i].set(ECK0121B004CBSMsg1List.LAST_UPD_DTM, lastUpdDtm);
}
}
} catch(SQLException e) {
inMsg.set(ECK0121B004CBSMsg.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(ECK0121B004CBSMsg.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
{
// カレントレコード取得分と未来の最新レコード取得の計2回分処理する
for (int i=0; i<2; i++) {
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, iPCnt++, JCKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, iPCnt++, JCKModelCommon.getOpeDate(inMsg));
if (!inMsg.isNull(ECK0121B004CBSMsg.KEY_GRP_CD)) {
// パラメータの設定(ＫＥＹ＿グループコードを指定)
CAANJDBCUtil.setParam(pstmt, iPCnt++, inMsg.getObject(ECK0121B004CBSMsg.KEY_GRP_CD));
}
}
return iPCnt;
}
/**
*
* CBSMsgにあるＫＥＹ＿ソート項目NoとＫＥＹ＿ソート区分を元に、
* SQLのソート条件を組立てます。
*
* @param inMsg 入力値の格納されたCBSMsg
* @return sbf inMsgを元に組み立てられたソート条件
*/
private StringBuffer strBuffOrderByBuilder(CAANMsg inMsg){
StringBuffer sbf = new StringBuffer();
String strSortOrder = null;
// ＫＥＹ＿ソート区分ORDER BY句
if (!inMsg.isNull(ECK0121B004CBSMsg.KEY_SORT_KBN)) {
if(SORTKBN_ASC.equals(inMsg.getString(ECK0121B004CBSMsg.KEY_SORT_KBN))) {
// ＫＥＹ＿ソート区分が"1"(昇順)の場合
strSortOrder = " ASC ";
}
else if(SORTKBN_DESC.equals(inMsg.getString(ECK0121B004CBSMsg.KEY_SORT_KBN))) {
// ＫＥＹ＿ソート区分が"2"(降順)の場合
strSortOrder = " DESC ";
}
}
// ＫＥＹ＿ソート項目ＮｏによるORDER BY句
if (!inMsg.isNull(ECK0121B004CBSMsg.KEY_SORT_ITEM_NO)) {
// ソート項目Noの取得
String sortNo = inMsg.getString(ECK0121B004CBSMsg.KEY_SORT_ITEM_NO);
// ORDER BY句
sbf.append(" ORDER BY ");
/* 第2、第3ソートキーについてはソート区分に関わらず常に"昇順"とする。 */
// ＫＥＹ＿ソート項目Noが"1"(グループ割引適用承認年月日)の場合
if(SORTITEM_GRP_WRIB_APLY_SHONIN_YMD.equals(sortNo)) {
// グループ割引適用承認年月日とSYSID
sbf.append(" CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(strSortOrder)
.append(" , CK0121.SYSID ")
.append(" ASC ");
}
// ＫＥＹ＿ソート項目Noが"2"(お客様グループ設定無効年月日)の場合
else if(SORTITEM_CUST_GRP_SETTE_MK_YMD.equals(sortNo)) {
// お客様グループ設定無効年月日とグループ割引適用承認年月日とSYSID
sbf.append(" CK0121.CUST_GRP_SETTE_MK_YMD ")
.append(strSortOrder)
.append(" , CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ASC ")
.append(" , CK0121.SYSID ")
.append(" ASC ");
}
// ＫＥＹ＿ソート項目Noが"3"(SYSID)の場合
else if(SORTITEM_SYSID.equals(sortNo)) {
// SYSIDとグループ割引適用承認年月日
sbf.append(" CK0121.SYSID ")
.append(strSortOrder)
.append(" , CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ASC ");
}
// ＫＥＹ＿ソート項目Noが"4"(eoID)の場合
else if(SORTITEM_EOID.equals(sortNo)) {
// eoIDとグループ割引適用承認年月日とSYSID
sbf.append(" CK0011.EOID ")
.append(strSortOrder)
.append(" , CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ASC ")
.append(" , CK0121.SYSID ")
.append(" ASC ");
}
// ＫＥＹ＿ソート項目Noが"5"(お客様名)の場合
else if(SORTITEM_CUST_NM.equals(sortNo)) {
// お客様名とグループ割引適用承認年月日とSYSID
sbf.append(" CK0011.CUST_NM ")
.append(strSortOrder)
.append(" , CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ASC ")
.append(" , CK0121.SYSID ")
.append(" ASC ");
}
// ＫＥＹ＿ソート項目Noが"6"(契約者住所コード)の場合
else if(SORTITEM_KEISHA_AD_CD.equals(sortNo)) {
// 契約者住所コードとグループ割引適用承認年月日とSYSID
sbf.append(" CK0011.KEISHA_AD_CD ")
.append(strSortOrder)
.append(" , CK0121.GRP_WRIB_APLY_SHONIN_YMD ")
.append(" ASC ")
.append(" , CK0121.SYSID ")
.append(" ASC ");
}
}
return sbf;
}
}