auto_vest

moment/views/consum.py

@@ -34,7 +34,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

@@ -31,7 +31,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,
@@ -45,7 +45,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,
@@ -59,7 +59,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,