From 546be8a1bafdfc804575a8d07a5d9f2306c29c42 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期四, 19 六月 2025 11:20:58 +0800
Subject: [PATCH] 修改直播列表

---
 ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopRelUserServiceImpl.java |   24 ++++++++++++++++++++++++
 1 files changed, 24 insertions(+), 0 deletions(-)

diff --git a/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopRelUserServiceImpl.java b/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopRelUserServiceImpl.java
index f81976b..9cf76f5 100644
--- a/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopRelUserServiceImpl.java
+++ b/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopRelUserServiceImpl.java
@@ -1,6 +1,7 @@
 package com.ruoyi.shop.service.impl.shop;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.ruoyi.shop.domain.pojo.shop.ShopRelUser;
 import com.ruoyi.shop.mapper.shop.ShopRelUserMapper;
@@ -31,6 +32,16 @@
      */
     @Override
     public void deleteByShopId(Long shopId){
+        LambdaQueryWrapper<ShopRelUser> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.eq(ShopRelUser::getDelFlag, 0).eq(ShopRelUser::getShopId, shopId);
+        List<ShopRelUser> shopRelUserList = this.list(queryWrapper);
+        if(shopRelUserList!=null&&!shopRelUserList.isEmpty()){
+            Long userId;
+            for(ShopRelUser shopRelUser : shopRelUserList){
+                userId = shopRelUser.getUserId();
+
+            }
+        }
         shopRelUserMapper.deleteByShopId(shopId);
     }
 
@@ -58,4 +69,17 @@
         queryWrapper.eq(ShopRelUser::getDelFlag, 0).eq(ShopRelUser::getUserId, userId);
         return this.getOne(queryWrapper,false);
     }
+
+    /**
+     * 通过用户id删除关联
+     * @param userId
+     */
+    @Override
+    public void deleteByUserId(Long userId){
+        LambdaUpdateWrapper<ShopRelUser> updateWrapper = new LambdaUpdateWrapper();
+        updateWrapper.set(ShopRelUser::getDelFlag,1);
+        updateWrapper.eq(ShopRelUser::getUserId,userId);
+        updateWrapper.eq(ShopRelUser::getDelFlag,0);
+        this.update(updateWrapper);
+    }
 }

--
Gitblit v1.7.1