package sample.tgfw.job.hello;

import jp.co.intra_mart.foundation.context.Contexts;
import jp.co.intra_mart.foundation.context.model.AccountContext;
import jp.co.intra_mart.foundation.job_scheduler.Job;
import jp.co.intra_mart.foundation.job_scheduler.JobResult;
import jp.co.intra_mart.foundation.job_scheduler.JobSchedulerContext;
import jp.co.intra_mart.foundation.job_scheduler.annotation.Parameter;
import jp.co.intra_mart.foundation.job_scheduler.annotation.Parameters;
import jp.co.intra_mart.foundation.job_scheduler.exception.JobExecuteException;
import jp.co.intra_mart.framework.extension.spring.context.ApplicationContextProvider;
import sample.tgfw.domain.greeting.GreetingService;

public class HelloJob implements Job {

    public HelloJob() {
    }

    @Override
    @Parameters(@Parameter(key = "message", value = "world!"))
    public JobResult execute() throws JobExecuteException {
        try {
            // アカウントコンテキスト
            final AccountContext accountContext = Contexts.get(AccountContext.class);
            System.out.println("Account context : " + accountContext.toString());

            // ジョブスケジューラコンテキスト
            final JobSchedulerContext jobSchedulerContext = Contexts.get(JobSchedulerContext.class);
            System.out.println("Job scheduler context : " + jobSchedulerContext.toString());

            // パラメータの取得
            final String message = jobSchedulerContext.getParameter("message");
            if (null == message) {
                // 処理結果：異常
                return JobResult.error("パラメータにメッセージが存在しません。");
            } else if (message.trim().isEmpty()) {
                // 処理結果：警告
                return JobResult.waring("メッセージが空です。");
            }
            // メッセージの表示
            System.out.println("Hello. " + message);

            // application contextから service beanを取得
            final GreetingService greetingService = ApplicationContextProvider.getApplicationContext().getBean(GreetingService.class);
            System.out.println(greetingService.hello());

            // 処理結果：正常
            return JobResult.success("ジョブが正常に実行されました。");
        } catch (final Exception e) {
            // 処理結果：異常（例外による処理結果の返却）
            throw new JobExecuteException("予期しないエラーが発生しました。", e);
        }
    }
}

sample.tgfw.domain.greeting.GreetingService の bean を Spring Framework の Application Context に登録するために、 モジュールプロジェクトの applicationContext*.xml に以下を追記しておきます。

<context:component-scan base-package="sample.tgfw.domain" />

• Jobの実装クラスの作成

  Java のジョブプログラムは、jp.co.intra_mart.foundation.job_scheduler.Jobの実装クラスを作成します。

  このインタフェースには、ジョブの実行処理を記述するためのexecuteメソッドが定義されています。

  ジョブ開発者は、このexecuteメソッドにジョブ処理で実行したいプログラムを記述します。
• Spring Framework の Application Context の取得

  Spring Framework の Application Context を取得する場合には、 jp.co.intra_mart.framework.extension.spring.context.ApplicationContextProvider.getApplicationContext() を使用してください。

  この例では、 Spring Framework の Application Context に登録されている GreetingService を取得しています。