From 3529cca4f1fa8aca8131d5d7486c827b9d41a54d Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Mon, 5 Mar 2012 17:33:41 +0530
Subject: [PATCH 01/13] [IMP] Create social chatter for 'Project Issues'.

bzr revid: jra@tinyerp.com-20120305120341-57h2iiytumjtpa9v
---
 addons/hr_recruitment/hr_recruitment.py     |  17 +-
 addons/project/project.py                   |   2 +
 addons/project/project_view.xml             |   2 +
 addons/project_issue/project_issue.py       | 242 +++++++++++++-------
 addons/project_issue/project_issue_view.xml |  66 ++----
 5 files changed, 191 insertions(+), 138 deletions(-)

diff --git a/addons/hr_recruitment/hr_recruitment.py b/addons/hr_recruitment/hr_recruitment.py
index 2a6bc0db64c..18d3f8545ce 100644
--- a/addons/hr_recruitment/hr_recruitment.py
+++ b/addons/hr_recruitment/hr_recruitment.py
@@ -392,45 +392,44 @@ class hr_applicant(crm.crm_case, osv.osv):
         return res
 
     def _case_open_notification(self, case, context=None):
-        message = _("Changed Status to <b>In Progress<b>.")
+        message = _("Changed Status to <b>in Progress<b>.")
         case.message_append_note('' ,message, type='notification')
         return True
 
     def _case_close_notification(self, case, context=None):
         case[0].message_mark_done(context)
         if case[0].emp_id:
-            message = _("Applicant is <b>Hired</b> and employee created.")
+            message = _("Applicant is <b>hired</b> and employee created.")
             case[0].message_append_note('' ,message, type='notification')
         else:
-            message = _("Applicant is <b>Hired</b>.")
+            message = _("Applicant is <b>hired</b>.")
             case[0].message_append_note('' ,message, type='notification')
         return True
 
     def _case_cancel_notification(self, case, context=None):
         case[0].message_mark_done(context=context)
-        message = _("Applicant is <b>Cancelled<b>.")
+        message = _("Applicant is <b>cancelled<b>.")
         case[0].message_append_note('' ,message, type="notification")
         return True
 
     def _case_pending_notification(self, case, context=None):
