import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(TwistRatedEvent event) {
    Twist twist = Twist.find.byId(event.getTwistId());
    if (twist != null) {
        switch (event.getRating()) {
            case 1:
                twist.likeCount++;
                break;
            case 0:
                twist.neutralCount++;
                break;
            case -1:
                twist.dislikeCount++;
                break;
        }
        System.out.println("Added rating for twist:" + event.getTwistId() + " (rating:" + event.getRating() + ")");
        twist.save();
    }
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void onUserCreated(UserCreatedEvent event) {
    if (log.isDebugEnabled()) {
        log.debug("Caught: " + event.getClass().getSimpleName());
    }

    this.id = event.getUserId();
    this.source = event.getSource();
    this.username = event.getUsername();
    this.password = event.getPassword();
    this.email = event.getEmail();
    this.firstName = event.getFirstName();
    this.lastName = event.getLastName();
    this.profilePictureUrl = event.getProfilePictureUrl();
    this.gender = event.getGender();
    this.roles = event.getRoles();
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void handleCreateUser(UserCreatedEvent event) {
    if (log.isDebugEnabled()) {
        log.debug("Caught: " + event.getClass().getSimpleName());
    }

    User user = new User(event);
    if (event.getRoles() != null && event.getRoles().size() > 0) {
        for (String roleName : event.getRoles()) {
            Role role = roleRepository.findByName(roleName);

            if (role != null) {
                user.addRole(role);
            }
        }
    }

    user = userRepository.save(user);

    if (log.isDebugEnabled()) {
        log.debug("Saved user object: " + user.toString());
    }
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(OrganizationMembershipAssignedToOwner event) {
    logger.debug("About to handle the OrganizationMembershipAssignedToOwner: {}", event);
    OrganizationMembershipEntry entry = organizationMemberQueryRepository.findOne(event.getMembershipId().identifier());
    if (entry == null) {
        // new organization
        entry = new OrganizationMembershipEntry();
        entry.setMembershipId(event.getMembershipId().identifier());
        entry.setOrganizationId(event.getOrganizationId().identifier());
        entry.setUsername(event.getUsername());
    }
    entry.setAcceptedByOrganization(true);
    entry.setAcceptedByUser(true);
    entry.setActive(true);
    organizationMemberQueryRepository.save(entry);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
@Subscribe
public void on(Task_mixinActAbstract.ActionDomainEvent ev) {
    if(ev.getSemantics().isSafeInNature()) {
        return;
    }

    final Class stateTransitionClass = ev.getStateTransitionClass();
    final Task task = (Task) ev.getMixedIn();
    final StateTransition transition = stateTransitionService.findFor(task);
    if(transition == null) {
        // shouldn't occur
        return;
    }
    final Class taskTransitionClass = stateTransitionService.transitionClassFor(transition.getTransitionType());
    if(stateTransitionClass != taskTransitionClass) {
        // just ignore; this mixin action on task doesn't apply to the domain object that the task applies to.

        // or, maybe should hide (and then we can delete code in the subtypes of the mixinAbstract
        return;
    }

    final Object domainObject = transition.getDomainObject();
    applyPolicy(stateTransitionClass, domainObject, ev);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
@Subscribe
public void on(Communication.IconUiEvent ev) {
    if(ev.getIconName() != null) {
        return;
    }
    switch (ev.getSource().getType()) {
    case POSTAL_ADDRESS:
        ev.setIconName("postal");
        break;
    case EMAIL_ADDRESS:
        ev.setIconName("email");
        break;
    case PHONE_NUMBER:
        break;
    case FAX_NUMBER:
        break;
    }
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
@Subscribe
public void on(Document.IconUiEvent ev) {
    if(ev.getIconName() != null) {
        return;
    }
    final Document document = ev.getSource();
    final String documentName = document.getName();
    String iconName = "";
    if(documentName.endsWith(".xls") || documentName.endsWith(".xlsx")) {
        iconName = "xlsx";
    }
    if(documentName.endsWith(".doc") || documentName.endsWith(".docx")) {
        iconName = "docx";
    }
    if(documentName.endsWith(".ppt") || documentName.endsWith(".pptx")) {
        iconName = "pptx";
    }
    if(documentName.endsWith(".pdf")) {
        iconName = "pdf";
    }
    if(documentName.endsWith(".html")) {
        iconName = "html";
    }
    ev.setIconName(iconName);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(ProductSaleableEvent event) {
    LOG.info("ProductSaleableEvent: [{}]", event.getId());
    if (productRepository.exists(event.getId())) {
        Product product = productRepository.findOne(event.getId());
        if (!product.isSaleable()) {
            product.setSaleable(true);
            productRepository.save(product);
        }
    }
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
void on(ItemHasBeenMarkedAsPicked event) {
    AllTimeTopPickers picker = this.repository.findOne(event.getStoreAssistantId().toString());
    picker.increment();

    repository.save(picker);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
void on(ItemHasBeenMarkedAsPicked event) {
    String id = buildId(event.getOrderId(), event.getSku(), event.getStoreAssistantId());

    StoreAssistantPickedItem mostPicked = new StoreAssistantPickedItem(id, event.getSku().toString(), event.getStoreAssistantId().toString(), event.getStoreAssistantName());
    this.repository.save(mostPicked);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
void on(DeliverySlotReserved event) {
    AvailableSlotsForDay daySlots = repository.findOne(event.getDeliveryDayId().toString());
    daySlots.decrementCapacity();

    repository.save(daySlots);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
void on(NewReaderRegisteredEvent event) {
	
	ReaderEntry reader = new ReaderEntry();
	reader.setId(event.getReaderId());
	reader.setLibraryId(event.getLibraryId());
	reader.setName(event.getName());
	readerRepository.save(reader);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
void on(NewBookRegisteredEvent event) {
	BookEntry book = new BookEntry();
	book.setId(event.getBookId());
	book.setLibraryId(event.getLibraryId());
	book.setTitle(event.getTitle());
	book.setAuthor(event.getAuthor());
	book.setBorrowerId(null);
	bookEntryRepository.save(book);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void onRoleCreated(RoleCreatedEvent event) {
    if (log.isDebugEnabled()) {
        log.debug("Caught: " + event.getClass().getSimpleName());
    }

    this.id = event.getRoleId();
    this.name = event.getName();
    this.rights = event.getRights();
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void handleCreateRole(RoleCreatedEvent event) {
    if (log.isDebugEnabled()) {
        log.debug("Caught: " + event.getClass().getSimpleName());
    }
    
    Role role = roleRepository.save(new Role(event));

    if (log.isDebugEnabled()) {
        log.debug("Saved role object: " + role.toString());
    }
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
    public void handle(ToDoItemCreatedEvent event) {

        ToDoDto dto = new ToDoDto(event);
        if (log.isDebugEnabled()) {
            log.debug("Publishing to websocket channel: " + event);
            log.debug("Dto: " + dto);
        }

        // send event over web socket to user subscriber
        this.simpMessagingTemplate.convertAndSend("/topic/todos." + event.getUsername(), dto);
//        this.simpMessagingTemplate.convertAndSendToUser(event.getUsername(), "/topic/todos", event);
    }
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(ServiceSpecificationCreated event) {
    logger.debug("About to handle the ServiceSpecificationCreatedEvent: {}", event);
    ServiceSpecificationEntry entry = new ServiceSpecificationEntry();
    entry.setServiceSpecificationId(event.getServiceSpecificationId().identifier());
    entry.setOwnerId(event.getOwnerId().identifier());
    entry.setServiceType(event.getServiceType());
    entry.setName(event.getName());
    entry.setSummary(event.getSummary());
    serviceSpecificationQueryRepository.save(entry);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(ServiceInstanceAliasAdded event) {
    AliasRegistryEntry entry = new AliasRegistryEntry(
            event.getOrganizationId().identifier(),
            ServiceInstanceId.class.getName(),
            event.getAlias(),
            event.getServiceInstanceId().identifier()
    );
    save(entry);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(OrganizationCreated event) {
    logger.debug("About to handle the OrganizationCreatedEvent: {}", event);
    OrganizationEntry organizationEntry = new OrganizationEntry();
    organizationEntry.setOrganizationId(event.getOrganizationId().identifier());
    organizationEntry.setName(event.getName());
    organizationEntry.setSummary(event.getSummary());
    organizationEntry.setUrl(event.getUrl());
    organizationQueryRepository.save(organizationEntry);
}
 

import org.axonframework.eventhandling.annotation.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(ServiceInstanceCreated event) {
    ServiceInstanceEntry entry = new ServiceInstanceEntry();
    entry.setServiceInstanceId(event.getServiceInstanceId().identifier());
    entry.setProviderId(event.getProviderId().identifier());
    entry.setSpecificationId(event.getSpecificationId().identifier());
    entry.setName(event.getName());
    entry.setSummary(event.getSummary());
    entry.setCoverage(event.getCoverage());
    entry.setSpecificationServiceType(event.getServiceType());
    save(entry);
}