1.update

@@ -50,7 +50,6 @@ public class MemberProfileServiceImpl implements MemberProfileService {
     public MemberProfileDTO findByMemberId(Long memberId) {
         log.info("MemberProfileDTO ==>> findByMemberId ==>> resources ===>> [{}]",memberId);
         MemberProfile memberProfile = this.memberProfileRepository.findByMemberId(memberId).orElseGet(MemberProfile::new);
-        ValidationUtil.isNull(memberProfile.getId(),"MemberProfile","memberId",memberId);
         return this.memberProfileMapper.toDto(memberProfile);
     }
 

@@ -14,6 +14,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StringUtils;
 
+import java.util.Objects;
+
 /**
  * @author ：
  * @description：
@@ -33,6 +35,38 @@ public class MemberProfileOperationServiceImpl implements MemberProfileOperation
     @Autowired
     private MemberService memberService;
 
+    public void asyncCreateMemberProfile(MemberProfileDTO memberProfileDTO) {
+        String memberCode = memberProfileDTO.getMemberCode();
+        MemberDTO memberDTO = this.memberService.findByCode(memberCode);
+        Long memberId = memberDTO.getId();
+        MemberProfileDTO _memberProfileDTO = this.memberProfileService.findByMemberId(memberId);
+        if (Objects.isNull(_memberProfileDTO.getId())) {
+            memberProfileDTO.setMemberId(memberId);
+            this.createMemberProfileAndSyncMember(memberProfileDTO, memberDTO);
+        }
+
+    }
+
+    private void createMemberProfileAndSyncMember(MemberProfileDTO memberProfileDTO, MemberDTO memberDTO) {
+        this.createMemberProfile(memberProfileDTO);
+        this.syncMember(memberProfileDTO, memberDTO);
+    }
+
+    private void syncMember(MemberProfileDTO memberProfileDTO, MemberDTO memberDTO) {
+        memberDTO.setAvatarUrl(memberProfileDTO.getAvatarUrl());
+        memberDTO.setNickname(memberProfileDTO.getRealname());
+        memberDTO.setGender(memberProfileDTO.getGender());
+        Member member = new Member();
+        BeanUtils.copyProperties(memberDTO, member);
+        this.memberService.update(member);
+    }
+
+    private void createMemberProfile(MemberProfileDTO memberProfileDTO) {
+        MemberProfile memberProfile = new MemberProfile();
+        BeanUtils.copyProperties(memberProfileDTO, memberProfile);
+        this.memberProfileService.createDefault(memberProfile);
+    }
+
     public MemberProfileDTO asyncMemberProfile(MemberProfileDTO memberProfileDTO){
         String memberCode = memberProfileDTO.getMemberCode();
         MemberDTO memberDTO = this.memberService.findByCode(memberCode);

@@ -82,7 +82,7 @@ mutil-mq:
 #    host: 122.112.214.149 # rabbitmq的连接地址
     host: 122.112.214.149 # rabbitmq的连接地址
     port: 5672 # rabbitmq的连接端口号
-    virtual-host: none # rabbitmq的虚拟host
+    virtual-host: member_center # rabbitmq的虚拟host
     username: guest # rabbitmq的用户名
     password: guest # rabbitmq的密码
 #    username: admin # rabbitmq的用户名
@@ -98,31 +98,31 @@ service:
         queue: event.queue
         exchange-type: direct
         routing-key:
-        active:
+        active: service
       - source: collection
         exchange: collection.exchange
         queue: collection.queue
         exchange-type: direct
         routing-key:
-        active:
+        active: service
       - source: viewRecord
         exchange: viewRecord.exchange
         queue: viewRecord.queue
         exchange-type: direct
         routing-key:
-        active:
+        active: service
       - source: eventBus
         exchange: uc.eventbus
         queue: uc.eventbus
         exchange-type: topic
         routing-key: uc.eventbus.*.topic
-        active:
+        active: service
       - source: uce
         exchange: uce.exchange
         queue: uce.queue
         exchange-type: direct
         routing-key:
-        active: service
+        active: management
       - source: wechat
         exchange: wechat.exchange
         queue: weixin.subOrUnSub.queue
@@ -151,5 +151,5 @@ service:
 
 # uc-engine服务地址
 api:
-  baseUrl: http://127.0.0.1:8447
+  baseUrl: http://127.0.0.1:8218