/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECR0011B100TPDA * ソースファイル名：JSYejbECR0011B100TPDA.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 受付番号の検索条件を変更 * ｖ29.00.00 2017/03/07 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.ejb.cbm.entity.CR0011ETMsg; import eo.ejb.cbs.cbsmsg.ECR0011B100CBSMsg; import eo.ejb.cbs.cbsmsg.ECR0011B100CBSMsg1List; import eo.ejb.common.JCCModelCommon; /** * * テンプレートDBアクセス部品　ECR0011B100_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECR0011B100TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECR0011B100TPDA() { } /** * ECR0011B100_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); // SQL編集処理呼び出し HashMap editMap = editSQL(inMsg); //パラメータ設定リスト List replaceList = (List)editMap.get("REPLACELIST"); // 編集後SQL StringBuffer edit_sql_Buff = (StringBuffer)editMap.get("SQL_BUFF"); StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .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(" , TBL2.PROSCST_NM ") .append(" , TBL2.PROSCST_KANA ") .append(" , TBL2.TAIO_STA_DTM ") .append(" , TBL2.TAIO_STAT_NM ") .append(" , TBL2.MSKMSHO_NO ") // ANK-2921-00-00 ADD START .append(" , TBL2.UPD_DTM ") // ANK-2921-00-00 ADD END .append(" FROM ") .append(" ( ") .append(edit_sql_Buff) .append(" ) TBL2 "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for (int idx = 0; idx < replaceList.size(); idx++ ) { CAANJDBCUtil.setParam(pstmt, idx + 1, replaceList.get(idx)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // ECR0011B100CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECR0011B100CBSMsg1List.QUE_BOX_NO_NM , ECR0011B100CBSMsg1List.TAIO_KIROK_NO , ECR0011B100CBSMsg1List.EASY_MEMO , ECR0011B100CBSMsg1List.TITLE , ECR0011B100CBSMsg1List.SVC_KEI_NO , ECR0011B100CBSMsg1List.CALLBK_KIBO_DTM , ECR0011B100CBSMsg1List.CALLBK_KIBO_TIME , ECR0011B100CBSMsg1List.CALLBK_SHITEI_TYPE_NM , ECR0011B100CBSMsg1List.PROSCST_NO_NM , ECR0011B100CBSMsg1List.PROSCST_NO_NM_KANA , ECR0011B100CBSMsg1List.TAIO_STA_DTM , ECR0011B100CBSMsg1List.TAIO_KIROK_STAT_NM , ECR0011B100CBSMsg1List.MSKM_NO // ANK-2921-00-00 ADD START , ECR0011B100CBSMsg1List.UPD_DTM // ANK-2921-00-00 ADD END }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECR0011B100CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("ECR0011B100CBSMsg1List", outMsg1); // 総検索件数の設定 inMsg.set(ECR0011B100CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(outMsg1.length)); } catch(SQLException e) { inMsg.set(ECR0011B100CBSMsg.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(ECR0011B100CBSMsg.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 ") .append(" TBL.QUE_BOX_NM "); // KEY_WKKBT_ORG_CDが入力されている場合 if (!(inMsg.isNull(ECR0011B100CBSMsg.KEY_WKKBT_ORG_CD))) { sql_Buff.append(" , TBL.WKKBT_ORG_CD "); } sql_Buff.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_NM ") .append(" , TBL.PROSCST_KANA ") .append(" , TBL.TAIO_STA_DTM ") .append(" , TBL.TAIO_STAT_NM ") .append(" , TBL.MSKMSHO_NO ") // ANK-2921-00-00 ADD START .append(" , TBL.UPD_DTM ") // ANK-2921-00-00 ADD END .append(" FROM ") .append(" ( ") .append(" SELECT ") .append(" (SELECT ") .append(" QUEB.QUE_BOX_NM ") .append(" FROM ") .append(" CR_T_QUE_BOX QUEB ") .append(" WHERE ") .append(" QUEB.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" ) AS QUE_BOX_NM ") .append(" , (SELECT ") .append(" QUEB.WKKBT_ORG_CD ") .append(" FROM ") .append(" CR_T_QUE_BOX QUEB ") .append(" WHERE ") .append(" 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(" , ( ") .append(" SELECT ") .append(" CD01.CD_DIV_ALI ") .append(" FROM ") .append(" ZM_M_CD_NM_KANRI CD01 ") .append(" WHERE ") .append(" 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(" , DECODE(TKRK.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 = TKRK.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.SYSID = SVCK_S_CSTNM.SYSID ") .append(" AND 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, 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 = CUST_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.SVC_KEI_NO = TKRK.SVC_KEI_NO ") .append(" AND 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, 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 = SVCK_S_CSTNM.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(" , 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, 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, 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 ") .append(" , TKRK.TAIO_STA_DTM ") .append(" , ( ") .append(" SELECT ") .append(" CD02.CD_DIV_ALI ") .append(" FROM ") .append(" ZM_M_CD_NM_KANRI CD02 ") .append(" WHERE ") .append(" 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 ") .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.GENE_ADD_DTM) = ( ") .append(" SELECT SVCK_S_MSKMSNO_RCNT.SVC_KEI_NO, ") .append(" MIN(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 .append(" , UPD_DTM ") // ANK-2921-00-00 ADD END .append(" FROM ") .append(" CR_T_TAIO_KIROK TKRK ") .append(" WHERE "); replaceList.add(opeDate); replaceList.add(opeDate); replaceList.add(opeDate); replaceList.add(opeDate); // KEY_QUE_BOX_NOが指定されていない場合 if ((inMsg.isNull(ECR0011B100CBSMsg.KEY_QUE_BOX_NO))) { sql_Buff.append(" EXISTS ( ") .append(" SELECT ") .append(" 'X' ") .append(" FROM ") .append(" CR_M_QUE_MEMBER QUEM ") .append(" WHERE ") .append(" QUEM.USER_ID = ? ") .append(" AND QUEM.QUE_BOX_NO = TKRK.QUE_BOX_NO ") .append(" AND QUEM.MK_FLG = '0' ") .append(" ) AND "); replaceList.add(inMsg.getObject(ECR0011B100CBSMsg.KEY_TAIO_USER_ID)); } // KEY_QUE_BOX_NOが指定されている場合 else { sql_Buff.append(" TKRK.QUE_BOX_NO = ? AND "); replaceList.add(inMsg.getObject(ECR0011B100CBSMsg.KEY_QUE_BOX_NO)); } sql_Buff.append(" TKRK.TOIAWASE_STAT_CD = '102' ") .append(" AND TKRK.MK_FLG = '0' ") .append(" ORDER BY "); replaceList.add(inMsg.getObject(ECR0011B100CBSMsg.KEY_WKKBT_ORG_CD)); String sortType = null; // SQL文_個別部1 if ("1".equals(inMsg.getObject(ECR0011B100CBSMsg.FUNC_CODE).toString())) { sortType = " ASC "; } else { sortType = " DESC "; } /* 対応記録番号 */ if ("TAIO_KIROK_NO".equals(inMsg.getObject(ECR0011B100CBSMsg.KEY_SORT_SHITEI_KMK))) { sql_Buff.append(" TAIO_KIROK_NO ").append(sortType); } /* コールバック希望日時 */ else if ("CALLBK_KIBO_YMD".equals(inMsg.getObject(ECR0011B100CBSMsg.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(ECR0011B100CBSMsg.KEY_SORT_SHITEI_KMK)).append(sortType) .append(", TAIO_KIROK_NO ASC "); } sql_Buff.append(" ) TBL ") .append(" WHERE TBL.WKKBT_ORG_CD = ? "); parentMap.put("SQL_BUFF", sql_Buff); parentMap.put("REPLACELIST", replaceList); return parentMap; } }