Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 1 | import frappe |
| 2 | from frappe import _ |
| 3 | from frappe.utils import flt, cint |
| 4 | from collections import defaultdict |
| 5 | from erpnext.stock.doctype.serial_no.serial_no import get_serial_nos |
| 6 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 7 | class Subcontracting(): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 8 | def set_materials_for_subcontracted_items(self, raw_material_table): |
| 9 | if self.doctype == 'Purchase Invoice' and not self.update_stock: |
| 10 | return |
| 11 | |
| 12 | self.raw_material_table = raw_material_table |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 13 | self.__identify_change_in_item_table() |
| 14 | self.__prepare_supplied_items() |
| 15 | self.__validate_consumed_qty() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 16 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 17 | def __prepare_supplied_items(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 18 | self.initialized_fields() |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 19 | self.__get_purchase_orders() |
| 20 | self.__get_pending_qty_to_receive() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 21 | self.get_available_materials() |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 22 | self.__remove_changed_rows() |
| 23 | self.__set_supplied_items() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 24 | |
| 25 | def initialized_fields(self): |
| 26 | self.available_materials = frappe._dict() |
| 27 | self.alternative_item_details = frappe._dict() |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 28 | self.__get_backflush_based_on() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 29 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 30 | def __get_backflush_based_on(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 31 | self.backflush_based_on = frappe.db.get_single_value("Buying Settings", |
| 32 | "backflush_raw_materials_of_subcontract_based_on") |
| 33 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 34 | def __get_purchase_orders(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 35 | self.purchase_orders = [] |
| 36 | |
| 37 | if self.doctype == 'Purchase Order': |
| 38 | return |
| 39 | |
| 40 | self.purchase_orders = [d.purchase_order for d in self.items if d.purchase_order] |
| 41 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 42 | def __identify_change_in_item_table(self): |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 43 | self.__changed_name = [] |
| 44 | self.__reference_name = [] |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 45 | |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 46 | if self.doctype == 'Purchase Order' or self.is_new(): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 47 | self.set(self.raw_material_table, []) |
| 48 | return |
| 49 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 50 | item_dict = self.__get_data_before_save() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 51 | if not item_dict: |
| 52 | return True |
| 53 | |
| 54 | for n_row in self.items: |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 55 | self.__reference_name.append(n_row.name) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 56 | if (n_row.name not in item_dict) or (n_row.item_code, n_row.qty) != item_dict[n_row.name]: |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 57 | self.__changed_name.append(n_row.name) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 58 | |
| 59 | if item_dict.get(n_row.name): |
| 60 | del item_dict[n_row.name] |
| 61 | |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 62 | self.__changed_name.extend(item_dict.keys()) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 63 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 64 | def __get_data_before_save(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 65 | item_dict = {} |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 66 | if self.doctype in ['Purchase Receipt', 'Purchase Invoice'] and self._doc_before_save: |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 67 | for row in self._doc_before_save.get('items'): |
| 68 | item_dict[row.name] = (row.item_code, row.qty) |
| 69 | |
| 70 | return item_dict |
| 71 | |
| 72 | def get_available_materials(self): |
| 73 | ''' Get the available raw materials which has been transferred to the supplier. |
| 74 | available_materials = { |
| 75 | (item_code, subcontracted_item, purchase_order): { |
| 76 | 'qty': 1, 'serial_no': [ABC], 'batch_no': {'batch1': 1}, 'data': item_details |
| 77 | } |
| 78 | } |
| 79 | ''' |
| 80 | if not self.purchase_orders: |
| 81 | return |
| 82 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 83 | for row in self.__get_transferred_items(): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 84 | key = (row.rm_item_code, row.main_item_code, row.purchase_order) |
| 85 | |
| 86 | if key not in self.available_materials: |
| 87 | self.available_materials.setdefault(key, frappe._dict({'qty': 0, 'serial_no': [], |
| 88 | 'batch_no': defaultdict(float), 'item_details': row, 'po_details': []}) |
| 89 | ) |
| 90 | |
| 91 | details = self.available_materials[key] |
| 92 | details.qty += row.qty |
| 93 | details.po_details.append(row.po_detail) |
| 94 | |
| 95 | if row.serial_no: |
| 96 | details.serial_no.extend(get_serial_nos(row.serial_no)) |
| 97 | |
| 98 | if row.batch_no: |
| 99 | details.batch_no[row.batch_no] += row.qty |
| 100 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 101 | self.__set_alternative_item_details(row) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 102 | |
| 103 | for doctype in ['Purchase Receipt', 'Purchase Invoice']: |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 104 | self.__update_consumed_materials(doctype) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 105 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 106 | def __update_consumed_materials(self, doctype, return_consumed_items=False): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 107 | '''Deduct the consumed materials from the available materials.''' |
| 108 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 109 | pr_items = self.__get_received_items(doctype) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 110 | if not pr_items: |
| 111 | return ([], {}) if return_consumed_items else None |
| 112 | |
| 113 | pr_items = {d.name: d.get(self.get('po_field') or 'purchase_order') for d in pr_items} |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 114 | consumed_materials = self.__get_consumed_items(doctype, pr_items.keys()) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 115 | |
| 116 | if return_consumed_items: |
| 117 | return (consumed_materials, pr_items) |
| 118 | |
| 119 | for row in consumed_materials: |
| 120 | key = (row.rm_item_code, row.main_item_code, pr_items.get(row.reference_name)) |
| 121 | if not self.available_materials.get(key): |
| 122 | continue |
| 123 | |
| 124 | self.available_materials[key]['qty'] -= row.consumed_qty |
| 125 | if row.serial_no: |
| 126 | self.available_materials[key]['serial_no'] = list( |
| 127 | set(self.available_materials[key]['serial_no']) - set(get_serial_nos(row.serial_no)) |
| 128 | ) |
| 129 | |
| 130 | if row.batch_no: |
| 131 | self.available_materials[key]['batch_no'][row.batch_no] -= row.consumed_qty |
| 132 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 133 | def __get_transferred_items(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 134 | fields = ['`tabStock Entry`.`purchase_order`'] |
| 135 | alias_dict = {'item_code': 'rm_item_code', 'subcontracted_item': 'main_item_code', 'basic_rate': 'rate'} |
| 136 | |
| 137 | child_table_fields = ['item_code', 'item_name', 'description', 'qty', 'basic_rate', 'amount', |
| 138 | 'serial_no', 'uom', 'subcontracted_item', 'stock_uom', 'batch_no', 'conversion_factor', |
| 139 | 's_warehouse', 't_warehouse', 'item_group', 'po_detail'] |
| 140 | |
| 141 | if self.backflush_based_on == 'BOM': |
| 142 | child_table_fields.append('original_item') |
| 143 | |
| 144 | for field in child_table_fields: |
| 145 | fields.append(f'`tabStock Entry Detail`.`{field}` As {alias_dict.get(field, field)}') |
| 146 | |
| 147 | filters = [['Stock Entry', 'docstatus', '=', 1], ['Stock Entry', 'purpose', '=', 'Send to Subcontractor'], |
| 148 | ['Stock Entry', 'purchase_order', 'in', self.purchase_orders]] |
| 149 | |
| 150 | return frappe.get_all('Stock Entry', fields = fields, filters=filters) |
| 151 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 152 | def __get_received_items(self, doctype): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 153 | fields = [] |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 154 | self.po_field = 'purchase_order' |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 155 | |
| 156 | for field in ['name', self.po_field, 'parent']: |
| 157 | fields.append(f'`tab{doctype} Item`.`{field}`') |
| 158 | |
| 159 | filters = [[doctype, 'docstatus', '=', 1], [f'{doctype} Item', self.po_field, 'in', self.purchase_orders]] |
| 160 | if doctype == 'Purchase Invoice': |
| 161 | filters.append(['Purchase Invoice', 'update_stock', "=", 1]) |
| 162 | |
| 163 | return frappe.get_all(f'{doctype}', fields = fields, filters = filters) |
| 164 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 165 | def __get_consumed_items(self, doctype, pr_items): |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 166 | return frappe.get_all('Purchase Receipt Item Supplied', |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 167 | fields = ['serial_no', 'rm_item_code', 'reference_name', 'batch_no', 'consumed_qty', 'main_item_code'], |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 168 | filters = {'docstatus': 1, 'reference_name': ('in', list(pr_items)), 'parenttype': doctype}) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 169 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 170 | def __set_alternative_item_details(self, row): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 171 | if row.get('original_item'): |
| 172 | self.alternative_item_details[row.get('original_item')] = row |
| 173 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 174 | def __get_pending_qty_to_receive(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 175 | '''Get qty to be received against the purchase order.''' |
| 176 | |
| 177 | self.qty_to_be_received = defaultdict(float) |
| 178 | |
| 179 | if self.doctype != 'Purchase Order' and self.backflush_based_on != 'BOM' and self.purchase_orders: |
| 180 | for row in frappe.get_all('Purchase Order Item', |
| 181 | fields = ['item_code', '(qty - received_qty) as qty', 'parent', 'name'], |
| 182 | filters = {'docstatus': 1, 'parent': ('in', self.purchase_orders)}): |
| 183 | |
| 184 | self.qty_to_be_received[(row.item_code, row.parent)] += row.qty |
| 185 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 186 | def __get_materials_from_bom(self, item_code, bom_no, exploded_item=0): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 187 | doctype = 'BOM Item' if not exploded_item else 'BOM Explosion Item' |
| 188 | fields = [f'`tab{doctype}`.`stock_qty` / `tabBOM`.`quantity` as qty_consumed_per_unit'] |
| 189 | |
| 190 | alias_dict = {'item_code': 'rm_item_code', 'name': 'bom_detail_no', 'source_warehouse': 'reserve_warehouse'} |
| 191 | for field in ['item_code', 'name', 'rate', 'stock_uom', |
| 192 | 'source_warehouse', 'description', 'item_name', 'stock_uom']: |
| 193 | fields.append(f'`tab{doctype}`.`{field}` As {alias_dict.get(field, field)}') |
| 194 | |
| 195 | filters = [[doctype, 'parent', '=', bom_no], [doctype, 'docstatus', '=', 1], |
| 196 | ['BOM', 'item', '=', item_code], [doctype, 'sourced_by_supplier', '=', 0]] |
| 197 | |
| 198 | return frappe.get_all('BOM', fields = fields, filters=filters, order_by = f'`tab{doctype}`.`idx`') or [] |
| 199 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 200 | def __remove_changed_rows(self): |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 201 | if not self.__changed_name: |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 202 | return |
| 203 | |
| 204 | i=1 |
| 205 | self.set(self.raw_material_table, []) |
| 206 | for d in self._doc_before_save.supplied_items: |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 207 | if d.reference_name in self.__changed_name: |
| 208 | continue |
| 209 | |
| 210 | if (d.reference_name not in self.__reference_name): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 211 | continue |
| 212 | |
| 213 | d.idx = i |
| 214 | self.append('supplied_items', d) |
| 215 | |
| 216 | i += 1 |
| 217 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 218 | def __set_supplied_items(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 219 | self.bom_items = {} |
| 220 | |
| 221 | has_supplied_items = True if self.get(self.raw_material_table) else False |
| 222 | for row in self.items: |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 223 | if (self.doctype != 'Purchase Order' and ((self.__changed_name and row.name not in self.__changed_name) |
| 224 | or (has_supplied_items and not self.__changed_name))): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 225 | continue |
| 226 | |
| 227 | if self.doctype == 'Purchase Order' or self.backflush_based_on == 'BOM': |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 228 | for bom_item in self.__get_materials_from_bom(row.item_code, row.bom, row.get('include_exploded_items')): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 229 | qty = (flt(bom_item.qty_consumed_per_unit) * flt(row.qty) * row.conversion_factor) |
| 230 | bom_item.main_item_code = row.item_code |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 231 | self.__update_reserve_warehouse(bom_item, row) |
| 232 | self.__set_alternative_item(bom_item) |
| 233 | self.__add_supplied_item(row, bom_item, qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 234 | |
| 235 | elif self.backflush_based_on != 'BOM': |
| 236 | for key, transfer_item in self.available_materials.items(): |
| 237 | if (key[1], key[2]) == (row.item_code, row.purchase_order) and transfer_item.qty > 0: |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 238 | qty = self.__get_qty_based_on_material_transfer(row, transfer_item) or 0 |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 239 | transfer_item.qty -= qty |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 240 | self.__add_supplied_item(row, transfer_item.get('item_details'), qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 241 | |
| 242 | if self.qty_to_be_received: |
| 243 | self.qty_to_be_received[(row.item_code, row.purchase_order)] -= row.qty |
| 244 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 245 | def __update_reserve_warehouse(self, row, item): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 246 | if self.doctype == 'Purchase Order': |
| 247 | row.reserve_warehouse = (self.set_reserve_warehouse or item.warehouse) |
| 248 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 249 | def __get_qty_based_on_material_transfer(self, item_row, transfer_item): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 250 | key = (item_row.item_code, item_row.purchase_order) |
| 251 | |
| 252 | if self.qty_to_be_received == item_row.qty: |
| 253 | return transfer_item.qty |
| 254 | |
| 255 | if self.qty_to_be_received: |
| 256 | qty = (flt(item_row.qty) * flt(transfer_item.qty)) / flt(self.qty_to_be_received.get(key, 0)) |
| 257 | if (transfer_item.serial_no or frappe.get_cached_value('UOM', |
| 258 | transfer_item.item_details.stock_uom, 'must_be_whole_number')): |
| 259 | return frappe.utils.ceil(qty) |
| 260 | |
| 261 | return qty |
| 262 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 263 | def __set_alternative_item(self, bom_item): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 264 | if self.alternative_item_details.get(bom_item.rm_item_code): |
| 265 | bom_item.update(self.alternative_item_details[bom_item.rm_item_code]) |
| 266 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 267 | def __add_supplied_item(self, item_row, bom_item, qty): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 268 | bom_item.conversion_factor = item_row.conversion_factor |
| 269 | rm_obj = self.append(self.raw_material_table, bom_item) |
| 270 | rm_obj.reference_name = item_row.name |
| 271 | |
| 272 | if self.doctype == 'Purchase Order': |
| 273 | rm_obj.required_qty = qty |
| 274 | else: |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 275 | self.__set_batch_nos(bom_item, item_row, rm_obj, qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 276 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 277 | def __set_batch_nos(self, bom_item, item_row, rm_obj, qty): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 278 | key = (rm_obj.rm_item_code, item_row.item_code, item_row.purchase_order) |
| 279 | |
| 280 | if (self.available_materials.get(key) and self.available_materials[key]['batch_no']): |
| 281 | for batch_no, batch_qty in self.available_materials[key]['batch_no'].items(): |
| 282 | if batch_qty >= qty: |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 283 | self.__set_batch_no_as_per_qty(item_row, rm_obj, batch_no, qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 284 | self.available_materials[key]['batch_no'][batch_no] -= qty |
| 285 | return |
| 286 | |
| 287 | elif qty > 0 and batch_qty > 0: |
| 288 | qty -= batch_qty |
| 289 | new_rm_obj = self.append(self.raw_material_table, bom_item) |
| 290 | new_rm_obj.reference_name = item_row.name |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 291 | self.__set_batch_no_as_per_qty(item_row, new_rm_obj, batch_no, batch_qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 292 | self.available_materials[key]['batch_no'][batch_no] = 0 |
| 293 | else: |
| 294 | rm_obj.required_qty = qty |
| 295 | rm_obj.consumed_qty = qty |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 296 | self.__set_serial_nos(item_row, rm_obj) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 297 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 298 | def __set_batch_no_as_per_qty(self, item_row, rm_obj, batch_no, qty): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 299 | rm_obj.update({'consumed_qty': qty, 'batch_no': batch_no, 'required_qty': qty}) |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 300 | self.__set_serial_nos(item_row, rm_obj) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 301 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 302 | def __set_serial_nos(self, item_row, rm_obj): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 303 | key = (rm_obj.rm_item_code, item_row.item_code, item_row.purchase_order) |
| 304 | if (self.available_materials.get(key) and self.available_materials[key]['serial_no']): |
| 305 | used_serial_nos = self.available_materials[key]['serial_no'][0: cint(rm_obj.consumed_qty)] |
| 306 | rm_obj.serial_no = '\n'.join(used_serial_nos) |
| 307 | |
| 308 | # Removed the used serial nos from the list |
| 309 | for sn in used_serial_nos: |
| 310 | self.available_materials[key]['serial_no'].remove(sn) |
| 311 | |
| 312 | def set_consumed_qty_in_po(self): |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 313 | # Update consumed qty back in the purchase order |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 314 | if self.is_subcontracted != 'Yes': |
| 315 | return |
| 316 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 317 | self.__get_purchase_orders() |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 318 | itemwise_consumed_qty = defaultdict(float) |
Rohit Waghchaure | 5cc3f14 | 2021-06-15 17:29:52 +0530 | [diff] [blame^] | 319 | for doctype in ['Purchase Receipt', 'Purchase Invoice']: |
| 320 | consumed_items, pr_items = self.__update_consumed_materials(doctype, return_consumed_items=True) |
| 321 | |
| 322 | for row in consumed_items: |
| 323 | key = (row.rm_item_code, row.main_item_code, pr_items.get(row.reference_name)) |
| 324 | itemwise_consumed_qty[key] += row.consumed_qty |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 325 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 326 | self.__update_consumed_qty_in_po(itemwise_consumed_qty) |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 327 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 328 | def __update_consumed_qty_in_po(self, itemwise_consumed_qty): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 329 | fields = ['main_item_code', 'rm_item_code', 'parent', 'supplied_qty', 'name'] |
| 330 | filters = {'docstatus': 1, 'parent': ('in', self.purchase_orders)} |
| 331 | |
| 332 | for row in frappe.get_all('Purchase Order Item Supplied', fields = fields, filters=filters, order_by='idx'): |
| 333 | key = (row.rm_item_code, row.main_item_code, row.parent) |
| 334 | consumed_qty = itemwise_consumed_qty.get(key, 0) |
| 335 | |
| 336 | if row.supplied_qty < consumed_qty: |
| 337 | consumed_qty = row.supplied_qty |
| 338 | |
| 339 | itemwise_consumed_qty[key] -= consumed_qty |
| 340 | frappe.db.set_value('Purchase Order Item Supplied', row.name, 'consumed_qty', consumed_qty) |
| 341 | |
Rohit Waghchaure | ddb0ec2 | 2021-06-08 10:36:39 +0530 | [diff] [blame] | 342 | def __validate_consumed_qty(self): |
Rohit Waghchaure | a94b897 | 2021-05-24 20:11:15 +0530 | [diff] [blame] | 343 | for row in self.get(self.raw_material_table): |
| 344 | if flt(row.consumed_qty) == 0.0 and row.get('serial_no'): |
| 345 | msg = f'Row {row.idx}: the consumed qty cannot be zero for the item {frappe.bold(row.rm_item_code)}' |
| 346 | |
| 347 | frappe.throw(_(msg),title=_('Consumed Items Qty Check')) |