feat: 日志管理接口

+package org.thingsboard.server.controller.yunteng;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+import org.thingsboard.server.common.data.audit.ActionType;
+import org.thingsboard.server.common.data.audit.AuditLog;
+import org.thingsboard.server.common.data.exception.ThingsboardException;
+import org.thingsboard.server.common.data.yunteng.dto.SysLogDTO;
+import org.thingsboard.server.common.data.yunteng.enums.OrderTypeEnum;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.controller.BaseController;
+import org.thingsboard.server.dao.model.ModelConstants;
+import org.thingsboard.server.dao.yunteng.entities.SysLogEntity;
+import org.thingsboard.server.dao.yunteng.service.YtSysLogService;
+
+import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
+
+@RestController
+@RequestMapping("api/yt/log")
+@Api(tags = {"日志管理"})
+@RequiredArgsConstructor
+public class YtSyslogController extends BaseController {
+
+    private final YtSysLogService logService;
+
+    @GetMapping("{entityId}")
+    @PreAuthorize("@check.checkPermissions({},{})")
+    @ApiOperation("详情")
+    public SysLogDTO detail(@PathVariable("entityId") String entityId)
+            throws ThingsboardException {
+        return logService.detail(entityId);
+    }
+
+    @GetMapping(value="exception",params = {PAGE_SIZE, PAGE})
+    @ApiOperation("异常日志列表")
+    @PreAuthorize("@check.checkPermissions({},{})")
+    public YtPageData<SysLogDTO> pageExceptions(
+            @RequestParam(PAGE_SIZE) int pageSize,
+            @RequestParam(PAGE) int page,
+            @RequestParam(value = "actionType", required = false) ActionType actionType,
+            @RequestParam(value = ORDER_FILED, required = false) String orderBy,
+            @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)
+            throws ThingsboardException {
+
+
+        if(StringUtils.isEmpty(orderBy)){
+            orderBy = ModelConstants.CREATED_TIME_PROPERTY;
+        }
+        IPage<SysLogEntity> pageInfrom = logService.getPage(page, pageSize, orderBy, orderType);
+        return logService.exceptionPage(pageInfrom, null,null
+                ,getCurrentUser().isPtTenantAdmin()?getCurrentUser().getCurrentTenantId():null
+                ,getCurrentUser().isCustomerUser()?getCurrentUser().getCurrentUserId():null
+                ,actionType);
+    }
+
+    @GetMapping(value="operate",params = {PAGE_SIZE, PAGE})
+    @ApiOperation("操作日志列表")
+    @PreAuthorize("@check.checkPermissions({},{})")
+    public YtPageData<SysLogDTO> pageOperate(
+            @RequestParam(PAGE_SIZE) int pageSize,
+            @RequestParam(PAGE) int page,
+            @RequestParam(value = "actionType", required = false) ActionType actionType,
+            @RequestParam(value = ORDER_FILED, required = false) String orderBy,
+            @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)
+            throws ThingsboardException {
+        if(StringUtils.isEmpty(orderBy)){
+            orderBy = ModelConstants.CREATED_TIME_PROPERTY;
+        }
+        IPage<SysLogEntity> pageInfrom = logService.getPage(page, pageSize, orderBy, orderType);
+        return logService.operatePage(pageInfrom, null,null
+                ,getCurrentUser().isPtTenantAdmin()?getCurrentUser().getCurrentTenantId():null
+                ,getCurrentUser().isCustomerUser()?getCurrentUser().getCurrentUserId():null
+                ,actionType);
+    }
+
+    @GetMapping(value="user",params = {PAGE_SIZE, PAGE})
+    @ApiOperation("登录登出列表")
+    @PreAuthorize("@check.checkPermissions({},{})")
+    public YtPageData<SysLogDTO> pageLogin(
+            @RequestParam(PAGE_SIZE) int pageSize,
+            @RequestParam(PAGE) int page,
+            @RequestParam(value = "actionType", required = false) ActionType actionType,
+            @RequestParam(value = ORDER_FILED, required = false) String orderBy,
+            @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)
+            throws ThingsboardException {
+
+
+        if(StringUtils.isEmpty(orderBy)){
+            orderBy = ModelConstants.CREATED_TIME_PROPERTY;
+        }
+        IPage<SysLogEntity> pageInfrom = logService.getPage(page, pageSize, orderBy, orderType);
+        return logService.loginPage(pageInfrom, null,null
+                ,getCurrentUser().isPtTenantAdmin()?getCurrentUser().getCurrentTenantId():null
+                ,getCurrentUser().isCustomerUser()?getCurrentUser().getCurrentUserId():null
+                ,actionType);
+    }
+
+
+
+
+
+}

