*
* @author 富士通
*/
public class JBSbatAC050UseStp extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(超過通知管理)*/
private static final String D_TBL_NAME_AC_T_CN050AP_TWRCKTC = "AC_T_CN050AP_TWRCKTC";
/** テーブル(コンテンツ契約内訳)*/
private static final String D_TBL_NAME_CN_T_CONT_KEI_UCWK = "CN_T_CONT_KEI_UCWK";
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** SQL定義キー(AC_SELECT_003)*/
private static final String AC_T_CN050AP_TWRCKTC_AC_SELECT_003 = "AC_SELECT_003";
/** SQL定義キー(AC_SELECT_001)*/
private static final String CN_T_CONT_KEI_UCWK_AC_SELECT_001 = "AC_SELECT_001";
/** SQL定義キー(AC_SELECT_004)*/
private static final String CK_T_CUST_AC_SELECT_004 = "AC_SELECT_004";
/** SQL定義キー(AC_UPDATE_002)*/
private static final String AC_T_CN050AP_TWRCKTC_AC_UPDATE_002 = "AC_UPDATE_002";
/** SQL定義キー(AC_INSERT_001)*/
private static final String CN_T_CONT_KEI_UCWK_AC_INSERT_001 = "AC_INSERT_001";
/** テーブルアクセスクラス(超過通知管理)*/
private JBSbatSQLAccess db_AC_T_CN050AP_TWRCKTC = null;
/** テーブルアクセスクラス(コンテンツ契約内訳)*/
private JBSbatSQLAccess db_CN_T_CONT_KEI_UCWK = null;
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 050超過通知種別コード(利用停止) */
public static final String CN050AP_OVER_TCH_SBT_CD_USE_STP = "4";
/** ユースケースID */
private static final String USECASE_ID = "CNSV0048";
/** 050電話利用停止・利用停止解除依頼(ECNA0110001) */
private static final String SC_TITLE_CNSV004802 = "CNSV004802SC";
/** 機能コード */
private static final String FUNC_CD = "1";
/** ステータス設定(利用停止)*/
private static final String STATUS_SETTE_USE_STP = "1";
/** コード区分(音声のみ)*/
private static final String ONLY_VOICE = "1";
/** リターンコード(正常終了)*/
private static final String RETURN_CODE_SUCCESS = "000";
/** 050アプリサービス利用状態コード(利用停止) */
public static final String CN050APSV_USE_STAT_CD_USE_STP = "3";
/** ファイル連携先ディレクトリ定義キー */
private static final String CR_FILE_DIR_KEY = "CR_TWS_RK_FILE_DIR";
/** ファイル連携先ディレクトリ(フルパス) */
private String crFileDir = null;
/** ダブルクォーテーション*/
private static final String S_DUBLLEQ = "\"";
/** 改行コード */
private static final String RETURN_CODE = "\r\n";
/** ファイル名(共通部) */
private static final String FILE_NAME = "CASE_050TUWASTP_";
/** ファイル出力文字列(加入者) */
public static final String KOKYAKU_TYPE = "加入者";
/** ファイル出力文字列(クローズ) */
public static final String FILE_CLOSE = "クローズ";
/** ファイル出力文字列(処理中) */
public static final String FILE_TRN = "処理中";
/** ファイル出力文字列(OTHER SYST) */
public static final String WORK_PARAM_ID_KK_TAIORRK_ADD_USER = "OTHER SYST";
/** ファイル出力文字列(他システム) */
public static final String FILE_TSYS = "他システム";
/** ファイル出力文字列(タイトル) */
public static final String FILE_TITLE = "【LaLa Call】通話料金の上限金額超過による利用停止";
/** CASEファイル出力件数 */
private int outmapCnt = 0;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_AC_T_CN050AP_TWRCKTC = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_CN050AP_TWRCKTC);
db_CN_T_CONT_KEI_UCWK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_CONT_KEI_UCWK);
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public void execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// 050番号利用停止対象者抽出の実行
JBSbatCommonDBInterface Cn050ApUseStpTrgtList = getCn050ApUseStpTrgt();
// 050番号利用停止の実行
doCNSV0048(Cn050ApUseStpTrgtList);
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_T_CN050AP_TWRCKTC.close();
db_CN_T_CONT_KEI_UCWK.close();
db_CK_T_CUST.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AC_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 通話利用年月 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_CN050AP_TWRCKTC_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());
// DBアクセスを実行します
db_AC_T_CN050AP_TWRCKTC.selectBySqlDefine(paramList, AC_T_CN050AP_TWRCKTC_AC_SELECT_003);
}
/**
* SQLKEY(CN_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID * 050電話番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_CONT_KEI_UCWK_AC_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_CONT_KEI_UCWK.selectBySqlDefine(paramList, CN_T_CONT_KEI_UCWK_AC_SELECT_001);
}
/**
* SQLKEY(AC_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID * 予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_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());
// DBアクセスを実行します
db_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_AC_SELECT_004);
}
/**
* SQLKEY(AC_UPDATE_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 超過通知年月日 * 050電話番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_CN050AP_TWRCKTC_AC_UPDATE_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_T_CN050AP_TWRCKTC.executeBySqlDefine(paramList, AC_T_CN050AP_TWRCKTC_AC_UPDATE_002);
}
/**
* SQLKEY(AC_INSERT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 050アプリサービス利用状態コード * 設備利用停止年月日 * 050電話番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_CONT_KEI_UCWK_AC_INSERT_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());
// DBアクセスを実行します
db_CN_T_CONT_KEI_UCWK.executeBySqlDefine(paramList, CN_T_CONT_KEI_UCWK_AC_INSERT_001);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 050番号利用停止の実行
* @throws Exception
*/
private JBSbatCommonDBInterface getCn050ApUseStpTrgt() throws Exception
{
// 050番号利用停止対象者の抽出
/**------------------------------------------------------------------------------------------------
* バインド変数設定
*-------------------------------------------------------------------------------------------------*/
Object[] cn050ApUseStp = new Object[]
{
super.opeDate.substring(0, 6),
CN050AP_OVER_TCH_SBT_CD_USE_STP,
"20991231"
};
/**------------------------------------------------------------------------------------------------
* SQL実行
*-------------------------------------------------------------------------------------------------*/
// 超過通知管理スキーマ検索実行
this.executeAC_T_CN050AP_TWRCKTC_AC_SELECT_003(cn050ApUseStp);
// 検索結果の取得
JBSbatCommonDBInterface dbCn050ApUseStpTrgtInf = db_AC_T_CN050AP_TWRCKTC.selectNext();
return dbCn050ApUseStpTrgtInf;
}
/**
* CNSV0048(050番号利用停止・利用停止解除依頼)のサービスを実行します。
*
* @param dbCn050ApUseStpTrgtInf 050番号利用停止対象者
* @throws Exception
*/
private void doCNSV0048(JBSbatCommonDBInterface dbCn050ApUseStpTrgtInf) throws Exception
{
// 格納先ディレクトリ情報を取得する
this.crFileDir = JKKBatCommon.getApplicationConst(CR_FILE_DIR_KEY) + "/";
// ファイル名に使用する日時情報(yyyymmddhhmmss)を取得する
String sSysData = JKKBatCommon.getSysDateTime().substring(0, 14);
// CASECSVファイル
String caseCvsFile = this.crFileDir + FILE_NAME + sSysData + ".CSV";
// CASECSVファイル
JBSbatBusinessFileUtil caseCvsFileObj = null;
// CASECSVファイルを生成する。
caseCvsFileObj = JCCBatCommon.createBusinessFileUtil(caseCvsFile, JKKBatConst.SJIS, RETURN_CODE, JKKBatConst.CONMA);
// CASE件数
String caseCntFile = this.crFileDir + FILE_NAME + JKKBatCommon.getSysDateTime().substring(0, 14) + "_CNT.TXT";
// CASEフラグファイル
String caseFlgFile = this.crFileDir + FILE_NAME + JKKBatCommon.getSysDateTime().substring(0, 14) + "_FTP.FLG";
// CASE件数
JBSbatBusinessFileUtil caseCntFileObj = null;
// CASEフラグファイル
JBSbatBusinessFileUtil caseFlgFileObj = null;
// 検索結果がなくなるまでループを行う
while(dbCn050ApUseStpTrgtInf != null)
{
// SYSIDと050電話番号を設定
String sysid = dbCn050ApUseStpTrgtInf.getString(JBSbatAC_T_CN050AP_TWRCKTC.SYSID);
String cn050Ap_Telno = dbCn050ApUseStpTrgtInf.getString(JBSbatAC_T_CN050AP_TWRCKTC.N_050_TELNO);
/**------------------------------------------------------------------------------------------------
* バインド変数設定
*-------------------------------------------------------------------------------------------------*/
Object[] contKei = new Object[]
{
sysid,
cn050Ap_Telno
};
/**------------------------------------------------------------------------------------------------
* SQL実行
*-------------------------------------------------------------------------------------------------*/
// コンテンツ契約内訳スキーマ検索実行
this.executeCN_T_CONT_KEI_UCWK_AC_SELECT_001(contKei);
// 検索結果の取得
JBSbatCommonDBInterface dbCn050ApUseStpTrgtCnkeiNo = db_CN_T_CONT_KEI_UCWK.selectNext();
// コンテンツ契約内訳にSYSID、050電話番号に一致するコンテンツ契約番号が存在するとき
if(dbCn050ApUseStpTrgtCnkeiNo != null)
{
String contKeiNo = dbCn050ApUseStpTrgtCnkeiNo.getString(JBSbatCN_T_CONT_KEI_UCWK.CONT_KEI_NO);
// ●サービス呼び出し処理
// ユースケースID格納用マップを生成
HashMap
* getParamFromXml("LKA11020_RECEIVE", "PROCESS_DIV");
*
* @param map マップ
* @param allKeys キー名
* @return 値
*/
@SuppressWarnings("unchecked")
public static Object getParamFromMap(Map map, String...allKeys)
{
Map nowMap = map;
Object returnVal = null;
for (int i = 0; i < allKeys.length; i++)
{
String key = allKeys[i];
int idx = -1;
if (key.matches("[a-zA-Z0-9_\\-]+\\[[0-9]+\\]"))
{
idx = new Integer(key.replaceFirst("^[a-zA-Z0-9_\\-]+\\[", "").replace("]", ""));
key = key.replaceFirst("\\[[0-9]+\\]", "");
}
if (nowMap.containsKey(key))
{
Object val = nowMap.get(key);
if ((val instanceof List) && (idx >= 0))
{
List nowList = (List)val;
val = nowList.get(idx);
}
if (val instanceof Map)
{
nowMap = (Map)val;
}
if (i == allKeys.length - 1)
{
returnVal = val;
}
}
else
{
return null;
}
}
return returnVal;
}
/**
* CASEファイルの出力処理
*
* @param dbEoID EOID
* @return 処理結果（true:正常終了、false:エラー）
* @throws Exception
*/
private void setOutFileData(JBSbatCommonDBInterface dbCustInfo, JBSbatBusinessFileUtil caseCvsFileObj) throws Exception
{
// CASEファイル出力リスト
ArrayList