导购

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

@@ -4,7 +4,9 @@ import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 
@@ -26,11 +28,13 @@ import com.gic.enterprise.api.service.StoreService;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.common.utils.PageUtil;
 import com.gic.haoban.common.utils.StringUtil;
+import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
 import com.gic.haoban.manage.api.dto.qdto.hm.HmQrcodeQDTO;
 import com.gic.haoban.manage.api.enums.BindTypeEnum;
 import com.gic.haoban.manage.api.enums.ChannelCodeEnum;
+import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.api.service.hm.HmClerkRelationApiService;
 import com.gic.haoban.manage.api.service.hm.HmQrcodeApiService;
 import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
@@ -63,7 +67,8 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
 
     @Autowired
     private ExternalClerkRelatedService externalClerkRelatedService;
-
+    @Autowired
+    private HaobanCommonMQApiService haobanCommonMQApiService ;
     @Autowired
     private ClerkMainStoreRelatedService clerkMainStoreRelatedService;
     @Autowired
@@ -180,10 +185,16 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
             List<String> memberIdList = this.externalClerkRelatedMapper.listByClerkId(staffId, oldClerkId) ;
             this.externalClerkRelatedService.updateClerkInfo(staffId , oldClerkId , newClerkId) ;
             if(CollectionUtils.isNotEmpty(memberIdList)) {
-                ClerkDTO clerk = this.clerkService.getclerkById(newClerkId);
-                String newStoreId = clerk.getStoreId() ;
                 for(String memberId : memberIdList) {
-                    logger.info("会员");
+                    logger.info("会员={}",memberId);
+                    CommonMQDTO dto = new CommonMQDTO();
+                    dto.setType(3);
+                    Map<String,String> map = new HashMap<>() ;
+                    map.put("enterpriseId", enterpriseId) ;
+                    map.put("memberId", memberId) ;
+                    map.put("clerkId", newClerkId) ;
+                    dto.setParams(map);
+                    this.haobanCommonMQApiService.putCommonMessage(dto);
                 }
             }
         }else {

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

@@ -15,6 +15,7 @@ import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.service.service.StaffDepartmentRelatedService;
 import com.gic.haoban.manage.service.service.WelcomeSendService;
+import com.gic.member.api.service.MemberOpenCardBusinessService;
 import com.gic.mq.sdk.GicMQClient;
 import com.gic.quartz.api.dto.QuartzTaskDTO;
 import com.gic.quartz.api.service.QuartzService;
@@ -32,6 +33,8 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     private StaffDepartmentRelatedService staffDepartmentRelatedService;
     @Autowired
     private WelcomeSendService welcomeSendService;
+    @Autowired
+    private MemberOpenCardBusinessService memberOpenCardBusinessService ;
 
     @Override
     public void putCommonMessage(CommonMQDTO dto) {
@@ -74,6 +77,13 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
             if (StringUtils.isNotBlank(staffId)) {
                 this.staffDepartmentRelatedService.repairStaffDepart(staffId);
             }
+            break ;
+        case 3:
+            String memberId = map.get("memberId") ;
+            enterpriseId = map.get("enterpriseId") ;
+            String clerkId = map.get("clerkId") ;
+            this.memberOpenCardBusinessService.memberClerkByQywx(enterpriseId, memberId, clerkId);
+            break ;
         default:
             break;
         }