* 割引サービス契約解約確定の副次処理を行う部品クラスです。 *
* @author 富士通 */ public class JEKK0451C030ETDA implements TemplateMainHandler { /** ** 割引サービス契約解約確定の副次処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // EE対応表の条件の判定 // 異動予約更新処理を実行 update(inCBSMsg, inContext); return; } /** ** 異動予約更新処理のDBアクセス処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ private void update(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // ETMsgの作成 CAANMsg inETMsg = new CAANMsg(KK1681ETMsg.class.getName()); // 予約適用年月日 RSV_APLY_YMD inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, inCBSMsg.getString(EKK0451C030CBSMsg.SVC_ENDYMD)); // 更新年月日時分秒 UPD_DTM inETMsg.set(KK1681ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); // 更新オペレータアカウント UPD_OPEACNT inETMsg.set(KK1681ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); // 異動予約番号のリスト取得 CAANMsg[] resultList = getKK1681(inCBSMsg); // 更新対象「異動予約」 CAANMsg updTgKK1681Msg = null; // 更新対象「異動予約」の異動予約番号 String updTgIdoRsvNo = null; // 取得した異動予約番号の数だけ更新処理を行う for (CAANMsg kk1681Msg : resultList) { /* ---------------------------------------------------------------------------------------------------- * 異動予約番号が最大の「異動予約」を返却対象とする。 * ---------------------------------------------------------------------------------------------------- */ String idoRsvNo = kk1681Msg.getString(KK1681ETMsg.IDO_RSV_NO); if (updTgIdoRsvNo == null || updTgIdoRsvNo.compareTo(idoRsvNo) < 0) { updTgIdoRsvNo = idoRsvNo; updTgKK1681Msg = kk1681Msg; } // 異動予約番号 IDO_RSV_NO inETMsg.set(KK1681ETMsg.IDO_RSV_NO, idoRsvNo); // 異動予約番号の更新 JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); dba.update(inETMsg); } if (updTgKK1681Msg == null) { throw new CAANRuntimeException("解約確定対象の割引サービス契約に対する異動予約が存在しません。割引サービス契約番号:" + inCBSMsg.getString(EKK0451C030CBSMsg.WRIB_SVC_KEI_NO)); } // 自動予約取消ワークへの設定用 // 入力．異動区分が未設定の場合(Not Null項目のため) if (inCBSMsg.isNull(EKK0451C030CBSMsg.IDO_DIV)) { inCBSMsg.set(EKK0451C030CBSMsg.IDO_DIV, updTgKK1681Msg.getObject(KK1681ETMsg.IDO_DIV)); } // 入力．申込明細番号が未設定の場合(Not Null項目ではないがなるべく設定したいため) if (inCBSMsg.isNull(EKK0451C030CBSMsg.MSKM_DTL_NO)) { inCBSMsg.set(EKK0451C030CBSMsg.MSKM_DTL_NO, updTgKK1681Msg.getObject(KK1681ETMsg.MSKM_DTL_NO)); } return; } /** * DBより条件に一致する異動予約番号を取得して配列で返却する。 * @param inCBSMsg 入力元のCBSMsg * @return 更新対象の異動予約番号リスト */ private CAANMsg[] getKK1681(CAANMsg inCBSMsg) { KK1681LE le = new KK1681LE(); // 異動予約参照用Msg生成 CAANMsg conditionETMsg = new CAANMsg(KK1681ETMsg.class.getName()); conditionETMsg.set(KK1681ETMsg.WRIB_SVC_KEI_NO, inCBSMsg.getString(EKK0451C030CBSMsg.WRIB_SVC_KEI_NO)); conditionETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, JKKModelConst.IDO_RSV_DTL_CD_WRIB_DSL); conditionETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, JKKModelConst.IDO_RSV_STAT_CD_IDO_RSV_TG_GAI); conditionETMsg.set(KK1681ETMsg.MK_FLG, "0"); //条件付き一覧照会 CAANMsg[] resultMsg; try { resultMsg = le.findByCondition(conditionETMsg); } catch (CAANException e) { throw new CAANRuntimeException(e); } return resultMsg; } }