| | |
|---|
| | | import com.moral.api.entity.Sensor; |
|---|
| | | import com.moral.api.entity.UnitConversion; |
|---|
| | | import com.moral.api.websocket.SingleDeviceServer; |
|---|
| | | import com.moral.util.UnitConvertUtils; |
|---|
| | | import org.apache.kafka.clients.consumer.Consumer; |
|---|
| | | import org.apache.kafka.clients.consumer.ConsumerRecord; |
|---|
| | | import org.apache.kafka.common.TopicPartition; |
|---|
| | |
|---|
| | | //单位转换 |
|---|
| | | if(!unitKey.equals(showUnitKey)){ |
|---|
| | | String formula = sensor.getFormula(); |
|---|
| | | //如果sensor中的公式为空则从缓存中获取公式 |
|---|
| | | if(ObjectUtils.isEmpty(formula)){ |
|---|
| | | List<UnitConversion> unitConversions = socket.getUnitConversions(); |
|---|
| | | System.out.println(unitConversions); |
|---|
| | | }else{ |
|---|
| | | |
|---|
| | | for (UnitConversion unitConversion : unitConversions) { |
|---|
| | | if (unitConversion.getOriginalUnitKey().equals(unitKey) && unitConversion.getTargetUnitKey().equals(showUnitKey)) |
|---|
| | | formula = unitConversion.getFormula(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //单位转换 |
|---|
| | | UnitConvertUtils.calculate(message.get(code),formula); |
|---|
| | | } |
|---|
| | | //拼接单位 |
|---|
| | | String showUnit = sensor.getShowUnit(); |
|---|
| | | String value = message.get(code); |
|---|
