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