From 68d2e92f824d72b98aaf68cd5a936945c1912bed Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期一, 21 十一月 2022 15:14:45 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/crm/manager/controller/PlanController.java |  139 ++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 134 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/crm/manager/controller/PlanController.java b/src/main/java/com/zy/crm/manager/controller/PlanController.java
index 2936d2e..8a47c4f 100644
--- a/src/main/java/com/zy/crm/manager/controller/PlanController.java
+++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java
@@ -9,16 +9,29 @@
 import com.core.common.Cools;
 import com.core.common.R;
 import com.core.domain.KeyValueVo;
+import com.core.exception.CoolException;
 import com.zy.crm.common.web.BaseController;
+import com.zy.crm.manager.controller.result.FollowerTableVo;
 import com.zy.crm.manager.entity.Plan;
+import com.zy.crm.manager.entity.PlanFoll;
+import com.zy.crm.manager.service.PlanFollService;
 import com.zy.crm.manager.service.PlanService;
+import com.zy.crm.system.entity.User;
+import com.zy.crm.system.service.UserService;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.DataFormatter;
+import org.apache.poi.ss.usermodel.Sheet;
+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;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.*;
 
 @RestController
 public class PlanController extends BaseController {
@@ -26,7 +39,7 @@
     @Autowired
     private PlanService planService;
 
-    @RequestMapping(value = "/plan/{id}/auth")
+    @GetMapping(value = "/plan/{id}/auth")
     @ManagerAuth
     public R get(@PathVariable("id") String id) {
         return R.ok(planService.selectById(String.valueOf(id)));
@@ -50,6 +63,21 @@
     @RequestMapping(value = "/plan/add/auth")
     @ManagerAuth
     public R add(Plan plan) {
+        Long hostId = getHostId();
+        if (planService.selectByUuid(hostId, plan.getUuid()) != null) {
+            throw new CoolException("瑙勫垝鍗曞凡瀛樺湪");
+        }
+        plan.setHostId(hostId);
+        plan.setUuid(planService.getUuid(hostId));  // 瑙勫垝鍗曚唬鍙�
+        plan.setDeptId(getDeptId());               // 鎵�灞為儴闂�
+        plan.setUserId(getUserId());               // 鎵�灞炰汉鍛�
+
+        plan.setCreateBy(getUserId());
+        plan.setCreateTime(new Date());
+        plan.setUpdateBy(getUserId());
+        plan.setUpdateTime(new Date());
+        plan.setStatus(1);
+
         planService.insert(plan);
         return R.ok();
     }
@@ -60,6 +88,8 @@
         if (Cools.isEmpty(plan) || null==plan.getId()){
             return R.error();
         }
+        plan.setUpdateBy(getUserId());
+        plan.setUpdateTime(new Date());
         planService.updateById(plan);
         return R.ok();
     }
@@ -108,4 +138,103 @@
         return R.ok().add(vos);
     }
 
+    /*************************************** 鏁版嵁鐩稿叧 ***********************************************/
+
+    /**
+     * excel瀵煎叆
+     */
+    @PostMapping(value = "/plan/excel/import/auth")
+    @ManagerAuth(memo = "鐢叉柟鍗曚綅Excel瀵煎叆")
+//    @Transactional
+    public R planExcelImport(MultipartFile file) throws IOException {
+        InputStream inStream = file.getInputStream();
+        String fileMime = file.getContentType();
+        int excelVersion = 2007;
+        if ("application/vnd.ms-excel".equals(fileMime)) {
+            excelVersion = 2003;
+        }
+        Workbook book = null;
+        if (excelVersion == 2003) {
+            book = new HSSFWorkbook(inStream);
+        }
+        else {  // 褰� excel 鏄� 2007 鏃�
+            book = new XSSFWorkbook(inStream);
+        }
+        Sheet sheet = book.getSheetAt(0);
+        int totalRows = sheet.getLastRowNum() + 1;    // 鎬�
+        Long userId = getUserId();
+        Long hostId = getHostId();
+        Long deptId = getDeptId();
+        Date now = new Date();
+        DataFormatter dataFormatter = new DataFormatter();
+        for (int i = 2; i < totalRows; i++) {
+        }
+        return R.ok();
+    }
+
+    /**
+     * excel瀵煎嚭
+     */
+    @PostMapping(value = "/plan/excel/export/auth")
+    @ManagerAuth
+    public void planExcelExport(HttpServletResponse response) throws IOException {
+
+    }
+
+    /******************************** 璺熻繘浜� ***************************************/
+
+    @Autowired
+    private PlanFollService planFollService;
+    @Autowired
+    private UserService userService;
+
+    @RequestMapping(value = "/plan/followers/table/auth")
+    @ManagerAuth
+    public R planFollowersTable(@RequestParam("orderId") Long orderId) {
+        List<PlanFoll> planFolls = planFollService.selectList(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).orderBy("id", false));
+        List<FollowerTableVo> result = new ArrayList<>();
+        for (PlanFoll planFoll : planFolls) {
+            User user = userService.selectById(planFoll.getUserId());
+            FollowerTableVo vo = new FollowerTableVo();
+            vo.setUserId(user.getId());
+            vo.setUserName(user.getNickname());
+            result.add(vo);
+        }
+        return R.ok().add(result);
+    }
+
+    @RequestMapping(value = "/plan/followers/add/auth")
+    @ManagerAuth
+    @Transactional
+    public R planFollowersAdd(@RequestParam("orderId") Long orderId,
+                               @RequestParam("followerIds[]") Long[] followerIds) {
+        if (Cools.isEmpty(orderId, followerIds)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        for (Long userId : followerIds) {
+            if (planFollService.selectCount(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).eq("user_id", userId)) == 0) {
+                PlanFoll planFoll = new PlanFoll();
+                planFoll.setPlanId(orderId);
+                planFoll.setUserId(userId);
+                if (!planFollService.insert(planFoll)) {
+                    throw new CoolException("娣诲姞澶辫触锛岃鑱旂郴绠$悊鍛�");
+                }
+            }
+        }
+        return R.ok("娣诲姞鎴愬姛");
+    }
+
+    @RequestMapping(value = "/plan/followers/remove/auth")
+    @ManagerAuth
+    public R planFollowersRemove(@RequestParam("orderId") Long orderId,
+                                  @RequestParam("userId") Long userId) {
+        if (Cools.isEmpty(orderId, userId)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (!planFollService.delete(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).eq("user_id", userId))) {
+            throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+        return R.ok("鍒犻櫎鎴愬姛");
+    }
+
 }

--
Gitblit v1.9.1