定时任务

src/main/java/com/yunzhi/marketing/entity/TaRecommendCustomer.java

@@ -151,6 +151,11 @@ public class TaRecommendCustomer implements Serializable {
 
     private LocalDateTime verifyDate;
 
+    /**
+     * 流转使劲
+     */
+    private LocalDateTime circulationTime;
+
     /**
      * 组织结构id
      */

src/main/java/com/yunzhi/marketing/job/CustomerTimeJob.java

@@ -0,0 +1,32 @@
+package com.yunzhi.marketing.job;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.marketing.common.CommConstant;
+import com.yunzhi.marketing.entity.TaRecommendCustomer;
+import com.yunzhi.marketing.service.ITaRecommendCustomerService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class CustomerTimeJob {
+
+    @Autowired
+    private ITaRecommendCustomerService taRecommendCustomerService;
+
+    //    @Scheduled(cron = "* 0/1 * * * ?")
+    private void customerTimeJob() {
+        LocalDateTime nowDate = LocalDateTime.now();
+        LocalDateTime beforeTime = nowDate.plusDays(-15);
+        LambdaQueryWrapper<TaRecommendCustomer> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.between(TaRecommendCustomer::getCirculationTime,beforeTime,nowDate);
+        queryWrapper.eq(TaRecommendCustomer::getVerifyStatus, CommConstant.VERIFY_AGREE);
+        List<TaRecommendCustomer> list = taRecommendCustomerService.list(queryWrapper);
+        list.forEach(e -> {
+            e.setBuildingId(null);
+            e.setRealtyConsultant(null);
+            e.setRecommendPerson(null);
+        });
+        taRecommendCustomerService.updateBatchById(list);
+    }
+}

src/main/java/com/yunzhi/marketing/service/impl/TaRecommendCustomerServiceImpl.java

@@ -533,6 +533,7 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
             recommendCustomer.setVerifyStatus(CommConstant.VERIFY_AGREE);
             recommendCustomer.setStatus(CommConstant.CUSTOMER_REPORT);
             recommendCustomer.setRecommendPerson(consultant.getPersonId());
+            recommendCustomer.setCirculationTime(LocalDateTime.now());
             customerFrom.setIsProjectFirst(true);
             customerFrom.setIsOrgFirst(true);
         }
@@ -1003,6 +1004,7 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
             }
         }
 
+        taRecommendCustomer.setCirculationTime(LocalDateTime.now());
         int row = taRecommendCustomerMapper.insert(taRecommendCustomer);
         if (row < 1) {
             return ResponseBean.error("报备客户失败", ResponseBean.ERROR_UNAVAILABLE);

src/main/java/com/yunzhi/marketing/xlk/service/impl/ChannelCustomerServiceImpl.java

@@ -78,6 +78,7 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
             taRecommendCustomer.setEntryType(CommConstant.ENTRY_VERIFY);
             taRecommendCustomer.setStatus(CommConstant.CUSTOMER_REPORT);
             taRecommendCustomer.setRealtyConsultant(channelCustomerDTO.getRealtyConsultant());
+            taRecommendCustomer.setCirculationTime(LocalDateTime.now());
             taRecommendCustomerMapper.insert(taRecommendCustomer);
             return ResponseBean.success("审核成功");
         }
@@ -131,6 +132,7 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
                 taRecommendCustomer.setEntryType(CommConstant.ENTRY_VERIFY);
                 taRecommendCustomer.setStatus(CommConstant.CUSTOMER_VISITE);
                 taRecommendCustomer.setRealtyConsultant(params.getRealtyConsultant());
+                taRecommendCustomer.setCirculationTime(LocalDateTime.now());
                 taRecommendCustomerMapper.insert(taRecommendCustomer);
                 return ResponseBean.success("审核成功");
             }
@@ -146,6 +148,7 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
                 recommendCustomer.setVerifyStatus(CommConstant.VERIFY_AGREE);
                 recommendCustomer.setStatus(CommConstant.CUSTOMER_VISITE);
                 recommendCustomer.setRealtyConsultant(params.getRealtyConsultant());
+                recommendCustomer.setCirculationTime(LocalDateTime.now());
                 taRecommendCustomerMapper.updateById(recommendCustomer);
                 return ResponseBean.success("审核成功");
             }
@@ -154,6 +157,7 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
             TaRecommendCustomer taRecommendCustomer = taRecommendCustomerMapper.selectById(params.getId());
             taRecommendCustomer.setVerifyStatus(CommConstant.VERIFY_AGREE);
             taRecommendCustomer.setStatus(CommConstant.CUSTOMER_VISITE);
+            taRecommendCustomer.setCirculationTime(LocalDateTime.now());
             taRecommendCustomerMapper.updateById(taRecommendCustomer);
             return ResponseBean.success("审核成功");
         }