置顶DEEPSEEK执行后为什么没有查询结果？精选热门

01-291197浏览问题模块：其他开发相关的问题

// addDeepSeek/index.js - 修复版
const cloud = require('wx-server-sdk')
cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV })
const db = cloud.database()
async function createCollection() {
  try {
    const db = wx.cloud.database()
    
    // 尝试创建集合（实际上会先检查是否存在）
    const result = await db.collection('deepseek_tasks').add({
      data: {
        _id: 'test_collection_creation',
        test: true,
        createdAt: new Date()
      }
    })
    
    console.log('集合测试成功，已存在或创建成功')
    wx.showToast({ title: '集合正常', icon: 'success' })
    
  } catch (error) {
    console.error('集合检查失败:', error)
    
    wx.showModal({
      title: '集合不存在',
      content: 'deepseek_tasks集合不存在，请在云开发控制台创建',
      showCancel: false,
      success: () => {
        // 跳转到云开发控制台
        wx.navigateTo({
          url: '/pages/cloud/cloud'
        })
      }
    })
  }
}
// 异步处理函数
async function processTaskAsync(taskId, prompt) {
  console.log(`开始异步处理任务: ${taskId}`)
  
  try {
    // 1. 更新状态为处理中
    await db.collection('deepseek_tasks').doc(taskId).update({
      data: {
        status: 'processing',
        updatedAt: db.serverDate()
      }
    })
    
    console.log(`任务 ${taskId} 状态更新为处理中`)
    
    // 2. 获取API密钥
     const apiKey = process.env.DEEPSEEK_API_KEY
    console.log('API密钥长度:', apiKey ? apiKey.length : 0)
    
    if (!apiKey || apiKey === 'your-api-key-here') {
      throw new Error('API密钥未配置，请在云函数环境变量中设置DEEPSEEK_API_KEY')
    }
    
    // 3. 调用DeepSeek API
    console.log('开始调用DeepSeek API...')
    
    const response = await cloud.openapi.cloudbase.httpRequest({
      url: 'https://api.deepseek.com/v1/chat/completions',
      method: 'POST',
      header: {
        'Content-Type': 'application/json',
        'Authorization': `Bearer ${apiKey}`
      },
      data: {
        model: 'deepseek-chat',
        messages: [
          {
            role: 'user',
            content: prompt
          }
        ],
        temperature: 0.7,
        max_tokens: 1000
      },
      dataType: 'json',
      timeout: 30000
    })
    
    console.log('DeepSeek API调用成功，状态码:', response.statusCode)
    
    // 4. 保存结果
    const result = response.data?.choices?.[0]?.message?.content || '无回复内容'
    
    await db.collection('deepseek_tasks').doc(taskId).update({
      data: {
        status: 'completed',
        result: result,
        usage: response.data?.usage,
        completedAt: db.serverDate(),
        updatedAt: db.serverDate()
      }
    })
    
    console.log(`任务 ${taskId} 处理完成`)
    
  } catch (error) {
    console.error(`处理任务 ${taskId} 失败:`, error)
    
    // 保存错误信息
    await db.collection('deepseek_tasks').doc(taskId).update({
      data: {
        status: 'failed',
        error: error.message,
        errorDetail: error.toString(),
        updatedAt: db.serverDate()
      }
    })
  }
}


// 主函数
exports.main = async (event, context) => {
  const wxContext = cloud.getWXContext()
  const { prompt } = event
  
  console.log('收到请求:', { 
    prompt: prompt?.substring(0, 50),
    openid: wxContext.OPENID 
  })
  
  // 参数验证
  if (!prompt || prompt.trim() === '') {
    return {
      code: 400,
      message: '请输入有效的问题',
      timestamp: Date.now()
    }
  }
  
  // 生成任务ID
  const taskId = `task_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`
  
  try {
    // 1. 创建任务记录
    console.log(`创建任务记录: ${taskId}`)
    
    await db.collection('deepseek_tasks').add({
      data: {
        _id: taskId,
        prompt: prompt,
        openid: wxContext.OPENID,
        status: 'pending',
        createdAt: db.serverDate(),
        updatedAt: db.serverDate(),
        env: cloud.DYNAMIC_CURRENT_ENV
      }
    })
    
    console.log(`任务记录创建成功: ${taskId}`)
    
    // 2. 立即返回任务ID
    const immediateResponse = {
      success: true,
      taskId: taskId,
      message: '任务已提交，请稍后查询结果',
      timestamp: new Date().toISOString()
    }
    
    console.log('立即返回响应:', immediateResponse)
    
    // 3. 异步处理任务（使用setTimeout确保不阻塞返回）
    setTimeout(async () => {
      console.log(`开始异步处理任务 ${taskId}`)
      try {
        await processTaskAsync(taskId, prompt)
      } catch (asyncError) {
        console.error(`异步处理异常: ${asyncError}`)
      }
    }, 100) // 延迟100ms开始处理，确保先返回响应
    
    return immediateResponse
    
  } catch (error) {
    console.error('创建任务失败:', error)
    
    return {
      success: false,
      message: '创建任务失败',
      error: error.message,
      timestamp: Date.now()
    }
  }
}

置顶DEEPSEEK执行后为什么没有查询结果？精选热门

请选择投诉理由

删除当前帖子

删除后帖子内容及评论将一并被删除，且不可恢复。

关注“微信开放社区”公众号

反馈

新增或编辑超链接

插入视频

请选择投诉理由

新增或编辑超链接

插入视频

请选择投诉理由

新增或编辑超链接

插入视频

请选择投诉理由

请选择投诉理由

新增或编辑超链接

插入视频

关注“微信开放社区”公众号