elab-parent/elab-mq/mq.sql

-- ----------------------------
-- Table structure for mq_consumer
-- ----------------------------
DROP TABLE IF EXISTS `mq_consumer`;
CREATE TABLE `mq_consumer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `producer_id` int(11) DEFAULT NULL COMMENT '生产者消息id',
  `msg_id` varchar(100) DEFAULT NULL COMMENT 'MQ的消息编号',
  `module_name` varchar(300) DEFAULT NULL COMMENT '模块名称',
  `module_method` varchar(200) DEFAULT NULL COMMENT '模块的方法名，用来处理一个项目里面同一个topic和tag被多个消费处理',
  `house_id` int(11) DEFAULT NULL COMMENT '项目id',
  `topic_id` varchar(300) DEFAULT NULL COMMENT 'topic的id',
  `tag` varchar(100) DEFAULT NULL COMMENT '标签名',
  `content` varchar(4000) DEFAULT NULL COMMENT '消费内容',
  `consumer_status` int(11) DEFAULT NULL COMMENT '消费者状态1成功-1失败0消费中',
  `retry_count` int(11) DEFAULT NULL COMMENT '重试次数',
  `cat_id` varchar(100) DEFAULT NULL COMMENT '消息编号',
  `status` int(11) DEFAULT NULL COMMENT '状态1有效-1无效',
  `created` datetime DEFAULT NULL COMMENT '创建时间',
  `creator` varchar(100) DEFAULT NULL COMMENT '创建人',
  `updated` datetime DEFAULT NULL COMMENT '修改时间',
  `updator` varchar(100) DEFAULT NULL COMMENT '修改人',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1052 DEFAULT CHARSET=utf8mb4 COMMENT='消费者消息应用状态表';

-- ----------------------------
-- Table structure for mq_producer
-- ----------------------------
DROP TABLE IF EXISTS `mq_producer`;
CREATE TABLE `mq_producer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `module_name` varchar(300) DEFAULT NULL COMMENT '模块名称',
  `house_id` int(11) DEFAULT NULL COMMENT '项目id',
  `producer_status` int(11) DEFAULT NULL COMMENT '生产者状态1成功-1失败',
  `group_id` varchar(300) DEFAULT NULL COMMENT 'group的id',
  `tag` varchar(100) DEFAULT NULL COMMENT '标签名称',
  `cat_id` varchar(100) DEFAULT NULL COMMENT '链路编号',
  `topic_id` varchar(300) DEFAULT NULL COMMENT 'topic的id',
  `content` varchar(4000) DEFAULT NULL COMMENT '发送内容',
  `result_content` varchar(1000) DEFAULT NULL COMMENT 'MQ结果参数',
  `status` int(11) DEFAULT NULL COMMENT '状态1有效-1无效',
  `created` datetime DEFAULT NULL COMMENT '创建时间',
  `creator` varchar(100) DEFAULT NULL COMMENT '创建人',
  `updated` datetime DEFAULT NULL COMMENT '修改时间',
  `updator` varchar(100) DEFAULT NULL COMMENT '修改人',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1050 DEFAULT CHARSET=utf8mb4 COMMENT='生产者消息应用状态表';