更新设备单管道信息(管道值、管道状态)
接收正常
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【设备消息实体】
