*
* @author 富士通
*/
public class JBSbatACOpTelTwDtlShuk extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(ｅｏ−ｎｅｔフォン通話合計)*/
private static final String D_TBL_NAME_AC_T_EONET_TW_GK = "AC_T_EONET_TW_GK";
/** SQL定義キー(AC_DELETE_001)*/
private static final String AC_T_EONET_TW_GK_AC_DELETE_001 = "AC_DELETE_001";
/** テーブルアクセスクラス(ｅｏ−ｎｅｔフォン通話合計)*/
private JBSbatSQLAccess db_AC_T_EONET_TW_GK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** ファイル定義 */
private static final String PARAM_IND = "IND";
/** 課税分(通話秒数) */
private static final String DTL_KAZEI_SEC_CNT = "KAZEI_SEC_CNT";
/** 非課税分(通話秒数) */
private static final String DTL_HIKAZEI_SEC_CNT = "HIKAZEI_SEC_CNT";
/** 課税分(レコード数) */
private static final String DTL_KAZEI_CNT = "KAZEI_CNT";
/** 非課税分(レコード数) */
private static final String DTL_HIKAZEI_CNT = "HIKAZEI_CNT";
/** 課税分(通話料金) */
private static final String DTL_KAZEI_PRC = "KAZEI_PRC";
/** 非課税分(通話料金) */
private static final String DTL_HIKAZEI_PRC = "HIKAZEI_PRC";
/** 再計算対象請求先番号 */
private String reCalSiky = null;
/** 退避．課税分通話秒数合計 */
private BigDecimal tmpKazeibunPcallSecCntGk = BigDecimal.ZERO;
/** 退避．免税分通話秒数合計 */
private BigDecimal tmpMenZeibunPcallSecCntGk = BigDecimal.ZERO;
/** 退避．課税分通話数合計 */
private BigDecimal tmpKazeibunPcallCntGk = BigDecimal.ZERO;
/** 退避．免税分通話数合計 */
private BigDecimal tmpMenZeibunPcallCntGk = BigDecimal.ZERO;
/** 退避．課税分料金合計 */
private BigDecimal tmpKazeibunPrcGk = BigDecimal.ZERO;
/** 退避．免税分料金合計 */
private BigDecimal tmpMenZeibunPrcGk = BigDecimal.ZERO;
/** 退避．消費税相当額 */
private BigDecimal tmpStaxEqvltAmnt = BigDecimal.ZERO;
/** 退避．キー項目 */
private String tmpBefSaveKey = null;
/** 入力．キー項目 */
private String tmpInSaveKey = null;
/** 退避．ｅｏ−ｎｅｔフォン通話明細マップ情報 */
private JBSbatServiceInterfaceMap tmpDbMap = null;
/** 料金業務共通クラスインスタンス */
private JACbatRknBusinessUtil rknBusinessUtil = null;
/** 税計算識別コード管理クラス */
private JACTaxCalcShikibetuCodeUtil jACTaxCalcShikibetuCodeUtil = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_AC_T_EONET_TW_GK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_EONET_TW_GK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
JACbatParamUtil paramUtil = new JACbatParamUtil(super.commonItem);
// 再計算対象請求先番号の取得
this.reCalSiky = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_TWK_RE_SHUK_NO1);
paramUtil.close();
// 料金業務共通クラスインスタンス生成
this.rknBusinessUtil = new JACbatRknBusinessUtil(commonItem);
// 税計算識別コード管理クラスのインスタンス生成
this.jACTaxCalcShikibetuCodeUtil = new JACTaxCalcShikibetuCodeUtil(JACStrConst.CALLER_BATCH, commonItem.getConnection());
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap, JBSbatOutputItem outputInItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
// 退避情報なしの場合
if(!outputInItem.isOutMapList())
{
// ダミーを設定
outputInItem.addOutMapList(new JBSbatServiceInterfaceMap());
}
// 最終レコードの場合
if(null == inMap)
{
// ｅｏ−ｎｅｔフォン通話合計の登録を行う
this.createEoNetTwGk(this.tmpDbMap);
// 集計項目クリア
this.initTmpInfo();
this.tmpBefSaveKey = null;
return outputInItem;
}
// 入力．キー項目設定（サービス契約番号＋オプションサービス契約番号＋料金コースコード＋料金サービスコード＋請求先番号＋課金先電話番号）
this.tmpInSaveKey = makeStr(inMap.getString(JBSbatAC_T_EONET_TW_DTL.SVC_KEI_NO), inMap.getString(JBSbatAC_T_EONET_TW_DTL.OP_SVC_KEI_NO),
inMap.getString(JBSbatAC_T_EONET_TW_DTL.PCRS_CD), inMap.getString(JBSbatAC_T_EONET_TW_DTL.PRC_SVC_CD),
inMap.getString(JBSbatAC_T_EONET_TW_DTL.SEIKY_KEI_NO), inMap.getString(JBSbatAC_T_EONET_TW_DTL.KAKINS_TELNO),
inMap.getString(JBSbatAC_T_EONET_TW_DTL.SEIKY_YM));
// 退避．キー項目 ≠ null（初回以外）、かつ 退避．キー項目 ≠ 入力．キー項目 の場合
if(this.tmpBefSaveKey != null && !this.tmpInSaveKey.equals(this.tmpBefSaveKey))
{
// ｅｏ−ｎｅｔフォン通話合計の登録を行う
this.createEoNetTwGk(this.tmpDbMap);
// 集計項目クリア
this.initTmpInfo();
}
if(this.tmpBefSaveKey == null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][初回削除][reCalSiky=" + this.reCalSiky + "]");
// ｅｏ−ｎｅｔフォン通話合計の削除
executeAC_T_EONET_TW_GK_AC_DELETE_001(new Object[] {this.reCalSiky});
}
// 退避．課税分通話秒数合計 ← 退避．課税分通話秒数合計 ＋ ｅｏ−ｎｅｔフォン通話明細．課税分(通話秒数)
this.tmpKazeibunPcallSecCntGk = this.tmpKazeibunPcallSecCntGk.add(inMap.getBigDecimal(DTL_KAZEI_SEC_CNT));
// 退避．免税分通話秒数合計 ← 退避．免税分通話秒数合計 ＋ ｅｏ−ｎｅｔフォン通話明細．免税分(通話秒数)
this.tmpMenZeibunPcallSecCntGk = this.tmpMenZeibunPcallSecCntGk.add(inMap.getBigDecimal(DTL_HIKAZEI_SEC_CNT));
// 退避．課税分通話数合計 ← 退避．課税分通話数合計 ＋ ｅｏ−ｎｅｔフォン通話明細．課税分（レコード数）
this.tmpKazeibunPcallCntGk = this.tmpKazeibunPcallCntGk.add(inMap.getBigDecimal(DTL_KAZEI_CNT));
// 退避．免税分通話数合計 ← 退避．免税分通話数合計 ＋ ｅｏ−ｎｅｔフォン通話明細．免税分（レコード数）
this.tmpMenZeibunPcallCntGk = this.tmpMenZeibunPcallCntGk.add(inMap.getBigDecimal(DTL_HIKAZEI_CNT));
// 退避．課税分料金合計 ← 退避．課税分料金合計 ＋ ｅｏ−ｎｅｔフォン通話明細．課税分(通話料金)
this.tmpKazeibunPrcGk = this.tmpKazeibunPrcGk.add(inMap.getBigDecimal(DTL_KAZEI_PRC));
// 退避．免税分料金合計 ← 退避．免税分料金合計 ＋ ｅｏ−ｎｅｔフォン通話明細．免税分(通話料金)
this.tmpMenZeibunPrcGk = this.tmpMenZeibunPrcGk.add(inMap.getBigDecimal(DTL_HIKAZEI_PRC));
// eo光電話通話明細．課税分合計（レコード数） > 0の場合
if(inMap.getBigDecimal(DTL_KAZEI_CNT).compareTo(BigDecimal.ZERO) > 0)
{
// 消費税相当額計算
String taxRateCd = inMap.getString(JBSbatAC_T_EONET_TW_DTL.PRC_KMK_CD).substring(0, 1); // 料金項目コードの上一桁
String taxSkbtCd = this.jACTaxCalcShikibetuCodeUtil.getTaxSkbtCd(taxRateCd, JACStrConst.UZEI_SZEI_SKBT_UCHI, super.opeDate);
BigDecimal[] tax = this.rknBusinessUtil.calcTaxCharge(taxSkbtCd, inMap.getBigDecimal(DTL_KAZEI_PRC), inMap.getString(JBSbatAC_T_EONET_TW_DTL.PCALL_ENDYMD));
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "料金（消費税額）(" + tax[0] + ") 税率(" + tax[1] + ")");
// 退避．消費税相当額 ← 退避．消費税相当額 ＋ 戻り値（税額）
this.tmpStaxEqvltAmnt = this.tmpStaxEqvltAmnt.add(tax[0]); // 退避．消費税相当額
}
// 退避情報の更新
this.tmpBefSaveKey = this.tmpInSaveKey;
this.tmpDbMap = inMap;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
// 処理終了
return outputInItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_T_EONET_TW_GK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AC_DELETE_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 対象キーワーク使用機能コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_EONET_TW_GK_AC_DELETE_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_AC_T_EONET_TW_GK.executeBySqlDefine(paramList, AC_T_EONET_TW_GK_AC_DELETE_001);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * サービス契約番号 SVC_KEI_NO * オプションサービス契約番号 OP_SVC_KEI_NO * 料金コースコード PCRS_CD * 料金サービスコード PRC_SVC_CD * 請求年月 SEIKY_YM * 課金先電話番号 KAKINS_TELNO * 請求契約番号 SEIKY_KEI_NO * 通話秒数合計 PCALL_SEC_CNT_GK * 通話数合計 PCALL_CNT_GK * 課税分通話数合計 KAZEIBUN_PCALL_CNT_GK * 免税分通話数合計 MENZEIBUN_PCALL_CNT_GK * 課税分料金合計 KAZEIBUN_PRC_GK * 免税分料金合計 MENZEIBUN_PRC_GK * 消費税相当額 STAX_EQVLT_AMNT * 通話料金合計 PCALL_PRC_GK * 登録年月日時分秒 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 executeAC_T_EONET_TW_GK_PKINSERT(Object[] setParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("SVC_KEI_NO", setParam[0]); setMap.setValue("OP_SVC_KEI_NO", setParam[1]); setMap.setValue("PCRS_CD", setParam[2]); setMap.setValue("PRC_SVC_CD", setParam[3]); setMap.setValue("SEIKY_YM", setParam[4]); setMap.setValue("KAKINS_TELNO", setParam[5]); setMap.setValue("SEIKY_KEI_NO", setParam[6]); setMap.setValue("PCALL_SEC_CNT_GK", setParam[7]); setMap.setValue("PCALL_CNT_GK", setParam[8]); setMap.setValue("KAZEIBUN_PCALL_CNT_GK", setParam[9]); setMap.setValue("MENZEIBUN_PCALL_CNT_GK", setParam[10]); setMap.setValue("KAZEIBUN_PRC_GK", setParam[11]); setMap.setValue("MENZEIBUN_PRC_GK", setParam[12]); setMap.setValue("STAX_EQVLT_AMNT", setParam[13]); setMap.setValue("PCALL_PRC_GK", setParam[14]); setMap.setValue("ADD_DTM", setParam[15]); setMap.setValue("ADD_OPEACNT", setParam[16]); setMap.setValue("UPD_DTM", setParam[17]); setMap.setValue("UPD_OPEACNT", setParam[18]); setMap.setValue("DEL_DTM", setParam[19]); setMap.setValue("DEL_OPEACNT", setParam[20]); setMap.setValue("MK_FLG", setParam[21]); setMap.setValue("ADD_UNYO_YMD", setParam[22]); setMap.setValue("ADD_TRN_ID", setParam[23]); setMap.setValue("UPD_UNYO_YMD", setParam[24]); setMap.setValue("UPD_TRN_ID", setParam[25]); setMap.setValue("DEL_UNYO_YMD", setParam[26]); setMap.setValue("DEL_TRN_ID", setParam[27]); // DBアクセスを実行します db_AC_T_EONET_TW_GK.insertByPrimaryKeys(setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * 文字を連結します * @param string 文字 * @return strBuf 連結した文字列 */ private String makeStr(String ...string) { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeStr]"); StringBuffer strBuf = new StringBuffer(); for(String str:string) { strBuf.append(str); } assert strBuf != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeStr][strBuf = " + strBuf.toString() + "]") : true; assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeStr]"); return strBuf.toString(); } /** * 退避項目初期化を行います。 */ private void initTmpInfo() { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initTmpInfo]"); this.tmpKazeibunPcallSecCntGk = BigDecimal.ZERO; // 退避．課税分通話秒数合計 this.tmpMenZeibunPcallSecCntGk = BigDecimal.ZERO; // 退避．免税分通話秒数合計 this.tmpKazeibunPcallCntGk = BigDecimal.ZERO; // 退避．課税分通話数合計 this.tmpMenZeibunPcallCntGk = BigDecimal.ZERO; // 退避．免税分通話数合計 this.tmpKazeibunPrcGk = BigDecimal.ZERO; // 退避．課税分料金合計 this.tmpMenZeibunPrcGk = BigDecimal.ZERO; // 退避．免税分料金合計 this.tmpStaxEqvltAmnt = BigDecimal.ZERO; // 退避．消費税相当額 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initTmpInfo]"); } /** *ｅｏ−ｎｅｔフォン通話合計の登録を行います。 * @param record ｅｏ−ｎｅｔフォン通話明細情報 * @param seikyYm 請求年月 * @throws Exception */ private void createEoNetTwGk(JBSbatServiceInterfaceMap record) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][createEohTelTwGk]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][createEohTelTwGk][record=" + record.getMap().toString() + "]"); // 通話秒数合計（退避．課税分通話秒数合計＋退避．免税分通話秒数合計）を算出 BigDecimal secCntGk = BigDecimal.ZERO; secCntGk = secCntGk.add(this.tmpKazeibunPcallSecCntGk); secCntGk = secCntGk.add(this.tmpMenZeibunPcallSecCntGk); // 通話数合計（退避．課税分通話数合計＋退避．免税分通話数合計）を算出 BigDecimal cntGk = BigDecimal.ZERO; cntGk = cntGk.add(this.tmpKazeibunPcallCntGk); cntGk = cntGk.add(this.tmpMenZeibunPcallCntGk); // 合計通話料金（退避．課税分料金合計＋退避．免税分料金合計）を算出 BigDecimal prcGk = BigDecimal.ZERO; prcGk = prcGk.add(this.tmpKazeibunPrcGk); prcGk = prcGk.add(this.tmpMenZeibunPrcGk); // ｅｏ−ｎｅｔフォン通話合計テーブルへ登録 Object[] setParam = new Object[30]; setParam[0] = record.getString(JBSbatAC_T_EONET_TW_DTL.SVC_KEI_NO); // サービス契約番号 setParam[1] = record.getString(JBSbatAC_T_EONET_TW_DTL.OP_SVC_KEI_NO); // オプションサービス契約番号 setParam[2] = record.getString(JBSbatAC_T_EONET_TW_DTL.PCRS_CD); // 料金コースコード setParam[3] = record.getString(JBSbatAC_T_EONET_TW_DTL.PRC_SVC_CD); // 料金サービスコード setParam[4] = record.getString(JBSbatAC_T_EONET_TW_DTL.SEIKY_YM); // 請求年月 setParam[5] = record.getString(JBSbatAC_T_EONET_TW_DTL.KAKINS_TELNO); // 課金先電話番号 setParam[6] = record.getString(JBSbatAC_T_EONET_TW_DTL.SEIKY_KEI_NO); // 請求契約番号 setParam[7] = secCntGk; // 通話秒数合計 setParam[8] = cntGk; // 通話数合計 setParam[9] = this.tmpKazeibunPcallCntGk; // 課税分通話数合計 setParam[10] = this.tmpMenZeibunPcallCntGk; // 免税分通話数合計 setParam[11] = this.tmpKazeibunPrcGk; // 課税分料金合計 setParam[12] = this.tmpMenZeibunPrcGk; // 免税分料金合計 setParam[13] = this.tmpStaxEqvltAmnt; // 消費税相当額 setParam[14] = prcGk; // 通話料金合計 executeAC_T_EONET_TW_GK_PKINSERT(setParam); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][createEohTelTwGk]"); return; } }