* オプションサービス契約のDBアクセス部品クラスです。 *
* @author 富士通 */ public class JKKejbKK0351ETDA { /** スキーマID オプションサービス契約 */ public static final String SCHEMAID_OPSVCKEI = "KK0351"; /** スキーマID 異動予約 */ public static final String SCHEMAID_IDORSV = "KK1681"; /** エラーフラグ 異動対象スキーマ判定相関ルール */ public static final String RSLT_CORR_IDORSV = "5"; /** 契約ステータス サービス提供中 */ private static final String STAT_USING = "100"; /** 予約適用コード 予約確定 */ private static final String APLYCD_DECIDED = "2"; /** 終了年月日 システム最終年月日 */ private static final String SYS_LASTYMD = "20991231"; /** 無効フラグ 有効 */ private static final String MKFLG_VALID = "0"; /** 関連チェックエラーフラグ&エラー返却項目(サブオプションサービス契約 開始日確定チェック) */ private static final String[] KRCK_SBOP_START_DECIDED_ERR = {"EC", EKK0361C040CBSMsg.OP_SVC_KEI_NO_ERR}; /** 親契約識別コード(サービス契約) */ private static final String OYA_KEI_SKBT_CD_SVC_KEI = "01"; /** 親契約識別コード(サービス契約内訳) */ private static final String OYA_KEI_SKBT_CD_SVC_KEI_UCWK = "03"; /** オプションサービス.オプションサービスコード(スマートリンクプレミアム) */ private static final String OP_SVC_CD_SMT_LINK_PRE = "B077"; /** 異動予約詳細コード オプション開始 */ private static final String IDO_RSV_DTL_OPSTA = "014"; /** オプションサービス契約番号 */ private static final String OP_SVC_KEI_NO = "op_svc_kei_no"; /** オプションサービス契約* 新しいJKKejbKK0351ETDAを作成します。 *
*/ public JKKejbKK0351ETDA() { } /** ** 「オプションサービス契約」のレコードを削除(論理削除)します。 *
* @param kk0351Msg 削除対象となる「オプションサービス契約」履歴世代レコードのメッセージキャリア * @param updDtm 更新年月日時分秒 * @param updOpeAct 更新オペレータアカウント */ public void deleteKK0351(CAANMsg kk0351Msg, String updDtm, String updOpeAct) { // 更新用メッセージ作成 CAANMsg inETMsg = new CAANMsg(KK0351ETMsg.class.getName()); inETMsg.set(KK0351ETMsg.OP_SVC_KEI_NO, kk0351Msg.getString(KK0351ETMsg.OP_SVC_KEI_NO)); inETMsg.set(KK0351ETMsg.GENE_ADD_DTM, kk0351Msg.getString(KK0351ETMsg.GENE_ADD_DTM)); inETMsg.set(KK0351ETMsg.UPD_DTM, updDtm); inETMsg.set(KK0351ETMsg.UPD_OPEACNT, updOpeAct); inETMsg.set(KK0351ETMsg.DEL_DTM, updDtm); inETMsg.set(KK0351ETMsg.DEL_OPEACNT, updOpeAct); inETMsg.set(KK0351ETMsg.MK_FLG, JKKModelConst.MK_FLG_MK); // 更新を行う new JKKejbDBAUtil(inETMsg).update(inETMsg); // サブタイプ更新を行う JKKejbKK0351SubTypeDelete instance = new JKKejbKK0351SubTypeDelete(inETMsg); instance.setOpSvcKeiNo(kk0351Msg.getString(KK0351ETMsg.OP_SVC_KEI_NO)); instance.setGeneAddDtm(kk0351Msg.getString(KK0351ETMsg.GENE_ADD_DTM)); instance.setAddUpdDelDtm(updDtm); instance.setAddUpdDelOpeacnt(updOpeAct); instance.deleteSubTypeKK0351(); } /** ** 開始日設定(オプションサービス)相関ルールを実行します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param opSvcKeiNo オプションサービス契約番号 * @param svcCd 「同時申込」を判定するサービスコード * @param skjYkgt 即時/翌月(01:即時、02:翌月) * @return 相関ルールにより取得した開始日 */ public String execSokanOfStaYmd(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo, String svcCd, String skjYkgt) { // オプションサービス契約に紐付くサービス契約のサービスコードを取得 CAANMsg kk0081Cur = getCurSvcKeiViaOpKei(inCBSMsg, inContext, opSvcKeiNo); // オプションサービス契約が存在しない場合 if (kk0081Cur == null) { return null; } String curSvcCd = kk0081Cur.getString(KK0081ETMsg.SVC_CD); // オプションサービス契約のオプションサービスコードを取得 CAANMsg kk0351Cur = getCurOpKei(inCBSMsg, inContext, opSvcKeiNo); String opSvcCd = kk0351Cur.getString(KK0351ETMsg.OP_SVC_CD); // OM-2014-0002598 MOD START // オプションサービス契約に紐付くサービス契約のサービス開始年月日を取得 //String svcStaYmd = kk0081Cur.getString(KK0081ETMsg.SVC_STA_YMD); String svcStaYmd = null; String svcChrgStaymd = null; // サービスが電話の場合 if (JKKModelConst.SVC_CD_TEL.equals(svcCd)) { // サービス契約内訳番号に紐付くサービス契約内訳を取得 CAANMsg kk0161Cur = getCurSvcKeiUcwk(inCBSMsg, inContext, kk0351Cur.getString(KK0351ETMsg.SVC_KEI_UCWK_NO)); // オプションサービス契約に紐付くサービス契約内訳のサービス開始年月日を取得 svcStaYmd = kk0161Cur.getString(KK0161ETMsg.SVC_STA_YMD); // オプションサービス契約に紐付くサービス契約内訳のサービス課金開始年月日を取得 svcChrgStaymd = kk0161Cur.getString(KK0161ETMsg.SVC_CHRG_STAYMD); } else { // オプションサービス契約に紐付くサービス契約のサービス開始年月日を取得 svcStaYmd = kk0081Cur.getString(KK0081ETMsg.SVC_STA_YMD); // オプションサービス契約に紐付くサービス契約のサービス課金開始年月日を取得 svcChrgStaymd = kk0081Cur.getString(KK0081ETMsg.SVC_CHRG_STAYMD); } // OM-2014-0002598 MOD END // サービス契約のサービス開始年月日が未設定の場合 if (svcStaYmd == null) { // 異動予約より予約適用年月日を取得する JKKejbIdoRsvAccess jkIdoAc = new JKKejbIdoRsvAccess(); List
* 課金開始日設定(オプション)相関ルールを実行します。
* (オプション引継以外の場合、こちらを使用する)
*
* 課金開始日設定(オプション)相関ルールを実行します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param opSvcKeiNo オプションサービス契約番号 * @param skjYkgt 即時/翌月(01:即時、02:翌月) * @param staYmd 開始日設定(オプションサービス)相関ルールで算出した開始年月日 * @param opHktgiYmd オプション引継年月日 * @return 相関ルールにより取得した課金開始日 */ // OM-2014-0004052 2015/03/03 MOD START // public String execSokanOfChrgStaYmd(CAANMsg inCBSMsg, AgentDispatchContext inContext, // String opSvcKeiNo, String skjYkgt, String staYmd) public String execSokanOfChrgStaYmd(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo, String skjYkgt, String staYmd, String opHktgiYmd) // OM-2014-0004052 2015/03/03 MOD END { // オプションサービス契約に紐付くサービス契約のサービスコードを取得 CAANMsg kk0081Cur = getCurSvcKeiViaOpKei(inCBSMsg, inContext, opSvcKeiNo); String curSvcCd = kk0081Cur.getString(KK0081ETMsg.SVC_CD); // オプションサービス契約のオプションサービスコードを取得 CAANMsg kk0351Cur = getCurOpKei(inCBSMsg, inContext, opSvcKeiNo); String opSvcCd = kk0351Cur.getString(KK0351ETMsg.OP_SVC_CD); // OM-2014-0002598 MOD START // オプションサービス契約に紐付くサービス契約のサービス開始年月日を取得 //String svcStaYmd = kk0081Cur.getString(KK0081ETMsg.SVC_STA_YMD); String svcStaYmd = null; String svcChrgStaymd = null; // サービスが電話の場合 if (JKKModelConst.SVC_CD_TEL.equals(curSvcCd)) { // サービス契約内訳番号に紐付くサービス契約内訳を取得 CAANMsg kk0161Cur = getCurSvcKeiUcwk(inCBSMsg, inContext, kk0351Cur.getString(KK0351ETMsg.SVC_KEI_UCWK_NO)); // オプションサービス契約に紐付くサービス契約内訳のサービス開始年月日を取得 svcStaYmd = kk0161Cur.getString(KK0161ETMsg.SVC_STA_YMD); // オプションサービス契約に紐付くサービス契約内訳のサービス課金開始年月日を取得 svcChrgStaymd = kk0161Cur.getString(KK0161ETMsg.SVC_CHRG_STAYMD); } else { // オプションサービス契約に紐付くサービス契約のサービス開始年月日を取得 svcStaYmd = kk0081Cur.getString(KK0081ETMsg.SVC_STA_YMD); // オプションサービス契約に紐付くサービス契約のサービス課金開始年月日を取得 svcChrgStaymd = kk0081Cur.getString(KK0081ETMsg.SVC_CHRG_STAYMD); } // OM-2014-0002598 MOD END // サービス契約のサービス開始年月日が未設定の場合 if (svcStaYmd == null) { // 異動予約より予約適用年月日を取得する JKKejbIdoRsvAccess jkIdoAc = new JKKejbIdoRsvAccess(); List* 異動対象スキーマ判定相関ルールを実行します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param svcStaYmd 開始日設定(オプションサービス)相関ルールで算出したサービス開始年月日 * @return 異動対象スキーマ判定相関ルール実行結果のリスト */ public List* 異動対象スキーマ判定相関ルールの結果を元に振舞うスキーマを判定します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param ruleList 異動対象スキーマ判定相関ルール実行結果のリスト * @return 振舞対象スキーマ */ public String judgeSchema(CAANMsg inCBSMsg, AgentDispatchContext inContext, List* オプションサービス契約への振舞を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk0351Msg オプションサービス契約のETメッセージ * @param staYmd 開始年月日 * @param chrgStaYmd 課金開始年月日 * @return オプションサービス契約に登録した内容を持ったETメッセージ */ public CAANMsg execDBAccessOpKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk0351Msg, String staYmd, String chrgStaYmd) { CAANMsg dbInfo = setInfoOfOpKei(inCBSMsg, inContext, kk0351Msg, staYmd, chrgStaYmd); createKK0351(inCBSMsg, inContext, dbInfo); return dbInfo; } /** ** 異動予約への振舞を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk1681Msg 異動予約のETメッセージ * @param staYmd 開始年月日 * @param chrgStaYmd 課金開始年月日 * @param ruleMap 異動対象スキーマ判定相関ルールの結果のマップ * @return 異動予約に登録した内容を持ったETメッセージ */ public CAANMsg execDBAccessIdoRsv(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk1681Msg, String staYmd, String chrgStaYmd, Map* 異動予約への振舞を行います（副次処理用）。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param msgKK0401 副次対象のサブオプションサービス契約レコード * @param ruleMap 異動対象スキーマ判定相関ルールの結果のマップ * @return 異動予約に登録した内容を持ったETメッセージ */ public void execDBAccessIdoRsvSec(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg msgKK0401, Map* 申込明細のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param mskmDtlNo 申込明細番号 * @return 申込明細のカレントレコード */ private CAANMsg getCurMskmDtl(CAANMsg inCBSMsg, AgentDispatchContext inContext, String mskmDtlNo) { CAANMsg kk0021Cond = new CAANMsg(KK0021ETMsg.class.getName()); kk0021Cond.set(KK0021ETMsg.MSKM_DTL_NO, mskmDtlNo); return new JKKejbKK0021DBABase().findByCurrent(kk0021Cond); } /** ** 申込のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param mskmNo 申込番号 * @return 申込のカレントレコード */ private CAANMsg getCurMskm(CAANMsg inCBSMsg, AgentDispatchContext inContext, String mskmNo) { CAANMsg kk0011Cond = new CAANMsg(KK0011ETMsg.class.getName()); kk0011Cond.set(KK0011ETMsg.MSKM_NO, mskmNo); return new JKKejbKK0011DBABase().findByCurrent(kk0011Cond); } /** ** オプションサービス契約に紐付く申込のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param opSvcKeiNo オプションサービス契約番号 * @return オプションサービス契約に紐付く申込のカレントレコード */ private CAANMsg getCurMskmViaOpKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo) { // オプションサービス契約のカレントレコードを取得 CAANMsg kk0351Cur = getCurOpKei(inCBSMsg, inContext, opSvcKeiNo); String mskmDtlNo = kk0351Cur.getString(KK0351ETMsg.MSKM_DTL_NO); // 申込明細のカレントレコードを取得 CAANMsg kk0021Cur = getCurMskmDtl(inCBSMsg, inContext, mskmDtlNo); String mskmNo = kk0021Cur.getString(KK0021ETMsg.MSKM_NO); // 申込のカレントレコードを取得 CAANMsg kk0011Cur = getCurMskm(inCBSMsg, inContext, mskmNo); return kk0011Cur; } /** ** オプションサービス契約のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param opSvcKeiNo オプションサービス契約番号 * @return オプションサービス契約のカレントレコード */ private CAANMsg getCurOpKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo) { String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); CAANMsg kk0351Cond = new CAANMsg(KK0351ETMsg.class.getName()); kk0351Cond.set(KK0351ETMsg.OP_SVC_KEI_NO, opSvcKeiNo); kk0351Cond.set(KK0351ETMsg.RSV_APLY_YMD, opeDate); return new JKKejbKK0351DBABase().findByCurrent(kk0351Cond); } /** ** サービス契約のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param svcKeiNo サービス契約番号 * @return サービス契約のカレントレコード */ private CAANMsg getCurSvcKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, String svcKeiNo) { String opeDate = JKKModelCommon.getOpeDate(inCBSMsg); CAANMsg kk0081Cond = new CAANMsg(KK0081ETMsg.class.getName()); kk0081Cond.set(KK0351ETMsg.SVC_KEI_NO, svcKeiNo); kk0081Cond.set(KK0351ETMsg.RSV_APLY_YMD, opeDate); return new JKKejbKK0081DBABase().findByCurrent(kk0081Cond); } /** ** サービス契約内訳のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param svcKeiNo サービス契約内訳番号 * @return サービス契約内訳のカレントレコード */ private CAANMsg getCurSvcKeiUcwk(CAANMsg inCBSMsg, AgentDispatchContext inContext, String svcKeiUcwkNo) { CAANMsg kk0161Cond = new CAANMsg(KK0161ETMsg.class.getName()); kk0161Cond.set(KK0161ETMsg.SVC_KEI_UCWK_NO, svcKeiUcwkNo); kk0161Cond.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg)); return new JKKejbKK0161DBABase().findByCurrent(kk0161Cond); } /** ** オプションサービス契約に紐付くサービス契約のカレントレコードを取得します。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param opSvcKeiNo オプションサービス契約番号 * @return オプションサービス契約に紐付くサービス契約のカレントレコード */ private CAANMsg getCurSvcKeiViaOpKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, String opSvcKeiNo) { // オプションサービス契約のカレントレコードを取得 CAANMsg kk0351Cur = getCurOpKei(inCBSMsg, inContext, opSvcKeiNo); // オプションサービス契約が存在しない場合 if (kk0351Cur == null) { return null; } String svcKeiNo = null; // 親契約識別コードがサービス契約の場合 if (OYA_KEI_SKBT_CD_SVC_KEI.equals(kk0351Cur.getString(KK0351ETMsg.OYA_KEI_SKBT_CD))) { // サービス契約番号を使用する svcKeiNo = kk0351Cur.getString(KK0351ETMsg.SVC_KEI_NO); } // 親契約識別コードがサービス契約内訳の場合 else if (OYA_KEI_SKBT_CD_SVC_KEI_UCWK.equals(kk0351Cur.getString(KK0351ETMsg.OYA_KEI_SKBT_CD))) { // サービス契約内訳番号に紐付くサービス契約内訳を取得 CAANMsg retMsgKK0161 = getCurSvcKeiUcwk(inCBSMsg, inContext, kk0351Cur.getString(KK0351ETMsg.SVC_KEI_UCWK_NO)); // 取得したサービス契約内訳のサービス契約番号を使用する svcKeiNo = retMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO); } // サービス契約カレントレコード検索 return getCurSvcKei(inCBSMsg, inContext, svcKeiNo); } /** ** オプションサービス契約の開始に伴うオプションサービス契約の登録内容の設定を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk0351Msg オプションサービス契約のETメッセージ * @param staYmd 開始年月日 * @param chrgStaYmd 課金開始年月日 * @return オプションサービス契約の登録内容 */ private CAANMsg setInfoOfOpKei(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk0351Msg, String staYmd, String chrgStaYmd) { String opSvcKeiNo = kk0351Msg.getString(KK0351ETMsg.OP_SVC_KEI_NO); // サービスインターフェイスID String templateID = inCBSMsg.getString(JCMConstants.TEMPLATE_ID_KEY); // 引継元となるオプションサービス契約カレントレコード取得 CAANMsg ret = getCurOpKei(inCBSMsg, inContext, opSvcKeiNo); // 入力値設定 ret.set(KK0351ETMsg.OP_SVC_KEI_NO, opSvcKeiNo); ret.set(KK0351ETMsg.GENE_ADD_DTM, JKKModelCommon.getTransferGeneAddDtm(inCBSMsg, inContext)); ret.set(KK0351ETMsg.OP_SVC_KEI_STAT, STAT_USING); String opedate = JKKModelCommon.getOpeDate(inCBSMsg); //オプションサービス契約ステータスに応じてカレント引継を行うか判定する if(JKKModelCommon.isStatCurrentKK0351(inCBSMsg, inContext, inCBSMsg.getObject(OP_SVC_KEI_NO))){ // 運用日 ＞ サービス開始年月日の場合 if (JPCUtilCommon.isPastDate(staYmd, opedate, "0")) { ret.set(KK0351ETMsg.RSV_APLY_YMD, opedate); } else { ret.set(KK0351ETMsg.RSV_APLY_YMD, staYmd); } } ret.set(KK0351ETMsg.RSV_APLY_CD, APLYCD_DECIDED); ret.set(KK0351ETMsg.PLAN_STAYMD, staYmd); ret.set(KK0351ETMsg.PLAN_ENDYMD, SYS_LASTYMD); ret.set(KK0351ETMsg.PLAN_CHRG_STAYMD, chrgStaYmd); ret.set(KK0351ETMsg.PLAN_CHRG_ENDYMD, SYS_LASTYMD); ret.set(KK0351ETMsg.SVC_STAYMD, staYmd); if ("EKK0381C040".equals(templateID)) { // "EKK0381C040"の場合、「表示用サービス提供開始年月日」には常に「サービス開始年月日」を設定 ret.set(KK0351ETMsg.DSP_SVCTK_STAYMD, staYmd); } // ANK-4427-00-00 ADD START else if ("EKK0361C040".equals(templateID)) { // 表示用サービス提供開始年月日 String dspSvctkStaymd = kk0351Msg.getString(KK0351ETMsg.DSP_SVCTK_STAYMD); if (dspSvctkStaymd != null && dspSvctkStaymd.length() > 0) { ret.set(KK0351ETMsg.DSP_SVCTK_STAYMD, dspSvctkStaymd); } } // ANK-4427-00-00 ADD END ret.set(KK0351ETMsg.SVC_CHRG_STAYMD, chrgStaYmd); ret.set(KK0351ETMsg.SVC_ENDYMD, SYS_LASTYMD); ret.set(KK0351ETMsg.SVC_CHRG_ENDYMD, SYS_LASTYMD); ret.set(KK0351ETMsg.IDO_DIV, kk0351Msg.getString(KK0351ETMsg.IDO_DIV)); ret.set(KK0351ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); ret.set(KK0351ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); ret.set(KK0351ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); ret.set(KK0351ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); ret.setNull(KK0351ETMsg.DEL_DTM); ret.setNull(KK0351ETMsg.DEL_OPEACNT); ret.set(KK0351ETMsg.MK_FLG, MKFLG_VALID); return ret; } /** ** オプションサービス契約の開始に伴う異動予約の登録内容の設定を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk1681Msg 異動予約のETメッセージ * @param staYmd 開始年月日 * @param chrgStaYmd 課金開始年月日 * @param ruleMap 異動対象スキーマ判定相関ルールの結果のマップ * @return 異動予約の登録内容 */ private CAANMsg setInfoOfIdoRsv(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk1681Msg, String staYmd, String chrgStaYmd, Map* オプションサービス契約の開始に伴う異動予約の登録内容の設定を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param msgKK0401 副次対象のサブオプションサービス契約レコード * @param staYmd 開始年月日 * @param ruleMap 異動対象スキーマ判定相関ルールの結果のマップ * @return 異動予約の登録内容 */ private CAANMsg setInfoOfIdoRsvSec(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg msgKK0401, String staYmd, Map* 料金計算日より求めた請求年月に末日を付与して返却します * @param inCBSMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return 請求年月の末日 *
*/ private String getCH0501SeikyYmd(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; try { //コネクション取得 con1 = JSYejbConnection.getConnection(CH0501ETMsg.getTableName()); String templateID = inCBSMsg.getString(JCMConstants.TEMPLATE_ID_KEY); // SQL文 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" CH0501.SEIKY_YM AS SEIKY_YM ") .append(" FROM ") .append(" CH_M_PRC_SCHDL_TEIGI CH0501 ") .append(" WHERE ") .append(" CH0501.EVENT_CD = '03' ") .append(" AND (CH0501.EVENT_CD, CH0501.EVENT_YMD) = ") .append(" (SELECT CH0501_MAX.EVENT_CD, MAX(CH0501_MAX.EVENT_YMD) AS CH0501_MAX ") .append(" FROM CH_M_PRC_SCHDL_TEIGI CH0501_MAX ") .append(" WHERE CH0501_MAX.EVENT_CD = CH0501.EVENT_CD "); if (templateID.equals(TEMPLATE_ID_EKK0361C040)) { sql_Buff.append(" AND CH0501_MAX.EVENT_YMD < ? "); } else { sql_Buff.append(" AND CH0501_MAX.EVENT_YMD <= ? "); } sql_Buff.append(" AND CH0501_MAX.MK_FLG = '0' ") .append(" GROUP BY CH0501_MAX.EVENT_CD ") .append(" ) "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 1, JKKModelCommon.getOpeDate(inCBSMsg)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // 検索結果が0件の場合 if (rsltQuery == null) { return null; } String seikyYm = null; // 請求年月を取得する if (rsltQuery.next()) { seikyYm = rsltQuery.getString("SEIKY_YM"); } // 請求年月を元に末日を付与して返却します return seikyYm.concat(JPCDateUtil.getEndOfMonth(seikyYm)); } catch (SQLException se) { throw new CAANRuntimeException(se); } finally { // 資源の解放 try { if (rsltQuery != null) { rsltQuery.close(); } if (pstmt != null) { pstmt.close(); } if (con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch (SQLException se) { throw new CAANRuntimeException(se); } } } /** ** 配送から配送完了年月日を取得します * @param inETMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return 配送年月日 *
*/ private String getDK0011HaisoFinYmd(CAANMsg inETMsg, AgentDispatchContext inContext) { // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; try { //コネクション取得 con1 = JSYejbConnection.getConnection(DK0011ETMsg.getTableName()); // SQL文 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" DK0011.HAISO_FIN_YMD AS HAISO_FIN_YMD ") .append(" FROM ") .append(" (SELECT ") .append(" KK0341.* ") .append(" ,ROW_NUMBER() OVER (PARTITION BY KK0341.SVC_KEI_NO ORDER BY KK0341.SHOSA_YMD DESC) AS LINE ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341 ") .append(" WHERE KK0341.SVC_KEI_NO = ? ") .append(" AND KK0341.KKTK_SVC_KEI_STAT = '100' ") .append(" AND KK0341.TAKNKIKI_SBT_CD = 'P0' ") .append(" AND (KK0341.KKTK_SVC_KEI_NO, KK0341.RSV_APLY_YMD || KK0341.GENE_ADD_DTM) = ") .append(" (SELECT KK0341_GENE.KKTK_SVC_KEI_NO, MAX(KK0341_GENE.RSV_APLY_YMD || KK0341_GENE.GENE_ADD_DTM) AS KK0341_MAX ") .append(" FROM KK_T_KKTK_SVC_KEI KK0341_GENE ") .append(" WHERE KK0341_GENE.KKTK_SVC_KEI_NO = KK0341.KKTK_SVC_KEI_NO ") .append(" AND KK0341_GENE.RSV_APLY_CD = '2' ") .append(" AND KK0341_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0341_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0341_GENE.KKTK_SVC_KEI_NO ") .append(" ) ") .append(" ) KK0341_01 ") .append(" INNER JOIN DK_T_HAISO_TG_BPIN DK0021 ") .append(" ON KK0341_01.KKTK_SVC_KEI_NO = DK0021.KKTK_SVC_KEI_NO ") .append(" INNER JOIN DK_T_HAISO DK0011 ") .append(" ON DK0011.HAISO_NO = DK0021.HAISO_NO ") .append(" WHERE ") .append(" DK0021.HAISO_TAIBPIN_NO = ") .append(" (SELECT MAX(DK0021_GENE.HAISO_TAIBPIN_NO) AS DK0021_MAX ") .append(" FROM DK_T_HAISO_TG_BPIN DK0021_GENE ") .append(" WHERE DK0021_GENE.KKTK_SVC_KEI_NO = DK0021.KKTK_SVC_KEI_NO ") .append(" AND DK0021_GENE.MK_FLG = '0' ") .append(" GROUP BY DK0021_GENE.KKTK_SVC_KEI_NO ") .append(" ) ") .append(" AND DK0011.HAISO_STAT = '004' ") .append(" AND DK0011.HAISO_FIN_YMD IS NOT NULL ") .append(" AND DK0011.MK_FLG = '0' ") // ++++++++++ v9.00.02 変更開始 ++++++++++ // // .append(" ORDER BY DK0011.HAISO_FIN_YMD DESC "); .append(" ORDER BY DK0011.HAISO_FIN_YMD ASC "); // ++++++++++ v9.00.02 変更終了 ++++++++++ // //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // パラメータの設定(サービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, 1, inETMsg.getString(KK0081ETMsg.SVC_KEI_NO)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 2, JKKModelCommon.getOpeDate(inETMsg)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); String haisoFinYmd = null; // 配送完了日を取得する if (rsltQuery.next()) { haisoFinYmd = rsltQuery.getString("HAISO_FIN_YMD"); } else { return null; } // 配送完了日に10日足して返却します return JPCDateUtil.addDay(haisoFinYmd, 10); } catch (SQLException se) { throw new CAANRuntimeException(se); } finally { // 資源の解放 try { if (rsltQuery != null) { rsltQuery.close(); } if (pstmt != null) { pstmt.close(); } if (con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch (SQLException se) { throw new CAANRuntimeException(se); } } } /** ** オプションサービス契約の登録を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk0351Msg オプションサービス契約のETメッセージ */ private void createKK0351(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk0351Msg) { JKKejbDBAUtil dbaU = new JKKejbDBAUtil(inCBSMsg); dbaU.create(kk0351Msg); } /** ** 異動予約の登録を行います。 *
* @param inCBSMsg CBSメッセージ * @param inContext Agentから渡されたAgentDispatchContext * @param kk1681Msg 異動予約のETメッセージ */ private void createKK1681(CAANMsg inCBSMsg, AgentDispatchContext inContext, CAANMsg kk1681Msg) { JKKejbDBAUtil dbaU = new JKKejbDBAUtil(inCBSMsg); dbaU.create(kk1681Msg); } /** ** エラー返却項目にエラーフラグを設定します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param status エラー時のステータス * @param errInfo[] エラー情報が設定された配列 [0]:エラーフラグ [1]:エラー返却項目 */ private void setErrInfo(CAANMsg inCBSMsg, int status, String[] errInfo) { inCBSMsg.set(JCMConstants.STATUS_INT_KEY, status); inCBSMsg.set(errInfo[1], errInfo[0]); return; } /** ** 申込期間を取得する *
* @param inCBSMsg 処理対象のメッセージキャリア * @param mskmYmd 申込日 * @param svcStaYmd サービス開始日 * @param svcChrgStaymd サービス課金開始日 * @return 申込期間 */ private String getMskmPeriod(CAANMsg inCBSMsg, String mskmYmd, String svcStaYmd, String svcChrgStaymd) { // 申込期間を取得 JKKejbRule0088001 rule0088 = new JKKejbRule0088001(inCBSMsg); rule0088.setMskm_ymd(mskmYmd); rule0088.setSvc_sta_ymd(svcStaYmd); rule0088.setSvc_chrg_staymd(svcChrgStaymd); return rule0088.getMskmPeriodDef(); } /** ** 課金開始日設定の相関ルールを呼び出し課金開始年月日を取得します * （更新契機が解約時のケース） *
* @param inMsg 処理対象のメッセージキャリア * @param kk0351Msg オプションサービス契約のカレント検索結果 * @param kk0081Msg サービス契約のカレント検索結果 * @return 相関ルールより取得した課金開始年月日 */ public String chrgStaYmdRuleRunForDsl(CAANMsg inMsg, CAANMsg kk0351Msg, CAANMsg kk0081Msg) { String staymd = null; // サービス開始年月日(またはプラン開始年月日)(オプションカレント) String endymd = null; // サービス終了年月日(またはプラン終了年月日) String chrgStaymd = null; // サービス課金開始年月日(またはプラン課金開始年月日)(オプションカレント) String chrgEndymd = null; // サービス課金終了年月日(またはプラン課金終了年月日) String dsljiChrgFlg = null; // 解約時課金フラグ // サービスインターフェイスID String templateID = inMsg.getString(JCMConstants.TEMPLATE_ID_KEY); // 呼出元：オプションサービス契約解約確定 if ("EKK0351C250".equals(templateID)) { staymd = kk0351Msg.getString(KK0351ETMsg.SVC_STAYMD); endymd = inMsg.getString(EKK0351C250CBSMsg.SVC_ENDYMD); chrgStaymd = kk0351Msg.getString(KK0351ETMsg.SVC_CHRG_STAYMD); chrgEndymd = inMsg.getString(EKK0351C250CBSMsg.SVC_CHRG_ENDYMD); dsljiChrgFlg = inMsg.getString(EKK0351C250CBSMsg.DSLJI_CHRG_FLG); // OM-2014-0003837 ADD START // 解約時課金フラグが課金の場合 if (DSLJI_CHRG_FLG_CHRG.equals(dsljiChrgFlg) && !kk0081Msg.isNull(KK0081ETMsg.SVC_CHRG_STAYMD) && null != chrgEndymd) { // 検索結果のオプションサービス契約ステータスが締結済以外の場合かつネットの場合 // (受付済及び照査済からはオプションサービス契約解約確定・プラン変からは呼ばれない。 // 締結済の場合はサービス課金開始日が未設定である。） if (!JKKModelConst.SVC_KEI_STAT_CNC_ZM.equals(kk0351Msg.getString(KK0351ETMsg.OP_SVC_KEI_STAT)) && JKKModelConst.SVC_CD_NET.equals(kk0081Msg.getString(KK0081ETMsg.SVC_CD))) { // 親サービス契約のサービス課金開始年月日 ≦ サービス課金終了年月日でない場合 if (!JKKModelCommon.isPastDate(kk0081Msg.getString(KK0081ETMsg.SVC_CHRG_STAYMD), chrgEndymd, "1")) { // 解約時課金フラグは非課金とする dsljiChrgFlg = DSLJI_CHRG_FLG_NO_CHRG; } } } // OM-2014-0003837 ADD END } // 呼出元：オプションサービス契約料金プラン変更確定 else if ("EKK0351C130".equals(templateID)) { staymd = kk0351Msg.getString(KK0351ETMsg.PLAN_STAYMD); endymd = inMsg.getString(EKK0351C130CBSMsg.PLAN_ENDYMD); chrgStaymd = kk0351Msg.getString(KK0351ETMsg.PLAN_CHRG_STAYMD); chrgEndymd = inMsg.getString(EKK0351C130CBSMsg.PLAN_CHRG_ENDYMD); dsljiChrgFlg = inMsg.getString(EKK0351C130CBSMsg.DSLJI_CHRG_FLG); } // 相関ルールを呼び出す為にインスタンス生成する JKKejbRule0066001 instance = new JKKejbRule0066001(inMsg); // 課金開始前／開始後を判定する String dslStaZengo = null; // 検索結果のオプションサービス契約ステータスが締結済以外の場合 // (受付済及び照査済からはオプションサービス契約解約確定・プラン変からは呼ばれない。 // 締結済の場合はサービス課金開始日が未設定である。） if (!JKKModelConst.SVC_KEI_STAT_CNC_ZM.equals(kk0351Msg.getString(KK0351ETMsg.OP_SVC_KEI_STAT)) && null != chrgStaymd && null != chrgEndymd) { // サービス課金開始年月日(またはプラン課金開始年月日) ≦ サービス課金終了年月日(またはプラン課金終了年月日) の場合 if (JKKModelCommon.isPastDate(chrgStaymd, chrgEndymd, "1")) { // 課金開始後解約 dslStaZengo = "1"; } // サービス課金開始年月日(またはプラン課金開始年月日) ＞ サービス課金終了年月日(またはプラン課金終了年月日) の場合 else { // 課金開始前解約 dslStaZengo = "0"; } } else { // 課金開始前解約 dslStaZengo = "0"; } instance.setSvc_cd(kk0081Msg.getString(KK0081ETMsg.SVC_CD)); // サービスコード instance.setUpd_type("0"); // 更新契機(解約時) instance.setOp_svc_cd(kk0351Msg.getString(KK0351ETMsg.OP_SVC_CD)); // オプションサービスコード instance.setDslji_chrg(dsljiChrgFlg); // 解約時課金フラグ instance.setDsl_sta_zengo(dslStaZengo); // 課金開始前／開始後 instance.setSvc_sta_ymd(staymd); // サービス開始年月日(またはプラン開始年月日)(オプションカレント) instance.setSvc_chrg_sta_ymd(chrgStaymd); // サービス課金開始年月日(またはプラン課金開始年月日)(オプションカレント) instance.setSvc_end_ymd(endymd); // サービス終了年月日(またはプラン終了年月日) // ▽▽▽ ANK-3484-00-00 ADD START instance.setBefor_svc_chrg_end_ymd(null); // 引継は存在しない // △△△ ANK-3484-00-00 ADD END // 相関ルールを実行して結果を返却する return instance.getChrgStaYmd(); } /** ** サービス契約番号に紐づくオプションサービス契約を遡及解約します。 *
* @param inCBSMsg 処理対象のメッセージキャリア * @param svcChrgEndYmd サービス課金終了年月日 */ public void sokyuKK0351(CAANMsg inCBSMsg, String svcChrgEndYmd) { CAANMsg[] kk0351List; String opedate = JKKModelCommon.getOpeDate(inCBSMsg); JKKejbKK0351DBABase dbaBase = new JKKejbKK0351DBABase(); // サービス契約番号に紐づくオプションサービス契約を取得 kk0351List = dbaBase.getKK0351bySvcKei(inCBSMsg.getString(EKK0081C260CBSMsg.SVC_KEI_NO), null, opedate, "3"); for (CAANMsg kk0351Data : kk0351List) { // オプションサービス契約ステータスが解約済でサービス契約よりも課金終了年月日が遅い場合 if (JKKModelConst.SVC_KEI_STAT_DSL_ZM.equals(kk0351Data.getString(KK0351ETMsg.OP_SVC_KEI_STAT)) && !kk0351Data.isNull(KK0351ETMsg.SVC_CHRG_ENDYMD) && kk0351Data.getString(KK0351ETMsg.SVC_CHRG_ENDYMD).compareTo(svcChrgEndYmd) > 0 && (inCBSMsg.isNull(EKK0081C260CBSMsg.MSKM_DTL_NO) || !inCBSMsg.getString(EKK0081C260CBSMsg.MSKM_DTL_NO).equals(kk0351Data.getString(KK0351ETMsg.MSKM_DTL_NO)))) { String svcEndYmd = inCBSMsg.getString(EKK0081C260CBSMsg.SVC_ENDYMD); // 遡及解約に伴う更新処理 CAANMsg inETMsg = new CAANMsg(KK0351ETMsg.class.getName()); inETMsg.set(KK0351ETMsg.OP_SVC_KEI_NO, kk0351Data.getString(KK0351ETMsg.OP_SVC_KEI_NO)); // オプションサービス契約番号 inETMsg.set(KK0351ETMsg.GENE_ADD_DTM, kk0351Data.getString(KK0351ETMsg.GENE_ADD_DTM)); // 世代登録年月日時分秒 inETMsg.set(KK0351ETMsg.OP_SVC_KEI_STAT, JKKModelConst.SVC_KEI_STAT_DSL_ZM); // オプションサービス契約ステータス inETMsg.set(KK0351ETMsg.PLAN_ENDYMD, svcEndYmd); // プラン終了年月日 inETMsg.set(KK0351ETMsg.PLAN_CHRG_ENDYMD, svcChrgEndYmd); // プラン課金終了年月日 // 予約適用年月日 if (opedate.compareTo(svcEndYmd) > 0) { // サービス終了年月日が運用日付より過去の場合運用日付を設定 inETMsg.set(KK0351ETMsg.RSV_APLY_YMD, opedate); } else { // 上記以外の場合サービス終了年月日を設定 inETMsg.set(KK0351ETMsg.RSV_APLY_YMD, svcEndYmd); } inETMsg.set(KK0351ETMsg.RSV_APLY_CD, JKKModelConst.RSV_APLY_CD_RSV_FIX); // 予約適用コード inETMsg.set(KK0351ETMsg.SVC_ENDYMD, svcEndYmd); // サービス終了年月日 inETMsg.set(KK0351ETMsg.SVC_CHRG_ENDYMD, svcChrgEndYmd); // サービス課金終了年月日 inETMsg.set(KK0351ETMsg.SVC_DLRE_CD, inCBSMsg.getString(EKK0081C260CBSMsg.SVC_DLRE_CD)); // サービス解約理由コード inETMsg.set(KK0351ETMsg.SVC_DLRE_MEMO, inCBSMsg.getString(EKK0081C260CBSMsg.SVC_DLRE_MEMO)); // サービス解約理由メモ inETMsg.set(KK0351ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY)); inETMsg.set(KK0351ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY)); JKKejbDBAUtil dbaUtil = new JKKejbDBAUtil(inCBSMsg); dbaUtil.update(inETMsg); } // サブオプションサービス契約の遡及解約 new JKKejbKK0401ETDA().sokyuKK0401(inCBSMsg, kk0351Data.getString(KK0351ETMsg.OP_SVC_KEI_NO), svcChrgEndYmd); } } // ▽▽▽ ANK-3484-00-00 ADD START /** *
* オプションサービス契約
* @param inETMsg メッセージ * @param inContext コンテキスト * @param opSvcKeiNo オプションサービス契約番号 * @param opSvcCd オプションサービスコード */ public String getTmcpPreviousSvcChrgEnd(CAANMsg inETMsg, AgentDispatchContext inContext, String opSvcKeiNo, String opSvcCd) { // 端末補償以外のオプションの場合、検索を行わない if (!TMCP_OP_SVC_CD_LIST.contains(opSvcCd)) { return null; } // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; try { //コネクション取得 con1 = JSYejbConnection.getConnection(KK0351ETMsg.getTableName()); // SQL文 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" MAX(KK0351.SVC_CHRG_ENDYMD) AS SVC_CHRG_ENDYMD ") .append(" FROM KK_T_OP_SVC_KEI KK0351") .append(" WHERE ") .append(" KK0351.OP_SVC_KEI_NO IN") .append(" (") .append(" SELECT KK0361.OP_SVC_KEI_NO") .append(" FROM KK_T_OPSVKEI_ISP KK0361") .append(" WHERE ") .append(" KK0361.OP_SVC_KEI_NO != ?") .append(" AND ") .append(" KK0361.TMCP_KEI_NO IN (") .append(" SELECT KK0361_TMCP.TMCP_KEI_NO ") .append(" FROM KK_T_OPSVKEI_ISP KK0361_TMCP ") .append(" WHERE KK0361_TMCP.OP_SVC_KEI_NO = ?") .append(" ) ") .append(" AND ") .append(" KK0361.MK_FLG = '0'") .append(" )") .append(" AND") .append(" (KK0351.RSV_APLY_YMD || KK0351.GENE_ADD_DTM) =") .append(" (") .append(" SELECT MAX(KK0351_MAX.RSV_APLY_YMD || KK0351_MAX.GENE_ADD_DTM)") .append(" FROM KK_T_OP_SVC_KEI KK0351_MAX") .append(" WHERE ") .append(" KK0351_MAX.OP_SVC_KEI_NO = KK0351.OP_SVC_KEI_NO") .append(" AND") .append(" KK0351_MAX.RSV_APLY_YMD <= ?") .append(" AND") .append(" KK0351_MAX.RSV_APLY_CD = '2'") .append(" AND ") .append(" KK0351_MAX.MK_FLG = '0'") .append(" )") .append(" AND") .append(" KK0351.OP_SVC_KEI_STAT = '910'") .append(" AND") .append(" KK0351.MK_FLG = '0'"); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // パラメータの設定(オプションサービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, 1, opSvcKeiNo); // パラメータの設定(オプションサービス契約番号を指定) CAANJDBCUtil.setParam(pstmt, 2, opSvcKeiNo); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 3, JKKModelCommon.getOpeDate(inETMsg)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); String chagEndYmd = ""; // 課金終了日を取得する if (rsltQuery.next()) { chagEndYmd = rsltQuery.getString("SVC_CHRG_ENDYMD"); } return chagEndYmd; } catch (SQLException se) { throw new CAANRuntimeException(se); } finally { // 資源の解放 try { if (rsltQuery != null) { rsltQuery.close(); } if (pstmt != null) { pstmt.close(); } if (con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch (SQLException se) { throw new CAANRuntimeException(se); } } } // ▲▲▲ ANK-3484-00-00 ADD END // ▽▽▽ ANK-3754-00-00 ADD STRAT /** *
* 多機能ルータの出荷日、配送方法コード、工事完了日 * @param inETMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return 出荷日 * @return 配送先工事会社コード * @return 工事完了日 *
*/ private HashMap