auto_vest

click/views/click_fun.py

@@ -2,13 +2,35 @@ from libs.rpc import get_rpc_invoker
 import traceback
 from libs.error import logging_exception
 import logging
+from libs.cache import redis_client
+import json
+from moment.views.send_email import send_email_tome
 
 
 def click(card_info):
     try:
+
         rpc_invoker = get_rpc_invoker()
         rpc_invoker['qa/irrigation/create_answer_vote'](user_id=card_info['current_user_id'],
                                                         answer_id=card_info['card_id']).unwrap()
+        key = "auto_vest_one_user_action:" + card_info['card_id']
+        redis_data = redis_client.get(key)
+        if redis_data:
+            redis_data = json.loads(redis_data)
+            click_num = int(redis_data.get("click")) + 1
+            redis_data['click'] = click_num
+            redis_client.set(key, json.dumps(redis_data))
+        else:
+            redis_data = {"click": 1, "follow": 0, "comment": 0}
+            redis_client.set(key, json.dumps(redis_data))
+        redis_client.expire(key, time=24 * 60 * 60)
+
+        logging.info("get redis_data:%s" % redis_data)
+
+        values = list(redis_data.values())
+        s = [True for i in values if i > 0]
+        if len(s) > 0:
+            send_email_tome(redis_data)
 
         return True
     except:

comment/views/comment_fun.py

@@ -2,7 +2,9 @@ from libs.rpc import get_rpc_invoker
 import traceback
 from libs.error import logging_exception
 import logging
-
+from libs.cache import redis_client
+import json
+from moment.views.send_email import send_email_tome
 
 def comment(card_info):
     try:
@@ -10,6 +12,27 @@ def comment(card_info):
         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()
+
+        ####
+        key = "auto_vest_one_user_action:" + card_info['card_id']
+        redis_data = redis_client.get(key)
+        if redis_data:
+            redis_data = json.loads(redis_data)
+            click_num = int(redis_data.get("comment")) + 1
+            redis_data['comment'] = click_num
+            redis_client.set(key, json.dumps(redis_data))
+        else:
+            redis_data = {"click": 1, "follow": 0, "comment": 0}
+            redis_client.set(key, json.dumps(redis_data))
+        redis_client.expire(key, time=24 * 60 * 60)
+
+        logging.info("get redis_data:%s" % redis_data)
+
+        values = list(redis_data.values())
+        s = [True for i in values if i > 0]
+        if len(s) > 0:
+            send_email_tome(redis_data)
+
         return True
     except:
         logging_exception()

follow/views/follow_fun.py

@@ -2,6 +2,9 @@ from libs.rpc import get_rpc_invoker
 import traceback
 from libs.error import logging_exception
 import logging
+from libs.cache import redis_client
+import json
+from moment.views.send_email import send_email_tome
 
 
 def follow(card_info):
@@ -10,6 +13,24 @@ def follow(card_info):
         rpc_invoker['api/irrigation/user_add_follow'](follow_user_id=card_info['current_user_id'],
                                                       followed_user_id=card_info['card_user_id']).unwrap()
 
+        key = "auto_vest_one_user_action:" + card_info['card_id']
+        redis_data = redis_client.get(key)
+        if redis_data:
+            redis_data = json.loads(redis_data)
+            click_num = int(redis_data.get("follow")) + 1
+            redis_data['follow'] = click_num
+            redis_client.set(key, json.dumps(redis_data))
+        else:
+            redis_data = {"click": 1, "follow": 0, "comment": 0}
+            redis_client.set(key, json.dumps(redis_data))
+        redis_client.expire(key, time=24 * 60 * 60)
+
+        logging.info("get redis_data:%s" % redis_data)
+        values = list(redis_data.values())
+        s = [True for i in values if i > 0]
+        if len(s) > 0:
+            send_email_tome(redis_data)
+
         return True
     except:
         logging_exception()

moment/views/send_email.py

+import datetime
+import traceback
+import logging
+import smtplib
+from email.mime.text import MIMEText
+from email.utils import formataddr
+from django.conf import settings
+
+my_sender = 'lixiaofang@igengmei.com'
+my_pass = 'tg5AVKBB8jLQGBET'
+my_user6 = "lixiaofang@igengmei.com"
+
+
+def send_email_tome(stat_data):
+    try:
+        msg = MIMEText(stat_data, 'plain', 'utf-8')
+        msg['From'] = formataddr(["李小芳", my_sender])
+        msg["To"] = formataddr(["李小芳", my_user6])
+        msg['Subject'] = str(datetime.date.today()) + "马甲超过次数啦，赶紧看一下" + str(settings.SERVICE_NAME)
+        server = smtplib.SMTP_SSL("smtp.exmail.qq.com", 465)
+        server.login(my_sender, my_pass)
+        server.sendmail(my_sender, [my_user6], msg.as_string())
+        server.quit()
+    except Exception:
+        logging.error("catch exception,main:%s" % traceback.format_exc())