From 92459e3e326488acae77e068c37eb4b96eae5ebf Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 27 三月 2024 12:41:48 +0800
Subject: [PATCH] #周计划

---
 src/main/java/com/zy/crm/manager/controller/PriOnline2Controller.java |  121 +++++++++++++---------------------------
 1 files changed, 39 insertions(+), 82 deletions(-)

diff --git a/src/main/java/com/zy/crm/manager/controller/PriOnline2Controller.java b/src/main/java/com/zy/crm/manager/controller/PriOnline2Controller.java
index f020640..acba7ea 100644
--- a/src/main/java/com/zy/crm/manager/controller/PriOnline2Controller.java
+++ b/src/main/java/com/zy/crm/manager/controller/PriOnline2Controller.java
@@ -12,6 +12,7 @@
 import com.core.common.R;
 import com.core.domain.KeyValueVo;
 import com.core.exception.CoolException;
+import com.zy.crm.common.entity.PhoneCodeTypeParam;
 import com.zy.crm.common.model.SettleDto;
 import com.zy.crm.common.web.BaseController;
 import com.zy.crm.manager.entity.*;
@@ -59,6 +60,9 @@
 
     @Autowired
     private PriOnline2FollService priOnline2FollService;
+
+    @Autowired
+    private SmsCodeService smsCodeService;
 
     String PZH = " 鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�� ";
 
@@ -108,9 +112,11 @@
         convert(param, wrapper);
         allLike(PriOnline2.class, param.keySet(), wrapper, condition);
         wrapper.or().eq("member_id", getUserId());
-        if (!Cools.isEmpty(orderByField)) {
-            wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));
-        }
+//        if (!Cools.isEmpty(orderByField)) {
+//            wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));
+//        }
+        wrapper.orderBy("update_time",false);
+        wrapper.orderBy("create_time",false);
         return R.ok(priOnline2Service.selectPage(new Page<>(curr, limit), wrapper));
     }
 
@@ -153,7 +159,7 @@
         }
         if (!signUserId && !signDeptId) {
             if (getRole().getId() == 1) {
-                wrapper.or().eq("host_id", 1);
+                wrapper.or().eq("host_id", getHostId());
             } else if (getRole().getId() == 2) {
                 wrapper.eq("dept_id", getDeptId());
             } else {
@@ -161,72 +167,9 @@
             }
         }
         if (signHostId) {
-            wrapper.or().eq("host_id", 1);
+            wrapper.or().eq("host_id", getHostId());
         }
     }
