|
@@ -48,8 +48,8 @@ public class PlanServiceImpl implements PlanServiceInterface {
|
|
|
@Override
|
|
@Override
|
|
|
public Mono<RStatus<Paged<ListeningPlanNewRes2>>> page(PlanReqPage request, Criteria criteria) {
|
|
public Mono<RStatus<Paged<ListeningPlanNewRes2>>> page(PlanReqPage request, Criteria criteria) {
|
|
|
Query query = Query.query(criteria);
|
|
Query query = Query.query(criteria);
|
|
|
- int skip = (request.getPage() - 1) * request.getSize();
|
|
|
|
|
- int limit = request.getSize();
|
|
|
|
|
|
|
+ int skip = (request.getPage() - 1) * request.getSize();
|
|
|
|
|
+ int limit = request.getSize();
|
|
|
Mono<Long> count = template.count(query, PlanNewCommon.class);
|
|
Mono<Long> count = template.count(query, PlanNewCommon.class);
|
|
|
Flux<PlanNewCommon> createdAt = template.select(Query.query(criteria)
|
|
Flux<PlanNewCommon> createdAt = template.select(Query.query(criteria)
|
|
|
.offset(skip)
|
|
.offset(skip)
|
|
@@ -91,17 +91,17 @@ public class PlanServiceImpl implements PlanServiceInterface {
|
|
|
@Override
|
|
@Override
|
|
|
public Integer setUserVisitsToRedis(String unique, String code) {
|
|
public Integer setUserVisitsToRedis(String unique, String code) {
|
|
|
String redisKey = RedisKey.H5_USER_UNIQUE + unique;
|
|
String redisKey = RedisKey.H5_USER_UNIQUE + unique;
|
|
|
- Integer integer = 0;
|
|
|
|
|
- if (Boolean.TRUE.equals(stringRedisTemplate.hasKey(redisKey))){
|
|
|
|
|
- Object val = stringRedisTemplate.opsForHash().get(unique, code);
|
|
|
|
|
|
|
+ int integer = 0;
|
|
|
|
|
+ if (Boolean.TRUE.equals(stringRedisTemplate.hasKey(redisKey))) {
|
|
|
|
|
+ Object val = stringRedisTemplate.opsForHash().get(redisKey, code);
|
|
|
if (val != null) {
|
|
if (val != null) {
|
|
|
- integer = Integer.getInteger(val.toString());
|
|
|
|
|
|
|
+ integer = Integer.parseInt(val.toString());
|
|
|
integer = integer + 1;
|
|
integer = integer + 1;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- stringRedisTemplate.opsForHash().put(redisKey, code, integer.toString());
|
|
|
|
|
|
|
+ stringRedisTemplate.opsForHash().put(redisKey, code, Integer.toString(integer));
|
|
|
// 设置过期时间
|
|
// 设置过期时间
|
|
|
- LocalDateTime expireTime = LocalDateTime.of(LocalDate.now().plusDays(1), LocalTime.of(4,0));
|
|
|
|
|
|
|
+ LocalDateTime expireTime = LocalDateTime.of(LocalDate.now().plusDays(1), LocalTime.of(4, 0));
|
|
|
long minute = Duration.between(LocalDateTime.now(), expireTime).toMinutes();
|
|
long minute = Duration.between(LocalDateTime.now(), expireTime).toMinutes();
|
|
|
stringRedisTemplate.expire(redisKey, minute, TimeUnit.MINUTES);
|
|
stringRedisTemplate.expire(redisKey, minute, TimeUnit.MINUTES);
|
|
|
return integer;
|
|
return integer;
|