python | Odoo Connects Everything

odoo tree view dynamic column

ODOO列表视图动态列
由于框架模型限定了字段是需要事先定义的，也就是个数是确定的，对应成列表视图仅仅是显示或者不显示这些字段而已

时间横排

一些特殊的场景，比如工时单记录，根据项目在列表视图上一行行的填写工时就变得非常重复和多余，可惜官方没有改造列表视图使其获得通用能力，而是专门为之新开发了一个项目日期横排组件级视图，使得应用范围比较窄，多些固定列或者非时间动态列的情况下就无法直接使用了

尺码横排

一些行业的应用，比如服装行业的尺码横排，动态列一般是浮点型价格或者整型数量，而固定列除了颜色之外，一般还有批次、仓位、款式、订单等组合。前期也参考了工时单和Grid视图的优秀设计，甚至尝试基于其进行二次开发改良，但最终还是选择最普遍的原生列表视图为基础进行扩展，希望最终用户可以获得习惯一致的体验，同时也对经典视图深入发展多元化应用进行了一次实打实的尝试

odoo document management system

ODOO文档管理系统
自从开始玩上官方应用市场，一直坚持平均一个月推出一款应用，日积月累也慢慢形成了移动互联网流行的应用矩阵，同时也对海外客户的国际化需求和口味风格异同都有了不少的了解

今天突然发现上个月发布的一款文档管理系统今天已经进入下载排名十强，目前位于第八个的样子，这可是破记录了，因为之前最高也就是在第二页徘徊而已。曾经也羡慕过那些霸榜应用，现在看来只要坚持总会摸索到爆款痛点：）

论市场优秀应用，我认为至少要同步官方的节奏，不仅要支持最新的三个版本，更要兼容企业版，当然最重要的还是开源免费，而开发者所收获的则是国际的规范的扎实的基础能力

https://apps.odoo.com/apps/modules/10.0/document_management_system/

odoo web window title config app

ODOO浏览器窗口标题配置模块
前文odoo custom web window title已经讲解了基础原理，虽然代码很简洁易懂，但对非开发出身的odoo玩家使用还是有一些难度，而且不同版本可能还会有一些实施细节上的差异

整体开箱即用、细节精益求精是我毕生追求的odoo一体化目标，周末趁这个小机会将其一步到位适配成8、9、10三大主流版本全覆盖的模块，并已发布到odoo官方应用市场，支持在线自动安装，也可以下载相应的版本到本地进行传统手动安装

https://apps.odoo.com/apps/modules/8.0/web_window_title/
https://apps.odoo.com/apps/modules/9.0/web_window_title/
https://apps.odoo.com/apps/modules/10.0/web_window_title/

odoo-web-window-title-app

odoo model import data ignore error

ODOO模块导入数据忽略错误
经常遇到大量的数据导入，不仅耗时很长，如果其中有一条数据有异常产生错误，就会导致整个过程回滚，这是非常悲剧的，其中相关源码如下：

for id, xid, record, info in converted:
    try:
        cr.execute('SAVEPOINT model_load_save')
    except psycopg2.InternalError as e:
        # broken transaction, exit and hope the source error was
        # already logged
        if not any(message['type'] == 'error' for message in messages):
            messages.append(dict(info, type='error',message=u"Unknown database error: '%s'" % e))
        break
    try:
        ids.append(ModelData._update(self._name, current_module, record, mode=mode,
                                     xml_id=xid, noupdate=noupdate, res_id=id))
        cr.execute('RELEASE SAVEPOINT model_load_save')
    except psycopg2.Warning as e:
        messages.append(dict(info, type='warning', message=str(e)))
        cr.execute('ROLLBACK TO SAVEPOINT model_load_save')
    except psycopg2.Error as e:
        messages.append(dict(info, type='error', **PGERROR_TO_OE[e.pgcode](self, fg, info, e)))
        # Failed to write, log to messages, rollback savepoint (to
        # avoid broken transaction) and keep going
        cr.execute('ROLLBACK TO SAVEPOINT model_load_save')
    except Exception as e:
        message = (_('Unknown error during import:') + ' %s: %s' % (type(e), unicode(e)))
        moreinfo = _('Resolve other errors first')
        messages.append(dict(info, type='error', message=message, moreinfo=moreinfo))
        # Failed for some reason, perhaps due to invalid data supplied,
        # rollback savepoint and keep going
        cr.execute('ROLLBACK TO SAVEPOINT model_load_save')
if any(message['type'] == 'error' for message in messages):
    cr.execute('ROLLBACK TO SAVEPOINT model_load')
    ids = False

for id, xid, record, info in converted:

try:

cr.execute('SAVEPOINT model_load_save')

except psycopg2.InternalError as e:

# broken transaction, exit and hope the source error was

# already logged

if not any(message['type'] == 'error' for message in messages):

messages.append(dict(info, type='error',message=u"Unknown database error: '%s'" % e))

break

try:

ids.append(ModelData._update(self._name, current_module, record, mode=mode,

xml_id=xid, noupdate=noupdate, res_id=id))

cr.execute('RELEASE SAVEPOINT model_load_save')

except psycopg2.Warning as e:

messages.append(dict(info, type='warning', message=str(e)))

cr.execute('ROLLBACK TO SAVEPOINT model_load_save')

except psycopg2.Error as e:

messages.append(dict(info, type='error', **PGERROR_TO_OE[e.pgcode](self, fg, info, e)))

# Failed to write, log to messages, rollback savepoint (to

# avoid broken transaction) and keep going

cr.execute('ROLLBACK TO SAVEPOINT model_load_save')

except Exception as e:

message = (_('Unknown error during import:') + ' %s: %s' % (type(e), unicode(e)))

moreinfo = _('Resolve other errors first')

messages.append(dict(info, type='error', message=message, moreinfo=moreinfo))

# Failed for some reason, perhaps due to invalid data supplied,

# rollback savepoint and keep going

cr.execute('ROLLBACK TO SAVEPOINT model_load_save')

if any(message['type'] == 'error' for message in messages):

cr.execute('ROLLBACK TO SAVEPOINT model_load')

ids = False

明白核心代码处理逻辑后，就可以在外层拦截并过滤错误数据继续提交干净数据以实现自动纠错导入，实现源码如下：

'''
  author: i@renjie.me
'''
original_load = models.Model.load

@api.model
def load(self, fields, data):
    load_result = original_load(self, fields, data)
    context = self.env.context or {}
    if context.get("import_ignore_error"):
        record = set()
        for message in load_result.get("messages", []):
            if message['type'] == 'error':
                record.add(message['record'])
        if record:
            data_ignore = []
            for index, item in enumerate(data):
                if index not in record:
                    data_ignore.append(item)
            load_result = original_load(self, fields, data_ignore)
    return load_result

models.Model.load = load

'''

author: i@renjie.me

'''

original_load = models.Model.load

@api.model

def load(self, fields, data):

load_result = original_load(self, fields, data)

context = self.env.context or {}

if context.get("import_ignore_error"):

record = set()

for message in load_result.get("messages", []):

if message['type'] == 'error':

record.add(message['record'])

if record:

data_ignore = []

for index, item in enumerate(data):

if index not in record:

data_ignore.append(item)

load_result = original_load(self, fields, data_ignore)

return load_result

models.Model.load = load

odoo notify and warning client action

odoo后台接口如果出现错误可以简单抛出一个UserError异常给前端进行处理
但是有些时候可能只是一个通知或者警告给用户，不需要错误这么重的模态强交互，也不用影响主流程

从odoo8的addons/web/static/src/js/chrome.js源码中可以发现这个功能曾经拥有

instance.web.action_notify = function(element, action) {
    element.do_notify(action.params.title, action.params.text, action.params.sticky);
};
instance.web.client_actions.add("action_notify", "instance.web.action_notify");

instance.web.action_warn = function(element, action) {
    element.do_warn(action.params.title, action.params.text, action.params.sticky);
};
instance.web.client_actions.add("action_warn", "instance.web.action_warn");

instance.web.action_notify = function(element, action) {

element.do_notify(action.params.title, action.params.text, action.params.sticky);

};

instance.web.client_actions.add("action_notify", "instance.web.action_notify");

instance.web.action_warn = function(element, action) {

element.do_warn(action.params.title, action.params.text, action.params.sticky);

};

instance.web.client_actions.add("action_warn", "instance.web.action_warn");

本次以notify通知为例，其对应到odoo9之后的移植代码为：

/**
 * author: i@renjie.me
 */
var core = require('web.core');
core.action_registry.add('action_notify', function(element, action){
    var params = action.params;
    if(params){
        element.do_notify(params.title, params.text, params.sticky);
    }
    return {'type':'ir.actions.act_window_close'};
});

