@ -12,6 +12,7 @@ import json
from datetime import date from datetime import date
from frappe . utils import cstr from frappe . utils import cstr
from frappe . utils import logger from frappe . utils import logger
import re
current_db_name = frappe . conf . get ( " db_name " ) current_db_name = frappe . conf . get ( " db_name " )
sys . tracebacklimit = 0 sys . tracebacklimit = 0
site_name = cstr ( frappe . local . site ) site_name = cstr ( frappe . local . site )
@ -199,18 +200,23 @@ def update_qwik_published_docs(self):
def update_publish_mapping ( vehicle , variant , language , module , publish_type ) : def update_publish_mapping ( vehicle , variant , language , module , publish_type ) :
frappe . set_user ( ' Administrator ' ) # frappe.set_user('Administrator')
try :
frappe . log_error ( " calling module " , str ( module ) )
if module == ' Repair service ' : if module == ' Repair service ' :
pub_data = frappe . db . get_list ( ' Module Publish Mapping ' , filters = { pub_data = frappe . db . get_list ( ' Module Publish Mapping ' , filters = {
" vehicle " : vehicle , " vehicle " : vehicle ,
" language " : language , " language " : language ,
" publish_type " : publish_type " publish_type " : publish_type
} , fields = [ ' name ' ] ) } , fields = [ ' name ' ] )
frappe . log_error ( " pub_data " , str ( pub_data ) )
if len ( pub_data ) > 0 : if len ( pub_data ) > 0 :
for d in pub_data : for d in pub_data :
if d [ ' name ' ] : if d [ ' name ' ] :
frappe . log_error ( " kkkkkkkkkk " )
frappe . db . sql ( frappe . db . sql (
f """ UPDATE `tabModule Publish Mapping` set repairservice_check_sheet= ' 1 ' and publish_type= ' 1 ' where name = ' { d [ ' name ' ] } ' """ , as_dict = 1 ) f """ UPDATE `tabModule Publish Mapping` set repairservice_check_sheet= ' 1 ' ,publish_type= ' { publish_type } ' where name = ' { d [ ' name ' ] } ' """ )
frappe . db . commit ( ) frappe . db . commit ( )
elif module == ' Special Tool ' : elif module == ' Special Tool ' :
@ -223,7 +229,7 @@ def update_publish_mapping(vehicle, variant, language, module, publish_type):
for d in pub_data : for d in pub_data :
if d [ ' name ' ] : if d [ ' name ' ] :
frappe . db . sql ( frappe . db . sql (
f """ UPDATE `tabModule Publish Mapping` set mahindra_special_tool_information= ' 1 ' and publish_type= ' 1 ' where name = ' { d [ ' name ' ] } ' """ , as_dict = 1 ) f """ UPDATE `tabModule Publish Mapping` set mahindra_special_tool_information= ' 1 ' ,publish_type= ' { publish_type } ' where name = ' { d [ ' name ' ] } ' """ , as_dict = 1 )
frappe . db . commit ( ) frappe . db . commit ( )
else : else :
pub_data = frappe . db . get_list ( ' Module Publish Mapping ' , filters = { pub_data = frappe . db . get_list ( ' Module Publish Mapping ' , filters = {
@ -256,7 +262,8 @@ def update_publish_mapping(vehicle, variant, language, module, publish_type):
doc . qwik_service = 1 doc . qwik_service = 1
doc . save ( ) doc . save ( )
except Exception as e :
frappe . log_error ( " update_publish_mapping " , str ( e ) )
# def update_publish_status(self): # def update_publish_status(self):
# try: # try:
@ -1291,21 +1298,39 @@ def qwik_service_data(language, publish_type, variant, parent, vehicle):
qwik_service_details = frappe . db . sql ( ''' select name,variant,vehicle,kilometers,language,service_time,active_status, qwik_service_details = frappe . db . sql ( ''' select name,variant,vehicle,kilometers,language,service_time,active_status,
pdf , display_order , keywords , my_id from ` tabQwik Service ` where name = ' %s ' ; ''' % pdf , display_order , keywords , my_id from ` tabQwik Service ` where name = ' %s ' ; ''' %
( parent ) , as_dict = 1 ) ( parent ) , as_dict = 1 )
CLEANR = re . compile ( ' <.*?> ' )
for q in qwik_service_details : for q in qwik_service_details :
q [ ' pre_work ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where parent= ' %s ' q [ ' pre_work ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where parent= ' %s '
& & content_type = ' Pre-work ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1) & & content_type = ' Pre-work ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1)
# if q['pre_work']:
# for con in q['pre_work']:
# if con['content']:
# con['content'] = re.sub(CLEANR, '', con['content'])
q [ ' consumables ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where q [ ' consumables ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where
parent = ' %s ' & & content_type = ' Consumables ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1) parent = ' %s ' & & content_type = ' Consumables ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1)
# if q['consumables']:
# for con in q['consumables']:
# if con['content']:
# con['content'] = re.sub(CLEANR, '', con['content'])
q [ ' tools ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where q [ ' tools ' ] = frappe . db . sql ( ''' select idx as ' display_order ' , content from `tabQwik Service Content` where
parent = ' %s ' & & content_type = ' Tools ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1) parent = ' %s ' & & content_type = ' Tools ' order by display_order ; ''' % (q[ ' name ' ]), as_dict=1)
# if q['tools']:
# for con in q['tools']:
# if con['content']:
# con['content'] = re.sub(CLEANR, '', con['content'])
for p in qwik_service_details : for p in qwik_service_details :
# p['qwik_procedure'] = frappe.db.sql('''select idx as 'display_order',side,level,content from `tabQwik Procedure`
# where parent ='%s';''' % (p['name']), as_dict=1)
LHS = frappe . db . sql ( ''' select idx as ' display_order ' ,side,level,content from `tabQwik Procedure` LHS = frappe . db . sql ( ''' select idx as ' display_order ' ,side,level,content from `tabQwik Procedure`
where parent = ' %s ' and side = ' LHS ' ; ''' % (p[ ' name ' ]), as_dict=1) where parent = ' %s ' and side = ' LHS ' ; ''' % (p[ ' name ' ]), as_dict=1)
# if LHS:
# for con in LHS:
# if con['content']:
# con['content'] = re.sub(CLEANR, '', con['content'])
RHS = frappe . db . sql ( ''' select idx as ' display_order ' ,side,level,content from `tabQwik Procedure` RHS = frappe . db . sql ( ''' select idx as ' display_order ' ,side,level,content from `tabQwik Procedure`
where parent = ' %s ' and side = ' RHS ' ; ''' % (p[ ' name ' ]), as_dict=1) where parent = ' %s ' and side = ' RHS ' ; ''' % (p[ ' name ' ]), as_dict=1)
# if RHS:
# for con in RHS:
# if con['content']:
# con['content'] = re.sub(CLEANR, '', con['content'])
p [ ' qwik_procedure ' ] = { ' LHS ' : LHS , ' RHS ' : RHS } p [ ' qwik_procedure ' ] = { ' LHS ' : LHS , ' RHS ' : RHS }
logger . info ( logger . info (
@ -1366,6 +1391,7 @@ def max_publish_new_module(doc):
@frappe . whitelist ( ) @frappe . whitelist ( )
def cal_ver_new_module ( vehicle , lang , publish_type , doc ) : def cal_ver_new_module ( vehicle , lang , publish_type , doc ) :
try :
current_db_name = frappe . conf . get ( " db_name " ) current_db_name = frappe . conf . get ( " db_name " )
doc = frappe . get_doc ( " Publish " , doc ) doc = frappe . get_doc ( " Publish " , doc )
ver = frappe . db . sql ( """ select max(version) from `tabPublish` where vehicle = " {vehi} " and language = " {lang} " and ver = frappe . db . sql ( """ select max(version) from `tabPublish` where vehicle = " {vehi} " and language = " {lang} " and
@ -1388,7 +1414,9 @@ def cal_ver_new_module(vehicle, lang, publish_type, doc):
frappe . db . sql ( """ update {0} .`tabPublish` set version = " {1} " where name = " {2} " ; """ . format ( frappe . db . sql ( """ update {0} .`tabPublish` set version = " {1} " where name = " {2} " ; """ . format (
current_db_name , v , doc . name ) ) current_db_name , v , doc . name ) )
frappe . db . commit ( ) frappe . db . commit ( )
return v return { " status " : 1 , " data " : v }
except Exception as e :
return { " status " : 0 , " data " : " None " , " error " : str ( e ) }
@frappe . whitelist ( ) @frappe . whitelist ( )
