20201215v1.3

util/src/main/java/com/ccsens/util/WebConstant.java

@@ -663,7 +663,7 @@ public class WebConstant {
             }
         }
         public static Message_Ack_Event phaseOf(String phase) {    //    手写的从String到enum的转换函数
-            if(phase.equalsIgnoreCase("Ack")) {
+            if("Ack".equalsIgnoreCase(phase)) {
                 return Ack;
             } else {
                 return null;

wisdomcar/src/main/java/com/ccsens/wisdomcar/rabbitMQ/RabbitController.java

@@ -1,57 +1,55 @@
-//package com.ccsens.wisdomcar.rabbitMQ;
+package com.ccsens.wisdomcar.rabbitMQ;
-//
+
-//import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.collection.CollectionUtil;
-//import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.ObjectUtil;
-//import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.JSONObject;
-//import com.ccsens.util.bean.message.common.OutMessage;
+import com.ccsens.util.bean.message.common.OutMessage;
-//import com.ccsens.util.bean.message.common.OutMessageSet;
+import com.ccsens.util.bean.message.common.OutMessageSet;
-//import com.ccsens.util.config.RabbitMQConfig;
+import com.ccsens.util.config.RabbitMQConfig;
-//import com.ccsens.wisdomcar.bean.dto.Message.CarRecordMessageDto;
+import com.ccsens.wisdomcar.bean.dto.Message.CarRecordMessageDto;
-//import com.ccsens.wisdomcar.service.IRecordService;
+import com.ccsens.wisdomcar.service.IRecordService;
-//import com.ccsens.wisdomcar.service.RecordService;
+import lombok.extern.slf4j.Slf4j;
-//import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
-//import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
-//import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
-//import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
-//import org.springframework.stereotype.Component;
+
-//
+import javax.annotation.Resource;
-//import javax.annotation.Resource;
+import java.util.Set;
-//import java.util.List;
+
-//import java.util.Set;
+@Slf4j
-//
+@Component
-//@Slf4j
+@RabbitListener(queues = RabbitMQConfig.WISDOM_CAR)
-//@Component
+public class RabbitController {
-//@RabbitListener(queues = RabbitMQConfig.WISDOM_CAR)
+    @Resource
-//public class RabbitController {
+    private IRecordService recordService;
-//    @Resource
+
-//    private IRecordService recordService;
+    private Logger logger = LoggerFactory.getLogger(RabbitController.class);
-//
+
-//    private Logger logger = LoggerFactory.getLogger(RabbitController.class);
+    @RabbitHandler
-//
+    public void process(String messageJson) {
-//    @RabbitHandler
+        logger.info("平车上传消息数据: {}",messageJson);
-//    public void process(String messageJson) {
+        OutMessageSet outMessageSet = JSONObject.parseObject(messageJson,OutMessageSet.class);
-//        logger.info("平车上传消息数据: {}",messageJson);
+        if(ObjectUtil.isNull(outMessageSet)){
-//        OutMessageSet outMessageSet = JSONObject.parseObject(messageJson,OutMessageSet.class);
+            return;
-//        if(ObjectUtil.isNull(outMessageSet)){
+        }
-//            return;
+        Set<OutMessage> messageSet = outMessageSet.getMessageSet();
-//        }
+        if (CollectionUtil.isEmpty(messageSet)) {
-//        Set<OutMessage> messageSet = outMessageSet.getMessageSet();
+            return;
-//        if (CollectionUtil.isEmpty(messageSet)) {
+        }
-//            return;
+        messageSet.forEach(outMessage -> {
-//        }
+            CarRecordMessageDto carRecordMessageDto = JSONObject.parseObject(outMessage.getData(),CarRecordMessageDto.class);
-//        messageSet.forEach(outMessage -> {
+            if(ObjectUtil.isNull(carRecordMessageDto)){
-//            CarRecordMessageDto carRecordMessageDto = JSONObject.parseObject(outMessage.getData(),CarRecordMessageDto.class);
+                return;
-//            if(ObjectUtil.isNull(carRecordMessageDto)){
+            }
-//                return;
+            try {
-//            }
+                recordService.disposeMessage(carRecordMessageDto);
-//            try {
+            } catch (Exception e) {
-//                recordService.disposeMessage(carRecordMessageDto);
+                log.error("处理平车信息异常",e);
-//            } catch (Exception e) {
+                e.printStackTrace();
-//                log.error("处理平车信息异常",e);
+            }
-//                e.printStackTrace();
+        });
-//            }
+    }
-//        });
+
-//    }
+}
-//
-//}

wisdomcar/src/main/java/com/ccsens/wisdomcar/service/RecordService.java

@@ -164,7 +164,7 @@ public class RecordService implements IRecordService{
         //震动传感器
         CarRecordMessageDto shakeMessage = new CarRecordMessageDto();
         BeanUtil.copyProperties(carRecordMessageDto,shakeMessage);
-        shakeMessage.setType(Constant.WEIGHT_SENSOR_4);
+        shakeMessage.setType(Constant.SHAKE_SENSOR);
         shakeMessage.setValue(shakeX + "," + shakeY + "," + shakeZ);
         //发送消息
         sendRecordMessage(shakeMessage,userIdSet);

wisdomcar/src/main/java/com/ccsens/wisdomcar/service/StatisticsService.java

@@ -10,7 +10,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 
 import javax.annotation.Resource;
-import java.security.PrivateKey;
 import java.util.ArrayList;
 
 import java.util.List;