改修抖音权限问题

master
wujingtao 2 years ago
parent 693ca8a137
commit c2b5ba7103

@ -81,6 +81,7 @@ public interface OrganizeUserRepository extends JpaRepository<OrganizeUser, Long
/**
* userId
*
* @param userIds
* @return
*/
@ -119,4 +120,12 @@ public interface OrganizeUserRepository extends JpaRepository<OrganizeUser, Long
List<OrganizeUser> findByOrganizeIdIn(Set<Long> organizeIdAll);
/**
* idid
*
* @param organizeId
* @return
*/
@Query(value = "select u.userId from OrganizeUser u where u.organizeId =?1")
List<Long> findAllIdByOrganizeId(Long organizeId);
}

@ -176,8 +176,8 @@ public class OrganizeController {
}
@GetMapping("/findOrganizeIdByMember")
@ApiOperation("根据用户id查询组id(有权限查看组员信息,并且是组长)")
public ResponseEntity<Long> findOrganizeIdByMember(@RequestParam("memberId") Long memberId) {
@ApiOperation("根据用户id查询组id(有权限查看组员信息,并且是组长)")
public ResponseEntity<List<Long>> findOrganizeIdByMember(@RequestParam("memberId") Long memberId) {
return organizeService.findOrganizeIdByMember(memberId);
}
}

@ -199,5 +199,5 @@ public interface OrganizeService {
* @param memberId
* @return
*/
ResponseEntity<Long> findOrganizeIdByMember(Long memberId);
ResponseEntity<List<Long>> findOrganizeIdByMember(Long memberId);
}

