/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKLoginJskCsvSaksei
*	ソースファイル名	：JBSbatKKLoginJskCsvSaksei.java
*	作成者				：富士通　
*	作成日				：2012年09月15日
*＜機能概要＞
*　ログイン実績ＣＳＶ作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/09/15   富士通		新規作成
*   v4.01.00    2013/01/24   FJ)三浦     【TAI-2012-0000142】異常メッセージの修正
*   v5.00.00    2013/09/03   FJ)松田     【OM-2013-0001539】申込実績集計ツール読込エラー対応
*********************************************************************/
package eo.business.service;

import java.io.IOException;
import java.text.DateFormat;
import java.text.ParseException;
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.util.file.JBSbatKKIFM263;
import eo.business.util.table.JBSbatFU_T_AGUSR_LOGIN_JSK;
import eo.common.constant.JKKStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JCCFileUtil;
import eo.common.util.JKKCommonUtil;
import eo.common.util.JPCDateUtil;
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.application.JCCbatFrameworkException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.util.JBSbatAplConst;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKLoginJskCsvSaksei extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(業務パラメータ管理)*/
	private static final String D_TBL_NAME_ZM_M_WORK_PARAM_KNRI = "ZM_M_WORK_PARAM_KNRI";

	/** テーブル(代理店ユーザーログイン実績)*/
	private static final String D_TBL_NAME_FU_T_AGUSR_LOGIN_JSK = "FU_T_AGUSR_LOGIN_JSK";

	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

	/** SQL定義キー(KK_SELECT_003)*/
	private static final String ZM_M_WORK_PARAM_KNRI_KK_SELECT_003 = "KK_SELECT_003";

	/** SQL定義キー(KK_SELECT_001)*/
	private static final String FU_T_AGUSR_LOGIN_JSK_KK_SELECT_001 = "KK_SELECT_001";

	/** テーブルアクセスクラス(業務パラメータ管理)*/
	private JBSbatSQLAccess db_ZM_M_WORK_PARAM_KNRI = null;

	/** テーブルアクセスクラス(代理店ユーザーログイン実績)*/
	private JBSbatSQLAccess db_FU_T_AGUSR_LOGIN_JSK = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/**	ファイル削除年月日 **/
	private String fileDelYmd = null;

	/** ディレイド処理依頼番号 **/
	private String dlydTrnReqNo = null;
	
	/** 電子ファイル管理番号 **/
	private String efileKanriNo = null;
	
	/** ファイル名で使用するシステム日付 **/
	private String sysDate = null;

	/** ファイルパス **/
	private  String fPath = "";

	/** ファイル出力件数 **/
	private int count = 0;
	
	/**
	 * ログイン実績ＣＳＶ作成ダウンロードファイルのインデックス
	 */
	private enum FileIndex {
		/** 開始年月日 */
		STAYMD,
		/** 終了年月日 */
		ENDYMD
	}
	
	/** ログイン実績ダウンロードファイル名 **/
	private static final	String	LOGINRECORDFILENAME = "LoginRecord";
	
	/** ログイン実績ダウンロードファイル処理管理番号 **/
	private static final String TRAN_KANRI_NO_LOGINRECORD = "000000000077";
	
	/** 電子ファイル管理　ファイルコード **/
	private static final String FILE_CD = "1128";
	
	/**
	 * ファイル出力の属性宣言
	 */
	private enum OutFileType {
		/** ログイン実績ダウンロードファイル **/
		KKIFM263(JKKStrConst.MID_ENV_DIR, LOGINRECORDFILENAME + "_" + JKKStrConst.FILE_NM_TIMESTAMP , "KKIFM263.def", "ログイン実績ダウンロードファイル");

		/** ファイルパス */
		private String filePath;
		/** ファイル名 */
		private String fileName;
		/** defファイル名 */
		private String defName;
		/** 日本語ファイル名 */
		private String fileJPName;

		/**
		 * ファイル出力宣言のコンストラクタ
		 * @param filePath ファイルパス
		 * @param fileName ファイル名
		 * @param defName defファイル名
		 * @param fileJPName 日本語ファイル名
		 */
		private OutFileType(String filePath, String fileName, String defName, String fileJPName)
		{
			this.filePath = filePath;
			this.fileName = fileName;
			this.defName = defName;
			this.fileJPName = fileJPName;
		}
	}
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_ZM_M_WORK_PARAM_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_WORK_PARAM_KNRI);
		db_FU_T_AGUSR_LOGIN_JSK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_FU_T_AGUSR_LOGIN_JSK);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		//日報DLファイル削除日数を取得する。
		Object[]	param = {JKKStrConst.NIPO_DL_DEL_NISU, commonItem.getOpeDate(), commonItem.getOpeDate()};
		
		executeZM_M_WORK_PARAM_KNRI_KK_SELECT_003(param);
		
		JBSbatCommonDBInterface mapMskm = new JBSbatCommonDBInterface();
		
		// 業務パラメータの取得
		mapMskm = db_ZM_M_WORK_PARAM_KNRI.selectNext();
		String	deleteDays = null;
		if(mapMskm != null)
		{
			deleteDays = mapMskm.getString("WORK_PARAM_SETTE_VALUE");
			
			if(deleteDays == null)
			{
				// 業務パラメータから日報DL削除日数が取得できなければ、例外をthrowする
				throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0520CE, new String[] {
						"業務パラメータ", "業務パラメータＩＤ：" + JKKStrConst.NIPO_DL_DEL_NISU});
			}
		}
		else
		{
			// 業務パラメータから日報DL削除日数が取得できなければ、例外をthrowする
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0520CE, new String[] {
					"業務パラメータ", "業務パラメータＩＤ：" + JKKStrConst.NIPO_DL_DEL_NISU});
		}

		try
		{
			fileDelYmd = JPCDateUtil.addDay(opeDate, Integer.valueOf(deleteDays));
		}
		catch (NumberFormatException e)
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[] {
					"業務パラメータ.業務パラメータＩＤ." + JKKStrConst.NIPO_DL_DEL_NISU + ":" + deleteDays});
		}
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 代理店ユーザーログイン実績の照会結果を格納
		List<JBSbatCommonDBInterface> loginJskList = null;
		// ログイン実績ＣＳＶ作成ダウンロード依頼パラメータを格納
		List<String[]> fileDataList = new ArrayList<String[]>();
		// ログイン実績ＣＳＶ作成ダウンロード依頼パラメータの取得
		String[] loginJskParamList = this.getDlydShoriIrai();
		DateFormat format = DateFormat.getDateInstance();
		format.setLenient(false);
		int	n = 0;
		// 日付フォーマットチェック
		StringBuffer	sb = null;
		// 戻り値がnullの場合は処理を終了する
		if (JKKCommonUtil.isNull(loginJskParamList))
		{
			return null;
		}
		
		sysDate = JCCBatCommon.getSysDateTime();
		
		try
		{
			for(int i = 0; i < loginJskParamList.length; i++)
			{
				String[] nipoParam = loginJskParamList[i].split(",");
				
				//フォーマットチェック（データ部のチェック）
				// 該当データが最終レコードかつ要素数が2でない場合
				if(i == loginJskParamList.length - 1 &&  nipoParam.length != 2)
				{
					// コネクションのロールバック
					commonItem.getConnection().rollback();

					// ディレイド処理依頼結果更新
					JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_SYS_ERR, null);

					// コネクションのコミット
					commonItem.getConnection().commit();

					// システムエラーログの出力
					throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0530CE, 
							new String[]{"電子ファイルに登録されているファイルの項目数(期待値：2,実際：" +
							nipoParam.length + ",電子ファイル管理番号：" + efileKanriNo + ")"});
				}
				
				// 日付フォーマットチェック
				n = 0;
				sb = new StringBuffer(nipoParam[n]);
				
				format.parse(sb.substring(0, 4) + "/" + sb.substring(4, 6) + "/" + sb.substring(6, 8));
				n++;
				
				sb = new StringBuffer(nipoParam[n]);
				format.parse(sb.substring(0, 4) + "/" + sb.substring(4, 6) + "/" + sb.substring(6, 8));
				
				fileDataList.add(nipoParam);
			}
		}
		catch(ParseException e)
		{
			// コネクションのロールバック
			commonItem.getConnection().rollback();

			// ディレイド処理依頼結果更新
			JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_SYS_ERR, null);

			// コネクションのコミット
			commonItem.getConnection().commit();

			if(n == 0)
			{
				// システムエラーログの出力
				throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE,
						new String[]{"電子ファイル管理番号：" + efileKanriNo + ",電子ファイルの開始年月日：" + sb});
			}
			else
			{
				// システムエラーログの出力
				throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE,
						new String[]{"電子ファイル管理番号：" + efileKanriNo + ",電子ファイルの終了年月日：" + sb});
			}
		}
		
		//日報ダウンロード依頼パラメータの取得
		List<HashMap<String, Object>> list = getLoginJskParamDate(fileDataList);
		
		//開始年月日
		String staYmd = (String)list.get(0).get("STAYMD");
		//終了年月日
		String endYmd = (String)list.get(0).get("ENDYMD");
		
		// 代理店ユーザーログイン実績から対象データ抽出
		loginJskList = getLoginJsk(staYmd, endYmd);
		
		//出力ファイルリストにデータを出力する。
		List<Map<String, Object>> outMapList = new ArrayList<Map<String, Object>>();
		
		String oldBreakKey = "";
		for(JBSbatCommonDBInterface loginJskMap : loginJskList)
		{
			Map<String, Object> outputDataMap = convertMap(loginJskMap);
			// ログイン日時
			String loginDate = (String)outputDataMap.get(JBSbatKKIFM263.LOGIN_DTM);
			// ログインＩＤ
			String userId = (String)outputDataMap.get(JBSbatKKIFM263.USER_ID);
			
			String newBreakKey = loginDate + userId;
			if (!oldBreakKey.equals(newBreakKey))
			{
				outMapList.add(outputDataMap);
				count++;
			}
			
			oldBreakKey = newBreakKey;
		}
		
		//ディレイド処理依頼結果更新を行う。
		JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_COMPLETE, null);
		
		// ファイル出力用リストを返却用パラメータにセットする
		fPath = putKKFile(OutFileType.KKIFM263, outMapList, false);
		
		//電子ファイル管理テーブル、ダウンロード管理テーブルに登録する。
		addEfileKanri();
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_ZM_M_WORK_PARAM_KNRI.close();
		db_FU_T_AGUSR_LOGIN_JSK.close();
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_003)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	業務パラメータID
	 *		 	運用日付
	 *		 	運用日付
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_M_WORK_PARAM_KNRI_KK_SELECT_003(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_ZM_M_WORK_PARAM_KNRI.selectBySqlDefine(paramList, ZM_M_WORK_PARAM_KNRI_KK_SELECT_003);
	}

	/**
	 * 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 executeFU_T_AGUSR_LOGIN_JSK_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_FU_T_AGUSR_LOGIN_JSK.selectBySqlDefine(paramList, FU_T_AGUSR_LOGIN_JSK_KK_SELECT_001);
	}

	/**
	 * 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
	 *		 	登録運用年月日				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 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]);
		setMap.setValue("ADD_UNYO_YMD", setParam[15]);
		setMap.setValue("ADD_TRN_ID", setParam[16]);
		setMap.setValue("UPD_UNYO_YMD", setParam[17]);
		setMap.setValue("UPD_TRN_ID", setParam[18]);
		setMap.setValue("DEL_UNYO_YMD", setParam[19]);
		setMap.setValue("DEL_TRN_ID", setParam[20]);
	
		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * ディレイド処理依頼を行います。<br>
	 * 
	 * @return 配送番号の配列（IN条件）
	 * @throws Exception
	 */
	private String[] getDlydShoriIrai() throws Exception
	{

		// ディレイド処理依頼取得
		ArrayList<HashMap<String, Object>> dlydShoriIraiList
					= JCCBatCommon.getShoriIraiInfo(commonItem, jobid);

		// ディレイド処理依頼が存在しなかった場合
		if (JKKCommonUtil.isNull(dlydShoriIraiList))
		{
			//日報CVS作成処理を終了します。
			return null;
		}

		// ディレイド処理依頼情報から最後のHashMapを取得する。
		HashMap<String, Object> dlydMap = dlydShoriIraiList.get(dlydShoriIraiList.size() - 1);

		dlydTrnReqNo = dlydMap.get("DLYD_TRN_REQ_NO").toString();
		
		//電子ファイル管理番号
        efileKanriNo = dlydMap.get("INPUT_EFILE_KANRI_NO").toString();

		// 実ファイル存在チェック
		if (JKKCommonUtil.isNull((byte[])dlydMap.get("INPUT_EFILE")))
		{

			// ディレイド処理依頼結果更新
			JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_APP_ERR, null);

			// マイナーエラー処理
			commonItem.addErrorCount(1);

			// 実ファイル(解凍済)が存在しない場合はマイナーエラーとして処理を終了
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0520CE,
					new String[]{"電子ファイル管理テーブルの電子ファイル", "(電子ファイル管理番号:" + efileKanriNo + ")"});
			return null;
		}

		// マップから実ファイルを取得
		byte[] dlydByte = (byte[])dlydMap.get("INPUT_EFILE");

		// ファイルの中身を取得する
		String dlydString = new String(dlydByte, JKKStrConst.CHAR_SET_WIN31J);

		// 文字列から改行コードで分割
		String[] strDlydList = dlydString.split(JKKStrConst.LINE_SEPARATOR);

		// 配列の第１要素が空の場合、
		if (JKKCommonUtil.isNull(strDlydList[0]))
		{
			// ディレイド処理依頼結果更新
			JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_APP_ERR, null);

			// マイナーエラー処理
			commonItem.addErrorCount(1);

			// 業務エラーログの出力
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0520CE,
					new String[]{"電子ファイル管理テーブルの電子ファイル内容の", "(電子ファイル管理番号:" + efileKanriNo + ")"});
			return null;
		}
		return strDlydList;
	}
	
	/**
	 * ログイン実績ＣＳＶ作成ダウンロード依頼パラメータ
	 * @param outputlist
	 * @return returnList
	 */
	private List<HashMap<String, Object>> getLoginJskParamDate(List<String[]> outputlist)
	{
		//返却リスト
		List<HashMap<String, Object>> returnList = new ArrayList<HashMap<String, Object>>();
		
		for(String[] henpinJoho : outputlist)
		{
			HashMap<String, Object> paramMap = new HashMap<String, Object>();
			//開始年月日
			paramMap.put("STAYMD", henpinJoho[FileIndex.STAYMD.ordinal()]);
			//終了年月日
			paramMap.put("ENDYMD", henpinJoho[FileIndex.ENDYMD.ordinal()]);
			returnList.add(paramMap);
		}
		return returnList;
	}
	
	/**
	 * 代理店ユーザーログイン実績から条件に適合したデータを抽出する。
	 * @param staYmd
	 * @param endYmd
	 * @return selectList
	 * @throws Exception
	 */
	private List<JBSbatCommonDBInterface> getLoginJsk(String staYmd, String endYmd) throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		
		Object[] param = {this.opeDate, staYmd, endYmd};
		
		executeFU_T_AGUSR_LOGIN_JSK_KK_SELECT_001(param);
		
		JBSbatCommonDBInterface selectMap = new JBSbatCommonDBInterface();
		
		
		while(true)
		{
			selectMap = db_FU_T_AGUSR_LOGIN_JSK.selectNext();
			
			if(selectMap != null)
			{
				selectList.add(selectMap);
			}
			else
			{
				break;
			}
		}
		return selectList;
	}
	
	/**
	 * ファイル出力型式に変換する。
	 * @param dateMap
	 * @return convertMap
	 * @throws Exception
	 */
	private Map<String, Object> convertMap(JBSbatCommonDBInterface dateMap) throws Exception
	{
		Map<String, Object> convertMap = new HashMap<String, Object>();
		
		// 日付変換
		String	work = dateMap.getString(JBSbatFU_T_AGUSR_LOGIN_JSK.LOGIN_DTM);
		work = work.substring(0, 4) + "/" + work.substring(4, 6) + "/" + work.substring(6, 8)
			+ " " + work.substring(8, 10) + ":" + work.substring(10, 12) + ":" + work.substring(12, 14);
		convertMap.put(JBSbatKKIFM263.LOGIN_DTM, work);
		convertMap.put(JBSbatKKIFM263.USER_ID, dateMap.getString(JBSbatFU_T_AGUSR_LOGIN_JSK.USER_ID));
		convertMap.put(JBSbatKKIFM263.AGNT_CD, dateMap.getString(JBSbatFU_T_AGUSR_LOGIN_JSK.AGNT_CD));
		convertMap.put(JBSbatKKIFM263.UK_TNTSHA_SKBT_CD, dateMap.getString(JBSbatFU_T_AGUSR_LOGIN_JSK.UK_TNTSHA_SKBT_CD));
		convertMap.put(JBSbatKKIFM263.FIRST_LOGIN_FLG, dateMap.getString(JBSbatFU_T_AGUSR_LOGIN_JSK.FIRST_LOGIN_FLG));

		return convertMap;
	}
	
	/**
	 * ファイルタイプからファイルパスを作成する
	 * @param fileType ファイルタイプ
	 * @return ファイルパス
	 * @throws Exception 例外
	 */
	private String createOutFileType2FilePath(OutFileType fileType) throws Exception
	{
		String filePath = rnktPath(JBSbatAplConst.getAplConstValue(JKKStrConst.MID_ENV_DIR), fileType.fileName);
		return filePath.replaceAll(JKKStrConst.FILE_TIMESTAMP_FORMAT, getOpeDateTime());
	}
	
	/**
	 * ファイルの出力処理
	 * @param fileType 出力ファイルタイプ
	 * @param dataList 出力データ
	 * @param doubleFlg
	 * @return 出力ファイル名
	 * @throws Exception 例外
	 */
	private String putKKFile(OutFileType fileType, List<Map<String, Object>> dataList, boolean doubleFlg) throws Exception
	{
		String filePath = createOutFileType2FilePath(fileType);

		// 出力ファイル形式設定
		JBSbatOutputFileUtil outFile = new JBSbatOutputFileUtil(filePath);
		outFile.setEncode(JKKStrConst.ENCODE_SJIS);		// 文字コード
		outFile.setLine(JKKStrConst.LINE_LF);			// 改行コード

		try
		{
			outFile.createWriter();
		}
		catch (IOException ex)
		{
			commonItem.getConnection().rollback();
			commonItem.getLogPrint().printBusinessErrorLog(fileType.fileJPName + "作成失敗");
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0500CE,
					new String[] {"(ファイルパス：" + filePath + ",ディレイド処理依頼番号：" + dlydTrnReqNo + ")"});
		}
		
		try
		{
			String defFile = this.rnktPath(JBSbatAplConst.getAplConstValue(JKKStrConst.KK_DIR_IND), fileType.defName);
			JBSbatDefFileUtil defDataUtil = new JBSbatDefFileUtil(defFile, outFile);

			JBSbatServiceInterfaceMap outDataMap = null;
			String data = "";
			
			for (Map<String, Object> dataMap : dataList)
			{
				outDataMap = new JBSbatServiceInterfaceMap();

				for (String key : dataMap.keySet())
				{
					data = (String)dataMap.get(key);
					if (doubleFlg)
					{
						data = encloseDQuot(data);
					}
					
					outDataMap.set(key, data);
				}

				outFile.print(outDataMap, defDataUtil);
			}

		}
		catch (IOException ex)
		{
			commonItem.getConnection().rollback();
			commonItem.getLogPrint().printBusinessErrorLog(fileType.fileJPName + "書き込み失敗");			
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0970CE, new String[] {"ディレイド処理依頼番号：" + dlydTrnReqNo});
		}
		finally
		{
			// ファイルのクローズ
			try
			{
				outFile.close();
			}
			catch (IOException ex2)
			{
				commonItem.getConnection().rollback();
				commonItem.getLogPrint().printBusinessErrorLog(fileType.fileJPName + "書き込み失敗");
				throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0970CE, new String[] {"ディレイド処理依頼番号：" + dlydTrnReqNo});
			}
		}
		
		return filePath;
	}
	
	/**
	 * パス文字列の連結
	 * 連結するパス文字列にパス区切り文字の設定を制御する。
	 * @param path1 パス文字列
	 * @param path2 パス文字列
	 * @return 連結したパス文字列
	 */
	private String rnktPath(String path1, String path2)
	{
		String pathDlmt = JKKStrConst.PATH_DLMT_UNIX;
		if (path1.indexOf(JKKStrConst.PATH_DLMT_WIN) > -1 || path2.indexOf(JKKStrConst.PATH_DLMT_WIN) > -1)
		{
			pathDlmt = JKKStrConst.PATH_DLMT_WIN;
		}
		if (!path1.endsWith(pathDlmt))
		{
			return path1 + pathDlmt + path2;
		}
		return path1 + path2;
	}
	
	/**
	 * 運用日付時分秒の取得を行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.運用日付(yyyyMMdd) + システム日時(hhmmss)を返却します。<br>
	 * </pre>
	 * <p>
	 * @return String 運用日付時分秒。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String getOpeDateTime() throws Exception 
	{
		StringBuffer dateTime = new StringBuffer();
		
		dateTime.append(sysDate);

		return dateTime.toString();
	}
	
	/**
	 * ダブルクォーテーション囲みを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で囲み対象文字を設定します。<br>
	 * </pre>
	 * <p>
	 * @param strTarget     囲み対象文字
	 * @return strRec       文字列連結結果を返却します。
	 */
	private String encloseDQuot(String strTarget)
	{
		if (null == strTarget)
		{
			return "\"\"";
		}
		return "\"" + strTarget + "\"";
	}

	/**
	 * 電子ファイルスキーマ登録
	 * @throws Exception
	 */
	private void addEfileKanri() throws Exception
	{
		// 電子ファイル管理スキーマ登録
		String[] eFileInfo = new String[]{};
		try
		{
			eFileInfo = JCCBatCommon.createDenshiFile(commonItem, FILE_CD, fPath, fileDelYmd);
		}
		catch(JCCbatFrameworkException jccBatFraExc)
		{
			super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB0510CE, new String[] {"電子ファイル管理",
					"(FILE_CD=".concat(JKKStrConst.FILE_CD).concat(",filePath=").concat(fPath).
					concat(",ディレイド処理依頼番号：").concat(dlydTrnReqNo).concat(")")});
			throw jccBatFraExc;
		}
		
		// ダウンロードファイル管理スキーマ登録
		insZmTDlFileKanri(eFileInfo);
	}

	/**
	 * ダウンロードファイル管理スキーマに登録します。
	 * 
	 * @param eFileInfo 電子ファイル管理情報
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void insZmTDlFileKanri(String[] eFileInfo) throws Exception
	{

		JBSbatCommonDBInterface param = new JBSbatCommonDBInterface();
		//  1.ファイル番号
		param.setValue(JCCBatCommon.getFormatedNextSeq(commonItem, JKKStrConst.SEQ_FILE_NO, JKKStrConst.SEQ_PREFIX_SEQ_FILE_NOO,
					JKKStrConst.SEQ_LEN_SEQ_FILE_NO));
		//  2.処理管理番号
		param.setValue(TRAN_KANRI_NO_LOGINRECORD);
		//  3.電子ファイル管理番号
		param.setValue(eFileInfo[0]);
		//  4.ファイル名
		String[] fileName = fPath.split("/", -1);
		param.setValue(fileName[fileName.length - 1]);
		//  5.ファイルサイズ
		param.setValue(JCCFileUtil.getFileSize(fPath));
		//  6.データ件数
		param.setValue(count);
		//  7.ファイル登録年月日時分秒
		param.setValue(eFileInfo[1]);
		//  8.ファイル削除年月日
		param.setValue(fileDelYmd);
		//  9.登録年月日時分秒
		param.setValue(null);
		// 10.登録オペレータアカウント
		param.setValue(null);
		// 11.更新年月日時分秒
		param.setValue(null);
		// 12.更新オペレータアカウント
		param.setValue(null);
		// 13.削除年月日時分秒
		param.setValue(null);
		// 14.削除オペレータアカウント
		param.setValue(null);
		// 15.無効フラグ
		param.setValue(null);
		//登録運用年月日
		param.setValue("ADD_UNYO_YMD");
		//登録処理ID
		param.setValue("ADD_TRN_ID");
		//更新運用年月日
		param.setValue("UPD_UNYO_YMD");
		//更新処理ID
		param.setValue("UPD_TRN_ID");
		//削除運用年月日
		param.setValue(null);
		//削除処理ID
		param.setValue(null);

		// SQL実行
		executeZM_T_DL_FILE_KANRI_PKINSERT(param.getList().toArray());
	}

}
