kingfisher/controllers/main.py

# -*- coding: utf-8 -*-
# Part of Biztech Consultancy. See LICENSE file for full copyright and licensing details.

import werkzeug
from openerp import http
from openerp.http import request
from openerp import SUPERUSER_ID
from openerp.addons.website.models.website import slug
from openerp.addons.website_sale.controllers.main import QueryURL
from openerp.addons.website_sale.controllers.main import get_pricelist
from openerp.addons.web.controllers.main import login_redirect
from openerp.addons.website_sale.controllers.main import website_sale

import re
PPG = 12 # Products Per Page
PPR = 3  # Products Per Row

class table_compute(object):
    def __init__(self):
        self.table = {}

    def _check_place(self, posx, posy, sizex, sizey):
        res = True
        for y in range(sizey):
            for x in range(sizex):
                if posx+x>=PPR:
                    res = False
                    break
                row = self.table.setdefault(posy+y, {})
                if row.setdefault(posx+x) is not None:
                    res = False
                    break
            for x in range(PPR):
                self.table[posy+y].setdefault(x, None)
        return res

    def process(self, products):
        # Compute products positions on the grid
        minpos = 0
        index = 0
        maxy = 0
        for p in products:
            x = min(max(p.website_size_x, 1), PPR)
            y = min(max(p.website_size_y, 1), PPR)
            if index>=PPG:
                x = y = 1

            pos = minpos
            while not self._check_place(pos%PPR, pos/PPR, x, y):
                pos += 1
            # if 21st products (index 20) and the last line is full (PPR products in it), break
            # (pos + 1.0) / PPR is the line where the product would be inserted
            # maxy is the number of existing lines
            # + 1.0 is because pos begins at 0, thus pos 20 is actually the 21st block
            # and to force python to not round the division operation
            if index >= PPG and ((pos + 1.0) / PPR) > maxy:
                break

            if x==1 and y==1:   # simple heuristic for CPU optimization
                minpos = pos/PPR

            for y2 in range(y):
                for x2 in range(x):
                    self.table[(pos/PPR)+y2][(pos%PPR)+x2] = False
            self.table[pos/PPR][pos%PPR] = {
                'product': p, 'x':x, 'y': y,
                'class': " ".join(map(lambda x: x.html_class or '', p.website_style_ids))
            }
            if index<=PPG:
                maxy=max(maxy,y+(pos/PPR))
            index += 1

        # Format table according to HTML needs
        rows = self.table.items()
        rows.sort()
        rows = map(lambda x: x[1], rows)
        for col in range(len(rows)):
            cols = rows[col].items()
            cols.sort()
            x += len(cols)
            rows[col] = [c for c in map(lambda x: x[1], cols) if c != False]

        return rows

        # TODO keep with input type hidden


