同步部门

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

@@ -10,4 +10,17 @@ public interface TestApiService {
      * @return
      */
     public String checkThread(String id,Long expireTime);
+    
+    
+    /**
+     * 拉取自己部门企业微信通讯录
+     * @return
+     */
+    public String listSelfQywxUser(String corpid,String secretVal, String dataId);
+    
+    /**
+     * 拉取所有部门企业微信通讯录
+     * @return
+     */
+    public String listAllQywxUser(String corpid,String secretVal, String dataId);
 }

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

 package com.gic.haoban.manage.service.service.out.impl;
 
+import java.util.List;
+
+import com.gic.haoban.manage.api.dto.SecretSettingDTO;
+import com.gic.haoban.manage.api.dto.WxEnterpriseDTO;
+import com.gic.haoban.manage.api.enums.SecretTypeEnum;
 import com.gic.haoban.manage.api.service.TestApiService;
+import com.gic.haoban.manage.service.service.SecretSettingService;
+import com.gic.haoban.manage.service.service.WxEnterpriseService;
+import com.gic.wechat.api.dto.qywx.UserDTO;
+import com.gic.wechat.api.service.qywx.QywxUserApiService;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 /**
@@ -11,6 +22,13 @@ import org.springframework.stereotype.Service;
 @Service
 public class TestServiceImpl implements TestApiService {
     private static final Logger logger= LoggerFactory.getLogger(TestServiceImpl.class);
+    @Autowired
+    private QywxUserApiService qywxUserApiService;
+    @Autowired
+    private WxEnterpriseService wxEnterpriseService;
+    @Autowired
+    private SecretSettingService secretSettingService;
+    
     @Override
     public String checkThread(String id, Long expireTime) {
         logger.info("测试-start：{}",id);
@@ -25,4 +43,28 @@ public class TestServiceImpl implements TestApiService {
         logger.info("测试-end：{}",id);
         return id;
     }
+	@Override
+	public String listSelfQywxUser(String corpid,String secretVal, String dataId) {
+        long t = System.currentTimeMillis();
+        List<UserDTO> list = this.qywxUserApiService.listSelfDepartmentUser(corpid, secretVal, dataId, 0);
+        logger.info("耗时为===============>{}毫秒",(System.currentTimeMillis()-t));	
+        if (null != list) {
+            logger.info("微信获取部门成员数量为：{}",list.size());
+        }else {
+            logger.info("微信获取部门成员数量异常");
+        }
+        return "";
+	}
+	@Override
+	public String listAllQywxUser(String corpid,String secretVal, String dataId) {
+        long t = System.currentTimeMillis();
+        List<UserDTO> list = this.qywxUserApiService.listSelfDepartmentUser(corpid, secretVal, dataId, 1);
+        logger.info("耗时为===============>{}毫秒",(System.currentTimeMillis()-t));	
+        if (null != list) {
+            logger.info("微信获取部门成员数量为：{}",list.size());
+        }else {
+            logger.info("微信获取部门成员数量异常");
+        }
+        return "";
+	}
 }

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/TestController.java

@@ -140,4 +140,16 @@ public class TestController extends WebBaseController {
         Page<MaidianLogDTO> page = maidianLogApiService.queryList(hbversion, pageInfo);
         return resultResponse(HaoBanErrCode.ERR_1,page);
     }
+    
+    @RequestMapping("/deal-slef-qywx-sys-department")
+    public HaobanResponse dealSys1(String corpid,String secretVal,String dataId) {
+    	testApiService.listSelfQywxUser(corpid, secretVal, dataId);
+        return resultResponse(HaoBanErrCode.ERR_1);
+    }
+    
+    @RequestMapping("/deal-all-qywx-sys-department")
+    public HaobanResponse dealSys2(String corpid,String secretVal,String dataId) {
+    	testApiService.listAllQywxUser(corpid, secretVal, dataId);
+        return resultResponse(HaoBanErrCode.ERR_1);
+    }
 }