/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCKEoIDIktTaikai
*	ソースファイル名	：JBSbatCKEoIDIktTaikai.java
*	作成者				：FJ)麻生
*	作成日				：2017年07月24日
*＜機能概要＞
*　eoID一括退会処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v33.00.00   2017/07/24   FJ)麻生    【ANK-3121-00-00】eoID一括退会機能の作成
*   v33.01.00   2017/08/10   FJ)麻生    【IT1-2017-0000100】処理管理番号および権限コードの採番ミスによるリリース申請ミス
*********************************************************************/
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.JBSbatCKIFM012;
import eo.business.util.file.JBSbatCKIFM013;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatCC_T_EFILE_KANRI;
import eo.business.util.table.JBSbatCK_T_CUST;
import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI;
import eo.common.constant.JCKStrConst;
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;
import eo.framework.util.JCCBatchEsbInterface;

/**
* eoID一括退会処理部品です。<p>
*<BR>
* @author 富士通
*/
public class JBSbatCKEoIDIktTaikai extends JBSbatBusinessService
{
	/** テーブル(お客様)*/
	private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
	/** テーブル(電子ファイル管理)*/
	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 CK_T_CUST_CK_SELECT_002 = "CK_SELECT_002";
	/** 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_CK_T_CUST = 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;

	/** コード種別コード（eoID一括退会エラーコード） */
	private static final String CD_SBT_ERR_CD  = "CD01717";
	/** コード種別コード（eoID一括退会結果コード） */
	private static final String CD_SBT_RSLT_CD = "CD01718";

	/** eoID一括退会エラーコード 項目数不正 */
	private static final String ERR_CD_E010 = "E010";
	/** eoID一括退会エラーコード SYSID未設定 */
	private static final String ERR_CD_E020 = "E020";
	/** eoID一括退会エラーコード 文字種不正 */
	private static final String ERR_CD_E030 = "E030";
	/** eoID一括退会エラーコード 桁数不正 */
	private static final String ERR_CD_E040 = "E040";
	/** eoID一括退会エラーコード E100 */
	private static final String ERR_CD_E100 = "E100";
	/** eoID一括退会エラーコード E110 */
	private static final String ERR_CD_E110 = "E110";
	/** eoID一括退会エラーコード E120 */
	private static final String ERR_CD_E120 = "E120";
	/** eoID一括退会エラーコード E200 */
	private static final String ERR_CD_E200 = "E200";

	/** eoID一括退会結果コード（正常） */
	private static final String PROC_RSLT_OK = "0";
	/** eoID一括退会結果コード（エラー） */
	private static final String PROC_RSLT_NG = "1";

	/** eoID一括退会エラーコード格納マップ */
	private Map<String, String> errCdMap  = null;
	/** eoID一括退会結果コード格納マップ */
	private Map<String, String> rsltCdMap = null;

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

	/** eoID退会サービス */
	private static final String SERVICE_EOID_TAIKAI = "CKSV9057";
	/** 会員情報更新依頼サービス */
	private static final String SERVICE_UPDATE_MEMBER_INFO_REQUEST = "CKSV9001";

	/** 標準コンテンツ解約マップ */
	private static final String CKSV905701CC = "CKSV905701CC";
	/** 会員情報更新依頼マップ */
	private static final String CKSV900101CC = "CKSV900101CC";

	/** CCMGリターンコードキー */
	private static final String CCMG_RETURN_CODE_KEY = "return_cd";

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

