2.2.2. ワークフローライブラリの基本的な使用方法¶

/**
 * 交通費を申請する。<br/>
 * 申請IDは自動採番される。
 *
 * @param entity 登録する交通費申請情報を設定したEntity
 * @param confirmUserId 確認者ユーザID
 * @param authorizeUserId 承認者ユーザID
 * @return 採番した交通費申請ID
 */
public String applyTransExpense(TransExpeApplicationEntity entity, String confirmUserId, String authorizeUserId) {

    // ワークフローを開始する。
    WorkflowInstance workflow = WorkflowManager.startInstance(TRANS_EXPENSE_APPLICATION_WORKFLOW_ID);

    // ワークフローの各タスクに、担当ユーザを割り当てる。
    workflow.assignUser(CONFIRMATION_TASK, confirmUserId);
    workflow.assignUser(AUTHORIZATION_TASK, authorizeUserId);
    workflow.assignUser(REAPPLICATION_TASK, ThreadContext.getUserId());

    // 申請登録
    String applicationId = IdGeneratorUtil.generateTransExpeAppliId();
    entity.setTransExpeAppliId(applicationId);
    entity.setWfInstanceId(workflow.getInstanceId());
    entity.setTransExpeAppliStatusCd(REGISTER_COMPLETE);
    ParameterizedSqlPStatement statement = getParameterizedSqlStatement("REGISTER_TRANS_EXPENCE_APPLICATION");
    statement.executeUpdateByObject(entity);

    // 履歴登録
    TransExpeAppliHistoryEntity historyEntity = new TransExpeAppliHistoryEntity();
    historyEntity.setTransExpeAppliId(applicationId);
    historyEntity.setTransExpeAppliActionCd(REGISTER);
    historyEntity.setTransExpeAppliResultCd(FORWARD_RESULT);
    registerHistory(historyEntity);

    return applicationId;
}

/**
 * 確認タスクを承認タスクへ進める。
 *
 * @param applicationEntity 交通費申請情報を保持するEntity
 * @param historyEntity 交通費申請履歴情報を保持するEntity
 */
public void executeConfirmation(TransExpeApplicationEntity applicationEntity, TransExpeAppliHistoryEntity historyEntity) {

    // アプリケーションデータを取得
    SqlRow application = getApplication(applicationEntity.getTransExpeAppliId());

    // ワークフローインスタンスを取得し、承認タスクに進行するようにパラメータを渡してタスクを完了する。
    Map<String, Object> parameter = new HashMap<String, Object>();
    parameter.put("condition", FORWARD_CONDITION);
    WorkflowManager.findInstance(application.getString("WF_INSTANCE_ID")).completeUserTask(parameter);

    // 業務データのステータスを更新
    applicationEntity.setTransExpeAppliStatusCd(CONFIRM_COMPLETE);
    updateApplicationStatus(applicationEntity);

    // 処理履歴の追加
    historyEntity.setTransExpeAppliActionCd(CONFIRM);
    historyEntity.setTransExpeAppliResultCd(FORWARD_RESULT);
    registerHistory(historyEntity);
}

/**
 * 確認タスクを引戻す。
 *
 * @param applicationEntity 交通費申請情報を保持するEntity
 * @param historyEntity 交通費申請履歴情報を保持するEntity
 */
public void cancelConfirmation(TransExpeApplicationEntity applicationEntity, TransExpeAppliHistoryEntity historyEntity) {

    SqlRow application = getApplication(applicationEntity.getTransExpeAppliId());

    // 境界イベントを実行する。
    WorkflowManager.findInstance(application.getString("WF_INSTANCE_ID")).triggerEvent(CANCEL_TRIGGER);

    // ワークアイテムの更新
    applicationEntity.setTransExpeAppliStatusCd(CONFIRM_CANCEL);
    updateApplicationStatus(applicationEntity);

    // 履歴情報の登録
    historyEntity.setTransExpeAppliActionCd(CANCEL);
    historyEntity.setTransExpeAppliResultCd(FORWARD_RESULT);
    registerHistory(historyEntity);
}

/**
 * 交通費申請承認画面を表示する。<br/>
 * （交通費承認一覧画面からの遷移）
 *
 * @param request リクエストコンテキスト
 * @param context HTTPリクエストの処理に関連するサーバ側の情報
 * @return HTTPレスポンス
 */
@OnError(type = ApplicationException.class, path = "forward:///action/ss11AB/W11AB01Action/RW11AB0102")
public HttpResponse doRW11AD0201(HttpRequest request, ExecutionContext context) {

    // ワークアイテムのキーを取得
    W11AD02Form form = W11AD02Form.validate("W11AD02", request, "initial");
    String applicationId = form.getApplicationId();

    // 排他制御開始
    HttpExclusiveControlUtil.prepareVersion(context,
            new ExclusiveCtrlTransExpeApplicationContext(applicationId));

    // 後略
}

/**
 * 交通費申請の承認タスクを完了する。
 *
 * @param request リクエストコンテキスト
 * @param context HTTPリクエストの処理に関連するサーバ側の情報
 * @return HTTPレスポンス
 */
@OnErrors({
    @OnError(type = OptimisticLockException.class,
             path = "forward:///action/ss11AB/W11AB01Action/RW11AB0102"),
    @OnError(type = ApplicationException.class,
             path = "forward:///action/ss11AD/W11AD02Action/RW11AD0210")
})
public HttpResponse doRW11AD0205(HttpRequest request, ExecutionContext context) {

    // 排他制御
    HttpExclusiveControlUtil.updateVersionsWithCheck(request);

    W11AD02Form form = W11AD02Form.validate("W11AD02", request, "authorize");

    // ワークフローの進行、業務処理の実施
    CM111001Component component = new CM111001Component();
    component.executeAuthorization(form.getApplicationEntity(), form.getHistoryEntity());

    // 後略
}