.env.development

@@ -5,9 +5,9 @@ VITE_APP_TITLE = 蓝天燃气智慧话务系统
 VITE_APP_ENV = 'development'
 
 # VITE_APP_BASE_API = 'http://192.168.1.15:8160/'  # 接口地址
+#  VITE_APP_BASE_API = 'http://39.164.159.226:8160/'  # 接口地址
  VITE_APP_BASE_API = 'http://192.168.1.170:8160/'  # 接口地址
 
-# VITE_APP_BASE_API = 'http://192.168.1.170:8160/'  # 接口地址
 # VITE_APP_BASE_API = 'http://412ym2dg6665.vicp.fun/'  # 接口地址
 
 VITE_APP_BASE_WS = 'ws://192.168.1.19:9000/ws'

src/views/main/chat/online/cpns/borderRight/borderRight.vue

@@ -127,18 +127,25 @@
           
           <!-- 其他标签页 - 保留标签结构但移除未使用的组件 -->
           <template v-else-if="tab.name === 'subscribe'">
+            <subscribe :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'payment'">
+            <PayRecord :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'meterReading'">
+            <MeterReading :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'overdue'">
+            <OweFee :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'meterInfo'">
+            <MeterBasicInfo :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'security'">
+            <seOrder :userNo="customerInfo.customerNo" />
           </template>
           <template v-else-if="tab.name === 'ticket'">
+            <woOrder :userNo="customerInfo.customerNo" />
           </template>
         </el-tab-pane>
       </el-tabs>
@@ -244,11 +251,19 @@ import { getPageListData ,deletePageData } from '@/api/main/system/system';
 import request from '@/utils/request';
 import { userToAsterisk } from '@/utils/aes';
 import useSelectStore from '@/store/commonSelect/common';
+import { getToken } from '@/utils/auth'
 
+import subscribe from '@/components/conInfor/subscribe/index.vue' // 预约记录
+import PayRecord from '@/components/conInfor/payrecord/index.vue' // 缴费明细
+import MeterReading from '@/components/conInfor/meterReading/index.vue' // 抄表记录
+import OweFee from '@/components/conInfor/owefee/index.vue'  // 欠费记录
+import MeterBasicInfo from '@/components/conInfor/meterBasicInfo/index.vue' // 表具信息
+import seOrder from '@/components/conInfor/seOrder/index.vue' // 安检工单
+import woOrder from '@/components/conInfor/woOrder/index.vue' // 工单信息
 // 标签页状态
 const activeName = ref('first');
 const isIntelligentFlag = ref(useSelectStore().isIntelligentFlag)
