package com.cloud.user.controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.model.common.Result;
|
import com.cloud.user.model.*;
|
import com.cloud.user.service.BbPersonToDevService;
|
import com.cloud.user.utils.Base64Utils;
|
import io.swagger.annotations.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.ArrayUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.MediaType;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.ServletContext;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpSession;
|
import java.io.UnsupportedEncodingException;
|
import java.util.*;
|
|
/**
|
* 人员分享 更新 设备节点查询 接口
|
* wp
|
* 2018-11-29
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/data/api-u/perDev")
|
@Api(value = "BbPersonToDevController", description = "/data/api-u/perDev 人员分享 更新 设备节点查询 接口")
|
public class BbPersonToDevController {
|
|
@Autowired
|
private BbPersonToDevService personToDevService;
|
|
private final String SyncDataBaseSessionKey = "cluSyncDataBase"; // 将 底库数据存于 session 中 的key
|
|
private final String updatePersonMap = "updatePersonMap"; // 待更新后
|
|
private final String sharePersonToDevList = "sharePersonToDevList";
|
|
private final String selectSharePerson = "selectSharePerson"; // 后台存储待分享人员
|
|
private final String dataBA = "dataBA";// 返回判断状态
|
|
private final String before = "before"; // 返回转台为之前
|
|
private final String after = "after"; // 返回状态为之后
|
private final String returnData = "returnData"; // 返回包装数据
|
|
private int baseTime = 0; // 轮询 底库ip 调用 次数增长值
|
|
@PostMapping("/getCluDataList")
|
@ApiOperation(value = "getCluDataList 集群下设备列表查询", notes = "/getCluDataList", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
})
|
public Result getCluDataList() {
|
JSONArray allCluListData = personToDevService.getAllCluListData();
|
if (allCluListData != null) log.info("allCluListData 集群设备:" + allCluListData.size());
|
else {
|
log.info("集群设备查询为空");
|
allCluListData = new JSONArray();
|
}
|
return Result.ok("success", allCluListData);
|
}
|
|
@PostMapping("/getCluDataBaseList")
|
@ApiOperation(value = "getCluDataBaseList 获取集群下所有底库", notes = "/getCluDataBaseList", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", paramType = "body", dataType = "Map", value = "{\"likeName\":\"\"}")
|
public Result getCluDataBaseList(@RequestBody Map<String, Object> map, HttpServletRequest req) {
|
List<DBaseCluster> allCluDataBaseList = personToDevService.getAllCluDataBaseList();
|
List<JSONObject> dbList = new ArrayList<JSONObject>();
|
DBaseCluster dBaseCluster = null;
|
for (int i = 0, item = allCluDataBaseList.size(); i < item; ++i) {
|
dBaseCluster = allCluDataBaseList.get(i);
|
boolean isFlag = true;
|
String likeName = "";
|
if (map.get("likeName") != null) {
|
likeName = map.get("likeName").toString().trim();
|
}
|
if (!likeName.isEmpty()) {
|
if (dBaseCluster.getCluName() == null || !dBaseCluster.getCluName().contains(likeName)) isFlag = false;
|
}
|
JSONObject jsonObj = new JSONObject();
|
jsonObj.put("id", dBaseCluster.getCluId());
|
jsonObj.put("parentId", "0");
|
jsonObj.put("label", dBaseCluster.getCluName());
|
List<SyncDataBase> syncDataBase = dBaseCluster.getSyncDataBase();
|
List<JSONObject> children = new ArrayList<JSONObject>();
|
if (syncDataBase != null && syncDataBase.size() > 0) {
|
for (SyncDataBase obj : syncDataBase) {
|
if (isFlag || (obj.getTableName() != null && obj.getTableName().contains(likeName))) {
|
JSONObject jsono = new JSONObject();
|
jsono.put("parentId", dBaseCluster.getCluId());
|
jsono.put("id", obj.getUuid());
|
jsono.put("label", obj.getTableName());
|
jsono.put("children", new JSONArray());
|
children.add(jsono);
|
}
|
}
|
}
|
if (isFlag || children.size() > 0) {
|
jsonObj.put("children", children);
|
dbList.add(jsonObj);
|
} else {
|
allCluDataBaseList.remove(i--);
|
}
|
}// 处理结束后再 存储 底库集群状态
|
HttpSession session = req.getSession();
|
session.setAttribute(SyncDataBaseSessionKey, JSONObject.toJSONString(allCluDataBaseList));
|
log.info("allCluDataBaseList底库集群:" + allCluDataBaseList.size());
|
return Result.ok("success", dbList);
|
}
|
|
@PostMapping("/sharePersonToDBNode")
|
@ApiOperation(value = "sharePersonToDBNode 分享选中人员到选中底库", notes = "/sharePersonToDBNode", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"tableIds\":[\"底库uuid集合\"],\"persons\":[\"人员Id\"]}",
|
dataType = "Map", paramType = "body")
|
public Result addSomePersonToDataBase(@RequestBody Map<String, Object> map, HttpServletRequest req) {
|
List<String> persons = (List<String>) map.get("persons");
|
List<String> tableIds = (List<String>) map.get("tableIds");
|
log.info("分享接受值:persons:" + persons + "tableIds:" + tableIds);
|
if (persons != null && persons.size() > 0) {
|
List<CServerPerson> perslist = personToDevService.findByPersonIds(persons);
|
if (perslist.size() < 1) {
|
log.info("分享前查询该人员失败" + perslist);
|
return Result.error(new RuntimeException("该人员不存在。"));
|
}
|
// persons 的 feature 转换
|
for (CServerPerson cServerPerson : perslist) {
|
if (cServerPerson.getByteFeature() != null) {
|
byte[] byteFeature = cServerPerson.getByteFeature();
|
if (byteFeature.length > 3) {
|
log.info("分享前查询该人员id:" + cServerPerson.getPersonId());
|
String s = Base64Utils.byteToBase64(cServerPerson.getByteFeature());
|
cServerPerson.setByteFeature(new byte[0]);
|
cServerPerson.setFeature(s);
|
} else {
|
log.info("该人员没有特征值不能分享到集群，人员id:" + cServerPerson.getPersonId() + "特征值信息byteFeature：" + byteFeature);
|
throw new RuntimeException(cServerPerson.getName() + "该人员没有特征值不能分享到该集群。");
|
}
|
} else {
|
log.info("该人员没有特征值不能分享到集群，人员id:" + cServerPerson.getPersonId());
|
}
|
}
|
List<IpTable> ipInfos = new ArrayList<IpTable>();
|
List<String> tableId = tableIds;
|
HttpSession session = req.getSession();
|
if (tableId != null && tableId.size() > 0) {
|
String json = (String) session.getAttribute(SyncDataBaseSessionKey);
|
List<DBaseCluster> dBCluList = (List<DBaseCluster>) JSONObject.parseArray(json, DBaseCluster.class);
|
log.info(dBCluList.size() + "集群信息 session查询");
|
if (dBCluList == null) {
|
return Result.error(new RuntimeException("请先查询底库集群列表"));
|
}
|
for (DBaseCluster dBaseCluster : dBCluList) { // 各集群 循环
|
log.info(dBaseCluster + "分享时查询集群信息");
|
List<SyncDataBase> syncDBs = dBaseCluster.getSyncDataBase();
|
IpTable ipTable = new IpTable();
|
boolean flag = false;
|
for (SyncDataBase sDB : syncDBs) { // 本集群 各同步底库 循环
|
if (tableId.contains(sDB.getUuid())) { // 待分享底库uuid集合 包含节点中
|
if (!flag) {
|
List<CluIP> cluIPList = dBaseCluster.getCluIPList();
|
CluIP cluIP = cluIPList.get(baseTime % cluIPList.size());
|
ipTable.setIp(cluIP.getNode_ip()); // 获取节点 IP
|
flag = true;
|
ipTable.setCluId(dBaseCluster.getCluId()); // 获取集群id
|
ipTable.setTableIds(new ArrayList<String>());
|
}
|
ipTable.getTableIds().add(sDB.getUuid()); // 将此节点 table uuid 加入集合
|
}
|
}
|
if (flag) {
|
ipInfos.add(ipTable);
|
} // 存在底库 在添加
|
}
|
baseTime++; // 循环 节点 增加
|
List<PerInDBStatus> cSerResults = personToDevService.addSyncPersons(perslist, ipInfos);
|
session.setAttribute(sharePersonToDevList, JSONObject.toJSONString(cSerResults));
|
// 更新 所有已分享成功的人员
|
for (PerInDBStatus cSerResult : cSerResults) {
|
if (cSerResult.getIsSomeSuccess() != null && cSerResult.getIsSomeSuccess() && cSerResult.getPersonId() != null) {
|
if (cSerResult.getCluList().size() > 0) {
|
Set<String> cluInfos = cSerResult.getCluList(); // 个集群id 获取
|
Integer integer = personToDevService.updatePersonForCluInfo(cluInfos, cSerResult.getPersonId()); // 集群id信息 加入数据库中
|
log.info(cSerResult.getPersonId() + "该人员已更新，status:" + integer);
|
}
|
}
|
}
|
// 将 选中人员 下发 到 es 索引中 便于 安卓 查询 使用 wp 19-03-19 代码编写
|
List<JSONObject> padPersonInfos = personToDevService.addPersonsToEs(persons);
|
log.info("并分享并存储到es为pad:" + padPersonInfos.toString());
|
return Result.ok("分享到底库成功。", cSerResults);
|
} else {
|
return Result.error(new RuntimeException("未选中分享集群底库。"));
|
}
|
} else {
|
return Result.error(new RuntimeException("未选中分享人员。"));
|
}
|
}
|
|
@PostMapping("/addPersonsToEs")
|
@ApiOperation(value = "addPersonsToEs 分享选中人员加入es", notes = "/addPersonsToEs", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
public Result addPersonsToEs(@RequestParam @ApiParam(value = "personId列表") List<String> list, HttpServletRequest req) {
|
log.info("后台存储分享人员信息" + list.size());
|
log.info("第一条人员信息" + (list.size() > 0 ? list.get(0) : 0));
|
List<JSONObject> padPersonInfos = personToDevService.addPersonsToEs(list);
|
return Result.ok("存储分享人员到es", padPersonInfos);
|
}
|
|
|
@PostMapping("/selectSharePersonToSession")
|
@ApiOperation(value = "selectSharePersonToSession 分享选中人员后台暂存", notes = "/selectSharePersonToSession", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "人员信息", dataType = "Array<Map>", paramType = "body")
|
public Result addSomePersonToDataBase(@RequestBody List<Map<String, Object>> list, HttpServletRequest req) {
|
log.info("后台存储分享人员信息" + list.size());
|
log.info("第一条人员信息" + (list.size() > 0 ? list.get(0) : 0));
|
if (list.size() > 0) {
|
req.getSession().setAttribute(selectSharePerson, list);
|
}
|
return Result.ok("存储分享人员", "{\"perSize\":\"" + (list != null ? list.size() : 0) + "\"}");
|
}
|
|
@PostMapping("/getSelectPersonFromSession")
|
@ApiOperation(value = "getSelectPersonFromSession 分享选中人员后台获取", notes = "/getSelectPersonFromSession", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"contVal\":\"输入内容\"}",
|
dataType = "Map", paramType = "body")
|
public Result getSelectPersonFromSession(@RequestBody Map<String, Object> map, HttpServletRequest req) {
|
String contVal = (String) map.get("contVal");
|
List<Map<String, Object>> list = (List<Map<String, Object>>) req.getSession().getAttribute(selectSharePerson);
|
List<Map<String, Object>> list1 = new ArrayList<Map<String, Object>>();
|
if (list != null) {
|
log.info("分享选中人员后台获取" + list.size());
|
log.info(list + "全部人员信息");
|
log.info("第一条人员信息" + (list.size() > 0 ? list.get(0) : 0));
|
list1.addAll(list);
|
if (contVal != null && !contVal.isEmpty() && list1.size() > 0) {
|
for (int i = 0; i < list1.size(); i++) {
|
Map<String, Object> strMap = list1.get(i);
|
if (strMap != null) {
|
String name = (String) strMap.get("name");
|
String cardId = (String) strMap.get("cardId");
|
if ((name != null && name.contains(contVal)) || (cardId != null && cardId.contains(contVal))) {
|
} else {
|
list1.remove(i--);
|
}
|
} else {
|
list1.remove(i--);
|
}
|
}
|
}
|
return Result.ok("获取待分享人员", list1);
|
} else {
|
return Result.error(new RuntimeException("人员不存在"));
|
}
|
}
|
|
|
@PostMapping("/getSharePersonStatusBySession")
|
@ApiOperation(value = "getSharePersonStatusBySession 获取分享人员后单人信息", notes = "/getSharePersonStatusBySession", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personId\":\"人员id\"}", dataType = "Map", paramType = "body")
|
public Result getSharePersonStatusBySession(@RequestBody(required = true) Map<String, Object> map, HttpServletRequest req)
|
throws UnsupportedEncodingException {
|
String personId = (String) map.get("personId");
|
if (personId != null && personId.isEmpty()) personId = null;
|
HttpSession session = req.getSession();
|
String json = (String) session.getAttribute(sharePersonToDevList);
|
List<PerInDBStatus> cSerResults = JSONObject.parseArray(json, PerInDBStatus.class);
|
if (personId == null || "".equals(personId)) {
|
return Result.error(new RuntimeException("请选择已分享人员"));
|
}
|
HashMap<String, Object> returnMap = new HashMap<>();
|
if (cSerResults == null) {
|
Result personDataBaseSyncStatus = getPersonDataBaseSyncStatus(map, req);
|
Object data = personDataBaseSyncStatus.getData();
|
returnMap.put(dataBA, before);
|
returnMap.put(returnData, data);
|
// throw new RuntimeException("分享人员后单人信息不存在，请重新分享。");
|
} else {
|
boolean isGetSharePerson = false;
|
PerInDBStatus getSharePerson = null;
|
for (PerInDBStatus cSerResult : cSerResults) {
|
if (personId.equals(cSerResult.getPersonId())) {
|
isGetSharePerson = true;
|
getSharePerson = cSerResult;
|
break;
|
}
|
}
|
if (isGetSharePerson) {
|
returnMap.put(dataBA, after);
|
returnMap.put(returnData, getSharePerson);
|
} else {
|
Result personDataBaseSyncStatus = getPersonDataBaseSyncStatus(map, req);
|
Object data = personDataBaseSyncStatus.getData();
|
returnMap.put(dataBA, before);
|
returnMap.put(returnData, data);
|
Result.ok("查询分享单个人员成功。", returnMap);
|
// return Result.error(new RuntimeException("查询分享单个人员失败。"));
|
}
|
}
|
return Result.ok("查询分享单个人员成功。", returnMap);
|
}
|
|
@PostMapping("/getPersonDBSyncStatus")
|
@ApiOperation(value = "getPersonDBSyncStatus 查询当前人员真实底库状态,分享前，待更新页面都可用", notes = "/getPersonDBSyncStatus",
|
httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personId\":\"人员id\"}", required = true, dataType = "Map", paramType = "body")
|
public Result getPersonDataBaseSyncStatus(@RequestBody Map<String, Object> map, HttpServletRequest req) throws UnsupportedEncodingException {
|
String persons = (String) map.get("personId");
|
if (persons != null && persons.isEmpty()) persons = null;
|
HttpSession session = req.getSession();
|
if (persons != null && !"".equals(persons)) {
|
String json = (String) session.getAttribute(SyncDataBaseSessionKey);
|
List<DBaseCluster> dBCluList = JSONObject.parseArray(json, DBaseCluster.class);
|
if (dBCluList == null) {
|
throw new RuntimeException("请先查询集群列表是否存在。");
|
}
|
List<String> ips = new ArrayList<String>();
|
for (DBaseCluster dBaseCluster : dBCluList) {
|
ips.add(dBaseCluster.getCluIPList().get(0).getNode_ip());
|
}
|
List<CSerResult> exists = personToDevService.isExists(persons, ips);
|
|
return Result.ok("success", exists);
|
}
|
return Result.error(new RuntimeException("未选中分享集群底库。"));
|
}
|
|
@PostMapping("/updatePersonBySyncStatus")
|
@ApiOperation(value = "updatePersonBySyncStatus 更新待更新人员信息", notes = "/updatePersonBySyncStatus", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"persons\":[\"人员id\",\"4805\",\"4806\"]}",
|
dataType = "Map", paramType = "body")
|
public Result updatePersonBySyncStatus(@RequestBody Map<String, Object> map, HttpServletRequest req)
|
throws UnsupportedEncodingException {
|
List<String> persons = (List<String>) map.get("persons");
|
HttpSession session = req.getSession();
|
String json = (String) session.getAttribute(SyncDataBaseSessionKey);
|
List<DBaseCluster> dBCluList = JSONObject.parseArray(json, DBaseCluster.class);
|
List<String> ipInfos = new ArrayList<String>();
|
if (dBCluList == null) {
|
throw new RuntimeException("请先查询集群列表是否存在。");
|
}
|
if (persons == null || persons.size() < 1) {
|
return Result.error(new RuntimeException("请选择待更新人员"));
|
}
|
for (DBaseCluster dBaseCluster : dBCluList) {
|
List<CluIP> cluIPList = dBaseCluster.getCluIPList();
|
String ip = cluIPList.get(baseTime % cluIPList.size()).getNode_ip();
|
ipInfos.add(ip);
|
}
|
++baseTime;
|
if (baseTime > 100) this.baseTime = 0;
|
if (ipInfos.size() < 1) {
|
return Result.error(new RuntimeException("集群信息为空，如若实际存在集群,请重试"));
|
}
|
log.info(ipInfos + "ip集合");
|
Map<String, List<UpdatePerToViewResult>> cResultMap = personToDevService.updateSyncPersons(persons, ipInfos);
|
session.setAttribute(updatePersonMap, JSONObject.toJSONString(cResultMap));
|
Collection<List<UpdatePerToViewResult>> values = cResultMap.values();
|
boolean isAllSuccess = true;
|
for (List<UpdatePerToViewResult> value : values) {
|
for (UpdatePerToViewResult result : value) {
|
if ("-1".equals(result.getResult())) {
|
isAllSuccess = false;
|
break;
|
}
|
}
|
if (!isAllSuccess) break;
|
}
|
if (isAllSuccess) {
|
return Result.ok("更新人员成功。", cResultMap);
|
} else {
|
return Result.custom("更新人员失败。", 203, false, cResultMap);
|
}
|
}
|
|
@PostMapping("/getUpdatePersonStatusBySession")
|
@ApiOperation(value = "getUpdatePersonStatusBySession 获取待更新人员将要被覆盖人员被更新信息", notes = "/getUpdatePersonStatusBySession", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personId\":\"被合并人员id\",\"fatherPersonId\":\"所合并人员id\"}", dataType = "Map", paramType = "body")
|
public Result getUpdatePersonStatusBySession(@RequestBody(required = true) Map<String, Object> map, HttpServletRequest req) throws UnsupportedEncodingException {
|
String personId = (String) map.get("personId");
|
String fatherPersonId = (String) map.get("fatherPersonId");
|
if (personId != null && personId.isEmpty()) personId = null;
|
HttpSession session = req.getSession();
|
String json = (String) session.getAttribute(updatePersonMap);
|
Map<String, List<UpdatePerToViewResult>> cResultMap = JSONObject.parseObject(json, HashMap.class);
|
;
|
List<String> ips = new ArrayList<>();
|
HashMap<String, Object> returnMap = new HashMap<>();
|
if (cResultMap == null) {
|
Result personDataBaseSyncStatus = getPersonDataBaseSyncStatus(map, req);
|
Object data = personDataBaseSyncStatus.getData();
|
returnMap.put(dataBA, before);
|
returnMap.put(returnData, data);
|
// throw new RuntimeException("待更新人员信息不存在，请重新更新。");
|
} else {
|
if (personId == null || "".equals(personId) || fatherPersonId == null) {
|
return Result.error(new RuntimeException("请选择待更新人员"));
|
}
|
UpdatePerToViewResult cSerResult = null;
|
if (cResultMap.get(fatherPersonId) != null) {
|
List<UpdatePerToViewResult> cSerResults = JSONArray.parseArray(cResultMap.get(fatherPersonId).toString(), UpdatePerToViewResult.class);
|
if (cSerResults != null && cSerResults.size() > 0) {
|
for (UpdatePerToViewResult updatePerToViewResult : cSerResults) {
|
if (personId.equalsIgnoreCase(updatePerToViewResult.getPersonId())) {
|
cSerResult = updatePerToViewResult;
|
break;
|
}
|
}
|
}
|
}
|
if (cSerResult == null) {
|
Result personDataBaseSyncStatus = getPersonDataBaseSyncStatus(map, req);
|
Object data = personDataBaseSyncStatus.getData();
|
returnMap.put(dataBA, before);
|
returnMap.put(returnData, data);
|
} else {
|
List<SyncDataBase> allDataBase = cSerResult.getAllDataBase();
|
List<SyncDataBase> existDataBase = cSerResult.getExistDataBase();
|
List<SyncDataBase> notDataBase = new ArrayList<SyncDataBase>();
|
if (allDataBase != null && existDataBase != null) {
|
notDataBase.addAll(allDataBase);
|
boolean b = notDataBase.removeAll(existDataBase);
|
}
|
cSerResult.setNotDataBase(notDataBase); // 获取 成功底库列表
|
returnMap.put(dataBA, after);
|
returnMap.put(returnData, cSerResult);
|
}
|
}
|
return Result.ok("查询更新人员成功。", returnMap);
|
}
|
|
@PostMapping("/getUpdatePersonDetail")
|
@ApiOperation(value = "getUpdatePersonDetail 获取待更新人员所需信息", notes = "/getUpdatePersonDetail", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personLike\":\"人员idcard/姓名\"}", dataType = "Map", paramType = "body")
|
public Result getUpdatePersonDetail(@RequestBody(required = true) Map<String, Object> map, HttpServletRequest req) {
|
String personLike = (String) map.get("personLike");
|
List<MergePersonView> cServerPeople = personToDevService.queryUpdatingPerson(personLike);
|
return Result.ok("查询待更新人员详情成功。", cServerPeople);
|
}
|
|
@PostMapping("/getUpdatePersonCount")
|
@ApiOperation(value = "getUpdatePersonCount 获取待更新人员总数", notes = "/getUpdatePersonCount", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParams({
|
})
|
public Result getUpdatePersonCount(HttpServletRequest req) {
|
Integer integer = personToDevService.queryUpdatingPersonCount();
|
return Result.ok("查询更新人员总数成功。", integer);
|
}
|
|
@PostMapping("/deleteMergePersonByPersonId")
|
@ApiOperation(value = "deleteMergePersonByPersonId 从待更新人员列表删除", notes = "/deleteMergePersonByPersonId", httpMethod = "POST",
|
produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personId\":\"合并人员id\"}", dataType = "Map", paramType = "body")
|
public Result deleteMergePersonByPersonId(@RequestBody Map<String, Object> map, HttpServletRequest req) {
|
String personId = (String) map.get("personId");
|
if (personId != null && personId.isEmpty()) personId = null;
|
Integer integer = personToDevService.deleteMergePersonByPersonId(personId);
|
return Result.ok("删除更新人员成功。", integer);
|
}
|
|
@PostMapping("/getPersonStatusForAddOrUpdateOrNow")
|
@ApiOperation(value = "getPersonStatusForAddOrUpdateOrNow 查询人员真实底库状态或分享后 更新后页面三合一接口", notes = "/getPersonStatusForAddOrUpdateOrNow",
|
httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@ApiImplicitParam(name = "map", value = "{\"personId\":\"人员id\",\"SDLType\":\"传输类型 update add\"}",
|
dataType = "Map", paramType = "body")
|
public Result getPersonStatusForAddOrUpdateOrNow(@RequestBody Map<String, Object> map, HttpServletRequest req) throws UnsupportedEncodingException {
|
String personId = (String) map.get("personId");
|
String sdlType = (String) map.get("SDLType");
|
if (personId != null && personId.isEmpty()) personId = null;
|
HttpSession session = req.getSession();
|
if (personId != null && !"".equals(personId)) {
|
String json = (String) session.getAttribute(SyncDataBaseSessionKey);
|
List<DBaseCluster> dBCluList = JSONObject.parseArray(json, DBaseCluster.class);
|
if (dBCluList == null) {
|
throw new RuntimeException("请先查询集群列表是否存在。");
|
}
|
// 判断三种状态
|
if ("update".equalsIgnoreCase(sdlType)) {
|
Result updatePersonStatusBySession = getUpdatePersonStatusBySession(map, req);
|
return updatePersonStatusBySession;
|
} else if ("add".equalsIgnoreCase(sdlType)) {
|
Result sharePersonStatusBySession = getSharePersonStatusBySession(map, req);
|
return sharePersonStatusBySession;
|
} else {
|
Result personDataBaseSyncStatus = getPersonDataBaseSyncStatus(map, req);
|
return personDataBaseSyncStatus;
|
}
|
/* List<String> ips = new ArrayList<String>();
|
for (DBaseCluster dBaseCluster : dBCluList){
|
ips.add(dBaseCluster.getCluIPList().get(0).getNode_ip());
|
}
|
List<CSerResult> exists = personToDevService.isExists(personId, ips);
|
return Result.ok("success",exists);*/
|
}
|
return Result.error(new RuntimeException("未选中分享集群底库。"));
|
}
|
}
|
