333

app/Jobs/PaymentJob.php

@@ -10,6 +10,8 @@ use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Log;
+use App\Services\PaymentOrderService;
+use Google\Service\Adsense\Payment;
 
 class PaymentJob implements ShouldQueue
 {
@@ -46,6 +48,7 @@ class PaymentJob implements ShouldQueue
         try {
             Log::error('🚀 开始执行更新订单状态任务: ' . now());
            
+            PaymentOrderService::syncPayOrder();
 
             // 重要：使用类名而不是 self()，避免递归
             PaymentJob::dispatch()->delay(now()->addSeconds(15));

app/Services/PaymentOrderService.php

@@ -602,4 +602,25 @@ class PaymentOrderService extends BaseService
 
     }
 
+
+    public static function syncPayOrder()
+    {
+        $list = self::model()::where(['state' => 0])->take(10)->get();
+        foreach($list->toArray() as $k => $v){
+             $item= [];
+            if($v['status'] == self::STATUS_SUCCESS){
+                $item['state'] = 1;
+                self::model()::where(['id'=>$v['id']])->update($item);
+            }else{
+                $ret = SanJinService::queryOrder($v['order_no']);
+                if($ret['code'] == 0){
+                
+                    $item['state'] = $ret['data']['state'];
+                    self::model()::where(['id'=>$v['id']])->update($item);
+                }
+            }
+            
+        }
+    }
+
 }