-
+const getOpenId = ref('')
 // 客户信息数据
 const customerInfo = ref({
   customerNo: '',
@@ -349,7 +364,24 @@ const userSearchLoading = ref(false);
 // 关联患者
 const associatedPatient = async () => {
   try {
-    ElMessage.warning('请先选择客户');
+    if (!AssociaPatientId.value) {
+      ElMessage.warning('请先选择客户');
+      return;
+    }
+    if (!getOpenId.value) {
+      ElMessage.warning('请先选择聊天对象');
+      return;
+    }
+    const params = {
+      patientId: AssociaPatientId.value,
+      openId: getOpenId.value
+    };
+    const res = await getPageListData('/patient/patient/associated', params);
+    if (res.state === 'success') {
+      ElMessage.success('关联成功');
+    } else {
+      ElMessage.error(res.message || '关联失败');
+    }
   } catch (error) {
     console.error('关联患者失败:', error);
     ElMessage.error('关联失败，请重试');
@@ -497,7 +529,168 @@ function delQuickMsg(rowData) {
     console.log('取消删除');
   });
 }
+// 搜索关键词
+const searchKeyword = ref('');
+const recommendations = ref([]);
+
+function searchRecommendations() {
+    knowledgeLoading.value = true;
+    if (searchKeyword.value) {
+        aiKnowledge(searchKeyword.value).then(res => {}).finally(() => {
+            knowledgeLoading.value = false;
+        })
+    } else {
+        ElMessage({
+        message: '请输入关键词',
+        type: 'warning'
+        });
+    }
+}
+const knowledgeLoading = ref(false)
+const aiKnowledge = async (text) => {
+    
+    // 构建对话文本
+    // let text = '热点问题请注意'
+    knowledgeObj.value = ''
+    if (text) {
+        // 获取AI分析结果
+        let res = await getKnowledgeDocs(text);
+        // 移除思考过程
+        if (knowledgeObj.value) {
+            const obj = {
+                content: knowledgeObj.value,
+                // type: knowledgeObj.value.intention,
+                source: "AI 推荐",
+                time: moment().format('HH:mm:ss'), // 当前时间时分秒
+            }
+            recommendations.value.splice(0,0,obj)
+        }
+        
+    }
+}
+const knowledgeObj = ref('')
+const workflow_run_id = ref('')
+const getKnowledgeDocs = async (text) => {
+    
+    // const params = {
+    //     "id": 6,
+    //     "inputs": {"type": "zsk","text":text}
+    // };
+   
+    // if (workflow_run_id.value) {
+    //     params.inputs.workflowrunid = workflow_run_id.value
+    // }
+    const params = {
+        "auto_generate_name": false,
+        "conversation_id": "",
+        "files": [],
+        "id": 8,
+        "inputs": {},
+        "query": text
+    };
+    if (workflow_run_id.value) {
+        params.conversation_id = workflow_run_id.value
+    }
+    try {
+        // 发送请求
+        // const url = import.meta.env.VITE_APP_AI_API || 'https://open.bigmodel.cn/api/paas/v4/chat/completions'
+        // const url = import.meta.env.VITE_APP_BASE_API+'/dify/difyassistant/workflows'  
+        const url = import.meta.env.VITE_APP_BASE_API+ '/dify/difyassistant/chatMessages'
+        console.log(url,params)
+        let response = await fetch(url,
+            {
+                method: "post",
+                responseType: "stream",
+                headers: {
+                    "Content-Type": "application/json",
+                    "Authorization": "Bearer "+getToken(),
+                },
+                body: JSON.stringify(params),
+            }
+        );
+
+        let resultStr = '';
+
+        // ok字段判断是否成功获取到数据流
+        if (!response.ok) {
+            throw new Error("Network response was not ok");
+        }
+        // 用来获取一个可读的流的读取器（Reader）以流的方式处理响应体数据
+        const reader = response.body.getReader();
+        // 将流中的字节数据解码为文本字符串
+        const textDecoder = new TextDecoder();
+        let result = true;
+        let sqlValue = ''
+
+        while (result) {
+            // done表示流是否已经完成读取  value包含读取到的数据块
+            const { done, value } = await reader.read();
+            if (done) {
+                result = false;
+                return resultStr;
+                break;
+            }
+            // 拿到的value就是后端分段返回的数据，大多是以data:开头的字符串
+            // 需要通过decode方法处理数据块，例如转换为文本或进行其他操作
+            const chunkText = textDecoder.decode(value).split("\n").forEach((val) => {
+                if (!val) return;
+                try {
+                    // 后端返回的流式数据一般都是以data:开头的字符，排除掉data:后就是需要的数据
+                    // 具体返回结构可以跟后端约定
+                    let text = val?.replace("data:", "") || ""
+                    const resultData = JSON.parse(text)
+                    let resultText = resultData.answer || ''
+                    workflow_run_id.value = resultData.conversation_id
+                    knowledgeObj.value += resultText
+                    console.log(knowledgeObj.value)
+                } catch (err) { }
+            });
+        }
+
+    } catch (err) {
+        console.error('获取客户信息异常:', err);
+        return err;
+    }
+}
+const dealChatMessage = (msg) => {
+    if (msg.detail && msg.detail.content && isIntelligentFlag.value ==='true') {
+      aiKnowledge(msg.detail.content)
+    }
+   
+}
+// 获取客户信息详情
+async function getchatDetail(openId) {
+  getOpenId.value = openId
+  console.log(getOpenId.value)
+  // if (getOpenId.value) window.addEventListener(`ChatMessageEvent-${getOpenId.value}`, dealChatMessage)
+  if (!getOpenId.value) {
+    ElMessage.warning('请提供有效的openId');
+    return;
+  }
+  
+  try {
+    const res = await request.get('/patient/patient', {
+      params: { openId }
+    });
+    
+    if (res.state === 'success' && res.data) {
+      // 更新客户信息
+      customerInfo.value = res.data[0];
+      // 对手机号和身份证号进行掩码处理
+      customerInfo.value.phoneNumber =   customerInfo.value.phoneNumber ? userToAsterisk(customerInfo.value.phoneNumber) : '';
+      customerInfo.value.idcard =   customerInfo.value.idcard ? userToAsterisk(customerInfo.value.idcard) : '';
+      customerInfo.value.tel =   customerInfo.value.tel ? userToAsterisk(customerInfo.value.tel) : '';
+    } else {
+      ElMessage.error('获取客户信息失败');
+      console.error('获取客户信息失败:', res.message);
+    }
+  } catch (error) {
+    ElMessage.error('获取客户信息异常');
+    console.error('获取客户信息异常:', error);
+  }
+}
 defineExpose({
+  getchatDetail,
   getQuickMsgList
 })
 </script>