/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHKapSknUcwkAdd
*	ソースファイル名	：JBSbatCHKapSknUcwkAdd.java
*	作成者				：富士通　
*	作成日				：2012年09月25日
*＜機能概要＞
*　割賦債権内訳登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者			修正内容
*	v4.00		2012/09/25   FJ）後藤		【ANK-0546-00-00】新規作成
*	v4.00		2012/12/01   FJ）佐藤(智)	【TG1-2012-0000217】割賦債権内訳をDELETE-INSERT方式に変更
**********************************************************************/
package eo.business.service;

import java.util.ArrayList;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatParamUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatCHIFM145;
import eo.business.util.table.JBSbatCH_M_PRC_KMK_CS_CHGE;
import eo.common.constant.JACStrConst;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCHKapSknUcwkAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(料金項目抽出変換)*/
	private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";

	/** テーブル(割賦債権内訳)*/
	private static final String D_TBL_NAME_CH_T_KAP_SAIKEN_UCWK = "CH_T_KAP_SAIKEN_UCWK";

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

	/** テーブルアクセスクラス(料金項目抽出変換)*/
	private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null;

	/** テーブルアクセスクラス(割賦債権内訳)*/
	private JBSbatSQLAccess db_CH_T_KAP_SAIKEN_UCWK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 割賦債権内訳登録判定用MAP*/
	private ArrayList<String> kapSknUwAddJdgMap = null;

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_CH_M_PRC_KMK_CS_CHGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE);
		db_CH_T_KAP_SAIKEN_UCWK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_KAP_SAIKEN_UCWK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
		
		// パラメータ取得クラス生成
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		String wKinoSkbtKapSknUw 	= paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_KAP_SKNUW);		// 業務機能識別コード(料金項目コード（割賦債権内訳登録用））

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "業務機能識別コード(料金項目コード（割賦債権内訳登録用））：" + wKinoSkbtKapSknUw);
		
		paramUtil.close();
		
		kapSknUwAddJdgMap = new ArrayList<String>();
		
		makePrcKmkCsChgeList(wKinoSkbtKapSknUw);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		assert null != inMap ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][inMap=" + inMap.getMap().toString() + "]") : true;

		
		String inKey = makeStr(inMap.getString(JBSbatCHIFM145.PRC_GRP_CD), inMap.getString(JBSbatCHIFM145.PCRS_CD), 
				inMap.getString(JBSbatCHIFM145.PRC_SVC_CD), inMap.getString(JBSbatCHIFM145.PRC_KMK_CD));
		
		// 割賦債権内訳登録判定用MAPに含まれている場合
		if(kapSknUwAddJdgMap.contains(inKey))
		{
			JBSbatCommonDBInterface setParam = new JBSbatCommonDBInterface();
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][登録対象]");
			// 債権番号
			setParam.setValue(inMap.getString(JBSbatCHIFM145.SAIKEN_NO));
			// 割賦契約番号
			setParam.setValue(inMap.getString(JBSbatCHIFM145.KAP_KEI_NO));
			// 料金グループコード
			setParam.setValue(inMap.getString(JBSbatCHIFM145.PRC_GRP_CD));
			// 料金コースコード
			setParam.setValue(inMap.getString(JBSbatCHIFM145.PCRS_CD));
			// 料金サービスコード
			setParam.setValue(inMap.getString(JBSbatCHIFM145.PRC_SVC_CD));
			// 料金項目コード
			setParam.setValue(inMap.getString(JBSbatCHIFM145.PRC_KMK_CD));
			// 金額
			setParam.setValue(inMap.getBigDecimal(JBSbatCHIFM145.AMNT));
			// 請求契約番号
			setParam.setValue(inMap.getString(JBSbatCHIFM145.SEIKY_KEI_NO));
			// サービス契約番号
			setParam.setValue(inMap.getString(JBSbatCHIFM145.SVC_KEI_NO));
			// 登録年月日時分秒
			setParam.setValue(null);
			// 登録オペレータアカウント
			setParam.setValue(null);
			// 更新年月日時分秒
			setParam.setValue(null);
			// 更新オペレータアカウント
			setParam.setValue(null);
			// 削除年月日時分秒
			setParam.setValue(null);
			// 削除オペレータアカウント
			setParam.setValue(null);
			// 無効フラグ
			setParam.setValue(null);
			// 登録運用年月日
			setParam.setValue(null);
			// 登録処理ID
			setParam.setValue(null);
			// 更新運用年月日
			setParam.setValue(null);
			// 更新処理ID
			setParam.setValue(null);
			// 削除運用年月日
			setParam.setValue(null);
			// 削除処理ID
			setParam.setValue(null);
			
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][insKapSknUcwk][setParam=" + setParam.getList().toString() + "]");

			// SQL文を実行
			executeCH_T_KAP_SAIKEN_UCWK_PKINSERT(setParam.getList().toArray());
		}
		

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
		db_CH_T_KAP_SAIKEN_UCWK.clearBatch();
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CH_M_PRC_KMK_CS_CHGE.close();
		db_CH_T_KAP_SAIKEN_UCWK.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	
	/**
	 * SQLKEY(CH_SELECT_015)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	システムコード
	 *		 	業務機能識別コード
	 *		 	抽出変換コード
	 *		 	料金項目抽出変換適用開始年月日
	 *		 	料金項目抽出変換適用終了年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_015(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_CH_M_PRC_KMK_CS_CHGE.selectBySqlDefine(paramList, CH_M_PRC_KMK_CS_CHGE_CH_SELECT_015);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	債権番号				SAIKEN_NO
	 *		 	割賦契約番号				KAP_KEI_NO
	 *		 	料金グループコード				PRC_GRP_CD
	 *		 	料金コースコード				PCRS_CD
	 *		 	料金サービスコード				PRC_SVC_CD
	 *		 	料金項目コード				PRC_KMK_CD
	 *		 	金額				AMNT
	 *		 	請求契約番号				SEIKY_KEI_NO
	 *		 	サービス契約番号				SVC_KEI_NO
	 *		 	登録年月日時分秒				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 executeCH_T_KAP_SAIKEN_UCWK_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("SAIKEN_NO", setParam[0]);
		setMap.setValue("KAP_KEI_NO", setParam[1]);
		setMap.setValue("PRC_GRP_CD", setParam[2]);
		setMap.setValue("PCRS_CD", setParam[3]);
		setMap.setValue("PRC_SVC_CD", setParam[4]);
		setMap.setValue("PRC_KMK_CD", setParam[5]);
		setMap.setValue("AMNT", setParam[6]);
		setMap.setValue("SEIKY_KEI_NO", setParam[7]);
		setMap.setValue("SVC_KEI_NO", setParam[8]);
		setMap.setValue("ADD_DTM", setParam[9]);
		setMap.setValue("ADD_OPEACNT", setParam[10]);
		setMap.setValue("UPD_DTM", setParam[11]);
		setMap.setValue("UPD_OPEACNT", setParam[12]);
		setMap.setValue("DEL_DTM", setParam[13]);
		setMap.setValue("DEL_OPEACNT", setParam[14]);
		setMap.setValue("MK_FLG", setParam[15]);
		setMap.setValue("ADD_UNYO_YMD", setParam[16]);
		setMap.setValue("ADD_TRN_ID", setParam[17]);
		setMap.setValue("UPD_UNYO_YMD", setParam[18]);
		setMap.setValue("UPD_TRN_ID", setParam[19]);
		setMap.setValue("DEL_UNYO_YMD", setParam[20]);
		setMap.setValue("DEL_TRN_ID", setParam[21]);
	
		// DBアクセスを実行します
		db_CH_T_KAP_SAIKEN_UCWK.insertByPrimaryKeysBatch(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * 料金項目抽出変換スキーマより、料金項目コードを取得します。
	 * 
	 * @param wkKinoSkbtCd 業務機能識別コード
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void makePrcKmkCsChgeList(String wkKinoSkbtCd) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makePrcKmkCsChgeList]");
		
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		// システムコード
		paramList.setValue(super.systemCode);
		// 業務機能識別コード
		paramList.setValue(wkKinoSkbtCd);
		// 抽出変換コード
		paramList.setValue(JACStrConst.CHSHT_CHG_CD_CST);
		// 料金項目抽出変換適用開始年月日
		paramList.setValue(super.opeDate);
		// 料金項目抽出変換適用終了年月日
		paramList.setValue(super.opeDate);

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makePrcKmkCsChgeList][paramList=" + paramList.getList().toString() + "]");
		
		// SQL実行
		executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_015(paramList.getList().toArray());
		JBSbatCommonDBInterface dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();

		// 督促処理制御情報を退避
		while(null != dbMap)
		{
			// 設定キー作成（料金グループコード＋料金コースコード＋料金サービスコード＋料金項目コード）
			String key = makeStr(dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_GRP_CD), dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PCRS_CD), 
					dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_SVC_CD), dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD));
			// 取得した情報をリストに設定
			assert  JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makePrcKmkCsChgeList][key = " + key + "]");
			
			kapSknUwAddJdgMap.add(key);
			
			dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makePrcKmkCsChgeList]");
		return;
	}

	/**
	 * 文字を連結します
	 * @param string　文字
	 * @return strBuf　連結した文字列
	 */
	private String makeStr(String ...string)
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeStr]");
		
		StringBuffer strBuf = new StringBuffer();
		for(String str:string){
			strBuf.append(str);
		}
		assert strBuf != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeStr][strBuf = " + strBuf.toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeStr]");
		
		return strBuf.toString();
	}
}