*
* @author 富士通
*/
public class JBSbatAKFtthTushinryoChshu extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(ＦＴＴＨ通信合計)*/
private static final String D_TBL_NAME_AC_T_FTTH_TUSHIN_GK = "AC_T_FTTH_TUSHIN_GK";
/** テーブル(料金項目抽出変換)*/
private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";
/** SQL定義キー(AK_SELECT_001)*/
private static final String AC_T_FTTH_TUSHIN_GK_AK_SELECT_001 = "AK_SELECT_001";
/** SQL定義キー(AK_SELECT_001)*/
private static final String CH_M_PRC_KMK_CS_CHGE_AK_SELECT_001 = "AK_SELECT_001";
/** テーブルアクセスクラス(ＦＴＴＨ通信合計)*/
private JBSbatSQLAccess db_AC_T_FTTH_TUSHIN_GK = null;
/** テーブルアクセスクラス(料金項目抽出変換)*/
private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 退避．請求年月 */
private String tmpSeikyYm = null;
/** 退避．ＦＴＴＨ通信量下限値取得用 */
private String tmpFtthJuryo = null;
/** 退避．料金項目コード */
private String tmpPrcKmkCd = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_AC_T_FTTH_TUSHIN_GK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_FTTH_TUSHIN_GK);
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, "[L][initial][opeDate=" + super.opeDate + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
// 請求年月を取得する。
this.getSchdlInfo();
// 業務パラメータを取得する。
this.getWorkPara();
// 料金項目コードを取得する。
this.getPrcKmkCd();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
assert inMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][inMap=" + inMap.getMap().toString() + "]") : true;
// 出力共通電文
JBSbatOutputItem outputItem = new JBSbatOutputItem();
// ＦＴＴＨ通信量合計の取得
this.selectAcTFtthTushinGk(inMap);
// 結果取得
JBSbatCommonDBInterface dbMap = db_AC_T_FTTH_TUSHIN_GK.selectNext();
if(dbMap == null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute][取得件数が０件]");
// 取得件数が０件の場合、次レコードへ
return outputItem;
}
while (dbMap != null)
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][取得件数が有件]");
// ＦＴＴＨ通信量情報の出力
this.makeOutputInfo(inMap, dbMap, outputItem);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][dbMap=" + dbMap.getMap().toString() + "]");
// 次レコードの取得
dbMap = db_AC_T_FTTH_TUSHIN_GK.selectNext();
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return outputItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_T_FTTH_TUSHIN_GK.close();
db_CH_M_PRC_KMK_CS_CHGE.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 料金スケジュール定義アクセス部品を使用してスケジュール情報を取得する。
* @throws Exception 業務サービス内で発生した例外全般
*/
private void getSchdlInfo() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getSchdlInfo]");
JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);
try
{
// 請求年月
this.tmpSeikyYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_PRC_CALC_DAY);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getSchdlInfo][請求年月=" + this.tmpSeikyYm + "]");
}
finally
{
schdlUtil.close();
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getSchdlInfo]");
return;
}
/**
* 業務パラメータ管理から値を取得します。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void getWorkPara() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getWorkPara]");
// 業務パラメータ取得
JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
try
{
// ＦＴＴＨ通信量下限値取得用
this.tmpFtthJuryo = paramUtil.getGyoumuParameter(JACStrConst.WKPAR_AK_WKS_FTTHJURYO);
}
finally
{
paramUtil.close();
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getWorkPara][ＦＴＴＨ通信量下限値取得用 = " + this.tmpFtthJuryo + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getWorkPara]");
return;
}
/**
* 料金項目抽出変換スキーマより料金項目コードを取得します。
* @throws Exception 業務サービス内で発生した例外全般
*/
private void getPrcKmkCd() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getPrcKmkCd]");
// 設定値
JBSbatCommonDBInterface setParam = new JBSbatCommonDBInterface();
// システムコード
setParam.setValue(super.systemCode);
// 業務機能識別コード
setParam.setValue(this.tmpFtthJuryo);
// 抽出変換コード
setParam.setValue(JACStrConst.CHSHT_CHG_CD_CST);
// 料金項目抽出変換適用開始年月日
setParam.setValue(super.opeDate);
// 料金項目抽出変換適用終了年月日
setParam.setValue(super.opeDate);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCd][paramList=" + setParam.getList().toString() + "]");
// 料金項目抽出変換スキーマ検索処理実行
executeCH_M_PRC_KMK_CS_CHGE_AK_SELECT_001(setParam.getList().toArray());
// 結果取得
JBSbatCommonDBInterface rec = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
if (null != rec)
{
// 検索結果が存在する場合
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCd][取得件数が有件]");
// 料金項目コードを取得値を設定する
this.tmpPrcKmkCd = rec.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD);
}
else
{
// 検索結果が存在しない場合
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCd][取得件数が無件]");
String[] outCntMsg = {JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME, setParam.getList().toString()};
// DB異常のメッセージ（【警告】ＤＢ未存在エラー）をLOGに出力する。
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EAKB0180CW, outCntMsg);
// 料金項目コードに空文字を設定する
this.tmpPrcKmkCd = JACStrConst.KARA_MOJI;
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCd][料金項目コード=" + this.tmpPrcKmkCd + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getPrcKmkCd]");
return;
}
/**
* ＦＴＴＨ通信合計スキーマの取得を行います。
*
* @param inMap 入力電文
* @throws Exception 業務サービス内で発生した例外全般
*/
private void selectAcTFtthTushinGk(JBSbatServiceInterfaceMap inMap) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectAcTFtthTushinGk]");
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// 請求契約番号
paramList.setValue(inMap.getString(JBSbatAKIFM001.SEIKY_KEI_NO));
// 請求年月
paramList.setValue(this.tmpSeikyYm);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectAcTFtthTushinGk][paramList=" + paramList.getList().toString() + "]");
// SQL実行
executeAC_T_FTTH_TUSHIN_GK_AK_SELECT_001(paramList.getList().toArray());
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectAcTFtthTushinGk]");
}
/**
* ＦＴＴＨ通信量情報作成処理を行います。
*
* @param inMap 入力電文
* @param dbMap ＦＴＴＨ通信量合計スキーマ情報
* @param outputInItem 出力情報
* @throws Exception
*/
private void makeOutputInfo(JBSbatServiceInterfaceMap inMap, JBSbatCommonDBInterface dbMap, JBSbatOutputItem outputInItem) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutputInfo]");
// ＦＴＴＨ通信量情報
JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
// 請求契約番号
outMap.set(JBSbatAKIFM016.SEIKY_KEI_NO, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.SEIKY_KEI_NO));
// 請求年月
outMap.set(JBSbatAKIFM016.SEIKY_YM, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.SEIKY_YM));
// サービス契約番号
outMap.set(JBSbatAKIFM016.SVC_KEI_NO, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.SVC_KEI_NO));
// 料金グループコード
outMap.set(JBSbatAKIFM016.PRC_GRP_CD, JACStrConst.KARA_MOJI);
// 料金コースコード
outMap.set(JBSbatAKIFM016.PCRS_CD, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.PCRS_CD));
// 料金サービスコード
outMap.set(JBSbatAKIFM016.PRC_SVC_CD, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.PRC_SVC_CD));
// 料金項目コード
outMap.set(JBSbatAKIFM016.PRC_KMK_CD, this.tmpPrcKmkCd);
// 利用通信量合計
outMap.set(JBSbatAKIFM016.USE_TSRYO_GK, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.USE_TSRYO_GK));
// 補正通信量合計
outMap.set(JBSbatAKIFM016.HOSEI_TSRYO_GK, dbMap.getString(JBSbatAC_T_FTTH_TUSHIN_GK.HOSEI_TSRYO_GK));
outMap.setOutFlg(true);
// 出力処理
outputInItem.addOutMapList(outMap);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeOutputInfo][outputItem = " + outMap.getMap().toString() + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutputInfo]");
return;
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AK_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 請求年月 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_FTTH_TUSHIN_GK_AK_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_AC_T_FTTH_TUSHIN_GK.selectBySqlDefine(paramList, AC_T_FTTH_TUSHIN_GK_AK_SELECT_001);
}
/**
* SQLKEY(AK_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * システムコード * 業務機能識別コード * 抽出変換コード * 料金項目抽出変換適用開始年月日 * 料金項目抽出変換適用終了年月日 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_M_PRC_KMK_CS_CHGE_AK_SELECT_001(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_AK_SELECT_001); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }