Zuordnen von benutzerdefinierten Feldern mithilfe der erweiterten Transaktionsdetailseitenpreise

global class ApexCustomFieldHandler implements RevSignaling.SignalingApexProcessor {

    public virtual class BaseException extends Exception {}
    public class OtherException extends BaseException {}
    
    public RevSignaling.TransactionResponse execute(RevSignaling.TransactionRequest request) {
        
        String contextId = request.ctxInstanceId;
        Context.IndustriesContext industriesContext = new Context.IndustriesContext();
        

        // STEP 2 - Query SalesTransactionItem nodes
        Map<String, Object> inputQueryItem = new Map<String, Object>{
            'contextId' => contextId,
            'tags' => new List<String>{ 'SalesTransactionItem', 'SalesTransactionItemDetail' }
        };
        Map<String, Object> itemQueryOutput = industriesContext.queryTags(inputQueryItem);
        Map<String, Object> itemQueryResult = (Map<String, Object>) itemQueryOutput.get('queryResult');
        List<Object> itemData = (List<Object>) itemQueryResult.get('SalesTransactionItem');
        List<Object> itemDetailData = (List<Object>) itemQueryResult.get('SalesTransactionItemDetail');


        Map<String, String> salesTransactionItemIdToCustomAggregatedValue = new Map<String, String>();
        
        // STEP 3 - Custom Field Value from SalesTransactionItemDetail
        for(Object itemDetailObj : itemDetailData) {
            Map<String, Object> itemDetailNode = (Map<String, Object>) itemDetailObj;
            Map<String, Object> detailTagMap = (Map<String, Object>) itemDetailNode.get('tagValue');
            
            String lineItemId = (String)((Map<String, Object>) detailTagMap.get('SalesTrxnItemDetailParent')).get('tagValue');
            String cfValue = (String)((Map<String, Object>) detailTagMap.get('STID_TenantName__c')).get('tagValue');
            
            System.debug('Custom Field Value for Detail Item' + cfValue);
            if(cfValue != null) {
                salesTransactionItemIdToCustomAggregatedValue.put(lineItemId, cfValue);
            }
        }


        // STEP 4 - Build update list
        List<Map<String, Object>> itemNodeUpdates = new List<Map<String, Object>>();

        for (Object itemObj : itemData) {
            Map<String, Object> itemNode = (Map<String, Object>) itemObj;
            Map<String, Object> tagMap = (Map<String, Object>) itemNode.get('tagValue');
            
            String lineItemId = (String)((Map<String, Object>) tagMap.get('LineItem')).get('tagValue');
            
            List<Object> dataPath = (List<Object>) itemNode.get('dataPath');

            dataPath.remove(0); // Remove contextId

            itemNodeUpdates.add(new Map<String, Object>{
                'nodePath' => new Map<String, Object>{ 'dataPath' => dataPath },
                'attributes' => new List<Object>{
                    new Map<String, Object>{
                        'attributeName' => 'STI_TenantName__c',
                        'attributeValue' => salesTransactionItemIdToCustomAggregatedValue.get(lineItemId)
                    }
                }
            });
        }

        // STEP 5 - Create collection context update
        if (!itemNodeUpdates.isEmpty()) {
            Map<String, Object> updateInput = new Map<String, Object>{
                'contextId' => contextId,
                'nodePathAndAttributes' => itemNodeUpdates
            };
            
            //Step 6 - Update context
            System.debug('--- PREHOOK: SUBMITTING CONTEXT UPDATE ---');
            System.debug(JSON.serializePretty(updateInput));
            industriesContext.updateContextAttributes(updateInput);
        }

        RevSignaling.TransactionResponse response = new RevSignaling.TransactionResponse();
        response.status = RevSignaling.TransactionStatus.SUCCESS;
        return response;
    }
}