/*******************************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JECNA0260001CBSMsgTPMA
*	ソースファイル名：JECNA0260001CBSMsgTPMA.java
*	作成者			：FJ）北村
*	日付			：2023年10月10日
*＜機能概要＞
*	コンテンツ即時契約独自処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v65.00.00	2023/10/10	FJ）北村	【ANK-4346-00-00】【eo定期】CCMG再構築対応
*   v65.00.01	2023/08/31	FJ) 渋谷	【ST-2024-0000002】エラーハンドリング対応
*	v73.00.00	2024/12/11	FJ)謝		【ANK-4570-00-00】コンテンツ新規同時申込み時契約仕様見直し対応
********************************************************************************/
package eo.ejb.cbs.mainproc;

import java.net.HttpURLConnection;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;


import com.fasterxml.jackson.databind.JsonNode;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.common.JCMAPLConstMgr;
import com.fujitsu.futurity.model.ejb.common.JSYejbLog;
import com.fujitsu.futurity.model.ejb.common.StatusCodes;
import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext;
import com.fujitsu.futurity.model.ejb.common.fw.TemplateMainHandler;

import eo.common.constant.JCNStrConst;
import eo.common.util.JCNStringUtil;
import eo.common.util.JKKStringUtil;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg1List;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg2List;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg3List;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg4List;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg5List;
import eo.ejb.cbs.cbsmsg.ECNA0260001CBSMsg6List;
import eo.ejb.common.JCNCtrlCcmgConnectInfoImpl;

/**
 * コンテンツ即時契約独自処理部品です。
 * <br>
 * @author FJ
 *
 */
public class JECNA0260001TPMA implements TemplateMainHandler
{	

	/** エラーフラグ(EA：設定値取得エラー) */
	private static final String EA_ERR_FLAG = "EA";
	/** エラーフラグ(EB：応答コードエラー) */
	private static final String EB_ERR_FLAG = "EB";
	/** エラーフラグ(EC：実行時エラー) */
	private static final String EC_ERR_FLAG = "EC";
	/** モード取得用キー */
	private static final String CCMG_MODE_KEY = "CCMG_CNIFE058_CONNECTION_MODE";
	/** 接続モード **/
	private static final String CCMG_CONTENTS_SOKUJI_KEI_CONNECTION_MODE  = "CCMG_CNIFE058_CONNECTION_MODE";
	/** 接続URL */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_URL  = "CCMG_CNIFE058_URL";
	/** 接続APIID */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_NM  = "CNIFE058";
	/** 接続メソッド */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_METHOD  = "CCMG_CNIFE058_METHOD";
	/** タイムアウト時間 */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_TIMEOUT  = "CCMG_CNIFE058_TIMEOUT";
	/** リトライカウント */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_RETRYCOUNT  = "CCMG_CNIFE058_RETRYCOUNT";
	/** リトライインターバル */
	private static final String CCMG_CONTENTS_SOKUJI_KEI_RETRYINTERVAL  = "CCMG_CNIFE058_RETRYINTERVAL";
	/** HTTPステータス（正常） */
	private static final String HTTP_STAT_201  = "201";
	/** CCMG_接続モード:0：本番 */
	private static final String CCMG_REQUEST_TEST_MODE_OFF = "0";
	/** CCMG実行結果 HTTPStatus */
	public static final String EXE_STATUS = "httpStatus";
	/** エラーコード */
	private static final String ERR_CD = "err_cd";
	/** 応答コードOK */
	private static final String CODE_OK = "00000";
	/** ダミーURL */
	private static final String DUMMY_URL = "DUMMY";

