/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECR0231B010TPDA * ソースファイル名：JSYejbECR0231B010TPDA.java * 作成者 ：EK909278 * 日付 ：2012年05月29日 *＜機能概要＞ * 対応履歴電子ファイル管理一覧照会テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * v22.00.00 2016/01/08 FJ）柿坂 【OM-2015-0003325】障害対応 * v23.00.00 2016/03/18 FJ）藤本 【OM-2016-0000744】性能改善 * ********************************************************************************/ 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.Iterator; 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.common.util.JCRUtilCommon; import eo.ejb.cbm.entity.CR0231ETMsg; import eo.ejb.cbs.cbsmsg.ECR0231B010CBSMsg; import eo.ejb.cbs.cbsmsg.ECR0231B010CBSMsg1List; /** * * テンプレートDBアクセス部品　ECR0231B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECR0231B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECR0231B010TPDA() { } /** * ECR0231B010_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(CR0231ETMsg.getTableName()); // ▼▼▼▼▼ 追加 開始 ▼▼▼▼▼ // ＫＥＹ＿文書種別コード String bunshoSbtCd = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_BUNSHO_SBT_CD); // ＫＥＹ＿対応記録番号 String taioKirokNo = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_TAIO_KIROK_NO); // ＫＥＹ＿対応記録明細番号 String taioKirokDtlNo = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_TAIO_KIROK_DTL_NO); // ＫＥＹ＿クエリ番号 String queryMo = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_QUERY_NO); // ＫＥＹ＿対応履歴文書作成年月日 String bunshoSakseiYmd = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_TAIORRKI_BUNSHO_SAKSEI_YMD); // ＫＥＹ＿業務個別設定組織コード String wkkbtOrgCd = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_WKKBT_ORG_CD); // ＫＥＹ＿電子ファイル管理番号 String efileKanriNo = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_EFILE_KANRI_NO); // ＫＥＹ＿対応履歴文書ファイル名 String taiorrki_bunsho_file_nm = (String)inMsg.getString(ECR0231B010CBSMsg.KEY_TAIORRKI_BUNSHO_FILE_NM); // ＳＯＲＴ指定項目名 String sortSiteiKmkNm = (String)inMsg.getString(ECR0231B010CBSMsg.SORT_SHITEI_KMK_NM); List replaceList = new ArrayList(); // ▲▲▲▲▲ 追加 終了 ▲▲▲▲▲ // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" TEKN.TORK_EFILE_KNRI_NO ") .append(" , TEKN.BUNSHO_SBT_CD ") .append(" , (SELECT ") .append(" CD01.CD_DIV_NM ") .append(" FROM ") .append(" ZM_M_CD_NM_KANRI CD01 ") .append(" WHERE ") .append(" CD01.CD_SBT_CD = 'CD00534' ") .append(" AND CD01.CD_DIV = TEKN.BUNSHO_SBT_CD ") .append(" AND CD01.CD_TSTAYMD <= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND CD01.CD_TENDYMD >= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND CD01.MK_FLG = '0') AS BUNSHO_SBT_CD_NM ") .append(" , TEKN.TAIO_KIROK_NO ") .append(" , TEKN.TAIO_KIROK_DTL_NO ") .append(" , TEKN.QUERY_NO ") .append(" , TEKN.EFILE_KANRI_NO ") .append(" , TEKN.TAIORRKI_BUNSHO_FILE_NM ") .append(" , TEKN.TAIORRKI_BUNSHO_SAKSEI_DTM ") .append(" , EFKN.GENE_ADD_DTM ") .append(" , TEKN.WKKBT_ORG_CD ") .append(" , (SELECT ") .append(" WKOG.WKKBT_ORG_NM ") .append(" FROM ") .append(" ZM_M_WKKBT_ORG WKOG ") .append(" WHERE ") .append(" WKOG.WKKBT_ORG_CD = TEKN.WKKBT_ORG_CD ") .append(" AND WKOG.AUTHORITY_APLY_ORG_SBT_CD = '02' ") .append(" AND WKOG.WKKBT_ORG_TSTAYMD <= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND WKOG.WKKBT_ORG_TENDYMD >= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND WKOG.MK_FLG = '0') AS WKKBT_ORG_CD_NM ") .append(" , TEKN.WKKBT_POSITION_CD ") .append(" , (SELECT ") .append(" WKPS.WKKBT_POSITION_NM ") .append(" FROM ") .append(" ZM_M_WKKBT_POSITION WKPS ") .append(" WHERE ") .append(" WKPS.WKKBT_POSITION_CD = TEKN.WKKBT_POSITION_CD ") .append(" AND WKPS.AUTHORITY_APLY_ORG_SBT_CD = '02' ") .append(" AND WKPS.WKKBT_POSITION_TSTAYMD <= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND WKPS.WKKBT_POSITION_TENDYMD >= SUBSTR(TEKN.UPD_DTM, 1, 8) ") .append(" AND WKPS.MK_FLG = '0') AS WKKBT_POSITION_CD_NM ") .append(" , EFKN.UPD_DTM ") .append(" FROM ") .append(" CR_T_TORK_EFILE_KNRI TEKN ") // ++++++ v22.00.00 MOD START +++++++++ // .append(" LEFT OUTER JOIN ") .append(" INNER JOIN ") // ++++++ v22.00.00 MOD END +++++++++ .append(" ( ") .append(" SELECT ") .append(" EFILE_KANRI_NO ") .append(" , GENE_ADD_DTM ") .append(" , UPD_DTM ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK ") .append(" WHERE ") .append(" (EFK.EFILE_KANRI_NO,EFK.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT ") .append(" EFK_GENE.EFILE_KANRI_NO, ") .append(" MAX(EFK_GENE.GENE_ADD_DTM) AS EFK_MAX ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK_GENE ") .append(" WHERE ") .append(" EFK_GENE.EFILE_KANRI_NO = EFK.EFILE_KANRI_NO AND ") .append(" EFK_GENE.MK_FLG= '0' ") .append(" GROUP BY EFK_GENE.EFILE_KANRI_NO ") .append(" ) ") .append(" ) EFKN ") .append(" ON ") .append(" ( ") .append(" EFKN.EFILE_KANRI_NO = TEKN.EFILE_KANRI_NO ") .append(" ) ") .append(" WHERE "); StringBuilder sql_where = new StringBuilder(""); String strAnd = ""; // ＫＥＹ＿文書種別コード 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(bunshoSbtCd)) { sql_where.append(strAnd); // 20160318 OM-2016-0000744 性能改善 MOD START // sql_where.append(" TEKN.BUNSHO_SBT_CD = ? "); sql_where.append(" TEKN.BUNSHO_SBT_CD = '").append(bunshoSbtCd).append("' "); // 20160318 OM-2016-0000744 性能改善 MOD END strAnd = " AND "; // 20160318 OM-2016-0000744 性能改善 DEL START // replaceList.add(bunshoSbtCd); // 20160318 OM-2016-0000744 性能改善 DEL END } // ＫＥＹ＿対応記録番号 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(taioKirokNo)) { sql_where.append(strAnd); sql_where.append(" TEKN.TAIO_KIROK_NO = ? "); strAnd = " AND "; replaceList.add(taioKirokNo); } // ＫＥＹ＿対応記録明細番号 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(taioKirokDtlNo)) { sql_where.append(strAnd); sql_where.append(" TEKN.TAIO_KIROK_DTL_NO = ? "); strAnd = " AND "; replaceList.add(taioKirokDtlNo); } // ＫＥＹ＿クエリ番号 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(queryMo)) { sql_where.append(strAnd); sql_where.append(" TEKN.QUERY_NO = ? "); strAnd = " AND "; replaceList.add(queryMo); } // ＫＥＹ＿対応履歴文書作成年月日 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(bunshoSakseiYmd)) { sql_where.append(strAnd); sql_where.append(" SUBSTR(TEKN.TAIORRKI_BUNSHO_SAKSEI_DTM, 1, 8) = ? "); strAnd = " AND "; replaceList.add(bunshoSakseiYmd); } // ＫＥＹ＿業務個別設定組織コード 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(wkkbtOrgCd)) { sql_where.append(strAnd); sql_where.append(" TEKN.WKKBT_ORG_CD = ? "); strAnd = " AND "; replaceList.add(wkkbtOrgCd); } // ＫＥＹ＿電子ファイル管理番号 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(efileKanriNo)) { sql_where.append(strAnd); sql_where.append(" TEKN.EFILE_KANRI_NO = ? "); strAnd = " AND "; replaceList.add(efileKanriNo); } // ＫＥＹ＿対応履歴文書ファイル名 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(taiorrki_bunsho_file_nm)) { sql_where.append(strAnd); sql_where.append(" TEKN.TAIORRKI_BUNSHO_FILE_NM = ? "); strAnd = " AND "; replaceList.add(taiorrki_bunsho_file_nm); } // 対応履歴電子ファイル管理.無効フラグ sql_where.append(strAnd); sql_where.append(" TEKN.MK_FLG = '0' "); sql_Buff.append(sql_where); sql_Buff.append(" ORDER BY "); String sortOrder = null; // 機能コードが"1"（昇順ソート）の場合 if (JPCModelConstant.FUNC_CD_1.equals(inMsg.getObject(ECR0231B010CBSMsg.FUNC_CODE).toString())) { sortOrder = " ASC "; } else if (JPCModelConstant.FUNC_CD_2.equals(inMsg.getObject(ECR0231B010CBSMsg.FUNC_CODE).toString())) // 機能コードが"2"（降順ソート）の場合 { sortOrder = " DESC "; } // 対応履歴電子ファイル管理番号ソート if ("TORK_EFILE_KNRI_NO".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ").append(sortOrder); } // 文書種別コードソート if ("BUNSHO_SBT_CD".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.BUNSHO_SBT_CD ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 対応記録番号ソート if ("TAIO_KIROK_NO".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.TAIO_KIROK_NO ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 対応記録明細ソート if ("TAIO_KIROK_DTL_NO".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.TAIO_KIROK_DTL_NO ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // クエリ番号ソート if ("QUERY_NO".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.QUERY_NO ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 電子ファイル管理番号ソート if ("EFILE_KANRI_NO".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.EFILE_KANRI_NO ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 対応履歴文書ファイル名ソート if ("TAIORRKI_BUNSHO_FILE_NM".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.TAIORRKI_BUNSHO_FILE_NM ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 対応履歴文書作成年月日時分秒ソート if ("TAIORRKI_BUNSHO_SAKSEI_DTM".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.TAIORRKI_BUNSHO_SAKSEI_DTM ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 業務個別設定組織コードソート if ("WKKBT_ORG_CD".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.WKKBT_ORG_CD ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } // 業務個別設定立場コードソート if ("WKKBT_POSITION_CD".equals(sortSiteiKmkNm)) { sql_Buff.append(" TEKN.WKKBT_POSITION_CD ").append(sortOrder).append(" , "); sql_Buff.append(" TEKN.TORK_EFILE_KNRI_NO ASC"); } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 int idx = 1; Iterator ite = replaceList.iterator(); while(ite.hasNext()) { CAANJDBCUtil.setParam(pstmt, idx, ite.next()); idx++; } //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // ECR0231B010CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECR0231B010CBSMsg1List.TORK_EFILE_KNRI_NO , ECR0231B010CBSMsg1List.BUNSHO_SBT_CD , ECR0231B010CBSMsg1List.BUNSHO_SBT_CD_NM , ECR0231B010CBSMsg1List.TAIO_KIROK_NO , ECR0231B010CBSMsg1List.TAIO_KIROK_DTL_NO , ECR0231B010CBSMsg1List.QUERY_NO , ECR0231B010CBSMsg1List.EFILE_KANRI_NO , ECR0231B010CBSMsg1List.TAIORRKI_BUNSHO_FILE_NM , ECR0231B010CBSMsg1List.TAIORRKI_BUNSHO_SAKSEI_DTM , ECR0231B010CBSMsg1List.GENE_ADD_DTM , ECR0231B010CBSMsg1List.WKKBT_ORG_CD , ECR0231B010CBSMsg1List.WKKBT_ORG_CD_NM , ECR0231B010CBSMsg1List.WKKBT_POSITION_CD , ECR0231B010CBSMsg1List.WKKBT_POSITION_CD_NM , ECR0231B010CBSMsg1List.UPD_DTM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECR0231B010CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("ECR0231B010CBSMsg1List", outMsg1); // 総検索件数の設定 inMsg.set(ECR0231B010CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(outMsg1.length)); } catch(SQLException e) { inMsg.set(ECR0231B010CBSMsg.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(ECR0231B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }