package org.springblade.modules.FTP;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import liquibase.pro.packaged.M;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.modules.system.entity.User;
|
import org.springblade.modules.system.service.IUserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
public class DataHanlder {
|
|
@Autowired
|
private IUserService userService;
|
|
//声明对象
|
private static DataHanlder hanlder;
|
|
/**
|
* 初始化
|
*/
|
@PostConstruct
|
public void init(){
|
hanlder = this;
|
hanlder.userService = this.userService;
|
}
|
|
|
/**
|
* 数据处理
|
* @param json
|
*/
|
public static void handler(String json){
|
//以分号分割
|
List<String> list = Arrays.asList(json.split(";"));
|
//对象转换
|
for (String s : list) {
|
Map map = JSON.parseObject(s, Map.class);
|
Object user = map.get("user");
|
User user1 = JSON.parseObject(user.toString(), User.class);
|
//获取 uuid
|
String uuid = user1.getReasonForLeav();
|
//用户数据校验
|
Result result = userCheckOut(user1);
|
System.out.println("result = " + result);
|
//创建返回对象
|
Result result1 = new Result();
|
if (result.getCode()==200){
|
user1.setReasonForLeav("");
|
//去新增
|
hanlder.userService.save(user1);
|
//设置返回结果
|
result1.setCode(200);
|
result1.setUserId(user1.getId());
|
result1.setMsg("新增成功");
|
}else if (result.getCode()==201){
|
//去修改
|
user1.setReasonForLeav("");
|
User data = result.getUser();
|
user1.setId(data.getId());
|
hanlder.userService.updateById(user1);
|
//设置返回结果
|
result1.setCode(201);
|
result1.setUserId(user1.getId());
|
result1.setMsg("修改成功");
|
}else {
|
//不新增,不修改
|
//设置返回结果
|
result1.setCode(400);
|
result1.setUserId(null);
|
result1.setMsg(result.getMsg());
|
}
|
System.out.println("result1 = " + result1);
|
Map<String, Object> map1 = new HashMap<>(1);
|
map1.put(uuid,result1);
|
//向外网发送数据
|
FtpUtil.objectFileUpload(map1);
|
}
|
}
|
|
/**
|
* 用户校验
|
* @param user
|
*/
|
private static Result userCheckOut(User user) {
|
//1. 校验是否有重复导入
|
User user1 = new User();
|
user1.setCardid(user.getCardid());
|
user1.setStatus(1);
|
user1.setIsDeleted(0);
|
User one = hanlder.userService.getOne(Condition.getQueryWrapper(user1));
|
if (null!=one){
|
//判断单位是否一致
|
if (!one.getDeptId().equals(user.getDeptId())){
|
return new Result(400,null,user.getRealName() + "已在其他单位导入");
|
}else {
|
return new Result(201,"已在本单位导入",one);
|
}
|
}
|
|
//2.保安证编号校验
|
|
|
|
return new Result(200,null,"");
|
}
|
|
|
}
|
