/**
 * @Author JiaQIng
 * @Description 修改密碼事件
 * @ClassName UserChangePasswordEvent
 * @Date 2023/3/26 13:55
 **/
@Getter
@Setter
public class UserChangePasswordEvent extends ApplicationEvent {
    private String userId;


    public UserChangePasswordEvent(String userId) {
        super(new Object());
        this.userId = userId;
    }
}

/**
 * @Author JiaQIng
 * @Description 發(fā)送短信監(jiān)聽器
 * @ClassName MessageListener
 * @Date 2023/3/26 14:16
 **/
@Component
public class MessageListener implements ApplicationListener<UserChangePasswordEvent> {


    @Override
    public void onApplicationEvent(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作給用戶發(fā)送短信。用戶userId為：" + event.getUserId());
    }
}

/**
 * @Author JiaQIng
 * @Description 事件監(jiān)聽器
 * @ClassName LogListener
 * @Date 2023/3/26 14:22
 **/
@Component
public class ListenerEvent {


    @EventListener({ UserChangePasswordEvent.class })
    public void LogListener(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作生成關鍵日志。用戶userId為：" + event.getUserId());
    }


    @EventListener({ UserChangePasswordEvent.class })
    public void messageListener(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作給用戶發(fā)送短信。用戶userId為：" + event.getUserId());
    }
}

// 在這個注解上面有一個注解：`@EventListener`，所以表明其實這個注解也是個事件監(jiān)聽器。 
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@EventListener
public @interface TransactionalEventListener {


  /**
   * 這個注解取值有：BEFORE_COMMIT(指定目標方法在事務commit之前執(zhí)行)、AFTER_COMMIT(指定目標方法在事務commit之后執(zhí)行)、
   *  AFTER_ROLLBACK(指定目標方法在事務rollback之后執(zhí)行)、AFTER_COMPLETION(指定目標方法在事務完成時執(zhí)行，這里的完成是指無論事務是成功提交還是事務回滾了)
   * 各個值都代表什么意思表達什么功能，非常清晰，
   * 需要注意的是：AFTER_COMMIT + AFTER_COMPLETION是可以同時生效的
   * AFTER_ROLLBACK + AFTER_COMPLETION是可以同時生效的
   */
  TransactionPhase phase() default TransactionPhase.AFTER_COMMIT;


  /**
   * 表明若沒有事務的時候，對應的event是否需要執(zhí)行，默認值為false表示，沒事務就不執(zhí)行了。
   */
  boolean fallbackExecution() default false;


  /**
   *  這里巧妙的用到了@AliasFor的能力，放到了@EventListener身上
   *  注意：一般建議都需要指定此值，否則默認可以處理所有類型的事件，范圍太廣了。
   */
  @AliasFor(annotation = EventListener.class, attribute = "classes")
  Class<?>[] value() default {};


  /**
   * The event classes that this listener handles.
   * <p>If this attribute is specified with a single value, the annotated
   * method may optionally accept a single parameter. However, if this
   * attribute is specified with multiple values, the annotated method
   * must <em>not</em> declare any parameters.
   */
  @AliasFor(annotation = EventListener.class, attribute = "classes")
  Class<?>[] classes() default {};


  /**
   * Spring Expression Language (SpEL) attribute used for making the event
   * handling conditional.
   * <p>The default is {@code ""}, meaning the event is always handled.
   * @see EventListener#condition
   */
  @AliasFor(annotation = EventListener.class, attribute = "condition")
  String condition() default "";


  /**
   * An optional identifier for the listener, defaulting to the fully-qualified
   * signature of the declaring method (e.g. "mypackage.MyClass.myMethod()").
   * @since 5.3
   * @see EventListener#id
   * @see TransactionalApplicationListener#getListenerId()
   */
  @AliasFor(annotation = EventListener.class, attribute = "id")
  String id() default "";


}

/**
 * @Author JiaQIng
 * @Description 事件監(jiān)聽器
 * @ClassName LogListener
 * @Date 2023/3/26 14:22
 **/
@Component
public class ListenerEvent {


    @EventListener({ UserChangePasswordEvent.class })
    public void logListener(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作生成關鍵日志。用戶userId為：" + event.getUserId());
    }


    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT,value = { UserChangePasswordEvent.class })
    public void messageListener(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作給用戶發(fā)送短信。用戶userId為：" + event.getUserId());
    }
}

@SpringBootTest
class SpirngEventApplicationTests {
    @Autowired
    ApplicationEventPublisher appEventPublisher;
    @Test
    void contextLoads() {
        appEventPublisher.publishEvent(new UserChangePasswordEvent("1111111"));
    }


}

@EnableAsync
@SpringBootApplication
public class SpirngEventApplication {


    public static void main(String[] args) {
        SpringApplication.run(SpirngEventApplication.class, args);
    }


}

/**
 * @Author JiaQIng
 * @Description 事件監(jiān)聽器
 * @ClassName LogListener
 * @Date 2023/3/26 14:22
 **/
@Component
public class ListenerEvent {
    
    @Async
    @EventListener({ UserChangePasswordEvent.class })
    public void logListener(UserChangePasswordEvent event) {
        System.out.println("收到事件:" + event);
        System.out.println("開始執(zhí)行業(yè)務操作生成關鍵日志。用戶userId為：" + event.getUserId());
    }
}