Content Comparison

for row in df_payload.rdd.collect():
    
     payload_retorno_s4_chamada_json["rotationHeader"]["shippingConditions"]hana_interno = row["SHIP_COND"]payload_retorno_s4_hana
    
    
   payload_chamada_json["rotationHeader"]["sdDocumentCurrency"] = if row["CURRENCYDOC_TYPE"] == 'ZDX - Venda Normal':
        payload_chamada_json["rotationHeaderschedule"]["Item"]["salesOrganizationsalesDocumentItem"] = row["SALESITM_ORGNUMBER"]
        payload_chamada_json["rotationHeaderschedule"]["salesOfficeItem"] = row["SALES_OFFscheduleLineDate"] = today
        payload_chamada_json["rotationHeader"]["salesGrouptermsOfPaymentKey"] = row["SALES_GRPPMNTTRMS"]
        payload_chamada_json["rotationHeader"]["salesDocumentTypeshippingConditions"] = row["DOCSHIP_TYPECOND"]
        payload_chamada_json["rotationHeader"]["salesDistrictsdDocumentCurrency"] = row["SALES_DISTCURRENCY"]
        payload_chamada_json["rotationHeader"]["priceListTypesalesOrganization"] = row["PRICESALES_LISTORG"]
        payload_chamada_json["rotationHeader"]["incotermsPart2salesOffice"] = row["INCOTERMS2SALES_OFF"]
        payload_chamada_json["rotationHeader"]["incotermsPart1salesGroup"] = row["INCOTERMS1SALES_GRP"]
        payload_chamada_json["rotationHeader"]["divisionsalesDocumentType"] = row["DIVISIONDOC_TYPE"]
        payload_chamada_json["rotationHeader"]["distributionChannelsalesDistrict"] = row["DISTRSALES_CHANDIST"]
        payload_chamada_json["rotationHeader"]["customerGrouppriceListType"] = row["CUSTPRICE_GROUPLIST"]
        payload_chamada_json["rotationHeader"]["cupincotermsPart2"] = row["cupINCOTERMS2"]
        payload_chamada_json["quotePartnersrotationHeader"]["Item"]["partnerFunctionincotermsPart1"] = row["INCOTERMS1"]
        payload_chamada_json["rotationHeader"]["division"] = row["PARTN_ROLEDIVISION"]
        payload_chamada_json["quotePartnersrotationHeader"]["ItemdistributionChannel"]["customerNumber"] = row["PARTNDISTR_NUMBCHAN"]
        payload_chamada_json["quoteItemsrotationHeader"]["ItemcustomerGroup"]["salesDocumentItem"] = row["ITMCUST_NUMBERGROUP"]
        payload_chamada_json["quoteItemsrotationHeader"]["Itemcup"]["plant"] = row["PLANTcup"]
        payload_chamada_json["quoteItemsquotePartners"]["Item"]["materialNumberpartnerFunction"] = row["MATERIALPARTN_ROLE"]
        payload_chamada_json["guuid"quotePartners"]["Item"]["customerNumber"] = row["uuidPARTN_NUMB"]

        payload_chamada_str = json.dumps(payload_chamada_json)

json["quoteItems"]["Item"]["salesDocumentItem"] = row["ITM_NUMBER"]
       payload_saida = chamada_simulate_api(payload_chamada_str)
json["quoteItems"]["Item"]["plant"] = row["PLANT"]
        payload_retorno_str = payload_saida.text
    chamada_json["quoteItems"]["Item"]["materialNumber"] = row["MATERIAL"]
             if (payload_retornochamada_str[:5json["guuid"] == row["<?xml"):uuid"]

           payload_retornochamada_str = json.dumps(payload_chamada_retornojson)

        payload_saida = chamada_simulate_api(payload_chamada_str)

        payload_retorno_str = payload_retorno_str.replace("Sem Erros!", "ERRO: Retorno enviado em XML!")saida.text
        

        if (payload_retorno_str[:5] = payload_retorno_str[:-1]= "<?xml"):
            payload_retorno_str = payload_retorno_str[1
            payload_retorno_str = payload_retorno_str.replace("Sem Erros!", "ERRO: Retorno enviado em XML!")
            payload_retorno_str = payload_retorno_str[:-1]
            payload_retorno_str = payload_retorno_str[1:]
            payload_chamada_str = payload_chamada_str[:-1]
        else : 
            payload_chamada_str = payload_chamada_str[:-1]
            payload_retorno_str = payload_retorno_str[:-2]
            payload_retorno_str = payload_retorno_str[2:]

        merge_json = payload_chamada_str +","+ payload_retorno_str + "}"
        print(merge_json)
        payload_gravar = json.loads(merge_json)
        print(payload_gravar)

        if (payload_gravar["quoteConditions"][0]["otherCosts"] == "NULL" or 
            payload_gravar["quoteConditions"][0]["otherCosts"] == "null" or 
            payload_gravar["quoteConditions"][0]["otherCosts"] == None
           ):
            payload_gravar["quoteConditions"][0]["otherCosts"] = 0.0

        if (payload_gravar["quoteConditions"][0]["valueTaxSubstitutionTributary"] == "NULL" or 
            payload_gravar["quoteConditions"][0]["valueTaxSubstitutionTributary"] == "null"  or 
            payload_gravar["quoteConditions"][0]["valueTaxSubstitutionTributary"] == None
           ):
            payload_gravar["quoteConditions"][0]["valueTaxSubstitutionTributary"] = 0.0

        if (payload_gravar["quoteConditions"][0]["commercialCost"] == "NULL" or 
            payload_gravar["quoteConditions"][0]["commercialCost"] == "null"  or 
            payload_gravar["quoteConditions"][0]["commercialCost"] == None
           ):
            payload_gravar["quoteConditions"][0]["commercialCost"] = 0.0

        if (payload_gravar["quoteConditions"][0]["manufacturingCost"] == "NULL" or 
            payload_gravar["quoteConditions"][0]["manufacturingCost"] == "null"  or 
            payload_gravar["quoteConditions"][0]["manufacturingCost"] == None
           ):
            payload_gravar["quoteConditions"][0]["manufacturingCost"] = 0.0

        if (payload_gravar["quoteConditions"][0]["valueAdditionalSale"] == "NULL" or 
            payload_gravar["quoteConditions"][0]["valueAdditionalSale"] == "null"  or 
            payload_gravar["quoteConditions"][0]["valueAdditionalSale"] == None
           ):
            payload_gravar["quoteConditions"][0]["valueAdditionalSale"] = 0.0

        if (len(payload_gravar["quotationItems"]) != 0):
            payload_gravar["sapReturn"] = payload_retorno_json["sapReturn"]

        if (len(payload_gravar["quotationItems"]) == 0):
            payload_gravar["quotationItems"] = payload_retorno_json["quotationItems"]
            payload_gravar["quoteConditions"] = payload_retorno_json["quoteConditions"]

        jsonData = json.dumps(payload_gravar)
        print(jsonData)

        jsonDataList = []
        jsonDataList.append(jsonData)

        jsonRDD = sc.parallelize(jsonDataList)
        df = spark.read.json(jsonRDD)

        df.write.format("delta").mode("append").saveAsTable(simulate_table_name)