/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JDKEFileKanriBaseService
*	ソースファイル名	：JDKEFileKanriBaseService.java
*	作成者				：富士通　
*	作成日				：2011年09月02日
*＜機能概要＞
*　電子ファイル管理ベースサービス部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/09/02   富士通		新規作成
*	v63.00.00	2022/12/6   FJ)平野  	OM-2022-0001147_DKIFE003玉突き問題
*********************************************************************/
package eo.business.common;

import static eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO;
import static eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO;
import static eo.business.util.table.JBSbatZM_T_DATAIKTTRK_KNRI.FILE_NM;
import static eo.common.constant.JDKStrConst.DLYD_MAP_KEY_INPUT_EFILE;
import static eo.common.constant.JDKStrConst.PATH_DLMT_UNIX;
import static eo.common.constant.JDKStrConst.PATH_DLMT_WIN;
import static eo.common.constant.JDKStrConst.SHORI_IRAI_RESULT_APP_ERROR;
import static eo.common.constant.JPCBatchMessageConstant.EDKB0030CE;
import static eo.common.constant.JPCBatchMessageConstant.EDKB0670CE;
import static eo.common.constant.JPCBatchMessageConstant.EDKB0150KW;

import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
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.common.constant.JDKStrConst;
import eo.common.util.JDKCommonUtil;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.application.JCCbatFrameworkException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public abstract class JDKEFileKanriBaseService extends JBSbatBusinessService
{
	/** テーブル(データ一括登録管理)*/
	private static final String D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI = "ZM_T_DATAIKTTRK_KNRI";

	/** SQL定義キー(DK_SELECT_001)*/
	private static final String ZM_T_DATAIKTTRK_KNRI_DK_SELECT_001 = "DK_SELECT_001";

	/** テーブルアクセスクラス(データ一括登録管理)*/
	private JBSbatSQLAccess db_ZM_T_DATAIKTTRK_KNRI = null;

	/** フラグファイル名 */
	private static final String SKIP_FILENM = "_Skip.flg";

	/** ディレイド処理依頼 */
	protected Map<String, Object> dlydMap = null;

	/** スキップフラグ */
	protected boolean skipFlg = false;

	/**
	 * JobId取得
	 * @return JobId
	 */
	protected abstract String getJobId();
	
	/**
	 * 作成するファイル名（日本語名）を取得する
	 * @return ファイル名
	 */
	protected abstract String getCreateJPFileName();

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_ZM_T_DATAIKTTRK_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI);
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
		skipFlg = false;

		try
		{
			byte[] fileData = getElectoricFileData();
			if (JDKCommonUtil.isNull(fileData))
			{
				skipFlg = true;
				return null;
			}
			createFile(fileData);
		}
		catch (Exception ex)
		{
			skipFlg = true;
			updateShoriIraiResult(SHORI_IRAI_RESULT_APP_ERROR);
			throw ex;
		}

		return null;
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
		// DBアクセスクラスをクローズします
		db_ZM_T_DATAIKTTRK_KNRI.close();
	}

	/**
	 * SQLKEY(DK_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	ディレイド処理依頼番号
	 *		 	電子ファイル管理番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_DATAIKTTRK_KNRI_DK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_ZM_T_DATAIKTTRK_KNRI.selectBySqlDefine(paramList, ZM_T_DATAIKTTRK_KNRI_DK_SELECT_001);
	}

	/**
	 * ファイルを作成します
	 * @param fileData ファイルデータ
	 * @throws Exception
	 */
	private void createFile(byte[] fileData) throws Exception
	{
		
		String fileName = getOutputFileFullPath();
		try
		{
			BufferedOutputStream outFileStream = 
				new BufferedOutputStream(new FileOutputStream(fileName));
			outFileStream.write(fileData);
			outFileStream.close();
		}
		catch (Exception ex)
		{
			String buff = (JDKCommonUtil.isNull(fileName) ? "null" : fileName);
			getCommonItem().getLogPrint().printBusinessErrorLog(getCreateJPFileName() + "作成失敗");
			throw new JBSbatBusinessException(EDKB0030CE, new String[] {buff});
		}
	}

	/**
	 * 出力ファイル名を取得する
	 * @return 出力ファイル名
	 * @throws Exception
	 */
	private String getOutputFileFullPath() throws Exception
	{
		
		String fileName = null;
		Map<String, Object> map = getDlydShoriMap();
// OM-2022-0001147 ADD START
		// パラメータの取得（Freeパラメータ）
		String[] freeParam = getCommonItem().getFreeItem().split(JDKStrConst.FREE_DLMT);
		
		// ファイルの配置先を取得
		String fileDir = freeParam[0];
// OM-2022-0001147 ADD END

		List<String> paramList = new ArrayList<String>();
		paramList.add(map.get(DLYD_TRN_REQ_NO).toString());
		paramList.add(map.get(INPUT_EFILE_KANRI_NO).toString());
		executeZM_T_DATAIKTTRK_KNRI_DK_SELECT_001(paramList.toArray());
		
		JBSbatCommonDBInterface dbMap = this.db_ZM_T_DATAIKTTRK_KNRI.selectNext();
		if (JDKCommonUtil.isNull(dbMap))
		{
			return fileName;
		}

		if (!JDKCommonUtil.isNull(dbMap.getValue(FILE_NM)))
		{
// OM-2022-0001147 ADD START
			if(fileDir != null && !"".equals(fileDir)) 
			{
				fileName = rnktPath(fileDir, dbMap.getValue(FILE_NM).toString());
			}else
			{
// OM-2022-0001147 ADD END
				fileName = rnktPath(getCommonItem().getFreeItem(), dbMap.getValue(FILE_NM).toString());
// OM-2022-0001147 ADD START
			}
// OM-2022-0001147 ADD END
		}
		
		return fileName;
	}

	/**
	 * 電子ファイルを取得します
	 * 
	 * @return 電子ファイルの内容
	 * @throws Exception
	 */
	private byte[] getElectoricFileData() throws Exception
	{
		// ディレイド処理依頼存在チェック
		Map<String, Object> map = getDlydShoriMap();
		if (JDKCommonUtil.isNull(dlydMap))
		{
			return null;
		
		}

		if (JDKCommonUtil.isNull(map.get(DLYD_MAP_KEY_INPUT_EFILE)))
		{
			updateShoriIraiResult(SHORI_IRAI_RESULT_APP_ERROR);
			throw new JBSbatBusinessException(EDKB0150KW, new String[]{"電子ファイル管理", ""});
		}
		return (byte[])map.get(DLYD_MAP_KEY_INPUT_EFILE);
	}
	
	/**
	 * 処理依頼を更新します
	 * @param status ステータス
	 * @throws Exception
	 */
	protected void updateShoriIraiResult(String status) throws Exception
	{
		Map<String, Object> map = getDlydShoriMap();
		if (JDKCommonUtil.isNull(map))
		{
			return;
		}

		String dlydTrnReqNo = map.get(DLYD_TRN_REQ_NO).toString();
		JCCBatCommon.updateShoriIraiResult(getCommonItem(), dlydTrnReqNo, status, null);
		getCommonItem().getConnection().commit();
	}
	
	/**
	 * ディレイド処理依頼を取得する
	 * @return ディレイド処理依頼
	 * @throws Exception
	 */
	private Map<String, Object> getDlydShoriMap() throws Exception
	{

		if (!JDKCommonUtil.isNull(this.dlydMap))
		{
			return this.dlydMap;
		}

		try 
		{
			// ディレイド処理依頼取得
			ArrayList<HashMap<String, Object>> dlydShoriIraiList
						= JCCBatCommon.getShoriIraiInfo(getCommonItem(), getJobId());
	
			// ディレイド処理依頼が存在しなかった場合
			if (JDKCommonUtil.isNull(dlydShoriIraiList))
			{
				return null;
			}

			// ディレイド処理依頼存在チェック
			this.dlydMap = dlydShoriIraiList.get(dlydShoriIraiList.size() - 1);
		}
		catch(JCCbatFrameworkException ex)
		{
			skipFlg = true;
			getCommonItem().getLogPrint().printBusinessErrorLog("ディレイド処理依頼取得失敗");
			throw new JBSbatBusinessException(EDKB0670CE, new String[]{"ディレイド処理依頼", ""});
		}
		return this.dlydMap;
	}



	/**
	 * パス文字列の連結
	 * 連結するパス文字列にパス区切り文字の設定を制御する。
	 * @param path1 パス文字列
	 * @param path2 パス文字列
	 * @return 連結したパス文字列
	 */
	protected String rnktPath(String path1, String path2)
	{
		String pathDlmt = PATH_DLMT_UNIX;
		StringBuffer buff = new StringBuffer();
		
		if (path1.indexOf(PATH_DLMT_WIN) > -1 || path2.indexOf(PATH_DLMT_WIN) > -1)
		{
			pathDlmt = PATH_DLMT_WIN;
		}
		if (!path1.endsWith(pathDlmt))
		{
			return buff.append(path1).append(pathDlmt).append(path2).toString();
		}
		return buff.append(path1).append(path2).toString();
	}
	
	/**
	 * 共通電文を取得する
	 * @return 共通電文
	 */
	private JBSbatCommonItem getCommonItem()
	{
		return this.commonItem;
	}

	/**
	 * フラグファイル名を取得する
	 * @return フラグファイル名
	 */
	private String getFlagFileName()
	{
		return getJobId() + SKIP_FILENM;
	}
	
}