Magento Integration Specification ERP Trade Agreement - Product Pricing & Discounts Extract

Magento Integration Specification ERP Trade Agreement - Product Pricing & Discounts Extract:

Main table pricediscadmtrans, need to add NoYesId field.
And write the code by taking extension of the table for Insert and Update methods

 [ExtensionOf(tableStr(PriceDiscAdmTrans))]
final class KGSPMIPriceDiscAdmTrans_Extension
{
    public void  insert()
    {
        this.KGSPMIIsProcessed  = NoYes::No;
        next insert();            
    }
    public void update()
    {
        this.KGSPMIIsProcessed  = NoYes::No;
        next update();  
    }
}
--------------------------------------

For reset for the pricediscadmtrans table of which added field of NoYesId
class KGSPMIPriceDiscAdmTransProcessAllData
{       
    /// <summary>
    /// Runs the class with the specified arguments.
    /// </summary>
    /// <param name = "_args">The specified arguments.</param>
    public static void main(Args _args)
    {
        PriceDiscAdmTrans   priceDiscAdmTrans;;
        int countRec = 0;
        ttsbegin;
        while select forupdate priceDiscAdmTrans
        {
            priceDiscAdmTrans.KGSPMIIsProcessed    = NoYes::No;
            priceDiscAdmTrans.doUpdate();
            countRec++;
        }
        ttscommit;
        Info(strFmt("@KGSPMI:KGSPMIJobUpdate", countRec));
    }
}
------------------------------------

1. Create a BaseEnums with IncrementalExport and FullExport
2. Create a table which to do temporary records comparing from pricediscadmtrans table
    ItemRelation,relation,accountcode,accountrelation,quantityamountfrom,quantityamountto,itemcode

3. Create a Data Contract class for initializing parameters
   [DataContractAttribute]
class KGSPMIPriceDiscAdmTransExportDataContract
{
    KGSPMIExportTradeAgreement       exportTradeAgreement;
    [DataMemberAttribute]
    public KGSPMIExportTradeAgreement parmExportTradeAgreement(KGSPMIExportTradeAgreement _exportTradeAgreement = exportTradeAgreement)
    {
        exportTradeAgreement = _exportTradeAgreement;
        return exportTradeAgreement;
    }
}
--------------------------------------------------------------------
4. Create a service class
  using System.IO;
using OfficeOpenXml;
using OfficeOpenXml.Style;
using OfficeOpenXml.Table;
class KGSPMIPriceDiscAdmTransExportService
{
    PriceDiscAdmTrans                   priceDiscAdmTrans;
    PriceDiscGroup                      priceDiscGroup;
    PriceDiscAdmTrans                   priceDiscAdmTransLoc,priceDiscAdmTransLocValue;
    EcoResProductCategory               prodCategory;
    InventTable                         inventTable;
    str                                 itemValueTable, journalValue;
    KGSPMITradeAgreementItemRelation    tradeAgreementItemRelation;
    KGSPMIExportTradeAgreement          exportTradeAgreement;
    KGSPMIIntegrationParameters         integrationParameters = KGSPMIIntegrationParameters::find();
    void process(KGSPMIPriceDiscAdmTransExportDataContract  _contract)
    {
        KGSPMIBlobFileShareDataWriter   integrationDataWriter;
        const str                       fileName        = "TradeAgreementTransaction.xlsx";
        MemoryStream                    memoryStream    = new MemoryStream();
        ttsbegin;
        using (var package = new ExcelPackage(memoryStream))
        {
            var currentRow = 1;
            var worksheets = package.get_Workbook().get_Worksheets();
            var CustTableWorksheet = worksheets.Add("@KGSPMI:KGSPMIExport");
            var cells = CustTableWorksheet.get_Cells();
           
            OfficeOpenXml.ExcelRange cell = cells.get_Item(currentRow, 1);
            System.String value = "@KGSPMI:KGSPMICustPriceGroup";
            cell.set_Value(value);
           
            cell = null;
            value = "@KGSPMI:KGSPMIItemItemGroup";
            cell = cells.get_Item(currentRow, 2);
            cell.set_Value(value);
            cell = null;
            value = "@SYS152640";
            cell = cells.get_Item(currentRow, 3);
            cell.set_Value(value);
            cell = null;
            value = "@SYS309396";
            cell = cells.get_Item(currentRow, 4);
            cell.set_Value(value);
           
            cell = null;
            value = "@SYS16617";
            cell = cells.get_Item(currentRow, 5);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMIAmount";
            cell = cells.get_Item(currentRow, 6);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMIDiscountPercent1";
            cell = cells.get_Item(currentRow, 7);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMIDiscountPercent2";
            cell = cells.get_Item(currentRow, 8);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMICurrency";
            cell = cells.get_Item(currentRow, 9);
            cell.set_Value(value);
           
            cell = null;
            value = "@KGSPMI:KGSPMIFromDate";
            cell = cells.get_Item(currentRow, 10);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMIToDate";
            cell = cells.get_Item(currentRow, 11);
            cell.set_Value(value);
            cell = null;
            value = "@SYS329986";
            cell = cells.get_Item(currentRow, 12);
            cell.set_Value(value);
            cell = null;
            value = "@KGSPMI:KGSPMIToQty";
            cell = cells.get_Item(currentRow, 13);
            cell.set_Value(value);
            cell = null;
            value = "@SYS328585";
            cell = cells.get_Item(currentRow, 14);
            cell.set_Value(value);
            cell = null;
            value = "@SYS101146";
            cell = cells.get_Item(currentRow, 15);
            cell.set_Value(value);
            exportTradeAgreement    = _contract.parmExportTradeAgreement();
            if(exportTradeAgreement == KGSPMIExportTradeAgreement::FullExport)
            {
                update_recordset priceDiscAdmTrans
                    setting KGSPMIIsProcessed = NoYes::No;
            }
            while select forupdate priceDiscAdmTrans
                where priceDiscAdmTrans.KGSPMIIsProcessed == NoYes::No
                    && priceDiscAdmTrans.KGSPMIPosted == NoYes::Yes
            {
                //Table
                if(priceDiscAdmTrans.ItemCode == PriceDiscProductCodeType::Table)
                {
                    select firstonly1 tradeAgreementItemRelation
                        where tradeAgreementItemRelation.ItemRelation       ==  priceDiscAdmTrans.ItemRelation
                            && tradeAgreementItemRelation.relation          ==  priceDiscAdmTrans.relation
                            && tradeAgreementItemRelation.AccountCode       ==  priceDiscAdmTrans.AccountCode
                            && tradeAgreementItemRelation.AccountRelation   ==  priceDiscAdmTrans.AccountRelation;
                    if(tradeAgreementItemRelation.ItemRelation == '')
                    {
                        select firstonly1 priceDiscAdmTransLocValue
                            order by RecId desc
                                where priceDiscAdmTransLocValue.ItemRelation            ==  priceDiscAdmTrans.ItemRelation
                                    && priceDiscAdmTransLocValue.relation               ==  priceDiscAdmTrans.relation
                                    && priceDiscAdmTransLocValue.AccountCode            ==  priceDiscAdmTrans.AccountCode
                                    && priceDiscAdmTransLocValue.AccountRelation        ==  priceDiscAdmTrans.AccountRelation
                                    && priceDiscAdmTransLocValue.KGSPMIIsProcessed      ==  priceDiscAdmTrans.KGSPMIIsProcessed
                                    && priceDiscAdmTransLocValue.KGSPMIPosted           ==  priceDiscAdmTrans.KGSPMIPosted;//fetching latest item
                        select firstonly1 inventTable
                            where inventTable.ItemId == priceDiscAdmTransLocValue.ItemRelation
                                notexists  join prodCategory
                                    where prodCategory.Product == inventTable.Product
                                        && prodCategory.Category == integrationParameters.MagentoCategory;//filtering from ProductCategory
                        if(inventTable)
                        {
                            currentRow ++;
                            cell = null;
                            cell = cells.get_Item(currentRow, 1);
                            cell.set_Value(this.getPriceGroupName(priceDiscAdmTransLocValue));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 2);
                            cell.set_Value(priceDiscAdmTransLocValue.ItemRelation);
                            cell = null;
                            cell = cells.get_Item(currentRow, 3);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.ItemCode));
                            cell = null;
                            cell = cells.get_Item(currentRow, 4);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.relation));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 5);
                            cell.set_Value(priceDiscAdmTransLocValue.UnitId);
                            cell = null;
                            cell = cells.get_Item(currentRow, 6);
                            cell.set_Value(priceDiscAdmTransLocValue.Amount);
                            cell = null;
                            cell = cells.get_Item(currentRow, 7);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent1);
                            cell = null;
                            cell = cells.get_Item(currentRow, 8);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent2);
                            cell = null;
                            cell = cells.get_Item(currentRow, 9);
                            cell.set_Value(priceDiscAdmTransLocValue.Currency);
                            cell = null;
                            cell = cells.get_Item(currentRow, 10);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.FromDate));
                            cell = null;
                            cell = cells.get_Item(currentRow, 11);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.ToDate));
                               
                            cell = null;
                            cell = cells.get_Item(currentRow, 12);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountFrom);
                            cell = null;
                            cell = cells.get_Item(currentRow, 13);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountTo);
                            cell = null;
                            cell = cells.get_Item(currentRow, 14);
                            cell.set_Value(priceDiscAdmTransLocValue.createdby);
                            cell = null;
                            cell = cells.get_Item(currentRow, 15);
                            cell.set_Value(this.getPostedDate(priceDiscAdmTransLocValue));
                            priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                            priceDiscAdmTrans.doUpdate();
                            tradeAgreementItemRelation.ItemRelation     =   priceDiscAdmTransLocValue.ItemRelation;
                            tradeAgreementItemRelation.relation         =   priceDiscAdmTransLocValue.relation;
                            tradeAgreementItemRelation.AccountCode      =   priceDiscAdmTransLocValue.AccountCode;
                            tradeAgreementItemRelation.AccountRelation  =   priceDiscAdmTransLocValue.AccountRelation;
                            tradeAgreementItemRelation.insert();
                        }
                    }
                    else
                    {
                        priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                        priceDiscAdmTrans.doUpdate();
                    }
                }
                //Group
                else if(priceDiscAdmTrans.ItemCode == PriceDiscProductCodeType::GroupId)
                {
                    select firstonly1 tradeAgreementItemRelation
                        where tradeAgreementItemRelation.ItemRelation           ==  priceDiscAdmTrans.ItemRelation
                            && tradeAgreementItemRelation.relation              ==  priceDiscAdmTrans.relation
                            && tradeAgreementItemRelation.QuantityAmountFrom    ==  priceDiscAdmTrans.QuantityAmountFrom
                            && tradeAgreementItemRelation.QuantityAmountTo      ==  priceDiscAdmTrans.QuantityAmountTo
                            && tradeAgreementItemRelation.AccountCode           ==  priceDiscAdmTrans.AccountCode
                            && tradeAgreementItemRelation.AccountRelation       ==  priceDiscAdmTrans.AccountRelation;
                    if(tradeAgreementItemRelation.ItemRelation == '')
                    {
                        select firstonly1 priceDiscAdmTransLocValue
                            order by RecId desc
                                where priceDiscAdmTransLocValue.ItemRelation            ==  priceDiscAdmTrans.ItemRelation
                                    && priceDiscAdmTransLocValue.relation               ==  priceDiscAdmTrans.relation
                                    && priceDiscAdmTransLocValue.AccountCode            ==  priceDiscAdmTrans.AccountCode
                                    && priceDiscAdmTransLocValue.AccountRelation        ==  priceDiscAdmTrans.AccountRelation
                                    && priceDiscAdmTransLocValue.QuantityAmountFrom     ==  priceDiscAdmTrans.QuantityAmountFrom
                                    && priceDiscAdmTransLocValue.QuantityAmountTo       ==  priceDiscAdmTrans.QuantityAmountTo
                                    && priceDiscAdmTransLocValue.KGSPMIIsProcessed      ==  priceDiscAdmTrans.KGSPMIIsProcessed
                                    && priceDiscAdmTransLocValue.KGSPMIPosted           ==  priceDiscAdmTrans.KGSPMIPosted;//fetching latest item
                        if(priceDiscAdmTransLocValue)
                        {
                            currentRow ++;
                            cell = null;
                            cell = cells.get_Item(currentRow, 1);
                            cell.set_Value(this.getPriceGroupName(priceDiscAdmTransLocValue));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 2);
                            cell.set_Value(priceDiscAdmTransLocValue.ItemRelation);
                            cell = null;
                            cell = cells.get_Item(currentRow, 3);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.ItemCode));
                            cell = null;
                            cell = cells.get_Item(currentRow, 4);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.relation));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 5);
                            cell.set_Value(priceDiscAdmTransLocValue.UnitId);
                            cell = null;
                            cell = cells.get_Item(currentRow, 6);
                            cell.set_Value(priceDiscAdmTransLocValue.Amount);
                            cell = null;
                            cell = cells.get_Item(currentRow, 7);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent1);
                            cell = null;
                            cell = cells.get_Item(currentRow, 8);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent2);
                            cell = null;
                            cell = cells.get_Item(currentRow, 9);
                            cell.set_Value(priceDiscAdmTransLocValue.Currency);
                            cell = null;
                            cell = cells.get_Item(currentRow, 10);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.FromDate));
                            cell = null;
                            cell = cells.get_Item(currentRow, 11);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.ToDate));
                               
                            cell = null;
                            cell = cells.get_Item(currentRow, 12);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountFrom);
                            cell = null;
                            cell = cells.get_Item(currentRow, 13);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountTo);
                            cell = null;
                            cell = cells.get_Item(currentRow, 14);
                            cell.set_Value(priceDiscAdmTransLocValue.createdby);
                            cell = null;
                            cell = cells.get_Item(currentRow, 15);
                            cell.set_Value(this.getPostedDate(priceDiscAdmTransLocValue));
                            priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                            priceDiscAdmTrans.doUpdate();
                            tradeAgreementItemRelation.ItemRelation         =   priceDiscAdmTransLocValue.ItemRelation;
                            tradeAgreementItemRelation.QuantityAmountFrom   =   priceDiscAdmTransLocValue.QuantityAmountFrom;
                            tradeAgreementItemRelation.QuantityAmountTo     =   priceDiscAdmTransLocValue.QuantityAmountTo;
                            tradeAgreementItemRelation.relation             =   priceDiscAdmTransLocValue.relation;
                            tradeAgreementItemRelation.AccountCode          =   priceDiscAdmTransLocValue.AccountCode;
                            tradeAgreementItemRelation.AccountRelation      =   priceDiscAdmTransLocValue.AccountRelation;
                            tradeAgreementItemRelation.insert();
                        }
                    }
                    else
                    {
                        priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                        priceDiscAdmTrans.doUpdate();
                    }
                }
                //All
                else
                {
                    select firstonly1 tradeAgreementItemRelation
                        where tradeAgreementItemRelation.AccountCode        ==  priceDiscAdmTrans.AccountCode
                            && tradeAgreementItemRelation.AccountRelation   ==  priceDiscAdmTrans.AccountRelation
                            && tradeAgreementItemRelation.ItemCode          ==  priceDiscAdmTrans.ItemCode
                            && tradeAgreementItemRelation.relation          ==  priceDiscAdmTrans.relation;
                    if(!tradeAgreementItemRelation.RecId)
                    {
                        select firstonly1 priceDiscAdmTransLocValue
                            order by RecId desc
                                where priceDiscAdmTransLocValue.ItemCode            ==  PriceDiscProductCodeType::All
                                    && priceDiscAdmTransLocValue.relation           ==  priceDiscAdmTrans.relation
                                    && priceDiscAdmTransLocValue.AccountCode        ==  priceDiscAdmTrans.AccountCode
                                    && priceDiscAdmTransLocValue.AccountRelation    ==  priceDiscAdmTrans.AccountRelation
                                    && priceDiscAdmTransLocValue.KGSPMIIsProcessed  ==  priceDiscAdmTrans.KGSPMIIsProcessed
                                    && priceDiscAdmTransLocValue.KGSPMIPosted       ==  priceDiscAdmTrans.KGSPMIPosted;//fetching latest item
                        if(priceDiscAdmTransLocValue)
                        {
                            currentRow ++;
                            cell = null;
                            cell = cells.get_Item(currentRow, 1);
                            cell.set_Value(this.getPriceGroupName(priceDiscAdmTransLocValue));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 2);
                            cell.set_Value(priceDiscAdmTransLocValue.ItemRelation);
                            cell = null;
                            cell = cells.get_Item(currentRow, 3);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.ItemCode));
                            cell = null;
                            cell = cells.get_Item(currentRow, 4);
                            cell.set_Value(enum2Str(priceDiscAdmTransLocValue.relation));
               
                            cell = null;
                            cell = cells.get_Item(currentRow, 5);
                            cell.set_Value(priceDiscAdmTransLocValue.UnitId);
                            cell = null;
                            cell = cells.get_Item(currentRow, 6);
                            cell.set_Value(priceDiscAdmTransLocValue.Amount);
                            cell = null;
                            cell = cells.get_Item(currentRow, 7);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent1);
                            cell = null;
                            cell = cells.get_Item(currentRow, 8);
                            cell.set_Value(priceDiscAdmTransLocValue.Percent2);
                            cell = null;
                            cell = cells.get_Item(currentRow, 9);
                            cell.set_Value(priceDiscAdmTransLocValue.Currency);
                            cell = null;
                            cell = cells.get_Item(currentRow, 10);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.FromDate));
                            cell = null;
                            cell = cells.get_Item(currentRow, 11);
                            cell.set_Value(DateTimeUtil::date(priceDiscAdmTransLocValue.ToDate));
                               
                            cell = null;
                            cell = cells.get_Item(currentRow, 12);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountFrom);
                            cell = null;
                            cell = cells.get_Item(currentRow, 13);
                            cell.set_Value(priceDiscAdmTransLocValue.QuantityAmountTo);
                            cell = null;
                            cell = cells.get_Item(currentRow, 14);
                            cell.set_Value(priceDiscAdmTransLocValue.createdby);
                            cell = null;
                            cell = cells.get_Item(currentRow, 15);
                            cell.set_Value(this.getPostedDate(priceDiscAdmTransLocValue));
                            priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                            priceDiscAdmTrans.doUpdate();
                            tradeAgreementItemRelation.relation             =   priceDiscAdmTransLocValue.relation;
                            tradeAgreementItemRelation.AccountCode          =   priceDiscAdmTransLocValue.AccountCode;
                            tradeAgreementItemRelation.AccountRelation      =   priceDiscAdmTransLocValue.AccountRelation;
                            tradeAgreementItemRelation.ItemCode             =   priceDiscAdmTransLocValue.ItemCode;
                            tradeAgreementItemRelation.insert();
                        }
                    }
                    else
                    {
                        priceDiscAdmTrans.KGSPMIIsProcessed = NoYes::yes;
                        priceDiscAdmTrans.doUpdate();
                    }
                }
            }
            package.Save();
            ttscommit;
            if(isRunningOnBatch())
            {
                integrationDataWriter.exportToBlob(memoryStream, fileName);
            }
            else
            {
                file::SendFileToUser(memoryStream, fileName);
            }
        }
    }
    /// <summary>
    /// Gets a PriceGroupName for a record based on the title fields of the record.
    /// </summary>
    /// <returns>
    /// A PriceGroupName for the specified record.
    /// <param name = "_priceDiscAdmTrans"></param>
    /// <returns></returns>
    public PriceDiscName  getPriceGroupName(PriceDiscAdmTrans    _priceDiscAdmTrans)
    {
        priceDiscAdmTransLoc    =   _priceDiscAdmTrans;//assigning pricediscadmtrans data for fetching the price group name.
        if(priceDiscAdmTransLoc.AccountCode    ==  PriceDiscPartyCodeType::Table)
        {
            return priceDiscAdmTransLoc.AccountRelation;
        }
        else
        {
            //fetching the name instead of the actual price group from pricediscgroup table.
            select priceDiscGroup
                        where priceDiscGroup.GroupId            ==  priceDiscAdmTransLoc.AccountRelation
                            && priceDiscAdmTransLoc.relation    ==  _priceDiscAdmTrans.relation;
            return priceDiscGroup.Name;
        }
    }
    /// <summary>
    /// Gets a PostedDate for a record based on the title fields of the record.
    /// </summary>
    /// <returns>
    /// A PostedDate for the specified record.
    /// <param name = "_priceDiscAdmTrans"></param>
    /// <returns></returns>
    public  TransDate   getPostedDate(PriceDiscAdmTrans     _priceDiscAdmTrans)
    {
        return PriceDiscAdmTable::find(_priceDiscAdmTrans.JournalNum).PostedDate;//fetching the posted date.
    }
}
------------------------------------------------------
5. create a class - Export integrations to Azure blob file share

 using Microsoft.WindowsAzure.Storage.File;
/// <summary>
/// Export integrations to Azure blob file share
/// </summary>
class KGSPMIBlobFileShareDataWriter
{
    KGSPMIIntegrationType                       integrationType;
    CloudFileShare                              fileShare;
    KGSPMIIntegrationDataImportExportSettings   integrationDataImportExportSettings;
    /// <summary>
    /// Construct the object for KGSPMIBlobFileShareDataWriter based on integration type
    /// </summary>
    /// <param name="_integrationType">
    /// Integration type enumeration
    /// </param>
    public static KGSPMIBlobFileShareDataWriter construct(KGSPMIIntegrationType _integrationType)
    {
        KGSPMIBlobFileShareDataWriter integrationDataExport = new KGSPMIBlobFileShareDataWriter();
        integrationDataExport.parmIntegrationType(_integrationType);
        integrationDataExport.fetchBlobSettings();

        return integrationDataExport;
    }
    /// <summary>
    /// Parm method for integration type
    /// </summary>
    /// <param name="_integrationType">
    /// Integration type enumeration
    /// </param>
    public KGSPMIIntegrationType parmIntegrationType(KGSPMIIntegrationType _integrationType = integrationType)
    {
        integrationType = _integrationType;
        return integrationType;
    }
    /// <summary>
    /// Initialyses the blob settings based on integration type
    /// </summary>
    public void fetchBlobSettings()
    {
       
        KGSPMIIntegrationParameters         integrationParameters = KGSPMIIntegrationParameters::find();
        integrationDataImportExportSettings = KGSPMIIntegrationDataImportExportSettings::construct(this.parmIntegrationType());
       
        fileShare = KGSPMIBlobFileShareUtility::connectToFileShare(integrationParameters.BlobConnectionString, integrationParameters.BlobFileShareName);
       
    }
    /// <summary>
    /// Export the file stream to blob file share
    /// </summary>
    /// <param name="_stream">
    /// File stream to export to blob file share
    /// </param>
    /// <param name="_fileName">
    /// Name of the file to be generated
    /// </param>
    public void exportToBlob(System.IO.Stream _stream, str _fileName)
    {     
        KGSPMIBlobFileShareUtility::uploadStreamToFileShare(_stream, fileShare, integrationDataImportExportSettings.parmOutFilePath(), _fileName);
    }
    /// <summary>
    /// Get all the files in a list from blob FileShare path
    /// </summary>
    public  List  getFileList()
    {
        return KGSPMIBlobFileShareUtility::getFileNamesFromFileShare(fileShare, integrationDataImportExportSettings.parmInFilePath());
    }
    /// <summary>
    /// Get specific file from blob FileShare path based on file name
    /// </summary>
    /// <param name="_fileName">
    /// Name of the file to read from blob
    /// </param>
    public  System.IO.Stream  getFileStream(str _fileName)
    {
        return KGSPMIBlobFileShareUtility::downloadFileFromFileShare(fileShare, integrationDataImportExportSettings.parmInFilePath(), _fileName);
    }
    /// <summary>
    /// Moves the file from processing folder to success folder
    /// </summary>
    /// <param name="_fileName">
    /// Name of the file to move to success path
    /// </param>
    public  void  moveToSuccessPath(str _fileName)
    {
        KGSPMIBlobFileShareUtility::movefilefromFileShare(fileShare, fileShare, integrationDataImportExportSettings.parmInFilePath(), integrationDataImportExportSettings.parmSuccessFilePath(), _fileName, _fileName);
    }
    /// <summary>
    /// Moves the file from processing folder to error folder
    /// </summary>
    /// <param name="_fileName">
    /// Name of the file to move to error path
    /// </param>
    public  void  moveToErrorPath(str _fileName)
    {
        KGSPMIBlobFileShareUtility::movefilefromFileShare(fileShare, fileShare, integrationDataImportExportSettings.parmInFilePath(), integrationDataImportExportSettings.parmErrorFilePath(), _fileName, _fileName);
    }
    /// <summary>
    /// Export the file to bob FileShare based on execution from data entity
    /// </summary>
    /// <param name="_definitionGroupId">
    /// Definition group id for data entity job
    /// </param>
    /// <param name="_executionId">
    /// Execution id for data entity job
    /// </param>
    public static void exportToBlobFromDefinitionGroup(DMFDefinitionGroupName _definitionGroupId, DMFExecutionId _executionId)
    {
        DMFEntityName                               entityName;
        DMFEntityExportDetails                      exportDetails;
        DMFEntity                                   dMFEntity;
        DMFDefinitionGroupExecution                 definitionGroupExecution;
        KGSPMIIntegrationParameters                 integrationParameters;
        KGSPMIIntegrationDataImportExportSettings   integrationDataImportExportSettings;
        KGSPMIIntegrationType                       integrationType;
        integrationParameters = KGSPMIIntegrationParameters::find();
        if(integrationParameters.EnableAll)
        {
            select firstonly definitionGroupExecution
                where definitionGroupExecution.ExecutionId  == _executionId &&
                definitionGroupExecution.DefinitionGroup    == _definitionGroupId;
            dMFEntity = DMFEntity::find(definitionGroupExecution.Entity);
            if (dMFEntity.ParentEntityName != '')
            {
                entityName = dMFEntity.ParentEntityName;
            }
            else
            {
                entityName = definitionGroupExecution.Entity;
            }
            if(KGSPMIIntegrationDataImportExportSettings::isPMIIntegration(entityName))
            {
                select firstonly1 SampleFilePath, DefinitionGroup, Entity from exportDetails
                    where exportDetails.DefinitionGroup == _definitionGroupId
                        && exportDetails.ExecutionId == _executionId
                        && exportDetails.Entity == entityName;
                if (exportDetails.RecId && exportDetails.SampleFilePath)
                {
                    integrationType                     = KGSPMIIntegrationDataImportExportSettings::getIntegrationTypeFromDataEntity(entityName);
                    integrationDataImportExportSettings = KGSPMIIntegrationDataImportExportSettings::construct(integrationType);               
                    integrationParameters               = KGSPMIIntegrationParameters::find();
                    CloudFileShare fileShare            = KGSPMIBlobFileShareUtility::connectToFileShare(integrationParameters.BlobConnectionString, integrationParameters.BlobFileShareName);
                    KGSPMIDataEntityBlobFileShareUtility::exportToFileShare(exportDetails, fileShare, integrationDataImportExportSettings.parmOutFilePath());
                }
                else
                {
                    warning(strFmt("@KGSPMI:KGSPMINoExportFileForEntityTxt", entityName, definitionGroupExecution.ExecutionId));
                }
            }
        }
    }
}
--------------------------------
6. Create a class - Utility class for Azure blob file share connection

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.File;
using System.IO;
/// <summary>
/// Utility class for Azure blob file share connection.
/// </summary>
class KGSPMIBlobFileShareUtility
{
    public static CloudFileShare connectToFileShare(str _connectionString, str _fileShareName)
    {
        CloudStorageAccount     storageAccount;     
        CloudFileClient         fileClient;
        CloudFileShare          fileShare;
       
        storageAccount      = CloudStorageAccount::Parse(_connectionString);
        fileClient          = storageAccount.CreateCloudFileClient();
        fileShare           = fileClient.GetShareReference(_fileShareName);
        return fileShare;
    }
    public static void uploadStreamToFileShare(System.IO.Stream _stream, CloudFileShare _fileShare, str _filepath, str _fileName)
    {
        CloudFileDirectory          fileRootDirectory;
        CloudFileDirectory          fileDirectory ;
        CloudFile                   file;
        fileRootDirectory       = _fileShare.GetRootDirectoryReference();
        fileDirectory           = fileRootDirectory.GetDirectoryReference(_filepath);
        file                    = fileDirectory.GetFileReference(_fileName);
       
        file.UploadFromStream(_stream, null, null, null);
    }
    public static void uploadTextToFileShare(str _stringData, CloudFileShare _fileShare, str _filepath, str _fileName, System.Text.Encoding _encoding = null)
    {
        CloudFileDirectory          fileRootDirectory;
        CloudFileDirectory          fileDirectory ;
        CloudFile                   file;
        fileRootDirectory       = _fileShare.GetRootDirectoryReference();
        fileDirectory           = fileRootDirectory.GetDirectoryReference(_filepath);
        file                    = fileDirectory.GetFileReference(_fileName);
       
        file.UploadText(_stringData, _encoding, null, null, null);
    }
    public static list getFileNamesFromFileShare(CloudFileShare _fileShare, str _filepath)
    {
        container                       con;
        List                            filenames           = new List(Types::String);
        CloudFileDirectory              fileRootDirectory   = _fileShare.GetRootDirectoryReference();
        CloudFileDirectory              fileDirectory       = fileRootDirectory.GetDirectoryReference(_filepath);
        System.Collections.IEnumerable  lstEnumarable       = fileDirectory.ListFilesAndDirectories(null, null);
        System.Collections.IEnumerator  lstEnumarator       = lstEnumarable.GetEnumerator();
        while(lstEnumarator.MoveNext())
        {
            IListFileItem item = lstEnumarator.Current;
           
            if(item is CloudFile)
            {
                CloudFile  file = item;
                file.FetchAttributes(null, null, null);
                con = str2con(file.name, "/");
                filenames.addStart(conPeek(con,conlen(con)));
            }
        }
        return filenames;
    }
    public static void movefilefromFileShare(CloudFileShare _srcFileShare, CloudFileShare _dstFileShare,
                                        str _srcFilePath, str _destFilePath, str _srcFilename, str _destFilename)
    {
        CloudFileDirectory          srcfileRootDirectory    = _srcFileShare.GetRootDirectoryReference();
        CloudFileDirectory          srcfileDirectory        = srcfileRootDirectory.GetDirectoryReference(_srcFilePath);
        CloudFileDirectory          dstfileRootDirectory    = _dstFileShare.GetRootDirectoryReference();
        CloudFileDirectory          dstfileDirectory        = dstfileRootDirectory.GetDirectoryReference(_destFilePath);
        CloudFile                   srcfile = srcfileDirectory.GetFileReference(_srcFilename);
        CloudFile                   dstfile = dstfileDirectory.GetFileReference(_destFilename);
       
        dstfile.UploadFromStream(srcfile.OpenRead(null,null,null),null,null,null);
        srcfile.Delete(null,null,null);
    }
    public static System.IO.Stream downloadFileFromFileShare(CloudFileShare _fileShare, str _filepath, str _filename)
    {
        CloudFileDirectory          fileRootDirectory   = _fileShare.GetRootDirectoryReference();
        CloudFileDirectory          fileDirectory       = fileRootDirectory.GetDirectoryReference(_filepath);
        CloudFile                   file                = fileDirectory.GetFileReference(_filename);
        System.IO.Stream            stream              = file.OpenRead(null,null,null);
       
        return stream;
    }
    /// <summary>
    ///
    /// </summary>
    public static MemoryStream convertStringToStream(str _record, System.Text.Encoding _encoding)
    {
        System.Byte[]  byteArray =   new System.Byte[0]();
        if(_encoding == System.Text.Encoding::Unicode)
        {
            byteArray = System.Text.Encoding::Unicode.GetBytes(_record);
        }
        else
        {
            byteArray = System.Text.Encoding::ASCII.GetBytes(_record);
        }
        return  new MemoryStream( byteArray );
    }
}
----------------------------------------------------------


 

Comments

Post a Comment

Popular posts from this blog

Data entites method calling sequence in D365FO

Data entites method calling sequence in D365FO Here is a sequence of method’s calls during export: 1. initValue 2. validateField 3. validateWrite 4. update 4.1. doUpdate 4.1.1. persistEntity 4.1.1.1. doPersistEntity 4.1.1.1.1. initializeDataSources 4.1.1.1.1.1. initializeEntityDataSource Note: initializeDataSource is called once for each DataSource in Entity. 4.1.1.1.2. mapEntityToDataSources Note: initializeDataSource is called once for each DataSource in Entity. 4.1.1.1.3. saveDataSources 4.1.1.1.3.1. updateEntityDataSource 4.1.1.1.4. mapEntityToDataSource (maybe for another record) 4.1.1.1.5. saveDataSources 4.1.1.1.5.1. updateEntityDataSource for update operation and (insertEntityDataSource for insert) 4.1.1.1.5.1.1. mapDataSourceToEntity 4.1.1.1.5.1.2. doSaveDataSource 4.1.1.1.5.1.2.1. updateDataSource 4.1.1.1.5.1.2.1.1. preupInsertDataSource 4.1.1.1.5.1.2.1.1.1. validateWrite of table 5.0 postLoad Plus: postLoad This method is called during the exp...
Read more

