feature(*): 续保跟进调整

- 续保跟进调整

feature(*): 续保跟进调整
- 续保跟进调整
张志伟
1 parent 2a40e3f8
Showing 4 changed files with 41 additions and 118 deletions
fw-valhalla-sdk/src/main/java/cn/fw/valhalla/sdk/result/CustomerInfoDto.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/producer/CustomerChangeProducer.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/MemberVehicleBizService.java
@@ -11,6 +11,7 @@ import java.util.Date;
  */
 @Data
 public class CustomerInfoDto {
+    public final static String TOPIC = "customer_change";
     /**
      * cusId
      */
@@ -16,13 +16,11 @@ public class CustomerChangeProducer {
     @Autowired
     private RocketMQTemplate rocketMQTemplate;
  
-    private final String TOPIC = "customer_change";
-
     @RequestMapping(value = "send")
     public void send(CustomerInfoDto customerInfoDto) {
         try {
             log.info("售后保有客信息变更mq: body:[{}]", customerInfoDto);
-            rocketMQTemplate.syncSend(TOPIC + ":*", customerInfoDto);
+            rocketMQTemplate.syncSend(CustomerInfoDto.TOPIC + ":*", customerInfoDto);
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -3,9 +3,6 @@ package cn.fw.valhalla.service.bus.cust;
 import cn.fw.common.cache.locker.DistributedLocker;
 import cn.fw.common.web.annotation.DisLock;
 import cn.fw.common.web.auth.LoginAuthBean;
-import cn.fw.data.base.domain.common.Message;
-import cn.fw.hermes.sdk.api.para.BusinessType;
-import cn.fw.hermes.sdk.api.para.MsgParamCondition;
 import cn.fw.passport.sdk.api.param.WxBCodeParam;
 import cn.fw.valhalla.common.constant.RoleCode;
 import cn.fw.valhalla.common.utils.DateUtil;
@@ -15,7 +12,6 @@ import cn.fw.valhalla.common.utils.StringUtils;
 import cn.fw.valhalla.domain.db.customer.AffiliationRecord;
 import cn.fw.valhalla.domain.db.customer.Customer;
 import cn.fw.valhalla.domain.db.customer.CustomerBaseInfo;
-import cn.fw.valhalla.domain.db.follow.FollowClue;
 import cn.fw.valhalla.domain.db.follow.FollowRecord;
 import cn.fw.valhalla.domain.db.follow.FollowRecordLog;
 import cn.fw.valhalla.domain.db.pool.PublicCluePool;
@@ -25,7 +21,6 @@ import cn.fw.valhalla.domain.enums.*;
 import cn.fw.valhalla.domain.vo.customer.CustomerChangeInfoVO;
 import cn.fw.valhalla.domain.vo.customer.CustomerChangeQrCodeVO;
 import cn.fw.valhalla.rpc.angel.dto.InsuranceDTO;
-import cn.fw.valhalla.rpc.erp.dto.PostUserDTO;
 import cn.fw.valhalla.rpc.erp.dto.UserInfoDTO;
 import cn.fw.valhalla.rpc.erp.dto.UserRoleDataRangeDTO;
 import cn.fw.valhalla.rpc.member.MemberRpcService;
@@ -186,6 +181,7 @@ public class CustomerChangeBizService extends AbstractCustomerService {
             if (Objects.isNull(customer)) {
                 customerId = addCustomer(customerByFrameNo, dto, baseId, memberId);
             } else {
+                final CustomerInfoDto customerInfoDto = new CustomerInfoDto();
                 if (Objects.nonNull(customerByFrameNo)) {
                     if (!customerByFrameNo.getId().equals(customerId)) {
                         if (customer.getGroupId().equals(groupId)) {
@@ -195,11 +191,18 @@ public class CustomerChangeBizService extends AbstractCustomerService {
                         }
                     }
                     packageCustomer(customerByFrameNo, dto, baseId);
+                    BeanUtils.copyProperties(customerByFrameNo, customerInfoDto);
+                    customerInfoDto.setConsultantId(customerByFrameNo.getAdviserId());
+                    customerInfoDto.setMemberId(memberId);
                     customerService.updateById(customerByFrameNo);
                 } else {
                     packageCustomer(customer, dto, baseId);
+                    BeanUtils.copyProperties(customer, customerInfoDto);
+                    customerInfoDto.setConsultantId(customer.getAdviserId());
+                    customerInfoDto.setMemberId(memberId);
                     customerService.updateById(customer);
                 }
+                this.customerChangeProducer.send(customerInfoDto);
             }
         }
  
@@ -380,85 +383,6 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         return updated;
     }
  
-    /**
-     * 二次分配更换跟进人
-     *
-     * @param clue
-     * @return
-     */
-    @Transactional(rollbackFor = Exception.class)
-    public StammkundePool changeFollowUser(FollowClue clue) {
-        final Customer customer = customerService.getOne(Wrappers.<Customer>lambdaQuery()
-                        .eq(Customer::getFrameNo, clue.getVin())
-                        .eq(Customer::getGroupId, clue.getGroupId())
-                        .eq(Customer::getYn, Boolean.TRUE)
-                , Boolean.FALSE
-        );
-        if (Objects.isNull(customer)) {
-            log.info("档案信息异常，vin: [{}]", clue.getVin());
-        }
-        BV.notNull(customer, () -> "档案信息不存在");
-        List<PostUserDTO> userList = userService.getUserByRole(customer.getShopId(), RoleCode.FWGW);
-
-        BV.isNotEmpty(userList, () -> String.format("更换跟进人员失败：门店[%s]没有服务顾问", customer.getShopId()));
-        Collections.shuffle(userList);
-        PostUserDTO userDTO = userList.stream()
-                .filter(u -> !u.getUserId().equals(customer.getAdviserId()))
-                .findAny()
-                .orElse(null);
-        if (Objects.isNull(userDTO)) {
-            return null;
-        }
-        AffiliationRecord entity = createEntity(customer, userDTO.getUserId(), customer.getShopId());
-        DefeatReasonEnum reasonEnum = DefeatReasonEnum.OT;
-        if (FollowTypeEnum.FM.equals(clue.getClueType())) {
-            reasonEnum = DefeatReasonEnum.FM;
-        }
-        if (FollowTypeEnum.RM.equals(clue.getClueType())) {
-            reasonEnum = DefeatReasonEnum.RM;
-        }
-        entity.setReason(reasonEnum.getName());
-        customer.setAdviserId(userDTO.getUserId());
-        customerService.updateById(customer);
-        affiliationRecordService.save(entity);
-
-        StammkundeDto stammkundeDto = new StammkundeDto();
-        stammkundeDto.setCustomerId(customer.getId());
-        stammkundeDto.setReason(reasonEnum);
-        stammkundeDto.setShopId(customer.getShopId());
-        stammkundeDto.setNewUserId(userDTO.getUserId());
-        stammkundeDto.setNewUserName(userDTO.getUserName());
-        ShopDTO shop = oopService.shop(customer.getShopId());
-        stammkundeDto.setNewShopId(customer.getShopId());
-        if (Objects.nonNull(shop)) {
-            stammkundeDto.setNewShopName(shop.getShortName());
-        }
-        stammkundeDto.setGroupId(customer.getGroupId());
-
-        StammkundePool stammkundePool = rejectAndNew(stammkundeDto);
-        stammkundePool.setSources(StammkundeSourcesEnum.REDISTRIBUTION);
-        stammkundePool.setPoolStatus(StammkundeStatusEnum.TWICE);
-        stammkundePool.setAktiv(Boolean.FALSE);
-        stammkundePool.setCreateTime(new Date());
-        stammkundePool.setGroupId(customer.getGroupId());
-        stammkundePoolService.save(stammkundePool);
-        return stammkundePool;
-    }
-
-    /**
-     * 修改档案
-     *
-     * @param customer
-     * @return
-     */
-    private Long edit(Customer customer) {
-        boolean updated = customerService.updateById(customer);
-        if (updated) {
-            customerChangeHandler(customer);
-        }
-        return customer.getId();
-    }
-
  
     private String createCode(String key, int expires, Long dealerId) {
         final WxBCodeParam param = new WxBCodeParam();
@@ -476,30 +400,6 @@ public class CustomerChangeBizService extends AbstractCustomerService {
     }
  
  
-    /**
-     * 消息发送
-     *
-     * @param targetUserId
-     * @param done
-     */
-    private void sendMsg(Long targetUserId, boolean done, String key) {
-        try {
-            String text = "档案变更通知";
-            final String msgBizType = "customerChangeStatus";
-            Map<String, Object> ext = new HashMap<>(3);
-            ext.put("type", msgBizType);
-            ext.put("done", done);
-            ext.put("key", key);
-            final MsgParamCondition msgPara = MsgParamCondition.getCustomMsg(text, "", ext,
-                    0, targetUserId, false).setBusinessType(BusinessType.INTERNAL_NOTIFICATION).build();
-            final Message<Boolean> msg = imSendMessage.synSendMsg(msgPara);
-            log.info("给[{}]推送im消息结果:[{}]", targetUserId, msg.getResult());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-
-
     private void create(Customer customer, Long adviserId, Long shopId) {
         StammkundePool stammkundePool = createSimpleInfo(customer, adviserId);
         stammkundePool.setSources(StammkundeSourcesEnum.NATURAL);
@@ -2,7 +2,10 @@ package cn.fw.valhalla.service.bus.cust;
  
 import cn.fw.common.data.mybatis.pagination.PageData;
 import cn.fw.data.base.db.query.Page;
-import cn.fw.valhalla.common.utils.*;
+import cn.fw.valhalla.common.utils.BeanUtils;
+import cn.fw.valhalla.common.utils.PageUtils;
+import cn.fw.valhalla.common.utils.StringUtils;
+import cn.fw.valhalla.component.producer.CustomerChangeProducer;
 import cn.fw.valhalla.domain.db.MemberVehicle;
 import cn.fw.valhalla.domain.db.customer.Customer;
 import cn.fw.valhalla.domain.db.customer.CustomerBaseInfo;
@@ -14,7 +17,10 @@ import cn.fw.valhalla.rpc.member.MemberRpcService;
 import cn.fw.valhalla.rpc.member.dto.MemberUserDTO;
 import cn.fw.valhalla.sdk.enums.CarUseTypeEnum;
 import cn.fw.valhalla.sdk.enums.CusTypeEnum;
-import cn.fw.valhalla.service.data.*;
+import cn.fw.valhalla.sdk.result.CustomerInfoDto;
+import cn.fw.valhalla.service.data.CustomerBaseInfoService;
+import cn.fw.valhalla.service.data.CustomerService;
+import cn.fw.valhalla.service.data.MemberVehicleService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import lombok.RequiredArgsConstructor;
@@ -23,7 +29,9 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
  
-import java.util.*;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
  
 import static cn.fw.common.businessvalidator.Validator.V;
  
@@ -46,6 +54,7 @@ public class MemberVehicleBizService {
     private final CustomerService customerService;
  
     private final CustomerBaseInfoService customerBaseInfoService;
+    private final CustomerChangeProducer customerChangeProducer;
  
     public List<MemberVehicleVO> getVehicleList(Long memberId) {
         List<MemberVehicle> memberVehicleList = memberVehicleService.list(Wrappers.<MemberVehicle>lambdaQuery()
@@ -60,7 +69,7 @@ public class MemberVehicleBizService {
  
     @Transactional(rollbackFor = Exception.class)
     public void saveVehicle(NewVehicleDTO dto) {
-        V.notNull(dto,"车辆认证信息不能为空");
+        V.notNull(dto, "车辆认证信息不能为空");
         //是否有认证车辆信息
         MemberVehicle memberVehicle = memberVehicleService.getVehicle(dto.getFrameNo());
         if (Objects.isNull(memberVehicle)) {
@@ -94,12 +103,12 @@ public class MemberVehicleBizService {
             customer.setRegDate(dto.getRegDate());
             customer.setPlateNo(dto.getPlateNo());
             customer.setUseType(CarUseTypeEnum.ofValue(dto.getUseType()));
-            if(Objects.isNull(customer.getSpecCode())){
+            if (Objects.isNull(customer.getSpecCode())) {
                 customer.setSpecCode(dto.getSpecCode());
             }
             CustomerBaseInfo customerBaseInfo = customerBaseInfoService.queryById(customer.getBaseId());
-            if (Objects.nonNull(customerBaseInfo) && Objects.equals(dto.getMemberId(),customerBaseInfo.getMemberId()) &&
-                   Objects.equals(CusTypeEnum.ofValue(dto.getCusType()),customerBaseInfo.getCusType())) {
+            if (Objects.nonNull(customerBaseInfo) && Objects.equals(dto.getMemberId(), customerBaseInfo.getMemberId()) &&
+                    Objects.equals(CusTypeEnum.ofValue(dto.getCusType()), customerBaseInfo.getCusType())) {
                 customerBaseInfo.setName(dto.getName());
                 customerBaseInfo.setContact(dto.getName());
                 customerBaseInfoService.updateById(customerBaseInfo);
@@ -117,6 +126,7 @@ public class MemberVehicleBizService {
                 customer.setBaseId(newCustomerBaseInfo.getId());
             }
             customerService.updateById(customer);
+            sendCustomerMq(customer, member.getUserId());
         });
     }
  
@@ -139,4 +149,18 @@ public class MemberVehicleBizService {
                 .eq(MemberVehicle::getId, vo.getId()));
     }
  
+    /**
+     * 发生档案更新mq
+     *
+     * @param customer
+     * @param memberId
+     */
+    private void sendCustomerMq(Customer customer, Long memberId) {
+        final CustomerInfoDto customerInfoDto = new CustomerInfoDto();
+        org.springframework.beans.BeanUtils.copyProperties(customer, customerInfoDto);
+        customerInfoDto.setConsultantId(customer.getAdviserId());
+        customerInfoDto.setMemberId(memberId);
+        customerChangeProducer.send(customerInfoDto);
+    }
+
 }