X++ code to consume API in D365FO

We can consume the API's by using System.Net.HttpWebRequest  and System.Net.WebHeaderCollection.

Find below sample code to call API.

    public void callAPI(str   _requestJson,str _url)
    {
        System.Net.HttpWebRequest       request;
        System.Net.HttpWebResponse      response;
        CLRObject                       clrObj;
        System.Exception                ex;
        System.Net.WebHeaderCollection  httpHeader;
        System.IO.Stream                requestStream, responseStream;
        System.IO.StreamWriter          streamWriter;
        RefRecId                        refrecid = 0;
	    System.Byte[]                   bytes        = null;
        System.Text.Encoding            encoding     = null;
        str  token;
        try
        {
            httpHeader = new System.Net.WebHeaderCollection();
            new InteropPermission(InteropKind::ClrInterop).assert();         
            clrObj = System.Net.WebRequest::Create(_url);

            request = clrObj;

	    // API Authentication. It can vary for different API providers
            httpHeader.Add("accessToken", token);
          
            request.set_Headers(httpHeader);
            request.Method = "POST";
            request.ContentType = "application/json";

            requestStream = request.GetRequestStream();
			
            streamWriter = new System.IO.StreamWriter(request.GetRequestStream());
	    streamWriter.Write(_requestJson); // writing JSON
            streamWriter.Flush();
            streamWriter.Close();

	    /*
	    if(_requestJson)
            {
                // info(_requestJson);
                encoding    = System.Text.Encoding::ASCII;//get_UTF8();
                bytes       = encoding.GetBytes(_requestJson);
                httpRequest.set_ContentLength(bytes.get_Length());
                stream      = httpRequest.GetRequestStream();
                stream.Write(bytes,0,bytes.get_Length());
                stream.Close ();
                
            }*\
			
            response = request.GetResponse();
            System.IO.StreamReader streamRead = new System.IO.StreamReader(response.GetResponseStream());
            str res = streamRead.ReadToEnd().ToString();
            info(res);                  
        }
        catch
        {
            //exception
            ex = CLRInterop::getLastException().GetBaseException();
            error(ex.get_Message());
        }
    }

Multi threading batch job in D365FO

 We get lot of requirements of some process that need to run in batch but sometimes batch takes time to complete because of large volume of data. In this case we can implement the Multi Threading for a batch which reduces execution time by creating multiple batch tasks at run time.

we need to create a class which creates the tasks based on our condition. In my case pushing all the customer transactions to a custom table. 

Find below code:

class MultiThreadBatch extends RunBaseBatch
{
    #Define.CurrentVersion(1)
    public ClassDescription caption()
    {
        ClassDescription ret;
        ret = 'Multhreading batch job';
        return ret;        
    }
    protected void new()
    {
        super();
    }
    public container pack()
    {
        return [#CurrentVersion];
    }
    public void run()
    {
        BatchHeader                     batchHeader;
        MultiThreadTask                 multiThreadTask;       
	CustTrans			custTrans;
		
        While select custTrans group by AccountNum
            where custTrans.isSent == NoYes::yes
        {
            if(this.isInBatch())
            {
                if(!batchHeader)
                {
                    batchHeader = BatchHeader::construct(this.parmCurrentBatch().BatchJobId);                    
                }
                multiThreadTask = MultiThreadTask::NewAccountNum(custTrans.AccountNum);
                              
                // add tasks to the batch header
                batchHeader.addRuntimeTask(multiThreadTask, this.parmCurrentBatch().RecId);           
            }
        }
        if(batchHeader)
        {
            // save the batchheader with added tasks
            batchHeader.save();
        }
    }

    public boolean showDefaultButton()
    {
        return true;
    }

    // Source showQuerySelectButton
    public boolean showQuerySelectButton()
    {
        return true;
    }

    // Source showQueryValues
    public boolean showQueryValues()
    {
        return true;
    }
    // Source unpack
    public boolean unpack(container packedClass)
    {
        //Deserializes the packedClass parameter value to an instance of the RunBase class.
        boolean         isSuccessful;
        Version         version = RunBase::getVersion(packedClass);
        container       base;        ;
        switch (version)
        {
            case #CurrentVersion:
                {
                    [version, base] = packedClass;
                    isSuccessful = true;
                    break;
                }

            default :
                return false;
        }
        return isSuccessful;        
    }
    // Source construct
    public static MultiThreadBatch construct()
    {
        return new MultiThreadBatch();
        
    }
    // Source main
    public static void main(Args _args)
    {
        MultiThreadBatch obj;        
        obj = MultiThreadBatch::construct();
        if(obj.prompt())
        {
            obj.run();
        }
    }
}

class  MultiThreadTask extends RunBaseBatch  
 {  
   custAccount custAccount;  
   #define.CurrentVersion(1)  
   #localmacro.CurrentList  
       custAccount  
     #endmacro  
   public ClassDescription caption()    
   {  
     ClassDescription ret;  
     ret = strfmt(' Multi Thread Task for customer %1' + custAccount);  
     return ret;      
   }  
   protected void new()    
   {  
     super();  
   }  
   public container pack()    
   {  
     return [#CurrentVersion,#CurrentList];      
   }  
   public custAccount newAccountNum(CustAccount _custAccount = custAccount)    
   {  
     ;  
     CustAccount = _custAccount;  
     return custAccount;      
   }  
   public void run()    
   {  
     ;  
     this.populateCustomTable(CustAccount);  
   }  
   public boolean unpack(container packedClass)    
   {  
     int version   = runbase::getVersion(packedClass);  
     switch (version)      
     {  
       case #CurrentVersion:  
         [version,#CurrentList] = packedClass;  
         return true;  
       default :  
         return false;        
     }  
     return false;      
   }  
   private static  MultiThreadTask construct()    
   {  
     return new  MultiThreadTask();      
   }  
   public static  MultiThreadTask initialize(CustAccount _custAccount)  
   {  
      MultiThreadTask multiTaskThread;  
     ;  
     multiTaskThread =  MultiThreadTask::construct();  
     multiTaskThread.NewAccountNum(_custAccount);  
     return multiTaskThread;  
   } 

	public void populateCustomTable(CustAccount _custAccount)
	{
		//insert data here
	}   
 }  

You can Click here to implement the above code using sys operation framework.

X++ Code to change form link type for datasource in D365FO

 Here we are taking the post event handler of init method of standard class. by using the below code we can change the link type for a datasource.

 

    [PostHandlerFor(classStr(RuntimeFormExtensionApplier), staticMethodStr(RuntimeFormExtensionApplier, OnFormInit))]
    public static void RuntimeFormExtensionApplier_Post_OnFormInit(XppPrePostArgs _args)
    {
        #ISOCountryRegionCodes
        const str dataSourceCustTable = 'TaxInformationCustTable_IN';
        Form frm = _args.getArg('_form') as Form
        if (SysCountryRegionCode::isLegalEntityInCountryRegion([#isoIN]) && formStr(CustTable) == frm.name())
        {
            FormBuildDataSource fbds = frm.dataSource(dataSourceCustTable);
            if (fbds != null)
            {
                fbds.linkType(FormLinkType::InnerJoin);
            }
        }
    }

Keep learning!!