*
* @author 富士通
*/
public class JBSbatCKShijishoFileTelNoInsertSokuji 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_CK_T_SJISHO = "CK_T_SJISHO";
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** SQL定義キー(CH_UPDATE_001)*/
private static final String KK_T_RNKI_FILE_CTRL_CK_UPDATE_001 = "CK_UPDATE_001";
/** SQL定義キー(CK_SELECT_017)*/
private static final String CK_T_CUST_CK_SELECT_017 = "CK_SELECT_017";
// OM-2020-0001099 ADD START
/** SQL定義キー(CK_SELECT_019)*/
private static final String CK_T_CUST_CK_SELECT_019 = "CK_SELECT_019";
// OM-2020-0001099 ADD END
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/** テーブルアクセスクラス(指示書)*/
private JBSbatSQLAccess db_CK_T_SJISHO = null;
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
/** 指示書番号*/
private static final String SEQ_SJISHO = "SEQ_SJISHO_NO";
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 今回処理年月日時分秒 17桁*/
private String freeItemTargetDtmEnd = "";
/** 今回処理年月日時分秒 17桁*/
private String freeItemTargetDtmSta = "";
/** 今回処理年月日（運用日） 8桁*/
private String freeItemTargetDtmYyyyMmDd = "";
/** ジョブID*/
private String freeItemJobId = "";
/**
* 初期処理
* @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_CK_T_SJISHO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_SJISHO);
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// フルパスを生成。
String[] freeItem = commonItem.getFreeItem().split(";");
// システム日付17桁(抽出日時(至))
freeItemTargetDtmEnd = freeItem[0];
// システム日付8桁
freeItemTargetDtmYyyyMmDd = freeItem[1];
//ジョブID
freeItemJobId = freeItem[2];
// システム日付17桁(抽出日時(自))
freeItemTargetDtmSta = freeItem[3];
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// SYSIDの取得
String sysId = (String)inMap.get("SYSID");
JBSbatCommonDBInterface custMap = null;
// OM-2020-0001099 ADD START
Object[] sysidParam = new Object[]
{
inMap.get("SYSID"), //処理対象ＳＹＳＩＤ
freeItemTargetDtmYyyyMmDd, //予約適用年月日
freeItemTargetDtmSta, //世代登録年月日時分秒
freeItemTargetDtmEnd, //世代登録年月日時分秒
inMap.get("SYSID"), //処理対象ＳＹＳＩＤ
freeItemTargetDtmYyyyMmDd, //予約適用年月日
freeItemTargetDtmSta, //世代登録年月日時分秒
freeItemTargetDtmEnd, //世代登録年月日時分秒
freeItemTargetDtmSta, //世代登録年月日時分秒
freeItemTargetDtmYyyyMmDd, //予約適用年月日
freeItemTargetDtmYyyyMmDd, //予約適用年月日
};
this.executeCK_T_CUST_CK_SELECT_019(sysidParam);
JBSbatCommonDBInterface custParam = db_CK_T_CUST.selectNext();
//登録対象の指示書かチェックを実施する
if(custParam == null)
{
return null;
}
// OM-2020-0001099 ADD END
//引数 OS日付YYYYMMDD、S日付YYYYMMDD、SYSID、OS日付YYYYMMDD
Object[] paramSelect = {freeItemTargetDtmYyyyMmDd, freeItemTargetDtmYyyyMmDd, sysId, freeItemTargetDtmYyyyMmDd};
executeCK_T_CUST_CK_SELECT_017(paramSelect);
custMap = db_CK_T_CUST.selectNext();
if(custMap != null)
{
// お客様から「会員種別コード」を取得する。
String memberSbtCd = custMap.getString("MEMBER_SBT_CD");
// サービス契約番号
String svcKeiNo = custMap.getString("SVC_KEI_NO");
// コンテンツ電話番号
String contTelNo = custMap.getString("TELNO");
// 契約者電話番号
String keisyaTelNo = custMap.getString("KEISHA_TELNO");
// 連携電話番号
String telNo = "";
// OM-2020-0000415 ADD START
// お客様退会日
String custTaikaiYmd = custMap.getString("CUST_TAIKAI_YMD");
// // 会員種別がファミリー会員(個人)、ファミリー会員(法人)、オープン会員かつお客様退会日が設定されている場合は対象外
if ((JBSbatKKConst.MEMBER_SBT_CD_FAMILY_MEMBER_KOJIN.equals(memberSbtCd) || JBSbatKKConst.MEMBER_SBT_CD_FAMILY_MEMBER_HOJIN.equals(memberSbtCd)
|| JBSbatKKConst.MEMBER_SBT_CD_OPEN_MEMBER.equals(memberSbtCd)) && !JKKStringUtil.isNullBlank(custTaikaiYmd))
{
return null;
}
// OM-2020-0000415 ADD END
//非EO会員は対象外
if (JBSbatKKConst.MEMBER_SBT_CD_HI_EO_MEMBER.equals(memberSbtCd))
{
return null;
}
// 会員種別コードがマスター会員または法人の場合
else if (JBSbatKKConst.MEMBER_SBT_CD_MASTER_MEMBER_KOJIN.equals(memberSbtCd) || JBSbatKKConst.MEMBER_SBT_CD_MASTER_MEMBER_HOJIN.equals(memberSbtCd))
{
// コンテンツ未同意
if (JKKStringUtil.isNullBlank(svcKeiNo))
{
// 契約者電話番号をを登録
telNo = keisyaTelNo;
}
// コンテンツ同意済
else
{
// コンテンツ電話番号を登録
telNo = contTelNo;
}
}
// ファミリー会員（個人） ファミリー会員（法人）オープン会員
else
{
// コンテンツ電話番号を登録
telNo = contTelNo;
}
// 連携電話番号が登録されていない場合
if (JKKStringUtil.isNullBlank(telNo))
{
// ALL9で登録する
telNo = "9999999999";
}
// 入力ファイルから情報を取得します
// 指示書作成
Object[] param = {
getNextShijishoNo(inMap), // 指示書番号
"000000000001", // 指示書内容枝番
SJISHO_TRN_CD_ADMIN_API, // 処理コード
null, // 対象テーブルＩＤ
0, // エラー回数
inMap.get("SYSID"), // 処理対象ＳＹＳＩＤ
"0", // 結果フラグ
22, // パラメータ有効数
ADMIN_SJISHO_PARAM1_UPD_PART, // パラメータ１
null, // パラメータ２(eoID)
null, // パラメータ３(メンバーSYSID)
null, // パラメータ４
null, // パラメータ５
null, // パラメータ６
null, // パラメータ７
null, // パラメータ８
null, // パラメータ９
null, // パラメータ１０
null, // パラメータ１１
null, // パラメータ１２
null, // パラメータ１３
null, // パラメータ１４
null, // パラメータ１５
null, // パラメータ１６
null, // パラメータ１７
null, // パラメータ１８
null, // パラメータ１９
telNo, // パラメータ２０
null, // パラメータ２１
null, // パラメータ２２
null, // パラメータ２３
null, // パラメータ２４
null, // パラメータ２５
null, // パラメータ２６
null, // パラメータ２７
null, // パラメータ２８
null, // パラメータ２９
null, // パラメータ３０
null, // パラメータ３１
null, // パラメータ３２
null, // パラメータ３３
null, // パラメータ３４
null, // パラメータ３５
null, // パラメータ３６
null, // パラメータ３７
null, // パラメータ３８
null, // パラメータ３９
null, // パラメータ４０
null, // パラメータ４１
null, // パラメータ４２
null, // パラメータ４３
null, // パラメータ４４
null, // パラメータ４５
null, // パラメータ４６
null, // パラメータ４７
null, // パラメータ４８
null, // パラメータ４９
null, // パラメータ５０
getBatchDatetime(), // 登録年月日時分秒
getUpdOperator(), // 登録オペレータアカウント
getBatchDatetime(), // 更新年月日時分秒
getUpdOperator(), // 更新オペレータアカウント
null, // 削除年月日時分秒
null, // 削除オペレータアカウント
"0", // 無効フラグ
};
// DBアクセスを実行します
executeCK_T_SJISHO_PKINSERT(param);
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* バッチ日時(17桁)を取得する
* @return バッチ日時
* @throws Exception
*/
private String getBatchDatetime() throws Exception
{
return JCCBatCommon.getSysDateTimeStamp();
}
/**
* 更新者IDを取得する.
*
* @return 更新者ID
*/
private String getUpdOperator()
{
return commonItem.getBatchUserId();
}
/**
* 次の指示書番号を取得する
* @param inMap
* @return String
* @throws Exception
*/
private String getNextShijishoNo(JBSbatServiceInterfaceMap inMap) throws Exception
{
return JCCBatCommon.getFormatedNextSeq(commonItem, SEQ_SJISHO, JCCBatCommon.getSysDate(), 7);
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
String[] updateParam = new String[2];
// 前回処理年月日時分秒
updateParam[0] = this.freeItemTargetDtmEnd;
// ジョブID
updateParam[1] = this.freeItemJobId;
// 連携ファイル制御更新
executeKK_T_RNKI_FILE_CTRL_CK_UPDATE_001(updateParam);
// 「%1% KEY=%2%」
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECKB0040AI,
new String[] { "携帯電話番号更新指示書登録(即時適用分)処理", "抽出日時(自):" + freeItemTargetDtmSta + "、抽出日時(至):" + freeItemTargetDtmEnd + "、予約適用日:" + freeItemTargetDtmYyyyMmDd});
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
db_CK_T_SJISHO.close();
db_CK_T_CUST.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
// OM-2020-0001099 ADD START
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CK_SELECT_019)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_CK_SELECT_019(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());
paramList.setValue(param[9].toString());
paramList.setValue(param[10].toString());
// DBアクセスを実行します
db_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_CK_SELECT_019);
}
// OM-2020-0001099 ADD END
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CK_SELECT_905)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_CK_SELECT_017(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_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_CK_SELECT_017);
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CH_UPDATE_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private int executeKK_T_RNKI_FILE_CTRL_CK_UPDATE_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
return db_KK_T_RNKI_FILE_CTRL.executeBySqlDefine(paramList, KK_T_RNKI_FILE_CTRL_CK_UPDATE_001);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 指示書番号 SJISHO_NO * 指示書内容枝番 SJISHO_NAIYO_SEQ * 処理コード TRN_CD * 対象テーブルＩＤ TRGT_TABLE_ID * エラー回数 ERR_CNT * 処理対象ＳＹＳＩＤ TRAN_TRGT_SYSID * 結果フラグ RSLT_FLG * パラメータ有効数 PARAMETER_YK_CNT * パラメータ１ PARAMETER_1 * パラメータ２ PARAMETER_2 * パラメータ３ PARAMETER_3 * パラメータ４ PARAMETER_4 * パラメータ５ PARAMETER_5 * パラメータ６ PARAMETER_6 * パラメータ７ PARAMETER_7 * パラメータ８ PARAMETER_8 * パラメータ９ PARAMETER_9 * パラメータ１０ PARAMETER_10 * パラメータ１１ PARAMETER_11 * パラメータ１２ PARAMETER_12 * パラメータ１３ PARAMETER_13 * パラメータ１４ PARAMETER_14 * パラメータ１５ PARAMETER_15 * パラメータ１６ PARAMETER_16 * パラメータ１７ PARAMETER_17 * パラメータ１８ PARAMETER_18 * パラメータ１９ PARAMETER_19 * パラメータ２０ PARAMETER_20 * パラメータ２１ PARAMETER_21 * パラメータ２２ PARAMETER_22 * パラメータ２３ PARAMETER_23 * パラメータ２４ PARAMETER_24 * パラメータ２５ PARAMETER_25 * パラメータ２６ PARAMETER_26 * パラメータ２７ PARAMETER_27 * パラメータ２８ PARAMETER_28 * パラメータ２９ PARAMETER_29 * パラメータ３０ PARAMETER_30 * パラメータ３１ PARAMETER_31 * パラメータ３２ PARAMETER_32 * パラメータ３３ PARAMETER_33 * パラメータ３４ PARAMETER_34 * パラメータ３５ PARAMETER_35 * パラメータ３６ PARAMETER_36 * パラメータ３７ PARAMETER_37 * パラメータ３８ PARAMETER_38 * パラメータ３９ PARAMETER_39 * パラメータ４０ PARAMETER_40 * パラメータ４１ PARAMETER_41 * パラメータ４２ PARAMETER_42 * パラメータ４３ PARAMETER_43 * パラメータ４４ PARAMETER_44 * パラメータ４５ PARAMETER_45 * パラメータ４６ PARAMETER_46 * パラメータ４７ PARAMETER_47 * パラメータ４８ PARAMETER_48 * パラメータ４９ PARAMETER_49 * パラメータ５０ PARAMETER_50 * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG *
* @param setParam 設定項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCK_T_SJISHO_PKINSERT(Object[] setParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("SJISHO_NO", setParam[0]); setMap.setValue("SJISHO_NAIYO_SEQ", setParam[1]); setMap.setValue("TRN_CD", setParam[2]); setMap.setValue("TRGT_TABLE_ID", setParam[3]); setMap.setValue("ERR_CNT", setParam[4]); setMap.setValue("TRAN_TRGT_SYSID", setParam[5]); setMap.setValue("RSLT_FLG", setParam[6]); setMap.setValue("PARAMETER_YK_CNT", setParam[7]); setMap.setValue("PARAMETER_1", setParam[8]); setMap.setValue("PARAMETER_2", setParam[9]); setMap.setValue("PARAMETER_3", setParam[10]); setMap.setValue("PARAMETER_4", setParam[11]); setMap.setValue("PARAMETER_5", setParam[12]); setMap.setValue("PARAMETER_6", setParam[13]); setMap.setValue("PARAMETER_7", setParam[14]); setMap.setValue("PARAMETER_8", setParam[15]); setMap.setValue("PARAMETER_9", setParam[16]); setMap.setValue("PARAMETER_10", setParam[17]); setMap.setValue("PARAMETER_11", setParam[18]); setMap.setValue("PARAMETER_12", setParam[19]); setMap.setValue("PARAMETER_13", setParam[20]); setMap.setValue("PARAMETER_14", setParam[21]); setMap.setValue("PARAMETER_15", setParam[22]); setMap.setValue("PARAMETER_16", setParam[23]); setMap.setValue("PARAMETER_17", setParam[24]); setMap.setValue("PARAMETER_18", setParam[25]); setMap.setValue("PARAMETER_19", setParam[26]); setMap.setValue("PARAMETER_20", setParam[27]); setMap.setValue("PARAMETER_21", setParam[28]); setMap.setValue("PARAMETER_22", setParam[29]); setMap.setValue("PARAMETER_23", setParam[30]); setMap.setValue("PARAMETER_24", setParam[31]); setMap.setValue("PARAMETER_25", setParam[32]); setMap.setValue("PARAMETER_26", setParam[33]); setMap.setValue("PARAMETER_27", setParam[34]); setMap.setValue("PARAMETER_28", setParam[35]); setMap.setValue("PARAMETER_29", setParam[36]); setMap.setValue("PARAMETER_30", setParam[37]); setMap.setValue("PARAMETER_31", setParam[38]); setMap.setValue("PARAMETER_32", setParam[39]); setMap.setValue("PARAMETER_33", setParam[40]); setMap.setValue("PARAMETER_34", setParam[41]); setMap.setValue("PARAMETER_35", setParam[42]); setMap.setValue("PARAMETER_36", setParam[43]); setMap.setValue("PARAMETER_37", setParam[44]); setMap.setValue("PARAMETER_38", setParam[45]); setMap.setValue("PARAMETER_39", setParam[46]); setMap.setValue("PARAMETER_40", setParam[47]); setMap.setValue("PARAMETER_41", setParam[48]); setMap.setValue("PARAMETER_42", setParam[49]); setMap.setValue("PARAMETER_43", setParam[50]); setMap.setValue("PARAMETER_44", setParam[51]); setMap.setValue("PARAMETER_45", setParam[52]); setMap.setValue("PARAMETER_46", setParam[53]); setMap.setValue("PARAMETER_47", setParam[54]); setMap.setValue("PARAMETER_48", setParam[55]); setMap.setValue("PARAMETER_49", setParam[56]); setMap.setValue("PARAMETER_50", setParam[57]); setMap.setValue("ADD_DTM", setParam[58]); setMap.setValue("ADD_OPEACNT", setParam[59]); setMap.setValue("UPD_DTM", setParam[60]); setMap.setValue("UPD_OPEACNT", setParam[61]); setMap.setValue("DEL_DTM", setParam[62]); setMap.setValue("DEL_OPEACNT", setParam[63]); setMap.setValue("MK_FLG", setParam[64]); // DBアクセスを実行します db_CK_T_SJISHO.insertByPrimaryKeys(setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }