/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECR0011B130TPDA * ソースファイル名：JSYejbECR0011B130TPDA.java * 作成者 ：EK909278 * 日付 ：2012年05月29日 *＜機能概要＞ * 対応記録一覧照会(キューBOX ページングあり)テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ4.00.00 2013/03/25 FJ）伊藤 ST4-2013-0000354 性能改善 * ｖ6.00.00 2013/09/06 FJ）伊藤 OM-2013-0000449 性能改善(index指定 CR_T_TAIO_KIROK_IDX_05→CR_T_TAIO_KIROK_IDX_11) * ｖ6.00.01 2013/09/16 FJ）伊藤 OM-2013-0002183 性能改善(SQL修正) * ｖ6.00.02 2013/09/22 FJ）伊藤 OM-2013-0002475 性能改善(SQL修正) * ｖ6.00.03 2013/10/24 FJ）伊藤 OM-2013-0003246 性能改善(SQL修正) * ｖ6.00.04 2013/12/07 FJ）伊藤 OM-2013-0004056 受付番号の検索条件を変更 * ｖ8.00.00 2014/06/20 FJ）小野 ST4-2014-0000036 性能改善(メモリバッファ量削減) 【キューBOX番号指定なしの場合の、テーブル結合条件を変更する】 * ｖ29.00.00 2017/02/24 FJ) 原田 ANK-2921-00-00 (客B) MyBox一覧、キューボックス一覧画面での簡易メモの登録 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; 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.CR0011ETMsg; import eo.ejb.cbs.cbsmsg.ECR0011B130CBSMsg; import eo.ejb.cbs.cbsmsg.ECR0011B130CBSMsg1List; import eo.ejb.common.JCCModelCommon; /** * * テンプレートDBアクセス部品　ECR0011B130_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECR0011B130TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECR0011B130TPDA() { } /** * ECR0011B130_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント（件数取得用） PreparedStatement pstmtCount = null; // リザルトセット（件数取得用） ResultSet rsltQueryCount = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /***************************************************** * サービスインターフェイス共通部の必須チェック *****************************************************/ // 最大検索件数、表示件数、表示ページ番号が未設定の場合 // 例外をスローする if (inMsg.isNull(ECR0011B130CBSMsg.DISPLAY_NUM) || inMsg.isNull(ECR0011B130CBSMsg.DISPLAY_PAGE_NUM)) { throw new IllegalArgumentException("サービスインターフェイス共通部の表示件数、表示ページ番号は必須項目です。"); } /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); //パラメータ設定リスト List replaceList = new ArrayList(); // 総検索件数の取得 // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT /*ECR0011B130*/ COUNT(*) ") .append(" FROM "); // KEY_QUE_BOX_NOが指定されていない場合 if ((inMsg.isNull(ECR0011B130CBSMsg.KEY_QUE_BOX_NO))) { sql_Buff.append(getCondition1(inMsg, replaceList)); } // KEY_QUE_BOX_NOが指定されている場合 else { sql_Buff.append(getCondition2(inMsg, replaceList)); } //prepareStatementにSQL文をセット pstmtCount = con1.prepareStatement(sql_Buff.toString()); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for (int idx = 0; idx < replaceList.size(); idx++ ) { CAANJDBCUtil.setParam(pstmtCount, idx + 1, replaceList.get(idx)); } //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // ResultSetの取得 rsltQueryCount = pstmtCount.executeQuery(); // ECR0011B130CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECR0011B130CBSMsg.TOTAL_SEARCH_NUM }; rsltQueryCount.next(); mapMessage(rsltQueryCount, msgKeyList1, inMsg); // 総ページ数設定 int iTotal = Integer.parseInt(inMsg.getString(ECR0011B130CBSMsg.TOTAL_SEARCH_NUM)); int iDispNum = Integer.parseInt(inMsg.getString(ECR0011B130CBSMsg.DISPLAY_NUM)); int iSearchDivDisp = iTotal / iDispNum; int iRest = iTotal % iDispNum; // 割り切れない場合は総ページ数を増やす if (0 != iRest) { iSearchDivDisp++; } inMsg.set(ECR0011B130CBSMsg.TOTAL_PAGE_NUM, Integer.toString(iSearchDivDisp)); // 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了 if (0 == (Integer.parseInt(inMsg.getString(ECR0011B130CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(ECR0011B130CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了 int iDispPageNum = Integer.parseInt(inMsg.getString(ECR0011B130CBSMsg.DISPLAY_PAGE_NUM)); int iStartNum = iDispNum * (iDispPageNum - 1) + 1; int iEndNum = iDispNum * iDispPageNum; if (iSearchDivDisp < iDispPageNum) { inMsg.set(ECR0011B130CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA); return; } // SQL編集処理呼び出し HashMap editMap = editSQL(inMsg); //パラメータ設定リスト replaceList = (List)editMap.get("REPLACELIST"); // 編集後SQL StringBuffer edit_sql_Buff = (StringBuffer)editMap.get("SQL_BUFF"); // SQL文_基本部1 StringBuffer sql_Buff_1 = new StringBuffer(); sql_Buff_1.append(edit_sql_Buff) .append(" WHERE ") .append(" ROW_NUM BETWEEN ? AND ? "); // パラメータの設定(画面表示データ開始レコード行を指定) replaceList.add(iStartNum); // パラメータの設定(画面表示データ終了レコード行を指定) replaceList.add(iEndNum); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff_1.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff_1); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for (int idx = 0; idx < replaceList.size(); idx++ ) { CAANJDBCUtil.setParam(pstmt, idx + 1, replaceList.get(idx)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // ECR0011B130CBSMsgの明細にセットする項目 String[] msgKeyList2 = { ECR0011B130CBSMsg1List.QUE_BOX_NO_NM , ECR0011B130CBSMsg1List.TAIO_KIROK_NO , ECR0011B130CBSMsg1List.EASY_MEMO , ECR0011B130CBSMsg1List.TITLE , ECR0011B130CBSMsg1List.SVC_KEI_NO , ECR0011B130CBSMsg1List.CALLBK_KIBO_DTM , ECR0011B130CBSMsg1List.CALLBK_KIBO_TIME , ECR0011B130CBSMsg1List.CALLBK_SHITEI_TYPE_NM , ECR0011B130CBSMsg1List.PROSCST_NO_NM , ECR0011B130CBSMsg1List.TAIO_STA_DTM , ECR0011B130CBSMsg1List.TAIO_KIROK_STAT_NM , ECR0011B130CBSMsg1List.MSKM_NO // ANK-2921-00-00 ADD START , ECR0011B130CBSMsg1List.UPD_DTM // ANK-2921-00-00 ADD END }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList2,"eo.ejb.cbs.cbsmsg.ECR0011B130CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("ECR0011B130CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(ECR0011B130CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQueryCount != null){ rsltQueryCount.close(); } if(pstmtCount != null){ pstmtCount.close(); } if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(ECR0011B130CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } /** * 渡されたKEY情報を元にSQLを編集する。
* @param inMsg 入力値の格納されたCBSMsg
* @return 編集後のSQL */ public HashMap editSQL(CAANMsg inMsg) { HashMap parentMap = new HashMap(); //パラメータ設定リスト List replaceList = new ArrayList(); //運用日付 String opeDate = JCCModelCommon.getOpeDate(inMsg, null); StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT /*ECR0011B130*/ ") .append(" TBL2.QUE_BOX_NM, ") .append(" TBL2.TAIO_KIROK_NO, ") .append(" TBL2.EASY_MEMO, ") .append(" TBL2.TITLE, ") .append(" TBL2.SVC_KEI_NO, ") .append(" TBL2.CALLBK_KIBO_YMD, ") .append(" TBL2.CALLBK_KIBO_TIME, ") .append(" TBL2.CALLBK_NM, ") .append(" DECODE(TBL2.SVC_KEI_NO, NULL, ") .append(" (SELECT PCST_S_CSTNM.PROSCST_NM ") .append(" FROM CK_T_PROSCST PCST_S_CSTNM ") .append(" WHERE PCST_S_CSTNM.PROSCST_NO = TBL2.PROSCST_NO AND PCST_S_CSTNM.MK_FLG = '0' ), ") .append(" (SELECT ") .append(" (SELECT ") .append(" CASE WHEN CUST_S_CSTNM.MEMBER_SBT_CD IN ('11', '21', '30') THEN ") .append(" CUST_S_CSTNM.CONT_CUST_NM ") .append(" ELSE ") .append(" CASE WHEN (CUST_S_CSTNM.MMB_SBT_TOKUT_FLG = '0' AND CUST_S_CSTNM.EONETID_MI_IKO_FLG = '1') THEN ") .append(" CUST_S_CSTNM.CONT_CUST_NM ") .append(" ELSE ") .append(" CUST_S_CSTNM.CUST_NM ") .append(" END ") .append(" END ") .append(" FROM CK_T_CUST CUST_S_CSTNM ") .append(" WHERE CUST_S_CSTNM.KEISHA_TYPE_CD <> '5' ") .append(" AND (CUST_S_CSTNM.SYSID, CUST_S_CSTNM.RSV_APLY_YMD || CUST_S_CSTNM.GENE_ADD_DTM) = ( ") .append(" SELECT CUST_S_CSTNM_RCNT.SYSID, ") .append(" MAX(CUST_S_CSTNM_RCNT.RSV_APLY_YMD || CUST_S_CSTNM_RCNT.GENE_ADD_DTM) AS CUST_S_CSTNM_RCNT_MAX ") .append(" FROM CK_T_CUST CUST_S_CSTNM_RCNT ") .append(" WHERE CUST_S_CSTNM_RCNT.SYSID = SVCK_S_CSTNM.SYSID ") .append(" AND CUST_S_CSTNM_RCNT.RSV_APLY_YMD <= ? ") .append(" AND CUST_S_CSTNM_RCNT.RSV_APLY_CD = '2' ") .append(" AND CUST_S_CSTNM_RCNT.MK_FLG = '0' ") .append(" GROUP BY CUST_S_CSTNM_RCNT.SYSID) ") .append(" ) ") .append(" FROM KK_T_SVC_KEI SVCK_S_CSTNM ") .append(" WHERE SVCK_S_CSTNM.PRC_GRP_CD <> '99' ") .append(" AND (SVCK_S_CSTNM.SVC_KEI_NO, SVCK_S_CSTNM.RSV_APLY_YMD || SVCK_S_CSTNM.GENE_ADD_DTM) = ( ") .append(" SELECT SVCK_S_CSTNM_RCNT.SVC_KEI_NO, ") .append(" MAX(SVCK_S_CSTNM_RCNT.RSV_APLY_YMD || SVCK_S_CSTNM_RCNT.GENE_ADD_DTM) AS SVCK_S_CSTNM_RCNT_MAX ") .append(" FROM KK_T_SVC_KEI SVCK_S_CSTNM_RCNT ") .append(" WHERE SVCK_S_CSTNM_RCNT.SVC_KEI_NO = TBL2.SVC_KEI_NO ") .append(" AND SVCK_S_CSTNM_RCNT.RSV_APLY_YMD <= ? ") .append(" AND SVCK_S_CSTNM_RCNT.RSV_APLY_CD = '2' ") .append(" AND SVCK_S_CSTNM_RCNT.MK_FLG = '0' ") .append(" GROUP BY SVCK_S_CSTNM_RCNT.SVC_KEI_NO) ") .append(" ) ") .append(" ) AS PROSCST_NM, ") .append(" TBL2.TAIO_STA_DTM, ") .append(" TBL2.TAIO_STAT_NM, "); // パラメータの設定 replaceList.add(opeDate); replaceList.add(opeDate); /* 申込書番号 */ if ("MSKMSHO_NO".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { // ANK-2921-00-00 MOD START //sql_Buff.append(" TBL2.MSKMSHO_NO "); sql_Buff.append(" TBL2.MSKMSHO_NO, "); // ANK-2921-00-00 MOD END } else { sql_Buff.append(" (SELECT ") .append(" (SELECT MSDT_S_MSKMSNO.MSKMSHO_NO ") .append(" FROM KK_T_MSKM_DTL MSDT_S_MSKMSNO ") .append(" WHERE (MSDT_S_MSKMSNO.MSKM_DTL_NO, MSDT_S_MSKMSNO.GENE_ADD_DTM) = ( ") .append(" SELECT MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO, ") .append(" MAX(MSDT_S_MSKMSNO_RCNT.GENE_ADD_DTM) ") .append(" FROM KK_T_MSKM_DTL MSDT_S_MSKMSNO_RCNT ") .append(" WHERE MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO = SVCK_S_MSKMSNO.MSKM_DTL_NO ") .append(" AND MSDT_S_MSKMSNO_RCNT.MK_FLG = '0' ") .append(" GROUP BY MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO) ") .append(" ) ") .append(" FROM KK_T_SVC_KEI SVCK_S_MSKMSNO ") .append(" WHERE ") .append(" SVCK_S_MSKMSNO.PRC_GRP_CD <> '99' ") .append(" AND (SVCK_S_MSKMSNO.SVC_KEI_NO, SVCK_S_MSKMSNO.RSV_APLY_YMD || SVCK_S_MSKMSNO.GENE_ADD_DTM) = ( ") .append(" SELECT SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO, ") .append(" MIN(SVCK_S_MSKMSNO_RCNT.RSV_APLY_YMD || SVCK_S_MSKMSNO_RCNT.GENE_ADD_DTM) AS SVCK_S_MSKMSNO_RCNT_MIN ") .append(" FROM KK_T_SVC_KEI SVCK_S_MSKMSNO_RCNT ") .append(" WHERE SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO = TBL2.SVC_KEI_NO ") .append(" AND SVCK_S_MSKMSNO_RCNT.MK_FLG = '0' ") .append(" GROUP BY SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO) ") // ANK-2921-00-00 MOD START //.append(" ) AS MSKMSHO_NO "); .append(" ) AS MSKMSHO_NO, "); // ANK-2921-00-00 MOD END } // ANK-2921-00-00 ADD START sql_Buff.append(" TBL2.UPD_DTM "); // ANK-2921-00-00 ADD END sql_Buff.append(" FROM ( ") .append(" SELECT ") .append(" TBL.QUE_BOX_NM, ") .append(" TBL.WKKBT_ORG_CD, ") .append(" TBL.TAIO_KIROK_NO, ") .append(" TBL.EASY_MEMO, ") .append(" TBL.TITLE, ") .append(" TBL.SVC_KEI_NO, ") .append(" TBL.CALLBK_KIBO_YMD, ") .append(" TBL.CALLBK_KIBO_TIME, ") .append(" TBL.CALLBK_NM, ") .append(" TBL.PROSCST_NO, ") .append(" TBL.TAIO_STA_DTM, ") .append(" TBL.TAIO_STAT_NM, "); /* 申込書番号 */ if ("MSKMSHO_NO".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" TBL.MSKMSHO_NO, "); } // ANK-2921-00-00 ADD START sql_Buff.append(" TBL.UPD_DTM, "); // ANK-2921-00-00 ADD END sql_Buff.append(" ROWNUM AS ROW_NUM ") .append(" FROM ( ") .append(" SELECT ") .append(" (SELECT QUEB.QUE_BOX_NM ") .append(" FROM CR_T_QUE_BOX QUEB ") .append(" WHERE QUEB.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" ) AS QUE_BOX_NM, ") .append(" (SELECT QUEB.WKKBT_ORG_CD ") .append(" FROM CR_T_QUE_BOX QUEB ") .append(" WHERE QUEB.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" ) AS WKKBT_ORG_CD, ") .append(" TKRK.TAIO_KIROK_NO, ") .append(" TKRK.EASY_MEMO, ") .append(" TKRK.TITLE, ") .append(" TKRK.SVC_KEI_NO, ") .append(" TKRK.CALLBK_KIBO_YMD, ") .append(" TKRK.CALLBK_KIBO_TIME, ") .append(" (SELECT CD01.CD_DIV_ALI ") .append(" FROM ZM_M_CD_NM_KANRI CD01 ") .append(" WHERE CD01.CD_DIV = TKRK.CALLBK_SHITEI_TYPE_CD ") .append(" AND CD01.CD_SBT_CD = 'CD00457' ") .append(" AND CD01.CD_TSTAYMD <= SUBSTR(TKRK.UPD_DTM, 1, 8) ") .append(" AND CD01.CD_TENDYMD >= SUBSTR(TKRK.UPD_DTM, 1, 8) ") .append(" ) AS CALLBK_NM, ") .append(" TKRK.PROSCST_NO, ") .append(" TKRK.TAIO_STA_DTM, ") .append(" (SELECT CD02.CD_DIV_ALI ") .append(" FROM ZM_M_CD_NM_KANRI CD02 ") .append(" WHERE CD02.CD_DIV = TKRK.TAIO_KIROK_STAT ") .append(" AND CD02.CD_SBT_CD = 'CD00230' ") .append(" AND CD02.CD_TSTAYMD <= SUBSTR(TKRK.UPD_DTM, 1, 8) ") .append(" AND CD02.CD_TENDYMD >= SUBSTR(TKRK.UPD_DTM, 1, 8) ") .append(" ) AS TAIO_STAT_NM "); /* お客様カナ名 */ if ("PROSCST_KANA".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" , DECODE(TKRK.SVC_KEI_NO, NULL, ") .append(" (SELECT PCST_S_CSTKN.PROSCST_KANA ") .append(" FROM CK_T_PROSCST PCST_S_CSTKN ") .append(" WHERE PCST_S_CSTKN.PROSCST_NO = TKRK.PROSCST_NO AND PCST_S_CSTKN.MK_FLG = '0' ), ") .append(" (SELECT ") .append(" (SELECT ") .append(" CASE WHEN CUST_S_CSTKN.MEMBER_SBT_CD IN ('11', '21', '30') THEN ") .append(" CUST_S_CSTKN.CONT_CUST_KANA ") .append(" ELSE ") .append(" CASE WHEN (CUST_S_CSTKN.MMB_SBT_TOKUT_FLG = '0' AND CUST_S_CSTKN.EONETID_MI_IKO_FLG = '1') THEN ") .append(" CUST_S_CSTKN.CONT_CUST_KANA ") .append(" ELSE ") .append(" CUST_S_CSTKN.CUST_KANA ") .append(" END ") .append(" END ") .append(" FROM CK_T_CUST CUST_S_CSTKN ") .append(" WHERE CUST_S_CSTKN.SYSID = SVCK_S_CSTKN.SYSID ") .append(" AND CUST_S_CSTKN.KEISHA_TYPE_CD <> '5' ") .append(" AND (CUST_S_CSTKN.SYSID, CUST_S_CSTKN.RSV_APLY_YMD || CUST_S_CSTKN.GENE_ADD_DTM) = ( ") .append(" SELECT CUST_S_CSTKN_RCNT.SYSID, ") .append(" MAX(CUST_S_CSTKN_RCNT.RSV_APLY_YMD || CUST_S_CSTKN_RCNT.GENE_ADD_DTM) AS CUST_S_CSTKN_RCNT_MAX ") .append(" FROM CK_T_CUST CUST_S_CSTKN_RCNT ") .append(" WHERE CUST_S_CSTKN_RCNT.SYSID = CUST_S_CSTKN.SYSID ") .append(" AND CUST_S_CSTKN_RCNT.RSV_APLY_YMD <= ? ") .append(" AND CUST_S_CSTKN_RCNT.RSV_APLY_CD = '2' ") .append(" AND CUST_S_CSTKN_RCNT.MK_FLG = '0' ") .append(" GROUP BY CUST_S_CSTKN_RCNT.SYSID) ") .append(" ) ") .append(" FROM KK_T_SVC_KEI SVCK_S_CSTKN ") .append(" WHERE SVCK_S_CSTKN.SVC_KEI_NO = TKRK.SVC_KEI_NO ") .append(" AND SVCK_S_CSTKN.PRC_GRP_CD <> '99' ") .append(" AND (SVCK_S_CSTKN.SVC_KEI_NO, SVCK_S_CSTKN.RSV_APLY_YMD || SVCK_S_CSTKN.GENE_ADD_DTM) = ( ") .append(" SELECT SVCK_S_CSTKN_RCNT.SVC_KEI_NO, ") .append(" MAX(SVCK_S_CSTKN_RCNT.RSV_APLY_YMD || SVCK_S_CSTKN_RCNT.GENE_ADD_DTM) AS SVCK_S_CSTKN_RCNT_MAX ") .append(" FROM KK_T_SVC_KEI SVCK_S_CSTKN_RCNT ") .append(" WHERE SVCK_S_CSTKN_RCNT.SVC_KEI_NO = SVCK_S_CSTKN.SVC_KEI_NO ") .append(" AND SVCK_S_CSTKN_RCNT.RSV_APLY_YMD <= ? ") .append(" AND SVCK_S_CSTKN_RCNT.RSV_APLY_CD = '2' ") .append(" AND SVCK_S_CSTKN_RCNT.MK_FLG = '0' ") .append(" GROUP BY SVCK_S_CSTKN_RCNT.SVC_KEI_NO) ") .append(" ) ") .append(" ) AS PROSCST_KANA "); // パラメータの設定 replaceList.add(opeDate); replaceList.add(opeDate); } /* 申込書番号 */ if ("MSKMSHO_NO".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" , (SELECT ") .append(" (SELECT MSDT_S_MSKMSNO.MSKMSHO_NO ") .append(" FROM KK_T_MSKM_DTL MSDT_S_MSKMSNO ") .append(" WHERE (MSDT_S_MSKMSNO.MSKM_DTL_NO, MSDT_S_MSKMSNO.GENE_ADD_DTM) = ( ") .append(" SELECT MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO, ") .append(" MAX(MSDT_S_MSKMSNO_RCNT.GENE_ADD_DTM) ") .append(" FROM KK_T_MSKM_DTL MSDT_S_MSKMSNO_RCNT ") .append(" WHERE MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO = MSDT_S_MSKMSNO.MSKM_DTL_NO ") .append(" AND MSDT_S_MSKMSNO_RCNT.MK_FLG = '0' ") .append(" GROUP BY MSDT_S_MSKMSNO_RCNT.MSKM_DTL_NO) ") .append(" AND MSDT_S_MSKMSNO.MSKM_DTL_NO = SVCK_S_MSKMSNO.MSKM_DTL_NO ") .append(" ) ") .append(" FROM KK_T_SVC_KEI SVCK_S_MSKMSNO ") .append(" WHERE SVCK_S_MSKMSNO.SVC_KEI_NO = TKRK.SVC_KEI_NO ") .append(" AND SVCK_S_MSKMSNO.PRC_GRP_CD <> '99' ") .append(" AND (SVCK_S_MSKMSNO.SVC_KEI_NO, SVCK_S_MSKMSNO.RSV_APLY_YMD || SVCK_S_MSKMSNO.GENE_ADD_DTM) = ( ") .append(" SELECT SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO, ") .append(" MIN(SVCK_S_MSKMSNO_RCNT.RSV_APLY_YMD || SVCK_S_MSKMSNO_RCNT.GENE_ADD_DTM) AS SVCK_S_MSKMSNO_RCNT_MIN ") .append(" FROM KK_T_SVC_KEI SVCK_S_MSKMSNO_RCNT ") .append(" WHERE SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO = SVCK_S_MSKMSNO.SVC_KEI_NO ") .append(" AND SVCK_S_MSKMSNO_RCNT.MK_FLG = '0' ") .append(" GROUP BY SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO) ") .append(" ) AS MSKMSHO_NO "); } // ANK-2921-00-00 ADD START sql_Buff.append(" , TKRK.UPD_DTM "); // ANK-2921-00-00 ADD END sql_Buff.append(" FROM "); // KEY_QUE_BOX_NOが指定されていない場合 if ((inMsg.isNull(ECR0011B130CBSMsg.KEY_QUE_BOX_NO))) { sql_Buff.append(getCondition1(inMsg, replaceList)); } // KEY_QUE_BOX_NOが指定されている場合 else { sql_Buff.append(getCondition2(inMsg, replaceList)); } sql_Buff.append(" ORDER BY "); String sortType = null; // SQL文_個別部1 if ("1".equals(inMsg.getObject(ECR0011B130CBSMsg.FUNC_CODE).toString())) { sortType = " ASC "; } else { sortType = " DESC "; } /* 対応記録番号 */ if ("TAIO_KIROK_NO".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" TAIO_KIROK_NO ").append(sortType); } /* コールバック希望日時 */ else if ("CALLBK_KIBO_YMD".equals(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" CALLBK_KIBO_YMD ").append(sortType) .append(" , CALLBK_KIBO_TIME ").append(sortType) .append(" , TAIO_KIROK_NO ASC "); } /* その他項目 */ else { sql_Buff.append(inMsg.getObject(ECR0011B130CBSMsg.KEY_SORT_SHITEI_KMK)).append(sortType) .append(", TAIO_KIROK_NO ASC "); } sql_Buff.append(" ) TBL ") .append(" ) TBL2 "); parentMap.put("SQL_BUFF", sql_Buff); parentMap.put("REPLACELIST", replaceList); return parentMap; } /** * キューBOX番号指定なしの場合のfrom句、where句の編集を行う。
*
* @param inMsg 入力値の格納されたCBSMsg
* @param replaceList パラメータ設定リスト
* @return StringBuffer */ private StringBuffer getCondition1(CAANMsg inMsg, List replaceList){ StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" CR_T_TAIO_KIROK TKRK, ") .append(" CR_M_QUE_MEMBER QUEM, ") .append(" CR_T_QUE_BOX QUEB ") .append(" WHERE ") .append(" TKRK.TOIAWASE_STAT_CD = '102' ") .append(" AND TKRK.MK_FLG = '0' ") .append(" AND QUEB.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" AND QUEM.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" AND QUEM.USER_ID = ? ") .append(" AND QUEM.MK_FLG = '0' ") .append(" AND QUEB.QUE_BOX_NO = QUEM.QUE_BOX_NO ") .append(" AND QUEB.WKKBT_ORG_CD = ? ") .append(" AND QUEB.MK_FLG = '0' "); replaceList.add(inMsg.getObject(ECR0011B130CBSMsg.KEY_USER_ID)); replaceList.add(inMsg.getObject(ECR0011B130CBSMsg.KEY_WKKBT_ORG_CD)); return sql_Buff; } /** * キューBOX番号指定ありの場合のfrom句、where句の編集を行う。
*
* @param inMsg 入力値の格納されたCBSMsg
* @param replaceList パラメータ設定リスト
* @return StringBuffer */ private StringBuffer getCondition2(CAANMsg inMsg, List replaceList){ StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" CR_T_TAIO_KIROK TKRK ") .append(" WHERE ") .append(" TKRK.QUE_BOX_NO = ? ") .append(" AND TKRK.TOIAWASE_STAT_CD = '102' ") .append(" AND TKRK.MK_FLG = '0' ") .append(" AND EXISTS (SELECT 'X' ") .append(" FROM CR_T_QUE_BOX QUEB ") .append(" WHERE QUEB.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" AND QUEB.WKKBT_ORG_CD = ? ") .append(" AND QUEB.MK_FLG = '0' ) "); replaceList.add(inMsg.getObject(ECR0011B130CBSMsg.KEY_QUE_BOX_NO)); replaceList.add(inMsg.getObject(ECR0011B130CBSMsg.KEY_WKKBT_ORG_CD)); return sql_Buff; } }