修改判断方式

comment/views/comment_fun.py

@@ -98,6 +98,29 @@ def comment(card_info):
                     return False
 
         else:
+
+            ###判断一下如果评论为空就重新拿一个
+            if not card_info['comment_content']:
+                comment = get_vest_userid_and_comment(need_comment_num=1, tag_names=card_info['tag_names'])[0]
+                card_info['comment_content'] = comment
+
+            ##在这里加一个判断  如果当前的评论的user_id和评论内容已经在这个评论下了就不再下发给同一个回答ID
+            else:
+                key = 'have_reply_answer_comment:' + str(card_info['card_id'])
+                redis_data = redis_client.hget(key, card_info['current_user_id'])
+                if redis_data:
+                    datas = json.loads(redis_data, encoding="utf-8")
+                    if card_info['comment_content'] in datas:
+                        logging.info("当前评论和当前的用户已经存在了")
+                        return True
+
+                    else:
+                        datas.append(card_info['comment_content'])
+                        redis_client.hset(key, card_info['current_user_id'], json.dumps(datas))
+                else:
+                    conent = [card_info['comment_content']]
+                    redis_client.hset(key, card_info['current_user_id'], json.dumps(conent))
+
             ####当天下发的次数存起来，每次下发判断已经下发了多少个 如果当前下发相等不再下发
             today = datetime.datetime.now()
             str_today = str(today.year) + str(today.month) + str(today.day)
@@ -123,27 +146,6 @@ def comment(card_info):
 
             logging.info("get action:comment,card_id:%s,redis_data:%s" % (card_info['card_id'], redis_data))
 
-            ###判断一下如果评论为空就重新拿一个
-            if not card_info['comment_content']:
-                comment = get_vest_userid_and_comment(need_comment_num=1, tag_names=card_info['tag_names'])[0]
-                card_info['comment_content'] = comment
-
-            ##在这里加一个判断  如果当前的评论的user_id和评论内容已经在这个评论下了就不再下发给同一个回答ID
-            else:
-                key = 'have_reply_answer_comment:' + str(card_info['card_id'])
-                redis_data = redis_client.hget(key, card_info['current_user_id'])
-                if redis_data:
-                    datas = json.loads(redis_data, encoding="utf-8")
-                    if card_info['comment_content'] in datas:
-                        logging.info("当前评论和当前的用户已经存在了")
-                        pass
-                    else:
-                        datas.append(card_info['comment_content'])
-                        redis_client.hset(key, card_info['current_user_id'], json.dumps(datas))
-                else:
-                    conent = [card_info['comment_content']]
-                    redis_client.hset(key, card_info['current_user_id'], json.dumps(conent))
-
             rpc_invoker = get_rpc_invoker()
 
             try: