Kaynağa Gözat

新增流程接口

韩帛霖 1 yıl önce
ebeveyn
işleme
494242d8d2

+ 105 - 0
ruoyi-admin/src/main/java/com/ruoyi/web/controller/BpmProcessController.java

@@ -0,0 +1,105 @@
+package com.ruoyi.web.controller;
+
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+
+import com.ruoyi.system.entity.BpmProcess;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.ruoyi.common.annotation.Log;
+import com.ruoyi.common.core.controller.BaseController;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.enums.BusinessType;
+import com.ruoyi.system.service.IBpmProcessService;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.common.core.page.TableDataInfo;
+
+/**
+ * 流程定义Controller
+ * 
+ * @author ruoyi
+ * @date 2023-10-10
+ */
+@RestController
+@RequestMapping("/system/process")
+public class BpmProcessController extends BaseController
+{
+    @Autowired
+    private IBpmProcessService bpmProcessService;
+
+    /**
+     * 查询流程定义列表
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(BpmProcess bpmProcess)
+    {
+        startPage();
+        List<BpmProcess> list = bpmProcessService.selectBpmProcessList(bpmProcess);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出流程定义列表
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:export')")
+    @Log(title = "流程定义", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, BpmProcess bpmProcess)
+    {
+        List<BpmProcess> list = bpmProcessService.selectBpmProcessList(bpmProcess);
+        ExcelUtil<BpmProcess> util = new ExcelUtil<BpmProcess>(BpmProcess.class);
+        util.exportExcel(response, list, "流程定义数据");
+    }
+
+    /**
+     * 获取流程定义详细信息
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:query')")
+    @GetMapping(value = "/{processId}")
+    public AjaxResult getInfo(@PathVariable("processId") Long processId)
+    {
+        return success(bpmProcessService.selectBpmProcessByProcessId(processId));
+    }
+
+    /**
+     * 新增流程定义
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:add')")
+    @Log(title = "流程定义", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody BpmProcess bpmProcess)
+    {
+        return toAjax(bpmProcessService.insertBpmProcess(bpmProcess));
+    }
+
+    /**
+     * 修改流程定义
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:edit')")
+    @Log(title = "流程定义", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody BpmProcess bpmProcess)
+    {
+        return toAjax(bpmProcessService.updateBpmProcess(bpmProcess));
+    }
+
+    /**
+     * 删除流程定义
+     */
+    @PreAuthorize("@ss.hasPermi('system:process:remove')")
+    @Log(title = "流程定义", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{processIds}")
+    public AjaxResult remove(@PathVariable Long[] processIds)
+    {
+        return toAjax(bpmProcessService.deleteBpmProcessByProcessIds(processIds));
+    }
+}

+ 49 - 56
ruoyi-admin/src/main/resources/application-druid.yml

@@ -1,58 +1,51 @@
 # 数据源配置
 spring:
-    datasource:
-        dbtype: mysql
-        type: com.alibaba.druid.pool.DruidDataSource
-        driverClassName: com.mysql.cj.jdbc.Driver
-        druid:
-            # 主库数据源
-            master:
-                url: jdbc:mysql://192.168.110.15:3306/zkqy-call?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
-                username: root
-                password: zkqy8888
-            # 从库数据源
-#            slave:
-#                # 从数据源开关/默认关闭
-#                enabled: false
-#                url:
-#                username:
-#                password:
-            # 初始连接数
-            initialSize: 5
-            # 最小连接池数量
-            minIdle: 10
-            # 最大连接池数量
-            maxActive: 20
-            # 配置获取连接等待超时的时间
-            maxWait: 60000
-            # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
-            timeBetweenEvictionRunsMillis: 60000
-            # 配置一个连接在池中最小生存的时间,单位是毫秒
-            minEvictableIdleTimeMillis: 300000
-            # 配置一个连接在池中最大生存的时间,单位是毫秒
-            maxEvictableIdleTimeMillis: 900000
-            # 配置检测连接是否有效
-            validationQuery: SELECT 1 FROM DUAL
-            testWhileIdle: true
-            testOnBorrow: false
-            testOnReturn: false
-            webStatFilter:
-                enabled: true
-            statViewServlet:
-                enabled: true
-                # 设置白名单,不填则允许所有访问
-                allow:
-                url-pattern:
-                # 控制台管理用户名和密码
-                login-username: ruoyi
-                login-password: 123456
-            filter:
-                stat:
-                    enabled: true
-                    # 慢SQL记录
-                    log-slow-sql: true
-                    slow-sql-millis: 1000
-                    merge-sql: true
-                wall:
-                    config:
-                        multi-statement-allow: true
+  datasource:
+    dbtype: mysql
+    type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    druid:
+      # 主库数据源
+      master:
+        url: jdbc:mysql://192.168.110.15:3306/zkqy-call?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+        username: root
+        password: zkqy8888
+      # 初始连接数
+      initialSize: 5
+      # 最小连接池数量
+      minIdle: 10
+      # 最大连接池数量
+      maxActive: 20
+      # 配置获取连接等待超时的时间
+      maxWait: 60000
+      # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
+      timeBetweenEvictionRunsMillis: 60000
+      # 配置一个连接在池中最小生存的时间,单位是毫秒
+      minEvictableIdleTimeMillis: 300000
+      # 配置一个连接在池中最大生存的时间,单位是毫秒
+      maxEvictableIdleTimeMillis: 900000
+      # 配置检测连接是否有效
+      validationQuery: SELECT 1 FROM DUAL
+      testWhileIdle: true
+      testOnBorrow: false
+      testOnReturn: false
+      webStatFilter:
+        enabled: true
+      statViewServlet:
+        enabled: true
+        # 设置白名单,不填则允许所有访问
+        allow:
+        url-pattern:
+        # 控制台管理用户名和密码
+        login-username: ruoyi
+        login-password: 123456
+      filter:
+        stat:
+          enabled: true
+          # 慢SQL记录
+          log-slow-sql: true
+          slow-sql-millis: 1000
+          merge-sql: true
+        wall:
+          config:
+            multi-statement-allow: true

+ 1 - 1
ruoyi-admin/src/main/resources/application.yml

@@ -18,7 +18,7 @@ ruoyi:
 # 开发环境配置
 server:
   # 服务器的HTTP端口,默认为8080
-  port: 8072
+  port: 8055
   servlet:
     # 应用的访问路径
     context-path: /

+ 49 - 56
ruoyi-admin/target/classes/application-druid.yml

@@ -1,58 +1,51 @@
 # 数据源配置
 spring:
-    datasource:
-        dbtype: mysql
-        type: com.alibaba.druid.pool.DruidDataSource
-        driverClassName: com.mysql.cj.jdbc.Driver
-        druid:
-            # 主库数据源
-            master:
-                url: jdbc:mysql://192.168.110.15:3306/zkqy-call?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
-                username: root
-                password: zkqy8888
-            # 从库数据源
-#            slave:
-#                # 从数据源开关/默认关闭
-#                enabled: false
-#                url:
-#                username:
-#                password:
-            # 初始连接数
-            initialSize: 5
-            # 最小连接池数量
-            minIdle: 10
-            # 最大连接池数量
-            maxActive: 20
-            # 配置获取连接等待超时的时间
-            maxWait: 60000
-            # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
-            timeBetweenEvictionRunsMillis: 60000
-            # 配置一个连接在池中最小生存的时间,单位是毫秒
-            minEvictableIdleTimeMillis: 300000
-            # 配置一个连接在池中最大生存的时间,单位是毫秒
-            maxEvictableIdleTimeMillis: 900000
-            # 配置检测连接是否有效
-            validationQuery: SELECT 1 FROM DUAL
-            testWhileIdle: true
-            testOnBorrow: false
-            testOnReturn: false
-            webStatFilter:
-                enabled: true
-            statViewServlet:
-                enabled: true
-                # 设置白名单,不填则允许所有访问
-                allow:
-                url-pattern:
-                # 控制台管理用户名和密码
-                login-username: ruoyi
-                login-password: 123456
-            filter:
-                stat:
-                    enabled: true
-                    # 慢SQL记录
-                    log-slow-sql: true
-                    slow-sql-millis: 1000
-                    merge-sql: true
-                wall:
-                    config:
-                        multi-statement-allow: true
+  datasource:
+    dbtype: mysql
+    type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    druid:
+      # 主库数据源
+      master:
+        url: jdbc:mysql://192.168.110.15:3306/zkqy-call?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+        username: root
+        password: zkqy8888
+      # 初始连接数
+      initialSize: 5
+      # 最小连接池数量
+      minIdle: 10
+      # 最大连接池数量
+      maxActive: 20
+      # 配置获取连接等待超时的时间
+      maxWait: 60000
+      # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
+      timeBetweenEvictionRunsMillis: 60000
+      # 配置一个连接在池中最小生存的时间,单位是毫秒
+      minEvictableIdleTimeMillis: 300000
+      # 配置一个连接在池中最大生存的时间,单位是毫秒
+      maxEvictableIdleTimeMillis: 900000
+      # 配置检测连接是否有效
+      validationQuery: SELECT 1 FROM DUAL
+      testWhileIdle: true
+      testOnBorrow: false
+      testOnReturn: false
+      webStatFilter:
+        enabled: true
+      statViewServlet:
+        enabled: true
+        # 设置白名单,不填则允许所有访问
+        allow:
+        url-pattern:
+        # 控制台管理用户名和密码
+        login-username: ruoyi
+        login-password: 123456
+      filter:
+        stat:
+          enabled: true
+          # 慢SQL记录
+          log-slow-sql: true
+          slow-sql-millis: 1000
+          merge-sql: true
+        wall:
+          config:
+            multi-statement-allow: true

+ 1 - 1
ruoyi-admin/target/classes/application.yml

@@ -18,7 +18,7 @@ ruoyi:
 # 开发环境配置
 server:
   # 服务器的HTTP端口,默认为8080
-  port: 8072
+  port: 8055
   servlet:
     # 应用的访问路径
     context-path: /

BIN
ruoyi-framework/target/classes/com/ruoyi/framework/aspectj/SqlInterceptor.class


+ 226 - 0
ruoyi-system/src/main/java/com/ruoyi/system/entity/BpmProcess.java

@@ -0,0 +1,226 @@
+package com.ruoyi.system.entity;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.ruoyi.common.annotation.Excel;
+import com.ruoyi.common.core.domain.BaseEntity;
+
+/**
+ * 流程定义对象 bpm_process
+ * 
+ * @author ruoyi
+ * @date 2023-10-10
+ */
+public class BpmProcess extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键 */
+    private Long processId;
+
+    /** 流程名称 */
+    @Excel(name = "流程名称")
+    private String processName;
+
+    /** 流程别名 */
+    @Excel(name = "流程别名")
+    private String processKey;
+
+    /** 流程开启状态 */
+    @Excel(name = "流程开启状态")
+    private Long processOpneState;
+
+    /** 流程类型。例如(OA类型,mes类型) */
+    @Excel(name = "流程类型。例如", readConverterExp = "O=A类型,mes类型")
+    private Long processType;
+
+    /** 流程部署时间 */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "流程部署时间", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date processDeployTime;
+
+    /** 启动事件类型 */
+    @Excel(name = "启动事件类型")
+    private Long startEventType;
+
+    /** 版本注释 */
+    @Excel(name = "版本注释")
+    private String note;
+
+    /** 版本状态(0代表最新版本,1代表历史版本) */
+    @Excel(name = "版本状态", readConverterExp = "0=代表最新版本,1代表历史版本")
+    private Long processVersion;
+
+    /** xml流文件 */
+    @Excel(name = "xml流文件")
+    private String processXml;
+
+    /** 节点json串 */
+    @Excel(name = "节点json串")
+    private String processJson;
+
+    /** xml标签内容 */
+    @Excel(name = "xml标签内容")
+    private String processXmlContent;
+
+    /** xml文件存放地址 */
+    @Excel(name = "xml文件存放地址")
+    private String processXmlPath;
+
+    /** 删除标志(0代表存在 2代表删除) */
+    private String delFlag;
+
+    public void setProcessId(Long processId) 
+    {
+        this.processId = processId;
+    }
+
+    public Long getProcessId() 
+    {
+        return processId;
+    }
+    public void setProcessName(String processName) 
+    {
+        this.processName = processName;
+    }
+
+    public String getProcessName() 
+    {
+        return processName;
+    }
+    public void setProcessKey(String processKey) 
+    {
+        this.processKey = processKey;
+    }
+
+    public String getProcessKey() 
+    {
+        return processKey;
+    }
+    public void setProcessOpneState(Long processOpneState) 
+    {
+        this.processOpneState = processOpneState;
+    }
+
+    public Long getProcessOpneState() 
+    {
+        return processOpneState;
+    }
+    public void setProcessType(Long processType) 
+    {
+        this.processType = processType;
+    }
+
+    public Long getProcessType() 
+    {
+        return processType;
+    }
+    public void setProcessDeployTime(Date processDeployTime) 
+    {
+        this.processDeployTime = processDeployTime;
+    }
+
+    public Date getProcessDeployTime() 
+    {
+        return processDeployTime;
+    }
+    public void setStartEventType(Long startEventType) 
+    {
+        this.startEventType = startEventType;
+    }
+
+    public Long getStartEventType() 
+    {
+        return startEventType;
+    }
+    public void setNote(String note) 
+    {
+        this.note = note;
+    }
+
+    public String getNote() 
+    {
+        return note;
+    }
+    public void setProcessVersion(Long processVersion) 
+    {
+        this.processVersion = processVersion;
+    }
+
+    public Long getProcessVersion() 
+    {
+        return processVersion;
+    }
+    public void setProcessXml(String processXml) 
+    {
+        this.processXml = processXml;
+    }
+
+    public String getProcessXml() 
+    {
+        return processXml;
+    }
+    public void setProcessJson(String processJson) 
+    {
+        this.processJson = processJson;
+    }
+
+    public String getProcessJson() 
+    {
+        return processJson;
+    }
+    public void setProcessXmlContent(String processXmlContent) 
+    {
+        this.processXmlContent = processXmlContent;
+    }
+
+    public String getProcessXmlContent() 
+    {
+        return processXmlContent;
+    }
+    public void setProcessXmlPath(String processXmlPath) 
+    {
+        this.processXmlPath = processXmlPath;
+    }
+
+    public String getProcessXmlPath() 
+    {
+        return processXmlPath;
+    }
+    public void setDelFlag(String delFlag) 
+    {
+        this.delFlag = delFlag;
+    }
+
+    public String getDelFlag() 
+    {
+        return delFlag;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("processId", getProcessId())
+            .append("processName", getProcessName())
+            .append("processKey", getProcessKey())
+            .append("processOpneState", getProcessOpneState())
+            .append("processType", getProcessType())
+            .append("processDeployTime", getProcessDeployTime())
+            .append("startEventType", getStartEventType())
+            .append("note", getNote())
+            .append("processVersion", getProcessVersion())
+            .append("processXml", getProcessXml())
+            .append("processJson", getProcessJson())
+            .append("processXmlContent", getProcessXmlContent())
+            .append("processXmlPath", getProcessXmlPath())
+            .append("createBy", getCreateBy())
+            .append("createTime", getCreateTime())
+            .append("updateBy", getUpdateBy())
+            .append("updateTime", getUpdateTime())
+            .append("delFlag", getDelFlag())
+            .append("remark", getRemark())
+            .toString();
+    }
+}

+ 62 - 0
ruoyi-system/src/main/java/com/ruoyi/system/mapper/BpmProcessMapper.java

@@ -0,0 +1,62 @@
+package com.ruoyi.system.mapper;
+
+import com.ruoyi.system.entity.BpmProcess;
+
+import java.util.List;
+
+/**
+ * 流程定义Mapper接口
+ * 
+ * @author ruoyi
+ * @date 2023-10-10
+ */
+public interface BpmProcessMapper 
+{
+    /**
+     * 查询流程定义
+     * 
+     * @param processId 流程定义主键
+     * @return 流程定义
+     */
+    public BpmProcess selectBpmProcessByProcessId(Long processId);
+
+    /**
+     * 查询流程定义列表
+     * 
+     * @param bpmProcess 流程定义
+     * @return 流程定义集合
+     */
+    public List<BpmProcess> selectBpmProcessList(BpmProcess bpmProcess);
+
+    /**
+     * 新增流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    public int insertBpmProcess(BpmProcess bpmProcess);
+
+    /**
+     * 修改流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    public int updateBpmProcess(BpmProcess bpmProcess);
+
+    /**
+     * 删除流程定义
+     * 
+     * @param processId 流程定义主键
+     * @return 结果
+     */
+    public int deleteBpmProcessByProcessId(Long processId);
+
+    /**
+     * 批量删除流程定义
+     * 
+     * @param processIds 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteBpmProcessByProcessIds(Long[] processIds);
+}

+ 62 - 0
ruoyi-system/src/main/java/com/ruoyi/system/service/IBpmProcessService.java

@@ -0,0 +1,62 @@
+package com.ruoyi.system.service;
+
+import com.ruoyi.system.entity.BpmProcess;
+
+import java.util.List;
+
+/**
+ * 流程定义Service接口
+ * 
+ * @author ruoyi
+ * @date 2023-10-10
+ */
+public interface IBpmProcessService 
+{
+    /**
+     * 查询流程定义
+     * 
+     * @param processId 流程定义主键
+     * @return 流程定义
+     */
+    public BpmProcess selectBpmProcessByProcessId(Long processId);
+
+    /**
+     * 查询流程定义列表
+     * 
+     * @param bpmProcess 流程定义
+     * @return 流程定义集合
+     */
+    public List<BpmProcess> selectBpmProcessList(BpmProcess bpmProcess);
+
+    /**
+     * 新增流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    public int insertBpmProcess(BpmProcess bpmProcess);
+
+    /**
+     * 修改流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    public int updateBpmProcess(BpmProcess bpmProcess);
+
+    /**
+     * 批量删除流程定义
+     * 
+     * @param processIds 需要删除的流程定义主键集合
+     * @return 结果
+     */
+    public int deleteBpmProcessByProcessIds(Long[] processIds);
+
+    /**
+     * 删除流程定义信息
+     * 
+     * @param processId 流程定义主键
+     * @return 结果
+     */
+    public int deleteBpmProcessByProcessId(Long processId);
+}

+ 96 - 0
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/BpmProcessServiceImpl.java

@@ -0,0 +1,96 @@
+package com.ruoyi.system.service.impl;
+
+import java.util.List;
+import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.system.entity.BpmProcess;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.ruoyi.system.mapper.BpmProcessMapper;
+import com.ruoyi.system.service.IBpmProcessService;
+
+/**
+ * 流程定义Service业务层处理
+ * 
+ * @author ruoyi
+ * @date 2023-10-10
+ */
+@Service
+public class BpmProcessServiceImpl implements IBpmProcessService 
+{
+    @Autowired
+    private BpmProcessMapper bpmProcessMapper;
+
+    /**
+     * 查询流程定义
+     * 
+     * @param processId 流程定义主键
+     * @return 流程定义
+     */
+    @Override
+    public BpmProcess selectBpmProcessByProcessId(Long processId)
+    {
+        return bpmProcessMapper.selectBpmProcessByProcessId(processId);
+    }
+
+    /**
+     * 查询流程定义列表
+     * 
+     * @param bpmProcess 流程定义
+     * @return 流程定义
+     */
+    @Override
+    public List<BpmProcess> selectBpmProcessList(BpmProcess bpmProcess)
+    {
+        return bpmProcessMapper.selectBpmProcessList(bpmProcess);
+    }
+
+    /**
+     * 新增流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    @Override
+    public int insertBpmProcess(BpmProcess bpmProcess)
+    {
+        bpmProcess.setCreateTime(DateUtils.getNowDate());
+        return bpmProcessMapper.insertBpmProcess(bpmProcess);
+    }
+
+    /**
+     * 修改流程定义
+     * 
+     * @param bpmProcess 流程定义
+     * @return 结果
+     */
+    @Override
+    public int updateBpmProcess(BpmProcess bpmProcess)
+    {
+        bpmProcess.setUpdateTime(DateUtils.getNowDate());
+        return bpmProcessMapper.updateBpmProcess(bpmProcess);
+    }
+
+    /**
+     * 批量删除流程定义
+     * 
+     * @param processIds 需要删除的流程定义主键
+     * @return 结果
+     */
+    @Override
+    public int deleteBpmProcessByProcessIds(Long[] processIds)
+    {
+        return bpmProcessMapper.deleteBpmProcessByProcessIds(processIds);
+    }
+
+    /**
+     * 删除流程定义信息
+     * 
+     * @param processId 流程定义主键
+     * @return 结果
+     */
+    @Override
+    public int deleteBpmProcessByProcessId(Long processId)
+    {
+        return bpmProcessMapper.deleteBpmProcessByProcessId(processId);
+    }
+}

+ 135 - 0
ruoyi-system/src/main/resources/mapper/BpmProcessMapper.xml

@@ -0,0 +1,135 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.system.mapper.BpmProcessMapper">
+    
+    <resultMap type="com.ruoyi.system.entity.BpmProcess" id="BpmProcessResult">
+        <result property="processId"    column="process_id"    />
+        <result property="processName"    column="process_name"    />
+        <result property="processKey"    column="process_key"    />
+        <result property="processOpneState"    column="process_opne_state"    />
+        <result property="processType"    column="process_type"    />
+        <result property="processDeployTime"    column="process_deploy_time"    />
+        <result property="startEventType"    column="start_event_type"    />
+        <result property="note"    column="note"    />
+        <result property="processVersion"    column="process_version"    />
+        <result property="processXml"    column="process_xml"    />
+        <result property="processJson"    column="process_json"    />
+        <result property="processXmlContent"    column="process_xml_content"    />
+        <result property="processXmlPath"    column="process_xml_path"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="delFlag"    column="del_flag"    />
+        <result property="remark"    column="remark"    />
+    </resultMap>
+
+    <sql id="selectBpmProcessVo">
+        select process_id, process_name, process_key, process_opne_state, process_type, process_deploy_time, start_event_type, note, process_version, process_xml, process_json, process_xml_content, process_xml_path, create_by, create_time, update_by, update_time, del_flag, remark from bpm_process
+    </sql>
+
+    <select id="selectBpmProcessList" parameterType="com.ruoyi.system.entity.BpmProcess" resultMap="BpmProcessResult">
+        <include refid="selectBpmProcessVo"/>
+        <where>  
+            <if test="processName != null  and processName != ''"> and process_name like concat('%', #{processName}, '%')</if>
+            <if test="processKey != null  and processKey != ''"> and process_key = #{processKey}</if>
+            <if test="processOpneState != null "> and process_opne_state = #{processOpneState}</if>
+            <if test="processType != null "> and process_type = #{processType}</if>
+            <if test="processDeployTime != null "> and process_deploy_time = #{processDeployTime}</if>
+            <if test="startEventType != null "> and start_event_type = #{startEventType}</if>
+            <if test="note != null  and note != ''"> and note = #{note}</if>
+            <if test="processVersion != null "> and process_version = #{processVersion}</if>
+            <if test="processXml != null  and processXml != ''"> and process_xml = #{processXml}</if>
+            <if test="processJson != null  and processJson != ''"> and process_json = #{processJson}</if>
+            <if test="processXmlContent != null  and processXmlContent != ''"> and process_xml_content = #{processXmlContent}</if>
+            <if test="processXmlPath != null  and processXmlPath != ''"> and process_xml_path = #{processXmlPath}</if>
+        </where>
+    </select>
+    
+    <select id="selectBpmProcessByProcessId" parameterType="Long" resultMap="BpmProcessResult">
+        <include refid="selectBpmProcessVo"/>
+        where process_id = #{processId}
+    </select>
+        
+    <insert id="insertBpmProcess" parameterType="com.ruoyi.system.entity.BpmProcess" useGeneratedKeys="true" keyProperty="processId">
+        insert into bpm_process
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="processName != null">process_name,</if>
+            <if test="processKey != null">process_key,</if>
+            <if test="processOpneState != null">process_opne_state,</if>
+            <if test="processType != null">process_type,</if>
+            <if test="processDeployTime != null">process_deploy_time,</if>
+            <if test="startEventType != null">start_event_type,</if>
+            <if test="note != null">note,</if>
+            <if test="processVersion != null">process_version,</if>
+            <if test="processXml != null">process_xml,</if>
+            <if test="processJson != null">process_json,</if>
+            <if test="processXmlContent != null">process_xml_content,</if>
+            <if test="processXmlPath != null">process_xml_path,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateBy != null">update_by,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="delFlag != null">del_flag,</if>
+            <if test="remark != null">remark,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="processName != null">#{processName},</if>
+            <if test="processKey != null">#{processKey},</if>
+            <if test="processOpneState != null">#{processOpneState},</if>
+            <if test="processType != null">#{processType},</if>
+            <if test="processDeployTime != null">#{processDeployTime},</if>
+            <if test="startEventType != null">#{startEventType},</if>
+            <if test="note != null">#{note},</if>
+            <if test="processVersion != null">#{processVersion},</if>
+            <if test="processXml != null">#{processXml},</if>
+            <if test="processJson != null">#{processJson},</if>
+            <if test="processXmlContent != null">#{processXmlContent},</if>
+            <if test="processXmlPath != null">#{processXmlPath},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="delFlag != null">#{delFlag},</if>
+            <if test="remark != null">#{remark},</if>
+         </trim>
+    </insert>
+
+    <update id="updateBpmProcess" parameterType="com.ruoyi.system.entity.BpmProcess">
+        update bpm_process
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="processName != null">process_name = #{processName},</if>
+            <if test="processKey != null">process_key = #{processKey},</if>
+            <if test="processOpneState != null">process_opne_state = #{processOpneState},</if>
+            <if test="processType != null">process_type = #{processType},</if>
+            <if test="processDeployTime != null">process_deploy_time = #{processDeployTime},</if>
+            <if test="startEventType != null">start_event_type = #{startEventType},</if>
+            <if test="note != null">note = #{note},</if>
+            <if test="processVersion != null">process_version = #{processVersion},</if>
+            <if test="processXml != null">process_xml = #{processXml},</if>
+            <if test="processJson != null">process_json = #{processJson},</if>
+            <if test="processXmlContent != null">process_xml_content = #{processXmlContent},</if>
+            <if test="processXmlPath != null">process_xml_path = #{processXmlPath},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="delFlag != null">del_flag = #{delFlag},</if>
+            <if test="remark != null">remark = #{remark},</if>
+        </trim>
+        where process_id = #{processId}
+    </update>
+
+    <delete id="deleteBpmProcessByProcessId" parameterType="Long">
+        delete from bpm_process where process_id = #{processId}
+    </delete>
+
+    <delete id="deleteBpmProcessByProcessIds" parameterType="String">
+        delete from bpm_process where process_id in 
+        <foreach item="processId" collection="array" open="(" separator="," close=")">
+            #{processId}
+        </foreach>
+    </delete>
+</mapper>

BIN
ruoyi-system/target/classes/com/ruoyi/system/test/DataSourceManager.class


BIN
ruoyi-system/target/classes/com/ruoyi/system/test/DataSourceSwitchManager.class


BIN
ruoyi-system/target/classes/com/ruoyi/system/test/DatabaseService.class


BIN
ruoyi-system/target/classes/com/ruoyi/system/test/DynamicDataSourceContext.class


BIN
ruoyi-system/target/classes/com/ruoyi/system/test/ljj.class