How to Extend Sales Order Update Functionality to Custom Fields in D365 Finance and Operations

Image
How to Extend Sales Order Update Functionality to Custom Fields in D365 Finance and Operations by Bill Thompson | Feb 6, 2019 | Dynamics 365 for Finance and Operations , Dynamics AX My colleague Jeremy Dobler wrote this nice article on how to extend sales order update functionality to custom fields in AX 2012 . In this post, I’m going to show how to implement sales order update functionality to custom fields in Dynamics 365 Finance and Operations, and what changes are necessary when comparing to Dynamics AX. Sales Order Update Functionality D365 Finance and Operations vs. Dynamics AX New Fields Jeremy’s article states the following: “Once you have added the fields to the SalesTable and the SalesLine table and exposed the fields on the SalesTable form, add the new custom field to the HeaderToLineUpdate field group on the SalesTable Table.” In D365FO, the new fields will need to be added via a table exten...
Read more

To generate dimension and find the account value - KGSPMIDimensionUtility

KGSPMIDimensionUtility /// <summary> /// Utility class for Dimensions. /// </summary>   class KGSPMIDimensionUtility { public static RefRecId generateDynamicAccount( LedgerJournalACType _type, str _account) { DimensionDynamicAccountServiceProvider dimensionDynamicAccountServiceProvider; DimensionAttributeValueContract ledgerContract; DimensionStorageResult dimensionStorageResult; DimensionDynamicAccountContract contract; contract = new DimensionDynamicAccountContract (); contract.parmAccountType(_type); contract.parmCompany(curExt()); ledgerContract = DimensionAttributeValueContract ::construct(enum2Str(_type), _account); contract.parmPrimaryDimensionAttributeValue(ledgerContract); dimensionDynamicAccountServiceProvider = DimensionDynamicAccountServiceProvider ::newForDynamicAccountContract(contract); dimensionStorageResult = dimensionDynamicAccountServiceProvider.resolve(); return dimens...
Read more