取消检测订单,取消订单订阅消息推送

app/Controller/PatientOrderController.php

@@ -274,4 +274,17 @@ class PatientOrderController extends AbstractController
         $data = $PatientOrderService->deletePatientDetectionOrder();
         return $this->response->json($data);
     }
+
+    /**
+     * 取消检测订单
+     * @return ResponseInterface
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
+    public function putCancelPatientDetectionOrder(): ResponseInterface
+    {
+        $PatientOrderService = new PatientOrderService();
+        $data = $PatientOrderService->putCancelPatientDetectionOrder();
+        return $this->response->json($data);
+    }
 }

app/Services/DetectionService.php

@@ -4,6 +4,7 @@ namespace App\Services;
 
 use App\Amqp\Producer\CancelUnpayOrdersDelayDirectProducer;
 use App\Constants\HttpEnumCode;
+use App\Exception\BusinessException;
 use App\Model\Area;
 use App\Model\BasicCompany;
 use App\Model\BasicNation;
@@ -12,10 +13,12 @@ use App\Model\DetectionProjectPurpose;
 use App\Model\DiseaseClassDetection;
 use App\Model\OrderDetection;
 use App\Model\OrderDetectionCase;
+use App\Model\OrderDetectionRefund;
 use App\Model\PatientFamily;
 use App\Model\UserDoctor;
 use App\Model\UserLocation;
 use App\Utils\Log;
+use Extend\Wechat\WechatPay;
 use Hyperf\Amqp\Producer;
 use Hyperf\DbConnection\Db;
 use Hyperf\Snowflake\IdGeneratorInterface;
@@ -242,7 +245,7 @@ class DetectionService extends BaseService
                     $doctor['hospital_name'] = $value['Hospital']['hospital_name'];
                 }
 
-//                unset($value['Hospital']);
+                unset($value['Hospital']);
 
                 $value['avatar'] = addAliyunOssWebsite($value['avatar']);
             }
@@ -547,4 +550,112 @@ class DetectionService extends BaseService
 
         return $result;
     }
+
+    /**
+     * 检测订单退款接口
+     */
+    public function detectionRefund(string $order_detection_id, string $refund_reason)
+    {
+        // 获取订单数据
+        $params = array();
+        $params['order_detection_id'] = $order_detection_id;
+        $order_detection = OrderDetection::getOne($params);
+        if (empty($order_detection)) {
+            throw new BusinessException("订单数据为空");
+        }
+
+        // 检测问诊订单状态
+        if (!in_array($order_detection['detection_status'], [2, 5])) {
+            // 检测订单状态(1:待支付 2:待绑定 3:检测中 4:检测完成 5:已取消)
+            throw new BusinessException("订单状态错误");
+        }
+
+        // 检测订单退款状态
+        if (in_array($order_detection['detection_refund_status'], [2, 3, 5,6])) {
+            // 检测订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭 6:退款异常）
+            throw new BusinessException("订单退款状态错误");
+        }
+
+        // 检测支付状态
+        if ($order_detection['detection_pay_status'] != 2) {
+            // 支付状态（1:未支付 2:已支付 3:支付中 4:支付失败 5:支付超时 6:支付关闭 7:已撤销 8:转入退款）
+            throw new BusinessException("订单支付状态错误");
+        }
+
+        // 系统退款编号
+        $generator = $this->container->get(IdGeneratorInterface::class);
+        $detection_refund_no = $generator->generate();
+
+        // 检测订单金额
+        if ($order_detection['payment_amount_total'] > 0){
+            // 发起退款
+            $WechatPay = new WechatPay(1, 1);
+
+            $options = array();
+            $options['transaction_id'] = $order_detection['escrow_trade_no'];
+            $options['out_refund_no'] = (string)$detection_refund_no;
+            $options['reason'] = $refund_reason;
+            $options['amount'] = [
+                'refund' => (int)round($order_detection['payment_amount_total'] * 100),
+                'total' => (int)round($order_detection['payment_amount_total'] * 100),
+                'currency' => "CNY",
+            ];
+
+            $result = $WechatPay->refund($options);
+
+            // 处理订单退款状态
+            // 检测订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
+            $success_time = "";
+            if ($result['status'] == "SUCCESS") {
+                // 退款成功
+                $detection_refund_status = 3;
+                $success_time = $result['success_time'];
+            } elseif ($result['status'] == "CLOSED") {
+                // 退款关闭
+                $detection_refund_status = 5;
+            } elseif ($result['status'] == "PROCESSING") {
+                // 退款处理中
+                $detection_refund_status = 2;
+            } elseif ($result['status'] == "ABNORMAL") {
+                // 退款异常,此情况不处理，进行短信通知
+                throw new BusinessException("订单退款状态异常");
+            } else {
+                throw new BusinessException("订单退款状态错误");
+            }
+
+            $refund_id = $result['refund_id'];
+        }else{
+            $detection_refund_status = 3;
+            $success_time = date('Y-m-d H:i:s',time());
+            $refund_id = $generator->generate();
+        }
+
+        // 新增退款表
+        $data = array();
+        $data['patient_id'] = $order_detection['patient_id'];
+        $data['order_detection_id'] = $order_detection['order_detection_id'];
+        $data['detection_no'] = $order_detection['detection_no'];
+        $data['detection_refund_no'] = $detection_refund_no;
+        $data['refund_id'] = $refund_id;
+        $data['detection_refund_status'] = $detection_refund_status;
+        $data['refund_total'] = $order_detection['payment_amount_total'];
+        $data['refund_reason'] = $refund_reason;
+
+        if ($detection_refund_status == 3 && !empty($success_time)) {
+            $data['success_time'] = date("Y-m-d H:i:s", strtotime($success_time)); // 退款成功时间
+        }
+
+        $order_detection_refund = OrderDetectionRefund::add($data);
+        if (empty($order_detection_refund)) {
+            throw new BusinessException("添加退款表失败");
+        }
+
+        // 修改问诊订单表状态
+        $data = array();
+        $data['detection_refund_status'] = $detection_refund_status;
+
+        $params = array();
+        $params['order_detection_id'] = $order_detection['order_detection_id'];
+        OrderDetection::editOrderDetection($params, $data);
+    }
 }

app/Services/MessagePush.php

@@ -7,7 +7,9 @@ use App\Amqp\Producer\SendStationMessageProducer;
 use App\Amqp\Producer\SendSubMessageProducer;
 use App\Constants\HttpEnumCode;
 use App\Exception\BusinessException;
+use App\Model\DetectionProject;
 use App\Model\DoctorWithdrawal;
+use App\Model\OrderDetection;
 use App\Model\OrderInquiry;
 use App\Model\OrderInquiryCase;
 use App\Model\OrderInquiryCoupon;
@@ -2074,6 +2076,7 @@ class MessagePush extends BaseService
             $user_doctor = UserDoctor::getOne($params);
             if (empty($user_doctor)) {
                 Log::getInstance("MessagePush")->error("错误：医生数据为空");
+                return;
             }
 
             // 获取问诊订单关联病例
@@ -2108,6 +2111,7 @@ class MessagePush extends BaseService
             $result = $producer->produce($message);
             if (!$result) {
                 Log::getInstance("MessagePush")->error("错误：加入推送队列失败" . json_encode($data, JSON_UNESCAPED_UNICODE));
+                return;
             }
 
             // 问诊内容-病情主诉
@@ -2226,4 +2230,60 @@ class MessagePush extends BaseService
             Log::getInstance("MessagePush")->error("错误：加入推送队列失败" . $e->getMessage());
         }
     }
+
+    /**
+     * 患者-订单取消成功通知
+     * 订阅
+     * @param string $order_detection_id
+     * @return void
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
+    public function patientCancelOrderSuccess(string $order_detection_id): void
+    {
+        try {
+            // 获取检测订单
+            $params = array();
+            $params['order_detection_id'] = $order_detection_id;
+            $order_detection = OrderDetection::getOne($params);
+            if (empty($order_detection)) {
+                Log::getInstance("MessagePush")->error("错误：加入推送队列失败,无检测订单数据");
+                return;
+            }
+
+            // 获取检测项目
+            $params = array();
+            $params['detection_project_id'] = $order_detection['detection_project_id'];
+            $detection_project = DetectionProject::getOne($params);
+            if (empty($detection_project)){
+                Log::getInstance("MessagePush")->error("错误：加入推送队列失败,检测项目错误");
+                return;
+            }
+
+            $sub_data = array();
+            $sub_data['push_user_id'] = $this->user['user_id'];
+            $sub_data['wx_template_id'] = "5aJSrO8SU5rxqdB99zzl4rMVgcOTjt5mQh56cpZI1Hg";//咨询提醒
+            $sub_data['params']['page'] = "/pages/checkOrderDetail/checkOrderDetail?order_detection_id=";
+            $sub_data['params']['data'] = [
+                "thing1" => $order_detection['patient_name'],// 就诊人
+                "thing7" => (string)$detection_project['detection_project_name'],// 服务项目
+                "time6" => date('Y年m月d日 H:i'),// 取消时间
+                "amount8" => $order_detection['payment_amount_total'],// 退款金额
+                "thing5" => "订单取消成功，支付金额将立即原路退回。",// 温馨提示
+            ];
+
+            $data = array();
+            $data['sub_data'] = $sub_data;
+            $data['sms_data'] = [];
+
+            $message = new SendSubMessageProducer($data);
+            $producer = ApplicationContext::getContainer()->get(Producer::class);
+            $result = $producer->produce($message);
+            if (!$result) {
+                Log::getInstance("MessagePush")->error("错误：加入推送队列失败" . json_encode($data, JSON_UNESCAPED_UNICODE));
+            }
+        } catch (\Exception $e) {
+            Log::getInstance("MessagePush")->error("错误：加入推送队列失败" . $e->getMessage());
+        }
+    }
 }

app/Services/PatientOrderService.php

@@ -1780,6 +1780,96 @@ class PatientOrderService extends BaseService
         return success();
     }
 
+    /**
+     * 取消检测订单
+     * @return array
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
+    public function putCancelPatientDetectionOrder(): array
+    {
+        $user_info = $this->request->getAttribute("userInfo") ?? [];
+
+        $order_detection_id = $this->request->route('order_detection_id');
+
+        // 获取订单数据
+        $params = array();
+        $params['patient_id'] = $user_info['client_user_id'];
+        $params['order_detection_id'] = $order_detection_id;
+        $params['is_delete'] = 0;
+        $order_detection = OrderDetection::getOne($params);
+        if (empty($order_detection)) {
+            return fail();
+        }
+
+        $redis = $this->container->get(Redis::class);
+        $redis_key = "order_detection_lock_" . $order_detection_id;
+        $redis_lock = $redis->setnx($redis_key, 1);
+        // 设置过期时间
+        $redis->expire($redis_key, 3);
+        if (!$redis_lock) {
+            // 设置失败，表示已经设置该值
+            return fail(HttpEnumCode::HTTP_SUCCESS, "请您稍后重试");
+        }
+
+        // 检测订单状态
+        if (!in_array($order_detection['detection_status'], [2])) {
+            // 检测订单状态(1:待支付 2:待绑定 3:检测中 4:检测完成 5:已取消)
+            return fail(HttpEnumCode::HTTP_ERROR, "订单无法取消");
+        }
+
+        if ($order_detection['detection_refund_status'] == 1) {
+            // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
+            return fail(HttpEnumCode::HTTP_ERROR, "订单申请退款中,请您稍后取消");
+        }
+
+        if ($order_detection['detection_refund_status'] == 2) {
+            // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
+            return fail(HttpEnumCode::HTTP_ERROR, "订单正在退款中,请您稍后取消");
+        }
+
+        Db::beginTransaction();
+        try {
+            // 退款成功
+            // 修改问诊订单为取消
+            $data = array();
+            $data['detection_status'] = 5;
+            $data['cancel_time'] = date("Y-m-d H:i:s", time());
+            $data['cancel_reason'] = 2; // 取消订单原因（1:主动取消 2:客服取消 3:支付超时）
+            $data['updated_at'] = date("Y-m-d H:i:s", time());
+
+            $params = array();
+            $params['order_detection_id'] = $order_detection['order_detection_id'];
+            OrderDetection::editOrderDetection($params, $data);
+
+            // 检测支付状态，判断是否需要退款处理
+            if ($order_detection['detection_pay_status'] == 2 && $order_detection['detection_refund_status'] != 3) {
+                // 需退款
+                $detectionService = new DetectionService();
+                $detectionService->detectionRefund($order_detection['order_detection_id'], "取消检测");
+            }
+
+            // 删除锁
+            $redis->del($redis_key);
+
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollBack();
+            return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
+        }
+
+        try {
+            if (!empty($order_inquiry['doctor_id'])) {
+                // 推送患者-订单取消成功通知
+                $MessagePush = new MessagePush($order_detection['user_id'], $order_inquiry['order_inquiry_id']);
+                $MessagePush->patientCancelOrderSuccess($order_detection['order_detection_id']);
+            }
+        } catch (\Exception $e) {
+            return success();
+        }
+
+        return success();
+    }
 
     /**
      * 获取患者未完成订单

config/routes.php

@@ -269,7 +269,11 @@ Router::addGroup('/patient', function () {
     // 检测
     Router::addGroup('/detection', function () {
         // 创建检测订单
-        Router::post('', [DetectionController::class, 'addDetectionOrder']);
+        Router::post('', [DetectionController::class, 'addDetectionOrder'],
+            [
+                'middleware' => [LockRequestMiddleware::class] // 锁定重复请求
+            ]
+        );
 
         // 获取检测机构合作医生列表
         Router::get('/doctor', [DetectionController::class, 'getDetectionDoctorList']);