标签同步

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

@@ -30,6 +30,14 @@ public interface QywxTagApiService {
     public ServiceResponse syncTagToQywx(String wxEnterpriseId, String enterpriseId, QywxTagInfoDTO infoDTO, List<QywxTagItemDTO> items);
 
     /**
+     * 更新标签同步更新企微侧
+     * @param enterpriseId
+     * @param memberTagId
+     * @return
+     */
+    public com.gic.api.base.commons.ServiceResponse syncTagToQywx(String enterpriseId, String memberTagId);
+
+    /**
      * 关闭同步
      *
      * @param wxEnterpriseId

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

@@ -25,6 +25,7 @@ import com.gic.haoban.manage.service.util.DingUtils;
 import com.gic.member.api.dto.MemberTagDTO;
 import com.gic.member.api.service.MemberTagService;
 import com.gic.member.tag.api.dto.MemberTagItemDTO;
+import com.gic.member.tag.api.service.MemberTagApiService;
 import com.gic.member.tag.api.service.MemberTagItemApiService;
 import com.gic.mq.sdk.GicMQClient;
 import com.gic.redis.data.util.RedisUtil;
@@ -89,6 +90,8 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
     private MemberTagItemApiService memberTagItemApiService;
     @Autowired
     private QywxTagRelationMapper qywxTagRelationMapper;
+    @Autowired
+    private MemberTagApiService memberTagApiService;
 
     @Override
     public void pullQywxTag(String wxEnterpriseId) {
@@ -110,6 +113,33 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
     }
 
     @Override
+    public  com.gic.api.base.commons.ServiceResponse syncTagToQywx(String enterpriseId, String memberTagId) {
+        logger.info("更新企微标签,memberTagId={}",memberTagId);
+        List<TabQywxTagRelation> relationList = this.qywxTagRelationMapper.listByMemberTagId(null,memberTagId) ;
+        if(CollectionUtils.isEmpty(relationList)) {
+            logger.info("标签未同步过企微");
+            return com.gic.api.base.commons.ServiceResponse.success() ;
+        }
+        String  wxEnterpriseId  = relationList.get(0).getWxEnterpriseId() ;
+        com.gic.member.tag.api.dto.MemberTagDTO memberTagDTO = memberTagApiService.getMemberTagById(memberTagId);
+        List<MemberTagItemDTO> tagItems = memberTagApiService.queryMemberTagItem(memberTagId);
+        QywxTagInfoDTO qywxTagInfoDTO = new QywxTagInfoDTO();
+        qywxTagInfoDTO.setWxEnterpriseId(wxEnterpriseId);
+        qywxTagInfoDTO.setMemberTagId(memberTagDTO.getTagId());
+        qywxTagInfoDTO.setQywxGroupName(memberTagDTO.getTagName());
+        List<QywxTagItemDTO> items = tagItems.stream().map(item -> {
+            QywxTagItemDTO mid = new QywxTagItemDTO();
+            mid.setMemberTagItemId(item.getTagItemId());
+            mid.setQywxTagKey(item.getTagItemId());
+            mid.setQywxTagName(item.getTagItemName());
+            return mid;
+        }).collect(Collectors.toList());
+        //保存同步
+        this.syncTagToQywx(wxEnterpriseId,enterpriseId,qywxTagInfoDTO,items);
+        return com.gic.api.base.commons.ServiceResponse.success() ;
+    }
+
+    @Override
     public ServiceResponse syncTagToQywx(String wxEnterpriseId, String enterpriseId, QywxTagInfoDTO infoDTO, List<QywxTagItemDTO> items) {
         logger.info("标签同步到企业微信,wxEnterpriseId={},memberTagId={}",wxEnterpriseId,infoDTO.getMemberTagId());
         ServiceResponse ret = new ServiceResponse();