添加简单的rocketmq例子，以后可能会更改

src/main/java/com/chinaitop/depot/intelligent/rocketMQ/MQConsumerService.java

@@ -0,0 +1,113 @@
+package com.chinaitop.depot.intelligent.rocketMQ;
+
+import com.alibaba.fastjson.JSON;
+import com.chinaitop.depot.intelligent.basicdata.service.ResolutionToSendAlarmService;
+import com.chinaitop.depot.intelligent.basicdata.service.WarningThresholdService;
+import com.chinaitop.depot.intelligent.grainsituation.mapper.TTestdataLayerMapper;
+import com.chinaitop.depot.intelligent.grainsituation.mapper.TWarningThresholdHistoryMapper;
+import com.chinaitop.depot.intelligent.grainsituation.model.TTestdata;
+import com.chinaitop.depot.intelligent.grainsituation.model.TTestdataLayer;
+import com.chinaitop.depot.intelligent.grainsituation.model.TWarningThresholdHistory;
+import com.chinaitop.depot.intelligent.grainsituation.service.TWarningThresholdHistoryService;
+import com.chinaitop.depot.intelligent.grainsituation.service.TemperatureRecordService;
+import com.chinaitop.depot.intelligent.utils.UuidUtils;
+import com.chinaitop.depot.intelligent.utils.WarningMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.catalina.User;
+import org.apache.rocketmq.common.message.MessageExt;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Component
+public class MQConsumerService {
+
+    @Resource
+    private TemperatureRecordService temperatureRecordService;
+    @Resource
+    private TTestdataLayerMapper tTestdataLayerMapper;
+    @Resource
+    private TWarningThresholdHistoryMapper tWarningThresholdHistoryMapper;
+    @Resource
+    private ResolutionToSendAlarmService resolutionToSendAlarmService;
+    @Resource
+    private TWarningThresholdHistoryService tWarningThresholdHistoryService;
+
+    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
+    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
+    @Service
+    @RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "t_testdata_c", consumerGroup = "t_testdata_c")
+    public class ConsumerSend implements RocketMQListener<ArrayList<TTestdata>> {
+        // 监听到消息就会执行此方法
+        @Override
+        public void onMessage(ArrayList<TTestdata> tTestdataList) {
+            log.info("监听到消息：tTestdataList={}", JSON.toJSONString(tTestdataList));
+            temperatureRecordService.insertBatch(tTestdataList);
+        }
+    }
+
+    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
+    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
+    @Service
+    @RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "t_testdata_layer_c", consumerGroup = "t_testdata_layer_c")
+    public class ConsumerSend1 implements RocketMQListener<ArrayList<TTestdataLayer>> {
+        // 监听到消息就会执行此方法
+        @Override
+        public void onMessage(ArrayList<TTestdataLayer> tTestdataLayerArrayList) {
+            log.info("监听到消息：tTestdataLayerArrayList={}", JSON.toJSONString(tTestdataLayerArrayList));
+            tTestdataLayerMapper.insertBatch(tTestdataLayerArrayList);
+        }
+    }
+
+    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
+    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
+    @Service
+    @RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "t_warning_threshold_history_c", consumerGroup = "t_warning_threshold_history_c")
+    public class ConsumerSend3 implements RocketMQListener<ArrayList<TWarningThresholdHistory>> {
+        // 监听到消息就会执行此方法
+        @Override
+        public void onMessage(ArrayList<TWarningThresholdHistory> tWarningThresholdHistorieList) {
+            log.info("监听到消息：tWarningThresholdHistorieList={}", JSON.toJSONString(tWarningThresholdHistorieList));
+            tWarningThresholdHistoryMapper.insertBatch(tWarningThresholdHistorieList);
+            List<TWarningThresholdHistory> collect = tWarningThresholdHistorieList.stream().filter(TWarningThresholdHistory -> TWarningThresholdHistory.getwWarning().equals("0")).collect(Collectors.toList());
+            boolean alarmDetails = resolutionToSendAlarmService.getAlarmDetails(collect);
+            if (!alarmDetails) {
+                collect.forEach(obj -> {
+                    obj.setIsSend("2");
+                    tWarningThresholdHistoryService.updateById(obj);
+                });
+            }
+        }
+    }
+
+    // 注意：这个ConsumerSend2和上面ConsumerSend在没有添加tag做区分时，不能共存，
+    // 不然生产者发送一条消息，这两个都会去消费，如果类型不同会有一个报错，所以实际运用中最好加上tag，写这只是让你看知道就行
+//    @Service
+//    @RocketMQMessageListener(topic = "smart_grp_yn", consumerGroup = "Con_Group_Two")
+//    public class ConsumerSend2 implements RocketMQListener<String> {
+//        @Override
+//        public void onMessage(String str) {
+//            log.info("监听到消息：555str={}", str);
+//        }
+//    }
+
+    // MessageExt：是一个消息接收通配符，不管发送的是String还是对象，都可接收，当然也可以像上面明确指定类型（我建议还是指定类型较方便）
+//    @Service
+//    @RocketMQMessageListener(topic = "smart_grp_yn", selectorExpression = "tag2", consumerGroup = "Con_Group_Three")
+//    public class Consumer implements RocketMQListener<MessageExt> {
+//        @Override
+//        public void onMessage(MessageExt messageExt) {
+//            byte[] body = messageExt.getBody();
+//            String msg = new String(body);
+//            log.info("监听到消息：666msg={}", msg);
+//        }
+//    }
+
+}