Explore Dynamics World With Krishh

2022-05-23T11:56:00.006+00:00

Create the User into ActiveDirectory

static void CreateADUSER(Args _args)

{

System.DirectoryServices DirectoryServices;

System.DirectoryServices.AccountManagement AccountManagement;

System.DirectoryServices.AccountManagement.UserPrincipal up;

System.DirectoryServices.AccountManagement.PrincipalContext pricipalContext;

str networkDomain="KrishhDAX";

InteropPermission permission;

try

{

permission = new InteropPermission(InteropKind::CLRInterop);

permission.assert();

pricipalContext = new System.DirectoryServices.AccountManagement.PrincipalContext(System.DirectoryServices.AccountManagement.ContextType::Domain, "KRISHHDAX", "OU=mDK,OU=Users,OU=TestOU,DC=KrishhDAX,DC=com");

//Sometimes we need to connect to AD using service/admin account credentials, in that case the above line of code will be as below

//pricipalContext = new PrincipalContext(ContextType.Domain, "yourdomain.com", "OU=TestOU,DC=yourdomain,DC=com","YourAdminUser","YourAdminPassword");

up = new System.DirectoryServices.AccountManagement.UserPrincipal(pricipalContext);

up.set_SamAccountName("krishh");

up.set_DisplayName("krishh Reddy");

up.set_EmailAddress(krishh.009@KRISHHDAX.com);

up.set_GivenName("krishh Reddy");

up.set_UserPrincipalName(krishh.009@KRISHHDAX.com);

up.set_Name("Krishh");

up.set_Surname("Reddy");

up.set_Description("User Created for testing");

up.set_Enabled(True);

up.SetPassword("KRISHHDAX#");

up.Save();

// info(strFmt("User Created %1",up.get_DisplayName()));

CodeAccessPermission::revertAssert();

}

catch(Exception::CLRError)

{

CodeAccessPermission::revertAssert();

info(CLRInterop::getLastException().ToString());

}

Splitting dimension into dimension columns in SQL.

2018-10-22T14:45:00.002+00:00

Getting dimension into splitted values

For ledger dimension
Select Dimension,MainAccount,Claims,Functions,ItemGroup,CostCenter,Market_IC,MTO,Projects,Vendor,Agreement from
(
select DIMENSIONATTRIBUTEVALUECOMBINATION.recid as dimension,DimensionAttribute.name,DimensionAttributeLevelValueAllView.DisplayValue from DIMENSIONATTRIBUTEVALUECOMBINATION
join DimensionAttributeLevelValueAllView on DimensionAttributeLevelValueAllView.VALUECOMBINATIONRECID = DIMENSIONATTRIBUTEVALUECOMBINATION.RECID
join DimensionAttribute on DIMENSIONATTRIBUTE.RecId = DimensionAttributeLevelValueAllView.DIMENSIONATTRIBUTE
where DIMENSIONATTRIBUTEVALUECOMBINATION.MAINACCOUNT!=0
) d
PIVOT
(
MAX(DisplayValue)
FOR Name
IN (MainAccount,Claims,Functions,ItemGroup,CostCenter,Market_IC,MTO,Projects,Vendor,Agreement)
)
AS PivotTable

select DefaultDimension,Claims,Functions,ItemGroup,CostCenter,Market_IC,MTO,Projects,Vendor,Agreement from

(

select DIMENSIONATTRIBUTEVALUECOMBINATION.recid as DefaultDimension,DimensionAttribute.name,DimensionAttributeValueSetItem.DisplayValue from DIMENSIONATTRIBUTEVALUECOMBINATION

join DimensionAttributeValueSet on DimensionAttributeValueSet.RecId = DIMENSIONATTRIBUTEVALUECOMBINATION.RECID

join DimensionAttributeValueSetItem on DimensionAttributeValueSetItem.DIMENSIONATTRIBUTEVALUESET = DimensionAttributeValueSet.RecID

join DimensionAttributeValue on DimensionAttributeValue.RECID = DimensionAttributeValueSetItem.DIMENSIONATTRIBUTEVALUE

join DimensionAttribute on DIMENSIONATTRIBUTE.RecId = DimensionAttributeValue.DIMENSIONATTRIBUTE

where DIMENSIONATTRIBUTEVALUECOMBINATION.MAINACCOUNT=0

) d

PIVOT

(

MAX(DisplayValue)

FOR Name

IN (Claims,Functions,ItemGroup,CostCenter,Market_IC,MTO,Projects,Vendor,Agreement)

)

AS PivotTable

Useful X++ functions

2018-08-24T09:44:00.001+00:00

//Return the value from the xmlNode
static str getXmlNodeValue(XmlNode _node)
{
System.Text.RegularExpressions.Regex re =
// BP deviation documented
new System.Text.RegularExpressions.Regex('^[ \r\n\t]*((.|\n)*?)[ \r\n\t]*$');
System.Text.RegularExpressions.Match m = re.Match(_node.text());
str result;
;

result = m.Result('$1');
return result;
}

/// <summary>
/// Provides a lookup of dimension values.
/// </summary>
/// <param name="_ctrl">The control to provide a lookup for.</param>
/// <param name="_dimensionName">The dimension attribute to filter by.</param>
public static client void lookupDimension(FormStringControl _ctrl, Name _dimensionName)
{
SysTableLookup sysTableLookup = SysTableLookup::newParameters(tablenum(DimensionAttribute),_ctrl);
Query query = new Query();
QueryBuildDataSource queryBuildDataSource = query.addDataSource(tablenum(DimensionAttribute));

sysTableLookup.addLookupfield(fieldnum(DimensionAttribute, Name));

queryBuildDataSource.addRange(fieldnum(DimensionAttribute, Type)).value(queryNotValue(DimensionAttributeType::MainAccount));

sysTableLookup.parmQuery(query);
sysTableLookup.performFormLookup();

}

/// <summary>
/// This method has the complete source file as input and will concatenate the target path with the filename
/// </summary>
/// <param name="_sourceFilename">
/// This is the full filename including the path
/// </param>
/// <param name="_targetPath">
/// the target folder
/// </param>
/// <returns>
/// It will return the target filename.
/// </returns>

static filename getTargetFilename(Filename _sourceFilename, Filepath _targetPath)
{
Filename targetFilename;
;
new InteropPermission(InteropKind::ClrInterop).assert();

targetFilename = System.IO.Path::Combine(_targetPath, System.IO.Path::GetFileName(_sourceFilename));

return targetFilename;
}

// Generate nodes into container.
static container containerFromXMLNode(XmlNode n)
{
container retval, containerToInsert;
Common recordToInsert;
XmlNamedNodeMap attrs;
XmlNode typeAttr, element, recordNode, containerNode;
int elemNo = 1;
;
//validate arguments before using them
if (n == null)
return retval;

// Collect all the elements ...
element = n.firstChild();
if (element.name() == 'container')
{
element = element.firstChild();
}
while (element)
{
attrs = element.attributes();
if (attrs)
{
typeAttr = attrs.getNamedItem('type');

switch (typeAttr.nodeValue())
{
case 'int' :
retval = conins(retval, elemNo, str2int(BisTools::getXmlNodeValue(element)));
break;

case 'str' :
retval = conins(retval, elemNo, BisTools::getXmlNodeValue(element));
break;

case 'real' :
retval = conins(retval, elemNo, str2num(BisTools::getXmlNodeValue(element)));
break;

case 'enum':
retval = conins(retval, elemNo, str2int(BisTools::getXmlNodeValue(element)));
break;

case 'date' :
retval = conins(retval, elemNo, str2date(BisTools::getXmlNodeValue(element), 321));
break;

case 'record' :
recordNode = element.firstChild();
recordToInsert = Global::recordFromXMLNode(recordNode);
retval = conins(retval, elemNo, recordToInsert);
break;

case 'container':
containerNode = element.firstChild();
containerToInsert = BisTools::containerFromXMLNode(containerNode);
retval = conins(retval, elemNo, containerToInsert);
break;

case 'blob':
containerToInsert = BinData::stringToData(BisTools::getXmlNodeValue(element));
retval = conins(retval, elemNo, containerToInsert);
break;
}
}

element = element.nextSibling();
elemNo += 1;
}

return retval;
}

//Generate html from Record
static str record2html(Common record)
{
str html;
DictTable dictTable = new dictTable(record.TableId);
DictField dictField;
fieldId fieldId;

void addField2html(str fieldName, anyType fieldValue, str htmlCode, str fieldLabel)
{
str newValue = strFmt('%1',fieldValue);
if (newValue == '')
{
newValue = '-';
}
html += strFmt('<tr><td width=30%>%3%4</td><td width=50%>%3%2</td><td width=20%>%3%1</td></tr>',fieldName, newValue , htmlCode, fieldLabel);
}
;
html = '<html><b>Record values<table border width=100%>';
addField2html('Field name','Value','<b>','Label');

fieldId = dictTable.fieldNext(0);
while (fieldId)
{
dictField = dictTable.fieldObject(fieldId);
if (dictField.arraySize() == 1 && dictField.baseType() != Types::Container && dictField.baseType() != Types::BLOB)
{
addField2html(dictField.name(), record.(fieldId),"", dictField.label());
}
fieldId = dictTable.fieldNext(fieldId);
}

html+='</table></html>';
return html;
}

//Generate record to Text
static str record2text(Common record)
{
str text;
DictTable dictTable = new dictTable(record.TableId);
DictField dictField;
fieldId fieldId;

void addField2text(str fieldName, anyType fieldValue, str fieldLabel)
{
str newValue = strFmt('%1',fieldValue);
if (newValue == '')
{
newValue = '-';
}
text += strFmt('Field \'%1\' = \'%2\', Label: \'%3\'\n',fieldName, newValue, fieldLabel);
}
;
text = strFmt("@BIS635", tableid2name(record.tableId));
addField2text('Field name','Value', 'Label');

fieldId = dictTable.fieldNext(0);
while (fieldId)
{
dictField = dictTable.fieldObject(fieldId);
if (dictField.arraySize() == 1)
{
addField2text(dictField.name(), record.(fieldId), dictField.label());
}
fieldId = dictTable.fieldNext(fieldId);
}

return text;
}

//Create the table record from xmlnode
// Input is <Record table="name"> <Field:field1> value </Field:field1> ... </Record>
// it's the opposite from record.xml() method
static Common xml2record(XmlNode n, Common c = null)
{
tableId table;
fieldId field;
DictTable dt;
DictField df;
XmlNode fieldNode;
str fieldName;
Struct content;
str tableName;
Types t;

//validate arguments before using them
if (n == null)
return null;
// If we don't have an incoming buffer, one is created
if (prmisdefault(c))
{
// Create a buffer of the correct type
tableName = n.name();
// tableName = n.attributes().getNamedItem('name');

// Check if table node can be accessed
if (tableName != '')
{
table = tablename2id(tableName);
dt = new DictTable(table);
c = dt.makeRecord();
}
}
else
{
table = c.TableId;
dt = new DictTable(table);
}

fieldNode = n.firstChild();
while (fieldNode)
{
fieldName = fieldNode.attributes().getNamedItem('name').text();
field = dt.fieldName2Id(fieldName);
df = new DictField(table, field);

t = df.baseType();
if (t == Types::Enum) //Enums need to be treated as Integers. By defult, Enums are getting treated as a boolean and hence loosing its value.
t = Types::Integer;

content = BisTools::valueFromXMLNode (t, fieldNode);

c.(field) = content.value('value');

fieldNode = fieldNode.nextSibling();
}
return c;
}

//Get next working date from the date .
public static date GetNextWorkDay(date _fromDate)
{
WorkCalendarDate workCalendar;
;

select firstOnly TransDate from workCalendar
order by TransDate ASC
where workCalendar.TransDate > _fromDate
&& workCalendar.WorkTimeControl == WorkTimeControl::Open;

return workCalendar.TransDate;
}

/// <summary>
/// Attempts to find executatble for file type specified, and open file with it.
/// </summary>
/// <param name="_filename">
/// File name to show
/// </param>
public static client void showFile(Filename _filename)
{
str filePath, fileName, fileExt, executable;
if (System.IO.File::Exists(_filename))
{
[filePath, filename, fileExt] = fileNameSplit(_filename);
executable = WinAPI::findExecutable(_filename);
if (!executable)
{
error(strFmt("Windows were not able to find executable for file %1", _filename));
return;
}
if (fileExt == '.msg')
WinAPI::shellExecute(strFmt('"%1"', executable),strFmt('/f "%1"', _filename),strFmt('"%1"', filePath)); // outlook requires extra parameter /f
else
WinAPI::shellExecute(strFmt('"%1"', executable),strFmt('"%1"', _filename),strFmt('"%1"', filePath));
}
else
{
error("File not found");
}
}

/// <summary>
/// Converts enum value to enum label in language specified
/// </summary>
/// <param name="enumId">
/// Enum Id
/// </param>
/// <param name="value">
/// Enum value
/// </param>
/// <param name="languageId">
/// Language for label
/// </param>
/// <returns>
/// Label of enum value in language specified
/// </returns>
public static str enum2Label(EnumId enumId, int value, LanguageId languageId = SrsReportRunUtil::getCurrentUserLangId())
{
DictEnum dictEnum;
int valueIndex, valueBuf;
;
dictEnum = new DictEnum(enumId);
if (dictEnum)
{

for (valueIndex = 0 ; valueIndex < dictEnum.values(); valueIndex++)
{
valueBuf = dictEnum.index2Value(valueIndex);
if (valueBuf == value)
return SysLabel::labelId2String(dictEnum.index2LabelId(valueIndex), languageId);
}
}
return '';
}

/// <summary>
/// Converts time value into string with hours and minutes. Mostly used when generating file names
/// </summary>
/// <param name="time">
/// Time as integer
/// </param>
/// <returns>
/// Time converted to string in format HHMM
/// </returns>
public static TempStr time2StrHM(int time)
{
return num2str( time div 3600 ,2,0,0,0) + num2Str0(time mod 3600 div 60,2,0,0,0);
}

/// <summary>
/// Converts any value to string. This is hardcoded conversion without using culture context
/// </summary>
/// <param name="_value">
/// The value to convert
/// </param>
/// <returns>
/// Converted value as string
/// </returns>
public static str any2String(anytype _value)
{
switch(typeOf(_value))
{
// BP deviation documented
case Types::Date: return date2str(_value, -1,-1,-1,-1,-1,-1,DateFlags::None);
case Types::Time: return KrishhUtils::time2StrHM(_value);
case Types::Int64, Types::Integer: return int2str(_value);
case Types::Real: return strFmt('%1', _value);
case Types::Enum: return strFmt('%1', _value);
case Types::UtcDateTime: return DateTimeUtil::toStr(DateTimeUtil::applyTimeZoneOffset(_value, DateTimeUtil::getUserPreferredTimeZone())); // Hotfix 52
default: return strFmt('%1', _value);
}
return "";
}

/// <summary>
/// Checks full path, and if \ is missing at the end - adds it
/// </summary>
/// <param name="path">
/// Full path to analyse
/// </param>
/// <returns>
/// Full path with \ at the end
/// </returns>
public static str fixPath(str path)
{
str buf = strLRTrim(path);
if (!path)
return "";
if (subStr(buf, strLen(buf),1) != '\\')
buf = buf + '\\';
return buf;
}

/// <summary>
/// Generates temporrary file with extension. Also creates file and saves it.
/// </summary>
/// <param name="filePrefix">
/// File prefix to use
/// </param>
/// <param name="extension">
/// Extension to use
/// </param>
/// <param name="filePath">
/// File path to use
/// </param>
/// <returns>
/// Created temporrary file name
/// </returns>
/// <remarks>
/// Creates empty file with unique name. Safe to use with multiple threads
/// </remarks>
/// <exception cref="Exception::Error">
/// When 10 attempts to create file failed
/// </exception>
/// <exception cref="Exception::Error">
/// When 10 attempts to create file failed
/// </exception>
public static str getTempFile(str filePrefix, str extension, str filePath = '')
{
#File
str tmpPath;
str fileName;
System.IO.FileStream fileStream;
boolean ok;
int i;

if (filePath)
tmpPath = KrishhUtils::fixPath(filePath);
else
{
new InteropPermission(InteropKind::ClrInterop).assert();
tmpPath = System.IO.Path::GetTempPath();
CodeAccessPermission::revertAssert();
}
while(!ok)
{
fileName = tmpPath + (filePrefix?filePrefix:filePrefix + guid2str(newGuid())) + extension; // First attempt direct
new InteropPermission(InteropKind::ClrInterop).assert();
while(System.IO.File::Exists(fileName))
{
fileName = tmpPath + filePrefix + guid2str(newGuid()) + extension;
}
CodeAccessPermission::revertAssert();
try
{
i++;
if (i>10)
throw Exception::Error;
new FileIOPermission(fileName, #IO_WRITE).assert();
fileStream = System.IO.File::Create(fileName);
fileStream.Dispose();
CodeAccessPermission::revertAssert();
ok = true;
}
catch (Exception::Error)
{
throw error("@SYS326095");
}
catch
{
exceptionTextFallThrough();
CodeAccessPermission::revertAssert();
}
}

return fileName;
}

/// <summary>
/// Returns the number associated with the specified month name.
/// </summary>
/// <param name="_monthName">
/// The name of the month.
/// </param>
/// <returns>
/// The number associated with the month name.
/// </returns>
public static int monthUSName2Num(str _monthName)
{
int ret;
str monthName = _monthName;
#Define.month1('january')
#Define.jan('jan')
#Define.month2('february')
#Define.feb('feb')
#Define.month3('march')
#Define.mar('mar')
#Define.month4('april')
#Define.apr('apr')
#Define.month5('may')
#Define.month6('june')
#Define.jun('jun')
#Define.month7('july')
#Define.jul('jul')
#Define.month8('august')
#Define.aug('aug')
#Define.month9('september')
#Define.sep('sep')
#Define.month10('october')
#Define.oct('oct')
#Define.month11('november')
#Define.nov('nov')
#Define.month12('december')
#Define.dec('dec');

monthName = strLwr(_monthName);

switch(monthName)
{
case #month1:
case #jan:
ret = 1;
break;
case #month2:
case #feb:
ret = 2;
break;
case #month3:
case #mar:
ret = 3;
break;
case #month4:
case #apr:
ret = 4;
break;
case #month5:
ret = 5;
break;
case #month6:
case #jun:
ret = 6;
break;
case #month7:
case #jul:
ret = 7;
break;
case #month8:
case #aug:
ret = 8;
break;
case #month9:
case #sep:
ret = 9;
break;
case #month10:
case #oct:
ret = 10;
break;
case #month11:
case #nov:
ret = 11;
break;
case #month12:
case #dec:
ret = 12;
break;
default:
ret = 0;
break;
}
return ret;
}

Get DimensionAttribute by providing the dimensionnumber

2018-08-24T09:33:00.001+00:00

public static dimensionAttribute getDimensionByNumber(int _dimensionNumber)
{
RecId companyLedger = Ledger::findByLegalEntity(CompanyInfo::findDataArea(curext()).RecId).RecId;
DimensionAttribute dimensionAttribute;
Query query = new Query();
QueryBuildDataSource qbd;
QueryRun qr;
;
if (! _dimensionNumber)
{
return dimensionAttribute;
}
qbd = query.addDataSource(tableNum(dimensionAttribute));
qbd.fields().dynamic(false);
qbd.fields().addField(fieldNum(dimensionAttribute, Name));
qbd.addOrderByField(fieldNum(dimensionAttribute, Name));
qbd.addGroupByField(fieldNum(dimensionAttribute, Name));
qbd.addRange(fieldNum(dimensionAttribute, RecId)).value(queryNotValue(DimensionAttribute::getMainAccountDimensionAttribute()));
qbd = qbd.addDataSource(tableNum(dimensionHierarchyLevel));
qbd.fields().dynamic(true);
qbd.relations(true);

qbd = qbd.addDataSource(tableNum(ledgerStructure));
qbd.relations(false);
qbd.addLink(fieldNum(dimensionHierarchyLevel, DimensionHierarchy), fieldNum(ledgerStructure, DimensionHierarchy));
qbd.addRange(fieldNum(ledgerStructure, Ledger)).value(queryvalue(companyLedger));

qr = new QueryRun(query);
qr.enablePositionPaging(true);
qr.addPageRange(_dimensionNumber,1);
if (qr.next())
{
dimensionAttribute = qr.getNo(1);
}
return dimensionAttribute;
}

Create Non clusterindex in Ax with include keyword.

2018-05-30T13:04:00.001+00:00

Create non clustered index with include keyword suggestion given by query plan

Index with Included Columns
You can extend the functionality of nonclustered indexes by adding nonkey columns to the leaf level of the nonclustered index. By including nonkey columns, you can create nonclustered indexes that cover more queries. This is because the nonkey columns have the following benefits:
• They can be data types not allowed as index key columns.
• They are not considered by the Database Engine when calculating the number of index key columns or index key size.
An index with included nonkey columns can significantly improve query performance when all columns in the query are included in the index either as key or nonkey columns. Performance gains are achieved because the query optimizer can locate all the column values within the index; table or clustered index data is not accessed resulting in fewer disk I/O operations.

Issue

Whenever a synchronization is done, AX overwrites the indexes which we put through SQL

Resolution

a. Created the index via AX as a table method

public static server void createSqlIndexes()
{

SqlStatementExecutePermission SqlStatementExecutePermission;
str createIndexSql;

Connection connection=new Connection(); Statement statement=connection.createStatement();
createIndexSql=
@"IF EXISTS(select * from sys.indexes where object_id=OBJECT_ID(N'[dbo].[InventDIM]')

AND NAME=N'sonIdx' )
DROP INDEX [sonIdx] on [dbo].[InventDIM] WITH (ONLINE=OFF)
CREATE NONCLUSTERED INDEX [sonIdx] ON [dbo].[INVENTDIM] ([INVENTBATCHID],[WMSLOCATIONID],[INVENTSERIALID],[INVENTSIZEID],[INVENTCOLORID],[INVENTGTDID_RU],[INVENTPROFILEID_RU],[INVENTOWNERID_RU],[INVENTSTYLEID],[LICENSEPLATEID],[INVENTSTATUSID],[DATAAREAID],[PARTITION],[INVENTLOCATIONID],[CONFIGID],[INVENTSITEID])
INCLUDE ([INVENTDIMID])
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, IGNORE_DUP_KEY = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)";

SqlStatementExecutePermission=new SqlStatementExecutePermission(createIndexSql);
SqlStatementExecutePermission.assert();
statement.executeUpdate(createIndexSql);
CodeAccessPermission::revertAssert();
}

Execute this code in the application class dbsynchronize method at the end of the method after standard dbsynch done. so that we will have an sql index.

Read xml file with namespace

2017-07-17T11:14:00.003+00:00

static void krishh_samplexmlread(Args _args)
{
XmlNode root;
XmlNode book;
XmlNodeList books;
XmlNamespaceManager nsmgr;

XmlDocument doc = new XmlDocument();
int i=1;
doc.Load(@"C:\Temp\book.xml");

//Create an XmlNamespaceManager for resolving namespaces.
nsmgr = new XmlNamespaceManager(doc.NameTable());
nsmgr.AddNamespace("bk", "urn:samples");

//Select the book node with the matching attribute value.

root = doc.DocumentElement();

books = root.selectNodes("descendant::book", nsmgr);
for (i = 0; i < books.length(); i++)
{
book = books.item(i);
info(book.selectSingleNode("bk:first-name").text());
info(book.selectSingleNode("bk:last-name").text());

}

}

//<?xml version="1.0"?>
//
//
//
//-<bookstore xmlns:bk="urn:samples">
//
//
//-<book bk:ISBN="1-861001-57-8" publicationdate="1997" genre="novel">
//
//<title>Pride And Prejudice</title>
//
//
//-<author>
//
//<first-name>Jane</first-name>
//
//<last-name>Austen</last-name>
//
//</author>
//
//<price>24.95</price>
//
//</book>
//
//
//-<book bk:ISBN="1-861002-30-1" publicationdate="1992" genre="novel">
//
//<title>The Handmaid's Tale</title>
//
//
//-<author>
//
//<first-name>Margaret</first-name>
//
//<last-name>Atwood</last-name>
//
//</author>
//
//<price>29.95</price>
//
//</book>
//
//
//-<book bk:ISBN="1-861001-57-6" publicationdate="1991" genre="novel">
//
//<title>Emma</title>
//
//
//-<author>
//
//<first-name>Jane</first-name>
//
//<last-name>Austen</last-name>
//
//</author>
//
//<price>19.95</price>
//
//</book>

//-<book bk:ISBN="1-861001-45-3" publicationdate="1982" genre="novel">
//
//<title>Sense and Sensibility</title>
//
//
//-<author>
//
//<first-name>Jane</first-name>
//
//<last-name>Austen</last-name>
//
//</author>
//
//<price>19.95</price>
//
//</book>
//
//</bookstore>

AX2012 Run AIF Single Message manually

2017-04-20T10:14:00.001+00:00

Execute single message for inbound without executing all inbound ports.

class Krishh_InboundParallelMsgProcessPerMsgId extends AifInboundParallelMsgProcess
{
RecId gatewayQueueRecId;
DialogField dlgfRecId;
AifMessageId messageId;
}

protected Object dialog()
{
DialogRunbase dialogRunbase;

dialogRunbase = super();
dialogRunbase.caption(AifInboundParallelMsgProcess::description());

dialogRunbase.addText("Runbase framework doesnt allow Guid type fields");
dialogRunbase.addText("reference field shows the gatewayqueue record");

dlgfRecId = dialogRunbase.addField(extendedTypeStr(AifGatewayQueueRecId));
dlgfRecId.lookupButton(2);

return dialogRunbase;
}

public AifGatewayQueue findGatewayQueue(RecId _recId)
{
AifGatewayQueue aifGatewayQueue;

select aifGatewayQueue
where aifGatewayQueue.RecId == _recId;

return aifGatewayQueue;
}

public boolean getFromDialog()
{
boolean ret;

ret = super();

gateWayQueueRecId = dlgfRecId.value();

return ret;
}

public AifMessageId parmMessageId(AifMessageId _messageId = messageId)
{
messageId = _messageId;

return messageId;
}

public void run()
{
if (gatewayQueueRecId != 0 && messageId == emptyGuid())
{
messageId = this.findGatewayQueue(gateWayQueueRecId).MessageId;
}

try
{
ttsBegin;

if (messageId != emptyGuid())
{
this.runSingleMsgId(messageId);
AifQueueManager::createQueueManagerData();
}
else
{
throw error ("invalid message id please enter valid messageid");
}

ttsCommit;
}
catch
{
throw error("process has been aborted");
}
}

private void runSingleMsgId(AifMessageId _messageId)
{
AifGatewayQueue gatewayQueue;
AifInboundMsgProcess inboundMsgProcess;
AifResourceLockId resourceLockId;
;

setprefix(classstr(InboundParallelMsgProcessPerMsgId) + '-' + methodstr(Krishh_InboundParallelMsgProcessPerMsgId , run));

select firstOnly gatewayQueue
where gatewayQueue.MessageId == _messageId;

if (gatewayQueue)
{
resourceLockId = AifResourceLock::lockResource(guid2str(gatewayQueue.MessageId),
AifResourceType::Message,
AifResourceLockType::DocumentService);

// Process message only if lock is created.
if(resourceLockId)
{
AifResourceIdMap::createMsgResourceMap(guid2str(gatewayQueue.MessageId), gatewayQueue.MessageId);

// remember selected record
inboundMsgProcess = new AifInboundMsgProcess(gatewayQueue.data(), resourceLockId);

inboundMsgProcess.run();
}
}
}

public boolean validate(Object calledFrom = null)
{
boolean ret;

ret = super(calledFrom);

if (this.findGatewayQueue(gateWayQueueRecId).RecId == 0)
{
throw error("Queue not found");
}

return ret;
}

public static Krishh_InboundParallelMsgProcessPerMsgId construct()
{
return new Krishh_InboundParallelMsgProcessPerMsgId ();
}

public static void main(Args args)
{
Krishh_InboundParallelMsgProcessPerMsgId inboundParallelMsgProcessPerMsgId;

inboundParallelMsgProcessPerMsgId = Krishh_InboundParallelMsgProcessPerMsgId ::construct();

if (inboundParallelMsgProcessPerMsgId.prompt())
{
inboundParallelMsgProcessPerMsgId.run();
}
}