	/** API送信 項目名 */
	private static final String[][] CNIFE058_REQ_INFO = new String[][]{
		  {"sysid",							ECNA0260001CBSMsg.KEY_SYSID}				// SYSID
		, {"service_id",					ECNA0260001CBSMsg.KEY_SERVICE_ID}			// コンテンツサービスID
		, {"contents",						ECNA0260001CBSMsg.ECNA0260001CBSMSG1LIST}	// コンテンツ配列
		, {"operation_id",					ECNA0260001CBSMsg.KEY_OPERATION_ID}			// 処理番号
		, {"settlement_way_no",				ECNA0260001CBSMsg.KEY_SETTLEMENT_WAY_NO}	// 決済方法番号
		, {"credit_id",						ECNA0260001CBSMsg.KEY_CREDIT_ID}			// クレジットカードID
		, {"application_channel",			ECNA0260001CBSMsg.KEY_APPLICATION_CHANNEL}	// 申込チャネル
// ANK-4570-00-00 ADD START
		, {"application_date",				ECNA0260001CBSMsg.KEY_APPLICATION_DATE}		// 申込日時
// ANK-4570-00-00 ADD END
	};
	
	/** API受信 項目名 */
	private static final String[][] CNIFE058_RES_INFO = new String[][]{
		  {ERR_CD,							ECNA0260001CBSMsg.ERR_CD}					// エラーコード
		, {"contracts",						ECNA0260001CBSMsg.ECNA0260001CBSMSG3LIST}	// コンテンツ契約情報配列
	};
	/** API受信 項目名(コンテンツ契約情報配列) */
	private static final String[][] CNIFE058_RES_LIST3_INFO = new String[][]{
		  {"service_id",				ECNA0260001CBSMsg3List.SERVICE_ID}	// コンテンツサービスID
		, {"contract_no",				ECNA0260001CBSMsg3List.CONTRACT_NO}	// 契約番号
		, {"contents_id",				ECNA0260001CBSMsg3List.CONTENTS_ID}	// コンテンツID
		, {"contents_name",				ECNA0260001CBSMsg3List.CONTENTS_NAME}	// コンテンツ名称
		, {"contract_start_date",		ECNA0260001CBSMsg3List.CONTRACT_START_DATE}	// 契約開始日時
		, {"contract_end_date",			ECNA0260001CBSMsg3List.CONTRACT_END_DATE}	// 契約終了日時
		, {"contract",					ECNA0260001CBSMsg3List.ECNA0260001CBSMSG4LIST}	// コンテンツ契約情報
		, {"charge",					ECNA0260001CBSMsg3List.ECNA0260001CBSMSG5LIST}	// 直近課金情報
		, {"contract_adds",				ECNA0260001CBSMsg3List.ECNA0260001CBSMSG6LIST}	// 契約付加情報
	};

	/** API受信 項目名(コンテンツ契約情報配列) */
	private static final String[][] CNIFE058_RES_LIST4_INFO = new String[][]{
		  {"contract_amount",			ECNA0260001CBSMsg4List.CONTRACT_AMOUNT}		// 契約数量
		, {"uncontinue_flg",			ECNA0260001CBSMsg4List.UNCONTINUE_FLG}		// 非継続フラグ
		, {"contract_class",			ECNA0260001CBSMsg4List.CONTRACT_CLASS}		// 契約種別
		, {"tax_division",				ECNA0260001CBSMsg4List.TAX_DIVISION}			// 税区分
		, {"price_flg",					ECNA0260001CBSMsg4List.PRICE_FLG}			// 料金フラグ

	};
	/** API受信 項目名(直近課金情報配列) */
	private static final String[][] CNIFE058_RES_LIST5_INFO = new String[][]{
		  {"regular_unit_price",			ECNA0260001CBSMsg5List.REGULAR_UNIT_PRICE}		// 単価
		, {"regular_charge_amount",			ECNA0260001CBSMsg5List.REGULAR_CHARGE_AMOUNT}	// 料金
		, {"campaign_text_screen",			ECNA0260001CBSMsg5List.CAMPAIGN_TEXT_SCREEN}	// キャンペーン文言
	};
	/** API受信 項目名(契約付加情報配列) */
	private static final String[][] CNIFE058_RES_LIST6_INFO = new String[][]{
		 {"item_name",						ECNA0260001CBSMsg6List.ITEM_NAME}				// 項目名
		, {"value",							ECNA0260001CBSMsg6List.VALUE}					// 値
	};
	// ST-2024-0000002 ADD START
	/** 正常終了エラーコード */
	private static final String[] NOMAL_END_ERR_CD  = {"00000",""};
	// ST-2024-0000002 ADD END
	
