diff --git a/zc-business/src/main/java/com/zc/business/controller/DcEmployeesController.java b/zc-business/src/main/java/com/zc/business/controller/DcEmployeesController.java
index ef66f469..b30e8ef6 100644
--- a/zc-business/src/main/java/com/zc/business/controller/DcEmployeesController.java
+++ b/zc-business/src/main/java/com/zc/business/controller/DcEmployeesController.java
@@ -11,11 +11,13 @@ import com.zc.business.enums.UniversalEnum;
 import com.zc.business.service.IDcEmployeesService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletResponse;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 值班人员信息Controller
@@ -155,4 +157,11 @@ public class DcEmployeesController extends BaseController
     public AjaxResult personnelPositions(){
         return toAjax(dcEmployeesService.personnelPositions());
     }
+
+    @ApiOperation("获取应急机构下的所有人员")
+    @GetMapping("/getAllEmployees")
+    public List<Map<String,Object>> getAllEmployees(@ApiParam(value = "桩号", name = "stakeMark", required = true) String stakeMark)
+    {
+        return dcEmployeesService.getAllEmployees(stakeMark);
+    }
 }
diff --git a/zc-business/src/main/java/com/zc/business/mapper/DcEmployeesMapper.java b/zc-business/src/main/java/com/zc/business/mapper/DcEmployeesMapper.java
index cf646a2b..647022b0 100644
--- a/zc-business/src/main/java/com/zc/business/mapper/DcEmployeesMapper.java
+++ b/zc-business/src/main/java/com/zc/business/mapper/DcEmployeesMapper.java
@@ -79,4 +79,8 @@ public interface DcEmployeesMapper
     public Integer updateJobInformation(@Param("employeesId")Long employeesId,@Param("station")Long station);
 
     List<DcEmployees> selectEmployeesByIds(Long[] ids);
+
+    List<Map<String, Object>> selectAllOrganization();
+
+    List<Map<String, Object>> selectOrganizationEmployees(@Param("organizationId") String organizationId);
 }
diff --git a/zc-business/src/main/java/com/zc/business/service/IDcEmployeesService.java b/zc-business/src/main/java/com/zc/business/service/IDcEmployeesService.java
index 2b0e6fc5..7d30bb0d 100644
--- a/zc-business/src/main/java/com/zc/business/service/IDcEmployeesService.java
+++ b/zc-business/src/main/java/com/zc/business/service/IDcEmployeesService.java
@@ -71,4 +71,7 @@ public interface IDcEmployeesService
     public List<HashMap<String,Object>> selectEmployeesPostAll();
     //定时任务,获取值班信息定义人员归属岗位
     public int personnelPositions();
+
+    //获取应急机构下所有人员
+    List<Map<String,Object>> getAllEmployees(String stakeMark);
 }
diff --git a/zc-business/src/main/java/com/zc/business/service/impl/DcEmployeesServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/DcEmployeesServiceImpl.java
index e234eedb..d04a29a2 100644
--- a/zc-business/src/main/java/com/zc/business/service/impl/DcEmployeesServiceImpl.java
+++ b/zc-business/src/main/java/com/zc/business/service/impl/DcEmployeesServiceImpl.java
@@ -1,6 +1,7 @@
 package com.zc.business.service.impl;
 
 import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.common.utils.StakeMarkUtils;
 import com.ruoyi.common.utils.StringUtils;
 import com.zc.business.domain.DcEmployees;
 import com.zc.business.enums.UniversalEnum;
@@ -160,4 +161,26 @@ public class DcEmployeesServiceImpl implements IDcEmployeesService {
         }
         return UniversalEnum.ONE.getNumber();
     }
+
+    //获取应急机构下所有人员
+    @Override
+    public List<Map<String,Object>> getAllEmployees(String stakeMark){
+        Long stakeMarkNum = StakeMarkUtils.formatMetreLong(stakeMark);
+        List<Map<String,Object>> organizationList = dcEmployeesMapper.selectAllOrganization();
+        if (organizationList != null){
+            for (Map<String, Object> organization : organizationList) {
+                if (StringUtils.isEmpty(organization.get("stakeMark").toString())){
+                    continue;
+                }
+                Long num = StakeMarkUtils.formatMetreLong(organization.get("stakeMark").toString());
+                Long difference = Math.abs(stakeMarkNum - num);
+                organization.put("difference", difference / 1000);
+                List<Map<String,Object>> employeesList = dcEmployeesMapper.selectOrganizationEmployees(organization.get("id").toString());
+                organization.put("employeesList",employeesList);
+            }
+        }
+
+        return organizationList;
+
+    }
 }
diff --git a/zc-business/src/main/java/com/zc/business/service/impl/MsmServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/MsmServiceImpl.java
index 8ed77809..59853a77 100644
--- a/zc-business/src/main/java/com/zc/business/service/impl/MsmServiceImpl.java
+++ b/zc-business/src/main/java/com/zc/business/service/impl/MsmServiceImpl.java
@@ -12,12 +12,15 @@ import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.spring.SpringUtils;
+import com.zc.business.domain.DcEmployees;
 import com.zc.business.domain.DcEventProcess;
 import com.zc.business.domain.DcPublishManage;
 import com.zc.business.enums.UniversalEnum;
+import com.zc.business.mapper.DcEmployeesMapper;
 import com.zc.business.mapper.DcPublishManageMapper;
 import com.zc.business.service.IMsmService;
 import com.zc.business.utils.HttpUtil;
+import com.zc.business.utils.QYWXUtil;
 import org.apache.commons.lang3.StringUtils;
 import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,9 +30,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.io.InputStream;
 import java.net.HttpURLConnection;
 import java.net.URL;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Random;
+import java.util.*;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -51,6 +52,10 @@ public class MsmServiceImpl implements IMsmService {
     private DcEventProcessServiceImpl dcEventProcessService;
     @Autowired
     private DcPublishManageMapper dcPublishManageMapper;
+    @Autowired
+    private DcEmployeesMapper employeesMapper;
+    @Autowired
+    private QYWXUtil qywxUtil;
     /**
      * 发送短信
      *
@@ -280,6 +285,26 @@ public class MsmServiceImpl implements IMsmService {
 //                continue;
 //            }
 //        }
+        //企业微信推送
+        List<Integer> employees = (List<Integer>) map.get("employees");
+        Long[] ids = employees.stream().mapToLong(Integer::longValue).boxed().toArray(Long[]::new);
+        List<DcEmployees> employeesList = employeesMapper.selectEmployeesByIds(ids);
+        List<String> wxUserIds = new ArrayList<>();
+        for (DcEmployees dcEmployees : employeesList) {
+            if (StringUtils.isNotBlank(dcEmployees.getWxUserId())){
+                wxUserIds.add(dcEmployees.getWxUserId());
+            } else {
+                String wxUserId = qywxUtil.getUserIdByMobile(dcEmployees.getContactNumber());
+                if (StringUtils.isNotBlank(wxUserId)){
+                    dcEmployees.setWxUserId(wxUserId);
+                    employeesMapper.updateDcEmployees(dcEmployees);
+                    wxUserIds.add(wxUserId);
+                }
+            }
+        }
+        qywxUtil.sendMessageByWxUserId(wxUserIds,content);
+
+
         DcEventProcess dcEventProcess = new DcEventProcess();
         dcEventProcess.setEventId(eventId);
         dcEventProcess.setSource(UniversalEnum.ONE.getNumber());
diff --git a/zc-business/src/main/resources/mapper/business/DcEmployeesMapper.xml b/zc-business/src/main/resources/mapper/business/DcEmployeesMapper.xml
index 87368f53..dd1821ff 100644
--- a/zc-business/src/main/resources/mapper/business/DcEmployeesMapper.xml
+++ b/zc-business/src/main/resources/mapper/business/DcEmployeesMapper.xml
@@ -130,6 +130,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{id}
         </foreach>
     </select>
+    <select id="selectAllOrganization" resultType="java.util.Map">
+        select id,organization_name organizationName,stake_mark stakeMark from dc_organization
+    </select>
+    <select id="selectOrganizationEmployees" resultType="java.util.Map">
+        select id,name from dc_employees where organization_id = #{organizationId}
+    </select>
     <update id="updateJobInformation">
         update dc_employees set  organization_id=#{station} where employees_id=#{employeesId}
     </update>