姑苏城外一茅屋，万树梅花月满天

0%

eosvoter | 后端介绍

发表于 分类于 ， ， ， ， Valine：

这里介绍 eosvoter 的后端系统。

思维导图如下:

相关的项目如下:

相关的思维导图如下:


技术介绍


  • python 3.7
  • flask

项目介绍


在

中，我们知道，这个项目是 MVC 的设计思想，由于是前后端分离，所以，后端项目只有 MV。

关于 MVC 你可以参考我下面的博文：

这里先介绍一下支撑起项目架构的三个模块

  • main.py
  • models
  • service

这里的 model 指的 项目中 models 文件夹，controll 指的是 service 文件夹。

main.py

这个是项目的主要入口，也是 flask 的启动文件，这里面主要用于请求的转发，不涉及一点业务逻辑代码，作用仅为转发请求。

贴一个代码看

1
2
3
4
5
6
7
8
9
10
@app.route("/eosvoter/v1/user/get_bps", methods=['GET'])
@login_required
def get_bps():
    bp_list = voteService.get_bp_list(current_user.user_name)
    data = {
        "code": Check.success,
        "msg": "success",
        "data": bp_list
    }
    return jsonify(data)

对外暴漏 restful 接口，收到请求后，转发到对应的 service，而不会涉及逻辑代码。

这么做的目的是让代码更加精炼、有序。

service

这个文件夹中，对应的是 controll 层，又或者说服务层。里面的文件是

  • claim.py
  • pool.py
  • …

这些一个个文件，对应的是以相同属性的数据表做的服务。

比如

  • claim.py 对应
    • t_claim_info 表
  • pool.py 对应
    • t_pool_data 表
    • t_pool_info 表

这一层的逻辑是，接受从 main.py 发来的指令，然后调用相关的逻辑代码，通过 models 来对数据库进行增删改查，整个项目的所有逻辑和业务代码都在这个层中。

我以 pool.py 为例

文件会创建一个类，然后类中写各种逻辑代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
from models.pool import Pool as pool_model

class Pool:

    def add_pool_data(self, pool_info):
        p = pool_model()
        for name, info in pool_info.items():
            change = info['change']
            base = info['data']['base']
            data = info['data']['data']
            for d in data:
                time_str = format_time_from_timestamp(int(d['block_time']))
                number = p.get_by_time(d['coin'], time_str)
                if number > 0:
                    continue
                p.add_pool_data(pool_name=name, block_coin=d['coin'], coin_reward=d['block_reward'], theory_reward='0',
                                block_time=time_str, pool_power=base['pool_power'], pool_scale=base['pool_scale'],
                                diff_24h=change['diff_24h'], lucky_3d=change['lucky_3d'])

从上面的代码可以知道，这里面是处理相关的逻辑和业务代码的。

models

这个文件夹相当于 model 层，负责对数据库的增删改查，没有相关的逻辑代码。

里面的文件和 service 的文件形式是一样的，都是以某一类同质的数据表来做为一个整体。

  • account.py
  • claim.py
  • …

以 pool.py 为例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
import db

class Pool:

    def __init__(self):
        self.db = db

    # 对单一的矿池数据操作
    def add_pool_data(self, pool_name: str, block_coin: str, coin_reward: str, theory_reward: str, block_time: str,
                      pool_power: str,
                      pool_scale: str, diff_24h: str, lucky_3d: str):
        sql = "insert into t_pool_data(`pool_name`,`block_coin`,`coin_reward`,`theory_reward`,`block_time`,`pool_power`,`pool_scale`,`diff_24h`,`lucky_3d`) values (%s,%s,%s,%s,%s,%s,%s,%s,%s);"
        return self.db.insert_one(sql, [pool_name, block_coin, coin_reward, theory_reward, block_time, pool_power,
                                        pool_scale, diff_24h, lucky_3d])

可以看出，这个只负责对数据库进行增删改查。

其他

  • 工具方法
  • 日志系统
  • 数据库

工具方法

  • api 文件夹
  • util 文件夹

api 文件夹

里面的文件是

  • eos_api.py

这里面主要是调用外部接口，举一个简单的例子

1
2
3
4
def get_actions_hyperion(account, limit=30):
    url = f"https://eos.hyperion.eosrio.io/v2/history/get_actions?account={account}&skip=0&limit={limit}&sort=desc&transfer.to={account}"
    response = get(url=url)
    return response.json()['actions']

util 文件夹

里面的文件是

  • init.py
  • auth.py
  • times.py
  • …

这里有各种工具方法，比如转化时间、转化数字等。

日志系统

是 logger 文件夹。

里面的文件是

  • log.py

数据库

这个包含两个文件夹

  • db.py 项目根目录下
    • 封装了对数据库的操作，这个可以在上面的 models 中可以看出
  • ddl 文件夹
    • 里面有 schema.sql 库和表的初始化
请我喝杯咖啡吧～