添加前端页面

device-manager/src/main/java/com/mortals/xhx/common/utils/DownMsgTask.java

@@ -69,6 +69,7 @@ public class DownMsgTask implements Runnable {
                     TopicPartitionInfo info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.DOWN_TOPIC + deviceEntity.getDeviceMac()).build();
                     TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
                     header.put(MessageHeader.MESSAGETYPE, item.getMessageType());
+                    header.put(MessageHeader.DEVICECODE, item.getDeviceCode());
                     header.put(MessageHeader.TIMESTAMP, item.getTimestamp().toString());
                     deviceService.sendDeviceMessage(deviceEntity, info, header, JSON.toJSONString(item.getData()), null);
 
@@ -81,13 +82,13 @@ public class DownMsgTask implements Runnable {
                         deviceLogEntity.setDeviceCode(deviceEntity.getDeviceCode());
                         deviceLogEntity.setMessageHead(item.getMessageType());
                         deviceLogEntity.setContent(JSON.toJSONString(item.getData()));
-                        deviceLogEntity.setLogType(LogTypeEnum.上报事件.getValue());
+                        deviceLogEntity.setLogType(LogTypeEnum.下发服务.getValue());
                         deviceLogEntity.setCreateUserId(1L);
                         deviceLogEntity.setCreateTime(new Date());
                         deviceLogService.save(deviceLogEntity);
                     }
-
-
+                }else{
+                    log.info("未找到设备，deviceCode:{}",item.getDeviceCode());
                 }
             });
         } catch (Exception e) {