/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKDmSendTrgtIktAdd * ソースファイル名 ：JBSbatKKDmSendTrgtIktAdd.java * 作成者 ：富士通　 * 作成日 ：2014年03月31日 *＜機能概要＞ *　ＤＭ送付対象一括登録部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2014/03/31 富士通 新規作成 * v10.00.00 2014/11/05 FJ)阪口 【ANK-2307-00-00】E-PON⇒GE-PON設備切替ＤＭ発送ＣＳＶに項目タイトルと工事案件番号追加 *********************************************************************/ package eo.business.service; import java.io.IOException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import eo.business.common.JBSbatBusinessService; import eo.business.common.JCCBatCommon; import eo.business.common.JKKBatCommon; import eo.business.common.JKKBatConst; import eo.business.util.file.JBSbatKKIFM589; import eo.business.util.file.JBSbatKKIFM591; import eo.common.constant.JKKStrConst; import eo.common.constant.JPCBatchMessageConstant; import eo.common.util.JCCFileUtil; import eo.framework.application.JBSbatBusinessException; import eo.framework.application.JCCbatFrameworkException; import eo.framework.db.JBSbatSQLAccess; import eo.framework.file.JBSbatDefFileUtil; import eo.framework.file.JBSbatOutputFileUtil; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.util.JBSbatAplConst; import eo.framework.util.JBSbatBusinessFileUtil; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKDmSendTrgtIktAdd extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(業務パラメータ管理)*/ private static final String D_TBL_NAME_ZM_M_WORK_PARAM_KNRI = "ZM_M_WORK_PARAM_KNRI"; /** テーブル(ダウンロードファイル管理)*/ private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI"; /** テーブルアクセスクラス(業務パラメータ管理)*/ private JBSbatSQLAccess db_ZM_M_WORK_PARAM_KNRI = null; /** テーブルアクセスクラス(ダウンロードファイル管理)*/ private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** 入力ファイル */ private static final String FILE_NAME = "工事予定配送情報ファイル"; // ＣＡＳＥファイル関連 ------------------------------------------------------------------------ /** ファイル出力文字列(加入者) */ private static final String FILE_KNYSHA = "加入者"; /** ファイル出力文字列(クローズ) */ private static final String FILE_CLOSE = "クローズ"; /** ファイル出力文字列(処理中) */ private static final String FILE_TRN = "処理中"; /** ファイル出力文字列(バッチＩＤ) */ private static final String FILE_BATCH_ID = "KKPRC51601"; /** ファイル出力文字列(他システム) */ private static final String FILE_TSYS = "他システム"; /** ファイル出力文字列(タイトル) */ private static final String FILE_TITLE = "【Ｅ−ＰＯＮ計画巻取り】ＤＭ発送（１回目）"; /** 件数ファイル括り文字 */ private static final String SCOPE = "\""; /** CASEファイル出力件数 */ private int outmapCnt = 0; // -------------------------------------------------------------------------------------------- /** ファイル出力文字列(様) */ private static final String FILE_SAMA = "様"; /** 設備切替ＤＭ送付対象ダウンロードファイル処理管理番号 **/ private static final String TRAN_KANRI_NO_DMSEND = "000000000118"; /** 設備切替ＤＭ送付対象ダウンロードファイル名 **/ private static final String DMSENDFILENAME = "設備切替DM送付対象"; /** 設備切替ＤＭ送付対象電子ファイル削除日数 **/ private String efileDelYmd = "20991231"; /** ファイル名で使用するシステム日付 **/ private String sysDate = null; /** ファイルコード **/ private String FILE_CD = "0000"; /** ファイルパス **/ private String fPath = ""; /** 出力ファイルリストにデータを出力する */ private List> outMapList = new ArrayList>(); /** ファイル連携先ディレクトリ定義キー */ private static final String CR_FILE_DIR_KEY = "CR_TWS_RK_FILE_DIR"; /** ファイル名(共通部) */ private static final String CASEFILE_NAME = "CASE_DMSEND_"; /** ＣＡＳＥＣＳＶファイル */ private JBSbatBusinessFileUtil caseCvsFileObj = null; /** ＣＡＳＥ件数ファイル */ private JBSbatBusinessFileUtil caseCntFileObj = null; /** ＣＡＳＥフラグファイル */ private JBSbatBusinessFileUtil caseFlgFileObj = null; /** 改行コード */ private static final String RETURN_CODE = "\r\n"; /** CASECSVファイル */ private String caseCsvFile; /** CASE件数 */ private String caseCntFile; /** CASEフラグファイル */ private String caseFlgFile; /** 初回フラグ */ private String fstFlg = "Y"; /** 出力共通電文保持*/ // private JBSbatOutputItem outputItem = null; /** * ファイル出力の属性宣言 */ private enum OutFileType { /** 設備切替ＤＭ送付対象ダウンロードファイル **/ KKIFM589(JKKStrConst.MID_ENV_DIR, DMSENDFILENAME + "_" + JKKStrConst.FILE_NM_TIMESTAMP , "KKIFM589.def", "設備切替ＤＭ送付対象ダウンロードファイル"); /** ファイルパス */ private final String FILEPATH; /** ファイル名 */ private final String FILENAME; /** defファイル名 */ private final String DEFNAME; /** 日本語ファイル名 */ private final String FILEJPNAME; /** * ファイル出力宣言のコンストラクタ * @param filePath ファイルパス * @param fileName ファイル名 * @param defName defファイル名 * @param fileJPName 日本語ファイル名 */ private OutFileType(String filePath, String fileName, String defName, String fileJPName) { this.FILEPATH = filePath; this.FILENAME = fileName; this.DEFNAME = defName; this.FILEJPNAME = fileJPName; } } /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_ZM_M_WORK_PARAM_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_WORK_PARAM_KNRI); db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ // 出力ファイル情報 // outputItem = new JBSbatOutputItem(); // 格納先ディレクトリ情報を取得する String sFileDir = JKKBatCommon.getApplicationConst(CR_FILE_DIR_KEY) + "/"; // ファイル名に使用する日時情報(yyyymmddhhmmss)を取得する String sSysData = JKKBatCommon.getSysDateTime().substring(0, 14); // CASECSVファイル caseCsvFile = sFileDir + CASEFILE_NAME + sSysData + ".CSV"; // CASE件数 caseCntFile = sFileDir + CASEFILE_NAME + sSysData + "_CNT.TXT"; // CASEフラグファイル caseFlgFile = sFileDir + CASEFILE_NAME + sSysData + "_FTP.FLG"; //システム日付を取得する。 sysDate = JCCBatCommon.getSysDateTime(); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ // 出力共通電文を生成 // JBSbatOutputItem outputItem = new JBSbatOutputItem(); // 入力レコードに異常があった場合 if (inMap.isInputErrorFlg()) { // 業務エラーログ出力 super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB0100AE, new String[] {FILE_NAME}); // エラーフラグ設定 super.commonItem.setErrFlg(true); return null; } /* ++++++++++ v10.00.00 追加開始 ++++++++++ */ // 1件目処理の場合、設備切替ＤＭ送付対象ファイルにヘッダを出力する if (outmapCnt == 0) { outMapList.add(setDmFileHeader()); } /* ++++++++++ v10.00.00 追加終了 ++++++++++ */ // 設備切替ＤＭ送付対象ファイルにデータを出力 outMapList.add(setDmFileData(inMap)); // ＤＭ送付対象ＣＡＳＥファイル（ＣＳＶ）にデータを出力 setCaseCsvFileData(inMap); // CASEファイル出力件数をカウントアップ this.outmapCnt++; //return outputItem; return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_ZM_M_WORK_PARAM_KNRI.close(); db_ZM_T_DL_FILE_KANRI.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ // 入力データ０件の場合でも処理を行う // ファイル出力用リストを返却用パラメータにセットする fPath = putKKFile(OutFileType.KKIFM589, outMapList, false); //電子ファイル管理テーブル、ダウンロード管理テーブルに登録する。 addEfileKanri(); // ＣＡＳＥ件数ファイルを作成する（入力データ０件の場合は出力しない） if (this.outmapCnt > 0) { try { // CASE件数ファイルを生成する。 caseCntFileObj = JCCBatCommon.createBusinessFileUtil(caseCntFile, JKKBatConst.SJIS, RETURN_CODE, JKKBatConst.SPACE); // CASE件数ファイルへ出力する。 JCCBatCommon.printBusinessFileUtil(caseCntFileObj, String.valueOf(this.outmapCnt)); // CASEフラグファイルを生成する。 caseFlgFileObj = JCCBatCommon.createBusinessFileUtil(caseFlgFile, JKKBatConst.SJIS, JKKBatConst.SPACE, JKKBatConst.SPACE); } catch (Exception e) { // 生成ファイルのクローズ処理 if (null != caseCvsFileObj) { JKKBatCommon.closeBusinessFileUtil(caseCvsFileObj); } if (null != caseCntFileObj) { JKKBatCommon.closeBusinessFileUtil(caseCntFileObj); } if (null != caseFlgFileObj) { JKKBatCommon.closeBusinessFileUtil(caseFlgFileObj); } throw e; } // 生成ファイルのクローズ処理 if (null != caseCvsFileObj) { JKKBatCommon.closeBusinessFileUtil(caseCvsFileObj); } if (null != caseCntFileObj) { JKKBatCommon.closeBusinessFileUtil(caseCntFileObj); } if (null != caseFlgFileObj) { JKKBatCommon.closeBusinessFileUtil(caseFlgFileObj); } } /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /** * PK(全項目登録)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で設定項目マップを作ります。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	ファイル番号				FILE_NO
	 *		 	処理管理番号				TRN_KANRI_NO
	 *		 	電子ファイル管理番号				EFILE_KANRI_NO
	 *		 	ファイル名				FILE_NM
	 *		 	ファイルサイズ				FILE_SIZE
	 *		 	データ件数				DATA_CNT
	 *		 	ファイル登録年月日時分秒				FILE_ADD_DTM
	 *		 	ファイル削除年月日				FILE_DEL_YMD
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 *		 	登録運用年月日				ADD_UNYO_YMD
	 *		 	登録処理ＩＤ				ADD_TRN_ID
	 *		 	更新運用年月日				UPD_UNYO_YMD
	 *		 	更新処理ＩＤ				UPD_TRN_ID
	 *		 	削除運用年月日				DEL_UNYO_YMD
	 *		 	削除処理ＩＤ				DEL_TRN_ID
	 *
*

* @param setParam 設定項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeZM_T_DL_FILE_KANRI_PKINSERT(Object[] setParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("FILE_NO", setParam[0]); setMap.setValue("TRN_KANRI_NO", setParam[1]); setMap.setValue("EFILE_KANRI_NO", setParam[2]); setMap.setValue("FILE_NM", setParam[3]); setMap.setValue("FILE_SIZE", setParam[4]); setMap.setValue("DATA_CNT", setParam[5]); setMap.setValue("FILE_ADD_DTM", setParam[6]); setMap.setValue("FILE_DEL_YMD", setParam[7]); setMap.setValue("ADD_DTM", setParam[8]); setMap.setValue("ADD_OPEACNT", setParam[9]); setMap.setValue("UPD_DTM", setParam[10]); setMap.setValue("UPD_OPEACNT", setParam[11]); setMap.setValue("DEL_DTM", setParam[12]); setMap.setValue("DEL_OPEACNT", setParam[13]); setMap.setValue("MK_FLG", setParam[14]); setMap.setValue("ADD_UNYO_YMD", setParam[15]); setMap.setValue("ADD_TRN_ID", setParam[16]); setMap.setValue("UPD_UNYO_YMD", setParam[17]); setMap.setValue("UPD_TRN_ID", setParam[18]); setMap.setValue("DEL_UNYO_YMD", setParam[19]); setMap.setValue("DEL_TRN_ID", setParam[20]); // DBアクセスを実行します db_ZM_T_DL_FILE_KANRI.insertByPrimaryKeys(setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * ＤＭ送付対象ＣＡＳＥファイル（ＣＳＶ）にデータを設定します。
*

* 処理フロー
* 

	 * 1.ＤＭ送付対象ＣＡＳＥファイル（ＣＳＶ）に出力するデータを設定する。

	 *
*

* @param inMap 入力電文 * @return JBSbatServiceInterfaceMap 入出力インターフェースマップ * @throws Exception */ private void setCaseCsvFileData(JBSbatServiceInterfaceMap inMap) throws Exception { // CASEファイル出力リスト ArrayList smlnMkjTsCjkDataList = new ArrayList(); // 顧客タイプ outputVal(FILE_KNYSHA, smlnMkjTsCjkDataList); // お客様ID outputVal(inMap.getString(JBSbatKKIFM591.SVC_KEI_NO), smlnMkjTsCjkDataList); // 顧客氏名 outputVal(inMap.getString(JBSbatKKIFM591.CUST_NM), smlnMkjTsCjkDataList); // 顧客氏名（カナ） outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 電話番号 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 電話番号2 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 郵便番号 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 住所1 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 住所2 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 住所3 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 性別 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 生年月日 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 状態 outputVal(FILE_CLOSE, smlnMkjTsCjkDataList); // ステータス outputVal(FILE_TRN, smlnMkjTsCjkDataList); // 作成日時 outputVal(JKKBatCommon.formatDatetimeSS(JKKBatCommon.getSysDateTime()), smlnMkjTsCjkDataList); // 受付者 outputVal(FILE_BATCH_ID, smlnMkjTsCjkDataList); // 担当者 outputVal(FILE_BATCH_ID, smlnMkjTsCjkDataList); // キュー名 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 受付種別 outputVal(FILE_TSYS, smlnMkjTsCjkDataList); // タイトル outputVal(FILE_TITLE, smlnMkjTsCjkDataList); // カテゴリ１ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ２ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ３ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ４ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ５ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ６ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ７ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ８ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ９ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ１０ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // カテゴリ１１ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 問い合わせ履歴 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 問合せ客ID outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // eoID outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 申込書番号 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // コールバック日時 outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // コールバック時間指定タイプ outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); // 業務個別設定組織コード outputVal(JKKBatConst.SPACE, smlnMkjTsCjkDataList); if (fstFlg.equals("Y")) { // CASECSVファイルを生成する。 caseCvsFileObj = JCCBatCommon.createBusinessFileUtil(caseCsvFile, JKKBatConst.SJIS, RETURN_CODE, JKKBatConst.CONMA); fstFlg = "N"; } // CASECSVファイルへ出力する。 JCCBatCommon.printBusinessFileUtil(caseCvsFileObj, smlnMkjTsCjkDataList); } /* ++++++++++ v10.00.00 追加開始 ++++++++++ */ /** * 設備切替ＤＭ送付対象ファイルのヘッダを設定する * @return convertMap * @throws Exception */ private Map setDmFileHeader() throws Exception { Map convertMap = new HashMap(); // お客様名 convertMap.put(JBSbatKKIFM589.CUST_NM, "契約者名"); // 敬称 convertMap.put(JBSbatKKIFM589.KEISHO, "敬称"); // 郵便番号 convertMap.put(JBSbatKKIFM589.PCD, "郵便番号"); // 住所１ convertMap.put(JBSbatKKIFM589.STATE_CITY_NM, "現住所"); // 住所２ convertMap.put(JBSbatKKIFM589.OAZTSU_BNCHIGO, "現住所　住所２"); // 住所３ convertMap.put(JBSbatKKIFM589.ADRTTM_ADRRM, "現住所　住所３"); // お客様ＩＤ convertMap.put(JBSbatKKIFM589.CUST_ID, "お客様ID"); // 工事案件番号 convertMap.put(JBSbatKKIFM589.KOJIAK_NO, "工事案件番号"); return convertMap; } /* ++++++++++ v10.00.00 追加終了 ++++++++++ */ /** * ファイル出力型式に変換する。 * @param dateMap * @return convertMap * @throws Exception */ private Map setDmFileData(JBSbatServiceInterfaceMap inMap) throws Exception { Map convertMap = new HashMap(); StringBuffer sb = new StringBuffer(); // お客様名 convertMap.put(JBSbatKKIFM589.CUST_NM, inMap.getString(JBSbatKKIFM591.CUST_NM)); // 敬称 convertMap.put(JBSbatKKIFM589.KEISHO, FILE_SAMA); // 郵便番号 sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_PCD).substring(0, 3)); sb.append("-"); sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_PCD).substring(3, 7)); convertMap.put(JBSbatKKIFM589.PCD, sb.toString()); sb.delete(0, 9999); // 住所１ sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_STATE_NM)); sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_CITY_NM)); convertMap.put(JBSbatKKIFM589.STATE_CITY_NM, sb.toString()); sb.delete(0, 9999); // 住所２ sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_OAZTSU_NM)); sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_AZCHO_NM)); sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_BNCHIGO)); convertMap.put(JBSbatKKIFM589.OAZTSU_BNCHIGO, sb.toString()); sb.delete(0, 9999); // 住所３ sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_ADRTTM)); sb.append(inMap.getString(JBSbatKKIFM591.KAISEN_PLACE_ADRRM)); convertMap.put(JBSbatKKIFM589.ADRTTM_ADRRM, sb.toString()); sb.delete(0, 9999); // お客様ＩＤ convertMap.put(JBSbatKKIFM589.CUST_ID, inMap.getString(JBSbatKKIFM591.SVC_KEI_NO)); /* ++++++++++ v10.00.00 追加開始 ++++++++++ */ // 工事案件番号 convertMap.put(JBSbatKKIFM589.KOJIAK_NO, inMap.getString(JBSbatKKIFM591.KOJIAK_NO)); /* ++++++++++ v10.00.00 追加終了 ++++++++++ */ return convertMap; } /** * 電子ファイルスキーマ登録 * @throws Exception */ private void addEfileKanri() throws Exception { // 電子ファイル管理スキーマ登録 String[] eFileInfo = new String[]{}; try { eFileInfo = JCCBatCommon.createDenshiFile(commonItem, FILE_CD, fPath, efileDelYmd); } catch(JCCbatFrameworkException jccBatFraExc) { // ファイル作成に失敗した場合(FWに渡す) commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0510CE, new String[] {"電子ファイル管理", "(FILE_CD=".concat(FILE_CD).concat(",filePath=").concat(fPath)}); throw jccBatFraExc; } // ダウンロードファイル管理スキーマ登録 insZmTDlFileKanri(eFileInfo); } /** * ダウンロードファイル管理スキーマに登録します。 * * @param eFileInfo 電子ファイル管理情報 * @throws Exception 業務サービス内で発生した例外全般 */ private void insZmTDlFileKanri(String[] eFileInfo) throws Exception { JBSbatCommonDBInterface param = new JBSbatCommonDBInterface(); // 1.ファイル番号 param.setValue(JCCBatCommon.getFormatedNextSeq(commonItem, JKKStrConst.SEQ_FILE_NO, JKKStrConst.SEQ_PREFIX_SEQ_FILE_NOO, JKKStrConst.SEQ_LEN_SEQ_FILE_NO)); // 2.処理管理番号 //param.setValue(JKKStrConst.TRAN_KANRI_NO_MSKM_JSK); param.setValue(TRAN_KANRI_NO_DMSEND); // 3.電子ファイル管理番号 param.setValue(eFileInfo[0]); // 4.ファイル名 String[] fileName = fPath.split("/", -1); param.setValue(fileName[fileName.length - 1]); // 5.ファイルサイズ param.setValue(JCCFileUtil.getFileSize(fPath)); // 6.データ件数 param.setValue(outmapCnt); // 7.ファイル登録年月日時分秒 param.setValue(eFileInfo[1]); // 8.ファイル削除年月日 param.setValue(null); // 9.登録年月日時分秒 param.setValue(null); // 10.登録オペレータアカウント param.setValue(null); // 11.更新年月日時分秒 param.setValue(null); // 12.更新オペレータアカウント param.setValue(null); // 13.削除年月日時分秒 param.setValue(null); // 14.削除オペレータアカウント param.setValue(null); // 15.無効フラグ param.setValue(null); //登録運用年月日 param.setValue("ADD_UNYO_YMD"); //登録処理ID param.setValue("ADD_TRN_ID"); //更新運用年月日 param.setValue("UPD_UNYO_YMD"); //更新処理ID param.setValue("UPD_TRN_ID"); //削除運用年月日 param.setValue(null); //削除処理ID param.setValue(null); // SQL実行 executeZM_T_DL_FILE_KANRI_PKINSERT(param.getList().toArray()); } /** * ファイルタイプからファイルパスを作成する * @param fileType ファイルタイプ * @return ファイルパス * @throws Exception 例外 */ private String createOutFileType2FilePath(OutFileType fileType) throws Exception { String filePath = rnktPath(JBSbatAplConst.getAplConstValue(JKKStrConst.MID_ENV_DIR), fileType.FILENAME); return filePath.replaceAll(JKKStrConst.FILE_TIMESTAMP_FORMAT, getOpeDateTime()); } /** * ファイルの出力処理 * @param fileType 出力ファイルタイプ * @param dataList 出力データ * @param doubleFlg * @return 出力ファイル名 * @throws Exception 例外 */ private String putKKFile(OutFileType fileType, List> dataList, boolean doubleFlg) throws Exception { String filePath = createOutFileType2FilePath(fileType); // 出力ファイル形式設定 JBSbatOutputFileUtil outFile = new JBSbatOutputFileUtil(filePath); outFile.setEncode(JKKStrConst.ENCODE_SJIS); // 文字コード outFile.setLine(JKKStrConst.LINE_LF); // 改行コード try { outFile.createWriter(); } catch (IOException ex) { commonItem.getConnection().rollback(); commonItem.getLogPrint().printBusinessErrorLog(fileType.FILEJPNAME + "作成失敗"); throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0500CE, new String[] {"(ファイルパス:" + filePath + ")"}); } try { String defFile = this.rnktPath(JBSbatAplConst.getAplConstValue(JKKStrConst.KK_DIR_IND), fileType.DEFNAME); JBSbatDefFileUtil defDataUtil = new JBSbatDefFileUtil(defFile, outFile); JBSbatServiceInterfaceMap outDataMap = null; String data = ""; for (Map dataMap : dataList) { outDataMap = new JBSbatServiceInterfaceMap(); for (String key : dataMap.keySet()) { data = (String)dataMap.get(key); if (doubleFlg) { data = encloseDQuot(data); } outDataMap.set(key, data); } outFile.print(outDataMap, defDataUtil); } } catch (IOException ex) { commonItem.getConnection().rollback(); commonItem.getLogPrint().printBusinessErrorLog(fileType.FILEJPNAME + "書き込み失敗"); throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0970CE, new String[] {""}); } finally { // ファイルのクローズ try { outFile.close(); } catch (IOException ex2) { commonItem.getConnection().rollback(); super.logPrint.printDebugLog("ファイル書込みオブジェクトのクローズ失敗:" + filePath); throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0970CE, new String[] {""}); } } return filePath; } /** * パス文字列の連結 * 連結するパス文字列にパス区切り文字の設定を制御する。 * @param path1 パス文字列 * @param path2 パス文字列 * @return 連結したパス文字列 */ private String rnktPath(String path1, String path2) { String pathDlmt = JKKStrConst.PATH_DLMT_UNIX; if (path1.indexOf(JKKStrConst.PATH_DLMT_WIN) > -1 || path2.indexOf(JKKStrConst.PATH_DLMT_WIN) > -1) { pathDlmt = JKKStrConst.PATH_DLMT_WIN; } if (!path1.endsWith(pathDlmt)) { return path1 + pathDlmt + path2; } return path1 + path2; } /** * 運用日付時分秒の取得を行います。
*

* 処理フロー
* 

	 * 1.運用日付(yyyyMMdd) + システム日時(hhmmss)を返却します。

	 *
*

* @return String 運用日付時分秒。 * @throws Exception 業務サービス内で発生した例外全般。 */ private String getOpeDateTime() throws Exception { StringBuffer dateTime = new StringBuffer(); dateTime.append(sysDate); return dateTime.toString(); } /** * ダブルクォーテーション囲みを行います。
*

* 処理フロー
* 

	 * 1.引数で囲み対象文字を設定します。

	 *
*

* @param strTarget 囲み対象文字 * @return strRec 文字列連結結果を返却します。 */ private String encloseDQuot(String strTarget) { if (null == strTarget) { return "\"\""; } return "\"" + strTarget + "\""; } /** * 出力用文字列の作成処理です。 * * @param value 対象文字列 * @param list 出力対象リスト * @return 対象文字列の結合情報 */ private static List outputVal(String value, List list) { list.add(SCOPE + value + SCOPE); return list; } }