-//    @RequestMapping(value = "/priOnline2/HJ/add/auth")
-//    @ManagerAuth(memo = "鎺ュ彇闆嗘垚鏍镐环浠诲姟")
-//    public R addHJ(PriOnline2 priOnline2) {
-//        PriOnline2 priOnline21 = priOnline2Service.selectById(priOnline2.getId());
-//        if (priOnline21.getSettle()!=1 || !priOnline21.getMemberId().equals(0L)){
-//            return R.error("姝ら泦鎴愭牳浠峰崟鐘舵�佸凡鏀瑰彉锛岃鍒锋柊椤甸潰閲嶆柊閫夋嫨锛�");
-//        }
-//        Date now = new Date();
-//        priOnline21.setMemberId(getUserId());
-//
-//
-//        List<SettleDto> planDtos = JSON.parseArray(priOnline21.getSettleMsg(), SettleDto.class);
-//        List<SettleDto> planDtoList = new ArrayList<>();
-//        for (SettleDto dto : planDtos) {
-//            if (dto.getStep().equals(2)) {
-//                dto.setUserId(getUserId());
-//                dto.setUsername(getUser().getNickname());
-//                if (Cools.isEmpty(dto.getMsg())) {
-//                    dto.setMsg(getUser().getNickname() + "鎺ュ彇鏍镐环");
-//                } else {
-//                    dto.setMsg(dto.getMsg() + PZH + DateUtils.convert(now) + " " + getUser().getNickname() + "鎺ュ彇鏍镐环");
-//                }
-//                dto.setTime(DateUtils.convert(new Date()));
-//            }
-//            planDtoList.add(dto);
-//        }
-//        priOnline21.setSettleMsg(JSON.toJSONString(planDtoList));
-//        priOnline21.setUpdateUserId(getUserId());
-//        priOnline21.setUpdateTime(now);
-//        priOnline2Service.updateById(priOnline21);
-//        return R.ok("鎺ュ彇鎴愬姛");
-//    }
-
-//    @RequestMapping(value = "/priOnline2/HJ/search/auth")
-//    @ManagerAuth
-//    public R priOnline2Search(String condition) {
-//        EntityWrapper<PriOnline2> wrapper = new EntityWrapper<>();
-//        wrapper.like("template_name", condition);
-//        wrapper.eq("member_id",0L);
-//
-//        List<ProcessPermissions> processPermissionsList = processPermissionsService.selectList(new EntityWrapper<ProcessPermissions>().eq("process_memo", 5));//2锛氭牳浠锋祦绋�
-//        int type =0;
-//        for (ProcessPermissions processPermissions:processPermissionsList){
-//            if (getUserId().equals(processPermissions.getUserId())){
-//                type=1;
-//                break;
-//            }
-//        }
-//        if (type==0){
-//            return R.error("浣犱笉鏄牳浠峰憳,鏃犳潈鎺ヤ换鍔�");
-//        }
-//        List<Map<String, Object>> result = new ArrayList<>();
-//
-//        List<PriOnline2> priOnline2s = priOnline2Service.selectList(wrapper);
-//        for (PriOnline2 priOnline2 : priOnline2s){
-//            Map<String, Object> map = new HashMap<>();
-//            map.put("id", priOnline2.getId());
-//            map.put("name", priOnline2.getTemplateName()+" - ID:"+priOnline2.getId());
-//            result.add(map);
-//        }
-//        return R.ok(result);
-//    }
-
 
     @RequestMapping(value = "/priOnline2/add/auth")
     @ManagerAuth(memo = "娣诲姞鏍镐环绠$悊")
@@ -267,10 +210,9 @@
         if (plan.getStatus() != 1) {
             return R.error("姝よ鍒掑崟鐘舵�佹敼鍙橈紝璇峰埛鏂伴〉闈㈤噸鏂伴�夋嫨锛�");
         }
-        priOnline2.setMemberId(getUserId());
 
         Cstmr cstmr = cstmrService.selectById(plan.getCstmrId());
-        priOnline2.setTemplateName(cstmr.getName());  //鐢叉柟鍗曚綅鍚嶇О
+        priOnline2.setTemplateName(cstmr.getName());  //瀹㈡埛淇℃伅鍚嶇О
 
         priOnline2.setSettle(0);
 
@@ -282,7 +224,7 @@
 //        }
 
 //        String node="2-";
-        PlanType planType = planTypeService.selectById(plan.getPlanType());
+//        PlanType planType = planTypeService.selectById(plan.getPlanType());
 //        node = node+planType.getType();
 //        ProcessPermissions processPermissions = processPermissionsService.selectOne(new EntityWrapper<ProcessPermissions>().eq("process_memo", 5).eq("process", "2-1"));//2锛氭牳浠锋祦绋�
 //        User manager = userService.selectById(processPermissions.getUserId());       // 鑾峰彇鏍镐环娴佺▼鑺傜偣2纭浜�
@@ -296,11 +238,16 @@
         List<User> users = new ArrayList<>();
         users.add(getUser());
         users.add(getUser());
+//        users.add(new User());
         users.add(userUp);
         priOnline2.setSettleMsg(JSON.toJSONString(SettleDto.InItFlowPath(users, initNames, users.size())));
         priOnline2.setSettleSize(users.size());
         priOnline2.setPlanId(plan.getId());
-
+        if (users.size()>1){
+            priOnline2.setMemberId(users.get(1).getId());
+        } else {
+            priOnline2.setMemberId(getUserId());
+        }
         //璁剧疆椤圭洰娴佺▼
         plan.setStep(2);
         plan.setStatus(2);
