feat(web): 完善confirmation快照页面

feat(frontend): 增加测试页面
feat(web): 增加审批快照的生成
2025-01-14 15:48:51 +08:00 · 2025-01-14 15:48:23 +08:00 · 2025-01-08 15:41:48 +08:00 · 2025-01-08 10:41:40 +08:00 · 2025-01-03 18:30:05 +08:00
22 changed files with 878 additions and 447 deletions
--- a/gringotts-frontend/components/constants.js
+++ b/gringotts-frontend/components/constants.js
@@ -261,13 +261,19 @@ export const permissionStateMapping = [
 export const checkTypeMapping = [
  mappingItem('确权审查', 'CONFIRMATION', 'bg-blue-500'),
  mappingItem('授权审查', 'AUTHENTICATION', 'bg-purple-500'),
-  mappingItem('上架审查', 'MARKET', 'bg-green-500'),
+  mappingItem('上架审查', 'WARE', 'bg-green-500'),
 ]

 export const checkOverMapping = [
-  mappingItem('进行中', 'CHECKING', 'bg-warning'),
-  mappingItem('已撤销', 'RETRACT', 'bg-primary'),
-  mappingItem('已办结', 'OVER', 'bg-success'),
+  mappingItem('进行中', 'RUNNING', 'bg-warning'),
+  mappingItem('已撤销', 'TERMINAL', 'bg-primary'),
+  mappingItem('已办结', 'COMPLETED', 'bg-success'),
+]
+
+export const checkActionMapping = [
+  mappingItem('同意', 'APPROVE', 'bg-green-500'),
+  mappingItem('驳回', 'REJECT', 'bg-red-500'),
+  mappingItem('撤回', 'TERMINAL', 'bg-blue-500'),
 ]

 function api(method, url) {
--- a/gringotts-frontend/pages/index/tab-check.js
+++ b/gringotts-frontend/pages/index/tab-check.js
@@ -1,16 +1,49 @@
 import {
  apiGet,
+  checkActionMapping,
  checkOverMapping,
  checkTypeMapping,
  crudCommonOptions,
  mappingField,
  operationField,
+  readOnlyDialogOptions,
  stringField,
  timeField,
 } from "../../components/constants.js";
 import {authenticationDetailDialog, confirmationDetailDialog} from "../../components/permission/dialog-permission.js";
 import {wareDetailDialog} from "../../components/ware/dialog-ware.js";

+function detailDialog() {
+  return {
+    actionType: 'dialog',
+    dialog: {
+      title: '详情',
+      size: 'md',
+      ...readOnlyDialogOptions(),
+      body: [
+        {
+          type: 'amis',
+          name: 'parameters.snapshot',
+        },
+        {type: 'divider'},
+        {
+          type: 'crud',
+          api: apiGet('${base}/check_order/history/${instanceId}'),
+          ...crudCommonOptions(),
+          headerToolbar: [
+            'reload',
+          ],
+          columns: [
+            mappingField('action', '类型', checkActionMapping),
+            stringField('comment', '描述'),
+            timeField('createdTime', '操作时间'),
+          ]
+        }
+      ]
+    }
+  }
+}
+
 export function tabCheck() {
  return [
    {
@@ -31,7 +64,14 @@ export function tabCheck() {
        stringField('modifiedUsername', '最后操作人', 100),
        operationField('操作', undefined, [
          {
-            visibleOn: "${type === 'CONFIRMATION' && state === 'CHECKING'}",
+            visibleOn: "${state === 'COMPLETED'}",
+            type: 'action',
+            label: '查看',
+            level: 'link',
+            ...detailDialog(),
+          },
+          {
+            visibleOn: "${type === 'CONFIRMATION' && state === 'RUNNING'}",
            type: 'action',
            label: '处理',
            level: 'link',
@@ -43,7 +83,7 @@ export function tabCheck() {
                  label: '同意',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/APPLY'),
+                  api: apiGet('${base}/check_order/approve/${instanceId}'),
                  reload: 'check_order_list',
                },
                {
@@ -51,21 +91,14 @@ export function tabCheck() {
                  label: '拒绝',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/REJECT'),
+                  api: apiGet('${base}/check_order/reject/${instanceId}'),
                  reload: 'check_order_list',
                },
              ],
            ),
          },
          {
-            visibleOn: "${type === 'CONFIRMATION' && state !== NORMAL}",
-            type: 'action',
-            label: '查看',
-            level: 'link',
-            ...confirmationDetailDialog('parameters.confirmationId'),
-          },
-          {
-            visibleOn: "${type === 'AUTHENTICATION' && state === 'CHECKING'}",
+            visibleOn: "${type === 'AUTHENTICATION' && state === 'RUNNING'}",
            type: 'action',
            label: '处理',
            level: 'link',
@@ -77,7 +110,7 @@ export function tabCheck() {
                  label: '同意',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/APPLY'),
+                  api: apiGet('${base}/check_order/approve/${instanceId}'),
                  reload: 'check_order_list',
                },
                {
@@ -85,21 +118,14 @@ export function tabCheck() {
                  label: '拒绝',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/REJECT'),
+                  api: apiGet('${base}/check_order/reject/${instanceId}'),
                  reload: 'check_order_list',
                },
              ],
            ),
          },
          {
-            visibleOn: "${type === 'AUTHENTICATION' && state !== NORMAL}",
-            type: 'action',
-            label: '查看',
-            level: 'link',
-            ...authenticationDetailDialog('parameters.authenticationId'),
-          },
-          {
-            visibleOn: "${type === 'MARKET' && state === 'CHECKING'}",
+            visibleOn: "${type === 'WARE' && state === 'RUNNING'}",
            type: 'action',
            label: '处理',
            level: 'link',
@@ -111,7 +137,7 @@ export function tabCheck() {
                  label: '同意',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/APPLY'),
+                  api: apiGet('${base}/check_order/approve/${instanceId}'),
                  reload: 'check_order_list',
                },
                {
@@ -119,19 +145,12 @@ export function tabCheck() {
                  label: '拒绝',
                  actionType: 'ajax',
                  close: true,
-                  api: apiGet('${base}/check_order/operation/${checkOrderId}/REJECT'),
+                  api: apiGet('${base}/check_order/reject/${instanceId}'),
                  reload: 'check_order_list',
                },
              ],
            ),
          },
-          {
-            visibleOn: "${type === 'MARKET' && state !== NORMAL}",
-            type: 'action',
-            label: '查看',
-            level: 'link',
-            ...wareDetailDialog('parameters.wareId'),
-          },
        ]),
      ],
    },
--- a/gringotts-frontend/pages/test/index.html
+++ b/gringotts-frontend/pages/test/index.html
@@ -0,0 +1,25 @@
+<!doctype html>
+<html lang="zh">
+<head>
+    <meta charset="UTF-8"/>
+    <meta content="width=device-width, initial-scale=1.0" name="viewport"/>
+    <title></title>
+    <link href="/assets/sdk/antd.css" rel="stylesheet"/>
+    <link href="/assets/sdk/helper.css" rel="stylesheet"/>
+    <link href="/assets/sdk/iconfont.css" rel="stylesheet"/>
+    <style>
+        html, body, #app {
+            position: relative;
+            width: 100%;
+            height: 100%;
+            margin: 0;
+            padding: 0;
+        }
+    </style>
+</head>
+<body>
+<div id="app"></div>
+<script src="/assets/sdk/sdk.js"></script>
+<script src="./main.js" type="module"></script>
+</body>
+</html>
--- a/gringotts-frontend/pages/test/main.js
+++ b/gringotts-frontend/pages/test/main.js
@@ -0,0 +1,124 @@
+import {useAmis} from "../../components/constants.js";
+
+useAmis((information) => {
+  return {
+    "type": "wrapper",
+    "size": "none",
+    "body": [
+      {
+        "type": "wrapper",
+        "body": [
+          {
+            "items": [
+              {
+                "label": "资源名称",
+                "span": 3,
+                "content": "文件资源"
+              },
+              {
+                "content": "FIle",
+                "span": 3,
+                "label": "资源描述"
+              }
+            ],
+            "type": "property"
+          },
+          {
+            "type": "divider"
+          },
+          {
+            "title": "资源类型定义",
+            "type": "property",
+            "items": [
+              {
+                "span": 3,
+                "label": "资源类型",
+                "content": "文件"
+              },
+              {
+                "span": 3,
+                "content": {
+                  "type": "flex",
+                  "alignItems": "start",
+                  "items": [
+                    {
+                      "label": "arthas-bin.zip",
+                      "api": {
+                        "method": "get",
+                        "url": "${base}/upload/download/3557040775256064",
+                        "headers": {
+                          "token": "${token|default:undefined}"
+                        },
+                        "responseType": "blob"
+                      },
+                      "actionType": "ajax",
+                      "type": "action",
+                      "level": "link"
+                    }
+                  ],
+                  "direction": "column"
+                },
+                "label": "文件"
+              },
+              {
+                label: '格式详情',
+                content: {
+                  type: 'editor',
+                  language: 'json',
+                  value: {
+                    "name": "arthas-bin.zip",
+                    "size": 1024,
+                    "type": "application/zip",
+                    "lastModified": 1673920000000,
+                    "lastModifiedDate": "2023-01-14T14:40:00.000Z",
+                    "webkitRelativePath": ""
+                  }
+                },
+              }
+            ]
+          },
+          {
+            "type": "divider"
+          },
+          {
+            "items": [
+              {
+                "label": "格式类型",
+                "content": "Json"
+              }
+            ],
+            "type": "property",
+            "title": "资源格式定义"
+          }
+        ],
+        "size": "none"
+      },
+      {
+        "type": "divider"
+      },
+      {
+        "items": [
+          {
+            "label": "创建人",
+            "span": 2,
+            "content": "administrator@eshore.com"
+          },
+          {
+            "content": "2025-01-14 14:41:56",
+            "label": "创建时间"
+          },
+          {
+            "span": 2,
+            "content": "administrator@eshore.com",
+            "label": "修改人"
+          },
+          {
+            "content": "2025-01-14 14:41:56",
+            "label": "修改时间"
+          }
+        ],
+        "type": "property"
+      }
+    ]
+  }
+})
--- a/gringotts-web/pom.xml
+++ b/gringotts-web/pom.xml
@@ -20,6 +20,10 @@
            <groupId>com.eshore</groupId>
            <artifactId>gringotts-forest</artifactId>
        </dependency>
