写出这段代码优化后的示例// 用户完成阅读任务的上限 List<TaskRuleDetail> taskRuleDetails = taskRuleDetailMapp...

朱雀 2024-03-26 10:11 33阅读 0赞

优化后的代码示例如下：

\`\`\` List taskRuleDetails = taskRuleDetailMapper.selectTaskGroupListCode(taskDTO.getGroupCode(), taskDTO.getTaskCode()); if (CollectionUtils.isEmpty(taskRuleDetails)) \{ throw new BusinessRuntimeException(ErrorCodeConstant.\_3004010.getCode(), ErrorCodeConstant.\_3004010.getMessage()); \} List<Map<String, Object>> result = getResult(taskRuleDetails); Map<String, Object> map = result.get(0);

// 定义用户 ID String userId = crmId + ":" + getDate(); // 定义分布式锁的 key String taskLockKey = "task:lock:" + userId; // 定义计数器的 key String readCountKey = "task:user:count:" + userId;

Object articlePlatformShared = map.get("reading\_article\_platform\_shared"); if (articlePlatformShared != null) \{ // 获取当天最大完成量 int READING\_TASK\_LIMIT = (Integer) map.get("day\_complete\_task\_max"); // 如果文章平台未共享，则添加 appCode 作为计数器的后缀 if (!"1".equals(articlePlatformShared)) \{ readCountKey += ":" + taskDTO.getAppCode(); \} \}

// 使用 RedisTemplate 获取用户已完成的阅读任务数 ValueOperations<String, String> ops = redisTemplate.opsForValue(); String dayCount = ops.get(readCountKey); // 如果计数器不存在，则设为 0 if (StringUtils.isEmpty(dayCount)) \{ dayCount = "0"; \} // 如果用户已完成的阅读任务数达到上限，则不再完成任务 int anInt = Integer.parseInt(dayCount); if (anInt >= READING\_TASK\_LIMIT) \{ log.warn("警告用户完成任务上限后再次完成"); return; \}

// 使用 Redisson 获取分布式锁 RLock lock = redissonClient.getLock(taskLockKey); lock.lock(); try \{ // 完成阅读任务，并将用户已完成的阅读任务数加 1 ops