| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.io.IOException; |
| | | import java.util.List; |
| | | |
| | | import static org.springblade.common.config.FtpConfig.qfqkBaseApiUrl; |
| | | |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | @Async |
| | | public void batchUserList(List<User> userList) { |
| | | for (User user : userList) { |
| | | String requestUrl = qfqkBaseApiUrl + "/blade-user/securitySaves"; |
| | | System.out.println("用户 = " + user.getRealName() + "异步推送了!"); |
| | | UserDTO userDTO = new UserDTO(); |
| | | userDTO.setAccount(user.getAccount()); |
| | | userDTO.setCardid(user.getCardid()); |
| | | userDTO.setPassword(user.getPassword()); |
| | | userDTO.setSex(user.getSex()); |
| | | userDTO.setAvatar(user.getAvatar()); |
| | | userDTO.setStatus(user.getStatus()); |
| | | userDTO.setPhone(user.getPhone()); |
| | | userDTO.setIsDeleted(user.getIsDeleted()); |
| | | userDTO.setRealName(user.getRealName()); |
| | | //装换为 json |
| | | JSONObject jsonObject = JSONObject.fromObject(userDTO); |
| | | //发送请求 |
| | | try { |
| | | HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString()); |
| | | System.out.println("用户新增请求已发送...."); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |
| | | } |