/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbETU0081B011TPDA
* ソースファイル名：JSYejbETU0081B011TPDA.java
* 作成者 ：EK909306
* 日付 ：2011年06月29日
*＜機能概要＞
* 電話帳申込依頼情報取得テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v3.00.00 2012/03/17 FJ)楠神 新規作成
* v4.00.00 2012/05/31 FJ)宮本 ANK-0398-00-00
* v4.00.01 2012/06/29 FJ)宮本 IT1-2012-0000872
* v4.00.02 2012/08/22 FJ)宮本 TAI-2012-0000093
* v4.00.03 2012/11/28 FJ)楠神 ST4-2012-0000113
*
********************************************************************************/
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.common.constant.JTUStrConst;
import eo.ejb.cbs.cbsmsg.ETU0081B011CBSMsg;
import eo.ejb.cbs.cbsmsg.ETU0081B011CBSMsg1List;
import eo.ejb.cbm.entity.TU0081ETMsg;
import eo.ejb.common.JTUModelCommon;
/**
*
* テンプレートDBアクセス部品 ETU0081B011_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
* @author FJ
*/
public class JSYejbETU0081B011TPDA extends CAANSQLFacility implements TemplateDBAccessHandler
{
/**
* コンストラクタ
*/
public JSYejbETU0081B011TPDA()
{
}
/**
* ETU0081B011_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext
* @return void
*/
public void invoke(CAANMsg inMsg, AgentDispatchContext inContext)
{
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
/**
* パラメータセット用
*/
int iIndex = 1;
/**
* 表示件数、表示ページ番号が未設定の場合
*/
if (inMsg.isNull(ETU0081B011CBSMsg.DISPLAY_NUM)
|| inMsg.isNull(ETU0081B011CBSMsg.DISPLAY_PAGE_NUM))
{
throw new IllegalArgumentException(JTUStrConst.ICRN_ERR_MSG_BBN);
}
/********************
* SQL文の作成
********************/
try
{
//コネクション取得
con1 = JSYejbConnection.getConnection(TU0081ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
StringBuffer sql_Select = new StringBuffer();
StringBuffer sql_From = new StringBuffer();
StringBuffer sql_Where = new StringBuffer();
sql_Select.append(" SELECT ")
.append(" ROW_NUMBER() OVER( ")
.append(" ORDER BY ")
.append(" MAIN.SVC_KEI_NO_DISP ASC, ")
.append(" MAIN.NTT_TELNO_DISP ASC, ")
.append(" MAIN.KEISAI_JUN ASC ")
.append(" ) AS ROW_NUM, ")
.append(" MAIN.DNWACHO_MSKM_NO, ")
.append(" MAIN.GENE_ADD_DTM, ")
.append(" MAIN.SVC_KEI_NO_DISP, ")
.append(" MAIN.SVC_KEI_NO, ")
.append(" MAIN.SVC_KEI_UCWK_NO, ")
.append(" MAIN.HJIN_EO_YKAE_SVKEI_NO, ")
.append(" MAIN.HOJIN_KOJIN_CD, ")
.append(" MAIN.DNWACHOMSK_IDO_NAIYO_CD, ")
.append(" ( ")
.append(" SELECT ")
.append(" CD_NM.CD_DIV_ALI ")
.append(" FROM ")
.append(" ZM_M_CD_NM_KANRI CD_NM ")
.append(" WHERE ")
.append(" CD_NM.CD_SBT_CD = 'CD00525' ")
.append(" AND MAIN.DNWACHOMSK_IDO_NAIYO_CD = CD_NM.CD_DIV ")
.append(" AND CD_NM.MK_FLG = '0' ")
.append(" ) AS DNWACHOMSK_REQ_NAIYO_CD_NM, ")
.append(" MAIN.KEISAI_NM_DISP, ")
.append(" MAIN.KEISAI_NM_NEW, ")
.append(" MAIN.KEISAI_NM_OLD, ")
.append(" MAIN.NTT_TELNO_DISP, ")
.append(" MAIN.NTT_TELNO_NEW, ")
.append(" MAIN.NTT_TELNO_OLD ");
sql_From.append(" FROM ")
.append(" ( ")
.append(" SELECT ")
.append(" DNW.DNWACHO_MSKM_NO, ")
.append(" DECODE(DNW.HOJIN_KOJIN_CD, '1', SKU.SVC_KEI_NO, DNW.HJIN_EO_YKAE_SVKEI_NO) SVC_KEI_NO_DISP, ")
.append(" DNW.GENE_ADD_DTM, ")
.append(" SKU.SVC_KEI_NO, ")
.append(" DNW.SVC_KEI_UCWK_NO, ")
.append(" DNW.HJIN_EO_YKAE_SVKEI_NO, ")
.append(" DNW.HOJIN_KOJIN_CD, ")
.append(" DNW.DNWACHOMSK_IDO_NAIYO_CD, ")
.append(" DECODE(DNW.DNWACHOMSK_IDO_NAIYO_CD, '3', DNWN_OLD.KEISAI_NM, DNWN_NEW.KEISAI_NM) KEISAI_NM_DISP, ")
.append(" DNWN_NEW.KEISAI_NM AS KEISAI_NM_NEW, ")
.append(" DNWN_OLD.KEISAI_NM AS KEISAI_NM_OLD, ")
.append(" DECODE(DNW.DNWACHOMSK_IDO_NAIYO_CD, '3', DNWN_OLD.NTT_TELNO, DNWN_NEW.NTT_TELNO) NTT_TELNO_DISP, ")
.append(" DNWN_NEW.NTT_TELNO AS NTT_TELNO_NEW, ")
.append(" DNWN_OLD.NTT_TELNO AS NTT_TELNO_OLD, ")
.append(" CASE WHEN (DNW.DNWACHOMSK_IDO_NAIYO_CD IN ('1', '2') AND DNWN_NEW.DBLE_KEISAI_FLG = '0') ")
.append(" OR (DNW.DNWACHOMSK_IDO_NAIYO_CD = '3' and DNWN_OLD.DBLE_KEISAI_FLG = '1') THEN 0 ELSE 1 END AS KEISAI_JUN ")
.append(" FROM ")
.append(" ( ")
.append(" SELECT ")
.append(" DNW_IN.DNWACHO_MSKM_NO, ")
.append(" DNW_IN.GENE_ADD_DTM, ")
.append(" DNW_IN.HOJIN_KOJIN_CD, ")
.append(" DNW_IN.SVC_KEI_UCWK_NO, ")
.append(" DNW_IN.HJIN_EO_YKAE_SVKEI_NO, ")
.append(" DNW_IN.DNWACHOMSK_IDO_NAIYO_CD, ")
.append(" DNW_IN.KEISAI_SVC_STAYMD, ")
.append(" DNW_IN.BMP_UM, ")
.append(" DNW_IN.REQ_UK_YMD ")
.append(" FROM ")
.append(" TU_T_DNWACHOMSK DNW_IN ")
.append(" WHERE ")
.append(" DNW_IN.DNWACHO_MSKM_STAT = '021' ")
.append(" AND DNW_IN.TDIS_INFO_CHK_FLG = '1' ")
.append(" AND DNW_IN.AD_CHK_RSLT_CD = '0' ")
.append(" AND (DNW_IN.DNWACHO_MSKM_NO, DNW_IN.GENE_ADD_DTM) = ( ")
.append(" SELECT ")
.append(" DNW_GENE.DNWACHO_MSKM_NO, MAX(DNW_GENE.GENE_ADD_DTM) ")
.append(" FROM ")
.append(" TU_T_DNWACHOMSK DNW_GENE ")
.append(" WHERE ")
.append(" DNW_GENE.DNWACHO_MSKM_NO = DNW_IN.DNWACHO_MSKM_NO ")
.append(" AND DNW_GENE.MK_FLG = '0' ")
.append(" GROUP BY ")
.append(" DNW_GENE.DNWACHO_MSKM_NO ")
.append(" ) ")
.append(" ) DNW ")
.append(" INNER JOIN ")
.append(" TU_T_DNWACHOMSK_NYO DNWN_NEW ")
.append(" ON ")
.append(" DNW.DNWACHO_MSKM_NO = DNWN_NEW.DNWACHO_MSKM_NO ")
.append(" AND DNW.GENE_ADD_DTM = DNWN_NEW.GENE_ADD_DTM ")
.append(" AND DNWN_NEW.DNWACHOMSK_NEW_OLD_FLG = '0' ")
.append(" AND DNWN_NEW.MK_FLG = '0' ")
.append(" INNER JOIN ")
.append(" TU_T_DNWACHOMSK_NYO DNWN_OLD ")
.append(" ON ")
.append(" DNW.DNWACHO_MSKM_NO = DNWN_OLD.DNWACHO_MSKM_NO ")
.append(" AND DNW.GENE_ADD_DTM = DNWN_OLD.GENE_ADD_DTM ")
.append(" AND DNWN_OLD.DNWACHOMSK_NEW_OLD_FLG = '1' ")
.append(" AND DNWN_OLD.MK_FLG = '0' ")
.append(" LEFT OUTER JOIN ")
.append(" KK_T_SVC_KEI_UCWK SKU ")
.append(" ON ")
.append(" DNW.SVC_KEI_UCWK_NO = SKU.SVC_KEI_UCWK_NO ")
.append(" AND SKU.RSV_APLY_YMD || SKU.GENE_ADD_DTM IN ( ")
.append(" SELECT ")
.append(" MAX(UCWK_GENE.RSV_APLY_YMD || UCWK_GENE.GENE_ADD_DTM) ")
.append(" FROM ")
.append(" KK_T_SVC_KEI_UCWK UCWK_GENE ")
.append(" WHERE ")
.append(" UCWK_GENE.SVC_KEI_UCWK_NO = SKU.SVC_KEI_UCWK_NO ")
.append(" AND UCWK_GENE.RSV_APLY_YMD <= ? ")
.append(" AND UCWK_GENE.RSV_APLY_CD = '2' ")
.append(" AND UCWK_GENE.MK_FLG = '0' ")
.append(" GROUP BY ")
.append(" SKU.SVC_KEI_UCWK_NO ")
.append(" ) ")
.append(" LEFT OUTER JOIN ")
.append(" TU_T_BMP_KOJI BMP ")
.append(" ON ")
.append(" NVL(DNW.SVC_KEI_UCWK_NO, 'DUMMY') = NVL(BMP.SVC_KEI_UCWK_NO, 'DUMMY') ")
.append(" AND NVL(DNW.HJIN_EO_YKAE_SVKEI_NO, 'DUMMY') = NVL(BMP.HJIN_EO_YKAE_SVKEI_NO, 'DUMMY') ")
.append(" AND DECODE(DNW.DNWACHOMSK_IDO_NAIYO_CD, 3, DNWN_OLD.NTT_TELNO, DNWN_NEW.NTT_TELNO) = BMP.NTT_KEI_TEL_KAISEN_NO ")
.append(" AND DNW.BMP_UM = '1' ")
.append(" WHERE ")
.append(" ( ")
.append(" ( ")
.append(" DNW.BMP_UM = '1' ")
.append(" AND BMP.GENE_ADD_DTM = ( ")
.append(" SELECT ")
.append(" MAX(BMP_GENE.GENE_ADD_DTM) ")
.append(" FROM ")
.append(" TU_T_BMP_KOJI BMP_GENE ")
.append(" WHERE ")
.append(" BMP_GENE.BMP_KOJI_NO = BMP.BMP_KOJI_NO ")
.append(" AND BMP_GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" AND BMP.BMP_KOJI_STAT IN('031', '032', '040', '050') ")
.append(" AND ( ")
.append(" ? >= SUBSTR(BMP.BMP_KOJI_FIX_YMDH,1,8) ")
.append(" OR ? >= ( ")
.append(" SELECT ")
.append(" MAX(BUSDAY.TRGT_YMD) ")
.append(" FROM ")
.append(" ZM_M_BUSIDAY_KANRI BUSDAY ")
.append(" WHERE ")
.append(" BUSDAY.TRGT_YMD < SUBSTR(BMP.BMP_KOJI_FIX_YMDH,1,8) ")
.append(" AND BUSDAY.BUSIDAY_FLG = '1' ")
.append(" AND BUSDAY.MK_FLG = '0' ")
.append(" ) ")
.append(" ) ")
.append(" ) ")
.append(" OR ")
.append(" ( ")
.append(" DNW.BMP_UM = '0' ")
.append(" AND ? >= DNW.KEISAI_SVC_STAYMD ")
.append(" ) ")
.append(" ) ")
.append(" ORDER BY ")
.append(" DNW.REQ_UK_YMD ASC, ")
.append(" DECODE(DNW.HOJIN_KOJIN_CD, '1', SKU.SVC_KEI_NO, DNW.HJIN_EO_YKAE_SVKEI_NO) ASC, ")
.append(" DECODE(DNW.DNWACHOMSK_IDO_NAIYO_CD, '3', DNWN_OLD.NTT_TELNO, DNWN_NEW.NTT_TELNO) ASC, ")
.append(" CASE WHEN (DNW.DNWACHOMSK_IDO_NAIYO_CD IN ('1', '2') AND DNWN_NEW.DBLE_KEISAI_FLG = '0') ")
.append(" OR (DNW.DNWACHOMSK_IDO_NAIYO_CD = '3' and DNWN_OLD.DBLE_KEISAI_FLG = '1') THEN 0 ELSE 1 END ASC ")
.append(" ) MAIN ");
// SQL文_個別部1
if ("1".equals(inMsg.getObject(ETU0081B011CBSMsg.FUNC_CODE).toString()))
{
sql_Where.append(" WHERE ")
.append(" ROWNUM <= ( ")
.append(" SELECT ")
.append(" MSKM.SEND_UPPLNO ")
.append(" FROM ")
.append(" TU_M_MSKM_JIGSHO MSKM ")
.append(" WHERE ")
.append(" MSKM.MSKM_JIGSHO_NO = ? ")
.append(" AND MSKM.MSKM_JIGSHO_SBT_CD = '3' ")
.append(" AND MSKM.MK_FLG = '0' ")
.append(" ) ");
}
//パラメータ取得
int iDispNum = 0;
int iDispPageNum = 0;
//開始行、終了行設定
int iStartNum = 0;
int iEndNum = 0;
//件数取得SQL
StringBuffer sql_cnt = new StringBuffer();
sql_cnt.append(" SELECT ")
.append(" COUNT(*) AS CNT ")
.append(sql_From)
.append(sql_Where);
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_cnt.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_cnt);
//パラメータ設定用Index 初期化
iIndex = 1;
String opeDate = JTUModelCommon.getOpeDate(inMsg, null);
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ("1".equals(inMsg.getString(ETU0081B011CBSMsg.FUNC_CODE)))
{
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
// パラメータの設定(ＫＥＹ＿申込事業所番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(ETU0081B011CBSMsg.KEY_MSKM_JIGSHO_NO));
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// 明細にセットする項目
String[] msgKeyListCnt = {
ETU0081B011CBSMsg.TOTAL_SEARCH_NUM
};
/**
* 結果取得
*/
rsltQuery.next();
mapMessage(rsltQuery, msgKeyListCnt, inMsg);
// 資源の解放
if(rsltQuery != null)
{
rsltQuery.close();
}
if(pstmt != null)
{
pstmt.close();
}
// 総ページ数設定
int iTotal = Integer.parseInt(inMsg.getString(ETU0081B011CBSMsg.TOTAL_SEARCH_NUM));
//パラメータ取得
iDispNum = Integer.parseInt(inMsg.getString(ETU0081B011CBSMsg.DISPLAY_NUM));
iDispPageNum = Integer.parseInt(inMsg.getString(ETU0081B011CBSMsg.DISPLAY_PAGE_NUM));
//開始行、終了行設定
iStartNum = iDispNum * (iDispPageNum - 1) + 1;
iEndNum = iDispNum * iDispPageNum;
/**
* 総ページ数、エラーフラグ設定
*/
int iSearchDivDisp = iTotal / iDispNum;
int iRest = iTotal % iDispNum;
// 割り切れない場合は総ページ数を増やす
if (0 != iRest)
{
iSearchDivDisp++;
}
inMsg.set(ETU0081B011CBSMsg.TOTAL_PAGE_NUM, Integer.toString(iSearchDivDisp));
// 部分検索の場合
// 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了
if (0 == (Integer.parseInt(inMsg.getString(ETU0081B011CBSMsg.TOTAL_SEARCH_NUM))))
{
inMsg.set(ETU0081B011CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
return;
}
// 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了
if (iTotal < iStartNum)
{
inMsg.set(ETU0081B011CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
/***********************************************************************************************
* データ取得
*/
sql_Buff.append(" SELECT ")
.append(" TBL.DNWACHO_MSKM_NO, ")
.append(" TBL.GENE_ADD_DTM, ")
.append(" TBL.SVC_KEI_NO_DISP, ")
.append(" TBL.SVC_KEI_NO, ")
.append(" TBL.SVC_KEI_UCWK_NO, ")
.append(" TBL.HJIN_EO_YKAE_SVKEI_NO, ")
.append(" TBL.HOJIN_KOJIN_CD, ")
.append(" TBL.DNWACHOMSK_IDO_NAIYO_CD, ")
.append(" TBL.DNWACHOMSK_REQ_NAIYO_CD_NM, ")
.append(" TBL.KEISAI_NM_DISP, ")
.append(" TBL.KEISAI_NM_NEW, ")
.append(" TBL.KEISAI_NM_OLD, ")
.append(" TBL.NTT_TELNO_DISP, ")
.append(" TBL.NTT_TELNO_NEW, ")
.append(" TBL.NTT_TELNO_OLD ")
.append(" FROM ")
.append(" ( ")
.append(sql_Select)
.append(sql_From)
.append(sql_Where)
.append(" ) TBL ")
.append(" WHERE ")
.append(" TBL.ROW_NUM BETWEEN ? AND ? ")
.append(" ORDER BY ")
.append(" TBL.ROW_NUM ASC ");
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
//パラメータ設定用Index 初期化
iIndex = 1;
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ("1".equals(inMsg.getString(ETU0081B011CBSMsg.FUNC_CODE)))
{
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
CAANJDBCUtil.setParam(pstmt, iIndex++, opeDate);
// パラメータの設定(ＫＥＹ＿申込事業所番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, inMsg.getObject(ETU0081B011CBSMsg.KEY_MSKM_JIGSHO_NO));
//開始レコードの設定
CAANJDBCUtil.setParam(pstmt, iIndex++, iStartNum);
//終了レコードの設定
CAANJDBCUtil.setParam(pstmt, iIndex++, iEndNum);
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// ETU0081B011CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
ETU0081B011CBSMsg1List.DNWACHO_MSKM_NO
, ETU0081B011CBSMsg1List.GENE_ADD_DTM
, ETU0081B011CBSMsg1List.SVC_KEI_NO_DISP
, ETU0081B011CBSMsg1List.SVC_KEI_NO
, ETU0081B011CBSMsg1List.SVC_KEI_UCWK_NO
, ETU0081B011CBSMsg1List.HJIN_EO_YKAE_SVKEI_NO
, ETU0081B011CBSMsg1List.HOJIN_KOJIN_CD
, ETU0081B011CBSMsg1List.DNWACHOMSK_IDO_NAIYO_CD
, ETU0081B011CBSMsg1List.DNWACHOMSK_REQ_NAIYO_CD_NM
, ETU0081B011CBSMsg1List.KEISAI_NM_DISP
, ETU0081B011CBSMsg1List.KEISAI_NM_NEW
, ETU0081B011CBSMsg1List.KEISAI_NM_OLD
, ETU0081B011CBSMsg1List.NTT_TELNO_DISP
, ETU0081B011CBSMsg1List.NTT_TELNO_NEW
, ETU0081B011CBSMsg1List.NTT_TELNO_OLD
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery, msgKeyList1, "eo.ejb.cbs.cbsmsg.ETU0081B011CBSMsg1List", 0);
/**
* 検索エラーフラグの設定
*/
// 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了
if (outMsg1.length == 0)
{
inMsg.set(ETU0081B011CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
// inMsg(CBSMsg)に明細をセット
inMsg.set("ETU0081B011CBSMsg1List", outMsg1);
}
catch(SQLException e)
{
inMsg.set(ETU0081B011CBSMsg.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(ETU0081B011CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}