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 ##############################################################################
25 from base_status.base_stage import base_stage
26 from datetime import datetime
27 from osv import fields, osv
28 from tools.translate import _
29 from tools import html2plaintext
33 ('cancel', 'Refused'),
34 ('open', 'In Progress'),
35 ('pending', 'Pending'),
39 AVAILABLE_PRIORITIES = [
48 class hr_recruitment_source(osv.osv):
49 """ Sources of HR Recruitment """
50 _name = "hr.recruitment.source"
51 _description = "Source of Applicants"
53 'name': fields.char('Source Name', size=64, required=True, translate=True),
56 class hr_recruitment_stage(osv.osv):
57 """ Stage of HR Recruitment """
58 _name = "hr.recruitment.stage"
59 _description = "Stage of Recruitment"
62 'name': fields.char('Name', size=64, required=True, translate=True),
63 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
64 '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 this field empty."),
65 'state': fields.selection(AVAILABLE_STATES, 'Status', required=True, help="The related status for the stage. The status of your document will automatically change according to the selected stage. Example, a stage is related to the status 'Close', when your document reach this stage, it will be automatically closed."),
66 '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."),
67 'requirements': fields.text('Requirements'),
75 class hr_recruitment_degree(osv.osv):
76 """ Degree of HR Recruitment """
77 _name = "hr.recruitment.degree"
78 _description = "Degree of Recruitment"
80 'name': fields.char('Name', size=64, required=True, translate=True),
81 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of degrees."),
87 ('name_uniq', 'unique (name)', 'The name of the Degree of Recruitment must be unique!')
90 class hr_applicant(base_stage, osv.Model):
91 _name = "hr.applicant"
92 _description = "Applicant"
94 _inherit = ['mail.thread', 'ir.needaction_mixin']
96 def _get_default_department_id(self, cr, uid, context=None):
97 """ Gives default department by checking if present in the context """
98 return (self._resolve_department_id_from_context(cr, uid, context=context) or False)
100 def _get_default_stage_id(self, cr, uid, context=None):
101 """ Gives default stage_id """
102 department_id = self._get_default_department_id(cr, uid, context=context)
103 return self.stage_find(cr, uid, [], department_id, [('state', '=', 'draft')], context=context)
105 def _resolve_department_id_from_context(self, cr, uid, context=None):
106 """ Returns ID of department based on the value of 'default_department_id'
107 context key, or None if it cannot be resolved to a single
112 if type(context.get('default_department_id')) in (int, long):
113 return context.get('default_department_id')
114 if isinstance(context.get('default_department_id'), basestring):
115 department_name = context['default_department_id']
116 department_ids = self.pool.get('hr.department').name_search(cr, uid, name=department_name, context=context)
117 if len(department_ids) == 1:
118 return int(department_ids[0][0])
121 def _read_group_stage_ids(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
122 access_rights_uid = access_rights_uid or uid
123 stage_obj = self.pool.get('hr.recruitment.stage')
124 order = stage_obj._order
125 # lame hack to allow reverting search, should just work in the trivial case
126 if read_group_order == 'stage_id desc':
127 order = "%s desc" % order
128 # retrieve section_id from the context and write the domain
129 # - ('id', 'in', 'ids'): add columns that should be present
130 # - OR ('department_id', '=', False), ('fold', '=', False): add default columns that are not folded
131 # - OR ('department_id', 'in', department_id), ('fold', '=', False) if department_id: add department columns that are not folded
132 department_id = self._resolve_department_id_from_context(cr, uid, context=context)
135 search_domain += ['|', ('department_id', '=', department_id)]
136 search_domain += ['|', ('id', 'in', ids), ('department_id', '=', False)]
137 stage_ids = stage_obj._search(cr, uid, search_domain, order=order, access_rights_uid=access_rights_uid, context=context)
138 result = stage_obj.name_get(cr, access_rights_uid, stage_ids, context=context)
139 # restore order of the search
140 result.sort(lambda x,y: cmp(stage_ids.index(x[0]), stage_ids.index(y[0])))
143 for stage in stage_obj.browse(cr, access_rights_uid, stage_ids, context=context):
144 fold[stage.id] = stage.fold or False
147 def _compute_day(self, cr, uid, ids, fields, args, context=None):
149 @param cr: the current row, from the database cursor,
150 @param uid: the current user’s ID for security checks,
151 @param ids: List of Openday’s IDs
152 @return: difference between current date and log date
153 @param context: A standard dictionary for contextual values
156 for issue in self.browse(cr, uid, ids, context=context):
163 if field in ['day_open']:
165 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
166 date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
167 ans = date_open - date_create
169 elif field in ['day_close']:
170 if issue.date_closed:
171 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
172 date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
173 ans = date_close - date_create
175 duration = float(ans.days)
176 res[issue.id][field] = abs(float(duration))
180 'name': fields.char('Subject', 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="['&', ('fold', '=', False), '|', ('department_id', '=', department_id), ('department_id', '=', False)]"),
191 'state': fields.related('stage_id', 'state', type="selection", store=True,
192 selection=AVAILABLE_STATES, string="Status", readonly=True,
193 help='The status is set to \'Draft\', when a case is created.\
194 If the case is in progress the status is set to \'Open\'.\
195 When the case is over, the status is set to \'Done\'.\
196 If the case needs to be reviewed then the status is \
197 set to \'Pending\'.'),
198 'categ_ids': fields.many2many('hr.applicant_category', string='Tags'),
199 'company_id': fields.many2one('res.company', 'Company'),
200 'user_id': fields.many2one('res.users', 'Responsible'),
202 'date_closed': fields.datetime('Closed', readonly=True, select=True),
203 'date_open': fields.datetime('Opened', readonly=True, select=True),
204 'date': fields.datetime('Date'),
205 'date_action': fields.date('Next Action Date'),
206 'title_action': fields.char('Next Action', size=64),
207 'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
208 'job_id': fields.many2one('hr.job', 'Applied Job'),
209 'salary_proposed_extra': fields.char('Proposed Salary Extra', size=100, help="Salary Proposed by the Organisation, extra advantages"),
210 'salary_expected_extra': fields.char('Expected Salary Extra', size=100, help="Salary Expected by Applicant, extra advantages"),
211 'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
212 'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
213 'availability': fields.integer('Availability'),
214 'partner_name': fields.char("Applicant's Name", size=64),
215 'partner_phone': fields.char('Phone', size=32),
216 'partner_mobile': fields.char('Mobile', size=32),
217 'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
218 'department_id': fields.many2one('hr.department', 'Department'),
219 'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
220 'response': fields.integer("Response"),
221 'reference': fields.char('Referred By', size=128),
222 'source_id': fields.many2one('hr.recruitment.source', 'Source'),
223 'day_open': fields.function(_compute_day, string='Days to Open', \
224 multi='day_open', type="float", store=True),
225 'day_close': fields.function(_compute_day, string='Days to Close', \
226 multi='day_close', type="float", store=True),
227 'color': fields.integer('Color Index'),
228 'emp_id': fields.many2one('hr.employee', 'employee'),
229 'user_email': fields.related('user_id', 'email', type='char', string='User Email', readonly=True),
233 'active': lambda *a: 1,
234 'user_id': lambda s, cr, uid, c: uid,
235 'email_from': lambda s, cr, uid, c: s._get_default_email(cr, uid, c),
236 'stage_id': lambda s, cr, uid, c: s._get_default_stage_id(cr, uid, c),
237 'department_id': lambda s, cr, uid, c: s._get_default_department_id(cr, uid, c),
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 obj_recru_stage = self.pool.get('hr.recruitment.stage')
257 stage_ids = obj_recru_stage.search(cr, uid, ['|',('department_id','=',department_id),('department_id','=',False)], context=context)
258 stage_id = stage_ids and stage_ids[0] or False
259 return {'value': {'stage_id': stage_id}}
261 def onchange_partner_id(self, cr, uid, ids, partner_id, context=None):
262 data = {'partner_phone': False,
263 'partner_mobile': False,
266 addr = self.pool.get('res.partner').browse(cr, uid, partner_id, context)
267 data.update({'partner_phone': addr.phone,
268 'partner_mobile': addr.mobile,
269 'email_from': addr.email})
270 return {'value': data}
272 def stage_find(self, cr, uid, cases, section_id, domain=[], order='sequence', context=None):
273 """ Override of the base.stage method
274 Parameter of the stage search taken from the lead:
275 - department_id: if set, stages must belong to this section or
278 if isinstance(cases, (int, long)):
279 cases = self.browse(cr, uid, cases, context=context)
280 # collect all section_ids
283 department_ids.append(section_id)
285 if case.department_id:
286 department_ids.append(case.department_id.id)
287 # OR all section_ids and OR with case_default
290 search_domain += ['|', ('department_id', 'in', department_ids)]
291 search_domain.append(('department_id', '=', False))
292 # AND with the domain in parameter
293 search_domain += list(domain)
294 # perform search, return the first found
295 stage_ids = self.pool.get('hr.recruitment.stage').search(cr, uid, search_domain, order=order, context=context)
300 def action_makeMeeting(self, cr, uid, ids, context=None):
301 """ This opens Meeting's calendar view to schedule meeting on current applicant
302 @return: Dictionary value for created Meeting view
304 applicant = self.browse(cr, uid, ids[0], context)
305 category = self.pool.get('ir.model.data').get_object(cr, uid, 'hr_recruitment', 'categ_meet_interview', context)
306 res = self.pool.get('ir.actions.act_window').for_xml_id(cr, uid, 'base_calendar', 'action_crm_meeting', context)
308 'default_partner_ids': applicant.partner_id and [applicant.partner_id.id] or False,
309 'default_user_id': uid,
310 'default_name': applicant.name,
311 'default_categ_ids': category and [category.id] or False,
315 def action_print_survey(self, cr, uid, ids, context=None):
317 If response is available then print this response otherwise print survey form(print template of the survey).
319 @param self: The object pointer
320 @param cr: the current row, from the database cursor,
321 @param uid: the current user’s ID for security checks,
322 @param ids: List of Survey IDs
323 @param context: A standard dictionary for contextual values
324 @return: Dictionary value for print survey form.
328 record = self.browse(cr, uid, ids, context=context)
329 record = record and record[0]
330 context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
331 value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
334 def message_new(self, cr, uid, msg, custom_values=None, context=None):
335 """ Overrides mail_thread message_new that is called by the mailgateway
336 through message_process.
337 This override updates the document according to the email.
339 if custom_values is None: custom_values = {}
340 desc = html2plaintext(msg.get('body')) if msg.get('body') else ''
341 custom_values.update({
342 'name': msg.get('subject') or _("No Subject"),
344 'email_from': msg.get('from'),
345 'email_cc': msg.get('cc'),
348 if msg.get('priority'):
349 custom_values['priority'] = msg.get('priority')
350 return super(hr_applicant,self).message_new(cr, uid, msg, custom_values=custom_values, context=context)
352 def message_update(self, cr, uid, ids, msg, update_vals=None, context=None):
353 """ Override mail_thread message_update that is called by the mailgateway
354 through message_process.
355 This method updates the document according to the email.
357 if isinstance(ids, (str, int, long)):
359 if update_vals is None: vals = {}
362 'description': msg.get('body'),
363 'email_from': msg.get('from'),
364 'email_cc': msg.get('cc'),
366 if msg.get('priority'):
367 update_vals['priority'] = msg.get('priority')
370 'cost': 'planned_cost',
371 'revenue': 'planned_revenue',
372 'probability': 'probability',
374 for line in msg.get('body', '').split('\n'):
376 res = tools.misc.command_re.match(line)
377 if res and maps.get(res.group(1).lower(), False):
378 key = maps.get(res.group(1).lower())
379 update_vals[key] = res.group(2).lower()
381 return super(hr_applicant, self).message_update(cr, uids, ids, update_vals=update_vals, context=context)
383 def create(self, cr, uid, vals, context=None):
384 obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
385 self.create_send_note(cr, uid, [obj_id], context=context)
388 def case_open(self, cr, uid, ids, context=None):
390 open Request of the applicant for the hr_recruitment
392 res = super(hr_applicant, self).case_open(cr, uid, ids, context)
393 date = self.read(cr, uid, ids, ['date_open'])[0]
394 if not date['date_open']:
395 self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
398 def case_close(self, cr, uid, ids, context=None):
399 res = super(hr_applicant, self).case_close(cr, uid, ids, context)
402 def case_close_with_emp(self, cr, uid, ids, context=None):
405 hr_employee = self.pool.get('hr.employee')
406 model_data = self.pool.get('ir.model.data')
407 act_window = self.pool.get('ir.actions.act_window')
409 for applicant in self.browse(cr, uid, ids, context=context):
411 if applicant.partner_id:
412 address_id = self.pool.get('res.partner').address_get(cr,uid,[applicant.partner_id.id],['contact'])['contact']
414 applicant.job_id.write({'no_of_recruitment': applicant.job_id.no_of_recruitment - 1})
415 emp_id = hr_employee.create(cr,uid,{'name': applicant.partner_name or applicant.name,
416 'job_id': applicant.job_id.id,
417 'address_home_id': address_id,
418 'department_id': applicant.department_id.id
420 self.write(cr, uid, [applicant.id], {'emp_id': emp_id}, context=context)
421 self.case_close(cr, uid, [applicant.id], context)
423 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
425 action_model, action_id = model_data.get_object_reference(cr, uid, 'hr', 'open_view_employee_list')
426 dict_act_window = act_window.read(cr, uid, action_id, [])
428 dict_act_window['res_id'] = emp_id
429 dict_act_window['view_mode'] = 'form,tree'
430 return dict_act_window
432 def case_cancel(self, cr, uid, ids, context=None):
433 """Overrides cancel for crm_case for setting probability
435 res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
436 self.write(cr, uid, ids, {'probability' : 0.0})
439 def case_pending(self, cr, uid, ids, context=None):
440 """Marks case as pending"""
441 res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
442 self.write(cr, uid, ids, {'probability' : 0.0})
445 def case_reset(self, cr, uid, ids, context=None):
446 """Resets case as draft
448 res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
449 self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
452 def set_priority(self, cr, uid, ids, priority, *args):
453 """Set applicant priority
455 return self.write(cr, uid, ids, {'priority' : priority})
457 def set_high_priority(self, cr, uid, ids, *args):
458 """Set applicant priority to high
460 return self.set_priority(cr, uid, ids, '1')
462 def set_normal_priority(self, cr, uid, ids, *args):
463 """Set applicant priority to normal
465 return self.set_priority(cr, uid, ids, '3')
467 # -------------------------------------------------------
468 # OpenChatter methods and notifications
469 # -------------------------------------------------------
471 def stage_set_send_note(self, cr, uid, ids, stage_id, context=None):
472 """ Override of the (void) default notification method. """
473 if not stage_id: return True
474 stage_name = self.pool.get('hr.recruitment.stage').name_get(cr, uid, [stage_id], context=context)[0][1]
475 return self.message_post(cr, uid, ids, body=_("Stage changed to <b>%s</b>.") % (stage_name), context=context)
477 def case_get_note_msg_prefix(self, cr, uid, id, context=None):
480 def case_open_send_note(self, cr, uid, ids, context=None):
481 message = _("Applicant has been set <b>in progress</b>.")
482 return self.message_post(cr, uid, ids, body=message, context=context)
484 def case_close_send_note(self, cr, uid, ids, context=None):
487 for applicant in self.browse(cr, uid, ids, context=context):
489 self.pool.get('hr.job').message_post(cr, uid, [applicant.job_id.id], body=_('New employee joined the company %s.')%(applicant.name,), subtype="hr_recruitment.mt_hired", context=context)
491 message = _("Applicant has been <b>hired</b> and created as an employee.")
492 self.message_post(cr, uid, [applicant.id], body=message, context=context)
494 message = _("Applicant has been <b>hired</b>.")
495 self.message_post(cr, uid, [applicant.id], body=message, context=context)
498 def case_cancel_send_note(self, cr, uid, ids, context=None):
499 msg = 'Applicant <b>refused</b>.'
500 return self.message_post(cr, uid, ids, body=msg, context=context)
502 def case_reset_send_note(self, cr, uid, ids, context=None):
503 message =_("Applicant has been set as <b>new</b>.")
504 return self.message_post(cr, uid, ids, body=message, context=context)
506 def create_send_note(self, cr, uid, ids, context=None):
507 message = _("Applicant has been <b>created</b>.")
508 for applicant in self.browse(cr, uid, ids, context=context):
510 self.pool.get('hr.job').message_post(cr, uid, [applicant.job_id.id], body=message, subtype="hr_recruitment.mt_applicant_new", context=context)
511 return self.message_post(cr, uid, ids, body=message, context=context)
513 class hr_job(osv.osv):
516 _inherits = {'mail.alias': 'alias_id'}
518 '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"),
519 'alias_id': fields.many2one('mail.alias', 'Alias', ondelete="cascade", required=True,
520 help="Email alias for this job position. New emails will automatically "
521 "create new applicants for this job position."),
524 'alias_domain': False, # always hide alias during creation
527 def _auto_init(self, cr, context=None):
528 """Installation hook to create aliases for all jobs and avoid constraint errors."""
529 self.pool.get('mail.alias').migrate_to_alias(cr, self._name, self._table, super(hr_job,self)._auto_init,
530 self._columns['alias_id'], 'name', alias_prefix='job+', alias_defaults={'job_id': 'id'}, context=context)
532 def create(self, cr, uid, vals, context=None):
533 mail_alias = self.pool.get('mail.alias')
534 if not vals.get('alias_id'):
535 vals.pop('alias_name', None) # prevent errors during copy()
536 alias_id = mail_alias.create_unique_alias(cr, uid,
537 # Using '+' allows using subaddressing for those who don't
538 # have a catchall domain setup.
539 {'alias_name': 'jobs+'+vals['name']},
540 model_name="hr.applicant",
542 vals['alias_id'] = alias_id
543 res = super(hr_job, self).create(cr, uid, vals, context)
544 mail_alias.write(cr, uid, [vals['alias_id']], {"alias_defaults": {'job_id': res}}, context)
547 def unlink(self, cr, uid, ids, context=None):
548 # Cascade-delete mail aliases as well, as they should not exist without the job position.
549 mail_alias = self.pool.get('mail.alias')
550 alias_ids = [job.alias_id.id for job in self.browse(cr, uid, ids, context=context) if job.alias_id]
551 res = super(hr_job, self).unlink(cr, uid, ids, context=context)
552 mail_alias.unlink(cr, uid, alias_ids, context=context)
555 def action_print_survey(self, cr, uid, ids, context=None):
559 record = self.browse(cr, uid, ids, context=context)[0]
561 datas['ids'] = [record.survey_id.id]
562 datas['model'] = 'survey.print'
563 context.update({'response_id': [0], 'response_no': 0,})
565 'type': 'ir.actions.report.xml',
566 'report_name': 'survey.form',
572 class applicant_category(osv.osv):
573 """ Category of applicant """
574 _name = "hr.applicant_category"
575 _description = "Category of applicant"
577 'name': fields.char('Name', size=64, required=True, translate=True),
580 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: