ibiz4j 发布系统代码

app_web/src/locale/lang/en-US.ts

-import jobinfo_en_US from '@locale/lanres/entities/jobinfo/jobinfo_en_US';
-import joblog_en_US from '@locale/lanres/entities/joblog/joblog_en_US';
-import joblock_en_US from '@locale/lanres/entities/joblock/joblock_en_US';
-import jobregistry_en_US from '@locale/lanres/entities/jobregistry/jobregistry_en_US';
+import jobsinfo_en_US from '@locale/lanres/entities/jobs-info/jobs-info_en_US';
+import jobslog_en_US from '@locale/lanres/entities/jobs-log/jobs-log_en_US';
+import jobslock_en_US from '@locale/lanres/entities/jobs-lock/jobs-lock_en_US';
+import jobsregistry_en_US from '@locale/lanres/entities/jobs-registry/jobs-registry_en_US';
 import components_en_US from '@locale/lanres/components/components_en_US';
 import codelist_en_US from '@locale/lanres/codelist/codelist_en_US';
 import userCustom_en_US from '@locale/lanres/userCustom/userCustom_en_US';
@@ -60,10 +60,10 @@ export default {
         },
     },
     entities: {
-        jobinfo: jobinfo_en_US,
-        joblog: joblog_en_US,
-        joblock: joblock_en_US,
-        jobregistry: jobregistry_en_US,
+        jobsinfo: jobsinfo_en_US,
+        jobslog: jobslog_en_US,
+        jobslock: jobslock_en_US,
+        jobsregistry: jobsregistry_en_US,
     },
     components: components_en_US,
     codelist: codelist_en_US,

app_web/src/locale/lang/zh-CN.ts

-import jobinfo_zh_CN from '@locale/lanres/entities/jobinfo/jobinfo_zh_CN';
-import joblog_zh_CN from '@locale/lanres/entities/joblog/joblog_zh_CN';
-import joblock_zh_CN from '@locale/lanres/entities/joblock/joblock_zh_CN';
-import jobregistry_zh_CN from '@locale/lanres/entities/jobregistry/jobregistry_zh_CN';
+import jobsinfo_zh_CN from '@locale/lanres/entities/jobs-info/jobs-info_zh_CN';
+import jobslog_zh_CN from '@locale/lanres/entities/jobs-log/jobs-log_zh_CN';
+import jobslock_zh_CN from '@locale/lanres/entities/jobs-lock/jobs-lock_zh_CN';
+import jobsregistry_zh_CN from '@locale/lanres/entities/jobs-registry/jobs-registry_zh_CN';
 import components_zh_CN from '@locale/lanres/components/components_zh_CN';
 import codelist_zh_CN from '@locale/lanres/codelist/codelist_zh_CN';
 import userCustom_zh_CN from '@locale/lanres/userCustom/userCustom_zh_CN';
@@ -60,10 +60,10 @@ export default {
         },
     },
     entities: {
-        jobinfo: jobinfo_zh_CN,
-        joblog: joblog_zh_CN,
-        joblock: joblock_zh_CN,
-        jobregistry: jobregistry_zh_CN,
+        jobsinfo: jobsinfo_zh_CN,
+        jobslog: jobslog_zh_CN,
+        jobslock: jobslock_zh_CN,
+        jobsregistry: jobsregistry_zh_CN,
     },
     components: components_zh_CN,
     codelist: codelist_zh_CN,

app_web/src/locale/lanres/entities/jobs-info/jobs-info_en_US.ts

+
+export default {
+  fields: {
+    id: '主键ID',
+    tenant_id: '租户ID',
+    app: '服务名',
+    cron: '任务执行CRON',
+    handler: '执行器任务HANDLER',
+    param: '执行器任务参数',
+    timeout: '任务执行超时时间（秒）',
+    fail_retry_count: '失败重试次数',
+    last_time: '上次调度时间',
+    next_time: '下次调度时间',
+    author: '所有者',
+    remark: '备注',
+    status: '状态（0、启用 1、已禁用）',
+    update_time: '更新时间',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-info/jobs-info_zh_CN.ts

+export default {
+  fields: {
+    id: '主键ID',
+    tenant_id: '租户ID',
+    app: '服务名',
+    cron: '任务执行CRON',
+    handler: '执行器任务HANDLER',
+    param: '执行器任务参数',
+    timeout: '任务执行超时时间（秒）',
+    fail_retry_count: '失败重试次数',
+    last_time: '上次调度时间',
+    next_time: '下次调度时间',
+    author: '所有者',
+    remark: '备注',
+    status: '状态（0、启用 1、已禁用）',
+    update_time: '更新时间',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-lock/jobs-lock_en_US.ts

+
+export default {
+  fields: {
+    id: '主键ID',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-lock/jobs-lock_zh_CN.ts

+export default {
+  fields: {
+    id: '主键ID',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-log/jobs-log_en_US.ts

+
+export default {
+  fields: {
+    id: '主键ID',
+    job_id: '任务ID',
+    address: '执行地址',
+    handler: '执行器任务HANDLER',
+    param: '执行器任务参数',
+    fail_retry_count: '失败重试次数',
+    trigger_code: '触发器调度返回码',
+    trigger_type: '触发器调度类型',
+    trigger_msg: '触发器调度类型',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-log/jobs-log_zh_CN.ts

+export default {
+  fields: {
+    id: '主键ID',
+    job_id: '任务ID',
+    address: '执行地址',
+    handler: '执行器任务HANDLER',
+    param: '执行器任务参数',
+    fail_retry_count: '失败重试次数',
+    trigger_code: '触发器调度返回码',
+    trigger_type: '触发器调度类型',
+    trigger_msg: '触发器调度类型',
+    create_time: '创建时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-registry/jobs-registry_en_US.ts

+
+export default {
+  fields: {
+    id: '主键ID',
+    app: '服务名',
+    address: '执行地址',
+    status: '状态（0、启用 1、已禁用）',
+    update_time: '更新时间',
+  },
+};
\ No newline at end of file

app_web/src/locale/lanres/entities/jobs-registry/jobs-registry_zh_CN.ts

+export default {
+  fields: {
+    id: '主键ID',
+    app: '服务名',
+    address: '执行地址',
+    status: '状态（0、启用 1、已禁用）',
+    update_time: '更新时间',
+  },
+};
\ No newline at end of file

app_web/src/mock/index.ts

@@ -7,7 +7,7 @@ import './login/login';
 import './upload/upload';
 
 // 实体级接口对象
-import './entity/jobinfos/jobinfos';
-import './entity/joblogs/joblogs';
-import './entity/joblocks/joblocks';
-import './entity/jobregistrys/jobregistrys';
+import './entity/jobs-infos/jobs-infos';
+import './entity/jobs-logs/jobs-logs';
+import './entity/jobs-locks/jobs-locks';
+import './entity/jobs-registrys/jobs-registrys';

app_web/src/service/entity-service-register.ts

@@ -39,10 +39,10 @@ export class EntityServiceRegister {
      * @memberof EntityServiceRegister
      */
     protected init(): void {
-                this.allEntityService.set('jobinfo', () => import('@/service/jobinfo/jobinfo-service'));
-        this.allEntityService.set('joblog', () => import('@/service/joblog/joblog-service'));
-        this.allEntityService.set('joblock', () => import('@/service/joblock/joblock-service'));
-        this.allEntityService.set('jobregistry', () => import('@/service/jobregistry/jobregistry-service'));
+                this.allEntityService.set('jobsinfo', () => import('@/service/jobs-info/jobs-info-service'));
+        this.allEntityService.set('jobslog', () => import('@/service/jobs-log/jobs-log-service'));
+        this.allEntityService.set('jobslock', () => import('@/service/jobs-lock/jobs-lock-service'));
+        this.allEntityService.set('jobsregistry', () => import('@/service/jobs-registry/jobs-registry-service'));
     }
 
     /**

app_web/src/service/jobs-info/jobs-info-service-base.ts

+import { Http,Util } from '@/utils';
+import EntityService from '../entity-service';
+
+
+
+/**
+ * 任务信息服务对象基类
+ *
+ * @export
+ * @class JobsInfoServiceBase
+ * @extends {EntityServie}
+ */
+export default class JobsInfoServiceBase extends EntityService {
+
+    /**
+     * Creates an instance of  JobsInfoServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsInfoServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+    /**
+     * 初始化基础数据
+     *
+     * @memberof JobsInfoServiceBase
+     */
+    public initBasicData(){
+        this.APPLYDEKEY ='jobsinfo';
+        this.APPDEKEY = 'id';
+        this.APPDENAME = 'jobsinfos';
+        this.APPDETEXT = 'app';
+        this.APPNAME = 'web';
+        this.SYSTEMNAME = 'ibztask';
+    }
+
+// 实体接口
+
+    /**
+     * Select接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Select(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().get(`/jobsinfos/${context.jobsinfo}/select`,isloading);
+    }
+
+    /**
+     * Update接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Update(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().put(`/jobsinfos/${context.jobsinfo}`,data,isloading);
+            return res;
+    }
+
+    /**
+     * CheckKey接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async CheckKey(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().post(`/jobsinfos/${context.jobsinfo}/checkkey`,data,isloading);
+    }
+
+    /**
+     * Save接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Save(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().post(`/jobsinfos/${context.jobsinfo}/save`,data,isloading);
+            return res;
+    }
+
+    /**
+     * GetDraft接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async GetDraft(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let res:any = await  Http.getInstance().get(`/jobsinfos/getdraft`,isloading);
+        res.data.jobsinfo = data.jobsinfo;
+        return res;
+    }
+
+    /**
+     * Remove接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Remove(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().delete(`/jobsinfos/${context.jobsinfo}`,isloading);
+
+    }
+
+    /**
+     * Get接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Get(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            let res:any = await Http.getInstance().get(`/jobsinfos/${context.jobsinfo}`,isloading);
+            return res;
+
+    }
+
+    /**
+     * Create接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async Create(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+        if(!data.srffrontuf || data.srffrontuf !== "1"){
+            data[this.APPDEKEY] = null;
+        }
+        if(data.srffrontuf){
+            delete data.srffrontuf;
+        }
+        let tempContext:any = JSON.parse(JSON.stringify(context));
+        let res:any = await Http.getInstance().post(`/jobsinfos`,data,isloading);
+        return res;
+    }
+
+    /**
+     * FetchDefault接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsInfoServiceBase
+     */
+    public async FetchDefault(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let tempData:any = JSON.parse(JSON.stringify(data));
+        return Http.getInstance().get(`/jobsinfos/fetchdefault`,tempData,isloading);
+    }
+}
\ No newline at end of file

app_web/src/service/jobs-info/jobs-info-service.ts

+import { Http,Util } from '@/utils';
+import JobsInfoServiceBase from './jobs-info-service-base';
+
+
+/**
+ * 任务信息服务对象
+ *
+ * @export
+ * @class JobsInfoService
+ * @extends {JobsInfoServiceBase}
+ */
+export default class JobsInfoService extends JobsInfoServiceBase {
+
+    /**
+     * Creates an instance of  JobsInfoService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsInfoService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+
+}
\ No newline at end of file

app_web/src/service/jobs-lock/jobs-lock-service-base.ts

+import { Http,Util } from '@/utils';
+import EntityService from '../entity-service';
+
+
+
+/**
+ * 任务锁服务对象基类
+ *
+ * @export
+ * @class JobsLockServiceBase
+ * @extends {EntityServie}
+ */
+export default class JobsLockServiceBase extends EntityService {
+
+    /**
+     * Creates an instance of  JobsLockServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLockServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+    /**
+     * 初始化基础数据
+     *
+     * @memberof JobsLockServiceBase
+     */
+    public initBasicData(){
+        this.APPLYDEKEY ='jobslock';
+        this.APPDEKEY = 'id';
+        this.APPDENAME = 'jobslocks';
+        this.APPDETEXT = '';
+        this.APPNAME = 'web';
+        this.SYSTEMNAME = 'ibztask';
+    }
+
+// 实体接口
+
+    /**
+     * Select接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Select(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().get(`/jobslocks/${context.jobslock}/select`,isloading);
+    }
+
+    /**
+     * Create接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Create(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+        if(!data.srffrontuf || data.srffrontuf !== "1"){
+            data[this.APPDEKEY] = null;
+        }
+        if(data.srffrontuf){
+            delete data.srffrontuf;
+        }
+        let tempContext:any = JSON.parse(JSON.stringify(context));
+        let res:any = await Http.getInstance().post(`/jobslocks`,data,isloading);
+        return res;
+    }
+
+    /**
+     * Save接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Save(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().post(`/jobslocks/${context.jobslock}/save`,data,isloading);
+            return res;
+    }
+
+    /**
+     * Get接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Get(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            let res:any = await Http.getInstance().get(`/jobslocks/${context.jobslock}`,isloading);
+            return res;
+
+    }
+
+    /**
+     * Update接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Update(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().put(`/jobslocks/${context.jobslock}`,data,isloading);
+            return res;
+    }
+
+    /**
+     * CheckKey接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async CheckKey(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().post(`/jobslocks/${context.jobslock}/checkkey`,data,isloading);
+    }
+
+    /**
+     * Remove接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async Remove(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().delete(`/jobslocks/${context.jobslock}`,isloading);
+
+    }
+
+    /**
+     * GetDraft接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async GetDraft(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let res:any = await  Http.getInstance().get(`/jobslocks/getdraft`,isloading);
+        res.data.jobslock = data.jobslock;
+        return res;
+    }
+
+    /**
+     * FetchDefault接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLockServiceBase
+     */
+    public async FetchDefault(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let tempData:any = JSON.parse(JSON.stringify(data));
+        return Http.getInstance().get(`/jobslocks/fetchdefault`,tempData,isloading);
+    }
+}
\ No newline at end of file

app_web/src/service/jobs-lock/jobs-lock-service.ts

+import { Http,Util } from '@/utils';
+import JobsLockServiceBase from './jobs-lock-service-base';
+
+
+/**
+ * 任务锁服务对象
+ *
+ * @export
+ * @class JobsLockService
+ * @extends {JobsLockServiceBase}
+ */
+export default class JobsLockService extends JobsLockServiceBase {
+
+    /**
+     * Creates an instance of  JobsLockService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLockService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+
+}
\ No newline at end of file

app_web/src/service/jobs-log/jobs-log-service-base.ts

+import { Http,Util } from '@/utils';
+import EntityService from '../entity-service';
+
+
+
+/**
+ * 任务调度日志服务对象基类
+ *
+ * @export
+ * @class JobsLogServiceBase
+ * @extends {EntityServie}
+ */
+export default class JobsLogServiceBase extends EntityService {
+
+    /**
+     * Creates an instance of  JobsLogServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLogServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+    /**
+     * 初始化基础数据
+     *
+     * @memberof JobsLogServiceBase
+     */
+    public initBasicData(){
+        this.APPLYDEKEY ='jobslog';
+        this.APPDEKEY = 'id';
+        this.APPDENAME = 'jobslogs';
+        this.APPDETEXT = '';
+        this.APPNAME = 'web';
+        this.SYSTEMNAME = 'ibztask';
+    }
+
+// 实体接口
+
+    /**
+     * Select接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Select(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().get(`/jobslogs/${context.jobslog}/select`,isloading);
+    }
+
+    /**
+     * GetDraft接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async GetDraft(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let res:any = await  Http.getInstance().get(`/jobslogs/getdraft`,isloading);
+        res.data.jobslog = data.jobslog;
+        return res;
+    }
+
+    /**
+     * Update接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Update(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().put(`/jobslogs/${context.jobslog}`,data,isloading);
+            return res;
+    }
+
+    /**
+     * Create接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Create(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+        if(!data.srffrontuf || data.srffrontuf !== "1"){
+            data[this.APPDEKEY] = null;
+        }
+        if(data.srffrontuf){
+            delete data.srffrontuf;
+        }
+        let tempContext:any = JSON.parse(JSON.stringify(context));
+        let res:any = await Http.getInstance().post(`/jobslogs`,data,isloading);
+        return res;
+    }
+
+    /**
+     * CheckKey接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async CheckKey(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().post(`/jobslogs/${context.jobslog}/checkkey`,data,isloading);
+    }
+
+    /**
+     * Save接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Save(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().post(`/jobslogs/${context.jobslog}/save`,data,isloading);
+            return res;
+    }
+
+    /**
+     * Remove接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Remove(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().delete(`/jobslogs/${context.jobslog}`,isloading);
+
+    }
+
+    /**
+     * Get接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async Get(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            let res:any = await Http.getInstance().get(`/jobslogs/${context.jobslog}`,isloading);
+            return res;
+
+    }
+
+    /**
+     * FetchDefault接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsLogServiceBase
+     */
+    public async FetchDefault(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let tempData:any = JSON.parse(JSON.stringify(data));
+        return Http.getInstance().get(`/jobslogs/fetchdefault`,tempData,isloading);
+    }
+}
\ No newline at end of file

app_web/src/service/jobs-log/jobs-log-service.ts

+import { Http,Util } from '@/utils';
+import JobsLogServiceBase from './jobs-log-service-base';
+
+
+/**
+ * 任务调度日志服务对象
+ *
+ * @export
+ * @class JobsLogService
+ * @extends {JobsLogServiceBase}
+ */
+export default class JobsLogService extends JobsLogServiceBase {
+
+    /**
+     * Creates an instance of  JobsLogService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLogService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+
+}
\ No newline at end of file

app_web/src/service/jobs-registry/jobs-registry-service-base.ts

+import { Http,Util } from '@/utils';
+import EntityService from '../entity-service';
+
+
+
+/**
+ * 任务注册信息服务对象基类
+ *
+ * @export
+ * @class JobsRegistryServiceBase
+ * @extends {EntityServie}
+ */
+export default class JobsRegistryServiceBase extends EntityService {
+
+    /**
+     * Creates an instance of  JobsRegistryServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsRegistryServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+    /**
+     * 初始化基础数据
+     *
+     * @memberof JobsRegistryServiceBase
+     */
+    public initBasicData(){
+        this.APPLYDEKEY ='jobsregistry';
+        this.APPDEKEY = 'id';
+        this.APPDENAME = 'jobsregistries';
+        this.APPDETEXT = 'app';
+        this.APPNAME = 'web';
+        this.SYSTEMNAME = 'ibztask';
+    }
+
+// 实体接口
+
+    /**
+     * Select接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Select(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().get(`/jobsregistries/${context.jobsregistry}/select`,isloading);
+    }
+
+    /**
+     * Get接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Get(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            let res:any = await Http.getInstance().get(`/jobsregistries/${context.jobsregistry}`,isloading);
+            return res;
+
+    }
+
+    /**
+     * Remove接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Remove(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().delete(`/jobsregistries/${context.jobsregistry}`,isloading);
+
+    }
+
+    /**
+     * Update接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Update(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().put(`/jobsregistries/${context.jobsregistry}`,data,isloading);
+            return res;
+    }
+
+    /**
+     * Save接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Save(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+            let res:any = await  Http.getInstance().post(`/jobsregistries/${context.jobsregistry}/save`,data,isloading);
+            return res;
+    }
+
+    /**
+     * Create接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async Create(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let masterData:any = {};
+        Object.assign(data,masterData);
+        if(!data.srffrontuf || data.srffrontuf !== "1"){
+            data[this.APPDEKEY] = null;
+        }
+        if(data.srffrontuf){
+            delete data.srffrontuf;
+        }
+        let tempContext:any = JSON.parse(JSON.stringify(context));
+        let res:any = await Http.getInstance().post(`/jobsregistries`,data,isloading);
+        return res;
+    }
+
+    /**
+     * CheckKey接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async CheckKey(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+            return Http.getInstance().post(`/jobsregistries/${context.jobsregistry}/checkkey`,data,isloading);
+    }
+
+    /**
+     * GetDraft接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async GetDraft(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let res:any = await  Http.getInstance().get(`/jobsregistries/getdraft`,isloading);
+        res.data.jobsregistry = data.jobsregistry;
+        return res;
+    }
+
+    /**
+     * FetchDefault接口方法
+     *
+     * @param {*} [context={}]
+     * @param {*} [data={}]
+     * @param {boolean} [isloading]
+     * @returns {Promise<any>}
+     * @memberof JobsRegistryServiceBase
+     */
+    public async FetchDefault(context: any = {},data: any = {}, isloading?: boolean): Promise<any> {
+        let tempData:any = JSON.parse(JSON.stringify(data));
+        return Http.getInstance().get(`/jobsregistries/fetchdefault`,tempData,isloading);
+    }
+}
\ No newline at end of file

app_web/src/service/jobs-registry/jobs-registry-service.ts

+import { Http,Util } from '@/utils';
+import JobsRegistryServiceBase from './jobs-registry-service-base';
+
+
+/**
+ * 任务注册信息服务对象
+ *
+ * @export
+ * @class JobsRegistryService
+ * @extends {JobsRegistryServiceBase}
+ */
+export default class JobsRegistryService extends JobsRegistryServiceBase {
+
+    /**
+     * Creates an instance of  JobsRegistryService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsRegistryService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-info/jobs-info-ui-service-base.ts

+import { Environment } from '@/environments/environment';
+import { UIActionTool,Util } from '@/utils';
+import UIService from '../ui-service';
+import { Subject } from 'rxjs';
+import JobsInfoService from '@/service/jobs-info/jobs-info-service';
+
+/**
+ * 任务信息UI服务对象基类
+ *
+ * @export
+ * @class JobsInfoUIServiceBase
+ */
+export default class JobsInfoUIServiceBase extends UIService {
+
+    /**
+     * 是否支持工作流
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */
+    public isEnableWorkflow:boolean = false;
+
+    /**
+     * 当前UI服务对应的数据服务对象
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */
+    public dataService:JobsInfoService = new JobsInfoService();
+
+    /**
+     * 所有关联视图
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */ 
+    public allViewMap: Map<string, Object> = new Map();
+
+    /**
+     * 状态值
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */ 
+    public stateValue: number = 0;
+
+    /**
+     * 状态属性
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */ 
+    public stateField: string = "";
+
+    /**
+     * 主状态属性集合
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */  
+    public mainStateFields:Array<any> = [];
+
+    /**
+     * 主状态集合Map
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */  
+    public allDeMainStateMap:Map<string,string> = new Map();
+
+    /**
+     * Creates an instance of  JobsInfoUIServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsInfoUIServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+        this.initViewMap();
+        this.initDeMainStateMap();
+    }
+
+    /**
+     * 初始化视图Map
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */  
+    public initViewMap(){
+    }
+
+    /**
+     * 初始化主状态集合
+     * 
+     * @memberof  JobsInfoUIServiceBase
+     */  
+    public initDeMainStateMap(){
+    }
+
+
+    /**
+     * 获取指定数据的重定向页面
+     * 
+     * @param srfkey 数据主键
+     * @param isEnableWorkflow  重定向视图是否需要处理流程中的数据
+     * @memberof  JobsInfoUIServiceBase
+     */
+    public async getRDAppView(srfkey:string,isEnableWorkflow:boolean){
+        this.isEnableWorkflow = isEnableWorkflow;
+        // 进行数据查询
+        let result:any = await this.dataService.Get({jobsinfo:srfkey});
+        const curData:any = result.data;
+        //判断当前数据模式,默认为true，todo
+        const iRealDEModel:boolean = true;
+
+        let bDataInWF:boolean = false;
+		let bWFMode:any = false;
+		// 计算数据模式
+		if (this.isEnableWorkflow) {
+			bDataInWF = await this.dataService.testDataInWF({stateValue:this.stateValue,stateField:this.stateField},curData);
+			if (bDataInWF) {
+				bDataInWF = true;
+				bWFMode = await this.dataService.testUserExistWorklist(null,curData);
+			}
+        }
+        let strPDTViewParam:string = await this.getDESDDEViewPDTParam(curData, bDataInWF, bWFMode);
+        //若不是当前数据模式，处理strPDTViewParam，todo
+
+        //查找视图
+
+        //返回视图
+        return this.allViewMap.get(strPDTViewParam);
+    }
+
+    /**
+	 * 获取实际的数据类型
+     * 
+     * @memberof  JobsInfoUIServiceBase
+	 */
+	public getRealDEType(entity:any){
+
+    }
+
+    /**
+     * 获取实体单数据实体视图预定义参数
+     * 
+     * @param curData 当前数据
+     * @param bDataInWF 是否有数据在工作流中
+     * @param bWFMode   是否工作流模式
+     * @memberof  JobsInfoUIServiceBase
+     */
+    public async getDESDDEViewPDTParam(curData:any, bDataInWF:boolean, bWFMode:boolean){
+        let strPDTParam:string = '';
+		if (bDataInWF) {
+			// 判断数据是否在流程中
+        }
+        //多表单，todo
+        const isEnableMultiForm:boolean = false;
+        const multiFormDEField:string|null =null;
+
+        if (isEnableMultiForm && multiFormDEField) {
+			const objFormValue:string = curData[multiFormDEField];
+			if(!Environment.isAppMode){
+				return 'MOBEDITVIEW'+objFormValue;
+			}
+			return 'EDITVIEW'+objFormValue;
+        }
+		if(!Environment.isAppMode){
+            if(this.getDEMainStateTag(curData)){
+                return `MOBEDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+            }
+			return 'MOBEDITVIEW:';
+        }
+        if(this.getDEMainStateTag(curData)){
+            return `EDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+        }
+		return 'EDITVIEW:';
+    }
+
+    /**
+     * 获取数据对象的主状态标识
+     * 
+     * @param curData 当前数据
+     * @memberof  JobsInfoUIServiceBase
+     */  
+    public async getDEMainStateTag(curData:any){
+        if(this.mainStateFields.length === 0) return null;
+
+        this.mainStateFields.forEach((singleMainField:any) =>{
+            if(!(singleMainField in curData)){
+                console.error(`当前数据对象不包含属性singleMainField，可能会发生错误`);
+            }
+        })
+
+        let strTag:String = "";
+        for (let i = 0; i <= 1; i++) {
+            let strTag:string = (curData[this.mainStateFields[0]])?(i == 0) ? curData[this.mainStateFields[0]] : "":"";
+            if (this.mainStateFields.length >= 2) {
+                for (let j = 0; j <= 1; j++) {
+                    let strTag2:string = (curData[this.mainStateFields[1]])?`${strTag}__${(j == 0) ? curData[this.mainStateFields[1]] : ""}`:strTag;
+                    if (this.mainStateFields.length >= 3) {
+                        for (let k = 0; k <= 1; k++) {
+                            let strTag3:string = (curData[this.mainStateFields[2]])?`${strTag2}__${(k == 0) ? curData[this.mainStateFields[2]] : ""}`:strTag2;
+                            // 判断是否存在
+                            return this.allDeMainStateMap.get(strTag3);
+                        }
+                    }else{
+                        return this.allDeMainStateMap.get(strTag2);
+                    }
+                }
+            }else{
+                return this.allDeMainStateMap.get(strTag);
+            }
+        }
+        return null;
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-info/jobs-info-ui-service.ts

+import JobsInfoUIServiceBase from './jobs-info-ui-service-base';
+
+/**
+ * 任务信息UI服务对象
+ *
+ * @export
+ * @class JobsInfoUIService
+ */
+export default class JobsInfoUIService extends JobsInfoUIServiceBase {
+
+    /**
+     * Creates an instance of  JobsInfoUIService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsInfoUIService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-lock/jobs-lock-ui-service-base.ts

+import { Environment } from '@/environments/environment';
+import { UIActionTool,Util } from '@/utils';
+import UIService from '../ui-service';
+import { Subject } from 'rxjs';
+import JobsLockService from '@/service/jobs-lock/jobs-lock-service';
+
+/**
+ * 任务锁UI服务对象基类
+ *
+ * @export
+ * @class JobsLockUIServiceBase
+ */
+export default class JobsLockUIServiceBase extends UIService {
+
+    /**
+     * 是否支持工作流
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */
+    public isEnableWorkflow:boolean = false;
+
+    /**
+     * 当前UI服务对应的数据服务对象
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */
+    public dataService:JobsLockService = new JobsLockService();
+
+    /**
+     * 所有关联视图
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */ 
+    public allViewMap: Map<string, Object> = new Map();
+
+    /**
+     * 状态值
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */ 
+    public stateValue: number = 0;
+
+    /**
+     * 状态属性
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */ 
+    public stateField: string = "";
+
+    /**
+     * 主状态属性集合
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */  
+    public mainStateFields:Array<any> = [];
+
+    /**
+     * 主状态集合Map
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */  
+    public allDeMainStateMap:Map<string,string> = new Map();
+
+    /**
+     * Creates an instance of  JobsLockUIServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLockUIServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+        this.initViewMap();
+        this.initDeMainStateMap();
+    }
+
+    /**
+     * 初始化视图Map
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */  
+    public initViewMap(){
+    }
+
+    /**
+     * 初始化主状态集合
+     * 
+     * @memberof  JobsLockUIServiceBase
+     */  
+    public initDeMainStateMap(){
+    }
+
+
+    /**
+     * 获取指定数据的重定向页面
+     * 
+     * @param srfkey 数据主键
+     * @param isEnableWorkflow  重定向视图是否需要处理流程中的数据
+     * @memberof  JobsLockUIServiceBase
+     */
+    public async getRDAppView(srfkey:string,isEnableWorkflow:boolean){
+        this.isEnableWorkflow = isEnableWorkflow;
+        // 进行数据查询
+        let result:any = await this.dataService.Get({jobslock:srfkey});
+        const curData:any = result.data;
+        //判断当前数据模式,默认为true，todo
+        const iRealDEModel:boolean = true;
+
+        let bDataInWF:boolean = false;
+		let bWFMode:any = false;
+		// 计算数据模式
+		if (this.isEnableWorkflow) {
+			bDataInWF = await this.dataService.testDataInWF({stateValue:this.stateValue,stateField:this.stateField},curData);
+			if (bDataInWF) {
+				bDataInWF = true;
+				bWFMode = await this.dataService.testUserExistWorklist(null,curData);
+			}
+        }
+        let strPDTViewParam:string = await this.getDESDDEViewPDTParam(curData, bDataInWF, bWFMode);
+        //若不是当前数据模式，处理strPDTViewParam，todo
+
+        //查找视图
+
+        //返回视图
+        return this.allViewMap.get(strPDTViewParam);
+    }
+
+    /**
+	 * 获取实际的数据类型
+     * 
+     * @memberof  JobsLockUIServiceBase
+	 */
+	public getRealDEType(entity:any){
+
+    }
+
+    /**
+     * 获取实体单数据实体视图预定义参数
+     * 
+     * @param curData 当前数据
+     * @param bDataInWF 是否有数据在工作流中
+     * @param bWFMode   是否工作流模式
+     * @memberof  JobsLockUIServiceBase
+     */
+    public async getDESDDEViewPDTParam(curData:any, bDataInWF:boolean, bWFMode:boolean){
+        let strPDTParam:string = '';
+		if (bDataInWF) {
+			// 判断数据是否在流程中
+        }
+        //多表单，todo
+        const isEnableMultiForm:boolean = false;
+        const multiFormDEField:string|null =null;
+
+        if (isEnableMultiForm && multiFormDEField) {
+			const objFormValue:string = curData[multiFormDEField];
+			if(!Environment.isAppMode){
+				return 'MOBEDITVIEW'+objFormValue;
+			}
+			return 'EDITVIEW'+objFormValue;
+        }
+		if(!Environment.isAppMode){
+            if(this.getDEMainStateTag(curData)){
+                return `MOBEDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+            }
+			return 'MOBEDITVIEW:';
+        }
+        if(this.getDEMainStateTag(curData)){
+            return `EDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+        }
+		return 'EDITVIEW:';
+    }
+
+    /**
+     * 获取数据对象的主状态标识
+     * 
+     * @param curData 当前数据
+     * @memberof  JobsLockUIServiceBase
+     */  
+    public async getDEMainStateTag(curData:any){
+        if(this.mainStateFields.length === 0) return null;
+
+        this.mainStateFields.forEach((singleMainField:any) =>{
+            if(!(singleMainField in curData)){
+                console.error(`当前数据对象不包含属性singleMainField，可能会发生错误`);
+            }
+        })
+
+        let strTag:String = "";
+        for (let i = 0; i <= 1; i++) {
+            let strTag:string = (curData[this.mainStateFields[0]])?(i == 0) ? curData[this.mainStateFields[0]] : "":"";
+            if (this.mainStateFields.length >= 2) {
+                for (let j = 0; j <= 1; j++) {
+                    let strTag2:string = (curData[this.mainStateFields[1]])?`${strTag}__${(j == 0) ? curData[this.mainStateFields[1]] : ""}`:strTag;
+                    if (this.mainStateFields.length >= 3) {
+                        for (let k = 0; k <= 1; k++) {
+                            let strTag3:string = (curData[this.mainStateFields[2]])?`${strTag2}__${(k == 0) ? curData[this.mainStateFields[2]] : ""}`:strTag2;
+                            // 判断是否存在
+                            return this.allDeMainStateMap.get(strTag3);
+                        }
+                    }else{
+                        return this.allDeMainStateMap.get(strTag2);
+                    }
+                }
+            }else{
+                return this.allDeMainStateMap.get(strTag);
+            }
+        }
+        return null;
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-lock/jobs-lock-ui-service.ts

+import JobsLockUIServiceBase from './jobs-lock-ui-service-base';
+
+/**
+ * 任务锁UI服务对象
+ *
+ * @export
+ * @class JobsLockUIService
+ */
+export default class JobsLockUIService extends JobsLockUIServiceBase {
+
+    /**
+     * Creates an instance of  JobsLockUIService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLockUIService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-log/jobs-log-ui-service-base.ts

+import { Environment } from '@/environments/environment';
+import { UIActionTool,Util } from '@/utils';
+import UIService from '../ui-service';
+import { Subject } from 'rxjs';
+import JobsLogService from '@/service/jobs-log/jobs-log-service';
+
+/**
+ * 任务调度日志UI服务对象基类
+ *
+ * @export
+ * @class JobsLogUIServiceBase
+ */
+export default class JobsLogUIServiceBase extends UIService {
+
+    /**
+     * 是否支持工作流
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */
+    public isEnableWorkflow:boolean = false;
+
+    /**
+     * 当前UI服务对应的数据服务对象
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */
+    public dataService:JobsLogService = new JobsLogService();
+
+    /**
+     * 所有关联视图
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */ 
+    public allViewMap: Map<string, Object> = new Map();
+
+    /**
+     * 状态值
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */ 
+    public stateValue: number = 0;
+
+    /**
+     * 状态属性
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */ 
+    public stateField: string = "";
+
+    /**
+     * 主状态属性集合
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */  
+    public mainStateFields:Array<any> = [];
+
+    /**
+     * 主状态集合Map
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */  
+    public allDeMainStateMap:Map<string,string> = new Map();
+
+    /**
+     * Creates an instance of  JobsLogUIServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLogUIServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+        this.initViewMap();
+        this.initDeMainStateMap();
+    }
+
+    /**
+     * 初始化视图Map
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */  
+    public initViewMap(){
+    }
+
+    /**
+     * 初始化主状态集合
+     * 
+     * @memberof  JobsLogUIServiceBase
+     */  
+    public initDeMainStateMap(){
+    }
+
+
+    /**
+     * 获取指定数据的重定向页面
+     * 
+     * @param srfkey 数据主键
+     * @param isEnableWorkflow  重定向视图是否需要处理流程中的数据
+     * @memberof  JobsLogUIServiceBase
+     */
+    public async getRDAppView(srfkey:string,isEnableWorkflow:boolean){
+        this.isEnableWorkflow = isEnableWorkflow;
+        // 进行数据查询
+        let result:any = await this.dataService.Get({jobslog:srfkey});
+        const curData:any = result.data;
+        //判断当前数据模式,默认为true，todo
+        const iRealDEModel:boolean = true;
+
+        let bDataInWF:boolean = false;
+		let bWFMode:any = false;
+		// 计算数据模式
+		if (this.isEnableWorkflow) {
+			bDataInWF = await this.dataService.testDataInWF({stateValue:this.stateValue,stateField:this.stateField},curData);
+			if (bDataInWF) {
+				bDataInWF = true;
+				bWFMode = await this.dataService.testUserExistWorklist(null,curData);
+			}
+        }
+        let strPDTViewParam:string = await this.getDESDDEViewPDTParam(curData, bDataInWF, bWFMode);
+        //若不是当前数据模式，处理strPDTViewParam，todo
+
+        //查找视图
+
+        //返回视图
+        return this.allViewMap.get(strPDTViewParam);
+    }
+
+    /**
+	 * 获取实际的数据类型
+     * 
+     * @memberof  JobsLogUIServiceBase
+	 */
+	public getRealDEType(entity:any){
+
+    }
+
+    /**
+     * 获取实体单数据实体视图预定义参数
+     * 
+     * @param curData 当前数据
+     * @param bDataInWF 是否有数据在工作流中
+     * @param bWFMode   是否工作流模式
+     * @memberof  JobsLogUIServiceBase
+     */
+    public async getDESDDEViewPDTParam(curData:any, bDataInWF:boolean, bWFMode:boolean){
+        let strPDTParam:string = '';
+		if (bDataInWF) {
+			// 判断数据是否在流程中
+        }
+        //多表单，todo
+        const isEnableMultiForm:boolean = false;
+        const multiFormDEField:string|null =null;
+
+        if (isEnableMultiForm && multiFormDEField) {
+			const objFormValue:string = curData[multiFormDEField];
+			if(!Environment.isAppMode){
+				return 'MOBEDITVIEW'+objFormValue;
+			}
+			return 'EDITVIEW'+objFormValue;
+        }
+		if(!Environment.isAppMode){
+            if(this.getDEMainStateTag(curData)){
+                return `MOBEDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+            }
+			return 'MOBEDITVIEW:';
+        }
+        if(this.getDEMainStateTag(curData)){
+            return `EDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+        }
+		return 'EDITVIEW:';
+    }
+
+    /**
+     * 获取数据对象的主状态标识
+     * 
+     * @param curData 当前数据
+     * @memberof  JobsLogUIServiceBase
+     */  
+    public async getDEMainStateTag(curData:any){
+        if(this.mainStateFields.length === 0) return null;
+
+        this.mainStateFields.forEach((singleMainField:any) =>{
+            if(!(singleMainField in curData)){
+                console.error(`当前数据对象不包含属性singleMainField，可能会发生错误`);
+            }
+        })
+
+        let strTag:String = "";
+        for (let i = 0; i <= 1; i++) {
+            let strTag:string = (curData[this.mainStateFields[0]])?(i == 0) ? curData[this.mainStateFields[0]] : "":"";
+            if (this.mainStateFields.length >= 2) {
+                for (let j = 0; j <= 1; j++) {
+                    let strTag2:string = (curData[this.mainStateFields[1]])?`${strTag}__${(j == 0) ? curData[this.mainStateFields[1]] : ""}`:strTag;
+                    if (this.mainStateFields.length >= 3) {
+                        for (let k = 0; k <= 1; k++) {
+                            let strTag3:string = (curData[this.mainStateFields[2]])?`${strTag2}__${(k == 0) ? curData[this.mainStateFields[2]] : ""}`:strTag2;
+                            // 判断是否存在
+                            return this.allDeMainStateMap.get(strTag3);
+                        }
+                    }else{
+                        return this.allDeMainStateMap.get(strTag2);
+                    }
+                }
+            }else{
+                return this.allDeMainStateMap.get(strTag);
+            }
+        }
+        return null;
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-log/jobs-log-ui-service.ts

+import JobsLogUIServiceBase from './jobs-log-ui-service-base';
+
+/**
+ * 任务调度日志UI服务对象
+ *
+ * @export
+ * @class JobsLogUIService
+ */
+export default class JobsLogUIService extends JobsLogUIServiceBase {
+
+    /**
+     * Creates an instance of  JobsLogUIService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsLogUIService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-registry/jobs-registry-ui-service-base.ts

+import { Environment } from '@/environments/environment';
+import { UIActionTool,Util } from '@/utils';
+import UIService from '../ui-service';
+import { Subject } from 'rxjs';
+import JobsRegistryService from '@/service/jobs-registry/jobs-registry-service';
+
+/**
+ * 任务注册信息UI服务对象基类
+ *
+ * @export
+ * @class JobsRegistryUIServiceBase
+ */
+export default class JobsRegistryUIServiceBase extends UIService {
+
+    /**
+     * 是否支持工作流
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */
+    public isEnableWorkflow:boolean = false;
+
+    /**
+     * 当前UI服务对应的数据服务对象
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */
+    public dataService:JobsRegistryService = new JobsRegistryService();
+
+    /**
+     * 所有关联视图
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */ 
+    public allViewMap: Map<string, Object> = new Map();
+
+    /**
+     * 状态值
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */ 
+    public stateValue: number = 0;
+
+    /**
+     * 状态属性
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */ 
+    public stateField: string = "";
+
+    /**
+     * 主状态属性集合
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */  
+    public mainStateFields:Array<any> = [];
+
+    /**
+     * 主状态集合Map
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */  
+    public allDeMainStateMap:Map<string,string> = new Map();
+
+    /**
+     * Creates an instance of  JobsRegistryUIServiceBase.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsRegistryUIServiceBase
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+        this.initViewMap();
+        this.initDeMainStateMap();
+    }
+
+    /**
+     * 初始化视图Map
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */  
+    public initViewMap(){
+    }
+
+    /**
+     * 初始化主状态集合
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+     */  
+    public initDeMainStateMap(){
+    }
+
+
+    /**
+     * 获取指定数据的重定向页面
+     * 
+     * @param srfkey 数据主键
+     * @param isEnableWorkflow  重定向视图是否需要处理流程中的数据
+     * @memberof  JobsRegistryUIServiceBase
+     */
+    public async getRDAppView(srfkey:string,isEnableWorkflow:boolean){
+        this.isEnableWorkflow = isEnableWorkflow;
+        // 进行数据查询
+        let result:any = await this.dataService.Get({jobsregistry:srfkey});
+        const curData:any = result.data;
+        //判断当前数据模式,默认为true，todo
+        const iRealDEModel:boolean = true;
+
+        let bDataInWF:boolean = false;
+		let bWFMode:any = false;
+		// 计算数据模式
+		if (this.isEnableWorkflow) {
+			bDataInWF = await this.dataService.testDataInWF({stateValue:this.stateValue,stateField:this.stateField},curData);
+			if (bDataInWF) {
+				bDataInWF = true;
+				bWFMode = await this.dataService.testUserExistWorklist(null,curData);
+			}
+        }
+        let strPDTViewParam:string = await this.getDESDDEViewPDTParam(curData, bDataInWF, bWFMode);
+        //若不是当前数据模式，处理strPDTViewParam，todo
+
+        //查找视图
+
+        //返回视图
+        return this.allViewMap.get(strPDTViewParam);
+    }
+
+    /**
+	 * 获取实际的数据类型
+     * 
+     * @memberof  JobsRegistryUIServiceBase
+	 */
+	public getRealDEType(entity:any){
+
+    }
+
+    /**
+     * 获取实体单数据实体视图预定义参数
+     * 
+     * @param curData 当前数据
+     * @param bDataInWF 是否有数据在工作流中
+     * @param bWFMode   是否工作流模式
+     * @memberof  JobsRegistryUIServiceBase
+     */
+    public async getDESDDEViewPDTParam(curData:any, bDataInWF:boolean, bWFMode:boolean){
+        let strPDTParam:string = '';
+		if (bDataInWF) {
+			// 判断数据是否在流程中
+        }
+        //多表单，todo
+        const isEnableMultiForm:boolean = false;
+        const multiFormDEField:string|null =null;
+
+        if (isEnableMultiForm && multiFormDEField) {
+			const objFormValue:string = curData[multiFormDEField];
+			if(!Environment.isAppMode){
+				return 'MOBEDITVIEW'+objFormValue;
+			}
+			return 'EDITVIEW'+objFormValue;
+        }
+		if(!Environment.isAppMode){
+            if(this.getDEMainStateTag(curData)){
+                return `MOBEDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+            }
+			return 'MOBEDITVIEW:';
+        }
+        if(this.getDEMainStateTag(curData)){
+            return `EDITVIEW:MSTAG:${ await this.getDEMainStateTag(curData)}`;
+        }
+		return 'EDITVIEW:';
+    }
+
+    /**
+     * 获取数据对象的主状态标识
+     * 
+     * @param curData 当前数据
+     * @memberof  JobsRegistryUIServiceBase
+     */  
+    public async getDEMainStateTag(curData:any){
+        if(this.mainStateFields.length === 0) return null;
+
+        this.mainStateFields.forEach((singleMainField:any) =>{
+            if(!(singleMainField in curData)){
+                console.error(`当前数据对象不包含属性singleMainField，可能会发生错误`);
+            }
+        })
+
+        let strTag:String = "";
+        for (let i = 0; i <= 1; i++) {
+            let strTag:string = (curData[this.mainStateFields[0]])?(i == 0) ? curData[this.mainStateFields[0]] : "":"";
+            if (this.mainStateFields.length >= 2) {
+                for (let j = 0; j <= 1; j++) {
+                    let strTag2:string = (curData[this.mainStateFields[1]])?`${strTag}__${(j == 0) ? curData[this.mainStateFields[1]] : ""}`:strTag;
+                    if (this.mainStateFields.length >= 3) {
+                        for (let k = 0; k <= 1; k++) {
+                            let strTag3:string = (curData[this.mainStateFields[2]])?`${strTag2}__${(k == 0) ? curData[this.mainStateFields[2]] : ""}`:strTag2;
+                            // 判断是否存在
+                            return this.allDeMainStateMap.get(strTag3);
+                        }
+                    }else{
+                        return this.allDeMainStateMap.get(strTag2);
+                    }
+                }
+            }else{
+                return this.allDeMainStateMap.get(strTag);
+            }
+        }
+        return null;
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/jobs-registry/jobs-registry-ui-service.ts

+import JobsRegistryUIServiceBase from './jobs-registry-ui-service-base';
+
+/**
+ * 任务注册信息UI服务对象
+ *
+ * @export
+ * @class JobsRegistryUIService
+ */
+export default class JobsRegistryUIService extends JobsRegistryUIServiceBase {
+
+    /**
+     * Creates an instance of  JobsRegistryUIService.
+     * 
+     * @param {*} [opts={}]
+     * @memberof  JobsRegistryUIService
+     */
+    constructor(opts: any = {}) {
+        super(opts);
+    }
+
+}
\ No newline at end of file

app_web/src/uiservice/ui-service-register.ts

@@ -39,10 +39,10 @@ export class UIServiceRegister {
      * @memberof UIServiceRegister
      */
     protected init(): void {
-                this.allUIService.set('jobinfo', () => import('@/uiservice/jobinfo/jobinfo-ui-service'));
-        this.allUIService.set('joblog', () => import('@/uiservice/joblog/joblog-ui-service'));
-        this.allUIService.set('joblock', () => import('@/uiservice/joblock/joblock-ui-service'));
-        this.allUIService.set('jobregistry', () => import('@/uiservice/jobregistry/jobregistry-ui-service'));
+                this.allUIService.set('jobsinfo', () => import('@/uiservice/jobs-info/jobs-info-ui-service'));
+        this.allUIService.set('jobslog', () => import('@/uiservice/jobs-log/jobs-log-ui-service'));
+        this.allUIService.set('jobslock', () => import('@/uiservice/jobs-lock/jobs-lock-ui-service'));
+        this.allUIService.set('jobsregistry', () => import('@/uiservice/jobs-registry/jobs-registry-ui-service'));
     }
 
     /**

ibztask-app/ibztask-app-web/src/main/resources/application-web-prod.yml

@@ -4,19 +4,19 @@ server:
 zuul:
   routes:
     jobs_info:
-      path: /jobinfos/**
+      path: /jobsinfos/**
       serviceId: ibztask-api
       stripPrefix: false
     jobs_log:
-      path: /joblogs/**
+      path: /jobslogs/**
       serviceId: ibztask-api
       stripPrefix: false
     jobs_lock:
-      path: /joblocks/**
+      path: /jobslocks/**
       serviceId: ibztask-api
       stripPrefix: false
     jobs_registry:
-      path: /jobregistries/**
+      path: /jobsregistries/**
       serviceId: ibztask-api
       stripPrefix: false
     loginv7:

ibztask-core/src/main/java/cn/ibizlab/core/task/domain/JobsInfo.java

+package cn.ibizlab.core.task.domain;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.math.BigInteger;
+import java.util.HashMap;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.DigestUtils;
+import cn.ibizlab.util.domain.EntityBase;
+import cn.ibizlab.util.annotation.DEField;
+import cn.ibizlab.util.enums.DEPredefinedFieldType;
+import cn.ibizlab.util.enums.DEFieldDefaultValueType;
+import java.io.Serializable;
+import lombok.*;
+import org.springframework.data.annotation.Transient;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.ibizlab.util.domain.EntityMP;
+
+/**
+ * 实体[任务信息]
+ */
+@Getter
+@Setter
+@NoArgsConstructor
+@JsonIgnoreProperties(value = "handler")
+@TableName(value = "JOBS_INFO",resultMap = "JobsInfoResultMap")
+public class JobsInfo extends EntityMP implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @DEField(isKeyField=true)
+    @TableId(value= "id",type=IdType.UUID)
+    @JSONField(name = "id")
+    @JsonProperty("id")
+    private BigInteger id;
+    /**
+     * 租户ID
+     */
+    @DEField(name = "tenant_id")
+    @TableField(value = "tenant_id")
+    @JSONField(name = "tenant_id")
+    @JsonProperty("tenant_id")
+    private String tenantId;
+    /**
+     * 服务名
+     */
+    @TableField(value = "app")
+    @JSONField(name = "app")
+    @JsonProperty("app")
+    private String app;
+    /**
+     * 任务执行CRON
+     */
+    @TableField(value = "cron")
+    @JSONField(name = "cron")
+    @JsonProperty("cron")
+    private String cron;
+    /**
+     * 执行器任务HANDLER
+     */
+    @TableField(value = "handler")
+    @JSONField(name = "handler")
+    @JsonProperty("handler")
+    private String handler;
+    /**
+     * 执行器任务参数
+     */
+    @TableField(value = "param")
+    @JSONField(name = "param")
+    @JsonProperty("param")
+    private String param;
+    /**
+     * 任务执行超时时间（秒）
+     */
+    @DEField(defaultValue = "0")
+    @TableField(value = "timeout")
+    @JSONField(name = "timeout")
+    @JsonProperty("timeout")
+    private Integer timeout;
+    /**
+     * 失败重试次数
+     */
+    @DEField(defaultValue = "0")
+    @TableField(value = "fail_retry_count")
+    @JSONField(name = "fail_retry_count")
+    @JsonProperty("fail_retry_count")
+    private Integer failRetryCount;
+    /**
+     * 上次调度时间
+     */
+    @DEField(name = "last_time")
+    @TableField(value = "last_time")
+    @JSONField(name = "last_time")
+    @JsonProperty("last_time")
+    private BigInteger lastTime;
+    /**
+     * 下次调度时间
+     */
+    @DEField(name = "next_time")
+    @TableField(value = "next_time")
+    @JSONField(name = "next_time")
+    @JsonProperty("next_time")
+    private BigInteger nextTime;
+    /**
+     * 所有者
+     */
+    @TableField(value = "author")
+    @JSONField(name = "author")
+    @JsonProperty("author")
+    private String author;
+    /**
+     * 备注
+     */
+    @TableField(value = "remark")
+    @JSONField(name = "remark")
+    @JsonProperty("remark")
+    private String remark;
+    /**
+     * 状态（0、启用 1、已禁用）
+     */
+    @TableField(value = "status")
+    @JSONField(name = "status")
+    @JsonProperty("status")
+    private Integer status;
+    /**
+     * 更新时间
+     */
+    @DEField(name = "update_time")
+    @TableField(value = "update_time")
+    @JSONField(name = "update_time")
+    @JsonProperty("update_time")
+    private BigInteger updateTime;
+    /**
+     * 创建时间
+     */
+    @DEField(name = "create_time")
+    @TableField(value = "create_time")
+    @JSONField(name = "create_time")
+    @JsonProperty("create_time")
+    private BigInteger createTime;
+
+
+
+    /**
+     * 设置 [租户ID]
+     */
+    public void setTenantId(String tenantId){
+        this.tenantId = tenantId ;
+        this.modify("tenant_id",tenantId);
+    }
+
+    /**
+     * 设置 [服务名]
+     */
+    public void setApp(String app){
+        this.app = app ;
+        this.modify("app",app);
+    }
+
+    /**
+     * 设置 [任务执行CRON]
+     */
+    public void setCron(String cron){
+        this.cron = cron ;
+        this.modify("cron",cron);
+    }
+
+    /**
+     * 设置 [执行器任务HANDLER]
+     */
+    public void setHandler(String handler){
+        this.handler = handler ;
+        this.modify("handler",handler);
+    }
+
+    /**
+     * 设置 [执行器任务参数]
+     */
+    public void setParam(String param){
+        this.param = param ;
+        this.modify("param",param);
+    }
+
+    /**
+     * 设置 [任务执行超时时间（秒）]
+     */
+    public void setTimeout(Integer timeout){
+        this.timeout = timeout ;
+        this.modify("timeout",timeout);
+    }
+
+    /**
+     * 设置 [失败重试次数]
+     */
+    public void setFailRetryCount(Integer failRetryCount){
+        this.failRetryCount = failRetryCount ;
+        this.modify("fail_retry_count",failRetryCount);
+    }
+
+    /**
+     * 设置 [上次调度时间]
+     */
+    public void setLastTime(BigInteger lastTime){
+        this.lastTime = lastTime ;
+        this.modify("last_time",lastTime);
+    }
+
+    /**
+     * 设置 [下次调度时间]
+     */
+    public void setNextTime(BigInteger nextTime){
+        this.nextTime = nextTime ;
+        this.modify("next_time",nextTime);
+    }
+
+    /**
+     * 设置 [所有者]
+     */
+    public void setAuthor(String author){
+        this.author = author ;
+        this.modify("author",author);
+    }
+
+    /**
+     * 设置 [备注]
+     */
+    public void setRemark(String remark){
+        this.remark = remark ;
+        this.modify("remark",remark);
+    }
+
+    /**
+     * 设置 [状态（0、启用 1、已禁用）]
+     */
+    public void setStatus(Integer status){
+        this.status = status ;
+        this.modify("status",status);
+    }
+
+    /**
+     * 设置 [更新时间]
+     */
+    public void setUpdateTime(BigInteger updateTime){
+        this.updateTime = updateTime ;
+        this.modify("update_time",updateTime);
+    }
+
+    /**
+     * 设置 [创建时间]
+     */
+    public void setCreateTime(BigInteger createTime){
+        this.createTime = createTime ;
+        this.modify("create_time",createTime);
+    }
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/domain/JobsLock.java

+package cn.ibizlab.core.task.domain;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.math.BigInteger;
+import java.util.HashMap;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.DigestUtils;
+import cn.ibizlab.util.domain.EntityBase;
+import cn.ibizlab.util.annotation.DEField;
+import cn.ibizlab.util.enums.DEPredefinedFieldType;
+import cn.ibizlab.util.enums.DEFieldDefaultValueType;
+import java.io.Serializable;
+import lombok.*;
+import org.springframework.data.annotation.Transient;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.ibizlab.util.domain.EntityMP;
+
+/**
+ * 实体[任务锁]
+ */
+@Getter
+@Setter
+@NoArgsConstructor
+@JsonIgnoreProperties(value = "handler")
+@TableName(value = "JOBS_LOCK",resultMap = "JobsLockResultMap")
+public class JobsLock extends EntityMP implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @DEField(isKeyField=true)
+    @TableId(value= "id",type=IdType.UUID)
+    @JSONField(name = "id")
+    @JsonProperty("id")
+    private BigInteger id;
+    /**
+     * 创建时间
+     */
+    @DEField(name = "create_time")
+    @TableField(value = "create_time")
+    @JSONField(name = "create_time")
+    @JsonProperty("create_time")
+    private BigInteger createTime;
+
+
+
+    /**
+     * 设置 [创建时间]
+     */
+    public void setCreateTime(BigInteger createTime){
+        this.createTime = createTime ;
+        this.modify("create_time",createTime);
+    }
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/domain/JobsLog.java

+package cn.ibizlab.core.task.domain;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.math.BigInteger;
+import java.util.HashMap;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.DigestUtils;
+import cn.ibizlab.util.domain.EntityBase;
+import cn.ibizlab.util.annotation.DEField;
+import cn.ibizlab.util.enums.DEPredefinedFieldType;
+import cn.ibizlab.util.enums.DEFieldDefaultValueType;
+import java.io.Serializable;
+import lombok.*;
+import org.springframework.data.annotation.Transient;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.ibizlab.util.domain.EntityMP;
+
+/**
+ * 实体[任务调度日志]
+ */
+@Getter
+@Setter
+@NoArgsConstructor
+@JsonIgnoreProperties(value = "handler")
+@TableName(value = "JOBS_LOG",resultMap = "JobsLogResultMap")
+public class JobsLog extends EntityMP implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @DEField(isKeyField=true)
+    @TableId(value= "id",type=IdType.UUID)
+    @JSONField(name = "id")
+    @JsonProperty("id")
+    private BigInteger id;
+    /**
+     * 任务ID
+     */
+    @DEField(name = "job_id")
+    @TableField(value = "job_id")
+    @JSONField(name = "job_id")
+    @JsonProperty("job_id")
+    private BigInteger jobId;
+    /**
+     * 执行地址
+     */
+    @TableField(value = "address")
+    @JSONField(name = "address")
+    @JsonProperty("address")
+    private String address;
+    /**
+     * 执行器任务HANDLER
+     */
+    @TableField(value = "handler")
+    @JSONField(name = "handler")
+    @JsonProperty("handler")
+    private String handler;
+    /**
+     * 执行器任务参数
+     */
+    @TableField(value = "param")
+    @JSONField(name = "param")
+    @JsonProperty("param")
+    private String param;
+    /**
+     * 失败重试次数
+     */
+    @DEField(defaultValue = "0")
+    @TableField(value = "fail_retry_count")
+    @JSONField(name = "fail_retry_count")
+    @JsonProperty("fail_retry_count")
+    private Integer failRetryCount;
+    /**
+     * 触发器调度返回码
+     */
+    @DEField(defaultValue = "0")
+    @TableField(value = "trigger_code")
+    @JSONField(name = "trigger_code")
+    @JsonProperty("trigger_code")
+    private Integer triggerCode;
+    /**
+     * 触发器调度类型
+     */
+    @DEField(name = "trigger_type")
+    @TableField(value = "trigger_type")
+    @JSONField(name = "trigger_type")
+    @JsonProperty("trigger_type")
+    private String triggerType;
+    /**
+     * 触发器调度类型
+     */
+    @DEField(name = "trigger_msg")
+    @TableField(value = "trigger_msg")
+    @JSONField(name = "trigger_msg")
+    @JsonProperty("trigger_msg")
+    private String triggerMsg;
+    /**
+     * 创建时间
+     */
+    @DEField(name = "create_time")
+    @TableField(value = "create_time")
+    @JSONField(name = "create_time")
+    @JsonProperty("create_time")
+    private BigInteger createTime;
+
+
+
+    /**
+     * 设置 [任务ID]
+     */
+    public void setJobId(BigInteger jobId){
+        this.jobId = jobId ;
+        this.modify("job_id",jobId);
+    }
+
+    /**
+     * 设置 [执行地址]
+     */
+    public void setAddress(String address){
+        this.address = address ;
+        this.modify("address",address);
+    }
+
+    /**
+     * 设置 [执行器任务HANDLER]
+     */
+    public void setHandler(String handler){
+        this.handler = handler ;
+        this.modify("handler",handler);
+    }
+
+    /**
+     * 设置 [执行器任务参数]
+     */
+    public void setParam(String param){
+        this.param = param ;
+        this.modify("param",param);
+    }
+
+    /**
+     * 设置 [失败重试次数]
+     */
+    public void setFailRetryCount(Integer failRetryCount){
+        this.failRetryCount = failRetryCount ;
+        this.modify("fail_retry_count",failRetryCount);
+    }
+
+    /**
+     * 设置 [触发器调度返回码]
+     */
+    public void setTriggerCode(Integer triggerCode){
+        this.triggerCode = triggerCode ;
+        this.modify("trigger_code",triggerCode);
+    }
+
+    /**
+     * 设置 [触发器调度类型]
+     */
+    public void setTriggerType(String triggerType){
+        this.triggerType = triggerType ;
+        this.modify("trigger_type",triggerType);
+    }
+
+    /**
+     * 设置 [触发器调度类型]
+     */
+    public void setTriggerMsg(String triggerMsg){
+        this.triggerMsg = triggerMsg ;
+        this.modify("trigger_msg",triggerMsg);
+    }
+
+    /**
+     * 设置 [创建时间]
+     */
+    public void setCreateTime(BigInteger createTime){
+        this.createTime = createTime ;
+        this.modify("create_time",createTime);
+    }
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/domain/JobsRegistry.java

+package cn.ibizlab.core.task.domain;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.math.BigInteger;
+import java.util.HashMap;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.DigestUtils;
+import cn.ibizlab.util.domain.EntityBase;
+import cn.ibizlab.util.annotation.DEField;
+import cn.ibizlab.util.enums.DEPredefinedFieldType;
+import cn.ibizlab.util.enums.DEFieldDefaultValueType;
+import java.io.Serializable;
+import lombok.*;
+import org.springframework.data.annotation.Transient;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.ibizlab.util.domain.EntityMP;
+
+/**
+ * 实体[任务注册信息]
+ */
+@Getter
+@Setter
+@NoArgsConstructor
+@JsonIgnoreProperties(value = "handler")
+@TableName(value = "JOBS_REGISTRY",resultMap = "JobsRegistryResultMap")
+public class JobsRegistry extends EntityMP implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @DEField(isKeyField=true)
+    @TableId(value= "id",type=IdType.UUID)
+    @JSONField(name = "id")
+    @JsonProperty("id")
+    private BigInteger id;
+    /**
+     * 服务名
+     */
+    @TableField(value = "app")
+    @JSONField(name = "app")
+    @JsonProperty("app")
+    private String app;
+    /**
+     * 执行地址
+     */
+    @TableField(value = "address")
+    @JSONField(name = "address")
+    @JsonProperty("address")
+    private String address;
+    /**
+     * 状态（0、启用 1、已禁用）
+     */
+    @TableField(value = "status")
+    @JSONField(name = "status")
+    @JsonProperty("status")
+    private Integer status;
+    /**
+     * 更新时间
+     */
+    @DEField(name = "update_time")
+    @TableField(value = "update_time")
+    @JSONField(name = "update_time")
+    @JsonProperty("update_time")
+    private BigInteger updateTime;
+
+
+
+    /**
+     * 设置 [服务名]
+     */
+    public void setApp(String app){
+        this.app = app ;
+        this.modify("app",app);
+    }
+
+    /**
+     * 设置 [执行地址]
+     */
+    public void setAddress(String address){
+        this.address = address ;
+        this.modify("address",address);
+    }
+
+    /**
+     * 设置 [状态（0、启用 1、已禁用）]
+     */
+    public void setStatus(Integer status){
+        this.status = status ;
+        this.modify("status",status);
+    }
+
+    /**
+     * 设置 [更新时间]
+     */
+    public void setUpdateTime(BigInteger updateTime){
+        this.updateTime = updateTime ;
+        this.modify("update_time",updateTime);
+    }
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/filter/JobsInfoSearchContext.java

+package cn.ibizlab.core.task.filter;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.*;
+import lombok.extern.slf4j.Slf4j;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+
+
+import cn.ibizlab.util.filter.QueryWrapperContext;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import cn.ibizlab.core.task.domain.JobsInfo;
+/**
+ * 关系型数据实体[JobsInfo] 查询条件对象
+ */
+@Slf4j
+@Data
+public class JobsInfoSearchContext extends QueryWrapperContext<JobsInfo> {
+
+
+    /**
+	 * 启用快速搜索
+	 */
+	public void setQuery(String query)
+	{
+		 this.query=query;
+		 if(!StringUtils.isEmpty(query)){
+            this.getSearchCond().and( wrapper ->
+                     wrapper.like("app", query)   
+            );
+		 }
+	}
+}
+
+
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/filter/JobsLockSearchContext.java

+package cn.ibizlab.core.task.filter;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.*;
+import lombok.extern.slf4j.Slf4j;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+
+
+import cn.ibizlab.util.filter.QueryWrapperContext;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import cn.ibizlab.core.task.domain.JobsLock;
+/**
+ * 关系型数据实体[JobsLock] 查询条件对象
+ */
+@Slf4j
+@Data
+public class JobsLockSearchContext extends QueryWrapperContext<JobsLock> {
+
+
+    /**
+	 * 启用快速搜索
+	 */
+	public void setQuery(String query)
+	{
+		 this.query=query;
+		 if(!StringUtils.isEmpty(query)){
+		 }
+	}
+}
+
+
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/filter/JobsLogSearchContext.java

+package cn.ibizlab.core.task.filter;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.*;
+import lombok.extern.slf4j.Slf4j;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+
+
+import cn.ibizlab.util.filter.QueryWrapperContext;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import cn.ibizlab.core.task.domain.JobsLog;
+/**
+ * 关系型数据实体[JobsLog] 查询条件对象
+ */
+@Slf4j
+@Data
+public class JobsLogSearchContext extends QueryWrapperContext<JobsLog> {
+
+
+    /**
+	 * 启用快速搜索
+	 */
+	public void setQuery(String query)
+	{
+		 this.query=query;
+		 if(!StringUtils.isEmpty(query)){
+		 }
+	}
+}
+
+
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/filter/JobsRegistrySearchContext.java

+package cn.ibizlab.core.task.filter;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.*;
+import lombok.extern.slf4j.Slf4j;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.fastjson.annotation.JSONField;
+
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+
+
+import cn.ibizlab.util.filter.QueryWrapperContext;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import cn.ibizlab.core.task.domain.JobsRegistry;
+/**
+ * 关系型数据实体[JobsRegistry] 查询条件对象
+ */
+@Slf4j
+@Data
+public class JobsRegistrySearchContext extends QueryWrapperContext<JobsRegistry> {
+
+	private String n_app_like;//[服务名]
+	public void setN_app_like(String n_app_like) {
+        this.n_app_like = n_app_like;
+        if(!ObjectUtils.isEmpty(this.n_app_like)){
+            this.getSearchCond().like("app", n_app_like);
+        }
+    }
+
+    /**
+	 * 启用快速搜索
+	 */
+	public void setQuery(String query)
+	{
+		 this.query=query;
+		 if(!StringUtils.isEmpty(query)){
+            this.getSearchCond().and( wrapper ->
+                     wrapper.like("app", query)   
+            );
+		 }
+	}
+}
+
+
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/mapper/JobsInfoMapper.java

+package cn.ibizlab.core.task.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.*;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import java.util.HashMap;
+import org.apache.ibatis.annotations.Select;
+import cn.ibizlab.core.task.domain.JobsInfo;
+import cn.ibizlab.core.task.filter.JobsInfoSearchContext;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import java.io.Serializable;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.alibaba.fastjson.JSONObject;
+
+public interface JobsInfoMapper extends BaseMapper<JobsInfo>{
+
+    Page<JobsInfo> searchDefault(IPage page, @Param("srf") JobsInfoSearchContext context, @Param("ew") Wrapper<JobsInfo> wrapper) ;
+    @Override
+    JobsInfo selectById(Serializable id);
+    @Override
+    int insert(JobsInfo entity);
+    @Override
+    int updateById(@Param(Constants.ENTITY) JobsInfo entity);
+    @Override
+    int update(@Param(Constants.ENTITY) JobsInfo entity, @Param("ew") Wrapper<JobsInfo> updateWrapper);
+    @Override
+    int deleteById(Serializable id);
+     /**
+      * 自定义查询SQL
+      * @param sql
+      * @return
+      */
+     @Select("${sql}")
+     List<JSONObject> selectBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义更新SQL
+    * @param sql
+    * @return
+    */
+    @Update("${sql}")
+    boolean updateBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义插入SQL
+    * @param sql
+    * @return
+    */
+    @Insert("${sql}")
+    boolean insertBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义删除SQL
+    * @param sql
+    * @return
+    */
+    @Delete("${sql}")
+    boolean deleteBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+}

ibztask-core/src/main/java/cn/ibizlab/core/task/mapper/JobsLockMapper.java

+package cn.ibizlab.core.task.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.*;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import java.util.HashMap;
+import org.apache.ibatis.annotations.Select;
+import cn.ibizlab.core.task.domain.JobsLock;
+import cn.ibizlab.core.task.filter.JobsLockSearchContext;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import java.io.Serializable;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.alibaba.fastjson.JSONObject;
+
+public interface JobsLockMapper extends BaseMapper<JobsLock>{
+
+    Page<JobsLock> searchDefault(IPage page, @Param("srf") JobsLockSearchContext context, @Param("ew") Wrapper<JobsLock> wrapper) ;
+    @Override
+    JobsLock selectById(Serializable id);
+    @Override
+    int insert(JobsLock entity);
+    @Override
+    int updateById(@Param(Constants.ENTITY) JobsLock entity);
+    @Override
+    int update(@Param(Constants.ENTITY) JobsLock entity, @Param("ew") Wrapper<JobsLock> updateWrapper);
+    @Override
+    int deleteById(Serializable id);
+     /**
+      * 自定义查询SQL
+      * @param sql
+      * @return
+      */
+     @Select("${sql}")
+     List<JSONObject> selectBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义更新SQL
+    * @param sql
+    * @return
+    */
+    @Update("${sql}")
+    boolean updateBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义插入SQL
+    * @param sql
+    * @return
+    */
+    @Insert("${sql}")
+    boolean insertBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义删除SQL
+    * @param sql
+    * @return
+    */
+    @Delete("${sql}")
+    boolean deleteBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+}

ibztask-core/src/main/java/cn/ibizlab/core/task/mapper/JobsLogMapper.java

+package cn.ibizlab.core.task.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.*;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import java.util.HashMap;
+import org.apache.ibatis.annotations.Select;
+import cn.ibizlab.core.task.domain.JobsLog;
+import cn.ibizlab.core.task.filter.JobsLogSearchContext;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import java.io.Serializable;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.alibaba.fastjson.JSONObject;
+
+public interface JobsLogMapper extends BaseMapper<JobsLog>{
+
+    Page<JobsLog> searchDefault(IPage page, @Param("srf") JobsLogSearchContext context, @Param("ew") Wrapper<JobsLog> wrapper) ;
+    @Override
+    JobsLog selectById(Serializable id);
+    @Override
+    int insert(JobsLog entity);
+    @Override
+    int updateById(@Param(Constants.ENTITY) JobsLog entity);
+    @Override
+    int update(@Param(Constants.ENTITY) JobsLog entity, @Param("ew") Wrapper<JobsLog> updateWrapper);
+    @Override
+    int deleteById(Serializable id);
+     /**
+      * 自定义查询SQL
+      * @param sql
+      * @return
+      */
+     @Select("${sql}")
+     List<JSONObject> selectBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义更新SQL
+    * @param sql
+    * @return
+    */
+    @Update("${sql}")
+    boolean updateBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义插入SQL
+    * @param sql
+    * @return
+    */
+    @Insert("${sql}")
+    boolean insertBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义删除SQL
+    * @param sql
+    * @return
+    */
+    @Delete("${sql}")
+    boolean deleteBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+}

ibztask-core/src/main/java/cn/ibizlab/core/task/mapper/JobsRegistryMapper.java

+package cn.ibizlab.core.task.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.*;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import java.util.HashMap;
+import org.apache.ibatis.annotations.Select;
+import cn.ibizlab.core.task.domain.JobsRegistry;
+import cn.ibizlab.core.task.filter.JobsRegistrySearchContext;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import java.io.Serializable;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.alibaba.fastjson.JSONObject;
+
+public interface JobsRegistryMapper extends BaseMapper<JobsRegistry>{
+
+    Page<JobsRegistry> searchDefault(IPage page, @Param("srf") JobsRegistrySearchContext context, @Param("ew") Wrapper<JobsRegistry> wrapper) ;
+    @Override
+    JobsRegistry selectById(Serializable id);
+    @Override
+    int insert(JobsRegistry entity);
+    @Override
+    int updateById(@Param(Constants.ENTITY) JobsRegistry entity);
+    @Override
+    int update(@Param(Constants.ENTITY) JobsRegistry entity, @Param("ew") Wrapper<JobsRegistry> updateWrapper);
+    @Override
+    int deleteById(Serializable id);
+     /**
+      * 自定义查询SQL
+      * @param sql
+      * @return
+      */
+     @Select("${sql}")
+     List<JSONObject> selectBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义更新SQL
+    * @param sql
+    * @return
+    */
+    @Update("${sql}")
+    boolean updateBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义插入SQL
+    * @param sql
+    * @return
+    */
+    @Insert("${sql}")
+    boolean insertBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+    /**
+    * 自定义删除SQL
+    * @param sql
+    * @return
+    */
+    @Delete("${sql}")
+    boolean deleteBySQL(@Param("sql") String sql, @Param("et")Map param);
+
+}

ibztask-core/src/main/java/cn/ibizlab/core/task/service/IJobsInfoService.java

+package cn.ibizlab.core.task.service;
+
+import java.io.Serializable;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collection;
+import java.math.BigInteger;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cache.annotation.CacheEvict;
+
+import cn.ibizlab.core.task.domain.JobsInfo;
+import cn.ibizlab.core.task.filter.JobsInfoSearchContext;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * 实体[JobsInfo] 服务对象接口
+ */
+public interface IJobsInfoService extends IService<JobsInfo>{
+
+    boolean update(JobsInfo et) ;
+    void updateBatch(List<JobsInfo> list) ;
+    boolean checkKey(JobsInfo et) ;
+    boolean save(JobsInfo et) ;
+    void saveBatch(List<JobsInfo> list) ;
+    JobsInfo getDraft(JobsInfo et) ;
+    boolean remove(BigInteger key) ;
+    void removeBatch(Collection<BigInteger> idList) ;
+    JobsInfo get(BigInteger key) ;
+    boolean create(JobsInfo et) ;
+    void createBatch(List<JobsInfo> list) ;
+    Page<JobsInfo> searchDefault(JobsInfoSearchContext context) ;
+    /**
+     *自定义查询SQL
+     * @param sql  select * from table where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return select * from table where id = '1'
+     */
+    List<JSONObject> select(String sql, Map param);
+    /**
+     *自定义SQL
+     * @param sql  update table  set name ='test' where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return     update table  set name ='test' where id = '1'
+     */
+    boolean execute(String sql, Map param);
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/service/IJobsLockService.java

+package cn.ibizlab.core.task.service;
+
+import java.io.Serializable;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collection;
+import java.math.BigInteger;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cache.annotation.CacheEvict;
+
+import cn.ibizlab.core.task.domain.JobsLock;
+import cn.ibizlab.core.task.filter.JobsLockSearchContext;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * 实体[JobsLock] 服务对象接口
+ */
+public interface IJobsLockService extends IService<JobsLock>{
+
+    boolean create(JobsLock et) ;
+    void createBatch(List<JobsLock> list) ;
+    boolean save(JobsLock et) ;
+    void saveBatch(List<JobsLock> list) ;
+    JobsLock get(BigInteger key) ;
+    boolean update(JobsLock et) ;
+    void updateBatch(List<JobsLock> list) ;
+    boolean checkKey(JobsLock et) ;
+    boolean remove(BigInteger key) ;
+    void removeBatch(Collection<BigInteger> idList) ;
+    JobsLock getDraft(JobsLock et) ;
+    Page<JobsLock> searchDefault(JobsLockSearchContext context) ;
+    /**
+     *自定义查询SQL
+     * @param sql  select * from table where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return select * from table where id = '1'
+     */
+    List<JSONObject> select(String sql, Map param);
+    /**
+     *自定义SQL
+     * @param sql  update table  set name ='test' where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return     update table  set name ='test' where id = '1'
+     */
+    boolean execute(String sql, Map param);
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/service/IJobsLogService.java

+package cn.ibizlab.core.task.service;
+
+import java.io.Serializable;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collection;
+import java.math.BigInteger;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cache.annotation.CacheEvict;
+
+import cn.ibizlab.core.task.domain.JobsLog;
+import cn.ibizlab.core.task.filter.JobsLogSearchContext;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * 实体[JobsLog] 服务对象接口
+ */
+public interface IJobsLogService extends IService<JobsLog>{
+
+    JobsLog getDraft(JobsLog et) ;
+    boolean update(JobsLog et) ;
+    void updateBatch(List<JobsLog> list) ;
+    boolean create(JobsLog et) ;
+    void createBatch(List<JobsLog> list) ;
+    boolean checkKey(JobsLog et) ;
+    boolean save(JobsLog et) ;
+    void saveBatch(List<JobsLog> list) ;
+    boolean remove(BigInteger key) ;
+    void removeBatch(Collection<BigInteger> idList) ;
+    JobsLog get(BigInteger key) ;
+    Page<JobsLog> searchDefault(JobsLogSearchContext context) ;
+    /**
+     *自定义查询SQL
+     * @param sql  select * from table where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return select * from table where id = '1'
+     */
+    List<JSONObject> select(String sql, Map param);
+    /**
+     *自定义SQL
+     * @param sql  update table  set name ='test' where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return     update table  set name ='test' where id = '1'
+     */
+    boolean execute(String sql, Map param);
+
+
+}
+
+

ibztask-core/src/main/java/cn/ibizlab/core/task/service/IJobsRegistryService.java

+package cn.ibizlab.core.task.service;
+
+import java.io.Serializable;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collection;
+import java.math.BigInteger;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cache.annotation.CacheEvict;
+
+import cn.ibizlab.core.task.domain.JobsRegistry;
+import cn.ibizlab.core.task.filter.JobsRegistrySearchContext;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * 实体[JobsRegistry] 服务对象接口
+ */
+public interface IJobsRegistryService extends IService<JobsRegistry>{
+
+    JobsRegistry get(BigInteger key) ;
+    boolean remove(BigInteger key) ;
+    void removeBatch(Collection<BigInteger> idList) ;
+    boolean update(JobsRegistry et) ;
+    void updateBatch(List<JobsRegistry> list) ;
+    boolean save(JobsRegistry et) ;
+    void saveBatch(List<JobsRegistry> list) ;
+    boolean create(JobsRegistry et) ;
+    void createBatch(List<JobsRegistry> list) ;
+    boolean checkKey(JobsRegistry et) ;
+    JobsRegistry getDraft(JobsRegistry et) ;
+    Page<JobsRegistry> searchDefault(JobsRegistrySearchContext context) ;
+    /**
+     *自定义查询SQL
+     * @param sql  select * from table where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return select * from table where id = '1'
+     */
+    List<JSONObject> select(String sql, Map param);
+    /**
+     *自定义SQL
+     * @param sql  update table  set name ='test' where id =#{et.param}
+     * @param param 参数列表  param.put("param","1");
+     * @return     update table  set name ='test' where id = '1'
+     */
+    boolean execute(String sql, Map param);
+
+
+}
+
+

ibztask-core/src/main/resources/liquibase/h2_table.xml

@@ -4,7 +4,7 @@
 
 
     <!--输出实体[JOBS_INFO]数据结构 -->
-    <changeSet author="a_A_5d9d78509" id="tab-jobs_info-41-1">
+    <changeSet author="a_A_5d9d78509" id="tab-jobs_info-43-1">
         <createTable tableName="JOBS_INFO">
                 <column name="ID" remarks="" type="BIGINT">
                     <constraints primaryKey="true" primaryKeyName="PK_JOBS_INFO_ID"/>
@@ -42,7 +42,7 @@
 
 
     <!--输出实体[JOBS_REGISTRY]数据结构 -->
-    <changeSet author="a_A_5d9d78509" id="tab-jobs_registry-13-2">
+    <changeSet author="a_A_5d9d78509" id="tab-jobs_registry-15-2">
         <createTable tableName="JOBS_REGISTRY">
                 <column name="ID" remarks="" type="BIGINT">
                     <constraints primaryKey="true" primaryKeyName="PK_JOBS_REGISTRY_ID"/>
@@ -60,7 +60,7 @@
 
 
     <!--输出实体[JOBS_LOCK]数据结构 -->
-    <changeSet author="a_A_5d9d78509" id="tab-jobs_lock-8-3">
+    <changeSet author="a_A_5d9d78509" id="tab-jobs_lock-10-3">
         <createTable tableName="JOBS_LOCK">
                 <column name="ID" remarks="" type="BIGINT">
                     <constraints primaryKey="true" primaryKeyName="PK_JOBS_LOCK_ID"/>
@@ -72,7 +72,7 @@
 
 
     <!--输出实体[JOBS_LOG]数据结构 -->
-    <changeSet author="a_A_5d9d78509" id="tab-jobs_log-25-4">
+    <changeSet author="a_A_5d9d78509" id="tab-jobs_log-28-4">
         <createTable tableName="JOBS_LOG">
                 <column name="ID" remarks="" type="BIGINT">
                     <constraints primaryKey="true" primaryKeyName="PK_JOBS_LOG_ID"/>
@@ -91,7 +91,7 @@
                 </column>
                 <column name="TRIGGER_TYPE" remarks="" type="VARCHAR(30)">
                 </column>
-                <column name="TRIGGER_MSG" remarks="" type="TEXT(9999999)">
+                <column name="TRIGGER_MSG" remarks="" type="TEXT(1048576)">
                 </column>
                 <column name="CREATE_TIME" remarks="" type="BIGINT">
                 </column>

ibztask-core/src/main/resources/mapper/task/jobsinfo/JobsInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper	namespace="cn.ibizlab.core.task.mapper.JobsInfoMapper">
+
+    <!--该方法用于重写mybatis中selectById方法，以实现查询逻辑属性-->
+	<select id="selectById"  resultMap="JobsInfoResultMap" databaseId="mysql">
+        <![CDATA[select t1.* from (SELECT t1.`APP`, t1.`AUTHOR`, t1.`CREATE_TIME`, t1.`CRON`, t1.`FAIL_RETRY_COUNT`, t1.`HANDLER`, t1.`ID`, t1.`LAST_TIME`, t1.`NEXT_TIME`, t1.`PARAM`, t1.`REMARK`, t1.`STATUS`, t1.`TENANT_ID`, t1.`TIMEOUT`, t1.`UPDATE_TIME` FROM `JOBS_INFO` t1  ) t1 where id=#{id}]]>
+    </select>
+
+    <!--通过mybatis将查询结果注入到entity中,通过配置autoMapping="true"由mybatis自动处理映射关系 -->
+    <resultMap id="JobsInfoResultMap" type="cn.ibizlab.core.task.domain.JobsInfo" autoMapping="true">
+        <id property="id" column="id" /><!--主键字段映射-->
+		<result property="tenantId" column="tenant_id" />
+		<result property="failRetryCount" column="fail_retry_count" />
+		<result property="lastTime" column="last_time" />
+		<result property="nextTime" column="next_time" />
+		<result property="updateTime" column="update_time" />
+		<result property="createTime" column="create_time" />
+            
+		
+    </resultMap>
+
+
+    <!--数据集合[Default]-->
+	 <select id="searchDefault"  parameterType="cn.ibizlab.core.task.filter.JobsInfoSearchContext"  resultMap="JobsInfoResultMap">
+         select t1.* from (
+                <include refid="Default" />
+         )t1
+         <where><if test="ew!=null and ew.sqlSegment!=null and !ew.emptyOfWhere">${ew.sqlSegment}</if></where>
+         <if test="ew!=null and ew.sqlSegment!=null and ew.emptyOfWhere">${ew.sqlSegment}</if>
+     </select>
+
+    <!--数据查询[Default]-->
+    <sql id="Default" databaseId="mysql">
+       <![CDATA[	SELECT t1.`APP`, t1.`AUTHOR`, t1.`CREATE_TIME`, t1.`CRON`, t1.`FAIL_RETRY_COUNT`, t1.`HANDLER`, t1.`ID`, t1.`LAST_TIME`, t1.`NEXT_TIME`, t1.`PARAM`, t1.`REMARK`, t1.`STATUS`, t1.`TENANT_ID`, t1.`TIMEOUT`, t1.`UPDATE_TIME` FROM `JOBS_INFO` t1  
+			]]>
+    </sql>
+    <!--数据查询[View]-->
+    <sql id="View" databaseId="mysql">
+       <![CDATA[	SELECT t1.`APP`, t1.`AUTHOR`, t1.`CREATE_TIME`, t1.`CRON`, t1.`FAIL_RETRY_COUNT`, t1.`HANDLER`, t1.`ID`, t1.`LAST_TIME`, t1.`NEXT_TIME`, t1.`PARAM`, t1.`REMARK`, t1.`STATUS`, t1.`TENANT_ID`, t1.`TIMEOUT`, t1.`UPDATE_TIME` FROM `JOBS_INFO` t1  
+			]]>
+    </sql>
+</mapper>
+

ibztask-core/src/main/resources/mapper/task/jobslock/JobsLockMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper	namespace="cn.ibizlab.core.task.mapper.JobsLockMapper">
+
+    <!--该方法用于重写mybatis中selectById方法，以实现查询逻辑属性-->
+	<select id="selectById"  resultMap="JobsLockResultMap" databaseId="mysql">
+        <![CDATA[select t1.* from (SELECT t1.`CREATE_TIME`, t1.`ID` FROM `JOBS_LOCK` t1  ) t1 where id=#{id}]]>
+    </select>
+
+    <!--通过mybatis将查询结果注入到entity中,通过配置autoMapping="true"由mybatis自动处理映射关系 -->
+    <resultMap id="JobsLockResultMap" type="cn.ibizlab.core.task.domain.JobsLock" autoMapping="true">
+        <id property="id" column="id" /><!--主键字段映射-->
+		<result property="createTime" column="create_time" />
+            
+		
+    </resultMap>
+
+
+    <!--数据集合[Default]-->
+	 <select id="searchDefault"  parameterType="cn.ibizlab.core.task.filter.JobsLockSearchContext"  resultMap="JobsLockResultMap">
+         select t1.* from (
+                <include refid="Default" />
+         )t1
+         <where><if test="ew!=null and ew.sqlSegment!=null and !ew.emptyOfWhere">${ew.sqlSegment}</if></where>
+         <if test="ew!=null and ew.sqlSegment!=null and ew.emptyOfWhere">${ew.sqlSegment}</if>
+     </select>
+
+    <!--数据查询[Default]-->
+    <sql id="Default" databaseId="mysql">
+       <![CDATA[	SELECT t1.`CREATE_TIME`, t1.`ID` FROM `JOBS_LOCK` t1  
+			]]>
+    </sql>
+    <!--数据查询[View]-->
+    <sql id="View" databaseId="mysql">
+       <![CDATA[	SELECT t1.`CREATE_TIME`, t1.`ID` FROM `JOBS_LOCK` t1  
+			]]>
+    </sql>
+</mapper>
+

ibztask-core/src/main/resources/permission/systemResource.json

@@ -4,7 +4,7 @@
     ],
     "entities":[
     {
-    "dename":"JOBInfo",
+    "dename":"JobsInfo",
     "delogicname":"任务信息",
     "sysmoudle":{"id":"TASK","name":"task"},
     "dedataset":[{"id":"Default" , "name":"DEFAULT"}],
@@ -12,7 +12,7 @@
     "datascope":[{"id":"all","name":"全部数据"}]
      }
     ,    {
-    "dename":"JOBLog",
+    "dename":"JobsLog",
     "delogicname":"任务调度日志",
     "sysmoudle":{"id":"TASK","name":"task"},
     "dedataset":[{"id":"Default" , "name":"DEFAULT"}],
@@ -20,7 +20,7 @@
     "datascope":[{"id":"all","name":"全部数据"}]
      }
     ,    {
-    "dename":"JOBLock",
+    "dename":"JobsLock",
     "delogicname":"任务锁",
     "sysmoudle":{"id":"TASK","name":"task"},
     "dedataset":[{"id":"Default" , "name":"DEFAULT"}],
@@ -28,7 +28,7 @@
     "datascope":[{"id":"all","name":"全部数据"}]
      }
     ,    {
-    "dename":"JOBRegistry",
+    "dename":"JobsRegistry",
     "delogicname":"任务注册信息",
     "sysmoudle":{"id":"TASK","name":"task"},
     "dedataset":[{"id":"Default" , "name":"DEFAULT"}],