Merge branch 'purchasing-job' into production

# Conflicts:
#	indoteknik_custom/models/__init__.py
#	indoteknik_custom/models/sale_order.py

1 files changed, 159 insertions, 0 deletions

diff --git a/indoteknik_custom/models/purchasing_job.py b/indoteknik_custom/models/purchasing_job.py
new file mode 100644
index 00000000..1c74f0e9
--- /dev/null
+++ b/indoteknik_custom/models/purchasing_job.py
@@ -0,0 +1,159 @@
+from odoo import fields, models, api, tools, _
+import logging
+from datetime import datetime
+
+_logger = logging.getLogger(__name__)
+
+
+class PurchasingJob(models.Model):
+    _name = 'v.purchasing.job'
+    _auto = False
+    _rec_name = 'product_id'
+
+    id = fields.Integer()
+    product_id = fields.Many2one('product.product', string="Product")
+    vendor_id = fields.Many2one('res.partner', string="Vendor", compute='compute_vendor_id')
+    brand = fields.Char(string='Brand')
+    item_code = fields.Char(string='Item Code')
+    product = fields.Char(string='Product Name')
+    onhand = fields.Float(string='OnHand')
+    incoming = fields.Float(string="Incoming")
+    outgoing = fields.Float(string="Outgoing")
+    action = fields.Char(string="Status")
+    status_apo = fields.Selection([
+        ('not_apo', 'Belum APO'),
+        ('apo', 'APO')
+    ], string='APO?')
+
+    def compute_vendor_id(self):
+        for sale in self:
+            domain = [
+                ('product_id', '=', sale.product_id.id)
+            ]
+            sales = self.env['v.sales.outstanding'].search(domain)
+
+            vendor_id = False
+            
+            if sales:
+                vendor_id = sales[0].sale_line_id.vendor_id.id
+
+            sale.vendor_id = vendor_id
+
+    def init(self):
+        tools.drop_view_if_exists(self.env.cr, self._table)
+        self.env.cr.execute("""
+            CREATE OR REPLACE VIEW %s AS (
+                SELECT
+                    pmp.product_id as id, 
+                    pmp.product_id, 
+                    pmp.brand, 
+                    pmp.item_code, 
+                    pmp.product, 
+                    pmp.onhand, 
+                    pmp.incoming, 
+                    pmp.outgoing, 
+                    pmp.action,
+                    pjs.status_apo AS status_apo
+                FROM v_procurement_monitoring_by_product pmp
+                LEFT JOIN purchasing_job_state pjs ON pjs.purchasing_job_id = pmp.product_id
+                WHERE pmp.action = 'kurang'
+            )
+        """ % self._table)
+
+
+    def open_form_multi_generate_request_po(self):
+        action = self.env['ir.actions.act_window']._for_xml_id('indoteknik_custom.action_purchasing_job_multi_update')
+        action['context'] = {
+            'product_ids': [x.id for x in self]
+        }
+        return action
+    
+    def generate_request_po(self):
+        # print(1)
+        # TODO create document automatic purchase
+
+        current_time = datetime.utcnow()
+
+        automatic_purchase = self.env['automatic.purchase'].create([{
+                    'apo_type': 'regular',
+                    'date_doc': current_time,
+                }])
+        count = 0
+        for job in self:
+            print(job.product_id.name)
+            qty_purchase = job.outgoing - (job.onhand + job.incoming)
+            qty_available = (job.onhand + job.incoming) - job.outgoing
+
+            domain = [
+                ('product_id.id', '=', job.product_id.id),
+            ]
+            orderby = 'count_trx_po desc, count_trx_po_vendor desc'
+            purchase_pricelist = self.env['purchase.pricelist'].search(domain, order=orderby, limit=1)
+
+            vendor_id = purchase_pricelist.vendor_id
+            price, taxes = automatic_purchase._get_valid_purchase_price(purchase_pricelist)
+            last_po_line = self.env['purchase.order.line'].search([('product_id', '=', job.product_id.id), ('order_id.state', '=', 'done')], order='id desc', limit=1)
+
+            self.env['automatic.purchase.line'].create([{
+                'automatic_purchase_id': automatic_purchase.id,
+                'product_id': job.product_id.id,
+                'qty_purchase': qty_purchase,
+                'qty_available': qty_available,
+                'partner_id': vendor_id.id,
+                'last_price': price,
+                'taxes_id': taxes,
+                'subtotal': qty_purchase * price,
+                'last_order_id': last_po_line.order_id.id,
+                'last_orderline_id': last_po_line.id,
+                'brand_id': job.product_id.product_tmpl_id.x_manufacture.id
+            }])
+            automatic_purchase._create_sales_matching()
+            automatic_purchase._create_sync_purchasing_job(job)
+            count += 1
+            _logger.info('Create Automatic Purchase Line %s' % job.product_id.name)
+        return automatic_purchase.id
+
+class OutstandingSales(models.Model):
+    _name = 'v.sales.outstanding'
+    _auto = False
+    _rec_name = 'move_id'
+
+    id = fields.Integer()
+    move_id = fields.Many2one('stock.move', string='Move')
+    picking_id = fields.Many2one('stock.picking', string='Picking')
+    product_id = fields.Many2one('product.product', string='Product')
+    sale_id = fields.Many2one('sale.order', string='Sale')
+    sale_line_id = fields.Many2one('sale.order.line', string='Sale Line')
+    partner_id = fields.Many2one('res.partner', string='Partner')
+    partner_invoice_id = fields.Many2one('res.partner', string='Invoice Partner')
+    salesperson_id = fields.Many2one('res.users', string='Salesperson')
+    origin = fields.Char(string='Origin')
+    salesperson = fields.Char(string='Sales Name')
+    item_code = fields.Char(string='Item Code')
+    product = fields.Char(string='Product')
+    outgoing = fields.Float(string='Outgoing')
+    brand = fields.Char(string='Brand')
+    invoice_partner = fields.Char(string='Invoice Partner')
+
+    def init(self):
+        tools.drop_view_if_exists(self.env.cr, self._table)
+        self.env.cr.execute("""
+            CREATE OR REPLACE VIEW v_sales_outstanding AS (
+                select sm.id, sm.id as move_id, sp.id as picking_id, sm.product_id, so.id as sale_id, 
+                sol.id as sale_line_id, rp.id as partner_id, so.user_id as salesperson_id, so.partner_invoice_id,
+                sp.origin, rp2.name as salesperson, coalesce(pp.default_code, pt.default_code) as item_code, pt.name as product,
+                sm.product_uom_qty as outgoing, xm.x_name as brand, rp.name as invoice_partner
+                from stock_move sm
+                join stock_picking sp on sp.id = sm.picking_id
+                join sale_order_line sol on sol.id = sm.sale_line_id
+                join sale_order so on so.id = sol.order_id
+                join res_partner rp on rp.id = so.partner_invoice_id
+                join res_users ru on ru.id = so.user_id
+                join res_partner rp2 on rp2.id = ru.partner_id
+                join product_product pp on pp.id = sm.product_id
+                join product_template pt on pt.id = pp.product_tmpl_id
+                left join x_manufactures xm on xm.id = pt.x_manufacture
+                where sp.state in ('draft', 'waiting', 'confirmed', 'assigned')
+                and sp.name like '%OUT%'
+            )
+        """)