修改kafka地址，增加未识别到设备类型的判断

gt-club/gt-club-biz/src/main/java/cn/gintone/dto/DeviceIllLogInfo.java

@@ -14,7 +14,7 @@ public class DeviceIllLogInfo {
     private String deviceTypeName; // 设备类型名称
     private String deviceSn; // 设备类型名称
     private String accessed; // 访问时间
-    private String illType; // 日志类型()  noRule:无规则，disconnected：掉线
+    private String illType; // 日志类型()  noRule:无规则，disconnected：掉线, noType:无类型
     private String clientIp; // 访问端ip
     private String remark; // 备注
 

gt-club/gt-club-biz/src/main/java/cn/gintone/service/DeviceConnetRuleInfoServiceImpl.java

@@ -163,7 +163,26 @@ public class DeviceConnetRuleInfoServiceImpl implements DeviceConnetRuleInfoServ
         DeviceTypeDO deviceTypeDO = deviceTypeMapper.selectOne(new QueryWrapper<DeviceTypeDO>().lambda()
                 .eq(DeviceTypeDO::getModelCode, deviceLogInfo.getDeviceTypeBs())
         );
+        if (null == deviceTypeDO) {
+            DeviceIllLogInfo deviceIllLogInfo = new DeviceIllLogInfo();
+            deviceIllLogInfo.setRoleId(deviceLogInfo.getRoleId());
+            deviceIllLogInfo.setRoleName(deviceLogInfo.getRoleName());
+            deviceIllLogInfo.setUserId(deviceLogInfo.getUserId());
+            deviceIllLogInfo.setUsername(deviceLogInfo.getUsername());
+            deviceIllLogInfo.setDeviceId(deviceLogInfo.getDeviceId());
+            deviceIllLogInfo.setDeviceName(deviceLogInfo.getDeviceName());
+            deviceIllLogInfo.setDeviceTypeId("");
+            deviceIllLogInfo.setDeviceTypeBs(deviceLogInfo.getDeviceTypeBs());
+            deviceIllLogInfo.setDeviceTypeName(deviceLogInfo.getDeviceTypeName());
 
+
+            deviceIllLogInfo.setAccessed(deviceLogInfo.getAccessed());
+            deviceIllLogInfo.setClientIp(deviceLogInfo.getClientIp());
+            deviceIllLogInfo.setRemark(deviceLogInfo.getRemark());
+            deviceIllLogInfo.setIllType("noType");
+            MyIotDbUtils.inserOneDeviceLogInfo_ill(iotDbConfig, deviceIllLogInfo);
+            return;
+        }
         String userId = deviceLogInfo.getUserId();
         if (null == userId || "".equals(userId)) {
             DeviceIllLogInfo deviceIllLogInfo = new DeviceIllLogInfo();
@@ -224,7 +243,7 @@ public class DeviceConnetRuleInfoServiceImpl implements DeviceConnetRuleInfoServ
             deviceIllLogInfo.setUsername(deviceLogInfo.getUsername());
             deviceIllLogInfo.setDeviceId(deviceLogInfo.getDeviceId());
             deviceIllLogInfo.setDeviceName(deviceLogInfo.getDeviceName());
-            deviceIllLogInfo.setDeviceTypeId(deviceTypeDO.getId() + "");
+            deviceIllLogInfo.setDeviceTypeId(deviceTypeDO.getId()== null ? "" : deviceTypeDO.getId() + "");
             deviceIllLogInfo.setDeviceTypeBs(deviceLogInfo.getDeviceTypeBs());
             deviceIllLogInfo.setDeviceTypeName(deviceLogInfo.getDeviceTypeName());
             deviceIllLogInfo.setAccessed(deviceLogInfo.getAccessed());

yudao-server/src/main/resources/application-dev.yaml

@@ -134,7 +134,7 @@ rocketmq:
   # Kafka 配置项，对应 KafkaProperties 配置类
 kafka:
   cluster1:
-    bootstrap-servers: 59.195.13.209:9092
+    bootstrap-servers: 59.195.13.208:9092
 #    bootstrap-servers: 192.168.19.128:9092
     producer:
       retries: 3

yudao-server/src/main/resources/application.yaml

@@ -3,8 +3,8 @@ spring:
     name: yudao-server
 
   profiles:
-    active: local
-#    active: dev
+#    active: local
+    active: dev
 
   main:
     allow-circular-references: true # 允许循环依赖，因为项目是三层架构，无法避免这个情况。