对接用户接口

src/main/java/com/sky/ioc/entity/domain/system/Users.java

@@ -1,10 +1,13 @@
 package com.sky.ioc.entity.domain.system;
 
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 
 @Data
 public class Users {
 
+    @TableId(type = IdType.AUTO)
     private Integer id;
     /** 用户名 */
     private String userName;

src/main/java/com/sky/ioc/service/system/UserService.java

@@ -18,4 +18,6 @@ public interface UserService {
 
 
     ReturnMsg getUserData();
+
+    ReturnMsg getUserList();
 }

src/main/java/com/sky/ioc/service/system/impl/UserServiceImpl.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.sky.ioc.config.RestTemplateConfig;
 import com.sky.ioc.constant.Constant;
+import com.sky.ioc.entity.domain.meeting.MeetingRecord;
 import com.sky.ioc.entity.domain.system.Menus;
 import com.sky.ioc.entity.domain.system.Users;
 import com.sky.ioc.entity.result.system.LoginUserVo;
@@ -12,10 +13,7 @@ import com.sky.ioc.mapper.job.TokenMapper;
 import com.sky.ioc.mapper.system.MenuMapper;
 import com.sky.ioc.mapper.system.UserMapper;
 import com.sky.ioc.service.system.UserService;
-import com.sky.ioc.tool.JwtUtil;
-import com.sky.ioc.tool.Pbkdf2Sha256Digest;
-import com.sky.ioc.tool.RedisUtil;
-import com.sky.ioc.tool.ReturnMsg;
+import com.sky.ioc.tool.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -31,6 +29,7 @@ import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
 import java.util.*;
+import java.util.concurrent.ThreadLocalRandom;
 
 @Service
 @Slf4j
@@ -190,4 +189,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");
+        ThreadLocalRandom random = ThreadLocalRandom.current();
+        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);
+        }
+    }
 }