消费退款订单流水日增量思路分析

使用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 =  当前日期