积分规则触发

yudao-module-member/yudao-module-member-impl/src/main/java/cn/iocoder/yudao/module/member/mq/consumer/score/core/RecommendStrategy.java

@@ -55,7 +55,7 @@ public class RecommendStrategy extends AbstractScoreRuleStrategy {
             map.put("userId", userId);
             map.put("userNameZh", message.getUserNameZh());
             map.put("userNameEn", message.getUserNameEn());
-            String desensitizedPhoneNumber = message.getPhone().replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2");
+            String desensitizedPhoneNumber = memberUserDO.getMobile().replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2");
             map.put("phone", desensitizedPhoneNumber);
 
             memberUserScoreApi.operateScore(MemberUserScoreOperateReqDTO.builder()
@@ -65,6 +65,7 @@ public class RecommendStrategy extends AbstractScoreRuleStrategy {
                     .ruleId(scoreRuleDO.getId())
                     .uniqueId(userId + "_" + message.getRecommendUserId())
                     .expireDays(scoreRuleDO.getScorePeriod())
+                    .extParam(map)
                     .build());
         } catch (Exception e) {
             log.error("Recommend listener: operateScore error", e);

yudao-module-member/yudao-module-member-impl/src/main/java/cn/iocoder/yudao/module/member/mq/consumer/score/core/RegisterStrategy.java

@@ -27,8 +27,8 @@ public class RegisterStrategy extends AbstractScoreRuleStrategy {
     @Resource
     private MemberUserService memberUserService;
 
-    public RegisterStrategy(ScoreRuleService scoreRuleService, MemberUserScoreLogService memberUserScoreLogService, MemberUserService memberUserService,MemberUserScoreApi memberUserScoreApi) {
-        super(scoreRuleService, memberUserScoreLogService, memberUserService,memberUserScoreApi);
+    public RegisterStrategy(ScoreRuleService scoreRuleService, MemberUserScoreLogService memberUserScoreLogService, MemberUserService memberUserService, MemberUserScoreApi memberUserScoreApi) {
+        super(scoreRuleService, memberUserScoreLogService, memberUserService, memberUserScoreApi);
     }
 
     @Override
@@ -68,6 +68,7 @@ public class RegisterStrategy extends AbstractScoreRuleStrategy {
                     .ruleId(scoreRuleDO.getId())
                     .uniqueId(String.valueOf(userId))
                     .expireDays(scoreRuleDO.getScorePeriod())
+                    .extParam(map)
                     .build());
         } catch (Exception e) {
             log.error("Register listener: operateScore error", e);