seven hace 1 día
padre
commit
809ee082c2
Se han modificado 1 ficheros con 30 adiciones y 3 borrados
  1. 30 3
      app/Services/IssueService.php

+ 30 - 3
app/Services/IssueService.php

@@ -122,6 +122,7 @@ class IssueService extends BaseService
         if($result){
            $msg['code'] = self::YES;
            $msg['msg'] = '设置成功';
+           $msg['key'] = $id;
         }else{
             $msg['msg'] = empty($msg['msg']) ?'操作失败':$msg['msg'];
         }
@@ -572,6 +573,7 @@ class IssueService extends BaseService
         }
     }
 
+    // 获取最新的开奖数据
     public static function getLatestIssue()
     {
         $url = "https://ydpc28.co/api/pc28/list";
@@ -582,12 +584,37 @@ class IssueService extends BaseService
 
         }
         $nextDrawInfo = $result['data']['nextDrawInfo'];
-        $endTime = date('Y-m-d').' '.$nextDrawInfo['nextDrawTime']; // 下一期的截止时间
+        if($nextDrawInfo['nextDrawTime'] < date('H:i:s')) {
+            $endTime = date('Y-m-d').' '.$nextDrawInfo['nextDrawTime']; // 下一期的截止时间
+        }else{
+            $endTime = date('Y-m-d',strtotime('+1 day')).' '.$nextDrawInfo['nextDrawTime']; // 下一期的截止时间
+        }
+        
 
         $list = $result['data']['list'];
-        $latestIssue = $list[0];
-        var_dump($latestIssue);
+        $latestIssue = $list[0];    // 最后开奖
+        
+        $new_issue_no = $latestIssue['lotNumber'] + 1;  // 新期号
+
+        $newInfo = self::findOne(['issue_no' => $new_issue_no]);   // 找新的期号
         
+        // 不存在
+        if(!$newInfo){
+
+            $res = self::submit([
+                'issue_no' => $new_issue_no,
+                'status' => self::model()::STATUS_DRAFT,
+                'start_time' => date('Y-m-d H:i:s'),
+                'end_time' => $endTime,
+            ]);
+
+            $id = $res['key']??0;
+            if($id){
+                self::betting($id); // 开始下注
+            }
+        }
+
+        // $oldList = self::findAll(['status' => self::model()::STATUS_CLOSE]);    // 获取所有封盘的期号
         return $result;
     }
 }