refactor(timetask): 重构命名空间结构

- 将 Index.php 移动到 controller 目录下 - 更新命名空间从 timetask 到 timetask\controller - 保持原有的 Api 控制器和 Db 类引用不变
2026-04-21 23:09:53 +08:00
parent 08e56caa72
commit edcfad59e2
1 changed files with 1 additions and 1 deletions
@@ -0,0 +1,52 @@
+<?php
+
+namespace timetask\controller;
+
+use app\common\controller\Api;
+use think\Db;
+
+class Index extends Api
+{
+    protected $noNeedLogin = ['*'];
+    protected $noNeedRight = ['*'];
+
+    public function get_history()
+    {
+        $client = new \GuzzleHttp\Client();
+        $res = $client->request('GET', 'https://history.macaumarksix.com/history/macaujc2/y/2026');
+        if ($res->getStatusCode() == 200) {
+            try {
+                $response = json_decode($res->getBody(), true);
+                $data = $response['data'];
+                foreach ($data as $item) {
+                    $insert_data = [];
+                    $insert_data['expect'] = $item['expect'];
+                    $insert_data['openTime'] = $item['openTime'];
+                    $openCode = explode(",", $item['openCode']);
+                    $insert_data['num1'] = $openCode[0];
+                    $insert_data['num2'] = $openCode[1];
+                    $insert_data['num3'] = $openCode[2];
+                    $insert_data['num4'] = $openCode[3];
+                    $insert_data['num5'] = $openCode[4];
+                    $insert_data['num6'] = $openCode[5];
+                    $insert_data['num7'] = $openCode[6];
+                    $exist = Db::name('history')->where('expect', $item['expect'])->find();
+                    if (!$exist) {
+                        Db::name('history')->insert($insert_data);
+                    } else {
+                        Db::name('history')->where('expect', $item['expect'])->update($insert_data);
+                    }
+                }
+            } catch (\Exception $e) {
+                $this->error($e->getMessage());
+            }
+
+
+            $this->success('获取成功');
+        } else {
+            $this->error('获取失败');
+        }
+
+
+    }
+}