*
* @author 富士通
*/
public class JBSbatACTelnoGuideUseChrgInfoTrkmProcReqUpd extends JBSbatBusinessService
{
/** テーブル(電子ファイル管理)*/
private static final String D_TBL_NAME_CC_T_EFILE_KANRI = "CC_T_EFILE_KANRI";
/** テーブル(ダウンロードファイル管理)*/
private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";
/** SQL定義キー(AC_SELECT_001)*/
private static final String CC_T_EFILE_KANRI_AC_SELECT_001 = "AC_SELECT_001";
/** テーブルアクセスクラス(電子ファイル管理)*/
private JBSbatSQLAccess db_CC_T_EFILE_KANRI = null;
/** テーブルアクセスクラス(ダウンロードファイル管理)*/
private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
/** 電話番号案内課金情報取込処理結果ファイル.処理管理番号 */
private String trnKanriNo_Dlyd = null;
/** 電話番号案内課金情報取込処理結果ファイル.処理管理番号 */
private String trnKanriNo_1 = null;
/** 電話番号案内課金情報取込処理結果ファイル.ファイル絶対パス */
private String filePath_1 = null;
/** 電話番号案内課金情報取込処理結果ファイル.データ件数 */
private String dataCount_1 = null;
/** 電話番号案内課金情報取込処理結果ファイル.ファイル名 */
private String fileNm_1 = null;
/** 電話番号案内課金エラー情報ファイル.処理管理番号 */
private String trnKanriNo_2 = null;
/** 電話番号案内課金エラー情報ファイル.ファイル絶対パス */
private String filePath_2 = null;
/** 電話番号案内課金エラー情報ファイル.データ件数 */
private String dataCount_2 = null;
/** 電話番号案内課金エラー情報ファイル.ファイル名 */
private String fileNm_2 = null;
/** ファイル削除年月日 */
private String fileDelYmd = null;
/** シーケンス接頭辞（ファイル番号） */
private static final String SEQ_PREFIX_SEQ_FILE_NOO = "";
/** シーケンス桁数（ファイル番号） */
private static final int SEQ_LEN_SEQ_FILE_NO = 12;
/** ファイルコード */
private static final String FILE_CD = "0000";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CC_T_EFILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_EFILE_KANRI);
db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
// フリー項目分割
String[] freeItem = super.freeItem.split(JACStrConst.FREE_DIV, -1);
this.trnKanriNo_1 = freeItem[0]; // エラーリストおよび充当結果リスト.処理管理番号
this.filePath_1 = freeItem[1]; // エラーリスト.ファイル絶対パス
this.dataCount_1 = freeItem[2]; // エラーリスト.データ件数
this.fileNm_1 = freeItem[3]; // エラーリスト.ダウンロードファイル名
this.trnKanriNo_2 = freeItem[4]; // 充当結果リスト.処理管理番号
this.filePath_2 = freeItem[5]; // 充当結果リスト.ファイル絶対パス
this.dataCount_2 = freeItem[6]; // 充当結果リスト.データ件数
this.fileNm_2 = freeItem[7]; // 充当結果リスト.ダウンロードファイル名
this.fileDelYmd = JPCDateUtil.addMonth(super.opeDate, 1); // エラーリストおよび充当結果リスト.ファイル削除年月日（運用日+1ヵ月）
//データ件数（エラーリストはヘッダが存在するため、ヘッダーの1件分をマイナスする）
int dataCountInt = 0;
if(!JCHStringUtil.isNullBlank(this.dataCount_1))
{
if(Integer.parseInt(this.dataCount_1) > 0)
{
dataCountInt = Integer.parseInt(this.dataCount_1);
dataCountInt--;
this.dataCount_1 = String.valueOf(dataCountInt);
}
}
if(!JCHStringUtil.isNullBlank(this.dataCount_2))
{
if(Integer.parseInt(this.dataCount_2) > 0)
{
dataCountInt = Integer.parseInt(this.dataCount_2);
dataCountInt--;
this.dataCount_2 = String.valueOf(dataCountInt);
}
}
assert this.trnKanriNo_Dlyd != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][trnKanriNo = " + this.trnKanriNo_Dlyd + "]") : true;
assert this.trnKanriNo_1 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][trnKanriNo = " + this.trnKanriNo_1 + "]") : true;
assert this.filePath_1 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][filePath = " + this.filePath_1 + "]") : true;
assert this.dataCount_1 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][dataCount = " + this.dataCount_1 + "]") : true;
assert this.trnKanriNo_2 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][trnKanriNo = " + this.trnKanriNo_2 + "]") : true;
assert this.filePath_2 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][filePath = " + this.filePath_2 + "]") : true;
assert this.dataCount_2 != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][dataCount = " + this.dataCount_2 + "]") : true;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
// 処理依頼番号
String dlydIrnReqNo = inMap.getString(JBSbatACIFM099.DLYD_TRN_REQ_NO);
// 処理結果コード
String dlyTrnRsltCd = inMap.getString(JBSbatACIFM099.DLYD_TRN_RSLT_CD);
// エラーリスト.電子ファイル管理番号
String eFileKnriNo = null;
// エラーリスト.世代登録年月日月日時分秒
String sedaiDate = null;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][dlydIrnReqNo=" + dlydIrnReqNo + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][dlyTrnRsltCd=" + dlyTrnRsltCd + "]");
// 電話番号案内利用課金情報取込エラーリスト.電子ファイル管理登録処理
JBSbatCommonItem arg0 = commonItem; // 業務共通電文
String arg1 = FILE_CD; // ファイルコード
String arg2 = filePath_1; // ファイルパス
String arg3 = this.fileDelYmd; // ファイル削除年月日
String[] rc_1 = JCCBatCommon.createDenshiFile(arg0, arg1, arg2, arg3);
// ログ出力
super.logPrint.printDebugLog("電子ファイル管理番号(" + rc_1[0] + ")、世代登録年月日時分秒(" + rc_1[1] + ")");
eFileKnriNo = rc_1[0]; // エラーリスト.電子ファイル管理番号
sedaiDate = rc_1[1]; // エラーリスト.世代登録年月日時分秒
// ダウンロードファイル管理スキーマ登録
insZmTDlFileKanri(this.trnKanriNo_1, eFileKnriNo, this.fileNm_1, this.filePath_1, this.dataCount_1);
JBSbatCommonItem arg4 = commonItem; // 業務共通電文
String arg5 = FILE_CD; // ファイルコード
String arg6 = filePath_2; // ファイルパス
String arg7 = this.fileDelYmd; // ファイル削除年月日
String[] rc_2 = JCCBatCommon.createDenshiFile(arg4, arg5, arg6, arg7);
// ログ出力
super.logPrint.printDebugLog("電子ファイル管理番号(" + rc_2[0] + ")、世代登録年月日時分秒(" + rc_2[1] + ")");
eFileKnriNo = rc_2[0]; // エラーリスト.電子ファイル管理番号
sedaiDate = rc_2[1]; // エラーリスト.世代登録年月日時分秒
// ダウンロードファイル管理スキーマ登録
insZmTDlFileKanri(this.trnKanriNo_2, eFileKnriNo, this.fileNm_2, this.filePath_2, this.dataCount_2);
JBSbatSQLAccess stmt = null;
try {
// ディレイド処理依頼テーブルアクセスを生成する
stmt = new JBSbatSQLAccess(commonItem,"CC_T_DLYD_TRN_REQ");
// 検索キーを設定する
JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();
dbList.setValue(dlyTrnRsltCd); // ディレイド処理依頼結果コード
if(JACStrConst.DLYD_TRN_RSLT_CD_FIN.equals(dlyTrnRsltCd)||JACStrConst.DLYD_TRN_RSLT_CD_WORK_ERR.equals(dlyTrnRsltCd)){ // ディレイド処理依頼ステータス
// 処理済を設定
dbList.setValue(JACStrConst.DLYD_TRN_STAT_TRN_ZUMI);
}else{
// 処理エラーを設定
dbList.setValue(JACStrConst.DLYD_TRN_STAT_TRN_ERR);
}
// 業務エラーの場合
if(JACStrConst.DLYD_TRN_RSLT_CD_WORK_ERR.equals(dlyTrnRsltCd))
{
dbList.setValue(rc_1[0]); // エラー電子ファイル管理番号
dbList.setValue(rc_1[1]); // エラー電子ファイル世代登録年月日時分秒
}
dbList.setValue(JCCbatGetSystemDateUtil.getSystemDateTime().get("sysDateTimeStamp")); // システム日付
dbList.setValue(commonItem.getBatchUserId()); // オペレータアカウント
dbList.setValue(dlydIrnReqNo); // 処理依頼番号
//SQL実行
if(JACStrConst.DLYD_TRN_RSLT_CD_WORK_ERR.equals(dlyTrnRsltCd)) // 引数にエラーファイルパスが入力されている場合
{
stmt.executeBySqlDefine(dbList, "CC_UPDATE_001");
}else{
stmt.executeBySqlDefine(dbList, "CC_UPDATE_002");
}
}
catch (Exception e)
{
throw new JCCbatFrameworkException( "ディレイド処理依頼取得処理で例外が発生しました" + e);
}
finally
{
if (null != stmt)
{
try {
stmt.close();
} catch (SQLException e) {
;//なにもしない
}
}
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CC_T_EFILE_KANRI.close();
db_ZM_T_DL_FILE_KANRI.close();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
* SQLKEY(AC_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 電子ファイル管理番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCC_T_EFILE_KANRI_AC_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_CC_T_EFILE_KANRI.selectBySqlDefine(paramList, CC_T_EFILE_KANRI_AC_SELECT_001);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * ファイル番号 FILE_NO * 処理管理番号 TRN_KANRI_NO * 電子ファイル管理番号 EFILE_KANRI_NO * ファイル名 FILE_NM * ファイルサイズ FILE_SIZE * データ件数 DATA_CNT * ファイル登録年月日時分秒 FILE_ADD_DTM * ファイル削除年月日 FILE_DEL_YMD * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG *
* @param setParam 設定項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeZM_T_DL_FILE_KANRI_PKINSERT(Object[] setParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("FILE_NO", setParam[0]); setMap.setValue("TRN_KANRI_NO", setParam[1]); setMap.setValue("EFILE_KANRI_NO", setParam[2]); setMap.setValue("FILE_NM", setParam[3]); setMap.setValue("FILE_SIZE", setParam[4]); setMap.setValue("DATA_CNT", setParam[5]); setMap.setValue("FILE_ADD_DTM", setParam[6]); setMap.setValue("FILE_DEL_YMD", 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]); // DBアクセスを実行します db_ZM_T_DL_FILE_KANRI.insertByPrimaryKeys(setMap); } /** * ダウンロードファイル管理スキーマに登録します。 * * @param eFileInfo 電子ファイル管理情報 * @throws Exception 業務サービス内で発生した例外全般 */ private void insZmTDlFileKanri(String trnKanriNo, String eFileKanriNo, String fileNm, String filePath, String dataCount) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][insZmTDlFileKanri]"); // 電子ファイル管理の情報を取得 JBSbatCommonDBInterface eFileInfo = this.selectCcTEfileKanri(eFileKanriNo); // 設定値 JBSbatCommonDBInterface param = new JBSbatCommonDBInterface(); // 1.ファイル番号 param.setValue(JCCBatCommon.getFormatedNextSeq(super.commonItem, JACStrConst.SEQ_FILE_NO, SEQ_PREFIX_SEQ_FILE_NOO, SEQ_LEN_SEQ_FILE_NO)); // 2.処理管理番号 param.setValue(trnKanriNo); // 3.電子ファイル管理番号 param.setValue(eFileKanriNo); // 4.ファイル名 param.setValue(fileNm); // 5.ファイルサイズ param.setValue(JCCFileUtil.getFileSize(filePath)); // 6.データ件数 param.setValue(dataCount); // 7.ファイル登録年月日時分秒 param.setValue(eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.ADD_DTM)); // 8.ファイル削除年月日 param.setValue(eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.FILE_DEL_YMD)); // 9.登録年月日時分秒 param.setValue(null); // 10.登録オペレータアカウント param.setValue(null); // 11.更新年月日時分秒 param.setValue(null); // 12.更新オペレータアカウント param.setValue(null); // 13.削除年月日時分秒 param.setValue(null); // 14.削除オペレータアカウント param.setValue(null); // 15.無効フラグ param.setValue(null); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][insZmTDlFileKanri][param = " + param.getList().toString() + "]"); // SQL実行 executeZM_T_DL_FILE_KANRI_PKINSERT(param.getList().toArray()); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][insZmTDlFileKanri]"); } /** * 電子ファイル管理スキーマより、電子ファイル管理の情報を取得します。 * * @param eFileNO 電子ファイル管理番号 * @return dbMap 電子ファイル管理の情報 * @throws Exception 業務サービス内で発生した例外全般 */ private JBSbatCommonDBInterface selectCcTEfileKanri(String eFileKanriNo) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectCcTEfileKanri]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(eFileKanriNo); // 電子ファイル管理番号 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCcTEfileKanri][paramList=" + paramList.getList().toString() + "]"); // SQL実行 executeCC_T_EFILE_KANRI_AC_SELECT_001(paramList.getList().toArray()); // 結果取得 JBSbatCommonDBInterface dbMap = db_CC_T_EFILE_KANRI.selectNext(); if (dbMap == null) { // DB未存在エラー String[] msgParam = new String[] { JBSbatCC_T_EFILE_KANRI.TABLE_NAME, JPCUtilCommon.convMapToString(paramList.getMap()) }; throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0260CH, msgParam); } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCcTEfileKanri][dbMap=" + dbMap.getMap().toString() + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectCcTEfileKanri]"); return dbMap; } }