sports_scrapy/hg3535/ball_func.py

import datetime
import hashlib
import time

# 生成哈希索引 sole
def hash_func(match_id, odds_code, sort, p_id):
    m = hashlib.md5()
    a = str(match_id) + str(odds_code) + str(sort) + str(p_id)
    m.update(a.encode('utf-8'))
    c = m.hexdigest()
    return c


# 生成odds_only哈希
def r_func(match_id, odds_code, sort, p_id, odd):
    m = hashlib.md5()
    a = str(match_id) + str(odds_code) + str(sort) + str(p_id) + str(odd)
    m.update(a.encode('utf-8'))
    c = m.hexdigest()
    return c


# 转换成本地时间
def new_time(ctime):
    time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
    time2 = time.localtime(time1)
    time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
    time4 = time3
    data_time = str(time4).split(" ")
    match_date = data_time[0]
    match_time = data_time[1]
    return match_date, match_time, time3


def out_time(ctime, i):
    ctime1 = datetime.datetime.strptime(ctime, "%Y-%m-%d %H:%M:%S")
    n_ctime = (ctime1 + datetime.timedelta(hours=i)).strftime("%Y-%m-%d %H:%M:%S")
    return n_ctime


def fuhao(f):
    if f.startswith('+'):
        f = f.replace('+', '-')
        return f
    elif f.startswith('-'):
        f = f.replace('-', '+')
        return f
    else:
        return f


# 篮球插入赔率 -----------------------------------------------------------------------------------------------------------
def one_intodb(data1, data2, data3, cursor, redis_db):
    if data1:
        for key, value in data1.items():
            if value:
                for x, y in enumerate(value):
                    new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'])
                    r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'],odd=y)
                    odds_only = r_hash
                    l_f = fuhao(str(data3[key][x]))
                    if redis_db.hexists("hg3535_lanqiu", r_hash):
                        pass
                    else:
                        redis_db.hset("hg3535_lanqiu", r_hash, 0)
                        sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
                        cursor.execute(sql1, (
                            int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
                            data2['p_id'], data2["p_code"], x, data2["source"], new_hash,
                            l_f, data2['expire_time'], odds_only,data2['utime'], y, data2['expire_time'],
                            odds_only, l_f))
                        # 更新主队st_zq_odds_record表
                        sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
                        cursor.execute(sql2, (
                            int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
                            data2['p_id'], data2["p_code"], x, data2["source"], l_f, odds_only))


def two_intodb(data1, data2, data3, cursor, redis_db):
    if data1:
        for key, value in data1.items():
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'])

                r_hash = r_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
                odds_only = r_hash
                if redis_db.hexists("hg3535_lanqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_lanqiu", r_hash, 0)
                    sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
                    cursor.execute(sql1, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
                        key, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'], odds_only,key))
                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], key, odds_only))


def three_intodb(data1, data2, cursor, redis_db):
    if data1:
        for key, value in data1.items():
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])

                r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
                odds_only = r_hash
                if redis_db.hexists("hg3535_lanqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_lanqiu", r_hash, 0)
                    sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s;"
                    cursor.execute(sql1, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash, data2['expire_time'],
                        odds_only,data2['utime'], value, data2['expire_time'], odds_only))
                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], odds_only))



# 插入篮球赛事表
def into_competition(data, cursor):
    Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag, type, source,expire_time,is_today,is_morningplate,is_stringscene) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s, %s, %s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,is_morningplate=%s,is_stringscene=%s;"
    cursor.execute(Competition_sql, (
        data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
        data['match_time'],
        data['utime'], data['utime'], data['number'], data['pt'], data["source"], data['expire_time'], data['is_today'],
        data['is_morningplate'], data['is_stringscene'], data['number'], data['expire_time'], data['is_today'],
        data['is_morningplate'], data['is_stringscene']))


# 插入足球赛事表----------------------------------------------------------------------------------------------------------
def zqone_competition(data, cursor):
    Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,us_time=%s;"
    cursor.execute(Competition_sql, (
        data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
        data['match_time'],
        data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_today'],
        data['us_time'], data['number'], data['expire_time'], data['is_today'],data['us_time']))


def zqtwo_competition(data, cursor):
    Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s,us_time=%s;"
    cursor.execute(Competition_sql, (
        data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
        data['match_time'],
        data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_morningplate'],
        data['us_time'], data['number'], data['expire_time'], data['is_morningplate'], data['us_time']))


def zqthree_competition(data, cursor):
    Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s,us_time=%s;"
    cursor.execute(Competition_sql, (
        data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
        data['match_time'],
        data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_stringscene'],
        data['us_time'], data['number'], data['expire_time'], data['is_stringscene'], data['us_time']))


# 足球 插入赔率 让球 大小-------------------------------------------------------------------------------------------------
def zqone_intodb(data1, data2, data3, data4, cursor, redis_db):
    if data1:
        for index, value in enumerate(data1):
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'])
                r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'], odd=value)
                odds_only = r_hash
                f1 = fuhao(str(data4[index]))
                if redis_db.hexists("hg3535_zuqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_zuqiu", r_hash, 0)
                    sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
                    cursor.execute(sql1, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], index, data2["source"], new_hash,
                        f1, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
                        odds_only, f1))

                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], index, data2["source"], f1, odds_only))



# 足球 插入赔率  独赢 单双
def zqtwo_intodb(data1, data2, data3, data4, cursor, redis_db):
    if data1:
        new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'])
        r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'],
                        odd=data1)
        odds_only = r_hash
        if redis_db.hexists("hg3535_zuqiu", r_hash):
            pass
        else:
            redis_db.hset("hg3535_zuqiu", r_hash, 0)
            sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time, odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
            cursor.execute(sql1, (
                int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
                data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
                data4, data2['expire_time'], odds_only, data2['utime'], data1, data2['expire_time'], odds_only,data4))
            # 更新主队st_zq_odds_record表
            sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s,%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
            cursor.execute(sql2, (
                int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
                data2['p_id'], data2["p_code"], data2['sort'], data2["source"], data4, odds_only))


def gjz_into(data, cursor, r_hash, s_hash, redis_db):
    if redis_db.hexists('hg3535_guanjun', r_hash):
        pass
    else:
        redis_db.hset('hg3535_guanjun', r_hash, 0)
        # if pt == 1:
        sql = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
        cursor.execute(sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
            data['champion_team'], data['expire_time'], data['odds_only']))
        # 插入st_zq_odds_record表
        new_sql = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
        cursor.execute(new_sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['odds_only']))

    if redis_db.hexists('hg3535_liansai', s_hash):
        pass
    else:
        redis_db.hset('hg3535_liansai', s_hash, 0)
        league_sql = "insert into st_zq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
        cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))


def gjl_into(data, cursor, r_hash, s_hash, redis_db):
    if redis_db.hexists('hg3535_guanjun', r_hash):
        pass
    else:
        redis_db.hset('hg3535_guanjun', r_hash, 0)
        sql = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
        cursor.execute(sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
            data['champion_team'], data['expire_time'], data['odds_only']))
        # 插入st_zq_odds_record表
        new_sql = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
        cursor.execute(new_sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['odds_only']))
    # 插入st_zq_league表
    if redis_db.hexists('hg3535_liansai', s_hash):
        pass
    else:
        redis_db.hset('hg3535_liansai', s_hash, 0)
        league_sql = "insert into st_lq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
        cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))


def gjw_into(data, cursor, r_hash, s_hash, redis_db):
    if redis_db.hexists('hg3535_guanjun', r_hash):
        pass
    else:
        redis_db.hset('hg3535_guanjun', r_hash, 0)
        sql = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
        cursor.execute(sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
            data['champion_team'], data['expire_time'], data['odds_only']))
        # 插入st_zq_odds_record表
        new_sql = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s)"
        cursor.execute(new_sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['odds_only']))
    # 插入st_zq_league表
    if redis_db.hexists('hg3535_liansai', s_hash):
        pass
    else:
        redis_db.hset('hg3535_liansai', s_hash, 0)
        league_sql = "insert into st_wq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
        cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))


def gjb_into(data, cursor, r_hash, s_hash, redis_db):
    if redis_db.hexists('hg3535_guanjun', r_hash):
        pass
    else:
        redis_db.hset('hg3535_guanjun', r_hash, 0)
        sql = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
        cursor.execute(sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
            data['champion_team'], data['expire_time'], data['odds_only']))
        # 插入st_zq_odds_record表
        new_sql = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
        cursor.execute(new_sql, (
            int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
            data['champion_team'], data['p_id'], data['new_league_name'],
            data['tema_home'], 1, "hg3535", data['odds_only']))
    # 插入st_zq_league表
    if redis_db.hexists('hg3535_liansai', s_hash):
        pass
    else:
        redis_db.hset('hg3535_liansai', s_hash, 0)
        league_sql = "insert into st_bq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
        cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))


# 网球 插入赔率----------------------------------------------------------------------------------------------------------
def wqone_intodb(data1, data2, data3, cursor, redis_db):
    if data1:
        for key, value in data1.items():
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
                r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
                odds_only = r_hash
                w_f = fuhao(str(data3[key]))
                if redis_db.hexists("hg3535_wangqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_wangqiu", r_hash, 0)
                    sql1 = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
                    cursor.execute(sql1, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
                        w_f, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
                        odds_only, w_f))
                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], w_f, odds_only))


# 棒球 插入赔率----------------------------------------------------------------------------------------------------------
def bqone_intodb(data1, data2, data3, cursor, redis_db):
    if data1:
        for key, value in data1.items():
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
                r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
                odds_only = r_hash
                b_f = fuhao(str(data3[key]))
                if redis_db.hexists("hg3535_bangqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_bangqiu", r_hash, 0)
                    sql1 = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s"
                    cursor.execute(sql1, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
                        b_f, data2['expire_time'], odds_only, data2['utime'], value,data2['expire_time'],
                        odds_only, b_f))
                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s, %s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
                        data2['p_id'], data2["p_code"], data2['sort'], data2["source"], b_f, odds_only))



def get_pcode(corner_ball, code):
    code_dict = {'concede_size': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6,
                 'first_last_ball': 7, 'temaball': 11}
    if corner_ball == "角球":
        p_code = "corner_ball"
        p_id = 9
    elif corner_ball == "会晋级":
        p_code = "promotion"
        p_id = 10
    elif corner_ball == "罚牌数":
        p_code = "Penalty_card"
        p_id = 12
    else:
        p_code = code
        p_id = code_dict[code]
    return p_code, p_id





# ----------------------------------------------------------------------------------------------------------------------
def new_times(ctime):
    time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
    time2 = time.localtime(time1)
    time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
    data_time = str(time3).split(" ")
    match_date = data_time[0]
    match_time = data_time[1]
    return match_date,match_time


def zqone_intodbs(data1, data2, data3, data4, cursor, redis_db):
    if data1:
        for index, value in enumerate(data1):
            if value:
                new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'])
                r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'], odd=value)
                odds_only = r_hash
                if redis_db.hexists("hg3535_zuqiu", r_hash):
                    pass
                else:
                    redis_db.hset("hg3535_zuqiu", r_hash, 0)
                    # if data2['pt'] == 0:
                    sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only,is_rollball) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
                    cursor.execute(sql1, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], index, data2["source"], new_hash,
                        data4[index], data2['expire_time'], odds_only, 1, data2['utime'], value, data2['expire_time'],
                        odds_only,data4[index]))

                    # 更新主队st_zq_odds_record表
                    sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only,is_rollball) values (%s,%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
                    cursor.execute(sql2, (
                        int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
                        data2['p_id'], data2["p_code"], index, data2["source"], data4[index], odds_only,1))
                    #写入数据设置默认值竟然不生效 待看
                    sql3 = "insert into st_zq_result(match_id, match_score, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_winer, update_time, match_time,match_process,tag,lg_id,u_home_score,u_guest_score,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set update_time=%s,match_score=%s,match_time=%s,match_process=%s,home_score=%s,guest_score=%s;"
                    cursor.execute(sql3, (
                        int(data2['game_id']), data2['match_score'],data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','','',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['league_id']),0,0,'hg3535',data2["p_code"],data2['utime'],data2['match_score'],data2['time_game'],data2['half_way'],data2['score_home'],data2['score_guest']
                    ))

                    sql4 = "insert into st_zq_result_record(lg_id, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_score, match_winer, update_time, match_time,match_process,tag,match_id,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s);"
                    cursor.execute(sql4, (
                        int(data2['league_id']), data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','',data2['match_score'],'',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['game_id']),'hg3535',data2["p_code"]
                    ))


def zqtwo_intodbs(data1, data2, data3, data4, cursor, redis_db):
    if data1:
        new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'])
        r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'],
                        odd=data1)
        odds_only = r_hash
        if redis_db.hexists("hg3535_zuqiu", r_hash):
            pass
        else:
            redis_db.hset("hg3535_zuqiu", r_hash, 0)
            # if data2['pt'] == 1:
            sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time, odds_only,is_today) values (%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
            cursor.execute(sql1, (
                int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
                data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
                data4, data2['expire_time'], odds_only, 1, data2['utime'], data1, data2['expire_time'], odds_only,data4))
            # 更新主队st_zq_odds_record表
            sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only, is_today) values (%s,%s,%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
            cursor.execute(sql2, (
                int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
                data2['p_id'], data2["p_code"], data2['sort'], data2["source"], data4, odds_only, 1))

            sql3 = "insert into st_zq_result(match_id, match_score, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_winer, update_time, match_time,match_process,tag,lg_id,u_home_score,u_guest_score,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set update_time=%s,match_score=%s,match_time=%s,match_process=%s,home_score=%s,guest_score=%s;"
            cursor.execute(sql3, (
                    int(data2['game_id']), data2['match_score'],data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','','',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['league_id']),0,0,'hg3535',data2["p_code"],data2['utime'],data2['match_score'],data2['time_game'],data2['half_way'],data2['score_home'],data2['score_guest']
                ))

            sql4 = "insert into st_zq_result_record(lg_id, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_score, match_winer, update_time, match_time,match_process,tag,match_id,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s);"
            cursor.execute(sql4, (
                    int(data2['league_id']), data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','',data2['match_score'],'',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['game_id']),'hg3535',data2["p_code"]
                ))


def zqone_competitions(data, cursor):
    Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, status, match_id, match_date, match_time, ctime, utime,tag, source,type,expire_time,us_time,is_rollball) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set utime = %s,status=%s,tag=%s,expire_time=%s;"
    cursor.execute(Competition_sql, (
        data['team_home'], data['team_guest'], data['league_id'],1,data['game_id'], data['match_date'],
        data['match_time'],
        data['utime'], data['utime'], data['number'], data["source"], 4,data['expire_time'], data['us_time'],data['is_rollball'],
        data['utime'], 1, data['number'], data['expire_time']))


def get_pcodes(corner_ball, code):
    code_dict = {'concede_size': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6,
                 'first_last_ball': 7, 'temaball': 11}
    if corner_ball == "角球":
        p_code = "corner_ball"
        p_id = 9
    elif corner_ball == "会晋级":
        p_code = "promotion"
        p_id = 10
    elif corner_ball == "罚牌数":
        p_code = "Penalty_card"
        p_id = 12
    else:
        p_code = code
        p_id = code_dict[code]
    return p_code, p_id


def news_times(ctime):
    time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
    time2 = time.localtime(time1)
    time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
    time4 = time3
    data_time = str(time4).split(" ")
    match_date = data_time[0]
    match_time = data_time[1]
    return match_date, match_time, time3


