openstack

openstack

egg.js+mongodb+openstack 公有云计费系统（三）OpenStack 对接 compute (一)

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1622 次浏览 • 2019-03-19 11:48 • 来自相关话题

配额
控制器
'use strict';

const Controller = require('egg').Controller;

class IndexController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.QPFn = ctx.helper.queryParamFn;
this.SERVICE = ctx.service.openstack.compute.index;
this.serverSERVICE = ctx.service.openstack.server.servers
}
/**
* name 计算相关配额
*
* @description
*
* @example GET /openstack/blcokstorage/limits
*
* @return {Object}
* - cores VCPU数量可用 颗
* - floatingIps 自定义IP可用 个
* - instances N/A
* - RAM 内存可用量 MB
* - securityGroups 实例数量 个
* - serverGroups 实例分组数量 个
*/
async limits() {
const { ctx, service } = this;
// if (!ctx.isAdmin()) return;
const DATAS = await this.SERVICE.limits(this.auth.id, ctx.isAdmin());
ctx.body = DATAS
}
}

module.exports = IndexController;
service
'use strict';
const ServerIndex = require('../index')
class ComputeIndexService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.actions = ':8774/v2.1/'
};
// 获取服务器相关配额
async limits(_ucid, isAdmin) {
try {
const DATAS = await this.OSAJax(`${this.actions}limits`, {
...!isAdmin && { _ucid }
});
const { maxImageMeta, maxPersonality, maxPersonalitySize, maxSecurityGroupRules, maxSecurityGroups, maxServerGroupMembers, maxServerGroups, maxServerMeta, maxTotalCores, maxTotalFloatingIps, maxTotalInstances, maxTotalKeypairs, maxTotalRAMSize, totalCoresUsed, totalFloatingIpsUsed, totalInstancesUsed, totalRAMUsed, totalSecurityGroupsUsed, totalServerGroupsUsed } = (await DATAS).limits.absolute
return {
data: {
maxTotalKeypairs,
'cores': maxTotalCores - totalCoresUsed,
'RAM': maxTotalRAMSize - totalRAMUsed,
maxTotalInstances,
totalInstancesUsed,
'instances': maxTotalInstances - totalInstancesUsed,
maxServerGroups,
'serverGroups': maxServerGroups - totalServerGroupsUsed,
}
}
} catch (error) {
return error
}
}
}

module.exports = ComputeIndexService;

?keypairs
?
控制器
'use strict';

const Controller = require('egg').Controller;

class OSKeypairController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.QPFn = ctx.helper.queryParamFn;
this.SERVICE = ctx.service.openstack.compute.keypair;
this.MODEL = ctx.model.Openstack.Servers.Keypair
}
/**
* @name 获取用户所有密钥对
*
* @example
* - GET /openstack/compute/keypairs
*/
async index() {
const ctx = this.ctx;
// const DATAS = await this.SERVICE.index(this.auth.id, this.QPFn(ctx.query));
// ctx.body = DATAS
const RESULT = await this.MODEL.getAll(this.auth.id, this.QPFn({ ...ctx.query
}));
ctx.body = RESULT
}
/**
* @name 创建密钥对
*
* @param {String} name 密钥对名称
*
* @example
* - POST application/x-www-form-urlencoded /openstack/compute/keypairs
*/
async create() {
const ctx = this.ctx;
const {
name,
public_key,
description
} = ctx.request.body;
const BODYS = this.DUFn({
name,
public_key,
description
});
// const DATAS = await this.SERVICE.create(this.auth.id, BODYS);
// ctx.body = DATAS
const RESULT = await this.MODEL.createOne(this.auth.id, BODYS);
ctx.body = RESULT
}
/**
* @name 获取指定密钥对信息
*
* @param {String} ctx.params.id 密钥对名称
*
* @example
* - GET /openstack/compute/keypairs/{ctx.params.id}
*/
async show() {
const ctx = this.ctx;
const DATAS = await this.MODEL.getOne(this.auth.id, ctx.params.id);
ctx.body = DATAS
}
/**
* @name 删除密钥对
*
* @param {String} ctx.params.id 密钥对名称
*
* @example
* - DELETE /openstack/compute/keypairs/{ctx.params.id}
*/
async destroy() {
const ctx = this.ctx;
const DATAS = await this.MODEL.deleteOne(this.auth.id, ctx.params.id);
ctx.body = DATAS
}
/**
* @name 绑定ECS
*
* @param {String} name 密钥对名称
* @param {String} type 'bind|unbind' 方式
* @param {String} _ECS_id 服务器id
*
*/
async setBindECS() {
const ctx = this.ctx;
const {
name,
type,
_ECS_id
} = ctx.request.body;
const BODYS = this.DUFn({
name,
type,
_ECS_id
})
const DATAS = await this.MODEL.setBindEcs(this.auth.id, BODYS);
ctx.body = DATAS
}
}

module.exports = OSKeypairController;service
'use strict';
const ServerIndex = require('../index')
class ComputeKeypairService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.actions = ':8774/v2.1/os-keypairs'
};
/**
* @name 列表
* @param {*} _ucid 用户id
*/
async index(_ucid, query) {
try {
const datas = await this.OSAJax(`${this.actions}`, {
_ucid,
body: { ...query.querys }
});
return {
data: {
'result': datas.keypairs,
'totalCount': datas.keypairs.length
},
}
} catch (error) {
return error
}
}
/**
* @name 获取
* @param {*} _ucid 用户id
* @param {*} keypair_name 密钥对名称
*/
async show(_ucid, keypair_name) {
try {
const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, { _ucid });
return {
data: datas.keypair
}
} catch (error) {
return error
}
}
/**
* @name 创建
* @param {*} _ucid 用户id
* @param {*} body 需要提交的参数
*/
async create(_ucid, body) {
try {
const datas = await this.OSAJax(`${this.actions}`, {
_ucid,
method: 'POST',
body: {
'keypair': {
...body,
}
}
});
return {
...!!datas.conflictingRequest ? { code: 422, message: `密钥对名称为：${body.name}的密钥对已存在` } : { data: datas }
}
} catch (error) {
return error
}
}
/**
* @name 删除
* @param {*} _ucid 用户id
* @param {*} keypair_name 密钥对名称
*/
async destroy(_ucid, keypair_name) {
try {
const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, {
_ucid,
method: 'DELETE',
full: true
});
return {
code: datas.status,
message: datas.status === 404 && `${keypair_name}不存在或已删除`
}
} catch (error) {

}
}
}

module.exports = ComputeKeypairService; 查看全部
配额
控制器
'use strict';



const Controller = require('egg').Controller;



class IndexController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.QPFn = ctx.helper.queryParamFn;

        this.SERVICE = ctx.service.openstack.compute.index;

        this.serverSERVICE = ctx.service.openstack.server.servers

    }

    /**

    * name 计算相关配额

    * 

    * @description 

    * 

    * @example  GET /openstack/blcokstorage/limits

    * 

    * @return {Object}

    *  - cores                VCPU数量可用                  颗

    *  - floatingIps          自定义IP可用                  个

    *  - instances            N/A                          

    *  - RAM                  内存可用量                    MB

    *  - securityGroups       实例数量                      个

    *  - serverGroups         实例分组数量                  个

    */

    async limits() {

        const { ctx, service } = this;

        // if (!ctx.isAdmin()) return;

        const DATAS = await this.SERVICE.limits(this.auth.id, ctx.isAdmin());

        ctx.body = DATAS

    }

}



module.exports = IndexController;
service
'use strict';

const ServerIndex = require('../index')

class ComputeIndexService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.actions = ':8774/v2.1/'

    };

    // 获取服务器相关配额

    async limits(_ucid, isAdmin) {

        try {

            const DATAS = await this.OSAJax(`${this.actions}limits`, {

                ...!isAdmin && { _ucid }

            });

            const { maxImageMeta, maxPersonality, maxPersonalitySize, maxSecurityGroupRules, maxSecurityGroups, maxServerGroupMembers, maxServerGroups, maxServerMeta, maxTotalCores, maxTotalFloatingIps, maxTotalInstances, maxTotalKeypairs, maxTotalRAMSize, totalCoresUsed, totalFloatingIpsUsed, totalInstancesUsed, totalRAMUsed, totalSecurityGroupsUsed, totalServerGroupsUsed } = (await DATAS).limits.absolute

            return {

                data: {

                    maxTotalKeypairs,

                    'cores': maxTotalCores - totalCoresUsed,

                    'RAM': maxTotalRAMSize - totalRAMUsed,

                    maxTotalInstances,

                    totalInstancesUsed,

                    'instances': maxTotalInstances - totalInstancesUsed,

                    maxServerGroups,

                    'serverGroups': maxServerGroups - totalServerGroupsUsed,

                }

            }

        } catch (error) {

            return error

        }

    }

}



module.exports = ComputeIndexService;

?keypairs
?
控制器
'use strict';



const Controller = require('egg').Controller;



class OSKeypairController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.QPFn = ctx.helper.queryParamFn;

        this.SERVICE = ctx.service.openstack.compute.keypair;

        this.MODEL = ctx.model.Openstack.Servers.Keypair

    }

    /**

     * @name  获取用户所有密钥对

     * 

     * @example  

     * - GET /openstack/compute/keypairs

     */

    async index() {

        const ctx = this.ctx;

        // const DATAS = await this.SERVICE.index(this.auth.id, this.QPFn(ctx.query));

        // ctx.body = DATAS

        const RESULT = await this.MODEL.getAll(this.auth.id, this.QPFn({ ...ctx.query

        }));

        ctx.body = RESULT

    }

    /**

     * @name  创建密钥对

     * 

     * @param {String}      name      密钥对名称

     * 

     * @example  

     * - POST  application/x-www-form-urlencoded /openstack/compute/keypairs 

     */

    async create() {

        const ctx = this.ctx;

        const {

            name,

            public_key,

            description

        } = ctx.request.body;

        const BODYS = this.DUFn({

            name,

            public_key,

            description

        });

        // const DATAS = await this.SERVICE.create(this.auth.id, BODYS);

        // ctx.body = DATAS

        const RESULT = await this.MODEL.createOne(this.auth.id, BODYS);

        ctx.body = RESULT

    }

    /**

     * @name 获取指定密钥对信息

     * 

     * @param {String}      ctx.params.id      密钥对名称

     * 

     * @example  

     * - GET /openstack/compute/keypairs/{ctx.params.id}

     */

    async show() {

        const ctx = this.ctx;

        const DATAS = await this.MODEL.getOne(this.auth.id, ctx.params.id);

        ctx.body = DATAS

    }

    /**

     * @name  删除密钥对

     * 

     * @param {String}      ctx.params.id      密钥对名称

     * 

     * @example  

     * - DELETE /openstack/compute/keypairs/{ctx.params.id}

     */

    async destroy() {

        const ctx = this.ctx;

        const DATAS = await this.MODEL.deleteOne(this.auth.id, ctx.params.id);

        ctx.body = DATAS

    }

    /**

     * @name 绑定ECS

     * 

     * @param {String} name                         密钥对名称

     * @param {String} type      'bind|unbind'      方式  

     * @param {String} _ECS_id                      服务器id

     * 

     */

    async setBindECS() {

        const ctx = this.ctx;

        const {

            name,

            type,

            _ECS_id

        } = ctx.request.body;

        const BODYS = this.DUFn({

            name,

            type,

            _ECS_id

        })

        const DATAS = await this.MODEL.setBindEcs(this.auth.id, BODYS);

        ctx.body = DATAS

    }

}



module.exports = OSKeypairController;
service
'use strict';

const ServerIndex = require('../index')

class ComputeKeypairService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.actions = ':8774/v2.1/os-keypairs'

    };

    /**

     * @name 列表

     * @param {*} _ucid         用户id

     */

    async index(_ucid, query) {

        try {

            const datas = await this.OSAJax(`${this.actions}`, {

                _ucid,

                body: { ...query.querys }

            });

            return {

                data: {

                    'result': datas.keypairs,

                    'totalCount': datas.keypairs.length

                },

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 获取

     * @param {*} _ucid            用户id

     * @param {*} keypair_name     密钥对名称

     */

    async show(_ucid, keypair_name) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, { _ucid });

            return {

                data: datas.keypair

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 创建

     * @param {*} _ucid          用户id

     * @param {*} body           需要提交的参数

     */

    async create(_ucid, body) {

        try {

            const datas = await this.OSAJax(`${this.actions}`, {

                _ucid,

                method: 'POST',

                body: {

                    'keypair': {

                        ...body,

                    }

                }

            });

            return {

                ...!!datas.conflictingRequest ? { code: 422, message: `密钥对名称为：${body.name}的密钥对已存在` } : { data: datas }

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 删除

     * @param {*} _ucid             用户id

     * @param {*} keypair_name      密钥对名称

     */

    async destroy(_ucid, keypair_name) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, {

                _ucid,

                method: 'DELETE',

                full: true

            });

            return {

                code: datas.status,

                message: datas.status === 404 && `${keypair_name}不存在或已删除`

            }

        } catch (error) {



        }

    }

}



module.exports = ComputeKeypairService;

egg.js+mongodb+openstack 公有云计费系统（三）OpenStack 对接 blcokStorage（2）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1380 次浏览 • 2019-03-15 11:27 • 来自相关话题

磁盘相关
控制器'use strict';

const Controller = require('egg').Controller;

class OPBlcokStorageVolumeController extends Controller {
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.QMFN = ctx.helper.queryParamFn;
this.DUFN = ctx.helper.deleteUndefined;
this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;
this.volumeSERVICE = ctx.service.openstack.blcokStorage.volume;
};
/**
* @name 磁盘列表
*
* @param {String} detail 不需要参数
*
* ----------------------------------- 分页 -------------------------------------
*
* @param {String} limit 分页>>条数/页
* @param {String} marker markerID(上页最后条id)
*
* ----------------------------------- 排序 -------------------------------------
*
* @param {String} sort_dir a|b 排序方式 ['asc':default,'desc']
* @param {String} sort_key 排序字段 [status,name,created_at]
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/blcokstorage/volume?{detail}
*
*/
async index() {
const { ctx } = this;
const RESULT = await this.volumeMODEL.getUsers(this.auth.id, this.QMFN({...ctx.query }));
ctx.body = RESULT;
};
/**
* @name 获取单一磁盘
*
* @description
*
* @example GET /openstack/blcokstorage/volume/{id}
*
*/
async show() {
const ctx = this.ctx;
// const datas = await this.volumeSERVICE.show(ctx.params.id, this.auth.id);
// ctx.body = datas;
const RESULT = await this.volumeMODEL.getOne(this.auth.id, ctx.params.id, ctx.isAdmin())
ctx.body = RESULT;
};
/**
* @name 创建磁盘
*
* @description
*
* @example POST /openstack/blcokstorage/volume
*
* @param {String} size 大小
* @param {String} availability_zone Optional 可用区域
* @param {String} snapshot_id Optional 快照ID FN从快照创建
* @param {String} backup_id Optional 备份ID FN从备份创建
* @param {String} imageRef Optional 镜像ID FN从镜像创建
* @param {String} volume_type Optional 磁盘类型 默认HDD
*
*/
async create() {
const { ctx } = this;
const { availability_zone, snapshot_id, backup_id, imageRef, size = 5, volume_type = "hdd" } = ctx.request.body;
const BODYS = this.DUFN({ availability_zone, snapshot_id, backup_id, imageRef, size, volume_type })
const datas = await this.volumeMODEL.createOne(this.auth.id, BODYS)
ctx.body = datas
};
/**
* @name 调整磁盘
*
* @description
*
* @example POST /openstack/blcokstorage/volume
*
* @param {String} size 大小
* @param {String} availability_zone Optional 可用区域
* @param {String} snapshot_id Optional 快照ID FN从快照创建
* @param {String} backup_id Optional 备份ID FN从备份创建
* @param {String} imageRef Optional 镜像ID FN从镜像创建
* @param {String} volume_type Optional 磁盘类型 默认HDD
*
*/
async update() {
const ctx = this.ctx;
const BODYS = ctx.request.body;
const { action, name } = BODYS;
delete BODYS.action;
const datas = !!action ? await this.volumeSERVICE.action(this.auth.id, this.auth.ProjectID, ctx.params.id, action, BODYS) : await this.serverSERVICE.update(ctx.params.id, this.auth.id, this.DUFn({ name }));
ctx.body = datas
};
/**
* @name 删除磁盘
*
* @description
*
*/
async destroy() {
const ctx = this.ctx;
const DATAS = await this.volumeSERVICE.destroy(this.auth.id, this.auth.ProjectID, ctx.params.id);
ctx.body = DATAS
}

}

module.exports = OPBlcokStorageVolumeController;modelmodule.exports = app => {
const mongoose = app.mongoose;
const Schema = mongoose.Schema;
const ctx = app.createAnonymousContext();
const {
helper,
service
} = app.createAnonymousContext();
const {
NumToStr
} = ctx.helper;
const OSblockStorageVolumeSchema = new Schema({
// 配置
config: {},
// 公司id
_comp: {
type: Schema.Types.ObjectId,
ref: 'Company',
required: true,
index: true
},
// 支付方式
payment: {
type: String,
default: 'prepay'
},
// 到期时间
endTime: {
type: Date
},
// 后台备注描述
_description: {

},
// 源信息
_metadata: {
type: String,
index: true
},
/*---------------------------------------------------*/
"status": {
type: 'String',
default: 'creating'
},
"migration_status": {},
"user_id": {},
"attachments": ,
"availability_zone": {},
"bootable": {},
"encrypted": {},
"created_at": {},
"description": {},
"updated_at": {},
"volume_type": {},
"name": {},
"replication_status": {},
"consistencygroup_id": {},
"source_volid": {},
"imageRef": {},
"backup_id": {},
"snapshot_id": {},
"multiattach": {},
"metadata": {},
"id": {
type: String,
index: true
},
"size": {},
"os-vol-host-attr:host": {},
"os-vol-tenant-attr:tenant_id": {}
}, {
timestamps: {
createdAt: 'created',
updatedAt: 'updated'
}
});
OSblockStorageVolumeSchema.statics = {
getUsers: async function(_comp, queryMix) {
const serverSERVICE = ctx.service.openstack.server.servers;
const {
querys,
select,
sort,
limit,
marker
} = queryMix;
const withDetail = querys.detail === '' || querys.detail;
delete querys.detail;
let QUERTS = {};
for (const key in querys) {
QUERTS[key] = eval(`/${querys[key]}.*/i`)
}
const MODELS = (count = false) => this.find({
_comp,
...QUERTS,
...(marker && !count && {
'_id': {
"$lt": marker
}
}),
}, {
...select,
}, {
...!count && {
limit
},
'sort': {
_id: -1,
...sort
}
});
try {
const datas = await MODELS()
return {
data: {
result: datas,
limit,
marker: datas.length ? [...datas].pop()._id : '',
totalCount: await MODELS(true).count()
}
}
} catch (error) {
return error
}
},
/**
* @name 创建硬盘
* @param {*} _id
* @param {*} body
*/
createOne: async function(_id, bodys) {
try {
const {
endTime,
payment,
_metadata
} = bodys;
delete bodys._metadata;
delete bodys.endTime;
delete bodys.payment;
//
const DATAS = await service.openstack.blcokStorage.volume.create(_id, {
...bodys,
... {
"name": `volume-${Math.random().toString(36).slice(2, 8)}`
}
});
const {
id: _openstack_id
} = DATAS.data.volume;
!!DATAS.data.volume && await ctx.model.Schedule.Openstack.Volume.addOne({
_comp: _id,
_openstack_id,
type: 'volume',
active: 'creating',
_metadata
})
return !!DATAS.data.volume ? {
data: await this.create({
_comp: _id,
endTime,
payment,
_metadata,
...DATAS.data.volume
})
} : {
'code': 422,
'message': '创建失败'
};
} catch (error) {
return error
}
},
// 获取全部
getAll: async function(queryMix) {
const {
querys,
select,
pages,
sort,
dates
} = queryMix;
const MODELS = this.find({
'status': {
'$ne': 0
},
...querys,
// ...(!!pages && !!pages.marker && { '_id': { "$lt": pages.marker } }),
}, {
...select,
})
// .limit(!!pages ? pages.limit : 10)
.sort({
// '_id': -1,
'id': 1,
...sort
});
return {
data: {
result: await MODELS,
totalCount: await MODELS.count()
}
};
},
// 查看单个
getOne: async function(_comp, id, isAdmin) {
const MODELS = this.findOne({...isAdmin ? {
id
} : {
_comp,
id
}
});
try {
const RESULT = await MODELS;
return {
data: RESULT
}
} catch (error) {
return error
}
},
// 绑定到磁盘
/**
* @name 绑定到磁盘
* @param {*} _comp 用户UUID
* @param {*} id 磁盘ID
* @param {*} type 'bind'|'unbind' 绑定方式
*/
bindToECS: async function({
_comp,
id,
type = "bind"
} = {}, bodys) {
const MODEL = this.findOneAndUpdate({
_comp,
id
}, {
'attachments': type === 'bind' ? [bodys] : ,
'status': type === 'bind' ? 'in-use' : 'available'
});
try {
const datas = await MODEL;
} catch (error) {
return error
}
}
}
return mongoose.model('openstack_block_storage_volume', OSblockStorageVolumeSchema)
}service'use strict';
const ServerIndex = require('../index')
//
class VolumeService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.adminprojectID = this.config.openstack.projectID.default;
this.actions = ':8776/v3';
};
// 获取磁盘列表
async list(querys, _ucid, project_id, isAdmin) {
try {
const detail = Object.keys(querys).includes('detail');
delete querys.detail;
let SORT = {}
if (querys.sort_key) {
SORT = { 'sort': `${querys.sort_key}:${querys.sort_dir}` };
delete querys.sort_key;
delete querys.sort_dir;
}
const datas = await this.OSAJax(`${this.actions}/${!!isAdmin ? this.adminprojectID : project_id}/volumes${detail ? '/detail' : ''}`, {
...!isAdmin && { _ucid },
body: {
...querys,
...querys.sort_key && SORT,
...isAdmin && { 'all_tenants': true },
},
});
return {
data: {
result: datas.volumes.map(e => {
!!detail && e.attachments.length && (e.attachment = e.attachments[0].server_id)
delete e.links;
delete e.attachments;
return e
}).filter(e => e.status != 'deleting'),
totalCount: datas.volumes.length
}
};
} catch (error) {
return error
}
}
// 获取磁盘详情
async show(id, _ucid, _description) {
try {
const datas = await this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes/${id}`, {
..._ucid !== 'admin' && { _ucid }
});
return _ucid === 'admin' ? { ...datas.volume, _description } : { data: datas.volume };
} catch (error) {
return error
}
}
// 创建磁盘
async create(_ucid, bodys, order = "false") {
const DATAS = this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes`, {
body: {
'volume': {
... {
"availability_zone": null,
"source_volid": null,
"description": null,
"multiattach": false,
"snapshot_id": null,
"backup_id": null,
"imageRef": null,
"metadata": {},
"consistencygroup_id": null
},
...bodys
}
},
method: 'POST',
_ucid
});
try {
const datas = await DATAS
return !!order ? { data: datas } : datas
} catch (error) {
return error
}

}
// 删除磁盘
async destroy(_ucid, project_id, volume_id) {
try {
const datas = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {
_ucid,
method: 'DELETE',
full: true
});
return {
...datas.status === 404 && {
message: `${volume_id}不存在或已删除`
}
}
} catch (error) {

}
}
// 磁盘操作
// {'os-extend':'磁盘扩容','revert':'镜像回滚'}
async action(_ucid, project_id, volume_id, type, bodys) {
const isIn = (e) => ['os-extend', 'revert'].includes(e);
if (!isIn(type)) return { code: 422 };
const actionMAP = (e) => {
const OBJ = {};
OBJ[e] = !bodys ? null : bodys;
return OBJ;
}
try {
const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}/action`, {
body: actionMAP(type),
method: 'POST',
_ucid, full: true
});
return {
code: DATAS.status
}
} catch (error) {
return error
}
}
async update(_ucid, project_id, volume_id, bodys) {
try {
const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {
_ucid,
bodys: {
...bodys
},
method: 'PUT'
});
return {
data: DATAS
}
} catch (error) {
return error
}
}
}
module.exports = VolumeService;
scheduleconst Subscription = require('egg').Subscription;

class getVolumeStatus extends Subscription {
constructor(ctx) {
super(ctx);
this.SERVICE = ctx.service.openstack.blcokStorage.volume;
this.MODELS = ctx.model.Schedule.Openstack.Volume;
this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;
}
static get schedule() {
return {
interval: '10s',
type: 'worker',
};
}
async subscribe() {
const ctx = this.ctx;
const lists = await this.MODELS.getALL();
if (lists.length) {
const datas = await this.checkItem(lists);
}
}
async checkItem(result) {
// 调取记录
const checkFN = result.map(e => {
// 记录尝试次数
this.MODELS.retry(e._openstack_id)
return this.SERVICE.show(e._openstack_id, 'admin', e);
})
let DATAS = await Promise.all(checkFN);
// 检查ACTION
if (!!DATAS.length) {
const endOrder = DATAS.map(e => {
const { _comp, _openstack_id: id } = e._description;
delete e._description
delete e.links
if (e.status === 'available' || e.status === 'in-use') {
return this.volumeMODEL.findOneAndUpdate({ id }, { ...e });
}
})
DATAS = await Promise.all(endOrder);
};
// 清除已完成任务
if (DATAS.length) {
const clearSchedule = DATAS.map(e => {
if (!!e) {
const { id: _openstack_id } = e;
return this.MODELS.deleteOne({ '_openstack_id': _openstack_id })
}
})
DATAS = await Promise.all(clearSchedule);
}
}
}

module.exports = getVolumeStatus;
schedule model
module.exports = app => {
const mongoose = app.mongoose;
const Schema = mongoose.Schema;
const ctx = app.createAnonymousContext();
const scheduleOSVolumeSchema = new Schema({
// 类型
type: {
type: String,
},
// 尝试次数
retry: {
type: Number,
dafault: 0
},
// 是否创建成功
status: {
type: Boolean,
default: false
},
// 操作方式 [BUILD:创建,DELETE:删除]
active: {
type: String,
},
// 数据ID
_openstack_id: {
type: String,
index: true
},
// 公司ID
_comp: {
type: String
},
// 其他配置参数
/**
* ecs：Number
*/
_description: {

},
// 其他配置元信息
_metadata: {

}
}, {
timestamps: {
createdAt: 'created',
updatedAt: 'updated'
}
});
scheduleOSVolumeSchema.statics = {
getALL: async function (limit = 50) {
const MODEL = this.find().limit(limit);
try {
return await MODEL;
} catch (error) {
return error
}
},
addOne: async function (bodys) {
const MODEL = this.create({ ...bodys });
try {
const result = await MODEL;
return { code: !!result ? 201 : 404 }
} catch (error) {
return error
}
},
// destroyOne: async function (id) {
// const MODEL = this.deleteOne(id);
// try {
// const result = await MODEL
// return result
// } catch (error) {
// return error
// }
// },
retry: async function (_openstack_id) {
const MODEL = this.findOneAndUpdate({ _openstack_id }, {
'$inc': { retry: 1 }
});
try {
await MODEL
} catch (error) {
return error
}
}
}
return mongoose.model('schedule_openstack_volume', scheduleOSVolumeSchema);
} 查看全部
磁盘相关
控制器
'use strict';



const Controller = require('egg').Controller;



class OPBlcokStorageVolumeController extends Controller {

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.QMFN = ctx.helper.queryParamFn;

        this.DUFN = ctx.helper.deleteUndefined;

        this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;

        this.volumeSERVICE = ctx.service.openstack.blcokStorage.volume;

    };

    /**

     * @name  磁盘列表

     * 

     * @param {String}      detail      不需要参数

     * 

     * -----------------------------------    分页    -------------------------------------

     * 

     * @param {String}      limit                     分页>>条数/页

     * @param {String}      marker                    markerID(上页最后条id)

     * 

     * -----------------------------------    排序    -------------------------------------

     * 

     * @param {String}      sort_dir          a|b     排序方式 ['asc':default,'desc']

     * @param {String}      sort_key                  排序字段 [status,name,created_at]

     * 

     * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

     * 

     * @example  GET /openstack/blcokstorage/volume?{detail}

     * 

     */

    async index() {

        const { ctx } = this;

        const RESULT = await this.volumeMODEL.getUsers(this.auth.id, this.QMFN({...ctx.query }));

        ctx.body = RESULT;

    };

    /**

     * @name  获取单一磁盘

     * 

     * @description 

     * 

     * @example  GET /openstack/blcokstorage/volume/{id}

     * 

     */

    async show() {

        const ctx = this.ctx;

        // const datas = await this.volumeSERVICE.show(ctx.params.id, this.auth.id);

        // ctx.body = datas;

        const RESULT = await this.volumeMODEL.getOne(this.auth.id, ctx.params.id, ctx.isAdmin())

        ctx.body = RESULT;

    };

    /**

     * @name  创建磁盘

     * 

     * @description 

     * 

     * @example  POST /openstack/blcokstorage/volume

     * 

     * @param {String} size                               大小

     * @param {String} availability_zone     Optional     可用区域

     * @param {String} snapshot_id           Optional     快照ID         FN从快照创建

     * @param {String} backup_id             Optional     备份ID         FN从备份创建

     * @param {String} imageRef              Optional     镜像ID         FN从镜像创建

     * @param {String} volume_type           Optional     磁盘类型       默认HDD

     * 

     */

    async create() {

        const { ctx } = this;

        const { availability_zone, snapshot_id, backup_id, imageRef, size = 5, volume_type = "hdd" } = ctx.request.body;

        const BODYS = this.DUFN({ availability_zone, snapshot_id, backup_id, imageRef, size, volume_type })

        const datas = await this.volumeMODEL.createOne(this.auth.id, BODYS)

        ctx.body = datas

    };

    /**

     * @name  调整磁盘

     * 

     * @description 

     * 

     * @example  POST /openstack/blcokstorage/volume

     * 

     * @param {String} size                               大小

     * @param {String} availability_zone     Optional     可用区域

     * @param {String} snapshot_id           Optional     快照ID         FN从快照创建

     * @param {String} backup_id             Optional     备份ID         FN从备份创建

     * @param {String} imageRef              Optional     镜像ID         FN从镜像创建

     * @param {String} volume_type           Optional     磁盘类型       默认HDD

     * 

     */

    async update() {

        const ctx = this.ctx;

        const BODYS = ctx.request.body;

        const { action, name } = BODYS;

        delete BODYS.action;

        const datas = !!action ? await this.volumeSERVICE.action(this.auth.id, this.auth.ProjectID, ctx.params.id, action, BODYS) : await this.serverSERVICE.update(ctx.params.id, this.auth.id, this.DUFn({ name }));

        ctx.body = datas

    };

    /**

     * @name 删除磁盘

     * 

     * @description

     * 

     */

    async destroy() {

        const ctx = this.ctx;

        const DATAS = await this.volumeSERVICE.destroy(this.auth.id, this.auth.ProjectID, ctx.params.id);

        ctx.body = DATAS

    }



}



module.exports = OPBlcokStorageVolumeController;
model
module.exports = app => {

    const mongoose = app.mongoose;

    const Schema = mongoose.Schema;

    const ctx = app.createAnonymousContext();

    const {

        helper,

        service

    } = app.createAnonymousContext();

    const {

        NumToStr

    } = ctx.helper;

    const OSblockStorageVolumeSchema = new Schema({

        // 配置

        config: {},

        // 公司id

        _comp: {

            type: Schema.Types.ObjectId,

            ref: 'Company',

            required: true,

            index: true

        },

        // 支付方式

        payment: {

            type: String,

            default: 'prepay'

        },

        // 到期时间

        endTime: {

            type: Date

        },

        // 后台备注描述

        _description: {



        },

        // 源信息

        _metadata: {

            type: String,

            index: true

        },

        /*---------------------------------------------------*/

        "status": {

            type: 'String',

            default: 'creating'

        },

        "migration_status": {},

        "user_id": {},

        "attachments": ,

        "availability_zone": {},

        "bootable": {},

        "encrypted": {},

        "created_at": {},

        "description": {},

        "updated_at": {},

        "volume_type": {},

        "name": {},

        "replication_status": {},

        "consistencygroup_id": {},

        "source_volid": {},

        "imageRef": {},

        "backup_id": {},

        "snapshot_id": {},

        "multiattach": {},

        "metadata": {},

        "id": {

            type: String,

            index: true

        },

        "size": {},

        "os-vol-host-attr:host": {},

        "os-vol-tenant-attr:tenant_id": {}

    }, {

        timestamps: {

            createdAt: 'created',

            updatedAt: 'updated'

        }

    });

    OSblockStorageVolumeSchema.statics = {

        getUsers: async function(_comp, queryMix) {

            const serverSERVICE = ctx.service.openstack.server.servers;

            const {

                querys,

                select,

                sort,

                limit,

                marker

            } = queryMix;

            const withDetail = querys.detail === '' || querys.detail;

            delete querys.detail;

            let QUERTS = {};

            for (const key in querys) {

                QUERTS[key] = eval(`/${querys[key]}.*/i`)

            }

            const MODELS = (count = false) => this.find({

                _comp,

                ...QUERTS,

                ...(marker && !count && {

                    '_id': {

                        "$lt": marker

                    }

                }),

            }, {

                ...select,

            }, {

                ...!count && {

                    limit

                },

                'sort': {

                    _id: -1,

                    ...sort

                }

            });

            try {

                const datas = await MODELS()

                return {

                    data: {

                        result: datas,

                        limit,

                        marker: datas.length ? [...datas].pop()._id : '',

                        totalCount: await MODELS(true).count()

                    }

                }

            } catch (error) {

                return error

            }

        },

        /**

         * @name 创建硬盘

         * @param {*} _id 

         * @param {*} body 

         */

        createOne: async function(_id, bodys) {

            try {

                const {

                    endTime,

                    payment,

                    _metadata

                } = bodys;

                delete bodys._metadata;

                delete bodys.endTime;

                delete bodys.payment;

                // 

                const DATAS = await service.openstack.blcokStorage.volume.create(_id, {

                    ...bodys,

                    ... {

                        "name": `volume-${Math.random().toString(36).slice(2, 8)}`

                    }

                });

                const {

                    id: _openstack_id

                } = DATAS.data.volume;

                !!DATAS.data.volume && await ctx.model.Schedule.Openstack.Volume.addOne({

                    _comp: _id,

                    _openstack_id,

                    type: 'volume',

                    active: 'creating',

                    _metadata

                })

                return !!DATAS.data.volume ? {

                    data: await this.create({

                        _comp: _id,

                        endTime,

                        payment,

                        _metadata,

                        ...DATAS.data.volume

                    })

                } : {

                    'code': 422,

                    'message': '创建失败'

                };

            } catch (error) {

                return error

            }

        },

        // 获取全部

        getAll: async function(queryMix) {

            const {

                querys,

                select,

                pages,

                sort,

                dates

            } = queryMix;

            const MODELS = this.find({

                    'status': {

                        '$ne': 0

                    },

                    ...querys,

                    // ...(!!pages && !!pages.marker && { '_id': { "$lt": pages.marker } }),

                }, {

                    ...select,

                })

                // .limit(!!pages ? pages.limit : 10)

                .sort({

                    // '_id': -1,

                    'id': 1,

                    ...sort

                });

            return {

                data: {

                    result: await MODELS,

                    totalCount: await MODELS.count()

                }

            };

        },

        // 查看单个

        getOne: async function(_comp, id, isAdmin) {

            const MODELS = this.findOne({...isAdmin ? {

                    id

                } : {

                    _comp,

                    id

                }

            });

            try {

                const RESULT = await MODELS;

                return {

                    data: RESULT

                }

            } catch (error) {

                return error

            }

        },

        // 绑定到磁盘

        /**

         * @name  绑定到磁盘

         * @param {*} _comp                                      用户UUID

         * @param {*} id                                         磁盘ID

         * @param {*} type              'bind'|'unbind'          绑定方式  

         */

        bindToECS: async function({

            _comp,

            id,

            type = "bind"

        } = {}, bodys) {

            const MODEL = this.findOneAndUpdate({

                _comp,

                id

            }, {

                'attachments': type === 'bind' ? [bodys] : ,

                'status': type === 'bind' ? 'in-use' : 'available'

            });

            try {

                const datas = await MODEL;

            } catch (error) {

                return error

            }

        }

    }

    return mongoose.model('openstack_block_storage_volume', OSblockStorageVolumeSchema)

}
service
'use strict';

const ServerIndex = require('../index')

//

class VolumeService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.adminprojectID = this.config.openstack.projectID.default;

        this.actions = ':8776/v3';

    };

    // 获取磁盘列表

    async list(querys, _ucid, project_id, isAdmin) {

        try {

            const detail = Object.keys(querys).includes('detail');

            delete querys.detail;

            let SORT = {}

            if (querys.sort_key) {

                SORT = { 'sort': `${querys.sort_key}:${querys.sort_dir}` };

                delete querys.sort_key;

                delete querys.sort_dir;

            }

            const datas = await this.OSAJax(`${this.actions}/${!!isAdmin ? this.adminprojectID : project_id}/volumes${detail ? '/detail' : ''}`, {

                ...!isAdmin && { _ucid },

                body: {

                    ...querys,

                    ...querys.sort_key && SORT,

                    ...isAdmin && { 'all_tenants': true },

                },

            });

            return {

                data: {

                    result: datas.volumes.map(e => {

                        !!detail && e.attachments.length && (e.attachment = e.attachments[0].server_id)

                        delete e.links;

                        delete e.attachments;

                        return e

                    }).filter(e => e.status != 'deleting'),

                    totalCount: datas.volumes.length

                }

            };

        } catch (error) {

            return error

        }

    }

    // 获取磁盘详情

    async show(id, _ucid, _description) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes/${id}`, {

                ..._ucid !== 'admin' && { _ucid }

            });

            return _ucid === 'admin' ? { ...datas.volume, _description } : { data: datas.volume };

        } catch (error) {

            return error

        }

    }

    // 创建磁盘

    async create(_ucid, bodys, order = "false") {

        const DATAS = this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes`, {

            body: {

                'volume': {

                    ... {

                        "availability_zone": null,

                        "source_volid": null,

                        "description": null,

                        "multiattach": false,

                        "snapshot_id": null,

                        "backup_id": null,

                        "imageRef": null,

                        "metadata": {},

                        "consistencygroup_id": null

                    },

                    ...bodys

                }

            },

            method: 'POST',

            _ucid

        });

        try {

            const datas = await DATAS

            return !!order ? { data: datas } : datas

        } catch (error) {

            return error

        }



    }

    // 删除磁盘

    async destroy(_ucid, project_id, volume_id) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {

                _ucid,

                method: 'DELETE',

                full: true

            });

            return {

                ...datas.status === 404 && {

                    message: `${volume_id}不存在或已删除`

                }

            }

        } catch (error) {



        }

    }

    // 磁盘操作

    // {'os-extend':'磁盘扩容','revert':'镜像回滚'}

    async action(_ucid, project_id, volume_id, type, bodys) {

        const isIn = (e) => ['os-extend', 'revert'].includes(e);

        if (!isIn(type)) return { code: 422 };

        const actionMAP = (e) => {

            const OBJ = {};

            OBJ[e] = !bodys ? null : bodys;

            return OBJ;

        }

        try {

            const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}/action`, {

                body: actionMAP(type),

                method: 'POST',

                _ucid, full: true

            });

            return {

                code: DATAS.status

            }

        } catch (error) {

            return error

        }

    }

    async update(_ucid, project_id, volume_id, bodys) {

        try {

            const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {

                _ucid,

                bodys: {

                    ...bodys

                },

                method: 'PUT'

            });

            return {

                data: DATAS

            }

        } catch (error) {

            return error

        }

    }

}

module.exports = VolumeService;

schedule
const Subscription = require('egg').Subscription;



class getVolumeStatus extends Subscription {

    constructor(ctx) {

        super(ctx);

        this.SERVICE = ctx.service.openstack.blcokStorage.volume;

        this.MODELS = ctx.model.Schedule.Openstack.Volume;

        this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;

    }

    static get schedule() {

        return {

            interval: '10s',

            type: 'worker',

        };

    }

    async subscribe() {

        const ctx = this.ctx;

        const lists = await this.MODELS.getALL();

        if (lists.length) {

            const datas = await this.checkItem(lists);

        }

    }

    async checkItem(result) {

        // 调取记录

        const checkFN = result.map(e => {

            // 记录尝试次数

            this.MODELS.retry(e._openstack_id)

            return this.SERVICE.show(e._openstack_id, 'admin', e);

        })

        let DATAS = await Promise.all(checkFN);

        // 检查ACTION

        if (!!DATAS.length) {

            const endOrder = DATAS.map(e => {

                const { _comp, _openstack_id: id } = e._description;

                delete e._description

                delete e.links

                if (e.status === 'available' || e.status === 'in-use') {

                    return this.volumeMODEL.findOneAndUpdate({ id }, { ...e });

                }

            })

            DATAS = await Promise.all(endOrder);

        };

        // 清除已完成任务

        if (DATAS.length) {

            const clearSchedule = DATAS.map(e => {

                if (!!e) {

                    const { id: _openstack_id } = e;

                    return this.MODELS.deleteOne({ '_openstack_id': _openstack_id })

                }

            })

            DATAS = await Promise.all(clearSchedule);

        }

    }

}



module.exports = getVolumeStatus;

schedule model
module.exports = app => {

    const mongoose = app.mongoose;

    const Schema = mongoose.Schema;

    const ctx = app.createAnonymousContext();

    const scheduleOSVolumeSchema = new Schema({

        // 类型

        type: {

            type: String,

        },

        // 尝试次数

        retry: {

            type: Number,

            dafault: 0

        },

        // 是否创建成功

        status: {

            type: Boolean,

            default: false

        },

        // 操作方式 [BUILD:创建,DELETE:删除]

        active: {

            type: String,

        },

        // 数据ID

        _openstack_id: {

            type: String,

            index: true

        },

        // 公司ID

        _comp: {

            type: String

        },

        // 其他配置参数

        /**

         * ecs：Number

         */

        _description: {



        },

        // 其他配置元信息

        _metadata: {



        }

    }, {

            timestamps: {

                createdAt: 'created',

                updatedAt: 'updated'

            }

        });

    scheduleOSVolumeSchema.statics = {

        getALL: async function (limit = 50) {

            const MODEL = this.find().limit(limit);

            try {

                return await MODEL;

            } catch (error) {

                return error

            }

        },

        addOne: async function (bodys) {

            const MODEL = this.create({ ...bodys });

            try {

                const result = await MODEL;

                return { code: !!result ? 201 : 404 }

            } catch (error) {

                return error

            }

        },

        // destroyOne: async function (id) {

        //     const MODEL = this.deleteOne(id);

        //     try {

        //         const result = await MODEL

        //         return result

        //     } catch (error) {

        //         return error

        //     }

        // },

        retry: async function (_openstack_id) {

            const MODEL = this.findOneAndUpdate({ _openstack_id }, {

                '$inc': { retry: 1 }

            });

            try {

                await MODEL

            } catch (error) {

                return error

            }

        }

    }

    return mongoose.model('schedule_openstack_volume', scheduleOSVolumeSchema);

}

egg.js+mongodb+openstack 公有云计费系统（三）用户系统的搭建 （2）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1503 次浏览 • 2019-03-15 11:08 • 来自相关话题

A/SK 机制
?
控制器
?
/*************************************************************
*
*- Copyright (c) qiduo, 2018
*- FileName: AccesskeyController.js 安全认证 Accesskey接口
*- Author: 罗波 lopo1983@vip.qq.com
*- Version: 1.0
*- Date:2018-10-15
*- Descripttion:openstack geecp
*- Modules:
*
*- Extends
* - 1.egg_Controller
*----------------------------------------------------------
*
*- Function List ：
*
*- StaticsList :
* - show 获取所有ak/sk
* - update 创建ak/sk 修改备注
* - destroy 删除ak/sk
*
*- History :
* <Author> <Date> <Desc>
*
**************************************************************/
'use strict';

const Controller = require('egg').Controller;

class AccesskeyController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Model} MODEL 公司表
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Account.Company;
}
/**
*
* @name 获取Accesskey列表
*
* @example
* - GET /user/accesskey/_id{ObjectId} HTTP/1.1
*
*/
async show() {
const ctx = this.ctx;
const result = await this.MODEL.getASK({ '_id': ctx.params.id });
ctx.body = result
}
/**
*
* @name 创建AK/SK|修改Info
*
* @param {String} info 必填 备注内容
* @param {ObjectId} id 必填 A/SK{ObjectId}
*
* @example
* - PUT /user/accesskey/user{ObjectId} HTTP/1.1 创建
* - PUT /user/accesskey/user{ObjectId} HTTP/1.1 修改
* body:{
* id:ak/sk{ObjectId}
* info:备注名称
* }
*
* @description info id 为必填参数
*
*/
async update() {
const ctx = this.ctx;
if (!!ctx.request.body.info) {
ctx.body = await this.MODEL.setInfo(ctx);
}
else {
ctx.body = await this.MODEL.createASK(ctx);
}
}
/**
*
* @name 删除AK/SK
*
* @param {ObjectId} id 必填 A/SK id
*
* @example
* PUT /user/accesskey/id{ObjectId} HTTP/1.1
* @description id 为必填参数
*
*/
async destroy() {
const ctx = this.ctx;
ctx.body = await this.MODEL.delASK(ctx);
}
/**
*
* @name ak/sk鉴权接口
*
* @param {ObjectId} uid 必填 用户uid
* @param {String} api_key 必填 accountKey
* @param {String} secret_key 必填 secretKey
*
* @example
* POST /user/authorization HTTP/1.1
*
* @description uid|api_key|secret_key 必填
*
*/
async authorization() {
const ctx = this.ctx;
const { uid, api_key, secret_key } = ctx.request.body;
ctx.body = await this.MODEL.apiToken({ uid, api_key, secret_key });
}
}

module.exports = AccesskeyController;

用户鉴权
控制器
'use strict';
const Controller = require('egg').Controller;
class ServiceJwtController extends Controller {
constructor(ctx) {
super(ctx);
this.MODELComp = ctx.model.Account.Company;
this.MODELAdmin = ctx.model.Account.Admin;
};
/**
* @name 用户token生成
*
* @param {action:string} 'api' 用于鉴权ak/sk生成token
* @param {String} compEmail 用户邮箱
* @param {String} compPhone 用户手机
* @param {String} compPassword 用户密码
*
* @description
*
* @example POST /user/sign/
*
* @return Object
*{
* "token": "",
* "info": {
* "_id": "5bcdd5e7f12ee030f44b6228",
* "compPhone": "13658157663",
* "compEmail": "64832897@qq.com",
* "compAuth": {
* "email": false,
* "phone": true
* },
* "compService": [],
* "updated": "2018-10-22T13:51:35.314Z",
* "compApi": []
* }
* }
*
**/
async sign() {
const ctx = this.ctx;
const {
body,
header
} = ctx.request;
try {
if (ctx.request.url.includes('admin')) {
ctx.body = await this.MODELAdmin.isLogin(ctx);
} else {
if (!['compEmail', 'compPhone'].map(e => Object.keys(body).includes(e)).reduce((a, b) => a + b)) {
ctx.body = {
code: 422,
message: '用户参数错误'
};
return
};
ctx.body = await this.MODELComp.isLogin(ctx);
}
} catch (error) {
console.log(error)
if (error.message === 'jwt expired') {
ctx.body = {
message: '用户鉴权失败,请重新登陆',
code: 401
}
} else {
ctx.body = {
message: !!error.errors ? `${error.errors.reduce((a, error) => { a.push(`${error.field} ${error.message}`); return a }, [])}` : error.message,
code: 422
}
}
}
}
}
module.exports = ServiceJwtControllerextend 扩展
简单用户划分
module.exports = {
isAdmin() {
console.log(this.url)
return this.state.user.group === 1 ? false : true;
},
};OpenStack 相关控制器
project
'use strict';

const Controller = require('egg').Controller;

class OPIdentityProjectsController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
}
/**
* @name project列表
*
* @param {String} ctx.query 不需要参数
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/projects
*
*/
async index() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.list(ctx.query);
ctx.body = datas;
}
/**
* @name 获取单一project信息
*
* @param {String} ctx.params.id 实例id
*
* @example GET /openstack/projects/{ctx.params.id}
*
*/
async show() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.show(ctx.params.id);
ctx.body = datas;
}
/**
* @name 创建project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - POST /openstack/projects/
*/
async create() {
const { ctx, service } = this;
const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;
const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };
const datas = await service.openstack.identity.projects.create(this.DUFn(bodys))
ctx.body = datas;
}
/**
* @name 更新project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - DELETE /openstack/projects/{ctx.params.id}
*/
async destroy() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.destroy(ctx.params.id);
ctx.body = datas;
}
/**
* @name 删除project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - PATCH /openstack/projects/{ctx.params.id}
*/
async update() {
const { ctx, service } = this;
const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;
const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };
const datas = await service.openstack.identity.projects.update(ctx.params.id, this.DUFn(bodys))
ctx.body = datas;
}
/**
* @name 锁定不可操作项目
*
*/
checkID(idx) {
const ARR = ['c3513f27bbf24362b74d13e6afae2c37', '5d3b50c18fd44db4bc6abfdbbfcf6a3a', '5c7e341df8ff493c8ae7baf57c0129dd'];
return ARR.includes(idx);
}
}

module.exports = OPIdentityProjectsController;
region
'use strict';

const Controller = require('egg').Controller;

class identityUserRegionController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Openstack.Identity.Region
this.TKMODEL = ctx.model.Openstack.Token
};
/**
*
* @name 用户列表
*
* @description
*
* @example GET /openstack/identity/region
*
*/
async index() {
const { ctx, service } = this;
const datas = await this.MODEL.getAll(this.auth.id, ctx.isAdmin());
ctx.body = datas;
}
}

module.exports = identityUserRegionController;user
'use strict';

const Controller = require('egg').Controller;

class identityUserController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Openstack.Identity.User
this.TKMODEL = ctx.model.Openstack.Token
};
/**
*
* @name 用户列表
*
* @param {String} ctx.query.detail 不需要参数
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/user
*
*/
async index() {
const { ctx, service } = this;
ctx.body = await service.openstack.identity.users.list(ctx.query);
};
/**
* @name 获取单一用户信息
*
* @param {String} ctx.params.id 实例id
*
* @example GET /openstack/user/{ctx.params.id}
*
*/
async show() {
const { ctx, service } = this;
ctx.body = await service.openstack.identity.users.show(ctx.params.id);
// const result = await this.MODEL.getOne(this.auth.id);
// ctx.body = result;
};
/**
* @name 创建用户
*
* @param {String} ctx.params.id 实例id
*
* @example
* - POST /openstack/user/
*/
async create() {
const ctx = this.ctx;
const result = await this.MODEL.createUser(this.auth.id)
ctx.body = result;
// const { ctx, service } = this;
// const { default_project_id, domain_id, description, enabled = true, email, name, password } = ctx.request.body;
// const bodys = { default_project_id, domain_id, description, enabled, email, name, password };
// ctx.body = await service.openstack.identity.users.create(this.DUFn(bodys));
};
/**
*
* @name 测试内部用token
*
*/
async testToken() {
const { ctx, service } = this;
ctx.body = await this.TKMODEL.getToken(this.auth.id)
};
}

module.exports = identityUserController; 查看全部
A/SK 机制
?
控制器
?
/*************************************************************

 * 

 *- Copyright (c) qiduo, 2018

 *- FileName: AccesskeyController.js 安全认证 Accesskey接口

 *- Author: 罗波 lopo1983@vip.qq.com 

 *- Version: 1.0   

 *- Date:2018-10-15

 *- Descripttion:openstack geecp

 *- Modules: 

 *  

 *- Extends      

 *  - 1.egg_Controller

 *----------------------------------------------------------

 * 

 *- Function List ：

 * 

 *- StaticsList :

 *  - show      获取所有ak/sk

 *  - update    创建ak/sk 修改备注

 *  - destroy   删除ak/sk

 * 

 *- History :

 *  <Author>      <Date>      <Desc> 

 * 

 **************************************************************/

'use strict';



const Controller = require('egg').Controller;



class AccesskeyController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Model}       MODEL    公司表

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Account.Company;

    }

    /**

     * 

     * @name 获取Accesskey列表

     * 

     * @example 

     * - GET /user/accesskey/_id{ObjectId} HTTP/1.1

     *  

     */

    async show() {

        const ctx = this.ctx;

        const result = await this.MODEL.getASK({ '_id': ctx.params.id });

        ctx.body = result

    }

    /**

     * 

     * @name  创建AK/SK|修改Info

     * 

     * @param {String}      info     必填      备注内容

     * @param {ObjectId}    id       必填      A/SK{ObjectId}

     * 

     * @example 

     * - PUT /user/accesskey/user{ObjectId} HTTP/1.1 创建

     * - PUT /user/accesskey/user{ObjectId} HTTP/1.1 修改

     *   body:{

     *      id:ak/sk{ObjectId}

     *      info:备注名称

     *   }

     * 

     * @description info id 为必填参数

     * 

    */

    async update() {

        const ctx = this.ctx;

        if (!!ctx.request.body.info) {

            ctx.body = await this.MODEL.setInfo(ctx);

        }

        else {

            ctx.body = await this.MODEL.createASK(ctx);

        }

    }

    /**

    * 

    * @name  删除AK/SK

    * 

    * @param {ObjectId}    id       必填      A/SK id 

    * 

    * @example 

    * PUT /user/accesskey/id{ObjectId} HTTP/1.1

    * @description id 为必填参数

    * 

   */

    async destroy() {

        const ctx = this.ctx;

        ctx.body = await this.MODEL.delASK(ctx);

    }

    /**

     * 

     * @name ak/sk鉴权接口

     * 

     * @param {ObjectId}   uid           必填      用户uid

     * @param {String}     api_key       必填      accountKey

     * @param {String}     secret_key    必填      secretKey

     * 

     * @example 

     * POST /user/authorization HTTP/1.1

     * 

     * @description uid|api_key|secret_key 必填

     * 

     */

    async authorization() {

        const ctx = this.ctx;

        const { uid, api_key, secret_key } = ctx.request.body;

        ctx.body = await this.MODEL.apiToken({ uid, api_key, secret_key });

    }

}



module.exports = AccesskeyController;

用户鉴权
控制器
'use strict';

const Controller = require('egg').Controller;

class ServiceJwtController extends Controller {

    constructor(ctx) {

        super(ctx);

        this.MODELComp = ctx.model.Account.Company;

        this.MODELAdmin = ctx.model.Account.Admin;

    };

    /**

     * @name 用户token生成

     * 

     * @param {action:string}   'api'   用于鉴权ak/sk生成token

     * @param {String}      compEmail       用户邮箱

     * @param {String}      compPhone       用户手机

     * @param {String}      compPassword    用户密码

     * 

     * @description

     * 

     * @example POST /user/sign/

     * 

     * @return Object

     *{

     *        "token": "",

     *        "info": {

     *            "_id": "5bcdd5e7f12ee030f44b6228",

     *            "compPhone": "13658157663",

     *            "compEmail": "64832897@qq.com",

     *            "compAuth": {

     *                "email": false,

     *                "phone": true

     *            },

     *            "compService": [],

     *            "updated": "2018-10-22T13:51:35.314Z",

     *            "compApi": []

     *        }

     *    }

     * 

     **/

    async sign() {

        const ctx = this.ctx;

        const {

            body,

            header

        } = ctx.request;

        try {

            if (ctx.request.url.includes('admin')) {

                ctx.body = await this.MODELAdmin.isLogin(ctx);

            } else {

                if (!['compEmail', 'compPhone'].map(e => Object.keys(body).includes(e)).reduce((a, b) => a + b)) {

                    ctx.body = {

                        code: 422,

                        message: '用户参数错误'

                    };

                    return

                };

                ctx.body = await this.MODELComp.isLogin(ctx);

            }

        } catch (error) {

            console.log(error)

            if (error.message === 'jwt expired') {

                ctx.body = {

                    message: '用户鉴权失败,请重新登陆',

                    code: 401

                }

            } else {

                ctx.body = {

                    message: !!error.errors ? `${error.errors.reduce((a, error) => { a.push(`${error.field} ${error.message}`); return a }, [])}` : error.message,

                    code: 422

                }

            }

        }

    }

}

module.exports = ServiceJwtController
extend 扩展
简单用户划分
module.exports = {

    isAdmin() {

        console.log(this.url)

        return this.state.user.group === 1 ? false : true;

    },

};
OpenStack 相关控制器
project
'use strict';



const Controller = require('egg').Controller;



class OPIdentityProjectsController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

    }

    /**

    * @name  project列表

    * 

    * @param {String}      ctx.query      不需要参数

    * 

    * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

    * 

    * @example  GET /openstack/projects

    * 

    */

    async index() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.list(ctx.query);

        ctx.body = datas;

    }

    /**

    * @name  获取单一project信息

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  GET /openstack/projects/{ctx.params.id}

    * 

    */

    async show() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.show(ctx.params.id);

        ctx.body = datas;

    }

    /**

    * @name  创建project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - POST /openstack/projects/

    */

    async create() {

        const { ctx, service } = this;

        const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;

        const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };

        const datas = await service.openstack.identity.projects.create(this.DUFn(bodys))

        ctx.body = datas;

    }

    /**

    * @name  更新project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - DELETE /openstack/projects/{ctx.params.id}

    */

    async destroy() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.destroy(ctx.params.id);

        ctx.body = datas;

    }

    /**

    * @name  删除project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - PATCH /openstack/projects/{ctx.params.id}

    */

    async update() {

        const { ctx, service } = this;

        const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;

        const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };

        const datas = await service.openstack.identity.projects.update(ctx.params.id, this.DUFn(bodys))

        ctx.body = datas;

    }

    /**

     * @name 锁定不可操作项目

     * 

     */

    checkID(idx) {

        const ARR = ['c3513f27bbf24362b74d13e6afae2c37', '5d3b50c18fd44db4bc6abfdbbfcf6a3a', '5c7e341df8ff493c8ae7baf57c0129dd'];

        return ARR.includes(idx);

    }

}



module.exports = OPIdentityProjectsController;
region
'use strict';



const Controller = require('egg').Controller;



class identityUserRegionController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Openstack.Identity.Region

        this.TKMODEL = ctx.model.Openstack.Token

    };

    /**

     * 

     * @name  用户列表

     *

     * @description 

     * 

     * @example  GET /openstack/identity/region

     * 

     */

    async index() {

        const { ctx, service } = this;

        const datas = await this.MODEL.getAll(this.auth.id, ctx.isAdmin());

        ctx.body = datas;

    }

}



module.exports = identityUserRegionController;
user
'use strict';



const Controller = require('egg').Controller;



class identityUserController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Openstack.Identity.User

        this.TKMODEL = ctx.model.Openstack.Token

    };

    /**

     * 

     * @name  用户列表

     * 

     * @param {String}      ctx.query.detail      不需要参数

     * 

     * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

     * 

     * @example  GET /openstack/user

     * 

     */

    async index() {

        const { ctx, service } = this;

        ctx.body = await service.openstack.identity.users.list(ctx.query);

    };

    /**

     * @name  获取单一用户信息

     * 

     * @param {String}      ctx.params.id      实例id

     * 

     * @example  GET /openstack/user/{ctx.params.id}

     * 

     */

    async show() {

        const { ctx, service } = this;

        ctx.body = await service.openstack.identity.users.show(ctx.params.id);

        // const result = await this.MODEL.getOne(this.auth.id);

        // ctx.body = result;

    };

    /**

     * @name  创建用户

     * 

     * @param {String}      ctx.params.id      实例id

     * 

     * @example  

     * - POST /openstack/user/

     */

    async create() {

        const ctx = this.ctx;

        const result = await this.MODEL.createUser(this.auth.id)

        ctx.body = result;

        // const { ctx, service } = this;

        // const { default_project_id, domain_id, description, enabled = true, email, name, password } = ctx.request.body;

        // const bodys = { default_project_id, domain_id, description, enabled, email, name, password };

        // ctx.body = await service.openstack.identity.users.create(this.DUFn(bodys));

    };

    /**

     * 

     * @name 测试内部用token

     * 

     */

    async testToken() {

        const { ctx, service } = this;

        ctx.body = await this.TKMODEL.getToken(this.auth.id)

    };

}



module.exports = identityUserController;

egg.js+mongodb+openstack 公有云计费系统（一）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1455 次浏览 • 2019-03-13 23:58 • 来自相关话题

本代码仅供学习 参考用 请勿做其他用途
?本项目结构
?
用户系统财务系统工单系统计费系统OpenStack （rocky）
?
OpenStack 功能
用户系统identity磁盘blcokStorage计算compute监控gnocchi网络 network
?
所需依赖
"dependencies": {
"egg": "^2.2.1",
"egg-scripts": "^2.5.0",
"lodash": "^4.17.11",
"xml2js": "^0.4.19"
},
"devDependencies": {
"autod": "^3.0.1",
"autod-egg": "^1.0.0",
"baidu-aip-sdk": "^2.3.3",
"bce-sdk-js": "^0.2.9",
"decimal": "0.0.2",
"decimal.js": "^10.0.1",
"egg-bin": "^4.3.5",
"egg-ci": "^1.8.0",
"egg-cors": "^2.1.0",
"egg-jwt": "^3.1.2",
"egg-mock": "^3.14.0",
"egg-mongoose": "^3.1.0",
"egg-multipart": "^2.1.0",
"egg-validate": "^1.1.1",
"egg-wechat-api": "^1.2.2",
"eslint": "^4.11.0",
"eslint-config-egg": "^6.0.0",
"formstream": "^1.1.0",
"jpush-async": "^4.0.0-rc.1",
"koa-useragent": "^1.1.0",
"moment": "^2.22.2",
"nodemailer": "^4.6.8",
"request": "^2.88.0",
"request-promise-native": "^1.0.5",
"stream-to-array": "^2.3.0",
"stream-wormhole": "^1.1.0",
"webstorm-disable-index": "^1.2.0"
},
环境?
node 8.11?
mongodb4.x?
openstack(rocky）
?
注意：
?
1.本教程不会上传相关代码到GitHub ；
2.本教程需要熟悉egg.js mongoose ES6/7;
3.熟悉Async/await
? 查看全部

本代码仅供学习 参考用 请勿做其他用途


?本项目结构
?
  • 用户系统
  • 财务系统
  • 工单系统
  • 计费系统
  • OpenStack （rocky）

?
OpenStack 功能
  • 用户系统identity
  • 磁盘blcokStorage
  • 计算compute
  • 监控gnocchi
  • 网络 network

?
所需依赖
  "dependencies": {

    "egg": "^2.2.1",

    "egg-scripts": "^2.5.0",

    "lodash": "^4.17.11",

    "xml2js": "^0.4.19"

  },

  "devDependencies": {

    "autod": "^3.0.1",

    "autod-egg": "^1.0.0",

    "baidu-aip-sdk": "^2.3.3",

    "bce-sdk-js": "^0.2.9",

    "decimal": "0.0.2",

    "decimal.js": "^10.0.1",

    "egg-bin": "^4.3.5",

    "egg-ci": "^1.8.0",

    "egg-cors": "^2.1.0",

    "egg-jwt": "^3.1.2",

    "egg-mock": "^3.14.0",

    "egg-mongoose": "^3.1.0",

    "egg-multipart": "^2.1.0",

    "egg-validate": "^1.1.1",

    "egg-wechat-api": "^1.2.2",

    "eslint": "^4.11.0",

    "eslint-config-egg": "^6.0.0",

    "formstream": "^1.1.0",

    "jpush-async": "^4.0.0-rc.1",

    "koa-useragent": "^1.1.0",

    "moment": "^2.22.2",

    "nodemailer": "^4.6.8",

    "request": "^2.88.0",

    "request-promise-native": "^1.0.5",

    "stream-to-array": "^2.3.0",

    "stream-wormhole": "^1.1.0",

    "webstorm-disable-index": "^1.2.0"

  },

环境?
node 8.11?
mongodb4.x?
openstack(rocky）
?
注意：
?
1.本教程不会上传相关代码到GitHub ；
2.本教程需要熟悉egg.js mongoose ES6/7;
3.熟悉Async/await
?
更多...

egg.js+mongodb+openstack 公有云计费系统（三）OpenStack 对接 compute (一)

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1622 次浏览 • 2019-03-19 11:48 • 来自相关话题

配额
控制器
'use strict';

const Controller = require('egg').Controller;

class IndexController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.QPFn = ctx.helper.queryParamFn;
this.SERVICE = ctx.service.openstack.compute.index;
this.serverSERVICE = ctx.service.openstack.server.servers
}
/**
* name 计算相关配额
*
* @description
*
* @example GET /openstack/blcokstorage/limits
*
* @return {Object}
* - cores VCPU数量可用 颗
* - floatingIps 自定义IP可用 个
* - instances N/A
* - RAM 内存可用量 MB
* - securityGroups 实例数量 个
* - serverGroups 实例分组数量 个
*/
async limits() {
const { ctx, service } = this;
// if (!ctx.isAdmin()) return;
const DATAS = await this.SERVICE.limits(this.auth.id, ctx.isAdmin());
ctx.body = DATAS
}
}

module.exports = IndexController;
service
'use strict';
const ServerIndex = require('../index')
class ComputeIndexService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.actions = ':8774/v2.1/'
};
// 获取服务器相关配额
async limits(_ucid, isAdmin) {
try {
const DATAS = await this.OSAJax(`${this.actions}limits`, {
...!isAdmin && { _ucid }
});
const { maxImageMeta, maxPersonality, maxPersonalitySize, maxSecurityGroupRules, maxSecurityGroups, maxServerGroupMembers, maxServerGroups, maxServerMeta, maxTotalCores, maxTotalFloatingIps, maxTotalInstances, maxTotalKeypairs, maxTotalRAMSize, totalCoresUsed, totalFloatingIpsUsed, totalInstancesUsed, totalRAMUsed, totalSecurityGroupsUsed, totalServerGroupsUsed } = (await DATAS).limits.absolute
return {
data: {
maxTotalKeypairs,
'cores': maxTotalCores - totalCoresUsed,
'RAM': maxTotalRAMSize - totalRAMUsed,
maxTotalInstances,
totalInstancesUsed,
'instances': maxTotalInstances - totalInstancesUsed,
maxServerGroups,
'serverGroups': maxServerGroups - totalServerGroupsUsed,
}
}
} catch (error) {
return error
}
}
}

module.exports = ComputeIndexService;

?keypairs
?
控制器
'use strict';

const Controller = require('egg').Controller;

class OSKeypairController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.QPFn = ctx.helper.queryParamFn;
this.SERVICE = ctx.service.openstack.compute.keypair;
this.MODEL = ctx.model.Openstack.Servers.Keypair
}
/**
* @name 获取用户所有密钥对
*
* @example
* - GET /openstack/compute/keypairs
*/
async index() {
const ctx = this.ctx;
// const DATAS = await this.SERVICE.index(this.auth.id, this.QPFn(ctx.query));
// ctx.body = DATAS
const RESULT = await this.MODEL.getAll(this.auth.id, this.QPFn({ ...ctx.query
}));
ctx.body = RESULT
}
/**
* @name 创建密钥对
*
* @param {String} name 密钥对名称
*
* @example
* - POST application/x-www-form-urlencoded /openstack/compute/keypairs
*/
async create() {
const ctx = this.ctx;
const {
name,
public_key,
description
} = ctx.request.body;
const BODYS = this.DUFn({
name,
public_key,
description
});
// const DATAS = await this.SERVICE.create(this.auth.id, BODYS);
// ctx.body = DATAS
const RESULT = await this.MODEL.createOne(this.auth.id, BODYS);
ctx.body = RESULT
}
/**
* @name 获取指定密钥对信息
*
* @param {String} ctx.params.id 密钥对名称
*
* @example
* - GET /openstack/compute/keypairs/{ctx.params.id}
*/
async show() {
const ctx = this.ctx;
const DATAS = await this.MODEL.getOne(this.auth.id, ctx.params.id);
ctx.body = DATAS
}
/**
* @name 删除密钥对
*
* @param {String} ctx.params.id 密钥对名称
*
* @example
* - DELETE /openstack/compute/keypairs/{ctx.params.id}
*/
async destroy() {
const ctx = this.ctx;
const DATAS = await this.MODEL.deleteOne(this.auth.id, ctx.params.id);
ctx.body = DATAS
}
/**
* @name 绑定ECS
*
* @param {String} name 密钥对名称
* @param {String} type 'bind|unbind' 方式
* @param {String} _ECS_id 服务器id
*
*/
async setBindECS() {
const ctx = this.ctx;
const {
name,
type,
_ECS_id
} = ctx.request.body;
const BODYS = this.DUFn({
name,
type,
_ECS_id
})
const DATAS = await this.MODEL.setBindEcs(this.auth.id, BODYS);
ctx.body = DATAS
}
}

module.exports = OSKeypairController;service
'use strict';
const ServerIndex = require('../index')
class ComputeKeypairService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.actions = ':8774/v2.1/os-keypairs'
};
/**
* @name 列表
* @param {*} _ucid 用户id
*/
async index(_ucid, query) {
try {
const datas = await this.OSAJax(`${this.actions}`, {
_ucid,
body: { ...query.querys }
});
return {
data: {
'result': datas.keypairs,
'totalCount': datas.keypairs.length
},
}
} catch (error) {
return error
}
}
/**
* @name 获取
* @param {*} _ucid 用户id
* @param {*} keypair_name 密钥对名称
*/
async show(_ucid, keypair_name) {
try {
const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, { _ucid });
return {
data: datas.keypair
}
} catch (error) {
return error
}
}
/**
* @name 创建
* @param {*} _ucid 用户id
* @param {*} body 需要提交的参数
*/
async create(_ucid, body) {
try {
const datas = await this.OSAJax(`${this.actions}`, {
_ucid,
method: 'POST',
body: {
'keypair': {
...body,
}
}
});
return {
...!!datas.conflictingRequest ? { code: 422, message: `密钥对名称为：${body.name}的密钥对已存在` } : { data: datas }
}
} catch (error) {
return error
}
}
/**
* @name 删除
* @param {*} _ucid 用户id
* @param {*} keypair_name 密钥对名称
*/
async destroy(_ucid, keypair_name) {
try {
const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, {
_ucid,
method: 'DELETE',
full: true
});
return {
code: datas.status,
message: datas.status === 404 && `${keypair_name}不存在或已删除`
}
} catch (error) {

}
}
}

module.exports = ComputeKeypairService; 查看全部
配额
控制器
'use strict';



const Controller = require('egg').Controller;



class IndexController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.QPFn = ctx.helper.queryParamFn;

        this.SERVICE = ctx.service.openstack.compute.index;

        this.serverSERVICE = ctx.service.openstack.server.servers

    }

    /**

    * name 计算相关配额

    * 

    * @description 

    * 

    * @example  GET /openstack/blcokstorage/limits

    * 

    * @return {Object}

    *  - cores                VCPU数量可用                  颗

    *  - floatingIps          自定义IP可用                  个

    *  - instances            N/A                          

    *  - RAM                  内存可用量                    MB

    *  - securityGroups       实例数量                      个

    *  - serverGroups         实例分组数量                  个

    */

    async limits() {

        const { ctx, service } = this;

        // if (!ctx.isAdmin()) return;

        const DATAS = await this.SERVICE.limits(this.auth.id, ctx.isAdmin());

        ctx.body = DATAS

    }

}



module.exports = IndexController;
service
'use strict';

const ServerIndex = require('../index')

class ComputeIndexService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.actions = ':8774/v2.1/'

    };

    // 获取服务器相关配额

    async limits(_ucid, isAdmin) {

        try {

            const DATAS = await this.OSAJax(`${this.actions}limits`, {

                ...!isAdmin && { _ucid }

            });

            const { maxImageMeta, maxPersonality, maxPersonalitySize, maxSecurityGroupRules, maxSecurityGroups, maxServerGroupMembers, maxServerGroups, maxServerMeta, maxTotalCores, maxTotalFloatingIps, maxTotalInstances, maxTotalKeypairs, maxTotalRAMSize, totalCoresUsed, totalFloatingIpsUsed, totalInstancesUsed, totalRAMUsed, totalSecurityGroupsUsed, totalServerGroupsUsed } = (await DATAS).limits.absolute

            return {

                data: {

                    maxTotalKeypairs,

                    'cores': maxTotalCores - totalCoresUsed,

                    'RAM': maxTotalRAMSize - totalRAMUsed,

                    maxTotalInstances,

                    totalInstancesUsed,

                    'instances': maxTotalInstances - totalInstancesUsed,

                    maxServerGroups,

                    'serverGroups': maxServerGroups - totalServerGroupsUsed,

                }

            }

        } catch (error) {

            return error

        }

    }

}



module.exports = ComputeIndexService;

?keypairs
?
控制器
'use strict';



const Controller = require('egg').Controller;



class OSKeypairController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.QPFn = ctx.helper.queryParamFn;

        this.SERVICE = ctx.service.openstack.compute.keypair;

        this.MODEL = ctx.model.Openstack.Servers.Keypair

    }

    /**

     * @name  获取用户所有密钥对

     * 

     * @example  

     * - GET /openstack/compute/keypairs

     */

    async index() {

        const ctx = this.ctx;

        // const DATAS = await this.SERVICE.index(this.auth.id, this.QPFn(ctx.query));

        // ctx.body = DATAS

        const RESULT = await this.MODEL.getAll(this.auth.id, this.QPFn({ ...ctx.query

        }));

        ctx.body = RESULT

    }

    /**

     * @name  创建密钥对

     * 

     * @param {String}      name      密钥对名称

     * 

     * @example  

     * - POST  application/x-www-form-urlencoded /openstack/compute/keypairs 

     */

    async create() {

        const ctx = this.ctx;

        const {

            name,

            public_key,

            description

        } = ctx.request.body;

        const BODYS = this.DUFn({

            name,

            public_key,

            description

        });

        // const DATAS = await this.SERVICE.create(this.auth.id, BODYS);

        // ctx.body = DATAS

        const RESULT = await this.MODEL.createOne(this.auth.id, BODYS);

        ctx.body = RESULT

    }

    /**

     * @name 获取指定密钥对信息

     * 

     * @param {String}      ctx.params.id      密钥对名称

     * 

     * @example  

     * - GET /openstack/compute/keypairs/{ctx.params.id}

     */

    async show() {

        const ctx = this.ctx;

        const DATAS = await this.MODEL.getOne(this.auth.id, ctx.params.id);

        ctx.body = DATAS

    }

    /**

     * @name  删除密钥对

     * 

     * @param {String}      ctx.params.id      密钥对名称

     * 

     * @example  

     * - DELETE /openstack/compute/keypairs/{ctx.params.id}

     */

    async destroy() {

        const ctx = this.ctx;

        const DATAS = await this.MODEL.deleteOne(this.auth.id, ctx.params.id);

        ctx.body = DATAS

    }

    /**

     * @name 绑定ECS

     * 

     * @param {String} name                         密钥对名称

     * @param {String} type      'bind|unbind'      方式  

     * @param {String} _ECS_id                      服务器id

     * 

     */

    async setBindECS() {

        const ctx = this.ctx;

        const {

            name,

            type,

            _ECS_id

        } = ctx.request.body;

        const BODYS = this.DUFn({

            name,

            type,

            _ECS_id

        })

        const DATAS = await this.MODEL.setBindEcs(this.auth.id, BODYS);

        ctx.body = DATAS

    }

}



module.exports = OSKeypairController;
service
'use strict';

const ServerIndex = require('../index')

class ComputeKeypairService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.actions = ':8774/v2.1/os-keypairs'

    };

    /**

     * @name 列表

     * @param {*} _ucid         用户id

     */

    async index(_ucid, query) {

        try {

            const datas = await this.OSAJax(`${this.actions}`, {

                _ucid,

                body: { ...query.querys }

            });

            return {

                data: {

                    'result': datas.keypairs,

                    'totalCount': datas.keypairs.length

                },

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 获取

     * @param {*} _ucid            用户id

     * @param {*} keypair_name     密钥对名称

     */

    async show(_ucid, keypair_name) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, { _ucid });

            return {

                data: datas.keypair

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 创建

     * @param {*} _ucid          用户id

     * @param {*} body           需要提交的参数

     */

    async create(_ucid, body) {

        try {

            const datas = await this.OSAJax(`${this.actions}`, {

                _ucid,

                method: 'POST',

                body: {

                    'keypair': {

                        ...body,

                    }

                }

            });

            return {

                ...!!datas.conflictingRequest ? { code: 422, message: `密钥对名称为：${body.name}的密钥对已存在` } : { data: datas }

            }

        } catch (error) {

            return error

        }

    }

    /**

     * @name 删除

     * @param {*} _ucid             用户id

     * @param {*} keypair_name      密钥对名称

     */

    async destroy(_ucid, keypair_name) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${keypair_name}`, {

                _ucid,

                method: 'DELETE',

                full: true

            });

            return {

                code: datas.status,

                message: datas.status === 404 && `${keypair_name}不存在或已删除`

            }

        } catch (error) {



        }

    }

}



module.exports = ComputeKeypairService;

egg.js+mongodb+openstack 公有云计费系统（三）OpenStack 对接 blcokStorage（2）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1380 次浏览 • 2019-03-15 11:27 • 来自相关话题

磁盘相关
控制器'use strict';

const Controller = require('egg').Controller;

class OPBlcokStorageVolumeController extends Controller {
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.QMFN = ctx.helper.queryParamFn;
this.DUFN = ctx.helper.deleteUndefined;
this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;
this.volumeSERVICE = ctx.service.openstack.blcokStorage.volume;
};
/**
* @name 磁盘列表
*
* @param {String} detail 不需要参数
*
* ----------------------------------- 分页 -------------------------------------
*
* @param {String} limit 分页>>条数/页
* @param {String} marker markerID(上页最后条id)
*
* ----------------------------------- 排序 -------------------------------------
*
* @param {String} sort_dir a|b 排序方式 ['asc':default,'desc']
* @param {String} sort_key 排序字段 [status,name,created_at]
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/blcokstorage/volume?{detail}
*
*/
async index() {
const { ctx } = this;
const RESULT = await this.volumeMODEL.getUsers(this.auth.id, this.QMFN({...ctx.query }));
ctx.body = RESULT;
};
/**
* @name 获取单一磁盘
*
* @description
*
* @example GET /openstack/blcokstorage/volume/{id}
*
*/
async show() {
const ctx = this.ctx;
// const datas = await this.volumeSERVICE.show(ctx.params.id, this.auth.id);
// ctx.body = datas;
const RESULT = await this.volumeMODEL.getOne(this.auth.id, ctx.params.id, ctx.isAdmin())
ctx.body = RESULT;
};
/**
* @name 创建磁盘
*
* @description
*
* @example POST /openstack/blcokstorage/volume
*
* @param {String} size 大小
* @param {String} availability_zone Optional 可用区域
* @param {String} snapshot_id Optional 快照ID FN从快照创建
* @param {String} backup_id Optional 备份ID FN从备份创建
* @param {String} imageRef Optional 镜像ID FN从镜像创建
* @param {String} volume_type Optional 磁盘类型 默认HDD
*
*/
async create() {
const { ctx } = this;
const { availability_zone, snapshot_id, backup_id, imageRef, size = 5, volume_type = "hdd" } = ctx.request.body;
const BODYS = this.DUFN({ availability_zone, snapshot_id, backup_id, imageRef, size, volume_type })
const datas = await this.volumeMODEL.createOne(this.auth.id, BODYS)
ctx.body = datas
};
/**
* @name 调整磁盘
*
* @description
*
* @example POST /openstack/blcokstorage/volume
*
* @param {String} size 大小
* @param {String} availability_zone Optional 可用区域
* @param {String} snapshot_id Optional 快照ID FN从快照创建
* @param {String} backup_id Optional 备份ID FN从备份创建
* @param {String} imageRef Optional 镜像ID FN从镜像创建
* @param {String} volume_type Optional 磁盘类型 默认HDD
*
*/
async update() {
const ctx = this.ctx;
const BODYS = ctx.request.body;
const { action, name } = BODYS;
delete BODYS.action;
const datas = !!action ? await this.volumeSERVICE.action(this.auth.id, this.auth.ProjectID, ctx.params.id, action, BODYS) : await this.serverSERVICE.update(ctx.params.id, this.auth.id, this.DUFn({ name }));
ctx.body = datas
};
/**
* @name 删除磁盘
*
* @description
*
*/
async destroy() {
const ctx = this.ctx;
const DATAS = await this.volumeSERVICE.destroy(this.auth.id, this.auth.ProjectID, ctx.params.id);
ctx.body = DATAS
}

}

module.exports = OPBlcokStorageVolumeController;modelmodule.exports = app => {
const mongoose = app.mongoose;
const Schema = mongoose.Schema;
const ctx = app.createAnonymousContext();
const {
helper,
service
} = app.createAnonymousContext();
const {
NumToStr
} = ctx.helper;
const OSblockStorageVolumeSchema = new Schema({
// 配置
config: {},
// 公司id
_comp: {
type: Schema.Types.ObjectId,
ref: 'Company',
required: true,
index: true
},
// 支付方式
payment: {
type: String,
default: 'prepay'
},
// 到期时间
endTime: {
type: Date
},
// 后台备注描述
_description: {

},
// 源信息
_metadata: {
type: String,
index: true
},
/*---------------------------------------------------*/
"status": {
type: 'String',
default: 'creating'
},
"migration_status": {},
"user_id": {},
"attachments": ,
"availability_zone": {},
"bootable": {},
"encrypted": {},
"created_at": {},
"description": {},
"updated_at": {},
"volume_type": {},
"name": {},
"replication_status": {},
"consistencygroup_id": {},
"source_volid": {},
"imageRef": {},
"backup_id": {},
"snapshot_id": {},
"multiattach": {},
"metadata": {},
"id": {
type: String,
index: true
},
"size": {},
"os-vol-host-attr:host": {},
"os-vol-tenant-attr:tenant_id": {}
}, {
timestamps: {
createdAt: 'created',
updatedAt: 'updated'
}
});
OSblockStorageVolumeSchema.statics = {
getUsers: async function(_comp, queryMix) {
const serverSERVICE = ctx.service.openstack.server.servers;
const {
querys,
select,
sort,
limit,
marker
} = queryMix;
const withDetail = querys.detail === '' || querys.detail;
delete querys.detail;
let QUERTS = {};
for (const key in querys) {
QUERTS[key] = eval(`/${querys[key]}.*/i`)
}
const MODELS = (count = false) => this.find({
_comp,
...QUERTS,
...(marker && !count && {
'_id': {
"$lt": marker
}
}),
}, {
...select,
}, {
...!count && {
limit
},
'sort': {
_id: -1,
...sort
}
});
try {
const datas = await MODELS()
return {
data: {
result: datas,
limit,
marker: datas.length ? [...datas].pop()._id : '',
totalCount: await MODELS(true).count()
}
}
} catch (error) {
return error
}
},
/**
* @name 创建硬盘
* @param {*} _id
* @param {*} body
*/
createOne: async function(_id, bodys) {
try {
const {
endTime,
payment,
_metadata
} = bodys;
delete bodys._metadata;
delete bodys.endTime;
delete bodys.payment;
//
const DATAS = await service.openstack.blcokStorage.volume.create(_id, {
...bodys,
... {
"name": `volume-${Math.random().toString(36).slice(2, 8)}`
}
});
const {
id: _openstack_id
} = DATAS.data.volume;
!!DATAS.data.volume && await ctx.model.Schedule.Openstack.Volume.addOne({
_comp: _id,
_openstack_id,
type: 'volume',
active: 'creating',
_metadata
})
return !!DATAS.data.volume ? {
data: await this.create({
_comp: _id,
endTime,
payment,
_metadata,
...DATAS.data.volume
})
} : {
'code': 422,
'message': '创建失败'
};
} catch (error) {
return error
}
},
// 获取全部
getAll: async function(queryMix) {
const {
querys,
select,
pages,
sort,
dates
} = queryMix;
const MODELS = this.find({
'status': {
'$ne': 0
},
...querys,
// ...(!!pages && !!pages.marker && { '_id': { "$lt": pages.marker } }),
}, {
...select,
})
// .limit(!!pages ? pages.limit : 10)
.sort({
// '_id': -1,
'id': 1,
...sort
});
return {
data: {
result: await MODELS,
totalCount: await MODELS.count()
}
};
},
// 查看单个
getOne: async function(_comp, id, isAdmin) {
const MODELS = this.findOne({...isAdmin ? {
id
} : {
_comp,
id
}
});
try {
const RESULT = await MODELS;
return {
data: RESULT
}
} catch (error) {
return error
}
},
// 绑定到磁盘
/**
* @name 绑定到磁盘
* @param {*} _comp 用户UUID
* @param {*} id 磁盘ID
* @param {*} type 'bind'|'unbind' 绑定方式
*/
bindToECS: async function({
_comp,
id,
type = "bind"
} = {}, bodys) {
const MODEL = this.findOneAndUpdate({
_comp,
id
}, {
'attachments': type === 'bind' ? [bodys] : ,
'status': type === 'bind' ? 'in-use' : 'available'
});
try {
const datas = await MODEL;
} catch (error) {
return error
}
}
}
return mongoose.model('openstack_block_storage_volume', OSblockStorageVolumeSchema)
}service'use strict';
const ServerIndex = require('../index')
//
class VolumeService extends ServerIndex {
constructor(ctx) {
super(ctx);
this.adminprojectID = this.config.openstack.projectID.default;
this.actions = ':8776/v3';
};
// 获取磁盘列表
async list(querys, _ucid, project_id, isAdmin) {
try {
const detail = Object.keys(querys).includes('detail');
delete querys.detail;
let SORT = {}
if (querys.sort_key) {
SORT = { 'sort': `${querys.sort_key}:${querys.sort_dir}` };
delete querys.sort_key;
delete querys.sort_dir;
}
const datas = await this.OSAJax(`${this.actions}/${!!isAdmin ? this.adminprojectID : project_id}/volumes${detail ? '/detail' : ''}`, {
...!isAdmin && { _ucid },
body: {
...querys,
...querys.sort_key && SORT,
...isAdmin && { 'all_tenants': true },
},
});
return {
data: {
result: datas.volumes.map(e => {
!!detail && e.attachments.length && (e.attachment = e.attachments[0].server_id)
delete e.links;
delete e.attachments;
return e
}).filter(e => e.status != 'deleting'),
totalCount: datas.volumes.length
}
};
} catch (error) {
return error
}
}
// 获取磁盘详情
async show(id, _ucid, _description) {
try {
const datas = await this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes/${id}`, {
..._ucid !== 'admin' && { _ucid }
});
return _ucid === 'admin' ? { ...datas.volume, _description } : { data: datas.volume };
} catch (error) {
return error
}
}
// 创建磁盘
async create(_ucid, bodys, order = "false") {
const DATAS = this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes`, {
body: {
'volume': {
... {
"availability_zone": null,
"source_volid": null,
"description": null,
"multiattach": false,
"snapshot_id": null,
"backup_id": null,
"imageRef": null,
"metadata": {},
"consistencygroup_id": null
},
...bodys
}
},
method: 'POST',
_ucid
});
try {
const datas = await DATAS
return !!order ? { data: datas } : datas
} catch (error) {
return error
}

}
// 删除磁盘
async destroy(_ucid, project_id, volume_id) {
try {
const datas = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {
_ucid,
method: 'DELETE',
full: true
});
return {
...datas.status === 404 && {
message: `${volume_id}不存在或已删除`
}
}
} catch (error) {

}
}
// 磁盘操作
// {'os-extend':'磁盘扩容','revert':'镜像回滚'}
async action(_ucid, project_id, volume_id, type, bodys) {
const isIn = (e) => ['os-extend', 'revert'].includes(e);
if (!isIn(type)) return { code: 422 };
const actionMAP = (e) => {
const OBJ = {};
OBJ[e] = !bodys ? null : bodys;
return OBJ;
}
try {
const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}/action`, {
body: actionMAP(type),
method: 'POST',
_ucid, full: true
});
return {
code: DATAS.status
}
} catch (error) {
return error
}
}
async update(_ucid, project_id, volume_id, bodys) {
try {
const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {
_ucid,
bodys: {
...bodys
},
method: 'PUT'
});
return {
data: DATAS
}
} catch (error) {
return error
}
}
}
module.exports = VolumeService;
scheduleconst Subscription = require('egg').Subscription;

class getVolumeStatus extends Subscription {
constructor(ctx) {
super(ctx);
this.SERVICE = ctx.service.openstack.blcokStorage.volume;
this.MODELS = ctx.model.Schedule.Openstack.Volume;
this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;
}
static get schedule() {
return {
interval: '10s',
type: 'worker',
};
}
async subscribe() {
const ctx = this.ctx;
const lists = await this.MODELS.getALL();
if (lists.length) {
const datas = await this.checkItem(lists);
}
}
async checkItem(result) {
// 调取记录
const checkFN = result.map(e => {
// 记录尝试次数
this.MODELS.retry(e._openstack_id)
return this.SERVICE.show(e._openstack_id, 'admin', e);
})
let DATAS = await Promise.all(checkFN);
// 检查ACTION
if (!!DATAS.length) {
const endOrder = DATAS.map(e => {
const { _comp, _openstack_id: id } = e._description;
delete e._description
delete e.links
if (e.status === 'available' || e.status === 'in-use') {
return this.volumeMODEL.findOneAndUpdate({ id }, { ...e });
}
})
DATAS = await Promise.all(endOrder);
};
// 清除已完成任务
if (DATAS.length) {
const clearSchedule = DATAS.map(e => {
if (!!e) {
const { id: _openstack_id } = e;
return this.MODELS.deleteOne({ '_openstack_id': _openstack_id })
}
})
DATAS = await Promise.all(clearSchedule);
}
}
}

module.exports = getVolumeStatus;
schedule model
module.exports = app => {
const mongoose = app.mongoose;
const Schema = mongoose.Schema;
const ctx = app.createAnonymousContext();
const scheduleOSVolumeSchema = new Schema({
// 类型
type: {
type: String,
},
// 尝试次数
retry: {
type: Number,
dafault: 0
},
// 是否创建成功
status: {
type: Boolean,
default: false
},
// 操作方式 [BUILD:创建,DELETE:删除]
active: {
type: String,
},
// 数据ID
_openstack_id: {
type: String,
index: true
},
// 公司ID
_comp: {
type: String
},
// 其他配置参数
/**
* ecs：Number
*/
_description: {

},
// 其他配置元信息
_metadata: {

}
}, {
timestamps: {
createdAt: 'created',
updatedAt: 'updated'
}
});
scheduleOSVolumeSchema.statics = {
getALL: async function (limit = 50) {
const MODEL = this.find().limit(limit);
try {
return await MODEL;
} catch (error) {
return error
}
},
addOne: async function (bodys) {
const MODEL = this.create({ ...bodys });
try {
const result = await MODEL;
return { code: !!result ? 201 : 404 }
} catch (error) {
return error
}
},
// destroyOne: async function (id) {
// const MODEL = this.deleteOne(id);
// try {
// const result = await MODEL
// return result
// } catch (error) {
// return error
// }
// },
retry: async function (_openstack_id) {
const MODEL = this.findOneAndUpdate({ _openstack_id }, {
'$inc': { retry: 1 }
});
try {
await MODEL
} catch (error) {
return error
}
}
}
return mongoose.model('schedule_openstack_volume', scheduleOSVolumeSchema);
} 查看全部
磁盘相关
控制器
'use strict';



const Controller = require('egg').Controller;



class OPBlcokStorageVolumeController extends Controller {

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.QMFN = ctx.helper.queryParamFn;

        this.DUFN = ctx.helper.deleteUndefined;

        this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;

        this.volumeSERVICE = ctx.service.openstack.blcokStorage.volume;

    };

    /**

     * @name  磁盘列表

     * 

     * @param {String}      detail      不需要参数

     * 

     * -----------------------------------    分页    -------------------------------------

     * 

     * @param {String}      limit                     分页>>条数/页

     * @param {String}      marker                    markerID(上页最后条id)

     * 

     * -----------------------------------    排序    -------------------------------------

     * 

     * @param {String}      sort_dir          a|b     排序方式 ['asc':default,'desc']

     * @param {String}      sort_key                  排序字段 [status,name,created_at]

     * 

     * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

     * 

     * @example  GET /openstack/blcokstorage/volume?{detail}

     * 

     */

    async index() {

        const { ctx } = this;

        const RESULT = await this.volumeMODEL.getUsers(this.auth.id, this.QMFN({...ctx.query }));

        ctx.body = RESULT;

    };

    /**

     * @name  获取单一磁盘

     * 

     * @description 

     * 

     * @example  GET /openstack/blcokstorage/volume/{id}

     * 

     */

    async show() {

        const ctx = this.ctx;

        // const datas = await this.volumeSERVICE.show(ctx.params.id, this.auth.id);

        // ctx.body = datas;

        const RESULT = await this.volumeMODEL.getOne(this.auth.id, ctx.params.id, ctx.isAdmin())

        ctx.body = RESULT;

    };

    /**

     * @name  创建磁盘

     * 

     * @description 

     * 

     * @example  POST /openstack/blcokstorage/volume

     * 

     * @param {String} size                               大小

     * @param {String} availability_zone     Optional     可用区域

     * @param {String} snapshot_id           Optional     快照ID         FN从快照创建

     * @param {String} backup_id             Optional     备份ID         FN从备份创建

     * @param {String} imageRef              Optional     镜像ID         FN从镜像创建

     * @param {String} volume_type           Optional     磁盘类型       默认HDD

     * 

     */

    async create() {

        const { ctx } = this;

        const { availability_zone, snapshot_id, backup_id, imageRef, size = 5, volume_type = "hdd" } = ctx.request.body;

        const BODYS = this.DUFN({ availability_zone, snapshot_id, backup_id, imageRef, size, volume_type })

        const datas = await this.volumeMODEL.createOne(this.auth.id, BODYS)

        ctx.body = datas

    };

    /**

     * @name  调整磁盘

     * 

     * @description 

     * 

     * @example  POST /openstack/blcokstorage/volume

     * 

     * @param {String} size                               大小

     * @param {String} availability_zone     Optional     可用区域

     * @param {String} snapshot_id           Optional     快照ID         FN从快照创建

     * @param {String} backup_id             Optional     备份ID         FN从备份创建

     * @param {String} imageRef              Optional     镜像ID         FN从镜像创建

     * @param {String} volume_type           Optional     磁盘类型       默认HDD

     * 

     */

    async update() {

        const ctx = this.ctx;

        const BODYS = ctx.request.body;

        const { action, name } = BODYS;

        delete BODYS.action;

        const datas = !!action ? await this.volumeSERVICE.action(this.auth.id, this.auth.ProjectID, ctx.params.id, action, BODYS) : await this.serverSERVICE.update(ctx.params.id, this.auth.id, this.DUFn({ name }));

        ctx.body = datas

    };

    /**

     * @name 删除磁盘

     * 

     * @description

     * 

     */

    async destroy() {

        const ctx = this.ctx;

        const DATAS = await this.volumeSERVICE.destroy(this.auth.id, this.auth.ProjectID, ctx.params.id);

        ctx.body = DATAS

    }



}



