新项目

.idea/codeStyles/Project.xml

+<component name="ProjectCodeStyleConfiguration">
+  <code_scheme name="Project" version="173">
+    <DBN-PSQL>
+      <case-options enabled="false">
+        <option name="KEYWORD_CASE" value="lower" />
+        <option name="FUNCTION_CASE" value="lower" />
+        <option name="PARAMETER_CASE" value="lower" />
+        <option name="DATATYPE_CASE" value="lower" />
+        <option name="OBJECT_CASE" value="preserve" />
+      </case-options>
+      <formatting-settings enabled="false" />
+    </DBN-PSQL>
+    <DBN-SQL>
+      <case-options enabled="false">
+        <option name="KEYWORD_CASE" value="lower" />
+        <option name="FUNCTION_CASE" value="lower" />
+        <option name="PARAMETER_CASE" value="lower" />
+        <option name="DATATYPE_CASE" value="lower" />
+        <option name="OBJECT_CASE" value="preserve" />
+      </case-options>
+      <formatting-settings enabled="false">
+        <option name="STATEMENT_SPACING" value="one_line" />
+        <option name="CLAUSE_CHOP_DOWN" value="chop_down_if_statement_long" />
+        <option name="ITERATION_ELEMENTS_WRAPPING" value="chop_down_if_not_single" />
+      </formatting-settings>
+    </DBN-SQL>
+    <DBN-PSQL>
+      <case-options enabled="false">
+        <option name="KEYWORD_CASE" value="lower" />
+        <option name="FUNCTION_CASE" value="lower" />
+        <option name="PARAMETER_CASE" value="lower" />
+        <option name="DATATYPE_CASE" value="lower" />
+        <option name="OBJECT_CASE" value="preserve" />
+      </case-options>
+      <formatting-settings enabled="false" />
+    </DBN-PSQL>
+    <DBN-SQL>
+      <case-options enabled="false">
+        <option name="KEYWORD_CASE" value="lower" />
+        <option name="FUNCTION_CASE" value="lower" />
+        <option name="PARAMETER_CASE" value="lower" />
+        <option name="DATATYPE_CASE" value="lower" />
+        <option name="OBJECT_CASE" value="preserve" />
+      </case-options>
+      <formatting-settings enabled="false">
+        <option name="STATEMENT_SPACING" value="one_line" />
+        <option name="CLAUSE_CHOP_DOWN" value="chop_down_if_statement_long" />
+        <option name="ITERATION_ELEMENTS_WRAPPING" value="chop_down_if_not_single" />
+      </formatting-settings>
+    </DBN-SQL>
+  </code_scheme>
+</component>
\ No newline at end of file

.idea/dictionaries/lxrent.xml

+<component name="ProjectDictionaryState">
+  <dictionary name="lxrent" />
+</component>
\ No newline at end of file

.idea/encodings.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Encoding">
+    <file url="PROJECT" charset="UTF-8" />
+  </component>
+</project>
\ No newline at end of file

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 2.7 (gaia_env)" project-jdk-type="Python SDK" />
+  <component name="PyCharmProfessionalAdvertiser">
+    <option name="shown" value="true" />
+  </component>
+</project>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/vest.iml" filepath="$PROJECT_DIR$/.idea/vest.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/vest.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+  <component name="TestRunnerService">
+    <option name="PROJECT_TEST_RUNNER" value="Unittests" />
+  </component>
+</module>
\ No newline at end of file

app_conf.xml

+<?xml version="1.0" encoding="utf-8"?>
+<gm_rpcd_config>
+    <info config_name="app" version="1.0"/>
+    <config name="application_name" value="vest"/>
+    <config name="service_list">
+        <element value="vest"/>
+    </config>
+    <config name="initializer_list">
+        <element value="moment.views.relation_search"/>
+    </config>
+    <config name="statuses" value="vest.system:statuses"/>
+
+</gm_rpcd_config>

click/admin.py

+from django.contrib import admin
+
+# Register your models here.

click/apps.py

+from django.apps import AppConfig
+
+
+class SearchConfig(AppConfig):
+    name = 'click'

click/models.py

+from django.db import models
+
+# Create your models here.

click/tests.py

+from django.test import TestCase
+
+# Create your tests here.

click/views/auto_click.py

+# -*- coding: UTF-8 -*-
+import datetime
+import logging
+import traceback
+import random
+import time
+from moment.views.process_time import get_content_time_by_create_time, get_click_follow_time_by_create_time, \
+    get_vest_userid
+from moment.views.process_time import save_data_to_kafka
+
+logger = logging.getLogger(__name__)
+
+
+def auto_click_user(card_info):
+    """
+
+    发帖后2小时：[1-3]个赞
+
+    对所有帖子每天1次轮询：
+
+    3星以下：
+    1天前发的回答：[1-3]个赞
+    2-15天前发的回答：[0-1]个赞
+    15天前或更早发的：每隔6天[0-1]个赞
+    3星以上：
+    1天前发的回答：[6-12]个赞
+    2-15天前发的回答：[0-6]个赞
+    15天前或更早发的回答：每隔5天[0-2]个赞
+
+    3.轮询时间-发布时间超过365天，终止点赞
+
+    被点赞兜底：每个人每天最多收到20个点赞
+    10-23点随机(对于非当天有效）
+    随机马甲（运营给予一批马甲号，只使用这些马甲号）
+    """
+    try:
+
+        if card_info:
+            ###先获取kafka的数据
+            create_time = card_info["create_time"]
+            content_level = card_info["content_level"]
+            card_info["action_type"] = "click"
+
+            # 当满足这些条件的时候 代表已经完成了下发的所有的时间或者还没有下发过时间 需要给予新的时间
+            if ("all_follow_id" in card_info and "all_push_time" in card_info and len(
+                    card_info['all_follow_id']) == 0 and len(card_info['all_push_time']) == 0) or (
+                    "all_follow_id" not in card_info and "all_push_time" not in card_info):
+
+                ###根据创建时间回答等级去获取对应的下发时间
+                get_time = get_click_follow_time_by_create_time(create_time, content_level, action_type="follow")
+                if len(get_time) > 0:
+
+                    ###拿到下发时间后根据下发的时间个数去拿对应个数的马甲账号
+                    userids = get_vest_userid(need_comment_num=len(get_time))
+                    for i in range(0, len(userids)):
+                        card_info["all_follow_id"] = userids
+                        card_info["current_user_id"] = userids[0]
+                        card_info['type'] = "have_get_push_time"
+                        card_info['current_push_time'] = get_time[0]
+                        card_info['all_push_time'] = get_time
+                        card_info["need_pust_num"] = len(userids)
+                        card_info["have_pust_num"] = 0
+                    save_data_to_kafka(card_info)  # 存储数据
+
+                else:
+                    pass
+
+            else:  # 代表还有push好的时间没有下发完成 需要继续使用这些
+
+                logging.info("get--------click--------------card_info:%s" % card_info)
+                current_user_id = card_info["current_user_id"]
+                card_info["all_follow_id"].remove(current_user_id)
+                current_push_time = card_info['current_push_time']
+                card_info['all_push_time'].remove(current_push_time)
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info["current_user_id"] = card_info["all_follow_id"].pop()
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info['current_push_time'] = card_info['all_push_time'].pop()
+
+                card_info["have_pust_num"] = card_info["have_pust_num"] + 1
+                save_data_to_kafka(card_info)  # 存储数据
+                logging.info("get--------click--------------card_info:%s" % card_info)
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())

comment/admin.py

+from django.contrib import admin
+
+# Register your models here.

comment/apps.py

+from django.apps import AppConfig
+
+
+class SearchConfig(AppConfig):
+    name = 'comment'

comment/models.py

+from django.db import models
+
+# Create your models here.

comment/tests.py

+from django.test import TestCase
+
+# Create your tests here.

comment/views/auto_comment.py

+# -*- coding: UTF-8 -*-
+import datetime
+import logging
+import traceback
+import random
+import time
+from moment.views.process_time import get_content_time_by_create_time, get_vest_userid_and_comment, get_vest_userid
+from moment.views.process_time import save_data_to_kafka
+
+logger = logging.getLogger(__name__)
+
+
+def auto_comment_user(card_info):
+    """
+    当天发布之后
+
+    2-4小时内随机，给予[0-1]个评论
+
+    对所有回答每天1次夜里24点轮询：
+
+    1天-6天之间发的的回答：
+    3星以下
+    [0-1]个评论
+    4星以上
+    [2-4]个评论
+
+    6天后，每10天：
+    3星以下
+    [0-1]个评论
+    4星以上
+    [0-2]个评论
+    轮询时间-发布时间超过365天，终止加评论
+
+
+
+    兜底:一天一人最多20条马甲评论，每条马甲评论的间隔时间40分钟-60分种。过24点清掉今天待发送队列。
+
+    评论时间10-23点随机(对于非当天有效）
+    随机马甲（运营给予一批马甲号，只使用这些马甲号）
+    从马甲评论库（excel）里取评论
+    覆盖所有发布回答的作者
+    覆盖所有内容来源：后台创建、app创建
+    """
+    try:
+
+        if card_info:
+            ###先获取kafka的数据
+            create_time = card_info["create_time"]
+            content_level = card_info["content_level"]
+            card_info["action_type"] = "comment"
+
+            tag_names = card_info['tag_names']
+            # 当满足这些条件的时候 代表已经完成了下发的所有的时间或者还没有下发过时间 需要给予新的时间
+            if ("all_follow_id" in card_info and "all_push_time" in card_info and len(
+                    card_info['all_follow_id']) == 0 and len(card_info['all_push_time']) == 0) or (
+                    "all_follow_id" not in card_info and "all_push_time" not in card_info):
+
+                ###根据创建时间回答等级去获取对应的下发时间
+                get_time = get_content_time_by_create_time(create_time, content_level, action_type="follow")
+                if len(get_time) > 0:
+
+                    ###拿到下发时间后根据下发的时间个数去拿对应个数的马甲账号
+                    all_content = get_vest_userid_and_comment(need_comment_num=len(get_time), tag_names=tag_names)
+                    all_userids = get_vest_userid(need_comment_num=len(get_time))
+
+                    for i in range(0, len(all_userids)):
+                        card_info["all_follow_id"] = all_userids
+                        card_info["current_user_id"] = all_userids[0]
+                        card_info['type'] = "have_get_push_time"
+                        card_info['current_push_time'] = get_time[0]
+                        card_info['all_push_time'] = get_time
+                        card_info["need_pust_num"] = len(all_userids)
+                        card_info["have_pust_num"] = 0
+                        card_info['comment_content'] = all_content[i]
+                    save_data_to_kafka(card_info)  # 存储数据
+                else:
+                    pass
+
+            else:  # 代表还有push好的时间没有下发完成 需要继续使用这些
+
+                logging.info("get-------comment---------------card_info:%s" % card_info)
+                current_user_id = card_info["current_user_id"]
+                card_info["all_follow_id"].remove(current_user_id)
+                current_push_time = card_info['current_push_time']
+                card_info['all_push_time'].remove(current_push_time)
+                card_info["have_pust_num"] = card_info["have_pust_num"] + 1
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info["current_user_id"] = card_info["all_follow_id"].pop()
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info['current_push_time'] = card_info['all_push_time'].pop()
+
+                save_data_to_kafka(card_info)  # 存储数据
+                logging.info("get-------comment---------------card_info:%s" % card_info)
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())

follow/admin.py

+from django.contrib import admin
+
+# Register your models here.

follow/apps.py

+from django.apps import AppConfig
+
+
+class SearchConfig(AppConfig):
+    name = 'follow'

follow/models.py

+from django.db import models
+
+# Create your models here.

follow/tests.py

+from django.test import TestCase
+
+# Create your tests here.

follow/views.py

+from django.shortcuts import render
+
+# Create your views here.

follow/views/auto_follow.py

+# -*- coding: UTF-8 -*-
+import datetime
+import logging
+import traceback
+import random
+import time
+from moment.views.process_time import get_content_time_by_create_time, get_click_follow_time_by_create_time, \
+    get_vest_userid
+from moment.views.process_time import save_data_to_kafka
+
+logger = logging.getLogger(__name__)
+
+
+def auto_follow_user(card_info):
+    """
+    灌水功能下发关注
+    发帖后2小时：[1-3]个粉丝
+    对所有回答每天1次轮询：
+    3星以下：
+    1天前发的回答：[1-3]个粉丝
+    2-15天前发的回答：[0-1]个粉丝
+    15天前或更早发的回答：每隔10天[0-2]个粉丝
+    2. 3星以上：
+
+    1天前发的回答：[5-10]个粉丝
+    前2-15天发的回答：[0-5]个粉丝
+    15天前或更早发的回答：每隔10天[0-2]个粉丝
+
+    3.轮询时间-发布时间超过365天，终止加粉
+    加粉兜底：每天每个人最多涨20个马甲粉丝
+
+    10-23点随机(对于非当天有效）
+    随机马甲（运营给予一批马甲号，只使用这些马甲号）
+    :param card_info:
+    :return:
+    """
+    try:
+
+        if card_info:
+            ###先获取kafka的数据
+            create_time = card_info["create_time"]
+            content_level = card_info["content_level"]
+            card_info["action_type"] = "follow"
+
+            # 当满足这些条件的时候 代表已经完成了下发的所有的时间或者还没有下发过时间 需要给予新的时间
+            if ("all_follow_id" in card_info and "all_push_time" in card_info and len(
+                    card_info['all_follow_id']) == 0 and len(card_info['all_push_time']) == 0) or (
+                    "all_follow_id" not in card_info and "all_push_time" not in card_info):
+
+                ###根据创建时间回答等级去获取对应的下发时间
+                get_time = get_click_follow_time_by_create_time(create_time, content_level, action_type="follow")
+                if len(get_time) > 0:
+
+                    ###拿到下发时间后根据下发的时间个数去拿对应个数的马甲账号
+                    userids = get_vest_userid(need_comment_num=len(get_time))
+                    for i in range(0, len(userids)):
+                        card_info["all_follow_id"] = userids
+                        card_info["current_user_id"] = userids[0]
+                        card_info['type'] = "have_get_push_time"
+                        card_info['current_push_time'] = get_time[0]
+                        card_info['all_push_time'] = get_time
+                        card_info["need_pust_num"] = len(userids)
+                        card_info["have_pust_num"] = 0
+                    save_data_to_kafka(card_info)  # 存储数据
+
+                else:
+                    pass
+
+            else:  # 代表还有push好的时间没有下发完成 需要继续使用这些
+                logging.info("get-----follow----card_info:%s" % card_info)
+
+                card_info["have_pust_num"] = card_info["have_pust_num"] + 1
+                current_user_id = card_info["current_user_id"]
+                card_info["all_follow_id"].remove(current_user_id)
+                current_push_time = card_info['current_push_time']
+                card_info['all_push_time'].remove(current_push_time)
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info["current_user_id"] = card_info["all_follow_id"][0]
+
+                if len(card_info["all_follow_id"]) > 0:
+                    card_info['current_push_time'] = card_info['all_push_time'][0]
+
+                save_data_to_kafka(card_info)  # 存储数据
+
+                logging.info("get-----follow----card_info:%s" % card_info)
+
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())

libs/cache.py

+import redis
+from django.conf import settings
+
+redis_client = redis.StrictRedis.from_url(settings.REDIS_URL)
+redis_client2 = redis.StrictRedis.from_url(settings.REDIS_URL2)

libs/error.py

+from gm_rpcd.all import RPCDFaultException
+from gm_types.doris.error import ERROR
+from raven.contrib.django.raven_compat.models import client as _sentry_client
+
+
+def raise_error(error_code, message=None):
+    assert error_code != 0
+    if message is None:
+        message = ERROR.getDesc(error_code)
+    raise RPCDFaultException(code=error_code, message=message)
+
+
+def logging_exception(send_to_sentry=True):
+    try:
+        # send exception info to sentry, fail silently
+        _sentry_client.captureException()
+    except:
+        pass

libs/rpc.py

+from django.conf import settings
+from helios.rpc import create_default_invoker
+
+
+_rpc_invoker = create_default_invoker(debug=settings.DEBUG)
+
+
+def get_rpc_invoker():
+    return _rpc_invoker

manage.py

+#!/usr/bin/env python
+import os
+import sys
+
+if __name__ == "__main__":
+    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "vest.settings")
+
+    from django.core.management import execute_from_command_line
+
+    execute_from_command_line(sys.argv)

moment/admin.py

+from django.contrib import admin
+
+# Register your models here.

moment/apps.py

+from django.apps import AppConfig
+
+
+class SearchConfig(AppConfig):
+    name = 'moment'

moment/models.py

+from django.db import models
+
+# Create your models here.

moment/tests.py

+from django.test import TestCase
+
+# Create your tests here.

moment/views/consum.py

+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import json
+from kafka import KafkaProducer
+from kafka import KafkaConsumer
+from gm_rpcd.all import bind
+import traceback
+from django.conf import settings
+from follow.views.auto_follow import auto_follow_user
+from click.views.auto_click import auto_click_user
+from comment.views.auto_comment import auto_comment_user
+import datetime
+import time
+import logging
+
+
+def kafka_consum(topic_name=None):
+    try:
+        topic_name = settings.KAFKA_TOPIC_NAME if not topic_name else topic_name
+        consumser_obj = KafkaConsumer(topic_name, bootstrap_servers=[settings.KAFKA_BROKER_LIST])
+        logging.info("get consumser_obj:%s" % consumser_obj)
+        while True:
+            msg_dict = consumser_obj.poll(timeout_ms=100)
+            for msg_key in msg_dict:
+                consume_msg = msg_dict[msg_key]
+                for msg in consume_msg:
+                    card_info = json.loads(msg.value)
+                    logging.info("get card_info:%s" % card_info)
+                    # 代表当天数据
+                    current_push_time = card_info['current_push_time']
+                    create_time = card_info['create_time']
+                    action_type = card_info['action_type']
+                    nowtime = datetime.datetime.now()
+                    # nowtime = now.strftime('%Y-%m-%d %H:%M:%S')
+                    push_time_date = datetime.datetime.strptime(current_push_time, '%Y-%m-%d %H:%M:%S')
+
+                    logging.info("get push_time_date:%s" % push_time_date)
+                    logging.info("get push_time_date:%s" % type(push_time_date))
+
+                    logging.info("get nowtime:%s" % nowtime)
+                    logging.info("get nowtime:%s" % type(nowtime))
+
+                    if push_time_date <= nowtime:  # push_time已经到时间了 需要去下发
+                        logging.info("get push_time_date:%s" % push_time_date)
+                        # 判断如果当前的push_time 和当前的创建时间一样  需要给push_time下发真的push时间
+                        if current_push_time == create_time:
+                            auto_follow_user(card_info)
+                            auto_comment_user(card_info)
+                            auto_click_user(card_info)
+
+                        else:
+                            # current_push_time = card_info['current_push_time']
+                            # current_time = datetime.datetime.strptime(current_push_time, '%Y-%m-%d %H:%M:%S')
+                            # now = datetime.datetime.now()
+                            # 需要判断是否真的已经下发完了 如果是时间过了但是没有下发直接下发了
+                            # 当前已下发完 需要判断最新一次的下发时间是否是今天 是的话直接跳过
+                            if card_info['have_pust_num'] == card_info['need_pust_num']:
+                                if nowtime.day - push_time_date.day == 0:  # 是今天的话直接跳过
+                                    pass
+                                else:
+                                    # 再存储起来？
+                                    pass
+                            # 还有一种是下发时间还没有到 之前没有轮询到
+                            else:
+                                if card_info['have_pust_num'] <= card_info['need_pust_num'] and \
+                                        push_time_date < nowtime:
+                                    if action_type == "comment":  # 在这里去调评论的接口
+                                        logging.info("get------------------comment-----------------")
+                                        # 调完接口后需要再次去拿新的push_time的时间
+                                        auto_comment_user(card_info)
+
+                                    elif action_type == "click":  # 在这里去调点赞的接口
+                                        logging.info("get--------------click---------------------")
+
+                                        auto_click_user(card_info)
+
+                                    elif action_type == "follow":  # 在这里去调关注的接口
+                                        logging.info("get----------follow-------------------------")
+
+                                        auto_follow_user(card_info)
+
+                else:  # push_time时间未到 需要等待
+                    logging.info("push_time时间未到========================需要等待")
+                    pass
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())

moment/views/get_keyword.py

+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import jieba
+import jieba.analyse
+
+
+class GetContentKeyWords(object):
+    def __init__(self):
+        self.jeiba = jieba
+        self.tag_list = ["瘦脸针kyc", "双眼皮kyc", "水光针kyc", "玻尿酸kyc", "吸脂kyc", "埋线提升kyc", "鼻综合kyc", "光子嫩肤kyc", "没有想法kyc",
+                         "牙齿kyc", "抗衰紧致kyc", "胸部kyc"]
+        self.star_list = []
+        self.synonym_tag_list = []
+        self.tags = ""
+        self.stars = ""
+        self.synonym_tags = ""
+
+    def add_tag_word(self):
+        jieba = self.jeiba
+
+        if self.tag_list:
+            for word in self.tag_list:
+                jieba.add_word(word)
+
+        if self.star_list:
+            for word in self.star_list:
+                jieba.add_word(word)
+
+        if self.synonym_tag_list:
+            for word in self.synonym_tag_list:
+                jieba.add_word(word)
+
+    def get(self, content):
+        self.add_tag_word()
+        return self.jeiba.cut(content)
+
+    def get_keywords(self, content, k=None):
+        self.add_tag_word()
+        jieba = self.jeiba
+        keywords = jieba.analyse.extract_tags(content, topK=9999, withWeight=True, allowPOS=())
+
+        tags = []
+        stars = []
+        synonym_tags = []
+
+        for item in keywords:
+            if item[0] in self.tag_list:
+                tags.append(str(item[0]))
+
+            if item[0] in self.star_list:
+                stars.append(str(item[0]))
+
+            if item[0] in self.synonym_tag_list:
+                synonym_tags.append(str(item[0]))
+
+        self.tags = ",".join(tags[:k])
+        self.stars = ",".join(stars[:k])
+        self.synonym_tags = ",".join(synonym_tags[:k])
+
+# a = GetContentKeyWords()
+# a.tag_list = ["天安门", "北京"]
+#
+# a.get_keywords("我爱北京天安门，天安门上太阳升",2)
+# print(a.tags)

moment/views/irrigation.py

+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import json
+from kafka import KafkaProducer
+from kafka import KafkaConsumer
+from gm_rpcd.all import bind
+import traceback
+from django.conf import settings
+import datetime
+import time
+import logging
+
+
+@bind('vest/moment/vest_irrigation')
+def vest_irrigation(card_id=0, card_type=None, create_time="", content_level=0, tag_names=[]):
+    try:
+        producer = KafkaProducer(bootstrap_servers=[settings.KAFKA_BROKER_LIST])
+        topic = settings.KAFKA_TOPIC_NAME
+        msg_dict = {
+            "card_id": card_id,
+            "card_type": card_type,
+            "create_time": create_time,
+            "content_level": content_level,
+            "tag_names": tag_names,
+            "type": "get_write_answer_userinfo",
+            "current_push_time": create_time
+        }
+        producer.send(topic, json.dumps(msg_dict).encode())
+        producer.close()
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())

moment/views/vest_ids.txt

+12345
+23456
+24244
+53555
+54647
+655757
+57575
+5747
+4653
+466546
+57745645

requirements.txt

+celery==4.2.1
+Django==1.8
+elasticsearch==6.3.1
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-config.git@v0.1.3
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-logging.git@v0.8.4
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-protocol.git@master
+git+ssh://git@git.wanmeizhensuo.com/gushitong/gm-serializer.git@v0.1.1
+git+ssh://git@git.wanmeizhensuo.com/system/gm-tracer.git@v0.1.2
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-types.git@master
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-upload.git@master
+git+ssh://git@git.wanmeizhensuo.com/system/kafka-python.git@master
+PyMySQL==0.7.10
+python-dateutil==1.5
+python-json-logger==0.1.11
+raven==5.25.0
+redis==2.10.6
+requests==2.2.1
+urllib3==1.24.1
+git+ssh://git@git.wanmeizhensuo.com/backend/helios.git@v0.7.2
+virtualenv==15.1.0
+gevent==1.2.1
+git+ssh://git@git.wanmeizhensuo.com/backend/gm-rpcd.git@v0.2.2
+jieba==0.39
\ No newline at end of file

