1
0

8 Commits

30 changed files with 542 additions and 391 deletions

View File

@@ -1,6 +1,11 @@
<component name="InspectionProjectProfileManager"> <component name="InspectionProjectProfileManager">
<profile version="1.0"> <profile version="1.0">
<option name="myName" value="Project Default" /> <option name="myName" value="Project Default" />
<inspection_tool class="DuplicatedCode" enabled="true" level="WEAK WARNING" enabled_by_default="true">
<Languages>
<language minSize="47" name="Java" />
</Languages>
</inspection_tool>
<inspection_tool class="HttpUrlsUsage" enabled="false" level="WEAK WARNING" enabled_by_default="false" /> <inspection_tool class="HttpUrlsUsage" enabled="false" level="WEAK WARNING" enabled_by_default="false" />
</profile> </profile>
</component> </component>

View File

@@ -104,7 +104,14 @@ export function inputFileFormItemCommonOptions(accept = '*', maxSize = size5MB)
} }
} }
export function copyField(field, tips = '复制', ignoreLength = 0, extra = undefined) { /**
* @param {string} field
* @param {string} label
* @param {string} tips
* @param {number} ignoreLength
* @param {{}} extra
*/
export function copyField(field, label, tips = '复制', ignoreLength = 0, extra = undefined) {
let tpl = ignoreLength === 0 ? `\${${field}}` : `\${TRUNCATE(${field}, ${ignoreLength})}` let tpl = ignoreLength === 0 ? `\${${field}}` : `\${TRUNCATE(${field}, ${ignoreLength})}`
let content = extra let content = extra
? { ? {
@@ -121,8 +128,10 @@ export function copyField(field, tips = '复制', ignoreLength = 0, extra = unde
tpl: tpl, tpl: tpl,
} }
return { return {
name: field,
type: 'wrapper', type: 'wrapper',
size: 'none', size: 'none',
className: 'nowrap',
body: [ body: [
content, content,
{ {
@@ -139,7 +148,68 @@ export function copyField(field, tips = '复制', ignoreLength = 0, extra = unde
} }
} }
export function mappingField(field, mapping) { /**
* @param {string} label
* @param {number} width
* @param {Array} buttons
*/
export function operationField(label, width = 100, buttons = []) {
return {
label: label,
width: width,
type: 'operation',
fixed: 'right',
className: 'nowrap',
buttons: buttons,
}
}
/**
* @param {string} field
* @param {string} label
* @param {number} width
*/
export function timeField(field, label, width = 150) {
return {
label: label,
width: width,
align: 'center',
type: 'tpl',
tpl: `\${IF(${field}, DATETOSTR(${field}), '-')}`
}
}
export function stringWrapField(field, label, width = undefined) {
return stringField(field, label, width, true)
}
/**
* @param {string} field
* @param {string} label
* @param {number} width
* @param {boolean} wrap
*/
export function stringField(field, label, width = undefined, wrap = false) {
let data = {
name: field,
label: label,
}
if (width) {
data['width'] = width
}
if (wrap) {
data['className'] = 'nowrap'
}
return data
}
/**
* @param {string} field
* @param {string} label
* @param {[{label: *, value: *, color: string}]} mapping
* @param {number} width
*/
export function mappingField(field, label, mapping, width = 80) {
let mapData = { let mapData = {
'*': `<span class='label bg-gray-300'>\${${field}}</span>`, '*': `<span class='label bg-gray-300'>\${${field}}</span>`,
} }
@@ -147,8 +217,11 @@ export function mappingField(field, mapping) {
mapData[item['value']] = `<span class='label ${item['color']}'>${item['label']}</span>` mapData[item['value']] = `<span class='label ${item['color']}'>${item['label']}</span>`
}) })
return { return {
label: label,
type: 'mapping', type: 'mapping',
width: width,
value: `\${${field}}`, value: `\${${field}}`,
align: 'center',
map: mapData, map: mapData,
} }
} }

View File

@@ -16,22 +16,8 @@ const dialogBody = [
{ {
type: 'group', type: 'group',
body: [ body: [
{ mappingField('role', '角色', userRoleMapping),
type: 'control', mappingField('state', '账号状态', userStateMapping),
name: 'role',
label: '角色',
body: [
mappingField('role', userRoleMapping),
]
},
{
type: 'control',
name: 'state',
label: '账号状态',
body: [
mappingField('state', userStateMapping)
]
},
] ]
}, },
...formCreatedUserAndModifiedUser(), ...formCreatedUserAndModifiedUser(),

View File

@@ -4,7 +4,10 @@ import {
checkOverMapping, checkOverMapping,
checkTypeMapping, checkTypeMapping,
crudCommonOptions, crudCommonOptions,
mappingField mappingField,
operationField,
stringField,
timeField,
} from "../../components/constants.js"; } from "../../components/constants.js";
import {permissionDetailDialog} from "../../components/permission/dialog-permission.js"; import {permissionDetailDialog} from "../../components/permission/dialog-permission.js";
@@ -16,6 +19,7 @@ export function tabCheck() {
reload: true, reload: true,
body: [ body: [
{ {
name: 'check_order_list',
type: 'crud', type: 'crud',
api: apiGet('${base}/check_order/list'), api: apiGet('${base}/check_order/list'),
...crudCommonOptions(), ...crudCommonOptions(),
@@ -23,56 +27,51 @@ export function tabCheck() {
'reload', 'reload',
], ],
columns: [ columns: [
{ stringField('description', '描述'),
name: 'description', mappingField('type', '类型', checkTypeMapping),
label: '描述', mappingField('over', '状态', checkOverMapping),
}, timeField('createdTime', '创建时间'),
{ stringField('createdUsername', '创建人', 100),
label: '类型', timeField('modifiedTime', '最后修改时间'),
width: 80, stringField('modifiedUsername', '最后操作人', 100),
align: 'center', operationField('操作', undefined, [
...mappingField('type', checkTypeMapping) {
}, visibleOn: '${!over}',
{ type: 'action',
label: '状态', label: '处理',
width: 80, level: 'link',
align: 'center', ...permissionDetailDialog(
...mappingField('over', checkOverMapping) 'parameters.confirmationId',
}, [
{ {
label: '操作', type: 'action',
width: 100, label: '同意',
type: 'operation', actionType: 'ajax',
fixed: 'right', close: true,
className: 'nowrap', api: apiGet('${base}/check_order/operation/${checkOrderId}/APPLY'),
buttons: [ reload: 'check_order_list',
{ },
visibleOn: '${!over}', {
type: 'action', type: 'action',
label: '处理', label: '拒绝',
level: 'link', actionType: 'ajax',
...permissionDetailDialog( close: true,
'parameters.confirmationId', api: apiGet('${base}/check_order/operation/${checkOrderId}/REJECT'),
[ reload: 'check_order_list',
{ },
type: 'action', ],
label: '同意', ),
actionType: 'ajax', },
api: apiGet('${base}/check_order/operation/${checkOrderId}/APPLY') {
}, visibleOn: '${over}',
{ type: 'action',
type: 'action', label: '查看',
label: '拒绝', level: 'link',
actionType: 'ajax', ...permissionDetailDialog('parameters.confirmationId'),
api: apiGet('${base}/check_order/operation/${checkOrderId}/REJECT') },
} ]),
] ],
), },
}, ],
]
}
]
}
]
} }
} }