+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.common.data.yunteng.dto;
+
+
+import com.fasterxml.jackson.databind.JsonNode;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.thingsboard.server.common.data.EntityType;
+import org.thingsboard.server.common.data.audit.ActionStatus;
+import org.thingsboard.server.common.data.audit.ActionType;
+
+import java.util.UUID;
+
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class SysLogDTO extends BaseDTO {
+
+
+    private long createdTime;
+
+    private EntityType entityType;
+
+    private UUID tenantId;
+    private String tenantName;
+
+    private UUID customerId;
+    private String customerName;
+
+    private UUID entityId;
+    private String entityName;
+
+    private UUID userId;
+    private String userName;
+
+
+    private ActionType actionType;
+
+    private JsonNode actionData;
+
+    private ActionStatus actionStatus;
+
+
+    private String actionFailureDetails;
+
+
+}

+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.dao.yunteng.entities;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
+import com.fasterxml.jackson.databind.JsonNode;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.hibernate.annotations.Type;
+import org.hibernate.annotations.TypeDef;
+import org.thingsboard.server.common.data.EntityType;
+import org.thingsboard.server.common.data.audit.ActionStatus;
+import org.thingsboard.server.common.data.audit.ActionType;
+import org.thingsboard.server.common.data.audit.AuditLog;
+import org.thingsboard.server.common.data.id.*;
+import org.thingsboard.server.common.data.yunteng.dto.TenantDTO;
+import org.thingsboard.server.dao.model.BaseSqlEntity;
+import org.thingsboard.server.dao.model.ModelConstants;
+import org.thingsboard.server.dao.util.mapping.JsonStringType;
+
+import javax.persistence.*;
+import java.util.UUID;
+
+import static org.thingsboard.server.dao.model.ModelConstants.*;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(ModelConstants.AUDIT_LOG_COLUMN_FAMILY_NAME)
+public class SysLogEntity  extends BaseEntity {
+
+
+    private UUID tenantId;
+
+    private long createdTime;
+    private UUID customerId;
+
+    private EntityType entityType;
+
+
+    private UUID entityId;
+
+
+    private String entityName;
+
+
+    private UUID userId;
+
+    private String userName;
+
+
+    private ActionType actionType;
+
+    @TableField(typeHandler = JacksonTypeHandler.class)
+    private JsonNode actionData;
+
+    private ActionStatus actionStatus;
+
+
+    private String actionFailureDetails;
+
+
+}

+package org.thingsboard.server.dao.yunteng.impl;
+
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.thingsboard.server.common.data.EntityType;
+import org.thingsboard.server.common.data.StringUtils;
+import org.thingsboard.server.common.data.audit.ActionType;
+import org.thingsboard.server.common.data.audit.AuditLog;
+import org.thingsboard.server.common.data.yunteng.dto.SysLogDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtOpinionDTO;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.dao.yunteng.entities.SysLogEntity;
+import org.thingsboard.server.dao.yunteng.entities.YtOpinionEntity;
+import org.thingsboard.server.dao.yunteng.mapper.YtSysLogMapper;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.YtSysLogService;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class YtSysLogServiceImpl extends AbstractBaseService<YtSysLogMapper, SysLogEntity>
+        implements YtSysLogService {
+
+
+    @Override
+    public SysLogDTO detail(String entityId) {
+        return baseMapper.detailById(entityId);
+    }
+
+    @Override
+    public YtPageData<SysLogDTO> exceptionPage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType) {
+        IPage<SysLogDTO> page =
+                baseMapper.getPageDatasMatched(pageInfrom, tenantId,customerId,startTime,endTime,EntityType.RUNNING_EXCEPTION,actionType);
+        return getPageData(page, SysLogDTO.class);
+    }
+
+
+    @Override
+    public YtPageData<SysLogDTO> operatePage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType) {
+        List<EntityType> entityTypes = new ArrayList<>();
+        entityTypes.add(EntityType.RUNNING_EXCEPTION);
+        entityTypes.add(EntityType.USER);
+
+        IPage<SysLogDTO> page =
+                baseMapper.getPageDatasNot(pageInfrom, tenantId,customerId,startTime,endTime,actionType, entityTypes);
+        return getPageData(page, SysLogDTO.class);
+    }
+
+    @Override
+    public YtPageData<SysLogDTO> loginPage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType) {
+        IPage<SysLogDTO> page =
+                baseMapper.getPageDatasMatched(pageInfrom, tenantId,customerId,startTime,endTime,EntityType.USER,actionType);
+        return getPageData(page, SysLogDTO.class);
+    }
+}

