查询职业为学生的改为从库

src/main/java/cn/quantgroup/xyqb/service/user/IUserExtInfoService.java

 package cn.quantgroup.xyqb.service.user;
 
+import cn.quantgroup.user.enums.OccupationEnum;
 import cn.quantgroup.xyqb.entity.UserExtInfo;
 
+import java.sql.Timestamp;
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -13,5 +16,7 @@ public interface IUserExtInfoService {
 
     UserExtInfo save(UserExtInfo info);
 
+    List<UserExtInfo> findByCreatedAtAfterAndCreatedAtBeforeAndOccupationEnum(Timestamp start, Timestamp end);
+
 
 }

src/main/java/cn/quantgroup/xyqb/service/user/impl/CleanDataServiceImp.java

@@ -80,7 +80,7 @@ public class CleanDataServiceImp implements CleanDataService {
                 Timestamp end = new Timestamp(calendar.getTime().getTime());
 
 
-                List<UserExtInfo> list = userExtInfoRepository.findByCreatedAtAfterAndCreatedAtBeforeAndOccupationEnum(start, end, OccupationEnum.STUDENT);
+                List<UserExtInfo> list = iUserExtInfoService.findByCreatedAtAfterAndCreatedAtBeforeAndOccupationEnum(start, end);
 
                 if (!CollectionUtils.isEmpty(list)) {
                     for (UserExtInfo userExtInfo : list) {

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserExtInfoServiceImpl.java

 package cn.quantgroup.xyqb.service.user.impl;
 
+import cn.quantgroup.tech.db.DSType;
+import cn.quantgroup.tech.db.TargetDataSource;
 import cn.quantgroup.user.enums.OccupationEnum;
 import cn.quantgroup.xyqb.entity.UserExtInfo;
 import cn.quantgroup.xyqb.repository.IUserExtInfoRepository;
@@ -42,4 +44,10 @@ public class UserExtInfoServiceImpl implements IUserExtInfoService {
     public UserExtInfo save(UserExtInfo info) {
         return userExtInfoRepository.save(info);
     }
+
+    @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
+    public List<UserExtInfo> findByCreatedAtAfterAndCreatedAtBeforeAndOccupationEnum(Timestamp start, Timestamp end) {
+        return userExtInfoRepository.findByCreatedAtAfterAndCreatedAtBeforeAndOccupationEnum(start, end, OccupationEnum.STUDENT);
+    }
 }