/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKDelKanuoresoHakko
*	ソースファイル名	：JBSbatKKDelKanuoresoHakko.java
*	作成者				：富士通　
*	作成日				：2011年05月03日
*＜機能概要＞
*　レコード削除処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00		2011/05/03   富士通		新規作成
*	v4.02		2012/12/31	FJ)藤原		【IT1-2012-0002601】ディレイド処理依頼取得部品を使用し、依頼がなければ終了するように修正
*	v4.03		2013/04/19	FJ)井熊		【IT1-2013-0000995】運用日でシステム日時を参照しているSQLを改修
*	v5.00		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.JCCbatShoriIraiUtil;
import eo.business.common.JKKBatCommon;
import eo.business.common.JKKBatConst;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatKK_T_KANUORESO_HAKKO;
import eo.common.util.JKKStringUtil;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;

/**
* (クラスの機能概要) <p>
* 加入御礼管理更新（削除）<BR>
* <BR>
* 加入御礼書発行のデータのうち、送信済み、または、送信除外済みのデータについて、<BR>
* データが作成されてから一定期間経過後、レコードを削除する。<BR>
* （業務上、６か月程度は必要とのこと。）<BR>
*<BR>
* @author 富士通
*/
public class JBSbatKKDelKanuoresoHakko extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(加入御礼書発行取得)*/
	private static final String D_TBL_NAME_KK_T_KANUORESO_HAKKO = "KK_T_KANUORESO_HAKKO";

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

	/** テーブルアクセスクラス(加入御礼書発行取得)*/
	private JBSbatSQLAccess db_KK_T_KANUORESO_HAKKO = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 業務パラメータID（削除対象期間） */
	private static final String WORK_PARAM_ID_KK_DELPRD = "KK_DELPRD";
	
	/** ディレイド処理結果：完了 .*/
	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";
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		// DBアクセスクラスを生成します
		db_KK_T_KANUORESO_HAKKO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KANUORESO_HAKKO);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/

		//■■■ IT1-2012-0002601 ディレイド処理結果反映 M.Ikuma Start ■■■
		if(super.freeItem != null && !"".equals(super.freeItem))
		{
			// フリーパラメータからジョブIDとシェル処理結果コード取得
			String[] str = super.freeItem.split(JKKBatConst.S_PARAM_DELIM);
			if(str.length == 2)
			{
				// ジョブＩＤ取得
				this.mREQ_JOB_ID = str[0];
				
				// 処理結果を取得
				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
						
					// 先行ＪＯＢが正常終了しているかチェック
					if(!RES_CD_OK.equals(str[1]) && !RES_CD_8.equals(str[1]))
					{
						// 先行ＪＯＢの処理結果が正常、マイナーエラー以上はこのバッチを終了
						return null;
					}
				}
				else
				{
					// 処理依頼がないのでこのバッチを終了
					return null;
				}
			}
		}
		//■■■ IT1-2012-0002601 ディレイド処理結果反映 M.Ikuma   End ■■■

		JBSbatCommonDBInterface rcvMap = new JBSbatCommonDBInterface();		// 結果取得用

		// 業務パラメータより削除対象期間を取得
		String delprd = JKKBatCommon.getWorkParamSetteValue(super.commonItem, WORK_PARAM_ID_KK_DELPRD);	
		
		// 業務パラメータが取得できた場合のみ実行
		if (delprd != null)
		{
			// パラメータの設定（運用日に業務パラメータで取得した月すうをプラスする）
			Object[] setParam1 = { JKKBatCommon.addMonth(super.opeDate, Integer.parseInt(delprd)) };
			// 削除対象の加入御礼書を抽出
			executeKK_T_KANUORESO_HAKKO_KK_SELECT_001(setParam1);
			// １件目を先読み
			rcvMap = db_KK_T_KANUORESO_HAKKO.selectNext();
			// 結果を取得
			while(rcvMap != null)
			{
				// パラメータの設定
				Object[] setParam2 = { rcvMap.getString(JBSbatKK_T_KANUORESO_HAKKO.KANUORESO_HAKKO_NO) };
				// PK削除
				executeKK_T_KANUORESO_HAKKO_PKDELETE(setParam2);
				// 次のデータを読む
				rcvMap = db_KK_T_KANUORESO_HAKKO.selectNext();
			}
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_KK_T_KANUORESO_HAKKO.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	KIJUN_YMD
	 *		 	ADD_MONTHS
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_KANUORESO_HAKKO_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

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

	/**
	 * PK(ＰＫ　削除)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KANUORESO_HAKKO_NO
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_KANUORESO_HAKKO_PKDELETE(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("KANUORESO_HAKKO_NO", whereParam[0]);

		// DBアクセスを実行します
		db_KK_T_KANUORESO_HAKKO.deleteByPrimaryKeys(whereMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
}