From a8db8fd61f48e3f367cd5968c11ffa1596c52e2f Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Fri, 19 Nov 2021 08:51:23 +0800
Subject: [PATCH] screen-api            增加污染等级柱状图接口mock数据

---
 screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java |   70 +++++++++++++++++++++++++++-------
 1 files changed, 55 insertions(+), 15 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
index c0660bb..68fcd33 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -6,14 +6,19 @@
 import com.moral.api.entity.UnitConversion;
 import com.moral.api.websocket.SingleDeviceServer;
 import com.moral.util.UnitConvertUtils;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.common.TopicPartition;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.listener.ConsumerSeekAware;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 
+import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -27,30 +32,53 @@
  * @Version TODO
  **/
 @Component
+@Slf4j
 public class SecondDataConsumer implements ConsumerSeekAware {
 
-    @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup3")
+    @KafkaListener(containerFactory = "secondDataListenerFactory", topics = "second_data")
     public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
         String messageStr = record.value();
-        Map<String, String> message = (Map<String, String>) JSON.parse(messageStr);
+        Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
+        //long serverStartTime = System.currentTimeMillis();
         CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
         for (SingleDeviceServer socket : sockets) {
-            //���������������������������socket
-            //������������������
+            //���������������������������socket
+            String messageMac = (String) message.get("mac");
             String mac = socket.getMac();
-            Map<String, Device> devicesInfo = socket.getDevicesInfo();
-            Device device = devicesInfo.get(mac);
+            if (!mac.equalsIgnoreCase(messageMac))
+                continue;
+            //������������������
+            Device device = socket.getDeviceAlarmInfo();
             //������������������������
-            Map<String, String> resultMessgae = new HashMap<>();
+            Map<String, Object> resultMessgae = new HashMap<>();
             //������������
             List<Sensor> sensors = device.getVersion().getSensors();//������������������������������
             for (Sensor sensor : sensors) {
                 String code = sensor.getCode();
+                String showUnit = sensor.getShowUnit();
                 String showUnitKey = sensor.getShowUnitKey();
                 String unitKey = sensor.getUnitKey();
+                String unit = sensor.getUnit();
+                //���������������������������������������������
+                Object value = message.get(code);
+                //������������������������������������������������
+                /*if(value==null)    ���������
+                    continue;
+                Double sourceDataD = Double.valueOf(String.valueOf(value));*/
+                //���������������������������������������������  start
+                Double sourceDataD = null;
+                if (value != null) {
+                     sourceDataD = Double.valueOf(String.valueOf(value));
+                }else{
+                    sourceDataD = 5.00d;
+                }
+                //���������������������������������������������  end
+                BigDecimal bg = new BigDecimal(sourceDataD);
+                bg = bg.setScale(2, BigDecimal.ROUND_FLOOR);
+                String sourceData = bg.toString();
                 //������������
                 //������������
-                if (!unitKey.equals(showUnitKey)) {
+                if (!unitKey.equals(showUnitKey)) {//������������������������������������������������������������
                     String formula = sensor.getFormula();
                     //������sensor���������������������������������������������
                     if (ObjectUtils.isEmpty(formula)) {
@@ -61,15 +89,26 @@
                         }
                     }
                     //������������
-                    UnitConvertUtils.calculate(message.get(code),formula);
+                    String resultData = UnitConvertUtils.calculate(sourceData, formula);
+                    if (resultData != null) {
+                        resultData += showUnit;
+                    } else {//���������������������������null���������������������������������������������������������������
+                        resultData = sourceData + unit;
+                    }
+                    resultMessgae.put(sensor.getCode(), resultData);
+                } else {
+                    //������������
+                    if(!showUnit.equals("���������"))
+                        sourceData = sourceData + " " + showUnit;
+                    resultMessgae.put(sensor.getCode(), sourceData);
                 }
-                //������������
-                String showUnit = sensor.getShowUnit();
-                String value = message.get(code);
-                value += showUnit;
-                resultMessgae.put(sensor.getCode(), value);
             }
-            resultMessgae.put("DataTime", message.get("DataTime"));
+            //���������������������������������
+            //resultMessgae.put("DataTime", message.get("DataTime"));
+            //resultMessgae.put("time", message.get("time"));
+            //resultMessgae.put("time1", message.get("time1"));
+            //resultMessgae.put("serverTime", System.currentTimeMillis());
+            //resultMessgae.put("serverStartTime", serverStartTime);
             socket.sendMessage(JSON.toJSONString(resultMessgae));
         }
     }
@@ -89,5 +128,6 @@
     public void onIdleContainer(Map<TopicPartition, Long> map, ConsumerSeekCallback consumerSeekCallback) {
 
     }
+
 }
 

--
Gitblit v1.8.0