PMC-885

database/factories/DynaformFactory.php

@@ -4,16 +4,18 @@
  * Model factory for a dynaform.
  */
 use Faker\Generator as Faker;
+use ProcessMaker\Model\Dynaform;
+use ProcessMaker\Model\Process;
 
-$factory->define(\ProcessMaker\Model\Dynaform::class, function(Faker $faker) {
+$factory->define(Dynaform::class, function(Faker $faker) {
     $date = $faker->dateTime();
     return [
         'DYN_UID' => G::generateUniqueID(),
-        'DYN_ID' => '',
+        'DYN_ID' => $faker->unique()->numberBetween(1, 10000),
-        'DYN_TITLE' => '',
+        'DYN_TITLE' => $faker->sentence(2),
-        'DYN_DESCRIPTION' => '',
+        'DYN_DESCRIPTION' => $faker->sentence(5),
         'PRO_UID' => function() {
-            $process = factory(\ProcessMaker\Model\Process::class)->create();
+            $process = factory(Process::class)->create();
             return $process->PRO_UID;
         },
         'DYN_TYPE' => 'xmlform',

database/factories/InputDocumentFactory.php

@@ -0,0 +1,30 @@
+<?php
+
+/**
+ * Model factory for a input document.
+ */
+use Faker\Generator as Faker;
+use ProcessMaker\Model\InputDocument;
+use ProcessMaker\Model\Process;
+
+$factory->define(InputDocument::class, function(Faker $faker) {
+    return [
+        'INP_DOC_UID' => G::generateUniqueID(),
+        'INP_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+        'PRO_UID' => function() {
+            $process = factory(Process::class)->create();
+            return $process->PRO_UID;
+        },
+        'INP_DOC_TITLE' => $faker->sentence(2),
+        'INP_DOC_DESCRIPTION' => $faker->sentence(10),
+        'INP_DOC_FORM_NEEDED' => 'VIRTUAL',
+        'INP_DOC_ORIGINAL' => 'ORIGINAL',
+        'INP_DOC_PUBLISHED' => 'PRIVATE',
+        'INP_DOC_VERSIONING' => 0,
+        'INP_DOC_DESTINATION_PATH' => '',
+        'INP_DOC_TAGS' => 'INPUT',
+        'INP_DOC_TYPE_FILE' => '.*',
+        'INP_DOC_MAX_FILESIZE' => 0,
+        'INP_DOC_MAX_FILESIZE_UNIT' => 'KB'
+    ];
+});

database/factories/OutputDocumentFactory.php

@@ -0,0 +1,43 @@
+<?php
+
+/**
+ * Model factory for a output document.
+ */
+use Faker\Generator as Faker;
+use ProcessMaker\Model\OutputDocument;
+use ProcessMaker\Model\Process;
+
+$factory->define(OutputDocument::class, function(Faker $faker) {
+    $date = $faker->dateTime();
+    return [
+        'OUT_DOC_UID' => G::generateUniqueID(),
+        'OUT_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+        'OUT_DOC_TITLE' => $faker->sentence(2),
+        'OUT_DOC_DESCRIPTION' => $faker->sentence(10),
+        'OUT_DOC_FILENAME' => $faker->sentence(2),
+        'OUT_DOC_TEMPLATE' => '',
+        'PRO_UID' => function() {
+            $process = factory(Process::class)->create();
+            return $process->PRO_UID;
+        },
+        'OUT_DOC_REPORT_GENERATOR' => 'TCPDF',
+        'OUT_DOC_LANDSCAPE' => 0,
+        'OUT_DOC_MEDIA' => 'Letter',
+        'OUT_DOC_LEFT_MARGIN' => 20,
+        'OUT_DOC_RIGHT_MARGIN' => 20,
+        'OUT_DOC_TOP_MARGIN' => 20,
+        'OUT_DOC_BOTTOM_MARGIN' => 20,
+        'OUT_DOC_GENERATE' => 'BOTH',
+        'OUT_DOC_TYPE' => 'HTML',
+        'OUT_DOC_CURRENT_REVISION' => 0,
+        'OUT_DOC_FIELD_MAPPING' => '',
+        'OUT_DOC_VERSIONING' => 1,
+        'OUT_DOC_DESTINATION_PATH' => '',
+        'OUT_DOC_TAGS' => '',
+        'OUT_DOC_PDF_SECURITY_ENABLED' => 0,
+        'OUT_DOC_PDF_SECURITY_OPEN_PASSWORD' => '',
+        'OUT_DOC_PDF_SECURITY_OWNER_PASSWORD' => '',
+        'OUT_DOC_PDF_SECURITY_PERMISSIONS' => '',
+        'OUT_DOC_OPEN_TYPE' => 1
+    ];
+});

tests/unit/workflow/engine/classes/ProcessesTest.php

@@ -0,0 +1,419 @@
+<?php
+
+namespace Tests\unit\workflow\engine\classes;
+
+use Faker\Factory;
+use G;
+use Processes;
+use ProcessMaker\Model\Dynaform;
+use ProcessMaker\Model\InputDocument;
+use ProcessMaker\Model\OutputDocument;
+use ProcessMaker\Model\Process;
+use Tests\TestCase;
+
+class ProcessesTest extends TestCase
+{
+
+    /**
+     * This is using instead of DatabaseTransactions
+     * @todo DatabaseTransactions is having conflicts with propel
+     */
+    protected function setUp()
+    {
+        
+    }
+
+    /**
+     * Sort array of array by column.
+     * @param array $data
+     * @param string $columnName
+     */
+    public function sortArrayByColumn(&$data, $columnName)
+    {
+        usort($data, function($a, $b) use($columnName) {
+            return strnatcmp($a[$columnName], $b[$columnName]);
+        });
+    }
+
+    /**
+     * This checks if the returned dynaforms are correct with the different parameters.
+     * @test
+     * @covers \Processes::getDynaformRows()
+     */
+    public function it_should_return_dynaforms()
+    {
+        $process = factory(Process::class)->create()->first();
+        $proUid = $process->PRO_UID;
+
+        $dynaforms = factory(Dynaform::class, 6)
+                ->create([
+                    'PRO_UID' => $proUid
+                ])
+                ->sortBy('DYN_UID')
+                ->values();
+
+        //test with parameter false
+        $expected = $dynaforms->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getDynaformRows($proUid, false);
+        $this->sortArrayByColumn($actual, 'DYN_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //by default the method getDynaformRows removed DYN_ID column
+        $dynaforms->transform(function($item, $key) {
+            unset($item->DYN_ID);
+            return $item;
+        });
+
+        //test with parameter default
+        $expected = $dynaforms->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getDynaformRows($proUid);
+        $this->sortArrayByColumn($actual, 'DYN_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //test with parameter true
+        $expected = $dynaforms->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getDynaformRows($proUid, true);
+        $this->sortArrayByColumn($actual, 'DYN_UID');
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    /**
+     * This check if the returned input documents are correct with the different 
+     * parameters.
+     * @test
+     * @covers \Processes::getInputRows()
+     */
+    public function it_should_return_input_documents()
+    {
+        $process = factory(Process::class)->create()->first();
+        $proUid = $process->PRO_UID;
+
+        $inputDocument = factory(InputDocument::class, 6)
+                ->create([
+                    'PRO_UID' => $proUid
+                ])
+                ->sortBy('INP_DOC_UID')
+                ->values();
+
+        //test with parameter false
+        $expected = $inputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getInputRows($proUid, false);
+        $this->sortArrayByColumn($actual, 'INP_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //by default the mnethod getInputRows removed INP_DOC_ID column
+        $inputDocument->transform(function($item, $key) {
+            unset($item->INP_DOC_ID);
+            return $item;
+        });
+
+        //test with parameter default
+        $expected = $inputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getInputRows($proUid);
+        $this->sortArrayByColumn($actual, 'INP_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //test with the parameter true
+        $expected = $inputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getInputRows($proUid, true);
+        $this->sortArrayByColumn($actual, 'INP_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    /**
+     * This checks fi the returned output documents are correct with the differect 
+     * parameters.
+     * @test
+     * @covers Processes::getOutputRows()
+     */
+    public function it_should_return_output_documents()
+    {
+        $process = factory(Process::class)->create()->first();
+        $proUid = $process->PRO_UID;
+
+        $outputDocument = factory(OutputDocument::class, 6)
+                ->create([
+                    'PRO_UID' => $proUid
+                ])
+                ->sortBy('OUT_DOC_UID')
+                ->values();
+
+        //test with parameter false
+        $expected = $outputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getOutputRows($proUid, false);
+        $this->sortArrayByColumn($actual, 'OUT_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //by default the method getOutoutRows removed OUT_DOC_ID column
+        $outputDocument->transform(function($item, $key) {
+            unset($item->OUT_DOC_ID);
+            return $item;
+        });
+
+        //test with parameter default
+        $expected = $outputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getOutputRows($proUid);
+        $this->sortArrayByColumn($actual, 'OUT_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+
+        //test with parameter true
+        $expected = $outputDocument->toArray();
+
+        $processes = new Processes();
+        $actual = $processes->getOutputRows($proUid, true);
+        $this->sortArrayByColumn($actual, 'OUT_DOC_UID');
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    /**
+     * This checks if the dynaforms structure is saved with the different parameters.
+     * @test
+     * @covers Processes::createDynaformRows()
+     */
+    public function it_sholud_create_dynaform()
+    {
+        $faker = Factory::create();
+        $date = $faker->datetime();
+        $proUid = G::generateUniqueID();
+        $expected = [
+            [
+                'DYN_ID' => $faker->unique()->numberBetween(1, 10000000),
+                'DYN_UID' => G::generateUniqueID(),
+                'DYN_TITLE' => $faker->sentence(2),
+                'DYN_DESCRIPTION' => $faker->sentence(5),
+                'PRO_UID' => $proUid,
+                'DYN_TYPE' => 'xmlform',
+                'DYN_FILENAME' => '',
+                'DYN_CONTENT' => '',
+                'DYN_LABEL' => '',
+                'DYN_VERSION' => 2,
+                'DYN_UPDATE_DATE' => $date->format('Y-m-d H:i:s'),
+                '__DYN_ID_UPDATE__' => false,
+            ],
+            [
+                'DYN_ID' => $faker->unique()->numberBetween(1, 10000000),
+                'DYN_UID' => G::generateUniqueID(),
+                'DYN_TITLE' => $faker->sentence(2),
+                'DYN_DESCRIPTION' => $faker->sentence(5),
+                'PRO_UID' => $proUid,
+                'DYN_TYPE' => 'xmlform',
+                'DYN_FILENAME' => '',
+                'DYN_CONTENT' => '',
+                'DYN_LABEL' => '',
+                'DYN_VERSION' => 2,
+                'DYN_UPDATE_DATE' => $date->format('Y-m-d H:i:s'),
+                '__DYN_ID_UPDATE__' => false,
+            ],
+        ];
+        $this->sortArrayByColumn($expected, 'DYN_UID');
+
+        $processes = new Processes();
+        $processes->createDynaformRows($expected);
+        foreach ($expected as &$value) {
+            ksort($value);
+            unset($value['__DYN_ID_UPDATE__']);
+        }
+
+        $dynaforms = Dynaform::getByProUid($proUid)
+                ->sortBy('DYN_UID')
+                ->values();
+        $dynaforms->transform(function($item, $key) {
+            return (array) $item;
+        });
+        $actual = $dynaforms->toArray();
+        foreach ($actual as $value) {
+            ksort($value);
+        }
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    /**
+     * This checks if the input documents structure is saved with the different 
+     * parameters.
+     * @test
+     * @covers Processes::createInputRows()
+     */
+    public function it_should_create_input_document()
+    {
+        $faker = Factory::create();
+        $date = $faker->datetime();
+        $proUid = G::generateUniqueID();
+        $expected = [
+            [
+                'INP_DOC_UID' => G::generateUniqueID(),
+                'INP_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+                'PRO_UID' => $proUid,
+                'INP_DOC_TITLE' => $faker->sentence(2),
+                'INP_DOC_DESCRIPTION' => $faker->sentence(10),
+                'INP_DOC_FORM_NEEDED' => 'VIRTUAL',
+                'INP_DOC_ORIGINAL' => 'ORIGINAL',
+                'INP_DOC_PUBLISHED' => 'PRIVATE',
+                'INP_DOC_VERSIONING' => 0,
+                'INP_DOC_DESTINATION_PATH' => '',
+                'INP_DOC_TAGS' => 'INPUT',
+                'INP_DOC_TYPE_FILE' => '.*',
+                'INP_DOC_MAX_FILESIZE' => 0,
+                'INP_DOC_MAX_FILESIZE_UNIT' => 'KB',
+                '__INP_DOC_ID_UPDATE__' => false,
+            ],
+            [
+                'INP_DOC_UID' => G::generateUniqueID(),
+                'INP_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+                'PRO_UID' => $proUid,
+                'INP_DOC_TITLE' => $faker->sentence(2),
+                'INP_DOC_DESCRIPTION' => $faker->sentence(10),
+                'INP_DOC_FORM_NEEDED' => 'VIRTUAL',
+                'INP_DOC_ORIGINAL' => 'ORIGINAL',
+                'INP_DOC_PUBLISHED' => 'PRIVATE',
+                'INP_DOC_VERSIONING' => 0,
+                'INP_DOC_DESTINATION_PATH' => '',
+                'INP_DOC_TAGS' => 'INPUT',
+                'INP_DOC_TYPE_FILE' => '.*',
+                'INP_DOC_MAX_FILESIZE' => 0,
+                'INP_DOC_MAX_FILESIZE_UNIT' => 'KB',
+                '__INP_DOC_ID_UPDATE__' => false,
+            ],
+        ];
+        $this->sortArrayByColumn($expected, 'INP_DOC_UID');
+
+        $processes = new Processes();
+        $processes->createInputRows($expected);
+        foreach ($expected as &$value) {
+            ksort($value);
+            unset($value['__INP_DOC_ID_UPDATE__']);
+        }
+
+        $inputDocuments = InputDocument::getByProUid($proUid)
+                ->sortBy('INP_DOC_UID')
+                ->values();
+        $inputDocuments->transform(function($item, $key) {
+            return $item->attributesToArray();
+        });
+        $actual = $inputDocuments->toArray();
+        foreach ($actual as &$value) {
+            ksort($value);
+        }
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    /**
+     * This checks if the output documents structure is saved with the different 
+     * parameters.
+     * @test
+     * @covers Processes::createOutputRows()
+     */
+    public function it_should_create_output_document()
+    {
+        $faker = Factory::create();
+        $date = $faker->datetime();
+        $proUid = G::generateUniqueID();
+        $expected = [
+            [
+                'OUT_DOC_UID' => G::generateUniqueID(),
+                'OUT_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+                'OUT_DOC_TITLE' => $faker->sentence(2),
+                'OUT_DOC_DESCRIPTION' => $faker->sentence(10),
+                'OUT_DOC_FILENAME' => $faker->sentence(2),
+                'OUT_DOC_TEMPLATE' => '',
+                'PRO_UID' => $proUid,
+                'OUT_DOC_REPORT_GENERATOR' => 'TCPDF',
+                'OUT_DOC_LANDSCAPE' => 0,
+                'OUT_DOC_MEDIA' => 'Letter',
+                'OUT_DOC_LEFT_MARGIN' => 20,
+                'OUT_DOC_RIGHT_MARGIN' => 20,
+                'OUT_DOC_TOP_MARGIN' => 20,
+                'OUT_DOC_BOTTOM_MARGIN' => 20,
+                'OUT_DOC_GENERATE' => 'BOTH',
+                'OUT_DOC_TYPE' => 'HTML',
+                'OUT_DOC_CURRENT_REVISION' => 0,
+                'OUT_DOC_FIELD_MAPPING' => '',
+                'OUT_DOC_VERSIONING' => 1,
+                'OUT_DOC_DESTINATION_PATH' => '',
+                'OUT_DOC_TAGS' => '',
+                'OUT_DOC_PDF_SECURITY_ENABLED' => 0,
+                'OUT_DOC_PDF_SECURITY_OPEN_PASSWORD' => '',
+                'OUT_DOC_PDF_SECURITY_OWNER_PASSWORD' => '',
+                'OUT_DOC_PDF_SECURITY_PERMISSIONS' => '',
+                'OUT_DOC_OPEN_TYPE' => 1,
+                '__OUT_DOC_ID_UPDATE__' => false,
+            ],
+            [
+                'OUT_DOC_UID' => G::generateUniqueID(),
+                'OUT_DOC_ID' => $faker->unique()->numberBetween(1, 10000),
+                'OUT_DOC_TITLE' => $faker->sentence(2),
+                'OUT_DOC_DESCRIPTION' => $faker->sentence(10),
+                'OUT_DOC_FILENAME' => $faker->sentence(2),
+                'OUT_DOC_TEMPLATE' => '',
+                'PRO_UID' => $proUid,
+                'OUT_DOC_REPORT_GENERATOR' => 'TCPDF',
+                'OUT_DOC_LANDSCAPE' => 0,
+                'OUT_DOC_MEDIA' => 'Letter',
+                'OUT_DOC_LEFT_MARGIN' => 20,
+                'OUT_DOC_RIGHT_MARGIN' => 20,
+                'OUT_DOC_TOP_MARGIN' => 20,
+                'OUT_DOC_BOTTOM_MARGIN' => 20,
+                'OUT_DOC_GENERATE' => 'BOTH',
+                'OUT_DOC_TYPE' => 'HTML',
+                'OUT_DOC_CURRENT_REVISION' => 0,
+                'OUT_DOC_FIELD_MAPPING' => '',
+                'OUT_DOC_VERSIONING' => 1,
+                'OUT_DOC_DESTINATION_PATH' => '',
+                'OUT_DOC_TAGS' => '',
+                'OUT_DOC_PDF_SECURITY_ENABLED' => 0,
+                'OUT_DOC_PDF_SECURITY_OPEN_PASSWORD' => '',
+                'OUT_DOC_PDF_SECURITY_OWNER_PASSWORD' => '',
+                'OUT_DOC_PDF_SECURITY_PERMISSIONS' => '',
+                'OUT_DOC_OPEN_TYPE' => 1,
+                '__OUT_DOC_ID_UPDATE__' => false,
+            ]
+        ];
+        $this->sortArrayByColumn($expected, 'OUT_DOC_UID');
+
+        $processes = new Processes();
+        $processes->createOutputRows($expected);
+        foreach ($expected as &$value) {
+            ksort($value);
+            unset($value['__OUT_DOC_ID_UPDATE__']);
+        }
+
+        $outputDocuments = OutputDocument::getByProUid($proUid)
+                ->sortBy('OUT_DOC_UID')
+                ->values();
+        $outputDocuments->transform(function($item, $key) {
+            return $item->attributestoArray();
+        });
+        $actual = $outputDocuments->toArray();
+        foreach ($actual as &$value) {
+            ksort($value);
+        }
+
+        $this->assertEquals($expected, $actual);
+    }
+}

workflow/engine/classes/Processes.php

@@ -1919,14 +1919,19 @@ class Processes
 
 
     /**
-     * Gets Input Documents Rows from aProcess.
+     * Gets Input Documents Rows from process.
      *
      * @param string $proUid
+     * @param boolean $unsetInpDocId
      *
      * @return array
      * @throws Exception
+     * 
+     * @see Processes::getWorkflowData()
+     * @see ProcessMaker\BusinessModel\Migrator\InputDocumentsMigrator::export()
+     * @see ProcessMaker\Importer\Importer::saveCurrentProcess()
      */
-    public function getInputRows($proUid)
+    public function getInputRows($proUid, $unsetInpDocId = true)
     {
         try {
             $inputList = [];
@@ -1938,7 +1943,9 @@ class Processes
             while ($row = $dataset->getRow()) {
                 $input = new InputDocument();
                 $infoInput = $input->load($row['INP_DOC_UID']);
-                unset($infoInput['INP_DOC_ID']);
+                if ($unsetInpDocId === true) {
+                    unset($infoInput['INP_DOC_ID']);
+                }
                 $inputList[] = $infoInput;
                 $dataset->next();
             }
@@ -1956,6 +1963,10 @@ class Processes
      *
      * @return void
      * @throws Exception
+     * 
+     * @see Processes::createProcessPropertiesFromData()
+     * @see Processes::updateProcessFromData()
+     * @see ProcessMaker\BusinessModel\Migrator\InputDocumentsMigrator::import()
      */
     public function createInputRows($input)
     {
@@ -1970,11 +1981,15 @@ class Processes
                 //Get the INP_DOC_ID column
                 $dataSet = BasePeer::doSelect($criteria, $con);
                 $dataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
-                if ($dataSet->next()) {
+                if (isset($row["__INP_DOC_ID_UPDATE__"]) && $row["__INP_DOC_ID_UPDATE__"] === false) {
-                    $inputInfo = $dataSet->getRow();
+                    unset($row["__INP_DOC_ID_UPDATE__"]);
-                    $row['INP_DOC_ID'] = $inputInfo['INP_DOC_ID'];
                 } else {
-                    $row['INP_DOC_ID'] = null;
+                    if ($dataSet->next()) {
+                        $inputInfo = $dataSet->getRow();
+                        $row['INP_DOC_ID'] = $inputInfo['INP_DOC_ID'];
+                    } else {
+                        $row['INP_DOC_ID'] = null;
+                    }
                 }
                 BasePeer::doDelete($criteria, $con);
                 //Prepare the insert
@@ -2102,11 +2117,16 @@ class Processes
      * Gets the Output Documents Rows from a Process.
      *
      * @param string $proUid
+     * @param boolean $unsetOutDocId
      *
      * @return array
      * @throws Exception
+     * 
+     * @see Processes::getWorkflowData()
+     * @see ProcessMaker\BusinessModel\Migrator\OutputDocumentsMigrator::export()
+     * @see ProcessMaker\Importer\Importer::saveCurrentProcess()
      */
-    public function getOutputRows($proUid)
+    public function getOutputRows($proUid, $unsetOutDocId = true)
     {
         try {
             $outputList = [];
@@ -2118,7 +2138,9 @@ class Processes
             while ($row = $dataset->getRow()) {
                 $output = new OutputDocument();
                 $infoOutput = $output->Load($row['OUT_DOC_UID']);
-                unset($infoOutput['OUT_DOC_ID']);
+                if ($unsetOutDocId === true) {
+                    unset($infoOutput['OUT_DOC_ID']);
+                }
                 $outputList[] = $infoOutput;
                 $dataset->next();
             }
@@ -2136,6 +2158,10 @@ class Processes
      *
      * @return void
      * @throws Exception
+     * 
+     * @see Processes::createProcessPropertiesFromData()
+     * @see Processes::updateProcessFromData()
+     * @see ProcessMaker\BusinessModel\Migrator\OutputDocumentsMigrator::import()
      */
     public function createOutputRows($output)
     {
@@ -2150,11 +2176,15 @@ class Processes
                 //Get the OUT_DOC_ID column
                 $dataSet = BasePeer::doSelect($criteria, $con);
                 $dataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
-                if ($dataSet->next()) {
+                if (isset($row["__OUT_DOC_ID_UPDATE__"]) && $row["__OUT_DOC_ID_UPDATE__"] === false) {
-                    $outputInfo = $dataSet->getRow();
+                    unset($row["__OUT_DOC_ID_UPDATE__"]);
-                    $row['OUT_DOC_ID'] = $outputInfo['OUT_DOC_ID'];
                 } else {
-                    $row['OUT_DOC_ID'] = null;
+                    if ($dataSet->next()) {
+                        $outputInfo = $dataSet->getRow();
+                        $row['OUT_DOC_ID'] = $outputInfo['OUT_DOC_ID'];
+                    } else {
+                        $row['OUT_DOC_ID'] = null;
+                    }
                 }
                 BasePeer::doDelete($criteria, $con);
                 //Prepare the insert
@@ -2931,11 +2961,16 @@ class Processes
      * Get Dynaform Rows from a Process
      *
      * @param string $proUid
+     * @param boolean $unsetDynId
      *
      * @return array
      * @throws Exception
+     * 
+     * @see Processes::getWorkflowData()
+     * @see ProcessMaker\BusinessModel\Migrator\DynaformsMigrator::export()
+     * @see ProcessMaker\Importer\Importer::saveCurrentProcess()
      */
-    public function getDynaformRows($proUid)
+    public function getDynaformRows($proUid, $unsetDynId = true)
     {
         try {
             $dynaformList = [];
@@ -2947,7 +2982,9 @@ class Processes
             while ($row = $dataset->getRow()) {
                 $dynaform = new Dynaform();
                 $infoDyn = $dynaform->Load($row['DYN_UID']);
-                unset($infoDyn['DYN_ID']);
+                if ($unsetDynId === true) {
+                    unset($infoDyn['DYN_ID']);
+                }
                 $dynaformList[] = $infoDyn;
                 $dataset->next();
             }
@@ -3077,12 +3114,16 @@ class Processes
     }
 
     /**
-     * Create dynaforms for a process
+     * Create dynaforms for a process.
      *
      * @param array $dynaforms
      *
      * @return void
      * @throws Exception
+     * 
+     * @see Processes::createProcessPropertiesFromData()
+     * @see Processes::updateProcessFromData()
+     * @see ProcessMaker\BusinessModel\Migrator\DynaformsMigrator::import()
      */
     public function createDynaformRows($dynaforms)
     {
@@ -3097,11 +3138,15 @@ class Processes
                 //Get the DYN_ID column
                 $dataSet = BasePeer::doSelect($criteria, $con);
                 $dataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
-                if ($dataSet->next()) {
+                if (isset($row["__DYN_ID_UPDATE__"]) && $row["__DYN_ID_UPDATE__"] === false) {
-                    $dynInfo = $dataSet->getRow();
+                    unset($row["__DYN_ID_UPDATE__"]);
-                    $row['DYN_ID'] = $dynInfo['DYN_ID'];
                 } else {
-                    $row['DYN_ID'] = null;
+                    if ($dataSet->next()) {
+                        $dynInfo = $dataSet->getRow();
+                        $row['DYN_ID'] = $dynInfo['DYN_ID'];
+                    } else {
+                        $row['DYN_ID'] = null;
+                    }
                 }
                 BasePeer::doDelete($criteria, $con);
                 //Prepare the insert

workflow/engine/src/ProcessMaker/Importer/Importer.php

@@ -301,6 +301,24 @@ abstract class Importer
                         }
                     }
                     
+                    if (isset($this->importData["tables"]["workflow"]["dynaforms"])) {
+                        foreach ($this->importData["tables"]["workflow"]["dynaforms"] as &$dynaform) {
+                            $this->preserveDynaformId($dynaform);
+                        }
+                    }
+
+                    if (isset($this->importData["tables"]["workflow"]["inputs"])) {
+                        foreach ($this->importData["tables"]["workflow"]["inputs"] as &$input) {
+                            $this->preserveInputDocumentId($input);
+                        }
+                    }
+
+                    if (isset($this->importData["tables"]["workflow"]["outputs"])) {
+                        foreach ($this->importData["tables"]["workflow"]["outputs"] as &$output) {
+                            $this->preserveOutputDocumentId($output);
+                        }
+                    }
+
                     $objectList = $granularObj->loadObjectsListSelected($this->importData, $newObjectArray);
                     if (sizeof($objectList) > 0 && $processGranulate) {
                         $granularObj->import($objectList);
@@ -603,6 +621,18 @@ abstract class Importer
                 $this->preserveEmailEventConfiguration($emailEvent);
             }
             
+            foreach ($arrayWorkflowTables["dynaforms"] as &$dynaform) {
+                $this->preserveDynaformId($dynaform);
+            }
+
+            foreach ($arrayWorkflowTables["inputs"] as &$input) {
+                $this->preserveInputDocumentId($input);
+            }
+
+            foreach ($arrayWorkflowTables["outputs"] as &$output) {
+                $this->preserveOutputDocumentId($output);
+            }
+
             $this->importWfTables($arrayWorkflowTables);
 
             //Import workflow files
@@ -862,6 +892,8 @@ abstract class Importer
      * Saves the current objects before import.
      * 
      * @param string $proUid
+     * 
+     * @see ProcessMaker\Importer\Importer::import()
      */
     public function saveCurrentProcess($proUid)
     {
@@ -873,9 +905,9 @@ abstract class Importer
         $result->tasks = $processes->getTaskRows($proUid);
         $result->abeConfigurations = $processes->getActionsByEmail($proUid);
         $result->emailEvents = $processes->getEmailEvent($proUid);
-        $result->dynaforms = $processes->getDynaformRows($proUid);
+        $result->dynaforms = $processes->getDynaformRows($proUid, false);
-        $result->inputs = $processes->getInputRows($proUid);
+        $result->inputs = $processes->getInputRows($proUid, false);
-        $result->outputs = $processes->getOutputRows($proUid);
+        $result->outputs = $processes->getOutputRows($proUid, false);
 
         $this->setCurrentProcess($result);
     }
@@ -948,4 +980,87 @@ abstract class Importer
         }
     }
 
+    /**
+     * Restore DYN_ID value for specific dynaform.
+     * The value of __DYN_ID_UPDATE__ only used like a reference.
+     * 
+     * @param array $data
+     * 
+     * @see ProcessMaker\Importer\Importer::import()
+     * @see ProcessMaker\Importer\Importer::doImport()
+     * @link https://wiki.processmaker.com/3.1/Importing_and_Exporting_Projects#Importing_a_Project
+     */
+    public function preserveDynaformId(&$data)
+    {
+        $currentProccess = $this->getCurrentProcess();
+        if (!is_object($currentProccess)) {
+            return;
+        }
+        if (!is_array($currentProccess->dynaforms)) {
+            return;
+        }
+        foreach ($currentProccess->dynaforms as $dynaform) {
+            if ($data["DYN_UID"] === $dynaform["DYN_UID"]) {
+                $data["DYN_ID"] = $dynaform["DYN_ID"];
+                $data["__DYN_ID_UPDATE__"] = false;
+                break;
+            }
+        }
+    }
+
+    /**
+     * Restore INP_DOC_ID value for specific input document.
+     * The value of __INP_DOC_ID_UPDATE__ only used like a reference.
+     * 
+     * @param array $data
+     * 
+     * @see ProcessMaker\Importer\Importer::import()
+     * @see ProcessMaker\Importer\Importer::doImport()
+     * @link https://wiki.processmaker.com/3.1/Importing_and_Exporting_Projects#Importing_a_Project
+     */
+    public function preserveInputDocumentId(&$data)
+    {
+        $currentProccess = $this->getCurrentProcess();
+        if (!is_object($currentProccess)) {
+            return;
+        }
+        if (!is_array($currentProccess->inputs)) {
+            return;
+        }
+        foreach ($currentProccess->inputs as $inputDocument) {
+            if ($data["INP_DOC_UID"] === $inputDocument["INP_DOC_UID"]) {
+                $data["INP_DOC_ID"] = $inputDocument["INP_DOC_ID"];
+                $data["__INP_DOC_ID_UPDATE__"] = false;
+                break;
+            }
+        }
+    }
+
+    /**
+     * Restore OUT_DOC_ID value for specific output document.
+     * The value of __OUT_DOC_ID_UPDATE__ only used like a reference.
+     * 
+     * @param array $data
+     * 
+     * @see ProcessMaker\Importer\Importer::import()
+     * @see ProcessMaker\Importer\Importer::doImport()
+     * @link https://wiki.processmaker.com/3.1/Importing_and_Exporting_Projects#Importing_a_Project
+     */
+    public function preserveOutputDocumentId(&$data)
+    {
+        $currentProccess = $this->getCurrentProcess();
+        if (!is_object($currentProccess)) {
+            return;
+        }
+        if (!is_array($currentProccess->outputs)) {
+            return;
+        }
+        foreach ($currentProccess->outputs as $outputDocument) {
+            if ($data["OUT_DOC_UID"] === $outputDocument["OUT_DOC_UID"]) {
+                $data["OUT_DOC_ID"] = $outputDocument["OUT_DOC_ID"];
+                $data["__OUT_DOC_ID_UPDATE__"] = false;
+                break;
+            }
+        }
+    }
 }

workflow/engine/src/ProcessMaker/Model/Dynaform.php

@@ -14,8 +14,13 @@ use Illuminate\Support\Facades\DB;
 class Dynaform extends Model
 {
     protected $table = 'DYNAFORM';
+    protected $primaryKey = "DYN_ID";
     public $timestamps = false;
 
+    /**
+     * Return relation process.
+     * @return object
+     */
     public function process()
     {
         return $this->belongsTo(Process::class, 'PRO_UID', 'PRO_UID');

workflow/engine/src/ProcessMaker/Model/InputDocument.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace ProcessMaker\Model;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * Represents a input document object in the system.
+ */
+class InputDocument extends Model
+{
+    protected $table = 'INPUT_DOCUMENT';
+    protected $primaryKey = 'INP_DOC_ID';
+    public $timestamps = false;
+
+    /**
+     * Return relation process.
+     * @return object
+     */
+    public function process()
+    {
+        return $this->belongsTo(Process::class, 'PRO_UID', 'PRO_UID');
+    }
+
+    /**
+     * Get input documents by PRO_UID 
+     * @param string $proUid
+     * @return \Illuminate\Database\Eloquent\Collection
+     */
+    public static function getByProUid($proUid)
+    {
+        return InputDocument::where('PRO_UID', '=', $proUid)->get();
+    }
+
+    /**
+     * Get input document by INP_DOC_UID
+     * @param type $inpDocUid
+     * @return Model
+     */
+    public static function getByInpDocUid($inpDocUid)
+    {
+        return InputDocument::where('INP_DOC_UID', '=', $inpDocUid)->first();
+    }
+}

workflow/engine/src/ProcessMaker/Model/OutputDocument.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace ProcessMaker\Model;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * Represents a output document object in the system.
+ */
+class OutputDocument extends Model
+{
+    protected $table = 'OUTPUT_DOCUMENT';
+    protected $primaryKey = 'OUT_DOC_ID';
+    public $timestamps = false;
+
+    /**
+     * Return relation process.
+     * @return object
+     */
+    public function process()
+    {
+        return $this->belongsTo(Process::class, 'PRO_UID', 'PRO_UID');
+    }
+
+    /**
+     * Get output documents by PRO_UID.
+     * @param string $proUid
+     * @return \Illuminate\Database\Eloquent\Collection
+     */
+    public static function getByProUid($proUid)
+    {
+        return OutputDocument::where('PRO_UID', '=', $proUid)->get();
+    }
+
+    /**
+     * Get output document by OUT_DOC_UID.
+     * @param string $outDocUid
+     * @return Model
+     */
+    public static function getByOutDocUid($outDocUid)
+    {
+        return OutputDocument::where('OUT_DOC_UID', '=', $outDocUid)->first();
+    }
+}