/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatZMKitenHdshoWkIktAdd
*	ソースファイル名	：JBSbatZMKitenHdshoWkIktAdd.java
*	作成者				：富士通　
*	作成日				：2016年10月11日
*＜機能概要＞
*　起点変電所ワーク一括登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v27.00.00	2016/10/11	FJ)謝		【ANK-2872-00-00】【随時機能化案件】起点変電所マスタメンテ機能化 新規作成
*********************************************************************/
package eo.business.service;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.common.JZMBatConst;
import eo.business.util.file.JBSbatZMIFM035;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI;
import eo.business.util.table.JBSbatZM_T_SHYAKK_WK;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatInputFileUtil;
import eo.framework.item.JBSbatCommonDBInterface;
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;
import eo.framework.util.JBSbatCheckUtil;
import eo.framework.util.JBSbatDateUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatZMKitenHdshoWkIktAdd extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(集約局ワーク)*/
	private static final String D_TBL_NAME_ZM_T_SHYAKK_WK = "ZM_T_SHYAKK_WK";

	/** テーブル(コード名称管理)*/
	private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";

	/** テーブル(起点変電所ワーク)*/
	private static final String D_TBL_NAME_ZM_T_KITEN_HDSHO_WK = "ZM_T_KITEN_HDSHO_WK";

	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

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

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

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

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

	/** テーブルアクセスクラス(集約局ワーク)*/
	private JBSbatSQLAccess db_ZM_T_SHYAKK_WK = null;

	/** テーブルアクセスクラス(コード名称管理)*/
	private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI_004 = null;

	/** テーブルアクセスクラス(コード名称管理)*/
	private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI_005 = null;

	/** テーブルアクセスクラス(起点変電所ワーク)*/
	private JBSbatSQLAccess db_ZM_T_KITEN_HDSHO_WK = null;

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** 起点変電所ワーク一括登録リスト定義ファイル名 */
	private static final String ZMIFM035_DEF = "ZMIFM035.def";
	
	/** 起点変電所ワーク一括登録結果リストファイル名 */
	private static final String ZMIFM036_NAME = "ZMIFM036.csv";
	
	/** ファイルコード */
	private static final String FILE_CD = "0000";
	
	/** 処理管理番号 */
	private static final String TRN_KANRI_NO = "000000000156";
	
	/** ファイル名編集用 */
	private static final String FILE_NM = "起点変電所ワーク一括登録結果リスト_yyyyMMddHHmmss.csv";
	
	/** ファイル名で利用するタイムスタンプのフォーマット */
	private static final String FILE_TIMESTAMP_FORMAT = "yyyyMMddHHmmss";
	
	/** 起点変電所ワーク一括登録結果リストファイルオブジェクト */
	private JBSbatBusinessFileUtil zmifm036FileObj = null;
	
	/** 起点変電所ワーク一括登録結果リストファイルレコード件数 */
	private int zmifm036RecordCnt = 0;
	
	/** 集約局コードリスト */
	private HashSet<String> shyakkCdList = null;
	
	/** 「可否」のコード区分リスト */
	private HashSet<String> khCdDivList = null;
	
	/** 「親PONバージョン識別コード」のコード区分リスト */
	private HashSet<String> oyaPonVsnSkcdCdDivList = null;

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

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

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// ディレイド処理依頼情報リストを取得する
		List<HashMap<String, Object>> shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, this.jobid);
		
		// ディレイド処理依頼情報リストが取得できない場合、処理を終了する
		if (null == shoriIraiList)
		{
			return null;
		}
		
		// 集約局コードリストを取得する
		getShyakkCdList();
		
		// 「可否」のコード区分リストを取得する
		getKhCdDivList();
		
		// 「親PONバージョン識別コード」のコード区分リストを取得する
		getOyaPonVsnSkcdCdDivList();
		
		// フリー項目を取得する
		String[] freeItems = freeItem.split(JZMBatConst.S_PARAM_DELIM);
		
		// 起点変電所ワーク一括登録結果リストファイルパス
		String zmifm036FilePath = freeItems[0] + ZMIFM036_NAME;
		
		// 起点変電所ワーク一括登録リスト定義ファイル名を取得する
		String zmifm035DefName = JBSbatAplConst.getAplConstValue(JZMBatConst.BAT_ID_IND) + ZMIFM035_DEF;
		
		// ディレイド処理依頼情報リストの件数分繰り返す
		for (HashMap<String, Object> shoriIrai : shoriIraiList)
		{
			// チェックエラーフラグ
			boolean checkErrFlg = false;
			
			// 電子ファイル管理から起点変電所ワーク一括登録リストファイルを取得する
			String zmifm035FilePath = JCCBatCommon.searchDenshiFile(commonItem, (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO));
			
			// 起点変電所ワーク一括登録リストファイルオブジェクトを生成する
			JBSbatInputFileUtil zmifm035FileUtil = new JBSbatInputFileUtil(zmifm035FilePath);
			
			// 起点変電所ワーク一括登録リスト定義ファイルオブジェクトを生成する
			JBSbatDefFileUtil zmifm035FileDef = new JBSbatDefFileUtil(zmifm035DefName, zmifm035FileUtil);
			
			// 起点変電所ワーク一括登録結果リストファイルオブジェクトを生成する
			zmifm036FileObj = JCCBatCommon.createBusinessFileUtil(zmifm036FilePath, JZMBatConst.SJIS, JZMBatConst.CRLF, JZMBatConst.CONMA);
			
			// 起点変電所ワーク一括登録リストファイルレコード件数
			int zmifm035RecordCnt = 0;
			
			// 起点変電所ワーク一括登録結果リストファイルレコード件数
			zmifm036RecordCnt = 0;
			
			// Readerオブジェクトを生成する
			zmifm035FileUtil.createReader();
			
			// 起点変電所ワーク一括登録リストファイルの件数分繰り返す
			while (zmifm035FileUtil.ready())
			{
				// ファイルから１レコードを取得する
				String line = zmifm035FileUtil.readLine();
				
				// 起点変電所ワーク一括登録リストファイルレコード件数カウント
				zmifm035RecordCnt++;
				
				// １レコードの情報をマップに格納する
				JBSbatServiceInterfaceMap recordMap = zmifm035FileDef.lineToObject(line, zmifm035FileUtil, zmifm035RecordCnt);
				
				// フォーマットチェックを行う
				if (recordMap.isInputErrorFlg())
				{
					// 起点変電所ワーク一括登録結果リストを出力する
					String[] data = line.split(JZMBatConst.CONMA);
					int len = data[0].length();
					if (1 < len)
					{
						createZmifm036(data[0].substring(1, len - 1), "ＮＧ", "フォーマットエラー");
					}
					else
					{
						createZmifm036("", "ＮＧ", "フォーマットエラー");
					}
					checkErrFlg = true;
					continue;
				}
				
				String kitenHdshoCd  = (String)recordMap.getMap().get(JBSbatZMIFM035.KITEN_HDSHO_CD);		// 起点変電所コード
				String shyakkCd      = (String)recordMap.getMap().get(JBSbatZMIFM035.SHYAKK_CD);			// 集約局コード
				String geponUseKh    = (String)recordMap.getMap().get(JBSbatZMIFM035.GEPON_USE_KH);			// GE-PON利用可否
				String oyaPonVsnSkcd = (String)recordMap.getMap().get(JBSbatZMIFM035.OYA_PON_VSN_SKCD);		// 親PONバージョン識別コード
				
				// 単項目チェック仕様を設定する
				LinkedHashMap<String, String[]> hashData = propertiesZmifm035();
				
				// 単項目チェックを行う
				if (isSingleCheck(recordMap.getMap(), hashData, kitenHdshoCd))
				{
					checkErrFlg = true;
					continue;
				}
				
				// 起点変電所ワークのPK検索を行う
				String[] selectWhereParam = new String[1];
				selectWhereParam[0] = kitenHdshoCd;			// 起点変電所コード
				JBSbatCommonDBInterface kitenHdshoWkMap = executeZM_T_KITEN_HDSHO_WK_PKSELECT(selectWhereParam);
				
				// 起点変電所ワークのPK検索結果ありの場合
				if (null != kitenHdshoWkMap)
				{
					// 起点変電所ワークのPK更新を行う
					String[] updateWhereParam = new String[1];
					String[] updateSetParam = new String[3];
					updateWhereParam[0] = kitenHdshoCd;		// 起点変電所コード
					updateSetParam[0] = shyakkCd;			// 集約局コード
					updateSetParam[1] = geponUseKh;			// GE-PON利用可否
					updateSetParam[2] = oyaPonVsnSkcd;		// 親PONバージョン識別コード
					executeZM_T_KITEN_HDSHO_WK_PKUPDATE(updateSetParam, updateWhereParam);
				}
				// 起点変電所ワークのPK検索結果なしの場合
				else
				{
					// 起点変電所ワークの全項目登録を行う
					String[] insertSetParam = new String[17];
					insertSetParam[0] = kitenHdshoCd;		// 起点変電所コード
					insertSetParam[1] = shyakkCd;			// 集約局コード
					insertSetParam[2] = geponUseKh;			// GE-PON利用可否
					insertSetParam[16] = oyaPonVsnSkcd;		// 親PONバージョン識別コード
					executeZM_T_KITEN_HDSHO_WK_PKINSERT(insertSetParam);
				}
				
				// 起点変電所ワーク一括登録結果リストを出力する
				createZmifm036(kitenHdshoCd, "ＯＫ", "");
			}
			
			// 起点変電所ワーク一括登録結果リストを閉じる
			JCCBatCommon.closeBusinessFileUtil(zmifm036FileObj);
			
			// ディレイド処理依頼番号
			String shoriIraiNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO);
			
			// ディレイド処理依頼結果更新
			// チェックエラーフラグがtrueの場合
			if (checkErrFlg)
			{
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JZMBatConst.DLYD_TRN_RSLT_CD_APP_ERR, null);
			}
			// チェックエラーフラグがfalseの場合
			else
			{
				JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JZMBatConst.DLYD_TRN_RSLT_CD_COMPLETE, null);
			}
			
			// 電子ファイル管理登録処理
			JBSbatCommonItem arg0 = commonItem;								// 業務共通電文
			String arg1 = FILE_CD;											// ファイルコード
			String arg2 = zmifm036FilePath;									// ファイルパス
			String arg3 = JBSbatDateUtil.adjustMonth(super.opeDate, 1);		// ファイル削除年月日（運用日付 + 1ヶ月）
			String[] rc = JCCBatCommon.createDenshiFile(arg0, arg1, arg2, arg3);
			
			// ログ出力
			super.logPrint.printDebugLog("電子ファイル管理番号(" + rc[0] +  ")、世代登録年月日時分秒(" + rc[1] + ")");
			
			// システム日時を取得する
			String sysDateTime = JCCBatCommon.getSysDateTime();
			
			// ダウンロードファイル管理登録処理
			String[] insertSetParam2 = new String[5];
			String fileName = FILE_NM .replaceAll(FILE_TIMESTAMP_FORMAT, sysDateTime);
			insertSetParam2[0] = TRN_KANRI_NO;							// 処理管理番号
			insertSetParam2[1] = fileName;								// ファイル名
			insertSetParam2[2] = String.valueOf(zmifm036RecordCnt);		// データ件数
			insertSetParam2[3] = rc[0];									// 電子ファイル管理番号
			insertSetParam2[4] = rc[1];									// 世代登録年月日時分秒
			executeZM_T_DL_FILE_KANRI_ZM_INSERT_001(insertSetParam2);
			
			// 一時ファイルを削除する
			File zmifm036File = new File(zmifm036FilePath);
			if (zmifm036File.exists())
			{
				zmifm036File.delete();
			}
		}
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

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

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

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

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

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

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

	/**
	 * PK(ＰＫ　検索)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KITEN_HDSHO_CD
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @return JBSbatCommonDBInterface 検索の結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeZM_T_KITEN_HDSHO_WK_PKSELECT(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("KITEN_HDSHO_CD", whereParam[0]);

		// DBアクセスを実行します
		return db_ZM_T_KITEN_HDSHO_WK.selectByPrimaryKeysForUpdateWait(whereMap);
	}

	/**
	 * PK(ＰＫ　更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	集約局コード				SHYAKK_CD
	 *		 	ＧＥ−ＰＯＮ利用可否				GEPON_USE_KH
	 *		 	親ＰＯＮバージョン識別コード				OYA_PON_VSN_SKCD
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KITEN_HDSHO_CD
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_KITEN_HDSHO_WK_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("SHYAKK_CD", setParam[0]);
		setMap.setValue("GEPON_USE_KH", setParam[1]);
		setMap.setValue("OYA_PON_VSN_SKCD", setParam[2]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("KITEN_HDSHO_CD", whereParam[0]);

		// DBアクセスを実行します
		db_ZM_T_KITEN_HDSHO_WK.updateByPrimaryKeys(whereMap, setMap);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	起点変電所コード				KITEN_HDSHO_CD
	 *		 	集約局コード				SHYAKK_CD
	 *		 	ＧＥ−ＰＯＮ利用可否				GEPON_USE_KH
	 *		 	登録年月日時分秒				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
	 *		 	親ＰＯＮバージョン識別コード				OYA_PON_VSN_SKCD
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_KITEN_HDSHO_WK_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("KITEN_HDSHO_CD", setParam[0]);
		setMap.setValue("SHYAKK_CD", setParam[1]);
		setMap.setValue("GEPON_USE_KH", setParam[2]);
		setMap.setValue("ADD_DTM", setParam[3]);
		setMap.setValue("ADD_OPEACNT", setParam[4]);
		setMap.setValue("UPD_DTM", setParam[5]);
		setMap.setValue("UPD_OPEACNT", setParam[6]);
		setMap.setValue("DEL_DTM", setParam[7]);
		setMap.setValue("DEL_OPEACNT", setParam[8]);
		setMap.setValue("MK_FLG", setParam[9]);
		setMap.setValue("ADD_UNYO_YMD", setParam[10]);
		setMap.setValue("ADD_TRN_ID", setParam[11]);
		setMap.setValue("UPD_UNYO_YMD", setParam[12]);
		setMap.setValue("UPD_TRN_ID", setParam[13]);
		setMap.setValue("DEL_UNYO_YMD", setParam[14]);
		setMap.setValue("DEL_TRN_ID", setParam[15]);
		setMap.setValue("OYA_PON_VSN_SKCD", setParam[16]);
	
		// DBアクセスを実行します
		db_ZM_T_KITEN_HDSHO_WK.insertByPrimaryKeys(setMap);
	}

	/**
	 * SQLKEY(ZM_INSERT_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 executeZM_T_DL_FILE_KANRI_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());

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

	/**
	 * 起点変電所ワーク一括登録結果リストを出力する。<br>
	 * @param kitenHdshoCd 起点変電所コード
	 * @param addRslt 登録結果
	 * @param rsltNaiyo 結果内容
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void createZmifm036(String kitenHdshoCd, String addRslt, String rsltNaiyo) throws Exception
	{
		ArrayList<String> outputInfo = new ArrayList<String>();
		
		outputInfo.add(kitenHdshoCd);			// 起点変電所コード
		outputInfo.add(addRslt);				// 登録結果
		outputInfo.add(rsltNaiyo);				// 結果内容
		
		JCCBatCommon.printDoubleQuoteBusinessFileUtil(zmifm036FileObj, outputInfo);
		zmifm036RecordCnt++;
	}

	/**
	 * 集約局ワークより集約局コードリストを取得する。<br>
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void getShyakkCdList() throws Exception
	{
		shyakkCdList = new HashSet<String>();
		
		// SQL実行
		String[] whereParam = new String[0];
		executeZM_T_SHYAKK_WK_ZM_SELECT_002(whereParam);
		
		// 集約局コードリストに集約局コードを設定する
		JBSbatCommonDBInterface dbMap = db_ZM_T_SHYAKK_WK.selectNext();
		while(null != dbMap)
		{
			shyakkCdList.add(dbMap.getString(JBSbatZM_T_SHYAKK_WK.SHYAKK_CD));
			dbMap = db_ZM_T_SHYAKK_WK.selectNext();
		}
	}

	/**
	 * 「可否」のコード区分リストを取得する。<br>
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void getKhCdDivList() throws Exception
	{
		khCdDivList = new HashSet<String>();
		
		// SQL実行
		String[] whereParam = new String[2];
		whereParam[0] = super.opeDate;			// 運用日付
		whereParam[1] = super.opeDate;			// 運用日付
		executeZM_M_CD_NM_KANRI_ZM_SELECT_004(whereParam);
		
		// 「可否」のコード区分リストにコード区分を設定する
		JBSbatCommonDBInterface dbMap = db_ZM_M_CD_NM_KANRI_004.selectNext();
		while(null != dbMap)
		{
			khCdDivList.add(dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV));
			dbMap = db_ZM_M_CD_NM_KANRI_004.selectNext();
		}
	}

	/**
	 * 「親PONバージョン識別コード」のコード区分リストを取得する。<br>
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private void getOyaPonVsnSkcdCdDivList() throws Exception
	{
		oyaPonVsnSkcdCdDivList = new HashSet<String>();
		
		// SQL実行
		String[] whereParam = new String[2];
		whereParam[0] = super.opeDate;			// 運用日付
		whereParam[1] = super.opeDate;			// 運用日付
		executeZM_M_CD_NM_KANRI_ZM_SELECT_005(whereParam);
		
		// 「親PONバージョン識別コード」のコード区分リストにコード区分を設定する
		JBSbatCommonDBInterface dbMap = db_ZM_M_CD_NM_KANRI_005.selectNext();
		while(null != dbMap)
		{
			oyaPonVsnSkcdCdDivList.add(dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV));
			dbMap = db_ZM_M_CD_NM_KANRI_005.selectNext();
		}
	}

	/**
	 * パラメタのチェックのためハッシュを作成する。<br>
	 * @return LinkedHashMap 起点変電所ワーク一括登録リストのハッシュマップ
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private LinkedHashMap<String, String[]> propertiesZmifm035() throws Exception
	{
		LinkedHashMap<String, String[]> hashData = new LinkedHashMap<String, String[]>();
		
		// 起点変電所コード
		String[] value = new String[5];
		value[0] = "起点変電所コード";					// 項目名
		value[1] = "1";									// 必須フラグ
		value[2] = "hannkakuesuuji1";					// 形式
		value[3] = "8";									// 最小桁数
		value[4] = "8";									// 最大桁数
		hashData.put(JBSbatZMIFM035.KITEN_HDSHO_CD, value);
		
		// 集約局コード
		value = new String[5];
		value[0] = "集約局コード";						// 項目名
		value[1] = "1";									// 必須フラグ
		value[2] = "hannkakuesuuji1";					// 形式
		value[3] = "2";									// 最小桁数
		value[4] = "2";									// 最大桁数
		hashData.put(JBSbatZMIFM035.SHYAKK_CD, value);
		
		// GE-PON利用可否
		value = new String[5];
		value[0] = "GE-PON利用可否";					// 項目名
		value[1] = "1";									// 必須フラグ
		value[2] = "hannkakuesuuji1";					// 形式
		value[3] = "1";									// 最小桁数
		value[4] = "1";									// 最大桁数
		hashData.put(JBSbatZMIFM035.GEPON_USE_KH, value);
		
		// 親PONバージョン識別コード
		value = new String[5];
		value[0] = "親PONバージョン識別コード";			// 項目名
		value[1] = "1";									// 必須フラグ
		value[2] = "hannkakuesuuji1";					// 形式
		value[3] = "1";									// 最小桁数
		value[4] = "1";									// 最大桁数
		hashData.put(JBSbatZMIFM035.OYA_PON_VSN_SKCD, value);
		return hashData;
	}

	/**
	 * パラメタの単項目チェックを行う。<br>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたHashMap
	 * @param arrHash チェックするデータの属性
	 * @param kitenHdshoCd 起点変電所コード
	 * @return boolean false：エラーなし、true：エラーあり
	 * @throws Exception メソッド内で発生した例外全般。
	 */
	private boolean isSingleCheck(HashMap rsMap, LinkedHashMap<String, String[]> arrHash, String kitenHdshoCd) throws Exception
	{
		String key = "";
		String strValue = "";
		String min = "";
		String max = "";
		boolean singleCheckErrFlg = false;
		Iterator<String> iterator = arrHash.keySet().iterator();
		while(iterator.hasNext())
		{
			key = iterator.next();
			strValue = (String)rsMap.get(key);
			
			// 必須チェック
			if ("1".equals(arrHash.get(key)[1]))
			{
				if (!JCCBatCommon.isNotNull(strValue))
				{
					// 起点変電所ワーク一括登録結果リストを出力する
					createZmifm036(kitenHdshoCd, "ＮＧ", "必須エラー（" + arrHash.get(key)[0] + "）");
					singleCheckErrFlg = true;
					continue;
				}
			}
			
			if (JCCBatCommon.isNotNull(strValue))
			{
				min = arrHash.get(key)[3];
				max = arrHash.get(key)[4];
				
				// 桁数チェック
				if (!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", min, max}))
				{
					// 起点変電所ワーク一括登録結果リストを出力する
					createZmifm036(kitenHdshoCd, "ＮＧ", "桁数エラー（" + arrHash.get(key)[0] + "）");
					singleCheckErrFlg = true;
					continue;
				}
				
				// 形式チェック
				if (!JBSbatCheckUtil.invoke(strValue, new String[]{arrHash.get(key)[2]}))
				{
					// 起点変電所ワーク一括登録結果リストを出力する
					createZmifm036(kitenHdshoCd, "ＮＧ", "属性エラー（" + arrHash.get(key)[0] + "）");
					singleCheckErrFlg = true;
					continue;
				}
				
				// マスタ存在チェック
				// 集約局コード
				if (JBSbatZMIFM035.SHYAKK_CD.equals(key))
				{
					if (!shyakkCdList.contains(strValue))
					{
						// 起点変電所ワーク一括登録結果リストを出力する
						createZmifm036(kitenHdshoCd, "ＮＧ", "存在チェックエラー（" + arrHash.get(key)[0] + "）");
						singleCheckErrFlg = true;
						continue;
					}
				}
				// GE-PON利用可否
				else if (JBSbatZMIFM035.GEPON_USE_KH.equals(key))
				{
					if (!khCdDivList.contains(strValue))
					{
						// 起点変電所ワーク一括登録結果リストを出力する
						createZmifm036(kitenHdshoCd, "ＮＧ", "存在チェックエラー（" + arrHash.get(key)[0] + "）");
						singleCheckErrFlg = true;
						continue;
					}
				}
				// 親PONバージョン識別コード
				else if (JBSbatZMIFM035.OYA_PON_VSN_SKCD.equals(key))
				{
					if (!oyaPonVsnSkcdCdDivList.contains(strValue))
					{
						// 起点変電所ワーク一括登録結果リストを出力する
						createZmifm036(kitenHdshoCd, "ＮＧ", "存在チェックエラー（" + arrHash.get(key)[0] + "）");
						singleCheckErrFlg = true;
						continue;
					}
				}
			}
		}
		return singleCheckErrFlg;
	}
}