*
* @author 富士通
*/
public class JBSbatKKKkHktgAfOldEqpDelRnki extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(サービス契約＿工事案件)*/
private static final String D_TBL_NAME_KU_T_SVKEI_KOJIAK = "KU_T_SVKEI_KOJIAK";
/** テーブル(工事案件)*/
private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";
/** SQL定義キー(KK_SELECT_031)*/
private static final String KU_T_SVKEI_KOJIAK_KK_SELECT_031 = "KK_SELECT_031";
/** テーブルアクセスクラス(サービス契約＿工事案件)*/
private JBSbatSQLAccess db_KU_T_SVKEI_KOJIAK = null;
/** テーブルアクセスクラス(工事案件)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/** 連携種別コード(工事完了連携済) */
private static final String KOJI_FIN_RNKIZM = "2";
/** 連携種別コード(旧設備削除) */
private static final String OLD_EQUIP_DEL_RNKIZM = "3";
/** 連携種別コード(ＯＮＵ直送返品済) */
private static final String ONU_CHOKUSO_HMPINZM = "6";
/** 連携種別コード(解約連携済返品未連携) */
private static final String DSL_RNKIKZM_HMPIN_MIRNKI = "7";
/** 連携種別コード(解約連携済返品連携済) */
private static final String DSL_RNKIZM_HMPIN_RNKIZM = "8";
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KU_T_SVKEI_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_SVKEI_KOJIAK);
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// 機器引継完了リストの宅内機器種別コードが"D0"（ＯＮＵ）または"S0"（ＨＧＷ）の場合
if (JKKStrConst.TAKNKIKI_SBT_CD_ONU.equals(inMap.getString(JBSbatKKIFM964.TAKNKIKI_SBT_CD)) ||
JKKStrConst.TAKNKIKI_SBT_CD_HGW.equals(inMap.getString(JBSbatKKIFM964.TAKNKIKI_SBT_CD)))
{
Object[] param = new Object[]{inMap.getString(JBSbatKKIFM964.NRKEMT_SVC_KEI_KAISEN_UCWK_NO)} ;
// サービス契約_工事案件から工事案件を取得
this.executeKU_T_SVKEI_KOJIAK_KK_SELECT_031(param);
JBSbatCommonDBInterface svcKeiKojiakMap = db_KU_T_SVKEI_KOJIAK.selectNext();
if (svcKeiKojiakMap != null)
{
//更新対象工事案件番号（１世代前の工事案件番号）
String updTrgtKojiakNo = svcKeiKojiakMap.getString("UPD_TRGT_KOJIAK_NO");
boolean isOldEquipDelMiSumi = false;
//抽出された更新対象工事案件番号がnullでない場合
if (updTrgtKojiakNo != null)
{
// 更新対象工事案件番号で工事案件情報を取得する
JBSbatCommonDBInterface kojiakMap1 = this.executeKU_T_KOJIAK_PKSELECT(new Object[] {updTrgtKojiakNo});
if (kojiakMap1 != null)
{
// 更新対象工事案件番号（２世代前の工事案件番号）
String updTrgtKojiakNo2 = kojiakMap1.getString("UPD_TRGT_KOJIAK_NO");
//抽出された更新対象工事案件番号がnullでない場合
if (updTrgtKojiakNo2 != null)
{
// 更新対象工事案件番号で工事案件情報を取得する
JBSbatCommonDBInterface kojiakMap2 = this.executeKU_T_KOJIAK_PKSELECT(new Object[] {updTrgtKojiakNo2});
if (kojiakMap2 != null)
{
// ２世代前の連携種別コードが"3"（旧設備削除）以外の場合、マイナーアラームを発行する
if (!OLD_EQUIP_DEL_RNKIZM.equals(kojiakMap2.getString(JBSbatKU_T_KOJIAK.FCDS_RNKI_SBT_CD))||
!OLD_EQUIP_DEL_RNKIZM.equals(kojiakMap2.getString(JBSbatKU_T_KOJIAK.GENESIS_RNKI_SBT_CD)))
{
isOldEquipDelMiSumi = true;
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2300KW, new String[]{
updTrgtKojiakNo}); // 更新対象工事案件番号（１世代前の工事案件番号）
// エラーフラグ認定
super.commonItem.setErrorCount(1);
}
}
}
}
}
// １世代前の更新対象工事案件番号が未設定の場合、
// 又は、２世代前の連携種別が"3"（旧設備削除）の場合
if (!isOldEquipDelMiSumi)
{
// 更新対象の工事案件情報を取得する
JBSbatCommonDBInterface map = this.executeKU_T_KOJIAK_PKSELECT(new Object[] {updTrgtKojiakNo});
if (map != null)
{
// FCDS連携種別コード
String fcdsRnkiSbtCd = map.getString(JBSbatKU_T_KOJIAK.FCDS_RNKI_SBT_CD);
// Genesis連携種別コード
String genesisRnkiSbtCd = map.getString(JBSbatKU_T_KOJIAK.GENESIS_RNKI_SBT_CD);
// FCDS連携種別コードが"2"(工事完了連携済)の場合、"6"(ＯＮＵ直送返品済)を設定する。
if (KOJI_FIN_RNKIZM.equals(fcdsRnkiSbtCd))
{
fcdsRnkiSbtCd = ONU_CHOKUSO_HMPINZM;
}
// Genesis連携種別コードが"2"(工事完了連携済)の場合、"6"(ＯＮＵ直送返品済)を設定する。
if (KOJI_FIN_RNKIZM.equals(genesisRnkiSbtCd))
{
genesisRnkiSbtCd = ONU_CHOKUSO_HMPINZM;
}
// Genesis連携種別コードが"7"(解約連携済返品未連携)の場合、"8"(解約連携済返品連携済)を設定する。
else if (DSL_RNKIKZM_HMPIN_MIRNKI.equals(genesisRnkiSbtCd))
{
genesisRnkiSbtCd = DSL_RNKIZM_HMPIN_RNKIZM;
}
Object[] param1 = new Object[]{fcdsRnkiSbtCd, genesisRnkiSbtCd};
Object[] param2 = new Object[]{updTrgtKojiakNo};
// 工事案件を更新する
this.executeKU_T_KOJIAK_PKUPDATE(param1, param2);
}
}
}
}
return null;
}
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KU_T_SVKEI_KOJIAK.close();
db_KU_T_KOJIAK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_031)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約回線内訳番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_SVKEI_KOJIAK_KK_SELECT_031(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KU_T_SVKEI_KOJIAK.selectBySqlDefine(paramList, KU_T_SVKEI_KOJIAK_KK_SELECT_031);
}
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * KOJIAK_NO *
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeKU_T_KOJIAK_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KOJIAK_NO", whereParam[0]);
// DBアクセスを実行します
return db_KU_T_KOJIAK.selectByPrimaryKeys(whereMap);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * ＦＣＤＳ連携種別コード FCDS_RNKI_SBT_CD * Ｇｅｎｅｓｉｓ連携種別コード GENESIS_RNKI_SBT_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * KOJIAK_NO *
* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKU_T_KOJIAK_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("FCDS_RNKI_SBT_CD", setParam[0]); setMap.setValue("GENESIS_RNKI_SBT_CD", setParam[1]); // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KOJIAK_NO", whereParam[0]); // DBアクセスを実行します db_KU_T_KOJIAK.updateByPrimaryKeys(whereMap, setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }