新增取消订单恢复优惠卷，新增获取订单支付数据接口

app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php

@@ -5,12 +5,15 @@ declare(strict_types=1);
 namespace App\Amqp\Consumer;
 
 use App\Model\OrderInquiry;
+use App\Model\OrderInquiryCoupon;
+use App\Model\UserCoupon;
 use App\Utils\Log;
 use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
 use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
+use Hyperf\DbConnection\Db;
 use Hyperf\Snowflake\IdGeneratorInterface;
 use PhpAmqpLib\Message\AMQPMessage;
 use Hyperf\Amqp\Message\Type;
@@ -38,30 +41,36 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
     {
         Log::getInstance()->error("开始执行 取消未支付订单 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
 
+        Db::beginTransaction();
+
         try {
             // 获取订单数据
             $params = array();
             $params['order_inquiry_id'] = $data['order_inquiry_id'];
             $order_inquiry = OrderInquiry::getOne($params);
             if (empty($order_inquiry)) {
+                Db::rollBack();
                 Log::getInstance()->error("队列执行失败原因：未查询到对应订单数据");
                 return Result::DROP;// 销毁
             }
 
             // 检测订单状态
             if ($order_inquiry['inquiry_status'] != 1) {
+                Db::rollBack();
                 // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
                 Log::getInstance()->error("队列执行失败原因：订单状态为" . $order_inquiry['inquiry_status'] . "无法执行");
                 return Result::DROP;// 销毁
             }
 
             if (!in_array($order_inquiry['inquiry_refund_status'],[0,4,5])) {
+                Db::rollBack();
                 // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
                 Log::getInstance()->error("队列执行失败原因：订单正在退款中");
                 return Result::DROP;// 销毁
             }
 
             if ($order_inquiry['inquiry_pay_status'] == 2) {
+                Db::rollBack();
                 // 支付状态（1:未支付 2:已支付 3:支付中 4:支付失败 5:支付超时 6:支付关闭 7:已撤销 8:转入退款）
                 Log::getInstance()->error("队列执行失败原因：订单已支付");
                 return Result::DROP;// 销毁
@@ -69,6 +78,7 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
 
             // 检测订单删除状态
             if ($order_inquiry['is_delete'] == 1) {
+                Db::rollBack();
                 // 删除状态（0:否 1:是）
                 Log::getInstance()->error("取消未支付订单：订单已被删除");
                 return Result::ACK;// 销毁
@@ -86,9 +96,29 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
             $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
             OrderInquiry::edit($params,$data);
 
+            // 处理订单优惠卷
+            if (!empty($order_inquiry['coupon_amount_total']) && $order_inquiry['coupon_amount_total'] > 0){
+                // 获取用户优惠卷信息
+                $params = array();
+                $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
+                $order_inquiry_coupon = OrderInquiryCoupon::getOne($params);
+                if (!empty($order_inquiry_coupon)){
+                    // 恢复优惠卷
+                    $data = array();
+                    $data['user_coupon_status'] = 0;
+                    $data['coupon_use_date'] = date('Y-m-d H:i:s',time());
+
+                    $params = array();
+                    $params['user_coupon_id'] = $order_inquiry_coupon['user_coupon_id'];
+                    UserCoupon::edit($params,$data);
+                }
+            }
+
+            Db::commit();
             Log::getInstance()->error("取消未支付订单 队列执行成功");
             return Result::ACK;
         } catch (\Exception $e) {
+            Db::rollBack();
             Log::getInstance()->error("队列执行失败原因：" . $e->getMessage());
             return Result::REQUEUE; // 重回队列
         }