新增手动运维的接口

张志伟
1 parent 9612b098
Showing 4 changed files with 140 additions and 87 deletions
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/app/CommonController.java
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowTaskDealTask.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/CommonService.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/IRFollowStrategy.java
@@ -25,6 +25,7 @@ import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.util.Date;
 import java.util.List;
+import java.util.Objects;
  
 import static cn.fw.common.web.util.ResultBuilder.success;
  
@@ -108,10 +109,22 @@ public class CommonController {
         return success();
     }
  
-    @PutMapping("/create/next-clue")
+    @PutMapping("/clue/manual/create")
     @Authorization(AuthType.NONE)
-    @ControllerMethod("处理过期续保")
-    public Message<Integer> createNextClue() {
-        return success(commonService.createClue());
+    @ControllerMethod("处理续保数据缺失")
+    public Message<Integer> createNextClue(Long groupId) {
+        if (Objects.isNull(groupId)) {
+            groupId = 2L;
+        }
+        commonService.createClue(groupId);
+        return success();
+    }
+
+    @PutMapping("/clue/manual/start")
+    @Authorization(AuthType.NONE)
+    @ControllerMethod("手动开始任务")
+    public Message<Integer> manualStartClue() {
+        commonService.startClue();
+        return success();
     }
 }
@@ -48,7 +48,7 @@ public class FollowTaskDealTask {
     public void startClue() {
         List<FollowClue> list = followClueService.list(Wrappers.<FollowClue>lambdaQuery()
                 .eq(FollowClue::getClueState, ClueStatusEnum.WAITING)
-                .ge(FollowClue::getStartTime, DateUtil.localDateTime2Date(LocalDate.now().atStartOfDay()))
+                .ge(FollowClue::getStartTime, DateUtil.localDateTime2Date(LocalDate.now().minusDays(1L).atTime(23, 59, 59)))
                 .le(FollowClue::getStartTime, DateUtil.localDateTime2Date(LocalDateTime.now()))
                 .last("limit 0, 500")
         );
@@ -3,35 +3,40 @@ package cn.fw.valhalla.service.bus;
 import cn.fw.common.util.ValidationUtils;
 import cn.fw.valhalla.common.constant.RoleCode;
 import cn.fw.valhalla.common.utils.DateUtil;
+import cn.fw.valhalla.domain.db.OriginalData;
 import cn.fw.valhalla.domain.db.customer.AccidentPool;
 import cn.fw.valhalla.domain.db.customer.Customer;
 import cn.fw.valhalla.domain.db.customer.CustomerBaseInfo;
-import cn.fw.valhalla.domain.db.pool.CustomerCluePool;
+import cn.fw.valhalla.domain.db.follow.FollowClue;
 import cn.fw.valhalla.domain.db.pool.StammkundePool;
 import cn.fw.valhalla.domain.enums.ClueStatusEnum;
 import cn.fw.valhalla.domain.enums.FollowTypeEnum;
+import cn.fw.valhalla.domain.enums.SettingTypeEnum;
 import cn.fw.valhalla.domain.enums.StammkundeStatusEnum;
 import cn.fw.valhalla.domain.vo.PostUserVO;
+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.erp.UserService;
 import cn.fw.valhalla.rpc.erp.dto.PostUserDTO;
 import cn.fw.valhalla.rpc.pstn.PstnService;
+import cn.fw.valhalla.sdk.enums.DataTypeEnum;
 import cn.fw.valhalla.service.bus.cust.CustomerChangeBizService;
+import cn.fw.valhalla.service.bus.follow.FollowBizService;
+import cn.fw.valhalla.service.bus.setting.SettingBizService;
 import cn.fw.valhalla.service.data.*;
+import cn.hutool.core.collection.ListUtil;
+import cn.hutool.core.map.MapUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
  
 import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
-import java.util.Random;
+import java.time.LocalDateTime;
+import java.util.*;
  
 import static cn.fw.common.businessvalidator.Validator.BV;
  
@@ -53,7 +58,20 @@ public class CommonService {
     private final EhrRpcService ehrRpcService;
     private final AccidentPoolService accidentPoolService;
     private final CustomerChangeBizService customerChangeBizService;
-    private final CustomerCluePoolService customerCluePoolService;
+    private final FollowClueService followClueService;
+    private final FollowBizService followBizService;
+    private final OriginalDataService originalDataService;
+    private final SettingBizService settingBizService;
+    Map<Long, List<Integer>> map = MapUtil.builder(new HashMap<Long, List<Integer>>())
+            .put(-1L, ListUtil.toList(67, 65, 66))
+            .put(28L, ListUtil.toList(67, 70, 79, 66, 65, 73, 69))
+            .put(29L, ListUtil.toList(79, 69, 66, 70, 65, 73, 147, 67))
+            .put(30L, ListUtil.toList(67))
+            .put(59L, ListUtil.toList(161, 159, 66))
+            .put(148L, ListUtil.toList(159))
+            .put(175L, ListUtil.toList(67))
+            .put(180L, ListUtil.toList(66, 67, 79, 65, 70, 69))
+            .build();
  
  
     public List<PostUserVO> getUsers(final Long shopId) {
@@ -121,89 +139,111 @@ public class CommonService {
         return virtualNumber;
     }
  
-    @Transactional(rollbackFor = Exception.class)
-    public int createClue() {
-        List<CustomerCluePool> list = customerCluePoolService.list(Wrappers.<CustomerCluePool>lambdaQuery()
-                .eq(CustomerCluePool::getClueType, FollowTypeEnum.IR)
-                .in(CustomerCluePool::getClueStatus, ClueStatusEnum.FAILURE, ClueStatusEnum.COMPLETE)
-                .lt(CustomerCluePool::getUpdateTime, DateUtil.localDate2Date(LocalDate.now()))
-                .ne(CustomerCluePool::getGroupId, 1L)
-                .last(" limit 2000")
+    /**
+     * 手动开始任务
+     */
+    public void startClue() {
+        List<FollowClue> list = followClueService.list(Wrappers.<FollowClue>lambdaQuery()
+                .eq(FollowClue::getClueState, ClueStatusEnum.WAITING)
+                .le(FollowClue::getStartTime, DateUtil.localDateTime2Date(LocalDateTime.now()))
+                .last("limit 0, 2000")
         );
         if (CollectionUtils.isEmpty(list)) {
-            return 0;
+            return;
+        }
+        for (FollowClue cluePool : list) {
+            followBizService.startClue(cluePool);
         }
+    }
  
-        Long[] shopArr = new Long[]{65L, 66L, 67L};
-        String[] shopNameArr = new String[]{"宁夏瑞静售后店", "宁夏翔之星售后店", "贺兰捷联售后店"};
-
-        for (int i = 0; i < list.size(); i++) {
-            CustomerCluePool pool = list.get(i);
-            Long customerId = pool.getRefererId();
-            int count = customerCluePoolService.count(Wrappers.<CustomerCluePool>lambdaQuery()
-                    .eq(CustomerCluePool::getClueType, FollowTypeEnum.IR)
-                    .eq(CustomerCluePool::getRefererId, customerId)
-                    .in(CustomerCluePool::getClueStatus, ClueStatusEnum.WAITING, ClueStatusEnum.ONGOING));
-            if (count > 0) {
-                continue;
-            }
-            Customer customer = customerService.queryById(customerId);
-            if (Objects.isNull(customer)) {
-                continue;
-            }
-            Long shopId = pool.getOriginalShopId();
-            String shopName = pool.getOriginalShopName();
-            if (Long.valueOf(146L).equals(shopId)) {
-                shopId = shopArr[i % 3];
-                shopName = shopNameArr[i % 3];
-            }
-            CustomerCluePool customerCluePool = new CustomerCluePool();
-            List<PostUserDTO> dtoList = userService.getUserByRole(shopId, RoleCode.XBGJ);
-            BV.isNotEmpty(dtoList, "门店[" + shopId + "]没有续保跟进人员");
-            int index = new Random().nextInt(dtoList.size());
-            PostUserDTO userDTO = dtoList.get(index);
-            BeanUtils.copyProperties(pool, customerCluePool);
-            customerCluePool.setId(null);
-            customerCluePool.setOriginalUserId(userDTO.getUserId());
-            customerCluePool.setOriginalUserName(userDTO.getUserName());
-            customerCluePool.setOriginalShopId(shopId);
-            customerCluePool.setOriginalShopName(shopName);
-            customerCluePool.setClueStatus(ClueStatusEnum.WAITING);
-            customerCluePool.setRedistribution(Boolean.FALSE);
-            customerCluePool.setClueType(FollowTypeEnum.IR);
-            customerCluePool.setFinishShopId(null);
-            customerCluePool.setFinishShopName(null);
-            customerCluePool.setFinishUserId(null);
-            customerCluePool.setFinishUserName(null);
-            customerCluePool.setCreateTime(null);
-            customerCluePool.setUpdateTime(null);
-
-            LocalDate addTime = DateUtil.date2LocalDate(pool.getAddTime());
-            while (!addTime.minusDays(40L).isAfter(LocalDate.now())) {
-                addTime = addTime.plusYears(1L);
-            }
+    public void createClue(Long groupId) {
+        int count = customerService.count(Wrappers.<Customer>lambdaQuery()
+                .eq(Customer::getGroupId, groupId)
+                .eq(Customer::getYn, Boolean.TRUE)
+        );
+        if (count <= 0) {
+            return;
+        }
+        List<Customer> list = customerService.list(Wrappers.<Customer>lambdaQuery()
+                .eq(Customer::getGroupId, groupId)
+                .eq(Customer::getYn, Boolean.TRUE)
+        );
+        for (Customer customer : list) {
+            createClue(customer);
+        }
+    }
  
-            customerCluePool.setStartTime(DateUtil.localDate2Date(addTime.minusDays(40L)));
-            customerCluePool.setAddTime(DateUtil.localDate2Date(addTime));
-            customerCluePool.setDeadline(DateUtil.localDate2Date(addTime));
-            customerCluePool.setCloseTime(null);
-            customerCluePoolService.save(customerCluePool);
+    @Transactional(rollbackFor = Exception.class)
+    public void createClue(Customer customer) {
+        String day = DateUtil.getStringDateShort(new Date());
+        Long customerId = customer.getId();
+        Long shopId = customer.getShopId();
+        Long adviserId = customer.getAdviserId();
+
+        String vin = customer.getFrameNo();
+        ArrayList<ClueStatusEnum> statusEnums = ListUtil.toList(ClueStatusEnum.WAITING, ClueStatusEnum.ONGOING);
+        int count = followClueService.count(Wrappers.<FollowClue>lambdaQuery()
+                .eq(FollowClue::getClueType, FollowTypeEnum.IR)
+                .eq(FollowClue::getVin, vin)
+                .in(FollowClue::getClueState, statusEnums)
+        );
+        if (count > 0) {
+            return;
         }
  
-        customerCluePoolService.updateBatchById(list);
-        return list.size();
+        OriginalData originalData = originalDataService.getOne(Wrappers.<OriginalData>lambdaQuery()
+                .eq(OriginalData::getType, DataTypeEnum.BI)
+                .eq(OriginalData::getCustomerId, customerId)
+                .orderByDesc(OriginalData::getCreateTime)
+                .last(" limit 1 ")
+        );
+        LocalDate generateTime = generateTime(originalData, customer);
+        if (Objects.isNull(generateTime)) {
+            return;
+        }
+        OriginalData data = new OriginalData();
+        data.setType(DataTypeEnum.BI);
+        data.setCustomerId(customerId);
+        data.setPlateNo(customer.getPlateNo());
+        data.setFrameNo(customer.getFrameNo());
+        if (Objects.nonNull(shopId)) {
+            data.setUserId(adviserId);
+            data.setShopId(shopId);
+        } else {
+            Long brandId = Optional.ofNullable(customer.getBrandId()).orElse(-1L);
+            List<Integer> list = map.get(brandId);
+            int randomIndex = new Random().nextInt(list.size());
+            data.setShopId(Long.valueOf(list.get(randomIndex)));
+        }
+        data.setGenerateTime(DateUtil.localDate2Date(generateTime));
+        data.setDetailId(customer.getPlateNo() + "_" + day);
+        data.setSolved(false);
+        data.setGroupId(customer.getGroupId());
+        originalDataService.save(data);
     }
  
-    private String getRoleCode(FollowTypeEnum followTypeEnum) {
-        switch (followTypeEnum) {
-            case AC:
-                return RoleCode.SGCGJ;
-            case IR:
-                return RoleCode.XBGJ;
-            case FM:
-            case RM:
-            default:
-                return RoleCode.FWGW;
+    private LocalDate generateTime(OriginalData originalData, Customer customer) {
+        LocalDate generateTime;
+        if (Objects.nonNull(originalData)) {
+            generateTime = DateUtil.date2LocalDate(originalData.getGenerateTime());
+        } else {
+            Date date = customer.getInsuranceExpires();
+            if (Objects.isNull(date)) {
+                date = Objects.isNull(customer.getBuyDate()) ? customer.getRegDate() : customer.getBuyDate();
+            }
+            if (Objects.isNull(date)) {
+                return null;
+            }
+            generateTime = DateUtil.date2LocalDate(date);
+        }
+        Optional<SettingVO> settingVO = settingBizService.querySettingByType(FollowTypeEnum.IR, SettingTypeEnum.FIRST_TRIGGER_TIME, customer.getGroupId(), null);
+        if (!settingVO.isPresent()) {
+            return null;
+        }
+        int detailValue = Optional.ofNullable(settingVO.get().getDetailValue()).orElse(0);
+        while (!generateTime.minusDays(detailValue).isAfter(LocalDate.now().minusDays(4L))) {
+            generateTime = generateTime.plusYears(1L);
         }
+        return generateTime;
     }
 }
@@ -84,7 +84,7 @@ public class IRFollowStrategy extends AbstractFollowStrategy {
             return;
         }
         Customer customer = customerService.queryByFrameNo(followClue.getVin(), followClue.getGroupId());
-        if (Objects.isNull(customer) || Objects.isNull(customer.getAdviserId())) {
+        if (Objects.isNull(customer)) {
             followClueService.removeById(followClue.getId());
             return;
         }