vest/log_settings.py

+# coding=utf-8
+"""
+__author__ = 'xumingming'
+"""
+
+import os
+import logging
+
+LOG_DIR = '/data/log/vest/app/'
+
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s %(levelname)s %(module)s.%(funcName)s Line:%(lineno)d  %(message)s',
+    filename=os.path.join(LOG_DIR, 'filelog.log'),
+)
+
+LOGGING = {
+    'version': 1,
+    'disable_existing_loggers': False,
+
+    'filters': {
+        'require_debug_true': {
+            '()': 'django.utils.log.RequireDebugTrue',
+        },
+    },
+
+    'formatters': {
+        'verbose': {
+            'format': '%(asctime)s %(levelname)s %(module)s.%(funcName)s Line:%(lineno)d  %(message)s'
+        },
+        'simple': {
+            'format': '%(levelname)s %(message)s'
+        },
+        'profile': {
+            'format': '%(asctime)s %(message)s'
+        },
+        'raw': {
+            'format': '%(message)s'
+        }
+    },
+
+    'handlers': {
+        'console': {
+            'level': 'DEBUG',
+            'class': 'logging.StreamHandler',
+            'formatter': 'simple'
+        },
+
+        # 默认的服务器Log(保存到log/filelog.log中, 通过linux的logrotate来处理日志的分割
+        'default': {
+            'level': 'INFO',
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filename': os.path.join(LOG_DIR, 'filelog.log'),
+            'formatter': 'verbose',
+        },
+
+        # 默认的服务器ERROR log
+        'default_err': {
+            'level': 'ERROR',
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filename': os.path.join(LOG_DIR, 'error_logger.log'),
+            'formatter': 'verbose',
+        },
+        'exception_logger': {
+            'level': 'INFO',
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filename': os.path.join(LOG_DIR, 'exception_logger.log'),
+            'formatter': 'verbose',
+        },
+
+        'tracer_handler': {
+            'level': 'INFO',
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filename': os.path.join(LOG_DIR, 'tracer.log'),
+            'formatter': 'raw'
+        },
+    },
+
+    'loggers': {
+        'django': {
+            'handlers': ['default'],
+            'propagate': True,
+            'level': 'INFO',
+        },
+        'django.request': {
+            'handlers': ['default_err'],
+            'level': 'ERROR',
+            'propagate': False,
+        },
+        'exception_logger': {
+            'handlers': ['exception_logger'],
+            'level': 'INFO',
+            'propagate': False,
+        },
+
+        'gm_tracer.subscribe': {
+            'handlers': ['tracer_handler'],
+            'propagate': False,
+            'level': 'INFO'
+        },
+
+    },
+}

vest/settings.py

+"""
+Django settings for vest project.
+
+Generated by 'django-admin startproject' using Django 1.8.
+
+For more information on this file, see
+https://docs.djangoproject.com/en/1.8/topics/settings/
+
+For the full list of settings and their values, see
+https://docs.djangoproject.com/en/1.8/ref/settings/
+"""
+
+from .log_settings import *
+from .settings_local import *
+
+# Build paths inside the project like this: os.path.join(BASE_DIR, ...)
+import os
+
+BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+
+# Quick-start development settings - unsuitable for production
+# See https://docs.djangoproject.com/en/1.8/howto/deployment/checklist/
+
+# SECURITY WARNING: keep the secret key used in production secret!
+SECRET_KEY = '18i6m2l99g9ev46#)j4d)h!_zn8co-52veo69spj*1&v%x-^n0'
+
+# SECURITY WARNING: don't run with debug turned on in production!
+DEBUG = True
+
+ALLOWED_HOSTS = []
+
+# Application definition
+
+INSTALLED_APPS = (
+    'django.contrib.admin',
+    'django.contrib.auth',
+    'django.contrib.contenttypes',
+    'django.contrib.sessions',
+    'django.contrib.messages',
+    'django.contrib.staticfiles',
+    "click",
+    "moment",
+    'follow',
+    'comment'
+)
+
+MIDDLEWARE_CLASSES = (
+    'django.contrib.sessions.middleware.SessionMiddleware',
+    'django.middleware.common.CommonMiddleware',
+    'django.middleware.csrf.CsrfViewMiddleware',
+    'django.contrib.auth.middleware.AuthenticationMiddleware',
+    'django.contrib.auth.middleware.SessionAuthenticationMiddleware',
+    'django.contrib.messages.middleware.MessageMiddleware',
+    'django.middleware.clickjacking.XFrameOptionsMiddleware',
+    'django.middleware.security.SecurityMiddleware',
+)
+
+# ROOT_URLCONF = 'vest.urls'
+
+TEMPLATES = [
+    {
+        'BACKEND': 'django.template.backends.django.DjangoTemplates',
+        'DIRS': [],
+        'APP_DIRS': True,
+        'OPTIONS': {
+            'context_processors': [
+                'django.template.context_processors.debug',
+                'django.template.context_processors.request',
+                'django.contrib.auth.context_processors.auth',
+                'django.contrib.messages.context_processors.messages',
+            ],
+        },
+    },
+]
+
+WSGI_APPLICATION = 'vest.wsgi.application'
+
+# Database
+# https://docs.djangoproject.com/en/1.8/ref/settings/#databases
+
+DATABASES = {
+    'default': {
+        'ENGINE': 'django.db.backends.sqlite3',
+        'NAME': os.path.join(BASE_DIR, 'db.sqlite3'),
+    }
+}
+
+# Internationalization
+# https://docs.djangoproject.com/en/1.8/topics/i18n/
+
+LANGUAGE_CODE = 'en-us'
+
+TIME_ZONE = 'Asia/Shanghai'
+
+USE_I18N = True
+
+USE_L10N = True
+
+USE_TZ = True
+
+# Static files (CSS, JavaScript, Images)
+# https://docs.djangoproject.com/en/1.8/howto/static-files/
+
+STATIC_URL = '/static/'

vest/settings_local.py

+# coding=utf-8
+from celery import *
+
+from celery.schedules import crontab
+
+KAFKA_TOPIC_NAME = "auto_vest"
+KAFKA_BROKER_LIST = "kafka-service-0.kafka-service-headless.test:9092"
+
+CELERY_BROKER_URL = 'redis://redis.paas-test.env:6379/0'
+REDIS_URL = 'redis://redis.paas-test.env:6379/0'
+REDIS_URL2 = 'redis://redis.paas-test.env:6379/0'
+
+COUNT_LIMIT = 50
+REDIS = {
+    'doctor': {'host': 'redis.paas-test.env', 'port': 6379, 'db': 1, },
+}
+
+# from base
+DATABASES = {
+    'ENGINE': 'django.db.backends.mysql',  # 设置为mysql数据库
+    'NAME': 'zhengxing_test',
+    'USER': 'work',
+    'PASSWORD': 'Gengmei1',
+    'HOST': 'bj-cdb-6slgqwlc.sql.tencentcdb.com',
+    'PORT': '62120',
+    'OPTIONS': {
+        "init_command": "SET foreign_key_checks = 0;",
+        "charset": "utf8mb4",  # 为了支持emoji表情
+    },
+}
+
+GM_KV_HOSTS = [
+    {
+        "host": "redis.paas-test.env",
+        "port": 6379,
+        "db": 11,
+        "password": ""
+    },
+    {
+        "host": "redis.paas-test.env",
+        "port": 6379,
+        "db": 11,
+        "password": ""
+    }
+]

vest/urls.py

+from django.conf.urls import include, url
+from django.contrib import admin
+
+urlpatterns = [
+    # Examples:
+    # url(r'^$', 'vest.views.home', name='home'),
+    # url(r'^blog/', include('blog.urls')),
+
+    url(r'^admin/', include(admin.site.urls)),
+]

vest/wsgi.py

+"""
+WSGI config for vest project.
+
+It exposes the WSGI callable as a module-level variable named ``application``.
+
+For more information on this file, see
+https://docs.djangoproject.com/en/1.8/howto/deployment/wsgi/
+"""
+
+import os
+
+from django.core.wsgi import get_wsgi_application
+
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "vest.settings")
+
+application = get_wsgi_application()