/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSBatKKGcrmSvkeiNayoseDataChg
*	ソースファイル名	：JBSBatKKGcrmSvkeiNayoseDataChg.java
*	作成者				：富士通　
*	作成日				：2019年10月08日
*＜機能概要＞
*　ＧＣＲＭサービス契約者名寄せデータ変換部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2019/10/08   富士通		新規作成
*  v48.00.00	2020/02/18   FJ) 張本   【ANK-3723-01-00】GCRM顧客データ提供日付の登録処理システム化(5M問題対応)
*  v54.00.00	2021/08/23   FJ) 張本	【ANK-4089-00-00】GCRMリスト改修
*********************************************************************/
package eo.business.service;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
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.JBSbatKKIFM898;
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.common.util.JCCUnCompressFileUtil;
import eo.common.util.JKKStringConverter;
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;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSBatKKGcrmSvkeiNayoseDataChg 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 KKIFM898_DEF = "KKIFM898.def";

	/** ＧＣＲＭサービス契約者名寄せ結果リストファイル名 */
	private static final String KKIFM899_NAME = "KKIFM899001_{DLYD_TRN_REQ_NO}.csv";

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

	/** ＧＣＲＭサービス契約者名寄せ結果リストファイルオブジェクト */
	private JBSbatBusinessFileUtil kkifm899FileObj = null;

	/** ＧＣＲＭサービス契約者名寄せ結果リストファイルレコード件数 */
	private int kkifm899RecordCnt = 0;

// v54.00.00 ANK-4089-00-00 DEL START
//	/** スペース（全角） */
//	public static final String SPACE_ZENKAKU = "　";
// v54.00.00 ANK-4089-00-00 DEL END

// v54.00.00 ANK-4089-00-00 ADD START
	/** 半角スペース */
	private static final String HALF_SPACE = " ";
	/** 文字コード */
	private static final String MS932  = "MS932";

	/** 半角カタカナ文字データテーブル */
	private static final String HANKAKU_KATAKANA[] = { "ﾜﾞ", "ｲﾞ", "ｴﾞ", "ｦﾞ" };
	/** 全角カタカナ文字データテーブル */
	private static final String ZENKAKU_KATAKANA[] = { "ワ゛", "イ゛", "エ゛", "ヲ゛" };
// v54.00.00 ANK-4089-00-00 ADD END

	/**
	 * 初期処理
	 * @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 kkifm898DefName = JBSbatAplConst.getAplConstValue(PARAM_IND) + KKIFM898_DEF;

		// ディレイド処理依頼情報リストの件数分繰り返す
		for (HashMap<String, Object> shoriIrai : shoriIraiList)
		{
			// チェックエラーフラグ
			boolean checkErrFlg = false;

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

			// ＧＣＲＭサービス契約者名寄せ結果リストファイルパス
			String kkifm899FilePath = freeItems[0] + KKIFM899_NAME;

			kkifm899FilePath = kkifm899FilePath.replace("{DLYD_TRN_REQ_NO}", shoriIraiNo);

			// 電子ファイル管理からＧＣＲＭサービス契約者名寄せリストファイルを取得する
			String kkifm898FilePath = JCCBatCommon.searchDenshiFile(commonItem, (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO));

// v48.00.00 ANK-3723-01-00 ADD START
			// ZIPファイルを解凍する
			try
			{
				String parentPath = new File(kkifm898FilePath).getParent();

				kkifm898FilePath = JCCUnCompressFileUtil.uncompressFile(kkifm898FilePath, parentPath, "0");
			}
			catch (Exception e){}
// v48.00.00 ANK-3723-01-00 ADD END

			// ＧＣＲＭサービス契約者名寄せリストファイルオブジェクトを生成する
			JBSbatInputFileUtil kkifm898FileUtil = new JBSbatInputFileUtil(kkifm898FilePath);

			// ＧＣＲＭサービス契約者名寄せリスト定義ファイルオブジェクトを生成する
			JBSbatDefFileUtil kkifm898FileDef = new JBSbatDefFileUtil(kkifm898DefName, kkifm898FileUtil);

			// ＧＣＲＭサービス契約者名寄せ結果リストファイルオブジェクトを生成する
// v54.00.00 ANK-4089-00-00 MOD START
//			kkifm899FileObj = JKKBatCommon.createBusinessFileUtil(kkifm899FilePath, JKKBatConst.SJIS, JKKStrConst.LINE_SEPARATOR, JKKBatConst.S_SEP_CAM);
			kkifm899FileObj = JKKBatCommon.createBusinessFileUtil(kkifm899FilePath, MS932, JKKStrConst.LINE_SEPARATOR, JKKBatConst.S_SEP_CAM);
// v54.00.00 ANK-4089-00-00 MOD END

			// ＧＣＲＭサービス契約者名寄せリストファイルレコード件数
			int kkifm898RecordCnt = 0;

			// ＧＣＲＭサービス契約者名寄せ結果リストファイルレコード件数
			kkifm899RecordCnt = 0;

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

			// ＧＣＲＭサービス契約者名寄せリストファイルの件数分繰り返す
			while (kkifm898FileUtil.ready())
			{

				// 契約者名＿カナ
				String keishaKana = JKKBatConst.SPACE;

				// ファイルから１レコードを取得する
				String line = kkifm898FileUtil.readLine();

				// ＧＣＲＭサービス契約者名寄せリストファイルレコード件数カウント
				kkifm898RecordCnt++;

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

					checkErrFlg = true;
					break;

				}

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

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

					checkErrFlg = true;
					break;
				}

				// 1行目はヘッダーのため、次のレコードへ移る
				if (kkifm898RecordCnt == 1)
				{
					continue;
				}

// v54.00.00 ANK-4089-00-00 MOD START
//				// 契約者名＿カナ　半角→全角
//				keishaKana = JKKStringConverter.convertFull((String)recordMap.getMap().get(JBSbatKKIFM898.KEISHA_KANA));
//				// 契約者名＿カナ　空白削除
//				keishaKana = keishaKana.replace(SPACE_ZENKAKU, JKKBatConst.SPACE);
				// 契約者名＿カナ
				keishaKana = (String)recordMap.getMap().get(JBSbatKKIFM898.KEISHA_KANA);
				// 契約者名＿カナ　空白削除
				String trmKeishaKana = keishaKana.replace(HALF_SPACE, JKKBatConst.SPACE);
				// 契約者名＿カナ　半角→全角
				keishaKana = JKKStringConverter.convertFull(trmKeishaKana);
				// 変換後の属性チェック
				if (!JCCBatCommon.isZenkaku(keishaKana))
				{
					// 変換できない文字を再度変換する
					keishaKana = convertFull(trmKeishaKana);
				}
// v54.00.00 ANK-4089-00-00 MOD END

				// ＧＣＲＭサービス契約者名寄せ結果リストを出力する
				createKkifm899(keishaKana, recordMap);
			}

			// ＧＣＲＭサービス契約者名寄せ結果リストを閉じる
			JKKBatCommon.closeBusinessFileUtil(kkifm899FileObj);

			// ディレイド処理依頼結果更新
			// チェックエラーフラグがtrueの場合
			if (checkErrFlg)
			{
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKStrConst.DLYD_TRN_RSLT_CD_APP_ERR, null);

				// 一時ファイルを削除する
				File kkifm899File = new File(kkifm899FilePath);
				if (kkifm899File.exists())
				{
					kkifm899File.delete();
				}
				// 処理依頼1件を処理する毎にコミット
				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>
	 * @param keishaKana 契約者名＿カナ
	 * @param recordMap 入力ファイル
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void createKkifm899(String keishaKana, JBSbatServiceInterfaceMap recordMap) throws Exception
	{
		ArrayList<String> outputInfo = new ArrayList<String>();

		outputInfo.add(recordMap.getString(JBSbatKKIFM898.SEQ_NO));				// 通し番号
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.SYRN_NO));			// システム連係番号
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.KEISHA_NM));			// 契約者名
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.KEISHA_KANA));		// 契約者名＿カナ
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.PCD));				// 郵便番号
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.JUYO_PLC_AD_1));		// 需要場所住所１
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.JUYO_PLC_AD_2));		// 需要場所住所２
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.JUYO_PLC_AD_3));		// 需要場所住所３
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.RRKS_TELNO));			// 連絡先電話番号
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.EOH_KEI_UM_GCRM));	// ｅｏ光契約有無（ＧＣＲＭ）
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.EOH_KNY_YM_GCRM));	// ｅｏ光加入年月（ＧＣＲＭ）
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.EOH_DSL_YM_GCRM));	// ｅｏ光解約年月（ＧＣＲＭ）
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.MINEO_KEI_UM_GCRM));	// マイネオ契約有無（ＧＣＲＭ）
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.MINEO_KNY_YM_GCRM));	// マイネオ加入年月（ＧＣＲＭ）
		outputInfo.add(recordMap.getString(JBSbatKKIFM898.MINEO_DSL_YM_GCRM));	// マイネオ解約年月（ＧＣＲＭ）
		outputInfo.add(keishaKana);	// カナ全角
		outputInfo.add("");			// SYSID
		outputInfo.add("");			// 関電G個人INF取扱同意有無
		outputInfo.add("");			// 関電G個人INF_TK_NG_FLG
		outputInfo.add("");			// お客様名
		outputInfo.add("");			// カナ氏名
		outputInfo.add("");			// 契約者タイプ
		outputInfo.add("");			// 料金グループ名
		outputInfo.add("");			// ネット照査日
		outputInfo.add("");			// ｍｉｎｅｏ照査日
		outputInfo.add("");			// 突合結果

		JKKBatCommon.printDoubleQuoteBusinessFileUtil(kkifm899FileObj, outputInfo);

		kkifm899RecordCnt++;
	}

	/**
	 * アップロードファイル名を取得する。<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 "";
	}

	/**
	 * 	全角変換処理する。<br>
	 * @param str 変換対象の文字列
	 * @return String 変換後の文字列
	 */
	private static String convertFull(String value)
	{
		// SJISで変換できない文字を全角変換する
		for (int i = 0; i < HANKAKU_KATAKANA.length; i++) {
			value = value.replace(HANKAKU_KATAKANA[i], ZENKAKU_KATAKANA[i]);
		}
		value = JKKStringConverter.convertFull(value);

		// 半角のままの文字を全角変換する
		String chgValue = "";
		for (int i = 0; i < value.length(); i++) {
			chgValue += JKKStringConverter.convertFull(value
					.substring(i, i + 1));
		}

		return chgValue;
	}

}