card_type

click/views/click_fun.py

@@ -7,9 +7,11 @@ import logging
 def click(card_info):
     try:
         rpc_invoker = get_rpc_invoker()
-        data = rpc_invoker['qa/irrigation/create_answer_vote'](user_id=card_info['current_user_id'],
-                                                               answer_id=card_info['card_id']).unwrap()
+        rpc_invoker['qa/irrigation/create_answer_vote'](user_id=card_info['current_user_id'],
+                                                        answer_id=card_info['card_id']).unwrap()
 
+        return True
     except:
         logging_exception()
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+        return False

comment/views/comment_fun.py

@@ -8,9 +8,10 @@ def comment(card_info):
     try:
         rpc_invoker = get_rpc_invoker()
         rpc_invoker['qa/irrigation/create_answer_reply'](user_id=card_info['current_user_id'],
-                                                                 answer_id=card_info['card_id'],
-                                                                 content=card_info['comment_content']).unwrap()
-
+                                                         answer_id=card_info['card_id'],
+                                                         content=card_info['comment_content']).unwrap()
+        return True
     except:
         logging_exception()
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+        return False

follow/views/follow_fun.py

@@ -10,7 +10,8 @@ def follow(card_info):
         rpc_invoker['api/irrigation/user_add_follow'](follow_user_id=card_info['current_user_id'],
                                                       followed_user_id=card_info['card_user_id']).unwrap()
 
-
+        return True
     except:
         logging_exception()
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+        return False

moment/views/consum.py

@@ -32,7 +32,7 @@ def kafka_consum(topic_name=None):
                 consume_msg = msg_dict[msg_key]
                 for msg in consume_msg:
                     card_info = json.loads(msg.value)
-                    if card_info['card_type'] == "tractate777":
+                    if card_info['card_type'] == "answer":
                         logging.info("+++++++++++++++++++++++++新的数据进来了+++++++++++++++++++++++")
                         logging.info("get card_info:%s" % card_info)
                         # 代表当天数据