同步经销商魔术漆和外墙人员

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

@@ -78,12 +78,21 @@ public class AnalysisDiyCustomerComponent {
     private Long[] roleMsq;//经销商魔术漆
     private Long[] roleWqBm;//经销商外墙业务经理
     private Long[] roleSfa;//5.1家装顾问挂sfa角色
+
+
+
+
+
     public SyncLog analyDiyCustomer1() {
 
         if (roleMsq == null) {
             Long roleId = Long.parseLong(configService.selectConfigByKey("libang.msq.roleid"));
             roleMsq = new Long[]{roleId};
         }
+        if (roleWqBm == null) {
+            Long roleId = Long.parseLong(configService.selectConfigByKey("libang.wqbm.roleid"));
+            roleWqBm = new Long[]{roleId};
+        }
         Map<String, Customers> chainsMap = customersMapper.selectCustomerMapByChainsCode();
 
         List<SyncFailDetail> failDetails = new ArrayList<>();
@@ -139,6 +148,55 @@ public class AnalysisDiyCustomerComponent {
             }
         }
 
+
+
+        String WqBmUserJson = "";
+        try {
+            WqBmUserJson = HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.WQBM, 1 + ""));
+        } catch (Exception e) {
+            log.error("获取经销外墙服务商人员接口错误！");
+            customerAccessTokenUtil.reSetToken();
+            throw e;
+        }
+        JSONObject wqbmjson = JSONObject.parseObject(WqBmUserJson);
+        Integer wqbmcount = wqbmjson.getInteger("count");
+        JSONArray WQBM = new JSONArray();
+        if (wqbmcount > 100) {
+            int co = 0;
+            if (wqbmcount % 100 != 0) {
+                co = (wqbmcount / 100) + 2;
+            } else {
+                co = (wqbmcount / 100) + 1;
+            }
+            for (int i = 1; i < co; i++) {
+                try {
+                    wqbmjson = JSONObject.parseObject(HttpUtils.sendSSLGet(customerAccessTokenUtil.getUrl(UrlType.WQBM, i + "")));
+                } catch (Exception e) {
+                    log.error("循环获取经销外墙服务商人员列表接口错误！第" + i + "页");
+                    customerAccessTokenUtil.reSetToken();
+                    throw e;
+                }
+                int code = wqbmjson.getInteger("code");
+                if (code == 0) {
+                    WQBM.addAll(wqbmjson.getJSONArray("data"));
+                }
+            }
+            success += buildSysUser(WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
+            total += WQBM.size();
+
+        } else {
+            int code = msqjson.getInteger("code");
+            if (code == 0) {
+                WQBM.addAll(msqjson.getJSONArray("data"));
+                success += buildSysUser(WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
+                total += WQBM.size();
+            }
+        }
+
+
+
+
+
         try{
             syncLog.setTotalCount(total);
             syncLog.setSuccessCount(success);