/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCCWksijUpdDnbnItiAdd
*	ソースファイル名	：JBSbatCCWksijUpdDnbnItiAdd.java
*	作成者				：富士通　
*	作成日				：2012年06月04日
*＜機能概要＞
*　業務規制時更新電文一意登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/06/04   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.beans.XMLDecoder;
import java.beans.XMLEncoder;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.table.JBSbatCC_T_WKSIJ_UPD_DNBN;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.util.JCCBatchEsbInterface;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCCWksijUpdDnbnItiAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(業務規制時更新電文)*/
	private static final String D_TBL_NAME_CC_T_WKSIJ_UPD_DNBN = "CC_T_WKSIJ_UPD_DNBN";

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

	/** SQL定義キー(CC_UPDATE_001)*/
	private static final String CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_001 = "CC_UPDATE_001";
	
	/** SQL定義キー(CC_UPDATE_002)*/
	private static final String CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_002 = "CC_UPDATE_002";

	/** テーブルアクセスクラス(業務規制時更新電文)*/
	private JBSbatSQLAccess db_CC_T_WKSIJ_UPD_DNBN = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

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

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

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// FREE項目から業務規制時更新電文番号の取得
		String free = super.commonItem.getFreeItem();
		// free項目がnullまたはブランクの場合
		if(free == null || free.length()==0)
		{
			throw new JBSbatBusinessException("ECCB0120CE",
					new String[]{"業務規制時更新電文番号の設定を行ってください。"});
		}
		// 業務規制時更新電文番号をコロン区切りで切り分け
		String[] freeList = free.split(":");
		
		// 業務規制時更新電文番号ごとにサービス呼び出し
		for(int i = 0 ; i < freeList.length ; i++)
		{
			// 業務規制時更新電文番号のチェック
			if(freeList[i] == null || freeList[i].length() != 15)
			{
				throw new JBSbatBusinessException("ECCB0120CE", new String[]{"業務規制時更新電文番号を15桁で設定してください。：" + freeList[i]});
			}
			
			String[] paramList = new String[]{freeList[i]};
			executeCC_T_WKSIJ_UPD_DNBN_CC_SELECT_002(paramList);
			JBSbatCommonDBInterface dbMap = db_CC_T_WKSIJ_UPD_DNBN.selectNext();
			
			if(dbMap != null)
			{
				XMLDecoder usecaseDeco = null;
				XMLDecoder inputDeco = null;
				XMLEncoder outputEnco = null;
				try
				{
					// 業務規制時更新電文情報取得
					// パラメータマップをHashMapに変換
					String usecase = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.PARAM_MAP);
					ByteArrayInputStream usecaseBais = new ByteArrayInputStream(usecase.getBytes("UTF-8"));
					usecaseDeco = new XMLDecoder(usecaseBais);
					HashMap<String, Object> usecaseMap = (HashMap)usecaseDeco.readObject();
					// 入力データマップをHashMapに変換
					String input = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.INPUT_DATA_MAP);
					ByteArrayInputStream inputBais = new ByteArrayInputStream(input.getBytes("UTF-8"));
					inputDeco = new XMLDecoder(inputBais);
					HashMap<String, Object> inputMap = (HashMap)inputDeco.readObject();
					// 出力データマップ
					HashMap<String, Object> outputMap = new HashMap<String, Object>();

					//2013/03/27 電文蓄積再開時のサービス呼出し区分の変更対応 fst)yanagihara start
					JCCBatchEsbInterface.setWksijupdDnbnFlg(
							freeList[i].substring(0, 1), 
							dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.ADD_OPEACNT),
							dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.ADD_TRN_ID));
					//2013/03/27 電文蓄積再開時のサービス呼出し区分の変更対応 fst)yanagihara end

					// サービス呼び出し
					JCCBatCommon.invokeService(super.commonItem, usecaseMap, inputMap, outputMap);
					
					// システム日付取得
					String sysDateTime = JCCBatCommon.getSysDateTimeStamp();
					
					// 業務規制時更新電文更新
					// 正常時
					if(JCCBatchEsbInterface.RETURN_CODE_SUCCESS.equals(JCCBatCommon.getReturnCode(outputMap)))
					{
						String[] param = new String[]{"02", sysDateTime, batchUserId, freeList[i]};
						executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_002(param);
					}
					else
					{
						// 異常時はエラーマップを登録
						ByteArrayOutputStream outputBaos = new ByteArrayOutputStream();
						outputEnco = new XMLEncoder(outputBaos);
						outputEnco.writeObject(outputMap);
						outputEnco.close();
						String[] param = new String[]{"03",outputBaos.toString("UTF-8"), sysDateTime, batchUserId, freeList[i]};
						executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_001(param);
						// 業務エラーの業務規制時電文管理番号をメッセージに設定
						super.logPrint.printBusinessErrorLog("ECCB0240AW", new String[]{freeList[i]});
						// エラーカウントを加算
						commonItem.addErrorCount(1);
					}
					// データベースのコミットを明示的に行う。
					super.commit();
				}
				finally
				{
					if(usecaseDeco != null)
					{
						usecaseDeco.close();
					}
					if(inputDeco != null)
					{
						inputDeco.close();
					}
					if(outputEnco != null)
					{
						outputEnco.close();
					}
				}
			}
			else
			{
				// 業務規制時更新電文番号をキーにしてデータが取得できなかった場合
				super.logPrint.printBusinessErrorLog("ECCB0230AW", new String[]{freeList[i]});
			}
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(CC_SELECT_002)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	業務規制時更新電文番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCC_T_WKSIJ_UPD_DNBN_CC_SELECT_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

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

	/**
	 * SQLKEY(CC_UPDATE_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 executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_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());

		// DBアクセスを実行します
		db_CC_T_WKSIJ_UPD_DNBN.executeBySqlDefine(paramList, CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_001);
	}
	
	/**
	 * SQLKEY(CC_UPDATE_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 executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0]);
		paramList.setValue(param[1]);
		paramList.setValue(param[2]);
		paramList.setValue(param[3]);

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