shayu/xq-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init

Browse Source
This commit is contained in:
77
2024-03-18 20:42:53 +08:00
parent a75e7b3257
commit 79927fb17d
8 changed files with 167 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ruoyi-xq/src/main/java/com/ruoyi/xq/service/UserVisitorService.java
View File

@@ -1,7 +1,11 @@
package com.ruoyi.xq.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.common.core.domain.PageQuery;
import com.ruoyi.xq.domain.UserVisitor;
import com.ruoyi.xq.dto.app.uservisitor.UserVisitorQuery;
import com.ruoyi.xq.dto.app.uservisitor.vo.UserVisitorListVo;
/**
* 用户来访记录Service接口
@@ -11,4 +15,7 @@ import com.ruoyi.xq.domain.UserVisitor;
*/
public interface UserVisitorService extends IService<UserVisitor> {
void visitor(Long userId, Long tarUserId);
Page<UserVisitorListVo> pageApp(PageQuery pageQuery, UserVisitorQuery query);
}

52
ruoyi-xq/src/main/java/com/ruoyi/xq/service/impl/UserVisitorServiceImpl.java
View File

@@ -1,9 +1,20 @@
package com.ruoyi.xq.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.core.domain.PageQuery;
import com.ruoyi.xq.domain.User;
import com.ruoyi.xq.domain.UserVisitor;
import com.ruoyi.xq.dto.app.uservisitor.UserVisitorQuery;
import com.ruoyi.xq.dto.app.uservisitor.vo.UserVisitorListVo;
import com.ruoyi.xq.lock.LockKey;
import com.ruoyi.xq.mapper.UserVisitorMapper;
import com.ruoyi.xq.service.UserService;
import com.ruoyi.xq.service.UserVisitorService;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
@@ -14,5 +25,46 @@ import org.springframework.stereotype.Service;
*/
@Service
public class UserVisitorServiceImpl extends ServiceImpl<UserVisitorMapper,UserVisitor> implements UserVisitorService {
@Autowired
private RedissonClient redissonClient;
@Autowired
private UserService userService;
@Override
public void visitor(Long userId, Long tarUserId) {
User user = userService.getById(userId);
User tarUser = userService.getById(tarUserId);
if(user == null || tarUser == null){
return;
}
UserVisitor one = this.getOne(Wrappers.lambdaQuery(UserVisitor.class).eq(UserVisitor::getUserId, userId)
.eq(UserVisitor::getTarId, tarUserId).last("limit 1"));
if(one != null){
baseMapper.incsVisitorCount(one.getId());
return;
}
RLock lock = redissonClient.getLock(LockKey.getUserVisitorAddLockKey(userId, tarUserId));
try {
lock.lock();
one = this.getOne(Wrappers.lambdaQuery(UserVisitor.class).eq(UserVisitor::getUserId, userId)
.eq(UserVisitor::getTarId, tarUserId).last("limit 1"));
if(one != null){
return;
}
UserVisitor userVisitor = new UserVisitor();
userVisitor.setUserId(user.getId());
userVisitor.setUsercode(user.getUsercode());
userVisitor.setTarId(tarUser.getId());
userVisitor.setTarUsercode(tarUser.getUsercode());
userVisitor.setVisitorNum(1);
this.save(userVisitor);
}finally {
lock.unlock();
}
}
@Override
public Page<UserVisitorListVo> pageApp(PageQuery pageQuery, UserVisitorQuery query) {
return baseMapper.pageApp(pageQuery.build(), query);
}
}