/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKU0011B010TPDA
* ソースファイル名：JSYejbEKU0011B010TPDA.java
* 作成者 ：富士通
* 日付 ：2011年07月31日
*＜機能概要＞
* SQLFacility
* テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v1.00.00 2011/07/31 FJ)高橋 新規作成
* v10.00.00 2014/06/27 FJ)高橋 【ANK-1918-00-00】US管理システム対応
* v13.00.00 2015/03/27 FJ)田枝 【ANK-2422-00-00】工程進捗状況を工事履歴へ表示する
* v31.00.00 2017/11/20 FJ)柳川 【ANK-3136-00-00】OPMSハードウエア保守切れ対応(STEP2-2)
* v53.00.00 2021/04/28 FJ)謝 【ANK-3989-00-00】マンション光コンセント方式への5G・10Gコース追加
* v53.00.01 2021/04/30 GDC)ジョバニー 【ANK-4009-00-00】CX戦略WG方針対応（異動シェア分・API）
* v63.00.00 2023/01/05 FJ)張本 【OM-2022-0001108】機器交換時の配送判定不具合
*
********************************************************************************/
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.common.constant.JKUStrConst;
import eo.common.constant.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.EKU0011B010CBSMsg;
import eo.ejb.cbs.cbsmsg.EKU0011B010CBSMsg1List;
import eo.ejb.cbm.entity.KU0011ETMsg;
/**
*
* テンプレートDBアクセス部品 EKU0011B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKU0011B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbEKU0011B010TPDA() {
}
/**
* EKU0011B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void
*/
public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
/**
* パラメータセット用
*/
int iIndex = 1;
// 検索処理パターン
String searchType = (String)inMsg.getObject(EKU0011B010CBSMsg.SEARCH_TYPE);
if(JPCModelConstant.SAERCH_TYPE_IKT.equals(searchType))
{
/**
* 最大検索件数が未設定の場合
*/
if (inMsg.isNull(EKU0011B010CBSMsg.MAX_SEARCH_NUM))
{
throw new IllegalArgumentException(JKUStrConst.ICRN_ERR_MSG_IKT);
}
}
else if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
/**
* 最大検索件数、表示件数、表示ページ番号が未設定の場合
*/
if (inMsg.isNull(EKU0011B010CBSMsg.MAX_SEARCH_NUM)
|| inMsg.isNull(EKU0011B010CBSMsg.DISPLAY_NUM)
|| inMsg.isNull(EKU0011B010CBSMsg.DISPLAY_PAGE_NUM))
{
throw new IllegalArgumentException(JKUStrConst.ICRN_ERR_MSG_BBN);
}
}
else
{
throw new IllegalArgumentException(JKUStrConst.ICRN_ERR_MSG_FUSEI_PTN);
}
/********************
* SQL文の作成
********************/
try{
//コネクション取得
con1 = JSYejbConnection.getConnection(KU0011ETMsg.getTableName());
/***********************************************************************************************
* 総件数取得
*/
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
StringBuffer sql_Select = new StringBuffer();
StringBuffer sql_From = new StringBuffer();
StringBuffer sql_Where = new StringBuffer();
StringBuffer sql_Order = new StringBuffer();
// SQL文_基本部1
sql_Select.append(" SELECT ")
.append(" ROW_NUMBER() OVER(ORDER BY KU0011.KOJIAK_REQYMD DESC, KU0011.KOJIAK_NO DESC, KU0011.PRC_GRP_CD ASC) AS ROW_NUM ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN KU0081.KOJIAK_NO ")
.append(" ELSE KU0071.KOJIAK_NO ")
.append(" END KOJIAK_NO ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN KU0081.SVC_KEI_NO ")
.append(" ELSE KU0071.HJIN_EO_YKAE_SVKEI_NO ")
.append(" END SVC_KEI_NO ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN KU0011.PRC_GRP_CD ")
.append(" ELSE KU0011.HOJIN_PRC_GRP_CD ")
.append(" END PRC_GRP_CD ")
.append(" ,CASE ")
.append(" WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN ")
.append(" CASE ")
.append(" WHEN KU0011.KOJIAK_REQYMD IS NOT NULL ")
.append(" THEN ")
.append(" (SELECT KK0781.PRC_GRP_NM FROM KK_M_PRC_GRP KK0781 ")
.append(" WHERE ")
.append(" KU0011.PRC_GRP_CD = KK0781.PRC_GRP_CD ")
.append(" AND KU0011.KOJIAK_REQYMD BETWEEN KK0781.PRC_GRP_TSTAYMD AND KK0781.PRC_GRP_TENDYMD ")
.append(" AND KK0781.MK_FLG = '0') ")
.append(" WHEN KU0011.MSKM_UK_YMD IS NOT NULL ")
.append(" THEN ")
.append(" (SELECT KK0781.PRC_GRP_NM FROM KK_M_PRC_GRP KK0781 ")
.append(" WHERE ")
.append(" KU0011.PRC_GRP_CD = KK0781.PRC_GRP_CD ")
.append(" AND KU0011.MSKM_UK_YMD BETWEEN KK0781.PRC_GRP_TSTAYMD AND KK0781.PRC_GRP_TENDYMD ")
.append(" AND KK0781.MK_FLG = '0') ")
.append(" ELSE ")
.append(" (SELECT KK0781.PRC_GRP_NM FROM KK_M_PRC_GRP KK0781 ")
.append(" WHERE ")
.append(" KU0011.PRC_GRP_CD = KK0781.PRC_GRP_CD ")
.append(" AND KK0781.PRC_GRP_TENDYMD = '20991231' ")
.append(" AND KK0781.MK_FLG = '0') ")
.append(" END ")
.append(" ELSE ")
.append(" (SELECT ZM0171.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171 ")
.append(" WHERE ZM0171.CD_SBT_CD = 'CD00886' ")
.append(" AND KU0011.HOJIN_PRC_GRP_CD = ZM0171.CD_DIV ")
.append(" AND ZM0171.MK_FLG = '0') ")
.append(" END PRC_GRP_NM ")
.append(" ,KU0011.KOJIAK_SBT_CD ")
.append(" ,(SELECT ZM0171.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171 ")
.append(" WHERE ZM0171.CD_SBT_CD = 'CD00577' ")
.append(" AND KU0011.KOJIAK_SBT_CD = ZM0171.CD_DIV ")
.append(" AND ZM0171.MK_FLG = '0' ")
.append(" )KOJIAK_SBT_NM ")
.append(" ,KU0011.KOJIAK_STAT ")
.append(" ,(SELECT ZM0171.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171 ")
.append(" WHERE ZM0171.CD_SBT_CD = 'CD00474' ")
.append(" AND KU0011.KOJIAK_STAT = ZM0171.CD_DIV ")
.append(" AND ZM0171.MK_FLG = '0' ")
.append(" )KOJIAK_STAT_NM ")
.append(" ,KU0011.KOJIAK_REQYMD ")
.append(" ,KU0011.KOJIAK_JSSI_YMD ")
.append(" ,KU0011.CUST_NM ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN KU0011.PCRS_CD ")
.append(" ELSE KU0011.HOJIN_PCRS_CD ")
.append(" END PCRS_CD ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN KU0011.PPLAN_CD ")
.append(" ELSE KU0011.HOJIN_PPLAN_CD ")
.append(" END PPLAN_CD ")
.append(" ,KU0011.WRIB_TYPE_CD ")
.append(" ,KU0011.MANSION_BUKKEN_CD ")
.append(" ,KU0061.MANS_TUSHIN_EQUIP_CD ")
.append(" ,KU0061.IP_HRADSI_CD ")
.append(" ,CASE WHEN KU0011.HOJIN_PRC_GRP_CD IS NULL or KU0011.HOJIN_PRC_GRP_CD = '' ")
.append(" THEN CASE WHEN KU0011.PRC_GRP_CD = '10' ")
.append(" THEN CASE WHEN KU0011.MANSION_BUKKEN_CD IS NULL or KU0011.MANSION_BUKKEN_CD = '' ")
.append(" THEN '001' ")
.append(" ELSE '005' ")
.append(" END ")
.append(" ELSE CASE WHEN KU0011.PRC_GRP_CD = '02' THEN '001' ")
.append(" WHEN KU0011.PRC_GRP_CD = '03' or KU0011.PRC_GRP_CD = '04' THEN '005' ")
.append(" WHEN KU0011.PRC_GRP_CD = '12' THEN '003' ")
.append(" WHEN KU0011.PRC_GRP_CD = '11' or KU0011.PRC_GRP_CD = '13' THEN '002' ")
.append(" ELSE '' ")
.append(" END ")
.append(" END ")
.append(" ELSE '004' ")
// v13.00.00 MOD START
//.append(" END SENI_INFO ");
.append(" END SENI_INFO ")
// v13.00.00 MOD END
// v13.00.00 ADD START
.append(" ,KU0011.MANS_KOJIAK_STAT_CD")
.append(" ,(SELECT ZM0171.CD_DIV_NM ")
.append(" FROM ZM_M_CD_NM_KANRI ZM0171 ")
.append(" WHERE ZM0171.CD_SBT_CD = 'CD01651' ")
.append(" AND KU0011.MANS_KOJIAK_STAT_CD = ZM0171.CD_DIV ")
.append(" AND ZM0171.MK_FLG = '0' ")
// ANK-3136-00-00 MOD START
// .append(" )MANS_KOJIAK_STAT_CD_NM ");
.append(" )MANS_KOJIAK_STAT_CD_NM ")
// v13.00.00 ADD END
// ANK-3989-00-00 MOD START
// .append(" ,KU0011.EQUIP_RYUYO_UM ");
.append(" ,KU0011.EQUIP_RYUYO_UM ")
.append(" ,KU0061.TK_HOSHIKI_PATTERN_CD ")
.append(" ,KU0061.TONAI_SPEED_CD ")
// ANK-3989-00-00 MOD END
// ANK-3136-00-00 MOD END
// ANK-4009-00-00 ADD START
.append(" ,KU0011.TAKNI_KOJI_FIN_RSV_YMD ")
// ANK-4009-00-00 ADD END
// OM-2022-0001108 ADD START
.append(" ,KU0011.KOJI_UK_OPTNTY_IDO_DIV ");
// OM-2022-0001108 ADD END
//From句
sql_From.append(" FROM ")
.append(" KU_T_KOJIAK KU0011 ")
.append(" LEFT OUTER JOIN KU_T_SVKEI_KOJIAK KU0081 ")
.append(" ON KU0011.KOJIAK_NO = KU0081.KOJIAK_NO ")
.append(" AND KU0081.MK_FLG = '0' ")
.append(" LEFT OUTER JOIN KU_T_HOJINSVKEI_KJAK KU0071 ")
.append(" ON KU0011.KOJIAK_NO = KU0071.KOJIAK_NO ")
.append(" AND KU0071.MK_FLG = '0' ")
.append(" LEFT OUTER JOIN KU_T_KJAK_EOH_NTMANS KU0061 ")
.append(" ON KU0011.KOJIAK_NO = KU0061.KOJIAK_NO ")
.append(" AND KU0061.MK_FLG = '0' ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(EKU0011B010CBSMsg.FUNC_CODE).toString() ) ) {
sql_Where.append(" WHERE ")
.append(" (EXISTS (SELECT ")
.append(" 1 ")
.append(" FROM ")
.append(" KU_T_SVKEI_KOJIAK KU0081 ")
.append(" WHERE ")
.append(" KU0081.SVC_KEI_NO = ? ")
.append(" AND KU0011.KOJIAK_NO = KU0081.KOJIAK_NO ")
.append(" AND KU0081.MK_FLG = '0') ")
.append(" OR EXISTS (SELECT ")
.append(" 1 ")
.append(" FROM ")
.append(" KU_T_HOJINSVKEI_KJAK KU0071 ")
.append(" WHERE ")
.append(" KU0071.HJIN_EO_YKAE_SVKEI_NO = ? ")
.append(" AND KU0011.KOJIAK_NO = KU0071.KOJIAK_NO ")
.append(" AND KU0071.MK_FLG = '0') ")
.append(" ) ")
.append(" AND KU0011.KOJIAK_SBT_CD != '005' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '010' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '011' ")
.append(" AND KU0011.MK_FLG = '0' ");
}
if ( "2".equals( inMsg.getObject(EKU0011B010CBSMsg.FUNC_CODE).toString() ) ) {
sql_Where.append(" WHERE ")
.append(" KU0011.KOJIAK_NO = ? ")
.append(" AND KU0011.KOJIAK_SBT_CD != '005' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '010' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '011' ")
.append(" AND KU0011.MK_FLG = '0' ");
}
if ( "3".equals( inMsg.getObject(EKU0011B010CBSMsg.FUNC_CODE).toString() ) ) {
sql_Where.append(" WHERE ")
.append(" (EXISTS (SELECT ")
.append(" 1 ")
.append(" FROM ")
.append(" KU_T_SVKEI_KOJIAK KU0081 ")
.append(" WHERE ")
.append(" KU0081.SVC_KEI_NO = ? ")
.append(" AND KU0011.KOJIAK_NO = KU0081.KOJIAK_NO ")
.append(" AND KU0081.MK_FLG = '0') ")
.append(" OR EXISTS (SELECT ")
.append(" 1 ")
.append(" FROM ")
.append(" KU_T_HOJINSVKEI_KJAK KU0071 ")
.append(" WHERE ")
.append(" KU0071.HJIN_EO_YKAE_SVKEI_NO = ? ")
.append(" AND KU0011.KOJIAK_NO = KU0071.KOJIAK_NO ")
.append(" AND KU0071.MK_FLG = '0') ")
.append(" ) ")
.append(" AND KU0011.KOJIAK_SBT_CD != '005' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '010' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '011' ")
// v13.00.00 DEL START
//.append(" AND KU0011.KOJIAK_STAT != '120' ")
// v13.00.00 DEL END
.append(" AND KU0011.MK_FLG = '0' ");
}
if ( "4".equals( inMsg.getObject(EKU0011B010CBSMsg.FUNC_CODE).toString() ) ) {
sql_Where.append(" WHERE ")
.append(" KU0011.KOJIAK_NO = ? ")
.append(" AND KU0011.KOJIAK_SBT_CD != '005' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '010' ")
.append(" AND KU0011.KOJIAK_SBT_CD != '011' ")
// v13.00.00 DEL START
//.append(" AND KU0011.KOJIAK_STAT != '120' ")
// v13.00.00 DEL END
.append(" AND KU0011.MK_FLG = '0' ");
}
sql_Order.append(" ORDER BY ")
.append(" KU0011.KOJIAK_REQYMD DESC ")
.append(" ,KU0011.KOJIAK_NO DESC ")
.append(" ,KU0011.PRC_GRP_CD ASC ");
//パラメータ取得
int iDispNum = 0;
int iDispPageNum = 0;
//開始行、終了行設定
int iStartNum = 0;
int iEndNum = 0;
Object svcKeiNo = inMsg.getObject(EKU0011B010CBSMsg.KEY_KOJIAK_NO_SVC_KEI_NO);
//件数取得SQL
StringBuffer sql_cnt = new StringBuffer();
sql_cnt.append(" SELECT ")
.append(" COUNT(*) AS CNT ")
.append(sql_From)
.append(sql_Where);
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_cnt.toString());
//パラメータ設定用Index 初期化
iIndex = 1;
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "2".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "3".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "4".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_cnt);
/**
* SQL文実行
*/
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// EKU0011B010CBSMsgの明細にセットする項目
String[] msgKeyListCnt = {
EKU0011B010CBSMsg.TOTAL_SEARCH_NUM
};
/**
* 結果取得
*/
rsltQuery.next();
mapMessage(rsltQuery, msgKeyListCnt, inMsg);
// 総ページ数設定
int iTotal = Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.TOTAL_SEARCH_NUM));
// 部分検索の場合
if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
//パラメータ取得
iDispNum = Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.DISPLAY_NUM));
iDispPageNum = Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.DISPLAY_PAGE_NUM));
//開始行、終了行設定
iStartNum = iDispNum * (iDispPageNum - 1) + 1;
iEndNum = iDispNum * iDispPageNum;
/**
* 総ページ数、エラーフラグ設定
*/
int iSearchDivDisp = iTotal / iDispNum;
int iRest = iTotal % iDispNum;
// 割り切れない場合は総ページ数を増やす
if (0 != iRest)
{
iSearchDivDisp++;
}
inMsg.set(EKU0011B010CBSMsg.TOTAL_PAGE_NUM, Integer.toString(iSearchDivDisp));
}
// 一括検索、部分検索の場合
// 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了
if (0 == (Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.TOTAL_SEARCH_NUM))))
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
return;
}
// 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了
if (Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.MAX_SEARCH_NUM))
< (Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.TOTAL_SEARCH_NUM))))
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX);
return;
}
// 部分検索の場合
if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
// 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了
if (iTotal < iStartNum)
//if (Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.MAX_SEARCH_NUM)) < iStartNum)
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
}
if(rsltQuery != null){
rsltQuery.close();
}
if(pstmt != null){
pstmt.close();
}
/***********************************************************************************************
* データ取得
*/
sql_Buff.append(" SELECT ")
.append(" TBL.KOJIAK_NO, ")
.append(" TBL.SVC_KEI_NO, ")
.append(" TBL.PRC_GRP_CD, ")
.append(" TBL.PRC_GRP_NM, ")
.append(" TBL.KOJIAK_SBT_CD, ")
.append(" TBL.KOJIAK_SBT_NM, ")
.append(" TBL.KOJIAK_STAT, ")
.append(" TBL.KOJIAK_STAT_NM, ")
.append(" TBL.KOJIAK_REQYMD, ")
.append(" TBL.KOJIAK_JSSI_YMD, ")
.append(" TBL.CUST_NM, ")
.append(" TBL.PCRS_CD, ")
.append(" TBL.PPLAN_CD, ")
.append(" TBL.WRIB_TYPE_CD, ")
.append(" TBL.MANSION_BUKKEN_CD, ")
.append(" TBL.MANS_TUSHIN_EQUIP_CD, ")
.append(" TBL.IP_HRADSI_CD, ")
// v13.00.00 MOD START
//.append(" TBL.SENI_INFO ")
.append(" TBL.SENI_INFO, ")
// v13.00.00 MOD END
// v13.00.00 ADD START
.append(" TBL.MANS_KOJIAK_STAT_CD, ")
// ANK-3136-00-00 MOD START
// .append(" TBL.MANS_KOJIAK_STAT_CD_NM ")
.append(" TBL.MANS_KOJIAK_STAT_CD_NM, ")
// v13.00.00 ADD END
.append(" TBL.EQUIP_RYUYO_UM ")
// ANK-3136-00-00 MOD END
// ANK-3989-00-00 ADD START
.append(" ,TBL.TK_HOSHIKI_PATTERN_CD ")
.append(" ,TBL.TONAI_SPEED_CD ")
// ANK-3989-00-00 ADD END
// ANK-4009-00-00 ADD START
.append(" ,TBL.TAKNI_KOJI_FIN_RSV_YMD ")
// ANK-4009-00-00 ADD END
// OM-2022-0001108 ADD START
.append(" ,TBL.KOJI_UK_OPTNTY_IDO_DIV ")
// OM-2022-0001108 ADD END
.append(" FROM ")
.append(" ( ")
.append(sql_Select)
.append(sql_From)
.append(sql_Where)
.append(sql_Order)
.append(" ) TBL ");
if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
sql_Buff.append(" WHERE ");
sql_Buff.append(" TBL.ROW_NUM BETWEEN ? AND ? ");
}
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//パラメータ設定用Index 初期化
iIndex = 1;
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "2".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "3".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if ( "4".equals( inMsg.getString(EKU0011B010CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定(ＫＥＹ＿工事案件番号サービス契約番号を指定)
CAANJDBCUtil.setParam(pstmt, iIndex++, svcKeiNo);
}
if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
//開始レコードの設定
CAANJDBCUtil.setParam(pstmt, iIndex++, iStartNum);
//終了レコードの設定
CAANJDBCUtil.setParam(pstmt, iIndex++, iEndNum);
}
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// EKU0011B010CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKU0011B010CBSMsg1List.KOJIAK_NO
, EKU0011B010CBSMsg1List.SVC_KEI_NO
, EKU0011B010CBSMsg1List.PRC_GRP_CD
, EKU0011B010CBSMsg1List.PRC_GRP_NM
, EKU0011B010CBSMsg1List.KOJIAK_SBT_CD
, EKU0011B010CBSMsg1List.KOJIAK_SBT_NM
, EKU0011B010CBSMsg1List.KOJIAK_STAT
, EKU0011B010CBSMsg1List.KOJIAK_STAT_NM
, EKU0011B010CBSMsg1List.KOJIAK_REQYMD
, EKU0011B010CBSMsg1List.KOJIAK_JSSI_YMD
, EKU0011B010CBSMsg1List.CUST_NM
, EKU0011B010CBSMsg1List.PCRS_CD
, EKU0011B010CBSMsg1List.PPLAN_CD
, EKU0011B010CBSMsg1List.WRIB_TYPE_CD
, EKU0011B010CBSMsg1List.MANSION_BUKKEN_CD
, EKU0011B010CBSMsg1List.MANS_TUSHIN_EQUIP_CD
, EKU0011B010CBSMsg1List.IP_HRADSI_CD
, EKU0011B010CBSMsg1List.SENI_INFO
// v13.00.00 ADD START
, EKU0011B010CBSMsg1List.MANS_KOJIAK_STAT_CD
, EKU0011B010CBSMsg1List.MANS_KOJIAK_STAT_CD_NM
// v13.00.00 ADD END
// ANK-3136-00-00 ADD START
, EKU0011B010CBSMsg1List.EQUIP_RYUYO_UM
// ANK-3136-00-00 ADD END
// ANK-3989-00-00 ADD START
, EKU0011B010CBSMsg1List.TK_HOSHIKI_PATTERN_CD
, EKU0011B010CBSMsg1List.TONAI_SPEED_CD
// ANK-3989-00-00 ADD END
// ANK-4009-00-00 ADD SRAT
, EKU0011B010CBSMsg1List.TAKNI_KOJI_FIN_RSV_YMD
// ANK-4009-00-00 ADD END
// OM-2022-0001108 ADD START
, EKU0011B010CBSMsg1List.KOJI_UK_OPTNTY_IDO_DIV
// OM-2022-0001108 ADD END
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKU0011B010CBSMsg1List",0);
// 検索エラーフラグの設定
// 一括検索の場合
if (JPCModelConstant.SAERCH_TYPE_IKT.equals(searchType))
{
// 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了
if (0 == outMsg1.length)
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
return;
}
// 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了
if (Integer.parseInt(inMsg.getString(EKU0011B010CBSMsg.MAX_SEARCH_NUM))
< (outMsg1.length))
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX);
return;
}
}
// 部分検索の場合
if(JPCModelConstant.SAERCH_TYPE_BBN.equals(searchType))
{
// 表示ページに該当するデータがない場合、エラーフラグに"3"を設定して処理終了
if (outMsg1.length == 0)
{
inMsg.set(EKU0011B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
}
// 検索エラーフラグの設定
// 一括検索の場合
if (JPCModelConstant.SAERCH_TYPE_IKT.equals(searchType))
{
//総検索件数を再設定
inMsg.set(EKU0011B010CBSMsg.TOTAL_SEARCH_NUM, Integer.toString(outMsg1.length));
}
// inMsg(CBSMsg)に明細をセット
inMsg.set("EKU0011B010CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(EKU0011B010CBSMsg.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(EKU0011B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}