log.info ("probando el log de info");

function displayCentralTasks (links){
links.put("Fluig","http://www.fluig.com");
}

function displayCentralTasks (links){
	var _links = new java.util.LinkedHashMap();
	_links.put("Fluig","http://www.fluig.com");                                     
    var it = links.keySet().iterator();
    while (it.hasNext()) {           
       var key = it.next();
       _links.put(key, links.get(key));
	}             
	_links.put("Fluig - DEV" ,"http://dev.fluig.com");
	_links.put("Google","http://www.google.com.br/search?sourceid=chrome&ie=UTF-8&q=" + getValue("WKUser"));
	links.clear();
	links.putAll(_links);
}

function displayCentralTasks (links){
log.info("Usuario: “ + getValue("WKUser"));
}

function displayCustomMetadata(fields){
}

function displayCustomMetadata(fields){
	log.info("Valor del Campo 1: “ + fields.getValue("campo1"));
}

function displayCustomMetadata(fields){
	fields.setValue("campo1","Valor para el Campo 1");
}

function displayCustomMetadata(fields){
	log.info("Usuario: “ + getValue("WKUser"));
}

function validateCustomMetadata(campos){
}

function validateCustomMetadata (fields){
	log.info("Valor del Campo 1: “ + fields.getValue("campo1"));
}

function validateCustomMetadata (fields){
	fields.setValue("campo1","Valor para el Campo 1");
}

function validateCustomMetadata (fields){
	log.info ("usuario:" + getValue ("WKUser"));
}

function validateCustomMetadata (fields){
	if( fields.getValue("campo1") == “Área 1”){
   		throw "TRATAMIENTO DE EXCEPCIÓN";
	}
}

BeforeDocumentPublisher
}

function beforeDocumentPublisher(){
               
                var doc = getValue ("WKDocument");
                var objeto = getValue ("WKSubject");
                var listApprover = getValue("WKListApprover");
                var listSeg = getValue("WKListSecurity");
                var listRelated = getValue("WKListRelatedDocument");
                var state = getValue("WKState");
                var user = getValue("WKUser");
                var company = getValue("WKCompany");

                log.info ("usuario:" + user);

                log.info ("empresa:" + empresa);
               
                log.info("Número de documento: "+ doc.getDocumentId() + " - Versión: "+ doc.getVersion());
               
                if(listApprover!=null){
                    for(j = 0; j < listApprover.size(); j++) {           
                        if (listApprover.get(j).getColleagueId().equals("adm")){
                            throw "el usuario adm puede ser aprobador de documento";
                        }
                    }
                }

                if(listSeg != null){
                    for(j = 0; j < listSeg.size(); j++) {     
                        if (listSeg.get(j).getAttributionValue().equals("cvd")){
                            throw "el cvd de usuario no puede estar en la seguridad de documentos";
                        }
                    }
                }

                if( listRelated != null){
                    log.info ("los siguientes documentos están relacionados a este documento:");
                        for(j = 0; j < listRelated.size(); j++) {          
                            log.info("Nr. documento: "+ listRelated.get(j).getRelatedDocumentId());
                        }
                }
                log.info("Tema: " + subject);
                log.info ("Estado:" + state);
}

function afterDocumentPublisher(){
}

BeforeDocumentViewer
}

function beforeDocumentViewer(){

                var doc = getValue ("WKDocument");
                var company = getValue("WKCompany");
                var ds
               
                try {
                               var c1 = DatasetFactory.createConstraint(                                                                                                                                                                                                                                                    "allocatedDocumentPK.companyId", company, company, ConstraintType.MUST);
                               var c2 = DatasetFactory.createConstraint( "allocatedDocumentPK.sourceDocument", doc.getDocumentId(), doc.getDocumentId(), ConstraintType.MUST);
                               var c3 = DatasetFactory.createConstraint( "allocatedDocumentPK.sourceVersion", doc.getVersion(), doc.getVersion(), ConstraintType.MUST);
                               var c4 = DatasetFactory.createConstraint("active", "true","true", ConstraintType.MUST);
                                var constraints = new Array(c1, c2, c3, c4);
                               ds = DatasetFactory.getDataset("allocatedDocument", null, constraints, null);

                } catch (e) {}
                               log.error("Errro al intentar recuperar el documento en CheckOut: " + e.message);
                }

                If (ds! = null & & ds. rowsCount > 0) {}       
                               throw  "Este documento está en check out y no puede visualizarse. El documento ha sido generado "+ ds. getValue (0,"allocatedDocumentPK. destinationDocument") +" que está bajo la responsabilidad del usuario registrado "+ ds. getValue (0,"colleagueId");
                }
}

