@ -10,6 +10,7 @@ import json
from datetime import date
from frappe . utils import cstr
from frappe . utils import logger
current_db_name = frappe . conf . get ( " db_name " )
sys . tracebacklimit = 0
site_name = cstr ( frappe . local . site )
@ -26,7 +27,7 @@ module_name = 'feature_finder'
class Publish ( Document ) :
def validate ( self ) :
self . published_date = str ( date . today ( ) )
self . published_by = frappe . session . user
self . published_by = frappe . session . email
# Selected variant and kilometer mapping details list
variant = [ ]
for vm in self . get ( ' publish_documents ' ) :
@ -36,53 +37,60 @@ class Publish(Document):
# variant.append(vm.variant_mapping)
if vm . variant_mapping not in variant :
variant . append ( vm . variant_mapping )
if self . publish_module == ' Feature Finder ' and self . feature_finder_publish_docs :
for vm in self . get ( ' feature_finder_publish_docs ' ) :
if vm . variant not in variant :
variant . append ( vm . variant )
self . variant_mapping_details = ' '
self . kilometer_mapping_details = ' '
for v in variant :
self . variant_mapping_details = self . variant_mapping_details + \
str ( v ) + ' \n '
km_mapping_record = frappe . db . sql ( """ select name from {0} .`tabKilometer Mapping` where variant_mapping = " {1} " and
language = ' {2} ' """ .format(current_db_name, str(v), self.language), as_dict=1)
km_mapping_record = frappe . db . sql ( """ select name from {0} .`tabKilometer Mapping` where variant_mapping = " {1} "
and language = ' {2} ' """ .format(current_db_name, str(v), self.language),
as_dict = 1 )
for km_mapping in km_mapping_record :
self . kilometer_mapping_details = self . kilometer_mapping_details + \
str ( km_mapping . name ) + ' \n '
def on_submit ( self ) :
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Repair service ' and self . publish_type == ' Internal ' :
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Repair service ' and \
self . publish_type == ' Internal ' :
repair_checksheet_publish ( self . vehicle , self . vehicle_id ,
self . language , self . publish_type ,
self . release_description , self . variant ,
self . repa ir_checksheet_publish )
self . repia r_checksheet_publish_docs )
update_publish_status = frappe . db . sql (
""" update `tabPublish` set publish_status= ' Published ' where name= ' {0} ' """ . format ( self . name ) )
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Feature Finder ' and self . publish_type == ' Internal ' and self . feature_finder_publish :
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Feature Finder ' \
and self . publish_type == ' Internal ' and self . feature_finder_publish_docs :
feature_finder_publish ( self . vehicle , self . vehicle_id ,
self . language , self . publish_type ,
self . release_description , self . feature_finder_publish , self . variant )
self . release_description , self . feature_finder_publish_docs , self . variant )
update_publish_status = frappe . db . sql (
""" update `tabPublish` set publish_status= ' Published ' where name= ' {0} ' """ . format ( self . name ) )
if self . docstatus == 1 and self . publish_module == ' Feature Finder ' and self . publish_type == ' Global ' :
feature_finder_publish ( self . vehicle , self . vehicle_id ,
self . language , self . publish_type ,
self . release_description , self . feature_finder_publish ,
self . release_description , self . feature_finder_publish_docs ,
self . variant )
update_feature_published_docs ( self )
update_publish_status = frappe . db . sql (
""" update `tabPublish` set publish_status= ' Published ' where name= ' {0} ' """ . format ( self . name ) )
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Repair service ' and self . publish_type == ' Global ' and self . repair_checksheet_publish :
if self . docstatus == 1 and self . publish_status == ' To Publish ' and self . publish_module == ' Repair service ' \
and self . publish_type == ' Global ' and self . repiar_checksheet_publish_docs :
repair_checksheet_publish ( self . vehicle , self . vehicle_id ,
self . language , self . publish_type ,
self . release_description , self . variant ,
self . repair_checksheet_publish )
self . repiar_checksheet_publish_docs )
update_repair_published_docs ( self )
update_publish_status = frappe . db . sql (
""" update `tabPublish` set publish_status= ' Published ' where name= ' {0} ' """ . format ( self . name ) )
frappe . log_error ( str ( self . variant_mapping_details ) )
variant = self . variant_mapping_details . split ( ' /n ' )
frappe . log_error ( ' variant ' , str ( variant ) )
# for v in variant:
# frappe.log_error('v', str(v))
@ -93,10 +101,12 @@ class Publish(Document):
def onload1 ( self ) :
current_db_name = frappe . conf . get ( " db_name " )
# To validate updated procedure status
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,p.sub_system,p.asset_category,
p . item_category , p . variant , p . procedure_link , p . procedure_status , pro . name , pro . workflow_state
from { 0 } . ` tabPublish_Docs ` as p , { 0 } . ` tabProcedure ` as pro where p . parent = ' {1} ' and
p . procedure_link = pro . name and p . procedure_link is not null """ .format(current_db_name, self.name), as_dict=1)
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,
p . sub_system , p . asset_category , p . item_category , p . variant , p . procedure_link ,
p . procedure_status , pro . name , pro . workflow_state from { 0 } . ` tabPublish_Docs `
as p , { 0 } . ` tabProcedure ` as pro where p . parent = ' {1} ' and
p . procedure_link = pro . name and p . procedure_link is not null """ .format(
current_db_name , self . name ) , as_dict = 1 )
l = len ( procedure_status )
if procedure_status and self . publish_status == " Published " :
@ -105,18 +115,24 @@ class Publish(Document):
if y . procedure_link :
if x . procedure_link == y . procedure_link and y . update_procedure_status != y . procedure_status :
y . update_procedure_status = x . workflow_state
frappe . db . sql ( """ update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s ; """ , (
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . sql (
""" update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s ; """ ,
(
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . commit ( )
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status :
y . update_procedure_status = x . workflow_state
frappe . db . sql ( """ update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s """ , (
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . sql (
""" update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s """ ,
(
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . commit ( )
if y . procedure_status == " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and not y . excluded_global :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and not \
y . excluded_global :
y . excluded_global = " 1 "
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and \
x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
y . excluded_internal = " 1 "
y . save ( )
frappe . db . commit ( )
@ -124,8 +140,9 @@ class Publish(Document):
# Update system and variant mapping ststus
if self . publish_status == " Published " and self . publish_type == " Global " :
current_db_name = frappe . conf . get ( " db_name " )
global_publish = frappe . db . sql ( """ select name from {0} .`tabPublish` where global_publish = " {1} " ; """ . format (
current_db_name , self . name ) , as_dict = True )
global_publish = frappe . db . sql (
""" select name from {0} .`tabPublish` where global_publish = " {1} " ; """ . format (
current_db_name , self . name ) , as_dict = True )
for global_name in global_publish :
update_mapping ( self . variant_mapping , global_name . name )
@ -150,11 +167,13 @@ def update_procedure(vehicle, lang, publish_type, doc):
# To validate updated procedure status
doc = frappe . get_doc ( " Publish " , doc )
current_db_name = frappe . conf . get ( " db_name " )
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,p.sub_system,p.asset_category,
p . item_category , p . variant , p . procedure_link , p . procedure_status , pro . name , pro . workflow_state
from { 0 } . ` tabPublish_Docs ` as p , { 0 } . ` tabProcedure ` as pro
where p . parent = " {1} " and p . procedure_link = pro . name and pro . workflow_state != p . update_procedure_status
and p . procedure_link is not null """ .format(current_db_name, doc.name), as_dict=1)
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,
p . sub_system , p . asset_category , p . item_category , p . variant , p . procedure_link ,
p . procedure_status , pro . name , pro . workflow_state from { 0 } . ` tabPublish_Docs ` as p ,
{ 0 } . ` tabProcedure ` as pro where p . parent = " {1} " and p . procedure_link = pro . name
and pro . workflow_state != p . update_procedure_status
and p . procedure_link is not null """ .format(current_db_name, doc.name),
as_dict = 1 )
l = len ( procedure_status )
if procedure_status :
for x in procedure_status :
@ -162,13 +181,16 @@ def update_procedure(vehicle, lang, publish_type, doc):
if y . procedure_link :
if x . procedure_link == y . procedure_link and x . workflow_state != y . update_procedure_status :
y . update_procedure_status = x . workflow_state
frappe . db . sql ( """ update `tabPublish_Docs` set update_procedure_status = %s where procedure_link = %s """ , (
x . workflow_state , x . procedure_link ) )
frappe . db . sql (
""" update `tabPublish_Docs` set update_procedure_status = %s where procedure_link = %s """ , (
x . workflow_state , x . procedure_link ) )
frappe . db . commit ( )
if y . procedure_status == " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and not y . excluded_global :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and \
not y . excluded_global :
y . excluded_global = " 1 "
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and \
x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
y . excluded_internal = " 1 "
y . save ( )
@ -196,6 +218,7 @@ def update_procedure(vehicle, lang, publish_type, doc):
if str ( table_len ) == str ( len_publish ) :
frappe . throw ( " There is no item for global publish " )
# Generate Publish versions
@ -233,7 +256,7 @@ def update_publish_mapping(vehicle, variant, language, module):
def update_publish_status ( self ) :
try :
update_status = frappe . db . sql (
""" update `tabPublish Test ` set publish_status= " Published " where name= ' {0} ' """ . format ( self . name ) )
""" update `tabPublish` set publish_status= " Published " where name= ' {0} ' """ . format ( self . name ) )
except Exception as e :
return e
@ -264,6 +287,7 @@ def cal_ver(vehicle, lang, publish_type, doc):
frappe . db . commit ( )
return v
# Create global publish document for publish ready procedures
@ -272,10 +296,10 @@ def global_publish(doc):
doc = frappe . get_doc ( " Publish " , doc )
current_db_name = frappe . conf . get ( " db_name " )
procedure = frappe . db . sql (
""" select parent,name from {0} .`tabPublish_Docs` where parent = " {1} " and update_procedure_status= ' Publish Ready ' and
procedure_link is not null ; """ .format(current_db_name, doc.name))
asset = frappe . db . sql ( """ select parent,name from {0} .`tabPublish_Docs` where parent = " {1} " and variant_mapping is not null
and procedure_link is null """ .format(current_db_name, doc.name))
""" select parent,name from {0} .`tabPublish_Docs` where parent = " {1} " and update_procedure_status= ' Publish Ready '
and procedure_link is not null ; """ .format(current_db_name, doc.name))
asset = frappe . db . sql ( """ select parent,name from {0} .`tabPublish_Docs` where parent = " {1} " and variant_mapping is
not null and procedure_link is null """ .format(current_db_name, doc.name))
if not procedure and not asset :
frappe . throw ( " There is no item for global publish " )
@ -318,21 +342,34 @@ def global_publish(doc):
@frappe . whitelist ( )
def generate_global_publish ( name ) :
def generate_global_publish ( name , module_name ) :
try :
res = frappe . get_doc ( " Publish " , name )
if module_name == ' Feature Finder ' :
ret = frappe . get_doc ( {
" doctype " : " Publish " ,
" vehicle " : res . vehicle ,
" publish_type " : " Global " ,
" language " : res . language ,
" variant_mapping_details " : res . variant_mapping_details ,
" publish_status " : ' To Publish ' ,
" release_description " : res . release_description ,
" publish_module " : res . publish_module ,
" feature_finder_publish_docs " : res . feature_finder_publish_docs
} )
elif module_name == ' Repair service ' :
ret = frappe . get_doc ( {
" doctype " : " Publish " ,
" vehicle " : res . vehicle ,
" publish_type " : " Global " ,
" language " : res . language ,
" variant_mapping_details " : res . variant_mapping ,
" publish_status " : ' To Publish ' ,
" release_description " : res . release_description ,
" publish_module " : res . publish_module ,
" repiar_checksheet_publish_docs " : res . repiar_checksheet_publish_docs
} )
ret = frappe . get_doc ( {
" doctype " : " Publish " ,
" vehicle " : res . vehicle ,
" publish_type " : " Global " ,
" language " : res . language ,
" publish_status " : ' To Publish ' ,
" release_description " : res . release_description ,
" publish_module " : res . publish_module ,
" feature_finder_publish " : res . feature_finder_publish ,
" repair_checksheet_publish " : res . repair_checksheet_publish
} )
ret . save ( )
return { " status " : " success " , " message " : ret . name , " url " : frappe . utils . get_url ( ) }
except Exception as e :
@ -353,6 +390,7 @@ def old_publish(vehicle, language):
if global_publish_record :
return global_publish_record
# Update System and Variant Mapping and its called from publish client script
@ -367,31 +405,37 @@ def update_mapping(variant_mapping, doc):
for v in vm . get ( ' assets ' ) :
if v . category == variant . asset_category :
v . published = ' 1 '
frappe . db . sql ( """ update {0} .`tabVariant Mapping_Assets` set published = ' 1 ' where parent = " {1} " and category = " {2} " ; """ . format (
current_db_name , variant . variant_mapping , variant . asset_category ) )
frappe . db . sql (
""" update {0} .`tabVariant Mapping_Assets` set published = ' 1 ' where parent = " {1} " and
category = " {2} " ; """ .format(current_db_name, variant.variant_mapping, variant.asset_category))
frappe . db . commit ( )
if variant . item_category == " System Mapping " :
system_mapping = frappe . db . sql ( """ select name from {0} .`tabSystem Mapping` where variant_mapping = " {1} " and language = " {2} " ; """ . format (
current_db_name , variant . variant_mapping , doc . language ) , as_dict = 1 )
system_mapping = frappe . db . sql (
""" select name from {0} .`tabSystem Mapping` where variant_mapping = " {1} " and language = " {2} " ; """ . format (
current_db_name , variant . variant_mapping , doc . language ) , as_dict = 1 )
if system_mapping :
for system_map in system_mapping :
sm = frappe . get_doc ( " System Mapping " , system_map . name )
for sys_asset in sm . get ( ' systems_assets ' ) :
if sys_asset . systems == variant . system :
sys_asset . published = ' 1 '
frappe . db . sql ( """ update {0} .`tabSystem Mapping_System Assets` set published = ' 1 ' where parent = " {1} " and systems = " {2} " ; """ . format (
current_db_name , sm . name , variant . system ) )
frappe . db . sql (
""" update {0} .`tabSystem Mapping_System Assets` set published = ' 1 ' where
parent = " {1} " and systems = " {2} " ; """ .format(
current_db_name , sm . name , variant . system ) )
frappe . db . commit ( )
for sm_item in sm . get ( " system_sub_systems " ) :
if sm_item . systems == variant . system and sm_item . sub_systems == variant . sub_system and sm_item . procedure == variant . procedure_link :
if sm_item . systems == variant . system and sm_item . sub_systems == variant . sub_system and \
sm_item . procedure == variant . procedure_link :
sm_item . procedure_is_published = ' 1 '
frappe . db . sql ( """ update {0} .`tabSystem Mapping_Sub System` set procedure_is_published = ' 1 ' where parent = " {1} "
and systems = " {2} " and sub_systems = " {3} " ; """ .format(
frappe . db . sql ( """ update {0} .`tabSystem Mapping_Sub System` set procedure_is_published =
' 1 ' where parent = " {1} " and systems = " {2} " and sub_systems = " {3} " ; """ .format(
current_db_name , sm . name , variant . system , variant . sub_system ) )
frappe . db . commit ( )
# Set filter for latest modified document
@ -399,31 +443,37 @@ def update_mapping(variant_mapping, doc):
def get_vm_asset ( doc , lang ) :
doc = frappe . get_doc ( " Variant Mapping " , doc )
vm_assets = frappe . db . sql ( """ select category,language,attach_file,active_status from {0} .`tabVariant Mapping_Assets`
where parent = " {1} " and language = ' {2} ' and published = 0 ; """ .format(current_db_name, doc.name, lang), as_dict=1)
where parent = " {1} " and language = ' {2} ' and published = 0 ; """ .format(current_db_name,
doc . name , lang ) ,
as_dict = 1 )
return vm_assets
@frappe . whitelist ( )
def get_sm_asset ( doc , name , lang ) :
system_map = frappe . db . sql ( """ select name from {0} .`tabSystem Mapping` where variant_mapping= " {1} " and name = " {2} " and language = ' {3} ' ; """ . format (
current_db_name , doc , name , lang ) , as_dict = 1 )
system_map = frappe . db . sql (
""" select name from {0} .`tabSystem Mapping` where variant_mapping= " {1} " and name = " {2} " and language = ' {3} ' ; """ . format (
current_db_name , doc , name , lang ) , as_dict = 1 )
if system_map :
for s in system_map :
doc = frappe . get_doc ( " System Mapping " , s . name )
system_asset = frappe . db . sql ( """ select systems,language,active_status,system_asset from {0} .`tabSystem Mapping_System Assets`
where parent = " {1} " and language = " {2} " and published = ' 0 ' ; """ .format(current_db_name, s.name, lang), as_dict=1)
where parent = " {1} " and language = " {2} " and published = ' 0 ' ; """ .format(current_db_name, s.name,
lang ) , as_dict = 1 )
return system_asset
@frappe . whitelist ( )
def get_system ( doc , name , lang ) :
system_map = frappe . db . sql ( """ select name from {0} .`tabSystem Mapping` where variant_mapping= " {1} " and name = " {2} " and language = " {3} " ; """ . format (
current_db_name , doc , name , lang ) , as_dict = 1 )
system_map = frappe . db . sql (
""" select name from {0} .`tabSystem Mapping` where variant_mapping= " {1} " and name = " {2} " and language = " {3} " ; """ . format (
current_db_name , doc , name , lang ) , as_dict = 1 )
if system_map :
for s in system_map :
doc = frappe . get_doc ( " System Mapping " , s . name )
system = frappe . db . sql ( """ select systems,sub_systems,active_status,symptom,component,estimate_time,rts,component,mat,
procedure_status , ` procedure ` from { 0 } . ` tabSystem Mapping_Sub System ` where parent = " {1} " and procedure_status != " Draft " and
system = frappe . db . sql ( """ select systems,sub_systems,active_status,symptom,component,estimate_time,rts,
component , mat , procedure_status , ` procedure ` from { 0 } . ` tabSystem Mapping_Sub System `
where parent = " {1} " and procedure_status != " Draft " and
procedure_is_published = " 0 " ; """ .format(current_db_name, s.name), as_dict=1)
return system
@ -431,8 +481,9 @@ def get_system(doc, name, lang):
@frappe . whitelist ( )
def max_publish ( doc ) :
doc = frappe . get_doc ( " Publish " , doc )
ver = frappe . db . sql ( """ select max(version) from {0} .tabPublish where vehicle = " {1} " and language = " {2} " ; """ . format (
current_db_name , doc . vehicle , doc . language ) )
ver = frappe . db . sql (
""" select max(version) from {0} .tabPublish where vehicle = " {1} " and language = " {2} " ; """ . format (
current_db_name , doc . vehicle , doc . language ) )
if ver :
return ver
@ -441,9 +492,11 @@ def max_publish(doc):
def variant ( doctype , txt , searchfield , start , page_len , filters ) :
vehicle = filters . get ( ' vehicle ' )
return frappe . db . sql ( """ select name,family_code,fuel,transmission,vehicle_segment,active_status
FROM { 0 } . ` tabVariant Mapping ` where vehicle = " {1} " and
( active_status like " %% %(txt)s %% " or vehicle_segment like " %% %(txt)s %% " or name like " %% %(txt)s %% " or variant like " %% %(txt)s %% " or
family_code like " %% %(txt)s %% " or fuel like " %% %(txt)s %% " or transmission like " %% %(txt)s %% " ) order by modified desc limit % ( start ) s , % ( page_len ) s """ .format(current_db_name, vehicle) % { ' txt ' : txt, ' start ' : start, ' page_len ' : page_len})
FROM { 0 } . ` tabVariant Mapping ` where vehicle = " {1} " and
( active_status like " %% %(txt)s %% " or vehicle_segment like " %% %(txt)s %% " or name like " %% %(txt)s %% " or
variant like " %% %(txt)s %% " or family_code like " %% %(txt)s %% " or fuel like " %% %(txt)s %% " or
transmission like " %% %(txt)s %% " ) order by modified desc limit % ( start ) s , % ( page_len ) s """ .format(
current_db_name , vehicle ) % { ' txt ' : txt , ' start ' : start , ' page_len ' : page_len } )
@frappe . whitelist ( )
@ -455,10 +508,12 @@ def update_procedure_value(name, file_path):
frappe . db . commit ( )
current_db_name = frappe . conf . get ( " db_name " )
# To validate updated procedure status
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,p.sub_system,
p . asset_category , p . item_category , p . variant , p . procedure_link , p . procedure_status , pro . name , pro . workflow_state
procedure_status = frappe . db . sql ( """ select p.name,p.update_procedure_status,pro.name,p.variant_mapping,p.system,
p . sub_system , p . asset_category , p . item_category , p . variant , p . procedure_link ,
p . procedure_status , pro . name , pro . workflow_state
from { 0 } . ` tabPublish_Docs ` as p , { 0 } . ` tabProcedure ` as pro where p . parent = " {1} " and
p . procedure_link = pro . name and p . procedure_link is not null """ .format(current_db_name, self.name), as_dict=1)
p . procedure_link = pro . name and p . procedure_link is not null """ .format(
current_db_name , self . name ) , as_dict = 1 )
# l = len(procedure_status)
if procedure_status :
@ -467,18 +522,23 @@ def update_procedure_value(name, file_path):
if y . procedure_link :
if x . procedure_link == y . procedure_link and y . update_procedure_status != y . procedure_status :
y . update_procedure_status = x . workflow_state
frappe . db . sql ( """ update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s ; """ , (
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . sql (
""" update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s ; """ ,
(
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . commit ( )
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status :
y . update_procedure_status = x . workflow_state
frappe . db . sql ( """ update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s """ , (
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . sql (
""" update `tabPublish_Docs` set update_procedure_status = %s where parent = %s and procedure_link = %s """ ,
(
x . workflow_state , self . name , x . procedure_link ) )
frappe . db . commit ( )
if y . procedure_status == " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and not y . excluded_global :
y . excluded_global = " 1 "
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
if x . procedure_link == y . procedure_link and x . workflow_state != y . procedure_status and \
x . workflow_state == " Draft " and y . procedure_status != " Publish Ready " :
y . excluded_internal = " 1 "
y . save ( )
frappe . db . commit ( )
@ -495,7 +555,7 @@ def update_procedure_value(name, file_path):
" User " , filters = { " name " : frappe . session . user } , fields = [ " username " ] )
if u_id :
for i in u_id :
name = i . user name
name = i . full_ name
if not self . published_by :
self . published_by = str ( name )
frappe . db . set_value (
@ -506,8 +566,7 @@ def update_procedure_value(name, file_path):
def update_feature_published_docs ( self ) :
try :
for d in self . feature_finder_publish :
for d in self . feature_finder_publish_docs :
frappe . db . sql (
""" UPDATE `tabFeature Finder` set is_published=1 where name= ' {0} ' """ . format ( d . parent1 ) )
frappe . db . commit ( )
@ -520,7 +579,6 @@ def update_repair_published_docs(self):
try :
for d in self . repair_checksheet_publish :
frappe . db . sql (
""" UPDATE `tabRepair Service Mapping` set published=1 where name= ' {0} ' """ . format ( d . parent_name ) )
frappe . db . commit ( )
@ -557,10 +615,11 @@ def get_service_repair(vehicle,
@frappe . whitelist ( )
def get_feature_finder ( vehicle , variant , language_label ) :
def get_feature_finder ( vehicle = None , variant = None , language_label = None ) :
try :
data = frappe . db . sql (
f """ select * from `tabFeature Finder` where vehicle= ' { vehicle } ' and variant_id= ' { variant } ' and language= ' { language_label } ' and is_published=0 """ , as_dict = 1 )
f """ select * from `tabFeature Finder` where vehicle= ' { vehicle } ' and variant_id= ' { variant } ' and language= ' { language_label } '
and is_published = 0 """ , as_dict=1)
return data
except Exception as e :
return str ( e )
@ -575,7 +634,8 @@ def repair_checksheet_publish(vehicle, vehicle_id,
logger . info (
f ' Repair Checksheet Started- { vehicle } - { language } - { publish_type } - { parent } ' )
folder_url = base_url + " / " + vehicle . replace ( ' ' , ' - ' ) + " / " + language
folder_url = base_url + " / " + \
vehicle . replace ( ' ' , ' - ' ) + " / " + language
logger . info ( f ' Created Folder- { vehicle } - { language } - { publish_type } ' )
''' Publish Ready Flags '''
@ -612,7 +672,7 @@ def repair_checksheet_publish(vehicle, vehicle_id,
repair_checksheet [ ' data ' ] [ 0 ] )
repair_checksheet_tmp = get_latest_data ( { ' data ' : published_data [ ' data ' ] } , {
' data ' : repair_checksheet_tmp } )
' data ' : repair_checksheet_tmp } )
else :
for i in parent :
@ -654,7 +714,8 @@ def feature_finder_publish(vehicle=None, vehicle_id=None,
logger . info (
f " start of fetching repair checksheet data - { vehicle } - { language } - { module_name } - { variant } " )
folder_url = base_url + " / " + vehicle . replace ( ' ' , ' - ' ) + " / " + language
folder_url = base_url + " / " + \
vehicle . replace ( ' ' , ' - ' ) + " / " + language
logger . info ( f ' Created Folder- { vehicle } - { language } - { publish_type } ' )
''' Final Json '''
@ -693,7 +754,6 @@ def feature_finder_publish(vehicle=None, vehicle_id=None,
feature_finder_tmp = get_latest_data (
{ ' data ' : published_data [ ' data ' ] } , { ' data ' : feature_finder_tmp } )
else :
@ -807,52 +867,59 @@ def feature_finder_data(vehicle=None, language=None,
f " start of fetching feature finder checksheet data - { vehicle } - { language } - { variant } - { module_name } " )
feature_finder_details = [ ]
if language == ' en ' :
feature_finder_details = frappe . db . sql ( f """ select ff.name,ff.vehicle,ff.vehicle_id,ff.variant,ff.variant_id,ff.language,
ff . features_names as feature_name , ff . feature_category , ff . display_order , ff . active_status ,
ffm . feature_pdf as pdf from ` tabFeature Finder ` ff left join ` tabFeature Finder Master ` ffm on
ff . features_names = ffm . feature_name
feature_finder_details = frappe . db . sql ( f """ select ff.name,ff.vehicle,ff.vehicle_id,ff.variant,ff.variant_id,
ff . language , ff . features_names as feature_name , ff . feature_category ,
ff . display_order , ff . active_status , ff m. feature_pdf as pdf from ` tabFeature Finder ` ff
left join ` tabFeature Finder Master ` ffm on ff . features_names = ffm . feature_name
where ff . vehicle = " THAR " and ffm . vehicle = " {vehicle} "
and ff . variant = " {variant} "
and ff . language = " {language} " and ffm . language = " {language} " and ff . name = " {parent} " ;
and ff . variant = " {variant} " and ff . language = " {language} " and
ffm . language = " {language} " and ff . name = " {parent} " ;
""" , as_dict=1)
logger . info ( feature_finder_details )
else :
feature_finder_details = frappe . db . sql ( f """ select ff.name,ff.vehicle,ff.vehicle_id,ff.variant,ff.variant_id,ff.language,
ff . translated_feature_name as feature_name , ff . feature_category ,
ff . display_order , ff . active_status , ffm . feature_pdf as pdf from ` tabFeature Finder ` ff
feature_finder_details = frappe . db . sql ( f """ select ff.name,ff.vehicle,ff.vehicle_id,ff.variant,ff.variant_id,
ff . language , ff . translated_feature_name as feature_name ,
ff . feature_category , ff . display_order , ff . active_status ,
ffm . feature_pdf as pdf from ` tabFeature Finder ` ff
left join ` tabFeature Finder Master ` ffm on ff . features_names = ffm . feature_name
where ff . vehicle = " {vehicle} " and ffm . vehicle = " {vehicle} " and ff . variant = " {variant} "
and ff . language = " {language} " and ff . name = " {parent} " ; """ , as_dict=1)
where ff . vehicle = " {vehicle} " and ffm . vehicle = " {vehicle} "
and ff . variant = " {variant} " and ff . language = " {language} "
and ff . name = " {parent} " ; """ , as_dict=1)
for f in feature_finder_details :
f [ ' disclaimer ' ] = frappe . db . sql ( f '''
SELECT name , content , active_status , idx as display_order FROM ` tabFeature Finder Disclaimer `
where parent = ' { str(f[ ' vehicle ' ])+ str( ' - ' )+ str(f[ ' feature_name ' ]) +str( ' - ' )+str(f[ ' language ' ])} ' ;
where parent = ' { str(f[ ' vehicle ' ]) + str( ' - ' ) + str(f[ ' feature_name ' ]) + str( ' - ' ) + str(f[ ' language ' ])} ' ;
''' , as_dict=1)
sop_images = frappe . db . sql ( f """ select image,display_order,active_status from `tabFeature Finder Images` where
parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ , as_dict=1)
parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ ,
as_dict = 1 )
sop_content = frappe . db . sql ( f """ select content,display_order, active_status from `tabFeature Finder Content`
where parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ , as_dict=1)
where parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ ,
as_dict = 1 )
sop_specification = frappe . db . sql ( f """ select specification,value,display_order,active_status from `tabFeature Finder Specification`
where parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ , as_dict=1)
where parent = ' {f['name']} ' and feature_type = ' SOP ' order by display_order desc ; """ ,
as_dict = 1 )
f [ ' sop ' ] = { ' content ' : sop_content , ' images ' : sop_images ,
' specificaton ' : sop_specification }
post_vin_data = frappe . db . sql ( f ''' select name,idx as display_order,post_vin_cutoff_name,post_vin_cutoff_id
from ` tabPost Vin Cutoff ID ` where parent = ' {f['name']} ' ; ''' , as_dict=1)
for p in post_vin_data :
vin_content = frappe . db . sql ( f """ select content,display_order, active_status from `tabFeature Finder Content`
where parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ , as_dict=1)
where parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ ,
as_dict = 1 )
vin_images = frappe . db . sql ( f """ select image,display_order,active_status from `tabFeature Finder Images` where
parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ , as_dict=1)
parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ ,
as_dict = 1 )
vin_specification = frappe . db . sql ( f """ select specification,value,display_order,active_status from `tabFeature Finder Specification`
where parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ , as_dict=1)
where parent = ' {f['name']} ' and post_vin_cutoff_name = ' {p['post_vin_cutoff_name']} ' order by display_order desc ; """ ,
as_dict = 1 )
p [ ' content ' ] = vin_content
p [ ' images ' ] = vin_images
p [ ' specificaton ' ] = vin_specification
@ -876,8 +943,9 @@ def feature_finder_data(vehicle=None, language=None,
@frappe . whitelist ( )
def max_publish_new_module ( doc ) :
doc = frappe . get_doc ( " Publish " , doc )
ver = frappe . db . sql ( """ select max(version) from {0} .tabPublish where vehicle = " {1} " and language = " {2} " and publish_module!= " Automotive System " ; """ . format (
current_db_name , doc . vehicle , doc . language ) )
ver = frappe . db . sql (
""" select max(version) from {0} .tabPublish where vehicle = " {1} " and language = " {2} " and publish_module!= " Automotive System " ; """ . format (
current_db_name , doc . vehicle , doc . language ) )
if ver :
return ver
@ -886,8 +954,9 @@ def max_publish_new_module(doc):
def cal_ver_new_module ( vehicle , lang , publish_type , doc ) :
current_db_name = frappe . conf . get ( " db_name " )
doc = frappe . get_doc ( " Publish " , doc )
ver = frappe . db . sql ( """ select max(version) from `tabPublish` where vehicle = " {vehi} " and language = " {lang} " and publish_module!= " Automotive System " ; """
. format ( vehi = vehicle , lang = lang ) )
ver = frappe . db . sql (
""" select max(version) from `tabPublish` where vehicle = " {vehi} " and language = " {lang} " and publish_module!= " Automotive System " ; """
. format ( vehi = vehicle , lang = lang ) )
v = 0.0
if publish_type == ' Global ' :
if ver [ 0 ] [ 0 ] == None :