# def hash_func(match_id, odds_code, sort, p_id):
#     m = hashlib.md5()
#     a = str(match_id) + str(odds_code) + str(sort) + str(p_id)
#     m.update(a.encode('utf-8'))
#     c = m.hexdigest()
#     return c
#
#
# # 生成odds_only哈希
# def r_func(match_id, odds_code, sort, p_id, odd):
#     m = hashlib.md5()
#     a = str(match_id) + str(odds_code) + str(sort) + str(p_id) + str(odd)
#     m.update(a.encode('utf-8'))
#     c = m.hexdigest()
#     return c
#
#
# # 转换成本地时间
# def new_time(ctime):
#     time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
#     time2 = time.localtime(time1)
#     time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
#     time4 = time3
#     data_time = str(time4).split(" ")
#     match_date = data_time[0]
#     match_time = data_time[1]
#     return match_date, match_time, time3
#
#
# def out_time(ctime, i):
#     ctime1 = datetime.datetime.strptime(ctime, "%Y-%m-%d %H:%M:%S")
#     n_ctime = (ctime1 + datetime.timedelta(hours=i)).strftime("%Y-%m-%d %H:%M:%S")
#     return n_ctime
#
#
# def fuhao(f):
#     if f.startswith('+'):
#         f = f.replace('+', '-')
#         return f
#     elif f.startswith('-'):
#         f = f.replace('-', '+')
#         return f
#     else:
#         return f
#
#
# # 篮球插入赔率 -----------------------------------------------------------------------------------------------------------
# def one_intodb(data1, data2, data3, cursor, redis_db):
#     if data1:
#         for key, value in data1.items():
#             if value:
#                 for x, y in enumerate(value):
#                     new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'])
#                     r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'],odd=y)
#                     odds_only = r_hash
#                     l_f = fuhao(str(data3[key][x]))
#                     if redis_db.hexists("hg3535_lanqiu", r_hash):
#                         pass
#                     else:
#                         redis_db.hset("hg3535_lanqiu", r_hash, 0)
#                         sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#                         cursor.execute(sql1, (
#                             int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
#                             data2['p_id'], data2["p_code"], x, data2["source"], new_hash,
#                             l_f, data2['expire_time'], odds_only,data2['utime'], y, data2['expire_time'],
#                             odds_only, l_f))
#                         # 更新主队st_zq_odds_record表
#                         sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
#                         cursor.execute(sql2, (
#                             int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
#                             data2['p_id'], data2["p_code"], x, data2["source"], l_f, odds_only))
#
#
# def two_intodb(data1, data2, data3, cursor, redis_db):
#     if data1:
#         for key, value in data1.items():
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'])
#
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
#                 odds_only = r_hash
#                 if redis_db.hexists("hg3535_lanqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_lanqiu", r_hash, 0)
#                     sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
#                         key, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'], odds_only,key))
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], key, odds_only))
#
#
# def three_intodb(data1, data2, cursor, redis_db):
#     if data1:
#         for key, value in data1.items():
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
#
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
#                 odds_only = r_hash
#                 if redis_db.hexists("hg3535_lanqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_lanqiu", r_hash, 0)
#                     sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s;"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash, data2['expire_time'],
#                         odds_only,data2['utime'], value, data2['expire_time'], odds_only))
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], odds_only))
#
#
# # 插入篮球赛事表
# def into_competition(data, cursor):
#     Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag, type, source,expire_time,is_today,is_morningplate,is_stringscene) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s, %s, %s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,is_morningplate=%s,is_stringscene=%s;"
#     cursor.execute(Competition_sql, (
#         data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
#         data['match_time'],
#         data['utime'], data['utime'], data['number'], data['pt'], data["source"], data['expire_time'], data['is_today'],
#         data['is_morningplate'], data['is_stringscene'], data['number'], data['expire_time'], data['is_today'],
#         data['is_morningplate'], data['is_stringscene']))
#
#
# # 插入足球赛事表----------------------------------------------------------------------------------------------------------
# def zqone_competition(data, cursor):
#     Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,us_time=%s;"
#     cursor.execute(Competition_sql, (
#         data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
#         data['match_time'],
#         data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_today'],
#         data['us_time'], data['number'], data['expire_time'], data['is_today'],data['us_time']))
#
#
# def zqtwo_competition(data, cursor):
#     Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s,us_time=%s;"
#     cursor.execute(Competition_sql, (
#         data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
#         data['match_time'],
#         data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_morningplate'],
#         data['us_time'], data['number'], data['expire_time'], data['is_morningplate'], data['us_time']))
#
#
# def zqthree_competition(data, cursor):
#     Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s,us_time=%s;"
#     cursor.execute(Competition_sql, (
#         data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
#         data['match_time'],
#         data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_stringscene'],
#         data['us_time'], data['number'], data['expire_time'], data['is_stringscene'], data['us_time']))
#
#
# # 足球 插入赔率 让球 大小-------------------------------------------------------------------------------------------------
# def zqone_intodb(data1, data2, data3, data4, cursor, redis_db):
#     if data1:
#         for index, value in enumerate(data1):
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'])
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'], odd=value)
#                 odds_only = r_hash
#                 f1 = fuhao(str(data4[index]))
#                 if redis_db.hexists("hg3535_zuqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_zuqiu", r_hash, 0)
#                     sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], index, data2["source"], new_hash,
#                         f1, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
#                         odds_only, f1))
#
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], index, data2["source"], f1, odds_only))
#
#
#
# # 足球 插入赔率  独赢 单双
# def zqtwo_intodb(data1, data2, data3, data4, cursor, redis_db):
#     if data1:
#         new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'])
#         r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'],
#                         odd=data1)
#         odds_only = r_hash
#         if redis_db.hexists("hg3535_zuqiu", r_hash):
#             pass
#         else:
#             redis_db.hset("hg3535_zuqiu", r_hash, 0)
#             sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time, odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#             cursor.execute(sql1, (
#                 int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
#                 data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
#                 data4, data2['expire_time'], odds_only, data2['utime'], data1, data2['expire_time'], odds_only,data4))
#             # 更新主队st_zq_odds_record表
#             sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s,%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#             cursor.execute(sql2, (
#                 int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
#                 data2['p_id'], data2["p_code"], data2['sort'], data2["source"], data4, odds_only))
#
#
# def gjz_into(data, cursor, r_hash, s_hash, redis_db):
#     if redis_db.hexists('hg3535_guanjun', r_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_guanjun', r_hash, 0)
#         # if pt == 1:
#         sql = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
#         cursor.execute(sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
#             data['champion_team'], data['expire_time'], data['odds_only']))
#         # 插入st_zq_odds_record表
#         new_sql = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
#         cursor.execute(new_sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['odds_only']))
#
#     if redis_db.hexists('hg3535_liansai', s_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_liansai', s_hash, 0)
#         league_sql = "insert into st_zq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
#         cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
#
#
# def gjl_into(data, cursor, r_hash, s_hash, redis_db):
#     if redis_db.hexists('hg3535_guanjun', r_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_guanjun', r_hash, 0)
#         sql = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
#         cursor.execute(sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
#             data['champion_team'], data['expire_time'], data['odds_only']))
#         # 插入st_zq_odds_record表
#         new_sql = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
#         cursor.execute(new_sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['odds_only']))
#     # 插入st_zq_league表
#     if redis_db.hexists('hg3535_liansai', s_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_liansai', s_hash, 0)
#         league_sql = "insert into st_lq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
#         cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
#
#
# def gjw_into(data, cursor, r_hash, s_hash, redis_db):
#     if redis_db.hexists('hg3535_guanjun', r_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_guanjun', r_hash, 0)
#         sql = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
#         cursor.execute(sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
#             data['champion_team'], data['expire_time'], data['odds_only']))
#         # 插入st_zq_odds_record表
#         new_sql = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s)"
#         cursor.execute(new_sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['odds_only']))
#     # 插入st_zq_league表
#     if redis_db.hexists('hg3535_liansai', s_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_liansai', s_hash, 0)
#         league_sql = "insert into st_wq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
#         cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
#
#
# def gjb_into(data, cursor, r_hash, s_hash, redis_db):
#     if redis_db.hexists('hg3535_guanjun', r_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_guanjun', r_hash, 0)
#         sql = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
#         cursor.execute(sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
#             data['champion_team'], data['expire_time'], data['odds_only']))
#         # 插入st_zq_odds_record表
#         new_sql = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
#         cursor.execute(new_sql, (
#             int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
#             data['champion_team'], data['p_id'], data['new_league_name'],
#             data['tema_home'], 1, "hg3535", data['odds_only']))
#     # 插入st_zq_league表
#     if redis_db.hexists('hg3535_liansai', s_hash):
#         pass
#     else:
#         redis_db.hset('hg3535_liansai', s_hash, 0)
#         league_sql = "insert into st_bq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
#         cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
#
#
# # 网球 插入赔率----------------------------------------------------------------------------------------------------------
# def wqone_intodb(data1, data2, data3, cursor, redis_db):
#     if data1:
#         for key, value in data1.items():
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
#                 odds_only = r_hash
#                 w_f = fuhao(str(data3[key]))
#                 if redis_db.hexists("hg3535_wangqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_wangqiu", r_hash, 0)
#                     sql1 = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
#                         w_f, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
#                         odds_only, w_f))
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], w_f, odds_only))
#
#
# # 棒球 插入赔率----------------------------------------------------------------------------------------------------------
# def bqone_intodb(data1, data2, data3, cursor, redis_db):
#     if data1:
#         for key, value in data1.items():
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
#                 odds_only = r_hash
#                 b_f = fuhao(str(data3[key]))
#                 if redis_db.hexists("hg3535_bangqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_bangqiu", r_hash, 0)
#                     sql1 = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
#                         b_f, data2['expire_time'], odds_only, data2['utime'], value,data2['expire_time'],
#                         odds_only, b_f))
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s, %s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
#                         data2['p_id'], data2["p_code"], data2['sort'], data2["source"], b_f, odds_only))
#
#
#
# def get_pcode(corner_ball, code):
#     code_dict = {'concede_size': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6,
#                  'first_last_ball': 7, 'temaball': 11}
#     if corner_ball == "角球":
#         p_code = "corner_ball"
#         p_id = 9
#     elif corner_ball == "会晋级":
#         p_code = "promotion"
#         p_id = 10
#     elif corner_ball == "罚牌数":
#         p_code = "Penalty_card"
#         p_id = 12
#     else:
#         p_code = code
#         p_id = code_dict[code]
#     return p_code, p_id





