暂时去掉需要判断offset的接口

click/views/click_fun.py

@@ -37,9 +37,14 @@ def click(card_info):
             try:
                 status = rpc_invoker['qa/irrigation/create_answer_vote'](user_id=card_info['current_user_id'],
                                                                          answer_id=card_info['card_id']).unwrap()
-                logging.info("get_card_info:%s,have_answer_reply:%s" % (card_info, status))
 
-                return True
+                logging.info("get_card_info:%s,create_answer_vote:%s" % (card_info, status))
+                error = status.get('error', 1)
+                if error == 0:
+                    return True
+                else:
+                    send_email_tome(str(card_info) + str(status))
+                    return False
             except:
                 logging_exception()
                 logging.error("catch exception,err_msg:%s" % traceback.format_exc())

comment/views/comment_fun.py

@@ -36,18 +36,22 @@ def comment(card_info):
             logging.info("get action:comment,card_id:%s,redis_data:%s" % (card_info['card_id'], redis_data))
             comment_num = redis_data["comment"]
 
-            ####在这里做判断 一天不能超过12个 如果超过二十个不下发  不超过二十个下发对应的灌水功能
             if comment_num > 12:
                 logging.info("今天已经消费到最大次数了，不能再消费")
             else:
                 try:
                     rpc_invoker = get_rpc_invoker()
                     status = 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()
                     logging.info("get_card_info:%s,have_answer_reply:%s" % (card_info, status))
-
-                    return True
+                    error = status.get('error', 1)
+                    if error == 0:
+                        return True
+                    else:
+                        send_email_tome(str(card_info) + str(status))
+                        return False
                 except:
                     logging.error("catch exception,err_msg:%s" % traceback.format_exc())
                     return False
@@ -71,7 +75,6 @@ def comment(card_info):
             logging.info("get action:comment,card_id:%s,redis_data:%s" % (card_info['card_id'], redis_data))
             comment_num = redis_data["comment"]
 
-            ####在这里做判断 一天不能超过12个 如果超过十二个不下发  不超过 十二个下发对应的灌水功能
             if comment_num > 12:
                 logging.info("今天已经消费到最大次数了，不能再消费")
             else:
@@ -79,9 +82,15 @@ def comment(card_info):
                     rpc_invoker = get_rpc_invoker()
                     status = 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()
+                                                                              content=card_info[
+                                                                                  'comment_content']).unwrap()
                     logging.info("get_card_info:%s,have_answer_reply:%s" % (card_info, status))
-                    return True
+                    error = status.get('error', 1)
+                    if error == 0:
+                        return True
+                    else:
+                        send_email_tome(str(card_info) + str(status))
+                        return False
                 except:
                     logging.error("catch exception,err_msg:%s" % traceback.format_exc())
                     return False
@@ -109,7 +118,6 @@ def comment(card_info):
                 comment = get_vest_userid_and_comment(need_comment_num=1, tag_names=card_info['tag_names'])[0]
                 card_info['comment_content'] = comment
 
-            ####在这里做判断 一天不能超过12个 如果超过二十个不下发  不超过二十个下发对应的灌水功能
             if comment_num > 12:
                 logging.info("今天已经消费到最大次数了，不能再消费")
             else:
@@ -120,7 +128,12 @@ def comment(card_info):
                                                                               content=card_info[
                                                                                   'comment_content']).unwrap()
                     logging.info("get_card_info:%s,have_answer_reply:%s" % (card_info, status))
-                    return True
+                    error = status.get('error', 1)
+                    if error == 0:
+                        return True
+                    else:
+                        send_email_tome(str(card_info) + str(status))
+                        return False
                 except:
                     logging.error("catch exception,err_msg:%s" % traceback.format_exc())
                     return False

follow/views/follow_fun.py

@@ -35,8 +35,14 @@ def follow(card_info):
                 status = rpc_invoker['api/irrigation/user_add_follow'](follow_user_id=card_info['current_user_id'],
                                                                        followed_user_id=card_info[
                                                                            'card_user_id']).unwrap()
+                logging.info("get_card_info:%s,user_add_follow:%s" % (card_info, status))
 
-                logging.info("get_card_info:%s,have_answer_reply:%s" % (card_info, status))
+                error = status.get('error', 1)
+                if error == 0:
+                    return True
+                else:
+                    send_email_tome(str(card_info) + str(status))
+                    return False
 
                 return True
             except: