/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKKoshumoTlnRirekiAdd
*	ソースファイル名	：JBSbatKKKoshumoTlnRirekiAdd.java
*	作成者				：FJ　
*	作成日				：2011年05月12日
*＜機能概要＞
*　公衆網電話番号履歴登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/05/12   FJ			新規作成
*   v7.00.00    2014/03/18   FJ)北谷    OM-2014-0000201 過去分のデータは論理削除し、必要なデータのみ公衆網実績に取り込む
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKKBatConst;
import eo.business.util.file.JBSbatKKIFE021;
import eo.business.util.table.JBSbatKK_T_OP_SVC_KEI;
import eo.common.constant.JPCBatchMessageConstant;
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.JBSbatCheckUtil;
import eo.framework.util.JBSbatStringUtil;
import eo.framework.util.JCCbatGetSystemDateUtil;

/**
* SIPシステムより連携された公衆網電話番号履歴情報ファイルの情報を公衆網電話番号実績テーブルに登録する。 <p>
*<BR>
* @author FJ
*/
public class JBSbatKKKoshumoTlnRirekiAdd extends JBSbatBusinessService
{
	
	/** 年月日時分秒最大値*/
	// ST1-2012-0000494 MOD START
	//private static final String DATETIME_MAXVALUE = "20991231235959999";
	private static final String DATETIME_MAXVALUE = "20991231000000000";
	// ST1-2012-0000494 MOD START
	// ST1-2012-0000494 DEL START
	/** 入力ファイルの年月日時分秒最大値*/
	//private static final String INPUT_FILE_DATETIME_MAXVALUE = "0";
	// ST1-2012-0000494 DEL END
	/** 年月日時分秒フォーマット値*/
	private static final String DATETIME_FORMAT_VALUE = "000";
	// OM-2014-0000201 2014/03/18 start
	/** 時分秒最大値*/
	private static final String TIME_MAXVALUE = "000000000";
	// OM-2014-0000201 2014/03/18 end
	
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(オプションサービス契約)*/
	private static final String D_TBL_NAME_KK_T_OP_SVC_KEI = "KK_T_OP_SVC_KEI";

	/** テーブル(公衆網通話実績)*/
	private static final String D_TBL_NAME_KK_T_KOSHUMO_TW_JSK = "KK_T_KOSHUMO_TW_JSK";

	/** SQL定義キー(KK_SELECT_001)*/
	private static final String KK_T_OP_SVC_KEI_KK_SELECT_001 = "KK_SELECT_001";
	
	// OM-2014-0000201 2014/03/18 start
	/** SQL定義キー(KK_UPDATE_001)*/
	private static final String KK_T_KOSHUMO_TW_JSK_KK_UPDATE_001 = "KK_UPDATE_001";
	// OM-2014-0000201 2014/03/18 end

	/** テーブルアクセスクラス(オプションサービス契約)*/
	private JBSbatSQLAccess db_KK_T_OP_SVC_KEI = null;

	/** テーブルアクセスクラス(公衆網通話実績)*/
	private JBSbatSQLAccess db_KK_T_KOSHUMO_TW_JSK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

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

