Odoo | Module | 统计系统周期使用人数/当前在线人数

文内材料

GITHUB地址

前言介绍

Odoo作为开源ERP系统的No.01,近年愈发的得到国内很多公司的关注。

虽然它的定位是中小型企业的ERP管理系统，但是在几年的Odoo开发实施过程中，有不足50人的小型企业，也有上万人的中大型企业。功能快速落地和高度个性化扩展是它的核心特性，使用其他框架开发一个完整的页面可能需要1-2天，但在Odoo可能远超你的预期，在同等页面且不做翻译的前提下，成熟的Odoo开发工程师只需要＜0.5天的时间即可完成界面的主体开发（不包含各类赋值、处理逻辑）。

所以如果有ERP需求但是不想花费太多License费用的用户或者组织可以了解了解：Odoo

需求描述

返回正题，我们经常看见政府门户类网站或者一些访问量很大的公共网站，都会有一个当前在线人数的功能。
回到Odoo，原生并没有提供这样的数据统计方式或者功能，但是不要担心，毕竟Odoo是一个扩展十分方便的框架，我们可以通过现有的一些功能进行集成。

对于Odoo来说，有三种情况：

初次登录
Session未过期，通过历史URL进入系统（无需登录）
网页打开但长时间未处理

源码阅读

初次登录、Session未过期访问
对于登录和已登录状态访问来说，如果验证成功会重定向回/web的route进行处理，并且最终会进入try内容，如果不发生错误，那么应该返回的是正常的网页内容+返回状态码200。

@http.route('/web', type='http', auth="none")
def web_client(self, s_action=None, **kw):
    ensure_db()
    if not request.session.uid:
        return werkzeug.utils.redirect('/web/login', 303)
    if kw.get('redirect'):
        return werkzeug.utils.redirect(kw.get('redirect'), 303)

    request.uid = request.session.uid
    try:
        context = request.env['ir.http'].webclient_rendering_context()
        response = request.render('web.webclient_bootstrap', qcontext=context)
        response.headers['X-Frame-Options'] = 'DENY'
        return response
    except AccessError:
        return werkzeug.utils.redirect('/web/login?error=access')

网页打开但长时间未处理
初次登录、已登录访问可以通过web_client的扩展进行用户信息记录，但是如何检测用户还在使用网页，而不是使用完就关闭页面，也就是如何检测用户的在线情况：Longpolling
我们可以通过新创建一个Module继承mail模块，以激活longpolling的定时轮询功能，轮询功能将定期的与服务器进行信息交互（交互方法如下），我们后续可以对其进行扩展：

@route('/longpolling/poll', type="json", auth="public")
def poll(self, channels, last, options=None):
    if options is None:
        options = {}
    if not dispatch:
        raise Exception("bus.Bus unavailable")
    if [c for c in channels if not isinstance(c, pycompat.string_types)]:
        raise Exception("bus.Bus only string channels are allowed.")
    if request.registry.in_test_mode():
        raise exceptions.UserError(_("bus.Bus not available in test mode"))
    return self._poll(request.db, channels, last, options)

在这里插入图片描述

集成操作

操作内容
1. 创建新模块，模块继承mail
2. 集成登录controller、poll
3. 提供用户访问信息记录表，必要时提供界面显示

创建新模块，继承mail

集成登录controller、poll

# -*- coding: utf-8 -*-

import odoo
from odoo import http
from odoo.http import request
from odoo import exceptions, _
from odoo.http import content_disposition, dispatch_rpc, request, \
    serialize_exception as _serialize_exception, route, Response
from odoo.addons.bus.controllers.main import BusController
from odoo.addons.web.controllers.main import Home


class BusControllerInherit(BusController):
    # 存活检测 longpolling
    @route()
    def poll(self, channels, last, options=None):
        self.collection_current_users()
        res = super(BusControllerInherit, self).poll(channels, last, options)
        return res
    @staticmethod
    def collection_current_users():
        request_ip = request.httprequest.remote_addr
        request_db = request.httprequest.session.db
        request_user = request.httprequest.session.uid
        request_login = request.httprequest.session.login

        try:
            conn = odoo.sql_db.db_connect(request_db)
            with conn.cursor() as cr:
                sql = """
                    insert into collection_user_info(request_ip, request_db, request_user, request_login, fast_login_time, latest_login_time)
                    values (%s, %s, %s, %s, now(), now())
                    on conflict (request_ip, request_db, request_user, request_login) do update set latest_login_time = now();
                """
                cr.execute(sql, (request_ip, request_db, request_user, request_login))
        except Exception as e:
            raise e

class HomeInherit(Home):
    # 记录登录或者session存在时自动登录的情况
    @http.route()
    def web_client(self, s_action=None, **kw):
        res = super(HomeInherit, self).web_client(s_action, **kw)
        if isinstance(res, Response) and res.status_code == 200:
            BusControllerInherit.collection_current_users()
        return res