qianggou
/
admin
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

【修复】并发锁处理

This commit is contained in:
liqianjin 2023-07-14 14:48:51 +08:00
parent 039839dad7
commit a1ada10b20
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
addon/futures/model/Futures.php
View File

@ -276,10 +276,10 @@ class Futures extends BaseModel
*/
public function orderCreate($id, $order_id, $member_id)
{
if(!Cache::store('redis_concurrent')->handler()->setnx('addon_futures_'.$id,'1')){
if(!Cache::store('redis_concurrent')->handler()->setnx('addon_futures_setnx_'.$id,'1')){
return $this->error('', '你太慢了已被抢购');
}
Cache::store('redis_concurrent')->handler()->expire('addon_futures_'.$id,30);
Cache::store('redis_concurrent')->handler()->expire('addon_futures_setnx_'.$id,30);
$date = model('futures')->getInfo([['id', '=', $id]]);
if (empty($date) || ($date['status'] !== 2 && $date['status'] !== 7)) {
@ -301,7 +301,7 @@ class Futures extends BaseModel
'total_business_num' => Db::raw('total_business_num +1'),
]);
(new Message())->addMessage($date['site_id'], '订单创建', 1, $member_id, $id);
Cache::store('redis_concurrent')->handler()->del('addon_futures_'.$id);
Cache::store('redis_concurrent')->handler()->del('addon_futures_setnx_'.$id);
return $this->success();
}