修改配置

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'] == "answer":
+                    if card_info['card_type'] == "auto_vest":
                         logging.info("+++++++++++++++++++++++++新的数据进来了+++++++++++++++++++++++")
                         logging.info("get card_info:%s" % card_info)
                         # 代表当天数据

moment/views/irrigation.py

@@ -21,7 +21,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
         topic = settings.KAFKA_TOPIC_NAME
         comment_msg_dict = {
             "card_id": card_id,
-            "card_type": card_type,
+            "card_type": "auto_vest",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,
@@ -34,7 +34,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
 
         follow_msg_dict = {
             "card_id": card_id,
-            "card_type": card_type,
+            "card_type": "auto_vest",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,
@@ -48,7 +48,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
 
         click_msg_dict = {
             "card_id": card_id,
-            "card_type": card_type,
+            "card_type": "auto_vest",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,