+package org.thingsboard.server.dao.yunteng.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.thingsboard.server.common.data.EntityType;
+import org.thingsboard.server.common.data.audit.ActionType;
+import org.thingsboard.server.common.data.audit.AuditLog;
+import org.thingsboard.server.common.data.rpc.RpcStatus;
+import org.thingsboard.server.common.data.yunteng.dto.SysLogDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtRpcRecordDTO;
+import org.thingsboard.server.dao.yunteng.entities.SysLogEntity;
+import org.thingsboard.server.dao.yunteng.entities.YtOpinionEntity;
+
+import java.util.List;
+
+/**
+ * @author Administrator
+ */
+@Mapper
+public interface YtSysLogMapper extends BaseMapper<SysLogEntity> {
+    IPage<SysLogDTO> getPageDatasMatched(IPage<?> page, @Param("tenantId") String tenantId, @Param("customerId") String customerId
+            , @Param("startTime") Long startTime, @Param("endTime") Long endTime, @Param("entityType") EntityType entityType, @Param("actionType")  ActionType actionType);
+    IPage<SysLogDTO> getPageDatasNot(IPage<?> page, @Param("tenantId") String tenantId, @Param("customerId") String customerId
+            , @Param("startTime") Long startTime, @Param("endTime") Long endTime, @Param("actionType")  ActionType actionType, @Param("entityType") List<EntityType> entityType);
+
+
+
+
+    SysLogDTO detailById( @Param("entityId") String entityId);
+}

