|
@@ -72,6 +72,7 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
private String providerSecret;
|
|
|
public static final String GET_TOKEN_URL = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=SECRET&code=CODE&grant_type=authorization_code";
|
|
|
public static final String GET_USERINFO_URL = "https://api.weixin.qq.com/sns/userinfo?access_token=accessToken&openid=openId&lang=zh_CN";
|
|
|
+ public static final String[] MATCHING_FILED = {"corpwx_userid","phone","job_number"};
|
|
|
|
|
|
//用于控制线程锁
|
|
|
public static HashMap<String, CorpwxJobResult> corpwxJobCenter = new HashMap();
|
|
@@ -746,7 +747,7 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
|
|
|
//获取员工的列表
|
|
|
@Override
|
|
|
- public HttpRespMsg getEmployeeList(Integer departmentId, String keyword, Integer status, Integer roleId, Integer onlyDirect, String cursor, Integer pageIndex, Integer pageSize, HttpServletRequest request) throws Exception {
|
|
|
+ public HttpRespMsg getEmployeeList(Integer departmentId,Integer matchingType,String keyword, Integer status, Integer roleId, Integer onlyDirect, String cursor, Integer pageIndex, Integer pageSize, HttpServletRequest request) throws Exception {
|
|
|
HttpRespMsg httpRespMsg = new HttpRespMsg();
|
|
|
Integer WXCompanyId = userMapper.selectById(request.getHeader("Token")).getCompanyId();
|
|
|
WxCorpInfo wxCorpInfo = wxCorpInfoMapper.selectOne(new QueryWrapper<WxCorpInfo>().eq("company_id", WXCompanyId));
|
|
@@ -757,22 +758,22 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
System.out.println("====================开始查询通讯录名单======================");
|
|
|
HashMap<String, List> result = wxCorpInfoService.getOpenId(wxCorpInfo.getCorpid(), keyword, cursor,1,200);
|
|
|
List users = result.get("user");
|
|
|
- if (users.size()!=0){
|
|
|
- List<User> realUser = userMapper.selectList(new QueryWrapper<User>().and(wrapper->wrapper.like("phone",keyword).or().like("job_number",keyword).or().in("corpwx_userid", users)));
|
|
|
+ if (users.size()!=0&&matchingType==0){
|
|
|
+ List<User> realUser = userMapper.selectList(new QueryWrapper<User>().in("corpwx_userid", users));
|
|
|
long total = realUser.size();
|
|
|
data.put("records",realUser);
|
|
|
data.put("nextCursor",result.get("nextCursor").get(0));
|
|
|
data.put("total",total);
|
|
|
- return httpRespMsg;
|
|
|
}else {
|
|
|
System.err.println("======================user列表没有查询到数据===========================");
|
|
|
System.err.println("======================httpRespMsg返回空集合===========================");
|
|
|
- ArrayList<Object> records = new ArrayList<>();
|
|
|
- data.put("records",records);
|
|
|
- data.put("nextCursor","");
|
|
|
- data.put("total",0);
|
|
|
- return httpRespMsg;
|
|
|
+ List<User> realUser = userMapper.selectList(new QueryWrapper<User>().eq("company_id",WXCompanyId).like(MATCHING_FILED[matchingType],keyword));
|
|
|
+ long total = realUser.size();
|
|
|
+ data.put("records",realUser);
|
|
|
+ data.put("nextCursor",result.get("nextCursor").get(0));
|
|
|
+ data.put("total",total);
|
|
|
}
|
|
|
+ return httpRespMsg;
|
|
|
}else {
|
|
|
try {
|
|
|
Integer companyId = userMapper.selectById(request.getHeader("Token")).getCompanyId();
|
|
@@ -782,11 +783,11 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
Page<User> page = new Page<>(pageIndex, pageSize);
|
|
|
if (departmentId == -1) {
|
|
|
//单独查找全部
|
|
|
- list = userMapper.getUserByDepartment(page, companyId, null, keyword, status, roleId);
|
|
|
+ list = userMapper.getUserByDepartment(page, companyId, null,matchingType, keyword, status, roleId);
|
|
|
total = page.getTotal();
|
|
|
} else if (departmentId == 0) {
|
|
|
//单独查找0, 未分配的
|
|
|
- list = userMapper.getUserByDepartment(page, companyId, departmentId, keyword, status, roleId);
|
|
|
+ list = userMapper.getUserByDepartment(page, companyId, departmentId,matchingType, keyword, status, roleId);
|
|
|
total = page.getTotal();
|
|
|
} else {
|
|
|
//范围查找
|