Shiloh/brotherton-erpnext
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: update already existing items

Browse Source
This commit is contained in:
Mangesh-Khairnar 2019-12-13 15:05:43 +05:30
parent c6599fd1e2
commit 4bea44b9c9
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
erpnext/hub_node/api.py
View File

@ -119,6 +119,7 @@ def get_valid_items(search_value=''):
@frappe.whitelist() @frappe.whitelist()
def publish_selected_items(items_to_publish): def publish_selected_items(items_to_publish):
items_to_publish = json.loads(items_to_publish) items_to_publish = json.loads(items_to_publish)
items_to_update = []
if not len(items_to_publish): if not len(items_to_publish):
frappe.throw(_('No items to publish')) frappe.throw(_('No items to publish'))
@ -126,14 +127,24 @@ def publish_selected_items(items_to_publish):
item_code = item.get('item_code') item_code = item.get('item_code')
frappe.db.set_value('Item', item_code, 'publish_in_hub', 1) frappe.db.set_value('Item', item_code, 'publish_in_hub', 1)
frappe.get_doc({ hub_dict = {
'doctype': 'Hub Tracked Item', 'doctype': 'Hub Tracked Item',
'item_code': item_code, 'item_code': item_code,
'published': 1,
'hub_category': item.get('hub_category'), 'hub_category': item.get('hub_category'),
'image_list': item.get('image_list') 'image_list': item.get('image_list')
}).insert(ignore_if_duplicate=True) }
if frappe.db.exists('Hub Tracked Item', item_code):
items_to_update.append(item)
hub_tracked_item = frappe.get_doc('Hub Tracked Item', item_code)
hub_tracked_item.update(hub_dict)
hub_tracked_items.save()
else:
frappe.get_doc(hub_dict).insert(ignore_if_duplicate=True)
items = map_fields(items_to_publish) items_to_publish = list(filter(lambda x: x not in items_to_update, items_to_publish))
new_items = map_fields(items_to_publish)
existing_items = map_fields(items_to_update)
try: try:
item_sync_preprocess(len(items)) item_sync_preprocess(len(items))
@ -141,7 +152,8 @@ def publish_selected_items(items_to_publish):
# TODO: Publish Progress # TODO: Publish Progress
connection = get_hub_connection() connection = get_hub_connection()
connection.insert_many(items) connection.insert_many(new_items)
connection.bulk_update(existing_items)
item_sync_postprocess() item_sync_postprocess()
except Exception as e: except Exception as e: