feat(*): 升级和对接新版会员

- 升级和对接新版会员

feat(*): 升级和对接新版会员
- 升级和对接新版会员
张志伟
1 parent 93c90933
Showing 5 changed files with 17 additions and 161 deletions
fw-hestia-domain/src/main/java/cn/fw/hestia/domain/vo/HistoryQuery.java
fw-hestia-rpc/src/main/java/cn/fw/hestia/rpc/member/MemberRpcService.java
fw-hestia-rpc/src/main/java/cn/fw/hestia/rpc/member/dto/MemberUserDTO.java
fw-hestia-service/src/main/java/cn/fw/hestia/component/AttentionConsumer.java
pom.xml
@@ -18,7 +18,4 @@ import lombok.ToString;
 public class HistoryQuery extends BasePageQuery {
     @PassportContextField(PassportContextField.Name.MEMBER_ID)
     private Long memberId;
-
-    @PassportContextField(PassportContextField.Name.ACCOUNT_ID)
-    private Long accId;
 }
@@ -6,26 +6,17 @@ import cn.fw.hestia.common.constant.Constant;
 import cn.fw.hestia.rpc.member.dto.MemberUserDTO;
 import cn.fw.member.sdk.api.FunctionApi;
 import cn.fw.member.sdk.api.MemberApi;
-import cn.fw.member.sdk.vo.BatchUserParam;
+import cn.fw.member.sdk.vo.MemberInfoVo;
 import cn.fw.member.sdk.vo.MobileLocation;
-import cn.fw.member.sdk.vo.UserBaseInfoVO;
-import cn.fw.member.sdk.vo.UserRegistryVO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
  
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
 import java.util.Objects;
  
-import static org.apache.commons.lang3.Validate.isTrue;
-import static org.apache.commons.lang3.Validate.notNull;
-
 /**
  * 会员服务
  *
@@ -62,12 +53,12 @@ public class MemberRpcService {
             return null;
         }
         try {
-            final Message<UserBaseInfoVO> msg = memberApi.queryUserByuserId(userId);
+            final Message<MemberInfoVo> msg = memberApi.getMemberById(userId);
             if (!msg.isSuccess()) {
                 log.warn("调用Member[根据会员ID[{}]获取会员信息]系统失败, 原因：{}", userId, msg.getResult());
                 return null;
             }
-            final UserBaseInfoVO user = msg.getData();
+            final MemberInfoVo user = msg.getData();
             if (user != null) {
                 final MemberUserDTO userDTO = new MemberUserDTO();
                 BeanUtils.copyProperties(user, userDTO);
@@ -79,86 +70,6 @@ public class MemberRpcService {
         return null;
     }
  
-    /**
-     * 根据会员ID集合获取会员列表
-     *
-     * @param userIds 会员ID集合
-     * @return 会员列表
-     */
-    public List<MemberUserDTO> users(final List<Long> userIds) {
-        if (CollectionUtils.isEmpty(userIds)) {
-            return Collections.emptyList();
-        }
-        try {
-            final BatchUserParam param = new BatchUserParam();
-            param.setUserIdList(userIds);
-            final Message<List<UserBaseInfoVO>> msg = memberApi.batchUserByUserId(param);
-            if (!msg.isSuccess()) {
-                log.warn("调用Member[根据会员ID集合[{}]获取会员列表]系统失败, 原因：{}", userIds, msg.getResult());
-                return Collections.emptyList();
-            }
-            final List<UserBaseInfoVO> users = msg.getData();
-            if (!CollectionUtils.isEmpty(users)) {
-                final List<MemberUserDTO> members = new ArrayList<>();
-                users.forEach(item -> {
-                    final MemberUserDTO userDTO = new MemberUserDTO();
-                    BeanUtils.copyProperties(item, userDTO);
-                    members.add(userDTO);
-                });
-                return members;
-            }
-        } catch (Exception e) {
-            log.error("调用Member[根据会员ID集合[{}]获取会员列表]系统失败", userIds, e);
-        }
-        return Collections.emptyList();
-    }
-
-    /**
-     * 根据手机号查询会员信息
-     *
-     * @param mobile 手机号
-     * @return 会员信息
-     */
-    @Cacheable(cacheNames = Constant.MEMBER_INFO_MOBILE_CACHE, key = "#mobile", unless = "#result == null ")
-    public MemberUserDTO queryByMobile(final String mobile) {
-        if (StringUtils.isBlank(mobile)) {
-            return null;
-        }
-        try {
-            final Message<UserBaseInfoVO> msg = memberApi.queryUserByMobile(mobile);
-            isTrue(msg.isSuccess(), String.format("调用Member系统失败: [根据会员手机号[%s]获取会员信息]", mobile));
-            final UserBaseInfoVO user = msg.getData();
-            if (Objects.isNull(user)) {
-                return null;
-            }
-            final MemberUserDTO userDTO = new MemberUserDTO();
-            BeanUtils.copyProperties(user, userDTO);
-            return userDTO;
-        } catch (Exception e) {
-            log.error("调用Member系统根据会员手机号[{}]获取会员信息失败", mobile, e);
-        }
-        return null;
-    }
-
-    /**
-     * 注册会员
-     *
-     * @param memberUser 注册信息
-     * @return 会员
-     */
-    public MemberUserDTO register(final MemberUserDTO memberUser) {
-        notNull(memberUser, "会员注册信息不能为空");
-        UserRegistryVO vo = new UserRegistryVO();
-        BeanUtils.copyProperties(memberUser, vo);
-        vo.setNickName(StringUtils.isNotBlank(memberUser.getNickName()) ? memberUser.getNickName() : memberUser.getRealName());
-        final Message<UserBaseInfoVO> msg = memberApi.register(vo);
-        isTrue(msg.isSuccess(), String.format("调用Member[注册会员[%s]]系统失败", vo));
-        final UserBaseInfoVO user = msg.getData();
-        notNull(user, String.format("调用Member[注册会员[%s]]系统失败,返回会员信息为空", vo));
-        final MemberUserDTO userDTO = new MemberUserDTO();
-        BeanUtils.copyProperties(user, userDTO);
-        return userDTO;
-    }
  
     /**
      * 查询手机号归属地
@@ -17,27 +17,15 @@ public class MemberUserDTO implements Serializable {
     /**
      * 用户Id
      */
-    private Long userId;
-
-    /**
-     * 真实姓名
-     */
-    private String realName;
-
-    /**
-     * 会员昵称
-     */
-    private String nickName;
-
+    private Long id;
     /**
-     * 手机号
+     * 最后一个账号id
      */
-    private String phone;
-
+    private Long latestAccountId;
     /**
-     * 用户头像URL
+     * 真实姓名
      */
-    private String avatarUrl;
+    private String realName;
  
     /**
      * 证件类型
@@ -50,13 +38,15 @@ public class MemberUserDTO implements Serializable {
     private String credentNo;
  
     /**
-     * 性别
-     */
-    private Integer sex;
-
-    /**
      * 生日
      */
     private Date birthday;
  
+    public Long getUserId() {
+        return id;
+    }
+
+    public Long getMemberId() {
+        return id;
+    }
 }
-package cn.fw.hestia.component;
-
-import cn.fw.hestia.service.buz.MessageCenterBizService;
-import cn.fw.passport.sdk.enums.SubScribeEventEnum;
-import cn.fw.passport.sdk.mq.SubscribeEvent;
-import com.alibaba.fastjson.JSON;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-
-/**
- * 监听关注公众号mq
- *
- * @author kurisu
- */
-@Slf4j
-@Component
-@RocketMQMessageListener(topic = "subs_event", consumerGroup = "${spring.application.name}" + "-subs_event")
-public class AttentionConsumer implements RocketMQListener<SubscribeEvent> {
-    private final MessageCenterBizService messageCenterBizService;
-
-    @Autowired
-    public AttentionConsumer(final MessageCenterBizService messageCenterBizService) {
-        this.messageCenterBizService = messageCenterBizService;
-    }
-
-    @Override
-    public void onMessage(SubscribeEvent t) {
-        log.info("监听关注公众号mq: SubscribeEvent=[{}]", t);
-        SubScribeEventEnum eventType = t.getEventType();
-        try {
-            if (eventType.equals(SubScribeEventEnum.SUBSCRIBE)) {
-                messageCenterBizService.onAttention(t.getUserId());
-            }
-        } catch (Exception ex) {
-            log.error("消费关注公众号mq失败，原因:{}", JSON.toJSONString(ex));
-        }
-    }
-}
 \ No newline at end of file
@@ -36,10 +36,10 @@
         <rocketmq-spring-boot-starter.version>2.1.0</rocketmq-spring-boot-starter.version>
         <redis.spring.boot.starter>1.0</redis.spring.boot.starter>
         <fastjson>1.2.51</fastjson>
-        <fw-passport-sdk.version>2.2.0</fw-passport-sdk.version>
+        <fw-passport-sdk.version>3.0.0</fw-passport-sdk.version>
         <yitter.idgenerator>1.0.6</yitter.idgenerator>
         <hutool.version>5.2.5</hutool.version>
-        <fw-member-sdk.version>2.0</fw-member-sdk.version>
+        <fw-member-sdk.version>3.0.0</fw-member-sdk.version>
     </properties>
  
     <dependencyManagement>