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/PlanController.java | 604 +++++++++++++++++++++--------------------------------- 1 files changed, 235 insertions(+), 369 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 305ffbc..6e91c54 100644 --- a/src/main/java/com/zy/crm/manager/controller/PlanController.java +++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java @@ -6,15 +6,12 @@ import com.baomidou.mybatisplus.mapper.Wrapper; import com.baomidou.mybatisplus.plugins.Page; import com.core.annotations.ManagerAuth; -import com.core.common.BaseRes; -import com.core.common.Cools; -import com.core.common.DateUtils; -import com.core.common.R; +import com.core.common.*; 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.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.*; @@ -58,7 +55,7 @@ @Autowired private ProcessPermissionsService processPermissionsService; - String PZH=" 鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�� "; + String PZH = " 鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�� "; Integer PBN = 6; @@ -78,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); } @@ -91,10 +88,10 @@ @RequestParam(required = false, value = "dept_id") Long deptId, @RequestParam(required = false, value = "user_id") Long userId) { Long director = null; - if (deptId==null && userId == null){ - if (getRole().getId()==3){ + if (deptId == null && userId == null) { + if (getRole().getId() == 3) { userId = getUserId(); - }else if (getRole().getId()==2){ + } else if (getRole().getId() == 2) { deptId = getDeptId(); userId = null; } @@ -123,14 +120,14 @@ @Transactional public R assistantPlanView(@RequestParam Long hostPlanId) { Plan plan = planService.selectById(hostPlanId); - if (plan.getAssistantHostSign()==1){ + if (plan.getAssistantHostSign() == 1) { EntityWrapper<Plan> wrapper = new EntityWrapper<>(); - wrapper.eq("id",plan.getHostPlanId()); + wrapper.eq("id", plan.getHostPlanId()); Page<Plan> planPage = planService.selectPage(new Page<>(1, 1), wrapper); return R.ok(planPage); } EntityWrapper<Plan> wrapper = new EntityWrapper<>(); - wrapper.eq("id",plan.getAssistantPlanId()); + wrapper.eq("id", plan.getAssistantPlanId()); Page<Plan> planPage = planService.selectPage(new Page<>(1, 1), wrapper); return R.ok(planPage); } @@ -159,7 +156,7 @@ throw new CoolException("璺熻釜椤圭洰涓嶅瓨鍦�"); } - if (!order.getDirector().equals(getUserId())){ + if (!order.getDirector().equals(getUserId())) { throw new CoolException("鍙厑璁歌窡韪」鐩礋璐d汉娣诲姞鎵�閫夐」鐩鍒掔敵璇峰崟"); } @@ -179,22 +176,43 @@ 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); - }else { + } else { 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("淇濇寔澶辫触锛岃閲嶈瘯"); @@ -207,7 +225,11 @@ if (!planFollService.insert(planFoll)) { throw new CoolException("淇濇寔澶辫触锛岃閲嶈瘯"); } - + if (users.size() > 1 && !users.get(1).getId().equals(getUserId())) { + if (!smsCodeService.sendSmsCodeText(users.get(1).getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E, getUserId())) { + return R.ok("鍒涘缓鎴愬姛浣嗙煭淇″彂閫佸け璐�!"); + } + } return R.ok(); } @@ -216,8 +238,18 @@ @Transactional public R assistantPlanAdd(@RequestParam Long hostPlanId) { Plan hostPlan = planService.selectById(hostPlanId); - if (!Cools.isEmpty(hostPlan.getAssistantPlanId()) && hostPlan.getAssistantPlanId()!=0){ - return R.error("姝よ鍒掑崟宸插瓨鍦ㄥ壇瑙勫垝鍗曪紝id涓�"+hostPlan.getAssistantPlanId()); + if (!getUserId().equals(hostPlan.getUserId())) { + return R.error("璇疯仈绯讳笟鍔″憳鎿嶄綔"); + } + if (hostPlan.getAssistantHostSign() != 0) { + return R.error("姝よ鍒掑崟涓嶉渶瑕佸垱寤哄壇娴佺▼"); + } + PlanType planType2 = planTypeService.selectById(hostPlan.getPlanType()); + if (planType2.getType() != 2) { + return R.error("姝よ鍒掑崟涓嶉渶瑕佸垱寤哄壇娴佺▼"); + } + if (!Cools.isEmpty(hostPlan.getAssistantPlanId()) && hostPlan.getAssistantPlanId() != 0) { + return R.error("姝よ鍒掑崟宸插瓨鍦ㄥ壇瑙勫垝鍗曪紝id涓�" + hostPlan.getAssistantPlanId()); } // pre Plan plan = new Plan(hostPlan); @@ -232,7 +264,7 @@ throw new CoolException("璺熻釜椤圭洰涓嶅瓨鍦�"); } - if (!order.getDirector().equals(getUserId())){ + if (!order.getDirector().equals(getUserId())) { throw new CoolException("鍙厑璁歌窡韪」鐩礋璐d汉娣诲姞鎵�閫夐」鐩鍒掔敵璇峰崟"); } @@ -254,14 +286,32 @@ plan.setAssistantHostSign(1);//鍓鍒掑崟 User manager = new User(); - try{ + try { manager = userService.getDeptManager(getHostId(), getUser().getDeptId()); // 鑾峰彇閮ㄩ棬棰嗗 - }catch (Exception e){ + } catch (Exception e) { manager = getUser(); } - PlanType planType = new PlanType(hostPlan.getHostId(),1);//1:璐ф灦 + 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()); @@ -286,13 +336,16 @@ if (!planService.updateById(hostPlan)) { throw new CoolException("鏇存柊澶辫触锛岃閲嶈瘯"); } + if (!smsCodeService.sendSmsCodeText(planLeader.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E, getUserId())) { + return R.ok("鍒涘缓鎴愬姛浣嗙煭淇″彂閫佸け璐�!"); + } return R.ok("淇濆瓨鎴愬姛"); } - @RequestMapping(value = "/plan/update/auth") - @ManagerAuth(memo = "鏇存柊瑙勫垝鐢宠鍗�") + @RequestMapping(value = "/plan/update/auth") + @ManagerAuth(memo = "鏇存柊瑙勫垝鐢宠鍗�") @Transactional - public R update(@RequestParam Map<String, Object> param){ + public R update(@RequestParam Map<String, Object> param) { // String planNeed = null; // Integer id = null; // for (Map.Entry<String, Object> entry : param.entrySet()){ @@ -311,7 +364,7 @@ // } // } // } - if (Cools.isEmpty(param) || Cools.isEmpty(param.get("id"))){ + if (Cools.isEmpty(param) || Cools.isEmpty(param.get("id"))) { return R.error(); } // List<String> planNeedbs = new ArrayList<>(Arrays.asList(planNeed.split("-"))); @@ -344,54 +397,30 @@ @RequestMapping(value = "/plan/delete/auth") @ManagerAuth(memo = "鍒犻櫎瑙勫垝鐢宠鍗�") - public R delete(@RequestParam(value="ids[]") Long[] ids){ - for (Long id : ids){ - int priOnline2 = priOnline2Service.selectCount(new EntityWrapper<PriOnline2>().eq("item_id", id)); - if (priOnline2!=0){ - return R.error("瀛樺湪鍏宠仈鐨勬牳浠峰崟锛岀姝㈠垹闄わ紒锛侊紒"); - } - Plan planA = planService.selectById(id); - if (planA.getAssistantHostSign()==1){ - Plan planB = planService.selectById(planA.getHostPlanId()); - planB.setAssistantPlanId(0L); - planB.setHostPlanId(0L); - planB.setStatus2(0); - planService.updateById(planB); - }else { - if (!Cools.isEmpty(planA.getAssistantPlanId()) && planA.getAssistantPlanId()!=0){ - Plan planB = planService.selectById(planA.getAssistantPlanId()); - if (!Cools.isEmpty(planB)){ - return R.error("瀛樺湪鍏宠仈鐨勫壇瑙勫垝鍗曪紝绂佹鍒犻櫎锛侊紒锛� 鍓鍒掑崟ID锛�"+planB.getId()); - } - } - } - planService.deleteById(id); + public R delete(@RequestParam(value = "ids[]") Long[] ids) { + for (Long id : ids) { + int priOnline2 = priOnline2Service.selectCount(new EntityWrapper<PriOnline2>().eq("item_id", id)); + if (priOnline2 != 0) { + return R.error("瀛樺湪鍏宠仈鐨勬牳浠峰崟锛岀姝㈠垹闄わ紒锛侊紒"); + } + Plan planA = planService.selectById(id); + if (planA.getAssistantHostSign() == 1) { + Plan planB = planService.selectById(planA.getHostPlanId()); + planB.setAssistantPlanId(0L); + planB.setHostPlanId(0L); + planB.setStatus2(0); + planService.updateById(planB); + } else { + if (!Cools.isEmpty(planA.getAssistantPlanId()) && planA.getAssistantPlanId() != 0) { + Plan planB = planService.selectById(planA.getAssistantPlanId()); + if (!Cools.isEmpty(planB)) { + return R.error("瀛樺湪鍏宠仈鐨勫壇瑙勫垝鍗曪紝绂佹鍒犻櫎锛侊紒锛� 鍓鍒掑崟ID锛�" + planB.getId()); + } + } + } + planService.deleteById(id); } return R.ok(); - } - - @RequestMapping(value = "/plan/insert/file/auth") -// @ManagerAuth - public R insertFile(@RequestParam("planId") String planId, @RequestParam("filename") String filename, @RequestParam("filesize") Long filesize) { - try { -// InputStream inputStream = file.getInputStream(); -// // 鑾峰彇鏂囦欢鐨勫唴瀹圭被鍨� -// String contentType = file.getContentType(); -// String url = ossService.upload(inputStream, file.getOriginalFilename(), contentType); -//// String url = "http://tjdt.oss-cn-hangzhou.aliyuncs.com/"+file.getOriginalFilename(); -// String[] names = url.split("com/"); -// String name= names[1]; - - - String[] split = planId.split("-"); - int id = Integer.parseInt(split[1]); - String url = "http://zhongyang-ftpserver.oss-cn-hangzhou.aliyuncs.com/" + filename; - planService.increasePlanUrl(id, url, filename, filesize); - return R.ok(); - } catch (Exception e) { - System.out.println(e); - return R.error(); - } } private String getFileSuffix(String filename) { @@ -418,277 +447,113 @@ // return R.ok(); // } - @RequestMapping(value = "/plan/view/file/auth") -// @ManagerAuth - public R viewFile(@RequestParam("planId") String planId){ - List<FileSaveExampleUtil.FileDTO> fileDTOS = new ArrayList<>(); - if (Cools.isEmpty(planId)){ - return R.ok(fileDTOS); - } - int id = Integer.parseInt(planId); -// String savePath = "D:/crm/plan/file/"+id+"/"; // 鎸囧畾淇濆瓨鏂囦欢鐨勮矾寰� - try{ - List<Integer> ids = planService.selectPlanUrlId(id); - for (int id2 : ids){ - String url = planService.selectPlanUrlPlanIdUrl(id2); - String name = planService.selectPlanUrlPlanIdName(id2); - Long size = planService.selectPlanUrlPlanIdSize(id2); - FileSaveExampleUtil.FileDTO dto = new FileSaveExampleUtil.FileDTO(name,size,url); - fileDTOS.add(dto); - } -// List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath); - return R.ok(fileDTOS); - }catch (Exception e){ - return R.error(); - } - } - @RequestMapping(value = "/plan/download/file/auth") // @ManagerAuth - public R downloadFile(@RequestParam("downloadUrl") String downloadUrl,HttpServletResponse response){ + public R downloadFile(@RequestParam("downloadUrl") String downloadUrl, HttpServletResponse response) { // System.out.println("---寮�濮�---"); // MultipartFile - try{ + try { String[] names = downloadUrl.split("com/"); - String name= names[1]; + String name = names[1]; // ResponseEntity<Resource> resourceResponseEntity = FileSaveExampleUtil.downloadFile(downloadUrl, response); // return R.ok(resourceResponseEntity); String download = ossService.download(name); return R.ok().add(download); - }catch (Exception e){ + } catch (Exception e) { } return R.error(); } - @PostMapping(value = "/plan/approval/auth") @ManagerAuth(memo = "瀹℃壒鐢宠鍗�") public R approval(@RequestParam Long planId, - @RequestParam(required = false) Long plannerId){ + @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()); - - boolean sendSmsCode = smsCodeService.sendSmsCodeText(planner.getMobile()); - if (!sendSmsCode) { - System.out.println("鐭俊鍙戦�佸け璐ワ紒"); - } - - 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("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); - } - 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("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); - } - 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, getUserId())) { + return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!"); + } + } else { + User phoneUser = userService.selectById(nextUserId); + if (!smsCodeService.sendSmsCodeText(phoneUser.getMobile(), PhoneCodeTypeParam.ALIYUN_M1ABAC630E, getUserId())) { + return R.ok("瀹℃牳鎴愬姛浣嗙煭淇″彂閫佸け璐�!"); + } + } + } + return R.ok("瀹℃壒鎴愬姛"); } @@ -700,26 +565,26 @@ Date now = new Date(); Long directorId = plan.getDirector(); User director = userService.selectById(directorId); - if (!director.getId().equals(getUserId())){ + 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)){ + 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()+"鍥為��瀹℃壒"); + 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()+"鍥為��瀹℃壒"); + if (sign) { + dto.setMsg(dto.getMsg() + PZH + DateUtils.convert(now) + " " + director.getNickname() + "鍥為��瀹℃壒"); } planDtoList.add(dto); @@ -736,7 +601,7 @@ @PostMapping(value = "/plan/planner/list/auth") @ManagerAuth - public R plannerList(@RequestParam Long planId){ + public R plannerList(@RequestParam Long planId) { Plan plan = planService.selectById(planId); assert plan != null; @@ -745,7 +610,7 @@ } // 鏌ユ壘瑙勫垝缁勯暱 PlanType planType = planTypeService.selectById(plan.getPlanType()); - if (plan.getAssistantHostSign()==1){ + if (plan.getAssistantHostSign() == 1) { planType.setType(1); } User planLeader = planTypeService.findPlanLeader(planType); @@ -759,8 +624,8 @@ List<User> users = userService.selectList(new EntityWrapper<User>().eq("dept_id", planLeader.getDeptId())); List<KeyValueVo> vos = new ArrayList<>(); users.forEach(item -> vos.add(new KeyValueVo(String.valueOf(item.getNickname()), item.getId()))); - if (planType.getType().equals(2)){ - ProcessPermissions processPermissions= processPermissionsService.selectOne(new EntityWrapper<ProcessPermissions>().eq("process_memo", 101).eq("process", "1-1"));//2锛氭牳浠锋祦绋� + if (planType.getType().equals(2)) { + ProcessPermissions processPermissions = processPermissionsService.selectOne(new EntityWrapper<ProcessPermissions>().eq("process_memo", 101).eq("process", "1-1"));//2锛氭牳浠锋祦绋� User manager = userService.selectById(processPermissions.getUserId()); // 鑾峰彇鏍镐环娴佺▼鑺傜偣1纭浜� vos.add(new KeyValueVo(String.valueOf(manager.getNickname()), manager.getId())); } @@ -774,7 +639,7 @@ wrapper.like("name", condition); Page<Plan> page = planService.selectPage(new Page<>(0, 10), wrapper); List<Map<String, Object>> result = new ArrayList<>(); - for (Plan plan : page.getRecords()){ + for (Plan plan : page.getRecords()) { Map<String, Object> map = new HashMap<>(); map.put("id", plan.getId()); map.put("value", plan.getName()); @@ -790,7 +655,7 @@ wrapper.like("name", condition); Long id = getRole().getId(); if (id.equals(1L)) { - wrapper.eq("host_id", 1); + wrapper.eq("host_id", getHostId()); } else if (id.equals(2L)) { wrapper.eq("dept_id", getDeptId()); } else { @@ -798,7 +663,7 @@ } Page<Plan> page = planService.selectPage(new Page<>(0, 10), wrapper); List<Map<String, Object>> result = new ArrayList<>(); - for (Plan plan : page.getRecords()){ + for (Plan plan : page.getRecords()) { Map<String, Object> map = new HashMap<>(); map.put("id", plan.getId()); // map.put("value", plan.getName()+"---"+plan.getId()); @@ -813,53 +678,55 @@ public R planQueryNameToRob(String condition) { EntityWrapper<Plan> wrapper = new EntityWrapper<>(); wrapper.like("name", condition); - wrapper.eq("status",1); - wrapper.eq("assistant_host_sign",0); + wrapper.eq("status", 1); + wrapper.eq("assistant_host_sign", 0); List<ProcessPermissions> processPermissionsList = processPermissionsService.selectList(new EntityWrapper<ProcessPermissions>().eq("process_memo", 4).or().eq("process_memo", 5));//2锛氭牳浠锋祦绋� - int type =0; - for (ProcessPermissions processPermissions:processPermissionsList){ - if (getUserId().equals(processPermissions.getUserId())){ - type=PBN-processPermissions.getProcessMemo(); + int type = 0; + for (ProcessPermissions processPermissions : processPermissionsList) { + if (getUserId().equals(processPermissions.getUserId())) { + type = PBN - processPermissions.getProcessMemo(); break; } } - if (type==0){ + if (type == 0) { return R.error("浣犱笉鏄牳浠峰憳,鏃犳潈鎺ヤ换鍔�"); } List<Long> typeList = new ArrayList<>(); List<PlanType> planTypes = planTypeService.selectList(new EntityWrapper<PlanType>().eq("type", type)); - if (Cools.isEmpty(planTypes) || planTypes.size()==0){ + if (Cools.isEmpty(planTypes) || planTypes.size() == 0) { return R.ok(); } - for (PlanType planType : planTypes){ + for (PlanType planType : planTypes) { typeList.add(planType.getId()); } - wrapper.in("plan_type",typeList); + 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){ + for (Plan plan : plans) { + User user = userService.selectById(plan.getUserId()); Map<String, Object> map = new HashMap<>(); map.put("id", plan.getId()); // map.put("value", plan.getName()+"---"+plan.getId()); - map.put("value", plan.getName()); + map.put("value", plan.getName() + "---" + user.getNickname()); result.add(map); } - if (type==1){ + if (type == 1) { EntityWrapper<Plan> wrapper2 = new EntityWrapper<>(); wrapper2.like("name", condition); - wrapper2.eq("status",1); - wrapper2.eq("assistant_host_sign",1); + wrapper2.eq("status", 1); + wrapper2.eq("assistant_host_sign", 1); List<Plan> plan2s = planService.selectList(wrapper2); - for (Plan plan : plan2s){ + for (Plan plan : plan2s) { + User user = userService.selectById(plan.getUserId()); Map<String, Object> map = new HashMap<>(); map.put("id", plan.getId()); // map.put("value", plan.getName()+"---"+plan.getId()); - map.put("value", plan.getName()); + map.put("value", plan.getName() + "---" + user.getNickname()); result.add(map); } } @@ -870,7 +737,7 @@ @ManagerAuth public R query(@RequestBody JSONObject param) { Wrapper<Plan> wrapper = new EntityWrapper<Plan>().eq(humpToLine(String.valueOf(param.get("key"))), param.get("val")); - if (null != planService.selectOne(wrapper)){ + if (null != planService.selectOne(wrapper)) { return R.parse(BaseRes.REPEAT).add(getComment(Plan.class, String.valueOf(param.get("key")))); } return R.ok(); @@ -891,7 +758,7 @@ * excel瀵煎叆 */ @PostMapping(value = "/plan/excel/import/auth") - @ManagerAuth(memo = "鐢叉柟鍗曚綅Excel瀵煎叆") + @ManagerAuth(memo = "瀹㈡埛淇℃伅Excel瀵煎叆") // @Transactional public R planExcelImport(MultipartFile file) throws IOException { InputStream inStream = file.getInputStream(); @@ -903,8 +770,7 @@ Workbook book = null; if (excelVersion == 2003) { book = new HSSFWorkbook(inStream); - } - else { // 褰� excel 鏄� 2007 鏃� + } else { // 褰� excel 鏄� 2007 鏃� book = new XSSFWorkbook(inStream); } Sheet sheet = book.getSheetAt(0); @@ -954,7 +820,7 @@ @ManagerAuth @Transactional public R planFollowersAdd(@RequestParam("planId") Long planId, - @RequestParam("followerIds[]") Long[] followerIds) { + @RequestParam("followerIds[]") Long[] followerIds) { if (Cools.isEmpty(planId, followerIds)) { return R.parse(BaseRes.PARAM); } @@ -974,7 +840,7 @@ @RequestMapping(value = "/plan/followers/remove/auth") @ManagerAuth public R planFollowersRemove(@RequestParam("planId") Long planId, - @RequestParam("userId") Long userId) { + @RequestParam("userId") Long userId) { if (Cools.isEmpty(planId, userId)) { return R.parse(BaseRes.PARAM); } -- Gitblit v1.9.1