企微更新用户

we-com-server/src/main/java/com/tzld/piaoquan/wecom/controller/WeComController.java

@@ -100,14 +100,14 @@ public class WeComController {
                     String userId = (String) suiteMap.get("UserID");
                     String externalUserId = (String) suiteMap.get("ExternalUserID");
                     log.info("addStaffWithUser userId={} externalUserId={}", userId, externalUserId);
-//                userService.addStaffWithUser(externalUserId, userId);
+                    userService.addStaffWithUser(externalUserId, userId);
                 }
 
                 if (StringUtils.isNotEmpty(changeType) && changeType.equals("del_follow_user")) {
                     String userId = (String) suiteMap.get("UserID");
                     String externalUserId = (String) suiteMap.get("ExternalUserID");
                     log.info("delStaffWithUser userId={} externalUserId={}", userId, externalUserId);
-//                userService.delStaffWithUser(externalUserId, userId);
+                    userService.delStaffWithUser(externalUserId, userId);
                 }
             }
 

we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComUserDataJob1.java

@@ -11,6 +11,7 @@ import com.tzld.piaoquan.wecom.service.AccessTokenService;
 import com.tzld.piaoquan.wecom.service.UserService;
 import com.tzld.piaoquan.wecom.utils.HttpClientUtil;
 import com.tzld.piaoquan.wecom.utils.HttpPoolClient;
+import com.tzld.piaoquan.wecom.utils.LarkRobotUtil;
 import com.tzld.piaoquan.wecom.utils.page.Page;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -126,6 +127,7 @@ public class WeComUserDataJob1 {
                 cursor = nextCursor;
             } while (StringUtils.isEmpty(cursor));
         } catch (IOException e) {
+            LarkRobotUtil.sendMessage("updateUser error" + e);
             log.error("updateUser error", e);
         }
     }
@@ -198,18 +200,22 @@ public class WeComUserDataJob1 {
     }
 
     @XxlJob("insertStaffWithUserJob1")
-    public ReturnT<String> insertStaffWithUserJob(String param) throws IOException {
-        StaffExample example = new StaffExample();
-        List<Staff> staffList = staffMapper.selectByExample(example);
-        for (Staff staff : staffList) {
-            List<String> externalUserIds = getUserList(staff.getCarrierId());
-            if (CollectionUtils.isEmpty(externalUserIds)) {
-                continue;
-            }
-            for (String externalUserId : externalUserIds) {
-                userService.insertStaffWithUser(externalUserId, staff);
+    public ReturnT<String> insertStaffWithUserJob(String param) {
+        try {
+            StaffExample example = new StaffExample();
+            List<Staff> staffList = staffMapper.selectByExample(example);
+            for (Staff staff : staffList) {
+                List<String> externalUserIds = getUserList(staff.getCarrierId());
+                if (CollectionUtils.isEmpty(externalUserIds)) {
+                    continue;
+                }
+                for (String externalUserId : externalUserIds) {
+                    userService.insertStaffWithUser(externalUserId, staff);
+                }
             }
-
+        }catch (Exception e){
+            LarkRobotUtil.sendMessage("insertStaffWithUserJob error" + e);
+            log.error("insertStaffWithUserJob error", e);
         }
 
         return ReturnT.SUCCESS;

we-com-server/src/main/java/com/tzld/piaoquan/wecom/service/Impl/UserServiceImpl.java

@@ -10,6 +10,7 @@ import com.tzld.piaoquan.wecom.service.AccessTokenService;
 import com.tzld.piaoquan.wecom.service.UserService;
 import com.tzld.piaoquan.wecom.utils.HttpClientUtil;
 import com.tzld.piaoquan.wecom.utils.HttpPoolClient;
+import com.tzld.piaoquan.wecom.utils.LarkRobotUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -44,7 +45,7 @@ public class UserServiceImpl implements UserService {
             return;
         }
         Staff staff = getStaff(carrierId);
-//        insertStaffWithUser(externalUserId, staff);
+        insertStaffWithUser(externalUserId, staff);
     }
 
 
@@ -129,6 +130,7 @@ public class UserServiceImpl implements UserService {
                 }
             }
         } catch (Exception e) {
+            LarkRobotUtil.sendMessage("insertUser error externalUserId=" + externalUserId + e);
             log.error("insertUser error", e);
         }
     }