qxm-增加获取经销商财务人员列表(分页)--获取经销商仓管人员列表(分页)数据同步

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/AnalysisDiyCustomerComponent.java

@@ -83,7 +83,7 @@ public class AnalysisDiyCustomerComponent {
         Set<String> loginNameSet = sysUserService.selectAllUserLoginName();
         String managerJson ="";
         try{
-            managerJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.MANAGER));
+            managerJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.MANAGER,null));
         }catch (Exception e){
             log.error("获取经销商经理接口错误！");
             customerAccessTokenUtil.reSetToken();
@@ -104,7 +104,7 @@ public class AnalysisDiyCustomerComponent {
 
         String guideJson ="";
         try{
-            guideJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.STOREGUIDE));
+            guideJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.STOREGUIDE,null));
         }catch (Exception e){
             log.error("获取经销商导购接口错误！");
             customerAccessTokenUtil.reSetToken();
@@ -118,6 +118,76 @@ public class AnalysisDiyCustomerComponent {
             total+=gjson.getJSONArray("userlist").size();
         }
 
+        String financeJson ="";
+        try{
+            financeJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.FINANCE,1+""));
+        }catch (Exception e){
+            log.error("获取经销商财务接口错误！");
+            customerAccessTokenUtil.reSetToken();
+            throw e;
+        }
+
+        JSONObject fjson = JSONObject.parseObject(financeJson);
+        Integer fcount = fjson.getInteger("count");
+        if(fcount>100){
+            for (int i = 1; i < Math.floor(fcount/100); i++) {
+                try {
+                    fjson = JSONObject.parseObject(HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.FINANCE,i+"")));
+                } catch (Exception e) {
+                    log.error("循环获取经销商财务接口错误！第"+i+"页");
+                    customerAccessTokenUtil.reSetToken();
+                    throw e;
+                }
+                code = fjson.getInteger("code");
+                if(code==0){
+                    success+=buildSysUser(fjson,loginNameSet,2,failDetails,packageId,codeMap);
+                    total+=fjson.getJSONArray("userlist").size();
+                }
+            }
+        }else{
+            code = fjson.getInteger("code");
+            if(code==0){
+                success+=buildSysUser(fjson,loginNameSet,2,failDetails,packageId,codeMap);
+                total+=fjson.getJSONArray("userlist").size();
+            }
+        }
+
+
+        String warehouseJson ="";
+        try{
+            warehouseJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.WAREHOUSE,1+""));
+        }catch (Exception e){
+            log.error("获取经销商仓管接口错误！");
+            customerAccessTokenUtil.reSetToken();
+            throw e;
+        }
+
+        JSONObject wjson = JSONObject.parseObject(warehouseJson);
+        Integer wcount = fjson.getInteger("count");
+        if(wcount>100){
+            for (int i = 1; i < Math.floor(wcount/100); i++) {
+                try {
+                    wjson = JSONObject.parseObject(HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.WAREHOUSE,i+"")));
+                } catch (Exception e) {
+                    log.error("获取经销商仓管接口错误！第"+i+"页");
+                    customerAccessTokenUtil.reSetToken();
+                    throw e;
+                }
+                code = wjson.getInteger("code");
+                if(code==0){
+                    success+=buildSysUser(wjson,loginNameSet,3,failDetails,packageId,codeMap);
+                    total+=wjson.getJSONArray("userlist").size();
+                }
+            }
+        }else{
+            code = wjson.getInteger("code");
+            if(code==0){
+                success+=buildSysUser(wjson,loginNameSet,3,failDetails,packageId,codeMap);
+                total+=wjson.getJSONArray("userlist").size();
+            }
+        }
+
+
         try{
             syncLog.setTotalCount(total);
             syncLog.setSuccessCount(success);

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/utils/CustomerAccessTokenUtil.java

@@ -16,7 +16,9 @@ public class CustomerAccessTokenUtil {
     public enum UrlType{
 
         MANAGER,
-        STOREGUIDE;
+        STOREGUIDE,
+        FINANCE,
+        WAREHOUSE;
 
 
 
@@ -53,12 +55,18 @@ public class CustomerAccessTokenUtil {
     private String managerListUrl ;
     //获取经销商导购列表
     private String storeGuideListUrl ;
+    //获取经销商财务人员列表(分页)
+    private String financeListUrl ;
+    //获取经销商仓管人员列表(分页)
+    private String warehouseListUrl ;
 
     @PostConstruct
     public void init() {
         tokenUrl=domain+"/auth/jwt/v1/gettoken?appid=%s&appsecret=%s";
         managerListUrl =domain+"/wechatwork/diydt/v1/user/manager/list?access_token=%s";
         storeGuideListUrl =domain+"/wechatwork/diydt/v1/user/storeGuide/list?access_token=%s";
+        financeListUrl =domain+"/wechatwork/diydt/v2/user/finance/list?page=%s&access_token=%s";
+        warehouseListUrl =domain+"/wechatwork/diydt/v2/user/warehouse/list?page=%s&access_token=%s";
     }
 
     public String getAccessToken(){
@@ -104,7 +112,7 @@ public class CustomerAccessTokenUtil {
     }
 
 
-    public String getUrl(UrlType type){
+    public String getUrl(UrlType type,String pageNum){
         String token = getAccessToken();
         String url ="";
         switch (type) {
@@ -114,6 +122,12 @@ public class CustomerAccessTokenUtil {
             case STOREGUIDE:
                 url = String.format(storeGuideListUrl,token);
                 break;
+            case FINANCE:
+                url = String.format(financeListUrl,pageNum,token);
+                break;
+            case WAREHOUSE:
+                url = String.format(warehouseListUrl,pageNum,token);
+                break;
         }
         return url;
     }