/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKDelJdgWkSeikySysidChk
*	ソースファイル名	：JBSbatKKDelJdgWkSeikySysidChk.java
*	作成者				：富士通　
*	作成日				：2013年04月07日
*＜機能概要＞
*　請求契約・ＳＹＳＩＤ対象外チェック部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2013/04/07   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;
import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatKKIFM445;
import eo.business.util.file.JBSbatKKIFM447;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.util.JBSbatCheckUtil;
import eo.framework.util.JBSbatDateUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKDelJdgWkSeikySysidChk extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(個人情報削除判定ワーク)*/
	private static final String D_TBL_NAME_KK_T_KJNIFDEL_JDG_WK = "KK_T_KJNIFDEL_JDG_WK";

	/** テーブル(課金先)*/
	private static final String D_TBL_NAME_KK_T_KAKINS = "KK_T_KAKINS";

	/** テーブル(サービス契約)*/
	private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";

	/** SQL定義キー(KK_SELECT_008)*/
	private static final String KK_T_KJNIFDEL_JDG_WK_KK_SELECT_008 = "KK_SELECT_008";

	/** SQL定義キー(KK_SELECT_009)*/
	private static final String KK_T_KJNIFDEL_JDG_WK_KK_SELECT_009 = "KK_SELECT_009";

	/** SQL定義キー(KK_SELECT_035)*/
	private static final String KK_T_KAKINS_KK_SELECT_035 = "KK_SELECT_035";

	/** SQL定義キー(KK_SELECT_206)*/
	private static final String KK_T_SVC_KEI_KK_SELECT_206 = "KK_SELECT_206";

	/** テーブルアクセスクラス(個人情報削除判定ワーク)*/
	private JBSbatSQLAccess db_KK_T_KJNIFDEL_JDG_WK = null;

	/** テーブルアクセスクラス(課金先)*/
	private JBSbatSQLAccess db_KK_T_KAKINS = null;

	/** テーブルアクセスクラス(サービス契約)*/
	private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** ALL0*/
	private static final String ALL0 = "0000000000";
	
	/** 削除判定コード削除可能 */
	private static final String DEL_OK = "00";
	
	/** カレントコード カレント */
	private static final String CRNT = "1";

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

		// DBアクセスクラスを生成します
		db_KK_T_KJNIFDEL_JDG_WK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KJNIFDEL_JDG_WK);
		db_KK_T_KAKINS = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KAKINS);
		db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		super.logPrint.printDebugLog("execute_START");
		// 出力共通電文を生成する
		JBSbatOutputItem out_item = new JBSbatOutputItem();
		// 入出力インタフェースオブジェクトを生成
		JBSbatServiceInterfaceMap out_map = new JBSbatServiceInterfaceMap();

		String svcKeiNo = inMap.getString(JBSbatKKIFM445.SVC_KEI_NO);
		String seiKeiNo = inMap.getString(JBSbatKKIFM445.SEIKY_KEI_NO);
		String sysId = inMap.getString(JBSbatKKIFM445.SYSID);
		
		if(!DEL_OK.equals(inMap.getString(JBSbatKKIFM445.DEL_JDG_CD))){
			//削除判定コードが"00"ではない場合
			//何もせずにファイル出力
			out_map = outPutFile(svcKeiNo, seiKeiNo, sysId, inMap);
			//出力共通電文に入出力インターフェースを設定する。
			out_item.addOutMapList(out_map);
			return out_item;
		}
		//請求契約番号件数チェック
		seiKeiNo = chkSeikyKeiNoKakins(seiKeiNo);
		//SYSID件数チェック
		sysId = chkSysIdSvcKei(sysId);
		//ファイル出力
		out_map = outPutFile(svcKeiNo, seiKeiNo, sysId, inMap);
		//出力共通電文に入出力インターフェースを設定する。
		out_item.addOutMapList(out_map);
		
		super.logPrint.printDebugLog("execute_END");
		return out_item;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_008)で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_KJNIFDEL_JDG_WK_KK_SELECT_008(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_KK_T_KJNIFDEL_JDG_WK.selectBySqlDefine(paramList, KK_T_KJNIFDEL_JDG_WK_KK_SELECT_008);
	}

	/**
	 * SQLKEY(KK_SELECT_009)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	SYSID
	 *		 	カレントデータ識別コード
	 *		 	削除判定コード
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_KJNIFDEL_JDG_WK_KK_SELECT_009(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_KK_T_KJNIFDEL_JDG_WK.selectBySqlDefine(paramList, KK_T_KJNIFDEL_JDG_WK_KK_SELECT_009);
	}

	/**
	 * SQLKEY(KK_SELECT_035)で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_KAKINS_KK_SELECT_035(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_KK_T_KAKINS.selectBySqlDefine(paramList, KK_T_KAKINS_KK_SELECT_035);
	}

	/**
	 * SQLKEY(KK_SELECT_206)で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_SVC_KEI_KK_SELECT_206(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_206);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * <p>
	 * <dd>メソッド名：請求契約番号課金先件数チェック
	 * <pre>
	 * <dd>メソッド説明：
	 * 
	 * </pre>
	 * <p>
	 * @param prmSeiKeiNo 請求契約番号
	 * @return チェック結果
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String chkSeikyKeiNoKakins(String prmSeiKeiNo) throws Exception
	{
		super.logPrint.printDebugLog("chkSeikyKeiNoKakins START:");
		
		String seiKeiNo = prmSeiKeiNo;
		
		ArrayList<String[]> lstKey = new ArrayList<String[]>();
		
		//請求契約番号がALL0の場合は処理しない
		if(seiKeiNo.compareTo(ALL0) != 0)
		{
			super.logPrint.printDebugLog("seiKeiNo:" + seiKeiNo);
			int intDelWk = 0;
			int intKknWk = 0;
			JBSbatCommonDBInterface map = null;
			Object[] param = {seiKeiNo, CRNT, this.DEL_OK};
			executeKK_T_KJNIFDEL_JDG_WK_KK_SELECT_008(param);
			map = db_KK_T_KJNIFDEL_JDG_WK.selectNext();
			if(map != null)
			{
				intDelWk = Integer.parseInt(map.getString("KK2611_CNT"));
				super.logPrint.printDebugLog("KK2611_CNT:" + intDelWk);
			}
			Object[] param2 = {seiKeiNo, super.opeDate, super.opeDate};
			executeKK_T_KAKINS_KK_SELECT_035(param2);
			map = db_KK_T_KAKINS.selectNext();
			if(map != null)
			{
				intKknWk = Integer.parseInt(map.getString("KK0321_CNT"));
				super.logPrint.printDebugLog("KK0321_CNT:" + intKknWk);
			}
			if(intDelWk < intKknWk)
			{
				//課金先の請求契約番号が多い時、削除データの請求契約番号を初期化
				seiKeiNo = ALL0;
			}
		}
		super.logPrint.printDebugLog("chkSeikyKeiNoKakins END:");
		return seiKeiNo;
	}

	/**
	 * <p>
	 * <dd>メソッド名：SYSIDサービス契約件数チェック
	 * <pre>
	 * <dd>メソッド説明：
	 * 
	 * </pre>
	 * <p>
	 * @param prmSysId SYSID
	 * @return チェック結果
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String chkSysIdSvcKei(String prmSysId) throws Exception
	{
		super.logPrint.printDebugLog("chkSysIdSvcKei START:");
		String sysId = prmSysId;
		
		//SYSIDがALL0の場合は処理しない
		if(sysId.compareTo(ALL0) != 0)
		{
			super.logPrint.printDebugLog("sysId:" + sysId);
			int intDelWk = 0;
			int intKknWk = 0;
			JBSbatCommonDBInterface map = null;
			Object[] param = {sysId, CRNT, this.DEL_OK};
			executeKK_T_KJNIFDEL_JDG_WK_KK_SELECT_009(param);
			map = db_KK_T_KJNIFDEL_JDG_WK.selectNext();
			if(map != null)
			{
				intDelWk = Integer.parseInt(map.getString("KK2611_CNT"));
				super.logPrint.printDebugLog("KK2611_CNT:" + intDelWk);
			}
			Object[] param2 = {sysId, super.opeDate};
			executeKK_T_SVC_KEI_KK_SELECT_206(param2);
			map = db_KK_T_SVC_KEI.selectNext();
			if(map != null)
			{
				intKknWk = Integer.parseInt(map.getString("KK0081_CNT"));
				super.logPrint.printDebugLog("KK0081_CNT:" + intKknWk);
			}
			if(intDelWk < intKknWk)
			{
				//サービス契約のSYSIDが多い時、削除データのSYSIDを初期化
				sysId = ALL0;
			}
		}
		super.logPrint.printDebugLog("chkSysIdSvcKei END:");
		return sysId;
	}

	/**
	 * <p>
	 * <dd>メソッド名：ファイル出力
	 * <pre>
	 * <dd>メソッド説明：
	 * 
	 * </pre>
	 * <p>
	 * @param svcKeiNo サービス契約番号	
	 * @param seiKeiNo 請求契約番号	
	 * @param sysId SYSID	
	 * @param inMap 入力ファイル		
	 * @return 
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatServiceInterfaceMap outPutFile(String svcKeiNo,
			String seiKeiNo,
			String sysId,
			JBSbatServiceInterfaceMap inMap) throws Exception
	{
		// 入出力インタフェースオブジェクトを生成
		JBSbatServiceInterfaceMap out_map = new JBSbatServiceInterfaceMap();
		
		// 出力項目を設定する
		// サービス契約番号
		out_map.setString(JBSbatKKIFM447.SVC_KEI_NO, svcKeiNo);
		// 請求契約番号
		out_map.setString(JBSbatKKIFM447.SEIKY_KEI_NO, seiKeiNo);
		// SYSID
		out_map.setString(JBSbatKKIFM447.SYSID, sysId);
		// サービスコード
		out_map.setString(JBSbatKKIFM447.SVC_CD, inMap.getString(JBSbatKKIFM445.SVC_CD));
		// 料金グループコード
		out_map.setString(JBSbatKKIFM447.PRC_GRP_CD, inMap.getString(JBSbatKKIFM445.PRC_GRP_CD));
		// 料金コースコード
		out_map.setString(JBSbatKKIFM447.PCRS_CD, inMap.getString(JBSbatKKIFM445.PCRS_CD));
		// 新規申込時申込書番号
		out_map.setString(JBSbatKKIFM447.NEW_MSKM_JI_MSKMSHO_NO, inMap.getString(JBSbatKKIFM445.NEW_MSKM_JI_MSKMSHO_NO));
		// ＩＳＰ認証ＩＤ
		out_map.setString(JBSbatKKIFM447.ISP_NINSHO_ID, inMap.getString(JBSbatKKIFM445.ISP_NINSHO_ID));
		// サービス解約起算年月日
		out_map.setString(JBSbatKKIFM447.SVC_DSL_KISAN_YMD, inMap.getString(JBSbatKKIFM445.SVC_DSL_KISAN_YMD));
		// サービスキャンセル年月日
		out_map.setString(JBSbatKKIFM447.SVC_CANCEL_YMD, inMap.getString(JBSbatKKIFM445.SVC_CANCEL_YMD));
		// サービス解約年月日
		out_map.setString(JBSbatKKIFM447.SVC_DSL_YMD, inMap.getString(JBSbatKKIFM445.SVC_DSL_YMD));
		// サービス終了年月日
		out_map.setString(JBSbatKKIFM447.SVC_ENDYMD, inMap.getString(JBSbatKKIFM445.SVC_ENDYMD));
		// 削除処理対象抽出年月日
		out_map.setString(JBSbatKKIFM447.DEL_TRN_TG_CHSHT_YMD, inMap.getString(JBSbatKKIFM445.DEL_TRN_TG_CHSHT_YMD));
		// 個人情報削除理由コード
		out_map.setString(JBSbatKKIFM447.KOJIN_INFO_DEL_RSN_CD, inMap.getString(JBSbatKKIFM445.KOJIN_INFO_DEL_RSN_CD));
		// 削除判定コード
		out_map.setString(JBSbatKKIFM447.DEL_JDG_CD, inMap.getString(JBSbatKKIFM445.DEL_JDG_CD));
		// 契約最終更新年月日時分秒
		out_map.setString(JBSbatKKIFM447.KEI_LAST_UPD_DTM, inMap.getString(JBSbatKKIFM445.KEI_LAST_UPD_DTM));
		// カレントデータ識別コード
		out_map.setString(JBSbatKKIFM447.CRNT_DATA_SKBT_CD, inMap.getString(JBSbatKKIFM445.CRNT_DATA_SKBT_CD));
		// 登録年月日時分秒
		out_map.setString(JBSbatKKIFM447.ADD_DTM, JBSbatDateUtil.getSystemDateTime());
		// 登録オペレータアカウント
		out_map.setString(JBSbatKKIFM447.ADD_OPEACNT, super.batchUserId);
		// 更新年月日時分秒
		out_map.setString(JBSbatKKIFM447.UPD_DTM, JBSbatDateUtil.getSystemDateTime());
		// 更新オペレータアカウント
		out_map.setString(JBSbatKKIFM447.UPD_OPEACNT, super.batchUserId);
		// 削除年月日時分秒
		out_map.setString(JBSbatKKIFM447.DEL_DTM, null);
		// 削除オペレータアカウント
		out_map.setString(JBSbatKKIFM447.DEL_OPEACNT, null);
		// 無効フラグ
		out_map.setString(JBSbatKKIFM447.MK_FLG, "0");
		// 登録運用年月日
		out_map.setString(JBSbatKKIFM447.ADD_UNYO_YMD, super.opeDate);
		// 登録処理ＩＤ
		out_map.setString(JBSbatKKIFM447.ADD_TRN_ID, super.jobid);
		// 更新運用年月日
		out_map.setString(JBSbatKKIFM447.UPD_UNYO_YMD, super.opeDate);
		// 更新処理ＩＤ
		out_map.setString(JBSbatKKIFM447.UPD_TRN_ID, super.jobid);
		// 削除運用年月日
		out_map.setString(JBSbatKKIFM447.DEL_UNYO_YMD, null);
		// 削除処理ＩＤ
		out_map.setString(JBSbatKKIFM447.DEL_TRN_ID, null);
		//出力フラグを設定
		out_map.setOutFlg(true);
		
		return out_map;
	}
}