init

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiAreaService.java

@@ -0,0 +1,14 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiArea;
+
+/**
+ * 地区Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiAreaService extends IService<CaiArea> {
+
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiDynamicImagesService.java

@@ -0,0 +1,14 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiDynamicImages;
+
+/**
+ * 附件Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiDynamicImagesService extends IService<CaiDynamicImages> {
+
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiDynamicService.java

@@ -0,0 +1,18 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiDynamic;
+import com.ruoyi.cai.dto.app.vo.DynamicVo;
+
+import java.util.List;
+
+/**
+ * 主播动态Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiDynamicService extends IService<CaiDynamic> {
+
+    List<DynamicVo> selectDynamicList(Long userId, Integer limit);
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiGuardTotalService.java

@@ -0,0 +1,18 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiGuardTotal;
+import com.ruoyi.cai.dto.app.vo.GuardTotalVo;
+
+import java.util.List;
+
+/**
+ * 守护用户累计Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiGuardTotalService extends IService<CaiGuardTotal> {
+
+    List<GuardTotalVo> selectGuardTotalLimit(Long fromUserId,Integer limit);
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiUserAlbumService.java

@@ -0,0 +1,18 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiUserAlbum;
+
+import java.util.List;
+
+/**
+ * 主播集锦Service接口
+ *
+ * @author ruoyi
+ * @date 2023-12-23
+ */
+public interface CaiUserAlbumService extends IService<CaiUserAlbum> {
+
+
+    List<String> getUserAlbum(Long userId, Integer anchor);
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiUserFollowDynamicService.java

@@ -0,0 +1,14 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiUserFollowDynamic;
+
+/**
+ * 关注动态表Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiUserFollowDynamicService extends IService<CaiUserFollowDynamic> {
+
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiUserFollowService.java

@@ -0,0 +1,17 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiUserFollow;
+
+/**
+ * 关注表Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiUserFollowService extends IService<CaiUserFollow> {
+
+    Long getFansNumByUserId(Long userId);
+
+    boolean checkStar(Long userId, Long followUserId);
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/CaiUserGiftService.java

@@ -0,0 +1,18 @@
+package com.ruoyi.cai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.cai.domain.CaiUserGift;
+import com.ruoyi.cai.dto.app.vo.UserGiftVo;
+
+import java.util.List;
+
+/**
+ * 礼物记录Service接口
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+public interface CaiUserGiftService extends IService<CaiUserGift>  {
+
+    List<UserGiftVo> selectGiftList(Long userId);
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiAreaServiceImpl.java

@@ -0,0 +1,17 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiArea;
+import com.ruoyi.cai.mapper.CaiAreaMapper;
+import com.ruoyi.cai.service.CaiAreaService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 地区Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@Service
+public class CaiAreaServiceImpl extends ServiceImpl<CaiAreaMapper,CaiArea> implements CaiAreaService {
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiDynamicImagesServiceImpl.java

@@ -0,0 +1,17 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiDynamicImages;
+import com.ruoyi.cai.mapper.CaiDynamicImagesMapper;
+import com.ruoyi.cai.service.CaiDynamicImagesService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 附件Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@Service
+public class CaiDynamicImagesServiceImpl extends ServiceImpl<CaiDynamicImagesMapper, CaiDynamicImages> implements CaiDynamicImagesService {
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiDynamicServiceImpl.java

@@ -0,0 +1,57 @@
+package com.ruoyi.cai.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiDynamic;
+import com.ruoyi.cai.domain.CaiDynamicImages;
+import com.ruoyi.cai.dto.app.vo.DynamicImageVo;
+import com.ruoyi.cai.dto.app.vo.DynamicVo;
+import com.ruoyi.cai.mapper.CaiDynamicMapper;
+import com.ruoyi.cai.service.CaiDynamicImagesService;
+import com.ruoyi.cai.service.CaiDynamicService;
+import com.ruoyi.common.utils.BeanConvertUtil;
+import lombok.RequiredArgsConstructor;
+import net.bytebuddy.utility.JavaConstant;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 主播动态Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@RequiredArgsConstructor
+@Service
+public class CaiDynamicServiceImpl extends ServiceImpl<CaiDynamicMapper,CaiDynamic> implements CaiDynamicService {
+
+    @Autowired
+    private CaiDynamicImagesService dynamicImagesService;
+
+    @Override
+    public List<DynamicVo> selectDynamicList(Long userId, Integer limit) {
+        List<CaiDynamic> list = this.list(Wrappers.lambdaQuery(CaiDynamic.class)
+                .eq(CaiDynamic::getUserId, userId)
+                .eq(CaiDynamic::getStatus, 1)
+                .orderByDesc(CaiDynamic::getCreateTime)
+                .last("limit "+ limit));
+        List<DynamicVo> res = BeanConvertUtil.convertListTo(list, DynamicVo::new);
+        List<Long> dynamicIds = res.stream().filter(i -> i.getIsAttach() == 1).map(DynamicVo::getId).collect(Collectors.toList());
+        if(CollectionUtil.isNotEmpty(dynamicIds)){
+            List<CaiDynamicImages> dynamicImages = dynamicImagesService.list(Wrappers.lambdaQuery(CaiDynamicImages.class)
+                    .in(CaiDynamicImages::getDynamicId, dynamicIds));
+            Map<Long, List<CaiDynamicImages>> map =
+                    dynamicImages.stream().collect(Collectors.groupingBy(CaiDynamicImages::getDynamicId));
+            for (DynamicVo re : res) {
+                List<CaiDynamicImages> images = map.get(re.getId());
+                re.setImageList(BeanConvertUtil.convertListTo(images, DynamicImageVo::new));
+            }
+        }
+        return res;
+    }
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiGuardTotalServiceImpl.java

@@ -0,0 +1,26 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiGuardTotal;
+import com.ruoyi.cai.dto.app.vo.GuardTotalVo;
+import com.ruoyi.cai.mapper.CaiGuardTotalMapper;
+import com.ruoyi.cai.service.CaiGuardTotalService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 守护用户累计Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@Service
+public class CaiGuardTotalServiceImpl extends ServiceImpl<CaiGuardTotalMapper,CaiGuardTotal> implements CaiGuardTotalService {
+
+    @Override
+    public List<GuardTotalVo> selectGuardTotalLimit(Long fromUserId,Integer limit) {
+        return baseMapper.selectGuardTotal(fromUserId, limit);
+    }
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiUserAlbumServiceImpl.java

@@ -0,0 +1,38 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiUserAlbum;
+import com.ruoyi.cai.mapper.CaiUserAlbumMapper;
+import com.ruoyi.cai.service.CaiUserAlbumService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 主播集锦Service业务层处理
+ *
+ * @author ruoyi
+ * @date 2023-12-23
+ */
+@RequiredArgsConstructor
+@Service
+public class CaiUserAlbumServiceImpl extends ServiceImpl<CaiUserAlbumMapper, CaiUserAlbum> implements CaiUserAlbumService {
+
+    @Override
+    public List<String> getUserAlbum(Long userId,Integer anchor){
+        LambdaQueryWrapper<CaiUserAlbum> eq = Wrappers.lambdaQuery(CaiUserAlbum.class)
+                .select(CaiUserAlbum::getUrl)
+                .eq(CaiUserAlbum::getUserId, userId);
+        if(anchor != null && anchor == 1){
+            eq.ne(CaiUserAlbum::getAuditRemark,2);
+        }else{
+            eq.eq(CaiUserAlbum::getAuditRemark,1);
+        }
+        List<CaiUserAlbum> list = this.list(eq);
+        return list.stream().map(CaiUserAlbum::getUrl).collect(Collectors.toList());
+    }
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiUserFollowDynamicServiceImpl.java

@@ -0,0 +1,20 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiUserFollowDynamic;
+import com.ruoyi.cai.mapper.CaiUserFollowDynamicMapper;
+import com.ruoyi.cai.service.CaiUserFollowDynamicService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ * 关注动态表Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@RequiredArgsConstructor
+@Service
+public class CaiUserFollowDynamicServiceImpl extends ServiceImpl<CaiUserFollowDynamicMapper,CaiUserFollowDynamic> implements CaiUserFollowDynamicService {
+
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiUserFollowServiceImpl.java

@@ -0,0 +1,38 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiUserFollow;
+import com.ruoyi.cai.mapper.CaiUserFollowMapper;
+import com.ruoyi.cai.service.CaiUserFollowService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ * 关注表Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@RequiredArgsConstructor
+@Service
+public class CaiUserFollowServiceImpl extends ServiceImpl<CaiUserFollowMapper,CaiUserFollow> implements CaiUserFollowService {
+
+
+    @Override
+    public Long getFansNumByUserId(Long userId){
+        return this.count(Wrappers.lambdaQuery(CaiUserFollow.class)
+                .eq(CaiUserFollow::getFollowUser,userId));
+    }
+
+    @Override
+    public boolean checkStar(Long userId,Long followUserId){
+        long count = this.count(Wrappers.lambdaQuery(CaiUserFollow.class)
+                .eq(CaiUserFollow::getFollowUser, followUserId)
+                .eq(CaiUserFollow::getUserId, userId));
+        if(count > 0){
+            return true;
+        }
+        return false;
+    }
+}

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/CaiUserGiftServiceImpl.java

@@ -0,0 +1,27 @@
+package com.ruoyi.cai.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.cai.domain.CaiUserGift;
+import com.ruoyi.cai.dto.app.vo.UserGiftVo;
+import com.ruoyi.cai.mapper.CaiUserGiftMapper;
+import com.ruoyi.cai.service.CaiUserGiftService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 礼物记录Service业务层处理
+ *
+ * @author 77
+ * @date 2023-12-23
+ */
+@RequiredArgsConstructor
+@Service
+public class CaiUserGiftServiceImpl extends ServiceImpl<CaiUserGiftMapper,CaiUserGift> implements CaiUserGiftService {
+
+    @Override
+    public List<UserGiftVo> selectGiftList(Long userId) {
+        return baseMapper.selectGiftList(userId);
+    }
+}