*
* @author 富士通
*/
public class JBSbatKKTvKsSvMoveInfChsht extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(連携ファイル制御)*/
private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";
/** テーブル(サービス契約)*/
private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
/** SQL定義キー(KK_SELECT_042)*/
private static final String KK_T_SVC_KEI_KK_SELECT_042 = "KK_SELECT_042";
/** SQL定義キー(KK_SELECT_043)*/
private static final String KK_T_SVC_KEI_KK_SELECT_043 = "KK_SELECT_043";
//OM-2016-0000595 2016/03/10 ADD START
/** SQL定義キー(KK_SELECT_322)*/
private static final String KK_T_SVC_KEI_KK_SELECT_322 = "KK_SELECT_322";
//OM-2016-0000595 2016/03/10 ADD END
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI_322 = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 連携異動区分（住所変更：10000）
*/
private static final String RNK_IDIV_HIKKOSHI = "10000";
// OM-2016-0001550 ADD START
private static final String RNK_IDIV_DSL_CANCEL = "90000";
// OM-2016-0001550 ADD END
/** 物理バッチID（KKPRC01601）*/
private static final String BAT_ID = "KKPRC01701";
/** ファイルID（KKIFE044）*/
private static final String FILE_ID = "KKIFE050 ";
/** 共通クラスインスタンス */
private JKKBatKKTvKsSvInfoCommon tvKsSvInfoCommon = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_RNKI_FILE_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_RNKI_FILE_CTRL);
db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
db_KK_T_SVC_KEI_322 = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// 共通クラスインスタンス生成
tvKsSvInfoCommon = new JKKBatKKTvKsSvInfoCommon(commonItem);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 出力共通電文を生成します。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// 連携ファイル制御より前回TV監視サーバ向け異動情報を作成した運用日取得
// 前回処理実行年月日時分秒
String znkiJssiTimestamp = getZnkiJssiDateTimeStamp();
super.logPrint.printDebugLog("前回処理実行年月日時分秒---->" + znkiJssiTimestamp);
// 1.サービス契約を検索し、住所変更情報を抽出します。
JBSbatCommonDBInterface adChgMap = this.selectSvcKei042(znkiJssiTimestamp);
// 検索結果を判断します。
if (null != adChgMap)
{
while (null != adChgMap)
{
// ファイル出力用データ作成をします。
createKkife050Data(outputBean, adChgMap);
// 次のレコードを取得します。
adChgMap = db_KK_T_SVC_KEI.selectNext();
}
}
else
{
super.logPrint.printDebugLog("住所変更情報：検索結果０件");
}
// 2.サービス契約を検索し、住所変更撤去情報を抽出します。
JBSbatCommonDBInterface adChgTkMap = this.selectSvcKei043(znkiJssiTimestamp);
// 検索結果を判断します。
if (null != adChgTkMap)
{
while (null != adChgTkMap)
{
// ファイル出力用データ作成をします。
createKkife050Data(outputBean, adChgTkMap);
// 次のレコードを取得します。
adChgTkMap = db_KK_T_SVC_KEI.selectNext();
}
}
else
{
super.logPrint.printDebugLog("住所変更撤去情報：検索結果０件");
}
super.logPrint.printDebugLog("execute_END");
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
db_KK_T_SVC_KEI.close();
db_KK_T_SVC_KEI_322.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 共通クラスクローズ
tvKsSvInfoCommon.close();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * BUTSURI_BAT_ID * FILE_ID *
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeKK_T_RNKI_FILE_CTRL_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
whereMap.setValue("FILE_ID", whereParam[1]);
// DBアクセスを実行します
return db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeys(whereMap);
}
/**
* SQLKEY(KK_SELECT_042)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 予約適用年月日 * 更新年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KK_SELECT_042(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_042);
}
/**
* SQLKEY(KK_SELECT_043)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 予約適用年月日 * 更新年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KK_SELECT_043(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
paramList.setValue(param[2].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_043);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* サービス契約テーブルの検索を行います。(KK_SELECT_042)
*
* @param znkiJssiTimestamp 前回処理実行年月日時分秒
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト。
* @throws Exception
*/
private JBSbatCommonDBInterface selectSvcKei042(String znkiJssiTimestamp) throws Exception
{
// サービス契約を検索して住所変更情報を取得します。
// サービス契約情報検索条件項目を設定します。
Object[] paramList = new Object[3];
paramList[0] = opeDate; // 予約適用年月日
paramList[1] = znkiJssiTimestamp; // 更新年月日時分秒
super.logPrint.printDebugLog("paramList[0]：" + paramList[0]);
super.logPrint.printDebugLog("paramList[1]：" + paramList[1]);
// サービス契約情報検索処理を実行します。
executeKK_T_SVC_KEI_KK_SELECT_042(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_KK_T_SVC_KEI.selectNext();
return outDbMap;
}
/**
* サービス契約テーブルの検索を行います。(KK_SELECT_043)
*
* @param znkiJssiTimestamp 前回処理実行年月日時分秒
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト。
* @throws Exception
*/
private JBSbatCommonDBInterface selectSvcKei043(String znkiJssiTimestamp) throws Exception
{
// サービス契約を検索して住所変更撤去情報を取得します。
// サービス契約情報検索条件項目を設定します。
Object[] paramList = new Object[3];
paramList[0] = znkiJssiTimestamp; // 更新年月日時分秒
paramList[1] = opeDate; // 運用日
paramList[2] = opeDate; // 運用日
super.logPrint.printDebugLog("paramList[0]：" + paramList[0]);
super.logPrint.printDebugLog("paramList[1]：" + paramList[1]);
super.logPrint.printDebugLog("paramList[2]：" + paramList[2]);
// サービス契約情報検索処理を実行します。
executeKK_T_SVC_KEI_KK_SELECT_043(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_KK_T_SVC_KEI.selectNext();
return outDbMap;
}
/**
*
* 住所変更情報のファイル出力レコードを出力します。
*
* @param outputBean 出力共通電文
* @param adChgInfMap DB検索結果
* @return JBSbatServiceInterfaceMap 入出力インターフェースオブジェクト
* @throws Exception メソッド内で発生した例外全般
*/
private void createKkife050Data(JBSbatOutputItem outputBean, JBSbatCommonDBInterface adChgInfMap)
throws Exception
{
super.logPrint.printDebugLog("createKkife050Data_START");
// 移転元サービス契約番号
String itnmSvcKeiNo = JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO));
// 移転先サービス契約番号
String itnsSvcKeiNo = JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO));
super.logPrint.printDebugLog("移転元サービス契約番号：" + itnmSvcKeiNo + "／移転先サービス契約番号：" + itnsSvcKeiNo);
// ＴＶ監視サーバ向け異動情報ファイル基本レコード作成処理を実行
JBSbatServiceInterfaceMap outMap = tvKsSvInfoCommon.createKKIFE050BaseData(itnmSvcKeiNo);
// 出力情報が取得できない場合
if (null == outMap)
{
commonItem.getLogPrint().printBusinessErrorLog("EKKB0010CW",
new String[]{"出力情報が取得できません。サービス契約番号：" + itnmSvcKeiNo});
return;
}
//OM-2016-0000595 2016/03/10 MOD START
//// No.2「異動区分」
//outMap.setString(JBSbatKKIFE050001.IDO_DIV, RNK_IDIV_HIKKOSHI);
//
//// No.3「異動日」（工事案件.工事案件実施年月日）
//String kojiakJssiYmd = JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD));
//if (!JKKStringUtil.isNullBlank(kojiakJssiYmd))
//{
// outMap.setString(JBSbatKKIFE050001.IDO_YMD, kojiakJssiYmd);
//}
//
//// No.15「引越先サービス契約番号」（引越先のサービス契約番号（「住所変更明細」の変更後識別番号）を設定）
//outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID,
// JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO)));
// OM-2016-0001550 MOD START
// // 異動区分、異動日、引越先サービス契約番号を設定する対象となるサービス契約（住所変更中）の抽出を行う。
// String[] param = {itnmSvcKeiNo};
// this.executeKK_T_SVC_KEI_KK_SELECT_322(param);
//
// JBSbatCommonDBInterface svcKei322Map = db_KK_T_SVC_KEI_322.selectNext();
//
// //住所変更中の場合
// if(null != svcKei322Map)
// {
// // No.2「異動区分」
// outMap.setString(JBSbatKKIFE050001.IDO_DIV, RNK_IDIV_HIKKOSHI);
// // No.3「異動日」（工事案件.工事案件実施年月日）
// String kojiakJssiYmd = JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD));
// if (!JKKStringUtil.isNullBlank(kojiakJssiYmd))
// {
// outMap.setString(JBSbatKKIFE050001.IDO_YMD, kojiakJssiYmd);
// }
// // No.15「引越先サービス契約番号」（引越先のサービス契約番号（「住所変更明細」の変更後識別番号）を設定）
// outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID,
// JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO)));
// }
// //OM-2016-0000595 2016/03/10 MOD END
// 住所変更中チェック
String[] param = {itnmSvcKeiNo};
this.executeKK_T_SVC_KEI_KK_SELECT_322(param);
JBSbatCommonDBInterface svcKei322Map = db_KK_T_SVC_KEI_322.selectNext();
// 異動区分/引越先サービス契約番号設定
if(JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("910") || JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("920"))
{
// 予備項目1(サービス契約ステータス)=解約済、キャンセル済の場合は異動区分に"90000"を設定
outMap.setString(JBSbatKKIFE050001.IDO_DIV, RNK_IDIV_DSL_CANCEL);
}
else
{
if(null != svcKei322Map)
{
// 住所変更中の場合は異動区分に10000を設定
outMap.setString(JBSbatKKIFE050001.IDO_DIV, RNK_IDIV_HIKKOSHI);
// 住所変更中の場合は異動日に工事案件.工事案件実施年月日を設定
String kojiakJssiYmd = JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD));
if (!JKKStringUtil.isNullBlank(kojiakJssiYmd))
{
outMap.setString(JBSbatKKIFE050001.IDO_YMD, kojiakJssiYmd);
}
// 住所変更中の場合は引越先サービス契約番号に住所変更明細.変更後識別番号を設定
outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID, JBSbatStringUtil.Rtrim(adChgInfMap.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO)));
}
}
// OM-2016-0001550 MOD END
JBSbatServiceInterfaceMap outMap2 = null;
// 移転元サービス契約番号と移転先サービス契約番号が異なる場合
if (!JKKStringUtil.isNullBlank(itnsSvcKeiNo) && !itnmSvcKeiNo.equals(itnsSvcKeiNo))
{
// OM-2016-0001550 DEL START
// // No.15「引越先サービス契約番号」（引越先のサービス契約番号（「住所変更明細」の変更後識別番号）を設定）
// //OM-2016-0000595 2016/03/10 MOD START
// //outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID, itnsSvcKeiNo);
// if(null != svcKei322Map)
// {
// outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID, itnsSvcKeiNo);
// }
// //OM-2016-0000595 2016/03/10 MOD END
// OM-2016-0001550 DEL END
// ＴＶ監視サーバ向け異動情報ファイル基本レコード作成処理を実行
outMap2 = tvKsSvInfoCommon.createKKIFE050BaseData(itnsSvcKeiNo);
// 出力情報が取得できない場合
if (null == outMap2)
{
commonItem.getLogPrint().printBusinessErrorLog("EKKB0010CW",
new String[]{"出力情報が取得できません。サービス契約番号：" + itnsSvcKeiNo});
return;
}
// OM-2016-0001550 ADD START
// 異動区分設定
if(JBSbatStringUtil.Rtrim(outMap2.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("910") || JBSbatStringUtil.Rtrim(outMap2.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("920"))
{
// 予備項目1(サービス契約ステータス)=解約済、キャンセル済の場合は異動区分に"90000"を設定
outMap2.setString(JBSbatKKIFE050001.IDO_DIV, RNK_IDIV_DSL_CANCEL);
}
// OM-2016-0001550 ADD END
}
outMap.setOutFlg(true);
outputBean.addOutMapList(outMap);
if (null != outMap2)
{
outMap2.setOutFlg(true);
outputBean.addOutMapList(outMap2);
}
super.logPrint.printDebugLog("createKkife050Data_END");
return;
}
/**
* 連携ファイル制御より前回処理実行年月日の取得
*
* @return 前回処理実行年月日時分秒
* @throws Exception
*/
private String getZnkiJssiDateTimeStamp() throws Exception
{
String znkiJssiTimestamp = "";
JBSbatCommonDBInterface dbMap = executeKK_T_RNKI_FILE_CTRL_PKSELECT(new Object[]{BAT_ID, FILE_ID});
// 取得できた場合
if(null != dbMap)
{
// 前回処理実行年月日時分秒
znkiJssiTimestamp = JBSbatStringUtil.Rtrim(dbMap.getString(JBSbatKK_T_RNKI_FILE_CTRL.ZNKI_TRAN_RUN_DTM));
}
// 前回実施日が取得できなかった場合、バッチ運用日-1日を「前回運用日」とする。
if("".equals(znkiJssiTimestamp))
{
znkiJssiTimestamp = JBSbatDateUtil.adjustDate(super.opeDate, -1) + "220000000";
}
return znkiJssiTimestamp;
}
//OM-2016-0000595 2016/03/10 ADD START
/**
* SQLKEY(KK_SELECT_322)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 予約適用年月日 * 更新年月日時分秒 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_KK_SELECT_322(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI_322.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_322); } //OM-2016-0000595 2016/03/10 ADD END }