/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKMcafeeCnslReq
*	ソースファイル名	：JBSbatKKMcafeeCnslReq.java
*	作成者				：富士通　
*	作成日				：2017年04月18日
*＜機能概要＞
*　マカフィーキャンセル依頼部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v32.00.00	2017/04/18  FJ)原田		【ANK-3149-00-00】新セキュリティパック
*	v32.00.01	2017/06/06  FJ)原田		【ST-2017-0000009】新セキュリティーパック案件の外部接続時におけるシステムエラー対応
*	v32.00.02	2017/06/13  FJ)原田		【IT1-2017-0000083】対応
*	v32.01.00	2017/07/07  FJ)原田		【OM-2017-0000695】対応
*********************************************************************/
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.JCCBatCommon;
import eo.business.util.table.JBSbatKK_T_TAJGS_KEI_IDT;
import eo.common.util.JKKCtrlMcafeeInfo;
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>
* @author 富士通
*/
public class JBSbatKKMcafeeCnslReq extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** コマンド実行結果（正常） */
	private String CMD_RESULT_CD_OK = "0";
	
	/** 処理日付格納用（YYYYMMDD） */
	private String sysDate = null;
	
	/** テーブルアクセスクラス(他事業者契約異動通知)*/
	private JBSbatSQLAccess db_KK_T_TAJGS_KEI_IDT = null;
	
	/** テーブルアクセスクラス（更新用）(他事業者契約異動通知)*/
	private JBSbatSQLAccess db_upd_KK_T_TAJGS_KEI_IDT = null;
	
	/** 他事業者契約異動通知結果コード（エラー） */
	private static final String TAJGS_KEI_IDT_RSLT_CD_ERR = "1";
	
	/** マカフィーキャンセル依頼 */
	private static final String MCAFEE_CANCEL_REQ = "0102";
	
	// OM-2017-0000695 ADD START
	/** トランザクション・コード（ワーニング：5001） */
	private static final String TRANSACTION_CD_WARN_5001= "5001";
	
	/** トランザクション・コード（ワーニング：5002） */
	private static final String TRANSACTION_CD_WARN_5002 = "5002";
	// OM-2017-0000695 ADD END
	
	/** SQL定義キー(KK_UPDATE_001) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_001 = "KK_UPDATE_001";
	
	/** SQL定義キー(KK_SELECT_001) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_SELECT_003 = "KK_SELECT_003";
	
	/** SQL定義キー(KK_UPDATE_005) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_005 = "KK_UPDATE_005";
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/**
	 * 初期処理
	 * @param commonItem バッチ共通パラメータ電文
	 * @throws Exception 各種エクセプション
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		
		// DBアクセスクラスを生成します
		db_KK_T_TAJGS_KEI_IDT = new JBSbatSQLAccess(commonItem, JBSbatKK_T_TAJGS_KEI_IDT.TABLE_NAME);
		db_upd_KK_T_TAJGS_KEI_IDT = new JBSbatSQLAccess(commonItem, JBSbatKK_T_TAJGS_KEI_IDT.TABLE_NAME);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception 各種エクセプション
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		String[] param = null;
		
		// システム日付取得
		sysDate = commonItem.getOpeDate();
		
		// 他事業者契約異動種別コードが
		// "0102"(マカフィーキャンセル依頼)の
		// 他事業者契約異動通知状態コードを "0"（未通知） →"3"（処理依頼中）へ更新
		param = new String[]{MCAFEE_CANCEL_REQ, sysDate};
		
		// 他事業者契約異動通知状態コードの更新を実行
		executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_001(param);
		super.commit();
		
		// 他事業者契約異動種別コードが"3"（処理依頼中）で
		// 他事業者契約異動通知状態コードが
		// "0102"(マカフィーキャンセル依頼)を対象に
		// 電文作成に必要なデータを取得
		param = new String[]{};
		
		// 送信対象のデータの情報取得
		executeKK_T_TAJGS_KEI_IDT_KK_SELECT_003(param);
		
		JBSbatCommonDBInterface sqlResultMap = new JBSbatCommonDBInterface();
		
		
		super.logPrint.printDebugLog("********** マカフィーキャンセル依頼処理処理 START **********");
		// 取得できた件数分while文で電文作成→送受信メソッド呼び出し→DB登録を行う
		while(null != (sqlResultMap = db_KK_T_TAJGS_KEI_IDT.selectNext()))
		{
			// 1件ずつデータを取って
			HashMap<String, Object> serviceMap = new HashMap<String, Object>();
			
			// serviceMapに電文の作成に必要なデータを格納
			// マカフィー会員ID
			serviceMap.put("mcafeeMemberId", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_MEMBER_ID));
			
			// 他事業者契約異動通知番号
			serviceMap.put("tajgsKeiIdoNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO));
			
			// 他事業者契約異動種別コード
			serviceMap.put("tajgsKeiIdoSbtCd", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDO_SBT_CD));
			
			if(sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_BUY_ID) == null)
			{
				// 他事業者契約異動通知スキーマに結果エラーで登録
				param = new String[]{JCCBatCommon.getSysDateTimeStamp()
						 ,TAJGS_KEI_IDT_RSLT_CD_ERR
						 ,""
						 ,sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)
						 };
				
				executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_005(param);
				
				super.commit();
				
				// ログの出力
				StringBuilder msg = new StringBuilder();
				
				msg.append("マカフィー購入ＩＤが設定されていません。")
					.append("他事業者契約異動通知番号[").append(sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)).append("]")
					;
				
				commonItem.getLogPrint().printBusinessErrorLog("EKKB1390AE",  new String[] {msg.toString()});
				
				continue;
			}
			else
			{
				// マカフィー購入ID
				serviceMap.put("mcafeeBuyId", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_BUY_ID));
			}
			
			super.logPrint.printDebugLog("************ キャンセル依頼対象データ ************");
			super.logPrint.printDebugLog("他事業者契約異動通知番号: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO));
			super.logPrint.printDebugLog("マカフィー会員ID: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_MEMBER_ID));
			
			// コマンド発行部品のインスタンスを取得
			JKKCtrlMcafeeInfo instance = JKKCtrlMcafeeInfo.getInstance();
			
			// マカフィー連携処理呼出
			Map<String, Object> ret = instance.call_KKIFE354(serviceMap);
				
			if (CMD_RESULT_CD_OK.equals(ret.get("CMD_RESULT_CD")))
			{
				ArrayList<Map<String, Object>> nodelist = new ArrayList<Map<String, Object>>();
				HashMap<String, Object> resultinfo = new HashMap<String, Object>();
				
				nodelist = (ArrayList<Map<String, Object>>)ret.get("CMD_RESULT_DETAIL");
				resultinfo = (HashMap<String, Object>)nodelist.get(0);
				
				// リターンコードから他事業者契約異動結果コードを判定
				String returnCode = (String)resultinfo.get("returnCode");
				String tajgsKeiIdtRsltCd = analyzeResult(returnCode);
				
				/** 返却された結果を他事業者契約通知テーブルに反映させる */
				param = new String[]{JCCBatCommon.getSysDateTimeStamp()
									 ,tajgsKeiIdtRsltCd
									 // ST-2017-0000009 MOD START
//									 ,(String)resultinfo.get("returnCode")
									 ,JKKStringUtil.nullToBlank((String)resultinfo.get("returnCode"))
									 // ST-2017-0000009 MOD END
									 ,sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)
									 };
				
				executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_005(param);
				
				super.commit();
				
				
				if(TAJGS_KEI_IDT_RSLT_CD_ERR.equals(tajgsKeiIdtRsltCd))
				{
					super.logPrint.printDebugLog("マカフィーキャンセル依頼処理にて返却値のエラーが発生しています。");
					
					StringBuilder msg = new StringBuilder();
					
					msg.append("他事業者契約異動通知番号[").append((String)serviceMap.get("tajgsKeiIdoNo")).append("]")
						// ST-2017-0000009 MOD START
//						.append("トランザクション・コード[").append((String)resultinfo.get("returnCode")).append("]")
//						.append("トランザクション・コード説明[").append((String)resultinfo.get("returnCodeSetmei")).append("]")
						.append("トランザクション・コード[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("returnCode"))).append("]")
						.append("トランザクション・コード説明[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("returnCodeSetmei"))).append("]")
						// ST-2017-0000009 MOD END
						;
					
					commonItem.getLogPrint().printBusinessErrorLog("EKKB1390AE",  new String[] {msg.toString()});
					
					// OM-2017-0000695 ADD START
					// リクエストとレスポンスの電文を出力
					String log = (String)ret.get("LOG_RESULT");
					commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log});
					// OM-2017-0000695 ADD END
					
					continue;
				}
				
				// OM-2017-0000695 ADD START
				// トランザクション・コードがワーニング("5001","5002")のときにもリクエストとレスポンスの電文を出力
				if(TRANSACTION_CD_WARN_5001.equals(returnCode) || TRANSACTION_CD_WARN_5002.equals(returnCode))
				{
					String log = (String)ret.get("LOG_RESULT");
					commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log});
				}
				// OM-2017-0000695 ADD END
			}
			else
			{
				super.logPrint.printDebugLog("マカフィーキャンセル依頼処理中に通信異常が発生しました。");
				
				param = new String[]{JCCBatCommon.getSysDateTimeStamp()
						 ,TAJGS_KEI_IDT_RSLT_CD_ERR
						 ,""
						 ,sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)
						 };
				
				executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_005(param);
				
				super.commit();
				
				// ログを出力
				StringBuilder msg = new StringBuilder();
				
				String log = (String)ret.get("LOG_RESULT");

				msg.append("他事業者契約異動通知番号[").append((String)serviceMap.get("tajgsKeiIdoNo")).append("]")
					.append("CMD_ERROR_CD[").append((String)ret.get("CMD_ERROR_CD")).append("]")
					.append("CMD_ERROR_MESSAGE[").append((String)ret.get("CMD_ERROR_MESSAGE")).append("]")
					;
				
				commonItem.getLogPrint().printBusinessErrorLog("EKKB0990CE", new String[] {msg.toString()});
				commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log});
				
				continue;
			}
		}
		
		super.logPrint.printDebugLog("********** マカフィーキャンセル依頼処理 END **********");
		
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception 各種エクセプション
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		db_KK_T_TAJGS_KEI_IDT.close();
		
		// IT1-2017-0000083 ADD START
		db_upd_KK_T_TAJGS_KEI_IDT.close();
		// IT1-2017-0000083 ADD END
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * 電文の返却値から他事業者契約異動通知に登録する値を編集します
	 * <br>
	 * @param returnCode リターンコード
	 * @return HashMap 他事業者契約異動通知に登録する値（他事業者契約異動通知結果コード、他事業者契約異動通知結果詳細コード）
	 */
	public String analyzeResult(String returnCode)
	{
		String tajgsKeiIdtRsltCd = "";
		
		if("1000".equals(returnCode) || "5001".equals(returnCode) || "5002".equals(returnCode))
		{
			tajgsKeiIdtRsltCd = "0";
		}
		else
		{
			tajgsKeiIdtRsltCd = "1";
		}
		
		return tajgsKeiIdtRsltCd;
	}
	
	/**
	 * SQLKEY(KK_UPDATE_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			"0102"(マカフィーキャンセル依頼)
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_KK_T_TAJGS_KEI_IDT.executeBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_UPDATE_001);
	}
	
	/**
	 * SQLKEY(KK_SELECT_003)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			"0102"(マカフィーキャンセル依頼)
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TAJGS_KEI_IDT_KK_SELECT_003(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();

		// DBアクセスを実行します
		db_KK_T_TAJGS_KEI_IDT.selectBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_SELECT_003);
	}
	
	/**
	 * SQLKEY(KK_UPDATE_005)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			ユーザーサブスクリプションPIN
	 *			サブスクリプションID
	 *			他事業者契約異動通知結果コード
	 *			他事業者契約異動通知結果詳細コード
	 *			他事業者契約異動通知番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_005(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_upd_KK_T_TAJGS_KEI_IDT.executeBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_UPDATE_005);
	}
}