Merge branch 'master' of http://106.13.50.125:13000/yuanqiang/dk_cloud_drone

# Conflicts:
#	dk-modules/sample/pom.xml

dk-api/api-workflow/src/main/java/org/dromara/workflow/api/RemoteWorkflowService.java

@@ -1,15 +1,13 @@
 package org.dromara.workflow.api;
 
 import org.dromara.system.api.domain.vo.RemoteUserVo;
-import org.dromara.workflow.api.domain.FlowDepartVo;
+import org.dromara.workflow.api.domain.FlowLabelVo;
 import org.dromara.workflow.api.domain.RemoteCompleteTask;
 import org.dromara.workflow.api.domain.RemoteStartProcess;
 import org.dromara.workflow.api.domain.RemoteStartProcessReturn;
 
-import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.CompletableFuture;
 
 /**
  * 通用 工作流服务
@@ -128,6 +126,6 @@ public interface RemoteWorkflowService {
      */
     List<RemoteUserVo> currentTaskAllUser(Long taskId);
 
-    FlowDepartVo getFlowDepart(Long deptId);
+    FlowLabelVo getFlowLabel(String labelId);
 
 }

dk-api/api-workflow/src/main/java/org/dromara/workflow/api/domain/FlowDepartVo.java → dk-api/api-workflow/src/main/java/org/dromara/workflow/api/domain/FlowLabelVo.java

@@ -3,7 +3,7 @@ package org.dromara.workflow.api.domain;
 import lombok.Data;
 
 @Data
