Skip to content
项目
群组
代码片段
帮助
正在加载...
帮助
提交反馈
为 GitLab 提交贡献
登录
切换导航
I
ibzdisk
项目
项目
详情
动态
版本
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
计划
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
ibiz4jteam
ibzdisk
提交
d60a93d9
提交
d60a93d9
编写于
3月 17, 2021
作者:
ibizdev
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
zhouweidong 发布系统代码 [ibz-disk,存储]
上级
6706efa0
变更
10
显示空白字符变更
内嵌
并排
正在显示
10 个修改的文件
包含
996 行增加
和
0 行删除
+996
-0
MetaDynamicModel.java
...in/java/cn/ibizlab/core/disk/domain/MetaDynamicModel.java
+181
-0
MetaDynamicModelSearchContext.java
...izlab/core/disk/filter/MetaDynamicModelSearchContext.java
+75
-0
MetaDynamicModelMapper.java
...a/cn/ibizlab/core/disk/mapper/MetaDynamicModelMapper.java
+68
-0
IMetaDynamicModelService.java
...n/ibizlab/core/disk/service/IMetaDynamicModelService.java
+64
-0
MetaDynamicModelServiceImpl.java
...b/core/disk/service/impl/MetaDynamicModelServiceImpl.java
+282
-0
MetaDynamicModelExService.java
...ab/core/extensions/service/MetaDynamicModelExService.java
+45
-0
h2_table.xml
ibzdisk-core/src/main/resources/liquibase/h2_table.xml
+26
-0
MetaDynamicModelMapper.xml
...s/mapper/disk/metadynamicmodel/MetaDynamicModelMapper.xml
+102
-0
ibzdisk.json
ibzdisk-core/src/main/resources/sysmodel/ibzdisk.json
+132
-0
StaticDict.java
...k-util/src/main/java/cn/ibizlab/util/dict/StaticDict.java
+21
-0
未找到文件。
ibzdisk-core/src/main/java/cn/ibizlab/core/disk/domain/MetaDynamicModel.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
disk
.
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
cn.ibizlab.util.helper.DataObject
;
import
cn.ibizlab.util.enums.DupCheck
;
import
java.io.Serializable
;
import
lombok.*
;
import
org.springframework.data.annotation.Transient
;
import
cn.ibizlab.util.annotation.Audit
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
com.fasterxml.jackson.annotation.JsonIgnoreProperties
;
import
com.baomidou.mybatisplus.annotation.*
;
import
cn.ibizlab.util.domain.EntityMP
;
import
com.baomidou.mybatisplus.core.toolkit.IdWorker
;
/**
* 实体[动态模型]
*/
@Getter
@Setter
@NoArgsConstructor
@JsonIgnoreProperties
(
value
=
"handler"
)
@TableName
(
value
=
"IBZDYNAMICMODEL"
,
resultMap
=
"MetaDynamicModelResultMap"
)
@ApiModel
(
"动态模型"
)
public
class
MetaDynamicModel
extends
EntityMP
implements
Serializable
{
private
static
final
long
serialVersionUID
=
1L
;
/**
* 动态实例
*/
@TableField
(
value
=
"dynainstid"
)
@JSONField
(
name
=
"dynainstid"
)
@JsonProperty
(
"dynainstid"
)
@ApiModelProperty
(
"动态实例"
)
private
String
dynainstid
;
/**
* 系统
*/
@TableField
(
value
=
"systemid"
)
@JSONField
(
name
=
"system_id"
)
@JsonProperty
(
"system_id"
)
@ApiModelProperty
(
"系统"
)
private
String
systemId
;
/**
* 配置标识
*/
@DEField
(
isKeyField
=
true
)
@TableId
(
value
=
"configid"
,
type
=
IdType
.
ASSIGN_UUID
)
@JSONField
(
name
=
"configid"
)
@JsonProperty
(
"configid"
)
@ApiModelProperty
(
"配置标识"
)
private
String
configid
;
/**
* 配置名称
*/
@TableField
(
value
=
"configname"
)
@JSONField
(
name
=
"configname"
)
@JsonProperty
(
"configname"
)
@ApiModelProperty
(
"配置名称"
)
private
String
configname
;
/**
* 父实例
*/
@TableField
(
value
=
"pdynainstid"
)
@JSONField
(
name
=
"pdynainstid"
)
@JsonProperty
(
"pdynainstid"
)
@ApiModelProperty
(
"父实例"
)
private
String
pdynainstid
;
/**
* 文件
*/
@TableField
(
value
=
"modelfile"
)
@JSONField
(
name
=
"modelfile"
)
@JsonProperty
(
"modelfile"
)
@ApiModelProperty
(
"文件"
)
private
String
modelfile
;
/**
* 状态
*/
@DEField
(
defaultValue
=
"0"
)
@TableField
(
value
=
"status"
)
@JSONField
(
name
=
"status"
)
@JsonProperty
(
"status"
)
@ApiModelProperty
(
"状态"
)
private
String
status
;
/**
* 主实例标识
*/
@JsonIgnore
@JSONField
(
serialize
=
false
)
@TableField
(
exist
=
false
)
private
cn
.
ibizlab
.
core
.
disk
.
domain
.
MetaDynamicModel
pdynamicinstid
;
/**
* 设置 [动态实例]
*/
public
void
setDynainstid
(
String
dynainstid
)
{
this
.
dynainstid
=
dynainstid
;
this
.
modify
(
"dynainstid"
,
dynainstid
);
}
/**
* 设置 [系统]
*/
public
void
setSystemId
(
String
systemId
)
{
this
.
systemId
=
systemId
;
this
.
modify
(
"systemid"
,
systemId
);
}
/**
* 设置 [配置名称]
*/
public
void
setConfigname
(
String
configname
)
{
this
.
configname
=
configname
;
this
.
modify
(
"configname"
,
configname
);
}
/**
* 设置 [父实例]
*/
public
void
setPdynainstid
(
String
pdynainstid
)
{
this
.
pdynainstid
=
pdynainstid
;
this
.
modify
(
"pdynainstid"
,
pdynainstid
);
}
/**
* 设置 [文件]
*/
public
void
setModelfile
(
String
modelfile
)
{
this
.
modelfile
=
modelfile
;
this
.
modify
(
"modelfile"
,
modelfile
);
}
/**
* 设置 [状态]
*/
public
void
setStatus
(
String
status
)
{
this
.
status
=
status
;
this
.
modify
(
"status"
,
status
);
}
/**
* 复制当前对象数据到目标对象(粘贴重置)
* @param targetEntity 目标数据对象
* @param bIncEmpty 是否包括空值
* @param <T>
* @return
*/
@Override
public
<
T
>
T
copyTo
(
T
targetEntity
,
boolean
bIncEmpty
)
{
this
.
reset
(
"configid"
);
return
super
.
copyTo
(
targetEntity
,
bIncEmpty
);
}
}
ibzdisk-core/src/main/java/cn/ibizlab/core/disk/filter/MetaDynamicModelSearchContext.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
disk
.
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.disk.domain.MetaDynamicModel
;
/**
* 关系型数据实体[MetaDynamicModel] 查询条件对象
*/
@Slf4j
@Data
public
class
MetaDynamicModelSearchContext
extends
QueryWrapperContext
<
MetaDynamicModel
>
{
private
String
n_systemid_eq
;
//[系统]
public
void
setN_systemid_eq
(
String
n_systemid_eq
)
{
this
.
n_systemid_eq
=
n_systemid_eq
;
if
(!
ObjectUtils
.
isEmpty
(
this
.
n_systemid_eq
)){
this
.
getSearchCond
().
eq
(
"systemid"
,
n_systemid_eq
);
}
}
private
String
n_configname_like
;
//[配置名称]
public
void
setN_configname_like
(
String
n_configname_like
)
{
this
.
n_configname_like
=
n_configname_like
;
if
(!
ObjectUtils
.
isEmpty
(
this
.
n_configname_like
)){
this
.
getSearchCond
().
like
(
"configname"
,
n_configname_like
);
}
}
private
String
n_pdynainstid_eq
;
//[父实例]
public
void
setN_pdynainstid_eq
(
String
n_pdynainstid_eq
)
{
this
.
n_pdynainstid_eq
=
n_pdynainstid_eq
;
if
(!
ObjectUtils
.
isEmpty
(
this
.
n_pdynainstid_eq
)){
this
.
getSearchCond
().
eq
(
"pdynainstid"
,
n_pdynainstid_eq
);
}
}
private
String
n_status_eq
;
//[状态]
public
void
setN_status_eq
(
String
n_status_eq
)
{
this
.
n_status_eq
=
n_status_eq
;
if
(!
ObjectUtils
.
isEmpty
(
this
.
n_status_eq
)){
this
.
getSearchCond
().
eq
(
"status"
,
n_status_eq
);
}
}
/**
* 启用快速搜索
*/
@Override
public
void
setQuery
(
String
query
)
{
this
.
query
=
query
;
if
(!
StringUtils
.
isEmpty
(
query
)){
this
.
getSearchCond
().
and
(
wrapper
->
wrapper
.
like
(
"configname"
,
query
)
);
}
}
}
ibzdisk-core/src/main/java/cn/ibizlab/core/disk/mapper/MetaDynamicModelMapper.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
disk
.
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.Map
;
import
org.apache.ibatis.annotations.Select
;
import
cn.ibizlab.core.disk.domain.MetaDynamicModel
;
import
cn.ibizlab.core.disk.filter.MetaDynamicModelSearchContext
;
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
MetaDynamicModelMapper
extends
BaseMapper
<
MetaDynamicModel
>
{
Page
<
MetaDynamicModel
>
searchDefault
(
IPage
page
,
@Param
(
"srf"
)
MetaDynamicModelSearchContext
context
,
@Param
(
"ew"
)
Wrapper
<
MetaDynamicModel
>
wrapper
);
Page
<
MetaDynamicModel
>
searchDynaInst
(
IPage
page
,
@Param
(
"srf"
)
MetaDynamicModelSearchContext
context
,
@Param
(
"ew"
)
Wrapper
<
MetaDynamicModel
>
wrapper
);
@Override
MetaDynamicModel
selectById
(
Serializable
id
);
@Override
int
insert
(
MetaDynamicModel
entity
);
@Override
int
updateById
(
@Param
(
Constants
.
ENTITY
)
MetaDynamicModel
entity
);
@Override
int
update
(
@Param
(
Constants
.
ENTITY
)
MetaDynamicModel
entity
,
@Param
(
"ew"
)
Wrapper
<
MetaDynamicModel
>
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
);
List
<
MetaDynamicModel
>
selectByPdynainstid
(
@Param
(
"configid"
)
Serializable
configid
);
}
ibzdisk-core/src/main/java/cn/ibizlab/core/disk/service/IMetaDynamicModelService.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
disk
.
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
org.springframework.scheduling.annotation.Async
;
import
com.alibaba.fastjson.JSONObject
;
import
org.springframework.cache.annotation.CacheEvict
;
import
cn.ibizlab.core.disk.domain.MetaDynamicModel
;
import
cn.ibizlab.core.disk.filter.MetaDynamicModelSearchContext
;
import
com.baomidou.mybatisplus.extension.service.IService
;
/**
* 实体[MetaDynamicModel] 服务对象接口
*/
public
interface
IMetaDynamicModelService
extends
IService
<
MetaDynamicModel
>
{
boolean
create
(
MetaDynamicModel
et
);
void
createBatch
(
List
<
MetaDynamicModel
>
list
);
boolean
update
(
MetaDynamicModel
et
);
void
updateBatch
(
List
<
MetaDynamicModel
>
list
);
boolean
remove
(
String
key
);
void
removeBatch
(
Collection
<
String
>
idList
);
MetaDynamicModel
get
(
String
key
);
MetaDynamicModel
getDraft
(
MetaDynamicModel
et
);
boolean
checkKey
(
MetaDynamicModel
et
);
MetaDynamicModel
init
(
MetaDynamicModel
et
);
boolean
initBatch
(
List
<
MetaDynamicModel
>
etList
);
MetaDynamicModel
publish
(
MetaDynamicModel
et
);
boolean
publishBatch
(
List
<
MetaDynamicModel
>
etList
);
boolean
save
(
MetaDynamicModel
et
);
void
saveBatch
(
List
<
MetaDynamicModel
>
list
);
Page
<
MetaDynamicModel
>
searchDefault
(
MetaDynamicModelSearchContext
context
);
Page
<
MetaDynamicModel
>
searchDynaInst
(
MetaDynamicModelSearchContext
context
);
List
<
MetaDynamicModel
>
selectByPdynainstid
(
String
configid
);
void
removeByPdynainstid
(
String
configid
);
/**
*自定义查询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
);
}
ibzdisk-core/src/main/java/cn/ibizlab/core/disk/service/impl/MetaDynamicModelServiceImpl.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
disk
.
service
.
impl
;
import
java.io.Serializable
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.Set
;
import
java.util.Map
;
import
java.util.HashSet
;
import
java.util.HashMap
;
import
java.util.Collection
;
import
java.util.Objects
;
import
java.util.Optional
;
import
java.math.BigInteger
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.cglib.beans.BeanCopier
;
import
org.springframework.stereotype.Service
;
import
org.springframework.data.domain.Page
;
import
org.springframework.data.domain.PageImpl
;
import
org.springframework.data.domain.Pageable
;
import
org.springframework.util.ObjectUtils
;
import
org.springframework.beans.factory.annotation.Value
;
import
cn.ibizlab.util.errors.BadRequestAlertException
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.context.annotation.Lazy
;
import
cn.ibizlab.core.disk.domain.MetaDynamicModel
;
import
cn.ibizlab.core.disk.filter.MetaDynamicModelSearchContext
;
import
cn.ibizlab.core.disk.service.IMetaDynamicModelService
;
import
cn.ibizlab.util.helper.CachedBeanCopier
;
import
cn.ibizlab.util.helper.DEFieldCacheMap
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
cn.ibizlab.core.disk.mapper.MetaDynamicModelMapper
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.baomidou.mybatisplus.core.conditions.Wrapper
;
import
com.alibaba.fastjson.JSONObject
;
import
org.springframework.util.StringUtils
;
/**
* 实体[动态模型] 服务对象接口实现
*/
@Slf4j
@Service
(
"MetaDynamicModelServiceImpl"
)
public
class
MetaDynamicModelServiceImpl
extends
ServiceImpl
<
MetaDynamicModelMapper
,
MetaDynamicModel
>
implements
IMetaDynamicModelService
{
protected
cn
.
ibizlab
.
core
.
disk
.
service
.
IMetaDynamicModelService
metadynamicmodelService
=
this
;
protected
int
batchSize
=
500
;
@Override
@Transactional
public
boolean
create
(
MetaDynamicModel
et
)
{
if
(!
this
.
retBool
(
this
.
baseMapper
.
insert
(
et
)))
{
return
false
;
}
CachedBeanCopier
.
copy
(
get
(
et
.
getConfigid
()),
et
);
return
true
;
}
@Override
@Transactional
public
void
createBatch
(
List
<
MetaDynamicModel
>
list
)
{
this
.
saveBatch
(
list
,
batchSize
);
}
@Override
@Transactional
public
boolean
update
(
MetaDynamicModel
et
)
{
if
(!
update
(
et
,
(
Wrapper
)
et
.
getUpdateWrapper
(
true
).
eq
(
"configid"
,
et
.
getConfigid
())))
{
return
false
;
}
CachedBeanCopier
.
copy
(
get
(
et
.
getConfigid
()),
et
);
return
true
;
}
@Override
@Transactional
public
void
updateBatch
(
List
<
MetaDynamicModel
>
list
)
{
updateBatchById
(
list
,
batchSize
);
}
@Override
@Transactional
public
boolean
remove
(
String
key
)
{
boolean
result
=
removeById
(
key
);
return
result
;
}
@Override
@Transactional
public
void
removeBatch
(
Collection
<
String
>
idList
)
{
removeByIds
(
idList
);
}
@Override
@Transactional
public
MetaDynamicModel
get
(
String
key
)
{
MetaDynamicModel
et
=
getById
(
key
);
if
(
et
==
null
){
et
=
new
MetaDynamicModel
();
et
.
setConfigid
(
key
);
}
else
{
}
return
et
;
}
@Override
public
MetaDynamicModel
getDraft
(
MetaDynamicModel
et
)
{
return
et
;
}
@Override
public
boolean
checkKey
(
MetaDynamicModel
et
)
{
return
(!
ObjectUtils
.
isEmpty
(
et
.
getConfigid
()))
&&
(!
Objects
.
isNull
(
this
.
getById
(
et
.
getConfigid
())));
}
@Override
@Transactional
public
MetaDynamicModel
init
(
MetaDynamicModel
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
boolean
initBatch
(
List
<
MetaDynamicModel
>
etList
)
{
for
(
MetaDynamicModel
et
:
etList
)
{
init
(
et
);
}
return
true
;
}
@Override
@Transactional
public
MetaDynamicModel
publish
(
MetaDynamicModel
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
boolean
publishBatch
(
List
<
MetaDynamicModel
>
etList
)
{
for
(
MetaDynamicModel
et
:
etList
)
{
publish
(
et
);
}
return
true
;
}
@Override
@Transactional
public
boolean
save
(
MetaDynamicModel
et
)
{
if
(!
saveOrUpdate
(
et
))
{
return
false
;
}
return
true
;
}
@Override
@Transactional
public
boolean
saveOrUpdate
(
MetaDynamicModel
et
)
{
if
(
null
==
et
)
{
return
false
;
}
else
{
return
checkKey
(
et
)
?
getProxyService
().
update
(
et
)
:
getProxyService
().
create
(
et
);
}
}
@Override
@Transactional
public
boolean
saveBatch
(
Collection
<
MetaDynamicModel
>
list
)
{
List
<
MetaDynamicModel
>
create
=
new
ArrayList
<>();
List
<
MetaDynamicModel
>
update
=
new
ArrayList
<>();
for
(
MetaDynamicModel
et
:
list
)
{
if
(
ObjectUtils
.
isEmpty
(
et
.
getConfigid
())
||
ObjectUtils
.
isEmpty
(
getById
(
et
.
getConfigid
())))
{
create
.
add
(
et
);
}
else
{
update
.
add
(
et
);
}
}
if
(
create
.
size
()
>
0
)
{
getProxyService
().
createBatch
(
create
);
}
if
(
update
.
size
()
>
0
)
{
getProxyService
().
updateBatch
(
update
);
}
return
true
;
}
@Override
@Transactional
public
void
saveBatch
(
List
<
MetaDynamicModel
>
list
)
{
List
<
MetaDynamicModel
>
create
=
new
ArrayList
<>();
List
<
MetaDynamicModel
>
update
=
new
ArrayList
<>();
for
(
MetaDynamicModel
et
:
list
)
{
if
(
ObjectUtils
.
isEmpty
(
et
.
getConfigid
())
||
ObjectUtils
.
isEmpty
(
getById
(
et
.
getConfigid
())))
{
create
.
add
(
et
);
}
else
{
update
.
add
(
et
);
}
}
if
(
create
.
size
()
>
0
)
{
getProxyService
().
createBatch
(
create
);
}
if
(
update
.
size
()
>
0
)
{
getProxyService
().
updateBatch
(
update
);
}
}
@Override
public
List
<
MetaDynamicModel
>
selectByPdynainstid
(
String
configid
)
{
return
baseMapper
.
selectByPdynainstid
(
configid
);
}
@Override
public
void
removeByPdynainstid
(
String
configid
)
{
this
.
remove
(
new
QueryWrapper
<
MetaDynamicModel
>().
eq
(
"pdynainstid"
,
configid
));
}
/**
* 查询集合 数据集
*/
@Override
public
Page
<
MetaDynamicModel
>
searchDefault
(
MetaDynamicModelSearchContext
context
)
{
com
.
baomidou
.
mybatisplus
.
extension
.
plugins
.
pagination
.
Page
<
MetaDynamicModel
>
pages
=
baseMapper
.
searchDefault
(
context
.
getPages
(),
context
,
context
.
getSelectCond
());
return
new
PageImpl
<
MetaDynamicModel
>(
pages
.
getRecords
(),
context
.
getPageable
(),
pages
.
getTotal
());
}
/**
* 查询集合 主实例数据查询
*/
@Override
public
Page
<
MetaDynamicModel
>
searchDynaInst
(
MetaDynamicModelSearchContext
context
)
{
com
.
baomidou
.
mybatisplus
.
extension
.
plugins
.
pagination
.
Page
<
MetaDynamicModel
>
pages
=
baseMapper
.
searchDynaInst
(
context
.
getPages
(),
context
,
context
.
getSelectCond
());
return
new
PageImpl
<
MetaDynamicModel
>(
pages
.
getRecords
(),
context
.
getPageable
(),
pages
.
getTotal
());
}
@Override
public
List
<
JSONObject
>
select
(
String
sql
,
Map
param
){
return
this
.
baseMapper
.
selectBySQL
(
sql
,
param
);
}
@Override
@Transactional
public
boolean
execute
(
String
sql
,
Map
param
){
if
(
sql
==
null
||
sql
.
isEmpty
())
{
return
false
;
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"insert"
))
{
return
this
.
baseMapper
.
insertBySQL
(
sql
,
param
);
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"update"
))
{
return
this
.
baseMapper
.
updateBySQL
(
sql
,
param
);
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"delete"
))
{
return
this
.
baseMapper
.
deleteBySQL
(
sql
,
param
);
}
log
.
warn
(
"暂未支持的SQL语法"
);
return
true
;
}
public
IMetaDynamicModelService
getProxyService
()
{
return
cn
.
ibizlab
.
util
.
security
.
SpringContextHolder
.
getBean
(
this
.
getClass
());
}
}
ibzdisk-core/src/main/java/cn/ibizlab/core/extensions/service/MetaDynamicModelExService.java
0 → 100644
浏览文件 @
d60a93d9
package
cn
.
ibizlab
.
core
.
extensions
.
service
;
import
cn.ibizlab.core.disk.service.impl.MetaDynamicModelServiceImpl
;
import
lombok.extern.slf4j.Slf4j
;
import
cn.ibizlab.core.disk.domain.MetaDynamicModel
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.context.annotation.Primary
;
import
java.util.*
;
/**
* 实体[动态模型] 自定义服务对象
*/
@Slf4j
@Primary
@Service
(
"MetaDynamicModelExService"
)
public
class
MetaDynamicModelExService
extends
MetaDynamicModelServiceImpl
{
@Override
protected
Class
currentModelClass
()
{
return
com
.
baomidou
.
mybatisplus
.
core
.
toolkit
.
ReflectionKit
.
getSuperClassGenericType
(
this
.
getClass
().
getSuperclass
(),
1
);
}
/**
* [Init:初始化副本实例] 行为扩展
* @param et
* @return
*/
@Override
@Transactional
public
MetaDynamicModel
init
(
MetaDynamicModel
et
)
{
return
super
.
init
(
et
);
}
/**
* [Publish:发布模型] 行为扩展
* @param et
* @return
*/
@Override
@Transactional
public
MetaDynamicModel
publish
(
MetaDynamicModel
et
)
{
return
super
.
publish
(
et
);
}
}
ibzdisk-core/src/main/resources/liquibase/h2_table.xml
浏览文件 @
d60a93d9
...
@@ -3,6 +3,32 @@
...
@@ -3,6 +3,32 @@
<!--输出实体[META_DYNAMICMODEL]数据结构 -->
<changeSet
author=
"a_A_5d9d78509"
id=
"tab-meta_dynamicmodel-1-1"
>
<createTable
tableName=
"IBZDYNAMICMODEL"
>
<column
name=
"DYNAINSTID"
remarks=
""
type=
"VARCHAR(100)"
>
</column>
<column
name=
"SYSTEMID"
remarks=
""
type=
"VARCHAR(100)"
>
</column>
<column
name=
"CONFIGID"
remarks=
""
type=
"VARCHAR(100)"
>
<constraints
primaryKey=
"true"
primaryKeyName=
"PK_META_DYNAMICMODEL_CONFIGID"
/>
</column>
<column
name=
"CONFIGNAME"
remarks=
""
type=
"VARCHAR(100)"
>
</column>
<column
name=
"PDYNAINSTID"
remarks=
""
type=
"VARCHAR(100)"
>
</column>
<column
name=
"MODELFILE"
remarks=
""
type=
"VARCHAR(1000)"
>
</column>
<column
name=
"STATUS"
remarks=
""
type=
"VARCHAR(60)"
>
</column>
</createTable>
</changeSet>
<!--输出实体[META_DYNAMICMODEL]外键关系 -->
<changeSet
author=
"a_A_5d9d78509"
id=
"fk-meta_dynamicmodel-1-2"
>
<addForeignKeyConstraint
baseColumnNames=
"PDYNAINSTID"
baseTableName=
"IBZDYNAMICMODEL"
constraintName=
"DER1N_META_DYNAMICMODEL_META_D"
deferrable=
"false"
initiallyDeferred=
"false"
onDelete=
"RESTRICT"
onUpdate=
"RESTRICT"
referencedColumnNames=
"CONFIGID"
referencedTableName=
"IBZDYNAMICMODEL"
validate=
"true"
/>
</changeSet>
</databaseChangeLog>
</databaseChangeLog>
ibzdisk-core/src/main/resources/mapper/disk/metadynamicmodel/MetaDynamicModelMapper.xml
0 → 100644
浏览文件 @
d60a93d9
<?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.disk.mapper.MetaDynamicModelMapper"
>
<!--该方法用于重写mybatis中selectById方法,以实现查询逻辑属性-->
<select
id=
"selectById"
resultMap=
"MetaDynamicModelResultMap"
databaseId=
"mysql"
>
<![CDATA[select t1.* from (SELECT t1.`CONFIGID`, t1.`CONFIGNAME`, t1.`DYNAINSTID`, t1.`MODELFILE`, t1.`PDYNAINSTID`, t1.`STATUS`, t1.`SYSTEMID` FROM `IBZDYNAMICMODEL` t1 ) t1 where configid=#{id}]]>
</select>
<select
id=
"selectById"
resultMap=
"MetaDynamicModelResultMap"
databaseId=
"oracle"
>
<![CDATA[select t1.* from (SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1 ) t1 where configid=#{id}]]>
</select>
<select
id=
"selectById"
resultMap=
"MetaDynamicModelResultMap"
databaseId=
"postgresql"
>
<![CDATA[select t1.* from (SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1 ) t1 where configid=#{id}]]>
</select>
<!--通过mybatis将查询结果注入到entity中,通过配置autoMapping="true"由mybatis自动处理映射关系 -->
<resultMap
id=
"MetaDynamicModelResultMap"
type=
"cn.ibizlab.core.disk.domain.MetaDynamicModel"
autoMapping=
"true"
>
<id
property=
"configid"
column=
"configid"
/>
<!--主键字段映射-->
<result
property=
"pdynainstid"
column=
"pdynainstid"
/>
<!--通过mybatis自动注入关系属性[主实体],fetchType="lazy"为懒加载配置 -->
<association
property=
"pdynamicinstid"
javaType=
"cn.ibizlab.core.disk.domain.MetaDynamicModel"
column=
"pdynainstid"
select=
"cn.ibizlab.core.disk.mapper.MetaDynamicModelMapper.selectById"
fetchType=
"lazy"
></association>
</resultMap>
<!--关系实体暴露select方法供主实体通过外键查询关系实体数据[实体关系名称:DER1N_META_DYNAMICMODEL_META_DYNAMICMODEL_PDYNAINSTID] -->
<select
id=
"selectByPdynainstid"
resultMap=
"MetaDynamicModelResultMap"
>
select t1.* from (
<include
refid=
"Default"
/>
) t1
where pdynainstid=#{configid}
</select>
<!--数据集合[Default]-->
<select
id=
"searchDefault"
parameterType=
"cn.ibizlab.core.disk.filter.MetaDynamicModelSearchContext"
resultMap=
"MetaDynamicModelResultMap"
>
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>
<!--数据集合[DynaInst]-->
<select
id=
"searchDynaInst"
parameterType=
"cn.ibizlab.core.disk.filter.MetaDynamicModelSearchContext"
resultMap=
"MetaDynamicModelResultMap"
>
select t1.* from (
<include
refid=
"DynaInst"
/>
)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.`CONFIGID`, t1.`CONFIGNAME`, t1.`DYNAINSTID`, t1.`MODELFILE`, t1.`PDYNAINSTID`, t1.`STATUS`, t1.`SYSTEMID` FROM `IBZDYNAMICMODEL` t1
]]>
</sql>
<!--数据查询[Default]-->
<sql
id=
"Default"
databaseId=
"oracle"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
]]>
</sql>
<!--数据查询[Default]-->
<sql
id=
"Default"
databaseId=
"postgresql"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
]]>
</sql>
<!--数据查询[DynaInst]-->
<sql
id=
"DynaInst"
databaseId=
"mysql"
>
<![CDATA[ SELECT t1.`CONFIGID`, t1.`CONFIGNAME`, t1.`DYNAINSTID`, t1.`MODELFILE`, t1.`PDYNAINSTID`, t1.`STATUS`, t1.`SYSTEMID` FROM `IBZDYNAMICMODEL` t1
WHERE ( t1.`PDYNAINSTID` IS NULL )
]]>
</sql>
<!--数据查询[DynaInst]-->
<sql
id=
"DynaInst"
databaseId=
"oracle"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
WHERE ( t1.PDYNAINSTID IS NULL )
]]>
</sql>
<!--数据查询[DynaInst]-->
<sql
id=
"DynaInst"
databaseId=
"postgresql"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
WHERE ( t1.PDYNAINSTID IS NULL )
]]>
</sql>
<!--数据查询[View]-->
<sql
id=
"View"
databaseId=
"mysql"
>
<![CDATA[ SELECT t1.`CONFIGID`, t1.`CONFIGNAME`, t1.`DYNAINSTID`, t1.`MODELFILE`, t1.`PDYNAINSTID`, t1.`STATUS`, t1.`SYSTEMID` FROM `IBZDYNAMICMODEL` t1
]]>
</sql>
<!--数据查询[View]-->
<sql
id=
"View"
databaseId=
"oracle"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
]]>
</sql>
<!--数据查询[View]-->
<sql
id=
"View"
databaseId=
"postgresql"
>
<![CDATA[ SELECT t1.CONFIGID, t1.CONFIGNAME, t1.DYNAINSTID, t1.MODELFILE, t1.PDYNAINSTID, t1.STATUS, t1.SYSTEMID FROM IBZDYNAMICMODEL t1
]]>
</sql>
</mapper>
ibzdisk-core/src/main/resources/sysmodel/ibzdisk.json
浏览文件 @
d60a93d9
...
@@ -3,6 +3,138 @@
...
@@ -3,6 +3,138 @@
"systemname"
:
"ibzdisk"
,
"systemname"
:
"ibzdisk"
,
"entities"
:[
"entities"
:[
{
{
"entity_name"
:
"META_DYNAMICMODEL"
,
"logic_name"
:
"动态模型"
,
"code_name"
:
"MetaDynamicModel"
,
"table_name"
:
"IBZDYNAMICMODEL"
,
"system_id"
:
"ibzdisk"
,
"system_name"
:
"ibzdisk"
,
"module_id"
:
"disk"
,
"module_name"
:
"disk"
,
"fields"
:[
{
"fieldname"
:
"DYNAINSTID"
,
"codename"
:
"Dynainstid"
,
"field_logic_name"
:
"动态实例"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"TEXT"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
100
,
"key_field"
:
0
,
"show_order"
:
1
,
"major_field"
:
0
},
{
"fieldname"
:
"SYSTEMID"
,
"codename"
:
"System_id"
,
"field_logic_name"
:
"系统"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"TEXT"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
100
,
"key_field"
:
0
,
"show_order"
:
2
,
"major_field"
:
0
},
{
"fieldname"
:
"CONFIGID"
,
"codename"
:
"Configid"
,
"field_logic_name"
:
"配置标识"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"TEXT"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
100
,
"key_field"
:
1
,
"show_order"
:
3
,
"major_field"
:
0
},
{
"fieldname"
:
"CONFIGNAME"
,
"codename"
:
"Configname"
,
"field_logic_name"
:
"配置名称"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"TEXT"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
100
,
"key_field"
:
0
,
"show_order"
:
4
,
"major_field"
:
1
},
{
"fieldname"
:
"PDYNAINSTID"
,
"codename"
:
"Pdynainstid"
,
"field_logic_name"
:
"父实例"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"ref_de"
:
"META_DYNAMICMODEL"
,
"ref_field_name"
:
"CONFIGID"
,
"relation_name"
:
"DER1N_META_DYNAMICMODEL_META_DYNAMICMODEL_PDYNAINSTID"
,
"relation_codename"
:
"PDynamicInstId"
,
"field_type"
:
"PICKUP"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
100
,
"key_field"
:
0
,
"show_order"
:
5
,
"major_field"
:
0
},
{
"fieldname"
:
"MODELFILE"
,
"codename"
:
"Modelfile"
,
"field_logic_name"
:
"文件"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"TEXT"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
1000
,
"key_field"
:
0
,
"show_order"
:
6
,
"major_field"
:
0
},
{
"fieldname"
:
"STATUS"
,
"codename"
:
"Status"
,
"field_logic_name"
:
"状态"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"field_type"
:
"SSCODELIST"
,
"dict"
:
"DynamicModelStatus"
,
"nullable"
:
1
,
"physical_field"
:
1
,
"data_type"
:
"VARCHAR"
,
"data_length"
:
60
,
"key_field"
:
0
,
"show_order"
:
7
,
"major_field"
:
0
}
],
"subEntitys"
:[
{
"name"
:
"DER1N_META_DYNAMICMODEL_META_DYNAMICMODEL_PDYNAINSTID"
,
"relation_type"
:
"DER1N"
,
"code_name"
:
"PDynamicInstId"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"ref_entity_name"
:
"META_DYNAMICMODEL"
}
],
"parentEntitys"
:[
{
"name"
:
"DER1N_META_DYNAMICMODEL_META_DYNAMICMODEL_PDYNAINSTID"
,
"relation_type"
:
"DER1N"
,
"code_name"
:
"PDynamicInstId"
,
"entity_name"
:
"META_DYNAMICMODEL"
,
"ref_entity_name"
:
"META_DYNAMICMODEL"
}
]
}
,
{
"entity_name"
:
"SD_FILE"
,
"entity_name"
:
"SD_FILE"
,
"logic_name"
:
"文件"
,
"logic_name"
:
"文件"
,
"code_name"
:
"SDFile"
,
"code_name"
:
"SDFile"
,
...
...
ibzdisk-util/src/main/java/cn/ibizlab/util/dict/StaticDict.java
浏览文件 @
d60a93d9
...
@@ -2504,6 +2504,27 @@ public class StaticDict {
...
@@ -2504,6 +2504,27 @@ public class StaticDict {
}
}
/**
* 代码表[动态模型导入状态]
*/
@Getter
public
enum
DynamicModelStatus
{
ITEM_0
(
"0"
,
"未激活"
),
ITEM_1
(
"1"
,
"已激活"
);
private
String
value
;
private
String
text
;
private
String
valueSeparator
=
""
;
private
String
textSeparator
=
""
;
private
String
emptyText
=
""
;
DynamicModelStatus
(
String
value
,
String
text
)
{
this
.
value
=
value
;
this
.
text
=
text
;
}
}
/**
/**
* 代码表[数据同步方向]
* 代码表[数据同步方向]
*/
*/
...
...
编辑
预览
Markdown
格式
0%
请重试
or
添加新附件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
先完成此消息的编辑!
取消
想要评论请
注册
或
登录