* 機器提供サービス契約料金コース変更の副次処理を行う部品クラスです。 *
* @author 富士通 */ public class JEKK0341C160ETDA implements TemplateMainHandler { /** 異動予約詳細コード（機器コース変更） */ private static final String IDO_RSV_DTL_KIKI_CNG = "011"; // ANK-2141-00-00 ADD START /** 異動予約詳細コード：STB宅配交換 */ private static final String IDO_RSV_DTL_STB_DELIV_CHNG = "029"; /** 異動予約状態コード：未反映 */ private static final String IDO_RSV_STAT_MI_HANEI = "00"; // ANK-2141-00-00 ADD END /** 異動予約状態コード（異動予約対象外） */ private static final String IDO_RSV_STAT_OUT_TAG = "04"; /** プラン終了種別コード（プラン変更による終了） */ private static final String PLAN_END_SBT_PLAN_CNG = "1"; /** 機器提供サービスコード（BBR） */ private static final String KKTK_SVC_CD_BBR = "C014"; /** 異動区分（機器機種変更） */ private static final String IDO_DIV_KKCNG = "00028"; /** 無効フラグ（有効） */ private static final String MK_FLG_VALID = "0"; /** 月初日 */ private static final String GESYOBI = "01"; /** ** 機器提供サービス契約料金コース変更の副次処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void invoke(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // カレントレコードの取得処理 CAANMsg curRetMsg = this.findByCurrentKK0341(inCBSMsg, inContext); // EE対応表の条件の判定(機器提供サービス契約の更新) if (checkJokenForUpdate0341(inCBSMsg, inContext, curRetMsg)) { // 機器提供サービス契約のカレントレコードを更新 update0341(inCBSMsg, inContext, curRetMsg); } // 異動予約登録処理を実行 create(inCBSMsg, inContext); } /** ** 異動予約登録処理のDBアクセス処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ private void create(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // ETMsgの作成 CAANMsg inETMsg = new CAANMsg(KK1681ETMsg.class.getName()); // 異動予約番号 IDO_RSV_NO inETMsg.set(KK1681ETMsg.IDO_RSV_NO, new JKKejbKK1681NumberParts().getIdoRsvNo(inCBSMsg, inContext)); // 異動区分 IDO_DIV inETMsg.set(KK1681ETMsg.IDO_DIV, inCBSMsg.getString(EKK0341C160CBSMsg.IDO_DIV)); // ANK-2141-00-00 ADD START if (inCBSMsg.getString(EKK0341C160CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD) == null) { // ANK-2141-00-00 ADD END // 異動予約詳細コード IDO_RSV_DTL_CD inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, IDO_RSV_DTL_KIKI_CNG); // 予約適用年月日 RSV_APLY_YMD inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, JKKejbEditYmdInit.convRsvAplyYmdInit(inCBSMsg.getString(EKK0341C160CBSMsg.RSV_APLY_YMD))); // 異動予約状態コード IDO_RSV_STAT_CD inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, IDO_RSV_STAT_OUT_TAG); // ANK-2141-00-00 ADD START } else { CAANMsg inMsg = new CAANMsg(KK0341ETMsg.class.getName()); inMsg.set(KK0341ETMsg.KKTK_SVC_KEI_NO, inCBSMsg.getString(EKK0341C160CBSMsg.KKTK_SVC_KEI_NO)); inMsg.set(KK0341ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg)); JKKejbKK0341DBABase kk0341dba = new JKKejbKK0341DBABase(); CAANMsg[] kk0341 = kk0341dba.findByCurrentSecond(inMsg); // 変更前の機器変更番号を取得 String oldKikiChgNo = null; if (inCBSMsg.getString(EKK0341C160CBSMsg.GENE_ADD_DTM).equals(kk0341[0].getString(KK0341ETMsg.GENE_ADD_DTM))) { // 登録したレコードがカレントになっている場合 oldKikiChgNo = kk0341[1].getString(KK0341ETMsg.KIKI_CHG_NO); } else { // 登録したレコードがカレントになっていない場合 oldKikiChgNo = kk0341[0].getString(KK0341ETMsg.KIKI_CHG_NO); } // 異動予約詳細コード IDO_RSV_DTL_CD inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, IDO_RSV_DTL_STB_DELIV_CHNG); // 予約適用年月日 RSV_APLY_YMD String monthEndYmd = inCBSMsg.getString(EKK0341C160CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD).substring(0, 6); monthEndYmd = monthEndYmd + JPCUtilCommon.getEndOfMonth(monthEndYmd); inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, monthEndYmd); // 異動予約状態コード IDO_RSV_STAT_CD inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, IDO_RSV_STAT_MI_HANEI); // 交換希望年月日 KOKAN_KIBOYMD inETMsg.set(KK1681ETMsg.NEW_KIKI_USE_STA_KIBO_YMD, inCBSMsg.getString(EKK0341C160CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD)); // 新機器変更番号 NEW_KIKI_CHG_NO inETMsg.set(KK1681ETMsg.NEW_KIKI_CHG_NO, inCBSMsg.getString(EKK0341C160CBSMsg.KIKI_CHG_NO)); // 旧機器変更番号 OLD_KIKI_CHG_NO inETMsg.set(KK1681ETMsg.OLD_KIKI_CHG_NO, oldKikiChgNo); } // ANK-2141-00-00 ADD END // 申込明細番号 MSKM_DTL_NO inETMsg.set(KK1681ETMsg.MSKM_DTL_NO, inCBSMsg.getString(EKK0341C160CBSMsg.MSKM_DTL_NO)); // 機器提供サービス契約番号 KKTK_SVC_KEI_NO inETMsg.set(KK1681ETMsg.KKTK_SVC_KEI_NO, inCBSMsg.getString(EKK0341C160CBSMsg.KKTK_SVC_KEI_NO)); // 登録年月日時分秒 ADD_DTM inETMsg.set(KK1681ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); // 登録オペレータアカウント ADD_OPEACNT inETMsg.set(KK1681ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); // 更新年月日時分秒 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)); // 無効フラグ MK_FLG inETMsg.set(KK1681ETMsg.MK_FLG, MK_FLG_VALID); // 異動予約番号の登録 JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); dba.create(inETMsg); } /** ** 機器提供サービス契約の更新処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @param curRetMsg 処理対象のカレントレコード */ private void update0341(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg curRetMsg){ // ETMsgの作成 CAANMsg inETMsg = new CAANMsg(KK0341ETMsg.class.getName()); // 運用日付取得 String upd_date = JKKModelCommon.getOpeDate(inCBSMsg); // 機器提供サービス契約番号 String kktkSvcKeiNo = inCBSMsg.getString(EKK0341C160CBSMsg.KKTK_SVC_KEI_NO); // 世代登録年月日時分秒 String geneAddDtm = curRetMsg.getString(KK0341ETMsg.GENE_ADD_DTM); // 更新データ設定 // 機器提供サービス契約番号 KKTK_SVC_KEI_NO inETMsg.set(KK0341ETMsg.KKTK_SVC_KEI_NO, kktkSvcKeiNo); // 世代登録年月日時分秒 GENE_ADD_DTM inETMsg.set(KK0341ETMsg.GENE_ADD_DTM, geneAddDtm); // プラン終了年月日 PLAN_ENDYMD inETMsg.set(KK0341ETMsg.PLAN_ENDYMD, upd_date); // プラン課金終了年月日 PLAN_CHRG_ENDYMD inETMsg.set(KK0341ETMsg.PLAN_CHRG_ENDYMD, getKK0341PlanChrgEndymd(upd_date)); // プラン終了種別コード PLAN_END_SBT_CD inETMsg.set(KK0341ETMsg.PLAN_END_SBT_CD, PLAN_END_SBT_PLAN_CNG); // 更新年月日時分秒 UPD_DTM inETMsg.set(KK0341ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); // 更新オペレータアカウント UPD_OPEACNT inETMsg.set(KK0341ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); // 機器提供サービス契約の更新 JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); dba.update(inETMsg); } /** ** 機器提供サービス契約更新処理の条件チェックを行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext ディスパッチコンテキスト * @param curRetMsg 処理対象のカレントレコード * @return チェック結果(OK:true, NG:false) */ private boolean checkJokenForUpdate0341(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg curRetMsg) { // カレントレコードが存在しない場合falseを返却 if (curRetMsg == null) { return false; } // カレントレコードの機器提供サービスコードが"BBR"、かつ入力値の異動区分が"機器機種変更"の場合Trueを返却 if (KKTK_SVC_CD_BBR.equals(curRetMsg.getString(KK0341ETMsg.KKTK_SVC_CD)) && IDO_DIV_KKCNG.equals(inCBSMsg.getString(EKK0341C160CBSMsg.IDO_DIV))) { return true; } return false; } /** ** 機器提供サービス契約のカレントレコードを取得します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext ディスパッチコンテキスト * @return curRetMsg 処理対象のカレントレコード */ private CAANMsg findByCurrentKK0341(CAANMsg inCBSMsg, AgentDispatchContext inContext) { String kktkSvcKeiNo = inCBSMsg.getString(EKK0341C160CBSMsg.KKTK_SVC_KEI_NO); CAANMsg cond = new CAANMsg(KK0341ETMsg.class.getName()); cond.set(KK0341ETMsg.KKTK_SVC_KEI_NO, kktkSvcKeiNo); if (inCBSMsg.isNull(EKK0341C160CBSMsg.RSV_APLY_YMD)) { cond.set(KK0341ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg)); } else { cond.set(KK0341ETMsg.RSV_APLY_YMD, inCBSMsg.getString(EKK0341C160CBSMsg.RSV_APLY_YMD)); } // 機器提供サービス契約のカレントレコード検索 CAANMsg curRetMsg = new JKKejbKK0341DBABase().findByCurrent(cond); return curRetMsg; } /** ** プラン終了年月日を元に、プラン課金終了年月日を取得する *
* @param planEndymd プラン終了年月日 * @return プラン終了年月日が月初1日の場合プラン終了年月日の前月末日、(yyyyMMdd) * プラン終了年月日が月初1日以外の場合プラン終了年月日の月の月末日を返却する(yyyyMMdd) */ private String getKK0341PlanChrgEndymd(String planEndYmd) { // プラン終了年月日がnullの場合、プラン終了年月日を返却する if (planEndYmd == null) { return planEndYmd; } String retPlanChrgEndymd = null; try { // プラン終了年月日の末尾2桁が月初日（01)の場合 if (GESYOBI.equals(planEndYmd.substring(6, 8))) { // プラン終了年月日の1ヶ月前日付より、月末日を返却する retPlanChrgEndymd = JPCUtilCommon.addMonth(planEndYmd, -1).substring(0, 6); retPlanChrgEndymd = retPlanChrgEndymd + JPCUtilCommon.getEndOfMonth(retPlanChrgEndymd); } // プラン終了年月日の末尾2桁が月初日（01)でない場合 else { // プラン終了年月日と同月の月末日を返却する retPlanChrgEndymd = planEndYmd.substring(0, 6); retPlanChrgEndymd = retPlanChrgEndymd + JPCUtilCommon.getEndOfMonth(retPlanChrgEndymd); } } catch (ParseException se) { throw new CAANRuntimeException(se); } return retPlanChrgEndymd; } }