| | |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.ruoyi.common.utils.RedisUtil; |
|---|
| | | import com.ruoyi.device.constant.DCResistanceMqttConstants; |
|---|
| | | import com.ruoyi.device.constant.ElongationMqttConstants; |
|---|
| | | import com.ruoyi.device.mapper.CollectBridgeMapper; |
|---|
| | | import com.ruoyi.device.pojo.CollectBridge; |
|---|
| | | import com.ruoyi.device.service.CollectBridgeService; |
|---|
| | |
|---|
| | | // 处理 NSDQCS.DQCS.DZZ 数据 |
|---|
| | | processSingleValueDataStream(dataList, DCResistanceMqttConstants.NSDQCS_DQCS_DZZ); |
|---|
| | | // 处理 NSTSSC.TSSC.WY 数据 |
|---|
| | | processThreeTimesValueDataStream(dataList, DCResistanceMqttConstants.NSTSSC_TSSC_WY); |
|---|
| | | // DCResistanceMqttVO dcResistanceMqttVO = dataList.stream().filter(f -> StringUtils.equals(f.getDataStream(), DCResistanceMqttConstants.NSDQCS_DQCS_DZZ)).findFirst().orElse(null); |
|---|
| | | // if(Objects.nonNull(dcResistanceMqttVO)){ |
|---|
| | | // List<DCResistanceMqttVO.DataPoint> dataPoints = dcResistanceMqttVO.getDataPoints(); |
|---|
| | | // BigDecimal value = CollectionUtil.isNotEmpty(dataPoints)?dataPoints.get(0).getValue():BigDecimal.ZERO; |
|---|
| | | // //保存实际电阻值到redis |
|---|
| | | // RedisUtil.set(DCResistanceMqttConstants.NSDQCS_DQCS_DZZ,value.doubleValue()); |
|---|
| | | // } |
|---|
| | | processThreeTimesValueDataStream(dataList, ElongationMqttConstants.NSTSSC_TSSC_WY); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | /** |
|---|
