package org.springblade.modules.system.service;
|
|
import net.sf.json.JSONObject;
|
import org.springblade.common.utils.HttpClientUtils;
|
import org.springblade.modules.system.dto.UserDTO;
|
import org.springblade.modules.system.entity.User;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import java.io.IOException;
|
|
import static org.springblade.common.config.FtpConfig.qfqkBaseApiUrl;
|
|
@Service
|
public class MyAsyncService {
|
|
/**
|
* 用户新增
|
* @param user
|
*/
|
@Async
|
public void qfqkUserSave(User user) {
|
// System.out.println("进入异步方法----------------------");
|
// try {
|
// Thread.sleep(30000);
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
String requestUrl = qfqkBaseApiUrl + "/blade-user/securitySaves";
|
UserDTO userDTO = new UserDTO();
|
userDTO.setAccount(user.getAccount());
|
userDTO.setCardid(user.getCardid());
|
userDTO.setPassword(user.getPassword());
|
userDTO.setSex(user.getSex());
|
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());
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
