You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							630 lines
						
					
					
						
							26 KiB
						
					
					
				
			
		
		
		
			
			
			
		
		
	
	
							630 lines
						
					
					
						
							26 KiB
						
					
					
				| # -*- coding: utf-8 -*- | |
| ############################################################################### | |
| # | |
| #    Cybrosys Technologies Pvt. Ltd. | |
| # | |
| #    Copyright (C) 2024-TODAY Cybrosys Technologies(<https://www.cybrosys.com>) | |
| #    Author: Afra MP (odoo@cybrosys.com) | |
| # | |
| #    You can modify it under the terms of the GNU AFFERO | |
| #    GENERAL PUBLIC LICENSE (AGPL v3), Version 3. | |
| # | |
| #    This program is distributed in the hope that it will be useful, | |
| #    but WITHOUT ANY WARRANTY; without even the implied warranty of | |
| #    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | |
| #    GNU AFFERO GENERAL PUBLIC LICENSE (AGPL v3) for more details. | |
| # | |
| #    You should have received a copy of the GNU AFFERO GENERAL PUBLIC LICENSE | |
| #    (AGPL v3) along with this program. | |
| #    If not, see <http://www.gnu.org/licenses/>. | |
| # | |
| ############################################################################### | |
| import calendar | |
| from odoo import api, fields, models | |
| 
 | |
| 
 | |
| class PurchaseOrder(models.Model): | |
|     """ Inherit purchase.order model and add fields and methods """ | |
|     _inherit = 'purchase.order' | |
| 
 | |
|     requisition_order = fields.Char( | |
|         string='Requisition Order', help='Requisition Order' | |
|     ) | |
|     company_currency_amount = fields.Float( | |
|         string='Company Currency Total', compute='_compute_amount', | |
|         help="Total amount in company currency" | |
|     ) | |
|     number_to_words = fields.Char( | |
|         string="Amount in Words (Total) : ", | |
|         compute='_compute_number_to_words', help="Total amount in words" | |
|     ) | |
| 
 | |
|     def _compute_amount(self): | |
|         """Total amount in company currency""" | |
|         for amount in self: | |
|             amount.company_currency_amount = self.env['res.currency']._convert(amount.amount_total, amount.company_id.currency_id) | |
| 
 | |
|     def _compute_number_to_words(self): | |
|         """Compute the amount to words in Purchase Order""" | |
|         for rec in self: | |
|             rec.number_to_words = rec.currency_id.amount_to_text( | |
|                 rec.amount_total) | |
| 
 | |
|     def action_multi_confirm(self): | |
|         """Confirm multiple order by a single click""" | |
|         for order in self.env['purchase.order'].browse( | |
|                 self.env.context.get('active_ids')).filtered( | |
|             lambda o: o.state in ['draft', 'sent']): | |
|             order.button_confirm() | |
| 
 | |
|     def action_multi_cancel(self): | |
|         """Cancel multiple order by a single click""" | |
|         for order in self.env['purchase.order'].browse( | |
|                 self.env.context.get('active_ids')): | |
|             order.button_cancel() | |
| 
 | |
|     def button_confirm(self): | |
|         """The same order line merges when the confirmation button is | |
|          clicked""" | |
|         line_groups = {} | |
|         for line in self.order_line: | |
|             key = (line.product_id.id, line.price_unit) | |
|             line_groups.setdefault(key, []).append(line) | |
|         for lines in line_groups.values(): | |
|             if len(lines) > 1: | |
|                 lines[0].product_qty = sum(line.product_qty for line in lines) | |
|                 lines[0]._compute_amount() | |
|                 for line in lines[1:]: | |
|                     line.unlink() | |
|         res = super(PurchaseOrder, self).button_confirm() | |
|         return res | |
| 
 | |
|     @api.onchange('partner_id') | |
|     def _recompute_discount(self): | |
|         """Calculate the discount""" | |
|         self.order_line.calculate_discount_percentage() | |
| 
 | |
|     @api.model | |
|     def get_purchase_data(self): | |
|         """Returns data to the orm call to display the data in the tiles | |
|         :return: Dictionary with purchase data | |
|         :rtype: dict""" | |
|         orders = self.env['purchase.order'].search([('state', 'in', [ | |
|             'purchase', 'done'])]) | |
|         priority_orders = self.env['purchase.order'].search([ | |
|             ('priority', '=', '1')]) | |
|         vendor = list(set(rec.partner_id for rec in orders)) | |
|         return { | |
|             'purchase_orders': len(orders), | |
|             'purchase_amount': sum(rec.amount_total for rec in orders), | |
|             'priority_orders': len(priority_orders), | |
|             'vendors': len(vendor) | |
|         } | |
| 
 | |
|     def get_yearly_data(self): | |
|         """Get yearly purchase data. | |
|         :return: Dictionary with yearly purchase data | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                    SELECT COUNT(*) as po_count, SUM(amount_total) as po_sum | |
|                    FROM purchase_order | |
|                    WHERE company_id = %s | |
|                        AND state IN ('purchase', 'done') | |
|                        AND date_order >= date_trunc('year', now()) | |
|                """ | |
|         self.env.cr.execute(query, (company,)) | |
|         data = self.env.cr.dictfetchall() | |
|         query_priority = """ | |
|                    SELECT COUNT(*) as priority_count | |
|                    FROM purchase_order po | |
|                    WHERE company_id = %s | |
|                        AND state IN ('purchase', 'done') | |
|                        AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR from now()) | |
|                        AND priority = '1' | |
|                """ | |
|         self.env.cr.execute(query_priority, (company,)) | |
|         priority_orders = self.env.cr.dictfetchall() | |
|         query_vendors = """ | |
|                    SELECT COUNT(DISTINCT partner_id) as vendor_count | |
|                    FROM purchase_order | |
|                    WHERE company_id = %s | |
|                        AND state IN ('purchase', 'done') | |
|                        AND date_order < date_trunc('year', now()) | |
|                """ | |
|         self.env.cr.execute(query_vendors, (company,)) | |
|         result = self.env.cr.dictfetchall() | |
|         if result: | |
|             previous_vendors = result[0]['vendor_count'] | |
|         else: | |
|             previous_vendors = 0 | |
|         query_current_vendors = """ | |
|                    SELECT COUNT(DISTINCT partner_id) as vendor_count | |
|                    FROM purchase_order | |
|                    WHERE company_id = %s | |
|                        AND state IN ('purchase', 'done') | |
|                        AND date_order BETWEEN date_trunc('year', now()) AND now() | |
|                """ | |
|         self.env.cr.execute(query_current_vendors, (company,)) | |
|         result = self.env.cr.dictfetchall() | |
|         if result: | |
|             current_vendors = result[0]['vendor_count'] | |
|         else: | |
|             current_vendors = 0 | |
|         new_vendors = current_vendors - previous_vendors | |
|         yearly = { | |
|             'purchase_orders': data[0]['po_count'], | |
|             'purchase_amount': data[0]['po_sum'] or 0, | |
|             'priority_orders': priority_orders[0]['priority_count'], | |
|             'vendors': new_vendors or 0, | |
|         } | |
|         return yearly | |
| 
 | |
