// JpaTaskStore.java
@Component // 关键：注册成Spring Bean
public class JpaTaskStore implements TaskStore {

    @Autowired
    private TaskDefinitionRepository taskRepo; // 自己写的JPA Repository

    @Override
    public void save(TaskDefinition definition) {
        // 把框架的TaskDefinition转成JPA实体
        TaskDefinitionEntity entity = TaskDefinitionEntity.from(definition);
        taskRepo.save(entity); // 用JPA存数据
    }

    // ... 实现TaskStore接口的其他方法（findById、deleteById这些）
}

@Bean
@ConditionalOnMissingBean(TaskStore.class) // 容器里没有TaskStore，我才生效
public TaskStore taskStore(...) {
    // 框架默认的实现（比如RedisTaskStore、MybatisTaskStore）
}

@Component
public class NacosTaskListener {

    @Autowired
    private TaskManager taskManager;

    // Nacos的监听注解，配置变了就调用这个方法
    @NacosConfigListener(dataId = "nacos-task-config.yaml", group = "DEFAULT_GROUP")
    public void onConfigChange(String configContent) {
        // 1. 把配置内容转成List<TaskDefinition> newTasks
        List<TaskDefinition> newTasks = YamlUtil.parse(configContent, new TypeReference<List<TaskDefinition>>() {
        });

        // 2. 拿当前运行的任务
        List<ManagedTask> currentTasks = taskManager.getAllTasks();

        // 3. 对比差异：删多余的、加新的、改状态
        syncTasks(newTasks, currentTasks);
    }

    private void syncTasks(List<TaskDefinition> newTasks, List<ManagedTask> currentTasks) {
        // 这里写具体的同步逻辑：
        // - 遍历currentTasks，不在newTasks里的就删
        // - 遍历newTasks，不在currentTasks里的就加
        // - 状态不一样的就改（比如配置里是RUNNING，当前是STOPPED就启动）
    }
}

@Component
public class ParamTaskService {

    @Autowired
    private TaskParamRepository paramRepo; // 存任务参数的库（可以是DB/Redis）

    // 方法还是无参，但能通过任务ID拿参数
    public void processWithParam() {
        // 问题：咋知道当前是哪个任务在调用？
        // 框架没传上下文，这是个小坑
        String taskId = ???; // 这里需要拿到当前任务的ID
        TaskParam param = paramRepo.findByTaskId(taskId); // 按ID拿参数
        // 用参数执行业务逻辑
    }
}

// TaskManagerImpl.java 里的resolveTaskDefinition方法
private Runnable resolveTaskDefinition(TaskDefinition definition) {
    Object bean = applicationContext.getBean(definition.getBeanName());
    Method method = findMethod(bean.getClass(), definition.getMethodName(), TaskDefinition.class); // 找带参数的方法

    // 原来的无参调用：() -> method.invoke(bean)
    // 改成传TaskDefinition：() -> method.invoke(bean, definition)
    return () -> {
        try {
            method.invoke(bean, definition); // 把任务定义传过去
        } catch (Exception e) {
            throw new RuntimeException("任务执行失败", e);
        }
    };
}

@Component
public class ParamTaskService {

    @Autowired
    private TaskParamRepository paramRepo;

    // 方法接收TaskDefinition参数
    public void processWithParam(TaskDefinition context) {
        String taskId = context.getId(); // 从上下文拿任务ID
        // 还能把参数存在context的description里（用JSON格式）
        String paramJson = context.getDescription();
        TaskParam param = JSON.parseObject(paramJson, TaskParam.class);

        // 用参数执行业务逻辑
        System.out.println("任务" + taskId + "的参数是：" + param);
    }
}