addons/website_blog/controllers/main.py

   1 # -*- coding: utf-8 -*-
   2 ##############################################################################
   3 #
   4 #    OpenERP, Open Source Management Solution
   5 #    Copyright (C) 2013-Today OpenERP SA (<http://www.openerp.com>).
   6 #
   7 #    This program is free software: you can redistribute it and/or modify
   8 #    it under the terms of the GNU Affero General Public License as
   9 #    published by the Free Software Foundation, either version 3 of the
  10 #    License, or (at your option) any later version.
  11 #
  12 #    This program is distributed in the hope that it will be useful,
  13 #    but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 #    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15 #    GNU Affero General Public License for more details.
  16 #
  17 #    You should have received a copy of the GNU Affero General Public License
  18 #    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  19 #
  20 ##############################################################################
  21
  22 import random
  23 import werkzeug
  24 from datetime import datetime
  25
  26 from openerp.addons.web import http
  27 from openerp.addons.web.http import request
  28 from openerp.tools.translate import _
  29 from openerp import SUPERUSER_ID
  30 from openerp.tools import html2plaintext
  31 from openerp import tools
  32
  33 class WebsiteBlog(http.Controller):
  34     _blog_post_per_page = 20
  35     _post_comment_per_page = 10
  36
  37     def nav_list(self):
  38         blog_post_obj = request.registry['blog.post']
  39         groups = blog_post_obj.read_group(request.cr, request.uid, [], ['name', 'create_date'],
  40             groupby="create_date", orderby="create_date asc", context=request.context)
  41         for group in groups:
  42             group['date_begin'] = str(datetime.date(datetime.strptime(group['__domain'][0][2], tools.DEFAULT_SERVER_DATETIME_FORMAT)))
  43             group['date_end'] = str(datetime.date(datetime.strptime( group['__domain'][1][2], tools.DEFAULT_SERVER_DATETIME_FORMAT)))
  44         return groups
  45
  46     @http.route([
  47         '/blog',
  48         '/blog/page/<int:page>',
  49     ], type='http', auth="public", website=True, multilang=True)
  50     def blogs(self, page=1):
  51         cr, uid, context = request.cr, request.uid, request.context
  52         blog_obj = request.registry['blog.post']
  53         total = blog_obj.search(cr, uid, [], count=True, context=context)
  54         pager = request.website.pager(
  55             url='/blog',
  56             total=total,
  57             page=page,
  58             step=self._blog_post_per_page,
  59         )
  60         bids = blog_obj.search(cr, uid, [], offset=pager['offset'], limit=self._blog_post_per_page, context=context)
  61         blogs = blog_obj.browse(cr, uid, bids, context=context)
  62         return request.website.render("website_blog.latest_blogs", {
  63             'blogs': blogs,
  64             'pager': pager
  65         })
  66
  67     @http.route([
  68         '/blog/<model("blog.blog"):blog>',
  69         '/blog/<model("blog.blog"):blog>/page/<int:page>',
  70         '/blog/<model("blog.blog"):blog>/tag/<model("blog.tag"):tag>',
  71         '/blog/<model("blog.blog"):blog>/tag/<model("blog.tag"):tag>/page/<int:page>',
  72         '/blog/<model("blog.blog"):blog>/date/<string(length=10):date_begin>/<string(length=10):date_end>',
  73         '/blog/<model("blog.blog"):blog>/date/<string(length=10):date_begin>/<string(length=10):date_end>/page/<int:page>',
  74         '/blog/<model("blog.blog"):blog>/tag/<model("blog.tag"):tag>/date/<string(length=10):date_begin>/<string(length=10):date_end>',
  75         '/blog/<model("blog.blog"):blog>/tag/<model("blog.tag"):tag>/date/<string(length=10):date_begin>/<string(length=10):date_end>/page/<int:page>',
  76     ], type='http', auth="public", website=True, multilang=True)
  77     def blog(self, blog=None, tag=None, date_begin=None,date_end=None, page=1, **opt):
  78         """ Prepare all values to display the blog.
  79
  80         :param blog: blog currently browsed.
  81         :param tag: tag that is currently used to filter blog posts
  82         :param integer page: current page of the pager. Can be the blog or
  83                             post pager.
  84         :param date: date currently used to filter blog posts (dateBegin_dateEnd)
  85
  86         :return dict values: values for the templates, containing
  87
  88          - 'blog_posts': list of browse records that are the posts to display
  89                          in a given blog, if not blog_post_id
  90          - 'blog': browse of the current blog, if blog_id
  91          - 'blogs': list of browse records of blogs
  92          - 'pager': the pager to display posts pager in a blog
  93          - 'tag': current tag, if tag_id
  94          - 'nav_list': a dict [year][month] for archives navigation
  95         """
  96         cr, uid, context = request.cr, request.uid, request.context
  97         blog_post_obj = request.registry['blog.post']
  98
  99         blog_obj = request.registry['blog.blog']
 100         blog_ids = blog_obj.search(cr, uid, [], context=context)
 101         blogs = blog_obj.browse(cr, uid, blog_ids, context=context)
 102
 103         path_filter = ""
 104         domain = []
 105         if blog:
 106             path_filter += "%s" % blog.id
 107             domain += [("blog_id", "in", [blog.id])]
 108         if tag:
 109             path_filter += 'tag/%s' % tag.id
 110             domain += [("tag_ids", "in", [tag.id])]
 111         if date_begin and date_end:
 112             path_filter += "date/%s/%s" % (date_begin,date_end)
 113             domain += [("create_date", ">=", date_begin), ("create_date", "<=", date_end)]
 114
 115         blog_post_count = blog_post_obj.search(cr, uid, domain, count=True, context=context)
 116         pager = request.website.pager(
 117             url="/blog/%s" % path_filter,
 118             total=blog_post_count,
 119             page=page,
 120             step=self._blog_post_per_page,
 121             scope=10
 122         )
 123         blog_post_ids = blog_post_obj.search(cr, uid, domain, context=context, limit=self._blog_post_per_page, offset=pager['offset'])
 124         blog_posts = blog_post_obj.browse(cr, uid, blog_post_ids, context=context)
 125
 126         tag_obj = request.registry['blog.tag']
 127         tag_ids = tag_obj.search(cr, uid, [], context=context)
 128         tags = tag_obj.browse(cr, uid, tag_ids, context=context)
 129
 130         values = {
 131             'blog': blog,
 132             'blogs': blogs,
 133             'tags': tags,
 134             'tag': tag,
 135             'blog_posts': blog_posts,
 136             'pager': pager,
 137             'nav_list': self.nav_list(),
 138             'path_filter': path_filter,
 139             'date': date_begin,
 140         }
 141         response = request.website.render("website_blog.blog_post_short", values)
 142         return response
 143
 144     @http.route([
 145         '/blog/<model("blog.blog"):blog>/post/<model("blog.post"):blog_post>',
 146     ], type='http', auth="public", website=True, multilang=True)
 147     def blog_post(self, blog, blog_post, enable_editor=None, **post):
 148         """ Prepare all values to display the blog.
 149
 150         :param blog_post: blog post currently browsed. If not set, the user is
 151                           browsing the blog and a post pager is calculated.
 152                           If set the user is reading the blog post and a
 153                           comments pager is calculated.
 154         :param blog: blog currently browsed.
 155         :param tag: tag that is currently used to filter blog posts
 156         :param integer page: current page of the pager. Can be the blog or
 157                             post pager.
 158         :param date: date currently used to filter blog posts (dateBegin_dateEnd)
 159
 160          - 'enable_editor': editor control
 161
 162         :return dict values: values for the templates, containing
 163
 164          - 'blog_post': browse of the current post, if blog_post_id
 165          - 'blog': browse of the current blog, if blog_id
 166          - 'blogs': list of browse records of blogs
 167          - 'pager': the pager to display comments pager in a blog post
 168          - 'tag': current tag, if tag_id
 169          - 'nav_list': a dict [year][month] for archives navigation
 170          - 'next_blog': next blog post , display in footer
 171         """
 172         cr, uid, context = request.cr, request.uid, request.context
 173         if not blog_post.blog_id.id==blog.id:
 174             return request.redirect("/blog/%s/post/%s" % (blog_post.blog_id.id, blog_post.id))
 175         blog_post_obj = request.registry.get('blog.post')
 176
 177         # Find next Post
 178         visited_blogs = request.httprequest.cookies.get('visited_blogs') or ''
 179         visited_ids = filter(None, visited_blogs.split(','))
 180         visited_ids = map(lambda x: int(x), visited_ids)
 181         if blog_post.id not in visited_ids:
 182             visited_ids.append(blog_post.id)
 183         next_post_id = blog_post_obj.search(cr, uid, [
 184             ('id', 'not in', visited_ids),
 185             ], order='ranking desc', limit=1, context=context)
 186         next_post = next_post_id and blog_post_obj.browse(cr, uid, next_post_id[0], context=context) or False
 187
 188         values = {
 189             'blog': blog,
 190             'blog_post': blog_post,
 191             'main_object': blog_post,
 192             'enable_editor': enable_editor,
 193             'next_post' : next_post,
 194         }
 195         response = request.website.render("website_blog.blog_post_complete", values)
 196         response.set_cookie('visited_blogs', ','.join(map(str, visited_ids)))
 197
 198         # Increase counter and ranking ratio for order
 199         d = datetime.now() - datetime.strptime(blog_post.create_date, "%Y-%m-%d %H:%M:%S")
 200         blog_post_obj.write(cr, SUPERUSER_ID, [blog_post.id], {
 201             'visits': blog_post.visits+1,
 202             'ranking': blog_post.visits * (0.5+random.random()) / max(3, d.days)
 203         },context=context)
 204         return response
 205
 206     def _blog_post_message(self, user, blog_post_id=0, **post):
 207         cr, uid, context = request.cr, request.uid, request.context
 208         blog_post = request.registry['blog.post']
 209         partner_obj = request.registry['res.partner']
 210         thread_obj = request.registry['mail.thread']
 211         website = request.registry['website']
 212
 213         public_id = website.get_public_user(cr, uid, context)
 214         if uid != public_id:
 215             partner_ids = [user.partner_id.id]
 216         else:
 217             partner_ids = blog_post._find_partner_from_emails(
 218                 cr, SUPERUSER_ID, 0, [post.get('email')], context=context)
 219             if not partner_ids or not partner_ids[0]:
 220                 partner_ids = [partner_obj.create(cr, SUPERUSER_ID, {'name': post.get('name'), 'email': post.get('email')}, context=context)]
 221
 222         message_id = blog_post.message_post(
 223             cr, SUPERUSER_ID, int(blog_post_id),
 224             body=post.get('comment'),
 225             type='comment',
 226             subtype='mt_comment',
 227             author_id=partner_ids[0],
 228             discussion=post.get('discussion'),
 229             context=dict(context, mail_create_nosubcribe=True))
 230         return message_id
 231
 232     @http.route(['/blogpost/comment'], type='http', auth="public", methods=['POST'], website=True)
 233     def blog_post_comment(self, blog_post_id=0, **post):
 234         cr, uid, context = request.cr, request.uid, request.context
 235         if post.get('comment'):
 236             user = request.registry['res.users'].browse(cr, uid, uid, context=context)
 237             blog_post = request.registry['blog.post']
 238             blog_post.check_access_rights(cr, uid, 'read')
 239             self._blog_post_message(user, blog_post_id, **post)
 240         return werkzeug.utils.redirect(request.httprequest.referrer + "#comments")
 241
 242     def _get_discussion_detail(self, ids, publish=False, **post):
 243         cr, uid, context = request.cr, request.uid, request.context
 244         values = []
 245         mail_obj = request.registry.get('mail.message')
 246         for message in mail_obj.browse(cr, SUPERUSER_ID, ids, context=context):
 247             values.append({
 248                 "id": message.id,
 249                 "author_name": message.author_id.name,
 250                 "author_image": message.author_id.image and \
 251                     ("data:image/png;base64,%s" % message.author_id.image) or \
 252                     '/website_blog/static/src/img/anonymous.png',
 253                 "date": message.date,
 254                 'body': html2plaintext(message.body),
 255                 'website_published' : message.website_published,
 256                 'publish' : publish,
 257             })
 258         return values
 259
 260     @http.route(['/blogpost/post_discussion'], type='json', auth="public", website=True)
 261     def post_discussion(self, blog_post_id=0, **post):
 262         cr, uid, context = request.cr, request.uid, request.context
 263         publish = request.registry['res.users'].has_group(cr, uid, 'base.group_website_publisher')
 264         user = request.registry['res.users'].browse(cr, uid, uid, context=context)
 265         id = self._blog_post_message(user, blog_post_id, **post)
 266         return self._get_discussion_detail([id], publish, **post)
 267
 268     @http.route('/blogpost/new', type='http', auth="public", website=True, multilang=True)
 269     def blog_post_create(self, blog_id, **post):
 270         cr, uid, context = request.cr, request.uid, request.context
 271         create_context = dict(context, mail_create_nosubscribe=True)
 272         new_blog_post_id = request.registry['blog.post'].create(cr, uid, {
 273                 'blog_id': blog_id,
 274                 'name': _("Blog Post Title"),
 275                 'sub_title': _("Subtitle"),
 276                 'content': '',
 277                 'website_published': False,
 278             }, context=create_context)
 279         return werkzeug.utils.redirect("/blog/%s/post/%s/?enable_editor=1" % (blog_id, new_blog_post_id))
 280
 281     @http.route('/blogpost/duplicate', type='http', auth="public", website=True)
 282     def blog_post_copy(self, blog_post_id, **post):
 283         """ Duplicate a blog.
 284
 285         :param blog_post_id: id of the blog post currently browsed.
 286
 287         :return redirect to the new blog created
 288         """
 289         cr, uid, context = request.cr, request.uid, request.context
 290         create_context = dict(context, mail_create_nosubscribe=True)
 291         nid = request.registry['blog.post'].copy(cr, uid, blog_post_id, {}, context=create_context)
 292         post = request.registry['blog.post'].browse(cr, uid, nid, context)
 293         return werkzeug.utils.redirect("/blog/%s/post/%s/?enable_editor=1" % (post.blog_id.id, nid))
 294
 295     @http.route('/blogpost/get_discussion/', type='json', auth="public", website=True)
 296     def discussion(self, post_id=0, discussion=None, count=False, **post):
 297         cr, uid, context = request.cr, request.uid, request.context
 298         mail_obj = request.registry.get('mail.message')
 299         domain = [('res_id', '=', int(post_id)) ,('model','=','blog.post'), ('discussion', '=', discussion)]
 300         #check current user belongs to website publisher group
 301         publish = request.registry['res.users'].has_group(cr, uid, 'base.group_website_publisher')
 302         if not publish:
 303             domain.append(('website_published', '=', True))
 304         ids = mail_obj.search(cr, SUPERUSER_ID, domain, count=count)
 305         if count:
 306             return ids
 307         return self._get_discussion_detail(ids, publish, **post)
 308
 309     @http.route('/blogpsot/change_background', type='json', auth="public", website=True)
 310     def change_bg(self, post_id=0, image=None, **post):
 311         post_obj = request.registry.get('blog.post')
 312         values = {'content_image' : image}
 313
 314         ids = post_obj.write(request.cr, request.uid, [int(post_id)], values, request.context)
 315         return []
 316
 317     @http.route('/blog/get_user/', type='json', auth="public", website=True)
 318     def get_user(self, **post):
 319         return [False if request.session.uid else True]