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

数据

Browse Source
This commit is contained in:
77
2024-08-03 19:26:31 +08:00
parent cf9081d69f
commit 90620baea4
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserGreetServiceImpl.java
View File

@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.cai.constant.RedisHttpConstant; import com.ruoyi.cai.constant.RedisHttpConstant;
import com.ruoyi.cai.domain.Anchor;
import com.ruoyi.cai.domain.User; import com.ruoyi.cai.domain.User;
import com.ruoyi.cai.domain.UserGreet; import com.ruoyi.cai.domain.UserGreet;
import com.ruoyi.cai.dto.admin.vo.UserGreetAdminVo; import com.ruoyi.cai.dto.admin.vo.UserGreetAdminVo;
@@ -17,6 +18,7 @@ import com.ruoyi.cai.manager.LockManager;
import com.ruoyi.cai.manager.SystemConfigManager; import com.ruoyi.cai.manager.SystemConfigManager;
import com.ruoyi.cai.mapper.UserGreetMapper; import com.ruoyi.cai.mapper.UserGreetMapper;
import com.ruoyi.cai.mapper.UserMapper; import com.ruoyi.cai.mapper.UserMapper;
import com.ruoyi.cai.service.AnchorService;
import com.ruoyi.cai.service.UserGreetService; import com.ruoyi.cai.service.UserGreetService;
import com.ruoyi.cai.service.UserService; import com.ruoyi.cai.service.UserService;
import com.ruoyi.common.core.domain.PageQuery; import com.ruoyi.common.core.domain.PageQuery;
@@ -58,6 +60,8 @@ public class UserGreetServiceImpl extends ServiceImpl<UserGreetMapper,UserGreet>
private Yunxin yunxin; private Yunxin yunxin;
@Resource @Resource
private UserMapper userMapper; private UserMapper userMapper;
@Autowired
private AnchorService anchorService;
@Override @Override
public List<UserGreet> listByUserId(Long userId) { public List<UserGreet> listByUserId(Long userId) {
@@ -133,6 +137,8 @@ public class UserGreetServiceImpl extends ServiceImpl<UserGreetMapper,UserGreet>
} }
} }
} }
Anchor anchor = anchorService.getByUserId(userId);
if(anchor.getEnableGreet() == 1){
List<Long> toUserIds = userMapper.getGreetNumId(userId); List<Long> toUserIds = userMapper.getGreetNumId(userId);
if(CollectionUtil.isEmpty(toUserIds)){ if(CollectionUtil.isEmpty(toUserIds)){
return; return;
@@ -141,6 +147,7 @@ public class UserGreetServiceImpl extends ServiceImpl<UserGreetMapper,UserGreet>
if(!r.isSuccess()){ if(!r.isSuccess()){
throw new ServiceException("发送失败"); throw new ServiceException("发送失败");
} }
}
stringRedisTemplate.opsForValue().set(userGreetSendTime,DateUtil.currentSeconds()+"",1,TimeUnit.DAYS); stringRedisTemplate.opsForValue().set(userGreetSendTime,DateUtil.currentSeconds()+"",1,TimeUnit.DAYS);
stringRedisTemplate.opsForValue().increment(numKey); stringRedisTemplate.opsForValue().increment(numKey);
stringRedisTemplate.expire(numKey,1,TimeUnit.DAYS); stringRedisTemplate.expire(numKey,1,TimeUnit.DAYS);