异步上传石墨文件进度条前端展示记录（采用Redis中List数据结构实现）

    /**
     * 将任务状态添加到Redis列表中
     * @param redisTemplate Redis模板
     */
    public void addTaskToList(RedisTemplate<String, Object> redisTemplate) {
        String taskKey = this.findTaskCacheKey();
        redisTemplate.opsForList().leftPush(taskKey, this);
        redisTemplate.expire(taskKey, 1, TimeUnit.DAYS);
    }
​
​
​
    /**
     * 更新任务进度
     * @param status 状态
     * @param msg 消息
     * @param addPercent 增加的进度百分比
     * @param redisTemplate Redis模板（使用这个进行存储调用）
     */
    public void commonUpdate(String status, String msg, Integer addPercent, RedisTemplate<String, Object> redisTemplate) {
        this.commonUpdate(status, msg, addPercent, null, redisTemplate);
    }
​
​
    /**
         * 从Redis中清理任务进度记录
         * @param taskId 任务ID
         * @param userCode 用户编码
         * @param targetStatus 目标状态（SUCCESS或FAILED）- 只保留这个状态的记录，若为null则删除所有记录
         */
    private void clearTaskProgressRecords(String taskId, String userCode, String targetStatus) {
        try {
            // 获取用户任务列表的键
            String userTasksKey = String.format("%s:%s", TASK_PROCESS_PREFIX_KEY, userCode);
​
            // 获取当前任务列表
            List<Object> tasksList = redisTemplate.opsForList().range(userTasksKey, 0, -1);
            if (tasksList != null && !tasksList.isEmpty()) {
                // 收集需要删除的元素和需要保留的元素
                List<Object> toRemove = new ArrayList<>();
                Object targetRecord = null;
​
                for (Object taskObj : tasksList) {
                    try {
                        // 检查对象类型
                        if (taskObj instanceof xxxx) {
                            LongTaskProcessResponse task = (xxx) taskObj;
                            String currentTaskId = task.getTaskId();
                            String status = task.getStatus();
​
                            // 如果找到匹配的任务ID
                            if (taskId.equals(currentTaskId)) {
                                // 如果指定了目标状态，检查是否匹配
                                if (targetStatus != null && targetStatus.equals(status)) {
                                    // 保留目标状态的记录
                                    targetRecord = taskObj;
                                } else {
                                    // 删除非目标状态的记录
                                    toRemove.add(taskObj);
                                }
                            }
                        } else {
                            log.warn("任务对象类型不正确，无法处理：{}",
                                    taskObj != null ? taskObj.getClass().getName() : "null");
                        }
                    } catch (Exception e) {
                        log.warn("处理任务对象失败: {}", e.getMessage());
                    }
                }
​
                // 删除收集到的所有元素
                for (Object obj : toRemove) {
                    redisTemplate.opsForList().remove(userTasksKey, 0, obj);
                }
​
                // 如果目标记录存在，确保它在列表的最前面（最新）
                if (targetRecord != null) {
                    // 先删除，再添加到列表头部，确保是最新的记录
                    redisTemplate.opsForList().remove(userTasksKey, 0, targetRecord);
                    redisTemplate.opsForList().leftPush(userTasksKey, targetRecord);
                }
​
                if (!toRemove.isEmpty()) {
                    log.info("从Redis中清理任务进度记录，userCode: {}, taskId: {}, 删除记录数: {}, 保留状态: {}",
                            userCode, taskId, toRemove.size(), targetStatus);
                }
            }
        } catch (Exception e) {
            log.error("从Redis中清理任务进度记录失败，taskId: {}, userCode: {}", taskId, userCode, e);
        }
    }

                // 创建一个纯粹的失败状态记录
                LongTaskProcessResponse failedResponse = new LongTaskProcessResponse();
                failedResponse.setTaskId(subTaskResponse.getTaskId());
                failedResponse.setBusinessType(subTaskResponse.getBusinessType());
                failedResponse.setStatus(KbProcessStatus.FAILED.name());
                failedResponse.setMsg("处理失败: " + e.getMessage());
                failedResponse.setProcessPercent(new BigDecimal(0));
                failedResponse.setUserCode(currentUser.getCode());
                failedResponse.setTitle(subTaskResponse.getTitle());
                failedResponse.setCreateTime(System.currentTimeMillis());
                failedResponse.setExtraData(subTaskResponse.getExtraData());
​
                // 添加失败记录
                failedResponse.addTaskToList(redisTemplate);
​
    /**
     * 将任务状态添加到Redis列表中
     * @param redisTemplate Redis模板
     */
    public void addTaskToList(RedisTemplate<String, Object> redisTemplate) {
        String taskKey = this.findTaskCacheKey();
        redisTemplate.opsForList().leftPush(taskKey, this);
        redisTemplate.expire(taskKey, 1, TimeUnit.DAYS);
    }