/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECR0231B030TPDA * ソースファイル名：JSYejbECR0231B030TPDA.java * 作成者 ：EK909278 * 日付 ：2012年05月29日 *＜機能概要＞ * 対応履歴電子ファイル管理一覧照会(エラーデータ)テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ6.00.00 2013/11/07 FJ）斉藤諭 随時-13-5157対応 MATEファイル表示対応 * ********************************************************************************/ 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.ECR0231B030CBSMsg; import eo.ejb.cbs.cbsmsg.ECR0231B030CBSMsg1List; /** * * テンプレートDBアクセス部品　ECR0231B030_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECR0231B030TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECR0231B030TPDA() { } /** * ECR0231B030_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 bunshoSakseiYmd = (String)inMsg.getString(ECR0231B030CBSMsg.KEY_TAIORRKI_BUNSHO_SAKSEI_YMD); // ＫＥＹ＿業務個別設定組織コード String wkkbtOrgCd = (String)inMsg.getString(ECR0231B030CBSMsg.KEY_WKKBT_ORG_CD); List replaceList = new ArrayList(); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" TEK1.TORK_EFILE_KNRI_NO, ") .append(" TEK1.EFILE_KANRI_NO, ") .append(" TEK1.TAIORRKI_BUNSHO_FILE_NM, ") .append(" TEK1.TAIORRKI_BUNSHO_SAKSEI_DTM, ") .append(" TEK1.WKKBT_ORG_CD, ") .append(" ( ") .append(" SELECT ") .append(" WKKBT_ORG_NM ") .append(" FROM ") .append(" ZM_M_WKKBT_ORG WOG1 ") .append(" WHERE ") .append(" WOG1.WKKBT_ORG_CD = TEK1.WKKBT_ORG_CD AND ") .append(" WOG1.AUTHORITY_APLY_ORG_SBT_CD = '02' AND ") .append(" WOG1.WKKBT_ORG_TSTAYMD <= SUBSTR(TEK1.UPD_DTM, 1, 8) AND ") .append(" WOG1.WKKBT_ORG_TENDYMD >= SUBSTR(TEK1.UPD_DTM, 1, 8) AND ") .append(" WOG1.MK_FLG = '0' ") .append(" ) WKKBT_ORG_CD_NM, ") .append(" TEK1.WKKBT_POSITION_CD, ") .append(" ( ") .append(" SELECT ") .append(" WKKBT_POSITION_NM ") .append(" FROM ") .append(" ZM_M_WKKBT_POSITION WPS1 ") .append(" WHERE ") .append(" WPS1.WKKBT_POSITION_CD = TEK1.WKKBT_POSITION_CD AND ") .append(" WPS1.AUTHORITY_APLY_ORG_SBT_CD = '02' AND ") .append(" WPS1.WKKBT_POSITION_TSTAYMD <= SUBSTR(TEK1.UPD_DTM, 1, 8) AND ") .append(" WPS1.WKKBT_POSITION_TENDYMD >= SUBSTR(TEK1.UPD_DTM, 1, 8) AND ") .append(" WPS1.MK_FLG = '0' ") .append(" ) WKKBT_POSITION_CD_NM, ") .append(" ( ") .append(" SELECT ") .append(" EFK1.GENE_ADD_DTM ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK1 ") .append(" WHERE ") .append(" EFK1.EFILE_KANRI_NO = TEK1.EFILE_KANRI_NO AND ") .append(" (EFK1.EFILE_KANRI_NO,EFK1.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT ") .append(" EFK1_GENE.EFILE_KANRI_NO, ") .append(" MAX(EFK1_GENE.GENE_ADD_DTM) AS EFK1_MAX ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK1_GENE ") .append(" WHERE ") .append(" EFK1_GENE.EFILE_KANRI_NO = EFK1.EFILE_KANRI_NO AND ") .append(" EFK1_GENE.MK_FLG= '0' ") .append(" GROUP BY EFK1_GENE.EFILE_KANRI_NO ") .append(" ) ") .append(" ) GENE_ADD_DTM, ") .append(" ( ") .append(" SELECT ") .append(" EFK2.UPD_DTM ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK2 ") .append(" WHERE ") .append(" EFK2.EFILE_KANRI_NO = TEK1.EFILE_KANRI_NO AND ") .append(" (EFK2.EFILE_KANRI_NO,EFK2.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT ") .append(" EFK2_GENE.EFILE_KANRI_NO, ") .append(" MAX(EFK2_GENE.GENE_ADD_DTM) AS EFK2_MAX ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK2_GENE ") .append(" WHERE ") .append(" EFK2_GENE.EFILE_KANRI_NO = EFK2.EFILE_KANRI_NO AND ") .append(" EFK2_GENE.MK_FLG= '0' ") .append(" GROUP BY EFK2_GENE.EFILE_KANRI_NO ") .append(" ) ") .append(" ) UPD_DTM, ") .append(" TEK2.TORK_EFILE_KNRI_NO LOG_TORK_EFILE_KNRI_NO, ") .append(" TEK2.EFILE_KANRI_NO LOG_EFILE_KANRI_NO, ") .append(" TEK2.TAIORRKI_BUNSHO_FILE_NM LOG_TAIORRKI_BUNSHO_FILE_NM, ") .append(" TEK2.TAIORRKI_BUNSHO_SAKSEI_DTM LOG_TAIORRKI_BUNSHO_SAKSEI_DTM, ") .append(" ( ") .append(" SELECT ") .append(" EFK3.GENE_ADD_DTM ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK3 ") .append(" WHERE ") .append(" EFK3.EFILE_KANRI_NO = TEK2.EFILE_KANRI_NO AND ") .append(" (EFK3.EFILE_KANRI_NO,EFK3.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT ") .append(" EFK3_GENE.EFILE_KANRI_NO, ") .append(" MAX(EFK3_GENE.GENE_ADD_DTM) AS EFK3_MAX ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK3_GENE ") .append(" WHERE ") .append(" EFK3_GENE.EFILE_KANRI_NO = EFK3.EFILE_KANRI_NO AND ") .append(" EFK3_GENE.MK_FLG= '0' ") .append(" GROUP BY EFK3_GENE.EFILE_KANRI_NO ") .append(" ) ") .append(" ) LOG_GENE_ADD_DTM, ") .append(" ( ") .append(" SELECT ") .append(" EFK4.UPD_DTM ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK4 ") .append(" WHERE ") .append(" EFK4.EFILE_KANRI_NO = TEK2.EFILE_KANRI_NO AND ") .append(" (EFK4.EFILE_KANRI_NO,EFK4.GENE_ADD_DTM) = ") .append(" ( ") .append(" SELECT ") .append(" EFK4_GENE.EFILE_KANRI_NO, ") .append(" MAX(EFK4_GENE.GENE_ADD_DTM) AS EFK4_MAX ") .append(" FROM ") .append(" CC_T_EFILE_KANRI EFK4_GENE ") .append(" WHERE ") .append(" EFK4_GENE.EFILE_KANRI_NO = EFK4.EFILE_KANRI_NO AND ") .append(" EFK4_GENE.MK_FLG= '0' ") .append(" GROUP BY EFK4_GENE.EFILE_KANRI_NO ") .append(" ) ") .append(" ) LOG_UPD_DTM ") .append(" FROM ") .append(" CR_T_TORK_EFILE_KNRI TEK1, ") .append(" CR_T_TORK_EFILE_KNRI TEK2 "); sql_Buff.append(" WHERE "); // SQL文_個別部1 if ( JPCModelConstant.FUNC_CD_1.equals( inMsg.getObject(ECR0231B030CBSMsg.FUNC_CODE).toString() ) ) { // ＫＥＹ＿対応履歴文書作成年月日 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(bunshoSakseiYmd)) { sql_Buff.append(" SUBSTR(TEK1.TAIORRKI_BUNSHO_SAKSEI_DTM, 1, 8) = ? AND "); replaceList.add(bunshoSakseiYmd); } // ＫＥＹ＿業務個別設定組織コード 入力値が設定されている場合のみAND条件にてWHERE句に設定する if (!JCRUtilCommon.isNull(wkkbtOrgCd)) { sql_Buff.append(" TEK1.WKKBT_ORG_CD = ? AND "); replaceList.add(wkkbtOrgCd); } sql_Buff.append(" TEK1.BUNSHO_SBT_CD = '13' AND ") .append(" TEK1.MK_FLG = '0' AND ") .append(" TEK2.BUNSHO_SBT_CD = '15' AND ") .append(" TEK2.MK_FLG = '0' AND ") // .append(" UPPER(TEK1.TAIORRKI_BUNSHO_FILE_NM) LIKE 'CASE%' AND ") .append(" REPLACE(SUBSTR(TEK1.TAIORRKI_BUNSHO_FILE_NM, 0, INSTR(TEK1.TAIORRKI_BUNSHO_FILE_NM, '.')), '_NG', '') = SUBSTR(TEK2.TAIORRKI_BUNSHO_FILE_NM, 0, INSTR(TEK2.TAIORRKI_BUNSHO_FILE_NM, '.')) ") .append(" ORDER BY ") .append(" TEK1.TORK_EFILE_KNRI_NO "); } //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(); // ECR0231B030CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECR0231B030CBSMsg1List.TORK_EFILE_KNRI_NO , ECR0231B030CBSMsg1List.EFILE_KANRI_NO , ECR0231B030CBSMsg1List.TAIORRKI_BUNSHO_FILE_NM , ECR0231B030CBSMsg1List.TAIORRKI_BUNSHO_SAKSEI_DTM , ECR0231B030CBSMsg1List.WKKBT_ORG_CD , ECR0231B030CBSMsg1List.WKKBT_ORG_CD_NM , ECR0231B030CBSMsg1List.WKKBT_POSITION_CD , ECR0231B030CBSMsg1List.WKKBT_POSITION_CD_NM , ECR0231B030CBSMsg1List.GENE_ADD_DTM , ECR0231B030CBSMsg1List.UPD_DTM , ECR0231B030CBSMsg1List.LOG_TORK_EFILE_KNRI_NO , ECR0231B030CBSMsg1List.LOG_EFILE_KANRI_NO , ECR0231B030CBSMsg1List.LOG_TAIORRKI_BUNSHO_FILE_NM , ECR0231B030CBSMsg1List.LOG_TAIORRKI_BUNSHO_SAKSEI_DTM , ECR0231B030CBSMsg1List.LOG_GENE_ADD_DTM , ECR0231B030CBSMsg1List.LOG_UPD_DTM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECR0231B030CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("ECR0231B030CBSMsg1List", outMsg1); // 総検索件数の設定 inMsg.set(ECR0231B030CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(outMsg1.length)); } catch(SQLException e) { inMsg.set(ECR0231B030CBSMsg.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(ECR0231B030CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }