mirrors/buildadmin
1
0
Fork 0
mirror of https://gitee.com/wonderful-code/buildadmin synced 2024-11-21 22:55:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor:会员余额和会员积分模型添加悲观锁 close #I7NGXI

Browse Source
This commit is contained in:
妙码生花 2023-07-24 20:36:31 +08:00
parent 13d5ef3c3e
commit 7b213232e2
2 changed files with 10 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
app/admin/model/UserMoneyLog.php
View File

@ -9,6 +9,8 @@ use think\model\relation\BelongsTo;
/**
* UserMoneyLog 模型
* 1. 创建余额日志自动完成会员余额的添加
* 2. 创建余额日志时，请开启事务
*/
class UserMoneyLog extends model
{
@ -21,7 +23,7 @@ class UserMoneyLog extends model
*/
public static function onBeforeInsert($model)
{
$user = User::where('id', $model->user_id)->find();
$user = User::where('id', $model->user_id)->lock(true)->find();
if (!$user) {
throw new Exception("The user can't find it");
}
@ -29,22 +31,11 @@ class UserMoneyLog extends model
throw new Exception("Change note cannot be blank");
}
$model->before = $user->money;
$model->after = $user->money + $model->money;
}
/**
* 入库后
* @throws Throwable
*/
public static function onAfterInsert($model)
{
$user = User::where('id', $model->user_id)->find();
if (!$user) {
$model->delete();
throw new Exception("The user can't find it");
}
$user->money += $model->money;
$user->save();
$model->after = $user->money;
}
public static function onBeforeDelete(): bool

19
app/admin/model/UserScoreLog.php
View File

@ -9,6 +9,8 @@ use think\model\relation\BelongsTo;
/**
* UserScoreLog 模型
* 1. 创建积分日志自动完成会员积分的添加
* 2. 创建积分日志时，请开启事务
*/
class UserScoreLog extends model
{
@ -21,7 +23,7 @@ class UserScoreLog extends model
*/
public static function onBeforeInsert($model)
{
$user = User::where('id', $model->user_id)->find();
$user = User::where('id', $model->user_id)->lock(true)->find();
if (!$user) {
throw new Exception("The user can't find it");
}
@ -29,22 +31,11 @@ class UserScoreLog extends model
throw new Exception("Change note cannot be blank");
}
$model->before = $user->score;
$model->after = $user->score + $model->score;
}
/**
* 入库后
* @throws Throwable
*/
public static function onAfterInsert($model)
{
$user = User::where('id', $model->user_id)->find();
if (!$user) {
$model->delete();
throw new Exception("The user can't find it");
}
$user->score += $model->score;
$user->save();
$model->after = $user->score;
}
public static function onBeforeDelete(): bool