Odoo Connects Everything | 欧度连接一切

odoo res model document multi download

odoo表单相关的附件文档如果过多，逐个下载到本地也是一种负担，比较好的方式是提供一种打包下载的可选功能，既可以提高操作效率也可以减少网络下载流量

'''
  author: i@renjie.me
'''
class Binary(http.Controller):
    @http.route('/web/binary/download_attachment', type='http', auth='user')
    def download_attachment(self, model, id):
        attachment_model = request.env['ir.attachment']
        attachment_ids = attachment_model.search([('res_model', '=', model), ('res_id', '=', id)])
        file_dict = {}
        for attachment_id in attachment_ids:
            file_store = attachment_id.store_fname
            #文件附件
            if file_store:
                file_name = attachment_id.name
                file_path = attachment_id._full_path(file_store)
                file_dict["%s:%s" % (file_store, file_name)] = dict(path=file_path, name=file_name)
        _logger.info("download attachment ready : %s" % file_dict)
        #压缩包名
        record_value = request.env[model].search_read(domain=[('id', '=', id)], fields=['name'])
        zip_filename = "attachment"
        if len(record_value) == 1:
            record_name = record_value[0].get("name", "")
            if record_name:
                zip_filename = record_name
        zip_filename = "%s.zip" % zip_filename
        #内存压缩
        strIO = StringIO.StringIO()
        zip_file = zipfile.ZipFile(strIO, "w", zipfile.ZIP_DEFLATED)
        for file_info in file_dict.itervalues():
            zip_file.write(file_info["path"], file_info["name"])
        zip_file.close()
        _logger.info("download attachment pack : %s(%s)" % (zip_filename, strIO.len))
        #二进制
        return request.make_response(strIO.getvalue(), 
            headers=[('Content-Type', 'application/x-zip-compressed'), ('Content-Disposition', content_disposition(zip_filename))])

'''

author: i@renjie.me

'''

class Binary(http.Controller):

@http.route('/web/binary/download_attachment', type='http', auth='user')

def download_attachment(self, model, id):

attachment_model = request.env['ir.attachment']

attachment_ids = attachment_model.search([('res_model', '=', model), ('res_id', '=', id)])

file_dict = {}

for attachment_id in attachment_ids:

file_store = attachment_id.store_fname

#文件附件

if file_store:

file_name = attachment_id.name

file_path = attachment_id._full_path(file_store)

file_dict["%s:%s" % (file_store, file_name)] = dict(path=file_path, name=file_name)

_logger.info("download attachment ready : %s" % file_dict)

#压缩包名

record_value = request.env[model].search_read(domain=[('id', '=', id)], fields=['name'])

zip_filename = "attachment"

if len(record_value) == 1:

record_name = record_value[0].get("name", "")

if record_name:

zip_filename = record_name

zip_filename = "%s.zip" % zip_filename

#内存压缩

strIO = StringIO.StringIO()

zip_file = zipfile.ZipFile(strIO, "w", zipfile.ZIP_DEFLATED)

for file_info in file_dict.itervalues():

zip_file.write(file_info["path"], file_info["name"])

zip_file.close()

_logger.info("download attachment pack : %s(%s)" % (zip_filename, strIO.len))

#二进制

return request.make_response(strIO.getvalue(),

headers=[('Content-Type', 'application/x-zip-compressed'), ('Content-Disposition', content_disposition(zip_filename))])

打包下载路径举例：
http://renjie.me/web/binary/download_attachment?model=project.task&id=1983

mongodb主主同步在线迁移

默认配置路径/etc/mongod.conf

原服务需要开启master和noauth
master = true
#auth = true
#noauth = true

新服务需要开启master和slave
#author = renjie
master = true
slave = true
#原服务IP和端口
source = 20.10.06.23:27017

重启原服务后再开启新服务即可自动开始全量同步
期间原服务还有数据增删改操作也会一并同步过来
直到所有相关调用都切换为新服务之后，即可关闭slave设置并重启就可安排原服务下线了

