/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKNippouCsvSakusei
*	ソースファイル名	：JBSbatKKNippouCsvSakusei.java
*	作成者				：富士通　
*	作成日				：2012年06月22日
*＜機能概要＞
*　日報ＣＳＶ作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/06/22   富士通		新規作成
*   v4.00.00    2013/01/23   FJ)三浦     【TAI-2012-0000142】異常メッセージの修正
*********************************************************************/
package eo.business.service;

import java.io.IOException;
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.JBSbatKKIFM221;
import eo.business.util.table.JBSbatKK_T_MDBT_MKC_SRLT;
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.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.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JBSbatAplConst;

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

	/** テーブル(ダウンロードファイル管理)*/
	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_002)*/
	private static final String KK_T_MDBT_MKC_SRLT_KK_SELECT_002 = "KK_SELECT_002";

	/** SQL定義キー(KK_SELECT_003)*/
	private static final String KK_T_MDBT_MKC_SRLT_KK_SELECT_003 = "KK_SELECT_003";

	/** テーブルアクセスクラス(業務パラメータ管理)*/
	private JBSbatSQLAccess db_ZM_M_WORK_PARAM_KNRI = null;

	/** テーブルアクセスクラス(申込日別申込数集計結果)*/
	private JBSbatSQLAccess db_KK_T_MDBT_MKC_SRLT = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** ジョブID（下三桁） **/
	private static final String JOBID_SHIMO3 = "0J0";
	
	/** ジョブID **/
	private String jobId = null;
	
	/** ディレイド処理依頼番号 **/
	private String dlydTrnReqNo = null;
	
	/** 電子ファイル管理番号 **/
	private String efileKanriNo = null;
	
	/** 日報DLファイル削除日数 **/
	private String dlFileDelYmd = null;
	
	/** 日報電子ファイル削除日数 **/
	private String efileDelYmd = null;
	
	/** ファイルパス **/
	private  String fPath = "";
	
	/** ファイル出力件数 **/
	private int count = 0;
	
	/** ファイル名で使用するシステム日付 **/
	private String sysDate = null;
	
	/**
	 * 日報ダウンロードファイルのインデックス
	 */
	private enum FileIndex {
		/** ボタン区分 */
		REC_BOTTON_DIV,
		/** グループID */
		REC_GRP_ID,
		/** 日報、月報区分 */
		NIPO_GEPO_DIV,
		/** 開始年月日 */
		STAYMD,
		/** 終了年月日 */
		ENDYMD
	}
	
	/**
	 * ファイル出力の属性宣言
	 */
	private enum OutFileType {
		/** 日報ダウンロードファイル **/
		KKIFM001(JKKStrConst.MID_ENV_DIR, JKKStrConst.FILE_NM + "_" + JKKStrConst.FILE_NM_TIMESTAMP , "KKIFM221.def", "日報ダウンロードファイル");

		/** ファイルパス */
		private final String FILEPATH;
		/** ファイル名 */
		private final String FILENAME;
		/** defファイル名 */
		private final String DEFNAME;
		/** 日本語ファイル名 */
		private final 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_KK_T_MDBT_MKC_SRLT = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_MDBT_MKC_SRLT);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
		
		//JOBIDを取得する。
		jobId = commonItem.getJobid().substring(0, 8) + JOBID_SHIMO3;
		//運用日付を取得する。
		String opeDate = commonItem.getOpeDate();
		
		//日報DLファイル削除日数
		List<JBSbatCommonDBInterface> workParamDlList = getWorkParamList(opeDate, JKKStrConst.NIPO_DL_DEL_NISU);
		
		if(workParamDlList.isEmpty())
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE, new String[] {
					"業務パラメータ", "業務パラメータＩＤ：" + JKKStrConst.NIPO_DL_DEL_NISU});
		}
		
		//日報DLファイル削除日数
		String nippouDlDelNisu = workParamDlList.get(0).getString("WORK_PARAM_SETTE_VALUE");
		
		try
		{
			dlFileDelYmd = JPCDateUtil.addDay(opeDate, Integer.valueOf(nippouDlDelNisu));
		}
		catch (NumberFormatException e) 
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[] {
					"業務パラメータ.業務パラメータＩＤ." + JKKStrConst.NIPO_DL_DEL_NISU + ":" + nippouDlDelNisu});
		}
		
		//日報電子ファイル削除日数
		List<JBSbatCommonDBInterface> workParamEfileList = getWorkParamList(opeDate, JKKStrConst.NIPO_EFILE_DEL_NISU);
		
		if(workParamEfileList.isEmpty())
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE, new String[] {
					"業務パラメータ", "業務パラメータＩＤ：" + JKKStrConst.NIPO_EFILE_DEL_NISU});
		}
		
		String nippouEfileDelNisu = workParamEfileList.get(0).getString("WORK_PARAM_SETTE_VALUE");
		
		try
		{
			efileDelYmd = JPCDateUtil.addDay(opeDate, Integer.valueOf(nippouEfileDelNisu));
		}
		catch (NumberFormatException e)
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[] {
					"業務パラメータ.業務パラメータＩＤ." + JKKStrConst.NIPO_EFILE_DEL_NISU + ":" + nippouEfileDelNisu});
		}
		
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		//申込日別集計結果の照会結果を格納
		List<JBSbatCommonDBInterface> mdbtMkcSrltList = null;
		//日報ダウンロード依頼パラメータを格納
		List<String[]> fileDataList = new ArrayList<String[]>();
		
		// 日報ダウンロード依頼パラメータの取得
		String[] nipoDlParamList = this.getDlydShoriIrai();

		// 戻り値がnullの場合は処理を終了する
		if (JKKCommonUtil.isNull(nipoDlParamList))
		{
			return null;
		}
		
		sysDate = JCCBatCommon.getSysDateTime();
		
		for(int i = 0; i < nipoDlParamList.length; i++)
		{
			String[] nipoParam = nipoDlParamList[i].split(",");
			
			//フォーマットチェック（データ部のチェック）
			// 該当データが最終レコードかつ要素数が５でない場合
			if(i == nipoDlParamList.length - 1 &&  nipoParam.length != 5)
			{
				// コネクションのロールバック
				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[]{"電子ファイルに登録されているファイルの項目数(期待値：5,実際：" + nipoParam.length + ",電子ファイル管理番号：" + efileKanriNo + ")"});
			}
			
			fileDataList.add(nipoParam);
		}
		
		//日報ダウンロード依頼パラメータの取得
		List<HashMap<String, Object>> list = getNipoParamDate(fileDataList);
		
		//グループID
		String grpId = (String)list.get(0).get("GRP_ID");
		//開始年月日
		String staYmd = (String)list.get(0).get("STAYMD");
		//終了年月日
		String endYmd = (String)list.get(0).get("ENDYMD");
		
		if(JKKStrConst.AGNT_SBT_CD_OTHER.equals(grpId))
		{
			//申込日別集計結果一覧照会（グループIDなし）
			mdbtMkcSrltList = getMdbtMkcSrltGrpIdNon(staYmd, endYmd);
		}
		else
		{
			//申込日別集計結果一覧紹介（グループIDあり）
			mdbtMkcSrltList = getMdbtMkcSrltGrpIdAri(grpId, staYmd, endYmd);
		}
		
		//出力ファイルリストにデータを出力する。
		List<Map<String, Object>> outMapList = new ArrayList<Map<String, Object>>();

		for(JBSbatCommonDBInterface mdbtMkcStltMap : mdbtMkcSrltList)
		{
			outMapList.add(convertMap(mdbtMkcStltMap));
			count++;
		}
		
		//ディレイド処理依頼結果更新を行う。
		JCCBatCommon.updateShoriIraiResult(commonItem, dlydTrnReqNo, JKKStrConst.DLYD_TRN_RSLT_CD_COMPLETE, null);
		
		// ファイル出力用リストを返却用パラメータにセットする
		fPath = putKKFile(OutFileType.KKIFM001, outMapList, true);
		
		//電子ファイル管理テーブル、ダウンロード管理テーブルに登録する。
		addEfileKanri();
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

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

	/**
	 * SQLKEY(KK_SELECT_003)で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_MDBT_MKC_SRLT_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_KK_T_MDBT_MKC_SRLT.selectBySqlDefine(paramList, KK_T_MDBT_MKC_SRLT_KK_SELECT_003);
	}

	/**
	 * 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);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * 業務パラメータをキーに業務パラメータ設定値を取得する。
	 * @param opeDate
	 * @param workParamId
	 * @return selectList
	 * @throws Exception 
	 */
	private List<JBSbatCommonDBInterface> getWorkParamList(String opeDate, String workParamId) throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		
		Object[] param = {workParamId, opeDate, opeDate};
		
		executeZM_M_WORK_PARAM_KNRI_KK_SELECT_003(param);
		
		JBSbatCommonDBInterface selectMap =  new JBSbatCommonDBInterface();
		
		while(true)
		{
			selectMap = db_ZM_M_WORK_PARAM_KNRI.selectNext();
			if(selectMap != null)
			{
				selectList.add(selectMap);
			}
			else
			{
				break;
			}			
		}
		
		return selectList;
	}
	
	/**
	 * 申込日別集計結果から条件に適合したデータを抽出する。（グループID：指定なし）
	 * @param staYmd
	 * @param endYmd
	 * @return selectList
	 * @throws Exception
	 */
	private List<JBSbatCommonDBInterface> getMdbtMkcSrltGrpIdNon(String staYmd, String endYmd) throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		
		Object[] param = {staYmd, endYmd}; 
		
		executeKK_T_MDBT_MKC_SRLT_KK_SELECT_002(param);
		
		JBSbatCommonDBInterface selectMap = new JBSbatCommonDBInterface();
		
		
		while(true)
		{
			selectMap = db_KK_T_MDBT_MKC_SRLT.selectNext();
			
			if(selectMap != null)
			{
				selectList.add(selectMap);
			}
			else
			{
				break;
			}
		}
		return selectList;
	}
	
	/**
	 * 申込日別集計結果から条件に適合したデータを抽出する。（グループID：指定あり）
	 * @param grpId
	 * @param staYmd
	 * @param endYmd
	 * @return selectList
	 * @throws Exception
	 */
	private List<JBSbatCommonDBInterface> getMdbtMkcSrltGrpIdAri(String grpId, String staYmd, String endYmd) throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		
		Object[] param = {grpId, staYmd, endYmd};
		
		executeKK_T_MDBT_MKC_SRLT_KK_SELECT_003(param);
		
		JBSbatCommonDBInterface selectMap = new JBSbatCommonDBInterface();
		
		
		while(true)
		{
			selectMap = db_KK_T_MDBT_MKC_SRLT.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>();
		
		convertMap.put(JBSbatKKIFM221.SHUK_TG_MSKM_YMD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.SHUK_TG_MSKM_YMD));
		convertMap.put(JBSbatKKIFM221.AGNT_SBT_CD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.AGNT_SBT_CD));
		convertMap.put(JBSbatKKIFM221.SVC_TYPE_SKBT_CD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.SVC_TYPE_SKBT_CD));
		convertMap.put(JBSbatKKIFM221.INTR_CMP_FLG, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.INTR_CMP_FLG));
		convertMap.put(JBSbatKKIFM221.AGNT_SHUK_KMK_CD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.AGNT_SHUK_KMK_CD));
		convertMap.put(JBSbatKKIFM221.MSKM_FORM_CD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_FORM_CD));
		convertMap.put(JBSbatKKIFM221.KARI_MSKM_FLG, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.KARI_MSKM_FLG));
		convertMap.put(JBSbatKKIFM221.MSKMSHA_CNT, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKMSHA_CNT));
		convertMap.put(JBSbatKKIFM221.MSKMSHA_CNT_NET, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKMSHA_CNT_NET));
		convertMap.put(JBSbatKKIFM221.MSKMSHA_CNT_TEL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKMSHA_CNT_TEL));
		convertMap.put(JBSbatKKIFM221.MSKMSHA_CNT_TV, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKMSHA_CNT_TV));
		convertMap.put(JBSbatKKIFM221.MSKMSHA_CNT_MOBILE, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKMSHA_CNT_MOBILE));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET_TEL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET_TEL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_3T_SET, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_3T_SET));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET_TV, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET_TV));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TEL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TEL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_TEL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_TEL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET_TEL_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET_TEL_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_4T_SET, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_4T_SET));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_NET_TV_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_NET_TV_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TEL_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TEL_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_TEL_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_TEL_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_MBL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_MBL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_DOJI, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_DOJI));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_ADD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_ADD));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_TV_SNGL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_TV_SNGL));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_MBL_DOJI, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_MBL_DOJI));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_MBL_ADD, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_MBL_ADD));
		convertMap.put(JBSbatKKIFM221.MSKM_CNT_MBL_SNGL, dateMap.getString(JBSbatKK_T_MDBT_MKC_SRLT.MSKM_CNT_MBL_SNGL));

		return convertMap;
	}
	
	/**
	 * ディレイド処理依頼を行います。<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>> getNipoParamDate(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>();
			//グループID
			paramMap.put("GRP_ID", henpinJoho[FileIndex.REC_GRP_ID.ordinal()]);
			//開始年月日
			paramMap.put("STAYMD", henpinJoho[FileIndex.STAYMD.ordinal()]);
			//終了年月日
			paramMap.put("ENDYMD", henpinJoho[FileIndex.ENDYMD.ordinal()]);
			returnList.add(paramMap);
		}
		return returnList;
	}
	
	/**
	 * 電子ファイルスキーマ登録
	 * @throws Exception
	 */
	private void addEfileKanri() throws Exception
	{
		// 電子ファイル管理スキーマ登録
		String[] eFileInfo = new String[]{};
		try
		{
			eFileInfo = JCCBatCommon.createDenshiFile(commonItem, JKKStrConst.FILE_CD, fPath, efileDelYmd);
		}
		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(JKKStrConst.TRAN_KANRI_NO_NIPO);
		//  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(dlFileDelYmd);
		//  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());
	}

	/**
	 * ファイルタイプからファイルパスを作成する
	 * @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();
				super.logPrint.printDebugLog("ファイル書込みオブジェクトのクローズ失敗:" + filePath);
				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 + "\"";
	}
}