飞书群消息推送；DB部门表中区域销售部ID路径提取为变量

src/main/java/com/sfa/job/domain/system/dao/SysUserDaoImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.sfa.common.core.enums.StatusType;
 import com.sfa.job.domain.system.entity.SysUser;
 import com.sfa.job.domain.system.mapper.SysUserMapper;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -21,6 +22,8 @@ public class SysUserDaoImpl implements ISysUserDao{
 
     @Autowired
     private SysUserMapper sysUserMapper;
+    @Value("${wxl.lvzx_dept.r_sales_dept_path}")
+    private String lvzxDeptPath;
 
     @Override
     public void insertOrUpdate(JSONObject jo, Long deptId) {
@@ -91,7 +94,7 @@ public class SysUserDaoImpl implements ISysUserDao{
 
     @Override
     public Map<String, String> selectListEmpAndLeader() {
-        List<HashMap<String, String>> empAndLeaders = sysUserMapper.selectListEmpAndLeader();
+        List<HashMap<String, String>> empAndLeaders = sysUserMapper.selectListEmpAndLeader(lvzxDeptPath);
         return empAndLeaders.stream().collect(Collectors.toMap(m -> m.get("user_name"), m -> m.get("leader_emp_code")));
     }
 }

src/main/java/com/sfa/job/domain/system/mapper/SysUserMapper.java

@@ -35,7 +35,7 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
 
     void updateUserLeader();
 
-    List<HashMap<String, String>> selectListEmpAndLeader();
+    List<HashMap<String, String>> selectListEmpAndLeader(String lvzxDeptPath);
 }
 
 

src/main/java/com/sfa/job/service/qince/impl/QinceEmpAndDeptServiceImpl.java

 package com.sfa.job.service.qince.impl;
 
-import cn.hutool.http.HttpUtil;
-import com.alibaba.fastjson.JSONObject;
 import com.sfa.common.core.utils.StringUtils;
+import com.sfa.common.core.utils.sdk.FeiShuUtil;
 import com.sfa.common.core.utils.sdk.FeiShuUtils;
 import com.sfa.job.domain.qince.dao.IQinceEmployeeDao;
 import com.sfa.job.domain.system.dao.ISysUserDao;
@@ -10,11 +9,13 @@ import com.sfa.job.pojo.qince.response.QinceEmployeeDto;
 import com.sfa.job.service.qince.IQinceEmpAndDeptService;
 import com.sfa.job.util.QinCeUtils;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.groovy.util.Maps;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.*;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
 import java.util.stream.Collectors;
 
 /**
@@ -61,7 +62,7 @@ public class QinceEmpAndDeptServiceImpl implements IQinceEmpAndDeptService {
                 logtext = "更新勤策【" + empDto.getEmpCode() + ":" + empDto.getEmpName() + "】的上级Leader信息失败：" + e.getMessage();
                 log.error(logtext);
             }
-            FeiShuUtils.pustRoot("https://open.feishu.cn/open-apis/bot/v2/hook/9793c485-d2a0-49bc-961e-578deb3b1912", logtext);
+            FeiShuUtils.pustRoot(FeiShuUtil.qinceWebhook, logtext);
         }
     }
 }

src/main/resources/mapper/master/SysUserMapper.xml

@@ -135,6 +135,6 @@
         from sys_user
         where del_flag = '0'
           and leader_emp_code is not null
-          and dept_id in (select dept_id from sys_dept where del_flag = '0' and ancestors like '1,2731,2732%')
+          and dept_id in (select dept_id from sys_dept where del_flag = '0' and ancestors like concat(#{lvzxDeptPath},'%'))
     </select>
 </mapper>