/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHmineoPayWayUseStopSjiFile
*	ソースファイル名	：JBSbatCHmineoPayWayUseStopSjiFile.java
*	作成者				：FJ)澤田
*	作成日				：2017年08月15日
*＜機能概要＞
*　mineo支払方法未登録一括登録チェック（利用停止予告・利停・強解予告・強制解約）処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v33.00.00   2017/08/15   FJ)澤田    【ANK-3171-00-00】有効な支払登録なしmineo契約の利用停止・強制解約実施
*********************************************************************/
package eo.business.service;

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.JCCbatShoriIraiUtil;
import eo.business.common.JKKBatCommon;
import eo.business.common.JKKBatConst;
import eo.business.common.JKKBatOutputUtil;
import eo.business.util.file.JBSbatCHIFM281;
import eo.business.util.file.JBSbatCHIFM282;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatCC_T_EFILE_KANRI;
import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JCCFileUtil;
import eo.common.util.JKKStringUtil;

import eo.framework.application.JBSbatBusinessException;
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.JBSbatCheckUtil;
import eo.framework.util.JBSbatDateUtil;

/**
* mineo支払方法未登録一括登録チェック（利用停止予告・利停・強解予告・強制解約）処理部品です。<p>
*<BR>
* @author 富士通
*/
public class JBSbatCHmineoPayWayUseStopSjiFile extends JBSbatBusinessService
{
	/** テーブル(サービス契約)*/
	private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
	/** テーブル(電子ファイル管理)*/
	private static final String D_TBL_NAME_CC_T_EFILE_KANRI = "CC_T_EFILE_KANRI";
	/** テーブル(コード名称管理)*/
	private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";
	/** テーブル(データ一括登録管理)*/
	private static final String D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI = "ZM_T_DATAIKTTRK_KNRI";

	/** SQL定義キー(CK_SELECT_002)*/
	private static final String KK_T_SVC_KEI_SELECT_014 = "CH_SELECT_014";
	/** SQL定義キー(KK_SELECT_001)*/
	private static final String CC_T_EFILE_KANRI_KK_SELECT_001 = "KK_SELECT_001";
	/** SQL定義キー(KK_SELECT_002)*/
	private static final String ZM_T_DATAIKTTRK_KNRI_KK_SELECT_002 = "KK_SELECT_002";
	/** SQL定義キー(KK_SELECT_004)*/
	private static final String ZM_M_CD_NM_KANRI_KK_SELECT_004 = "KK_SELECT_004";

	/** テーブルアクセスクラス(サービス契約)*/
	private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
	/** テーブルアクセスクラス(電子ファイル管理)*/
	private JBSbatSQLAccess db_CC_T_EFILE_KANRI = null;
	/** テーブルアクセスクラス(コード名称管理)*/
	private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
	/** テーブルアクセスクラス(ディレイド処理依頼)*/
	private JBSbatSQLAccess db_ZM_T_DATAIKTTRK_KNRI = null;
	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;

	/** コード種別コード（mineo支払方法未登録利停予告指示エラーコード） */
	private static final String CD_SBT_ERR_CD  = "CD01720";

	/** mineo支払方法未登録利停予告指示エラーコード 単項目チェックでエラーとなった場合 */
	private static final String ERR_CD_E001 = "E001";
	/** mineo支払方法未登録利停予告指示エラーコード サービス契約が存在しない場合 */
	private static final String ERR_CD_E002 = "E002";
	/** mineo支払方法未登録利停予告指示エラーコード サービス契約がマイネオ以外の場合 */
	private static final String ERR_CD_E003 = "E003";

	/** mineo支払方法未登録利停予告指示エラーコード格納マップ */
	private Map<String, String> errCdMap  = null;

	/** システム日時 **/
	private String sysDateTimeStamp = null;

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

		// DBアクセスクラスを生成します
		db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
		db_CC_T_EFILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_EFILE_KANRI);
		db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		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 = new ArrayList<HashMap<String, Object>>();
		//ディレイド処理依頼取得
		shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, this.jobid);
		if (shoriIraiList == null)
		{
			// 対象データが存在しないため処理終了
			return null;
		}

		// mineo支払方法未登録利停予告指示エラーコード取得
		errCdMap = getCdNmKanri(CD_SBT_ERR_CD);

		for(Map<String, Object> shoriIrai:shoriIraiList)
		{
			// ディレイド処理依頼番号
			String shoriIraiNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO);

			try
			{
				//システム日時を取得する。
				sysDateTimeStamp = JCCBatCommon.getSysDateTimeStamp();
				
				// mineo支払方法未登録利停予告指示結果リスト
				ArrayList<JBSbatServiceInterfaceMap> eoIDIktTaikaiReqRsltList = new ArrayList<JBSbatServiceInterfaceMap>();

				// エラー存在フラグ（mineo支払方法未登録利停予告指示結果ファイル出力時の判定処理に使用）
				boolean hasErr = false;

				// 入力ファイルの定義取得
				String inDefFileName = JBSbatAplConst.getAplConstValue("IND") + "CHIFM281.def";
				// 入力電子ファイル管理番号
				String fileKanriNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO);

				// 電子ファイル管理よりコース変更依頼ファイルの復元
				String inFilePath = JCCBatCommon.searchDenshiFile(commonItem, fileKanriNo);
				// ReadFileOpen
				JBSbatInputFileUtil inFileUtil = new JBSbatInputFileUtil(inFilePath);
				JBSbatDefFileUtil inFileDef = new JBSbatDefFileUtil(inDefFileName, inFileUtil);

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

				// 入力ファイルのレコード件数
				int inFileRecordCnt = 0;
				// 入力ファイルのエラーレコード件数
				int inFileErrorCount = 0;

				while (inFileUtil.ready())
				{
					// ファイルから１レコード取得
					String line = inFileUtil.readLine();

					// レコード件数カウント
					inFileRecordCnt++;

					JBSbatServiceInterfaceMap recordMap = new JBSbatServiceInterfaceMap();
					
					try
					{
						// １レコードの情報をマップに格納
						recordMap = inFileDef.lineToObject(line, inFileUtil, inFileRecordCnt);
					} 			
					catch (Throwable th)
					{
						// エラーレコード件数カウント
						inFileErrorCount++;
						eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(line, ERR_CD_E001));
						hasErr = true;
						// 次レコードを処理
						continue;
					}
					// チェック処理
					String errCd = checkMain(recordMap);

					// チェックエラーの場合
					if (!errCd.isEmpty())
					{
						// エラーレコード件数カウント
						inFileErrorCount++;
						eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(line, errCd));
						hasErr = true;
						// 次レコードを処理
						continue;
					}
				}

				// mineo支払方法未登録利停予告指示結果ファイル出力
				if (hasErr)
				{
					// ファイル名などの出力ファイル情報をフリー項目から取得
					String[] outMidFile = freeItem.split(JKKBatConst.S_PARAM_DELIM);

					JBSbatOutputItem outputBean = new JBSbatOutputItem();
					for (JBSbatServiceInterfaceMap outMap : eoIDIktTaikaiReqRsltList) {
						outMap.setOutFlg(true);
						outputBean.addOutMapList(outMap);
					}

					// mineo支払方法未登録利停予告指示結果ファイルの出力先パスを取得（スラッシュ付）
					String outFilePath = outMidFile[0];

					// mineo支払方法未登録利停予告指示結果ファイルのファイル名を編集
					String outFileName =  outMidFile[1] + sysDateTimeStamp + ".csv";

					// mineo支払方法未登録利停予告指示結果ファイルをファイル出力する
					JKKBatOutputUtil.editOutFile(super.commonItem, outputBean, "CHIFM282", outFilePath, outFileName);

					String outFileFullPath = outFilePath + outFileName;

					// 処理管理番号の取得を行う
					String trn_kanri_no = "000000000168";
					//mineo支払方法未登録利停予告指示ファイルの場合
					if ("EO62R0110J0".equals(this.jobid)) 
					{
						trn_kanri_no = "000000000168";
					}
					//mineo支払方法未登録利停・強解予告指示ファイルの場合
					else if ("EO62R0210J0".equals(this.jobid)) 
					{
						trn_kanri_no = "000000000169";
					}
					//mineo支払方法未登録強制解約指示ファイルの場合
					else
					{
						trn_kanri_no = "000000000170";
					}
					executeZM_T_DATAIKTTRK_KNRI_KK_SELECT_002(new String[]{shoriIraiNo});
					JBSbatCommonDBInterface dateIkKriInfo = db_ZM_T_DATAIKTTRK_KNRI.selectNext();
					if (null == dateIkKriInfo)
					{
						// 何もしない
					}
					else
					{
						trn_kanri_no = dateIkKriInfo.getString("TRN_KANRI_NO");
					}

					// 電子ファイル管理に登録するファイル名
					String outFileNhngName = outFileName;

					// エラーありのため、ディレイド処理依頼結果コードを"業務エラー"で更新
					Map<String, String> retMap = JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, "2", outFileFullPath);

					// エラーファイルの電子ファイル管理番号取得して、ダウンロードファイル管理に登録
					String eFileKanriNo = retMap.get("EFILE_KAMRI_NO");

					if(!JKKStringUtil.isNullBlank(eFileKanriNo))
					{
						insertZM_T_DL_FILE_KANRI(eFileKanriNo, outFileNhngName, outFileFullPath, inFileErrorCount, trn_kanri_no);
					}
				} 
				else
				{
					// エラーなしのため、ディレイド処理依頼結果コードを"完了"で更新
					JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, "1", null);
				}
			}
			catch (Throwable th)
			{
				// ディレイド処理依頼ステータスを処理エラーに更新
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKBatConst.RESULT_SYSERR, null);
				super.commonItem.setErrFlg(true);
				//フレームワークがエラーログにスタックトレースを出さないので、独自にエラーログ出力する
				super.logPrint.printErrMsg(JPCBatchMessageConstant.EWCB0230CE, th, new String[]{"ディレイド処理依頼番号：" + shoriIraiNo});
				// 終了コードを127に設定するためエラーログを出力
				super.commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EWCB0230CE, new String[]{"ディレイド処理依頼番号：" + shoriIraiNo});
			}
		}
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**
	 * 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 executeCC_T_EFILE_KANRI_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0]);

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

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

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

	/**
	 * SQLKEY(KK_SELECT_007)で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_M_CD_NM_KANRI_KK_SELECT_004(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0]);
		paramList.setValue(param[1]);
		paramList.setValue(param[2]);

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

	/**
	 * ディレイド処理依頼で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_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0]);

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

	/**
	 * 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);
	}

	/**
	 * ダウンロードファイル管理テーブルの登録を行います。
	 * <br>
	 * @param eFileKanriNo 電子ファイル管理番号
	 * @param fileName   ファイル名
	 * @param filePath   ファイルパス
	 * @param rowCnt     データ件数
	 * @param trn_kanri_no 処理管理番号
	 * @throws Exception 
	 */
	private void insertZM_T_DL_FILE_KANRI(String eFileKanriNo, String fileName, String filePath, int rowCnt, String trn_kanri_no) throws Exception
	{
		JBSbatCommonDBInterface eFileInfo = getEfileKanriInfo(eFileKanriNo);
		
		// パラメータ設定
		Object[] prm = new Object[15];
		prm[0] = JKKBatCommon.getFormatedNextSeq(commonItem, "SEQ_FILE_NO", "", 12);
		prm[1] = trn_kanri_no;
		prm[2] = eFileKanriNo;
		prm[3] = fileName;
		prm[4] = JCCFileUtil.getFileSize(filePath);
		prm[5] = String.valueOf(rowCnt);
		prm[6] = eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.ADD_DTM);
		prm[7] = eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.FILE_DEL_YMD);
		prm[8] = JBSbatDateUtil.getSystemDateTimeStamp();
		prm[9] = "SYSTEM";
		prm[10] = JBSbatDateUtil.getSystemDateTimeStamp();
		prm[11] = "SYSTEM";
		prm[12] = null;
		prm[13] = null;
		prm[14] = "0";

		executeZM_T_DL_FILE_KANRI_PKINSERT(prm);
	}

	/**
	 * 電子ファイル管理スキーマより、電子ファイル管理の情報を取得します。
	 * 
	 * @param eFileKanriNo 		電子ファイル管理番号
	 * @return dbMap		電子ファイル管理の情報
	 * @throws Exception	業務サービス内で発生した例外全般
	 */
	private JBSbatCommonDBInterface getEfileKanriInfo(String eFileKanriNo) throws Exception
	{
		Object[] param = new Object[1];
		param[0] = eFileKanriNo;
		
		// SQL実行
		executeCC_T_EFILE_KANRI_KK_SELECT_001(param);
		
		// 結果取得
		JBSbatCommonDBInterface dbMap = db_CC_T_EFILE_KANRI.selectNext();
		
		if (dbMap == null)
		{
			// DB未存在エラー
			String[] msgParam = new String[]
			{ JBSbatCC_T_EFILE_KANRI.TABLE_NAME };
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0720KW, msgParam);
		}
		return dbMap;
	}

	/**
	 * コード名称管理より該当のコード種別のコードを取得します。
	 * <br>
	 * @param cdSbtCd  コード種別コード
	 * @return 
	 * @throws Exception 
	 */
	private Map<String, String> getCdNmKanri(String cdSbtCd) throws Exception
	{
		Map<String, String> resultMap  = new HashMap<String, String>();
		
		Object[] prm = new Object[]{cdSbtCd, super.opeDate, super.opeDate};
		executeZM_M_CD_NM_KANRI_KK_SELECT_004(prm);
		
		// 取得したコード名称管理の内容をハッシュテーブルに格納する
		JBSbatCommonDBInterface dbMap = db_ZM_M_CD_NM_KANRI.selectNext();
		while(dbMap != null)
		{
			// 「コード区分」をキーに「コード区分名」を設定する
			resultMap.put(
					dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV), dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV_NM));
			dbMap = db_ZM_M_CD_NM_KANRI.selectNext();
		}
		
		return resultMap;
	}

	/**
	 * チェックを行います。
	 * <br>
	 * @param recordMap mineo支払方法未登録利停予告指示依頼リストの１レコードの情報
	 * @return mineo支払方法未登録利停予告指示エラーコード
	 * @throws Exception 下位メソッドで発生した例外
	 */
	@SuppressWarnings("unchecked")
	private String checkMain(JBSbatServiceInterfaceMap recordMap)
	throws Exception
	{
		// (a)ファイルチェック

		// フォーマットチェック
		if (recordMap.isInputErrorFlg())
		{
			// １レコードの項目数が異なる
			return ERR_CD_E001;
		}

		// 必須・属性・桁数チェック
		String result = singleCheck(recordMap.getMap());
		
		if (!JKKStringUtil.isNullBlank(result))
		{
			return result;
		}

		// (b)内容チェック

		// サービス契約番号を取得
		String svcKeiNo = recordMap.getString(JBSbatCHIFM281.SVC_KEI_NO);
		executeKK_T_SVC_KEI_SELECT_014(new String[]{svcKeiNo, super.opeDate});
		JBSbatCommonDBInterface custInfo = db_KK_T_SVC_KEI.selectNext();

		// サービス契約に存在しないサービス契約番号の場合、チェックエラーとする
		if (null == custInfo)
		{
			return ERR_CD_E003;
		} 
		else 
		{
			String prcGrpCd = (String)custInfo.getString("PRC_GRP_CD");
			//マイネオ以外の場合 
			if (!"51".equals(prcGrpCd))
			{
				return ERR_CD_E002;
			}
		}

		// チェックOK
		return "";
	}

	/**
	 * 入力情報（mineo支払方法未登録利停予告指示依頼）の単項目チェックを行います。<br>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたMap。
	 * @return エラー内容に該当するmineo支払方法未登録利停予告指示エラーコード。エラーなしの場合には空文字を返却。
	 */
	private String singleCheck(Map<String, Object> rsMap)
	{
		// 単項目チェックを行います
		String strValue = null;

		// サービス契約番号項目チェック
		strValue = (String)rsMap.get(JBSbatCHIFM281.SVC_KEI_NO);

		// 必須チェック
		if(JKKStringUtil.isNullBlank(strValue))
		{
			return ERR_CD_E001;
		}

		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu1", "10"}))
		{
			return ERR_CD_E001;
		}

		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			return ERR_CD_E001;
		}

		return null;
	}

	/**
	 * mineo支払方法未登録利停予告指示結果ファイル内容をマップオブジェクトへ設定する。<br>
	 * @param  line 入力ファイルの１レコード分を格納した String
	 * @param  errCd チェックエラーコード（正常の場合はNULLもしくは空文字を設定）
	 * @return JBSbatServiceInterfaceMap 出力ファイル記載内容１件分
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	private JBSbatServiceInterfaceMap setEoIDIktTaikaiReqRslt(String line, String errCd) throws Exception
	{
		JBSbatServiceInterfaceMap result = new JBSbatServiceInterfaceMap();

		String errRsn = "";

		if (!JKKStringUtil.isNullBlank(errCd))
		{
			//エラーメッセージ取得
			errRsn = errCdMap.get(errCd);
		}

		// エラーコード
		result.set(JBSbatCHIFM282.ERR_CD, errCd);
		// エラー理由
		result.set(JBSbatCHIFM282.ERR_RSN, errRsn);
		// サービス契約番号
		result.set(JBSbatCHIFM282.SVC_KEI_NO, line.replaceAll("\"", ""));
		result.setOutFlg(true);

		return result;
	}
}