员工可能修改userId，需要拿到openUserId再去查询一次

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

@@ -28,6 +28,7 @@ import com.gic.thirdparty.cloudfile.enums.CloudFileBusinessOptEnum;
 import com.gic.thirdparty.cloudfile.enums.CloudFileTypeEnum;
 import com.gic.thirdparty.cloudfile.pojo.CloudFileInfo;
 import com.gic.wechat.api.dto.qywx.ItemDTO;
+import com.gic.wechat.api.dto.qywx.QywxNewUseridDTO;
 import com.gic.wechat.api.dto.qywx.QywxXcxSendMessageDTO;
 import com.gic.wechat.api.dto.qywx.UserDTO;
 import com.gic.wechat.api.service.qywx.QywxDepartmentApiService;
@@ -224,8 +225,16 @@ public class MessageApiServiceImpl implements MessageApiService {
             //修改
             TabHaobanStaff oldStaff = this.staffService.selectByUserIdAndEnterpriseId(userid, wxEnterpriseId);
             if (oldStaff == null) {
-                log.error("成员同步更新失败，无历史员工数据：userid:{},wxEnterpriseId:{}", userid, wxEnterpriseId);
-                return;
+                //员工可能修改userId，需要拿到openUserId再去查询一次
+                WxEnterpriseQwDTO qwDTO = this.wxEnterpriseService.getQwInfo(wxEnterpriseId);
+                if (qwDTO != null){
+                    String openUserid = getOpenUserid(userid, qwDTO);
+                    oldStaff = this.staffService.selectByUserIdAndEnterpriseId(openUserid, wxEnterpriseId);
+                    if (oldStaff == null){
+                        log.error("成员同步更新失败，无历史员工数据：userid:{},wxEnterpriseId:{}", userid, wxEnterpriseId);
+                        return;
+                    }
+                }
             }
             TabHaobanStaff staff = new TabHaobanStaff();
             staff.setStaffId(oldStaff.getStaffId());
@@ -320,6 +329,14 @@ public class MessageApiServiceImpl implements MessageApiService {
         }
         log.error("成员同步结束");
     }
+    private String getOpenUserid(String userId,WxEnterpriseQwDTO qwDTO) {
+        List<QywxNewUseridDTO> list = qywxUserApiService.useridToOpenuserid(qwDTO.getThirdCorpid(), config.getWxSuiteid(), Collections.singletonList(userId));
+        log.info("明文userId转密文={},{}", userId, JSON.toJSONString(list));
+        if (CollectionUtils.isEmpty(list)) {
+            return "";
+        }
+        return list.get(0).getOpen_userid();
+    }
 
     /**
      * 处理部门