/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKEoidMmbInfFileSaksei
*	ソースファイル名	：JBSbatKKEoidMmbInfFileSaksei.java
*	作成者				：富士通　
*	作成日				：2011年06月14日
*＜機能概要＞
*　ｅｏＩＤ会員情報ファイル作成処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/06/14	FJ）庭山	新規作成
*	v3.00.00	2012/05/02	FJ)岡田		【巻@登録テーブル項目同期】対応
*	v3.01.00	2012/06/16	FJ)久保田	【IT2-2012-0000892】障害対応
*********************************************************************/
package eo.business.service;

import java.io.BufferedWriter;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.file.JBSbatKKIFE026001;
import eo.business.util.file.JBSbatKKIFM029;
import eo.business.util.table.JBSbatKK_T_RNKI_FILE_CTRL;
import eo.business.util.table.JBSbatKK_T_TSYRN_ZM_EOMBIN;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.util.JBSbatDateUtil;
import eo.framework.util.JBSbatStringUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKEoidMmbInfFileSaksei extends JBSbatBusinessService
{
	/**
	 * 囲み文字（"）
	 */
	private static final String MOJI_D = "\"";

	/**
	 * 契約ステータス（解約）
	 */
	private static final String KEI_STAT_DSL = "910";

	/**
	 * 契約ステータス（キャンセル）
	 */
	private static final String KEI_STAT_CNCL = "920";

	/**
	 * 連携先コード（ePOP用）
	 */
	private static final String RNKS_CD = "2";

	/**
	 * 物理バッチID（KKPRC06501）
	 */
	private static final String BAT_ID = "KKPRC06501";

	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(連携ファイル制御)*/
	private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";

	/** テーブル(他システム連携済ｅｏＩＤ会員情報)*/
	private static final String D_TBL_NAME_KK_T_TSYRN_ZM_EOMBIN = "KK_T_TSYRN_ZM_EOMBIN";

	/** テーブルアクセスクラス(連携ファイル制御)*/
	private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;

	/** テーブルアクセスクラス(他システム連携済ｅｏＩＤ会員情報)*/
	private JBSbatSQLAccess db_KK_T_TSYRN_ZM_EOMBIN = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/**
	 * 出力件数
	 * */
	private int out_cnt = 0;

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_KK_T_RNKI_FILE_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_RNKI_FILE_CTRL);
		db_KK_T_TSYRN_ZM_EOMBIN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_TSYRN_ZM_EOMBIN);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		super.logPrint.printDebugLog("execute_START");

		JBSbatOutputItem out_bean = null;
		JBSbatCommonDBInterface map = null;
		JBSbatCommonDBInterface where_map = new JBSbatCommonDBInterface();

		String[] param = new String[2];
		String[] value = null;

		param[0] = RNKS_CD;
		param[1] = inMap.getString(JBSbatKKIFM029.SVC_KEI_NO);

		where_map.setValue(JBSbatKK_T_TSYRN_ZM_EOMBIN.RNKS_CD, param[0]);
		where_map.setValue(JBSbatKK_T_TSYRN_ZM_EOMBIN.SVC_KEI_NO, param[1]);

		// 他システム連携済eoID会員情報テーブルの照合を行います。
		map = db_KK_T_TSYRN_ZM_EOMBIN.selectByPrimaryKeysForUpdateWait(where_map);

		// 該当レコードが存在しない場合、以下の処理を行います。
		if (map == null)
		{
			// サービス契約ステータスが解約・キャンセル以外の場合、以下の処理を行います。
			if (!isStat(inMap))
			{
				// システム日付を取得
				String sysdate = JCCBatCommon.getSysDateTimeStamp();
				
				value = new String[17];
				value[0] = RNKS_CD;
				value[1] = inMap.getString(JBSbatKKIFM029.SVC_KEI_NO);
				value[2] = inMap.getString(JBSbatKKIFM029.SYSID);
				value[3] = inMap.getString(JBSbatKKIFM029.EOID);
				value[4] = sysdate;				// 登録年月日時分秒
				value[5] = super.batchUserId;	// 登録オペレータアカウント
				value[6] = sysdate;				// 更新年月日時分秒
				value[7] = super.batchUserId;	// 更新オペレータアカウント
				value[8] = "";					// 削除年月日時分秒
				value[9] = "";					// 削除オペレータアカウント
				value[10] = "0";				// 無効フラグ
				value[11] = "";					// 登録運用年月日
				value[12] = "";					// 登録処理ID
				value[13] = "";					// 更新運用年月日
				value[14] = "";					// 更新処理ID
				value[15] = "";					// 削除運用年月日
				value[16] = "";					// 削除処理ID

				// 当日分eoID会員情報ファイルの内容を元に他システム連携済eoID会員情報テーブルへ登録を行います。
				executeKK_T_TSYRN_ZM_EOMBIN_PKINSERT(value);

				// eoID会員情報ファイルへ出力を行います。
				out_bean = setOutData(inMap);
			}
		}
		// 該当レコードが存在した場合、以下の処理を行います。
		else
		{
			// 当日分eoID会員情報ファイルと検索結果を比較し、SYSIDまたはeoIDが相違している場合、以下の処理を行います。
			if (isJudge(inMap, map))
			{
				// サービス契約ステータスが解約・キャンセルの場合、以下の処理を行います。
				if (isStat(inMap))
				{
					// 他システム連携済eoID会員情報テーブルから削除を行います。
					executeKK_T_TSYRN_ZM_EOMBIN_PKDELETE(param);
				}
				// サービス契約ステータスが解約・キャンセル以外の場合、以下の処理を行います。
				else
				{
					value = new String[2];
					value[0] = inMap.getString(JBSbatKKIFM029.SYSID);
					value[1] = inMap.getString(JBSbatKKIFM029.EOID);

					// 当日分eoID会員情報ファイルの内容を元に他システム連携済eoID会員情報テーブルへ更新を行います。
					executeKK_T_TSYRN_ZM_EOMBIN_PKUPDATE(value, param);

					// 当日分eoID会員情報ファイルへ出力を行います。
					out_bean = setOutData(inMap);
				}
			}
		}

		super.logPrint.printDebugLog("execute_END");

		return out_bean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		// eoID会員情報件数ファイルの出力をします
		setOutCnt();

		// FTPフラグファイルの出力をします
		setFtpFile();

		// 連携ファイル制御の前回処理実行年月日時分秒を更新します
		executeRnkiFileCtrl();

		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_KK_T_RNKI_FILE_CTRL.close();
		db_KK_T_TSYRN_ZM_EOMBIN.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * PK(ＰＫ　更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	前回処理実行年月日時分秒				ZNKI_TRAN_RUN_DTM
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	BUTSURI_BAT_ID
	 *		 	FILE_ID
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @return int 更新件数。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private int executeKK_T_RNKI_FILE_CTRL_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("ZNKI_TRAN_RUN_DTM", setParam[0]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
		whereMap.setValue("FILE_ID", whereParam[1]);

		// DBアクセスを実行します
		return db_KK_T_RNKI_FILE_CTRL.updateByPrimaryKeys(whereMap, setMap);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	連携先コード				RNKS_CD
	 *		 	サービス契約番号				SVC_KEI_NO
	 *		 	ＳＹＳＩＤ				SYSID
	 *		 	ｅｏＩＤ				EOID
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 *		 	登録運用年月日				ADD_UNYO_YMD
	 *		 	登録処理ＩＤ				ADD_TRN_ID
	 *		 	更新運用年月日				UPD_UNYO_YMD
	 *		 	更新処理ＩＤ				UPD_TRN_ID
	 *		 	削除運用年月日				DEL_UNYO_YMD
	 *		 	削除処理ＩＤ				DEL_TRN_ID
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TSYRN_ZM_EOMBIN_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("RNKS_CD", setParam[0]);
		setMap.setValue("SVC_KEI_NO", setParam[1]);
		setMap.setValue("SYSID", setParam[2]);
		setMap.setValue("EOID", setParam[3]);
		setMap.setValue("ADD_DTM", setParam[4]);
		setMap.setValue("ADD_OPEACNT", setParam[5]);
		setMap.setValue("UPD_DTM", setParam[6]);
		setMap.setValue("UPD_OPEACNT", setParam[7]);
		setMap.setValue("DEL_DTM", setParam[8]);
		setMap.setValue("DEL_OPEACNT", setParam[9]);
		setMap.setValue("MK_FLG", setParam[10]);
		setMap.setValue("ADD_UNYO_YMD", setParam[11]);
		setMap.setValue("ADD_TRN_ID", setParam[12]);
		setMap.setValue("UPD_UNYO_YMD", setParam[13]);
		setMap.setValue("UPD_TRN_ID", setParam[14]);
		setMap.setValue("DEL_UNYO_YMD", setParam[15]);
		setMap.setValue("DEL_TRN_ID", setParam[16]);
	
		// DBアクセスを実行します
		db_KK_T_TSYRN_ZM_EOMBIN.insertByPrimaryKeys(setMap);
	}

	/**
	 * PK(ＰＫ　更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	ＳＹＳＩＤ				SYSID
	 *		 	ｅｏＩＤ				EOID
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	RNKS_CD
	 *		 	SVC_KEI_NO
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TSYRN_ZM_EOMBIN_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("SYSID", setParam[0]);
		setMap.setValue("EOID", setParam[1]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("RNKS_CD", whereParam[0]);
		whereMap.setValue("SVC_KEI_NO", whereParam[1]);

		// DBアクセスを実行します
		db_KK_T_TSYRN_ZM_EOMBIN.updateByPrimaryKeys(whereMap, setMap);
	}

	/**
	 * PK(ＰＫ　削除)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	RNKS_CD
	 *		 	SVC_KEI_NO
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TSYRN_ZM_EOMBIN_PKDELETE(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("RNKS_CD", whereParam[0]);
		whereMap.setValue("SVC_KEI_NO", whereParam[1]);

		// DBアクセスを実行します
		db_KK_T_TSYRN_ZM_EOMBIN.deleteByPrimaryKeys(whereMap);
	}
	
	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	物理バッチＩＤ				BUTSURI_BAT_ID
	 *		 	ファイルＩＤ				FILE_ID
	 *		 	処理済ファイル通番				TRAN_ZUMI_FILE_SEQ
	 *		 	前回処理実行年月日時分秒				ZNKI_TRAN_RUN_DTM
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 *		 	登録運用年月日				ADD_UNYO_YMD
	 *		 	登録処理ＩＤ				ADD_TRN_ID
	 *		 	更新運用年月日				UPD_UNYO_YMD
	 *		 	更新処理ＩＤ				UPD_TRN_ID
	 *		 	削除運用年月日				DEL_UNYO_YMD
	 *		 	削除処理ＩＤ				DEL_TRN_ID
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_RNKI_FILE_CTRL_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("BUTSURI_BAT_ID", setParam[0]);
		setMap.setValue("FILE_ID", setParam[1]);
		setMap.setValue("TRAN_ZUMI_FILE_SEQ", setParam[2]);
		setMap.setValue("ZNKI_TRAN_RUN_DTM", setParam[3]);
		setMap.setValue("ADD_DTM", setParam[4]);
		setMap.setValue("ADD_OPEACNT", setParam[5]);
		setMap.setValue("UPD_DTM", setParam[6]);
		setMap.setValue("UPD_OPEACNT", setParam[7]);
		setMap.setValue("DEL_DTM", setParam[8]);
		setMap.setValue("DEL_OPEACNT", setParam[9]);
		setMap.setValue("MK_FLG", setParam[10]);
		setMap.setValue("ADD_UNYO_YMD", setParam[11]);
		setMap.setValue("ADD_TRN_ID", setParam[12]);
		setMap.setValue("UPD_UNYO_YMD", setParam[13]);
		setMap.setValue("UPD_TRN_ID", setParam[14]);
		setMap.setValue("DEL_UNYO_YMD", setParam[15]);
		setMap.setValue("DEL_TRN_ID", setParam[16]);
	
		// DBアクセスを実行します
		db_KK_T_RNKI_FILE_CTRL.insertByPrimaryKeys(setMap);
	}
	
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * サービス契約ステータスが解約またはキャンセルか判定します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.解約またはキャンセルの場合trueを返却します。<br>
	 *
	 * </pre>
	 * <p>
	 * @param in_map　入力電文。
	 * @return boolean　判定結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private boolean isStat(JBSbatServiceInterfaceMap in_map) throws Exception
	{
		boolean rtn_value = false;
		String svc_stat = in_map.getString(JBSbatKKIFM029.SVC_KEI_STAT);

		if (KEI_STAT_DSL.equals(svc_stat) || KEI_STAT_CNCL.equals(svc_stat))
		{
			rtn_value = true;
		}

		return rtn_value;
	}

	/**
	 * ＤＢ検索結果と入力電文のSYSID、eoIDの相違チェックをします。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.相違があった場合trueを返却します。<br>
	 *
	 * </pre>
	 * <p>
	 * @param in_map　入力電文。
	 * @param db_map　検索結果。
	 * @return boolean　判定結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private boolean isJudge(JBSbatServiceInterfaceMap in_map, JBSbatCommonDBInterface db_map) throws Exception
	{
		boolean rtn_value = true;

		String in_sysid = in_map.getString(JBSbatKKIFM029.SYSID);
		String in_eoid = in_map.getString(JBSbatKKIFM029.EOID);
		String db_sysid = db_map.getString(JBSbatKK_T_TSYRN_ZM_EOMBIN.SYSID);
		String db_eoid = db_map.getString(JBSbatKK_T_TSYRN_ZM_EOMBIN.EOID);

		if (in_sysid.equals(db_sysid) && in_eoid.equals(db_eoid))
		{
			rtn_value = false;
		}

		return rtn_value;
	}

	/**
	 * eoID会員情報ファイルへ出力をします。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.eoID会員情報ファイルの出力処理をします。<br>
	 *
	 * 2.出力件数に１を足します。<br>
	 *
	 * </pre>
	 * <p>
	 * @param in_map　入力電文。
	 * @return JBSbatOutputItem　出力情報。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatOutputItem setOutData(JBSbatServiceInterfaceMap in_map) throws Exception
	{
		JBSbatOutputItem out_Bean = new JBSbatOutputItem();
		JBSbatServiceInterfaceMap out_map = new JBSbatServiceInterfaceMap();

		out_map.setString(JBSbatKKIFE026001.SVC_KEI_NO, editStringCSV(in_map.getString(JBSbatKKIFM029.SVC_KEI_NO)));
		out_map.setString(JBSbatKKIFE026001.SYSID, editStringCSV(in_map.getString(JBSbatKKIFM029.SYSID)));
		out_map.setString(JBSbatKKIFE026001.EOID, editStringCSV(in_map.getString(JBSbatKKIFM029.EOID)));

		out_map.setOutFlg(true);
		out_Bean.addOutMapList(out_map);

		// 出力件数に＋１を足します。
		out_cnt++;

		return out_Bean;
	}

	/**
	 * eoID会員情報件数ファイルへ出力をします。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.eoID会員情報件数ファイルの出力処理をします。<br>
	 *
	 * </pre>
	 * <p>
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void setOutCnt() throws Exception
	{
		JBSbatOutputFileUtil out_obj = super.commonItem.getOutPutFile2();

		String value = editStringCSV(JBSbatStringUtil.padNumFormString(String.valueOf(out_cnt), 10));

		out_obj.write(value);
	}

	/**
	 * FTPフラグファイルの作成をします。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.FTPフラグファイル名を共通フリー項目から取得します。<br>
	 *
	 * 2.FTPフラグファイルの生成を行います。<br>
	 *
	 * </pre>
	 * <p>
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void setFtpFile() throws Exception
	{
		BufferedWriter out_writer = null;
		String file_nm = super.commonItem.getFreeItem();

		try
		{
			out_writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file_nm)));

			out_writer.newLine();
			out_writer.flush();
		}
		catch(IOException ioe)
		{
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0250CE, new String[]{file_nm, ioe.getMessage()});
		}
		finally
		{
			if (out_writer != null)
			{
				out_writer.close();
			}
		}
	}

	/**
	 * 連携ファイル制御の前回処理実行年月日時分秒を更新ます。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.DBアクセスを実行します。<br>
	 * 
	 * </pre>
	 * <p>
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeRnkiFileCtrl() throws Exception
	{
//		int rslt = 0;
//		String[] value = new String[1];
//		String[] param = new String[2];
//
//		value[0] = JCCBatCommon.getSysDateTimeStamp();
//		param[0] = BAT_ID;
//		param[1] = BAT_ID;
//
//		rslt = executeKK_T_RNKI_FILE_CTRL_PKUPDATE(value, param);
//
//		if (rslt == 0)
//		{
//			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE, new String[]{"KK_T_RNKI_FILE_CTRL", BAT_ID});
//		}
		// 検索条件の設定
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		
		// 物理バッチID
		whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.BUTSURI_BAT_ID, BAT_ID);
		
		// ファイルID
		whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.FILE_ID, BAT_ID);
		
		// 連携ファイル制御排他検索を実施します。
		JBSbatCommonDBInterface outDbMap = db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeysForUpdateWait(whereMap);
		
		// システム日付を取得します。
		String sys_date = JBSbatDateUtil.getSystemDateTimeStamp();
		
		// 検索結果が存在する場合(更新処理の実施)。
		if (null != outDbMap)
		{
			// 連携ファイル制御更新処理を実施します。
			Object[] setParam = new Object[1];
			
			// 抽出適用開始日時を設定。
			setParam[0] = sys_date;
			
			Object[] whereParam = new Object[2];
			whereParam[0] = BAT_ID;
			whereParam[1] = BAT_ID;
			
			// 更新処理の実行
			executeKK_T_RNKI_FILE_CTRL_PKUPDATE(setParam, whereParam);
		}
		
		// 検索結果が存在しない場合(登録処理の実施)。
		else
		{
			// 連携ファイル制御登録処理を実施します。
			Object[] setParam = new Object[17];
			
			// 物理バッチID
			setParam[0]  = BAT_ID;
			// ファイルID
			setParam[1]  = BAT_ID;
			// 処理済ファイル通番
			setParam[2]  = "00000";
			// 前回処理実行年月日時分秒
			setParam[3]  = this.opeDate + sys_date.substring(8);
			setParam[4]  = sys_date;
			setParam[5]  = super.batchUserId;
			setParam[6]  = sys_date;
			setParam[7]  = super.batchUserId;
			setParam[8]  = "";
			setParam[9]  = "";
			setParam[10] = "0";
			setParam[11]  = "";
			setParam[12]  = "";
			setParam[13]  = "";
			setParam[14]  = "";
			setParam[15]  = "";
			setParam[16]  = "";
			
			// 登録処理の実行
			executeKK_T_RNKI_FILE_CTRL_PKINSERT(setParam);
		}
	}

	/**
	 * 文字列に囲み文字を付加します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.文字列の前後に囲み文字を追加します。<br>
	 *
	 * </pre>
	 * <p>
	 * @param data　編集する文字列。
	 * @return String　編集後文字列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String editStringCSV(String data) throws Exception
	{
		StringBuffer value = new StringBuffer();

		value.append(MOJI_D);
		value.append(data);
		value.append(MOJI_D);

		return value.toString();
	}
}
