/// <reference path="../../includes.ts"/>
/// <reference path="./kubernetesHelpers.ts"/>
module Kubernetes {
export var hostPorts =[];
/**
* Sorts the the ip field
*
* @param ip the ip such as '10.1.2.13'
* @returns {any}
*/
export function sortByPodIp(ip) : any {
// i guess there is maybe nicer ways of sort this without parsing and slicing
var regex = /(\d{1,3})\.(\d{1,3})\.(\d{1,3})\.(\d{1,3})/;
var groups = regex.exec(ip);
if (angular.isDefined(groups)) {
var g1 = ("00" + groups[1]).slice(-3);
var g2 = ("00" + groups[2]).slice(-3);
var g3 = ("00" + groups[3]).slice(-3);
var g4 = ("00" + groups[4]).slice(-3);
var answer = g1 + g2 + g3 + g4;
return answer;
} else {
return 0;
}
}
export function ramdomPort(): number{
var hostPort=Math.floor(30000+Math.random()*(65535-30000));
while(hostPorts.indexOf(hostPort) === 0){
hostPort = Math.floor(30000+Math.random()*(65535-30000));
}
hostPorts.push(hostPort);
return hostPort
}
export function getRandomString(len : number) : string{
len = len || 32;
var $chars = 'abcdefhijkmnprstwxyz'; // 默认去掉了容易混淆的字符oOLl,9gq,Vv,Uu,I1
var maxPos = $chars.length;
var pwd = '';
for (var i = 0; i < len; i++) {
pwd += $chars.charAt(Math.floor(Math.random() * maxPos));
}
return pwd;
}
export class resourceRCTemplate{
public image="oracle:utf8";
public names = ["oradata"];
public createRC(Obj){
var labels = {
"style": "oracle",
"status": "0",
"isExtract": Obj.isExtract+"" || "0",
"isTarget": Obj.isTarget
};
for(var item in Obj.labels)
labels[item] = Obj.labels[item];
return {
"apiVersion" : Kubernetes.defaultApiVersion,
"kind" : "ReplicationController",
"metadata" : {
"name" : Obj.name,
"labels" : labels,
"annotations": Obj.annotations
},
"spec" : {
replicas : Obj.replicas || 1,
"template" : this.createTemplate(Obj)
}
}
}
public createVolumeMounts(){
var volumeMounts = [];
for(var item in this.names){
if(this.names[item] === 'flash-recovery-area')
volumeMounts.push({
"name" : this.names[item],
"mountPath" : "/opt/oracle/app/flash_recovery_area"
});
else
volumeMounts.push({
"name" : this.names[item],
"mountPath" : "/opt/oracle/app/" + this.names[item]
});
}
return volumeMounts;
}
public createVolumes(rootPath :string){
var volumes = [];
for(var item in this.names){
if(this.names[item] === 'flash-recovery-area')
volumes.push({
"name" : this.names[item],
"hostPath" :{
"path" : rootPath + "flash_recovery_area"
}
});
else
volumes.push({
"name" : this.names[item],
"hostPath" :{
"path" : rootPath + this.names[item]
}
});
}
return volumes;
}
public createContainers(Obj){
var containers = [];
containers.push(
{
"name" : "oracle",
"image": this.image,
"imagePullPolicy": "IfNotPresent",
"command":["/assets/entrypoint.sh"],
"ports": [
{
"containerPort": 1521,
"hostPort": Obj.port || ramdomPort()
}],
"volumeMounts" : this.createVolumeMounts()
});
return containers
}
public createTemplate(Obj){
return {
"metadata":
{
//"name": Obj.name,
"labels": Obj.labels
},
"spec" : {
"terminationGracePeriodSeconds" : 0,
"containers" : this.createContainers(Obj),
"volumes" : this.createVolumes(Obj.path)
}
}
}
}
export function labelToChinese(labels){
var answer = {};
angular.forEach(labels,(value, key) => {
answer[key] = labelChangeToChines(value, key);
});
return answer
}
export function findSameNameReplicationControllers(replicationControllers, name){
var names = [];
replicationControllers.forEach((rc) => {
var rcName = getName(rc);
if(rcName.indexof(name) !== -1)
names.push(rcName);
});
if(names.length === 0){
return name + "_1";
}else{
var max = 0;
names.forEach((value) => {
var answer = value.split("_");
var key = parseInt(answer[1]);
if(max < key)
max = key;
});
return name + (max+1);
}
}
export function isFilterRC(rc){
var answer = false;
angular.forEach(Core.pathGet(rc, ["metadata", "labels"]),(value, key) => {
if(key === 'isTarget' && value === 'true'){
answer = true;
}
});
return answer;
}
export function isInclude(rcs, rc){
for(var i in rcs){
if(getName(rcs[i]) === getName(rc))
return true;
}
return false;
}
export function labelChangeToChines(value:string, key:string){
var trueValue = '';
switch(key){
case 'type':
if(value === '01')
trueValue = '财政';
else if(value === '02')
trueValue = '社保';
else
trueValue = value;
break;
case 'batch':
if(value === 'A')
trueValue = '批次A';
else if(value === 'B')
trueValue = '批次B';
else
trueValue = value;
break;
case 'region':
trueValue = Kubernetes.getCountyByCode(value);
break;
case 'system':
trueValue = Kubernetes.getSystemNameById(value);
break;
case 'version':
var reg= new RegExp('^[0-9]$').exec(value);
if(reg)
trueValue = '版本' + reg[0];
else
trueValue = value;
break;
case 'isTarget':
if(value === 'true')
trueValue = '汇总数据库';
else
trueValue = value;
break;
default:
trueValue = value;
}
return trueValue;
}
export function checkForExit(replicationControllers:Array<KubePod>, selectItem){
for(var index in replicationControllers) {
var replicas = replicationControllers[index];
if(getName(replicas)==selectItem._key && getAnnotationValueBykey(replicas,"year") == selectItem["year"])
return true;
}
return false;
}
function getAnnotationValueBykey(replicationController, key:string){
var annotations = getAnnotations(replicationController);
if(annotations && annotations != undefined){
return annotations[key];
}
}
/*
启动oracle时检查是否正在迁移
*/
export function checkForCreateOracle(transferTasks:Array<any>, selectItems:Array<any>){
var result = [];
angular.forEach(selectItems, (item) => {
if(checkForExitTask(transferTasks, item))
result.push(item);
});
return result;
}
function checkForExitTask(transferTasks:Array<any>, selectItem){
for(var index in transferTasks){
var task = transferTasks[index];
if(task["_key"] == selectItem["_key"] && selectItem["year"] == task.labels.dataYear ){
if(task.status == 2 || task.status == 3)
return false;
else
return true;
}
}
return false;
}
/**
**/
export function checkForExtract(replicationControllers: Array<any>){
var result = [];
angular.forEach(replicationControllers, (replicas) => {
var labels = getLabels(replicas);
if(labels["isExtract"] == "1")
result.push(replicas);
});
return result;
}
export function checkIsStartSuccess(replicationControllers: Array<any>){
var result = [];
angular.forEach(replicationControllers, (replicas) => {
var labels = getLabels(replicas);
if(labels["status"] != "2")
result.push(replicas);
});
return result;
};
/*
检查数据否已挂载使用或正在迁移。
*/
export function checkForMigration(replicationControllers:Array<KubePod>, transferTasks: Array<any>, selectItem:Array<any>, type:string){
var message = "";
for (var index in selectItem) {
var item = selectItem[index];
var id = null;
if(type == 'manager')
id = item.id;
if(type == 'verify')
id = item.dataId
/*
检查迁移文件是否正在迁移
*/
for(i in transferTasks){
/*if(transferTasks[i]["_key"] == item["_key"] && (transferTasks[i]["status"] == "1" || transferTasks[i]["status"] == "0") && item["year"] == transferTasks[i].labels.dataYear){
message = "数据正在迁移"
return message;
}*/
if(transferTasks[i].fkid == id && (transferTasks[i]["status"] == "1" || transferTasks[i]["status"] == "0")){
message = "数据正在迁移"
return message;
}
}
/**
数据是否在热区，如果在则需要判断数据是否已启动
*/
if(item["mark"] == 1)
continue;
/*
检查迁移文件是否已挂载使用
*/
for (var i in replicationControllers) {
var labels = getLabels(replicationControllers[i]);
if(getName(replicationControllers[i]) == item._key && getAnnotationValueBykey(replicationControllers[i],"year") == item["year"]){
message = "数据正在使用";
return message;
}
}
}
return message;
}
export function eliminateChechBoxClick(){
var element = $("#tableConfig > thead > tr input:checkbox");
if(element.is(':checked'))
element.click();
}
/*
是否已存在当前
*/
export function alreadyExitInFolder(selectedItems: Array<any>, selectNode){
var childNodes = selectNode.childNodes;
for(var i in selectedItems) {
var itemName = selectedItems[i].regionalismCode + "_" + selectedItems[i].systemCode;
for (var j in childNodes) {
if(childNodes[j].name == itemName){
var childrens = childNodes[j].childNodes;
for(var k in childrens)
if(childrens[k].name == selectedItems[i].dataVersion)
return true;
}
}
}
return false;
}
}