	/**
	 * コンテンツ即時契約を行います。
	 * 
	 * @param inCBSMsg コンテンツ即時契約メッセージ
	 * @param inContext AgentDispatchContext
	 */
	@SuppressWarnings("unchecked")
	public static void call_CNIFE058(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 開始ログ出力を実施。
		JSYejbLog.println(JSYejbLog.DEBUG, JECNA0260001TPMA.class, "JECNA0260001TPMA#invoke start");
		
		Hashtable<String, Object> response = new Hashtable<String, Object>();
		
		/** 接続先などの判定に使用
		*   OFF： 本番・検証、ON: 開発
		*/
		String mode = JCMAPLConstMgr.getString(CCMG_MODE_KEY);
		// アプリケーションプロパティ設定チェック
		if(isNullBlank(mode))
		{
			// ステータス設定（設定値取得エラー）
			inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.RELATION_ERR);
			inCBSMsg.set(ECNA0260001CBSMsg.KEY_SYSID_ERR, EA_ERR_FLAG);
			inCBSMsg.set(ECNA0260001CBSMsg.ECNA0260001CBSMSG1LIST, new CAANMsg[0]);
			return;
		}
		
		// eo顧客 ⇒ CCMGへの送信先URLを設定
		String strUrl = "";
		
		if (CCMG_REQUEST_TEST_MODE_OFF.equals(mode))
		{
			// 本番・検証：propertiesに設定された値を使用
			strUrl = JCMAPLConstMgr.getString(CCMG_CONTENTS_SOKUJI_KEI_URL);
		}
		else
		{
			// 開発：設定しない
			strUrl = DUMMY_URL;
		}

		// API名称
		String apiName = CCMG_CONTENTS_SOKUJI_KEI_NM;
		// 接続メソッド
		String method = JCMAPLConstMgr.getString(CCMG_CONTENTS_SOKUJI_KEI_METHOD);
		// 接続タイムアウト
		String strConnectTimeout = JCMAPLConstMgr.getString(CCMG_CONTENTS_SOKUJI_KEI_TIMEOUT);
		// リトライ回数
		String strRetryCount = JCMAPLConstMgr.getString(CCMG_CONTENTS_SOKUJI_KEI_RETRYCOUNT);
		// リトライインターバル
		String strRetryInterval = JCMAPLConstMgr.getString(CCMG_CONTENTS_SOKUJI_KEI_RETRYINTERVAL);
		
