diff --git a/jenkinsfile_script_3.6.2_data_bind_anxinproject_local b/jenkinsfile_script_3.6.2_data_bind_anxinproject_local new file mode 100644 index 0000000..2c834d6 --- /dev/null +++ b/jenkinsfile_script_3.6.2_data_bind_anxinproject_local @@ -0,0 +1,25 @@ +podTemplate { + node('pod-templ-jenkins-slave-common') { + + env.IMAGE_NAME = "${IOT_IMAGES_REGISTRY}/${IOT}/${JOB_NAME}" + env.IMAGE_NAME_SHORT = "${IOT}/${JOB_NAME}" + env.CODE_ADDR = "${GIT_ADDRESS}/free-sun/Inspection.git" + + stage('Run shell') { + git branch: 'master', credentialsId: 'gitea-builder', url: "${CODE_ADDR}" + + container('image-builder') { + sh''' + pwd + ls -al + + /kaniko/executor --context=${BUILD_WORKSPACE} --dockerfile=./script/2.0.0/data/1_reset_project_bind_point/Dockerfile --destination=${IMAGE_NAME}:${IMAGE_VERSION} --cache=false --cleanup + + ''' + } + + buildName "${IMAGE_NAME_SHORT}:${IMAGE_VERSION}" + buildDescription "${IMAGE_NAME}:${IMAGE_VERSION}" + } + } +} \ No newline at end of file diff --git a/script/3.6.2/data/1_bing_anxinproject_local/.vscode/launch.json b/script/3.6.2/data/1_bing_anxinproject_local/.vscode/launch.json new file mode 100644 index 0000000..3a3fcba --- /dev/null +++ b/script/3.6.2/data/1_bing_anxinproject_local/.vscode/launch.json @@ -0,0 +1,17 @@ +{ + // 使用 IntelliSense 了解相关属性。 + // 悬停以查看现有属性的描述。 + // 欲了解更多信息，请访问: https://go.microsoft.com/fwlink/?linkid=830387 + "version": "0.2.0", + "configurations": [ + { + "type": "node", + "request": "launch", + "name": "启动程序", + "skipFiles": [ + "/**" + ], + "program": "${workspaceFolder}\\index.js" + } + ] +} \ No newline at end of file diff --git a/script/3.6.2/data/1_bing_anxinproject_local/Dockerfile b/script/3.6.2/data/1_bing_anxinproject_local/Dockerfile new file mode 100644 index 0000000..046f4f8 --- /dev/null +++ b/script/3.6.2/data/1_bing_anxinproject_local/Dockerfile @@ -0,0 +1,9 @@ +FROM repository.anxinyun.cn/base-images/nodejs12:20.10.12.2 + +COPY . /var/app + +WORKDIR /var/app + +RUN npm cache clean -f && npm install --production --force --registry https://nexus.ngaiot.com/repository/fs-npm/ + +ENTRYPOINT [ "node", "index.js" ] \ No newline at end of file diff --git a/script/3.6.2/data/1_bing_anxinproject_local/index.js b/script/3.6.2/data/1_bing_anxinproject_local/index.js new file mode 100644 index 0000000..92c6afa --- /dev/null +++ b/script/3.6.2/data/1_bing_anxinproject_local/index.js @@ -0,0 +1,91 @@ +try { + const { Pool, Client } = require('pg') + const path = require('path') + const fs = require("fs"); + + // 开发环境 + // ! 这里是安心云 + const anxinyunPool = new Pool({ + user: 'postgres', + host: '10.8.30.166', + database: 'Anxinyun0726', + password: '123', + port: 5432, + }) + // 这里是运维平台 + const pomsPool = new Pool({ + user: 'postgres', + host: '10.8.30.32', + database: 'poms_231026_backup', + password: '123', + port: 5432, + }) + + // 商用环境 + // const pool = new Pool({ + // user: '', + // host: '', + // database: '', + // password: '', + // port: 5432, + // }) + + // ! 这里是假定的创建人id + const create_user_id = 1 + + const fun = async () => { + // note: we don't try/catch this because if connecting throws an exception + // we don't need to dispose of the client (it will be undefined) + const anxinClient = await anxinyunPool.connect() + const pomsClient = await pomsPool.connect() + + anxinClient.on('error', err => { + console.error(err); + }) + pomsClient.on('error', () => { + console.error(err); + }) + try { + await anxinClient.query('BEGIN') + await pomsClient.query('BEGIN') + console.log(`开始`); + + const projects = (await anxinClient.query(`SELECT * FROM "t_project"`)).rows + // console.log(projects); + + // 遍历项目 + for (let project of projects) { + console.log(`遍历 ${project.id} ${project.name}`); + // 查项目下结构物 + const strucCount = (await anxinClient.query(`SELECT count(*) FROM "t_project_structure" INNER JOIN "t_structure" ON "t_project_structure"."structure" = "t_structure"."id" WHERE "project" = ${project.id} AND "t_structure"."external_platform" IS NOT null`)).rows + // console.log(strucCount); + if (strucCount[0].count > 0) { + // 判断有没有创建这个项目 + const projectPoms = (await pomsClient.query(`SELECT * FROM project_correlation WHERE anxin_project_id @> ARRAY[${project.id}];`)).rows + if (projectPoms.length == 0) { + // 在运维平台新建项目 + console.log(`创建运维项目`); + const projectData = await pomsClient.query(`INSERT INTO project_correlation (anxin_project_id, create_time, create_user, name, del, update_time) VALUES ('{${project.id}}', NOW(),${create_user_id || 1}, '${project.name}', false, NOW()) RETURNING id;`) + } + } + } + + // await client.query('ROLLBACK') + await anxinClient.query('COMMIT') + await pomsClient.query('COMMIT') + console.log('执行完毕~') + } catch (e) { + await anxinClient.query('ROLLBACK') + await pomsClient.query('ROLLBACK') + console.log('执行错误~') + throw e + } finally { + anxinClient.release(); + pomsClient.release(); + } + } + + fun() +} catch (error) { + console.error(error) +} diff --git a/script/3.6.2/data/1_bing_anxinproject_local/package.json b/script/3.6.2/data/1_bing_anxinproject_local/package.json new file mode 100644 index 0000000..da145d7 --- /dev/null +++ b/script/3.6.2/data/1_bing_anxinproject_local/package.json @@ -0,0 +1,15 @@ +{ + "name": "appkey-generator", + "version": "1.0.0", + "description": "tool", + "main": "index.js", + "scripts": { + "test": "mocha", + "start": "set NODE_ENV=development&&node index" + }, + "author": "liu", + "license": "ISC", + "dependencies": { + "pg": "^7.18.2" + } +} \ No newline at end of file