|  |  |  | 
|---|
|  |  |  | 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.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.springframework.web.multipart.MultipartFile; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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 { | 
|---|
|  |  |  | 
|---|
|  |  |  | 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=" ————————————————— "; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @GetMapping(value = "/plan/{id}/auth") | 
|---|
|  |  |  | @ManagerAuth | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | resultObj.put("formHtml", planType.getHtml()); | 
|---|
|  |  |  | // 步骤条相关 | 
|---|
|  |  |  | resultObj.put("step", plan.getSettle() == 5 ? 0 : plan.getSettle() + 1); | 
|---|
|  |  |  | resultObj.put("step", plan.getSettle() == 4 ? 0 : plan.getSettle() + 1); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return R.ok().add(resultObj); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/plan/add/auth") | 
|---|
|  |  |  | @ManagerAuth | 
|---|
|  |  |  | @ManagerAuth(memo = "添加规划申请单") | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public R add(@RequestParam Map<String, Object> param) { | 
|---|
|  |  |  | // pre | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.开始 | 
|---|
|  |  |  | User manager = userService.getDeptManager(hostId, getUser().getDeptId());        // 获取部门领导 | 
|---|
|  |  |  | plan.setSettleMsg(JSON.toJSONString(SettleDto.init(plan, manager))); | 
|---|
|  |  |  | 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(manager.getId()); | 
|---|
|  |  |  | planFoll.setUserId(planLeader.getId()); | 
|---|
|  |  |  | if (!planFollService.insert(planFoll)) { | 
|---|
|  |  |  | throw new CoolException("保持失败,请重试"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/plan/update/auth") | 
|---|
|  |  |  | @ManagerAuth | 
|---|
|  |  |  | @ManagerAuth(memo = "更新规划申请单") | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public R update(@RequestParam Map<String, Object> param){ | 
|---|
|  |  |  | //        String planNeed = null; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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){ | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | InputStream inputStream = file.getInputStream(); | 
|---|
|  |  |  | // 获取文件的内容类型 | 
|---|
|  |  |  | String contentType = file.getContentType(); | 
|---|
|  |  |  | String suffix = getFileSuffix(file.getOriginalFilename()); | 
|---|
|  |  |  | String url = ossService.upload(inputStream, suffix,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(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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(); | 
|---|
|  |  |  | private String getFileSuffix(String filename) { | 
|---|
|  |  |  | int dotIndex = filename.lastIndexOf("."); | 
|---|
|  |  |  | if (dotIndex > 0 && dotIndex < filename.length() - 1) { | 
|---|
|  |  |  | return filename.substring(dotIndex + 1); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | 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+"/"; // 指定保存文件的路径 | 
|---|
|  |  |  | //        String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径 | 
|---|
|  |  |  | try{ | 
|---|
|  |  |  | List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath); | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | @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: | 
|---|
|  |  |  | // 本组组长审核 | 
|---|
|  |  |  | User user = userService.selectById(plan.getUserId()); | 
|---|
|  |  |  | User manager = userService.getDeptManager(getHostId(), user.getDeptId()); | 
|---|
|  |  |  | 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 2: | 
|---|
|  |  |  | // 查找规划组长 | 
|---|
|  |  |  | PlanType planType = planTypeService.selectById(plan.getPlanType()); | 
|---|
|  |  |  | User planLeader = planTypeService.findPlanLeader(planType); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 2: | 
|---|
|  |  |  | case 1: | 
|---|
|  |  |  | dto.setCurr(Boolean.FALSE); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 3: | 
|---|
|  |  |  | 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 4: | 
|---|
|  |  |  | case 3: | 
|---|
|  |  |  | dto.setUserId(planner.getId()); | 
|---|
|  |  |  | dto.setUsername(planner.getNickname()); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | plan.setSettleMsg(JSON.toJSONString(list)); | 
|---|
|  |  |  | // 修改规划单状态 | 
|---|
|  |  |  | plan.setSettle(3);  // 规划员待审 | 
|---|
|  |  |  | 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("审核失败,请联系管理员"); | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new CoolException("审核失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 3: | 
|---|
|  |  |  | case 2: | 
|---|
|  |  |  | User plannerUser = userService.selectById(plan.getPlanner()); | 
|---|
|  |  |  | if (Cools.isEmpty(plannerUser)) { | 
|---|
|  |  |  | 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 3: | 
|---|
|  |  |  | case 2: | 
|---|
|  |  |  | dto.setCurr(Boolean.FALSE); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 4: | 
|---|
|  |  |  | 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 5: | 
|---|
|  |  |  | case 4: | 
|---|
|  |  |  | dto.setUserId(salesman.getId()); | 
|---|
|  |  |  | dto.setUsername(salesman.getNickname()); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | plan.setSettleMsg(JSON.toJSONString(list0)); | 
|---|
|  |  |  | // 修改规划单状态 | 
|---|
|  |  |  | plan.setSettle(4);  // 审批通过 | 
|---|
|  |  |  | plan.setSettle(3);  // 审批通过 | 
|---|
|  |  |  | plan.setUpdateBy(getUserId()); | 
|---|
|  |  |  | plan.setUpdateTime(new Date()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new CoolException("审核失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 4: | 
|---|
|  |  |  | case 3: | 
|---|
|  |  |  | // 业务员 | 
|---|
|  |  |  | User salesman0 = userService.selectById(plan.getUserId()); | 
|---|
|  |  |  | if (!getUserId().equals(salesman0.getId())) { | 
|---|
|  |  |  | 
|---|
|  |  |  | List<SettleDto> list1 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class); | 
|---|
|  |  |  | for (SettleDto dto : list1) { | 
|---|
|  |  |  | switch (dto.getStep()) { | 
|---|
|  |  |  | case 4: | 
|---|
|  |  |  | case 3: | 
|---|
|  |  |  | dto.setCurr(Boolean.TRUE); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 5: | 
|---|
|  |  |  | 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: | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | plan.setSettleMsg(JSON.toJSONString(list1)); | 
|---|
|  |  |  | // 修改规划单状态 | 
|---|
|  |  |  | plan.setSettle(5);  // 审批通过 | 
|---|
|  |  |  | plan.setSettle(4);  // 审批通过 | 
|---|
|  |  |  | plan.setStatus(1);  // 审批通过 | 
|---|
|  |  |  | plan.setUpdateBy(getUserId()); | 
|---|
|  |  |  | plan.setUpdateTime(new Date()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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() != 2) { | 
|---|
|  |  |  | if (plan.getSettle() != 1) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 查找规划组长 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ProcessPermissions processPermissions1 = processPermissionsService.selectOne(new EntityWrapper<ProcessPermissions>().eq("process_memo", 5).eq("process", "1-1"));//2:核价流程 | 
|---|
|  |  |  | User manager1 = userService.selectById(processPermissions1.getUserId());       // 获取核价流程节点1确认人 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ProcessPermissions processPermissions2 = processPermissionsService.selectOne(new EntityWrapper<ProcessPermissions>().eq("process_memo", 5).eq("process", "1-2"));//2:核价流程 | 
|---|
|  |  |  | User manager2 = userService.selectById(processPermissions2.getUserId());       // 获取核价流程节点1确认人 | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | int type =0; | 
|---|
|  |  |  | if (getUserId().equals(manager1.getId())){ | 
|---|
|  |  |  | type=1;//(货架) | 
|---|
|  |  |  | }else if (getUserId().equals(manager2.getId())){ | 
|---|
|  |  |  | type = 2;//(集成) | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | return R.error("你不是核价员,无权接任务"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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) { | 
|---|