Commit 1d55d78ad5a82be085b8de3b6d6fbd80c1e13ed7
Merge remote-tracking branch 'origin/dev' into test
Showing
3 changed files
with
4 additions
and
4 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/FMFollowStrategy.java
@@ -160,7 +160,7 @@ public class FMFollowStrategy extends AbstractFollowStrategy { | @@ -160,7 +160,7 @@ public class FMFollowStrategy extends AbstractFollowStrategy { | ||
160 | @Transactional(rollbackFor = Exception.class) | 160 | @Transactional(rollbackFor = Exception.class) |
161 | public boolean origin2task(OriginalData originalData) { | 161 | public boolean origin2task(OriginalData originalData) { |
162 | Customer customer = customerService.queryById(originalData.getCustomerId()); | 162 | Customer customer = customerService.queryById(originalData.getCustomerId()); |
163 | - if (Objects.isNull(customer)) { | 163 | + if (Objects.isNull(customer) || Objects.isNull(customer.getAdviserId()) || Objects.isNull(customer.getShopId())) { |
164 | return true; | 164 | return true; |
165 | } | 165 | } |
166 | if (DataTypeEnum.FM.equals(originalData.getType())) { | 166 | if (DataTypeEnum.FM.equals(originalData.getType())) { |
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/IRFollowStrategy.java
@@ -220,7 +220,7 @@ public class IRFollowStrategy extends AbstractFollowStrategy { | @@ -220,7 +220,7 @@ public class IRFollowStrategy extends AbstractFollowStrategy { | ||
220 | @Transactional(rollbackFor = Exception.class) | 220 | @Transactional(rollbackFor = Exception.class) |
221 | public boolean origin2task(OriginalData originalData) { | 221 | public boolean origin2task(OriginalData originalData) { |
222 | Customer customer = customerService.queryById(originalData.getCustomerId()); | 222 | Customer customer = customerService.queryById(originalData.getCustomerId()); |
223 | - if (Objects.isNull(customer)) { | 223 | + if (Objects.isNull(customer) || Objects.isNull(customer.getAdviserId()) || Objects.isNull(customer.getShopId())) { |
224 | return true; | 224 | return true; |
225 | } | 225 | } |
226 | this.completeTask(customer, originalData.getGenerateTime()); | 226 | this.completeTask(customer, originalData.getGenerateTime()); |
@@ -233,7 +233,7 @@ public class IRFollowStrategy extends AbstractFollowStrategy { | @@ -233,7 +233,7 @@ public class IRFollowStrategy extends AbstractFollowStrategy { | ||
233 | List<PostUserDTO> userList = userService.getUserByRole(shopId, RoleCode.XBGJ); | 233 | List<PostUserDTO> userList = userService.getUserByRole(shopId, RoleCode.XBGJ); |
234 | 234 | ||
235 | if (CollectionUtils.isEmpty(userList)) { | 235 | if (CollectionUtils.isEmpty(userList)) { |
236 | - log.error("跟进人员获取失败:没有续保跟进员"); | 236 | + log.error("跟进人员获取失败:没有续保跟进员 -> shopId:{}", shopId); |
237 | return false; | 237 | return false; |
238 | } | 238 | } |
239 | task.setOriginUser(userList.get(0).getUserId()); | 239 | task.setOriginUser(userList.get(0).getUserId()); |
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/RMFollowStrategy.java
@@ -161,7 +161,7 @@ public class RMFollowStrategy extends AbstractFollowStrategy { | @@ -161,7 +161,7 @@ public class RMFollowStrategy extends AbstractFollowStrategy { | ||
161 | @Transactional(rollbackFor = Exception.class) | 161 | @Transactional(rollbackFor = Exception.class) |
162 | public boolean origin2task(OriginalData originalData) { | 162 | public boolean origin2task(OriginalData originalData) { |
163 | Customer customer = customerService.queryById(originalData.getCustomerId()); | 163 | Customer customer = customerService.queryById(originalData.getCustomerId()); |
164 | - if (Objects.isNull(customer)) { | 164 | + if (Objects.isNull(customer) || Objects.isNull(customer.getAdviserId()) || Objects.isNull(customer.getShopId())) { |
165 | return true; | 165 | return true; |
166 | } | 166 | } |
167 | completeTask(customer, originalData.getGenerateTime()); | 167 | completeTask(customer, originalData.getGenerateTime()); |