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 one_post(data, match_id, odds_code, p_id, league_id, p_code, condition, game_code):
    if data:
        new_hash = hash_func(match_id=match_id, odds_code=odds_code, sort=0, p_id=p_id)
        r_hash = r_func(match_id=match_id, odds_code=odds_code, sort=0, p_id=p_id, odd=data)
        payload = {
            "game_code": game_code,
            "title": "odds",
            "data": {
                "match_id": match_id,
                "lg_id": league_id,
                "odds_code": odds_code,
                "status": 0,
                "sort": 0,
                "p_code": p_code,
                "odds": data,
                "condition": condition,
                "odds_only": r_hash,
                "sole": new_hash,
                "source": "hg3535",
                "type": 0,
                "team": ""
            }
        }
        return payload


def two_post(data, match_id, odds_code, p_id, league_id, p_code, condition, game_code):
    if data:
        for index, value in enumerate(data):
            if value:
                s_hash = hash_func(match_id=match_id, odds_code=odds_code, sort=0, p_id=p_id)
                o_hash = r_func(match_id=match_id, odds_code=odds_code, sort=0, p_id=p_id, odd=value)
                f1 = fuhao(str(condition[index]))
                payload = {
                    "game_code": game_code,
                    "title": "odds",
                    "data": {
                        "match_id": match_id,
                        "lg_id": league_id,
                        "odds_code": odds_code,
                        "status": 0,
                        "sort": index,
                        "p_code": p_code,
                        "odds": value,
                        "condition": f1,
                        "odds_only": o_hash,
                        "sole": s_hash,
                        "source": "hg3535",
                        "type": 0,
                        "team": ""
                    }
                }
                return payload