View File

@@ -11,6 +11,8 @@ import {
confirmationStateMapping, confirmationStateMapping,
crudCommonOptions, crudCommonOptions,
mappingField, mappingField,
operationField,
timeField,
userOnly userOnly
} from "../../components/constants.js"; } from "../../components/constants.js";
@@ -38,63 +40,45 @@ export function resourceList() {
label: '描述', label: '描述',
name: 'description', name: 'description',
}, },
{ mappingField('confirmationState', '确权状态', confirmationStateMapping),
label: '确权状态', timeField('createdTime', '创建时间'),
width: 80, operationField('操作', undefined, [
align: 'center', {
...mappingField('confirmationState', confirmationStateMapping) type: 'action',
}, label: '详情',
{ level: 'link',
label: '创建时间', ...resourceDetailDialog(),
width: 150, },
align: 'center', {
type: 'tpl', type: 'dropdown-button',
tpl: "${IF(createdTime, DATETOSTR(createdTime), '-')}" level: 'link',
}, icon: 'fa fa-ellipsis-h',
{ hideCaret: true,
label: '操作', trigger: 'hover',
width: 100, buttons: [
type: 'operation', {
fixed: 'right', disabledOn: arrayOutCheck([confirmationState.none, confirmationState.draft], 'confirmationState'),
className: 'nowrap', disabledTip: '审查或确权成功后无法编辑',
buttons: [ tooltipPlacement: 'top',
{ type: 'action',
type: 'action', label: '编辑',
label: '详情', level: 'link',
level: 'link', ...resourceEditeDialog(),
...resourceDetailDialog(), },
}, {
{ disabledOn: arrayInCheck([confirmationState.checking], 'confirmationState'),
type: 'dropdown-button', disabledTip: '审查中无法删除',
level: 'link', tooltipPlacement: 'bottom',
icon: 'fa fa-ellipsis-h', type: 'action',
hideCaret: true, label: "删除",
trigger: 'hover', confirmTitle: '确认删除',
buttons: [ confirmText: '确认删除名称为「${name}」的数据资源吗?',
{ actionType: 'ajax',
disabledOn: arrayOutCheck([confirmationState.none, confirmationState.draft], 'confirmationState'), api: apiGet('${base}/data_resource/remove/${id}')
disabledTip: '审查或确权成功后无法编辑', },
tooltipPlacement: 'top', ]
type: 'action', },
label: '编辑', ]),
level: 'link',
...resourceEditeDialog(),
},
{
disabledOn: arrayInCheck([confirmationState.checking], 'confirmationState'),
disabledTip: '审查中无法删除',
tooltipPlacement: 'bottom',
type: 'action',
label: "删除",
confirmTitle: '确认删除',
confirmText: '确认删除名称为「${name}」的数据资源吗?',
actionType: 'ajax',
api: apiGet('${base}/data_resource/remove/${id}')
},
]
},
]
},
] ]
} }
} }

View File

