From 4d70d2fce0e3dd5f0842cb8161181107dca1d55a Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期二, 28 十一月 2023 13:55:18 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/crm/manager/controller/PlanController.java |  363 ++++++++++++++++++---------------------------------
 1 files changed, 132 insertions(+), 231 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 aaa3922..5fe3109 100644
--- a/src/main/java/com/zy/crm/manager/controller/PlanController.java
+++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java
@@ -12,7 +12,6 @@
 import com.zy.crm.common.entity.PhoneCodeTypeParam;
 import com.zy.crm.common.model.SettleDto;
 import com.zy.crm.common.service.OssService;
-import com.zy.crm.common.utils.FileSaveExampleUtil;
 import com.zy.crm.common.web.BaseController;
 import com.zy.crm.manager.controller.result.FollowerTableVo;
 import com.zy.crm.manager.entity.*;
@@ -76,7 +75,7 @@
         }
         resultObj.put("formHtml", planType.getHtml());
         // 姝ラ鏉$浉鍏�
-        resultObj.put("step", plan.getSettle() == 4 ? 0 : plan.getSettle() + 1);
+        resultObj.put("step", plan.getSettle().equals(plan.getSettleSize()) ? 0 : plan.getSettle() + 1);
 
         return R.ok().add(resultObj);
     }
@@ -177,12 +176,12 @@
 
         plan.setForm(JSON.toJSONString(param));     // 鑷畾涔夎〃鍗曞唴瀹�
         plan.setSettle(1);  // 1.寮�濮�
-        User manager = new User();
-        try{
-            manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
-        }catch (Exception e){
-            manager = getUser();
-        }
+//        User manager = new User();
+//        try{
+//            manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
+//        }catch (Exception e){
+//            manager = getUser();
+//        }
         PlanType planType = planTypeService.selectById(plan.getPlanType());
         if (planType.getType().equals(2)) {
             plan.setStatus2(0);
@@ -190,9 +189,30 @@
             plan.setStatus2(10);
         }
         User planLeader = planTypeService.findPlanLeader(planType);
-        plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager, planLeader)));
 
-        plan.setDirector(planLeader.getId());
+        // 鑾峰彇涓氬姟鍛�
+        List<String> initNames = new ArrayList<>();
+        initNames.add("鍒涘缓浜嗗鎵�");
+        if (!planType.getFlag().equals("澧炶ˉ")){
+            initNames.add("鍞墠瀹℃牳");
+            initNames.add("瑙勫垝鍛樺鏍�");
+        }
+        initNames.add("涓氬姟鍛樼‘璁�");
+        List<User> users = new ArrayList<>();
+        users.add(getUser());
+        if (!planType.getFlag().equals("澧炶ˉ")){
+            users.add(planLeader);
+            users.add(new User());
+        }
+        users.add(getUser());
+//        plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager, planLeader)));
+        plan.setSettleMsg(JSON.toJSONString(SettleDto.InItFlowPathTwo(users, initNames, users.size())));
+        plan.setSettleSize(users.size());
+        if (users.size()>1){
+            plan.setDirector(users.get(1).getId());
+        }else {
+            plan.setDirector(getUserId());
+        }
 
         if (!planService.insert(plan)) {
             throw new CoolException("淇濇寔澶辫触锛岃閲嶈瘯");
@@ -218,6 +238,9 @@
     @Transactional
     public R assistantPlanAdd(@RequestParam Long hostPlanId) {
         Plan hostPlan = planService.selectById(hostPlanId);
+        if (!getUserId().equals(hostPlan.getUserId())){
+            return R.error("璇疯仈绯讳笟鍔″憳鎿嶄綔");
+        }
         if (hostPlan.getAssistantHostSign()!=0){
             return R.error("姝よ鍒掑崟涓嶉渶瑕佸垱寤哄壇娴佺▼");
         }
@@ -270,7 +293,25 @@
         }
         PlanType planType = new PlanType(hostPlan.getHostId(),1);//1:璐ф灦
         User planLeader = planTypeService.findPlanLeader(planType);
-        plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager, planLeader)));
+        // 鑾峰彇涓氬姟鍛�
+        List<String> initNames = new ArrayList<>();
+        initNames.add("鍒涘缓浜嗗鎵�");
+        initNames.add("鍞墠瀹℃牳");
+        initNames.add("瑙勫垝鍛樺鏍�");
+        initNames.add("涓氬姟鍛樼‘璁�");
+        List<User> users = new ArrayList<>();
+        users.add(getUser());
+        users.add(planLeader);
+        users.add(new User());
+        users.add(getUser());
+//        plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager, planLeader)));
+        plan.setSettleMsg(JSON.toJSONString(SettleDto.InItFlowPathTwo(users, initNames, users.size())));
+        plan.setSettleSize(users.size());
+        if (users.size()>1){
+            plan.setDirector(users.get(1).getId());
+        }else {
+            plan.setDirector(getUserId());
+        }
 
         plan.setDirector(planLeader.getId());
 
