newAgent.git - Gitblit

			@@ -1,7 +1,12 @@
			<template>
			<div class="chartBox">
			<div class="ChartBox">
			<JwChat-index :taleList="list" @enter="bindEnter" v-model="inputMsg" :toolConfig="tool">
			<JwChat-index
			:taleList="list"
			@enter="bindEnter"
			v-model="inputMsg"
			:toolConfig="tool"
			>
			</JwChat-index>
			</div>
			</div>
			@@ -12,9 +17,14 @@
			import msgData from "../../assets/js/msg/msgData";
			import store from "../../store";
			import bus from "./../../assets/js/bus.js";
			import { getAgentThistoryUpdate, getAgentIntention, getAgentLayerList, getAgentThistorySave } from "../../api/api.js";
			import {
			getAgentThistoryUpdate,
			getAgentIntention,
			getAgentLayerList,
			getAgentThistorySave,
			} from "../../api/api.js";
			import mapSetFunc from "../../assets/js/mapSetFunc.js";
			import { nanoid } from 'nanoid'
			import { nanoid } from "nanoid";
			import mapServer from "../../assets/js/map/mapServer.js";
			import mapImg from "../../assets/js/map/mapImg.js";
			import mapModel from "../../assets/js/map/mapModel.js";
			@@ -32,20 +42,20 @@
			obj: null,
			tool: {
			show: ["file", "history", "img"],
			callback: this.toolEvent
			callback: this.toolEvent,
			},
			config: {
			img: "/image/cover.png",
			name: "JwChat",
			dept: "最简单、最便捷",
			callback: this.bindCover
			}
			callback: this.bindCover,
			},
			};
			},
			computed: {
			Obj() {
			return store.state.setMsgData;
			}
			},
			},
			watch: {
			Obj(newVal, oldVal) {
			@@ -63,7 +73,7 @@
			this.list[this.list.length - 1].text = newVal;
			}
			}
			}
			},
			},
			mounted() {
			this.uuid = nanoid();
			@@ -78,7 +88,6 @@
			// modelLayer.init();
			setTimeout(() => {
			this.getMsg("ai", "您好，请输入指令");

			}, 1000);

			bus.$on("mapInfo", (res) => {
			@@ -107,16 +116,15 @@
			createSocket() {
			this.wsSocket = new WebSocket(config.wsHost);
			this.wsSocket.onopen = (event) => {
			console.log('WebSocket连接成功');
			console.log("WebSocket连接成功");
			//定时任务，由于使用nginx反向代理，60秒无数据传输会断开
			var timer = setInterval(() => {
			if ( this.wsSocket.readyState == 1) {
			if (this.wsSocket.readyState == 1) {
			this.wsSocket.send("心跳包检测");
			} else {
			//IM连接已断开
			}
			}, 50 * 1000);

			};
			this.wsSocket.onmessage = (event) => {
			// console.log('Received message:', event.data);
			@@ -124,29 +132,25 @@

			if (event.data != "连接成功") {
			console.log(event.data);
			const val = JSON.parse(event.data)
			const val = JSON.parse(event.data);
			if (val.session_id == this.uuid) {
			this.setMapfunc(val, this.obj)
			this.setMapfunc(val, this.obj);
			}
			}

			}
			};
			},
			async getQueryLayerList() {
			getAgentLayerList().then(response => {
			getAgentLayerList().then((response) => {
			if (response.code != 200) return;
			const items = response.data;
			for (var i in items) {
			const name = items[i].name;
			if (
			name != "FW20" && name != "FW12"
			) {
			mapServer.addServer(items[i])
			if (name != "FW20" && name != "FW12") {
			console.log("items[i]", items[i]);
			mapServer.addServer(items[i]);
			}

			}

			})
			});
			},
			bindEnter() {
			const msg = this.inputMsg;
			@@ -173,7 +177,9 @@
			2
			);
			mapImg.addImageLayer();
			var roleMsg1 = msgData.getAffairsData([{ type: "text", val: "相关信息已在地图展示" }]);
			var roleMsg1 = msgData.getAffairsData([
			{ type: "text", val: "相关信息已在地图展示" },
			]);
			this.refashMsg(roleMsg1.list);
			},
			getMsg(type, msg) {
			@@ -200,84 +206,85 @@
			2
			);

			const formData = new FormData();
			formData.append("message", res);
			formData.append("lib_id", "No1");
			formData.append("session_id", this.uuid.toString());
			// const formData = new FormData();
			// formData.append("message", res);
			// formData.append("lib_id", "No1");
			// formData.append("session_id", this.uuid.toString());
			const formData = {
			message: res,
			lib_id: "No1",
			session_id: this.uuid.toString(),
			};

			var obj = {
			"ai": "",
			"create_time": msgData.getDate1(),
			"human": res,
			"sessionid": this.uuid,
			"update_time": "",
			"userid": 0
			}
			ai: "",
			create_time: msgData.getDate1(),
			human: res,
			sessionid: this.uuid,
			update_time: "",
			userid: 0,
			};

			getAgentThistorySave(
			obj
			).then(response => {

			getAgentThistorySave(obj).then((response) => {
			if (response.code == 200) {
			obj.id = response.id;
			this.obj = obj;
			}

			this.setAgentIntention(obj, formData)
			})




			this.setAgentIntention(obj, formData);
			});
			},
			async setAgentIntention(obj, formData) {
			getAgentIntention(formData).then((response) => {

			if (response.code != 200) {
			var rolMsg = [
			{
			type: "text",
			val: "未查询到相关信息。"
			}
			val: "未查询到相关信息。",
			},
			];
			this.refashMsg(rolMsg);
			return;
			}


			const type = response.type;
			if (type == "Map") {
			this.setMapfunc(response.content, obj);
			} else if (type == "Rag") {
			this.setMapRag(response, obj);
			} else {
			this.setMapfunc(response.content, obj);
			}
			});
			},
			setMapfunc(res, obj) {
			this.$store.state.showLenged = false;

			switch (res.func) {
			case "queryRelationship":

			var roleMsg = null;
			if (res.data) {
			mapSetFunc.init(res)
			mapSetFunc.init(res);
			var a = `${res.msg}`;
			this.setUpdateHistoryInFor(obj, a);
			roleMsg = msgData.getMdData("markdown", a);
			} else {
			roleMsg = msgData.getAffairsData([{ type: "text", val: res.msg }]);

			}

			this.refashMsg(roleMsg.list);
			break;
			case "queryMeta":
			var a = `${res.data}`;
			// var a = `\|数据类型 \|数据量 \|\n\|------\|------\|\n\|军事目标 \|724\|\n\|`//`${res.data}`;
			const subData = res.data
			.filter((item) => item.subtype !== null)
			.map((item) => `\| ${item.subtype} \| ${item.count} \|`)
			.join("\n");
			var a = `\| 数据类型 \| 数据量 \|\n\|------\|------\|\n` + subData;
			console.log("aaa", subData, a);
			this.setUpdateHistoryInFor(obj, a);
			var roleMsg = msgData.getMdData("markdown", a);
			this.refashMsg(roleMsg.list);
			mapSetFunc.init(res)
			mapSetFunc.init(res);
			break;
			case "combatSimulate":
			this.setMsgStart2();
			@@ -287,11 +294,9 @@
			this.refashMsg(roleMsg1.list);
			break;
			case "batEnv":

			if (res.msg) {
			var a = `${res.msg}`;
			var roleMsg = msgData.getMdData("markdown", a);


			roleMsg.list[0].link = true;

			@@ -303,15 +308,69 @@

			break;
			case "poiMap":
			case "aroundPoi":
			mapSetFunc.init(res)
			mapSetFunc.init(res);
			this.setUpdateHistoryInFor(obj, res.msg);
			var roleMsg = msgData.getAffairsData([{ type: "text", val: res.msg }]);
			var roleMsg = msgData.getAffairsData([
			{ type: "text", val: "地图已显示" },
			]);
			console.log("roleMsg----", roleMsg);
			this.refashMsg(roleMsg.list);
			break;
			case "aroundPoi":
			let dataList = [
			{
			type: "可打击目标",
			color:'#FF3366',
			list: [],
			},
			{
			type: "不可打击目标",
			color:'#33FF66',
			list: [],
			},
			{
			type: "其他",
			color:'#3366FF',
			list: [],
			},
			];
			res.data.forEach((item) => {
			if (item.ifstrike === "1") {
			dataList[0].list.push(item.seid);
			} else if (item.ifstrike === "2") {
			dataList[1].list.push(item.seid);
			} else {
			dataList[2].list.push(item.seid);
			}
			});
			const resultData = dataList
			.map((item) => `\| ${item.type} \| ${item.list.length} \|`)
			.join("\n");
			var a = `\| 数据类型 \| 数据量 \|\n\|------\|------\|\n`+resultData;
			console.log("aaa", a);
			this.setUpdateHistoryInFor(obj, a);
			var roleMsg = msgData.getMdData("markdown", a);
			this.refashMsg(roleMsg.list);
			const finalData = {
			func: "aroundPoi",
			data: dataList,
			}
			mapSetFunc.init(finalData);
			break;
			case "getParam":
			mapSetFunc.init(res);
			console.log("res.data.targetinfo", res);
			this.setUpdateHistoryInFor(obj, res.msg);
			var roleMsg = msgData.getAffairsData([
			{ type: "text", val: res.data[0].targetinfo },
			]);
			this.refashMsg(roleMsg.list);
			break;
			default:
			this.setUpdateHistoryInFor(obj, res.msg);
			var roleMsg1 = msgData.getAffairsData([{ type: "text", val: res.msg }]);
			var roleMsg1 = msgData.getAffairsData([
			{ type: "text", val: res.msg },
			]);
			this.refashMsg(roleMsg1.list);
			break;
			}
			@@ -319,10 +378,9 @@
			setUpdateHistoryInFor(obj, message) {
			obj.ai = message;
			obj.update_time = msgData.getDate1();
			getAgentThistoryUpdate(obj).then(response => {
			getAgentThistoryUpdate(obj).then((response) => {
			console.log(response);

			})
			});
			},
			setMapRag(res, objRes) {
			const val = res.content.split("\n");
			@@ -331,8 +389,8 @@
			if (val[i]) {
			obj.push({
			type: "text",
			val: val[i]
			})
			val: val[i],
			});
			}
			}
			var listData = [];
			@@ -340,52 +398,46 @@
			var obj_file = res.fileSrource;
			for (var i = 0; i < obj_file.length; i++) {
			const file_name = obj_file[i].metadata.split("/");
			const name = file_name[file_name.length - 1]
			const name = file_name[file_name.length - 1];
			if (listData.length == 0) {
			listData.push({
			name: name,
			val: [
			obj_file[i].page_content
			]
			})
			val: [obj_file[i].page_content],
			});
			} else {
			var boolen = false;
			for (var k in listData) {
			if (listData[k].name == name) {
			boolen = true;
			listData[k].val.push(obj_file[i].page_content)
			listData[k].val.push(obj_file[i].page_content);
			}
			}
			if (boolen == false) {
			listData.push({
			name: name,
			val: [
			obj_file[i].page_content
			]
			})
			val: [obj_file[i].page_content],
			});
			}

			}
			}
			}
			if (listData.length > 0) {
			obj.push({
			type: "fileSrource",
			val: listData
			})
			val: listData,
			});
			}

			var roleMsg = msgData.getAffairsData(obj);

			this.setUpdateHistoryInFor(objRes, JSON.stringify(roleMsg.list));
			this.refashMsg(roleMsg.list);

			},
			refashMsg(res) {
			this.loading = false;
			this.list[this.list.length - 1].list = res;
			}
			}
			},
			},
			};
			</script>
			<style scoped>