From b030a201a7786972337f8117750c99eb8428482b Mon Sep 17 00:00:00 2001 From: lbw_9527443 <780139497@qq.com> Date: Wed, 10 Sep 2025 14:22:24 +0800 Subject: [PATCH] =?UTF-8?q?feat(api):=20=E6=B7=BB=E5=8A=A0=E7=94=B5?= =?UTF-8?q?=E8=AF=9D=E6=8E=A5=E9=80=9A=E7=8E=87API=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit refactor(cache): 将缓存系统重构为独立模块并添加测试页面 fix: 修复客户详情中电话接通率显示格式问题 refactor: 移除各页面中的缓存逻辑，统一使用缓存store feat: 在客户详情中添加通话分析API调用 fix: 修正导出客户API的URL路径 chore: 更新开发环境配置注释 --- my-vue-app/src/api/api.js | 6 +- my-vue-app/src/api/secondTop.js | 2 +- my-vue-app/src/stores/cache.js | 135 ++++++++++++++ my-vue-app/src/utils/https.js | 2 +- my-vue-app/src/views/maneger/manager.vue | 141 +------------- .../person/components/CustomerDetail.vue | 26 ++- .../person/components/PersonalDashboard.vue | 2 +- my-vue-app/src/views/person/sale.vue | 164 ++++------------- my-vue-app/src/views/test/CacheTest.vue | 173 ++++++++++++++++++ 9 files changed, 371 insertions(+), 280 deletions(-) create mode 100644 my-vue-app/src/stores/cache.js create mode 100644 my-vue-app/src/views/test/CacheTest.vue diff --git a/my-vue-app/src/api/api.js b/my-vue-app/src/api/api.js index 2454c85..c8a7dc3 100644 --- a/my-vue-app/src/api/api.js +++ b/my-vue-app/src/api/api.js @@ -77,5 +77,7 @@ export const getGoldContactTime = (params) => { export const getAvgCallTime = (params) => { return https.post('/api/v1/sales/get_avg_call_time', params) } - - +// 电话接通率 /api/v1/sales/get_call_success_rate +export const getCallSuccessRate = (params) => { + return https.post('/api/v1/sales/get_call_success_rate', params) +} diff --git a/my-vue-app/src/api/secondTop.js b/my-vue-app/src/api/secondTop.js index 704d811..ddee8a6 100644 --- a/my-vue-app/src/api/secondTop.js +++ b/my-vue-app/src/api/secondTop.js @@ -87,7 +87,7 @@ export const cancelSwitchHistoryCampPeriod = (params) => { // 一键导出 api/v1/level_four/overview/export_customers export const exportCustomers = (params) => { - return https.post('http://192.168.15.56:8890/api/v1/level_four/overview/export_customers', params) + return https.post('/api/v1/level_four/overview/export_customers', params) } diff --git a/my-vue-app/src/stores/cache.js b/my-vue-app/src/stores/cache.js new file mode 100644 index 0000000..07221bc --- /dev/null +++ b/my-vue-app/src/stores/cache.js @@ -0,0 +1,135 @@ +import { defineStore } from 'pinia' +import { ref } from 'vue' + +export const useCacheStore = defineStore('cache', () => { + // 缓存Map + const cache = ref(new Map()) + const CACHE_DURATION = 30 * 60 * 1000 // 30分钟缓存时长 + + // 生成缓存键 + const getCacheKey = (apiName, params = {}) => { + const sortedParams = Object.keys(params) + .sort() + .reduce((result, key) => { + result[key] = params[key] + return result + }, {}) + return `${apiName}_${JSON.stringify(sortedParams)}` + } + + // 检查缓存是否有效 + const isValidCache = (cacheData) => { + return cacheData && (Date.now() - cacheData.timestamp) < CACHE_DURATION + } + + // 设置缓存 + const setCache = (key, data) => { + cache.value.set(key, { + data, + timestamp: Date.now() + }) + } + + // 获取缓存 + const getCache = (key) => { + const cacheData = cache.value.get(key) + if (isValidCache(cacheData)) { + return cacheData.data + } + // 如果缓存过期，删除它 + if (cacheData) { + cache.value.delete(key) + } + return null + } + + // 缓存包装器函数 + const withCache = async (apiName, apiFunction, params = {}) => { + const cacheKey = getCacheKey(apiName, params) + const cachedData = getCache(cacheKey) + + if (cachedData) { + console.log(`[缓存命中] ${apiName}:`, cachedData) + return cachedData + } + + console.log(`[API调用] ${apiName}`) + const result = await apiFunction(params) + setCache(cacheKey, result) + return result + } + + // 清除所有缓存 + const clearCache = () => { + cache.value.clear() + console.log('所有缓存已清除') + } + + // 清除特定缓存 + const clearSpecificCache = (apiName, params = {}) => { + const key = getCacheKey(apiName, params) + cache.value.delete(key) + console.log(`已清除缓存: ${key}`) + } + + // 获取缓存信息并清理过期缓存 + const getCacheInfo = () => { + const now = Date.now() + const validCaches = [] + const expiredCaches = [] + + for (const [key, data] of cache.value.entries()) { + if (isValidCache(data)) { + validCaches.push({ + key, + timestamp: data.timestamp, + age: Math.round((now - data.timestamp) / 1000) + 's' + }) + } else { + expiredCaches.push(key) + cache.value.delete(key) + } + } + + return { + validCount: validCaches.length, + expiredCount: expiredCaches.length, + validCaches, + expiredCaches + } + } + + // 清除过期缓存 + const clearExpiredCache = () => { + const info = getCacheInfo() + console.log(`清理了 ${info.expiredCount} 个过期缓存`) + return info + } + + // 获取缓存统计信息 + const getCacheStats = () => { + return { + totalCount: cache.value.size, + duration: CACHE_DURATION / (1000 * 60) + '分钟', + ...getCacheInfo() + } + } + + return { + // 状态 + cache, + CACHE_DURATION, + + // 方法 + getCacheKey, + isValidCache, + setCache, + getCache, + withCache, + clearCache, + clearSpecificCache, + getCacheInfo, + clearExpiredCache, + getCacheStats + } +}) \ No newline at end of file diff --git a/my-vue-app/src/utils/https.js b/my-vue-app/src/utils/https.js index 0caac29..07a1086 100644 --- a/my-vue-app/src/utils/https.js +++ b/my-vue-app/src/utils/https.js @@ -6,7 +6,7 @@ import { useUserStore } from '@/stores/user' // 创建axios实例 const service = axios.create({ baseURL: 'https://mldash.nycjy.cn/' || '', // API基础路径，支持完整URL - // baseURL: 'http://192.168.15.121:8889' || '', // API基础路径，支持完整URL + // baseURL: 'http://192.168.15.121:8890' || '', // API基础路径，支持完整URL timeout: 100000, // 请求超时时间 headers: { 'Content-Type': 'application/json;charset=UTF-8' diff --git a/my-vue-app/src/views/maneger/manager.vue b/my-vue-app/src/views/maneger/manager.vue index 4d1b889..079c197 100644 --- a/my-vue-app/src/views/maneger/manager.vue +++ b/my-vue-app/src/views/maneger/manager.vue @@ -83,51 +83,6 @@ import { useRouter } from "vue-router"; import {getGroupAbnormalResponse, getWeekTotalCall, getWeekAddCustomerTotal, getWeekAddDealTotal, getWeekAddFeeTotal, getGroupFunnel,getPayDepositToMoneyRate,getGroupRanking, getGroupCallDuration} from "@/api/manager.js"; -// 缓存系统 -const cache = new Map() -const CACHE_DURATION = 30 * 60 * 1000 // 30分钟缓存 - -// 缓存工具函数 -function getCacheKey(apiName, params = {}) { - return `${apiName}_${JSON.stringify(params)}` -} - -function isValidCache(cacheData) { - return cacheData && (Date.now() - cacheData.timestamp) < CACHE_DURATION -} - -function setCache(key, data) { - cache.set(key, { - data, - timestamp: Date.now() - }) -} - -function getCache(key) { - const cacheData = cache.get(key) - if (isValidCache(cacheData)) { - return cacheData.data - } - cache.delete(key) - return null -} - -// 通用缓存包装函数 -async function withCache(apiName, apiCall, params = {}) { - const key = getCacheKey(apiName, params) - const cachedData = getCache(key) - - if (cachedData) { - console.log(`使用缓存数据: ${key}`) - return cachedData - } - - console.log(`调用API: ${key}`) - const result = await apiCall() - setCache(key, result) - return result -} - // 团队成员数据 const teamMembers = [ { @@ -198,7 +153,7 @@ async function TeamGetGroupAbnormalResponse() { const params = getRequestParams() const hasParams = params.user_name try { - const response = await withCache('getGroupAbnormalResponse', () => getGroupAbnormalResponse(hasParams ? params : undefined), hasParams ? params : {}) + const response = await getGroupAbnormalResponse(hasParams ? params : undefined) const rawData = response.data // 转换数据格式，生成预警消息 @@ -243,7 +198,7 @@ async function TeamGetGroupAbnormalResponse() { async function TeamGetWeekTotalCall() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getWeekTotalCall', () => getWeekTotalCall(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getWeekTotalCall(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.week_total_call = res.data @@ -253,7 +208,7 @@ async function TeamGetWeekTotalCall() { async function TeamGetGroupCallDuration() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getGroupCallDuration', () => getGroupCallDuration(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getGroupCallDuration(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.group_call_duration = res.data @@ -263,7 +218,7 @@ async function TeamGetGroupCallDuration() { async function TeamGetWeekAddCustomerTotal() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getWeekAddCustomerTotal', () => getWeekAddCustomerTotal(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getWeekAddCustomerTotal(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.week_add_customer_total = res.data @@ -273,7 +228,7 @@ async function TeamGetWeekAddCustomerTotal() { async function TeamGetWeekAddDealTotal() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getWeekAddDealTotal', () => getWeekAddDealTotal(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getWeekAddDealTotal(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.week_add_deal_total = res.data @@ -286,7 +241,7 @@ async function TeamGetWeekAddDealTotal() { async function TeamGetWeekAddFeeTotal() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getPayDepositToMoneyRate', () => getPayDepositToMoneyRate(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getPayDepositToMoneyRate(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.pay_deposit_to_money_rate = res.data @@ -296,7 +251,7 @@ async function TeamGetWeekAddFeeTotal() { async function TeamGetGroupFunnel() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getGroupFunnel', () => getGroupFunnel(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getGroupFunnel(hasParams ? params : undefined) console.log(res) if (res.code === 200) { weekTotalData.value.group_funnel = res.data @@ -321,7 +276,7 @@ const groupRanking = ref({}) async function TeamGetGroupRanking() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getGroupRanking', () => getGroupRanking(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getGroupRanking(hasParams ? params : undefined) console.log(res) if (res.code === 200) { groupRanking.value = res.data @@ -339,76 +294,11 @@ const selectMember = (member) => { selectedMember.value = member; }; -// 缓存管理功能 -// 清除所有缓存 -function clearCache() { - cache.clear() - console.log('所有缓存已清除') -} -// 清除特定缓存 -function clearSpecificCache(apiName, params = {}) { - const key = getCacheKey(apiName, params) - cache.delete(key) - console.log(`已清除缓存: ${key}`) -} - -// 获取缓存信息并清理过期缓存 -function getCacheInfo() { - const now = Date.now() - const validCaches = [] - const expiredCaches = [] - - for (const [key, data] of cache.entries()) { - if (isValidCache(data)) { - validCaches.push({ - key, - timestamp: data.timestamp, - age: Math.round((now - data.timestamp) / 1000) + 's' - }) - } else { - expiredCaches.push(key) - cache.delete(key) - } - } - - console.log('有效缓存:', validCaches) - console.log('已清理过期缓存:', expiredCaches) - - return { - validCount: validCaches.length, - expiredCount: expiredCaches.length, - validCaches, - expiredCaches - } -} - -// 强制刷新所有数据（清除缓存并重新调用所有API） -async function forceRefreshAllData() { - console.log('开始强制刷新所有数据...') - clearCache() - - // 重新调用所有API - await Promise.all([ - TeamGetGroupAbnormalResponse(), - TeamGetWeekTotalCall(), - TeamGetGroupCallDuration(), - TeamGetWeekAddCustomerTotal(), - TeamGetWeekAddDealTotal(), - TeamGetWeekAddFeeTotal(), - TeamGetGroupFunnel(), - TeamGetGroupRanking() - ]) - - console.log('所有数据刷新完成') -} // 团队异常预警 onMounted(async () => { - // 输出缓存状态信息 - console.log('Manager页面缓存系统已初始化，缓存时长:', CACHE_DURATION / (1000 * 60), '分钟') - await TeamGetGroupAbnormalResponse() await TeamGetWeekTotalCall() await TeamGetGroupCallDuration() @@ -417,21 +307,6 @@ onMounted(async () => { await TeamGetWeekAddFeeTotal() await TeamGetGroupFunnel() await TeamGetGroupRanking() - - // 输出初始缓存信息 - getCacheInfo() - - // 开发环境下暴露缓存管理函数到全局对象，方便调试 - if (process.env.NODE_ENV === 'development') { - window.managerCache = { - clearCache, - clearSpecificCache, - getCacheInfo, - forceRefreshAllData, - cache - } - console.log('开发模式：缓存管理函数已暴露到 window.managerCache') - } }) diff --git a/my-vue-app/src/views/person/components/CustomerDetail.vue b/my-vue-app/src/views/person/components/CustomerDetail.vue index 53a2649..4afea44 100644 --- a/my-vue-app/src/views/person/components/CustomerDetail.vue +++ b/my-vue-app/src/views/person/components/CustomerDetail.vue @@ -94,6 +94,7 @@ import { ref, watch, computed } from 'vue'; import { SimpleChatService } from '@/utils/ChatService.js'; import MarkdownIt from 'markdown-it'; +import https from '@/utils/https' // 定义props const props = defineProps({ @@ -115,6 +116,7 @@ const props = defineProps({ } }); +console.log(999999999,props.selectedContact); // 分析结果状态 const basicAnalysisResult = ref(''); // 基础信息分析结果 const sopAnalysisResult = ref(''); // SOP通话分析结果 @@ -349,16 +351,20 @@ ${callData.length > 0 && callData[0].record_context ? callData[0].record_context try { - await chatService.sendMessage( - query, - (update) => { - sopAnalysisResult.value = update.content; - }, - () => { - isSopAnalysisLoading.value = false; - console.log('SOP通话分析完成'); - } - ); + // await chatService.sendMessage( + // query, + // (update) => { + // sopAnalysisResult.value = update.content; + // }, + // () => { + // isSopAnalysisLoading.value = false; + // console.log('SOP通话分析完成'); + // } + // ); + const res= await https.get('http://192.168.3.112:6002/api/v1/call',{ + wechat_id:props.selectedContact.wechat_id + }) + sopAnalysisResult.value = res.data.report_content; } catch (error) { console.error('SOP通话分析失败:', error); sopAnalysisResult.value = `分析失败: ${error.message}`; diff --git a/my-vue-app/src/views/person/components/PersonalDashboard.vue b/my-vue-app/src/views/person/components/PersonalDashboard.vue index 904a08f..c7f69fc 100644 --- a/my-vue-app/src/views/person/components/PersonalDashboard.vue +++ b/my-vue-app/src/views/person/components/PersonalDashboard.vue @@ -16,7 +16,7 @@

今日通话 ⓘ

-
{{ props.kpiData.successRate }}%
+
{{ props.kpiData.successRate }}

电话接通率 ⓘ

diff --git a/my-vue-app/src/views/person/sale.vue b/my-vue-app/src/views/person/sale.vue index e77dfcf..7f188f5 100644 --- a/my-vue-app/src/views/person/sale.vue +++ b/my-vue-app/src/views/person/sale.vue @@ -142,64 +142,8 @@ import UserDropdown from "@/components/UserDropdown.vue"; import Loading from "@/components/Loading.vue"; import {getCustomerAttendance,getTodayCall,getProblemDistribution,getTableFillingRate,getAverageResponseTime, getWeeklyActiveCommunicationRate,getTimeoutResponseRate,getCustomerCallInfo,getCustomerChatInfo,getCustomerFormInfo, - getConversionRateAndAllocatedData,getCustomerAttendanceAfterClass4,getPayMoneyCustomers,getSalesFunnel,getGoldContactTime,getAvgCallTime} from "@/api/api.js" - -// 缓存系统 -const cache = new Map(); -const CACHE_DURATION = 30 * 60 * 1000; // 30分钟缓存时长 - -// 生成缓存键 -const getCacheKey = (apiName, params = {}) => { - const sortedParams = Object.keys(params) - .sort() - .reduce((result, key) => { - result[key] = params[key]; - return result; - }, {}); - return `${apiName}_${JSON.stringify(sortedParams)}`; -}; - -// 检查缓存是否有效 -const isValidCache = (cacheData) => { - return cacheData && (Date.now() - cacheData.timestamp) < CACHE_DURATION; -}; - -// 设置缓存 -const setCache = (key, data) => { - cache.set(key, { - data, - timestamp: Date.now() - }); -}; - -// 获取缓存 -const getCache = (key) => { - const cacheData = cache.get(key); - if (isValidCache(cacheData)) { - return cacheData.data; - } - // 如果缓存过期，删除它 - if (cacheData) { - cache.delete(key); - } - return null; -}; - -// 缓存包装器函数 -const withCache = async (apiName, apiFunction, params = {}) => { - const cacheKey = getCacheKey(apiName, params); - const cachedData = getCache(cacheKey); - - if (cachedData) { - console.log(`[缓存命中] ${apiName}:`, cachedData); - return cachedData; - } - - console.log(`[API调用] ${apiName}`); - const result = await apiFunction(params); - setCache(cacheKey, result); - return result; -}; + getConversionRateAndAllocatedData,getCustomerAttendanceAfterClass4,getPayMoneyCustomers,getSalesFunnel,getGoldContactTime, + getAvgCallTime,getCallSuccessRate} from "@/api/api.js" // 路由实例 const router = useRouter(); @@ -220,7 +164,6 @@ const getRequestParams = () => { if (routeUserName) { params.user_name = routeUserName } - return params } @@ -329,6 +272,8 @@ const formInfo = ref({}); const callRecords = ref([]); // 聊天记录 const chatRecords = ref([]); +// 电话接通率 +const callSuccessRate = ref(0) // MOCK DATA (Should ideally come from a store or API) const MOCK_DATA = reactive({ @@ -366,24 +311,27 @@ async function getCoreKpi() { const hasParams = params.user_name // 今日通话数据 - const res = await withCache('getTodayCall', () => getTodayCall(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getTodayCall(hasParams ? params : undefined) if (res.code === 200) { kpiDataState.totalCalls = res.data.today_call } - // 转化率、分配数据量、加微率 - const conversionRes = await withCache('getConversionRateAndAllocatedData', () => getConversionRateAndAllocatedData(hasParams ? params : undefined), hasParams ? params : {}) + const conversionRes = await getConversionRateAndAllocatedData(hasParams ? params : undefined) if (conversionRes.code === 200) { kpiDataState.conversionRate = conversionRes.data.conversion_rate || 0 kpiDataState.assignedData = conversionRes.data.all_count || 0 kpiDataState.wechatAddRate = conversionRes.data.plus_v_conversion_rate || 0 - } - + } // 平均通话时长 - const avgCallTimeRes = await withCache('getAvgCallTime', () => getAvgCallTime(hasParams ? params : undefined), hasParams ? params : {}) + const avgCallTimeRes = await getAvgCallTime(hasParams ? params : undefined) if (avgCallTimeRes.code === 200) { kpiDataState.avgDuration = avgCallTimeRes.data.call_time || 0 } + // 电话接通率 + const callSuccessRateRes = await getCallSuccessRate(hasParams ? params : undefined) + if (callSuccessRateRes.code === 200) { + kpiDataState.successRate = callSuccessRateRes.data.call_success_rate || 0 + } } catch (error) { console.error('获取核心KPI数据失败:', error) } finally { @@ -398,25 +346,25 @@ async function getStatisticsData() { const hasParams = params.user_name // 获取表单填写率 - const fillingRateRes = await withCache('getTableFillingRate', () => getTableFillingRate(hasParams ? params : undefined), hasParams ? params : {}) + const fillingRateRes = await getTableFillingRate(hasParams ? params : undefined) if (fillingRateRes.code === 200) { statisticsData.formCompletionRate = fillingRateRes.data.filling_rate } // 获取平均响应时间 - const avgResponseRes = await withCache('getAverageResponseTime', () => getAverageResponseTime(hasParams ? params : undefined), hasParams ? params : {}) + const avgResponseRes = await getAverageResponseTime(hasParams ? params : undefined) if (avgResponseRes.code === 200) { statisticsData.averageResponseTime = avgResponseRes.data.average_minutes } // 获取客户沟通率 - const communicationRes = await withCache('getWeeklyActiveCommunicationRate', () => getWeeklyActiveCommunicationRate(hasParams ? params : undefined), hasParams ? params : {}) + const communicationRes = await getWeeklyActiveCommunicationRate(hasParams ? params : undefined) if (communicationRes.code === 200) { statisticsData.customerCommunicationRate = communicationRes.data.communication_rate } // 获取超时响应率 - const timeoutRes = await withCache('getTimeoutResponseRate', () => getTimeoutResponseRate(hasParams ? params : undefined), hasParams ? params : {}) + const timeoutRes = await getTimeoutResponseRate(hasParams ? params : undefined) if (timeoutRes.code === 200) { statisticsData.timeoutResponseRate = timeoutRes.data.overtime_rate_600 statisticsData.severeTimeoutRate = timeoutRes.data.overtime_rate_800 @@ -434,7 +382,7 @@ async function getUrgentProblem() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getProblemDistribution', () => getProblemDistribution(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getProblemDistribution(hasParams ? params : undefined) if(res.code === 200) { // 将API返回的对象格式转换为数组格式 const problemDistributionCount = res.data.problem_distribution_count @@ -453,7 +401,7 @@ async function getTimeline() { const params = getRequestParams() const hasParams = params.user_name // 前6个阶段 - const res = await withCache('getCustomerAttendance', () => getCustomerAttendance(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getCustomerAttendance(hasParams ? params : undefined) if(res.code === 200) { // 处理时间线数据 if (res.data.timeline) { @@ -471,7 +419,7 @@ async function getTimeline() { } } // 后4个阶段 - const classRes = await withCache('getCustomerAttendanceAfterClass4', () => getCustomerAttendanceAfterClass4(hasParams ? params : undefined), hasParams ? params : {}) + const classRes = await getCustomerAttendanceAfterClass4(hasParams ? params : undefined) if(classRes.code === 200) { // 处理课1-4阶段的客户数据 if (classRes.data.class_customers_list) { @@ -547,7 +495,7 @@ async function getTimeline() { } } // 成交阶段 - const payRes = await withCache('getPayMoneyCustomers', () => getPayMoneyCustomers(hasParams ? params : undefined), hasParams ? params : {}) + const payRes = await getPayMoneyCustomers(hasParams ? params : undefined) if(payRes.code === 200) { // 处理成交阶段的客户数据 if (payRes.data.pay_money_customers_list) { @@ -577,7 +525,7 @@ async function getCustomerForm() { customer_name: selectedContact.value.name, } try { - const res = await withCache('getCustomerFormInfo', () => getCustomerFormInfo(params), params) + const res = await getCustomerFormInfo(params) if(res.code === 200) { formInfo.value = res.data } @@ -596,7 +544,7 @@ async function getCustomerChat() { customer_name: selectedContact.value.name, } try { - const res = await withCache('getCustomerChatInfo', () => getCustomerChatInfo(params), params) + const res = await getCustomerChatInfo(params) if(res.code === 200) { chatRecords.value = res.data } else { @@ -617,7 +565,7 @@ async function getCustomerCall() { customer_name: selectedContact.value.name, } try { - const res = await withCache('getCustomerCallInfo', () => getCustomerCallInfo(params), params) + const res = await getCustomerCallInfo(params) if(res.code === 200) { callRecords.value = res.data console.log('Call Records Data from API:', res.data) @@ -631,6 +579,7 @@ async function getCustomerCall() { const kpiData = computed(() => kpiDataState); // COMPUTED PROPERTIES const selectedContact = computed(() => { + console.log(999999999,formattedCustomersList.value); // 优先从API数据中查找 if (formattedCustomersList.value.length > 0) { return formattedCustomersList.value.find((c) => c.id === selectedContactId.value) || null; @@ -672,6 +621,7 @@ const formattedCustomersList = computed(() => { } return customersList.value?.map(customer => ({ + wechat_id: customer.customer_wechat_id, id: customer.customer_name, // 使用客户姓名作为唯一标识 name: customer.customer_name, phone: customer.phone, @@ -871,7 +821,7 @@ const SalesFunnel = ref([]) async function CenterGetSalesFunnel() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getSalesFunnel', () => getSalesFunnel(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getSalesFunnel(hasParams ? params : undefined) if(res.code === 200){ SalesFunnel.value = res.data /** @@ -894,56 +844,15 @@ const goldContactTime = ref([]) async function CenterGetGoldContactTime() { const params = getRequestParams() const hasParams = params.user_name - const res = await withCache('getGoldContactTime', () => getGoldContactTime(hasParams ? params : undefined), hasParams ? params : {}) + const res = await getGoldContactTime(hasParams ? params : undefined) if(res.code === 200){ goldContactTime.value = res.data } } -// 缓存管理功能 -// 清除所有缓存 -function clearCache() { - cache.clear() -} - -// 清除特定缓存 -function clearSpecificCache(apiName, params = {}) { - const key = getCacheKey(apiName, params) - cache.delete(key) - console.log(`已清除缓存: ${key}`) -} - -// 获取缓存信息并清理过期缓存 -function getCacheInfo() { - const now = Date.now() - const validCaches = [] - const expiredCaches = [] - - for (const [key, data] of cache.entries()) { - if (isValidCache(data)) { - validCaches.push({ - key, - timestamp: data.timestamp, - age: Math.round((now - data.timestamp) / 1000) + 's' - }) - } else { - expiredCaches.push(key) - cache.delete(key) - } - } - - return { - validCount: validCaches.length, - expiredCount: expiredCaches.length, - validCaches, - expiredCaches - } -} - -// 强制刷新所有数据（清除缓存并重新调用所有API） +// 强制刷新所有数据（重新调用所有API） async function forceRefreshAllData() { console.log('开始强制刷新所有数据...') - clearCache() // 重新调用所有API await Promise.all([ @@ -951,7 +860,6 @@ async function forceRefreshAllData() { getStatisticsData(), getUrgentProblem(), getTimeline(), - getCustomerPayMoney(), CenterGetSalesFunnel(), CenterGetGoldContactTime(), // 客户相关数据需要在选中客户后才能获取 @@ -975,19 +883,11 @@ onMounted(async () => { await getUrgentProblem() await getCustomerCall() await getTimeline() - await getCustomerPayMoney() - // 输出初始缓存信息 - getCacheInfo() - - // 开发环境下暴露缓存管理函数到全局对象，方便调试 + // 开发环境下暴露数据刷新函数到全局对象，方便调试 if (process.env.NODE_ENV === 'development') { - window.saleCache = { - clearCache, - clearSpecificCache, - getCacheInfo, - forceRefreshAllData, - cache + window.saleData = { + forceRefreshAllData } } diff --git a/my-vue-app/src/views/test/CacheTest.vue b/my-vue-app/src/views/test/CacheTest.vue new file mode 100644 index 0000000..17072be --- /dev/null +++ b/my-vue-app/src/views/test/CacheTest.vue @@ -0,0 +1,173 @@ + + + + + \ No newline at end of file