6 Commits

8 changed files with 273 additions and 163 deletions

View File

@@ -16,6 +16,8 @@ app.$mount();
import { createSSRApp } from "vue"; import { createSSRApp } from "vue";
import * as Pinia from "pinia"; import * as Pinia from "pinia";
import { createUnistorage } from "pinia-plugin-unistorage"; import { createUnistorage } from "pinia-plugin-unistorage";
import noclick from "./utils/noclick";
export function createApp() { export function createApp() {
const app = createSSRApp(App); const app = createSSRApp(App);
const pinia = Pinia.createPinia(); const pinia = Pinia.createPinia();
@@ -23,6 +25,7 @@ export function createApp() {
pinia.use(createUnistorage()); pinia.use(createUnistorage());
app.use(pinia); app.use(pinia);
app.use(share); app.use(share);
app.use(noclick);
return { return {
app, app,

View File

@@ -21,7 +21,7 @@
/> />
<text <text
class="font-size-16 font-500 color-white" class="font-size-16 font-500 color-white"
@click="emit('payClick', orderData)" @click="$onMultipleClicks(() => emit('payClick', orderData))"
>立即支付</text >立即支付</text
> >
</view> </view>

View File

@@ -128,11 +128,6 @@ const isDeleting = ref(false); // 标志位防止删除时watch冲突
watch( watch(
quantity, quantity,
async (newQuantity) => { async (newQuantity) => {
// 非酒店类型,不处理
if (orderData.value.commodityTypeCode !== "0") {
return;
}
// 如果正在执行删除操作跳过watch逻辑 // 如果正在执行删除操作跳过watch逻辑
if (isDeleting.value) { if (isDeleting.value) {
isDeleting.value = false; isDeleting.value = false;
@@ -208,96 +203,107 @@ const validateUserForms = () => {
// 处理支付点击事件 // 处理支付点击事件
const handlePayClick = ThrottleUtils.createThrottle(async (goodsData) => { const handlePayClick = ThrottleUtils.createThrottle(async (goodsData) => {
console.log("处理支付点击事件", userFormList.value); // 点击后立即展示 loading
// 判断是酒店类型 uni.showLoading({ title: "正在提交订单..." });
if (goodsData.commodityTypeCode === "0") {
// 校验用户姓名 try {
if (!validateUserForms()) { console.log("处理支付点击事件", userFormList.value);
// 判断是酒店类型
if (goodsData.commodityTypeCode === "0") {
// 校验用户姓名
if (!validateUserForms()) {
uni.hideLoading();
return;
}
}
// 校验手机号
if (!PhoneUtils.validatePhone(userFormList.value[0].contactPhone)) {
uni.hideLoading();
uni.showToast({ title: "请输入正确的手机号", icon: "none" });
return; return;
} }
// 购买的商品id
const commodityId = goodsData.commodityId;
// 消费者信息
const consumerInfoEntityList = userFormList.value;
// 购买数量
const purchaseAmount = consumerInfoEntityList.length;
// 支付方式 0-微信 1-支付宝 2-云闪付
const payWay = "0";
// 支付渠道 0-app 1-小程序 2-h5
const paySource = "1";
const params = {
commodityId,
purchaseAmount,
payWay,
paySource,
consumerInfoEntityList,
};
//酒店类型添加入住时间、离店时间
if (goodsData.commodityTypeCode === "0" && selectedDate.value) {
const { startDate, endDate } = selectedDate.value;
// 入住时间
params.checkInData = startDate;
// 离店时间
params.checkOutData = endDate;
}
const res = await orderPay(params);
console.log("确认订单---2:", res);
// 检查接口返回数据
if (!res || !res.data) {
uni.hideLoading();
uni.showToast({ title: "订单创建失败,请重试", icon: "none" });
return;
}
const { data } = res;
const { nonceStr, packageVal, paySign, signType, timeStamp } = data;
// 验证支付参数是否完整
if (!nonceStr || !packageVal || !paySign || !signType || !timeStamp) {
uni.hideLoading();
uni.showToast({ title: "支付参数错误,请重试", icon: "none" });
return;
}
// 在发起微信支付前关闭 loading避免与原生支付 UI 冲突)
uni.hideLoading();
// 调用微信支付
uni.requestPayment({
provider: "wxpay",
timeStamp: String(timeStamp), // 确保为字符串类型
nonceStr: String(nonceStr),
package: String(packageVal), // 确保为字符串类型
signType: String(signType),
paySign: String(paySign),
success: () => {
uni.showToast({
title: "支付成功",
icon: "success",
success: () => {
uni.navigateTo({
url: "/pages-order/order/list",
});
},
});
},
fail: () => {
uni.showToast({ title: "支付失败,请重试", icon: "none" });
},
});
} catch (error) {
console.error(error);
uni.showToast({ title: "请求出错,请重试", icon: "none" });
} finally {
// 防止某些分支忘记 hide确保最终关闭 loadingrequestPayment 后也可以安全调用 hide
uni.hideLoading();
} }
// 校验手机号
if (!PhoneUtils.validatePhone(userFormList.value[0].contactPhone)) {
uni.showToast({ title: "请输入正确的手机号", icon: "none" });
return;
}
// 购买的商品id
const commodityId = goodsData.commodityId;
// 消费者信息
const consumerInfoEntityList = userFormList.value;
// 购买数量
const purchaseAmount = consumerInfoEntityList.length;
// 支付方式 0-微信 1-支付宝 2-云闪付
const payWay = "0";
// 支付渠道 0-app 1-小程序 2-h5
const paySource = "1";
const params = {
commodityId,
purchaseAmount,
payWay,
paySource,
consumerInfoEntityList,
};
//酒店类型添加入住时间、离店时间
if (goodsData.commodityTypeCode === "0" && selectedDate.value) {
const { startDate, endDate } = selectedDate.value;
// 入住时间
params.checkInData = startDate;
// 离店时间
params.checkOutData = endDate;
}
const res = await orderPay(params);
console.log("确认订单---2:", res);
// 检查接口返回数据
if (!res || !res.data) {
uni.showToast({ title: "订单创建失败,请重试", icon: "none" });
return;
}
const { data } = res;
const { nonceStr, packageVal, paySign, signType, timeStamp } = data;
// 验证支付参数是否完整
if (!nonceStr || !packageVal || !paySign || !signType || !timeStamp) {
// console.error("支付参数不完整:", {
// nonceStr: !!nonceStr,
// packageVal: !!packageVal,
// paySign: !!paySign,
// signType: !!signType,
// timeStamp: !!timeStamp,
// });
uni.showToast({ title: "支付参数错误,请重试", icon: "none" });
return;
}
// 调用微信支付
uni.requestPayment({
provider: "wxpay",
timeStamp: String(timeStamp), // 确保为字符串类型
nonceStr: String(nonceStr),
package: String(packageVal), // 确保为字符串类型
signType: String(signType),
paySign: String(paySign),
success: () => {
uni.showToast({
title: "支付成功",
icon: "success",
success: () => {
uni.navigateTo({
url: "/pages-order/order/list",
});
},
});
},
fail: () => {
uni.showToast({ title: "支付失败,请重试", icon: "none" });
},
});
}, 1000); }, 1000);
</script> </script>

View File

@@ -17,7 +17,7 @@
'bg-2D91FF': ['1', '2', '3', '4', '5', '6'].includes(statusCode), 'bg-2D91FF': ['1', '2', '3', '4', '5', '6'].includes(statusCode),
}, },
]" ]"
@click="handleButtonClick(orderData)" @click="$onmultipleClicks(() => handleButtonClick(orderData))"
> >
{{ buttonText }} {{ buttonText }}
</button> </button>
@@ -71,10 +71,14 @@ const handleButtonClick = async (orderData) => {
uni.navigateTo({ uni.navigateTo({
url: `/pages/goods/index?commodityId=${orderData.commodityId}`, url: `/pages/goods/index?commodityId=${orderData.commodityId}`,
}); });
return;
} }
// 待支付状态,调用支付接口 // 待支付状态,调用支付接口
if (statusCode.value === "0") { if (statusCode.value === "0") {
// 显示 loading
uni.showLoading({ title: "正在提交订单..." });
const orderId = orderData.orderId; const orderId = orderData.orderId;
const payWay = orderData.payWay; const payWay = orderData.payWay;
const paySource = orderData.paySource; const paySource = orderData.paySource;
@@ -84,6 +88,7 @@ const handleButtonClick = async (orderData) => {
// 检查接口返回数据 // 检查接口返回数据
if (!res || !res.data) { if (!res || !res.data) {
uni.hideLoading();
uni.showToast({ title: "订单创建失败,请重试", icon: "none" }); uni.showToast({ title: "订单创建失败,请重试", icon: "none" });
return; return;
} }
@@ -93,17 +98,14 @@ const handleButtonClick = async (orderData) => {
// 验证支付参数是否完整 // 验证支付参数是否完整
if (!nonceStr || !packageVal || !paySign || !signType || !timeStamp) { if (!nonceStr || !packageVal || !paySign || !signType || !timeStamp) {
// console.error("支付参数不完整:", { uni.hideLoading();
// nonceStr: !!nonceStr,
// packageVal: !!packageVal,
// paySign: !!paySign,
// signType: !!signType,
// timeStamp: !!timeStamp,
// });
uni.showToast({ title: "支付参数错误,请重试", icon: "none" }); uni.showToast({ title: "支付参数错误,请重试", icon: "none" });
return; return;
} }
// 在发起微信支付前关闭 loading避免与原生支付 UI 冲突)
uni.hideLoading();
// 调用微信支付 // 调用微信支付
uni.requestPayment({ uni.requestPayment({
provider: "wxpay", provider: "wxpay",
@@ -126,6 +128,7 @@ const handleButtonClick = async (orderData) => {
} }
} catch (error) { } catch (error) {
console.error("操作失败:", error); console.error("操作失败:", error);
uni.hideLoading();
} }
}; };
</script> </script>

View File

@@ -407,7 +407,7 @@ const getMainPageData = async () => {
/// =============对话↓================ /// =============对话↓================
// 初始化WebSocket // 初始化WebSocket
const initWebSocket = () => { const initWebSocket = async () => {
// 清理旧实例 // 清理旧实例
if (webSocketManager) { if (webSocketManager) {
webSocketManager.destroy(); webSocketManager.destroy();
@@ -426,9 +426,10 @@ const initWebSocket = () => {
// 连接成功回调 // 连接成功回调
onOpen: (event) => { onOpen: (event) => {
console.log("WebSocket连接成功");
// 重置会话状态 // 重置会话状态
webSocketConnectStatus = true; webSocketConnectStatus = true;
isSessionActive.value = true; isSessionActive.value = false; // 连接成功时重置会话状态,避免影响新消息发送
}, },
// 连接断开回调 // 连接断开回调
@@ -441,9 +442,9 @@ const initWebSocket = () => {
// 错误回调 // 错误回调
onError: (error) => { onError: (error) => {
console.error("WebSocket错误:", error);
webSocketConnectStatus = false; webSocketConnectStatus = false;
isSessionActive.value = false; isSessionActive.value = false;
console.error("WebSocket错误:", error);
}, },
// 消息回调 // 消息回调
@@ -458,67 +459,73 @@ const initWebSocket = () => {
getAgentId: () => agentId.value, getAgentId: () => agentId.value,
}); });
// 初始化连接 try {
webSocketManager // 初始化连接
.connect() await webSocketManager.connect();
.then(() => { console.log("WebSocket连接初始化成功");
webSocketConnectStatus = true; webSocketConnectStatus = true;
}) return true;
.catch((error) => { } catch (error) {
console.error("WebSocket连接失败:", error); console.error("WebSocket连接失败:", error);
}); webSocketConnectStatus = false;
return false;
}
}; };
// 处理WebSocket消息 // 处理WebSocket消息
const handleWebSocketMessage = (data) => { const handleWebSocketMessage = (data) => {
const aiMsgIndex = chatMsgList.value.length - 1; const aiMsgIndex = chatMsgList.value.length - 1;
if (!chatMsgList.value[aiMsgIndex] || aiMsgIndex < 0) { if (!chatMsgList.value[aiMsgIndex] || aiMsgIndex < 0) {
return; console.error("处理WebSocket消息时找不到对应的AI消息项");
} return;
// 确保消息内容是字符串类型
if (data.content && typeof data.content !== "string") {
data.content = String(data.content);
}
// 直接拼接内容到AI消息
if (data.content) {
if (chatMsgList.value[aiMsgIndex].isLoading) {
chatMsgList.value[aiMsgIndex].msg = "";
} }
chatMsgList.value[aiMsgIndex].msg += data.content;
chatMsgList.value[aiMsgIndex].isLoading = false;
nextTick(() => scrollToBottom());
}
// 处理完成状态 // 确保消息内容是字符串类型
if (data.finish) { if (data.content && typeof data.content !== "string") {
const msg = chatMsgList.value[aiMsgIndex].msg; data.content = String(data.content);
if (!msg || chatMsgList.value[aiMsgIndex].isLoading) { }
chatMsgList.value[aiMsgIndex].msg = "未获取到内容,请重试";
chatMsgList.value[aiMsgIndex].isLoading = false; // 直接拼接内容到AI消息
if (data.toolCall) { if (data.content) {
if (chatMsgList.value[aiMsgIndex].isLoading) {
chatMsgList.value[aiMsgIndex].msg = ""; chatMsgList.value[aiMsgIndex].msg = "";
} }
chatMsgList.value[aiMsgIndex].msg += data.content;
chatMsgList.value[aiMsgIndex].isLoading = false;
nextTick(() => scrollToBottom());
} }
// 处理toolCall // 处理完成状态
if (data.toolCall) { if (data.finish) {
chatMsgList.value[aiMsgIndex].toolCall = data.toolCall; const msg = chatMsgList.value[aiMsgIndex].msg;
} if (!msg || chatMsgList.value[aiMsgIndex].isLoading) {
chatMsgList.value[aiMsgIndex].msg = "未获取到内容,请重试";
chatMsgList.value[aiMsgIndex].isLoading = false;
if (data.toolCall) {
chatMsgList.value[aiMsgIndex].msg = "";
}
}
// 处理question // 处理toolCall
if (data.question && data.question.length > 0) { if (data.toolCall) {
chatMsgList.value[aiMsgIndex].question = data.question; chatMsgList.value[aiMsgIndex].toolCall = data.toolCall;
} }
// 重置会话状态 // 处理question
isSessionActive.value = false; if (data.question && data.question.length > 0) {
} chatMsgList.value[aiMsgIndex].question = data.question;
}; }
// 重置会话状态
isSessionActive.value = false;
}
};
// 重置消息状态 // 重置消息状态
const resetMessageState = () => {}; const resetMessageState = () => {
// 重置当前会话消息ID
currentSessionMessageId = null;
};
// 初始化数据 首次数据加载的时候 // 初始化数据 首次数据加载的时候
const initData = () => { const initData = () => {
@@ -536,12 +543,39 @@ const sendMessage = async (message, isInstruct = false) => {
await checkToken(); await checkToken();
// 检查WebSocket连接状态如果未连接尝试重新连接
if (!webSocketConnectStatus) { if (!webSocketConnectStatus) {
uni.showToast({ console.log("WebSocket未连接尝试重新连接...");
title: "当前网络异常,请稍后重试", // 显示加载提示
icon: "none", uni.showLoading({
title: "正在连接服务器...",
}); });
return;
// 尝试重新初始化WebSocket连接
try {
await initWebSocket();
// 等待短暂时间确保连接建立
await new Promise(resolve => setTimeout(resolve, 1000));
// 检查连接是否成功建立
if (!webSocketConnectStatus) {
uni.hideLoading();
uni.showToast({
title: "连接服务器失败,请稍后重试",
icon: "none",
});
return;
}
uni.hideLoading();
} catch (error) {
console.error("重新连接WebSocket失败:", error);
uni.hideLoading();
uni.showToast({
title: "连接服务器失败,请稍后重试",
icon: "none",
});
return;
}
} }
if (isSessionActive.value) { if (isSessionActive.value) {
@@ -563,6 +597,8 @@ const sendMessage = async (message, isInstruct = false) => {
}; };
chatMsgList.value.push(newMsg); chatMsgList.value.push(newMsg);
inputMessage.value = ""; inputMessage.value = "";
// 发送消息后滚动到底部
setTimeoutScrollToBottom();
sendChat(message, isInstruct); sendChat(message, isInstruct);
console.log("发送的新消息:", JSON.stringify(newMsg)); console.log("发送的新消息:", JSON.stringify(newMsg));
}; };
@@ -578,9 +614,11 @@ const sendWebSocketMessage = (messageType, messageContent, options = {}) => {
}; };
try { try {
webSocketManager.sendMessage(args); // 直接调用webSocketManagersendMessage方法,利用其内部的消息队列机制
// 即使当前连接断开,消息也会被加入队列,等待连接恢复后发送
const result = webSocketManager.sendMessage(args);
console.log(`WebSocket消息已发送 [类型:${messageType}]:`, args); console.log(`WebSocket消息已发送 [类型:${messageType}]:`, args);
return true; return result;
} catch (error) { } catch (error) {
console.error("发送WebSocket消息失败:", error); console.error("发送WebSocket消息失败:", error);
isSessionActive.value = false; isSessionActive.value = false;
@@ -590,9 +628,26 @@ const sendWebSocketMessage = (messageType, messageContent, options = {}) => {
// 发送获取AI聊天消息 // 发送获取AI聊天消息
const sendChat = (message, isInstruct = false) => { const sendChat = (message, isInstruct = false) => {
if (!webSocketManager || !webSocketManager.isConnected()) { // 检查WebSocket管理器是否存在如果不存在尝试重新初始化
console.error("WebSocket未连接"); if (!webSocketManager) {
isSessionActive.value = false; console.error("WebSocket管理器不存在尝试重新初始化...");
initWebSocket();
// 短暂延迟后再次检查连接状态
setTimeout(() => {
if (webSocketManager && webSocketManager.isConnected()) {
// 连接成功后重新发送消息
sendChat(message, isInstruct);
} else {
console.error("WebSocket重新初始化失败");
isSessionActive.value = false;
// 更新AI消息状态为失败
const aiMsgIndex = chatMsgList.value.length - 1;
if (aiMsgIndex >= 0 && chatMsgList.value[aiMsgIndex].msgType === MessageRole.AI) {
chatMsgList.value[aiMsgIndex].msg = "发送消息失败,请重试";
chatMsgList.value[aiMsgIndex].isLoading = false;
}
}
}, 1000);
return; return;
} }
@@ -615,6 +670,8 @@ const sendChat = (message, isInstruct = false) => {
}, },
}; };
chatMsgList.value.push(aiMsg); chatMsgList.value.push(aiMsg);
// 添加AI消息后滚动到底部
setTimeoutScrollToBottom();
const aiMsgIndex = chatMsgList.value.length - 1; const aiMsgIndex = chatMsgList.value.length - 1;
// 发送消息 // 发送消息
@@ -678,6 +735,7 @@ const resetConfig = () => {
// 重置消息状态 // 重置消息状态
resetMessageState(); resetMessageState();
isSessionActive.value = false;
// 清理定时器 // 清理定时器
if (holdKeyboardTimer.value) { if (holdKeyboardTimer.value) {

View File

@@ -3,11 +3,21 @@
} }
.ip { .ip {
position: relative;
flex: 0 0 158px; flex: 0 0 158px;
width: 158px; width: 158px;
height: 134px; height: 134px;
animation: sprite-play calc(var(--ipLargeTime) * 1s) animation: sprite-play calc(var(--ipLargeTime) * 1s)
steps(var(--ipLargeImageStep)) infinite; steps(var(--ipLargeImageStep)) infinite;
&::before {
content: "";
position: absolute;
background-color: #f9fcfd;
top: 0;
left: 0;
right: 0;
height: 3px;
}
} }
@keyframes sprite-play { @keyframes sprite-play {

28
src/utils/noclick.js Normal file
View File

@@ -0,0 +1,28 @@
// 防止处理多次点击
// methods是需要点击后需要执行的函数 info是点击需要传的参数
export function noMultipleClicks(fn, info, delay = 2000) {
if (typeof fn !== 'function') return;
// this 会是组件实例(因为通过 globalProperties 调用时 Vue 会把组件实例作为上下文)
const ctx = this || {};
if (!ctx.__noClickMap) ctx.__noClickMap = new WeakMap();
const map = ctx.__noClickMap;
if (map.get(fn)) {
console.log('请勿重复点击:', fn.name);
return;
}
map.set(fn, true);
// 保留组件上下文调用方法
fn.call(ctx, info);
setTimeout(() => {
map.set(fn, false);
}, delay);
}
export default {
install(app) {
app.config.globalProperties.$noMultipleClicks = noMultipleClicks;
}
}

View File

@@ -3,7 +3,9 @@ export default {
app.mixin({ app.mixin({
onLoad() { onLoad() {
const page = getCurrentPages().pop(); const page = getCurrentPages().pop();
if (page) { console.log("Current page:", page);
const allowShare = page && page.route && page.route !== "pages/login/index";
if (allowShare) {
uni.showShareMenu({ uni.showShareMenu({
withShareTicket: true, withShareTicket: true,
menus: ["shareAppMessage", "shareTimeline"], menus: ["shareAppMessage", "shareTimeline"],