valhalla / fw-valhalla

Commit 901773da137cd0a165f0951b4c9ad559d8d49412

Authored by 张志伟
1 parent 951e1268

:bug: 修复保有客分配后推送消息失败的bug

Inline Side-by-side
Showing 1 changed file with 2 additions and 2 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/LeaveNeedDoBizService.java
  View file @901773d
@@ -164,7 +164,7 @@ public class LeaveNeedDoBizService { @@ -164,7 +164,7 @@ public class LeaveNeedDoBizService {
164 List<FollowTypeEnum> enumList = Arrays.asList(FollowTypeEnum.FM, FollowTypeEnum.RM); 164 List<FollowTypeEnum> enumList = Arrays.asList(FollowTypeEnum.FM, FollowTypeEnum.RM);
165 List<FollowTask> taskList = followTaskService.list(Wrappers.<FollowTask>lambdaQuery() 165 List<FollowTask> taskList = followTaskService.list(Wrappers.<FollowTask>lambdaQuery()
166 .eq(FollowTask::getState, TaskStateEnum.ONGOING) 166 .eq(FollowTask::getState, TaskStateEnum.ONGOING)
167 - .eq(FollowTask::getRedistribution, dto.getAdviserId()) 167 + .eq(FollowTask::getFollowUser, dto.getAdviserId())
168 .in(FollowTask::getType, enumList) 168 .in(FollowTask::getType, enumList)
169 ); 169 );
170 if (!CollectionUtils.isEmpty(taskList)) { 170 if (!CollectionUtils.isEmpty(taskList)) {
@@ -216,7 +216,7 @@ public class LeaveNeedDoBizService { @@ -216,7 +216,7 @@ public class LeaveNeedDoBizService {
216 216
217 List<FollowTask> taskList = followTaskService.list(Wrappers.<FollowTask>lambdaQuery() 217 List<FollowTask> taskList = followTaskService.list(Wrappers.<FollowTask>lambdaQuery()
218 .eq(FollowTask::getState, TaskStateEnum.ONGOING) 218 .eq(FollowTask::getState, TaskStateEnum.ONGOING)
219 - .eq(FollowTask::getRedistribution, userId) 219 + .eq(FollowTask::getFollowUser, userId)
220 .eq(FollowTask::getType, FollowTypeEnum.IR) 220 .eq(FollowTask::getType, FollowTypeEnum.IR)
221 ); 221 );
222 if (CollectionUtils.isEmpty(taskList)) { 222 if (CollectionUtils.isEmpty(taskList)) {