大数据全系列 教程
1869个小节阅读:464.8k
目录
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
使用SparkSQL代码清洗和统计分析TO_YCAK_CNSM_D
机器消费订单明细增量表到EDS层TW_CNSM_BRIEF_D
消费退款订单流水日增量表中,这里主要根据用户每天在机器上的消费行为统计每台机器的订单营收情况.
xxxxxxxxxx
select
ID, --ID
TRD_ID, --第三方交易编号
cast(UID as string) AS UID, --用户ID
MID, --机器ID
PRDCD_TYPE, --产品类型
PAY_TYPE, --支付类型
ACT_TM, --消费时间
PKG_ID, --套餐ID
case when AMT<0 then AMT*-1 else AMT end AS COIN_PRC,--币值
1 AS COIN_CNT, --币数 ,单位分
ACT_TM as UPDATE_TM, --状态更新时间
ORDR_ID, --订单ID
ACTV_NM, --优惠活动名称
PKG_PRC, --套餐原价
PKG_DSCNT, --套餐优惠价
CPN_TYPE, --优惠券类型
CASE WHEN ORDR_TYPE = 1 THEN 0 --异常类型:0-无异常
WHEN ORDR_TYPE = 2 THEN 1 --1-异常订单
WHEN ORDR_TYPE = 3 THEN 2 --2-商家退款
WHEN ORDR_TYPE = 4 THEN 2 END AS ABN_TYP
FROM TO_YCAK_CNSM_D
WHERE DATA_DT = 当前日期