odoo views client reload action

odoo原生常用的reload动作，是整个框架的刷新，源码如下：

//  * Client action to reload the whole interface.
//  * If params.menu_id, it opens the given menu entry.
//  * If params.wait, reload will wait the openerp server to be reachable before reloading
 
function Reload(parent, action) {
    var params = action.params || {};
    var menu_id = params.menu_id || false;
    var l = window.location;

    var sobj = $.deparam(l.search.substr(1));
    if (params.url_search) {
        sobj = _.extend(sobj, params.url_search);
    }
    var search = '?' + $.param(sobj);

    var hash = l.hash;
    if (menu_id) {
        hash = "#menu_id=" + menu_id;
    }
    var url = l.protocol + "//" + l.host + l.pathname + search + hash;

    redirect(url, params.wait);
}

core.action_registry.add("reload", Reload);

// * Client action to reload the whole interface.

// * If params.menu_id, it opens the given menu entry.

// * If params.wait, reload will wait the openerp server to be reachable before reloading

function Reload(parent, action) {

var params = action.params || {};

var menu_id = params.menu_id || false;

var l = window.location;

var sobj = $.deparam(l.search.substr(1));

if (params.url_search) {

sobj = _.extend(sobj, params.url_search);

}

var search = '?' + $.param(sobj);

var hash = l.hash;

if (menu_id) {

hash = "#menu_id=" + menu_id;

}

var url = l.protocol + "//" + l.host + l.pathname + search + hash;

redirect(url, params.wait);

}

core.action_registry.add("reload", Reload);

还有一个reload_context动作，整体刷新前会先刷新session上下文是否正常，源码如下：

/**
 * Client action to refresh the session context (making sure
 * HTTP requests will have the right one) then reload the
 * whole interface.
 */
function ReloadContext (parent, action) {
    // side-effect of get_session_info is to refresh the session context
    session.rpc("/web/session/get_session_info", {}).then(function() {
        Reload(parent, action);
    });
}
core.action_registry.add("reload_context", ReloadContext);

/**

* Client action to refresh the session context (making sure

* HTTP requests will have the right one) then reload the

* whole interface.

function ReloadContext (parent, action) {

// side-effect of get_session_info is to refresh the session context

session.rpc("/web/session/get_session_info", {}).then(function() {

Reload(parent, action);

});

}

core.action_registry.add("reload_context", ReloadContext);

现在需要对一些轻量级的通用场景进行视图层级的数据重载刷新支持，以提高用户体验的舒适度，核心代码如下：

/**
 * author: i@renjie.me
 */
function ReloadView(parent, action) {
    var inner_widget = parent.inner_widget;
    var active_view = inner_widget.active_view;
    var controller = active_view.controller;
    controller.reload();
}
core.action_registry.add("reload_view", ReloadView);

/**

* author: i@renjie.me

function ReloadView(parent, action) {

var inner_widget = parent.inner_widget;

var active_view = inner_widget.active_view;

var controller = active_view.controller;

controller.reload();

}

core.action_registry.add("reload_view", ReloadView);

之后就可以在odoo任何层级应用代码里跟调用reload和reload_context一样快捷方便的使用reload_view动作

odoo search view default show filters advanced menu

odoo搜索视图默认是隐藏高级搜索菜单栏，虽然可以打开记住状态，但换台电脑或浏览器默认又是关闭，这就需要改变其缺省机制，源码如下：

var SearchView = require('web.SearchView');
SearchView.include({
    init: function () {
        var self = this;
        self._super.apply(self, arguments);
        self.visible_filters = (localStorage.visible_search_menu !== 'false');
    }
});

var SearchView = require('web.SearchView');

SearchView.include({

init: function () {

var self = this;

self._super.apply(self, arguments);

self.visible_filters = (localStorage.visible_search_menu !== 'false');

}

});

odoo ldap plus admin mode local and remote password

双份密码
ODOO配置LDAP模式后，同一个用户有本地密码和LDAP密码，可相同也可不同，两个密码只要任意一个通过验证都可以登录系统

本地密码
本地密码修改需要先验证旧密码是否正确，根据上条定律任意一个本地或远程原密码通过验证即可更新本地新密码

远程密码
远程密码可以做为超级密码来不断重置本地密码

管理模式
配置新增ldap_binddn_admin布尔属性用于确认是否启用LDAP binddn管理员模式，即授权SUPERUSER直接修改用户LDAP远程密码

改密区别

默认普通模式下三种情况：

1、本地和LDAP密码相同，本地和LDAP都更新为新密码
2、本地和LDAP密码不同，本地旧密码通过验证，直接更新本地新密码，但LDAP无法通过验证同步修改
3、本地和LDAP密码不同，LDAP旧密码通过验证，直接更新本地与LDAP新密码

开启Admin管理模式统一：
1、本地密码和LDAP密码只要通过一个旧密码验证就可以同步双写统一为新的密码

python decompress http response gzip and deflate Content-Encoding

deflate与gzip解压的方法几乎相同，源码如下：

import zlib
import urllib2

def get_url_content(url):
    headers = {
        'Accept-Encoding': 'gzip, deflate',
    }
    response = urllib2.urlopen(urllib2.Request(url, headers=headers))
    content = response.read()
    content_encode = response.info().get('Content-Encoding')
    if content_encode == 'gzip':
        content = zlib.decompress(content, zlib.MAX_WBITS|16)
    elif content_encode == 'deflate':
        content = zlib.decompress(content, -zlib.MAX_WBITS)
    return content

import zlib

import urllib2

def get_url_content(url):

headers = {

'Accept-Encoding': 'gzip, deflate',

}

response = urllib2.urlopen(urllib2.Request(url, headers=headers))

content = response.read()

content_encode = response.info().get('Content-Encoding')

if content_encode == 'gzip':

content = zlib.decompress(content, zlib.MAX_WBITS|16)

elif content_encode == 'deflate':

content = zlib.decompress(content, -zlib.MAX_WBITS)

return content

odoo tree view pagination disable unlimited

odoo列表视图分页默认80条记录，但可以点击切换选择200、500、2000、无限制，相关源码如下：

/**
 * Render the pager according to the ListView.pager template and add listeners on it.
 * Set this.$pager with the produced jQuery element
 * @param {jQuery} [$node] a jQuery node where the rendered pager should be inserted
 * $node may be undefined, in which case the ListView inserts the pager into this.options.$pager
 * or into a div of its template
 */
render_pager: function($node) {
    if (!this.$pager && this.options.pager) {
        var self =  this;

        this.$pager = $(QWeb.render("ListView.pager", {'widget': self}));
        this.$pager
            .on('click', 'a[data-pager-action]', function () {
                var $this = $(this);
                var max_page_index = Math.ceil(self.dataset.size() / self._limit) - 1;
                switch ($this.data('pager-action')) {
                    case 'first':
                        self.page = 0;
                        break;
                    case 'last':
                        self.page = max_page_index;
                        break;
                    case 'next':
                        self.page += 1;
                        break;
                    case 'previous':
                        self.page -= 1;
                        break;
                }
                if (self.page < 0) {
                    self.page = max_page_index;
                } else if (self.page > max_page_index) {
                    self.page = 0;
                }
                self.reload_content();
            }).find('.oe_list_pager_state')
                .click(function (e) {
                    e.stopPropagation();
                    var $this = $(this);

                    var $select = $('<select>')
                        .appendTo($this.empty())
                        .click(function (e) {e.stopPropagation();})
                        .append('<option value="80">80</option>' +
                                '<option value="200">200</option>' +
                                '<option value="500">500</option>' +
                                '<option value="2000">2000</option>' +
                                '<option value="NaN">' + _t("Unlimited") + '</option>')
                        .change(function () {
                            var val = parseInt($select.val(), 10);
                            self._limit = (isNaN(val) ? null : val);
                            self.page = 0;
                            self.reload_content();
                        }).blur(function() {
                            $(this).trigger('change');
                        })
                        .val(self._limit || 'NaN');
                });
        this.configure_pager(this.dataset);

        $node = $node || this.options.$pager;
        if ($node) {
            this.$pager.appendTo($node);
        } else {
            this.$('.oe_list_pager').replaceWith(this.$pager);
        }
    }
}

