public abstract class AbstractGenericImportJob extends AbstractGenericJob
汎用インポートジョブの抽象クラスです。
ジョブに指定可能なパラメータについて
AbstractGenericJob
で指定可能なパラメータに加え、次のパラメータを指定可能です。
AbstractGenericJob で指定可能なパラメータ | ||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
キー | 値 | 設定 | 省略時 | |||||||||||||||||||||||||||
error_skip | 会社別処理エラー時の後続処理スキップ | 任意 | スキップしない(false) | |||||||||||||||||||||||||||
lock_wait | ロック待ち時間 | 任意 | 10(秒) | |||||||||||||||||||||||||||
company_group_set_cd | 会社グループセットコード | 任意 | 会社グループの絞り込みを行わない | |||||||||||||||||||||||||||
company_group_cd | 会社グループコード | 任意 | 会社グループの絞り込みを行わない | |||||||||||||||||||||||||||
company_cd | 会社コード(カンマ区切りで複数指定可) | 任意 | 会社の絞り込みを行わない | |||||||||||||||||||||||||||
conductor | ジョブの各処理間で実行されるコンダクター(カンマ区切りで複数指定可)AbstractGenericJobConductor を継承したクラスのコンポーネント名を指定してください。 |
任意 | コンダクターを使用しない | |||||||||||||||||||||||||||
本クラス(AbstractGenericImportJob )で追加指定可能なパラメータ | ||||||||||||||||||||||||||||||
キー | 値 | 設定 | 省略時 | |||||||||||||||||||||||||||
import_mode | インポートモード
| 任意 | 1 | |||||||||||||||||||||||||||
start_date | インポート期間の開始日 (インポートモード1,2,3で使用します。) | 任意 | ジョブの実行日 | |||||||||||||||||||||||||||
end_date | インポート期間の終了日 (インポートモード1,2,3で使用します。) | 任意 | システムの終了日 | |||||||||||||||||||||||||||
shift_date | インポート期間の開始日に対する増減日数 (インポートモード1,2,3で使用します。) | 任意 | 0 (日) | |||||||||||||||||||||||||||
file_path | インポートファイルのパス | 任意 | kaiden/generic/import.csv | |||||||||||||||||||||||||||
file_mode | 処理後のインポートファイル操作モード
| 任意 | 1 | |||||||||||||||||||||||||||
archive_path | インポートファイルのアーカイブ先パス | 任意 | kaiden/generic/import_{YMDHMSN}.csv | |||||||||||||||||||||||||||
character | インポートファイルの文字コード UTF-8 SHIFT-JIS | 任意 | UTF-8 | |||||||||||||||||||||||||||
delimiter | インポートファイルの区切り文字 , (カンマ) \\t (タブ) | 任意 | , (カンマ) | |||||||||||||||||||||||||||
enclosing | インポートファイルの囲み文字 none (なし) " (ダブルクォーテーション) | 任意 | " (ダブルクォーテーション) | |||||||||||||||||||||||||||
start_rows | インポートファイルの読込開始行数 | 任意 | 1 (行目から読込) | |||||||||||||||||||||||||||
columns | インポートファイルのカラム | 任意 | カラム未指定(インポートしない) | |||||||||||||||||||||||||||
primary_columns | インポートファイルのプライマリーカラム | 任意 | プライマリーカラム未指定(全行異なるデータとして扱う) |
修飾子とタイプ | クラスと説明 |
---|---|
static class |
AbstractGenericImportJob.ImportFileMode
インポートファイルモード.
|
static class |
AbstractGenericImportJob.ImportMode
インポートモード.
|
AbstractGenericJob.FileProcessType, AbstractGenericJob.IllegalJobParametersException, AbstractGenericJob.ProcessFile
修飾子とタイプ | フィールドと説明 |
---|---|
static String |
IMPORT_FILE_ROW_COUNT
インポートファイルの行数(DBのカラム名で使用されない定数値を設定).
|
static String |
JOBPARAM_ARCHIVE_PATH
ジョブパラメータキー:インポートファイルのアーカイブ先パス(archive_path).
|
static String |
JOBPARAM_CHARACTER
ジョブパラメータキー:インポートファイルの文字コード(character).
|
static String |
JOBPARAM_COLUMNS
ジョブパラメータキー:インポートファイルのカラム(columns).
|
static String |
JOBPARAM_DELIMITER
ジョブパラメータキー:インポートファイルの区切り文字(delimiter).
|
static String |
JOBPARAM_ENCLOSING
ジョブパラメータキー:インポートファイルの囲み文字(enclosing).
|
static String |
JOBPARAM_END_DATE
ジョブパラメータキー:インポート期間の終了日(end_date).
|
static String |
JOBPARAM_FILE_MODE
ジョブパラメータキー:処理後のインポートファイル操作モード(file_mode).
|
static String |
JOBPARAM_FILE_PATH
ジョブパラメータキー:インポートファイルのパス(file_path).
|
static String |
JOBPARAM_IMPORT_MODE
ジョブパラメータキー:インポートモード(import_mode).
|
static String |
JOBPARAM_PRIMARY_COLUMNS
ジョブパラメータキー:インポートファイルのプライマリーカラム(primary_columns).
|
static String |
JOBPARAM_SHIFT_DATE
ジョブパラメータキー:インポート期間の開始日に対する増減日数(shift_date).
|
static String |
JOBPARAM_START_DATE
ジョブパラメータキー:インポート期間の開始日(start_date).
|
static String |
JOBPARAM_START_ROWS
ジョブパラメータキー:インポートファイルの読込開始行数(start_rows).
|
contextHelper, dateHelper, dateValidator, identifierHelper, JOBPARAM_COMPANY_CD, JOBPARAM_COMPANY_GROUP_CD, JOBPARAM_COMPANY_GROUP_SET_CD, JOBPARAM_CONDUCTOR, JOBPARAM_ERROR_SKIP, JOBPARAM_JOB_ID, JOBPARAM_JOB_NAME, JOBPARAM_JOB_NET_ID, JOBPARAM_JOB_NET_NAME, JOBPARAM_LOCK_WAIT, JOBPARAM_MONITOR_ID, JOBPARAM_OUTPUT_LOG, JOBPARAM_PROCESS_COMPANY, JOBPARAM_PROCESS_DATE, JOBPARAM_TASK_ID, JOBPARAM_TENANT_ID, jobResultList, localeValidator, parameters, processCompany, processDate, processFiles, propertyHelper, result, systemLocaleHelper, transactionHelper, xmlOutputHelper
コンストラクタと説明 |
---|
AbstractGenericImportJob()
コンストラクタ.
|
AbstractGenericImportJob(Map<String,String> parameters)
コンストラクタ.
|
修飾子とタイプ | メソッドと説明 |
---|---|
protected String |
getArchiveFilePath()
アーカイブ先のパスを返却.
|
protected String |
getCharacter()
インポートファイルの文字コードを返却.
|
protected List<String> |
getColumnData(String lineData)
行データを区切り文字、囲み文字に従い分割.
|
protected List<String> |
getColumnList()
カラムリストを返却.
|
protected String |
getCompanyCdColumn()
会社コードのカラム名を返却.
|
protected String |
getDelimiter()
インポートファイルの区切り文字を返却.
|
protected String |
getEnclosing()
インポートファイルの囲み文字を返却.
|
protected Date |
getEndDate()
インポート期間の終了日を返却.
|
protected String |
getEndDateColumn()
終了日のカラム名を返却.
|
protected AbstractGenericImportJob.ImportFileMode |
getFileMode()
処理後のインポートファイル操作モードを返却.
|
protected String |
getImportFilePath()
インポートファイルのパスを返却.
|
protected AbstractGenericImportJob.ImportMode |
getImportMode()
インポートモードを返却.
|
protected List<String> |
getPrimaryColumnList()
プライマリーカラムリストを返却.
|
protected KaidenJobProcessType |
getProcessType()
ジョブスケジューラーの処理種類を返却.
|
protected Map<String,Object> |
getRecordData(List<String> columnList,
String lineData)
行データを返却.
|
protected Timestamp |
getStartDate()
インポート期間の開始日を返却.
|
protected String |
getStartDateColumn()
開始日のカラム名を返却.
|
protected int |
getStartRows()
インポートファイルの読込開始行数を返却.
|
protected String |
getValidMsg(String rowCount,
KaidenValidateResult validResult)
バリデートエラーメッセージを返却.
|
protected String |
getValidMsg(String rowCount,
String message)
バリデートエラーメッセージを返却.
|
protected boolean |
importModeCheck(AbstractGenericImportJob.ImportMode mode)
インポートモード利用可否判定.
|
protected boolean |
isMatchData(List<String> primaryKeyList,
Map<String,Object> comparisonRecord,
Map<String,Object> record)
行データの一致確認.
|
protected void |
postExecute()
ジョブ全体の後処理.
|
protected void |
postProcessImport()
インポートデータの登録後処理.
|
protected void |
preProcessImport()
インポートデータの登録前処理.
|
protected void |
process()
インポート処理.
|
protected void |
processImport(List<Map<String,Object>> recordList)
インポートデータの登録処理.
|
protected void |
processRenewal()
一新処理.
|
protected void |
processReplace()
入替処理.
|
protected void |
validate(List<Map<String,Object>> recordList)
バリデートを実行.
|
addArchiveFile, addDeleteFile, addReadFile, addWriteFile, execute, getCompanyCdList, getConductor, getEndMessage, getJobResult, getLockKey, getLockWait, getMessage, getParameter, getParameters, getStartMessage, getSurface, initializeJobResult, isCompanyProcess, isOutputLog, outputJobProcessResult, postProcess, preExecute, preProcess, replace, run, validateParameters
public static final String JOBPARAM_IMPORT_MODE
public static final String JOBPARAM_START_DATE
public static final String JOBPARAM_END_DATE
public static final String JOBPARAM_SHIFT_DATE
public static final String JOBPARAM_FILE_PATH
public static final String JOBPARAM_FILE_MODE
public static final String JOBPARAM_ARCHIVE_PATH
public static final String JOBPARAM_CHARACTER
public static final String JOBPARAM_DELIMITER
public static final String JOBPARAM_ENCLOSING
public static final String JOBPARAM_START_ROWS
public static final String JOBPARAM_COLUMNS
public static final String JOBPARAM_PRIMARY_COLUMNS
protected KaidenJobProcessType getProcessType()
getProcessType
クラス内 AbstractGenericJob
protected void process() throws KaidenSystemException, KaidenApplicationException
protected boolean importModeCheck(AbstractGenericImportJob.ImportMode mode)
mode
- インポートモードprotected List<String> getColumnList() throws KaidenSystemException, KaidenApplicationException
protected List<String> getPrimaryColumnList() throws KaidenSystemException, KaidenApplicationException
KaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected Map<String,Object> getRecordData(List<String> columnList, String lineData) throws KaidenSystemException, KaidenApplicationException
columnList
- カラムのリストlineData
- 1行データKaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected List<String> getColumnData(String lineData) throws KaidenSystemException, KaidenApplicationException
区切り文字毎にデータを分割し、囲み文字で囲まれている場合には除去します。 囲み文字内の囲み文字のエスケープを解除します。※"aaa""bbb" →aaa"bbb ※囲み文字指定されない場合はエスケープ解除しません。
lineData
- 1行データKaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected void validate(List<Map<String,Object>> recordList)
recordList
- 行データprotected String getValidMsg(String rowCount, KaidenValidateResult validResult)
rowCount
- エラー発生行validResult
- KaidenValidateResult
protected String getValidMsg(String rowCount, String message)
rowCount
- エラー発生行message
- メッセージprotected boolean isMatchData(List<String> primaryKeyList, Map<String,Object> comparisonRecord, Map<String,Object> record)
MasterBuilder定義GenericSettings
に従って、
会社コード、開始日、終了日、コードが一致するか否かを返却します。
primaryKeyList
- プライマリーキーのリストcomparisonRecord
- 判定元データrecord
- 判定先データprotected void preProcessImport() throws KaidenSystemException, KaidenApplicationException
protected void processRenewal() throws KaidenSystemException, KaidenApplicationException
preProcessImport()
の後に次のモードの際に実行されます。
protected void processReplace() throws KaidenSystemException, KaidenApplicationException
protected void processImport(List<Map<String,Object>> recordList) throws KaidenSystemException, KaidenApplicationException
recordList
- インポート対象データのリストKaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected void postProcessImport() throws KaidenSystemException, KaidenApplicationException
protected void postExecute() throws jp.co.intra_mart.foundation.job_scheduler.exception.JobExecuteException
postExecute
クラス内 AbstractGenericJob
jp.co.intra_mart.foundation.job_scheduler.exception.JobExecuteException
- JobExecuteException
protected String getCompanyCdColumn()
#getColumnList(GenericJobDto)
、#getPrimaryColumnList(GenericJobDto)
で返却する会社コードのカラム名を返却します。
protected String getStartDateColumn()
#getColumnList(GenericJobDto)
、#getPrimaryColumnList(GenericJobDto)
で返却する開始日のカラム名を返却します。
protected String getEndDateColumn()
#getColumnList(GenericJobDto)
、#getPrimaryColumnList(GenericJobDto)
で返却する終了日のカラム名を返却します。
protected AbstractGenericImportJob.ImportMode getImportMode()
protected Timestamp getStartDate() throws KaidenSystemException, KaidenApplicationException
KaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected Date getEndDate() throws KaidenSystemException, KaidenApplicationException
KaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
protected String getImportFilePath()
protected AbstractGenericImportJob.ImportFileMode getFileMode()
protected String getArchiveFilePath()
protected String getCharacter()
protected String getDelimiter()
protected String getEnclosing()
protected int getStartRows() throws KaidenSystemException, KaidenApplicationException
KaidenSystemException
- KaidenSystemException
KaidenApplicationException
- KaidenApplicationException
Copyright © 2023 Sumitomo Life Information Systems Co., Ltd. All Rights Reserved.