Merge remote-tracking branch 'origin/dev' into dev

lihongji

2024-10-12 f1de76007e7834e17d87712e3342efd84876c200

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 JobIncomingProduct
{
  Description: 'Process mapped product NVT request from QI'
  OnFailureText:
  [*
    MPSync::JobHandleMessageResponse( this.MDSMPSync().ID(), requestnvt, errormessage );
    MessageIntegrationLog::CreateError( this, MPSyncUtility::ID_ObjectGroup_Products(), errormessage );
  *]
  Priority: 'Default'
  Text:
  [*
    //Process mapped product NVT request from QI
    feedback    := '';
    objectgroup := MPSyncUtility::ID_ObjectGroup_Products();
    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.ProcessIncomingProducts( requestnvt, rootNamedValue, messagelog );
        }
      }
      // otherwise, process single message
      else
      {
        rootNamedValue := requestnvt.Root();
        this.ProcessIncomingProducts( 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 }
  ]
}