/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom						 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACReCalcTgSikyIfAdd
*	ソースファイル名	：JBSbatACReCalcTgSikyIfAdd.java
*	作成者				：富士通　
*	作成日				：2011年07月26日
*＜機能概要＞
*　再計算対象請求先情報登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/07/26   富士通		新規作成
*	v4.00.00	2012/11/29   FJ）今井	【ST2-2012-0001779】対応
*	v4.01		2012/12/26   FJ) 指原	【TG1-2012-0000222】登録処理をデータファイル出力→SQLLOADERに変更
*	v4.02		2013/01/25   FJ) 早崎	【内部管理番号-0000502】対応
*	v4.03		2013/01/30   FJ) 指原	【ST4-2013-0000085】シーケンス採番方法変更。java内でカウントアップし、加算数をファイル出力する。
*	v4.04		2013/04/05   FJ) 小柴	【IKK-2013-0000783】文字化け対策のため、エンコード形式の変更
*	v25.00.00	2016/06/28   FJ) 中山	【OM-2016-0001657】シーケンスの桁あふれ対応
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;

import eo.business.common.JACBatCommon;
import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatParamUtil;
import eo.business.common.JACbatSchdlUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.file.JBSbatACIFM183;
import eo.business.util.file.JBSbatACIFM181;
import eo.common.constant.JACStrConst;
import eo.common.util.JPCUtilCommon;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JBSbatAplConst;
import eo.framework.util.JBSbatBusinessFileUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatACReCalcTgSikyIfAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(対象キーワーク)*/
	private static final String D_TBL_NAME_AC_T_TRGT_KEY_WK = "AC_T_TRGT_KEY_WK";

	/** テーブルアクセスクラス(対象キーワーク)*/
	private JBSbatSQLAccess db_AC_T_TRGT_KEY_WK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 請求年月 */
	private String seikyYm = null;

	/** 対象キーワーク使用機能識別コード＿再計算対象請求先番号 */
	private String wk_TWK_RE_CL_SLY = null;

	/** フリー項目(カンマsplit済み) */
	private String[] freeItems = null;

	/*▼ シーケンス採番用定義変数 ▼*/
	/** シーケンス名（対象キーワーク番号） */
	private static final String SEQ_NAME_SEQ_TRGT_KEY_WK = "SEQ_TRGT_KEY_WK";

	/** シーケンス接頭辞（対象キーワーク番号） */
	private static final String SEQ_PREFIX_SEQ_NAME_SEQ_TRGT_KEY_WK = "";

	/** シーケンス桁数（対象キーワーク番号） */
	private static final int SEQ_LEN_SEQ_NAME_SEQ_TRGT_KEY_WK = 20;

	/** 出力ファイル定義 */
	private static final String PRM_OTD 	= "OTD";

	/** 対象キーワークシーケンス更新用ファイル */
	private JBSbatBusinessFileUtil trgtKeyWkSeqFile = null;

//OM-2016-0001657 MOD START
//	/** 対象キーワーク番号（処理前（シーケンスから取得）） */
//	private int seqTrgtKeyWkNoBef = 0;
//	
//	/** 対象キーワーク番号（シーケンスから取得） */
//	private int seqTrgtKeyWkNo = 0;
	/** 対象キーワーク番号（処理前（シーケンスから取得）） */
	private long seqTrgtKeyWkNoBef = 0;
	
	/** 対象キーワーク番号（シーケンスから取得） */
	private long seqTrgtKeyWkNo = 0;
//OM-2016-0001657 MOD END

	/** フリー項目(0)：ファイル項目定義ファイル(ACIFM106) */
	private final int FREEITEM_ACIFM106 = 0;

	/** フリー項目(1)：対象キーワーク更新数ファイル */
	private final int FREEITEM_SEQFILE_TRGT_KEY_WK = 1;

	/** フリー項目(2)：工事完了報告遅延区分 */
	private final int FREEITEM_KOJI_FIN_REPORT_DIV = 2;


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

		// DBアクセスクラスを生成します
		db_AC_T_TRGT_KEY_WK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_TRGT_KEY_WK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/

		// FREEITEMの取得
		freeItems = super.freeItem.split(JACStrConst.SEMI_COLON);

		// 料金スケジュール定義アクセス部品初期処理
		JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);

		// バッチ運用日、イベントコード("03"（料金計算日)）から請求年月を求める
		this.seikyYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_RYOKIN_KEISAN_YMD);

		// 料金スケジュール定義アクセス部品クローズ処理
		schdlUtil.close();

		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		// 通常分
		if(JACStrConst.KOJI_FIN_REPORT_DIV_OFF.equals(freeItems[FREEITEM_KOJI_FIN_REPORT_DIV]))
		{
			this.wk_TWK_RE_CL_SLY = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_TWK_RE_CL_SKY_NO1);
		}
		// 工事遅延分
		else if(JACStrConst.KOJI_FIN_REPORT_DIV_ON.equals(freeItems[FREEITEM_KOJI_FIN_REPORT_DIV]))
		{
			this.wk_TWK_RE_CL_SLY = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_TWK_RE_CL_SKY_NO2);
		}
		
		paramUtil.close();

		// シーケンスからサービス契約蓄積番号を取得
