fine-task模块

• 任务模块：任务、通知管理模块，任务状态及进度管理，站内通知管理（待扩展邮件、短信、企业端消息）

依赖

• pom.xml

<!--fine-task-->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-task</artifactId>
    <version>${fine.version}</version>
</dependency>

任务存储配置application-task.yml

• src/main/resources/application-task.yml

fine:
  task:
    # 存储类型： redis , local
    # storage: redis
    # 任务缓存
    redis:
      # 任务缓存前缀
      # prefix: task
    local:
      # 本地任务存储路径
      # path: /task
      # 存储文件名称
      # ileName: task.json

创建子模块：fine-task

• 在fine-parent中创建：fine-task子模块

fine-task

• 创建子模块：New > Module...
• 添加短信依赖

依赖

• fine-task/pom.xml

<!--fine-boot-->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-boot</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-commons -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-commons</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-logs -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-logs</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-doc -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-doc</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-cache -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-cache</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-auth -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-auth</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>
<!-- fine-file -->
<dependency>
    <groupId>cn.finemap</groupId>
    <artifactId>fine-file</artifactId>
    <version>${fine.version}</version>
    <optional>true</optional>
</dependency>

fine-task使用

服务调用

创建

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){
    // 添加任务
    TaskVo taskVo = TaskVo.builder()
            .data("任务内容")
            .taskName("excel导入")
            .taskType(TaskTypeEnum.TASK)
            .taskStatus(TaskStatusEnum.RUNNING)
            .userList(List.of("userId1","userId2")) //为传入的用户id创建任务
            .build();
    Result<TaskVo> userTask = taskService.createTask(taskVo);
    if (!userTask.isSuccess()){
       return new Result(ResultCodes.ERROR, ResultCodes.ERROR_STRING, "创建任务失败");
    }
    
    // 添加当前用户任务
    TaskVo taskVo = TaskVo.builder()
                .data("任务内容")
                .taskName("excel导入")
                .taskType(TaskTypeEnum.TASK)
                .taskStatus(TaskStatusEnum.RUNNING)
                .build();
    Result<TaskVo> userTask = taskService.createUserTask(taskVo);
    if (!userTask.isSuccess()){
       return new Result(ResultCodes.ERROR, ResultCodes.ERROR_STRING, "创建任务失败");
    }
  
  }
}

查询

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){
    // 当前用户所有任务
    Result<List<TaskVo>> taskListResult = taskService.queryAll();

    // 查询当前应用任务
    Result<List<TaskVo>> taskListResult = taskService.queryApp();

    // 查询应用任务
    Result<List<TaskVo>> taskListResult = taskService.queryApp(name);

    // 获取单条任务
    String taskId = "3b9a7d2e-8c1f-4d6e-9a0b-1c2d3e4f5a6b";
    Result<TaskVo> taskResult = taskService.getTask(taskId);

  }
}

修改

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){

    // 修改任务:完成
    taskVo.setTaskStatus(TaskStatusEnum.COMPLETED);
    taskVo.setTaskProgress(100);
    Result<TaskVo> taskResult = taskService.updateTask(taskVo);

  }
}

删除

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){

    // 删除所有任务
    Result result = taskService.removeAll();

    // 删除单条任务
    String taskId = "3b9a7d2e-8c1f-4d6e-9a0b-1c2d3e4f5a6b";
    Result result = taskService.remove(taskId);

    // 删除已读任务
    Result result = taskService.removeRead();

  }
}

已读

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){

    // 全部已读任务
    Result result = taskService.readTaskAll();

    // 已读单条任务
    String taskId = "3b9a7d2e-8c1f-4d6e-9a0b-1c2d3e4f5a6b";
    Result result = taskService.readTask(taskId);

  }
}

统计

@Slf4j
@Service
public class TestService {

  @Autowired
  private TaskService taskService;

  public void test(){

    //获取所有应用的未读数量
    Result<Integer> unreadNum = taskService.countUnread(); 

    //获取当前应用的未读数量
    Result<Integer> appUnreadNum = taskService.countAppUnread(); 

    //fine-user应用未读数量
    Result<Integer> fineUserUnreadNum = taskService.countAppUnread("fine-user"); 

    //获取任务未读数量
    Result<Integer> taskUnreadNum = taskService.countTaskUnread(); 

    //获取通知未读数量
    Result<Integer> noticeUnreadNum = taskService.countNoticeUnread(); 

  }
}

API调用

任务管理（fine-task）