/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKMskmJiskDataShuk
*	ソースファイル名	：JBSbatKKMskmJiskDataShuk.java
*	作成者				：富士通　
*	作成日				：2012年08月13日
*＜機能概要＞
*　申込実績データ集計部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/08/13   富士通		新規作成
*   v4.00.00    2012/12/05   FJ）三浦   【TAI-2012-0000122】申込実績集計SQLのパラメータ数変更
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;
import java.util.List;

import com.fujitsu.futurity.model.base.jcc.util.JCCDateUtil;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;

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

	/** テーブル(申込)*/
	private static final String D_TBL_NAME_KK_T_MSKM = "KK_T_MSKM";

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

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

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

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

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

	/** テーブルアクセスクラス(代理店申込集計結果)*/
	private JBSbatSQLAccess db_KK_T_AGNT_MSKM_SRLT = null;

	/** テーブルアクセスクラス(申込)*/
	private JBSbatSQLAccess db_KK_T_MSKM = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/**集計契機コード**/
	private String sktgwOptntyCd = "";

	/** 業務パラメータＩＤ（集計結果削除日数）*/
	private static final String SRLT_DEL_NISU = "KK_SRLT_DEL_NISU";

	/** 業務パラメータ設定値（集計結果削除日数）*/
	private String workParamSrltDelNisu = "";

	/**
	 * 初期処理
	 * @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_AGNT_MSKM_SRLT = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_AGNT_MSKM_SRLT);
		db_KK_T_MSKM = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_MSKM);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/

		//運用日付の取得
		String opeDate =  commonItem.getOpeDate();
		
		sktgwOptntyCd = commonItem.getFreeItem();
		
		if(!"0".equals(sktgwOptntyCd) && !"1".equals(sktgwOptntyCd))
		{
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[] {
					"集計契機コード:" + sktgwOptntyCd });
		}
		
		//業務パラメータ取得（集計結果削除日数）
		List<JBSbatCommonDBInterface> workParamMsyaList =  getTargetParamList(SRLT_DEL_NISU, opeDate);
		
		if(workParamMsyaList.isEmpty())
		{
			// パラメータが不正です。
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE, new String[] {
					"業務パラメータ", "業務パラメータＩＤ：" + SRLT_DEL_NISU });
		}
		
		workParamSrltDelNisu = workParamMsyaList.get(0).getString("WORK_PARAM_SETTE_VALUE");
	}

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

		//運用日付の取得
		String opeDate =  commonItem.getOpeDate();

		//代理店申込集計結果データ削除
		delAgntMskmSrlt();

		//最終確定年月日の取得
		List<JBSbatCommonDBInterface> ymdList =  getLastFixYmd();

		//最終確定年月日
		String lastFixYmd = ymdList.get(0).getString("MAX_MSKM_YMD");

		// 最終確定年月日が取得できない場合
		if (lastFixYmd == null)
		{
			//運用日付 - 1日を設定
			lastFixYmd = JCCDateUtil.addDay(opeDate, -1);
			//throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE, new String[] { "申込実績データ集計",  "最終確定年月日"});
		}

		//申込実績データ集計
		
		List<JBSbatCommonDBInterface> dataShukList = getDataShuk(opeDate, lastFixYmd);
		
		for(JBSbatCommonDBInterface addMap : dataShukList)
		{
			addAgntMskmSrlt(addMap);
		}
		
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

		// DBアクセスを実行します
		db_KK_T_AGNT_MSKM_SRLT.executeBySqlDefine(paramList, KK_T_AGNT_MSKM_SRLT_KK_DELETE_001);
	}

	/**
	 * 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 executeKK_T_AGNT_MSKM_SRLT_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();

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

	/**
	 * SQLKEY(KK_SELECT_009)で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_MSKM_KK_SELECT_009(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());

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

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	集計対象申込年月日				SHUK_TG_MSKM_YMD
	 *		 	代理店コード				AGNT_CD
	 *		 	申込件数				MSKM_CNT
	 *		 	申込件数（テレビバンドル）				MSKM_CNT_TV_BUNDLE
	 *		 	申込件数（量販店員獲得）				MSKM_CNT_RHSTF_KAKUTOKU
	 *		 	申込件数（ｅｏスタッフ獲得）				MSKM_CNT_EOSTF_KAKUTOKU
	 *		 	集計契機コード				SHUK_OPTNTY_CD
	 *		 	登録年月日時分秒				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_AGNT_MSKM_SRLT_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("SHUK_TG_MSKM_YMD", setParam[0]);
		setMap.setValue("AGNT_CD", setParam[1]);
		setMap.setValue("MSKM_CNT", setParam[2]);
		setMap.setValue("MSKM_CNT_TV_BUNDLE", setParam[3]);
		setMap.setValue("MSKM_CNT_RHSTF_KAKUTOKU", setParam[4]);
		setMap.setValue("MSKM_CNT_EOSTF_KAKUTOKU", setParam[5]);
		setMap.setValue("SHUK_OPTNTY_CD", setParam[6]);
		setMap.setValue("ADD_DTM", setParam[7]);
		setMap.setValue("ADD_OPEACNT", setParam[8]);
		setMap.setValue("UPD_DTM", setParam[9]);
		setMap.setValue("UPD_OPEACNT", setParam[10]);
		setMap.setValue("DEL_DTM", setParam[11]);
		setMap.setValue("DEL_OPEACNT", setParam[12]);
		setMap.setValue("MK_FLG", setParam[13]);
		setMap.setValue("ADD_UNYO_YMD", setParam[14]);
		setMap.setValue("ADD_TRN_ID", setParam[15]);
		setMap.setValue("UPD_UNYO_YMD", setParam[16]);
		setMap.setValue("UPD_TRN_ID", setParam[17]);
		setMap.setValue("DEL_UNYO_YMD", setParam[18]);
		setMap.setValue("DEL_TRN_ID", setParam[19]);
	
		// DBアクセスを実行します
		db_KK_T_AGNT_MSKM_SRLT.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * 業務パラメータ取得処理
	 * @param workParamCd
	 * @param opeDate
	 * @throws Exception 
	 * @return selectList
	 */
	private List<JBSbatCommonDBInterface> getTargetParamList(String workParamCd, String opeDate) throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		Object[] param = {workParamCd, 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;
	}
	
	/**
	 * 代理店申込集計結果データ削除処理
	 * @throws Exception 
	 * 
	 */
	private void delAgntMskmSrlt() throws Exception
	{
		Object[] param = {this.opeDate, workParamSrltDelNisu};
		executeKK_T_AGNT_MSKM_SRLT_KK_DELETE_001(param);
	}
	
	/**
	 * 申込実績集計結果最終確定年月日取得
	 * @return selectMap
	 * @throws Exception
	 */
	private List<JBSbatCommonDBInterface> getLastFixYmd() throws Exception
	{
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		Object[] param = {};
		executeKK_T_AGNT_MSKM_SRLT_KK_SELECT_001(param);
		
		JBSbatCommonDBInterface selectMap = new JBSbatCommonDBInterface();
		
		while(true)
		{
			selectMap = db_KK_T_AGNT_MSKM_SRLT.selectNext();
			if(selectMap != null)
			{
				selectList.add(selectMap);
			}
			else
			{
				break;
			}
		}

		return selectList;
	}

	/**
	 * 申込実績データ集計
	 * @param opeDate 運用日
	 * @param lastFixYmd 最終確定年月日
	 * @return selectList
	 * @throws Exception
	 */
	private List<JBSbatCommonDBInterface> getDataShuk(String opeDate, String lastFixYmd) throws Exception
	{
		
		List<JBSbatCommonDBInterface> selectList = new ArrayList<JBSbatCommonDBInterface>();
		Object[] param = {opeDate, opeDate, lastFixYmd, opeDate};
		
		JBSbatCommonDBInterface selectMap = new JBSbatCommonDBInterface();
		executeKK_T_MSKM_KK_SELECT_009(param);
		
		while(true)
		{
			selectMap = db_KK_T_MSKM.selectNext();
			
			if(selectMap != null)
			{
				selectList.add(selectMap);
			}
			else 
			{
				break;
			}
		}
		return selectList;
		
	}

	/**
	 * 申込実績データ集計（登録）
	 * @param setParamMap
	 * @throws Exception
	 */
	private void addAgntMskmSrlt(JBSbatCommonDBInterface setParamMap) throws Exception
	{
		
		Object[] param = 
		{
			setParamMap.getString("MSKM_NYO_SHONIN_YMD"),	//集計対象申込年月日
			setParamMap.getString("AGNT_CD"),				//代理店コード
			setParamMap.getString("MSKM_CNT"),				//申込件数
			setParamMap.getString("MSKM_CNT_TV"),			//申込件数(テレビバンドル)
			setParamMap.getString("MSKM_CNT_RHSTF"),		//申込件数(量販店員獲得)
			setParamMap.getString("MSKM_CNT_EOSTF"),		//申込件数(eoスタッフ獲得)
			sktgwOptntyCd,									//集計契機コード
			getBatchDatetime(),								//登録年月日時分秒
			getUpdOperator(),								//登録オペレータアカウント
			getBatchDatetime(),								//更新年月日時分秒
			getUpdOperator(),								//更新オペレータアカウント
			null,											//削除年月日時分秒
			null,											//削除オペレータアカウント
			"0",											//無効フラグ
			"ADD_UNYO_YMD",									//登録運用年月日
			"ADD_TRN_ID",									//登録処理ＩＤ
			"UPD_UNYO_YMD",									//更新運用年月日
			"UPD_TRN_ID",									//更新処理ＩＤ
			null,											//削除運用年月日
			null											//削除処理ＩＤ
		};
			
		executeKK_T_AGNT_MSKM_SRLT_PKINSERT(param);

	}
	
	/**
	 * バッチ日時(17桁)を取得する
	 * @return バッチ日時
	 * @throws Exception
	 */
	private String getBatchDatetime() throws Exception
	{
		return JCCBatCommon.getSysDateTimeStamp();
	}


	/**
	 * 更新者IDを取得する.
	 * 
	 * @return 更新者ID
	 */
	private String getUpdOperator()
	{
		return commonItem.getBatchUserId();
	}

}