3.7门店经销商倍增人员

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

@@ -342,17 +342,60 @@ public class AnalysisDiyCustomerComponent {
                     STAFF.addAll(json.getJSONArray("data"));
                 }
             }
-            success += buildSysUserStaff(STAFF, loginNameSet, diyNameSet, failDetails, packageId, chainsMap);
+            success += buildSysUserStaff(STAFF, loginNameSet, diyNameSet, failDetails, packageId, chainsMap,8);
             total += STAFF.size();
         }else{
             code = json.getInteger("code");
             if(code==0){
                 STAFF.addAll(json.getJSONArray("data"));
-                success += buildSysUserStaff(STAFF, loginNameSet, diyNameSet, failDetails, packageId, chainsMap);
+                success += buildSysUserStaff(STAFF, loginNameSet, diyNameSet, failDetails, packageId, chainsMap,8);
                 total += STAFF.size();
             }
         }
 
+        //3.7经销商倍增人员人员(门店经销商)
+        String beizengJson ="";
+        JSONArray bz = new JSONArray();
+        try {
+            beizengJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.BZ, 1+""));
+        } catch (Exception e) {
+            log.error("3.7经销商倍增人员列表！");
+            customerAccessTokenUtil.reSetToken();
+            throw e;
+        }
+
+        JSONObject bzJson = JSONObject.parseObject(beizengJson);
+        Integer bzCount = bzJson.getInteger("count");
+        if(bzCount>100){
+            int co = 0;
+            if (bzCount%100 != 0){
+                co = (bzCount/100) +2;
+            }else{
+                co = (bzCount/100) +1;
+            }
+            for (int i = 1; i < co; i++) {
+                try {
+                    bzJson = JSONObject.parseObject(HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.STAFF,i+"")));
+                } catch (Exception e) {
+                    log.error("循环获取3.7经销商倍增人员错误！第"+i+"页");
+                    customerAccessTokenUtil.reSetToken();
+                    throw e;
+                }
+                code = bzJson.getInteger("code");
+                if(code==0){
+                    bz.addAll(bzJson.getJSONArray("data"));
+                }
+            }
+            success += buildSysUserStaff(bz, loginNameSet, diyNameSet, failDetails, packageId, chainsMap,10);
+            total += bz.size();
+        }else{
+            code = bzJson.getInteger("code");
+            if(code==0){
+                bz.addAll(bzJson.getJSONArray("data"));
+                success += buildSysUserStaff(bz, loginNameSet, diyNameSet, failDetails, packageId, chainsMap,10);
+                total += bz.size();
+            }
+        }
         /*try {
             JSONObject bossListJson = JSONObject.parseObject(HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.BOSSLIST, null)));
             code = bossListJson.getInteger("code");
@@ -1066,12 +1109,11 @@ public class AnalysisDiyCustomerComponent {
 
     /***
      *
-     * 3.6经销商经销人员门店
+     * 3.6/3.7经销商经销人员门店
      * **/
-    public Integer buildSysUserStaff(JSONArray STAFF, Set<String> loginNameSet,Set<String> diyNameSet, List<SyncFailDetail> failDetails,String packageId, Map<String,Customers> cusMap){
+    public Integer buildSysUserStaff(JSONArray STAFF, Set<String> loginNameSet,Set<String> diyNameSet, List<SyncFailDetail> failDetails,String packageId, Map<String,Customers> cusMap,Integer isManager){
         //JSONArray jsonArray = json.getJSONArray("data");
         int count = 0;
-        int isManager=8;
         List<String > interfaceList=new ArrayList<>();
         for(int x =0;x<STAFF.size();x++){
             JSONObject jsonObject = STAFF.getJSONObject(x);

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

@@ -24,7 +24,8 @@ public class CustomerAccessTokenUtil {
         BUSINESSLIST,*/
         WAREHOUSE,
         AllRole,
-        STAFF;
+        STAFF,
+        BZ;
 
 
     }
@@ -78,6 +79,9 @@ public class CustomerAccessTokenUtil {
     //获取经销商经销商人员列表
     private String staffUrl;
 
+    //获取3.7经销商倍增人员
+    private String bzUrl;
+
     @PostConstruct
     public void init() {
         tokenUrl=domain+"/auth/jwt/v1/gettoken?appid=%s&appsecret=%s";
@@ -99,6 +103,8 @@ public class CustomerAccessTokenUtil {
         allRoleUrl=domain+"/api/chuwei/v1/user/all/list?access_token=%s";
 
         staffUrl=domain+"/api/diydt/v1/user/staff/list?page=%s&access_token=%s";
+
+        bzUrl=domain+"/api/diydt/v1/user/beizeng/list?page=%s&access_token=%s";
     }
 
     public String getAccessToken(){
@@ -177,6 +183,9 @@ public class CustomerAccessTokenUtil {
                 break;
             case STAFF:
                 url = String.format(staffUrl,pageNum,token);
+                break;
+            case BZ:
+                url = String.format(bzUrl,pageNum,token);
         }
         return url;
     }