EDS至DM思路分析

根据TW_MAC_STAT_D机器日统计表数据得到TM_USR_MRCHNT_STAT_D商户日统计表信息。

具体思路分析：

1. 接收处理数据日期参数的合法性验证

2. 构建SparkSession对象

3. 切换Hive的命名空间baizhan_music

4. 按照代理人和支付类型分组，对EDS层 TW_MAC_STAT_D表做聚合查询，将查询结果注册为临时视图TEMP_USR_MRCHNT_STAT。

   xxxxxxxxxx
   select AGE_ID AS ADMIN_ID,   --代理人
     PAY_TYPE,
     SUM(REV_ORDR_CNT) AS REV_ORDR_CNT,  --总营收订单数
     SUM(REF_ORDR_CNT) AS REF_ORDR_CNT,  --总退款订单数
     SUM(TOT_REV)  AS TOT_REV,  --总营收
     SUM(TOT_REF) AS TOT_REF,  --总退款
     CAST(SUM(TOT_REV * NVL(INV_RATE,0)/100) AS DECIMAL(10,4)) AS TOT_INV_REV,  --投资人营收
     CAST(SUM(TOT_REV * NVL(AGE_RATE,0)/100) AS DECIMAL(10,4)) AS TOT_AGE_REV,  --代理人营收
     CAST(SUM(TOT_REV * NVL(COM_RATE,0)/100) AS DECIMAL(10,4)) AS TOT_COM_REV,  --公司营收
     CAST(SUM(TOT_REV * NVL(PAR_RATE,0)/100) AS DECIMAL(10,4)) AS TOT_PAR_REV    --合伙人营收
   from TW_MAC_STAT_D
   WHERE DATA_DT = ${analyticDate}
   GROUP BY AGE_ID,PAY_TYPE
   

5. 将临时视图TEMP_USR_MRCHNT_STAT结果保存到分区表TM_USR_MRCHNT_STAT_D中

6. 同时将以上结果保存至 mysql的songresult.tm_usr_mrchnt_stat_d中,作为DM层结果