|
|
@@ -15,11 +15,12 @@ import { useInfinite } from '@/composables/useInfinite';
|
|
|
import { useRecommend } from '@/composables/useRecommend';
|
|
|
import { useFetchStream } from '@/composables/useFetchStream';
|
|
|
import { useScroll } from '@/composables/useScroll';
|
|
|
+import { SIMULATE_ENUM } from './components/config';
|
|
|
|
|
|
const { recommendList } = useRecommend({type: 1});
|
|
|
-const { scrollRef, scrollToTop, scrollToBottomIfAtBottom } = useScroll();
|
|
|
+const { scrollRef, scrollToTop, scrollToBottom, scrollToBottomIfAtBottom } = useScroll();
|
|
|
const { refetch, cancelFetch } = useFetchStream("/grpc/decisionStream", { methdos: 'POST' }, false);
|
|
|
-const { recordList, isFetching, onScrolltolower, onRestore, addHistoryRecord } = useInfinite('/front/bigModel/warning/pageList', { type: 0, warningStatus: 0 });
|
|
|
+const { recordList, isFetching, onScrolltolower, onRestore } = useInfinite('/front/bigModel/warning/pageList', { type: 0, warningStatus: 0 });
|
|
|
|
|
|
const router = useRouter();
|
|
|
const chatStore = useChatStore();
|
|
|
@@ -31,7 +32,7 @@ const flowParams = {
|
|
|
feedback: '',
|
|
|
category: '',
|
|
|
warningId: '',
|
|
|
- simulate: null
|
|
|
+ simulate: '{}'
|
|
|
};
|
|
|
|
|
|
const answerLoading = ref(false);
|
|
|
@@ -109,67 +110,124 @@ const columns = [
|
|
|
}
|
|
|
]
|
|
|
|
|
|
-
|
|
|
-// 新建对话
|
|
|
-const handleCreateDialog = () => {
|
|
|
- console.log("handleCreateDialog");
|
|
|
-}
|
|
|
-
|
|
|
-const handleLoad = () => {
|
|
|
- console.log("loading")
|
|
|
-}
|
|
|
-
|
|
|
const handleModelVisible = () => {
|
|
|
visible.value = true;
|
|
|
}
|
|
|
|
|
|
+const resetConfiguration = () => {
|
|
|
+ /**
|
|
|
+ * 临时这样，后续统一处理
|
|
|
+ * */
|
|
|
+ textDataSources.value = '';
|
|
|
+ answerLoading.value = false;
|
|
|
+ answerResult.value = [];
|
|
|
+ flowParams.feedback = '';
|
|
|
+ flowParams.category = '';
|
|
|
+ flowParams.warningId = '';
|
|
|
+ flowParams.simulate = '{}';
|
|
|
+ cancelFetch();
|
|
|
+}
|
|
|
+
|
|
|
/**
|
|
|
* 报警详情
|
|
|
*/
|
|
|
const handleOpenContent = async ({ id, category }) => {
|
|
|
|
|
|
if ( id == flowParams.warningId ) return;
|
|
|
-
|
|
|
+
|
|
|
flowParams.category = category;
|
|
|
flowParams.warningId = id;
|
|
|
+ flowParams.feedback = '';
|
|
|
+ flowParams.simulate = '{}';
|
|
|
+ answerLoading.value = false;
|
|
|
+ cancelFetch();
|
|
|
|
|
|
const { data } = await waterApi.getWaringDetails(id);
|
|
|
+ const res = await waterApi.getWaringForecast(id);
|
|
|
+
|
|
|
const showVal = JSON.parse(data.showVal);
|
|
|
const { basic, jsData, csData } = showVal;
|
|
|
const answer = JSON.parse(data.answer);
|
|
|
- const [ answerStrItem ] = answer;
|
|
|
- const answerObjItem = JSON.parse( answerStrItem );
|
|
|
-
|
|
|
+
|
|
|
cancelFetch();
|
|
|
|
|
|
answerResult.value = [];
|
|
|
|
|
|
- const textWhiteList = [
|
|
|
- { label: '报警时间', realKey: '报警时间', value: '', isWarning: false },
|
|
|
- { label: '报警值', realKey: '报警值', value: 'mg/L', isWarning: true },
|
|
|
- { label: '管控值', realKey: '管控值', value: 'mg/L', isWarning: false },
|
|
|
- { label: '标准值', realKey: '标准值', value: 'mg/L', isWarning: false },
|
|
|
- { label: '报警级别', realKey: '告警级别', value: '', isWarning: false },
|
|
|
- { label: '报警次数', realKey: '报警次数', value: '', isWarning: false },
|
|
|
- { label: '状态', realKey: '状态', value: '', isWarning: false }
|
|
|
- ]
|
|
|
+ const reportList = [];
|
|
|
+ const alertList = [];
|
|
|
+
|
|
|
+ answer.map(item => {
|
|
|
+
|
|
|
+ const answerObjItem = JSON.parse( item );
|
|
|
+
|
|
|
+ if ( answerObjItem.biz === "DECISION_REPORT" ) {
|
|
|
+ reportList.push(answerObjItem.message);
|
|
|
+
|
|
|
+ // const answerContent = answer.map(item => {
|
|
|
+ // const itemParse = JSON.parse(item);
|
|
|
+ // return itemParse.message;
|
|
|
+ // }).join("");
|
|
|
+
|
|
|
+ // answerResult.value.push({
|
|
|
+ // biz: 'DECISION_REPORT',
|
|
|
+ // answer: answerContent,
|
|
|
+ // loading: false,
|
|
|
+ // delayLoading: false
|
|
|
+ // })
|
|
|
+ }
|
|
|
+
|
|
|
+ if( answerObjItem.biz === "DECISION_ALERT" ) {
|
|
|
+ alertList.push(item);
|
|
|
+ // const [ parseAnswer ] = answer.map(item => {
|
|
|
+ // const result = JSON.parse( item );
|
|
|
+ // result.message = Object.keys(result.message).map(key => ({ ...result.message[key], isActive: null }));
|
|
|
+ // return result;
|
|
|
+ // })
|
|
|
+
|
|
|
+ // answerResult.value.push({
|
|
|
+ // biz: 'DECISION_ALERT',
|
|
|
+ // loading: false,
|
|
|
+ // delayLoading: false,
|
|
|
+ // isAllSelect: false,
|
|
|
+ // list: parseAnswer?.message
|
|
|
+ // })
|
|
|
+ }
|
|
|
+
|
|
|
+ if (answerObjItem.biz === "DECISION_SIMULATE") {
|
|
|
+
|
|
|
+
|
|
|
|
|
|
- if ( answerObjItem.biz === "DECISION_REPORT" ) {
|
|
|
+ // const usefulkeys = ['on', 'off'];
|
|
|
+ // const resultObj = {};
|
|
|
|
|
|
- const answerContent = answer.map(item => {
|
|
|
- const itemParse = JSON.parse(item);
|
|
|
- return itemParse.message;
|
|
|
- }).join("");
|
|
|
+ // usefulkeys.forEach(key => {
|
|
|
+ // const tempArr = data[key];
|
|
|
|
|
|
+ // resultObj[key] = tempArr.map(item => {
|
|
|
+ // return {
|
|
|
+ // ...item,
|
|
|
+ // label: SIMULATE_ENUM[item.name],
|
|
|
+ // inpVal: Array.isArray( item.value ) ? item.value.join() : item.value,
|
|
|
+ // errMsg: ''
|
|
|
+ // }
|
|
|
+ // })
|
|
|
+ // })
|
|
|
+ }
|
|
|
+
|
|
|
+ })
|
|
|
+
|
|
|
+ if ( reportList.length ) {
|
|
|
+ const answerContent = reportList.join("");
|
|
|
answerResult.value.push({
|
|
|
biz: 'DECISION_REPORT',
|
|
|
answer: answerContent,
|
|
|
loading: false,
|
|
|
delayLoading: false
|
|
|
})
|
|
|
+ }
|
|
|
|
|
|
- } else {
|
|
|
- const [ parseAnswer ] = answer.map(item => {
|
|
|
+ if ( alertList.length ) {
|
|
|
+ const [ parseAnswer ] = alertList.map(item => {
|
|
|
const result = JSON.parse( item );
|
|
|
result.message = Object.keys(result.message).map(key => ({ ...result.message[key], isActive: null }));
|
|
|
return result;
|
|
|
@@ -183,7 +241,28 @@ const handleOpenContent = async ({ id, category }) => {
|
|
|
})
|
|
|
}
|
|
|
|
|
|
- console.log( basic );
|
|
|
+ // console.log( "reportList", reportList );
|
|
|
+ // console.log( "alertList", alertList );
|
|
|
+ // const [ answerStrItem ] = answer;
|
|
|
+ // const answerObjItem = JSON.parse( answerStrItem );
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ // console.log( "answerObjItem", answer, JSON.parse(answerObjItem.message) );
|
|
|
+ const textWhiteList = [
|
|
|
+ { label: '报警时间', realKey: '报警时间', value: '', isWarning: false },
|
|
|
+ { label: '报警值', realKey: '报警值', value: 'mg/L', isWarning: true },
|
|
|
+ { label: '管控值', realKey: '管控值', value: 'mg/L', isWarning: false },
|
|
|
+ { label: '标准值', realKey: '标准值', value: 'mg/L', isWarning: false },
|
|
|
+ { label: '报警级别', realKey: '告警级别', value: '', isWarning: false },
|
|
|
+ { label: '报警次数', realKey: '报警次数', value: '', isWarning: false },
|
|
|
+ { label: '数据来源', realKey: '数据来源', value: '', isWarning: false },
|
|
|
+ { label: '状态', realKey: '状态', value: '', isWarning: false }
|
|
|
+ ]
|
|
|
+
|
|
|
+ basic['数据来源'] = '在线仪表';
|
|
|
+
|
|
|
textDataSources.value = format.textSorting(basic, textWhiteList);
|
|
|
|
|
|
jsTableData.value = [jsData];
|
|
|
@@ -193,13 +272,11 @@ const handleOpenContent = async ({ id, category }) => {
|
|
|
}
|
|
|
|
|
|
const onChangeTabs = warningStatus => {
|
|
|
- textDataSources.value = '';
|
|
|
- answerLoading.value = false;
|
|
|
- answerResult.value = [];
|
|
|
- cancelFetch();
|
|
|
- onRestore({ warningStatus })
|
|
|
+ resetConfiguration();
|
|
|
+ onRestore({ warningStatus });
|
|
|
}
|
|
|
|
|
|
+// 生成流数据
|
|
|
const onRegenerate = async () => {
|
|
|
|
|
|
answerLoading.value = true;
|
|
|
@@ -215,7 +292,7 @@ const onRegenerate = async () => {
|
|
|
|
|
|
let tempSimulate = null;
|
|
|
|
|
|
- answerLoading.value = true;
|
|
|
+ answerLoading.value = answerResult.value[len -1 ].biz !== 'DECISION_TABLE';
|
|
|
|
|
|
const params = {
|
|
|
body: JSON.stringify(flowParams),
|
|
|
@@ -230,6 +307,7 @@ const onRegenerate = async () => {
|
|
|
|
|
|
if (item.biz === 'DECISION_REPORT') {
|
|
|
tempReport.answer += item.message;
|
|
|
+ tempReport.delayLoading = false;
|
|
|
answerResult.value[len] = { ...tempReport };
|
|
|
}
|
|
|
|
|
|
@@ -239,7 +317,7 @@ const onRegenerate = async () => {
|
|
|
answerResult.value.push({
|
|
|
biz: 'DECISION_ALERT',
|
|
|
loading: true,
|
|
|
- delayLoading: true,
|
|
|
+ delayLoading: false,
|
|
|
isAllSelect: false,
|
|
|
list
|
|
|
})
|
|
|
@@ -251,7 +329,7 @@ const onRegenerate = async () => {
|
|
|
if ( lastAnswerItem.biz === 'DECISION_TABLE' ) {
|
|
|
answerResult.value[len - 1] = {
|
|
|
...lastAnswerItem,
|
|
|
- content: JSON.parse(item.message).pred.join(",")
|
|
|
+ content: JSON.parse(item.message).pred.join(", ")
|
|
|
}
|
|
|
} else {
|
|
|
const { off, on, pred } = JSON.parse(item.message);
|
|
|
@@ -264,7 +342,6 @@ const onRegenerate = async () => {
|
|
|
}
|
|
|
modalData.value = tempSimulate;
|
|
|
}
|
|
|
- console.log("DECISION_SIMULATE")
|
|
|
}
|
|
|
|
|
|
scrollToBottomIfAtBottom();
|
|
|
@@ -272,16 +349,24 @@ const onRegenerate = async () => {
|
|
|
}
|
|
|
|
|
|
try {
|
|
|
- const res = await refetch(params);
|
|
|
- console.log( "最终", res );
|
|
|
+ await refetch(params);
|
|
|
+
|
|
|
const answerItem = answerResult.value[answerResult.value.length - 1];
|
|
|
if (answerItem?.biz) {
|
|
|
answerItem.loading = false;
|
|
|
answerItem.delayLoading = false;
|
|
|
+
|
|
|
+ if (answerItem.biz === 'DECISION_TABLE') {
|
|
|
+ scrollToBottom()
|
|
|
+ }
|
|
|
}
|
|
|
if (tempSimulate) {
|
|
|
answerResult.value.push(tempSimulate);
|
|
|
}
|
|
|
+
|
|
|
+ setTimeout(() => {
|
|
|
+ scrollToBottomIfAtBottom();
|
|
|
+ }, 500)
|
|
|
}
|
|
|
catch(error) {
|
|
|
console.log("exist error .....", error);
|
|
|
@@ -318,12 +403,12 @@ const handleSendSimulate = ({ simulate, table }) => {
|
|
|
const len = answerResult.value.length;
|
|
|
|
|
|
flowParams.simulate = simulate;
|
|
|
- answerResult.value[len - 1].isDisable = false;
|
|
|
+ answerResult.value[len - 1].isDisable = true;
|
|
|
|
|
|
answerResult.value.push({
|
|
|
biz: 'DECISION_TABLE',
|
|
|
loading: true,
|
|
|
- delayLoading: true,
|
|
|
+ delayLoading: false,
|
|
|
table,
|
|
|
isDisable: false
|
|
|
})
|
|
|
@@ -336,7 +421,6 @@ const handleWelcomeRecommend = question => {
|
|
|
chatStore.setChatQuestion(question);
|
|
|
router.push('/answer');
|
|
|
}
|
|
|
-
|
|
|
</script>
|
|
|
|
|
|
<template>
|
|
|
@@ -364,11 +448,10 @@ const handleWelcomeRecommend = question => {
|
|
|
</TheSubMenu>
|
|
|
|
|
|
<TheChatView ref="scrollRef" :is-footer="false">
|
|
|
-
|
|
|
<ChatWelcome title="您好,我是LibraAI工艺管控助手" card-title="常见处理方案："
|
|
|
:sub-title="[
|
|
|
- '报警分析功能具备实时监测与预警机制，检测到异常情况推送相关工作人员确保问题及时处理。',
|
|
|
- '报警时间为每小时警报，请大家及时处理。'
|
|
|
+ '水质报警功能针对五大核心指标实时监测，发现异常后将推送给相关人员决策方案',
|
|
|
+ '报警时间为每小时警报，请大家及时处理'
|
|
|
]"
|
|
|
:card-content="recommendList"
|
|
|
@on-click="handleWelcomeRecommend"
|
|
|
@@ -401,7 +484,7 @@ const handleWelcomeRecommend = question => {
|
|
|
</div>
|
|
|
</div>
|
|
|
</ChatBaseCard>
|
|
|
-
|
|
|
+
|
|
|
<section v-for="item,index in answerResult" :key="index">
|
|
|
<template v-if="item.biz === 'DECISION_REPORT'">
|
|
|
<ChatAnswer
|
|
|
@@ -411,7 +494,7 @@ const handleWelcomeRecommend = question => {
|
|
|
:content="item.answer"
|
|
|
></ChatAnswer>
|
|
|
</template>
|
|
|
- <!-- {{ item }} -->
|
|
|
+
|
|
|
<template v-if="item.biz === 'DECISION_ALERT'">
|
|
|
<ChatBaseCard
|
|
|
:loading="item.loading"
|
|
|
@@ -468,7 +551,7 @@ const handleWelcomeRecommend = question => {
|
|
|
</tbody>
|
|
|
</table>
|
|
|
<strong class="block mb-[16px]">预测推演结果：</strong>
|
|
|
- <span>出水硝酸盐：{{ item.content }}</span>
|
|
|
+ <span>未来三小时好氧池硝酸盐预测结果：{{ item.content }}</span>
|
|
|
</div>
|
|
|
</ChatAnswer>
|
|
|
<button class="
|
|
|
@@ -489,11 +572,10 @@ const handleWelcomeRecommend = question => {
|
|
|
:delay-loading="answerLoading"
|
|
|
:toggleVisibleIcons="false"
|
|
|
v-show="answerLoading"
|
|
|
+ loadingText="内容生成中，大概需要50秒..."
|
|
|
></ChatAnswer>
|
|
|
-
|
|
|
</TheChatView>
|
|
|
</section>
|
|
|
-
|
|
|
<CustomModal
|
|
|
v-model:visible="visible"
|
|
|
:current-data="modalData"
|
余尚辉
