mqtt认证查询日志

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

@@ -3,10 +3,12 @@ package com.xy.service;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.annotation.LogOperate;
 import com.xy.device.EnumEnvParams;
 import com.xy.dto.MqttUserDto;
 import com.xy.entity.MqttUser;
 import com.xy.entity.SysDictRedis;
+import com.xy.enums.LogEnum;
 import com.xy.mapper.MqttUserMapper;
 import com.xy.utils.*;
 import io.swagger.annotations.Api;
@@ -42,6 +44,7 @@ public class MqttUserServiceImpl extends ServiceImpl<MqttUserMapper, MqttUser> i
 
     @PostMapping("obj")
     @ApiOperation("对象查询")
+    @LogOperate(logType = LogEnum.LogType.V2, optType = LogEnum.OptType.V3, logContent = "mqtt认证查询")
     public R<MqttUserDto.Vo> obj(@RequestBody MqttUserDto.Obj obj) {
         log.info("mqtt认证查询，sn：{}", obj.getSn());
         MqttUserDto.SelectList selectList = copy(MqttUserDto.SelectList.class, obj);
@@ -56,7 +59,7 @@ public class MqttUserServiceImpl extends ServiceImpl<MqttUserMapper, MqttUser> i
         mqttUser.setServerTime(System.currentTimeMillis())
                 .setIpAddress(mqttUrl.getValue())
                 .setServerUrl(serverUrl.getValue());
-        return R.ok(mqttUser);
+        return R.ok(mqttUser).setLogMsg("sn=" + obj.getSn());
     }
 
     @PostMapping("list")