/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKBmpNoChgKjFinInfKkti
*	ソースファイル名	：JBSbatKKBmpNoChgKjFinInfKkti.java
*	作成者				：富士通　
*	作成日				：2013年03月19日
*＜機能概要＞
*　番ポ番号変更工事完了情報確定部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2013/03/19   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;
import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKKBatCommon;
import eo.business.util.file.JBSbatKKIFM415;
import eo.business.util.table.JBSbatKK_T_KJNIFDEL_WK;
import eo.business.util.table.JBSbatKK_T_PRG;
import eo.business.util.table.JBSbatZM_T_AGING;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessError;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.util.JBSbatCheckUtil;
import eo.framework.util.JBSbatDateUtil;
import eo.framework.util.JBSbatOracleSeqUtil;
import eo.framework.util.JBSbatStringUtil;
import eo.framework.util.JCCBatchEsbInterface;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKBmpNoChgKjFinInfKkti extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(進捗)*/
	private static final String D_TBL_NAME_KK_T_PRG = "KK_T_PRG";

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

	/** テーブルアクセスクラス(進捗)*/
	private JBSbatSQLAccess db_KK_T_PRG = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** 電話番号変更CC ユースケースID */
	private static final String USECASE_ID = "KKSV0745";
	
	/** 電話番号変更CC オペレーションID */
	private static final String OPERATION_ID = "KKSV0745OP";
	
	/** 電話番号変更CCマップ リクエストキー */
	private static final String KKSV074501CC = "KKSV074501CC";

	/** シーケンス名（進捗） */
	private static final String SEQ_PRG_NO = "SEQ_PRG_NO";

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

		// DBアクセスクラスを生成します
		db_KK_T_PRG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		super.logPrint.printDebugLog("execute_START");
		
		//進捗を作成
		createKK_T_PRG(inMap.getString(JBSbatKKIFM415.CHBF_SVC_KEI_UCWK_NO),
				inMap.getString(JBSbatKKIFM415.CHAF_SVC_KEI_UCWK_NO),
				inMap.getString(JBSbatKKIFM415.IDO_DIV));
		
		//電話番号変更CC入力情報
		HashMap<String, Object> excuteMap = new HashMap<String, Object>();
		//電話番号変更CC出力情報
		HashMap<String, Object> outputMap = new HashMap<String, Object>();
		
		//サービス契約内訳番号（変更前）
		excuteMap.put("chbf_svc_kei_ucwk_no", (String)inMap.getString(JBSbatKKIFM415.CHBF_SVC_KEI_UCWK_NO));
		//サービス契約内訳番号（変更後）
		excuteMap.put("chaf_svc_kei_ucwk_no", (String)inMap.getString(JBSbatKKIFM415.CHAF_SVC_KEI_UCWK_NO));
		//異動区分
		excuteMap.put("ido_div", (String)inMap.getString(JBSbatKKIFM415.IDO_DIV));
		//番ポ工事完了年月日
		excuteMap.put("bmp_koji_fin_ymd", (String)inMap.getString(JBSbatKKIFM415.BMP_KOJI_FIN_YMD));
		//機器出荷有無
		excuteMap.put("kkshka_um", "0");
		
		//電話番号変更CC呼び出し
		outputMap = doExecute(excuteMap);
		
		// サービスの処理結果を判定
		String returnCode = outputMap.get(JCCBatchEsbInterface.RETURN_CODE).toString();
		if(!JCCBatchEsbInterface.RETURN_CODE_SUCCESS.equals(returnCode))
		{
			super.logPrint.printDebugLog("returnCode:" + returnCode);
			// コネクションのロールバック
			commonItem.getConnection().rollback();
			// エラーログ出力
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0270CE, 
					new String[]{"電話番号変更"});
			// エラーフラグ設定
			super.commonItem.setErrFlg(true);
			throw new JBSbatBusinessError();
		}
		
		//正常終了の場合コミット
		commonItem.getConnection().commit();
		
		super.logPrint.printDebugLog("execute_END");
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_034)で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_PRG_KK_SELECT_034(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_PRG.selectBySqlDefine(paramList, KK_T_PRG_KK_SELECT_034);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	進捗番号				PRG_NO
	 *		 	申込明細番号				MSKM_DTL_NO
	 *		 	請求契約番号				SEIKY_KEI_NO
	 *		 	請求方法番号（口座）				SEIKY_WAY_NO_KOZA
	 *		 	請求方法番号（クレジットカード）				SEIKY_WAY_NO_CRECARD
	 *		 	サービス契約番号				SVC_KEI_NO
	 *		 	サービス契約内訳番号				SVC_KEI_UCWK_NO
	 *		 	サービス契約回線内訳番号				SVC_KEI_KAISEN_UCWK_NO
	 *		 	機器提供サービス契約番号				KKTK_SVC_KEI_NO
	 *		 	オプションサービス契約番号				OP_SVC_KEI_NO
	 *		 	請求オプションサービス契約番号				SEIOPSVC_KEI_NO
	 *		 	サブオプションサービス契約番号				SBOP_SVC_KEI_NO
	 *		 	割引サービス契約番号				WRIB_SVC_KEI_NO
	 *		 	異動区分				IDO_DIV
	 *		 	異動年月日時分秒				IDO_DTM
	 *		 	進捗ステータス				PRG_STAT
	 *		 	進捗年月日時分秒				PRG_DTM
	 *		 	進捗メモ				PRG_MEMO
	 *		 	進捗特記事項１				PRG_TKJK_1
	 *		 	進捗特記事項２				PRG_TKJK_2
	 *		 	登録年月日時分秒				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_PRG_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("PRG_NO", setParam[0]);
		setMap.setValue("MSKM_DTL_NO", setParam[1]);
		setMap.setValue("SEIKY_KEI_NO", setParam[2]);
		setMap.setValue("SEIKY_WAY_NO_KOZA", setParam[3]);
		setMap.setValue("SEIKY_WAY_NO_CRECARD", setParam[4]);
		setMap.setValue("SVC_KEI_NO", setParam[5]);
		setMap.setValue("SVC_KEI_UCWK_NO", setParam[6]);
		setMap.setValue("SVC_KEI_KAISEN_UCWK_NO", setParam[7]);
		setMap.setValue("KKTK_SVC_KEI_NO", setParam[8]);
		setMap.setValue("OP_SVC_KEI_NO", setParam[9]);
		setMap.setValue("SEIOPSVC_KEI_NO", setParam[10]);
		setMap.setValue("SBOP_SVC_KEI_NO", setParam[11]);
		setMap.setValue("WRIB_SVC_KEI_NO", setParam[12]);
		setMap.setValue("IDO_DIV", setParam[13]);
		setMap.setValue("IDO_DTM", setParam[14]);
		setMap.setValue("PRG_STAT", setParam[15]);
		setMap.setValue("PRG_DTM", setParam[16]);
		setMap.setValue("PRG_MEMO", setParam[17]);
		setMap.setValue("PRG_TKJK_1", setParam[18]);
		setMap.setValue("PRG_TKJK_2", setParam[19]);
		setMap.setValue("ADD_DTM", setParam[20]);
		setMap.setValue("ADD_OPEACNT", setParam[21]);
		setMap.setValue("UPD_DTM", setParam[22]);
		setMap.setValue("UPD_OPEACNT", setParam[23]);
		setMap.setValue("DEL_DTM", setParam[24]);
		setMap.setValue("DEL_OPEACNT", setParam[25]);
		setMap.setValue("MK_FLG", setParam[26]);
		setMap.setValue("ADD_UNYO_YMD", setParam[27]);
		setMap.setValue("ADD_TRN_ID", setParam[28]);
		setMap.setValue("UPD_UNYO_YMD", setParam[29]);
		setMap.setValue("UPD_TRN_ID", setParam[30]);
		setMap.setValue("DEL_UNYO_YMD", setParam[31]);
		setMap.setValue("DEL_TRN_ID", setParam[32]);
	
		// DBアクセスを実行します
		db_KK_T_PRG.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * 番ポ番号変更CC呼び出し処理
	 * 
	 * @param inMap 入力電文
	 * @return HashMap<String, Object> 処理結果
	 * @throws Exception
	 */
	private HashMap<String, Object> doExecute(HashMap<String, Object> excuteMap) throws Exception
	{
		
		HashMap<String, Object> paramMap = new HashMap<String, Object>();
		// 電話番号変更CC呼び出し
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, USECASE_ID);
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_OPERATION_ID, OPERATION_ID);
		// サービスに渡す業務データを格納するMAPです。
		HashMap<String, Object> inputMap = new HashMap<String, Object>();
		// サービスに渡す業務データを格納するMAPです。
		HashMap<String, Object> dataMap = new HashMap<String, Object>();
		
		// inputMapにCCに必要な情報をセットする
		inputMap.put(KKSV074501CC, excuteMap);
		
		// サービスの処理結果が格納されるMAPを生成
		HashMap<String, Object> outputMap = new HashMap<String, Object>();
		// 電話番号変更CCを呼び出す
		JCCBatchEsbInterface.invokeService(super.commonItem, paramMap, inputMap, outputMap);

		// 処理結果を返却する
		return outputMap;
	}

	/**
	 * 進捗作成処理
	 * 
	 * @param chbf_svc_kei_ucwk_no 変更前サービス契約内訳番号
	 * @param chaf_svc_kei_ucwk_no 変更後サービス契約内訳番号
	 * @param ido_div 異動区分
	 * @throws Exception
	 */
	private void createKK_T_PRG(String chbf_svc_kei_ucwk_no, 
			String chaf_svc_kei_ucwk_no, 
			String ido_div) throws Exception
	{
		super.logPrint.printDebugLog("createKK_T_PRG_START");
		JBSbatCommonDBInterface map = new JBSbatCommonDBInterface();
		String[] param = new String[3];
		//過去の進捗情報を取得
		param[0] = chaf_svc_kei_ucwk_no;
		param[1] = ido_div;
		param[2] = super.opeDate;
		executeKK_T_PRG_KK_SELECT_034(param);
		map = db_KK_T_PRG.selectNext();
		if(map != null)
		{
			//変更前データの進捗を登録
			param = new String[33];
			// 進捗番号
			param[0] = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), 12);
			// 申込明細番号
			param[1] = map.getString(JBSbatKK_T_PRG.MSKM_DTL_NO);
			// 請求契約番号
			param[2] = map.getString(JBSbatKK_T_PRG.SEIKY_KEI_NO);
			// 請求方法番号（口座）
			param[3] = map.getString(JBSbatKK_T_PRG.SEIKY_WAY_NO_KOZA);
			// 請求方法番号（クレジットカード）
			param[4] = map.getString(JBSbatKK_T_PRG.SEIKY_WAY_NO_CRECARD);
			// サービス契約番号
			param[5] = map.getString(JBSbatKK_T_PRG.SVC_KEI_NO);
			// サービス契約内訳番号
			param[6] = chbf_svc_kei_ucwk_no;
			// サービス契約回線内訳番号
			param[7] = null;
			// 機器提供サービス契約番号
			param[8] = null;
			// オプションサービス契約番号
			param[9] = null;
			// 請求オプションサービス契約番号
			param[10] = null;
			// サブオプションサービス契約番号
			param[11] = null;
			// 割引サービス契約番号
			param[12] = null;
			// 異動区分
			param[13] = ido_div;
			// 異動年月日時分秒
			param[14] = map.getString(JBSbatKK_T_PRG.IDO_DTM);
			// 進捗ステータス
			param[15] = "B304";
			// 進捗年月日時分秒
			param[16] = JKKBatCommon.getOpeDateTimeStamp(commonItem);
			// 進捗メモ
			param[17] = "変更前電話番号　解約";
			// 進捗特記事項１
			param[18] = null;
			// 進捗特記事項２
			param[19] = null;
			// 登録年月日時分秒
			param[20] = JBSbatDateUtil.getSystemDateTimeStamp();
			// 登録オペレータアカウント
			param[21] = super.batchUserId;
			// 更新年月日時分秒
			param[22] = JBSbatDateUtil.getSystemDateTimeStamp();
			// 更新オペレータアカウント
			param[23] = super.batchUserId;
			// 削除年月日時分秒
			param[24] = "";
			// 削除オペレータアカウント
			param[25] = "";
			// 無効フラグ
			param[26] = "0";
			// 登録運用年月日
			param[27] = super.opeDate;
			// 登録処理ID
			param[28] = super.jobid;
			// 更新運用年月日
			param[29] = super.opeDate;
			// 更新処理ID
			param[30] = super.jobid;
			// 削除運用年月日
			param[31] = "";
			// 削除処理ID
			param[32] = "";
			
			executeKK_T_PRG_PKINSERT(param);

			//変更後データの進捗を登録
			param = new String[33];
			// 進捗番号
			param[0] = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), 12);
			// 申込明細番号
			param[1] = map.getString(JBSbatKK_T_PRG.MSKM_DTL_NO);
			// 請求契約番号
			param[2] = map.getString(JBSbatKK_T_PRG.SEIKY_KEI_NO);
			// 請求方法番号（口座）
			param[3] = map.getString(JBSbatKK_T_PRG.SEIKY_WAY_NO_KOZA);
			// 請求方法番号（クレジットカード）
			param[4] = map.getString(JBSbatKK_T_PRG.SEIKY_WAY_NO_CRECARD);
			// サービス契約番号
			param[5] = map.getString(JBSbatKK_T_PRG.SVC_KEI_NO);
			// サービス契約内訳番号
			param[6] = chaf_svc_kei_ucwk_no;
			// サービス契約回線内訳番号
			param[7] = null;
			// 機器提供サービス契約番号
			param[8] = null;
			// オプションサービス契約番号
			param[9] = null;
			// 請求オプションサービス契約番号
			param[10] = null;
			// サブオプションサービス契約番号
			param[11] = null;
			// 割引サービス契約番号
			param[12] = null;
			// 異動区分
			param[13] = ido_div;
			// 異動年月日時分秒
			param[14] = map.getString(JBSbatKK_T_PRG.IDO_DTM);
			// 進捗ステータス
			param[15] = "B304";
			// 進捗年月日時分秒
			param[16] = JKKBatCommon.getOpeDateTimeStamp(commonItem);
			// 進捗メモ
			param[17] = "変更後電話番号　開始";
			// 進捗特記事項１
			param[18] = null;
			// 進捗特記事項２
			param[19] = null;
			// 登録年月日時分秒
			param[20] = JBSbatDateUtil.getSystemDateTimeStamp();
			// 登録オペレータアカウント
			param[21] = super.batchUserId;
			// 更新年月日時分秒
			param[22] = JBSbatDateUtil.getSystemDateTimeStamp();
			// 更新オペレータアカウント
			param[23] = super.batchUserId;
			// 削除年月日時分秒
			param[24] = "";
			// 削除オペレータアカウント
			param[25] = "";
			// 無効フラグ
			param[26] = "0";
			// 登録運用年月日
			param[27] = super.opeDate;
			// 登録処理ID
			param[28] = super.jobid;
			// 更新運用年月日
			param[29] = super.opeDate;
			// 更新処理ID
			param[30] = super.jobid;
			// 削除運用年月日
			param[31] = "";
			// 削除処理ID
			param[32] = "";
			
			executeKK_T_PRG_PKINSERT(param);
		}
		super.logPrint.printDebugLog("createKK_T_PRG_END");
	}
}