package org.springblade.modules.system.service;
|
|
import net.sf.json.JSONObject;
|
import org.springblade.common.config.DataSyncConfig;
|
import org.springblade.common.utils.HttpClientUtils;
|
import org.springblade.modules.FTP.FtpUtil;
|
import org.springblade.modules.dataSync.MysqlCenlint;
|
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 java.util.List;
|
|
import static org.springblade.common.config.FtpConfig.qfqkBaseApiUrl;
|
|
@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());
|
//装换为 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());
|
//装换为 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 s sql语句
|
*/
|
@Async
|
public void FTP(String s) {
|
FtpUtil.sqlFileUpload(s);
|
}
|
|
|
/**
|
* 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());
|
//装换为 json
|
JSONObject jsonObject = JSONObject.fromObject(userDTO);
|
//发送请求
|
try {
|
HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString());
|
System.out.println("用户新增请求已发送....");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 数据同步
|
* @param sql
|
*/
|
@Async
|
public void dataSync(String sql) {
|
if (DataSyncConfig.enable.equals("start")) {
|
//判断同步类型
|
//sql 直连处理
|
if (DataSyncConfig.type.equals("sql")) {
|
sqlDataHandler(sql);
|
}
|
|
//ftp 连接同步
|
if (DataSyncConfig.type.equals("ftp")) {
|
FTP(sql);
|
}
|
}
|
}
|
|
/**
|
* sql 直连处理
|
* @param sql sql
|
*/
|
@Async
|
public void sqlDataHandler(String sql) {
|
//以逗号分割
|
String[] split = sql.split(";");
|
if (null!=split && split.length>0) {
|
for (String sqls : split) {
|
//判断是否是新增，删除，修改
|
String substring = sqls.substring(0, 2);
|
//新增
|
if (substring.equals("in")) {
|
//运行sql语句
|
MysqlCenlint.inster(sqls);
|
}
|
//修改
|
else if (substring.equals("up")) {
|
MysqlCenlint.update(sqls);
|
}
|
//删除
|
else {
|
MysqlCenlint.delete(sqls);
|
}
|
}
|
}
|
}
|
}
|
