doge il y a 3 heures
Parent
commit
4f80858518
1 fichiers modifiés avec 8 ajouts et 16 suppressions
  1. 8 16
      app/Services/IssueService.php

+ 8 - 16
app/Services/IssueService.php

@@ -340,24 +340,16 @@ class IssueService extends BaseService
         $winArr = array_map('intval', explode(',', $winning_numbers));
         $winArr = array_map('intval', explode(',', $winning_numbers));
         // 计算中奖
         // 计算中奖
         $awards = self::award(explode(',', $winning_numbers));
         $awards = self::award(explode(',', $winning_numbers));
-        $kenoJson = self::encodePlayNowKeno($keno);
         DB::beginTransaction();
         DB::beginTransaction();
         try {
         try {
-            $updatePayload = [
-                'status' => self::model()::STATUS_DRAW,
-                'winning_numbers' => $winning_numbers,
-                'combo' => $combo,
-            ];
+            $info->status = self::model()::STATUS_DRAW;
+            $info->winning_numbers = $winning_numbers;
+            $info->combo = $combo;
+            $kenoJson = self::encodePlayNowKeno($keno);
             if ($kenoJson) {
             if ($kenoJson) {
-                $updatePayload['keno'] = $kenoJson;
-            }
-            self::model()::where('id', $info->id)->update($updatePayload);
-            $info->status = $updatePayload['status'];
-            $info->winning_numbers = $updatePayload['winning_numbers'];
-            $info->combo = $updatePayload['combo'];
-            if (isset($updatePayload['keno'])) {
-                $info->keno = $updatePayload['keno'];
+                $info->keno = $kenoJson;
             }
             }
+            $info->saveQuietly();
 
 
             Log::channel('issue')->info('官方期开奖写入源头号码', [
             Log::channel('issue')->info('官方期开奖写入源头号码', [
                 'issue_no' => $info->issue_no,
                 'issue_no' => $info->issue_no,
@@ -1183,9 +1175,9 @@ class IssueService extends BaseService
         $kenoJson = self::encodePlayNowKeno($drawInfo['source_numbers']);
         $kenoJson = self::encodePlayNowKeno($drawInfo['source_numbers']);
         if ($kenoJson) {
         if ($kenoJson) {
             $drawIssue = self::findOne(['issue_no' => (string)$drawNo]);
             $drawIssue = self::findOne(['issue_no' => (string)$drawNo]);
-            if ($drawIssue && empty($drawIssue->keno)) {
-                self::model()::where('id', $drawIssue->id)->update(['keno' => $kenoJson]);
+            if ($drawIssue && $drawIssue->status == self::model()::STATUS_DRAW && empty($drawIssue->keno)) {
                 $drawIssue->keno = $kenoJson;
                 $drawIssue->keno = $kenoJson;
+                $drawIssue->saveQuietly();
 
 
                 Log::channel('issue')->info('PlayNow源头号码已补写', [
                 Log::channel('issue')->info('PlayNow源头号码已补写', [
                     'issue_no' => $drawNo,
                     'issue_no' => $drawNo,