fuwuhao content link

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/MessageSendCallbackService.java

@@ -1,7 +1,9 @@
 package com.tzld.longarticle.recommend.server.service;
 
 import com.tzld.longarticle.recommend.server.repository.mapper.crawler.ArticleContentLinkMapper;
+import com.tzld.longarticle.recommend.server.repository.mapper.crawler.ArticleGzhDeveloperMapper;
 import com.tzld.longarticle.recommend.server.repository.model.ArticleContentLink;
+import com.tzld.longarticle.recommend.server.repository.model.ArticleGzhDeveloper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.math.NumberUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -25,6 +27,8 @@ public class MessageSendCallbackService {
     @Autowired
     private ArticleContentLinkMapper articleContentLinkMapper;
 
+    @Autowired
+    private ArticleGzhDeveloperMapper articleGzhDeveloperMapper;
 
     /**
      * https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Batch_Sends_and_Originality_Checks.html#_8%E3%80%81%E4%BA%8B%E4%BB%B6%E6%8E%A8%E9%80%81%E7%BE%A4%E5%8F%91%E7%BB%93%E6%9E%9C
@@ -44,6 +48,13 @@ public class MessageSendCallbackService {
 
 
             String gzhId = root.elementText("ToUserName");
+            ArticleGzhDeveloper agd = articleGzhDeveloperMapper.selectByPrimaryKey(gzhId);
+            if (agd == null) {
+                // 不再体系内的账号，不记录链接
+                return;
+            }
+
+
             long createTime = NumberUtils.toLong(root.elementText("CreateTime"), 0);
 
             Element articleUrlResultEle = root.element("ArticleUrlResult");

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/UserManagementService.java

@@ -4,6 +4,7 @@ import com.tzld.longarticle.recommend.server.model.WxUserGetResponse;
 import com.tzld.longarticle.recommend.server.remote.WxUserManagementRemoteService;
 import com.tzld.longarticle.recommend.server.repository.mapper.crawler.ArticleGzhDeveloperMapper;
 import com.tzld.longarticle.recommend.server.repository.mapper.crawler.ArticleUserGroupMapper;
+import com.tzld.longarticle.recommend.server.repository.model.ArticleGzhDeveloper;
 import com.tzld.longarticle.recommend.server.repository.model.ArticleUserGroup;
 import com.tzld.longarticle.recommend.server.util.CommonCollectionUtils;
 import lombok.extern.slf4j.Slf4j;
@@ -34,7 +35,7 @@ public class UserManagementService {
     @Autowired
     private ArticleGzhDeveloperMapper articleGzhDeveloperMapper;
 
-    public void addGZH(String gzhId, int groupNum) {
+    public void addGZH(String gzhId, String appId, int groupNum) {
 
         // syncAllUserOnce(gzhId, groupNum);
 
@@ -95,11 +96,10 @@ public class UserManagementService {
 
         log.info("end sync user gzhId={}", gzhId);
 
-//        ArticleGzhDeveloper obj = new ArticleGzhDeveloper();
-//        obj.setAppId(appId);
-//        obj.setGzhId(gzhId);
-//        articleGzhDeveloperMapper.insert(obj);
-//        log.info("start group gzhId={}", gzhId);
+        ArticleGzhDeveloper obj = new ArticleGzhDeveloper();
+        obj.setAppId(appId);
+        obj.setGzhId(gzhId);
+        articleGzhDeveloperMapper.insert(obj);
 
 
     }

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/web/UserManagementController.java

@@ -28,8 +28,9 @@ public class UserManagementController {
 
     @RequestMapping("/addGZH")
     public String addGZH(@RequestParam(name = "gzhId") String gzhId,
+                         @RequestParam(name = "appId") String appId,
                          @RequestParam(name = "groupNum") int groupNum) {
-        userManagementService.addGZH(gzhId,groupNum);
+        userManagementService.addGZH(gzhId, appId, groupNum);
         return "success";
     }