Skip to content

Q
qa-deploy-utils
Commit 7613cf97 authored by 智勇's avatar 智勇
Browse files
Options

.gitignore

parent 3ac64cd8
Hide whitespace changes
Inline Side-by-side
Showing with 172 additions and 169 deletions
.gitignore
View file @ 7613cf97
...@@ -9,5 +9,4 @@ ...@@ -9,5 +9,4 @@
.DS_Store .DS_Store
qa_shell_script/config_server/node_modules qa_shell_script/config_server/node_modules
.log .log
./qa_shell_script/config_server/package.json qa_shell_script/config_server/package-lock.json
./qa_shell_script/config_server/package-lock.json
qa_shell_script/config_server/get_project_config_server.js
View file @ 7613cf97
...@@ -14,16 +14,16 @@ var options = { ...@@ -14,16 +14,16 @@ var options = {
type: 'application/octet-stream' type: 'application/octet-stream'
}; };
// 同步进行接口转发 // 同步进行接口转发
function requestPromise (option) { function requestPromise(option) {
return new Promise(function (resolve, reject) { return new Promise(function (resolve, reject) {
request(option, function (err, res, body) { request(option, function (err, res, body) {
if (err) { if (err) {
reject(err) reject(err)
} else { } else {
resolve(body) resolve(body)
} }
})
}) })
})
} }
// mongoose.connect('mongodb://localhost/my_database'); // mongoose.connect('mongodb://localhost/my_database');
mongoose.connect('mongodb://172.30.220.22:27017/qaHome') mongoose.connect('mongodb://172.30.220.22:27017/qaHome')
...@@ -93,69 +93,72 @@ function parseJson2Str(json) { ...@@ -93,69 +93,72 @@ function parseJson2Str(json) {
let db_conf = db_config.db_config(); let db_conf = db_config.db_config();
let db_conf_keys = Object.keys(db_conf); let db_conf_keys = Object.keys(db_conf);
// 从mongo中获取配置 // 从mongo中获取配置
function getProjectConfigPromise () { function getProjectConfigPromise() {
return new Promise(function (resolve, reject) { return new Promise(function (resolve, reject) {
// mongoose.model("ProConfig",new mongoose.Schema({})) // mongoose.model("ProConfig",new mongoose.Schema({}))
ProConfig.find({}).exec().then(res=>{ ProConfig.find({}).exec().then(res => {
let _pros = JSON.parse(JSON.stringify(res)); let _pros = JSON.parse(JSON.stringify(res));
let re = {},hosts={}; let re = {}, hosts = {};
for(let pro of _pros){ for (let pro of _pros) {
hosts[pro["project_name"]] = pro["host_name"]; hosts[pro["project_name"]] = pro["host_name"];
if(pro["project_name"] == "xjd-ui"){ if (pro["project_name"] == "xjd-ui") {
hosts["xyqb-ui--xjd-ui"] = pro["host_name"]; hosts["xyqb-ui--xjd-ui"] = pro["host_name"];
}else if(pro["project_name"] == "new-paycenter-ui"){ } else if (pro["project_name"] == "new-paycenter-ui") {
hosts["paycenter-ui--new-paycenter-ui"] = pro["host_name"]; hosts["paycenter-ui--new-paycenter-ui"] = pro["host_name"];
} }
// else if(pro["project_name"] == "new-spider-center-ui"){ // else if(pro["project_name"] == "new-spider-center-ui"){
// hosts["spider-center-ui--new-spider-center-ui"] = pro["host_name"]; // hosts["spider-center-ui--new-spider-center-ui"] = pro["host_name"];
// } // }
let temp = { let temp = {
project_group: "", project_group: "",
name: pro["project_name"], name: pro["project_name"],
type: pro["type"], type: pro["type"],
url: pro["host_name"].replace(".xyqb.com", "").replace(".quantgroup.cn", ""), url: pro["host_name"].replace(".xyqb.com", "").replace(".quantgroup.cn", ""),
www: pro["host_name"], www: pro["host_name"],
git_path: pro["git_path"], git_path: pro["git_path"],
log_name: pro["log_path"], log_name: pro["log_path"],
config_file: pro["config_path"], config_file: pro["config_path"],
command: "", command: "",
command_: "", command_: "",
command2: "", command2: "",
node_version: "", node_version: "",
port: `${pro["port"]}`, port: `${pro["port"]}`,
desc: pro["des"], desc: pro["des"],
is_active: pro["is_active"], is_active: pro["is_active"],
auth: pro["auth"], auth: pro["auth"],
target_path: "" target_path: ""
} }
if(pro["type"] == "java"){ if (pro["type"] == "java") {
temp.node_version = pro["command1"]; temp.node_version = pro["command1"];
temp.target_path = pro["jar_path"]; temp.target_path = pro["jar_path"];
temp.command2 = pro["build_command"]; temp.command2 = pro["build_command"];
temp.command = pro["start_command"]; temp.command = pro["start_command"];
}else if(pro["type"] == "ui"){ } else if (pro["type"] == "ui") {
temp.command = pro["build_command"] temp.command = pro["build_command"]
}else if(pro["type"] == "node"){ } else if (pro["type"] == "node") {
temp.command = pro["start_command"] temp.command = pro["start_command"]
temp.command2 = pro["stop_command"] temp.command2 = pro["stop_command"]
}else if(pro["type"] == "python"){ } else if (pro["type"] == "python") {
} }
re[temp["name"]] = temp; re[temp["name"]] = temp;
} }
resolve({projects:re,hosts:hosts}) resolve({ projects: re, hosts: hosts })
}).catch((err) => { }).catch((err) => {
reject(err) reject(err)
}); });
}) })
} }
// //
admin.get('/get_db_config/:name/:attr', function(req, res) { admin.get('/get_db_config/:name/:attr', function (req, res) {
console.log(111, req)
console.log(222, res)
let str = "" let str = ""
if (req.params.name == "all") { if (req.params.name == "all") {
if (req.params.attr == "name") { if (req.params.attr == "name") {
...@@ -171,14 +174,14 @@ admin.get('/get_db_config/:name/:attr', function(req, res) { ...@@ -171,14 +174,14 @@ admin.get('/get_db_config/:name/:attr', function(req, res) {
} }
}); });
admin.get('/get_db_dump_command/:name/:opt', function(req, res) { admin.get('/get_db_dump_command/:name/:opt', function (req, res) {
if (req.params.opt != "opt") { if (req.params.opt != "opt") {
res.send(db_config.get_mysql_dump_table(req.params.name)); res.send(db_config.get_mysql_dump_table(req.params.name));
} else { } else {
res.send(db_config.get_mysql_dump_opt(req.params.name)); res.send(db_config.get_mysql_dump_opt(req.params.name));
} }
}); });
admin.get('/get_db_config/refersh', function() { admin.get('/get_db_config/refersh', function () {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
db_conf = db_config.db_config(); db_conf = db_config.db_config();
db_conf_keys = Object.keys(db_conf); db_conf_keys = Object.keys(db_conf);
...@@ -187,17 +190,17 @@ admin.get('/get_db_config/refersh', function() { ...@@ -187,17 +190,17 @@ admin.get('/get_db_config/refersh', function() {
// 获取节点命令 // 获取节点命令
admin.get('/get_node_command/:name', async function(req, res) { admin.get('/get_node_command/:name', async function (req, res) {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
let projects = configs.projects let projects = configs.projects
let pro = projects[req.params.name]; let pro = projects[req.params.name];
res.send({ configPath: pro.config_file, buildCmd: pro.command, gitGroup: pro.gitPathHead }); res.send({ configPath: pro.config_file, buildCmd: pro.command, gitGroup: pro.gitPathHead });
}); });
// 获取项目配置 // 获取项目配置
admin.get('/get_project_attr/:name', async function(req, res) { admin.get('/get_project_attr/:name', async function (req, res) {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
var names = req.params.name.split("--"); var names = req.params.name.split("--");
var p_name = ""; var p_name = "";
...@@ -206,75 +209,75 @@ admin.get('/get_project_attr/:name', async function(req, res) { ...@@ -206,75 +209,75 @@ admin.get('/get_project_attr/:name', async function(req, res) {
} else { } else {
p_name = req.params.name p_name = req.params.name
} }
try{ try {
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
let projects = configs.projects let projects = configs.projects
let pro = projects[p_name]; let pro = projects[p_name];
let rs = {}; let rs = {};
for (let item of attrComs){ for (let item of attrComs) {
rs[item] = pro[attrs[item]] rs[item] = pro[attrs[item]]
} }
res.send(rs); res.send(rs);
} }
catch (e){ catch (e) {
console.log(e) console.log(e)
res.send(e) res.send(e)
} }
}); });
// 获取所有域名 // 获取所有域名
admin.get('/get_hosts', async function(req, res) { admin.get('/get_hosts', async function (req, res) {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
res.send(configs.hosts); res.send(configs.hosts);
}); });
// 根据类型获取系统名称 // 根据类型获取系统名称
function getfrontendbackend(pros){ function getfrontendbackend(pros) {
let temp = { let temp = {
frontend : [], frontend: [],
backend : [], backend: [],
ui:[], ui: [],
node:[], node: [],
java:[], java: [],
python:[] python: []
} }
let keys = Object.keys(pros) let keys = Object.keys(pros)
// console.log(keys) // console.log(keys)
for(let key of keys){ for (let key of keys) {
let pro = pros[key] let pro = pros[key]
if(pro.type == "ui"){ if (pro.type == "ui") {
// && pro.name != "spider-center-ui" // && pro.name != "spider-center-ui"
if(pro.name != "xyqb-ui" && pro.name != "paycenter-ui" ){ if (pro.name != "xyqb-ui" && pro.name != "paycenter-ui") {
if(pro.name == "xjd-ui"){ if (pro.name == "xjd-ui") {
temp.frontend.push("xyqb-ui--xjd-ui"); temp.frontend.push("xyqb-ui--xjd-ui");
temp[pro.type].push("xyqb-ui--xjd-ui") temp[pro.type].push("xyqb-ui--xjd-ui")
}else if(pro.name == "new-paycenter-ui"){ } else if (pro.name == "new-paycenter-ui") {
temp.frontend.push("paycenter-ui--new-paycenter-ui"); temp.frontend.push("paycenter-ui--new-paycenter-ui");
temp[pro.type].push("paycenter-ui--new-paycenter-ui") temp[pro.type].push("paycenter-ui--new-paycenter-ui")
} }
// else if(pro.name == "new-spider-center-ui"){ // else if(pro.name == "new-spider-center-ui"){
// temp.frontend.push("spider-center-ui--new-spider-center-ui"); // temp.frontend.push("spider-center-ui--new-spider-center-ui");
// temp[pro.type].push("spider-center-ui--new-spider-center-ui") // temp[pro.type].push("spider-center-ui--new-spider-center-ui")
// } // }
else{ else {
temp.frontend.push(pro.name); temp.frontend.push(pro.name);
temp[pro.type].push(pro.name) temp[pro.type].push(pro.name)
} }
} }
}else{ } else {
temp.backend.push(pro.name); temp.backend.push(pro.name);
temp[pro.type].push(pro.name) temp[pro.type].push(pro.name)
} }
} }
return temp return temp
} }
admin.get('/get_systems_by_type',async function(req, res) { admin.get('/get_systems_by_type', async function (req, res) {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
let pros = configs.projects; let pros = configs.projects;
let fb = getfrontendbackend(pros); let fb = getfrontendbackend(pros);
res.send({ res.send({
common: "db,redis,rabbitmq,zookeeper", common: "db,redis,rabbitmq,zookeeper",
frontend: fb.frontend.join(","), frontend: fb.frontend.join(","),
...@@ -283,48 +286,48 @@ admin.get('/get_systems_by_type',async function(req, res) { ...@@ -283,48 +286,48 @@ admin.get('/get_systems_by_type',async function(req, res) {
}); });
// 给jenkins使用根据类型获取系统名称 // 给jenkins使用根据类型获取系统名称
admin.get('/get_systems_by_type_for_jenkins/:_type',async function(req, res) { admin.get('/get_systems_by_type_for_jenkins/:_type', async function (req, res) {
let str = ""; let str = "";
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
let pros = configs.projects; let pros = configs.projects;
let fb = getfrontendbackend(pros); let fb = getfrontendbackend(pros);
if(req.params._type === "frontend"){ if (req.params._type === "frontend") {
res.send(fb.frontend.join(" ")); res.send(fb.frontend.join(" "));
}else{ } else {
res.send(fb.backend.join(" ")); res.send(fb.backend.join(" "));
} }
}); });
// 给jenkins使用根据类型获取系统名称 // 给jenkins使用根据类型获取系统名称
admin.get('/get_systems_by_type_for_temp', async function(req, res) { admin.get('/get_systems_by_type_for_temp', async function (req, res) {
let configs = await getProjectConfigPromise(); let configs = await getProjectConfigPromise();
let pros = configs.projects; let pros = configs.projects;
let fb = getfrontendbackend(pros); let fb = getfrontendbackend(pros);
res.send({ res.send({
ui: fb.ui.join(" "), ui: fb.ui.join(" "),
java: fb.java.join(" "), java: fb.java.join(" "),
node: fb.node.join(" "), node: fb.node.join(" "),
python: fb.python.join(" ") python: fb.python.join(" ")
}); });
}); });
// 给jenkins使用获取环境的namespace // 给jenkins使用获取环境的namespace
admin.get('/get_namespace_by_type_for_jenkins/:_type', async function(req, res) { admin.get('/get_namespace_by_type_for_jenkins/:_type', async function (req, res) {
let url = ""; let url = "";
if(req.params._type == "old"){ if (req.params._type == "old") {
url = "http://192.168.6.13/api/qahome/list_env" url = "http://192.168.6.13/api/qahome/list_env"
} }
let ns = await requestPromise({url:url,method:"GET"}); let ns = await requestPromise({ url: url, method: "GET" });
ns = JSON.parse(ns); ns = JSON.parse(ns);
let ns_array = []; let ns_array = [];
for(let ist of ns.details.instances){ for (let ist of ns.details.instances) {
ns_array.push(ist.name) ns_array.push(ist.name)
} }
res.send(ns_array.join("\n")); res.send(ns_array.join("\n"));
}); });
// 增加一个新的nginx映射 // 增加一个新的nginx映射
admin.post('/add_new_proxy', function(req, res) { admin.post('/add_new_proxy', function (req, res) {
let request = req.body; let request = req.body;
let new_namespace = request["namespace"], let new_namespace = request["namespace"],
new_ip = request["ip"], new_ip = request["ip"],
...@@ -347,7 +350,7 @@ admin.post('/add_new_proxy', function(req, res) { ...@@ -347,7 +350,7 @@ admin.post('/add_new_proxy', function(req, res) {
// 删除一个namespace映射 // 删除一个namespace映射
admin.post('/remove_proxy', function(req, res) { admin.post('/remove_proxy', function (req, res) {
let request = req.body; let request = req.body;
console.log(request); console.log(request);
let new_namespace = request["namespace"]; let new_namespace = request["namespace"];
...@@ -369,7 +372,7 @@ admin.post('/remove_proxy', function(req, res) { ...@@ -369,7 +372,7 @@ admin.post('/remove_proxy', function(req, res) {
}); });
// 获取现有映射关系 // 获取现有映射关系
admin.get('/get_proxy', function(req, res) { admin.get('/get_proxy', function (req, res) {
res.setHeader("Content-Type", "application/json"); res.setHeader("Content-Type", "application/json");
var str = execSync(`cat ../ngrok/docker_env_name.sh`) var str = execSync(`cat ../ngrok/docker_env_name.sh`)
res.send({ namespace: String(str) }); res.send({ namespace: String(str) });
......
qa_shell_script/config_server/package.json
View file @ 7613cf97
...@@ -12,8 +12,9 @@ ...@@ -12,8 +12,9 @@
"body-parser": "^1.18.2", "body-parser": "^1.18.2",
"child_process": "^1.0.2", "child_process": "^1.0.2",
"express": "^4.16.2", "express": "^4.16.2",
"request": "^2.83.0",
"mongodb": "^2.2.33", "mongodb": "^2.2.33",
"pm2": "^2.7.2" "mongoose": "^5.0.11",
"pm2": "^2.7.2",
"request": "^2.83.0"
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment