Merge branch 'dev'

yy

2023-09-25 7e72a43c063c1c7728be80db4e7bf0f493eecacc

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
Quintiq file version 2.0
#parent: #root
Job JobIncomingLane
{
  Description: 'Process mapped NVT request from QI'
  OnFailureText:
  [*
    MPSync::JobHandleMessageResponse( this.MDSMPSync().ID(), requestnvt, errormessage );
    MessageIntegrationLog::CreateError( this, MPSyncUtility::ID_ObjectGroup_Lanes(), errormessage );
  *]
  Priority: 'Default'
  Text:
  [*
    feedback    := '';
    objectgroup := MPSyncUtility::ID_ObjectGroup_Lanes();
    
    if( this.IsImportObjectGroupExpectingMessage( objectgroup, feedback ) )
    {
      messagelog     := MessageIntegrationLog::Create( this, objectgroup );
      
      // Check if the incoming message is batched
      size := LibInt_BatchAccessor::GetSize( requestnvt );
      if( size > 1 )
      {
        for( i := 0; i < size; i++ )
        {
          rootNamedValue := LibInt_BatchAccessor::GetChildRoot( requestnvt, i );
          this.ProcessIncomingLanes( requestnvt, rootNamedValue, messagelog );
        }
      }
      // otherwise, process single message
      else
      {
        rootNamedValue := requestnvt.Root();
        this.ProcessIncomingLanes( requestnvt, rootNamedValue, messagelog );
      }
      
      messagelog.CompleteProcess();
      MPSync::JobHandleMessageResponse( this.MDSMPSync().ID(), requestnvt, messagelog.Error() );
    }
    // Add error to message log
    else
    {
      MPSync::JobHandleMessageResponse( this.MDSMPSync().ID(), requestnvt, feedback );
      MessageIntegrationLog::CreateError( this, objectgroup, feedback );
    }
  *]
  Arguments:
  [
    Argument requestnvt { Type: NamedValueTree }
  ]
}