traveler/LaneTexture/unpackage/dist/dev/mp-weixin/pages/api/ai.js

"use strict";
const common_vendor = require("../../common/vendor.js");
const util_request = require("../../util/request.js");
const pages_api_config = require("./config.js");
function generateAIPlan(data) {
  return util_request.request({
    url: `/api/ai/travel/generate`,
    method: "POST",
    data,
    header: {
      "Content-Type": "application/json"
    }
  });
}
function saveAIPlan(data) {
  return util_request.request({
    url: `/api/ai/travel/plans`,
    method: "POST",
    data,
    header: {
      "Content-Type": "application/json"
    }
  });
}
const startAISession = async () => {
  var _a;
  try {
    const response = await common_vendor.index.request({
      url: `${pages_api_config.baseUrl}/api/ai/travel/start`,
      method: "POST",
      header: {
        "Content-Type": "application/json"
      }
    });
    if (response.statusCode === 200) {
      return response.data;
    } else {
      throw new Error(((_a = response.data) == null ? void 0 : _a.msg) || "创建会话失败");
    }
  } catch (error) {
    common_vendor.index.__f__("error", "at pages/api/ai.js:70", "创建会话失败:", error);
    throw error;
  }
};
const chatWithAI = async (sessionId, message) => {
  var _a;
  try {
    common_vendor.index.__f__("log", "at pages/api/ai.js:78", "准备发送聊天请求:", {
      url: `${pages_api_config.baseUrl}/api/ai/travel/chat`,
      sessionId,
      message
    });
    const isLogMessage = message.startsWith("[LOG_TO_CONSOLE]");
    if (isLogMessage) {
      common_vendor.index.__f__("log", "at pages/api/ai.js:87", "发送带日志标记的消息到服务器");
    }
    const response = await common_vendor.index.request({
      url: `${pages_api_config.baseUrl}/api/ai/travel/chat`,
      method: "POST",
      header: {
        "Content-Type": "application/json",
        "sessionId": sessionId,
        // 添加特殊标记，让后端知道要输出日志
        "X-Log-To-Console": "true"
      },
      data: {
        message,
        // 添加日志标志到数据中
        logToConsole: true
      }
    });
    common_vendor.index.__f__("log", "at pages/api/ai.js:106", "服务器响应状态码:", response.statusCode);
    if (response.statusCode === 200) {
      return response.data;
    } else {
      throw new Error(((_a = response.data) == null ? void 0 : _a.msg) || `请求失败: ${response.statusCode}`);
    }
  } catch (error) {
    common_vendor.index.__f__("error", "at pages/api/ai.js:114", "发送消息失败:", error);
    throw error;
  }
};
function getSSEUrl(sessionId) {
  return `${pages_api_config.baseUrl}/api/ai/travel/stream?sessionId=${sessionId}`;
}
async function getLastAIReply(sessionId) {
  try {
    common_vendor.index.__f__("log", "at pages/api/ai.js:147", "获取最新AI回复:", sessionId);
    const response = await common_vendor.index.request({
      url: `${pages_api_config.baseUrl}/api/ai/travel/status`,
      method: "GET",
      header: {
        "Content-Type": "application/json",
        "sessionId": sessionId
      },
      // 设置超时时间为5秒
      timeout: 5e3
    });
    common_vendor.index.__f__("log", "at pages/api/ai.js:161", "检查状态响应:", response);
    if (response.statusCode === 404) {
      common_vendor.index.__f__("log", "at pages/api/ai.js:165", "状态检查接口不存在，视为无新消息");
      return {
        code: 200,
        reply: null,
        msg: "无新消息"
      };
    }
    let reply = null;
    if (response.data) {
      if (response.data.reply) {
        reply = response.data.reply;
      } else if (response.data.data && response.data.data.reply) {
        reply = response.data.data.reply;
      } else if (response.data.content) {
        reply = response.data.content;
      } else if (response.data.msg && response.data.msg.length > 20) {
        reply = response.data.msg;
      }
    }
    return {
      code: response.data.code || 200,
      reply,
      msg: response.data.msg || "无新消息",
      hasNewMessage: response.data.hasNewMessage || false
    };
  } catch (error) {
    common_vendor.index.__f__("error", "at pages/api/ai.js:195", "获取最新回复失败:", error);
    return {
      code: 200,
      reply: null,
      msg: "检查新消息超时",
      hasNewMessage: false
    };
  }
}
async function fetchServerResponse(sessionId) {
  try {
    common_vendor.index.__f__("log", "at pages/api/ai.js:208", "获取服务器响应:", sessionId);
    const response = await common_vendor.index.request({
      url: `${pages_api_config.baseUrl}/api/ai/travel/chat`,
      method: "POST",
      header: {
        "Content-Type": "application/json",
        "sessionId": sessionId
      },
      data: {
        message: "显示服务器响应",
        command: "fetchServerResponse"
      }
    });
    common_vendor.index.__f__("log", "at pages/api/ai.js:224", "服务器响应:", response);
    return {
      code: response.data.code || 200,
      data: response.data,
      statusCode: response.statusCode,
      msg: response.data.msg || "获取服务器响应成功"
    };
  } catch (error) {
    common_vendor.index.__f__("error", "at pages/api/ai.js:233", "获取服务器响应失败:", error);
    throw error;
  }
}
exports.chatWithAI = chatWithAI;
exports.fetchServerResponse = fetchServerResponse;
exports.generateAIPlan = generateAIPlan;
exports.getLastAIReply = getLastAIReply;
exports.getSSEUrl = getSSEUrl;
exports.saveAIPlan = saveAIPlan;
exports.startAISession = startAISession;
//# sourceMappingURL=../../../.sourcemap/mp-weixin/pages/api/ai.js.map