card_type

moment/views/consum.py

@@ -81,6 +81,8 @@ def kafka_consum(topic_name=None):
                                             if 'have_comment_number' in card_info and \
                                                     card_info['have_comment_number'] < 20:
                                                 card_info["have_comment_number"] += 1
+                                                is_success = comment(card_info)
+                                                logging.info("当前ID:%s，下发状状态:%s" % (card_info["card_id"], is_success))
                                                 logging.info("get------xiafa------------vestcomment:%s" % card_info)
 
                                             # 调完接口后需要再次去拿新的push_time的时间
@@ -89,6 +91,8 @@ def kafka_consum(topic_name=None):
                                         elif action_type == "click":  # 在这里去调点赞的接口
                                             if 'have_click_number' in card_info and card_info['have_click_number'] < 20:
                                                 card_info["have_click_number"] += 1
+                                                is_success = click(card_info)
+                                                logging.info("当前ID:%s，下发状状态:%s" % (card_info["card_id"], is_success))
                                                 logging.info("get------xiafa------------vestclick:%s" % card_info)
 
                                             auto_click_user(card_info)
@@ -97,8 +101,10 @@ def kafka_consum(topic_name=None):
 
                                             if 'have_follow_number' in card_info and \
                                                     card_info['have_follow_number'] < 20:
-                                                logging.info("get------xiafa------------vestfollow:%s" % card_info)
                                                 card_info["have_follow_number"] += 1
+                                                is_success = follow(card_info)
+                                                logging.info("当前ID:%s，下发状状态:%s" % (card_info["card_id"], is_success))
+                                                logging.info("get------xiafa------------vestfollow:%s" % card_info)
 
                                             auto_follow_user(card_info)