KPI / fw-morax

  package cn.fw.morax.server.task;
  

  import cn.fw.common.cache.locker.DistributedLocker;

  import cn.fw.morax.common.constant.TimeTaskConstant;

  import cn.fw.morax.rpc.oop.OopRpcService;
  import cn.fw.morax.rpc.oop.dto.GroupDTO;

  import cn.fw.morax.service.biz.salary.PayoffBizService;

  import cn.fw.morax.service.biz.salary.SalaryConfirmBizService;

  import lombok.Getter;

  import lombok.extern.slf4j.Slf4j;

  import org.redisson.api.RLock;

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

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

  import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
  import org.springframework.scheduling.annotation.Scheduled;
  import org.springframework.stereotype.Component;

  import org.springframework.util.CollectionUtils;
  
  import java.util.List;
  import java.util.concurrent.locks.Lock;

  
  /**
   * 通用定时器
   *
   * @author : kurisu
   * @version : 1.0
   * @className : PayoffTask
   * @description : 薪资发放定时器
   * @date : 2022-05-07 16:10
   */
  @Component
  @Slf4j
  @ConditionalOnProperty(prefix = "task", name = "switch", havingValue = "on")
  public class PayoffTask {
      private final PayoffBizService payoffBizService;

      private final DistributedLocker distributedLocker;
      private final OopRpcService oopRpcService;
      private final SalaryConfirmBizService salaryConfirmBizService;

      @Value("${spring.cache.custom.global-prefix}:createSalarySheet")
      @Getter
      private String createSalarySheetKey;
  

      @Autowired

      public PayoffTask(final PayoffBizService payoffBizService,
                        final DistributedLocker distributedLocker,
                        final OopRpcService oopRpcService,
                        final SalaryConfirmBizService salaryConfirmBizService) {

          this.payoffBizService = payoffBizService;

          this.distributedLocker = distributedLocker;
          this.oopRpcService = oopRpcService;
          this.salaryConfirmBizService = salaryConfirmBizService;

      }
  

      /**
       * 发放工资的准备
       * [展示不对接财务]
       */

  //    @Scheduled(initialDelay = 1000L * 10, fixedRate = 1000L * 30)

      public void read2payoff() {

  //        payoffBizService.read2payoff();

      }
  
      /**

       * 发放工资 [工资单数据推送财务系统]

       * [暂时不对接财务]
       */

  //    @Scheduled(initialDelay = 1000L * 20, fixedRate = 1000L * 20)

      public void go2pay() {

          //  payoffBizService.go2payoff();

      }
  
      /**

       * 生成工资单[工资发放记录]

       * 每两个小时执行
       */
      @Scheduled(cron = "0 0 0/2 * * ?")
      public void createSalarySheet() {

          Lock lock = distributedLocker.lock(getCreateSalarySheetKey());

          if (((RLock) lock).isLocked()) {
              List<GroupDTO> list = oopRpcService.allGroups();
              if (!CollectionUtils.isEmpty(list)) {
                  for (GroupDTO groupDTO : list) {
                      payoffBizService.createSalarySheet(groupDTO.getId());
                  }
              }
              lock.unlock();
          }
      }
  
      /**
       * 生成工资确认待办（在申述期开始时发送工资确认待办）
       * 每隔两小时检查一次是否有未生成确认待办的薪酬池数据
       */
      @Scheduled(cron = TimeTaskConstant.SALARY_CONFIRM_TODO)
      public void createSalaryConfirmTodo() {
          List<GroupDTO> list = oopRpcService.allGroups();
          for (GroupDTO groupDTO : list) {
              salaryConfirmBizService.createSalaryConfirmTodo(groupDTO.getId());
          }
      }
  
      /**

       * 每5分钟检查待办推送

       */

      @Scheduled(cron = "0 0/5 * * * ?")

      public void pushTodo() {
          salaryConfirmBizService.pushConfirm();
      }

  }