*
* @author 富士通
*/
public class JBSbatACKaikSumupPrcGrpWr extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(料金集計先)*/
private static final String D_TBL_NAME_CH_M_PRC_SHUK_SK = "CH_M_PRC_SHUK_SK";
/** SQL定義キー(AC_SELECT_001)*/
private static final String CH_M_PRC_SHUK_SK_AC_SELECT_001 = "AC_SELECT_001";
/** SQL定義キー(AC_SELECT_002)*/
private static final String CH_M_PRC_SHUK_SK_AC_SELECT_002 = "AC_SELECT_002";
/** SQL定義キー(AC_SELECT_002)*/
private static final String CH_M_PRC_SHUK_SK_AC_SELECT_003 = "AC_SELECT_003";
// v47.00.00 ANK-3674 ADD START
/** SQL定義キー(AC_SELECT_004)*/
private static final String CH_M_PRC_SHUK_SK_AC_SELECT_004 = "AC_SELECT_004";
// v47.00.00 ANK-3674 ADD END
/** テーブルアクセスクラス(料金集計先)*/
private JBSbatSQLAccess db_CH_M_PRC_SHUK_SK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 利用開始終了日 */
private String[] UseStrEnd = null;
/* ++++++++++ v12.00.00 追加開始 ++++++++++ */
/** NHK受信料料金サービスコード（料金グループ置き換え対象） */
private static final String PRC_SVC_CD_NHK_JUSHIN = "PE0201 ";
/* ++++++++++ v12.00.00 追加完了 ++++++++++ */
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CH_M_PRC_SHUK_SK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_SHUK_SK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
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 + "]");
// 利用開始終了日を取得
JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);
// 会計処理日
String kaikTranYmd = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_KAIK_SHORI_YMD);
// 利用開始終了日
this.UseStrEnd = schdlUtil.getUseStrEnd(kaikTranYmd, JACStrConst.EVENT_CD_USE_STAYMD, JACStrConst.EVENT_CD_USE_ENDYMD);
schdlUtil.close();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][kaikTranYmd=" + kaikTranYmd + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][UseStr=" + UseStrEnd[0] + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][UseEnd=" + UseStrEnd[1] + "]");
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();
// 料金グループ取得
selectChMPrcShukSk(inMap);
// レコード出力判定フラグの設定
inMap.setOutFlg(true);
// 出力レコード情報を設定する
outputItem.addOutMapList(inMap);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][inMap=" + inMap.getMap().toString() + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return outputItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CH_M_PRC_SHUK_SK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AC_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 課金先適用開始年月日 * 課金先適用終了年月日 * サービス契約予約適用年月日 * サービス開始年月日 * サービス解約起算日 * 料金集計先適用開始年月日 * 料金集計先適用終了年月日 * 料金集計先予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_PRC_SHUK_SK_AC_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());
paramList.setValue(param[5].toString());
paramList.setValue(param[6].toString());
paramList.setValue(param[7].toString());
paramList.setValue(param[8].toString());
// DBアクセスを実行します
db_CH_M_PRC_SHUK_SK.selectBySqlDefine(paramList, CH_M_PRC_SHUK_SK_AC_SELECT_001);
}
/**
* SQLKEY(AC_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 課金先適用終了年月日 * 請求契約番号 * サービス契約予約適用年月日 * 料金集計先適用開始年月日 * 料金集計先適用終了年月日 * 料金集計先予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_PRC_SHUK_SK_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());
paramList.setValue(param[5].toString());
paramList.setValue(param[6].toString());
// DBアクセスを実行します
db_CH_M_PRC_SHUK_SK.selectBySqlDefine(paramList, CH_M_PRC_SHUK_SK_AC_SELECT_002);
}
/**
* SQLKEY(AC_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 課金先適用開始年月日 * 課金先適用終了年月日 * サービス契約予約適用年月日 * サービス開始年月日 * サービス解約起算日 * 料金集計先適用開始年月日 * 料金集計先適用終了年月日 * 料金集計先予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_PRC_SHUK_SK_AC_SELECT_003(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());
paramList.setValue(param[5].toString());
paramList.setValue(param[6].toString());
paramList.setValue(param[7].toString());
paramList.setValue(param[8].toString());
// DBアクセスを実行します
db_CH_M_PRC_SHUK_SK.selectBySqlDefine(paramList, CH_M_PRC_SHUK_SK_AC_SELECT_003);
}
// v47.00.00 ANK-3674 ADD START
/**
* SQLKEY(AC_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求契約番号 * 課金先適用開始年月日 * 課金先適用終了年月日 * サービス契約予約適用年月日 * サービス開始年月日 * サービス解約起算日 * 料金集計先適用開始年月日 * 料金集計先適用終了年月日 * 料金集計先予約適用年月日 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_M_PRC_SHUK_SK_AC_SELECT_004(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()); paramList.setValue(param[5].toString()); paramList.setValue(param[6].toString()); // DBアクセスを実行します db_CH_M_PRC_SHUK_SK.selectBySqlDefine(paramList, CH_M_PRC_SHUK_SK_AC_SELECT_004); } // v47.00.00 ANK-3674 ADD END /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * 料金グループコードを取得します。 * * @param inMap 入力電文 * @throws Exception 業務サービス内で発生した例外全般 */ private void selectChMPrcShukSk(JBSbatServiceInterfaceMap inMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectChMPrcShukSk]"); /* ++++++++++ v12.00.00 追加開始 ++++++++++ */ // JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); // // paramList.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 // paramList.setValue(super.opeDate); // 課金先適用開始年月日 // paramList.setValue(super.opeDate); // 課金先適用終了年月日 // paramList.setValue(super.opeDate); // サービス契約予約適用年月日 // paramList.setValue(this.UseStrEnd[1]); // サービス開始年月日 // paramList.setValue(this.UseStrEnd[0]); // サービス解散起算年月日 // paramList.setValue(super.opeDate); // 料金集計先適用開始年月日 // paramList.setValue(super.opeDate); // 料金集計先適用終了年月日 // paramList.setValue(super.opeDate); // 料金集計先予約適用年月日 // // assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][paramList=" + paramList.getList().toString() + "]"); // // // SQL実行 // executeCH_M_PRC_SHUK_SK_AC_SELECT_001(paramList.getList().toArray()); // // // 結果取得 // JBSbatCommonDBInterface dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); // if(dbMap == null) // { // // 取得件数が０件の場合,解約済みサービスから取得する // executeCH_M_PRC_SHUK_SK_AC_SELECT_003(paramList.getList().toArray()); // // // 結果取得 // dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); // if (dbMap == null) // { // // 取得件数が０件の場合,課金適用終了から取得する // dbMap = selectChMPrcShukSk2(inMap); // if (dbMap == null) // { // // 課金先適用終了からも取得できなければリターン // return; // // } // } // } // assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][dbMap=" + dbMap.getMap().toString() + "]"); // // inMap.setString(JBSbatACIFM142.PRC_GRP_CD, dbMap.getString(JBSbatCH_M_PRC_SHUK_SK.PRC_GRP_CD)); // 料金サービスコードを取得 String prcSvcCd = inMap.getString(JBSbatACIFM142.PRC_SVC_CD); String prcGrpCd = ""; // NHK団体一括の場合、料金グループコードにeo光テレビを設定します。 if(PRC_SVC_CD_NHK_JUSHIN.equals(prcSvcCd)) { prcGrpCd = JACStrConst.PRC_GRP_CD_TV_KCAT; } else { JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 paramList.setValue(super.opeDate); // 課金先適用開始年月日 paramList.setValue(super.opeDate); // 課金先適用終了年月日 paramList.setValue(super.opeDate); // サービス契約予約適用年月日 paramList.setValue(this.UseStrEnd[1]); // サービス開始年月日 paramList.setValue(this.UseStrEnd[0]); // サービス解散起算年月日 paramList.setValue(super.opeDate); // 料金集計先適用開始年月日 paramList.setValue(super.opeDate); // 料金集計先適用終了年月日 paramList.setValue(super.opeDate); // 料金集計先予約適用年月日 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][paramList=" + paramList.getList().toString() + "]"); // v26.00.00 ADD START prcGrpCd = inMap.getString(JBSbatACIFM142.PRC_GRP_CD); if(JKKStringUtil.isNullSpace(prcGrpCd)) { // ※１．料金グループコードを取得する為、下記処理順でSQLを実行する。 // 取得結果：（有）の場合、後続処理はスキップして取得結果から、料金グループコードを設定する。 // 処理順１： CH_M_PRC_SHUK_SK_AC_SELECT_001 // 処理順２： CH_M_PRC_SHUK_SK_AC_SELECT_003 // 処理順２.５： CH_M_PRC_SHUK_SK_AC_SELECT_004 // 処理順３： CH_M_PRC_SHUK_SK_AC_SELECT_002 // SQL実行 executeCH_M_PRC_SHUK_SK_AC_SELECT_001(paramList.getList().toArray()); // 結果取得 JBSbatCommonDBInterface dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); if (dbMap == null) { // 取得件数が０件の場合,解約済みサービスから取得する executeCH_M_PRC_SHUK_SK_AC_SELECT_003(paramList.getList().toArray()); // 結果取得 dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); if (dbMap == null) { // 取得件数が０件の場合,課金適用終了から取得する dbMap = selectChMPrcShukSk2(inMap); if (dbMap == null) { // 課金先適用終了からも取得できなければリターン return; } } // v47.00.00 ANK-3674 ADD START else { if ("999".equals(dbMap.getString(JBSbatCH_M_PRC_SHUK_SK.KAIK_SUMUP_SK_YUSEN_JUN))) { // 取得結果が廃止サービスの場合,課金先適用終了から別サービスを取得する JBSbatCommonDBInterface paramList2 = new JBSbatCommonDBInterface(); paramList2.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 paramList2.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 paramList2.setValue(super.opeDate); // 課金先適用終了年月日 paramList2.setValue(super.opeDate); // サービス契約予約適用年月日 paramList2.setValue(super.opeDate); // 料金集計先適用開始年月日 paramList2.setValue(super.opeDate); // 料金集計先適用終了年月日 paramList2.setValue(super.opeDate); // 料金集計先予約適用年月日 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][paramList2=" + paramList.getList().toString() + "]"); executeCH_M_PRC_SHUK_SK_AC_SELECT_004(paramList2.getList().toArray()); JBSbatCommonDBInterface dbMap2 = db_CH_M_PRC_SHUK_SK.selectNext(); if (dbMap2 != null) { dbMap = dbMap2; } } } // v47.00.00 ANK-3674 ADD END } // ※１．結果取得：有 prcGrpCd = dbMap.getString(JBSbatCH_M_PRC_SHUK_SK.PRC_GRP_CD); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][dbMap=" + dbMap.getMap().toString() + "]"); } } // v26.00.00 ADD END // v26.00.00 DEL START ////OM-2016-0000647 DEL STA //// // SQL実行 //// executeCH_M_PRC_SHUK_SK_AC_SELECT_001(paramList.getList().toArray()); //// //// // 結果取得 //// JBSbatCommonDBInterface dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); ////OM-2016-0000647 DEL END ////OM-2016-0000647 MOD STA //// if(dbMap == null) // prcGrpCd = inMap.getString(JBSbatACIFM142.PRC_GRP_CD); // if(JKKStringUtil.isNullSpace(prcGrpCd)) ////OM-2016-0000647 MOD END // { // // 取得件数が０件の場合,解約済みサービスから取得する // executeCH_M_PRC_SHUK_SK_AC_SELECT_003(paramList.getList().toArray()); // // // 結果取得 ////OM-2016-0000647 MOD STA //// dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); // JBSbatCommonDBInterface dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); ////OM-2016-0000647 MOD END // if (dbMap == null) // { // // 取得件数が０件の場合,課金適用終了から取得する // dbMap = selectChMPrcShukSk2(inMap); // if (dbMap == null) // { // // 課金先適用終了からも取得できなければリターン // return; // // } // } ////OM-2016-0000647 ADD STA // prcGrpCd = dbMap.getString(JBSbatCH_M_PRC_SHUK_SK.PRC_GRP_CD); // assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][dbMap=" + dbMap.getMap().toString() + "]"); ////OM-2016-0000647 ADD END // } ////OM-2016-0000647 DEL STA //// assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk][dbMap=" + dbMap.getMap().toString() + "]"); ////OM-2016-0000647 DEL END // ////OM-2016-0000647 DEL STA //// prcGrpCd = dbMap.getString(JBSbatCH_M_PRC_SHUK_SK.PRC_GRP_CD); ////OM-2016-0000647 DEL END // } // v26.00.00 DEL END // 料金グループを設定 inMap.setString(JBSbatACIFM142.PRC_GRP_CD, prcGrpCd); /* ++++++++++ v12.00.00 追加完了 ++++++++++ */ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectChMPrcShukSk]"); } /** * 適用終了の課金先から料金グループコードを取得します。 * * @param inMap 入力電文 * @throws Exception 業務サービス内で発生した例外全般 */ private JBSbatCommonDBInterface selectChMPrcShukSk2(JBSbatServiceInterfaceMap inMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectChMPrcShukSk2]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 paramList.setValue(super.opeDate); // 課金先適用終了年月日 paramList.setValue(inMap.getString(JBSbatACIFM142.SEIKY_KEI_NO)); // 請求契約番号 paramList.setValue(super.opeDate); // サービス契約予約適用年月日 paramList.setValue(super.opeDate); // 料金集計先適用開始年月日 paramList.setValue(super.opeDate); // 料金集計先適用終了年月日 paramList.setValue(super.opeDate); // 料金集計先予約適用年月日 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk2][paramList=" + paramList.getList().toString() + "]"); // SQL実行 executeCH_M_PRC_SHUK_SK_AC_SELECT_002(paramList.getList().toArray()); // 結果取得 JBSbatCommonDBInterface dbMap = db_CH_M_PRC_SHUK_SK.selectNext(); if (dbMap == null) { // 取得件数０件の場合 return null; } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectChMPrcShukSk2][dbMap=" + dbMap.getMap().toString() + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectChMPrcShukSk2]"); return dbMap; } }