/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKKnytcsReissueDataMake
*	ソースファイル名	：JBSbatKKKnytcsReissueDataMake.java
*	作成者				：FJ)柳
*	作成日				：2016年01月12日
*＜機能概要＞
*　契約内容通知書再発行データ作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v23.00.00	2016/01/12  FJ)柳		【ANK-2737-00-00】新規作成
*	v26.00.00	2016/08/18  FJ)原田		【OM-2016-0001880】登録運用年月日の登録方法変更
*	v48.00.01	2020/02/20	FJ)荒木		【ANK-3639-00-00】契約内容通知書の修正可能項目追加
*********************************************************************/
package eo.business.service;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatDenshiFileUtil;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.common.constant.JKKStrConst;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatInputFileUtil;

/**
* データ一括登録画面にて登録されたファイルを元に、
* 契約内容通知書の再送信が可能となるよう
* 契約内容通知書データのコピー作成を行う。 <p>
*<BR>
* @author FJ)柳
*/
public class JBSbatKKKnytcsReissueDataMake extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	/** テーブル(契約内容通知書) */
	private static final String TBL_KK_T_KNYTCS = "KK_T_KNYTCS";
	/** テーブル(契約内容通知書内訳) */
	private static final String TBL_KK_T_KNYTCS_UW = "KK_T_KNYTCS_UW";
	/** テーブル(契約内容通知書非定型部) */
	private static final String TBL_KK_T_KNYTCS_HTKB = "KK_T_KNYTCS_HTKB";
	/** テーブル(契約内容通知対象物) */
	private static final String TBL_KK_T_KNYO_TCH_TG_BUT = "KK_T_KNYO_TCH_TG_BUT";
// ANK-3639-00-00 ADD START
	/** テーブル(契約内容通知書訂正) */
	private static final String TBL_KK_T_KNYTCS_TEISE = "KK_T_KNYTCS_TEISE";
// ANK-3639-00-00 ADD END
	/** テーブル(ディレイド処理依頼) */
	private static final String TBL_CC_T_DLYD_TRN_REQ = "CC_T_DLYD_TRN_REQ";
	
	/** SQL定義キー(契約内容通知書) */
	private static final String KK_T_KNYTCS_KK_INSERT_001 = "KK_INSERT_001";
	/** SQL定義キー(契約内容通知対象物) */
	private static final String KK_T_KNYO_TCH_TG_BUT_KK_INSERT_001 = "KK_INSERT_001";
	/** SQL定義キー(契約内容通知書内訳) */
	private static final String KK_T_KNYTCS_UW_KK_SELECT_001 = "KK_SELECT_001";
	private static final String KK_T_KNYTCS_UW_KK_INSERT_002 = "KK_INSERT_002";
	/** SQL定義キー(契約内容通知書非定型部) */
	private static final String KK_T_KNYTCS_HTKB_KK_INSERT_002 = "KK_INSERT_002";
// ANK-3639-00-00 ADD START
	/** SQL定義キー(契約内容通知書訂正) */
	private static final String KK_T_KNYTCS_TEISE_KK_INSERT_001 = "KK_INSERT_001";
// ANK-3639-00-00 ADD END
	/** SQL定義キー(ディレイド処理依頼) */
	private static final String CC_T_DLYD_TRN_REQ_CC_UPDATE_002 = "CC_UPDATE_002";
	

	/** DB項目名(契約内容通知書表示文言コード) */
	private static final String KNYTCS_DSP_MNGN_CD = "KNYTCS_DSP_MNGN_CD";
	/** DB項目名(表示位置識別通番) */
	private static final String DSP_PST_SKBT_SEQ = "DSP_PST_SKBT_SEQ";
	/** DB項目名(契約内容通知書内訳番号) */
	private static final String KNYTCS_UW_NO = "KNYTCS_UW_NO";
	// OM-2016-0001880 ADD START
	/** DB項目名(登録運用年月日) */
	private static final String ADD_UNYO_YMD = "ADD_UNYO_YMD";
	// OM-2016-0001880 ADD END
	
	/** シーケンス(契約内容通知書番号) */
	private static final String SEQ_KNYTCS_NO = "SEQ_KNYTCS_NO";
	/** シーケンス(契約内容通知書内訳番号) */
	private static final String SEQ_KNYTCS_UW_NO = "SEQ_KNYTCS_UW_NO";
	
	/** ジョブID(EO2FA1110D0)*/
	private static final String JOB_ID_EO2FA1110D0 = "EO2FA1110D0";
	
	/** DBアクセスクラス(契約内容通知書) */
	private JBSbatSQLAccess db_access_knytcs = null;
	/** DBアクセスクラス(契約内容通知書内訳) */
	private JBSbatSQLAccess db_access_knytcs_uw = null;
	/** DBアクセスクラス(契約内容通知書非定型部) */
	private JBSbatSQLAccess db_access_knytcs_htkb = null;
	/** DBアクセスクラス(契約内容通知対象物) */
	private JBSbatSQLAccess db_access_knyo_tch_tg_but = null;
