获取导购活码

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/hm/HmLinkApiService.java

@@ -57,4 +57,6 @@ public interface HmLinkApiService {
      */
     public ServiceResponse<HmLinkWxaDTO> getLinkHmFromWxa(String enterpriseId, Integer whitchStore, String storeId,
             String clerkId, String linkShortCode, String mixPhone, String unionid , String memberId);
+    
+    public ServiceResponse<HmLinkWxaDTO> getMemberClerkHm(String enterpriseId , String memberId , String unionid , Long linkId) ;
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/hm/impl/WxUserAddLogServiceImpl.java

@@ -115,10 +115,12 @@ public class WxUserAddLogServiceImpl implements WxUserAddLogService {
                 if (null != qdto.getLinkId()) {
                     HmLinkBO link = this.hmLinkService.getByLinkIdFormCache(qdto.getWxEnterpriseId(),
                             qdto.getEnterpriseId(), qdto.getLinkId());
-                    entity.setAddChannel(1);
-                    entity.setLinkId(qdto.getLinkId());
-                    entity.setLinkName(link.getName());
-                    memberLabelId = link.getMemberLabelId();
+                    if(null != link) {
+                        entity.setAddChannel(1);
+                        entity.setLinkId(qdto.getLinkId());
+                        entity.setLinkName(link.getName());
+                        memberLabelId = link.getMemberLabelId();
+                    }
                 }
 
                 if (null != memberLabelId) {

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/hm/HmLinkApiServiceImpl.java

@@ -30,6 +30,7 @@ import com.gic.commons.util.PageHelperUtils;
 import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
 import com.gic.haoban.common.utils.DingUtils;
+import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.api.dto.WxEnterpriseDTO;
 import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
 import com.gic.haoban.manage.api.dto.hm.HmLinkChatDTO;
@@ -43,6 +44,7 @@ import com.gic.haoban.manage.api.enums.hm.HmLinkTypeEnum;
 import com.gic.haoban.manage.api.service.hm.HmLinkApiService;
 import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
+import com.gic.haoban.manage.service.dao.mapper.TabHaobanStaffClerkRelationMapper;
 import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
 import com.gic.haoban.manage.service.entity.TabHaobanStaff;
 import com.gic.haoban.manage.service.errorcode.HaoBanErrCode;
@@ -121,6 +123,8 @@ public class HmLinkApiServiceImpl implements HmLinkApiService {
     private MemberTagGroupApiService memberTagGroupApiService;
     @Autowired
     private GroupChatHmService groupChatHmService;
+    @Autowired
+    private TabHaobanStaffClerkRelationMapper staffClerkRelationMapper;
 
     @Override
     public ServiceResponse<String> getHmLinkUrl() {
@@ -537,6 +541,9 @@ public class HmLinkApiServiceImpl implements HmLinkApiService {
         paramsDTO.setSkipVerify(hm.getPassFlag() == 1);
         paramsDTO.setState("DT" + key);
         TabHaobanStaff tabHaobanStaff = staffService.selectById(hm.getStaffId());
+        if(null == tabHaobanStaff) {
+            return ServiceResponse.failure("9999", "成员不存在") ;
+        }
         if (tabHaobanStaff != null) {
             if (qwDTO.needOpenUserId3th()) {
                 paramsDTO.setUser(Arrays.asList(tabHaobanStaff.getWxOpenUseId()));
@@ -684,4 +691,90 @@ public class HmLinkApiServiceImpl implements HmLinkApiService {
         }
         return flag;
     }
+    
+    public ServiceResponse<HmLinkWxaDTO> getMemberClerkHm(String enterpriseId , String memberId , String unionid , Long linkId) {
+        log.info("getMemberClerkHm={},linkId={}",memberId,linkId);
+        HmLinkWxaDTO retDTO = new HmLinkWxaDTO();
+        HmQrcodeBO hm = null ;
+        MemberDataDTO member = this.getMemberClerk(enterpriseId, memberId);
+        List<MemberStoreClerkDataDTO> list = member.getStoreClerkRel();
+        List<String> clerkIdList = list.stream().map(dto->dto.getClerkIdRel()).collect(Collectors.toList()) ;
+        if(CollectionUtils.isEmpty(clerkIdList)) {
+            log.info("会员下无导购");
+            return ServiceResponse.failure("9999", "会员下无导购") ; 
+        }
+        HmLinkBO link = this.hmLinkService.getByLinkId(null, enterpriseId, linkId);
+        if(null == link) {
+            log.info("链接不存在,linkId={}",linkId);
+            return ServiceResponse.failure("9999", "链接不存在") ; 
+        }
+        String wxEnterpriseId = link.getWxEnterpriseId() ;
+        log.info("wxEnterpriseId={}",wxEnterpriseId);
+        List<StaffClerkRelationDTO> staffClerkList = this.staffClerkRelationMapper.listByClerkIds(clerkIdList,wxEnterpriseId) ;
+        if(CollectionUtils.isEmpty(staffClerkList)) {
+            log.info("会员导购无关联成员");
+            return ServiceResponse.failure("9999", "会员导购无关联成员") ; 
+        }
+        clerkIdList = staffClerkList.stream().map(dto->dto.getClerkId()).collect(Collectors.toList()) ;
+        List<String> friendList = this.tabHaobanExternalClerkRelatedMapper.listMemberAndClerk(Arrays.asList(memberId), clerkIdList, enterpriseId) ;
+        if(CollectionUtils.isNotEmpty(friendList)) {
+            log.info("已存在好友");
+            return ServiceResponse.failure("9999", "已存在好友") ; 
+        }
+        String mainClerkId = member.getMainClerkId();
+        String mainStoreId = member.getMainStoreId();
+        // 服务门店
+        log.info("memberId={},主导购={}",memberId,mainClerkId);
+        if (StringUtils.isNotBlank(mainClerkId)) {
+            clerkIdList.add(mainClerkId);
+            hm = this.getHmFromClerk(mainClerkId, wxEnterpriseId, memberId, enterpriseId);
+            if (null != hm) {
+                log.info("获取服务导购活码,mainClerkId={}", mainClerkId);
+            }
+        }
+        // 协管门店
+        if (null == hm &&  CollectionUtils.isNotEmpty(list)) {
+            log.info("处理协管导购");
+            // 协管导购
+            for (MemberStoreClerkDataDTO item : list) {
+                String clerkId = item.getClerkIdRel();
+                if (StringUtils.isNotBlank(mainStoreId) && mainStoreId.equals(item.getStoreIdRel())) {
+                    continue;
+                }
+                hm = this.getHmFromClerk(clerkId, wxEnterpriseId, memberId, enterpriseId);
+                if (null != hm) {
+                    log.info("获取导购活码,clerkId={}", clerkId);
+                    break ;
+                }
+            }
+        }
+        if (null != hm) {
+            log.info("获取到单人活码={}", JSON.toJSONString(hm));
+            retDTO.setHmId(hm.getHmId());
+            KeyDataLinkBO bo = new KeyDataLinkBO();
+            bo.setUnionid(unionid);
+            bo.setHmId(hm.getHmId());
+            // bo.setLinkId(hm.getHmId());
+            String dthmKey = this.keyDataService.saveDataForLink(enterpriseId, bo);
+            if (null != dthmKey) {
+                WxEnterpriseQwDTO qwDTO = this.wxEnterpriseService.getQwInfo(wxEnterpriseId);
+                if(null == qwDTO) {
+                    log.info("wxEnterprise不存在={}",wxEnterpriseId);
+                    return ServiceResponse.failure("9999", "企业不存在") ; 
+                }
+                ServiceResponse<String> addResp = this.addQrcode(hm, dthmKey, qwDTO, retDTO);
+                if (!addResp.isSuccess()) {
+                    if (StringUtils.isBlank(hm.getWxQrcode())) {
+                        return ServiceResponse.success(retDTO);
+                    }
+                    retDTO.setHmQrcode(hm.getWxQrcode());
+                } else {
+                    retDTO.setHmQrcode(addResp.getResult());
+                }
+            }
+        }
+        // 生成动态活码
+        log.info("活码数据返回={}", JSON.toJSONString(retDTO));
+        return ServiceResponse.success(retDTO);
+    }
 }

haoban-manage3-service/src/main/resources/mapper/hm/TabHaobanHmQrcodeMapper.xml

@@ -253,7 +253,9 @@
         <include refid="Base_Column_List"></include>
         from tab_haoban_hm_qrcode
         where clerk_id = #{clerkId} and status_flag = 1
-        and wx_enterprise_id = #{wxEnterpriseId}
+        <if test="null != wxEnterpriseId">
+	        and wx_enterprise_id = #{wxEnterpriseId}
+        </if>
         <if test="hmType != null">
             and hm_type = #{hmType}
         </if>