/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKOrsjgsUseStp
*	ソースファイル名	：JBSbatKKOrsjgsUseStp.java
*	作成者				：FJ)麻生
*	作成日				：2018年04月06日
*＜機能概要＞
*卸先事業者利用停止部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v37.00.00	2018/04/06	FJ)麻生		【ANK-3366-00-00】eo光設備卸対応
*********************************************************************/
package eo.business.service;

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

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JBSbatKKConst;
import eo.business.util.file.JBSbatKKIFM796;
import eo.business.util.table.JBSbatKK_T_SVC_KEI;
import eo.common.constant.JKKStrConst;
import eo.common.constant.JPCModelConstant;
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;
import eo.framework.util.JCCBatchEsbInterface;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKOrsjgsUseStp extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	/** テーブル(サービス契約)*/
	private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
	
	/** テーブル(卸先事業者契約異動通知)*/
	private static final String D_TBL_NAME_KK_T_ORSJGS_KEI_IDT = "KK_T_ORSJGS_KEI_IDT";

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

	/** テーブルアクセスクラス(サービス契約)*/
	private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
	
	/** テーブルアクセスクラス(卸先事業者契約異動通知)*/
	private JBSbatSQLAccess db_KK_T_ORSJGS_KEI_IDT = null;
	
	/** 対象データマップ */
	private static final String CC_TRGT_DATA = "KKSV089901CC";

	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		// 中間ファイルが空ファイルの場合は継続処理を行わず、警告を返す。卸先契約受付済キャンセルファイルの削除を行う。
		if(!super.commonItem.getInput_data_flg())
		{
			super.logPrint.printBusinessErrorLog("EKKB0720KW",
			new String[]{ "卸先事業者利用停止対象情報ファイル" });

		}

		// DBアクセスクラスを生成します
		db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
		db_KK_T_ORSJGS_KEI_IDT = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_ORSJGS_KEI_IDT);
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		try
		{
			// 入力ファイルの内容取得
			String inputOrsjgsKeiIdtNo = inMap.getString(JBSbatKKIFM796.ORSJGS_KEI_IDT_NO);
			String inputSvcKeiNo = inMap.getString(JBSbatKKIFM796.SVC_KEI_NO);
			
			
			// 利用停止対象情報抽出
			ArrayList<JBSbatCommonDBInterface> svcKeiNoInfo = getExistSvcKeiNo(inputSvcKeiNo);
			
			boolean isValidStatus = false;

			if (svcKeiNoInfo.size() > 0)
			{
				String svcKeiStat = svcKeiNoInfo.get(0).getString(JBSbatKK_T_SVC_KEI.SVC_KEI_STAT);
				if (JBSbatKKConst.SVC_KEI_STAT_SVCTK_CHU.equals(svcKeiStat))
				{
					String svcCd = svcKeiNoInfo.get(0).getString(JBSbatKK_T_SVC_KEI.SVC_CD);
					if (JBSbatKKConst.SVC_CD_IN_SVC.equals(svcCd) || JBSbatKKConst.SVC_CD_TEL_SVC.equals(svcCd)
							|| JBSbatKKConst.SVC_CD_TV_SVC.equals(svcCd))
					{
						isValidStatus = true;
					}
				}
			}
			
			String orsjgsKeiIdtRsltCd = "1";
			String orsjgsKeiIdtNgRsn = "";
			
			if (!isValidStatus)
			{
				orsjgsKeiIdtRsltCd = "2";
				orsjgsKeiIdtNgRsn = "契約状態が利用停止処理対象外です。";
				super.logPrint.printBusinessErrorLog("EKKB1620KW",  new String[]{inputSvcKeiNo, "利用停止"});
				super.commonItem.setErrFlg(true);
			}
			else
			{
				// ユースケースIDを格納するMAP
				HashMap<String,Object> paramMap = new HashMap<String, Object>();
				paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, "KKSV0899");
				
				// サービスに渡す業務データを格納するMAP
				HashMap<String,Object> inputMap = new HashMap<String, Object>();
				
				// inputMapに設定するデータをHashMapで構築する。
				HashMap<String,Object> dataMap = new HashMap<String, Object>();
				
				// MAPにデータを格納する。
				dataMap.put("svc_kei_no", inputSvcKeiNo);
				
				// 機能コードのマッピング
				dataMap.put("func_code", JPCModelConstant.FUNC_CD_1);
				
				inputMap.put(CC_TRGT_DATA, dataMap);
				
				// サービスの処理結果が格納されるMAP
				HashMap<String,Object> outputMap = new HashMap<String, Object>();
				
				String ccReturnCode = "";

				try
				{
					// サービス呼び出し
					JCCBatchEsbInterface.invokeService(super.commonItem, paramMap, inputMap, outputMap);
					
					// サービスの処理結果が格納されたoutputMapから指定したキーで値を取得する。
					Map<String, Object> ccMap = (Map<String, Object>)outputMap.get(CC_TRGT_DATA);
	
					if (ccMap != null)
					{
						ccReturnCode = (String)ccMap.get(JKKStrConst.RETURN_CODE);
					}
					// サービスがエラーを返した場合
					if(!JKKStrConst.CHECK_OK.equals(ccReturnCode))
					{
						orsjgsKeiIdtRsltCd = "2";
						orsjgsKeiIdtNgRsn = "卸先事業者利用停止時、エラーが発生しました。";
						super.logPrint.printBusinessErrorLog("EKKB1670KW", new String[]{"利用停止" , inputSvcKeiNo});
						super.commonItem.setErrFlg(true);
					}
				}
				catch (Throwable e)
				{
					orsjgsKeiIdtRsltCd = "2";
					orsjgsKeiIdtNgRsn = "卸先事業者利用停止時、エラーが発生しました。";
					super.logPrint.printBusinessErrorLog("EKKB1670KW", new String[]{"利用停止" , inputSvcKeiNo});
					super.commonItem.setErrFlg(true);
				}
			}
			
			// 利用停止処理結果を卸先事業者契約異動通知スキーマに対して更新をおこなう。
			updateOrsjgsKeiIdt(inputOrsjgsKeiIdtNo, orsjgsKeiIdtRsltCd, orsjgsKeiIdtNgRsn);
			
		
		}
		catch(Exception e)
		{
			throw e;
		}

		return null;
	}
	
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		// DBアクセスクラスをクローズします
		db_KK_T_SVC_KEI.close();
		db_KK_T_ORSJGS_KEI_IDT.close();
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 入力ファイルのサービス契約番号をもとにサービス契約を検索する.
	 * 取得項目：
	 *			サービス契約番号
	 * @param svcKeiNo サービス契約番号
	 * @return ArrayList
	 * @throws Exception DBアクセス時の例外
	 */
	private ArrayList<JBSbatCommonDBInterface> getExistSvcKeiNo(String svcKeiNo) throws Exception
	{
		Object[] param = {
				svcKeiNo,					// サービス契約．サービス契約番号			= 入力ファイル．サービス契約番号
				super.opeDate,				// サービス契約．予約適用年月日				<=バッチ運用日
		};
		
		executeKK_T_SVC_KEI_KK_SELECT_012(param);
		JBSbatCommonDBInterface orsjgsInfo = new JBSbatCommonDBInterface();
		ArrayList<JBSbatCommonDBInterface> orsjgsList = new ArrayList<JBSbatCommonDBInterface>();

		while((orsjgsInfo = db_KK_T_SVC_KEI.selectNext()) != null)
		{
			orsjgsList.add(orsjgsInfo);
		}
		return orsjgsList;
	}
	
	/**
	 * SQLKEY(KK_SELECT_012)で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_SVC_KEI_KK_SELECT_012(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		
		// DBアクセスを実行します
		db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_012);
	}
	
	/**
	 * 卸先事業者契約異動通知スキーマの更新を行う<br>
	 * 
	 * @param orsjgsKeiIdoNo 卸先事業者契約異動通知番号
	 * @param orsjgsKeiIdtRsltCd 卸先事業者契約異動通知結果コード
	 * @param orsjgsKeiIdtNgRsn 卸先事業者契約異動処理年月日
	 * @throws Exception DB更新時の例外
	 */
	private void updateOrsjgsKeiIdt(String orsjgsKeiIdoNo, String orsjgsKeiIdtRsltCd, String orsjgsKeiIdtNgRsn) throws Exception
	{
		// 設定項目を設定します。
		String [] setParam = {orsjgsKeiIdtRsltCd, super.opeDate, orsjgsKeiIdtNgRsn};
		// 条件項目を設定します。
		String [] whereParam = {orsjgsKeiIdoNo};
		
		// 卸先事業者契約異動通知スキーマ登録
		executeKK_T_ORSJGS_KEI_IDT_PKUPDATE(setParam, whereParam);
		
		// コミット処理を行う
		super.commit();

	}
	
	/**
	 * PK(ＰＫ 更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	卸先事業者契約異動通知結果コード				ORSJGS_KEI_IDT_RSLT_CD
	 *		 	卸先事業者契約異動処理年月日					ORSJGS_KEI_IDO_TRN_YMD
	 *		 	卸先事業者契約異動通知NG理由					ORSJGS_KEI_IDT_NG_RSN
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	卸先事業者契約異動通知番号						ORSJGS_KEI_IDT_NO
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_ORSJGS_KEI_IDT_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("ORSJGS_KEI_IDT_RSLT_CD", setParam[0]);
		setMap.setValue("ORSJGS_KEI_IDO_TRN_YMD", setParam[1]);
		setMap.setValue("ORSJGS_KEI_IDT_NG_RSN", setParam[2]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("ORSJGS_KEI_IDT_NO", whereParam[0]);

		// DBアクセスを実行します
		db_KK_T_ORSJGS_KEI_IDT.updateByPrimaryKeys(whereMap, setMap);
	}
	
}