chore(js): 新增ai、客服、安全事件、wxwork-jssdk.js

common/js/ai-service.js

@@ -0,0 +1,434 @@
+import Config from './config.js'
+import http from './http.js'
+import store from '@/store/index.js'
+
+let currentConversationId = null;
+const CONVERSATION_KEY = 'ai_conversation_id';
+
+// 初始化时从本地读取会话ID
+try {
+  const saved = uni.getStorageSync(CONVERSATION_KEY);
+  if (saved) {
+    currentConversationId = saved;
+  }
+} catch (e) {
+  console.warn('读取会话ID失败:', e);
+}
+
+export default {
+  /**
+   * 发送普通消息（blocking 模式）
+   */
+  async sendMessage(message, options = {}) {
+    try {
+      const aiConfig = store.getters.globalAIKefuConfig;
+      const params = {
+        url: '/api/kefu/chat',
+        data: {
+          user_id: store.state.memberInfo?.id || 'anonymous',
+          stream: false,
+          inputs: {},
+          query: message,
+          response_mode: 'blocking', // 强制 blocking
+          user: store.state.memberInfo?.id || 'anonymous',
+          conversation_id: this.getConversationId() || ''
+        },
+        header: {
+          'Content-Type': 'application/json'
+        }
+      };
+
+      console.log('Sending blocking request to:', params.url);
+      console.log('Request data:', params.data);
+
+      const response = await http.sendRequest({
+        ...params,
+        async: false
+      });
+
+      const result = this.handleResponse(response);
+      if (result.conversationId) {
+        this.setConversationId(result.conversationId);
+      }
+      return result;
+    } catch (error) {
+      console.error('Dify API请求失败:', error);
+      throw new Error('AI服务暂时不可用，请稍后重试');
+    }
+  },
+
+  /**
+   * 流式消息入口（自动适配平台）
+   */
+  async sendStreamMessage(message, onChunk, onComplete) {
+    // #ifdef MP-WEIXIN
+    // 微信小程序：降级为普通请求 + 前端打字模拟
+    try {
+      const result = await this.sendMessage(message);
+      const content = result.content || '';
+      const conversationId = result.conversationId || '';
+
+      // 保存会话ID（确保连续对话）
+      if (conversationId) {
+        this.setConversationId(conversationId);
+      }
+
+      // 模拟打字效果
+      let index = 0;
+      const chunkSize = 2; // 每次显示2个字符
+      return new Promise((resolve) => {
+        const timer = setInterval(() => {
+          if (index < content.length) {
+            const chunk = content.substring(index, index + chunkSize);
+            index += chunkSize;
+            if (onChunk) onChunk(chunk);
+          } else {
+            clearInterval(timer);
+            if (onComplete) {
+              onComplete({
+                content: content,
+                conversation_id: conversationId
+              });
+            }
+            resolve({ content, conversation_id: conversationId });
+          }
+        }, 80); // 打字速度：80ms/次
+      });
+    } catch (error) {
+      console.error('小程序流式消息降级失败:', error);
+      if (onComplete) {
+        onComplete({ error: error.message || '发送失败' });
+      }
+      throw error;
+    }
+    // #endif
+
+    // #ifdef H5
+    // H5：使用真实流式（EventSource / Fetch）
+    return this.sendHttpStream(message, onChunk, onComplete);
+    // #endif
+  },
+
+  /**
+   * HTTP 流式请求（仅 H5 使用）
+   */
+  async sendHttpStream(message, onChunk, onComplete) {
+    // #ifdef H5
+    try {
+      const url = Config.baseUrl + `/api/kefu/chat`;
+      const response = await fetch(url, {
+        method: 'POST',
+        headers: {
+          'Content-Type': 'application/json',
+          'Accept': 'text/event-stream',
+        },
+        body: JSON.stringify({
+          uniacid: store.state.uniacid || '1',
+          inputs: {},
+          query: message,
+          response_mode: 'streaming',
+          user_id: store.state.memberInfo?.id || 'anonymous',
+          conversation_id: this.getConversationId() || ''
+        })
+      });
+
+      if (!response.ok) {
+        throw new Error(`HTTP ${response.status}`);
+      }
+      if (!response.body) {
+        throw new Error('响应体不可用');
+      }
+
+      const reader = response.body.getReader();
+      const decoder = new TextDecoder('utf-8');
+      let buffer = '';
+      let content = '';
+      let conversationId = '';
+
+      function processBuffer(buf, callback) {
+        const lines = buf.split('\n');
+        buf = lines.pop() || '';
+        for (const line of lines) {
+          const trimmed = line.trim();
+          if (trimmed.startsWith('data:')) {
+            const jsonStr = trimmed.slice(5).trim();
+            if (jsonStr) {
+              try {
+                const data = JSON.parse(jsonStr);
+                if (data.event === 'message') {
+                  const text = data.answer || data.text || '';
+                  content += text;
+                  callback(text);
+                }
+                if (data.conversation_id) {
+                  conversationId = data.conversation_id;
+                }
+                if (data.event === 'message_end') {
+                  // 可选：提前完成
+                }
+              } catch (e) {
+                console.warn('解析流数据失败:', e);
+              }
+            }
+          }
+        }
+        return buf;
+      }
+
+      while (true) {
+        const { done, value } = await reader.read();
+        if (done) break;
+        buffer += decoder.decode(value, { stream: true });
+        buffer = processBuffer(buffer, (chunk) => {
+          if (onChunk) onChunk(chunk);
+        });
+      }
+
+      if (onComplete) {
+        onComplete({
+          content,
+          conversation_id: conversationId
+        });
+      }
+      return { content, conversation_id: conversationId };
+    } catch (error) {
+      console.error('H5 流式请求失败:', error);
+      throw error;
+    }
+    // #endif
+
+    // #ifdef MP-WEIXIN
+    // 理论上不会执行到这里，但防止 fallback
+    return this.sendStreamMessage(message, onChunk, onComplete);
+    // #endif
+  },
+
+  /**
+   * 处理API响应（统一格式）
+   */
+  handleResponse(response) {
+    if (response.code === 0 || response.success) {
+      return {
+        success: true,
+        content: response.data?.answer || response.data?.content || response.data?.reply || response.data,
+        conversationId: response.data?.conversation_id,
+        messageId: response.data?.message_id
+      };
+    } else {
+      throw new Error(response.message || 'AI服务返回错误');
+    }
+  },
+
+  /**
+   * 获取当前会话ID
+   */
+  getConversationId() {
+    return currentConversationId;
+  },
+
+  /**
+   * 设置并持久化会话ID
+   */
+  setConversationId(id) {
+    if (id && id !== currentConversationId) {
+      currentConversationId = id;
+      try {
+        uni.setStorageSync(CONVERSATION_KEY, id);
+      } catch (e) {
+        console.error('保存会话ID失败:', e);
+      }
+    }
+  },
+
+  /**
+   * 清除会话ID
+   */
+  clearConversationId() {
+    currentConversationId = null;
+    try {
+      uni.removeStorageSync(CONVERSATION_KEY);
+    } catch (e) {
+      console.error('清除会话ID失败:', e);
+    }
+  },
+
+  /**
+   * 生成新会话（如需）
+   */
+  async generateConversationId() {
+    const params = {
+      url: '/api/kefu/createConversation',
+      data: {
+        uniacid: store.state.uniacid,
+        user_id: store.state.memberInfo?.id || 'anonymous',
+        member_id: store.state.memberInfo?.id || '',
+      },
+      header: {
+        'Content-Type': 'application/json'
+      }
+    };
+    const response = await http.sendRequest({
+      ...params,
+      async: false
+    });
+    return this.handleResponse(response);
+  },
+
+  /**
+   * 获取服务状态
+   */
+  async getServiceStatus() {
+    try {
+      const response = await http.sendRequest({
+        url: '/api/kefu/health',
+        async: false,
+        data: {}
+      });
+      const available = [response?.data?.status, response?.data?.components?.ai_service_config?.status]
+        .filter(item => item === 'healthy').length > 0;
+      return {
+        available,
+        reason: available ? '服务正常' : '服务异常'
+      };
+    } catch (error) {
+      return {
+        available: false,
+        reason: '服务检查失败'
+      };
+    }
+  },
+
+  /**
+   * 清除会话历史（调用后端接口）
+   */
+  async clearConversation(conversationId) {
+    try {
+      const response = await http.sendRequest({
+        url: '/api/kefu/clear-conversation',
+        data: { conversation_id: conversationId },
+        async: false
+      });
+      return response.success;
+    } catch (error) {
+      console.error('清除会话失败:', error);
+      return false;
+    }
+  },
+
+  /**
+   * 获取会话历史
+   */
+  async getConversationHistory(params = {}) {
+    try {
+      if (!params.conversation_id) {
+        throw new Error('会话ID（conversation_id）是必填参数');
+      }
+      const requestData = {
+        uniacid: params.uniacid || store.state.uniacid || '1',
+        conversation_id: params.conversation_id,
+        user_id: params.user_id || store.state.memberInfo?.id || 'anonymous',
+        limit: params.limit || 20,
+        offset: params.offset || 0,
+        member_id: params.member_id || store.state.memberInfo?.id || '',
+        token: params.token || ''
+      };
+      const response = await http.sendRequest({
+        url: '/api/kefu/getHistory',
+        data: requestData,
+        header: {
+          'Content-Type': 'application/json'
+        },
+        async: false
+      });
+      if (response.code === 0 || response.success) {
+        return {
+          success: true,
+          data: response.data,
+          messages: response.data?.messages || [],
+          total: response.data?.total || 0,
+          page_info: response.data?.page_info || { limit: 20, offset: 0 }
+        };
+      } else {
+        throw new Error(response.message || '获取会话历史失败');
+      }
+    } catch (error) {
+      console.error('获取会话历史失败:', error);
+      throw new Error(error.message || '获取会话历史时发生错误，请稍后重试');
+    }
+  },
+
+  // ================================
+  // 以下方法仅用于 H5，小程序无效
+  // ================================
+
+  /**
+   * [H5 Only] EventSource 流式聊天（备用）
+   */
+  chatWithEventSource(message, conversationId = '', onMessage, onComplete, onError) {
+    // #ifdef H5
+    if (window.currentEventSource) {
+      window.currentEventSource.close();
+    }
+    const params = new URLSearchParams({
+      uniacid: store.state.uniacid || '1',
+      user_id: store.state.memberInfo?.id || '123456',
+      query: message,
+      conversation_id: conversationId || '',
+      stream: 'true'
+    });
+    const url = `${Config.baseUrl}/api/kefu/chat?${params.toString()}`;
+    try {
+      const eventSource = new EventSource(url);
+      window.currentEventSource = eventSource;
+      let aiMessage = '';
+      eventSource.onmessage = (event) => {
+        try {
+          const data = JSON.parse(event.data);
+          if (data.event === 'message') {
+            aiMessage += data.answer || '';
+            if (onMessage) onMessage(data.answer || '');
+          }
+          if (data.event === 'message_end') {
+            if (onComplete) onComplete({ 
+              conversation_id: data.conversation_id,
+              message: aiMessage 
+            });
+          }
+        } catch (error) {
+          console.error('解析消息失败:', error);
+        }
+      };
+      eventSource.onerror = (error) => {
+        console.error('EventSource错误:', error);
+        if (onError) onError({ error: '连接失败' });
+        window.currentEventSource = null;
+      };
+      return eventSource;
+    } catch (error) {
+      console.error('创建EventSource失败:', error);
+      if (onError) onError({ error: error.message });
+      return null;
+    }
+    // #endif
+    // #ifdef MP-WEIXIN
+    console.warn('chatWithEventSource 不支持微信小程序');
+    return null;
+    // #endif
+  },
+
+  /**
+   * [H5 Only] Fetch 流式聊天（备用）
+   */
+  async chatWithFetchStream(message, conversationId = '', onMessage, onComplete, onError) {
+    // #ifdef H5
+    // 实际逻辑已在 sendHttpStream 中实现，此处可复用或留空
+    return this.sendHttpStream(message, onMessage, (res) => {
+      onComplete?.({ message: res.content, conversation_id: res.conversation_id });
+    });
+    // #endif
+    // #ifdef MP-WEIXIN
+    console.warn('chatWithFetchStream 不支持微信小程序');
+    return null;
+    // #endif
+  }
+};

