Leadfyy.co
/
lanzu_api_2021-12-26
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

余额加锁

master
weigang 5 years ago
parent
87453f5e4f
commit
5616483721
1 changed files with 14 additions and 14 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 28
      app/Service/v3/Implementations/FinancialRecordService.php

28
app/Service/v3/Implementations/FinancialRecordService.php
View File

@ -40,7 +40,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
}
// 获取当前用户的流水前余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $record['user_type'],
'source_id' => $user_id
]);
@ -78,7 +78,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护社区服务点余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -103,7 +103,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护社区服务点余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -127,7 +127,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护社区服务点余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -152,7 +152,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -176,7 +176,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -253,7 +253,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -277,7 +277,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -385,7 +385,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
{
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -424,7 +424,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -449,7 +449,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -474,7 +474,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -499,7 +499,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);
@ -524,7 +524,7 @@ class FinancialRecordService implements FinancialRecordServiceInterface
$this->recordAll($user_id, $source_id, $money, $user_type, $source_type, $money_type, $desc, $comment);
// 维护余额
$balance = UserBalance::query()->firstOrNew([
$balance = UserBalance::query()->lockForUpdate()->firstOrNew([
'user_type' => $user_type,
'source_id' => $user_id
]);

Write Preview
Loading…
Cancel
Save