*
* @author 富士通
*/
public class JBSbatACMdgcSksHakCommiAdd extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(定額料金)*/
private static final String D_TBL_NAME_AC_M_TEGAK_PRC = "AC_M_TEGAK_PRC";
/** テーブル(料金項目抽出変換)*/
private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";
/** テーブル(請求)*/
private static final String D_TBL_NAME_CH_T_SEIKY = "CH_T_SEIKY";
/** テーブル(請求契約)*/
private static final String D_TBL_NAME_KK_T_SEIKY_KEI = "KK_T_SEIKY_KEI";
/** テーブル(料金スケジュール定義)*/
private static final String D_TBL_NAME_CH_M_PRC_SCHDL_TEIGI = "CH_M_PRC_SCHDL_TEIGI";
/** SQL定義キー(AC_SELECT_002)*/
private static final String AC_M_TEGAK_PRC_AC_SELECT_002 = "AC_SELECT_002";
/** SQL定義キー(AC_SELECT_007)*/
private static final String CH_M_PRC_KMK_CS_CHGE_AC_SELECT_007 = "AC_SELECT_007";
/** SQL定義キー(AC_SELECT_004)*/
private static final String CH_T_SEIKY_AC_SELECT_004 = "AC_SELECT_004";
/** SQL定義キー(AC_SELECT_003)*/
private static final String KK_T_SEIKY_KEI_AC_SELECT_003 = "AC_SELECT_003";
/** SQL定義キー(AC_SELECT_002)*/
private static final String CH_M_PRC_SCHDL_TEIGI_AC_SELECT_002 = "AC_SELECT_002";
/** テーブルアクセスクラス(定額料金)*/
private JBSbatSQLAccess db_AC_M_TEGAK_PRC = null;
/** テーブルアクセスクラス(料金項目抽出変換)*/
private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null;
/** テーブルアクセスクラス(請求)*/
private JBSbatSQLAccess db_CH_T_SEIKY = null;
/** テーブルアクセスクラス(請求契約)*/
private JBSbatSQLAccess db_KK_T_SEIKY_KEI = null;
/** テーブルアクセスクラス(料金スケジュール定義)*/
private JBSbatSQLAccess db_CH_M_PRC_SCHDL_TEIGI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 請求年月 （利用開始日／利用終了日基準）*/
private String seikyYm = null;
/** 翌請求年月 */
private String wkNextSeikyYm = null;
/** 料金項目抽出変換 */
JBSbatCommonDBInterface csChgeMap = null;
/** 定額料金取得結果 */
JBSbatCommonDBInterface tegakuMap = null;
/** ファイル出力件数 */
private int outPutCnt = 0;
/** ファイル出力部品 */
JBSbatOutputFileUtil fileUtil = null;
/** 出力定義ファイルオブジェクト */
JBSbatDefFileUtil outFileDef = null;
/** 請求書発行手数料課金サービス */
String[] wkParaSvc = null;
/** 請求書発行手数料非課金料金グループ */
String[] wkParaPrgp = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_AC_M_TEGAK_PRC = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_M_TEGAK_PRC);
db_CH_M_PRC_KMK_CS_CHGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE);
db_CH_T_SEIKY = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_SEIKY);
db_KK_T_SEIKY_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SEIKY_KEI);
db_CH_M_PRC_SCHDL_TEIGI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_SCHDL_TEIGI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
// パラメータ取得クラス生成
JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
// 業務パラメータ情報を取得する
String wKinoSkbt = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_WKS_SEIKY_HAK_CMS); // 請求書発行手数料登録
this.wkParaSvc = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_KK_SKSHAK_CHRG_SVC).split(JACStrConst.COMMA); // 請求書発行手数料課金サービス
this.wkParaPrgp = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_KK_SKSHAK_HCHRG_PRGP).split(JACStrConst.COMMA); // 請求書発行手数料非課金料金グループ
// パラメータ取得クラスクローズ
paramUtil.close();
// スケジュール定義アクセスクラス生成
JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);
// 利用開始日と利用終了に対応する請求年月を取得する
seikyYm = getSeikyYm(super.opeDate);
// 料金スケジュール定義．請求年月
String wSeikyYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_SEIKY_SHORI_YMD);
wkNextSeikyYm = JPCUtilCommon.addMonth(wSeikyYm.concat(JACStrConst.STR_OF_MONTH), 1).substring(0, 6);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "翌請求年月：" + wkNextSeikyYm);
// スケジュール定義アクセスクラスクローズ
schdlUtil.close();
// 料金情報取得
this.getPrcInfo(wKinoSkbt);
// 定額料金取得
this.getTegakuPrc();
// ファイル出力部品を取得
this.fileUtil = super.commonItem.getOutPutFile();
// 設定されているエンコード形式を退避
String enc = fileUtil.getEncode();
// encodeの形式がSHIFT-JISの場合、MS932に変換
if (JACStrConst.ENCODE_SJIS.toUpperCase().equals(enc.toUpperCase()))
{
enc = JACStrConst.ENCODE_MS932;
}
// 出力定義ファイル名を取得する。
String outFileDefName = JBSbatAplConst.getAplConstValue("OTD") + super.freeItem;
// 出力定義ファイルオブジェクトを生成する
this.outFileDef = new JBSbatDefFileUtil(outFileDefName, fileUtil);
// 退避したエンコード形式を戻す（出力定義ファイルオブジェクト生成時に上書きが発生しているため）
fileUtil.setEncode(enc);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
// 請求スキーマより請求先番号抽出
this.getSeiky();
// 請求先番号取得結果
JBSbatCommonDBInterface seikyRec = db_CH_T_SEIKY.selectNext();
while(seikyRec != null)
{
// 発行手数料無料期間判定処理
// 無料期間判定要素（請求契約.初回請求年月、サービス契約.サービス課金開始年月日）を取得する
this.getSeikyKei(seikyRec);
// 取得結果
JBSbatCommonDBInterface jdgRec = db_KK_T_SEIKY_KEI.selectNext();
// 無料期間かどうかの判定を行う(true:発行手数料無料期間)
if(this.isHakCmTrgtJdg(jdgRec))
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute][発行手数料徴収対象外]");
// 強制窓口請求書発行手数料情報を出力せずし次のレコードを読み込む
seikyRec = db_CH_T_SEIKY.selectNext();
continue;
}
// 出力項目設定
JBSbatServiceInterfaceMap outList = setOutList(seikyRec);
// ファイル出力
finalOut(outList);
seikyRec = db_CH_T_SEIKY.selectNext();
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_M_TEGAK_PRC.close();
db_CH_M_PRC_KMK_CS_CHGE.close();
db_CH_T_SEIKY.close();
db_KK_T_SEIKY_KEI.close();
db_CH_M_PRC_SCHDL_TEIGI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
String[] outCntMsg = {"主処理", String.valueOf(outPutCnt)};
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EACB0560AI, outCntMsg);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AC_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * システムコード * 料金コースコード * 料金サービスコード * 料金項目コード * バッチ運用日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_M_TEGAK_PRC_AC_SELECT_002(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_AC_M_TEGAK_PRC.selectBySqlDefine(paramList, AC_M_TEGAK_PRC_AC_SELECT_002);
}
/**
* SQLKEY(AC_SELECT_007)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * システムコード * 業務機能識別コード * 抽出変換コード * バッチ運用日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_PRC_KMK_CS_CHGE_AC_SELECT_007(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());
// DBアクセスを実行します
db_CH_M_PRC_KMK_CS_CHGE.selectBySqlDefine(paramList, CH_M_PRC_KMK_CS_CHGE_AC_SELECT_007);
}
/**
* SQLKEY(AC_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * イベントコード * イベント年月日 * 請求契約．予約適用年月日 * サービス契約．予約適用年月日 * サービス契約．サービスコード * サービス契約．料金グループコード * 課金先．課金先適用開始年月日 * 課金先．課金先適用終了年月日 * 請求方法コード * 請求書発行要否 * 請求種別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_T_SEIKY_AC_SELECT_004(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
for (int i = 0; i < param.length; i++ )
{
paramList.setValue(param[i].toString());
}
// DBアクセスを実行します
db_CH_T_SEIKY.selectBySqlDefine(paramList, CH_T_SEIKY_AC_SELECT_004);
}
/**
* SQLKEY(AC_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 予約適用年月日 * 請求契約番号 * 予約適用年月日 * サービス契約．サービスコード * サービス契約．料金グループコード * 予約適用年月日 * 予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SEIKY_KEI_AC_SELECT_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
for (int i = 0; i < param.length; i++ )
{
paramList.setValue(param[i].toString());
}
// DBアクセスを実行します
db_KK_T_SEIKY_KEI.selectBySqlDefine(paramList, KK_T_SEIKY_KEI_AC_SELECT_003);
}
/**
* SQLKEY(AC_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * イベント日付（利用開始日） * イベント日付（利用終了日） *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_PRC_SCHDL_TEIGI_AC_SELECT_002(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_002);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 請求年月を取得する
*
* @param ymd 年月日
* @return 請求年月
* @throws Exception
*/
private String getSeikyYm(String ymd) throws Exception
{
executeCH_M_PRC_SCHDL_TEIGI_AC_SELECT_002(new String[] {ymd, ymd});
JBSbatCommonDBInterface record = db_CH_M_PRC_SCHDL_TEIGI.selectNext();
if (record != null)
{
// レコードが存在する場合
return record.getString(JBSbatCH_M_PRC_SCHDL_TEIGI.SEIKY_YM);
}
else
{
// レコードが存在しない場合
// 業務例外
throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0440CE, new String[] {JBSbatCH_M_PRC_SCHDL_TEIGI.TABLE_NAME});
}
}
/**
* 料金情報取得を取得します。
* @param wKinoSkbt 業務機能識別コード
* @throws Exception
*/
private void getPrcInfo(String wKinoSkbt) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getPrcInfo]");
// ＤＢアクセス用のパラメータ定義
JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();
// 対象キーの設定
dbList.setValue(super.systemCode); // システムコード
dbList.setValue(wKinoSkbt); // 業務機能識別コード
dbList.setValue(JACStrConst.CHSHT_CHG_CD_CST); // 抽出変換コード（抽出のみ）
dbList.setValue(super.opeDate); // バッチ運用日
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcInfo]dbList：" + dbList.getList().toString());
// 料金情報取得
executeCH_M_PRC_KMK_CS_CHGE_AC_SELECT_007(dbList.getList().toArray());
// 料金情報取得結果
csChgeMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
if(csChgeMap == null)
{
String[] msgParam = new String[]{JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME, wKinoSkbt};
throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0250CE, msgParam);
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getPrcInfo]");
}
/**
* 定額料金データを取得します。
* @throws Exception
*/
private void getTegakuPrc() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getTegakuPrc]");
// ＤＢアクセス用のパラメータ定義
JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();
// 対象キーの設定
dbList.setValue(super.systemCode); // システムコード
dbList.setValue(csChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PCRS_CD)); // 料金コースコード
dbList.setValue(csChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_SVC_CD)); // 料金サービスコード
dbList.setValue(csChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD)); // 料金項目コード
dbList.setValue(super.opeDate); // バッチ運用日
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getTegakuPrc]dbList：" + dbList.getList().toString());
// 定額料金データ取得
executeAC_M_TEGAK_PRC_AC_SELECT_002(dbList.getList().toArray());
// 定額料金取得結果
this.tegakuMap = db_AC_M_TEGAK_PRC.selectNext();
if(this.tegakuMap == null)
{
String[] msgParam = new String[]{JBSbatAC_M_TEGAK_PRC.TABLE_NAME, JPCUtilCommon.convMapToString(csChgeMap.getMap())};
throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0250CE, msgParam);
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getTegakuPrc]");
}
/**
* 出力対象の請求先番号を取得します。
* @throws Exception
*/
private void getSeiky() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getSeiky]");
// SQL定義キーを指定してSQL文を取得
String sqlBf = db_CH_T_SEIKY.getSql(CH_T_SEIKY_AC_SELECT_004);
// 加工対象の文字列
String ckn1Bf = "KK0081.SVC_CD IN(?)";
String ckn2Bf = "KK0081.PRC_GRP_CD NOT IN(?)";
String para = "?";
// IN句の対象数を変更（SVC_CD）
StringBuffer paraAf = new StringBuffer();
for(int i = 0; this.wkParaSvc.length > i; i++)
{
if(i > 0)
{
paraAf.append(JACStrConst.COMMA);
}
paraAf.append(para);
}
String ckn1Af = ckn1Bf.replace(para, paraAf.toString());
// IN句の対象数を変更（PRC_GRP_CD）
paraAf = new StringBuffer();
for(int i = 0; wkParaPrgp.length > i; i++)
{
if(i > 0)
{
paraAf.append(JACStrConst.COMMA);
}
paraAf.append(para);
}
String ckn2Af = ckn2Bf.replace(para, paraAf.toString());
// SQLを置き換える
HashMap