333

app/Services/BetService.php

@@ -604,6 +604,37 @@ class BetService extends BaseService
         return $msg;
     }
 
+
+    /**
+     * @description: 开奖失败退回投注的
+     * @param {*} $issue_no
+     * @return {*}
+     */    
+    public static function betFail($issue_no)
+    {
+        $list = self::findAll(['issue_no' => $issue_no, 'status' => self::model()::STATUS_STAY]);
+        foreach ($list->toArray() as $k => $v) {
+            $profit = $v['amount'];
+            WalletService::updateBalance($v['member_id'], $profit);
+
+            $walletInfo = WalletService::findOne(['member_id' => $v['member_id']]);
+            $balance = $walletInfo['available_balance'];
+
+            BalanceLogService::addLog($v['member_id'], $profit, $balance, ($balance + $profit), '中奖', $v['id'], '');
+
+            $text = $issue_no . "期开奖失败 \n";
+            $text .= "投注类型:{$v['keywords']} \n";
+            $text .= "投注金额:{$v['amount']} \n";
+            $text .= "投注的资金已退回您的钱包 \n";
+
+            self::asyncSendMessage($v['member_id'],$text);
+            $item = [];
+            $iem['status'] = self::model()::STATUS_CANCEL;
+            self::model()::where('id', $v['id'])->update($item);
+        }
+
+    }
+
     /**
      * @description: 中奖结算
      * @param {*} $issue_no

app/Services/IssueService.php

@@ -259,13 +259,15 @@ class IssueService extends BaseService
             } else {
                 $params['status'] = self::model()::STATUS_FAIL;
                 $result = $info->update($params);
+
+                BetService::betFail($info->issue_no);
             }
 
             DB::commit();
-            return ['code' => self::YES, 'msg' => '开奖成功'];
+            return ['code' => self::YES, 'msg' => '投注已退回'];
         } catch (\Exception $e) {
             DB::rollBack();
-            return ['code' => self::NOT, 'msg' => '开奖失败失败'];
+            return ['code' => self::NOT, 'msg' => '投注退回失败'];
         }
         
 

routes/admin.php

@@ -80,6 +80,7 @@ Route::middleware(['admin.jwt'])->group(function () {
             Route::post('/submit', [Issue::class, 'store']);
             Route::post('/betting', [Issue::class, 'betting']);
             Route::post('/close', [Issue::class, 'close']);
+            Route::post('/failure', [Issue::class, 'failure']); 
             Route::post('/lotteryDraw', [Issue::class, 'lotteryDraw']); // 开奖
             Route::post('/delete', [Issue::class, 'destroy']); // 删除
         });