auto_vest

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

moment/views/irrigation.py

@@ -30,7 +30,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
         if flag == True:
             comment_msg_dict = {
                 "card_id": card_id,
-                "card_type": "auto_vest123",
+                "card_type": "auto_vest",
                 "create_time": create_time,
                 "content_level": content_level,
                 "tag_names": tag_names,
@@ -44,7 +44,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": "auto_vest123",
+            "card_type": "auto_vest",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,
@@ -58,7 +58,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": "auto_vest123",
+            "card_type": "auto_vest",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,