机加管线报表测试环境报错

lazhen

2025-01-07 b3987122cbbc46c5c59d3173f37fca3170b6dc5a

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
Quintiq file version 2.0
#parent: #root
Method SendDataSuccessGetSet (LibDEF_Set set_i, NamedValueTree request_i, LibDEF_IntegrationEvent event_i, 
  Boolean inChunk_i)
{
  Description: 'Send a Data-Success message for requesting a Set.'
  TextBody:
  [*
    LibDEF_Util::EventLog( event_i, "Sending GetSet reply." );
    
    dataBroker := this.DataBroker();
    channel    := set_i.SetType().Channel();
    
    // Export the set to NVT
    setNvt := NamedValueTreeIO::Export( set_i );
    
    // Prepare message
    nvt := LibDEF_DataAccessor::CreateMessageData();
    
    // Add headers
    type := LibDEF_DataAccessor::GetDataHeaderPropertyAsString( request_i, LibDEF_DataAccessor::HEADER_TYPE() );
    datasetMDSID := LibDEF_DataAccessor::GetDataHeaderPropertyAsKey( request_i, LibDEF_DataAccessor::HEADER_DATASETMDSID() );
    datasetDTD   := LibDEF_DataAccessor::GetDataHeaderPropertyAsKey( request_i, LibDEF_DataAccessor::HEADER_DATASETDTD() );
    datasetType  := LibDEF_DataAccessor::GetDataHeaderPropertyAsString( request_i, LibDEF_DataAccessor::HEADER_DATASETMODELTYPE() );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_TYPE(), type );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_SETTYPEGUID(), set_i.SetType().GUID() );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_SETGUID(), set_i.GUID() );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_SETLASTUPDATED(), set_i.LastUpdated() );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_DATASETMDSID(), datasetMDSID );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_DATASETDTD(), datasetDTD );
    LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_DATASETMODELTYPE(), datasetType );
    
    if( not inChunk_i )
    {
      // Fill in the message body with the setNvt
      LibDEF_DataAccessor::SetDataBody( nvt, setNvt );
    }
    else
    {
      // create a DataTransfer
      dataBroker := this.DataBroker();
      setMeta    := LibDEF_SetMeta::FindSetMeta( dataBroker, dataBroker.SystemLocal().GUID(),
                                                 set_i.ChannelName(), set_i.SetTypeName(), set_i.Name() );
      dataTransfer   := LibDEF_DataTransfer::Create( this.DataBroker().QueueOutbox(),
                                                     LibDEF_NamedValueTreeProcessor::GetCumulativeNumberOfChildren( setNvt.Root() ),
                                                     "",
                                                     setMeta,
                                                     this,
                                                     event_i );
    
      // Add chunking related headers
      LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_ISINIT(),  true ); // this is the initialization only
      LibDEF_DataAccessor::SetDataHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_DATATRANSFERGUID(), dataTransfer.GUID() );
      
      // export the DataTransfer into NVT
      LibDEF_DataAccessor::SetDataBody( nvt, NamedValueTreeIO::Export( dataTransfer ) );
      
      // Add internal message for the async SOAP procedure to retrieve the payload to be chunked
      LibDEF_DataAccessor::SetInternalMessageHeaderProperty( nvt, LibDEF_DataAccessor::HEADER_TYPE(), LibDEF_DataAccessor::TYPE_INTERNALMESSAGE_PAYLOADTOCHUNK() );
      LibDEF_DataAccessor::SetInternalMessageBody( nvt, setNvt );
    }
    
    // Send data
    dataBroker.SendData( this, nvt, LibDEF_DataAccessor::KIND_SUCCESS(), event_i,
                         channel.Name(), channel.MajorVersion(), channel.MinorVersion() );
  *]
}