feat(web): 适配flowable

- 修改了 visibleOn 属性的字符串格式，统一使用双引号
- 移除了不必要的反引号，简化了字符串表达式

.idea/jarRepositories.xml

@@ -1,6 +1,11 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="RemoteRepositoriesConfiguration">
+    <remote-repository>
+      <option name="id" value="central" />
+      <option name="name" value="Central Repository" />
+      <option name="url" value="https://repo.maven.apache.org/maven2" />
+    </remote-repository>
     <remote-repository>
       <option name="id" value="mavenCentral" />
       <option name="name" value="mavenCentral" />

gringotts-frontend/components/constants.js

@@ -1,6 +1,6 @@
 export const information = {
-  debug: true,
+  debug: import.meta.env.DEV,
-  baseUrl: 'http://127.0.0.1:20080',
+  baseUrl: import.meta.env.DEV ? 'http://127.0.0.1:20080' : '',
   title: '可信供给中心',
 }
 
@@ -16,8 +16,8 @@ export function useAmis(amisObject) {
     struct,
     {
       data: {
-        debug: information.debug ?? false,
+        debug: information.debug,
-        base: information.baseUrl ?? '',
+        base: information.baseUrl,
       },
     },
     {

gringotts-frontend/components/ware/dialog-ware.js

@@ -99,6 +99,16 @@ function detailForm() {
         trimContents: true,
         minRows: 2,
         maxRows: 2,
+        maxLength: 100,
+      },
+      {
+        type: 'input-tag',
+        name: 'tags',
+        label: '标签',
+        max: 10,
+        maxTagLength: 10,
+        joinValues: false,
+        extractValue: true,
       },
       {
         type: 'input-rich-text',

gringotts-frontend/pages/index/main.js

@@ -1,14 +1,14 @@
 import './style.css'
-import {apiGet, useAmis} from '../../components/constants.js'
+import {administratorOnly, apiGet, checkerOnly, useAmis, userOnly} from '../../components/constants.js'
-import {userChangePasswordDialog} from "../../components/user/dialog-user-change-password.js";
+import {userChangePasswordDialog} from '../../components/user/dialog-user-change-password.js'
-import {tabUser} from "./tab-user.js";
+import {tabUser} from './tab-user.js'
-import {tabData} from "./tab-data.js";
+import {tabData} from './tab-data.js'
-import {tabSettings} from "./tab-settings.js";
+import {tabSettings} from './tab-settings.js'
-import {tabCheck} from "./tab-check.js";
+import {tabCheck} from './tab-check.js'
-import {tabPermissions} from "./tab-permissions.js";
+import {tabPermissions} from './tab-permissions.js'
-import {tabMarket} from "./tab-market.js";
+import {tabMarket} from './tab-market.js'
 
-useAmis(information => {
+useAmis((information) => {
   return {
     id: 'header-service',
     className: 'h-full',
@@ -23,22 +23,105 @@ useAmis(information => {
             args: {
               url: '/pages/login/index.html',
               blank: false,
+            },
+          },
+        ],
+      },
+    },
+    body: [
+      {
+        id: 'root-page',
+        type: 'page',
+        title: {
+          type: 'flex',
+          justify: 'flex-start',
+          items: [
+            {
+              type: 'avatar',
+              className: 'mr-2 bg-transparent',
+              src: '/logo.svg',
+              shape: 'square',
+              fit: 'contain',
+            },
+            {
+              type: 'flex',
+              className: 'w-50',
+              direction: 'column',
+              items: [
+                {
+                  type: 'tpl',
+                  className: 'font-bold text-white',
+                  tpl: information.title,
+                },
+                {
+                  type: 'tpl',
+                  className: 'font-bold text-xs text-gray-200',
+                  tpl: '提供合法合规的数据要素可信供给工具',
+                },
+              ]
+            }
+          ]
+        },
+        // subTitle: '提供合法合规的数据要素可信供给工具',
+        headerClassName: 'bg-gray-800 text-white',
+        toolbarClassName: 'bg-gray-800',
+        toolbar: [
+          {
+            type: 'action',
+            label: '数据市场',
+            icon: 'fa fa-store',
+            level: 'link',
+            className: "text-bold ${IF(activePage === 'market', 'text-primary', 'text-white')}",
+            onEvent: {
+              click: {
+                actions: [
+                  {
+                    actionType: 'setValue',
+                    componentId: 'root-page',
+                    args: {
+                      value: {
+                        activePage: 'market',
+                      }
                     }
                   }
                 ]
               }
+            }
           },
-    body: [
           {
-        type: 'page',
+            type: 'action',
-        title: information.title,
+            label: '我的资源',
-        subTitle: '提供合法合规的数据要素可信供给工具',
+            icon: 'fa fa-database',
-        toolbar: [
+            level: 'link',
+            className: "text-bold ${IF(activePage === 'tab', 'text-primary', 'text-white')}",
+            onEvent: {
+              click: {
+                actions: [
+                  {
+                    actionType: 'setValue',
+                    componentId: 'root-page',
+                    args: {
+                      value: {
+                        activePage: 'tab',
+                      }
+                    }
+                  }
+                ]
+              }
+            }
+          },
+          {
+            type: 'divider',
+            direction: 'vertical',
+            color: '#4d4d4d',
+          },
           {
             type: 'dropdown-button',
             label: '${username}',
             align: 'right',
             trigger: 'hover',
+            btnClassName: 'text-white',
+            level: 'link',
             buttons: [
               {
                 label: '修改密码',
@@ -49,26 +132,69 @@ useAmis(information => {
                 actionType: 'ajax',
                 api: apiGet('${base}/user/logout'),
                 reload: 'header-service',
-              }
+              },
-            ]
+            ],
-          }
+          },
         ],
         bodyClassName: 'p-0',
-        body: {
+        data: {
+          activePage: 'tab',
+          tabActiveKey: 'data'
+        },
+        body: [
+          {
+            visibleOn: "${activePage === 'market'}",
+            type: 'wrapper',
+            body: tabMarket(),
+          },
+          {
+            visibleOn: "${activePage === 'tab'}",
             className: 'h-full border-0',
             type: 'tabs',
             tabsMode: 'vertical',
+            activeKey: '${tabActiveKey}',
             tabs: [
               // tabOverview(),
-            tabMarket(),
+              {
-            tabData(),
+                hash: 'data',
-            tabPermissions(),
+                visibleOn: userOnly,
-            tabCheck(),
+                title: '数据资源',
-            tabUser(),
+                icon: 'fa fa-database',
-            tabSettings(),
+                reload: true,
-          ]
+                body: tabData()
               },
+              {
+                hash: 'permission',
+                visibleOn: userOnly,
+                title: '权属管理',
+                icon: 'fa fa-key',
+                reload: true,
+                body: tabPermissions(),
+              },
+              {
+                hash: 'check',
+                visibleOn: checkerOnly,
+                title: '审核审查',
+                icon: 'fa fa-shield-halved',
+                reload: true,
+                body: tabCheck(),
+              },
+              {
+                hash: 'user',
+                visibleOn: administratorOnly,
+                title: '用户管理',
+                icon: 'fa fa-user',
+                reload: true,
+                body: tabUser(),
+              },
+              {
+                hash: 'settings',
+                ...tabSettings(),
               }
-    ]
+            ],
+          }
+        ],
+      },
+    ],
   }
 })

gringotts-frontend/pages/index/tab-check.js

@@ -1,6 +1,5 @@
 import {
   apiGet,
-  checkerOnly,
   checkOverMapping,
   checkTypeMapping,
   crudCommonOptions,
@@ -13,12 +12,7 @@ import {authenticationDetailDialog, confirmationDetailDialog} from "../../compon
 import {wareDetailDialog} from "../../components/ware/dialog-ware.js";
 
 export function tabCheck() {
-  return {
+  return [
-    visibleOn: checkerOnly,
-    title: '审核审查',
-    icon: 'fa fa-shield-halved',
-    reload: true,
-    body: [
     {
       name: 'check_order_list',
       type: 'crud',
@@ -37,7 +31,7 @@ export function tabCheck() {
         stringField('modifiedUsername', '最后操作人', 100),
         operationField('操作', undefined, [
           {
-              visibleOn: `\${type === 'CONFIRMATION' && state === 'CHECKING'}`,
+            visibleOn: "${type === 'CONFIRMATION' && state === 'CHECKING'}",
             type: 'action',
             label: '处理',
             level: 'link',
@@ -64,14 +58,14 @@ export function tabCheck() {
             ),
           },
           {
-              visibleOn: `\${type === 'CONFIRMATION' && state !== NORMAL}`,
+            visibleOn: "${type === 'CONFIRMATION' && state !== NORMAL}",
             type: 'action',
             label: '查看',
             level: 'link',
             ...confirmationDetailDialog('parameters.confirmationId'),
           },
           {
-              visibleOn: `\${type === 'AUTHENTICATION' && state === 'CHECKING'}`,
+            visibleOn: "${type === 'AUTHENTICATION' && state === 'CHECKING'}",
             type: 'action',
             label: '处理',
             level: 'link',
@@ -98,14 +92,14 @@ export function tabCheck() {
             ),
           },
           {
-              visibleOn: `\${type === 'AUTHENTICATION' && state !== NORMAL}`,
+            visibleOn: "${type === 'AUTHENTICATION' && state !== NORMAL}",
             type: 'action',
             label: '查看',
             level: 'link',
             ...authenticationDetailDialog('parameters.authenticationId'),
           },
           {
-              visibleOn: `\${type === 'MARKET' && state === 'CHECKING'}`,
+            visibleOn: "${type === 'MARKET' && state === 'CHECKING'}",
             type: 'action',
             label: '处理',
             level: 'link',
@@ -132,7 +126,7 @@ export function tabCheck() {
             ),
           },
           {
-              visibleOn: `\${type === 'MARKET' && state !== NORMAL}`,
+            visibleOn: "${type === 'MARKET' && state !== NORMAL}",
             type: 'action',
             label: '查看',
             level: 'link',
@@ -141,6 +135,5 @@ export function tabCheck() {
         ]),
       ],
     },
-    ],
+  ]
-  }
 }

gringotts-frontend/pages/index/tab-data.js

@@ -11,8 +11,7 @@ import {
   mappingField,
   operationField,
   permissionStateMapping,
-  timeField,
+  timeField
-  userOnly
 } from "../../components/constants.js";
 import {wareAddDialog, wareDetailDialog, wareEditeDialog} from "../../components/ware/dialog-ware.js";
 
@@ -86,11 +85,6 @@ export function resourceList(showMode = false) {
 
 export function tabData() {
   return {
-    visibleOn: userOnly,
-    title: '数据资源',
-    icon: 'fa fa-database',
-    reload: true,
-    body: {
     type: 'tabs',
     tabs: [
       {
@@ -121,6 +115,8 @@ export function tabData() {
             {
               name: 'description',
               label: '描述',
+              type: 'tpl',
+              tpl: '${TRUNCATE(description, 100)}',
             },
             mappingField('state', '状态', permissionStateMapping),
             timeField('createdTime', '创建时间'),
@@ -182,5 +178,4 @@ export function tabData() {
       }
     ]
   }
-  }
 }

gringotts-frontend/pages/index/tab-market.js

@@ -3,10 +3,6 @@ import {authenticationAddDialog} from "../../components/permission/dialog-permis
 
 export function tabMarket() {
   return {
-    title: '数据市场',
-    icon: 'fa fa-store',
-    reload: true,
-    body: {
     type: 'crud',
     api: {
       ...apiGet('${base}/ware/list_public'),
@@ -84,7 +80,6 @@ export function tabMarket() {
           ...authenticationAddDialog(),
         }
       ]
-      },
     }
   }
 }

gringotts-frontend/pages/index/tab-permissions.js

@@ -12,7 +12,6 @@ import {
   stringField,
   stringWrapField,
   timeField,
-  userOnly,
 } from "../../components/constants.js";
 import {
   authenticationAddDialog,
@@ -25,11 +24,6 @@ import {
 
 export function tabPermissions() {
   return {
-    visibleOn: userOnly,
-    title: '权属管理',
-    icon: 'fa fa-key',
-    reload: true,
-    body: {
     type: 'tabs',
     tabs: [
       {
@@ -192,5 +186,4 @@ export function tabPermissions() {
       },
     ]
   }
-  }
 }

gringotts-frontend/pages/index/tab-user.js

@@ -1,5 +1,4 @@
 import {
-  administratorOnly,
   apiGet,
   copyField,
   crudCommonOptions,
@@ -13,12 +12,7 @@ import {userCheckDialog, userDetailDialog} from "../../components/user/dialog-us
 import {userAdministratorRegisterDialog} from "../../components/user/dialog-user-register.js";
 
 export function tabUser() {
-  return {
+  return [
-    visibleOn: administratorOnly,
-    title: '用户管理',
-    icon: 'fa fa-user',
-    reload: true,
-    body: [
     {
       type: 'crud',
       api: apiGet('${base}/user_management/list'),
@@ -79,5 +73,4 @@ export function tabUser() {
       ]
     }
   ]
-  }
 }

gringotts-frontend/pages/login/main.js

@@ -4,74 +4,103 @@ import {userRegisterDialog} from '../../components/user/dialog-user-register.js'
 useAmis(information => {
     return {
         type: 'page',
-        title: information.title,
+        className: 'h-screen bg-gray-900',
-        subTitle: '统一登陆入口',
+        bodyClassName: 'h-full flex items-start mt-20',
         body: [
             {
-                type: 'grid',
+                type: 'wrapper',
-                columns: [
+                className: 'relative w-full max-w-md mx-auto',
+                body: [
                     {
-                        xs: 0,
+                        type: 'flex',
-                        sm: 0,
+                        justify: 'center',
-                        md: 4,
+                        className: 'mb-8',
-                        body: [],
+                        items: [
+                            {
+                                type: 'avatar',
+                                src: '/logo.svg',
+                                shape: 'square',
+                                size: 64,
+                                fit: 'contain',
+                                className: 'mr-4 bg-transparent'
                             },
                             {
-                        xs: 12,
+                                type: 'flex',
-                        sm: 12,
+                                direction: 'column',
-                        md: 4,
+                                justify: 'center',
-                        body: [
+                                items: [
+                                    {
+                                        type: 'tpl',
+                                        tpl: information.title,
+                                        className: 'text-2xl font-bold text-white'
+                                    },
+                                    {
+                                        type: 'tpl',
+                                        tpl: '统一登录入口',
+                                        className: 'text-lg ml-1 mt-1 text-gray-100'
+                                    }
+                                ]
+                            }
+                        ]
+                    },
                     {
                         type: 'form',
-                                title: '用户登陆',
+                        className: 'bg-white rounded-xl p-10 shadow-2xl',
                         api: '${base}/user/login',
                         redirect: '/pages/index/index.html?token=${token}',
-                                mode: 'horizontal',
+                        mode: 'normal',
-                                horizontal: {
+                        wrapWithPanel: false,
-                                    left: 2,
-                                },
-                                actions: [
-                                    {
-                                        type: 'action',
-                                        label: '注册',
-                                        ...userRegisterDialog(),
-                                    },
-                                    {
-                                        type: 'action',
-                                        actionType: 'submit',
-                                        label: '登陆',
-                                        level: 'primary',
-                                    },
-                                ],
                         body: [
                             {
                                 type: 'input-email',
                                 name: 'username',
-                                        label: '邮箱',
+                                label: false,
                                 placeholder: '请输入邮箱',
                                 required: true,
                                 clearable: true,
-                                        clearValueOnEmpty: true,
+                                className: 'mb-4',
+                                inputClassName: 'rounded-lg',
                             },
                             {
                                 type: 'input-password',
                                 name: 'password',
-                                        label: '密码',
+                                label: false,
-                                        placeholder: '请再次输入密码',
+                                placeholder: '请输入密码',
                                 required: true,
-                                    },
+                                className: 'mb-4',
-                                ],
+                                inputClassName: 'rounded-lg',
-                            },
-                        ],
                             },
                             {
-                        xs: 0,
+                                type: 'flex',
-                        sm: 0,
+                                justify: 'space-between',
-                        md: 4,
+                                className: 'mb-4',
-                        body: [],
+                                items: [
+                                    {
+                                        type: 'button',
+                                        label: '注册账号',
+                                        className: 'text-blue-600 hover:text-blue-700',
+                                        level: 'link',
+                                        ...userRegisterDialog(),
                                     },
-                ],
+                                    {
+                                        type: 'button',
+                                        label: '忘记密码？',
+                                        level: 'link',
+                                        className: 'text-gray-600 hover:text-gray-700'
+                                    }
+                                ]
                             },
-        ],
+                            {
+                                type: 'submit',
+                                label: '登录',
+                                level: 'primary',
+                                className: 'w-full rounded-lg',
+                                size: 'lg'
+                            }
+                        ]
+                    }
+                ]
+            }
+        ]
     }
 })

gringotts-frontend/public/logo.svg

@@ -0,0 +1,8 @@
+<svg version="1.2" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 1589 1540" width="1589" height="1540">
+    <title>China_Telecom_Logo-svg</title>
+    <style>
+        .s0 { fill: #FFFFFF }
+    </style>
+    <path id="path8564" class="s0"
+          d="m1004.4 258.8c0 0-27.8-30.7-64.4-30.7 0 0-80.2 0-134.7 173.4 0 0-46.5 151.5-46.5 376.4 0 0 0 212 43.6 361.6 0 0 43.5 151.6 106.9 151.6 0 0 44.6 0 82.2-83.2 0 0 37.6-83.2 53.5-219l118.8-29.7c0 0-30.7 252.7-125.8 416.1 0 0-98 164.5-221.8 164.5 0 0-148.5 0-253.4-222.9 0 0-105-222.9-105-539 0 0 0-316 105-540.9 0 0 104.9-223.9 253.4-223.9 0 0 148.6 0 254.5 227.9zm417.8 304.1c0 0-204.9 169.4-531.7 251.6 0 0-327.7 81.3-588.1 27.8 0 0-260.4-55.5-299-215 0 0-32.7-132.8 110.9-279.4 0 0 141.6-145.6 396-242.7l16.9 65.4c0 0-148.5 63.4-230.7 143.6 0 0-84.2 84.2-65.4 156.6 0 0 24.8 92.1 199 119.8 0 0 173.3 26.8 398.1-28.7 0 0 222.7-55.5 365.3-161.5 0 0 140.6-107 116.8-200.1 0 0-19.8-80.2-162.3-114.9l-21.8-85.2c0 0 185.1 6.9 307.9 68.3 0 0 125.7 61.5 151.5 165.5 0 0 40.6 158.5-163.4 328.9z"/>
+</svg>

gringotts-web/pom.xml

@@ -12,6 +12,11 @@
     <artifactId>gringotts-web</artifactId>
 
     <dependencies>
+        <dependency>
+            <groupId>com.lanyuanxiaoyao</groupId>
+            <artifactId>flowable</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>com.eshore</groupId>
             <artifactId>gringotts-configuration</artifactId>

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/entity/CheckingNeededEntity.java

@@ -1,6 +1,6 @@
 package com.eshore.gringotts.web.domain.base.entity;
 
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
+import com.eshore.gringotts.web.domain.entity.order.CheckOrder;
 import javax.persistence.CascadeType;
 import javax.persistence.Column;
 import javax.persistence.EntityListeners;

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/base/service/CheckingService.java

@@ -1,6 +1,10 @@
 package com.eshore.gringotts.web.domain.base.service;
 
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
+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.order.CheckOrder;
+import com.eshore.gringotts.web.domain.service.UserService;
+import javax.persistence.EntityManager;
 import org.eclipse.collections.api.map.ImmutableMap;
 
 /**
@@ -9,6 +13,16 @@ import org.eclipse.collections.api.map.ImmutableMap;
  * @author lanyuanxiaoyao
  * @date 2024-11-28
  */
-public interface CheckingService {
+public abstract class CheckingService<ENTITY extends LogicDeleteEntity> extends LogicDeleteService<ENTITY> {
-  void onChecked(CheckOrder order, CheckOrder.Operation operation, ImmutableMap<String, Object> parameters);
+  public CheckingService(SimpleRepository<ENTITY, Long> repository, UserService userService, EntityManager manager) {
+    super(repository, userService, manager);
+  }
+
+  abstract public void submit(Long id) throws Exception;
+
+  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);
 }

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/AuthenticationController.java

@@ -1,6 +1,5 @@
 package com.eshore.gringotts.web.domain.controller;
 
-import com.eshore.gringotts.web.configuration.amis.AmisResponse;
 import com.eshore.gringotts.web.domain.base.controller.SimpleControllerSupport;
 import com.eshore.gringotts.web.domain.base.entity.FileInfo;
 import com.eshore.gringotts.web.domain.base.entity.SimpleListItem;
@@ -9,7 +8,6 @@ import com.eshore.gringotts.web.domain.entity.Authentication;
 import com.eshore.gringotts.web.domain.service.AuthenticationService;
 import com.eshore.gringotts.web.domain.service.DataFileService;
 import com.eshore.gringotts.web.domain.service.DataResourceService;
-import com.fasterxml.jackson.core.JsonProcessingException;
 import java.time.LocalDateTime;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -17,8 +15,6 @@ import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.collections.api.factory.Sets;
 import org.eclipse.collections.api.set.ImmutableSet;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -30,29 +26,15 @@ import org.springframework.web.bind.annotation.RestController;
 @RestController
 @RequestMapping("authentication")
 public class AuthenticationController extends SimpleControllerSupport<Authentication, AuthenticationController.SaveItem, AuthenticationController.ListItem, AuthenticationController.DetailItem> {
-  private final AuthenticationService authenticationService;
   private final DataResourceService dataResourceService;
   private final DataFileService dataFileService;
 
   public AuthenticationController(AuthenticationService service, DataResourceService dataResourceService, DataFileService dataFileService) {
     super(service);
-    this.authenticationService = service;
     this.dataResourceService = dataResourceService;
     this.dataFileService = dataFileService;
   }
 
-  @GetMapping("/submit/{id}")
-  public AmisResponse<Object> submit(@PathVariable Long id) throws JsonProcessingException {
-    authenticationService.submit(id);
-    return AmisResponse.responseSuccess();
-  }
-
-  @GetMapping("/retract/{id}")
-  public AmisResponse<Object> retract(@PathVariable Long id) {
-    authenticationService.retract(id);
-    return AmisResponse.responseSuccess();
-  }
-
   @Override
   protected Authentication fromSaveItem(SaveItem item) throws Exception {
     Authentication authentication = new Authentication();

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/CheckOrderController.java

@@ -3,9 +3,9 @@ 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.entity.order.CheckOrder;
+import com.eshore.gringotts.web.domain.entity.order.node.CheckOrderNode;
 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 java.time.LocalDateTime;
@@ -52,13 +52,25 @@ public class CheckOrderController implements ListController<CheckOrderController
     return AmisResponse.responseSuccess(checkOrderService.list().collect(this::toListItem));
   }
 
+  @GetMapping("/approve/{id}")
+  public AmisResponse<Object> approve(@PathVariable Long id) {
+    checkOrderService.approve(id);
+    return AmisResponse.responseSuccess();
+  }
+
+  @GetMapping("/reject/{id}")
+  public AmisResponse<Object> reject(@PathVariable Long id) {
+    checkOrderService.reject(id);
+    return AmisResponse.responseSuccess();
+  }
+
   @SneakyThrows
   private ListItem toListItem(CheckOrder order) {
     ListItem item = new ListItem();
     item.setCheckOrderId(order.getId());
     item.setDescription(order.getDescription());
-    item.setType(order.getType());
+    item.setCurrentNode(order.getCurrentNode());
-    item.setParameters(mapper.readValue(order.getParameters(), new TypeReference<>() {}));
+    item.setParameters(mapper.readValue(order.getContext(), new TypeReference<>() {}));
     item.setState(order.getState());
     item.setCreatedUsername(order.getCreatedUser().getUsername());
     item.setCreatedTime(order.getCreatedTime());
@@ -67,18 +79,11 @@ public class CheckOrderController implements ListController<CheckOrderController
     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 description;
-    private CheckOrder.Type type;
+    private CheckOrderNode currentNode;
     private ImmutableMap<String, Object> parameters;
     private CheckOrder.State state;
     private LocalDateTime createdTime;

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/ConfirmationController.java

@@ -33,25 +33,19 @@ public class ConfirmationController extends SimpleControllerSupport<Confirmation
   private final DataResourceService dataResourceService;
   private final DataFileService dataFileService;
 
-  public ConfirmationController(ConfirmationService service, ConfirmationService confirmationService, DataResourceService dataResourceService, DataFileService dataFileService) {
+  public ConfirmationController(ConfirmationService service, DataResourceService dataResourceService, DataFileService dataFileService) {
     super(service);
-    this.confirmationService = confirmationService;
+    this.confirmationService = service;
     this.dataResourceService = dataResourceService;
     this.dataFileService = dataFileService;
   }
 
-  @GetMapping("/submit/{id}")
+  @GetMapping("submit/{id}")
   public AmisResponse<Object> submit(@PathVariable Long id) throws JsonProcessingException {
     confirmationService.submit(id);
     return AmisResponse.responseSuccess();
   }
 
-  @GetMapping("/retract/{id}")
-  public AmisResponse<Object> retract(@PathVariable Long id) {
-    confirmationService.retract(id);
-    return AmisResponse.responseSuccess();
-  }
-
   @Override
   protected Confirmation fromSaveItem(SaveItem item) throws Exception {
     Confirmation confirmation = new Confirmation();

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/controller/WareController.java

@@ -10,14 +10,12 @@ import com.eshore.gringotts.web.domain.entity.Ware;
 import com.eshore.gringotts.web.domain.service.DataFileService;
 import com.eshore.gringotts.web.domain.service.DataResourceService;
 import com.eshore.gringotts.web.domain.service.WareService;
-import com.fasterxml.jackson.core.JsonProcessingException;
 import java.time.LocalDateTime;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.collections.api.list.ImmutableList;
 import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -47,18 +45,6 @@ public class WareController extends SimpleControllerSupport<Ware, WareController
     return AmisResponse.responseSuccess(wareService.listPublic().collect(this::toListItem));
   }
 
-  @GetMapping("/submit/{id}")
-  public AmisResponse<Object> submit(@PathVariable Long id) throws JsonProcessingException {
-    wareService.submit(id);
-    return AmisResponse.responseSuccess();
-  }
-
-  @GetMapping("/retract/{id}")
-  public AmisResponse<Object> retract(@PathVariable Long id) {
-    wareService.retract(id);
-    return AmisResponse.responseSuccess();
-  }
-
   @Override
   protected Ware fromSaveItem(SaveItem saveItem) {
     Ware ware = new Ware();

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/entity/order/CheckOrder.java

@@ -1,7 +1,9 @@
-package com.eshore.gringotts.web.domain.entity;
+package com.eshore.gringotts.web.domain.entity.order;
 
 import com.eshore.gringotts.core.Constants;
 import com.eshore.gringotts.web.domain.base.entity.SimpleEntity;
+import com.eshore.gringotts.web.domain.entity.order.node.CheckOrderNode;
+import java.util.List;
 import javax.persistence.Column;
 import javax.persistence.ConstraintMode;
 import javax.persistence.Entity;
@@ -13,6 +15,7 @@ import javax.persistence.ForeignKey;
 import javax.persistence.JoinColumn;
 import javax.persistence.NamedAttributeNode;
 import javax.persistence.NamedEntityGraph;
+import javax.persistence.OneToMany;
 import javax.persistence.OneToOne;
 import javax.persistence.Table;
 import lombok.Getter;
@@ -38,74 +41,34 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
     @NamedAttributeNode(value = "modifiedUser"),
 })
 @NamedEntityGraph(name = "check_order.detail", attributeNodes = {
+    @NamedAttributeNode(value = "nodes"),
     @NamedAttributeNode(value = "createdUser"),
     @NamedAttributeNode(value = "modifiedUser"),
 })
 @NoArgsConstructor
 public class CheckOrder extends SimpleEntity {
   @Column(nullable = false)
-  private String keyword;
+  private String name;
   @Column(nullable = false)
   private String description;
-  @Column(nullable = false)
+
-  @Enumerated(EnumType.STRING)
+  @OneToOne(fetch = FetchType.LAZY)
-  private Type type;
+  @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
+  @ToString.Exclude
+  private CheckOrderNode currentNode;
+  @OneToMany(fetch = FetchType.LAZY, mappedBy = "order")
+  @ToString.Exclude
+  private List<CheckOrderNode> nodes;
   /**
    * JSON 结构 Map<String, Object>
    */
   @Column(nullable = false)
-  private String parameters;
+  private String context = "{}";
-
-  @Column(nullable = false)
-  @Enumerated(EnumType.STRING)
-  private Target target;
-  @Column(nullable = false)
-  private String targetClass;
-  @OneToOne(fetch = FetchType.LAZY)
-  @JoinColumn(foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
-  @ToString.Exclude
-  private User targetUser;
-  @Enumerated(EnumType.STRING)
-  private User.Role targetRole;
 
   @Column(nullable = false)
   @Enumerated(EnumType.STRING)
   private State state = State.CHECKING;
 
-  public CheckOrder(
-      String keyword,
-      String description,
-      Type type,
-      String parameters,
-      String targetClass,
-      User targetUser
-  ) {
-    this.keyword = keyword;
-    this.description = description;
-    this.type = type;
-    this.parameters = parameters;
-    this.target = Target.USER;
-    this.targetClass = targetClass;
-    this.targetUser = targetUser;
-  }
-
-  public CheckOrder(
-      String keyword,
-      String description,
-      Type type,
-      String parameters,
-      String targetClass,
-      User.Role targetRole
-  ) {
-    this.keyword = keyword;
-    this.description = description;
-    this.type = type;
-    this.parameters = parameters;
-    this.target = Target.ROLE;
-    this.targetClass = targetClass;
-    this.targetRole = targetRole;
-  }
-
   public enum Operation {
     APPLY,
     REJECT,

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/entity/order/node/CheckOrderNode.java

@@ -0,0 +1,49 @@
+package com.eshore.gringotts.web.domain.entity.order.node;
+
+import com.eshore.gringotts.core.Constants;
+import com.eshore.gringotts.web.domain.base.entity.IdOnlyEntity;
+import com.eshore.gringotts.web.domain.entity.order.CheckOrder;
+import javax.persistence.Column;
+import javax.persistence.ConstraintMode;
+import javax.persistence.Entity;
+import javax.persistence.EntityListeners;
+import javax.persistence.FetchType;
+import javax.persistence.ForeignKey;
+import javax.persistence.Inheritance;
+import javax.persistence.InheritanceType;
+import javax.persistence.JoinColumn;
+import javax.persistence.ManyToOne;
+import javax.persistence.Table;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Getter
+@Setter
+@ToString
+@Entity
+@DynamicUpdate
+@EntityListeners(AuditingEntityListener.class)
+@Table(name = Constants.TABLE_PREFIX + "check_order_node")
+@Inheritance(strategy = InheritanceType.TABLE_PER_CLASS)
+public abstract class CheckOrderNode extends IdOnlyEntity {
+  @Column(nullable = false)
+  private Integer sequence;
+  @ManyToOne(fetch = FetchType.LAZY)
+  @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
+  @ToString.Exclude
+  private CheckOrder order;
+
+  public abstract Type getCheckType();
+
+  public enum Type {
+    USER,
+    ROLE,
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/entity/order/node/RoleCheckOrderNode.java

@@ -0,0 +1,38 @@
+package com.eshore.gringotts.web.domain.entity.order.node;
+
+import com.eshore.gringotts.core.Constants;
+import com.eshore.gringotts.web.domain.entity.User;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.EnumType;
+import javax.persistence.Enumerated;
+import javax.persistence.Table;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * 指定用户审核
+ *
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Getter
+@Setter
+@ToString
+@AllArgsConstructor
+@NoArgsConstructor
+@Entity
+@Table(name = Constants.TABLE_PREFIX + "check_order_node_role")
+public class RoleCheckOrderNode extends CheckOrderNode {
+  @Column(nullable = false)
+  @Enumerated(EnumType.STRING)
+  private User.Role target;
+
+  @Override
+  public Type getCheckType() {
+    return Type.ROLE;
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/entity/order/node/UserCheckOrderNode.java

@@ -0,0 +1,41 @@
+package com.eshore.gringotts.web.domain.entity.order.node;
+
+import com.eshore.gringotts.core.Constants;
+import com.eshore.gringotts.web.domain.entity.User;
+import javax.persistence.ConstraintMode;
+import javax.persistence.Entity;
+import javax.persistence.FetchType;
+import javax.persistence.ForeignKey;
+import javax.persistence.JoinColumn;
+import javax.persistence.OneToOne;
+import javax.persistence.Table;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * 指定用户审核
+ *
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Getter
+@Setter
+@ToString
+@AllArgsConstructor
+@NoArgsConstructor
+@Entity
+@Table(name = Constants.TABLE_PREFIX + "check_order_node_user")
+public class UserCheckOrderNode extends CheckOrderNode {
+  @OneToOne(fetch = FetchType.EAGER)
+  @JoinColumn(nullable = false, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))
+  @ToString.Exclude
+  private User target;
+
+  @Override
+  public Type getCheckType() {
+    return Type.USER;
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/FlowDatabaseRepository.java

@@ -0,0 +1,126 @@
+package com.eshore.gringotts.web.domain.flowable;
+
+import com.eshore.gringotts.web.domain.entity.order.CheckOrder;
+import com.eshore.gringotts.web.domain.entity.order.node.CheckOrderNode;
+import com.eshore.gringotts.web.domain.entity.order.node.RoleCheckOrderNode;
+import com.eshore.gringotts.web.domain.entity.order.node.UserCheckOrderNode;
+import com.eshore.gringotts.web.domain.flowable.node.RoleCheckFlowNode;
+import com.eshore.gringotts.web.domain.flowable.node.UserCheckFlowNode;
+import com.eshore.gringotts.web.domain.repository.CheckOrderNodeRepository;
+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.lanyuanxiaoyao.flowable.model.Flow;
+import com.lanyuanxiaoyao.flowable.model.FlowStatus;
+import com.lanyuanxiaoyao.flowable.node.FlowNode;
+import com.lanyuanxiaoyao.flowable.repository.FlowRepository;
+import java.util.stream.Collectors;
+import lombok.SneakyThrows;
+import org.eclipse.collections.api.factory.Lists;
+import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Service
+public class FlowDatabaseRepository implements FlowRepository {
+  private final CheckOrderService checkOrderService;
+  private final CheckOrderNodeRepository checkOrderNodeRepository;
+  private final ObjectMapper mapper;
+
+  public FlowDatabaseRepository(CheckOrderService checkOrderService, CheckOrderNodeRepository checkOrderNodeRepository, Jackson2ObjectMapperBuilder builder) {
+    this.checkOrderService = checkOrderService;
+    this.checkOrderNodeRepository = checkOrderNodeRepository;
+    this.mapper = builder.build();
+  }
+
+  private FlowNode mapTo(CheckOrderNode source) {
+    switch (source.getCheckType()) {
+      case USER:
+        return new UserCheckFlowNode(source.getId().toString(), ((UserCheckOrderNode) source).getTarget());
+      case ROLE:
+        return new RoleCheckFlowNode(source.getId().toString(), ((RoleCheckOrderNode) source).getTarget());
+      default:
+        throw new IllegalArgumentException("Unsupported check type: " + source.getCheckType());
+    }
+  }
+
+  private CheckOrderNode mapTo(FlowNode source) {
+    return checkOrderNodeRepository.findById(Long.valueOf(source.getNodeId())).orElseThrow(() -> new RuntimeException(""));
+  }
+
+  private Flow mapTo(CheckOrder order) throws JsonProcessingException {
+    Flow flow = new Flow();
+    flow.setName(order.getName());
+    flow.setDescription(order.getDescription());
+    flow.setNodes(order.getNodes()
+        .stream()
+        .map(this::mapTo)
+        .collect(Collectors.toList())
+    );
+    flow.setCurrentNode(mapTo(order.getCurrentNode()).getNodeId());
+    switch (order.getState()) {
+      case CHECKING:
+        flow.setStatus(FlowStatus.PENDING);
+        break;
+      case RETRACT:
+        flow.setStatus(FlowStatus.REJECTED);
+        break;
+      case OVER:
+        flow.setStatus(FlowStatus.APPROVED);
+        break;
+    }
+    flow.setContextVariables(mapper.readValue(order.getContext(), new TypeReference<>() {}));
+    flow.setCreateTime(order.getCreatedTime());
+    flow.setUpdateTime(order.getModifiedTime());
+    return flow;
+  }
+
+  private void mapTo(Flow flow, CheckOrder order) throws JsonProcessingException {
+    order.setName(flow.getName());
+    order.setDescription(flow.getDescription());
+    order.setNodes(Lists.mutable.ofAll(flow.getNodes()).collect(this::mapTo));
+    order.setCurrentNode(mapTo(flow.getCurrentNodeObject()));
+    switch (flow.getStatus()) {
+      case APPROVED:
+        order.setState(CheckOrder.State.OVER);
+        break;
+      case PENDING:
+        order.setState(CheckOrder.State.CHECKING);
+        break;
+      case REJECTED:
+        order.setState(CheckOrder.State.RETRACT);
+        break;
+    }
+    order.setContext(mapper.writeValueAsString(flow.getContextVariables()));
+  }
+
+  @SneakyThrows
+  @Override
+  public Flow save(Flow flow) {
+    CheckOrder order = new CheckOrder();
+    mapTo(flow, order);
+    Long id = checkOrderService.save(order);
+    flow.setId(id.toString());
+    return flow;
+  }
+
+  @SneakyThrows
+  @Override
+  public Flow update(Flow flow) {
+    CheckOrder order = checkOrderService.detailOrThrow(Long.parseLong(flow.getId()));
+    mapTo(flow, order);
+    checkOrderService.save(order);
+    return flow;
+  }
+
+  @SneakyThrows
+  @Override
+  public Flow findById(String id) {
+    CheckOrder order = checkOrderService.detailOrThrow(Long.parseLong(id));
+    return mapTo(order);
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/node/RoleCheckFlowNode.java

@@ -0,0 +1,19 @@
+package com.eshore.gringotts.web.domain.flowable.node;
+
+import com.eshore.gringotts.web.domain.entity.User;
+import com.lanyuanxiaoyao.flowable.node.AbstractFlowNode;
+import lombok.Getter;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Getter
+public class RoleCheckFlowNode extends AbstractFlowNode {
+  private final User.Role role;
+
+  public RoleCheckFlowNode(String nodeId, User.Role role) {
+    super(nodeId);
+    this.role = role;
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/flowable/node/UserCheckFlowNode.java

@@ -0,0 +1,34 @@
+package com.eshore.gringotts.web.domain.flowable.node;
+
+import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.service.ConfirmationService;
+import com.lanyuanxiaoyao.flowable.model.FlowContext;
+import com.lanyuanxiaoyao.flowable.node.AbstractFlowNode;
+import lombok.Getter;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Getter
+public class UserCheckFlowNode extends AbstractFlowNode {
+  private final User user;
+  private final ConfirmationService confirmationService;
+
+  public UserCheckFlowNode(String nodeId, User user, ConfirmationService confirmationService) {
+    super(nodeId);
+    this.user = user;
+    this.confirmationService = confirmationService;
+  }
+
+  @Override
+  public void onApprove(FlowContext context) {
+    super.onApprove(context);
+    Long confirmationId = context.getVariable("confirmationId", Long.class);
+  }
+
+  @Override
+  public void onReject(FlowContext context) {
+    super.onReject(context);
+  }
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/CheckOrderNodeRepository.java

@@ -0,0 +1,13 @@
+package com.eshore.gringotts.web.domain.repository;
+
+import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
+import com.eshore.gringotts.web.domain.entity.order.node.CheckOrderNode;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20241225
+ */
+@Repository
+public interface CheckOrderNodeRepository extends SimpleRepository<CheckOrderNode, Long> {
+}

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/repository/CheckOrderRepository.java

@@ -1,8 +1,8 @@
 package com.eshore.gringotts.web.domain.repository;
 
 import com.eshore.gringotts.web.domain.base.repository.SimpleRepository;
-import com.eshore.gringotts.web.domain.entity.CheckOrder;
 import com.eshore.gringotts.web.domain.entity.User;
+import com.eshore.gringotts.web.domain.entity.order.CheckOrder;
 import java.util.List;
 import java.util.Optional;
 import javax.transaction.Transactional;

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/AuthenticationService.java

@@ -1,30 +1,11 @@
 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.entity.CheckingNeededEntity;
-import com.eshore.gringotts.web.domain.base.service.CheckingService;
 import com.eshore.gringotts.web.domain.base.service.LogicDeleteService;
 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.User;
 import com.eshore.gringotts.web.domain.repository.AuthenticationRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 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.Service;
 
 /**
@@ -32,38 +13,15 @@ import org.springframework.stereotype.Service;
  * @date 2024-12-02
  */
 @Slf4j
-@Service("com.eshore.gringotts.web.domain.service.AuthenticationService")
+@Service
-public class AuthenticationService extends LogicDeleteService<Authentication> implements CheckingService {
+public class AuthenticationService extends LogicDeleteService<Authentication> {
   private final AuthenticationRepository authenticationRepository;
   private final UserService userService;
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
 
-  public AuthenticationService(AuthenticationRepository repository, UserService userService, EntityManager manager, CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
+  public AuthenticationService(AuthenticationRepository repository, UserService userService, EntityManager manager) {
     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)
-        )
-    ));
   }
 
   @Override
@@ -83,68 +41,6 @@ public class AuthenticationService extends LogicDeleteService<Authentication> im
     return super.save(entity);
   }
 
-  @Transactional(rollbackOn = Throwable.class)
-  public void submit(Long id) throws JsonProcessingException {
-    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);
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  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);
-  }
-
-  @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);
-  }
-
   public static final class AuthenticationDuplicatedException extends RuntimeException {
     public AuthenticationDuplicatedException() {
       super("数据资源已绑定该账号的授权申请，无法再次申请");

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/CheckOrderService.java

@@ -1,26 +1,12 @@
 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.order.CheckOrder;
-import com.eshore.gringotts.web.domain.entity.CheckOrder_;
+import com.eshore.gringotts.web.domain.flowable.FlowDatabaseRepository;
-import com.eshore.gringotts.web.domain.entity.User;
 import com.eshore.gringotts.web.domain.repository.CheckOrderRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
+import com.lanyuanxiaoyao.flowable.service.FlowService;
-import com.fasterxml.jackson.core.type.TypeReference;
+import javax.transaction.Transactional;
-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;
 
 /**
@@ -30,53 +16,30 @@ import org.springframework.stereotype.Service;
 @Slf4j
 @Service
 public class CheckOrderService extends SimpleServiceSupport<CheckOrder> {
-  private final ApplicationContext applicationContext;
+  private final FlowService flowService;
-  private final ObjectMapper mapper;
-  private final CheckOrderRepository checkOrderRepository;
-  private final UserService userService;
 
-  public CheckOrderService(CheckOrderRepository repository, UserService userService, ApplicationContext applicationContext, Jackson2ObjectMapperBuilder builder) {
+  public CheckOrderService(CheckOrderRepository repository, UserService userService, FlowDatabaseRepository flowDatabaseRepository) {
     super(repository, userService);
-    this.applicationContext = applicationContext;
+    this.flowService = new FlowService(flowDatabaseRepository);
-    this.mapper = builder.build();
-    this.checkOrderRepository = repository;
-    this.userService = userService;
   }
 
-  @Override
+  @Transactional(rollbackOn = Throwable.class)
-  protected ImmutableList<Predicate> listPredicate(Root<CheckOrder> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
+  public void startFlow(CheckOrder order) {
-    User user = userService.currentLoginUser();
+    startFlow(order.getId());
-    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 {
+  @Transactional(rollbackOn = Throwable.class)
-    CheckOrder order = detailOrThrow(id);
+  public void startFlow(Long id) {
-    CheckingService service = applicationContext.getBean(order.getTargetClass(), CheckingService.class);
+    flowService.startFlow(id.toString());
-    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) {
+  @Transactional(rollbackOn = Throwable.class)
-    checkOrderRepository.overById(id, CheckOrder.State.RETRACT, userService.currentLoginUser());
+  public void approve(Long id) {
+    flowService.approve(id.toString());
   }
 
-  public void over(Long id) {
+  @Transactional(rollbackOn = Throwable.class)
-    checkOrderRepository.overById(id, CheckOrder.State.OVER, userService.currentLoginUser());
+  public void reject(Long id) {
+    flowService.reject(id.toString());
   }
 }

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/ConfirmationService.java

@@ -1,31 +1,19 @@
 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.entity.CheckingNeededEntity;
-import com.eshore.gringotts.web.domain.base.service.CheckingService;
 import com.eshore.gringotts.web.domain.base.service.LogicDeleteService;
-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.User;
+import com.eshore.gringotts.web.domain.entity.order.CheckOrder;
+import com.eshore.gringotts.web.domain.entity.order.node.RoleCheckOrderNode;
 import com.eshore.gringotts.web.domain.repository.ConfirmationRepository;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 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.Service;
 
@@ -34,8 +22,8 @@ import org.springframework.stereotype.Service;
  * @date 2024-11-26
  */
 @Slf4j
-@Service("com.eshore.gringotts.web.domain.service.ConfirmationService")
+@Service
-public class ConfirmationService extends LogicDeleteService<Confirmation> implements CheckingService {
+public class ConfirmationService extends LogicDeleteService<Confirmation> {
   private final ConfirmationRepository confirmationRepository;
   private final CheckOrderService checkOrderService;
   private final ObjectMapper mapper;
@@ -47,31 +35,6 @@ public class ConfirmationService extends LogicDeleteService<Confirmation> implem
     this.mapper = builder.build();
   }
 
-  @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)
-                )
-            )
-        )
-    ));
-  }
-
   @Override
   public Long save(Confirmation entity) {
     if (ObjectUtil.isNull(entity.getId()) && confirmationRepository.existsByTarget_Id(entity.getTarget().getId())) {
@@ -82,51 +45,15 @@ public class ConfirmationService extends LogicDeleteService<Confirmation> implem
 
   @Transactional(rollbackOn = Throwable.class)
   public void submit(Long id) throws JsonProcessingException {
-    Confirmation confirmation = detailOrThrow(id);
+    CheckOrder order = new CheckOrder();
-    confirmation.setState(Confirmation.State.CHECKING);
+    order.setName("确权申请");
-    Long orderId = checkOrderService.save(new CheckOrder(
+    order.setDescription("确权申请");
-        "confirmation_check",
+    order.setNodes(Lists.mutable.of(
-        StrUtil.format("数据资源「{}」的确权申请", confirmation.getTarget().getName()),
+        new RoleCheckOrderNode(User.Role.CHECKER)
-        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);
+    order.setContext(mapper.writeValueAsString(Maps.immutable.of("confirmationId", id)));
-    confirmation.setOrder(order);
-    save(confirmation);
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  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);
-  }
+    checkOrderService.startFlow(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);
-    }
   }
 
   public static final class ConfirmationDuplicatedException extends RuntimeException {

gringotts-web/src/main/java/com/eshore/gringotts/web/domain/service/WareService.java

@@ -1,22 +1,12 @@
 package com.eshore.gringotts.web.domain.service;
 
-import cn.hutool.core.util.StrUtil;
-import com.eshore.gringotts.web.domain.base.service.CheckingService;
 import com.eshore.gringotts.web.domain.base.service.LogicDeleteService;
-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.repository.WareRepository;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 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.Service;
 
 /**
@@ -24,17 +14,13 @@ import org.springframework.stereotype.Service;
  * @date 2024-12-13
  */
 @Slf4j
-@Service("com.eshore.gringotts.web.domain.service.WareService")
+@Service
-public class WareService extends LogicDeleteService<Ware> implements CheckingService {
+public class WareService extends LogicDeleteService<Ware> {
   private final WareRepository wareRepository;
-  private final CheckOrderService checkOrderService;
-  private final ObjectMapper mapper;
 
-  public WareService(WareRepository repository, UserService userService, EntityManager entityManager, CheckOrderService checkOrderService, Jackson2ObjectMapperBuilder builder) {
+  public WareService(WareRepository repository, UserService userService, EntityManager entityManager) {
     super(repository, userService, entityManager);
     this.wareRepository = repository;
-    this.checkOrderService = checkOrderService;
-    this.mapper = builder.build();
   }
 
   public ImmutableList<Ware> listPublic() {
@@ -42,53 +28,4 @@ public class WareService extends LogicDeleteService<Ware> implements CheckingSer
         wareRepository.findAll((root, query, builder) -> builder.equal(root.get("state"), Ware.State.NORMAL))
     );
   }
-
-  @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);
-    }
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  public void submit(Long id) throws JsonProcessingException {
-    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);
-  }
-
-  @Transactional(rollbackOn = Throwable.class)
-  public void retract(Long id) {
-    Ware ware = detailOrThrow(id);
-    ware.setState(Ware.State.DRAFT);
-    save(ware);
-
-    CheckOrder order = ware.getOrder();
-    order.setState(CheckOrder.State.RETRACT);
-    checkOrderService.save(order);
-  }
 }

gringotts-web/src/main/java/com/eshore/gringotts/web/helper/EntityHelper.java

@@ -3,9 +3,9 @@ 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 com.eshore.gringotts.web.domain.entity.order.CheckOrder;
 import java.util.function.Supplier;
 import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.Predicate;