selenium_action/web_module/tornado_api.py

from wechat_action.sql_models import DB
from settings import using_config
import tornado.ioloop
import tornado.web
import json
from wechat_action import sql_tools
# TODO:需要添加上supervisor,来维护进程
# TODO:有时间需要对tornado进行改进


db = DB(config=using_config)


# 1.实现本机服务
# 2.实现线上docker-selenium服务

class login(tornado.web.RequestHandler):
    # 0.登录,
    #   1.成功---
    #   2.不超过,返回一个二维码
    def get(self):
        self.write("Hello, world")

    def post(self):
        # 利用ｒｅｑｕｅｓｔ属性
        # 取出客户端提交的ｊｓｏｎ字符串
        jsonbyte = self.request.body
        print('二进制格式ｊｓｏｎ字符串：', jsonbyte)
        jsonstr = jsonbyte.decode('utf8')  # 解码，二进制转为字符串
        print('ｊｓｏｎ字符串：', jsonstr)

        # 从ｊｓｏｎ字符串转换为ｊｓｏｎ对象，然后利用ｊｓｏｎ对象提供的ａｐｉ
        # 从ｊｓｏｎ字符串中取出我想要的内容(解析ｊｓｏｎ字符串)
        jsonobj = json.loads(jsonstr)  # 将字符串转为json对象
        day = jsonobj.get('day')  # 就可以用api取值
        title = jsonobj.get('title')
        print('day: ', day, ', title: ', title)

        self.write('hello post')


class create_ad_plan(tornado.web.RequestHandler):
    # 1.批量创建计划
    # 返回创建计划是否已经开始
    def post(self):
        # 1.
        pass


class create_ad_show(tornado.web.RequestHandler):
    # 1.批量创建落地页
    pass


# TODO:数据库创建一批虚拟数据,供明天测试使用起
# TODO:wechat_info,human_info 这两张表有空时需要进行对应改进
class ad_status(tornado.web.RequestHandler):
    # 1.创建情况
    pass


class ad_human_info(tornado.web.RequestHandler):
    # 1.人群包获取
    def get(self):
        # 0.是否刷新
        # 1.获取userid,以及是否刷新
        user_id = self.get_argument("user_id", None)
        is_refresh = self.get_argument("is_refresh", None)
        if is_refresh:
            # 1.返回二维码链接
            # ----1.查看cookie是否可用
            pass
        else:
            # 1.查看是否在刷新,
            #     在刷新中,
            #       返回正在刷新

            # -------不管上面逻辑让他们多刷新几次
            #     不在刷新
            #       返回对应数据
            # 2.获取userid对应数据
            sql_session = db.DBSession()
            sql_tools.get_human_info(sql_session=sql_session,user_id=user_id)



        pass


class ad_wechat_info():
    # 1.公众号相关信息获取
    def get(self):
        pass


def make_app():
    return tornado.web.Application([
        (r"/create_ad_plan", create_ad_plan),
        (r"/create_ad_show", create_ad_show),
    ], debug=True)


if __name__ == "__main__":
    app = make_app()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()