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': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6, 'first_last_ball': 7, 'team_score': 11, 'goal_size': 13} 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': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6, 'first_last_ball': 7, 'team_score': 11, 'goal_size': 13} 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