/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKNetflixKeiActivationPerForManAdd
*	ソースファイル名	：JBSbatKKNetflixKeiActivationPerForManAdd.java
*	作成者				：富士通　
*	作成日				：2021年01月15日
*＜機能概要＞
*　Netflix契約Activation実績登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v52.00.00	2021/1/15  FJ)澤田		ANK-3987-00-00_Netflix導入対応(STEP2)
*********************************************************************/
package eo.business.service;

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import org.json.JSONArray;
import org.json.JSONObject;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.table.JBSbatKK_T_RNKI_FILE_CTRL;
import eo.common.constant.JFUStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JKKCtrlNetflix;
import eo.common.util.JKKStringUtil;
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;
import eo.framework.util.JBSbatOracleSeqUtil;
import eo.framework.util.JBSbatStringUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKNetflixKeiActivationPerForManAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(連携ファイル制御)*/
	private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";
	/** テーブル(他事業者契約利用開始実績)*/
	private static final String D_TBL_NAME_KK_T_TJGSK_UEST_JSK = "KK_T_TJGSK_UEST_JSK";
	/** テーブルアクセスクラス(連携ファイル制御)*/
	private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
	/** テーブルアクセスクラス(他事業者契約利用開始実績)*/
	private JBSbatSQLAccess db_KK_T_TJGSK_UEST_JSK = null;
	/** 物理バッチID */
	private static final String BUTSURI_BAT_ID = "KKPRC64901";
	/** ファイルID */
	private static final String FILE_ID = "0000000000";
	/** API種別(ActivationData) **/
	private static final String API_SBT_ACTIVATION  = "ACTIVATIONDATA";
	/** リクエスト項目 */
	/** 問い合わせ範囲開始日時 **/
	private static final String REQ_ACTIVATEDAFTERTIMESTAMP = "activatedAfterTimestamp";
	/** 問い合わせ範囲終了日時 **/
	private static final String REQ_ACTIVATEDBEFORETIMESTAMP = "activatedBeforeTimestamp";
	/** ページ **/
	private static final String REQ_PAGE = "page";
	/** サービスプロバイダー **/
	private static final String REQ_SERVICEPROVIDER = "serviceProvider";
	/** イベント */
	private static final String RES_ACTIVATION_EVENTS = "activationEvents";
	/** パートナーアカウントID */
	private static final String RES_PAI = "pai";
	/** アクティベーション日時 */
	private static final String RES_ACTIVATIONTIMESTAMP = "activationTimestamp";
	/** 問い合わせ範囲終了日時（結果） */
	private static final String RES_ACTIVATEDBEFORETIMESTAMP = "activatedBeforeTimestamp";
	/** 次ページ */
	private static final String RES_NEXT = "next";
	/** 他事業者契約利用開始実績番号シーケンス */
	private static final String SEQ_TJGSK_UEST_JSK_NO = "SEQ_TJGSK_UEST_JSK_NO";
	/** レスポンス項目 */
	/** エラー */
	private static final String RESPONSESTATUS  = "responseStatus";
	/** エラーコード */
	private static final String ERRORCODE  = "errorCode";
	/** HTTPステータスコード */
	private static final String HTTPSTATUSCODE  = "httpStatusCode";
	/** エラー説明 */
	private static final String DESCRIPTION  = "description";
	/** SQL定義キー(KK_SELECT_001)*/
	private static final String KK_T_TJGSK_UEST_JSK_KK_SELECT_001 = "KK_SELECT_001";
	
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

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

		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception 各種エクセプション
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 連携ファイル制御TBLから「前回処理実行年月日時分秒」を取得する。
		String zenkaiShoriJikoYMD = getZenkaiShorJjikoYMD();
		
		// 前回処理実行年月日時分秒を取得できない場合
		if (JKKStringUtil.isNullBlank(zenkaiShoriJikoYMD))
		{
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0150JE, new String[] {"連携ファイル制御スキーマ"});
		}
		
		HashMap<String, Object> serviceMap = new HashMap<String, Object>();
		
		// serviceMapに電文の作成に必要なデータを格納
		// API種別
		serviceMap.put("apiSbtCd", API_SBT_ACTIVATION);
		// 運用年月日時分秒
		serviceMap.put("opeDateTime", JCCBatCommon.getSysDateTime());

		//次ページ
		String resNext = null;
		
		//問い合わせ範囲終了日時（結果）
		long znkiTranRunDtm= 0;
		
		//日付をUNIX時間に変更（17桁）
		SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyyMMddHHmmssSSS");
		Date date = sdf.parse(zenkaiShoriJikoYMD);
		long unixTimeZenkaiShoriJikoYMD = date.getTime();
		
		// APIの繰返回数を取得
		int forCount = Integer.parseInt(JCCBatCommon.getApplicationConst("KK_NETFLIX_ACTIVATIONDATA_FORCOUNT"));
		
		Map<String, Object> requestEditMap = new HashMap<String, Object>();
		
		// 問い合わせ範囲開始日時 
		requestEditMap.put(REQ_ACTIVATEDAFTERTIMESTAMP, String.valueOf(unixTimeZenkaiShoriJikoYMD));
		
		//get通信用のパラメータ
		String urlParam = "";
		
		// GET通信用に編集
		Iterator<?> it = requestEditMap.keySet().iterator();
		
		StringBuffer queryStringSb = new StringBuffer();
		while (it.hasNext())
		{
			String paramName = (String) it.next();
			String paramValue = (String) requestEditMap.get(paramName);
			if (queryStringSb.length() > 0)
			{
				queryStringSb.append("&");
			}
			queryStringSb.append(paramName + "=" + paramValue);
		}
		if (queryStringSb.length() > 0)
		{
			urlParam = queryStringSb.toString();
		}
		
		Map<String, Object> requestMap = new HashMap<String, Object>();
		
		// レスポンスの次ページが存在するまで繰り返し処理を行う。
		for (int i = 0; i < forCount; i++)
		{
			//リクエストマップ
			requestMap.put("urlParam", urlParam);
			//サービスマップ
			serviceMap.put("requestValue", requestMap);
			
			super.logPrint.printDebugLog("************ ActivationData対象データ ************");
			StringBuilder logMsg = new StringBuilder();
			
			logMsg.append("リクエストデータ:問い合わせ範囲開始日時[").append(zenkaiShoriJikoYMD).append("]").append(",ページ[").append("").append("next[").append(urlParam).append("]");
			commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI",  new String[] {logMsg.toString()});
			// コマンド発行部品のインスタンスを取得
			JKKCtrlNetflix instance = JKKCtrlNetflix.getInstance();
			
			Map<String, Object> resultinfo = instance.call_netflix(serviceMap);
			
			// 戻り値の取得
			String reqHeader = (String)resultinfo.get("reqHeader");
			String request = (String)resultinfo.get("request");
			String response = (String)resultinfo.get("response");
			String url = JFUStrConst.EMPTY;
			if (resultinfo.containsKey("url"))
			{
				url = (String)resultinfo.get("url");
			}
			//ログの出力
			String log = "header=" + reqHeader + ", request=" + request + ", response=" + response; 
			commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log});
			if (!JFUStrConst.EMPTY.equals(url))
			{
				commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI",  new String[] {"送信先URL[" + url + "]"});
			}
			// 戻り値の設定
			String errorCode = JFUStrConst.EMPTY;
			int httpStatusCode = 500;
			String errorDescription = JFUStrConst.EMPTY;
			String eventInfoList = null;
			// リクエストパラメータを設定する前に初期化しておく
			urlParam = "";
			
			// HTTPのレスポンスから電文を取得する。
			if ( response.length() > 0 )
			{
				try
				{
					JSONObject jsonResult = new JSONObject(response);
					// エラー情報取得
					if (jsonResult.isNull(RESPONSESTATUS))
					{
						// エラーコード
						if (!jsonResult.isNull(ERRORCODE))
						{
							errorCode = jsonResult.optString(ERRORCODE);
						}
						// HTTPステータスコード
						httpStatusCode = jsonResult.optInt(HTTPSTATUSCODE);
						// エラー説明
						if (!jsonResult.isNull(DESCRIPTION))
						{
							errorDescription = jsonResult.optString(DESCRIPTION);
						}
					} else {
						String errorInfo = jsonResult.optString(RESPONSESTATUS);
						JSONObject jsonErrorMap = new JSONObject(errorInfo);
						// エラーコード
						if (!jsonErrorMap.isNull(ERRORCODE))
						{
							errorCode = jsonErrorMap.optString(ERRORCODE);
						}
						// HTTPステータスコード
						httpStatusCode = jsonErrorMap.optInt(HTTPSTATUSCODE);
						// エラー説明
						if (!jsonErrorMap.isNull(DESCRIPTION))
						{
							errorDescription = jsonErrorMap.optString(DESCRIPTION);
						}
					}
					// イベント情報取得
					eventInfoList = jsonResult.optString(RES_ACTIVATION_EVENTS);
					
					// 次ページ
					if (jsonResult.isNull(RES_NEXT))
					{
						resNext = "";
					}
					else
					{
						resNext = jsonResult.optString(RES_NEXT);
						// nextが存在する場合は、urlStringに設定する。
						urlParam = resNext;
					}
					//問い合わせ範囲終了日時（結果）
					znkiTranRunDtm =  jsonResult.optLong(RES_ACTIVATEDBEFORETIMESTAMP);
				}
				catch (Exception ex)
				{
					ex.printStackTrace();
				}
			}
			if (httpStatusCode >= 200 && httpStatusCode < 300)
			{
				if ((eventInfoList != null) && (!"".equals(eventInfoList)))
				{
					JSONArray eventInfoArray = new JSONArray(eventInfoList);
					// イベント情報処理 
					for (int j = 0; j < eventInfoArray.length(); j++)
					{
						JSONObject eventInfo = eventInfoArray.getJSONObject(j);
						// パートナーアカウントID 
						String resPai= "";
						// アクティベーション日時
						long resActivationimestamp= 0;
						//
						String formatActivationimestamp = "";
						
						if (!eventInfo.isNull(RES_PAI))
						{
							resPai = eventInfo.getString(RES_PAI);
						}
						// アクティベーション日時
						if (!eventInfo.isNull(RES_ACTIVATIONTIMESTAMP))
						{
							resActivationimestamp = eventInfo.optLong(RES_ACTIVATIONTIMESTAMP);
							//UNIX時間を日付に変更
							Date dateResActivationimestamp = new java.util.Date(resActivationimestamp);
							formatActivationimestamp = sdf.format(dateResActivationimestamp);
						}
						
						JBSbatCommonDBInterface whereparam = new JBSbatCommonDBInterface();
						
						whereparam.setValue(resPai);// パートナーアカウントID
						
						//他事業者契約利用開始実績でパートナーアカウントIDが存在するかチェックする。
						executeKK_T_TJGSK_UEST_JSK_KK_SELECT_001(whereparam.getList().toArray());
						
						JBSbatCommonDBInterface rcvMap = new JBSbatCommonDBInterface();	// 結果取得用

						// １件目を先読み
						rcvMap = db_KK_T_TJGSK_UEST_JSK.selectNext();

						// 取得できる場合はスキップを行う。
						if (rcvMap != null)
						{
							continue;
						}

						String tjgskUestJskNo = JBSbatOracleSeqUtil.getFormatedNextSeq(commonItem.getConnection(), SEQ_TJGSK_UEST_JSK_NO, "", 12);
						
						JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
						setMap.setValue("TJGSK_UEST_JSK_NO", tjgskUestJskNo);
						setMap.setValue("PTNRACNT_ID", resPai);
						setMap.setValue("TAJGS_KEI_UEST_HMS", formatActivationimestamp);
						// 他事業者契約利用開始実績
						executeKK_T_TJGSK_UEST_JSK_PKINSERT(setMap);
					}
				}
			}
			// 正常終了以外の場合、ログを出力
			else
			{
				super.logPrint.printDebugLog("Netflix情報連携処理部品にて返却値の異常が発生しています。");
				
				logMsg.setLength(0);
				logMsg.append("通信エラー：HttpStatusCode[").append(httpStatusCode).append("]").append(",ErrorCode[").append(errorCode).append("]").append(",errorDescription[").append(errorDescription).append("]");
				commonItem.getLogPrint().printBusinessErrorLog("EKKB2080KW",  new String[] {logMsg.toString()});
				// エラーフラグ設定
				super.commonItem.setErrFlg(true);
				return null;
			}
			//次ページが存在するまで繰り返し処理を行う。
			if (JKKStringUtil.isNullBlank(resNext))
			{
				break;
			}
		} 
		
		date = new java.util.Date(znkiTranRunDtm);
		String formatznkiTranRunDtm = sdf.format(date);
		
		// 連携ファイル制御TBL更新処理を実施する。
		upDateRnkiFileCtrl(formatznkiTranRunDtm);
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 【連携ファイル制御】より前回処理実行年月日時分秒取得<br>
	 * <p>
	 * @return result 前回処理実行年月日時分秒
	 * @throws Exception 
	 */	
	private String getZenkaiShorJjikoYMD() throws Exception
	{
		String result = "";
		
		JBSbatCommonDBInterface dbMap = executeKK_T_RNKI_FILE_CTRL_PKSELECT(new Object[]{BUTSURI_BAT_ID, FILE_ID});
		
		// 結果あり
		if(null != dbMap)
		{
			// 前回処理実行年月日時分秒
			result = JBSbatStringUtil.Rtrim(dbMap.getString(JBSbatKK_T_RNKI_FILE_CTRL.ZNKI_TRAN_RUN_DTM));
		}
		
		return result;
	}
	
	/**
	 * PK(ＰＫ　検索)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	BUTSURI_BAT_ID
	 *		 	FILE_ID
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @return JBSbatCommonDBInterface 検索の結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeKK_T_RNKI_FILE_CTRL_PKSELECT(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
		whereMap.setValue("FILE_ID", whereParam[1]);
		
		// DBアクセスを実行します
		return db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeys(whereMap);
	}

	/**
	 * 連携ファイル制御TBL更新<br>
	 * <p>
	 * @throws Exception 業務サービス内で発生した例外全般。
	 * @throws IOException 
	 */	
	private void upDateRnkiFileCtrl(String znkiTranRunDtm) throws Exception
	{
		// 検索条件の設定
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		
		// 物理バッチID
		whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.BUTSURI_BAT_ID, BUTSURI_BAT_ID);
		
		// ファイルID
		whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.FILE_ID, FILE_ID);
		
		// 連携ファイル制御排他検索を実施します。
		JBSbatCommonDBInterface outDbMap = db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeysForUpdateWait(whereMap);
		
		// 検索結果が存在する場合(更新処理の実施)。
		if (null != outDbMap)
		{
			// 連携ファイル制御更新処理を実施します。
			Object[] setParam = new Object[1];
			
			// 抽出適用開始日時を設定。
			setParam[0] = znkiTranRunDtm;
			
			Object[] whereParam = new Object[2];
			whereParam[0] = BUTSURI_BAT_ID;
			whereParam[1] = FILE_ID;
			
			// 更新処理の実行
			executeKK_T_RNKI_FILE_CTRL_PKUPDATE(setParam, whereParam);
		}
	}
	
	/**
	 * PK(ＰＫ　更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	BUTSURI_BAT_ID
	 *		 	FILE_ID
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_RNKI_FILE_CTRL_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("ZNKI_TRAN_RUN_DTM", setParam[0]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
		whereMap.setValue("FILE_ID", whereParam[1]);

		// DBアクセスを実行します
		db_KK_T_RNKI_FILE_CTRL.updateByPrimaryKeys(whereMap, setMap);
	}
	
	/**
	 * SQLKEY(KK_SELECT_002)で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_TJGSK_UEST_JSK_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

		// DBアクセスを実行します
		db_KK_T_TJGSK_UEST_JSK.selectBySqlDefine(paramList, KK_T_TJGSK_UEST_JSK_KK_SELECT_001);
	}
	
	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TJGSK_UEST_JSK_PKINSERT(JBSbatCommonDBInterface setMap) throws Exception
	{
		// DBアクセスを実行します
		db_KK_T_TJGSK_UEST_JSK.insertByPrimaryKeys(setMap);
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
}