refs #6014 feat: executeRoutine

@@ -0,0 +83,4 @@
+                schema,
+                type: type.toUpperCase(),
+                name: routine,
+                host: process.env.NODE_ENV ? '' : '%',

@@ -0,0 +38,4 @@
+        }
+    });
+
+    Self.executeRoutine = async(ctx, routine, params, schema, type, options) => {

@@ -0,0 +2,4 @@
+
+module.exports = Self => {
+    Self.remoteMethodCtx('executeRoutine', {
+        description: 'Return the routes by worker',

@@ -0,0 +54,4 @@
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        const user = await models.VnUser.findById(userId, {

@@ -0,0 +1,100 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    Self.remoteMethodCtx('executeRoutine', {

@@ -0,0 +43,4 @@
+        const models = Self.app.models;
+        const isFunction = type == 'function';
+        params = params ?? [];
+        schema = schema ?? 'vn';

@@ -0,0 +78,4 @@
+
+        const roles = inherits.map(inherit => inherit.inherits().name);
+
+        const canExecute = await models.ProcsPriv.findOne({

@@ -0,0 +92,4 @@
+
+        let argString = params.map(() => '?').join(',');
+
+        const query = `${caller} ${schema}.${routine}(${argString})`;

@@ -2355,0 +2355,4 @@
+
+
+DELIMITER ;;
+CREATE DEFINER=`root`@`localhost` FUNCTION `account`.`user_hasRoutinePriv`(vType ENUM('PROCEDURE', 'FUNCTION'),

@@ -0,0 +6,4 @@
+        const models = Self.app.models;
+        let caller = 'CALL';
+
+        params = params ?? [];

@@ -0,0 +11,4 @@
+            Object.assign(myOptions, options);
+
+        let [caller, chain] = query.split(' ');
+        if (!chain.includes('.')) chain = 'vn.' + chain;

@@ -0,0 +20,4 @@
+
+        if (!Object.values(canExecute)[0]) throw new UserError(`You don't have enough privileges`, 'ACCESS_DENIED');
+
+        let argString = params.map(() => '?').join(',');

@@ -0,0 +18,4 @@
+            {
+                arg: 'schema',
+                type: 'string',
+                description: 'The routine schema',

@@ -0,0 +32,4 @@
+    });
+
+    Self.executeFunc = async(ctx, routine, params, schema, options) => {
+        if (schema)

@@ -0,0 +10,4 @@
+        return {
+            req: {
+                accessToken: {userId},
+                headers: {origin: 'http://localhost'}