/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JECC0041C010TPMA * ソースファイル名：JECC0041C010TPMA.java * 作成者 ：EKek0069 * 日付 ：2011年04月17日 *＜機能概要＞ * 電子ファイル管理更新独自処理部品 * 入力パラメータチェック、電子ファイルの圧縮およびファイルサイズチェックを行う。 * 電子ファイル管理番号をキーとし、電子ファイル管理テーブルから最新のシステムコードおよびファイルコードを取得する。 * 電子ファイル管理テーブルへ電子ファイル情報の登録を行う。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ32.00.00 2017/05/26 FJ)河邊 【OM-2017-0000488】オープンカーソルエラー * ********************************************************************************/ package eo.ejb.cbs.mainproc; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.HashMap; import com.fujitsu.futurity.model.base.CAANConnectionMgr; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; 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.TemplateMainHandler; import eo.common.util.JCCFileUtil; import eo.common.util.JCCFrameworkException; import eo.ejb.cbm.entity.CC0041ETMsg; import eo.ejb.cbs.cbsmsg.ECC0041C010CBSMsg; import eo.ejb.cbs.cbsmsg.ECC0041D010CBSMsg; import eo.ejb.common.EventIDList; import eo.ejb.common.JCCModelCommon; import eo.ejb.common.JCCejbEFile; import java.sql.Connection; import java.sql.SQLException; public class JECC0041C010TPMA implements TemplateMainHandler { /** * コンストラクタ. */ public JECC0041C010TPMA() { } /** * 電子ファイル管理更新独自処理部品 * @param inCBSMsg CBSMsg * @param inContext AgentDispatchContext * @throws Throwable */ public void invoke(CAANMsg inCBSMsg, AgentDispatchContext inContext) throws Throwable { // 変数定義 //圧縮後電子ファイルパス String asshukuFilePath; //圧縮後ファイル名 String butsuriFileName; //圧縮後ファイルサイズ String assukuFileSize; //圧縮前ファイルサイズ String fileSize ; //ファイル削除年月日 String fileDelYmd; // //作業用ディレクトリパス // String dirCompTmp; //作業用ディレクトリパス String removeTmpDir; // コネクション Connection con = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; //電子ファイル情報 HashMap eFileInfo; JCCejbEFile jCCejbEFile = new JCCejbEFile(); final String ASSHUKU_FILE_PATH = "ASSHUKU_FILE_PATH"; final String BUTSURI_FILE_NM = "BUTSURI_FILE_NM"; final String ASSHUKU_FILE_SIZE = "ASSHUKU_FILE_SIZE"; final String FILE_SIZE = "FILE_SIZE"; final String FILE_DEL_YMD = "FILE_DEL_YMD"; final String REMOVE_TEMP_DIR = "REMOVE_TEMP_DIR"; final String strNull = null; //(1)電子ファイル情報チェック //@ 電子ファイル情報チェック部品の呼び出しを行い、圧縮後電子ファイルパス、圧縮後ファイル名、圧縮後ファイルサイズ、圧縮前ファイルサイズ、 // ファイル削除年月日、作業用ディレクトリパスを取得する。 // （引数：電子ファイル、ファイル削除年月日） // 呼び出し先にて、JCCFrameworkExceptionが発生した場合は、そのまま呼び出し先へJCCFrameworkExceptionを返却する。 try { eFileInfo = jCCejbEFile.eFileInfoCheck((byte[])(inCBSMsg.getObject(ECC0041C010CBSMsg.EFILE)), inCBSMsg.getString(ECC0041D010CBSMsg.FILE_DEL_YMD)); //A 部品からの返却値がnullの場合、CBSMsgに以下の値を設定し、処理を終了する。 // ・ CBSMsg(ファイルサイズエラー)に"E5"を設定する。 // ・ CBSMsg(ステータス)に「単項目関連チェックでエラー」を設定する。 if(eFileInfo == null) { // ファイルサイズエラーに"E5"を設定 inCBSMsg.set(ECC0041C010CBSMsg.EFILE_ERR, "E5"); // ステータスに「単項目関連でチェックエラー」を設定 inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.ITEM_RELATION_ERR); return; } asshukuFilePath = eFileInfo.get(ASSHUKU_FILE_PATH); butsuriFileName = eFileInfo.get(BUTSURI_FILE_NM); assukuFileSize = eFileInfo.get(ASSHUKU_FILE_SIZE); //fileSize = inCBSMsg.getString(ECC0041C010CBSMsg.FILE_SIZE); fileSize = eFileInfo.get(FILE_SIZE); fileDelYmd = eFileInfo.get(FILE_DEL_YMD); // dirCompTmp = eFileInfo.get(DIR_COMP_TMP); removeTmpDir = eFileInfo.get(REMOVE_TEMP_DIR); } catch(JCCFrameworkException e) { throw e; } //B A以外の場合、以下の値を設定する。 //CBSMsg（物理ファイル名）へ圧縮後ファイル名を設定する。 //CBSMsg（圧縮ファイルサイズ）へ圧縮前ファイルサイズを設定する。 //CBSMsg（ファイルサイズ）へ圧縮前ファイルサイズを設定する。 //CBSMsg(ファイル削除年月日)へファイル削除年月日を設定する。 //CBSMsg(世代登録年月日時分秒)へオンラインシステム日付取得部品より取得できるシステム日付を設定する。 //オンラインシステム日付取得部品についての詳細は、「SSA26_部品仕様書(オンラインシステム日付取得部品)」参照。 // CBSMsg物理ファイル名へ圧縮後ファイル名を設定 inCBSMsg.set(ECC0041C010CBSMsg.BUTSURI_FILE_NM, butsuriFileName); // CBSMsg圧縮ファイルサイズへ圧縮後ファイルサイズを設定 inCBSMsg.set(ECC0041C010CBSMsg.ASSHUKU_FILE_SIZE, assukuFileSize); // CBSMsgファイルサイズへ圧縮前ファイルサイズを設定 inCBSMsg.set(ECC0041C010CBSMsg.FILE_SIZE, fileSize); // CBSMsgファイル削除年月日へファイル削除年月日を設定 inCBSMsg.set(ECC0041C010CBSMsg.FILE_DEL_YMD, fileDelYmd); //CBSMsg(世代登録年月日時分秒)へオンラインシステム日付取得部品より取得できるシステム日付を設定する。 inCBSMsg.set(ECC0041C010CBSMsg.GENE_ADD_DTM, JCCModelCommon.getSysDateTimeStamp()); //C CBSMsg(ファイルコード)がnullまたは空白の場合、「0000」を設定する。 if(null == inCBSMsg.getString(ECC0041C010CBSMsg.FILE_CD) || (inCBSMsg.getString(ECC0041C010CBSMsg.FILE_CD)).isEmpty()) { inCBSMsg.set(ECC0041C010CBSMsg.FILE_CD, "0000"); } // D機能コード2の場合、世代登録年月日時分秒と物理ファイル名にnullを設定 if( inCBSMsg.getString(ECC0041C010CBSMsg.FUNC_CODE).equals("2") ) { inCBSMsg.set(ECC0041C010CBSMsg.GENE_ADD_DTM, strNull); inCBSMsg.set(ECC0041C010CBSMsg.BUTSURI_FILE_NM, strNull); } //(2)電子ファイル情報取得 //@ コネクションの取得を行う。 //A 最新の電子ファイル情報の取得を行う。 //CBSMsgより取得できる電子ファイル管理番号および更新前世代年月日時分秒を基に、以下の通りSQL文を組み立て、 //最新の電子ファイル情報の取得を行う。 //システムコード String sysCD = null; //ファイルコード String fileCD = null; try { //(a) SQLの組み立て //con = JSYejbConnection.getConnection("DUAL"); con = JSYejbConnection.getConnection(CC0041ETMsg.getTableName()); StringBuffer sql = new StringBuffer(); sql.append("SELECT CC0041.SYS_CD, "); sql.append(" CC0041.FILE_CD "); sql.append(" FROM CC_T_EFILE_KANRI CC0041 "); sql.append(" WHERE CC0041.EFILE_KANRI_NO = ? "); sql.append(" AND CC0041.GENE_ADD_DTM = ? "); sql.append(" AND CC0041.MK_FLG = '0' "); //(c) PreparedStatementの設定 //EFILE_KANRI_NO CBSMsg(電子ファイル管理番号) //GENE_ADD_DTM_BF CBSMsg(更新前世代年月日時分秒) //MK_FLG 0（有効のみ検索対象） pstmt = con.prepareStatement(sql.toString()); CAANJDBCUtil.setParam(pstmt, 1, inCBSMsg.getString(ECC0041C010CBSMsg.EFILE_KANRI_NO)); CAANJDBCUtil.setParam(pstmt, 2, inCBSMsg.getString(ECC0041C010CBSMsg.GENE_ADD_DTM_BF)); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); //(d) 取得件数が0件の場合、CBSMsgに以下の値を設定し、処理を終了する。 // また、(1)で取得した作業用ディレクトリの削除およびコネクションのクローズを行う。 //電子ファイル管理番号エラーに"EA"を付与 //ステータス：「関連チェックでエラー」 //if(rsltQuery.getInt(1) == 0) if(!rsltQuery.next()) { //JCCFileUtil.removeDir(removeTmpDir); inCBSMsg.set(ECC0041C010CBSMsg.EFILE_KANRI_NO_ERR, "EA"); //inCBSMsg.set(ECC0041C010CBSMsg.STATUS, "関連チェックでエラー"); inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.RELATION_ERR); // 下記項目にNullを設定する inCBSMsg.set(ECC0041C010CBSMsg.EFILE, strNull); try { JCCFileUtil.removeDir(removeTmpDir); } catch(JCCFrameworkException e) { } if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } return; } sysCD = rsltQuery.getString("SYS_CD"); fileCD = rsltQuery.getString("FILE_CD"); } catch(SQLException e) { //(e) SQLExceptionが発生した場合、CBSMsgに以下の値を設定し、JCCFrameworkExceptionをスローし、処理を終了する。 //また、(1)で取得した作業用ディレクトリの削除およびコネクションのクローズを行う。 //ステータス：「検索時DBエラー」 inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); //throw new CAANRuntimeException(e); try { JCCFileUtil.removeDir(removeTmpDir); } catch(JCCFrameworkException ex) { } //throw new JCCFrameworkException(e); if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } // OM-2017-0000488 2017/05/26 ADD START if (con != null) { CAANConnectionMgr.getInstance().close(con); } // OM-2017-0000488 2017/05/26 ADD END throw e; } //(f) (d)(e)以外の場合、電子ファイル管理テーブルより取得した情報をCBSMsgに以下の値を設定する。 //システムコード //ファイルコード inCBSMsg.set(ECC0041C010CBSMsg.SYS_CD, sysCD); inCBSMsg.set(ECC0041C010CBSMsg.FILE_CD, fileCD); //B カレントコードタイムスタンプチェック //CBSMsgより取得できる電子ファイル管理番号および更新前更新年月日時分秒を基に、以下の通りSQL文を組み立て、カレントコードタイムスタンプチェックを行う。 //(a) SQLの組み立て try { boolean lockCheckFLG = false; SQLException ex = null; // SQLの作成 //カレントコードタイムスタンプチェックを行う StringBuffer sql = new StringBuffer(); sql.append("SELECT CC0041.UPD_DTM "); sql.append(" FROM CC_T_EFILE_KANRI CC0041 "); sql.append(" WHERE CC0041.EFILE_KANRI_NO = ? "); sql.append(" AND CC0041.GENE_ADD_DTM = (SELECT MAX(CC0041_GENE.GENE_ADD_DTM) "); // 2012/08/16 FST)arata 単体製造品質チェック対応 start sql.append(" FROM CC_T_EFILE_KANRI CC0041_GENE WHERE CC0041_GENE.EFILE_KANRI_NO = CC0041.EFILE_KANRI_NO AND CC0041_GENE.MK_FLG = '0') "); sql.append(" AND CC0041.MK_FLG = '0' "); // 2012/08/16 FST)arata 単体製造品質チェック対応 end sql.append(" FOR UPDATE NOWAIT"); for(int i = 0; i < 3; i++) { lockCheckFLG = false; try { //(b) ログ出力(SQL文の出力)を行う。 JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql); //(c) PreparedStatementの設定 // ・ EFILE_KANRI_NO //2012/03/21 prepareStatementをクローズする start if(null != pstmt) { pstmt.close(); } //2012/03/21 prepareStatementをクローズする end pstmt = con.prepareStatement(sql.toString()); CAANJDBCUtil.setParam(pstmt, 1, inCBSMsg.getString(ECC0041C010CBSMsg.EFILE_KANRI_NO)); //(d) 取得したUPD_DTM（更新年月日時分秒）と更新前更新年月日時分秒が異なる場合、CBSMsgに以下の値を設定し、処理を終了する。 // また、(1)で取得した作業用ディレクトリの削除およびコネクションのクローズを行う。 // ・ 更新前更新年月日時分秒エラーに"EB"を付与 // ・ ステータス：「関連チェックでエラー」 //2012/03/21 ResultSetをクローズする start if(null != rsltQuery) { rsltQuery.close(); } //2012/03/21 ResultSetをクローズする start // ResultSetの取得 rsltQuery = pstmt.executeQuery(); } catch(SQLException e) { ex = e; lockCheckFLG = true; } if(!lockCheckFLG) { break; } } if(lockCheckFLG) { throw ex; } rsltQuery.next(); if(!rsltQuery.getString("UPD_DTM").equals(inCBSMsg.getString(ECC0041C010CBSMsg.UPD_DTM_BF))) { inCBSMsg.set(ECC0041C010CBSMsg.UPD_DTM_BF_ERR, "EB"); //inCBSMsg.set(ECC0041E010CBSMsg.STATUS, "関連チェックでエラー"); inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.RELATION_ERR); try { JCCFileUtil.removeDir(removeTmpDir); } catch(JCCFrameworkException e) { } if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } return; } } catch(SQLException e) { //(e) SQLExceptionが発生した場合、CBSMsgに以下の値を設定し、JCCFrameworkExceptionをスローし、処理を終了する。 // また、(1)で取得した作業用ディレクトリの削除およびコネクションのクローズを行う。 // ・ ステータス：「検索時DBエラー」 inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); try { JCCFileUtil.removeDir(removeTmpDir); } catch(JCCFrameworkException ex) { } if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } throw e; //throw new JCCFrameworkException(e); } finally { // 資源の解放 try { if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } // OM-2017-0000488 2017/05/26 ADD START if (con != null) { CAANConnectionMgr.getInstance().close(con); } // OM-2017-0000488 2017/05/26 ADD END } catch(SQLException e) { inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw e; //throw new JCCFrameworkException(e); } } //(3) 電子ファイル情報の登録(機能コードが"2"の場合は呼び出しは行わない。) if(!inCBSMsg.getString(ECC0041C010CBSMsg.FUNC_CODE).equals("2")) { //@ 電子ファイル登録部品を呼び出し、電子ファイル管理テーブルへ電子ファイルの登録を行う。 // （引数：コネクションオブジェクト、圧縮後電子ファイルパス、作業用ディレクトリパス、CBSMsg(電子ファイル管理番号)、CBSMsg(世代登録年月日時分秒)、 // 　CBSMsg(システムコード)、CBSMsg(ファイルコード)、CBSMsg(物理ファイル名)、CBSMsg(ファイルサイズ)、CBSMsg(圧縮ファイルサイズ)、CBSMsg(ファイル削除年月日時分秒） try { /*CC0041ETMsg etMsg = jCCejbEFile.createEFileInfo(inCBSMsg, asshukuFilePath, dirCompTmp, eFileKanriNo, inCBSMsg.getString(ECC0041C010CBSMsg.GENE_ADD_DTM), inCBSMsg.getString(ECC0041C010CBSMsg.SYS_CD), inCBSMsg.getString(ECC0041C010CBSMsg.FILE_CD), inCBSMsg.getString(ECC0041C010CBSMsg.BUTSURI_FILE_NM), inCBSMsg.getString(ECC0041C010CBSMsg.FILE_SIZE), inCBSMsg.getString(ECC0041C010CBSMsg.ASSHUKU_FILE_SIZE), inCBSMsg.getString(ECC0041C010CBSMsg.FILE_DEL_YMD));*/ String eventId = EventIDList.ICC0041D001; String templateId = inCBSMsg.getString(ECC0041C010CBSMsg.TEMPLATEID); String identifyCd = inCBSMsg.getString(ECC0041C010CBSMsg.IDENTIFYCD); // String status = inCBSMsg.getString(ECC0041C010CBSMsg.STATUS); int status = inCBSMsg.getInt(ECC0041C010CBSMsg.STATUS); String operatorId = inCBSMsg.getString(ECC0041C010CBSMsg.OPERATORID); String operatedate = inCBSMsg.getString(ECC0041C010CBSMsg.OPERATEDATE); String operateDtm = inCBSMsg.getString(ECC0041C010CBSMsg.OPERATEDATETIME); String acGroupCd = inCBSMsg.getString(ECC0041C010CBSMsg.AC_GROUP_CD); String functionCd = inCBSMsg.getString(ECC0041C010CBSMsg.FUNC_CODE); String eFilePath = asshukuFilePath; // String workPath = dirCompTmp; String eFileKanriNo = inCBSMsg.getString(ECC0041C010CBSMsg.EFILE_KANRI_NO); String geneAddDtm =inCBSMsg.getString(ECC0041C010CBSMsg.GENE_ADD_DTM); String sysCd = inCBSMsg.getString(ECC0041C010CBSMsg.SYS_CD); String fileCd = inCBSMsg.getString(ECC0041C010CBSMsg.FILE_CD); String butsuriFileNm = inCBSMsg.getString(ECC0041C010CBSMsg.BUTSURI_FILE_NM); // String fileSize = inCBSMsg.getString(ECC0041C010CBSMsg.FILE_SIZE); String asshukuFileSize = inCBSMsg.getString(ECC0041C010CBSMsg.ASSHUKU_FILE_SIZE); // String fileDelYmd = inCBSMsg.getString(ECC0041C010CBSMsg.FILE_DEL_YMD); // String eFile = inCBSMsg.getString(ECC0041C010CBSMsg.EFILE); CAANMsg cAANMsg = jCCejbEFile.createEFileInfo(eventId, templateId, identifyCd, status, operatorId, operatedate, operateDtm, acGroupCd, functionCd, eFilePath, removeTmpDir, eFileKanriNo, geneAddDtm, sysCd, fileCd, butsuriFileNm, fileSize, asshukuFileSize, fileDelYmd); //CC0041ETMsg etMsg; //B A以外の場合、CBSMsgに以下の値を設定し、処理を終了する。 // ・ CBSMsg（更新年月日時分秒）へ部品より返却された更新日時を設定する。 // ・ CBSMsg（登録年月日時分秒）へ部品より返却された更新日時を設定する。 // ・ CBSMsg（更新オペレータアカウント）へCBSMsgの共通部へ設定されているオペレータアカウントを設定する。 // ・ CBSMsg（登録オペレータアカウント）へCBSMsgの共通部へ設定されているオペレータアカウントを設定する。 // ・ CBSMsg（無効フラグ）へ"0:有効"を設定する。 inCBSMsg.set(ECC0041C010CBSMsg.UPD_DTM,cAANMsg.getString(CC0041ETMsg.UPD_DTM)); inCBSMsg.set(ECC0041C010CBSMsg.ADD_DTM,cAANMsg.getString(CC0041ETMsg.ADD_DTM)); inCBSMsg.set(ECC0041C010CBSMsg.UPD_OPEACNT, cAANMsg.getString(CC0041ETMsg.UPD_OPEACNT)); inCBSMsg.set(ECC0041C010CBSMsg.ADD_OPEACNT, cAANMsg.getString(CC0041ETMsg.ADD_OPEACNT)); inCBSMsg.set(ECC0041C010CBSMsg.MK_FLG, "0"); } catch(JCCFrameworkException e) { //A 部品からJCCFrameworkExceptionが返却された場合、CBSMsgに以下の値を設定し、JCCFrameworkExceptionをスローし、処理を終了する。 // ・ ステータス：「更新時DBエラー」 inCBSMsg.set(ECC0041C010CBSMsg.STATUS, StatusCodes.UPDATE_DB_ERR); throw e; } //B A以外の場合、CBSMsgに以下の値を設定し、処理を終了する。 // ・ CBSMsg（更新年月日時分秒）へ部品より返却された更新日時を設定する。 // ・ CBSMsg（登録年月日時分秒）へ部品より返却された更新日時を設定する。 // ・ CBSMsg（更新オペレータアカウント）へCBSMsgの共通部へ設定されているオペレータアカウントを設定する。 // ・ CBSMsg（登録オペレータアカウント）へCBSMsgの共通部へ設定されているオペレータアカウントを設定する。 // ・ CBSMsg（無効フラグ）へ"0:有効"を設定する。 /* inCBSMsg.set(ECC0041C010CBSMsg.UPD_DTM, updDtm); inCBSMsg.set(ECC0041C010CBSMsg.ADD_DTM, updDtm); inCBSMsg.set(ECC0041C010CBSMsg.UPD_OPEACNT, inCBSMsg.getString(ECC0041D010CBSMsg.OPERATORID)); inCBSMsg.set(ECC0041C010CBSMsg.ADD_OPEACNT, inCBSMsg.getString(ECC0041D010CBSMsg.OPERATORID)); inCBSMsg.set(ECC0041C010CBSMsg.MK_FLG, "0"); */ } if (inCBSMsg.getString(ECC0041C010CBSMsg.FUNC_CODE).equals("2")) { try { JCCFileUtil.removeDir(removeTmpDir); } catch (Exception e) { } } return; } }