拉取经销商负责人逻辑调整

suishenbang-quartz/src/main/java/com/dgtly/quartz/task/RyTask.java

@@ -66,7 +66,7 @@ public class RyTask
         analysisDiyCustomerComponent.analyDiyCustomer();
     }
     public void analyDiyCustomer1(){
-        analysisDiyCustomerComponent.analyDiyCustomer1();
+        analysisDiyCustomerComponent.analyDiyCustomer2();
     }
     /**
      * @description: 获取TUC仿石漆服务商人员

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

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.dgtly.common.exception.BusinessException;
 import com.dgtly.common.utils.ShiroSaltUtil;
+import com.dgtly.common.utils.StringUtils;
 import com.dgtly.common.utils.UserIdentityUtil;
 import com.dgtly.common.utils.http.HttpUtils;
 import com.dgtly.common.utils.security.EncryptPassWordClass;
@@ -1074,6 +1075,40 @@ public class AnalysisDiyCustomerComponent {
                     //查询岗位现阶段存在的用户
                     SysUser userOld = sysUserService.selectUserByLoginName(userid);
                     SysUser user = sysUserService.selectUserByLoginName(userid);
+                    if(StringUtils.isBlank(user.getSysUserExt().getSalesLevel())){
+                        log.info("进行用户扩展表信息补偿：--------userId:"+user.getSysUserExt().getUserId().toString());
+
+                        SysUserExt userExt = new SysUserExt();
+                        userExt.setUserId(user.getUserId());
+                        userExt.setSalesLevel("customer_level");
+                        userExt.setIsCustomerManager(isManager + "");
+                        userExt.setSapEmployeeId(userNo);
+                        userExt.setIdentity(UserIdentityUtil.UI_DIY);
+                        userExt.setPostName("DIY经销商");
+                        String orgCode = jo.getString("depCode");
+                        String code = null;
+                        if (cusMap.containsKey(orgCode)) {
+                            Customers c = cusMap.get(orgCode);
+                            userExt.setOrgCode(c.getChainsCode());
+                            userExt.setOrgName(c.getChainsName());
+                            code = c.getChainsCode();
+                        } else {
+                            userExt.setOrgCode(orgCode);
+                            userExt.setOrgName(customerName);
+                        }
+                        if (isManager == 0) {
+                            userExt.setCustomerCode(userExt.getOrgCode());
+                        } else {
+                            userExt.setCustomerCode(jo.getString("depCode"));
+                        }
+
+                        sysUserExtMapper.insertOrUpSysUserExt(userExt);
+
+
+
+                    }
+
+
                     if (("0").equals(user.getIsSync())) {
                         //查询该用户是否存在该接口返回中
                         user.setPhonenumber(jo.getString("mobile"));