From 128eadbe3e8d8b31c2c75f62aa038d304e1f893e Mon Sep 17 00:00:00 2001
From: zhn <947514737@qq.com>
Date: Thu, 24 Feb 2022 09:29:34 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=87=E6=A1=A3=E5=BA=93--=E8=AE=A2=E9=98=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BussDocumentLibraryEOController.java      | 36 +++++++++++++++++++
 .../IBussDocumentLibraryEOService.java        | 12 +++++++
 .../BussDocumentLibraryEOServiceImpl.java     | 27 ++++++++++++++
 3 files changed, 75 insertions(+)

diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
index 871b4f2f8..778517302 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
@@ -314,6 +314,42 @@ public class BussDocumentLibraryEOController extends JeroController<BussDocument
 		 return Result.OK("取消收藏成功");
 	 }
 
+	 /**
+	  * 添加订阅
+	  * @param id
+	  * @return
+	  */
+	 @AutoLog(value = "添加订阅")
+	 @ApiOperation(value="添加订阅", notes="添加订阅")
+	 @GetMapping(value = "/addSubscribe")
+	 public Result<?> addSubscribe(String id) {
+		 try {
+			 bussDocumentLibraryEOService.addSubscribe(id);
+		 } catch (Exception e) {
+			 return Result.error("订阅失败");
+		 }
+		 return Result.OK("订阅成功");
+	 }
+
+	 /**
+	  * 取消订阅
+	  * @param id
+	  * @return
+	  */
+	 @AutoLog(value = "取消订阅")
+	 @ApiOperation(value="取消订阅", notes="取消订阅")
+	 @GetMapping(value = "/cancelSubscribe")
+	 public Result<?> cancelSubscribe(String id) {
+		 try {
+			 bussDocumentLibraryEOService.cancelSubscribe(id);
+		 } catch (Exception e) {
+			 return Result.error("取消订阅失败");
+		 }
+		 return Result.OK("取消订阅成功");
+	 }
+
+
+
 
 
 }
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
index b074d3542..2cdad8e2e 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
@@ -119,5 +119,17 @@ public interface IBussDocumentLibraryEOService extends IService<BussDocumentLibr
 	 */
 	void cancelCollect(String id);
 
+	/**
+	 * 添加订阅
+	 * @param id
+	 */
+	void addSubscribe(String id);
+
+	/**
+	 * 取消订阅
+	 * @param id
+	 */
+	void cancelSubscribe(String id);
+
 
 }
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
index 4d83636c7..593990436 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
@@ -18,6 +18,8 @@ import com.jero.modules.document.mapper.BussDocumentLibraryEOMapper;
 import com.jero.modules.document.service.IBussDocumentLibraryEOService;
 import com.jero.modules.oss.entity.OSSFile;
 import com.jero.modules.oss.service.IOSSFileService;
+import com.jero.modules.subscribe.entity.OnlCgformSubscribe;
+import com.jero.modules.subscribe.service.IOnlCgformSubscribeService;
 import com.jero.modules.system.entity.SysDictItem;
 import com.jero.modules.system.service.impl.SysDictItemServiceImpl;
 import com.jero.modules.tag.entity.OnlCgformArea;
@@ -59,6 +61,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
     private SysDictItemServiceImpl sysDictItemServiceImpl;
     @Autowired
     private IOnlCgformCollectionService iOnlCgformCollectionService;
+    @Autowired
+    private IOnlCgformSubscribeService iOnlCgformSubscribeService;
 
 
     /**
@@ -745,6 +749,9 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         onlCgformCollection.setDocumentId(id);
         iOnlCgformCollectionService.add(onlCgformCollection);
         //订阅表中添加数据
+        OnlCgformSubscribe onlCgformSubscribe = new OnlCgformSubscribe();
+        onlCgformSubscribe.setDocumentId(id);
+        iOnlCgformSubscribeService.add(onlCgformSubscribe);
     }
 
     @Override
@@ -754,5 +761,25 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         lambdaQueryWrapper.in(OnlCgformCollection::getDocumentId,id);
         iOnlCgformCollectionService.remove(lambdaQueryWrapper);
         //订阅表中删除数据
+        LambdaQueryWrapper<OnlCgformSubscribe> wrapper = new LambdaQueryWrapper<>();
+        wrapper.in(OnlCgformSubscribe::getDocumentId,id);
+        iOnlCgformSubscribeService.remove(wrapper);
+
+    }
+
+    @Override
+    public void addSubscribe(String id) {
+        //订阅表中添加数据
+        OnlCgformSubscribe onlCgformSubscribe = new OnlCgformSubscribe();
+        onlCgformSubscribe.setDocumentId(id);
+        iOnlCgformSubscribeService.add(onlCgformSubscribe);
+    }
+
+    @Override
+    public void cancelSubscribe(String id) {
+        //订阅表中删除数据
+        LambdaQueryWrapper<OnlCgformSubscribe> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.in(OnlCgformSubscribe::getDocumentId,id);
+        iOnlCgformSubscribeService.remove(lambdaQueryWrapper);
     }
 }