From 94e9dc3adb80baf6e1d7d56e54a93917996bc339 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期日, 28 四月 2024 11:21:49 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 rest/src/main/java/cn/stylefeng/rest/modular/order/service/MentalTestOrderBizService.java |   24 +++++++++++++++++++-----
 1 files changed, 19 insertions(+), 5 deletions(-)

diff --git a/rest/src/main/java/cn/stylefeng/rest/modular/order/service/MentalTestOrderBizService.java b/rest/src/main/java/cn/stylefeng/rest/modular/order/service/MentalTestOrderBizService.java
index 513521e..c709ab4 100644
--- a/rest/src/main/java/cn/stylefeng/rest/modular/order/service/MentalTestOrderBizService.java
+++ b/rest/src/main/java/cn/stylefeng/rest/modular/order/service/MentalTestOrderBizService.java
@@ -102,6 +102,20 @@
 
     @Transactional(rollbackFor = Exception.class)
     public OrderConsultOne createOrderConsultOne(CreateOrderConsultOneRequest req) {
+        // 生成了订单但未支付
+        OrderConsultOne oo = orderConsultOneService.getOne(
+                Wrappers.<OrderConsultOne>lambdaQuery()
+                        .eq(OrderConsultOne::getUserId, req.getUserId())
+                        .eq(OrderConsultOne::getMentalTestRecordId, req.getMentalTestRecordId())
+                        .eq(OrderConsultOne::getStatusFlag, OrderStatusFlagEnum.WAIT_PAY.getCode())
+                        .eq(OrderConsultOne::getIsDelete, YesOrNotEnum.N.getCode())
+                        .last("LIMIT 1")
+        );
+        if (oo != null) {
+            // 可以提示用户
+            return oo;
+        }
+
         // 心理测试记录
         MentalTestRecord mentalTestRecord = mentalTestRecordService.getById(req.getMentalTestRecordId());
         Assert.notNull(mentalTestRecord, "心理测试记录不存在");
@@ -151,7 +165,7 @@
         }
 
         // 保存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);
         }
@@ -183,7 +197,7 @@
      * @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())
@@ -193,9 +207,9 @@
                 .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());

--
Gitblit v1.7.1