Thibault Delavallée
7cad4baa84
Indeed using fromkeys with a list / dict as argument leads to the creation of shared list / dict. This could create some ugly side effects when used in loops. This commit fixes or cleans this kind of statement to avoid unwanted side effects.
151 lines
7.7 KiB
Python
151 lines
7.7 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
import datetime
|
|
from dateutil import relativedelta
|
|
|
|
from openerp import tools, SUPERUSER_ID
|
|
from openerp.addons.web import http
|
|
from openerp.addons.website.models.website import slug
|
|
from openerp.addons.web.http import request
|
|
|
|
|
|
class MailGroup(http.Controller):
|
|
_thread_per_page = 20
|
|
_replies_per_page = 10
|
|
|
|
def _get_archives(self, group_id):
|
|
MailMessage = request.registry['mail.message']
|
|
groups = MailMessage.read_group(
|
|
request.cr, request.uid, [('model', '=', 'mail.group'), ('res_id', '=', group_id)], ['subject', 'date'],
|
|
groupby="date", orderby="date desc", context=request.context)
|
|
for group in groups:
|
|
begin_date = datetime.datetime.strptime(group['__domain'][0][2], tools.DEFAULT_SERVER_DATETIME_FORMAT).date()
|
|
end_date = datetime.datetime.strptime(group['__domain'][1][2], tools.DEFAULT_SERVER_DATETIME_FORMAT).date()
|
|
group['date_begin'] = '%s' % datetime.date.strftime(begin_date, tools.DEFAULT_SERVER_DATE_FORMAT)
|
|
group['date_end'] = '%s' % datetime.date.strftime(end_date, tools.DEFAULT_SERVER_DATE_FORMAT)
|
|
return groups
|
|
|
|
@http.route("/groups", type='http', auth="public", website=True)
|
|
def view(self, **post):
|
|
cr, uid, context = request.cr, request.uid, request.context
|
|
group_obj = request.registry.get('mail.group')
|
|
mail_message_obj = request.registry.get('mail.message')
|
|
group_ids = group_obj.search(cr, uid, [('alias_id', '!=', False), ('alias_id.alias_name', '!=', False)], context=context)
|
|
groups = group_obj.browse(cr, uid, group_ids, context)
|
|
# compute statistics
|
|
month_date = datetime.datetime.today() - relativedelta.relativedelta(months=1)
|
|
group_data = dict()
|
|
for group in groups:
|
|
group_data[group.id] = {
|
|
'monthly_message_nbr': mail_message_obj.search(
|
|
cr, SUPERUSER_ID,
|
|
[('model', '=', 'mail.group'), ('res_id', '=', group.id), ('date', '>=', month_date.strftime(tools.DEFAULT_SERVER_DATETIME_FORMAT))],
|
|
count=True, context=context)}
|
|
values = {'groups': groups, 'group_data': group_data}
|
|
return request.website.render('website_mail_group.mail_groups', values)
|
|
|
|
@http.route(["/groups/subscription/"], type='json', auth="user")
|
|
def subscription(self, group_id=0, action=False, **post):
|
|
""" TDE FIXME: seems dead code """
|
|
cr, uid, context = request.cr, request.uid, request.context
|
|
group_obj = request.registry.get('mail.group')
|
|
if action:
|
|
group_obj.message_subscribe_users(cr, uid, [group_id], context=context)
|
|
else:
|
|
group_obj.message_unsubscribe_users(cr, uid, [group_id], context=context)
|
|
return []
|
|
|
|
@http.route([
|
|
"/groups/<model('mail.group'):group>",
|
|
"/groups/<model('mail.group'):group>/page/<int:page>"
|
|
], type='http', auth="public", website=True)
|
|
def thread_headers(self, group, page=1, mode='thread', date_begin=None, date_end=None, **post):
|
|
cr, uid, context = request.cr, request.uid, request.context
|
|
thread_obj = request.registry.get('mail.message')
|
|
|
|
domain = [('model', '=', 'mail.group'), ('res_id', '=', group.id)]
|
|
if mode == 'thread':
|
|
domain += [('parent_id', '=', False)]
|
|
if date_begin and date_end:
|
|
domain += [('date', '>=', date_begin), ('date', '<=', date_end)]
|
|
|
|
thread_count = thread_obj.search_count(cr, uid, domain, context=context)
|
|
pager = request.website.pager(
|
|
url='/groups/%s' % slug(group),
|
|
total=thread_count,
|
|
page=page,
|
|
step=self._thread_per_page,
|
|
url_args={'mode': mode, 'date_begin': date_begin or '', 'date_end': date_end or ''},
|
|
)
|
|
thread_ids = thread_obj.search(cr, uid, domain, limit=self._thread_per_page, offset=pager['offset'])
|
|
messages = thread_obj.browse(cr, uid, thread_ids, context)
|
|
values = {
|
|
'messages': messages,
|
|
'group': group,
|
|
'pager': pager,
|
|
'mode': mode,
|
|
'archives': self._get_archives(group.id),
|
|
'date_begin': date_begin,
|
|
'date_end': date_end,
|
|
'replies_per_page': self._replies_per_page,
|
|
}
|
|
return request.website.render('website_mail_group.group_messages', values)
|
|
|
|
@http.route([
|
|
'''/groups/<model('mail.group'):group>/<model('mail.message', "[('model','=','mail.group'), ('res_id','=',group[0])]"):message>''',
|
|
], type='http', auth="public", website=True)
|
|
def thread_discussion(self, group, message, mode='thread', date_begin=None, date_end=None, **post):
|
|
cr, uid, context = request.cr, request.uid, request.context
|
|
Message = request.registry['mail.message']
|
|
if mode == 'thread':
|
|
base_domain = [('model', '=', 'mail.group'), ('res_id', '=', group.id), ('parent_id', '=', message.parent_id and message.parent_id.id or False)]
|
|
else:
|
|
base_domain = [('model', '=', 'mail.group'), ('res_id', '=', group.id)]
|
|
next_message = None
|
|
next_message_ids = Message.search(cr, uid, base_domain + [('date', '<', message.date)], order="date DESC", limit=1, context=context)
|
|
if next_message_ids:
|
|
next_message = Message.browse(cr, uid, next_message_ids[0], context=context)
|
|
prev_message = None
|
|
prev_message_ids = Message.search(cr, uid, base_domain + [('date', '>', message.date)], order="date ASC", limit=1, context=context)
|
|
if prev_message_ids:
|
|
prev_message = Message.browse(cr, uid, prev_message_ids[0], context=context)
|
|
values = {
|
|
'message': message,
|
|
'group': group,
|
|
'mode': mode,
|
|
'archives': self._get_archives(group.id),
|
|
'date_begin': date_begin,
|
|
'date_end': date_end,
|
|
'replies_per_page': self._replies_per_page,
|
|
'next_message': next_message,
|
|
'prev_message': prev_message,
|
|
}
|
|
return request.website.render('website_mail_group.group_message', values)
|
|
|
|
@http.route(
|
|
'''/groups/<model('mail.group'):group>/<model('mail.message', "[('model','=','mail.group'), ('res_id','=',group[0])]"):message>/get_replies''',
|
|
type='json', auth="public", methods=['POST'], website=True)
|
|
def render_messages(self, group, message, **post):
|
|
last_displayed_id = post.get('last_displayed_id')
|
|
if not last_displayed_id:
|
|
return False
|
|
Message = request.registry['mail.message']
|
|
replies_domain = [('id', '<', int(last_displayed_id)), ('parent_id', '=', message.id)]
|
|
msg_ids = Message.search(request.cr, request.uid, replies_domain, limit=self._replies_per_page, context=request.context)
|
|
msg_count = Message.search(request.cr, request.uid, replies_domain, count=True, context=request.context)
|
|
messages = Message.browse(request.cr, request.uid, msg_ids, context=request.context)
|
|
values = {
|
|
'group': group,
|
|
'thread_header': message,
|
|
'messages': messages,
|
|
'msg_more_count': msg_count - self._replies_per_page,
|
|
'replies_per_page': self._replies_per_page,
|
|
}
|
|
return request.registry['ir.ui.view'].render(request.cr, request.uid, 'website_mail_group.messages_short', values, engine='ir.qweb', context=request.context)
|
|
|
|
@http.route("/groups/<model('mail.group'):group>/get_alias_info", type='json', auth='public', website=True)
|
|
def get_alias_info(self, group, **post):
|
|
return {
|
|
'alias_name': group.alias_id and group.alias_id.alias_name and group.alias_id.alias_domain and '%s@%s' % (group.alias_id.alias_name, group.alias_id.alias_domain) or False
|
|
}
|