diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserOpenidMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserOpenidMapper.java
index 19cdbde1..3463e3c1 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserOpenidMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserOpenidMapper.java
@@ -2,6 +2,7 @@ package com.ruoyi.system.mapper;
 
 import java.util.List;
 import com.ruoyi.system.domain.SysUserOpenid;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * 用户绑定小程序openIdMapper接口
@@ -55,9 +56,10 @@ public interface SysUserOpenidMapper
      * 查询用户绑定小程序openId列表[项目经理]
      *
      * @param proId 项目信息
+     * @param deptId 总包单位信息
      * @return 用户绑定小程序openId集合
      */
-    public List<SysUserOpenid> findMsgProOrgUsers(Long proId);
+    public List<SysUserOpenid> findMsgProOrgUsers(@Param("proId") Long proId, @Param("deptId") Long deptId);
 
     /**
      * 查询用户绑定小程序openId列表[项目甲代]
diff --git a/ruoyi-system/src/main/resources/mapper/system/SysUserOpenidMapper.xml b/ruoyi-system/src/main/resources/mapper/system/SysUserOpenidMapper.xml
index bdb7ea68..c17c6a67 100644
--- a/ruoyi-system/src/main/resources/mapper/system/SysUserOpenidMapper.xml
+++ b/ruoyi-system/src/main/resources/mapper/system/SysUserOpenidMapper.xml
@@ -50,7 +50,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         from sys_user_openid suo
         left join sys_user su on su.phonenumber = suo.loginName
         left join sur_project_userinfo spu on spu.user_id = su.user_id
-        where spu.project_id = #{proId} and spu.job_type=24 and spu.is_del = 0 and su.del_flag = '0' and suo.isDel=0
+        where spu.project_id = #{proId} and spu.dept_id = #{deptId} and spu.job_type=24 and spu.is_del = 0 and su.del_flag = '0' and suo.isDel=0
     </select>
 
     <select id="findMsgProMagUsers" parameterType="Long" resultMap="SysUserOpenidResult">
diff --git a/yanzhu-jh/src/main/java/com/yanzhu/jh/flow/domain/FlowLabourInfo.java b/yanzhu-jh/src/main/java/com/yanzhu/jh/flow/domain/FlowLabourInfo.java
index 6235305c..0d44ef8e 100644
--- a/yanzhu-jh/src/main/java/com/yanzhu/jh/flow/domain/FlowLabourInfo.java
+++ b/yanzhu-jh/src/main/java/com/yanzhu/jh/flow/domain/FlowLabourInfo.java
@@ -5,6 +5,8 @@ import org.apache.commons.lang3.builder.ToStringStyle;
 import com.ruoyi.common.annotation.Excel;
 import com.ruoyi.common.core.domain.BaseEntity;
 
+import java.math.BigDecimal;
+
 /**
  * 劳资投诉对象 flow_labour_info
  * 
@@ -60,7 +62,7 @@ public class FlowLabourInfo extends BaseEntity
 
     /** 欠薪金额 */
     @Excel(name = "欠薪金额")
-    private Long laborAmount;
+    private BigDecimal laborAmount;
 
     /** 欠薪原因说明 */
     @Excel(name = "欠薪原因说明")
@@ -177,12 +179,12 @@ public class FlowLabourInfo extends BaseEntity
     {
         return laborNumber;
     }
-    public void setLaborAmount(Long laborAmount) 
+    public void setLaborAmount(BigDecimal laborAmount)
     {
         this.laborAmount = laborAmount;
     }
 
-    public Long getLaborAmount() 
+    public BigDecimal getLaborAmount()
     {
         return laborAmount;
     }
diff --git a/yanzhu-jh/src/main/java/com/yanzhu/jh/wxsetting/service/impl/WeChatMessageServiceImpl.java b/yanzhu-jh/src/main/java/com/yanzhu/jh/wxsetting/service/impl/WeChatMessageServiceImpl.java
index aa3b0048..8cc2e77d 100644
--- a/yanzhu-jh/src/main/java/com/yanzhu/jh/wxsetting/service/impl/WeChatMessageServiceImpl.java
+++ b/yanzhu-jh/src/main/java/com/yanzhu/jh/wxsetting/service/impl/WeChatMessageServiceImpl.java
@@ -588,7 +588,7 @@ public class WeChatMessageServiceImpl {
     }
 
     /**
-     * 取样复试操作时推送信息
+     * 劳资投诉时推送信息
      * @param flowLabourInfo
      */
     @Async
@@ -599,7 +599,7 @@ public class WeChatMessageServiceImpl {
             /**
              * 项目经理审批
              */
-            String supMsgId = this.getMsgProOrgUsers(flowLabourInfo.getProjectId());
+            String supMsgId = this.getMsgProOrgUsers(flowLabourInfo.getProjectId(),flowLabourInfo.getDeptId());
             //模板数据
             WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
                     .toUser(supMsgId)
@@ -670,13 +670,13 @@ public class WeChatMessageServiceImpl {
      * @param proId
      * @return
      */
-    private String getMsgProOrgUsers(Long proId){
+    private String getMsgProOrgUsers(Long proId,Long deptId){
         List<SysUserOpenid> list = redisCache.getCacheObject(CacheConstants.WX_MPMESSAGE_P_ORG +proId);
         if(list!=null){
             List<String> strs = list.stream().map(SysUserOpenid :: getMsgOpenId).collect(Collectors.toList());
             return String.join(",",strs);
         }else{
-            list = sysUserOpenidMapper.findMsgProOrgUsers(proId);
+            list = sysUserOpenidMapper.findMsgProOrgUsers(proId,deptId);
             if(StringUtils.isNotEmpty(list)){
                 //设置30分钟有效期
                 redisCache.setCacheObject(CacheConstants.WX_MPMESSAGE_P_ORG +proId,list,30, TimeUnit.MINUTES);