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

fix: delete hub tracked item on unpublish

Browse Source
This commit is contained in:
Mangesh-Khairnar 2020-04-30 20:31:12 +05:30
parent 7f374e7ba5
commit 367b644d9e
1 changed files with 6 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
erpnext/hub_node/api.py
View File

@ -144,27 +144,17 @@ def publish_selected_items(items_to_publish):
'hub_category': item.get('hub_category'), 'hub_category': item.get('hub_category'),
'image_list': item.get('image_list') 'image_list': item.get('image_list')
} }
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_item.save()
else:
frappe.get_doc(hub_dict).insert(ignore_if_duplicate=True) frappe.get_doc(hub_dict).insert(ignore_if_duplicate=True)
items_to_publish = list(filter(lambda x: x not in items_to_update, items_to_publish)) items = map_fields(items_to_publish)
new_items = map_fields(items_to_publish)
existing_items = map_fields(items_to_update)
try: try:
item_sync_preprocess(len(new_items+existing_items)) item_sync_preprocess(len(items))
convert_relative_image_urls_to_absolute(new_items) convert_relative_image_urls_to_absolute(items)
convert_relative_image_urls_to_absolute(existing_items)
# TODO: Publish Progress # TODO: Publish Progress
connection = get_hub_connection() connection = get_hub_connection()
connection.insert_many(new_items) connection.insert_many(items)
connection.bulk_update(existing_items)
item_sync_postprocess() item_sync_postprocess()
except Exception as e: except Exception as e:
@ -180,6 +170,7 @@ def unpublish_item(item_code, hub_item_name):
if response: if response:
frappe.db.set_value('Item', item_code, 'publish_in_hub', 0) frappe.db.set_value('Item', item_code, 'publish_in_hub', 0)
frappe.delete_doc('Hub Tracked Item', item_code)
else: else:
frappe.throw(_('Unable to update remote activity')) frappe.throw(_('Unable to update remote activity'))