ReviewService.java 文件源码

@Transactional
public long create(String cluster, String path, String data, User creator, Action action, ReviewStatus reviewStatus)
        throws ShepherException {
    if (creator == null) {
        throw ShepherException.createIllegalParameterException();
    }
    Stat stat = nodeDAO.getStat(cluster, path, true);
    long snapshotId = snapshotBiz.getOriginalId(path, cluster, ReviewUtil.DEFAULT_CREATOR, stat, action, true);
    long newSnapshotId = snapshotBiz.create(cluster, path, data, creator.getName(), action, ReviewUtil.DEFAULT_MTIME,
            ReviewStatus.NEW, stat.getVersion() + 1, ReviewUtil.DEFAULT_REVIEWER).getId();
    Set<String> masters = teamBiz.listUserNamesByPathAndUser(creator.getId(), cluster, path, Role.MASTER);
    String reviewers = this.asStringReviewers(masters);
    long reviewId = reviewBiz.create(cluster, path, snapshotId, newSnapshotId,
            reviewStatus, creator.getName(), ReviewUtil.DEFAULT_REVIEWER, action).getId();
    logger.info("Create review request, reviewId={}, creator={}, reviewers={}", reviewId, creator, reviewers);
    mailSenderFactory.getMailSender().noticeUpdate(masters, creator.getName(), path, cluster, serverUrl + "/reviews/" + reviewId);
    return reviewId;
}