Merge remote-tracking branch 'refs/remotes/origin/dev'

This commit is contained in:
landaiqing
2024-07-23 21:17:04 +08:00
2 changed files with 28 additions and 12 deletions

View File

@@ -13,12 +13,10 @@ import com.schisandra.share.common.utils.CaffeineUtil;
import com.schisandra.share.domain.bo.SchisandraShareDetailBO;
import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO;
import com.schisandra.share.domain.service.SchisandraShareDetailDomainService;
import feign.form.FormData;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
@@ -49,6 +47,13 @@ public class SchisandraShareDetailController {
@Resource
private RocketMQTemplate rocketMQTemplate;
@GetMapping("getRecentShare")
public Result getRecentShare(String userId) {
String key = redisUtil.buildKey(SHARE_USER_RECENT, userId, "*");
List<HashMap<Object, Object>> list = redisUtil.getDataFromShare(key);
return Result.ok(list);
}
/**
* @description: 点赞

View File

@@ -53,6 +53,17 @@ public class RedisUtil {
});
return keysList;
}
public List<HashMap<Object,Object>> getDataFromShare(String directory) {
Set<String>keys=redisTemplate.keys(directory);
List<HashMap<Object,Object>> keysList=new ArrayList<>();
keys.forEach(key->{
HashMap<Object,Object> map=new HashMap<>();
String value= (String) redisTemplate.opsForValue().get(key);
map.put(key,value);
keysList.add(map);
});
return keysList;
}