/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKEoelePayListSksi
*	ソースファイル名	：JBSbatKKEoelePayListSksi.java
*	作成者				：富士通　
*	作成日				：2017年09月01日
*＜機能概要＞
*　ｅｏ電気支払申込書個別発送対象リスト作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v34.00.00	2017/09/01  FJ)永井		【ANK-3210-00-00】【eo電気】電気単独対応（STEP3） 新規作成
*********************************************************************/
package eo.business.service;

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JKKBatCommon;
import eo.business.common.JKKBatConst;
import eo.business.util.table.JBSbatKK_T_SVC_KEI;
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.util.JBSbatBusinessFileUtil;
import eo.framework.util.JBSbatDateUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKEoelePayListSksi extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(サービス契約)*/
	private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";

	/** テーブル(電子ファイル管理)*/
	private static final String D_TBL_NAME_CC_T_EFILE_KANRI = "CC_T_EFILE_KANRI";

	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

	/** SQL定義キー(KK_SELECT_334)*/
	private static final String KK_T_SVC_KEI_KK_SELECT_334 = "KK_SELECT_334";

	/** テーブルアクセスクラス(サービス契約)*/
	private JBSbatSQLAccess db_KK_T_SVC_KEI = null;

	/** テーブルアクセスクラス(電子ファイル管理)*/
	private JBSbatSQLAccess db_CC_T_EFILE_KANRI = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** SQL定義キー(KK_INSERT_001)*/
	private static final String ZM_T_DL_FILE_KANRI_KK_INSERT_001 = "KK_INSERT_001";
	
	/** ファイルコード */
	private static final String FILE_CD = "0000";
	
	/** 処理管理番号 */
	private static final String TRN_KANRI_NO = "000000000164";

	/** ファイル名編集用 */
	private static final String FILE_NM = "ｅｏ電気支払申込書個別発送対象リスト_";
	
	/** 受付済サービス契約番号ｅｏ電気ファイルファイルパス */
	private String kkifm737FilePath = null;
	
	/** ｅｏ電気支払申込書個別発送対象リストファイルパス */
	private String kkifm740FilePath = null;
	
	/** ｅｏ電気支払申込書個別発送対象リストファイルオブジェクト */
	private JBSbatBusinessFileUtil kkifm740FileObj = null;
	
	/** ファイル出力件数 */
	private int outCount = 0;
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		
		// DBアクセスクラスを生成します
		db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
		db_CC_T_EFILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_EFILE_KANRI);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		String[] freeItems = commonItem.getFreeItem().split(JKKBatConst.S_PARAM_DELIM);
		
		// 受付済サービス契約番号ｅｏ電気ファイルファイルパス
		kkifm737FilePath = freeItems[0];
		
		// ｅｏ電気支払申込書個別発送対象リストファイルパス
		kkifm740FilePath = freeItems[1];
		
		// ｅｏ電気支払申込書個別発送対象リストファイルオブジェクト
		kkifm740FileObj = JKKBatCommon.createBusinessFileUtil(kkifm740FilePath,
				JKKBatConst.SJIS, JKKStrConst.LINE_SEPARATOR, JKKBatConst.S_SEP_CAM);

	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 受付済サービス契約番号ｅｏ電気ファイルの件数分を繰返す
		BufferedReader br = null;
		try
		{
			InputStreamReader is = new InputStreamReader(new FileInputStream(kkifm737FilePath), JKKStrConst.ENCODE_SJIS);
			br = new BufferedReader(is);
			
			while (br.ready())
			{
				// 1行読込み
				String data = br.readLine();
				
				// サービス契約番号(eo電気)
				String svcKeiNoEoD = data.substring(1, data.length() - 1);
				
				// 退避.サービス契約番号（eo光サービス）
				String svcKeiNoEoH = null;
				
				// サービス契約番号(eo電気)と同一利用場所のeo光サービス契約を取得する
				executeKK_T_SVC_KEI_KK_SELECT_334(new Object[] {
						super.opeDate, svcKeiNoEoD, super.opeDate, super.opeDate, super.opeDate});
				
				// レコードを取得する
				JBSbatCommonDBInterface svcKeiEoHStateMap = db_KK_T_SVC_KEI.selectNext();
				
				while (svcKeiEoHStateMap != null)
				{ 
					// レコードのサービス契約ステータスが"キャンセル済",
					// もしくはサービス契約ステータスが"照査済"かつ照査解約完了コードが"照査NG"の
					// いずれも満たしていない場合、出力対象外とする
					if (!(JKKStrConst.CD00037_CANCEL_ZM.equals(svcKeiEoHStateMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_STAT))
							|| (JKKStrConst.CD00037_SHOSA_ZUMI.equals(svcKeiEoHStateMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_STAT))
								&& (JKKStrConst.CD00469_2.equals(svcKeiEoHStateMap.getString(JBSbatKK_T_SVC_KEI.SHOSA_DSL_FIN_CD))))))
					{
						svcKeiNoEoH = null;
						break;
					}
					
					// サービス契約番号(eo光サービス)のサービス契約番号を退避する
					if (svcKeiNoEoH == null)
					{
						svcKeiNoEoH = svcKeiEoHStateMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO);
					}
					
					// 次のレコードを取得する
					svcKeiEoHStateMap = db_KK_T_SVC_KEI.selectNext();
				}
				
				// サービス契約番号(eo光サービス)が退避されていない場合、出力対象外とする
				if (svcKeiNoEoH == null)
				{
					continue;
				}
				
				// ｅｏ電気支払申込書個別発送対象リストファイルを出力する
				String[] strList = new String[2];
				strList[0] = svcKeiNoEoD;
				strList[1] = svcKeiNoEoH;

				// ｅｏ電気支払申込書個別発送対象リストファイルを出力する
				createKkifm740(strList);
				
				// ファイル出力件数にインクリメントする
				outCount++;
			}
		}
		catch (IOException e)
		{
			// 受付済サービス契約番号ｅｏ電気ファイルがない場合０件と同様とする
			super.logPrint.printDebugLog("受付済サービス契約番号ｅｏ電気ファイルなし");
		}
		finally
		{
			if (null != br)
			{
				br.close();
			}
		}
		
		// ファイルを閉じる
		JCCBatCommon.closeBusinessFileUtil(kkifm740FileObj);
		
		// 電子ファイル管理登録処理
		JBSbatCommonItem arg0 = super.commonItem;					// 業務共通電文
		String arg1 = FILE_CD;										// ファイルコード
		String arg2 = kkifm740FilePath;								// ファイルパス
		String arg3 = JBSbatDateUtil.adjustMonth(super.opeDate, 3);	// ファイル削除年月日（運用日付 + 3ヶ月）
		String[] rc = JCCBatCommon.createDenshiFile(arg0, arg1, arg2, arg3);
		
		// ログ出力
		super.logPrint.printDebugLog("電子ファイル管理番号(" + rc[0] +  ")、世代登録年月日時分秒(" + rc[1] + ")");
		
		// ダウンロードファイル管理登録処理
		executeZM_T_DL_FILE_KANRI_KK_INSERT_001(getDlFileInsertParam(rc, arg3));
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_KK_T_SVC_KEI.close();
		db_CC_T_EFILE_KANRI.close();
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_334)で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_334(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());

		// DBアクセスを実行します
		db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_334);
	}

	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	/**
	 * ｅｏ電気支払申込書個別発送対象リストファイルの作成を行う。
	 * @param strList 出力対象データ
	 * @return JBSbatServiceInterfaceMap
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void createKkifm740(String[] strList) throws Exception
	{
		super.logPrint.printDebugLog("createKkifm740_START");
		
		ArrayList<String> outputList = new ArrayList<String>();
		
		// 項目を設定
		outputList.add(strList[0]);		// サービス契約番号（eo電気）
		outputList.add(strList[1]);		// サービス契約番号（eo光サービス）	
		
		JKKBatCommon.printBusinessFileUtil(kkifm740FileObj, outputList);
		
		super.logPrint.printDebugLog("createKkifm740_END");
	}
	
	/**
	 * SQLKEY(KK_INSERT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	処理管理番号
	 *			ファイル名
	 *			データ件数
	 *		 	ファイル登録年月日時分秒
	 *			ファイル削除年月日
	 *		 	登録年月日時分秒
	 *		 	登録オペレータアカウント
	 *		 	更新年月日時分秒
	 *		 	更新オペレータアカウント
	 *		 	電子ファイル管理番号
	 *		 	世代登録年月日時分秒
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_DL_FILE_KANRI_KK_INSERT_001(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());
		paramList.setValue(param[6].toString());

		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.executeBySqlDefine(paramList, ZM_T_DL_FILE_KANRI_KK_INSERT_001);
	}
	
	/**
	 * ZM_T_DL_FILE_KANRI-KK_INSERT_001を実行する際に必要なパラメータを返す。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * 
	 * <pre>
	 * 1.パラメータ設定処理。
	 * </pre>
	 * <p>
	 * 
	 * @param rc
	 *            共通部品の電子ファイル管理登録から返却された文字列
	 * @param arg3
	 *            共通部品の電子ファイル管理登録に渡したファイル削除年月日
	 * @return setParam ZM_T_DL_FILE_KANRI-KK_INSERT_001を実行する際に必要なパラメータ
	 * @throws Exception
	 */
	private Object[] getDlFileInsertParam(String[] rc, String arg3) throws Exception
	{
		// システム日時
		String fileTimeStamp = JCCBatCommon.getSysDateTime();
		
		// ファイル名
		String fileName = FILE_NM + JKKStrConst.FILE_NM_TIMESTAMP.replaceAll(
				JKKStrConst.FILE_TIMESTAMP_FORMAT, fileTimeStamp);
		
		Object[] setParam = {
				TRN_KANRI_NO,						// 処理管理番号
				fileName,							// ファイル名
				outCount,							// データ件数
				rc[1],								// ファイル登録年月日時分秒
				arg3,								// ファイル削除年月日
				rc[0],								// 電子ファイル管理番号
				rc[1]								// 世代登録年月日時分秒
		};
		return setParam;
	}
}

