/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKDensoEquipInfPrgAdd
*	ソースファイル名	：JBSbatKKDensoEquipInfPrgAdd.java
*	作成者				：富士通　
*	作成日				：2011年08月16日
*＜機能概要＞
*　伝送設備情報進捗登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/08/16	FJ）庭山	新規作成
*	v1.01.00	2012/02/14  FJ)神吉 	ST2-2012-0000196障害対応
*	v3.00.00	2012/05/01	FJ)岡田		【巻�@登録テーブル項目同期】対応
*	v3.01.00	2012/06/26  FJ)岡田		【SGY-2012-0000037】住所変更対応
*	v3.02.00	2012/06/26  FJ)藤本		【ST1-2012-0000263】サービス契約の抽出修正
*	v4.00.00	2012/10/25  FJ)桑島		【ANK-1223-00-00】進捗設定変更
*	v4.01.00	2012/12/28  FJ)岡田		【IT1-2012-0002603】障害対応
*	v4.02.00	2012/12/29  FJ)中作		【ST4-2012-0000301】障害対応
*	v4.03.00	2013/01/25  FJ)岡田		【ST3-2013-0000137】障害対応
*	v4.04.00	2013/03/22  FJ)中作 	【IT1-2013-0000498】障害対応
*	v5.00.00	2013/09/18	FJ)石原		【OM-2013-0002386】障害対応
*	v6.00.00	2013/12/14	FJ)神吉		【OM-2013-0004528】障害対応
**********************************************************************/
package eo.business.service;

import java.util.HashMap;
import java.util.Map;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JKKBatCommon;
import eo.business.util.file.JBSbatKKIFM090;
import eo.business.util.table.JBSbatKK_T_KAISEN_TG_SVKEI;
import eo.business.util.table.JBSbatKU_T_KOJIAK;
import eo.business.util.table.JBSbatKU_T_MSKM_DTL_KOJIAK;
import eo.business.util.table.JBSbatKU_T_SVKEI_KOJIAK;
import eo.common.util.JPCFomatString;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JBSbatOracleSeqUtil;
import eo.framework.util.JBSbatStringUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKDensoEquipInfPrgAdd extends JBSbatBusinessService
{
	/**
	 * シーケンスID（進捗）
	 */
	private static final String SEQ_ID = "SEQ_PRG_NO";

	/**
	 * 進捗ステータス（起点変電所コード取込完了）
	 */
	private static final String PRG_STAT = "9560";

	/**
	 * 進捗特記事項２編集定義
	 */
	private static final String PRG_TKJK = "連携日：%1$s 起点変電所コード：%2$s";

	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(進捗)*/
	private static final String D_TBL_NAME_KK_T_PRG = "KK_T_PRG";

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

    /** テーブル(工事案件)*/
	private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";

	/** テーブルアクセスクラス(進捗)*/
	private JBSbatSQLAccess db_KK_T_PRG = null;
	
	/** テーブルアクセスクラス(工事案件)*/
	private JBSbatSQLAccess db_KU_T_KOJIAK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** テーブルアクセスクラス(共通部品)*/
	private JBSbatSQLAccess stmt = null;
	
	/**
	 * 進捗登録サービス契約番号重複チェック用Map
	 */
	private Map<String, String> svcKeiNoMap = null;
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_KK_T_PRG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
		db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// 共通部品用
		stmt = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
		
		// 進捗登録サービス契約番号重複チェック用Mapを作成します。
		svcKeiNoMap = new HashMap<String, String>();
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		super.logPrint.printDebugLog("execute_START");

		JBSbatCommonDBInterface map = null;
		
		JBSbatCommonDBInterface kojiakMap = null;

		String sys_dtm = JCCBatCommon.getSysDateTimeStamp();
		String rnki_ymd = JPCFomatString.formatDate(JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM090.RNKI_YMD)));

		// 進捗特記事項２
		String prg_tkjk2 = String.format(PRG_TKJK, rnki_ymd, JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM090.KITEN_HDSHO_CD)));
		
		String kojiakNo = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM090.KOJIAK_NO));
		
		// 進捗作成情報を工事案件から取得します。
		map = serchKojiak(kojiakNo);
		
		// 進捗作成情報の抽出結果がなしの場合でも進捗への書き込みを行う。
		if (map == null)
		{
			
			// 進捗番号の採番をします。
			String seq_no = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(super.commonItem.getConnection(), SEQ_ID), 12);
			
			// 進捗へ登録処理を行います。
			String[] value = new String[33];
			
			value[0] = seq_no;
			value[1] = " ";															// 申込明細番号
			value[2] = "";															// 請求契約番号
			value[3] = "";															// 請求方法番号（口座）
			value[4] = "";															// 請求方法番号（クレジットカード）
			value[5] = " ";															// サービス契約番号
			value[6] = "";															// サービス契約内訳番号
			value[7] = "";															// サービス契約回線内訳番号
			value[8] = "";															// 機器提供サービス契約番号
			value[9] = "";															// オプションサービス契約番号
			value[10] = "";															// 請求オプションサービス契約番号
			value[11] = "";															// サブオプションサービス契約番号
			value[12] = "";															// 割引サービス契約番号
			value[13] = " ";														// 異動区分
			value[14] = " ";														// 異動年月日時分秒
			value[15] = PRG_STAT;													// 進捗ステータス
			value[16] = super.opeDate + sys_dtm.substring(8);						// 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
			value[17] = "";															// 進捗メモ
			value[18] = "";															// 進捗特記事項１
			value[19] = prg_tkjk2;													// 進捗特記事項２
			value[20] = sys_dtm;													// 登録年月日時分秒
			value[21] = super.batchUserId;											// 登録オペレータアカウント
			value[22] = sys_dtm;													// 更新年月日時分秒
			value[23] = super.batchUserId;											// 更新オペレータアカウント
			value[24] = "";															// 削除年月日時分秒
			value[25] = "";															// 削除オペレータアカウント
			value[26] = "0";														// 無効フラグ
			value[27] = "";															// 登録運用年月日
			value[28] = "";															// 登録処理ID
			value[29] = "";															// 更新運用年月日
			value[30] = "";															// 更新処理ID
			value[31] = "";															// 削除運用年月日
			value[32] = "";															// 削除処理ID
			
			executeKK_T_PRG_PKINSERT(value);
			
		}
		
		// 取得件数分、以下の処理を行います。
		while (map != null)
		{
			String svcKeiNo = JBSbatStringUtil.Rtrim(map.getString(JBSbatKU_T_SVKEI_KOJIAK.SVC_KEI_NO));
			super.logPrint.printDebugLog("svcKeiNo：" + svcKeiNo);
			
			// サービス契約番号の重複チェックを行います。
			if (svcKeiNoMap.containsKey(svcKeiNo))
			{
				// 同一サービス契約番号で既に進捗登録済の場合、スキップします。
				map = db_KU_T_KOJIAK.selectNext();
				super.logPrint.printDebugLog("★同一サービス契約番号で既に進捗登録済。スキップ");
				continue;
			}
			
			// 進捗番号の採番をします。
			String seq_no = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(super.commonItem.getConnection(), SEQ_ID), 12);
			
			//共通部品（進捗.異動年月日取得部品）より異動年月日時分秒（またはシステム日付）を取得
			String idoDtm = JKKBatCommon. getIdoDtmMax(commonItem, 
					JBSbatStringUtil.Rtrim(map.getString(JBSbatKU_T_SVKEI_KOJIAK.SVC_KEI_NO)), JBSbatStringUtil.Rtrim(map.getString(JBSbatKU_T_KOJIAK.KOJI_UK_OPTNTY_IDO_DIV)), stmt);
			
			// 進捗へ登録処理を行います。
			String[] value = new String[33];
			
			value[0] = seq_no;
			value[1] = "";															// 申込明細番号
			value[2] = "";															// 請求契約番号
			value[3] = "";															// 請求方法番号（口座）
			value[4] = "";															// 請求方法番号（クレジットカード）
			value[5] = svcKeiNo;													// サービス契約番号
			value[6] = "";															// サービス契約内訳番号
			value[7] = "";															// サービス契約回線内訳番号
			value[8] = "";															// 機器提供サービス契約番号
			value[9] = "";															// オプションサービス契約番号
			value[10] = "";															// 請求オプションサービス契約番号
			value[11] = "";															// サブオプションサービス契約番号
			value[12] = "";															// 割引サービス契約番号
			value[13] = JBSbatStringUtil.Rtrim(map.getString(JBSbatKU_T_KOJIAK.KOJI_UK_OPTNTY_IDO_DIV));	// 工事受付契機異動区分
			value[14] = idoDtm;														// 異動年月日時分秒
			value[15] = PRG_STAT;													// 進捗ステータス
			value[16] = super.opeDate + sys_dtm.substring(8);						// 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
			value[17] = "";															// 進捗メモ
			value[18] = "";															// 進捗特記事項１
			value[19] = prg_tkjk2;													// 進捗特記事項２
			value[20] = sys_dtm;													// 登録年月日時分秒
			value[21] = super.batchUserId;											// 登録オペレータアカウント
			value[22] = sys_dtm;													// 更新年月日時分秒
			value[23] = super.batchUserId;											// 更新オペレータアカウント
			value[24] = "";															// 削除年月日時分秒
			value[25] = "";															// 削除オペレータアカウント
			value[26] = "0";														// 無効フラグ
			value[27] = "";															// 登録運用年月日
			value[28] = "";															// 登録処理ID
			value[29] = "";															// 更新運用年月日
			value[30] = "";															// 更新処理ID
			value[31] = "";															// 削除運用年月日
			value[32] = "";															// 削除処理ID
			
			executeKK_T_PRG_PKINSERT(value);
			
			// 進捗登録サービス契約番号重複チェック用Mapに進捗登録済サービス契約番号を格納します。
			svcKeiNoMap.put(svcKeiNo, svcKeiNo);
			
			map = db_KU_T_KOJIAK.selectNext();
		}
		
		super.logPrint.printDebugLog("execute_END");

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

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/

	/**
	 * SQLKEY(KK_SELECT_032)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	サービス契約_工事案件適用開始年月日
	 *		 	サービス契約_工事案件適用終了年月日
	 *		 	工事案件番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKU_T_KOJIAK_KK_SELECT_032(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

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

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	進捗番号				PRG_NO
	 *		 	申込明細番号				MSKM_DTL_NO
	 *		 	請求契約番号				SEIKY_KEI_NO
	 *		 	請求方法番号（口座）				SEIKY_WAY_NO_KOZA
	 *		 	請求方法番号（クレジットカード）				SEIKY_WAY_NO_CRECARD
	 *		 	サービス契約番号				SVC_KEI_NO
	 *		 	サービス契約内訳番号				SVC_KEI_UCWK_NO
	 *		 	サービス契約回線内訳番号				SVC_KEI_KAISEN_UCWK_NO
	 *		 	機器提供サービス契約番号				KKTK_SVC_KEI_NO
	 *		 	オプションサービス契約番号				OP_SVC_KEI_NO
	 *		 	請求オプションサービス契約番号				SEIOPSVC_KEI_NO
	 *		 	サブオプションサービス契約番号				SBOP_SVC_KEI_NO
	 *		 	割引サービス契約番号				WRIB_SVC_KEI_NO
	 *		 	異動区分				IDO_DIV
	 *		 	異動年月日時分秒				IDO_DTM
	 *		 	進捗ステータス				PRG_STAT
	 *		 	進捗年月日時分秒				PRG_DTM
	 *		 	進捗メモ				PRG_MEMO
	 *		 	進捗特記事項１				PRG_TKJK_1
	 *		 	進捗特記事項２				PRG_TKJK_2
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 *		 	登録運用年月日				ADD_UNYO_YMD
	 *		 	登録処理ＩＤ				ADD_TRN_ID
	 *		 	更新運用年月日				UPD_UNYO_YMD
	 *		 	更新処理ＩＤ				UPD_TRN_ID
	 *		 	削除運用年月日				DEL_UNYO_YMD
	 *		 	削除処理ＩＤ				DEL_TRN_ID
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_PRG_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("PRG_NO", setParam[0]);
		setMap.setValue("MSKM_DTL_NO", setParam[1]);
		setMap.setValue("SEIKY_KEI_NO", setParam[2]);
		setMap.setValue("SEIKY_WAY_NO_KOZA", setParam[3]);
		setMap.setValue("SEIKY_WAY_NO_CRECARD", setParam[4]);
		setMap.setValue("SVC_KEI_NO", setParam[5]);
		setMap.setValue("SVC_KEI_UCWK_NO", setParam[6]);
		setMap.setValue("SVC_KEI_KAISEN_UCWK_NO", setParam[7]);
		setMap.setValue("KKTK_SVC_KEI_NO", setParam[8]);
		setMap.setValue("OP_SVC_KEI_NO", setParam[9]);
		setMap.setValue("SEIOPSVC_KEI_NO", setParam[10]);
		setMap.setValue("SBOP_SVC_KEI_NO", setParam[11]);
		setMap.setValue("WRIB_SVC_KEI_NO", setParam[12]);
		setMap.setValue("IDO_DIV", setParam[13]);
		setMap.setValue("IDO_DTM", setParam[14]);
		setMap.setValue("PRG_STAT", setParam[15]);
		setMap.setValue("PRG_DTM", setParam[16]);
		setMap.setValue("PRG_MEMO", setParam[17]);
		setMap.setValue("PRG_TKJK_1", setParam[18]);
		setMap.setValue("PRG_TKJK_2", setParam[19]);
		setMap.setValue("ADD_DTM", setParam[20]);
		setMap.setValue("ADD_OPEACNT", setParam[21]);
		setMap.setValue("UPD_DTM", setParam[22]);
		setMap.setValue("UPD_OPEACNT", setParam[23]);
		setMap.setValue("DEL_DTM", setParam[24]);
		setMap.setValue("DEL_OPEACNT", setParam[25]);
		setMap.setValue("MK_FLG", setParam[26]);
		setMap.setValue("ADD_UNYO_YMD", setParam[27]);
		setMap.setValue("ADD_TRN_ID", setParam[28]);
		setMap.setValue("UPD_UNYO_YMD", setParam[29]);
		setMap.setValue("UPD_TRN_ID", setParam[30]);
		setMap.setValue("DEL_UNYO_YMD", setParam[31]);
		setMap.setValue("DEL_TRN_ID", setParam[32]);
	
		// DBアクセスを実行します
		db_KK_T_PRG.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * 進捗作成情報を抽出します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.DBアクセスを実行します。<br>
	 *
	 * </pre>
	 * <p>
	 * @param kojiakNo　工事案件番号。
	 * @return JBSbatCommonDBInterface　検索結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface serchKojiak(String kojiakNo) throws Exception
	{
		super.logPrint.printDebugLog("serchSvcKei_START");
		super.logPrint.printDebugLog("param[0] b_date ：" + super.opeDate);
		super.logPrint.printDebugLog("param[1] b_date ：" + super.opeDate);
		super.logPrint.printDebugLog("param[2] kojiakNo ：" + kojiakNo);
		
		String[] param = new String[3];
		JBSbatCommonDBInterface map = null;

		// バインド変数を設定します
		param[0] = super.opeDate;
		param[1] = super.opeDate;
		param[2] = kojiakNo;

		// 検索を実行します
		executeKU_T_KOJIAK_KK_SELECT_032(param);
		map = db_KU_T_KOJIAK.selectNext();

//		// 未取得の場合、ログ出力し処理をスキップします。
//		if (map == null)
//		{
//			String value = "進捗作成対象サービス契約未存在 サービス契約回線内訳番号：" + svc_no + " 工事案件番号：" + koji_no;
//			super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB0010CW, new String[]{value});
//			throw new JBSbatBusinessError();
//		}

		super.logPrint.printDebugLog("serchSvcKei_END");
		
		return map;
	}

}