* オプションサービス契約解約確定のDBアクセス部品クラスです。 *
* @author 富士通 */ public class JEKK0351C250ETDA { /** 異動予約詳細コード オプション解約 */ private static final String DTLCD_OPDISSOLVE = "016"; /** 異動予約状態コード 反映済 */ private static final String STATCD_DONE = "01"; /** 異動予約状態コード 予約手続中 */ private static final String STATCD_RSV_PROC = "03"; /** 無効フラグ 有効 */ private static final String MK_FLG_VALID = "0"; /** 予約適用コード 予約確定 */ private static final String RSVAPLY_DECIDED = "2"; /** オプションサービス契約ステータス 解約済 */ private static final String OP_STAT_DISSOLVE = "910"; /** オプションサービス契約ステータス 締結済 */ private static final String OP_STAT_TEIKETUZUMI = "030"; /** 親契約識別コード(サービス契約内訳) */ private static final String OYA_KEI_SKBT_CD_SVC_KEI_UCWK = "03"; /** スキーマID オプションサービス契約 */ private static final String SCHEMAID_OP_SVCKEI = "KK0351"; /** スキーマID 異動予約 */ private static final String SCHEMAID_IDORSV = "KK1681"; /** 料金グループコード ｅｏ光テレビ（Ｋ−ＣＡＴ）*/ private static final String PRC_GRP_CD_TV_K_CAT = "11"; /** 料金グループコード ｅｏ光テレビ（再送信）*/ private static final String PRC_GRP_CD_TV_RESEND = "13"; /** カレント引継値 */ private static final String CURRENT_VALUE = "CURRENT"; /** 設定種類Key名 */ private static final String KEY_SET_TYPE = "KEY_SET_TYPE"; /** サービス課金開始年月日Key名 */ private static final String KEY_SVC_CHRG_STA_YMD = "KEY_SVC_CHRG_STA_YMD"; /** 設定種類保持用 */ private String setType = null; /** プラン終了種別コード：プラン変更に伴う終了 */ private static final String PLAN_END_SBT_CD_PLAN_CHANGE = "1"; /** 年月日：初期値 */ private static final String YMD_SHKV = "20991231"; /** ** 新しいJEKK0351C250ETDAを作成します。 *
*/ public JEKK0351C250ETDA() { } /** ** 相関ルールにて振舞判定を行い、オプションサービス契約または異動予約にDBアクセスを行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // 相関ルールにて振舞うスキーマを判定 JKKejbRule0083001 rule0083 = new JKKejbRule0083001(inCBSMsg); rule0083.setSvc_if_id(inCBSMsg.getString(JCMConstants.TEMPLATE_ID_KEY)); String baseDate = inCBSMsg.getString(EKK0351C250CBSMsg.SVC_ENDYMD); String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); rule0083.setBase_date(baseDate); rule0083.setOpe_date(opeDate); List* DBの登録を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア(CBSメッセージ) * @param inETMsg 登録対象DBのメッセージキャリア(ETメッセージ) */ private void create(CAANMsg inCBSMsg, CAANMsg inETMsg) { JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); // レコード登録 dba.create(inETMsg); } /** ** DBの更新を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア(CBSメッセージ) * @param inETMsg 更新対象DBのメッセージキャリア(ETメッセージ) */ private void update(CAANMsg inCBSMsg, CAANMsg inETMsg) { JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); // レコード更新 dba.update(inETMsg); } /** ** オプションサービス契約に設定するETメッセージを作成します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return サービス契約に設定する内容が設定されたETメッセージ */ private CAANMsg makeKK0351ETMsg(CAANMsg inCBSMsg, AgentDispatchContext inContext) { String opSvcKeiNo = inCBSMsg.getString(EKK0351C250CBSMsg.OP_SVC_KEI_NO); String geneAddDtm = (String)JKKModelCommon.getTransferGeneAddDtm(inCBSMsg, inContext); String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); // 引継元となるカレントレコードを取得 CAANMsg infoKK0351 = getCurKK0351(inCBSMsg); // オプションサービス契約ステータスを取得する String opSvcKeiStat = infoKK0351.getString(KK0351ETMsg.OP_SVC_KEI_STAT); // サービス課金開始年月日を取得する HashMap* 異動予約に設定するETメッセージを作成します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param ruleMap 相関ルールチェック結果のマップクラス * @param idoRsvDtlCd 検索する異動予約詳細コード * @param idoRsvStatCd 検索する異動予約状態コード * @return 異動予約に設定する内容が設定されたETメッセージ */ private CAANMsg makeKK1681ETMsg(CAANMsg inCBSMsg, Map* CBSメッセージの出力項目に値を設定します。 *
* @param inCBSMsg 処理対象のメッセージキャリア(CBSメッセージ) * @param inETMsg DBに設定した内容を持っているETメッセージ */ private void setOutputItem(CAANMsg inCBSMsg, CAANMsg inETMsg) { inCBSMsg.set(EKK0351C250CBSMsg.ADD_DTM, inETMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); inCBSMsg.set(EKK0351C250CBSMsg.ADD_OPEACNT, inETMsg.getString(JCMConstants.OPERATOR_ID_KEY)); inCBSMsg.set(EKK0351C250CBSMsg.UPD_DTM, inETMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); inCBSMsg.set(EKK0351C250CBSMsg.UPD_OPEACNT, inETMsg.getString(JCMConstants.OPERATOR_ID_KEY)); inCBSMsg.set(EKK0351C250CBSMsg.MK_FLG, MK_FLG_VALID); } /** ** オプションサービス契約のカレントレコードを取得します。 *
* @param inCBSMsg 処理対象のメッセージキャリア(CBSメッセージ) * @return オプションサービス契約のカレントレコード */ private CAANMsg getCurKK0351(CAANMsg inCBSMsg) { // オプションサービス契約のカレントレコードを取得 CAANMsg et = new CAANMsg(KK0351ETMsg.class.getName()); et.set(KK0351ETMsg.OP_SVC_KEI_NO, inCBSMsg.getString(EKK0351C250CBSMsg.OP_SVC_KEI_NO)); et.set(KK0351ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg)); CAANMsg curKK0351 = new JKKejbKK0351DBABase().findByCurrent(et); return curKK0351; } /** *
* 下記項目を条件に異動予約を取得します。
*
・オプションサービス契約番号
*
・異動予約詳細コード
*
・異動予約状態コード
*
* 料金グループが「ｅｏ光テレビ（Ｋ−ＣＡＴ）」か「ｅｏ光テレビ（再送信）」判定処理 *
* @param inCBSMsg 入力パラメータのCBSMsg * @return 「ｅｏ光テレビ（Ｋ−ＣＡＴ）」か「ｅｏ光テレビ（再送信）」の場合true */ private boolean isChkPrcGrpCdTv(CAANMsg inCBSMsg) { // 運用日付 String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); // オプションサービス契約番号 String opSvcKeiNo = inCBSMsg.getString(EKK0351C250CBSMsg.OP_SVC_KEI_NO); // 内部スキーマメッセージを作成(オプションサービス契約) CAANMsg inMsgKK0351 = new CAANMsg(KK0351ETMsg.class.getName()); // パラメータ設定 inMsgKK0351.set(KK0351ETMsg.OP_SVC_KEI_NO, opSvcKeiNo); inMsgKK0351.set(KK0351ETMsg.RSV_APLY_YMD, opeDate); // オプションサービス契約のカレントレコードを取得する。 CAANMsg curMsgKK0351 = new JKKejbKK0351DBABase().findByCurrent(inMsgKK0351); if(null == curMsgKK0351) { return false; } // サービス契約番号 String svcKeiNo = curMsgKK0351.getString(KK0351ETMsg.SVC_KEI_NO); // サービス契約番号が取得でない場合 if (null == svcKeiNo || "".equals(svcKeiNo)) { // サービス契約内訳メッセージ生成 CAANMsg inMsgKK0161 = new CAANMsg(KK0161ETMsg.class.getName()); // サービス契約番号 String svcKeiUcwkNo = curMsgKK0351.getString(KK0351ETMsg.SVC_KEI_UCWK_NO); // サービス契約内訳設定 inMsgKK0161.set(KK0161ETMsg.SVC_KEI_UCWK_NO, svcKeiUcwkNo); inMsgKK0161.set(KK0161ETMsg.RSV_APLY_YMD, opeDate); // サービス契約内訳カレント検索を行う CAANMsg curMsgKK0161 = new JKKejbKK0161DBABase().findByCurrent(inMsgKK0161); if(null == curMsgKK0161) { return false; } svcKeiNo = curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO); } // サービス契約メッセージ生成 CAANMsg inMsgKK0081 = new CAANMsg(KK0081ETMsg.class.getName()); // サービス契約設定 inMsgKK0081.set(KK0081ETMsg.SVC_KEI_NO, svcKeiNo); inMsgKK0081.set(KK0081ETMsg.RSV_APLY_YMD, opeDate); // サービス契約カレント検索を行う CAANMsg curMsgKK0081 = new JKKejbKK0081DBABase().findByCurrent(inMsgKK0081); if(null == curMsgKK0081) { return false; } // 料金グループコード String prcGrpCd = curMsgKK0081.getString(KK0081ETMsg.PRC_GRP_CD); // 料金グループコードが「ｅｏ光テレビ（Ｋ−ＣＡＴ）」か「ｅｏ光テレビ（再送信）」の場合 if (PRC_GRP_CD_TV_K_CAT.equals(prcGrpCd) || PRC_GRP_CD_TV_RESEND.equals(prcGrpCd)) { return true; } return false; } /** ** 遡及解約対応・履歴レコード課金終了日更新処理 * 遡及解約により、解約(最新)レコードの課金終了日に対して、履歴レコードの課金終了日が未来日になってしまう場合に、 * 解約(最新)レコードの課金終了日と同日を履歴レコードの課金終了日に設定する。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @param updateInfo 解約(最新)レコードのメッセージキャリア * @param planChrgEndymd 新規レコードのプラン課金終了年月日 * @param svcChrgEndymd 新規レコードのサービス課金終了年月日 */ private void updRirekiKK0351(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg updateInfo, String planChrgEndymd, String svcChrgEndymd) { // 同一「サービス契約」配下の「オプションサービス契約」で、プラン課金終了日が設定されている履歴レコードを取得する。 // 条件：プラン終了種別コード＝"プラン変更に伴う終了"、オプションサービスコード＝解約対象オプション CAANMsg[] conRetMsg = getPlanEndRirekiKK0351(updateInfo); // 取得できない場合は処理を終了する if (null == conRetMsg || conRetMsg.length == 0) { return; } // 当該サービスIFにて作成した解約(最新)レコードのサービス契約内訳番号、世代登録年月日時分秒 String opSvcKeiNo = inCBSMsg.getString(EKK0351C250CBSMsg.OP_SVC_KEI_NO); String geneAddDtm = inCBSMsg.getString(EKK0351C250CBSMsg.GENE_ADD_DTM); /* ---------------------------------------------------------------------------------------------------- * 履歴レコード.プラン課金終了年月日更新処理 * 条件：解約(最新)レコード.プラン課金終了年月日＜履歴レコード.プラン課金終了年月日 * ---------------------------------------------------------------------------------------------------- */ for (CAANMsg retMsg : conRetMsg) { // 当該サービスIFにて作成した解約(最新)レコードは、更新対象外 if (opSvcKeiNo.equals(retMsg.getString(KK0351ETMsg.OP_SVC_KEI_NO)) && geneAddDtm.equals(retMsg.getString(KK0351ETMsg.GENE_ADD_DTM))) { continue; } // 履歴レコード.プラン課金終了年月日 String workPlanChrgEndymd = retMsg.getString(KK0351ETMsg.PLAN_CHRG_ENDYMD); // 履歴レコード.プラン課金終了年月日が未設定または"20991231"または解約(最新)レコード.サービス課金終了年月日が未設定の場合は処理しない if (!(null == workPlanChrgEndymd || "".equals(workPlanChrgEndymd) || YMD_SHKV.equals(workPlanChrgEndymd) || null == svcChrgEndymd) && JPCUtilCommon.isFutureDate(workPlanChrgEndymd, planChrgEndymd, "0")) { // 解約(最新)レコード.プラン課金終了年月日＜履歴レコード.プラン課金終了年月日の場合 retMsg.set(KK0351ETMsg.PLAN_CHRG_ENDYMD, planChrgEndymd); /* ---------------------------------------------------------------------------------------------------- * 履歴レコード.サービス課金終了年月日更新処理 * 条件：解約(最新)レコード.サービス課金終了年月日＜履歴レコード.サービス課金終了年月日 * ※同一「サービス契約」配下で、サービス課金終了年月日が解約対象の当該「オプションサービス契約」より未来日になる場合 * ---------------------------------------------------------------------------------------------------- */ // 履歴レコード.サービス課金終了年月日 String workSvcChrgEndymd = retMsg.getString(KK0351ETMsg.SVC_CHRG_ENDYMD); // 履歴レコード.サービス課金終了年月日が未設定または"20991231"の場合は処理しない if (!(null == workSvcChrgEndymd || "".equals(workSvcChrgEndymd) || YMD_SHKV.equals(workSvcChrgEndymd)) && JPCUtilCommon.isFutureDate(workSvcChrgEndymd, svcChrgEndymd, "0")) { // 解約(最新)レコード.サービス課金終了年月日＜履歴レコード.サービス課金終了年月日の場合 retMsg.set(KK0351ETMsg.SVC_CHRG_ENDYMD, svcChrgEndymd); } retMsg.set(KK0351ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); retMsg.set(KK0351ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); } else { continue; } JKKejbDBAUtil dbaUtil = new JKKejbDBAUtil(inCBSMsg); dbaUtil.update(retMsg); } } /** ** 遡及解約対応・プラン終了履歴レコード抽出処理 *
* @param updateInfo 解約(最新)レコードのメッセージキャリア */ private CAANMsg[] getPlanEndRirekiKK0351(CAANMsg updateInfo) { // 解約(最新)レコード.オプションサービスコード String opSvcCd = updateInfo.getString(KK0351ETMsg.OP_SVC_CD); // 解約(最新)レコード.サービス契約番号 String svcKeiNo = updateInfo.getString(KK0351ETMsg.SVC_KEI_NO); // 解約(最新)レコード.サービス契約内訳番号 String svcKeiUcwkNo = updateInfo.getString(KK0351ETMsg.SVC_KEI_UCWK_NO); // 解約(最新)レコード.親契約識別コード String oyaKeiSkbtCd = updateInfo.getString(KK0351ETMsg.OYA_KEI_SKBT_CD); if (OYA_KEI_SKBT_CD_SVC_KEI_UCWK.equals(oyaKeiSkbtCd)) { // サービス契約内訳のカレントレコードを取得 CAANMsg infoKK0161 = getCurKK0161(updateInfo, svcKeiUcwkNo); svcKeiNo = infoKK0161.getString(KK0161ETMsg.SVC_KEI_NO); } // 運用日付 String opeDate = JKKModelCommon.getOpeDate(updateInfo); // 個別検索条件マップ HashMap* サービス契約内訳のカレントレコードを取得します。 *
* @param updateInfo 処理対象のメッセージキャリア(CBSメッセージ) * @return サービス契約内訳のカレントレコード */ private CAANMsg getCurKK0161(CAANMsg updateInfo, String svcKeiUcwkNo) { // サービス契約内訳のカレントレコードを取得 CAANMsg et = new CAANMsg(KK0161ETMsg.class.getName()); et.set(KK0161ETMsg.SVC_KEI_UCWK_NO, svcKeiUcwkNo); et.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(updateInfo)); CAANMsg curKK0161 = new JKKejbKK0161DBABase().findByCurrent(et); return curKK0161; } }