@GetMapping("/list")
    @ApiOperation("根據(jù)分類id查詢套餐")
    @Cacheable(cacheNames = "setmealCache",key = "#categoryId")
    public Result<List<Setmeal>> list(Long categoryId) {
        Setmeal setmeal = new Setmeal();
        setmeal.setCategoryId(categoryId);
        setmeal.setStatus(StatusConstant.ENABLE);
        List<Setmeal> list = setmealService.list(setmeal);
        return Result.success(list);
    }

    @GetMapping("/{id}")
    @ApiOperation("根據(jù)id查詢套餐")
    @CachePut(cacheNames = "setmealCache",key = "#categoryId")
    public Result<SetmealVO> getById(@PathVariable Long id) {
        SetmealVO setmealVO = setmealService.getByIdWithDish(id);
        return Result.success(setmealVO);
    }

    @PostMapping
    @ApiOperation("新增套餐")
    @CacheEvict(cacheNames = "setmealCache",key = "#setmealDTO.categoryId")
    public Result save(@RequestBody SetmealDTO setmealDTO) {
        setmealService.saveWithDish(setmealDTO);
        return Result.success();
    }

@CacheEvict(cacheNames = "setmealCache", allEntries = true)
public Result startOrStop(@PathVariable Integer status, Long id) {
    setmealService.startOrStop(status, id);
    return Result.success();
}

@Cacheable("user")
public User getUserById(Long id) {
    return userRepository.findById(id);
}

Boolean success = redisTemplate.opsForValue().setIfAbsent("lock_key", "locked", 30, TimeUnit.SECONDS);

@Autowired
private StringRedisTemplate stringRedisTemplate;
public void stringOperationsExample(String key, String value) {
    // 設(shè)置字符串值
    stringRedisTemplate.opsForValue().set(key, value);
    // 獲取字符串值
    String retrievedValue = stringRedisTemplate.opsForValue().get(key);
    System.out.println("Retrieved Value: " + retrievedValue);
}

public void hashOperationsExample(String key, String field, String value) {
    // 設(shè)置哈希表中的字段值
    stringRedisTemplate.opsForHash().put(key, field, value);
    // 獲取哈希表中字段的值
    Object fieldValue = stringRedisTemplate.opsForHash().get(key, field);
    System.out.println("Field Value: " + fieldValue);
}

public void listOperationsExample(String key, String... values) {
    // 右側(cè)插入元素到列表
    for (String value : values) {
        stringRedisTemplate.opsForList().rightPush(key, value);
    }
    
    // 獲取列表中的所有元素
    List<String> elements = stringRedisTemplate.opsForList().range(key, 0, -1);
    
    System.out.println("List Elements: " + elements);
}

public void setOperationsExample(String key, String... members) {
    // 添加成員到集合
    for (String member : members) {
        stringRedisTemplate.opsForSet().add(key, member);
    }
    // 獲取集合中的所有成員
    Set<String> membersSet = stringRedisTemplate.opsForSet().members(key);
    System.out.println("Members of Set: " + membersSet);
}

public void sortedSetOperationsExample(String key, String member, double score) {
    // 添加成員到有序集合并指定分數(shù)
    stringRedisTemplate.opsForZSet().add(key, member, score);
    // 獲取有序集合中的所有成員及其分數(shù)
    Set<ZSetOperations.TypedTuple<String>> tuples = stringRedisTemplate.opsForZSet().rangeWithScores(key, 0, -1);
    tuples.forEach(tuple -> System.out.println("Member: " + tuple.getValue() + ", Score: " + tuple.getScore()));
}

@Autowired
private StringRedisTemplate stringRedisTemplate;
// 訂閱者
public void subscribeToChannel(String channelName) {
    stringRedisTemplate.getConnectionFactory().getConnection().subscribe((message, pattern) -> {
        System.out.println("Received message on channel [" + new String(pattern) + "] with content: " + new String(message.getBody()));
    }, channelName.getBytes());
}
// 發(fā)布者
public void publishToChannel(String channelName, String message) {
    stringRedisTemplate.convertAndSend(channelName, message);
}

@Autowired
private StringRedisTemplate stringRedisTemplate;
public void executeLuaScript() {
    DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
    redisScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("lua_script.lua")));
    redisScript.setResultType(Long.class);
    List<String> keys = Arrays.asList("key1", "key2");
    Long result = stringRedisTemplate.execute(redisScript, keys, "arg1");
    System.out.println("Lua Script Result: " + result);
}

@Autowired
private StringRedisTemplate stringRedisTemplate;
public boolean acquireLock(String lockKey, long timeout) throws InterruptedException {
    long millisecondsTimeout = System.currentTimeMillis() + timeout;
    while (System.currentTimeMillis() < millisecondsTimeout) {
        Boolean success = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, "locked", Duration.ofMinutes(1));
        if (Boolean.TRUE.equals(success)) {
            return true;
        }
        Thread.sleep(100); // 等待一段時間后重試
    }
    return false;
}
public void releaseLock(String lockKey) {
    stringRedisTemplate.delete(lockKey);
}

public void geoOperationsExample() {
    stringRedisTemplate.opsForGeo().add("cities",
        new Point(13.361389, 38.115556), "Palermo",
        new Point(15.087269, 37.502669), "Catania");
    Distance distance = stringRedisTemplate.opsForGeo().distance("cities", "Palermo", "Catania", RedisGeoCommands.DistanceUnit.KILOMETERS);
    System.out.println("Distance between Palermo and Catania: " + distance.getValue() + " km");
}

public void pipelineOperationsExample() {
    List<Object> results = stringRedisTemplate.executePipelined((RedisCallback<String>) connection -> {
        connection.openPipeline();
        connection.set("key1".getBytes(), "value1".getBytes());
        connection.incr("key2".getBytes());
        return null;
    });
    System.out.println("Pipeline Results: " + results);
}

public void transactionOperationsExample() {
    stringRedisTemplate.execute(new SessionCallback<List<Object>>() {
        @Override
        public List<Object> execute(RedisOperations operations) throws DataAccessException {
            operations.multi();
            operations.opsForValue().increment("key1");
            operations.opsForValue().increment("key2");
            return operations.exec(); // 執(zhí)行并返回結(jié)果
        }
    });
}

public void ttlOperationsExample(String key) {
    // 設(shè)置TTL
    stringRedisTemplate.expire(key, Duration.ofMinutes(10));
}
public void scanKeysExample() {
    ScanOptions options = ScanOptions.scanOptions().match("*").count(100).build();
    Cursor<Map.Entry<byte[], byte[]>> cursor = stringRedisTemplate.executeWithStickyConnection(
        redisConnection -> new ConvertingCursor<>(redisConnection.scan(options),
            entry -> new AbstractMap.SimpleEntry<>(new String(entry.getKey()), new String(entry.getValue()))));
    while (cursor.hasNext()) {
        Map.Entry<String, String> entry = cursor.next();
        System.out.println("Key: " + entry.getKey() + ", Value: " + entry.getValue());
    }
}