统一消息系统

@RestController

public class AuthController {

@Autowired

private UserService userService;

@PostMapping("/login")

public ResponseEntity login(@RequestBody LoginRequest request) {

// 调用统一信息门户的OAuth接口获取token

String token = getAccessTokenFromPortal(request.getUsername(), request.getPassword());

if (token == null || token.isEmpty()) {

return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body("Login failed");

}

// 解析token获取用户信息

User user = parseUserInfo(token);

// 检查用户是否已存在

if (!userService.existsByUsername(user.getUsername())) {

userService.save(user);

}

return ResponseEntity.ok("Login successful");

}

private String getAccessTokenFromPortal(String username, String password) {

// 调用统一信息门户的认证接口

RestTemplate restTemplate = new RestTemplate();

String url = "https://portal.example.com/oauth/token";

MultiValueMap map = new LinkedMultiValueMap<>();

map.add("grant_type", "password");

map.add("username", username);

map.add("password", password);

ResponseEntity response = restTemplate.postForEntity(url, map, String.class);

JsonNode jsonNode = new ObjectMapper().readTree(response.getBody());

return jsonNode.get("access_token").asText();

}

private User parseUserInfo(String token) {

// 解析token中的用户信息

// 此处仅为示例，实际应使用JWT解析库

return new User("user123", "张三", "student");

}

}

import requests

def sync_user_data(portal_url, access_token):

headers = {

'Authorization': f'Bearer {access_token}',

'Content-Type': 'application/json'

}

response = requests.get(f'{portal_url}/api/users', headers=headers)

if response.status_code == 200:

users = response.json()

for user in users:

# 将用户信息同步到迎新系统

post_response = requests.post('https://nixing.example.com/api/user', json=user, headers=headers)

print(post_response.status_code)

# 示例调用

sync_user_data('https://portal.example.com', 'your_access_token')