token更改

hg3535/pipeline/bangqiu.py

@@ -137,11 +137,11 @@ class Bangqiupipeline(object):
             if res:
                 if res.get('status') == 1:
                     self.db.bq_competition35.insert(match_data)
-                    logger.info('棒球赛事提交成功, {}, {}'.format(res, match_data))
+                    logger.info('棒球赛事提交成功, {}'.format(res))
                 else:
-                    logger.warning('棒球赛事提交失败, {}, {}'.format(res, match_data))
+                    logger.warning('棒球赛事提交失败, {}, {}'.format(res, match_dict))
             else:
-                logger.warning('棒球赛事接口异常, 提交失败, {}, {}'.format(res, match_data))
+                logger.warning('棒球赛事接口异常, 提交失败, {}, {}'.format(res, match_dict))
         else:
             logger.info("棒球赛事已存在，不做修改")
 
@@ -221,7 +221,7 @@ class Bangqiupipeline(object):
             res = Helper.async_post('{}/setOdds'.format(POST_URL), odds_dict)
             if res:
                 if res.get('status') == 1:
-                    logger.info('棒球赔率提交成功, {}, {}'.format(res, odds_dict))
+                    logger.info('棒球赔率提交成功, {}'.format(res))
                 else:
                     logger.warning('棒球赔率提交失败, {}, {}'.format(res, odds_dict))
             else:

hg3535/pipeline/roll_bangqiu.py

@@ -107,9 +107,9 @@ class Roll_Banqiupipeline(object):
                 if res.get('status') == 1:
                     self.db.bq_competition35.insert(match_data)
                 else:
-                    logger.warning('棒球滚球赛事提交失败, {}, {}'.format(res, match_data))
+                    logger.warning('棒球滚球赛事提交失败, {}, {}'.format(res, match_dict))
             else:
-                logger.warning('棒球滚球赛事,接口异常,提交失败, {}, {}'.format(res, match_data))
+                logger.warning('棒球滚球赛事,接口异常,提交失败, {}, {}'.format(res, match_dict))
         else:
             logger.info("棒球赛事已存在，棒球赛事状态时间未改变，不做修改")
         """赔率"""

hg3535/pipeline/roll_lanqiu.py

@@ -82,9 +82,9 @@ class Roll_Lanqiupipeline(object):
                     logger.info('篮球滚球联赛提交成功, {}'.format(res))
                     self.db.lq_league35.insert(league_data)
                 else:
-                    logger.warning('篮球滚球联赛提交失败, {}, {}'.format(res, league_data))
+                    logger.warning('篮球滚球联赛提交失败, {}, {}'.format(res, league_dict))
             else:
-                logger.warning('篮球滚球联赛接口, 提交失败, {}, {}'.format(res, league_data))
+                logger.warning('篮球滚球联赛接口, 提交失败, {}, {}'.format(res, league_dict))
         else:
             logger.info('篮球滚球联赛已存在')
         match_identity = Helper.genearte_uuid(team_home + team_guest + match_date)

hg3535/pipeline/roll_wangqiu.py

@@ -260,7 +260,7 @@ class Roll_Wangqiupipeline(object):
                 else:
                     logger.warning('网球滚球结果记录提交失败, {}, {}'.format(res, r_data_dict))
             except Exception as e:
-                logger.warning("网球接口数据异常, 提交失败, {}".format(e))
+                logger.warning("网球接口数据异常, 提交失败, {}, {}".format(e, r_data_dict))
         else:
             logger.info('网球滚球结果记录为空, 不提交')
         reactor.callFromThread(out.callback, item)

hg3535/pipeline/roll_zuqiu.py

@@ -70,13 +70,13 @@ class Roll_Zuqiupipeline(object):
                 if res.get('status') == 1:
                     self.db.zq_league35.insert(league_data)
                     logger.info('足球滚球联赛提交成功, {}'.format(res))
-                    logger.info(league_dict)
+                    # logger.info(league_dict)
                 else:
-                    logger.warning('足球滚球联赛提交失败, {}'.format(res))
-                    logger.warning(league_dict)
+                    logger.warning('足球滚球联赛提交失败, {}, {}'.format(res, league_dict))
+                    # logger.warning(league_dict)
             else:
-                logger.warning('足球滚球联赛接口异常提交失败, {}'.format(res))
-                logger.warning(league_dict)
+                logger.warning('足球滚球联赛接口异常提交失败, {}, {}'.format(res, league_dict))
+                # logger.warning(league_dict)
         else:
             logger.info('足球滚球联赛已存在, 不存在')
         match_identity = Helper.genearte_uuid(team_home + team_guest + match_date)
@@ -98,10 +98,10 @@ class Roll_Zuqiupipeline(object):
                     logger.info('足球滚球赛事提交成功, {}'.format(res))
                     # logger.info(match_data)
                 else:
-                    logger.warning('足球滚球赛事，提交失败, {}'.format(res))
+                    logger.warning('足球滚球赛事，提交失败, {}, {}'.format(res, match_dict))
                     # logger.warning(match_data)
             else:
-                logger.warning('足球滚球赛事接口异常提交失败, {}'.format(res))
+                logger.warning('足球滚球赛事接口异常提交失败, {}, {}'.format(res, match_dict))
                 # logger.warning(match_data)
         else:
             logger.info('足球滚球赛事已存在, 不提交')
@@ -540,10 +540,10 @@ class Roll_Zuqiupipeline(object):
                     logger.info('足球滚球详细赔率提交成功, {}'.format(res))
                     # logger.info(odds_dict)
                 else:
-                    logger.warning('足球滚球详细赔率提交失败, {}'.format(res))
+                    logger.warning('足球滚球详细赔率提交失败, {}, {}'.format(res, odds_dict))
                     # logger.warning(odds_dict)
             else:
-                logger.warning('足球滚球详细赔率接口异常，提交失败, {}'.format(res))
+                logger.warning('足球滚球详细赔率接口异常，提交失败, {}, {}'.format(res, odds_dict))
                 # logger.warning(odds_dict)
         else:
             logger.info('足球滚球详细赔率列表为空')
@@ -572,13 +572,13 @@ class Roll_Zuqiupipeline(object):
                         self.db.zq_match_result35.insert(zq_rball)
                         # logger.info(r_data_dict)
                     else:
-                        logger.warning('足球滚球结果记录提交失败, {}'.format(res))
+                        logger.warning('足球滚球结果记录提交失败, {}, {}'.format(res, r_data_dict))
                         # logger.warning(r_data_dict)
                 else:
-                    logger.warning('足球滚球结果记录接口异常，提交失败, {}'.format(res))
+                    logger.warning('足球滚球结果记录接口异常，提交失败, {}, {}'.format(res, r_data_dict))
                     # logger.warning(r_data_dict)
             except Exception as e:
-                logger.warning('滚球数据接口异常，提交失败, {}'.format(e))
+                logger.warning('滚球数据接口异常，提交失败, {}, {}'.format(e, r_data_dict))
         reactor.callFromThread(out.callback, item)
 
 

hg3535/pipeline/wangqiu.py

@@ -94,15 +94,13 @@ class Wangqiupipeline(object):
             if res:
                 if res.get('status') == 1:
                     self.db.wq_league35.insert(league_data)
-                    # self.db.wq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                    #                                 upsert=True)
                     logger.info('网球联赛提交成功, {}'.format(res))
                 else:
-                    logger.warning('网球联赛提交失败, {}'.format(res))
+                    logger.warning('网球联赛提交失败, {}, {}'.format(res, league_dict))
                     logger.warning(league_dict)
             else:
-                logger.warning('网球联赛接口异常,提交失败, {}'.format(res))
-                logger.warning(league_dict)
+                logger.warning('网球联赛接口异常,提交失败, {}, {}'.format(res, league_dict))
+                # logger.warning(league_dict)
         else:
             logger.info('网球联赛已存在, 不提交')
 
@@ -142,11 +140,11 @@ class Wangqiupipeline(object):
                     self.db.wq_competition35.insert(match_data)
                     logger.info('网球赛事提交成功, {}'.format(res))
                 else:
-                    logger.warning('网球赛事提交失败, {}'.format(res))
-                    logger.warning(match_data)
+                    logger.warning('网球赛事提交失败, {}, {}'.format(res, match_dict))
+                    # logger.warning(match_data)
             else:
-                logger.warning('网球赛事接口异常,提交失败, {}'.format(res))
-                logger.warning(match_dict)
+                logger.warning('网球赛事接口异常,提交失败, {}, {}'.format(res, match_dict))
+                # logger.warning(match_dict)
         else:
             logging.info('网球赛事已存在, 不提交')
 
@@ -243,11 +241,11 @@ class Wangqiupipeline(object):
                     logger.info('网球赔率提交成功, {}'.format(res))
                     # logger.info(odds_dict)
                 else:
-                    logger.warning('网球赔率提交失败, {}'.format(res))
-                    logger.warning(odds_dict)
+                    logger.warning('网球赔率提交失败, {}, {}'.format(res, odds_dict))
+                    # logger.warning(odds_dict)
             else:
-                logger.warning('网球详细接口赔率返回异常, {}'.format(res))
-                logger.warning(odds_dict)
+                logger.warning('网球详细接口赔率返回异常, {}, {}'.format(res, odds_dict))
+                # logger.warning(odds_dict)
         else:
             logger.info('网球详细赔率列表为空, 不提交')
 

hg3535/pipeline/zuqiu.py

@@ -77,7 +77,7 @@ class Zuqiupipeline(object):
                 if res.get('status') == 1:
                     self.db.zq_league35.insert(league_data)
             else:
-                logging.warning('足球详细赔率接口异常, {}'.format(res))
+                logging.warning('足球详细赔率接口异常, {}, {}'.format(res, league_dict))
         else:
             logging.info('{},联赛已存在, 不提交'.format(league_name))
         pt_dict = {'1': 'is_today', '2': 'is_morningplate', '3': 'is_stringscene', '4': 'is_rollball'}
@@ -115,11 +115,11 @@ class Zuqiupipeline(object):
                 if res.get('status') == 1:
                     self.db.zq_competition35.insert(match_data)
                 else:
-                    logger.warning('足球赛事表提交失败, {}'.format(res))
-                    logger.warning(match_dict)
+                    logger.warning('足球赛事表提交失败, {}, {}'.format(res, match_dict))
+                    # logger.warning(match_dict)
             else:
-                logger.warning('足球赛事接口异常提交失败, {}'.format(res))
-                logger.warning(match_dict)
+                logger.warning('足球赛事接口异常提交失败, {}, {}'.format(res, match_dict))
+                # logger.warning(match_dict)
         else:
             logger.info('足球赛事已存在，不提交')
 
@@ -560,11 +560,11 @@ class Zuqiupipeline(object):
                     logger.info('足球详细赔率提交成功, {}'.format(res))
                     # logger.info(odds_dict)
                 else:
-                    logger.warning('足球相信赔率提交失败, {}'.format(res))
-                    logger.warning(odds_dict)
+                    logger.warning('足球相信赔率提交失败, {}, {}'.format(res, odds_dict))
+                    # logger.warning(odds_dict)
             else:
-                logging.warning('足球详细赔率接口异常, {}'.format(res))
-                logger.warning(odds_dict)
+                logging.warning('足球详细赔率接口异常, {},{}'.format(res, odds_dict))
+                # logger.warning(odds_dict)
         else:
             logger.info('足球详细赔率列表为空')
         reactor.callFromThread(out.callback, item)