/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCCWksijUpdDnbnIktAdd
*	ソースファイル名	：JBSbatCCWksijUpdDnbnIktAdd.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.text.SimpleDateFormat;
import java.util.Calendar;
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.db.JBSbatSQLAccess;
import eo.framework.util.JBSbatAplConst;
import eo.framework.util.JCCBatchEsbInterface;

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

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

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

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

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

	/** テーブルアクセスクラス(業務規制時更新電文)*/
	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
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// アプリケーションプロパティファイルから業務規制時更新電文削除日を取得
		String deleteDayStr = JBSbatAplConst.getAplConstValue("WKSIJ_UPD_DNBN_DELETE_DAY");
		if(deleteDayStr == null || "".equals(deleteDayStr))
		{
			// 取得できない場合は削除を行わない
		}
		else
		{
			int deleteDay = Integer.parseInt(deleteDayStr);
			String sysDate = JCCBatCommon.getSysDateTimeStamp();
			Calendar calender = Calendar.getInstance();
			calender.set(Integer.parseInt(sysDate.substring(0,4)), Integer.parseInt(sysDate.substring(4,6))-1, 
					Integer.parseInt(sysDate.substring(6,8)), Integer.parseInt(sysDate.substring(8,10)), Integer.parseInt(sysDate.substring(10,12))
					,Integer.parseInt(sysDate.substring(12,14)));
			calender.add(Calendar.DATE, - deleteDay);
			
			// 比較対象の日付を取得
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			String sdfSysDate = sdf.format(calender.getTime());
			
			// 物理削除SQL呼び出し
			String[] param = new String[]{sdfSysDate};
			executeCC_T_WKSIJ_UPD_DNBN_CC_DELETE_001(param);
		}
		
		// 未登録の電文情報を取得
		executeCC_T_WKSIJ_UPD_DNBN_CC_SELECT_001(null);
		JBSbatCommonDBInterface dbMap = db_CC_T_WKSIJ_UPD_DNBN.selectNext();
		
		while (dbMap != null)
		{
			XMLDecoder useCaseDeco = null;
			XMLDecoder inputDeco = null;
			XMLEncoder outputEnco = null;
			String wksijUpddnbnNo = "";
			try
			{
				// 業務規制時更新電文情報取得
				// 業務規制時更新電文番号
				wksijUpddnbnNo = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.WKSIJ_UPD_DNBN_NO);
				// パラメータマップを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(
						wksijUpddnbnNo.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, wksijUpddnbnNo};
					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, wksijUpddnbnNo};
					executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_001(param);
					// 業務エラーの業務規制時電文管理番号をメッセージに設定
					super.logPrint.printBusinessErrorLog("ECCB0240AW", new String[]{wksijUpddnbnNo});
					// エラーカウントを加算
					commonItem.addErrorCount(1);
				}
				// 次のレコード呼び出し
				dbMap = db_CC_T_WKSIJ_UPD_DNBN.selectNext();
				// データベースのコミットを明示的に行う。
				super.commit();
			}
			finally
			{
				if(useCaseDeco != null)
				{
					useCaseDeco.close();
				}
				if(inputDeco != null)
				{
					inputDeco.close();
				}
				if(outputEnco != null)
				{
					outputEnco.close();
				}
			}
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(CC_SELECT_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_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();

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

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

		// DBアクセスを実行します
		db_CC_T_WKSIJ_UPD_DNBN.executeBySqlDefine(paramList, CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_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_DELETE_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_DELETE_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

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