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();
		}
	}
}