#滚球方法都加了s

# def zqone_intodbs(data1, data2, data3, data4, cursor, redis_db):
#     if data1:
#         for index, value in enumerate(data1):
#             if value:
#                 new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'])
#                 r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'], odd=value)
#                 odds_only = r_hash
#                 if redis_db.hexists("hg3535_zuqiu", r_hash):
#                     pass
#                 else:
#                     redis_db.hset("hg3535_zuqiu", r_hash, 0)
#                     # if data2['pt'] == 0:
#                     sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only,is_rollball) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#                     cursor.execute(sql1, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], index, data2["source"], new_hash,
#                         data4[index], data2['expire_time'], odds_only, 1, data2['utime'], value, data2['expire_time'],
#                         odds_only,data4[index]))
#
#                     # 更新主队st_zq_odds_record表
#                     sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only,is_rollball) values (%s,%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#                     cursor.execute(sql2, (
#                         int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
#                         data2['p_id'], data2["p_code"], index, data2["source"], data4[index], odds_only,1))
#                     #写入数据设置默认值竟然不生效 待看
#                     sql3 = "insert into st_zq_result(match_id, match_score, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_winer, update_time, match_time,match_process,tag,lg_id,u_home_score,u_guest_score,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set update_time=%s,match_score=%s,match_time=%s,match_process=%s,home_score=%s,guest_score=%s;"
#                     cursor.execute(sql3, (
#                         int(data2['game_id']), data2['match_score'],data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','','',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['league_id']),0,0,'hg3535',data2["p_code"],data2['utime'],data2['match_score'],data2['time_game'],data2['half_way'],data2['score_home'],data2['score_guest']
#                     ))
#
#                     sql4 = "insert into st_zq_result_record(lg_id, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_score, match_winer, update_time, match_time,match_process,tag,match_id,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s);"
#                     cursor.execute(sql4, (
#                         int(data2['league_id']), data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','',data2['match_score'],'',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['game_id']),'hg3535',data2["p_code"]
#                     ))
#
# def zqtwo_intodbs(data1, data2, data3, data4, cursor, redis_db):
#     if data1:
#         new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'])
#         r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'],
#                         odd=data1)
#         odds_only = r_hash
#         if redis_db.hexists("hg3535_zuqiu", r_hash):
#             pass
#         else:
#             redis_db.hset("hg3535_zuqiu", r_hash, 0)
#             # if data2['pt'] == 1:
#             sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time, odds_only,is_today) values (%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
#             cursor.execute(sql1, (
#                 int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
#                 data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
#                 data4, data2['expire_time'], odds_only, 1, data2['utime'], data1, data2['expire_time'], odds_only,data4))
#             # 更新主队st_zq_odds_record表
#             sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only, is_today) values (%s,%s,%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
#             cursor.execute(sql2, (
#                 int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
#                 data2['p_id'], data2["p_code"], data2['sort'], data2["source"], data4, odds_only, 1))
#
#             sql3 = "insert into st_zq_result(match_id, match_score, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_winer, update_time, match_time,match_process,tag,lg_id,u_home_score,u_guest_score,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set update_time=%s,match_score=%s,match_time=%s,match_process=%s,home_score=%s,guest_score=%s;"
#             cursor.execute(sql3, (
#                     int(data2['game_id']), data2['match_score'],data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','','',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['league_id']),0,0,'hg3535',data2["p_code"],data2['utime'],data2['match_score'],data2['time_game'],data2['half_way'],data2['score_home'],data2['score_guest']
#                 ))
#
#             sql4 = "insert into st_zq_result_record(lg_id, home_team, guest_team, home_score, guest_score, all_goal, status, first_score, last_score, match_score, match_winer, update_time, match_time,match_process,tag,match_id,source,p_code) values (%s,%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s,%s,%s);"
#             cursor.execute(sql4, (
#                     int(data2['league_id']), data2['team_home'],data2['team_guest'],data2['score_home'],data2['score_guest'],data2['number'],1,'','',data2['match_score'],'',data2['utime'],data2['time_game'],data2['half_way'],data2['number'],int(data2['game_id']),'hg3535',data2["p_code"]
#                 ))
#
#
# def zqone_competitions(data, cursor):
#     Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, status, match_id, match_date, match_time, ctime, utime,tag, source,type,expire_time,us_time,is_rollball) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s,%s,%s) on conflict(match_id) do update set utime = %s,status=%s,tag=%s,expire_time=%s;"
#     cursor.execute(Competition_sql, (
#         data['team_home'], data['team_guest'], data['league_id'],1,data['game_id'], data['match_date'],
#         data['match_time'],
#         data['utime'], data['utime'], data['number'], data["source"], 4,data['expire_time'], data['us_time'],data['is_rollball'],
#         data['utime'], 1, data['number'], data['expire_time']))
#
#
# def get_pcodes(corner_ball, code):
#     code_dict = {'concede_size': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6,
#                  'first_last_ball': 7, 'temaball': 11}
#     if corner_ball == "角球":
#         p_code = "corner_ball"
#         p_id = 9
#     elif corner_ball == "会晋级":
#         p_code = "promotion"
#         p_id = 10
#     elif corner_ball == "罚牌数":
#         p_code = "Penalty_card"
#         p_id = 12
#     else:
#         p_code = code
#         p_id = code_dict[code]
#     return p_code, p_id
#
#
# def news_times(ctime):
#     time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
#     time2 = time.localtime(time1)
#     time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
#     time4 = time3
#     data_time = str(time4).split(" ")
#     match_date = data_time[0]
#     match_time = data_time[1]
#     return match_date, match_time, time3

# def new_times(ctime):
#     time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
#     time2 = time.localtime(time1)
#     time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
#     data_time = str(time3).split(" ")
#     match_date = data_time[0]
#     match_time = data_time[1]
#     return match_date,match_time