@@ -310,10 +257,10 @@
 
         // 鑷姩娣诲姞璺熻繘浜�
         for (User user:users){
-            List<PriOnline2Foll> priOnline2Folls = priOnline2FollService.selectList(new EntityWrapper<PriOnline2Foll>().eq("pri_online2_id", plan.getId()).eq("user_id", user.getId()));
+            List<PriOnline2Foll> priOnline2Folls = priOnline2FollService.selectList(new EntityWrapper<PriOnline2Foll>().eq("pri_online2_id", priOnline2.getId()).eq("user_id", user.getId()));
             if (Cools.isEmpty(priOnline2Folls) || priOnline2Folls.size()==0){
                 PriOnline2Foll priOnline2Foll = new PriOnline2Foll();
-                priOnline2Foll.setPriOnline2Id(plan.getId());
+                priOnline2Foll.setPriOnline2Id(priOnline2.getId());
                 priOnline2Foll.setUserId(user.getId());
                 if (!priOnline2FollService.insert(priOnline2Foll)) {
                     throw new CoolException("淇濆瓨澶辫触锛岃閲嶈瘯");
@@ -619,10 +566,7 @@
         assert priOnline2 != null;
         Date now = new Date();
         Long nextUserId = getUserId();
-        User user = new User();
-        List<SettleDto> list = new ArrayList<>();
-
-        user = userService.selectById(priOnline2.getMemberId());
+        User user = userService.selectById(priOnline2.getMemberId());
 
         if (Cools.isEmpty(getUser()) || Cools.isEmpty(user)){
             return R.error("鎶辨瓑锛屾偍鏃犻渶纭锛侊紒锛�");
@@ -632,7 +576,7 @@
             return R.error("鎶辨瓑锛屾偍鏃犻渶纭锛侊紒锛�");
         }
         // 淇敼 settle 姝ラ鏁版嵁
-        list = JSON.parseArray(priOnline2.getSettleMsg(), SettleDto.class);
+        List<SettleDto> list = JSON.parseArray(priOnline2.getSettleMsg(), SettleDto.class);
         for (SettleDto dto : list) {
             if (dto.getStep().equals(priOnline2.getSettle())) {
                 dto.setCurr(Boolean.TRUE);
@@ -672,10 +616,19 @@
 
         if (user.getId().equals(priOnline2.getUserId())) {
             if (priOnline2.getAssistantHostSign()==0){
+                User manager = new User();
+                try {
+                    manager = userService.getDeptManager(getHostId(), getUser().getDeptId());        // 鑾峰彇閮ㄩ棬棰嗗
+                } catch (Exception e) {
+                    manager = getUser();
+                }
                 try {
                     priQuoteAdd(priOnline2.getId(), plannerId);
                 } catch (Exception e) {
                     return R.error("鑷姩鐢熸垚鎶ヤ环鍗曞け璐�");
+                }
+                if (!smsCodeService.sendSmsCodeText(manager.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E,getUserId())) {
+                    return R.ok("瀹℃壒鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
                 }
             }else {
                 try {
@@ -686,7 +639,11 @@
                     return R.error("鏇存柊涓昏〃澶辫触");
                 }
             }
-
+        }else {
+            User phoneUser = userService.selectById(nextUserId);
+            if (!smsCodeService.sendSmsCodeText(phoneUser.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E,getUserId())) {
+                return R.ok("瀹℃壒鎴愬姛浣嗙煭淇″彂閫佸け璐�!");
+            }
         }
 
         return R.ok("瀹℃壒鎴愬姛");
@@ -753,8 +710,8 @@
     @ManagerAuth
     public R priOnline2priQuoteAdd(@RequestParam Long planId) {
         List<KeyValueVo> vos = new ArrayList<>();
-        vos.add(new KeyValueVo("鎶ヤ环妯℃澘1", 1L));
-        vos.add(new KeyValueVo("鎶ヤ环妯℃澘2", 2L));
+        vos.add(new KeyValueVo("璐ф灦妯℃澘", 1L));
+        vos.add(new KeyValueVo("闆嗘垚妯℃澘", 2L));
         return R.ok().add(vos);
     }
 

--
Gitblit v1.9.1