* サービス契約回線内訳登録の副次処理を行う部品クラスです。 *
* @author 富士通 */ public class JEKK0251D010ETDA implements TemplateMainHandler { /** 無効フラグ 有効 */ private static final String MK_FLG_VALID = "0"; /** 異動予約詳細コード 回線利用場所変更 */ private static final String IDODTL_KAISEN_CHANGE = "009"; /** 異動予約状態コード 異動予約対象外 */ private static final String IDOSTAT_NOTTARGET = "04"; /** 異動区分コード 住所変更・登録 */ private static final String IDO_DIV_JUSHOHENKO = "00019"; /** ** サービス契約回線内訳登録の副次処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // 開始ログ出力 JSYejbLog.println(JSYejbLog.DEBUG, this.getClass(), "call:JEKK0251D010ETDA.execDBAccess"); // EE対応表の条件の判定 if (!checkJoken(inCBSMsg, inContext)) { return; } // 異動予約登録処理を実行 create(inCBSMsg, inContext); // 終了ログ出力 JSYejbLog.println(JSYejbLog.DEBUG, this.getClass(), "end:JEKK0251D010ETDA.execDBAccess"); return; } /** ** 異動予約登録処理の条件チェックを行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext ディスパッチコンテキスト * @return チェック結果(OK:true, NG:false) */ private boolean checkJoken(CAANMsg inCBSMsg, AgentDispatchContext inContext) { //紐付く申込の「申込種別コード」が"住所変更申込"の場合はチェックOK if (getMskmSbtCd(inCBSMsg, inContext) != null) { return true; } return false; } /** ** 異動予約登録処理のDBアクセス処理を行います。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ private void create(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // サービス契約の数だけ異動予約を作成する String[] svcKeiNoList = getSvcKeiNoList(inCBSMsg.getString(EKK0251D010CBSMsg.SVC_KEI_KAISEN_UCWK_NO)); for (String svcKeiNo : svcKeiNoList) { // 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, IDO_DIV_JUSHOHENKO); // 異動予約詳細コード IDO_RSV_DTL_CD inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, IDODTL_KAISEN_CHANGE); // 予約適用年月日 RSV_APLY_YMD // 固定値(終了日の最大値)を設定 inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, JKKejbEditYmdInit.convRsvAplyYmdInit(null)); // 異動予約状態コード IDO_RSV_STAT_CD inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, IDOSTAT_NOTTARGET); // 申込明細番号 MSKM_DTL_NO inETMsg.set(KK1681ETMsg.MSKM_DTL_NO, inCBSMsg.getString(EKK0251D010CBSMsg.MSKM_DTL_NO)); // サービス契約番号 SVC_KEI_NO inETMsg.set(KK1681ETMsg.SVC_KEI_NO, svcKeiNo); // 登録年月日時分秒 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); } return; } /** ** サービス契約回線内訳番号に紐付くサービス契約番号を取得します。 *
* @param svcKeiKaisenUcwkNo 検索するサービス契約回線内訳番号 * @return サービス契約番号の配列 */ private String[] getSvcKeiNoList(String svcKeiKaisenUcwkNo) { // サービス契約回線内訳番号を検索条件に回線対象サービス契約のレコードを取得 KK0241LE kk0241le = new KK0241LE(); CAANMsg kk0241Cond = new CAANMsg(KK0241ETMsg.class.getName()); kk0241Cond.set(KK0241ETMsg.SVC_KEI_KAISEN_UCWK_NO, svcKeiKaisenUcwkNo); kk0241Cond.set(KK0241ETMsg.MK_FLG, MK_FLG_VALID); CAANMsg[] msgList = null; try { msgList = kk0241le.findByCondition(kk0241Cond); } catch (CAANException ce) { throw new CAANRuntimeException(ce); } ArrayList* 申込明細番号に紐づく申込データから申込種別コードを取得します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return 申込種別コード */ private String getMskmSbtCd(CAANMsg inCBSMsg, AgentDispatchContext inContext) { //申込種別コード String mskm_sbt_no = null; try { //申込明細がなければnull返却 if(inCBSMsg.isNull(EKK0251D010CBSMsg.MSKM_DTL_NO)) { return null; } //申込明細のレコードを取得 CAANMsg inETMsgMskmDtl = new CAANMsg(KK0021ETMsg.class.getName()); inETMsgMskmDtl.set(KK0021ETMsg.MSKM_DTL_NO, inCBSMsg.getObject(EKK0251D010CBSMsg.MSKM_DTL_NO)); inETMsgMskmDtl.set(KK0021ETMsg.MK_FLG, MK_FLG_VALID); // KK0021LEインスタンスの生成 KK0021LE mskm_dtl_Le = new KK0021LE(); CAANMsg[] outETMsgMskmDtl = mskm_dtl_Le.findByCondition(inETMsgMskmDtl); //レコードが存在しない場合はnullを返却 if(outETMsgMskmDtl == null || outETMsgMskmDtl.length == 0) { return null; } //申込番号を取得 String mskm_no = outETMsgMskmDtl[0].getString(KK0011ETMsg.MSKM_NO); CAANMsg inETMsgMskm = new CAANMsg(KK0011ETMsg.class.getName()); inETMsgMskm.set(KK0011ETMsg.MSKM_NO, mskm_no); inETMsgMskm.set(KK0011ETMsg.MSKM_SBT_CD, "00017"); inETMsgMskm.set(KK0011ETMsg.MK_FLG, MK_FLG_VALID); // KK0011LEインスタンスの生成 KK0011LE mskm_Le = new KK0011LE(); CAANMsg[] outETMsgMskm = mskm_Le.findByCondition(inETMsgMskm); //申込種別コードを取得 if (outETMsgMskm != null && outETMsgMskm.length > 0) { mskm_sbt_no = outETMsgMskm[0].getString(KK0011ETMsg.MSKM_SBT_CD); } } catch (CAANException ce) { throw new CAANRuntimeException(ce); } return mskm_sbt_no; } }