*
* @author 富士通
*/
public class JBSbatCHJotoMisyuPrcReplaceTgChst extends JBSbatBusinessService implements JBSbatMatchServiceInterface
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** キーマッチ処理フラグ*/
private boolean matchProcFlg;
/** マスタファイル処理フラグ*/
private boolean mastProcFlg;
/** トランファイル処理フラグ*/
private boolean tranProcFlg;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** テーブル(料金スケジュール定義)*/
private static final String D_TBL_NAME_CH_M_PRC_SCHDL_TEIGI = "CH_M_PRC_SCHDL_TEIGI";
/** SQL定義キー(AC_SELECT_014)*/
private static final String CH_M_PRC_SCHDL_TEIGI_AC_SELECT_015 = "AC_SELECT_015";
/** テーブルアクセスクラス(料金スケジュール定義)*/
private JBSbatSQLAccess db_CH_M_PRC_SCHDL_TEIGI = null;
/** 前回料金計算日 */
private String zenRyokinKeisanYmd = null;
/** 前前回料金計算日 */
private String zenZenRyokinKeisanYmd = null;
/** サービス契約番号 */
private String svcKeiNo = null;
/** 請求契約番号（譲渡元） */
private String seikyKeiNoMt = null;
/** 請求契約番号（譲渡先） */
private String seikyKeiNoSk = null;
/** 出力フラグ*/
private boolean outFlg = false;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CH_M_PRC_SCHDL_TEIGI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_SCHDL_TEIGI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// 前回料金計算日
zenRyokinKeisanYmd = getZenKaikCalkYmd(super.opeDate);
// 前前回料金計算日
zenZenRyokinKeisanYmd = getZenKaikCalkYmd(zenRyokinKeisanYmd);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param mastMap 入力電文
* @param tranMap 入力電文
* @param outputInItem 入力情報
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap mastMap, JBSbatServiceInterfaceMap tranMap, JBSbatOutputItem outputInItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert mastMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][mastMap=" + mastMap.getMap().toString() + "]") : true;
assert tranMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][tranMap=" + tranMap.getMap().toString() + "]") : true;
// 出力対象が存在する場合、ファイル出力を行う
if (outFlg)
{
// 出力
makeOutmap(mastMap, tranMap, outputInItem);
outFlg = false;
seikyKeiNoMt = null;
seikyKeiNoSk = null;
}
// 入力Ｍのみ存在する
if (mastMap != null && tranMap == null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍのみ存在する]");
this.setMastProcFlg(true);
}
// 入力Ｔのみ存在する
else if (mastMap == null && tranMap != null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｔのみ存在する]");
this.setTranProcFlg(true);
}
// 入力Ｍ、入力Ｔともに存在する
else
{
// マッチングキー（サービス契約番号）
String mastKey = mastMap.getString(JBSbatCHIFM346.SVC_KEI_NO);
// マッチングキー（サービス契約番号）
String tranKey = tranMap.getString(JBSbatCHIFM347.SVC_KEI_NO);
// 入力Ｍ＝入力Ｔ（マッチ）
if (mastKey.compareTo(tranKey) == 0)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＝入力Ｔ（マッチ）]");
// 出力情報の退避
seikyKeiNoSk = mastMap.getString(JBSbatCHIFM346.SEIKY_KEI_NO);
//課金先.課金先適用終了年月日 ＜ 異動年月日かつ、課金先.課金先適用開始年月日 ＜＝ 前々回の料金計算日かつ、課金先.課金先適用終了年月日 ＞＝ 前々回の料金計算日の場合
if (tranMap.getString(JBSbatCHIFM347.KAKINS_TENDYMD).compareTo(mastMap.getString(JBSbatCHIFM346.IDO_YND)) < 0 &&
tranMap.getString(JBSbatCHIFM347.KAKINS_TSTAYMD).compareTo(zenZenRyokinKeisanYmd) <= 0 &&
tranMap.getString(JBSbatCHIFM347.KAKINS_TENDYMD).compareTo(zenZenRyokinKeisanYmd) >= 0)
{
seikyKeiNoMt = tranMap.getString(JBSbatCHIFM347.SEIKY_KEI_NO);
}
// 譲渡元、譲渡先が設定されている場合、出力対象とする
if (seikyKeiNoMt != null && (svcKeiNo == null || !svcKeiNo.equals(mastKey)))
{
svcKeiNo = mastKey;
outFlg = true;
}
// トランのファイルを進める
this.setTranProcFlg(true);
}
// 入力Ｍ＜入力Ｔ
else if (mastKey.compareTo(tranKey) < 0)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＜入力Ｔ]");
// マスタのファイルを進める
this.setMastProcFlg(true);
}
// 入力Ｍ＞入力Ｔ
else
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＞入力Ｔ]");
// トランのファイルを進める
this.setTranProcFlg(true);
}
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return outputInItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CH_M_PRC_SCHDL_TEIGI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* @return mastProcFlg を戻します。
*/
public boolean isMastProcFlg()
{
return mastProcFlg;
}
/**
* @return matchProcFlg を戻します。
*/
public boolean isMatchProcFlg()
{
return matchProcFlg;
}
/**
* @return tranProcFlg を戻します。
*/
public boolean isTranProcFlg()
{
return tranProcFlg;
}
/**
* @param mast_ProcFlg 設定する mastProcFlg。
*/
public void setMastProcFlg(boolean mast_ProcFlg)
{
this.mastProcFlg = mast_ProcFlg;
}
/**
* @param match_ProcFlg 設定する matchProcFlg。
*/
public void setMatchProcFlg(boolean match_ProcFlg)
{
this.matchProcFlg = match_ProcFlg;
}
/**
* @param tran_ProcFlg 設定する tranProcFlg。
*/
public void setTranProcFlg(boolean tran_ProcFlg)
{
this.tranProcFlg = tran_ProcFlg;
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* SQLKEY(AC_SELECT_015)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * イベントコード * バッチ運用日 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_M_PRC_SCHDL_TEIGI_AC_SELECT_015(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_CH_M_PRC_SCHDL_TEIGI.selectBySqlDefine(paramList, CH_M_PRC_SCHDL_TEIGI_AC_SELECT_015); } /** * 過去直近（当日含まない）の料金計算日を取得します。 * * @param ymd イベント年月日 * @return String イベント年月日 * @throws Exception */ private String getZenKaikCalkYmd(String ymd) throws Exception { JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); // 料金スケジュール定義．イベントコード paramList.setValue(JACStrConst.EVENT_CD_RYOKIN_KEISAN_YMD); // 料金スケジュール定義．イベント日付 paramList.setValue(ymd); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectSeikyYm][paramList=" + paramList.getList().toString() + "]"); // SQL実行 executeCH_M_PRC_SCHDL_TEIGI_AC_SELECT_015(paramList.getList().toArray()); // 取得結果判定 JBSbatCommonDBInterface prcSchdlTeigiInfo = db_CH_M_PRC_SCHDL_TEIGI.selectNext(); // 取得結果判定 if (prcSchdlTeigiInfo == null) { // DB未存在エラー String[] msgParam = new String[] { JBSbatCH_M_PRC_SCHDL_TEIGI.TABLE_NAME, paramList.getList().toString(), }; throw new JBSbatBusinessException(JPCBatchMessageConstant.ECHB0270CH, msgParam); } return prcSchdlTeigiInfo.getString(JBSbatCH_M_PRC_SCHDL_TEIGI.EVENT_YMD); } /** * 出力情報作成 * * @param mastMap 入力情報 * @param tranMap 入力情報 * @param outputInItem 出力情報 * @throws Exception */ private void makeOutmap( JBSbatServiceInterfaceMap mastMap, JBSbatServiceInterfaceMap tranMap, JBSbatOutputItem outputInItem) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutmap]"); // 出力情報 JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); // サービス契約番号 outMap.setString(JBSbatCHIFM348.SVC_KEI_NO, svcKeiNo); // 請求契約番号（譲渡元） outMap.setString(JBSbatCHIFM348.SEIKY_KEI_NO_MT, seikyKeiNoMt); // 請求契約番号（譲渡先） outMap.setString(JBSbatCHIFM348.SEIKY_KEI_NO_SK, seikyKeiNoSk); // ANK-4083-00-00 ADD START // 異動理由コード outMap.setString(JBSbatCHIFM348.IDO_RSN_CD, mastMap.getString(JBSbatCHIFM346.IDO_RSN_CD)); // ANK-4083-00-00 ADD END // 出力指示フラグを設定 outMap.setOutFlg(true); // 解約精算金検証・マッチングファイル出力 outputInItem.addOutMapList(outMap); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutmap]"); } }