//OM-2016-0001657 MOD START
//		this.seqTrgtKeyWkNoBef = Integer.parseInt(JCCBatCommon.getFormatedNextSeq(super.commonItem, SEQ_NAME_SEQ_TRGT_KEY_WK, SEQ_PREFIX_SEQ_NAME_SEQ_TRGT_KEY_WK, SEQ_LEN_SEQ_NAME_SEQ_TRGT_KEY_WK));
		this.seqTrgtKeyWkNoBef = Long.parseLong(JCCBatCommon.getFormatedNextSeq(super.commonItem, SEQ_NAME_SEQ_TRGT_KEY_WK, SEQ_PREFIX_SEQ_NAME_SEQ_TRGT_KEY_WK, SEQ_LEN_SEQ_NAME_SEQ_TRGT_KEY_WK));
//OM-2016-0001657 MOD END
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][シーケンス番号（対象キーワーク）" + this.seqTrgtKeyWkNoBef + "]");
		
		this.seqTrgtKeyWkNo = this.seqTrgtKeyWkNoBef;

		// サービス契約蓄積シーケンス更新用ファイル
		this.trgtKeyWkSeqFile = createFile(freeItems[FREEITEM_SEQFILE_TRGT_KEY_WK], freeItems[FREEITEM_ACIFM106]);

	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		assert inMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][inMap = " + inMap.getMap().toString() + "]") : true;

		JBSbatOutputItem outputItem = new JBSbatOutputItem();

		// 入金情報がない場合、処理をせずに終了
		if (inMap != null)
		{
			// 入金料金情報を作成
			outputItem = makeTrgtKeyWkInfo(inMap);
		}

		assert outputItem != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][outputItem = " + outputItem.getOutMapList().toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");

		return outputItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼メソッド追加 開始▼▼▼▼▼▼*/
	/**
	 * 対象キーワークのデータを作成します。
	 * @param inMap 入力電文
	 * @return outputItem 出力情報
	 * @throws Exception 
	 */
	private JBSbatOutputItem makeTrgtKeyWkInfo(JBSbatServiceInterfaceMap inMap) throws Exception {
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeNyukinPrcInfo]");

		JBSbatOutputItem outputItem = new JBSbatOutputItem();

		// シーケンスからサービス契約蓄積番号を取得
		String trgtKeyWkNo = JPCUtilCommon.fillZero(String.valueOf(this.seqTrgtKeyWkNo), SEQ_LEN_SEQ_NAME_SEQ_TRGT_KEY_WK, false);

		// 対象キーワーク番号
		inMap.set(JBSbatACIFM181.TRGT_KEY_WK_NO, trgtKeyWkNo);
		// 対象キーワーク使用機能コード
		inMap.set(JBSbatACIFM181.TRGT_KEY_WK_USE_KINO_CD, this.wk_TWK_RE_CL_SLY);
		// 対象キー１
		inMap.set(JBSbatACIFM181.TRGT_KEY_1, this.seikyYm);
		// 対象キー２
		inMap.set(JBSbatACIFM181.TRGT_KEY_2, inMap.getString(JBSbatACIFM183.SEIKY_KEI_NO));
		// 対象キー３
		String trgtKey3 = inMap.getString(JBSbatACIFM183.SVC_KEI_NO);
		if(null == trgtKey3 || trgtKey3.equals(""))
		{
			inMap.set(JBSbatACIFM181.TRGT_KEY_3, JACStrConst.KARA_MOJI);
		}
		else
		{
			inMap.set(JBSbatACIFM181.TRGT_KEY_3, trgtKey3);
		}
		// 対象キー４
		String trgtKey4 = inMap.getString(JBSbatACIFM183.SVC_KEI_UCWK_NO);
		if(null == trgtKey4 || trgtKey4.equals(""))
		{
			inMap.set(JBSbatACIFM181.TRGT_KEY_4, JACStrConst.KARA_MOJI);
		}
		else
		{
			inMap.set(JBSbatACIFM181.TRGT_KEY_4, trgtKey4);
		}
		// 対象キー５
		inMap.set(JBSbatACIFM181.TRGT_KEY_5, JACStrConst.KARA_MOJI);

		// 出力フラグ
		inMap.setOutFlg(true);

		outputItem.addOutMapList(inMap);

		this.seqTrgtKeyWkNo = getNextSeq(this.seqTrgtKeyWkNo, 1);

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeTrgtKeyWkInfo][outputMap = " + inMap.getMap().toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeTrgtKeyWkInfo]");

		return outputItem;
	}

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

		// サービス契約シーケンス更新用ファイル出力
		this.outSeqNo();

		// サービス契約蓄積シーケンス更新用ファイルクローズ
		JCCBatCommon.closeBusinessFileUtil(this.trgtKeyWkSeqFile);

		/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 更新用シーケンス番号をファイル出力します
	 * 
	 * @throws Exception
	 */
	private void outSeqNo() throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][outSeqNo]");
		
		// シーケンスを100進める
		this.seqTrgtKeyWkNo = getNextSeq(this.seqTrgtKeyWkNo, 100);
		
		// 処理前との差分を算出
