*
* @author 富士通
*/
public class JBSbatSCEMIdoIfDataDslCss extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(モバイルオーダ)*/
private static final String D_TBL_NAME_SC_T_MOBILE_ORDER = "SC_T_MOBILE_ORDER";
/** テーブル(ＥＭオーダ送受信情報)*/
private static final String D_TBL_NAME_SC_T_EM_ODR_SRINF = "SC_T_EM_ODR_SRINF";
/** SQL定義キー(SC_SELECT_003)*/
private static final String SC_T_MOBILE_ORDER_SC_SELECT_003 = "SC_SELECT_003";
/** SQL定義キー(SC_UPDATE_005)*/
private static final String SC_T_EM_ODR_SRINF_SC_UPDATE_005 = "SC_UPDATE_005";
/** SQL定義キー(SC_UPDATE_003)*/
private static final String SC_T_MOBILE_ORDER_SC_UPDATE_003 = "SC_UPDATE_003";
/** テーブルアクセスクラス(モバイルオーダ)*/
private JBSbatSQLAccess db_SC_T_MOBILE_ORDER = null;
/** テーブルアクセスクラス(ＥＭオーダ送受信情報)*/
private JBSbatSQLAccess db_SC_T_EM_ODR_SRINF = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_SC_T_MOBILE_ORDER = new JBSbatSQLAccess(commonItem, D_TBL_NAME_SC_T_MOBILE_ORDER);
db_SC_T_EM_ODR_SRINF = new JBSbatSQLAccess(commonItem, D_TBL_NAME_SC_T_EM_ODR_SRINF);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
logPrint.printDebugLog("JBSbatSCEMIdoIfDataDslCss#execute START");
// 出力共通電文を生成する
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// 入出力インターフェースオブジェクトを生成
JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap();
// 抽出結果取得用オブジェクト
JBSbatCommonDBInterface map = new JBSbatCommonDBInterface();
// システム日付の取得
String sysDateTimeStamp = JCCBatCommon.getSysDateTimeStamp();
// 更新オペレータアカウント取得
String upAccount = commonItem.getBatchUserId();
// モバイルオーダテーブルのロック
String[] param1 = {inMap.getString("SOD_RENKEI_SEQ")};
executeSC_T_MOBILE_ORDER_SC_SELECT_003(param1);
// モバイルオーダテーブルにレコードが存在しなければ、エラーとする
map = db_SC_T_MOBILE_ORDER.selectNext();
if(null == map)
{
super.logPrint.printDebugLog("モバイルオーダテーブルにレコードが存在しません。");
throw new JBSbatBusinessException("ESCB0100CE",
new String[] {inMap.getString("SVC_KEI_NO"),
inMap.getString("EM_KEISHA_CD"),
"SC_T_MOBILE_ORDER"});
}
// データ部の出力開始
//項目を設定
outmap.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); // EMレコード種別コード:データ部
outmap.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); // サービス契約者コード
outmap.setString("YOBI_2", ""); // 予備2 Null
outmap.setString("YOBI_3", ""); // 予備3 Null
outmap.setString("YOBI_4", ""); // 予備4 Null
outmap.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); // EM契約者コード
outmap.setString("YOBI_5", ""); // 予備5 Null
outmap.setString("EM_SET_YMD_2", ""); // EM設定年月日2ではなく、Nullを設定
outmap.setString("EM_SET_YMD_3", ""); // EM設定年月日3ではなく、Nullを設定
outmap.setString("YOBI_6", ""); // 予備6 Null
outmap.setString("UK_TRAN_RSLT_CD", ""); // 受付処理結果コード Null
outmap.setString("TRN_DATE", ""); // 異動日付 Null
outmap.setString("TRN_TIME", ""); // 異動時刻 Null
outmap.setString("YOBI_7", ""); // 予備7 Null
// 出力フラグを設定
outmap.setOutFlg(true);
// 出力共通電文に入出力インターフェースを設定する
outputBean.addOutMapList(outmap);
// モバイルオーダテーブルの更新
String[] param2 =
{
JSCStrConstant.SOD_STAT_ACK_WAIT, // モバイルオーダステータス:応答待ち(モバイルオーダステータスとSODステータスは同じ意味)
JSCStrConstant.SOD_RNKI_STAT_WAIT_RES, // SOD業務連携ステータス:業務連携待ちSOD応答未
sysDateTimeStamp, // 更新年月日時分秒ミリ秒
upAccount, // 更新オペレータアカウント
inMap.getString("SOD_RENKEI_SEQ") // SOD連携通番
};
executeSC_T_MOBILE_ORDER_SC_UPDATE_003(param2);
// EMオーダ送受信情報の更新
String[] param3 =
{
JSCStrConstant.SOD_STAT_ACK_WAIT, // SODステータス:応答待ち
sysDateTimeStamp, // SOD投入年月日時分秒ミリ秒
JSCStrConstant.SOD_RNKI_STAT_WAIT_RES, // SOD業務連携ステータス:業務連携待ちSOD応答未
sysDateTimeStamp, // 更新年月日時分秒ミリ秒
upAccount, // 更新オペレータアカウント
inMap.getString("SOD_RENKEI_SEQ") // SOD連携通番
};
executeSC_T_EM_ODR_SRINF_SC_UPDATE_005(param3);
logPrint.printDebugLog("JBSbatSCEMIdoIfDataDslCss#execute END");
return outputBean; // ファイルを出力
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
// 入力行数の取得
int i = commonItem.getInputCount();
// ヘッダー部の出力
outHeader(JSCStrConstant.EM_JGYOSHA_SKBT_CD, JSCStrConstant.EM_DSL_HEADER, commonItem.getFreeItem());
if(0 < i)
{
// トレーラ部の出力
outTrailer(i, JSCStrConstant.EM_DSL_TRAILER, commonItem.getFreeItem());
}
else
{
// トレーラ部の出力
outTrailer(0, JSCStrConstant.EM_DSL_TRAILER, commonItem.getFreeItem());
super.logPrint.printLogMsg("ESCB0080AI", "EM異動依頼(解約)");
}
super.commit();
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_SC_T_MOBILE_ORDER.close();
db_SC_T_EM_ODR_SRINF.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(SC_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * モバイルオーダ番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeSC_T_MOBILE_ORDER_SC_SELECT_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_SC_T_MOBILE_ORDER.selectBySqlDefine(paramList, SC_T_MOBILE_ORDER_SC_SELECT_003);
}
/**
* SQLKEY(SC_UPDATE_005)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SODステータス * SOD投入年月日 * SOD業務連携ステータス * 更新日時 * 更新オペレータ * SOD連携通番 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeSC_T_EM_ODR_SRINF_SC_UPDATE_005(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());
// DBアクセスを実行します
db_SC_T_EM_ODR_SRINF.executeBySqlDefine(paramList, SC_T_EM_ODR_SRINF_SC_UPDATE_005);
}
/**
* SQLKEY(SC_UPDATE_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * モバイルオーダステータス * SOD業務連携ステータス * 更新日時 * 更新オペレータアカウント * モバイルオーダ番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeSC_T_MOBILE_ORDER_SC_UPDATE_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());
paramList.setValue(param[4].toString());
// DBアクセスを実行します
db_SC_T_MOBILE_ORDER.executeBySqlDefine(paramList, SC_T_MOBILE_ORDER_SC_UPDATE_003);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* EM異動依頼(解約)ファイルのヘッダー部出力を行います。
*
* 処理フロー
*
* 1.ヘッダー部の出力を行います。*
*
* @param s EM事業者識別コード
* @param outFileName ファイル出力名
* @param outFilePath パス名
* @return なし
* @exception JBSbatBusinessException 業務サービス内で発生した例外全般。
*/
private void outHeader(String s, String outFileName, String outFilePath) throws JBSbatBusinessException
{
StringBuffer outString = new StringBuffer(29);
// レコード種別を追加
outString.append(JSCStrConstant.EM_RECORD_TYPE_HEADER);
outString.append('\t');
// モバイル要求種別コードを追加
outString.append(JSCStrConstant.MOBILE_YOKYU_DSL_SHIN);
outString.append('\t');
// ファイル作成年月日を追加
outString.append(commonItem.getOpeDate());
outString.append('\t');
// EM事業者識別コードを追加
outString.append(s);
outString.append('\t');
// 予備1の出力なし(Nullなので何も出力しない)
String outFile = outFilePath + outFileName;
try
{
// PGReliefの規約に従っていないが、
// バッチから渡される引数を使用するので
// 問題ない
FileWriter file = new FileWriter(outFile);
BufferedWriter buf = new BufferedWriter(file);
PrintWriter writer = new PrintWriter(buf);
writer.println(outString);
writer.close(); // ファイルクローズ
}
catch (IOException e)
{
super.logPrint.printDebugLog("出力ファイルヘッダー部書き込み失敗");
throw new JBSbatBusinessException("ESCB0030CE", new String[] {outFile});
}
}
/**
* EM異動依頼(解約)ファイルのトレーラ部出力を行います。
*
* 処理フロー
*
* 1.トレーラ部の出力を行います。*
*
* @param idx レコード件数 * @param outFileName ファイル出力名。 * @param outFilePath パス名 * @return なし。 * @throws JBSbatBusinessException 業務サービス内で発生した例外全般。 */ private void outTrailer(int idx, String outFileName, String outFilePath) throws JBSbatBusinessException { StringBuffer outString = new StringBuffer(15); // レコード種別を追加 outString.append(JSCStrConstant.EM_RECORD_TYPE_TRAILER); // 区切り文字(タブ)を追加 outString.append('\t'); // レコード件数を追加 String s = Integer.toString(idx); // 件数を文字列化 outString.append(s); // 区切り文字(タブを追加) outString.append('\t'); // 予備8の出力(なし) String outFile = outFilePath + outFileName; try { // PGReliefの規約に従っていないが、 // バッチから渡される引数を使用するので // 問題ない FileWriter file = new FileWriter(outFile); BufferedWriter buf = new BufferedWriter(file); PrintWriter writer = new PrintWriter(buf); writer.println(outString); writer.close(); // ファイルクローズ } catch (IOException e) { super.logPrint.printDebugLog("出力ファイルトレーラ部書き込み失敗"); throw new JBSbatBusinessException("ESCB0030CE", new String[] {outFile}); } } }