feature(*): 公共池完成逻辑

- 公共池完成逻辑

feature(*): 公共池完成逻辑
- 公共池完成逻辑
张志伟
1 parent 2fcb1932
Showing 5 changed files with 139 additions and 4 deletions
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/PubFollowTask.java
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/PubStandTask.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/follow/strategy/impl/PubFollowStrategy.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/pub/PubFollowBizService.java
@@ -11,6 +11,7 @@ import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.data.redis.core.BoundListOperations;
 import org.springframework.data.redis.core.BoundSetOperations;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -40,6 +41,10 @@ public class PubFollowTask {
     @Getter(AccessLevel.PRIVATE)
     private String roleChangeNeedCloseClueKey;
  
+    @Value("${spring.cache.custom.global-prefix}:pub-clue:complete")
+    @Getter(AccessLevel.PRIVATE)
+    private String pubClueCompleteKey;
+
     public PubFollowTask(final StringRedisTemplate stringRedisTemplate,
                          final PubFollowBizService pubFollowBizService,
                          final PubCluePoolService pubCluePoolService) {
@@ -67,6 +72,33 @@ public class PubFollowTask {
     }
  
     /**
+     * 关闭线索
+     */
+    @Scheduled(initialDelay = 1000 * 10, fixedRate = 1000 * 10)
+    public void closeClue() {
+        BoundListOperations<String, String> listOps = stringRedisTemplate.boundListOps(getPubClueCompleteKey());
+        List<String> failList = new ArrayList<>();
+        String idStr;
+        while ((idStr = listOps.leftPop()) != null) {
+            if (!StringUtils.isEmpty(idStr)) {
+                continue;
+            }
+            try {
+                pubFollowBizService.closeClue(idStr);
+            } catch (Exception e) {
+                if (StringUtils.isValid(idStr)) {
+                    failList.add(idStr);
+                }
+                log.error("处理关闭公共池线索失败", e);
+            }
+        }
+        if (!CollectionUtils.isEmpty(failList)) {
+            String[] idArr = failList.toArray(new String[0]);
+            listOps.rightPushAll(idArr);
+        }
+    }
+
+    /**
      * 处理角色变动战败公共池跟进线索
      */
     @Scheduled(cron = "0/20 * * * * *")
@@ -61,7 +61,7 @@ public class PubStandTask {
     /**
      * 执行分配
      */
-    @Scheduled(initialDelay = 1000 * 10, fixedRate = 1000 * 5)
+    @Scheduled(initialDelay = 1000 * 10, fixedRate = 1000 * 8)
     public void distributeBatch() {
         List<GroupDTO> groups = oopService.allGroup();
         for (GroupDTO group : groups) {
 package cn.fw.valhalla.service.bus.cust;
  
 import cn.fw.common.cache.locker.DistributedLocker;
+import cn.fw.common.constant.CommonConstant;
 import cn.fw.common.web.annotation.DisLock;
 import cn.fw.common.web.auth.LoginAuthBean;
 import cn.fw.passport.sdk.api.param.WxBCodeParam;
@@ -37,11 +38,14 @@ import cn.fw.valhalla.service.data.FollowRecordService;
 import cn.fw.valhalla.service.data.PublicPoolService;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import lombok.AccessLevel;
+import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.tuple.Pair;
 import org.redisson.api.RLock;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -78,6 +82,10 @@ public class CustomerChangeBizService extends AbstractCustomerService {
     private final FollowRecordLogService followRecordLogService;
     private final CommonService commonService;
  
+    @Value("${spring.cache.custom.global-prefix}:pub-clue:complete")
+    @Getter(AccessLevel.PRIVATE)
+    private String pubClueCompleteKey;
+
     /**
      * 生成档案变更二维码
      *
@@ -298,6 +306,15 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         if (CollectionUtils.isEmpty(dataRange) || Objects.isNull(dataRange.get(0).getRangeValue())) {
             return true;
         }
+        String sb = customer.getFrameNo() +
+                CommonConstant.Symbol.AT +
+                adviserId +
+                CommonConstant.Symbol.AT +
+                customer.getGroupId() +
+                CommonConstant.Symbol.AT +
+                dataRange.get(0).getRangeValue();
+        stringRedisTemplate.opsForList().rightPush(getPubClueCompleteKey(), sb);
+
         if (adviserId.equals(customer.getAdviserId())) {
             StammkundePool stammkundePool = stammkundePoolService.queryAktivAble(customer.getId(), customer.getGroupId(), customer.getShopId());
             if (Objects.nonNull(stammkundePool)) {
@@ -517,7 +534,7 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         customer.setSource(SourceTypeEnum.TO_SHOP);
         customer.setYn(Boolean.TRUE);
         customer.setGroupId(dto.getGroupId());
-        if(Objects.isNull(customer.getBuyDate())){
+        if (Objects.isNull(customer.getBuyDate())) {
             customer.setBuyDate(dto.getRegDate());
         }
     }
@@ -10,6 +10,8 @@ import cn.fw.valhalla.domain.db.pub.PubCluePool;
 import cn.fw.valhalla.domain.dto.CustomerDetailDto;
 import cn.fw.valhalla.domain.enums.*;
 import cn.fw.valhalla.domain.vo.setting.SettingVO;
+import cn.fw.valhalla.rpc.ehr.EhrRpcService;
+import cn.fw.valhalla.rpc.ehr.dto.StaffInfoDTO;
 import cn.fw.valhalla.rpc.oop.OopService;
 import cn.fw.valhalla.rpc.oop.dto.ShopDTO;
 import cn.fw.valhalla.rpc.shirasawa.ShirasawaRpcService;
@@ -50,6 +52,7 @@ public class PubFollowStrategy implements FollowStrategy {
     private final ShirasawaRpcService shirasawaRpcService;
     private final OopService oopService;
     private final SettingBizService settingBizService;
+    private final EhrRpcService ehrRpcService;
  
     @Autowired
     public PubFollowStrategy(final PubCluePoolService pubCluePoolService,
@@ -57,13 +60,15 @@ public class PubFollowStrategy implements FollowStrategy {
                              final CustomerBizService customerBizService,
                              final ShirasawaRpcService shirasawaRpcService,
                              final OopService oopService,
-                             final SettingBizService settingBizService) {
+                             final SettingBizService settingBizService,
+                             final EhrRpcService ehrRpcService) {
         this.pubCluePoolService = pubCluePoolService;
         this.clueTaskService = clueTaskService;
         this.customerBizService = customerBizService;
         this.shirasawaRpcService = shirasawaRpcService;
         this.oopService = oopService;
         this.settingBizService = settingBizService;
+        this.ehrRpcService = ehrRpcService;
     }
  
     @Override
@@ -103,7 +108,7 @@ public class PubFollowStrategy implements FollowStrategy {
         // 公共池线索不存在这种场景
     }
  
-
+    @Transactional(rollbackFor = Exception.class)
     public void startClue(final PubCluePool pubClue) {
         ClueTask clueTask = new ClueTask();
         clueTask.setClueId(pubClue.getId());
@@ -121,6 +126,51 @@ public class PubFollowStrategy implements FollowStrategy {
         shirasawaRpcService.createFollowData(followInitDTO);
     }
  
+    @Transactional(rollbackFor = Exception.class)
+    public void clueConvertSuccess(final PubCluePool pubClue) {
+        pubClue.setState(PublicClueStateEnum.COMPLETE);
+        pubClue.setCloseTime(LocalDateTime.now());
+
+        ClueTask clueTask = clueTaskService.queryOngoingTaskByClueId(pubClue.getId());
+        if (Objects.nonNull(clueTask)) {
+            clueTask.setCloseTime(LocalDateTime.now());
+            clueTask.setFinishUser(pubClue.getAdviserId());
+            StaffInfoDTO infoDTO = ehrRpcService.queryStaffInfo(pubClue.getAdviserId());
+            if (Objects.nonNull(infoDTO)) {
+                clueTask.setFinishUserName(infoDTO.getName());
+            }
+            clueTask.setState(TaskStateEnum.COMPLETE);
+            clueTask.setFinishShop(pubClue.getShopId());
+            boolean rpcSucess = rpcStopTask(clueTask);
+            clueTask.setRpcSuccess(rpcSucess);
+            clueTaskService.updateById(clueTask);
+        }
+        pubCluePoolService.updateById(pubClue);
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public void clueConvertFailed(final PubCluePool pubClue, Long userId, Long shopId) {
+        pubClue.setState(PublicClueStateEnum.DEFEAT);
+        pubClue.setCloseTime(LocalDateTime.now());
+
+        ClueTask clueTask = clueTaskService.queryOngoingTaskByClueId(pubClue.getId());
+        if (Objects.nonNull(clueTask)) {
+            clueTask.setCloseTime(LocalDateTime.now());
+            clueTask.setFinishUser(pubClue.getAdviserId());
+            StaffInfoDTO infoDTO = ehrRpcService.queryStaffInfo(userId);
+            if (Objects.nonNull(infoDTO)) {
+                clueTask.setFinishUserName(infoDTO.getName());
+            }
+            clueTask.setState(TaskStateEnum.DEFEAT);
+            clueTask.setReason(TaskDefeatTypeEnum.F);
+            clueTask.setFinishShop(shopId);
+            boolean rpcSucess = rpcStopTask(clueTask);
+            clueTask.setRpcSuccess(rpcSucess);
+            clueTaskService.updateById(clueTask);
+        }
+        pubCluePoolService.updateById(pubClue);
+    }
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void onRoleChangeCloseTask(final ClueTask task) {
 package cn.fw.valhalla.service.bus.pub;
  
+import cn.fw.common.constant.CommonConstant;
 import cn.fw.valhalla.common.utils.StringUtils;
 import cn.fw.valhalla.domain.db.customer.Customer;
 import cn.fw.valhalla.domain.db.customer.CustomerBaseInfo;
@@ -117,6 +118,41 @@ public class PubFollowBizService {
     }
  
     /**
+     * 关闭线索
+     *
+     * @param str
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void closeClue(String str) {
+        String[] dataArr = str.split(CommonConstant.Symbol.AT);
+        if (dataArr.length < 4) {
+            log.info("关闭公共池线索失败：{}", str);
+            return;
+        }
+        String vin = dataArr[0];
+        Long adviserId = Long.parseLong(dataArr[1]);
+        Long groupId = Long.parseLong(dataArr[2]);
+        Long shopId = Long.parseLong(dataArr[3]);
+
+        PubCluePool pool = pubCluePoolService.getOne(Wrappers.<PubCluePool>lambdaQuery()
+                        .eq(PubCluePool::getVin, vin)
+                        .eq(PubCluePool::getGroupId, groupId)
+                        .eq(PubCluePool::getState, PublicClueStateEnum.ONGOING)
+                , Boolean.FALSE
+        );
+
+        if (Objects.isNull(pool)) {
+            return;
+        }
+        if (pool.getAdviserId().equals(adviserId)) {
+            pubFollowStrategy.clueConvertSuccess(pool);
+            return;
+        }
+        pubFollowStrategy.clueConvertFailed(pool, adviserId, shopId);
+
+    }
+
+    /**
      * 查询最近分配的20条线索
      *
      * @param userId