优化通知栏，通知实时同步功能

system-admin/CLAUDE.md

@@ -0,0 +1,144 @@
+# CLAUDE.md — system-admin
+
+Backend module: Spring Boot 3.5 admin application (port 8080, context `/system-admin`).
+
+---
+
+## Build & Run
+
+```bash
+mvn clean install -DskipTests           # full build (tests skipped by default)
+mvn clean install -DskipTests=false     # build with tests
+mvn -pl system-admin -DskipTests=false -Dtest=YourTestClass test  # single test
+```
+
+Tests use **JUnit 4** (`@RunWith(SpringRunner.class)`), not JUnit 5. Only 2 test files exist (Redis, dynamic datasource). No Maven wrapper (`mvnw`). Maven remote repository: Aliyun mirror.
+
+Launch from IntelliJ:
+- `AdminApplication` (`system-admin/`) → port 8080, context `/system-admin`
+- `GeneratorApplication` (`renren-generator/`) — commented out of build
+
+## Service layer pattern
+
+Two base classes in `system-common`:
+
+| Base | Purpose |
+|---|---|
+| `CrudService<Dao, Entity, DTO>` | Generic CRUD: `page()`, `get()`, `save()`, `update()`, `delete()` |
+| `BaseService<Dao>` | Lighter base without DTO generic |
+
+Module convention:
+```
+modules/<name>/
+├── controller/  → @RestController, returns Result
+├── dao/         → extends BaseMapper<Entity> (MyBatis-Plus)
+├── dto/         → request/query DTOs (often extends BaseEntity)
+├── entity/      → @TableName JPA entity
+├── service/     → interface extends CrudService/BaseService
+│   └── impl/    → @Service implementation
+├── excel/       → EasyExcel VO classes (optional)
+└── vo/          → response VO classes (optional)
+```
+
+Mapper XMLs: `src/main/resources/mapper/<domain>/**/*.xml`
+
+### Conventions
+
+- Lombok used throughout: `@Data`, `@AllArgsConstructor`, `@Slf4j` are standard on entity/service classes.
+- DTO/Entity/VO separation per module — request DTOs often extend `BaseEntity`.
+
+## PK & Auth
+
+- PK: `ASSIGN_ID` (Snowflake) via `IdUtil.getSnowflakeNextId()`. All entities extend `BaseEntity`. Exception: `WeatherStationEntity` uses `AUTO_INCREMENT`.
+- Auth: Apache Shiro 1.12 (**Jakarta classifier**) + OAuth2 token. Login → `token` header.
+- **Do not introduce Spring Security** — the project uses Shiro exclusively.
+
+## Key cross-cutting mechanisms
+
+| Mechanism | How |
+|---|---|
+| **Data permissions** | `@DataFilter` on controller → `DataFilterAspect` → MyBatis interceptor injects dept-based SQL |
+| **Auto-fill** | `FieldMetaObjectHandler` fills creator/date via MyBatis-Plus. **Only works with `insert()`/`updateById()`** — batch inserts (e.g. `insertBatchMultiRow`) bypass auto-fill; fields must be set manually. |
+| **Scheduled jobs** | Quartz. `schedule_job` table, implements `ITask`, `@Component("beanName")`. Jobs auto-register at startup via `JobCommandLineRunner`. Seed data: `testTask` (paused, every 30 min), `fileScanTask` (paused, every 5 min), `weatherSummarizeCacheTask` (**active**, daily 1 AM). |
+| **File scanning** | `WatchService` (primary, background thread) + Quartz fallback (`FileScanTask`) + startup runner (`FileScanStartupRunner`). Files identified by MD5 hash. |
+| **Excel import** | EasyExcel + async dual-pass via `WeatherDataImportManager`. Progress tracked in-memory (`ConcurrentHashMap`), lost on restart. |
+| **API responses** | Always wrapped in `Result`. Frontend expects `code === 0` for success. |
+| **Validation** | Hibernate Validator. XSS filter via `XssFilter`. i18n messages in `system-common/src/main/resources/i18n/validation.properties`. |
+
+## Exception handling
+
+Single `@RestControllerAdvice` handler in the admin module:
+
+| Handler | Catches | Persists errors? |
+|---|---|---|
+| `CustomExceptionHandler` | `CommonException`, `DuplicateKeyException`, `UnauthorizedException`, generic `Exception` | **Yes** — saves to `SysLogErrorService` (IP, user-agent, URI, params, stack trace) |
+
+Both return a generic error for caught `Exception` (not the exception message). `CommonException` uses i18n message lookup via `MessageUtils.getMessage(code)`. Error codes follow `int` scheme: 5 digits, first 2 = module, last 3 = business (e.g. `10001`-`10029`).
+
+## Logging
+
+- Logback-spring config in `system-admin/src/main/resources/logback-spring.xml`. Logger names use `io.renren` (fork legacy), **not** `com.weather`.
+- Admin dev profile enables MyBatis SQL stdout logging (`StdOutImpl`).
+- When adding `@Slf4j` to `com.weather.*` classes, add a `com.weather` level override or change the existing `io.renren` logger scope.
+
+## Redis & Docs
+
+- Redis: `project-options.redis.open: true` in dev YAML controls whether `RedisAspect` intercepts Redis calls (default `false` — Redis operations silently skipped when disabled).
+- Knife4j: disabled by default (`knife4j.enable: false`). Docs at `/doc.html` when enabled.
+- `RedisAspect` wraps `@RedisCache` annotations with channel publish for cache invalidation.
+
+## MyBatis-Plus gotchas
+
+- **Batch inserts bypass auto-fill** — `FieldMetaObjectHandler` only fires on `insert()`/`updateById()`. Custom batch methods must manually set `creator`, `createDate`, `updater`, `updateDate`, `deptId`.
+- Column names with special characters (e.g. `rain_20_20`) require explicit `@TableField` annotations — MyBatis-Plus cannot auto-map them from camelCase.
+- `typeAliasesPackage: com.weather.modules.*.entity` — all entity classes must reside under a `modules` sub-package.
+
+## Weather domain
+
+Three sub-modules under `system-admin/.../modules/weather/`:
+
+| Module | Purpose |
+|---|---|
+| `dailydata/` | Daily observations, Excel batch import (async dual-pass), EasyExcel listener, summary export |
+| `station/` | Weather station CRUD, linked to dept via `dept_id` |
+| `filescan/` | File monitoring + serving. Format: `<地区>地区-<指标>.png` / `<地区>地区631信息.txt` |
+
+### Weather data import flow
+
+1. **First pass**: `AnalysisEventListener` counts total rows.
+2. **Second pass**: `WeatherDataListener` processes with batch insert (2000 records/batch).
+3. Progress tracked in-memory via `ConcurrentHashMap<String, ImportProgress>` (`volatile` fields + `AtomicInteger`).
+4. Runs on `CompletableFuture` with manual `UserContextHolder` propagation for security context. (Note: `UserContextHolder` is in `system-admin/.../security/user/`, not the empty `system-common/.../holder/` package.)
+5. On completion, clears Redis summary cache (`weather:summarize:*`).
+
+### Weather summarize cache
+
+`WeatherSummarizeCacheTask` (Quartz job) pre-computes daily historical summaries into Redis. Uses **MySQL-specific** SQL functions (`MONTH()`, `DAY()` on `observe_date`). Cache key: `weather:summarize:{month}:{day}`, non-expiring. Service checks cache first for queries spanning same month/day across years.
+
+### Station priority ordering
+
+`WeatherDailyDataServiceImpl.page()` uses custom `CASE WHEN` SQL to order stations belonging to the user's department + sub-departments first.
+
+## System alert module
+
+CRUD + polling notification system under `modules/sys/`:
+
+| Layer | File |
+|---|---|
+| Entity | `entity/SysAlertEntity.java` — `sys_alert` table, Snowflake PK |
+| DAO | `dao/SysAlertDao.java` + `mapper/sys/SysAlertDao.xml` — `selectActiveAlerts`, `selectActiveAlertsSince`, `countBySource` |
+| DTO | `dto/SysAlertDTO.java` — `publishTime`/`createDate`/`updateDate` read-only |
+| VO | `vo/SysAlertVO.java` — `id` as String (mapped from Long) |
+| Service | `service/SysAlertService.java` + `impl/` — `publishIfNotExists` (dedup by source), `withdraw` (soft), CRUD |
+| Controller | `controller/SysAlertController.java` — polling: `GET active`, `GET active/since` (no auth); CRUD: `page`/`get`/`save`/`update`/`delete`/`withdraw` (Shiro permissions) |
+| Enums | `enums/AlertLevelEnum.java` (info/warning/danger), `enums/AlertSourceTypeEnum.java` (manual/import/schedule/datasource) |
+
+### Data source extension
+
+| File | Role |
+|---|---|
+| `alert/AlertSource.java` | SPI interface: `getName()`, `check()` returning `AlertMessage` records |
+| `alert/AlertSourceCollector.java` | `@Autowired(required=false) List<AlertSource>` auto-discovery, calls `publishIfNotExists` for each |
+| `alert/task/AlertSourcePollingTask.java` | Quartz job (`alertSourcePollingTask`), default paused in `schedule_job` |
+
+To add a new alert source: implement `AlertSource`, register as `@Component`, enable the polling task.