@ -542,9 +542,9 @@ public class OrganizeServiceImpl implements OrganizeService {
List<Long> roles = Lists.newArrayList();
Long roleId = Collections.min(roleService.findByUsersId(SecurityUtils.getCurrentUserId()).stream().map(RoleSmallDto::getId).collect(Collectors.toList()));
// 判断角色,管理员只查组长角色的用户
if (roleId.equals(RoleNumberConstants.MINUS_EIGHT_NUMBER) || roleId.equals(RoleNumberConstants.MINUS_TEN_NUMBER)){
if (roleId.equals(RoleNumberConstants.MINUS_EIGHT_NUMBER) || roleId.equals(RoleNumberConstants.MINUS_TEN_NUMBER)) {
roles.add(RoleNumberConstants.MINUS_NINE_NUMBER);
}else {
} else {
roles.add(RoleNumberConstants.MINUS_FIVE_NUMBER);
}
//查询角色下所有用户
@ -682,10 +682,11 @@ public class OrganizeServiceImpl implements OrganizeService {
}
@Override
public ResponseEntity<Long> findOrganizeIdByMember(Long memberId) {
public ResponseEntity<List<Long>> findOrganizeIdByMember(Long memberId) {
Organize organizeIdByMember = organizeRepository.findOrganizeIdByMember(memberId, true, true);
if (ObjectUtil.isNotEmpty(organizeIdByMember) && organizeIdByMember.getId() != null) {
return new ResponseEntity<>(organizeIdByMember.getId(), HttpStatus.OK);
List<Long> organizeUserList = organizeUserRepository.findAllIdByOrganizeId(organizeIdByMember.getId());
return new ResponseEntity<>(organizeUserList, HttpStatus.OK);
}
return new ResponseEntity<>(null, HttpStatus.OK);
}

@ -212,13 +212,12 @@ public class UserServiceImpl implements UserService {
if (flag) {
if (userDTO.getCompanyType() == 1) {
//抖音(飞鱼)
createTask(userCreateResult.getId(), "飞鱼任务", DefaultNumberConstants.THREE_NUMBER);
} else {
createTask(userCreateResult.getId(), userCreateResult.getUsername(), DefaultNumberConstants.ONE_NUMBER);
createTask(userCreateResult.getId(), "员工上传任务", DefaultNumberConstants.TWO_NUMBER);
createTask(userCreateResult.getId(), "投流回流任务", DefaultNumberConstants.SEVEN_NUMBER);
createTask(userCreateResult.getId(), "拓客回流任务", DefaultNumberConstants.SIX_NUMBER);
createTask(userCreateResult.getId(), "抖音任务", DefaultNumberConstants.THREE_NUMBER);
}
createTask(userCreateResult.getId(), userCreateResult.getUsername(), DefaultNumberConstants.ONE_NUMBER);
createTask(userCreateResult.getId(), "员工上传任务", DefaultNumberConstants.TWO_NUMBER);
createTask(userCreateResult.getId(), "投流回流任务", DefaultNumberConstants.SEVEN_NUMBER);
createTask(userCreateResult.getId(), "拓客回流任务", DefaultNumberConstants.SIX_NUMBER);
}
MultipartFile file = userDTO.getFile();

@ -36,7 +36,7 @@ public interface OrganizeClient {
@ApiOperation("根据id查询组名")
Map<Long, String> findNameById(@RequestBody Set<Long> organizeIds);
@GetMapping(PAY_PREFIX+ "/findOrganizeIdByMember")
@ApiOperation("根据用户id查询组id(有权限查看组员信息,并且是组长)")
ResponseEntity<Long> findOrganizeIdByMember(@RequestParam("memberId") Long memberId);
@GetMapping(PAY_PREFIX + "/findOrganizeIdByMember")
@ApiOperation("根据用户id查询组id(有权限查看组员信息,并且是组长)")
ResponseEntity<List<Long>> findOrganizeIdByMember(@RequestParam("memberId") Long memberId);
}

@ -29,7 +29,7 @@ public class OrganizeClientFallback implements OrganizeClient {
}
@Override
public ResponseEntity<Long> findOrganizeIdByMember(Long memberId) {
public ResponseEntity<List<Long>> findOrganizeIdByMember(Long memberId) {
return null;
}
}

@ -107,6 +107,9 @@ public class ClueJpa {
if (clueQueryCriteria.getMemberId() != null) {
sql.append("and cm.member_id = :memberId ");
}
if (clueQueryCriteria.getUserIdList() != null) {
sql.append("and cm.member_id in :userIdList ");
}
if (clueQueryCriteria.getOrganizeId() != null) {
sql.append("and cm.organize_id = :organizeId ");
}
@ -149,6 +152,10 @@ public class ClueJpa {
if (clueQueryCriteria.getMemberId() != null) {
query.setParameter("memberId", clueQueryCriteria.getMemberId());
}
if (CollUtil.isNotEmpty(clueQueryCriteria.getUserIdList())) {
query.setParameter("userIdList", clueQueryCriteria.getUserIdList());
}
if (clueQueryCriteria.getOrganizeId() != null) {
query.setParameter("organizeId", clueQueryCriteria.getOrganizeId());
}
@ -177,7 +184,7 @@ public class ClueJpa {
if (clueType != null) {
query.setParameter("clueType", clueType);
} else {
query.setParameter("clueTypes",clueQueryCriteria.getClueTypes());
query.setParameter("clueTypes", clueQueryCriteria.getClueTypes());
}
query.unwrap(NativeQueryImpl.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
return query.getResultList();
@ -208,11 +215,11 @@ public class ClueJpa {
String key = "task:encryption:" + taskId;
String str = String.valueOf(redisUtils.get(key));
// 查看资源是否需要加密显示
if (isEncryption != null && isEncryption == 1){
if (isEncryption != null && isEncryption == 1) {
StringBuilder stringBuilder = new StringBuilder(nid);
String strRep = stringBuilder.replace(3, 7, "****").toString();
clueDto.setNid(strRep);
}else{
} else {
// 查看任务是否需要加密显示资源
if ("null".equals(str) || StringUtils.isBlank(str)) {
ClueDto clueDtoClient = new ClueDto();
@ -348,7 +355,7 @@ public class ClueJpa {
} else {
sql.append("AND tcm.clue_type in :clueTypes ");
}
if(clueCallStatus !=null){
if (clueCallStatus != null) {
sql.append("AND tcm.clue_call_status = :clueCallStatus ");
}
//拼接最后加入时间排序,没加id排序出现数据重复问题(注意空格)
@ -381,9 +388,9 @@ public class ClueJpa {
if (clueType != null) {
query.setParameter("clueType", clueType);
} else {
query.setParameter("clueTypes",clueQueryCriteria.getClueTypes());
query.setParameter("clueTypes", clueQueryCriteria.getClueTypes());
}
if(clueCallStatus!=null){
if (clueCallStatus != null) {
query.setParameter("clueCallStatus", clueCallStatus);
}
query.setParameter("number", pageable.getPageNumber() * pageable.getPageSize());
@ -404,11 +411,11 @@ public class ClueJpa {
clue.setCreateTime((Date) row.get("createTime"));
clue.setName((String) row.get("name"));
String nid = AESUtils.decrypt(phone, secret);
if (isEncryption == 1){
if (isEncryption == 1) {
StringBuilder stringBuilder = new StringBuilder(nid);
String strRep = stringBuilder.replace(3, 7, "****").toString();
clue.setNid(strRep);
}else {
} else {
clue.setNid(nid);
}
BigInteger taskId = (BigInteger) row.get("taskId");

@ -78,7 +78,7 @@ public class ClueServiceImpl implements ClueService {
// 24位的nid解密,查询时要加*显示的线索
if (clue.getNid().length() == DefaultNumberConstants.TWENTY_FOUR) {
String str = DecryptPnoUtil.decryptPno(clue.getNid());
if (str != null){
if (str != null) {
clue.setNid(str);
clue.setIsEncryption(DefaultNumberConstants.ONE_NUMBER);
}
@ -202,10 +202,11 @@ public class ClueServiceImpl implements ClueService {
String nid = clueQueryCriteria.getNid();
if (clueQueryCriteria.getMemberId() != null) {
Long organizeId = organizeClient.findOrganizeIdByMember(clueQueryCriteria.getMemberId()).getBody();
List<Long> userIds = organizeClient.findOrganizeIdByMember(clueQueryCriteria.getMemberId()).getBody();
//如果查询的小组id不为空 ,说明是组长并有权限查看组员信息
if (organizeId != null) {
clueQueryCriteria.setOrganizeId(organizeId);
if (CollUtil.isNotEmpty(userIds)) {
// clueQueryCriteria.setOrganizeId(organizeId);
clueQueryCriteria.setUserIdList(userIds);
clueQueryCriteria.setMemberId(null);
}
if (clueQueryCriteria.getClueType() == null) {

Loading…
Cancel
Save