valhalla / fw-valhalla

  package cn.fw.valhalla.service.bus.listener;

  import cn.fw.valhalla.domain.db.follow.ClueTask;

  import cn.fw.valhalla.domain.enums.FollowTypeEnum;

  import cn.fw.valhalla.domain.vo.setting.SettingVO;

  import cn.fw.valhalla.service.bus.follow.FollowBizService;

  import cn.fw.valhalla.service.bus.follow.strategy.impl.PubFollowStrategy;

  import cn.fw.valhalla.service.bus.setting.SettingBizService;

  import cn.fw.valhalla.service.event.PublicPoolEvent;
  import cn.fw.valhalla.service.event.SettingChangeEvent;
  import cn.fw.valhalla.service.event.StopTaskEvent;
  import cn.fw.valhalla.service.event.TaskCancelEvent;

  import lombok.extern.slf4j.Slf4j;

  import org.springframework.beans.factory.annotation.Autowired;

  import org.springframework.context.event.EventListener;
  import org.springframework.stereotype.Component;

  import java.util.List;

  import java.util.Objects;
  import java.util.Optional;
  

  /**
   * @author : kurisu
   * @className : CustomEventListener
   * @description : 事件监听器
   * @date: 2020-08-18 16:28
   */
  @Component
  @Slf4j
  public class CustomEventListener {
      private final SettingBizService settingBizService;
      private final FollowBizService followBizService;

      private final PubFollowStrategy pubFollowStrategy;

      @Autowired

      public CustomEventListener(final SettingBizService settingBizService,

                                 final FollowBizService followBizService,
                                 final PubFollowStrategy pubFollowStrategy) {

          this.settingBizService = settingBizService;
          this.followBizService = followBizService;

          this.pubFollowStrategy = pubFollowStrategy;

      }
  
      /**
       * 监听跟进任务取消事件
       *
       * @param event
       */
      @EventListener(TaskCancelEvent.class)

      public void onDataCancel(final TaskCancelEvent event) {

          followBizService.onDataCancel(event);
      }
  
      /**
       * 当设置发生改变时
       *
       * @param event
       */
      @EventListener(SettingChangeEvent.class)

      public void onSettingChange(final SettingChangeEvent event) {

          final FollowTypeEnum type = event.getType();

          if (Objects.isNull(type) || FollowTypeEnum.OT.equals(type)) {

              return;
          }

          Optional<List<SettingVO>> listOptional = Optional.ofNullable(settingBizService.querySettingByCat(type.getValue(), event.getGroupId(), event.getBrandId()));

          listOptional.ifPresent(settingList -> followBizService.synFollowTask(settingList, type, event.getGroupId()));

      }
  

      /**
       * 档案进入公共池
       *
       * @param event
       */
      @EventListener(PublicPoolEvent.class)

      public void stopTaskAndAddPublic(final PublicPoolEvent event) {

          String vin = event.getVin();
          Long groupId = event.getGroupId();

          boolean fromTask = event.isFromTask();
  

          followBizService.stopClue(vin, groupId, fromTask);
          pubFollowStrategy.clueConvertFailedFromFlow(vin, groupId);

      }

  
      /**

       * 审批终止 续保/事故车 任务

       *
       * @param event
       */
      @EventListener(StopTaskEvent.class)
      public void stopTask(final StopTaskEvent event) {

          ClueTask task = event.getTask();

          followBizService.stopTask(task);
      }

  }