bug

src/main/java/com/huiju/estateagents/controller/MiniAppController.java

@@ -199,15 +199,21 @@ public class MiniAppController extends BaseController {
             personQueryWrapper.eq("org_id",orgId);
             int count = taPersonService.count(personQueryWrapper);
 
-            if(null!=from&&from.contains("share") && StringUtils.isNotBlank(recommender) && count>0){
-                // 添加积分
-                 applicationContext.publishEvent(new EventBus(recommender, EventBus.EventType.SharePosterAll, orgId));
-            }
-
             TaPerson taPerson = taPersonService.newPersonByOpenid(session.getOpenid(), orgId);
             if (null == taPerson) {
                 return ResponseBean.error("发生未知错误", ResponseBean.ERROR_UNAVAILABLE);
             }
+
+            if(null!=from&&from.contains("share") && StringUtils.isNotBlank(recommender) && count>0){
+                // 校验是否点击过此人的分享
+                boolean checkPoint = checkSharePersonFrom(from,taPerson.getPersonId(),targetId,orgId);
+                if (checkPoint){
+                    // 添加积分
+                    applicationContext.publishEvent(new EventBus(recommender, EventBus.EventType.SharePosterAll, orgId));
+                }
+            }
+
+
             Map<Object,Object> map = new HashMap<>();
             map.put("openId",session.getOpenid());
             map.put("orgId",orgId);
@@ -322,6 +328,19 @@ public class MiniAppController extends BaseController {
         }
     }
 
+    private boolean checkSharePersonFrom(String from, String personId, String targetId, Integer orgId) {
+        QueryWrapper<TaSharePersonFrom> queryWrapper =  new QueryWrapper<>();
+        queryWrapper.eq("target_type",from);
+        queryWrapper.eq("person_id",personId);
+        queryWrapper.eq("target_id",targetId);
+        queryWrapper.eq("org_id",orgId);
+        List<TaSharePersonFrom> list = taSharePersonFromService.list(queryWrapper);
+        if (list.size() > 0){
+            return false;
+        }
+        return true;
+    }
+
     /**
      * 登陆接口
      */

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

@@ -109,17 +109,13 @@ public class TaPointsRecordsServiceImpl extends ServiceImpl<TaPointsRecordsMappe
 			return;
 		}
 
-		// 发放积分
-		TaPerson person = taPersonMapper.selectById(recommenderId);
 		String[] params = {
 				"openUser="+recommenderId
 		};
 		String changeParams = String.join("&", params);
-		boolean hasJoined = isPointsRecordsExist(person.getPersonId(), changeType, changeParams);
-		if (hasJoined) {
-			return;
-		}
 
+		// 发放积分
+		TaPerson person = taPersonMapper.selectById(recommenderId);
 		if (savePoints(person, changeType, changeParams, pointsAmount, orgId)) {
 			taPersonMapper.setFieldIncrement(person.getPersonId(), "points", pointsAmount);
 		}