// ANK-3639-00-00 ADD START
	/** DBアクセスクラス(契約内容通知書訂正) */
	private JBSbatSQLAccess db_access_knytcs_teise = null;
// ANK-3639-00-00 ADD END
	/** DBアクセスクラス(ディレイド処理依頼) */
	private JBSbatSQLAccess db_access_dlyd_trn_req = null;

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// DBアクセスクラス生成
		db_access_knytcs = new JBSbatSQLAccess(commonItem, TBL_KK_T_KNYTCS);
		db_access_knytcs_uw = new JBSbatSQLAccess(commonItem, TBL_KK_T_KNYTCS_UW);
		db_access_knytcs_htkb = new JBSbatSQLAccess(commonItem, TBL_KK_T_KNYTCS_HTKB);
		db_access_knyo_tch_tg_but = new JBSbatSQLAccess(commonItem, TBL_KK_T_KNYO_TCH_TG_BUT);
// ANK-3639-00-00 ADD START
		db_access_knytcs_teise = new JBSbatSQLAccess(commonItem, TBL_KK_T_KNYTCS_TEISE);
// ANK-3639-00-00 ADD END
		db_access_dlyd_trn_req = new JBSbatSQLAccess(commonItem, TBL_CC_T_DLYD_TRN_REQ);
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// (1)対象ファイル抽出
		// ディレイド処理依頼からデータを取得
		List<HashMap<String, Object>> shoriIraiList = new ArrayList<HashMap<String, Object>>();
		shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, JOB_ID_EO2FA1110D0);
		if (shoriIraiList != null)
		{
			// 処理依頼件数分ループ
			for(HashMap<String, Object> shoriIrai : shoriIraiList)
			{
				if (shoriIrai != null)
				{
					// ディレイド処理依頼番号
					String dlydTrnReqNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO);
					// 入力電子ファイル管理番号
					String inputEfileKanriNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO);
					// 電子ファイル解凍処理
					// ファイルのフルパスを取得
					String filePath = JCCbatDenshiFileUtil.searchDenshiFile(commonItem, inputEfileKanriNo);
					if (filePath != null)
					{
						JBSbatInputFileUtil file = new JBSbatInputFileUtil(filePath);
						file.setEncode(JKKStrConst.ENCODE_SJIS);
						// Readerオブジェクトを生成する。
						file.createReader();
						
						// ファイル行数(コピー元契約内容通知書番号)分ループ
						while (file.ready())
						{
							// (2)レコードコピー
							copySchema(file);
							
							// (3)ステータス更新
							// 更新(ディレイド処理依頼)
							// パラメタを設定する
							JBSbatCommonDBInterface dlydTrnReqParamList = new JBSbatCommonDBInterface();
							dlydTrnReqParamList.setValue("1");					// ディレイド処理結果コード(完了)
							dlydTrnReqParamList.setValue("002");				// ディレイド処理依頼ステータス(処理済)
							dlydTrnReqParamList.setValue(getBatchDatetime());	// 更新年月日時分秒
							dlydTrnReqParamList.setValue(getUpdOperator());		// 更新オペレータアカウント
							dlydTrnReqParamList.setValue(dlydTrnReqNo);			// ディレイド処理依頼番号
							// SQL文を実行
							db_access_dlyd_trn_req.executeBySqlDefine(dlydTrnReqParamList, CC_T_DLYD_TRN_REQ_CC_UPDATE_002);
						}
					}
				}
			}
		}
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	private void copySchema(JBSbatInputFileUtil file) throws IOException, Exception
	{
		// コピー元となる契約内容通知書番号
		String orgKnytcsNo = file.readLine();
		
		// コピー先となる契約内容通知書番号の発番
		String knytcsNo = JCCBatCommon.getFormatedNextSeq(super.commonItem, SEQ_KNYTCS_NO, "", 12);
		
		// 登録(契約内容通知書)
		// パラメタを設定する
		JBSbatCommonDBInterface knytcsParamList = new JBSbatCommonDBInterface();
		knytcsParamList.setValue(knytcsNo);		// コピー先契約内容通知書番号
		knytcsParamList.setValue(orgKnytcsNo);	// コピー元契約内容通知書番号
		// SQL文を実行
		db_access_knytcs.executeBySqlDefine(knytcsParamList, KK_T_KNYTCS_KK_INSERT_001);
		
		// 登録(契約内容通知対象物)
		// パラメタを設定する
		JBSbatCommonDBInterface knyoTchTgButParamList = new JBSbatCommonDBInterface();
		knyoTchTgButParamList.setValue(knytcsNo);		// コピー先契約内容通知書番号
		knyoTchTgButParamList.setValue(orgKnytcsNo);	// コピー元契約内容通知書番号
		// SQL文を実行
		db_access_knyo_tch_tg_but.executeBySqlDefine(knyoTchTgButParamList, KK_T_KNYO_TCH_TG_BUT_KK_INSERT_001);
		
		// 参照(契約内容通知書内訳)
		// パラメタを設定する
		JBSbatCommonDBInterface slctKnytcsUwParamList = new JBSbatCommonDBInterface();
		slctKnytcsUwParamList.setValue(orgKnytcsNo);	// コピー元契約内容通知書番号
		// SELECT文を実行
		db_access_knytcs_uw.selectBySqlDefine(slctKnytcsUwParamList, KK_T_KNYTCS_UW_KK_SELECT_001);
		
		// 結果を取得
		JBSbatCommonDBInterface knytcsUwResMap = new JBSbatCommonDBInterface();
		while((knytcsUwResMap = db_access_knytcs_uw.selectNext()) != null)
		{
			// 契約内容通知書内訳番号の発番
			String knytcsUwNo = JCCBatCommon.getFormatedNextSeq(super.commonItem, SEQ_KNYTCS_UW_NO, "", 15);
			
			// 登録(契約内容通知書内訳)
			// パラメタを設定する
			JBSbatCommonDBInterface insrtKnytcsUwParamList = new JBSbatCommonDBInterface();
			insrtKnytcsUwParamList.setValue(knytcsUwNo);									// 契約内容通知書内訳番号
			insrtKnytcsUwParamList.setValue(knytcsNo);										// コピー先契約内容通知書番号
			insrtKnytcsUwParamList.setValue(knytcsUwResMap.getString(KNYTCS_DSP_MNGN_CD));	// 契約内容通知書表示文言コード
			insrtKnytcsUwParamList.setValue(knytcsUwResMap.getString(DSP_PST_SKBT_SEQ));	// 表示位置識別通番
			// OM-2016-0001880 ADD START
			insrtKnytcsUwParamList.setValue(knytcsUwResMap.getString(ADD_UNYO_YMD));	// 登録運用年月日
			// OM-2016-0001880 ADD END
			// SQL文を実行
			db_access_knytcs_uw.executeBySqlDefine(insrtKnytcsUwParamList, KK_T_KNYTCS_UW_KK_INSERT_002);
			
			// 登録(契約内容通知書非定型部)
			// パラメタを設定する
			JBSbatCommonDBInterface knytcsHtkbParamList = new JBSbatCommonDBInterface();
			knytcsHtkbParamList.setValue(knytcsUwNo);								// コピー先契約内容通知書内訳番号
			knytcsHtkbParamList.setValue(knytcsUwResMap.getString(KNYTCS_UW_NO));	// コピー元契約内容通知書内訳番号
			// SQL文を実行
			db_access_knytcs_htkb.executeBySqlDefine(knytcsHtkbParamList, KK_T_KNYTCS_HTKB_KK_INSERT_002);
		}
		
// ANK-3639-00-00 ADD START
		// 登録(契約内容通知書訂正)
		// パラメタを設定する
		JBSbatCommonDBInterface knytcsTeiseParamList = new JBSbatCommonDBInterface();
		knytcsTeiseParamList.setValue(knytcsNo);		// コピー先契約内容通知書番号
		knytcsTeiseParamList.setValue(orgKnytcsNo);		// コピー元契約内容通知書番号
		// SQL文を実行
		db_access_knytcs_teise.executeBySqlDefine(knytcsTeiseParamList, KK_T_KNYTCS_TEISE_KK_INSERT_001);
// ANK-3639-00-00 ADD END

	}
	
	/**
	 * バッチ日時(17桁)を取得する
	 * @return バッチ日時
	 * @throws Exception
	 */
	private String getBatchDatetime() throws Exception
	{
		return JCCBatCommon.getSysDateTimeStamp();
	}
	/**
	 * 更新者IDを取得する
	 * 
	 * @return 更新者ID
	 */
	private String getUpdOperator()
	{
		return commonItem.getBatchUserId();
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		
		// DBアクセスクラスクローズ
		db_access_knytcs.close();
		db_access_knytcs_uw.close();
		db_access_knytcs_htkb.close();
		db_access_knyo_tch_tg_but.close();
// ANK-3639-00-00 ADD START
		db_access_knytcs_teise.close();
// ANK-3639-00-00 ADD END
		db_access_dlyd_trn_req.close();
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

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