/*******************************************************************************
*	All Right reserved,Copyright (c) Fujitsu, 2010-2011
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム構築
*	モジュール名	：JSYejbEZM0411B050TPDA
*	ソースファイル名：JSYejbEZM0411B050TPDA.java
*	作成者			：FJ)藤本
*	日付			：2011年06月21日
*＜機能概要＞
*	SQLFacility
*	テンプレートDBアクセス部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	ｖ1.00.00
*
********************************************************************************/

package eo.ejb.cbs.sqlf;

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 eo.ejb.cbs.cbsmsg.EZM0411B050CBSMsg;
import eo.ejb.cbs.cbsmsg.EZM0411B050CBSMsg1List;
import eo.ejb.cbm.entity.TN0071ETMsg;

/**
* 
*  テンプレートDBアクセス部品　EZM0411B050_SQLF<br>
*  入力された項目からSQL文を動的に組み立て、<br>
*  検索結果をCBSMsgにセットします。<br>
*/
public class JSYejbEZM0411B050TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
	
	/**
	 * コンストラクタ
	 */
	public JSYejbEZM0411B050TPDA()	{
	}
	
	/**
	*   EZM0411B050_SQLF<br>
	*   @param inMsg    入力値の格納されたCBSMsg <br>
	*   @return void
	*/
	public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
		
		// コネクション
		Connection con1 = null;
		
		// プリペアステートメント
		PreparedStatement pstmt = null;
		
		// リザルトセット
		ResultSet rsltQuery = null;
		
		/******************** 
		 * SQL文の作成
		 ********************/

		try{
			
			//コネクション取得
			con1 = JSYejbConnection.getConnection(TN0071ETMsg.getTableName());
			
			
			// SQL文_基本部1
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append("SELECT ")
					.append("  ZM0411.TAKNKIKI_MODEL_CD AS MODEL_CD	")						//宅内機器型式コード
					.append(", ZM0411.TAKNKIKI_MODEL_NM AS MODEL_NM	")						//宅内機器型式名
					.append(", ZM0411.MAKER_CD AS MAKER_CD	")								//メーカーコード
					.append(", ZM0411.MAKER_KK_MDL_NO AS MAKER_KIKI_MDL_NO	")				//メーカー機器型番
					.append(", ZM0411.TAKNKIKI_SBT_CD AS SBT_CD	")							//宅内機器種別コード
					.append(", NULL AS HAISO_UK_STP_STAYMD	")								//
					.append(", NULL AS HAISO_UK_STP_ENDYMD	")								//
					.append(", NULL AS HATTCHU_STP_STAYMD	")								//
					.append(", NULL AS HATTCHU_STP_ENDYMD	")								//
					.append(", ZM0411.SEIZO_STA_YMD AS SEIZO_STAYMD	")						//製造開始年月日
					.append(", ZM0411.SEIZO_END_YMD AS SEIZO_ENDYMD	")						//製造終了年月日
					.append(", ZM0411.MAKER_HOSHO_KIGEN_YMD AS MAKER_HOSHO_KIGEN_YMD	")	//メーカー保証期限年月日
					.append(", ZM0411.MAKER_HOSHO_PRD AS MAKER_HOSHO_PRD	")				//メーカー保証期間
					.append(", ZM0411.STB_HDD_NAIZO_FLG AS STB_HDD_NAIZO_FLG	")			//STBHDD内蔵フラグ
					.append(", ZM0411.MRYO_ROUTER_DSP_MONGON AS MRYO_ROUTER_DSP_MONGON	")	//無料ルーター表示文言
					.append(", ZM0411.HOYU_ROUTER_CD AS HOYU_ROUTER_SBT_CD	")				//保有ルーターコード
					.append(", ZM0411.MAC_INF_UM AS MAC_IF_UM	")							//MAC情報有無
					.append(", ZM0411.SEIZO_NO_UM AS SEIZO_NO_UM	")						//製造番号有無
					.append(", ZM0411.ALI_NM AS ALI_NM	")									//略称名
					.append(", ZM0411.SHURI_KOKAN_GRP_SBT_CD AS SHURI_KOKAN_GRP_SBT_CD	")	//修理交換グループ種別コード
					.append(", ZM0411.KOJI_COMP_HAISO_UM AS KOCOMP_HAISO_UM	")				//工事会社配送有無
					.append(", ZM0411.OPMS_ROUTER_KIND_CD AS OPMS_ROUTER_KIND_CD	")		//OPMSルーター種類コード
					.append(", ZM0411.PORT_CNT AS PORT_CNT	")								//ポート数
					.append(", ZM0411.HDD_CAPA_CD AS HDD_CAPA_CD	")						//HDD容量コード
					.append(", ZM0411.HAISO_YOKSI_UM AS HAISO_YOKSI_UM	")					//配送抑止有無
					.append(", ZM0411.VONU_BSPT_KH AS VONU_BSPT_KH	")						//VONUBSパススルー可否
					.append(", ZM0411.KOJI_AF_SHKA_UM AS KOJI_AF_SHKA_UM	")				//工事後出荷有無
					.append(", NULL AS BSPT_UM	")											//
					.append("FROM ")
					.append("  ZM_M_TAKNKIKI_MODEL ZM0411 ")		//2012-06-28 TN -> ZM
					.append("WHERE ")
					.append("  ZM0411.TAKNKIKI_MODEL_CD = ? ")
					.append("  AND ")
					.append("  ZM0411.MK_FLG = '0' ");
//↓↓↓2012-06-28無効化、ZMに付属品型式スキーマが無いので↓↓↓
//			// SQL文_個別部1
//			if ( "1".equals( inMsg.getObject(EZM0411B050CBSMsg.FUNC_CODE).toString() ) ) {
//				sql_Buff.append(" UNION ALL ")
//						.append(" SELECT ")
//						.append(" TN0041.HUZOKUHIN_MODEL_CD AS MODEL_CD ")
//						.append(" , TN0041.HUZOKUHIN_MODEL_NM AS MODEL_NM ")
//						.append(" , TN0041.MAKER_CD AS MAKER_CD ")
//						.append(" , NULL AS MAKER_KIKI_MDL_NO ")
//						.append(" , TN0041.HUZOKUHIN_SBT_CD AS SBT_CD ")
//						.append(" , TN0041.HAISO_UK_STP_STAYMD AS HAISO_UK_STP_STAYMD ")
//						.append(" , TN0041.HAISO_UK_STP_ENDYMD AS HAISO_UK_STP_ENDYMD ")
//						.append(" , TN0041.HATTCHU_STP_STAYMD AS HATTCHU_STP_STAYMD ")
//						.append(" , TN0041.HATTCHU_STP_ENDYMD AS HATTCHU_STP_ENDYMD ")
//						.append(" , TN0041.SEIZO_STAYMD AS SEIZO_STAYMD ")
//						.append(" , TN0041.SEIZO_ENDYMD AS SEIZO_ENDYMD ")
//						.append(" , TN0041.MAKER_HOSHO_KIGEN_YMD AS MAKER_HOSHO_KIGEN_YMD ")
//						.append(" , TN0041.MAKER_HOSHO_PRD AS MAKER_HOSHO_PRD ")
//						.append(" , NULL AS STB_HDD_NAIZO_FLG ")
//						.append(" , NULL AS MRYO_ROUTER_DSP_MONGON ")
//						.append(" , NULL AS HOYU_ROUTER_SBT_CD ")
//						.append(" , TN0041.MAC_IF_UM AS MAC_IF_UM ")
//						.append(" , TN0041.SEIZO_NO_UM AS SEIZO_NO_UM ")
//						.append(" , NULL AS ALI_NM ")
//						.append(" , TN0041.SHURI_KOKAN_GRP_SBT_CD AS SHURI_KOKAN_GRP_SBT_CD ")
//						.append(" , TN0041.KOCOMP_HAISO_UM AS KOCOMP_HAISO_UM ")
//						.append(" , TN0041.OPMS_ROUTER_KIND_CD AS OPMS_ROUTER_KIND_CD ")
//						.append(" , TN0041.PORT_CNT AS PORT_CNT ")
//						.append(" , TN0041.HDD_CAPA_CD AS HDD_CAPA_CD ")
//						.append(" , TN0041.HAISO_YOKSI_UM AS HAISO_YOKSI_UM ")
//						.append(" , NULL AS VONU_BSPT_KH ")
//						.append(" , NULL AS KOJI_AF_SHKA_UM ")
//						.append(" , TN0041.BSPT_UM AS BSPT_UM ")
//						.append(" FROM ")
//						.append(" TN_M_HUZOKUHIN_MDL TN0041 ")
//						.append(" WHERE ")
//						.append(" TN0041.HUZOKUHIN_MODEL_CD = ? ")
//						.append(" AND ")
//						.append(" TN0041.MK_FLG = '0' ");
//			}
//↑↑↑2012-06-28無効化、ZMに付属品型式スキーマが無いので↑↑↑
			
			//prepareStatementにSQL文をセット
			pstmt = con1.prepareStatement(sql_Buff.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
			
			// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
			if ( "1".equals( inMsg.getString(EZM0411B050CBSMsg.FUNC_CODE) ) ) {
				// パラメータの設定(ＫＥＹ＿型式コードを指定)
				CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(EZM0411B050CBSMsg.KEY_MODEL_CD));
//↓↓↓2012-06-28無効化、ZMに付属品型式スキーマが無いので↓↓↓
//				// パラメータの設定(ＫＥＹ＿型式コードを指定)
//				CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(EZM0411B050CBSMsg.KEY_MODEL_CD));
//↑↑↑2012-06-28無効化、ZMに付属品型式スキーマが無いので↑↑↑
			}
			
			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();
			
			// EZM0411B050CBSMsgの明細にセットする項目
			String[] msgKeyList1 = {
					  EZM0411B050CBSMsg1List.MODEL_CD
					, EZM0411B050CBSMsg1List.MODEL_NM
					, EZM0411B050CBSMsg1List.MAKER_CD
					, EZM0411B050CBSMsg1List.MAKER_KIKI_MDL_NO
					, EZM0411B050CBSMsg1List.SBT_CD
					, EZM0411B050CBSMsg1List.HAISO_UK_STP_STAYMD
					, EZM0411B050CBSMsg1List.HAISO_UK_STP_ENDYMD
					, EZM0411B050CBSMsg1List.HATTCHU_STP_STAYMD
					, EZM0411B050CBSMsg1List.HATTCHU_STP_ENDYMD
					, EZM0411B050CBSMsg1List.SEIZO_STAYMD
					, EZM0411B050CBSMsg1List.SEIZO_ENDYMD
					, EZM0411B050CBSMsg1List.MAKER_HOSHO_KIGEN_YMD
					, EZM0411B050CBSMsg1List.MAKER_HOSHO_PRD
					, EZM0411B050CBSMsg1List.STB_HDD_NAIZO_FLG
					, EZM0411B050CBSMsg1List.MRYO_ROUTER_DSP_MONGON
					, EZM0411B050CBSMsg1List.HOYU_ROUTER_SBT_CD
					, EZM0411B050CBSMsg1List.MAC_IF_UM
					, EZM0411B050CBSMsg1List.SEIZO_NO_UM
					, EZM0411B050CBSMsg1List.ALI_NM
					, EZM0411B050CBSMsg1List.SHURI_KOKAN_GRP_SBT_CD
					, EZM0411B050CBSMsg1List.KOCOMP_HAISO_UM
					, EZM0411B050CBSMsg1List.OPMS_ROUTER_KIND_CD
					, EZM0411B050CBSMsg1List.PORT_CNT
					, EZM0411B050CBSMsg1List.HDD_CAPA_CD
					, EZM0411B050CBSMsg1List.HAISO_YOKSI_UM
					, EZM0411B050CBSMsg1List.VONU_BSPT_KH
					, EZM0411B050CBSMsg1List.KOJI_AF_SHKA_UM
					, EZM0411B050CBSMsg1List.BSPT_UM
			};
			
			// 明細に処理結果(ResultSet)をマッピング
			CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EZM0411B050CBSMsg1List",0);
			// inMsg(CBSMsg)に明細をセット
			inMsg.set("EZM0411B050CBSMsg1List", outMsg1);
			

		} catch(SQLException e) {
			inMsg.set(EZM0411B050CBSMsg.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(EZM0411B050CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
				throw new CAANRuntimeException(e);
			}
		}
	}
}