' + build.displayName + '
' + + 'duration: ' + y + ' seconds
'; + if (date) { + tooltip += 'started: ' + date + '
'; + } + if (result) { + tooltip += 'result: ' + result + '
'; + } + if (x) { + var data = buildsSucceeded; + var key = successBuildKey; + if (!successBuildKey && (!result || !result.startsWith("SUCC"))) { + data = buildsFailed; + key = failedBuildKey; + } + data.push({ + tooltip: tooltip, + color: color, + x: x, y: y }); + } + }); + $scope.data = []; + if (buildsSucceeded.length) { + $scope.data.push({ + key: successBuildKey, + values: buildsSucceeded + }); + } + if (buildsFailed.length) { + $scope.data.push({ + key: failedBuildKey, + values: buildsFailed + }); + } + $scope.api.updateWithData($scope.data); + $timeout(function () { + $scope.api.update(); + }, 50); + } + function updateData() { + var metricsPath = $scope.jobId ? UrlHelpers.join("job", $scope.jobId, "fabric8/metrics") : "fabric8/metrics"; + var url = Kubernetes.kubernetesProxyUrlForServiceCurrentNamespace(Developer.jenkinsServiceNameAndPort, metricsPath); + Developer.log.info(""); + if (url && (!$scope.jenkins || Kubernetes.keepPollingModel)) { + $http.get(url, Developer.jenkinsHttpConfig). + success(function (data, status, headers, config) { + if (data) { + if (Developer.hasObjectChanged(data, $scope.entityChangedCache)) { + Developer.log.info("entity has changed!"); + $scope.metrics = data; + updateChartData(); + } + } + $scope.model.fetched = true; + Core.$apply($scope); + }). + error(function (data, status, headers, config) { + Developer.log.warn("Failed to load " + url + " " + data + " " + status); + }); + } + } + }]); +})(Developer || (Developer = {})); + +///
+ var codeValueTemp = itemvalue[0].split("");
+ var codeValue = codeValueTemp[codeValueTemp.length - 1].split("")[0];
+ //
+ var sys_nameValueTemp = itemvalue[0].split("");
+ var sys_nameValue = sys_nameValueTemp[sys_nameValueTemp.length - 1].split(" ")[0];
+ //
+ var character_setValueTemp = itemvalue[0].split("");
+ var character_setValue = character_setValueTemp[character_setValueTemp.length - 1].split(" ")[0];
+ //
+ var sys_name_codeValueTemp = itemvalue[0].split("");
+ var sys_name_codeValue = sys_name_codeValueTemp[sys_name_codeValueTemp.length - 1].split(" ")[0];
+ //
+ var contactValueTemp = itemvalue[0].split("");
+ var contactValue = contactValueTemp[contactValueTemp.length - 1].split(" ")[0];
+ //
+ var phoneValueTemp = itemvalue[0].split("");
+ var phoneValue = phoneValueTemp[phoneValueTemp.length - 1].split(" ")[0];
+ //
+ var dateValueTemp = itemvalue[0].split("");
+ var dateValue = dateValueTemp[dateValueTemp.length - 1].split(" ")[0];
+ //id :
+ var itemId = codeValue + "_" + sys_name_codeValue;
+ // http get version
+ var rid = itemId; //.replace(/\"/g, "");
+ // TODO typeValue 通过前端页面获取或者？？，财政01或社保02
+ var typeValue = "01";
+ // TODO batchValue 通过前端页面获取或者？？，批次A ：大写的A，批次B ：大写的B，
+ var batchValue = "A";
+ var itemname = cityValue + countyValue + sys_nameValue;
+ var versionid = 1;
+ var xhr = new XMLHttpRequest();
+ xhr.onreadystatechange = function () {
+ if (xhr.readyState == 4) {
+ if (xhr.status == 200) {
+ versionid = xhr.responseText;
+ }
+ }
+ };
+ xhr.open("get", "/getversion?id=" + rid, false);
+ xhr.send(null);
+ var jsobj = JSON.parse(versionid);
+ var xmlversion = jsobj.id;
+ var properValue = "{\"id\":\"" + itemId + "\", \"name\":\"" + itemname + "\", \"city\":\"" +
+ cityValue + "\", \"county\":\"" + countyValue + "\", \"system\":\"" +
+ sys_nameValue + "\", \"type\":\"" + typeValue + "\",\"batch\":\"" +
+ batchValue + "\",\"version\":\"" + xmlversion + "\", \"province\":\"" +
+ provinceValue + "\", \"code\":\"" +
+ codeValue + "\", \"character_set\":\"" +
+ character_setValue + "\", \"sys_name_code\":\"" +
+ sys_name_codeValue + "\", \"contact\":\"" +
+ contactValue + "\", \"phone\":\"" +
+ phoneValue + "\", \"date\":\"" +
+ dateValue + "\"}";
+ resultString = resultString + properValue;
+ if (k < itemsize - 1) {
+ resultString = resultString + ", ";
+ }
+ }
+ resultString = resultString + "]}";
+ }
+ $scope.$apply(function () {
+ $scope.model.localdata = JSON.parse(resultString.toString());
+ });
+ };
+ reader.readAsText(files[i], "utf-8");
+ }
+ else {
+ FilterList.length += 1;
+ var file_id = files[i].name.replace(/\.\w*$/, '');
+ // var file_id=file[i].webkitRelativePath.replace(/^[a-z]*\/$/,'');
+ // file_id = file_id.replace(/\/\w+$/,'');
+ FilterList[j++] = files[i];
+ }
+ }
+ }
+ $scope.model.uploadprocess = {};
+ };
+ $scope.upLoadFiles = function () {
+ if ($scope.model.uploadedStatus == "once") {
+ return;
+ }
+ $scope.model.uploadedStatus = "once";
+ $scope.model.createFolderList(FilterList, rootPath);
+ if ($scope.model.folderList.length > 0 && $scope.model.selectednodes.length > 0) {
+ var isNotExited = [];
+ var isExited = [];
+ for (var node in $scope.model.selectednodes) {
+ if (!$scope.model.folderList.hasOwnProperty($scope.model.selectednodes[node].id)) {
+ isNotExited.push($scope.model.selectednodes[node]);
+ }
+ else {
+ if ($scope.model.uploadprocess[$scope.model.selectednodes[node].id] === 'undefined' || $scope.model.uploadprocess[$scope.model.selectednodes[node].id] === 0)
+ isExited.push($scope.model.selectednodes[node]);
+ }
+ }
+ if (isNotExited.length > 0) {
+ var str = "以下数据文件不存在:\n\r文件名:\n";
+ for (var item in isNotExited)
+ str += isNotExited[item].id + "\n";
+ alert(str);
+ }
+ if (isExited.length <= 0) {
+ alert("数据文件中没有可用上传的文件!");
+ }
+ else {
+ var isuploaad = 1, i = 0;
+ var timerForUpload = $interval(function () {
+ if (i >= isExited.length) {
+ // clearInterval(timerForUpload);
+ $interval.cancel(timerForUpload);
+ }
+ if (isuploaad == 1) {
+ var r = new Resumable({
+ target: '/uploadfiles',
+ chunkSize: 50 * 1024 * 1024,
+ simultaneousUploads: 400,
+ testChunks: true,
+ throttleProgressCallbacks: 1
+ });
+ var xhr = new XMLHttpRequest();
+ xhr.open("GET", "/getclientip", true);
+ xhr.onreadystatechange = function () {
+ if (xhr.readyState == 4) {
+ if (xhr.status == 200) {
+ r.setip(xhr.responseText);
+ }
+ }
+ };
+ xhr.send(null);
+ r.on('fileAdded', function (file) {
+ r.upload();
+ update();
+ });
+ $scope.model.resumablejs.push({
+ dirname: isExited[i].id,
+ resumable: r
+ });
+ r.setRootPath(isExited[i].type + "/" + isExited[i].batch + "/" + isExited[i].id + "/" + isExited[i].version + "/");
+ r.myLoadFiles($scope.model.folderList[isExited[i].id]);
+ r.upload();
+ r.on('fileProgress', function (file) {
+ var file_id = file.relativePath.replace(/^[a-z]*\/$/, '');
+ var filestr = "";
+ var reg = /\/[0-9]*_*[0-9]*\//g;
+ var resultstr;
+ while ((resultstr = reg.exec(file_id)) != null) {
+ filestr = resultstr[0];
+ }
+ file_id = filestr.replace(/\/*/g, '');
+ r.setFileId(file_id);
+ // $scope.$apply(function(){
+ $scope.model.uploadprocess[file_id] = Math.floor(r.progress() * 98);
+ // });
+ });
+ r.on('complete', function () {
+ var timerForchmod = setInterval(function () {
+ var pathjson = "\"path\":\"" + r.getrootPath() + "\"";
+ var datamessage = { "path": r.getrootPath(), "filenum": $scope.model.folderList[isExited[i - 1].id].length };
+ $scope.model.uploadprocess[r.getFileId()] = Math.round(r.progress() * 99);
+ $http({
+ url: '/setchmod2dir',
+ method: 'GET',
+ params: datamessage
+ }).success(function (data, header, config, status) {
+ if (data) {
+ //console.log(data);
+ var clientdata = data;
+ if (clientdata == "chmod") {
+ sendDateMessage(isExited[i - 1]);
+ r.setisnowcheck("1");
+ r.mkRetfileUploadSucceed();
+ clearInterval(timerForchmod);
+ }
+ }
+ }).error(function (data, header, config, status) {
+ console.log("-----sendDateMessage-------------" + status);
+ });
+ }, 5000);
+ });
+ i++;
+ isuploaad = 0;
+ r.on('fileuploadendsucceed', function () {
+ $scope.model.uploadprocess[r.getFileId()] = Math.floor(r.progress() * 100);
+ $timeout(function () {
+ $http({
+ url: '/xmlformserver',
+ method: 'Post'
+ }).success(function (data, header, config, status) {
+ if (data) {
+ $scope.model.serverdata = data;
+ }
+ }).error(function (data, header, config, status) {
+ console.log("error");
+ });
+ }, 2000);
+ isuploaad = 1;
+ });
+ }
+ }, 2000);
+ }
+ }
+ else {
+ alert("您没有选择需要上传的数据文件，或你选择的文件中不存在指定格式的数据文件!");
+ }
+ };
+ function sendDateMessage(datamessage) {
+ $http({
+ url: '/sendDateMessage',
+ method: 'GET',
+ params: datamessage
+ }).success(function (data, header, config, status) {
+ if (data)
+ var clientdata = data;
+ }).error(function (data, header, config, status) {
+ });
+ }
+ $scope.downLoadFiles = function () {
+ //Kubernetes.connectOracle($http, $timeout, "192.168.0.103:64182", "320614-54-1", 500);
+ };
+ $scope.isSelected = function (node) {
+ var index = $scope.model.findItemIndex(node);
+ if (index !== -1) {
+ $scope.model.selecteditems.splice(index, 1);
+ }
+ else {
+ $scope.model.selecteditems.push(node);
+ }
+ };
+ $scope.showSelectedLocal = function (node, selected) {
+ var index = $scope.model.findNodes(node);
+ if (index !== "-1") {
+ if ($scope.model.uploadprocess[node.id] === 0)
+ $scope.model.selectednodes.splice(index, 1);
+ }
+ else {
+ $scope.model.uploadprocess[node.id] = 0;
+ $scope.model.selectednodes.push(node);
+ }
+ };
+ $scope.startOracle = function () {
+ if ($scope.model.selecteditems.length > 0) {
+ for (var id in $scope.model.selecteditems) {
+ var Obj = createRCObj($scope.model.selecteditems[id]);
+ if (!checkIsRunning(KubernetesModel.replicationControllers, Obj)) {
+ Kubernetes.createRC(Obj, function (rc) {
+ console.log(rc);
+ Kubernetes.connectOracle($http, $timeout, "/connectToOracle", "create", rc.metadata.name, 0);
+ });
+ }
+ }
+ }
+ };
+ function checkIsRunning(replicationControllers, item) {
+ for (var rc in replicationControllers) {
+ if (item.name === replicationControllers[rc].metadata.name)
+ return true;
+ }
+ return false;
+ }
+ function createRCObj(item) {
+ var array = item.id.split("_");
+ if (array[0] === "10") {
+ //console.log(item);
+ return {
+ "name": item.fakename,
+ "labels": {
+ "name": item.fakename
+ },
+ "path": item.path + "app/",
+ "isTarget": "true"
+ };
+ }
+ else {
+ return {
+ "name": array[2] + "-" + array[3] + "-" + array[4],
+ "labels": {
+ "type": array[0],
+ "batch": array[1],
+ "region": array[2],
+ "system": array[3],
+ "version": array[4]
+ },
+ "path": item.path + "app/",
+ "isTarget": "false"
+ };
+ }
+ }
+ function setchmod2dir(datamessage) {
+ $http({
+ url: '/setchmod2dir',
+ method: 'GET',
+ params: datamessage
+ }).success(function (data, header, config, status) {
+ if (data)
+ var clientdata = data;
+ }).error(function (data, header, config, status) {
+ console.log("-----sendDateMessage-------------" + status);
+ });
+ }
+ function update() {
+ for (var i = 0; i < $scope.model.resumablejs.length; i++) {
+ var dirId = $scope.model.resumablejs[i].dirname;
+ var r = $scope.model.resumablejs[i].resumable;
+ r.on('fileProgress', function (file) {
+ if (r.getisnowcheck().indexOf("0") == -1) {
+ $scope.$apply(function () {
+ $scope.model.uploadprocess[dirId] = Math.floor(r.progress() * 100);
+ });
+ }
+ else {
+ $scope.$apply(function () {
+ $scope.model.uploadprocess[dirId] = Math.floor(r.progress() * 98);
+ });
+ }
+ });
+ }
+ }
+ }]);
+})(Developer || (Developer = {}));
+
/// {
- return this.filterReplicationcontrollers;
- }
-
- public set filterReplicationcontrollers(filterReplicationcontrollers:Array) {
- this.filterReplicationcontrollers = filterReplicationcontrollers;
- }*/
- get: function () {
- return this.replicationcontrollers;
- },
- set: function (replicationControllers) {
- this.replicationcontrollers = replicationControllers;
- },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(KubernetesModelService.prototype, "namespaces", {
- get: function () {
- return this.kubernetes.namespaces;
- },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(KubernetesModelService.prototype, "showRunButton", {
- get: function () {
- if (Kubernetes.isOpenShift) {
- return true;
- }
- return _.any(this.services, function (service) {
- var name = Kubernetes.getName(service);
- if (name === "templates") {
- var podCounters = service.$podCounters;
- return podCounters && (podCounters.valid || podCounters.ready);
- }
- else {
- return false;
- }
- });
- },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(KubernetesModelService.prototype, "serviceApps", {
- get: function () {
- return _.filter(this.services, function (s) {
- return s.$host && s.$serviceUrl && s.$podCount;
- });
- },
- enumerable: true,
- configurable: true
- });
- KubernetesModelService.prototype.$keepPolling = function () {
- return Kubernetes.keepPollingModel;
- };
- KubernetesModelService.prototype.orRedraw = function (flag) {
- this.redraw = this.redraw || flag;
- };
- KubernetesModelService.prototype.getService = function (namespace, id) {
- return this.servicesByKey[createKey(namespace, id, 'service')];
- };
- KubernetesModelService.prototype.getReplicationController = function (namespace, id) {
- return this.replicationControllersByKey[createKey(namespace, id, 'replicationController')];
- };
- KubernetesModelService.prototype.getPod = function (namespace, id) {
- return this.podsByKey[createKey(namespace, id, 'pod')];
- };
- KubernetesModelService.prototype.podsForNamespace = function (namespace) {
- if (namespace === void 0) { namespace = this.currentNamespace(); }
- return _.filter(this.pods, { namespace: namespace });
- };
- KubernetesModelService.prototype.getBuildConfig = function (name) {
- return _.find(this.buildconfigs, { $name: name });
- };
- KubernetesModelService.prototype.getProject = function (name, ns) {
- if (ns === void 0) { ns = this.currentNamespace(); }
- var buildConfig = this.project;
- if (!buildConfig) {
- var text = localStorage[Kubernetes.FABRIC8_PROJECT_JSON];
- if (text) {
- try {
- buildConfig = angular.fromJson(text);
- }
- catch (e) {
- Kubernetes.log.warn("Could not parse json for " + Kubernetes.FABRIC8_PROJECT_JSON + ". Was: " + text + ". " + e, e);
- }
- }
- }
- if (buildConfig && ns != Kubernetes.getNamespace(buildConfig) && name != buildConfig.$name) {
- buildConfig = this.getBuildConfig(name);
- }
- return buildConfig;
- };
- KubernetesModelService.prototype.setProject = function (buildConfig) {
- this.project = buildConfig;
- if (buildConfig) {
- // lets store in local storage
- var localStorage = Kubernetes.inject("localStorage");
- if (localStorage) {
- localStorage[Kubernetes.FABRIC8_PROJECT_JSON] = angular.toJson(buildConfig);
- }
- }
- };
- /**
- * Returns the current selected namespace or the default namespace
- */
- KubernetesModelService.prototype.currentNamespace = function () {
- var answer = null;
- if (this.kubernetes) {
- answer = this.kubernetes.selectedNamespace;
- }
- return answer || Kubernetes.defaultNamespace;
- };
- KubernetesModelService.prototype.updateIconUrlAndAppInfo = function (entity, nameField) {
- var answer = null;
- var id = Kubernetes.getName(entity);
- entity.$iconUrl = Core.pathGet(entity, ['metadata', 'annotations', 'fabric8.' + id + '/iconUrl']);
- entity.$info = Core.pathGet(entity, ['metadata', 'annotations', 'fabric8.' + id + '/summary']);
- if (entity.$iconUrl) {
- return;
- }
- if (id && nameField) {
- (this.templates || []).forEach(function (template) {
- var metadata = template.metadata;
- if (metadata) {
- var annotations = metadata.annotations || {};
- var iconUrl = annotations["fabric8." + id + "/iconUrl"] || annotations["fabric8/iconUrl"];
- if (iconUrl) {
- (template.objects || []).forEach(function (item) {
- var entityName = Kubernetes.getName(item);
- if (id === entityName) {
- entity.$iconUrl = iconUrl;
- }
- });
- }
- }
- });
- (this.appInfos || []).forEach(function (appInfo) {
- var iconPath = appInfo.iconPath;
- if (iconPath && !answer && iconPath !== "null") {
- var iconUrl = Kubernetes.gitPathToUrl(iconPath);
- var ids = Core.pathGet(appInfo, ["names", nameField]);
- angular.forEach(ids, function (appId) {
- if (appId === id) {
- entity.$iconUrl = iconUrl;
- entity.appPath = appInfo.appPath;
- entity.$info = appInfo;
- }
- });
- }
- });
- }
- if (!entity.$iconUrl) {
- entity.$iconUrl = Kubernetes.defaultIconUrl;
- }
- };
- KubernetesModelService.prototype.maybeInit = function () {
- var _this = this;
- this.fetched = true;
- this.servicesByKey = {};
- this.podsByKey = {};
- this.replicationControllersByKey = {};
- this.pods.forEach(function (pod) {
- if (!pod.kind)
- pod.kind = "Pod";
- _this.podsByKey[pod._key] = pod;
- var host = Kubernetes.getHost(pod);
- pod.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(pod));
- if (host) {
- pod.$labelsText += Kubernetes.labelFilterTextSeparator + "host=" + host;
- }
- pod.$iconUrl = Kubernetes.defaultIconUrl;
- _this.discoverPodConnections(pod);
- pod.$containerPorts = [];
- var podStatus = pod.status || {};
- var startTime = podStatus.startTime;
- pod.$startTime = null;
- if (startTime) {
- pod.$startTime = new Date(startTime);
- }
- var createdTime = Kubernetes.getCreationTimestamp(pod);
- pod.$createdTime = null;
- pod.$age = null;
- if (createdTime) {
- pod.$createdTime = new Date(createdTime);
- pod.$age = humandate.relativeTime(pod.$createdTime);
- }
- var ready = Kubernetes.isReady(pod);
- pod.$ready = ready;
- pod.$statusCss = Kubernetes.statusTextToCssClass(podStatus.phase, ready);
- var maxRestartCount = 0;
- angular.forEach(Core.pathGet(pod, ["status", "containerStatuses"]), function (status) {
- var restartCount = status.restartCount;
- if (restartCount) {
- if (restartCount > maxRestartCount) {
- maxRestartCount = restartCount;
- }
- }
- });
- if (maxRestartCount) {
- pod.$restartCount = maxRestartCount;
- }
- var imageNames = "";
- angular.forEach(Core.pathGet(pod, ["spec", "containers"]), function (container) {
- var image = container.image;
- if (image) {
- if (!imageNames) {
- imageNames = image;
- }
- else {
- imageNames = imageNames + " " + image;
- }
- var idx = image.lastIndexOf(":");
- if (idx > 0) {
- image = image.substring(0, idx);
- }
- var paths = image.split("/", 3);
- if (paths.length) {
- var answer = null;
- if (paths.length == 3) {
- answer = paths[1] + "/" + paths[2];
- }
- else if (paths.length == 2) {
- answer = paths[0] + "/" + paths[1];
- }
- else {
- answer = paths[0] + "/" + paths[1];
- }
- container.$imageLink = UrlHelpers.join("https://registry.hub.docker.com/u/", answer);
- }
- }
- angular.forEach(container.ports, function (port) {
- var containerPort = port.containerPort;
- if (containerPort) {
- pod.$containerPorts.push(containerPort);
- }
- });
- });
- pod.$imageNames = imageNames;
- var podStatus = podStatus;
- var podSpec = (pod.spec || {});
- pod.$podIP = podStatus.podIP;
- pod.$host = podSpec.host || podSpec.nodeName || podStatus.hostIP;
- });
- this.services.forEach(function (service) {
- if (!service.kind)
- service.kind = "Service";
- _this.servicesByKey[service._key] = service;
- var selector = Kubernetes.getSelector(service);
- service.$pods = [];
- if (!service.$podCounters) {
- service.$podCounters = {};
- }
- var podLinkUrl = UrlHelpers.join("/kubernetes/namespace", service.metadata.namespace, "pods");
- _.assign(service.$podCounters, selector ? Kubernetes.createPodCounters(selector, _this.pods, service.$pods, Kubernetes.labelsToString(selector, ","), podLinkUrl) : {});
- service.$podCount = service.$pods.length;
- var selectedPods = service.$pods;
- service.connectTo = selectedPods.map(function (pod) {
- return pod._key;
- }).join(',');
- service.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(service));
- _this.updateIconUrlAndAppInfo(service, "serviceNames");
- var spec = service.spec || {};
- service.$portalIP = spec.portalIP;
- service.$selectorText = Kubernetes.labelsToString(spec.selector);
- var ports = _.map(spec.ports || [], "port");
- service.$ports = ports;
- service.$portsText = ports.join(", ");
- var iconUrl = service.$iconUrl;
- if (iconUrl && selectedPods) {
- selectedPods.forEach(function (pod) {
- pod.$iconUrl = iconUrl;
- });
- }
- service.$serviceUrl = Kubernetes.serviceLinkUrl(service);
- });
- this.replicationControllers.forEach(function (replicationController) {
- if (!replicationController.kind)
- replicationController.kind = "ReplicationController";
- _this.replicationControllersByKey[replicationController._key] = replicationController;
- var selector = Kubernetes.getSelector(replicationController);
- replicationController.$pods = [];
- if (Kubernetes.isFilterRC(replicationController) && !Kubernetes.isInclude(_this.filterReplicationcontrollers, replicationController))
- _this.filterReplicationcontrollers.push(replicationController);
- replicationController.$podCounters = selector ? Kubernetes.createPodCounters(selector, _this.pods, replicationController.$pods) : null;
- replicationController.$podCount = replicationController.$pods.length;
- replicationController.$replicas = (replicationController.spec || {}).replicas;
- replicationController.$oracleName = Kubernetes.getOracleName(Kubernetes.getName(replicationController));
- //console.log(getName(replicationController));
- replicationController.$oracleStatus = Kubernetes.getOracleStatus(Kubernetes.getLabels(replicationController));
- var selectedPods = replicationController.$pods;
- replicationController.connectTo = selectedPods.map(function (pod) {
- return pod._key;
- }).join(',');
- replicationController.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(replicationController));
- replicationController.metadata.labels = Kubernetes.labelToChinese(Kubernetes.getLabels(replicationController));
- _this.updateIconUrlAndAppInfo(replicationController, "replicationControllerNames");
- var iconUrl = replicationController.$iconUrl;
- if (iconUrl && selectedPods) {
- selectedPods.forEach(function (pod) {
- pod.$iconUrl = iconUrl;
- });
- }
- });
- // services may not map to an icon but their pods may do via the RC
- // so lets default it...
- this.services.forEach(function (service) {
- var iconUrl = service.$iconUrl;
- var selectedPods = service.$pods;
- if (selectedPods) {
- if (!iconUrl || iconUrl === Kubernetes.defaultIconUrl) {
- iconUrl = null;
- selectedPods.forEach(function (pod) {
- if (!iconUrl) {
- iconUrl = pod.$iconUrl;
- if (iconUrl) {
- service.$iconUrl = iconUrl;
- }
- }
- });
- }
- }
- });
- this.updateApps();
- var podsByHost = {};
- this.pods.forEach(function (pod) {
- var host = Kubernetes.getHost(pod);
- var podsForHost = podsByHost[host];
- if (!podsForHost) {
- podsForHost = [];
- podsByHost[host] = podsForHost;
- }
- podsForHost.push(pod);
- });
- this.podsByHost = podsByHost;
- var tmpHosts = [];
- for (var hostKey in podsByHost) {
- var hostPods = [];
- var podCounters = Kubernetes.createPodCounters(function (pod) { return Kubernetes.getHost(pod) === hostKey; }, this.pods, hostPods, "host=" + hostKey);
- var hostIP = null;
- if (hostPods.length) {
- var pod = hostPods[0];
- var currentState = pod.status;
- if (currentState) {
- hostIP = currentState.hostIP;
- }
- }
- var hostDetails = {
- name: hostKey,
- id: hostKey,
- elementId: hostKey.replace(/\./g, '_'),
- hostIP: hostIP,
- pods: hostPods,
- kind: "Host",
- $podCounters: podCounters,
- $iconUrl: Kubernetes.hostIconUrl
- };
- tmpHosts.push(hostDetails);
- }
- this.hosts = tmpHosts;
- Kubernetes.enrichBuildConfigs(this.buildconfigs);
- Kubernetes.enrichEvents(this.events, this);
- };
- KubernetesModelService.prototype.updateApps = function () {
- var _this = this;
- try {
- // lets create the app views by trying to join controllers / services / pods that are related
- var appViews = [];
- this.replicationControllers.forEach(function (replicationController) {
- var name = Kubernetes.getName(replicationController);
- var $iconUrl = replicationController.$iconUrl;
- appViews.push({
- appPath: "/dummyPath/" + name,
- $name: name,
- $info: {
- $iconUrl: $iconUrl
- },
- $iconUrl: $iconUrl,
- replicationControllers: [replicationController],
- pods: replicationController.$pods || [],
- services: []
- });
- });
- var noMatches = [];
- this.services.forEach(function (service) {
- // now lets see if we can find an app with an RC of the same selector
- var matchesApp = null;
- appViews.forEach(function (appView) {
- appView.replicationControllers.forEach(function (replicationController) {
- var repSelector = Kubernetes.getSelector(replicationController);
- if (repSelector &&
- Kubernetes.selectorMatches(repSelector, Kubernetes.getSelector(service)) &&
- Kubernetes.getNamespace(service) === Kubernetes.getNamespace(replicationController)) {
- matchesApp = appView;
- }
- });
- });
- if (matchesApp) {
- matchesApp.services.push(service);
- }
- else {
- noMatches.push(service);
- }
- });
- Kubernetes.log.debug("no matches: ", noMatches);
- noMatches.forEach(function (service) {
- var appView = _.find(appViews, function (appView) {
- return _.any(appView.replicationControllers, function (rc) {
- return _.startsWith(Kubernetes.getName(rc), Kubernetes.getName(service));
- });
- });
- if (appView) {
- appView.services.push(service);
- }
- else {
- var $iconUrl = service.$iconUrl;
- appViews.push({
- appPath: "/dummyPath/" + name,
- $name: name,
- $info: {
- $iconUrl: $iconUrl
- },
- $iconUrl: $iconUrl,
- replicationControllers: [],
- pods: service.$pods || [],
- services: [service]
- });
- }
- });
- angular.forEach(this.routes, function (route) {
- var metadata = route.metadata || {};
- var spec = route.spec || {};
- var serviceName = Core.pathGet(spec, ["to", "name"]);
- var host = spec.host;
- var namespace = Kubernetes.getNamespace(route);
- if (serviceName && host) {
- var service = _this.getService(namespace, serviceName);
- if (service) {
- service.$host = host;
- // TODO we could use some annotations / metadata to deduce what URL we should use to open this
- // service in the console. For now just assume its http:
- if (host) {
- var hostUrl = host;
- if (hostUrl.indexOf("://") < 0) {
- hostUrl = "http://" + host;
- }
- service.$connectUrl = UrlHelpers.join(hostUrl, "/");
- }
- // TODO definitely need that annotation, temp hack for apiman link
- if (Kubernetes.getName(service) === 'apiman' && host) {
- service.$connectUrl = new URI().host(service.$host)
- .path('apimanui/index.html')
- .query({})
- .hash(URI.encode(angular.toJson({
- backTo: new URI().toString(),
- token: HawtioOAuth.getOAuthToken()
- }))).toString();
- }
- }
- else {
- Kubernetes.log.debug("Could not find service " + serviceName + " namespace " + namespace + " for route: " + metadata.name);
- }
- }
- });
- appViews = _.sortBy(populateKeys(appViews), function (appView) { return appView._key; });
- ArrayHelpers.sync(this.appViews, appViews, '$name');
- if (this.appInfos && this.appViews) {
- var folderMap = {};
- var folders = [];
- var appMap = {};
- angular.forEach(this.appInfos, function (appInfo) {
- if (!appInfo.$iconUrl && appInfo.iconPath && appInfo.iconPath !== "null") {
- appInfo.$iconUrl = Kubernetes.gitPathToUrl(appInfo.iconPath);
- }
- var appPath = appInfo.appPath;
- if (appPath) {
- appMap[appPath] = appInfo;
- var idx = appPath.lastIndexOf("/");
- var folderPath = "";
- if (idx >= 0) {
- folderPath = appPath.substring(0, idx);
- }
- folderPath = Core.trimLeading(folderPath, "/");
- var folder = folderMap[folderPath];
- if (!folder) {
- folder = {
- path: folderPath,
- expanded: true,
- apps: []
- };
- folders.push(folder);
- folderMap[folderPath] = folder;
- }
- folder.apps.push(appInfo);
- }
- });
- this.appFolders = _.sortBy(folders, "path");
- var apps = [];
- var defaultInfo = {
- $iconUrl: Kubernetes.defaultIconUrl
- };
- angular.forEach(this.appViews, function (appView) {
- try {
- var appPath = appView.appPath;
- /*
- TODO
- appView.$select = () => {
- Kubernetes.setJson($scope, appView.id, $scope.model.apps);
- };
- */
- var appInfo = angular.copy(defaultInfo);
- if (appPath) {
- appInfo = appMap[appPath] || appInfo;
- }
- if (!appView.$info) {
- appView.$info = defaultInfo;
- appView.$info = appInfo;
- }
- appView.id = appPath;
- if (!appView.$name) {
- appView.$name = appInfo.name || appView.$name;
- }
- if (!appView.$iconUrl) {
- appView.$iconUrl = appInfo.$iconUrl;
- }
- apps.push(appView);
- appView.$podCounters = Kubernetes.createAppViewPodCounters(appView);
- appView.$podCount = (appView.pods || []).length;
- appView.$replicationControllersText = (appView.replicationControllers || []).map(function (i) { return i["_key"]; }).join(" ");
- appView.$servicesText = (appView.services || []).map(function (i) { return i["_key"]; }).join(" ");
- appView.$serviceViews = Kubernetes.createAppViewServiceViews(appView);
- }
- catch (e) {
- Kubernetes.log.warn("Failed to update appViews: " + e);
- }
- });
- //this.apps = apps;
- this.apps = this.appViews;
- }
- }
- catch (e) {
- Kubernetes.log.warn("Caught error: " + e);
- }
- };
- KubernetesModelService.prototype.discoverPodConnections = function (entity) {
- var info = Core.pathGet(entity, ["status", "info"]);
- var hostPort = null;
- var currentState = entity.status || {};
- var desiredState = entity.spec || {};
- var podId = Kubernetes.getName(entity);
- var host = currentState["hostIP"];
- var podIP = currentState["podIP"];
- var hasDocker = false;
- var foundContainerPort = null;
- if (desiredState) {
- var containers = desiredState.containers;
- angular.forEach(containers, function (container) {
- if (!hostPort) {
- var ports = container.ports;
- angular.forEach(ports, function (port) {
- if (!hostPort) {
- var containerPort = port.containerPort;
- var portName = port.name;
- var containerHostPort = port.hostPort;
- if (containerPort === 8778 || "jolokia" === portName) {
- if (containerPort) {
- if (podIP) {
- foundContainerPort = containerPort;
- }
- if (containerHostPort) {
- hostPort = containerHostPort;
- }
- }
- }
- }
- });
- }
- });
- }
- if (foundContainerPort && podId && Kubernetes.isRunning(currentState)) {
- if (!Kubernetes.isOpenShift) {
- // TODO temp workaround for k8s on GKE https://github.com/kubernetes/kubernetes/issues/17172
- entity.$jolokiaUrl = UrlHelpers.join(Kubernetes.masterApiUrl(), "api", Kubernetes.defaultApiVersion, "proxy", "namespaces", entity.metadata.namespace, "pods",
- //"https:" + podId + ":" + foundContainerPort,
- podId + ":" + foundContainerPort, "jolokia/");
- }
- else {
- entity.$jolokiaUrl = UrlHelpers.join(Kubernetes.masterApiUrl(), "api", Kubernetes.defaultApiVersion, "namespaces", entity.metadata.namespace, "pods", "https:" + podId + ":" + foundContainerPort, "proxy/jolokia/");
- }
- }
- };
- return KubernetesModelService;
- }());
- Kubernetes.KubernetesModelService = KubernetesModelService;
- function getTemplateService(model) {
- var key = createKey('default', 'templates', 'service');
- var answer = model.servicesByKey[key];
- Kubernetes.log.debug("found template service: ", answer);
- return answer;
- }
- /**
- * Creates a model service which keeps track of all the pods, replication controllers and services along
- * with their associations and status
- */
- Kubernetes._module.factory('KubernetesModel', ['$rootScope', '$http', 'KubernetesApiURL', 'KubernetesState', 'WatcherService', '$location', '$resource', function ($rootScope, $http, AppLibraryURL, KubernetesState, watcher, $location, $resource) {
- var $scope = new KubernetesModelService();
- $scope.kubernetes = KubernetesState;
- // create all of our resource classes
- var typeNames = watcher.getTypes();
- _.forEach(typeNames, function (type) {
- var urlTemplate = Kubernetes.uriTemplateForKubernetesKind(type);
- $scope[type + 'Resource'] = Kubernetes.createResource(type, urlTemplate, $resource, $scope);
- });
- if (!Kubernetes.isOpenShift) {
- // register custom URL factories for templates/projects
- watcher.registerCustomUrlFunction(KubernetesAPI.WatchTypes.BUILD_CONFIGS, function (options) {
- var templateService = getTemplateService($scope);
- if (templateService) {
- return UrlHelpers.join(templateService.proxyUrl, '/oapi/v1/namespaces/default/buildconfigs/');
- }
- return null;
- });
- // register custom URL factories for templates/projects
- watcher.registerCustomUrlFunction(KubernetesAPI.WatchTypes.TEMPLATES, function (options) {
- var templateService = getTemplateService($scope);
- if (templateService) {
- return UrlHelpers.join(templateService.proxyUrl, '/oapi/v1/namespaces/default/templates/');
- }
- return null;
- });
- }
- // register for all updates on objects
- watcher.registerListener(function (objects) {
- var types = watcher.getTypes();
- _.forEach(types, function (type) {
- switch (type) {
- case Kubernetes.WatchTypes.SERVICES:
- var items = populateKeys(objects[type]);
- angular.forEach(items, function (item) {
- item.proxyUrl = Kubernetes.kubernetesProxyUrlForService(Kubernetes.kubernetesApiUrl(), item);
- });
- $scope[type] = items;
- break;
- case Kubernetes.WatchTypes.TEMPLATES:
- case Kubernetes.WatchTypes.ROUTES:
- case Kubernetes.WatchTypes.BUILDS:
- case Kubernetes.WatchTypes.BUILD_CONFIGS:
- case Kubernetes.WatchTypes.IMAGE_STREAMS:
- // don't put a break here :-)
- default:
- $scope[type] = populateKeys(objects[type]);
- }
- Kubernetes.log.debug("Type: ", type, " object: ", $scope[type]);
- });
- $scope.maybeInit();
- $rootScope.$broadcast('kubernetesModelUpdated', $scope);
- Core.$apply($rootScope);
- });
- // set the selected namespace if set in the location bar
- // otherwise use whatever previously selected namespace is
- // available
- var search = $location.search();
- if ('namespace' in search) {
- watcher.setNamespace(search['namespace']);
- }
- function selectPods(pods, namespace, labels) {
- return pods.filter(function (pod) {
- return Kubernetes.getNamespace(pod) === namespace && Kubernetes.selectorMatches(labels, Kubernetes.getLabels(pod));
- });
- }
- return $scope;
- }]);
-})(Kubernetes || (Kubernetes = {}));
-
/// ' + build.displayName + '
' +
- 'duration: ' + y + ' seconds
';
- if (date) {
- tooltip += 'started: ' + date + '
';
- }
- if (result) {
- tooltip += 'result: ' + result + '
';
- }
- if (x) {
- var data = buildsSucceeded;
- var key = successBuildKey;
- if (!successBuildKey && (!result || !result.startsWith("SUCC"))) {
- data = buildsFailed;
- key = failedBuildKey;
- }
- data.push({
- tooltip: tooltip,
- color: color,
- x: x, y: y });
- }
- });
- $scope.data = [];
- if (buildsSucceeded.length) {
- $scope.data.push({
- key: successBuildKey,
- values: buildsSucceeded
- });
- }
- if (buildsFailed.length) {
- $scope.data.push({
- key: failedBuildKey,
- values: buildsFailed
- });
- }
- $scope.api.updateWithData($scope.data);
- $timeout(function () {
- $scope.api.update();
- }, 50);
- }
- function updateData() {
- var metricsPath = $scope.jobId ? UrlHelpers.join("job", $scope.jobId, "fabric8/metrics") : "fabric8/metrics";
- var url = Kubernetes.kubernetesProxyUrlForServiceCurrentNamespace(Developer.jenkinsServiceNameAndPort, metricsPath);
- Developer.log.info("");
- if (url && (!$scope.jenkins || Kubernetes.keepPollingModel)) {
- $http.get(url, Developer.jenkinsHttpConfig).
- success(function (data, status, headers, config) {
- if (data) {
- if (Developer.hasObjectChanged(data, $scope.entityChangedCache)) {
- Developer.log.info("entity has changed!");
- $scope.metrics = data;
- updateChartData();
- }
- }
- $scope.model.fetched = true;
- Core.$apply($scope);
- }).
- error(function (data, status, headers, config) {
- Developer.log.warn("Failed to load " + url + " " + data + " " + status);
- });
- }
- }
- }]);
-})(Developer || (Developer = {}));
-
-/// ");
- var provinceValue = provinceValueTemp[provinceValueTemp.length - 1].split(" ")[0];
- //city
- var cityValueTemp = itemvalue[0].split("");
- var cityValue = cityValueTemp[cityValueTemp.length - 1].split(" ")[0];
- // county
- var countyValueTemp = itemvalue[0].split("");
- var countyValue = countyValueTemp[countyValueTemp.length - 1].split(" ")[0];
- //
- var codeValueTemp = itemvalue[0].split("");
- var codeValue = codeValueTemp[codeValueTemp.length - 1].split("")[0];
- //
- var sys_nameValueTemp = itemvalue[0].split("");
- var sys_nameValue = sys_nameValueTemp[sys_nameValueTemp.length - 1].split(" ")[0];
- //
- var character_setValueTemp = itemvalue[0].split("");
- var character_setValue = character_setValueTemp[character_setValueTemp.length - 1].split(" ")[0];
- //
- var sys_name_codeValueTemp = itemvalue[0].split("");
- var sys_name_codeValue = sys_name_codeValueTemp[sys_name_codeValueTemp.length - 1].split(" ")[0];
- //
- var contactValueTemp = itemvalue[0].split("");
- var contactValue = contactValueTemp[contactValueTemp.length - 1].split(" ")[0];
- //
- var phoneValueTemp = itemvalue[0].split("");
- var phoneValue = phoneValueTemp[phoneValueTemp.length - 1].split(" ")[0];
- //
- var dateValueTemp = itemvalue[0].split("");
- var dateValue = dateValueTemp[dateValueTemp.length - 1].split(" ")[0];
- //id :
- var itemId = codeValue + "_" + sys_name_codeValue;
- // http get version
- var rid = itemId; //.replace(/\"/g, "");
- // TODO typeValue 通过前端页面获取或者？？，财政01或社保02
- var typeValue = "01";
- // TODO batchValue 通过前端页面获取或者？？，批次A ：大写的A，批次B ：大写的B，
- var batchValue = "A";
- var itemname = cityValue + countyValue + sys_nameValue;
- var versionid = 1;
- var xhr = new XMLHttpRequest();
- xhr.onreadystatechange = function () {
- if (xhr.readyState == 4) {
- if (xhr.status == 200) {
- versionid = xhr.responseText;
- }
- }
- };
- xhr.open("get", "/getversion?id=" + rid, false);
- xhr.send(null);
- var jsobj = JSON.parse(versionid);
- var xmlversion = jsobj.id;
- var properValue = "{\"id\":\"" + itemId + "\", \"name\":\"" + itemname + "\", \"city\":\"" +
- cityValue + "\", \"county\":\"" + countyValue + "\", \"system\":\"" +
- sys_nameValue + "\", \"type\":\"" + typeValue + "\",\"batch\":\"" +
- batchValue + "\",\"version\":\"" + xmlversion + "\", \"province\":\"" +
- provinceValue + "\", \"code\":\"" +
- codeValue + "\", \"character_set\":\"" +
- character_setValue + "\", \"sys_name_code\":\"" +
- sys_name_codeValue + "\", \"contact\":\"" +
- contactValue + "\", \"phone\":\"" +
- phoneValue + "\", \"date\":\"" +
- dateValue + "\"}";
- resultString = resultString + properValue;
- if (k < itemsize - 1) {
- resultString = resultString + ", ";
- }
- }
- resultString = resultString + "]}";
- }
- $scope.$apply(function () {
- $scope.model.localdata = JSON.parse(resultString.toString());
- });
- };
- reader.readAsText(files[i], "utf-8");
- }
- else {
- FilterList.length += 1;
- var file_id = files[i].name.replace(/\.\w*$/, '');
- // var file_id=file[i].webkitRelativePath.replace(/^[a-z]*\/$/,'');
- // file_id = file_id.replace(/\/\w+$/,'');
- FilterList[j++] = files[i];
- }
- }
- }
- $scope.model.uploadprocess = {};
- };
- $scope.upLoadFiles = function () {
- if ($scope.model.uploadedStatus == "once") {
- return;
- }
- $scope.model.uploadedStatus = "once";
- $scope.model.createFolderList(FilterList, rootPath);
- if ($scope.model.folderList.length > 0 && $scope.model.selectednodes.length > 0) {
- var isNotExited = [];
- var isExited = [];
- for (var node in $scope.model.selectednodes) {
- if (!$scope.model.folderList.hasOwnProperty($scope.model.selectednodes[node].id)) {
- isNotExited.push($scope.model.selectednodes[node]);
- }
- else {
- if ($scope.model.uploadprocess[$scope.model.selectednodes[node].id] === 'undefined' || $scope.model.uploadprocess[$scope.model.selectednodes[node].id] === 0)
- isExited.push($scope.model.selectednodes[node]);
- }
- }
- if (isNotExited.length > 0) {
- var str = "以下数据文件不存在:\n\r文件名:\n";
- for (var item in isNotExited)
- str += isNotExited[item].id + "\n";
- alert(str);
- }
- if (isExited.length <= 0) {
- alert("数据文件中没有可用上传的文件!");
- }
- else {
- var isuploaad = 1, i = 0;
- var timerForUpload = $interval(function () {
- if (i >= isExited.length) {
- // clearInterval(timerForUpload);
- $interval.cancel(timerForUpload);
- }
- if (isuploaad == 1) {
- var r = new Resumable({
- target: '/uploadfiles',
- chunkSize: 50 * 1024 * 1024,
- simultaneousUploads: 400,
- testChunks: true,
- throttleProgressCallbacks: 1
- });
- var xhr = new XMLHttpRequest();
- xhr.open("GET", "/getclientip", true);
- xhr.onreadystatechange = function () {
- if (xhr.readyState == 4) {
- if (xhr.status == 200) {
- r.setip(xhr.responseText);
- }
- }
- };
- xhr.send(null);
- r.on('fileAdded', function (file) {
- r.upload();
- update();
- });
- $scope.model.resumablejs.push({
- dirname: isExited[i].id,
- resumable: r
- });
- r.setRootPath(isExited[i].type + "/" + isExited[i].batch + "/" + isExited[i].id + "/" + isExited[i].version + "/");
- r.myLoadFiles($scope.model.folderList[isExited[i].id]);
- r.upload();
- r.on('fileProgress', function (file) {
- var file_id = file.relativePath.replace(/^[a-z]*\/$/, '');
- var filestr = "";
- var reg = /\/[0-9]*_*[0-9]*\//g;
- var resultstr;
- while ((resultstr = reg.exec(file_id)) != null) {
- filestr = resultstr[0];
- }
- file_id = filestr.replace(/\/*/g, '');
- r.setFileId(file_id);
- // $scope.$apply(function(){
- $scope.model.uploadprocess[file_id] = Math.floor(r.progress() * 98);
- // });
- });
- r.on('complete', function () {
- var timerForchmod = setInterval(function () {
- var pathjson = "\"path\":\"" + r.getrootPath() + "\"";
- var datamessage = { "path": r.getrootPath(), "filenum": $scope.model.folderList[isExited[i - 1].id].length };
- $scope.model.uploadprocess[r.getFileId()] = Math.round(r.progress() * 99);
- $http({
- url: '/setchmod2dir',
- method: 'GET',
- params: datamessage
- }).success(function (data, header, config, status) {
- if (data) {
- //console.log(data);
- var clientdata = data;
- if (clientdata == "chmod") {
- sendDateMessage(isExited[i - 1]);
- r.setisnowcheck("1");
- r.mkRetfileUploadSucceed();
- clearInterval(timerForchmod);
- }
- }
- }).error(function (data, header, config, status) {
- console.log("-----sendDateMessage-------------" + status);
- });
- }, 5000);
- });
- i++;
- isuploaad = 0;
- r.on('fileuploadendsucceed', function () {
- $scope.model.uploadprocess[r.getFileId()] = Math.floor(r.progress() * 100);
- $timeout(function () {
- $http({
- url: '/xmlformserver',
- method: 'Post'
- }).success(function (data, header, config, status) {
- if (data) {
- $scope.model.serverdata = data;
- }
- }).error(function (data, header, config, status) {
- console.log("error");
- });
- }, 2000);
- isuploaad = 1;
- });
- }
- }, 2000);
- }
- }
- else {
- alert("您没有选择需要上传的数据文件，或你选择的文件中不存在指定格式的数据文件!");
- }
- };
- function sendDateMessage(datamessage) {
- $http({
- url: '/sendDateMessage',
- method: 'GET',
- params: datamessage
- }).success(function (data, header, config, status) {
- if (data)
- var clientdata = data;
- }).error(function (data, header, config, status) {
- });
- }
- $scope.downLoadFiles = function () {
- Kubernetes.connectOracle($http, $timeout, "192.168.0.103:64182", "320614-54-1", 500);
- };
- $scope.isSelected = function (node) {
- var index = $scope.model.findItemIndex(node);
- if (index !== -1) {
- $scope.model.selecteditems.splice(index, 1);
- }
- else {
- $scope.model.selecteditems.push(node);
- }
- };
- $scope.showSelectedLocal = function (node, selected) {
- var index = $scope.model.findNodes(node);
- if (index !== "-1") {
- if ($scope.model.uploadprocess[node.id] === 0)
- $scope.model.selectednodes.splice(index, 1);
- }
- else {
- $scope.model.uploadprocess[node.id] = 0;
- $scope.model.selectednodes.push(node);
- }
- };
- $scope.startOracle = function () {
- if ($scope.model.selecteditems.length > 0) {
- for (var id in $scope.model.selecteditems) {
- var Obj = createRCObj($scope.model.selecteditems[id]);
- if (!checkIsRunning(KubernetesModel.replicationControllers, Obj)) {
- Kubernetes.createRC(Obj, function (rc) {
- console.log(rc.metadata.name);
- Kubernetes.connectOracle($http, $timeout, "/connectToOracle", "", rc.metadata.name, 0);
- });
- }
- }
- }
- };
- function checkIsRunning(replicationControllers, item) {
- for (var rc in replicationControllers) {
- if (item.name === replicationControllers[rc].metadata.name)
- return true;
- }
- return false;
- }
- function createRCObj(item) {
- var array = item.id.split("_");
- if (array[0] === "10") {
- //console.log(item);
- return {
- "name": item.fakename,
- "labels": {
- "name": item.fakename
- },
- "path": item.path + "app/",
- "isTarget": "true"
- };
- }
- else {
- return {
- "name": array[2] + "-" + array[3] + "-" + array[4],
- "labels": {
- "type": array[0],
- "batch": array[1],
- "region": array[2],
- "system": array[3],
- "version": array[4]
- },
- "path": item.path + "app/",
- "isTarget": "false"
- };
- }
- }
- function setchmod2dir(datamessage) {
- $http({
- url: '/setchmod2dir',
- method: 'GET',
- params: datamessage
- }).success(function (data, header, config, status) {
- if (data)
- var clientdata = data;
- }).error(function (data, header, config, status) {
- console.log("-----sendDateMessage-------------" + status);
- });
- }
- function update() {
- for (var i = 0; i < $scope.model.resumablejs.length; i++) {
- var dirId = $scope.model.resumablejs[i].dirname;
- var r = $scope.model.resumablejs[i].resumable;
- r.on('fileProgress', function (file) {
- if (r.getisnowcheck().indexOf("0") == -1) {
- $scope.$apply(function () {
- $scope.model.uploadprocess[dirId] = Math.floor(r.progress() * 100);
- });
- }
- else {
- $scope.$apply(function () {
- $scope.model.uploadprocess[dirId] = Math.floor(r.progress() * 98);
- });
- }
- });
- }
- }
- }]);
-})(Developer || (Developer = {}));
-
/// \r\n 江苏省审计厅数据汇总平台
\r\n \r\n \r\n \r\n 本地文件列表
\r\n \r\n - 文件名
\r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n \r\n - 文件属性
\r\n \r\n \r\n
\r\n \r\n \r\n \r\n \r\n 服务器文件列表
\r\n \r\n \r\n employee: {{node.name}} age {{node.age}}\r\n \r\n \r\n \r\n \r\n \r\n - 文件名
\r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n \r\n - 文件属性
\r\n
\r\n \r\n \r\n \r\n \r\n\r\n \r\n\r\n\r\n\r\n");
-$templateCache.put("plugins/developer/html/code.html","\n \n \n \n\n \n \n \n\n \n \n \n There are no tools currently available.
\n \n \n \n There are no tools currently available.
\n \n \n \n \n \n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/environment.html","environment!!!!");
-$templateCache.put("plugins/developer/html/environmentPanel.html","\n \n \n \n \n \n \n {{env.label}}\n \n
\n \n\n \n \n \n \n \n \n \n {{rc.$name}}\n : {{version}}\n \n \n \n {{rc.$name}}\n : {{version}}\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {{rc.$podCounters.ready}}\n {{rc.$podCounters.valid}}\n {{rc.$podCounters.waiting}}\n {{rc.$podCounters.error}}\n \n \n \n \n \n \n Build #{{rc.$buildId}}\n \n \n \n \n \n \n Commit {{rc.$gitCommit | limitTo:7}}\n \n \n \n Commit {{rc.$gitCommit | limitTo:7}}\n \n \n \n \n\n\n \n\n \n \n");
-$templateCache.put("plugins/developer/html/environments.html","\n\n \n \n\n \n\n \n \n \n \n \n \n \n \n \n\n \n\n\n \n\n \n \n \n \n Environments Overview
\n \n \n \n \n \n No Environment Available
\n Environment is a logical place where deployments happen which maps to a kubernetes / openshift namespace. You will see environments here after you add a build.
\n New Build\n \n \n \n \n \n \n \n \n \n \n \n\n \n \n \n \n Active Pipelines\n View All Pipelines >>\n
\n \n \n \n \n \n \n\n \n \n \n \n Commits
\n View All Commits >>\n \n \n \n \n \n \n \n\n\n");
-$templateCache.put("plugins/developer/html/home.html","\n \n Perspectives
\n\n \n Please choose the perspective you would like to use:\n
\n \n \n\n \n \n \n \n Develop »\n \n
\n\n \n Work on projects and source code\n
\n \n \n \n \n \n Operate »\n \n
\n\n \n Manage and run Pods and Services\n
\n \n \n");
-$templateCache.put("plugins/developer/html/jenkinsApproveModal.html","\n {{operation}}?
\n\n\n Are you sure you wish to {{operation}}?\n\n\n");
-$templateCache.put("plugins/developer/html/jenkinsJob.html","\n \n \n \n \n\n\n \n \n \n\n \n \n \n\n \n \n \n There are no builds in this job.
\n \n \n
\n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/jenkinsJobs.html","\n \n \n \n \n \n \n\n\n \n \n \n\n \n \n \n\n \n \n \n There are no jobs in this jenkins.
\n \n \n
\n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/jenkinsLog.html","\n \n \n \n\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n\n \n \n\n");
-$templateCache.put("plugins/developer/html/jenkinsMetrics.html","\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n There are no completed builds in this job.
\n \n \n There are no pipeline stages in this build.
\n \n \n\n Pipeline for {{jobId}}
\n\n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/pipelineView.html","\n \n \n \n \n Build {{build.displayName}}\n \n \n started {{build.$timestamp.relative()}}\n \n
\n \n\n \n \n\n \n \n \n\n \n \n \n \n \n \n \n {{stage.stageName}}\n \n \n \n \n \n\n \n \n \n \n View Full Log\n \n \n \n \n Logs
\n View Full Log\n \n \n \n\n \n \n\n\n \n\n");
-$templateCache.put("plugins/developer/html/pipelines.html","\n \n \n\n \n \n \n There are no pipelines for this job.
\n \n \n \n \n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/projectDetail.html","\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/projectSelector.html","\n - \n \n \n \n \n \n
\n
\n");
-$templateCache.put("plugins/developer/html/projects.html","\n \n \n \n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n There are no projects in this workspace.
\n \n \n
\n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/tools.html","\n \n \n \n\n \n \n \n\n \n \n \n There are no tools currently available.
\n \n \n \n There are no tools currently available.
\n \n \n \n \n \n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/workspace.html","\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n");
-$templateCache.put("plugins/developer/html/workspaces.html","\n \n \n\n \n \n \n \n 江苏省审计厅数据汇总平台
\n \n \n \n 本地文件列表
\n \n - 文件名
\n \n {{node.name}}\n \n
\n \n - 已选数据文件
\n - {{node.name}}
\n\n
\n \n - 采集时间
\n - {{node.date}} \n {{model.uploadprocess[node.id]}}%
\n
\n \n \n \n \n \n 服务器文件列表
\n \n \n {{node.name}}\n \n \n \n \n - 文件名
\n - {{item.name}}
\n
\n \n - 采集时间
\n - {{item.time}}
\n
\n \n \n \n \n 下载服务数据\n \n 启动oracle服务\n \n \n \n \n\n\n\n\n");
-$templateCache.put("plugins/kubernetes/html/appDeployedTemplate.html","\n {{row.entity.$creationDate ? (row.entity.$creationDate | relativeTime) : \'\'}}\n\n");
+angular.module("hawtio-kubernetes-templates", []).run(["$templateCache", function($templateCache) {$templateCache.put("plugins/kubernetes/html/appDeployedTemplate.html","\n {{row.entity.$creationDate ? (row.entity.$creationDate | relativeTime) : \'\'}}\n\n");
$templateCache.put("plugins/kubernetes/html/appDetailTemplate.html","\n \n \n \n \n ![]()
\n \n \n \n \n {{view.appName}}\n \n \n \n \n \n \n {{view.service.$host}}\n \n {{view.service.$host}}\n \n \n \n \n\n \n \n \n \n deployed:\n {{view.createdDate | relativeTime}}\n \n \n not deployed\n \n \n \n \n pod template:\n {{view.controllerId}} \n \n \n no pod template\n \n \n \n \n pods:\n \n {{view.podCount}}\n \n \n {{view.podCount}}\n \n \n \n \n\n \n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n Pod {{pod.idAbbrev}}\n \n \n IP:\n {{pod.status.podIP}}\n \n \n \n \n \n \n
\n \n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/appIconTemplate.html","\n \n ![]()
\n \n \n \n {{row.entity.$info.name}}\n \n \n\n");
$templateCache.put("plugins/kubernetes/html/appPodCountsAndLinkTemplate.html","\n");
@@ -18537,8 +18564,8 @@ $templateCache.put("plugins/kubernetes/html/hosts.html","\n \n \n \n \n \n \n \n \n \n \n \n \n \n There are no image repositories available.
\n Create Image Repository\n \n \n
\n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/importProject.html","\n \n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n\n \n Create a project by entering or copy/pasting the Git URL for a repository, and give the project a name. By default the name will be based on the repository name.\n
\n\n \n\n \n\n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/kubernetesJsonDirective.html","\n \n \n \n\n \n \n ![]()
\n \n \n \n {{displayName || appTitle}}
\n \n \n \n \n \n {{containerName}} logs
\n \n \n \n \n \n {{containerName}}的汇总日志
\n \n \n \n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/overview.html","\n \n \n \n \n \n \n \n \n \n\n \n \n \n\n No Pipeline Available
\n Pipeline is a kind of build which uses Jenkins Workflow internally which has multiple Stages. You will see the active pipelines here after you add a build to this project
\n \n \n \n \n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/pipelines.html","\n \n \n \n \n There are no build pipelines available.
\n Create Build Configuration\n \n \n \n \n \n \n \n\n \n \n \n \n \n \n \n \n \n\n \n \n \n \n {{step.buildConfig.metadata.name}}\n \n \n \n \n \n \n build\n \n \n\n \n \n \n new: {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n pending: {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n running {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n completed {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n failed {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n {{step.buildConfig.$lastBuild.status}}: {{step.buildConfig.$lastBuild.$creationDate.relative()}}\n \n \n \n \n \n \n logs\n \n \n \n \n \n \n \n \n \n \n\n \n \n \n \n \n \n \n \n\n");
@@ -18549,7 +18576,7 @@ $templateCache.put("plugins/kubernetes/html/pods.html","\n\n \n \n \n\n \n \n \n\n \n \n \n ![]()
{{item.metadata.name}}\n \n\n \n \n\n \n \n\n {{rawMode ? \'Form\' : \'Raw\'}}\n \n\n Edit\n \n\n Save\n \n\n \n Events\n \n\n \n\n \n Scale\n \n\n Pods:\n \n {{item.$podCounters.ready}}\n {{item.$podCounters.valid}}\n {{item.$podCounters.waiting}}\n {{item.$podCounters.error}}\n \n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n \n \n \n \n \n\n \n \n");
$templateCache.put("plugins/kubernetes/html/replicationControllerCreate.html","\n");
$templateCache.put("plugins/kubernetes/html/replicationControllerEdit.html","\n");
-$templateCache.put("plugins/kubernetes/html/replicationControllers.html","\n \n \n\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n 当前没有正在运行的oracle服务.
\n \n \n
\n \n \n \n \n \n\n \n \n \n \n");
+$templateCache.put("plugins/kubernetes/html/replicationControllers.html","\n \n \n\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n 当前没有正在运行的oracle服务.
\n \n \n
\n \n \n \n \n \n\n \n \n \n \n");
$templateCache.put("plugins/kubernetes/html/secret.html","\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n\n \n \n \n \n \n \n \n \n \n\n \n \n \n \n\n\n \n \n \n \n \n \n \n \n \n \n \n \n\n \n \n \n\n\n");
$templateCache.put("plugins/kubernetes/html/secrets.html","\n \n \n \n\n \n \n \n\n \n \n \n There are no secrets currently available.
\n \n \n
\n \n \n \n \n\n");
$templateCache.put("plugins/kubernetes/html/service.html","\n \n \n \n\n \n \n \n\n \n \n \n ![]()
{{item.metadata.name}}\n \n\n \n \n\n \n\n {{rawMode ? \'Form\' : \'Raw\'}}\n \n\n Edit\n \n\n Save\n \n\n \n Connect\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n \n \n \n \n \n\n\n");
@@ -18560,4 +18587,25 @@ $templateCache.put("plugins/kubernetes/html/services.html","\n");
$templateCache.put("plugins/kubernetes/html/templateDescription.html","\n Description
\n\n\n \n\n\n");
$templateCache.put("plugins/kubernetes/html/templates.html","\n \n\n \n \n \n\n \n \n \n\n\n \n \n \n \r\n 江苏省审计厅数据汇总平台
\r\n \r\n \r\n \r\n 本地文件列表
\r\n \r\n - 文件名
\r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n \r\n - 文件属性
\r\n \r\n \r\n
\r\n \r\n \r\n \r\n \r\n 服务器文件列表
\r\n \r\n \r\n employee: {{node.name}} age {{node.age}}\r\n \r\n \r\n \r\n \r\n \r\n - 文件名
\r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n \r\n - 文件属性
\r\n
\r\n \r\n \r\n \r\n \r\n\r\n \r\n\r\n\r\n\r\n");
+$templateCache.put("plugins/developer/html/code.html","\n \n \n \n\n \n \n \n\n \n \n \n There are no tools currently available.
\n \n \n \n There are no tools currently available.
\n \n \n \n \n \n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/environment.html","environment!!!!");
+$templateCache.put("plugins/developer/html/environmentPanel.html","\n \n \n \n \n \n \n {{env.label}}\n \n
\n \n\n \n \n \n \n \n \n \n {{rc.$name}}\n : {{version}}\n \n \n \n {{rc.$name}}\n : {{version}}\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {{rc.$podCounters.ready}}\n {{rc.$podCounters.valid}}\n {{rc.$podCounters.waiting}}\n {{rc.$podCounters.error}}\n \n \n \n \n \n \n Build #{{rc.$buildId}}\n \n \n \n \n \n \n Commit {{rc.$gitCommit | limitTo:7}}\n \n \n \n Commit {{rc.$gitCommit | limitTo:7}}\n \n \n \n \n\n\n \n\n \n \n");
+$templateCache.put("plugins/developer/html/environments.html","\n\n \n \n\n \n\n \n \n \n \n \n \n \n \n \n\n \n\n\n \n\n \n \n \n \n Environments Overview
\n \n \n \n \n \n No Environment Available
\n Environment is a logical place where deployments happen which maps to a kubernetes / openshift namespace. You will see environments here after you add a build.
\n New Build\n \n \n \n \n \n \n \n \n \n \n \n\n \n \n \n \n Active Pipelines\n View All Pipelines >>\n
\n \n \n \n \n \n \n\n \n \n \n \n Commits
\n View All Commits >>\n \n \n \n \n \n \n \n\n\n");
+$templateCache.put("plugins/developer/html/home.html","\n \n Perspectives
\n\n \n Please choose the perspective you would like to use:\n
\n \n \n\n \n \n \n \n Develop »\n \n
\n\n \n Work on projects and source code\n
\n \n \n \n \n \n Operate »\n \n
\n\n \n Manage and run Pods and Services\n
\n \n \n");
+$templateCache.put("plugins/developer/html/jenkinsApproveModal.html","\n {{operation}}?
\n\n\n Are you sure you wish to {{operation}}?\n\n\n");
+$templateCache.put("plugins/developer/html/jenkinsJob.html","\n \n \n \n \n\n\n \n \n \n\n \n \n \n\n \n \n \n There are no builds in this job.
\n \n \n
\n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/jenkinsJobs.html","\n \n \n \n \n \n \n\n\n \n \n \n\n \n \n \n\n \n \n \n There are no jobs in this jenkins.
\n \n \n
\n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/jenkinsLog.html","\n \n \n \n\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n\n \n \n\n");
+$templateCache.put("plugins/developer/html/jenkinsMetrics.html","\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n There are no completed builds in this job.
\n \n \n There are no pipeline stages in this build.
\n \n \n\n Pipeline for {{jobId}}
\n\n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/pipelineView.html","\n \n \n \n \n Build {{build.displayName}}\n \n \n started {{build.$timestamp.relative()}}\n \n
\n \n\n \n \n\n \n \n \n\n \n \n \n \n \n \n \n {{stage.stageName}}\n \n \n \n \n \n\n \n \n \n \n View Full Log\n \n \n \n \n Logs
\n View Full Log\n \n \n \n\n \n \n\n\n \n\n");
+$templateCache.put("plugins/developer/html/pipelines.html","\n \n \n\n \n \n \n There are no pipelines for this job.
\n \n \n \n \n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/projectDetail.html","\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/projectSelector.html","\n - \n \n \n \n \n \n
\n
\n");
+$templateCache.put("plugins/developer/html/projects.html","\n \n \n \n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n There are no projects in this workspace.
\n \n \n
\n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/tools.html","\n \n \n \n\n \n \n \n\n \n \n \n There are no tools currently available.
\n \n \n \n There are no tools currently available.
\n \n \n \n \n \n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/workspace.html","\n \n \n \n\n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n");
+$templateCache.put("plugins/developer/html/workspaces.html","\n \n \n\n \n \n \n \n 江苏省审计厅数据汇总平台
\n \n \n \n 本地文件列表
\n \n - 文件名
\n \n {{node.name}}\n \n
\n \n - 已选数据文件
\n - {{node.name}}
\n\n
\n \n - 采集时间
\n - {{node.date}} \n {{model.uploadprocess[node.id]}}%
\n
\n \n \n \n \n \n 服务器文件列表
\n \n \n {{node.name}}\n \n \n \n \n - 文件名
\n - {{item.name}}
\n
\n \n - 采集时间
\n - {{item.time}}
\n
\n \n \n \n \n 下载服务数据\n \n 启动oracle服务\n \n \n \n \n\n\n\n\n");}]); hawtioPluginLoader.addModule("hawtio-kubernetes-templates");
\ No newline at end of file
diff --git a/gulpfile.js b/gulpfile.js
index 34d9a1d..eceef50 100644
--- a/gulpfile.js
+++ b/gulpfile.js
@@ -18,18 +18,18 @@ var gulp = require('gulp'),
app = hawtio.app,
shellprocess = require('child_process'),
xmloperation = require('./app/xmloperation'),
- rootdir = process.env.STORAGE_PATH || '/home/server_data/',
K8s = require('k8s'),
crontab = require('node-crontab'),
+ async = require('async'),
myjs=require('./app/my.js');
var oracledb = require('oracledb');
-
var plugins = gulpLoadPlugins({});
var pkg = require('./package.json');
var time =0;
var schedule = [];
-
+var allDataPath = process.env.ALL_DATA || '/home/all_data';
+var rootdir = allDataPath + "/collecting_data/";
var kubectl = K8s.kubectl({
endpoint: process.env.KUBERNETES_MASTER,
binary: '/usr/bin/kubectl'
@@ -313,7 +313,7 @@ gulp.task('connect', ['watch'], function() {
if(req.method=='POST') {
var data = [];
var parser = new xml2js.Parser();
- fs.readFile(rootdir + 'data.xml', function(err, xml) {
+ fs.readFile(rootdir + '/data.xml', function(err, xml) {
parser.parseString(xml, function (err, result) {
myjs.Recursion(result.node);
data.push(result.node);
@@ -324,9 +324,9 @@ gulp.task('connect', ['watch'], function() {
});
hawtio.use("/oracleAppPath",function(req,res){
- var dataPath = "/home/ubuntu/data/";
- var tmpPath = "/home/ubuntu/tmp/app";
- var appSource="/home/app";
+ var dataPath = allDataPath + "/tabulate_data/";
+ var tmpPath = allDataPath + "/tmp_data/app";
+ var appSource=allDataPath + "/template/app";
if(req.method="POST"){
var timestamp=new Date();
if((timestamp.getTime() - time) >= 2*60*1000){
@@ -337,7 +337,7 @@ gulp.task('connect', ['watch'], function() {
fs.mkdirSync(dataPath);
//path.exists(tmpPath,function(exists){if(exists) console.log("exists");});
fs.renameSync(tmpPath, dataPath+"app");
- console.log("move 'home/ubuntu/tmp/app' to " + dataPath);
+ console.log("move '" + tmpPath + "' to " + dataPath);
xmloperation.savehuizong(timestamp.Format('yyyy-MM-dd hh:mm:ss'), '10', id, "汇总数据库("+ id +")", dataPath, dirName);
fs.writeFileSync('./app/version.txt', 2);
res.send(200,{path: dataPath+"app/", name: dirName});
@@ -352,6 +352,18 @@ gulp.task('connect', ['watch'], function() {
//}
});
+ hawtio.use('/oracleExtractLog', function(req,res){
+ var path = allDataPath + "/tabulate_logs/" + req.query.rcName;
+ if(fs.existsSync(path)){
+ var log = fs.readFileSync(path, 'utf-8');
+ res.send(200,{logContent: log.toString()});
+ res.end();
+ }else{
+ res.send(200,{logContent: "当前没有日志可以查看！"});
+ res.end();
+ }
+ });
+
hawtio.use('/uploadfiles',function(req,res){
if(req.method==="POST"){
var relativePath = req.body.resumableRelativePath;
@@ -549,95 +561,271 @@ gulp.task('connect', ['watch'], function() {
});*/
hawtio.use('/connectToOracle',function(req,res){
- var rcName = req.query.oracleName;
+ var rcName = req.query.oracleName;
- cancelOracleConectionTask(rcName);
+ cancelOracleConectionTask(rcName);
- kubectl.rc.get(rcName,function(err, rc){
- //console.log(rc);
- if(err){
- console.log(err);
- return
- }
- if(rc && rc.status.replicas === 1 && rc.metadata.labels.hasOwnProperty("style") && rc.metadata.labels.style === "oracle"){
- var selector = rc.spec.selector;
- var task = {
- taskName: rcName,
- taskTime: 0,
- taskCrontab: crontab.scheduleJob("*/1 * * * *", function(){ //This will call this function every 2 minutes
- //console.log(rcName + "it's been 1 minutes!");
- if(task.taskTime === 9){
- kubectl.rc.command("label --overwrite rc " + task.taskName + " status=1", function(err, data){
- if(err)
- console.log(err);
- crontab.cancelJob(task.taskCrontab);
- cancelOracleConectionTask(task.rcName);
- });
- }
+ kubectl.rc.get(rcName,function(err, rc){
+ //console.log(rc);
+ if(err){
+ console.log(err);
+ return
+ }
+ if(rc && rc.status.replicas === 1 && rc.metadata.labels.hasOwnProperty("style") && rc.metadata.labels.style === "oracle"){
+ var selector = rc.spec.selector;
+ var task = {
+ taskName: rcName,
+ taskTime: 0,
+ taskCrontab: crontab.scheduleJob("*/1 * * * *", function(){ //This will call this function every 2 minutes
+ //console.log(rcName + "it's been 1 minutes!");
+ if(task.taskTime === 9){
+ kubectl.rc.command("label --overwrite rc " + task.taskName + " status=1", function(err, data){
+ if(err)
+ console.log(err);
+ crontab.cancelJob(task.taskCrontab);
+ cancelOracleConectionTask(task.rcName);
+ return;
+ });
+ }
+
+ var selectorPods = [];
+ kubectl.pod.list(function(err, pods){
+ if(!err){
+ pods.items.forEach(function(item){
+ if(myjs.selectorMatches(selector, item.metadata.labels))
+ selectorPods.push(item);
+ });
+ if(selectorPods.length === 0)
+ return;
+ var host = selectorPods[0].status.hostIP
+ var port = selectorPods[0].spec.containers[0].ports[0].hostPort;
+
+ if(host && port){
+ oracledb.getConnection(
+ {
+ user : "system",
+ password : "oracle",
+ connectString : host + ":" + port + "/orcl"
+ },function(err, connection){
+ if (err) {
+ console.log("connection failed! message" + err.message);
+ return;
+ }
+
+ kubectl.rc.command("label --overwrite rc " + task.taskName + " status=2", function(err, data){
+ if(err){
+ console.log(err);
+ }
+ console.log("update replicationControllers " + rcName + " success");
+ if(connection !== null){
+ connection.close(function(err){
+ if (err){
+ console.error(err.message);
+ }
+ console.log(rcName + "connect success!");
+ crontab.cancelJob(task.taskCrontab);
+ cancelOracleConectionTask(task.rcName);
+ console.log(rcName + "connection closed!");
+ });
+ }
+ });
+ });
+ }
+ }
+ });
+ task.taskTime++;
+ })
+ }
+ schedule.push(task);
+ }
+ res.send(200,"Ok");
+ res.end();
+ });
+ });
- var selectorPods = [];
- kubectl.pod.list(function(err, pods){
- if(!err){
- pods.items.forEach(function(item){
- if(myjs.selectorMatches(selector, item.metadata.labels))
- selectorPods.push(item);
- });
- if(selectorPods.length === 0)
- return;
- var host = selectorPods[0].status.hostIP
- var port = selectorPods[0].spec.containers[0].ports[0].hostPort;
- if(host && port){
- oracledb.getConnection(
- {
- user : "system",
- password : "oracle",
- connectString : host + ":" + port + "/orcl"
- },function(err, connection){
- if (err) {
- console.log("connection failed! message" + err.message);
- return;
- }
- console.log("connect success!");
- kubectl.rc.command("label --overwrite rc " + task.taskName + " status=2", function(err, data){
- if(err){
- console.log(err);
- }
- console.log("update replicationControllers " + rcName + " success");
- if(connection !== null){
- connection.close(function(err){
- if (err){
- console.error(err.message);
- }
- crontab.cancelJob(task.taskCrontab);
- cancelOracleConectionTask(task.rcName);
- console.log("connection closed!");
- });
- }
- });
- });
- }
- }
- });
- task.taskTime++;
- })
- }
- schedule.push(task);
- }
- res.send(200,"Ok");
- res.end();
- });
- });
hawtio.use('/cancelOracleConection', function(req,res){
- var rcName = req.query.oracleName;
- cancelOracleConectionTask(rcName);
- res.send(200,"Ok");
- res.end();
+ var rcName = req.query.oracleName;
+ var operation = req.query.operation;
+ if(operation !== 'stop')
+ cancelOracleConectionTask(rcName);
+ else{
+ kubectl.rc.command("label --overwrite rc " + rcName + " status=0", function(err, data){
+ if(err)
+ console.error(err.message);
+ console.log("update replicationControllers " + rcName + " success");
+ cancelOracleConectionTask(rcName);
+ });
+ }
+ res.send(200,"Ok");
+ res.end();
});
hawtio.use('/extractOracleData', function(req,res){
var data = req.query.param;
- console.log(data);
+ var poolOracle;
+ var collectOracle = [];
+ data.forEach(function(item){
+ var obj = JSON.parse(item);
+ if(obj.isTarget)
+ poolOracle = obj;
+ else{
+ var names = obj.OracleName.split("-");
+ kubectl.rc.command("label --overwrite rc " + obj.OracleName + " isExtract=1", function(err, data){
+ if(err)
+ console.error(err);
+ console.log("update replicationControllers " + obj.OracleName + " success");
+ });
+ obj["name"] = "J" + names[0] + "_" + names[1];
+ collectOracle.push(obj);
+ }
+ });
+ var poolOracleParam = poolOracle.connectHost + ":" +poolOracle.connectPort;
+ var logMessage = "";
+
+ oracledb.getConnection({
+ user : "system",
+ password : "oracle",
+ connectString : poolOracleParam + "/orcl"
+ }, function(err, connection){
+ if (err) {
+ console.error(err.message);
+ return;
+ }
+ var logPath = allDataPath + "/tabulate_logs/";
+ async.eachSeries(collectOracle, function(item, callback){
+ var strTUser = item.name + "_20152016";
+ var message = "-------------------------------------------采集库:" + item.name + "执行汇总-------------------------------------------";
+ console.log(message);
+ fs.appendFileSync(logPath + poolOracle.OracleName, message + "\n\n");
+ async.waterfall([
+ function(cb){
+ var dbLinkSql = "create public database link linkTo" + item.name + " connect to system IDENTIFIED BY oracle using "
+ +"'(DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = "
+ + item.connectHost + ")(PORT = " + item.connectPort + ")))(CONNECT_DATA = (SERVICE_NAME = orcl)))'";
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + dbLinkSql + "\n\n");
+ connection.execute(dbLinkSql, function(err, result){
+ if(err){
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ cb(null);
+ return;
+ }
+ fs.appendFileSync(logPath + poolOracle.OracleName, "数据库链接已创建。" + "\n\n");
+ cb(null);
+ });
+ },
+ function(cb){
+ connection.execute("select TABLESPACE_NAME from dba_tablespaces where TABLESPACE_NAME = 'TS_JSSJBS'", function(err, result){
+ if(err){
+ console.log(err);
+ return;
+ }
+ if(result.rows.length !== 0)
+ cb(null, false);
+ else
+ cb(null, true);
+ });
+ },
+ function(arg, cb){
+ if(!arg){
+ cb(null);
+ return;
+ }
+ var sql = "create tablespace TS_JSSJBS datafile '/opt/oracle/app/oradata/orcl/ts_jssjbs.dbf' size 512M autoextend on next 512M maxsize unlimited";
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + sql + ";\n\n");
+ connection.execute(sql, function(err, result){
+ if (err){
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ cb(null);
+ return;
+ }
+ fs.appendFileSync(logPath + poolOracle.OracleName, "表空间已创建。" + "\n\n");
+ cb(null);
+ });
+ },
+ function(cb){
+ var sql = "Create user " + strTUser + " default tablespace TS_JSSJBS identified by 1";
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + sql + ";\n\n");
+ connection.execute(sql, function(err, result){
+ if (err){
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ cb(null);
+ return;
+ }
+ fs.appendFileSync(logPath + poolOracle.OracleName, "用户已创建。" + "\n\n");
+ //console.log("create us");
+ cb(null);
+ });
+ },
+ function(cb){
+ var sql = "grant connect, resource, dba to " + strTUser;
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + sql + ";\n\n");
+ connection.execute(sql, function(err, result){
+ if(err)
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ fs.appendFileSync(logPath + poolOracle.OracleName, "授权成功。" + "\n\n");
+ //console.log("grant dba");
+ cb(null);
+ });
+ },
+ function(cb){
+ var sql = "SELECT 'create table " + strTUser + ".J'|| substr(t.OWNER||'_'||t.TABLE_NAME,0,29)||' as select * from '||t.OWNER||'.'||t.TABLE_NAME||"
+ +"'@linkTo" + item.name + ";' FROM dba_tables@linkTo" + item.name + " t WHERE t.TABLESPACE_NAME NOT IN ('SYSTEM','SYSAUX')"
+ + " and t.owner||t.table_name not in (select owner||table_name from dba_tables@linkTo" + item.name + " where 'data_type'='CLOB')";
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + sql + ";\n\n");
+ connection.execute(sql, function(err, result){
+ if(err){
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ return;
+ }
+ preSql = [];
+ result.rows.forEach(function(row){
+ row.forEach(function(it){
+ preSql.push(it.replace(/;$/, ""));
+ fs.appendFileSync(logPath + poolOracle.OracleName, it + "\n");
+ });
+ });
+ fs.appendFileSync(logPath + poolOracle.OracleName, "\n");
+ cb(null, preSql);
+ });
+ },
+ function(arg, cb){
+ async.eachSeries(arg, function(sql, cback){
+ fs.appendFileSync(logPath + poolOracle.OracleName, "SQL> " + sql + ";\n\n");
+ connection.execute(sql, function(err, result){
+ if(err){
+ fs.appendFileSync(logPath + poolOracle.OracleName, err + "\n\n");
+ cback(null, !err);
+ return;
+ }
+ fs.appendFileSync(logPath + poolOracle.OracleName, "表已创建。" + "\n\n");
+ cback(null, !err);
+ });
+ }, function(err, result){
+ cb(null);
+ });
+ }
+ ], function(err, result){
+ if(err)
+ console.error(err);
+ kubectl.rc.command("label --overwrite rc " + item.OracleName + " isExtract=2", function(err, data){
+ if(err)
+ console.err(err);
+ console.log("update replicationControllers " + item.OracleName + " success");
+ callback(null);
+ });
+ });
+ }, function(err, result){
+ if(err)
+ console.error(err);
+ connection.close(function(err){
+ if(err)
+ console.log(err);
+ });
+ });
+ });
+ res.send(200,"Ok");
+ res.end();
});
hawtio.listen(function(server) {
diff --git a/node_modules.tar.gz b/node_modules.tar.gz
new file mode 100644
index 0000000..66b7cb9
Binary files /dev/null and b/node_modules.tar.gz differ
diff --git a/package.json b/package.json
index 1d76c97..0dfe8b7 100644
--- a/package.json
+++ b/package.json
@@ -29,6 +29,7 @@
"yargs": "^3.32.0"
},
"dependencies": {
+ "async": "^2.0.0-rc.6",
"connect-multiparty": "^2.0.0",
"hawtio-node-backend": "^2.1.0",
"k8s": "^0.2.7",
diff --git a/plugins/developer/ts/workspaces.ts b/plugins/developer/ts/workspaces.ts
index f9982cc..8cfaf74 100644
--- a/plugins/developer/ts/workspaces.ts
+++ b/plugins/developer/ts/workspaces.ts
@@ -364,7 +364,7 @@ module Developer {
}
$scope.downLoadFiles = ()=>{
- Kubernetes.connectOracle($http, $timeout, "192.168.0.103:64182", "320614-54-1", 500);
+ //Kubernetes.connectOracle($http, $timeout, "192.168.0.103:64182", "320614-54-1", 500);
}
$scope.isSelected= (node)=>{
@@ -394,8 +394,8 @@ module Developer {
var Obj = createRCObj($scope.model.selecteditems[id]);
if(!checkIsRunning(KubernetesModel.replicationControllers,Obj)){
Kubernetes.createRC(Obj, (rc) =>{
- console.log(rc.metadata.name);
- Kubernetes.connectOracle($http, $timeout, "/connectToOracle", "", rc.metadata.name, 0);
+ console.log(rc);
+ Kubernetes.connectOracle($http, $timeout, "/connectToOracle", "create", rc.metadata.name, 0);
});
}
}
diff --git a/plugins/kubernetes/html/layoutKubernetes.html b/plugins/kubernetes/html/layoutKubernetes.html
index f8da014..a08176f 100644
--- a/plugins/kubernetes/html/layoutKubernetes.html
+++ b/plugins/kubernetes/html/layoutKubernetes.html
@@ -34,6 +34,22 @@
+
+
+
+
+