class biztech_theme(http.Controller):

     # For multi product slider
    @http.route(['/kingfisher_pro/product_multi_get_options'], type='json', auth="public", website=True)
    def product_multi_get_slider_options(self):
        slider_options = []
        option = request.env['multi.slider.config'].search(
            [('active', '=', True)], order="name asc")
        for record in option:
            slider_options.append({'id': record.id,
                                   'name': record.name})
        return slider_options

    @http.route(['/kingfisher_pro/product_multi_get_dynamic_slider'], type='http', auth='public', website=True)
    def product_multi_get_dynamic_slider(self, **post):
        if post.get('slider-type'):
            slider_header = request.env['multi.slider.config'].sudo().search(
                [('id', '=', int(post.get('slider-type')))])
            values = {
                'slider_details': slider_header,
                'slider_header': slider_header
            }
            return request.website.render("kingfisher_pro.kingfisher_pro_multi_cat_slider_view", values)

    @http.route(['/kingfisher_pro/product_multi_image_effect_config'], type='json', auth='public', website=True)
    def product_multi_product_image_dynamic_slider(self, **post):
        slider_data = request.env['multi.slider.config'].search(
            [('id', '=', int(post.get('slider_type')))])
        values = {
            's_id': slider_data.no_of_collection + '-' + str(slider_data.id),
            'counts': slider_data.no_of_collection,
            'auto_rotate': slider_data.auto_rotate,
            'auto_play_time': slider_data.sliding_speed,
        }
        return values



    @http.route(['/home/subscribe'
    ], type='http', auth="public", website=True)
    def subscribe(self, **post):
        email=post.pop('email')
        values={'sub_error':{},'subscribe':{'email':email}}
        if not email:
            values = {'sub_error':{'email':True},'subscribe':{'email':email}}
            return request.website.render("website.homepage",values)
        if email:
            if re.match("^.+\\@(\\[?)[a-zA-Z0-9\\-\\.]+\\.([a-zA-Z]{2,3}|[0-9]{1,3})(\\]?)$", email) != None:
                pass
            else:
                values['sub_error'].update({'email': 'invalid'})
                return request.website.render("website.homepage",values)
        cr, uid, context, pool = request.cr, request.uid, request.context, request.registry
        model_id=pool.get('ir.model').search(cr,uid,[('model','=','res.partner')])
        mass_mail = pool.get('distribution.list').search(cr,uid,[('name','=','Subscribe')])
        if not mass_mail:
            mass_mail=pool.get('distribution.list').create(cr,uid,{
                                                                   'name':'Subscribe',
                                                                   'dst_model_id': model_id[0],
                                                                   'bridge_field':'id',
                                                                   'partner_path':'id',
                                                                   'to_include_distribution_list_line_ids':[[0,False,
                                                                                                             {'name':'Subscribe',
                                                                                                              'src_model_id':model_id[0],
                                                                                                              'domain':"[['subscribe', '=', True]]"}
                                                                                                             ]]},context)
        email_id=email
        success_msg=False
        already_sub_msg=False
        if email_id:
            uid=SUPERUSER_ID
            partner=pool.get('res.partner').search(cr,uid,[('email','=',email_id),('subscribe','=',True)])
            if not partner:
                pool.get('res.partner').create(cr,uid,{'name':email_id.split('@')[0],'email':email_id,
                                                           'customer':True,'subscribe':True},context)
                success_msg='You have been subscribed successfully.'
            else:
                already_sub_msg='You are already subscribed.'
        return request.website.render("website.homepage", {'successmsg':success_msg,'already_sub_msg':already_sub_msg})

    @http.route(['/home/contact_info'
    ], type='http', auth="public", website=True)
    def contacts(self,**post):
        cr, uid, context, pool = request.cr, request.uid, request.context, request.registry
        uid=SUPERUSER_ID
        partner = pool.get('res.users').browse(cr, SUPERUSER_ID, request.uid, context).partner_id
        super_email=pool.get('res.users').browse(cr, SUPERUSER_ID, SUPERUSER_ID, context).email
        name=post.pop('full_name', '')
        email=post.pop('emp_email', '')
        subject=post.pop('email_subject', '')
        msg=post.pop('message', '')
        contact={'full_name':name,'emp_email':email,'email_subject':subject,'message':msg}
        values={'error':{},'contact':contact}
        if not name:
            values['error'].update({'full_name': True})
        if not email:
            values['error'].update({'emp_email': True})
        if email:
            if re.match("^.+\\@(\\[?)[a-zA-Z0-9\\-\\.]+\\.([a-zA-Z]{2,3}|[0-9]{1,3})(\\]?)$", email) != None:
                pass
            else:
                values['error'].update({'emp_email': 'invalid'})
        if values and values.has_key('error')  and values['error']:
            return request.website.render("website.contactus", values)
        if  super_email:
            body="<p>Hello,Admin<br/><br/> Name: "+name+" <br/><br/>Email Address: "+email+ " <br/><br/> Subject: "+subject+" <br/><br/> Message:"+msg+"<br/><br/> Thanks"
            temp_id= pool.get('ir.model.data').get_object(cr, uid, 'kingfisher', 'contact_info_email')
            pool.get('email.template').write(cr, uid, temp_id.id, {'email_to': super_email,'subject' : subject,'body_html':body or ''}, context=context)
            pool.get('email.template').send_mail(cr, uid, temp_id.id,partner.id,True, context=context)
            return request.website.render("website.contactus", {'successmsg':'Your message has been sent successfully.'})
        return request.website.render("website.contactus", {'failmsg':'Your message has not been sent.'})
        #return request.redirect("/page/contactus")

    def get_pricelist(self):
        return get_pricelist()


    @http.route(['/shop/product/comment/<int:product_template_id>'], type='http', auth="public", methods=['GET','POST'], website=True)
    def product_comment(self, product_template_id, **post):
        if not request.session.uid:
            request.session.update({'comments':post.get('comment')})
            return login_redirect()
        cr, uid, context = request.cr, request.uid, request.context
        if post.get('comment') or request.session.has_key('comments') and request.session.comments!=None:
            request.registry['product.template'].message_post(
                cr, uid, product_template_id,
                body=post.get('comment') or request.session.comments,
                type='comment',
                subtype='mt_comment',
                context=dict(context, mail_create_nosubscribe=True))
            if request.session.has_key('comments') and request.session.comments!=None:
                request.session.update({'comments':None})
                return werkzeug.utils.redirect('/shop/product/' +str(product_template_id)+ "#comments")
        return werkzeug.utils.redirect(request.httprequest.referrer + "#comments")



    @http.route(['/shop',
        '/shop/page/<int:page>',
        '/shop/category/<model("product.public.category"):category>',
        '/shop/category/<model("product.public.category"):category>/page/<int:page>'
    ], type='http', auth="public", website=True)
    def shop(self, page=0, category=None, search='', **post):
        cr, uid, context, pool = request.cr, request.uid, request.context, request.registry

        domain = request.website.sale_product_domain()
        if search:
            for srch in search.split(" "):
                domain += ['|', '|', '|', ('name', 'ilike', srch), ('description', 'ilike', srch),
                    ('description_sale', 'ilike', srch), ('product_variant_ids.default_code', 'ilike', srch)]
        if category:
            domain += [('public_categ_ids', 'child_of', int(category))]
        attrib_list = request.httprequest.args.getlist('attrib')
        attrib_values = [map(int,v.split("-")) for v in attrib_list if v]
        attrib_set = set([v[1] for v in attrib_values])

        if attrib_values:
            attrib = None
            ids = []
            for value in attrib_values:
                if not attrib:
                    attrib = value[0]
                    ids.append(value[1])
                elif value[0] == attrib:
                    ids.append(value[1])
                else:
                    domain += [('attribute_line_ids.value_ids', 'in', ids)]
                    attrib = value[0]
                    ids = [value[1]]
            if attrib:
                domain += [('attribute_line_ids.value_ids', 'in', ids)]

        keep = QueryURL('/shop', category=category and int(category), search=search, attrib=attrib_list)

        if not context.get('pricelist'):
            pricelist = self.get_pricelist()
            context['pricelist'] = int(pricelist)
        else:
            pricelist = pool.get('product.pricelist').browse(cr, uid, context['pricelist'], context)

        product_obj = pool.get('product.template')

        url = "/shop"
        product_count = product_obj.search_count(cr, uid, domain, context=context)
        if search:
            post["search"] = search
        if category:
            category = pool['product.public.category'].browse(cr, uid, int(category), context=context)
            url = "/shop/category/%s" % slug(category)
        if attrib_list:
            post['attrib'] = attrib_list
        pager = request.website.pager(url=url, total=product_count, page=page, step=PPG, scope=7, url_args=post)
        product_ids = product_obj.search(cr, uid, domain, limit=PPG, offset=pager['offset'], order='website_published desc, website_sequence desc', context=context)
        products = product_obj.browse(cr, uid, product_ids, context=context)

        style_obj = pool['product.style']
        style_ids = style_obj.search(cr, uid, [], context=context)
        styles = style_obj.browse(cr, uid, style_ids, context=context)

        category_obj = pool['product.public.category']
        category_ids = category_obj.search(cr, uid, [('parent_id', '=', False)], context=context)
        categs = category_obj.browse(cr, uid, category_ids, context=context)

        attributes_obj = request.registry['product.attribute']
        attributes_ids = attributes_obj.search(cr, uid, [], context=context)
        attributes = attributes_obj.browse(cr, uid, attributes_ids, context=context)

        from_currency = pool.get('product.price.type')._get_field_currency(cr, uid, 'list_price', context)
        to_currency = pricelist.currency_id
        compute_currency = lambda price: pool['res.currency']._compute(cr, uid, from_currency, to_currency, price, context=context)

        values = {
            'search': search,
            'category': category,
            'attrib_values': attrib_values,
            'attrib_set': attrib_set,
            'pager': pager,
            'pricelist': pricelist,
            'products': products,
            'bins': table_compute().process(products),
            'rows': PPR,
            'styles': styles,
            'categories': categs,
            'attributes': attributes,
            'compute_currency': compute_currency,
            'keep': keep,
            'style_in_product': lambda style, product: style.id in [s.id for s in product.website_style_ids],
            'attrib_encode': lambda attribs: werkzeug.url_encode([('attrib',i) for i in attribs]),
        }
        return request.website.render("website_sale.products", values)

    @http.route(['/shop/get_products_slider'], type='http', auth='public', website=True)
    def get_slider_product(self, **post):
        cr, uid, context = request.cr, request.uid, request.context
        value = {'products': False, 'header': False}
        if post.get('product_count') and post.get('slider_type'):
            prod_ids = request.registry['product.template'].search(cr, uid, [(post.get(
                'slider_type'), '=', 'True'), ("sale_ok", "=", True)], limit=int(post.get('product_count')), context=context)
            price_list = request.registry[
                'website'].price_list_get(cr, uid, context)
            product_data = request.registry['product.template'].browse(
                cr, uid, prod_ids, {'pricelist': int(price_list)})
            if product_data:
                value['products'] = product_data
                if post.get('slider_type') == 'is_arrival':
                    if post.get('product_label'):
                        value['header'] = post.get('product_label')
                    else:
                        value['header'] = "LANZAMIENTOS"
                if post.get('slider_type') == 'is_features':
                    if post.get('product_label'):
                        value['header'] = post.get('product_label')
                    else:
                        value['header'] = "FEATURES PRODUCT"
        if post.get('product_label'):
            value['header'] = post.get('product_label')
        return request.website.render("kingfisher.product_snippet", value)

    @http.route(['/shop/get_brand_slider'], type='http', auth='public', website=True)
    def get_brand_slider(self, **post):
        cr, uid, context = request.cr, request.uid, request.context
        value = {'brand_header': False}
        if post.get('product_label'):
            value['brand_header'] = post.get('product_label')
        return request.website.render("kingfisher.our_brand_slider", value)

    @http.route(['/shop/cart/update'], type='http', auth="public", methods=['POST'], website=True)
    def cart_update(self, product_id, add_qty=1, set_qty=0, **kw):
        cr, uid, context = request.cr, request.uid, request.context
        request.website.sale_get_order(force_create=1)._cart_update(product_id=int(product_id), add_qty=float(add_qty), set_qty=float(set_qty))
        #return request.redirect("/shop/cart")
	prod_obj = request.registry.get('product.product')
        product = prod_obj.browse(cr,uid,int(product_id),context=context)
        tpl_obj = request.registry('product.template')
        tpl_ids = tpl_obj.search(cr,uid, [('id', '=', product.product_tmpl_id.id)],context=context);
        template = tpl_obj.browse(cr,uid,tpl_ids, context=context)

	return request.redirect('/shop/product/%s' % slug(template))

class product_zoom_config(website_sale):

    @http.route(['/product/zoom_type'], type='json', auth="public", website=True)
    def get_zoom_type(self, type_id=None):
        cr, uid, context = request.cr, request.uid, request.context
        result=False
        result=request.website.inner_zoom
        return result


# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: