ToB企服应用市场:ToB评测及商务社交产业平台

标题: 大数据-261 及时数仓 - 业务数据库表布局生意业务订单、订单产品、产品分类、 [打印本页]

作者: 王柳 时间: 2025-1-3 02:19
标题: 大数据-261 及时数仓 - 业务数据库表布局生意业务订单、订单产品、产品分类、
点一下关注吧！！！非常感谢！！持续更新！！！

Java篇开始了！

MyBatis 更新完毕
现在开始更新 Spring，一起深入浅出！

现在已经更新到了：

Hadoop（已更完）
HDFS（已更完）
MapReduce（已更完）
Hive（已更完）
Flume（已更完）
Sqoop（已更完）
Zookeeper（已更完）
HBase（已更完）
Redis （已更完）
Kafka（已更完）
Spark（已更完）
Flink（已更完）
ClickHouse（已更完）
Kudu（已更完）
Druid（已更完）
Kylin（已更完）
Elasticsearch（已更完）
DataX（已更完）
Tez（已更完）
数据挖掘（已更完）
Prometheus（已更完）
Grafana（已更完）
离线数仓（已更完）
及时数仓（正在更新…）

章节内容

及时数仓 - 项目配景与需求
及时数仓架构需求分析
技能选型
逻辑架构

及时数仓的定义

及时数仓是一种数据堆栈系统，区别于传统批处理数仓，它强调低延迟、高吞吐和高可用性。及时数仓可以或许处理流式数据或近及时的数据流，使企业可以或许及时监控关键指标并做出决策。
及时数仓的关键特性

低延迟数据处理：数据从采集到可查询分析的时间极短，通常在秒级或毫秒级。
高并发查询支持：可以或许支持多用户同时查询，满足业务需求。
高可用性和可靠性：系统在高负载下仍能保持稳定，支持数据冗余和容错机制。
流批一体：既支持及时流式盘算，也支持批量数据分析，满足多样化需求。
可扩展性：可以或许通太过布式架构动态扩展存储和盘算资源，满足不断增长的业务需求。

及时数仓的发展趋势

云原生及时数仓：越来越多企业选择基于云平台搭建及时数仓，提升资源管理与成本控制本领。
湖仓一体化：结合数据湖和数据堆栈的优势，支持布局化与非布局化数据的同一分析。
AI 与呆板学习集成：及时数仓将与 AI 和呆板学习深度结合，实现智能分析与预测。
开源生态发展：更多开源工具不断涌现，低落企业建立及时数仓的门槛。

业务数据库表布局

业务数据库：

生意业务订单表（trade_orders）
订单产品表（order_product）
产品信息表（product_info）
产品分类表（product_category）
商家店铺表（shops）
商家地区组织表（shop_admin_org）
付出方式表（payments）

生意业务订单表

