/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSBatKKKepcoGasGcrmTgLstSDCst
*	ソースファイル名	：JBSBatKKKepcoGasGcrmTgLstSDCst.java
*	作成者				：富士通　
*	作成日				：2019年10月15日
*＜機能概要＞
*　関電ガス営業向けＧＣＲＭ対象リスト指定日抽出部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2019/10/15   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.common.JKKBatCommon;
import eo.business.common.JKKBatConst;
import eo.business.util.file.JBSbatKKIFM902;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatZM_T_DL_FILE_KANRI;
import eo.common.constant.JKKStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatInputFileUtil;
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;
import eo.framework.util.JBSbatCheckUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSBatKKKepcoGasGcrmTgLstSDCst extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(データ一括登録管理)*/
	private static final String D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI = "ZM_T_DATAIKTTRK_KNRI";

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

	/** テーブルアクセスクラス(データ一括登録管理)*/
	private JBSbatSQLAccess db_ZM_T_DATAIKTTRK_KNRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	/** 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイル定義ファイル名 */
	private static final String KKIFM902_DEF = "KKIFM902.def";

	/** 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイル名 */
	private static final String KKIFM902_NAME = "KKIFM902.csv";

	/** 入力ファイル定義 */
	private static final String PARAM_IND = "IND";

	/** 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルファイルオブジェクト */
	private JBSbatBusinessFileUtil kkifm902FileObj = null;

	/**
	 * 初期処理
	 * @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
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// ディレイド処理依頼情報リストを取得する
		List<HashMap<String, Object>> shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, this.jobid);

		// ディレイド処理依頼情報リストが取得できない場合、処理を終了する
		if (null == shoriIraiList)
		{
			return null;
		}

		// フリー項目を取得する
		String[] freeItems = freeItem.split(JKKBatConst.S_PARAM_DELIM);

		// 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルファイルパス
		String kkifm902FilePathOut = freeItems[0] + KKIFM902_NAME;

		// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイル定義ファイル名を取得する
		String kkifm902DefName = JBSbatAplConst.getAplConstValue(PARAM_IND) + KKIFM902_DEF;

		int count = 0;

		// ディレイド処理依頼情報リストの件数分繰り返す
		for (HashMap<String, Object> shoriIrai : shoriIraiList)
		{
			count++;

			// チェックエラーフラグ
			boolean checkErrFlg = false;

			// ディレイド処理依頼番号
			String shoriIraiNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO);

			// 最初のレコードのみ処理対象とする。
			if (count > 1)
			{
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKStrConst.DLYD_TRN_RSLT_CD_COMPLETE, null);
				continue;
			}

			// 電子ファイル管理から関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルファイルを取得する
			String kkifm902FilePathIn = JCCBatCommon.searchDenshiFile(commonItem, (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO));

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルファイルオブジェクトを生成する
			JBSbatInputFileUtil kkifm902FileUtil = new JBSbatInputFileUtil(kkifm902FilePathIn);

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイル定義ファイルオブジェクトを生成する
			JBSbatDefFileUtil kkifm902FileDef = new JBSbatDefFileUtil(kkifm902DefName, kkifm902FileUtil);

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルファイルオブジェクトを生成する
			kkifm902FileObj = JKKBatCommon.createBusinessFileUtil(kkifm902FilePathOut, JKKBatConst.SJIS, JKKStrConst.LINE_SEPARATOR, JKKBatConst.S_SEP_CAM);

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルファイルレコード件数
			int kkifm902RecordCnt = 0;

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルファイルレコード件数
			kkifm902RecordCnt = 0;

			// Readerオブジェクトを生成する
			kkifm902FileUtil.createReader();

			// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルの件数分繰り返す
			while (kkifm902FileUtil.ready())
			{
				// ファイルから１レコードを取得する
				String line = kkifm902FileUtil.readLine();

				// 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルレコード件数カウント
				kkifm902RecordCnt++;

				// 空行の場合
				if (!JKKBatCommon.isNotNull(line))
				{
					// メッセージ内容 入力ファイル（Key：%1%）の内容が異常です。
					super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2050AW, 
							new String[] { getUpFileNm(shoriIrai) + "、行数：" + String.valueOf(kkifm902RecordCnt) });
					checkErrFlg = true;
					break;
				}

				// １レコードの情報をマップに格納する
				JBSbatServiceInterfaceMap recordMap = kkifm902FileDef.lineToObject(line, kkifm902FileUtil, kkifm902RecordCnt);

				// フォーマットチェックを行う
				if (recordMap.isInputErrorFlg())
				{
					// メッセージ内容 入力ファイル（Key：%1%）の内容が異常です。
					super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2050AW, 
							new String[] { getUpFileNm(shoriIrai) + "、行数：" + String.valueOf(kkifm902RecordCnt) });
					checkErrFlg = true;
					break;
				}

				// 単項目チェック仕様を設定する
				LinkedHashMap<String, String[]> hashData = propertiesKkifm902();

				// 単項目チェックを行う
				if (isSingleCheck(recordMap.getMap(), hashData, kkifm902RecordCnt))
				{
					checkErrFlg = true;
					break;
				}

				// 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイル
				createKkifm902(recordMap);
			}
			// 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルを閉じる
			JKKBatCommon.closeBusinessFileUtil(kkifm902FileObj);

			// ディレイド処理依頼結果更新
			// チェックエラーフラグがtrueの場合
			if (checkErrFlg)
			{
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKStrConst.DLYD_TRN_RSLT_CD_APP_ERR, null);
				// 一時ファイルを削除する
				File kkifm902File = new File(kkifm902FilePathOut);
				if (kkifm902File.exists())
				{
					kkifm902File.delete();
				}
			}

			// 処理依頼をコミット
			commit();
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/

	/**
	 * SQLKEY(KK_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_KK_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_KK_SELECT_001);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * パラメタのチェックのためハッシュを作成する。<br>
	 * @return LinkedHashMap 関電ガス営業向けＧＣＲＭ対象リスト指定日ファイルのハッシュマップ
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private LinkedHashMap<String, String[]> propertiesKkifm902() throws Exception
	{
		LinkedHashMap<String, String[]> hashData = new LinkedHashMap<String, String[]>();

		// 指定日
		String[] value = new String[5];
		value[0] = "抽出指定日";							// 項目名
		value[1] = "1";										// 必須フラグ
		value[2] = "year_month_day1";						// 形式
		value[3] = "8";										// 最小桁数
		value[4] = "8";										// 最大桁数
		hashData.put(JBSbatKKIFM902.CST_SITEI_YMD, value);

		return hashData;
	}

	/**
	 * パラメタの単項目チェックを行う。<br>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたHashMap
	 * @param arrHash チェックするデータの属性
	 * @param cnt レコード行
	 * @return boolean false：エラーなし、true：エラーあり
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	@SuppressWarnings("unchecked")
	private boolean isSingleCheck(HashMap rsMap, LinkedHashMap<String, String[]> arrHash, int cnt) throws Exception
	{
		String key = "";
		String strValue = "";
		String min = "";
		String max = "";
		boolean singleCheckErrFlg = false;
		Iterator<String> iterator = arrHash.keySet().iterator();
		while(iterator.hasNext())
		{
			key = iterator.next();
			strValue = (String)rsMap.get(key);
			
			// 必須チェック
			if ("1".equals(arrHash.get(key)[1]))
			{
				if (!JKKBatCommon.isNotNull(strValue))
				{
					// メッセージ内容 必須エラー（%1%）
					super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2020TW, new String[] { String.valueOf(cnt) + "行目" });
					singleCheckErrFlg = true;
					continue;
				}
			}

			if (JKKBatCommon.isNotNull(strValue))
			{
				min = arrHash.get(key)[3];
				max = arrHash.get(key)[4];

				// 桁数チェック
				if (!JBSbatCheckUtil.invoke(strValue, new String[] { "ketasuu2", min, max }))
				{
					// メッセージ内容 桁数エラー（%1%）
					super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2030TW, new String[] { String.valueOf(cnt) + "行目" });
					singleCheckErrFlg = true;
					continue;
				}

				// 形式チェック
				if (!JBSbatCheckUtil.invoke(strValue, new String[] { arrHash.get(key)[2] }))
				{
					// メッセージ内容 属性エラー（%1%）
					super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2040TW, new String[] { String.valueOf(cnt) + "行目" });
					singleCheckErrFlg = true;
					continue;
				}
			}
		}
		return singleCheckErrFlg;
	}

	/**
	 * 関電ガス営業向けＧＣＲＭ対象リスト指定日中間ファイルを出力する。<br>
	 * @param result 突合結果
	 * @param recordMap 入力ファイル
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void createKkifm902(JBSbatServiceInterfaceMap recordMap) throws Exception
	{
		ArrayList<String> outputInfo = new ArrayList<String>();

		outputInfo.add(recordMap.getString(JBSbatKKIFM902.CST_SITEI_YMD));		// 抽出指定日

		JKKBatCommon.printBusinessFileUtil(kkifm902FileObj, outputInfo);
	}

	/**
	 * アップロードファイル名を取得する。<br>
	 * @param shoriIrai 処理依頼マップ
	 * @return アップロードファイル名
	 */
	private String getUpFileNm(HashMap<String, Object> shoriIrai) throws Exception
	{
		// データ一括登録管理テーブルデータ取得条件を設定
		Object[] whereParamDlFile = new Object[2];
		// ディレイド処理依頼番号
		whereParamDlFile[0] = shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO).toString();
		// 電子ファイル管理番号
		whereParamDlFile[1] = shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO).toString();

		// データ一括登録管理テーブルデータ取得
		executeZM_T_DATAIKTTRK_KNRI_KK_SELECT_001(whereParamDlFile);

		JBSbatCommonDBInterface mapDataikttrkKanri = db_ZM_T_DATAIKTTRK_KNRI.selectNext();

		if (mapDataikttrkKanri != null)
		{
			// ファイル名
			return mapDataikttrkKanri.getString(JBSbatZM_T_DL_FILE_KANRI.FILE_NM);
		}
		return "";
	}
}