+        <dependency>
+            <groupId>com.lanyuanxiaoyao</groupId>
+            <artifactId>flowable-spring-boot-jpa-starter</artifactId>
+        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/WebApplication.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/WebApplication.java
@@ -8,6 +8,7 @@ import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
@@ -21,7 +22,14 @@ import org.springframework.scheduling.annotation.EnableAsync;
 * @author lanyuanxiaoyao
 * @date 2024-11-14
 */
-@SpringBootApplication(scanBasePackages = {"com.eshore.gringotts"})
+@SpringBootApplication(scanBasePackages = {
+    "com.eshore.gringotts",
+    "com.lanyuanxiaoyao.flowable.jpa"
+})
+@EntityScan({
+    "com.eshore.gringotts.web.domain.entity",
+    "com.lanyuanxiaoyao.flowable.jpa.entity"
+})
@EnableFenix
@EnableJpaAuditing
@EnableAsync
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/entity/CheckingNeededEntity.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/entity/CheckingNeededEntity.java
@@ -1,14 +1,10 @@
 package com.eshore.gringotts.web.domain.base.entity;

-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import javax.persistence.CascadeType;
 import javax.persistence.Column;
 import javax.persistence.EntityListeners;
 import javax.persistence.EnumType;
 import javax.persistence.Enumerated;
-import javax.persistence.FetchType;
 import javax.persistence.MappedSuperclass;
