发放积分

src/main/java/com/huiju/estateagents/service/impl/TaPersonServiceImpl.java

         }
 
         iTaRecommendCustomerService.newByPerson(person);
-
-        //查看是否领取过授权积分
-        QueryWrapper<TaPointsRecords> taPointsRecordsQueryWrapper = new QueryWrapper<>();
-        taPointsRecordsQueryWrapper.eq("person_id", person.getPersonId());
-        taPointsRecordsQueryWrapper.eq("change_type",CommConstant.POINTS_AUTHORIZE);
-
-        List<TaPointsRecords> taPointsRecordsList = taPointsRecordsMapper.selectList(taPointsRecordsQueryWrapper);
-        if (taPointsRecordsList.size() < 1){
-            //发放积分(成为经纪人ID 是4)
-            applicationContext.publishEvent(new PointsEvent(person.getPersonId(),CommConstant.POINTS_AUTHORIZE));
-        }
-
+        
+        //发放积分(成为经纪人ID 是4)
+        applicationContext.publishEvent(new PointsEvent(person.getPersonId(),CommConstant.POINTS_AUTHORIZE));
+        
         return person;
     }
 

src/main/java/com/huiju/estateagents/service/impl/TaPointsRecordsServiceImpl.java

 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Map;
 
 /**
 	
 	@Override
 	public void authPoints(String personId) {
-		TaPerson person = taPersonMapper.selectById(personId);
-		sendPoints(person,4,CommConstant.POINTS_AUTHORIZE);
+		//查看是否领取过授权积分
+		QueryWrapper<TaPointsRecords> taPointsRecordsQueryWrapper = new QueryWrapper<>();
+		taPointsRecordsQueryWrapper.eq("person_id", personId);
+		taPointsRecordsQueryWrapper.eq("change_type",CommConstant.POINTS_AUTHORIZE);
+		
+		List<TaPointsRecords> taPointsRecordsList = taPointsRecordsMapper.selectList(taPointsRecordsQueryWrapper);
+		if (taPointsRecordsList.size() < 1){
+			TaPerson person = taPersonMapper.selectById(personId);
+			sendPoints(person,4,CommConstant.POINTS_AUTHORIZE);
+		}
 	}
 	
 	private void sendPoints(TaPerson person,Integer rulesId,String shareType) {