|
|
@@ -512,508 +512,27 @@ def news_times(ctime):
|
|
|
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
|
|
|
+def one_post(data, match_id, odds_code, p_id, league_id, p_code, condition):
|
|
|
+ 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": "zq",
|
|
|
+ "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
|
Your Name