添加上传国网调度记录日志和反馈表

doc/数据库脚本/gateway.sql

@@ -664,4 +664,67 @@ ON COLUMN biz_yk_log.update_time IS '修改时间';
 COMMENT
 ON COLUMN biz_yk_log.create_by IS '创建者';
 COMMENT
-ON COLUMN biz_yk_log.update_by IS '更新者';
+ON COLUMN biz_yk_log.update_by IS '更新者';
+
+-- 上报日志表 data_report_log
+drop table if exists data_report_log;
+CREATE TABLE data_report_log (
+     id BIGSERIAL PRIMARY KEY,
+     curve_id BIGINT NOT NULL,
+     report_time TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+     target_dispatch VARCHAR(64) NOT NULL,
+     channel SMALLINT NOT NULL,
+     message_no VARCHAR(128) NOT NULL,
+     content_path VARCHAR(256),
+     status SMALLINT NOT NULL,
+     response_msg TEXT,
+     remark varchar(200),
+     create_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+     update_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+     create_by varchar(25) NOT NULL DEFAULT '',
+     update_by varchar(25) NOT NULL DEFAULT '',
+    -- 索引：按曲线查上报记录、按上报时间检索
+     CONSTRAINT uk_report_log_msg_no UNIQUE(message_no)
+);
+
+-- 注释（PG专用COMMENT）
+COMMENT ON TABLE data_report_log IS '功率预测上报日志表，记录每次向电网调度上报预测曲线';
+COMMENT ON COLUMN data_report_log.id IS '日志主键ID';
+COMMENT ON COLUMN data_report_log.curve_id IS '关联预测曲线ID(forecast_curve)';
+COMMENT ON COLUMN data_report_log.report_time IS '上报发起时间';
+COMMENT ON COLUMN data_report_log.target_dispatch IS '目标调度机构：省调/地调名称';
+COMMENT ON COLUMN data_report_log.channel IS '上报通道：1=IEC104，2=XML文件，3=FTP，4=MQTT';
+COMMENT ON COLUMN data_report_log.message_no IS '报文流水号，对外唯一';
+COMMENT ON COLUMN data_report_log.content_path IS '报文原文存储路径';
+COMMENT ON COLUMN data_report_log.status IS '上报状态：0待发送，1上报成功，2上报失败，3超时';
+COMMENT ON COLUMN data_report_log.response_msg IS '调度侧返回报文/反馈信息';
+COMMENT ON COLUMN data_report_log.remark IS '备注，失败原因描述';
+COMMENT ON COLUMN data_report_log.create_time IS '记录创建时间';
+COMMENT ON COLUMN data_report_log.update_time IS '记录更新时间';
+
+-- 调度回执确认表 data_dispatch_confirm
+DROP TABLE IF EXISTS data_dispatch_confirm;
+CREATE TABLE data_dispatch_confirm (
+   id BIGSERIAL PRIMARY KEY,
+   curve_id BIGINT NOT NULL,
+   data_report_log_id BIGINT,
+   confirm_time TIMESTAMPTZ NOT NULL,
+   confirm_result SMALLINT NOT NULL,
+   feedback_info TEXT,
+   dispatch_msg_no VARCHAR(128),
+   create_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+   update_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+   create_by varchar(25) NOT NULL DEFAULT '',
+   update_by varchar(25) NOT NULL DEFAULT ''
+);
+
+-- 字段注释
+COMMENT ON TABLE data_dispatch_confirm IS '调度系统回执确认表，存储调度对预测曲线上报的接收/拒收反馈';
+COMMENT ON COLUMN data_dispatch_confirm.id IS '回执主键ID';
+COMMENT ON COLUMN data_dispatch_confirm.curve_id IS '关联预测曲线ID(forecast_curve)';
+COMMENT ON COLUMN data_dispatch_confirm.data_report_log_id IS '关联上报日志ID(report_log)，可选';
+COMMENT ON COLUMN data_dispatch_confirm.confirm_time IS '调度回执接收时间';
+COMMENT ON COLUMN data_dispatch_confirm.confirm_result IS '回执结果：0=待回执，1=接收成功，2=拒收，3=数据修正';
+COMMENT ON COLUMN data_dispatch_confirm.feedback_info IS '调度反馈详细说明、拒绝原因';
+COMMENT ON COLUMN data_dispatch_confirm.dispatch_msg_no IS '调度侧报文流水号';
+