本地

mpwechatApp/src/main/java/com/liangjian11/wx/mp/controller/WxFansTagController.java

@@ -22,6 +22,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.RestTemplate;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -70,33 +71,25 @@ public class WxFansTagController {
             List<WxUserTag> tagList = userTagService.tagGet();
             List<String> tagNameList = tagService.queryAll(appid).stream().map(EsTagInfo::getTagName).collect(Collectors.toList());
 
-            new 
             for (WxUserTag wxUserTag : tagList) {
                 String tagName = wxUserTag.getName();
                 if(tagNameList.contains(tagName)){
                     tagNameList.remove(tagName);
                 }else {
-
-                }
-
-
-            }
-
-            for (WxUserTag wxUserTag : tagList) {
-                QueryWrapper wrapper = new QueryWrapper();
-                wrapper.eq("tagValue", wxUserTag.getId().toString());
-                List<EsTagInfo> tags = tagService.list(wrapper);
-                if (tags == null || tags.size() == 0) {
                     EsTagInfo tag = new EsTagInfo();
                     tag.setTagValue(wxUserTag.getId().toString());
                     tag.setTagName(wxUserTag.getName());
                     tag.setAppId(appid);
-
                     tagService.save(tag);
                 }
             }
-            ResultInfo body = tagService.queryTagList(data);
 
+            // 本地有但微信方没有，删除本地的标签
+            for (String tagName : tagNameList) {
+                tagService.delete(appid, tagName);
+            }
+
+            ResultInfo body = tagService.queryTagList(data);
             return ResultUtil.createSuccess(200, body);
         } catch (WxErrorException e) {
             e.printStackTrace();

mpwechatApp/src/main/java/com/liangjian11/wx/mp/service/TagService.java

@@ -27,4 +27,11 @@ public interface TagService extends IService<EsTagInfo> {
      * @return
      */
     List<EsTagInfo> queryAll(String appid);
+
+    /**
+     * 仅删除本地标签
+     * @param appid
+     * @param tagName
+     */
+    void delete(String appid, String tagName);
 }

mpwechatApp/src/main/java/com/liangjian11/wx/mp/service/impl/TagServiceImpl.java

@@ -81,6 +81,10 @@ public class TagServiceImpl   extends ServiceImpl<TagMapper, EsTagInfo> implemen
         return esTagInfos;
     }
 
+    @Override
+    public void delete(String appid, String tagName) {
+
+    }
 
 
 }