From b7c9eedeaae615374e0bda5311440aa0b6df3958 Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Tue, 28 May 2024 16:37:36 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=96=B0=E5=8F=91=E8=B5=B7=E5=92=8C?=
 =?UTF-8?q?=E5=8F=96=E6=B6=88=E6=B5=81=E7=A8=8B=E6=8E=A5=E5=8F=A3=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../enums/SupervisionResponseEnum.java        |  1 +
 .../param/device/QuitRunningDeviceParam.java  |  6 +++
 .../pojo/po/device/QuitRunningDevice.java     |  5 +++
 .../pojo/vo/device/QuitRunningDeviceVO.java   |  6 +++
 .../mapping/QuitRunningDeviceMapper.xml       |  1 +
 .../impl/QuitRunningDeviceServiceImpl.java    | 14 ++++++-
 .../njcn/supervision/utils/InstanceUtil.java  | 39 +++++++++++++++++++
 7 files changed, 71 insertions(+), 1 deletion(-)
 create mode 100644 pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/utils/InstanceUtil.java

diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/enums/SupervisionResponseEnum.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/enums/SupervisionResponseEnum.java
index 4c475afbd..f046ae897 100644
--- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/enums/SupervisionResponseEnum.java
+++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/enums/SupervisionResponseEnum.java
@@ -16,6 +16,7 @@ public enum SupervisionResponseEnum {
      * A00550 ~ A00649
      */
     SUPERVISION_COMMON_ERROR("A00550","监督管理模块异常"),
+    NO_POWER("A00550","很抱歉，该流程不是您创建的，没有权限操作！")
     ;
 
     private final String code;
diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/QuitRunningDeviceParam.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/QuitRunningDeviceParam.java
index 379f854ae..284fc076b 100644
--- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/QuitRunningDeviceParam.java
+++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/QuitRunningDeviceParam.java
@@ -67,6 +67,12 @@ public class QuitRunningDeviceParam  implements Serializable {
     @ApiModelProperty(value = "流程实例的编号")
     private String processInstanceId;
 
+    /**
+     * 历史流程实例编号
+     */
+    @ApiModelProperty(value = "历史流程实例编号")
+    private String historyInstanceId;
+
     @ApiModelProperty("发起人自选审批人 Map")
     private Map<String, List<String>> startUserSelectAssignees;
 
diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/device/QuitRunningDevice.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/device/QuitRunningDevice.java
index 14e636823..af6bb6885 100644
--- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/device/QuitRunningDevice.java
+++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/device/QuitRunningDevice.java
@@ -58,6 +58,11 @@ public class QuitRunningDevice extends BaseEntity implements Serializable{
      */
     private String processInstanceId;
 
+    /**
+     * 历史流程实例编号
+     */
+    private String historyInstanceId;
+
     /**
      * 状态：0-删除 1-正常
      */
diff --git a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/QuitRunningDeviceVO.java b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/QuitRunningDeviceVO.java
index 402ba0814..a671d7817 100644
--- a/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/QuitRunningDeviceVO.java
+++ b/pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/QuitRunningDeviceVO.java
@@ -81,5 +81,11 @@ public class QuitRunningDeviceVO extends BaseEntity implements Serializable{
     @ApiModelProperty(value = "流程实例的编号")
     private String processInstanceId;
 
+    /**
+     * 历史流程实例编号
+     */
+    @ApiModelProperty(value = "历史流程实例编号")
+    private String historyInstanceId;
+
 
 }
diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/QuitRunningDeviceMapper.xml b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/QuitRunningDeviceMapper.xml
index de7e01a98..22e6bc74d 100644
--- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/QuitRunningDeviceMapper.xml
+++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/mapper/device/mapping/QuitRunningDeviceMapper.xml
@@ -10,6 +10,7 @@
             supervision_quit_running_device.property_no,
             supervision_quit_running_device.report_path,
             supervision_quit_running_device.process_instance_id,
+            supervision_quit_running_device.history_instance_id,
             supervision_quit_running_device.create_time,
             supervision_quit_running_device.status
         FROM supervision_quit_running_device supervision_quit_running_device
diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java
index 82bcb9a10..90865484b 100644
--- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java
+++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java
@@ -27,6 +27,7 @@ import com.njcn.supervision.pojo.param.device.QuitRunningDeviceParam;
 import com.njcn.supervision.pojo.po.device.QuitRunningDevice;
 import com.njcn.supervision.pojo.vo.device.QuitRunningDeviceVO;
 import com.njcn.supervision.service.device.IQuitRunningDeviceService;
+import com.njcn.supervision.utils.InstanceUtil;
 import com.njcn.user.api.UserFeignClient;
 import com.njcn.web.factory.PageFactory;
 import com.njcn.web.utils.RequestUtil;
@@ -93,9 +94,16 @@ public class QuitRunningDeviceServiceImpl extends ServiceImpl<QuitRunningDeviceM
     @Transactional(rollbackFor = Exception.class)
     public String updateQuitRunningDevice(QuitRunningDeviceParam.QuitRunningDeviceUpdateParam quitRunningDeviceUpdateParam) {
         QuitRunningDevice quitRunningDevice = this.baseMapper.selectById(quitRunningDeviceUpdateParam.getId());
+        //判断是否有权限操作
+        InstanceUtil.judgeUserPower(RequestUtil.getUserIndex(),quitRunningDevice.getCreateBy());
+        quitRunningDeviceUpdateParam.setStatus(quitRunningDevice.getStatus());
+        quitRunningDeviceUpdateParam.setProcessInstanceId(quitRunningDevice.getProcessInstanceId());
+        quitRunningDeviceUpdateParam.setHistoryInstanceId(quitRunningDevice.getHistoryInstanceId());
         BeanUtils.copyProperties(quitRunningDeviceUpdateParam, quitRunningDevice);
         quitRunningDevice.setState(DataStateEnum.ENABLE.getCode());
         quitRunningDevice.setStatus(BpmTaskStatusEnum.RUNNING.getStatus());
+        //处理历史流程id列表
+        String historyInstanceIds = InstanceUtil.dealHistoryId(quitRunningDevice.getProcessInstanceId(), quitRunningDevice.getHistoryInstanceId());
         // 发起 BPM 流程
         Map<String, Object> processInstanceVariables = new HashMap<>();
         BpmProcessInstanceCreateReqDTO bpmProcessInstanceCreateReqDTO = new BpmProcessInstanceCreateReqDTO();
@@ -106,6 +114,8 @@ public class QuitRunningDeviceServiceImpl extends ServiceImpl<QuitRunningDeviceM
         String processInstanceId = bpmProcessFeignClient.createProcessInstance(quitRunningDevice.getCreateBy(), bpmProcessInstanceCreateReqDTO).getData();
         // 将工作流的编号，更新到流程单中
         quitRunningDevice.setProcessInstanceId(processInstanceId);
+        //保存历史流程id列表
+        quitRunningDevice.setHistoryInstanceId(historyInstanceIds);
         this.baseMapper.updateById(quitRunningDevice);
         return quitRunningDevice.getId();
     }
@@ -127,7 +137,7 @@ public class QuitRunningDeviceServiceImpl extends ServiceImpl<QuitRunningDeviceM
 
         //获取当前用户部门所有同事的id，查看该部门下所有的数据
         List<String> colleaguesIds = userFeignClient.getColleaguesIdByUserId(RequestUtil.getUserIndex()).getData();
-        quitRunningDeviceVOQueryWrapper.in("supervision_quit_running_device.Create_By",colleaguesIds)
+        quitRunningDeviceVOQueryWrapper.in("supervision_quit_running_device.Create_By", colleaguesIds)
                 .orderByDesc("supervision_quit_running_device.Update_Time");
         Page<QuitRunningDeviceVO> page = this.baseMapper.page(new Page<>(PageFactory.getPageNum(quitRunningDeviceQueryParam), PageFactory.getPageSize(quitRunningDeviceQueryParam)), quitRunningDeviceVOQueryWrapper);
         List<QuitRunningDeviceVO> records = page.getRecords();
@@ -205,6 +215,8 @@ public class QuitRunningDeviceServiceImpl extends ServiceImpl<QuitRunningDeviceM
     public String cancelQuitRunningDevice(BpmProcessInstanceCancelParam cancelReqVO) {
         //准备取消该流程，需要远程调用接口
         QuitRunningDevice quitRunningDevice = this.baseMapper.selectById(cancelReqVO.getId());
+        //判断是否有权限操作
+        InstanceUtil.judgeUserPower(RequestUtil.getUserIndex(),quitRunningDevice.getCreateBy());
         //取消流程
         bpmProcessFeignClient.cancelProcessInstanceByStartUser(cancelReqVO);
         //更新状态
diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/utils/InstanceUtil.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/utils/InstanceUtil.java
new file mode 100644
index 000000000..f9e13b97d
--- /dev/null
+++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/utils/InstanceUtil.java
@@ -0,0 +1,39 @@
+package com.njcn.supervision.utils;
+
+import cn.hutool.core.text.StrPool;
+import cn.hutool.core.util.StrUtil;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.supervision.enums.SupervisionResponseEnum;
+
+/**
+ * 处理流程实例的工具类
+ */
+public class InstanceUtil {
+
+    /**
+     * 处理历史流程实例的id
+     *
+     * @param lastId     最近一次流程实例id
+     * @param historyIds 之前历史id列表
+     * @return 最新的历史id列表
+     */
+    public static String dealHistoryId(String lastId, String historyIds) {
+        if (StrUtil.isBlank(historyIds)) {
+            return lastId;
+        }
+        return historyIds.concat(StrPool.COMMA).concat(lastId);
+    }
+
+    /**
+     * 判断用户是否有权限操作
+     * @param userId 当前用户id
+     * @param createBy 数据创建用户id
+     */
+    public static void judgeUserPower(String userId,String createBy){
+        if(!userId.equalsIgnoreCase(createBy)){
+            throw new BusinessException(SupervisionResponseEnum.NO_POWER);
+        }
+    }
+
+
+}