@ -13,13 +13,12 @@ module Developer {
export var WorkspacesController = controller ( "WorkspacesController" , [ "$scope" , "KubernetesModel" , "DataModel" , "ConfigsModel" , "KubernetesState" , "$templateCache" , "$location" , "$routeParams" , "$http" , "$timeout" , "KubernetesApiURL" , "$element" , "ngDialog" ,
( $scope , KubernetesModel : Kubernetes.KubernetesModelService , DataModel :Developer.DataModelService , ConfigsModel :Configs.ConfigsModelService , KubernetesState , $templateCache :ng.ITemplateCacheService , $location :ng.ILocationService , $routeParams , $http , $timeout , KubernetesApiURL , $element , ngDialog ) = > {
$scope . model = DataModel ;
$scope . replicasModel = KubernetesModel ;
init ( $scope , $location , $routeParams ) ;
$scope . replicasModel = KubernetesModel ;
$scope . options = DataModel . paramOptions ;
$scope . pageSizeChoses = DataModel . paramOptions . pagerSizeOption ;
var result = getDataType ( $location )
$scope . options . dataType = result [ "dataType" ] ;
$scope . options . volumeType = result [ "volumeType" ] ;
var result = getDataType ( $location ) ;
$scope . treeOptions = {
nodeChildren : "childNodes" ,
@ -65,6 +64,10 @@ module Developer {
return field . systemCode ;
}
} ,
{
field : "dataBaseType" ,
displayName : '数据库类型' ,
} ,
{
field : "labels" ,
displayName : '数据标签' ,
@ -82,7 +85,7 @@ module Developer {
field : "extractStatus" ,
displayName : '汇总状态' ,
cellTemplate : $templateCache.get ( "dataExtractTemplate.html" )
}
}
] ,
sortInfo : {
sortBy : "_key" ,
@ -90,28 +93,33 @@ module Developer {
}
} ;
init ( $scope , $location , $routeParams ) ;
$scope . model . paramOptions . dataType = result [ "dataType" ] ;
$scope . model . paramOptions . volumeType = result [ "volumeType" ] ;
$scope . $on ( "dataLabelFilterUpdate" , ( $event , text , key ) = > {
$scope . keyQuery += " " + text ;
} )
$scope . selectBatchItem = ( item ) = > {
$scope . selectBatchItem = ( item ) = > {
$scope . navbarItems . forEach ( ( nav ) = > {
nav . class = "" ;
} ) ;
item . class = "active" ;
$scope . model . updateParamOption ( "currentPageNum" , 1 ) ;
$scope . model . updateParamOption ( "keyQuery" , $scope . keyQuery ) ;
$scope . model . updateParamOption ( "dataBatch" , item . alias ) ;
}
$scope . isEmptyOrFirst = ( ) = > {
var idx = $scope . model . getParamOption ( "currentPageNum" ) ;
var length = $scope . . ge tPageSizeNum( ) ;
var length = $scope . m odel. paramO ptions. otle Page;
return length <= 0 || idx <= 1 ;
}
$scope . isEmptyOrLast = ( ) = > {
var idx = $scope . model . getParamOption ( "currentPageNum" ) ;
var length = $scope . . ge tPageSizeNum( ) ;
var length = $scope . m odel. paramO ptions. otle Page;
return length < 1 || idx >= length ;
}
@ -125,7 +133,7 @@ module Developer {
$scope . last = ( ) = > {
var idx = $scope . model . getParamOption ( "currentPageNum" ) ;
var length = $scope . . ge tPageSizeNum( ) ;
var length = $scope . m odel. paramO ptions. otle Page;
if ( idx < length ) {
Kubernetes . eliminateChechBoxClick ( ) ;
$scope . model . updateParamOption ( "currentPageNum" , length ) ;
@ -134,7 +142,7 @@ module Developer {
$scope . previous = ( ) = > {
var idx = $scope . model . getParamOption ( "currentPageNum" ) ;
var length = $scope . . ge tPageSizeNum( ) ;
var length = $scope . m odel. paramO ptions. otle Page;
if ( idx > 1 ) {
Kubernetes . eliminateChechBoxClick ( ) ;
$scope . model . updateParamOption ( "currentPageNum" , idx - 1 ) ;
@ -142,7 +150,7 @@ module Developer {
}
$scope . next = ( ) = > {
var length = $scope . . ge tPageSizeNum( ) ;
var length = $scope . m odel. paramO ptions. otle Page;
var idx = $scope . model . getParamOption ( "currentPageNum" ) ;
if ( idx < length ) {
Kubernetes . eliminateChechBoxClick ( ) ;
@ -150,8 +158,8 @@ module Developer {
}
}
$scope . $watch ( ' options', ( newValue , oldValue ) = > {
if ( newValue ) {
$scope . $watch ( ' m odel.paramO ptions', ( newValue , oldValue ) = > {
if ( newValue ) {
if ( newValue . currentTableSize !== oldValue . currentTableSize )
$scope . options . priorTableSize = oldValue . currentTableSize ;
else
@ -162,6 +170,8 @@ module Developer {
} , true ) ;
$scope . search = ( ) = > {
//$scope.model.initParamOptions();
$scope . model . paramOptions . currentPageNum = 1 ;
$scope . model . updateParamOption ( "keyQuery" , $scope . keyQuery ) ;
}
@ -175,7 +185,7 @@ module Developer {
/ *
判 断 数 据 是 否 已 挂 载 使 用 和 正 在 迁 移 。
* /
var message = Kubernetes . checkForMigration ( $scope . replicasModel . replicationControllers , $scope . model . transferTasks , $scope . tableConfig . selectedItems ;
var message = Kubernetes . checkForMigration ( $scope . replicasModel . replicationControllers , $scope . model . transferTasks , $scope . tableConfig . selectedItems , "manager" );
if ( message != "" ) {
Configs . customAlert ( "提示" , "操作失败:" + message + ",不能删除！" , '' , null , 0 , "error" ) ;
return ;
@ -183,7 +193,7 @@ module Developer {
UI . multiItemConfirmActionDialog ( < UI.MultiItemConfirmActionOptions > {
collection : selected ,
index : ' id ',
index : ' alias ',
onClose : ( result :boolean ) = > {
var idColl = [ ] ;
if ( result ) {
@ -223,6 +233,7 @@ module Developer {
向 后 台 发 生 数 据 迁 移 请 求 , $http : 发 生 http 异 步 请 求 ； 第 二 个 参 数 ： 请 求 url ; 第 三 个 参 数 ： 请 求 操 作 类 型 ； 第 四 个 参 数 ： 请 求 携 带 的 数 据 ； 第 五 个 参 数 ：
一 个 回 调 函 数 ， 请 求 响 应 后 的 回 调 函 数 。
* /
if ( Kubernetes . alreadyExitInFolder ( $scope . tableConfig . selectedItems , $scope . selectNode ) ) {
migrationClick . close ( ) ;
Configs . customAlert ( "提示" , "操作失败:" + "数据已在当前目录！" , '' , null , 0 , "error" ) ;
@ -250,10 +261,16 @@ module Developer {
} ,
open : ( selected ) = > {
var migrationClick = $scope . migrationClick ;
ConfigsModel . updateVolumeData ( ) ;
if ( ConfigsModel . cluster != null )
$scope . volumes = ConfigsModel . cluster ;
/ *
判 断 数 据 是 否 已 挂 载 使 用 和 正 在 迁 移 。
* /
var message = Kubernetes . checkForMigration ( $scope . replicasModel . replicationControllers , $scope . model . transferTasks , $scope . tableConfig . selectedItems ) ;
* /
var message = Kubernetes . checkForMigration ( $scope . replicasModel . replicationControllers , $scope . model . transferTasks , $scope . tableConfig . selectedItems , "manager" ) ;
if ( message == "" ) {
if ( $scope . volumes && $scope . volumes instanceof Array && $scope . volumes . length > 0 )
@ -269,10 +286,18 @@ module Developer {
}
} ;
$scope . createOracleService = ( items ) = > {
var exitedItems = Kubernetes . checkForCreateOracle ( $scope . model . transferTasks , items ) ;
$scope . createOracleService = ( items ) = > {
var exitedItems = Kubernetes . checkForCreateOracle ( $scope . model . transferTasks , items ) ;
for ( var i = 0 ; i < items . length ; ++ i ) {
// code...
if ( items [ i ] . dataBaseType != 'ORACLE' ) {
Configs . customAlert ( "提示" , "操作失败: 非ORACLE数据不需要挂载启动！ , '' , null , 0 , "error" ) ;
return ;
}
}
if ( exitedItems . length == 0 ) {
angular . forEach ( items , ( item ) = > {
angular . forEach ( items , ( item ) = > {
console . log ( item ) ;
var isExited = Kubernetes . checkForExit ( $scope . replicasModel . replicationControllers , item ) ;
if ( ! isExited ) {
Kubernetes . createRC ( {
@ -287,7 +312,8 @@ module Developer {
districtName : item.districtName ,
systemName : item.systemName ,
id : item.id + "" ,
year : item.year
year : item.year ,
checkoutFlag : item.checkoutFlag
} ,
path : item.dataPath + "app/" ,
isTarget : "false" ,
@ -310,9 +336,9 @@ module Developer {
}
}
function init ( $scope , $location , $routeParams ) {
//$scope.model.updateModel();
function init ( $scope , $location , $routeParams ) {
$scope . keyQuery = "" ;
$scope . model . initParamOptions ( ) ;
$scope . model . updateParamOption ( "keyQuery" , $scope . keyQuery ) ;
if ( ConfigsModel . cluster != null )
$scope . volumes = ConfigsModel . cluster ;
@ -339,14 +365,27 @@ module Developer {
title : "查看批次B的数据" ,
class : "" ,
alias : "B"
} ]
} ] ;
if ( ! ( $location . path ( ) . indexOf ( "hot" ) > - 1 ) ) {
$scope . tableConfig . columnDefs . splice ( 7 , 0 , {
field : "existHotData" ,
displayName : '是否已在热区' ,
cellTemplate : $templateCache.get ( "isExistHot.html" )
} ) ;
}
}
function getDataType ( $location ) {
var path = $location . path ( ) ;
var dataType ;
var volumeType ;
var subPath = path . split ( "/" ) ;
var subPath = path . split ( "/" ) ;
if ( path . indexOf ( "hot" ) > - 1 )
$scope . isShow = true ;
else
$scope . isShow = false ;
switch ( subPath [ subPath . length - 1 ] ) {
case "financial" :
dataType = "财政" ;
@ -364,7 +403,7 @@ module Developer {
break ;
default :
volumeType = 1
}
}
return {
"dataType" : dataType ,
"volumeType" : volumeType