-public class FlowDepartVo {
+public class FlowLabelVo {
 
 
     private Long id;

dk-modules/business/src/main/java/org/dromara/business/controller/BusinessAlertStatisticsController.java

@@ -34,11 +34,11 @@ public class BusinessAlertStatisticsController extends BaseController {
 
     @Operation(summary="panel看板数据", description="panel看板数据")
     @GetMapping(value = "/panel/count")
-    public R<List<StatObj>> countPanelAlert(BusinessAlertBo businessAlertBo) {
+    public R<StatObj> countPanelAlert(BusinessAlertBo businessAlertBo) {
         return R.ok(statisticsService.countPanelAlert(businessAlertBo));
     }
 
-    /**
+    /**`
      * 总体情况看板
      * @param businessAlertBo
      * @return
@@ -68,7 +68,7 @@ public class BusinessAlertStatisticsController extends BaseController {
      */
     @Operation(summary="各局今日预警数", description="各局今日预警数")
     @GetMapping(value = "/post/day/count")
-    public R<Map<String,Object>> countPostDayAlert(BusinessAlertBo businessAlertBo) {
+    public R<List<StatObj>> countPostDayAlert(BusinessAlertBo businessAlertBo) {
         return R.ok(statisticsService.countPostDayAlert(businessAlertBo));
     }
 

dk-modules/business/src/main/java/org/dromara/business/domain/BusinessAlert.java

@@ -65,12 +65,12 @@ public class BusinessAlert extends BaseEntity {
     /**
      * 纬度
      */
-    private Long lat;
+    private String lat;
 
     /**
      * 精度
      */
-    private Long lng;
+    private String lng;
 
     /**
      * 标签名-中

dk-modules/business/src/main/java/org/dromara/business/domain/bo/BusinessAlertBo.java

@@ -42,16 +42,6 @@ public class BusinessAlertBo {
     private String images;
 
 
-    /**
-     * 纬度
-     */
-    private Long lat;
-
-    /**
-     * 精度
-     */
-    private Long lng;
-
     /**
      * 预警类型
      */
@@ -245,4 +235,8 @@ public class BusinessAlertBo {
      */
     private Integer dateType;
 
+    private String startTime;
+
+    private String endTime;
+
 }

dk-modules/business/src/main/java/org/dromara/business/domain/model/StatObj.java

@@ -38,16 +38,47 @@ public class StatObj implements Serializable {
      */
     private String url;
 
+    private Object todoCount;
+
+    private Object totalCount;
+
+    private Object finishCount;
+
+    private Object cancelCount;
+
+    private Object flyCount;
+
+    private Object flyAccTime;
+
+    private List<Object> data;
+
+    private List<String> date;
+
 
     public StatObj(){
 
     }
 
+    public StatObj(Object todoCount, Object totalCount, Object finishCount, Object cancelCount, Object flyCount, Object flyAccTime) {
+        this.todoCount = todoCount;
+        this.totalCount = totalCount;
+        this.finishCount = finishCount;
+        this.cancelCount = cancelCount;
+        this.flyCount = flyCount;
+        this.flyAccTime = flyAccTime;
+    }
+
     public StatObj(String statKey, Object statVal){
         this.statKey = statKey;
         this.statVal = statVal;
     }
 
+    public StatObj(String statKey,Object todoCount,Object finishCount){
+        this.statKey = statKey;
+        this.todoCount =todoCount;
+        this.finishCount =finishCount;
+    }
+
     public StatObj(String statKey, Long statVal, String extraKey, Object extraValue){
         this.statKey = statKey;
         this.statVal = statVal;

dk-modules/business/src/main/java/org/dromara/business/domain/vo/BusinessAlertVo.java

@@ -67,12 +67,12 @@ public class BusinessAlertVo implements Serializable {
     /**
      * 纬度
      */
-    private Long lat;
+    private String lat;
 
     /**
      * 精度
      */
-    private Long lng;
+    private String lng;
 
     /**
      * 标签名-中

dk-modules/business/src/main/java/org/dromara/business/mapper/BusinessAlertMapper.java

@@ -64,7 +64,7 @@ public interface BusinessAlertMapper extends BaseMapperPlus<BusinessAlert, Busin
     List<Map<String, Object>> countAlertCompare(@Param("param")BusinessAlertBo businessAlertBo);
 
 
-    List<Map<String, Object>> countPanelAlert(@Param("param")BusinessAlertBo businessAlertBo);
+    Map<String, Object> countPanelAlert(@Param("param")BusinessAlertBo businessAlertBo);
 
 
     List<Map<String, Object>> countAlertTypeCompare(@Param("param") BusinessAlertBo businessAlertBo);
@@ -77,7 +77,7 @@ public interface BusinessAlertMapper extends BaseMapperPlus<BusinessAlert, Busin
 
     Map<String, Object> countCurrentDayAlert(@Param("param") BusinessAlertBo businessAlertBo);
 
-    Map<String, Object> handlerRate(@Param("param") BusinessAlertBo businessAlertBo,@Param("month") String month);
+    List<Map<String, Object>> handlerRate(@Param("param") BusinessAlertBo businessAlertBo,@Param("months") List<String>  months);
 
     Map<String, Object> countPastYearAlert(@Param("param") BusinessAlertBo businessAlertBo,@Param("startTime") String startTime,@Param("endTime") String endTime);
 

dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertStatisticsService.java

@@ -18,15 +18,15 @@ public interface IBusinessAlertStatisticsService {
 
     List<Map<String, Object>> countAlertStatusCompare(BusinessAlertBo businessAlertBo);
 
-    List<StatObj> countPanelAlert(BusinessAlertBo businessAlertBo);
+    StatObj countPanelAlert(BusinessAlertBo businessAlertBo);
 
     List<Map<String, Object>> countAlertTypeCompare(BusinessAlertBo businessAlertBo);
 
     Map<String,Object> countPanelTotalAlert(BusinessAlertBo businessAlertBo);
 
-    Map<String, Object> countCurrentDayAlert(BusinessAlertBo businessAlertBo);
+    Map<String,Object> countCurrentDayAlert(BusinessAlertBo businessAlertBo);
 
-    Map<String,Object> countPostDayAlert(BusinessAlertBo businessAlertBo);
+    List<StatObj> countPostDayAlert(BusinessAlertBo businessAlertBo);
 
     List<StatObj> countPostAlert(BusinessAlertBo businessAlertBo);
 

dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java

@@ -170,14 +170,14 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
      */
     @Override
     public TableDataInfo<BusinessAlert> pageBusinessAlertCancel(BusinessAlertBo bo, PageQuery pageQuery) {
-        bo.setHandleType(BusinessStatusEnum.INVALID.getStatus());
+        bo.setHandleType(BusinessStatusEnum.CANCEL.getStatus());
         QueryWrapper<BusinessAlert> wrapper = buildQueryWrapper(bo);
 
         if (ObjectUtil.isEmpty(wrapper)){
             return new TableDataInfo<>();
         }
 
-        wrapper.in("t.flowStatus", BusinessStatusEnum.INVALID.getStatus());
+        wrapper.in("t.flowStatus", BusinessStatusEnum.CANCEL.getStatus());
 
         Page<BusinessAlert> page = this.baseMapper.pageBusinessAlertCancel(pageQuery.build(), wrapper);
 
@@ -199,7 +199,7 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
             return new TableDataInfo<>();
         }
 
-        wrapper.notIn("t.flowStatus", BusinessStatusEnum.INVALID.getStatus());
+        wrapper.notIn("t.flowStatus", BusinessStatusEnum.CANCEL.getStatus());
 
         wrapper.apply(" EXISTS(select * from dk_workflow.flow_his_task ht where ht.approver ='" + LoginHelper.getUserId() + "' and ht.instance_id = t.instanceId)");
 
@@ -279,8 +279,9 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
             wrapper.like("t.job_name", bo.getJobName());
         }
 
-        if (ObjectUtil.isNotEmpty(bo.getCreateTime())){
-            wrapper.eq("DATE_FORMAT(t.create_time, '%Y-%m-%d')", bo.getCreateTime());
+        if (ObjectUtil.isNotEmpty(bo.getStartTime()) && ObjectUtil.isNotEmpty(bo.getEndTime())){
+            wrapper.ge("DATE_FORMAT(t.create_time, '%Y-%m-%d')", bo.getStartTime());
+            wrapper.le("DATE_FORMAT(t.create_time, '%Y-%m-%d')", bo.getEndTime());
         }
 
         wrapper.orderByDesc("t.create_time","t.complete_date");
@@ -341,6 +342,8 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
         List<RemoteAiLabelPostVo> postVoList = remoteLablePostService.selectLabelByList(businessAlertBo.getPostCode(), LoginHelper.getDeptId());
 
         postVoList.forEach(postVo -> {
+            Map<String,Object> labelResult =  new HashMap<>();
+
             Map<String,Object> result =  new HashMap<>();
 
             businessAlertBo.setAiLabelEnList(List.of(postVo.getLabelEn()));
@@ -350,9 +353,9 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
             List<BusinessAlert> alertList = this.baseMapper.listAlert(businessAlertBo, startTime, endTime);
 
             handlerMap.put("total",alertList.size());
-            handlerMap.put("finishCount",alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.FINISH.getStatus())).count());
-            handlerMap.put("todoCount",alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.WAITING.getStatus())).count());
-            handlerMap.put("cancelCount",alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.INVALID.getStatus())).count());
+            handlerMap.put("finishCount",ObjectUtil.isEmpty(alertList)?0:alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.FINISH.getStatus())).count());
+            handlerMap.put("todoCount",ObjectUtil.isEmpty(alertList)?0:alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.WAITING.getStatus())).count());
+            handlerMap.put("cancelCount",ObjectUtil.isEmpty(alertList)?0:alertList.stream().filter(p-> p.getHandleType().equalsIgnoreCase(BusinessStatusEnum.CANCEL.getStatus())).count());
 
             result.put("panel",handlerMap);
 
@@ -360,7 +363,9 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
 
             result.put("date", startTime + "~" + endTime);
 
-            resultList.add(result);
+            labelResult.put(postVo.getLabelCn(),result);
+
+            resultList.add(labelResult);
         });
 
 

dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertStatisticsServiceImpl.java

@@ -25,6 +25,7 @@ import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.TemporalAdjusters;
 import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -105,6 +106,7 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
     @Override
     public List<StatObj> countDepartAlertStatus(BusinessAlertBo businessAlertBo) {
+        businessAlertBo.setDeptId(String.valueOf(LoginHelper.getDeptId()));
         businessAlertBo.setAiLabelEnList(getAiLabel(businessAlertBo.getPostCode()).stream().map(RemoteAiLabelPostVo::getLabelEn).collect(Collectors.toList()));
 
         List<Map<String, Object>> mapList =  baseMapper.listDepartAlertStatus(businessAlertBo);
@@ -136,19 +138,12 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
     }
 
     @Override
-    public List<StatObj> countPanelAlert(BusinessAlertBo businessAlertBo) {
+    public StatObj countPanelAlert(BusinessAlertBo businessAlertBo) {
         LocalDate today = LocalDate.now();
 
         if (ObjectUtil.isNotEmpty(businessAlertBo.getPostCode())){
             if (ObjectUtil.isEmpty(getAiLabel(businessAlertBo.getPostCode()))){
-                return Stream.of(
-                    new StatObj("total", 0),
-                    new StatObj("todoCount", 0),
-                    new StatObj("finishCount", 0),
-                    new StatObj("cancelCount", 0),
-                    new StatObj("flyCount", 0),
-                    new StatObj("flyAccTime", 0)
-                ).toList();
+                return new StatObj(0, 0,0,0,0,0);
             }
 
             businessAlertBo.setCreateTime(today.getYear()+"-"+today.getMonthValue()+"-"+today.getDayOfMonth());
@@ -194,18 +189,15 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
         //----------------------------------------------获取飞行总架次、总时长----------------------------------------------
 
-        List<Map<String, Object>> mapList = baseMapper.countPanelAlert(businessAlertBo);
+        Map<String, Object> panel = baseMapper.countPanelAlert(businessAlertBo);
 
-        return mapList.stream()
-            .flatMap(map -> Stream.of(
-                new StatObj("total", map.get("total")),
-                new StatObj("todoCount", map.get("todoCount")),
-                new StatObj("finishCount", map.get("finishCount")),
-                new StatObj("cancelCount", map.get("cancelCount")),
-                new StatObj("flyCount", flyCount),
-                new StatObj("flyAccTime", flyAccTime)
-            ))
-            .collect(Collectors.toList());
+        return new StatObj(
+            ObjectUtil.isEmpty(panel.get("todoCount"))?0:panel.get("todoCount"),
+            ObjectUtil.isEmpty(panel.get("total"))?0:panel.get("total"),
+            ObjectUtil.isEmpty(panel.get("finishCount"))?0:panel.get("finishCount"),
+            ObjectUtil.isEmpty(panel.get("cancelCount"))?0:panel.get("cancelCount"),
+            flyCount,
+            flyAccTime);
     }
 
     @Override
@@ -316,20 +308,23 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
      * @return
      */
     @Override
-    public Map<String, Object> countPostDayAlert(BusinessAlertBo businessAlertBo) {
-       Map<String,Object> result =  new HashMap<>();
+    public List<StatObj> countPostDayAlert(BusinessAlertBo businessAlertBo) {
+        List<StatObj> result =  new ArrayList<>();
         //查询所有的职能岗位
         List<RemotePostVo> postVoList = remotePostService.listPost();
 
         if (ObjectUtil.isEmpty(postVoList)) {
-            return Map.of();
+            return ListUtil.empty();
         }
 
+        AtomicInteger number = new AtomicInteger(1);
+
         postVoList.forEach(postVo -> {
             List<String> labelList = getAiLabel(postVo.getPostCode()).stream().map(RemoteAiLabelPostVo::getLabelEn).collect(Collectors.toList());
             businessAlertBo.setAiLabelEnList(labelList);
             Map<String, Object> dayMap = this.baseMapper.countCurrentDayAlert(businessAlertBo);
-            result.put(postVo.getPostName(), dayMap.get("total"));
+            number.getAndIncrement();
+            result.add(new StatObj(postVo.getPostName(), ObjectUtil.isEmpty(dayMap.get("total"))? number.get() + 1:dayMap.get("total")));
         });
 
         return result;
@@ -364,7 +359,11 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
             endTime = dateMap.get("endTime");
         }
 
+        AtomicInteger number = new AtomicInteger(1);
+
         postVoList.forEach(postVo -> {
+            number.getAndIncrement();
+
             List<String> labelList = getAiLabel(postVo.getPostCode()).stream().map(RemoteAiLabelPostVo::getLabelEn).collect(Collectors.toList());
             Map<String, Object> dateMap = new HashMap<>();
             if (ObjectUtil.isEmpty(labelList)) {
@@ -377,10 +376,8 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
             result.add(new StatObj(
                 postVo.getPostName(),
-                List.of(
-                    new StatObj("todoCount", dateMap.get("todoCount")),
-                    new StatObj("finishCount", dateMap.get("finishCount"))
-                )
+                ObjectUtil.isEmpty(dateMap.get("todoCount"))?number.get() + 1:dateMap.get("todoCount"),
+                ObjectUtil.isEmpty(dateMap.get("finishCount"))?number.get() + 2:dateMap.get("finishCount")
             ));
         });
 
@@ -401,32 +398,47 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
         List<StatObj> result =  new ArrayList<>();
 
-        monthList.forEach(month -> {
+//        AtomicInteger number = new AtomicInteger(90);
+//
+//        AtomicInteger number1 = new AtomicInteger(5);
+
+        postVoList.forEach(postVo -> {
+//            number.getAndIncrement();
             StatObj statObj = new StatObj();
-            statObj.setStatKey(month);
-            List<StatObj> statObjs =  new ArrayList<>();
-            postVoList.forEach(postVo -> {
-                List<String> labelList = getAiLabel(postVo.getPostCode()).stream().map(RemoteAiLabelPostVo::getLabelEn).collect(Collectors.toList());
-                StatObj statObj1 = new StatObj();
-                statObj1.setStatKey(postVo.getPostName());
-                if (ObjectUtil.isEmpty(labelList)){
-                    statObj1.setStatVal(0);
+            statObj.setStatKey(postVo.getPostName());
+
+            statObj.setDate(monthList);
+
+            List<Object> data = new ArrayList<>();
+
+            List<String> labelList = getAiLabel(postVo.getPostCode()).stream().map(RemoteAiLabelPostVo::getLabelEn).collect(Collectors.toList());
+
+            if (ObjectUtil.isEmpty(labelList)){
+                monthList.forEach(month -> {
+                    data.add(0.0);
+                });
+            }else {
+                businessAlertBo.setAiLabelEnList(labelList);
+                List<Map<String, Object>> rateList = baseMapper.handlerRate(businessAlertBo,monthList);
+                if (ObjectUtil.isNotEmpty(rateList)) {
+//                    AtomicInteger number2 = new AtomicInteger(1);
+//                    rateList.forEach(rate -> {
+//                        number2.getAndIncrement();
+//                       rate.put("avgInfo",number.get() + number1.get() + number2.get());
+//                    });
+
+                    data.addAll(rateList.stream().map(p-> p.get("avgInfo")).toList());
                 }else {
-                    businessAlertBo.setAiLabelEnList(labelList);
-                    Map<String,Object> rateMap = baseMapper.handlerRate(businessAlertBo,month);
-                    if (ObjectUtil.isNotEmpty(rateMap)) {
-                        statObj1.setStatVal(rateMap.get("avgInfo"));
-                    }else {
-                        statObj1.setStatVal(0);
-                    }
+                    monthList.forEach(month -> {
+                        data.add(0.0);
+                    });
                 }
+            }
 
-                statObjs.add(statObj1);
-            });
-            statObj.setNextStatList(statObjs);
-
+            statObj.setData(data);
             result.add(statObj);
         });
+
         return result;
     }
 
@@ -468,8 +480,14 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
         List<Map<String,Object>> labelMapList = this.baseMapper.countAiLabel(businessAlertBo,startTime,endTime);
 
+        List<StatObj> labelStatObj = new ArrayList<>();
+
+        labelMapList.forEach(labelMap -> {
+            labelStatObj.add(new StatObj(labelMap.get("labelCn").toString(),labelMap.get("total")));
+        });
+
         //识别类型存储
-        result.put("label", labelMapList);
+        result.put("label", labelStatObj);
 
         //-------------------------------------------------------街道事件高发区Top5--------------------------------------------
         //事件高发区
@@ -480,21 +498,40 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
         List<Map<String,Object>> top5Map = this.baseMapper.countStreetAlert(businessAlertBo,startTime,endTime,deptIdList);
 
+        List<StatObj> top5StatObj = new ArrayList<>();
+
+        top5Map.forEach(map -> {
+            top5StatObj.add(new StatObj(map.get("deptName").toString(),map.get("total")));
+        });
+
         //街道事件高发区前5个
-        result.put("incidentTop5", top5Map);
+        result.put("incidentTop5", top5StatObj);
 
         //-------------------------------------------------------街道处理效率Top5--------------------------------------------
 
         List<Map<String,Object>> streetRateTop5Map = this.baseMapper.countStreetRateAlert(businessAlertBo,startTime,endTime,deptIdList);
 
+        List<StatObj> streetRateTop5StatObj = new ArrayList<>();
+
+        streetRateTop5Map.forEach(map -> {
+            streetRateTop5StatObj.add(new StatObj(map.get("deptName").toString(),map.get("avgInfo")));
+        });
+
+
         //街道处理效率top5
-        result.put("incidentHandlerTop5", streetRateTop5Map);
+        result.put("incidentHandlerTop5", streetRateTop5StatObj);
 
         //-------------------------------------------------------识别类型事件处理情况--------------------------------------------
         //识别类型事件处理情况
         List<Map<String,Object>> labelRateMap = this.baseMapper.countLabelRateAlert(businessAlertBo,startTime,endTime);
-        result.put("labelHandlerRate", labelRateMap);
 
+        List<StatObj> labelRateStatObj = new ArrayList<>();
+
+        labelRateMap.forEach(map -> {
+            labelRateStatObj.add(new StatObj(map.get("labelCn").toString(),map.get("avgInfo")));
+        });
+
+        result.put("labelHandlerRate", labelRateStatObj);
 
         return result;
     }
@@ -595,7 +632,13 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
 
             List<Map<String,Object>> labelMapList = this.baseMapper.countAiLabel(businessAlertBo,startTime,endTime);
 
-            keyMap.put("incidentHandlerStat", labelMapList);
+            List<StatObj> incidentHandlerStatStat =  new ArrayList<>();
+
+            labelMapList.forEach(map -> {
+                incidentHandlerStatStat.add(new StatObj(map.get("labelCn").toString(),map.get("total")));
+            });
+
+            keyMap.put("incidentHandlerStat", incidentHandlerStatStat);
 
 
             //-------------------------------------------------------事件高发区--------------------------------------------
@@ -629,7 +672,7 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
         LocalDate currentDate = LocalDate.now();
         DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
 
-        for (int i = 0; i < 6; i++) {
+        for (int i = 5; i >=0 ; i--) {
             LocalDate date = currentDate.minusMonths(i);
             months.add(date.format(formatter));
         }
@@ -637,6 +680,7 @@ public class BusinessAlertStatisticsServiceImpl implements IBusinessAlertStatist
         return months;
     }
 
+
     private List<String> buildDateList(BusinessAlertBo businessAlertBo) {
        List<String> resultList =  new ArrayList<>();
         String currentYear = String.valueOf(Calendar.getInstance().get(Calendar.YEAR));

dk-modules/business/src/main/resources/mapper/business/BusinessAlertMapper.xml

@@ -149,33 +149,34 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </if>
     </where>
         ),
-        sub_depts AS ( SELECT
-        sda.dept_id,
-        sda.parent_id,
-        sda.tenant_id
-        FROM
-        dk_cloud.sys_dept sda
-        WHERE
-        sda.parent_id IN (SELECT dd.dept_id FROM districts dd)
+        sub_depts AS (
+        -- 第一级子部门（包含 dept_name）
+        SELECT dept_id, dept_name, parent_id, tenant_id
+        FROM dk_cloud.sys_dept
+        <where>
+            <if test="param.deptId != null and param.deptId != ''">
+                parent_id = #{param.deptId}
+            </if>
+            <if test="param.deptId == null or param.deptId == ''">
+                parent_id in (select dsd.dept_id from dk_cloud.sys_dept dsd where dsd.parent_id = '0')
+            </if>
+        </where>
         UNION ALL
-        SELECT
-        d.dept_id,
-        d.parent_id,
-        d.tenant_id
-        FROM
-        dk_cloud.sys_dept d
+        -- 递归查询下级部门（同样包含 dept_name）
+        SELECT d.dept_id, d.dept_name, d.parent_id, d.tenant_id
+        FROM dk_cloud.sys_dept d
         INNER JOIN sub_depts st ON d.parent_id = st.dept_id
-                       ),
+        ),
                        warning_summary AS (
                            SELECT
-                               d.parent_id AS district_id,
+                               d.dept_id AS district_id,
                                COUNT( ba.id ) AS total_warnings
                            FROM
                                business_alert ba
                                INNER JOIN sub_depts d ON ba.dept_id = d.dept_id
                            <include refid="searchSql"></include>
                            GROUP BY
-                               d.parent_id
+                               d.dept_id
                        )
         SELECT
             d.dept_id deptId,
@@ -199,7 +200,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         IFNULL(COUNT(ba.id), 0) AS total,
         IFNULL(SUM(ba.handle_type = 'waiting'), 0) AS todoCount,
         IFNULL(SUM(ba.handle_type = 'finish'), 0) AS finishCount,
-        IFNULL(SUM( ba.handle_type = 'invalid' ),0) AS cancelCount
+        IFNULL(SUM( ba.handle_type = 'cancel' ),0) AS cancelCount
         FROM months m
         LEFT JOIN business_alert ba
         ON DATE_FORMAT(ba.create_time, '%Y-%m') = DATE_FORMAT(m.dateMonth, '%Y-%m')
@@ -220,37 +221,37 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </where>
         ),
         sub_depts AS (
-        SELECT
-        sda.dept_id,
-        sda.parent_id,
-        sda.tenant_id
-        FROM
-        dk_cloud.sys_dept sda
-        WHERE
-        sda.parent_id IN (SELECT dd.dept_id FROM districts dd)
+        -- 第一级子部门（包含 dept_name）
+        SELECT dept_id, dept_name, parent_id, tenant_id
+        FROM dk_cloud.sys_dept
+        <where>
+            <if test="param.deptId != null and param.deptId != ''">
+                parent_id = #{param.deptId}
+            </if>
+            <if test="param.deptId == null or param.deptId == ''">
+                parent_id in (select dsd.dept_id from dk_cloud.sys_dept dsd where dsd.parent_id = '0')
+            </if>
+        </where>
         UNION ALL
-        SELECT
-        d.dept_id,
-        d.parent_id,
-        d.tenant_id
-        FROM
-        dk_cloud.sys_dept d
+        -- 递归查询下级部门（同样包含 dept_name）
+        SELECT d.dept_id, d.dept_name, d.parent_id, d.tenant_id
+        FROM dk_cloud.sys_dept d
         INNER JOIN sub_depts st ON d.parent_id = st.dept_id
         ),
         warning_summary AS (
         SELECT
-        d.parent_id AS district_id,
+        d.dept_id AS district_id,
         COUNT(ba.id) AS total_warnings,
         IFNULL(SUM(handle_type = 'waiting'), 0) AS todoCount,
         IFNULL(SUM(handle_type = 'finish'), 0) AS finishCount,
-        IFNULL(SUM(ba.handle_type = 'invalid'), 0) AS cancelCount
+        IFNULL(SUM(ba.handle_type = 'cancel'), 0) AS cancelCount
         FROM
         business_alert ba
         INNER JOIN sub_depts d ON ba.dept_id = d.dept_id
         AND ba.handle_type != 'verify'
         <include refid="searchSql"></include>
         GROUP BY
-        d.parent_id
+        d.dept_id
         )
         SELECT
         d.dept_id deptId,
@@ -310,7 +311,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         COUNT(DISTINCT ba.id) AS total,
         IFNULL(SUM( ba.handle_type = 'waiting' ),0) AS todoCount,
         IFNULL(SUM( ba.handle_type = 'finish' ),0) AS finishCount,
-        IFNULL(SUM( ba.handle_type = 'invalid' ),0) AS cancelCount
+        IFNULL(SUM( ba.handle_type = 'cancel' ),0) AS cancelCount
         FROM month_department md
         LEFT JOIN business_alert ba
         ON md.dept_id = ba.dept_id
@@ -324,7 +325,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         select   COUNT(DISTINCT ba.id) AS total,
                  IFNULL(SUM( ba.handle_type = 'waiting' ),0) AS todoCount,
                  IFNULL(SUM( ba.handle_type = 'finish' ),0) AS finishCount,
-                 IFNULL(SUM( ba.handle_type = 'invalid' ),0) AS cancelCount
+                 IFNULL(SUM( ba.handle_type = 'cancel' ),0) AS cancelCount
         from business_alert ba
         where 1=1
         <include refid="searchSql"></include>
@@ -428,13 +429,24 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </select>
 
     <select id="handlerRate" resultType="java.util.Map">
-        select
-        ROUND(SUM(TIMESTAMPDIFF(HOUR, ba.create_time, ba.complete_date))  / COUNT(*)) AS avgInfo
-        from business_alert ba
-        where 1=1
-        and  <![CDATA[ DATE_FORMAT(ba.create_time, '%Y-%m') = #{month} ]]>
-        and ba.handle_type = 'finish'
-        <include refid="searchSql"></include>
+        WITH months AS (
+        <foreach collection="months" item="month" separator=" UNION ALL ">
+            SELECT #{month} AS month_value
+        </foreach>
+        )
+        SELECT
+        ml.month_value AS monthDate,
+        COALESCE(
+        ROUND(SUM(TIMESTAMPDIFF(HOUR, ba.create_time, ba.complete_date)) / COUNT(ba.id)),
+        0
+        ) AS avgInfo
+        FROM months ml
+        LEFT JOIN business_alert ba ON
+        DATE_FORMAT(ba.create_time, '%Y-%m') = ml.month_value
+        AND ba.handle_type = 'finish'
+        <include refid="searchSql"/>
+        GROUP BY ml.month_value
+        ORDER BY ml.month_value
     </select>
 
     <select id="countPastYearAlert" resultType="java.util.Map">
@@ -509,8 +521,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="listAlert" resultType="org.dromara.business.domain.BusinessAlert">
         select
             ba.label_en labelEn,
+            ba.images images,
             ba.label_cn labelCn,
             ba.create_time createTime,
+            ba.handle_type handleType,
+            ba.lat,
+            ba.lng,
             b.flow_status flowStatus,
             b.business_id businessId,
             b.id instanceId

dk-modules/system/src/main/java/org/dromara/system/controller/system/AiLabelController.java

@@ -43,10 +43,10 @@ public class AiLabelController extends BaseController {
     @SaCheckPermission("system:label:list")
     @GetMapping("/list")
     public TableDataInfo<AiLabelVo> list(AiLabelBo bo, PageQuery pageQuery) {
-        pageQuery.setPageSize(30);
         return aiLabelService.queryPageList(bo, pageQuery);
     }
 
+
     /**
      * 下拉框集合
      */

dk-modules/workflow/src/main/java/org/dromara/workflow/controller/FlwDepartController.java → dk-modules/workflow/src/main/java/org/dromara/workflow/controller/FlwLabelController.java

@@ -7,8 +7,8 @@ import lombok.RequiredArgsConstructor;
 import org.dromara.common.core.domain.R;
 import org.dromara.common.core.validate.AddGroup;
 import org.dromara.workflow.common.ConditionalOnEnable;
-import org.dromara.workflow.domain.FlowDepart;
-import org.dromara.workflow.service.FlwDepartService;
+import org.dromara.workflow.domain.FlowLabel;
+import org.dromara.workflow.service.FlwLabelService;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -17,11 +17,11 @@ import org.springframework.web.bind.annotation.*;
 @Validated
 @RequiredArgsConstructor
 @RestController
-@RequestMapping("/depart")
-public class FlwDepartController {
+@RequestMapping("/flow/label")
+public class FlwLabelController {
 
 
-    private final FlwDepartService flwDepartService;
+    private final FlwLabelService flwDepartService;
 
     /**
      * 查询流程部门关系
@@ -29,7 +29,7 @@ public class FlwDepartController {
      */
     @Operation(summary = "查询流程部门关系",description = "查询流程部门关系")
     @GetMapping("/{flowCode}/getInfo")
-    public R<FlowDepart> getInfo(@PathVariable String flowCode) {
+    public R<FlowLabel> getInfo(@PathVariable String flowCode) {
         return R.ok(flwDepartService.getInfo(flowCode));
     }
 
@@ -39,8 +39,8 @@ public class FlwDepartController {
      * flowCode
      */
     @Operation(summary = "绑定流程部门关系",description = "绑定流程部门关系")
-    @PostMapping("/bind/depart")
-    public R<FlowDepart> bindDepart(@Validated({AddGroup.class}) @RequestBody FlowDepart flowDepart) {
-        return R.ok(flwDepartService.bindDepart(flowDepart));
+    @PostMapping("/bind/label")
+    public R<FlowLabel> bindLabel(@Validated({AddGroup.class}) @RequestBody FlowLabel flowLabel) {
+        return R.ok(flwDepartService.bindLabel(flowLabel));
     }
 }

dk-modules/workflow/src/main/java/org/dromara/workflow/domain/FlowDepart.java → dk-modules/workflow/src/main/java/org/dromara/workflow/domain/FlowLabel.java

@@ -15,18 +15,13 @@ import java.util.List;
  * 部门流程关系表
  */
 @Data
-@TableName(value = "flow_depart",autoResultMap = true)
-public class FlowDepart {
+@TableName(value = "flow_label",autoResultMap = true)
+public class FlowLabel {
 
 
     @TableId(type = IdType.ASSIGN_ID)
     private Long id;
 
-    /**
-     * 流程类型
-     */
-//    @NotNull(message = "流程类型不能为空", groups = AddGroup.class)
-//    private String flowType;
 
     /**
      * 流程编码
@@ -43,6 +38,6 @@ public class FlowDepart {
      * 部门id集合
      */
     @NotNull(message = "部门id不能为空", groups = AddGroup.class)
-    @TableField(value = "dept_ids",typeHandler = ListTypeHandler.class)
-    List<Long> departIds;
+    @TableField(value = "label_ids",typeHandler = ListTypeHandler.class)
+    List<String> labelIds;
 }

dk-modules/workflow/src/main/java/org/dromara/workflow/domain/vo/FlowDefinitionVo.java

@@ -103,5 +103,5 @@ public class FlowDefinitionVo implements Serializable {
      */
     private String ext;
 
-    private List<Long> deptIds;
+    private List<String> labelIds;
 }

dk-modules/workflow/src/main/java/org/dromara/workflow/dubbo/RemoteWorkflowServiceImpl.java

@@ -1,11 +1,10 @@
 package org.dromara.workflow.dubbo;
 
-import cn.dev33.satoken.stp.StpUtil;
 import lombok.RequiredArgsConstructor;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.dromara.system.api.domain.vo.RemoteUserVo;
 import org.dromara.workflow.api.RemoteWorkflowService;
-import org.dromara.workflow.api.domain.FlowDepartVo;
+import org.dromara.workflow.api.domain.FlowLabelVo;
 import org.dromara.workflow.api.domain.RemoteCompleteTask;
 import org.dromara.workflow.api.domain.RemoteStartProcess;
 import org.dromara.workflow.api.domain.RemoteStartProcessReturn;
@@ -15,7 +14,6 @@ import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -102,8 +100,8 @@ public class RemoteWorkflowServiceImpl implements RemoteWorkflowService {
     }
 
     @Override
-    public FlowDepartVo getFlowDepart(Long deptId) {
-        return flwTaskService.getFlowDepart(deptId);
+    public FlowLabelVo getFlowLabel(String labelId) {
+        return flwTaskService.getFlowLabel(labelId);
     }
 
     @Override

dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java

@@ -34,7 +34,11 @@ 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(),null,null);
+        String message = null;
+        if (ObjectUtil.isNotEmpty(processEvent.getParams())){
+            message = processEvent.getParams().get("message").toString();
+        }
+        alertService.updateAlertStatus(processEvent.getBusinessId(),processEvent.getStatus(),processEvent.getIsIllegal(),processEvent.getAlertType(),message,null);
     }
 
     /**

dk-modules/workflow/src/main/java/org/dromara/workflow/mapper/FlwDepartMapper.java

@@ -1,15 +0,0 @@
-package org.dromara.workflow.mapper;
-
-import jakarta.validation.constraints.NotNull;
-import org.apache.ibatis.annotations.Param;
-import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
-import org.dromara.workflow.domain.FlowDepart;
-
-import java.util.List;
-import java.util.Map;
-
-public interface FlwDepartMapper extends BaseMapperPlus<FlowDepart, FlowDepart> {
-    FlowDepart getFlowDepart(@Param("deptId") Long deptId);
-
-    Integer checkFlowDepart(@Param("deptIds") List<Long> departIds);
-}

dk-modules/workflow/src/main/java/org/dromara/workflow/mapper/FlwLabelMapper.java

@@ -0,0 +1,13 @@
+package org.dromara.workflow.mapper;
+
+import org.apache.ibatis.annotations.Param;
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.workflow.domain.FlowLabel;
+
+import java.util.List;
+
+public interface FlwLabelMapper extends BaseMapperPlus<FlowLabel, FlowLabel> {
+    FlowLabel getFlowLabel(@Param("labelId") String labelId);
+
+    Integer checkFlowLabel(@Param("labelIds") List<String> labelIds);
+}

dk-modules/workflow/src/main/java/org/dromara/workflow/service/FlwDepartService.java

@@ -1,11 +0,0 @@
-package org.dromara.workflow.service;
-
-import org.dromara.workflow.domain.FlowDepart;
-
-public interface FlwDepartService {
-    FlowDepart getInfo(String flowCode);
-
-    FlowDepart bindDepart(FlowDepart flowDepart);
-
-    FlowDepart getFlowDepart(Long deptId);
-}

dk-modules/workflow/src/main/java/org/dromara/workflow/service/FlwLabelService.java

@@ -0,0 +1,11 @@
+package org.dromara.workflow.service;
+
+import org.dromara.workflow.domain.FlowLabel;
+
+public interface FlwLabelService {
+    FlowLabel getInfo(String flowCode);
+
+    FlowLabel bindLabel(FlowLabel flowDepart);
+
+    FlowLabel getFlowLabel(String labelId);
+}

dk-modules/workflow/src/main/java/org/dromara/workflow/service/IFlwTaskService.java

@@ -3,20 +3,15 @@ package org.dromara.workflow.service;
 import org.dromara.common.mybatis.core.page.PageQuery;
 import org.dromara.common.mybatis.core.page.TableDataInfo;
 import org.dromara.system.api.domain.vo.RemoteUserVo;
-import org.dromara.warm.flow.core.dto.FlowParams;
 import org.dromara.warm.flow.core.entity.Node;
-import org.dromara.warm.flow.core.entity.Task;
-import org.dromara.warm.flow.core.service.impl.TaskServiceImpl;
 import org.dromara.warm.flow.orm.entity.FlowHisTask;
-import org.dromara.warm.flow.orm.entity.FlowNode;
 import org.dromara.warm.flow.orm.entity.FlowTask;
-import org.dromara.workflow.api.domain.FlowDepartVo;
+import org.dromara.workflow.api.domain.FlowLabelVo;
 import org.dromara.workflow.api.domain.RemoteStartProcessReturn;
 import org.dromara.workflow.domain.bo.*;
 import org.dromara.workflow.domain.vo.FlowHisTaskVo;
 import org.dromara.workflow.domain.vo.FlowTaskVo;
 
-import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 
@@ -214,8 +209,8 @@ public interface IFlwTaskService {
 
     /**
      * 根据部门获取流程
-     * @param deptId
+     * @param labelId
      * @return
      */
-    FlowDepartVo getFlowDepart(Long deptId);
+    FlowLabelVo getFlowLabel(String labelId);
 }

dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwDefinitionServiceImpl.java

@@ -32,10 +32,10 @@ import org.dromara.warm.flow.orm.mapper.FlowSkipMapper;
 import org.dromara.workflow.common.ConditionalOnEnable;
 import org.dromara.workflow.common.constant.FlowConstant;
 import org.dromara.workflow.domain.FlowCategory;
-import org.dromara.workflow.domain.FlowDepart;
+import org.dromara.workflow.domain.FlowLabel;
 import org.dromara.workflow.domain.vo.FlowDefinitionVo;
 import org.dromara.workflow.mapper.FlwCategoryMapper;
-import org.dromara.workflow.service.FlwDepartService;
+import org.dromara.workflow.service.FlwLabelService;
 import org.dromara.workflow.service.IFlwDefinitionService;
 import org.dromara.workflow.utils.WorkflowUtils;
 import org.springframework.stereotype.Service;
@@ -67,7 +67,7 @@ public class FlwDefinitionServiceImpl implements IFlwDefinitionService {
     private final FlowNodeMapper flowNodeMapper;
     private final FlowSkipMapper flowSkipMapper;
     private final FlwCategoryMapper flwCategoryMapper;
-    private final FlwDepartService flwDepartService;
+    private final FlwLabelService flwDepartService;
 
     /**
      * 查询流程定义列表
@@ -85,9 +85,9 @@ public class FlwDefinitionServiceImpl implements IFlwDefinitionService {
         build.setRows(BeanUtil.copyToList(page.getRecords(), FlowDefinitionVo.class));
         build.setTotal(page.getTotal());
         build.getRows().forEach(p ->{
-            FlowDepart info = flwDepartService.getInfo(p.getFlowCode());
+            FlowLabel info = flwDepartService.getInfo(p.getFlowCode());
             if(ObjectUtil.isNotEmpty(info)){
-                p.setDeptIds(info.getDepartIds());
+                p.setLabelIds(info.getLabelIds());
             }
         });
         return build;

dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwDepartServiceImpl.java

@@ -1,49 +0,0 @@
-package org.dromara.workflow.service.impl;
-
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import lombok.RequiredArgsConstructor;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.workflow.domain.FlowDepart;
-import org.dromara.workflow.mapper.FlwDepartMapper;
-import org.dromara.workflow.service.FlwDepartService;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.Map;
-
-@Service
-@RequiredArgsConstructor
-public class FlwDepartServiceImpl extends ServiceImpl<FlwDepartMapper, FlowDepart> implements FlwDepartService {
-
-
-    @Override
-    public FlowDepart getInfo(String flowCode) {
-        LambdaQueryWrapper<FlowDepart> wrapper = new LambdaQueryWrapper<>();
-        wrapper.eq(FlowDepart::getFlowCode, flowCode);
-
-        return this.baseMapper.selectOne(wrapper);
-    }
-
-    @Transactional(rollbackFor = Exception.class)
-    @Override
-    public FlowDepart bindDepart(FlowDepart flowDepart) {
-        LambdaQueryWrapper<FlowDepart> updateWrapper = new LambdaQueryWrapper<>();
-        updateWrapper.eq(FlowDepart::getFlowCode, flowDepart.getFlowCode());
-        this.baseMapper.delete(updateWrapper);
-
-        //查询部门是否还存在别的流程
-        if (this.baseMapper.checkFlowDepart(flowDepart.getDepartIds()) > 0){
-            throw new ServiceException("所选的部门中,已存在在其他流程中,请检查后在提交!");
-        }
-
-        this.baseMapper.insert(flowDepart);
-
-        return flowDepart;
-    }
-
-    @Override
-    public FlowDepart getFlowDepart(Long deptId) {
-        return this.baseMapper.getFlowDepart(deptId);
-    }
-}

dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwInstanceServiceImpl.java

@@ -256,7 +256,8 @@ public class FlwInstanceServiceImpl implements IFlwInstanceService {
                     WorkflowUtils.deleteRunTask(StreamUtils.toList(currentTaskList, Task::getId));
                 }
             }
-
+            //删除流程实例
+            this.deleteByInstanceIds(List.of(instance.getId()));
         } catch (Exception e) {
             log.error("撤销失败: {}", e.getMessage(), e);
             throw new ServiceException(e.getMessage());

dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwLabelServiceImpl.java

@@ -0,0 +1,47 @@
+package org.dromara.workflow.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.exception.ServiceException;
+import org.dromara.workflow.domain.FlowLabel;
+import org.dromara.workflow.mapper.FlwLabelMapper;
+import org.dromara.workflow.service.FlwLabelService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class FlwLabelServiceImpl extends ServiceImpl<FlwLabelMapper, FlowLabel> implements FlwLabelService {
+
+
+    @Override
+    public FlowLabel getInfo(String flowCode) {
+        LambdaQueryWrapper<FlowLabel> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(FlowLabel::getFlowCode, flowCode);
+
+        return this.baseMapper.selectOne(wrapper);
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public FlowLabel bindLabel(FlowLabel flowDepart) {
+        LambdaQueryWrapper<FlowLabel> updateWrapper = new LambdaQueryWrapper<>();
+        updateWrapper.eq(FlowLabel::getFlowCode, flowDepart.getFlowCode());
+        this.baseMapper.delete(updateWrapper);
+
+        //查询部门是否还存在别的流程
+        if (this.baseMapper.checkFlowLabel(flowDepart.getLabelIds()) > 0){
+            throw new ServiceException("所选的标签中,已存在在其他流程中,请检查后在提交!");
+        }
+
+        this.baseMapper.insert(flowDepart);
+
+        return flowDepart;
+    }
+
+    @Override
+    public FlowLabel getFlowLabel(String labelId) {
+        return this.baseMapper.getFlowLabel(labelId);
+    }
+}

dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/FlwTaskServiceImpl.java

@@ -13,7 +13,6 @@ 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;
@@ -22,13 +21,9 @@ import org.dromara.common.core.utils.StringUtils;
 import org.dromara.common.core.utils.ValidatorUtils;
 import org.dromara.common.core.validate.AddGroup;
 import org.dromara.common.core.validate.EditGroup;
-import org.dromara.common.mail.utils.MailUtils;
 import org.dromara.common.mybatis.core.page.PageQuery;
 import org.dromara.common.mybatis.core.page.TableDataInfo;
 import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.sse.dto.SseMessageDto;
-import org.dromara.common.sse.utils.SseMessageUtils;
-import org.dromara.resource.api.RemoteMessageService;
 import org.dromara.system.api.RemoteUserService;
 import org.dromara.system.api.domain.vo.RemoteUserVo;
 import org.dromara.warm.flow.core.dto.FlowParams;
@@ -40,13 +35,13 @@ import org.dromara.warm.flow.orm.entity.*;
 import org.dromara.warm.flow.orm.mapper.FlowHisTaskMapper;
 import org.dromara.warm.flow.orm.mapper.FlowInstanceMapper;
 import org.dromara.warm.flow.orm.mapper.FlowTaskMapper;
-import org.dromara.workflow.api.domain.FlowDepartVo;
+import org.dromara.workflow.api.domain.FlowLabelVo;
 import org.dromara.workflow.api.domain.RemoteStartProcessReturn;
 import org.dromara.workflow.common.ConditionalOnEnable;
 import org.dromara.workflow.common.enums.MessageTypeEnum;
 import org.dromara.workflow.common.enums.TaskAssigneeType;
 import org.dromara.workflow.common.enums.TaskStatusEnum;
-import org.dromara.workflow.domain.FlowDepart;
+import org.dromara.workflow.domain.FlowLabel;
 import org.dromara.workflow.domain.bo.*;
 import org.dromara.workflow.domain.vo.FlowHisTaskVo;
 import org.dromara.workflow.domain.vo.FlowTaskVo;
@@ -54,7 +49,7 @@ import org.dromara.workflow.handler.FlowProcessEventHandler;
 import org.dromara.workflow.handler.WorkflowPermissionHandler;
 import org.dromara.workflow.mapper.FlwCategoryMapper;
 import org.dromara.workflow.mapper.FlwTaskMapper;
-import org.dromara.workflow.service.FlwDepartService;
+import org.dromara.workflow.service.FlwLabelService;
 import org.dromara.workflow.service.IFlwTaskService;
 import org.dromara.workflow.utils.WorkflowUtils;
 import org.springframework.beans.BeanUtils;
@@ -65,8 +60,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.util.*;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 import static org.dromara.workflow.common.constant.FlowConstant.*;
@@ -94,7 +87,7 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
     private final FlowProcessEventHandler flowProcessEventHandler;
     private final FlwTaskMapper flwTaskMapper;
     private final FlwCategoryMapper flwCategoryMapper;
-    private final FlwDepartService flwDepartService;
+    private final FlwLabelService flwDepartService;
     @DubboReference
     private RemoteUserService remoteUserService;
 
@@ -329,9 +322,9 @@ public class FlwTaskServiceImpl implements IFlwTaskService {
     }
 
     @Override
-    public FlowDepartVo getFlowDepart(Long deptId) {
-        FlowDepart flowDepart = flwDepartService.getFlowDepart(deptId);
-        FlowDepartVo flowDepartVo = new FlowDepartVo();
+    public FlowLabelVo getFlowLabel(String labelId) {
+        FlowLabel flowDepart = flwDepartService.getFlowLabel(labelId);
+        FlowLabelVo flowDepartVo = new FlowLabelVo();
         BeanUtils.copyProperties(flowDepart, flowDepartVo);
         return flowDepartVo;
     }

dk-modules/workflow/src/main/resources/mapper/workflow/FlwDepartMapper.xml

@@ -1,22 +0,0 @@
-<?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="org.dromara.workflow.mapper.FlwDepartMapper">
-
-    <select id="getFlowDepart" resultType="org.dromara.workflow.domain.FlowDepart">
-        select fd.* from flow_depart fd where JSON_CONTAINS(fd.dept_ids, #{deptId})
-    </select>
-
-    <select id="checkFlowDepart" resultType="java.lang.Integer">
-        SELECT
-            count(1)
-        FROM flow_depart fd
-        where
-        <foreach collection="deptIds" item="item" open="(" separator=" OR " close=")">
-            JSON_CONTAINS(fd.dept_ids, CONCAT('"', #{item}, '"'))
-        </foreach>
-    </select>
-
-
-</mapper>

dk-modules/workflow/src/main/resources/mapper/workflow/FlwLabelMapper.xml

@@ -0,0 +1,22 @@
+<?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="org.dromara.workflow.mapper.FlwLabelMapper">
+
+    <select id="getFlowLabel" resultType="org.dromara.workflow.domain.FlowLabel">
+        select fd.* from flow_depart fd where JSON_CONTAINS(fd.label_ids, #{labelId})
+    </select>
+
+    <select id="checkFlowLabel" resultType="java.lang.Integer">
+        SELECT
+            count(1)
+        FROM flow_depart fd
+        where
+        <foreach collection="labelIds" item="item" open="(" separator=" OR " close=")">
+            JSON_CONTAINS(fd.label_ids, CONCAT('"', #{item}, '"'))
+        </foreach>
+    </select>
+
+
+</mapper>

pom.xml

@@ -521,6 +521,10 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
         </plugins>
         <resources>
             <resource>
@@ -610,5 +614,7 @@
         </pluginRepository>
     </pluginRepositories>
 
+
+
 </project>