优化角色变动分配算法

张志伟
1 parent 740805dc
Showing 1 changed file with 14 additions and 3 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/LeaveNeedDoBizService.java
@@ -12,6 +12,7 @@ import cn.fw.valhalla.common.constant.RoleCode;
 import cn.fw.valhalla.common.utils.DateUtil;
 import cn.fw.valhalla.domain.db.LeaveNeedDo;
 import cn.fw.valhalla.domain.db.customer.Customer;
+import cn.fw.valhalla.domain.db.follow.FollowRecord;
 import cn.fw.valhalla.domain.db.follow.FollowTask;
 import cn.fw.valhalla.domain.db.pool.CustomerCluePool;
 import cn.fw.valhalla.domain.db.pool.StammkundePool;
@@ -397,9 +398,13 @@ public class LeaveNeedDoBizService {
         task.setCloseTime(new Date());
         task.setState(TaskStateEnum.DEFEAT);
         task.setReason(TaskDefeatTypeEnum.D);
+        FollowRecord taskRecord = followRecordService.getOne(Wrappers.<FollowRecord>lambdaQuery()
+                .eq(FollowRecord::getTaskId, task.getId())
+                .eq(FollowRecord::getAddTodo, Boolean.FALSE)
+                .isNull(FollowRecord::getFollowTime)
+                .last(" limit 1")
+        );
         followTaskService.updateById(task);
-        followRecordService.removeByTaskId(task.getId());
-
         if (Boolean.TRUE.equals(task.getRedistribution())) {
             clue.setCloseTime(new Date());
             clue.setClueStatus(ClueStatusEnum.FAILURE);
@@ -407,7 +412,6 @@ public class LeaveNeedDoBizService {
         } else {
             clue.setRedistribution(Boolean.TRUE);
         }
-
         FollowTask nTask = new FollowTask();
         nTask.setClueId(clue.getId());
         nTask.setCustomerId(clue.getRefererId());
@@ -421,6 +425,13 @@ public class LeaveNeedDoBizService {
         nTask.setFollowShop(shopId);
         nTask.setGroupId(clue.getGroupId());
         followTaskService.save(nTask);
+        if (Objects.nonNull(taskRecord)) {
+            taskRecord.setTaskId(nTask.getId());
+            taskRecord.setUserId(nTask.getFollowUser());
+            taskRecord.setUserName(nTask.getFollowUserName());
+            followRecordService.updateById(taskRecord);
+            return;
+        }
         followBizService.startTask(nTask);
     }