You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
70 lines
1.9 KiB
70 lines
1.9 KiB
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Libs\AlipayF2F;
|
|
use App\Models\Recharge;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class SyncAlipayRechargeState extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'sync-recharge-pay-state:alipay';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'sync alipay recharge pay state';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function handle()
|
|
{
|
|
$threshold = 5;
|
|
$offset_seconds = 40; //支付发起后多少秒开始轮询
|
|
$due_minutes = 10; //支付发起后第一次开始轮询的时间往后延迟若干分钟后不再轮询
|
|
$last_id = cache("last_sync_alipay_recharge_id", 0);
|
|
|
|
DB::enableQueryLog();
|
|
$recharges = (new Recharge())
|
|
->where("id", ">", $last_id)
|
|
->whereNull("paid_at")
|
|
->where("payment", "alipay")
|
|
->whereRaw("(" . time() . " between (UNIX_TIMESTAMP(`created_at`) + {$offset_seconds}) and (UNIX_TIMESTAMP(`created_at`) + " . ($due_minutes * 60) . " + {$offset_seconds}))")
|
|
->limit($threshold)
|
|
->get();
|
|
if (!$recharges->count()) {
|
|
cache(['last_sync_alipay_recharge_id' => null], now()->addSeconds(90));
|
|
echo "nothing";
|
|
return;
|
|
}
|
|
|
|
foreach ($recharges as $recharge) {
|
|
$result = (new AlipayF2F())->manualQuery($recharge);
|
|
dump($result);
|
|
}
|
|
|
|
cache(['last_sync_alipay_recharge_id' => $recharges->last()->id], now()->addSeconds(90));
|
|
}
|
|
}
|