| | |
|---|
| | | //过滤出包含实际电阻值的对象 |
|---|
| | | // 处理 NSDQCS.DQCS.DZZ 数据 |
|---|
| | | processSingleValueDataStream(dataList, DCResistanceMqttConstants.NSDQCS_DQCS_DZZ); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void addBridgeValueByNSD(String jsonStr) { |
|---|
| | | Map<String, Object> dataMap = JSONObject.parseObject(jsonStr, new TypeReference<Map<String, Object>>(){}.getType()); |
|---|
| | | if(CollectionUtil.isNotEmpty(dataMap) && Objects.nonNull(dataMap.get("data"))){ |
|---|
| | | List<DCResistanceMqttVO> dataList = JSONArray.parseObject(dataMap.get("data").toString(), new TypeReference<List<DCResistanceMqttVO>>(){}.getType()); |
|---|
| | | //过滤出包含实际电阻值的对象 |
|---|
| | | // 处理 NSTSSC.TSSC.WY 数据 |
|---|
| | | processThreeTimesValueDataStream(dataList, ElongationMqttConstants.NSTSSC_TSSC_WY); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 处理单值数据流的数据并保存到 Redis |
|---|
| | | * @param dataList 数据列表 |
|---|
