From d5441f5235a3b0997a91a43f08130d2a7c64a1c3 Mon Sep 17 00:00:00 2001
From: yangwei <867012372@qq.com>
Date: Thu, 13 Mar 2025 14:45:42 +0800
Subject: [PATCH] =?UTF-8?q?[feat]=201=E3=80=81=E8=81=94=E8=B0=83=E9=A2=84?=
 =?UTF-8?q?=E8=AD=A6=E7=9B=B8=E5=85=B3=E5=8A=9F=E8=83=BD=202=E3=80=81?=
 =?UTF-8?q?=E5=BC=80=E5=8F=91=E6=B5=81=E7=A8=8B=E9=83=A8=E9=97=A8=E5=85=B3?=
 =?UTF-8?q?=E7=B3=BB=E8=AE=BE=E7=BD=AE=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/RemoteBusinessAlertService.java       |  2 +-
 .../common/core/enums/BusinessStatusEnum.java |  8 ++-
 .../business/domain/BusinessAlert.java        | 18 ++++++
 .../business/domain/bo/BusinessAlertBo.java   | 19 +++++++
 .../business/domain/vo/BusinessAlertVo.java   | 19 +++++++
 .../dubbo/RemoteBusinessAlertServiceImpl.java |  4 +-
 .../business/mapper/BusinessAlertMapper.java  | 16 +++++-
 .../service/IBusinessAlertService.java        |  4 +-
 .../impl/BusinessAlertServiceImpl.java        | 57 +++++++++++++++++--
 .../mapper/business/BusinessAlertMapper.xml   | 18 ++++++
 .../org/dromara/system/domain/SysDept.java    |  5 ++
 .../dromara/system/domain/bo/SysDeptBo.java   |  5 ++
 .../workflow/domain/bo/CompleteTaskBo.java    | 15 +++++
 .../workflow/handler/FlwAlertHandler.java     | 16 +++++-
 .../handler/WorkflowPermissionHandler.java    |  5 +-
 .../service/impl/FlwTaskServiceImpl.java      | 14 ++++-
 16 files changed, 208 insertions(+), 17 deletions(-)

diff --git a/dk-api/api-business/src/main/java/org/dromara/business/api/RemoteBusinessAlertService.java b/dk-api/api-business/src/main/java/org/dromara/business/api/RemoteBusinessAlertService.java
index 2237092..88b19c7 100644
--- a/dk-api/api-business/src/main/java/org/dromara/business/api/RemoteBusinessAlertService.java
+++ b/dk-api/api-business/src/main/java/org/dromara/business/api/RemoteBusinessAlertService.java
@@ -15,5 +15,5 @@ public interface RemoteBusinessAlertService {
      * @param businessId 业务id(预警、工单)
      * @param flowStatus 流程状态
      */
-    void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType);
+    void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType,String message,String assignName);
 }
diff --git a/dk-common/common-core/src/main/java/org/dromara/common/core/enums/BusinessStatusEnum.java b/dk-common/common-core/src/main/java/org/dromara/common/core/enums/BusinessStatusEnum.java
index d2c38dd..329ee68 100644
--- a/dk-common/common-core/src/main/java/org/dromara/common/core/enums/BusinessStatusEnum.java
+++ b/dk-common/common-core/src/main/java/org/dromara/common/core/enums/BusinessStatusEnum.java
@@ -32,10 +32,16 @@ public enum BusinessStatusEnum {
      * 草稿
      */
     DRAFT("draft", "草稿"),
+    /**
+     * 处理中
+     */
+    WAITING("waiting", "处理中"),
+
     /**
      * 待审核
      */
-    WAITING("waiting", "待审核"),
+    TODO("todo", "待审核"),
+
     /**
      * 已完成
      */
diff --git a/dk-modules/business/src/main/java/org/dromara/business/domain/BusinessAlert.java b/dk-modules/business/src/main/java/org/dromara/business/domain/BusinessAlert.java
index 43e1502..5ef21c5 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/domain/BusinessAlert.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/domain/BusinessAlert.java
@@ -165,6 +165,24 @@ public class BusinessAlert extends BaseEntity {
      */
     private String jobName;
 
+    /**
+     * 指派人员
+     */
+    private String assignUserId;
+
+
+    /**
+     * 指派人员名称
+     */
+    @Translation(type = TransConstant.USER_ID_TO_NICKNAME, mapper = "assignUserId")
+    private String assignUserName;
+
+
+    /**
+     * 指派时间
+     */
+    private Date assignDate;
+
     /**
      * 处理时间
      */
diff --git a/dk-modules/business/src/main/java/org/dromara/business/domain/bo/BusinessAlertBo.java b/dk-modules/business/src/main/java/org/dromara/business/domain/bo/BusinessAlertBo.java
index fa1d2d5..00d3c61 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/domain/bo/BusinessAlertBo.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/domain/bo/BusinessAlertBo.java
@@ -10,6 +10,9 @@ import io.github.linpeilie.annotations.AutoMapper;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import jakarta.validation.constraints.*;
+import org.dromara.common.translation.annotation.Translation;
+import org.dromara.common.translation.constant.TransConstant;
+
 import java.util.Date;
 import java.util.List;
 
@@ -224,5 +227,21 @@ public class BusinessAlertBo {
      */
     private String postCode;
 
+    /**
+     * 指派人员
+     */
+    private String assignUserId;
+
+
+    /**
+     * 指派人员名称
+     */
+    private String assignUserName;
+
+
+    /**
+     * 指派时间
+     */
+    private Date assignDate;
 
 }
diff --git a/dk-modules/business/src/main/java/org/dromara/business/domain/vo/BusinessAlertVo.java b/dk-modules/business/src/main/java/org/dromara/business/domain/vo/BusinessAlertVo.java
index 04ed32d..c70d16a 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/domain/vo/BusinessAlertVo.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/domain/vo/BusinessAlertVo.java
@@ -6,6 +6,8 @@ import io.github.linpeilie.annotations.AutoMapper;
 import lombok.Data;
 import org.dromara.business.domain.BusinessAlert;
 import org.dromara.common.core.enums.BusinessStatusEnum;
+import org.dromara.common.translation.annotation.Translation;
+import org.dromara.common.translation.constant.TransConstant;
 
 import java.io.Serial;
 import java.io.Serializable;
@@ -233,4 +235,21 @@ public class BusinessAlertVo implements Serializable {
     @ExcelProperty(value = "来源：0：平台 1：小程序")
     private Long handleSource;
 
+
+    /**
+     * 指派人员
+     */
+    private String assignUserId;
+
+
+    /**
+     * 指派人员名称
+     */
+    private String assignUserName;
+
+
+    /**
+     * 指派时间
+     */
+    private Date assignDate;
 }
diff --git a/dk-modules/business/src/main/java/org/dromara/business/dubbo/RemoteBusinessAlertServiceImpl.java b/dk-modules/business/src/main/java/org/dromara/business/dubbo/RemoteBusinessAlertServiceImpl.java
index be01604..dc63dbb 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/dubbo/RemoteBusinessAlertServiceImpl.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/dubbo/RemoteBusinessAlertServiceImpl.java
@@ -23,7 +23,7 @@ public class RemoteBusinessAlertServiceImpl implements RemoteBusinessAlertServic
      * @param flowStatus 流程状态
      */
     @Override
-    public void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType) {
-        businessAlertService.updateAlertStatus(businessId,flowStatus,isIllegal,alertType);
+    public void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType,String message,String assignName) {
+        businessAlertService.updateAlertStatus(businessId,flowStatus,isIllegal,alertType,message,assignName);
     }
 }
diff --git a/dk-modules/business/src/main/java/org/dromara/business/mapper/BusinessAlertMapper.java b/dk-modules/business/src/main/java/org/dromara/business/mapper/BusinessAlertMapper.java
index d242c68..94933ec 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/mapper/BusinessAlertMapper.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/mapper/BusinessAlertMapper.java
@@ -29,10 +29,22 @@ public interface BusinessAlertMapper extends BaseMapperPlus<BusinessAlert, Busin
 
     Page<BusinessAlert> pageAlertFinish(Page<BusinessAlert> page, QueryWrapper<BusinessAlert> ew);
 
-
+    /**
+     * 待指派
+     * @param page
+     * @param ew
+     * @return
+     */
+    Page<BusinessAlert> pageAlertAssign(Page<BusinessAlert> page, QueryWrapper<BusinessAlert> ew);
+
+    /**
+     * 处理中
+     * @param page
+     * @param ew
+     * @return
+     */
     Page<BusinessAlert> pageAlertTodo(Page<BusinessAlert> page, QueryWrapper<BusinessAlert> ew);
 
-
     Page<BusinessAlert> pageBusinessAlertCancel(Page<BusinessAlert> build, QueryWrapper<BusinessAlert> ew);
 
     @DataPermission(
diff --git a/dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java b/dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java
index 7d7d5a8..5c642cb 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java
@@ -20,6 +20,8 @@ public interface IBusinessAlertService {
 
     TableDataInfo<BusinessAlert> pageBusinessAlertFinish(BusinessAlertBo bo, PageQuery pageQuery);
 
+    TableDataInfo<BusinessAlert> pageAlertAssign(BusinessAlertBo bo, PageQuery pageQuery);
+
     TableDataInfo<BusinessAlert> pageBusinessAlertAll(BusinessAlertBo bo, PageQuery pageQuery);
 
     TableDataInfo<BusinessAlert> pageBusinessAlertCancel(BusinessAlertBo bo, PageQuery pageQuery);
@@ -62,7 +64,7 @@ public interface IBusinessAlertService {
      * @param businessId
      * @param flowStatus
      */
-    void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType);
+    void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType,String message,String assignName);
 
     TableDataInfo<BusinessAlert> getInfo(BusinessAlertBo bo, PageQuery pageQuery, String alertCode);
 }
diff --git a/dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java b/dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java
index 31a12a1..67a90dd 100644
--- a/dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java
+++ b/dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java
@@ -26,10 +26,7 @@ import org.dromara.workflow.api.RemoteWorkflowService;
 import org.springframework.stereotype.Service;
 
 import java.lang.reflect.Method;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -109,7 +106,7 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
      * @param flowStatus
      */
     @Override