@@ -3,13 +3,17 @@ import {
confirmationStateMapping, confirmationStateMapping,
crudCommonOptions, crudCommonOptions,
mappingField, mappingField,
operationField,
providerOnly, providerOnly,
userOnly stringField,
stringWrapField,
timeField,
userOnly,
} from "../../components/constants.js"; } from "../../components/constants.js";
import { import {
permissionAddDialog, permissionAddDialog,
permissionDetailDialog, permissionDetailDialog,
permissionEditeDialog permissionEditeDialog,
} from "../../components/permission/dialog-permission.js"; } from "../../components/permission/dialog-permission.js";
export function tabPermissions() { export function tabPermissions() {
@@ -40,88 +44,63 @@ export function tabPermissions() {
}, },
], ],
columns: [ columns: [
{ stringField('name', '名称', 200),
label: '名称', stringWrapField('description', '描述'),
name: 'name', mappingField('state', '状态', confirmationStateMapping),
width: 200, timeField('createdTime', '创建时间'),
}, operationField('操作', undefined, [
{ {
label: '描述', type: 'action',
name: 'description', label: '查看',
}, level: 'link',
{ ...permissionDetailDialog(),
label: '状态', },
width: 80, {
align: 'center', visibleOn: "${state === 'CHECKING'}",
...mappingField('state', confirmationStateMapping) type: 'action',
}, label: '撤销',
{ level: 'link',
label: '创建时间', confirmTitle: '确认撤销',
width: 150, confirmText: '确认撤销名称为「${name}」的确权申请吗?',
align: 'center', actionType: 'ajax',
type: 'tpl', api: apiGet('${base}/confirmation/retract/${id}'),
tpl: "${IF(createdTime, DATETOSTR(createdTime), '-')}" },
}, {
{ visibleOn: "${state === 'DRAFT' || state === 'REJECT'}",
label: '操作', type: 'action',
width: 100, label: '提交',
type: 'operation', level: 'link',
fixed: 'right', confirmTitle: '确认提交',
className: 'nowrap', confirmText: '确认提交名称为「${name}」的确权申请吗?',
buttons: [ actionType: 'ajax',
{ api: apiGet('${base}/confirmation/submit/${id}'),
type: 'action', },
label: '查看', {
level: 'link', type: 'dropdown-button',
...permissionDetailDialog(), level: 'link',
}, icon: 'fa fa-ellipsis-h',
{ hideCaret: true,
visibleOn: "${state === 'CHECKING'}", trigger: 'hover',
type: 'action', buttons: [
label: '撤销', {
level: 'link', disabledOn: "${state !== 'DRAFT'}",
confirmTitle: '确认撤销', type: 'action',
confirmText: '确认撤销名称为「${name}」的确权申请吗?', label: '编辑',
actionType: 'ajax', level: 'link',
api: apiGet('${base}/confirmation/retract/${id}'), ...permissionEditeDialog(),
}, },
{ {
visibleOn: "${state === 'DRAFT' || state === 'REJECT'}", disabledOn: "${state === 'CHECKING'}",
type: 'action', type: 'action',
label: '提交', label: "删除",
level: 'link', confirmTitle: '确认删除',
confirmTitle: '确认提交', confirmText: '确认删除名称为「${name}」的确权申请吗?删除后对应的数据资源处于未确权状态。',
confirmText: '确认提交名称为「${name}」的确权申请吗?', actionType: 'ajax',
actionType: 'ajax', api: apiGet('${base}/confirmation/remove/${id}'),
api: apiGet('${base}/confirmation/submit/${id}'), },
}, ]
{ },
type: 'dropdown-button', ]),
level: 'link',
icon: 'fa fa-ellipsis-h',
hideCaret: true,
trigger: 'hover',
buttons: [
{
disabledOn: "${state === 'CHECKING'}",
type: 'action',
label: '编辑',
level: 'link',
...permissionEditeDialog(),
},
{
disabledOn: "${state === 'CHECKING'}",
type: 'action',
label: "删除",
confirmTitle: '确认删除',
confirmText: '确认删除名称为「${name}」的确权申请吗?',
actionType: 'ajax',
api: apiGet('${base}/confirmation/remove/${id}'),
},
]
},
]
},
] ]
} }
}, },

View File

@@ -4,6 +4,8 @@ import {
copyField, copyField,
crudCommonOptions, crudCommonOptions,
mappingField, mappingField,
operationField,
timeField,
userRoleMapping, userRoleMapping,
userStateMapping userStateMapping
} from '../../components/constants.js' } from '../../components/constants.js'
@@ -31,81 +33,49 @@ export function tabUser() {
}, },
], ],
columns: [ columns: [
{ copyField(
name: 'username', 'username',
label: '邮箱', '邮箱',
...copyField( undefined,
'username', undefined,
undefined, userDetailDialog(),
undefined, ),
userDetailDialog(), mappingField('role', '角色', userRoleMapping, 120),
) mappingField('state', '账号状态', userStateMapping),
}, timeField('createdTime', '创建时间'),
{ timeField('lastLoginTime', '上次登陆时间'),
label: '角色', operationField('操作', undefined, [
width: 120, {
align: 'center', visibleOn: "${state === 'CHECKING'}",
...mappingField('role', userRoleMapping) label: '审核',
}, icon: 'fa fa-fingerprint',
{ level: 'primary',
label: '账号状态', size: 'xs',
width: 80, ...userCheckDialog(),
align: 'center', },
...mappingField('state', userStateMapping) {
}, visibleOn: "${state === 'NORMAL' && role !== 'ADMINISTRATOR'}",
{ label: '禁用',
label: '创建时间', icon: 'fa fa-ban',
width: 150, level: 'danger',
align: 'center', size: 'xs',
type: 'tpl', confirmText: '确认禁用账号${username}',
tpl: "${IF(createdTime, DATETOSTR(createdTime), '-')}" confirmTitle: '禁用账号',
}, actionType: 'ajax',
{ api: apiGet('${base}/user_management/disable/${username}'),
label: '上次登陆时间', },
width: 150, {
align: 'center', visibleOn: "${state === 'DISABLED' && role !== 'ADMINISTRATOR'}",
type: 'tpl', label: '启用',
tpl: "${IF(lastLoginTime, DATETOSTR(lastLoginTime), '-')}" icon: 'fa fa-check',
}, level: 'success',
{ size: 'xs',
label: '操作', confirmText: '确认启用账号${username}',
width: 100, confirmTitle: '启用账号',
type: 'operation', actionType: 'ajax',
fixed: 'right', api: apiGet('${base}/user_management/enable/${username}'),
className: 'nowrap', }
buttons: [ ]),
{
visibleOn: "${state === 'CHECKING'}",
label: '审核',
icon: 'fa fa-fingerprint',
level: 'primary',
size: 'xs',
...userCheckDialog(),
},
{
visibleOn: "${state === 'NORMAL' && role !== 'ADMINISTRATOR'}",
label: '禁用',
icon: 'fa fa-ban',
level: 'danger',
size: 'xs',
confirmText: '确认禁用账号${username}',
confirmTitle: '禁用账号',
actionType: 'ajax',
api: apiGet('${base}/user_management/disable/${username}'),
},
{
visibleOn: "${state === 'DISABLED' && role !== 'ADMINISTRATOR'}",
label: '启用',
icon: 'fa fa-check',
level: 'success',
size: 'xs',
confirmText: '确认启用账号${username}',
confirmTitle: '启用账号',
actionType: 'ajax',
api: apiGet('${base}/user_management/enable/${username}'),
}
]
},
] ]
} }
] ]

