Commit e9b3cf04691d86f48ca8868f0cb88670fadee2d5
1 parent
f6736d02
bug修复
Showing
1 changed file
with
1 additions
and
1 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/AbstractFollowStrategy.java
@@ -863,11 +863,11 @@ public abstract class AbstractFollowStrategy implements FollowStrategy { | @@ -863,11 +863,11 @@ public abstract class AbstractFollowStrategy implements FollowStrategy { | ||
863 | } | 863 | } |
864 | redistributionTask.setGroupId(clue.getGroupId()); | 864 | redistributionTask.setGroupId(clue.getGroupId()); |
865 | redistributionTask.setRpcSuccess(Boolean.FALSE); | 865 | redistributionTask.setRpcSuccess(Boolean.FALSE); |
866 | + clueTaskService.save(redistributionTask); | ||
866 | FollowInitDTO followInitDTO = creteRedistributionFollowInitDTO(clue, redistributionTask); | 867 | FollowInitDTO followInitDTO = creteRedistributionFollowInitDTO(clue, redistributionTask); |
867 | shirasawaRpcService.createFollowData(followInitDTO); | 868 | shirasawaRpcService.createFollowData(followInitDTO); |
868 | clue.setNextTime(redistributionTask.getDeadline().plusDays(1L)); | 869 | clue.setNextTime(redistributionTask.getDeadline().plusDays(1L)); |
869 | followClueService.updateById(clue); | 870 | followClueService.updateById(clue); |
870 | - clueTaskService.save(redistributionTask); | ||
871 | } | 871 | } |
872 | 872 | ||
873 | protected String generateAddKey() { | 873 | protected String generateAddKey() { |