@@ -432,228 +473,88 @@
                       @RequestParam(required = false) Long plannerId){
         Plan plan = planService.selectById(planId);
         assert plan != null;
+        User plannerUser = new User();
+        Long nextUserId = getUserId();
+        User director = userService.selectById(plan.getDirector());
 
-        switch (plan.getSettle()) {
-//            case 1:
-//                // 鏈粍缁勯暱瀹℃牳
-//                User user = userService.selectById(plan.getUserId());
-//                User manager = new User();
-//                try{
-//                    manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
-//                }catch (Exception e){
-//                    manager = user;
-//                }
-//                if (manager.getId().equals(getUserId())) {
-//
-//                    // 鏌ユ壘瑙勫垝缁勯暱
-//                    PlanType planType = planTypeService.selectById(plan.getPlanType());
-//                    User planLeader = planTypeService.findPlanLeader(planType);
-//                    if (Cools.isEmpty(planLeader)) {
-//                        throw new CoolException("鏈煡鎵惧埌瑙勫垝缁勯暱锛岃鑱旂郴绠$悊鍛�");
-//                    }
-//
-//                    // 淇敼 settle 姝ラ鏁版嵁
-//                    List<SettleDto> list = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
-//                    for (SettleDto dto : list) {
-//                        switch (dto.getStep()) {
-//                            case 1:
-//                                dto.setCurr(Boolean.FALSE);
-//                                break;
-//                            case 2:
-//                                dto.setCurr(Boolean.TRUE);
-//                                dto.setMsg("鏈粍缁勯暱" + manager.getNickname() + "瀹℃壒閫氳繃");
-//                                dto.setTime(DateUtils.convert(new Date()));
-//                                break;
-//                            case 3:
-//                                dto.setUserId(planLeader.getId());
-//                                dto.setUsername(planLeader.getNickname());
-//                                break;
-//                            default:
-//                                break;
-//                        }
-//                    }
-//                    plan.setSettleMsg(JSON.toJSONString(list));
-//
-//                    // 淇敼瑙勫垝鍗曠姸鎬�
-//                    plan.setSettle(2);  // 瑙勫垝缁勯暱寰呭
-//                    plan.setUpdateBy(getUserId());
-//                    plan.setUpdateTime(new Date());
-//
-//                    if (!planService.updateById(plan)) {
-//                        throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-//                    }
-//
-//                    // 娣诲姞瑙勫垝缁勯暱璺熻繘浜�
-//                    PlanFoll planFoll = new PlanFoll();
-//                    planFoll.setPlanId(plan.getId());
-//                    planFoll.setUserId(planLeader.getId());
-//                    if (!planFollService.insert(planFoll)) {
-//                        throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-//                    }
-//
-//                } else {
-//                    return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�");
-//                }
-//                break;
-            case 1:
-                // 鏌ユ壘瑙勫垝缁勯暱
-                User planLeader = userService.selectById(plan.getDirector());
-                if (Cools.isEmpty(planLeader)) {
-                    throw new CoolException("鏈煡鎵惧埌瑙勫垝缁勯暱锛岃鑱旂郴绠$悊鍛�");
-                }
-                if (Cools.isEmpty(planLeader)) {
-                    throw new CoolException("鏈煡鎵惧埌瑙勫垝缁勯暱锛岃鑱旂郴绠$悊鍛�");
-                }
-                if (!getUserId().equals(planLeader.getId())) {
-                    return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�");
-                }
-                if (Cools.isEmpty(plannerId)) {
-                    return R.error("鎸囧畾瑙勫垝鍛樹笉鑳戒负绌�");
-                }
-                plan.setDirector(plannerId);
-                User planner = userService.selectById(plannerId);
-                // 淇敼 settle 姝ラ鏁版嵁
-                List<SettleDto> list = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
-                for (SettleDto dto : list) {
-                    switch (dto.getStep()) {
-                        case 1:
-                            dto.setCurr(Boolean.FALSE);
-                            break;
-                        case 2:
-                            dto.setCurr(Boolean.TRUE);
-                            if (Cools.isEmpty(dto.getMsg())){
-                                dto.setMsg("鍞墠缁勯暱" + planLeader.getNickname() + "瀹℃壒閫氳繃");
-                            }else {
-                                dto.setMsg(dto.getMsg()+PZH+DateUtils.convert(new Date())+" "+"鍞墠缁勯暱" + planLeader.getNickname() + "瀹℃壒閫氳繃");
-                            }
-                            dto.setTime(DateUtils.convert(new Date()));
-                            break;
-                        case 3:
-                            dto.setUserId(planner.getId());
-                            dto.setUsername(planner.getNickname());
-                            break;
-                        default:
-                            break;
-                    }
-                }
-                plan.setSettleMsg(JSON.toJSONString(list));
-                // 淇敼瑙勫垝鍗曠姸鎬�
-                plan.setSettle(2);  // 瑙勫垝鍛樺緟瀹�
-                plan.setPlanner(planner.getId());
-                plan.setUpdateBy(getUserId());
-                plan.setUpdateTime(new Date());
-
-                if (!planService.updateById(plan)) {
-                    throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-                }
-
-                // 娣诲姞瑙勫垝鍛樿窡杩涗汉
-                PlanFoll planFoll = new PlanFoll();
-                planFoll.setPlanId(plan.getId());
-                planFoll.setUserId(planner.getId());
-                if (!planFollService.insert(planFoll)) {
-                    throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-                }
-
-                if (!smsCodeService.sendSmsCodeText(planner.getMobile(), PhoneCodeTypeParam.ALIYUN_M6F3C81FE3)) {
-                    return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
-                }
-                break;
-            case 2:
-                User plannerUser = userService.selectById(plan.getPlanner());
-                if (Cools.isEmpty(plannerUser)) {
-                    return R.error("鏈壘鍒拌鍒掑憳");
-                }
-                if (!getUserId().equals(plannerUser.getId())) {
-                    return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�");
-                }
-                // 涓氬姟鍛�
-                User salesman = userService.selectById(plan.getUserId());
-                plan.setDirector(salesman.getId());
-
-                // 淇敼 settle 姝ラ鏁版嵁
-                List<SettleDto> list0 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
-                for (SettleDto dto : list0) {
-                    switch (dto.getStep()) {
-                        case 2:
-                            dto.setCurr(Boolean.FALSE);
-                            break;
-                        case 3:
-                            dto.setCurr(Boolean.TRUE);
-                            if (Cools.isEmpty(dto.getMsg())){
-                                dto.setMsg("瑙勫垝鍛�" + plannerUser.getNickname() + "瀹℃壒閫氳繃");
-                            }else {
-                                dto.setMsg(dto.getMsg()+PZH+DateUtils.convert(new Date())+" "+"瑙勫垝鍛�" + plannerUser.getNickname() + "瀹℃壒閫氳繃");
-                            }
-                            dto.setTime(DateUtils.convert(new Date()));
-                            break;
-                        case 4:
-                            dto.setUserId(salesman.getId());
-                            dto.setUsername(salesman.getNickname());
-                            break;
-                        default:
-                            break;
-                    }
-                }
-                plan.setSettleMsg(JSON.toJSONString(list0));
-                // 淇敼瑙勫垝鍗曠姸鎬�
-                plan.setSettle(3);  // 瀹℃壒閫氳繃
-                plan.setUpdateBy(getUserId());
-                plan.setUpdateTime(new Date());
-
-                if (!planService.updateById(plan)) {
-                    throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-                }
-                if (!smsCodeService.sendSmsCodeText(salesman.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E)) {
-                    return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
-                }
-                break;
-            case 3:
-                // 涓氬姟鍛�
-                User salesman0 = userService.selectById(plan.getUserId());
-                if (!getUserId().equals(salesman0.getId())) {
-                    return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�");
-                }
-                // 淇敼 settle 姝ラ鏁版嵁
-                List<SettleDto> list1 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
-                for (SettleDto dto : list1) {
-                    switch (dto.getStep()) {
-                        case 3:
-                            dto.setCurr(Boolean.TRUE);
-                            break;
-                        case 4:
-                            dto.setCurr(Boolean.TRUE);
-                            if (Cools.isEmpty(dto.getMsg())){
-                                dto.setMsg("涓氬姟鍛�" + salesman0.getNickname() + "瀹℃壒閫氳繃");
-                            }else {
-                                dto.setMsg(dto.getMsg()+PZH+DateUtils.convert(new Date())+" "+"涓氬姟鍛�" + salesman0.getNickname() + "瀹℃壒閫氳繃");
-                            }
-                            dto.setTime(DateUtils.convert(new Date()));
-                            break;
-                        default:
-                            break;
-                    }
-                }
-                plan.setSettleMsg(JSON.toJSONString(list1));
-                // 淇敼瑙勫垝鍗曠姸鎬�
-                plan.setSettle(4);  // 瀹℃壒閫氳繃
-                plan.setStatus(1);  // 瀹℃壒閫氳繃
-                plan.setUpdateBy(getUserId());
-                plan.setUpdateTime(new Date());
-
-                if (plan.getAssistantHostSign()==1){
-                    Plan planHost = planService.selectById(plan.getHostPlanId());
-                    planHost.setStatus2(1);
-                    planService.updateById(planHost);
-                }
-
-                if (!planService.updateById(plan)) {
-                    throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
-                }
-                break;
-            default:
-                return R.error();
+        if (Cools.isEmpty(getUser()) || Cools.isEmpty(director)){
+            return R.error("鎶辨瓑锛屾偍鏃犻渶纭锛侊紒锛�");
         }
+
+        if (!getUserId().equals(director.getId())) {
+            return R.error("鎶辨瓑锛屾偍鏃犻渶纭锛侊紒锛�");
+        }
+
+        // 淇敼 settle 姝ラ鏁版嵁
+        List<SettleDto> list = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
+        // 淇敼 settle 姝ラ鏁版嵁
+        for (SettleDto dto : list) {
+            if (dto.getStep().equals(plan.getSettle())) {
+                dto.setCurr(Boolean.TRUE);
+            } else if (dto.getStep().equals(plan.getSettle()+1)) {
+                dto.setCurr(Boolean.TRUE);
+                if (Cools.isEmpty(dto.getMsg())) {
+                    dto.setMsg(director.getNickname() + "瀹℃壒閫氳繃");
+                } else {
+                    dto.setMsg(dto.getMsg() + PZH + DateUtils.convert(new Date()) + " " + director.getNickname() + "瀹℃壒閫氳繃");
+                }
+                dto.setTime(DateUtils.convert(new Date()));
+            } else if (dto.getStep().equals(plan.getSettle() + 2)) {
+                if (Cools.isEmpty(dto.getUserId())){
+                    if (Cools.isEmpty(plannerId)) {
+                        return R.error("鎸囧畾瑙勫垝鍛樹笉鑳戒负绌�");
+                    }
+                    plannerUser = userService.selectById(plannerId);
+                    if (Cools.isEmpty(plannerUser)){
+                        return R.error("鏈煡鍒版寚瀹氳鍒掑憳璐﹀彿");
+                    }
+                    nextUserId= plannerId;
+                    plan.setPlanner(plannerId);
+                    dto.setUserId(plannerId);
+                    dto.setUsername(plannerUser.getNickname());
+                    // 娣诲姞瑙勫垝鍛樿窡杩涗汉
+                    PlanFoll planFoll = new PlanFoll();
+                    planFoll.setPlanId(plan.getId());
+                    planFoll.setUserId(nextUserId);
+                    if (!planFollService.insert(planFoll)) {
+                        throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
+                    }
+                }else {
+                    nextUserId=dto.getUserId();
+                }
+            }
+        }
+        plan.setSettleMsg(JSON.toJSONString(list));
+        // 淇敼瑙勫垝鍗曠姸鎬�
+        plan.setSettle(plan.getSettle()+1);  // 瀹℃壒閫氳繃
+        if (plan.getSettle().equals(plan.getSettleSize())){
+            plan.setStatus(1);
+            if (plan.getAssistantHostSign()==1){
+                Plan planHost = planService.selectById(plan.getHostPlanId());
+                planHost.setStatus2(1);
+                planService.updateById(planHost);
+            }
+        }
+        plan.setUpdateBy(getUserId());
+        plan.setUpdateTime(new Date());
+        plan.setDirector(nextUserId);
+
+        if (!planService.updateById(plan)) {
+            throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+        if (!plan.getSettle().equals(plan.getSettleSize())){
+            if (!Cools.isEmpty(plannerId) && nextUserId.equals(plannerId)){
+                if (!smsCodeService.sendSmsCodeText(plannerUser.getMobile(), PhoneCodeTypeParam.ALIYUN_M6F3C81FE3)) {
+                    return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
+                }
+            }else {
+                User phoneUser = userService.selectById(nextUserId);
+                if (!smsCodeService.sendSmsCodeText(phoneUser.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E)) {
+                    return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
+                }
+            }
+        }
+
         return R.ok("瀹℃壒鎴愬姛");
     }
 

--
Gitblit v1.9.1