/*******************************************************************************
*	 All Rights reserved,Copyright (c) K-Opticom 
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JSYejbECH0051B100TPDA
*	ソースファイル名：JSYejbECH0051B100TPDA.java
*	作成者			：EK968176
*	日付			：2024年11月12日
*＜機能概要＞
*	NTT卸未納分単独請求チェックテンプレートDBアクセス部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v73.00.00   2024/11/12  FJ) 張     【ANK-4427-00-00】NTT卸対応：STEP1
*   v73.00.01   2024/12/12  FJ）張      IT2-2024-0000073 【ANK-4427-00-00】NTT卸対応：STEP1
*   v73.00.02	2025/01/10  FJ) 張     【IT1-2025-0000003】NTT卸対応：STEP1 
*   v73.00.03	2025/03/12  FJ) 張     【#86808】NHKのみ請求がtypeNとして出力されないように改修
********************************************************************************/

package eo.ejb.cbs.sqlf;

import com.fujitsu.futurity.model.base.CAANConnectionMgr;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.base.CAANSQLFacility;
import com.fujitsu.futurity.model.base.CAANRuntimeException;
import com.fujitsu.futurity.model.base.CAANJDBCUtil;
import com.fujitsu.futurity.model.ejb.common.JSYejbConnection;
import com.fujitsu.futurity.model.ejb.common.JSYejbLog;
import com.fujitsu.futurity.model.ejb.common.StatusCodes;
import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler;
import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

import eo.ejb.cbs.cbsmsg.ECH0051B080CBSMsg;
import eo.ejb.cbs.cbsmsg.ECH0051B080CBSMsg1List;
import eo.ejb.cbs.cbsmsg.ECH0051B100CBSMsg;
import eo.ejb.cbs.cbsmsg.ECH0051B100CBSMsg1List;
import eo.ejb.cbm.entity.CH0051ETMsg;
import eo.ejb.cbm.entity.CH0101ETMsg;
import eo.ejb.common.JPCModelCommon;

/**
*
*  テンプレートDBアクセス部品　ECH0051B100_SQLF<br>
*  入力された項目からSQL文を動的に組み立て、<br>
*  検索結果をCBSMsgにセットします。<br>
*/
public class JSYejbECH0051B100TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
	
//#86808 20250312 張 ADD START
	/** 料金コースコード */
	private static final String PRCS_CD_KU = "   ";
//#86808 20250312 張 ADD END
	
	/**
	 * コンストラクタ
	 */
	public JSYejbECH0051B100TPDA()	{
	}
	
	/**
	*   ECH0051B100_SQLF<br>
	*   @param inMsg    入力値の格納されたCBSMsg <br>
	*   @return void
	*/
	public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
		
		ArrayList rsltMsgList = new ArrayList();
		CAANMsg outMsg1 = new CAANMsg("eo.ejb.cbs.cbsmsg.ECH0051B100CBSMsg1List");
		
		// 当月分がNTT卸単独以外で当月ご請求料金が存在するかをチェックする
		if ((int)getNttoChk(inMsg, inContext) > 0 && "0".equals(inMsg.getObject(ECH0051B100CBSMsg.KEY_NTTO_CHK_FLG)))
		{
			// inMsg(CBSMsg)に明細をセット
			outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
			rsltMsgList.add(outMsg1);
			inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
			return;
		}
		
		// NTT卸請求が存在するかをチェックする
		if ((int)getNttoCnt(inMsg, inContext) == 0)
		{
			// inMsg(CBSMsg)に明細をセット
			outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
			rsltMsgList.add(outMsg1);
			inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
			return;
		}

		// 請求内訳合計明細を取得する
//IT1-2025-0000003 20250114 張 MOD START
		//ArrayList<Map<String, String>> mapListGki = getSkyGki(inMsg, inContext, "SKY_U_NTT");
		ArrayList<Map<String, String>> mapListGki = getSkyGki(inMsg, inContext);
//IT1-2025-0000003 20250114 張 MOD END

		// NTT卸単独請求明細を取得する
		//IT2-2024-0000073 MOD START
		//ArrayList<Map<String, String>> mapListOnly = getSkyGki(inMsg, inContext, "NTTO_ONLY");
		ArrayList<Map<String, String>> mapListOnly = getSkyGkiTandoku(inMsg, inContext, "NTTO_ONLY");
		//IT2-2024-0000073 MOD END

		// 請求内訳合計明細が存在しない場合
		if (mapListGki.size() == 0 )
		{
			// inMsg(CBSMsg)に明細をセット
			outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
			rsltMsgList.add(outMsg1);
			inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
			return;
		}

		// 請求内訳合計明細とNTT卸単独請求明細の件数が不一致の場合
		if (mapListGki.size() != mapListOnly.size())
		{
				// inMsg(CBSMsg)に明細をセット
				outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
				rsltMsgList.add(outMsg1);
				inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
				return;
		}
		
//#86808 20250312 張 ADD START
		//同一請求契約番号に料金コースコードが"   "でない数をカウントする
		int prcsCd2Cnt = 0;
//#86808 20250312 張 ADD END
		
		// 請求内訳リストとNTT卸単独リストのサイズが一致の場合
		if(mapListGki.size() == mapListOnly.size())
		{
			for (int i = 0; i < mapListGki.size(); i++)
			{
				// 料金項目コードnullの場合
				if (null == mapListGki.get(i).get(CH0101ETMsg.PRC_KMK_CD) || null == mapListOnly.get(i).get(CH0101ETMsg.PRC_KMK_CD))
				{
					// inMsg(CBSMsg)に明細をセット
					outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
					rsltMsgList.add(outMsg1);
					inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
					return;
				}

				// 請求内訳合計明細とNTT卸単独請求明細の料金グループコード、料金項目コードが不一致の場合
				if (!mapListGki.get(i).get(CH0101ETMsg.PRC_GRP_CD).equals(mapListOnly.get(i).get(CH0101ETMsg.PRC_GRP_CD)) ||
//IT1-2025-0000003 20250114 張 MOD START
						//!mapListGki.get(i).get(CH0101ETMsg.PRC_KMK_CD).equals(mapListOnly.get(i).get(CH0101ETMsg.PRC_KMK_CD)))
						!mapListGki.get(i).get(CH0101ETMsg.PCRS_CD).equals(mapListOnly.get(i).get(CH0101ETMsg.PCRS_CD)))
//IT1-2025-0000003 20250114 張 MOD END
				{
					// inMsg(CBSMsg)に明細をセット
					outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
					rsltMsgList.add(outMsg1);
					inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
					return;
				}
//#86808 20250312 張 ADD START
				if(!PRCS_CD_KU.equals(mapListGki.get(i).get(CH0101ETMsg.PCRS_CD)) 
						&& !"".equals(mapListGki.get(i).get(CH0101ETMsg.PCRS_CD)) 
						&& null != mapListGki.get(i).get(CH0101ETMsg.PCRS_CD)){
					prcsCd2Cnt++;
				}
//#86808 20250312 張 ADD END	
				
			}
//#86808 20250312 張 ADD START
			// 同一請求契約番号に料金グループコードが"  "しか持っていない請求はNTT卸単独請求外とする
			if(0 == prcsCd2Cnt){
				// inMsg(CBSMsg)に明細をセット
				outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
				rsltMsgList.add(outMsg1);
				inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
				return;
			}
//#86808 20250312 張 ADD END
		}
		else
		{
			// inMsg(CBSMsg)に明細をセット
			outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "0");
			rsltMsgList.add(outMsg1);
			inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
			return;
		}

		
		// NTT卸単独の場合
		outMsg1.set(ECH0051B100CBSMsg1List.NTTO_CHK_FLG, "1");
		rsltMsgList.add(outMsg1);
		// inMsg(CBSMsg)に明細をセット
		inMsg.set("ECH0051B100CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
		return;
		
	}

	/**
	 * <p>
	 * 当月分がNTT卸単独以外で当月ご請求料金が存在するかをチェックする
	 * </p>
	 * @param inMsg 入力値の格納されたCBSMsg
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @return 検索結果　true：存在する　false：存在しない
	 */
	public long getNttoChk(CAANMsg inMsg,AgentDispatchContext inContext){
		
		// コネクション
		Connection con1 = null;
		
		// プリペアステートメント
		PreparedStatement pstmt = null;
		
		// リザルトセット
		ResultSet rsltQuery = null;

		long lDataCnt = 0L;
		
		/******************** 
		 * SQL文の作成
		 ********************/

		try{
			
			//コネクション取得
			con1 = JSYejbConnection.getConnection(CH0051ETMsg.getTableName());
			
			
			// SQL文_基本部1
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append(" SELECT  COUNT(*) AS CNT_CHEK  ")
					.append(" FROM  CH_T_SEIKY CH0051 ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101 ")
					.append(" ON    CH0101.SEIKY_NO = CH0051.SEIKY_NO ")
					.append(" AND   CH0101.SEIKY_YM = CH0051.SEIKY_YM ")
					.append(" WHERE  ")
					.append("       CH0051.SEIKY_NO = ?  ")
					.append(" AND   CH0051.SEIKY_YM = ? ")
					.append(" AND   CH0051.SEIKYUS_HAKKO_TG_FLG = '1' ")
					.append(" AND   CH0051.MK_FLG = '0' ")
					.append(" AND   CH0101.MK_FLG = '0' ")
					.append(" AND   CH0101.PRC_GRP_CD = '  ' ")
					.append(" AND   CH0101.PCRS_CD    = '   ' ")
					.append(" AND   CH0101.PRC_SVC_CD = '            ' ")
					.append(" AND   CH0101.PRC_KMK_CD = '00900940601' ");
			
			//prepareStatementにSQL文をセット
			pstmt = con1.prepareStatement(sql_Buff.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
			
			// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
			// パラメータの設定(ＫＥＹ＿請求番号を指定)
			CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_NO));
			// パラメータの設定(ＫＥＹ＿請求年月を指定)
			CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_YM));
			
			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();

			// 件数を返却する
			if (rsltQuery.next())
			{
				lDataCnt = rsltQuery.getLong("CNT_CHEK");
			}

		} catch(SQLException e) {
			inMsg.set(ECH0051B100CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
			throw new CAANRuntimeException(e);
		} finally {
			// 資源の解放
			try{
				if(rsltQuery != null){
					rsltQuery.close();
				}
				if(pstmt != null){
					pstmt.close();
				}
				if(con1 != null){
					closeConnection(con1);
				}
			}catch(SQLException e){
				inMsg.set(ECH0051B100CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
				throw new CAANRuntimeException(e);
			}
		}
		return lDataCnt;
	}
	
	/**
	 * <p>
	 * NTT卸請求が存在するかをチェックする
	 * </p>
	 * @param inMsg 入力値の格納されたCBSMsg
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @return 検索結果　true：存在する　false：存在しない
	 */
	public long getNttoCnt(CAANMsg inMsg,AgentDispatchContext inContext){
		
		// コネクション
		Connection con1 = null;
		
		// プリペアステートメント
		PreparedStatement pstmt = null;
		
		// リザルトセット
		ResultSet rsltQuery = null;

		long lDataCnt = 0L;
		
		/******************** 
		 * SQL文の作成
		 ********************/

		try{
			
			//コネクション取得
			con1 = JSYejbConnection.getConnection(CH0051ETMsg.getTableName());
			
			
			// SQL文_基本部1
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append(" SELECT  COUNT(*) AS CNT_CHEK  ")
					.append(" FROM  CH_T_SEIKY CH0051 ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_01 ")
					.append(" ON    CH0101_01.SEIKY_NO = CH0051.SEIKY_NO ")
					.append(" AND   CH0101_01.SEIKY_YM = CH0051.SEIKY_YM ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_01 ")
					.append(" ON    CH0041_01.SEIKY_NO = CH0101_01.SEIKY_NO ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_02 ")
					.append(" ON    CH0041_02.SAIKEN_NO = CH0041_01.SAIKEN_NO ")
					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_01 ")
					.append(" ON    CH0401_01.PRC_GRP_CD = CH0101_01.PRC_GRP_CD ")
					.append(" AND   CH0401_01.PCRS_CD = CH0101_01.PCRS_CD ")
					.append(" AND   CH0401_01.PRC_SVC_CD = CH0101_01.PRC_SVC_CD ")
					.append(" AND   CH0401_01.PRC_KMK_CD = CH0101_01.PRC_KMK_CD ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_02 ")
					.append(" ON    CH0101_02.SEIKY_NO = CH0041_02.SEIKY_NO ")
					.append(" AND   CH0101_02.SEIKY_YM = CH0101_01.GSAN_SEIKY_YM ")
					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_02 ")
					.append(" ON    CH0401_02.PRC_GRP_CD = CH0101_02.PRC_GRP_CD ")
					.append(" AND   CH0401_02.PCRS_CD = CH0101_02.PCRS_CD ")
					//IT1-2025-0000003 20250114 張 DEL START
//					.append(" AND   CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
//					.append(" AND   CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
					//IT1-2025-0000003 20250114 張 DEL END
					.append(" WHERE  ")
					.append("       CH0051.SEIKY_NO = ?  ")
					.append(" AND   CH0051.SEIKY_YM = ? ")
					.append(" AND   CH0051.SEIKYUS_HAKKO_TG_FLG = '1' ")
					.append(" AND   CH0051.MK_FLG = '0' ")
					.append(" AND   CH0101_01.MK_FLG = '0' ")
					.append(" AND   CH0041_01.KKSHI_CNT > 0 ")
					.append(" AND   CH0041_01.MK_FLG = '0' ")
					.append(" AND   CH0041_02.KKSHI_CNT = 0 ")
					.append(" AND   CH0041_02.MK_FLG = '0' ")
					.append(" AND   CH0401_01.SYS_CD = 'CH' ")
					.append(" AND   CH0401_01.WORK_KINO_SKBT_CD = 'MISG_GSKY' ")
					.append(" AND   CH0401_01.CHSHT_CHG_CD = '1' ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
					.append(" AND   CH0401_01.MK_FLG = '0' ")
					.append(" AND   CH0101_02.MK_FLG = '0' ")
					.append(" AND   CH0401_02.SYS_CD = 'CH' ")
					.append(" AND   CH0401_02.WORK_KINO_SKBT_CD = 'NTTO_ONLY' ")
					.append(" AND   CH0401_02.CHSHT_CHG_CD = '1' ")
					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
					.append(" AND   CH0401_02.MK_FLG = '0' ");
			
			//prepareStatementにSQL文をセット
			pstmt = con1.prepareStatement(sql_Buff.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
			
			// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
			// パラメータの設定(ＫＥＹ＿請求番号を指定)
			CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_NO));
			// パラメータの設定(ＫＥＹ＿請求年月を指定)
			CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_YM));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 3, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 4, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 5, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 6, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			
			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();

			// 件数を返却する
			if (rsltQuery.next())
			{
				lDataCnt = rsltQuery.getLong("CNT_CHEK");
			}

		} catch(SQLException e) {
			inMsg.set(ECH0051B100CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
			throw new CAANRuntimeException(e);
		} finally {
			// 資源の解放
			try{
				if(rsltQuery != null){
					rsltQuery.close();
				}
				if(pstmt != null){
					pstmt.close();
				}
				if(con1 != null){
					closeConnection(con1);
				}
			}catch(SQLException e){
				inMsg.set(ECH0051B100CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
				throw new CAANRuntimeException(e);
			}
		}
		return lDataCnt;
	}

	/**
	 * <p>
	 * 請求内訳合計明細を取得する
	 * </p>
	 * @param  inMsg     処理対象のメッセージキャリア
	 * @param  inContext ディスパッチコンテキスト
	 * @param  workKinoSkbtCd 業務機能識別コード
	 * @return サービス契約回線内訳のカレントレコード情報
	 *          該当するレコードが存在しない場合null
	 */
//IT1-2025-0000003 20250114 張 MOD START
	//private ArrayList<Map<String, String>> getSkyGki(CAANMsg inMsg, AgentDispatchContext inContext, String workKinoSkbtCd)
	private ArrayList<Map<String, String>> getSkyGki(CAANMsg inMsg, AgentDispatchContext inContext)
//IT1-2025-0000003 20250114 張 MOD END
	{
		// 返却用メッセージ
		ArrayList<Map<String, String>> mapList = new ArrayList<Map<String, String>>();
		// コネクション
		Connection con = null;
		// プリペアステートメント
		PreparedStatement pstmt = null;
		// リザルトセット
		ResultSet rsltQuery = null;
		
		try
		{
			// 対象テーブルのコネクション取得
			con = JSYejbConnection.getConnection(CH0051ETMsg.getTableName());
			// SQL文
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append(" SELECT    ")
					.append("       CH0101_02.PRC_GRP_CD ")
					.append("     , TRIM(CH0101_02.PRC_KMK_CD) ")
					//IT1-2025-0000003 20250114 張 ADD START
					.append("     , CH0101_02.PCRS_CD ")
					//IT1-2025-0000003 20250114 張 ADD END
					.append(" FROM  CH_T_SEIKY CH0051 ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_01 ")
					.append(" ON    CH0101_01.SEIKY_NO = CH0051.SEIKY_NO ")
					.append(" AND   CH0101_01.SEIKY_YM = CH0051.SEIKY_YM ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_01 ")
					.append(" ON    CH0041_01.SEIKY_NO = CH0101_01.SEIKY_NO ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_02 ")
					.append(" ON    CH0041_02.SAIKEN_NO = CH0041_01.SAIKEN_NO ")
					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_01 ")
					.append(" ON    CH0401_01.PRC_GRP_CD = CH0101_01.PRC_GRP_CD ")
					.append(" AND   CH0401_01.PCRS_CD = CH0101_01.PCRS_CD ")
					.append(" AND   CH0401_01.PRC_SVC_CD = CH0101_01.PRC_SVC_CD ")
					.append(" AND   CH0401_01.PRC_KMK_CD = CH0101_01.PRC_KMK_CD ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_02 ")
					.append(" ON    CH0101_02.SEIKY_NO = CH0041_02.SEIKY_NO ")
					.append(" AND   CH0101_02.SEIKY_YM = CH0101_01.GSAN_SEIKY_YM ")
//IT1-2025-0000003 20250114 張 DEL START
//					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_02 ")
//					//IT2-2024-0000073 DEL START
////					.append(" ON    CH0401_02.PRC_GRP_CD = CH0101_02.PRC_GRP_CD ")
////					.append(" AND   CH0401_02.PCRS_CD = CH0101_02.PCRS_CD ")
////					.append(" AND   CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
//					//IT2-2024-0000073 DEL END
//					//IT2-2024-0000073 MOD START
//				  //.append(" AND   CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
//					.append(" ON    CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
					////IT2-2024-0000073 MOD END
//IT1-2025-0000003 20250114 張 DEL END
					.append(" WHERE  ")
					.append("       CH0051.SEIKY_NO = ?  ")
					.append(" AND   CH0051.SEIKY_YM = ? ")
					.append(" AND   CH0051.SEIKYUS_HAKKO_TG_FLG = '1' ")
					.append(" AND   CH0051.MK_FLG = '0' ")
					.append(" AND   CH0101_01.MK_FLG = '0' ")
					.append(" AND   CH0041_01.KKSHI_CNT > 0 ")
					.append(" AND   CH0041_01.MK_FLG = '0' ")
					.append(" AND   CH0041_02.KKSHI_CNT = 0 ")
					.append(" AND   CH0041_02.MK_FLG = '0' ")
					.append(" AND   CH0401_01.SYS_CD = 'CH' ")
					.append(" AND   CH0401_01.WORK_KINO_SKBT_CD = 'MISG_GSKY' ")
					.append(" AND   CH0401_01.CHSHT_CHG_CD = '1' ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
					.append(" AND   CH0401_01.MK_FLG = '0' ")
					.append(" AND   CH0101_02.MK_FLG = '0' ")
					//IT1-2025-0000003 20250114 張 ADD START
					.append(" AND   CH0101_02.PRC_KMK_CD NOT LIKE ('2103%') ")
					.append(" AND   CH0101_02.PRC_KMK_CD NOT LIKE ('1103%') ")
					//IT1-2025-0000003 20250114 張 ADD END
//IT1-2025-0000003 20250114 張 DEL START
//					.append(" AND   CH0401_02.SYS_CD = 'CH' ")
//					.append(" AND   CH0401_02.WORK_KINO_SKBT_CD = ? ")
//					.append(" AND   CH0401_02.CHSHT_CHG_CD = '1' ")
//					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
//					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
//					.append(" AND   CH0401_02.MK_FLG = '0' ")
//IT1-2025-0000003 20250114 張 DEL END
					.append(" ORDER BY  ")
					.append("       CH0101_02.PRC_GRP_CD ASC")
					.append("     , CH0101_02.PRC_KMK_CD ASC");

			// repareStatementにSQL文をセット
			pstmt = con.prepareStatement(sql_Buff.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);

			// パラメータの設定(ＫＥＹ＿請求番号を指定)
			CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_NO));
			// パラメータの設定(ＫＥＹ＿請求年月を指定)
			CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_YM));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 3, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 4, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(業務機能識別を指定)
