~unifield-team/unifield-wm/us-826

from osv import osv, fields

from osv.orm import browse_record, browse_null

from tools.translate import _

 

import decimal_precision as dp

import netsvc

import pooler

import time

 

from purchase_override import PURCHASE_ORDER_STATE_SELECTION

 

class tender(osv.osv):

        if not default:

            default = {}

        default['internal_state'] = 'draft' # UF-733: Reset the internal_state

        return super(osv.osv, self).copy(cr, uid, id, default, context=context)

    

    def unlink(self, cr, uid, ids, context=None):

        '''

        cannot delete tender not draft

        '''

        if context is None:

            context = {}

        if isinstance(ids, (int, long)):

        for obj in self.browse(cr, uid, ids, context=context):

            if obj.state != 'draft':

                raise osv.except_osv(_('Warning !'), _("Cannot delete Tenders not in 'draft' state."))

        return super(tender, self).unlink(cr, uid, ids, context=context)

    

    def _vals_get(self, cr, uid, ids, fields, arg, context=None):

        for obj in self.browse(cr, uid, ids, context=context):

            result[obj.id] = {'rfq_name_list': '',

                              }

            rfq_names = []

            for rfq in obj.rfq_ids:

                rfq_names.append(rfq.name)

            result[obj.id]['rfq_name_list'] = ','.join(rfq_names)

            

        return result

    _columns = {'name': fields.char('Tender Reference', size=64, required=True, select=True, readonly=True),

                'sale_order_id': fields.many2one('sale.order', string="Sale Order", readonly=True),

                'state': fields.selection([('draft', 'Draft'),('comparison', 'Comparison'), ('done', 'Closed'), ('cancel', 'Cancelled'),], string="State", readonly=True),

                'notes': fields.text('Notes'),

                'internal_state': fields.selection([('draft', 'Draft'),('updated', 'Rfq Updated'), ], string="Internal State", readonly=True),

                'rfq_name_list': fields.function(_vals_get, method=True, string='RfQs Ref', type='char', readonly=True, store=False, multi='get_vals',),

                }

    

                 'internal_state': 'draft',

                 'company_id': lambda obj, cr, uid, context: obj.pool.get('res.users').browse(cr, uid, uid, context=context).company_id.id,

                 'creator': lambda obj, cr, uid, context: uid,

                 'creation_date': lambda *a: time.strftime('%Y-%m-%d'),

                 }

    

    _order = 'name desc'

    

    def onchange_warehouse(self, cr, uid, ids, warehouse_id, context=None):

        '''

        on_change function for the warehouse

        pol_obj = self.pool.get('purchase.order.line')

        partner_obj = self.pool.get('res.partner')

        pricelist_obj = self.pool.get('product.pricelist')

        # no suppliers -> raise error

        for tender in self.browse(cr, uid, ids, context=context):

            # check some supplier have been selected

            if not tender.supplier_ids:

                raise osv.except_osv(_('Warning !'), _('You must select at least one supplier!'))

            # check some products have been selected

            if not tender_line_ids:

                raise osv.except_osv(_('Warning !'), _('You must select at least one product!'))

            for supplier in tender.supplier_ids:

                # create a purchase order for each supplier

                if not address_id:

                    raise osv.except_osv(_('Warning !'), _('The supplier "%s" has no address defined!')%(supplier.name,))

                pricelist_id = supplier.property_product_pricelist_purchase.id

                          'rfq_ok': True,

                          'partner_id': supplier.id,

                          'partner_address_id': address_id,

                          'priority': tender.priority,

                          'details': tender.details,

                          'delivery_requested_date': tender.requested_date,

                          }

                # create the rfq - dic is udpated for default partner_address_id at purchase.order level

                

                for line in tender.tender_line_ids:

                    # create an order line for each tender line

                    price = pricelist_obj.price_get(cr, uid, [pricelist_id], line.product_id.id, line.qty, supplier.id, {'uom': line.product_uom.id})[pricelist_id]

                    newdate = datetime.strptime(line.date_planned, '%Y-%m-%d')

                              'date_planned': newdate.strftime('%Y-%m-%d'),

                              'notes': line.product_id.description_purchase,

                              'order_id': po_id,

                              }

                    # create purchase order line

                    pol_id = pol_obj.create(cr, uid, values, context=context)

        '''

        # done all related rfqs

        wf_service = netsvc.LocalService("workflow")

        for tender in self.browse(cr, uid, ids, context=context):

            rfq_list = []

            for rfq in tender.rfq_ids:

                raise osv.except_osv(_('Warning !'), _("Generated RfQs must be Updated or Cancelled."))

            

            # integrity check, all lines must have purchase_order_line_id

                raise osv.except_osv(_('Error !'), _('All tender lines must have been compared!'))

        # update product supplierinfo and pricelist

        self.update_supplier_info(cr, uid, ids, context=context, integrity_test=False,)

        # change tender state

            # gather the product_id -> supplier_id relationship to display it back in the compare wizard

            suppliers = {}

            for line in tender.tender_line_ids:

                    suppliers.update({line.product_id.id:line.supplier_id.id,})

            # rfq corresponding to this tender with done state (has been updated and not canceled)

            # the list of rfq which will be compared

            if integrity_test:

                self.tender_integrity(cr, uid, tender, context=context)

            for line in tender.tender_line_ids:

                # if a supplier has been selected

                if line.purchase_order_line_id:

                    # set the flag

            # check if corresponding rfqs are in the good state

            self.tender_integrity(cr, uid, tender, context=context)

            # integrity check, all lines must have purchase_order_line_id

                raise osv.except_osv(_('Error !'), _('All tender lines must have been compared!'))

            data = {}

            for line in tender.tender_line_ids:

                data.setdefault(line.supplier_id.id, {}) \

                    .setdefault('order_line', []).append((0,0,{'name': line.product_id.partner_ref,

                                                               'product_qty': line.qty,

                                                               }))

                    

                # fill data corresponding to po creation

                pricelist = line.supplier_id.property_product_pricelist_purchase.id,

                if line.currency_id:

                    price_ids = self.pool.get('product.pricelist').search(cr, uid, [('type', '=', 'purchase'), ('currency_id', '=', line.currency_id.id)], context=context)

                    if price_ids:

                        pricelist = price_ids[0]

                             'partner_id': line.supplier_id.id,

                             'partner_address_id': address_id,

                             'location_id': tender.location_id.id,

                             'warehouse_id': tender.warehouse_id.id,

                             'details': tender.details,

                             'delivery_requested_date': tender.requested_date,

                             }

                data[line.supplier_id.id].update(po_values)

            

            self.done(cr, uid, [tender.id], context=context)

        

        return po_id

    

    def wkf_action_cancel(self, cr, uid, ids, context=None):

        '''

        cancel all corresponding rfqs

        '''

        po_obj = self.pool.get('purchase.order')

        wf_service = netsvc.LocalService("workflow")

        # set state

        self.write(cr, uid, ids, {'state': 'cancel'}, context=context)

            rfq_ids = po_obj.search(cr, uid, [('tender_id', '=', tender.id),], context=context)

            for rfq_id in rfq_ids:

                wf_service.trg_validate(uid, 'purchase.order', rfq_id, 'purchase_cancel', cr)

                

        return True

 

    

    _SELECTION_TENDER_STATE = [('draft', 'Draft'),('comparison', 'Comparison'), ('done', 'Closed'),]

    

        '''

        product is changed, we update the UoM

        '''

        prod_obj = self.pool.get('product.product')

        result = {'value': {}}

        if product_id:

        return result

    

    def _get_total_price(self, cr, uid, ids, field_name, arg, context=None):

        '''

    

    _columns = {'product_id': fields.many2one('product.product', string="Product", required=True),

                'qty': fields.float(string="Qty", required=True),

                'purchase_order_line_id': fields.many2one('purchase.order.line', string="Related RfQ line", readonly=True),

                'sale_order_line_id': fields.many2one('sale.order.line', string="Sale Order Line"),

                'product_uom': fields.many2one('product.uom', 'Product UOM', required=True),

                'date_planned': fields.related('tender_id', 'requested_date', type='date', string='Requested Date', store=False,),

                # functions

                'supplier_id': fields.related('purchase_order_line_id', 'order_id', 'partner_id', type='many2one', relation='res.partner', string="Supplier", readonly=True),

                'currency_id': fields.function(_get_total_price, method=True, type='many2one', relation='res.currency', string='Cur.', multi='total'),

                'func_currency_id': fields.function(_get_total_price, method=True, type='many2one', relation='res.currency', string='Func. Cur.', multi='total'),

                'purchase_order_id': fields.related('purchase_order_line_id', 'order_id', type='many2one', relation='purchase.order', string="Related RfQ", readonly=True,),

                'state': fields.related('tender_id', 'state', type="selection", selection=_SELECTION_TENDER_STATE, string="State",),

                }

    _defaults = {'qty': lambda *a: 1.0,

                 'state': lambda *a: 'draft',

                 }

    

tender_line()

 

 

        # reset the tender line

        for line in result['tender_line_ids']:

            line[2].update(sale_order_line_id=False,

        return result

 

tender2()

    '''

    _inherit = 'procurement.order'

    

        '''

        '''

        result = {}

        for proc in self.browse(cr, uid, ids, context=context):

            for line in proc.sale_order_line_ids:

                                

        return result

    

                'sale_order_line_ids': fields.one2many('sale.order.line', 'procurement_id', string="Sale Order Lines"),

                'tender_id': fields.many2one('tender', string='Tender', readonly=True),

                'is_tender_done': fields.boolean(string="Tender Closed"),

                'state': fields.selection([('draft','Draft'),

                                           ('confirmed','Confirmed'),

                                           ('exception','Exception'),

                                           ('ready','Ready'),

                                           ('done','Closed'),

                                           ('tender', 'Tender'),

                                           ('waiting','Waiting'),], 'State', required=True,

                                          help='When a procurement is created the state is set to \'Draft\'.\n If the procurement is confirmed, the state is set to \'Confirmed\'.\

                                                \nAfter confirming the state is set to \'Running\'.\n If any exception arises in the order then the state is set to \'Exception\'.\n Once the exception is removed the state becomes \'Ready\'.\n It is in \'Waiting\'. state when the procurement is waiting for another one to finish.'),

        }