*
* @author 富士通
*/
public class JBSbatCHKariNyukinFileClOput extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(請求)*/
private static final String D_TBL_NAME_CH_T_SEIKY = "CH_T_SEIKY";
/** テーブル(コンビニエンスストア)*/
private static final String D_TBL_NAME_CH_M_CVSTORE = "CH_M_CVSTORE";
/** テーブル(業務パラメータ管理)*/
private static final String D_TBL_NAME_ZM_M_WORK_PARAM_KNRI = "ZM_M_WORK_PARAM_KNRI";
/** テーブル(コード名称管理)*/
private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
/** SQL定義キー(CH_SELECT_017)*/
private static final String CH_T_SEIKY_CH_SELECT_017 = "CH_SELECT_017";
/** SQL定義キー(CH_SELECT_003)*/
private static final String CH_M_CVSTORE_CH_SELECT_003 = "CH_SELECT_003";
/** テーブルアクセスクラス(請求)*/
private JBSbatSQLAccess db_CH_T_SEIKY = null;
/** テーブルアクセスクラス(コンビニエンスストア)*/
private JBSbatSQLAccess db_CH_M_CVSTORE = null;
/** テーブルアクセスクラス(業務パラメータ管理)*/
private JBSbatSQLAccess db_ZM_M_WORK_PARAM_KNRI = null;
/** テーブルアクセスクラス(コード名称管理)*/
private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 出力ファイル桁数（10桁） */
private static final int LENGTH_LIMIT_10 = 10;
/** 出力ファイル桁数（30桁） */
private static final int LENGTH_LIMIT_30 = 30;
/** 項目ごとの囲み文字 */
private static final String KAKOMI_MOJI = "\"";
/** 接頭辞（業務パラメータID） */
private static final String PREFIX_WKPARA = "CH_";
/** データ種別（取消） */
private String dataSbt = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CH_T_SEIKY = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_SEIKY);
db_CH_M_CVSTORE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_CVSTORE);
db_ZM_M_WORK_PARAM_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_WORK_PARAM_KNRI);
db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_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 + "]");
// データ種別取得
JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
dataSbt = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_CH_DATA_SBT_3);
paramUtil.close();
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]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][inMap=" + inMap.getMap().toString() + "]");
// 入力電文有無確認
if (inMap.getMap().isEmpty())
{
return null;
}
// エラー文言取得
String msgCd = JACStrConst.WKPARA_CH_OK;
if (JACStrConst.ERRFLG_ERROR.equals(inMap.getString(JBSbatCHIFM008.ERR_FLG)))
{
msgCd = PREFIX_WKPARA + inMap.getString(JBSbatCHIFM008.ERR_CD);
}
String errMsg = selectMsg(msgCd);
// 送付先名取得
String sofuSakiNm = selectSohuSakiNm(inMap.getString(JBSbatCHIFM008.SEIKY_NO));
// コンビニエンスストア会社名取得
String cvstoreCompNm = selectCVStoreCompNm(inMap.getString(JBSbatCHIFM008.CVSTORE_CD));
// 仮入金情報作成
JBSbatServiceInterfaceMap kariNyukinInfo = makeKariNyukinInfo(inMap, errMsg, sofuSakiNm, cvstoreCompNm);
// 出力共通電文設定
JBSbatOutputItem outputItem = new JBSbatOutputItem();
outputItem.addOutMapList(kariNyukinInfo);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return outputItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 仮入金情報を作成します。
*
* @param inMap 入力電文
* @param sohuSakiNm 送付先名
* @param nyukinInfo 入金番号
* @param cvstoreCompNm コンビニエンスストア会社名
* @return 仮入金一覧
* @throws Exception 業務サービス内で発生した例外
*/
private JBSbatServiceInterfaceMap makeKariNyukinInfo(JBSbatServiceInterfaceMap inMap, String errMsg, String sohuSakiNm, String cvstoreCompNm)
throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeKariNyukinInfo]");
// エラー文言が存在する場合、再設定
if(errMsg != null && LENGTH_LIMIT_10 < errMsg.length())
{
errMsg = errMsg.substring(0, LENGTH_LIMIT_10);
}
// 送付先名が存在する場合、再設定
if(sohuSakiNm != null && LENGTH_LIMIT_30 < sohuSakiNm.length())
{
sohuSakiNm = sohuSakiNm.substring(0, LENGTH_LIMIT_30);
}
// コンビニエンスストア会社名が存在する場合、再設定
if(cvstoreCompNm != null && LENGTH_LIMIT_30 < cvstoreCompNm.length())
{
cvstoreCompNm = cvstoreCompNm.substring(0, LENGTH_LIMIT_30);
}
// 仮入金情報
JBSbatServiceInterfaceMap kariNyukinInfo = new JBSbatServiceInterfaceMap();
// データ種別
kariNyukinInfo.set(JBSbatCHIFE027.DATA_SBT, dataSbt);
// 処理結果
kariNyukinInfo.set(JBSbatCHIFE027.TRN_RSLT, errMsg);
// 請求先番号
kariNyukinInfo.set(JBSbatCHIFE027.SEIKY_SAKI_NO, inMap.get(JBSbatCHIFM008.SEIKY_KEI_NO));
// 請求先名
kariNyukinInfo.set(JBSbatCHIFE027.SEIKY_SAKI_NM, sohuSakiNm);
// 請求月
kariNyukinInfo.set(JBSbatCHIFE027.SEIKY_MON, JPCFomatString.formatYears(inMap.getString(JBSbatCHIFM008.SEIKY_YM)));
// 仮入金額
kariNyukinInfo.set(JBSbatCHIFE027.KARI_NYUKIN_AMNT, JPCFomatString.formatNumber(inMap.getBigDecimal(JBSbatCHIFM008.NYUKIN_AMNT).toPlainString()));
// 仮入金処理日
kariNyukinInfo.set(JBSbatCHIFE027.KARI_NYUKIN_TRN_YMD, JPCFomatString.formatDate(inMap.getString(JBSbatCHIFM008.PAY_YMD)));
// ＣＶＳコード
kariNyukinInfo.set(JBSbatCHIFE027.CVS_CD, inMap.getString(JBSbatCHIFM008.CVSTORE_CD));
// ＣＶＳ名
kariNyukinInfo.set(JBSbatCHIFE027.CVS_NM, cvstoreCompNm);
// 出力内容を項目ごとにダブルコーテーション（""）で囲む
kariNyukinInfo.setMap(JCHbatSeikyKaknoBusinessUtil.quote(kariNyukinInfo.getMap(), KAKOMI_MOJI, KAKOMI_MOJI));
// 出力フラグON
kariNyukinInfo.setOutFlg(true);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeKariNyukinInfo]");
return kariNyukinInfo;
}
/**
* 「送付先名」を取得します。
*
* @param seikyNo 請求番号
* @return 送付先名
* @throws Exception 業務サービス内で発生した例外
*/
private String selectSohuSakiNm(String seikyNo) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectSohuSakiNm]");
// 条件値
JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface();
// 請求番号
whereParam.setValue(seikyNo);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectSohuSakiNm][whereParam=" + whereParam.getList().toString() + "]");
// 請求情報検索SQL実行
executeCH_T_SEIKY_CH_SELECT_017(whereParam.getList().toArray());
JBSbatCommonDBInterface selectMap = db_CH_T_SEIKY.selectNext();
// 取得結果判定
String sohuSakiNm = null;
if (selectMap == null)
{
// ログ出力（ＤＢ未存在エラー）
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB0260CE, new String[]
{ JBSbatCH_T_SEIKY.TABLE_NAME, whereParam.getList().toString() });
}
else
{
// 取得した送付先名を返却
sohuSakiNm = selectMap.getString(JBSbatCH_T_SEIKY.SOHUS_NM);
}
assert selectMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectSohuSakiNm][selectMap=" + selectMap.getMap().toString() + "]") : true;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectSohuSakiNm]");
return sohuSakiNm;
}
/**
* 「コンビニエンスストア会社名」を取得します。
*
* @param cvstoreCd コンビニエンスストアコード
* @return コンビニエンスストア会社名
* @throws Exception 業務サービス内で発生した例外
*/
private String selectCVStoreCompNm(String cvstoreCd) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectCVStoreCompNm]");
// 条件値
JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface();
// コンビニエンスストアコード
whereParam.setValue(cvstoreCd);
whereParam.setValue(super.opeDate);
whereParam.setValue(super.opeDate);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCVStoreCompNm][whereParam=" + whereParam.getList().toString() + "]");
// コンビニエンスストア会社名検索SQL実行
executeCH_M_CVSTORE_CH_SELECT_003(whereParam.getList().toArray());
JBSbatCommonDBInterface selectMap = db_CH_M_CVSTORE.selectNext();
// 取得結果判定
String cvstoreCompNm = null;
if (selectMap == null)
{
// ログ出力（ＤＢ未存在エラー）
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB0260CE, new String[]
{ JBSbatCH_M_CVSTORE.TABLE_NAME, whereParam.getList().toString() });
}
else
{
// 取得したコンビニエンスストア会社名を返却
cvstoreCompNm = selectMap.getString(JBSbatCH_M_CVSTORE.CVSTORE_COMP_NM);
}
assert selectMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectCVStoreCompNm][selectMap=" + selectMap.getMap().toString() + "]") : true;
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectCVStoreCompNm]");
return cvstoreCompNm;
}
/**
* 業務パラメータ管理からエラーコードに対応するエラー文言を取得します。。
*
* @param msgCd エラーコード
* @return エラー文言
* @throws Exception 取得に失敗した場合
*/
public String selectMsg(String msgCd) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectMsg]");
// 条件のマップを作成します
JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface();
whereParam.setValue(msgCd);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectMsg][whereParam=" + whereParam.getList().toString() + "]");
// DBアクセスを実行します
JBSbatCommonDBInterface workParamKnriInfo = executeZM_M_WORK_PARAM_KNRI_PKSELECT(whereParam.getList().toArray());
// 取得結果判定
String errMsg = null;
if (workParamKnriInfo == null)
{
// ログ出力（ＤＢ未存在エラー）
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB0260CE, new String[]
{ JBSbatZM_M_WORK_PARAM_KNRI.TABLE_NAME, whereParam.getList().toString() });
}
else
{
// 取得したエラー文言を返却
errMsg = workParamKnriInfo.getString(JBSbatZM_M_WORK_PARAM_KNRI.WORK_PARAM_SETTE_VALUE);
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectMsg]");
return errMsg;
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CH_T_SEIKY.close();
db_CH_M_CVSTORE.close();
db_ZM_M_WORK_PARAM_KNRI.close();
db_ZM_M_CD_NM_KANRI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CH_SELECT_017)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 請求番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_T_SEIKY_CH_SELECT_017(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_CH_T_SEIKY.selectBySqlDefine(paramList, CH_T_SEIKY_CH_SELECT_017);
}
/**
* SQLKEY(CH_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * コンビニエンスストアコード * コンビニエンスストア適用開始年月日 * コンビニエンスストア適用終了年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCH_M_CVSTORE_CH_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_CH_M_CVSTORE.selectBySqlDefine(paramList, CH_M_CVSTORE_CH_SELECT_003);
}
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * WORK_PARAM_ID *
* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeZM_M_WORK_PARAM_KNRI_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("WORK_PARAM_ID", whereParam[0]); // DBアクセスを実行します return db_ZM_M_WORK_PARAM_KNRI.selectByPrimaryKeys(whereMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }