From 6a494b5109518bfaabd56f8e92445fb8ebc1166f Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期二, 10 十月 2023 15:07:45 +0800
Subject: [PATCH] #甲方单位优化

---
 src/main/java/com/zy/crm/manager/controller/PlanController.java |  150 ++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 133 insertions(+), 17 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 0ba45fb..ac48cfe 100644
--- a/src/main/java/com/zy/crm/manager/controller/PlanController.java
+++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java
@@ -12,11 +12,9 @@
 import com.core.common.R;
 import com.core.domain.KeyValueVo;
 import com.core.exception.CoolException;
-import com.zy.crm.common.entity.RouteCollectCountType;
 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.utils.SetOfUtils;
 import com.zy.crm.common.web.BaseController;
 import com.zy.crm.manager.controller.result.FollowerTableVo;
 import com.zy.crm.manager.entity.*;
@@ -33,20 +31,12 @@
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
-import org.springframework.core.io.Resource;
-import org.springframework.core.io.FileSystemResource;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
 
 import javax.servlet.http.HttpServletResponse;
-import java.io.File;
+import javax.xml.crypto.Data;
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.*;
-
-import static java.util.stream.Collectors.toList;
 
 @RestController
 public class PlanController extends BaseController {
@@ -61,6 +51,13 @@
     private OssService ossService;
     @Autowired
     private PriOnline2Service priOnline2Service;
+    @Autowired
+    private OrderService orderService;
+    @Autowired
+    private SmsCodeService smsCodeService;
+
+    String PZH=" 鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�� ";
+
 
     @GetMapping(value = "/plan/{id}/auth")
     @ManagerAuth
@@ -124,6 +121,16 @@
         if (planService.selectByUuid(hostId, plan.getUuid()) != null) {
             throw new CoolException("瑙勫垝鍗曞凡瀛樺湪");
         }
+
+        Order order = orderService.selectById(plan.getOrderId());
+        if (Cools.isEmpty(order)) {
+            throw new CoolException("璺熻釜椤圭洰涓嶅瓨鍦�");
+        }
+
+        if (!order.getDirector().equals(getUserId())){
+            throw new CoolException("鍙厑璁歌窡韪」鐩礋璐d汉娣诲姞鎵�閫夐」鐩鍒掔敵璇峰崟");
+        }
+
         Date now = new Date();
         plan.setHostId(hostId);
         plan.setUuid(planService.getUuid(hostId));  // 瑙勫垝鍗曚唬鍙�
@@ -135,14 +142,22 @@
         plan.setCreateTime(now);
         plan.setUpdateBy(getUserId());
         plan.setUpdateTime(now);
-        plan.setStatus(1);
+        plan.setStatus(0);
+        plan.setStep(1);
 
         plan.setForm(JSON.toJSONString(param));     // 鑷畾涔夎〃鍗曞唴瀹�
         plan.setSettle(1);  // 1.寮�濮�
-        User manager = userService.getDeptManager(hostId, getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
+        User manager = new User();
+        try{
+            manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
+        }catch (Exception e){
+            manager = getUser();
+        }
         PlanType planType = planTypeService.selectById(plan.getPlanType());
         User planLeader = planTypeService.findPlanLeader(planType);
         plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager, planLeader)));
+
+        plan.setDirector(planLeader.getId());
 
         if (!planService.insert(plan)) {
             throw new CoolException("淇濇寔澶辫触锛岃閲嶈瘯");
@@ -334,7 +349,12 @@
 //            case 1:
 //                // 鏈粍缁勯暱瀹℃牳
 //                User user = userService.selectById(plan.getUserId());
-//                User manager = userService.getDeptManager(getHostId(), user.getDeptId());
+//                User manager = new User();
+//                try{
+//                    manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
+//                }catch (Exception e){
+//                    manager = user;
+//                }
 //                if (manager.getId().equals(getUserId())) {
 //
 //                    // 鏌ユ壘瑙勫垝缁勯暱
@@ -403,6 +423,7 @@
                 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);
@@ -413,7 +434,11 @@
                             break;
                         case 2:
                             dto.setCurr(Boolean.TRUE);
-                            dto.setMsg("鍞墠缁勯暱" + planLeader.getNickname() + "瀹℃壒閫氳繃");
+                            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:
@@ -430,6 +455,11 @@
                 plan.setPlanner(planner.getId());
                 plan.setUpdateBy(getUserId());
                 plan.setUpdateTime(new Date());
+
+                boolean sendSmsCode = smsCodeService.sendSmsCodeText(planner.getMobile());
+                if (!sendSmsCode) {
+                    System.out.println("鐭俊鍙戦�佸け璐ワ紒");
+                }
 
                 if (!planService.updateById(plan)) {
                     throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
@@ -453,6 +483,8 @@
                 }
                 // 涓氬姟鍛�
                 User salesman = userService.selectById(plan.getUserId());
+                plan.setDirector(salesman.getId());
+
                 // 淇敼 settle 姝ラ鏁版嵁
                 List<SettleDto> list0 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
                 for (SettleDto dto : list0) {
@@ -462,7 +494,11 @@
                             break;
                         case 3:
                             dto.setCurr(Boolean.TRUE);
-                            dto.setMsg("瑙勫垝鍛�" + plannerUser.getNickname() + "瀹℃壒閫氳繃");
+                            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:
@@ -498,7 +534,11 @@
                             break;
                         case 4:
                             dto.setCurr(Boolean.TRUE);
-                            dto.setMsg("涓氬姟鍛�" + salesman0.getNickname() + "瀹℃壒閫氳繃");
+                            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:
@@ -508,6 +548,7 @@
                 plan.setSettleMsg(JSON.toJSONString(list1));
                 // 淇敼瑙勫垝鍗曠姸鎬�
                 plan.setSettle(4);  // 瀹℃壒閫氳繃
+                plan.setStatus(1);  // 瀹℃壒閫氳繃
                 plan.setUpdateBy(getUserId());
                 plan.setUpdateTime(new Date());
 
@@ -519,6 +560,48 @@
                 return R.error();
         }
         return R.ok("瀹℃壒鎴愬姛");
+    }
+
+    @PostMapping(value = "/plan/approvalEnd/auth")
+    @ManagerAuth(memo = "鎷掔粷鐢宠鍗�")
+    public R approvalEnd(@RequestParam Long planId,
+                         @RequestParam(required = false) Long plannerId) {
+        Plan plan = planService.selectById(planId);
+        Date now = new Date();
+        Long directorId = plan.getDirector();
+        User director = userService.selectById(directorId);
+        if (!director.getId().equals(getUserId())){
+            return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�");
+        }
+        List<SettleDto> planDtos = JSON.parseArray(plan.getSettleMsg(), SettleDto.class);
+        List<SettleDto> planDtoList = new ArrayList<>();
+        boolean sign = true;
+        for (SettleDto dto : planDtos) {
+            if (dto.getStep().equals(2)){
+                plan.setDirector(dto.getUserId());
+            }
+            if (sign && dto.getUserId().equals(directorId) && plan.getSettle()+1==dto.getStep()){
+                if (Cools.isEmpty(dto.getMsg())){
+                    dto.setMsg(DateUtils.convert(now)+" "+director.getNickname()+"鍥為��瀹℃壒");
+                }else {
+                    dto.setMsg(dto.getMsg()+PZH+DateUtils.convert(now)+" "+director.getNickname()+"鍥為��瀹℃壒");
+                }
+                sign = false;
+            }
+            if (sign){
+                dto.setMsg(dto.getMsg()+PZH+DateUtils.convert(now)+" "+director.getNickname()+"鍥為��瀹℃壒");
+            }
+
+            planDtoList.add(dto);
+        }
+        plan.setStatus(0);
+        plan.setStep(1);
+        plan.setSettle(1);
+        plan.setSettleMsg(JSON.toJSONString(planDtoList));
+        plan.setUpdateBy(getUserId());
+        plan.setUpdateTime(now);
+        planService.updateById(plan);
+        return R.ok("鍥為��鎴愬姛");
     }
 
     @PostMapping(value = "/plan/planner/list/auth")
@@ -587,6 +670,39 @@
         return R.ok(result);
     }
 
+    @RequestMapping(value = "/planQueryNameToRob/auth")
+    @ManagerAuth
+    public R planQueryNameToRob(String condition) {
+        EntityWrapper<Plan> wrapper = new EntityWrapper<>();
+        wrapper.like("name", condition);
+        wrapper.eq("status",1);
+
+        int type =1;
+        if (getUser().getNickname().equals("鏉庝笘璞�2绾�")){
+            type=2;
+        }
+
+        List<Long> typeList = new ArrayList<>();
+        List<PlanType> planTypes = planTypeService.selectList(new EntityWrapper<PlanType>().eq("type", type));
+        for (PlanType planType : planTypes){
+            typeList.add(planType.getId());
+        }
+        wrapper.in("plan_type",typeList);
+
+//        Page<Plan> page = planService.selectPage(new Page<>(0, 10), wrapper);
+        List<Plan> plans = planService.selectList(wrapper);
+        List<Map<String, Object>> result = new ArrayList<>();
+//        for (Plan plan : page.getRecords()){
+        for (Plan plan : plans){
+            Map<String, Object> map = new HashMap<>();
+            map.put("id", plan.getId());
+//            map.put("value", plan.getName()+"---"+plan.getId());
+            map.put("value", plan.getName());
+            result.add(map);
+        }
+        return R.ok(result);
+    }
+
     @RequestMapping(value = "/plan/check/column/auth")
     @ManagerAuth
     public R query(@RequestBody JSONObject param) {

--
Gitblit v1.9.1