module.exports = OPBlcokStorageVolumeController;
model
module.exports = app => {

    const mongoose = app.mongoose;

    const Schema = mongoose.Schema;

    const ctx = app.createAnonymousContext();

    const {

        helper,

        service

    } = app.createAnonymousContext();

    const {

        NumToStr

    } = ctx.helper;

    const OSblockStorageVolumeSchema = new Schema({

        // 配置

        config: {},

        // 公司id

        _comp: {

            type: Schema.Types.ObjectId,

            ref: 'Company',

            required: true,

            index: true

        },

        // 支付方式

        payment: {

            type: String,

            default: 'prepay'

        },

        // 到期时间

        endTime: {

            type: Date

        },

        // 后台备注描述

        _description: {



        },

        // 源信息

        _metadata: {

            type: String,

            index: true

        },

        /*---------------------------------------------------*/

        "status": {

            type: 'String',

            default: 'creating'

        },

        "migration_status": {},

        "user_id": {},

        "attachments": ,

        "availability_zone": {},

        "bootable": {},

        "encrypted": {},

        "created_at": {},

        "description": {},

        "updated_at": {},

        "volume_type": {},

        "name": {},

        "replication_status": {},

        "consistencygroup_id": {},

        "source_volid": {},

        "imageRef": {},

        "backup_id": {},

        "snapshot_id": {},

        "multiattach": {},

        "metadata": {},

        "id": {

            type: String,

            index: true

        },

        "size": {},

        "os-vol-host-attr:host": {},

        "os-vol-tenant-attr:tenant_id": {}

    }, {

        timestamps: {

            createdAt: 'created',

            updatedAt: 'updated'

        }

    });

    OSblockStorageVolumeSchema.statics = {

        getUsers: async function(_comp, queryMix) {

            const serverSERVICE = ctx.service.openstack.server.servers;

            const {

                querys,

                select,

                sort,

                limit,

                marker

            } = queryMix;

            const withDetail = querys.detail === '' || querys.detail;

            delete querys.detail;

            let QUERTS = {};

            for (const key in querys) {

                QUERTS[key] = eval(`/${querys[key]}.*/i`)

            }

            const MODELS = (count = false) => this.find({

                _comp,

                ...QUERTS,

                ...(marker && !count && {

                    '_id': {

                        "$lt": marker

                    }

                }),

            }, {

                ...select,

            }, {

                ...!count && {

                    limit

                },

                'sort': {

                    _id: -1,

                    ...sort

                }

            });

            try {

                const datas = await MODELS()

                return {

                    data: {

                        result: datas,

                        limit,

                        marker: datas.length ? [...datas].pop()._id : '',

                        totalCount: await MODELS(true).count()

                    }

                }

            } catch (error) {

                return error

            }

        },

        /**

         * @name 创建硬盘

         * @param {*} _id 

         * @param {*} body 

         */

        createOne: async function(_id, bodys) {

            try {

                const {

                    endTime,

                    payment,

                    _metadata

                } = bodys;

                delete bodys._metadata;

                delete bodys.endTime;

                delete bodys.payment;

                // 

                const DATAS = await service.openstack.blcokStorage.volume.create(_id, {

                    ...bodys,

                    ... {

                        "name": `volume-${Math.random().toString(36).slice(2, 8)}`

                    }

                });

                const {

                    id: _openstack_id

                } = DATAS.data.volume;

                !!DATAS.data.volume && await ctx.model.Schedule.Openstack.Volume.addOne({

                    _comp: _id,

                    _openstack_id,

                    type: 'volume',

                    active: 'creating',

                    _metadata

                })

                return !!DATAS.data.volume ? {

                    data: await this.create({

                        _comp: _id,

                        endTime,

                        payment,

                        _metadata,

                        ...DATAS.data.volume

                    })

                } : {

                    'code': 422,

                    'message': '创建失败'

                };

            } catch (error) {

                return error

            }

        },

        // 获取全部

        getAll: async function(queryMix) {

            const {

                querys,

                select,

                pages,

                sort,

                dates

            } = queryMix;

            const MODELS = this.find({

                    'status': {

                        '$ne': 0

                    },

                    ...querys,

                    // ...(!!pages && !!pages.marker && { '_id': { "$lt": pages.marker } }),

                }, {

                    ...select,

                })

                // .limit(!!pages ? pages.limit : 10)

                .sort({

                    // '_id': -1,

                    'id': 1,

                    ...sort

                });

            return {

                data: {

                    result: await MODELS,

                    totalCount: await MODELS.count()

                }

            };

        },

        // 查看单个

        getOne: async function(_comp, id, isAdmin) {

            const MODELS = this.findOne({...isAdmin ? {

                    id

                } : {

                    _comp,

                    id

                }

            });

            try {

                const RESULT = await MODELS;

                return {

                    data: RESULT

                }

            } catch (error) {

                return error

            }

        },

        // 绑定到磁盘

        /**

         * @name  绑定到磁盘

         * @param {*} _comp                                      用户UUID

         * @param {*} id                                         磁盘ID

         * @param {*} type              'bind'|'unbind'          绑定方式  

         */

        bindToECS: async function({

            _comp,

            id,

            type = "bind"

        } = {}, bodys) {

            const MODEL = this.findOneAndUpdate({

                _comp,

                id

            }, {

                'attachments': type === 'bind' ? [bodys] : ,

                'status': type === 'bind' ? 'in-use' : 'available'

            });

            try {

                const datas = await MODEL;

            } catch (error) {

                return error

            }

        }

    }

    return mongoose.model('openstack_block_storage_volume', OSblockStorageVolumeSchema)

}
service
'use strict';

const ServerIndex = require('../index')

//

class VolumeService extends ServerIndex {

    constructor(ctx) {

        super(ctx);

        this.adminprojectID = this.config.openstack.projectID.default;

        this.actions = ':8776/v3';

    };

    // 获取磁盘列表

    async list(querys, _ucid, project_id, isAdmin) {

        try {

            const detail = Object.keys(querys).includes('detail');

            delete querys.detail;

            let SORT = {}

            if (querys.sort_key) {

                SORT = { 'sort': `${querys.sort_key}:${querys.sort_dir}` };

                delete querys.sort_key;

                delete querys.sort_dir;

            }

            const datas = await this.OSAJax(`${this.actions}/${!!isAdmin ? this.adminprojectID : project_id}/volumes${detail ? '/detail' : ''}`, {

                ...!isAdmin && { _ucid },

                body: {

                    ...querys,

                    ...querys.sort_key && SORT,

                    ...isAdmin && { 'all_tenants': true },

                },

            });

            return {

                data: {

                    result: datas.volumes.map(e => {

                        !!detail && e.attachments.length && (e.attachment = e.attachments[0].server_id)

                        delete e.links;

                        delete e.attachments;

                        return e

                    }).filter(e => e.status != 'deleting'),

                    totalCount: datas.volumes.length

                }

            };

        } catch (error) {

            return error

        }

    }

    // 获取磁盘详情

    async show(id, _ucid, _description) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes/${id}`, {

                ..._ucid !== 'admin' && { _ucid }

            });

            return _ucid === 'admin' ? { ...datas.volume, _description } : { data: datas.volume };

        } catch (error) {

            return error

        }

    }

    // 创建磁盘

    async create(_ucid, bodys, order = "false") {

        const DATAS = this.OSAJax(`${this.actions}/${await this.getProject(_ucid)}/volumes`, {

            body: {

                'volume': {

                    ... {

                        "availability_zone": null,

                        "source_volid": null,

                        "description": null,

                        "multiattach": false,

                        "snapshot_id": null,

                        "backup_id": null,

                        "imageRef": null,

                        "metadata": {},

                        "consistencygroup_id": null

                    },

                    ...bodys

                }

            },

            method: 'POST',

            _ucid

        });

        try {

            const datas = await DATAS

            return !!order ? { data: datas } : datas

        } catch (error) {

            return error

        }



    }

    // 删除磁盘

    async destroy(_ucid, project_id, volume_id) {

        try {

            const datas = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {

                _ucid,

                method: 'DELETE',

                full: true

            });

            return {

                ...datas.status === 404 && {

                    message: `${volume_id}不存在或已删除`

                }

            }

        } catch (error) {



        }

    }

    // 磁盘操作

    // {'os-extend':'磁盘扩容','revert':'镜像回滚'}

    async action(_ucid, project_id, volume_id, type, bodys) {

        const isIn = (e) => ['os-extend', 'revert'].includes(e);

        if (!isIn(type)) return { code: 422 };

        const actionMAP = (e) => {

            const OBJ = {};

            OBJ[e] = !bodys ? null : bodys;

            return OBJ;

        }

        try {

            const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}/action`, {

                body: actionMAP(type),

                method: 'POST',

                _ucid, full: true

            });

            return {

                code: DATAS.status

            }

        } catch (error) {

            return error

        }

    }

    async update(_ucid, project_id, volume_id, bodys) {

        try {

            const DATAS = await this.OSAJax(`${this.actions}/${project_id}/volumes/${volume_id}`, {

                _ucid,

                bodys: {

                    ...bodys

                },

                method: 'PUT'

            });

            return {

                data: DATAS

            }

        } catch (error) {

            return error

        }

    }

}

module.exports = VolumeService;

schedule
const Subscription = require('egg').Subscription;



class getVolumeStatus extends Subscription {

    constructor(ctx) {

        super(ctx);

        this.SERVICE = ctx.service.openstack.blcokStorage.volume;

        this.MODELS = ctx.model.Schedule.Openstack.Volume;

        this.volumeMODEL = ctx.model.Openstack.BlcokStorage.Volumes;

    }

    static get schedule() {

        return {

            interval: '10s',

            type: 'worker',

        };

    }

    async subscribe() {

        const ctx = this.ctx;

        const lists = await this.MODELS.getALL();

        if (lists.length) {

            const datas = await this.checkItem(lists);

        }

    }

    async checkItem(result) {

        // 调取记录

        const checkFN = result.map(e => {

            // 记录尝试次数

            this.MODELS.retry(e._openstack_id)

            return this.SERVICE.show(e._openstack_id, 'admin', e);

        })

        let DATAS = await Promise.all(checkFN);

        // 检查ACTION

        if (!!DATAS.length) {

            const endOrder = DATAS.map(e => {

                const { _comp, _openstack_id: id } = e._description;

                delete e._description

                delete e.links

                if (e.status === 'available' || e.status === 'in-use') {

                    return this.volumeMODEL.findOneAndUpdate({ id }, { ...e });

                }

            })

            DATAS = await Promise.all(endOrder);

        };

        // 清除已完成任务

        if (DATAS.length) {

            const clearSchedule = DATAS.map(e => {

                if (!!e) {

                    const { id: _openstack_id } = e;

                    return this.MODELS.deleteOne({ '_openstack_id': _openstack_id })

                }

            })

            DATAS = await Promise.all(clearSchedule);

        }

    }

}



module.exports = getVolumeStatus;

schedule model
module.exports = app => {

    const mongoose = app.mongoose;

    const Schema = mongoose.Schema;

    const ctx = app.createAnonymousContext();

    const scheduleOSVolumeSchema = new Schema({

        // 类型

        type: {

            type: String,

        },

        // 尝试次数

        retry: {

            type: Number,

            dafault: 0

        },

        // 是否创建成功

        status: {

            type: Boolean,

            default: false

        },

        // 操作方式 [BUILD:创建,DELETE:删除]

        active: {

            type: String,

        },

        // 数据ID

        _openstack_id: {

            type: String,

            index: true

        },

        // 公司ID

        _comp: {

            type: String

        },

        // 其他配置参数

        /**

         * ecs：Number

         */

        _description: {



        },

        // 其他配置元信息

        _metadata: {



        }

    }, {

            timestamps: {

                createdAt: 'created',

                updatedAt: 'updated'

            }

        });

    scheduleOSVolumeSchema.statics = {

        getALL: async function (limit = 50) {

            const MODEL = this.find().limit(limit);

            try {

                return await MODEL;

            } catch (error) {

                return error

            }

        },

        addOne: async function (bodys) {

            const MODEL = this.create({ ...bodys });

            try {

                const result = await MODEL;

                return { code: !!result ? 201 : 404 }

            } catch (error) {

                return error

            }

        },

        // destroyOne: async function (id) {

        //     const MODEL = this.deleteOne(id);

        //     try {

        //         const result = await MODEL

        //         return result

        //     } catch (error) {

        //         return error

        //     }

        // },

        retry: async function (_openstack_id) {

            const MODEL = this.findOneAndUpdate({ _openstack_id }, {

                '$inc': { retry: 1 }

            });

            try {

                await MODEL

            } catch (error) {

                return error

            }

        }

    }

    return mongoose.model('schedule_openstack_volume', scheduleOSVolumeSchema);

}

egg.js+mongodb+openstack 公有云计费系统（三）用户系统的搭建 （2）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1503 次浏览 • 2019-03-15 11:08 • 来自相关话题

A/SK 机制
?
控制器
?
/*************************************************************
*
*- Copyright (c) qiduo, 2018
*- FileName: AccesskeyController.js 安全认证 Accesskey接口
*- Author: 罗波 lopo1983@vip.qq.com
*- Version: 1.0
*- Date:2018-10-15
*- Descripttion:openstack geecp
*- Modules:
*
*- Extends
* - 1.egg_Controller
*----------------------------------------------------------
*
*- Function List ：
*
*- StaticsList :
* - show 获取所有ak/sk
* - update 创建ak/sk 修改备注
* - destroy 删除ak/sk
*
*- History :
* <Author> <Date> <Desc>
*
**************************************************************/
'use strict';

const Controller = require('egg').Controller;

class AccesskeyController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Model} MODEL 公司表
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Account.Company;
}
/**
*
* @name 获取Accesskey列表
*
* @example
* - GET /user/accesskey/_id{ObjectId} HTTP/1.1
*
*/
async show() {
const ctx = this.ctx;
const result = await this.MODEL.getASK({ '_id': ctx.params.id });
ctx.body = result
}
/**
*
* @name 创建AK/SK|修改Info
*
* @param {String} info 必填 备注内容
* @param {ObjectId} id 必填 A/SK{ObjectId}
*
* @example
* - PUT /user/accesskey/user{ObjectId} HTTP/1.1 创建
* - PUT /user/accesskey/user{ObjectId} HTTP/1.1 修改
* body:{
* id:ak/sk{ObjectId}
* info:备注名称
* }
*
* @description info id 为必填参数
*
*/
async update() {
const ctx = this.ctx;
if (!!ctx.request.body.info) {
ctx.body = await this.MODEL.setInfo(ctx);
}
else {
ctx.body = await this.MODEL.createASK(ctx);
}
}
/**
*
* @name 删除AK/SK
*
* @param {ObjectId} id 必填 A/SK id
*
* @example
* PUT /user/accesskey/id{ObjectId} HTTP/1.1
* @description id 为必填参数
*
*/
async destroy() {
const ctx = this.ctx;
ctx.body = await this.MODEL.delASK(ctx);
}
/**
*
* @name ak/sk鉴权接口
*
* @param {ObjectId} uid 必填 用户uid
* @param {String} api_key 必填 accountKey
* @param {String} secret_key 必填 secretKey
*
* @example
* POST /user/authorization HTTP/1.1
*
* @description uid|api_key|secret_key 必填
*
*/
async authorization() {
const ctx = this.ctx;
const { uid, api_key, secret_key } = ctx.request.body;
ctx.body = await this.MODEL.apiToken({ uid, api_key, secret_key });
}
}

module.exports = AccesskeyController;

用户鉴权
控制器
'use strict';
const Controller = require('egg').Controller;
class ServiceJwtController extends Controller {
constructor(ctx) {
super(ctx);
this.MODELComp = ctx.model.Account.Company;
this.MODELAdmin = ctx.model.Account.Admin;
};
/**
* @name 用户token生成
*
* @param {action:string} 'api' 用于鉴权ak/sk生成token
* @param {String} compEmail 用户邮箱
* @param {String} compPhone 用户手机
* @param {String} compPassword 用户密码
*
* @description
*
* @example POST /user/sign/
*
* @return Object
*{
* "token": "",
* "info": {
* "_id": "5bcdd5e7f12ee030f44b6228",
* "compPhone": "13658157663",
* "compEmail": "64832897@qq.com",
* "compAuth": {
* "email": false,
* "phone": true
* },
* "compService": [],
* "updated": "2018-10-22T13:51:35.314Z",
* "compApi": []
* }
* }
*
**/
async sign() {
const ctx = this.ctx;
const {
body,
header
} = ctx.request;
try {
if (ctx.request.url.includes('admin')) {
ctx.body = await this.MODELAdmin.isLogin(ctx);
} else {
if (!['compEmail', 'compPhone'].map(e => Object.keys(body).includes(e)).reduce((a, b) => a + b)) {
ctx.body = {
code: 422,
message: '用户参数错误'
};
return
};
ctx.body = await this.MODELComp.isLogin(ctx);
}
} catch (error) {
console.log(error)
if (error.message === 'jwt expired') {
ctx.body = {
message: '用户鉴权失败,请重新登陆',
code: 401
}
} else {
ctx.body = {
message: !!error.errors ? `${error.errors.reduce((a, error) => { a.push(`${error.field} ${error.message}`); return a }, [])}` : error.message,
code: 422
}
}
}
}
}
module.exports = ServiceJwtControllerextend 扩展
简单用户划分
module.exports = {
isAdmin() {
console.log(this.url)
return this.state.user.group === 1 ? false : true;
},
};OpenStack 相关控制器
project
'use strict';

const Controller = require('egg').Controller;

class OPIdentityProjectsController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
}
/**
* @name project列表
*
* @param {String} ctx.query 不需要参数
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/projects
*
*/
async index() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.list(ctx.query);
ctx.body = datas;
}
/**
* @name 获取单一project信息
*
* @param {String} ctx.params.id 实例id
*
* @example GET /openstack/projects/{ctx.params.id}
*
*/
async show() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.show(ctx.params.id);
ctx.body = datas;
}
/**
* @name 创建project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - POST /openstack/projects/
*/
async create() {
const { ctx, service } = this;
const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;
const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };
const datas = await service.openstack.identity.projects.create(this.DUFn(bodys))
ctx.body = datas;
}
/**
* @name 更新project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - DELETE /openstack/projects/{ctx.params.id}
*/
async destroy() {
const { ctx, service } = this;
const datas = await service.openstack.identity.projects.destroy(ctx.params.id);
ctx.body = datas;
}
/**
* @name 删除project
*
* @param {String} ctx.params.id 实例id
*
* @example
* - PATCH /openstack/projects/{ctx.params.id}
*/
async update() {
const { ctx, service } = this;
const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;
const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };
const datas = await service.openstack.identity.projects.update(ctx.params.id, this.DUFn(bodys))
ctx.body = datas;
}
/**
* @name 锁定不可操作项目
*
*/
checkID(idx) {
const ARR = ['c3513f27bbf24362b74d13e6afae2c37', '5d3b50c18fd44db4bc6abfdbbfcf6a3a', '5c7e341df8ff493c8ae7baf57c0129dd'];
return ARR.includes(idx);
}
}

