/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCCMmmrAdrChgSecurityPack
*	ソースファイル名	：JBSbatCCMmmrAdrChgSecurityPack.java
*	作成者				：富士通　
*	作成日				：2024年02月29日
*＜機能概要＞
*　見守りSQLを実行し、罹災候補のキー番号を抽出する。抽出結果が0件でなければ、罹災対応済みファイルから取得したキー番号と突合する。
*　突合結果、合致しない行(新規罹災候補)が存在すれば、キー番号をログへ出力し、MNアラームを発砲する。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v70.0.0		2024/02/29   富士通		新規作成
*********************************************************************/
package eo.business.service;


import java.util.ArrayList;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKKBatCommon;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;


/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCCMmmrAdrChgSecurityPack extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(住所変更明細)*/
	private static final String D_TBL_NAME_KK_T_ADCHG_DTL = "KK_T_ADCHG_DTL";

	/** SQL定義キー(CC_SELECT_002)*/
	private static final String KK_T_ADCHG_DTL_KK_SELECT_061 = "KK_SELECT_061";

	/** テーブルアクセスクラス(住所変更明細)*/
	private JBSbatSQLAccess db_KK_T_ADCHG_DTL = null;
	
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/	
	/** 住所変更番号文字長 */
	private static final String ADCHG_NO_LENGTH = "10";
	
	/** 半角数字(半角数字チェック時の変換用文言) */
	private static final String HANKAKU_NUM = "半角数字";
	
	/** 住所変更番号リスト(罹災候補) */
	private List<String> risaikoho_Adchg_No_List = new ArrayList<String>();
	
	/** 罹災候補件数 */
	private static int risaikoho_Cnt = 0;

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_KK_T_ADCHG_DTL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_ADCHG_DTL);
		
		// 見守りSQLを実行
		executeKK_T_ADCHG_DTL_KK_SELECT_061();
		// 結果をリストに格納
		JBSbatCommonDBInterface adchgMap;
		// 罹災候補の住所変更番号が取得できれば、その番号を保持
		while( (adchgMap=db_KK_T_ADCHG_DTL.selectNext()) != null ){
			// 罹災候補の住所変更番号を保持
			risaikoho_Adchg_No_List.add(adchgMap.getString("ADCHG_NO"));
		}
		
		// 罹災候補の件数を保持
		risaikoho_Cnt = risaikoho_Adchg_No_List.size();
		
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 罹災候補がある場合
		if (risaikoho_Cnt > 0) {
			// CCIFM050のレコードが空ではない場合
			if(inMap != null) {
				// CCIFM050の住所変更番号を取得
				String ccifm050_Adchg_No = getCcifm050(inMap);
				
				// 半角数字チェック
				if (!JKKBatCommon.isHannkakuSuuji1(ccifm050_Adchg_No)) {
					// エラーが生じた場合、エラーログを出力し処理を異常終了する。
					throw new JBSbatBusinessException(JPCBatchMessageConstant.ECCB0320CE, new String[]{Integer.toString(commonItem.getInputCount()) + "行目", HANKAKU_NUM});
				}
				// 桁数チェック
				if (!JKKBatCommon.isKetasuu1(ccifm050_Adchg_No, ADCHG_NO_LENGTH)) {
					// エラーが生じた場合、エラーログを出力し処理を異常終了する。
					throw new JBSbatBusinessException(JPCBatchMessageConstant.ECCB0310CE, new String[]{Integer.toString(commonItem.getInputCount()) + "行目", ADCHG_NO_LENGTH});
				}
				
				// 突合
				for (String risaikoho_Adchg_No : risaikoho_Adchg_No_List) {
					// 罹災候補リスト中に、罹災対応済みの住所変更番号がある場合
					if (ccifm050_Adchg_No.equals(risaikoho_Adchg_No)) {
						// 罹災対応済みであれば、罹災候補リストから削除
						risaikoho_Adchg_No_List.remove(risaikoho_Adchg_No_List.indexOf(risaikoho_Adchg_No));
						break;
					}
				}
			}
			// 最終レコードの場合
			if (commonItem.isEndRecordFlg()) {
				/** 罹災候補存在フラグの初期化 */
				boolean is_RisaikohoFlg = false;
				
				// 新規罹災候補がある場合
				for (String risaikoho_Adchg_No : risaikoho_Adchg_No_List) {
					// 罹災候補存在フラグをtrueにする
					is_RisaikohoFlg = true;
					// 罹災候補の住所変更番号をbusログに出力する。
					commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.ECCB0460AW, new String[]{risaikoho_Adchg_No});
				}
				// 罹災候補が存在する場合
				if (is_RisaikohoFlg) {
					// マイナーアラーム発砲の為、エラーフラグをtrueにする。
					commonItem.setErrFlg(true);
				}
				
			}
		}
		// 出力共通電文を空で返却
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		return outputBean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_061)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * </pre>
	 * <p>
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_ADCHG_DTL_KK_SELECT_061() throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		// DBアクセスを実行します
		db_KK_T_ADCHG_DTL.selectBySqlDefine(paramList, KK_T_ADCHG_DTL_KK_SELECT_061);
	}

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

	/**
	 * 
	 * 入力ファイルの読み込み
	 * 
	 * @param inMap 入力ファイルの値
	 * @throws Exception メソッド内で発生した例外全般
	 * @return 住所変更番号
	 */
	private String getCcifm050(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		String adchg_No = inMap.getString("ADCHG_NO");
		return adchg_No;
	}
	
}