AX2012 Actiavte/Deactivate Ports using X++

2017-04-20T09:30:00.004+00:00

create enum 1. AIFPortActivorDeactive with Acivate,Decativate as enumvalues.
2. AIF portType with inbound and Outbound as enumvalues.

class krishhAIFPortsUtil extends RunBaseBatch
{
Map serviceStatusMap;
Map portWsdlUrlMap;
AIFPortActivorDeactive portActiveorDeactive;
AIFPortType aifPortType;

DialogField dlgActiveorDeactive;
DialogField dlgaifPortType;

#define.CurrentVersion(1)
#define.Version1(1)
#localmacro.CurrentList
portActiveorDeactive,
aifPortType
#endmacro
}

private void deployInboundPort(AifInboundPort port)
{
startLengthyOperation();
AifPortManager::deployPort(port.Name);
this.updateServiceHostStatus();
endLengthyOperation();
}

private void deployOutboundPort(AifOutboundPort port)
{
startLengthyOperation();
AifPortManager::deployPort(port.Name);
endLengthyOperation();
}

public Object dialog()
{
DialogRunbase dialog = super();
#resAppl
;

dlgActiveorDeactive=dialog.addField(enumStr(AIFPortActivorDeactive), "Activate/Deactivate");
dlgaifPortType=dialog.addField(enumStr(AIFPortType), "PortType");
return dialog;
}

public boolean getFromDialog()
{
;
portActiveorDeactive=dlgActiveorDeactive.value();
aifPortType=dlgaifPortType.value();
return super();
}

str getPortRuntimeError(AifInboundPort port)
{
str serviceTypeName, status;
boolean isPortStarted = false;
#Aif

if (port.Deployed)
{
serviceTypeName = strFmt('%1.%2', #DotNetServiceNamespace, port.Name);

if (!serviceStatusMap)
{
// If the map is null, then the IL appDomain does not exist and services are not available
status = strFmt("@SYS345108");
}
else if (serviceStatusMap.exists(serviceTypeName))
{
status = serviceStatusMap.lookup(serviceTypeName);
isPortStarted = strStartsWith(status, #WcfCommunicationState_Opened);
}
}

return isPortStarted?"":status;
}

// BP deviation documented
str getPortWsdlUrl(AifInboundPort port)
{
str wsdlUrl = '';
AifPortName portName;
AifWcfAdapter wcfAdapter;

if (port.Deployed)
{
portName = port.Name;

if (portWsdlUrlMap.exists(portName))
{
wsdlUrl = portWsdlUrlMap.lookup(portName);
}
else
{
wcfAdapter = AifWcfAdapter::getWcfAdapterForPort(port);

if (wcfAdapter != null)
{
wsdlUrl = wcfAdapter.getWsdlUrl(port.ChannelId, port.Name);
}

portWsdlUrlMap.insert(portName, wsdlUrl);
}
}

return wsdlUrl;
}

// BP deviation documented
boolean isPortRunning(AifInboundPort port)
{
str serviceTypeName, status;
boolean isPortStarted = false;
#Aif

if (port.Deployed)
{
serviceTypeName = strFmt('%1.%2', #DotNetServiceNamespace, port.Name);

// If the map is null, then the IL appDomain does not exist and services are not available
if (serviceStatusMap && serviceStatusMap.exists(serviceTypeName))
{
status = serviceStatusMap.lookup(serviceTypeName);
isPortStarted = strStartsWith(status, #WcfCommunicationState_Opened);
}
}

return isPortStarted;
}

public container pack()
{
return [#CurrentVersion,#CurrentList];
}

public boolean unpack(container packedClass)
{
Version version = RunBase::getVersion(packedClass);
;
switch (version)
{
case #CurrentVersion:
[version,#CurrentList] = packedClass;
break;
default:
return false;
}

return true;
}

public AIFPortType parmAifPortType(AIFPortType _aifPortType = aifPortType)
{
aifPortType = _aifPortType;

return aifPortType;
}

public AIFPortActivorDeactive parmPortActiveorDeactive(AIFPortActivorDeactive _portActiveorDeactive = portActiveorDeactive)
{
portActiveorDeactive = _portActiveorDeactive;

return portActiveorDeactive;
}

public void portinit()
{
AifSetup::initialize();
// Register out of the box adapters
AifSetup::registerOutOfTheBoxAdapters();

portWsdlUrlMap = new Map(Types::String, Types::String);
}

/// <summary>
/// Contains the code that does the actual job of the class.
/// </summary>
public void run()
{
#OCCRetryCount
AifInboundPort AifInboundPort;

AifOutboundPort AifOutboundPort;

try
{
this.updateServiceHostStatus();
switch (aifPortType)
{
case AIFPortType::Inbound:
if(AIFPortActivorDeactive::Activate==portActiveorDeactive)
{
while select AifInboundPort //where AifInboundPort.PortCategory==AifPortCategory::Enhanced
{

if(this.isPortRunning(AifInboundPort))
{
this.portinit();
this.deployInboundPort(AifInboundPort);
if(this.getPortRuntimeError(AifInboundPort)!="")
{
info(strFmt("@krishh1896",AifInboundPort.Name,this.getPortRuntimeError(AifInboundPort)));
}
}
}
}
else
{
while select AifInboundPort where AifInboundPort.PortCategory==AifPortCategory::Enhanced
{
this.portinit();
this.undeployInboundPort(AifInboundPort);
}
}
break;
case AIFPortType::OutBound:
if(IFPortActivorDeactive::Activate==portActiveorDeactive)
{
while select AifOutboundPort
{
this.portinit();
this.deployOutboundPort(AifOutboundPort);

}
}
else
{
while select AifOutboundPort
{
this.portinit();
this.unDeployOutboundPort(AifOutboundPort);
}
}
break;
default:
throw error(strfmt("@SYS12580",aifPortType));

}
}
catch (Exception::Deadlock)
{
retry;
}
catch (Exception::UpdateConflict)
{
if (appl.ttsLevel() == 0)
{
if (xSession::currentRetryCount() >= #RetryNum)
{
throw Exception::UpdateConflictNotRecovered;
}
else
{
retry;
}
}
else
{
throw Exception::UpdateConflict;
}
}

}

private void undeployInboundPort(AifInboundPort port)
{
startLengthyOperation();
AifPortManager::undeployPort(port.Name);
this.updateServiceHostStatus();
//this.clearPortWsdlUrl(port);
endLengthyOperation();
}

private void unDeployOutboundPort(AifOutboundPort port)
{
startLengthyOperation();
AifPortManager::undeployPort(port.Name);
endLengthyOperation();
}

public void updateServiceHostStatus()

{

// If the map is null, then the IL appDomain does not exist and services are not available

serviceStatusMap = appl.getServiceHostStatus();

}

static krishhAIFPortsUtil construct()

{

return new krishhAIFPortsUtil();

}

public static void main(Args _args)

{

krishhAIFPortsUtil krishhAIFPortsUtil ;

;

krishhAIFPortsUtil = krishhAIFPortsUtil ::construct();

if (krishhAIFPortsUtil .prompt())

krishhAIFPortsUtil .run();

}

public static void mainAutoRun(str _args)

{

krishhAIFPortsUtil aifPortsUtil;

;

aifPortsUtil = krishhAIFPortsUtil ::construct();

if (!_args)

return;

switch(_args)

{

case('activate') :

{

aifPortsUtil.parmPortActiveorDeactive(AIFPortActivorDeactive::Activate);

}

case('deactivate') :

{

aifPortsUtil.parmPortActiveorDeactive(AIFPortActivorDeactive::Deactivate);

}

aifPortsUtil.run();

}

AX2012 Export ActiveDirectory Data to file.

2017-04-20T09:17:00.001+00:00

Created the framework class called ADReader which reads the data from ActiveDirectory of current domains in the nework that connected.

static void krishh_ADExportToCSV(Args _args)
{
AxaptaUserManager mgr;
container domainNames;
int i;
int domainCount;
str name;
System.Collections.ArrayList domains = new System.Collections.ArrayList();

TextIo ioData;
FileIOPermission permission;
str filename = "c:\\temp\\tmotest_"+FileUtil::createFilenameTimeStamp()+".csv";

ADReader adReader = new ADReader();
map costcenter = new Map(types::String, types::String);
str key;

#File

permission = new FileIOPermission(filename, #io_write);
permission.assert();

// Open file for writing
ioData = new TextIo(filename, #io_write);

// Check file open status
if (!ioData)
{
// File '%1' could not be opened.
throw error(strfmt("@SYS19312", filename));
}

// Set file delimiters
ioData.outRecordDelimiter('\r\n');
ioData.outFieldDelimiter(';');
ioData.write(
[
"Domain"
, "Company"
, "Country"
, "DepartmentNumber"
, "EmployeeType"
, "Mail"
, "Manager"
, "Manager_Converted"
, "GivenName"
, "Sn"
, "TelephoneNumber"
, "UserId"
, "samAccountName"
, "EmployeeNumber"
, "EmployeeNumber_Converted"
, "Disabled"
, "MemberOf"
, "ADGroups"
]);

mgr = new AxaptaUserManager();
// Get the names of the domains from the kernel class
domainNames = mgr.enumerateDomains('');
if(domainNames)
{
domainCount = conLen(domainNames);
// Add all the domain names to the domains combo box
// dual loop to sort the domains alphabetically using the default comparator
if(domainCount > 0)
{
domains.Clear();
for(i = 0; i < domainCount; i++)
{
if (conPeek(domainNames, i+1) == "Krishhdax.com")
{
adReader.reset();
adReader.parmSelectedDomainName(conPeek(domainNames, i+1));

while(adReader.next())
{
if ( adReader.getEmployeeType() == "Employee Master Account"
|| adReader.getEmployeeType() == "Consultant Master Account")
{
ioData.write(
[
adReader.parmSelectedDomainName()
, adReader.getCompany()
, adReader.getCountry()
, adReader.getDepartmentNumber()
, adReader.getEmployeeType()
, adReader.getMail()
, adReader.getManager()
, subStr(adReader.getManager()
, strfind(adReader.getManager(), "CN=", 1, strLen(adReader.getManager()))+3
, strfind(adReader.getManager(), ",", strfind(adReader.getManager(), "CN=", 1, strLen(adReader.getManager())), strLen(adReader.getManager())) - strfind(adReader.getManager(), "CN=",1 , strLen(adReader.getManager())) - 3
)
, adReader.getGivenName()
, adReader.getSn()
, adReader.getTelephoneNumber()
, adReader.getUserId()
, adReader.getsamAccountName()
, adReader.getEmployeeNumber()
, subStr(adReader.getEmployeeNumber(), 4, 255)
, adReader.getDisabled()
, con2Str(adReader.getMemberOf())
, con2Str(adReader.getADGroups())
]);
}
}
}
}
}
}

CodeAccessPermission::revertAssert();
}

class ADReader
{
System.DirectoryServices.DirectorySearcher directorySearcher;
System.DirectoryServices.SearchResultCollection searchResultCollection;
System.DirectoryServices.SearchResult searchResult;
System.DirectoryServices.DirectoryEntry entry;
System.DirectoryServices.PropertyValueCollection propertyValueCollection;
System.DirectoryServices.SearchScope searchScope;
str selectedDomainName;
str prefix;
str criteria;
Filename filename;

System.Collections.Specialized.StringCollection propertyList;
System.DirectoryServices.PropertyCollection propertyCollection;
int numberOfUsers, currentUserNumber;

NetworkAlias networkAlias;
Description company;
Description department;
Description title;
Email mail;
Name givenName;
str manager, departmentNumber, telephoneNumber, userId, sn, employeeType, employeeNumber, country, samAccountName;
container memberOf, adGroups;
Integer userAccountControl;

}
public container getADGroups()
{
str memberOfStr, searchStr;
Counter pos, posCount;

Counter posFrom, posTo, searchStrLen;

if (!ADGroups)
{
searchStr = 'CN=';
searchStrLen = strLen(searchStr);

posCount = conlen(memberOf);
for (Pos=1; pos<=posCount;pos++)
{
memberOfStr = conpeek(memberOf, pos);

posTo = 0;
posFrom = strScan(memberOfStr, searchStr, posTo, strLen(memberOfStr));
while (posFrom)
{
posTo = strScan(memberOfStr, ',', posFrom, strLen(memberOfStr));
ADGroups += [subStr(memberOfStr, posFrom+searchStrLen, posTo-posFrom-searchStrLen)];
posFrom = strScan(memberOfStr, searchStr, posTo, strLen(memberOfStr));
}
}
}

return ADGroups;
}
private void setSearchPropertyList(System.DirectoryServices.DirectorySearcher _directorySearcher)
{
propertyList = _directorySearcher.get_PropertiesToLoad();
propertyList.Add('samaccountname');
propertyList.Add('company');
propertyList.Add('department');
propertyList.Add('title');
propertyList.Add('displayName');
propertyList.Add('distinguishedName');
propertyList.Add('objectClass');
propertyList.Add('member');
propertyList.Add('manager');
propertyList.Add('mail');
propertyList.Add('telephoneNumber');
propertyList.Add('Userid');
propertyList.Add('sn');
propertyList.Add('EmployeeType');
propertyList.Add('employeeNumber');
propertyList.Add('c');
propertyList.Add('samAccountName');
}

public boolean next()
{
Counter pos, posCount;
str memberOfStr;
CLRObject clrenumerator;

networkAlias = "";
company = "";
department = "";
title = "";
mail = "";
givenName = "";
manager = "";
departmentNumber = "";
telephoneNumber = "";
userId = "";
sn = "";
employeeType = "";
adGroups = conNull();
memberOf = conNull();

try
{
if (currentUserNumber == 0 && searchResultCollection == null)
{
prefix = 'LDAP://';
searchScope = System.DirectoryServices.SearchScope::Subtree;

entry = new System.DirectoryServices.DirectoryEntry(prefix+selectedDomainName);

directorySearcher = new System.DirectoryServices.DirectorySearcher(entry);

directorySearcher.set_PageSize(65535);
directorySearcher.set_CacheResults(false);
directorySearcher.set_SearchScope(searchScope);

directorySearcher.set_Filter(strFmt('(&(objectClass=user)(objectCategory=person)%1(userAccountControl:1.2.840.113556.1.4.803:=512))', criteria));
this.setSearchPropertyList(directorySearcher);

searchResultCollection = directorySearcher.FindAll();
numberOfUsers = searchResultCollection.get_Count();
}

do
{
currentUserNumber++;

if (currentUserNumber > numberOfUsers)
{
return false;
}

searchResult = searchResultCollection.get_Item(currentUserNumber-1);
entry = searchResult.GetDirectoryEntry();

if (entry)
{
PropertyCollection = entry.get_Properties();
}

if (!PropertyCollection)
{
entry.Dispose();
}
}
while (!PropertyCollection);

propertyValueCollection = PropertyCollection.get_Item('samaccountname');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
NetworkAlias = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('company');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

company = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('telephoneNumber');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

telephoneNumber = PropertyValueCollection.get_Value();
telephoneNumber = telephoneNumber; //str2int(telephoneNumber)==0 ? "" : telephoneNumber;
}
}

PropertyValueCollection = propertyCollection.get_Item('department');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

department = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('departmentNumber');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

departmentNumber = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('title');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{
title = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('mail');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{
mail = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('givenName');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

givenName = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('Userid');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

UserId = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('EmployeeNumber');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

employeeNumber = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('sn');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

sn = PropertyValueCollection.get_Value();
}
}

PropertyValueCollection = propertyCollection.get_Item('EmployeeType');

if (PropertyValueCollection && PropertyValueCollection.get_Count())
{
if (PropertyValueCollection.get_Value())
{

employeeType = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('manager');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
manager = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('c');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
country = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('samAccountName');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
samAccountName = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('userAccountControl');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
userAccountControl = PropertyValueCollection.get_Value();
}
}

propertyValueCollection = PropertyCollection.get_Item('memberOf');

if (PropertyValueCollection)
{
if (PropertyValueCollection.get_Value())
{
clrenumerator = PropertyValueCollection.GetEnumerator();
while (clrenumerator.MoveNext())
{
memberOfStr = clrenumerator.get_Current();
memberOf += [memberOfStr];
}
//posCount = PropertyValueCollection.get_Count();
//for (Pos=0; pos<posCount;pos++)
//{
//memberOfStr = PropertyValueCollection.get_Item(pos);
//memberOf += [memberOfStr];
//}
}
}
}
catch (Exception::CLRError)
{
//SRSProxy::handleClrException(Exception::Warning);
//warning(strFmt("@SYS117734"));
curext();
}

return true;
}

public str getCompany()
{
return company;
}
public str getCountry()
{
return country;
}
public str getDepartmentNumber()
{
return departmentNumber;
}

public boolean getDisabled()
{

// Added new conditions for when a user should be seen as disabled.
boolean ret;
;
//ACCOUNTDISABLE 0x0002 2
ret = bitTest(userAccountControl, 1 << 1);

if (!ret && title == 'SLUTAT')
ret = true;

if (!ret && (strLen(departmentNumber) > 0 && !strRem(departmentNumber,'0')) && (strLen(employeeNumber) > 0 && !strRem(employeeNumber,'0')))
ret = true;

return ret;

}

public str getEmployeeNumber()
{
return employeeNumber;
}

public str getEmployeeType()
{
return EmployeeType;
}
public str getGivenName()
{
return givenName;
}

public email getMail()
{
return mail;
}

public str getManager()
{
return subStr(manager
, strfind(manager, 'CN=', 1, strLen(manager))+3
, strfind(manager, ',', strfind(manager, 'CN=', 1, strLen(manager)), strLen(manager)) - strfind(manager, 'CN=',1 , strLen(manager)) - 3
);
}

public container getMemberOf()
{
return memberOf;
}

public str getSamAccountName()
{
return samAccountName;
}

public str getSn()
{
return sn;
}

public str getTelephoneNumber()
{
return telephoneNumber;
}

public str getUserId()
{
return UserId;
}

public int parmCurrentUserNumber(int _currentUserNumber = currentUserNumber)
{

currentUserNumber = _currentUserNumber;

return currentUserNumber;
}

public str parmFileName(Filename _filename = filename)
{
filename = _filename;

return filename;
}

public str parmselectedDomainName(str _selectedDomainName = selectedDomainName)
{
selectedDomainName = _selectedDomainName;

return selectedDomainName;
}

public void reset()
{
currentUserNumber = 0;
}

AX2012 Import CostCenter Owner

2017-04-20T09:04:00.001+00:00

static void Krishh_ImportCostCenterOwner(Args _args)
{
#File
#AviFiles
#OCCRetryCount

Dialog dialog = new dialog("Import cost center owners");
DialogField dlgFileNameOpen, dlgFirstRowsIsHeader;
Filename fileName;
NoYesId firstRowIsHeader;
container readcon;
CommaIO file;
FileIoPermission permission;
SysOperationProgress progressbar = new SysOperationProgress();
Counter fileRowsRead;
OMOperatingUnit oMOperatingUnit;
DimensionAttribute dimensionAttributeValue;
HcmWorkerRecId hcmWorkerRecId;

dlgFileNameOpen = dialog.addField(extendedTypeStr(FilenameOpen));
dlgFirstRowsIsHeader = dialog.addField(extendedTypeStr(NoYesId), "First row is header");

if (dialog.run())
{
fileName = dlgFileNameOpen.value();
firstRowIsHeader = dlgFirstRowsIsHeader.value();

if (!fileName)
throw error("File name must be specified");

permission = new FileIoPermission(filename,'r');
permission.assert();

file = new CommaIo(filename, 'r');
file.inFieldDelimiter(';');

if (!file)
throw error(strFmt("Error opening file", fileName));

progressbar.setCaption("Importing cost center owners");
progressbar.setAnimation(#AviUpdate);

try
{
ttsBegin;

while (file.status() == IO_Status::OK)
{
readCon = file.read();
fileRowsRead++;

if (fileRowsRead > firstRowIsHeader && readCon && conPeek(readcon, 1))
{
oMOperatingUnit = OMOperatingUnit::findName(conPeek(readcon, 1), OMOperatingUnitType::OMCostCenter);

if (!oMOperatingUnit)
warning(strFmt("Cost center %1 not found."));
else
{
// Find worker from user id
hcmWorkerRecId = HcmWorker::userId2Worker(conPeek(readcon, 2));

if (!hcmWorkerRecId)
warning(strFmt("User id %1 not found as worker in AX."));
else
{
// Find and update dimensionAttributeValue with worker as owner
}

}
}

progressbar.setText(strfmt("@SYS136776", fileRowsRead));
progressbar.update();
}

ttsCommit;

info(strFmt("%1 rows read from file", fileRowsRead));

}
catch (Exception::Error)
{
error("Error");
}
catch (Exception::Deadlock)
{
retry;
}
catch (Exception::UpdateConflict)
{
if (appl.ttsLevel() == 0)
{
if (xSession::currentRetryCount() >= #RetryNum)
{
throw Exception::UpdateConflictNotRecovered;
}
else
{
retry;
}
}
else
{
throw Exception::UpdateConflict;
}
}
}
}

AX2012 Export Account Structures

2017-04-20T09:02:00.003+00:00

static void Krishh_AcctStructureExport(Args _args)
{
DimensionHierarchy dimensionHierarchy;
DimensionHierarchyLevel dimensionHierarchyLevel;
DimensionAttribute dimensionAttribute;
DimensionConstraintNode dimensionConstraintNode;
DimensionConstraintNodeCriteria dimensionConstraintNodeCriteria;
FileIOPermission fileIoPermission;
CommaIO csvFile;
container writecon;
Dialog dialog;
DialogField dfFileName;
FileName fileName;
boolean firstRow = true;
Counter countRows;
#File

dialog = new Dialog("Export account structure text file");
dfFileName = dialog.addField(extendedTypeStr(FileNameSave));
dialog.filenameLookupFilter(["CSV files", #AllFilesName+#CSV, "All files", #AllFiles]);

if (dialog.run())
filename = dfFileName.value();
else
throw error("Export cancelled");

fileIoPermission = new FileIOPermission(filename ,'W');
fileIoPermission.assert();

csvFile = new CommaIO(filename, 'w');
csvFile.outFieldDelimiter(';');

while select dimensionHierarchy order by dimensionHierarchy.Name, dimensionHierarchyLevel.Level, dimensionConstraintNodeCriteria.RangeFrom, dimensionConstraintNodeCriteria.RangeTo, dimensionConstraintNodeCriteria.WildCardString
where !dimensionHierarchy.IsSystemGenerated
join dimensionHierarchyLevel
where dimensionHierarchyLevel.DimensionHierarchy == dimensionHierarchy.RecId
join dimensionAttribute
where dimensionAttribute.RecId == dimensionHierarchylevel.DimensionAttribute
join dimensionConstraintNode
where dimensionConstraintNode.DimensionHierarchyLevel == dimensionHierarchyLevel.RecId
join dimensionConstraintNodeCriteria
where dimensionConstraintNodeCriteria.DimensionConstraintNode == dimensionConstraintNode.RecId
{
if (firstRow)
{
writeCon = [ "Account structure",
"Level",
"Dimension",
"From",
"To",
"Wildcard"];

csvFile.write(writecon);
firstRow = false;
}

writeCon = [ dimensionHierarchy.Name,
int2str(dimensionHierarchyLevel.Level),
dimensionAttribute.Name,
dimensionConstraintNodeCriteria.RangeFrom,
dimensionConstraintNodeCriteria.RangeTo,
dimensionConstraintNodeCriteria.WildCardString];

csvFile.write(writecon);
countRows++;
}

CodeAccessPermission::revertAssert();

info(strFmt("%1 rows written to %2.", countRows, fileName));
}

AX2012 finding AIF menuItems and write to file

2017-04-20T08:38:00.000+00:00

Traverse the Menu Node in AOT and find AIF menuItems and write to a file.

static void krishh_verifyAifInMenu(Args _args)
{
// Dialog
dialog dialog = new dialog('verifyAifInMenu');
dialogField dlgFileName, dlgAction;
FileName fileName;
int action;
container saved;

// File
#File
TextIo ioData;
FileIOPermission permission;

Treenode treenode = TreeNode::findNode(@'\Menus\KrishhTest\Periodic');
//Treenode treenode = TreeNode::findNode(@'\Menus\KrishhTest\Periodic');
//Treenode treenode = TreeNode::findNode(@'\Menus\KrishhTest\Periodic');
//Treenode treenode = TreeNode::findNode(@'\Menus\KrishhTest\Periodic');
TreeNodeTraverser traverser = new TreeNodeTraverser(treenode);
TreeNode node, menuTypeNode;
UtilElements ue;

MenuItem mi;
DictClass dc;
className cn, scn;

Counter i,j;
SysDictMethod sdm;
Source s;

Str1260 sLable, sClass, sMenuItem, sClassMethodName, sMethod, sAIFPort, sDirection, sEnabled, sActionAddedToPort, sFolderName;

System.Text.RegularExpressions.Match regExMatch;
boolean isValid;
Int position, posStart, posEnd;

DictTable dt;
RecId recId;
boolean aifFound;
AifPort aifPort;

AifChannel aifChannel;
AifPortActionPolicy aifPortActionPolicy;
AifActionId aifActionId;

#Properties
#AOT
#AIF

#localmacro.PortInfo
any2str(%1)
+ ","
+ any2str(%2)
+ ","
+ any2str(%3)
+ ","
+ any2str(%4)
+ ","
+ any2str(%5)
+ ","
+ any2str(%6)
, "Goto method", SysInfoAction_Editor::newOpen(%7)
#EndMacro

saved = xSysLastValue::getValue(curExt(),curUserId(),UtilElementType::Class,'verifyAifInMenu','fileName');
if (saved)
{
fileName = conpeek(saved,1);
}

dlgFileName = dialog.addFieldValue(extendedTypeStr(FilenameOpen),fileName,'Filename','File to save result.');
//dlgAction = dialog.addFieldValue(extendedTypeStr(NumberOf),0,'Action','1=Save, 2=Undeploy, 3=Deploy');

if (dialog.run())
{
fileName = dlgFileName.value();
saved = [fileName];
xSysLastValue::putValue(saved,curExt(),curUserId(),UtilElementType::Class,'verifyAifInMenu','fileName');

permission = new FileIOPermission(fileName, #io_write);
permission.assert();

// Open file for writing
ioData = new TextIo(filename, #io_write);

// Check file open status
if (!ioData)
{
// File '%1' could not be opened.
throw error(strfmt("@SYS19312", filename));
}

// Set file delimiters
ioData.outRecordDelimiter('\r\n');
ioData.outFieldDelimiter(';');

ioData.write(
[
"Menu label"
, "Menu item"
, "Class"
, "AIF Port"
, "Direction"
, "Enabled"
, "Methode"
, "ActionAddedToPort"
, "Folder name"
]);

setPrefix("Services");
while (traverser.next())
{
node = traverser.currentNode();
if (node.AOTgetProperty('MenuItemName')!= '')
{
menuTypeNode = TreeNode::findNode(#MenuItemsPath +"\\Action\\" + findProperty(node.AOTgetProperties(),#PropertyMenuItemName));
mi = traverser.currentNode();

// Is menuitem object a class
if (findProperty(menuTypeNode.AOTgetProperties(),#PropertyObjectType) == enum2Value(MenuItemObjectType::Class))
{
// Find Class
if (findProperty(menuTypeNode.AOTgetProperties(),#PropertyObject) == 'SysOperationServiceController')
{
dc = new DictClass(className2Id(subStr(findProperty(menuTypeNode.AOTgetProperties(),#PropertyParameters), 1, strScan(findProperty(menuTypeNode.AOTgetProperties(),#PropertyParameters), '.', 1, 1000)-1)));
}
else
{
dc = new DictClass(className2Id(findProperty(menuTypeNode.AOTgetProperties(),#PropertyObject)));
}

sLable = mi.label();
sMenuItem = #MenuItemsPath +"\\Action\\" + findProperty(node.AOTgetProperties(),#PropertyMenuItemName);//node.treeNodePath();
sClass = dc.name();
setPrefix(strFmt("%1, %2, %3, %4", node.treeNodePath(), sLable, sMenuItem, sClass));

aifFound = false;
// Find the methode in the class where AxdDocumentParameters is used
for (i=1;i<=dc.objectMethodCnt()+dc.staticMethodCnt();i++)
{
// Instance method else Static method
if (i<=dc.objectMethodCnt())
{
sdm = new SysDictMethod(UtilElementType::ClassInstanceMethod, dc.id(), dc.objectMethod(i));
}
else
{
sdm = new SysDictMethod(UtilElementType::ClassStaticMethod, dc.id(), dc.staticMethod(i-dc.objectMethodCnt()));
}
sMethod = sdm.path();
s = sdm.getSource();

// Find port from AxdDocumentParameters
regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)AxdDocumentParameters::find.krishh.{1,22}Port');
isValid = regExMatch.get_Success();
regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)AifSendService::submitFrom');
isValid = isValid && regExMatch.get_Success();

setPrefix("Port");
if (isValid)
{
dt = new DictTable(tableNum(AxdDocumentParameters));

// Get AIFPort from AxdDocumentParameters used in code
for (j=1;j<=dt.fieldCnt();j++)
{
if (strScan(dt.fieldName(dt.fieldCnt2Id(j)), 'krishh', 1, 100) && strScan(dt.fieldName(dt.fieldCnt2Id(j)), 'Port', 1, 100))
{
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)%1', dt.fieldName(dt.fieldCnt2Id(j))));
isValid = regExMatch.get_Success();
if (isValid)
{
recId = AxdDocumentParameters::find().(dt.fieldCnt2Id(j));

// Find Port
if (recId)
{
select firstOnly aifPort
where aifPort.RecId == recId
join aifChannel
where aifChannel.ChannelId == aifPort.ChannelId;
sDirection = enum2Value(aifChannel.Direction);
sEnabled = enum2Value(aifChannel.Enabled);
sFolderName = aifChannel.TransportAddress;
aifFound = true;
}

if (aifFound)
{
// Find action
sActionAddedToPort = "";
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)AifSendActionType::'));
isValid = regExMatch.get_Success();
if (isValid)
{
// Calculate position of the portaction
position = regExMatch.get_Index();
posStart = position+1+strLen('AifSendActionType::');
posEnd = strScan(s, ')', position, strLen(s));

// Convet actiontype to actionId-searchstring
switch (subStr(s, posStart, posEnd-posStart))
{
case "SendByQuery":
aifActionId = "*.find";
break;
case "SendByKey":
aifActionId = "*.read";
break;
}

// Find portaction
while select AifPortActionPolicy
where AifPortActionPolicy.ActionId like aifActionId
&& AifPortActionPolicy.Port == recId
{
// Get the serviceclassname
scn = subStr(AifPortActionPolicy.ActionId, 1, strLen(AifPortActionPolicy.ActionId) - (strLen(aifActionId)-1));
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)classnum\(%1', scn));
isValid = regExMatch.get_Success();
if (isValid)
{
// Create a portaction exm. serviceclassname.action
sActionAddedToPort = scn+subStr(aifActionId, 2, strLen(aifActionId));
break;
}
}
}
}

// Output Port info
if (sEnabled && sActionAddedToPort)
{
info(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}
else
{
error(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}

ioData.write(
[
sLable
, sMenuItem
, sClass
, aifPort.Name
, sDirection
, sEnabled
, sMethod
, sActionAddedToPort, sFolderName
]);
}
}
}
}

// Find port from AifOutboundPort::find
recId = 0;
regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)AifSendService::submitFrom');
isValid = regExMatch.get_Success();
regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)AifOutboundPort::find\(');
isValid = isValid && regExMatch.get_Success();

if (isValid)
{
// Calculate position of the portClass
position = regExMatch.get_Index();
posStart = position+2+strLen('AifOutboundPort::find\(');
posEnd = strScan(s, ');', position, strLen(s))-1;

// Convet actiontype to actionId-searchstring
scn = subStr(s, posStart, posEnd-posStart);

// Find Port
if (scn)
{
select firstOnly aifPort
where aifPort.Name == scn
join aifChannel
where aifChannel.ChannelId == aifPort.ChannelId;
sDirection = enum2Value(aifChannel.Direction);
sEnabled = enum2Value(aifChannel.Enabled);
sFolderName = aifChannel.TransportAddress;

recId = aifPort.RecId;
aifFound = true;
}

if (recId)
{
// Find action
sActionAddedToPort = "";
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)AifSendActionType::'));
isValid = regExMatch.get_Success();
if (isValid)
{
// Calculate position of the portaction
position = regExMatch.get_Index();
posStart = position+1+strLen('AifSendActionType::');
posEnd = strScan(s, ')', position, strLen(s));

// Convet actiontype to actionId-searchstring
switch (subStr(s, posStart, posEnd-posStart))
{
case "SendByQuery":
aifActionId = "*.find";
break;
case "SendByKey":
aifActionId = "*.read";
break;
}

// Find portaction
while select AifPortActionPolicy
where AifPortActionPolicy.ActionId like aifActionId
&& AifPortActionPolicy.Port == recId
{
// Get the serviceclassname
scn = subStr(AifPortActionPolicy.ActionId, 1, strLen(AifPortActionPolicy.ActionId) - (strLen(aifActionId)-1));
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)classnum\(%1', scn));
isValid = regExMatch.get_Success();
if (isValid)
{
// Create a portaction exm. serviceclassname.action
sActionAddedToPort = scn+subStr(aifActionId, 2, strLen(aifActionId));
break;
}
}
}
}
// Output Port info
if (sEnabled && sActionAddedToPort)
{
info(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}
else
{
error(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}

ioData.write(
[
sLable
, sMenuItem
, sClass
, aifPort.Name
, sDirection
, sEnabled
, sMethod
, sActionAddedToPort, sFolderName
]);

}

// Find port from AifSendService::submitDefault
recId = 0;
sDirection = '';
sEnabled = '';
sFolderName = '';
sActionAddedToPort = '';

regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)AifSendService::submitDefault\(');
isValid = regExMatch.get_Success();
regExMatch = System.Text.RegularExpressions.Regex::Match(s, @'(?i)classnum\(');
isValid = isValid && regExMatch.get_Success();

if (isValid)
{
// Calculate position of the portClass
position = regExMatch.get_Index();
posStart = position+1+strLen('classnum\(');
posEnd = strScan(s, '),', position, strLen(s));

// Convet actiontype to actionId-searchstring
scn = subStr(s, posStart, posEnd-posStart);

// Find Port
if (scn)
{
select firstOnly AifPortActionPolicy
where AifPortActionPolicy.ActionId == scn + #MethodNameSeparator + #DefaultSendByKeyAction
join aifPort
where aifPort.RecId == AifPortActionPolicy.Port
join aifChannel
where aifChannel.ChannelId == aifPort.ChannelId;
sDirection = enum2Value(aifChannel.Direction);
sEnabled = enum2Value(aifChannel.Enabled);
sFolderName = aifChannel.TransportAddress;

recId = AifPortActionPolicy.Port;
aifFound = true;
}

if (recId)
{
aifActionId = "*.read";

// Find portaction
while select AifPortActionPolicy
where AifPortActionPolicy.ActionId like aifActionId
&& AifPortActionPolicy.Port == recId
{
// Get the serviceclassname
scn = subStr(AifPortActionPolicy.ActionId, 1, strLen(AifPortActionPolicy.ActionId) - (strLen(aifActionId)-1));
regExMatch = System.Text.RegularExpressions.Regex::Match(s, strFmt(@'(?i)classnum\(%1', scn));
isValid = regExMatch.get_Success();
if (isValid)
{
// Create a portaction exm. serviceclassname.action
sActionAddedToPort = scn+subStr(aifActionId, 2, strLen(aifActionId));
break;
}
}
}

// Output Port info
if (sEnabled && sActionAddedToPort)
{
info(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}
else
{
error(#PortInfo(aifPort.Name, sDirection, sEnabled, sMethod, sActionAddedToPort, sFolderName, sdm.path()));
}

ioData.write(
[
sLable
, sMenuItem
, sClass
, aifPort.Name
, sDirection
, sEnabled
, sMethod
, sActionAddedToPort, sFolderName
]);

}
}
if (!aifFound)
{
info(strFmt('%1, %2, %3, %4, %5, %6, %7, %8'
, sLable
, sMenuItem
, sClass
, "Not AIF"
, "No"
, "No"
, "No"
, "No"));
ioData.write(
[
sLable
, sMenuItem
, sClass
, "Not AIF"
, "No"
, "No"
, "No"
, "No"
]);
}
}
}
}

CodeAccessPermission::revertAssert();
}
}

AX2012 Update AIF Port adresses

2017-04-20T08:30:00.000+00:00

When we export from one environmen to another we should update the port addresses to the new environment addresses.
Like moving from config environmen to SIT, QA..etc.

static void krishh_UpdateAddressForPorts(Args _args)
{
AifChannel aifchannel;
str fromPath, toPath;
boolean Update;

Dialog dialog;

DialogField _from;
DialogField _to;
dialogField _Update
;

dialog = new Dialog("Move configdata");

dialog.addInfoImage();
dialog.addText("This job changes all paths on inbound and outbound ports!!!");

dialog.addGroup("Paths");
_from = dialog.addField(ExtendedTypeStr(String255), "From enviroment" , "Normally from MasterConfigData (CFG)" );
_to = dialog.addField(ExtendedTypeStr(String255), "To enviroment" , "Valid enviroments are SIT, UAT, QA & PROD");
dialog.addGroup("Update");
_Update = dialog.addField(ExtendedTypeStr(NoYesId) , "Commit change" , "Update the changes");

//InitValues
_from.value("CFG");
_Update.value(false);

dialog.run();

fromPath = _from.value();
toPath = _to.value();

if ((!fromPath || !toPath) || (fromPath == toPath))
{
return;
}

ttsBegin;
while select forupdate aifchannel where aifchannel.Direction != AIFChannelDirection::Both
{
if (strScan(aifchannel.TransportAddress, fromPath, 1, 255))
{
aifchannel.TransportAddress=strReplace(aifchannel.transportAddress, fromPath, toPath);
info(aifchannel.TransportAddress);

if (_Update)
aifchannel.update();
}
}
ttsCommit;
}

AX2012 Flush recids

2017-04-20T08:26:00.002+00:00

static void krishh_flushAllRecIds(Args _args)
{
#AviFiles

Dictionary dictionary = new Dictionary();
systemSequence systemseq = new systemSequence();

SysDictTable dictTable;

TableId tableId,LastTableId;

SysOperationProgress progress;
container fileContainer;

int i;

setPrefix("Flush all RecIds");

tableId = dictionary.tableNext(0);
lastTableId = dictionary.tableCnt();

progress = new SysOperationProgress();
progress.updateInterval(1);
progress.setAnimation(#AviStopwatch);
progress.setTotal(LastTableId);

progress.setText(strfmt("Flushing recIds"));

ttsbegin;
while (tableId)
{
progress.incCount();

dictTable = new SysDictTable(tableId);

setPrefix(dictTable.name());

Systemseq.suspendRecIds(tableId);
Systemseq.suspendTransIds(tableId);
Systemseq.flushValues(tableId);
Systemseq.removeRecIdSuspension(tableId);
Systemseq.removeTransIdSuspension(tableId);

//info(strFmt("Tables RecId Flushed (%1)", dictTable.name()));

tableId = dictionary.tableNext(tableId);
}

ttscommit;
}

AX2012 get gropu dimension from financial dimension

2017-04-20T08:25:00.000+00:00

static void krish_findGroupDimension(Args _args)
{
Name _dimensionTypeName = 'COSTCENTER';
DimensionValue _dimensionDisplayName = 'csttest';

DimensionExt retVal;

OMOperatingUnit oMOperatingUnit;
DimensionAttribute dimensionAttribute;
DimensionAttributeLevelValue dimensionAttributeLevelValue;
DimensionAttributeValue dimensionAttributeValue;
DimensionAttributeValueSetItemView dimensionAttributeValueSetItemView;
;

select oMOperatingUnit
Join dimensionAttribute where dimensionAttribute.Name == _dimensionTypeName
join dimensionAttributeValue where dimensionAttributeValue.DimensionAttribute == dimensionAttribute.RecId
Join dimensionAttributeLevelValue where dimensionAttributeLevelValue.DimensionAttributeValue == dimensionAttributeValue.recid
&& dimensionAttributeLevelValue.DisplayValue == _dimensionDisplayName;

retVal = dimensionAttributeValue.GroupDimension;

if (!retVal)
{
select dimensionAttribute where dimensionAttribute.Name == _dimensionTypeName
Join dimensionAttributeValueSetItemView where dimensionAttributeValueSetItemView.DimensionAttribute == dimensionAttribute.RecId &&
dimensionAttributeValueSetItemView.DisplayValue == _dimensionDisplayName
join dimensionAttributeValue where dimensionAttributeValue.RecId == dimensionAttributeValueSetItemView.DimensionAttributeValue;

retVal = dimensionAttributeValue.GroupDimension;
}

info(strFmt("DimensionAttribute = %1", DimensionAttribute.RecId));
info(strFmt("DimensionAttributeValueSetItemView = %1", DimensionAttributeValueSetItemView.RecId));
info(strFmt("%1 : %2 = %3 (%4)", _dimensionTypeName, _dimensionDisplayName, retVal, dimensionAttributeValue.RecId));

}

AX2012 File Reader Test

2017-04-20T08:16:00.000+00:00

static void fileAccessTest(Args _args)
{
CommaIO commaIO;
int row;
Container c;
FileIOPermission fileIOPermission;
int recCountNotExist;
boolean errorlog;
Dialog dialog;
DialogField dialogField;
FilenameOpen filename;
;

dialog = new Dialog("Test version of File reader");

dialogField = dialog.addFieldValue(extendedTypeStr(FilenameOpen), "", "File to access");

if (dialog.run())
filename = dialogField.value();
else
throw error("No filename");

fileIOPermission = new FileIOPermission(filename,'r');
fileIOPermission.assert();

//BP Deviation documented
commaIO = new CommaIO(filename, 'r');

if (commaIO != null)
{
if (commaIO.status())
{
throw error("@SYS52680");
}

commaIO.inRecordDelimiter('\r\n');
commaIO.inFieldDelimiter(',');
}
else
{
throw error("@SYS52680");
}

c = conNull();

if (commaIO)
{
if (commaIO.status() == IO_Status::OK)
{
if (row==0)
{
c = commaIO.read();
}
info(con2Str(c));
row++;
c = commaIO.read();
info(con2Str(c));
}
}
}

AX2012 CompileCIL and Refresh Services using X++

2017-04-20T08:13:00.000+00:00

static void krishh_CompileCILRefreshServices(Args _args)
{
#AviFiles
#File

#define.fileName('AxTime.txt')

TextIo file;
FileIoPermission permission;
SysOperationProgress progress;
container fileContainer;

int i;

Dialog dialog;

DialogField dlgCompile;
DialogField dlgCIL;
DialogField dlgIncCIL;
DialogField dlgRefreshService;

int timeStarted[2];
int timeAverage[4]; //1:FUllCompileTime,2:FULLCILCompileTime,3:IncrementalCILTime,4:RefreshServicesTime
int timeExpected;

Filename filename
;

void getAverageTime()
{
filename = WinAPI::getCurrentDirectory() + '\\' + fileName;

permission = new FileIoPermission(filename, #io_read+#io_write);
permission.assert();

if(WinAPI::fileExists(filename))
{
file = new TextIo(filename, #io_read);
fileContainer = file.read();
timeAverage[1] = str2int(conPeek(fileContainer,1));
timeAverage[2] = str2int(conPeek(fileContainer,2));
timeAverage[3] = str2int(conPeek(fileContainer,3));
timeAverage[4] = str2int(conPeek(fileContainer,4));
file = null;
}

CodeAccessPermission::revertAssert();
}

void setAverageTime()
{
permission = new FileIoPermission(filename, #io_write);
permission.assert();

fileContainer = conNull();
fileContainer = conIns(fileContainer,1,int2str(timeAverage[1]));
fileContainer = conIns(fileContainer,2,int2str(timeAverage[2]));
fileContainer = conIns(fileContainer,3,int2str(timeAverage[3]));
fileContainer = conIns(fileContainer,4,int2str(timeAverage[4]));

file = new TextIo(filename, #io_write);
file.write(fileContainer);
file.finalize();

file = null;

CodeAccessPermission::revertAssert();
permission = null;
}

dialog = new Dialog("Compile/CIl/Refresh");

dialog.addInfoImage();
dialog.addText("Please select actions needed and please be aware that all are time consuming processes");

dialog.addGroup("Compile application");
dlgCompile = dialog.addFieldValue(extendedTypeStr(NoYesId),NoYes::No,"AOT Compile");

dialog.addGroup("Compile CIL");
dlgCIL = dialog.addFieldValue(extendedTypeStr(NoYesId), NoYes::No, "FULL");
dlgIncCIL = dialog.addFieldValue(extendedTypeStr(NoYesId), NoYes::No, "Incemental");

dialog.addGroup("Other");
dlgRefreshService = dialog.addFieldValue(extendedTypeStr(NoYesId),NoYes::No,"Refresh Services");

if (!dialog.run())
throw error("Operation aborted");

filename = #fileName;

timeAverage[1] = 3600; // 60:00 min
timeAverage[2] = 1800; // 30:00 min
timeAverage[3] = 900; // 15:00 min
timeAverage[4] = 300; // 5:00 min

getAverageTime();

timeExpected += dlgCompile.value() ? timeAverage[1] : 0;
timeExpected += dlgCIL.value() ? timeAverage[2] : 0;
timeExpected += dlgIncCIL.value() ? timeAverage[3] : 0;
timeExpected += dlgRefreshService.value() ? timeAverage[4] : 0;

progress = new SysOperationProgress();
progress.updateInterval(0);
progress.setAnimation(#AviStopwatch);

progress.setTotal(1 + dlgCompile.value() + (dlgCIL.value() || dlgIncCIL.value()) + dlgRefreshService.value());

timeStarted[1] = timeNow();

info(strFmt("Process stared by %1",curUserId()));

//Compile the application
startLengthyOperation();
sleep(3);

//AOT Compile
if (dlgCompile.value())
{
progress.incCount();
progress.setText(strfmt("AOT Compile compiling | Start time : %1 ETA : %2",time2str(timeNow(),1,1),time2str(timeAverage[1] + timeNow(),1,1)));

//Do function
timeStarted[2] = timeNow();

SysCompileAll::flushClient();
SysCompileAll::compile();

SysCheckList::finished(classnum(SysCheckListItem_Compile));
SysCheckList::finished(classnum(SysCheckListItem_CompileUpgrade));
SysCheckList::finished(className2Id(classStr(SysCheckListItem_CompileServ)));
SysCheckList::finished(classnum(SysCheckListItem_SysUpdateCodeCompilInit));

timeAverage[1] = ((timeNow()-timeStarted[2]) + timeAverage[1])/2;
info(strFmt("AOT Compile toke : %1*",time2str(timeAverage[1],1,1)));
}

//Incremntal CIL
if (dlgIncCIL.value())
{
progress.incCount();
progress.setText(strfmt("Incremental CIL Compiling | Start time : %1 ETA : %2",time2str(timeNow(),1,1),time2str(timeAverage[3] + timeNow(),1,1)));

//Do function
timeStarted[2] = timeNow();
SysCompileIL::generateIncrementalIL();

timeAverage[3] = ((timeNow()-timeStarted[2]) + timeAverage[3])/2;
info(strFmt("Increment CIL toke : %1*",time2str(timeAverage[3],1,1)));
}
//Full CIL
else if (dlgCIL.value())
{
progress.incCount();
progress.setText(strfmt("FULL CIL Compiling | Start time : %1 ETA : %2",time2str(timeNow(),1,1),time2str(timeAverage[2] + timeNow(),1,1)));

//Do function
timeStarted[2] = timeNow();
SysCompileIL::generateIL();
timeAverage[2] = ((timeNow()-timeStarted[2]) + timeAverage[2])/2;
info(strFmt("FULL CIL toke : %1*",time2str(timeAverage[2],1,1)));
}

// Refresh services
if (dlgRefreshService.value())
{
progress.setText(strfmt("Refresh Services | Start time : %1 ETA : %2",time2str(timeNow(),1,1),time2str(timeAverage[4] + timeNow(),1,1)));
progress.incCount();

timeStarted[2] = timeNow();

AifServiceGenerationManager::registerServices();

timeAverage[4] = ((timeNow()-timeStarted[2]) + timeAverage[4])/2;
info(strFmt("Refresh Services toke : %1*",time2str(timeAverage[4],1,1)));
}

setAverageTime();

endLengthyOperation();

//Flush all
sysFlushAOD::main(_args);
sysFlushData::main(_args);
sysFlushDictionary::main(_args);
info(strFmt("*Averagetime"));
info(strFmt("Total time spendt : %1",time2str(timeNow()-timeStarted[1],1,1)));
}

Hide Query values in the dialog with select button Enabled

2016-12-07T13:22:00.001+00:00

Scneario: we want to hide the query values that was selected by the user in query range select button.

I created the parmmethod as below in the class Dialog,RunBaseDialogModify

public boolean hideQueryValuesInDialog(boolean _showValues = showValues)
{
;
showValues = _showValues;

return showValues;
}

Added the highlighted code as below in the following method of class RunBaseDialogModify

client public static RunBaseDialogModify newRunbaseOnClient(
RunBase runBase,
DialogRunbase dialog)
{
// <GEERU>
RunBaseDialogModify runBaseDialogModify = RunBaseDialogModify::construct(runBase.runBaseDialogModifyType_RU());
// </GEERU>
;
runBaseDialogModify.parmRunbase(runBase);
runBaseDialogModify.parmDialog(dialog);

//Addded by krishna
runBaseDialogModify.rsaShowQueryValuesInDialog(dialog.rsaShowQueryValuesInDialog());
//Addded by krishna

return runBaseDialogModify;
}

Server public static RunBaseDialogModify newRunbaseOnServer(
RunBase runBase,
DialogRunbase dialog)
{
// <GEERU>
RunBaseDialogModify runBaseDialogModify = RunBaseDialogModify::construct(runBase.runBaseDialogModifyType_RU());
// </GEERU>
;
runBaseDialogModify.parmRunbase(runBase);
runBaseDialogModify.parmDialog(dialog);
//Addded by krishna
runBaseDialogModify.rsaShowQueryValuesInDialog(dialog.rsaShowQueryValuesInDialog());
//Addded by krishna
return runBaseDialogModify;
}

// <GEERU>
protected boolean addField(SysDictField _dictField, Set _fieldNameSet, LabelType _labelType, Range _range)
// </GEERU>
{
boolean ret = false;
Map map;
DialogField dialogField;
TableId tableId;

if (_dictField)
{
tableId = _dictField.tableid();
if (_fieldNameSet.in(_dictField.name()))
{
if (this.existField(_dictField))
{
this.addRange(this.getFieldName(_dictField), _range);
}
}
else
{
ret = true;

if (!dialogQueryFieldsMap.exists(tableId))
{
dialogQueryFieldsMap.insert(tableId, new Map(Types::String, Types::String));
}

map = dialogQueryFieldsMap.lookup(tableId);
dialogField = dialog.addField(extendedTypeStr(RunBaseRange), _labelType);

dialogField.value(_range);
dialogField.allowEdit(false);

//Addded by krishna
// dialogField.visible(true);
if(!showValues)
{
dialogField.visible(false);
}
else
{
dialogField.visible(true);
}
//Addded by krishna

map.insert(_dictField.name(), dialogField.fieldname());

_fieldNameSet.add(_dictField.name());
}
}
return ret;
}

In your runbasebatch class override the method as below
public DialogRunbase dialogInit(DialogRunbase dialog, boolean forceOnClient= false)
{
DialogRunbase ret;
//Addded by krishna
if (! dialog)
{
if (xGlobal::clientKind() != ClientType::Server || forceOnClient)
dialog = DialogRunbase::newOnClient(this.caption(),this);
else
dialog = DialogRunbase::newOnServer(this.caption(),this);
}
dialog.rsaShowQueryValuesInDialog(false);
//Addded by krishna
ret = super(dialog, forceOnClient);

return ret;
}

The above changes will hide your query range selected values in the dialog with showing select button.

Ax2012 Useful functions 2

2015-07-13T13:00:00.001+00:00

Show viewhistory on form datasources if you have ValidaTimeState Enabled DateTime enabled on the tables of that form.
create this method in Global class so you can call whereever you want in form button click as below.

void clicked()

{
buttonHistoryClick(element, this);
Super();
}

static public void buttonHistoryClick(FormRun _formRun, FormButtonControl _fbc)
{
void changeDataSources(ValidTimeStateAutoQuery _from, ValidTimeStateAutoQuery _to, boolean _allowDelete)
{
Counter dataSourceNo;
FormDataSource formDataSource;

for (dataSourceNo=1;_formRun.dataSourceCount()>=dataSourceNo;dataSourceNo++)
{
formDataSource = _formRun.dataSource(dataSourceNo) as FormDataSource;
if (formDataSource.validTimeStateAutoQuery() == _from && new DictTable(formDataSource.table()).isValidTimeStateTable())
{
formDataSource.validTimeStateAutoQuery(_to);
switch (_to)
{
case ValidTimeStateAutoQuery::AsOfDate:
formDataSource.validTimeStateAutoQuery(ValidTimeStateAutoQuery::AsOfDate);
formDataSource.query().resetValidTimeStateQueryType();
formDataSource.allowDelete(_allowDelete);
break;
case ValidTimeStateAutoQuery::DateRange:
formDataSource.validTimeStateAutoQuery(ValidTimeStateAutoQuery::DateRange);
formDataSource.query().validTimeStateDateTimeRange(DateTimeUtil::minValue(), DateTimeUtil::maxValue());
formDataSource.allowDelete(_allowDelete);
break;
}
formDataSource.executeQuery();
}
}
}

if (_fbc.labelText() == "@SYS110266")
{
changeDataSources(ValidTimeStateAutoQuery::AsOfDate, ValidTimeStateAutoQuery::DateRange, false);
_fbc.text("Stop viewing History");
_fbc.normalImage("10006");
}
else
{
changeDataSources(ValidTimeStateAutoQuery::DateRange, ValidTimeStateAutoQuery::AsOfDate, true);
_fbc.Text("@SYS110266");
_fbc.normalImage("10007");
}

}
// this method is used to create filenameTimeStamp.

static FileName createFilenameTimeStamp()
{
FileName ret;
Microsoft.Dynamics.IntegrationFramework.Adapter.FileSystem fileSystem;
#Aif

fileSystem = AifUtil::getClrObject(#FileSystemProgId);

ret = fileSystem.GetCurrentTimestamp();

return ret;
}

// This method is used to split the string, and returns the conatiner with the position defined in the parameter
public static str rsaStrSplit(str _splitString,str _splitchar,int _pos)
{
List strlist=new List(Types::String);
ListIterator iterator;
container packedList;
;
strlist=strSplit(_splitString,_splitchar);
iterator = new ListIterator(strlist);
while(iterator.more())
{
packedList += iterator.value();
iterator.next();
}
return conPeek(packedList,_pos);

}

public static str encrypt(str _input, str _salt = '')
{
System.Security.Cryptography.SHA512Managed sha512managed = new System.Security.Cryptography.SHA512Managed();
System.Text.Encoding encoding = System.Text.Encoding::get_UTF8();

System.Byte[] inputBytes;
System.Byte[] resultBytes;

int i;
str returnString;
;

new InteropPermission(InteropKind::ClrInterop).assert();

inputBytes = encoding.GetBytes(strLwr(_salt) + _input); // Convert lower case salt + input into byte array

// The input is hashed 1024 times for attack resiliency
for (i = 0; i < 1024; i++)
{
resultBytes = resultBytes ? resultBytes : inputBytes; // First loop uses input for hashing
resultBytes = sha512managed.ComputeHash(resultBytes);
}

returnString = System.Convert::ToBase64String(resultBytes);

CodeAccessPermission::revertAssert();

return returnString;
}

private static Map fileGetList(FilePath _filePathArchive)

{

Map mapFiles;

InteropPermission interopPermission = new InteropPermission(InteropKind::ClrInterop);
Set interopPermissionSet = new Set(Types::Class);
System.Array arrayFiles;

int i;
;

// Granting file permission rights
interopPermissionSet.add(interopPermission);
CodeAccessPermission::assertMultiple(interopPermissionSet);

mapFiles = new Map(Types::String, Types::String); // Key = return file | Value = archive path

if (!System.IO.Directory::Exists(_filePathArchive))
{
throw error("Path doesnt exist");
}

arrayFiles = System.IO.Directory::GetFiles(_filePathArchive);

// CLRInterop::getAnyTypeForObject method is used to handle difference in AX and System types (e.g. System.Int32 != int)

for (i = 0; i < CLRInterop::getAnyTypeForObject(arrayFiles.get_Length()); i++)
{
mapFiles.insert(CLRInterop::getAnyTypeForObject(arrayFiles.GetValue(i)), _filePathArchive);
}
}

// Reverting file permission rights
CodeAccessPermission::revertAssert();

return mapFiles;
}

/// <summary>
/// Gets the SenderID from AIF xml .
/// </summary>
/// <param name="messagePartsXml">
/// An <c>AifXml</c> value.
/// </param>
/// <returns>
/// An instance of the <c>str document Namespace</c> class.
/// </returns>
public static str getSenderIDValue(AifXml messagePartsXml)
{
XmlTextReader xmlReader;
str value,currentElement,pureElement;

;
#Aif
xmlReader = XmlTextReader::newXml(messagePartsXml);
while (xmlReader.Read())
{
switch (xmlReader.nodeType())
{
case XmlNodeType::Element:
currentElement = xmlReader.name();
break;
case XmlNodeType::Text:
pureElement = subStr(currentElement,strFind(currentElement,':',1,256)+1,256);
switch (pureElement)
{
case "SenderId":
{
value=xmlReader.value();
return value;
}
break;
}
break;
}
}

return value;
}

AX2012 Replacing Company element value in AIF using .net dll and QueryService

2015-07-13T12:37:00.001+00:00

Scenario:
In AIF we have some data coming from externalSystem, which externalSystem doesnt have anyinformation to which company it should load, as ExternalSystem knows the information about coRegNum as we have to find the right company in AX by using coRegNum.
Solution:
so I build a .net component where we use the dll in transformation to replace the companyelement in the header to pass the file into right company.
I am using QueryService which I querying the companyInfoTable with the range coRegNum and getting the right Company and replacing in the sourceXML in transfromation in headersection.

sample xml section below.

<ns0:Envelope xmlns:ns0="http://schemas.microsoft.com/dynamics/2011/01/documents/Message">
<ns0:Header>
<ns0:MessageId>354bcae9-45a5-411e-953f-e2920a6c0229</ns0:MessageId>
<ns0:Company>123456</ns0:Company>
<ns0:Action>http://schemas.microsoft.com/dynamics/2008/01/services/GeneralJournalService/create</ns0:Action>
</ns0:Header>
<ns0:Body>
<ns0:MessageParts>
<ns0:LedgerGeneralJournal xmlns:ns0="http://schemas.microsoft.com/dynamics/2008/01/documents/LedgerGeneralJournal" xmlns:st="http://schemas.microsoft.com/dynamics/2008/01/sharedtypes">

Before writing this class add serviceReference QueryService from AX standardservice into your solution that will create app.config as below

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<bindings>
<netTcpBinding>
<binding name="QueryServiceEndpoint" closeTimeout="00:01:00"
openTimeout="00:01:00" receiveTimeout="00:10:00" sendTimeout="00:01:00"
transactionFlow="false" transferMode="Streamed" transactionProtocol="OleTransactions"
hostNameComparisonMode="StrongWildcard" listenBacklog="10"
maxBufferPoolSize="524288" maxBufferSize="65536" maxConnections="10"
maxReceivedMessageSize="65536">
<readerQuotas maxDepth="32" maxStringContentLength="8192" maxArrayLength="16384"
maxBytesPerRead="4096" maxNameTableCharCount="16384" />
<reliableSession ordered="true" inactivityTimeout="00:10:00"
enabled="false" />
<security mode="Transport">
<transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
<message clientCredentialType="Windows" />
</security>
</binding>
</netTcpBinding>
</bindings>
<client>
<endpoint address="net.tcp://KrishhDax:8201/DynamicsAx/Services/QueryService"
binding="netTcpBinding" bindingConfiguration="QueryServiceEndpoint"
contract="AXQueryService.IQueryService" name="QueryServiceEndpoint">
<identity>
<servicePrincipalName value="host/KrishhDax.adep01.nordic.rsa-ins.com" />
</identity>
</endpoint>
</client>
</system.serviceModel>

</configuration>

Create a tranform class which extends from Itransform.
I am using xml.linq to read the element value in the class, so I referenced System.Xml.Linq;

using System;
using System.IO;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.Dynamics.IntegrationFramework.Transform;
using System.Xml;
using System.Xml.Linq;
using KrishhIbanToCompanyTrans.AXQueryService;
using System.ServiceModel;
using System.Data;
using System.Net;

namespace KrishhIbanToCompanyTrans
{
public class IBANToCompanyTrans : ITransform
{
public void Transform(System.IO.Stream input, System.IO.Stream output, string config)
{
XDocument inputXml = XDocument.Load(input);

string accStr = inputXml.Root.Descendants().Where(e => e.Name.LocalName == "Company").First().Value;

string[] serviceParams = config.Split(';');

if (serviceParams.Count() != 1 && serviceParams.Count() != 4)
throw new ArgumentException("Invalid configuration passed. Expecting single endpoint address or endpoint address with username, password and domain, separated by ;");

NetTcpBinding binding1 = new NetTcpBinding();
EndpointAddress epa = new EndpointAddress(serviceParams[0]);

binding1.Name = "QueryServiceEndpoint";
binding1.TransactionProtocol = TransactionProtocol.OleTransactions;
binding1.TransferMode = TransferMode.Streamed;
binding1.Security.Mode = SecurityMode.Transport;
binding1.HostNameComparisonMode = HostNameComparisonMode.StrongWildcard;
binding1.Security.Transport.ClientCredentialType = TcpClientCredentialType.Windows;
binding1.Security.Transport.ProtectionLevel = System.Net.Security.ProtectionLevel.EncryptAndSign;
binding1.Security.Message.ClientCredentialType = MessageCredentialType.Windows;
binding1.ReliableSession.Enabled = false;

QueryServiceClient serviceClient = new QueryServiceClient(binding1, epa);

if (serviceParams.Count() == 4)
{
serviceClient.ClientCredentials.Windows.ClientCredential.UserName = serviceParams[1];
serviceClient.ClientCredentials.Windows.ClientCredential.Password = serviceParams[2];
serviceClient.ClientCredentials.Windows.ClientCredential.Domain = serviceParams[3];
}

QueryMetadata query = new QueryMetadata();
query.DataSources = new QueryDataSourceMetadata[1];
query.Name = "CompanyInfo";
QueryDataSourceMetadata queryDS = new QueryDataSourceMetadata();
queryDS.Name = "CompanyInfo";
queryDS.Table = "CompanyInfo";
queryDS.Enabled = true;
query.DataSources[0] = queryDS;
queryDS.DynamicFieldList = false;
queryDS.Fields = new QueryDataFieldMetadata[2];
QueryDataFieldMetadata fieldId = new QueryDataFieldMetadata();
fieldId.FieldName = "DataArea";
fieldId.SelectionField = SelectionField.Database;
queryDS.Fields[0] = fieldId;
QueryDataFieldMetadata fieldName = new QueryDataFieldMetadata();
fieldName.FieldName = "CoRegNum";
fieldName.SelectionField = SelectionField.Database;
queryDS.Fields[1] = fieldName;
queryDS.Ranges = new QueryDataRangeMetadata[] { new QueryDataRangeMetadata() { TableName = "CompanyInfo", FieldName = "CoRegNum", Value = accStr, Enabled = true } };

Paging paging = new ValueBasedPaging() { RecordLimit = 25 };

DataSet dataset = serviceClient.ExecuteQuery(query, ref paging);
Console.Write(dataset.GetXml());

if (dataset != null)
{
if (dataset.Tables.Count > 2)
{
if (dataset.Tables[3].Rows.Count > 0)
{
DataRow dr = dataset.Tables[3].Rows[0];

var element = inputXml.Root.Descendants().Where(e => e.Name.LocalName == "Company").First();
if (element != null)
element.Value = dr["DataArea"].ToString();
}
}
}
inputXml.Save(output);

}

This method is used to test the above code.
/*
static void Main(string[] args)
{
IBANToCompanyTrans transformClass = new IBANToCompanyTrans();

FileStream input, output;

// Create the two streams to pass into the assembly. You will need to change these
// to your file locations.
input = new FileStream("C:\\Temp\\922\\922.xml", FileMode.Open);
output = new FileStream("C:\\Temp\\922\\922_c.xml", FileMode.OpenOrCreate);

string paramString = "net.tcp://hssdas115:8201/DynamicsAx/Services/QueryService";
// Passes in the customers CSV file and gets back an XML file.
transformClass.Transform(input, output, paramString);

// Displays the XML to the console.
// StreamReader sreader = new StreamReader(new FileStream("c:\\temp\\testtmpn.xml", FileMode.Open));
// Console.Write(sreader.ReadToEnd());
// Console.ReadLine();

} */
}
}

After building this component, go to the inboundPort and click transformation button and go to transformations and create the .net dll transformation and provide the dll and select the class in the dropdown.
in Config file provide the app.config file for this transformation.

AIF Outbound Read ParentAXBC while processingRecord AX2012

2015-06-25T14:36:00.001+00:00

Scenario:

In AIF outbound document service Exporting Invoices information,
In this document we have the customization as one table which contains the printTemplates where it stores the printTemplate information like,address,bankdetails,etc.Using this printTemplate number the external system will define which printing report they have to use.
The Requirement is The Address containes all the street,country,etc. these information we have to generate from translation tables based on the language that defined in the custinvoiceJournal.

so the datasource lookes like this.
custinvoicejour->custinvoicetrans,custTable,etc, as well printTemplateTable also outerjoins to the custinvoicejour.

I didnt find the way where I can get the parentaxbc object while processing the current record.

Solution:
I thought to get parentAXBC object always for the outbound for the current AXBC record.

See the Modification that I have build.

1. AXDBase class
added the class variable as AXInternalBase parentAXBC;

2. AxdBaseRead class
Open method serializeRecord add the folllowing line of code above AXbase.ProccesingRecord(common) line in that method
axdBase.parmParentAxBC(_parentAxBC);

3. AxdBaseGenerateXSD class
Open this class edit method addDocumentProperties and add one more case for classType as below, so that while serialization class object wont fail.
// added by krishna for to check for class type also. begins
case Types::Class:
if (typename == '')
{
typename = #xsdStringType;
typeNameSpace = #xsdNameSpace ;
}
break;

// added by krishna for to check for class type also.

Now framework was updated to get parentAXBC allways while outbound. now you can write logic whatever you want to use it.

Open AXDSalesInvoice class and update the processing record with the business logic for you to handle.
It this method i am verifying the current record in printTemplate then get the parent and get the languageId from that do my logic.

public void processingRecord(Common common)
{
PrintTemplate PrintTemplate;
AxCustInvoiceJour axCustInvoiceJour;
if(common.TableId == tableNum(PrintTemplate))
{
axCustInvoiceJour=this.parmParentAxBC();
PrintTemplate=common;
PrintTemplate.CompanyCountryName=LogisticsAddressCountryRegionTranslation::find(LogisticsPostalAddress::findRecId(PrintTemplate.Address).CountryRegionId,axCustInvoiceJour.parmLanguageId()).ShortName;
super(PrintTemplate);
}
else
{
super(common);
}

}

If you guys likes this post and useful please like and share it.

Editable Multi select lookup in Grid field AX2012

2015-06-25T14:04:00.002+00:00

Scneario: Multiple select Editable lookup in grid

I created an extension of class from SysLookupMultiselectGrid

class KrisSysLookupMultiSelectGrid extends SysLookupMultiSelectGrid
{

#Characters

}

public void setSelected()
{
dictfield dictField;
Common currentDSRecord;
FormDataSource formdatasource;
callingControlId.text(SysOperationHelper::convertMultiSelectedValueString (selectedId));
formdatasource = callingControlId.dataSourceObject();
if(formdatasource && callingControlStr.dataField())
{
dictfield = new dictfield(formdatasource.table(),callingControlStr.dataField());
currentDSRecord = formdatasource.cursor();
currentDSRecord.(dictfield.id()) = currentDSRecord.(dictfield.id()) + SysOperationHelper::convertMultiSelectedValueString(selectedStr);
callingControlStr.update();
}
else
{
callingControlStr.text(SysOperationHelper::convertMultiSelectedValueString(selectedStr));
}
}

public static KrisSysLookupMultiSelectGrid construct(FormControl _ctrlId,
FormControl _ctrlStr)
{
KrisSysLookupMultiSelectGrid lookupMS;
lookupMS = new KrisSysLookupMultiSelectGrid ();
lookupMS.parmCallingControlId(_ctrlId);
lookupMS.parmCallingControlStr(_ctrlStr);
return lookupMS;

}

On form declare this class on the form level as below

KrisSysLookupMultiSelectGrid multiSelectGrid;

On form Init method initiliaze this object as below
multiSelectGrid = KrisSysLookupMultiSelectGrid ::construct(GridResults_Value,GridResults_Value);

On grid string edit field lookup method you can use this object as below

Query query = new Query();

QueryBuildDataSource queryBuildDataSource;

queryBuildDataSource = query.addDataSource(tableNum(DimensionAttribute));
queryBuildDataSource.addRange(fieldNum(DimensionAttribute,Type)).value(queryValue(DimensionAttributeType::CustomList));
queryBuildDataSource.addRange(fieldNum(DimensionAttribute,Type)).value(queryValue(DimensionAttributeType::MainAccount));
queryBuildDataSource.addRange(fieldNum(DimensionAttribute,Type)).value(queryValue(DimensionAttributeType::ExistingList));
queryBuildDataSource.addSelectionField(fieldNum(DimensionAttribute,Name));
multiSelectGrid.parmQuery(query);

multiSelectGrid.run();

you can see in form as below screenshot

Its editable and multi select lookup.

AIF Inheritance Extending AXD classes AX2012

2015-06-25T13:36:00.001+00:00

Scenario:

I have multiple ledgerTransaction files coming from different source systems to AX, so each file import must have different business logic,business handlings regarding the dimensions, type of files ex ledger,cust,bank,vend.

I build the whole logic in the standard AXDLEdgerGeneralService class in deserializeEntity method with journalNames I handled, but its becoming more complex and to maintain the functionality and growing business requirements, its getting messing in the code.

I designed the inheritance for AIF documents, For each inbound we can have different axdclass with their own business logic implemented and I defined which axdclass that you want to run on that inbound port. It became easier to maintain the code and standard class is same as Standard.

I thought to share as it may be useful for lot of people.

abstract class AifDocument extends AfStronglyTypedDataContainer

{

classId axdClassId;

AxdBase axdInstance;

AifXml documentXml;

boolean documentXmlExists;

boolean deserializeNow;

}

public classId parmAXDClassId(classId _classId=axdClassId)

{

axdClassId=_classId;

return axdClassId;

}

Add field ClassId in table AIFInboundPort which extends classID EDT.

Create an Edit method in this table

edit className name(boolean set, Classname value)

{

classid classID;

if(set)

{

classid=classname2id(value);

this.classid=classid;

}

else

{

value = classid2name(this.classid);

}

Create an inMemmory table AifAxdClassLookup with the field ClassName of EDT Name.

Edit the form aifinboundPort and add a method at element level

Declare a variable at form level as AifAxdClassLookup aifAxdClassLookup;

Add AXDClass string edit control on details header group. define Datamethod Name

Add progress control under details header group and name it as progress.

Create element level method as below, we will use this method in the lookup of the AXDclass string edit control.

void generateAXDClassesLookupTable()

{

AXDBase componentInstance;

Dictionary dictionary;

SysDictClass dictClass;

int i;

int classCount;

classId componentInterfaceId,componentInterfaceId1;

SysTableLookup sysTableLookup;

;

dictionary = new Dictionary();

componentInterfaceId1=classNum(AxdLedgerGeneralJournal);

classCount = dictionary.classCnt();

progress.rangeLo(1);

progress.rangeHi(classCount);

progress.pos(1);

progress.step(1);

progress.visible(true);

for (i=1; i <= classCount; i++)

{

progress.pos(i);

dictClass = new SysDictClass(dictionary.classCnt2Id(i));

if (dictClass.isImplementing(componentInterfaceId1))

{

componentInstance = dictClass.makeObject();

AifAxdClassLookup.clear();

AifAxdClassLookup.ClassName = dictClass.name();

AifAxdClassLookup.insert();

}

progress.visible(false);

componentLookupGenerated = true;

}

Override the lookup method of AXDClass string edit control and add below code

public void lookup()

{

SysTableLookup tableLookup;

Query query;

QueryBuildDataSource queryBuildDataSource;

;

if (componentLookupGenerated == false)

{

element.generateAXDClassesLookupTable();

}

query = new Query();

queryBuildDataSource = query.addDataSource(tablenum(AifAxdClassLookup));

tableLookup = SysTableLookup::newParameters(tablenum(AifAxdClassLookup), this);

tableLookup.addLookupfield(fieldnum(AifAxdClassLookup, ClassName));

tableLookup.parmQuery(query);

//BP Deviation Documented.

tableLookup.parmTmpBuffer(AifAxdClassLookup);

tableLookup.parmUseLookupValue(false);

tableLookup.performFormLookup();

}

Modify the service class ex: ledgerGeneralService class in my case its ledgerGeneralJournalService

[AifDocumentCreateAttribute, SysEntryPointAttribute(true)]

public AifEntityKeyList create(LedgerGeneralJournal _ledgerGeneralJournal)

{

AifInboundPort aifInboundPort;

ClassId AxdClassId;

;

//Assign inheritance extension AXDclass for each port defined on the inboundPort added by krishna.

if (operationContext != null)

{

AxdClassId=aifInboundPort::find(operationContext.getPortName()).ClassId;

if(AxdClassId!=0)

{

_ledgerGeneralJournal.parmAXDClassId(AxdClassId);

}

//assign inheritance extension AXDclass for each port defined on the inboundPort added by krishna.

return this.createList(_ledgerGeneralJournal);

}

Now we will create a class which extends AXDclass ex: AXDLedgerGeneralJournal

class AxdLedgerGeneralJournal_GeneralALL extends AxdLedgerGeneralJournal

{

}

Override the queryName method and use which query you are using for your inbound AIF

In my example I am using AXDLedgerGeneralJournal

public QueryName getQueryName()

{

return querystr(AxdLedgerGeneralJournal);

}

Now you can override whatever the method you want to overiride, in my case I am overriding deserializeentity.

This method contains all my modification logic.

public void afterDeserializeEntity(AxInternalBase _axbc, tableId _tableId, str _dataSourceName)

{

AxdBaseProperty axdBaseProperty = new AxdBaseProperty();

container dimensionValue, axdBasePropertyContainer, dimensionValueConverted,bankDimensionContainer;

recId dimensionFieldRecId,bankDimensionFieldRecid;

int containerElementIndex = 1;

int containerLength;

int fieldId;

selectableDataArea company, offsetCompany;

BankAccountTable localBankAccountTable;

AccountStatementRules AccountStatementRules;

JournalNameId localJournalName;

LogisticsPostalAddressView locallogisticsPostalAddressView;

LogisticsLocationParty logisticslocationParty;

CustTable localCustTable;

MappingText localMappingText="";

localJournalName="";

dimensionFieldRecId=0;

containerLength = conLen(fieldList);

if (containerLength == 0)

{

return;

}

if(_tableId == tableNum(LedgerJournalTrans))

{

ledgerJournalName = LedgerJournalName::find(_axbc.parentAxBC().fieldId(fieldNum(ledgerJournalTable, JournalName)));

}

if(_tableId == tableNum(LedgerJournalTable))

{

ledgerJournalName = LedgerJournalName::find(_axbc.fieldId(fieldNum(ledgerJournalTable, JournalName)));

}

if(ledgerJournalName)

{

ateAccountDefinitionId = ATEAccountDefinitionTable::findRecId(

ledgerJournalName.ATEAccountDefinitionTable

).DefinitionId;

}

if (_tableId == tableNum(LedgerJournalTrans))

{

company = _axbc.fieldId(fieldNum(LedgerJournalTrans, Company));

offsetCompany = _axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetCompany));

company = AifLookupEntry::findInternal(SystemParameters::find().LookupTableId,company);

offsetCompany = AifLookupEntry::findInternal(SystemParameters::find().LookupTableId,offsetCompany);

if(LedgerJournalName::find(_axbc.parentAxBC().fieldId(fieldNum(ledgerJournalTable, JournalName))).JournalName=="1234")

{

company =curext();

offsetCompany =curext();

}

if (company)

{

_axbc.fieldId(fieldNum(LedgerJournalTrans, Company), company);

}

else

{

company =curext();

_axbc.fieldId(fieldNum(LedgerJournalTrans, Company), company);

}

if (offsetCompany)

{

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetCompany), offsetCompany);

}

else

{

offsetCompany =curext();

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetCompany), offsetCompany);

}

// Validate the primary and offset companies.

this.validateCompany(_axbc.currentRecord(), tableNum(LedgerJournalTrans), fieldNum(LedgerJournalTrans, Company), company);

this.validateCompany(_axbc.currentRecord(), tableNum(LedgerJournalTrans), fieldNum(LedgerJournalTrans, OffsetCompany), offsetCompany);

}

{

axdBasePropertyContainer = conPeek(fieldList, containerElementIndex);

axdBaseProperty.unpack(axdBasePropertyContainer);

containerElementIndex++;

dimensionValue = conPeek(fieldList, containerElementIndex);

containerElementIndex++;

fieldId = axdBaseProperty.parmImplementingFieldId();

// If the Table number and Field number match then convert the field by calling axdDimensionUtil

// and set the corresponding field through its parm method.

if (_tableId == tableNum(LedgerJournalTable) &&

fieldId == fieldNum(LedgerJournalTable, OffsetLedgerDimension))

{

// MultiTypeDefaultAccount requires an account type to be specified.

//return AxdDimensionUtil::getMultiTypeDefaultAccountId(_accountTypeEnumId, _accountType, _dimensionValue);

dimensionFieldRecId = AxdDimensionUtil::getMultiTypeDefaultAccountId(enumName2Id('LedgerJournalACType'),

_axbc.fieldId(fieldNum(LedgerJournalTable, OffsetAccountType)),

dimensionValue);

_axbc.fieldId(fieldNum(LedgerJournalTable, OffsetLedgerDimension), dimensionFieldRecId);

}

else if (_tableId == tableNum(LedgerJournalTrans))

{

if (fieldId == fieldNum(LedgerJournalTrans, LedgerDimension))

{

if (ateAccountDefinitionId)

{

dimensionValueConverted = this.ConvertLedgerdimension_PC(

_axbc.fieldId(fieldNum(LedgerJournalTrans, ExternalAccountString))

, _axbc.fieldId(fieldNum(LedgerJournalTrans, Company))

, _axbc.fieldId(fieldNum(LedgerJournalTrans, CurrencyCode))

, LedgerJournalName::find(_axbc.parentAxBC().fieldId(fieldNum(ledgerJournalTable, JournalName))).JournalName);

if (BankAccountTable::exist(conPeek(dimensionValueConverted,2)))

{

_axbc.fieldId(fieldNum(LedgerJournalTrans, AccountType), LedgerJournalACType::Bank);

_axbc.fieldId(fieldNum(LedgerJournalTrans,DefaultDimension),BankAccountTable::find(conPeek(dimensionValueConverted,2)).DefaultDimension);

}

dimensionFieldRecId = AxdDimensionUtil::getMultiTypeAccountId(enumName2Id('LedgerJournalACType'),

_axbc.fieldId(fieldNum(LedgerJournalTrans, AccountType)),

dimensionValueConverted,

company);

}

else //Non ATE starts

{

dimensionFieldRecId = AxdDimensionUtil::getMultiTypeAccountId(enumName2Id('LedgerJournalACType'),

_axbc.fieldId(fieldNum(LedgerJournalTrans, AccountType)),

dimensionValue,

company);

}// Else Non ATE closed

_axbc.fieldId(fieldNum(LedgerJournalTrans, LedgerDimension), dimensionFieldRecId);

}// IF ledgerJournalTrans ledgerDimensionClosed field is closed

else if (fieldId == fieldNum(LedgerJournalTrans, OffsetLedgerDimension))

{

if (ateAccountDefinitionId)

{

dimensionValueConverted = this.ConvertLedgerdimension_PC(

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetAccountString))

, _axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetCompany))

, _axbc.fieldId(fieldNum(LedgerJournalTrans, CurrencyCode))

,LedgerJournalName::find(_axbc.parentAxBC().fieldId(fieldNum(ledgerJournalTable, JournalName))).JournalName);

dimensionFieldRecId = AxdDimensionUtil::getMultiTypeAccountId(enumName2Id('LedgerJournalACType'),

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetAccountType)),

dimensionValueConverted,//dimensionValue,

offsetCompany);

}// ATE offset closed

else

{

dimensionFieldRecId = AxdDimensionUtil::getMultiTypeAccountId(enumName2Id('LedgerJournalACType'),

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetAccountType)),

dimensionValue,

offsetCompany);

}//ELse non ATE offset closed

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetLedgerDimension), dimensionFieldRecId);

}//Else if OffsetLedger dimension closed

else if (fieldId == fieldNum(LedgerJournalTrans, DefaultDimension))

{

dimensionFieldRecId = AxdDimensionUtil::getDimensionAttributeValueSetId(dimensionValue, company);

_axbc.fieldId(fieldNum(LedgerJournalTrans, DefaultDimension), dimensionFieldRecId);

}//Else if Default dimension closed

else if (fieldId == fieldNum(LedgerJournalTrans, OffsetDefaultDimension))

{

// OffsetDefaultDimension requires a Legal entity to be specified to support intercompany transactions.

dimensionFieldRecId = AxdDimensionUtil::getDimensionAttributeValueSetId(dimensionValue, offsetCompany);

_axbc.fieldId(fieldNum(LedgerJournalTrans, OffsetDefaultDimension), dimensionFieldRecId);

}//Else if OffsetDefault dimension closed

}//IF ledgerJournalTrans table check closed

}//Do while closed

while (containerElementIndex < containerLength);

fieldList = conNull();

}

If you guys likes this post please share it and like this post.

if you have any queries please contact and message me.

List out elements not added to version control from project

2015-03-09T13:25:00.000+00:00

This job is used to list all elements not added to tfs(due to tfs) in project.

static void Krishh_projectElementsNotaddedtoTFS(Args _args)
{

Treenode parentNode,childnode;

TreenodeIterator rootiterator;
VersionControl vs;
ProjectNode pln,plnproj;
ProjectListNode list;

;
vs=new VersionControl();
vs.init();

parentNode = infolog.projectRootNode();
list=infolog.projectRootNode().AOTfindChild("Private");

rootiterator=list.AOTiterator();
pln=list.AOTfindChild("Testproject");
plnproj=pln.loadForInspection();
rootiterator=plnproj.AOTiterator();
childnode=rootiterator.next();

while(childnode)
{

if(vs.allowCreate(childnode))
{
info(childnode.AOTname());
}
childnode=rootiterator.next();
}
}

Get Multiple files from Folder

2014-12-04T09:25:00.001+00:00

static container Krishh_findMatchingFiles(str _folderPath, str _filePattern = '*.*')
{
System.IO.DirectoryInfo directory;
System.IO.FileInfo[] files;
System.IO.FileInfo file;
InteropPermission permission;

str fileName;
counter filesCount;
counter loop;
container mathchingFiles;
;

permission = new InteropPermission(InteropKind::ClrInterop);
permission.assert();

directory = new System.IO.DirectoryInfo(_folderPath);
files = directory.GetFiles(_filePattern);
filesCount = files.get_Length();

for (loop = 0; loop < filesCount; loop++)
{
file = files.GetValue(loop);
fileName = file.get_FullName();
mathchingFiles = conins(mathchingFiles, conlen(mathchingFiles) + 1, fileName);
}

CodeAccessPermission::revertAssert();

return mathchingFiles;
}

I placed the above method in Global class, so we can use that in your classes.
Make sure your folder should have access permissions when you are running in the batch.

static void Krishh_fetchFiles(Args _args)
{
container files;
counter loop;
str fileName;
;
//Assign the folder path with the file pattern if you want to filter by ex *.txt or k*.txt or m*.*..etc.
files = Global::Krishh_findMatchingFiles(AxdDocumentParameters::find().PaymJournalFile);

for (loop = 1; loop <= conlen(files); loop++)
{
fileName = conpeek(files, loop);
info(fileName);
}

}