package org.springblade.modules.system.service;

import com.alibaba.fastjson.JSON;
import net.sf.json.JSONObject;
import org.springblade.common.utils.HttpClientUtils;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.FTP.Result;
import org.springblade.modules.system.dto.UserDTO;
import org.springblade.modules.system.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.util.List;
import java.util.Map;

import static org.springblade.common.config.FtpConfig.qfqkBaseApiUrl;
import static org.springblade.modules.FTP.DataHandler.handlerUserInfo;

@Service
public class MyAsyncService {

	/**
	 * 用户新增
	 * @param user
	 */
	@Async
	public void qfqkUserSave(User user) {
		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());
		userDTO.setSecurityId(user.getId().toString());
		//装换为 json
		JSONObject jsonObject = JSONObject.fromObject(userDTO);
		//发送请求
		try {
			System.out.println("发起异步推送qfqk----用户新增");
			HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
			System.out.println("用户新增请求已发送....");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 用户信息修改
	 * @param user
	 */
	@Async
	public void updateUserByQfqk(User user) {
		String requestUrl = qfqkBaseApiUrl + "/blade-user/updateBySecurtiy";
		UserDTO userDTO = new UserDTO();
		userDTO.setCardid(user.getCardid());
		userDTO.setStatus(user.getStatus());
		userDTO.setIsDeleted(user.getIsDeleted());
		userDTO.setRealName(user.getRealName());
		userDTO.setPhone(user.getPhone());
		userDTO.setSex(user.getSex());
		userDTO.setAvatar(user.getAvatar());
		userDTO.setExamination_type(user.getExaminationType());
		userDTO.setSecurityId(user.getId().toString());
		//装换为 json
		JSONObject jsonObject = JSONObject.fromObject(userDTO);
		//发送请求
		try {
			System.out.println("发起异步推送qfqk----用户更新");
			HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 保安员信息修改(账号,身份证,密码 修改)
	 * @param user
	 */
	@Async
	public void updateUserByAccount(UserDTO user) {
		String requestUrl = qfqkBaseApiUrl + "/blade-user/updateUserByAccount";
		//装换为 json
		JSONObject jsonObject = JSONObject.fromObject(user);
		//发送请求
		try {
			HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 删除用户
	 * @param user
	 */
	@Async
	public void deleteUserByQfqk(User user) {
		String requestUrl = qfqkBaseApiUrl + "/blade-user/removeSecurity";
		//装换为 json
		JSONObject jsonObject = JSONObject.fromObject(user);
		//发送请求
		try {
			HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * FTP 传对象
	 * @param obj
	 */
	public void FTPObject(Object obj) {
		FtpUtil.objectFileUpload(obj);
	}

	/**
	 * FTP
	 * @param s sql语句
	 */
	@Async
	public void FTP(String s) {
		FtpUtil.sqlFileUpload(s);
	}


	/**
	 * 用户审查FTP
	 * @param user
	 */
	@Async
	public void userExamineFTP(User user) {
		FtpUtil.sqlFileUploadUserExamine(user);
	}


	/**
	 * test
	 * @param user
	 */
	@Async
	public void test(User user) {
		String requestUrl = qfqkBaseApiUrl + "/blade-user/test";
		//装换为 json
		JSONObject jsonObject = JSONObject.fromObject(user);
		//发送请求
		try {
			HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
		} catch (IOException e) {
			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());
			userDTO.setSecurityId(user.getId().toString());
			//装换为 json
			JSONObject jsonObject = JSONObject.fromObject(userDTO);
			//发送请求
			try {
				HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
				System.out.println("用户新增请求已发送....");
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 存入集合
	 * @param map
	 */
	public void FTPObjectList(Map<String, Object> map) {
		FtpUtil.objectFileUploadList(map);
	}

	/**
	 * 存入集合
	 * @param map
	 */
	public void FTPObjectListUserId(Map<String, Object> map) {
		FtpUtil.objectFileUploadListUserId(map);
	}

	/**
	 * 查询保安员证编号位数
	 * @param map
	 */
	public void FTPSecurityNumberBit(Map<String, Object> map) {
		FtpUtil.getSecurityNumberBit(map);
	}

	/**
	 * 考试实操成绩推送内网导入
	 * @param map
	 */
	public void FTPObjectExamScore(Map<String, Object> map) {
		FtpUtil.objectFileUploadExamScore(map);
	}
}