CREATE TABLE `wzk_trade_orders` (
`orderId` bigint(11) NOT NULL DEFAULT 0 COMMENT '订单id',
`orderNo` varchar(20) NOT NULL COMMENT '订单编号',
`userId` bigint(11) NOT NULL COMMENT '用户id',
`status` tinyint(4) NOT NULL DEFAULT -2 COMMENT '订单状态 -3:用户拒收 -2:未付款的订单 -1：用户取消 0:待发货 1:配送中 2:用户确认收货',
`productMoney` decimal(11,2) NOT NULL COMMENT '商品金额',
`totalMoney` decimal(11,2) NOT NULL COMMENT '订单金额（包括运费）',
`payMethod` tinyint(4) NOT NULL DEFAULT 0 COMMENT '支付方式,0:未知;1:支付宝，2：微信;3、现金；4、其他',
`isPay` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否支付 0:未支付 1:已支付',
`areaId` int(11) NOT NULL COMMENT '区域最低一级',
`tradeSrc` tinyint(4) NOT NULL DEFAULT 0 COMMENT '订单来源 0:商城 1:微信 2:手机版 3:安卓App 4:苹果App',
`tradeType` int(11) DEFAULT 0 COMMENT '订单类型',
`isRefund` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否退款 0:否 1：是',
`dataFlag` tinyint(4) NOT NULL DEFAULT 1 COMMENT '订单有效标志 -1：删除 1:有效',
`createTime` varchar(25) NOT NULL COMMENT '下单时间',
`payTime` varchar(25) DEFAULT NULL COMMENT '支付时间',
`modifiedTime` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT '订单更新时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

记录订单的信息
status 订单状态
createTime、payTime、modifiedTime

订单产品表

CREATE TABLE `wzk_order_product` (
`id` bigint(11) NOT NULL DEFAULT 0,
`orderId` bigint(11) NOT NULL COMMENT '订单id',
`productId` bigint(11) NOT NULL COMMENT '商品id',
`productNum` bigint(11) NOT NULL DEFAULT 0 COMMENT '商品数量',
`productPrice` decimal(11,2) NOT NULL DEFAULT 0.00 COMMENT '商品价格',
`money` decimal(11,2) DEFAULT 0.00 COMMENT '付款金额',
`extra` text DEFAULT NULL COMMENT '额外信息',
`createTime` varchar(25) DEFAULT NULL COMMENT '创建时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

记录订单中购买产品的信息，包括产品的数量、单价等

产品信息表

CREATE TABLE `wzk_product_info` (
`productId` bigint(11) NOT NULL DEFAULT 0 COMMENT '商品id',
`productName` varchar(200) NOT NULL COMMENT '商品名称',
`shopId` bigint(11) NOT NULL COMMENT '门店ID',
`price` decimal(11,2) NOT NULL DEFAULT 0.00 COMMENT '门店价',
`isSale` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否上架 0:不上架 1:上架',
`status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否新品 0:否 1:是',
`categoryId` int(11) NOT NULL COMMENT 'goodsCatId 最后一级商品分类ID',
`createTime` varchar(25) NOT NULL,
`modifyTime` datetime DEFAULT NULL ON UPDATE current_timestamp() COMMENT '修改时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci

复制代码

备注：

记录产品的详细信息，对应商家 ID、商品属性（是否新品、是否上架）
createTime、modifyTime、创建时间、修改时间

产品分类表

CREATE TABLE `wzk_product_category` (
`catId` int(11) NOT NULL DEFAULT 0 COMMENT '品类ID',
`parentId` int(11) NOT NULL COMMENT '父ID',
`catName` varchar(20) NOT NULL COMMENT '分类名称',
`isShow` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否显示 0:隐藏 1:显示',
`sortNum` int(11) NOT NULL DEFAULT 0 COMMENT '排序号',
`isDel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '删除标志 1:有效 -1：删除',
`createTime` varchar(25) NOT NULL COMMENT '建立时间',
`level` tinyint(4) DEFAULT 0 COMMENT '分类级别，共3级'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

产品分类表，共分3 个级别

-- 第一级产品目录
select catName, catid from wzk_product_category where level = 1;
-- 查看电脑、办公的子类（查看二级目录）
select catName, catid from wzk_product_category where level = 2 and parentId
= 32;
-- 查看电脑整机的子类（查看三级目录）
select catName, catid from wzk_product_category where level = 3 and parentId
= 10250;

复制代码

实行结果如下图所示：

商家的店铺表

CREATE TABLE `wzk_shops` (
`shopId` int(11) NOT NULL DEFAULT 0 COMMENT '商铺ID，自增',
`userId` int(11) NOT NULL COMMENT '商铺联系人ID',
`areaId` int(11) DEFAULT 0,
`shopName` varchar(100) DEFAULT '' COMMENT '商铺名称',
`shopLevel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '店铺等级',
`status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '商铺状态',
`createTime` date DEFAULT NULL,
`modifyTime` datetime DEFAULT NULL COMMENT '修改时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

记录店铺的详细信息

商家地区组织表

CREATE TABLE `wzk_shop_admin_org` (
`id` int(11) NOT NULL DEFAULT 0 COMMENT '组织ID',
`parentId` int(11) NOT NULL COMMENT '父ID',
`orgName` varchar(100) NOT NULL COMMENT '组织名称',
`orgLevel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '组织级别1;总部及大区级部门;2：总部下属的各个部门及基部门;3:具体工作部门',
`isDelete` tinyint(4) NOT NULL DEFAULT 0 COMMENT '删除标志,1:删除;0:有效',
`createTime` varchar(25) DEFAULT NULL COMMENT '创建时间',
`updateTime` varchar(25) DEFAULT NULL COMMENT '最后修改时间',
`isShow` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否显示,0:是 1:否',
`orgType` tinyint(4) NOT NULL DEFAULT 1 COMMENT '组织类型,0:总裁办;1:研发;2:销售;3:运营;4:产品'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

记录店铺所属地区

付出方式表

CREATE TABLE `wzk_payments` (
`id` int(11) NOT NULL,
`payMethod` varchar(20) DEFAULT NULL,
`payName` varchar(255) DEFAULT NULL,
`description` varchar(255) DEFAULT NULL,
`payOrder` int(11) DEFAULT 0,
`online` tinyint(4) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

记录付出方式

最闭幕果

团体截图：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)