/**

* author: i@renjie.me

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

core.action_registry.add('action_notify', function(element, action){

var params = action.params;

if(params){

element.do_notify(params.title, params.text, params.sticky);

}

return {'type':'ir.actions.act_window_close'};

});

相对应后台调用统一封装方法：

'''
  author: i@renjie.me
'''
def action_notify(self, title=u'默认通知标题', text=u"默认通知内容", sticky=False):
    return {
        "type": "ir.actions.client",
        "tag": "action_notify",
        "params": {
            "title": title,
            "text": text,
            "sticky": sticky
        }
    }

'''

author: i@renjie.me

'''

def action_notify(self, title=u'默认通知标题', text=u"默认通知内容", sticky=False):

return {

"type": "ir.actions.client",

"tag": "action_notify",

"params": {

"title": title,

"text": text,

"sticky": sticky

}

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

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 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 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)

odoo muilt domain dbfilter many to one config and code

odoo支持dbfilter配置用于实现多域名对应多账套，dbfilter是一个python标准正则字符串，并支持特殊的%h、%d这两个动态参数

根据源代码剖析（odoo8、odoo9）
openerp/http.py

def db_filter(dbs, httprequest=None):
    httprequest = httprequest or request.httprequest
    #请求域名去除端口号，如果有的话
    h = httprequest.environ.get('HTTP_HOST', '').split(':')[0]
    #分割域名取主机名，即多级域名最左边段
    d, _, r = h.partition('.')
    #如主机名为www且有下一段取第二段为主机名
    if d == "www" and r:
        d = r.partition('.')[0]
    #动态正则支持，%h替换为域名，%d替换为主机名
    r = openerp.tools.config['dbfilter'].replace('%h', h).replace('%d', d)
    #正则筛选匹配的数据库列表   
    dbs = [i for i in dbs if re.match(r, i)]
    return dbs

def db_filter(dbs, httprequest=None):

httprequest = httprequest or request.httprequest

#请求域名去除端口号，如果有的话

h = httprequest.environ.get('HTTP_HOST', '').split(':')[0]

#分割域名取主机名，即多级域名最左边段

d, _, r = h.partition('.')

#如主机名为www且有下一段取第二段为主机名

if d == "www" and r:

d = r.partition('.')[0]

#动态正则支持，%h替换为域名，%d替换为主机名

r = openerp.tools.config['dbfilter'].replace('%h', h).replace('%d', d)

#正则筛选匹配的数据库列表

dbs = [i for i in dbs if re.match(r, i)]

return dbs

由此可见，绝大部分有规律的映射需求都可以得到满足。惟有那些情况特殊，完全没有规则可言的：比如SEO需要、历史数据库命名混乱、甚至多个一级域名只对一个数据库的需求就悲剧了

这里举一个理想的openerp-server.conf扩展配置特例

dbfilter = %m
dbfilter_zhunlian.net = www-zhunlian-net
dbfilter_www.zhunlian.net = www-zhunlian-net
dbfilter_wap.zhunlian.net = www-zhunlian-net
dbfilter_higk.com = www-higk-com
dbfilter_www.higk.com = www-higk-com
dbfilter_wap.higk.com = www-higk-com
dbfilter_higk.com.cn = www-higk-com
dbfilter_www.higk.com.cn = www-higk-com
dbfilter_higk.net = www-higk-com
dbfilter_www.higk.net = www-higk-com

dbfilter = %m

dbfilter_zhunlian.net = www-zhunlian-net

dbfilter_www.zhunlian.net = www-zhunlian-net

dbfilter_wap.zhunlian.net = www-zhunlian-net

dbfilter_higk.com = www-higk-com

dbfilter_www.higk.com = www-higk-com

dbfilter_wap.higk.com = www-higk-com

dbfilter_higk.com.cn = www-higk-com

dbfilter_www.higk.com.cn = www-higk-com

dbfilter_higk.net = www-higk-com

dbfilter_www.higk.net = www-higk-com

首先新增支持%m特别参数，用来开启域名数据库映射复杂模式
其次新增支持dbfilter_前缀的域名映射独立配置指定数据库名称（www-zhunlian-net、www-higk-com）
最后迫不得已新增插入两行精炼的源代码

def db_filter(dbs, httprequest=None):
    httprequest = httprequest or request.httprequest
    h = httprequest.environ.get('HTTP_HOST', '').split(':')[0]
    d, _, r = h.partition('.')
    if d == "www" and r:
        d = r.partition('.')[0]
    r = openerp.tools.config['dbfilter'].replace('%h', h).replace('%d', d)
    #开启域名数据库映射复杂模式
    if r == '%m':
        #尝试获取域名独立配置，如无指定则映射同名数据库名，相当于保底%h功能以减少标准配置
        r = openerp.tools.config.get('dbfilter_%s' % h, h)
    dbs = [i for i in dbs if re.match(r, i)]
    return dbs

def db_filter(dbs, httprequest=None):

httprequest = httprequest or request.httprequest

h = httprequest.environ.get('HTTP_HOST', '').split(':')[0]

d, _, r = h.partition('.')

if d == "www" and r:

d = r.partition('.')[0]

r = openerp.tools.config['dbfilter'].replace('%h', h).replace('%d', d)

#开启域名数据库映射复杂模式

if r == '%m':

#尝试获取域名独立配置，如无指定则映射同名数据库名，相当于保底%h功能以减少标准配置

r = openerp.tools.config.get('dbfilter_%s' % h, h)

dbs = [i for i in dbs if re.match(r, i)]

return dbs

注：一个域名必备的.号在正则表达式领域可用于匹配任意字符，所以域名全称作为正则也可以根据需要匹配出一组数据库列表，如域名renjie.me可同时匹配出数据库名为renjie.me、renjie-me、renjie@me等等相似名称的数据库