> mapListOnly = getSkyGki(inMsg, inContext, "MVNO_ONLY");
// 請求内訳合計明細が存在しない場合
//ANK-4418-00-00 ADD START
//if (mapListGki.size() == 0 || mapListOnly.size() == 0)
if (mapListGki.size() == 0 )
//ANK-4418-00-00 ADD END
{
// inMsg(CBSMsg)に明細をセット
outMsg1.set(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "0");
rsltMsgList.add(outMsg1);
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
}
// 請求内訳合計明細とmineo単独請求明細の件数が不一致の場合
if (mapListGki.size() != mapListOnly.size())
{
//ANK-4418-00-00 ADD START
// 初期費用もしくはmineo単独料金項目コードのいずれも存在しない場合
if( shokiCnt == 0 || !mineoSoroFlg )
{
//ANK-4418-00-00 ADD END
// inMsg(CBSMsg)に明細をセット
outMsg1.set(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "0");
rsltMsgList.add(outMsg1);
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
//ANK-4418-00-00 ADD START
}
//ANK-4418-00-00 ADD END
}
//ANK-4418-00-00 MOD START
// 請求内訳リストとmineo単独リストのサイズが一致の場合
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(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "0");
rsltMsgList.add(outMsg1);
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
}
// 請求内訳合計明細とmineo単独請求明細の料金グループコード、料金項目コードが不一致の場合
if (!mapListGki.get(i).get(CH0101ETMsg.PRC_GRP_CD).equals(mapListOnly.get(i).get(CH0101ETMsg.PRC_GRP_CD)) ||
!mapListGki.get(i).get(CH0101ETMsg.PRC_KMK_CD).equals(mapListOnly.get(i).get(CH0101ETMsg.PRC_KMK_CD)))
{
// inMsg(CBSMsg)に明細をセット
outMsg1.set(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "0");
rsltMsgList.add(outMsg1);
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
}
}
}
// 請求内訳リストとmineo単独リストのサイズが差分１かつ、初期費用とmineo単独合計金額が一致する場合
else if (mapListGki.size() - mapListOnly.size() == shokiCnt && shokiTotalAmnt == mineoSoroTotalAmnt )
{
//mineo単独の場合とみなす
;
}
else
{
// inMsg(CBSMsg)に明細をセット
outMsg1.set(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "0");
rsltMsgList.add(outMsg1);
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
}
//ANK-4418-00-00 MOD END
// mineo単独の場合
outMsg1.set(ECH0051B060CBSMsg1List.MVNO_CHK_FLG, "1");
rsltMsgList.add(outMsg1);
// inMsg(CBSMsg)に明細をセット
inMsg.set("ECH0051B060CBSMsg1List", (CAANMsg[])rsltMsgList.toArray(new CAANMsg[0]));
return;
}
/**
*
* 当月分がmineo単独以外で当月ご請求料金が存在するかをチェックする
*
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext Agentから渡されたAgentDispatchContext
* @return 検索結果 true：存在する false：存在しない
*/
public long getMineoChk(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(ECH0051B060CBSMsg.KEY_SEIKY_NO));
// パラメータの設定(ＫＥＹ＿請求年月を指定)
CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B060CBSMsg.KEY_SEIKY_YM));
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// 件数を返却する
if (rsltQuery.next())
{
lDataCnt = rsltQuery.getLong("CNT_CHEK");
}
} catch(SQLException e) {
inMsg.set(ECH0051B060CBSMsg.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(ECH0051B060CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
return lDataCnt;
}
/**
*
* mineo請求が存在するかをチェックする
*
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext Agentから渡されたAgentDispatchContext
* @return 検索結果 true：存在する false：存在しない
*/
public long getMineoCnt(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 ")
.append(" AND CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
.append(" AND CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
.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 = 'MVNO_CHEK' ")
.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(ECH0051B060CBSMsg.KEY_SEIKY_NO));
// パラメータの設定(ＫＥＹ＿請求年月を指定)
CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B060CBSMsg.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(ECH0051B060CBSMsg.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(ECH0051B060CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
return lDataCnt;
}
/**
*
* 請求内訳合計明細を取得する
*
* @param inMsg 処理対象のメッセージキャリア
* @param inContext ディスパッチコンテキスト
* @param workKinoSkbtCd 業務機能識別コード
* @return サービス契約回線内訳のカレントレコード情報
* 該当するレコードが存在しない場合null
*/
private ArrayList> getSkyGki(CAANMsg inMsg, AgentDispatchContext inContext, String workKinoSkbtCd)
{
// 返却用メッセージ
ArrayList> mapList = new ArrayList>();
// コネクション
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) ")
.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 ")
.append(" AND CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
.append(" AND CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
.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(ECH0051B060CBSMsg.KEY_SEIKY_NO));
// パラメータの設定(ＫＥＹ＿請求年月を指定)
CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B060CBSMsg.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 map = null;
// 取得結果をマップに格納
while (rsltQuery.next())
{
// レコード情報格納用マップを初期化する
map = new HashMap();
// 取得したレコード情報をセットする
map.put(CH0101ETMsg.PRC_GRP_CD, rsltQuery.getString(1));
map.put(CH0101ETMsg.PRC_KMK_CD, rsltQuery.getString(2));
// セットした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);
}
}
}
//ANK-4418-00-00 ADD START
/**
*
* 業務パラメータ管理から対象データを取得
*
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext Agentから渡されたAgentDispatchContext
* @return 検索結果 取得値：
*/
public String getWorkParamKanri(CAANMsg inMsg,AgentDispatchContext inContext){
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
String prcKmkCd = null;
/********************
* SQL文の作成
********************/
try{
//コネクション取得
con1 = JSYejbConnection.getConnection(CH0051ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT REGEXP_REPLACE(REGEXP_REPLACE( ZM0321.WORK_PARAM_SETTE_VALUE,'^|$',''''),',',''',''') AS PRC_KMK_CD ")
.append(" FROM ZM_M_WORK_PARAM_KNRI ZM0321 ")
.append(" WHERE ZM0321.WORK_PARAM_ID = 'CH_MVNO_ONLY_PRC_KMK' ")
.append(" AND ZM0321.WORK_PARAM_TSTAYMD <= ? ")
.append(" AND ZM0321.WORK_PARAM_TENDYMD >= ? ")
.append(" AND ZM0321.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, JPCModelCommon.getOpeDate(inMsg, inContext, null));
// パラメータの設定(運用日付を指定)
CAANJDBCUtil.setParam(pstmt, 2, JPCModelCommon.getOpeDate(inMsg, inContext, null));
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// 業務パラメータ管理に設定されている料金項目コードを取得する
if (rsltQuery.next())
{
prcKmkCd = rsltQuery.getString("PRC_KMK_CD");
}
} catch(SQLException e) {
inMsg.set(ECH0051B060CBSMsg.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(ECH0051B060CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
return prcKmkCd;
}
/**
*
* 請求内訳合計明細を取得する
*
* @param inMsg 処理対象のメッセージキャリア
* @param inContext ディスパッチコンテキスト
* @param workKinoSkbtCd 業務機能識別コード
* @param workParamPrcKmkCd 料金項目コード
* @return 請求内訳レコード情報
* 該当するレコードが存在しない場合null
*/
private ArrayList> getshokiMineoSoroPrckmk(CAANMsg inMsg, AgentDispatchContext inContext,
String workKinoSkbtCd, String workParamPrcKmkCd)
{
// 返却用メッセージ
ArrayList> mapList = new ArrayList>();
// コネクション
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) ")
.append(" , TO_CHAR(CH0101_02.AMNT) ")
.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 ")
.append(" AND CH0401_02.PRC_SVC_CD = CH0101_02.PRC_SVC_CD ")
.append(" AND CH0401_02.PRC_KMK_CD = CH0101_02.PRC_KMK_CD ")
.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(" AND ( CH0101_02.PRC_GRP_CD = '51' ")
.append(" AND CH0101_02.PRC_KMK_CD IN (" + workParamPrcKmkCd +") " )
.append(" OR CH0101_02.PRC_KMK_CD = ? ")
.append(" ) ")
.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(ECH0051B060CBSMsg.KEY_SEIKY_NO));
// パラメータの設定(ＫＥＹ＿請求年月を指定)
CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECH0051B060CBSMsg.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));
// パラメータの設定(料金項目コードを指定)
CAANJDBCUtil.setParam(pstmt, 8, SHOKIHIY_OPRCKMKCD);
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// リスト格納用マップ
HashMap map = null;
// 取得結果をマップに格納
while (rsltQuery.next())
{
// レコード情報格納用マップを初期化する
map = new HashMap();
// 取得したレコード情報をセットする
map.put(CH0101ETMsg.PRC_GRP_CD, rsltQuery.getString(1));
map.put(CH0101ETMsg.PRC_KMK_CD, rsltQuery.getString(2));
map.put(CH0101ETMsg.AMNT, rsltQuery.getString(3));
// セットした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);
}
}
}
//ANK-4418-00-00 ADD END
}