Merge remote-tracking branch 'origin/master'
| | |
| | | Assert.isTrue(StrUtil.isNotBlank(req.getLinkPhone()), "联系电话不能为空"); |
| | | OrderConsultOne o = mentalTestOrderBizService.createOrderConsultOne(req); |
| | | try { |
| | | Customer customer =new Customer(); |
| | | BeanUtil.copyProperties(req,customer); |
| | | Customer customer = new Customer(); |
| | | BeanUtil.copyProperties(req, customer); |
| | | LoginUser loginUser = LoginContext.me().getLoginUser(); |
| | | customer.setCustomerId(loginUser.getUserId()); |
| | | customerService.updateById(customer); |
| | | }catch (Exception e){ |
| | | } catch (Exception e) { |
| | | log.info("修改用户信息报错"); |
| | | } |
| | | return new SuccessResponseData(o); |
| | |
| | | } |
| | | |
| | | // 保存1v1性格分析预约,并推送消息给工作人员 |
| | | MentalAppointment mentalAppointment = saveMentalAppointmentPushMessage(o.getStatusFlag(), o); |
| | | MentalAppointment mentalAppointment = saveMentalAppointmentPushMessage(o.getStatusFlag(), o, req.getRealName(), req.getLinkPhone()); |
| | | if (mentalAppointment == null) { |
| | | throw new BusinessException(DefaultBusinessExceptionEnum.MENTAL_APPOINTMENT_NO_WORKER_ERROR); |
| | | } |
| | |
| | | * @param o |
| | | * @return |
| | | */ |
| | | public MentalAppointment saveMentalAppointmentPushMessage(Integer orderConsultOneStatusFlag, OrderConsultOne o) { |
| | | public MentalAppointment saveMentalAppointmentPushMessage(Integer orderConsultOneStatusFlag, OrderConsultOne o, String realName, String linkPhone) { |
| | | // 性格分析预约 |
| | | MentalAppointment mentalAppointment = MentalAppointment.builder() |
| | | .userId(o.getUserId()) |
| | |
| | | .build(); |
| | | |
| | | // 用户信息 |
| | | CustomerInfo customerInfo = customerService.getCustomerInfoById(o.getUserId()); |
| | | mentalAppointment.setUserName(customerInfo.getRealName()); |
| | | mentalAppointment.setPhone(customerInfo.getLinkPhone()); |
| | | //CustomerInfo customerInfo = customerService.getCustomerInfoById(o.getUserId()); |
| | | mentalAppointment.setUserName(realName); |
| | | mentalAppointment.setPhone(linkPhone); |
| | | |
| | | // 分配性格分析师 |
| | | Long consultWorkerId = mentalAppointmentService.assignMentalAppointmentWorkerId(o.getAppointmentDay(), o.getBeginTimePoint(), o.getEndTimePoint()); |
| | |
| | | |
| | | // 获取绑定顾问岗位ID |
| | | String[] bindWorkerPostIds = customerService.getBindWorkerPostIds(workerNo, post11Enum, post21Enum); |
| | | Customer workerByNo = customerService.getOne( |
| | | Wrappers.<Customer>lambdaUpdate().eq(Customer::getWorkerNo, workerNo).last("LIMIT 1") |
| | | ); |
| | | |
| | | LambdaUpdateWrapper<Customer> wrapper = Wrappers.<Customer>lambdaUpdate().eq(Customer::getCustomerId, userId); |
| | | for (String postId : bindWorkerPostIds) { |
| | | if (postId.equals(post11Enum.getCode().toString())) { |
| | | wrapper.set(Customer::getClassWorkerId, userId); |
| | | wrapper.set(Customer::getClassWorkerId, workerByNo.getCustomerId()); |
| | | } else if (postId.equals(post21Enum.getCode().toString())) { |
| | | wrapper.set(Customer::getConsultWorkerId, userId); |
| | | wrapper.set(Customer::getConsultWorkerId, workerByNo.getCustomerId()); |
| | | } |
| | | } |
| | | |