定时任务：刷新企业成员外部联系人

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

@@ -342,4 +342,11 @@ public interface StaffApiService {
      * @return
      */
     com.gic.api.base.commons.ServiceResponse<List<WxEnterpriseRelatedDTO>> getWxEnterpriseRelatedList(String wxEnterpriseId);
+    /**
+     * 定时任务
+     * 刷新企业成员外部联系人
+     * @param params 企业微信id,多个按”，“隔开
+     */
+    com.gic.api.base.commons.ServiceResponse<Boolean> updateExternalUserId(String params);
+
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/TabHaobanExternalClerkRelatedMapper.java

@@ -400,4 +400,12 @@ public interface TabHaobanExternalClerkRelatedMapper {
      */
     List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(@Param("staffId") String staffId, @Param("memberIds") List<String> memberIds);
 
+    /**
+     * 查询企业微信下面 外部联系人是null的所有成员
+     * @param wxEnterpriseId
+     * @param enterpriseIdList
+     * @return
+     */
+    List<String> listByWxEnterpriseId(@Param("wxEnterpriseId")String wxEnterpriseId, @Param("enterpriseIdList") List<String> enterpriseIdList);
+
 }
\ No newline at end of file

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

@@ -98,4 +98,12 @@ public interface ExternalClerkRelatedService {
 	 */
 	List<TabHaobanExternalClerkRelated> queryClerkMemberRelations(String staffId, List<String> memberIds);
 
+	/**
+	 * 查询企业微信下面,所有外部联系人是null的成员
+	 * @param wxEnterpriseId
+	 * @param enterpriseIdList
+	 * @return
+	 */
+	List<String> listByWxEnterpriseId(String wxEnterpriseId,List<String> enterpriseIdList);
+
 }

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

@@ -520,4 +520,9 @@ public class ExternalClerkRelatedServiceImpl implements ExternalClerkRelatedServ
         }
         return this.mapper.queryClerkMemberRelations(staffId, memberIds);
     }
+
+    @Override
+    public List<String> listByWxEnterpriseId(String wxEnterpriseId, List<String> enterpriseIdList) {
+        return this.mapper.listByWxEnterpriseId(wxEnterpriseId,enterpriseIdList);
+    }
 }

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

@@ -29,6 +29,8 @@ import com.gic.haoban.manage.api.dto.*;
 import com.gic.haoban.manage.api.dto.qdto.TransferActiveCodeQDTO;
 import com.gic.haoban.manage.api.dto.role.StoreRoleDTO;
 import com.gic.haoban.manage.api.enums.SecretTypeEnum;
+import com.gic.haoban.manage.api.enums.SyncTaskTypeEnum;
+import com.gic.haoban.manage.api.service.DealSyncOperationApiService;
 import com.gic.haoban.manage.api.service.StaffApiService;
 import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.dao.mapper.StaffDepartmentRelatedMapper;
@@ -112,6 +114,10 @@ public class StaffApiServiceImpl implements StaffApiService {
     private GroupChatService groupChatService;
     @Autowired
     private WxEnterpriseRelatedService wxEnterpriseRelatedService;
+    @Autowired
+    private DealSyncOperationApiService dealSyncOperationApiService;
+    @Autowired
+    private ExternalClerkRelatedService externalClerkRelatedService;
 
     @Override
     public StaffDTO selectById(String staffId) {
@@ -1167,4 +1173,35 @@ public class StaffApiServiceImpl implements StaffApiService {
         List<TabHaobanWxEnterpriseRelated> list = wxEnterpriseRelatedService.getByWxEnterpriseId(wxEnterpriseId);
         return com.gic.api.base.commons.ServiceResponse.success(com.gic.haoban.common.utils.EntityUtil.changeEntityListByJSON(WxEnterpriseRelatedDTO.class, list));
     }
+
+    @Override
+    public com.gic.api.base.commons.ServiceResponse<Boolean> updateExternalUserId(String params) {
+        if(StrUtil.isBlank(params)){
+            return com.gic.api.base.commons.ServiceResponse.failure("-9999","参数不能为空");
+        }
+        logger.info("定时刷新成员外部联系人开始，id参数：{}",params);
+        List<String> wxEnterpriseIdList = Arrays.asList(params.split(","));
+        String taskName = "刷新企业微信好友(定时处理)";
+        for (String wxEnterpriseId: wxEnterpriseIdList){
+            List<TabHaobanWxEnterpriseRelated> list = wxEnterpriseRelatedService.getByWxEnterpriseId(wxEnterpriseId);
+            //查询企业微信下面所有的品牌id
+            List<String> enterpriseIdList = list.stream().map(dto -> dto.getEnterpriseId()).collect(Collectors.toList());
+            //查询外部联系人id为空的成员id
+            List<String> staffIdList = externalClerkRelatedService.listByWxEnterpriseId(wxEnterpriseId, enterpriseIdList);
+            if (CollUtil.isNotEmpty(staffIdList)){
+                //去重
+                List<String> collect = staffIdList.stream().distinct().collect(Collectors.toList());
+                logger.info("需要刷新好友的企业微信id：{}，staff成员列表：{}",wxEnterpriseId,JSON.toJSONString(collect));
+                for (String staffId : staffIdList){
+                    String taskId = dealSyncOperationApiService.createWxFriendTaskSingle(wxEnterpriseId, taskName, staffId,
+                            "刷新企业微信好友(定时任务处理)", SyncTaskTypeEnum.FRIEND_SINGLE.getType());
+                    if (StringUtils.isNotBlank(taskId)) {
+                        dealSyncOperationApiService.dealWxFriendClerkSingle(taskId, staffId, staffId, wxEnterpriseId);
+                    }
+                }
+            }
+        }
+        logger.info("定时刷新成员外部联系人结束");
+        return com.gic.api.base.commons.ServiceResponse.success(true);
+    }
 }

haoban-manage3-service/src/main/resources/mapper/TabHaobanExternalClerkRelatedMapper.xml

@@ -795,4 +795,17 @@
         AND status_flag = 1 
     </select>
 
+    <select id="listByWxEnterpriseId"  resultType="java.lang.String">
+        select staff_id
+        from tab_haoban_external_clerk_related
+        WHERE
+	    wx_enterprise_id = #{wxEnterpriseId}
+	    AND enterprise_id IN
+	    <foreach collection="enterpriseIdList" item="item" separator="," open="(" close=")">
+            #{item}
+        </foreach>
+	    AND status_flag = 1
+	    AND external_user_id IS NULL
+    </select>
+
 </mapper>
\ No newline at end of file