common/js/customer-service.js

@@ -0,0 +1,511 @@
+/**
+ * 客服统一处理服务
+ * 整合各种客服方式，提供统一的调用接口
+ */
+export class CustomerService {
+    constructor(vueInstance, externalConfig = null) {
+        this.vm = vueInstance;
+        this.externalConfig = externalConfig; // 外部传入的最新配置（优先级最高）
+        this.latestPlatformConfig = null;
+    }
+
+    /**
+     * 强制刷新配置（支持传入外部配置）
+     * @param {Object} externalConfig 外部最新配置
+     */
+    refreshConfig(externalConfig = null) {
+        this.externalConfig = externalConfig || this.externalConfig;
+        this.latestPlatformConfig = null;
+        return this.getPlatformConfig();
+    }
+
+    /**
+     * 获取平台配置
+     * @returns {Object} 平台对应的客服配置
+     */
+    getPlatformConfig() {
+        if (this.latestPlatformConfig) {
+            return this.latestPlatformConfig;
+        }
+
+        // 优先级：外部传入的最新配置 > vuex配置 > 空对象
+        const servicerConfig = this.externalConfig || this.vm.$store.state.servicerConfig || {};
+        console.log(`【实时客服配置】`, servicerConfig);
+
+        let platformConfig = null;
+        // #ifdef H5
+        platformConfig = servicerConfig.h5 ? (typeof servicerConfig.h5 === 'object' ? servicerConfig.h5 : null) : null;
+        // #endif
+
+        // #ifdef MP-WEIXIN
+        platformConfig = servicerConfig.weapp ? (typeof servicerConfig.weapp === 'object' ? servicerConfig.weapp : null) : null;
+        // #endif
+
+        // #ifdef MP-ALIPAY
+        platformConfig = servicerConfig.aliapp ? (typeof servicerConfig.aliapp === 'object' ? servicerConfig.aliapp : null) : null;
+        // #endif
+
+        // #ifdef PC
+        platformConfig = servicerConfig.pc ? (typeof servicerConfig.pc === 'object' ? servicerConfig.pc : null) : null;
+        // #endif
+
+        // 处理空数组情况（你的配置中pc/aliapp是空数组，转为null）
+        if (Array.isArray(platformConfig)) {
+            platformConfig = null;
+        }
+
+        this.latestPlatformConfig = platformConfig;
+        return platformConfig;
+    }
+
+    /**
+     * 获取企业微信配置
+     * @returns {Object} 企业微信配置
+     */
+    getWxworkConfig() {
+        return this.vm.$store.state.wxworkConfig || {};
+    }
+
+    /**
+     * 检查客服配置是否可用
+     * @returns {boolean} 是否有可用配置
+     */
+    isConfigAvailable() {
+        const config = this.getPlatformConfig();
+        return config && typeof config === 'object' && config.type;
+    }
+
+    /**
+     * 验证客服配置完整性
+     * @returns {Object} 验证结果
+     */
+    validateConfig() {
+        const config = this.getPlatformConfig();
+        const wxworkConfig = this.getWxworkConfig();
+        
+        const result = {
+            isValid: true,
+            errors: [],
+            warnings: []
+        };
+
+        if (!config) {
+            result.isValid = false;
+            result.errors.push('客服配置不存在');
+            return result;
+        }
+
+        if (config.type === 'aikefu') {
+            return result;
+        }
+
+        if (!config.type) {
+            result.isValid = false;
+            result.errors.push('客服类型未配置');
+        }
+
+        if (config.type === 'wxwork') {
+            if (!wxworkConfig) {
+                result.isValid = false;
+                result.errors.push('企业微信配置不存在');
+            } else {
+                if (!wxworkConfig.enable) {
+                    result.warnings.push('企业微信功能未启用');
+                }
+                if (!wxworkConfig.contact_url) {
+                    result.warnings.push('企业微信活码链接未配置，将使用原有客服方式');
+                }
+            }
+        }
+
+        return result;
+    }
+
+    /**
+     * 跳转到Dify客服页面
+     */
+    openDifyService() {
+        try {
+            if (this.vm.setAiUnreadCount) {
+                this.vm.setAiUnreadCount(0);
+            }
+            // 强制跳转，忽略框架层的封装
+            uni.redirectTo({
+                url: '/pages_tool/ai-chat/index',
+                fail: (err) => {
+                    // 兜底：使用window.location跳转（H5）
+                    // #ifdef H5
+                    window.location.href = '/pages_tool/ai-chat/index';
+                    // #endif
+                    console.error('跳转Dify客服失败:', err);
+                    uni.showToast({
+                        title: '跳转客服失败',
+                        icon: 'none'
+                    });
+                }
+            });
+        } catch (e) {
+            console.error('跳转Dify客服异常:', e);
+            uni.showToast({
+                title: '跳转客服失败',
+                icon: 'none'
+            });
+        }
+    }
+
+    /**
+     * 处理客服点击事件
+     * @param {Object} options 选项参数
+     */
+    handleCustomerClick(options = {}) {
+        const validation = this.validateConfig();
+        if (!validation.isValid) {
+            console.error('客服配置验证失败:', validation.errors);
+            this.showConfigErrorPopup(validation.errors);
+            return;
+        }
+
+        if (validation.warnings.length > 0) {
+            console.warn('客服配置警告:', validation.warnings);
+        }
+
+        const config = this.getPlatformConfig();
+        const { niushop = {}, sendMessageTitle = '', sendMessagePath = '', sendMessageImg = '' } = options;
+
+        if (config.type === 'none') {
+            this.showNoServicePopup();
+            return;
+        }
+
+        // 核心分支：根据最新的type处理
+        switch (config.type) {
+            case 'aikefu':
+                this.openDifyService();
+                break;
+            case 'wxwork':
+                this.openWxworkService(false, config, options);
+                break;
+            case 'third':
+                this.openThirdService(config);
+                break;
+            case 'niushop':
+                this.openNiushopService(niushop);
+                break;
+            case 'weapp':
+                this.openWeappService(config, options);
+                break;
+            case 'aliapp':
+                this.openAliappService(config);
+                break;
+            default:
+                this.makePhoneCall();
+        }
+    }
+
+    /**
+     * 打开企业微信客服
+     * @param {boolean} useOriginalService 是否使用原有客服方式
+     * @param {Object} servicerConfig 客服配置
+     * @param {Object} options 选项参数
+     */
+    openWxworkService(useOriginalService = false, servicerConfig = null, options = {}) {
+        const config = servicerConfig || this.getPlatformConfig();
+        const wxworkConfig = this.getWxworkConfig();
+        const { sendMessageTitle = '', sendMessagePath = '', sendMessageImg = '' } = options;
+
+        // #ifdef MP-WEIXIN
+        if (wxworkConfig?.enable && wxworkConfig?.contact_url && !useOriginalService) {
+            wx.navigateToMiniProgram({
+                appId: 'wxeb490c6f9b154ef9',
+                path: `pages/contacts/externalContactDetail?url=${encodeURIComponent(wxworkConfig.contact_url)}`,
+                success: () => console.log('跳转企业微信成功'),
+                fail: (err) => {
+                    console.error('跳转企业微信失败:', err);
+                    this.fallbackToOriginalService();
+                }
+            });
+        } else {
+            wx.openCustomerServiceChat({
+                extInfo: { url: config.wxwork_url },
+                corpId: config.corpid,
+                showMessageCard: true,
+                sendMessageTitle,
+                sendMessagePath,
+                sendMessageImg
+            });
+        }
+        // #endif
+
+        // #ifdef H5
+        if (wxworkConfig?.enable && wxworkConfig?.contact_url) {
+            window.location.href = wxworkConfig.contact_url;
+        } else if (config.wxwork_url) {
+            location.href = config.wxwork_url;
+        } else {
+            this.fallbackToPhoneCall();
+        }
+        // #endif
+    }
+
+    /**
+     * 打开第三方客服
+     * @param {Object} config 客服配置
+     */
+    openThirdService(config) {
+        if (config.third_url) {
+            window.location.href = config.third_url;
+        } else {
+            this.fallbackToPhoneCall();
+        }
+    }
+
+    /**
+     * 打开牛商客服
+     * @param {Object} niushop 牛商参数
+     */
+    openNiushopService(niushop) {
+        if (Object.keys(niushop).length > 0) {
+            this.vm.$util.redirectTo('/pages_tool/chat/room', niushop);
+        } else {
+            this.makePhoneCall();
+        }
+    }
+
+    /**
+     * 打开微信小程序客服
+     * @param {Object} config 客服配置
+     * @param {Object} options 选项参数
+     */
+    openWeappService(config, options = {}) {
+        if (!this.shouldUseCustomService(config)) {
+            console.log('使用官方微信小程序客服');
+            return;
+        }
+
+        console.log('使用自定义微信小程序客服');
+        this.handleCustomWeappService(config, options);
+    }
+
+    /**
+     * 处理自定义微信小程序客服
+     * @param {Object} config 客服配置
+     * @param {Object} options 选项参数
+     */
+    handleCustomWeappService(config, options = {}) {
+        const { sendMessageTitle = '', sendMessagePath = '', sendMessageImg = '' } = options;
+
+        if (config.customServiceUrl) {
+            let url = config.customServiceUrl;
+            const params = [];
+            if (sendMessageTitle) params.push(`title=${encodeURIComponent(sendMessageTitle)}`);
+            if (sendMessagePath) params.push(`path=${encodeURIComponent(sendMessagePath)}`);
+            if (sendMessageImg) params.push(`img=${encodeURIComponent(sendMessageImg)}`);
+            
+            if (params.length > 0) {
+                url += (url.includes('?') ? '&' : '?') + params.join('&');
+            }
+            
+            uni.navigateTo({
+                url: url,
+                fail: (err) => {
+                    console.error('跳转自定义客服页面失败:', err);
+                    this.tryThirdPartyService(config, options);
+                }
+            });
+            return;
+        }
+
+        this.tryThirdPartyService(config, options);
+    }
+
+    /**
+     * 尝试使用第三方客服
+     * @param {Object} config 客服配置
+     * @param {Object} options 选项参数
+     */
+    tryThirdPartyService(config, options = {}) {
+        if (config.thirdPartyServiceUrl) {
+            // #ifdef H5
+            window.open(config.thirdPartyServiceUrl, '_blank');
+            // #endif
+            
+            // #ifdef MP-WEIXIN
+            if (config.thirdPartyMiniAppId) {
+                wx.navigateToMiniProgram({
+                    appId: config.thirdPartyMiniAppId,
+                    path: config.thirdPartyMiniAppPath || '',
+                    fail: (err) => {
+                        console.error('跳转第三方小程序失败:', err);
+                        this.fallbackToPhoneCall();
+                    }
+                });
+            } else {
+                uni.setClipboardData({
+                    data: config.thirdPartyServiceUrl,
+                    success: () => {
+                        uni.showModal({
+                            title: '客服链接已复制',
+                            content: '客服链接已复制到剪贴板，请在浏览器中粘贴访问',
+                            showCancel: false
+                        });
+                    }
+                });
+            }
+            // #endif
+            return;
+        }
+
+        this.fallbackToPhoneCall();
+    }
+
+    /**
+     * 降级到电话客服
+     */
+    fallbackToPhoneCall() {
+        uni.showModal({
+            title: '联系客服',
+            content: '在线客服暂时不可用，是否拨打电话联系客服？',
+            success: (res) => {
+                if (res.confirm) {
+                    this.makePhoneCall();
+                }
+            }
+        });
+    }
+
+    /**
+     * 打开支付宝小程序客服
+     * @param {Object} config 客服配置
+     */
+    openAliappService(config) {
+        console.log('支付宝小程序客服', config);
+        switch (config.type) {
+            case 'aikefu':
+                this.openDifyService();
+                break;
+            case 'third':
+                this.openThirdService(config);
+                break;
+            default:
+                console.log('使用支付宝官方客服');
+                break;
+        }
+    }
+
+    /**
+     * 拨打电话
+     */
+    makePhoneCall() {
+        this.vm.$api.sendRequest({
+            url: '/api/site/shopcontact',
+            success: res => {
+                if (res.code === 0 && res.data?.mobile) {
+                    uni.makePhoneCall({
+                        phoneNumber: res.data.mobile
+                    });
+                } else {
+                    uni.showToast({
+                        title: '暂无客服电话',
+                        icon: 'none'
+                    });
+                }
+            },
+            fail: () => {
+                uni.showToast({
+                    title: '获取客服电话失败',
+                    icon: 'none'
+                });
+            }
+        });
+    }
+
+    /**
+     * 显示无客服弹窗
+     */
+    showNoServicePopup() {
+        const siteInfo = this.vm.$store.state.siteInfo || {};
+        const message = siteInfo?.site_tel 
+            ? `请联系客服，客服电话是${siteInfo.site_tel}` 
+            : '抱歉，商家暂无客服，请线下联系';
+
+        uni.showModal({
+            title: '联系客服',
+            content: message,
+            showCancel: false
+        });
+    }
+
+    /**
+     * 显示配置错误弹窗
+     * @param {Array} errors 错误列表
+     */
+    showConfigErrorPopup(errors) {
+        const message = errors.join('\n');
+        uni.showModal({
+            title: '配置错误',
+            content: `客服配置有误：\n${message}`,
+            showCancel: false
+        });
+    }
+
+    /**
+     * 降级处理：使用原有客服方式
+     */
+    fallbackToOriginalService() {
+        uni.showModal({
+            title: '提示',
+            content: '无法直接添加企业微信客服，是否使用其他方式联系客服？',
+            success: (res) => {
+                if (res.confirm) {
+                    this.openWxworkService(true);
+                }
+            }
+        });
+    }
+
+    /**
+     * 获取客服按钮配置
+     * @returns {Object} 按钮配置
+     */
+    getButtonConfig() {
+        const config = this.getPlatformConfig();
+        if (!config) return { openType: '' };
+
+        let openType = '';
+        // #ifdef MP-WEIXIN
+        if (config.type === 'weapp') {
+            openType = config.useOfficial !== false ? 'contact' : '';
+        }
+        // #endif
+
+        // #ifdef MP-ALIPAY
+        if (config.type === 'aliapp') openType = 'contact';
+        // #endif
+
+        return { ...config, openType };
+    }
+
+    /**
+     * 判断是否应该使用自定义客服处理
+     * @param {Object} config 客服配置
+     * @returns {boolean} 是否使用自定义客服
+     */
+    shouldUseCustomService(config) {
+        // #ifdef MP-WEIXIN
+        if (config?.type === 'weapp') {
+            return config.useOfficial === false;
+        }
+        // #endif
+        return true;
+    }
+}
+
+/**
+ * 创建客服服务实例
+ * @param {Object} vueInstance Vue实例
+ * @param {Object} externalConfig 外部最新配置
+ * @returns {CustomerService} 客服服务实例
+ */
+export function createCustomerService(vueInstance, externalConfig = null) {
+    return new CustomerService(vueInstance, externalConfig);
+}

common/js/event-safety.js

@@ -0,0 +1,112 @@
+// 事件安全处理工具
+export class EventSafety {
+  // 创建安全的事件对象
+  static createSafeEvent(originalEvent = {}) {
+    const safeEvent = {
+      type: originalEvent.type || 'unknown',
+      timeStamp: originalEvent.timeStamp || Date.now(),
+      detail: originalEvent.detail || {},
+      // 安全的目标对象
+      get target() {
+        return EventSafety.createSafeTarget(originalEvent.target)
+      },
+      get currentTarget() {
+        return EventSafety.createSafeTarget(originalEvent.currentTarget)
+      },
+      // 安全的 matches 方法
+      matches(selector) {
+        return EventSafety.safeMatches(originalEvent.target, selector)
+      }
+    }
+    
+    return new Proxy(safeEvent, {
+      get(obj, prop) {
+        // 防止访问不存在的属性
+        if (prop in obj) {
+          return obj[prop]
+        }
+        return undefined
+      }
+    })
+  }
+  
+  // 创建安全的目标对象
+  static createSafeTarget(target) {
+    if (!target || typeof target !== 'object') {
+      return EventSafety.getFallbackTarget()
+    }
+    
+    const safeTarget = {
+      // 基础属性
+      tagName: target.tagName || '',
+      id: target.id || '',
+      className: target.className || '',
+      // 安全的方法
+      matches: (selector) => EventSafety.safeMatches(target, selector),
+      // 数据集
+      dataset: target.dataset || {}
+    }
+    
+    return safeTarget
+  }
+  
+  // 安全的 matches 检查
+  static safeMatches(element, selector) {
+    if (!element || typeof element.matches !== 'function') {
+      return false
+    }
+    
+    try {
+      return element.matches(selector)
+    } catch (error) {
+      console.warn('matches 检查失败:', error)
+      return false
+    }
+  }
+  
+  // 回退目标对象
+  static getFallbackTarget() {
+    return {
+      tagName: '',
+      id: '',
+      className: '',
+      matches: () => false,
+      dataset: {}
+    }
+  }
+  
+  // 包装事件处理器
+  static wrapEventHandler(handler, options = {}) {
+    return function(event) {
+      try {
+        // 创建安全的事件对象
+        const safeEvent = EventSafety.createSafeEvent(event)
+        return handler.call(this, safeEvent)
+      } catch (error) {
+        console.error('事件处理错误:', error)
+        // 可选的错误处理
+        if (options.onError) {
+          options.onError(error, event, this)
+        }
+      }
+    }
+  }
+  
+  // 验证事件类型
+  static isValidEventType(event, expectedType) {
+    return event && event.type === expectedType
+  }
+  
+  // 提取安全的事件数据
+  static extractEventData(event, fields = ['type', 'timeStamp', 'detail']) {
+    const result = {}
+    
+    fields.forEach(field => {
+      if (event && field in event) {
+        result[field] = event[field]
+      }
+    })
+    
+    return result
+  }
+}

common/js/wxwork-jssdk.js

@@ -0,0 +1,187 @@
+/**
+ * 企业微信JS-SDK调用
+ */
+let WxWork = function () {
+	// 企业微信JS-SDK
+	this.wxwork = null;
+
+	/**
+	 * 初始化企业微信JS-SDK
+	 * @param {Object} params - 初始化参数
+	 * @param {string} params.corpId - 企业ID
+	 * @param {string} params.agentId - 应用ID
+	 * @param {string} params.timestamp - 时间戳
+	 * @param {string} params.nonceStr - 随机字符串
+	 * @param {string} params.signature - 签名
+	 * @param {Array} params.jsApiList - 需要使用的JS接口列表
+	 */
+	this.init = function (params) {
+		if (typeof wx !== 'undefined' && wx.config) {
+			// 小程序环境下的企业微信
+			this.wxwork = wx;
+		} else if (typeof WWOpenData !== 'undefined') {
+			// H5环境下的企业微信
+			this.wxwork = WWOpenData;
+		} else {
+			console.error('企业微信JS-SDK未加载');
+			return false;
+		}
+
+		this.wxwork.config({
+			beta: true, // 必须这么写，否则wx.invoke调用形式的jsapi会有问题
+			debug: false, // 开启调试模式
+			corpId: params.corpId, // 必填，企业号的唯一标识
+			agentId: params.agentId, // 必填，企业微信应用ID
+			timestamp: params.timestamp, // 必填，生成签名的时间戳
+			nonceStr: params.nonceStr, // 必填，生成签名的随机串
+			signature: params.signature, // 必填，签名
+			jsApiList: params.jsApiList || [
+				'openUserProfile',
+				'openEnterpriseChat',
+				'getContext',
+				'getCurExternalContact',
+				'openExistedChatWithMsg'
+			] // 必填，需要使用的JS接口列表
+		});
+
+		return true;
+	};
+
+	/**
+	 * 添加企业微信联系人
+	 * @param {Object} params - 参数
+	 * @param {string} params.userId - 用户ID
+	 * @param {Function} success - 成功回调
+	 * @param {Function} fail - 失败回调
+	 */
+	this.addContact = function (params, success, fail) {
+		if (!this.wxwork) {
+			console.error('企业微信JS-SDK未初始化');
+			if (fail) fail('企业微信JS-SDK未初始化');
+			return;
+		}
+
+		this.wxwork.ready(() => {
+			this.wxwork.invoke('openUserProfile', {
+				type: 'external', // 外部联系人
+				userId: params.userId // 用户ID
+			}, (res) => {
+				if (res.err_msg === 'openUserProfile:ok') {
+					if (success) success(res);
+				} else {
+					console.error('打开用户资料失败:', res);
+					if (fail) fail(res.err_msg);
+				}
+			});
+		});
+	};
+
+	/**
+	 * 打开企业微信客服会话
+	 * @param {Object} params - 参数
+	 * @param {string} params.corpId - 企业ID
+	 * @param {string} params.url - 客服URL
+	 * @param {string} params.name - 会话名称
+	 * @param {Function} success - 成功回调
+	 * @param {Function} fail - 失败回调
+	 */
+	this.openCustomerService = function (params, success, fail) {
+		if (!this.wxwork) {
+			console.error('企业微信JS-SDK未初始化');
+			if (fail) fail('企业微信JS-SDK未初始化');
+			return;
+		}
+
+		this.wxwork.ready(() => {
+			// #ifdef MP-WEIXIN
+			if (typeof wx !== 'undefined' && wx.openCustomerServiceChat) {
+				// 微信小程序环境
+				wx.openCustomerServiceChat({
+					extInfo: {
+						url: params.url
+					},
+					corpId: params.corpId,
+					showMessageCard: true,
+					sendMessageTitle: params.sendMessageTitle || '',
+					sendMessagePath: params.sendMessagePath || '',
+					sendMessageImg: params.sendMessageImg || ''
+				});
+				if (success) success();
+			}
+			// #endif
+			// #ifdef H5
+			else if (typeof WWOpenData !== 'undefined') {
+				// H5环境
+				window.location.href = params.url;
+				if (success) success();
+			}
+			// #endif
+			else {
+				// 直接跳转链接
+				window.location.href = params.url;
+				if (success) success();
+			}
+		});
+	};
+
+	/**
+	 * 生成企业微信活码链接
+	 * @param {Object} params - 参数
+	 * @param {string} params.configId - 活码配置ID
+	 * @param {string} params.userId - 用户ID
+	 * @returns {string} 活码链接
+	 */
+	this.generateContactUrl = function (params) {
+		// 企业微信活码链接格式
+		const baseUrl = 'https://work.weixin.qq.com/kfid';
+		if (params.configId) {
+			return `${baseUrl}/${params.configId}`;
+		}
+		return null;
+	};
+
+	/**
+	 * 检查环境是否支持企业微信
+	 * @returns {boolean} 是否支持
+	 */
+	this.isSupported = function () {
+		// #ifdef MP-WEIXIN
+		return typeof wx !== 'undefined' && wx.openCustomerServiceChat;
+		// #endif
+		// #ifdef H5
+		return typeof WWOpenData !== 'undefined' || /wxwork/i.test(navigator.userAgent);
+		// #endif
+		return false;
+	};
+
+	/**
+	 * 获取当前环境信息
+	 * @returns {Object} 环境信息
+	 */
+	this.getEnvironment = function () {
+		// #ifdef MP-WEIXIN
+		return {
+			platform: 'miniprogram',
+			isWxWork: false,
+			supportContact: typeof wx !== 'undefined' && wx.openCustomerServiceChat
+		};
+		// #endif
+		// #ifdef H5
+		const isWxWork = /wxwork/i.test(navigator.userAgent);
+		return {
+			platform: 'h5',
+			isWxWork: isWxWork,
+			supportContact: isWxWork || typeof WWOpenData !== 'undefined'
+		};
+		// #endif
+		return {
+			platform: 'unknown',
+			isWxWork: false,
+			supportContact: false
+		};
+	};
+}
+
+export {
+	WxWork
+}