1 [2026-11-09 18:41:04.474] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create table `attribution_id` ( 2 `id` int(11) unsigned not null auto_increment, 3 `dtu` varchar(50) not null default '' comment '包dtu', 4 `campaign` varchar(200) not null default '' comment '推广计划维度id/名字', 5 `account_id` int(10) unsigned not null default '0' comment '虫洞后台账户id', 6 `adgroup` varchar(200) not null default '' comment 'adgroup维度id/名字', 7 `ad` varchar(100) not null default '' comment 'ad/创意维度id/名字', 8 `landing_page_id` varchar(50) not null default '0' comment '动态落地页id', 9 `agent_account_id` int(10) unsigned not null default '0' comment '虫洞后台账户id(补丁字段，不可为0值)', 10 `att_dtu` varchar(50) not null default '' comment '归因后的dtu', 11 `att_campaign_id` varchar(100) not null default '' comment '归因后的推广计划ID', 12 `att_adgroup_id` varchar(100) default '' comment '归因后的广告组ID', 13 `att_ad_id` varchar(100) default '' comment '归因后的广告ID', 14 `slot_name` varchar(100) default '' comment '广告位名称', 15 `slot_type` varchar(100) default '' comment '广告位类型', 16 `slot_desc` varchar(100) default '' comment '广告位描述', 17 `att_campaign_name` varchar(100) default '' comment '归因后的推广计划名称', 18 `att_adgroup_name` varchar(100) default '' comment '归因后的广告组名称', 19 `att_ad_name` varchar(100) default '' comment '归因后的广告名称', 20 `union_site` varchar(50) not null default '' comment '联盟广告位id', 21 `content_id` varchar(20) not null default '' comment '书籍id', 22 `refresh_date` date not null default '0000-00-00' comment '刷新日期', 23 `is_expired` tinyint(4) not null default '0' comment '是否过期', 24 `update_time` datetime default CURRENT_TIMESTAMP on update current_timestamp comment '更新时间', 25 `book_name` varchar(40) not null default '' comment '书籍名称', 26 `traffic_sources` tinyint(2) not null default '0' comment '流量类型 0其他 1内广 2联盟流量 3混投', 27 `media_name` varchar(50) not null default '' comment '流量媒体, 从marketing_creative同步', 28 primary key (`id`), 29 constraint `uk` unique key (`dtu`, `campaign`, `account_id`, `adgroup`, `ad`, `landing_page_id`, `union_site`) LOCAL with column group (all columns, each column) 30 )organization INDEX 31 default charset=utf8mb4 32 default collate=utf8mb4_general_ci 33 comment='归因激活id表' 34 with column group (all columns, each column), checkpoint[1794220863] 35 [2026-11-09 18:41:05.395] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_account_id` on `attribution_id` (`account_id` ASC, `campaign` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220864] 36 [2026-11-09 18:41:05.423] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_att_dtu` on `attribution_id` (`att_dtu` ASC, `landing_page_id` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220864] 37 [2026-11-09 18:41:06.069] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_att_exp_acc_id` on `attribution_id` (`att_campaign_id` ASC, `is_expired` ASC, `account_id` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220865] 38 [2026-11-09 18:41:06.371] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_expired` on `attribution_id` (`is_expired` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220865] 39 [2026-11-09 18:41:06.977] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_refresh_date` on `attribution_id` (`refresh_date` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220866] 40 [2026-11-09 18:41:07.476] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_ref_date` on `attribution_id` (`refresh_date` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220866] 41 [2026-11-09 18:41:07.977] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `update_time` on `attribution_id` (`update_time` ASC) LOCAL with column group (all columns, each column), checkpoint[1794220867] 42 [2026-11-09 18:43:36.629] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create table `marketing_base_data` ( 43 `id` bigint(10) not null auto_increment, 44 `agent_account_id` int(10) not null comment '账号id', 45 `ad_id` varchar(100) not null comment '广告id', 46 `ad` varchar(200) comment '广告名称', 47 `account_balance` decimal(10,2) default '0.00' comment '当前余额', 48 `account_daily_budget` decimal(10,2) default '0.00' comment '账号每日预算 无限制为-1', 49 `campaign_id` varchar(100) not null comment '计划id', 50 `campaign` varchar(128) not null default '' comment '计划名称', 51 `campaign_budget` decimal(10,2) not null default '-1.00' comment '推广计划每日预算 无限制为-1', 52 `campaign_status` tinyint(2) not null default '1' comment '计划状态 0 已删除 1投放中 2暂停中 3已结束 4超出预算 5账户余额不足 7审核中 9审核未通过', 53 `campaign_created_date` date not null default '0000-00-00' comment '计划创建日期', 54 `campaign_created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '计划创建时间', 55 `campaign_start_time` datetime comment '推广计划开始时间', 56 `campaign_end_time` datetime comment '推广计划结束时间', 57 `adgroup_id` varchar(100) comment '广告组id', 58 `adgroup` varchar(200) not null default '' comment '广告组名称', 59 `adgroup_status` tinyint(2) not null default '1' comment '广告组状态 -3计划新建 0已删除 1投放中 2暂停中 3审核中 5审核不通过 6投放结束 7计划暂停 8超出预算 9计划超出预算 10账户余额不足 11未到达投放时间', 60 `adgroup_budget` decimal(10,2) not null default '-1.00' comment '广告组限额 无限制为-1', 61 `adgroup_targeting_gender` tinyint(3) unsigned not null default '0' comment '定向信息，性别 0无 1FEMALE 2MALE', 62 `adgroup_targeting_age` varchar(299) not null default '定向信息，年龄', 63 `adgroup_targeting_age_23tag` tinyint(3) unsigned not null default '0' comment '定向信息，年龄标签 0无 1小于等于24 2大于24', 64 `billing_type` tinyint(3) default '1' comment '计费方式 1点击CPC 2曝光CPM 3曝光优化OCPM 4播放CPV 5激活优化OCPA 6OCPC第一阶段 7OCPC第二阶段', 65 `bid` decimal(10,2) default '0.00' comment '出价', 66 `os` tinyint(2) default '0' comment '操作系统 0 其他 1 android 2 ios', 67 `opt_targets` int(5) default '-1' comment '优化目标类型(快手字段) 0 点击数 2行为数 31 下载完成 180激活', 68 `targets_cost` decimal(8,2) default '0.00' comment '目标成本', 69 `adgroup_created_date` date not null default '0000-00-00' comment '广告组创建日期', 70 `adgroup_created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '广告组创建时间', 71 `adgroup_start_date` date default '0000-00-00' comment '广告组投放起始时间', 72 `adgroup_end_date` date default '0000-00-00' comment '广告组投放结束时间', 73 `super_link_product_id` varchar(100) not null default '' comment 'super-link 解析数据内容id', 74 `super_link_category_id` varchar(100) not null default '' comment 'super-link 解析数据类目id', 75 `dtu` varchar(32) default '' comment '目标应用', 76 `status` tinyint(2) default '1' comment '广告状态 待定', 77 `slot_id` varchar(50) default '' comment '广告版位id', 78 `slot_name` varchar(255) default '' comment '广告媒体', 79 `slot_desc` varchar(100) not null default '' comment '广告位', 80 `slot_type` varchar(50) not null default '' comment '广告描述', 81 `traffic_sources` tinyint(2) not null default '0' comment '流量类型 0其他 1内广 2联盟流量 3混投', 82 `material_id` varchar(100) default '' comment '素材id', 83 `material_url` varchar(300) default '' comment '素材地址', 84 `material_md5` varchar(32) default '' comment '素材md5', 85 `material_title` varchar(100) default '' comment '素材标题', 86 `material_type` tinyint(3) default '1' comment '素材类型（1：图片，2：视频）', 87 `material_created_date` date default '0000-00-00' comment '素材创建日期', 88 `material_created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '素材创建时间', 89 `landing_page_id` varchar(100) default '' comment '落地页id', 90 `landing_page_preview_url` varchar(500) default '' comment '广告落地页链接', 91 `landing_page_url` varchar(300) default '' comment '落地页地址', 92 `landing_page_md5` varchar(32) default '' comment '落地页md5', 93 `landing_page_created_date` date default '0000-00-00' comment '落地页创建日期', 94 `landing_page_created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '落地页创建时间', 95 `cover_img_url` varchar(200) default '' comment '广告封面图', 96 `cover_img_md5` varchar(32) default '' comment '广告封面图md5', 97 `cover_img_created_date` date default '0000-00-00' comment '封面创建日期', 98 `cover_img_created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '封面创建时间', 99 `button_title` varchar(64) default '' comment '按钮标题(快手行动号召按钮)', 100 `ad_style` varchar(32) default '' comment '广告样式', 101 `ad_flow` varchar(32) default '' comment '广告流量 微信专属', 102 `ad_desc` varchar(64) default '' comment '广告文案', 103 `created_date` date not null default '0000-00-00' comment '创意创建日期', 104 `created_timestamp` timestamp not null default '0000-00-00 00:00:00' comment '创意创建时间', 105 `create_time` timestamp not null default CURRENT_TIMESTAMP, 106 `update_time` timestamp null default CURRENT_TIMESTAMP on update current_timestamp comment '更新时间', 107 `material_description` varchar(100) not null default '', 108 `media_name` varchar(50) not null default '' comment '流量媒体, 多个用逗号隔开', 109 `ad_slot_name` varchar(50) not null default '' comment '广告位置, 多个用逗号隔开', 110 `ad_slot_type` varchar(50) not null default '' comment '广告类型', 111 `ad_style_type` varchar(20) not null default '' comment '广告样式类型', 112 `ad_slot_size` varchar(50) default '' comment '广告位尺寸', 113 `material_size` varchar(50) default '' comment '素材尺寸', 114 `origin_id` bigint(20) unsigned not null default '0' comment '原始素材id', 115 `is_original` tinyint(1) unsigned not null default '1' comment '是否原创 1 原创 0 非原创', 116 `deep_link_url` varchar(3000) default '' comment '应用直达页 URL', 117 `schema_name` varchar(33) default '' comment 'schema别名', 118 `params_map` varchar(255) default '' comment '解析出的参数，json格式', 119 `hash_id` varchar(64) default '' comment 'params_map 里的bookId', 120 `is_static_assemble` tinyint(1) unsigned not null default '0' comment '创意类型（1：程序化创意，0：普通创意）', 121 `material_title_list` varchar(600) not null default '' comment '标题全', 122 `material_description_list` varchar(1000) not null default '' comment '描述全', 123 `material_group_id` varchar(64) not null default '' comment '素材组id', 124 `group_origin_id` varchar(64) not null default '' comment '原创素材组id', 125 `is_group_original` tinyint(1) unsigned not null default '1' comment '素材组是否原创 1 原创 0 非原创', 126 `tpl_code` varchar(32) not null default '' comment '样式编码', 127 `origin_material_url` varchar(300) default '' comment '归一化素材地址', 128 `origin_material_md5` varchar(32) default '' comment '归一化素材md5', 129 `origin_material_created_date` date default '0000-00-00' comment '归一化素材创建日期', 130 `cover_origin_id` bigint(20) unsigned not null default '0' comment '归一化封面图id', 131 `campaign_denied_reason` varchar(600) not null default '' comment '计划审核不通过原因', 132 `adgroup_denied_reason` varchar(600) not null default '' comment '广告组审核不通过原因', 133 `ad_denied_reason` varchar(600) not null default '' comment '创意审核不通过原因', 134 `material_source` varchar(20) not null default '4' comment '素材来源，1：创意网络素材，2:老平台素材，3:挖掘素材，4:代理素材', 135 `convert_type` varchar(64) default '' comment '转化目标', 136 `deep_convert_type` varchar(64) default '' comment '深度转化目标', 137 `deep_convert_bid` decimal(10,2) default '0.00' comment '深度转化目标出价', 138 `convert_bid` decimal(10,2) default '0.00' comment '转化目标出价', 139 `cost_protection_status` varchar(64) default '' comment '成本保障状态', 140 `click_bid` decimal(10,2) default '0.00' comment '点击出价', 141 `playable_id` varchar(100) default '' comment '试玩id', 142 `playable_url` varchar(300) default '' comment '试玩素材url', 143 `campaign_opt_status` tinyint(1) not null default '1' comment '计划操作状态值 1启用 2暂停 3删除', 144 `adgroup_opt_status` tinyint(1) not null default '1' comment '广告组操作状态值 1启用 2暂停 3删除', 145 `creative_opt_status` tinyint(1) not null default '1' comment '创意操作状态值 1启用 2暂停 3删除', 146 `click_feedback_url` varchar(256) comment '点击回传链接', 147 `click_feedback_status` tinyint(1) default '1' comment '点击回传状态 1:正常, 2:异常', 148 `cpa_bid` decimal(10,2) default '0.00' comment '项目出价', 149 `roi_goal` decimal(10,4) default '0.0000' comment '深度转化ROI系数', 150 primary key (`id`), 151 constraint `unq_base` unique key (`agent_account_id`, `campaign_id`, `adgroup_id`, `ad_id`) LOCAL with column group (all columns, each column) 152 )organization INDEX 153 default charset=utf8mb4 154 default collate=utf8mb4_general_ci 155 comment='渠道基础数据表' 156 with column group (all columns, each column), checkpoint[1794221015] 157 [2026-11-09 18:43:37.475] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_st_id` on `marketing_base_data` (`is_static_assemble` ASC, `id` ASC, `material_title` ASC, `material_description` ASC) LOCAL with column group (all columns, each column), checkpoint[1794221016] 158 [2026-11-09 18:43:37.832] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_update_time` on `marketing_base_data` (`update_time` ASC) LOCAL with column group (all columns, each column), checkpoint[1794221017] 159 [2026-11-09 18:44:42.486] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create table `marketing_ext_data` ( 160 `id` bigint(20) unsigned not null auto_increment, 161 `agent_account_id` int(11) not null comment '账号id', 162 `campaign_id` varchar(100) not null default '' comment '计划id', 163 `adgroup_id` varchar(100) not null default '' comment '广告组id', 164 `ad_id` varchar(100) not null default '' comment '广告id', 165 `book_id` varchar(20) not null default '' comment '书籍id', 166 `hash_id` varchar(64) not null comment '书籍hashid', 167 `first_category_id` bigint(20) unsigned not null default '0' comment '一级分类', 168 `first_category_name` varchar(128) not null default '' comment '一级分类名称', 169 `second_category_id` bigint(20) unsigned not null default '0' comment '二级分类', 170 `second_category_name` varchar(128) not null default '' comment '二级分类名称', 171 `third_category_id` bigint(20) unsigned not null default '0' comment '三级分类', 172 `third_category_name` varchar(128) not null default '' comment '三级分类名称', 173 `title` varchar(128) not null default '' comment '书名', 174 `author` varchar(66) not null default '' comment '作者', 175 `cover` varchar(255) not null default '' comment '封面图', 176 `end_status` tinyint(3) unsigned not null default '1' comment '完结状态 1:完结2未完结', 177 `read_book_uv` bigint(20) unsigned not null default '0' comment '阅读人数', 178 `click_book_uv` bigint(20) unsigned not null default '0' comment '点击uv', 179 `avg_chapter_words_len` decimal(20,2) unsigned not null default '0.00' comment '人均阅读字数', 180 `read_remain1` bigint(20) unsigned not null default '0' comment '次留', 181 `read_remain3` bigint(20) unsigned not null default '0' comment '三留', 182 `read_remain7` bigint(20) unsigned not null default '0' comment '七留', 183 `read_cnt1` bigint(20) unsigned not null default '0' comment '次留阅读人数', 184 `read_cnt3` bigint(20) unsigned not null default '0' comment '三留阅读人数', 185 `read_cnt7` bigint(20) unsigned not null default '0' comment '七留阅读人数', 186 `total_like_cnt` bigint(20) unsigned not null default '0' comment '总收藏数', 187 `book_created_at` datetime comment '原表创建时间', 188 `book_status` tinyint(3) unsigned not null default '1' comment '状态 1:正常 2:下架', 189 `book_version` date comment 'day, 数据来源日期', 190 `create_time` datetime not null default CURRENT_TIMESTAMP, 191 `update_time` datetime not null default CURRENT_TIMESTAMP on update current_timestamp, 192 `hot_num` bigint(20) unsigned not null default '0' comment '热度', 193 `ex_city` varchar(255) not null default '' comment '排除的城市', 194 `score` decimal(5,1) unsigned not null default '0.0' comment '分数', 195 `recommend_score` decimal(5,1) unsigned not null default '0.0' comment '推荐指数', 196 `tag` varchar(255) not null default '' comment '标签', 197 `description` varchar(666) not null default '' comment '简介', 198 `word_count` bigint(20) unsigned not null default '0' comment '字数', 199 `expose_book_pv` bigint(20) unsigned not null default '0' comment '曝光pv', 200 `copyright_id` bigint(20) unsigned not null default '0' comment '版权方ID', 201 `copyright_name` varchar(99) not null default '' comment '版权方名称', 202 `copyright_code` varchar(99) not null default '' comment '版权方代码', 203 `chapter_num` int(10) unsigned not null default '0' comment '章节数', 204 `laxin_type` tinyint(5) unsigned not null default '0' comment '拉新类型 1: 通投, 2: 单书', 205 `category_id` varchar(100) not null default '' comment 'CID', 206 `extension_id` text comment 'EID', 207 `product_id` varchar(100) not null default '' comment 'PID', 208 `status` tinyint(3) unsigned not null default '0' comment '调起状态枚举值', 209 primary key (`id`), 210 constraint `unq_base2` unique key (`agent_account_id`, `campaign_id`, `adgroup_id`, `ad_id`) LOCAL with column group (all columns, each column) 211 )organization INDEX 212 default charset=utf8mb4 213 default collate=utf8mb4_general_ci 214 comment='渠道扩展数据表' 215 with column group (all columns, each column), checkpoint[1794221081] 216 [2026-11-09 18:44:43.188] [forward_slot0-(ETLProcessor)-queue_slot1] receive ddl:create index if not exists `idx_adgp_c_id` on `marketing_ext_data` (`adgroup_id` ASC, `campaign_id` ASC, `agent_account_id` ASC) LOCAL with column group (all columns, each column), checkpoint[1794221082]