		// アプリケーションプロパティ設定チェック
		if(isNullBlank(strUrl)
				|| isNullBlank(strConnectTimeout)
				|| isNullBlank(strRetryCount)
				|| isNullBlank(strRetryInterval))
		{
			// ステータス設定（設定値取得エラー）
			inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.RELATION_ERR);
			inCBSMsg.set(ECNA0260001CBSMsg.KEY_SYSID_ERR, EA_ERR_FLAG);
			inCBSMsg.set(ECNA0260001CBSMsg.ECNA0260001CBSMSG1LIST, new CAANMsg[0]);
			return;
		}

		JSYejbLog.println(JSYejbLog.EXECUTION, JECNA0260001TPMA.class , "JECNA0260001TPMA#URL=" + strUrl + apiName);
		
		Hashtable<String, Object> jsonResult = new Hashtable<String, Object>();

		String httpStatus = null;

		try
		{
			/*
			 * 送信パラメータ作成
			 */
			CAANMsg paramMap = requestParamMake(inCBSMsg, apiName, mode, strUrl, method, strConnectTimeout, strRetryCount, strRetryInterval);
			JSYejbLog.println(JSYejbLog.EXECUTION, JECNA0260001TPMA.class , "JECNA0260001TPMA#request postParameter=" + paramMap);
			
			// コマンド発行部品のインスタンスを取得
			response = new JCNCtrlCcmgConnectInfoImpl().ctrlCcmgConnect(paramMap);
			
			// 接続結果
			Map<String, Object> connectResult = (Map<String, Object>) response.get(JCNCtrlCcmgConnectInfoImpl.CONNECTRESULT);
			// レスポンス情報
			Map<String, Object> resInfo = (Map<String, Object>) response.get(JCNCtrlCcmgConnectInfoImpl.RESINFO);
			JsonNode resBodyNode = (JsonNode)resInfo.get(JCNCtrlCcmgConnectInfoImpl.RESINFO_BODY);
			jsonResult = read(resBodyNode);

			// HTTPステータス
			httpStatus = JKKStringUtil.nullToBlank((String) connectResult.get("httpStatus"));
			// ST-2024-0000002 ADD START
			
			//String errCd = resBodyNode.get(ERR_CD).asText();

			String errCd = "";
			// エラーコード
			if(jsonResult.get(ECNA0260001CBSMsg.ERR_CD) != null)
			{
				errCd = (String) jsonResult.get(ECNA0260001CBSMsg.ERR_CD);
			}

			// HTTPステータスが500の場合、接続エラー
			if("500".equals(httpStatus) && "".equals(errCd))
			{
				// ステータス設定（実行時エラー）
				inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.RELATION_ERR);
				inCBSMsg.set(ECNA0260001CBSMsg.ECNA0260001CBSMSG1LIST, new CAANMsg[0]);
				return;
			}
			// ST-2024-0000002 ADD END

			// body情報マッピング
			// 連携実行結果判定
			if(isNormal(response, errCd))
			{
				// ステータス設定（0:正常終了）
				inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.NORMAL_END);
			}
			else
			{
				// ステータス設定（応答コードエラー）
				inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1);
				inCBSMsg.set(ECNA0260001CBSMsg.KEY_SYSID_ERR, EB_ERR_FLAG);
			}
			
		}
		catch (Exception e)
		{
			printErrorLog(e);
			// ステータス設定（実行時エラー）
			inCBSMsg.set(ECNA0260001CBSMsg.STATUS, StatusCodes.RELATION_ERR);
			inCBSMsg.set(ECNA0260001CBSMsg.KEY_SYSID_ERR, EC_ERR_FLAG);
			inCBSMsg.set(ECNA0260001CBSMsg.ECNA0260001CBSMSG1LIST, new CAANMsg[0]);
			return;
		}
		
		// JSONレスポンス
		editOutMsg(inCBSMsg, jsonResult, httpStatus);
		
		// 終了ログ出力を実施。
		JSYejbLog.println(JSYejbLog.DEBUG, JECNA0260001TPMA.class, "JECNA0260001TPMA#call_CNIFE058 end");

	}

	/**
	 * コンテンツメール情報取得APIに対して送信するリクエストパラメータを作成する。
	 * @param inCBSMsg CAANメッセージ
	 * @param apiId APIID
	 * @param mode 処理区分
	 * @param strUrl URL
	 * @param method メソッド
	 * @param strConnectTimeout コネクションタイムアウト
	 * @param strRetryCount リトライ回数
	 * @param strRetryInterval リトライインターバル
	 * @return リクエストパラメータを返却する。
	 */
	private static CAANMsg requestParamMake(CAANMsg inCBSMsg, String apiId, String mode, String strUrl, String method,
						String strConnectTimeout, String strRetryCount, String strRetryInterval)
	{
		// リクエストパラメータ作成
		CAANMsg paramMap = new CAANMsg();
		
		// リクエストパラメータヘッダー部作成
		Map<String, Object> paramConnectinfo = new HashMap<String, Object>();
		
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_CONNECTMODE, mode);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_URL, strUrl);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_APIID, apiId);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_CONNECTMETHOD, method);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_TIMEOUT, strConnectTimeout);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_RETRYCOUNT, strRetryCount);
		paramConnectinfo.put(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO_RETRYINTERVAL, strRetryInterval);
		
		// リクエストパラメータボディ部作成
		Map<String, Object> paramReqInfo = new HashMap<String, Object>();
		Map<String, Object> paramBody = new HashMap<String, Object>();
		ArrayList<HashMap<String, Object>> dataList = new ArrayList<HashMap<String, Object>>();
		HashMap<String, Object> list = new HashMap<String, Object>() ;

		for(String[] item : CNIFE058_REQ_INFO)
		{
			String itemName = item[0];
			String itemValue = inCBSMsg.getString(item[1]);

			if ("contents".equals(itemName)) {
				String[] content_info_list = itemValue.split(",", -1);
				list.put(content_info_list[0], JCNStringUtil.nullToBlank(content_info_list[1]));
// ANK-4570-00-00 ADD START
				if (content_info_list.length > 3)
				{
					list.put(content_info_list[2], JCNStringUtil.nullToBlank(content_info_list[3]));
				}
// ANK-4570-00-00 ADD END
				dataList.add(list);
				paramBody.put(itemName, objNullToBlank(dataList));
			}
			else if( !isNullBlank(itemValue) )
			{
				paramBody.put(itemName, itemValue);
			}
		}

		paramReqInfo.put(JCNCtrlCcmgConnectInfoImpl.REQINFO_BODY, paramBody);
		
		// ------------------------------------
		// リストをデータマップに設定する
		// ------------------------------------
		paramMap.setPrivate(JCNCtrlCcmgConnectInfoImpl.CONNECTINFO, paramConnectinfo);
		paramMap.setPrivate(JCNCtrlCcmgConnectInfoImpl.REQINFO, paramReqInfo);
		
		return paramMap;
	}

	/**
	 * 電文読み込み処理
	 * @param jsonResponse
	 * @return json電文解析結果
	 */
	private static Hashtable<String, Object> read(JsonNode jsonResponse) 
	{
		if(jsonResponse == null)
		{
			return null;
		}
		Hashtable<String, Object> result = analyzeJson(jsonResponse);

		return result;
	}
	
	/**
	 * コマンド送信戻り電文解析処理
	 * @param elem コマンド解析電文rootjson要素
	 * @param rootflag ルートフラグ
	 * @return json解析結果
	 */
	private static Hashtable<String, Object> analyzeJson(JsonNode elem)
	{
		
		Hashtable<String, Object> resultMap = new Hashtable<String, Object>();
		
		Iterator<Map.Entry<String, JsonNode>> fields = elem.fields();
		while(fields.hasNext())
		{
			Map.Entry<String, JsonNode> field = fields.next();
			
			String fieldName = field.getKey();
			JsonNode fieldValue = field.getValue();
			
			// Arrayの場合
			if(fieldValue.isArray())
			{
				ArrayList<Map<String, Object>> Bodynodelist = new ArrayList<Map<String, Object>>();
				Iterator<JsonNode> itr = fieldValue.elements();
				while(itr.hasNext())
				{
					JsonNode node = itr.next();
					Hashtable<String, Object> resultinfo = analyzeJson(node);
					if(resultinfo != null && !resultinfo.isEmpty())
					{
						Bodynodelist.add(resultinfo);
					}
				}
				
				resultMap.put( fieldName, Bodynodelist);
			}
			// 子要素を持つ場合は再帰処理
			else if( fieldValue.isObject() )
			{
				resultMap.put(fieldName, analyzeJson(fieldValue) );
			}
			// 以外は値を設定
			else
			{
				resultMap.put(fieldName, fieldValue.asText());
			}
		}
		return resultMap;
	}

	/**
	 * エラーログ出力
	 * @param e 発生した例外
	 * @param params 指示書パラメータ(1〜50)
	 * @param errTitle エラータイトル
	 * @param sjishoNo 指示書番号
	 * @param sjishoNaiyoSeq 指示書内容枝番
	 */
	static private void printErrorLog(Exception e)
	{
		StringBuffer sb = new StringBuffer();
		sb.append(e.getMessage()+ "\n");
		sb.append(e.getClass().getName()+ "\n");
		StackTraceElement[] steAll = e.getStackTrace();
		for (StackTraceElement ste : steAll) {
			sb.append("	at " + ste.getClassName() + "." + ste.getMethodName() + "(" + ste.getFileName() + ":" + ste.getLineNumber()+")"+ "\n");
		}
		JSYejbLog.println(JSYejbLog.ERROR, JECNA0170001TPMA.class, sb.toString());
	}
	
	/**
	 * null又は空文字の場合、trueを返却する
	 * 
	 * @param str 検査対象文字列
	 * @return true:null、又は空文字／false:左記以外
	 */
	public static boolean isNullBlank(String str)
	{
		if (str == null || "".equals(str))
		{
			return true;
		}
		return false;
	}
	/**
	 * 連携実行結果判定
	 */
	private static boolean isNormal(Map<String, Object> response, String errCd) 
	{
		if(response==null)
		{
			return false;
		}
		
		Map<String, Object> connectResult = (HashMap<String, Object>)response.get(JCNCtrlCcmgConnectInfoImpl.CONNECTRESULT);
		// HTTPステータスを取得
		String httpStat = (String) connectResult.get(JCNCtrlCcmgConnectInfoImpl.CONNECTRESULT_HTTPSTATUS);
		
		// HTTPステータスをログ出力
		JSYejbLog.println(JSYejbLog.EXECUTION, JECNA0260001TPMA.class, "JECNA0260001TPMA#http_status=" + httpStat );
		
		// HTTPステータス確認
		// ST-2024-0000002 MOD START
//		if( !HTTP_STAT_201.equals(httpStat) )
		// HTTPステータスが200番台ではない場合
		if(!httpStat.startsWith("2") )
		// ST-2024-0000002 MOD END
		{
			return false;
		}
		
		Map<String, Object> resInfo = (Map<String, Object>)response.get(JCNCtrlCcmgConnectInfoImpl.RESINFO);
		JsonNode body = (JsonNode)resInfo.get(JCNCtrlCcmgConnectInfoImpl.RESINFO_BODY);
		
		//String errCd = body.get(ERR_CD).asText();
		
		// エラーコードがbody部にあるので確認
		// ST-2024-0000002 MOD START
//		// 応答コード（00000:正常）の確認
//		if (!CODE_OK.equals(errCd))
		// 応答コード（"00000","","53001","99070"）の確認
		if(!Arrays.asList(NOMAL_END_ERR_CD).contains(errCd))
		// ST-2024-0000002 MOD END
		{
			return false;
		}
		
		// ここまで来たら正常終了
		return true;
	}

	
	/**
	 * レスポンス電文を設定します。
	 */
	private static void editOutMsg(CAANMsg inCBSMsg, Hashtable<String, Object> response, String httpStat)
	{
		if (response != null)
		{
			for( String[] item : CNIFE058_RES_INFO )
			{
				String itemName = item[1];
				Object itemValue = response.get(item[0]);
				
				if(itemValue == null)
				{
					inCBSMsg.setNull(itemName);
				}
				else if(itemName.equals(ECNA0260001CBSMsg.ECNA0260001CBSMSG3LIST) )
				{
					List<CAANMsg> msg1List = new ArrayList<CAANMsg>();
					
					List<Map<String, Object>> list1 = (List<Map<String, Object>>) itemValue;
					
					for( Map<String, Object> record1 : list1)
					{
						CAANMsg msg1 = new CAANMsg(ECNA0260001CBSMsg3List.class.getName());
						
						for( String[] item1 : CNIFE058_RES_LIST3_INFO )
						{
							String itemName1 = item1[1];
							Object itemValue1 = record1.get(item1[0]);

							if(itemValue1 == null || "null".equals(itemValue1) || "".equals(itemValue1))
							{
								msg1.setNull(itemName);
							}
							else if(itemName1.equals(ECNA0260001CBSMsg3List.ECNA0260001CBSMSG4LIST) )
							{
								List<CAANMsg> msg2List = new ArrayList<CAANMsg>();
								
								List<Map<String, Object>> list2 = (List<Map<String, Object>>) itemValue1;
								for( Map<String, Object> record2 : list2)
								{
									CAANMsg msg2 = new CAANMsg(ECNA0260001CBSMsg4List.class.getName());
									
									for( String[] item2 : CNIFE058_RES_LIST4_INFO )
									{
										String itemName2 = item2[1];
										Object itemValue2 = record2.get(item2[0]);
										msg2.set(itemName2, (String) itemValue2);
									}
									msg2List.add(msg2);
								}
								
								msg1.set(itemName1, msg2List.toArray(new CAANMsg[msg2List.size()]));

							} 
							else if(itemName1.equals(ECNA0260001CBSMsg3List.ECNA0260001CBSMSG5LIST) )
							{
								List<CAANMsg> msg3List = new ArrayList<CAANMsg>();
								
								List<Map<String, Object>> list3 = (List<Map<String, Object>>) itemValue1;
								for( Map<String, Object> record3 : list3)
								{
									CAANMsg msg3 = new CAANMsg(ECNA0260001CBSMsg5List.class.getName());
									
									for( String[] item3 : CNIFE058_RES_LIST5_INFO )
									{
										String itemName3 = item3[1];
										Object itemValue3 = record3.get(item3[0]);
										msg3.set(itemName3, (String) itemValue3);
									}
									msg3List.add(msg3);
								}
								
								msg1.set(itemName1, msg3List.toArray(new CAANMsg[msg3List.size()]));
							} 
							else if(itemName1.equals(ECNA0260001CBSMsg3List.ECNA0260001CBSMSG6LIST) )
							{
								List<CAANMsg> msg4List = new ArrayList<CAANMsg>();
								
								List<Map<String, Object>> list4 = (List<Map<String, Object>>) itemValue1;
								for( Map<String, Object> record4 : list4)
								{
									CAANMsg msg4 = new CAANMsg(ECNA0260001CBSMsg6List.class.getName());
									
									for( String[] item4 : CNIFE058_RES_LIST6_INFO )
									{
										String itemName4 = item4[1];
										Object itemValue4 = record4.get(item4[0]);
										msg4.set(itemName4, (String) itemValue4);
									}
									msg4List.add(msg4);
								}
								
								msg1.set(itemName1, msg4List.toArray(new CAANMsg[msg4List.size()]));
							}
							else
							{
								msg1.set(itemName1, itemValue1);
							}
						}
						msg1List.add(msg1);
					}
					
					inCBSMsg.set(itemName, msg1List.toArray(new CAANMsg[msg1List.size()]));
				}
				else
				{
					inCBSMsg.set(itemName, itemValue);
				}
			}
		}
	}

	/**
	 * 引数で受け取った値がNULLの場合、空を設定し返却する。
	 * <br>
	 * @param Object 
	 */
	private static Object objNullToBlank(Object obj)
	{
		if(obj == null)
		{
			return JCNStrConst.S_BLANK;
		}
		return obj;
	}
}