//IT1-2025-0000003 20250114 張 DEL START
//			CAANJDBCUtil.setParam(pstmt, 5, workKinoSkbtCd);		
//			// パラメータの設定(運用日付を指定)
//			CAANJDBCUtil.setParam(pstmt, 6, JPCModelCommon.getOpeDate(inMsg, inContext, null));
//			// パラメータの設定(運用日付を指定)
//			CAANJDBCUtil.setParam(pstmt, 7, JPCModelCommon.getOpeDate(inMsg, inContext, null));			
//IT1-2025-0000003 20250114 張 DEL END	
			
			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();
			
			// リスト格納用マップ
			HashMap<String, String> map = null;
			
			// 取得結果をマップに格納
			while (rsltQuery.next())
			{
				// レコード情報格納用マップを初期化する
				map = new HashMap<String, String>();
				// 取得したレコード情報をセットする
				map.put(CH0101ETMsg.PRC_GRP_CD, rsltQuery.getString(1));
				map.put(CH0101ETMsg.PRC_KMK_CD, rsltQuery.getString(2));
				//IT1-2025-0000003 20250114 張 ADD START
				map.put(CH0101ETMsg.PCRS_CD, rsltQuery.getString(3));
				//IT1-2025-0000003 20250114 張 ADD END
				
				// セットしたMapをListに格納する
				mapList.add(map);
			}
			
			return mapList;
		}
		catch(SQLException se)
		{
			throw new CAANRuntimeException(se);
		}
		finally
		{
			// 資源の解放
			try
			{
				if(rsltQuery != null)
				{
					rsltQuery.close();
				}
				if(pstmt != null)
				{
					pstmt.close();
				}
				if(con != null)
				{
					CAANConnectionMgr.getInstance().close(con);
				}
			}
			catch(SQLException se)
			{
				throw new CAANRuntimeException(se);
			}
		}

	}	
	
	
	
	//IT2-2024-0000073 ADD START
	/**
	 * <p>
	 * 請求内訳NTT卸単独明細を取得する
	 * </p>
	 * @param  inMsg     処理対象のメッセージキャリア
	 * @param  inContext ディスパッチコンテキスト
	 * @param  workKinoSkbtCd 業務機能識別コード
	 * @return サービス契約回線内訳のカレントレコード情報
	 *          該当するレコードが存在しない場合null
	 */
	private ArrayList<Map<String, String>> getSkyGkiTandoku(CAANMsg inMsg, AgentDispatchContext inContext, String workKinoSkbtCd)
	{
		// 返却用メッセージ
		ArrayList<Map<String, String>> mapList = new ArrayList<Map<String, String>>();
		// コネクション
		Connection con = null;
		// プリペアステートメント
		PreparedStatement pstmt = null;
		// リザルトセット
		ResultSet rsltQuery = null;
		
		try
		{
			// 対象テーブルのコネクション取得
			con = JSYejbConnection.getConnection(CH0051ETMsg.getTableName());
			// SQL文
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append(" SELECT    ")
					.append("       CH0101_02.PRC_GRP_CD ")
					.append("     , TRIM(CH0101_02.PRC_KMK_CD) ")
					//IT1-2025-0000003 20250114 張 ADD START
					.append("     , CH0101_02.PCRS_CD ")
					//IT1-2025-0000003 20250114 張 ADD END
					.append(" FROM  CH_T_SEIKY CH0051 ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_01 ")
					.append(" ON    CH0101_01.SEIKY_NO = CH0051.SEIKY_NO ")
					.append(" AND   CH0101_01.SEIKY_YM = CH0051.SEIKY_YM ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_01 ")
					.append(" ON    CH0041_01.SEIKY_NO = CH0101_01.SEIKY_NO ")
					.append(" INNER JOIN CH_T_SEIKY_SKN_KNRN CH0041_02 ")
					.append(" ON    CH0041_02.SAIKEN_NO = CH0041_01.SAIKEN_NO ")
					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_01 ")
					.append(" ON    CH0401_01.PRC_GRP_CD = CH0101_01.PRC_GRP_CD ")
					.append(" AND   CH0401_01.PCRS_CD = CH0101_01.PCRS_CD ")
					.append(" AND   CH0401_01.PRC_SVC_CD = CH0101_01.PRC_SVC_CD ")
					.append(" AND   CH0401_01.PRC_KMK_CD = CH0101_01.PRC_KMK_CD ")
					.append(" INNER JOIN CH_T_SEIKY_UCWK CH0101_02 ")
					.append(" ON    CH0101_02.SEIKY_NO = CH0041_02.SEIKY_NO ")
					.append(" AND   CH0101_02.SEIKY_YM = CH0101_01.GSAN_SEIKY_YM ")
					.append(" INNER JOIN CH_M_PRC_KMK_CS_CHGE CH0401_02 ")
					.append(" ON    CH0401_02.PRC_GRP_CD = CH0101_02.PRC_GRP_CD ")
					.append(" AND   CH0401_02.PCRS_CD = CH0101_02.PCRS_CD ")
					//IT1-2025-0000003 20250114 張 DEL START
//					.append(" AND   CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
//					.append(" AND   CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
					//IT1-2025-0000003 20250114 張 DEL END
					.append(" WHERE  ")
					.append("       CH0051.SEIKY_NO = ?  ")
					.append(" AND   CH0051.SEIKY_YM = ? ")
					.append(" AND   CH0051.SEIKYUS_HAKKO_TG_FLG = '1' ")
					.append(" AND   CH0051.MK_FLG = '0' ")
					.append(" AND   CH0101_01.MK_FLG = '0' ")
					.append(" AND   CH0041_01.KKSHI_CNT > 0 ")
					.append(" AND   CH0041_01.MK_FLG = '0' ")
					.append(" AND   CH0041_02.KKSHI_CNT = 0 ")
					.append(" AND   CH0041_02.MK_FLG = '0' ")
					.append(" AND   CH0401_01.SYS_CD = 'CH' ")
					.append(" AND   CH0401_01.WORK_KINO_SKBT_CD = 'MISG_GSKY' ")
					.append(" AND   CH0401_01.CHSHT_CHG_CD = '1' ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
					.append(" AND   CH0401_01.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
					.append(" AND   CH0401_01.MK_FLG = '0' ")
					.append(" AND   CH0101_02.MK_FLG = '0' ")
					.append(" AND   CH0401_02.SYS_CD = 'CH' ")
					.append(" AND   CH0401_02.WORK_KINO_SKBT_CD = ? ")
					.append(" AND   CH0401_02.CHSHT_CHG_CD = '1' ")
					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TSTAYMD <= ? ")
					.append(" AND   CH0401_02.PRC_KMK_CS_CHGE_TENDYMD >= ? ")
					.append(" AND   CH0401_02.MK_FLG = '0' ")
					.append(" ORDER BY  ")
					.append("       CH0101_02.PRC_GRP_CD ASC")
					.append("     , CH0101_02.PRC_KMK_CD ASC");

			// repareStatementにSQL文をセット
			pstmt = con.prepareStatement(sql_Buff.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);

			// パラメータの設定(ＫＥＹ＿請求番号を指定)
			CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_NO));
			// パラメータの設定(ＫＥＹ＿請求年月を指定)
			CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B100CBSMsg.KEY_SEIKY_YM));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 3, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 4, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(業務機能識別を指定)
			CAANJDBCUtil.setParam(pstmt, 5, workKinoSkbtCd);
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 6, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			// パラメータの設定(運用日付を指定)
			CAANJDBCUtil.setParam(pstmt, 7, JPCModelCommon.getOpeDate(inMsg, inContext, null));
			
			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();
			
			// リスト格納用マップ
			HashMap<String, String> map = null;
			
			// 取得結果をマップに格納
			while (rsltQuery.next())
			{
				// レコード情報格納用マップを初期化する
				map = new HashMap<String, String>();
				// 取得したレコード情報をセットする
				map.put(CH0101ETMsg.PRC_GRP_CD, rsltQuery.getString(1));
				map.put(CH0101ETMsg.PRC_KMK_CD, rsltQuery.getString(2));
				//IT1-2025-0000003 20250114 張 ADD START
				map.put(CH0101ETMsg.PCRS_CD, rsltQuery.getString(3));
				//IT1-2025-0000003 20250114 張 ADD END
				
				// セットしたMapをListに格納する
				mapList.add(map);
			}
			
			return mapList;
		}
		catch(SQLException se)
		{
			throw new CAANRuntimeException(se);
		}
		finally
		{
			// 資源の解放
			try
			{
				if(rsltQuery != null)
				{
					rsltQuery.close();
				}
				if(pstmt != null)
				{
					pstmt.close();
				}
				if(con != null)
				{
					CAANConnectionMgr.getInstance().close(con);
				}
			}
			catch(SQLException se)
			{
				throw new CAANRuntimeException(se);
			}
		}

	}	
	//IT2-2024-0000073 ADD END
}