Browse Source

mqtt认证查询日志

李进 2 năm trước cách đây
mục cha
commit
bf59db7086

+ 2 - 2
device-api-service/src/main/java/com/xy/service/MqttUserServiceImpl.java

@@ -50,7 +50,7 @@ public class MqttUserServiceImpl extends ServiceImpl<MqttUserMapper, MqttUser> i
         MqttUserDto.SelectList selectList = copy(MqttUserDto.SelectList.class, obj);
         MqttUserDto.SelectList selectList = copy(MqttUserDto.SelectList.class, obj);
         List<MqttUserDto.Vo> list = list(selectList).getData();
         List<MqttUserDto.Vo> list = list(selectList).getData();
         if (!Emptys.check(list)) {
         if (!Emptys.check(list)) {
-            return R.ok();
+            return R.ok().setLogMsg("结果=false,sn=" + obj.getSn());
         }
         }
         MqttUserDto.Vo mqttUser = list.get(0);
         MqttUserDto.Vo mqttUser = list.get(0);
         Map<String, SysDictRedis> map = SysDictUtils.get(EnumEnvParams.Code.CODE.getCode());
         Map<String, SysDictRedis> map = SysDictUtils.get(EnumEnvParams.Code.CODE.getCode());
@@ -59,7 +59,7 @@ public class MqttUserServiceImpl extends ServiceImpl<MqttUserMapper, MqttUser> i
         mqttUser.setServerTime(System.currentTimeMillis())
         mqttUser.setServerTime(System.currentTimeMillis())
                 .setIpAddress(mqttUrl.getValue())
                 .setIpAddress(mqttUrl.getValue())
                 .setServerUrl(serverUrl.getValue());
                 .setServerUrl(serverUrl.getValue());
-        return R.ok(mqttUser).setLogMsg("sn=" + obj.getSn());
+        return R.ok(mqttUser).setLogMsg("结果=true,sn=" + obj.getSn());
     }
     }
 
 
     @PostMapping("list")
     @PostMapping("list")