修改添加位置

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/mq/processor/AddMemberUnionRelateConsumerProcessor.java

@@ -87,19 +87,6 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
             logger.info("unionId为空, 会员无法查询");
             return;
         }
-        // 幂等
-        MemberUnionidRelatedDTO exsitDTO = memberUnionRelatedService.getByUnionId(wxEnterpriseId, wxUserId, dto.getUnionid());
-        String memberUnionIdRelatedId;
-        if (Objects.isNull(exsitDTO)) {
-            // 创建memberUnion 临时表关联
-            memberUnionIdRelatedId = memberUnionRelatedService.addMemberUnionidRelated(dto);
-        } else {
-            memberUnionIdRelatedId = exsitDTO.getMemberUnionidRelatedId();
-        }
-        if (StringUtils.isEmpty(memberUnionIdRelatedId)) {
-            logger.info("添加临时关联表memberUnionIdRelate失败");
-            return;
-        }
         // 设置主门店
         TabHaobanClerkMainStoreRelated mainStoreRelated = clerkMainStoreRelatedService.getMainStoreByStaffId(staffId, wxEnterpriseId);
         if (mainStoreRelated == null) {
@@ -128,6 +115,21 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
             logger.info("会员信息不存在unionId：{}", dto.getUnionid());
             return;
         }
+        // 幂等
+        MemberUnionidRelatedDTO exsitDTO = memberUnionRelatedService.getByUnionId(wxEnterpriseId, wxUserId, dto.getUnionid());
+        String memberUnionIdRelatedId;
+        if (Objects.isNull(exsitDTO)) {
+            dto.setMemberId(member.getMemberId());
+            dto.setEnterpriseId(enterpriseId);
+            // 创建memberUnion 临时表关联
+            memberUnionIdRelatedId = memberUnionRelatedService.addMemberUnionidRelated(dto);
+        } else {
+            memberUnionIdRelatedId = exsitDTO.getMemberUnionidRelatedId();
+        }
+        if (StringUtils.isEmpty(memberUnionIdRelatedId)) {
+            logger.info("添加临时关联表memberUnionIdRelate失败");
+            return;
+        }
         String relationKey = SecureUtil.md5(staffId + externalUserid);
         logger.info("新增TabHaobanExternalClerkRelated");
         TabHaobanExternalClerkRelated related = new TabHaobanExternalClerkRelated();