/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKBbssRsMskmReq
*	ソースファイル名	：JBSbatKKBbssRsMskmReq.java
*	作成者				：富士通　
*	作成日				：2017年04月18日
*＜機能概要＞
*　ＢＢＳＳライセンス申込依頼部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v32.00.00	2017/04/18  FJ)原田		【ANK-3149-00-00】新セキュリティパック
*	v32.00.01	2017/05/08  FJ)二村		【ANK-3149-02-00】CMP画面URLの通知メール送信
*	v32.00.02	2017/06/02  FJ)原田		【ST-2017-0000009】新セキュリティーパック案件の外部接続時におけるシステムエラー対応
*	v71.00.00	2024/03/07	GDC)ml.alcantara	【ANK-4468-00-00】eo光ネット「シンプルプラン」追加対応
*   v71.00.01   2024/07/29  FJ)張       【 ANK-4468-00-01】eo光ネット「シンプルプラン」追加対応
*********************************************************************/
package eo.business.service;

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

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.table.JBSbatKK_T_OPSVKEI_ISP;
import eo.business.util.table.JBSbatCK_T_RRKS;
import eo.business.util.table.JBSbatKK_T_TAJGS_KEI_IDT;
import eo.business.util.table.JBSbatCK_T_CUST;
import eo.business.util.table.JBSbatCC_M_MAIL;
import eo.common.util.JKKCtrlBbssInfo;
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 JBSbatKKBbssRsMskmReq extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** 処理日付格納用（YYYYMMDD） */
	private String sysDate = null;
	
	/** 他事業者契約異動通知結果コード（エラー） */
	private String TAJGS_KEI_IDT_RSLT_CD_ERR = "1";
	
	/** コマンド実行結果（正常） */
	private String CMD_RESULT_CD_OK = "0";
	
	/** テーブルアクセスクラス(他事業者契約異動通知)*/
	private JBSbatSQLAccess db_KK_T_TAJGS_KEI_IDT = null;
	
	/** テーブルアクセスクラス（更新用）(他事業者契約異動通知)*/
	private JBSbatSQLAccess db_upd_KK_T_TAJGS_KEI_IDT = null;
	
	/** テーブルアクセスクラス(オプションサービス契約＜ＩＳＰ＞) */
	private JBSbatSQLAccess db_KK_T_OPSVKEI_ISP = null;
	
	// ANK-3149-02-00 ADD START
	/** テーブルアクセスクラス（メール送信用）(オプションサービス契約＜ＩＳＰ＞)*/
	private JBSbatSQLAccess db_MAIL_SEND_KK_T_OPSVKEI_ISP = null;
	// ANK-3149-02-00 ADD END
	
	// ANK-4468-00-00 ADD START
	/** テーブルアクセスクラス（メール送信用）(連絡先)*/
	private JBSbatSQLAccess db_MAIL_SEND_CK_T_RRKS = null;
	// ANK-4468-00-00 ADD END
	
	/** インターネットサギウォールライセンス申込依頼 */
	private static final String INETSGWL_RS_MSKM_REQ = "0201";
	
	/** ノートンファミリープレミアライセンス申込依頼 */
	private static final String NTFMLPRM_RS_MSKM_REQ = "0211";
	
	/** SQL定義キー(KK_UPDATE_008) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_008 = "KK_UPDATE_008";

	/** SQL定義キー(KK_SELECT_002) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_SELECT_002 = "KK_SELECT_002";
	
	/** SQL定義キー(KK_UPDATE_004) */
	private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_004 = "KK_UPDATE_004";
	
	/** SQL定義キー(KK_UPDATE_029) */
	private static final String KK_T_OPSVKEI_ISP_KK_SELECT_029 = "KK_SELECT_029";
	
	/** SQL定義キー(KK_UPDATE_002) */
	private static final String KK_T_OPSVKEI_ISP_KK_UPDATE_002 = "KK_UPDATE_002";
	
	// ANK-3149-02-00 ADD START
	/** SQL定義キー(KK_SELECT_030) */
	private static final String KK_T_OPSVKEI_ISP_KK_SELECT_030 = "KK_SELECT_030";
	
	// ANK-4468-00-00 ADD START
	/** SQL定義キー(KK_SELECT_013) */
	private static final String CK_T_RRKS_KK_SELECT_013 = "KK_SELECT_013";
	// ANK-4468-00-00 ADD END
	
	/** 送信予定年月日時分秒設定キー */
	private static final String MAIL_SEND_RSV_DTM = "MAIL_SEND_RSV_DTM";

	/** メールの送信パターン(ディレイド) */
	private static final String MAIL_SEND_PATTERN_CD_02 = "02";

	/** メールの送信パターンコード設定キー */
	private static final String MAIL_SEND_PATTERN_CD = "MAIL_SEND_PATTERN_CD";

	/** メールの送信先アドレス設定キー */
	private static final String MLAD_TO = "MLAD_TO";

	/** メールの送信先アドレス表示名設定キー */
	private static final String MLAD_TO_NM = "MLAD_TO_NM";

	/** 本文に埋め込む非定型な置換文字列設定キー*/
	private static final String TEXT_HTK_CKAN_MOJI = "TEXT_HTK_CKAN_MOJI";

	/** メールコード（インターネットサギウォールライセンス申込依頼）*/
	private static final String MAIL_CODE_0201 = "KKM1000016";
	
	/** メールコード（ノートンファミリープレミアライセンス申込依頼）*/
	private static final String MAIL_CODE_0211 = "KKM1000017";
	
	/** ０件（メール情報の登録件数）*/
	private static final int ZERO = 0;
	// ANK-3149-02-00 ADD END
	
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/**
	 * 初期処理
	 * @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);
		db_KK_T_OPSVKEI_ISP = new JBSbatSQLAccess(commonItem, JBSbatKK_T_OPSVKEI_ISP.TABLE_NAME);
		// ANK-3149-02-00 ADD START
		db_MAIL_SEND_KK_T_OPSVKEI_ISP = new JBSbatSQLAccess(commonItem, JBSbatKK_T_OPSVKEI_ISP.TABLE_NAME);
		// ANK-3149-02-00 ADD END
		// ANK-4468-00-00 ADD START
		db_MAIL_SEND_CK_T_RRKS = new JBSbatSQLAccess(commonItem, JBSbatCK_T_RRKS.TABLE_NAME);
		// ANK-4468-00-00 ADD END
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception 各種エクセプション
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		String[] param = null;
		
		// システム日付取得
		sysDate = commonItem.getOpeDate();
		
		// 他事業者契約異動種別コードが
		// "0201"(インターネットサギウォールライセンス申込依頼)または
		// "0211"(ノートンファミリープレミアライセンス申込依頼)の
		// 他事業者契約異動通知状態コードを "0"（未通知） →"3"（処理依頼中）へ更新
		param = new String[]{INETSGWL_RS_MSKM_REQ, NTFMLPRM_RS_MSKM_REQ};
		
		// 他事業者契約異動通知状態コードの更新を実行
		executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_008(param);
		super.commit();
		
		// 送信対象のデータの情報取得
		executeKK_T_TAJGS_KEI_IDT_KK_SELECT_002();
		
		
		JBSbatCommonDBInterface sqlResultMap = new JBSbatCommonDBInterface();
		
		super.logPrint.printDebugLog("********** BBSS申込依頼処理 START **********");
		// 取得できた件数分while文で電文作成→送受信メソッド呼び出し→DB登録を行う
		while((sqlResultMap = db_KK_T_TAJGS_KEI_IDT.selectNext()) != null)
		{
			// 1件ずつデータを取って
			HashMap<String, Object> serviceMap = new HashMap<String, Object>();
			
			// serviceMapに電文の作成に必要なデータを格納
			// 他事業者契約異動通知番号
			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));
			
			// BBSS会員ID
			serviceMap.put("bbssMemberId", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.BBSS_MEMBER_ID));
			
			// オプションサービス契約番号
			serviceMap.put("opSvcKeiNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.OP_SVC_KEI_NO));
			
			// ANK-3149-02-00 ADD START
			// サービス契約番号
			serviceMap.put("svcKeiNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.SVC_KEI_NO));
			// ANK-3149-02-00 ADD END
			
			super.logPrint.printDebugLog("************ 申込依頼対象データ ************");
			super.logPrint.printDebugLog("他事業者契約異動通知番号: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO));
			super.logPrint.printDebugLog("BBSS会員ID: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.BBSS_MEMBER_ID));
			
			// コマンド発行部品のインスタンスを取得
			JKKCtrlBbssInfo instance = JKKCtrlBbssInfo.getInstance();
			
				// BSSS連携処理呼出
				Map<String, Object> ret = instance.call_KKIFE355(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 statusCode = (String)resultinfo.get("statusCode");
					String tajgsKeiIdtRsltCd = analyzeResult(statusCode);
					
					/** 返却された結果を他事業者契約通知テーブルに反映させる */
					// ST-2017-0000009 MOD START
//					param = new String[]{(String)resultinfo.get("userSubscriptionPin")
//										 ,(String)resultinfo.get("subscriptionIds")
//										 ,JCCBatCommon.getSysDateTimeStamp()
//										 ,tajgsKeiIdtRsltCd
//										 ,(String)resultinfo.get("statusCode")
//										 ,(String)serviceMap.get("tajgsKeiIdoNo")
//										 };
					param = new String[]{JKKStringUtil.nullToBlank((String)resultinfo.get("userSubscriptionPin"))
										 ,JKKStringUtil.nullToBlank((String)resultinfo.get("subscriptionIds"))
										 ,JCCBatCommon.getSysDateTimeStamp()
										 ,tajgsKeiIdtRsltCd
										 ,JKKStringUtil.nullToBlank((String)resultinfo.get("statusCode"))
										 ,(String)serviceMap.get("tajgsKeiIdoNo")
										 };
					// ST-2017-0000009 MOD END
					
					executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_004(param);
					
					// ST-2017-0000009 DEL START
//					// オプションサービス契約＜ISP＞に更新する対象のレコードを検索
//					param = new String[]{(String)serviceMap.get("opSvcKeiNo") ,sysDate};
//					executeKK_T_OPSVKEI_ISP_KK_SELECT_029(param);
//					
//					JBSbatCommonDBInterface opSvkeiIspUpdTrgt = db_KK_T_OPSVKEI_ISP.selectNext();
//					HashMap<String, Object> childTrgtList = (HashMap<String, Object>)opSvkeiIspUpdTrgt.getMap();
//					
//					// 返却された結果をオプションサービス契約＜ISP＞テーブルに反映させる
//					// ST-2017-0000009 MOD START
////						param = new String[]{(String)resultinfo.get("userSubscriptionPin")
////											 ,(String)resultinfo.get("subscriptionIds")
//					param = new String[]{JKKStringUtil.nullToBlank((String)resultinfo.get("userSubscriptionPin"))
//										 ,JKKStringUtil.nullToBlank((String)resultinfo.get("subscriptionIds"))
//					// ST-2017-0000009 MOD END
//										 ,(String)childTrgtList.get("OP_SVC_KEI_NO")
//										 ,(String)childTrgtList.get("GENE_ADD_DTM")
//										};
//					executeKK_T_OPSVKEI_ISP_KK_UPDATE_002(param);
					// ST-2017-0000009 DEL END
					
					super.commit();
					
					if(TAJGS_KEI_IDT_RSLT_CD_ERR.equals(tajgsKeiIdtRsltCd))
					{
						super.logPrint.printDebugLog("BBSS申込依頼処理にて返却値のエラーが発生しています。");
						
						StringBuilder msg = new StringBuilder();
						
						String errKeyTajgsKeiIdoNo = (String)serviceMap.get("tajgsKeiIdoNo");
						msg.append("他事業者契約異動通知番号[").append(errKeyTajgsKeiIdoNo).append("]")
							// ST-2017-0000009 MOD START
//							.append("トランザクション・コード[").append((String)resultinfo.get("statusCode")).append("]")
//							.append("トランザクション・コード説明[").append((String)resultinfo.get("statusMessage")).append("]")
							.append("トランザクション・コード[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("statusCode"))).append("]")
							.append("トランザクション・コード説明[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("statusMessage"))).append("]")
							// ST-2017-0000009 MOD END
							;
						
						commonItem.getLogPrint().printBusinessErrorLog("EKKB1380AE",  new String[] {msg.toString()});
						
						continue;
					}
					
					// ST-2017-0000009 ADD START
					// オプションサービス契約＜ISP＞に更新する対象のレコードを検索
					param = new String[]{(String)serviceMap.get("opSvcKeiNo") ,sysDate};
					executeKK_T_OPSVKEI_ISP_KK_SELECT_029(param);
					
					JBSbatCommonDBInterface opSvkeiIspUpdTrgt = db_KK_T_OPSVKEI_ISP.selectNext();
					HashMap<String, Object> childTrgtList = (HashMap<String, Object>)opSvkeiIspUpdTrgt.getMap();
					
					// 返却された結果をオプションサービス契約＜ISP＞テーブルに反映させる
					param = new String[]{JKKStringUtil.nullToBlank((String)resultinfo.get("userSubscriptionPin"))
										 ,JKKStringUtil.nullToBlank((String)resultinfo.get("subscriptionIds"))
										 ,(String)childTrgtList.get("OP_SVC_KEI_NO")
										 ,(String)childTrgtList.get("GENE_ADD_DTM")
										};
					executeKK_T_OPSVKEI_ISP_KK_UPDATE_002(param);
					
					super.commit();
					// ST-2017-0000009 ADD END
					
					// ANK-3149-02-00 ADD START
					// インターネットサギウォールダウンロード準備完了通知メールと
					// ノートンファミリープレミアダウンロード準備完了通知メールの送信処理
					mailSendInfoKakno(commonItem, serviceMap);
					
					super.commit();
					// ANK-3149-02-00 ADD END
				}
				else
				{
					super.logPrint.printDebugLog("BBSS申込依頼処理中に通信異常が発生しました。");
					
					// 他事業者契約異動通知スキーマに結果エラーで登録
					param = new String[]{""
										 ,""
										 ,JCCBatCommon.getSysDateTimeStamp()
										 ,TAJGS_KEI_IDT_RSLT_CD_ERR
										 ,""
										 ,(String)serviceMap.get("tajgsKeiIdoNo")
										 };
							
					executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_004(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("********** BBSS申込依頼処理 END **********");
		
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

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

		// DBアクセスを実行します
		db_upd_KK_T_TAJGS_KEI_IDT.executeBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_UPDATE_008);
	}
	
	/**
	 * SQLKEY(KK_SELECT_002)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			"0201"(インターネットサギウォールライセンス申込依頼)
	 *			"0211"(ノートンファミリープレミアライセンス申込依頼)
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_TAJGS_KEI_IDT_KK_SELECT_002() throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();

		// DBアクセスを実行します
		db_KK_T_TAJGS_KEI_IDT.selectBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_SELECT_002);
	}
	
	/**
	 * SQLKEY(KK_UPDATE_004)で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_004(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());
		paramList.setValue(param[4].toString());
		paramList.setValue(param[5].toString());

		// DBアクセスを実行します
		db_upd_KK_T_TAJGS_KEI_IDT.executeBySqlDefine(paramList, KK_T_TAJGS_KEI_IDT_KK_UPDATE_004);
	}
	
	/**
	 * SQLKEY(KK_SELECT_029)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			BBSS会員ID
	 *			システム日付
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_OPSVKEI_ISP_KK_SELECT_029(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_KK_T_OPSVKEI_ISP.selectBySqlDefine(paramList, KK_T_OPSVKEI_ISP_KK_SELECT_029);
	}
	
	/**
	 * SQLKEY(KK_UPDATE_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_OPSVKEI_ISP_KK_UPDATE_002(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_KK_T_OPSVKEI_ISP.executeBySqlDefine(paramList, KK_T_OPSVKEI_ISP_KK_UPDATE_002);
	}
	
	// ANK-3149-02-00 ADD START
	/**
	 * SQLKEY(KK_SELECT_030)で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_OPSVKEI_ISP_KK_SELECT_030(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_MAIL_SEND_KK_T_OPSVKEI_ISP.selectBySqlDefine(paramList, KK_T_OPSVKEI_ISP_KK_SELECT_030);
	}
	
	// ANK-4468-00-00 ADD START
	/**
	 * SQLKEY(KK_SELECT_013)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			システム日付
	 *			システム日付
	 *			サービス契約番号
	 *			システム日付
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCK_T_RRKS_KK_SELECT_013(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		//ANK-4468-00-01 ADD START
		paramList.setValue(param[3].toString());
		//ANK-4468-00-01 ADD START
		
		// DBアクセスを実行します
		db_MAIL_SEND_CK_T_RRKS.selectBySqlDefine(paramList, CK_T_RRKS_KK_SELECT_013);
	}
	// ANK-4468-00-00 ADD END
	
	/**
	 * メール送信情報格納処理です。<br>
	 * <p>
	 * @param commonItem バッチ共通電文
	 * @param map パラメータ情報格納
	 * @throws Exception 業務サービス内で発生した例外全般
	 * @throws IOException 
	 */	
	private void mailSendInfoKakno(JBSbatCommonItem commonItem, HashMap<String, Object> map) throws Exception
	{
		// サービス契約番号を取得
		String svcKeiNo = (String)map.get("svcKeiNo");
		
		String[] param = new String[]{svcKeiNo
				,sysDate
				,sysDate
				,sysDate
		};
		
		// DBアクセス実行
		executeKK_T_OPSVKEI_ISP_KK_SELECT_030(param);
		// 結果取得用Map初期化
		JBSbatCommonDBInterface sqlResultMap = new JBSbatCommonDBInterface();
		
		// ANK-4468-00-00 ADD START
		String[] param2 = new String[]{sysDate
				,sysDate
				,svcKeiNo
	    // ANK-4468-00-01 ADD START
				,sysDate
		// ANK-4468-00-01 ADD END
		};
		// DBアクセス実行
		executeCK_T_RRKS_KK_SELECT_013(param2);
		// 結果取得用Map初期化
		JBSbatCommonDBInterface sqlResultMap2 = new JBSbatCommonDBInterface();
		// データ追加済メールアドレスハッシュマップ初期化
		HashSet<String> addedMail = new HashSet<String>();
		// ANK-4468-00-00 ADD END
		
		// メール情報の登録の件数をカウントする
		int mailCnt = 0;
		
		// 取得できた件数分、メール送信共通部品呼び出し→DB登録を行う
		while((sqlResultMap = db_MAIL_SEND_KK_T_OPSVKEI_ISP.selectNext()) != null)
		{
			mailCnt ++;
			
			// 取得項目の必須チェック
			boolean result = isSingleCheckKK_T_OPSVKEI_ISP_KK_SELECT_030(sqlResultMap, svcKeiNo);
			
			// 必須チェックエラーの場合、エラーとして処理をスキップする。
			if(result  ==  false)
			{
				super.commonItem.setErrFlg(true);	// 処理をスキップ
				continue;
			}
			
			// メール送信情報格納Map
			HashMap<String, Object> infoMap = new HashMap<String, Object>();
			
			// 変数初期化
			String sysDateTime = null;	// 処理日時分秒を取得
			String[] htk_cakn_moji = new String[1];		// メール本文非定型文字格納
			String[] mail_to = new String[1];			// メール送信先アドレス
			String[] mail_toNm = new String[1];			// メール送信先アドレス表示名
			
			// 処理日時分秒を取得
			sysDateTime = JCCBatCommon.getSysDateTimeStamp();
			
			// メールアドレス取得
			String mlad = sqlResultMap.getString(JBSbatKK_T_OPSVKEI_ISP.MLAD);
			// お客様名取得
			String custNm = sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM);
			
			// 送信予定年月日時分秒の設定
			infoMap.put(MAIL_SEND_RSV_DTM, sysDateTime);
			
			// メール送信パターンの設定
			infoMap.put(MAIL_SEND_PATTERN_CD, MAIL_SEND_PATTERN_CD_02);
			
			// メールコードの設定
			if(INETSGWL_RS_MSKM_REQ.equals(map.get("tajgsKeiIdoSbtCd")))
			{
				// インターネットサギウォールライセンス申込依頼
				infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0201);
			}
			else if(NTFMLPRM_RS_MSKM_REQ.equals(map.get("tajgsKeiIdoSbtCd")))
			{
				// ノートンファミリープレミアライセンス申込依頼
				infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0211);
			}
			
			// メール送信先アドレス（TO）の設定。
			mail_to[0] = mlad;
			infoMap.put(MLAD_TO, mail_to);
			
			// メール送信先アドレス表示名（TO）の設定。＜お客様名＞
			mail_toNm[0] = custNm;
			infoMap.put(MLAD_TO_NM, mail_toNm);
			
			// 置換文字列_メール本文非定型部１の設定。（お客様名）
			htk_cakn_moji[0] = custNm;
			infoMap.put(TEXT_HTK_CKAN_MOJI, htk_cakn_moji);
			
			mailSendExecute(commonItem, infoMap);
			// ANK-4468-00-00 ADD START
			// ハッシュセットにデータ追加済メールアドレスを追加
			addedMail.add(mlad);
			// ANK-4468-00-00 ADD END
		}
		
		// ANK-4468-00-00 ADD START
		// 取得できた件数分、メール送信共通部品呼び出し→DB登録を行う
		while((sqlResultMap2 = db_MAIL_SEND_CK_T_RRKS.selectNext()) != null)
		{	
			// 取得項目の必須チェック
			boolean result = isSingleCheckCK_T_RRKS_KK_SELECT_013(sqlResultMap2, svcKeiNo);
			
			// 必須チェックエラーの場合、エラーとして処理をスキップする。
			if(result  ==  false)
			{
				super.commonItem.setErrFlg(true);	// 処理をスキップ
				continue;
			}
			
			// メール送信情報格納Map
			HashMap<String, Object> infoMap = new HashMap<String, Object>();
			
			// 変数初期化
			String sysDateTime = null;	// 処理日時分秒を取得
			String[] htk_cakn_moji = new String[1];		// メール本文非定型文字格納
			String[] mail_to = new String[1];			// メール送信先アドレス
			String[] mail_toNm = new String[1];			// メール送信先アドレス表示名
			
			// 処理日時分秒を取得
			sysDateTime = JCCBatCommon.getSysDateTimeStamp();
			
			// メールアドレス取得
			String mlad = sqlResultMap2.getString(JBSbatCK_T_RRKS.MLAD);
			// お客様名取得
			String custNm = sqlResultMap2.getString(JBSbatCK_T_CUST.CUST_NM);
			
			// 連絡先.メールアドレスが�@で取得したオプションサービス契約_ISP.メールアドレスと同一の場合、支払変更登録完了お知らせメール向けリストに出力しない
			if (!addedMail.contains(mlad))
			{
				mailCnt ++;
				
				// 送信予定年月日時分秒の設定
				infoMap.put(MAIL_SEND_RSV_DTM, sysDateTime);
				
				// メール送信パターンの設定
				infoMap.put(MAIL_SEND_PATTERN_CD, MAIL_SEND_PATTERN_CD_02);
				
				// メールコードの設定
				if(INETSGWL_RS_MSKM_REQ.equals(map.get("tajgsKeiIdoSbtCd")))
				{
					// インターネットサギウォールライセンス申込依頼
					infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0201);
				}
				else if(NTFMLPRM_RS_MSKM_REQ.equals(map.get("tajgsKeiIdoSbtCd")))
				{
					// ノートンファミリープレミアライセンス申込依頼
					infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0211);
				}
				
				// メール送信先アドレス（TO）の設定。
				mail_to[0] = mlad;
				infoMap.put(MLAD_TO, mail_to);
				
				// メール送信先アドレス表示名（TO）の設定。＜お客様名＞
				mail_toNm[0] = custNm;
				infoMap.put(MLAD_TO_NM, mail_toNm);
				
				// 置換文字列_メール本文非定型部１の設定。（お客様名）
				htk_cakn_moji[0] = custNm;
				infoMap.put(TEXT_HTK_CKAN_MOJI, htk_cakn_moji);
				
				mailSendExecute(commonItem, infoMap);
			}
		}
		// ANK-4468-00-00 ADD END
		
		if(ZERO == mailCnt)
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0290AW",
					new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールオプション"});
			
			super.commonItem.setErrFlg(true);
		}
	}
	
	/**
	 *入力情報の単項目チェック<br>
	 * <p>
	 * @param sqlResultMap 入力データ（TXT又はDB）を格納されたMap
	 * @param svcKeiNo サービス契約番号
	 * @throws Exception 業務サービス内で発生した例外全般
	 * @return  boolean trueである場合、エラーがありません。falseである場合、エラー。
	 */
	private boolean isSingleCheckKK_T_OPSVKEI_ISP_KK_SELECT_030(JBSbatCommonDBInterface sqlResultMap, String svcKeiNo) throws Exception
	{
		// お客さま名の必須チェック
		if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM)))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW",
					new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくお客様名"});
			return false;
		}
		
		// メールアドレスの必須チェック
		if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatKK_T_OPSVKEI_ISP.MLAD)))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", 
					new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールアドレス"});
			return false;
		}
		return true;
	}
	
	// ANK-4468-00-00 ADD START
	/**
	 *入力情報の単項目チェック<br>
	 * <p>
	 * @param sqlResultMap 入力データ（TXT又はDB）を格納されたMap
	 * @param svcKeiNo サービス契約番号
	 * @throws Exception 業務サービス内で発生した例外全般
	 * @return  boolean trueである場合、エラーがありません。falseである場合、エラー。
	 */
	private boolean isSingleCheckCK_T_RRKS_KK_SELECT_013(JBSbatCommonDBInterface sqlResultMap, String svcKeiNo) throws Exception
	{
		// お客さま名の必須チェック
		if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM)))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW",
					new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくお客様名"});
			return false;
		}
		
		// メールアドレスの必須チェック
		if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_RRKS.MLAD)))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", 
					new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールアドレス"});
			return false;
		}
		return true;
	}
	// ANK-4468-00-00 ADD END
	
	/**
	 * メール送信情報格納処理です。<br>
	 * <p>
	 * @param commonItem バッチ共通電文
	 * @param map パラメータ情報格納
	 * @return HashMap map 採番部品で発行した採番値をセットしたHashMap。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 * @throws IOException 
	 */	
	private HashMap<String, Object> mailSendExecute(JBSbatCommonItem commonItem, HashMap<String, Object> map) throws Exception
	{
		// メール送信情報格納処理を呼び出します。
		HashMap<String, Object> result_map = JCCBatCommon.insertTMailSend(commonItem, map);
		
		return result_map;
	}
	// ANK-3149-02-00 ADD END
	
}