1 # -*- coding: utf-8 -*-
2 ##############################################################################
4 # OpenERP, Open Source Management Solution
5 # Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>).
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.
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.
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/>.
20 ##############################################################################
22 from base_status.base_stage import base_stage
24 from datetime import datetime, timedelta
26 from osv import fields, osv
30 from tools.translate import _
34 ('cancel', 'Refused'),
35 ('open', 'In Progress'),
36 ('pending', 'Pending'),
40 AVAILABLE_PRIORITIES = [
49 class hr_recruitment_source(osv.osv):
50 """ Sources of HR Recruitment """
51 _name = "hr.recruitment.source"
52 _description = "Source of Applicants"
54 'name': fields.char('Source Name', size=64, required=True, translate=True),
57 class hr_recruitment_stage(osv.osv):
58 """ Stage of HR Recruitment """
59 _name = "hr.recruitment.stage"
60 _description = "Stage of Recruitment"
63 'name': fields.char('Name', size=64, required=True, translate=True),
64 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
65 'department_id':fields.many2one('hr.department', 'Specific to a Department', help="Stages of the recruitment process may be different per department. If this stage is common to all departments, keep tempy this field."),
66 'state': fields.selection(AVAILABLE_STATES, 'State', required=True, help="The related state for the stage. The state of your document will automatically change regarding the selected stage. Example, a stage is related to the state 'Close', when your document reach this stage, it will be automatically closed."),
67 'fold': fields.boolean('Hide in views if empty', help="This stage is not visible, for example in status bar or kanban view, when there are no records in that stage to display."),
68 'requirements': fields.text('Requirements'),
76 class hr_recruitment_degree(osv.osv):
77 """ Degree of HR Recruitment """
78 _name = "hr.recruitment.degree"
79 _description = "Degree of Recruitment"
81 'name': fields.char('Name', size=64, required=True, translate=True),
82 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of degrees."),
88 ('name_uniq', 'unique (name)', 'The name of the Degree of Recruitment must be unique!')
91 class hr_applicant(base_stage, osv.Model):
92 _name = "hr.applicant"
93 _description = "Applicant"
95 _inherit = ['ir.needaction_mixin', 'mail.thread']
96 _mail_compose_message = True
98 def _get_default_department_id(self, cr, uid, context=None):
99 """ Gives default department by checking if present in the context """
100 return (self._resolve_department_id_from_context(cr, uid, context=context) or False)
102 def _get_default_stage_id(self, cr, uid, context=None):
103 """ Gives default stage_id """
104 department_id = self._get_default_department_id(cr, uid, context=context)
105 return self.stage_find(cr, uid, [], department_id, [('state', '=', 'draft')], context=context)
107 def _resolve_department_id_from_context(self, cr, uid, context=None):
108 """ Returns ID of department based on the value of 'default_department_id'
109 context key, or None if it cannot be resolved to a single
114 if type(context.get('default_department_id')) in (int, long):
115 return context.get('default_department_id')
116 if isinstance(context.get('default_department_id'), basestring):
117 department_name = context['default_department_id']
118 department_ids = self.pool.get('hr.department').name_search(cr, uid, name=department_name, context=context)
119 if len(department_ids) == 1:
120 return int(department_ids[0][0])
123 def _read_group_stage_ids(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
124 access_rights_uid = access_rights_uid or uid
125 stage_obj = self.pool.get('hr.recruitment.stage')
126 order = stage_obj._order
127 # lame hack to allow reverting search, should just work in the trivial case
128 if read_group_order == 'stage_id desc':
129 order = "%s desc" % order
130 # retrieve section_id from the context and write the domain
131 # - ('id', 'in', 'ids'): add columns that should be present
132 # - OR ('department_id', '=', False), ('fold', '=', False): add default columns that are not folded
133 # - OR ('department_id', 'in', department_id), ('fold', '=', False) if department_id: add department columns that are not folded
134 department_id = self._resolve_department_id_from_context(cr, uid, context=context)
137 search_domain += ['|', '&', ('department_id', '=', department_id), ('fold', '=', False)]
138 search_domain += ['|', ('id', 'in', ids), '&', ('department_id', '=', False), ('fold', '=', False)]
139 stage_ids = stage_obj._search(cr, uid, search_domain, order=order, access_rights_uid=access_rights_uid, context=context)
140 result = stage_obj.name_get(cr, access_rights_uid, stage_ids, context=context)
141 # restore order of the search
142 result.sort(lambda x,y: cmp(stage_ids.index(x[0]), stage_ids.index(y[0])))
145 def _compute_day(self, cr, uid, ids, fields, args, context=None):
147 @param cr: the current row, from the database cursor,
148 @param uid: the current user’s ID for security checks,
149 @param ids: List of Openday’s IDs
150 @return: difference between current date and log date
151 @param context: A standard dictionary for contextual values
154 for issue in self.browse(cr, uid, ids, context=context):
161 if field in ['day_open']:
163 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
164 date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
165 ans = date_open - date_create
166 date_until = issue.date_open
168 elif field in ['day_close']:
169 if issue.date_closed:
170 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
171 date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
172 date_until = issue.date_closed
173 ans = date_close - date_create
175 duration = float(ans.days)
176 res[issue.id][field] = abs(float(duration))
180 'name': fields.char('Name', size=128, required=True),
181 'active': fields.boolean('Active', help="If the active field is set to false, it will allow you to hide the case without removing it."),
182 'description': fields.text('Description'),
183 'email_from': fields.char('Email', size=128, help="These people will receive email."),
184 'email_cc': fields.text('Watchers Emails', size=252, help="These email addresses will be added to the CC field of all inbound and outbound emails for this record before being sent. Separate multiple email addresses with a comma"),
185 'probability': fields.float('Probability'),
186 'partner_id': fields.many2one('res.partner', 'Contact'),
187 'create_date': fields.datetime('Creation Date', readonly=True, select=True),
188 'write_date': fields.datetime('Update Date', readonly=True),
189 'stage_id': fields.many2one ('hr.recruitment.stage', 'Stage',
190 domain="['|', ('department_id', '=', department_id), ('department_id', '=', False)]"),
191 'state': fields.related('stage_id', 'state', type="selection", store=True,
192 selection=AVAILABLE_STATES, string="State", readonly=True,
193 help='The state is set to \'Draft\', when a case is created.\
194 If the case is in progress the state is set to \'Open\'.\
195 When the case is over, the state is set to \'Done\'.\
196 If the case needs to be reviewed then the state is \
197 set to \'Pending\'.'),
198 'company_id': fields.many2one('res.company', 'Company'),
199 'user_id': fields.many2one('res.users', 'Responsible'),
201 'date_closed': fields.datetime('Closed', readonly=True, select=True),
202 'date_open': fields.datetime('Opened', readonly=True, select=True),
203 'date': fields.datetime('Date'),
204 'date_action': fields.date('Next Action Date'),
205 'title_action': fields.char('Next Action', size=64),
206 'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
207 'job_id': fields.many2one('hr.job', 'Applied Job'),
208 'salary_proposed_extra': fields.char('Proposed Salary Extra', size=100, help="Salary Proposed by the Organisation, extra advantages"),
209 'salary_expected_extra': fields.char('Expected Salary Extra', size=100, help="Salary Expected by Applicant, extra advantages"),
210 'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
211 'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
212 'availability': fields.integer('Availability (Days)'),
213 'partner_name': fields.char("Applicant's Name", size=64),
214 'partner_phone': fields.char('Phone', size=32),
215 'partner_mobile': fields.char('Mobile', size=32),
216 'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
217 'department_id': fields.many2one('hr.department', 'Department'),
218 'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
219 'response': fields.integer("Response"),
220 'reference': fields.char('Referred By', size=128),
221 'source_id': fields.many2one('hr.recruitment.source', 'Source'),
222 'day_open': fields.function(_compute_day, string='Days to Open', \
223 multi='day_open', type="float", store=True),
224 'day_close': fields.function(_compute_day, string='Days to Close', \
225 multi='day_close', type="float", store=True),
226 'color': fields.integer('Color Index'),
227 'emp_id': fields.many2one('hr.employee', 'employee'),
228 'user_email': fields.related('user_id', 'user_email', type='char', string='User Email', readonly=True),
232 'active': lambda *a: 1,
233 'user_id': lambda s, cr, uid, c: uid,
234 'email_from': lambda s, cr, uid, c: s._get_default_email(cr, uid, c),
235 'stage_id': lambda s, cr, uid, c: s._get_default_stage_id(cr, uid, c),
236 'department_id': lambda s, cr, uid, c: s._get_default_department_id(cr, uid, c),
237 'priority': lambda *a: '',
238 'company_id': lambda s, cr, uid, c: s.pool.get('res.company')._company_default_get(cr, uid, 'hr.applicant', context=c),
243 'stage_id': _read_group_stage_ids
246 def onchange_job(self,cr, uid, ids, job, context=None):
250 job_obj = self.pool.get('hr.job')
251 result['department_id'] = job_obj.browse(cr, uid, job, context=context).department_id.id
252 return {'value': result}
253 return {'value': {'department_id': False}}
255 def onchange_department_id(self, cr, uid, ids, department_id=False, context=None):
256 if not department_id:
257 return {'value': {'stage_id': False}}
258 obj_recru_stage = self.pool.get('hr.recruitment.stage')
259 stage_ids = obj_recru_stage.search(cr, uid, ['|',('department_id','=',department_id),('department_id','=',False)], context=context)
260 stage_id = stage_ids and stage_ids[0] or False
261 return {'value': {'stage_id': stage_id}}
263 def stage_find(self, cr, uid, cases, section_id, domain=[], order='sequence', context=None):
264 """ Override of the base.stage method
265 Parameter of the stage search taken from the lead:
266 - department_id: if set, stages must belong to this section or
269 if isinstance(cases, (int, long)):
270 cases = self.browse(cr, uid, cases, context=context)
271 # collect all section_ids
274 department_ids.append(section_id)
276 if case.department_id:
277 department_ids.append(case.department_id.id)
278 # OR all section_ids and OR with case_default
281 search_domain += ['|', ('department_id', 'in', department_ids)]
282 search_domain.append(('department_id', '=', False))
283 # AND with the domain in parameter
284 search_domain += list(domain)
285 # perform search, return the first found
286 stage_ids = self.pool.get('hr.recruitment.stage').search(cr, uid, search_domain, order=order, context=context)
291 def action_makeMeeting(self, cr, uid, ids, context=None):
293 This opens Meeting's calendar view to schedule meeting on current Opportunity
294 @param self: The object pointer
295 @param cr: the current row, from the database cursor,
296 @param uid: the current user’s ID for security checks,
297 @param ids: List of Opportunity to Meeting IDs
298 @param context: A standard dictionary for contextual values
300 @return: Dictionary value for created Meeting view
302 data_obj = self.pool.get('ir.model.data')
306 for opp in self.browse(cr, uid, ids, context=context):
308 search_view = data_obj.get_object(cr, uid, 'crm', 'view_crm_case_meetings_filter', context)
309 calendar_view = data_obj.get_object(cr, uid, 'crm', 'crm_case_calendar_view_meet', context)
310 form_view = data_obj.get_object(cr, uid, 'crm', 'crm_case_form_view_meet', context)
311 tree_view = data_obj.get_object(cr, uid, 'crm', 'crm_case_tree_view_meet', context)
312 category = data_obj.get_object(cr, uid, 'hr_recruitment', 'categ_meet_interview', context)
314 'default_applicant_id': opp.id,
315 'default_partner_id': opp.partner_id and opp.partner_id.id or False,
316 'default_email_from': opp.email_from,
317 'default_state': 'open',
318 'default_categ_id': category.id,
319 'default_name': opp.name,
322 'name': ('Meetings'),
323 'domain': "[('user_id','=',%s)]" % (uid),
326 'view_mode': 'calendar,form,tree',
327 'res_model': 'crm.meeting',
329 'views': [(calendar_view.id, 'calendar'), (form_view.id, 'form'), (tree_view.id, 'tree')],
330 'type': 'ir.actions.act_window',
331 'search_view_id': search_view.id,
336 def action_print_survey(self, cr, uid, ids, context=None):
338 If response is available then print this response otherwise print survey form(print template of the survey).
340 @param self: The object pointer
341 @param cr: the current row, from the database cursor,
342 @param uid: the current user’s ID for security checks,
343 @param ids: List of Survey IDs
344 @param context: A standard dictionary for contextual values
345 @return: Dictionary value for print survey form.
349 record = self.browse(cr, uid, ids, context=context)
350 record = record and record[0]
351 context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
352 value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
355 def message_new(self, cr, uid, msg, custom_values=None, context=None):
356 """ Overrides mail_thread message_new that is called by the mailgateway
357 through message_process.
358 This override updates the document according to the email.
360 if custom_values is None: custom_values = {}
361 custom_values.update({
362 'name': msg.get('subject') or _("No Subject"),
363 'description': msg.get('body_text'),
364 'email_from': msg.get('from'),
365 'email_cc': msg.get('cc'),
368 if msg.get('priority'):
369 custom_values['priority'] = msg.get('priority')
370 custom_values.update(self.message_partner_by_email(cr, uid, msg.get('from', False), context=context))
371 return super(hr_applicant,self).message_new(cr, uid, msg, custom_values=custom_values, context=context)
373 def message_update(self, cr, uid, ids, msg, update_vals=None, context=None):
374 """ Override mail_thread message_update that is called by the mailgateway
375 through message_process.
376 This method updates the document according to the email.
378 if isinstance(ids, (str, int, long)):
380 if update_vals is None: vals = {}
383 'description': msg.get('body'),
384 'email_from': msg.get('from'),
385 'email_cc': msg.get('cc'),
387 if msg.get('priority'):
388 update_vals['priority'] = msg.get('priority')
391 'cost': 'planned_cost',
392 'revenue': 'planned_revenue',
393 'probability': 'probability',
395 for line in msg.get('body_text', '').split('\n'):
397 res = tools.misc.command_re.match(line)
398 if res and maps.get(res.group(1).lower(), False):
399 key = maps.get(res.group(1).lower())
400 update_vals[key] = res.group(2).lower()
402 return super(hr_applicant, self).message_update(cr, uids, ids, update_vals=update_vals, context=context)
404 def create(self, cr, uid, vals, context=None):
405 obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
406 self.create_send_note(cr, uid, [obj_id], context=context)
409 def case_open(self, cr, uid, ids, context=None):
411 open Request of the applicant for the hr_recruitment
413 res = super(hr_applicant, self).case_open(cr, uid, ids, context)
414 date = self.read(cr, uid, ids, ['date_open'])[0]
415 if not date['date_open']:
416 self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
419 def case_close(self, cr, uid, ids, context=None):
420 res = super(hr_applicant, self).case_close(cr, uid, ids, context)
423 def case_close_with_emp(self, cr, uid, ids, context=None):
426 hr_employee = self.pool.get('hr.employee')
427 model_data = self.pool.get('ir.model.data')
428 act_window = self.pool.get('ir.actions.act_window')
430 for applicant in self.browse(cr, uid, ids, context=context):
432 if applicant.partner_id:
433 address_id = applicant.partner_id.address_get(['contact'])['contact']
435 applicant.job_id.write({'no_of_recruitment': applicant.job_id.no_of_recruitment - 1})
436 emp_id = hr_employee.create(cr,uid,{'name': applicant.partner_name or applicant.name,
437 'job_id': applicant.job_id.id,
438 'address_home_id': address_id,
439 'department_id': applicant.department_id.id
441 self.write(cr, uid, [applicant.id], {'emp_id': emp_id}, context=context)
442 self.case_close(cr, uid, [applicant.id], context)
444 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
446 action_model, action_id = model_data.get_object_reference(cr, uid, 'hr', 'open_view_employee_list')
447 dict_act_window = act_window.read(cr, uid, action_id, [])
449 dict_act_window['res_id'] = emp_id
450 dict_act_window['view_mode'] = 'form,tree'
451 return dict_act_window
453 def case_cancel(self, cr, uid, ids, context=None):
454 """Overrides cancel for crm_case for setting probability
456 res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
457 self.write(cr, uid, ids, {'probability' : 0.0})
460 def case_pending(self, cr, uid, ids, context=None):
461 """Marks case as pending"""
462 res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
463 self.write(cr, uid, ids, {'probability' : 0.0})
466 def case_reset(self, cr, uid, ids, context=None):
467 """Resets case as draft
469 res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
470 self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
473 def set_priority(self, cr, uid, ids, priority, *args):
474 """Set applicant priority
476 return self.write(cr, uid, ids, {'priority' : priority})
478 def set_high_priority(self, cr, uid, ids, *args):
479 """Set applicant priority to high
481 return self.set_priority(cr, uid, ids, '1')
483 def set_normal_priority(self, cr, uid, ids, *args):
484 """Set applicant priority to normal
486 return self.set_priority(cr, uid, ids, '3')
488 # -------------------------------------------------------
489 # OpenChatter methods and notifications
490 # -------------------------------------------------------
492 def message_get_subscribers(self, cr, uid, ids, context=None):
493 """ Override to add responsible user. """
494 user_ids = super(hr_applicant, self).message_get_subscribers(cr, uid, ids, context=context)
495 for obj in self.browse(cr, uid, ids, context=context):
496 if obj.user_id and not obj.user_id.id in user_ids:
497 user_ids.append(obj.user_id.id)
500 def stage_set_send_note(self, cr, uid, ids, stage_id, context=None):
501 """ Override of the (void) default notification method. """
502 if not stage_id: return True
503 stage_name = self.pool.get('hr.recruitment.stage').name_get(cr, uid, [stage_id], context=context)[0][1]
504 return self.message_append_note(cr, uid, ids, body= _("Stage changed to <b>%s</b>.") % (stage_name), context=context)
506 def case_get_note_msg_prefix(self, cr, uid, id, context=None):
509 def case_open_send_note(self, cr, uid, ids, context=None):
510 message = _("Applicant has been set <b>in progress</b>.")
511 return self.message_append_note(cr, uid, ids, body=message, context=context)
513 def case_close_send_note(self, cr, uid, ids, context=None):
516 for applicant in self.browse(cr, uid, ids, context=context):
518 message = _("Applicant has been <b>hired</b> and created as an employee.")
519 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
521 message = _("Applicant has been <b>hired</b>.")
522 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
525 def case_cancel_send_note(self, cr, uid, ids, context=None):
526 msg = 'Applicant <b>refused</b>.'
527 return self.message_append_note(cr, uid, ids, body=msg, context=context)
529 def case_reset_send_note(self, cr, uid, ids, context=None):
530 message =_("Applicant has been set as <b>new</b>.")
531 return self.message_append_note(cr, uid, ids, body=message, context=context)
533 def create_send_note(self, cr, uid, ids, context=None):
534 message = _("Applicant has been <b>created</b>.")
535 return self.message_append_note(cr, uid, ids, body=message, context=context)
538 class hr_job(osv.osv):
542 'survey_id': fields.many2one('survey', 'Interview Form', help="Choose an interview form for this job position and you will be able to print/answer this interview from all applicants who apply for this job"),
545 def action_print_survey(self, cr, uid, ids, context=None):
549 record = self.browse(cr, uid, ids, context=context)[0]
551 datas['ids'] = [record.survey_id.id]
552 datas['model'] = 'survey.print'
553 context.update({'response_id': [0], 'response_no': 0,})
555 'type': 'ir.actions.report.xml',
556 'report_name': 'survey.form',
563 class crm_meeting(osv.osv):
564 _inherit = 'crm.meeting'
566 'applicant_id': fields.many2one('hr.applicant','Applicant'),
569 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: