/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatZMTkWkInfoDataSet
*	ソースファイル名	：JBSbatZMTkWkInfoDataSet.java
*	作成者				：富士通　
*	作成日				：2012年04月13日
*＜機能概要＞
*　宅内機器ワーク情報取込処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v3.00.00	2012/04/13  FJ) 伊藤	新規作成
*	v3.00.00	2012/04/13  FJ) 伊藤　 【ANK-0286-00-00】新規作成のため
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatZMIFM023;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.db.JBSbatSQLAccess;

/**
* 宅内機器ワーク情報ファイルの情報を宅内機器ワークへ反映するクラス <p>
*<BR>
* @author 富士通
*/
public class JBSbatZMTkWkInfoDataSet extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(宅内機器ワーク)*/
	private static final String D_TBL_NAME_ZM_T_TAKNKIKI_WK = "ZM_T_TAKNKIKI_WK";

	/** SQL定義キー(ZM_DELETE_001)*/
	private static final String ZM_T_TAKNKIKI_WK_ZM_DELETE_001 = "ZM_DELETE_001";

	/** SQL定義キー(ZM_INSERT_001)*/
	private static final String ZM_T_TAKNKIKI_WK_ZM_INSERT_001 = "ZM_INSERT_001";

	/** テーブルアクセスクラス(宅内機器ワーク)*/
	private JBSbatSQLAccess db_ZM_T_TAKNKIKI_WK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/* ++++++++++ v1.0.0 追加開始 ++++++++++ */
	/** 処理件数*/
	private int resultCnt = 0;

	/** エラーメッセージ埋め込み文字（件目） */
	private static final String ERRMSG_NUMBER = "件目　";

	/** 件番号 */
	private int rdcnt = 0;

	/** テーブル名 */
	private static final String ZM_T_TAKNKIKI_WK_NM = "宅内機器ワーク";

	/** 宅内機器型式コード */
	private static final String TK_MDL_CD_NM = "宅内機器型式コード：";

	/** 機器製造番号 */
	private static final String KK_SEIZO_NO_NM = "機器製造番号：";

	/** 更新識別コード(登録) */
	private static final String INSERT_CD = "1";

	/** 更新識別コード(更新) */
	private static final String UPDATE_CD = "2";

	/** 更新識別コード(削除) */
	private static final String DELETE_CD = "3";
	/* ++++++++++ v1.0.0 追加終了 ++++++++++ */

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_ZM_T_TAKNKIKI_WK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_TAKNKIKI_WK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		/* ++++++++++ v1.0.0 追加開始 ++++++++++ */
		rdcnt++;

		HashMap<?, ?> valueMap = inMap.getMap();
		String[] param = new String[35];

		String updCd = (String)valueMap.get(JBSbatZMIFM023.UPD_SKBT_CD);
		param[0] = (String)valueMap.get(JBSbatZMIFM023.TAKNKIKI_MODEL_CD);
		param[1] = (String)valueMap.get(JBSbatZMIFM023.KIKI_SEIZO_NO);

		if(UPDATE_CD.equals(updCd) || DELETE_CD.equals(updCd))
		{
			resultCnt = executeZM_T_TAKNKIKI_WK_ZM_DELETE_001(param);
			if(resultCnt == 0)
			{
				StringBuffer rdmsg = new StringBuffer();
				rdmsg.append(rdcnt).append(ERRMSG_NUMBER);
				rdmsg.append(TK_MDL_CD_NM).append(param[0]).append("　");
				rdmsg.append(KK_SEIZO_NO_NM).append(param[1]);
				commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EZMB0180KW,
						new String[]{ZM_T_TAKNKIKI_WK_NM, rdmsg.toString()});
				return null;
			}
			else if(DELETE_CD.equals(updCd))
			{
				return null;
			}
		}

		param[2] = (String)valueMap.get(JBSbatZMIFM023.TAKNKIKI_STAT);
		param[3] = (String)valueMap.get(JBSbatZMIFM023.TAKNKIKI_SBT_CD);
		param[4] = (String)valueMap.get(JBSbatZMIFM023.SHOYU_CD);
		param[5] = (String)valueMap.get(JBSbatZMIFM023.KANRI_PLACE_SKBT_CD);
		param[6] = (String)valueMap.get(JBSbatZMIFM023.KANRI_PLACE_CD);
		param[7] = (String)valueMap.get(JBSbatZMIFM023.KANRI_PLACE_SHELF_CD);
		param[8] = (String)valueMap.get(JBSbatZMIFM023.GDS_STAT_CD);
		param[9] = (String)valueMap.get(JBSbatZMIFM023.MACAD);
		param[10] = (String)valueMap.get(JBSbatZMIFM023.JOI_TAKNKIKI_MODEL_CD);
		param[11] = (String)valueMap.get(JBSbatZMIFM023.JOI_KIKI_SEIZO_NO);
		param[12] = (String)valueMap.get(JBSbatZMIFM023.RENEWAL_CNT);
		param[13] = (String)valueMap.get(JBSbatZMIFM023.YOBI_GOODS_FLG);
		param[14] = (String)valueMap.get(JBSbatZMIFM023.PLACE_STC_YMD);
		param[15] = (String)valueMap.get(JBSbatZMIFM023.TAKNKIKI_NYUKA_YMD);
		param[16] = (String)valueMap.get(JBSbatZMIFM023.TAKNKIKI_ABDMNT_YMD);
		param[17] = (String)valueMap.get(JBSbatZMIFM023.VER);
		param[18] = (String)valueMap.get(JBSbatZMIFM023.STB_STAT);
		param[19] = (String)valueMap.get(JBSbatZMIFM023.STB_ID);
		param[20] = (String)valueMap.get(JBSbatZMIFM023.CTRL_AREA_CD);
		param[21] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_1);
		param[22] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_2);
		param[23] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_3);
		param[24] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_4);
		param[25] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_5);
		param[26] = (String)valueMap.get(JBSbatZMIFM023.STB_MTST_GRP_ID_6);
		param[27] = (String)valueMap.get(JBSbatZMIFM023.KARI_KEY_STA_YMD);
		param[28] = (String)valueMap.get(JBSbatZMIFM023.CAS_CARD_SBT_CD);
		param[29] = (String)valueMap.get(JBSbatZMIFM023.CCAS_CARD_STAT);
		param[30] = (String)valueMap.get(JBSbatZMIFM023.LEASE_STA_YMD);
		param[31] = (String)valueMap.get(JBSbatZMIFM023.LEASE_MANRYO_YMD);
		param[32] = (String)valueMap.get(JBSbatZMIFM023.LEASE_DSL_YMD);
		param[33] = (String)valueMap.get(JBSbatZMIFM023.LEASE_PRD);
		param[34] = (String)valueMap.get(JBSbatZMIFM023.LEASE_CNT);

		try
		{
			executeZM_T_TAKNKIKI_WK_ZM_INSERT_001(param);
		}
		catch (Exception e)
		{
			if(INSERT_CD.equals(updCd))
			{
				StringBuffer rdmsg = new StringBuffer();
				rdmsg.append(rdcnt).append(ERRMSG_NUMBER);
				rdmsg.append(TK_MDL_CD_NM).append(param[0]).append("　");
				rdmsg.append(KK_SEIZO_NO_NM).append(param[1]);
				commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EZMB0170KW,
						new String[]{rdmsg.toString()});
			}
		}
		/* ++++++++++ v1.0.0 追加終了 ++++++++++ */
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_ZM_T_TAKNKIKI_WK.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/* ++++++++++ v1.0.0 追加開始 ++++++++++ */
	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/

	/**
	 * SQLKEY(ZM_DELETE_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	宅内機器型式コード
	 *		 	機器製造番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @return 処理件数
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private int executeZM_T_TAKNKIKI_WK_ZM_DELETE_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		return db_ZM_T_TAKNKIKI_WK.executeBySqlDefine(paramList, ZM_T_TAKNKIKI_WK_ZM_DELETE_001);
	}

	/**
	 * SQLKEY(ZM_INSERT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	宅内機器型式コード
	 *		 	機器製造番号
	 *		 	宅内機器ステータス
	 *		 	宅内機器種別コード
	 *		 	所有コード
	 *		 	管理場所識別コード
	 *		 	管理場所コード
	 *		 	管理場所棚コード
	 *		 	商品状態コード
	 *		 	MACアドレス
	 *		 	上位宅内機器型式コード
	 *		 	上位機器製造番号
	 *		 	リニューアル回数
	 *		 	予備品フラグ
	 *		 	場所設置年月日
	 *		 	宅内機器入荷年月日
	 *		 	宅内機器破棄年月日
	 *		 	Ver
	 *		 	STBステータス
	 *		 	STBID
	 *		 	制御エリアコード
	 *		 	STB松下用グループID1
	 *		 	STB松下用グループID2
	 *		 	STB松下用グループID3
	 *		 	STB松下用グループID4
	 *		 	STB松下用グループID5
	 *		 	STB松下用グループID6
	 *		 	仮鍵開年月日
	 *		 	CASカード種別コード
	 *		 	C-CASカードステータス
	 *		 	リース開始年月日
	 *		 	リース満了年月日
	 *		 	リース解約年月日
	 *		 	リース期間
	 *		 	リース回数
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_TAKNKIKI_WK_ZM_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());
		paramList.setValue(param[7].toString());
		paramList.setValue(param[8].toString());
		paramList.setValue(param[9].toString());
		paramList.setValue(param[10].toString());
		paramList.setValue(param[11].toString());
		paramList.setValue(param[12].toString());
		paramList.setValue(param[13].toString());
		paramList.setValue(param[14].toString());
		paramList.setValue(param[15].toString());
		paramList.setValue(param[16].toString());
		paramList.setValue(param[17].toString());
		paramList.setValue(param[18].toString());
		paramList.setValue(param[19].toString());
		paramList.setValue(param[20].toString());
		paramList.setValue(param[21].toString());
		paramList.setValue(param[22].toString());
		paramList.setValue(param[23].toString());
		paramList.setValue(param[24].toString());
		paramList.setValue(param[25].toString());
		paramList.setValue(param[26].toString());
		paramList.setValue(param[27].toString());
		paramList.setValue(param[28].toString());
		paramList.setValue(param[29].toString());
		paramList.setValue(param[30].toString());
		paramList.setValue(param[31].toString());
		paramList.setValue(param[32].toString());
		paramList.setValue(param[33].toString());
		paramList.setValue(param[34].toString());

		// DBアクセスを実行します
		db_ZM_T_TAKNKIKI_WK.executeBySqlDefine(paramList, ZM_T_TAKNKIKI_WK_ZM_INSERT_001);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	/* ++++++++++ v1.0.0 追加終了 ++++++++++ */
}
