*
* @author FJ
*/
public class JBSbatKKKoshumoTlnRirekiHkn extends JBSbatBusinessService
{
/** 年月日時分秒最大値*/
// ST1-2012-0000494 2012/09/12 ADD START
//private static final String DATETIME_MAXVALUE = "20991231235959999";
private static final String DATETIME_MAXVALUE = "20991231000000000";
// ST1-2012-0000494 2012/09/12 ADD END
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(公衆網通話実績)*/
private static final String D_TBL_NAME_KK_T_KOSHUMO_TW_JSK = "KK_T_KOSHUMO_TW_JSK";
/** SQL定義キー(KK_SELECT_002)*/
private static final String KK_T_KOSHUMO_TW_JSK_KK_SELECT_002 = "KK_SELECT_002";
/** SQL定義キー(KK_SELECT_003)*/
private static final String KK_T_KOSHUMO_TW_JSK_KK_SELECT_003 = "KK_SELECT_003";
/** SQL定義キー(KK_SELECT_004)*/
private static final String KK_T_KOSHUMO_TW_JSK_KK_SELECT_004 = "KK_SELECT_004";
/** テーブルアクセスクラス(公衆網通話実績)*/
private JBSbatSQLAccess db_KK_T_KOSHUMO_TW_JSK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_KOSHUMO_TW_JSK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KOSHUMO_TW_JSK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
String voipUserId = JBSbatStringUtil.trim(inMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_USER_ID));
String voipTelno = JBSbatStringUtil.trim(inMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_TELNO));
String svcKeiNo = JBSbatStringUtil.trim(inMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.SVC_KEI_NO));
// ST1-2012-0000494 MOD START
String twStaDtm = JBSbatStringUtil.trim(inMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.TW_STA_DTM));
//String twEndDtm = JBSbatStringUtil.trim(inMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.TW_END_DTM));
// ST1-2012-0000494 MOD END
// ＶＯＩＰユーザーＩＤ変更後解約レコードを検索
Object[] select02WhereParam = {
svcKeiNo,
voipUserId,
voipTelno,
// ST1-2012-0000494 MOD START
twStaDtm
//twEndDtm
// ST1-2012-0000494 MOD END
};
executeKK_T_KOSHUMO_TW_JSK_KK_SELECT_002(select02WhereParam);
JBSbatCommonDBInterface select02Map = db_KK_T_KOSHUMO_TW_JSK.selectNext();
if (select02Map != null)
{
// 変更登録レコード登録処理
insertChgAddRec(select02Map);
}
// 公衆網電話番号変更後解約レコードを検索
Object[] select03WhereParam = {
svcKeiNo,
voipUserId,
voipTelno,
// ST1-2012-0000494 MOD START
twStaDtm
//twEndDtm
// ST1-2012-0000494 MOD END
};
executeKK_T_KOSHUMO_TW_JSK_KK_SELECT_003(select03WhereParam);
JBSbatCommonDBInterface select03Map = db_KK_T_KOSHUMO_TW_JSK.selectNext();
if (select03Map != null)
{
// 変更登録レコード登録処理
insertChgAddRec(select03Map);
}
return new JBSbatOutputItem();
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_KOSHUMO_TW_JSK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 * VoIPユーザーID * VoIP電話番号 * 通話開始年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KOSHUMO_TW_JSK_KK_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());
// DBアクセスを実行します
db_KK_T_KOSHUMO_TW_JSK.selectBySqlDefine(paramList, KK_T_KOSHUMO_TW_JSK_KK_SELECT_002);
}
/**
* SQLKEY(KK_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 * VoIPユーザーID * VoIP電話番号 * 通話開始年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KOSHUMO_TW_JSK_KK_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());
// DBアクセスを実行します
db_KK_T_KOSHUMO_TW_JSK.selectBySqlDefine(paramList, KK_T_KOSHUMO_TW_JSK_KK_SELECT_003);
}
/**
* SQLKEY(KK_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 * VoIPユーザーID * VoIP電話番号 * 通話開始年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KOSHUMO_TW_JSK_KK_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_KK_T_KOSHUMO_TW_JSK.selectBySqlDefine(paramList, KK_T_KOSHUMO_TW_JSK_KK_SELECT_004);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 集計対象年月日 SHUK_TG_YMD * オプションサービス契約番号 OP_SVC_KEI_NO * ＶＯＩＰユーザーＩＤ VOIP_USER_ID * ＶＯＩＰ電話番号 VOIP_TELNO * サービス契約番号 SVC_KEI_NO * 通話開始年月日時分秒 TW_STA_DTM * 通話終了年月日時分秒 TW_END_DTM * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG *
* @param setParam 設定項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KOSHUMO_TW_JSK_PKINSERT(Object[] setParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("SHUK_TG_YMD", setParam[0]);
setMap.setValue("OP_SVC_KEI_NO", setParam[1]);
setMap.setValue("VOIP_USER_ID", setParam[2]);
setMap.setValue("VOIP_TELNO", setParam[3]);
setMap.setValue("KOSHUMO_TW_JSK_SKSI_DTM", setParam[4]);
setMap.setValue("TW_STA_DTM", setParam[5]);
setMap.setValue("TW_END_DTM", setParam[6]);
setMap.setValue("SVC_KEI_NO", setParam[7]);
setMap.setValue("ADD_DTM", setParam[8]);
setMap.setValue("ADD_OPEACNT", setParam[9]);
setMap.setValue("UPD_DTM", setParam[10]);
setMap.setValue("UPD_OPEACNT", setParam[11]);
setMap.setValue("DEL_DTM", setParam[12]);
setMap.setValue("DEL_OPEACNT", setParam[13]);
setMap.setValue("MK_FLG", setParam[14]);
setMap.setValue("ADD_UNYO_YMD", setParam[15]);
setMap.setValue("ADD_TRN_ID", setParam[16]);
setMap.setValue("UPD_UNYO_YMD", setParam[17]);
setMap.setValue("UPD_TRN_ID", setParam[18]);
setMap.setValue("DEL_UNYO_YMD", setParam[19]);
setMap.setValue("DEL_TRN_ID", setParam[20]);
// DBアクセスを実行します
db_KK_T_KOSHUMO_TW_JSK.insertByPrimaryKeys(setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 変更登録レコードを登録します。
*
* 処理フロー
*
* 1.引数の公衆網通話実績レコードに対する変更登録レコードを検索します。*
* * 2.変更後登録レコードが存在しなければ、公衆網通話実績登録処理を呼びます。
*
* @param koshumoMap 公衆網通話実績マップ
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void insertChgAddRec(JBSbatCommonDBInterface koshumoMap) throws Exception
{
String voipUserId = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_USER_ID));
String voipTelno = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_TELNO));
String svcKeiNo = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.SVC_KEI_NO));
String twStaDtm = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.TW_STA_DTM));
// 変更登録レコードを検索
Object[] select04WhereParam = {
svcKeiNo,
voipUserId,
voipTelno,
twStaDtm
};
executeKK_T_KOSHUMO_TW_JSK_KK_SELECT_004(select04WhereParam);
JBSbatCommonDBInterface select04Map = db_KK_T_KOSHUMO_TW_JSK.selectNext();
if (select04Map == null)
{
// 公衆網通話実績を登録
insertKoshumoTwJsk(koshumoMap);
}
}
/**
* 公衆網通話実績を登録します。
*
* 処理フロー
*
* 1.引数で設定項目の配列を作ります。*
* * 2.公衆網通話実績全項目登録処理を実行します。
*
* @param koshumoMap 公衆網通話実績マップ * @throws Exception 業務サービス内で発生した例外全般。 */ private void insertKoshumoTwJsk(JBSbatCommonDBInterface koshumoMap) throws Exception { // 入力マップより情報を取得 String shukTgYmd = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.SHUK_TG_YMD)); String opSvcKeiNo = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.OP_SVC_KEI_NO)); String voipUserId = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_USER_ID)); String voipTelno = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.VOIP_TELNO)); String svcKeiNo = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.SVC_KEI_NO)); String twStaDtm = JBSbatStringUtil.trim(koshumoMap.getString(JBSbatKK_T_KOSHUMO_TW_JSK.TW_STA_DTM)); String[] setParam = { shukTgYmd, // 集計対象年月日 opSvcKeiNo, // オプションサービス契約番号 voipUserId, // VoIPユーザーID voipTelno, // VoIP電話番号 // ST1-2012-0000494 MOD START JCCbatGetSystemDateUtil.getSystemDateTime().get(JCCbatGetSystemDateUtil.KEY_YYYYMMDDHHMMSS_SSS), // 公衆網通話実績作成年月日 //svcKeiNo, // サービス契約番号 twStaDtm, // 通話開始年月日時分秒 DATETIME_MAXVALUE, // 通話終了年月日時分秒 svcKeiNo, // サービス契約番号 // ST1-2012-0000494 MOD END null, // 登録年月日時分秒 null, // 登録オペレータアカウント null, // 更新年月日時分秒 null, // 更新オペレータアカウント null, // 削除年月日時分秒 null, // 削除オペレータアカウント null, // 無効フラグ // ST1-2012-0000494 ADD START null, // 登録運用年月日 null, // 登録処理ID null, // 更新運用年月日 null, // 更新処理ID null, // 削除運用年月日 null // 削除処理ID // ST1-2012-0000494 ADD END }; executeKK_T_KOSHUMO_TW_JSK_PKINSERT(setParam); } }