Spring事件的应用

@Data
@Accessors(chain = true)
@ApiModel("用户审核事件")
public class UserExamineEvent {

    @ApiModelProperty("注册者的id")
    String userId;

    @ApiModelProperty("推荐人的id")
    String recommendId;

    @ApiModelProperty("审核结果")
    boolean success;

    ActivityInfo info;

}

@Service
public class ActivityServiceImpl implements ActivityService, ApplicationEventPublisherAware {
    ApplicationEventPublisher applicationEventPublisher;

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
    @Override
    @Transactional(rollbackFor = {Exception.class, CommonException.class})
    public void examine(ActivityInfo info) {
        int value = activityMapper.examine(info);
        if (value != 1) {
            throw new CommonException(CommonExcepEnums.ERROR.getCode(), "审核失败！");
        }
        final ActivityInfo allInfo = activityMapper.queryByUserId(info);
        boolean isSuccess = "examined".equalsIgnoreCase(info.getStatus()) ? true : false;
        //发送审核操作的事件
        applicationEventPublisher.publishEvent(new UserExamineEvent()
                .setRecommendId(allInfo.getRecommendId())
                .setSuccess(isSuccess)
                .setUserId(allInfo.getUserId().toString())
                .setInfo(allInfo)
        );
}

@Component
public class UserExamineListener {
@Async
    @EventListener
    public void listenUserExamine(UserExamineEvent event) {
        sendMessage(event);
        if (!event.isSuccess()) return;
        giveRegisterMoney(event);
        Long successed = redisTemplate.opsForValue().increment(getSuccessedKey(event), 1);
        recommendServices.forEach(
                recommendService -> {
                    if (recommendService.isAccept(successed)) {
                        recommendService.afterRecommend(event, successed);
                    }
                }
        );
}
}