fix:修复获取RewardCount

supabase/.temp/cli-latest

-v2.9.6
\ No newline at end of file
+v2.15.8
\ No newline at end of file

supabase/functions/update-app-recommend/index.ts

@@ -52,31 +52,20 @@ const getTimestampForMidnight3AM = () => {
 async function cacheTaskCount(supabase, directory, bucketName) {
   const pageFileName = `${directory}/task_count.json`;
 
-  // // 获取所有任务组 ID
-  // const { data: taskGroupArr, error: groupError } = await supabase
-  //   .from('task')
-  //   .select('task_group_id');
-
-  // if (groupError) {
-  //   console.error("Error fetching task groups:", groupError);
-  //   return;
-  // }
-
-  // // 提取所有任务组 ID
-  // const groupIds = taskGroupArr.map(group => group.task_group_id);
-
-  // // 使用 IN 操作符来一次性查询所有匹配的任务组任务数量
-  // const { data, error } = await supabase
-  //   .from('taskcenter.task')
-  //   .select('group_id, id', { count: 'exact' })
-  //   .in('group_id', groupIds);
-
-  // if (error) {
-  //   console.error("Error fetching task counts:", error);
-  //   return;
-  // }
+  // 查询group_id = 1 and enabled = true 的task数量 
+  const { data, error } = await supabase
+    .from('task')
+    .select('id', { count: 'exact' })
+    .eq('group_id', '1856166987890167808')
+    .eq('enable', true);
+
+  if (error) {
+    console.error("Error fetching task counts:", error);
+    return;
+  }
+
   const pageJson = JSON.stringify({
-    total_count: 4,
+    total_count: data.length,
   });
 
   const { error: pageUploadError } = await supabase.storage
@@ -187,7 +176,18 @@ Deno.serve(async (req) => {
     const directory = `app-category/${timestamp}`;
     const bucketName = 'cache'; // 替换为存储桶名称
 
-    EdgeRuntime.waitUntil(cacheTaskCount(supabase, directory, bucketName));
+    const supabaseTask = createClient(
+      Deno.env.get('SUPABASE_URL') ?? '',
+      Deno.env.get('SUPABASE_ANON_KEY') ?? '',
+      {
+        global: {
+          headers: { Authorization: req.headers.get('Authorization')! }
+        },
+        db: { schema: 'taskcenter' }
+      }
+    )
+
+    EdgeRuntime.waitUntil(cacheTaskCount(supabaseTask, directory, bucketName));
 
     EdgeRuntime.waitUntil(cacheAnnouncementData(supabase, directory, bucketName));