admin/craftlabs-authorization-sdk
1
0
Fork 0
mirror of https://github.com/hpd840321/craftlabs-authorization-sdk.git synced 2026-06-09 10:00:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(m10): add audit event search and CSV export

Browse Source
This commit is contained in:
huangping
2026-05-25 01:38:48 +08:00
parent c088c0ed71
commit d933639518
5 changed files with 275 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/delivery-platform-api/src/main/java/cn/craftlabs/platform/api/audit/AuditController.java
+54 -4
View File
@@ -5,14 +5,20 @@ import cn.craftlabs.platform.api.web.dto.AuditEventResponse;
import cn.craftlabs.platform.api.web.dto.PageResponse;
import jakarta.validation.constraints.Max;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.Resource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.nio.charset.StandardCharsets;
import java.time.LocalDate;
import java.util.List;
@RestController
@RequestMapping("/api/v1/audit-events")
@Validated
@@ -26,10 +32,54 @@ public class AuditController {
@GetMapping
public PageResponse<AuditEventResponse> list(
@RequestParam("entityType") @NotBlank String entityType,
@RequestParam("entityId") @NotNull Long entityId,
@RequestParam(required = false) String entityType,
@RequestParam(required = false) Long entityId,
@RequestParam(value = "page", defaultValue = "0") @Min(0) int page,
@RequestParam(value = "size", defaultValue = "20") @Min(1) @Max(200) int size) {
return auditService.page(entityType, entityId, page, size);
}
@GetMapping("/export")
public ResponseEntity<Resource> exportAuditEvents(
@RequestParam(required = false) String entityType,
@RequestParam(required = false) Long entityId,
@RequestParam(required = false) String from,
@RequestParam(required = false) String to) {
List<AuditEventResponse> events = auditService.searchAuditEvents(entityType, entityId, from, to);
StringBuilder sb = new StringBuilder();
sb.append("时间,操作者,动作,实体类型,实体ID,摘要,详情\n");
for (AuditEventResponse e : events) {
sb.append(escapeCsv(e.getCreatedAt() != null ? e.getCreatedAt().toString() : "")).append(",");
sb.append(escapeCsv(e.getActorUserId())).append(",");
sb.append(escapeCsv(e.getAction())).append(",");
sb.append(escapeCsv(e.getEntityType())).append(",");
sb.append(e.getEntityId() != null ? String.valueOf(e.getEntityId()) : "").append(",");
sb.append(escapeCsv(e.getFieldName())).append(",");
sb.append(escapeCsv(e.getOldValue())).append("\n");
}
byte[] bytes = sb.toString().getBytes(StandardCharsets.UTF_8);
byte[] bom = {(byte) 0xEF, (byte) 0xBB, (byte) 0xBF};
byte[] withBom = new byte[bom.length + bytes.length];
System.arraycopy(bom, 0, withBom, 0, bom.length);
System.arraycopy(bytes, 0, withBom, bom.length, bytes.length);
ByteArrayResource resource = new ByteArrayResource(withBom);
return ResponseEntity.ok()
.header(HttpHeaders.CONTENT_DISPOSITION,
"attachment; filename=audit-events-" + LocalDate.now() + ".csv")
.header(HttpHeaders.CONTENT_TYPE, "text/csv; charset=utf-8")
.body(resource);
}
private static String escapeCsv(String value) {
if (value == null) return "";
if (value.contains(",") || value.contains("\"") || value.contains("\n")) {
return "\"" + value.replace("\"", "\"\"") + "\"";
}
return value;
}
}
services/delivery-platform-api/src/main/java/cn/craftlabs/platform/api/service/AuditService.java
+30 -5
View File
@@ -50,11 +50,7 @@ public class AuditService {
@Transactional(readOnly = true)
public PageResponse<AuditEventResponse> page(
String entityType, Long entityId, int page, int size) {
LambdaQueryWrapper<PlatformAuditEvent> q =
Wrappers.lambdaQuery(PlatformAuditEvent.class)
.eq(PlatformAuditEvent::getEntityType, entityType.trim())
.eq(PlatformAuditEvent::getEntityId, entityId)
.orderByDesc(PlatformAuditEvent::getId);
LambdaQueryWrapper<PlatformAuditEvent> q = buildQuery(entityType, entityId, null, null);
Page<PlatformAuditEvent> mpPage = new Page<>(page + 1L, size);
auditEventMapper.selectPage(mpPage, q);
List<AuditEventResponse> content =
@@ -62,6 +58,35 @@ public class AuditService {
return new PageResponse<>(content, mpPage.getTotal(), page, size);
}
@Transactional(readOnly = true)
public List<AuditEventResponse> searchAuditEvents(
String entityType, Long entityId, String from, String to) {
LambdaQueryWrapper<PlatformAuditEvent> q = buildQuery(entityType, entityId, from, to);
return auditEventMapper.selectList(q).stream()
.map(this::toResponse)
.collect(Collectors.toList());
}
private LambdaQueryWrapper<PlatformAuditEvent> buildQuery(
String entityType, Long entityId, String from, String to) {
LambdaQueryWrapper<PlatformAuditEvent> q =
Wrappers.lambdaQuery(PlatformAuditEvent.class)
.orderByDesc(PlatformAuditEvent::getId);
if (entityType != null && !entityType.isBlank()) {
q.eq(PlatformAuditEvent::getEntityType, entityType.trim());
}
if (entityId != null) {
q.eq(PlatformAuditEvent::getEntityId, entityId);
}
if (from != null && !from.isBlank()) {
q.ge(PlatformAuditEvent::getCreatedAt, OffsetDateTime.parse(from + "T00:00:00Z"));
}
if (to != null && !to.isBlank()) {
q.le(PlatformAuditEvent::getCreatedAt, OffsetDateTime.parse(to + "T23:59:59Z"));
}
return q;
}
private AuditEventResponse toResponse(PlatformAuditEvent e) {
AuditEventResponse r = new AuditEventResponse();
r.setId(e.getId());
web/delivery-platform-ui/src/api/platform.js
+17 -1
View File
@@ -117,12 +117,28 @@ export function patchContractStatus(id, body) {
/**
* M10-F01 审计分页：`GET /api/v1/audit-events`。
* @param {{ entityType: string, entityId: string | number, page?: number, size?: number }} params
* @param {{ entityType?: string, entityId?: string | number, page?: number, size?: number }} params
*/
export function listAuditEvents(params) {
return axios.get("/api/v1/audit-events", { params });
}
/**
* M10-F02 审计检索：`GET /api/v1/audit-events`（无分页）。
* @param {{ entityType?: string, entityId?: string | number, from?: string, to?: string }} params
*/
export function searchAuditEvents(params) {
return axios.get("/api/v1/audit-events", { params });
}
/**
* M10-F03 审计导出 CSV：`GET /api/v1/audit-events/export`。
* @param {{ entityType?: string, entityId?: string | number, from?: string, to?: string }} params
*/
export function exportAuditEvents(params) {
return axios.get("/api/v1/audit-events/export", { params, responseType: 'blob' });
}
/**
* @param {{ page?: number, size?: number, projectId?: string | number, keyword?: string }} params
*/
web/delivery-platform-ui/src/router/index.js
+6
View File
@@ -182,6 +182,12 @@ const routes = [
component: () => import("../views/ProjectHealthView.vue"),
meta: { roles: ["SYS_ADMIN"], title: "项目健康度" },
},
{
path: "audit",
name: "audit",
component: () => import("../views/AuditSearchView.vue"),
meta: { roles: ["SYS_ADMIN"], title: "审计日志" },
},
],
},
{ path: "/403", name: "forbidden", component: () => import("../views/ForbiddenView.vue") },
web/delivery-platform-ui/src/views/AuditSearchView.vue
+168
View File
@@ -0,0 +1,168 @@
<template>
<el-card shadow="never">
<template #header>
<div class="toolbar">
<span class="title">审计日志</span>
<div class="actions">
<el-input v-model="filters.entityType" clearable placeholder="实体类型" class="filter-item" />
<el-input v-model="filters.entityId" clearable placeholder="实体 ID" class="filter-item" />
<el-input v-model="filters.userId" clearable placeholder="操作者" class="filter-item" />
<el-date-picker
v-model="dateRange"
type="daterange"
range-separator="至"
start-placeholder="开始日期"
end-placeholder="结束日期"
value-format="YYYY-MM-DD"
class="filter-item"
/>
<el-button type="primary" :loading="loading" @click="load">查询</el-button>
<el-button :loading="exporting" @click="onExport">导出 CSV</el-button>
</div>
</div>
</template>
<el-table v-loading="loading" :data="rows" stripe style="width: 100%">
<el-table-column label="时间" min-width="180">
<template #default="{ row }">{{ row.createdAt }}</template>
</el-table-column>
<el-table-column prop="actorUserId" label="操作者" min-width="140" />
<el-table-column prop="action" label="动作" min-width="100" />
<el-table-column prop="entityType" label="实体类型" min-width="120" />
<el-table-column prop="entityId" label="实体 ID" width="100" />
<el-table-column prop="fieldName" label="摘要" min-width="120" show-overflow-tooltip />
<el-table-column label="详情" min-width="200" show-overflow-tooltip>
<template #default="{ row }">{{ row.oldValue }} → {{ row.newValue }}</template>
</el-table-column>
</el-table>
<div class="pager">
<el-pagination
v-model:current-page="page"
v-model:page-size="pageSize"
:total="total"
:page-sizes="[10, 20, 50]"
layout="total, sizes, prev, pager, next, jumper"
background
@current-change="load"
@size-change="onSizeChange"
/>
</div>
</el-card>
</template>
<script setup>
import { ref, reactive, onMounted } from "vue";
import { ElMessage } from "element-plus";
import { useAuthStore } from "../stores/auth";
import { listAuditEvents, exportAuditEvents } from "../api/platform";
import { apiErrorMessage } from "../utils/apiErrorMessage";
const auth = useAuthStore();
const loading = ref(false);
const exporting = ref(false);
const rows = ref([]);
const total = ref(0);
const page = ref(1);
const pageSize = ref(10);
const dateRange = ref(null);
const filters = reactive({
entityType: "",
entityId: "",
userId: "",
});
onMounted(() => {
auth.restoreAxiosAuth();
load();
});
function onSizeChange() {
page.value = 1;
load();
}
async function load() {
loading.value = true;
try {
const params = {
page: page.value - 1,
size: pageSize.value,
};
if (filters.entityType) params.entityType = filters.entityType.trim();
if (filters.entityId) params.entityId = filters.entityId.trim();
if (filters.userId) params.userId = filters.userId.trim();
if (dateRange.value) {
params.from = dateRange.value[0];
params.to = dateRange.value[1];
}
const { data } = await listAuditEvents(params);
const body = data && typeof data === "object" ? data : {};
rows.value = Array.isArray(body.content) ? body.content : [];
total.value = Number(body.totalElements ?? body.total ?? 0);
} catch (e) {
ElMessage.error(apiErrorMessage(e, "加载审计日志失败"));
rows.value = [];
total.value = 0;
} finally {
loading.value = false;
}
}
async function onExport() {
exporting.value = true;
try {
const params = {};
if (filters.entityType) params.entityType = filters.entityType.trim();
if (filters.entityId) params.entityId = filters.entityId.trim();
if (filters.userId) params.userId = filters.userId.trim();
if (dateRange.value) {
params.from = dateRange.value[0];
params.to = dateRange.value[1];
}
const res = await exportAuditEvents(params);
const blob = new Blob([res.data], { type: "text/csv;charset=utf-8" });
const url = URL.createObjectURL(blob);
const a = document.createElement("a");
a.href = url;
a.download = `audit-events-${new Date().toISOString().slice(0, 10)}.csv`;
a.click();
URL.revokeObjectURL(url);
ElMessage.success("导出成功");
} catch (e) {
ElMessage.error(apiErrorMessage(e, "导出失败"));
} finally {
exporting.value = false;
}
}
</script>
<style scoped>
.toolbar {
display: flex;
flex-wrap: wrap;
align-items: center;
justify-content: space-between;
gap: 12px;
}
.title {
font-weight: 600;
font-size: 16px;
}
.actions {
display: flex;
flex-wrap: wrap;
align-items: center;
gap: 8px;
}
.filter-item {
width: 160px;
}
.pager {
margin-top: 16px;
display: flex;
justify-content: flex-end;
}
</style>