lsh#站点同步至MES

1

昨天 b2deb1cc93b3d2c3fb9dc795e3589e1c62329a8f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package com.vincent.rsf.server.ai.store.support;
 
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
 
import java.util.Set;
 
@Component
@RequiredArgsConstructor
public class AiRedisIndexSupport {
 
    private final AiRedisExecutor aiRedisExecutor;
 
    public void remember(String indexKey, String cacheKey) {
        if (indexKey == null || cacheKey == null) {
            return;
        }
        aiRedisExecutor.executeVoid(jedis -> jedis.sadd(indexKey, cacheKey));
    }
 
    public void forget(String indexKey, String cacheKey) {
        if (indexKey == null || cacheKey == null) {
            return;
        }
        aiRedisExecutor.executeVoid(jedis -> jedis.srem(indexKey, cacheKey));
    }
 
    public void deleteTrackedKeys(String indexKey) {
        if (indexKey == null) {
            return;
        }
        aiRedisExecutor.executeVoid(jedis -> {
            Set<String> keys = jedis.smembers(indexKey);
            if (keys != null && !keys.isEmpty()) {
                jedis.del(keys.toArray(new String[0]));
            }
            jedis.del(indexKey);
        });
    }
}