のデータが異常です");
}
}
else
{
// カレントレコードにトビラフォンIDが存在する場合
if (!JKKStringUtil.isNullBlank(kk0371CurDate.get(KK0371ETMsg.TOBILAPH_ID)))
{
sbSql.append(" WHERE KK3081.TOBILAPH_ID = ?");
arraylist.add(kk0371CurDate.get(KK0371ETMsg.TOBILAPH_ID));
}
else
{
throw new CAANRuntimeException("オプションサービス契約<電話>のデータが異常です");
}
}
// ANK-3754-00-00 MOD END
sbSql.append(" AND KK3081.TAJGS_KEI_IDO_SBT_CD = ?");
arraylist.add(whereTajgyKeiIdoSbtCd);
sbSql.append(" AND KK3081.TAJGS_KEI_IDT_STAT_CD IN('")
.append(TAJGS_KEI_IDT_STAT_CD_MITUTI + "', '") //未通知か
.append(TAJGS_KEI_IDT_STAT_CD_SYORITYU + "')") //処理中か
.append(" AND KK3081.MK_FLG = '0' ");
try
{
//コネクション取得
con = JSYejbConnection.getConnection(KK3081ETMsg.getTableName());
//prepareStatementにSQL文をセット
pstmt = con.prepareStatement(sbSql.toString());
//ログ出力(SQL文の出力)
JSYejbLog.println(JSYejbLog.DEBUG, this.getClass(), sbSql);
// バインド変数設定
for (int iCnt = 0; iCnt < arraylist.size(); iCnt++)
{
// バインド変数に設定
CAANJDBCUtil.setParam(pstmt, ++iPCnt, arraylist.get(iCnt));
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// 取得結果返却用のメッセージを用意
CAANMsg rtnMsg = null;
int recCntMituti = 0;
CAANMsg[] outMsg1 = mapMessageList(rsltQuery, getSelectMsgColumnList(), 0);
for (int i = 0; i < outMsg1.length; i++)
{
if (!isAddPattern)
{
// 解約処理において、処理中の登録レコードが存在する場合、関連制約エラーを設定し返却
if (TAJGS_KEI_IDT_STAT_CD_SYORITYU.equals(outMsg1[i].getString(KK3081ETMsg.TAJGS_KEI_IDT_STAT_CD)))
{
inCBSMsg.set(JCMConstants.STATUS_INT_KEY, StatusCodes.RELATION_ERR);
inCBSMsg.set(OP_SVC_KEI_NO_ERR, "EV");
return null;
}
}
// 未通知のレコードが存在する場合
if (TAJGS_KEI_IDT_STAT_CD_MITUTI.equals(outMsg1[i].getString(KK3081ETMsg.TAJGS_KEI_IDT_STAT_CD)))
{
rtnMsg = outMsg1[i];
recCntMituti++;
}
}
//未通知のレコードが1件異常の場合、システムエラー
if (1 < recCntMituti)
{
throw new CAANRuntimeException("他事業者契約異動通知のデータが異常です");
}
return rtnMsg;
}
catch (SQLException e)
{
throw new CAANRuntimeException(e);
}
finally
{
// 資源の解放
try
{
if (rsltQuery != null)
{
rsltQuery.close();
}
if (pstmt != null)
{
pstmt.close();
}
if (con != null)
{
CAANConnectionMgr.getInstance().close(con);
}
}
catch (SQLException e)
{
throw new CAANRuntimeException(e);
}
}
}
/**
*
* 他事業者契約異動通知の新規レコードを作成します。
*
* @param inCBSMsg CBSメッセージ
* @param inContext Agentから渡されたAgentDispatchContext
* @param kk3081RecData 新規レコード用データ
*/
private void insTajgsKeiIdt(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk3081RecData)
{
//共通項目を設定
kk3081RecData.set(KK3081ETMsg.TAJGS_KEI_IDT_NO, JKKModelCommon.getTajgsKeiIdtNoKK3081(inCBSMsg, inContext));
kk3081RecData.set(KK3081ETMsg.TAJGS_KEI_IDT_STAT_CD, TAJGS_KEI_IDT_STAT_CD_MITUTI); //未通知
kk3081RecData.set(KK3081ETMsg.TAJGS_KEI_IDO_HSI_YMD, JKKModelCommon.getOpeDate(inCBSMsg));
kk3081RecData.set(KK3081ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
kk3081RecData.set(KK3081ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
kk3081RecData.set(KK3081ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
kk3081RecData.set(KK3081ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
kk3081RecData.set(KK3081ETMsg.MK_FLG, "0");
try
{
// 登録処理の実行
create(kk3081RecData);
}
catch (CAANCreateException cce)
{
throw new CAANRuntimeException(cce);
}
}
/**
*
* 他事業者契約異動通知の更新処理をします。
*
* @param inCBSMsg CBSメッセージ
* @param inContext Agentから渡されたAgentDispatchContext
* @param kk3081RecMsg 他事業者契約異動通知のレコード
*/
private void updTajgsKeiIdt(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk3081RecMsg)
{
// 他事業者契約異動通知 更新用CAANMsg生成
CAANMsg updMsg = new CAANMsg(KK3081ETMsg.class.getName());
// 更新用の項目設定
updMsg.set(KK3081ETMsg.TAJGS_KEI_IDT_NO, kk3081RecMsg.getString(KK3081ETMsg.TAJGS_KEI_IDT_NO));
updMsg.set(KK3081ETMsg.TAJGS_KEI_IDT_STAT_CD, TAJGS_KEI_IDT_STAT_CD_TUTIHUYOU); //通知不要
updMsg.set(KK3081ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
updMsg.set(KK3081ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
// 更新処理の実行
try
{
update(updMsg);
}
catch (CAANFinderException cfe)
{
throw new CAANRuntimeException(cfe);
}
}
/**
*
* 他事業者契約異動通知予定年月日を60日後の翌月1日に設定します。
*
* @param opeDate 他事業者契約異動発生年月日（オンライン運用日）
* @return 他事業者契約異動通知予定年月日
* @throws ParseException
*/
private String editTajgsKeiIdtRsvYmd_60days(String opeDate) throws ParseException
{
String date_after60 = JKKModelCommon.addDay(opeDate, 60);
return editTajgsKeiIdtRsvYmd_1month(date_after60);
}
/**
*
* 他事業者契約異動通知予定年月日を翌月1日に設定します。
*
* @param opeDate 他事業者契約異動発生年月日（オンライン運用日）
* @return 他事業者契約異動通知予定年月日
* @throws ParseException
*/
private String editTajgsKeiIdtRsvYmd_1month(String opeDate) throws ParseException
{
return JKKModelCommon.addMonth(opeDate, 1).substring(0, 6).concat("01");
}
// ANK-3754-00-00 ADD START
/**
*
* オプションサービス契約＜電話>、サービス契約内訳に紐づく
* サービス契約のカレントレコードを取得。
*
* @param opSvcKeiNo オプションサービス契約番号
* @return
* @return オプションサービス契約＜電話＞、サービス契約内訳、サービス契約スキーマの検索結果
*/
private HashMap getKK0371byopSvcKeiNo(CAANMsg inCBSMsg, String opSvcKeiNo)
{
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
try
{
//コネクション取得
con1 = JSYejbConnection.getConnection(KK0371ETMsg.getTableName());
StringBuffer sb = new StringBuffer();
// 運用日付を取得
String opeDate = JKKModelCommon.getOpeDate(inCBSMsg);
// SELECT句は生成する
sb.append(" SELECT ")
.append(" KK0161.SVC_KEI_NO ")
.append(" , KK0161.KEIZK_AF_KEI_CHGECHU_FLG ")
.append(" , KK0191.TELNO ")
.append(" , KK0371.TOBILAPH_ID ")
.append("FROM ")
.append(" KK_T_OP_SVC_KEI KK0351 ")
.append(" INNER JOIN KK_T_OPSVKEI_TEL KK0371 ")
.append(" ON KK0371.OP_SVC_KEI_NO = KK0351.OP_SVC_KEI_NO ")
.append(" AND KK0371.GENE_ADD_DTM = KK0351.GENE_ADD_DTM ")
.append(" AND KK0371.MK_FLG = '0' ")
.append(" INNER JOIN KK_T_SVC_KEI_UCWK KK0161 ")
.append(" ON KK0161.SVC_KEI_UCWK_NO = KK0351.SVC_KEI_UCWK_NO ")
.append(" AND KK0161.RSV_APLY_YMD || KK0161.GENE_ADD_DTM = ( ")
.append(" SELECT ")
.append(" MAX( ")
.append(" KK0161_GENE.RSV_APLY_YMD || KK0161_GENE.GENE_ADD_DTM ")
.append(" ) AS KK0161_MAX ")
.append(" FROM ")
.append(" KK_T_SVC_KEI_UCWK KK0161_GENE ")
.append(" WHERE ")
.append(" KK0161_GENE.SVC_KEI_UCWK_NO = KK0161.SVC_KEI_UCWK_NO ")
.append(" AND KK0161_GENE.RSV_APLY_YMD <= '").append(opeDate).append("'")
.append(" AND KK0161_GENE.RSV_APLY_CD = '2' ")
.append(" AND KK0161_GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" INNER JOIN KK_T_SVKEIUW_EOH_TEL KK0191 ")
.append(" ON KK0191.SVC_KEI_UCWK_NO = KK0161.SVC_KEI_UCWK_NO ")
.append(" AND KK0191.GENE_ADD_DTM = KK0161.GENE_ADD_DTM ")
.append(" AND KK0191.MK_FLG = '0' ")
.append("WHERE ")
.append(" KK0351.OP_SVC_KEI_NO = '").append(opSvcKeiNo).append("'")
.append(" AND KK0351.RSV_APLY_YMD || KK0351.GENE_ADD_DTM = ( ")
.append(" SELECT ")
.append(" MAX( ")
.append(" KK0351_GENE.RSV_APLY_YMD || KK0351_GENE.GENE_ADD_DTM ")
.append(" ) AS KK0351_MAX ")
.append(" FROM ")
.append(" KK_T_OP_SVC_KEI KK0351_GENE ")
.append(" WHERE ")
.append(" KK0351_GENE.OP_SVC_KEI_NO = KK0351.OP_SVC_KEI_NO ")
.append(" AND KK0351_GENE.RSV_APLY_YMD <= '").append(opeDate).append("'")
.append(" AND KK0351_GENE.RSV_APLY_CD = '2' ")
.append(" AND KK0351_GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" AND KK0351.MK_FLG = '0' ");
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sb.toString());
//ログ出力(SQL文の出力)
JSYejbLog.println(JSYejbLog.DBACCESS, this.getClass(), sb);
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
HashMap hm = new HashMap();
// 検索結果の分繰り返し
while (rsltQuery.next())
{
hm.put(KK0161ETMsg.SVC_KEI_NO, rsltQuery.getString(KK0161ETMsg.SVC_KEI_NO));
hm.put(KK0161ETMsg.KEIZK_AF_KEI_CHGECHU_FLG, rsltQuery.getString(KK0161ETMsg.KEIZK_AF_KEI_CHGECHU_FLG));
hm.put(KK0191ETMsg.TELNO, rsltQuery.getString(KK0191ETMsg.TELNO));
hm.put(KK0371ETMsg.TOBILAPH_ID, rsltQuery.getString(KK0371ETMsg.TOBILAPH_ID));
}
return hm;
}
catch (SQLException se)
{
throw new CAANRuntimeException(se);
}
finally
{
// 資源の解放
try
{
if (rsltQuery != null)
{
rsltQuery.close();
}
if (pstmt != null)
{
pstmt.close();
}
if (con1 != null)
{
CAANConnectionMgr.getInstance().close(con1);
}
}
catch (SQLException se)
{
throw new CAANRuntimeException(se);
}
}
}
/**
*
* オプションサービス契約<電話>のトビラフォンIDを更新をします。
*
* @param inCBSMsg CBSメッセージ
* @param inContext Agentから渡されたAgentDispatchContext
* @param opSvcKeiNo オプションサービス契約番号
* @param tobilaphId トビラフォンID
*/
private void updOpsvcKeiTel(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo, String tobilaphId)
{
// オプションサービス契約<電話> 更新用CAANMsg生成
CAANMsg updMsg = new CAANMsg(KK0371ETMsg.class.getName());
// オプションサービス契約のカレントレコード
String currentGene = (String)JKKModelCommon.getCurrentGeneAddDtmKK0351(inCBSMsg, inContext, opSvcKeiNo);
// 更新用の項目設定
updMsg.set(KK0371ETMsg.OP_SVC_KEI_NO, opSvcKeiNo);
updMsg.set(KK0371ETMsg.GENE_ADD_DTM, currentGene);
updMsg.set(KK0371ETMsg.TOBILAPH_ID, tobilaphId);
updMsg.set(KK0371ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
updMsg.set(KK0371ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
// 更新処理の実行
JKKejbDBAUtil dbaUtil = new JKKejbDBAUtil(inCBSMsg);
dbaUtil.update(updMsg);
}
// ANK-3754-00-00 ADD END
}