xxl定时器任务,数据库查询MP无法拼接租户条件

南希 剑童 2024-01-30 11:03

@XxlJob("asyncReceivingSendInspection")
public void asyncReceivingSendInspection()

BladeX-Tool
org.springblade2.9.0.RELEASE

• 

  zhx1994 - BladeX技术支持

  2024-01-30 11:21

  可以写个TenantJob注解，然后写个AOP拦截该注解执行任务，任务执行时，会按照租户逐个设置租户id执行 Job 的逻辑。

  @Target({ElementType.METHOD})
  @Retention(RetentionPolicy.RUNTIME)
  public @interface TenantJob {
  }

  @Aspect
  @RequiredArgsConstructor
  @Slf4j
  public class TenantJobAspect {
  
      private final TenantFrameworkService tenantFrameworkService;
  
      @Around("@annotation(tenantJob)")
      public String around(ProceedingJoinPoint joinPoint, TenantJob tenantJob) {
          // 获得租户列表
          List<Long> tenantIds = tenantFrameworkService.getTenantIds();
          if (CollUtil.isEmpty(tenantIds)) {
              return null;
          }
  
          // 逐个租户，执行 Job
          Map<Long, String> results = new ConcurrentHashMap<>();
          tenantIds.parallelStream().forEach(tenantId -> {
              TenantUtils.execute(tenantId, () -> {
                  try {
                      joinPoint.proceed();
                  } catch (Throwable e) {
                      results.put(tenantId, ExceptionUtil.getRootCauseMessage(e));
                  }
              });
          });
          return JsonUtils.toJsonString(results);
      }
  
  }

  
  

  作者追问:2024-01-30 14:12

  感谢回复
  0 讨论(0)
  评论:

  提交评论

  ---

  •  加载中...

验证码

 看不清?

提交回复