FAS4.0设备消息处理流程

更新设备单管道信息(管道值、管道状态)

接收正常

POST\"application/json

判断设备有无未处理消息

更新设备单管道信息(管道名称、管道字段、管道值、管道状态)

故障

AttributeAndValue中是否包含status(设备状态)

在线

添加告警数据

RequestBody数据解释：infoType: 无状态类型、故障类型、告警类型、监管类型deviceType：设备类型deviceCode：设备编码msgType: 消息类型msgContent：消息内容msgTime：消息时间attributeAndValue：属性值备注：1、【attributeAndValue为map键值对，键为String，值为Object】2、requestbody为JSON格式

不存在

无

messageReceiveVO(接收到的设备消息) --> deviceMessageinfoType、msgType、msgContent、msgTime->reportTime

包含

查询设备管道信息devicePipelineList

完整

根据消息类型-->管道状态信息状态: 无状态类型(正常)、故障类型(故障)、告警类型(告警)

deviceCode不存在

attributeValue --> deviceMessage(systemCode、loopCode、oneCode)

UPDATE device status

判断消息类型

仅更新管道值、状态

开始遍历管道信息

不完整

判断设备是否有未处理故障

如果设备状态更新为在线继续执行

判断管道值-->超限-->生成管道告警数据

有

管道必须信息：管道字段是否包含管道字段

存在

deviceMessage --> MYSQL

管道遍历结束

if deviceCode存在

更新设备状态

异步

DM服务端

判断设备是否有未处理报警

设备消息处理发送信息例子：{\"attributeAndValue\":{\"signalStrenth\":\"66\

报警

更新设备状态(1:在线；0:离线)

交由messageReceive处理数据

无状态类型

管道完整信息：管道号、管道名称、管道字段判断管道信息是否完整？

fas4.0设备消息处理

管道信息完整

更新管道属性

告警类型、故障类型、监管类型

devicePipelineList.filter（仅保留管道号相同的pipeline)

不包含

deviceMessage --> responseMessageVO<WebsocketFormatVO>TOWebSocket

deviceMessage: new DeviceMessage【设备消息实体】