DataCenterGame/app/novel_order_daily_amount.py

""""
@desc 订单数据日统计
@auth ck
@date 20201119
"""

from model.util.DateUtils import DateUtils
from model.util.DataBaseUtils import MysqlUtils
db = MysqlUtils()
dt = DateUtils()


def run(ymd):

    sql = """replace into novel_daily_order_amount
             select "{0}" as ymd,platform,channel_id,channel,stage,
                    ROUND(SUM(amount),2) as amount,
                    count(1) as order_num,
                    count(DISTINCT user_id) as order_user
             from `order` 
             where `date` = UNIX_TIMESTAMP("{0}") GROUP BY platform,stage,channel 
             """.format(ymd)
    db.quchen_text.execute(sql)


if __name__ == '__main__':
    ymd = dt.get_n_days(-1)
    run(ymd)

    # for i in dt.getDateLists("2020-10-01", "2020-11-01"):
    #     run(i)