/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACProcReqUpd
*	ソースファイル名	：JBSbatACProcReqUpd.java
*	作成者				：富士通　
*	作成日				：2012年06月21日
*＜機能概要＞
*　処理依頼更新部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v3.00.00	2012/06/21  山下		新規作成
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.util.file.JBSbatACIFM099;
import eo.business.util.table.JBSbatCC_T_EFILE_KANRI;
import eo.common.constant.JACStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JCCFileUtil;
import eo.common.util.JPCUtilCommon;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatACProcReqUpd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(電子ファイル管理)*/
	private static final String D_TBL_NAME_CC_T_EFILE_KANRI = "CC_T_EFILE_KANRI";

	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

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

	/** テーブルアクセスクラス(電子ファイル管理)*/
	private JBSbatSQLAccess db_CC_T_EFILE_KANRI = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 処理結果コード（業務エラー） */
	private static final String RSLT_CD_ERR = "2";
	
	/** ファイル絶対パス */
	private String filePath = null;
	
	/** データ件数*/
	private String dataCount = null;
	
	/** ダウンロード管理登録制御フラグ*/
	private String dlKnrFlg = null;
	
	/** 処理管理番号*/
	private String trnKanriNo = null;
	
	/** ダウンロード管理登録制御フラグが"1"（登録）*/
	private static final String DLTOUROKU = "1";
	
	/** シーケンス接頭辞（ファイル番号） */
	private static final String SEQ_PREFIX_SEQ_FILE_NOO = "";
	
	/** シーケンス桁数（ファイル番号） */
	private static final int SEQ_LEN_SEQ_FILE_NO = 12;

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_CC_T_EFILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_EFILE_KANRI);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
		
		// フリー項目分割
		String[] freeItem = super.freeItem.split(JACStrConst.FREE_DIV, -1);
		this.filePath = freeItem[0];
		this.trnKanriNo = freeItem[1];
		this.dataCount = freeItem[2];
		this.dlKnrFlg = freeItem[3];

		assert this.filePath != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][filePath = " + this.filePath + "]") : true;
		assert this.trnKanriNo != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][trnKanriNo = " + this.trnKanriNo + "]") : true;
		assert this.dataCount != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][dataCount = " + this.dataCount + "]") : true;
		assert this.dlKnrFlg != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][dlKnrFlg = " + this.dlKnrFlg + "]") : true;
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		
		// 処理依頼番号
		String dlydIrnReqNo = inMap.getString(JBSbatACIFM099.DLYD_TRN_REQ_NO);
		// 処理結果コード
		String dlyTrnRsltCd = inMap.getString(JBSbatACIFM099.DLYD_TRN_RSLT_CD);
		// エラーファイルパス
		String errorFilePath = null;
		if (RSLT_CD_ERR.equals(dlyTrnRsltCd))
		{
			// エラーファイルパスを設定
			errorFilePath = this.filePath;
		}

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][dlydIrnReqNo=" + dlydIrnReqNo + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][dlyTrnRsltCd=" + dlyTrnRsltCd + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][errorFilePath=" + errorFilePath + "]");
		
		// ディレイド処理依頼スキーマ更新（ディレイド処理依頼管理部品呼び出し）
		HashMap<String, String> retMap = JCCbatShoriIraiUtil.updateShoriIraiResult(super.commonItem, dlydIrnReqNo, dlyTrnRsltCd, errorFilePath);
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][retMap=" + retMap.toString() + "]");
		

		// 電子ファイル管理番号を取得
		String eFileKanriNo = retMap.get("EFILE_KAMRI_NO");
		// ダウンロード管理制御フラグが"1"(登録)の場合、ダウンロード管理テーブルに登録する
		if(DLTOUROKU.equals(dlKnrFlg) && eFileKanriNo != null)
		{
			// ダウンロードファイル管理スキーマ登録
			insZmTDlFileKanri(eFileKanriNo);
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		
		return null;
		
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CC_T_EFILE_KANRI.close();
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
		
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(AC_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 executeCC_T_EFILE_KANRI_AC_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

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

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		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
	 * </pre>
	 * <p>
	 * @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]);
	
		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * ダウンロードファイル管理スキーマに登録します。
	 * 
	 * @param eFileInfo 電子ファイル管理情報
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void insZmTDlFileKanri(String eFileKanriNo) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][insZmTDlFileKanri]");

		// 電子ファイル管理の情報を取得
		JBSbatCommonDBInterface eFileInfo = this.selectCcTEfileKanri(eFileKanriNo);
		
		// 設定値
		JBSbatCommonDBInterface param = new JBSbatCommonDBInterface();
		//  1.ファイル番号
		param.setValue(JCCBatCommon.getFormatedNextSeq(super.commonItem, JACStrConst.SEQ_FILE_NO, SEQ_PREFIX_SEQ_FILE_NOO, SEQ_LEN_SEQ_FILE_NO));
		//  2.処理管理番号
		param.setValue(this.trnKanriNo);
		//  3.電子ファイル管理番号
		param.setValue(eFileKanriNo);
		//  4.ファイル名
		String[] fileName = this.filePath.split(JACStrConst.SLASH, -1);
		param.setValue(fileName[fileName.length - 1]);
		//  5.ファイルサイズ
		param.setValue(JCCFileUtil.getFileSize(this.filePath));
		//  6.データ件数
		param.setValue(this.dataCount);
		//  7.ファイル登録年月日時分秒
		param.setValue(eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.ADD_DTM));
		//  8.ファイル削除年月日
		param.setValue(eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.FILE_DEL_YMD));
		//  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);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][insZmTDlFileKanri][param = " + param.getList().toString() + "]");

		// SQL実行
		executeZM_T_DL_FILE_KANRI_PKINSERT(param.getList().toArray());

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][insZmTDlFileKanri]");
	}
	
	/**
	 * 電子ファイル管理スキーマより、電子ファイル管理の情報を取得します。
	 * 
	 * @param eFileNO 		電子ファイル管理番号
	 * @return dbMap		電子ファイル管理の情報
	 * @throws Exception 　業務サービス内で発生した例外全般
	 */
	private JBSbatCommonDBInterface selectCcTEfileKanri(String eFileKanriNo) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectCcTEfileKanri]");
		
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		paramList.setValue(eFileKanriNo);				// 電子ファイル管理番号
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCcTEfileKanri][paramList=" + paramList.getList().toString() + "]");

		// SQL実行
		executeCC_T_EFILE_KANRI_AC_SELECT_001(paramList.getList().toArray());
		
		// 結果取得
		JBSbatCommonDBInterface dbMap = db_CC_T_EFILE_KANRI.selectNext();
		
		if (dbMap == null)
		{
			// DB未存在エラー
			String[] msgParam = new String[]
			{ JBSbatCC_T_EFILE_KANRI.TABLE_NAME, JPCUtilCommon.convMapToString(paramList.getMap()) };
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0260CH, msgParam);
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCcTEfileKanri][dbMap=" + dbMap.getMap().toString() + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectCcTEfileKanri]");
		return dbMap;
	}
}