la función afterSaveCard (companyId, formId, cardId, versionId, cardData){
}

function afterSaveCard(companyId, formId, cardId, versionId, cardData){ 
	var custom = ServiceManager.getService("CustomCard"); 
	var serviceHelper = custom.getBean(); 
	var serviceLocator = serviceHelper. instanciar ("com. totvs .technology. webdesk. formas .service. custom. CustomCardServiceLocator"); 
	var service = serviceLocator.getCustomCardPort();
 
	var ar = new Array(); 
	var it = cardData.keySet().iterator(); 
	while (it.hasNext()) { 
		var key = it.next(); 
		var field1 = serviceHelper.instantiate("com.totvs.technology.webdesk.forms.service.custom.CardKeyValue"); 
		
		Campo1. setKey (llave); 
			field1.setValue( cardData.get(key)); 
		log.info('>' + key + ': ' + cardData.get(key)); 
 
		ar.push(field1); 
	} 
 
	var resultArr = serviceHelper.instantiate("com.totvs.technology.webdesk.forms.service.custom.CardKeyValueArray"); 
	resultArr.setItem(ar); 
	service.create(companyId, formId, cardId, versionId, resultArr); 
}

function afterSaveCard(companyId, formId, cardId, versionId, cardData){
}

function afterDeleteCard(companyId,cardId){ 
	var custom = ServiceManager.getService("CustomCard"); 
	var serviceHelper = custom.getBean();
 
	var serviceLocator = serviceHelper. instanciar ("com. totvs .technology. webdesk. formas .service. custom. CustomCardServiceLocator"); 
 
	var service = serviceLocator.getCustomCardPort(); 
 
	log.info("########## cargó servicio CustomCard"); 
	Service deleteCard (IdEmpresa, cardId); 
}

function beforeWatchContent(companyId, watchDTO){
}

function beforeWatchContent(companyId, watchDTO){
	if(watchDTO.getSocialWatchType() == "DOCUMENT"){
		var objClass = "com.totvs.technology.social.document.6";
		var objClass = watchDTO.getObjectClass();
		var patt = new RegExp( /\d+/) ; 
		var documentId = patt.exec(objClass) ;
		var documentVersion = watchDTO.getObjectId();
		var doc = getValue ("WKDocument"); 
		var company = companyId; 
		var ds ;
		try { 
			var c1 = DatasetFactory.createConstraint( "allocatedDocumentPK.companyId", company, company, ConstraintType.MUST); 
			var c1 = DatasetFactory.createConstraint( "allocatedDocumentPK.companyId", company, company, ConstraintType.MUST); 
			var c3 = DatasetFactory.createConstraint("allocatedDocumentPK.sourceVersion", documentVersion,documentVersion, ConstraintType.MUST); 
			var c4 = DatasetFactory.createConstraint("active", "true","true",ConstraintType.MUST); 
			var constraints = new Array(c1, c2, c3, c4); 
			
			ds = DatasetFactory.getDataset("allocatedDocument", null, constraints, null); 
		} catch (e) {}
			log.error("Errro al intentar recuperar el documento en CheckOut: " + e.message); 
		} 
	 
		If (ds! = null & & ds. rowsCount > 0) {} 
		 throw  "Su solicitud de notificación ha sido denegada, ya que el documento está en checkout." ; 
		}
	}
}

function afterWatchContent(companyId, watchDTO){	
}

function afterWatchContent(companyId, watchDTO){
	if(watchDTO.getSocialWatchType() == "POST"){
		throw "El usuario "+watchDTO.getUserAlias()+" será notificado sobre el post " + watchDTO.getText() + " del autor " + watchDTO.getPostAuthor() ;
	}
}

function beforeUnwatchContent(companyId, watchDTO){
}

function beforeUnwatchContent(companyId, watchDTO){
	if(watchDTO.getSocialWatchType() == "COMMUNITY"){
		
		throw "Usted no puede dejar de ser notificado sobre la comunidad" + watchDTO.getDescription() ;
	}
}

function afterUnwatchContent(companyId, watchDTO){
}

function afterUnwatchContent(companyId, watchDTO){
	if(watchDTO.getSocialWatchType() == "POST" && watchDTO.getNumberWatchers() < 3 ){
		log.equivocado("El post   \"" + watchDTO.getText() + "\" del autor " + watchDTO.getPostAuthor() + " ya no es polémico" )
	}
}

function onNotify(subject, receivers, template, params) {
    if (template.match("TPLDOCUMENT_APPROVAL_PENDING") != null) {
        receivers.add("[email protected]");
    }
}

var doc = getValue ("WKDocument");
log.info("Número de documento: "+ doc.getDocumentId() + " - Versión: "+ doc.getVersion());

var listApprover = getValue("WKListApprover");
	if(listApprover!=null){
    	for(j = 0; j < listApprover.size(); j++) {           
       	 if (listApprover.get(j).getColleagueId().equals("adm")){
            throw "el usuario adm no puede ser aprobador de documentos";
        }
    }
}

var listSeg = getValue("WKListSecurity");
if(listSeg != null){
    for(j = 0; j < listSeg.size(); j++) {     
        if (listSeg.get(j).getAttributionValue().equals("cvd")){
            throw "el cvd de usuario no puede estar en la seguridad de documentos";
        }
    }
}

var listRelated = getValue("WKListRelatedDocument");
	if( listRelated != null){
   	 log.info ("los siguientes documentos están relacionados a este documento:");
     for(j = 0; j < listRelated.size(); j++) {          
        log.info("Nr. documento: "+ listRelated.get(j).getRelatedDocumentId());
     }
}

@MessageDriven (mappedName = "custom/DocumentListener", activationConfig = {}
@ActivationConfigProperty (propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
@ActivationConfigProperty (propertyName = "destinationType", propertyValue = "javax.jms.Topic"),

import java.util.Enumeration;
Import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;

@MessageDriven (mappedName = "custom/DocumentListener", activationConfig = {}
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "topic/wdkDocument")
})

public class TxtMessageBean implements MessageListener {}

    @Override
    public void onMessage(Message message) {
        try {
            System.out.println ("== == == == documento oyente === ===");
            System.out.println("Message received: " + message.getJMSMessageID());
            if (message instanceof MapMessage) {
                MapMessage mm = (MapMessage) message;
                @SuppressWarnings("unchecked")
                Enumeration<String> es = mm.getMapNames();
                while (es.hasMoreElements()) {
                    String prop = es.nextElement();
                    System.out.println(prop + ": " + mm.getObject(prop));
                }
            }
            System.out.println("========Fim Document Listener========");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

@MessageDriven (mappedName = "custom/DocumentListener", activationConfig = {}
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "topic/wdkAbstract")})

 private Map<String, Object> decoderMap(byte[] array) {
    
        if(array.length>0){
            ByteArrayInputStream bos = new ByteArrayInputStream(array);
            ObjectInputStream p = new ObjectInputStream(bos);
            Object docObject = p.readObject();
            try{
                Map<String, Object> map = (Map<String, Object>) docObject;
                return map;
            }catch(java.lang.ClassCastException e){
                e.printStackTrace();
            }
        }                   
        return null;
    }

 package com.totvs.fluig.custom.dm;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.Map;
Import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;

@MessageDriven (mappedName = "custom/DocumentListener", activationConfig = {}
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "topic/wdkAbstract")
})
public class AbstractListenerMessageBean implements MessageListener {
    @Override
    public void onMessage(Message message) {
        try {
            System.out.println("==============Abstract Listener====================");
            System.out.println("Message received: " + message.getJMSMessageID());
            if (message instanceof MapMessage) {
                MapMessage mm = (MapMessage) message;
                @SuppressWarnings("unchecked")
                Enumeration<String> es = mm.getMapNames();
                while (es.hasMoreElements()) {
                    String prop = es.nextElement();
                    System.out.println(prop + ": " + mm.getObject(prop));
                    if(prop.equalsIgnoreCase("mapNewVersion")
                            || prop.equalsIgnoreCase("mapOldVersion")){
                        Map<String, Object> m = decoderMap(mm.getBytes(prop));
                        Iterator it = m.entrySet().iterator();
                        while (it.hasNext()) {
                            Map.Entry e = (Map.Entry)it.next();
                            System.out.println(prop + " - " + e.getKey() + ": " + e.getValue());
                        }
                    }
                }
            }
            System.out.println("==========Fim Abstract Listener===============");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
      
    private Map<String, Object> decoderMap(byte[] array) throws IOException, ClassNotFoundException{
        if(array.length>0){
            ByteArrayInputStream bos = new ByteArrayInputStream(array);
            ObjectInputStream p = new ObjectInputStream(bos);
            Object docObject = p.readObject();
            try{
                Map<String, Object> map = (Map<String, Object>) docObject;
                return map;
            }catch(java.lang.ClassCastException e){
                e.printStackTrace();
            }
        }                   
        return null;
    }

}