/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKHnsokuCdCstRlthei
*	ソースファイル名	：JBSbatKKHnsokuCdCstRlthei.java
*	作成者				：富士通　
*	作成日				：2011年09月30日
*＜機能概要＞
*　販売促進コード抽出結果反映部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/09/30   富士通		新規作成
*	v2.00.00	2012/04/23  FJ)砂川		【ST2-2012-0000509】データ抽出項目設定対象契約登録処理を削除
*	v2.01.00	2012/05/11  FJ)藤原		【ST2-2012-0000509】電子ファイル管理・ダウンロードファイル管理登録処理を追加
*   v4.00.00	2013/02/08  FJ)泉		【TAI-2012-0000143】バッチ異常終了時のログのメッセージ修正
*	v5.00.00	2013/04/14  FJ)掛木		【ST6-2013-0000031】ディレード対応
*	v5.00.01	2013/10/21  FJ)鈴木		【OM-2013-0002358】ディレード共通部品変更対応
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;
import java.util.HashMap;

import eo.business.common.JBSBatKKShoriIraiUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.common.JKKBatConst;
import eo.business.util.file.JBSbatKKIFM094;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.common.util.JKKStringUtil;
import eo.framework.db.JBSbatSQLAccess;
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.JBSbatCheckUtil;

/**
* データ一括登録画面にて登録された販売促進データ抽出結果ファイルより、データ抽出項目設定に実績を更新する。<br>
*<BR>
* @author 富士通
*/
public class JBSbatKKHnsokuCdCstRlthei extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(データ抽出項目設定)*/
	private static final String D_TBL_NAME_KK_T_DCHSKMST = "KK_T_DCHSKMST";

	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

	/** SQL定義キー(KK_UPDATE_001)*/
	private static final String KK_T_DCHSKMST_KK_UPDATE_001 = "KK_UPDATE_001";

	/** SQL定義キー(KK_UPDATE_002)*/
	private static final String KK_T_DCHSKMST_KK_UPDATE_002 = "KK_UPDATE_002";

	/** SQL定義キー(KK_INSERT_001)*/
	private static final String ZM_T_DL_FILE_KANRI_KK_INSERT_001 = "KK_INSERT_001";

	/** テーブルアクセスクラス(データ抽出項目設定)*/
	private JBSbatSQLAccess db_KK_T_DCHSKMST = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** データ抽出項目設定ステータス（完了済）*/
	private static final String DCHSKMST_STAT_FIN = "100";

	/** データ抽出項目設定完了種別コード（適用済）*/
	private static final String DCHSKMST_FIN_SBT_CD_APLY = "010";

	/** 適用数判別コード（回数）*/
	private static final String APLY_CNT_HAMBET_CD_CNT = "2";

	/** 更新済みデータ抽出項目設定番号の記憶用マップ*/
	private ArrayList<String> memoryDchskmstNo = new ArrayList<String>();

	/** 処理管理番号「販売促進コード抽出」 */
	private static final String TRN_KANRI_NO = "000000000026";

	// 2013/04/14 ST6-2013-0000031 add start
	/** ディレイド処理結果：完了 .*/
	private static final String SUCCESS = "1";
	/** ディレイド処理結果：業務エラー .*/
	private static final String WORK_ERROR = "2";
	/** ディレイド処理結果：システムエラー .*/
	private static final String SYS_ERROR = "3";
	/** ディレイド処理結果コード .*/
	private String mRES_CD = null;
	
	/** ディレイドジョブ依頼ＩＤ .*/
	private String mREQ_JOB_ID = null;
	
	/** シェル処理結果コード：正常 .*/
	private static final String RES_CD_OK = "0";
	/** シェル処理結果コード：業務エラー：8 .*/
	private static final String RES_CD_8 = "8";
	/** シェル処理結果コード：業務エラー：127 .*/
	private static final String RES_CD_127 = "127";
	
	/** ファイルパス .*/
	private String createFile = null;
	// 2013/04/14 ST6-2013-0000031 add end

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_KK_T_DCHSKMST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_DCHSKMST);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/

		//■■■ ST6-2013-0000031 Add Start ■■■
		if(super.freeItem != null && !"".equals(super.freeItem))
		{
			// フリーパラメータからジョブIDとシェル処理結果コード取得
			String[] str = super.freeItem.split(JKKBatConst.S_PARAM_DELIM);
			if(str.length == 3)
			{
				// ジョブＩＤ取得
				this.mREQ_JOB_ID = str[0];
				
				// ファイル名取得
				this.createFile = str[2];
				
				// 処理結果を取得
				if(RES_CD_OK.equals(str[1]))
				// 処理結果が「0」
				{
					// ディレイド処理結果 正常完了
					this.mRES_CD = SUCCESS;
				}
				else if(RES_CD_8.equals(str[1]) || RES_CD_127.equals(str[1]))
				// 処理結果が「8」もしくは「127」
				{
					//ディレイド処理結果 業務エラー
					this.mRES_CD = WORK_ERROR;
				}
				else
				// 処理結果が不明なコード
				{
					// ディレイド処理結果 システムエラー
					this.mRES_CD = SYS_ERROR;
				}
				
				// ディレイド処理依頼取得
// 2013.10.21 OM-2013-0002358 mod start		
//				ArrayList<HashMap<String,Object>> arrayList = JCCbatShoriIraiUtil.getShoriIraiInfo(super.commonItem, mREQ_JOB_ID);
				ArrayList<HashMap<String,Object>> arrayList = JBSBatKKShoriIraiUtil.getShoriIraiInfo(super.commonItem, mREQ_JOB_ID);
// 2013.10.21 OM-2013-0002358 mod end
				if(arrayList != null)
				{
// 2013.10.21 OM-2013-0002358 mod start
//					HashMap<String, Object> resutlMap = arrayList.get(0);
//					String shori_id = resutlMap.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO).toString();
//					// ディレイド処理結果更新
//					JCCbatShoriIraiUtil.updateShoriIraiResult(super.commonItem, shori_id, this.mRES_CD, null);

					// 取得した件数分、更新する。（２重起動防止しているので１件のはず）
					for (HashMap<String, Object> resutlMap : arrayList) {
						String shori_id = resutlMap.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO).toString();
						if(! JKKStringUtil.isNullBlank(shori_id)) {
							// ディレイド処理結果更新
							JCCbatShoriIraiUtil.updateShoriIraiResult(super.commonItem, shori_id, this.mRES_CD, null);
						}
					}
// 2013.10.21 OM-2013-0002358 mod end
				}
			}
		}
		//■■■ ST6-2013-0000031 Add End ■■■
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 先行ＪＯＢが正常終了しているかチェック
		if(!SUCCESS.equals(this.mRES_CD))
		{
			// 先行ＪＯＢの処理結果が正常以外はこのバッチを終了
			return null;
		}
		
		// 入力レコードに異常があった場合
		if (inMap.isInputErrorFlg())
		{
			// TAI-2012-0000143 2013/02/08 MOD START
			// 業務エラーログ出力
//			super.logPrint.printBusinessErrorLog("EKKB0100AE",
//					new String[] {"販売促進コード抽出ファイル"});
			super.logPrint.printBusinessErrorLog("EKKB0100AE",
						new String[] {"販売促進コード抽出ファイル(KKIFM094.csv)"});
			// TAI-2012-0000143 2013/02/08 MOD END
			
			// エラーフラグ設定
			super.commonItem.setErrFlg(true);
			return null;
		}

		// 入力データ保持Mapを生成
		HashMap<String, String> rsMap = inMap.getMap();

		// 単項目チェック関数呼出
		if (!isSingleCheckKKIFM094_INF1(rsMap, getItemvalueMap()))
		{
			// エラーフラグ設定
			super.commonItem.setErrFlg(true);
			return null;
		}

		// パラメータの設定
		String aplyCntHambetCd = inMap.getString(JBSbatKKIFM094.APLY_CNT_HAMBET_CD);	// 適用数判別コード
		String aplyCnt = inMap.getString(JBSbatKKIFM094.APLY_CNT);						// 適用数
		String chshtCnt = inMap.getString(JBSbatKKIFM094.CHSHT_CNT);					// 抽出回数
		Long chshtCntLong = Long.parseLong(chshtCnt) + 1;
		String chshtCntAdd = chshtCntLong.toString();									// 抽出回数＋１
		String dchskmstNo = inMap.getString(JBSbatKKIFM094.DCHSKMST_NO);				// データ抽出項目設定番号
		boolean dbleFlag = true;														// データ抽出項目設定番号の重複確認フラグ

		// データ抽出項目設定番号の重複確認
		// 重複がある場合、Flagを"false"にする。
		if(memoryDchskmstNo.contains(dchskmstNo))
		{
			dbleFlag = false;
		}

		// 更新定義（データ抽出項目の適用数判別コードが回数で、データ抽出項目の適用数＝データ抽出項目設定の抽出回数+1の場合）
		if(APLY_CNT_HAMBET_CD_CNT.equals(aplyCntHambetCd) && aplyCnt.equals(chshtCntAdd))
		{

			// データ抽出項目設定番号に重複しない場合
			if(dbleFlag)
			{
				Object[] setParam1391 = {
						DCHSKMST_STAT_FIN,										// データ抽出項目設定ステータス
						DCHSKMST_FIN_SBT_CD_APLY,								// データ抽出項目設定完了種別コード
						chshtCntAdd,											// 抽出回数
						inMap.getString(JBSbatKKIFM094.DCHSKMST_NO),			// データ抽出項目設定番号
						inMap.getString(JBSbatKKIFM094.GENE_ADD_DTM_KK1391),	// 世代登録年月日時分秒
				};

				// SQL発行
				executeKK_T_DCHSKMST_KK_UPDATE_001(setParam1391);

				// データ抽出項目設定番号の保持
				memoryDchskmstNo.add(dchskmstNo);

			}
		}
		// 更新定義に合致しない場合
		else
		{
			// データ抽出項目設定番号に重複しない場合
			if(dbleFlag)
			{
				Object[] setParam1391 = {
						chshtCntAdd,											// 抽出回数
						inMap.getString(JBSbatKKIFM094.DCHSKMST_NO),			// データ抽出項目設定番号
						inMap.getString(JBSbatKKIFM094.GENE_ADD_DTM_KK1391),	// 世代登録年月日時分秒
				};
				// SQL発行
				executeKK_T_DCHSKMST_KK_UPDATE_002(setParam1391);

				// データ抽出項目設定番号の保持
				memoryDchskmstNo.add(dchskmstNo);
			}
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		// 2013/04/14 ST6-2013-0000031 add start
		if(SUCCESS.equals(this.mRES_CD)) {
		// 2013/04/14 ST6-2013-0000031 add end
			// 電子ファイル管理登録処理
			// return 電子ファイル登録情報（電子ファイル管理番号,世代登録年月日時分秒）
			JBSbatCommonItem arg0 = super.commonItem;	// 業務共通電文
			String arg1 = "M094";						// ファイルコード
			// 2013/04/14 ST6-2013-0000031 mod start
			//String arg2 = super.freeItem;				// ファイルパス
			String arg2 = this.createFile;				// ファイルパス
			// 2013/04/14 ST6-2013-0000031 mod end
			String arg3 = null;							// ファイル削除年月日
			String[] rc = JCCBatCommon.createDenshiFile(arg0, arg1, arg2, arg3);
			
			// ログ出力
			super.logPrint.printDebugLog("電子ファイル管理番号(" + rc[0] +  ")、世代登録年月日時分秒(" + rc[1] + ")");
			
			// ダウンロードファイル管理登録処理
			executeZM_T_DL_FILE_KANRI_KK_INSERT_001(getDlFileInsertParam(rc));
		// 2013/04/14 ST6-2013-0000031 add start
		}
		// 2013/04/14 ST6-2013-0000031 add end
		
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_KK_T_DCHSKMST.close();
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 *入力情報（販売促進コード抽出ファイル）の単項目チェックを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.単項目チェックを行います。<br>
	 * 
	 * 2.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		rsMap:(項目、値)を(key、value)として、データをrsMapに入れます
	 *		itemvalueMap:埋め込み文字の値をitemvalueMapに入れます。キーの値は、以下に説明します。
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定）
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定）
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定）
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定対象契約）
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定対象契約）
	 *			 TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401			販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定対象契約）
	 *			 TXT-KKIFM094-INF1.DCHSKMST_NO			販売促進コード抽出ファイル.データ抽出項目設定番号
	 *			 TXT-KKIFM094-INF1.DCHSKMST_NO			販売促進コード抽出ファイル.データ抽出項目設定番号
	 *			 TXT-KKIFM094-INF1.DCHSKMST_NO			販売促進コード抽出ファイル.データ抽出項目設定番号
	 *			 TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD			販売促進コード抽出ファイル.適用数判別コード
	 *			 TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD			販売促進コード抽出ファイル.適用数判別コード
	 *			 TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD			販売促進コード抽出ファイル.適用数判別コード
	 *			 TXT-KKIFM094-INF1.APLY_CNT			販売促進コード抽出ファイル.適用数
	 *			 TXT-KKIFM094-INF1.APLY_CNT			販売促進コード抽出ファイル.適用数
	 *			 TXT-KKIFM094-INF1.APLY_CNT			販売促進コード抽出ファイル.適用数
	 *			 TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO			販売促進コード抽出ファイル.データ抽出項目設定対象契約番号
	 *			 TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO			販売促進コード抽出ファイル.データ抽出項目設定対象契約番号
	 *			 TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO			販売促進コード抽出ファイル.データ抽出項目設定対象契約番号
	 *			 TXT-KKIFM094-INF1.CHSHT_CNT			販売促進コード抽出ファイル.抽出回数
	 *			 TXT-KKIFM094-INF1.CHSHT_CNT			販売促進コード抽出ファイル.抽出回数
	 *			 TXT-KKIFM094-INF1.CHSHT_CNT			販売促進コード抽出ファイル.抽出回数
	 * </pre>
	 * <p>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたHashMap。
	 * @param itemvalueMap エラーメッセージに関する項目値を格納されたHashMap。
	 * @return  boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 */
	private boolean isSingleCheckKKIFM094_INF1(HashMap rsMap, HashMap itemvalueMap)
	{
		// 単項目チェックを行います
		String strValue = null;

		// 世代登録年月日時分秒（データ抽出項目設定）項目チェック
		strValue = (String)rsMap.get("GENE_ADD_DTM_KK1391");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "17"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"day_hour1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391")});
			return false;
		}

		// 世代登録年月日時分秒（データ抽出項目設定対象契約）項目チェック
		strValue = (String)rsMap.get("GENE_ADD_DTM_KK1401");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "17"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"day_hour1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401")});
			return false;
		}

		// データ抽出項目設定番号項目チェック
		strValue = (String)rsMap.get("DCHSKMST_NO");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_NO")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "12"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_NO")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_NO")});
			return false;
		}

		// 適用数判別コード項目チェック
		strValue = (String)rsMap.get("APLY_CNT_HAMBET_CD");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD")});
			return false;
		}

		// 適用数項目チェック
		strValue = (String)rsMap.get("APLY_CNT");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"double_chk", "12", "0"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakusuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.APLY_CNT")});
			return false;
		}

		// データ抽出項目設定対象契約番号項目チェック
		strValue = (String)rsMap.get("DCHSKMST_TG_KEI_NO");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "12"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO")});
			return false;
		}

		// 抽出回数項目チェック
		strValue = (String)rsMap.get("CHSHT_CNT");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.CHSHT_CNT")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"double_chk", "12", "0"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.CHSHT_CNT")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakusuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFM094-INF1.CHSHT_CNT")});
			return false;
		}

		return true;
	}

	/**
	 * SQLKEY(KK_UPDATE_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 executeKK_T_DCHSKMST_KK_UPDATE_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		paramList.setValue(param[3].toString());
		paramList.setValue(param[4].toString());

		// DBアクセスを実行します
		db_KK_T_DCHSKMST.executeBySqlDefine(paramList, KK_T_DCHSKMST_KK_UPDATE_001);
	}

	/**
	 * SQLKEY(KK_UPDATE_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_DCHSKMST_KK_UPDATE_002(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_DCHSKMST.executeBySqlDefine(paramList, KK_T_DCHSKMST_KK_UPDATE_002);
	}

	/**
	 * SQLKEY(KK_INSERT_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 executeZM_T_DL_FILE_KANRI_KK_INSERT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		paramList.setValue(param[3].toString());
		paramList.setValue(param[4].toString());
		paramList.setValue(param[5].toString());
		paramList.setValue(param[6].toString());

		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.executeBySqlDefine(paramList, ZM_T_DL_FILE_KANRI_KK_INSERT_001);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * エラーメッセージに関する項目値を格納されたHashMap<String, String>を生成します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.エラーメッセージに関する項目値を格納されたHashMapを生成する。<br>
	 *
	 * 2.エラーメッセージに関する項目値を格納されたHashMapに値を設定する。<br>
	 * </pre>
	 * <p>
	 * @return itemvalueMap エラーメッセージに関する項目値を格納されたHashMap
	 */
	private HashMap<String, String> getItemvalueMap()
	{
		// エラーメッセージに関する項目値が格納されたHashMapを設定
		HashMap<String, String> itemvalueMap = new HashMap<String, String>();
		itemvalueMap.put("TXT-KKIFM094-INF1.DCHSKMST_NO", "販売促進コード抽出ファイル.データ抽出項目設定番号");
		itemvalueMap.put("TXT-KKIFM094-INF1.DCHSKMST_TG_KEI_NO", "販売促進コード抽出ファイル.データ抽出項目設定対象契約番号");
		itemvalueMap.put("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1391", "販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定）");
		itemvalueMap.put("TXT-KKIFM094-INF1.GENE_ADD_DTM_KK1401", "販売促進コード抽出ファイル.世代登録年月日時分秒（データ抽出項目設定対象契約）");
		itemvalueMap.put("TXT-KKIFM094-INF1.APLY_CNT_HAMBET_CD", "販売促進コード抽出ファイル.適用数判別コード");
		itemvalueMap.put("TXT-KKIFM094-INF1.APLY_CNT", "販売促進コード抽出ファイル.適用数");
		itemvalueMap.put("TXT-KKIFM094-INF1.CHSHT_CNT", "販売促進コード抽出ファイル.抽出回数");

		return itemvalueMap;
	}

	/**
	 * ZM_T_DL_FILE_KANRI-KK_INSERT_001を実行する際に必要なパラメータを返します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.パラメータ設定処理。
	 * </pre>
	 * <p>
	 * @param rc 共通部品の電子ファイル管理登録から返却された文字列
	 * @return setParam ZM_T_DL_FILE_KANRI-KK_INSERT_001を実行する際に必要なパラメータ
	 * @throws Exception 
	 */
	private Object[] getDlFileInsertParam(String[] rc) throws Exception
	{
		Object[] setParam = {
				TRN_KANRI_NO,						// 処理管理番号
				getFileName(),						// ファイル名
				getLineCnt(),						// データ件数
				rc[1],								// ファイル登録年月日時分秒
				"",									// ファイル削除年月日
				rc[0],								// 電子ファイル管理番号
				rc[1],								// 世代登録年月日時分秒
		};
		return setParam;
	}
	
	/**
	 * フリーパラメータのファイルパスからファイル名のみを返却します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.ファイル名取得
	 * </pre>
	 * <p>
	 * @return fileName フリーパラメータのファイルパスのファイル名
	 */
	private String getFileName()
	{
		// 2013/04/14 ST6-2013-0000031 mod start
		//String[] lines = super.freeItem.split(JKKBatConst.S_HALF_SLASH);
		String[] lines = this.createFile.split(JKKBatConst.S_HALF_SLASH);
		// 2013/04/14 ST6-2013-0000031 mod end
		String fileName = lines[lines.length - 1];
		return fileName;
	}
	
	/**
	 * フリーパラメータのファイルパスからレコード数を文字列で返却します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.レコード数取得
	 * </pre>
	 * <p>
	 * @return フリーパラメータのファイルパスのファイルレコード数
	 * @throws Exception 
	 */
	private String getLineCnt() throws Exception
	{
		int line_cnt = 0;
		// 2013/04/14 ST6-2013-0000031 mod start
		//JBSbatInputFileUtil inFile = new JBSbatInputFileUtil(super.freeItem);
		JBSbatInputFileUtil inFile = new JBSbatInputFileUtil(this.createFile);
		// 2013/04/14 ST6-2013-0000031 mod end
		inFile.setEncode(JKKBatConst.SJIS);
		inFile.setLine(JKKBatConst.S_LINE_SEPARAOR_LF);
		inFile.createReader();
		while(null != inFile.readLine())
		{
			line_cnt++;
		}
		inFile.close();
		return String.valueOf(line_cnt);
	}
}
