27 changed files with 833 additions and 107 deletions
@ -0,0 +1,100 @@ |
|||||
|
package com.zdxt.app.task; |
||||
|
|
||||
|
import com.alibaba.fastjson.JSONObject; |
||||
|
import com.zdxt.auth.dto.UserBean; |
||||
|
import com.zdxt.auth.feign.UserApi; |
||||
|
import com.zdxt.code.utils.HttpUtil; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.beans.factory.annotation.Value; |
||||
|
import org.springframework.stereotype.Component; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* @Author: kylin |
||||
|
* @Date: 2024/5/9 2:58 下午 |
||||
|
* @Version: 1.0 |
||||
|
* @Desc: TODO |
||||
|
*/ |
||||
|
@Component("userInfoAndDeptTask") |
||||
|
public class UserInfoAndDeptTask { |
||||
|
|
||||
|
@Value("${znwg.systemCode}") |
||||
|
private String systemCode; |
||||
|
@Value("${znwg.integrationKey}") |
||||
|
private String integrationKey; |
||||
|
@Value("${znwg.url}") |
||||
|
private String znwgUrl; |
||||
|
|
||||
|
@Autowired private UserApi userApi; |
||||
|
|
||||
|
|
||||
|
public void run(){ |
||||
|
this.userInfoAndDept(); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* 预警任务 |
||||
|
*/ |
||||
|
public void userInfoAndDept(){ |
||||
|
String token = ""; |
||||
|
String userInfo = ""; |
||||
|
String deptInfo = ""; |
||||
|
String destroyTken = ""; |
||||
|
try { |
||||
|
// 获取 access_token
|
||||
|
token = HttpUtil.HttpSendGet(znwgUrl + "/ebus/sfrzhqxglmk/sysPullLogin?systemCode="+systemCode+"&integrationKey="+integrationKey, null); |
||||
|
System.out.println("====================== accessToken ======================"); |
||||
|
System.out.println(token); |
||||
|
System.out.println("====================== accessToken ======================"); |
||||
|
|
||||
|
// 获取 用户信息
|
||||
|
userInfo = HttpUtil.HttpSendGet(znwgUrl + "/ebus/sfrzhqxglmk/sysPullTacc?token="+token+"&page=0&pageSize=20&status=0", null); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
System.out.println(userInfo); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
|
||||
|
// 获取 部门信息
|
||||
|
deptInfo = HttpUtil.HttpSendGet(znwgUrl + "/ebus/sfrzhqxglmk/sysPullOrg?token="+token+"&page=0&pageSize=20&status=0", null); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
System.out.println(deptInfo); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
|
||||
|
// 注销token
|
||||
|
HttpUtil.HttpSendGet(znwgUrl + "/ebus/sfrzhqxglmk/sysPullLogout?token="+token, null); |
||||
|
System.out.println("====================== destroyTken ======================"); |
||||
|
System.out.println(destroyTken); |
||||
|
System.out.println("====================== destroyTken ======================"); |
||||
|
} catch (Exception e) { |
||||
|
e.printStackTrace(); |
||||
|
} |
||||
|
JSONObject userObj = JSONObject.parseObject(userInfo); |
||||
|
JSONObject deptObj = JSONObject.parseObject(deptInfo); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
System.out.println(userObj); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
System.out.println(deptObj); |
||||
|
System.out.println("====================== userInfo ======================"); |
||||
|
|
||||
|
userApi.insertOrUpdateUserResId(convertUser(userObj)); |
||||
|
} |
||||
|
|
||||
|
private UserBean convertUser(JSONObject userJson) { |
||||
|
UserBean userBean = new UserBean(); |
||||
|
userBean.setFullname(userJson.getString("fullname")); |
||||
|
userBean.setTaskId(userJson.getString("taskId")); |
||||
|
userBean.setSystemId(userJson.getString("systemId")); |
||||
|
userBean.setEffectOn(userJson.getString("effectOn")); |
||||
|
userBean.setIsDeleted(Integer.valueOf(userJson.getString("isDeleted"))); |
||||
|
userBean.setIsDisabled(Integer.valueOf(userJson.getString("isDisabled"))); |
||||
|
userBean.setCreateAt(userJson.getString("createAt")); |
||||
|
userBean.setUpdateAt(userJson.getString("updateAt")); |
||||
|
userBean.setGuid(userJson.getString("guid")); |
||||
|
userBean.setMobileNumber(userJson.getString("mobileNumber")); |
||||
|
userBean.setCertificateNumber(userJson.getString("certificateNumber")); |
||||
|
userBean.setSrzUserid(userJson.getString("srzUserid")); |
||||
|
userBean.setIsMappingPerson(userJson.getString("isMappingPerson")); |
||||
|
userBean.setUnits(userJson.getString("units")); |
||||
|
return userBean; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,24 @@ |
|||||
|
//package com.zdxt.auth.framework.config;
|
||||
|
//
|
||||
|
//import com.fasterxml.jackson.databind.DeserializationFeature;
|
||||
|
//import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
|
//import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
|
||||
|
//import org.springframework.context.annotation.Bean;
|
||||
|
//import org.springframework.context.annotation.Configuration;
|
||||
|
//import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
|
||||
|
//
|
||||
|
//@Configuration
|
||||
|
//public class JacksonConverters {
|
||||
|
// @Bean
|
||||
|
// public HttpMessageConverters JacksonHttpMessageConverters() {
|
||||
|
// MappingJackson2HttpMessageConverter mappingJackson2HttpMessageConverter
|
||||
|
// = new MappingJackson2HttpMessageConverter();
|
||||
|
// ObjectMapper objectMapper = new ObjectMapper();
|
||||
|
// //省略其他配置开始
|
||||
|
// //反序列化的时候如果多了其他属性,抛出异常
|
||||
|
// objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, true);
|
||||
|
// mappingJackson2HttpMessageConverter.setObjectMapper(objectMapper);
|
||||
|
// //省略其他配置结束
|
||||
|
// return new HttpMessageConverters(mappingJackson2HttpMessageConverter);
|
||||
|
// }
|
||||
|
//}
|
||||
Loading…
Reference in new issue