tom/fuc-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
hellcat 2025-10-15 13:52:05 +08:00
parent b73305311b
commit 9d0c32cdfd
1 changed files with 18 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/Services/Cron.php
View File

@ -823,7 +823,7 @@ final class Cron
$iPayClass = $_ENV["user_payClass"]; $iPayClass = $_ENV["user_payClass"];
$pending_payment_orders = (new Order())->where('status', 'payment_pending')->get(); // 这里还是无脑检索order了，但是现在order表可以只保留一年内数据，问题不大 $pending_payment_orders = (new Order())->where('status', 'payment_pending')->get(); // 这里还是无脑检索order了，但是现在order表可以只保留一年内数据，问题不大
// var_dump($pending_payment_orders);
$aUserInQueue = []; // 用户可能在5分钟之内多次下单，但一次只处理一个，坚固 $aUserInQueue = []; // 用户可能在5分钟之内多次下单，但一次只处理一个，坚固
foreach ($pending_payment_orders as $oOrder) { foreach ($pending_payment_orders as $oOrder) {
@ -831,28 +831,25 @@ final class Cron
continue; continue;
} }
$invoice = (new Invoice())->where('order_id', $oOrder->id)->first();
if ($invoice === null) {
continue;
}
DB::beginTransaction();
//var_dump($aUserInQueue);
try { try {
$invoice = (new Invoice())->where('order_id', $oOrder->id)->first();
if ($invoice === null) {
continue;
}
DB::beginTransaction();
// var_dump($invoice->id);
// var_dump($invoice->status);
// 付款完成后 // 付款完成后
if (in_array($invoice->status, ['paid_gateway', 'paid_balance', 'paid_admin'])) { if (in_array($invoice->status, ['paid_gateway', 'paid_balance', 'paid_admin'])) {
// var_dump(111);
$oUser = User::find($invoice->user_id); $oUser = User::find($invoice->user_id);
$iPayAmount = $invoice->price - $invoice->money_use; $iPayAmount = $invoice->price - $invoice->money_use;
if ($oOrder->product_code == "code") { // 钱包充值 if ($oOrder->product_code == "code") { // 钱包充值
// var_dump(222);
$iUserMoneyOld = $oUser->money; $iUserMoneyOld = $oUser->money;
$iUserMoneyNew = $oUser->money + $invoice->price; $iUserMoneyNew = $oUser->money + $invoice->price;
$iAmount = $invoice->price; $iAmount = $invoice->price;
@ -959,10 +956,10 @@ final class Cron
foreach ($oUserList as $oUser) { foreach ($oUserList as $oUser) {
DB::beginTransaction();
try { try {
DB::beginTransaction();
// $oUser->isPayClass = $oUser->class >= $iPayClass ? true : false; // $oUser->isPayClass = $oUser->class >= $iPayClass ? true : false;
if (strtotime($oUser->class_expire) < time()) { // 时间到期 if (strtotime($oUser->class_expire) < time()) { // 时间到期
@ -1014,10 +1011,10 @@ final class Cron
continue; // 没有待激活就直接桡过，而不是报错 continue; // 没有待激活就直接桡过，而不是报错
} }
DB::beginTransaction();
try { try {
DB::beginTransaction();
$oProduct = Product::where("code", $oPlanPending->product_code)->first(); // * 商品表 $oProduct = Product::where("code", $oPlanPending->product_code)->first(); // * 商品表
// 没有对应商品时 // 没有对应商品时
@ -1129,10 +1126,10 @@ final class Cron
continue; continue;
} }
DB::beginTransaction();
try { try {
DB::beginTransaction();
//// 开始自动续订 //// 开始自动续订
$iUserMoneyOld = $oUser->money; $iUserMoneyOld = $oUser->money;
$iUserMoneyNew = $oUser->money - $oPlanActivated->user_price; $iUserMoneyNew = $oUser->money - $oPlanActivated->user_price;
@ -1233,10 +1230,10 @@ final class Cron
foreach ($oPlanExpireQueueList as $oPlanExpireQueue) foreach ($oPlanExpireQueueList as $oPlanExpireQueue)
{ {
DB::beginTransaction();
try { try {
DB::beginTransaction();
$oUser = User::where("id", $oPlanExpireQueue->user_id)->first(); $oUser = User::where("id", $oPlanExpireQueue->user_id)->first();
//// activated转移到expired //// activated转移到expired