module.exports = OPIdentityProjectsController;
region
'use strict';

const Controller = require('egg').Controller;

class identityUserRegionController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Openstack.Identity.Region
this.TKMODEL = ctx.model.Openstack.Token
};
/**
*
* @name 用户列表
*
* @description
*
* @example GET /openstack/identity/region
*
*/
async index() {
const { ctx, service } = this;
const datas = await this.MODEL.getAll(this.auth.id, ctx.isAdmin());
ctx.body = datas;
}
}

module.exports = identityUserRegionController;user
'use strict';

const Controller = require('egg').Controller;

class identityUserController extends Controller {
/**
* @name constructor
*
* @param {*} ctx
* @param {Function} DuFn 清理空字段函数
* @param {Object} auth 用户JWT
*
*/
constructor(ctx) {
super(ctx);
this.auth = ctx.state.user;
this.DUFn = ctx.helper.deleteUndefined;
this.MODEL = ctx.model.Openstack.Identity.User
this.TKMODEL = ctx.model.Openstack.Token
};
/**
*
* @name 用户列表
*
* @param {String} ctx.query.detail 不需要参数
*
* @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表
*
* @example GET /openstack/user
*
*/
async index() {
const { ctx, service } = this;
ctx.body = await service.openstack.identity.users.list(ctx.query);
};
/**
* @name 获取单一用户信息
*
* @param {String} ctx.params.id 实例id
*
* @example GET /openstack/user/{ctx.params.id}
*
*/
async show() {
const { ctx, service } = this;
ctx.body = await service.openstack.identity.users.show(ctx.params.id);
// const result = await this.MODEL.getOne(this.auth.id);
// ctx.body = result;
};
/**
* @name 创建用户
*
* @param {String} ctx.params.id 实例id
*
* @example
* - POST /openstack/user/
*/
async create() {
const ctx = this.ctx;
const result = await this.MODEL.createUser(this.auth.id)
ctx.body = result;
// const { ctx, service } = this;
// const { default_project_id, domain_id, description, enabled = true, email, name, password } = ctx.request.body;
// const bodys = { default_project_id, domain_id, description, enabled, email, name, password };
// ctx.body = await service.openstack.identity.users.create(this.DUFn(bodys));
};
/**
*
* @name 测试内部用token
*
*/
async testToken() {
const { ctx, service } = this;
ctx.body = await this.TKMODEL.getToken(this.auth.id)
};
}

module.exports = identityUserController; 查看全部
A/SK 机制
?
控制器
?
/*************************************************************

 * 

 *- Copyright (c) qiduo, 2018

 *- FileName: AccesskeyController.js 安全认证 Accesskey接口

 *- Author: 罗波 lopo1983@vip.qq.com 

 *- Version: 1.0   

 *- Date:2018-10-15

 *- Descripttion:openstack geecp

 *- Modules: 

 *  

 *- Extends      

 *  - 1.egg_Controller

 *----------------------------------------------------------

 * 

 *- Function List ：

 * 

 *- StaticsList :

 *  - show      获取所有ak/sk

 *  - update    创建ak/sk 修改备注

 *  - destroy   删除ak/sk

 * 

 *- History :

 *  <Author>      <Date>      <Desc> 

 * 

 **************************************************************/

'use strict';



const Controller = require('egg').Controller;



class AccesskeyController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Model}       MODEL    公司表

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Account.Company;

    }

    /**

     * 

     * @name 获取Accesskey列表

     * 

     * @example 

     * - GET /user/accesskey/_id{ObjectId} HTTP/1.1

     *  

     */

    async show() {

        const ctx = this.ctx;

        const result = await this.MODEL.getASK({ '_id': ctx.params.id });

        ctx.body = result

    }

    /**

     * 

     * @name  创建AK/SK|修改Info

     * 

     * @param {String}      info     必填      备注内容

     * @param {ObjectId}    id       必填      A/SK{ObjectId}

     * 

     * @example 

     * - PUT /user/accesskey/user{ObjectId} HTTP/1.1 创建

     * - PUT /user/accesskey/user{ObjectId} HTTP/1.1 修改

     *   body:{

     *      id:ak/sk{ObjectId}

     *      info:备注名称

     *   }

     * 

     * @description info id 为必填参数

     * 

    */

    async update() {

        const ctx = this.ctx;

        if (!!ctx.request.body.info) {

            ctx.body = await this.MODEL.setInfo(ctx);

        }

        else {

            ctx.body = await this.MODEL.createASK(ctx);

        }

    }

    /**

    * 

    * @name  删除AK/SK

    * 

    * @param {ObjectId}    id       必填      A/SK id 

    * 

    * @example 

    * PUT /user/accesskey/id{ObjectId} HTTP/1.1

    * @description id 为必填参数

    * 

   */

    async destroy() {

        const ctx = this.ctx;

        ctx.body = await this.MODEL.delASK(ctx);

    }

    /**

     * 

     * @name ak/sk鉴权接口

     * 

     * @param {ObjectId}   uid           必填      用户uid

     * @param {String}     api_key       必填      accountKey

     * @param {String}     secret_key    必填      secretKey

     * 

     * @example 

     * POST /user/authorization HTTP/1.1

     * 

     * @description uid|api_key|secret_key 必填

     * 

     */

    async authorization() {

        const ctx = this.ctx;

        const { uid, api_key, secret_key } = ctx.request.body;

        ctx.body = await this.MODEL.apiToken({ uid, api_key, secret_key });

    }

}



module.exports = AccesskeyController;

用户鉴权
控制器
'use strict';

const Controller = require('egg').Controller;

class ServiceJwtController extends Controller {

    constructor(ctx) {

        super(ctx);

        this.MODELComp = ctx.model.Account.Company;

        this.MODELAdmin = ctx.model.Account.Admin;

    };

    /**

     * @name 用户token生成

     * 

     * @param {action:string}   'api'   用于鉴权ak/sk生成token

     * @param {String}      compEmail       用户邮箱

     * @param {String}      compPhone       用户手机

     * @param {String}      compPassword    用户密码

     * 

     * @description

     * 

     * @example POST /user/sign/

     * 

     * @return Object

     *{

     *        "token": "",

     *        "info": {

     *            "_id": "5bcdd5e7f12ee030f44b6228",

     *            "compPhone": "13658157663",

     *            "compEmail": "64832897@qq.com",

     *            "compAuth": {

     *                "email": false,

     *                "phone": true

     *            },

     *            "compService": [],

     *            "updated": "2018-10-22T13:51:35.314Z",

     *            "compApi": []

     *        }

     *    }

     * 

     **/

    async sign() {

        const ctx = this.ctx;

        const {

            body,

            header

        } = ctx.request;

        try {

            if (ctx.request.url.includes('admin')) {

                ctx.body = await this.MODELAdmin.isLogin(ctx);

            } else {

                if (!['compEmail', 'compPhone'].map(e => Object.keys(body).includes(e)).reduce((a, b) => a + b)) {

                    ctx.body = {

                        code: 422,

                        message: '用户参数错误'

                    };

                    return

                };

                ctx.body = await this.MODELComp.isLogin(ctx);

            }

        } catch (error) {

            console.log(error)

            if (error.message === 'jwt expired') {

                ctx.body = {

                    message: '用户鉴权失败,请重新登陆',

                    code: 401

                }

            } else {

                ctx.body = {

                    message: !!error.errors ? `${error.errors.reduce((a, error) => { a.push(`${error.field} ${error.message}`); return a }, [])}` : error.message,

                    code: 422

                }

            }

        }

    }

}

module.exports = ServiceJwtController
extend 扩展
简单用户划分
module.exports = {

    isAdmin() {

        console.log(this.url)

        return this.state.user.group === 1 ? false : true;

    },

};
OpenStack 相关控制器
project
'use strict';



const Controller = require('egg').Controller;



class OPIdentityProjectsController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

    }

    /**

    * @name  project列表

    * 

    * @param {String}      ctx.query      不需要参数

    * 

    * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

    * 

    * @example  GET /openstack/projects

    * 

    */

    async index() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.list(ctx.query);

        ctx.body = datas;

    }

    /**

    * @name  获取单一project信息

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  GET /openstack/projects/{ctx.params.id}

    * 

    */

    async show() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.show(ctx.params.id);

        ctx.body = datas;

    }

    /**

    * @name  创建project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - POST /openstack/projects/

    */

    async create() {

        const { ctx, service } = this;

        const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;

        const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };

        const datas = await service.openstack.identity.projects.create(this.DUFn(bodys))

        ctx.body = datas;

    }

    /**

    * @name  更新project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - DELETE /openstack/projects/{ctx.params.id}

    */

    async destroy() {

        const { ctx, service } = this;

        const datas = await service.openstack.identity.projects.destroy(ctx.params.id);

        ctx.body = datas;

    }

    /**

    * @name  删除project

    * 

    * @param {String}      ctx.params.id      实例id

    * 

    * @example  

    * - PATCH /openstack/projects/{ctx.params.id}

    */

    async update() {

        const { ctx, service } = this;

        const { name, is_domain, description, domain_id, enabled, parent_id, tags } = ctx.request.body;

        const bodys = { name, is_domain, description, domain_id, enabled, parent_id, tags };

        const datas = await service.openstack.identity.projects.update(ctx.params.id, this.DUFn(bodys))

        ctx.body = datas;

    }

    /**

     * @name 锁定不可操作项目

     * 

     */

    checkID(idx) {

        const ARR = ['c3513f27bbf24362b74d13e6afae2c37', '5d3b50c18fd44db4bc6abfdbbfcf6a3a', '5c7e341df8ff493c8ae7baf57c0129dd'];

        return ARR.includes(idx);

    }

}



module.exports = OPIdentityProjectsController;
region
'use strict';



const Controller = require('egg').Controller;



class identityUserRegionController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Openstack.Identity.Region

        this.TKMODEL = ctx.model.Openstack.Token

    };

    /**

     * 

     * @name  用户列表

     *

     * @description 

     * 

     * @example  GET /openstack/identity/region

     * 

     */

    async index() {

        const { ctx, service } = this;

        const datas = await this.MODEL.getAll(this.auth.id, ctx.isAdmin());

        ctx.body = datas;

    }

}



module.exports = identityUserRegionController;
user
'use strict';



const Controller = require('egg').Controller;



class identityUserController extends Controller {

    /**

     * @name constructor

     * 

     * @param {*} ctx 

     * @param {Function}    DuFn     清理空字段函数

     * @param {Object}      auth     用户JWT

     * 

     */

    constructor(ctx) {

        super(ctx);

        this.auth = ctx.state.user;

        this.DUFn = ctx.helper.deleteUndefined;

        this.MODEL = ctx.model.Openstack.Identity.User

        this.TKMODEL = ctx.model.Openstack.Token

    };

    /**

     * 

     * @name  用户列表

     * 

     * @param {String}      ctx.query.detail      不需要参数

     * 

     * @description query参数detail存在则显示实力配置列表详细信息,若不传仅显示概要列表

     * 

     * @example  GET /openstack/user

     * 

     */

    async index() {

        const { ctx, service } = this;

        ctx.body = await service.openstack.identity.users.list(ctx.query);

    };

    /**

     * @name  获取单一用户信息

     * 

     * @param {String}      ctx.params.id      实例id

     * 

     * @example  GET /openstack/user/{ctx.params.id}

     * 

     */

    async show() {

        const { ctx, service } = this;

        ctx.body = await service.openstack.identity.users.show(ctx.params.id);

        // const result = await this.MODEL.getOne(this.auth.id);

        // ctx.body = result;

    };

    /**

     * @name  创建用户

     * 

     * @param {String}      ctx.params.id      实例id

     * 

     * @example  

     * - POST /openstack/user/

     */

    async create() {

        const ctx = this.ctx;

        const result = await this.MODEL.createUser(this.auth.id)

        ctx.body = result;

        // const { ctx, service } = this;

        // const { default_project_id, domain_id, description, enabled = true, email, name, password } = ctx.request.body;

        // const bodys = { default_project_id, domain_id, description, enabled, email, name, password };

        // ctx.body = await service.openstack.identity.users.create(this.DUFn(bodys));

    };

    /**

     * 

     * @name 测试内部用token

     * 

     */

    async testToken() {

        const { ctx, service } = this;

        ctx.body = await this.TKMODEL.getToken(this.auth.id)

    };

}



module.exports = identityUserController;

egg.js+mongodb+openstack 公有云计费系统（一）

Nodejs • lopo1983 发表了文章 • 0 个评论 • 1455 次浏览 • 2019-03-13 23:58 • 来自相关话题

本代码仅供学习 参考用 请勿做其他用途
?本项目结构
?
用户系统财务系统工单系统计费系统OpenStack （rocky）
?
OpenStack 功能
用户系统identity磁盘blcokStorage计算compute监控gnocchi网络 network
?
所需依赖
"dependencies": {
"egg": "^2.2.1",
"egg-scripts": "^2.5.0",
"lodash": "^4.17.11",
"xml2js": "^0.4.19"
},
"devDependencies": {
"autod": "^3.0.1",
"autod-egg": "^1.0.0",
"baidu-aip-sdk": "^2.3.3",
"bce-sdk-js": "^0.2.9",
"decimal": "0.0.2",
"decimal.js": "^10.0.1",
"egg-bin": "^4.3.5",
"egg-ci": "^1.8.0",
"egg-cors": "^2.1.0",
"egg-jwt": "^3.1.2",
"egg-mock": "^3.14.0",
"egg-mongoose": "^3.1.0",
"egg-multipart": "^2.1.0",
"egg-validate": "^1.1.1",
"egg-wechat-api": "^1.2.2",
"eslint": "^4.11.0",
"eslint-config-egg": "^6.0.0",
"formstream": "^1.1.0",
"jpush-async": "^4.0.0-rc.1",
"koa-useragent": "^1.1.0",
"moment": "^2.22.2",
"nodemailer": "^4.6.8",
"request": "^2.88.0",
"request-promise-native": "^1.0.5",
"stream-to-array": "^2.3.0",
"stream-wormhole": "^1.1.0",
"webstorm-disable-index": "^1.2.0"
},
环境?
node 8.11?
mongodb4.x?
openstack(rocky）
?
注意：
?
1.本教程不会上传相关代码到GitHub ；
2.本教程需要熟悉egg.js mongoose ES6/7;
3.熟悉Async/await
? 查看全部

本代码仅供学习 参考用 请勿做其他用途


?本项目结构
?
  • 用户系统
  • 财务系统
  • 工单系统
  • 计费系统
  • OpenStack （rocky）

?
OpenStack 功能
  • 用户系统identity
  • 磁盘blcokStorage
  • 计算compute
  • 监控gnocchi
  • 网络 network

?
所需依赖
  "dependencies": {

    "egg": "^2.2.1",

    "egg-scripts": "^2.5.0",

    "lodash": "^4.17.11",

    "xml2js": "^0.4.19"

  },

  "devDependencies": {

    "autod": "^3.0.1",

    "autod-egg": "^1.0.0",

    "baidu-aip-sdk": "^2.3.3",

    "bce-sdk-js": "^0.2.9",

    "decimal": "0.0.2",

    "decimal.js": "^10.0.1",

    "egg-bin": "^4.3.5",

    "egg-ci": "^1.8.0",

    "egg-cors": "^2.1.0",

    "egg-jwt": "^3.1.2",

    "egg-mock": "^3.14.0",

    "egg-mongoose": "^3.1.0",

    "egg-multipart": "^2.1.0",

    "egg-validate": "^1.1.1",

    "egg-wechat-api": "^1.2.2",

    "eslint": "^4.11.0",

    "eslint-config-egg": "^6.0.0",

    "formstream": "^1.1.0",

    "jpush-async": "^4.0.0-rc.1",

    "koa-useragent": "^1.1.0",

    "moment": "^2.22.2",

    "nodemailer": "^4.6.8",

    "request": "^2.88.0",

    "request-promise-native": "^1.0.5",

    "stream-to-array": "^2.3.0",

    "stream-wormhole": "^1.1.0",

    "webstorm-disable-index": "^1.2.0"

  },

环境?
node 8.11?
mongodb4.x?
openstack(rocky）
?
注意：
?
1.本教程不会上传相关代码到GitHub ；
2.本教程需要熟悉egg.js mongoose ES6/7;
3.熟悉Async/await
?
更多...
Copyright © 2024