com.ibm.tivoli.maximo.iotservices.mapper

Class IoTCloudantProcessor

java.lang.Object

com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

com.ibm.tivoli.maximo.iotservices.historian.HistorianProcessor

com.ibm.tivoli.maximo.iotservices.mapper.IotProcessor

com.ibm.tivoli.maximo.iotservices.mapper.IoTCloudantProcessor

All Implemented Interfaces:

IoTHistorianProcessor, FixedLoggerNames, FixedLoggers

public class IoTCloudantProcessor
extends IotProcessor

Field Summary

Fields inherited from class com.ibm.tivoli.maximo.iotservices.mapper.IotProcessor

NOACCESSCHECK, NOVALIDATION_AND_NOACTION

Fields inherited from class com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

formattedUrl

Fields inherited from interface psdi.util.logging.FixedLoggers

APPLOGGER, CRONTASKLOGGER, CRONTASKMGRLOGGER, CRONTASKMGRSQLLOGGER, DBCONNECTIONLOGGER, DDLOGGER, DMLOGGER, EVENTLOGGER, EXCEPTIONLOGGER, MAILLOGGER, MAXIMOLOGGER, MTLOGGER, NULLMBOPOINTER, SECURITY, SENDFAILEDLOGGER, SERVICELOGGER, SQLLOGGER

Fields inherited from interface psdi.util.logging.FixedLoggerNames

appenderPrefix, LOGGERNAME_APP, LOGGERNAME_CRONTASK, LOGGERNAME_CRONTASKMGR, LOGGERNAME_DBCONNECTION, LOGGERNAME_DD, LOGGERNAME_DM, LOGGERNAME_DMPREVIEW, LOGGERNAME_EVENT, LOGGERNAME_EXCEPTION, LOGGERNAME_MAIL, LOGGERNAME_MAXIMO, LOGGERNAME_MT, LOGGERNAME_NULLMBOPOINTER, LOGGERNAME_SECURITY, LOGGERNAME_SENDFAILED, LOGGERNAME_SERVICE, LOGGERNAME_SQL, LOGGERNAME_SQL_CRONTASKMGR, LOGGERNAME_TXN, loggerPrefix

Constructor Summary

Constructors

Constructor and Description
IoTCloudantProcessor()

Method Summary

Modifier and Type	Method and Description
com.ibm.json.java.JSONObject	evaluateExpression(com.ibm.json.java.JSONObject jsonData, java.lang.String path)
protected java.util.List	getIOTPlatformRestURL(java.lang.String iotServiceName, java.lang.String endPointName, java.lang.String histURL, java.lang.String deviceType, IoTMeterToPayloadMappingInfo mappingInfo, java.util.Date lastRun, IoTConnectionService iotfProc, java.lang.String useWith)
java.util.Map	getReadingDate(com.ibm.json.java.JSONObject json, java.lang.String iotServiceName, IoTMeterToPayloadMappingInfo mappingInfo)
java.lang.Object	getReadings(com.ibm.json.java.JSONObject jo, IoTMeterToPayloadMappingInfo mapInfo) Map response of the external resource invocation to format accepted in AH Dash Board.
protected java.lang.String	getResultTagName(java.lang.String iotServiceName, IoTMeterToPayloadMappingInfo mappingInfo)
void	mapReadings(com.ibm.json.java.JSONArray readings, com.ibm.json.java.JSONObject jo, IoTMeterToPayloadMappingInfo mapInfo) Map response of the external resource invocation to format accepted in AH Dash Board.
com.ibm.json.java.JSONArtifact	processResource(JSONResourceInfo resourceInfo, MboRemote owner, UserInfo userInfo, int pageSize, int currentPage, JSONAnalyzer jsonAnalyzer) Invoke external Resource
java.lang.String	setReadingsForHistorianData(com.ibm.json.java.JSONObject jo, IoTMeterToPayloadMappingInfo mappingInfo, java.util.Date readingDate)

Methods inherited from class com.ibm.tivoli.maximo.iotservices.mapper.IotProcessor

getDeviceidsForDeviceTypeAsset, getDeviceidsForDeviceTypeLocation, mapAssetMeterFeedData, mapLocationMeterFeedData, processHistorianData, syncMeterReadings

Methods inherited from class com.ibm.tivoli.maximo.iotservices.historian.HistorianProcessor

pingHistorian

Methods inherited from class com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

getPagingParams, processPaging

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IoTCloudantProcessor

public IoTCloudantProcessor()
                     throws MXException,
                            java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

Method Detail

getIOTPlatformRestURL

protected java.util.List getIOTPlatformRestURL(java.lang.String iotServiceName,
                                               java.lang.String endPointName,
                                               java.lang.String histURL,
                                               java.lang.String deviceType,
                                               IoTMeterToPayloadMappingInfo mappingInfo,
                                               java.util.Date lastRun,
                                               IoTConnectionService iotfProc,
                                               java.lang.String useWith)
                                        throws MXException,
                                               java.rmi.RemoteException

Specified by:

getIOTPlatformRestURL in class IotProcessor

Throws:

MXException

java.rmi.RemoteException

getReadingDate

public java.util.Map getReadingDate(com.ibm.json.java.JSONObject json,
                                    java.lang.String iotServiceName,
                                    IoTMeterToPayloadMappingInfo mappingInfo)
                             throws java.rmi.RemoteException,
                                    MXException

Specified by:

getReadingDate in class IotProcessor

Throws:

java.rmi.RemoteException

MXException

setReadingsForHistorianData

public java.lang.String setReadingsForHistorianData(com.ibm.json.java.JSONObject jo,
                                                    IoTMeterToPayloadMappingInfo mappingInfo,
                                                    java.util.Date readingDate)
                                             throws MXException

Specified by:

setReadingsForHistorianData in class IotProcessor

Throws:

MXException

processResource

public com.ibm.json.java.JSONArtifact processResource(JSONResourceInfo resourceInfo,
                                                      MboRemote owner,
                                                      UserInfo userInfo,
                                                      int pageSize,
                                                      int currentPage,
                                                      JSONAnalyzer jsonAnalyzer)
                                               throws MXException,
                                                      java.rmi.RemoteException

Invoke external Resource

Overrides:

processResource in class HistorianProcessor

Parameters:

pageSize - Page size if paging is used

pageNum - Current page

Returns:

JSON from external resource invocation

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

mapReadings

public void mapReadings(com.ibm.json.java.JSONArray readings,
                        com.ibm.json.java.JSONObject jo,
                        IoTMeterToPayloadMappingInfo mapInfo)
                 throws MXException,
                        java.rmi.RemoteException

Map response of the external resource invocation to format accepted in AH Dash Board. This method can both getting date from historian and mapping it.

Parameters:

ja - JSON with results of the external invocation

pageSize - Page size if paging is used

pageNum - Current page

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

getReadings

public java.lang.Object getReadings(com.ibm.json.java.JSONObject jo,
                                    IoTMeterToPayloadMappingInfo mapInfo)
                             throws MXException,
                                    java.rmi.RemoteException

Map response of the external resource invocation to format accepted in AH Dash Board. This method can both getting date from historian and mapping it.

Parameters:

ja - JSON with results of the external invocation

pageSize - Page size if paging is used

pageNum - Current page

Returns:

JSON from external resource invocation

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

evaluateExpression

public com.ibm.json.java.JSONObject evaluateExpression(com.ibm.json.java.JSONObject jsonData,
                                                       java.lang.String path)
                                                throws MXException

Throws:

MXException

getResultTagName

protected java.lang.String getResultTagName(java.lang.String iotServiceName,
                                            IoTMeterToPayloadMappingInfo mappingInfo)

Specified by:

getResultTagName in class IotProcessor