# coding=utf-8

import pymysql
from SendEmail import Email

def start(page):
    try:
        db = pymysql.connect('localhost', 'root', 'eagle', 'db_east_money', charset='utf8')
        cs = db.cursor()
    
        sql1 = 'select code,name,shijian,type,zhangfu,level_zhuli,level_zhuli_per,level_chaoda,level_chaoda_per,level_da,level_da_per,level_zhong,level_zhong_per,level_xiao,level_xiao_per from t_zijinliu_gegu_1 order by id limit '+str(page)+', 1000;'
    
        cs.execute(sql1)
        list = cs.fetchall()
    
        for i in list:
            sj = i[2][:-3]
            sql = "REPLACE INTO `t_zijinliu_gegu` " \
                  "(`code`, `name`, `shijian`, `type`, `zhangfu`, `level_zhuli`, `level_zhuli_per`, `level_chaoda`, " \
                  "`level_chaoda_per`, `level_da`, `level_da_per`, `level_zhong`, `level_zhong_per`, `level_xiao`, " \
                  "`level_xiao_per`) VALUES " \
                  "('%s', '%s', '%s', %s, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s');" % \
                  (i[0], i[1], sj, i[3], i[4], i[5], i[6], i[7],
                   i[8],
                   i[9], i[10], i[11], i[12], i[13], i[14])
    
            cs.execute(sql)
        db.commit()
    
        cs.close()
        db.close()

    except Exception as e:
        Email.sendErr()


for i in range(0, 1):
    print(i)
    start(1000*i)