feat(wm-dispatch): #69 调度指令全生命周期管理

- 实现调度指令全生命周期：DRAFT → ISSUED → RECEIVED → EXECUTING → COMPLETED/REJECTED/CANCELLED
- 添加完整状态机服务：CommandLifecycleService（18个API端点）
- 实现指令台账管理：CommandLedgerService（多维度查询/统计/导出）
- 提供全过程追踪：CommandTrackingService（时间线追踪）
- 支持分页查询、状态统计、追踪日志查询
- 完整的调度指令实体、服务、控制器
- 提供指令台账列表查询和统计概览功能

wm-dispatch/target/classes/application.yml

@@ -0,0 +1,15 @@
+server:
+  port: 9050
+spring:
+  application:
+    name: wm-dispatch
+  datasource:
+    url: jdbc:postgresql://localhost:5432/water_dispatch
+    username: water
+    password: water123
+mybatis-plus:
+  configuration:
+    map-underscore-to-camel-case: true
+  global-config:
+    db-config:
+      id-type: auto

wm-dispatch/target/classes/db/V1__dispatch.sql

@@ -0,0 +1,33 @@
+CREATE TABLE IF NOT EXISTS dispatch_duty_schedule (
+    id BIGSERIAL PRIMARY KEY, user_id BIGINT, user_name VARCHAR(50),
+    duty_date DATE, start_time TIME, end_time TIME, area VARCHAR(100),
+    created_time TIMESTAMP DEFAULT NOW(), updated_time TIMESTAMP DEFAULT NOW()
+);
+CREATE TABLE IF NOT EXISTS dispatch_command (
+    id BIGSERIAL PRIMARY KEY, cmd_no VARCHAR(50) UNIQUE, title VARCHAR(200),
+    content TEXT, type VARCHAR(20), status INT DEFAULT 0,
+    issued_time TIMESTAMP, completed_time TIMESTAMP,
+    created_time TIMESTAMP DEFAULT NOW(), updated_time TIMESTAMP DEFAULT NOW()
+);
+CREATE TABLE IF NOT EXISTS dispatch_work_order (
+    id BIGSERIAL PRIMARY KEY, order_no VARCHAR(50) UNIQUE, title VARCHAR(200),
+    description TEXT, type VARCHAR(20), priority VARCHAR(10), status INT DEFAULT 0,
+    assignee_id BIGINT, creator_id BIGINT, deadline TIMESTAMP, completed_at TIMESTAMP,
+    created_time TIMESTAMP DEFAULT NOW(), updated_time TIMESTAMP DEFAULT NOW()
+);
+CREATE TABLE IF NOT EXISTS dispatch_duty_log (
+    id BIGSERIAL PRIMARY KEY, schedule_id BIGINT, user_id BIGINT,
+    log_type VARCHAR(20), content TEXT, attachments TEXT,
+    created_time TIMESTAMP DEFAULT NOW()
+);
+CREATE TABLE IF NOT EXISTS dispatch_strategy (
+    id BIGSERIAL PRIMARY KEY, name VARCHAR(100), type VARCHAR(20),
+    description TEXT, rule_config TEXT, status INT DEFAULT 1,
+    created_time TIMESTAMP DEFAULT NOW(), updated_time TIMESTAMP DEFAULT NOW()
+);
+CREATE TABLE IF NOT EXISTS dispatch_emergency_plan (
+    id BIGSERIAL PRIMARY KEY, plan_no VARCHAR(50) UNIQUE, name VARCHAR(100),
+    type VARCHAR(20), content TEXT, resource_config TEXT,
+    status INT DEFAULT 0, creator_id BIGINT,
+    created_time TIMESTAMP DEFAULT NOW(), updated_time TIMESTAMP DEFAULT NOW()
+);

wm-dispatch/target/classes/db/V2__command_lifecycle.sql