|     def get_monthly_data(self): | |
|         """Get monthly purchase data. | |
|         :return: Dictionary with monthly purchase data | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                 SELECT COUNT(*), SUM(amount_total) | |
|                 FROM purchase_order po | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR from  | |
|                     CURRENT_DATE) | |
|                     AND EXTRACT(MONTH from date_order) = EXTRACT(MONTH from  | |
|                     CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, (company,)) | |
|         data = self.env.cr.dictfetchall() | |
|         query = """ | |
|                 SELECT COUNT(*) | |
|                 FROM purchase_order po | |
|                 WHERE company_id = %s | |
|                     AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR from  | |
|                     CURRENT_DATE) | |
|                     AND EXTRACT(MONTH from date_order) = EXTRACT(MONTH from | |
|                      CURRENT_DATE)  | |
|                     AND priority = '1' | |
|             """ | |
|         self.env.cr.execute(query, (company,)) | |
|         priority_orders = self.env.cr.dictfetchall() | |
|         query = """ | |
|                 SELECT DISTINCT partner_id | |
|                 FROM purchase_order po | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase','done') | |
|                     AND EXTRACT(month from date_order) < EXTRACT(month FROM | |
|                      CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, (company,)) | |
|         previous_vendors = self.env.cr.dictfetchall() | |
|         previous = [] | |
|         if len(previous_vendors) > 1: | |
|             previous = [rec['partner_id'] for rec in previous_vendors] | |
|         else: | |
|             previous.append(rec for rec in previous_vendors) | |
|         query = """ | |
|                 SELECT DISTINCT partner_id | |
|                 FROM purchase_order po | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase','done') | |
|                     AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR FROM | |
|                      CURRENT_DATE)  | |
|                     AND EXTRACT(month from date_order) = EXTRACT(month FROM | |
|                      CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, (company,)) | |
|         vendors = self.env.cr.dictfetchall() | |
|         new_vendors = [] | |
|         if vendors: | |
|             if len(vendors) > 1: | |
|                 for rec in vendors: | |
|                     if rec['partner_id'] not in previous: | |
|                         new_vendors.append(rec['partner_id']) | |
|             else: | |
|                 if vendors not in previous: | |
|                     new_vendors.append(vendors[0]['partner_id']) | |
|         monthly = { | |
|             'purchase_orders': data[0]['count'], | |
|             'purchase_amount': data[0]['sum'], | |
|             'priority_orders': priority_orders[0]['count'], | |
|             'vendors': len(new_vendors), | |
|             'vendor_id': new_vendors, | |
|         } | |
|         return monthly | |
| 
 | |
|     def get_weekly_data(self): | |
|         """Get weekly purchase data. | |
|         :return: Dictionary with weekly purchase data | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                 SELECT COUNT(*), SUM(amount_total), COUNT(CASE WHEN priority = '1'  | |
|                 THEN 1 ELSE NULL END) | |
|                 FROM purchase_order | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR from  | |
|                     CURRENT_DATE) | |
|                     AND EXTRACT(WEEK from date_order) = EXTRACT(WEEK from  | |
|                     CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, [company]) | |
|         data = self.env.cr.fetchone() | |
|         query = """ | |
|                 SELECT DISTINCT partner_id | |
|                 FROM purchase_order | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND EXTRACT(WEEK from date_order) < EXTRACT(WEEK FROM  | |
|                     CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, [company]) | |
|         previous_vendors = self.env.cr.dictfetchall() | |
|         previous = [rec['partner_id'] for rec in previous_vendors] | |
|         query = """ | |
|                 SELECT DISTINCT partner_id | |
|                 FROM purchase_order | |
|                 WHERE company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND EXTRACT(YEAR from date_order) = EXTRACT(YEAR FROM  | |
|                     CURRENT_DATE)  | |
|                     AND EXTRACT(WEEK from date_order) = EXTRACT(WEEK FROM  | |
|                     CURRENT_DATE) | |
|             """ | |
|         self.env.cr.execute(query, [company]) | |
|         vendors = self.env.cr.dictfetchall() | |
|         new_vendors = [rec['partner_id'] for rec in vendors if rec[ | |
|             'partner_id'] not in previous] | |
|         weekly = { | |
|             'purchase_orders': data[0], | |
|             'purchase_amount': data[1], | |
|             'priority_orders': data[2], | |
|             'vendors': len(new_vendors) | |
|         } | |
|         return weekly | |
| 
 | |
|     def get_today_data(self): | |
|         """Get purchase data for the current day. | |
|         :return: Dictionary with purchase data for the current day | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                 SELECT | |
|                     COUNT(*) AS purchase_orders, | |
|                     SUM(amount_total) AS purchase_amount, | |
|                     COUNT(*) FILTER (WHERE priority = '1') AS priority_orders | |
|                 FROM purchase_order | |
|                 WHERE | |
|                     company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND date_order::date = CURRENT_DATE | |
|             """ | |
|         self.env.cr.execute(query, (company,)) | |
|         today_data = self.env.cr.dictfetchall()[0] | |
|         query = """ | |
|                 SELECT DISTINCT partner_id | |
|                 FROM purchase_order | |
|                 WHERE | |
|                     company_id = %s | |
|                     AND state IN ('purchase', 'done') | |
|                     AND date_order::date = CURRENT_DATE | |
|                     AND NOT EXISTS ( | |
|                         SELECT 1 | |
|                         FROM purchase_order | |
|                         WHERE | |
|                             company_id = %s | |
|                             AND state IN ('purchase', 'done') | |
|                             AND date_order::date < CURRENT_DATE | |
|                             AND partner_id = purchase_order.partner_id)""" | |
|         self.env.cr.execute(query, (company, company)) | |
|         new_vendors = [r['partner_id'] for r in self.env.cr.dictfetchall()] | |
|         return { | |
|             'purchase_orders': today_data['purchase_orders'], | |
|             'purchase_amount': today_data['purchase_amount'], | |
|             'priority_orders': today_data['priority_orders'], | |
|             'vendors': len(new_vendors), | |
|             'vendor_id': new_vendors, | |
|         } | |
| 
 | |
|     @api.model | |
|     def get_select_mode_data(self, args): | |
|         """Get data based on the selected filters | |
|         :param args: Selected filter | |
|         :type args: str | |
|         :return: Data based on the selected filter | |
|         :rtype: dict or False""" | |
|         data = { | |
|             'this_year': self.get_yearly_data, | |
|             'this_month': self.get_monthly_data, | |
|             'this_week': self.get_weekly_data, | |
|             'today': self.get_today_data, | |
|         }.get(args) | |
|         return data() if data else False | |
| 
 | |
|     def execute_query(self, query, args): | |
|         """Returns quantity/count regarding the top entities | |
|         :param query: SQL query to be executed | |
|         :type query: str | |
|         :param args: Query parameters | |
|         :type args: str | |
|         :return: Query results | |
|         :rtype: list""" | |
|         self._cr.execute(query) | |
|         results = self._cr.dictfetchall() | |
|         final = [] | |
|         if args == 'top_product': | |
|             final = [[record.get('total_quantity') for record in results], | |
|                      [record.get('product_name') for record in results]] | |
|         elif args == 'top_vendor': | |
|             final = [[record.get('count') for record in results], | |
|                      [record.get('name') for record in results]] | |
|         elif args == 'top_rep': | |
|             final = [[record.get('count') for record in results], | |
|                      [record.get('name') for record in results]] | |
|         return final | |
| 
 | |
|     @api.model | |
|     def get_top_chart_data(self, args): | |
|         """Get top chart data based on the selected filter. | |
|          :param args: Selected filter | |
|         :type args: str | |
|         :return: Top chart data | |
|         :rtype: list""" | |
|         query = '' | |
|         company_id = self.env.company.id | |
|         if args == 'top_product': | |
|             query = f''' | |
|                     SELECT DISTINCT(product_template.name) as product_name, | |
|                     SUM(product_qty) as total_quantity  | |
|                     FROM purchase_order_line  | |
|                     INNER JOIN product_product ON  | |
|                     product_product.id=purchase_order_line.product_id  | |
|                     INNER JOIN product_template ON  | |
|                     product_product.product_tmpl_id = product_template.id  | |
|                     WHERE purchase_order_line.company_id = {company_id}  | |
|                     GROUP BY product_template.id  | |
|                     ORDER BY total_quantity DESC  | |
|                     LIMIT 10 | |
|                 ''' | |
|         elif args == 'top_vendor': | |
|             query = f''' | |
|                     SELECT partner.name, COUNT(po.id) as count | |
|                     FROM purchase_order po | |
|                     JOIN res_partner partner ON po.partner_id = partner.id | |
|                     WHERE po.company_id = {company_id} | |
|                     GROUP BY partner.name | |
|                     ORDER BY count DESC  | |
|                     LIMIT 10 | |
|                 ''' | |
|         elif args == 'top_rep': | |
|             query = f''' | |
|                     SELECT partner.name, COUNT(po.id) as count | |
|                     FROM purchase_order po | |
|                     JOIN res_users users ON po.user_id = users.id | |
|                     JOIN res_partner partner ON users.partner_id = partner.id | |
|                     WHERE po.company_id = {company_id} | |
|                     GROUP BY partner.name | |
|                     ORDER BY count DESC | |
|                     LIMIT 10 | |
|                 ''' | |
|         final = self.execute_query(query, args) | |
|         return final | |
| 
 | |
|     @api.model | |
|     def get_orders_by_month(self): | |
|         """Get purchase orders grouped by month. | |
|         :return: Purchase orders by month | |
|         :rtype: dict""" | |
|         query = f"""select count(*), EXTRACT(month from date_order) as dates | |
|                 from purchase_order po | |
|                 where company_id = {self.env.company.id} and state = 'purchase' | |
|                 group by dates""" | |
|         self.env.cr.execute(query, (self.env.company.id,)) | |
|         cr = self.env.cr.dictfetchall() | |
|         month = [] | |
|         for rec in cr: | |
|             month.append(int(rec['dates'])) | |
|             rec.update({ | |
|                 'count': rec['count'], | |
|                 'dates': calendar.month_name[int(rec['dates'])], | |
|                 'month': int(rec['dates']) | |
|             }) | |
|         for rec in range(1, 13): | |
|             if rec not in month: | |
|                 cr.append({ | |
|                     'count': 0, | |
|                     'dates': calendar.month_name[rec], | |
|                     'month': rec | |
|                 }) | |
|         cr = sorted(cr, key=lambda i: i['month']) | |
|         return { | |
|             'count': [rec['count'] for rec in cr], | |
|             'dates': [rec['dates'] for rec in cr] | |
|         } | |
| 
 | |
|     @api.model | |
|     def purchase_vendors(self): | |
|         """Get a list of purchase vendors. | |
|         :return: List of purchase vendors in the format | |
|         [{'id': vendor_id, 'name': vendor_name}] | |
|         :rtype: list""" | |
|         company_id = self.env.company.id | |
|         query = """ | |
|                 SELECT partner.id, partner.name | |
|                 FROM purchase_order po | |
|                 INNER JOIN res_partner partner ON po.partner_id = partner.id | |
|                 WHERE po.company_id = %s | |
|                 GROUP BY partner.id | |
|             """ | |
|         self._cr.execute(query, (company_id,)) | |
|         return self._cr.dictfetchall() | |
| 
 | |
|     @api.model | |
|     def purchase_vendor_details(self, args): | |
|         """Get purchase details for a specific vendor. | |
|         :param args: Vendor ID | |
|         :type args: int | |
|         :return: Purchase details for the specific vendor | |
|         :rtype: dict""" | |
|         company_id = self.env.company.id | |
|         partner = int(args) if args else 1 | |
|         query = """ | |
|                 SELECT count(po.id),SUM(po.amount_total), EXTRACT(MONTH from  | |
|                 po.date_order) as dates  | |
|                 FROM purchase_order po  | |
|                 JOIN res_partner ON res_partner.id = po.partner_id  | |
|                 WHERE po.company_id = %s and po.partner_id = %s  | |
|                 GROUP BY dates | |
|             """ | |
|         self._cr.execute(query, (company_id, partner)) | |
|         partner_orders = self._cr.dictfetchall() | |
|         query_draft = """ | |
|                 SELECT count(po.id),SUM(po.amount_total), EXTRACT(MONTH from  | |
|                 po.date_order) as dates  | |
|                 FROM purchase_order po  | |
|                 JOIN res_partner ON res_partner.id = po.partner_id  | |
|                 WHERE po.state in ('draft', 'sent') and po.company_id = %s and  | |
|                 po.partner_id = %s  | |
|                 GROUP BY dates""" | |
|         self._cr.execute(query_draft, (company_id, partner)) | |
|         draft_orders = self._cr.dictfetchall() | |
|         approve_qry = """ | |
|                 SELECT count(po.id),SUM(po.amount_total), EXTRACT(MONTH from  | |
|                 po.date_order) as dates  | |
|                 FROM purchase_order po  | |
|                 JOIN res_partner ON res_partner.id = po.partner_id  | |
|                 WHERE po.state = 'to approve' and po.company_id = %s and  | |
|                 po.partner_id = %s  | |
|                 GROUP BY dates""" | |
|         self._cr.execute(approve_qry, (company_id, partner)) | |
|         approve_orders = self._cr.dictfetchall() | |
|         cancel_qry = """ | |
|                 SELECT count(po.id),SUM(po.amount_total), EXTRACT(MONTH from  | |
|                 po.date_order) as dates  | |
|                 FROM purchase_order po  | |
|                 JOIN res_partner ON res_partner.id = po.partner_id  | |
|                 WHERE po.state = 'cancel' and po.company_id = %s and po.partner_id  | |
|                 = %s  | |
|                 GROUP BY dates""" | |
|         self._cr.execute(cancel_qry, (company_id, partner)) | |
|         cancel_orders = self._cr.dictfetchall() | |
|         all_orders = { | |
|             'partner_orders': partner_orders, 'draft_orders': draft_orders, | |
|             'approve_orders': approve_orders, 'cancel_orders': cancel_orders} | |
|         for order_type, order_list in all_orders.items(): | |
|             order_months = [] | |
|             for rec in order_list: | |
|                 order_months.append(int(rec.get('dates'))) | |
|             for rec in range(1, 13): | |
|                 if rec not in order_months: | |
|                     vals = {'sum': 0.0, 'dates': rec, 'count': 0} | |
|                     order_list.append(vals) | |
|             all_orders[order_type] = sorted( | |
|                 order_list, key=lambda order: order['dates']) | |
|         value = { | |
|             'purchase_amount': [record.get('sum') for record in | |
|                                 partner_orders], | |
|             'po_count': [record.get('count') for record in partner_orders], | |
|             'draft_amount': [record.get('sum') for record in draft_orders], | |
|             'draft_count': [record.get('count') for record in draft_orders], | |
|             'approve_amount': [record.get('sum') for record in approve_orders], | |
|             'approve_count': [record.get('count') for record in | |
|                               approve_orders], | |
|             'cancel_amount': [record.get('sum') for record in cancel_orders], | |
|             'cancel_count': [record.get('count') for record in cancel_orders], | |
|             'dates': [record.get('dates') for record in partner_orders], | |
|         } | |
|         return value | |
| 
 | |
|     @api.model | |
|     def get_pending_purchase_data(self): | |
|         """Get pending purchase orders data. | |
|         :return: Data of pending purchase orders | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                 SELECT po.name, po.id, rp.name as partner_name, po.date_planned,  | |
|                 po.amount_total, po.state  | |
|                 FROM purchase_order po  | |
|                 JOIN purchase_order_line pol ON pol.order_id = po.id  | |
|                 JOIN res_partner rp ON rp.id = po.partner_id  | |
|                 WHERE po.date_planned < CURRENT_DATE AND pol.qty_received <  | |
|                 pol.product_qty AND po.company_id = %s | |
|                 GROUP BY po.id, rp.id | |
|             """ | |
|         self._cr.execute(query, (company,)) | |
|         orders = self._cr.dictfetchall() | |
|         value = { | |
|             'order': [rec['name'] for rec in orders], | |
|             'vendor': [rec['partner_name'] for rec in orders], | |
|             'amount': [rec['amount_total'] for rec in orders], | |
|             'date': [rec['date_planned'] for rec in orders], | |
|             'state': [rec['state'] for rec in orders], | |
|             'data': [list(val for val in rec.values()) for rec in orders] | |
|         } | |
|         return value | |
| 
 | |
|     @api.model | |
|     def get_upcoming_purchase_data(self): | |
|         """Get upcoming purchase orders data. | |
|         :return: Data of upcoming purchase orders | |
|         :rtype: dict""" | |
|         company = self.env.company.id | |
|         query = """ | |
|                 SELECT po.name, po.id, rp.name as partner_name, po.date_planned,  | |
|                 po.amount_total, po.state  | |
|                 FROM purchase_order po  | |
|                 JOIN purchase_order_line pol ON pol.order_id = po.id  | |
|                 JOIN res_partner rp ON rp.id = po.partner_id  | |
|                 WHERE po.date_planned > CURRENT_DATE AND pol.qty_received <  | |
|                 pol.product_qty AND po.company_id = %s | |
|                 GROUP BY po.id, rp.id | |
|             """ | |
|         self._cr.execute(query, (company,)) | |
|         orders = self._cr.dictfetchall() | |
|         value = { | |
|             'order': [rec['name'] for rec in orders], | |
|             'vendor': [rec['partner_name'] for rec in orders], | |
|             'amount': [rec['amount_total'] for rec in orders], | |
|             'date': [rec['date_planned'] for rec in orders], | |
|             'state': [rec['state'] for rec in orders], | |
|             'data': [list(val for val in rec.values()) for rec in orders], | |
|         } | |
|         return value | |
| 
 | |
|     @api.model | |
|     def total_amount_spend(self): | |
|         """Returns total amount spend for purchase""" | |
|         total_amount = sum(self.search([ | |
|             ('state', '=', 'purchase')]).mapped('amount_total')) | |
|         return { | |
|             'amount_total': total_amount | |
|         } | |
| 
 | |
|     def recommendation_wizard(self): | |
|         """Add data to wizard""" | |
|         orders = self.search([('partner_id', '=', self.partner_id.id)]) | |
|         pro_id = [] | |
|         for order in orders: | |
|             for product in order.order_line.product_id: | |
|                 val = (0, 0, { | |
|                     'product_id': product.id, | |
|                     'available_qty': product.qty_available, | |
|                     'list_price': product.list_price, | |
|                     'qty_need': 0, | |
|                     'is_modified': False, | |
|                 }) | |
|                 if val not in pro_id: | |
|                     pro_id.append(val) | |
|             res = { | |
|                 'type': 'ir.actions.act_window', | |
|                 'view_mode': 'form', | |
|                 'res_model': 'product.recommendation', | |
|                 'target': 'new', | |
|                 'context': { | |
|                     'default_line_ids': pro_id, | |
|                 } | |
|             } | |
|         return res
 | |
| 
 |