-    public void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType) {
+    public void updateAlertStatus(String businessId, String flowStatus,Boolean isIllegal,String alertType,String message,String assignName) {
         LambdaUpdateWrapper<BusinessAlert> wrapper = new LambdaUpdateWrapper<>();
         wrapper.set(BusinessAlert::getHandleType, BusinessStatusEnum.getByStatus(flowStatus).getStatus());
         if (ObjectUtil.isNotEmpty(isIllegal)){
@@ -118,6 +115,17 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
         if (ObjectUtil.isNotEmpty(alertType)){
             wrapper.set(BusinessAlert::getAlertType, alertType);
         }
+
+        if (ObjectUtil.isNotEmpty(message)){
+            wrapper.set(BusinessAlert::getReason, message);
+        }
+
+        //判断指派人员是否为空
+        if (ObjectUtil.isNotEmpty(assignName)){
+            wrapper.set(BusinessAlert::getAssignUserId, assignName);
+            wrapper.set(BusinessAlert::getAssignDate, new Date());
+        }
+
         wrapper.eq(BusinessAlert::getId, businessId);
 
         this.baseMapper.update(wrapper);
@@ -189,6 +197,45 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
         return TableDataInfo.build(page);
     }
 
+    /**
+     * 查询当前用户待办预警
+     * @param bo
+     * @param pageQuery
+     * @return
+     */
+    @Override
+    public TableDataInfo<BusinessAlert> pageAlertAssign(BusinessAlertBo bo, PageQuery pageQuery) {
+        QueryWrapper<BusinessAlert> wrapper = buildQueryWrapper(bo);
+
+//        if (ObjectUtil.isEmpty(wrapper)){
+//            return new TableDataInfo<>();
+//        }
+
+        buildCommonQueryWrapper(wrapper);
+
+        wrapper.eq("uu.del_flag", 0);
+        wrapper.in("uu.type", 1,2,3);
+
+        wrapper.in("uu.processed_by", remoteWorkflowService.getPermissions());
+        wrapper.eq("b.flow_status", BusinessStatusEnum.DRAFT.getStatus());
+
+        Page<BusinessAlert> page = this.baseMapper.pageAlertTodo(pageQuery.build(), wrapper);
+
+        List<BusinessAlert> records = page.getRecords();
+        if (CollUtil.isNotEmpty(records)) {
+            List<Long> taskIds = StreamUtils.toList(records, BusinessAlert::getFlowTaskId);
+            Map<Long, List<RemoteUserVo>> listMap = remoteWorkflowService.currentTaskAllUser(taskIds);
+            records.forEach(t -> {
+                List<RemoteUserVo> userList = listMap.getOrDefault(t.getId(), Collections.emptyList());
+                if (CollUtil.isNotEmpty(userList)) {
+                    t.setApprover(StreamUtils.join(userList, e -> String.valueOf(e.getUserId())));
+                    t.setApproveName(StreamUtils.join(userList, RemoteUserVo::getNickName));
+                }
+            });
+        }
+        return TableDataInfo.build(page);
+    }
+
 
     /**
      * 查询当前用户待办预警
diff --git a/dk-modules/business/src/main/resources/mapper/business/BusinessAlertMapper.xml b/dk-modules/business/src/main/resources/mapper/business/BusinessAlertMapper.xml
index 27b62d8..8a25577 100644
--- a/dk-modules/business/src/main/resources/mapper/business/BusinessAlertMapper.xml
+++ b/dk-modules/business/src/main/resources/mapper/business/BusinessAlertMapper.xml
@@ -73,6 +73,24 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             ${ew.getCustomSqlSegment}
     </select>
 
+    <select id="pageAlertAssign" resultType="org.dromara.business.domain.BusinessAlert">
+        select
+            ba.*,
+            b.flow_status,
+            b.business_id,
+            uu.processed_by approver,
+            a.id flowTaskId,
+            b.id instanceId,
+            fn.permissions
+        from dk_business.business_alert ba
+                 left join dk_workflow.flow_instance b on ba.id = b.business_id
+                 left join dk_workflow.flow_task a on a.instance_id = b.id
+                 left join dk_workflow.flow_user uu on uu.associated = a.id
+                 left join dk_workflow.flow_definition c on a.definition_id = c.id
+                 left join dk_workflow.flow_node fn on fn.node_code = b.node_code
+            ${ew.getCustomSqlSegment}
+    </select>
+
     <select id="listMonthAlert" resultType="java.util.Map">
         SELECT DATE_FORMAT(DATE_ADD(CURDATE(), INTERVAL -11 MONTH), '%Y-%m') AS dateMonth,count(1) total from business_alert ba
          where DATE_FORMAT(ba.create_time, '%Y-%m' ) = DATE_FORMAT(DATE_ADD(DATE_FORMAT(CURDATE(), '%Y-01-01'), INTERVAL 0 MONTH), '%Y-%m')
diff --git a/dk-modules/system/src/main/java/org/dromara/system/domain/SysDept.java b/dk-modules/system/src/main/java/org/dromara/system/domain/SysDept.java
index 50d5e7b..e1f6cb0 100644
--- a/dk-modules/system/src/main/java/org/dromara/system/domain/SysDept.java
+++ b/dk-modules/system/src/main/java/org/dromara/system/domain/SysDept.java
@@ -87,4 +87,9 @@ public class SysDept extends TenantEntity {
      */
     private String shpNo;
 
+    /**
+     * 是否需要指派
+     */
+    private Boolean assign;
+
 }
diff --git a/dk-modules/system/src/main/java/org/dromara/system/domain/bo/SysDeptBo.java b/dk-modules/system/src/main/java/org/dromara/system/domain/bo/SysDeptBo.java
index 7ec0687..bdec777 100644
--- a/dk-modules/system/src/main/java/org/dromara/system/domain/bo/SysDeptBo.java
+++ b/dk-modules/system/src/main/java/org/dromara/system/domain/bo/SysDeptBo.java
@@ -78,4 +78,9 @@ public class SysDeptBo extends BaseEntity {
      */
     private String shpNo;
 
+    /**
+     * 是否指派
+     */
+    private Boolean assign;
+
 }
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/domain/bo/CompleteTaskBo.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/domain/bo/CompleteTaskBo.java
index 53cbf24..8b17915 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/domain/bo/CompleteTaskBo.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/domain/bo/CompleteTaskBo.java
@@ -79,6 +79,21 @@ public class CompleteTaskBo implements Serializable {
      */
     private String alertTypeContent;
 
+    /**
+     * 网关判断(是否需要介入)
+     */
+    private Boolean flag = true;
+
+    /**
+     * 动态负责人
+     */
+    private String handler;
+
+    /**
+     * 是否需要指派
+     */
+    private Boolean assign = true;
+
     public Map<String, Object> getVariables() {
         if (variables == null) {
             return new HashMap<>(16);
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
index d17dde1..d7f8ae9 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
@@ -1,5 +1,6 @@
 package org.dromara.workflow.handler;
 
+import cn.hutool.core.util.ObjectUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.dromara.business.api.RemoteBusinessAlertService;
@@ -12,6 +13,8 @@ import org.dromara.workflow.common.handler.FlwCommonHandler;
 import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 /**
  * 流程预警扩展业务
  */
@@ -31,7 +34,16 @@ public class FlwAlertHandler implements FlwCommonHandler {
     @EventListener(condition = "#processEvent.flowCode.startsWith('alert')")
     @Override
     public void processHandler(ProcessEvent processEvent) {
-        alertService.updateAlertStatus(processEvent.getBusinessId(),processEvent.getStatus(),processEvent.getIsIllegal(),processEvent.getAlertType());
+        String message = null;
+        String assignName = null;
+        if (ObjectUtil.isNotEmpty(processEvent.getParams())){
+            message = ObjectUtil.isNotEmpty(processEvent.getParams().get("message"))?(String)processEvent.getParams().get("message"):null;
+            if ((Boolean) processEvent.getParams().get("assign")) {
+                assignName = ObjectUtil.isNotEmpty(processEvent.getParams().get("handler"))?(String)processEvent.getParams().get("handler"):null;
+            }
+        }
+
+        alertService.updateAlertStatus(processEvent.getBusinessId(),processEvent.getStatus(),processEvent.getIsIllegal(),processEvent.getAlertType(),message,assignName);
     }
 
     /**
@@ -43,7 +55,7 @@ public class FlwAlertHandler implements FlwCommonHandler {
     @EventListener(condition = "#processCreateTaskEvent.flowCode.startsWith('alert')")
     @Override
     public void processCreateTaskHandler(ProcessCreateTaskEvent processCreateTaskEvent) {
-        alertService.updateAlertStatus(processCreateTaskEvent.getBusinessId(), BusinessStatusEnum.WAITING.getStatus(),processCreateTaskEvent.getIsIllegal(),processCreateTaskEvent.getAlertType());
+        alertService.updateAlertStatus(processCreateTaskEvent.getBusinessId(), BusinessStatusEnum.WAITING.getStatus(),processCreateTaskEvent.getIsIllegal(),processCreateTaskEvent.getAlertType(),null,null);
     }
 
     /**
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/WorkflowPermissionHandler.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/WorkflowPermissionHandler.java
index fcda1f0..9fbe450 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/WorkflowPermissionHandler.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/WorkflowPermissionHandler.java
@@ -41,7 +41,7 @@ public class WorkflowPermissionHandler implements PermissionHandler {
             return new ArrayList<>();
         }
         // 使用一个流来构建权限列表
-        return Stream.of(
+        List<String> permissionList = Stream.of(
                 // 角色权限前缀
                 loginUser.getRoles().stream()
                     .map(role -> TaskAssigneeEnum.ROLE.getCode() + role.getRoleId()),
@@ -58,6 +58,9 @@ public class WorkflowPermissionHandler implements PermissionHandler {
             )
             .flatMap(stream -> stream)
             .collect(Collectors.toList());
+
+        permissionList.add("${handler}");
+        return permissionList;
     }
 
     /**
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwTaskServiceImpl.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwTaskServiceImpl.java
index 3210338..8312daf 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwTaskServiceImpl.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwTaskServiceImpl.java
@@ -13,6 +13,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
+import org.dromara.business.api.RemoteBusinessAlertService;
 import org.dromara.common.core.enums.BusinessStatusEnum;
 import org.dromara.common.core.exception.ServiceException;
 import org.dromara.common.core.utils.SpringUtils;
@@ -96,6 +97,9 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
     @Autowired
     private ApplicationContext applicationContext;
 
+    @Autowired
+    private RemoteBusinessAlertService remoteBusinessAlertService;
+
     /**
      * 启动任务
      *
@@ -127,6 +131,8 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
         FlowParams flowParams = new FlowParams();
         flowParams.flowCode(startProcessBo.getFlowCode());
         flowParams.variable(startProcessBo.getVariables());
+
+
         flowParams.flowStatus(BusinessStatusEnum.DRAFT.getStatus());
         Instance instance;
         try {
@@ -143,8 +149,7 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
         dto.setProcessInstanceId(instance.getId());
         dto.setTaskId(taskList.get(0).getId());
 
-        //创建任务
-        executeTask(taskList.get(0).getId());
+        remoteBusinessAlertService.updateAlertStatus(startProcessBo.getBusinessId(),flowParams.getFlowStatus(),null,null,null,null);
         return dto;
     }
 
@@ -176,6 +181,11 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
             }
             // 构建流程参数，包括变量、跳转类型、消息、处理人、权限等信息
             FlowParams flowParams = new FlowParams();
+            // 流程变量
+            completeTaskBo.getVariables().put("flag",completeTaskBo.getFlag());
+            completeTaskBo.getVariables().put("assign",completeTaskBo.getAssign());
+            completeTaskBo.getVariables().put("handler", completeTaskBo.getHandler());
+
             flowParams.variable(completeTaskBo.getVariables());
             flowParams.skipType(SkipType.PASS.getKey());
             flowParams.message(completeTaskBo.getMessage());