-- 平台对接模块 DDL -- 创建时间: 2026-05-30 -- ---------------------------- -- 0. 平台传感器类型字典 -- 页面从 platform_sensor_type 读取选项，新增类型只需维护字典。 -- ---------------------------- INSERT IGNORE INTO `sys_dict_type` (`dict_name`, `dict_type`, `status`, `create_by`, `create_time`, `remark`) VALUES ('平台传感器类型', 'platform_sensor_type', '0', 'system', NOW(), '第三方平台对接使用的传感器类型'); DELETE FROM `sys_dict_data` WHERE `dict_type` = 'platform_sensor_type' AND `dict_value` IN ('inclino', 'deep_inclino', 'stress', 'hyeto', 'static_level'); INSERT INTO `sys_dict_data` (`dict_sort`, `dict_label`, `dict_value`, `dict_type`, `list_class`, `is_default`, `status`, `create_by`, `create_time`, `remark`) VALUES (1, '倾角', 'inclino', 'platform_sensor_type', 'primary', 'N', '0', 'system', NOW(), 'DCP倾角'), (2, '深部位移计', 'deep_inclino', 'platform_sensor_type', 'primary', 'N', '0', 'system', NOW(), 'DCP深部位移计'), (3, '轴力计', 'stress', 'platform_sensor_type', 'primary', 'N', '0', 'system', NOW(), 'DCP轴力计'), (4, '雨量计', 'hyeto', 'platform_sensor_type', 'primary', 'N', '0', 'system', NOW(), 'DCP雨量计'), (5, '静力水准仪', 'static_level', 'platform_sensor_type', 'primary', 'N', '0', 'system', NOW(), 'DCP静力水准'); INSERT INTO `sys_dict_data_translate` (`id`,`zh_cn`, `en_us`) VALUES (738,'倾角','inclino'), (739,'深部位移','deepInclino'), (740,'轴力','stress'), (741,'雨量','hyeto'), (742,'静力水准','staticLevel') ; -- ---------------------------- -- 1. 平台实体 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_instance` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `name` varchar(100) NOT NULL COMMENT '平台名称，如 DCP结构监测', `code` varchar(50) NOT NULL COMMENT '平台唯一标识，如 dcp', `base_url` varchar(255) NOT NULL COMMENT '基础URL', `auth_type` tinyint(1) NOT NULL DEFAULT 1 COMMENT '认证类型(1=密码Token,2=ApiKey,3=OAuth2)', `auth_config` json DEFAULT NULL COMMENT '认证凭证JSON {userName,password,clientId,scope}', `extra_config` json DEFAULT NULL COMMENT '初始化后保存的平台数据 {userId,projectId,...}', `access_token` varchar(2000) DEFAULT NULL COMMENT '当前有效Token', `token_expires_at` datetime DEFAULT NULL COMMENT 'Token过期时间', `init_status` tinyint(1) NOT NULL DEFAULT 0 COMMENT '初始化状态(0=未初始化,1=已初始化)', `enable` char(1) NOT NULL DEFAULT '1' COMMENT '是否启用(0=禁用,1=启用)', `tenant_id` bigint(20) DEFAULT NULL COMMENT '租户ID', `remark` varchar(500) DEFAULT NULL COMMENT '备注', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_code` (`code`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='第三方平台实体'; -- ---------------------------- -- 2. 接口定义 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_interface` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `platform_id` bigint(20) NOT NULL COMMENT '所属平台ID', `name` varchar(100) NOT NULL COMMENT '接口名称', `code` varchar(100) NOT NULL COMMENT '接口标识', `method` varchar(10) NOT NULL COMMENT 'HTTP方法: GET/POST/PUT/DELETE', `is_batch_push` tinyint(1) NOT NULL DEFAULT 0 COMMENT '是否批量推送(0=否,1=是)，用于深部位移等整孔数据推送', `path` varchar(255) NOT NULL COMMENT '接口路径，支持路径变量 {userId}', `content_type` varchar(100) DEFAULT 'application/json' COMMENT 'Content-Type', `request_schema` json DEFAULT NULL COMMENT '入参字段定义 [{name,type,source,value,field,contextKey,required,desc}]', `response_schema` json DEFAULT NULL COMMENT '出参字段定义 [{name,type,path,desc}]', `sort_order` int(11) DEFAULT 0 COMMENT '排序', `remark` varchar(500) DEFAULT NULL COMMENT '备注', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_platform_id` (`platform_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台接口定义'; ALTER TABLE `platform_interface` ADD COLUMN `is_batch_push` tinyint(1) NOT NULL DEFAULT 0 COMMENT '是否批量推送(0=否,1=是)，用于深部位移等整孔数据推送' AFTER `method` -- ---------------------------- -- 3. 流程定义 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_flow` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `platform_id` bigint(20) NOT NULL COMMENT '所属平台ID', `name` varchar(100) NOT NULL COMMENT '流程名称', `code` varchar(100) NOT NULL COMMENT '流程标识', `flow_type` tinyint(1) NOT NULL COMMENT '流程类型(1=平台初始化,2=设备入网,3=Token刷新)', `sensor_type` varchar(50) DEFAULT NULL COMMENT '传感器类型，flow_type=2时有效，来自字典 platform_sensor_type', `enable` char(1) NOT NULL DEFAULT '1' COMMENT '是否启用', `remark` varchar(500) DEFAULT NULL COMMENT '备注', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_platform_type` (`platform_id`, `flow_type`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台对接流程'; -- ---------------------------- -- 4. 流程步骤 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_flow_step` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `flow_id` bigint(20) NOT NULL COMMENT '所属流程ID', `step_order` int(11) NOT NULL DEFAULT 1 COMMENT '执行顺序，从1开始', `interface_id` bigint(20) NOT NULL COMMENT '关联接口ID', `param_mapping` json DEFAULT NULL COMMENT '入参来源覆盖配置，覆盖接口默认schema', `result_key` varchar(100) DEFAULT NULL COMMENT '出参写入上下文的key，如 step1', `result_save` json DEFAULT NULL COMMENT '需持久化的出参字段 [{field,saveTo}]', `remark` varchar(255) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), KEY `idx_flow_id` (`flow_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='流程步骤'; -- ---------------------------- -- 5. 设备绑定关系 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_device_mapping` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `platform_id` bigint(20) NOT NULL COMMENT '所属平台ID', `platform_user_auth_id` bigint(20) DEFAULT NULL COMMENT '关联用户认证ID', `platform_project_id` varchar(100) NOT NULL COMMENT 'DCP项目ID', `platform_project_name` varchar(255) DEFAULT NULL COMMENT 'DCP项目名称', `device_id` bigint(20) NOT NULL COMMENT 'FastBee设备ID', `serial_number` varchar(64) NOT NULL COMMENT 'FastBee设备序列号', `device_name` varchar(64) DEFAULT NULL COMMENT '默认为本平台设备名称，可以修改为对方平台需要的名称', `platform_device_id` varchar(100) DEFAULT NULL COMMENT 'DCP侧deviceId，入网后自动回填', `platform_point_id` varchar(100) DEFAULT NULL COMMENT 'DCP侧pointId，入网后自动回填', `sensor_type` varchar(50) NOT NULL COMMENT '传感器类型，来自字典 platform_sensor_type', `device_type` tinyint(1) NOT NULL DEFAULT 0 COMMENT '设备类型: 0=直连设备 1=网关设备(多子设备)', `push_interface_id` bigint(20) DEFAULT NULL COMMENT '推送接口ID，用于字段映射参照', `field_mapping` json DEFAULT NULL COMMENT '字段映射 [{identifier,platformField,transform}]', `extra_mapping` json DEFAULT NULL COMMENT '扩展映射配置，如静力水准子设备编号与DCP sensorId映射', `net_status` tinyint(1) NOT NULL DEFAULT 0 COMMENT '入网状态(0=未入网,1=已入网)', `push_mode` TINYINT(1) NOT NULL DEFAULT 1 COMMENT '推送模式：1=实时 2=定时（默认1）', `push_interval` INT DEFAULT 0 COMMENT '定时推送间隔（分钟），0=不自动推送', `last_push_time` DATETIME DEFAULT NULL COMMENT '最近推送时间', `enable` char(1) NOT NULL DEFAULT '1' COMMENT '是否启用', `remark` varchar(255) DEFAULT NULL COMMENT '备注', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_serial` (`serial_number`), KEY `idx_platform_device` (`platform_id`, `device_id`), KEY `idx_user_auth` (`platform_user_auth_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台设备绑定关系'; -- ---------------------------- -- 5.1 设备绑定关系 - 补充绑定项目和设备类型字段 -- ---------------------------- ALTER TABLE `platform_device_mapping` ADD COLUMN IF NOT EXISTS `platform_project_id` varchar(100) DEFAULT NULL COMMENT 'DCP项目ID' AFTER `platform_id`, ADD COLUMN IF NOT EXISTS `platform_project_name` varchar(255) DEFAULT NULL COMMENT 'DCP项目名称' AFTER `platform_project_id`; ALTER TABLE `platform_device_mapping` ADD COLUMN IF NOT EXISTS `device_type` tinyint(1) NOT NULL DEFAULT 0 COMMENT '设备类型: 0=直连设备 1=网关设备(多子设备)' AFTER `sensor_type`; ALTER TABLE `platform_device_mapping` ADD COLUMN `device_name` varchar(64) DEFAULT NULL COMMENT '默认为本平台设备名称，可以修改为对方平台需要的名称' AFTER `serial_number`; -- 添加推送模式字段 ALTER TABLE platform_device_mapping ADD COLUMN `push_mode` TINYINT DEFAULT 1 COMMENT '推送模式：1=实时 2=定时（默认1）' AFTER `net_status`; -- 添加定时推送间隔字段 ALTER TABLE platform_device_mapping ADD COLUMN `push_interval` INT DEFAULT 0 COMMENT '定时推送间隔（分钟），0=不自动推送' after `push_mode`; -- 添加最近推送时间字段 ALTER TABLE platform_device_mapping ADD COLUMN `last_push_time` DATETIME DEFAULT NULL COMMENT '最近推送时间' after `push_interval`; -- 添加索引优化查询性能 CREATE INDEX idx_push_mode ON platform_device_mapping(push_mode); CREATE INDEX idx_last_push_time ON platform_device_mapping(last_push_time); -- ---------------------------- -- 5.2 子设备映射（网关多子设备通用） -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_device_sub_mapping` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `parent_mapping_id` bigint(20) NOT NULL COMMENT '父映射ID (platform_device_mapping.id)', `sub_serial_number` varchar(64) NOT NULL COMMENT '子设备序列号', `sub_device_name` varchar(64) DEFAULT NULL COMMENT '子设备名称', `device_role` varchar(20) NOT NULL DEFAULT 'monitor' COMMENT '角色: reference=基准 monitor=监测', `platform_device_id` varchar(100) DEFAULT NULL COMMENT '平台分配的设备ID (入网后回填)', `platform_point_id` varchar(100) DEFAULT NULL COMMENT '平台分配的测点/辅助ID (入网后回填)', `onboard_config` json DEFAULT NULL COMMENT '入网时传给平台的标识参数(平台相关)', `net_status` tinyint(1) NOT NULL DEFAULT 0 COMMENT '0=未入网 1=已入网', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_parent` (`parent_mapping_id`), KEY `idx_sub_serial` (`sub_serial_number`), UNIQUE KEY `uk_parent_sub` (`parent_mapping_id`, `sub_serial_number`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台设备子映射(网关多子设备通用)'; ALTER TABLE `platform_device_sub_mapping` ADD COLUMN IF NOT EXISTS `sub_device_name` varchar(64) DEFAULT NULL COMMENT '子设备名称' AFTER `sub_serial_number`; -- ---------------------------- -- 6. 推送日志 -- ---------------------------- CREATE TABLE IF NOT EXISTS `platform_push_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `platform_id` bigint(20) NOT NULL COMMENT '平台ID', `flow_id` bigint(20) DEFAULT NULL COMMENT '流程ID', `step_order` int(11) DEFAULT NULL COMMENT '步骤序号', `device_id` bigint(20) DEFAULT NULL COMMENT '设备ID', `serial_number` varchar(64) DEFAULT NULL COMMENT '设备序列号', `interface_code` varchar(100) DEFAULT NULL COMMENT '接口标识', `request_url` varchar(500) DEFAULT NULL COMMENT '请求URL', `request_body` mediumtext DEFAULT NULL COMMENT '请求体', `response_code` int(11) DEFAULT NULL COMMENT 'HTTP响应码', `response_body` mediumtext DEFAULT NULL COMMENT '响应体', `status` tinyint(1) NOT NULL DEFAULT 0 COMMENT '状态(0=进行中,1=成功,2=失败)', `error_msg` varchar(1000) DEFAULT NULL COMMENT '错误信息', `idempotency_key` varchar(100) DEFAULT NULL COMMENT '幂等键，防重复推送', `log_type` tinyint(1) NOT NULL DEFAULT 1 COMMENT '日志类型(1=数据推送,2=操作日志)', `retry_count` int(11) NOT NULL DEFAULT 0 COMMENT '重试次数', `cost_ms` int(11) DEFAULT NULL COMMENT '耗时毫秒', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', PRIMARY KEY (`id`), KEY `idx_platform_status` (`platform_id`, `status`), KEY `idx_device_time` (`device_id`, `create_time`), KEY `idx_idempotency` (`idempotency_key`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台推送日志'; -- ---------------------------- -- DCP 内置数据初始化 -- ---------------------------- -- DCP 平台接口定义（内置，用户无需手动配置） -- 注意：platform_id 需在创建 DCP 平台实例后更新，此处用占位符 0 -- 实际由 DcpPlatformAdapter 在初始化时写入 -- ---------------------------- -- 7. 创建平台用户认证表 -- ---------------------------- CREATE TABLE `platform_user_auth` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `platform_id` bigint(20) NOT NULL COMMENT '平台实例ID', `platform_user_id` varchar(100) DEFAULT NULL COMMENT '平台侧用户ID（如DCP的userId）', `platform_user_name` varchar(100) DEFAULT NULL COMMENT '平台侧用户名', `auth_config` json DEFAULT NULL COMMENT '用户认证凭证JSON {userName,password,clientId,scope}', `access_token` varchar(2000) DEFAULT NULL COMMENT '该用户的Token', `token_expires_at` datetime DEFAULT NULL COMMENT 'Token过期时间', `init_status` tinyint(1) NOT NULL DEFAULT 0 COMMENT '初始化状态(0=未初始化,1=已初始化)', `extra_config` json DEFAULT NULL COMMENT '用户级配置 {projectId,projectName,...}', `enable` char(1) NOT NULL DEFAULT '1' COMMENT '是否启用', `remark` varchar(500) DEFAULT NULL COMMENT '备注', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_platform_user` (`platform_id`, `platform_user_id`), KEY `idx_token_expire` (`token_expires_at`), KEY `idx_init_status` (`init_status`), KEY `idx_platform_id` (`platform_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台用户认证'; -- ---------------------------- -- 2. 修改 platform_device_mapping 表 -- ---------------------------- -- 增加用户认证关联字段 ALTER TABLE `platform_device_mapping` ADD COLUMN `platform_user_auth_id` bigint(20) DEFAULT NULL COMMENT '关联用户认证ID' AFTER `platform_id`; -- 增加索引 CREATE INDEX `idx_user_auth` ON `platform_device_mapping`(`platform_user_auth_id`); -- 平台对接另外一套方案 -- fastbee.iot_platform_api definition CREATE TABLE `iot_platform_api` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `template_id` bigint NOT NULL COMMENT '平台模板ID', `api_code` varchar(64) NOT NULL COMMENT '接口编码', `api_name` varchar(128) NOT NULL COMMENT '接口名称', `api_type` varchar(32) NOT NULL COMMENT '接口类型', `method` varchar(16) DEFAULT NULL COMMENT '请求方法', `path_template` varchar(512) DEFAULT NULL COMMENT '路径模板', `content_type` varchar(64) DEFAULT NULL COMMENT '内容类型', `header_template` json DEFAULT NULL COMMENT 'Header模板', `query_template` json DEFAULT NULL COMMENT 'Query模板', `body_template` json DEFAULT NULL COMMENT 'Body模板', `auth_config` json DEFAULT NULL COMMENT '接口认证配置', `idempotency_config` json DEFAULT NULL COMMENT '幂等配置', `success_condition` json DEFAULT NULL COMMENT '成功条件', `response_mapping` json DEFAULT NULL COMMENT '响应映射', `retry_policy` json DEFAULT NULL COMMENT '重试策略', `timeout_ms` int DEFAULT NULL COMMENT '超时时间毫秒', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), UNIQUE KEY `uk_template_api_code` (`template_id`,`api_code`), KEY `idx_template_api_type` (`template_id`,`api_type`) ) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-接口定义'; -- fastbee.iot_platform_api_field definition CREATE TABLE `iot_platform_api_field` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `api_id` bigint NOT NULL COMMENT '接口ID', `direction` varchar(16) NOT NULL COMMENT '方向（REQUEST RESPONSE）', `field_path` varchar(256) NOT NULL COMMENT '字段路径', `field_name` varchar(128) DEFAULT NULL COMMENT '字段名称', `data_type` varchar(32) DEFAULT NULL COMMENT '数据类型', `required` tinyint(1) DEFAULT '0' COMMENT '是否必填', `default_value` varchar(512) DEFAULT NULL COMMENT '默认值', `example_value` varchar(512) DEFAULT NULL COMMENT '示例值', `description` varchar(500) DEFAULT NULL COMMENT '说明', `sort_order` int DEFAULT '0' COMMENT '排序', PRIMARY KEY (`id`), KEY `idx_api_direction` (`api_id`,`direction`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-接口字段'; -- fastbee.iot_platform_binding definition CREATE TABLE `iot_platform_binding` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `tenant_channel_id` bigint NOT NULL COMMENT '租户平台实例ID', `flow_id` bigint NOT NULL COMMENT '平台流程ID', `product_id` bigint DEFAULT NULL COMMENT '产品ID', `product_name` varchar(128) DEFAULT NULL COMMENT '产品名称', `device_id` bigint DEFAULT NULL COMMENT 'FastBee设备ID', `device_name` varchar(128) DEFAULT NULL COMMENT 'FastBee设备名称', `serial_number` varchar(64) NOT NULL COMMENT 'FastBee设备编号', `external_user_id` varchar(128) DEFAULT NULL COMMENT '绑定级第三方用户ID', `external_project_id` varchar(128) DEFAULT NULL COMMENT '绑定级第三方项目ID', `external_device_type` varchar(32) DEFAULT NULL COMMENT '第三方设备类型', `binding_name` varchar(128) DEFAULT NULL COMMENT '绑定名称', `exchange_mode` varchar(32) NOT NULL COMMENT '交换模式', `config_json` json DEFAULT NULL COMMENT '绑定配置', `last_success_time` datetime DEFAULT NULL COMMENT '最近成功时间', `last_success_value` varchar(128) DEFAULT NULL COMMENT '最近成功值', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `del_flag` char(1) DEFAULT '0' COMMENT '删除标志（0代表存在 2代表删除）', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_time` datetime DEFAULT NULL COMMENT '更新时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_binding` (`tenant_channel_id`,`flow_id`,`serial_number`,`del_flag`), KEY `idx_binding_device` (`tenant_id`,`product_id`,`serial_number`), KEY `idx_binding_channel_flow` (`tenant_channel_id`,`flow_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-设备绑定'; -- fastbee.iot_platform_exchange_attempt definition CREATE TABLE `iot_platform_exchange_attempt` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `record_id` bigint NOT NULL COMMENT '交换记录ID', `attempt_no` int NOT NULL COMMENT '尝试次数', `direction` varchar(32) NOT NULL COMMENT '方向', `request_url` varchar(1024) DEFAULT NULL COMMENT '请求地址或接收入口', `request_headers` json DEFAULT NULL COMMENT '请求头', `request_payload` json DEFAULT NULL COMMENT '请求体', `response_status` int DEFAULT NULL COMMENT '响应状态码', `response_body` mediumtext COMMENT '响应内容', `success` tinyint(1) DEFAULT '0' COMMENT '是否成功', `error_msg` varchar(1000) DEFAULT NULL COMMENT '错误信息', `duration_ms` int DEFAULT NULL COMMENT '耗时毫秒', `create_time` datetime DEFAULT NULL COMMENT '创建时间', PRIMARY KEY (`id`), KEY `idx_attempt_record` (`record_id`,`attempt_no`), KEY `idx_attempt_tenant` (`tenant_id`,`create_time`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-数据交换尝试日志'; -- fastbee.iot_platform_exchange_record definition CREATE TABLE `iot_platform_exchange_record` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `tenant_channel_id` bigint NOT NULL COMMENT '租户平台实例ID', `flow_id` bigint NOT NULL COMMENT '流程ID', `binding_id` bigint DEFAULT NULL COMMENT '绑定ID', `task_id` bigint DEFAULT NULL COMMENT '任务ID', `direction` varchar(32) NOT NULL COMMENT '方向', `source_type` varchar(32) DEFAULT NULL COMMENT '来源类型', `sink_type` varchar(32) DEFAULT NULL COMMENT '落点类型', `source_device_id` bigint DEFAULT NULL COMMENT 'FastBee设备ID', `serial_number` varchar(64) DEFAULT NULL COMMENT '设备编号', `external_message_id` varchar(128) DEFAULT NULL COMMENT '第三方消息ID', `source_ref_id` varchar(128) DEFAULT NULL COMMENT '来源ID', `source_time` datetime DEFAULT NULL COMMENT '数据时间', `time_window_start` datetime DEFAULT NULL COMMENT '窗口开始', `time_window_end` datetime DEFAULT NULL COMMENT '窗口结束', `raw_payload` json DEFAULT NULL COMMENT '原始输入', `standard_payload` json DEFAULT NULL COMMENT '标准消息', `request_payload` json DEFAULT NULL COMMENT '请求载荷', `response_payload` json DEFAULT NULL COMMENT '响应载荷', `payload_hash` varchar(64) DEFAULT NULL COMMENT 'payload哈希', `idempotency_key` varchar(128) NOT NULL COMMENT '幂等键', `status` varchar(32) NOT NULL DEFAULT 'PENDING' COMMENT '状态', `retry_count` int DEFAULT '0' COMMENT '重试次数', `max_retry` int DEFAULT '3' COMMENT '最大重试次数', `next_retry_time` datetime DEFAULT NULL COMMENT '下次重试时间', `last_error` varchar(1000) DEFAULT NULL COMMENT '最近错误', `locked_by` varchar(64) DEFAULT NULL COMMENT 'worker锁', `locked_time` datetime DEFAULT NULL COMMENT '锁定时间', `success_time` datetime DEFAULT NULL COMMENT '成功时间', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_time` datetime DEFAULT NULL COMMENT '更新时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_idempotency` (`idempotency_key`), KEY `idx_record_poll` (`status`,`next_retry_time`), KEY `idx_record_direction` (`tenant_channel_id`,`direction`,`source_time`), KEY `idx_record_device` (`tenant_channel_id`,`serial_number`,`source_time`), KEY `idx_record_binding` (`binding_id`,`source_time`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-数据交换记录'; -- fastbee.iot_platform_exchange_task definition CREATE TABLE `iot_platform_exchange_task` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `tenant_channel_id` bigint NOT NULL COMMENT '租户平台实例ID', `flow_id` bigint NOT NULL COMMENT '流程ID', `task_name` varchar(128) NOT NULL COMMENT '任务名称', `task_type` varchar(32) NOT NULL COMMENT '任务类型', `cron_expression` varchar(128) DEFAULT NULL COMMENT 'Cron表达式', `window_type` varchar(32) DEFAULT NULL COMMENT '窗口类型', `window_config` json DEFAULT NULL COMMENT '窗口配置', `cursor_json` json DEFAULT NULL COMMENT '拉取游标', `sink_type` varchar(32) DEFAULT NULL COMMENT '入站数据落点', `batch_size` int DEFAULT '100' COMMENT '批次大小', `max_retry` int DEFAULT '3' COMMENT '最大重试次数', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `last_run_time` datetime DEFAULT NULL COMMENT '最近执行时间', `next_run_time` datetime DEFAULT NULL COMMENT '下次执行时间', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_time` datetime DEFAULT NULL COMMENT '更新时间', PRIMARY KEY (`id`), KEY `idx_task_channel_type` (`tenant_channel_id`,`task_type`), KEY `idx_task_next_run` (`status`,`next_run_time`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-数据交换任务'; -- fastbee.iot_platform_field_mapping definition CREATE TABLE `iot_platform_field_mapping` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `binding_id` bigint NOT NULL COMMENT '绑定ID', `direction` varchar(32) NOT NULL COMMENT '方向', `target_path` varchar(256) NOT NULL COMMENT '目标字段路径', `target_name` varchar(128) DEFAULT NULL COMMENT '目标字段名称', `source_type` varchar(32) NOT NULL COMMENT '来源类型', `source_key` varchar(256) DEFAULT NULL COMMENT '来源键', `source_name` varchar(128) DEFAULT NULL COMMENT '来源字段名称', `transform_type` varchar(32) DEFAULT 'DIRECT' COMMENT '转换类型', `transform_config` json DEFAULT NULL COMMENT '转换配置', `default_value` varchar(512) DEFAULT NULL COMMENT '默认值', `required` tinyint(1) DEFAULT '0' COMMENT '是否必填', `sort_order` int DEFAULT '0' COMMENT '排序', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', PRIMARY KEY (`id`), KEY `idx_mapping_binding` (`binding_id`,`direction`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-字段映射'; -- fastbee.iot_platform_flow definition CREATE TABLE `iot_platform_flow` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `template_id` bigint NOT NULL COMMENT '平台模板ID', `flow_code` varchar(64) NOT NULL COMMENT '流程编码', `flow_name` varchar(128) NOT NULL COMMENT '流程名称', `flow_type` varchar(32) NOT NULL COMMENT '流程类型', `adapter_code` varchar(64) DEFAULT NULL COMMENT '适配器编码', `sink_type` varchar(32) DEFAULT NULL COMMENT '入站数据落点', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), UNIQUE KEY `uk_template_flow_code` (`template_id`,`flow_code`), KEY `idx_template_flow_type` (`template_id`,`flow_type`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-流程模板'; -- fastbee.iot_platform_flow_step definition CREATE TABLE `iot_platform_flow_step` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `flow_id` bigint NOT NULL COMMENT '流程ID', `step_code` varchar(64) NOT NULL COMMENT '步骤编码', `step_name` varchar(128) NOT NULL COMMENT '步骤名称', `step_type` varchar(32) NOT NULL COMMENT '步骤类型', `api_id` bigint DEFAULT NULL COMMENT '接口ID', `adapter_method` varchar(128) DEFAULT NULL COMMENT '适配器方法', `input_mapping` json DEFAULT NULL COMMENT '入参映射', `output_mapping` json DEFAULT NULL COMMENT '输出映射', `condition_expr` varchar(512) DEFAULT NULL COMMENT '执行条件', `on_fail` varchar(32) DEFAULT 'STOP' COMMENT '失败策略', `sort_order` int DEFAULT '0' COMMENT '排序', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', PRIMARY KEY (`id`), KEY `idx_flow_sort` (`flow_id`,`sort_order`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-流程步骤'; -- fastbee.iot_platform_resource_mapping definition CREATE TABLE `iot_platform_resource_mapping` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `tenant_channel_id` bigint NOT NULL COMMENT '租户平台实例ID', `binding_id` bigint DEFAULT NULL COMMENT '绑定ID', `resource_scope` varchar(32) NOT NULL COMMENT '资源范围', `resource_type` varchar(64) NOT NULL COMMENT '资源类型', `local_key` varchar(128) NOT NULL COMMENT '本地唯一键', `external_id` varchar(128) DEFAULT NULL COMMENT '外部资源ID', `external_code` varchar(128) DEFAULT NULL COMMENT '外部资源编码', `external_name` varchar(128) DEFAULT NULL COMMENT '外部资源名称', `resource_payload` json DEFAULT NULL COMMENT '外部资源详情', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0失效 1有效）', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_time` datetime DEFAULT NULL COMMENT '更新时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_resource` (`tenant_channel_id`,`binding_id`,`resource_type`,`local_key`), KEY `idx_resource_tenant_type` (`tenant_id`,`tenant_channel_id`,`resource_type`), KEY `idx_external_id` (`tenant_channel_id`,`resource_type`,`external_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-资源映射'; -- fastbee.iot_platform_task_binding definition CREATE TABLE `iot_platform_task_binding` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `task_id` bigint NOT NULL COMMENT '任务ID', `binding_id` bigint NOT NULL COMMENT '绑定ID', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', PRIMARY KEY (`id`), UNIQUE KEY `uk_task_binding` (`task_id`,`binding_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-任务绑定'; -- fastbee.iot_platform_template definition CREATE TABLE `iot_platform_template` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `platform_code` varchar(64) NOT NULL COMMENT '平台编码', `platform_name` varchar(128) NOT NULL COMMENT '平台名称', `platform_type` varchar(32) NOT NULL COMMENT '平台类型', `adapter_code` varchar(64) DEFAULT NULL COMMENT '适配器编码', `base_url_template` varchar(512) DEFAULT NULL COMMENT '默认基础地址模板', `auth_type` varchar(32) DEFAULT NULL COMMENT '认证类型', `auth_schema` json DEFAULT NULL COMMENT '授权配置字段定义', `request_config` json DEFAULT NULL COMMENT '默认请求配置', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), UNIQUE KEY `uk_platform_code` (`platform_code`), KEY `idx_platform_type` (`platform_type`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-平台模板'; -- fastbee.iot_platform_tenant_channel definition CREATE TABLE `iot_platform_tenant_channel` ( `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', `tenant_id` bigint NOT NULL COMMENT '租户ID', `tenant_name` varchar(64) DEFAULT '' COMMENT '租户名称', `template_id` bigint NOT NULL COMMENT '平台模板ID', `channel_code` varchar(64) NOT NULL COMMENT '租户平台实例编码', `channel_name` varchar(128) NOT NULL COMMENT '租户平台实例名称', `base_url` varchar(512) DEFAULT NULL COMMENT '实际基础地址', `auth_config` json DEFAULT NULL COMMENT '租户授权配置', `receive_config` json DEFAULT NULL COMMENT '接收安全配置', `default_user_id` varchar(128) DEFAULT NULL COMMENT '默认第三方用户ID', `default_project_id` varchar(128) DEFAULT NULL COMMENT '默认第三方项目ID', `config_json` json DEFAULT NULL COMMENT '扩展配置', `status` tinyint(1) DEFAULT '1' COMMENT '状态（0停用 1启用）', `del_flag` char(1) DEFAULT '0' COMMENT '删除标志（0代表存在 2代表删除）', `create_by` varchar(64) DEFAULT '' COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` varchar(64) DEFAULT '' COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`), UNIQUE KEY `uk_tenant_channel_code` (`tenant_id`,`channel_code`,`del_flag`), KEY `idx_tenant_template` (`tenant_id`,`template_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='平台对接-租户平台实例';