package com.cloud.control.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.common.utils.JsonUtil;
|
import com.cloud.common.utils.RestTemplateUtil;
|
import com.cloud.control.dao.TaskMapper;
|
import com.cloud.control.dao.TaskUserMapper;
|
import com.cloud.control.model.Task;
|
import com.cloud.control.model.TaskUser;
|
import com.cloud.control.service.TaskService;
|
import com.cloud.control.service.ClusterService;
|
import com.cloud.control.service.TaskUserService;
|
import com.cloud.control.vo.TaskUserEditVo;
|
import com.cloud.control.vo.TaskUserInfoVo;
|
import com.cloud.control.utils.DevInfoColumnMap;
|
import lombok.extern.slf4j.Slf4j;
|
import com.cloud.control.utils.EnumStr;
|
import com.cloud.control.vo.MenuTreeVo;
|
import com.cloud.model.common.Result;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.MultiValueMap;
|
import java.util.*;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Service
|
public class TaskUserServiceImpl implements TaskUserService {
|
|
@Autowired
|
private TaskUserMapper taskUserDao;
|
@Autowired
|
private TaskMapper taskDao;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private ClusterServiceImpl clusterServiceImpl;
|
@Autowired
|
private ClusterService clusterService;
|
@Autowired
|
private EnumStr enumStr;
|
|
@Override
|
public Map select(Map<String, Object> params) {
|
Map map = new HashMap();
|
List<Map> list = taskUserDao.select(params);
|
if(list !=null && list.size() >0) {
|
list.forEach(map1 -> {
|
List<String> nameList = new ArrayList();
|
JSONArray scope = JSONArray.parseArray( taskDao.selectScopeById(map1.get("taskId").toString()).getScope().toString());
|
Integer syncType = taskDao.selectScopeById(map1.get("taskId").toString()).getSyncType();
|
String taskName = taskDao.selectScopeById(map1.get("taskId").toString()).getName();
|
scope.forEach(item->{
|
String cluId = JSON.parseObject(item.toString()).get("cluId").toString();
|
String cluName = taskService.getCluOrDevAndNameOrIpById(cluId, DevInfoColumnMap.CluType,DevInfoColumnMap.nameType);
|
if(syncType == 0){
|
//本地库去请求nodes信息
|
JSONArray nodes = JSONArray.parseArray(JSON.parseObject(item.toString()).get("nodes").toString());
|
if(nodes != null){
|
nodes.forEach(node->{
|
String nodeIp = JSON.parseObject(node.toString()).get("id").toString();
|
String nodeName = taskService.getCluOrDevAndNameOrIpById(nodeIp, DevInfoColumnMap.DevType,DevInfoColumnMap.nameType);
|
nameList.add(map1.get("taskName")+"(集群:"+cluName+"/"+"节点:"+nodeName+")");
|
});
|
}else{
|
nameList.add(map1.get("taskName")+"(集群:"+cluName+")");
|
}
|
}else{
|
nameList.add(map1.get("taskName")+"(集群:"+cluName+")");
|
}
|
|
});
|
map1.put("baseInfo",nameList);
|
});
|
map.put("total", list.size());
|
map.put("list", list);
|
}else{
|
map.put("total", 0);
|
map.put("list", Collections.emptyList());
|
}
|
return map;
|
}
|
|
@Override
|
@Transactional
|
public void stopControl(List<String> ids) {
|
ids.forEach(id->{
|
taskUserDao.stopControl(id);
|
Map taskMap = taskUserDao.selectById(id);
|
Integer syncType = (Integer)taskMap.get("syncType");
|
|
if(syncType != null && syncType == 1){
|
log.info("集群同步库");
|
JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
scope.forEach(item->{
|
String cluld = ((JSONObject)item).get(DevInfoColumnMap.cluId).toString();
|
String ip = taskService.getCluOrDevAndNameOrIpById(((JSONObject)item).get(DevInfoColumnMap.cluId).toString(), DevInfoColumnMap.CluType,DevInfoColumnMap.ipType);
|
String url = "http://" + ip+ "/addPerson";
|
JSONObject jsonParam = new JSONObject();
|
jsonParam.put("uuid",taskMap.get("userId").toString());
|
jsonParam.put("TableId",taskMap.get("taskId").toString());
|
jsonParam.put("TableName",taskMap.get("name").toString());
|
jsonParam.put("SyncType","1");
|
jsonParam.put("enabled","0");
|
String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED,true);
|
if(result.contains("error")){
|
throw new IllegalArgumentException("erlang is null");
|
}
|
});
|
}else{
|
log.info("设备本地库");
|
JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
scope.forEach(item->{
|
JSONArray nodes = JSON.parseArray(JSON.parseObject(item.toString()).get(DevInfoColumnMap.nodes).toString());
|
nodes.forEach(node->{
|
String ip = taskService.getCluOrDevAndNameOrIpById(JSON.parseObject(node.toString()).get(DevInfoColumnMap.devId).toString(),
|
DevInfoColumnMap.DevType,DevInfoColumnMap.ipType);
|
String url = "http://" + ip+ "/addPerson";
|
JSONObject jsonParam = new JSONObject();
|
jsonParam.put("uuid",taskMap.get("userId").toString());
|
jsonParam.put("TableId",taskMap.get("taskId").toString());
|
jsonParam.put("TableName",taskMap.get("name").toString());
|
jsonParam.put("SyncType","0");
|
jsonParam.put("enabled","0");
|
String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED,true);
|
if(result.contains("error")){
|
throw new IllegalArgumentException("erlang is null");
|
}
|
});
|
});
|
}
|
});
|
}
|
|
@Override
|
@Transactional
|
public void deleteTaskUser(List<TaskUser> list) {
|
list.forEach(record-> {
|
taskUserDao.deleteTaskUser(record);
|
// Map taskMap = taskUserDao.selectById(record.getId());
|
// Integer syncType = (Integer)taskMap.get("syncType");
|
//
|
// if(syncType != null && syncType == 1){
|
// log.info("集群同步库");
|
// JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
// scope.forEach(item->{
|
// String ip = taskService.getCluOrDevAndNameOrIpById(JSON.parseObject(item.toString()).get("cluld").toString(), DevInfoColumnMap.CluType,DevInfoColumnMap.ipType);
|
// String url = "http://" + ip+ "/addPerson";
|
// JSONObject jsonParam = new JSONObject();
|
// jsonParam.put("uuid",taskMap.get("userId").toString());
|
// jsonParam.put("TableId",taskMap.get("taskId").toString());
|
// jsonParam.put("TableName",taskMap.get("name").toString());
|
// jsonParam.put("SyncType","1");
|
// jsonParam.put("enabled","0");
|
// String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED,true);
|
// if(result.contains("error")){
|
// throw new IllegalArgumentException("erlang is null");
|
// }
|
// });
|
// }else{
|
// log.info("设备本地库");
|
// JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
// scope.forEach(item->{
|
// JSONArray nodes = JSON.parseArray(JSON.parseObject(item.toString()).get("nodes").toString());
|
// nodes.forEach(node->{
|
// String ip = taskService.getCluOrDevAndNameOrIpById(JSON.parseObject(node.toString()).get("cluld").toString(), DevInfoColumnMap.DevType,DevInfoColumnMap.ipType);
|
// String url = "http://" + ip+ "/addPerson";
|
// JSONObject jsonParam = new JSONObject();
|
// jsonParam.put("isAdd",false);
|
// jsonParam.put("uuid",taskMap.get("userId").toString());
|
// jsonParam.put("TableId",taskMap.get("taskId").toString());
|
// jsonParam.put("TableName",taskMap.get("name").toString());
|
// jsonParam.put("SyncType","0");
|
// jsonParam.put("enabled","0");
|
// String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED,true);
|
// if(result.contains("error")){
|
// throw new IllegalArgumentException("erlang is null");
|
// }
|
// });
|
// });
|
// }
|
});
|
}
|
|
@Override
|
public Map selectById(String id) {
|
Map taskMap = taskUserDao.selectById(id);
|
return taskMap;
|
}
|
|
@Override
|
@Transactional
|
public void save(TaskUser taskUser) {
|
taskUserDao.updateByPrimaryKeySelective(taskUser);
|
//判断身份证号是否变化了，变了的话需要往C同步
|
// Map taskMap = taskUserDao.selectById(taskUser.getId());
|
// if(!taskMap.get("idCard").toString().equals(taskUser.getIdCard())) {
|
// log.info("身份证号改变，需要更新到C");
|
// Integer syncType = (Integer) taskMap.get("syncType");
|
//
|
// if (syncType != null && syncType == 1) {
|
// log.info("集群同步库");
|
// JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
// scope.forEach(item -> {
|
// String ip = taskService.getCluOrDevAndNameOrIpById(JSON.parseObject(item.toString()).get("id").toString(), DevInfoColumnMap.CluType, DevInfoColumnMap.ipType);
|
// String url = "http://" + ip + "/addPerson";
|
// JSONObject jsonParam = new JSONObject();
|
// jsonParam.put("uuid", taskMap.get("userId").toString());
|
// jsonParam.put("TableId", taskMap.get("taskId").toString());
|
// jsonParam.put("TableName", taskMap.get("name").toString());
|
// jsonParam.put("SyncType", "1");
|
//
|
// String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED, true);
|
// if (result.contains("error")) {
|
// throw new IllegalArgumentException("erlang is null");
|
// }
|
// });
|
// } else {
|
// log.info("设备本地库");
|
// JSONArray scope = JSON.parseArray(taskMap.get("scope").toString());
|
// scope.forEach(item -> {
|
// JSONArray nodes = JSON.parseArray(JSON.parseObject(item.toString()).get("nodes").toString());
|
// nodes.forEach(node -> {
|
// String ip = taskService.getCluOrDevAndNameOrIpById(JSON.parseObject(node.toString()).get("id").toString(), DevInfoColumnMap.DevType, DevInfoColumnMap.ipType);
|
// String url = "http://" + ip + "/addPerson";
|
// JSONObject jsonParam = new JSONObject();
|
// jsonParam.put("isAdd", false);
|
// jsonParam.put("uuid", taskMap.get("userId").toString());
|
// jsonParam.put("TableId", taskMap.get("taskId").toString());
|
// jsonParam.put("TableName", taskMap.get("name").toString());
|
// jsonParam.put("SyncType", "0");
|
// String result = RestTemplateUtil.post(url, jsonParam, MediaType.APPLICATION_FORM_URLENCODED, true);
|
// if (result.contains("error")) {
|
// throw new IllegalArgumentException("erlang is null");
|
// }
|
// });
|
// });
|
// }
|
// }
|
}
|
|
@Override
|
@Transactional
|
public void saveFromC(List<TaskUser> taskUsers) {
|
taskUsers.forEach(taskUser -> {
|
taskUserDao.selectById(taskUser.getId());
|
taskUserDao.updateByPrimaryKeySelective(taskUser);
|
});
|
|
}
|
|
@Override
|
public void add(TaskUser taskUser) {
|
taskUser.setId(UUID.randomUUID().toString());
|
taskUser.setDelFlag("0");
|
taskUser.setSource(2);
|
taskUser.setCreateTime(new Date());
|
taskUser.setUpdateTime(new Date());
|
taskUserDao.insertSelective(taskUser);
|
}
|
|
@Override
|
public void joinControl(TaskUser taskUser) {
|
//先删除原有的用户布控任务关联
|
taskUserDao.deleteByUser(taskUser.getUserId());
|
List<String> taskIds = taskUser.getTaskIds();
|
//再进行新的关联
|
taskIds.forEach(taskId->{
|
taskUser.setId(UUID.randomUUID().toString());
|
taskUser.setTaskId(taskId);
|
taskUserDao.insertSelective(taskUser);
|
});
|
|
}
|
|
/**
|
* 编辑布控任务人员时，从集群底库中选择
|
* @param params
|
* @return
|
*/
|
@Override
|
public List findTaskUserMenusFromCluster(Map<String, Object> params) {
|
List result = new ArrayList<>();
|
|
List<TaskUser> taskUserAll = taskUserDao.findAll(params);
|
final String TYPE_MENU = "MENU";
|
Result allClusterInfo = clusterService.findAllNode();//查找所有集群-》节点（包含同步库）-》设备（本地库信息）
|
if(allClusterInfo !=null && allClusterInfo.isSuccess()){
|
JSONArray jsonClusters = JSONArray.parseArray(allClusterInfo.getData().toString());
|
if(jsonClusters !=null && jsonClusters.size()>0){
|
for(Object clusterOjb: jsonClusters){
|
JSONObject clusterJson = (JSONObject)clusterOjb;
|
JSONObject clusterMenu = new JSONObject();
|
clusterMenu.put("id", clusterJson.getString("id"));//集群id
|
clusterMenu.put("type", TYPE_MENU);//菜单
|
clusterMenu.put("userInfo", clusterJson.getString("name"));//集群名称
|
|
List childs = new ArrayList<>();
|
JSONArray syncDbs = clusterJson.getJSONArray("syncDbs");//集群内同步库信息
|
if(syncDbs !=null && syncDbs.size()>0){
|
for(Object syncDb : syncDbs){
|
JSONObject jsonSyncDb = (JSONObject) syncDb;
|
JSONObject syncMenu = new JSONObject();
|
String syncDbId = jsonSyncDb.getString("uuid");//同步库id
|
syncMenu.put("id", syncDbId);
|
syncMenu.put("userInfo", jsonSyncDb.getString("tableName"));//同步库名
|
syncMenu.put("type", TYPE_MENU);
|
List syncUsers = getTaskUserChildren(syncDbId, taskUserAll);
|
syncMenu.put("child", syncUsers);
|
|
childs.add(syncMenu);
|
}
|
}
|
|
JSONArray nodes = clusterJson.getJSONArray("nodes");//集群内节点信息
|
if(nodes !=null && nodes.size()>0){
|
for(Object node : nodes){
|
JSONObject jsonNode = (JSONObject)node;
|
JSONArray nodeLocalDbs = jsonNode.getJSONArray("localDates");
|
if(nodeLocalDbs !=null && nodeLocalDbs.size()>0){
|
for(Object localDb : nodeLocalDbs){
|
JSONObject jsonLocalDb = (JSONObject) localDb;
|
JSONObject localMenu = new JSONObject();
|
String localDbId = jsonLocalDb.getString("uuid");
|
localMenu.put("id", localDbId);
|
localMenu.put("userInfo", jsonLocalDb.getString("tableName")+"("+jsonNode.getString("devName")+")");
|
localMenu.put("type", TYPE_MENU);
|
List localUsers = getTaskUserChildren(localDbId, taskUserAll);
|
localMenu.put("child", localUsers);
|
|
childs.add(localMenu);
|
}
|
}
|
}
|
}
|
|
clusterMenu.put("child", childs);
|
result.add(clusterMenu);
|
|
}
|
}
|
}
|
|
return result;
|
}
|
|
/**
|
* 计算同步库或本地库id下的人员，并生成对应的递归菜单结构
|
* @param parentId
|
* @param taskUsers
|
* @return
|
*/
|
private List getTaskUserChildren(String parentId,List<TaskUser> taskUsers){
|
List list = new ArrayList<>();
|
if(taskUsers !=null && taskUsers.size()>0){
|
for(TaskUser taskUser : taskUsers){
|
if(taskUser.getTaskId().equals(parentId)){
|
JSONObject menu = new JSONObject();
|
menu.put("id", taskUser.getId());
|
menu.put("icon", taskUser.getImgUrl());
|
String showName = "";
|
TaskUserInfoVo userInfo = new TaskUserInfoVo();
|
if(StringUtils.isNotEmpty(taskUser.getUserName()))
|
showName += taskUser.getUserName();
|
if(taskUser.getSex() != null)
|
showName += "/" + (taskUser.getSex() == 1?"男":"女");
|
if(StringUtils.isNotEmpty(taskUser.getIdCard()))
|
showName += "/" + taskUser.getIdCard();
|
if(StringUtils.isNotEmpty(taskUser.getMobile()))
|
showName += "/" + taskUser.getMobile();
|
if(showName.startsWith("/"))
|
showName = showName.substring(1);
|
|
userInfo.setId(taskUser.getId());
|
userInfo.setSex(taskUser.getSex());
|
userInfo.setUsername(taskUser.getUserName());
|
userInfo.setIdCard(taskUser.getIdCard());
|
userInfo.setMobile(taskUser.getMobile());
|
userInfo.setImgUrl(taskUser.getImgUrl());
|
|
menu.put("userInfo", showName);
|
menu.put("detail", userInfo);
|
|
list.add(menu);
|
}
|
}
|
}
|
|
return list;
|
}
|
|
/**
|
* 从人员管理选择布控人员
|
* @param params
|
* @return
|
*/
|
public List findTaskUserMenusFromPlat(Map<String, Object> params){
|
List resultList = new ArrayList();
|
if(params !=null && params.containsKey("orgById") && params.get("orgById")!=null && StringUtils.isNotEmpty(params.get("orgById").toString())){
|
String baseUrl = "http://"+enumStr.getUserHOSTNAME()+":"+enumStr.getUserHTTP_PORT();
|
JSONObject orgParams = new JSONObject();
|
orgParams.put("currentId", params.get("orgById"));
|
orgParams.put("name", params.get("name"));//模糊搜索组织名称
|
//1.获取这个人可以看到的组织机构列表
|
String strOrgs = RestTemplateUtil.get(baseUrl+"/data/api-u/org/findDownByType", orgParams,true);
|
if(StringUtils.isNotEmpty(strOrgs)){//有组织机构id
|
JSONArray orgList = JSONArray.parseArray(strOrgs);
|
|
//2.获取人员总库中当前登录人可以管理的总库人员
|
JSONObject userQueryParams = new JSONObject();
|
userQueryParams.put("id", params.get("orgById"));
|
userQueryParams.put("name", params.get("name"));//模糊搜索用户姓名
|
|
String strBbPersons = RestTemplateUtil.get(baseUrl+"/data/api-u/BbEmployee/findBbEmployeeByCurUser",userQueryParams, true);
|
if(StringUtils.isNotEmpty(strBbPersons)){//底库中有人员信息
|
JSONArray userList = JSONArray.parseArray(strBbPersons);
|
if(userList !=null && userList.size()>0){
|
String userParentOrgId = null;
|
for(Object orgObj: orgList){
|
if(params.get("orgById").equals(((JSONObject)orgObj).getString("id"))){
|
userParentOrgId = ((JSONObject)orgObj).getString("parentId");
|
}
|
}
|
if(StringUtils.isNotEmpty(userParentOrgId))
|
setPlatOrgTreeUser(userParentOrgId, orgList, userList, resultList);
|
}
|
}
|
}
|
}
|
|
return resultList;
|
}
|
|
/**
|
* 保存任务布控人员
|
* 1.获取已布控人员列表
|
* 2.获取删除人员
|
* 3.获取新增人员
|
* @param map
|
*/
|
@Override
|
@Transactional
|
public String saveTaskUser(Map<String, Object> map) {
|
String result = "";
|
Map<String, Object> oldMap = new HashMap<>();
|
Map<String, Object> newMap = new HashMap<>();
|
|
JSONObject jsonObj = JsonUtil.mapToJson(map);
|
if(jsonObj !=null && jsonObj.get("taskId")!=null){
|
String taskId = jsonObj.get("taskId").toString();
|
JSONArray userList = jsonObj.getJSONArray("userList");//userList的size可以是0，表示清除了任务内的人员
|
log.info("taskId:"+taskId+"userList:"+userList);
|
Map<String, Object> queryParam = new HashMap<>();
|
queryParam.put("taskId", taskId);
|
List<TaskUser> taskUsers = taskUserDao.findAll(queryParam);//任务内已布控人员
|
|
for(TaskUser taskUser : taskUsers){
|
oldMap.put(taskUser.getId(), taskUser);
|
}
|
for(Object curObj : userList){
|
JSONObject curJson = (JSONObject)curObj;
|
String id = curJson.getString("id");
|
newMap.put(id,curObj);//保存时的新集合
|
if(!oldMap.containsKey(id)){
|
//新增的人员，解析后insert
|
TaskUser taskUser = new TaskUser();
|
if(StringUtils.isEmpty(id)) {
|
taskUser.setId(UUID.randomUUID().toString());
|
}
|
taskUser.setImgUrl(curJson.getString("imgUrl"));
|
taskUser.setTaskId(curJson.getString("taskId"));
|
taskUserDao.insert(taskUser);
|
}
|
}
|
for(TaskUser taskUser : taskUsers){
|
if(!newMap.containsKey(taskUser.getId())){//已删除的人员
|
taskUserDao.deleteTaskUser(taskUser);
|
}
|
}
|
|
}
|
|
|
return result;
|
}
|
|
private void setPlatOrgTreeUser(String parentId, JSONArray allOrgs, JSONArray allUsers, List list){
|
allOrgs.forEach(org->{
|
JSONObject jsonOrg = (JSONObject)org;
|
|
if(parentId.equals(jsonOrg.getString("parentId"))){//当前人组织下的组织机构
|
JSONObject curMenu = new JSONObject();
|
curMenu.put("id",jsonOrg.getString("id"));
|
curMenu.put("type", "MENU");
|
curMenu.put("userInfo", jsonOrg.getString("name"));
|
|
List child = new ArrayList();
|
curMenu.put("child",child);
|
setPlatOrgTreeUser(jsonOrg.getString("id"), allOrgs, allUsers, child);
|
|
list.add(curMenu);
|
}
|
});
|
allUsers.forEach(user->{
|
JSONObject jsonUser = (JSONObject)user;
|
if(parentId.equals(jsonUser.getString("orgId"))){
|
JSONObject userMenu = new JSONObject();
|
userMenu.put("id", jsonUser.getString("id"));
|
userMenu.put("type","");
|
String showName = "";
|
TaskUserInfoVo userInfo = new TaskUserInfoVo();
|
if(StringUtils.isNotEmpty(jsonUser.getString("name")))
|
showName += jsonUser.getString("name");
|
if(StringUtils.isNotEmpty(jsonUser.getString("gender"))){
|
showName += "/" + jsonUser.getString("gender");
|
userInfo.setSex(jsonUser.getString("gender") == "男"? 1:0);
|
}else{
|
userInfo.setSex(1);
|
}
|
|
if(StringUtils.isNotEmpty(jsonUser.getString("cardId")))
|
showName += "/" + jsonUser.getString("cardId");
|
if(StringUtils.isNotEmpty(jsonUser.getString("phone")))
|
showName += "/" + jsonUser.getString("phone");
|
|
userInfo.setId(jsonUser.getString("id"));
|
userInfo.setUsername(jsonUser.getString("name"));
|
userInfo.setIdCard(jsonUser.getString("cardId"));
|
userInfo.setMobile(jsonUser.getString("phone"));
|
userInfo.setImgUrl(jsonUser.getString("photos"));
|
|
if(showName.startsWith("/"))
|
showName = showName.substring(1);
|
userMenu.put("userInfo", showName);//姓名
|
userMenu.put("icon", jsonUser.getString("photos"));//人脸图片
|
userMenu.put("child", Collections.emptyList());
|
userMenu.put("detail", userInfo);
|
list.add(userMenu);
|
}
|
});
|
}
|
}
|
