wesmiler

app/Services/LiveService.php

@@ -702,6 +702,7 @@ class LiveService extends BaseService
         if(!$orderId = RewardOrderModel::insertGetId($order)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'创建订单失败'], 600);
             return false;
         }
 
@@ -710,6 +711,7 @@ class LiveService extends BaseService
         if(!MemberModel::where(['id'=> $userId,'mark'=>1])->update($updateData)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'账户扣款失败'], 600);
             return false;
         }
 
@@ -734,6 +736,7 @@ class LiveService extends BaseService
         if(!AccountLogModel::insertGetId($log)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'账户明细处理失败'], 600);
             return false;
         }
 
@@ -742,6 +745,7 @@ class LiveService extends BaseService
         if(!MemberModel::where(['id'=> $liveUserId,'mark'=>1])->update($updateData)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'打赏进账处理失败'], 600);
             return false;
         }
 
@@ -766,6 +770,7 @@ class LiveService extends BaseService
         if(!AccountLogModel::insertGetId($log)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'打赏进账明细处理失败'], 600);
             return false;
         }
 
@@ -785,6 +790,7 @@ class LiveService extends BaseService
             if(!VideoCollectModel::insertGetId($data)){
                 DB::rollBack();
                 $this->error = 2305;
+                RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'更新打赏统计失败'], 600);
                 return false;
             }
             RedisService::set("caches:videos:collect:temp_{$userId}_{$liveId}_1_2", $data, rand(10,30));
@@ -796,6 +802,7 @@ class LiveService extends BaseService
         else if (!VideoCollectModel::where(['user_id'=> $userId,'type'=>1,'source_type'=>2, 'collect_id'=>$liveId])->update(['reward_total'=> DB::raw("reward_total + {$money}"),'update_time'=>time()])){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'更新打赏统计失败1'], 600);
             return false;
         }
 
@@ -808,6 +815,7 @@ class LiveService extends BaseService
         if(!$this->model->where(['id'=> $liveId])->update($updateData)){
             DB::rollBack();
             $this->error = 2305;
+            RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'更新打赏统计失败2'], 600);
             return false;
         }
 
@@ -822,6 +830,7 @@ class LiveService extends BaseService
             if(!MemberModel::where(['id'=> $bonusUserId,'mark'=>1])->update($updateData)){
                 DB::rollBack();
                 $this->error = 2305;
+                RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'主播推荐奖励处理失败'], 600);
                 return false;
             }
 
@@ -846,6 +855,7 @@ class LiveService extends BaseService
             if(!AccountLogModel::insertGetId($log)){
                 DB::rollBack();
                 $this->error = 2305;
+                RedisService::set("caches:live:reward:error_{$userId}", ['data'=> $order,'error'=>'主播推荐奖励明细处理失败'], 600);
                 return false;
             }