@ -15,6 +15,7 @@
* /
import $ from 'jquery' ;
import 'javascript-detect-element-resize/detect-element-resize' ;
import Subscription from '../api/subscription' ;
/* eslint-disable angular/angularelement */
@ -34,19 +35,11 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
$scope . rpcErrorText = null ;
$scope . rpcEnabled = false ;
$scope . executingRpcRequest = false ;
$scope . executingPromises = [ ] ;
var gridsterItemInited = false ;
var datasourceListeners = [ ] ;
var targetDeviceAliasId = null ;
var targetDeviceId = null ;
var originalTimewindow = null ;
var subscriptionTimewindow = null ;
var cafs = { } ;
var varsRegex = /\$\{([^\}]*)\}/g ;
/ *
* data = array of datasourceData
* datasourceData = {
@ -54,8 +47,6 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
* dataKey , { name , config }
* data = array of [ time , value ]
* }
*
*
* /
var widgetContext = {
@ -71,22 +62,70 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
settings : widget . config . settings ,
units : widget . config . units || '' ,
decimals : angular . isDefined ( widget . config . decimals ) ? widget . config . decimals : 2 ,
datasources : angular . copy ( widget . config . datasources ) ,
data : [ ] ,
hiddenData : [ ] ,
timeWindow : {
stDiff : stDiff
} ,
subscriptions : { } ,
defaultSubscription : null ,
timewindowFunctions : {
onUpdateTimewindow : onUpdateTimewindow ,
onResetTimewindow : onResetTimewindow
onUpdateTimewindow : function ( startTimeMs , endTimeMs ) {
if ( widgetContext . defaultSubscription ) {
widgetContext . defaultSubscription . onUpdateTimewindow ( startTimeMs , endTimeMs ) ;
}
} ,
onResetTimewindow : function ( ) {
if ( widgetContext . defaultSubscription ) {
widgetContext . defaultSubscription . onResetTimewindow ( ) ;
}
}
} ,
subscriptionApi : {
createSubscription : function ( options , subscribe ) {
return createSubscription ( options , subscribe ) ;
} ,
// type: "timeseries" or "latest" or "rpc"
/ * d e v i c e s S u b s c r i p t i o n I n f o = [
{
deviceId : ""
deviceName : ""
timeseries : [ { name : "" , label : "" } , . . ]
attributes : [ { name : "" , label : "" } , . . ]
}
. .
] * /
// options = {
// timeWindowConfig,
// useDashboardTimewindow,
// legendConfig,
// decimals,
// units,
// callbacks [ onDataUpdated(subscription, apply) ]
// }
//
createSubscriptionFromInfo : function ( type , subscriptionsInfo , options , useDefaultComponents , subscribe ) {
return createSubscriptionFromInfo ( type , subscriptionsInfo , options , useDefaultComponents , subscribe ) ;
} ,
removeSubscription : function ( id ) {
var subscription = widgetContext . subscriptions [ id ] ;
if ( subscription ) {
subscription . destroy ( ) ;
delete widgetContext . subscriptions [ id ] ;
}
}
} ,
controlApi : {
sendOneWayCommand : function ( method , params , timeout ) {
return sendCommand ( true , method , params , timeout ) ;
if ( widgetContext . defaultSubscription ) {
return widgetContext . defaultSubscription . sendOneWayCommand ( method , params , timeout ) ;
}
return null ;
} ,
sendTwoWayCommand : function ( method , params , timeout ) {
return sendCommand ( false , method , params , timeout ) ;
if ( widgetContext . defaultSubscription ) {
return widgetContext . defaultSubscription . sendTwoWayCommand ( method , params , timeout ) ;
}
return null ;
}
} ,
utils : {
@ -94,7 +133,27 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
}
} ;
var subscriptionContext = {
$scope : $scope ,
$q : $q ,
$filter : $filter ,
$timeout : $timeout ,
tbRaf : tbRaf ,
timeService : timeService ,
deviceService : deviceService ,
datasourceService : datasourceService ,
utils : utils ,
widgetUtils : widgetContext . utils ,
dashboardTimewindowApi : dashboardTimewindowApi ,
types : types ,
stDiff : stDiff ,
aliasesInfo : aliasesInfo
} ;
var widgetTypeInstance ;
vm . useCustomDatasources = false ;
try {
widgetTypeInstance = new widgetType ( widgetContext ) ;
} catch ( e ) {
@ -119,19 +178,14 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
if ( ! widgetTypeInstance . onDestroy ) {
widgetTypeInstance . onDestroy = function ( ) { } ;
}
//var bounds = {top: 0, left: 0, bottom: 0, right: 0};
//TODO: widgets visibility
/*var visible = false;*/
$scope . clearRpcError = function ( ) {
$scope . rpcRejection = null ;
$scope . rpcErrorText = null ;
if ( widgetTypeInstance . useCustomDatasources ) {
vm . useCustomDatasources = widgetTypeInstance . useCustomDatasources ( ) ;
}
vm . gridsterItemInitialized = gridsterItemInitialized ;
//TODO: widgets visibility
//var bounds = {top: 0, left: 0, bottom: 0, right: 0};
/*var visible = false;*/
/ * v m . v i s i b l e R e c t C h a n g e d = v i s i b l e R e c t C h a n g e d ;
function visibleRectChanged ( newVisibleRect ) {
@ -139,23 +193,216 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
updateVisibility ( ) ;
} * /
$scope . clearRpcError = function ( ) {
if ( widgetContext . defaultSubscription ) {
widgetContext . defaultSubscription . clearRpcError ( ) ;
}
}
vm . gridsterItemInitialized = gridsterItemInitialized ;
initialize ( ) ;
function handleWidgetException ( e ) {
$log . error ( e ) ;
$scope . widgetErrorData = utils . processWidgetException ( e ) ;
/ *
options = {
type ,
targetDeviceAliasIds , // RPC
targetDeviceIds , // RPC
datasources ,
timeWindowConfig ,
useDashboardTimewindow ,
legendConfig ,
decimals ,
units ,
callbacks
}
* /
function createSubscriptionFromInfo ( type , subscriptionsInfo , options , useDefaultComponents , subscribe ) {
var deferred = $q . defer ( ) ;
options . type = type ;
if ( useDefaultComponents ) {
defaultComponentsOptions ( options ) ;
} else {
if ( ! options . timeWindowConfig ) {
options . useDashboardTimewindow = true ;
}
}
utils . createDatasoucesFromSubscriptionsInfo ( subscriptionsInfo ) . then (
function ( datasources ) {
options . datasources = datasources ;
var subscription = createSubscription ( options , subscribe ) ;
if ( useDefaultComponents ) {
defaultSubscriptionOptions ( subscription , options ) ;
}
deferred . resolve ( subscription ) ;
}
) ;
return deferred . promise ;
}
function createSubscription ( options , subscribe ) {
options . dashboardTimewindow = dashboardTimewindow ;
var subscription =
new Subscription ( subscriptionContext , options ) ;
widgetContext . subscriptions [ subscription . id ] = subscription ;
if ( subscribe ) {
subscription . subscribe ( ) ;
}
return subscription ;
}
function notifyDataLoaded ( ) {
if ( $scope . loadingData === true ) {
function defaultComponentsOptions ( options ) {
options . useDashboardTimewindow = angular . isDefined ( widget . config . useDashboardTimewindow )
? widget . config . useDashboardTimewindow : true ;
options . timeWindowConfig = options . useDashboardTimewindow ? dashboardTimewindow : widget . config . timewindow ;
options . legendConfig = null ;
if ( $scope . displayLegend ) {
options . legendConfig = $scope . legendConfig ;
}
options . decimals = widgetContext . decimals ;
options . units = widgetContext . units ;
options . callbacks = {
onDataUpdated : function ( ) {
widgetTypeInstance . onDataUpdated ( ) ;
} ,
onDataUpdateError : function ( subscription , e ) {
handleWidgetException ( e ) ;
} ,
dataLoading : function ( subscription ) {
if ( $scope . loadingData !== subscription . loadingData ) {
$scope . loadingData = subscription . loadingData ;
}
} ,
legendDataUpdated : function ( subscription , apply ) {
if ( apply ) {
$scope . $digest ( ) ;
}
} ,
timeWindowUpdated : function ( subscription , timeWindowConfig ) {
widget . config . timewindow = timeWindowConfig ;
$scope . $apply ( ) ;
}
}
}
function defaultSubscriptionOptions ( subscription , options ) {
if ( ! options . useDashboardTimewindow ) {
$scope . $watch ( function ( ) {
return widget . config . timewindow ;
} , function ( newTimewindow , prevTimewindow ) {
if ( ! angular . equals ( newTimewindow , prevTimewindow ) ) {
subscription . updateTimewindowConfig ( widget . config . timewindow ) ;
}
} ) ;
}
if ( $scope . displayLegend ) {
$scope . legendData = subscription . legendData ;
}
}
function createDefaultSubscription ( ) {
var subscription ;
var options ;
if ( widget . type !== types . widgetType . rpc . value && widget . type !== types . widgetType . static . value ) {
options = {
type : widget . type ,
datasources : angular . copy ( widget . config . datasources )
} ;
defaultComponentsOptions ( options ) ;
subscription = createSubscription ( options ) ;
defaultSubscriptionOptions ( subscription , options ) ;
// backward compatibility
widgetContext . datasources = subscription . datasources ;
widgetContext . data = subscription . data ;
widgetContext . hiddenData = subscription . hiddenData ;
widgetContext . timeWindow = subscription . timeWindow ;
} else if ( widget . type === types . widgetType . rpc . value ) {
$scope . loadingData = false ;
options = {
type : widget . type ,
targetDeviceAliasIds : widget . config . targetDeviceAliasIds
}
options . callbacks = {
rpcStateChanged : function ( subscription ) {
$scope . rpcEnabled = subscription . rpcEnabled ;
$scope . executingRpcRequest = subscription . executingRpcRequest ;
} ,
onRpcSuccess : function ( subscription ) {
$scope . executingRpcRequest = subscription . executingRpcRequest ;
} ,
onRpcFailed : function ( subscription ) {
$scope . executingRpcRequest = subscription . executingRpcRequest ;
$scope . rpcErrorText = subscription . rpcErrorText ;
$scope . rpcRejection = subscription . rpcRejection ;
} ,
onRpcErrorCleared : function ( ) {
$scope . rpcErrorText = null ;
$scope . rpcRejection = null ;
}
}
subscription = createSubscription ( options ) ;
} else if ( widget . type === types . widgetType . static . value ) {
$scope . loadingData = false ;
}
if ( subscription ) {
widgetContext . defaultSubscription = subscription ;
}
}
function notifyDataLoading ( ) {
if ( $scope . loadingData === false ) {
$scope . loadingData = true ;
function initialize ( ) {
if ( ! vm . useCustomDatasources ) {
createDefaultSubscription ( ) ;
} else {
$scope . loadingData = false ;
}
$scope . $on ( 'toggleDashboardEditMode' , function ( event , isEdit ) {
onEditModeChanged ( isEdit ) ;
} ) ;
addResizeListener ( widgetContext . $containerParent [ 0 ] , onResize ) ; // eslint-disable-line no-undef
$scope . $watch ( function ( ) {
return widget . row + ',' + widget . col + ',' + widget . config . mobileOrder ;
} , function ( ) {
//updateBounds();
$scope . $emit ( "widgetPositionChanged" , widget ) ;
} ) ;
$scope . $on ( 'gridster-item-resized' , function ( event , item ) {
if ( ! widgetContext . isMobile ) {
widget . sizeX = item . sizeX ;
widget . sizeY = item . sizeY ;
}
} ) ;
$scope . $on ( 'mobileModeChanged' , function ( event , newIsMobile ) {
onMobileModeChanged ( newIsMobile ) ;
} ) ;
$scope . $on ( "$destroy" , function ( ) {
removeResizeListener ( widgetContext . $containerParent [ 0 ] , onResize ) ; // eslint-disable-line no-undef
onDestroy ( ) ;
} ) ;
}
function handleWidgetException ( e ) {
$log . error ( e ) ;
$scope . widgetErrorData = utils . processWidgetException ( e ) ;
}
function onInit ( ) {
@ -166,42 +413,12 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
} catch ( e ) {
handleWidgetException ( e ) ;
}
if ( widgetContext . dataUpdatePending ) {
widgetContext . dataUpdatePending = false ;
onDataUpdated ( ) ;
if ( ! vm . useCustomDatasources && widgetContext . defaultSubscription ) {
widgetContext . defaultSubscription . subscribe ( ) ;
}
}
}
function updateTimewindow ( ) {
widgetContext . timeWindow . interval = subscriptionTimewindow . aggregation . interval || 1000 ;
if ( subscriptionTimewindow . realtimeWindowMs ) {
widgetContext . timeWindow . maxTime = ( new Date ) . getTime ( ) + widgetContext . timeWindow . stDiff ;
widgetContext . timeWindow . minTime = widgetContext . timeWindow . maxTime - subscriptionTimewindow . realtimeWindowMs ;
} else if ( subscriptionTimewindow . fixedWindow ) {
widgetContext . timeWindow . maxTime = subscriptionTimewindow . fixedWindow . endTimeMs ;
widgetContext . timeWindow . minTime = subscriptionTimewindow . fixedWindow . startTimeMs ;
}
}
function onDataUpdated ( ) {
if ( widgetContext . inited ) {
if ( cafs [ 'dataUpdate' ] ) {
cafs [ 'dataUpdate' ] ( ) ;
cafs [ 'dataUpdate' ] = null ;
}
cafs [ 'dataUpdate' ] = tbRaf ( function ( ) {
try {
widgetTypeInstance . onDataUpdated ( ) ;
} catch ( e ) {
handleWidgetException ( e ) ;
}
} ) ;
} else {
widgetContext . dataUpdatePending = true ;
}
}
function checkSize ( ) {
var width = widgetContext . $containerParent . width ( ) ;
var height = widgetContext . $containerParent . height ( ) ;
@ -289,11 +506,35 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
}
}
function isNumeric ( val ) {
return ( val - parseFloat ( val ) + 1 ) >= 0 ;
}
function formatValue ( value , dec , units ) {
if ( angular . isDefined ( value ) &&
value !== null && isNumeric ( value ) ) {
var formatted = value ;
if ( angular . isDefined ( dec ) ) {
formatted = formatted . toFixed ( dec ) ;
}
formatted = ( formatted * 1 ) . toString ( ) ;
if ( angular . isDefined ( units ) && units . length > 0 ) {
formatted += ' ' + units ;
}
return formatted ;
} else {
return '' ;
}
}
function onDestroy ( ) {
unsubscribe ( ) ;
for ( var id in widgetContext . subscriptions ) {
var subscription = widgetContext . subscriptions [ id ] ;
subscription . destroy ( ) ;
}
widgetContext . subscriptions = [ ] ;
if ( widgetContext . inited ) {
widgetContext . inited = false ;
widgetContext . dataUpdatePending = false ;
for ( var cafId in cafs ) {
if ( cafs [ cafId ] ) {
cafs [ cafId ] ( ) ;
@ -308,243 +549,6 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
}
}
function onRestart ( ) {
onDestroy ( ) ;
onInit ( ) ;
}
/ * s c o p e . l e g e n d D a t a = {
keys : [ ] ,
data : [ ]
key : {
label : '' ,
color : ''
dataIndex : 0
}
data : {
min : null ,
max : null ,
avg : null ,
total : null
}
} ; * /
function initialize ( ) {
$scope . caulculateLegendData = $scope . displayLegend &&
widget . type === types . widgetType . timeseries . value &&
( $scope . legendConfig . showMin === true ||
$scope . legendConfig . showMax === true ||
$scope . legendConfig . showAvg === true ||
$scope . legendConfig . showTotal === true ) ;
if ( widget . type !== types . widgetType . rpc . value && widget . type !== types . widgetType . static . value ) {
for ( var i = 0 ; i < widgetContext . datasources . length ; i ++ ) {
var datasource = widgetContext . datasources [ i ] ;
for ( var a = 0 ; a < datasource . dataKeys . length ; a ++ ) {
var dataKey = datasource . dataKeys [ a ] ;
dataKey . pattern = angular . copy ( dataKey . label ) ;
var datasourceData = {
datasource : datasource ,
dataKey : dataKey ,
data : [ ]
} ;
widgetContext . data . push ( datasourceData ) ;
widgetContext . hiddenData . push ( { data : [ ] } ) ;
if ( $scope . displayLegend ) {
var legendKey = {
dataKey : dataKey ,
dataIndex : Number ( i ) + Number ( a )
} ;
$scope . legendData . keys . push ( legendKey ) ;
var legendKeyData = {
min : null ,
max : null ,
avg : null ,
total : null ,
hidden : false
} ;
$scope . legendData . data . push ( legendKeyData ) ;
}
}
}
if ( $scope . displayLegend ) {
$scope . legendData . keys = $filter ( 'orderBy' ) ( $scope . legendData . keys , '+label' ) ;
$scope . $on ( 'legendDataHiddenChanged' , function ( event , index ) {
event . stopPropagation ( ) ;
var hidden = $scope . legendData . data [ index ] . hidden ;
if ( hidden ) {
widgetContext . hiddenData [ index ] . data = widgetContext . data [ index ] . data ;
widgetContext . data [ index ] . data = [ ] ;
} else {
widgetContext . data [ index ] . data = widgetContext . hiddenData [ index ] . data ;
widgetContext . hiddenData [ index ] . data = [ ] ;
}
onDataUpdated ( ) ;
} ) ;
}
} else if ( widget . type === types . widgetType . rpc . value ) {
if ( widget . config . targetDeviceAliasIds && widget . config . targetDeviceAliasIds . length > 0 ) {
targetDeviceAliasId = widget . config . targetDeviceAliasIds [ 0 ] ;
if ( aliasesInfo . deviceAliases [ targetDeviceAliasId ] ) {
targetDeviceId = aliasesInfo . deviceAliases [ targetDeviceAliasId ] . deviceId ;
}
}
if ( targetDeviceId ) {
$scope . rpcEnabled = true ;
} else {
$scope . rpcEnabled = $scope . widgetEditMode ? true : false ;
}
}
$scope . $on ( 'toggleDashboardEditMode' , function ( event , isEdit ) {
onEditModeChanged ( isEdit ) ;
} ) ;
addResizeListener ( widgetContext . $containerParent [ 0 ] , onResize ) ; // eslint-disable-line no-undef
$scope . $watch ( function ( ) {
return widget . row + ',' + widget . col + ',' + widget . config . mobileOrder ;
} , function ( ) {
//updateBounds();
$scope . $emit ( "widgetPositionChanged" , widget ) ;
} ) ;
$scope . $on ( 'gridster-item-resized' , function ( event , item ) {
if ( ! widgetContext . isMobile ) {
widget . sizeX = item . sizeX ;
widget . sizeY = item . sizeY ;
}
} ) ;
$scope . $on ( 'mobileModeChanged' , function ( event , newIsMobile ) {
onMobileModeChanged ( newIsMobile ) ;
} ) ;
$scope . $on ( 'deviceAliasListChanged' , function ( event , newAliasesInfo ) {
aliasesInfo = newAliasesInfo ;
if ( widget . type === types . widgetType . rpc . value ) {
if ( targetDeviceAliasId ) {
var deviceId = null ;
if ( aliasesInfo . deviceAliases [ targetDeviceAliasId ] ) {
deviceId = aliasesInfo . deviceAliases [ targetDeviceAliasId ] . deviceId ;
}
if ( ! angular . equals ( deviceId , targetDeviceId ) ) {
targetDeviceId = deviceId ;
if ( targetDeviceId ) {
$scope . rpcEnabled = true ;
} else {
$scope . rpcEnabled = $scope . widgetEditMode ? true : false ;
}
onRestart ( ) ;
}
}
} else {
checkSubscriptions ( ) ;
}
} ) ;
$scope . $on ( "$destroy" , function ( ) {
removeResizeListener ( widgetContext . $containerParent [ 0 ] , onResize ) ; // eslint-disable-line no-undef
onDestroy ( ) ;
} ) ;
if ( widget . type === types . widgetType . timeseries . value ) {
widgetContext . useDashboardTimewindow = angular . isDefined ( widget . config . useDashboardTimewindow )
? widget . config . useDashboardTimewindow : true ;
if ( widgetContext . useDashboardTimewindow ) {
$scope . $on ( 'dashboardTimewindowChanged' , function ( event , newDashboardTimewindow ) {
if ( ! angular . equals ( dashboardTimewindow , newDashboardTimewindow ) ) {
dashboardTimewindow = newDashboardTimewindow ;
unsubscribe ( ) ;
subscribe ( ) ;
}
} ) ;
} else {
$scope . $watch ( function ( ) {
return widgetContext . useDashboardTimewindow ? dashboardTimewindow : widget . config . timewindow ;
} , function ( newTimewindow , prevTimewindow ) {
if ( ! angular . equals ( newTimewindow , prevTimewindow ) ) {
unsubscribe ( ) ;
subscribe ( ) ;
}
} ) ;
}
}
subscribe ( ) ;
}
function sendCommand ( oneWayElseTwoWay , method , params , timeout ) {
if ( ! $scope . rpcEnabled ) {
return $q . reject ( ) ;
}
if ( $scope . rpcRejection && $scope . rpcRejection . status !== 408 ) {
$scope . rpcRejection = null ;
$scope . rpcErrorText = null ;
}
var requestBody = {
method : method ,
params : params
} ;
if ( timeout && timeout > 0 ) {
requestBody . timeout = timeout ;
}
var deferred = $q . defer ( ) ;
$scope . executingRpcRequest = true ;
if ( $scope . widgetEditMode ) {
$timeout ( function ( ) {
$scope . executingRpcRequest = false ;
if ( oneWayElseTwoWay ) {
deferred . resolve ( ) ;
} else {
deferred . resolve ( requestBody ) ;
}
} , 500 ) ;
} else {
$scope . executingPromises . push ( deferred . promise ) ;
var targetSendFunction = oneWayElseTwoWay ? deviceService . sendOneWayRpcCommand : deviceService . sendTwoWayRpcCommand ;
targetSendFunction ( targetDeviceId , requestBody ) . then (
function success ( responseBody ) {
$scope . rpcRejection = null ;
$scope . rpcErrorText = null ;
var index = $scope . executingPromises . indexOf ( deferred . promise ) ;
if ( index >= 0 ) {
$scope . executingPromises . splice ( index , 1 ) ;
}
$scope . executingRpcRequest = $scope . executingPromises . length > 0 ;
deferred . resolve ( responseBody ) ;
} ,
function fail ( rejection ) {
var index = $scope . executingPromises . indexOf ( deferred . promise ) ;
if ( index >= 0 ) {
$scope . executingPromises . splice ( index , 1 ) ;
}
$scope . executingRpcRequest = $scope . executingPromises . length > 0 ;
if ( ! $scope . executingRpcRequest || rejection . status === 408 ) {
$scope . rpcRejection = rejection ;
if ( rejection . status === 408 ) {
$scope . rpcErrorText = 'Device is offline.' ;
} else {
$scope . rpcErrorText = 'Error : ' + rejection . status + ' - ' + rejection . statusText ;
if ( rejection . data && rejection . data . length > 0 ) {
$scope . rpcErrorText += '</br>' ;
$scope . rpcErrorText += rejection . data ;
}
}
}
deferred . reject ( rejection ) ;
}
) ;
}
return deferred . promise ;
}
//TODO: widgets visibility
/ * f u n c t i o n u p d a t e V i s i b i l i t y ( f o r c e R e d r a w ) {
if ( visibleRect ) {
@ -583,285 +587,6 @@ export default function WidgetController($scope, $timeout, $window, $element, $q
onRedraw ( ) ;
} * /
function onResetTimewindow ( ) {
if ( widgetContext . useDashboardTimewindow ) {
dashboardTimewindowApi . onResetTimewindow ( ) ;
} else {
if ( originalTimewindow ) {
widget . config . timewindow = angular . copy ( originalTimewindow ) ;
originalTimewindow = null ;
}
}
}
function onUpdateTimewindow ( startTimeMs , endTimeMs ) {
if ( widgetContext . useDashboardTimewindow ) {
dashboardTimewindowApi . onUpdateTimewindow ( startTimeMs , endTimeMs ) ;
} else {
if ( ! originalTimewindow ) {
originalTimewindow = angular . copy ( widget . config . timewindow ) ;
}
widget . config . timewindow = timeService . toHistoryTimewindow ( widget . config . timewindow , startTimeMs , endTimeMs ) ;
}
}
function dataUpdated ( sourceData , datasourceIndex , dataKeyIndex , apply ) {
notifyDataLoaded ( ) ;
var update = true ;
var currentData ;
if ( $scope . displayLegend && $scope . legendData . data [ datasourceIndex + dataKeyIndex ] . hidden ) {
currentData = widgetContext . hiddenData [ datasourceIndex + dataKeyIndex ] ;
} else {
currentData = widgetContext . data [ datasourceIndex + dataKeyIndex ] ;
}
if ( widget . type === types . widgetType . latest . value ) {
var prevData = currentData . data ;
if ( prevData && prevData [ 0 ] && prevData [ 0 ] . length > 1 && sourceData . data . length > 0 ) {
var prevValue = prevData [ 0 ] [ 1 ] ;
if ( prevValue === sourceData . data [ 0 ] [ 1 ] ) {
update = false ;
}
}
}
if ( update ) {
if ( subscriptionTimewindow && subscriptionTimewindow . realtimeWindowMs ) {
updateTimewindow ( ) ;
}
currentData . data = sourceData . data ;
onDataUpdated ( ) ;
if ( $scope . caulculateLegendData ) {
updateLegend ( datasourceIndex + dataKeyIndex , sourceData . data , apply ) ;
}
}
if ( apply ) {
$scope . $digest ( ) ;
}
}
function updateLegend ( dataIndex , data , apply ) {
var legendKeyData = $scope . legendData . data [ dataIndex ] ;
if ( $scope . legendConfig . showMin ) {
legendKeyData . min = formatValue ( calculateMin ( data ) , widgetContext . decimals , widgetContext . units ) ;
}
if ( $scope . legendConfig . showMax ) {
legendKeyData . max = formatValue ( calculateMax ( data ) , widgetContext . decimals , widgetContext . units ) ;
}
if ( $scope . legendConfig . showAvg ) {
legendKeyData . avg = formatValue ( calculateAvg ( data ) , widgetContext . decimals , widgetContext . units ) ;
}
if ( $scope . legendConfig . showTotal ) {
legendKeyData . total = formatValue ( calculateTotal ( data ) , widgetContext . decimals , widgetContext . units ) ;
}
$scope . $broadcast ( 'legendDataUpdated' , apply !== false ) ;
}
function isNumeric ( val ) {
return ( val - parseFloat ( val ) + 1 ) >= 0 ;
}
function formatValue ( value , dec , units ) {
if ( angular . isDefined ( value ) &&
value !== null && isNumeric ( value ) ) {
var formatted = value ;
if ( angular . isDefined ( dec ) ) {
formatted = formatted . toFixed ( dec ) ;
}
formatted = ( formatted * 1 ) . toString ( ) ;
if ( angular . isDefined ( units ) && units . length > 0 ) {
formatted += ' ' + units ;
}
return formatted ;
} else {
return '' ;
}
}
function calculateMin ( data ) {
if ( data . length > 0 ) {
var result = Number ( data [ 0 ] [ 1 ] ) ;
for ( var i = 1 ; i < data . length ; i ++ ) {
result = Math . min ( result , Number ( data [ i ] [ 1 ] ) ) ;
}
return result ;
} else {
return null ;
}
}
function calculateMax ( data ) {
if ( data . length > 0 ) {
var result = Number ( data [ 0 ] [ 1 ] ) ;
for ( var i = 1 ; i < data . length ; i ++ ) {
result = Math . max ( result , Number ( data [ i ] [ 1 ] ) ) ;
}
return result ;
} else {
return null ;
}
}
function calculateAvg ( data ) {
if ( data . length > 0 ) {
return calculateTotal ( data ) / data . length ;
} else {
return null ;
}
}
function calculateTotal ( data ) {
if ( data . length > 0 ) {
var result = 0 ;
for ( var i = 0 ; i < data . length ; i ++ ) {
result += Number ( data [ i ] [ 1 ] ) ;
}
return result ;
} else {
return null ;
}
}
function checkSubscriptions ( ) {
if ( widget . type !== types . widgetType . rpc . value ) {
var subscriptionsChanged = false ;
for ( var i = 0 ; i < datasourceListeners . length ; i ++ ) {
var listener = datasourceListeners [ i ] ;
var deviceId = null ;
var aliasName = null ;
if ( listener . datasource . type === types . datasourceType . device ) {
if ( aliasesInfo . deviceAliases [ listener . datasource . deviceAliasId ] ) {
deviceId = aliasesInfo . deviceAliases [ listener . datasource . deviceAliasId ] . deviceId ;
aliasName = aliasesInfo . deviceAliases [ listener . datasource . deviceAliasId ] . alias ;
}
if ( ! angular . equals ( deviceId , listener . deviceId ) ||
! angular . equals ( aliasName , listener . datasource . name ) ) {
subscriptionsChanged = true ;
break ;
}
}
}
if ( subscriptionsChanged ) {
unsubscribe ( ) ;
subscribe ( ) ;
}
}
}
function unsubscribe ( ) {
if ( widget . type !== types . widgetType . rpc . value ) {
for ( var i = 0 ; i < datasourceListeners . length ; i ++ ) {
var listener = datasourceListeners [ i ] ;
datasourceService . unsubscribeFromDatasource ( listener ) ;
}
datasourceListeners = [ ] ;
}
}
function updateRealtimeSubscription ( _ subscriptionTimewindow ) {
if ( _ subscriptionTimewindow ) {
subscriptionTimewindow = _ subscriptionTimewindow ;
} else {
subscriptionTimewindow =
timeService . createSubscriptionTimewindow (
widgetContext . useDashboardTimewindow ? dashboardTimewindow : widget . config . timewindow ,
widgetContext . timeWindow . stDiff ) ;
}
updateTimewindow ( ) ;
return subscriptionTimewindow ;
}
function hasTimewindow ( ) {
if ( widgetContext . useDashboardTimewindow ) {
return angular . isDefined ( dashboardTimewindow ) ;
} else {
return angular . isDefined ( widget . config . timewindow ) ;
}
}
function updateDataKeyLabel ( dataKey , deviceName , aliasName ) {
var pattern = dataKey . pattern ;
var label = dataKey . pattern ;
var match = varsRegex . exec ( pattern ) ;
while ( match !== null ) {
var variable = match [ 0 ] ;
var variableName = match [ 1 ] ;
if ( variableName === 'deviceName' ) {
label = label . split ( variable ) . join ( deviceName ) ;
} else if ( variableName === 'aliasName' ) {
label = label . split ( variable ) . join ( aliasName ) ;
}
match = varsRegex . exec ( pattern ) ;
}
dataKey . label = label ;
}
function subscribe ( ) {
if ( widget . type !== types . widgetType . rpc . value && widget . type !== types . widgetType . static . value ) {
notifyDataLoading ( ) ;
if ( widget . type === types . widgetType . timeseries . value &&
hasTimewindow ( ) ) {
updateRealtimeSubscription ( ) ;
if ( subscriptionTimewindow . fixedWindow ) {
onDataUpdated ( ) ;
}
}
var index = 0 ;
for ( var i = 0 ; i < widgetContext . datasources . length ; i ++ ) {
var datasource = widgetContext . datasources [ i ] ;
if ( angular . isFunction ( datasource ) )
continue ;
var deviceId = null ;
if ( datasource . type === types . datasourceType . device && datasource . deviceAliasId ) {
if ( aliasesInfo . deviceAliases [ datasource . deviceAliasId ] ) {
deviceId = aliasesInfo . deviceAliases [ datasource . deviceAliasId ] . deviceId ;
datasource . name = aliasesInfo . deviceAliases [ datasource . deviceAliasId ] . alias ;
var aliasName = aliasesInfo . deviceAliases [ datasource . deviceAliasId ] . alias ;
var deviceName = '' ;
var devicesInfo = aliasesInfo . deviceAliasesInfo [ datasource . deviceAliasId ] ;
for ( var d = 0 ; d < devicesInfo . length ; d ++ ) {
if ( devicesInfo [ d ] . id === deviceId ) {
deviceName = devicesInfo [ d ] . name ;
break ;
}
}
for ( var dk = 0 ; dk < datasource . dataKeys . length ; dk ++ ) {
updateDataKeyLabel ( datasource . dataKeys [ dk ] , deviceName , aliasName ) ;
}
}
} else {
datasource . name = types . datasourceType . function ;
}
var listener = {
widget : widget ,
subscriptionTimewindow : subscriptionTimewindow ,
datasource : datasource ,
deviceId : deviceId ,
dataUpdated : function ( data , datasourceIndex , dataKeyIndex , apply ) {
dataUpdated ( data , datasourceIndex , dataKeyIndex , apply ) ;
} ,
updateRealtimeSubscription : function ( ) {
this . subscriptionTimewindow = updateRealtimeSubscription ( ) ;
return this . subscriptionTimewindow ;
} ,
setRealtimeSubscription : function ( subscriptionTimewindow ) {
updateRealtimeSubscription ( angular . copy ( subscriptionTimewindow ) ) ;
} ,
datasourceIndex : index
} ;
for ( var a = 0 ; a < datasource . dataKeys . length ; a ++ ) {
widgetContext . data [ index + a ] . data = [ ] ;
}
index += datasource . dataKeys . length ;
datasourceListeners . push ( listener ) ;
datasourceService . subscribeToDatasource ( listener ) ;
}
} else {
notifyDataLoaded ( ) ;
}
}
}
/* eslint-enable angular/angularelement */
Andrew Shvayka
10 years ago
GitHub