|
|
@@ -1294,31 +1294,35 @@ class Roll_Zuqiupipeline(object):
|
|
|
pt = item['pt']
|
|
|
match_score = "{}:{}".format(score_home,score_guest)
|
|
|
corner_ball = item['corner_ball']
|
|
|
- p_code, p_id = get_pcode(corner_ball, 'concede_size')
|
|
|
# 构建唯一索引
|
|
|
half_size_guest = item["half_size_guest"]
|
|
|
half_size_guest_rule = item["half_size_guest_rule"]
|
|
|
half_size_home = item["half_size_home"]
|
|
|
half_size_home_rule = item["half_size_home_rule"]
|
|
|
try:
|
|
|
+ p_code, p_id = get_pcode(corner_ball, 'goal_size')
|
|
|
size_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
|
|
|
'source': "hg3535", 'expire_time': expire_time, 'pt': pt,'match_score':match_score,'team_home':team_home,'team_guest':team_guest,'score_home':score_home,'score_guest':score_guest,'number':number,'time_game':time_game,'half_way':half_way}
|
|
|
# 让球 数据插入数据库
|
|
|
- zqone_intodbs(data1=half_size_home, data2=size_data, data3="half_size_home", data4=half_size_home_rule,
|
|
|
+ zqone_intodbs(data1=half_size_home, data2=size_data, data3="half_goal_size_home", data4=half_size_home_rule,
|
|
|
cursor=self.cursor, redis_db=self.redis_db)
|
|
|
# 让球 数据插入数据库
|
|
|
- zqone_intodbs(data1=half_size_guest, data2=size_data, data3="half_size_guest", data4=half_size_guest_rule,
|
|
|
+ zqone_intodbs(data1=half_size_guest, data2=size_data, data3="half_goal_size_guest", data4=half_size_guest_rule,
|
|
|
cursor=self.cursor, redis_db=self.redis_db)
|
|
|
# 全场场大小
|
|
|
size_guest = item["size_guest"]
|
|
|
size_guest_rule = item["size_guest_rule"]
|
|
|
size_home = item["size_home"]
|
|
|
size_home_rule = item["size_home_rule"]
|
|
|
- zqone_intodbs(data1=size_guest, data2=size_data, data3="size_guest", data4=size_guest_rule,
|
|
|
+ zqone_intodbs(data1=size_guest, data2=size_data, data3="goal_size_guest", data4=size_guest_rule,
|
|
|
cursor=self.cursor, redis_db=self.redis_db)
|
|
|
- zqone_intodbs(data1=size_home, data2=size_data, data3="size_home", data4=size_home_rule,
|
|
|
+ zqone_intodbs(data1=size_home, data2=size_data, data3="goal_size_home", data4=size_home_rule,
|
|
|
cursor=self.cursor, redis_db=self.redis_db)
|
|
|
# 上半场大小
|
|
|
+ p_code, p_id = get_pcode(corner_ball, 'concede')
|
|
|
+ size_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
|
|
|
+ 'source': "hg3535", 'expire_time': expire_time, 'pt': pt,'match_score':match_score,'team_home':team_home,'team_guest':team_guest,'score_home':score_home,'score_guest':score_guest,'number':number,'time_game':time_game,'half_way':half_way}
|
|
|
+ # 让球 数据插入数据库
|
|
|
half_concede_home_rule = item["half_concede_home_rule"]
|
|
|
half_concede_home = item["half_concede_home"]
|
|
|
half_concede_guest_rule = item["half_concede_guest_rule"]
|
|
|
@@ -1456,7 +1460,7 @@ class Roll_Zuqiupipeline(object):
|
|
|
# 构建唯一索引
|
|
|
zqtwo_intodbs(data1=value, data2=first_last_data, data3=key, data4=first_last_dict[key], cursor=self.cursor, redis_db=self.redis_db)
|
|
|
|
|
|
- p_code, p_id = get_pcode(corner_ball, 'temaball')
|
|
|
+ p_code, p_id = get_pcode(corner_ball, 'tema_ball')
|
|
|
full_dicts = item['full_data']
|
|
|
half_dicts = item['half_data']
|
|
|
full_dict_rules = item['full_data_rule']
|