-        message = _("Changed Status to <b>Pending<b>.")
+        message = _("Changed Status to <b>pending<b>.")
         case[0].message_append_note('' ,message, type='notification')
         return True
 
     def _case_reset_notification(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
             self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Changed Status to <b>New<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
+                        _("Changed Status to <b>new<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
         return True
 
     def create_notificate(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
             self.message_subscribe(cr, uid, ids, [obj.user_id.id], context=context)
             self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Applicant is <b>Created</b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
+                        _("Applicant is <b>created</b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
         return True
 
-
     def create(self, cr, uid, vals, context=None):
         obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
         self.create_notificate(cr, uid, [obj_id], context=context)
@@ -518,7 +517,7 @@ class hr_applicant(crm.crm_case, osv.osv):
         if 'stage_id' in vals and vals['stage_id']:
             stage = self.pool.get('hr.recruitment.stage').browse(cr, uid, vals['stage_id'], context=context)
             self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Changed Stage to <b>%s</b>.") % stage.name, type='notification')
+                        _("Changed stage to <b>%s</b>.") % stage.name, type='notification')
         return super(hr_applicant,self).write(cr, uid, ids, vals, context=context)
 
 hr_applicant()
diff --git a/addons/project/project.py b/addons/project/project.py
index 9966ad02ee8..b9a3ccd0578 100644
--- a/addons/project/project.py
+++ b/addons/project/project.py
@@ -53,6 +53,7 @@ class project(osv.osv):
     _name = "project.project"
     _description = "Project"
     _inherits = {'account.analytic.account': "analytic_account_id"}
+    _inherit = ['mail.thread']
 
     def search(self, cr, user, args, offset=0, limit=None, order=None, context=None, count=False):
         if user == 1:
@@ -457,6 +458,7 @@ class task(osv.osv):
     _description = "Task"
     _log_create = True
     _date_name = "date_start"
+    _inherit = ['mail.thread']
 
 
     def _resolve_project_id_from_context(self, cr, uid, context=None):
diff --git a/addons/project/project_view.xml b/addons/project/project_view.xml
index 26abe86fe99..fa5d1539e60 100644
--- a/addons/project/project_view.xml
+++ b/addons/project/project_view.xml
@@ -97,6 +97,7 @@
                         </page>
                     </notebook>
                     <newline/>
+                    <field name="message_ids_social" colspan="4" widget="ThreadView" nolabel="1"/>
                 </form>
             </field>
         </record>
@@ -309,6 +310,7 @@
                             <field colspan="4" name="notes" nolabel="1"/>
                         </page>
                     </notebook>
+                    <field name="message_ids_social" colspan="4" widget="ThreadView" nolabel="1"/>
                 </form>
             </field>
         </record>
diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index b950bfd0b34..646be577211 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -48,44 +48,6 @@ class project_issue(crm.crm_case, osv.osv):
     _order = "priority, create_date desc"
     _inherit = ['mail.thread']
 
-    def write(self, cr, uid, ids, vals, context=None):
-        #Update last action date everytime the user change the stage, the state or send a new email
-        logged_fields = ['type_id', 'state', 'message_ids']
-        if any([field in vals for field in logged_fields]):
-            vals['date_action_last'] = time.strftime('%Y-%m-%d %H:%M:%S')
-        return super(project_issue, self).write(cr, uid, ids, vals, context)
-
-    def case_open(self, cr, uid, ids, *args):
-        """
-        @param self: The object pointer
-        @param cr: the current row, from the database cursor,
-        @param uid: the current user’s ID for security checks,
-        @param ids: List of case's Ids
-        @param *args: Give Tuple Value
-        """
-
-        res = super(project_issue, self).case_open(cr, uid, ids, *args)
-        self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'), 'user_id' : uid})
-        for (id, name) in self.name_get(cr, uid, ids):
-            message = _("Issue '%s' has been opened.") % name
-            self.log(cr, uid, id, message)
-        return res
-
-    def case_close(self, cr, uid, ids, *args):
-        """
-        @param self: The object pointer
-        @param cr: the current row, from the database cursor,
-        @param uid: the current user’s ID for security checks,
-        @param ids: List of case's Ids
-        @param *args: Give Tuple Value
-        """
-
-        res = super(project_issue, self).case_close(cr, uid, ids, *args)
-        for (id, name) in self.name_get(cr, uid, ids):
-            message = _("Issue '%s' has been closed.") % name
-            self.log(cr, uid, id, message)
-        return res
-
     def _compute_day(self, cr, uid, ids, fields, args, context=None):
         """
         @param cr: the current row, from the database cursor,
@@ -112,7 +74,8 @@ class project_issue(crm.crm_case, osv.osv):
                         ans = date_open - date_create
                         date_until = issue.date_open
                         #Calculating no. of working hours to open the issue
-                        hours = cal_obj.interval_hours_get(cr, uid, issue.project_id.resource_calendar_id.id,
+                        if issue.project_id.resource_calendar_id:
+                            hours = cal_obj.interval_hours_get(cr, uid, issue.project_id.resource_calendar_id.id,
                                                            date_create,
                                                            date_open)
                 elif field in ['working_hours_close','day_close']:
@@ -121,7 +84,8 @@ class project_issue(crm.crm_case, osv.osv):
                         date_until = issue.date_closed
                         ans = date_close - date_create
                         #Calculating no. of working hours to close the issue
-                        hours = cal_obj.interval_hours_get(cr, uid, issue.project_id.resource_calendar_id.id,
+                        if issue.project_id.resource_calendar_id:
+                            hours = cal_obj.interval_hours_get(cr, uid, issue.project_id.resource_calendar_id.id,
                                date_create,
                                date_close)
                 elif field in ['days_since_creation']:
@@ -166,6 +130,25 @@ class project_issue(crm.crm_case, osv.osv):
 
         return res
 
+    def _hours_get(self, cr, uid, ids, field_names, args, context=None):
+        task_pool = self.pool.get('project.task')
+        res = {}
+        for issue in self.browse(cr, uid, ids, context=context):
+            progress = 0.0
+            if issue.task_id:
+                progress = task_pool._hours_get(cr, uid, [issue.task_id.id], field_names, args, context=context)[issue.task_id.id]['progress']
+            res[issue.id] = {'progress' : progress}
+        return res
+
+    def _get_project(self, cr, uid, context=None):
+        user = self.pool.get('res.users').browse(cr, uid, uid, context=context)
+        if user.context_project_id:
+            return user.context_project_id.id
+        return False
+
+    def on_change_project(self, cr, uid, ids, project_id, context=None):
+        return {}
+
     def _get_issue_task(self, cr, uid, ids, context=None):
         issues = []
         issue_pool = self.pool.get('project.issue')
@@ -181,16 +164,6 @@ class project_issue(crm.crm_case, osv.osv):
                 issues += issue_pool.search(cr, uid, [('task_id','=',work.task_id.id)])
         return issues
 
-    def _hours_get(self, cr, uid, ids, field_names, args, context=None):
-        task_pool = self.pool.get('project.task')
-        res = {}
-        for issue in self.browse(cr, uid, ids, context=context):
-            progress = 0.0
-            if issue.task_id:
-                progress = task_pool._hours_get(cr, uid, [issue.task_id.id], field_names, args, context=context)[issue.task_id.id]['progress']
-            res[issue.id] = {'progress' : progress}
-        return res
-
     _columns = {
         'id': fields.integer('ID', readonly=True),
         'name': fields.char('Issue', size=128, required=True),
@@ -251,15 +224,6 @@ class project_issue(crm.crm_case, osv.osv):
             }),
     }
 
-    def _get_project(self, cr, uid, context=None):
-        user = self.pool.get('res.users').browse(cr, uid, uid, context=context)
-        if user.context_project_id:
-            return user.context_project_id.id
-        return False
-
-    def on_change_project(self, cr, uid, ids, project_id, context=None):
-        return {}
-
 
     _defaults = {
         'active': 1,
@@ -319,11 +283,13 @@ class project_issue(crm.crm_case, osv.osv):
                 'user_id': bug.user_id.id,
                 'planned_hours': 0.0,
             })
-
             vals = {
                 'task_id': new_task_id,
                 'state':'pending'
             }
+            self._convert_to_task_notification(cr, uid, ids, context)
+            cases = self.browse(cr, uid, ids)
+            self._case_pending_notification(cases, context=context)
             case_obj.write(cr, uid, [bug.id], vals)
 
         return  {
@@ -356,28 +322,39 @@ class project_issue(crm.crm_case, osv.osv):
     def convert_to_bug(self, cr, uid, ids, context=None):
         return self._convert(cr, uid, ids, 'bug_categ', context=context)
 
-    def next_type(self, cr, uid, ids, *args):
-        for task in self.browse(cr, uid, ids):
-            typeid = task.type_id.id
-            types = map(lambda x:x.id, task.project_id.type_ids or [])
-            if types:
-                if not typeid:
-                    self.write(cr, uid, task.id, {'type_id': types[0]})
-                elif typeid and typeid in types and types.index(typeid) != len(types)-1 :
-                    index = types.index(typeid)
-                    self.write(cr, uid, task.id, {'type_id': types[index+1]})
-        return True
-
-    def prev_type(self, cr, uid, ids, *args):
+    def prev_type(self, cr, uid, ids, context=None):
         for task in self.browse(cr, uid, ids):
             typeid = task.type_id.id
             types = map(lambda x:x.id, task.project_id and task.project_id.type_ids or [])
             if types:
                 if typeid and typeid in types:
                     index = types.index(typeid)
-                    self.write(cr, uid, task.id, {'type_id': index and types[index-1] or False})
+                    self.write(cr, uid, [task.id], {'type_id': index and types[index-1] or False})
         return True
 
+    def next_type(self, cr, uid, ids, context=None):
+        for task in self.browse(cr, uid, ids):
+            typeid = task.type_id.id
+            types = map(lambda x:x.id, task.project_id.type_ids or [])
+            if types:
+                if not typeid:
+                    self.write(cr, uid, [task.id], {'type_id': types[0]})
+                elif typeid and typeid in types and types.index(typeid) != len(types)-1 :
+                    index = types.index(typeid)
+                    self.write(cr, uid, [task.id], {'type_id': types[index+1]})
+        return True
+
+    def write(self, cr, uid, ids, vals, context=None):
+        #Update last action date everytime the user change the stage, the state or send a new email
+        logged_fields = ['type_id', 'state', 'message_ids']
+        if any([field in vals for field in logged_fields]):
+            vals['date_action_last'] = time.strftime('%Y-%m-%d %H:%M:%S')
+        if 'type_id' in vals and vals['type_id']:
+            stage = self.pool.get('project.task.type').browse(cr, uid, vals['type_id'], context=context)
+            self.message_append_note(cr, uid, ids, _('System notification'),
+                        _("Changed stage to <b>%s</b>.") % stage.name, type='notification')
+        return super(project_issue, self).write(cr, uid, ids, vals, context)
+
     def onchange_task_id(self, cr, uid, ids, task_id, context=None):
         result = {}
         if not task_id:
@@ -385,13 +362,113 @@ class project_issue(crm.crm_case, osv.osv):
         task = self.pool.get('project.task').browse(cr, uid, task_id, context=context)
         return {'value':{'user_id': task.user_id.id,}}
 
-    def case_escalate(self, cr, uid, ids, *args):
+    def _case_open_notification(self, case, context=None):
+        if case.state:
+        message = _("Issue is <b>opened</b>.")
+        case.message_append_note('' ,message, type='notification')
+        return True
+
+    def _case_close_notification(self, case, context=None):
+        case[0].message_mark_done(context)
+        message = _("Issue <em>%s</em> is <b>closed</b>.")
+        case[0].message_append_note('' ,message, type='notification')
+        return True
+
+
+    def _convert_to_task_notification(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            self.message_append_note(cr, uid, ids, _('System notification'),
+                        _("Issue is <b>converted</b> in to task."), type='notification', context=context)
+        return True
+
+    def create_notificate(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            self.message_append_note(cr, uid, ids, _('System notification'),
+                        _("Issue is <b>created</b>."), type='notification', need_action_user_id=False, context=context)
+        return True
+
+    def _case_pending_notification(self, case, context=None):
+        message = _("Issue is on <b>pending<b>.")
+        case[0].message_append_note('' ,message, type='notification')
+        return True
+
+    def _case_escalate_notification(self, case, context=None):
+        if case[0].project_id.project_escalation_id.user_id.id:
+            message = _("Issue is <b>escalated</b> from project <em>'%s'</em>.") % (case[0].project_id.name)
+            case[0].message_append_note('' ,message, type='notification', need_action_user_id=case[0].project_id.project_escalation_id.user_id.id, context=context)
+        else:
+            message = _("Issue is <b>escalated</b>.")
+            case[0].message_append_note('' ,message, type='notification', need_action_user_id=False, context=context)
+        
+        return True
+
+    def _case_reset_notification(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            self.message_append_note(cr, uid, ids, _('System notification'),
+                        _("Issue is reset as <b>new<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
+        return True
+
+    def _case_cancel_notification(self, case, context=None):
+        case[0].message_mark_done(context=context)
+        message = _("Issue is <b>cancelled<b>.")
+        case[0].message_append_note('' ,message, type="notification")
+        return True
+
+    def case_reset(self, cr, uid, ids, context=None):
+        """Resets case as draft
+        """
+        res = super(project_issue, self).case_reset(cr, uid, ids, context)
+        self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
+        self._case_reset_notification(cr, uid, ids, context)
+        return res
+
+    def case_pending(self, cr, uid, ids, context=None):
+        """Marks case as pending"""
+        res = super(project_issue, self).case_pending(cr, uid, ids, context)
+        self.write(cr, uid, ids, context)
+        return res
+
+    def case_cancel(self, cr, uid, ids, context=None):
+        """Overrides cancel for crm_case for setting probability
+        """
+        res = super(project_issue, self).case_cancel(cr, uid, ids, context)
+        self.write(cr, uid, ids, context)
+        return res
+
+    def create(self, cr, uid, vals, context=None):
+        obj_id = super(project_issue, self).create(cr, uid, vals, context=context)
+        self.create_notificate(cr, uid, [obj_id], context=context)
+        return obj_id
+
+    def case_open(self, cr, uid, ids, context=None):
+        """
+        @param self: The object pointer
+        @param cr: the current row, from the database cursor,
+        @param uid: the current user’s ID for security checks,
+        @param ids: List of case's Ids
+        """
+
+        res = super(project_issue, self).case_open(cr, uid, ids, context)
+        self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'), 'user_id' : uid})
+        return res
+
+    def case_close(self, cr, uid, ids, context=None):
+        """
+        @param self: The object pointer
+        @param cr: the current row, from the database cursor,
+        @param uid: the current user’s ID for security checks,
+        @param ids: List of case's Ids
+        """
+
+        res = super(project_issue, self).case_close(cr, uid, ids, context)
+        return res
+
+    def case_escalate(self, cr, uid, ids, context=None):
         """Escalates case to top level
         @param self: The object pointer
         @param cr: the current row, from the database cursor,
         @param uid: the current user’s ID for security checks,
         @param ids: List of case Ids
-        @param *args: Tuple Value for additional Params
         """
         cases = self.browse(cr, uid, ids)
         for case in cases:
@@ -405,7 +482,7 @@ class project_issue(crm.crm_case, osv.osv):
             else:
                 raise osv.except_osv(_('Warning !'), _('You cannot escalate this issue.\nThe relevant Project has not configured the Escalation Project!'))
             self.write(cr, uid, [case.id], data)
-        self.message_append(cr, uid, cases, _('Escalate'))
+        self._case_escalate_notification(cases, context=context)
         return True
 
     def message_new(self, cr, uid, msg, custom_values=None, context=None):
@@ -437,7 +514,6 @@ class project_issue(crm.crm_case, osv.osv):
         return res_id
 
     def message_update(self, cr, uid, ids, msg, vals=None, default_act='pending', context=None):
-
         if vals is None:
             vals = {}
 
@@ -493,11 +569,11 @@ class project(osv.osv):
     }
 
     def _check_escalation(self, cr, uid, ids, context=None):
-         project_obj = self.browse(cr, uid, ids[0], context=context)
-         if project_obj.project_escalation_id:
-             if project_obj.project_escalation_id.id == project_obj.id:
-                 return False
-         return True
+        project_obj = self.browse(cr, uid, ids[0], context=context)
+        if project_obj.project_escalation_id:
+            if project_obj.project_escalation_id.id == project_obj.id:
+                return False
+        return True
 
     _constraints = [
         (_check_escalation, 'Error! You cannot assign escalation to the same project!', ['project_escalation_id'])
diff --git a/addons/project_issue/project_issue_view.xml b/addons/project_issue/project_issue_view.xml
index d50501279fd..1d6a560158d 100644
--- a/addons/project_issue/project_issue_view.xml
+++ b/addons/project_issue/project_issue_view.xml
@@ -54,7 +54,12 @@
                     <group colspan="4" col="6">
                         <field name="name"/>
                         <field name="project_id" required="True" on_change="on_change_project(project_id)"/>
-                        <field name="categ_id" widget="selection" domain="[('object_id.model', '=', 'project.issue')]"/>
+                        <group colspan="2" col="3">
+                            <field name="categ_id" widget="selection" domain="[('object_id.model', '=', 'project.issue')]"/>
+                            <button string="Send New Email"
+                                name="%(mail.action_email_compose_message_wizard)d"
+                                icon="terp-mail-message-new" type="action"/>
+                        </group>
                         <field name="user_id"/>
                         <field name="version_id" colspan="2" widget="selection"/>
                         <group colspan="2" col="4">
@@ -92,55 +97,24 @@
                             <button name="case_reset" string="Reset to New" states="done,cancel" type="object" icon="gtk-convert"/>
                             </group>
                         </page>
-                        <page string="Communication &amp; History" groups="base.group_extended">
-                            <group colspan="4">
-                            <field colspan="4" name="email_cc" string="Global CC" widget="url"/>
+                        <page string="Extra Info" groups="base.group_extended">
+                            <group col="4" colspan="4">
+                                <separator string="Statistics" colspan="4" col="4"/>
+                                <field name="day_open"/>
+                                <field name="day_close"/>
+                                <field name="working_hours_open" widget="float_time"/>
+                                <field name="working_hours_close" widget="float_time"/>
+                                <field name="inactivity_days"/>
+                                <field name="days_since_creation"/>
                             </group>
-                            <field name="message_ids" colspan="4" nolabel="1" mode="tree" readonly="1">
-                                <tree string="History">
-                                    <field name="display_text" string="History Information"/>
-                                    <field name="email_from" invisible="1"/>
-                                    <button
-                                        string="Reply" attrs="{'invisible': [('email_from', '=', False)]}"
-                                        name="%(mail.action_email_compose_message_wizard)d"
-                                        context="{'mail.compose.message.mode':'reply', 'message_id':active_id}"
-                                        icon="terp-mail-replied" type="action" />
-                                </tree>
-                            </field>
-                           <separator colspan="4"/>
-                            <button string="Add Internal Note"
-                                name="%(crm.action_crm_add_note)d"
-                                context="{'model': 'crm.lead' }"
-                                icon="terp-document-new" type="action" />
-                            <button string="Send New Email"
-                                name="%(mail.action_email_compose_message_wizard)d"
-                                icon="terp-mail-message-new" type="action"/>
-                        </page>
-                           <page string="Extra Info" groups="base.group_extended">
-                            <group col="2" colspan="2">
-                            <separator colspan="2" string="Date"/>
-                            <field name="create_date"/>
-                            <field name="write_date" />
-                            <field name="date_closed"/>
-                            <field name="date_open"/>
-                            <field name="date_action_last"/>
-                            </group>
-                            <group colspan="2" col="2">
-                            <separator string="Statistics" colspan="2" col="2"/>
-                            <field name="day_open"/>
-                            <field name="day_close"/>
-                            <field name="working_hours_open" widget="float_time"/>
-                            <field name="working_hours_close" widget="float_time"/>
-                            <field name="inactivity_days"/>
-                            <field name="days_since_creation"/>
-                            </group>
-                            <group colspan="2" col="2">
-                            <separator string="References" colspan="2"/>
-                            <field name="id"/>
-                            <field name="active"/>
+                            <group colspan="4" col="4">
+                                <separator string="References" colspan="4"/>
+                                <field name="id"/>
+                                <field name="active"/>
                             </group>
                         </page>
                     </notebook>
+                    <field name="message_ids_social" colspan="4" widget="ThreadView" nolabel="1"/>
                 </form>
             </field>
         </record>

From 61ce9ab13e32be0c652d2381ebb1fafb0402a6a0 Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Mon, 5 Mar 2012 17:51:34 +0530
Subject: [PATCH 02/13] [FIX] Correction of statement alignment.

bzr revid: jra@tinyerp.com-20120305122134-agx28jedes7hsp01
---
 addons/project_issue/project_issue.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 646be577211..7a7ce225f41 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -364,8 +364,8 @@ class project_issue(crm.crm_case, osv.osv):
 
     def _case_open_notification(self, case, context=None):
         if case.state:
-        message = _("Issue is <b>opened</b>.")
-        case.message_append_note('' ,message, type='notification')
+            message = _("Issue is <b>opened</b>.")
+            case.message_append_note('' ,message, type='notification')
         return True
 
     def _case_close_notification(self, case, context=None):

From df4829dfa54864f0e4733def39db1bdaf5d484d2 Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Wed, 14 Mar 2012 16:21:59 +0530
Subject: [PATCH 03/13] [IMP] Improved project issue

bzr revid: jra@tinyerp.com-20120314105159-y9i9n8kjb39r3vmu
---
 addons/project/project.py             | 46 +++++++++++++++++++++++++++
 addons/project_issue/project_issue.py |  4 +--
 2 files changed, 48 insertions(+), 2 deletions(-)

diff --git a/addons/project/project.py b/addons/project/project.py
index b9a3ccd0578..a1d492fb6f6 100644
--- a/addons/project/project.py
+++ b/addons/project/project.py
@@ -462,6 +462,7 @@ class task(osv.osv):
 
 
     def _resolve_project_id_from_context(self, cr, uid, context=None):
+        print "\n ::: resolve project id from context ::::"
         """Return ID of project based on the value of 'project_id'
            context key, or None if it cannot be resolved to a single project.
         """
@@ -476,6 +477,7 @@ class task(osv.osv):
                 return project_ids[0][0]
 
     def _read_group_type_id(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
+        print "\n :::: read group type id ::::"
         stage_obj = self.pool.get('project.task.type')
         project_id = self._resolve_project_id_from_context(cr, uid, context=context)
         order = stage_obj._order
@@ -494,6 +496,7 @@ class task(osv.osv):
         return result
 
     def _read_group_user_id(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
+        print "\n :: read group user id :::"
         res_users = self.pool.get('res.users')
         project_id = self._resolve_project_id_from_context(cr, uid, context=context)
         access_rights_uid = access_rights_uid or uid
@@ -517,6 +520,7 @@ class task(osv.osv):
 
 
     def search(self, cr, user, args, offset=0, limit=None, order=None, context=None, count=False):
+        print "\n ::: search :::"
         obj_project = self.pool.get('project.project')
         for domain in args:
             if domain[0] == 'project_id' and (not isinstance(domain[2], str)):
@@ -527,12 +531,14 @@ class task(osv.osv):
         return super(task, self).search(cr, user, args, offset=offset, limit=limit, order=order, context=context, count=count)
 
     def _str_get(self, task, level=0, border='***', context=None):
+        print "\n :: st get :::"
         return border+' '+(task.user_id and task.user_id.name.upper() or '')+(level and (': L'+str(level)) or '')+(' - %.1fh / %.1fh'%(task.effective_hours or 0.0,task.planned_hours))+' '+border+'\n'+ \
             border[0]+' '+(task.name or '')+'\n'+ \
             (task.description or '')+'\n\n'
 
     # Compute: effective_hours, total_hours, progress
     def _hours_get(self, cr, uid, ids, field_names, args, context=None):
+        print "\n ::: hours get :::"
         res = {}
         cr.execute("SELECT task_id, COALESCE(SUM(hours),0) FROM project_task_work WHERE task_id IN %s GROUP BY task_id",(tuple(ids),))
         hours = dict(cr.fetchall())
@@ -548,14 +554,17 @@ class task(osv.osv):
 
 
     def onchange_remaining(self, cr, uid, ids, remaining=0.0, planned = 0.0):
+        print "\n ::: onchange remaining :::"
         if remaining and not planned:
             return {'value':{'planned_hours': remaining}}
         return {}
 
     def onchange_planned(self, cr, uid, ids, planned = 0.0, effective = 0.0):
+        print "\n :::: onchange planned ::::"
         return {'value':{'remaining_hours': planned - effective}}
 
     def onchange_project(self, cr, uid, id, project_id):
+        print "\n :: onchange project :::"
         if not project_id:
             return {}
         data = self.pool.get('project.project').browse(cr, uid, [project_id])
@@ -565,6 +574,7 @@ class task(osv.osv):
         return {}
 
     def duplicate_task(self, cr, uid, map_ids, context=None):
+        print "\n ::: duplicate tasK:::"
         for new in map_ids.values():
             task = self.browse(cr, uid, new, context)
             child_ids = [ ch.id for ch in task.child_ids]
@@ -584,6 +594,7 @@ class task(osv.osv):
             self.write(cr, uid, new, {'parent_ids':[(6,0,set(parent_ids))], 'child_ids':[(6,0, set(child_ids))]})
 
     def copy_data(self, cr, uid, id, default={}, context=None):
+        print "\n :: copy data :::"
         default = default or {}
         default.update({'work_ids':[], 'date_start': False, 'date_end': False, 'date_deadline': False})
         if not default.get('remaining_hours', False):
@@ -599,6 +610,7 @@ class task(osv.osv):
 
 
     def _is_template(self, cr, uid, ids, field_name, arg, context=None):
+        print "\n :: is template :::"
         res = {}
         for task in self.browse(cr, uid, ids, context=context):
             res[task.id] = True
@@ -608,6 +620,7 @@ class task(osv.osv):
         return res
 
     def _get_task(self, cr, uid, ids, context=None):
+        print "\n :: get task ::"
         result = {}
         for work in self.pool.get('project.task.work').browse(cr, uid, ids, context=context):
             if work.task_id: result[work.task_id.id] = True
@@ -684,21 +697,25 @@ class task(osv.osv):
     _order = "priority, sequence, date_start, name, id"
 
     def set_priority(self, cr, uid, ids, priority):
+        print "\n :: set priority :::"
         """Set task priority
         """
         return self.write(cr, uid, ids, {'priority' : priority})
 
     def set_high_priority(self, cr, uid, ids, *args):
+        print "\n :: set high priority :::"
         """Set task priority to high
         """
         return self.set_priority(cr, uid, ids, '1')
 
     def set_normal_priority(self, cr, uid, ids, *args):
+        print "\n :: set normal priority :::"
         """Set task priority to normal
         """
         return self.set_priority(cr, uid, ids, '2')
 
     def _check_recursion(self, cr, uid, ids, context=None):
+        print "\n :: check recursion :::"
         for id in ids:
             visited_branch = set()
             visited_node = set()
@@ -709,6 +726,7 @@ class task(osv.osv):
         return True
 
     def _check_cycle(self, cr, uid, id, visited_branch, visited_node, context=None):
+        print "\n :: check cycle :::"
         if id in visited_branch: #Cycle
             return False
 
@@ -729,6 +747,7 @@ class task(osv.osv):
         return True
 
     def _check_dates(self, cr, uid, ids, context=None):
+        print "\n :: check dates :::"
         if context == None:
             context = {}
         obj_task = self.browse(cr, uid, ids[0], context=context)
@@ -747,6 +766,7 @@ class task(osv.osv):
     # Override view according to the company definition
     #
     def fields_view_get(self, cr, uid, view_id=None, view_type='form', context=None, toolbar=False, submenu=False):
+        print "\n :: fields view get :::"
         users_obj = self.pool.get('res.users')
 
         # read uom as admin to avoid access rights issues, e.g. for portal/share users,
@@ -778,6 +798,7 @@ class task(osv.osv):
         return res
 
     def _check_child_task(self, cr, uid, ids, context=None):
+        print "\n :: check child task :::"
         if context == None:
             context = {}
         tasks = self.browse(cr, uid, ids, context=context)
@@ -789,6 +810,7 @@ class task(osv.osv):
         return True
 
     def action_close(self, cr, uid, ids, context=None):
+        print "\n :: action close :::"
         # This action open wizard to send email to partner or project manager after close task.
         if context == None:
             context = {}
@@ -813,6 +835,7 @@ class task(osv.osv):
         return res
 
     def do_close(self, cr, uid, ids, context={}):
+        print "\n :: do close ::"
         """
         Close Task
         """
@@ -852,6 +875,7 @@ class task(osv.osv):
         return True
 
     def do_reopen(self, cr, uid, ids, context=None):
+        print "\n :: do reopen:::"
         request = self.pool.get('res.request')
 
         for task in self.browse(cr, uid, ids, context=context):
@@ -871,6 +895,7 @@ class task(osv.osv):
         return True
 
     def do_cancel(self, cr, uid, ids, context={}):
+        print "\n :: do cancel ::"
         request = self.pool.get('res.request')
         tasks = self.browse(cr, uid, ids, context=context)
         self._check_child_task(cr, uid, ids, context=context)
@@ -892,6 +917,7 @@ class task(osv.osv):
         return True
 
     def do_open(self, cr, uid, ids, context={}):
+        print "\n :: do open:::"
         if not isinstance(ids,list): ids = [ids]
         tasks= self.browse(cr, uid, ids, context=context)
         for t in tasks:
@@ -904,11 +930,13 @@ class task(osv.osv):
         return True
 
     def do_draft(self, cr, uid, ids, context={}):
+        print "\n ::do draft ::"
         self.write(cr, uid, ids, {'state': 'draft'}, context=context)
         return True
 
 
     def _delegate_task_attachments(self, cr, uid, task_id, delegated_task_id, context=None):
+        print "\n :: delegate task attachents :::"
         attachment = self.pool.get('ir.attachment')
         attachment_ids = attachment.search(cr, uid, [('res_model', '=', self._name), ('res_id', '=', task_id)], context=context)
         new_attachment_ids = []
@@ -918,6 +946,7 @@ class task(osv.osv):
         
 
     def do_delegate(self, cr, uid, ids, delegate_data={}, context=None):
+        print "\n do delegate :::"
         """
         Delegate Task to another users.
         """
@@ -953,6 +982,7 @@ class task(osv.osv):
         return delegated_tasks
 
     def do_pending(self, cr, uid, ids, context={}):
+        print "\n ::: do pending :::"
         self.write(cr, uid, ids, {'state': 'pending'}, context=context)
         for (id, name) in self.name_get(cr, uid, ids):
             message = _("The task '%s' is pending.") % name
@@ -960,6 +990,7 @@ class task(osv.osv):
         return True
 
     def set_remaining_time(self, cr, uid, ids, remaining_time=1.0, context=None):
+        print "\n ::: set remaining time ::"
         for task in self.browse(cr, uid, ids, context=context):
             if (task.state=='draft') or (task.planned_hours==0.0):
                 self.write(cr, uid, [task.id], {'planned_hours': remaining_time}, context=context)
@@ -967,27 +998,35 @@ class task(osv.osv):
         return True
 
     def set_remaining_time_1(self, cr, uid, ids, context=None):
+        print "\n :: set remaining time 1 :::"
         return self.set_remaining_time(cr, uid, ids, 1.0, context)
 
     def set_remaining_time_2(self, cr, uid, ids, context=None):
+        print "\n set remaining time 2 :::"
         return self.set_remaining_time(cr, uid, ids, 2.0, context)
 
     def set_remaining_time_5(self, cr, uid, ids, context=None):
+        print "\n set remaining time 5 :::"
         return self.set_remaining_time(cr, uid, ids, 5.0, context)
 
     def set_remaining_time_10(self, cr, uid, ids, context=None):
+        print "\n set remaining time 10 :::"
         return self.set_remaining_time(cr, uid, ids, 10.0, context)
 
     def set_kanban_state_blocked(self, cr, uid, ids, context=None):
+        print "\n ::: set kanban state blocked :::"
         self.write(cr, uid, ids, {'kanban_state': 'blocked'}, context=context)
 
     def set_kanban_state_normal(self, cr, uid, ids, context=None):
+        print "\n :: set kanban state normal :::"
         self.write(cr, uid, ids, {'kanban_state': 'normal'}, context=context)
 
     def set_kanban_state_done(self, cr, uid, ids, context=None):
+        print "\n :: set kanban state done ::::"
         self.write(cr, uid, ids, {'kanban_state': 'done'}, context=context)
 
     def _change_type(self, cr, uid, ids, next, *args):
+        print "\n ::: change type :::"
         """
             go to the next stage
             if next is False, go to previous stage
@@ -1011,12 +1050,15 @@ class task(osv.osv):
         return True
 
     def next_type(self, cr, uid, ids, *args):
+        print "\n :: next type ::"
         return self._change_type(cr, uid, ids, True, *args)
 
     def prev_type(self, cr, uid, ids, *args):
+        print "\n :: prev type :::"
         return self._change_type(cr, uid, ids, False, *args)
 
     def _store_history(self, cr, uid, ids, context=None):
+        print "\n ::: store history ::"
         for task in self.browse(cr, uid, ids, context=context):
             self.pool.get('project.task.history').create(cr, uid, {
                 'task_id': task.id,
@@ -1031,6 +1073,7 @@ class task(osv.osv):
         return True
 
     def create(self, cr, uid, vals, context=None):
+        print "\n :: create :::"
         result = super(task, self).create(cr, uid, vals, context=context)
         self._store_history(cr, uid, [result], context=context)
         return result
@@ -1038,6 +1081,7 @@ class task(osv.osv):
     # Overridden to reset the kanban_state to normal whenever
     # the stage (type_id) of the task changes.
     def write(self, cr, uid, ids, vals, context=None):
+        print "\n :: write :::"
         if isinstance(ids, (int, long)):
             ids = [ids]
         if vals and not 'kanban_state' in vals and 'type_id' in vals:
@@ -1054,6 +1098,7 @@ class task(osv.osv):
         return result
 
     def unlink(self, cr, uid, ids, context=None):
+        print "\n :: unlink::::"
         if context == None:
             context = {}
         self._check_child_task(cr, uid, ids, context=context)
@@ -1061,6 +1106,7 @@ class task(osv.osv):
         return res
 
     def _generate_task(self, cr, uid, tasks, ident=4, context=None):
+        print "\n ::: generate task :::"
         context = context or {}
         result = ""
         ident = ' '*ident
diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 7a7ce225f41..b24864d9167 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -370,7 +370,7 @@ class project_issue(crm.crm_case, osv.osv):
 
     def _case_close_notification(self, case, context=None):
         case[0].message_mark_done(context)
-        message = _("Issue <em>%s</em> is <b>closed</b>.")
+        message = _("Issue is <b>closed</b>.")
         case[0].message_append_note('' ,message, type='notification')
         return True
 
@@ -394,7 +394,7 @@ class project_issue(crm.crm_case, osv.osv):
 
     def _case_escalate_notification(self, case, context=None):
         if case[0].project_id.project_escalation_id.user_id.id:
-            message = _("Issue is <b>escalated</b> from project <em>'%s'</em>.") % (case[0].project_id.name)
+            message = _("Issue is <b>escalated</b> from project <em>'%s'</em> to project <em>'%s'</em>.") % (case[0].project_id.name, case[0].project_id.project_escalation_id.name)
             case[0].message_append_note('' ,message, type='notification', need_action_user_id=case[0].project_id.project_escalation_id.user_id.id, context=context)
         else:
             message = _("Issue is <b>escalated</b>.")

From f7059326ac6f06a29025df4ca78e823e696886d6 Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Thu, 15 Mar 2012 11:59:03 +0530
Subject: [PATCH 04/13] [IMP] Improved methods of notification messages of
 social chatter for Project Issue.

bzr revid: jra@tinyerp.com-20120315062903-cg7gm6uv2rdvt9b9
---
 addons/project_issue/project_issue.py | 100 +++++++++++++++-----------
 1 file changed, 57 insertions(+), 43 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index b24864d9167..63be487e220 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -287,9 +287,9 @@ class project_issue(crm.crm_case, osv.osv):
                 'task_id': new_task_id,
                 'state':'pending'
             }
-            self._convert_to_task_notification(cr, uid, ids, context)
+            self.convert_to_task_send_note(cr, uid, ids, context)
             cases = self.browse(cr, uid, ids)
-            self._case_pending_notification(cases, context=context)
+            self.case_pending_send_note(cr, uid, ids, context)
             case_obj.write(cr, uid, [bug.id], vals)
 
         return  {
@@ -345,14 +345,14 @@ class project_issue(crm.crm_case, osv.osv):
         return True
 
     def write(self, cr, uid, ids, vals, context=None):
-        #Update last action date everytime the user change the stage, the state or send a new email
+        #Update last action date every time the user change the stage, the state or send a new email
         logged_fields = ['type_id', 'state', 'message_ids']
         if any([field in vals for field in logged_fields]):
             vals['date_action_last'] = time.strftime('%Y-%m-%d %H:%M:%S')
         if 'type_id' in vals and vals['type_id']:
             stage = self.pool.get('project.task.type').browse(cr, uid, vals['type_id'], context=context)
             self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Changed stage to <b>%s</b>.") % stage.name, type='notification')
+                        _("changed stage to <b>%s</b>.") % stage.name, type='notification')
         return super(project_issue, self).write(cr, uid, ids, vals, context)
 
     def onchange_task_id(self, cr, uid, ids, task_id, context=None):
@@ -362,56 +362,69 @@ class project_issue(crm.crm_case, osv.osv):
         task = self.pool.get('project.task').browse(cr, uid, task_id, context=context)
         return {'value':{'user_id': task.user_id.id,}}
 
-    def _case_open_notification(self, case, context=None):
-        if case.state:
-            message = _("Issue is <b>opened</b>.")
-            case.message_append_note('' ,message, type='notification')
+    def case_open_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            message = _("has been <b>opened</b>.")
+            obj.message_append_note('' ,message)
         return True
 
-    def _case_close_notification(self, case, context=None):
-        case[0].message_mark_done(context)
-        message = _("Issue is <b>closed</b>.")
-        case[0].message_append_note('' ,message, type='notification')
+    def case_close_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            message = _("has been <b>closed</b>.")
+            obj.message_append_note('' ,message)
         return True
 
 
-    def _convert_to_task_notification(self, cr, uid, ids, context=None):
+    def convert_to_task_send_note(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
             self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Issue is <b>converted</b> in to task."), type='notification', context=context)
+                        _("has been <b>converted</b> in to task."), type='notification', context=context)
         return True
 
-    def create_notificate(self, cr, uid, ids, context=None):
+    def get_needaction_user_id(self, cr, uid, ids, name, arg, context=None):
+        result = {}
         for obj in self.browse(cr, uid, ids, context=context):
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Issue is <b>created</b>."), type='notification', need_action_user_id=False, context=context)
-        return True
+            result[obj.id] = False
+            if (obj.state == 'draft' and obj.user_id):
+                result[obj.id] = obj.user_id.id
+            if obj.project_id.project_escalation_id.user_id:
+                result[obj.id] = obj.project_id.project_escalation_id.user_id.id
+        return result
 
-    def _case_pending_notification(self, case, context=None):
-        message = _("Issue is on <b>pending<b>.")
-        case[0].message_append_note('' ,message, type='notification')
-        return True
-
-    def _case_escalate_notification(self, case, context=None):
-        if case[0].project_id.project_escalation_id.user_id.id:
-            message = _("Issue is <b>escalated</b> from project <em>'%s'</em> to project <em>'%s'</em>.") % (case[0].project_id.name, case[0].project_id.project_escalation_id.name)
-            case[0].message_append_note('' ,message, type='notification', need_action_user_id=case[0].project_id.project_escalation_id.user_id.id, context=context)
-        else:
-            message = _("Issue is <b>escalated</b>.")
-            case[0].message_append_note('' ,message, type='notification', need_action_user_id=False, context=context)
-        
-        return True
-
-    def _case_reset_notification(self, cr, uid, ids, context=None):
+    def case_escalate_send_note(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Issue is reset as <b>new<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
+            if obj.project_id.project_escalation_id.user_id.id:
+                message = _("has been<b>escalated</b> from project <em>'%s'</em> to project <em>'%s'</em>.") % (obj.project_id.name, obj.project_id.project_escalation_id.name)
+                obj.message_append_note('' ,message, type='notification', context=context)
+            else:
+                message = _("has been <b>escalated</b>.")
+                obj.message_append_note('' ,message, type='notification', context=context)
         return True
 
-    def _case_cancel_notification(self, case, context=None):
-        case[0].message_mark_done(context=context)
-        message = _("Issue is <b>cancelled<b>.")
-        case[0].message_append_note('' ,message, type="notification")
+    def case_create_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+#            self.message_subscribe(cr, uid, ids, [obj.user_id.id], context=context)
+            message = _("has been <b>created</b>.")
+            self.message_append_note(cr, uid, ids, _('System notification'),
+                        message, type='notification', context=context)
+        return True
+
+    def case_pending_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            message = _("has been <b>pending<b>.")
+            obj.message_append_note('' ,message)
+        return True
+
+    def case_reset_send_note(self,  cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            message =_("has been set as <b>new<b>.")
+            obj.message_append_note('' ,message)
+        return True
+
+    def case_cancel_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            message = _("has been <b>cancelled<b>.")
+            obj.message_append_note('' ,message)
         return True
 
     def case_reset(self, cr, uid, ids, context=None):
@@ -419,7 +432,7 @@ class project_issue(crm.crm_case, osv.osv):
         """
         res = super(project_issue, self).case_reset(cr, uid, ids, context)
         self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
-        self._case_reset_notification(cr, uid, ids, context)
+        self.case_reset_send_note(cr, uid, ids, context)
         return res
 
     def case_pending(self, cr, uid, ids, context=None):
@@ -429,6 +442,7 @@ class project_issue(crm.crm_case, osv.osv):
         return res
 
     def case_cancel(self, cr, uid, ids, context=None):
+        print "\n :: case cancel ::::"
         """Overrides cancel for crm_case for setting probability
         """
         res = super(project_issue, self).case_cancel(cr, uid, ids, context)
@@ -437,7 +451,7 @@ class project_issue(crm.crm_case, osv.osv):
 
     def create(self, cr, uid, vals, context=None):
         obj_id = super(project_issue, self).create(cr, uid, vals, context=context)
-        self.create_notificate(cr, uid, [obj_id], context=context)
+        self.case_create_send_note(cr, uid, [obj_id], context=context)
         return obj_id
 
     def case_open(self, cr, uid, ids, context=None):
@@ -482,7 +496,7 @@ class project_issue(crm.crm_case, osv.osv):
             else:
                 raise osv.except_osv(_('Warning !'), _('You cannot escalate this issue.\nThe relevant Project has not configured the Escalation Project!'))
             self.write(cr, uid, [case.id], data)
-        self._case_escalate_notification(cases, context=context)
+        self.case_escalate_send_note(cr, uid, ids, context=context)
         return True
 
     def message_new(self, cr, uid, msg, custom_values=None, context=None):

From bb02b5f663c0c66ba37543b5cf64ad399ca492ee Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Thu, 15 Mar 2012 15:52:11 +0530
Subject: [PATCH 05/13] [IMP] Improved message notification of social for
 project escalation.

bzr revid: jra@tinyerp.com-20120315102211-0ueh26nr4yrt2lj6
---
 addons/project_issue/project_issue.py | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 63be487e220..2d47e245767 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -387,14 +387,14 @@ class project_issue(crm.crm_case, osv.osv):
             result[obj.id] = False
             if (obj.state == 'draft' and obj.user_id):
                 result[obj.id] = obj.user_id.id
-            if obj.project_id.project_escalation_id.user_id:
-                result[obj.id] = obj.project_id.project_escalation_id.user_id.id
+            if obj.project_id.user_id:
+                result[obj.id] = obj.project_id.user_id.id
         return result
 
     def case_escalate_send_note(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
-            if obj.project_id.project_escalation_id.user_id.id:
-                message = _("has been<b>escalated</b> from project <em>'%s'</em> to project <em>'%s'</em>.") % (obj.project_id.name, obj.project_id.project_escalation_id.name)
+            if obj.project_id:
+                message = _("has been <b>escalated</b> to <em>'%s'</em>.") % (obj.project_id.name)
                 obj.message_append_note('' ,message, type='notification', context=context)
             else:
                 message = _("has been <b>escalated</b>.")
@@ -442,7 +442,6 @@ class project_issue(crm.crm_case, osv.osv):
         return res
 
     def case_cancel(self, cr, uid, ids, context=None):
-        print "\n :: case cancel ::::"
         """Overrides cancel for crm_case for setting probability
         """
         res = super(project_issue, self).case_cancel(cr, uid, ids, context)

From 0eb94e3cf5712798b73b153033f8c0048316a50e Mon Sep 17 00:00:00 2001
From: "Jiten (OpenERP)" <jra@tinyerp.com>
Date: Thu, 15 Mar 2012 16:08:50 +0530
Subject: [PATCH 06/13] [REM] Remove print line statement.

bzr revid: jra@tinyerp.com-20120315103850-5n1tr0gs8y3s6yo5
---
 addons/project/project.py | 48 +--------------------------------------
 1 file changed, 1 insertion(+), 47 deletions(-)

diff --git a/addons/project/project.py b/addons/project/project.py
index a1d492fb6f6..166d8574f92 100644
--- a/addons/project/project.py
+++ b/addons/project/project.py
@@ -462,7 +462,6 @@ class task(osv.osv):
 
 
     def _resolve_project_id_from_context(self, cr, uid, context=None):
-        print "\n ::: resolve project id from context ::::"
         """Return ID of project based on the value of 'project_id'
            context key, or None if it cannot be resolved to a single project.
         """
@@ -477,7 +476,6 @@ class task(osv.osv):
                 return project_ids[0][0]
 
     def _read_group_type_id(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
-        print "\n :::: read group type id ::::"
         stage_obj = self.pool.get('project.task.type')
         project_id = self._resolve_project_id_from_context(cr, uid, context=context)
         order = stage_obj._order
@@ -496,7 +494,6 @@ class task(osv.osv):
         return result
 
     def _read_group_user_id(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
-        print "\n :: read group user id :::"
         res_users = self.pool.get('res.users')
         project_id = self._resolve_project_id_from_context(cr, uid, context=context)
         access_rights_uid = access_rights_uid or uid
@@ -520,7 +517,6 @@ class task(osv.osv):
 
 
     def search(self, cr, user, args, offset=0, limit=None, order=None, context=None, count=False):
-        print "\n ::: search :::"
         obj_project = self.pool.get('project.project')
         for domain in args:
             if domain[0] == 'project_id' and (not isinstance(domain[2], str)):
@@ -531,14 +527,12 @@ class task(osv.osv):
         return super(task, self).search(cr, user, args, offset=offset, limit=limit, order=order, context=context, count=count)
 
     def _str_get(self, task, level=0, border='***', context=None):
-        print "\n :: st get :::"
         return border+' '+(task.user_id and task.user_id.name.upper() or '')+(level and (': L'+str(level)) or '')+(' - %.1fh / %.1fh'%(task.effective_hours or 0.0,task.planned_hours))+' '+border+'\n'+ \
             border[0]+' '+(task.name or '')+'\n'+ \
             (task.description or '')+'\n\n'
 
     # Compute: effective_hours, total_hours, progress
     def _hours_get(self, cr, uid, ids, field_names, args, context=None):
-        print "\n ::: hours get :::"
         res = {}
         cr.execute("SELECT task_id, COALESCE(SUM(hours),0) FROM project_task_work WHERE task_id IN %s GROUP BY task_id",(tuple(ids),))
         hours = dict(cr.fetchall())
@@ -554,17 +548,14 @@ class task(osv.osv):
 
 
     def onchange_remaining(self, cr, uid, ids, remaining=0.0, planned = 0.0):
-        print "\n ::: onchange remaining :::"
         if remaining and not planned:
             return {'value':{'planned_hours': remaining}}
         return {}
 
     def onchange_planned(self, cr, uid, ids, planned = 0.0, effective = 0.0):
-        print "\n :::: onchange planned ::::"
         return {'value':{'remaining_hours': planned - effective}}
 
     def onchange_project(self, cr, uid, id, project_id):
-        print "\n :: onchange project :::"
         if not project_id:
             return {}
         data = self.pool.get('project.project').browse(cr, uid, [project_id])
@@ -574,7 +565,6 @@ class task(osv.osv):
         return {}
 
     def duplicate_task(self, cr, uid, map_ids, context=None):
-        print "\n ::: duplicate tasK:::"
         for new in map_ids.values():
             task = self.browse(cr, uid, new, context)
             child_ids = [ ch.id for ch in task.child_ids]
@@ -594,7 +584,6 @@ class task(osv.osv):
             self.write(cr, uid, new, {'parent_ids':[(6,0,set(parent_ids))], 'child_ids':[(6,0, set(child_ids))]})
 
     def copy_data(self, cr, uid, id, default={}, context=None):
-        print "\n :: copy data :::"
         default = default or {}
         default.update({'work_ids':[], 'date_start': False, 'date_end': False, 'date_deadline': False})
         if not default.get('remaining_hours', False):
@@ -610,7 +599,6 @@ class task(osv.osv):
 
 
     def _is_template(self, cr, uid, ids, field_name, arg, context=None):
-        print "\n :: is template :::"
         res = {}
         for task in self.browse(cr, uid, ids, context=context):
             res[task.id] = True
@@ -620,7 +608,6 @@ class task(osv.osv):
         return res
 
     def _get_task(self, cr, uid, ids, context=None):
-        print "\n :: get task ::"
         result = {}
         for work in self.pool.get('project.task.work').browse(cr, uid, ids, context=context):
             if work.task_id: result[work.task_id.id] = True
@@ -697,25 +684,21 @@ class task(osv.osv):
     _order = "priority, sequence, date_start, name, id"
 
     def set_priority(self, cr, uid, ids, priority):
-        print "\n :: set priority :::"
         """Set task priority
         """
         return self.write(cr, uid, ids, {'priority' : priority})
 
     def set_high_priority(self, cr, uid, ids, *args):
-        print "\n :: set high priority :::"
         """Set task priority to high
         """
         return self.set_priority(cr, uid, ids, '1')
 
     def set_normal_priority(self, cr, uid, ids, *args):
-        print "\n :: set normal priority :::"
         """Set task priority to normal
         """
         return self.set_priority(cr, uid, ids, '2')
 
     def _check_recursion(self, cr, uid, ids, context=None):
-        print "\n :: check recursion :::"
         for id in ids:
             visited_branch = set()
             visited_node = set()
@@ -726,7 +709,6 @@ class task(osv.osv):
         return True
 
     def _check_cycle(self, cr, uid, id, visited_branch, visited_node, context=None):
-        print "\n :: check cycle :::"
         if id in visited_branch: #Cycle
             return False
 
@@ -747,7 +729,6 @@ class task(osv.osv):
         return True
 
     def _check_dates(self, cr, uid, ids, context=None):
-        print "\n :: check dates :::"
         if context == None:
             context = {}
         obj_task = self.browse(cr, uid, ids[0], context=context)
@@ -766,7 +747,6 @@ class task(osv.osv):
     # Override view according to the company definition
     #
     def fields_view_get(self, cr, uid, view_id=None, view_type='form', context=None, toolbar=False, submenu=False):
-        print "\n :: fields view get :::"
         users_obj = self.pool.get('res.users')
 
         # read uom as admin to avoid access rights issues, e.g. for portal/share users,
@@ -798,7 +778,6 @@ class task(osv.osv):
         return res
 
     def _check_child_task(self, cr, uid, ids, context=None):
-        print "\n :: check child task :::"
         if context == None:
             context = {}
         tasks = self.browse(cr, uid, ids, context=context)
@@ -810,7 +789,6 @@ class task(osv.osv):
         return True
 
     def action_close(self, cr, uid, ids, context=None):
-        print "\n :: action close :::"
         # This action open wizard to send email to partner or project manager after close task.
         if context == None:
             context = {}
@@ -835,7 +813,6 @@ class task(osv.osv):
         return res
 
     def do_close(self, cr, uid, ids, context={}):
-        print "\n :: do close ::"
         """
         Close Task
         """
@@ -875,8 +852,7 @@ class task(osv.osv):
         return True
 
     def do_reopen(self, cr, uid, ids, context=None):
-        print "\n :: do reopen:::"
-        request = self.pool.get('res.request')
+         request = self.pool.get('res.request')
 
         for task in self.browse(cr, uid, ids, context=context):
             project = task.project_id
@@ -895,7 +871,6 @@ class task(osv.osv):
         return True
 
     def do_cancel(self, cr, uid, ids, context={}):
-        print "\n :: do cancel ::"
         request = self.pool.get('res.request')
         tasks = self.browse(cr, uid, ids, context=context)
         self._check_child_task(cr, uid, ids, context=context)
@@ -917,7 +892,6 @@ class task(osv.osv):
         return True
 
     def do_open(self, cr, uid, ids, context={}):
-        print "\n :: do open:::"
         if not isinstance(ids,list): ids = [ids]
         tasks= self.browse(cr, uid, ids, context=context)
         for t in tasks:
@@ -930,13 +904,11 @@ class task(osv.osv):
         return True
 
     def do_draft(self, cr, uid, ids, context={}):
-        print "\n ::do draft ::"
         self.write(cr, uid, ids, {'state': 'draft'}, context=context)
         return True
 
 
     def _delegate_task_attachments(self, cr, uid, task_id, delegated_task_id, context=None):
-        print "\n :: delegate task attachents :::"
         attachment = self.pool.get('ir.attachment')
         attachment_ids = attachment.search(cr, uid, [('res_model', '=', self._name), ('res_id', '=', task_id)], context=context)
         new_attachment_ids = []
@@ -946,7 +918,6 @@ class task(osv.osv):
         
 
     def do_delegate(self, cr, uid, ids, delegate_data={}, context=None):
-        print "\n do delegate :::"
         """
         Delegate Task to another users.
         """
@@ -982,7 +953,6 @@ class task(osv.osv):
         return delegated_tasks
 
     def do_pending(self, cr, uid, ids, context={}):
-        print "\n ::: do pending :::"
         self.write(cr, uid, ids, {'state': 'pending'}, context=context)
         for (id, name) in self.name_get(cr, uid, ids):
             message = _("The task '%s' is pending.") % name
@@ -990,7 +960,6 @@ class task(osv.osv):
         return True
 
     def set_remaining_time(self, cr, uid, ids, remaining_time=1.0, context=None):
-        print "\n ::: set remaining time ::"
         for task in self.browse(cr, uid, ids, context=context):
             if (task.state=='draft') or (task.planned_hours==0.0):
                 self.write(cr, uid, [task.id], {'planned_hours': remaining_time}, context=context)
@@ -998,35 +967,27 @@ class task(osv.osv):
         return True
 
     def set_remaining_time_1(self, cr, uid, ids, context=None):
-        print "\n :: set remaining time 1 :::"
         return self.set_remaining_time(cr, uid, ids, 1.0, context)
 
     def set_remaining_time_2(self, cr, uid, ids, context=None):
-        print "\n set remaining time 2 :::"
         return self.set_remaining_time(cr, uid, ids, 2.0, context)
 
     def set_remaining_time_5(self, cr, uid, ids, context=None):
-        print "\n set remaining time 5 :::"
         return self.set_remaining_time(cr, uid, ids, 5.0, context)
 
     def set_remaining_time_10(self, cr, uid, ids, context=None):
-        print "\n set remaining time 10 :::"
         return self.set_remaining_time(cr, uid, ids, 10.0, context)
 
     def set_kanban_state_blocked(self, cr, uid, ids, context=None):
-        print "\n ::: set kanban state blocked :::"
         self.write(cr, uid, ids, {'kanban_state': 'blocked'}, context=context)
 
     def set_kanban_state_normal(self, cr, uid, ids, context=None):
-        print "\n :: set kanban state normal :::"
         self.write(cr, uid, ids, {'kanban_state': 'normal'}, context=context)
 
     def set_kanban_state_done(self, cr, uid, ids, context=None):
-        print "\n :: set kanban state done ::::"
         self.write(cr, uid, ids, {'kanban_state': 'done'}, context=context)
 
     def _change_type(self, cr, uid, ids, next, *args):
-        print "\n ::: change type :::"
         """
             go to the next stage
             if next is False, go to previous stage
@@ -1050,15 +1011,12 @@ class task(osv.osv):
         return True
 
     def next_type(self, cr, uid, ids, *args):
-        print "\n :: next type ::"
         return self._change_type(cr, uid, ids, True, *args)
 
     def prev_type(self, cr, uid, ids, *args):
-        print "\n :: prev type :::"
         return self._change_type(cr, uid, ids, False, *args)
 
     def _store_history(self, cr, uid, ids, context=None):
-        print "\n ::: store history ::"
         for task in self.browse(cr, uid, ids, context=context):
             self.pool.get('project.task.history').create(cr, uid, {
                 'task_id': task.id,
@@ -1073,7 +1031,6 @@ class task(osv.osv):
         return True
 
     def create(self, cr, uid, vals, context=None):
-        print "\n :: create :::"
         result = super(task, self).create(cr, uid, vals, context=context)
         self._store_history(cr, uid, [result], context=context)
         return result
@@ -1081,7 +1038,6 @@ class task(osv.osv):
     # Overridden to reset the kanban_state to normal whenever
     # the stage (type_id) of the task changes.
     def write(self, cr, uid, ids, vals, context=None):
-        print "\n :: write :::"
         if isinstance(ids, (int, long)):
             ids = [ids]
         if vals and not 'kanban_state' in vals and 'type_id' in vals:
@@ -1098,7 +1054,6 @@ class task(osv.osv):
         return result
 
     def unlink(self, cr, uid, ids, context=None):
-        print "\n :: unlink::::"
         if context == None:
             context = {}
         self._check_child_task(cr, uid, ids, context=context)
@@ -1106,7 +1061,6 @@ class task(osv.osv):
         return res
 
     def _generate_task(self, cr, uid, tasks, ident=4, context=None):
-        print "\n ::: generate task :::"
         context = context or {}
         result = ""
         ident = ' '*ident

From 5eebf54a7528b4141980c4a6af225457cf520cac Mon Sep 17 00:00:00 2001
From: "Bhumi Thakkar (Open ERP)" <bth@tinyerp.com>
Date: Tue, 20 Mar 2012 17:17:28 +0530
Subject: [PATCH 07/13] [IMP] Renamed methods and modify code for loops and
 overwrite get_needaction_user_ids and message_get_subscribers.

bzr revid: bth@tinyerp.com-20120320114728-6awxltk66d3cykzg
---
 addons/project_issue/project_issue.py | 53 +++++++++++++++------------
 1 file changed, 29 insertions(+), 24 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 2d47e245767..759e19d81e7 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -363,34 +363,40 @@ class project_issue(crm.crm_case, osv.osv):
         return {'value':{'user_id': task.user_id.id,}}
 
     def case_open_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
+        for id in ids:
             message = _("has been <b>opened</b>.")
-            obj.message_append_note('' ,message)
+            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
     def case_close_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
+        for id in ids:
             message = _("has been <b>closed</b>.")
-            obj.message_append_note('' ,message)
+            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
 
     def convert_to_task_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("has been <b>converted</b> in to task."), type='notification', context=context)
+        for id in ids:
+            message = _("has been <b>converted</b> in to task.")
+            self.message_append_note(cr, uid, [id], 'System notification', message, context=context)
         return True
 
-    def get_needaction_user_id(self, cr, uid, ids, name, arg, context=None):
-        result = {}
+    def get_needaction_user_ids(self, cr, uid, ids, context=None):
+        result = dict.fromkeys(ids, [])
         for obj in self.browse(cr, uid, ids, context=context):
-            result[obj.id] = False
-            if (obj.state == 'draft' and obj.user_id):
-                result[obj.id] = obj.user_id.id
+            if obj.state == 'draft' and obj.user_id:
+                result[obj.id] = [obj.user_id.id]
             if obj.project_id.user_id:
-                result[obj.id] = obj.project_id.user_id.id
+                result[obj.id] = [obj.project_id.user_id.id]
         return result
 
+    def message_get_subscribers(self, cr, uid, ids, context=None):
+        sub_ids = self.message_get_subscribers_ids(cr, uid, ids, context=context);
+        for obj in self.browse(cr, uid, ids, context=context):
+            if obj.user_id:
+                sub_ids.append(obj.user_id.id)
+        return self.pool.get('res.users').read(cr, uid, sub_ids, context=context)
+
     def case_escalate_send_note(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
             if obj.project_id:
@@ -401,30 +407,29 @@ class project_issue(crm.crm_case, osv.osv):
                 obj.message_append_note('' ,message, type='notification', context=context)
         return True
 
-    def case_create_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
-#            self.message_subscribe(cr, uid, ids, [obj.user_id.id], context=context)
+    def create_send_note(self, cr, uid, ids, context=None):
+        for id in ids:
             message = _("has been <b>created</b>.")
-            self.message_append_note(cr, uid, ids, _('System notification'),
+            self.message_append_note(cr, uid, [id], _('System notification'),
                         message, type='notification', context=context)
         return True
 
     def case_pending_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
+        for id in ids:
             message = _("has been <b>pending<b>.")
-            obj.message_append_note('' ,message)
+            self.message_append_note(cr, uid, [id], 'System Notification', message, context=context)
         return True
 
     def case_reset_send_note(self,  cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
+        for id in ids:
             message =_("has been set as <b>new<b>.")
-            obj.message_append_note('' ,message)
+            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
     def case_cancel_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
+        for id in ids:
             message = _("has been <b>cancelled<b>.")
-            obj.message_append_note('' ,message)
+            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
     def case_reset(self, cr, uid, ids, context=None):
@@ -450,7 +455,7 @@ class project_issue(crm.crm_case, osv.osv):
 
     def create(self, cr, uid, vals, context=None):
         obj_id = super(project_issue, self).create(cr, uid, vals, context=context)
-        self.case_create_send_note(cr, uid, [obj_id], context=context)
+        self.create_send_note(cr, uid, [obj_id], context=context)
         return obj_id
 
     def case_open(self, cr, uid, ids, context=None):

From 2e48fb0413b54b6b09dba06e4385b2d3a95f4505 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Thibault=20Delavall=C3=A9e?= <tde@openerp.com>
Date: Tue, 20 Mar 2012 18:20:58 +0100
Subject: [PATCH 08/13] [REM] hr_recruitment: back to social-trunk-tde version,
 because already developed in another merge proposal

bzr revid: tde@openerp.com-20120320172058-is9xef2flxm6b68l
---
 addons/hr_recruitment/hr_recruitment.py       | 99 ++++++-------------
 addons/hr_recruitment/hr_recruitment_view.xml | 34 ++++++-
 2 files changed, 58 insertions(+), 75 deletions(-)

diff --git a/addons/hr_recruitment/hr_recruitment.py b/addons/hr_recruitment/hr_recruitment.py
index 18d3f8545ce..68855b79d7d 100644
--- a/addons/hr_recruitment/hr_recruitment.py
+++ b/addons/hr_recruitment/hr_recruitment.py
@@ -171,6 +171,7 @@ class hr_applicant(crm.crm_case, osv.osv):
         'partner_mobile': fields.char('Mobile', size=32),
         'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
         'department_id': fields.many2one('hr.department', 'Department'),
+        'state': fields.selection(AVAILABLE_STATES, 'State', size=16, readonly=True),
         'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
         'response': fields.integer("Response"),
         'reference': fields.char('Refered By', size=128),
@@ -180,7 +181,6 @@ class hr_applicant(crm.crm_case, osv.osv):
         'day_close': fields.function(_compute_day, string='Days to Close', \
                                 multi='day_close', type="float", store=True),
         'color': fields.integer('Color Index'),
-        'emp_id': fields.many2one('hr.employee', 'employee'),
         'user_email': fields.related('user_id', 'user_email', type='char', string='User Email', readonly=True),
     }
 
@@ -391,65 +391,31 @@ class hr_applicant(crm.crm_case, osv.osv):
         self.message_append_dict(cr, uid, ids, msg, context=context)
         return res
 
-    def _case_open_notification(self, case, context=None):
-        message = _("Changed Status to <b>in Progress<b>.")
-        case.message_append_note('' ,message, type='notification')
-        return True
-
-    def _case_close_notification(self, case, context=None):
-        case[0].message_mark_done(context)
-        if case[0].emp_id:
-            message = _("Applicant is <b>hired</b> and employee created.")
-            case[0].message_append_note('' ,message, type='notification')
-        else:
-            message = _("Applicant is <b>hired</b>.")
-            case[0].message_append_note('' ,message, type='notification')
-        return True
-
-    def _case_cancel_notification(self, case, context=None):
-        case[0].message_mark_done(context=context)
-        message = _("Applicant is <b>cancelled<b>.")
-        case[0].message_append_note('' ,message, type="notification")
-        return True
-
-    def _case_pending_notification(self, case, context=None):
-        message = _("Changed Status to <b>pending<b>.")
-        case[0].message_append_note('' ,message, type='notification')
-        return True
-
-    def _case_reset_notification(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Changed Status to <b>new<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
-        return True
-
-    def create_notificate(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
-            self.message_subscribe(cr, uid, ids, [obj.user_id.id], context=context)
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Applicant is <b>created</b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
-        return True
-
-    def create(self, cr, uid, vals, context=None):
-        obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
-        self.create_notificate(cr, uid, [obj_id], context=context)
-        return obj_id
-
-    def case_open(self, cr, uid, ids, context=None):
+    def case_open(self, cr, uid, ids, *args):
         """
-            open Request of the applicant for the hr_recruitment
+        @param self: The object pointer
+        @param cr: the current row, from the database cursor,
+        @param uid: the current user’s ID for security checks,
+        @param ids: List of case's Ids
+        @param *args: Give Tuple Value
         """
-        res = super(hr_applicant, self).case_open(cr, uid, ids, context)
+        res = super(hr_applicant, self).case_open(cr, uid, ids, *args)
         date = self.read(cr, uid, ids, ['date_open'])[0]
         if not date['date_open']:
             self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
+        for (id, name) in self.name_get(cr, uid, ids):
+            message = _("The job request '%s' has been set 'in progress'.") % name
+            self.log(cr, uid, id, message)
         return res
 
-    def case_close(self, cr, uid, ids, context=None):
-        res = super(hr_applicant, self).case_close(cr, uid, ids, context)
+    def case_close(self, cr, uid, ids, *args):
+        res = super(hr_applicant, self).case_close(cr, uid, ids, *args)
+        for (id, name) in self.name_get(cr, uid, ids):
+            message = _("Applicant '%s' is being hired.") % name
+            self.log(cr, uid, id, message)
         return res
 
-    def case_close_with_emp(self, cr, uid, ids, context=None):
+    def case_close_with_emp(self, cr, uid, ids, *args):
         hr_employee = self.pool.get('hr.employee')
         model_data = self.pool.get('ir.model.data')
         act_window = self.pool.get('ir.actions.act_window')
@@ -465,8 +431,7 @@ class hr_applicant(crm.crm_case, osv.osv):
                                                      'address_home_id': address_id,
                                                      'department_id': applicant.department_id.id
                                                      })
-                self.write(cr, uid, [applicant.id], {'emp_id': emp_id})
-                self.case_close(cr, uid, [applicant.id], context)
+                self.case_close(cr, uid, [applicant.id], *args)
             else:
                 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
 
@@ -477,25 +442,17 @@ class hr_applicant(crm.crm_case, osv.osv):
         dict_act_window['view_mode'] = 'form,tree'
         return dict_act_window
 
-    def case_cancel(self, cr, uid, ids, context=None):
-        """Overrides cancel for crm_case for setting probability
-        """
-        res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
-        self.write(cr, uid, ids, {'probability' : 0.0})
-        return res
-
-    def case_pending(self, cr, uid, ids, context=None):
-        """Marks case as pending"""
-        res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
-        self.write(cr, uid, ids, {'probability' : 0.0})
-        return res
-
-    def case_reset(self, cr, uid, ids, context=None):
+    def case_reset(self, cr, uid, ids, *args):
         """Resets case as draft
+        @param self: The object pointer
+        @param cr: the current row, from the database cursor,
+        @param uid: the current user’s ID for security checks,
+        @param ids: List of case Ids
+        @param *args: Tuple Value for additional Params
         """
-        res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
+
+        res = super(hr_applicant, self).case_reset(cr, uid, ids, *args)
         self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
-        self._case_reset_notification(cr, uid, ids, context)
         return res
 
     def set_priority(self, cr, uid, ids, priority, *args):
@@ -516,8 +473,8 @@ class hr_applicant(crm.crm_case, osv.osv):
     def write(self, cr, uid, ids, vals, context=None):
         if 'stage_id' in vals and vals['stage_id']:
             stage = self.pool.get('hr.recruitment.stage').browse(cr, uid, vals['stage_id'], context=context)
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("Changed stage to <b>%s</b>.") % stage.name, type='notification')
+            text = _("Changed Stage to: %s") % stage.name
+            self.message_append(cr, uid, ids, text, body_text=text, context=context)
         return super(hr_applicant,self).write(cr, uid, ids, vals, context=context)
 
 hr_applicant()
diff --git a/addons/hr_recruitment/hr_recruitment_view.xml b/addons/hr_recruitment/hr_recruitment_view.xml
index 2faac78af8c..69a7c104073 100644
--- a/addons/hr_recruitment/hr_recruitment_view.xml
+++ b/addons/hr_recruitment/hr_recruitment_view.xml
@@ -79,9 +79,6 @@
                         <field name="partner_name"/>
                         <field name="job_id" on_change="onchange_job(job_id)"/>
                         <button name="action_makeMeeting" type="object" string="Meeting" icon="gtk-index"/>
-                        <button string="Send New Email"
-                            name="%(mail.action_email_compose_message_wizard)d"
-                            icon="terp-mail-message-new" type="action"/>
                     <newline/>
                     <field name="department_id" widget="selection" on_change="onchange_department_id(department_id)"/>
                     <group colspan="2" col="4">
@@ -127,6 +124,13 @@
                             <field name="source_id"/>
                             <field name="reference"/>
                         </group>
+                        <group col="2" colspan="2">
+                           <separator colspan="2" string="Dates"/>
+                           <field name="create_date"/>
+                           <field name="write_date"/>
+                           <field name="date_closed"/>
+                           <field name="date_open"/>
+                        </group>
                         <separator colspan="4" string="Status"/>
                         <group col="8" colspan="4">
                             <field name="state" widget="statusbar" statusbar_visible="draft,open,done" statusbar_colors='{"pending":"blue"}'/>
@@ -137,11 +141,33 @@
                             <button name="case_reset" string="Reset to New" states="done,cancel" type="object" icon="gtk-convert"/>
                         </group>
                    </page>
+                   <page string="Communication &amp; History" groups="base.group_extended">
+                       <group colspan="4">
+                           <field colspan="4" name="email_cc" string="Global CC" widget="char"/>
+                       </group>
+                       <field name="message_ids" colspan="4" nolabel="1" mode="tree" readonly="1">
+                            <tree string="History">
+                                <field name="display_text" string="History Information"/>
+                                <field name="email_from" invisible="1"/>
+                                <button
+                                    string="Reply" attrs="{'invisible': [('email_from', '=', False)]}"
+                                    name="%(mail.action_email_compose_message_wizard)d"
+                                    context="{'mail.compose.message.mode':'reply', 'message_id':active_id}"
+                                    icon="terp-mail-replied" type="action" />
+                            </tree>
+                        </field>
+                        <button string="Add Internal Note"
+                                name="%(crm.action_crm_add_note)d"
+                                context="{'model': 'crm.lead' }"
+                                icon="terp-document-new" type="action" />
+                        <button string="Send New Email"
+                            name="%(mail.action_email_compose_message_wizard)d"
+                            icon="terp-mail-message-new" type="action"/>
+                 </page>
                  <page string="Notes">
                      <field name="description" nolabel="1" colspan="4"/>
                  </page>
                 </notebook>
-                <field name="message_ids_social" colspan="4" widget="ThreadView" nolabel="1"/>
             </form>
         </field>
     </record>

From 2a88aeed156315471ae165106162120ed3607680 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Thibault=20Delavall=C3=A9e?= <tde@openerp.com>
Date: Tue, 20 Mar 2012 18:37:40 +0100
Subject: [PATCH 09/13] [FIX] Fixed indentation problem

bzr revid: tde@openerp.com-20120320173740-almu2spg1l1vsu96
---
 addons/project/project.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/addons/project/project.py b/addons/project/project.py
index 9f8e1b0f7c0..c89ae55d369 100644
--- a/addons/project/project.py
+++ b/addons/project/project.py
@@ -893,7 +893,7 @@ class task(osv.osv):
         return True
 
     def do_reopen(self, cr, uid, ids, context=None):
-         request = self.pool.get('res.request')
+        request = self.pool.get('res.request')
 
         for task in self.browse(cr, uid, ids, context=context):
             project = task.project_id

From 143718ec7700fb20e10f6225b0a765df826a8e43 Mon Sep 17 00:00:00 2001
From: "Bhumi Thakkar (Open ERP)" <bth@tinyerp.com>
Date: Wed, 21 Mar 2012 16:41:52 +0530
Subject: [PATCH 10/13] [FIX] Code Optimization.

bzr revid: bth@tinyerp.com-20120321111152-hif1n4cz2q17lneu
---
 addons/project_issue/project_issue.py | 46 ++-------------------------
 1 file changed, 3 insertions(+), 43 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 759e19d81e7..3f416ad0e15 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -368,19 +368,15 @@ class project_issue(crm.crm_case, osv.osv):
             self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
-    def case_close_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>closed</b>.")
-            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
-        return True
-
-
     def convert_to_task_send_note(self, cr, uid, ids, context=None):
         for id in ids:
             message = _("has been <b>converted</b> in to task.")
             self.message_append_note(cr, uid, [id], 'System notification', message, context=context)
         return True
 
+    def case_get_note_msg_prefix(self, cr, uid, id, context=None):
+        return ''
+
     def get_needaction_user_ids(self, cr, uid, ids, context=None):
         result = dict.fromkeys(ids, [])
         for obj in self.browse(cr, uid, ids, context=context):
@@ -414,24 +410,12 @@ class project_issue(crm.crm_case, osv.osv):
                         message, type='notification', context=context)
         return True
 
-    def case_pending_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>pending<b>.")
-            self.message_append_note(cr, uid, [id], 'System Notification', message, context=context)
-        return True
-
     def case_reset_send_note(self,  cr, uid, ids, context=None):
         for id in ids:
             message =_("has been set as <b>new<b>.")
             self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
         return True
 
-    def case_cancel_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>cancelled<b>.")
-            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
-        return True
-
     def case_reset(self, cr, uid, ids, context=None):
         """Resets case as draft
         """
@@ -440,19 +424,6 @@ class project_issue(crm.crm_case, osv.osv):
         self.case_reset_send_note(cr, uid, ids, context)
         return res
 
-    def case_pending(self, cr, uid, ids, context=None):
-        """Marks case as pending"""
-        res = super(project_issue, self).case_pending(cr, uid, ids, context)
-        self.write(cr, uid, ids, context)
-        return res
-
-    def case_cancel(self, cr, uid, ids, context=None):
-        """Overrides cancel for crm_case for setting probability
-        """
-        res = super(project_issue, self).case_cancel(cr, uid, ids, context)
-        self.write(cr, uid, ids, context)
-        return res
-
     def create(self, cr, uid, vals, context=None):
         obj_id = super(project_issue, self).create(cr, uid, vals, context=context)
         self.create_send_note(cr, uid, [obj_id], context=context)
@@ -470,17 +441,6 @@ class project_issue(crm.crm_case, osv.osv):
         self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'), 'user_id' : uid})
         return res
 
-    def case_close(self, cr, uid, ids, context=None):
-        """
-        @param self: The object pointer
-        @param cr: the current row, from the database cursor,
-        @param uid: the current user’s ID for security checks,
-        @param ids: List of case's Ids
-        """
-
-        res = super(project_issue, self).case_close(cr, uid, ids, context)
-        return res
-
     def case_escalate(self, cr, uid, ids, context=None):
         """Escalates case to top level
         @param self: The object pointer

From ad9803d842de7c1f083d0aa1413e875ab1d36564 Mon Sep 17 00:00:00 2001
From: "Bhumi Thakkar (Open ERP)" <bth@tinyerp.com>
Date: Thu, 22 Mar 2012 12:28:43 +0530
Subject: [PATCH 11/13] [FIX] Code Optimization.

bzr revid: bth@tinyerp.com-20120322065843-hlfvb9d5il0wlcrg
---
 addons/project_issue/project_issue.py | 23 +++++++----------------
 1 file changed, 7 insertions(+), 16 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 3f416ad0e15..449f0f8da74 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -393,6 +393,12 @@ class project_issue(crm.crm_case, osv.osv):
                 sub_ids.append(obj.user_id.id)
         return self.pool.get('res.users').read(cr, uid, sub_ids, context=context)
 
+    def create_send_note(self, cr, uid, ids, context=None):
+        message = _("has been <b>created</b>.")
+        self.message_append_note(cr, uid, ids, _('System notification'),
+                        message, type='notification', context=context)
+        return True
+
     def case_escalate_send_note(self, cr, uid, ids, context=None):
         for obj in self.browse(cr, uid, ids, context=context):
             if obj.project_id:
@@ -403,25 +409,11 @@ class project_issue(crm.crm_case, osv.osv):
                 obj.message_append_note('' ,message, type='notification', context=context)
         return True
 
-    def create_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>created</b>.")
-            self.message_append_note(cr, uid, [id], _('System notification'),
-                        message, type='notification', context=context)
-        return True
-
-    def case_reset_send_note(self,  cr, uid, ids, context=None):
-        for id in ids:
-            message =_("has been set as <b>new<b>.")
-            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
-        return True
-
     def case_reset(self, cr, uid, ids, context=None):
         """Resets case as draft
         """
         res = super(project_issue, self).case_reset(cr, uid, ids, context)
         self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
-        self.case_reset_send_note(cr, uid, ids, context)
         return res
 
     def create(self, cr, uid, vals, context=None):
@@ -436,7 +428,6 @@ class project_issue(crm.crm_case, osv.osv):
         @param uid: the current user’s ID for security checks,
         @param ids: List of case's Ids
         """
-
         res = super(project_issue, self).case_open(cr, uid, ids, context)
         self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'), 'user_id' : uid})
         return res
@@ -460,7 +451,7 @@ class project_issue(crm.crm_case, osv.osv):
             else:
                 raise osv.except_osv(_('Warning !'), _('You cannot escalate this issue.\nThe relevant Project has not configured the Escalation Project!'))
             self.write(cr, uid, [case.id], data)
-        self.case_escalate_send_note(cr, uid, ids, context=context)
+            self.case_escalate_send_note(cr, uid, [case.id], context)
         return True
 
     def message_new(self, cr, uid, msg, custom_values=None, context=None):

From 196eff2648a8f4213925f23ad896da8a396e1e41 Mon Sep 17 00:00:00 2001
From: "Bhumi Thakkar (Open ERP)" <bth@tinyerp.com>
Date: Thu, 22 Mar 2012 12:40:49 +0530
Subject: [PATCH 12/13] [FIX] Change get_needaction_user_ids method to make it
 clean.

bzr revid: bth@tinyerp.com-20120322071049-ll84zqvursq46hfk
---
 addons/project_issue/project_issue.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 449f0f8da74..07d22b82133 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -382,8 +382,6 @@ class project_issue(crm.crm_case, osv.osv):
         for obj in self.browse(cr, uid, ids, context=context):
             if obj.state == 'draft' and obj.user_id:
                 result[obj.id] = [obj.user_id.id]
-            if obj.project_id.user_id:
-                result[obj.id] = [obj.project_id.user_id.id]
         return result
 
     def message_get_subscribers(self, cr, uid, ids, context=None):

From e5388ca6fab807bf10871455f3beb9b9c24cfe52 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Thibault=20Delavall=C3=A9e?= <tde@openerp.com>
Date: Tue, 3 Apr 2012 12:19:41 +0200
Subject: [PATCH 13/13] [CLEAN] Cleaned code.

bzr revid: tde@openerp.com-20120403101941-sugghykn8yfwwp6w
---
 addons/project_issue/project_issue.py | 137 +++++++++++---------------
 1 file changed, 58 insertions(+), 79 deletions(-)

diff --git a/addons/project_issue/project_issue.py b/addons/project_issue/project_issue.py
index 07d22b82133..bc2a849f7de 100644
--- a/addons/project_issue/project_issue.py
+++ b/addons/project_issue/project_issue.py
@@ -254,14 +254,13 @@ class project_issue(crm.crm_case, osv.osv):
         return self.set_priority(cr, uid, ids, '3')
 
     def convert_issue_task(self, cr, uid, ids, context=None):
+        if context is None:
+            context = {}
+        
         case_obj = self.pool.get('project.issue')
         data_obj = self.pool.get('ir.model.data')
         task_obj = self.pool.get('project.task')
-
-
-        if context is None:
-            context = {}
-
+        
         result = data_obj._get_id(cr, uid, 'project', 'view_task_search_form')
         res = data_obj.read(cr, uid, result, ['res_id'])
         id2 = data_obj._get_id(cr, uid, 'project', 'view_task_form2')
@@ -287,10 +286,9 @@ class project_issue(crm.crm_case, osv.osv):
                 'task_id': new_task_id,
                 'state':'pending'
             }
-            self.convert_to_task_send_note(cr, uid, ids, context)
-            cases = self.browse(cr, uid, ids)
-            self.case_pending_send_note(cr, uid, ids, context)
-            case_obj.write(cr, uid, [bug.id], vals)
+            self.convert_to_task_send_note(cr, uid, [bug.id], context=context)
+            case_obj.write(cr, uid, [bug.id], vals, context=context)
+            self.case_pending_send_note(cr, uid, [bug.id], context=context)
 
         return  {
             'name': _('Tasks'),
@@ -322,16 +320,6 @@ class project_issue(crm.crm_case, osv.osv):
     def convert_to_bug(self, cr, uid, ids, context=None):
         return self._convert(cr, uid, ids, 'bug_categ', context=context)
 
-    def prev_type(self, cr, uid, ids, context=None):
-        for task in self.browse(cr, uid, ids):
-            typeid = task.type_id.id
-            types = map(lambda x:x.id, task.project_id and task.project_id.type_ids or [])
-            if types:
-                if typeid and typeid in types:
-                    index = types.index(typeid)
-                    self.write(cr, uid, [task.id], {'type_id': index and types[index-1] or False})
-        return True
-
     def next_type(self, cr, uid, ids, context=None):
         for task in self.browse(cr, uid, ids):
             typeid = task.type_id.id
@@ -344,15 +332,24 @@ class project_issue(crm.crm_case, osv.osv):
                     self.write(cr, uid, [task.id], {'type_id': types[index+1]})
         return True
 
+    def prev_type(self, cr, uid, ids, context=None):
+        for task in self.browse(cr, uid, ids):
+            typeid = task.type_id.id
+            types = map(lambda x:x.id, task.project_id and task.project_id.type_ids or [])
+            if types:
+                if typeid and typeid in types:
+                    index = types.index(typeid)
+                    self.write(cr, uid, [task.id], {'type_id': index and types[index-1] or False})
+        return True
+
     def write(self, cr, uid, ids, vals, context=None):
         #Update last action date every time the user change the stage, the state or send a new email
         logged_fields = ['type_id', 'state', 'message_ids']
         if any([field in vals for field in logged_fields]):
             vals['date_action_last'] = time.strftime('%Y-%m-%d %H:%M:%S')
-        if 'type_id' in vals and vals['type_id']:
+        if vals.get('type_id', False):
             stage = self.pool.get('project.task.type').browse(cr, uid, vals['type_id'], context=context)
-            self.message_append_note(cr, uid, ids, _('System notification'),
-                        _("changed stage to <b>%s</b>.") % stage.name, type='notification')
+            self.message_append_note(cr, uid, ids, body=_("Stage changed to <b>%s</b>.") % stage.name, context=context)
         return super(project_issue, self).write(cr, uid, ids, vals, context)
 
     def onchange_task_id(self, cr, uid, ids, task_id, context=None):
@@ -362,51 +359,6 @@ class project_issue(crm.crm_case, osv.osv):
         task = self.pool.get('project.task').browse(cr, uid, task_id, context=context)
         return {'value':{'user_id': task.user_id.id,}}
 
-    def case_open_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>opened</b>.")
-            self.message_append_note(cr, uid, [id],'System Notification', message, context=context)
-        return True
-
-    def convert_to_task_send_note(self, cr, uid, ids, context=None):
-        for id in ids:
-            message = _("has been <b>converted</b> in to task.")
-            self.message_append_note(cr, uid, [id], 'System notification', message, context=context)
-        return True
-
-    def case_get_note_msg_prefix(self, cr, uid, id, context=None):
-        return ''
-
-    def get_needaction_user_ids(self, cr, uid, ids, context=None):
-        result = dict.fromkeys(ids, [])
-        for obj in self.browse(cr, uid, ids, context=context):
-            if obj.state == 'draft' and obj.user_id:
-                result[obj.id] = [obj.user_id.id]
-        return result
-
-    def message_get_subscribers(self, cr, uid, ids, context=None):
-        sub_ids = self.message_get_subscribers_ids(cr, uid, ids, context=context);
-        for obj in self.browse(cr, uid, ids, context=context):
-            if obj.user_id:
-                sub_ids.append(obj.user_id.id)
-        return self.pool.get('res.users').read(cr, uid, sub_ids, context=context)
-
-    def create_send_note(self, cr, uid, ids, context=None):
-        message = _("has been <b>created</b>.")
-        self.message_append_note(cr, uid, ids, _('System notification'),
-                        message, type='notification', context=context)
-        return True
-
-    def case_escalate_send_note(self, cr, uid, ids, context=None):
-        for obj in self.browse(cr, uid, ids, context=context):
-            if obj.project_id:
-                message = _("has been <b>escalated</b> to <em>'%s'</em>.") % (obj.project_id.name)
-                obj.message_append_note('' ,message, type='notification', context=context)
-            else:
-                message = _("has been <b>escalated</b>.")
-                obj.message_append_note('' ,message, type='notification', context=context)
-        return True
-
     def case_reset(self, cr, uid, ids, context=None):
         """Resets case as draft
         """
@@ -420,23 +372,11 @@ class project_issue(crm.crm_case, osv.osv):
         return obj_id
 
     def case_open(self, cr, uid, ids, context=None):
-        """
-        @param self: The object pointer
-        @param cr: the current row, from the database cursor,
-        @param uid: the current user’s ID for security checks,
-        @param ids: List of case's Ids
-        """
         res = super(project_issue, self).case_open(cr, uid, ids, context)
         self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'), 'user_id' : uid})
         return res
 
     def case_escalate(self, cr, uid, ids, context=None):
-        """Escalates case to top level
-        @param self: The object pointer
-        @param cr: the current row, from the database cursor,
-        @param uid: the current user’s ID for security checks,
-        @param ids: List of case Ids
-        """
         cases = self.browse(cr, uid, ids)
         for case in cases:
             data = {'state' : 'draft'}
@@ -525,6 +465,45 @@ class project_issue(crm.crm_case, osv.osv):
         default['name'] = issue['name'] + _(' (copy)')
         return super(project_issue, self).copy(cr, uid, id, default=default,
                 context=context)
+    
+    # -------------------------------------------------------
+    # OpenChatter methods and notifications
+    # -------------------------------------------------------
+    
+    def get_needaction_user_ids(self, cr, uid, ids, context=None):
+        result = dict.fromkeys(ids, [])
+        for obj in self.browse(cr, uid, ids, context=context):
+            if obj.state == 'draft' and obj.user_id:
+                result[obj.id] = [obj.user_id.id]
+        return result
+    
+    def message_get_subscribers(self, cr, uid, ids, context=None):
+        sub_ids = self.message_get_subscribers_ids(cr, uid, ids, context=context);
+        for obj in self.browse(cr, uid, ids, context=context):
+            if obj.user_id:
+                sub_ids.append(obj.user_id.id)
+        return self.pool.get('res.users').read(cr, uid, sub_ids, context=context)
+    
+    def case_get_note_msg_prefix(self, cr, uid, id, context=None):
+        return 'Project issue '
+
+    def convert_to_task_send_note(self, cr, uid, ids, context=None):
+        message = _("Project issue has been <b>converted</b> in to task.")
+        return self.message_append_note(cr, uid, ids, body=message, context=context)
+
+    def create_send_note(self, cr, uid, ids, context=None):
+        message = _("Project issue has been <b>created</b>.")
+        return self.message_append_note(cr, uid, ids, body=message, context=context)
+
+    def case_escalate_send_note(self, cr, uid, ids, context=None):
+        for obj in self.browse(cr, uid, ids, context=context):
+            if obj.project_id:
+                message = _("has been <b>escalated</b> to <em>'%s'</em>.") % (obj.project_id.name)
+                obj.message_append_note(body=message, context=context)
+            else:
+                message = _("has been <b>escalated</b>.")
+                obj.message_append_note(body=message, context=context)
+        return True
 
 project_issue()