|
|
@ -149,16 +149,12 @@ public class PointsModifyConsumer implements RocketMQListener<MessageExt> { |
|
|
|
} |
|
|
|
//判断用户是否完善信息
|
|
|
|
Long gridId = 0L; |
|
|
|
if(userDTO.getDeptId() == null || userDTO.getDeptId() == 0L){ |
|
|
|
//获取网格人员关系表
|
|
|
|
Result<UserGridRelationDTO> userLastSwitchGird = usersFeignClient.getUserLastSwitchGird(userDTO.getId()); |
|
|
|
if(!userLastSwitchGird.success() || userLastSwitchGird.getData()==null){ |
|
|
|
return "无法获取到网格人员关系信息"; |
|
|
|
} |
|
|
|
gridId = userLastSwitchGird.getData().getGridId(); |
|
|
|
}else{ |
|
|
|
gridId = userDTO.getDeptId(); |
|
|
|
//获取网格人员关系表
|
|
|
|
Result<UserGridRelationDTO> userLastSwitchGird = usersFeignClient.getUserLastSwitchGird(userDTO.getId()); |
|
|
|
if(!userLastSwitchGird.success() || userLastSwitchGird.getData()==null){ |
|
|
|
return "无法获取到网格人员关系信息"; |
|
|
|
} |
|
|
|
gridId = userLastSwitchGird.getData().getGridId(); |
|
|
|
//2.更新用户积分分数
|
|
|
|
if (OPERATION_TYPE_ADD.equals(pointsRuleResultDTO.getOperationType())) { |
|
|
|
userDTO.setPoints(userDTO.getPoints() + pointsRuleResultDTO.getPoints()); |
|
|
|