View File

@@ -1,17 +1,15 @@
package com.eshore.gringotts.web.domain.authentication.entity; package com.eshore.gringotts.web.domain.authentication.entity;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.SimpleEntity; import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
import com.eshore.gringotts.web.domain.resource.entity.DataResource; import com.eshore.gringotts.web.domain.resource.entity.DataResource;
import com.eshore.gringotts.web.domain.upload.entity.DataFile; import com.eshore.gringotts.web.domain.upload.entity.DataFile;
import java.util.Set; import java.util.Set;
import javax.persistence.CascadeType; import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.ConstraintMode; import javax.persistence.ConstraintMode;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.EntityListeners; import javax.persistence.EntityListeners;
import javax.persistence.EnumType;
import javax.persistence.Enumerated;
import javax.persistence.FetchType; import javax.persistence.FetchType;
import javax.persistence.ForeignKey; import javax.persistence.ForeignKey;
import javax.persistence.JoinColumn; import javax.persistence.JoinColumn;
@@ -25,6 +23,7 @@ import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.DynamicUpdate; import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.Where;
import org.springframework.data.jpa.domain.support.AuditingEntityListener; import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/** /**
@@ -50,43 +49,14 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@NamedAttributeNode(value = "createdUser"), @NamedAttributeNode(value = "createdUser"),
@NamedAttributeNode(value = "modifiedUser"), @NamedAttributeNode(value = "modifiedUser"),
}) })
public class Authentication extends SimpleEntity { public class Authentication extends CheckingNeededEntity {
@ManyToOne(fetch = FetchType.EAGER) @ManyToOne(fetch = FetchType.EAGER)
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private DataResource target; private DataResource target;
private String description;
@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY) @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY)
@JoinTable(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT), inverseForeignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinTable(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT), inverseForeignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private Set<DataFile> evidences; private Set<DataFile> evidences;
@Column(nullable = false)
@Enumerated(EnumType.STRING)
private State state = State.DRAFT;
public enum State {
/**
* 无确权
*/
NONE,
/**
* 草稿
*/
DRAFT,
/**
* 属主审查中
*/
OWNER_CHECKING,
/**
* 审查中
*/
CHECKING,
/**
* 正常
*/
NORMAL,
/**
* 驳回
*/
REJECT,
}
} }

View File

@@ -0,0 +1,47 @@
package com.eshore.gringotts.web.domain.base.entity;
import javax.persistence.Column;
import javax.persistence.EntityListeners;
import javax.persistence.EnumType;
import javax.persistence.Enumerated;
import javax.persistence.MappedSuperclass;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@Getter
@Setter
@ToString
@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
public class CheckingNeededEntity extends LogicDeleteEntity {
private String description;
@Column(nullable = false)
@Enumerated(EnumType.STRING)
private State state = State.DRAFT;
public enum State {
/**
* 无确权
*/
NONE,
/**
* 草稿
*/
DRAFT,
/**
* 审查中
*/
CHECKING,
/**
* 正常
*/
NORMAL,
/**
* 驳回
*/
REJECT,
}
}

View File

@@ -1,13 +1,11 @@
package com.eshore.gringotts.web.domain.base.entity; package com.eshore.gringotts.web.domain.base.entity;
import java.time.LocalDateTime; import javax.persistence.Column;
import javax.persistence.EntityListeners; import javax.persistence.EntityListeners;
import javax.persistence.MappedSuperclass; import javax.persistence.MappedSuperclass;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.LastModifiedDate;
import org.springframework.data.jpa.domain.support.AuditingEntityListener; import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/** /**
@@ -18,12 +16,12 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
*/ */
@Getter @Getter
@Setter @Setter
@ToString @ToString(callSuper = true)
@MappedSuperclass @MappedSuperclass
@EntityListeners(AuditingEntityListener.class) @EntityListeners(AuditingEntityListener.class)
public class DatetimeOnlyEntity extends IdOnlyEntity { public class LogicDeleteEntity extends SimpleEntity {
@CreatedDate public static final String LOGIC_DELETE_CLAUSE = "deleted = false";
private LocalDateTime createdTime;
@LastModifiedDate @Column(nullable = false)
private LocalDateTime modifiedTime; private Boolean deleted = false;
} }

View File

@@ -0,0 +1,27 @@
package com.eshore.gringotts.web.domain.base.entity;
import javax.persistence.Column;
import javax.persistence.EntityListeners;
import javax.persistence.MappedSuperclass;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/**
* 实体类公共字段
*
* @author lanyuanxiaoyao
* @date 2024-11-20
*/
@Getter
@Setter
@ToString(callSuper = true)
@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
public class LogicDeleteIdOnlyEntity extends IdOnlyEntity {
public static final String LOGIC_DELETE_CLAUSE = "deleted = false";
@Column(nullable = false)
private Boolean deleted = false;
}

View File

@@ -0,0 +1,50 @@
package com.eshore.gringotts.web.domain.base.service;
import cn.hutool.core.util.ClassUtil;
import cn.hutool.core.util.StrUtil;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
import com.eshore.gringotts.web.domain.user.service.UserService;
import javax.persistence.EntityManager;
import javax.persistence.Query;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.transaction.Transactional;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.collections.api.factory.Lists;
import org.eclipse.collections.api.list.ImmutableList;
/**
* @author lanyuanxiaoyao
* @date 2024-11-21
*/
@Slf4j
public abstract class LogicDeleteService<ENTITY extends LogicDeleteEntity> extends SimpleServiceSupport<ENTITY> {
private final EntityManager manager;
public LogicDeleteService(SimpleRepository<ENTITY, Long> repository, UserService userService, EntityManager manager) {
super(repository, userService);
this.manager = manager;
}
@Override
protected ImmutableList<Predicate> extraListPredicates(Root<ENTITY> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
return Lists.immutable.of(builder.equal(root.get("deleted"), false));
}
@Override
protected ImmutableList<Predicate> extraDetailPredicates(Root<ENTITY> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
return Lists.immutable.of(builder.equal(root.get("deleted"), false));
}
@Transactional(rollbackOn = Throwable.class)
@Override
public void remove(Long id) {
String entityName = ClassUtil.getTypeArgument(this.getClass()).getSimpleName();
Query query = manager.createQuery(StrUtil.format("update {} entity set deleted=true where id=?1", entityName));
query.setParameter(1, id);
query.executeUpdate();
}
}

View File

@@ -9,7 +9,10 @@ import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
import com.eshore.gringotts.web.domain.user.entity.User; import com.eshore.gringotts.web.domain.user.entity.User;
import com.eshore.gringotts.web.domain.user.service.UserService; import com.eshore.gringotts.web.domain.user.service.UserService;
import java.util.Optional; import java.util.Optional;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate; import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.transaction.Transactional; import javax.transaction.Transactional;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.eclipse.collections.api.factory.Lists; import org.eclipse.collections.api.factory.Lists;
@@ -24,8 +27,8 @@ import org.springframework.data.domain.Sort;
*/ */
@Slf4j @Slf4j
public abstract class SimpleServiceSupport<ENTITY extends SimpleEntity> implements SimpleService<ENTITY> { public abstract class SimpleServiceSupport<ENTITY extends SimpleEntity> implements SimpleService<ENTITY> {
private final SimpleRepository<ENTITY, Long> repository; protected final SimpleRepository<ENTITY, Long> repository;
private final UserService userService; protected final UserService userService;
public SimpleServiceSupport(SimpleRepository<ENTITY, Long> repository, UserService userService) { public SimpleServiceSupport(SimpleRepository<ENTITY, Long> repository, UserService userService) {
this.repository = repository; this.repository = repository;
@@ -64,6 +67,7 @@ public abstract class SimpleServiceSupport<ENTITY extends SimpleEntity> implemen
if (User.isNotAdministrator(user)) { if (User.isNotAdministrator(user)) {
predicates.add(builder.equal(root.get("createdUser"), user)); predicates.add(builder.equal(root.get("createdUser"), user));
} }
predicates.addAllIterable(extraListPredicates(root, query, builder));
return builder.and(predicates.toArray(new Predicate[predicates.size()])); return builder.and(predicates.toArray(new Predicate[predicates.size()]));
}, },
Sort.by("createdTime").descending() Sort.by("createdTime").descending()
@@ -81,12 +85,17 @@ public abstract class SimpleServiceSupport<ENTITY extends SimpleEntity> implemen
if (User.isNotAdministrator(user)) { if (User.isNotAdministrator(user)) {
predicates.add(builder.equal(root.get("createdUser"), user)); predicates.add(builder.equal(root.get("createdUser"), user));
} }
predicates.addAllIterable(extraListPredicates(root, query, builder));
return builder.and(predicates.toArray(new Predicate[predicates.size()])); return builder.and(predicates.toArray(new Predicate[predicates.size()]));
}, },
Sort.by("createdTime").descending() Sort.by("createdTime").descending()
)); ));
} }
protected ImmutableList<Predicate> extraListPredicates(Root<ENTITY> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
return Lists.immutable.empty();
}
@Override @Override
public Optional<ENTITY> detailOptional(Long id) { public Optional<ENTITY> detailOptional(Long id) {
if (ObjectUtil.isNull(id)) { if (ObjectUtil.isNull(id)) {
@@ -101,11 +110,16 @@ public abstract class SimpleServiceSupport<ENTITY extends SimpleEntity> implemen
if (User.isNotAdministrator(user)) { if (User.isNotAdministrator(user)) {
predicates.add(builder.equal(root.get("createdUser"), user)); predicates.add(builder.equal(root.get("createdUser"), user));
} }
predicates.addAllIterable(extraDetailPredicates(root, query, builder));
return builder.and(predicates.toArray(new Predicate[predicates.size()])); return builder.and(predicates.toArray(new Predicate[predicates.size()]));
} }
); );
} }
protected ImmutableList<Predicate> extraDetailPredicates(Root<ENTITY> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
return Lists.immutable.empty();
}
@Override @Override
public ENTITY detail(Long id) { public ENTITY detail(Long id) {
return detailOrNull(id); return detailOrNull(id);

View File

@@ -7,6 +7,7 @@ import com.eshore.gringotts.web.domain.check.service.CheckOrderService;
import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import java.time.LocalDateTime;
import lombok.Data; import lombok.Data;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -27,18 +28,18 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j @Slf4j
@RestController @RestController
@RequestMapping("check_order") @RequestMapping("check_order")
public class CheckController implements ListController<CheckController.ListItem> { public class CheckOrderController implements ListController<CheckOrderController.ListItem> {
private final CheckOrderService checkOrderService; private final CheckOrderService checkOrderService;
private final ObjectMapper mapper; private final ObjectMapper mapper;
public CheckController(CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) { public CheckOrderController(CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
this.checkOrderService = checkOrderService; this.checkOrderService = checkOrderService;
this.mapper = builder.build(); this.mapper = builder.build();
} }
@GetMapping("/list") @GetMapping("/list")
@Override @Override
public AmisResponse<ImmutableList<CheckController.ListItem>> list() throws Exception { public AmisResponse<ImmutableList<CheckOrderController.ListItem>> list() throws Exception {
return AmisResponse.responseSuccess(checkOrderService.list().collect(this::toListItem)); return AmisResponse.responseSuccess(checkOrderService.list().collect(this::toListItem));
} }
@@ -50,6 +51,10 @@ public class CheckController implements ListController<CheckController.ListItem>
item.setType(order.getType()); item.setType(order.getType());
item.setParameters(mapper.readValue(order.getParameters(), new TypeReference<>() {})); item.setParameters(mapper.readValue(order.getParameters(), new TypeReference<>() {}));
item.setOver(order.getOver()); item.setOver(order.getOver());
item.setCreatedUsername(order.getCreatedUser().getUsername());
item.setCreatedTime(order.getCreatedTime());
item.setModifiedUsername(order.getModifiedUser().getUsername());
item.setModifiedTime(order.getModifiedTime());
return item; return item;
} }
@@ -67,5 +72,9 @@ public class CheckController implements ListController<CheckController.ListItem>
private CheckOrder.Type type; private CheckOrder.Type type;
private ImmutableMap<String, Object> parameters; private ImmutableMap<String, Object> parameters;
private Boolean over; private Boolean over;
private LocalDateTime createdTime;
private String createdUsername;
private LocalDateTime modifiedTime;
private String modifiedUsername;
} }
} }

View File

@@ -36,6 +36,7 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@Table(name = Constants.TABLE_PREFIX + "check_order") @Table(name = Constants.TABLE_PREFIX + "check_order")
@NamedEntityGraph(name = "check_order.list", attributeNodes = { @NamedEntityGraph(name = "check_order.list", attributeNodes = {
@NamedAttributeNode(value = "createdUser"), @NamedAttributeNode(value = "createdUser"),
@NamedAttributeNode(value = "modifiedUser"),
}) })
@NamedEntityGraph(name = "check_order.detail", attributeNodes = { @NamedEntityGraph(name = "check_order.detail", attributeNodes = {
@NamedAttributeNode(value = "createdUser"), @NamedAttributeNode(value = "createdUser"),

View File

@@ -1,17 +1,15 @@
package com.eshore.gringotts.web.domain.confirmation.entity; package com.eshore.gringotts.web.domain.confirmation.entity;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.SimpleEntity; import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
import com.eshore.gringotts.web.domain.resource.entity.DataResource; import com.eshore.gringotts.web.domain.resource.entity.DataResource;
import com.eshore.gringotts.web.domain.upload.entity.DataFile; import com.eshore.gringotts.web.domain.upload.entity.DataFile;
import java.util.Set; import java.util.Set;
import javax.persistence.CascadeType; import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.ConstraintMode; import javax.persistence.ConstraintMode;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.EntityListeners; import javax.persistence.EntityListeners;
import javax.persistence.EnumType;
import javax.persistence.Enumerated;
import javax.persistence.FetchType; import javax.persistence.FetchType;
import javax.persistence.ForeignKey; import javax.persistence.ForeignKey;
import javax.persistence.JoinColumn; import javax.persistence.JoinColumn;
@@ -25,6 +23,8 @@ import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.DynamicUpdate; import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
import org.springframework.data.jpa.domain.support.AuditingEntityListener; import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/** /**
@@ -50,39 +50,16 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@NamedAttributeNode(value = "createdUser"), @NamedAttributeNode(value = "createdUser"),
@NamedAttributeNode(value = "modifiedUser"), @NamedAttributeNode(value = "modifiedUser"),
}) })
public class Confirmation extends SimpleEntity { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "confirmation" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
public class Confirmation extends CheckingNeededEntity {
@OneToOne(fetch = FetchType.EAGER) @OneToOne(fetch = FetchType.EAGER)
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private DataResource target; private DataResource target;
private String description;
@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY) @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY)
@JoinTable(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT), inverseForeignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinTable(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT), inverseForeignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private Set<DataFile> evidences; private Set<DataFile> evidences;
@Column(nullable = false)
@Enumerated(EnumType.STRING)
private State state = State.DRAFT;
public enum State {
/**
* 无确权
*/
NONE,
/**
* 草稿
*/
DRAFT,
/**
* 审查中
*/
CHECKING,
/**
* 正常
*/
NORMAL,
/**
* 驳回
*/
REJECT,
}
} }

View File

@@ -2,7 +2,7 @@ package com.eshore.gringotts.web.domain.resource.entity;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.authentication.entity.Authentication; import com.eshore.gringotts.web.domain.authentication.entity.Authentication;
import com.eshore.gringotts.web.domain.base.entity.SimpleEntity; import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
import com.eshore.gringotts.web.domain.confirmation.entity.Confirmation; import com.eshore.gringotts.web.domain.confirmation.entity.Confirmation;
import com.eshore.gringotts.web.domain.resource.entity.format.ResourceFormat; import com.eshore.gringotts.web.domain.resource.entity.format.ResourceFormat;
import com.eshore.gringotts.web.domain.resource.entity.type.ResourceType; import com.eshore.gringotts.web.domain.resource.entity.type.ResourceType;
@@ -25,6 +25,8 @@ import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.DynamicUpdate; import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
import org.springframework.data.jpa.domain.support.AuditingEntityListener; import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@Getter @Getter
@@ -48,26 +50,33 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@NamedAttributeNode(value = "createdUser"), @NamedAttributeNode(value = "createdUser"),
@NamedAttributeNode(value = "modifiedUser"), @NamedAttributeNode(value = "modifiedUser"),
}) })
public class DataResource extends SimpleEntity { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "data_resource" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
public class DataResource extends LogicDeleteEntity {
@Column(nullable = false) @Column(nullable = false)
private String name; private String name;
private String description; private String description;
@OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.LAZY) @OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.LAZY)
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private ResourceType type; private ResourceType type;
@OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.LAZY) @OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.LAZY)
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private ResourceFormat format; private ResourceFormat format;
@OneToOne(fetch = FetchType.LAZY) @OneToOne(fetch = FetchType.LAZY)
@JoinColumn(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private DataFile example; private DataFile example;
@OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.EAGER, mappedBy = "target") @OneToOne(cascade = CascadeType.REMOVE, fetch = FetchType.EAGER, mappedBy = "target")
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private Confirmation confirmation; private Confirmation confirmation;
@OneToMany(cascade = CascadeType.REMOVE, fetch = FetchType.EAGER, mappedBy = "target") @OneToMany(cascade = CascadeType.REMOVE, fetch = FetchType.EAGER, mappedBy = "target")
@ToString.Exclude @ToString.Exclude
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
private Set<Authentication> authentications; private Set<Authentication> authentications;
} }

View File

@@ -1,5 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorValue; import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -7,6 +9,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* CSV格式 * CSV格式
@@ -21,6 +25,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@DiscriminatorValue("CSV") @DiscriminatorValue("CSV")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class CsvResourceFormat extends ResourceFormat { public class CsvResourceFormat extends ResourceFormat {
private String schema; private String schema;

View File

@@ -1,5 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorValue; import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -7,6 +9,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* JSON line格式 * JSON line格式
@@ -21,6 +25,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@DiscriminatorValue("JSON_LINE") @DiscriminatorValue("JSON_LINE")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class JsonLineResourceFormat extends ResourceFormat { public class JsonLineResourceFormat extends ResourceFormat {
private String schema; private String schema;

View File

@@ -1,5 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorValue; import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -7,6 +9,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 一个文件就是一个JSON * 一个文件就是一个JSON
@@ -21,6 +25,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@DiscriminatorValue("JSON") @DiscriminatorValue("JSON")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class JsonResourceFormat extends ResourceFormat { public class JsonResourceFormat extends ResourceFormat {
private String schema; private String schema;

View File

@@ -1,10 +1,14 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorValue; import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 无格式,文件每行就是一份数据 * 无格式,文件每行就是一份数据
@@ -17,6 +21,8 @@ import lombok.ToString;
@ToString @ToString
@Entity @Entity
@DiscriminatorValue("LINE") @DiscriminatorValue("LINE")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class LineResourceFormat extends ResourceFormat { public class LineResourceFormat extends ResourceFormat {
@Override @Override
public Type getFormatType() { public Type getFormatType() {

View File

@@ -1,10 +1,14 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorValue; import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 无格式,整个文件就是一份数据 * 无格式,整个文件就是一份数据
@@ -17,6 +21,8 @@ import lombok.ToString;
@ToString @ToString
@Entity @Entity
@DiscriminatorValue("NONE") @DiscriminatorValue("NONE")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class NoneResourceFormat extends ResourceFormat { public class NoneResourceFormat extends ResourceFormat {
@Override @Override
public Type getFormatType() { public Type getFormatType() {

View File

@@ -1,9 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.format; package com.eshore.gringotts.web.domain.resource.entity.format;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.IdOnlyEntity; import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.DiscriminatorColumn;
import javax.persistence.DiscriminatorType;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Inheritance; import javax.persistence.Inheritance;
import javax.persistence.InheritanceType; import javax.persistence.InheritanceType;
@@ -11,6 +9,8 @@ import javax.persistence.Table;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 资源格式 * 资源格式
@@ -24,8 +24,9 @@ import lombok.ToString;
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_format") @Table(name = Constants.TABLE_PREFIX + "resource_format")
@Inheritance(strategy = InheritanceType.SINGLE_TABLE) @Inheritance(strategy = InheritanceType.SINGLE_TABLE)
@DiscriminatorColumn(name = "type", discriminatorType = DiscriminatorType.STRING) @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_format" + " set deleted = true where id = ?")
public abstract class ResourceFormat extends IdOnlyEntity { @Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public abstract class ResourceFormat extends LogicDeleteIdOnlyEntity {
public enum Type { public enum Type {
NONE, NONE,
LINE, LINE,

View File

@@ -1,6 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.Column; import javax.persistence.Column;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Table; import javax.persistence.Table;
@@ -9,6 +10,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
@Getter @Getter
@Setter @Setter
@@ -17,6 +20,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type_api") @Table(name = Constants.TABLE_PREFIX + "resource_type_api")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type_api" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class ApiResourceType extends ResourceType { public class ApiResourceType extends ResourceType {
@Column(nullable = false) @Column(nullable = false)
private String url; private String url;

View File

@@ -1,6 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.Column; import javax.persistence.Column;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.EnumType; import javax.persistence.EnumType;
@@ -11,6 +12,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
@Getter @Getter
@Setter @Setter
@@ -19,6 +22,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type_database") @Table(name = Constants.TABLE_PREFIX + "resource_type_database")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type_database" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class DatabaseResourceType extends ResourceType { public class DatabaseResourceType extends ResourceType {
@Column(nullable = false) @Column(nullable = false)
private String jdbc; private String jdbc;

View File

@@ -1,13 +1,12 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import com.eshore.gringotts.web.domain.upload.entity.DataFile; import com.eshore.gringotts.web.domain.upload.entity.DataFile;
import javax.persistence.ConstraintMode; import javax.persistence.ConstraintMode;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.ForeignKey; import javax.persistence.ForeignKey;
import javax.persistence.JoinColumn; import javax.persistence.JoinColumn;
import javax.persistence.NamedAttributeNode;
import javax.persistence.NamedEntityGraph;
import javax.persistence.OneToOne; import javax.persistence.OneToOne;
import javax.persistence.Table; import javax.persistence.Table;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -15,6 +14,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
@Getter @Getter
@Setter @Setter
@@ -23,9 +24,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type_file") @Table(name = Constants.TABLE_PREFIX + "resource_type_file")
@NamedEntityGraph(name = "file_resource_type.detail", attributeNodes = { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type_file" + " set deleted = true where id = ?")
@NamedAttributeNode(value = "file") @Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
})
public class FileResourceType extends ResourceType { public class FileResourceType extends ResourceType {
@OneToOne @OneToOne
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))

View File

@@ -1,6 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.Column; import javax.persistence.Column;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Table; import javax.persistence.Table;
@@ -9,6 +10,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
@Getter @Getter
@Setter @Setter
@@ -17,6 +20,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type_ftp") @Table(name = Constants.TABLE_PREFIX + "resource_type_ftp")
@SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type_ftp" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public class FtpResourceType extends ResourceType { public class FtpResourceType extends ResourceType {
@Column(nullable = false) @Column(nullable = false)
private String url; private String url;

View File

@@ -1,13 +1,12 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import com.eshore.gringotts.web.domain.upload.entity.DataFile; import com.eshore.gringotts.web.domain.upload.entity.DataFile;
import javax.persistence.ConstraintMode; import javax.persistence.ConstraintMode;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.ForeignKey; import javax.persistence.ForeignKey;
import javax.persistence.JoinColumn; import javax.persistence.JoinColumn;
import javax.persistence.NamedAttributeNode;
import javax.persistence.NamedEntityGraph;
import javax.persistence.OneToOne; import javax.persistence.OneToOne;
import javax.persistence.Table; import javax.persistence.Table;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -15,6 +14,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
@Getter @Getter
@Setter @Setter
@@ -23,10 +24,8 @@ import lombok.ToString;
@NoArgsConstructor @NoArgsConstructor
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type_hdfs") @Table(name = Constants.TABLE_PREFIX + "resource_type_hdfs")
@NamedEntityGraph(name = "hdfs_resource_type.detail", attributeNodes = { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type_hdfs" + " set deleted = true where id = ?")
@NamedAttributeNode(value = "coreSite"), @Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
@NamedAttributeNode(value = "hdfsSite"),
})
public class HDFSResourceType extends ResourceType { public class HDFSResourceType extends ResourceType {
@OneToOne @OneToOne
@JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT)) @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))

View File

@@ -1,7 +1,7 @@
package com.eshore.gringotts.web.domain.resource.entity.type; package com.eshore.gringotts.web.domain.resource.entity.type;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.IdOnlyEntity; import com.eshore.gringotts.web.domain.base.entity.LogicDeleteIdOnlyEntity;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Inheritance; import javax.persistence.Inheritance;
import javax.persistence.InheritanceType; import javax.persistence.InheritanceType;
@@ -9,6 +9,8 @@ import javax.persistence.Table;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 资源类型 * 资源类型
@@ -21,8 +23,10 @@ import lombok.ToString;
@ToString @ToString
@Entity @Entity
@Table(name = Constants.TABLE_PREFIX + "resource_type") @Table(name = Constants.TABLE_PREFIX + "resource_type")
@Inheritance(strategy = InheritanceType.JOINED) @Inheritance(strategy = InheritanceType.TABLE_PER_CLASS)
public abstract class ResourceType extends IdOnlyEntity { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "resource_type" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteIdOnlyEntity.LOGIC_DELETE_CLAUSE)
public abstract class ResourceType extends LogicDeleteIdOnlyEntity {
public abstract Type getResourceType(); public abstract Type getResourceType();
public enum Type { public enum Type {

View File

@@ -1,13 +1,15 @@
package com.eshore.gringotts.web.domain.upload.entity; package com.eshore.gringotts.web.domain.upload.entity;
import com.eshore.gringotts.core.Constants; import com.eshore.gringotts.core.Constants;
import com.eshore.gringotts.web.domain.base.entity.SimpleEntity; import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.Table; import javax.persistence.Table;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.DynamicUpdate; import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
/** /**
* 上传文件 * 上传文件
@@ -21,7 +23,9 @@ import org.hibernate.annotations.DynamicUpdate;
@Entity @Entity
@DynamicUpdate @DynamicUpdate
@Table(name = Constants.TABLE_PREFIX + "data_file") @Table(name = Constants.TABLE_PREFIX + "data_file")
public class DataFile extends SimpleEntity { @SQLDelete(sql = "update " + Constants.TABLE_PREFIX + "data_file" + " set deleted = true where id = ?")
@Where(clause = LogicDeleteEntity.LOGIC_DELETE_CLAUSE)
public class DataFile extends LogicDeleteEntity {
private String filename; private String filename;
private Long size; private Long size;
private String md5; private String md5;