		// DBアクセスクラスを生成します
		db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
		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;
		}

		// eoID一括退会エラーコード取得
		errCdMap = getCdNmKanri(CD_SBT_ERR_CD);
		// eoID一括退会結果コード取得
		rsltCdMap = getCdNmKanri(CD_SBT_RSLT_CD);

		int totalExceptionCount = 0;

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

			try
			{
				//システム日時を取得する。
				sysDateTimeStamp = JCCBatCommon.getSysDateTimeStamp();

				int successCount = 0;
				int businessErrorCount = 0;
				int exceptionCount = 0;

				// eoID一括退会結果リスト
				ArrayList<JBSbatServiceInterfaceMap> eoIDIktTaikaiReqRsltList = new ArrayList<JBSbatServiceInterfaceMap>();

				// エラー存在フラグ（eoID一括退会結果ファイル出力時の判定処理に使用）
				boolean hasErr = false;

				// 入力ファイルの定義取得
				String inDefFileName = JBSbatAplConst.getAplConstValue("IND") + "CKIFM012.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;

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

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

					// １レコードの情報をマップに格納
					JBSbatServiceInterfaceMap recordMap = inFileDef.lineToObject(line, inFileUtil, inFileRecordCnt);

					// お客様情報
					Map<String, Object> custMap = new HashMap<String, Object>();

					// 退会チェック処理
					String errCd = checkMain(recordMap, custMap);

					// チェックエラーの場合
					if (!errCd.isEmpty())
					{
						eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(recordMap.getMap(), errCd));
						hasErr = true;
						businessErrorCount++;
						// 次レコードを処理
						continue;
					}

					// eoID退会のためサービスを呼び出す
					try
					{
						// サービス呼出し
						Map<String, Object> outputMap = invokeService(SERVICE_EOID_TAIKAI, custMap);
						String returnCode = (String) outputMap.get(JCCBatchEsbInterface.RETURN_CODE);
						String ccmgReturnCode = getCcmgReturnCode(outputMap);
						if(!JCCBatchEsbInterface.RETURN_CODE_SUCCESS.equals(returnCode) || !JCKStrConst.PMP_NORMAL_END.equals(ccmgReturnCode))
						{
							// エラーコード設定
							eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(recordMap.getMap(), ERR_CD_E200));
							hasErr = true;
							// エラーログ出力
							commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB1220CI,
									new String[]{"SYSID：" + (String)recordMap.getMap().get(JBSbatCKIFM012.SYSID)});
							businessErrorCount++;
							// 次レコードを処理
							continue;
						}
					}
					catch (Throwable e)
					{
						// エラーコード設定
						eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(recordMap.getMap(), ERR_CD_E200));
						hasErr = true;
						//フレームワークがエラーログにスタックトレースを出さないので、独自にエラーログ出力する
						super.logPrint.printErrMsg(JPCBatchMessageConstant.ECCB0110CE, e, new String[]{});
						commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB1220CI,
								new String[]{"SYSID：" + (String)recordMap.getMap().get(JBSbatCKIFM012.SYSID)});
						exceptionCount++;
						// 次レコードを処理
						continue;
					}

					// 会員情報更新依頼のためサービスを呼び出す
					try
					{
						// サービス呼出し
						invokeService(SERVICE_UPDATE_MEMBER_INFO_REQUEST, custMap);
					}
					catch (Throwable e)
					{
						// 何もしない
					}

					// 正常登録件数加算
					successCount++;
					// 正常に登録したため、正常としてファイル出力を行う
					eoIDIktTaikaiReqRsltList.add(setEoIDIktTaikaiReqRslt(recordMap.getMap(), errCd));
				}

				// eoID一括退会結果ファイル出力
				if(!JKKStringUtil.isNullEmpty(eoIDIktTaikaiReqRsltList))
				{
					// ファイル名などの出力ファイル情報をフリー項目から取得
					String[] outMidFile = freeItem.split(JKKBatConst.S_PARAM_DELIM);

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

					// eoID一括退会結果ファイルの出力先パスを取得（スラッシュ付）
					String outFilePath = outMidFile[0];

					// eoID一括退会結果ファイルのファイル名を編集
					String outFileName =  "CKIFM013001_" + sysDateTimeStamp + ".csv";

					// eoID一括退会結果ファイルをファイル出力する
					JKKBatOutputUtil.editOutFile(super.commonItem, outputBean, "CKIFM013", outFilePath, outFileName);

					String outFileFullPath = outFilePath + outFileName;

					// 処理管理番号の取得を行う
					//IT1-2017-0000100 MOD START
//					String trn_kanri_no = "000000000163";
					String trn_kanri_no = "000000000166";
					//IT1-2017-0000100 MOD END
					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 = "eoID一括退会結果ファイル_" + sysDateTimeStamp + ".csv";
					if (hasErr)
					{
						// エラーありのため、ディレイド処理依頼結果コードを"業務エラー"で更新
						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, inFileRecordCnt, trn_kanri_no);
						}
					}
					else
					{
						// エラーなしのため、ディレイド処理依頼結果コードを"完了"で更新
						JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, "1", null);

						// eoID一括退会結果ファイルを電子ファイル管理スキーマに設定
						String[] denshiRet = JCCBatCommon.createDenshiFile(super.commonItem, "0000", outFileFullPath, null);

						// ダウンロードファイル管理に登録
						insertZM_T_DL_FILE_KANRI(denshiRet[0], outFileNhngName, outFileFullPath, inFileRecordCnt, trn_kanri_no);
					}
				}

				// 処理件数を出力
				StringBuffer countSummary = new StringBuffer();
				countSummary.append("計");
				countSummary.append(successCount + businessErrorCount + exceptionCount);
				countSummary.append("件 (正常");
				countSummary.append(successCount);
				countSummary.append("件;業務エラー");
				countSummary.append(businessErrorCount);
				countSummary.append("件;例外発生");
				countSummary.append(exceptionCount);
				countSummary.append("件)");
				// 「%1% ファイル出力件数 = %2%」
				super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB0760AI,
						new String[] { "eoID一括退会結果ファイル", countSummary.toString() });

				totalExceptionCount += exceptionCount;

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

		}

		// eoID退会サービスで例外が発生している場合
		if (0 < totalExceptionCount)
		{
			// 単一サービス呼び出しパターンの場合は、エラー件数を設定することで警告終了する
			commonItem.setErrorCount(totalExceptionCount);
		}

		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CK_T_CUST.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;
		rsltCdMap = 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 executeCK_T_CUST_CK_SELECT_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0]);
		paramList.setValue(param[1]);

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

	/**
	 * 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     データ件数
	 * @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 eFileNO 		電子ファイル管理番号
	 * @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 eoID一括退会依頼リストの１レコードの情報
	 * @param custMap サービス契約情報（返却用）
	 * @return eoID一括退会エラーコード
	 * @throws Exception 下位メソッドで発生した例外
	 */
	@SuppressWarnings("unchecked")
	private String checkMain(JBSbatServiceInterfaceMap recordMap,
			Map<String, Object> custMap)
	throws Exception
	{
		// (a)ファイルチェック

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

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

		// (b)内容チェック

		// SYSIDを取得
		String sysid = recordMap.getString(JBSbatCKIFM012.SYSID);
		executeCK_T_CUST_CK_SELECT_002(new String[]{sysid, super.opeDate});
		JBSbatCommonDBInterface custInfo = db_CK_T_CUST.selectNext();

		// お客様に存在しないSYSIDの場合、チェックエラーとする
		if (null == custInfo)
		{
			return ERR_CD_E100;
		}

		// お客様情報を戻す
		custMap.putAll(custInfo.getMap());

		// お客様の会員種別が「オープン会員」以外の場合、チェックエラーとする
		String memberSbtCd = custInfo.getString(JBSbatCK_T_CUST.MEMBER_SBT_CD);
		if (!JCKStrConst.CD00039_OPEN.equals(memberSbtCd))
		{
			return ERR_CD_E110;
		}

		// お客様のお客様入退会コードが「退会」の場合、チェックエラーとする
		String custNtaikaiCd = custInfo.getString(JBSbatCK_T_CUST.CUST_NTAIKAI_CD);
		if (JCKStrConst.CD00260_TAIKAI.equals(custNtaikaiCd))
		{
			return ERR_CD_E120;
		}

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

	/**
	 * 入力情報（eoID一括退会依頼）の単項目チェックを行います。<br>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたMap。
	 * @return エラー内容に該当するeoID一括退会エラーコード。エラーなしの場合には空文字を返却。
	 */
	private String singleCheck(Map<String, Object> rsMap)
	{
		// 単項目チェックを行います
		String strValue = null;

		// SYSID項目チェック
		strValue = (String)rsMap.get(JBSbatCKIFM012.SYSID);

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

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

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

		return null;
	}

	/**
	 * eoID一括退会結果ファイル内容をマップオブジェクトへ設定する。<br>
	 * @param  inMap 入力ファイルの１レコード分を格納したHashMap
	 * @param  errCd チェックエラーコード（正常の場合はNULLもしくは空文字を設定）
	 * @return JBSbatServiceInterfaceMap 出力ファイル記載内容１件分
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	private JBSbatServiceInterfaceMap setEoIDIktTaikaiReqRslt(Map inMap, String errCd) throws Exception
	{
		JBSbatServiceInterfaceMap result = new JBSbatServiceInterfaceMap();

		String procRslt = rsltCdMap.get(PROC_RSLT_OK);
		String procYmd = super.opeDate;
		String errRsn = "";

		if (!JKKStringUtil.isNullBlank(errCd))
		{
			// エラーのため、エラー用の出力内容を設定
			procRslt = rsltCdMap.get(PROC_RSLT_NG);
			procYmd = "";
			errRsn = errCdMap.get(errCd);
		}

		// SYSID
		result.set(JBSbatCKIFM013.SYSID, inMap.get(JBSbatCKIFM012.SYSID));
		// 処理結果
		result.set(JBSbatCKIFM013.PROC_RSLT, procRslt);
		// 処理日
		result.set(JBSbatCKIFM013.PROC_YMD, procYmd);
		// エラーコード
		result.set(JBSbatCKIFM013.ERR_CD, errCd);
		// エラー理由
		result.set(JBSbatCKIFM013.ERR_RSN, errRsn);
		result.setOutFlg(true);

		return result;
	}

	/**
	 * サービス呼出処理
	 * @param custMap お客様情報
	 * @return サービスの処理結果
	 * @throws Exception
	 */
	private Map<String, Object> invokeService(String usecaseId,
			Map<String, Object> custMap) throws Exception
	{
		// サービス呼び出し時の引数を生成
		HashMap<String, Object> paramMap = new HashMap<String, Object>();
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, usecaseId);
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_OPERATION_ID, usecaseId
				+ "OP");

		HashMap<String, Object> inputMap = new HashMap<String, Object>();
		Map<String, Object> mapCc01 = new HashMap<String, Object>();
		mapCc01.put("sysid", custMap.get(JBSbatCK_T_CUST.SYSID));
		if (SERVICE_EOID_TAIKAI.equals(usecaseId))
		{
			mapCc01.put("eoid", custMap.get(JBSbatCK_T_CUST.EOID));
			inputMap.put(CKSV905701CC, mapCc01);
		}
		else
		{
			inputMap.put(CKSV900101CC, mapCc01);
		}

		HashMap<String, Object> outputMap = new HashMap<String, Object>();

		// サービス呼び出し
		JCCBatchEsbInterface.invokeService(super.commonItem, paramMap,
				inputMap, outputMap);

		return outputMap;
	}

	/**
	 * CCMGリターンコード取得処理
	 * @param outputMap 出力結果
	 * @return CCMGリターンコード
	 */
	@SuppressWarnings("unchecked")
	private String getCcmgReturnCode(Map<String, Object> outputMap)
	{
		String ccmgReturnCode = "";
		Map<String, Object> ccmgMap = (Map<String, Object>) outputMap.get(CKSV905701CC);
		if (ccmgMap != null)
		{
			ccmgReturnCode = (String) ccmgMap.get(CCMG_RETURN_CODE_KEY);
		}

		return ccmgReturnCode;
	}

}