Commit 92267adc authored by xinglei's avatar xinglei

提交代码

parent 4a076d4a
...@@ -389,7 +389,9 @@ export const SpcSerUrl = { ...@@ -389,7 +389,9 @@ export const SpcSerUrl = {
updateSelfUrl: completePrefix(baseURI, 'bank/topography/selfnodes'), //更新自建系统节点 updateSelfUrl: completePrefix(baseURI, 'bank/topography/selfnodes'), //更新自建系统节点
listSelfDevice: completePrefix(baseURI, 'bank/equipment/selfDevice?fname={fname}&pageNumber={page}&pageSize={size}'), listSelfDevice: completePrefix(baseURI, 'bank/equipment/selfDevice?fname={fname}&pageNumber={page}&pageSize={size}'),
getTopoTreeByTypeUrl: completePrefix(baseURI, 'bank/topography/treeByType/{type}') //监控系统树 getTopoTreeByTypeUrl: completePrefix(baseURI, 'bank/topography/treeByType/{type}'), //监控系统树
getNodesByTypeAndTreeIdUrl: completePrefix(baseURI, 'bank/topography/getNodesByTypeAndTreeId/{type}/{treeId}'), //根据类型查询拓扑图列表
saveNodesByTypeUrl: completePrefix(baseURI, 'bank/topography/saveNodesByType/{type}'), //保存拓扑图数据
}; };
export const patrolUrls = { export const patrolUrls = {
......
...@@ -6,3 +6,16 @@ import { commonPost, commonGet, formatUrl } from './../utils/request'; ...@@ -6,3 +6,16 @@ import { commonPost, commonGet, formatUrl } from './../utils/request';
export const getTopoTreeByTypeAction = (type) => { export const getTopoTreeByTypeAction = (type) => {
return commonGet(formatUrl(SpcSerUrl.getTopoTreeByTypeUrl, { type })); return commonGet(formatUrl(SpcSerUrl.getTopoTreeByTypeUrl, { type }));
}; };
// 拓扑图查询
export const getNodesByTypeAndTreeIdAction = (type, treeId) => {
console.log(treeId);
return commonGet(formatUrl(SpcSerUrl.getNodesByTypeAndTreeIdUrl, { type, treeId }));
};
// 拓扑图更新数据
export const saveNodesByTypeUrlAction = (type, params) => {
return commonPost(formatUrl(SpcSerUrl.saveNodesByTypeUrl, { type }), params);
};
...@@ -8,14 +8,13 @@ import TopologyComponent from './TopologyComponent'; ...@@ -8,14 +8,13 @@ import TopologyComponent from './TopologyComponent';
import TreeComponent from './TreeComponent'; import TreeComponent from './TreeComponent';
import mqtt from 'mqtt'; import mqtt from 'mqtt';
import * as endConf from 'amos-processor/lib/config/endconf'; import * as endConf from 'amos-processor/lib/config/endconf';
import { getSelfTopoTreeAction, getSelfTopographyAction, updateSelfTopographyAction, getTopographyEventsAction, getDeivceListAction } from './../../..//services/selfServices';
import { getTypeBySystem } from './conf'; import { getTypeBySystem } from './conf';
import { getTopoTreeByTypeAction } from 'SERVICES/monitorService'; import { getTopoTreeByTypeAction, getNodesByTypeAndTreeIdAction, saveNodesByTypeUrlAction } from 'SERVICES/monitorService';
import SysWsURL from './../../../consts/wsUrlConsts'; import SysWsURL from './../../../consts/wsUrlConsts';
const type = getTypeBySystem('SelfSupport'); const type = getTypeBySystem('CityLan');
//const type = getTypeBySystem('SelfSupport');
//偏移 //偏移
const offsetHeight = 110; const offsetHeight = 110;
...@@ -80,41 +79,6 @@ class FinancialCityLan extends Component { ...@@ -80,41 +79,6 @@ class FinancialCityLan extends Component {
} }
receivcemqtt = () => {
client.on('connect', (e) => {
console.log("连接成功!!!")
//QoS0,最多一次送达。也就是发出去就fire掉,没有后面的事情了。
// QoS1,至少一次送达。发出去之后必须等待ack,没有ack,就要找时机重发
// QoS2,准确一次送达。消息id将拥有一个简单的生命周期。
// client.subscribe('bank/equipment/ping', { qos: 1 }, (res) => {
client.subscribe('bank/equipment/ping', { qos: 1 }, (res) => {
if (!res) {
console.log('订阅成功');
} else {
console.log('订阅失败')
}
});
// 接收消息处理
client.on('message', (topic, message) => {
// console.log('收到来自', topic, '的消息', message.toString());
const { selectedKeys } = this.state;
this.initTopologyData(selectedKeys[0], '');
});
// 断开发起重连
client.on('reconnect', (error) => {
console.log('正在重连:', error)
});
// 链接异常处理
client.on('error', (error) => {
console.log('连接失败:', error)
});
});
}
//点击地图线操作 //点击地图线操作
viewlineItem = () => { viewlineItem = () => {
let { treeData, selectedKeys, cityLine } = this.state; let { treeData, selectedKeys, cityLine } = this.state;
...@@ -170,7 +134,7 @@ class FinancialCityLan extends Component { ...@@ -170,7 +134,7 @@ class FinancialCityLan extends Component {
// 拓扑图数据初始化 // 拓扑图数据初始化
initTopologyData = (id, value = '') => { initTopologyData = (id, value = '') => {
getSelfTopographyAction(id).then(data => { getNodesByTypeAndTreeIdAction(type, id).then(data => {
if (value === 'refresh') { if (value === 'refresh') {
message.success('拓扑图刷新成功!'); message.success('拓扑图刷新成功!');
} }
...@@ -180,22 +144,8 @@ class FinancialCityLan extends Component { ...@@ -180,22 +144,8 @@ class FinancialCityLan extends Component {
topologyData: data topologyData: data
}); });
}); });
getDeivceListAction(0, 10, null).then(data => {
// console.log('表格刷新成功!');
this.setState({ tableData: data.content, totalCount: data.totalElements });
});
} }
// // 拓扑图事件数据初始化
// initTopologyEventData = () => {
// debugger
// getDeivceListAction().then(data => {
// this.setState({
// tableData: data
// });
// });
// }
/** /**
* 获取表格所选则的行数据 * 获取表格所选则的行数据
*/ */
...@@ -233,18 +183,6 @@ class FinancialCityLan extends Component { ...@@ -233,18 +183,6 @@ class FinancialCityLan extends Component {
}); });
}; };
queryEquipPage = () => {
let pageConfig = this.pageConfig;
let pageNumber = pageConfig.pageNumber - 1;
let pageSize = pageConfig.pageSize;
getDeivceListAction(pageNumber, pageSize, null).then(data => {
this.setState({ tableData: data.content, totalCount: data.totalElements });
});
}
// // 选择节点连线 // // 选择节点连线
// nodeSelectionLinkChanged = (node) => { // nodeSelectionLinkChanged = (node) => {
// if (node.isSelected) { // if (node.isSelected) {
...@@ -280,7 +218,7 @@ class FinancialCityLan extends Component { ...@@ -280,7 +218,7 @@ class FinancialCityLan extends Component {
nodeData: nodeDataArray, nodeData: nodeDataArray,
linkData: linkDataArray linkData: linkDataArray
}; };
updateSelfTopographyAction(params).then(data => { saveNodesByTypeUrlAction(type, params).then(data => {
message.success('拓扑图保存成功!'); message.success('拓扑图保存成功!');
}); });
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment