云选联盟订单支付40分钟后回传 调试

app/Console/Commands/Order/SyncYunXuanOrder.php

@@ -50,7 +50,6 @@ class SyncYunXuanOrder extends Command
                         'start_time' => intval($startTime.'000'),
                         'end_time' => intval($endTime.'000'),
                         'share_id' => $config['share_id'],
-//                        'tx_cps_id' => "",
                     ]
                 ], 256);
                 $response = YXRequestService::sendRequestWithAppAuth($appKey, $appSecret, $method, $requestUrl, $contentType, $acceptHeader, $reqBody);
@@ -85,9 +84,9 @@ class SyncYunXuanOrder extends Command
                 'trace' => $e->getTraceAsString()
             ], 'YunXuanOrderList-Exception');
 
-//            EmailQueue::rPush('云选联盟平台订单获取过程发生异常', json_encode([
-//                'message' => $e->getMessage()
-//            ], 256), ['song.shen@kuxuan-inc.com'], '猎羽');
+            EmailQueue::rPush('云选联盟平台订单获取过程发生异常', json_encode([
+                'message' => $e->getMessage()
+            ], 256), ['song.shen@kuxuan-inc.com'], '猎羽');
         }
 
         return true;

app/Models/Tencent/YxOrder.php

@@ -2,6 +2,7 @@
 
 namespace App\Models\Tencent;
 
+use App\Log;
 use App\Models\TencentAdAuth;
 use Illuminate\Database\Eloquent\Model;
 
@@ -103,6 +104,16 @@ class YxOrder extends Model
             TencentAdAuth::intoActionAddListSecond($res->toArray());
         }
 
+        if (
+//            $res->payment_amount > 0 &&
+            $res->order_status == 1 &&
+            (isset($res->ad_report_order_status) && $res->ad_report_order_status != 0)// 已经进行过回传处理的订单此项数据会发生变化
+            && ($res->payed_time <= date('Y-m-d H:i:s', strtotime('-40 minutes')))) {# 支付成功40分钟后再进行回传，尽量避免一些由于用户取消支付导致回传数据
+            # 数据回传
+//            TencentAdAuth::intoActionAddListSecond($res->toArray());
+            Log::logInfo('订单回传入队列记录', [$res], 'YXorder');
+        }
+
         return $res->id ?? 0;
     }
 }