*
* @author 富士通
*/
public class JBSbatACTsryoHoseiInfoAddGokei extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(ＦＴＴＨ通信合計)*/
private static final String D_TBL_NAME_AC_T_FTTH_TUSHIN_GK = "AC_T_FTTH_TUSHIN_GK";
/** テーブルアクセスクラス(ＦＴＴＨ通信合計)*/
private JBSbatSQLAccess db_AC_T_FTTH_TUSHIN_GK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 割り算用：1000 */
private static final BigDecimal THOUSAND = new BigDecimal("1000");
/** 変換補正通信量合計 */
private BigDecimal chHoseoTsnGk = null;
/** FTTH通信合計_更新フラグ */
private String ftthTsnUpdFlg = 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);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
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 + "]");
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;
// 入力情報≠nullの場合
if(inMap != null)
{
// 補正通信量合計変換
BigDecimal tushinryo = inMap.getBigDecimal(JBSbatAC_T_FTTH_TUSHIN_DTL.HOSEI_TSRYO);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][setTushin][tushinryo=" + tushinryo + "]");
this.chHoseoTsnGk = JACbatRknBusinessUtil.round(JACStrConst.ROUND_UP, tushinryo.divide(THOUSAND), 0);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][setTushin][tushinryo=" + chHoseoTsnGk + "]");
// FTTH通信合計更新
this.searchFtthTsnGK(inMap);
// FTTH通信合計_更新フラグ＝"1"(更新)の場合
if(this.ftthTsnUpdFlg.equals(JACStrConst.FTTH_TSN_GK_UPD))
{
// FTTH通信合計更新処理
updFtthTsnGK(inMap);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][FTTH通信合計_更新]");
}
// FTTH通信合計_更新フラグ＝"0"(追加)の場合
else
{
// FTTH通信合計追加処理
insertFtthTsnGK(inMap);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][FTTH通信合計_追加]");
}
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_T_FTTH_TUSHIN_GK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * SVC_KEI_NO * PCRS_CD * PRC_SVC_CD * USE_YM *
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeAC_T_FTTH_TUSHIN_GK_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("SVC_KEI_NO", whereParam[0]);
whereMap.setValue("PCRS_CD", whereParam[1]);
whereMap.setValue("PRC_SVC_CD", whereParam[2]);
whereMap.setValue("USE_YM", whereParam[3]);
// DBアクセスを実行します
return db_AC_T_FTTH_TUSHIN_GK.selectByPrimaryKeys(whereMap);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 補正通信量合計 HOSEI_TSRYO_GK * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * SVC_KEI_NO * PCRS_CD * PRC_SVC_CD * USE_YM *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_FTTH_TUSHIN_GK_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("HOSEI_TSRYO_GK", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("SVC_KEI_NO", whereParam[0]);
whereMap.setValue("PCRS_CD", whereParam[1]);
whereMap.setValue("PRC_SVC_CD", whereParam[2]);
whereMap.setValue("USE_YM", whereParam[3]);
// DBアクセスを実行します
db_AC_T_FTTH_TUSHIN_GK.updateByPrimaryKeys(whereMap, setMap);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * サービス契約番号 SVC_KEI_NO * 料金コースコード PCRS_CD * 料金サービスコード PRC_SVC_CD * 請求契約番号 SEIKY_KEI_NO * 請求年月 SEIKY_YM * 利用年月 USE_YM * 利用通信量合計 USE_TSRYO_GK * 補正通信量合計 HOSEI_TSRYO_GK * 超過通知コード CHOK_TCHI_CD * 登録年月日時分秒 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_FTTH_TUSHIN_GK_PKINSERT(Object[] setParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("SVC_KEI_NO", setParam[0]); setMap.setValue("PCRS_CD", setParam[1]); setMap.setValue("PRC_SVC_CD", setParam[2]); setMap.setValue("SEIKY_KEI_NO", setParam[3]); setMap.setValue("SEIKY_YM", setParam[4]); setMap.setValue("USE_YM", setParam[5]); setMap.setValue("USE_TSRYO_GK", setParam[6]); setMap.setValue("HOSEI_TSRYO_GK", setParam[7]); setMap.setValue("CHOK_TCHI_CD", setParam[8]); setMap.setValue("ADD_DTM", setParam[9]); setMap.setValue("ADD_OPEACNT", setParam[10]); setMap.setValue("UPD_DTM", setParam[11]); setMap.setValue("UPD_OPEACNT", setParam[12]); setMap.setValue("DEL_DTM", setParam[13]); setMap.setValue("DEL_OPEACNT", setParam[14]); setMap.setValue("MK_FLG", setParam[15]); setMap.setValue("ADD_UNYO_YMD", setParam[16]); setMap.setValue("ADD_TRN_ID", setParam[17]); setMap.setValue("UPD_UNYO_YMD", setParam[18]); setMap.setValue("UPD_TRN_ID", setParam[19]); setMap.setValue("DEL_UNYO_YMD", setParam[20]); setMap.setValue("DEL_TRN_ID", setParam[21]); // DBアクセスを実行します db_AC_T_FTTH_TUSHIN_GK.insertByPrimaryKeys(setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * FTTH通信合計検索 * @param inMap FTTH通信明細マップ * @throws Exception 業務サービス内で発生した例外全般。 */ private void searchFtthTsnGK(JBSbatServiceInterfaceMap inMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][searchFtthTsnGK]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.SVC_KEI_NO)); // サービス契約番号 paramList.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PCRS_CD)); // 料金コースコード paramList.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PRC_SVC_CD)); // 料金サービスコード paramList.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.USE_YM)); // 利用年月 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][searchFtthTsnGK][paramList=" + paramList.getList().toString() + "]"); // SQL実行 // 結果を取得 JBSbatCommonDBInterface dbMap = executeAC_T_FTTH_TUSHIN_GK_PKSELECT(paramList.getList().toArray()); // 取得結果≠nullの場合 if(dbMap != null) { // FTTH通信合計_更新フラグ："1"(更新) this.ftthTsnUpdFlg = JACStrConst.FTTH_TSN_GK_UPD; assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][searchFtthTsnGK][FTTH通信合計_更新フラグ=" + ftthTsnUpdFlg + "]"); } else { // FTTH通信合計_更新フラグ："0"(追加) this.ftthTsnUpdFlg = JACStrConst.FTTH_TSN_GK_IN; assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][searchFtthTsnGK][FTTH通信合計_更新フラグ=" + ftthTsnUpdFlg + "]"); } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][searchFtthTsnGK]"); } /** * FTTH通信合計更新処理 * @param tsnMeisaiMap 通信明細マップ * @throws Exception 業務サービス内で発生した例外全般。 */ private void updFtthTsnGK(JBSbatServiceInterfaceMap inMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][updateFtthTsnGK]"); // 設定項目 JBSbatCommonDBInterface setParam = new JBSbatCommonDBInterface(); // 設定条件 JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface(); setParam.setValue(this.chHoseoTsnGk); // 変換補正通信量合計 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][updateFtthTsnGK][setParam=" + setParam.getList().toString() + "]"); whereParam.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.SVC_KEI_NO)); // サービス契約番号 whereParam.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PCRS_CD)); // 料金コースコード whereParam.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PRC_SVC_CD)); // 料金サービスコード whereParam.setValue(inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.USE_YM)); // 利用年月 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][updateFtthTsnGK][whereParam=" + whereParam.getList().toString() + "]"); // FTTH通信合計更新 executeAC_T_FTTH_TUSHIN_GK_PKUPDATE(setParam.getList().toArray(), whereParam.getList().toArray()); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][updateFtthTsnGK]"); } /** * FTTH通信合計追加処理 * @param inMap 通信明細マップ * @throws Exception 業務サービス内で発生した例外全般。 */ private void insertFtthTsnGK(JBSbatServiceInterfaceMap inMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][insertFtthTsnGK]"); // 設定項目 Object[] setParam = new Object[25]; setParam[0] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.SVC_KEI_NO); // サービス契約番号 setParam[1] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PCRS_CD); // 料金コースコード setParam[2] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.PRC_SVC_CD); // 料金サービスコード setParam[3] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.SEIKY_KEI_NO); // 請求契約番号 setParam[4] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.SEIKY_YM); // 請求年月 setParam[5] = inMap.getString(JBSbatAC_T_FTTH_TUSHIN_DTL.USE_YM); // 利用年月 setParam[6] = 0; // 利用通信量合計 setParam[7] = this.chHoseoTsnGk; // 補正通信量合計 setParam[8] = JACStrConst.CHOK_TCHI_CD_MI; // 超過通知コード assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][insertFtthTsnGK][setParam=" + setParam + "]"); // FTTH通信合計追加 executeAC_T_FTTH_TUSHIN_GK_PKINSERT(setParam); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][insertFtthTsnGK]"); } }