*
* @author 富士通
*/
public class JBSbatCHKhriInfoRef extends JBSbatBusinessService implements JBSbatMatchServiceInterface
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(請求)*/
private static final String D_TBL_NAME_CH_T_SEIKY = "CH_T_SEIKY";
/** テーブル(請求内訳)*/
private static final String D_TBL_NAME_CH_T_SEIKY_UCWK = "CH_T_SEIKY_UCWK";
/** テーブル(料金項目抽出変換)*/
private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";
/** SQL定義キー(CH_SELECT_005)*/
private static final String CH_M_PRC_KMK_CS_CHGE_CH_SELECT_005 = "CH_SELECT_005";
/** テーブルアクセスクラス(請求)*/
private JBSbatSQLAccess db_CH_T_SEIKY = null;
/** テーブルアクセスクラス(請求内訳)*/
private JBSbatSQLAccess db_CH_T_SEIKY_UCWK = null;
/** テーブルアクセスクラス(料金項目抽出変換)*/
private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null;
/** キーマッチ処理フラグ*/
private boolean matchProcFlg;
/** マスタファイル処理フラグ*/
private boolean mastProcFlg;
/** トランファイル処理フラグ*/
private boolean tranProcFlg;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 更新件数 */
private int updateCnt = 0;
/** 業務機能識別コード（請求依頼金額）*/
private String workKinoSbtCd = JACStrConst.KARA_MOJI;
/** 料金グループコード（請求依頼金額）*/
private String prcGrpCd = JACStrConst.KARA_MOJI;
/** 料金コースコード（請求依頼金額）*/
private String pcrsCd = JACStrConst.KARA_MOJI;
/** 料金サービスコード（請求依頼金額）*/
private String prcSvcCd = JACStrConst.KARA_MOJI;
/** 料金項目コード（請求依頼金額）*/
private String prcKmkCd = JACStrConst.KARA_MOJI;
/** 月初日*/
private String manStaYmd = JACStrConst.KARA_MOJI;
/** 月末日*/
private String manEndYmd = JACStrConst.KARA_MOJI;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CH_T_SEIKY = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_SEIKY);
db_CH_T_SEIKY_UCWK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_SEIKY_UCWK);
db_CH_M_PRC_KMK_CS_CHGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial][opeDate ＝ " + super.opeDate + "]");
// パラメータ取得クラス生成
JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
// 業務パラメータより業務機能識別コード（請求依頼金額）を取得する
this.workKinoSbtCd = paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_SEIKY_IRAI);
// パラメータ取得クラスクローズ
paramUtil.close();
// 業務機能識別コードより「請求依頼金額」情報を取得
getPrcKmkCsChgeInfo();
// 料金スケジュール定義アクセス部品初期処理
JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);
// 請求年月(口座振替請求依頼日)を取得する
String seikyYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_KOUZA_SEIKYU_IRAI_YMD);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial]請求年月（口座振替請求依頼日）：" + seikyYm);
// 群月初日、群締め日を取得する
String[] gunStartEndDate = schdlUtil.getUseStrEnd(seikyYm, JACStrConst.EVENT_CD_USE_STAYMD, JACStrConst.EVENT_CD_USE_ENDYMD);
// 月初日
this.manStaYmd = gunStartEndDate[0];
// 月末日
this.manEndYmd = gunStartEndDate[1];
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial]群月初日：" + gunStartEndDate[0]);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial]群締め日：" + gunStartEndDate[1]);
// 料金スケジュール定義アクセス部品クローズ
schdlUtil.close();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param mastMap 入力電文
* @param tranMap 入力電文
* @param outputInItem 入力情報
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap mastMap, JBSbatServiceInterfaceMap tranMap, JBSbatOutputItem outputInItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
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(mastMap == null && tranMap != null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍが存在しない]");
// フラグ．トラン ← true
this.setTranProcFlg(true);
}
// 入力Ｔのみが未存在の場合
else if(mastMap != null && tranMap == null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｔが存在しない]");
// フラグ．マスタ ← true
this.setMastProcFlg(true);
}
// 入力Ｍおよび入力Ｔが存在する場合
else
{
// マッチングキーＭ
String mastKey = mastMap.getString(JBSbatCHIFM006.SEIKY_NO);
// マッチングキーＴ
String tranKey = tranMap.getString(JBSbatCHIFM217.SEIKY_NO);
// 入力Ｍ＝入力Ｔ（マッチ）
if(mastKey.compareTo(tranKey) == 0)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＝入力Ｔ（マッチ）]");
// 請求スキーマ更新件数
int seikyUpdCount = 0;
// 請求スキーマ更新処理
seikyUpdCount = updateSeiky(mastMap);
// 請求スキーマに対して更新処理が行われた場合
if(seikyUpdCount > 0)
{
// 入力Ｍ．金額
BigDecimal mastAmnt = mastMap.getBigDecimal(JBSbatCHIFM006.AMNT);
// 入力Ｔ．金額
BigDecimal tranAmnt = tranMap.getBigDecimal(JBSbatCHIFM217.AMNT);
// 入力Ｍ．金額 ≠ 入力Ｔ．金額
if(mastAmnt.compareTo(tranAmnt) != 0)
{
// 請求内訳スキーマ登録
insertSeikyUcwk(mastMap);
}
}
// フラグ．マスタ ← true
this.setMastProcFlg(true);
// フラグ．トラン ← true
this.setTranProcFlg(true);
}
// 入力Ｍ＜入力Ｔ
else if(mastKey.compareTo(tranKey) < 0)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＜入力Ｔ]");
// フラグ．マスタ ← true
this.setMastProcFlg(true);
}
// 入力Ｍ＞入力Ｔ
else
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＞入力Ｔ]");
// フラグ．トラン ← true
this.setTranProcFlg(true);
}
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return outputInItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 請求スキーマを更新します。
*
* @param inMap 入力電文
* @return count 更新件数
* @throws Exception 業務サービス内で発生した例外全般
*/
private int updateSeiky(JBSbatServiceInterfaceMap inMap) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][updateSeiky]");
// 更新件数
int count = 0;
// 設定値
JBSbatCommonDBInterface setParam = new JBSbatCommonDBInterface();
// 請求依頼年月日
setParam.setValue(super.opeDate);
// 更新年月日時分秒
setParam.setValue(JCCBatCommon.getSysDateTimeStamp());
// 更新オペレータアカウント
setParam.setValue(super.batchUserId);
// 条件値
JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface();
// 入力情報．請求番号
whereParam.setValue(inMap.getString(JBSbatCHIFM006.SEIKY_NO));
// 更新実行（PK更新）
count = executeCH_T_SEIKY_PKUPDATE(setParam.getList().toArray(), whereParam.getList().toArray());
// 更新件数カウントアップ
updateCnt += count;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][updateSeiky]");
return count;
}
/**
* 請求内訳スキーマを登録します。
*
* @param inMap 入力電文
* @throws Exception 業務サービス内で発生した例外全般
*/
private void insertSeikyUcwk(JBSbatServiceInterfaceMap inMap) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][insertSeikyUcwk]");
// 設定値
JBSbatCommonDBInterface setParam = new JBSbatCommonDBInterface();
// 請求番号
setParam.setValue(inMap.get(JBSbatCHIFM006.SEIKY_NO));
// 請求契約番号
setParam.setValue(inMap.get(JBSbatCHIFM006.SEIKY_KEI_NO));
// 請求年月
setParam.setValue(inMap.get(JBSbatCHIFM006.SEIKY_YM));
// 整理番号
setParam.setValue(JACStrConst.SEIRI_NO_SP);
// サービス契約番号
setParam.setValue(JACStrConst.SVC_KEI_NO_SP);
// 料金グループコード
setParam.setValue(this.prcGrpCd);
// 料金コースコード
setParam.setValue(this.pcrsCd);
// 料金サービスコード
setParam.setValue(this.prcSvcCd);
// 料金項目コード
setParam.setValue(this.prcKmkCd);
// 合算請求年月
setParam.setValue(inMap.get(JBSbatCHIFM006.SEIKY_YM));
// 利用開始年月日
setParam.setValue(this.manStaYmd);
// 利用終了年月日
setParam.setValue(this.manEndYmd);
// 金額
setParam.setValue(inMap.get(JBSbatCHIFM006.AMNT));
// 料金訂正登録フラグ
setParam.setValue(JACStrConst.PRC_TEISE_ADD_FLG_OFF);
// 登録年月日時分秒
setParam.setValue(null);
// 登録オペレータアカウント
setParam.setValue(null);
// 更新年月日時分秒
setParam.setValue(null);
// 更新オペレータアカウント
setParam.setValue(null);
// 削除年月日時分秒
setParam.setValue(null);
// 削除オペレータアカウント
setParam.setValue(null);
// 無効フラグ
setParam.setValue(null);
// 登録運用年月日
setParam.setValue(null);
// 登録処理ID
setParam.setValue(null);
// 更新運用年月日
setParam.setValue(null);
// 更新処理ID
setParam.setValue(null);
// 削除運用年月日
setParam.setValue(null);
// 削除処理ID
setParam.setValue(null);
// 登録実行（PK全項目登録）
executeCH_T_SEIKY_UCWK_PKINSERT(setParam.getList().toArray());
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][insertSeikyUcwk]");
}
/**
* 料金項目抽出変換情報取得
* @throws Exception
*/
private void getPrcKmkCsChgeInfo() throws Exception
{
// ＤＢアクセス用のパラメータ定義
JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();
// 対象キーの設定
dbList.setValue(super.systemCode); // システムコード
dbList.setValue(this.workKinoSbtCd); // 業務機能識別コード（請求依頼金額）
dbList.setValue(JACStrConst.CHSHT_CHG_CD_CST); // 抽出変換コード（抽出のみ）
dbList.setValue(super.opeDate); // バッチ運用日
dbList.setValue(super.opeDate); // バッチ運用日
// 料金項目抽出変換データ取得
executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_005(dbList.getList().toArray());
// 料金項目抽出変換データ取得結果
JBSbatCommonDBInterface dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
// 取得結果が存在しない場合
if(dbMap == null)
{
String[] msgParam = new String[]{JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME, dbList.toString()};
throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0260CH, msgParam);
}
// 取得結果より料金項目抽出変換情報を取得する
// 料金グループコード
this.prcGrpCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_GRP_CD);
// 料金コースコード
this.pcrsCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PCRS_CD);
// 料金サービスコード
this.prcSvcCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_SVC_CD);
// 料金項目コード
this.prcKmkCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD);
}
/**
* 業務サービス終了処理
* @throws Exception 業務サービス内で発生した例外全般。
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CH_T_SEIKY.close();
db_CH_T_SEIKY_UCWK.close();
db_CH_M_PRC_KMK_CS_CHGE.close();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
// 更新件数をログ出力
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB1190AI, new String[] {JBSbatCH_T_SEIKY.TABLE_NAME, String.valueOf(updateCnt)});
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* @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;
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 請求依頼年月日 SEIKY_REQ_YMD * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * SEIKY_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private int executeCH_T_SEIKY_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("SEIKY_REQ_YMD", setParam[0]);
setMap.setValue("UPD_DTM", setParam[1]);
setMap.setValue("UPD_OPEACNT", setParam[2]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("SEIKY_NO", whereParam[0]);
// DBアクセスを実行します
return db_CH_T_SEIKY.updateByPrimaryKeys(whereMap, setMap);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 請求番号 SEIKY_NO * 請求契約番号 SEIKY_KEI_NO * 請求年月 SEIKY_YM * 整理番号 SEIRI_NO * サービス契約番号 SVC_KEI_NO * 料金グループコード PRC_GRP_CD * 料金コースコード PCRS_CD * 料金サービスコード PRC_SVC_CD * 料金項目コード PRC_KMK_CD * 合算請求年月 GSAN_SEIKY_YM * 利用開始年月日 USE_STAYMD * 利用終了年月日 USE_ENDYMD * 金額 AMNT * 料金訂正登録フラグ PRC_TEISE_ADD_FLG * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG * 登録運用年月日 ADD_UNYO_YMD * 登録処理ＩＤ ADD_TRN_ID * 更新運用年月日 UPD_UNYO_YMD * 更新処理ＩＤ UPD_TRN_ID * 削除運用年月日 DEL_UNYO_YMD * 削除処理ＩＤ DEL_TRN_ID *
* @param setParam 設定項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_T_SEIKY_UCWK_PKINSERT(Object[] setParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("SEIKY_NO", setParam[0]);
setMap.setValue("SEIKY_KEI_NO", setParam[1]);
setMap.setValue("SEIKY_YM", setParam[2]);
setMap.setValue("SEIRI_NO", setParam[3]);
setMap.setValue("SVC_KEI_NO", setParam[4]);
setMap.setValue("PRC_GRP_CD", setParam[5]);
setMap.setValue("PCRS_CD", setParam[6]);
setMap.setValue("PRC_SVC_CD", setParam[7]);
setMap.setValue("PRC_KMK_CD", setParam[8]);
setMap.setValue("GSAN_SEIKY_YM", setParam[9]);
setMap.setValue("USE_STAYMD", setParam[10]);
setMap.setValue("USE_ENDYMD", setParam[11]);
setMap.setValue("AMNT", setParam[12]);
setMap.setValue("PRC_TEISE_ADD_FLG", setParam[13]);
setMap.setValue("ADD_DTM", setParam[14]);
setMap.setValue("ADD_OPEACNT", setParam[15]);
setMap.setValue("UPD_DTM", setParam[16]);
setMap.setValue("UPD_OPEACNT", setParam[17]);
setMap.setValue("DEL_DTM", setParam[18]);
setMap.setValue("DEL_OPEACNT", setParam[19]);
setMap.setValue("MK_FLG", setParam[20]);
setMap.setValue("ADD_UNYO_YMD", setParam[21]);
setMap.setValue("ADD_TRN_ID", setParam[22]);
setMap.setValue("UPD_UNYO_YMD", setParam[23]);
setMap.setValue("UPD_TRN_ID", setParam[24]);
setMap.setValue("DEL_UNYO_YMD", setParam[25]);
setMap.setValue("DEL_TRN_ID", setParam[26]);
// DBアクセスを実行します
db_CH_T_SEIKY_UCWK.insertByPrimaryKeys(setMap);
}
/**
* SQLKEY(CH_SELECT_005)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * システムコード * 業務機能識別機能コード * 抽出変換コード * 適用開始年月日 * 適用終了年月日 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_005(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); paramList.setValue(param[4].toString()); // DBアクセスを実行します db_CH_M_PRC_KMK_CS_CHGE.selectBySqlDefine(paramList, CH_M_PRC_KMK_CS_CHGE_CH_SELECT_005); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }