* 割引サービス契約解約の副次処理を行う部品クラスです。 *
* @author 富士通 */ public class JEKK0451C020ETDA implements TemplateMainHandler { /** 異動予約詳細コード：割引解約 */ private static final String WRBK_KAIYAKU = "020"; /** 異動予約状態コード：異動予約対象外 */ private static final String YOYAKU_OUTSIDE = "04"; /** 無効フラグ(有効) **/ private static final String MK_FLG_YUKO = "0"; /** 予約適用年月日（設定なしの場合に使用） **/ private static final String RSV_APLY_YMD = "20991231"; /** ** 割引サービス契約解約の副次処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // EE対応表の条件の判定 // 異動予約登録処理を実行 create(inCBSMsg, inContext); return; } /** ** 異動予約登録処理のDBアクセス処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ private void create(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // ETMsgの作成 CAANMsg inETMsg = new CAANMsg(KK1681ETMsg.class.getName()); // 採番処理 JKKejbKK1681NumberParts numberParts = new JKKejbKK1681NumberParts(); String ido_rsv_no = numberParts.getIdoRsvNo(inCBSMsg, inContext); // 異動予約番号 IDO_RSV_NO inETMsg.set(KK1681ETMsg.IDO_RSV_NO, ido_rsv_no); // 異動区分 IDO_DIV inETMsg.set(KK1681ETMsg.IDO_DIV, inCBSMsg.getString(EKK0451C020CBSMsg.IDO_DIV)); // 異動予約詳細コード IDO_RSV_DTL_CD inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, WRBK_KAIYAKU); // 予約適用年月日 RSV_APLY_YMD String rsv_aply_ymd = inCBSMsg.getString(EKK0451C020CBSMsg.SVC_ENDYMD); if (null == rsv_aply_ymd || rsv_aply_ymd.length() == 0) { inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, RSV_APLY_YMD); } else { inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, rsv_aply_ymd); } // 異動予約状態コード IDO_RSV_STAT_CD inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, YOYAKU_OUTSIDE); // 申込明細番号 MSKM_DTL_NO inETMsg.set(KK1681ETMsg.MSKM_DTL_NO, inCBSMsg.getString(EKK0451C020CBSMsg.MSKM_DTL_NO)); // 割引サービス契約番号 WRIB_SVC_KEI_NO inETMsg.set(KK1681ETMsg.WRIB_SVC_KEI_NO, inCBSMsg.getString(EKK0451C020CBSMsg.WRIB_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_YUKO); // 異動予約番号の登録 JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg); dba.create(inETMsg); return; } /** * 回復年月日の履歴更新を行います。 * * @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void updateKaihkYmdGene(CAANMsg inCBSMsg, AgentDispatchContext inContext) { String wribSvcKeiNo = inCBSMsg.getString(EKK0451C020CBSMsg.WRIB_SVC_KEI_NO); // 割引サービス契約番号 String svcDslYmd = inCBSMsg.getString(EKK0451C020CBSMsg.SVC_DSL_YMD); // サービス解約年月日 // 運用日付の取得 String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); // 割引サービス契約のカレントレコードを取得します。 CAANMsg kk0451Cur = new CAANMsg(KK0451ETMsg.class.getName()); kk0451Cur.set(KK0451ETMsg.WRIB_SVC_KEI_NO, wribSvcKeiNo); kk0451Cur.set(KK0451ETMsg.RSV_APLY_YMD, opeDate); CAANMsg retCurrentETMsg0451 = new JKKejbKK0451DBABase().findByCurrent(kk0451Cur); if (null == retCurrentETMsg0451) { // カレントレコードが存在しない場合 return; } String wribSvcCd = retCurrentETMsg0451.getString(KK0451ETMsg.WRIB_SVC_CD); // 割引サービスコード // 割引サービスのカレントレコードを取得します。 CAANMsg kk0841Cur = new CAANMsg(KK0841ETMsg.class.getName()); kk0841Cur.set(KK0841ETMsg.WRIB_SVC_CD, wribSvcCd); kk0841Cur.set(KK0841ETMsg.RSV_APLY_YMD, opeDate); CAANMsg retCurrentETMsg0841 = new JKKejbKK0841DBABase().findByCurrent(kk0841Cur); if (null == retCurrentETMsg0841) { // カレントレコードが存在しない場合 return; } String wribTypeCd = retCurrentETMsg0841.getString(KK0841ETMsg.WRIB_TYPE_CD); // 割引タイプコード // セット割以外は処理しない if (!JKKModelConst.WRIB_TYPE_CD_SET_WARI.equals(wribTypeCd)) { // カレントレコードが存在しない場合 return; } // 割引サービス契約番号で一覧検索を行います CAANMsg inETMsgForCondition0451 = new CAANMsg(KK0451ETMsg.class.getName()); inETMsgForCondition0451.set(KK0451ETMsg.WRIB_SVC_KEI_NO, wribSvcKeiNo); inETMsgForCondition0451.set(KK0451ETMsg.MK_FLG, JKKModelConst.MK_FLG_YK); KK0451LE le0451 = new KK0451LE(); CAANMsg[] retConditionETMsg0451 = null; try { retConditionETMsg0451 = le0451.findByCondition(inETMsgForCondition0451); } catch (CAANException ce) { throw new CAANRuntimeException(ce); } // 一覧の結果を検索します for (CAANMsg kk0451 : retConditionETMsg0451) { // 入力のサービス解約年月日と履歴の回復年月日が同じ場合は回復年月日を前日に変更する if (svcDslYmd.equals(kk0451.getString(KK0451ETMsg.KAIHK_YMD))) { // 割引サービス契約を更新する kk0451.set(KK0451ETMsg.KAIHK_YMD, JPCUtilCommon.addDay(svcDslYmd, -1)); kk0451.set(KK0451ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); kk0451.set(KK0451ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); JKKejbDBAUtil dbaUtil = new JKKejbDBAUtil(inCBSMsg); dbaUtil.update(kk0451); } } } }