@Component @Scope(value="prototype") public class JobnetManagerHelper extends Object
JobSchedulerManager
の拡張クラス.修飾子とタイプ | フィールドと説明 |
---|---|
ContextHelper |
contextHelper
ContextHelper.
|
DateHelper |
dateHelper
DateHelper.
|
IdentifierHelper |
identifierHelper
IdentifierHelper.
|
static String |
JOBNET_EXEC_TASK
ジョブネットタスク.
|
static String |
JOBNET_ID
パラメータキー:ジョブネットID.
|
jp.co.slcs.kaiden.v2.base.foundation.model.service.K10tParametersService |
k10tParametersService
K10tParametersService.
|
MasterManager |
masterManager
MasterManager.
|
static String |
PARAMETERS_KEY
パラメータキー:パラメータキー.
|
protected PropertyHelper |
propertyHelper
PropertyHelper.
|
static String |
QUEUE_ID
ジョブネットタスクキューID.
|
TaskManagerHelper |
taskManagerHelper
TaskManagerHelper.
|
コンストラクタと説明 |
---|
JobnetManagerHelper() |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
createJob(String jobId)
ジョブを作成.
|
void |
createJobCategory(String categoryId)
ジョブカテゴリを作成.
|
void |
createJobNet(String jobNetId)
ジョブネットを作成.
|
void |
createJobNetCategory(String categoryId)
ジョブネットカテゴリを作成.
|
void |
deleteParameter(String parameterKey)
パラメータを削除.
|
void |
execute(String jobNetId)
ジョブネットを実行(同期).
|
void |
execute(String jobNetId,
Map<String,String> jobNetParameters)
ジョブネットを実行(同期).
|
void |
execute(String jobNetId,
Map<String,String> jobNetParameters,
Object memoryParameter)
ジョブネットを実行(同期).
|
void |
execute(String jobNetId,
Map<String,String> jobNetParameters,
String databaseParameter)
ジョブネットを実行(同期).
|
void |
execute(String jobNetId,
Map<String,String> jobNetParameters,
String databaseParameter,
Object memoryParameter)
ジョブネットを実行(同期).
|
void |
executeJobNet(String jobNetId)
ジョブネットを実行.
|
Collection<jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet> |
findUsedJobnets(String jobId)
指定したジョブIDを利用しているジョブネットを全て取得.
|
jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet |
getJobnet(String jobnetId)
Jobnetのを返却.
|
Map<String,String> |
getJobNetParameters(String jobNetId)
ジョブネットパラメータを返却.
|
String |
getParameterKey(String jobNetId)
ジョブネットパラメータの連携キーを返却.
|
jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet |
getRunningJobnet(String jobId)
指定したジョブIDから取得したジョブネットの内、実行中のジョブネットを返却.
|
boolean |
isExistDatabase(String parameterKey)
DBの存在チェック.
|
boolean |
isExistMemory(String parameterKey)
メモリの存在チェック.
|
boolean |
isRunning(String jobNetId)
ジョブネットの実行有無を返却.
|
boolean |
jobExist(String jobId)
ジョブの存在を確認.
|
boolean |
jobExist(String jobId,
boolean exception)
ジョブの存在を確認.
|
boolean |
jobNetExist(String jobNetId)
ジョブネットの存在を確認.
|
boolean |
jobNetExist(String jobNetId,
boolean exception)
ジョブネットの存在を確認.
|
void |
registParameter(String parameterKey,
String databaseParameter,
Object memoryParameter)
パラメータを登録.
|
void |
setJobNetParameters(String jobNetId,
Map<String,String> jobNetPparameters)
ジョブネットパラメータを設定.
|
boolean |
sleep(String parameterKey,
int wait)
パラメータの取得を待機.
|
@Autowired public DateHelper dateHelper
@Autowired public ContextHelper contextHelper
@Autowired public IdentifierHelper identifierHelper
@Autowired public TaskManagerHelper taskManagerHelper
@Autowired protected PropertyHelper propertyHelper
@Autowired public jp.co.slcs.kaiden.v2.base.foundation.model.service.K10tParametersService k10tParametersService
@Autowired public MasterManager masterManager
public jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet getJobnet(String jobnetId)
以下の条件で検索します
jobnetId
- ジョブネットIDpublic void execute(String jobNetId) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDKaidenSystemException
- システムエラーKaidenApplicationException
- アプリケーションエラーpublic void execute(String jobNetId, Map<String,String> jobNetParameters) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDjobNetParameters
- ジョブネットパラメータKaidenSystemException
- システムエラーKaidenApplicationException
- アプリケーションエラーpublic void execute(String jobNetId, Map<String,String> jobNetParameters, String databaseParameter) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDjobNetParameters
- ジョブネットパラメータdatabaseParameter
- k10tParametersを利用したジョブネットへの連携パラメータKaidenSystemException
- システムエラーKaidenApplicationException
- アプリケーションエラーpublic void execute(String jobNetId, Map<String,String> jobNetParameters, Object memoryParameter) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDjobNetParameters
- ジョブネットパラメータmemoryParameter
- ParametersUtil
を利用したジョブネットへの連携パラメータKaidenSystemException
- システムエラーKaidenApplicationException
- アプリケーションエラーpublic void execute(String jobNetId, Map<String,String> jobNetParameters, String databaseParameter, Object memoryParameter) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDjobNetParameters
- ジョブネットパラメータdatabaseParameter
- K10tParametersを利用したジョブネットへの連携パラメータmemoryParameter
- ParametersUtil
を利用したジョブネットへの連携パラメータKaidenSystemException
- システムエラーKaidenApplicationException
- アプリケーションエラーpublic void executeJobNet(String jobNetId) throws KaidenApplicationException
jobNetId
- ジョブネットIDKaidenApplicationException
- ジョブネットの実行に失敗public void setJobNetParameters(String jobNetId, Map<String,String> jobNetPparameters) throws KaidenApplicationException
jobNetId
- ジョブネットIDjobNetPparameters
- ジョブネットパラメータKaidenApplicationException
- ジョブネットパラメータの設定に失敗public Map<String,String> getJobNetParameters(String jobNetId) throws KaidenApplicationException
jobNetId
- ジョブネットIDKaidenApplicationException
- ジョブネットパラメータの取得に失敗public boolean isRunning(String jobNetId) throws KaidenApplicationException
jobNetId
- ジョブネットIDKaidenApplicationException
- ジョブネットの取得に失敗public String getParameterKey(String jobNetId) throws KaidenApplicationException
jobNetId
- ジョブネットIDKaidenApplicationException
- ジョブネットパラメータの取得に失敗public boolean jobNetExist(String jobNetId)
jobNetId
- ジョブネットIDpublic boolean jobNetExist(String jobNetId, boolean exception) throws KaidenApplicationException
jobNetId
- ジョブネットIDexception
- 非存在の場合のエラー出力有無KaidenApplicationException
- ジョブネットが存在しないpublic boolean jobExist(String jobId)
jobId
- ジョブIDpublic boolean jobExist(String jobId, boolean exception) throws KaidenApplicationException
jobId
- ジョブIDexception
- 非存在の場合のエラー出力有無KaidenApplicationException
- ジョブが存在しないpublic void createJobNet(String jobNetId) throws KaidenSystemException, KaidenApplicationException
jobNetId
- ジョブネットIDKaidenSystemException
- ジョブネットの登録に失敗KaidenApplicationException
- ジョブネットの登録に失敗public void createJobNetCategory(String categoryId) throws KaidenSystemException, KaidenApplicationException
categoryId
- ジョブネットカテゴリIDKaidenSystemException
- ジョブネットカテゴリの作成に失敗KaidenApplicationException
- ジョブネットカテゴリの作成に失敗public void createJob(String jobId) throws KaidenSystemException, KaidenApplicationException
jobId
- ジョブネットIDKaidenSystemException
- ジョブの作成に失敗KaidenApplicationException
- ジョブの作成に失敗public void createJobCategory(String categoryId) throws KaidenSystemException, KaidenApplicationException
categoryId
- ジョブカテゴリIDKaidenSystemException
- ジョブカテゴリの作成に失敗KaidenApplicationException
- ジョブカテゴリの作成に失敗public boolean sleep(String parameterKey, int wait) throws KaidenApplicationException
parameterKey
- パラメータキーwait
- 待ち秒KaidenApplicationException
- InterruptedException
public boolean isExistDatabase(String parameterKey)
parameterKey
- パラメータキーpublic boolean isExistMemory(String parameterKey)
parameterKey
- パラメータキーpublic void registParameter(String parameterKey, String databaseParameter, Object memoryParameter)
parameterKey
- パラメータキーdatabaseParameter
- ~~Manager
を利用したジョブネットへの連携パラメータmemoryParameter
- ParametersUtil
を利用したジョブネットへの連携パラメータpublic void deleteParameter(String parameterKey)
parameterKey
- パラメータキーpublic Collection<jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet> findUsedJobnets(String jobId)
jobId
- ジョブIDpublic jp.co.intra_mart.foundation.job_scheduler.model.jobnet.Jobnet getRunningJobnet(String jobId)
jobId
- ジョブIDCopyright © 2024 Sumitomo Life Information Systems Co., Ltd. All Rights Reserved.