卷轴模式开发功能模块与源码解析

@RestControllerpublic class VideoController {    @Autowired    private StringRedisTemplate redisTemplate;    @PostMapping("/watchVideo")    public Map<String, Object> watchVideo(@RequestParamLong uid) {        Map<String, Object> result = new HashMap<>();        // 1. 检查缓存锁        String cacheKey = "cache_purchase_" + uid;        Boolean lock = redisTemplate.opsForValue()                .setIfAbsent(cacheKey, "1", 2, TimeUnit.SECONDS);        if (Boolean.FALSE.equals(lock)) {            result.put("code", 500054);            result.put("msg", "操作过于频繁");            return result;        }        try {            // 2. 获取用户信息（这里简化，实际需要从数据库查询）            User user = getUserFromDatabase(uid);            // 3. 检查任务次数            if (user.getTask() >= 5) {                result.put("code", 200);                result.put("msg", "任务已完成");                return result;            }            // 4. 更新任务次数            int newTaskCount = user.getTask() + 1;            updateUserTask(uid, newTaskCount);            // 5. 如果达到5次，发放奖励            if (newTaskCount == 5) {                sendReward(uid);            }            result.put("code", 200);            result.put("msg", "成功");            return result;        } catch (Exception e) {            result.put("code", 500);            result.put("msg", "系统错误");            return result;        }    }    private User getUserFromDatabase(Long uid) {        // 从数据库查询用户        // 实现数据库查询逻辑        return new User(); // 示例    }    private void updateUserTask(Long uid, int newTaskCount) {        // 更新数据库中的任务次数        // 实现数据库更新逻辑    }    private void sendReward(Long uid) {        // 发放奖励逻辑    }}

@Service@Transactional(rollbackFor = Exception.class)public class TaskService {    @Autowired    private UserTaskNotesMapper userTaskNotesMapper;    @Autowired    private FudouService fudouService;    @Autowired    private UserService userService;    @Autowired    private UserMapper userMapper;    /**     * 获取累积笔记（积分释放）     * @param uid 用户ID     * @return 操作结果     */    public boolean getLjNotes(Long uid) {        return TransactionSynchronizationManager.isActualTransactionActive()             ? executeInTransaction(uid)             : executeWithNewTransaction(uid);    }    /**     * 在现有事务中执行     */    private boolean executeInTransaction(Long uid) {        try {            return processLjNotes(uid);        } catch (Exception e) {            throw new BusinessException("领取失败", e);        }    }    /**     * 开启新事务执行     */    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)    public boolean executeWithNewTransaction(Long uid) {        try {            return processLjNotes(uid);        } catch (Exception e) {            throw new BusinessException("领取失败", e);        }    }    /**     * 处理累积笔记的核心逻辑     */    private boolean processLjNotes(Long uid) {        // 1. 获取该释放的所有积分        BigDecimal allJifen = userTaskNotesMapper.sumNumByCondition(uid, 1, 1);        if (allJifen == null || allJifen.compareTo(BigDecimal.ZERO) <= 0) {            return false;        }        // 2. 增加用户fudou余额        boolean res1 = userService.bcInc(uid, "fudou", allJifen, 4);        // 3. 创建fudou记录        Fudou fudou = new Fudou();        fudou.setUid(uid);        fudou.setType(5);        fudou.setNum(allJifen);        fudou.setPm(1);        fudou.setLinkId(0L);        fudou.setAddTime(LocalDateTime.now());        fudou.setLevel(66);        boolean res2 = fudouService.save(fudou);        // 4. 更新记录为释放状态        boolean res3 = userTaskNotesMapper.updateStatusByCondition(uid, 1, 1, 2) > 0;        // 5. 重置用户lj_num        boolean res4 = userService.update(uid, Map.of("lj_num", BigDecimal.ZERO));        if (res1 && res2 && res3 && res4) {            return true;        } else {            throw new BusinessException("领取失败");        }    }}