//OM-2016-0001657 MOD START
//		int updSeikyNoCnt = this.seqTrgtKeyWkNo - this.seqTrgtKeyWkNoBef;
		long updSeikyNoCnt = this.seqTrgtKeyWkNo - this.seqTrgtKeyWkNoBef;
//OM-2016-0001657 MOD END
		
		// 請求シーケンス更新用ファイル出力
		ArrayList<Object> updSeikyNoList = new ArrayList<Object>();
		updSeikyNoList.add(updSeikyNoCnt);
		JCCBatCommon.printBusinessFileUtil(this.trgtKeyWkSeqFile, updSeikyNoList);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][outSeqNo]");
	}

//OM-2016-0001657 MOD START
//	/**
//	 * シーケンスを引数分加算します。
//	 * 
//	 * @param seqNo 加算対象シーケンス番号
//	 * @param num 加算数
//	 * @return int 加算済シーケンス番号
//	 * @throws Exception
//	 */
//	private int getNextSeq(int seqNo, int num) throws Exception
//	{
//		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getNextSeq]");
//		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getNextSeq][" + seqNo + " ＋ " + num + " ＝ " + seqNo + num + "]");
//		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getNextSeq]");
//		
//		//引数分加算する
//		return seqNo + num;
//	}
	
	/**
	 * シーケンスを引数分加算します。
	 * 
	 * @param seqNo 加算対象シーケンス番号
	 * @param num 加算数
	 * @return 加算済シーケンス番号
	 * @throws Exception
	 */
	private long getNextSeq(long seqNo, long num) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getNextSeq]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getNextSeq][" + seqNo + " ＋ " + num + " ＝ " + seqNo + num + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getNextSeq]");
		
		//引数分加算する
		return seqNo + num;
	}
//OM-2016-0001657 MOD END

	/**
	 * ファイル出力
	 * 
	 * @param  filePath  ファイルパス
	 * @param  fileDef   ファイル定義
	 * @return fileUtil  ファイルインスタンス
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatBusinessFileUtil createFile(String filePath, String fileDef) throws Exception 
	{
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][createFile]");
		JBSbatOutputFileUtil trailerFile 	= new JBSbatOutputFileUtil(filePath);
		String tempFileDefName 				= JBSbatAplConst.getAplConstValue(PRM_OTD) + fileDef;
		JBSbatDefFileUtil trailerFileDef 	= new JBSbatDefFileUtil(tempFileDefName, trailerFile);
		
		// ファイルの生成
		JBSbatBusinessFileUtil fileUtil = JCCBatCommon.createBusinessFileUtil(filePath
																			, JACStrConst.ENCODE_MS932
																			, JACBatCommon.chgKaigyo(JACStrConst.LINE_CRLF)
																			, trailerFileDef.getDelimiter());
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][createFile]");
		return fileUtil;
	}
}