Browse Source

对接用户接口

ZhangManMan 2 years ago
parent
commit
522fd07dab
1 changed files with 42 additions and 0 deletions
  1. 42 0
      src/main/java/com/sky/ioc/service/system/impl/UserServiceImpl.java

+ 42 - 0
src/main/java/com/sky/ioc/service/system/impl/UserServiceImpl.java

@@ -190,4 +190,46 @@ public class UserServiceImpl implements UserService {
         }
        return null;
     }
+
+    @Override
+    public ReturnMsg getUserList() {
+        // 1.请求URL
+        RestTemplate restTemplate = restTemplateConfig.build();
+        String postUrl = "http://"+dataIp+"/api/hr/HR/staff/list?pageNum=1&pageSize=10000";
+        String url = restTemplateConfig.addBaseUrl(postUrl);
+        ResponseEntity<Map> responseEntity = restTemplate.getForEntity(url, Map.class);
+        // 获取响应对象里的 body 对象
+        Map<String, Object> body = responseEntity.getBody();
+        // 获取状态码
+        Integer code = (Integer)body.get("code");
+        // 获取响应信息
+        String message = (String)body.get("msg");
+        if(code==200){
+            ArrayList list = (ArrayList) body.get("rows");
+            if(list!=null&&list.size()>0){
+                for (int i=0;i<list.size();i++){
+                    LinkedHashMap json = (LinkedHashMap) list.get(i);
+                    String staffNo = json.get("staffNo").toString();
+                    Users users = userMapper.selectOne(new LambdaQueryWrapper<Users>().eq(Users::getUserName,staffNo));
+                    if(users==null){
+                        users = new Users();
+                        users.setUserName(staffNo);
+                        users.setName(json.get("staffName").toString());
+                        users.setPhone(json.get("phone").toString());
+                        users.setCompany(json.get("departName").toString());
+                        users.setEmail(json.get("email").toString());
+                        String password = Pbkdf2Sha256Digest.encode("123456");
+                        users.setPassword(password);
+                        userMapper.insert(users);
+                    }
+                }
+            }
+            return ReturnMsg.ok();
+            //  System.out.println("data   "+data.getString(""));
+        }else{
+            log.info("获取用户数据失败:"+message);
+            return ReturnMsg.fail(message);
+        }
+    }
+
 }