system-admin/src/main/java/com/weather/modules/sys/alert/AlertCreatedEvent.java

@@ -0,0 +1,22 @@
+package com.weather.modules.sys.alert;
+
+import com.weather.modules.sys.vo.SysAlertVO;
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * 通知创建事件。由 {@link com.weather.modules.sys.service.impl.SysAlertServiceImpl}
+ * 在手动发布或数据源推送成功后发布，SSE 服务监听此事件并实时推送给前端。
+ */
+public class AlertCreatedEvent extends ApplicationEvent {
+
+    private final SysAlertVO alert;
+
+    public AlertCreatedEvent(SysAlertVO alert) {
+        super(alert);
+        this.alert = alert;
+    }
+
+    public SysAlertVO getAlert() {
+        return alert;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/AlertDeletedEvent.java

@@ -0,0 +1,21 @@
+package com.weather.modules.sys.alert;
+
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * 通知删除事件。由 {@link com.weather.modules.sys.service.impl.SysAlertServiceImpl#delete(Long[])}
+ * 发布，SSE 服务监听此事件并通知前端批量移除通知。
+ */
+public class AlertDeletedEvent extends ApplicationEvent {
+
+    private final Long[] alertIds;
+
+    public AlertDeletedEvent(Long[] alertIds) {
+        super(alertIds);
+        this.alertIds = alertIds;
+    }
+
+    public Long[] getAlertIds() {
+        return alertIds;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/AlertSource.java

@@ -0,0 +1,46 @@
+package com.weather.modules.sys.alert;
+
+import java.util.List;
+
+/**
+ * 通知数据源接口。
+ * 任何需要自动产生通知的模块，实现此接口并注册为 Spring Bean，
+ * AlertSourceCollector 会定时轮询所有实现并收集通知。
+ *
+ * <p>示例：
+ * <pre>{@code
+ * @Component
+ * public class RainWarningSource implements AlertSource {
+ *     public String getName() { return "rain-warning"; }
+ *     public List<AlertMessage> check() {
+ *         // 查询数据，发现异常则返回 AlertMessage 列表
+ *     }
+ * }
+ * }</pre>
+ */
+public interface AlertSource {
+
+    /**
+     * 数据源唯一标识，用于日志和 source_id 去重
+     */
+    String getName();
+
+    /**
+     * 检查该数据源，返回本次发现的通知。
+     * 返回空列表或 null 表示无新通知。
+     * 返回的通知会通过 (sourceType=datasource, sourceId=getName():message.sourceId) 去重。
+     */
+    List<AlertMessage> check();
+
+    /**
+     * 数据源产生的单条通知
+     */
+    record AlertMessage(String level, String title, String content, String sourceId) {
+        public AlertMessage {
+            if (level == null) level = "info";
+            if (title == null) title = "";
+            if (content == null) content = "";
+            if (sourceId == null) sourceId = "";
+        }
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/AlertSourceCollector.java

@@ -0,0 +1,56 @@
+package com.weather.modules.sys.alert;
+
+import com.weather.modules.sys.service.SysAlertService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * 通知数据源收集器。
+ * 自动发现所有 AlertSource 实现，轮询并发布通知。
+ */
+@Slf4j
+@Component
+public class AlertSourceCollector {
+
+    @Autowired(required = false)
+    private List<AlertSource> sources = Collections.emptyList();
+
+    /**
+     * 轮询所有数据源，通过 SysAlertService 发布去重后的通知。
+     *
+     * @param alertService 通知服务
+     * @return 本次新发布的通知总数
+     */
+    public int collectAll(SysAlertService alertService) {
+        if (sources.isEmpty()) {
+            return 0;
+        }
+        int total = 0;
+        for (AlertSource source : sources) {
+            try {
+                List<AlertSource.AlertMessage> alerts = source.check();
+                if (alerts == null || alerts.isEmpty()) {
+                    continue;
+                }
+                for (AlertSource.AlertMessage a : alerts) {
+                    boolean isNew = alertService.publishIfNotExists(
+                            a.level(), a.title(), a.content(),
+                            "datasource",
+                            source.getName() + ":" + a.sourceId()
+                    );
+                    if (isNew) total++;
+                }
+            } catch (Exception e) {
+                log.error("数据源 [{}] 检查失败", source.getName(), e);
+            }
+        }
+        if (total > 0) {
+            log.info("从 {} 个数据源收集到 {} 条新通知", sources.size(), total);
+        }
+        return total;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/AlertWithdrawnEvent.java

@@ -0,0 +1,21 @@
+package com.weather.modules.sys.alert;
+
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * 通知撤回事件。由 {@link com.weather.modules.sys.service.impl.SysAlertServiceImpl#withdraw(Long)}
+ * 发布，SSE 服务监听此事件并通知前端移除该通知。
+ */
+public class AlertWithdrawnEvent extends ApplicationEvent {
+
+    private final Long alertId;
+
+    public AlertWithdrawnEvent(Long alertId) {
+        super(alertId);
+        this.alertId = alertId;
+    }
+
+    public Long getAlertId() {
+        return alertId;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/SseAlertService.java

@@ -0,0 +1,122 @@
+package com.weather.modules.sys.alert;
+
+import com.weather.modules.sys.vo.SysAlertVO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Service;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.CopyOnWriteArraySet;
+import java.util.stream.Collectors;
+
+/**
+ * SSE 连接管理服务。
+ * 管理所有活跃的 SSE 连接，监听 {@link AlertCreatedEvent} 并实时推送给前端。
+ */
+@Slf4j
+@Service
+public class SseAlertService {
+
+    private final Set<SseEmitter> emitters = new CopyOnWriteArraySet<>();
+
+    /**
+     * 创建并注册一个新的 SSE 连接。
+     * 绑定清理回调：连接完成/超时/异常时自动移除。
+     */
+    public SseEmitter createEmitter() {
+        SseEmitter emitter = new SseEmitter(0L); // 无超时
+        emitters.add(emitter);
+        log.info("SSE 连接已建立，当前连接数: {}", emitters.size());
+
+        emitter.onCompletion(() -> {
+            emitters.remove(emitter);
+            log.info("SSE 连接已关闭(completion)，当前连接数: {}", emitters.size());
+        });
+        emitter.onTimeout(() -> {
+            emitters.remove(emitter);
+            log.info("SSE 连接已关闭(timeout)，当前连接数: {}", emitters.size());
+        });
+        emitter.onError(e -> {
+            emitters.remove(emitter);
+            log.info("SSE 连接已关闭(error)，当前连接数: {}", emitters.size());
+        });
+
+        // 初始连接确认事件
+        try {
+            emitter.send(SseEmitter.event().name("connected").data("ok"));
+        } catch (IOException e) {
+            emitters.remove(emitter);
+        }
+
+        return emitter;
+    }
+
+    /**
+     * 监听通知创建事件，广播到所有活跃 SSE 连接。
+     */
+    @EventListener
+    public void onAlertCreated(AlertCreatedEvent event) {
+        SysAlertVO alert = event.getAlert();
+        if (emitters.isEmpty()) {
+            return;
+        }
+        log.info("广播新通知 [{}] 到 {} 个 SSE 连接", alert.getTitle(), emitters.size());
+        for (SseEmitter emitter : emitters) {
+            try {
+                emitter.send(SseEmitter.event().name("alert").data(alert));
+            } catch (IOException e) {
+                emitters.remove(emitter);
+                log.debug("SSE 发送失败，移除连接");
+            }
+        }
+    }
+
+    /**
+     * 监听通知撤回事件，广播到所有活跃 SSE 连接。
+     */
+    @EventListener
+    public void onAlertWithdrawn(AlertWithdrawnEvent event) {
+        if (emitters.isEmpty()) return;
+        Map<String, String> data = Map.of("id", String.valueOf(event.getAlertId()));
+        log.info("广播撤回通知 [{}] 到 {} 个 SSE 连接", event.getAlertId(), emitters.size());
+        for (SseEmitter emitter : emitters) {
+            try {
+                emitter.send(SseEmitter.event().name("alert-withdrawn").data(data));
+            } catch (IOException e) {
+                emitters.remove(emitter);
+            }
+        }
+    }
+
+    /**
+     * 监听通知删除事件，广播到所有活跃 SSE 连接。
+     */
+    @EventListener
+    public void onAlertDeleted(AlertDeletedEvent event) {
+        if (emitters.isEmpty()) return;
+        List<String> ids = Arrays.stream(event.getAlertIds())
+                .map(String::valueOf)
+                .collect(Collectors.toList());
+        Map<String, List<String>> data = Map.of("ids", ids);
+        log.info("广播删除通知 {} 条到 {} 个 SSE 连接", ids.size(), emitters.size());
+        for (SseEmitter emitter : emitters) {
+            try {
+                emitter.send(SseEmitter.event().name("alert-deleted").data(data));
+            } catch (IOException e) {
+                emitters.remove(emitter);
+            }
+        }
+    }
+
+    /**
+     * 当前活跃连接数。
+     */
+    public int getActiveCount() {
+        return emitters.size();
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/alert/task/AlertSourcePollingTask.java

@@ -0,0 +1,31 @@
+package com.weather.modules.sys.alert.task;
+
+import com.weather.modules.job.task.ITask;
+import com.weather.modules.sys.alert.AlertSourceCollector;
+import com.weather.modules.sys.service.SysAlertService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * 通知数据源定时轮询任务。
+ * 通过 Quartz schedule_job 表注册：
+ * beanName = alertSourcePollingTask，建议 cron = 每 10 分钟。
+ *
+ * <p>默认暂停（status=0），待数据源实现就绪后启用。
+ */
+@Slf4j
+@Component("alertSourcePollingTask")
+@AllArgsConstructor
+public class AlertSourcePollingTask implements ITask {
+
+    private final AlertSourceCollector collector;
+    private final SysAlertService sysAlertService;
+
+    @Override
+    public void run(String params) {
+        log.info("开始轮询通知数据源");
+        int count = collector.collectAll(sysAlertService);
+        log.info("通知数据源轮询完成，新增 {} 条", count);
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/controller/SysAlertController.java

@@ -0,0 +1,132 @@
+package com.weather.modules.sys.controller;
+
+import com.weather.common.annotation.LogOperation;
+import com.weather.common.constant.Constant;
+import com.weather.common.page.PageData;
+import com.weather.common.utils.Result;
+import com.weather.common.validator.AssertUtils;
+import com.weather.common.validator.ValidatorUtils;
+import com.weather.common.validator.group.AddGroup;
+import com.weather.common.validator.group.DefaultGroup;
+import com.weather.common.validator.group.UpdateGroup;
+import com.weather.modules.sys.alert.SseAlertService;
+import com.weather.modules.sys.dto.SysAlertDTO;
+import com.weather.modules.sys.service.SysAlertService;
+import com.weather.modules.sys.vo.SysAlertVO;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.Parameters;
+import io.swagger.v3.oas.annotations.enums.ParameterIn;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 系统通知
+ */
+@RestController
+@RequestMapping("sys/alert")
+@Tag(name = "系统通知")
+@AllArgsConstructor
+public class SysAlertController {
+    private final SysAlertService sysAlertService;
+    private final SseAlertService sseAlertService;
+
+    // ===== 前端轮询接口（无需权限，登录即可访问） =====
+
+    @GetMapping("active")
+    @Operation(summary = "获取所有有效通知")
+    public Result<List<SysAlertVO>> active() {
+        List<SysAlertVO> list = sysAlertService.getActiveAlerts();
+        return new Result<List<SysAlertVO>>().ok(list);
+    }
+
+    @GetMapping("active/since")
+    @Operation(summary = "增量获取通知")
+    @Parameter(name = "since", description = "起始ID（返回ID大于此值的通知）", in = ParameterIn.QUERY)
+    public Result<List<SysAlertVO>> activeSince(@RequestParam(required = false) Long since) {
+        if (since == null) {
+            List<SysAlertVO> list = sysAlertService.getActiveAlerts();
+            return new Result<List<SysAlertVO>>().ok(list);
+        }
+        List<SysAlertVO> list = sysAlertService.getActiveAlertsSince(since);
+        return new Result<List<SysAlertVO>>().ok(list);
+    }
+
+    @GetMapping("stream")
+    @Operation(summary = "通知SSE实时推送")
+    public SseEmitter stream() {
+        return sseAlertService.createEmitter();
+    }
+
+    // ===== 管理后台接口 =====
+
+    @GetMapping("page")
+    @Operation(summary = "分页")
+    @Parameters({
+            @Parameter(name = Constant.PAGE, description = "当前页码，从1开始", in = ParameterIn.QUERY, required = true, ref = "int"),
+            @Parameter(name = Constant.LIMIT, description = "每页显示记录数", in = ParameterIn.QUERY, required = true, ref = "int"),
+            @Parameter(name = Constant.ORDER_FIELD, description = "排序字段", in = ParameterIn.QUERY, ref = "String"),
+            @Parameter(name = Constant.ORDER, description = "排序方式，可选值(asc、desc)", in = ParameterIn.QUERY, ref = "String"),
+            @Parameter(name = "level", description = "级别", in = ParameterIn.QUERY, ref = "String"),
+            @Parameter(name = "title", description = "标题", in = ParameterIn.QUERY, ref = "String"),
+            @Parameter(name = "sourceType", description = "来源类型", in = ParameterIn.QUERY, ref = "String")
+    })
+    @RequiresPermissions("sys:alert:page")
+    public Result<PageData<SysAlertVO>> page(@Parameter(hidden = true) @RequestParam Map<String, Object> params) {
+        PageData<SysAlertVO> page = sysAlertService.pageAlerts(params);
+        return new Result<PageData<SysAlertVO>>().ok(page);
+    }
+
+    @GetMapping("{id}")
+    @Operation(summary = "信息")
+    @RequiresPermissions("sys:alert:info")
+    public Result<SysAlertVO> get(@PathVariable("id") Long id) {
+        SysAlertVO data = sysAlertService.get(id);
+        return new Result<SysAlertVO>().ok(data);
+    }
+
+    @PostMapping
+    @Operation(summary = "保存")
+    @LogOperation("发布通知")
+    @RequiresPermissions("sys:alert:save")
+    public Result save(@RequestBody SysAlertDTO dto) {
+        ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class);
+        sysAlertService.save(dto);
+        return new Result();
+    }
+
+    @PutMapping
+    @Operation(summary = "修改")
+    @LogOperation("修改通知")
+    @RequiresPermissions("sys:alert:update")
+    public Result update(@RequestBody SysAlertDTO dto) {
+        ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class);
+        sysAlertService.update(dto);
+        return new Result();
+    }
+
+    @DeleteMapping
+    @Operation(summary = "删除")
+    @LogOperation("删除通知")
+    @RequiresPermissions("sys:alert:delete")
+    public Result delete(@RequestBody Long[] ids) {
+        AssertUtils.isArrayEmpty(ids, "id");
+        sysAlertService.delete(ids);
+        return new Result();
+    }
+
+    @PutMapping("{id}/withdraw")
+    @Operation(summary = "撤回通知")
+    @LogOperation("撤回通知")
+    @RequiresPermissions("sys:alert:retract")
+    public Result withdraw(@PathVariable Long id) {
+        sysAlertService.withdraw(id);
+        return new Result();
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/dao/SysAlertDao.java

@@ -0,0 +1,30 @@
+package com.weather.modules.sys.dao;
+
+import com.weather.common.dao.BaseDao;
+import com.weather.modules.sys.entity.SysAlertEntity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 系统通知
+ */
+@Mapper
+public interface SysAlertDao extends BaseDao<SysAlertEntity> {
+
+    /**
+     * 查询有效且未过期的通知
+     */
+    List<SysAlertEntity> selectActiveAlerts();
+
+    /**
+     * 增量查询：ID 大于 sinceId 的有效通知
+     */
+    List<SysAlertEntity> selectActiveAlertsSince(@Param("sinceId") Long sinceId);
+
+    /**
+     * 检查 source_type + source_id 是否已存在
+     */
+    int countBySource(@Param("sourceType") String sourceType, @Param("sourceId") String sourceId);
+}

system-admin/src/main/java/com/weather/modules/sys/dto/SysAlertDTO.java

@@ -0,0 +1,61 @@
+package com.weather.modules.sys.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.weather.common.validator.group.AddGroup;
+import com.weather.common.validator.group.DefaultGroup;
+import com.weather.common.validator.group.UpdateGroup;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Null;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 系统通知
+ */
+@Data
+@Schema(title = "系统通知")
+public class SysAlertDTO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @Schema(title = "id")
+    @Null(message = "{id.null}", groups = AddGroup.class)
+    @NotNull(message = "{id.require}", groups = UpdateGroup.class)
+    private Long id;
+
+    @Schema(title = "级别: info|warning|danger")
+    @NotBlank(message = "通知级别不能为空", groups = DefaultGroup.class)
+    private String level;
+
+    @Schema(title = "通知标题")
+    @NotBlank(message = "通知标题不能为空", groups = DefaultGroup.class)
+    private String title;
+
+    @Schema(title = "通知正文")
+    @NotBlank(message = "通知正文不能为空", groups = DefaultGroup.class)
+    private String content;
+
+    @Schema(title = "来源类型")
+    private String sourceType;
+
+    @Schema(title = "业务关联ID")
+    private String sourceId;
+
+    @Schema(title = "过期时间")
+    private Date expireTime;
+
+    @Schema(title = "发布时间")
+    @JsonProperty(access = JsonProperty.Access.READ_ONLY)
+    private Date publishTime;
+
+    @Schema(title = "创建时间")
+    @JsonProperty(access = JsonProperty.Access.READ_ONLY)
+    private Date createDate;
+
+    @Schema(title = "更新时间")
+    @JsonProperty(access = JsonProperty.Access.READ_ONLY)
+    private Date updateDate;
+}

system-admin/src/main/java/com/weather/modules/sys/entity/SysAlertEntity.java

@@ -0,0 +1,71 @@
+package com.weather.modules.sys.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.weather.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 系统通知
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("sys_alert")
+public class SysAlertEntity extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 级别: info | warning | danger
+     */
+    private String level;
+    /**
+     * 通知标题
+     */
+    private String title;
+    /**
+     * 通知正文
+     */
+    private String content;
+    /**
+     * 来源: manual | import | schedule | datasource
+     */
+    private String sourceType;
+    /**
+     * 业务关联ID
+     */
+    private String sourceId;
+    /**
+     * 1=有效 0=已撤回
+     */
+    private Integer isActive;
+    /**
+     * 发布时间
+     */
+    private Date publishTime;
+    /**
+     * 过期时间（null=永不过期）
+     */
+    private Date expireTime;
+    /**
+     * 更新者
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Long updater;
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateDate;
+
+    public boolean isActive() {
+        return isActive != null && isActive == 1;
+    }
+
+    public boolean isExpired() {
+        return expireTime != null && expireTime.before(new Date());
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/enums/AlertLevelEnum.java

@@ -0,0 +1,33 @@
+package com.weather.modules.sys.enums;
+
+/**
+ * 通知级别
+ */
+public enum AlertLevelEnum {
+    INFO("info", "提示"),
+    WARNING("warning", "警告"),
+    DANGER("danger", "紧急");
+
+    private final String value;
+    private final String label;
+
+    AlertLevelEnum(String value, String label) {
+        this.value = value;
+        this.label = label;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public String getLabel() {
+        return label;
+    }
+
+    public static boolean isValid(String value) {
+        for (AlertLevelEnum e : values()) {
+            if (e.value.equals(value)) return true;
+        }
+        return false;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/enums/AlertSourceTypeEnum.java

@@ -0,0 +1,27 @@
+package com.weather.modules.sys.enums;
+
+/**
+ * 通知来源类型
+ */
+public enum AlertSourceTypeEnum {
+    MANUAL("manual", "手动发布"),
+    IMPORT("import", "导入任务"),
+    SCHEDULE("schedule", "定时任务"),
+    DATASOURCE("datasource", "数据源监测");
+
+    private final String value;
+    private final String label;
+
+    AlertSourceTypeEnum(String value, String label) {
+        this.value = value;
+        this.label = label;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public String getLabel() {
+        return label;
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/service/SysAlertService.java

@@ -0,0 +1,55 @@
+package com.weather.modules.sys.service;
+
+import com.weather.common.page.PageData;
+import com.weather.common.service.BaseService;
+import com.weather.modules.sys.dto.SysAlertDTO;
+import com.weather.modules.sys.entity.SysAlertEntity;
+import com.weather.modules.sys.vo.SysAlertVO;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 系统通知
+ */
+public interface SysAlertService extends BaseService<SysAlertEntity> {
+
+    // ===== 前端轮询 =====
+
+    /**
+     * 获取所有有效且未过期的通知
+     */
+    List<SysAlertVO> getActiveAlerts();
+
+    /**
+     * 增量获取：只返回 sinceId 之后的通知
+     */
+    List<SysAlertVO> getActiveAlertsSince(Long sinceId);
+
+    // ===== 发布与撤回 =====
+
+    /**
+     * 发布通知（去重：同 sourceType + sourceId 不重复发）
+     *
+     * @return true=新发布  false=已存在（跳过）
+     */
+    boolean publishIfNotExists(String level, String title, String content,
+                               String sourceType, String sourceId);
+
+    /**
+     * 撤回通知（软删除）
+     */
+    void withdraw(Long id);
+
+    // ===== 管理后台 =====
+
+    PageData<SysAlertVO> pageAlerts(Map<String, Object> params);
+
+    SysAlertVO get(Long id);
+
+    void save(SysAlertDTO dto);
+
+    void update(SysAlertDTO dto);
+
+    void delete(Long[] ids);
+}

system-admin/src/main/java/com/weather/modules/sys/service/impl/SysAlertServiceImpl.java

@@ -0,0 +1,172 @@
+package com.weather.modules.sys.service.impl;
+
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.weather.common.constant.Constant;
+import com.weather.common.page.PageData;
+import com.weather.common.service.impl.BaseServiceImpl;
+import com.weather.common.utils.ConvertUtils;
+import cn.hutool.core.util.IdUtil;
+import com.weather.modules.sys.alert.AlertCreatedEvent;
+import com.weather.modules.sys.alert.AlertDeletedEvent;
+import com.weather.modules.sys.alert.AlertWithdrawnEvent;
+import com.weather.modules.sys.dao.SysAlertDao;
+import com.weather.modules.sys.dto.SysAlertDTO;
+import com.weather.modules.sys.entity.SysAlertEntity;
+import com.weather.modules.sys.enums.AlertLevelEnum;
+import com.weather.modules.sys.service.SysAlertService;
+import com.weather.modules.sys.vo.SysAlertVO;
+import lombok.AllArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 系统通知
+ */
+@Service
+@AllArgsConstructor
+public class SysAlertServiceImpl extends BaseServiceImpl<SysAlertDao, SysAlertEntity> implements SysAlertService {
+
+    private final ApplicationEventPublisher eventPublisher;
+
+    @Override
+    public List<SysAlertVO> getActiveAlerts() {
+        List<SysAlertEntity> entities = baseDao.selectActiveAlerts();
+        return toVOList(entities);
+    }
+
+    @Override
+    public List<SysAlertVO> getActiveAlertsSince(Long sinceId) {
+        List<SysAlertEntity> entities = baseDao.selectActiveAlertsSince(sinceId);
+        return toVOList(entities);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean publishIfNotExists(String level, String title, String content,
+                                      String sourceType, String sourceId) {
+        if (!AlertLevelEnum.isValid(level)) {
+            level = AlertLevelEnum.INFO.getValue();
+        }
+        if (StrUtil.isNotBlank(sourceId)) {
+            int count = baseDao.countBySource(sourceType, sourceId);
+            if (count > 0) {
+                return false;
+            }
+        }
+        SysAlertEntity entity = new SysAlertEntity();
+        entity.setId(IdUtil.getSnowflakeNextId());
+        entity.setLevel(level);
+        entity.setTitle(title);
+        entity.setContent(content);
+        entity.setSourceType(sourceType);
+        entity.setSourceId(sourceId);
+        entity.setIsActive(1);
+        entity.setPublishTime(new Date());
+        entity.setCreateDate(new Date());
+        insert(entity);
+        eventPublisher.publishEvent(new AlertCreatedEvent(toVO(entity)));
+        return true;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void withdraw(Long id) {
+        SysAlertEntity entity = new SysAlertEntity();
+        entity.setId(id);
+        entity.setIsActive(0);
+        entity.setUpdateDate(new Date());
+        updateById(entity);
+        eventPublisher.publishEvent(new AlertWithdrawnEvent(id));
+    }
+
+    @Override
+    public PageData<SysAlertVO> pageAlerts(Map<String, Object> params) {
+        IPage<SysAlertEntity> page = baseDao.selectPage(
+                getPage(params, "publish_time", false),
+                getWrapper(params)
+        );
+        List<SysAlertVO> voList = toVOList(page.getRecords());
+        PageData<SysAlertVO> pageData = new PageData<>(voList, page.getTotal());
+        return pageData;
+    }
+
+    private QueryWrapper<SysAlertEntity> getWrapper(Map<String, Object> params) {
+        String level = (String) params.get("level");
+        String title = (String) params.get("title");
+        String sourceType = (String) params.get("sourceType");
+
+        QueryWrapper<SysAlertEntity> wrapper = new QueryWrapper<>();
+        wrapper.eq("is_active", 1);
+        wrapper.eq(StrUtil.isNotBlank(level), "level", level);
+        wrapper.like(StrUtil.isNotBlank(title), "title", title);
+        wrapper.eq(StrUtil.isNotBlank(sourceType), "source_type", sourceType);
+        return wrapper;
+    }
+
+    @Override
+    public SysAlertVO get(Long id) {
+        SysAlertEntity entity = baseDao.selectById(id);
+        return toVO(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void save(SysAlertDTO dto) {
+        SysAlertEntity entity = ConvertUtils.sourceToTarget(dto, SysAlertEntity.class);
+        entity.setId(IdUtil.getSnowflakeNextId());
+        entity.setIsActive(1);
+        entity.setSourceType(StrUtil.blankToDefault(dto.getSourceType(), "manual"));
+        entity.setPublishTime(new Date());
+        entity.setCreateDate(new Date());
+        insert(entity);
+        eventPublisher.publishEvent(new AlertCreatedEvent(toVO(entity)));
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void update(SysAlertDTO dto) {
+        SysAlertEntity entity = ConvertUtils.sourceToTarget(dto, SysAlertEntity.class);
+        entity.setUpdateDate(new Date());
+        updateById(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void delete(Long[] ids) {
+        deleteBatchIds(Arrays.asList(ids));
+        eventPublisher.publishEvent(new AlertDeletedEvent(ids));
+    }
+
+    // ===== 工具方法 =====
+
+    private SysAlertVO toVO(SysAlertEntity entity) {
+        if (entity == null) return null;
+        SysAlertVO vo = new SysAlertVO();
+        vo.setId(String.valueOf(entity.getId()));
+        vo.setLevel(entity.getLevel());
+        vo.setTitle(entity.getTitle());
+        vo.setContent(entity.getContent());
+        vo.setSourceType(entity.getSourceType());
+        vo.setPublishTime(entity.getPublishTime() != null
+                ? DateUtil.formatDateTime(entity.getPublishTime())
+                : null);
+        vo.setExpireTime(entity.getExpireTime() != null
+                ? DateUtil.formatDateTime(entity.getExpireTime())
+                : null);
+        return vo;
+    }
+
+    private List<SysAlertVO> toVOList(List<SysAlertEntity> entities) {
+        return entities.stream().map(this::toVO).collect(Collectors.toList());
+    }
+}

system-admin/src/main/java/com/weather/modules/sys/vo/SysAlertVO.java

@@ -0,0 +1,43 @@
+package com.weather.modules.sys.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 系统通知 - 前端响应对象
+ */
+@Data
+public class SysAlertVO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 通知ID（对应前端 AlertMessage.id）
+     */
+    private String id;
+    /**
+     * 级别: info | warning | danger（对应前端 AlertMessage.level）
+     */
+    private String level;
+    /**
+     * 标题
+     */
+    private String title;
+    /**
+     * 正文（对应前端 AlertMessage.content）
+     */
+    private String content;
+    /**
+     * 来源类型
+     */
+    private String sourceType;
+    /**
+     * 发布时间（对应前端 AlertMessage.publishTime）
+     */
+    private String publishTime;
+    /**
+     * 过期时间
+     */
+    private String expireTime;
+}

system-admin/src/main/resources/mapper/sys/SysAlertDao.xml

@@ -0,0 +1,30 @@
+<?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="com.weather.modules.sys.dao.SysAlertDao">
+
+    <sql id="activeCondition">
+        is_active = 1
+        AND (expire_time IS NULL OR expire_time > NOW())
+    </sql>
+
+    <select id="selectActiveAlerts" resultType="com.weather.modules.sys.entity.SysAlertEntity">
+        SELECT * FROM sys_alert
+        WHERE <include refid="activeCondition"/>
+        ORDER BY publish_time DESC
+    </select>
+
+    <select id="selectActiveAlertsSince" resultType="com.weather.modules.sys.entity.SysAlertEntity">
+        SELECT * FROM sys_alert
+        WHERE <include refid="activeCondition"/>
+        AND id > #{sinceId}
+        ORDER BY publish_time DESC
+    </select>
+
+    <select id="countBySource" resultType="int">
+        SELECT COUNT(1) FROM sys_alert
+        WHERE source_type = #{sourceType}
+        AND source_id = #{sourceId}
+        AND <include refid="activeCondition"/>
+    </select>
+
+</mapper>