fix: error while using data import and importing docs (develop)version-14
@@ -1202,10 +1202,10 @@ def make_property_setter(args, ignore_validate=False, validate_fields_for_doctyp | |||
ps.validate_fieldtype_change() | |||
ps.insert() | |||
def import_doc(path, ignore_links=False, ignore_insert=False, insert=False): | |||
def import_doc(path): | |||
"""Import a file using Data Import.""" | |||
from frappe.core.doctype.data_import.data_import import import_doc | |||
import_doc(path, ignore_links=ignore_links, ignore_insert=ignore_insert, insert=insert) | |||
import_doc(path) | |||
def copy_doc(doc, ignore_no_copy=True): | |||
""" No_copy fields also get copied.""" | |||
@@ -293,7 +293,7 @@ def import_doc(context, path, force=False): | |||
try: | |||
frappe.init(site=site) | |||
frappe.connect() | |||
import_doc(path, overwrite=context.force) | |||
import_doc(path) | |||
finally: | |||
frappe.destroy() | |||
if not context.sites: | |||
@@ -2,16 +2,16 @@ | |||
# Copyright (c) 2019, Frappe Technologies and contributors | |||
# For license information, please see license.txt | |||
from __future__ import unicode_literals | |||
import os | |||
import frappe | |||
from frappe.model.document import Document | |||
from frappe.core.doctype.data_import.importer import Importer | |||
import frappe | |||
from frappe import _ | |||
from frappe.core.doctype.data_import.exporter import Exporter | |||
from frappe.core.doctype.data_import.importer import Importer | |||
from frappe.model.document import Document | |||
from frappe.modules.import_file import import_file_by_path | |||
from frappe.utils.background_jobs import enqueue | |||
from frappe.utils.csvutils import validate_google_sheets_url | |||
from frappe import _ | |||
class DataImport(Document): | |||
@@ -173,15 +173,7 @@ def import_file( | |||
############## | |||
def import_doc( | |||
path, | |||
overwrite=False, | |||
ignore_links=False, | |||
ignore_insert=False, | |||
insert=False, | |||
submit=False, | |||
pre_process=None, | |||
): | |||
def import_doc(path, pre_process=None): | |||
if os.path.isdir(path): | |||
files = [os.path.join(path, f) for f in os.listdir(path)] | |||
else: | |||
@@ -190,30 +182,21 @@ def import_doc( | |||
for f in files: | |||
if f.endswith(".json"): | |||
frappe.flags.mute_emails = True | |||
frappe.modules.import_file.import_file_by_path( | |||
f, data_import=True, force=True, pre_process=pre_process, reset_permissions=True | |||
) | |||
frappe.flags.mute_emails = False | |||
frappe.db.commit() | |||
elif f.endswith(".csv"): | |||
import_file_by_path( | |||
f, | |||
ignore_links=ignore_links, | |||
overwrite=overwrite, | |||
submit=submit, | |||
data_import=True, | |||
force=True, | |||
pre_process=pre_process, | |||
reset_permissions=True | |||
) | |||
frappe.flags.mute_emails = False | |||
frappe.db.commit() | |||
elif f.endswith(".csv"): | |||
validate_csv_import_file(f) | |||
frappe.db.commit() | |||
def import_file_by_path( | |||
path, | |||
ignore_links=False, | |||
overwrite=False, | |||
submit=False, | |||
pre_process=None, | |||
no_email=True, | |||
): | |||
def validate_csv_import_file(path): | |||
if path.endswith(".csv"): | |||
print() | |||
print("This method is deprecated.") | |||
@@ -2,20 +2,22 @@ | |||
# Copyright (c) 2017, Frappe Technologies and contributors | |||
# For license information, please see license.txt | |||
from __future__ import unicode_literals | |||
import frappe, os | |||
from frappe import _ | |||
import os | |||
import frappe | |||
import frappe.modules.import_file | |||
from frappe.model.document import Document | |||
from frappe.utils.data import format_datetime | |||
from frappe import _ | |||
from frappe.core.doctype.data_import_legacy.importer import upload | |||
from frappe.model.document import Document | |||
from frappe.modules.import_file import import_file_by_path as _import_file_by_path | |||
from frappe.utils.background_jobs import enqueue | |||
from frappe.utils.data import format_datetime | |||
class DataImportLegacy(Document): | |||
def autoname(self): | |||
if not self.name: | |||
self.name = "Import on " +format_datetime(self.creation) | |||
self.name = "Import on " + format_datetime(self.creation) | |||
def validate(self): | |||
if not self.import_file: | |||
@@ -33,6 +35,7 @@ class DataImportLegacy(Document): | |||
def get_importable_doctypes(): | |||
return frappe.cache().hget("can_import", frappe.session.user) | |||
@frappe.whitelist() | |||
def import_data(data_import): | |||
frappe.db.set_value("Data Import Legacy", data_import, "import_status", "In Progress", update_modified=False) | |||
@@ -57,7 +60,7 @@ def import_doc(path, overwrite=False, ignore_links=False, ignore_insert=False, | |||
for f in files: | |||
if f.endswith(".json"): | |||
frappe.flags.mute_emails = True | |||
frappe.modules.import_file.import_file_by_path(f, data_import=True, force=True, pre_process=pre_process, reset_permissions=True) | |||
_import_file_by_path(f, data_import=True, force=True, pre_process=pre_process, reset_permissions=True) | |||
frappe.flags.mute_emails = False | |||
frappe.db.commit() | |||
elif f.endswith(".csv"): | |||
@@ -69,7 +72,7 @@ def import_file_by_path(path, ignore_links=False, overwrite=False, submit=False, | |||
from frappe.utils.csvutils import read_csv_content | |||
print("Importing " + path) | |||
with open(path, "r") as infile: | |||
upload(rows = read_csv_content(infile.read()), ignore_links=ignore_links, no_email=no_email, overwrite=overwrite, | |||
upload(rows=read_csv_content(infile.read()), ignore_links=ignore_links, no_email=no_email, overwrite=overwrite, | |||
submit_after_import=submit, pre_process=pre_process) | |||
@@ -1,10 +1,11 @@ | |||
# Copyright (c) 2015, Frappe Technologies Pvt. Ltd. and Contributors | |||
# MIT License. See license.txt | |||
from __future__ import unicode_literals, print_function | |||
import os | |||
import frappe | |||
from frappe.core.doctype.data_import.data_import import export_json, import_doc | |||
import frappe, os | |||
from frappe.core.doctype.data_import.data_import import import_doc, export_json | |||
def sync_fixtures(app=None): | |||
"""Import, overwrite fixtures from `[app]/fixtures`""" | |||
@@ -20,8 +21,7 @@ def sync_fixtures(app=None): | |||
fixture_files = sorted(os.listdir(frappe.get_app_path(app, "fixtures"))) | |||
for fname in fixture_files: | |||
if fname.endswith(".json") or fname.endswith(".csv"): | |||
import_doc(frappe.get_app_path(app, "fixtures", fname), | |||
ignore_links=True, overwrite=True) | |||
import_doc(frappe.get_app_path(app, "fixtures", fname)) | |||
import_custom_scripts(app) | |||
@@ -29,6 +29,7 @@ def sync_fixtures(app=None): | |||
frappe.db.commit() | |||
def import_custom_scripts(app): | |||
"""Import custom scripts from `[app]/fixtures/custom_scripts`""" | |||
if os.path.exists(frappe.get_app_path(app, "fixtures", "custom_scripts")): | |||
@@ -44,11 +45,12 @@ def import_custom_scripts(app): | |||
custom_script.save() | |||
else: | |||
frappe.get_doc({ | |||
"doctype":"Client Script", | |||
"doctype": "Client Script", | |||
"dt": doctype, | |||
"script": script | |||
}).insert() | |||
def export_fixtures(app=None): | |||
"""Export fixtures as JSON to `[app]/fixtures`""" | |||
if app: | |||