tcjlj/Xboard
1
0
Fork 0
mirror of https://github.com/cedar2025/Xboard.git synced 2025-02-08 18:08:13 -05:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix: 修复创建工单中的事务安全

Browse Source
This commit is contained in:
xboard 2023-12-13 03:00:43 +08:00
parent e16618142a
commit f812e5f239
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
app/Http/Controllers/V1/User/TicketController.php
View File

@ -44,7 +44,7 @@ class TicketController extends Controller
try{ try{
DB::beginTransaction(); DB::beginTransaction();
if ((int)Ticket::where('status', 0)->where('user_id', $request->user['id'])->lockForUpdate()->count()) { if ((int)Ticket::where('status', 0)->where('user_id', $request->user['id'])->lockForUpdate()->count()) {
return $this->fail([400, __('There are other unresolved tickets')]); throw new \Exception(__('There are other unresolved tickets'));
} }
$ticket = Ticket::create(array_merge($request->only([ $ticket = Ticket::create(array_merge($request->only([
'subject', 'subject',
@ -53,7 +53,7 @@ class TicketController extends Controller
'user_id' => $request->user['id'] 'user_id' => $request->user['id']
])); ]));
if (!$ticket) { if (!$ticket) {
return $this->fail([400, __('Failed to open ticket')]); throw new \Exception(__('There are other unresolved tickets'));
} }
$ticketMessage = TicketMessage::create([ $ticketMessage = TicketMessage::create([
'user_id' => $request->user['id'], 'user_id' => $request->user['id'],
@ -61,15 +61,17 @@ class TicketController extends Controller
'message' => $request->input('message') 'message' => $request->input('message')
]); ]);
if (!$ticketMessage) { if (!$ticketMessage) {
return $this->fail([400, __('Failed to open ticket')]); throw new \Exception(__('Failed to open ticket'));
} }
DB::commit(); DB::commit();
}catch(\Exception $e){
DB::rollBack();
throw $e;
}
$this->sendNotify($ticket, $request->input('message'), $request->user['id']); $this->sendNotify($ticket, $request->input('message'), $request->user['id']);
return $this->success(true); return $this->success(true);
}catch(\Exception $e){
DB::rollBack();
\Log::error($e);
return $this->fail([400, $e->getMessage()]);
}
} }
public function reply(Request $request) public function reply(Request $request)