+package org.thingsboard.server.dao.yunteng.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.thingsboard.server.common.data.audit.ActionType;
+import org.thingsboard.server.common.data.audit.AuditLog;
+import org.thingsboard.server.common.data.yunteng.dto.SysLogDTO;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.dao.yunteng.entities.SysLogEntity;
+import org.thingsboard.server.dao.yunteng.entities.YtOpinionEntity;
+
+public interface YtSysLogService extends BaseService<SysLogEntity> {
+
+
+    /**
+     * 日志详细信息
+     *
+     * @param entityId 日志ID
+     * @return
+     */
+    SysLogDTO detail(String entityId);
+
+    /**
+     * 异常日志列表
+     *
+     * @param pageInfrom 分页配置信息
+     * @param startTime  时间过滤窗口起点
+     * @param endTime    时间过滤窗口终点
+     * @param tenantId   租户ID，超级管理员该值为null
+     * @param customerId 客户ID，租户管理员该值为null
+     * @param actionType 日志类型
+     * @return
+     */
+    YtPageData<SysLogDTO> exceptionPage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType);
+
+    /**
+     * 操作日志列表
+     *
+     * @param pageInfrom 分页配置信息
+     * @param startTime  时间过滤窗口起点
+     * @param endTime    时间过滤窗口终点
+     * @param tenantId   租户ID，超级管理员该值为null
+     * @param customerId 客户ID，租户管理员该值为null
+     * @param actionType 日志类型
+     * @return
+     */
+    YtPageData<SysLogDTO> operatePage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType);
+
+    /**
+     * 登录日志列表
+     *
+     * @param pageInfrom 分页配置信息
+     * @param startTime  时间过滤窗口起点
+     * @param endTime    时间过滤窗口终点
+     * @param tenantId   租户ID，超级管理员该值为null
+     * @param customerId 客户ID，租户管理员该值为null
+     * @param actionType 日志类型
+     * @return
+     */
+    YtPageData<SysLogDTO> loginPage(IPage<SysLogEntity> pageInfrom, Long startTime, Long endTime, String tenantId, String customerId, ActionType actionType);
+
+}

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="org.thingsboard.server.dao.yunteng.mapper.YtSysLogMapper">
+    <resultMap id="logDto" type="org.thingsboard.server.common.data.yunteng.dto.SysLogDTO">
+        <result property="id" column="id"/>
+        <result property="entityType" column="entity_type" typeHandler="org.apache.ibatis.type.EnumTypeHandler"/>
+
+        <result property="entityId" column="entity_id"  typeHandler="org.thingsboard.server.dao.yunteng.mapper.UUIDTypeHandler"/>
+        <result property="entityName" column="entity_name" />
+        <result property="tenantId" column="tenant_id" typeHandler="org.thingsboard.server.dao.yunteng.mapper.UUIDTypeHandler"/>
+        <result property="tenantName" column="tenant_name"/>
+        <result property="customerId" column="customer_id" typeHandler="org.thingsboard.server.dao.yunteng.mapper.UUIDTypeHandler"/>
+        <result property="customerName" column="customer_name"/>
+        <result property="userId" column="user_id" typeHandler="org.thingsboard.server.dao.yunteng.mapper.UUIDTypeHandler"/>
+        <result property="userName" column="user_name" />
+
+        <result property="actionData" column="action_data" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler"/>
+        <result property="actionType" column="action_type" typeHandler="org.apache.ibatis.type.EnumTypeHandler"/>
+        <result property="actionStatus" column="action_status" typeHandler="org.apache.ibatis.type.EnumTypeHandler"/>
+        <result property="actionFailureDetails" column="action_failure_details"/>
+        <result property="createdTime" column="created_time"/>
+
+    </resultMap>
+
+    <sql id="baseColumn">
+        base.id, base.tenant_id, base.created_time, base.customer_id, base.entity_type, base.entity_id, base.entity_name, base.user_id, base.user_name, base.action_type, base.action_status
+        ,ten.title tenant_name
+    </sql>
+    <sql id="detailColumn">
+        <include refid="baseColumn"></include>
+        , base.action_data,base.action_failure_details
+    </sql>
+
+    <select id="getPageDatasMatched" resultMap="logDto">
+        SELECT  <include refid="baseColumn"/>
+        FROM audit_log base
+        LEFT JOIN tenant ten ON base.tenant_id = ten.id
+        <where>
+            base.entity_type = #{entityType}
+            <if test="tenantId !=null and tenantId !=''">
+                AND base.tenant_id = #{tenantId}::uuid
+            </if>
+            <if test="customerId !=null ">
+                AND base.customer_id = #{customerId}::uuid
+            </if>
+            <if test="startTime !=null">
+                AND base.created_time >= #{startTime}
+            </if>
+            <if test="endTime !=null">
+                AND base.created_time &lt;  #{endTime}
+            </if>
+            <if test="actionType !=null">
+                AND base.action_type =  #{actionType}
+            </if>
+        </where>
+    </select>
+
+
+    <select id="getPageDatasNot" resultMap="logDto">
+        SELECT  <include refid="baseColumn"/>
+        FROM audit_log base
+        LEFT JOIN tenant ten ON base.tenant_id = ten.id
+        <where>
+            base.entity_type
+            NOT IN
+            <foreach collection="entityType" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+            <if test="tenantId !=null and tenantId !=''">
+                AND base.tenant_id = #{tenantId}::uuid
+            </if>
+            <if test="customerId !=null ">
+                AND base.customer_id = #{customerId}::uuid
+            </if>
+            <if test="startTime !=null">
+                AND base.created_time >= #{startTime}
+            </if>
+            <if test="endTime !=null">
+                AND base.created_time &lt;  #{endTime}
+            </if>
+            <if test="actionType !=null">
+                AND base.action_type =  #{actionType}
+            </if>
+        </where>
+    </select>
+
+    <select id="detailById" resultMap="logDto">
+        SELECT  <include refid="detailColumn"/>
+        FROM audit_log base
+        LEFT JOIN tenant ten ON base.tenant_id = ten.id
+        <where>
+            base.id = #{entityId}::uuid
+
+        </where>
+    </select>
+
+</mapper>