		// DBアクセスクラスを生成します
		db_KK_T_OP_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_OP_SVC_KEI);
		db_KK_T_KOSHUMO_TW_JSK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KOSHUMO_TW_JSK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// OM-2014-0000201 2014/03/18 start
		// 過去分の公衆網通話実績データは削除   全て無効フラグ１にする
		executeKK_T_KOSHUMO_TW_JSK_KK_UPDATE_001();
		// OM-2014-0000201 2014/03/18 end
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 単項目チェック関数呼出
		if (!isSingleCheckKKIFE021_INF1(inMap.getMap(), getItemvalueMap()))
		{
			// エラーフラグ設定
			super.commonItem.setErrFlg(true);
			// 出力情報を返却
			return new JBSbatOutputItem();
		}

		// 入力マップより情報を取得
		String svcKeiNo = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_KEI_NO));
		String voipUserId = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.VOIP_USER_ID));
		
		// オプションサービス契約を検索
		Object[] opSvcKeiWhereParam = {
				this.commonItem.getOpeDate(),
				voipUserId,
				svcKeiNo
			};
		executeKK_T_OP_SVC_KEI_KK_SELECT_001(opSvcKeiWhereParam);
		JBSbatCommonDBInterface opSvcKeiMap = db_KK_T_OP_SVC_KEI.selectNext();
		if (opSvcKeiMap == null)
		{
			// エラーログ出力
			// OM-2013-0000265 2013/08/23 start
			//commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0150JE, new String[]{"オプションサービス契約"});
			// 警告メッセージに変更する
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKKB0290AW, new String[]{"オプションサービス契約にレコード"});
			// OM-2013-0000265 2013/08/23 end
			// エラーフラグ設定
			super.commonItem.setErrFlg(true);
			// 出力情報を返却
			return new JBSbatOutputItem();
		}
		
		// OM-2014-0000201 2014/03/18 start
		if(registChk(inMap, opSvcKeiMap)){
			// 公衆網通話実績を登録
			insertKoshumoTwJsk(inMap, opSvcKeiMap);
		}
		// OM-2014-0000201 2014/03/18 end
		
		return new JBSbatOutputItem();
		/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 *入力情報（公衆網電話番号履歴情報ファイル）の単項目チェックを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.単項目チェックを行います。<br>
	 * 
	 * 2.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		rsMap:(項目、値)を(key、value)として、データをrsMapに入れます
	 *		itemvalueMap:埋め込み文字の値をitemvalueMapに入れます。キーの値は、以下に説明します。
	 *			 TXT-KKIFE021-INF1.SHK_TISH_KKN			公衆網電話番号履歴情報ファイル.集計対象期間
	 *			 TXT-KKIFE021-INF1.SHK_TISH_KKN			公衆網電話番号履歴情報ファイル.集計対象期間
	 *			 TXT-KKIFE021-INF1.SHK_TISH_KKN			公衆網電話番号履歴情報ファイル.集計対象期間
	 *			 TXT-KKIFE021-INF1.SVC_KEI_NO			公衆網電話番号履歴情報ファイル.サービス契約番号
	 *			 TXT-KKIFE021-INF1.SVC_KEI_NO			公衆網電話番号履歴情報ファイル.サービス契約番号
	 *			 TXT-KKIFE021-INF1.SVC_KEI_NO			公衆網電話番号履歴情報ファイル.サービス契約番号
	 *			 TXT-KKIFE021-INF1.VOIP_USER_ID			公衆網電話番号履歴情報ファイル.ＶｏＩＰユーザＩＤ
	 *			 TXT-KKIFE021-INF1.VOIP_USER_ID			公衆網電話番号履歴情報ファイル.ＶｏＩＰユーザＩＤ
	 *			 TXT-KKIFE021-INF1.VOIP_USER_ID			公衆網電話番号履歴情報ファイル.ＶｏＩＰユーザＩＤ
	 *			 TXT-KKIFE021-INF1.KOSHUMO_TELNO			公衆網電話番号履歴情報ファイル.公衆網電話番号
	 *			 TXT-KKIFE021-INF1.KOSHUMO_TELNO			公衆網電話番号履歴情報ファイル.公衆網電話番号
	 *			 TXT-KKIFE021-INF1.KOSHUMO_TELNO			公衆網電話番号履歴情報ファイル.公衆網電話番号
	 *			 TXT-KKIFE021-INF1.SVC_STA_DTM			公衆網電話番号履歴情報ファイル.サービス開始年月日時分秒
	 *			 TXT-KKIFE021-INF1.SVC_STA_DTM			公衆網電話番号履歴情報ファイル.サービス開始年月日時分秒
	 *			 TXT-KKIFE021-INF1.SVC_STA_DTM			公衆網電話番号履歴情報ファイル.サービス開始年月日時分秒
	 *			 TXT-KKIFE021-INF1.SVC_END_DTM			公衆網電話番号履歴情報ファイル.サービス終了年月日時分秒
	 *			 TXT-KKIFE021-INF1.SVC_END_DTM			公衆網電話番号履歴情報ファイル.サービス終了年月日時分秒
	 *			 TXT-KKIFE021-INF1.SVC_END_DTM			公衆網電話番号履歴情報ファイル.サービス終了年月日時分秒
	 *			 TXT-KKIFE021-INF1.SHR_DTM			公衆網電話番号履歴情報ファイル.処理日時
	 *			 TXT-KKIFE021-INF1.SHR_DTM			公衆網電話番号履歴情報ファイル.処理日時
	 *			 TXT-KKIFE021-INF1.SHR_DTM			公衆網電話番号履歴情報ファイル.処理日時
	 * </pre>
	 * <p>
	 * @param rsMap 入力データ（TXT又はDB）を格納されたHashMap。
	 * @param itemvalueMap エラーメッセージに関する項目値を格納されたHashMap。
	 * @return  boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 */
	private boolean isSingleCheckKKIFE021_INF1(HashMap rsMap, HashMap itemvalueMap)
	{
		// 単項目チェックを行います
		String strValue = null;

		// 集計対象期間項目チェック
		strValue = (String)rsMap.get("SHK_TISH_KKN");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHK_TISH_KKN")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "8"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHK_TISH_KKN")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"year_month_day1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHK_TISH_KKN")});
			return false;
		}

		// サービス契約番号項目チェック
		strValue = (String)rsMap.get("SVC_KEI_NO");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_KEI_NO")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "10"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_KEI_NO")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_KEI_NO")});
			return false;
		}

		// ＶｏＩＰユーザＩＤ項目チェック
		strValue = (String)rsMap.get("VOIP_USER_ID");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.VOIP_USER_ID")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "16"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.VOIP_USER_ID")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.VOIP_USER_ID")});
			return false;
		}

		// 公衆網電話番号項目チェック
		strValue = (String)rsMap.get("KOSHUMO_TELNO");
		// 必須チェック
		if(strValue == null || "".equals(strValue))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.KOSHUMO_TELNO")});
			return false;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "11"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.KOSHUMO_TELNO")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"tel2"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.KOSHUMO_TELNO")});
			return false;
		}

		// サービス開始年月日時分秒項目チェック
		strValue = (String)rsMap.get("SVC_STA_DTM");
		// ST1-2012-0000494 DEL START
		// 必須チェック
//		if(strValue == null || "".equals(strValue))
//		{
//			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
//															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_STA_DTM")});
//			return false;
//		}
		// ST1-2012-0000494 DEL END
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "14"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_STA_DTM")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"day_hour4"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_STA_DTM")});
			return false;
		}

		// サービス終了年月日時分秒項目チェック
		strValue = (String)rsMap.get("SVC_END_DTM");
		// ST1-2012-0000494 DEL START
		// 必須チェック
//		if(strValue == null || "".equals(strValue))
//		{
//			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
//															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_END_DTM")});
//			return false;
//		}
		// ST1-2012-0000494 DEL END
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "14"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_END_DTM")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakusuuji1"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SVC_END_DTM")});
			return false;
		}

		// 処理日時項目チェック
		strValue = (String)rsMap.get("SHR_DTM");
		// ST1-2012-0000494 DEL START
		// 必須チェック
//		if(strValue == null || "".equals(strValue))
//		{
//			commonItem.getLogPrint().printBusinessErrorLog("EKKB0060TE", new String[]{
//															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHR_DTM")});
//			return false;
//		}
		// ST1-2012-0000494 DEL END
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "14"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0070TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHR_DTM")});
			return false;
		}
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"day_hour4"}))
		{
			commonItem.getLogPrint().printBusinessErrorLog("EKKB0080TE", new String[]{
															(String)itemvalueMap.get("TXT-KKIFE021-INF1.SHR_DTM")});
			return false;
		}

		return true;
	}

	/**
	 * SQLKEY(KK_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	VoIPユーザーID
	 *		 	サービス契約番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_OP_SVC_KEI_KK_SELECT_001(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_KK_T_OP_SVC_KEI.selectBySqlDefine(paramList, KK_T_OP_SVC_KEI_KK_SELECT_001);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	集計対象年月日				SHUK_TG_YMD
	 *		 	オプションサービス契約番号				OP_SVC_KEI_NO
	 *		 	ＶＯＩＰユーザーＩＤ				VOIP_USER_ID
	 *		 	ＶＯＩＰ電話番号				VOIP_TELNO
	 *		 	サービス契約番号				SVC_KEI_NO
	 *		 	通話開始年月日時分秒				TW_STA_DTM
	 *		 	通話終了年月日時分秒				TW_END_DTM
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_KOSHUMO_TW_JSK_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("SHUK_TG_YMD", setParam[0]);
		setMap.setValue("OP_SVC_KEI_NO", setParam[1]);
		setMap.setValue("VOIP_USER_ID", setParam[2]);
		setMap.setValue("VOIP_TELNO", setParam[3]);
		setMap.setValue("KOSHUMO_TW_JSK_SKSI_DTM", setParam[4]);
		setMap.setValue("TW_STA_DTM", setParam[5]);
		setMap.setValue("TW_END_DTM", setParam[6]);
		setMap.setValue("SVC_KEI_NO", setParam[7]);
		setMap.setValue("ADD_DTM", setParam[8]);
		setMap.setValue("ADD_OPEACNT", setParam[9]);
		setMap.setValue("UPD_DTM", setParam[10]);
		setMap.setValue("UPD_OPEACNT", setParam[11]);
		setMap.setValue("DEL_DTM", setParam[12]);
		setMap.setValue("DEL_OPEACNT", setParam[13]);
		setMap.setValue("MK_FLG", setParam[14]);
		setMap.setValue("ADD_UNYO_YMD", setParam[15]);
		setMap.setValue("ADD_TRN_ID", setParam[16]);
		setMap.setValue("UPD_UNYO_YMD", setParam[17]);
		setMap.setValue("UPD_TRN_ID", setParam[18]);
		setMap.setValue("DEL_UNYO_YMD", setParam[19]);
		setMap.setValue("DEL_TRN_ID", setParam[20]);
	
		// DBアクセスを実行します
		db_KK_T_KOSHUMO_TW_JSK.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	// OM-2014-0000201 2014/03/18 start
	private void executeKK_T_KOSHUMO_TW_JSK_KK_UPDATE_001() throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();

		// DBアクセスを実行します
		db_KK_T_KOSHUMO_TW_JSK.executeBySqlDefine(paramList, KK_T_KOSHUMO_TW_JSK_KK_UPDATE_001);
	}
	// OM-2014-0000201 2014/03/18 end
	
	/**
	 * エラーメッセージに関する項目値を格納されたHashMap<String, String>を生成します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.エラーメッセージに関する項目値を格納されたHashMapを生成する。<br>
	 *
	 * 2.エラーメッセージに関する項目値を格納されたHashMapに値を設定する。<br>
	 * </pre>
	 * <p>
	 * @return itemvalueMap エラーメッセージに関する項目値を格納されたHashMap
	 */
	private HashMap<String, String> getItemvalueMap()
	{
		// エラーメッセージに関する項目値が格納されたHashMapを設定
		HashMap<String, String> itemvalue_Map = new HashMap<String, String>();
		itemvalue_Map.put("TXT-KKIFE021-INF1.SHK_TISH_KKN", "公衆網電話番号履歴情報ファイル.集計対象期間");
		itemvalue_Map.put("TXT-KKIFE021-INF1.SVC_KEI_NO", "公衆網電話番号履歴情報ファイル.サービス契約番号");
		itemvalue_Map.put("TXT-KKIFE021-INF1.VOIP_USER_ID", "公衆網電話番号履歴情報ファイル.ＶｏＩＰユーザＩＤ");
		itemvalue_Map.put("TXT-KKIFE021-INF1.KOSHUMO_TELNO", "公衆網電話番号履歴情報ファイル.公衆網電話番号");
		itemvalue_Map.put("TXT-KKIFE021-INF1.SVC_STA_DTM", "公衆網電話番号履歴情報ファイル.サービス開始年月日時分秒");
		itemvalue_Map.put("TXT-KKIFE021-INF1.SVC_END_DTM", "公衆網電話番号履歴情報ファイル.サービス終了年月日時分秒");
		itemvalue_Map.put("TXT-KKIFE021-INF1.SHR_DTM", "公衆網電話番号履歴情報ファイル.処理日時");

		return itemvalue_Map;
	}
	
	/**
	 * 公衆網通話実績を登録します。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目の配列を作ります。<br>
	 *
	 * 2.公衆網通話実績全項目登録処理を実行します。<br>
	 * </pre>
	 * <p>
	 * @param inMap 入力電文
	 * @param opSvcKeiMap オプションサービス契約マップ
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void insertKoshumoTwJsk(JBSbatServiceInterfaceMap inMap, JBSbatCommonDBInterface opSvcKeiMap) throws Exception
	{
		
		// 入力マップより情報を取得
		String shkTishKkn = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SHK_TISH_KKN));
		String svcKeiNo = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_KEI_NO));
		String voipUserId = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.VOIP_USER_ID));
		String koshumoTelno = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.KOSHUMO_TELNO));
		String svcStaDtm = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_STA_DTM));
		String svcEndDtm = JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_END_DTM));
		String opSvcKeiNo = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.OP_SVC_KEI_NO));
		// ST1-2012-0000494 MOD START
		// 開始日に値が設定されている場合は、ミリ秒を付加する
		if(!"".equals(svcStaDtm) && svcStaDtm != null)
		{
			svcStaDtm = svcStaDtm + DATETIME_FORMAT_VALUE;
		}
		//svcStaDtm = svcStaDtm + DATETIME_FORMAT_VALUE;
		// ST1-2012-0000494 MOD END
		// ST1-2012-0000494 MOD START
		// 終了日が設定されていない場合、デフォルト値を設定する
		if ("".equals(svcEndDtm) || svcEndDtm == null)
		//if (INPUT_FILE_DATETIME_MAXVALUE.equals(svcEndDtm))
		// ST1-2012-0000494 MOD END
		{
			svcEndDtm = DATETIME_MAXVALUE;
		}
		else
		{
			svcEndDtm = svcEndDtm + DATETIME_FORMAT_VALUE;
		}

		String[] setParam = {
				shkTishKkn, // 集計対象年月日
				opSvcKeiNo, // オプションサービス契約番号
				voipUserId, // VoIPユーザーID
				koshumoTelno, // VoIP電話番号
				// ST1-2012-0000494 MOD START
				JCCbatGetSystemDateUtil.getSystemDateTime().get(JCCbatGetSystemDateUtil.KEY_YYYYMMDDHHMMSS_SSS),	// 公衆網通話実績作成年月日
				//svcKeiNo, // サービス契約番号
				svcStaDtm, // 通話開始年月日時分秒
				svcEndDtm, // 通話終了年月日時分秒
				svcKeiNo, // サービス契約番号
				// ST1-2012-0000494 MOD END
				null, // 登録年月日時分秒
				null, // 登録オペレータアカウント
				null, // 更新年月日時分秒
				null, // 更新オペレータアカウント
				null, // 削除年月日時分秒
				null, // 削除オペレータアカウント
				null, // 無効フラグ
				// ST1-2012-0000494 ADD START
				null, // 登録運用年月日
				null, // 登録処理ID
				null, // 更新運用年月日
				null, // 更新処理ID
				null, // 削除運用年月日
				null // 削除処理ID
				// ST1-2012-0000494 ADD END
			};

		executeKK_T_KOSHUMO_TW_JSK_PKINSERT(setParam);
	}
	
	// OM-2014-0000201 2014/03/18 start
	/**
	 * 連携されたデータを公衆網通話実績に取り込むかどうか判定
	 * @return true:取り込む  false:取り込まない
	 */
	private boolean registChk(JBSbatServiceInterfaceMap inMap, JBSbatCommonDBInterface opSvcKeiMap) throws Exception{

//		�ASIP連携されたデータが解約年月日が入っている場合
//		　�A−１：オプションのカレントレコードが解約かつ解約年月日＜SIP連携データの解約年月日
//		　　　　　※あり得ないと思うが、解約後にSIPから再度解約連携があった場合は公衆網実績に取り込む
//		　�A−２：オプションのカレントレコードが解約以外の場合は公衆網実績に取り込む
//		�BSIP連携されたデータが解約年月日が入っていない場合
//		　�B−１：オプションのカレントレコードが解約以外　かつ　サービス開始日＜SIP連携データのサービス開始日の場合は公衆網実績に取り込む
//		　※VOIPユーザIDや電話番号変更連携の場合
		 
		boolean registFlg = false;
		//連携データ　サービス終了年月日時分秒
		String in_svcEndDtm =  JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_END_DTM));
		if(!"".equals(in_svcEndDtm)){
			in_svcEndDtm = in_svcEndDtm + DATETIME_FORMAT_VALUE;
		}
		if(DATETIME_MAXVALUE.equals(in_svcEndDtm)){
			in_svcEndDtm = "";
		}
		//オプションサービス契約から
		String opSvcKeiStat = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.OP_SVC_KEI_STAT));
		String op_svcEndYmd = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.SVC_ENDYMD));
		String op_svcEndHms = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.SVC_END_HMS));
		if(!"".equals(op_svcEndYmd) && "".equals(op_svcEndHms)){
			op_svcEndHms =TIME_MAXVALUE;
		}
		String op_svcEndDtm = op_svcEndYmd + op_svcEndHms;
		if(DATETIME_MAXVALUE.equals(op_svcEndDtm)){
			op_svcEndDtm = "";
		}
		
		if(!"".equals(in_svcEndDtm)){
			//連携されたデータに終了年月日が入っている
			
			if(!JKKBatConst.SVC_KEI_STAT_DSL_ZM.equals(opSvcKeiStat)){
				//オプションのカレントレコードが解約以外
				registFlg = true;
			}else if(op_svcEndDtm.compareTo(in_svcEndDtm) < 0){
				//オプションのカレントレコードが解約かつ終了年月日＜SIP連携データの終了年月日
				registFlg = true;
			}
		}else{
			//連携されたデータに終了年月日が入っていない
			
			if(!JKKBatConst.SVC_KEI_STAT_DSL_ZM.equals(opSvcKeiStat)){
				//オプションのカレントレコードが解約以外
				
				//連携データ　サービス開始年月日時分秒
				String in_svcStaDtm =  JBSbatStringUtil.trim(inMap.getString(JBSbatKKIFE021.SVC_STA_DTM));
				if(!"".equals(in_svcStaDtm)){
					in_svcStaDtm = in_svcStaDtm + DATETIME_FORMAT_VALUE;
				}
				//オプションサービス契約から
				String op_svcStaYmd = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.SVC_STAYMD));
				String op_svcStaHms = JBSbatStringUtil.trim(opSvcKeiMap.getString(JBSbatKK_T_OP_SVC_KEI.SVC_STA_HMS));
				if(!"".equals(op_svcStaYmd) && "".equals(op_svcStaHms)){
					op_svcStaHms =TIME_MAXVALUE;
				}
				String op_svcStaDtm = op_svcStaYmd + op_svcStaHms;
				if(op_svcStaDtm.compareTo(in_svcStaDtm) < 0){
					//オプションのカレントレコードが解約以外　かつ　サービス開始日＜SIP連携データのサービス開始日の場合
					registFlg = true;
				}
			}else{
				registFlg = true;
			}
		}
		
		return registFlg;
	}
	// OM-2014-0000201 2014/03/18 end
}