@@ -0,0 +1,73 @@
+-- V2: 调度指令全生命周期管理
+-- 新增/重建表，支持 创建→下发→接收确认→执行反馈→完成归档 全流程
+
+-- 1. 调度指令主表（增强）
+CREATE TABLE IF NOT EXISTS disp_dispatch_command (
+    id              BIGSERIAL PRIMARY KEY,
+    command_no      VARCHAR(64)  NOT NULL UNIQUE,
+    title           VARCHAR(200) NOT NULL,
+    content         TEXT,
+    command_type    VARCHAR(30)  NOT NULL DEFAULT 'NORMAL',   -- NORMAL / EMERGENCY / MAINTENANCE
+    priority        VARCHAR(20)  NOT NULL DEFAULT 'MEDIUM',   -- LOW / MEDIUM / HIGH / URGENT
+    status          VARCHAR(30)  NOT NULL DEFAULT 'DRAFT',    -- DRAFT / ISSUED / RECEIVED / EXECUTING / COMPLETED / REJECTED / CANCELLED
+    issuer_id       BIGINT,
+    issuer_name     VARCHAR(64),
+    receiver_id     BIGINT,
+    receiver_name   VARCHAR(64),
+    facility_id     BIGINT,
+    deadline        TIMESTAMP,
+    issued_at       TIMESTAMP,
+    received_at     TIMESTAMP,
+    executed_at     TIMESTAMP,
+    completed_at    TIMESTAMP,
+    rejected_at     TIMESTAMP,
+    reject_reason   TEXT,
+    execute_result  TEXT,
+    remark          TEXT,
+    deleted         INT DEFAULT 0,
+    created_at      TIMESTAMP DEFAULT NOW(),
+    updated_at      TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_cmd_status      ON disp_dispatch_command(status);
+CREATE INDEX idx_cmd_type        ON disp_dispatch_command(command_type);
+CREATE INDEX idx_cmd_priority    ON disp_dispatch_command(priority);
+CREATE INDEX idx_cmd_issuer      ON disp_dispatch_command(issuer_id);
+CREATE INDEX idx_cmd_receiver    ON disp_dispatch_command(receiver_id);
+CREATE INDEX idx_cmd_deadline    ON disp_dispatch_command(deadline);
+CREATE INDEX idx_cmd_created_at  ON disp_dispatch_command(created_at);
+
+-- 2. 执行记录表
+CREATE TABLE IF NOT EXISTS disp_command_execution_record (
+    id              BIGSERIAL PRIMARY KEY,
+    command_id      BIGINT       NOT NULL,
+    command_no      VARCHAR(64),
+    executor_id     BIGINT       NOT NULL,
+    executor_name   VARCHAR(64),
+    action          VARCHAR(30)  NOT NULL,    -- RECEIVE / START / PROGRESS / COMPLETE / REJECT
+    description     TEXT,
+    attachments     TEXT,                      -- JSON array of file URLs
+    progress        INT DEFAULT 0,            -- 0-100
+    created_at      TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_exec_cmd_id ON disp_command_execution_record(command_id);
+CREATE INDEX idx_exec_cmd_no ON disp_command_execution_record(command_no);
+
+-- 3. 过程追踪表（时间线）
+CREATE TABLE IF NOT EXISTS disp_command_tracking (
+    id              BIGSERIAL PRIMARY KEY,
+    command_id      BIGINT       NOT NULL,
+    command_no      VARCHAR(64),
+    stage           VARCHAR(30)  NOT NULL,    -- CREATED / ISSUED / RECEIVED / EXECUTING / COMPLETED / REJECTED / CANCELLED
+    operator_id     BIGINT,
+    operator_name   VARCHAR(64),
+    action_desc     VARCHAR(500),
+    from_status     VARCHAR(30),
+    to_status       VARCHAR(30),
+    created_at      TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_track_cmd_id ON disp_command_tracking(command_id);
+CREATE INDEX idx_track_cmd_no ON disp_command_tracking(command_no);
+CREATE INDEX idx_track_stage  ON disp_command_tracking(stage);

wm-dispatch/target/classes/db/V2__emergency_drill.sql

@@ -0,0 +1,67 @@
+-- Emergency Drill & Response DDL
+CREATE TABLE IF NOT EXISTS disp_pipe_burst_simulation (
+    id BIGSERIAL PRIMARY KEY,
+    simulation_no VARCHAR(50) UNIQUE,
+    location VARCHAR(200),
+    lng DOUBLE PRECISION,
+    lat DOUBLE PRECISION,
+    pipe_diameter DOUBLE PRECISION,
+    pipe_material VARCHAR(50),
+    affected_radius INT,
+    affected_users INT,
+    estimated_water_loss DOUBLE PRECISION,
+    estimated_repair_hours INT,
+    pressure_drop DOUBLE PRECISION,
+    affected_valves TEXT,
+    status VARCHAR(20) DEFAULT 'COMPLETED',
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE TABLE IF NOT EXISTS disp_water_quality_incident (
+    id BIGSERIAL PRIMARY KEY,
+    incident_no VARCHAR(50) UNIQUE,
+    location VARCHAR(200),
+    pollutant_type VARCHAR(50),
+    detected_value DOUBLE PRECISION,
+    standard_value DOUBLE PRECISION,
+    severity VARCHAR(20),
+    status VARCHAR(20) DEFAULT 'DETECTED',
+    matched_plan VARCHAR(200),
+    detected_time TIMESTAMP,
+    response_start_time TIMESTAMP,
+    resolved_time TIMESTAMP,
+    response_log TEXT,
+    resolution TEXT,
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE TABLE IF NOT EXISTS disp_emergency_drill (
+    id BIGSERIAL PRIMARY KEY,
+    drill_no VARCHAR(50) UNIQUE,
+    name VARCHAR(200),
+    drill_type VARCHAR(30),
+    description TEXT,
+    status VARCHAR(20) DEFAULT 'PLANNED',
+    planned_time TIMESTAMP,
+    started_time TIMESTAMP,
+    completed_time TIMESTAMP,
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE TABLE IF NOT EXISTS disp_drill_evaluation (
+    id BIGSERIAL PRIMARY KEY,
+    drill_id BIGINT REFERENCES disp_emergency_drill(id),
+    score INT,
+    response_time_score INT,
+    coordination_score INT,
+    overall_rating VARCHAR(20),
+    findings TEXT,
+    recommendations TEXT,
+    evaluator VARCHAR(50),
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX IF NOT EXISTS idx_pbs_status ON disp_pipe_burst_simulation(status);
+CREATE INDEX IF NOT EXISTS idx_wqi_status ON disp_water_quality_incident(status);
+CREATE INDEX IF NOT EXISTS idx_wqi_type ON disp_water_quality_incident(pollutant_type);
+CREATE INDEX IF NOT EXISTS idx_ed_status ON disp_emergency_drill(status);

wm-dispatch/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -0,0 +1,43 @@
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/DispatchApplication.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/controller/DispatchCommandController.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/controller/DispatchController.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/controller/EmergencyController.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/CommandExecutionRecord.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/CommandTracking.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/DispatchCommand.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/DispatchStrategy.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/DrillEvaluation.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/DutyLog.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/DutySchedule.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/EmergencyDrill.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/EmergencyPlan.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/PipeBurstSimulation.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/WaterQualityIncident.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/WorkOrder.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/CommandCreateRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/CommandQueryRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/CommandStatVO.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/DrillCreateRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/DrillEvaluationRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/ExecutionRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/PipeBurstRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/entity/dto/WaterQualityRequest.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/CommandExecutionRecordMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/CommandTrackingMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/DispatchCommandMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/DispatchStrategyMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/DrillEvaluationMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/DutyLogMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/DutyScheduleMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/EmergencyDrillMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/EmergencyPlanMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/PipeBurstSimulationMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/WaterQualityIncidentMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/mapper/WorkOrderMapper.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/CommandLedgerService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/CommandLifecycleService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/CommandTrackingService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/DispatchBizService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/EmergencyDrillService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/PipeBurstService.java
+/root/.openclaw/workspace/water-management-system/wm-dispatch/src/main/java/com/water/dispatch/service/WaterQualityIncidentService.java