py_script/task_idl/idl_year_channel_avg_ratings_stat.py

#!/usr/bin/env python
#coding=utf-8

"""近一年电视台平均收视率

"""
import sys

from fty_util.common import Mysql, Util

reload(sys)
sys.setdefaultencoding('utf8')

class channel_avg_ratings():
    
    def province(self):
        conn = Mysql.createOfflineConn()
        sql = """
            truncate table idl.tv_channel_avg_ratings
        """
        Mysql.execute(sql, conn=conn)
        sql = """
            insert into idl.tv_channel_avg_ratings (channel, theater_attribute, value)
            select channel, theater_attribute, value from tmp.channel_avg_ratings
        """
        Mysql.execute(sql, conn=conn)
        Mysql.close(conn)

    def area(self):
        conn = Mysql.createOfflineConn()
        sql = """
            truncate table idl.area_tv_channel_avg_ratings
        """
        Mysql.execute(sql, conn=conn)
        sql = """
            insert into idl.area_tv_channel_avg_ratings (channel, theater_attribute, value)
            select channel, theater_attribute, value from tmp.area_channel_avg_ratings
        """
        Mysql.execute(sql, conn=conn)
        Mysql.close(conn)

if __name__ == '__main__':
    if len(sys.argv) != 2:
        print '没有输入参数，退出'
        sys.exit(0)
    print 'method name is ' + sys.argv[1]
    obj = channel_avg_ratings()
    try:
        getattr(obj, sys.argv[1])()
    except Exception, e:
        print e