/**

* Render the pager according to the ListView.pager template and add listeners on it.

* Set this.$pager with the produced jQuery element

* @param {jQuery} [$node] a jQuery node where the rendered pager should be inserted

* $node may be undefined, in which case the ListView inserts the pager into this.options.$pager

* or into a div of its template

render_pager: function($node) {

if (!this.$pager && this.options.pager) {

var self = this;

this.$pager = $(QWeb.render("ListView.pager", {'widget': self}));

this.$pager

.on('click', 'a[data-pager-action]', function () {

var $this = $(this);

var max_page_index = Math.ceil(self.dataset.size() / self._limit) - 1;

switch ($this.data('pager-action')) {

case 'first':

self.page = 0;

break;

case 'last':

self.page = max_page_index;

break;

case 'next':

self.page += 1;

break;

case 'previous':

self.page -= 1;

break;

}

if (self.page < 0) {

self.page = max_page_index;

} else if (self.page > max_page_index) {

self.page = 0;

}

self.reload_content();

}).find('.oe_list_pager_state')

.click(function (e) {

e.stopPropagation();

var $this = $(this);

var $select = $('<select>')

.appendTo($this.empty())

.click(function (e) {e.stopPropagation();})

.append('<option value="80">80</option>' +

'<option value="200">200</option>' +

'<option value="500">500</option>' +

'<option value="2000">2000</option>' +

'<option value="NaN">' + _t("Unlimited") + '</option>')

.change(function () {

var val = parseInt($select.val(), 10);

self._limit = (isNaN(val) ? null : val);

self.page = 0;

self.reload_content();

}).blur(function() {

$(this).trigger('change');

})

.val(self._limit || 'NaN');

});

this.configure_pager(this.dataset);

$node = $node || this.options.$pager;

if ($node) {

this.$pager.appendTo($node);

} else {

this.$('.oe_list_pager').replaceWith(this.$pager);

}

如果系统运行许久积累了大量数据，特别是互联网海量应用，这个无限制就造成了一个性能上的隐患

var ListView = require('web.ListView');
ListView.include({
    render_pager: function ($node) {
        var self = this;
        self._super.apply(self, arguments);
        if (self.$pager && self.options.pager) {
            self.$pager.find('.oe_list_pager_state').click(function(e){
                e.stopPropagation();
                $(this).find("select").children("option:last").remove();
            });
        }
    }
});

var ListView = require('web.ListView');

ListView.include({

render_pager: function ($node) {

var self = this;

self._super.apply(self, arguments);

if (self.$pager && self.options.pager) {

self.$pager.find('.oe_list_pager_state').click(function(e){

e.stopPropagation();

$(this).find("select").children("option:last").remove();

});

}

});

这里通过继承渲染分页方法，在点击分页信息动态生成记录条数选择的事件上优雅的移除掉最后一个无限制选项

odoo pivot graph view group by date format and order by date desc

分组日期格式自定义

@api.model
def _read_group_process_groupby(self, gb, query):
    #自定义格式
    display_formats = {
        # Careful with week/year formats:
        #  - yyyy (lower) must always be used, *except* for week+year formats
        #  - YYYY (upper) must always be used for week+year format
        #         e.g. 2006-01-01 is W52 2005 in some locales (de_DE),
        #                         and W1 2006 for others
        #
        # Mixing both formats, e.g. 'MMM YYYY' would yield wrong results,
        # such as 2006-01-01 being formatted as "January 2005" in some locales.
        # Cfr: http://babel.pocoo.org/docs/dates/#date-fields
        'day': 'yyyy-MM-dd', # yyyy = normal year
        'week': "yyyy-w",  # w YYYY = ISO week-year
        'month': 'yyyy-MM',
        'quarter': 'yyyy-QQ',
        'year': 'yyyy',
    }
    annotate = super(Model, self)._read_group_process_groupby(gb=gb, query=query)
    if annotate.get('display_format'):
        gb = annotate.get('groupby','')
        split = gb.split(':')
        #默认月
        gb_function = split[1] if len(split) == 2 else 'month'
        #覆盖超类默认格式
        annotate["display_format"] = display_formats.get(gb_function,"")
    return annotate

@api.model

def _read_group_process_groupby(self, gb, query):

#自定义格式

display_formats = {

# Careful with week/year formats:

# - yyyy (lower) must always be used, *except* for week+year formats

# - YYYY (upper) must always be used for week+year format

# e.g. 2006-01-01 is W52 2005 in some locales (de_DE),

# and W1 2006 for others

# Mixing both formats, e.g. 'MMM YYYY' would yield wrong results,

# such as 2006-01-01 being formatted as "January 2005" in some locales.

# Cfr: http://babel.pocoo.org/docs/dates/#date-fields

'day': 'yyyy-MM-dd', # yyyy = normal year

'week': "yyyy-w", # w YYYY = ISO week-year

'month': 'yyyy-MM',

'quarter': 'yyyy-QQ',

'year': 'yyyy',

}

annotate = super(Model, self)._read_group_process_groupby(gb=gb, query=query)

if annotate.get('display_format'):

gb = annotate.get('groupby','')

split = gb.split(':')

#默认月

gb_function = split[1] if len(split) == 2 else 'month'

#覆盖超类默认格式

annotate["display_format"] = display_formats.get(gb_function,"")

return annotate

排序日期默认倒序

@api.model
def read_group(self, domain, fields, groupby, offset=0, limit=None, context=None, orderby=False, lazy=True):
    if not orderby and groupby and len(groupby) == 1:
        first_group_field = groupby[0]
        #日期分组
        if len(first_group_field.split(":")) == 2:
            #默认倒序
            orderby = "%s desc" % first_group_field
    return super(Model, self).read_group(domain=domain, fields=fields, groupby=groupby, offset=offset, limit=limit, context=context, orderby=orderby, lazy=lazy)

@api.model

def read_group(self, domain, fields, groupby, offset=0, limit=None, context=None, orderby=False, lazy=True):

if not orderby and groupby and len(groupby) == 1:

first_group_field = groupby[0]

#日期分组

if len(first_group_field.split(":")) == 2:

#默认倒序

orderby = "%s desc" % first_group_field

return super(Model, self).read_group(domain=domain, fields=fields, groupby=groupby, offset=offset, limit=limit, context=context, orderby=orderby, lazy=lazy)

odoo china baidu maps api

odoo原生内置google maps，导致中国大部分区域不仅无法正常使用，用户浏览器一直加载到超时还拖慢了网站整体

odoo disabled website homepage

odoo有些模块包含website功能，这就依赖了website这个重量级模块
很多时候仅仅想用其核心功能，并不想因此造成首页变成企业网站

# -*- coding: utf-8 -*-
import logging

from openerp import http
from openerp.http import request
from openerp.addons.website.controllers.main import Website

logger = logging.getLogger(__name__)

class WebsiteDisabled(Website):
    @http.route(auth="none", website=False)
    def index(self, **kw):
        return http.local_redirect('/web', query=request.params, keep_hash=True)

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

import logging

from openerp import http

from openerp.http import request

from openerp.addons.website.controllers.main import Website

logger = logging.getLogger(__name__)

class WebsiteDisabled(Website):

@http.route(auth="none", website=False)

def index(self, **kw):

return http.local_redirect('/web', query=request.params, keep_hash=True)