-import javax.persistence.OneToOne;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
@@ -26,9 +22,7 @@ public class CheckingNeededEntity extends LogicDeleteEntity {
  @Enumerated(EnumType.STRING)
  private State state = State.DRAFT;

-  @OneToOne(cascade = CascadeType.DETACH, fetch = FetchType.LAZY)
-  @ToString.Exclude
-  private CheckOrder order;
+  private String flowableInstanceId;

  public enum State {
    /**
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/service/CheckingService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/service/CheckingService.java
@@ -2,10 +2,8 @@ package com.eshore.gringotts.web.domain.base.service;

 import com.eshore.gringotts.web.domain.base.entity.LogicDeleteEntity;
 import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
 import com.eshore.gringotts.web.domain.service.UserService;
 import javax.persistence.EntityManager;
-import org.eclipse.collections.api.map.ImmutableMap;

 /**
 * 需要审查
@@ -22,7 +20,5 @@ public abstract class CheckingService<ENTITY extends LogicDeleteEntity> extends

  abstract public void retract(Long id) throws Exception;

-  abstract public void onChecked(CheckOrder order, CheckOrder.Operation operation, ImmutableMap<String, Object> parameters);
-
-  abstract public ImmutableMap<String, Object> archive(ENTITY entity);
+  abstract protected Object archive(ENTITY entity);
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/CheckOrderController.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/CheckOrderController.java
@@ -3,18 +3,21 @@ package com.eshore.gringotts.web.domain.controller;
 import com.eshore.gringotts.web.configuration.amis.AmisResponse;
 import com.eshore.gringotts.web.domain.base.controller.ListController;
 import com.eshore.gringotts.web.domain.base.controller.query.Query;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import com.eshore.gringotts.web.domain.service.CheckOrderService;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.service.UserService;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableHistory;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import com.lanyuanxiaoyao.flowable.jpa.SpringFlowableManager;
 import java.time.LocalDateTime;
+import java.util.List;
 import lombok.Data;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
+import org.eclipse.collections.api.factory.Lists;
+import org.eclipse.collections.api.factory.Maps;
 import org.eclipse.collections.api.list.ImmutableList;
 import org.eclipse.collections.api.map.ImmutableMap;
-import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -32,55 +35,81 @@ import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("check_order")
 public class CheckOrderController implements ListController<CheckOrderController.ListItem> {
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
+  private final UserService userService;
+  private final SpringFlowableManager flowableManager;

-  public CheckOrderController(CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
-    this.checkOrderService = checkOrderService;
-    this.mapper = builder.build();
+  public CheckOrderController(UserService userService, SpringFlowableManager flowableManager) {
+    this.userService = userService;
+    this.flowableManager = flowableManager;
  }

  @GetMapping("/list")
  @Override
  public AmisResponse<ImmutableList<CheckOrderController.ListItem>> list() throws Exception {
-    return AmisResponse.responseSuccess(checkOrderService.list().collect(this::toListItem));
+    User user = userService.currentLoginUser();
+    return AmisResponse.responseSuccess(
+        Lists.immutable.ofAll(flowableManager.listInstances(
+            (root, query, builder) -> {
+              if (User.isAdministrator(user)) {
+                return null;
+              }
+              return builder.or(
+                  builder.like(root.get("extra"), user.getRole().name()),
+                  builder.like(root.get("extra"), user.getId().toString())
+              );
+            }
+        )).collect(this::toListItem)
+    );
  }

  @PostMapping("/list")
  @Override
  public AmisResponse<ImmutableList<ListItem>> list(@RequestBody Query query) throws Exception {
-    return AmisResponse.responseSuccess(checkOrderService.list().collect(this::toListItem));
+    throw new UnsupportedOperationException();
+  }
+
+  @GetMapping("/approve/{instanceId}")
+  public AmisResponse<Object> approve(@PathVariable String instanceId) {
+    flowableManager.approve(instanceId);
+    return AmisResponse.responseSuccess();
+  }
+
+  @GetMapping("/reject/{instanceId}")
+  public AmisResponse<Object> reject(@PathVariable String instanceId) {
+    flowableManager.reject(instanceId);
+    return AmisResponse.responseSuccess();
+  }
+
+  @GetMapping("/history/{instanceId}")
+  public AmisResponse<List<FlowableHistory>> history(@PathVariable String instanceId) {
+    return AmisResponse.responseSuccess(flowableManager.listHistories(instanceId));
  }

  @SneakyThrows
-  private ListItem toListItem(CheckOrder order) {
+  private ListItem toListItem(FlowableInstance instance) {
+    FlowableNode node = flowableManager.getNode(instance.getCurrentNodeId());
    ListItem item = new ListItem();
-    item.setCheckOrderId(order.getId());
-    item.setDescription(order.getDescription());
-    item.setType(order.getType());
-    item.setParameters(mapper.readValue(order.getParameters(), new TypeReference<>() {}));
-    item.setState(order.getState());
-    item.setCreatedUsername(order.getCreatedUser().getUsername());
-    item.setCreatedTime(order.getCreatedTime());
-    item.setModifiedUsername(order.getModifiedUser().getUsername());
-    item.setModifiedTime(order.getModifiedTime());
+    item.setInstanceId(instance.getInstanceId());
+    item.setName(node.getName());
+    item.setDescription(node.getDescription());
+    item.setType(instance.getMetadata().getStringOrDefault("type", "unknown"));
+    item.setParameters(Maps.immutable.ofAll(instance.getMetadata().getMetadata()));
+    item.setState(instance.getStatus());
+    item.setCreatedUsername(instance.getMetadata().getStringOrDefault("createdUsername", ""));
+    item.setCreatedTime(instance.getCreatedTime());
+    item.setModifiedUsername(instance.getMetadata().getStringOrDefault("modifiedUsername", ""));
+    item.setModifiedTime(instance.getUpdatedTime());
    return item;
  }

-  @GetMapping("/operation/{id}/{operation}")
-  public AmisResponse<Object> operation(@PathVariable Long id, @PathVariable CheckOrder.Operation operation) throws JsonProcessingException {
-    log.info("id:{}, operation:{}", id, operation);
-    checkOrderService.operation(id, operation);
-    return AmisResponse.responseSuccess();
-  }
-
  @Data
  public static final class ListItem {
-    private Long checkOrderId;
+    private String instanceId;
+    private String name;
    private String description;
-    private CheckOrder.Type type;
+    private String type;
    private ImmutableMap<String, Object> parameters;
-    private CheckOrder.State state;
+    private FlowableInstance.Status state;
    private LocalDateTime createdTime;
    private String createdUsername;
    private LocalDateTime modifiedTime;
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/CheckRoleAssessor.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/CheckRoleAssessor.java
@@ -0,0 +1,28 @@
+package com.eshore.gringotts.web.domain.flowable;
+
+import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.service.UserService;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAccessor;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAction;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250106
+ */
+@Service
+public class CheckRoleAssessor implements FlowableAccessor {
+  private final UserService userService;
+
+  public CheckRoleAssessor(UserService userService) {
+    this.userService = userService;
+  }
+
+  @Override
+  public boolean access(FlowableInstance flowableInstance, FlowableNode flowableNode, FlowableAction flowableAction) {
+    User.Role role = userService.currentLoginUser().getRole();
+    return User.Role.ADMINISTRATOR.equals(role) || User.Role.CHECKER.equals(role);
+  }
+}
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/UserAssessor.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/UserAssessor.java
@@ -0,0 +1,31 @@
+package com.eshore.gringotts.web.domain.flowable;
+
+import cn.hutool.core.util.NumberUtil;
+import com.eshore.gringotts.web.domain.service.UserService;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAccessor;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAction;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableMetadata;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250106
+ */
+@Service
+public class UserAssessor implements FlowableAccessor {
+  public static final String KEY = "user_access_key";
+
+  private final UserService userService;
+
+  public UserAssessor(UserService userService) {
+    this.userService = userService;
+  }
+
+  @Override
+  public boolean access(FlowableInstance flowableInstance, FlowableNode flowableNode, FlowableAction flowableAction) {
+    FlowableMetadata metadata = flowableInstance.getMetadata();
+    return NumberUtil.equals(userService.currentLoginUser().getId(), metadata.getLong(KEY));
+  }
+}
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/AuthenticationRepository.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/AuthenticationRepository.java
@@ -4,9 +4,12 @@ import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
 import com.eshore.gringotts.web.domain.entity.Authentication;
 import java.util.List;
 import java.util.Optional;
+import javax.transaction.Transactional;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;

 /**
@@ -27,4 +30,14 @@ public interface AuthenticationRepository extends SimpleRepository<Authenticatio
  @Override
  @EntityGraph(value = "authentication.detail", type = EntityGraph.EntityGraphType.FETCH)
  Optional<Authentication> findOne(Specification<Authentication> specification);
+
+  @Transactional
+  @Modifying
+  @Query("update Authentication confirmation set confirmation.state = ?2 where confirmation.id = ?1 and confirmation.deleted = false")
+  void updateStateById(Long id, Authentication.State state);
+
+  @Transactional
+  @Modifying
+  @Query("update Authentication confirmation set confirmation.flowableInstanceId = ?2 where confirmation.id = ?1 and confirmation.deleted = false")
+  void updateInstanceIdById(Long id, String instanceId);
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/ConfirmationRepository.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/ConfirmationRepository.java
@@ -4,9 +4,12 @@ import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
 import com.eshore.gringotts.web.domain.entity.Confirmation;
 import java.util.List;
 import java.util.Optional;
+import javax.transaction.Transactional;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;

 /**
@@ -28,5 +31,15 @@ public interface ConfirmationRepository extends SimpleRepository<Confirmation, L
  @EntityGraph(value = "confirmation.detail", type = EntityGraph.EntityGraphType.FETCH)
  Optional<Confirmation> findOne(Specification<Confirmation> specification);

-  Boolean existsByTarget_Id(Long id);
+  @Transactional
+  @Modifying
+  @Query("update Confirmation confirmation set confirmation.state = ?2 where confirmation.id = ?1 and confirmation.deleted = false")
+  void updateStateById(Long id, Confirmation.State state);
+
+  @Transactional
+  @Modifying
+  @Query("update Confirmation confirmation set confirmation.flowableInstanceId = ?2 where confirmation.id = ?1 and confirmation.deleted = false")
+  void updateInstanceIdById(Long id, String instanceId);
+
+  Boolean existsByTarget_Id(Long targetId);
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/WareRepository.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/WareRepository.java
@@ -4,9 +4,12 @@ import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
 import com.eshore.gringotts.web.domain.entity.Ware;
 import java.util.List;
 import java.util.Optional;
+import javax.transaction.Transactional;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;

@SuppressWarnings("NullableProblems")
@@ -23,4 +26,14 @@ public interface WareRepository extends SimpleRepository<Ware, Long> {
  @Override
  @EntityGraph(value = "ware.detail", type = EntityGraph.EntityGraphType.FETCH)
  Optional<Ware> findOne(Specification<Ware> specification);
+
+  @Transactional
+  @Modifying
+  @Query("update Ware ware set ware.state = ?2 where ware.id = ?1 and ware.deleted = false")
+  void updateStateById(Long id, Ware.State state);
+
+  @Transactional
+  @Modifying
+  @Query("update Ware ware set ware.flowableInstanceId = ?2 where ware.id = ?1 and ware.deleted = false")
+  void updateInstanceIdById(Long id, String instanceId);
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/AuthenticationService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/AuthenticationService.java
@@ -1,29 +1,26 @@
 package com.eshore.gringotts.web.domain.service;

+import cn.hutool.core.map.MapUtil;
 import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
 import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity;
 import com.eshore.gringotts.web.domain.base.service.CheckingService;
 import com.eshore.gringotts.web.domain.entity.Authentication;
-import com.eshore.gringotts.web.domain.entity.Authentication_;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import com.eshore.gringotts.web.domain.entity.CheckOrder_;
+import com.eshore.gringotts.web.domain.entity.Confirmation;
 import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.flowable.CheckRoleAssessor;
+import com.eshore.gringotts.web.domain.flowable.UserAssessor;
 import com.eshore.gringotts.web.domain.repository.AuthenticationRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAction;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableListener;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableMetadata;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import com.lanyuanxiaoyao.flowable.jpa.SpringFlowableManager;
 import javax.persistence.EntityManager;
-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.factory.Maps;
-import org.eclipse.collections.api.list.ImmutableList;
-import org.eclipse.collections.api.map.ImmutableMap;
-import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;

 /**
@@ -31,38 +28,38 @@ import org.springframework.stereotype.Service;
 * @date 2024-12-02
 */
@Slf4j
-@Service("com.eshore.gringotts.web.domain.service.AuthenticationService")
+@Service
 public class AuthenticationService extends CheckingService<Authentication> {
+  private static final String AUTHENTICATION_FLOW_ID = "4ba86acd-1420-450b-98f9-0ed41772fe53";
+
  private final AuthenticationRepository authenticationRepository;
  private final UserService userService;
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
+  private final SpringFlowableManager flowableManager;

-  public AuthenticationService(AuthenticationRepository repository, UserService userService, EntityManager manager, CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
+  public AuthenticationService(AuthenticationRepository repository, UserService userService, EntityManager manager, SpringFlowableManager flowableManager) {
    super(repository, userService, manager);
    this.authenticationRepository = repository;
    this.userService = userService;
-    this.checkOrderService = checkOrderService;
-    this.mapper = builder.build();
-  }

-  @Override
-  protected ImmutableList<Predicate> listPredicate(Root<Authentication> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
-    User loginUser = userService.currentLoginUser();
-    if (User.isAdministrator(loginUser)) {
-      return Lists.immutable.empty();
-    }
-    return Lists.immutable.of(builder.or(
-        builder.equal(root.get(Authentication_.createdUser), loginUser),
-        builder.and(
-            builder.equal(root.get(Authentication_.order).get(CheckOrder_.target), CheckOrder.Target.ROLE),
-            builder.equal(root.get(Authentication_.order).get(CheckOrder_.targetRole), loginUser.getRole())
-        ),
-        builder.and(
-            builder.equal(root.get(Authentication_.order).get(CheckOrder_.target), CheckOrder.Target.USER),
-            builder.equal(root.get(Authentication_.order).get(CheckOrder_.targetUser), loginUser)
-        )
-    ));
+    this.flowableManager = flowableManager;
+    FlowableNode userCheckNode = FlowableNode.builder()
+        .nodeId(AUTHENTICATION_FLOW_ID)
+        .name("用户审查")
+        .description("用户审查")
+        .listeners(Lists.mutable.of(AuthenticationService.AuthenticationFlowUserCheckListener.class.getName()))
+        .accessor(UserAssessor.class.getName())
+        .targets(Maps.mutable.of(
+            FlowableAction.APPROVE, "f087b0e4-0efa-4b26-945f-642436aa4aef"
+        ))
+        .build();
+    FlowableNode roleCheckNode = FlowableNode.builder()
+        .nodeId("f087b0e4-0efa-4b26-945f-642436aa4aef")
+        .name("授权审查")
+        .description("授权审查")
+        .listeners(Lists.mutable.of(AuthenticationService.AuthenticationFlowRoleCheckListener.class.getName()))
+        .accessor(CheckRoleAssessor.class.getName())
+        .build();
+    flowableManager.create(userCheckNode, roleCheckNode);
  }

  @Override
@@ -82,73 +79,34 @@ public class AuthenticationService extends CheckingService<Authentication> {
    return super.save(entity);
  }

-  @Transactional(rollbackOn = Throwable.class)
  @Override
-  public void submit(Long id) throws JsonProcessingException {
+  public void submit(Long id) {
+    User user = userService.currentLoginUser();
    Authentication authentication = detailOrThrow(id);
-    authentication.setState(CheckingNeededEntity.State.OWNER_CHECKING);
-    Long orderId = checkOrderService.save(new CheckOrder(
-        "authentication_owner_check",
-        StrUtil.format("数据资源「{}」的授权申请", authentication.getTarget().getName()),
-        CheckOrder.Type.AUTHENTICATION,
-        mapper.writeValueAsString(Maps.immutable.of("authenticationId", authentication.getId())),
-        "com.eshore.gringotts.web.domain.service.AuthenticationService",
-        authentication.getCreatedUser()
-    ));
-    CheckOrder order = checkOrderService.detailOrThrow(orderId);
-    authentication.setOrder(order);
-    save(authentication);
+    String instanceId = flowableManager.start(
+        AUTHENTICATION_FLOW_ID,
+        MapUtil.<String, Object>builder()
+            .put("authenticationId", id)
+            .put("type", "AUTHENTICATION")
+            .put("createdUsername", user.getUsername())
+            .put("modifiedUsername", user.getUsername())
+            .put(UserAssessor.KEY, authentication.getTarget().getCreatedUser().getId())
+            .build(),
+        authentication.getTarget().getCreatedUser().getId().toString()
+    );
+    authenticationRepository.updateInstanceIdById(id, instanceId);
+    authenticationRepository.updateStateById(id, Confirmation.State.CHECKING);
  }

-  @Transactional(rollbackOn = Throwable.class)
  @Override
  public void retract(Long id) {
    Authentication authentication = detailOrThrow(id);
-    authentication.setState(Authentication.State.DRAFT);
-    save(authentication);
-
-    CheckOrder order = authentication.getOrder();
-    order.setState(CheckOrder.State.RETRACT);
-    checkOrderService.save(order);
+    flowableManager.terminal(authentication.getFlowableInstanceId());
  }

  @Override
-  @Transactional(rollbackOn = Throwable.class)
-  public void onChecked(CheckOrder order, CheckOrder.Operation operation, ImmutableMap<String, Object> parameters) {
-    Long id = (Long) parameters.get("authenticationId");
-    Authentication authentication = detailOrThrow(id);
-    if (StrUtil.equals(order.getKeyword(), "authentication_owner_check")) {
-      switch (operation) {
-        case APPLY:
-          authentication.setState(Authentication.State.CHECKING);
-          order.setKeyword("authentication_checker_check");
-          order.setTarget(CheckOrder.Target.ROLE);
-          order.setTargetRole(User.Role.CHECKER);
-          break;
-        case REJECT:
-          authentication.setState(Authentication.State.DRAFT);
-          order.setState(CheckOrder.State.OVER);
-          break;
-      }
-    } else if (StrUtil.equals(order.getKeyword(), "authentication_checker_check")) {
-      switch (operation) {
-        case APPLY:
-          authentication.setState(Authentication.State.NORMAL);
-          order.setState(CheckOrder.State.OVER);
-          break;
-        case REJECT:
-          authentication.setState(Authentication.State.DRAFT);
-          order.setState(CheckOrder.State.OVER);
-          break;
-      }
-    }
-    save(authentication);
-    checkOrderService.save(order);
-  }
-
-  @Override
-  public ImmutableMap<String, Object> archive(Authentication authentication) {
-    return null;
+  protected Object archive(Authentication entity) {
+    return "";
  }

  public static final class AuthenticationDuplicatedException extends RuntimeException {
@@ -156,4 +114,44 @@ public class AuthenticationService extends CheckingService<Authentication> {
      super("数据资源已绑定该账号的授权申请，无法再次申请");
    }
  }
+
+  @Component
+  public static final class AuthenticationFlowUserCheckListener extends FlowableListener.AbstractFlowableListener {
+    private final AuthenticationRepository authenticationRepository;
+
+    public AuthenticationFlowUserCheckListener(AuthenticationRepository authenticationRepository) {
+      this.authenticationRepository = authenticationRepository;
+    }
+
+    @Override
+    public void onActionComplete(FlowableInstance instance, FlowableNode node, FlowableAction action) {
+      FlowableMetadata metadata = instance.getMetadata();
+      Long authenticationId = metadata.getLong("authenticationId");
+      if (FlowableAction.APPROVE.equals(action)) {
+        instance.setExtra(User.Role.CHECKER.name());
+      } else {
+        authenticationRepository.updateStateById(authenticationId, Confirmation.State.DRAFT);
+      }
+    }
+  }
+
+  @Component
+  public static final class AuthenticationFlowRoleCheckListener extends FlowableListener.AbstractFlowableListener {
+    private final AuthenticationRepository authenticationRepository;
+
+    public AuthenticationFlowRoleCheckListener(AuthenticationRepository authenticationRepository) {
+      this.authenticationRepository = authenticationRepository;
+    }
+
+    @Override
+    public void onActionComplete(FlowableInstance instance, FlowableNode node, FlowableAction action) {
+      FlowableMetadata metadata = instance.getMetadata();
+      Long authenticationId = metadata.getLong("authenticationId");
+      if (FlowableAction.APPROVE.equals(action)) {
+        authenticationRepository.updateStateById(authenticationId, CheckingNeededEntity.State.NORMAL);
+      } else {
+        authenticationRepository.updateStateById(authenticationId, Confirmation.State.DRAFT);
+      }
+    }
+  }
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/CheckOrderService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/CheckOrderService.java
@@ -1,82 +0,0 @@
-package com.eshore.gringotts.web.domain.service;
-
-import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
-import com.eshore.gringotts.web.domain.base.service.CheckingService;
-import com.eshore.gringotts.web.domain.base.service.SimpleServiceSupport;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import com.eshore.gringotts.web.domain.entity.CheckOrder_;
-import com.eshore.gringotts.web.domain.entity.User;
-import com.eshore.gringotts.web.domain.repository.CheckOrderRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Predicate;
-import javax.persistence.criteria.Root;
-import lombok.extern.slf4j.Slf4j;
-import org.eclipse.collections.api.factory.Lists;
-import org.eclipse.collections.api.list.ImmutableList;
-import org.eclipse.collections.api.map.ImmutableMap;
-import org.springframework.context.ApplicationContext;
-import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
-import org.springframework.stereotype.Service;
-
-/**
- * @author lanyuanxiaoyao
- * @date 2024-11-29
- */
-@Slf4j
-@Service
-public class CheckOrderService extends SimpleServiceSupport<CheckOrder> {
-  private final ApplicationContext applicationContext;
-  private final ObjectMapper mapper;
-  private final CheckOrderRepository checkOrderRepository;
-  private final UserService userService;
-
-  public CheckOrderService(CheckOrderRepository repository, UserService userService, ApplicationContext applicationContext, Jackson2ObjectMapperBuilder builder) {
-    super(repository, userService);
-    this.applicationContext = applicationContext;
-    this.mapper = builder.build();
-    this.checkOrderRepository = repository;
-    this.userService = userService;
-  }
-
-  @Override
-  protected ImmutableList<Predicate> listPredicate(Root<CheckOrder> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
-    User user = userService.currentLoginUser();
-    if (User.isAdministrator(user)) {
-      return Lists.immutable.empty();
-    }
-    return Lists.immutable.of(builder.or(
-        builder.equal(root.get(CheckOrder_.createdUser), user),
-        builder.and(
-            builder.equal(root.get(CheckOrder_.target), CheckOrder.Target.USER),
-            builder.equal(root.get(CheckOrder_.targetUser), user)
-        ),
-        builder.and(
-            builder.equal(root.get(CheckOrder_.target), CheckOrder.Target.ROLE),
-            builder.equal(root.get(CheckOrder_.targetRole), user.getRole())
-        )
-    ));
-  }
-
-  public void operation(Long id, CheckOrder.Operation operation) throws JsonProcessingException {
-    CheckOrder order = detailOrThrow(id);
-    CheckingService service = applicationContext.getBean(order.getTargetClass(), CheckingService.class);
-    if (ObjectUtil.isNull(service)) {
-      throw new RuntimeException(StrUtil.format("名为「{}」的服务未找到", order.getTargetClass()));
-    }
-    ImmutableMap<String, Object> parameters = mapper.readValue(order.getParameters(), new TypeReference<>() {});
-    service.onChecked(order, operation, parameters);
-  }
-
-  public void retract(Long id) {
-    checkOrderRepository.overById(id, CheckOrder.State.RETRACT, userService.currentLoginUser());
-  }
-
-  public void over(Long id) {
-    checkOrderRepository.overById(id, CheckOrder.State.OVER, userService.currentLoginUser());
-  }
-}
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/ConfirmationService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/ConfirmationService.java
@@ -1,31 +1,24 @@
 package com.eshore.gringotts.web.domain.service;

+import cn.hutool.core.map.MapUtil;
 import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
-import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity;
 import com.eshore.gringotts.web.domain.base.service.CheckingService;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import com.eshore.gringotts.web.domain.entity.CheckOrder_;
 import com.eshore.gringotts.web.domain.entity.Confirmation;
-import com.eshore.gringotts.web.domain.entity.Confirmation_;
+import com.eshore.gringotts.web.domain.entity.DataResource;
 import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.flowable.CheckRoleAssessor;
 import com.eshore.gringotts.web.domain.repository.ConfirmationRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.eshore.gringotts.web.helper.AmisHelper;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAction;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableListener;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableMetadata;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import com.lanyuanxiaoyao.flowable.jpa.SpringFlowableManager;
 import javax.persistence.EntityManager;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Join;
-import javax.persistence.criteria.JoinType;
-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.factory.Maps;
-import org.eclipse.collections.api.list.ImmutableList;
-import org.eclipse.collections.api.map.ImmutableMap;
-import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;

 /**
@@ -33,42 +26,63 @@ import org.springframework.stereotype.Service;
 * @date 2024-11-26
 */
@Slf4j
-@Service("com.eshore.gringotts.web.domain.service.ConfirmationService")
+@Service
 public class ConfirmationService extends CheckingService<Confirmation> {
-  private final ConfirmationRepository confirmationRepository;
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
+  private static final String CONFIRMATION_FLOW_ID = "69d8ded5-35fd-4f03-b11a-be0ed91a4b8b";

-  public ConfirmationService(ConfirmationRepository confirmationRepository, UserService userService, EntityManager entityManager, CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
+  private final ConfirmationRepository confirmationRepository;
+  private final SpringFlowableManager flowableManager;
+
+  public ConfirmationService(ConfirmationRepository confirmationRepository, UserService userService, EntityManager entityManager, SpringFlowableManager flowableManager) {
    super(confirmationRepository, userService, entityManager);
    this.confirmationRepository = confirmationRepository;
-    this.checkOrderService = checkOrderService;
-    this.mapper = builder.build();
+
+    this.flowableManager = flowableManager;
+    FlowableNode node = FlowableNode.builder()
+        .nodeId(CONFIRMATION_FLOW_ID)
+        .name("确权审查")
+        .description("确权审查")
+        .listeners(Lists.mutable.of(ConfirmationService.ConfirmationFlowRoleCheckListener.class.getName()))
+        .accessor(CheckRoleAssessor.class.getName())
+        .build();
+    flowableManager.create(node);
  }

  @Override
-  protected ImmutableList<Predicate> listPredicate(Root<Confirmation> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
-    User loginUser = userService.currentLoginUser();
-    if (User.isAdministrator(loginUser)) {
-      return Lists.immutable.empty();
-    }
-    Join<Confirmation, CheckOrder> orderJoin = root.join(Confirmation_.order, JoinType.LEFT);
-    return Lists.immutable.of(builder.or(
-        builder.equal(root.get(Confirmation_.createdUser), loginUser),
-        builder.and(
-            builder.isNotNull(orderJoin),
-            builder.or(
-                builder.and(
-                    builder.equal(orderJoin.get(CheckOrder_.target), CheckOrder.Target.ROLE),
-                    builder.equal(orderJoin.get(CheckOrder_.targetRole), loginUser.getRole())
-                ),
-                builder.and(
-                    builder.equal(orderJoin.get(CheckOrder_.target), CheckOrder.Target.USER),
-                    builder.equal(orderJoin.get(CheckOrder_.targetUser), loginUser)
-                )
-            )
-        )
-    ));
+  public void submit(Long id) {
+    Confirmation confirmation = detailOrThrow(id);
+    User user = userService.currentLoginUser();
+    String instanceId = flowableManager.start(
+        CONFIRMATION_FLOW_ID,
+        MapUtil.<String, Object>builder()
+            .put("confirmationId", id)
+            .put("type", "CONFIRMATION")
+            .put("snapshot", archive(confirmation))
+            .put("createdUsername", user.getUsername())
+            .put("modifiedUsername", user.getUsername())
+            .build(),
+        User.Role.CHECKER.name()
+    );
+    confirmationRepository.updateInstanceIdById(id, instanceId);
+    confirmationRepository.updateStateById(id, Confirmation.State.CHECKING);
+  }
+
+  @Override
+  public void retract(Long id) {
+    Confirmation confirmation = detailOrThrow(id);
+    flowableManager.terminal(confirmation.getFlowableInstanceId());
+  }
+
+  @Override
+  protected Object archive(Confirmation entity) {
+    DataResource resource = entity.getTarget();
+    return AmisHelper.wrapper(
+        AmisHelper.property(resource),
+        AmisHelper.divider(),
+        AmisHelper.property(entity),
+        AmisHelper.divider(),
+        AmisHelper.property(resource.getExample())
+    );
  }

  @Override
@@ -79,65 +93,29 @@ public class ConfirmationService extends CheckingService<Confirmation> {
    return super.save(entity);
  }

-  @Transactional(rollbackOn = Throwable.class)
-  @Override
-  public void submit(Long id) throws JsonProcessingException {
-    Confirmation confirmation = detailOrThrow(id);
-    confirmation.setState(Confirmation.State.CHECKING);
-    Long orderId = checkOrderService.save(new CheckOrder(
-        "confirmation_check",
-        StrUtil.format("数据资源「{}」的确权申请", confirmation.getTarget().getName()),
-        CheckOrder.Type.CONFIRMATION,
-        mapper.writeValueAsString(Maps.immutable.of("confirmationId", confirmation.getId())),
-        "com.eshore.gringotts.web.domain.service.ConfirmationService",
-        User.Role.CHECKER
-    ));
-    CheckOrder order = checkOrderService.detailOrThrow(orderId);
-    confirmation.setOrder(order);
-    save(confirmation);
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  @Override
-  public void retract(Long id) {
-    Confirmation confirmation = detailOrThrow(id);
-    confirmation.setState(CheckingNeededEntity.State.DRAFT);
-    save(confirmation);
-
-    CheckOrder order = confirmation.getOrder();
-    order.setState(CheckOrder.State.RETRACT);
-    checkOrderService.save(order);
-  }
-
-  @Override
-  @Transactional(rollbackOn = Throwable.class)
-  public void onChecked(CheckOrder order, CheckOrder.Operation operation, ImmutableMap<String, Object> parameters) {
-    if (StrUtil.equals(order.getKeyword(), "confirmation_check")) {
-      Long id = (Long) parameters.get("confirmationId");
-      Confirmation confirmation = detailOrThrow(id);
-      switch (operation) {
-        case APPLY:
-          confirmation.setState(Confirmation.State.NORMAL);
-          order.setState(CheckOrder.State.OVER);
-          break;
-        case REJECT:
-          confirmation.setState(Confirmation.State.DRAFT);
-          order.setState(CheckOrder.State.OVER);
-          break;
-      }
-      save(confirmation);
-      checkOrderService.save(order);
-    }
-  }
-
-  @Override
-  public ImmutableMap<String, Object> archive(Confirmation confirmation) {
-    return null;
-  }
-
  public static final class ConfirmationDuplicatedException extends RuntimeException {
    public ConfirmationDuplicatedException() {
      super("数据资源已绑定确权申请，无法再次申请");
    }
  }
+
+  @Component
+  public static final class ConfirmationFlowRoleCheckListener extends FlowableListener.AbstractFlowableListener {
+    private final ConfirmationRepository confirmationRepository;
+
+    public ConfirmationFlowRoleCheckListener(ConfirmationRepository confirmationRepository) {
+      this.confirmationRepository = confirmationRepository;
+    }
+
+    @Override
+    public void onActionComplete(FlowableInstance instance, FlowableNode node, FlowableAction action) {
+      FlowableMetadata metadata = instance.getMetadata();
+      Long confirmationId = metadata.getLong("confirmationId");
+      if (action == FlowableAction.APPROVE) {
+        confirmationRepository.updateStateById(confirmationId, Confirmation.State.NORMAL);
+      } else {
+        confirmationRepository.updateStateById(confirmationId, Confirmation.State.DRAFT);
+      }
+    }
+  }
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/DataResourceService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/DataResourceService.java
@@ -14,7 +14,6 @@ import com.eshore.gringotts.web.domain.entity.type.ResourceType;
 import com.eshore.gringotts.web.domain.repository.DataResourceRepository;
 import com.eshore.gringotts.web.domain.repository.ResourceFormatRepository;
 import com.eshore.gringotts.web.domain.repository.ResourceTypeRepository;
-import com.eshore.gringotts.web.helper.EntityHelper;
 import javax.persistence.EntityManager;
 import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
@@ -56,26 +55,8 @@ public class DataResourceService extends LogicDeleteService<DataResource> {
      return Lists.immutable.empty();
    }

-    Subquery<Confirmation> confirmationSubquery = query.subquery(Confirmation.class);
-    Root<Confirmation> confirmationRoot = confirmationSubquery.from(Confirmation.class);
-    confirmationSubquery.select(confirmationRoot)
-        .where(
-            builder.equal(confirmationRoot.get(Confirmation_.target), root),
-            EntityHelper.checkNeededEntityPrediction(confirmationRoot, builder, loginUser)
-        );
-
-    Subquery<Authentication> authenticationSubquery = query.subquery(Authentication.class);
-    Root<Authentication> authenticationRoot = authenticationSubquery.from(Authentication.class);
-    authenticationSubquery.select(authenticationRoot)
-        .where(
-            builder.equal(authenticationRoot.get(Authentication_.target), root),
-            EntityHelper.checkNeededEntityPrediction(authenticationRoot, builder, loginUser)
-        );
-
    return Lists.immutable.of(builder.or(
-        builder.equal(root.get(DataResource_.createdUser), loginUser),
-        builder.exists(confirmationSubquery),
-        builder.exists(authenticationSubquery)
+        builder.equal(root.get(DataResource_.createdUser), loginUser)
    ));
  }

--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/WareService.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/WareService.java
@@ -1,21 +1,22 @@
 package com.eshore.gringotts.web.domain.service;

-import cn.hutool.core.util.StrUtil;
+import cn.hutool.core.map.MapUtil;
 import com.eshore.gringotts.web.domain.base.service.CheckingService;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
 import com.eshore.gringotts.web.domain.entity.User;
 import com.eshore.gringotts.web.domain.entity.Ware;
+import com.eshore.gringotts.web.domain.flowable.UserAssessor;
 import com.eshore.gringotts.web.domain.repository.WareRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableAction;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableInstance;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableListener;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableMetadata;
+import com.lanyuanxiaoyao.flowable.core.model.FlowableNode;
+import com.lanyuanxiaoyao.flowable.jpa.SpringFlowableManager;
 import javax.persistence.EntityManager;
-import javax.transaction.Transactional;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.collections.api.factory.Lists;
-import org.eclipse.collections.api.factory.Maps;
 import org.eclipse.collections.api.list.ImmutableList;
-import org.eclipse.collections.api.map.ImmutableMap;
-import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;

 /**
@@ -23,17 +24,28 @@ import org.springframework.stereotype.Service;
 * @date 2024-12-13
 */
@Slf4j
-@Service("com.eshore.gringotts.web.domain.service.WareService")
+@Service
 public class WareService extends CheckingService<Ware> {
-  private final WareRepository wareRepository;
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
+  private static final String WARE_FLOW_ID = "870e7376-1713-48ed-9e60-e602981c6ecc";

-  public WareService(WareRepository repository, UserService userService, EntityManager entityManager, CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
+  private final WareRepository wareRepository;
+  private final UserService userService;
+  private final SpringFlowableManager flowableManager;
+
+  public WareService(WareRepository repository, UserService userService, EntityManager entityManager, SpringFlowableManager flowableManager) {
    super(repository, userService, entityManager);
    this.wareRepository = repository;
-    this.checkOrderService = checkOrderService;
-    this.mapper = builder.build();
+    this.userService = userService;
+
+    this.flowableManager = flowableManager;
+    FlowableNode node = FlowableNode.builder()
+        .nodeId(WARE_FLOW_ID)
+        .name("上架审查")
+        .description("上架审查")
+        .listeners(Lists.mutable.of(WareService.WareFlowUserCheckListener.class.getName()))
+        .accessor(UserAssessor.class.getName())
+        .build();
+    flowableManager.create(node);
  }

  public ImmutableList<Ware> listPublic() {
@@ -42,59 +54,53 @@ public class WareService extends CheckingService<Ware> {
    );
  }

-  @Transactional(rollbackOn = Throwable.class)
  @Override
-  public void onChecked(CheckOrder order, CheckOrder.Operation operation, ImmutableMap<String, Object> parameters) {
-    if (StrUtil.equals(order.getKeyword(), "ware_check")) {
-      Long wareId = (Long) parameters.get("wareId");
-      Ware ware = detailOrThrow(wareId);
-      switch (operation) {
-        case APPLY:
-          ware.setState(Ware.State.NORMAL);
-          order.setState(CheckOrder.State.OVER);
-          break;
-        case REJECT:
-          ware.setState(Ware.State.DRAFT);
-          order.setState(CheckOrder.State.OVER);
-          break;
-      }
-      save(ware);
-      checkOrderService.save(order);
-    }
-  }
-
-  @Override
-  public ImmutableMap<String, Object> archive(Ware ware) {
-    return null;
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  @Override
-  public void submit(Long id) throws JsonProcessingException {
+  public void submit(Long id) {
+    User user = userService.currentLoginUser();
    Ware ware = detailOrThrow(id);
-    ware.setState(Ware.State.CHECKING);
-    Long orderId = checkOrderService.save(new CheckOrder(
-        "ware_check",
-        StrUtil.format("数据资源「{}」的上架申请", ware.getName()),
-        CheckOrder.Type.MARKET,
-        mapper.writeValueAsString(Maps.immutable.of("wareId", ware.getId())),
-        "com.eshore.gringotts.web.domain.service.WareService",
-        User.Role.CHECKER
-    ));
-    CheckOrder order = checkOrderService.detailOrThrow(orderId);
-    ware.setOrder(order);
-    save(ware);
+    String instanceId = flowableManager.start(
+        WARE_FLOW_ID,
+        MapUtil.<String, Object>builder()
+            .put("wareId", id)
+            .put("type", "WARE")
+            .put("createdUsername", user.getUsername())
+            .put("modifiedUsername", user.getUsername())
+            .put(UserAssessor.KEY, ware.getResource().getCreatedUser().getId())
+            .build(),
+        ware.getResource().getCreatedUser().getId().toString()
+    );
+    wareRepository.updateInstanceIdById(id, instanceId);
+    wareRepository.updateStateById(id, Ware.State.CHECKING);
  }

-  @Transactional(rollbackOn = Throwable.class)
  @Override
  public void retract(Long id) {
    Ware ware = detailOrThrow(id);
-    ware.setState(Ware.State.DRAFT);
-    save(ware);
+    flowableManager.terminal(ware.getFlowableInstanceId());
+  }

-    CheckOrder order = ware.getOrder();
-    order.setState(CheckOrder.State.RETRACT);
-    checkOrderService.save(order);
+  @Override
+  protected Object archive(Ware entity) {
+    return "";
+  }
+
+  @Component
+  public static final class WareFlowUserCheckListener extends FlowableListener.AbstractFlowableListener {
+    private final WareRepository wareRepository;
+
+    public WareFlowUserCheckListener(WareRepository wareRepository) {
+      this.wareRepository = wareRepository;
+    }
+
+    @Override
+    public void onActionComplete(FlowableInstance instance, FlowableNode node, FlowableAction action) {
+      FlowableMetadata metadata = instance.getMetadata();
+      Long wareId = metadata.getLong("wareId");
+      if (FlowableAction.APPROVE.equals(action)) {
+        wareRepository.updateStateById(wareId, Ware.State.NORMAL);
+      } else {
+        wareRepository.updateStateById(wareId, Ware.State.DRAFT);
+      }
+    }
  }
 }
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/helper/AmisHelper.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/helper/AmisHelper.java
@@ -0,0 +1,243 @@
+package com.eshore.gringotts.web.helper;
+
+import cn.hutool.core.map.MapBuilder;
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.eshore.gringotts.web.domain.base.entity.SimpleEntity;
+import com.eshore.gringotts.web.domain.entity.DataFile;
+import com.eshore.gringotts.web.domain.entity.DataResource;
+import com.eshore.gringotts.web.domain.entity.format.CsvResourceFormat;
+import com.eshore.gringotts.web.domain.entity.format.JsonLineResourceFormat;
+import com.eshore.gringotts.web.domain.entity.format.JsonResourceFormat;
+import com.eshore.gringotts.web.domain.entity.format.ResourceFormat;
+import com.eshore.gringotts.web.domain.entity.type.ApiResourceType;
+import com.eshore.gringotts.web.domain.entity.type.DatabaseResourceType;
+import com.eshore.gringotts.web.domain.entity.type.FileResourceType;
+import com.eshore.gringotts.web.domain.entity.type.FtpResourceType;
+import com.eshore.gringotts.web.domain.entity.type.HDFSResourceType;
+import com.eshore.gringotts.web.domain.entity.type.ResourceType;
+import org.eclipse.collections.api.factory.Lists;
+import org.eclipse.collections.api.factory.Maps;
+import org.eclipse.collections.api.list.ImmutableList;
+import org.eclipse.collections.api.list.MutableList;
+import org.eclipse.collections.api.map.ImmutableMap;
+import org.hibernate.Hibernate;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250108
+ */
+public class AmisHelper {
+  @SafeVarargs
+  public static ImmutableMap<Object, Object> wrapper(ImmutableMap<Object, Object>... body) {
+    MapBuilder<Object, Object> builder = MapUtil.builder();
+    builder.put("type", "wrapper");
+    builder.put("size", "none");
+    builder.put("body", body);
+    return Maps.immutable.ofMap(builder.build());
+  }
+
+  public static ImmutableMap<Object, Object> divider() {
+    return Maps.immutable.of("type", "divider");
+  }
+
+  @SafeVarargs
+  public static ImmutableMap<Object, Object> property(ImmutableMap<Object, Object>... items) {
+    return property(null, items);
+  }
+
+  public static ImmutableMap<Object, Object> property(ImmutableList<ImmutableMap<Object, Object>> items) {
+    return property(null, items);
+  }
+
+  @SafeVarargs
+  public static ImmutableMap<Object, Object> property(String title, ImmutableMap<Object, Object>... items) {
+    return property(title, Lists.immutable.of(items));
+  }
+
+  public static ImmutableMap<Object, Object> property(String title, ImmutableList<ImmutableMap<Object, Object>> items) {
+    MapBuilder<Object, Object> builder = MapUtil.builder();
+    builder.put("type", "property");
+    if (StrUtil.isNotBlank(title)) {
+      builder.put("title", title);
+    }
+    if (ObjectUtil.isNotEmpty(items)) {
+      builder.put("items", items);
+    }
+    return Maps.immutable.ofMap(builder.build());
+  }
+
+  public static ImmutableMap<Object, Object> property(DataResource resource) {
+    return AmisHelper.wrapper(
+        AmisHelper.property(
+            AmisHelper.propertyItem("资源名称", resource.getName(), 3),
+            AmisHelper.propertyItem("资源描述", resource.getDescription(), 3)
+        ),
+        AmisHelper.divider(),
+        AmisHelper.property(resource.getType()),
+        AmisHelper.divider(),
+        AmisHelper.property(resource.getFormat())
+    );
+  }
+
+  public static ImmutableMap<Object, Object> property(ResourceType type) {
+    type = Hibernate.unproxy(type, ResourceType.class);
+    MutableList<ImmutableMap<Object, Object>> items = Lists.mutable.empty();
+    switch (type.getResourceType()) {
+      case API:
+        ApiResourceType apiResourceType = (ApiResourceType) type;
+        items.add(propertyItem("资源类型", "API", 3));
+        items.add(propertyItem("用户名", apiResourceType.getUsername(), 1));
+        items.add(propertyItem("密码", apiResourceType.getPassword(), 2));
+        items.add(propertyItem("地址", apiResourceType.getUrl(), 3));
+        break;
+      case FILE:
+        FileResourceType fileResourceType = (FileResourceType) type;
+        items.add(propertyItem("资源类型", "文件", 3));
+        items.add(propertyItem(fileResourceType.getFile()));
+        break;
+      case DATABASE:
+        DatabaseResourceType databaseResourceType = (DatabaseResourceType) type;
+        items.add(propertyItem("资源类型", "数据库"));
+        items.add(propertyItem("数据库", databaseResourceType.getDatabaseType().name(), 3));
+        items.add(propertyItem("地址", databaseResourceType.getJdbc(), 3));
+        items.add(propertyItem("用户名", databaseResourceType.getUsername(), 1));
+        items.add(propertyItem("密码", databaseResourceType.getPassword(), 2));
+        break;
+      case HDFS:
+        HDFSResourceType hdfsResourceType = (HDFSResourceType) type;
+        items.add(propertyItem("资源类型", "HDFS"));
+        items.add(propertyItem("core-site", hdfsResourceType.getCoreSite()));
+        items.add(propertyItem("hdfs-site", hdfsResourceType.getHdfsSite()));
+        break;
+      case FTP:
+        FtpResourceType ftpResourceType = (FtpResourceType) type;
+        items.add(propertyItem("资源类型", "FTP"));
+        items.add(propertyItem("地址", ftpResourceType.getUrl(), 3));
+        items.add(propertyItem("用户名", ftpResourceType.getUsername(), 1));
+        items.add(propertyItem("密码", ftpResourceType.getPassword(), 2));
+        items.add(propertyItem("根路径", ftpResourceType.getPath(), 3));
+        items.add(propertyItem("正则匹配过滤", ftpResourceType.getRegexFilter(), 3));
+        break;
+    }
+    return property("资源类型定义", items.toImmutable());
+  }
+
+  public static ImmutableMap<Object, Object> property(ResourceFormat format) {
+    format = Hibernate.unproxy(format, ResourceFormat.class);
+    MutableList<ImmutableMap<Object, Object>> items = Lists.mutable.empty();
+    switch (format.getFormatType()) {
+      case NONE:
+        items.add(propertyItem("格式类型", "文件", 3));
+        break;
+      case LINE:
+        items.add(propertyItem("格式类型", "文本行", 3));
+        break;
+      case JSON:
+        JsonResourceFormat jsonResourceFormat = (JsonResourceFormat) format;
+        items.add(propertyItem("格式类型", "Json", 3));
+        items.add(propertyItem("格式详情", editor("json", jsonResourceFormat.getJsonSchema()), 3));
+        break;
+      case JSON_LINE:
+        JsonLineResourceFormat jsonLineResourceFormat = (JsonLineResourceFormat) format;
+        items.add(propertyItem("格式类型", "Json Line", 3));
+        items.add(propertyItem("格式详情", editor("json", jsonLineResourceFormat.getJsonSchema()), 3));
+        break;
+      case CSV:
+        CsvResourceFormat csvResourceFormat = (CsvResourceFormat) format;
+        items.add(propertyItem("格式类型", "CSV文本", 3));
+        items.add(propertyItem("格式详情", editor("json", csvResourceFormat.getCsvSchema()), 3));
+        break;
+    }
+    return property("资源格式定义", items.toImmutable());
+  }
+
+  public static ImmutableMap<Object, Object> property(SimpleEntity entity) {
+    return property(
+        propertyItem("创建人", entity.getCreatedUser().getUsername(), 2),
+        propertyItem("创建时间", entity.getCreatedTime()),
+        propertyItem("修改人", entity.getModifiedUser().getUsername(), 2),
+        propertyItem("修改时间", entity.getModifiedTime())
+    );
+  }
+
+  public static ImmutableMap<Object, Object> property(DataFile dataFile) {
+    return property(
+        propertyItem("资源示例", dataFile)
+    );
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(String label, Object content) {
+    return propertyItem(label, content, null);
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(String label, Object content, Integer span) {
+    MapBuilder<Object, Object> builder = MapUtil.builder();
+    builder.put("label", label);
+    builder.put("content", content);
+    if (ObjectUtil.isNotNull(span)) {
+      builder.put("span", span);
+    }
+    return Maps.immutable.ofMap(builder.build());
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(String label, DataFile dataFile) {
+    return propertyItem(label, Lists.immutable.of(dataFile));
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(DataFile dataFile) {
+    return propertyItem(Lists.immutable.of(dataFile));
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(ImmutableList<DataFile> dataFiles) {
+    return propertyItem("文件", dataFiles);
+  }
+
+  public static ImmutableMap<Object, Object> propertyItem(String label, ImmutableList<DataFile> dataFiles) {
+    return propertyItem(
+        label,
+        flex(dataFiles.collect(file -> ajaxAction(file.getFilename(), "${base}/upload/download/" + file.getId()))),
+        3
+    );
+  }
+
+  public static ImmutableMap<Object, Object> editor(String language, String value) {
+    return Maps.immutable.ofMap(MapUtil.builder()
+        .put("disabled", true)
+        .put("type", "editor")
+        .put("language", language)
+        .put("value", value)
+        .build());
+  }
+
+  public static ImmutableMap<Object, Object> flex(ImmutableList<ImmutableMap<Object, Object>> items) {
+    return Maps.immutable.ofMap(MapUtil.builder()
+        .put("type", "flex")
+        .put("direction", "column")
+        .put("alignItems", "start")
+        .put("items", items)
+        .build());
+  }
+
+  public static ImmutableMap<Object, Object> ajaxAction(String label, String url) {
+    return Maps.immutable.ofMap(MapUtil.builder()
+        .put("type", "action")
+        .put("actionType", "ajax")
+        .put("label", label)
+        .put("level", "link")
+        .put("api", apiDownload(url))
+        .build());
+  }
+
+  public static ImmutableMap<Object, Object> apiDownload(String url) {
+    return Maps.immutable.ofMap(MapUtil.builder()
+        .put("method", "get")
+        .put("url", url)
+        .put("responseType", "blob")
+        .put("headers", MapUtil.builder()
+            .put("token", "${token|default:undefined}")
+            .build())
+        .build());
+  }
+}
--- a/gringotts-web/src/main/java/com/eshore/gringotts/web/helper/EntityHelper.java
+++ b/gringotts-web/src/main/java/com/eshore/gringotts/web/helper/EntityHelper.java
@@ -2,9 +2,6 @@ package com.eshore.gringotts.web.helper;

 import cn.hutool.core.util.ObjectUtil;
 import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity;
-import com.eshore.gringotts.web.domain.base.entity.CheckingNeededEntity_;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
-import com.eshore.gringotts.web.domain.entity.CheckOrder_;
 import com.eshore.gringotts.web.domain.entity.User;
 import java.util.function.Supplier;
 import javax.persistence.criteria.CriteriaBuilder;
@@ -28,14 +25,14 @@ public class EntityHelper {

  public static Predicate checkNeededEntityPrediction(Root<? extends CheckingNeededEntity> root, CriteriaBuilder builder, User loginUser) {
    return builder.or(
-        builder.and(
+        /* builder.and(
            builder.equal(root.get(CheckingNeededEntity_.order).get(CheckOrder_.target), CheckOrder.Target.ROLE),
            builder.equal(root.get(CheckingNeededEntity_.order).get(CheckOrder_.targetRole), loginUser.getRole())
        ),
        builder.and(
            builder.equal(root.get(CheckingNeededEntity_.order).get(CheckOrder_.target), CheckOrder.Target.USER),
            builder.equal(root.get(CheckingNeededEntity_.order).get(CheckOrder_.targetUser), loginUser)
-        )
+        ) */
    );
  }
 }
--- a/pom.xml
+++ b/pom.xml
@@ -60,6 +60,13 @@
                <version>${project.version}</version>
            </dependency>

+            <!-- Private Dependencies -->
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>flowable-spring-boot-jpa-starter</artifactId>
+                <version>1.0.0-SNAPSHOT</version>
+            </dependency>
+
            <!-- Spring Dependencies -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
Author	SHA1	Message	Date
lanyuanxiaoyao	36c8959c01	feat(web): 完善confirmation快照页面	2025-01-14 15:48:51 +08:00
lanyuanxiaoyao	4242940e6b	feat(frontend): 增加测试页面	2025-01-14 15:48:23 +08:00
lanyuanxiaoyao	b16dba4ef1	feat(web): 增加审批快照的生成	2025-01-08 15:41:48 +08:00
lanyuanxiaoyao	509410de9a	feat(web): 适配flowable	2025-01-08 10:41:40 +08:00
lanyuanxiaoyao	0aa9ec738a	feat(web): 增加flowable依赖	2025-01-03 18:30:05 +08:00