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 {
|
|
@Autowired
|
private IUserService userService;
|
|
/**
|
* 用户新增
|
* @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 {
|
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 {
|
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 uuid
|
* @param result
|
*/
|
@Async
|
public void userInfoHandler(String uuid, Result result){
|
//用户数处理
|
User users = handlerUserInfo(uuid);
|
System.out.println("用户数据 = " + users);
|
//判断结果
|
if (result.getCode()==200){
|
//新增
|
users.setId(result.getUserId());
|
users.setStatus(1);
|
//插入数据库
|
boolean save = userService.save(users);
|
if (save){
|
//异步同步到群防群控
|
qfqkUserSave(users);
|
}
|
}else if (result.getCode()==201) {
|
//修改
|
users.setId(result.getUserId());
|
//先查询当前库是否有改用户？
|
User user2 = userService.getById(result.getUserId());
|
if (null!=user2) {
|
//数据修改
|
boolean b = userService.updateById(users);
|
if (b) {
|
//异步同步到群防群控
|
updateUserByQfqk(users);
|
}
|
}else {
|
//新增
|
boolean save = userService.save(users);
|
if (save){
|
//异步同步到群防群控
|
qfqkUserSave(users);
|
}
|
}
|
}else if (result.getCode()==203){
|
//保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 用户为新增
|
//新增
|
users.setId(result.getUserId());
|
//插入数据库
|
boolean save = userService.save(users);
|
if (save) {
|
//异步同步到群防群控
|
qfqkUserSave(users);
|
}
|
}else if (result.getCode()==204){
|
//保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请! 内网用户已存在情况
|
users.setId(result.getUserId());
|
//先查询当前库是否有改用户？
|
User user2 = userService.getById(result.getUserId());
|
//判断
|
if (null!=user2) {
|
//修改
|
//数据修改
|
boolean b = userService.updateById(users);
|
if (b){
|
//异步同步到群防群控
|
updateUserByQfqk(users);
|
}
|
}else {
|
//新增
|
boolean save = userService.save(users);
|
if (save){
|
//异步同步到群防群控
|
qfqkUserSave(users);
|
}
|
}
|
}
|
}
|
}
|
