| | |
| | | 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.domain.KeyValueVo; |
| | | import com.core.exception.CoolException; |
| | | 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.Plan; |
| | | import com.zy.crm.manager.entity.PlanFoll; |
| | | import com.zy.crm.manager.entity.PlanType; |
| | | import com.zy.crm.manager.service.PlanFollService; |
| | | import com.zy.crm.manager.service.PlanService; |
| | | import com.zy.crm.manager.service.PlanTypeService; |
| | | import com.zy.crm.manager.entity.*; |
| | | import com.zy.crm.manager.service.*; |
| | | import com.zy.crm.system.entity.User; |
| | | import com.zy.crm.system.service.DeptService; |
| | | import com.zy.crm.system.service.UserService; |
| | | import org.apache.poi.hssf.usermodel.HSSFWorkbook; |
| | | import org.apache.poi.ss.usermodel.DataFormatter; |
| | |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import javax.xml.crypto.Data; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.util.*; |
| | |
| | | private PlanService planService; |
| | | @Autowired |
| | | private PlanTypeService planTypeService; |
| | | @Autowired |
| | | private DeptService deptService; |
| | | @Autowired |
| | | private OssService ossService; |
| | | @Autowired |
| | | private PriOnline2Service priOnline2Service; |
| | | @Autowired |
| | | private OrderService orderService; |
| | | @Autowired |
| | | private SmsCodeService smsCodeService; |
| | | @Autowired |
| | | private ProcessPermissionsService processPermissionsService; |
| | | |
| | | String PZH=" ————————————————— "; |
| | | Integer PBN = 6; |
| | | |
| | | |
| | | @GetMapping(value = "/plan/{id}/auth") |
| | | @ManagerAuth |
| | |
| | | } |
| | | resultObj.put("formHtml", planType.getHtml()); |
| | | // 步骤条相关 |
| | | resultObj.put("step", this.getStepOfSettle(plan.getSettle())); |
| | | resultObj.put("step", plan.getSettle() == 4 ? 0 : plan.getSettle() + 1); |
| | | |
| | | return R.ok().add(resultObj); |
| | | } |
| | |
| | | @RequestParam(required = false) String condition, |
| | | @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){ |
| | | userId = getUserId(); |
| | | }else if (getRole().getId()==2){ |
| | | deptId = getDeptId(); |
| | | userId = null; |
| | | } |
| | | director = getUserId(); |
| | | } |
| | | |
| | | return R.ok(planService.getPage(new Page<>(curr, limit) |
| | | , getHostId() |
| | | , deptId == null ? null : String.valueOf(deptId) |
| | | , userId == null ? getUserId() : userId |
| | | , userId |
| | | , director |
| | | , condition) |
| | | ); |
| | | } |
| | |
| | | } |
| | | |
| | | @RequestMapping(value = "/plan/add/auth") |
| | | @ManagerAuth |
| | | @ManagerAuth(memo = "添加规划申请单") |
| | | @Transactional |
| | | public R add(@RequestParam Map<String, Object> param) { |
| | | // pre |
| | | Plan plan = JSON.parseObject(JSON.toJSONString(param), Plan.class); |
| | |
| | | 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("只允许跟踪项目负责人添加所选项目规划申请单"); |
| | | } |
| | | |
| | | Date now = new Date(); |
| | | plan.setHostId(hostId); |
| | | plan.setUuid(planService.getUuid(hostId)); // 规划单代号 |
| | | plan.setDeptId(getDeptId()); // 所属部门 |
| | | plan.setUserId(getUserId()); // 所属人员 |
| | | |
| | | plan.setAppleTime(now); |
| | | plan.setCreateBy(getUserId()); |
| | | plan.setCreateTime(new Date()); |
| | | plan.setCreateTime(now); |
| | | plan.setUpdateBy(getUserId()); |
| | | plan.setUpdateTime(new Date()); |
| | | plan.setStatus(1); |
| | | plan.setUpdateTime(now); |
| | | plan.setStatus(0); |
| | | plan.setStep(1); |
| | | |
| | | plan.setForm(JSON.toJSONString(param)); // 自定义表单内容 |
| | | plan.setSettle(1); // 1.开始 |
| | | plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan))); |
| | | 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("保持失败,请重试"); |
| | | } |
| | | |
| | | // 自动添加跟进人 |
| | | PlanFoll planFoll = new PlanFoll(); |
| | | planFoll.setPlanId(plan.getId()); |
| | | planFoll.setUserId(planLeader.getId()); |
| | | if (!planFollService.insert(planFoll)) { |
| | | throw new CoolException("保持失败,请重试"); |
| | | } |
| | | |
| | | return R.ok(); |
| | | } |
| | | |
| | | @RequestMapping(value = "/plan/update/auth") |
| | | @ManagerAuth |
| | | @ManagerAuth(memo = "更新规划申请单") |
| | | @Transactional |
| | | public R update(@RequestParam Map<String, Object> param){ |
| | | // String planNeed = null; |
| | | // Integer id = null; |
| | | // for (Map.Entry<String, Object> entry : param.entrySet()){ |
| | | // String val = String.valueOf(entry.getValue()); |
| | | // if (Cools.isEmpty(val)){ |
| | | // continue; |
| | | // } |
| | | // if (entry.getKey().equals("planNeed")){ |
| | | // planNeed = val; |
| | | // } |
| | | // if (entry.getKey().equals("id")){ |
| | | // try{ |
| | | // id = Integer.parseInt(val); |
| | | // }catch (Exception e){ |
| | | // return R.error(); |
| | | // } |
| | | // } |
| | | // } |
| | | if (Cools.isEmpty(param) || Cools.isEmpty(param.get("id"))){ |
| | | return R.error(); |
| | | } |
| | | // List<String> planNeedbs = new ArrayList<>(Arrays.asList(planNeed.split("-"))); |
| | | // if (planNeedbs.get(0).equals("[object Object]")){ |
| | | // planNeedbs.remove(0); |
| | | // Plan plan1 = planService.selectById(id); |
| | | // List<String> planNeedas = Arrays.asList(plan1.getPlanNeed().split("-")); |
| | | // List<String> routeIntersectionString = SetOfUtils.getRouteIntersectionString(planNeedas, planNeedbs, RouteCollectCountType.DEDUPLICATIONUNION); |
| | | // planNeed=""; |
| | | // for (String planNeedss:routeIntersectionString){ |
| | | // planNeed=planNeed==""? planNeedss:planNeed + "-" + planNeedss; |
| | | // } |
| | | // } |
| | | |
| | | |
| | | // pre |
| | | Plan plan = JSON.parseObject(JSON.toJSONString(param), Plan.class); |
| | | // plan.setPlanNeed(planNeed); |
| | | param.entrySet().removeIf(next -> this.fields.contains(next.getKey())); |
| | | plan.setUpdateBy(getUserId()); |
| | | plan.setUpdateTime(new Date()); |
| | | |
| | | plan.setForm(JSON.toJSONString(param)); // 自定义表单内容 |
| | | plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan))); |
| | | |
| | | if (!planService.updateById(plan)) { |
| | | throw new CoolException("保持失败,请重试"); |
| | |
| | | } |
| | | |
| | | @RequestMapping(value = "/plan/delete/auth") |
| | | @ManagerAuth |
| | | @ManagerAuth(memo = "删除规划申请单") |
| | | public R delete(@RequestParam(value="ids[]") Long[] ids){ |
| | | for (Long id : ids){ |
| | | planService.deleteById(id); |
| | | int priOnline2 = priOnline2Service.selectCount(new EntityWrapper<PriOnline2>().eq("item_id", id)); |
| | | if (priOnline2!=0){ |
| | | return R.error("存在关联的核价单,禁止删除!!!"); |
| | | } |
| | | planService.deleteById(id); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | @RequestMapping(value = "/plan/insert/file/auth") |
| | | // @ManagerAuth |
| | | public R insertFile(@RequestParam("planId") String planId,@RequestParam MultipartFile file){ |
| | | 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]); |
| | | planService.increasePlanUrl(id,url,name,file.getSize()); |
| | | |
| | | /*String[] split = planId.split("-"); |
| | | int id = Integer.parseInt(split[1]); |
| | | System.out.println("---开始---"); |
| | | String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径 |
| | | try{ |
| | | FileSaveExampleUtil.saveFile(file, savePath); |
| | | }catch (Exception e){ |
| | | return R.error(); |
| | | }*/ |
| | | return R.ok(); |
| | | }catch (Exception e){ |
| | | System.out.println(e); |
| | | return R.error(); |
| | | } |
| | | } |
| | | |
| | | private String getFileSuffix(String filename) { |
| | | int dotIndex = filename.lastIndexOf("."); |
| | | if (dotIndex > 0 && dotIndex < filename.length() - 1) { |
| | | return filename.substring(dotIndex + 1); |
| | | } |
| | | return ""; |
| | | } |
| | | |
| | | // @RequestMapping(value = "/plan/delete/file/auth") |
| | | //// @ManagerAuth |
| | | // public R deleteFile(@RequestParam("planId") String planId,@RequestParam MultipartFile file){ |
| | | // planId="上传文件-20"; |
| | | // String[] split = planId.split("-"); |
| | | // int id = Integer.parseInt(split[1]); |
| | | // System.out.println("---开始---"); |
| | | // String savePath = "D:/crm/plan/file/"+id+"/"+file.getName(); // 指定保存文件的路径 |
| | | // try{ |
| | | // FileSaveExampleUtil.deleteFilesInDirectory(savePath); |
| | | // }catch (Exception e){ |
| | | // return R.error(); |
| | | // } |
| | | // return R.ok(); |
| | | // } |
| | | |
| | | @RequestMapping(value = "/plan/view/file/auth") |
| | | // @ManagerAuth |
| | | public R viewFile(@RequestParam("planId") String planId){ |
| | | int id = Integer.parseInt(planId); |
| | | // String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径 |
| | | try{ |
| | | List<Integer> ids = planService.selectPlanUrlId(id); |
| | | List<FileSaveExampleUtil.FileDTO> fileDTOS = new ArrayList<>(); |
| | | 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){ |
| | | // System.out.println("---开始---"); |
| | | // MultipartFile |
| | | try{ |
| | | String[] names = downloadUrl.split("com/"); |
| | | 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){ |
| | | |
| | | } |
| | | return R.error(); |
| | | } |
| | | |
| | | |
| | | |
| | | @PostMapping(value = "/plan/approval/auth") |
| | | @ManagerAuth(memo = "审批申请单") |
| | | public R approval(@RequestParam Long planId, |
| | | @RequestParam(required = false) Long plannerId){ |
| | | Plan plan = planService.selectById(planId); |
| | | assert plan != null; |
| | | |
| | | 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: |
| | | // 查找规划组长 |
| | | PlanType planType = planTypeService.selectById(plan.getPlanType()); |
| | | User planLeader = planTypeService.findPlanLeader(planType); |
| | | 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 (!planService.updateById(plan)) { |
| | | throw new CoolException("审核失败,请联系管理员"); |
| | | } |
| | | break; |
| | | default: |
| | | 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") |
| | | @ManagerAuth |
| | | public R plannerList(@RequestParam Long planId){ |
| | | Plan plan = planService.selectById(planId); |
| | | assert plan != null; |
| | | |
| | | if (plan.getSettle() != 1) { |
| | | return R.error(); |
| | | } |
| | | // 查找规划组长 |
| | | PlanType planType = planTypeService.selectById(plan.getPlanType()); |
| | | User planLeader = planTypeService.findPlanLeader(planType); |
| | | if (Cools.isEmpty(planLeader)) { |
| | | throw new CoolException("未查找到规划组长,请联系管理员"); |
| | | } |
| | | if (!getUserId().equals(planLeader.getId())) { |
| | | return R.error("抱歉,您没有审核的权限"); |
| | | } |
| | | // 获取当期规划组所有成员 |
| | | 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:核价流程 |
| | | User manager = userService.selectById(processPermissions.getUserId()); // 获取核价流程节点1确认人 |
| | | vos.add(new KeyValueVo(String.valueOf(manager.getNickname()), manager.getId())); |
| | | } |
| | | return R.ok().add(vos); |
| | | } |
| | | |
| | | @RequestMapping(value = "/planQuery/auth") |
| | |
| | | for (Plan plan : page.getRecords()){ |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("id", plan.getId()); |
| | | map.put("value", plan.getName()); |
| | | result.add(map); |
| | | } |
| | | return R.ok(result); |
| | | } |
| | | |
| | | @RequestMapping(value = "/planQueryName/auth") |
| | | @ManagerAuth |
| | | public R queryName(String condition) { |
| | | EntityWrapper<Plan> wrapper = new EntityWrapper<>(); |
| | | wrapper.like("name", condition); |
| | | Long id = getRole().getId(); |
| | | if (id.equals(1L)) { |
| | | wrapper.eq("host_id", 1); |
| | | } else if (id.equals(2L)) { |
| | | wrapper.eq("dept_id", getDeptId()); |
| | | } else { |
| | | wrapper.eq("user_id", getUserId()); |
| | | } |
| | | Page<Plan> page = planService.selectPage(new Page<>(0, 10), wrapper); |
| | | List<Map<String, Object>> result = new ArrayList<>(); |
| | | for (Plan plan : page.getRecords()){ |
| | | 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 = "/planQueryNameToRob/auth") |
| | | @ManagerAuth |
| | | public R planQueryNameToRob(String condition) { |
| | | EntityWrapper<Plan> wrapper = new EntityWrapper<>(); |
| | | wrapper.like("name", condition); |
| | | wrapper.eq("status",1); |
| | | |
| | | 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(); |
| | | break; |
| | | } |
| | | } |
| | | 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){ |
| | | return R.ok(); |
| | | } |
| | | 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); |
| | | } |
| | |
| | | throw new CoolException("删除失败,请联系管理员"); |
| | | } |
| | | return R.ok("删除成功"); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | /*************************************** 步骤条相关 **********************************************/ |
| | | private Integer getStepOfSettle(int settle){ |
| | | switch (settle){ |
| | | case 1: |
| | | return 2; |
| | | case 2: |
| | | return 3; |
| | | case 3: |
| | | return 4; |
| | | case 4: |
| | | return 0; |
| | | default: |
| | | return 1; |
| | | } |
| | | } |
| | | |
| | | } |