问XML组合文档

EN

<?xml version='1.0' encoding='UTF-8'?>
<EMPLEADOS>
  <EMPLEADO TIPO="A" NUMERO="123">
    <PROCESO PERIODO="201603" TT="MN" PAC="9999" />
    <SECCION ID="ETACIV">
      <CAMPO ID="ETA_ETCNOM" SEC=" " FECHA=" ">abc</CAMPO>
    </SECCION>
  </EMPLEADO>
</EMPLEADOS>

<?xml version='1.0' encoding='UTF-8'?>
<EMPLEADOS>
  <EMPLEADO TIPO="A" NUMERO="123">
    <PROCESO PERIODO="201603" TT="MN" PAC="9999" />
    <SECCION ID="SADMIN ">
      <CAMPO ID="SAD_SADESO" SEC=" " FECHA="01/03/2015">01/03/2015</CAMPO>
    </SECCION>
  </EMPLEADO>
</EMPLEADOS>

<?xml version='1.0' encoding='UTF-8'?>
<EMPLEADOS>
  <EMPLEADO TIPO="A" NUMERO="123">
    <PROCESO PERIODO="201603" TT="MN" PAC="9999" />
    <SECCION ID="SADMIN ">
      <CAMPO ID="SAD_SADESO" SEC=" " FECHA="01/06/2015">01/06/2015</CAMPO>
    </SECCION>
  </EMPLEADO>
</EMPLEADOS>

<?xml version='1.0' encoding='UTF-8'?>
<EMPLEADOS>
  <EMPLEADO TIPO="A" NUMERO="123">
    <PROCESO PERIODO="201603" TT="MN" PAC="9999" />
     <SECCION ID="ETACIV">
     <CAMPO ID="ETA_ETCNOM" SEC=" " FECHA=" ">abc</CAMPO>
     </SECCION>
     <SECCION ID="SADMIN ">
     <CAMPO ID="SAD_SADESO" SEC=" " FECHA="01/03/2015">01/03/2015</CAMPO>
     <CAMPO ID="SAD_SADESO" SEC=" " FECHA="01/06/2015">01/06/2015</CAMPO>
     </SECCION>
   </EMPLEADO>
</EMPLEADOS>

import java.util.Properties;
import java.io.InputStream;
import org.jdom.input.SAXBuilder;
import org.jdom.Document;
import org.jdom.Element;
import org.jdom.xpath.XPath;
import org.jdom.output.XMLOutputter;
import groovy.util.slurpersupport.GPathResult;
import groovy.xml.StreamingMarkupBuilder;


for( int i = 0; i < dataContext.getDataCount(); i++ ) {
  InputStream is = dataContext.getStream(i);
  Properties props = dataContext.getProperties(i);

def xs = new XmlSlurper()
def employee = xs.parse(is);
String Encod = "UTF-8" ;
HashMap<String, GPathResult> CampoMap = new HashMap<String, GPathResult>()

employee.EMPLEADOS.EMPLEADO.PROCESO.SECCION.CAMPO.each {
    CampoMap["${it.@ID}"] = it
}

new StreamingMarkupBuilder().bind {
     mkp.xmlDeclaration(["version":"1.0", "encoding":"UTF-8"]);
    EMPLEADOS {
        EMPLEADO.PROCESO.SECCION.each {
            if (CampoMap["${it.@ID}"] != null) {
                it.appendNode(CampoMap["${it.@id}"].sites)
            }
            out << it
        }
    }
} .writeTo(is.newWriter(Encod))
}
  dataContext.storeStream(is, props);

import groovy.util.XmlParser
import groovy.xml.MarkupBuilder

def parser = new XmlParser()
def writer = new StringWriter()
def builder = new MarkupBuilder(writer)

for( int i = 0; i < dataContext.getDataCount(); i++ ) {
  InputStream is = dataContext.getStream(i);
  Properties props = dataContext.getProperties(i);

def mergedDocument = (0..<dataContext.dataCount)
    .collect { XmlParser.parse(dataContext.getStream(it)) }
    .inject { nodeA, nodeB -> merge(nodeA, nodeB) }


builder.mkp.xmlDeclaration(version:'1.0', encoding:'UTF-8')
builder.EMPLEADOS {
    doc1.EMPLEADO.each { empleado ->
        EMPLEADO(empleado.attributes()) {
           empleado.PROCESO.each { proceso -> 
               PROCESO(proceso.attributes()) 
           }

           empleado.SECCION.each { seccion ->
               SECCION(seccion.attributes()) {
                   seccion.CAMPO.each { campo ->
                       CAMPO(campo.attributes(), campo.value().head())
                   }
               }
           }            
        }
    }
}
is = mergedDocument ;
}


/*
 * Category to simplify XML node comparisons.
 * Basically, two Nodes are equal if their attributes are the same.
 */
// class NodeCategory {
//    static boolean equals(Node me, Node other) {
//        me.attributes() == other.attributes()
//    }

//    static boolean isCase(List<Node> nodes, Node other) {
//      nodes.find { it == other } != null
//    }
//}

/*
 * Merges document b into document a.
 * WARNING: This method is destructive; it modifies document a
 * @Returns a, for convenience
 */
def merge(a, b) {
//    use(NodeCategory) {
        b.EMPLEADO.each { empleado ->
            def existingEmpleado = a.EMPLEADO.find { 
                it == empleado
            }

            if(existingEmpleado) {
                // Empleado already exists, must merge differences.

                // Add any missing PROCESO nodes.
                empleado.PROCESO
                   .findAll { !(it in existingEmpleado.PROCESO) }
                   .with {
                       delegate.each { existingEmpleado.append(it) }
                   }

                // Add any missing SECCION nodes.
                empleado.SECCION
                   .findAll { !(it in existingEmpleado.SECCION) }
                   .with {
                       delegate.each { existingEmpleado.append(it) }
                   }

                // Add any missing CAMPO nodes.
                empleado.SECCION.each { seccion ->
                    existingEmpleado.SECCION
                        .find { it == seccion }
                        .with {
                            seccion.CAMPO
                                .findAll { !(it in delegate.CAMPO) }
                                .each { delegate.append(it) }
                        }
                }
            } else {
                // Empleado does not exist, go ahead and add it as-is.
                a.append(empleado)
            }
        }    
 //   }

    return a
}