XuanHuyen
298 lines
16 KiB
Python
298 lines
16 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
|
from odoo import _, http
|
|
from odoo.http import request, Response
|
|
from datetime import datetime
|
|
from markupsafe import Markup
|
|
from odoo.addons.website_slides.controllers.main import WebsiteSlides
|
|
|
|
|
|
class WebsiteSlidesORA(WebsiteSlides):
|
|
|
|
@http.route('/ora/response/save/', type='http', auth="user", website=True)
|
|
def save_response(self, **kwargs):
|
|
user_response = self._get_access_data(kwargs)
|
|
slide = request.env['slide.slide'].sudo().browse(int(kwargs.get('slide_id')))
|
|
if kwargs.get('submit') == 'save':
|
|
self.add_answers(kwargs, user_response)
|
|
if kwargs.get('submit') == 'resubmit_fresh':
|
|
self._get_access_data(kwargs, resubmit=True)
|
|
user_response.state = 'inactive'
|
|
if kwargs.get('submit') == 'resubmit_copy':
|
|
resubmit_copy_response = self._get_access_data(kwargs, resubmit=True)
|
|
self.add_answers(kwargs, resubmit_copy_response)
|
|
user_response.state = 'inactive'
|
|
if kwargs.get('submit') == 'submit':
|
|
if len(user_response) > 1:
|
|
user_response = user_response[-1]
|
|
user_response.state = 'submitted'
|
|
user_response.submitted_date = datetime.now()
|
|
self.add_answers(kwargs, user_response)
|
|
if slide.peer_assessment:
|
|
peer_limit = slide.peer_limit
|
|
enrolled_users = slide.channel_id.partner_ids.filtered(lambda l: l.id != request.env.user.partner_id.id)
|
|
if peer_limit <= len(enrolled_users):
|
|
peer_limit = peer_limit
|
|
else:
|
|
peer_limit = len(enrolled_users)
|
|
for _ in range(peer_limit):
|
|
peer_user = slide._get_peer_user(user_response)
|
|
if peer_user:
|
|
request.env['open.response.rubric.staff'].create({
|
|
'assess_type': 'peer',
|
|
'user_id': peer_user.id,
|
|
'state': 'in_progress',
|
|
'response_id': user_response.id
|
|
})
|
|
user_response.message_post(
|
|
body='This response has been submitted!', message_type='notification',
|
|
subtype_xmlid='mail.mt_comment', author_id=request.env.user.partner_id.id,
|
|
partner_ids=[user_response.staff_id.partner_id.id])
|
|
return request.redirect('/slides/slide/%s' % request.env['ir.http']._slug(slide))
|
|
|
|
def _get_access_data(self, post, resubmit=False):
|
|
user = request.env.user
|
|
slide_id = request.env['slide.slide'].sudo().browse(int(post.get('slide_id')))
|
|
if slide_id.response_ids and not resubmit:
|
|
response = slide_id.response_ids.filtered(lambda x: x.state in ['active', 'submitted'] and x.user_id == user)
|
|
if response:
|
|
return response
|
|
response = slide_id._create_answer(request.env.user.id)
|
|
return response
|
|
|
|
def add_answers(self, kwargs, response):
|
|
if kwargs.get('response_id'):
|
|
old_user_response = request.env['ora.response'].browse(int(kwargs.get('response_id')))
|
|
for line in response.user_response_line:
|
|
for oline in old_user_response.user_response_line:
|
|
if line.prompt_id == oline.prompt_id:
|
|
if line.response_type == 'text':
|
|
line.value_text_box = oline.value_text_box
|
|
elif line.response_type == 'rich_text':
|
|
line.value_richtext_box = Markup(oline.value_richtext_box)
|
|
# query = ("update open_response_user_line set value_richtext_box='%s' where id=%s") % (oline.value_richtext_box, oline.id)
|
|
# request.cr.execute(query)
|
|
else:
|
|
for line in response.user_response_line:
|
|
if line.response_type == 'text':
|
|
line.value_text_box = kwargs[str(line.prompt_id.id)]
|
|
elif line.response_type == 'rich_text':
|
|
line.value_richtext_box = Markup(kwargs[str(line.prompt_id.id)])
|
|
# query = ("update open_response_user_line set value_richtext_box='%s' where id='%s'") % (Markup(kwargs[str(line.prompt_id.id)]), line.id)
|
|
# request.cr.execute(query)
|
|
|
|
def _prepare_additional_channel_values(self, values, **kwargs):
|
|
values = super(WebsiteSlidesORA, self)._prepare_additional_channel_values(values, **kwargs)
|
|
slide = values.get('slide')
|
|
submitted = False
|
|
if slide and slide.prompt_ids:
|
|
values.update({
|
|
'slide_prompts': [{
|
|
'id': prompt.id,
|
|
'sequence': prompt.sequence,
|
|
'question': Markup(prompt.question_name),
|
|
'response_type': prompt.response_type,
|
|
'submitted': submitted,
|
|
'name': prompt.name,
|
|
} for prompt in slide.prompt_ids.sorted(key=lambda x: x.id)]
|
|
})
|
|
if slide and slide.response_ids:
|
|
total_responses = slide.response_ids.filtered(lambda l: l.user_id == request.env.user)
|
|
submitted_response = total_responses.filtered(lambda l: l.state == 'submitted')
|
|
active_response = total_responses.filtered(lambda l: l.state == 'active')
|
|
inactive_response = total_responses.filtered(lambda l: l.state == 'inactive')
|
|
assessed_response = total_responses.filtered(lambda l: l.state == 'assessed')
|
|
values['submitted_response'] = submitted_response
|
|
values['active_response'] = active_response
|
|
values['inactive_response'] = inactive_response
|
|
values['total_responses'] = total_responses
|
|
values['assessed_response'] = assessed_response
|
|
values['rubric_ids'] = slide.rubric_ids
|
|
# if assessed_response:
|
|
# values['channel_progress'][slide.id]['quiz_karma_gain'] += assessed_response.xp_points
|
|
# values['channel_progress'][slide.id]['quiz_karma_won'] += assessed_response.xp_points
|
|
for response in total_responses:
|
|
if response.feedback == '<p><br></p>':
|
|
response.feedback = False
|
|
values['peer_responses'] = request.env['open.response.rubric.staff'].search([
|
|
('user_id', '=', request.env.user.id),
|
|
('assess_type', '=', 'peer'),
|
|
('response_id.state', 'in', ['submitted', 'assessed']),
|
|
('response_id.slide_id', '=', slide.id)
|
|
]).mapped('response_id')
|
|
return values
|
|
|
|
@http.route('/slides/slide/get_values', website=True, type="json", auth="user")
|
|
def slide_get_value(self, slide_id):
|
|
csrf_token = request.csrf_token()
|
|
slide = request.env['slide.slide'].browse(slide_id)
|
|
if slide:
|
|
values = {'slide': self._get_slide_values(slide), 'csrf_token': csrf_token}
|
|
if slide.prompt_ids:
|
|
values.update({
|
|
'slide_prompts': [{
|
|
'id': prompt.id,
|
|
'sequence': prompt.sequence,
|
|
'question': Markup(prompt.question_name),
|
|
'response_type': prompt.response_type,
|
|
'name': prompt.name,
|
|
} for prompt in slide.prompt_ids.sorted(key=lambda x: x.id)]
|
|
})
|
|
if slide.response_ids:
|
|
total_responses = slide.response_ids.filtered(lambda l: l.user_id == request.env.user)
|
|
values['total_responses'] = []
|
|
for ora_response in total_responses:
|
|
if ora_response.feedback == '<p><br></p>' or ora_response.feedback == False:
|
|
ora_response.feedback = ''
|
|
values['total_responses'].append(self._get_total_responses(ora_response, slide))
|
|
peer_response_ids = request.env['open.response.rubric.staff'].search([
|
|
('user_id', '=', request.env.user.id),
|
|
('assess_type', '=', 'peer'),
|
|
('response_id.state', 'in', ['submitted', 'assessed']),
|
|
('response_id.slide_id', '=', slide.id)
|
|
])
|
|
values['peer_responses'] = []
|
|
for staff_response in peer_response_ids:
|
|
submitted_date = False
|
|
if staff_response.submitted_date:
|
|
submitted_date = staff_response.submitted_date.strftime('%d %B %Y')
|
|
values['peer_responses'].append(({
|
|
'id': staff_response.response_id.id,
|
|
'state': staff_response.state,
|
|
'assess_type': staff_response.assess_type,
|
|
'user_id': staff_response.user_id.id,
|
|
'submitted_date': submitted_date,
|
|
'option_ids': [{
|
|
'id': rubric_id.criteria_id.id,
|
|
'criterian_name': rubric_id.criteria_id.criterian_name,
|
|
'criteria_desc': rubric_id.criteria_desc,
|
|
'name': rubric_id.option_id.name,
|
|
'criteria_option_point': rubric_id.criteria_option_point,
|
|
'criteria_option_desc': rubric_id.criteria_option_desc,
|
|
'assess_explanation': rubric_id.assess_explanation,
|
|
} for rubric_id in staff_response.option_ids],
|
|
'user_response_line': [self._get_user_response(user_response_line) for user_response_line in staff_response.response_id.user_response_line]
|
|
}))
|
|
return values
|
|
|
|
def _get_slide_values(self, slide):
|
|
next_slide = slide.channel_id.slide_content_ids[((slide.channel_id.slide_content_ids.ids).index(slide.id))+1] if ((slide.channel_id.slide_content_ids.ids).index(slide.id)) < len(slide.channel_id.slide_content_ids.ids) - 1 else None
|
|
return {
|
|
'id': slide.id,
|
|
'is_member': slide.channel_id.is_member,
|
|
'is_preview': slide.is_preview,
|
|
'peer_assessment': slide.peer_assessment,
|
|
'completed': (request.env['slide.slide.partner'].sudo().search([('slide_id', '=', slide.id),('partner_id', '=', request.env.user.partner_id.id)])).completed,
|
|
'hasNext' : next_slide if next_slide else None,
|
|
'ispro' : 1 if 'is_sequential' in request.env['slide.channel']._fields else None,
|
|
'next_slide_url': '/slides/slide/%s?fullscreen=1' % request.env['ir.http']._slug(next_slide) if next_slide else None,
|
|
'user': request.env.user.id,
|
|
'rubric_ids': [{
|
|
'criterian_name': rubric.criterian_name,
|
|
'name': rubric.name,
|
|
'id': rubric.id,
|
|
'criterian_ids': [{
|
|
'id': option.id,
|
|
'name': option.name,
|
|
} for option in rubric.criterian_ids],
|
|
}for rubric in slide.rubric_ids],
|
|
}
|
|
|
|
def _get_user_response(self, user_response_line):
|
|
return {
|
|
'id': user_response_line.id,
|
|
'prompt_id': user_response_line.prompt_id.id,
|
|
'value_text_box': user_response_line.value_text_box,
|
|
'value_richtext_box': Markup(user_response_line.value_richtext_box),
|
|
}
|
|
|
|
def _get_total_responses(self, ora_response, slide):
|
|
submitted_date = False
|
|
if ora_response.submitted_date:
|
|
submitted_date = ora_response.submitted_date.strftime('%d %B %Y')
|
|
return {
|
|
'id': ora_response.id,
|
|
'user': request.env.user.id,
|
|
'state': ora_response.state,
|
|
'feedback': Markup(ora_response.feedback),
|
|
'staff_id': ora_response.sudo().staff_id.id,
|
|
'staff_name': ora_response.sudo().staff_id.name,
|
|
'user_name': ora_response.sudo().user_id.name,
|
|
'submitted_date': submitted_date,
|
|
'can_resubmit': ora_response.can_resubmit,
|
|
'feedback_user_image_url': request.website.image_url(ora_response.sudo().staff_id, 'image_1920', size=256),
|
|
'ora_res_user_image_url': request.website.image_url(ora_response.sudo().user_id, 'image_1920', size=256),
|
|
'user_response_line': [self._get_user_response(user_response_line) for user_response_line in ora_response.user_response_line],
|
|
'slide_rubric_staff_line': [{
|
|
'state': staff_line.state,
|
|
'assess_type': staff_line.assess_type,
|
|
'user_id': staff_line.sudo().user_id.id,
|
|
'option_ids': [{
|
|
'id': rubric_id.criteria_id.id,
|
|
'criterian_name': rubric_id.criteria_id.criterian_name,
|
|
'criteria_desc': rubric_id.criteria_desc,
|
|
'name': rubric_id.option_id.name,
|
|
'criteria_option_point': rubric_id.criteria_option_point,
|
|
'criteria_option_desc': rubric_id.criteria_option_desc,
|
|
'assess_explanation': rubric_id.assess_explanation,
|
|
} for rubric_id in staff_line.option_ids],
|
|
}for staff_line in ora_response.slide_rubric_staff_line],
|
|
'rubric_ids': [{
|
|
'criterian_name': rubric.criterian_name,
|
|
'name': rubric.name,
|
|
'id': rubric.id,
|
|
'criterian_ids': [{
|
|
'id': option.id,
|
|
'name': option.name,
|
|
} for option in rubric.criterian_ids],
|
|
}for rubric in slide.rubric_ids],
|
|
}
|
|
|
|
@http.route('/submit/peer/response', type='http', auth="user", website=True)
|
|
def submit_peer_response(self, **kwargs):
|
|
slide = request.env['slide.slide'].sudo().browse(int(kwargs.get('slide_id')))
|
|
if kwargs.get('response_id'):
|
|
response_id = request.env['ora.response'].browse(int(kwargs.get('response_id')))
|
|
for line in response_id.slide_rubric_staff_line:
|
|
if line.user_id == request.env.user and line.assess_type == 'peer':
|
|
values = []
|
|
for criteria in response_id.slide_id.rubric_ids:
|
|
opt_key = ''
|
|
exp_key = ''
|
|
for option_id in criteria.criterian_ids:
|
|
opt_key = 'options_%s_%s' % (response_id.id, criteria.id)
|
|
exp_key = 'exp_%s_%s' % (response_id.id, criteria.id)
|
|
if opt_key in kwargs and exp_key in kwargs:
|
|
break
|
|
option_id = kwargs.get(opt_key)
|
|
values.append((0, 0, {
|
|
'criteria_id': criteria.id,
|
|
'option_id': int(option_id) if option_id else False,
|
|
'assess_explanation': kwargs.get(exp_key)
|
|
}))
|
|
line.option_ids = values
|
|
line.state = 'completed'
|
|
line.submitted_date = datetime.now()
|
|
return request.redirect('/slides/slide/%s' % request.env['ir.http']._slug(slide))
|
|
|
|
def _get_channel_progress(self, channel, include_quiz=False):
|
|
result = super(WebsiteSlidesORA, self)._get_channel_progress(channel, include_quiz=include_quiz)
|
|
slides = request.env['slide.slide'].sudo().search([('channel_id', '=', channel.id)])
|
|
ora_response_ids = request.env['ora.response'].sudo().search([
|
|
('slide_id', 'in', slides.ids),
|
|
('state', '=', 'assessed'),
|
|
('user_id', '=', request.env.user.id)
|
|
])
|
|
for ora_response in ora_response_ids:
|
|
result[ora_response.slide_id.id]['quiz_karma_gain'] += ora_response.xp_points
|
|
result[ora_response.slide_id.id]['quiz_karma_won'] += ora_response.xp_points
|
|
return result
|
|
|
|
@http.route(['/slides/channel/leave'], type='json', auth='user', website=True)
|
|
def slide_channel_leave(self, channel_id):
|
|
slide_ids = request.env['slide.slide'].sudo().search([('channel_id','=',int(channel_id))])
|
|
for slide_id in slide_ids:
|
|
request.env['ora.response'].sudo().search([('user_id','=',int(request.env.uid)),('slide_id','=', int(slide_id))]).unlink()
|
|
res = super(WebsiteSlidesORA, self).slide_channel_leave(channel_id)
|
|
return res
|