From 2c22d1837a5c37c37d52871a38b59eff19e60ede Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期二, 08 十一月 2022 11:15:51 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/crm/manager/controller/CstmrController.java |   62 +++++++++++++++++++++++++++++++
 1 files changed, 62 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/crm/manager/controller/CstmrController.java b/src/main/java/com/zy/crm/manager/controller/CstmrController.java
index 5c60c43..8340a86 100644
--- a/src/main/java/com/zy/crm/manager/controller/CstmrController.java
+++ b/src/main/java/com/zy/crm/manager/controller/CstmrController.java
@@ -11,12 +11,17 @@
 import com.core.common.R;
 import com.core.exception.CoolException;
 import com.zy.crm.common.web.BaseController;
+import com.zy.crm.manager.controller.result.CstmrFollowerTableVo;
 import com.zy.crm.manager.entity.Cstmr;
+import com.zy.crm.manager.entity.CstmrFoll;
 import com.zy.crm.manager.entity.CstmrType;
+import com.zy.crm.manager.service.CstmrFollService;
 import com.zy.crm.manager.service.CstmrService;
 import com.zy.crm.manager.service.CstmrTypeService;
 import com.zy.crm.system.entity.Dic;
+import com.zy.crm.system.entity.User;
 import com.zy.crm.system.service.DicService;
+import com.zy.crm.system.service.UserService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.ss.usermodel.DataFormatter;
@@ -25,6 +30,7 @@
 import org.apache.poi.ss.usermodel.Workbook;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -290,4 +296,60 @@
 
     }
 
+    /******************************** 璺熻繘浜� ***************************************/
+
+    @Autowired
+    private CstmrFollService cstmrFollService;
+    @Autowired
+    private UserService userService;
+
+    @RequestMapping(value = "/cstmr/followers/table/auth")
+    @ManagerAuth
+    public R cstmrFollowersTable(@RequestParam("cstmrId") Long cstmrId) {
+        List<CstmrFoll> cstmrFolls = cstmrFollService.selectList(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId).orderBy("id", false));
+        List<CstmrFollowerTableVo> result = new ArrayList<>();
+        for (CstmrFoll cstmrFoll : cstmrFolls) {
+            User user = userService.selectById(cstmrFoll.getUserId());
+            CstmrFollowerTableVo vo = new CstmrFollowerTableVo();
+            vo.setUserId(user.getId());
+            vo.setUserName(user.getNickname());
+            result.add(vo);
+        }
+        return R.ok().add(result);
+    }
+
+    @RequestMapping(value = "/cstmr/followers/add/auth")
+    @ManagerAuth
+    @Transactional
+    public R cstmrFollowersAdd(@RequestParam("cstmrId") Long cstmrId,
+                               @RequestParam("followerIds[]") Long[] followerIds) {
+        if (Cools.isEmpty(cstmrId, followerIds)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        for (Long userId : followerIds) {
+            if (cstmrFollService.selectCount(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId).eq("user_id", userId)) == 0) {
+                CstmrFoll cstmrFoll = new CstmrFoll();
+                cstmrFoll.setCstmrId(cstmrId);
+                cstmrFoll.setUserId(userId);
+                if (!cstmrFollService.insert(cstmrFoll)) {
+                    throw new CoolException("娣诲姞澶辫触锛岃鑱旂郴绠$悊鍛�");
+                }
+            }
+        }
+        return R.ok("娣诲姞鎴愬姛");
+    }
+
+    @RequestMapping(value = "/cstmr/followers/remove/auth")
+    @ManagerAuth
+    public R cstmrFollowersRemove(@RequestParam("cstmrId") Long cstmrId,
+                                  @RequestParam("userId") Long userId) {
+        if (Cools.isEmpty(cstmrId, userId)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (!cstmrFollService.delete(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId).eq("user_id", userId))) {
+            throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+        return R.ok("鍒犻櫎鎴愬姛");
+    }
+
 }

--
Gitblit v1.9.1