1.update

@@ -205,6 +205,39 @@ public class UserOperationServiceImpl implements UserOperationService {
     }
 
     @Transactional(propagation = Propagation.SUPPORTS, rollbackFor = Exception.class)
+    public void asyncSubscribe(MemberAndWeixinUserDTO memberAndWeixinUserDTO) {
+        UserWeixinDTO userWeixinDTO = memberAndWeixinUserDTO.getUserWeixinDTO();
+        String openid = userWeixinDTO.getOpenid();
+        String unionid = userWeixinDTO.getUnionid();
+        String appid = userWeixinDTO.getAppid();
+        MemberDTO memberDTO = memberAndWeixinUserDTO.getMemberDTO();
+
+        UserWeixinDTO _userWeixinDTO = this.userWeixinService.findFirstByUnionIdAndAppIdAndOpenId(unionid, appid, openid);
+        if (Objects.nonNull(_userWeixinDTO)) {
+
+            // 账号存在，修改账号和会员
+            this.updateWeixin(_userWeixinDTO, userWeixinDTO);
+
+            MemberDTO _memberDTO = this.memberService.findById(_userWeixinDTO.getMemberId());
+            if (Objects.nonNull(_memberDTO)) {
+
+                memberDTO.setUserIptvId(_memberDTO.getUserIptvId());
+                this.updateMember(_memberDTO, memberDTO);
+
+            } else {
+
+                throw new EntityNotFoundException(MemberDTO.class, "id", GlobeExceptionMsg.MEMBER_ID_IS_NULL);
+
+            }
+
+        } else {
+
+            throw new EntityNotFoundException(UserWeixinDTO.class, "id", GlobeExceptionMsg.WEIXIN_IS_NULL);
+
+        }
+    }
+
+    @Transactional(propagation = Propagation.SUPPORTS, rollbackFor = Exception.class)
     public void asyncUnsubscribe(MemberAndWeixinUserDTO memberAndWeixinUserDTO) {
         UserWeixinDTO userWeixinDTO = memberAndWeixinUserDTO.getUserWeixinDTO();
         String openid = userWeixinDTO.getOpenid();