/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACReShukTrgtInfAdd
*	ソースファイル名	：JBSbatACReShukTrgtInfAdd.java
*	作成者				：富士通　
*	作成日				：2012年11月29日
*＜機能概要＞
*　再集計対象情報登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v4.00.00	2012/11/29  FJ）今井	【ST2-2012-0001779】新規作成
*	v4.00.00	2013/02/04  FJ）高田	【ST4-2013-0000114】sql*loader化
*	v4.00.01	2013/04/05  FJ) 小柴	【IKK-2013-0000783】文字化け対策のため、エンコード形式の変更
*	v23.00.00	2016/06/27  FJ) 中山	【OM-2016-0001645】シーケンスの桁あふれ対応
*********************************************************************/
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.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.file.JBSbatACIFM180;
import eo.business.util.file.JBSbatACIFM181;
import eo.common.constant.JACStrConst;
import eo.common.util.JPCUtilCommon;
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 JBSbatACReShukTrgtInfAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 対象キーワーク使用機能識別コード＿再集計対象情報 */
	private String wk_TWK_RE_SHUK = null;
	
	/** シーケンス桁数（対象キーワーク番号） */
	private static final int SEQ_LEN_SEQ_TRGT_KEY_NO = 20;
	
//OM-2016-0001645 MOD START
//	/** シーケンス */
//	private int seqtrgtkeyWkNoBef = 0;
	/** シーケンス */
	private long seqtrgtkeyWkNoBef = 0;
//OM-2016-0001645 MOD END
	
	/** シーケンス更新数 */
	private int seqCnt = 0;
	
	/** シーケンス更新用ファイル */
	private JBSbatBusinessFileUtil trgtkeySeqFile = null;
	
	/** フリー項目(カンマsplit済み) */
	private String[] freeItems = null;
	
	/** 出力ファイル定義 */
	private static final String PRM_OTD 	= "OTD";

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

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

	/** フリー項目：処理区分(2) */
	private final int FREEITEM_TRAN_DIV = 2;
	
	/** シーケンスカウント数 */
	private final int SEQ_COUNTUP = 100;
	
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/

		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
		
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		
		freeItems = super.freeItem.split(JACStrConst.SEMI_COLON);
		
		// 通常分
		if(JACStrConst.KOJI_FIN_REPORT_DIV_OFF.equals(freeItems[FREEITEM_TRAN_DIV]))
		{
			wk_TWK_RE_SHUK = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_TWK_RE_SHUK_NO1);
		}
		// 工事遅延分
		else if(JACStrConst.KOJI_FIN_REPORT_DIV_ON.equals(freeItems[FREEITEM_TRAN_DIV]))
		{
			wk_TWK_RE_SHUK = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_TWK_RE_SHUK_NO2);
		}
		
		paramUtil.close();
		
//OM-2016-0001645 MOD START
//		this.seqtrgtkeyWkNoBef = Integer.parseInt(JCCBatCommon.getFormatedNextSeq(commonItem, JACStrConst.SEQ_TRGT_KEY_WK, "", SEQ_LEN_SEQ_TRGT_KEY_NO));
		this.seqtrgtkeyWkNoBef = Long.parseLong(JCCBatCommon.getFormatedNextSeq(commonItem, JACStrConst.SEQ_TRGT_KEY_WK, "", SEQ_LEN_SEQ_TRGT_KEY_NO));
//OM-2016-0001645 MOD END

		//シーケンス更新用ファイル
		this.trgtkeySeqFile = createFile(freeItems[FREEITEM_SEQFILE_TRGT_KEY_WK], freeItems[FREEITEM_ACIFM106]);
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		JBSbatOutputItem outputItem = new JBSbatOutputItem();
		
		if (inMap != null)
		{
			// 出力情報を作成
			outputItem = makeTrgtKeyWkInfo(inMap);
			this.seqtrgtkeyWkNoBef++;
			this.seqCnt++;
		}
		
		return outputItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	private JBSbatOutputItem makeTrgtKeyWkInfo(JBSbatServiceInterfaceMap inMap) throws Exception {
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeNyukinPrcInfo]");

		JBSbatOutputItem outputItem = new JBSbatOutputItem();

		String seqNo = JPCUtilCommon.fillZero(String.valueOf(this.seqtrgtkeyWkNoBef), SEQ_LEN_SEQ_TRGT_KEY_NO, false);
		
		// 対象キーワーク番号
		inMap.set(JBSbatACIFM181.TRGT_KEY_WK_NO, seqNo);
		// 対象キーワーク使用機能コード
		inMap.set(JBSbatACIFM181.TRGT_KEY_WK_USE_KINO_CD, this.wk_TWK_RE_SHUK);
		// 対象キー１
		inMap.set(JBSbatACIFM181.TRGT_KEY_1, inMap.getString(JBSbatACIFM180.TRGT_KEY_1));
		// 対象キー２
		inMap.set(JBSbatACIFM181.TRGT_KEY_2, inMap.getString(JBSbatACIFM180.TRGT_KEY_2));
		// 対象キー３
		inMap.set(JBSbatACIFM181.TRGT_KEY_3, inMap.getString(JBSbatACIFM180.TRGT_KEY_3));
		// 対象キー４
		inMap.set(JBSbatACIFM181.TRGT_KEY_4, inMap.getString(JBSbatACIFM180.TRGT_KEY_4));
		// 対象キー５
		inMap.set(JBSbatACIFM181.TRGT_KEY_5, inMap.getString(JBSbatACIFM180.TRGT_KEY_5));

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

		outputItem.addOutMapList(inMap);

		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
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		
		this.outSeqNo();
		
		//シーケンス更新用ファイルクローズ
		JCCBatCommon.closeBusinessFileUtil(this.trgtkeySeqFile);
		
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 更新用シーケンス番号をファイル出力します
	 * 
	 * @throws Exception
	 */
	private void outSeqNo() throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][outSeqNo]");
		
		// シーケンス更新用ファイル出力
		ArrayList<Object> updSeikyNoList = new ArrayList<Object>();
		updSeikyNoList.add(seqCnt + SEQ_COUNTUP);
		JCCBatCommon.printBusinessFileUtil(this.trgtkeySeqFile, updSeikyNoList);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][outSeqNo]");
	}
	
	/**
	 * ファイル出力
	 * 
	 * @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;
	}
}