Commit 9307577e7b0228e6c7bf059e5a31b4ea60dfa614
1 parent
81ad74fd
v1.1.0 首保线索处理优化
Showing
1 changed file
with
7 additions
and
5 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
... | ... | @@ -297,12 +297,14 @@ public class CustomerChangeBizService extends AbstractCustomerService { |
297 | 297 | AffiliationRecord entity = createEntity(customer, adviserId, shopId); |
298 | 298 | entity.setReason(DefeatReasonEnum.SYS.getName()); |
299 | 299 | affiliationRecordService.save(entity); |
300 | - | |
301 | - StammkundePool pool = stammkundePoolService.queryAktivAble(customer.getId(), customer.getGroupId(), customer.getShopId()); | |
300 | + StammkundePool pool = stammkundePoolService.getOne(Wrappers.<StammkundePool>lambdaQuery() | |
301 | + .eq(StammkundePool::getCustomerId, customer.getId()) | |
302 | + .eq(StammkundePool::getGroupId, customer.getGroupId()) | |
303 | + .eq(StammkundePool::getAdviserId, customer.getAdviserId()) | |
304 | + .eq(StammkundePool::getAktiv, Boolean.TRUE) | |
305 | + ); | |
302 | 306 | if (Objects.nonNull(pool)) { |
303 | - stammkundePoolService.aktiv(pool.getId()); | |
304 | - } else { | |
305 | - create(customer, adviserId, false); | |
307 | + stammkundePoolService.reject(customer.getId(), customer.getGroupId()); | |
306 | 308 | } |
307 | 309 | } |
308 | 310 | if (Objects.isNull(customer.getAdviserId()) && Objects.isNull(customer.getShopId())) { | ... | ... |