/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECH0191B010TPDA * ソースファイル名：JSYejbECH0191B010TPDA.java * 作成者 ：EKek0077 * 日付 ：2011年10月24日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ5.00.00 2013/07/26 FJ)河井 【TG1-2013-0000662】マスタ参照基準日対応 * ｖ32.00.00 2017/05/26 FJ)河邊 【OM-2017-0000488】オープンカーソルエラー * ********************************************************************************/ 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.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.JACStrConst; import eo.common.constant.JPCModelConstant; import eo.ejb.cbm.entity.CH0191ETMsg; import eo.ejb.cbm.entity.CH0501ETMsg; import eo.ejb.cbs.cbsmsg.ECH0191B010CBSMsg; import eo.ejb.cbs.cbsmsg.ECH0191B010CBSMsg1List; import eo.ejb.common.JCHModelConst; import eo.ejb.common.JPCModelCommon; /** * * テンプレートDBアクセス部品　ECH0191B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECH0191B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECH0191B010TPDA() { } /** * ECH0191B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null; // リザルトセット ResultSet rsltQuery = null; // ページング用 int iTotalSearchNum = 0; // 総検索数 int iTotalPageNum = 0; // 総ページ数 int iDisplayNum = 0; // 表示件数 int iMaxSearchNum = 0; // 最大検索件数 int iDisplayPageNum = 0; // 表示ページ番号 int iArrayCopyStart = 0; // 取得範囲先頭 int iArrayCopyCount = 0; // 取得件数 // パラメータ設定リスト List replaceListCnt = new ArrayList(); /******************** * SQL文の作成 ********************/ try{ // 運用日付 String opeDate = (String)JPCModelCommon.getOpeDate(inMsg, inContext, null); //コネクション取得 con1 = JSYejbConnection.getConnection(CH0191ETMsg.getTableName()); // -------------------------------------------------- // // カウント取得 // -------------------------------------------------- // StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" COUNT(CH0191.KNK_NO) AS CNT "); // 条件1 追加 StringBuilder condition1 = getCondition1(inMsg, replaceListCnt); sql_Buff.append(condition1); //prepareStatementにSQL文をセット pstmt1 = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for (int idx = 0; idx < replaceListCnt.size(); idx++ ) { CAANJDBCUtil.setParam(pstmt1, idx+1, replaceListCnt.get(idx)); } // ResultSetの取得 rsltQuery = pstmt1.executeQuery(); // ECH0191B010CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECH0191B010CBSMsg.TOTAL_SEARCH_NUM }; rsltQuery.next(); mapMessage(rsltQuery, msgKeyList1, inMsg); // パラメータの設定 // パラメータの最大検索件数がnullでない場合、最大検索件数の設定 if (!inMsg.isNull(ECH0191B010CBSMsg.MAX_SEARCH_NUM)) { iMaxSearchNum = Integer.parseInt(inMsg.getString(ECH0191B010CBSMsg.MAX_SEARCH_NUM)); } // パラメータの表示件数がnullでない場合、表示件数の設定 if (!inMsg.isNull(ECH0191B010CBSMsg.DISPLAY_NUM)) { iDisplayNum = Integer.parseInt(inMsg.getString(ECH0191B010CBSMsg.DISPLAY_NUM)); } // パラメータの表示ページ番号がnullでない場合、表示ページ番号の設定 if (!inMsg.isNull(ECH0191B010CBSMsg.DISPLAY_PAGE_NUM)) { iDisplayPageNum = Integer.parseInt(inMsg.getString(ECH0191B010CBSMsg.DISPLAY_PAGE_NUM)); } // 総検索件数の設定 iTotalSearchNum = Integer.parseInt(inMsg.getString(ECH0191B010CBSMsg.TOTAL_SEARCH_NUM)); // 総ページ数の設定 // 表示件数が0の場合 if (0 == iDisplayNum) { iTotalPageNum = 1; } // 検索件数/表示件数の余りがない場合 else if (0 == iTotalSearchNum % iDisplayNum) { iTotalPageNum = iTotalSearchNum / iDisplayNum; } else { iTotalPageNum = iTotalSearchNum / iDisplayNum + 1; } // 総検索数と総ページ数の設定 inMsg.set(ECH0191B010CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(iTotalSearchNum)); inMsg.set(ECH0191B010CBSMsg.TOTAL_PAGE_NUM, String.valueOf(iTotalPageNum)); // 検索エラーの設定 // 総検索件数が0の場合 if(0 == iTotalSearchNum) { inMsg.set(ECH0191B010CBSMsg.SEARCH_ERR_FLG , "1"); return; } // 総検索件数が最大検索件数より大きい場合(最大検索件数超え) else if(0 != iMaxSearchNum && iTotalSearchNum > iMaxSearchNum) { inMsg.set(ECH0191B010CBSMsg.SEARCH_ERR_FLG , "2"); return; } // 表示ページに該当するデータがない場合 else if(iTotalPageNum < iDisplayPageNum) { inMsg.set(ECH0191B010CBSMsg.SEARCH_ERR_FLG , "3"); return; } // 請求年月の月末日取得 String endYmd = getUseEnd(inMsg, inContext, opeDate); // -------------------------------------------------- // // データ取得 // -------------------------------------------------- // sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" CH0191.KNK_NO ") .append(" ,CH0191.SEIKY_KEI_NO ") .append(" ,(SELECT KK0491.SHS_KANA ") .append(" FROM KK_T_SEIKY_KEI KK0491 ") .append(" WHERE KK0491.SEIKY_KEI_NO = CH0191.SEIKY_KEI_NO ") .append(" AND KK0491.RSV_APLY_YMD || KK0491.GENE_ADD_DTM = ") .append(" (SELECT MAX(KK0491.RSV_APLY_YMD || KK0491_GENE.GENE_ADD_DTM) AS KK0491_MAX ") .append(" FROM KK_T_SEIKY_KEI KK0491_GENE ") .append(" WHERE KK0491_GENE.SEIKY_KEI_NO = KK0491.SEIKY_KEI_NO ") .append(" AND KK0491_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0491_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0491_GENE.MK_FLG ='0' ) ") .append(" ) AS SHS_KANA ") .append(" ,CH0191.KNK_PRC_KMK_CD ") .append(" ,(SELECT CH0391.PRC_KMK_NM ") .append(" FROM CH_M_PRC_KMK_OPUT_NM CH0391 ") .append(" WHERE CH0391.PRC_KMK_NM_SBT_CD = '1' ") .append(" AND CH0391.PRC_GRP_CD =' ' ") .append(" AND CH0391.PCRS_CD =' ' ") .append(" AND CH0391.PRC_SVC_CD =' ' ") .append(" AND CH0391.PRC_KMK_CD = CH0191.KNK_PRC_KMK_CD ") .append(" AND CH0391.PRC_KMK_OPUT_NM_TSTAYMD = ") .append(" ( SELECT MAX(CH0391_GENE.PRC_KMK_OPUT_NM_TSTAYMD) AS CH0391_MAX ") .append(" FROM CH_M_PRC_KMK_OPUT_NM CH0391_GENE ") .append(" WHERE CH0391_GENE.PRC_KMK_NM_SBT_CD = CH0391.PRC_KMK_NM_SBT_CD ") .append(" AND CH0391_GENE.PRC_GRP_CD = CH0391.PRC_GRP_CD ") .append(" AND CH0391_GENE.PCRS_CD = CH0391.PCRS_CD ") .append(" AND CH0391_GENE.PRC_SVC_CD = CH0391.PRC_SVC_CD ") .append(" AND CH0391_GENE.PRC_KMK_CD = CH0391.PRC_KMK_CD ") .append(" AND CH0391_GENE.PRC_KMK_OPUT_NM_TSTAYMD <= ? ") .append(" AND CH0391_GENE.MK_FLG = '0' ) ") .append(" AND ROWNUM = 1 ") .append(" ) AS KNK_PRC_KMK_NM ") .append(" ,( ") .append(" SELECT ") .append(" ( ") .append(" SELECT ") .append(" ZM0321.WORK_PARAM_SETTE_VALUE ") .append(" FROM ") .append(" ZM_M_WORK_PARAM_KNRI ZM0321 ") .append(" WHERE ") .append(" ZM0321.WORK_PARAM_ID = 'CH_WKS_'|| CH0401.WORK_KINO_SKBT_CD ") .append(" AND ZM0321.MK_FLG = '0' ") .append(" ) ") .append(" FROM ") .append(" CH_M_PRC_KMK_CS_CHGE CH0401 ") .append(" WHERE ") .append(" CH0401.PRC_KMK_CD = CH0191.KNK_PRC_KMK_CD AND ") .append(" CH0401.SYS_CD = 'CH' AND ") .append(" CH0401.WORK_KINO_SKBT_CD LIKE 'KNKSTAT%' AND ") .append(" CH0401.CHSHT_CHG_CD = ? AND ") .append(" CH0401.PRC_KMK_CS_CHGE_TSTAYMD <= ? AND ") .append(" CH0401.PRC_KMK_CS_CHGE_TENDYMD >= ? AND ") .append(" CH0401.MK_FLG = '0'") .append(" ) AS KNK_PRC_KMK_CD_DIV") .append(" ,CH0191.KNK_AMNT ") .append(" ,CH0191.SSN_WAY_CD ") .append(" ,(SELECT ZM0171.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171 ") .append(" WHERE ZM0171.CD_SBT_CD = 'CD00915' ") .append(" AND ZM0171.CD_DIV = CH0191.SSN_WAY_CD ") .append(" AND ? BETWEEN ZM0171.CD_TSTAYMD AND ZM0171.CD_TENDYMD ") .append(" AND ZM0171.MK_FLG = '0' ") .append(" ) AS SSN_WAY_CD_NM ") .append(" ,(SELECT ZM0171.CD_DIV_ALI ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171 ") .append(" WHERE ZM0171.CD_SBT_CD = 'CD00915' ") .append(" AND ZM0171.CD_DIV = CH0191.SSN_WAY_CD ") .append(" AND ? BETWEEN ZM0171.CD_TSTAYMD AND ZM0171.CD_TENDYMD ") .append(" AND ZM0171.MK_FLG = '0' ") .append(" ) AS SSN_WAY_CD_ALI ") .append(" ,CH0191.NYUKIN_NO ") .append(" ,CH0191.TOGO_KNK_NO AS SK_KNK_NO ") .append(" ,CH0191.IDOMOTO_KNK_NO AS MT_KNK_NO ") .append(" ,CH0191.KNK_IDO_YMD ") .append(" ,CH0191.KNK_MOVE_CD ") .append(" ,(SELECT ZM0171.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171 ") .append(" WHERE ZM0171.CD_SBT_CD = 'CD00904' ") .append(" AND ZM0171.CD_DIV = CH0191.KNK_MOVE_CD ") .append(" AND ? BETWEEN ZM0171.CD_TSTAYMD AND ZM0171.CD_TENDYMD ") .append(" AND ZM0171.MK_FLG = '0' ") .append(" ) AS KNK_MOVE_CD_NM ") .append(" ,(SELECT ZM0171.CD_DIV_ALI ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171 ") .append(" WHERE ZM0171.CD_SBT_CD = 'CD00904' ") .append(" AND ZM0171.CD_DIV = CH0191.KNK_MOVE_CD ") .append(" AND ? BETWEEN ZM0171.CD_TSTAYMD AND ZM0171.CD_TENDYMD ") .append(" AND ZM0171.MK_FLG = '0' ") .append(" ) AS KNK_MOVE_CD_ALI ") .append(" ,CH0191.RIREKI_DATA_FLG ") .append(" ,CH0191.UPD_DTM ") .append(" ,CH0191.ADD_OPEACNT ") .append(" ,(SELECT ZM0051.USER_NM ") .append(" FROM ZM_M_USER ZM0051 ") .append(" WHERE ZM0051.USER_ID = CH0191.ADD_OPEACNT ") .append(" AND ZM0051.MK_FLG = '0' ") .append(" ) AS ADD_OPEACNT_NM "); // from句、where句のパラメータはreplaceListCntにセット済であるため、リストに挿入する int insIndex = 0; replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, endYmd); replaceListCnt.add(insIndex++, JACStrConst.CHSHT_CHG_CD_1); replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, opeDate); replaceListCnt.add(insIndex++, opeDate); // 条件1 追加 sql_Buff.append(condition1); // ソート条件 追加 sql_Buff.append(getSortCondition(inMsg)); //prepareStatementにSQL文をセット pstmt2 = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for (int idx = 0; idx < replaceListCnt.size(); idx++ ) { CAANJDBCUtil.setParam(pstmt2, idx+1, replaceListCnt.get(idx)); } // OM-2017-0000488 2017/05/26 ADD START if(rsltQuery != null){ rsltQuery.close(); } // OM-2017-0000488 2017/05/26 ADD END // ResultSetの取得 rsltQuery = pstmt2.executeQuery(); // ECH0191B010CBSMsgの明細にセットする項目 String[] msgKeyList2 = { ECH0191B010CBSMsg1List.KNK_NO , ECH0191B010CBSMsg1List.SEIKY_KEI_NO , ECH0191B010CBSMsg1List.SHS_KANA , ECH0191B010CBSMsg1List.KNK_PRC_KMK_CD , ECH0191B010CBSMsg1List.KNK_PRC_KMK_NM , ECH0191B010CBSMsg1List.KNK_PRC_KMK_CD_DIV , ECH0191B010CBSMsg1List.KNK_AMNT , ECH0191B010CBSMsg1List.SSN_WAY_CD , ECH0191B010CBSMsg1List.SSN_WAY_CD_NM , ECH0191B010CBSMsg1List.SSN_WAY_CD_ALI , ECH0191B010CBSMsg1List.NYUKIN_NO , ECH0191B010CBSMsg1List.SK_KNK_NO , ECH0191B010CBSMsg1List.MT_KNK_NO , ECH0191B010CBSMsg1List.KNK_IDO_YMD , ECH0191B010CBSMsg1List.KNK_MOVE_CD , ECH0191B010CBSMsg1List.KNK_MOVE_CD_NM , ECH0191B010CBSMsg1List.KNK_MOVE_CD_ALI , ECH0191B010CBSMsg1List.RIREKI_DATA_FLG , ECH0191B010CBSMsg1List.UPD_DTM , ECH0191B010CBSMsg1List.ADD_OPEACNT , ECH0191B010CBSMsg1List.ADD_OPEACNT_NM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList2,"eo.ejb.cbs.cbsmsg.ECH0191B010CBSMsg1List",0); // inMsg(CBSMsg)に取得した明細をセット inMsg.set("ECH0191B010CBSMsg1List", outMsg1); // 手修正箇所S // ページング関連処理 CAANMsg[] outMsg2 = null; // 対象データの取得 if(null == inMsg.getString(ECH0191B010CBSMsg.SEARCH_ERR_FLG)) { // 取得範囲の設定 // 取得範囲先頭の設定 iArrayCopyStart = iDisplayNum * (iDisplayPageNum - 1); // 取得範囲末尾の設定 // 表示件数が指定されていない場合 if (0 == iDisplayNum) { // 取得件数に総検索件数を設定 iArrayCopyCount = iTotalSearchNum; } // 表示ページ数が最終ページかつ総検索件数/表示件数の余りがある場合 else if(iTotalPageNum == iDisplayPageNum && 0 < iTotalSearchNum % iDisplayNum) { // 取得件数に総検索数/表示件数の余りを設定 iArrayCopyCount = iTotalSearchNum % iDisplayNum; } // 表示ページ数が最終ページでないまたは総検索件数/表示件数の余りがない場合 else { // 取得件数に総検索数/表示件数を設定 iArrayCopyCount = iDisplayNum; } // ページング範囲のデータを取得 outMsg2 = new CAANMsg[iArrayCopyCount]; System.arraycopy(outMsg1, iArrayCopyStart, outMsg2, 0, iArrayCopyCount); // inMsg(CBSMsg)に取得した明細をセット inMsg.set("ECH0191B010CBSMsg1List", outMsg2); } // 手修正箇所E } catch(SQLException e) { inMsg.set(ECH0191B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery != null){ rsltQuery.close(); } if(pstmt1 != null){ pstmt1.close(); } if(pstmt2 != null){ pstmt2.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(ECH0191B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } /** * ECH0191B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @param opeDate 運用日付
* @param replaceListCnt パラメータ設定リスト
* @return StringBuilder */ private StringBuilder getCondition1(CAANMsg inMsg, List replaceListCnt){ StringBuilder sql_Buff = new StringBuilder(); sql_Buff.append(" FROM ") .append(" CH_T_KNK CH0191 ") .append(" WHERE ") .append(" CH0191.GENE_ADD_DTM = ") .append(" (SELECT MAX(CH0191_GENE.GENE_ADD_DTM) AS CH0191_MAX ") .append(" FROM CH_T_KNK CH0191_GENE ") .append(" WHERE CH0191_GENE.KNK_NO = CH0191.KNK_NO ") .append(" AND CH0191_GENE.MK_FLG='0' ") .append(" ) "); // パラメータの請求契約番号がnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_SEIKY_KEI_NO)) { sql_Buff.append(" AND CH0191.SEIKY_KEI_NO = ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SEIKY_KEI_NO)); } // パラメータの金庫料金項目コードがnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_KNK_PRC_KMK_CD)) { sql_Buff.append(" AND CH0191.KNK_PRC_KMK_CD = ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_KNK_PRC_KMK_CD)); } // パラメータの登録オペレータアカウントがnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_ADD_OPEACNT)) { sql_Buff.append(" AND CH0191.ADD_OPEACNT = ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_ADD_OPEACNT)); } // パラメータの検索開始移動年月日がnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_SERCH_IDO_STAYMD)) { sql_Buff.append(" AND CH0191.KNK_IDO_YMD >= ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_IDO_STAYMD)); } // パラメータの検索終了移動年月日がnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_SERCH_IDO_ENDYMD)) { sql_Buff.append(" AND CH0191.KNK_IDO_YMD <= ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_IDO_ENDYMD)); } // パラメータの検索開始領収年月日がnullでない場合、検索条件に追加 if (!inMsg.isNull(ECH0191B010CBSMsg.KEY_SERCH_PAY_STAYMD)) { sql_Buff.append(" AND CH0191.NYUKIN_NO IN ") .append(" (SELECT ") .append(" CH0111.NYUKIN_NO ") .append(" FROM ") .append(" CH_T_NYUKIN CH0111 ") .append(" WHERE ") .append(" CH0191.NYUKIN_NO = CH0111.NYUKIN_NO ") .append(" AND CH0111.RECEIPT_YMD >= ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_PAY_STAYMD)); // パラメータの検索終了領収年月日がnullでない場合、検索条件に追加 if(null != inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_PAY_ENDYMD)) { sql_Buff.append(" AND CH0111.RECEIPT_YMD <= ? "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_PAY_ENDYMD)); } sql_Buff.append(" AND CH0111.MK_FLG = '0' ") .append(" ) "); } // パラメータの検索開始領収年月日がnullかつ検索終了領収年月日がnullでない場合、検索終了領収年月日を検索条件に追加 else if(!inMsg.isNull(ECH0191B010CBSMsg.KEY_SERCH_PAY_ENDYMD)) { sql_Buff.append(" AND CH0191.NYUKIN_NO IN ") .append(" (SELECT ") .append(" CH0111.NYUKIN_NO ") .append(" FROM ") .append(" CH_T_NYUKIN CH0111 ") .append(" WHERE ") .append(" CH0191.NYUKIN_NO = CH0111.NYUKIN_NO ") .append(" AND CH0111.RECEIPT_YMD <= ? ") .append(" AND CH0111.MK_FLG = '0' ") .append(" ) "); replaceListCnt.add(inMsg.getObject(ECH0191B010CBSMsg.KEY_SERCH_PAY_ENDYMD)); } //パラメータの履歴データフラグが無効の場合、検索条件に追加 if (JCHModelConst.RIREKI_DATA_OFF.equals(inMsg.getObject(ECH0191B010CBSMsg.KEY_RIREKI_DATA_FLG))) { sql_Buff.append(" AND CH0191.RIREKI_DATA_FLG = ? "); replaceListCnt.add(JACStrConst.KNK_RIREKI_DATA_FLG_CURRENT); } return sql_Buff; } /** * ECH0191B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return StringBuilder */ private StringBuilder getSortCondition(CAANMsg inMsg){ String funcCode = inMsg.getString(ECH0191B010CBSMsg.FUNC_CODE); StringBuilder sql_Buff = new StringBuilder(); sql_Buff.append(" ORDER BY "); if (JPCModelConstant.FUNC_CD_1.equals(funcCode)) { sql_Buff.append(" KNK_NO ASC, ") .append(" KNK_PRC_KMK_CD ASC, ") .append(" KNK_IDO_YMD DESC "); } else if (JPCModelConstant.FUNC_CD_2.equals(funcCode)) { sql_Buff.append(" KNK_PRC_KMK_CD ASC, ") .append(" KNK_NO ASC, ") .append(" KNK_IDO_YMD DESC "); } else if (JPCModelConstant.FUNC_CD_3.equals(funcCode)) { sql_Buff.append(" KNK_PRC_KMK_CD DESC, ") .append(" KNK_NO ASC, ") .append(" KNK_IDO_YMD DESC "); } else if (JPCModelConstant.FUNC_CD_4.equals(funcCode)) { sql_Buff.append(" KNK_IDO_YMD ASC, ") .append(" KNK_NO ASC, ") .append(" KNK_PRC_KMK_CD ASC "); } else if (JPCModelConstant.FUNC_CD_5.equals(funcCode)) { sql_Buff.append(" KNK_IDO_YMD DESC, ") .append(" KNK_NO ASC, ") .append(" KNK_PRC_KMK_CD ASC "); } else if (JPCModelConstant.FUNC_CD_6.equals(funcCode)) { sql_Buff.append(" KNK_MOVE_CD ASC, ") .append(" SEIKY_KEI_NO ASC, ") .append(" KNK_NO ASC, ") .append(" KNK_PRC_KMK_CD ASC, ") .append(" KNK_IDO_YMD DESC "); } return sql_Buff; } /** * イベント年月日より請求年月の月末日を取得します。
* @param msg CBSメッセージ * @param context エージェントディスパッチコンテキスト * @param eventYmd イベント年月日 * @return String YYYYMMDD形式の月末日 */ private String getUseEnd(CAANMsg inCBSMsg, AgentDispatchContext inContext, String eventYmd) { String endYmd = ""; if (eventYmd == null) { return ""; } // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; try { //コネクション取得 con1 = JSYejbConnection.getConnection(CH0501ETMsg.getTableName()); StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" CH0501.EVENT_YMD ") .append(" FROM ") .append(" CH_M_PRC_SCHDL_TEIGI CH0501 ") .append(" WHERE ") .append(" CH0501.EVENT_CD = '02' ") .append(" AND CH0501.SEIKY_YM = (SELECT ") .append(" MIN(CH0501_SUB.SEIKY_YM) AS SEIKY_YM ") .append(" FROM ") .append(" CH_M_PRC_SCHDL_TEIGI CH0501_SUB ") .append(" WHERE ") .append(" CH0501_SUB.EVENT_CD = '03' ") .append(" AND CH0501_SUB.EVENT_YMD >= ? ") .append(" AND CH0501_SUB.MK_FLG = '0') "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // パラメータの設定 CAANJDBCUtil.setParam(pstmt, 1, eventYmd); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // 戻り値の判定 if (rsltQuery.next()) { endYmd = rsltQuery.getString(CH0501ETMsg.EVENT_YMD); } } catch(SQLException e) { inCBSMsg.set(ECH0191B010CBSMsg.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) { inCBSMsg.set(ECH0191B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } return endYmd; } }